|
@@ -193,7 +193,8 @@ namespace MIVA
|
|
|
// 查询数据
|
|
|
vector<vector<std::string>> sqlRet;
|
|
|
PIDSClientResultMsg clentResultMsg;
|
|
|
-
|
|
|
+ clentResultMsg.Train = 04;
|
|
|
+ clentResultMsg.TrainLine = 01;
|
|
|
SqlWriter sqlSelect("SELECT CarId,Grade,Num FROM MIVA_DB.`CarData`");
|
|
|
sqlSelect << sqlRet;
|
|
|
if(sqlRet.empty()){
|
|
@@ -216,7 +217,7 @@ namespace MIVA
|
|
|
// 传输至PIS系统
|
|
|
struct sockaddr addrDst;
|
|
|
makeAddr(&addrDst,this->PIS_ip.c_str(),this->PIS_port);//UDP数据发送地址
|
|
|
- this->m_udpClient->send((char *)data,&addrDst, sizeof(struct sockaddr_in));
|
|
|
+ this->m_udpClient->send((char *)data,48,&addrDst, sizeof(struct sockaddr_in));
|
|
|
|
|
|
// 传输至Netty端
|
|
|
if(this->m_tcpClient->alive()){
|
|
@@ -333,7 +334,7 @@ namespace MIVA
|
|
|
uint32_t UserApp::DataCalculation(uint32_t noLoad, uint32_t dynamicLoad, int num)
|
|
|
{
|
|
|
uint32_t result;
|
|
|
-
|
|
|
+
|
|
|
|
|
|
return result;
|
|
|
}
|