1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
| #ifndef SLAVECTRL_H
| #define SLAVECTRL_H
|
| #include <qthread.h>
| #include <QDebug>
| #include <QMutex>
| #include <QTcpServer>
| #include <QTcpSocket>
| #include "WorkForm/working_page.h"
|
| typedef struct _MASTER_CMD_
| {
| quint16 CMD;
| quint8 RecState;
| quint8 Cid1;
| quint8 Cid2;
| quint8 Alarm;
| }MASTER_CMD;
|
| class SlaveCtrl :public QThread
| {
| Q_OBJECT
|
| public:
| SlaveCtrl(Working_Page *page=0);
| virtual void run();
| ~SlaveCtrl();
|
| public:
| Working_Page *work_page;
| enum CMD_TYPE {
| Heartbea = 0x0A01,
| ExitSlave,
| EnterSlave,
| GetDischargeParam,
| SetDischargeParam, //0A05
| GetCellData,
| GetFileInfo,
| GetFile,
| SetChargeParam,
| GetChargeParam, //0A0A
| StartDischarge,
| PausetDischarge,
|
| GetDischargeData,
| StartCharge,
| PauseCharge, //0A0F
|
| GetChargeData, //0A10
| GetAdjustData,
| SetAdjustParm,
| Adjust_StartDischarge,
| Adjust_StartCharge,
| Adjust_Stop, //0A15
| EnterHome,
| GetCycleParam,
| SetCycleParam,
| NewBatt, //0A19 设置电池组名
| ChangedBatt, //0A1A
| DelBatt,
|
| StopDischarge,
| StopCharge,
| ClearAlarm,
| StartCycle,
| PauseCycle, //0A20
| StopCycle,
| GetBattName, //0A22 获取电池组列表
| GetFileName,
| GetSelectFile,
|
| SetTKQState,
| SetFanState,
| A27,
| A28,
| A29,
| GetVersion //0A2A
| };
|
| enum RTN_TYPE {
| SUCCEED = 0,
| LEN_ERR,
| CRC_ERR,
| SLAVEMODE_ERR,
| FILE_DATA_ERR,
| START_ERR,
| OTHER_ERR,
| SYSTEM_WORKING
| };
|
| static void setMasterCmd(CMD_TYPE CMD, quint8 status=0, quint8 Cid1=0, quint8 Cid2=0, quint8 arm=0);
| bool isConnect(void);
| void sentClientConnect(const QString &hostName, quint16 port);
| void Restartlisten(void);
|
| private:
| quint8 waitRecvCnt;
| QTcpServer *tcpServer;
| QTcpSocket *tcpSocket;
| bool IF_CLOSEServer;
| bool IF_CLOSEClient;
| quint8 ServerFlag;
|
| quint8 ClientFlag;
| QTcpSocket *tcpClient;
| QString ClienthostName;
| quint16 Clientport;
|
| private:
| bool CheckLen(FRAME_DATA *recv);
| bool CheckSYNCode(FRAME_DATA *recv);
| bool CheckCRC(FRAME_DATA *recv);
| bool ReadFrameHead(FRAME_DATA *recv, FRAME_DATA *Sent);
| bool WriteFrameData(FRAME_DATA *Sent);
| bool ReadFrameData(FRAME_DATA &recv, FRAME_DATA &Sent);
|
| quint16 getMonData(quint8 *info, quint16 MonNum);
| //quint16 getAdjData(quint8 *info);
| quint16 getTestData(quint8 *info);
| quint8 *getFileDataHead(FILE_LIST_DATA &data,TEST_DATA_INFO &test_info, quint8 total, quint8 Index);
| quint16 getPageFileData(FRAME_DATA &recv, FRAME_DATA &Sent);
| quint16 getFileSmallBlock(FRAME_DATA &recv, FRAME_DATA &Sent);
| quint16 getBattName(FRAME_DATA &recv, FRAME_DATA &Sent);
| quint16 getfileName(FRAME_DATA &recv, FRAME_DATA &Sent);
| quint16 getSelectFile(FRAME_DATA &recv, FRAME_DATA &Sent);
| void SaveTestParam(const QString &fname,TEST_PARAM_XML &test_param);
| void NewBattFile(quint8 *info);
| bool SelectBatt(quint8 *info);
| void DeleteBatt(quint8 *info);
|
| void SlaveClearHeart();
| void SlaveDisposeCMD(FRAME_DATA &recv, FRAME_DATA &Sent);
| void SlaveSentFrame(FRAME_DATA &recv, FRAME_DATA &Sent);
| void SlaveResponse(FRAME_DATA &recv, FRAME_DATA &Sent);
| void SlaveMode(FRAME_DATA &recv, FRAME_DATA &Sent);
|
| bool MasterSentFrame(MASTER_CMD cmd_data);
| void MasterDisposeCMD(FRAME_DATA &recv);
| void MasterMode(FRAME_DATA &recv, FRAME_DATA &Sent);
|
| void setTestCommParam(TEST_PARAM_XML &test_param, void *comm_param);
| void getTestCommParam(TEST_PARAM_XML &test_param, void *comm_param);
|
| void dataReceived();//解析数据
| quint16 getVersion(FRAME_DATA &recv, FRAME_DATA &Sent);
|
| signals:
| void sendStart(int,QString);
| void SendCurrAdjCMD(int,int);
| void SendInterface(int);
| void sendParam(int);
|
|
| protected slots:
| void deleteSocket();
| };
|
| #endif // RS485DRIVER_PC_H
|
|
