icpdasprocess.cpp 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578
  1. #include "stdafx.h"
  2. #include "rtuprocess.h"
  3. #include "Global.h"
  4. #include "struct.h"
  5. #include "NoticeQueue.h"
  6. DWORD g_dwIcpdasVariantTick = 0;
  7. HANDLE g_ICPDASRequestThread = NULL;
  8. HANDLE g_ICPDASResponseThread = NULL;
  9. DWORD g_dwICPDASVariantTick = 0;
  10. CRITICAL_SECTION g_csIcpdasReadOneData;
  11. //icpdas动态库输出函数
  12. HINSTANCE g_hICPDASLibModule = NULL;
  13. ICPDAS_DLLInitCom pICPDAS_DLLInitCom = NULL;
  14. ICPDAS_DLLInit pICPDAS_DLLInit = NULL;
  15. ICPDAS_DLLUnInit pICPDAS_DLLUnInit = NULL;
  16. ICPDAS_DLLRequestStatusData pICPDAS_DLLRequestStatusData = NULL;
  17. ICPDAS_DLLWrCom pICPDAS_DLLWrCom = NULL;
  18. int IcpdasResponseValue();
  19. int IcpdasCommandSend();
  20. void UnInitIcpdasDll();
  21. int IcpdasSingleResponseData(char chDevUid[20], int iVarID, char chMsg[80]);
  22. int GetIcpdasFromIni(char chCmd[32], BYTE *Start, BYTE* byWithAddrFlag, BYTE *pFuncCode);
  23. BOOL LoadIcpdasDll(CString strpath)
  24. {
  25. char strFile[256] = {0};
  26. g_hICPDASLibModule = NULL;
  27. sprintf(strFile, "%s\\dll\\icpdas.dll", strpath);
  28. g_hICPDASLibModule = AfxLoadLibrary(strFile);
  29. InitializeCriticalSection( &g_csIcpdasReadOneData );
  30. //RTU 动态库初始化
  31. if (NULL != g_hICPDASLibModule)
  32. {
  33. pICPDAS_DLLInitCom =( ICPDAS_DLLInitCom)::GetProcAddress(g_hICPDASLibModule, "ICPDAS_DLLInitCom");
  34. pICPDAS_DLLInit = (ICPDAS_DLLInit)::GetProcAddress(g_hICPDASLibModule, "ICPDAS_DLLInit");
  35. pICPDAS_DLLUnInit = (ICPDAS_DLLUnInit)::GetProcAddress(g_hICPDASLibModule, "ICPDAS_DLLUnInit");
  36. pICPDAS_DLLRequestStatusData = (ICPDAS_DLLRequestStatusData)::GetProcAddress(g_hICPDASLibModule, "ICPDAS_DLLRequestStatusData");
  37. pICPDAS_DLLWrCom = (ICPDAS_DLLWrCom)::GetProcAddress(g_hICPDASLibModule, "ICPDAS_DLLWrCom");
  38. return TRUE;
  39. }
  40. else
  41. {
  42. return FALSE;
  43. }
  44. }
  45. BOOL InitIcpdasComm(int iAddr, int iPort, int iBaudrate, int iDataBit, int iStopBit, int iParity, int iIntervals)
  46. {
  47. if (pICPDAS_DLLInitCom(iAddr,iPort, iBaudrate, iDataBit, iStopBit, iParity, iIntervals))//初始化串口
  48. {
  49. return TRUE;
  50. }
  51. else
  52. {
  53. return FALSE;
  54. }
  55. }
  56. int IcpdasRequestData(
  57. int nIndex,
  58. SETBASEPARAM SetBasePara,
  59. int nDataLen,
  60. int nPort,
  61. int nDevAddr,
  62. char chDevUid[20],
  63. int iVarID,
  64. char chRs232cmd[32])
  65. {
  66. char chMsg[80] = {0};
  67. BYTE Start= 0x0;//起始位
  68. BYTE StartAddr[MAX_ID] = {0};
  69. BYTE FuncCode[MAX_ID] = {0};
  70. BYTE byWithAddrFlag;
  71. int nDeviceIndex = -1, nVarIndex = -1;
  72. BOOL bFind = FindVar(chDevUid, iVarID, nDeviceIndex, nVarIndex);
  73. if( bFind == FALSE ) return -1;
  74. CDevice *pDev = g_pDevicesManager->m_Devices[nDeviceIndex];
  75. CBaseVar *pBaseVar = pDev->m_Vars[nVarIndex];
  76. char szMsg[80] = {0};
  77. sprintf((char*)StartAddr, "%02X", SetBasePara.nStartAddr);//modify by 2012.05.22
  78. GetIcpdasFromIni(chRs232cmd, &Start, &byWithAddrFlag,FuncCode);
  79. CString strIndex;
  80. if( 0 == stricmp((char *)FuncCode, "#AAN") )
  81. {
  82. strIndex.Format("%d", atoi(pBaseVar->m_strRs232Index));
  83. strcpy((char *)FuncCode, (char *)(LPCTSTR)strIndex);
  84. //LOG4C((LOG_NOTICE, "strIndex=%s, FuncCode=%s", strIndex, FuncCode));
  85. }
  86. if( nIndex == 0 )
  87. {
  88. if( pICPDAS_DLLInit(nPort, nDevAddr, Start, StartAddr,
  89. SetBasePara.nRegNum, FuncCode, nDataLen, byWithAddrFlag, szMsg)!=0)
  90. {
  91. return -1;
  92. }
  93. }
  94. else if( strlen(szMsg) == 0 )
  95. {
  96. if( pICPDAS_DLLInit(nPort, nDevAddr, Start, StartAddr,
  97. SetBasePara.nRegNum, FuncCode, nDataLen, byWithAddrFlag, szMsg)!=0)
  98. {
  99. return -1;
  100. }
  101. }
  102. return IcpdasSingleResponseData(chDevUid, iVarID, szMsg);
  103. }
  104. int IcpdasSingleResponseData(char chDevUid[20], int iVarID, char chMsg[80])
  105. {
  106. int nDeviceIndex = -1, nVarIndex = -1;
  107. BOOL bFind = FindVar(chDevUid, iVarID, nDeviceIndex, nVarIndex);
  108. if( bFind == FALSE ) return -1;
  109. CDevice *pDev = g_pDevicesManager->m_Devices[nDeviceIndex];
  110. CBaseVar *pBaseVar = pDev->m_Vars[nVarIndex];
  111. EnterCriticalSection(&g_csIcpdasReadOneData);
  112. pDev->m_dwOnlineTick = GetTickCount();
  113. LeaveCriticalSection(&g_csIcpdasReadOneData);
  114. DWORD nValue = 0;
  115. WORD wdValue = 0;
  116. double fCoef = pBaseVar->m_dbCoefficient;
  117. int nDataLen = pBaseVar->m_iDataLen/2;
  118. int nVarItemID = pBaseVar->m_nVarItemID;
  119. if( nVarItemID > 0 )//BIT位变量
  120. {
  121. int nStartBit = pBaseVar->m_nStartBit;
  122. int nEndBit = pBaseVar->m_nEndBit;
  123. int nStartReg, nEndReg;
  124. if( nEndBit - nStartBit < 7 ) // 一般告警状态会这样子定义,Modbus Ascii码暂时没有碰到,没有经过调试,待测试
  125. {
  126. if( nDataLen == 1 )
  127. {
  128. char chBuffer[8] = {0};
  129. memset(chBuffer, 0, sizeof(chBuffer));
  130. BYTE byValue = (AsciiToBYTE(chMsg[0]) << 4) | ( AsciiToBYTE(chMsg[0 + 1]) & 0x00FF );
  131. DigitToBinary(byValue, chBuffer, 8) ;
  132. CString strTemp;
  133. switch( nEndBit - nStartBit )
  134. {
  135. case 0:
  136. strTemp.Format("%c", chBuffer[nStartBit]);
  137. break;
  138. case 1:
  139. strTemp.Format("%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1]);
  140. break;
  141. case 2:
  142. strTemp.Format("%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1], chBuffer[nStartBit + 2]);
  143. break;
  144. case 3:
  145. strTemp.Format("%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1],
  146. chBuffer[nStartBit + 2], chBuffer[nStartBit +3]);
  147. break;
  148. case 4:
  149. strTemp.Format("%c%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1],
  150. chBuffer[nStartBit + 2], chBuffer[nStartBit + 3], chBuffer[nStartBit + 4]);
  151. break;
  152. case 5:
  153. strTemp.Format("%c%c%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1], chBuffer[nStartBit + 2],
  154. chBuffer[nStartBit + 3], chBuffer[nStartBit + 4], chBuffer[nStartBit + 5]);
  155. break;
  156. case 6:
  157. strTemp.Format("%c%c%c%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1], chBuffer[nStartBit + 2],
  158. chBuffer[nStartBit + 3], chBuffer[nStartBit + 4], chBuffer[nStartBit + 5], chBuffer[nStartBit + 6]);
  159. break;
  160. default:
  161. LOG4C((LOG_NOTICE, "起始位与终止位不对",pDev->m_strDeviceName, pBaseVar->m_strDesc));
  162. }
  163. nValue = atoi(strTemp);
  164. //strTemp.Format("%d",
  165. }
  166. else if( nDataLen == 2 )
  167. {
  168. char chBuffer[16] = {0};
  169. //chMsg[0] = 0x00;
  170. //chMsg[2] = 0x00;
  171. //chMsg[2] = 0x0E;
  172. //chMsg[3] = 0x0F;
  173. WORD wValue = ( ( (AsciiToBYTE(chMsg[0]) << 4) | ( AsciiToBYTE(chMsg[1]) & 0x00FF ) ) << 8 ) |
  174. ( ( (AsciiToBYTE(chMsg[2]) << 4) | ( AsciiToBYTE(chMsg[3]) & 0x00FF ) ) & 0x0000FFFF );
  175. DigitToBinary(wValue, chBuffer, 16) ;
  176. CString strTemp;
  177. switch( nEndBit - nStartBit )
  178. {
  179. case 0:
  180. strTemp.Format("%c", chBuffer[nStartBit]);
  181. break;
  182. case 1:
  183. strTemp.Format("%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1]);
  184. break;
  185. case 2:
  186. strTemp.Format("%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1], chBuffer[nStartBit + 2]);
  187. break;
  188. case 3:
  189. strTemp.Format("%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1],
  190. chBuffer[nStartBit + 2], chBuffer[nStartBit +3]);
  191. break;
  192. case 4:
  193. strTemp.Format("%c%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1],
  194. chBuffer[nStartBit + 2], chBuffer[nStartBit + 3], chBuffer[nStartBit + 4]);
  195. break;
  196. case 5:
  197. strTemp.Format("%c%c%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1], chBuffer[nStartBit + 2],
  198. chBuffer[nStartBit + 3], chBuffer[nStartBit + 4], chBuffer[nStartBit + 5]);
  199. break;
  200. case 6:
  201. strTemp.Format("%c%c%c%c%c%c%c", chBuffer[nStartBit], chBuffer[nStartBit + 1], chBuffer[nStartBit + 2],
  202. chBuffer[nStartBit + 3], chBuffer[nStartBit + 4], chBuffer[nStartBit + 5], chBuffer[nStartBit + 6]);
  203. break;
  204. default:
  205. LOG4C((LOG_NOTICE, "起始位与终止位不对",pDev->m_strDeviceName, pBaseVar->m_strDesc));
  206. }
  207. nValue = atoi(strTemp);
  208. }
  209. }
  210. // 特殊变量处理(例如,一个命令返回两个变量的情况)
  211. else if( nEndBit - nStartBit == 7 ) // 1个字节的情况
  212. {
  213. nStartReg = (int)nStartBit / 8;
  214. nEndReg = (int)(nEndBit + 1) / 8;
  215. nValue = (AsciiToBYTE(chMsg[nStartReg]) << 4) | ( AsciiToBYTE(chMsg[nStartReg + 1]) & 0x00FF );
  216. }
  217. else if( nEndBit - nStartBit == 15 ) // 2个字节的情况
  218. {
  219. nStartReg = (int)nStartBit / 8;
  220. nEndReg = (int)(nEndBit + 1) / 8;
  221. nValue = ( ( (AsciiToBYTE(chMsg[nStartReg]) << 4) | ( AsciiToBYTE(chMsg[nStartReg + 1]) & 0x00FF ) ) << 8 ) |
  222. ( ( (AsciiToBYTE(chMsg[nStartReg + 2]) << 4) | ( AsciiToBYTE(chMsg[nStartReg + 3]) & 0x00FF ) ) & 0x0000FFFF );
  223. }
  224. EnterCriticalSection( &g_csIcpdasReadOneData );
  225. pBaseVar->m_dbData = (double)(nValue * fCoef);
  226. if( pBaseVar->m_nRearm != 0 )
  227. {
  228. pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
  229. }
  230. LeaveCriticalSection( &g_csIcpdasReadOneData );
  231. //LOG4C((LOG_NOTICE, "变量:%s, 值=%d", pBaseVar->m_strDesc, (int)pBaseVar->m_dbData));
  232. }
  233. else
  234. {
  235. // 联合类型变量做特殊处理
  236. if( pBaseVar->m_nVarTypeID >= UNION_TYPE_MIN_ID && pBaseVar->m_nVarTypeID <= UNION_TYPE_MAX_ID )
  237. {
  238. if( nDataLen == 2 )
  239. {
  240. //int类型
  241. union __UNION_VAR_INT{
  242. char ch[2];
  243. int value;
  244. }unionVarInt;
  245. unionVarInt.ch[0] = chMsg[1];
  246. unionVarInt.ch[1] = chMsg[0];
  247. EnterCriticalSection( &g_csIcpdasReadOneData );
  248. pBaseVar->m_dbData = (double)(unionVarInt.value * fCoef);
  249. if( pBaseVar->m_nRearm != 0 )
  250. {
  251. pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
  252. }
  253. LeaveCriticalSection( &g_csIcpdasReadOneData );
  254. //TRACE2("联合类型变量ID%d, 值=%d\r\n", iVarID, unionVarInt.value);
  255. }
  256. else if( nDataLen == 4 )
  257. {
  258. //float类型
  259. union __UNION_VAR_FLOAT{
  260. char ch[4];
  261. float value;
  262. }unionVarFloat;
  263. unionVarFloat.ch[0] = chMsg[3];
  264. unionVarFloat.ch[1] = chMsg[2];
  265. unionVarFloat.ch[2] = chMsg[1];
  266. unionVarFloat.ch[3] = chMsg[0];
  267. EnterCriticalSection( &g_csIcpdasReadOneData );
  268. pBaseVar->m_dbData = (double)(unionVarFloat.value * fCoef);
  269. if( pBaseVar->m_nRearm != 0 )
  270. {
  271. pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
  272. }
  273. LeaveCriticalSection( &g_csIcpdasReadOneData );
  274. //TRACE2("联合类型变量ID%d, 值=%.1f\r\n", iVarID, unionVarFloat.value);
  275. }
  276. else if( nDataLen == 8 )
  277. {
  278. //double类型
  279. union __UNION_VAR_DOUBLE{
  280. char ch[8];
  281. double value;
  282. }unionVarDouble;
  283. unionVarDouble.ch[0] = chMsg[7];
  284. unionVarDouble.ch[1] = chMsg[6];
  285. unionVarDouble.ch[2] = chMsg[5];
  286. unionVarDouble.ch[3] = chMsg[4];
  287. unionVarDouble.ch[4] = chMsg[3];
  288. unionVarDouble.ch[5] = chMsg[2];
  289. unionVarDouble.ch[6] = chMsg[1];
  290. unionVarDouble.ch[7] = chMsg[0];
  291. EnterCriticalSection( &g_csIcpdasReadOneData );
  292. pBaseVar->m_dbData = (double)(unionVarDouble.value * fCoef);
  293. if( pBaseVar->m_nRearm != 0 )
  294. {
  295. pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
  296. }
  297. LeaveCriticalSection( &g_csIcpdasReadOneData );
  298. //TRACE2("联合类型变量ID%d, 值=%.1f\r\n", iVarID, unionVarDouble.value);
  299. }
  300. }
  301. else
  302. {
  303. CString str;
  304. WORD wdValue;
  305. switch( nDataLen )
  306. {
  307. case 1:
  308. nValue = atoi(chMsg);
  309. break;
  310. case 2:
  311. memcpy(&wdValue, chMsg, sizeof(WORD));
  312. nValue = ntohs(wdValue);
  313. break;
  314. case 3: // 一般为字符串类型,不作处理
  315. LOG4C((LOG_NOTICE, "保留,暂时没有用到"));
  316. break;
  317. case 4: // 保留,暂时不知道什么处理
  318. LOG4C((LOG_NOTICE, "保留,暂时没有用到"));
  319. break;
  320. case 5: // 一般为字符串类型,不作处理
  321. LOG4C((LOG_NOTICE, "保留,暂时没有用到"));
  322. break;
  323. case 6: // 一般为字符串类型,不作处理
  324. LOG4C((LOG_NOTICE, "保留,暂时没有用到"));
  325. break;
  326. case 7: // 7017
  327. //str.Format("%s", chMsg);
  328. LOG4C((LOG_NOTICE, "保留,暂时没有用到"));
  329. break;
  330. case 8: // 保留,暂时没有用到
  331. LOG4C((LOG_NOTICE, "保留,暂时没有用到"));
  332. break;
  333. }
  334. //LOG4C((LOG_NOTICE, "pBaseVar->m_iDataLen = %d", pBaseVar->m_iDataLen));
  335. if( pBaseVar->m_iDataLen == 7 )
  336. {
  337. str.Format("%s", chMsg);
  338. EnterCriticalSection( &g_csIcpdasReadOneData );
  339. if( pBaseVar->m_nMaxValues != 0 || pBaseVar->m_nMinValues != 0 ||
  340. pBaseVar->m_nMaxConvtRate != 0 || pBaseVar->m_nMinConvtRate != 0 )
  341. {
  342. double fScale = (double)(pBaseVar->m_nMaxConvtRate - pBaseVar->m_nMinConvtRate) /
  343. (double)(pBaseVar->m_nMaxValues - pBaseVar->m_nMinValues);
  344. pBaseVar->m_dbData = atof(str) *
  345. fCoef *
  346. fScale;
  347. }
  348. else
  349. {
  350. pBaseVar->m_dbData = (double)(atof(str) * fCoef);
  351. }
  352. if( pBaseVar->m_nRearm != 0 )
  353. {
  354. pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
  355. }
  356. pDev->m_dwOnlineTick = GetTickCount();
  357. LeaveCriticalSection( &g_csIcpdasReadOneData );
  358. //LOG4C((LOG_NOTICE, "desc = %s, data = %d", pBaseVar->m_strDesc, (int)pBaseVar->m_dbData));
  359. return 0;
  360. }
  361. EnterCriticalSection( &g_csIcpdasReadOneData );
  362. if( pBaseVar->m_nMaxValues != 0 || pBaseVar->m_nMinValues != 0 ||
  363. pBaseVar->m_nMaxConvtRate != 0 || pBaseVar->m_nMinConvtRate != 0 )
  364. {
  365. double fScale = (double)(pBaseVar->m_nMaxConvtRate - pBaseVar->m_nMinConvtRate) /
  366. (double)(pBaseVar->m_nMaxValues - pBaseVar->m_nMinValues);
  367. pBaseVar->m_dbData = nValue *
  368. fCoef *
  369. fScale;
  370. }
  371. else
  372. {
  373. pBaseVar->m_dbData = (double)(nValue * fCoef);
  374. }
  375. if( pBaseVar->m_nRearm != 0 )
  376. {
  377. pBaseVar->m_dbData = pBaseVar->m_dbData + pBaseVar->m_nRearm;
  378. }
  379. LeaveCriticalSection( &g_csIcpdasReadOneData );
  380. //g_IcpdasReadOneData.dbData = (double)(nValue * fCoef);
  381. //TRACE2("普通变量ID%d, 值=%d\r\n", iVarID, g_IcpdasReadOneData.dbData);
  382. }
  383. }
  384. EnterCriticalSection(&g_csIcpdasReadOneData);
  385. pDev->m_dwOnlineTick = GetTickCount();
  386. LeaveCriticalSection(&g_csIcpdasReadOneData);
  387. return 0;
  388. }
  389. void UnInitIcpdasDll()
  390. {
  391. if (g_hICPDASLibModule != NULL && ( NULL != pICPDAS_DLLUnInit ))
  392. {
  393. pICPDAS_DLLUnInit();
  394. }
  395. DeleteCriticalSection( &g_csIcpdasReadOneData );
  396. if (g_hICPDASLibModule!= NULL)
  397. {
  398. AfxFreeLibrary(g_hICPDASLibModule);
  399. g_hICPDASLibModule = NULL;
  400. }
  401. }
  402. int GetIcpdasFromIni(char chCmd[32], BYTE *Start, BYTE* byWithAddrFlag, BYTE *pFuncCode)
  403. {
  404. CHAR strFile[MAX_FILE_LENGTH + 1] = "";
  405. CHAR strValue[MAX_VALUE_LENGTH + 1] = "";
  406. CHAR strValueAddrFlag[4] ="";
  407. wsprintf(strFile, "%s\\config\\icpdas.ini", g_strDirectory);
  408. //Database
  409. GetPrivateProfileString("CMD", chCmd, "", strValue, sizeof(strValue), strFile);
  410. GetPrivateProfileString("RESWITHADDR", chCmd, "", strValueAddrFlag, sizeof(strValueAddrFlag), strFile);
  411. Start[0] = strValue[0];
  412. byWithAddrFlag[0] = strValueAddrFlag[0];
  413. if (strcmp( strValue, "@AA") == 0)
  414. sprintf((char*)pFuncCode, "%02d", -1);
  415. else if (strcmp( strValue, "$AALS") == 0)
  416. memcpy(pFuncCode, strValue + 3, 2);
  417. else if (strcmp( strValue, "@AA(Data)") == 0)
  418. sprintf((char*)pFuncCode, "%02d", -1);
  419. else if( strcmp( strValue, "#AA1cDD") == 0 )
  420. memcpy(pFuncCode, strValue + 3, 4);
  421. else if( strcmp( strValue, "#AAN" ) == 0 )
  422. memcpy(pFuncCode, "#AAN", strlen("#AAN"));
  423. else
  424. sprintf((char*)pFuncCode, "%02C", strValue[3]);
  425. return 0;
  426. }
  427. int RequestWrIcpdasData(char chDevUid[20], int iVarID, double data)//用于请求写命令操作
  428. {
  429. int nDeviceIndex = -1, nVarIndex = -1;
  430. BOOL bFind = FindVar(chDevUid, iVarID, nDeviceIndex, nVarIndex);
  431. if( bFind == FALSE ) return -1;
  432. CDevice *pDev = g_pDevicesManager->m_Devices[nDeviceIndex];
  433. CBaseVar *pBaseVar = pDev->m_Vars[nVarIndex];
  434. char chTemp[80] = {0};
  435. char chMsg[80] = {0};
  436. BYTE Start= 0x0;//起始位
  437. BYTE StartAddr[MAX_ID] = {0};
  438. BYTE FuncCode[MAX_ID] = {0};
  439. BYTE byWithAddrFlag = 0;
  440. int nLen = 0;
  441. sprintf((char*)StartAddr, "%02X", pDev->m_iDevideaddr);//modify by 2012.05.22
  442. GetIcpdasFromIni((char *)(LPCTSTR)pBaseVar->m_strRs232cmd, &Start, &byWithAddrFlag,FuncCode);
  443. memcpy(chMsg, &Start, sizeof(Start));
  444. nLen += sizeof(Start);
  445. memcpy(chMsg + nLen, StartAddr, strlen((char *)StartAddr));
  446. nLen += strlen((char *)StartAddr);
  447. // 固定信息
  448. memcpy(chMsg + nLen, "1", 1);
  449. nLen += 1;
  450. double fCoef = pBaseVar->m_dbCoefficient;
  451. int nDataLen = pBaseVar->m_iDataLen;
  452. int nVarItemID = pBaseVar->m_nVarItemID;
  453. // 泓格I-7000系列为特殊协议只有BIT变量,这里只处理BIT位变量
  454. if( nVarItemID > 0 )//BIT位变量
  455. {
  456. int nStartBit = pBaseVar->m_nStartBit;
  457. int nEndBit = pBaseVar->m_nEndBit;
  458. if( nEndBit - nStartBit < 7 )
  459. {
  460. CString strTemp;
  461. CString strIndex;
  462. if( nDataLen == 1 )
  463. {
  464. switch( nEndBit - nStartBit )
  465. {
  466. case 0:
  467. strTemp.Format("%02d", (int)data);
  468. break;
  469. default:
  470. LOG4C((LOG_NOTICE, "起始位与终止位不对",pDev->m_strDeviceName, pBaseVar->m_strDesc));
  471. }
  472. //LOG4C((LOG_NOTICE, "RequestWrIcpdasData1 nLen=%d %s",nLen,chMsg ));
  473. strIndex.Format("%d", atoi(pBaseVar->m_strRs232Index));
  474. memcpy(chMsg + nLen, (char *)(LPCTSTR)strIndex, strIndex.GetLength());
  475. nLen += strIndex.GetLength();
  476. //LOG4C((LOG_NOTICE, "RequestWrIcpdasData2 nLen=%d %s",nLen,chMsg ));
  477. memcpy(chMsg + nLen, (char *)(LPCTSTR)strTemp, strTemp.GetLength());
  478. nLen += strTemp.GetLength();
  479. //LOG4C((LOG_NOTICE, "RequestWrIcpdasData3 nLen=%d %s %s",nLen,chMsg,strTemp ));
  480. }
  481. else
  482. {
  483. LOG4C((LOG_NOTICE, "注意,变量iVarID=%d 的 nDataLen != 1!",iVarID ));
  484. }
  485. }
  486. else
  487. {
  488. LOG4C((LOG_NOTICE, "注意,变量iVarID=%d 的 nEndBit-nStartBit >= 7!",iVarID ));
  489. }
  490. }
  491. else
  492. {
  493. LOG4C((LOG_NOTICE, "注意,变量iVarID=%d 的nVarItemID = 0!",iVarID ));
  494. }
  495. chMsg[nLen] = 0x0D;
  496. nLen++;
  497. if( pICPDAS_DLLWrCom(pDev->m_iPort, pDev->m_iDevideaddr, chMsg, nLen) == 0)
  498. {
  499. //LOG4C((LOG_NOTICE, "pICPDAS_DLLWrCom success! 串口%d, 地址%d",pDev->m_iPort, pDev->m_iDevideaddr));
  500. return 0;
  501. }
  502. else
  503. {
  504. LOG4C((LOG_NOTICE, "pICPDAS_DLLWrCom lost! 串口%d, 地址%d",pDev->m_iPort, pDev->m_iDevideaddr));
  505. return -1;
  506. }
  507. }