DBInterface.cpp 68 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650
  1. /*************************************************************
  2. /* Copyright (C), 2008-2010, StoneU Tech. Co., Ltd.
  3. /* 文件名: DBInterface.h
  4. /* 作者: Jesse
  5. /* 创建日期: 2010-08-02
  6. /* 版本号: V1.0
  7. /* 描述: 实现多种数据库的支持
  8. /* 其它:
  9. /* 主要类模块: CDBInterface
  10. /* 历史修改记录:
  11. 作者 时间 版本 描述
  12. Jesse 10/08/02 1.0 创建这个模块
  13. ***************************************************************/
  14. #include "stdafx.h"
  15. #include "DBInterface.h"
  16. #include "kernel.h"
  17. namespace DBInterface
  18. {
  19. CDBInterface* CDBInterface::m_pDBInterface = NULL;
  20. // 静态成员函数,提供全局访问的接口
  21. CDBInterface* CDBInterface::GetInstancePtr()
  22. {
  23. if( NULL == m_pDBInterface )
  24. {
  25. m_pDBInterface = new CDBInterface();
  26. }
  27. return m_pDBInterface;
  28. }
  29. // 释放资源
  30. void CDBInterface::Release()
  31. {
  32. if( m_pDBInterface )
  33. delete m_pDBInterface;
  34. m_pDBInterface = NULL;
  35. }
  36. // 设置数据库类型
  37. void CDBInterface::SetDBType(char *pDBType)
  38. {
  39. strcpy(m_chDBType, pDBType);
  40. }
  41. //得到时间计划
  42. INT CDBInterface::GetDatePlan( int nPlanType, CHAR *pPlanID, unsigned char nBufDate[7][24] )
  43. {//0:星期一 1:星期二 6:星期天
  44. CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
  45. list<string> list1, list2, list3, list4;
  46. list<string>::iterator it_list1, it_list2, it_list3, it_list4;
  47. sprintf(strSQLText, "select starttime, endtime, startweekofday, endweekofday " \
  48. "from t_plan_info where planid=\'%s\' and plantype = %d",
  49. pPlanID, nPlanType);
  50. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList4(strSQLText, list1, list2, list3, list4);
  51. if( list1.size() == 0 || list2.size() == 0 || list3.size() == 0 || list4.size() == 0 )
  52. {
  53. return 0;
  54. }
  55. if( nRet != -1 )
  56. {
  57. for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin();
  58. it_list1 != list1.end() && it_list2 != list2.end() && it_list3 != list3.end() && it_list4 != list4.end();
  59. it_list1++, it_list2++, it_list3++, it_list4++)
  60. {
  61. for( int i = atoi((*it_list3).c_str()); i < atoi((*it_list4).c_str()) + 1; i++ )
  62. {
  63. for( int j = atoi((*it_list1).c_str()); j < atoi((*it_list2).c_str()) + 1; j++ )
  64. {
  65. nBufDate[i][j] = 15;
  66. }
  67. }
  68. }
  69. }
  70. for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin();
  71. it_list1 != list1.end(), it_list2 != list2.end(), it_list3 != list3.end(), it_list4 != list4.end(); )
  72. {
  73. list1.erase(it_list1++);
  74. list2.erase(it_list2++);
  75. list3.erase(it_list3++);
  76. list4.erase(it_list4++);
  77. }
  78. return nRet;
  79. }
  80. //得到时间计划
  81. INT CDBInterface::GetDatePlan( int nPlanType, CHAR *pUid, int nVarID, unsigned char nBufDate[7][24] )
  82. {
  83. CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
  84. list<string> list1, list2, list3, list4;
  85. list<string>::iterator it_list1, it_list2, it_list3, it_list4;
  86. sprintf(strSQLText, "select starttime, endtime, startweekofday, endweekofday " \
  87. "from t_plan_info where uid=\'%s\' and varid = %d and plantype = %d",
  88. pUid, nVarID, nPlanType);
  89. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList4(strSQLText, list1, list2, list3, list4);
  90. if( list1.size() == 0 || list2.size() == 0 || list3.size() == 0 || list4.size() == 0 )
  91. {
  92. return 0;
  93. }
  94. if( nRet != -1 )
  95. {
  96. for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin();
  97. it_list1 != list1.end() && it_list2 != list2.end() && it_list3 != list3.end() && it_list4 != list4.end();
  98. it_list1++, it_list2++, it_list3++, it_list4++ )
  99. {
  100. for( int i = atoi((*it_list3).c_str()); i < atoi((*it_list4).c_str()) + 1; i++ )
  101. {
  102. for( int j = atoi((*it_list1).c_str()); j < atoi((*it_list2).c_str()) + 1; j++ )
  103. {
  104. nBufDate[i][j] = 15;
  105. }
  106. }
  107. }
  108. }
  109. for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin();
  110. it_list1 != list1.end(), it_list2 != list2.end(), it_list3 != list3.end(), it_list4 != list4.end(); )
  111. {
  112. list1.erase(it_list1++);
  113. list2.erase(it_list2++);
  114. list3.erase(it_list3++);
  115. list4.erase(it_list4++);
  116. }
  117. return nRet;
  118. }
  119. //获取变量
  120. INT CDBInterface::GetVarInfo()
  121. {
  122. CHAR strSQLText[MAX_SQL_LENGTH * 2] = {0};
  123. list<string> list_var_id, list_set_value, list_var_name, list_uid, list_upper_limit;
  124. list<string> list_lower_limit, list_normal_state, list_identify_time, list_redetect_time;
  125. list<string> list_normal_is_notice, list_warn_level, list_snmp_oid, list_fields, list_description;
  126. list<string> list_max_values, list_min_values, list_max_convtrate, list_min_convtrate, list_is_save;
  127. list<string> list_collect_freq, list_var_type_id, list_readonly, list_is_dde, list_address, list_unit;
  128. list<string> list_reccurve, list_register_num, list_child_id, list_var_item_id, list_rearm, list_offsets;
  129. list<string> list_funcid, list_data_len, list_coefficient, list_realtimeflag;
  130. list<string> list_rs232_cmd, list_rs232_type, list_rs232_index;
  131. list<string> list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5;
  132. list<string> list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10;
  133. list<string> list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5;
  134. list<string> list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10;
  135. list<string> list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5;
  136. list<string> list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10;
  137. list<string>::iterator it_var_id, it_set_value, it_var_name, it_uid, it_upper_limit;
  138. list<string>::iterator it_lower_limit, it_normal_state, it_identify_time, it_redetect_time;
  139. list<string>::iterator it_normal_is_notice, it_warn_level, it_snmp_oid, it_fields, it_description;
  140. list<string>::iterator it_max_values, it_min_values, it_max_convtrate, it_min_convtrate, it_is_save;
  141. list<string>::iterator it_collect_freq, it_var_type_id, it_readonly, it_is_dde, it_address, it_unit;
  142. list<string>::iterator it_reccurve, it_register_num, it_child_id, it_var_item_id, it_rearm, it_offsets;
  143. list<string>::iterator it_funcid, it_data_len, it_coefficient, it_realtimeflag;
  144. list<string>::iterator it_rs232_cmd, it_rs232_type, it_rs232_index;
  145. list<string>::iterator it_str_reserved1, it_str_reserved2, it_str_reserved3, it_str_reserved4, it_str_reserved5;
  146. list<string>::iterator it_str_reserved6, it_str_reserved7, it_str_reserved8, it_str_reserved9, it_str_reserved10;
  147. list<string>::iterator it_int_reserved1, it_int_reserved2, it_int_reserved3, it_int_reserved4, it_int_reserved5;
  148. list<string>::iterator it_int_reserved6, it_int_reserved7, it_int_reserved8, it_int_reserved9, it_int_reserved10;
  149. list<string>::iterator it_bool_reserved1, it_bool_reserved2, it_bool_reserved3, it_bool_reserved4, it_bool_reserved5;
  150. list<string>::iterator it_bool_reserved6, it_bool_reserved7, it_bool_reserved8, it_bool_reserved9, it_bool_reserved10;
  151. if (!_stricmp(m_chDBType, "SQL SERVER"))
  152. {
  153. sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \
  154. "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \
  155. "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \
  156. "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \
  157. "var_item_id, rearm, [offsets], funcid, datalen, coefficient, realtimeflag, " \
  158. "rs232cmd, rs232type, rs232index, " \
  159. "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \
  160. "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \
  161. "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \
  162. "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \
  163. "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \
  164. "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \
  165. "from t_dev_variant order by id");
  166. }
  167. else if (!_stricmp(m_chDBType, "ACCESS97"))
  168. {
  169. sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \
  170. "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \
  171. "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \
  172. "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \
  173. "var_item_id, rearm, [offsets], funcid, datalen, coefficient, realtimeflag, " \
  174. "rs232cmd, rs232type, rs232index, " \
  175. "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \
  176. "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \
  177. "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \
  178. "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \
  179. "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \
  180. "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \
  181. "from t_dev_variant order by id");
  182. }
  183. else if (!_stricmp(m_chDBType, "ACCESS2000"))
  184. {
  185. sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \
  186. "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \
  187. "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \
  188. "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \
  189. "var_item_id, rearm, [offsets], funcid, datalen, coefficient, realtimeflag, " \
  190. "rs232cmd, rs232type, rs232index, " \
  191. "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \
  192. "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \
  193. "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \
  194. "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \
  195. "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \
  196. "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \
  197. "from t_dev_variant order by id");
  198. }
  199. else if(!_stricmp(m_chDBType, "PGSQL"))
  200. {
  201. sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \
  202. "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \
  203. "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \
  204. "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \
  205. "var_item_id, rearm, offsets, funcid, datalen, coefficient, realtimeflag, " \
  206. "rs232cmd, rs232type, rs232index, " \
  207. "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \
  208. "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \
  209. "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \
  210. "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \
  211. "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \
  212. "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \
  213. "from t_dev_variant order by id");
  214. }
  215. //LOG4C((LOG_NOTICE, "%s", strSQLText));
  216. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList68(strSQLText
  217. ,list_var_id, list_set_value, list_var_name, list_uid, list_upper_limit
  218. ,list_lower_limit, list_normal_state, list_identify_time, list_redetect_time
  219. ,list_normal_is_notice, list_warn_level, list_snmp_oid, list_fields, list_description
  220. ,list_max_values, list_min_values, list_max_convtrate, list_min_convtrate, list_is_save
  221. ,list_collect_freq, list_var_type_id, list_readonly, list_is_dde, list_address, list_unit
  222. ,list_reccurve, list_register_num, list_child_id, list_var_item_id, list_rearm, list_offsets
  223. ,list_funcid, list_data_len, list_coefficient, list_realtimeflag
  224. ,list_rs232_cmd, list_rs232_type, list_rs232_index
  225. ,list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5
  226. ,list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10
  227. ,list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5
  228. ,list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10
  229. ,list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5
  230. ,list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10);
  231. if( 0 == list_var_id.size() || 0 == list_set_value.size() || 0 == list_var_name.size()
  232. || 0 == list_uid.size() || 0 == list_upper_limit.size() || 0 == list_lower_limit.size()
  233. || 0 == list_normal_state.size() || 0 == list_identify_time.size() || 0 == list_redetect_time.size()
  234. || 0 == list_normal_is_notice.size() || 0 == list_warn_level.size() || 0 == list_snmp_oid.size()
  235. || 0 == list_fields.size() || 0 == list_description.size() || 0 == list_max_values.size() || 0 == list_min_values.size()
  236. || 0 == list_max_convtrate.size() || 0 == list_min_convtrate.size() || 0 == list_is_save.size()
  237. || 0 == list_collect_freq.size() || 0 == list_var_type_id.size() || 0 == list_readonly.size()
  238. || 0 == list_is_dde.size() || 0 == list_address.size() || 0 == list_unit.size()
  239. || 0 == list_reccurve.size() || 0 == list_register_num.size() || 0 == list_child_id.size()
  240. || 0 == list_var_item_id.size() || 0 == list_rearm.size() || 0 == list_offsets.size()
  241. || 0 == list_funcid.size() || 0 == list_data_len.size() || 0 == list_coefficient.size()
  242. || 0 == list_realtimeflag.size() || 0 == list_rs232_cmd.size() || 0 == list_rs232_type.size() || 0 == list_rs232_index.size()
  243. || 0 == list_str_reserved1.size() || 0 == list_str_reserved2.size() || 0 == list_str_reserved3.size()
  244. || 0 == list_str_reserved4.size() || 0 == list_str_reserved5.size() || 0 == list_str_reserved6.size()
  245. || 0 == list_str_reserved7.size() || 0 == list_str_reserved8.size() || 0 == list_str_reserved9.size()
  246. || 0 == list_str_reserved10.size() || 0 == list_int_reserved1.size() || 0 == list_int_reserved2.size()
  247. || 0 == list_int_reserved3.size() || 0 == list_int_reserved4.size() || 0 == list_int_reserved5.size()
  248. || 0 == list_int_reserved6.size() || 0 == list_int_reserved7.size() || 0 == list_int_reserved8.size()
  249. || 0 == list_int_reserved9.size() || 0 == list_int_reserved10.size() || 0 == list_bool_reserved1.size()
  250. || 0 == list_bool_reserved2.size() || 0 == list_bool_reserved3.size() || 0 == list_bool_reserved4.size()
  251. || 0 == list_bool_reserved5.size() || 0 == list_bool_reserved6.size() || 0 == list_bool_reserved7.size()
  252. || 0 == list_bool_reserved8.size() || 0 == list_bool_reserved9.size() || 0 == list_bool_reserved10.size()
  253. )
  254. {
  255. return 0;
  256. }
  257. if( nRet != -1 )
  258. {
  259. for( it_var_id = list_var_id.begin(), it_set_value = list_set_value.begin(), it_var_name = list_var_name.begin()
  260. ,it_uid = list_uid.begin(), it_upper_limit = list_upper_limit.begin()
  261. ,it_lower_limit = list_lower_limit.begin(), it_normal_state = list_normal_state.begin()
  262. ,it_identify_time = list_identify_time.begin(),it_redetect_time = list_redetect_time.begin()
  263. ,it_normal_is_notice = list_normal_is_notice.begin(), it_warn_level = list_warn_level.begin()
  264. ,it_snmp_oid = list_snmp_oid.begin(), it_fields = list_fields.begin(), it_description = list_description.begin()
  265. ,it_max_values = list_max_values.begin(), it_min_values = list_min_values.begin()
  266. ,it_max_convtrate = list_max_convtrate.begin(), it_min_convtrate = list_min_convtrate.begin()
  267. ,it_is_save = list_is_save.begin(), it_collect_freq = list_collect_freq.begin(), it_var_type_id = list_var_type_id.begin()
  268. ,it_readonly = list_readonly.begin(), it_is_dde = list_is_dde.begin(), it_address = list_address.begin()
  269. ,it_unit = list_unit.begin(), it_reccurve = list_reccurve.begin(), it_register_num = list_register_num.begin()
  270. ,it_child_id = list_child_id.begin(), it_var_item_id = list_var_item_id.begin()
  271. ,it_rearm = list_rearm.begin(), it_offsets = list_offsets.begin(), it_funcid = list_funcid.begin()
  272. ,it_data_len = list_data_len.begin(), it_coefficient = list_coefficient.begin(), it_realtimeflag = list_realtimeflag.begin()
  273. ,it_rs232_cmd = list_rs232_cmd.begin(), it_rs232_type = list_rs232_type.begin(), it_rs232_index = list_rs232_index.begin()
  274. ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin()
  275. ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin()
  276. ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin()
  277. ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin()
  278. ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin()
  279. ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin()
  280. ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin()
  281. ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin()
  282. ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin()
  283. ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin()
  284. ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin()
  285. ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin()
  286. ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin()
  287. ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin()
  288. ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin();
  289. it_var_id != list_var_id.end(), it_set_value != list_set_value.end(), it_var_name != list_var_name.end()
  290. ,it_uid != list_uid.end(), it_upper_limit != list_upper_limit.end()
  291. ,it_lower_limit != list_lower_limit.end(), it_normal_state != list_normal_state.end()
  292. ,it_identify_time != list_identify_time.end(),it_redetect_time != list_redetect_time.end()
  293. ,it_normal_is_notice != list_normal_is_notice.end(), it_warn_level != list_warn_level.end()
  294. ,it_snmp_oid != list_snmp_oid.end(), it_fields != list_fields.end(), it_description != list_description.end()
  295. ,it_max_values != list_max_values.end(), it_min_values != list_min_values.end()
  296. ,it_max_convtrate != list_max_convtrate.end(), it_min_convtrate != list_min_convtrate.end()
  297. ,it_is_save != list_is_save.end(), it_collect_freq != list_collect_freq.end(), it_var_type_id != list_var_type_id.end()
  298. ,it_readonly != list_readonly.end(), it_is_dde != list_is_dde.end(), it_address != list_address.end()
  299. ,it_unit != list_unit.end(), it_reccurve != list_reccurve.end(), it_register_num != list_register_num.end()
  300. ,it_child_id != list_child_id.end(), it_var_item_id != list_var_item_id.end()
  301. ,it_rearm != list_rearm.end(), it_offsets != list_offsets.end(), it_funcid != list_funcid.end()
  302. ,it_data_len != list_data_len.end(), it_coefficient != list_coefficient.end(), it_realtimeflag != list_realtimeflag.end()
  303. ,it_rs232_cmd != list_rs232_cmd.end(), it_rs232_type != list_rs232_type.end(), it_rs232_index != list_rs232_index.end()
  304. ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end()
  305. ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end()
  306. ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end()
  307. ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end()
  308. ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end()
  309. ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end()
  310. ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end()
  311. ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end()
  312. ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end()
  313. ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end()
  314. ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end()
  315. ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end()
  316. ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end()
  317. ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end()
  318. ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end();
  319. )
  320. {
  321. //CBaseVar *pBaseVar;
  322. //pBaseVar = new CBaseVar();
  323. CAnalog *pBaseVar;
  324. pBaseVar = new CAnalog();
  325. int nVarID;
  326. CString strUid;
  327. nVarID = atoi((*it_var_id++).c_str());
  328. strUid = (*it_uid++).c_str();
  329. // 变量ID
  330. pBaseVar->m_nVarID = nVarID;
  331. // 设定值
  332. pBaseVar->m_strSetValue = (*it_set_value++).c_str();
  333. // 变量名称
  334. pBaseVar->m_strName = (*it_var_name++).c_str();
  335. // 变量Uid
  336. pBaseVar->m_strVarUID = strUid;
  337. // 上限
  338. pBaseVar->m_nUpperLimit = atoi((*it_upper_limit++).c_str());
  339. //LOG4C((LOG_NOTICE, "GetVarInfo pBaseVar->m_nUpperLimit = %d", pBaseVar->m_nUpperLimit));
  340. // 下限
  341. pBaseVar->m_nLowerLimit = atoi((*it_lower_limit++).c_str());
  342. // 正常状态
  343. pBaseVar->m_nNormalState = atoi((*it_normal_state++).c_str());
  344. // 辨识时间
  345. pBaseVar->m_nIdentifyTime = atoi((*it_identify_time++).c_str());
  346. // 重新检测时间
  347. pBaseVar->m_nRedetectTime = atoi((*it_redetect_time++).c_str());
  348. // 恢复正常是否触发远程报警
  349. CString strNormalIsNotice = (*it_normal_is_notice++).c_str();
  350. if( 0 == atoi(strNormalIsNotice) )
  351. {
  352. pBaseVar->m_bIsNormalAlarm = FALSE;
  353. }
  354. else
  355. {
  356. pBaseVar->m_bIsNormalAlarm = TRUE;
  357. }
  358. // 报警级别
  359. pBaseVar->m_nWaringLevel = atoi((*it_warn_level++).c_str());
  360. // Snmp对象OID
  361. pBaseVar->m_strSnmpOid = (*it_snmp_oid++).c_str();
  362. // Snmp对象域
  363. pBaseVar->m_strFields = (*it_fields++).c_str();
  364. // 变量描述
  365. pBaseVar->m_strDesc = (*it_description++).c_str();
  366. // 最大值
  367. pBaseVar->m_nMaxValues = atoi((*it_max_values++).c_str());
  368. // 最小值
  369. pBaseVar->m_nMinValues = atoi((*it_min_values++).c_str());
  370. // 最大比例
  371. pBaseVar->m_nMaxConvtRate = atoi((*it_max_convtrate++).c_str());
  372. // 最小比例
  373. pBaseVar->m_nMinConvtRate = atoi((*it_min_convtrate++).c_str());
  374. // 是否保存数值
  375. CString strIsSave = (*it_is_save++).c_str();
  376. if( 0 == atoi(strIsSave) )
  377. {
  378. pBaseVar->m_bIsSave = FALSE;
  379. }
  380. else
  381. {
  382. pBaseVar->m_bIsSave = TRUE;
  383. }
  384. //LOG4C((LOG_NOTICE, "var desc = %s, pBaseVar->m_bIsSave = %d, strIsSave = %s", pBaseVar->m_strDesc, pBaseVar->m_bIsSave, strIsSave));
  385. // 采集频率
  386. pBaseVar->m_nCollectFreq = atoi((*it_collect_freq++).c_str());
  387. // 变量类型ID
  388. pBaseVar->m_nVarTypeID = atoi((*it_var_type_id++).c_str());
  389. // 读写权限
  390. CString strReadOnly = (*it_readonly++).c_str();
  391. if( 0 == atoi(strReadOnly) )
  392. {
  393. pBaseVar->m_nPurview = FALSE;
  394. }
  395. else
  396. {
  397. pBaseVar->m_nPurview = TRUE;
  398. }
  399. // 是否DDE
  400. CString strDDE = (*it_is_dde++).c_str();
  401. if( 0 == atoi(strDDE) )
  402. {
  403. pBaseVar->m_bIsDDE = FALSE;
  404. }
  405. else
  406. {
  407. pBaseVar->m_bIsDDE = TRUE;
  408. }
  409. // 寄存器起始地址
  410. pBaseVar->m_nRegStartAddr = atoi((*it_address++).c_str());
  411. // 单位
  412. pBaseVar->m_strUnit = (*it_unit++).c_str();
  413. // 是否记录实时曲线
  414. CString strRecCurve = (*it_reccurve++).c_str();
  415. if( 0 == atoi(strRecCurve) )
  416. {
  417. pBaseVar->m_bRecCurve = FALSE;
  418. }
  419. else
  420. {
  421. pBaseVar->m_bRecCurve = TRUE;
  422. }
  423. // 寄存器个数
  424. pBaseVar->m_nRegNum = atoi((*it_register_num++).c_str());
  425. // 变量子ID
  426. pBaseVar->m_nVarChildID = atoi((*it_child_id++).c_str());
  427. // t_dev_varint_item表的ID
  428. pBaseVar->m_nVarItemID = atoi((*it_var_item_id++).c_str());
  429. // 校正值
  430. pBaseVar->m_nRearm = atoi((*it_rearm++).c_str());
  431. // 偏移值
  432. pBaseVar->m_nOffset = atoi((*it_offsets++).c_str());
  433. // 功能码ID
  434. pBaseVar->m_nFuncCode = atoi((*it_funcid++).c_str());
  435. // 数据长度
  436. pBaseVar->m_nDataLen = atoi((*it_data_len++).c_str());
  437. // 系数
  438. pBaseVar->m_fCoef = atof((*it_coefficient++).c_str());
  439. // 是否实时采集
  440. CString strRealTimeFlag = (*it_realtimeflag++).c_str();
  441. //LOG4C((LOG_NOTICE, "strRealTimeFlag = %s, atoi(strRealTimeFlag) = %d", strRealTimeFlag, atoi(strRealTimeFlag)));
  442. if( 0 == atoi(strRealTimeFlag) )
  443. {
  444. pBaseVar->m_bRealtimeFlag = FALSE;
  445. }
  446. else
  447. {
  448. pBaseVar->m_bRealtimeFlag = TRUE;
  449. }
  450. //LOG4C((LOG_NOTICE, "pBaseVar->m_bRealTimeflag = %d", pBaseVar->m_bRealTimeflag));
  451. // RS232命令
  452. pBaseVar->m_strRs232Cmd = (*it_rs232_cmd++).c_str();
  453. // RS232类型
  454. pBaseVar->m_strRs232Type = (*it_rs232_type++).c_str();
  455. // RS232索引
  456. pBaseVar->m_nRs232Index = atoi((*it_rs232_index++).c_str());
  457. //LOG4C((LOG_NOTICE, "pBaseVar->m_strRs232Index = %s", pBaseVar->m_strRs232Index));
  458. // 字符串预留1
  459. pBaseVar->m_strReserved1 = (*it_str_reserved1++).c_str();
  460. // 字符串预留2
  461. pBaseVar->m_strReserved2 = (*it_str_reserved2++).c_str();
  462. // 字符串预留3
  463. pBaseVar->m_strReserved3 = (*it_str_reserved3++).c_str();
  464. // 字符串预留4
  465. pBaseVar->m_strReserved4 = (*it_str_reserved4++).c_str();
  466. // 字符串预留5
  467. pBaseVar->m_strReserved5 = (*it_str_reserved5++).c_str();
  468. // 字符串预留6
  469. pBaseVar->m_strReserved6 = (*it_str_reserved6++).c_str();
  470. // 字符串预留7
  471. pBaseVar->m_strReserved7 = (*it_str_reserved7++).c_str();
  472. // 字符串预留8
  473. pBaseVar->m_strReserved8 = (*it_str_reserved8++).c_str();
  474. // 字符串预留9
  475. pBaseVar->m_strReserved9 = (*it_str_reserved9++).c_str();
  476. // 字符串预留10
  477. pBaseVar->m_strReserved10 = (*it_str_reserved10++).c_str();
  478. // 整形预留1
  479. pBaseVar->m_nReserved1 = atoi((*it_int_reserved1++).c_str());
  480. // 整形预留2
  481. pBaseVar->m_nReserved2 = atoi((*it_int_reserved2++).c_str());
  482. // 整形预留3
  483. pBaseVar->m_nReserved3 = atoi((*it_int_reserved3++).c_str());
  484. // 整形预留4
  485. pBaseVar->m_nReserved4 = atoi((*it_int_reserved4++).c_str());
  486. // 整形预留5
  487. pBaseVar->m_nReserved5 = atoi((*it_int_reserved5++).c_str());
  488. // 整形预留6
  489. pBaseVar->m_nReserved6 = atoi((*it_int_reserved6++).c_str());
  490. // 整形预留7
  491. pBaseVar->m_nReserved7 = atoi((*it_int_reserved7++).c_str());
  492. // 整形预留8
  493. pBaseVar->m_nReserved8 = atoi((*it_int_reserved8++).c_str());
  494. // 整形预留9
  495. pBaseVar->m_nReserved9 = atoi((*it_int_reserved9++).c_str());
  496. // 整形预留10
  497. pBaseVar->m_nReserved10 = atoi((*it_int_reserved10++).c_str());
  498. CString strBoolReserved1 = (*it_bool_reserved1++).c_str();
  499. //布尔型预留1
  500. if( 0 == atoi(strBoolReserved1) )
  501. {
  502. pBaseVar->m_bReserved1 = false;
  503. }
  504. else
  505. {
  506. pBaseVar->m_bReserved1 = true;
  507. }
  508. //布尔型预留2
  509. if( 0 == atoi((*it_bool_reserved2++).c_str()) )
  510. {
  511. pBaseVar->m_bReserved2 = false;
  512. }
  513. else
  514. {
  515. pBaseVar->m_bReserved2 = true;
  516. }
  517. CString strBoolReserved3 = (*it_bool_reserved3++).c_str();
  518. //LOG4C((LOG_NOTICE, "strBoolReserved3=%s", strBoolReserved3));
  519. //布尔型预留3
  520. if( 0 == atoi(strBoolReserved3) )
  521. {
  522. pBaseVar->m_bReserved3 = false;
  523. }
  524. else
  525. {
  526. pBaseVar->m_bReserved3 = true;
  527. }
  528. //布尔型预留4
  529. if( 0 == atoi((*it_bool_reserved4++).c_str()) )
  530. {
  531. pBaseVar->m_bReserved4 = false;
  532. }
  533. else
  534. {
  535. pBaseVar->m_bReserved4 = true;
  536. }
  537. //布尔型预留5
  538. if( 0 == atoi((*it_bool_reserved5++).c_str()) )
  539. {
  540. pBaseVar->m_bReserved5 = false;
  541. }
  542. else
  543. {
  544. pBaseVar->m_bReserved5 = true;
  545. }
  546. //布尔型预留6
  547. if( 0 == atoi((*it_bool_reserved6++).c_str()) )
  548. {
  549. pBaseVar->m_bReserved6 = false;
  550. }
  551. else
  552. {
  553. pBaseVar->m_bReserved6 = true;
  554. }
  555. //布尔型预留7
  556. if( 0 == atoi((*it_bool_reserved7++).c_str()) )
  557. {
  558. pBaseVar->m_bReserved7 = false;
  559. }
  560. else
  561. {
  562. pBaseVar->m_bReserved7 = true;
  563. }
  564. //布尔型预留8
  565. if( 0 == atoi((*it_bool_reserved8++).c_str()) )
  566. {
  567. pBaseVar->m_bReserved8 = false;
  568. }
  569. else
  570. {
  571. pBaseVar->m_bReserved8 = true;
  572. }
  573. //布尔型预留9
  574. if( 0 == atoi((*it_bool_reserved9++).c_str()) )
  575. {
  576. pBaseVar->m_bReserved9 = false;
  577. }
  578. else
  579. {
  580. pBaseVar->m_bReserved9 = true;
  581. }
  582. //布尔型预留10
  583. if( 0 == atoi((*it_bool_reserved10++).c_str()) )
  584. {
  585. pBaseVar->m_bReserved10 = false;
  586. }
  587. else
  588. {
  589. pBaseVar->m_bReserved10 = true;
  590. }
  591. pBaseVar->m_fData = pBaseVar->m_nReserved1;
  592. if( pVariantsManager )
  593. {
  594. CString sMsg = GetInvalidMessage( pBaseVar->m_strName,pBaseVar->m_nReserved1,pBaseVar->m_nReserved2,pBaseVar->m_nReserved3,
  595. pBaseVar->m_nLowerLimit,pBaseVar->m_nUpperLimit,pBaseVar->m_nNormalState,pBaseVar->m_nWaringLevel,pBaseVar->m_nIdentifyTime );
  596. if( sMsg!="" )
  597. {
  598. LOG4C((LOG_NOTICE, "变量 %s %s",pBaseVar->m_strName,sMsg ));
  599. }
  600. FindVarIsExist( pBaseVar );
  601. pVariantsManager->m_analog.Add( pBaseVar );
  602. }
  603. }
  604. }
  605. for( it_var_id = list_var_id.begin(), it_set_value = list_set_value.begin(), it_var_name = list_var_name.begin()
  606. ,it_uid = list_uid.begin(), it_upper_limit = list_upper_limit.begin()
  607. ,it_lower_limit = list_lower_limit.begin(), it_normal_state = list_normal_state.begin()
  608. ,it_identify_time = list_identify_time.begin(),it_redetect_time = list_redetect_time.begin()
  609. ,it_normal_is_notice = list_normal_is_notice.begin(), it_warn_level = list_warn_level.begin()
  610. ,it_snmp_oid = list_snmp_oid.begin(), it_fields = list_fields.begin(), it_description = list_description.begin()
  611. ,it_max_values = list_max_values.begin(), it_min_values = list_min_values.begin()
  612. ,it_max_convtrate = list_max_convtrate.begin(), it_min_convtrate = list_min_convtrate.begin()
  613. ,it_is_save = list_is_save.begin(), it_collect_freq = list_collect_freq.begin(), it_var_type_id = list_var_type_id.begin()
  614. ,it_readonly = list_readonly.begin(), it_is_dde = list_is_dde.begin(), it_address = list_address.begin()
  615. ,it_unit = list_unit.begin(), it_reccurve = list_reccurve.begin(), it_register_num = list_register_num.begin()
  616. ,it_child_id = list_child_id.begin(), it_var_item_id = list_var_item_id.begin()
  617. ,it_rearm = list_rearm.begin(), it_offsets = list_offsets.begin(), it_funcid = list_funcid.begin()
  618. ,it_data_len = list_data_len.begin(), it_coefficient = list_coefficient.begin(), it_realtimeflag = list_realtimeflag.begin()
  619. ,it_rs232_cmd = list_rs232_cmd.begin(), it_rs232_type = list_rs232_type.begin(), it_rs232_index = list_rs232_index.begin()
  620. ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin()
  621. ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin()
  622. ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin()
  623. ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin()
  624. ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin()
  625. ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin()
  626. ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin()
  627. ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin()
  628. ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin()
  629. ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin()
  630. ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin()
  631. ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin()
  632. ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin()
  633. ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin()
  634. ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin();
  635. it_var_id != list_var_id.end(), it_set_value != list_set_value.end(), it_var_name != list_var_name.end()
  636. ,it_uid != list_uid.end(), it_upper_limit != list_upper_limit.end()
  637. ,it_lower_limit != list_lower_limit.end(), it_normal_state != list_normal_state.end()
  638. ,it_identify_time != list_identify_time.end(),it_redetect_time != list_redetect_time.end()
  639. ,it_normal_is_notice != list_normal_is_notice.end(), it_warn_level != list_warn_level.end()
  640. ,it_snmp_oid != list_snmp_oid.end(), it_fields != list_fields.end(), it_description != list_description.end()
  641. ,it_max_values != list_max_values.end(), it_min_values != list_min_values.end()
  642. ,it_max_convtrate != list_max_convtrate.end(), it_min_convtrate != list_min_convtrate.end()
  643. ,it_is_save != list_is_save.end(), it_collect_freq != list_collect_freq.end(), it_var_type_id != list_var_type_id.end()
  644. ,it_readonly != list_readonly.end(), it_is_dde != list_is_dde.end(), it_address != list_address.end()
  645. ,it_unit != list_unit.end(), it_reccurve != list_reccurve.end(), it_register_num != list_register_num.end()
  646. ,it_child_id != list_child_id.end(), it_var_item_id != list_var_item_id.end()
  647. ,it_rearm != list_rearm.end(), it_offsets != list_offsets.end(), it_funcid != list_funcid.end()
  648. ,it_data_len != list_data_len.end(), it_coefficient != list_coefficient.end(), it_realtimeflag != list_realtimeflag.end()
  649. ,it_rs232_cmd != list_rs232_cmd.end(), it_rs232_type != list_rs232_type.end(), it_rs232_index != list_rs232_index.end()
  650. ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end()
  651. ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end()
  652. ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end()
  653. ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end()
  654. ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end()
  655. ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end()
  656. ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end()
  657. ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end()
  658. ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end()
  659. ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end()
  660. ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end()
  661. ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end()
  662. ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end()
  663. ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end()
  664. ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end();
  665. )
  666. {
  667. list_var_id.erase(it_var_id++);
  668. list_set_value.erase(it_set_value++);
  669. list_var_name.erase(it_var_name++);
  670. list_uid.erase(it_uid++);
  671. list_upper_limit.erase(it_upper_limit++);
  672. list_lower_limit.erase(it_lower_limit++);
  673. list_normal_state.erase(it_normal_state++);
  674. list_identify_time.erase(it_identify_time++);
  675. list_redetect_time.erase(it_redetect_time++);
  676. list_normal_is_notice.erase(it_normal_is_notice++);
  677. list_warn_level.erase(it_warn_level++);
  678. list_snmp_oid.erase(it_snmp_oid++);
  679. list_fields.erase(it_fields++);
  680. list_description.erase(it_description++);
  681. list_max_values.erase(it_max_values++);
  682. list_min_values.erase(it_min_values++);
  683. list_max_convtrate.erase(it_max_convtrate++);
  684. list_min_convtrate.erase(it_min_convtrate++);
  685. list_is_save.erase(it_is_save++);
  686. list_collect_freq.erase(it_collect_freq++);
  687. list_var_type_id.erase(it_var_type_id++);
  688. list_readonly.erase(it_readonly++);
  689. list_is_dde.erase(it_is_dde++);
  690. list_address.erase(it_address++);
  691. list_unit.erase(it_unit++);
  692. list_reccurve.erase(it_reccurve++);
  693. list_register_num.erase(it_register_num++);
  694. list_child_id.erase(it_child_id++);
  695. list_var_item_id.erase(it_var_item_id++);
  696. list_rearm.erase(it_rearm++);
  697. list_offsets.erase(it_offsets++);
  698. list_funcid.erase(it_funcid++);
  699. list_data_len.erase(it_data_len++);
  700. list_coefficient.erase(it_coefficient++);
  701. list_realtimeflag.erase(it_realtimeflag++);
  702. list_rs232_cmd.erase(it_rs232_cmd++);
  703. list_rs232_type.erase(it_rs232_type++);
  704. list_rs232_index.erase(it_rs232_index++);
  705. list_str_reserved1.erase(it_str_reserved1++);
  706. list_str_reserved2.erase(it_str_reserved2++);
  707. list_str_reserved3.erase(it_str_reserved3++);
  708. list_str_reserved4.erase(it_str_reserved4++);
  709. list_str_reserved5.erase(it_str_reserved5++);
  710. list_str_reserved6.erase(it_str_reserved6++);
  711. list_str_reserved7.erase(it_str_reserved7++);
  712. list_str_reserved8.erase(it_str_reserved8++);
  713. list_str_reserved9.erase(it_str_reserved9++);
  714. list_str_reserved10.erase(it_str_reserved10++);
  715. list_int_reserved1.erase(it_int_reserved1++);
  716. list_int_reserved2.erase(it_int_reserved2++);
  717. list_int_reserved3.erase(it_int_reserved3++);
  718. list_int_reserved4.erase(it_int_reserved4++);
  719. list_int_reserved5.erase(it_int_reserved5++);
  720. list_int_reserved6.erase(it_int_reserved6++);
  721. list_int_reserved7.erase(it_int_reserved7++);
  722. list_int_reserved8.erase(it_int_reserved8++);
  723. list_int_reserved9.erase(it_int_reserved9++);
  724. list_int_reserved10.erase(it_int_reserved10++);
  725. list_bool_reserved1.erase(it_bool_reserved1++);
  726. list_bool_reserved2.erase(it_bool_reserved2++);
  727. list_bool_reserved3.erase(it_bool_reserved3++);
  728. list_bool_reserved4.erase(it_bool_reserved4++);
  729. list_bool_reserved5.erase(it_bool_reserved5++);
  730. list_bool_reserved6.erase(it_bool_reserved6++);
  731. list_bool_reserved7.erase(it_bool_reserved7++);
  732. list_bool_reserved8.erase(it_bool_reserved8++);
  733. list_bool_reserved9.erase(it_bool_reserved9++);
  734. list_bool_reserved10.erase(it_bool_reserved10++);
  735. }
  736. return nRet;
  737. }
  738. void GetID( CString sInfo,int &iDriverID, int &iFactoryID, int &iDevicesID )
  739. {
  740. int nPos1=0,nPos2=0;
  741. CString s;
  742. nPos2 = sInfo.Find( ".",nPos1 );
  743. iDriverID = atoi( sInfo.Mid( nPos1+0,nPos2-nPos1-0 ) );
  744. nPos1 = nPos2;
  745. nPos2 = sInfo.Find( ".",nPos1+1 );
  746. iFactoryID = atoi( sInfo.Mid( nPos1+1,nPos2-nPos1-1 ) );
  747. nPos1 = nPos2;
  748. nPos2 = sInfo.Find( ".",nPos1+1 );
  749. iDevicesID = atoi( sInfo.Mid( nPos1+1,nPos2-nPos1-1 ) );
  750. nPos1 = nPos2;
  751. }
  752. // 获取设备资料
  753. INT CDBInterface::GetDevInfo()
  754. {
  755. CHAR strSQLText[MAX_SQL_LENGTH + 1] = {0};
  756. list<string> list_dev_id, list_uid, list_port, list_device_name, list_device_baudrate;
  757. list<string> list_commmode, list_devide_addr, list_is_use, list_protocol_dll_name;
  758. list<string> list_special_device, list_data_bit, list_stop_bit, list_parity_bit, list_ip, list_ip_port, list_ini_name;
  759. list<string> list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5;
  760. list<string> list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10;
  761. list<string> list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5;
  762. list<string> list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10;
  763. list<string> list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5;
  764. list<string> list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10;
  765. list<string>::iterator it_dev_id, it_uid, it_port, it_device_name, it_device_baudrate;
  766. list<string>::iterator it_commmode, it_devide_addr, it_is_use, it_protocol_dll_name;
  767. list<string>::iterator it_special_device, it_data_bit, it_stop_bit, it_parity_bit, it_ip, it_ip_port, it_ini_name;
  768. list<string>::iterator it_str_reserved1, it_str_reserved2, it_str_reserved3, it_str_reserved4, it_str_reserved5;
  769. list<string>::iterator it_str_reserved6, it_str_reserved7, it_str_reserved8, it_str_reserved9, it_str_reserved10;
  770. list<string>::iterator it_int_reserved1, it_int_reserved2, it_int_reserved3, it_int_reserved4, it_int_reserved5;
  771. list<string>::iterator it_int_reserved6, it_int_reserved7, it_int_reserved8, it_int_reserved9, it_int_reserved10;
  772. list<string>::iterator it_bool_reserved1, it_bool_reserved2, it_bool_reserved3, it_bool_reserved4, it_bool_reserved5;
  773. list<string>::iterator it_bool_reserved6, it_bool_reserved7, it_bool_reserved8, it_bool_reserved9, it_bool_reserved10;
  774. sprintf(strSQLText, "select id as devId, uid, port, devicename, baudrate, commmode, devideaddr, isuse, protocoldllname, " \
  775. " specialdevice, databit, stopbit, paritybit, ip, ipport, ininame, " \
  776. " strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \
  777. " strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \
  778. " intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \
  779. " intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \
  780. " boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \
  781. " boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \
  782. " from t_dev_property");// where isuse = '1' modify at 08.30
  783. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList46(strSQLText
  784. ,list_dev_id, list_uid, list_port, list_device_name, list_device_baudrate
  785. ,list_commmode, list_devide_addr, list_is_use, list_protocol_dll_name
  786. ,list_special_device, list_data_bit, list_stop_bit, list_parity_bit, list_ip, list_ip_port, list_ini_name
  787. ,list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5
  788. ,list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10
  789. ,list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5
  790. ,list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10
  791. ,list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5
  792. ,list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10);
  793. if( 0 == list_dev_id.size() || 0 == list_uid.size() || 0 == list_port.size()
  794. || 0 == list_device_name.size() || 0 == list_device_baudrate.size() || 0 == list_commmode.size()
  795. || 0 == list_devide_addr.size() || 0 == list_is_use.size() || 0 == list_protocol_dll_name.size()
  796. || 0 == list_special_device.size() || 0 == list_data_bit.size() || 0 == list_stop_bit.size()
  797. || 0 == list_parity_bit.size() || 0 == list_ip.size() || 0 == list_ip_port.size() || 0 == list_ini_name.size()
  798. || 0 == list_str_reserved1.size() || 0 == list_str_reserved2.size() || 0 == list_str_reserved3.size()
  799. || 0 == list_str_reserved4.size() || 0 == list_str_reserved5.size() || 0 == list_str_reserved6.size()
  800. || 0 == list_str_reserved7.size() || 0 == list_str_reserved8.size() || 0 == list_str_reserved9.size()
  801. || 0 == list_str_reserved10.size() || 0 == list_int_reserved1.size() || 0 == list_int_reserved2.size()
  802. || 0 == list_int_reserved3.size() || 0 == list_int_reserved4.size() || 0 == list_int_reserved5.size()
  803. || 0 == list_int_reserved6.size() || 0 == list_int_reserved7.size() || 0 == list_int_reserved8.size()
  804. || 0 == list_int_reserved9.size() || 0 == list_int_reserved10.size() || 0 == list_bool_reserved1.size()
  805. || 0 == list_bool_reserved2.size() || 0 == list_bool_reserved3.size() || 0 == list_bool_reserved4.size()
  806. || 0 == list_bool_reserved5.size() || 0 == list_bool_reserved6.size() || 0 == list_bool_reserved7.size()
  807. || 0 == list_bool_reserved8.size() || 0 == list_bool_reserved9.size() || 0 == list_bool_reserved10.size()
  808. )
  809. {
  810. return 0;
  811. }
  812. if( nRet != -1 )
  813. {
  814. for( it_dev_id = list_dev_id.begin(), it_uid = list_uid.begin(), it_port = list_port.begin()
  815. ,it_device_name = list_device_name.begin(), it_device_baudrate = list_device_baudrate.begin()
  816. ,it_commmode = list_commmode.begin(), it_devide_addr = list_devide_addr.begin()
  817. ,it_is_use = list_is_use.begin(),it_protocol_dll_name = list_protocol_dll_name.begin()
  818. ,it_special_device = list_special_device.begin(), it_data_bit = list_data_bit.begin()
  819. ,it_stop_bit = list_stop_bit.begin(), it_parity_bit = list_parity_bit.begin(), it_ip = list_ip.begin()
  820. ,it_ip_port = list_ip_port.begin(), it_ini_name = list_ini_name.begin()
  821. ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin()
  822. ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin()
  823. ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin()
  824. ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin()
  825. ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin()
  826. ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin()
  827. ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin()
  828. ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin()
  829. ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin()
  830. ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin()
  831. ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin()
  832. ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin()
  833. ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin()
  834. ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin()
  835. ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin();
  836. it_dev_id != list_dev_id.end(), it_uid != list_uid.end(), it_port != list_port.end()
  837. ,it_device_name != list_device_name.end(), it_device_baudrate != list_device_baudrate.end()
  838. ,it_commmode != list_commmode.end(), it_devide_addr != list_devide_addr.end()
  839. ,it_is_use != list_is_use.end(),it_protocol_dll_name != list_protocol_dll_name.end()
  840. ,it_special_device != list_special_device.end(), it_data_bit != list_data_bit.end()
  841. ,it_stop_bit != list_stop_bit.end(), it_parity_bit != list_parity_bit.end(), it_ip != list_ip.end()
  842. ,it_ip_port != list_ip_port.end(), it_ini_name != list_ini_name.end()
  843. ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end()
  844. ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end()
  845. ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end()
  846. ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end()
  847. ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end()
  848. ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end()
  849. ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end()
  850. ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end()
  851. ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end()
  852. ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end()
  853. ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end()
  854. ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end()
  855. ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end()
  856. ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end()
  857. ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end();
  858. )
  859. {
  860. CDevice* pDev = new CDevice();
  861. CChannel *pChannel = new CChannel();
  862. // 获取设备ID
  863. pDev->m_iID = atoi((*it_dev_id++).c_str());
  864. // 获取设备UID
  865. pDev->m_strUID = (*it_uid++).c_str();
  866. int nDriverID=0, nFactoryID=0, nDevicesID=0;
  867. GetID( pDev->m_strUID,nDriverID,nFactoryID,nDevicesID );
  868. GetDriverName( nDriverID,pDev->m_strDevDriveName );
  869. GetFactoryName( nDriverID,nFactoryID,pDev->m_strDevFactoryName );
  870. GetDevicesName( nDriverID,nFactoryID,nDevicesID,pDev->m_strType );
  871. // 获取设备端口号
  872. pChannel->m_nAddr = atoi((*it_port++).c_str());
  873. pChannel->m_strPort.Format( "COM%d",pChannel->m_nAddr );
  874. // 获取设备名称
  875. pDev->m_strName = (*it_device_name++).c_str();
  876. // 获取设备的波特率
  877. pChannel->m_nBaudRate = atoi((*it_device_baudrate++).c_str());
  878. // 获取设备的数据位
  879. pChannel->m_nByteSize = atoi((*it_data_bit++).c_str());
  880. // 获取设备的停止位
  881. pChannel->m_nStopBits = atoi((*it_stop_bit++).c_str());
  882. // 获取设备的校验位
  883. pChannel->m_nParity = atoi((*it_parity_bit++).c_str());
  884. // 通信的方式
  885. pChannel->m_nCommunicateType = atoi((*it_commmode++).c_str());
  886. if( pChannel->m_nCommunicateType==0 )
  887. pChannel->m_strName.Format( "COM%d",pChannel->m_nAddr );
  888. else
  889. pChannel->m_strName = "";
  890. // 设备地址
  891. pDev->m_Address = atoi((*it_devide_addr++).c_str());
  892. // 设备是否启用
  893. CString strIsUse = (*it_is_use++).c_str();
  894. if( 0 == atoi(strIsUse) )
  895. {
  896. pDev->m_bUsed = 0;
  897. }
  898. else
  899. {
  900. pDev->m_bUsed = 1;
  901. }
  902. // 协议DLL名称
  903. pDev->m_strProtocolName = (*it_protocol_dll_name++).c_str();
  904. // Modbus Rtu;Modbus Ascii;Modbus Tcp;Snmp;RS232;
  905. pDev->m_nProtocolType = atoi( (*it_special_device++).c_str() );
  906. //pDev->m_bySpecialdevice = atoi(strSpecialDevice);
  907. //LOG4C((LOG_NOTICE, "device name = %s, specialdevice = %d, %s", pDev->m_strDeviceName, pDev->m_bySpecialdevice, strSpecialDevice));
  908. // 设备IP
  909. pDev->m_strDevIP = (*it_ip++).c_str();
  910. // 网络通信端口
  911. pDev->m_nNetPort = atoi((*it_ip_port++).c_str());
  912. // ini配置文件名称
  913. pDev->m_strIniName = (*it_ini_name++).c_str();
  914. // 字符串预留1
  915. pDev->m_strReserved1 = (*it_str_reserved1++).c_str();
  916. // 字符串预留2
  917. pDev->m_strReserved2 = (*it_str_reserved2++).c_str();
  918. // 字符串预留3
  919. pDev->m_strReserved3 = (*it_str_reserved3++).c_str();
  920. // 字符串预留4
  921. pDev->m_strReserved4 = (*it_str_reserved4++).c_str();
  922. // 字符串预留5
  923. pDev->m_strReserved5 = (*it_str_reserved5++).c_str();
  924. // 字符串预留6
  925. pDev->m_strReserved6 = (*it_str_reserved6++).c_str();
  926. // 字符串预留7
  927. pDev->m_strReserved7 = (*it_str_reserved7++).c_str();
  928. // 字符串预留8
  929. pDev->m_strReserved8 = (*it_str_reserved8++).c_str();
  930. // 字符串预留9
  931. pDev->m_strReserved9 = (*it_str_reserved9++).c_str();
  932. // 字符串预留10
  933. pDev->m_strReserved10 = (*it_str_reserved10++).c_str();
  934. // 整形预留1
  935. pDev->m_nReserved1 = atoi((*it_int_reserved1++).c_str());
  936. // 整形预留2
  937. pDev->m_nReserved2 = atoi((*it_int_reserved2++).c_str());
  938. // 整形预留3
  939. pDev->m_nReserved3 = atoi((*it_int_reserved3++).c_str());
  940. // 整形预留4
  941. pDev->m_nReserved4 = atoi((*it_int_reserved4++).c_str());
  942. // 整形预留5
  943. pDev->m_nReserved5 = atoi((*it_int_reserved5++).c_str());
  944. // 整形预留6
  945. pDev->m_nReserved6 = atoi((*it_int_reserved6++).c_str());
  946. // 整形预留7
  947. pDev->m_nReserved7 = atoi((*it_int_reserved7++).c_str());
  948. // 整形预留8
  949. pDev->m_nReserved8 = atoi((*it_int_reserved8++).c_str());
  950. // 整形预留9
  951. pDev->m_nReserved9 = atoi((*it_int_reserved9++).c_str());
  952. // 整形预留10
  953. pDev->m_nReserved10 = atoi((*it_int_reserved10++).c_str());
  954. CString strBoolReserved1 = (*it_bool_reserved1++).c_str();
  955. //LOG4C((LOG_NOTICE, "strBoolReserved1=%s", strBoolReserved1));
  956. //布尔型预留1
  957. if( 0 == atoi(strBoolReserved1) )
  958. {
  959. pDev->m_bReserved1 = false;
  960. }
  961. else
  962. {
  963. pDev->m_bReserved1 = true;
  964. }
  965. //布尔型预留2
  966. if( 0 == atoi((*it_bool_reserved2++).c_str()) )
  967. {
  968. pDev->m_bReserved2 = false;
  969. }
  970. else
  971. {
  972. pDev->m_bReserved2 = true;
  973. }
  974. //布尔型预留3
  975. if( 0 == atoi((*it_bool_reserved3++).c_str()) )
  976. {
  977. pDev->m_bReserved3 = false;
  978. }
  979. else
  980. {
  981. pDev->m_bReserved3 = true;
  982. }
  983. //布尔型预留4
  984. if( 0 == atoi((*it_bool_reserved4++).c_str()) )
  985. {
  986. pDev->m_bReserved4 = false;
  987. }
  988. else
  989. {
  990. pDev->m_bReserved4 = true;
  991. }
  992. //布尔型预留5
  993. if( 0 == atoi((*it_bool_reserved5++).c_str()) )
  994. {
  995. pDev->m_bReserved5 = false;
  996. }
  997. else
  998. {
  999. pDev->m_bReserved5 = true;
  1000. }
  1001. //布尔型预留6
  1002. if( 0 == atoi((*it_bool_reserved6++).c_str()) )
  1003. {
  1004. pDev->m_bReserved6 = false;
  1005. }
  1006. else
  1007. {
  1008. pDev->m_bReserved6 = true;
  1009. }
  1010. //布尔型预留7
  1011. if( 0 == atoi((*it_bool_reserved7++).c_str()) )
  1012. {
  1013. pDev->m_bReserved7 = false;
  1014. }
  1015. else
  1016. {
  1017. pDev->m_bReserved7 = true;
  1018. }
  1019. //布尔型预留8
  1020. if( 0 == atoi((*it_bool_reserved8++).c_str()) )
  1021. {
  1022. pDev->m_bReserved8 = false;
  1023. }
  1024. else
  1025. {
  1026. pDev->m_bReserved8 = true;
  1027. }
  1028. //布尔型预留9
  1029. if( 0 == atoi((*it_bool_reserved9++).c_str()) )
  1030. {
  1031. pDev->m_bReserved9 = false;
  1032. }
  1033. else
  1034. {
  1035. pDev->m_bReserved9 = true;
  1036. }
  1037. //布尔型预留10
  1038. if( 0 == atoi((*it_bool_reserved10++).c_str()) )
  1039. {
  1040. pDev->m_bReserved10 = false;
  1041. }
  1042. else
  1043. {
  1044. pDev->m_bReserved10 = true;
  1045. }
  1046. if( pDevicesManager )
  1047. {
  1048. FindDriverIsExist( pDev,pChannel->m_nCommunicateType,pChannel->m_nAddr );
  1049. int nTmpChannelIndex=0,nTmpDeviceIndex=0;
  1050. if( pChannel->m_nCommunicateType==0 )
  1051. {
  1052. int nChannelsSize = pDevicesManager->m_channels.GetCount();
  1053. int nRet = pDevicesManager->FindCommPort( pChannel->m_strName );
  1054. if( nRet != -1 )
  1055. {
  1056. delete pChannel;//#####
  1057. pDevicesManager->m_channels[nRet]->m_Devices.Add( pDev );
  1058. }
  1059. else
  1060. {
  1061. pDevicesManager->m_channels.Add( pChannel );
  1062. pDevicesManager->m_channels[nChannelsSize]->m_Devices.Add( pDev );
  1063. }
  1064. }
  1065. else
  1066. {
  1067. int nChannelsSize = pDevicesManager->m_channels.GetCount();
  1068. int nRet = pDevicesManager->FindCommPort( pChannel->m_strName );
  1069. if( nRet != -1 )
  1070. {
  1071. delete pChannel;//#####
  1072. pDevicesManager->m_channels[nRet]->m_Devices.Add( pDev );
  1073. }
  1074. else
  1075. {
  1076. pChannel->m_strPort = "";
  1077. pDevicesManager->m_channels.Add( pChannel );
  1078. pDevicesManager->m_channels[nChannelsSize]->m_Devices.Add( pDev );
  1079. }
  1080. }
  1081. }
  1082. }
  1083. }
  1084. for( it_dev_id = list_dev_id.begin(), it_uid = list_uid.begin(), it_port = list_port.begin()
  1085. ,it_device_name = list_device_name.begin(), it_device_baudrate = list_device_baudrate.begin()
  1086. ,it_commmode = list_commmode.begin(), it_devide_addr = list_devide_addr.begin()
  1087. ,it_is_use = list_is_use.begin(),it_protocol_dll_name = list_protocol_dll_name.begin()
  1088. ,it_special_device = list_special_device.begin(), it_data_bit = list_data_bit.begin()
  1089. ,it_stop_bit = list_stop_bit.begin(), it_parity_bit = list_parity_bit.begin(), it_ip = list_ip.begin()
  1090. ,it_ip_port = list_ip_port.begin(), it_ini_name = list_ini_name.begin()
  1091. ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin()
  1092. ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin()
  1093. ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin()
  1094. ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin()
  1095. ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin()
  1096. ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin()
  1097. ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin()
  1098. ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin()
  1099. ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin()
  1100. ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin()
  1101. ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin()
  1102. ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin()
  1103. ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin()
  1104. ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin()
  1105. ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin();
  1106. it_dev_id != list_dev_id.end(), it_uid != list_uid.end(), it_port != list_port.end()
  1107. ,it_device_name != list_device_name.end(), it_device_baudrate != list_device_baudrate.end()
  1108. ,it_commmode != list_commmode.end(), it_devide_addr != list_devide_addr.end()
  1109. ,it_is_use != list_is_use.end(),it_protocol_dll_name != list_protocol_dll_name.end()
  1110. ,it_special_device != list_special_device.end(), it_data_bit != list_data_bit.end()
  1111. ,it_stop_bit != list_stop_bit.end(), it_parity_bit != list_parity_bit.end(), it_ip != list_ip.end()
  1112. ,it_ip_port != list_ip_port.end(), it_ini_name != list_ini_name.end()
  1113. ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end()
  1114. ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end()
  1115. ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end()
  1116. ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end()
  1117. ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end()
  1118. ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end()
  1119. ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end()
  1120. ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end()
  1121. ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end()
  1122. ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end()
  1123. ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end()
  1124. ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end()
  1125. ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end()
  1126. ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end()
  1127. ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end();
  1128. )
  1129. {
  1130. list_dev_id.erase(it_dev_id++);
  1131. list_uid.erase(it_uid++);
  1132. list_port.erase(it_port++);
  1133. list_device_name.erase(it_device_name++);
  1134. list_device_baudrate.erase(it_device_baudrate++);
  1135. list_commmode.erase(it_commmode++);
  1136. list_devide_addr.erase(it_devide_addr++);
  1137. list_is_use.erase(it_is_use++);
  1138. list_protocol_dll_name.erase(it_protocol_dll_name++);
  1139. list_special_device.erase(it_special_device++);
  1140. list_data_bit.erase(it_data_bit++);
  1141. list_stop_bit.erase(it_stop_bit++);
  1142. list_parity_bit.erase(it_parity_bit++);
  1143. list_ip.erase(it_ip++);
  1144. list_ip_port.erase(it_ip_port++);
  1145. list_ini_name.erase(it_ini_name++);
  1146. list_str_reserved1.erase(it_str_reserved1++);
  1147. list_str_reserved2.erase(it_str_reserved2++);
  1148. list_str_reserved3.erase(it_str_reserved3++);
  1149. list_str_reserved4.erase(it_str_reserved4++);
  1150. list_str_reserved5.erase(it_str_reserved5++);
  1151. list_str_reserved6.erase(it_str_reserved6++);
  1152. list_str_reserved7.erase(it_str_reserved7++);
  1153. list_str_reserved8.erase(it_str_reserved8++);
  1154. list_str_reserved9.erase(it_str_reserved9++);
  1155. list_str_reserved10.erase(it_str_reserved10++);
  1156. list_int_reserved1.erase(it_int_reserved1++);
  1157. list_int_reserved2.erase(it_int_reserved2++);
  1158. list_int_reserved3.erase(it_int_reserved3++);
  1159. list_int_reserved4.erase(it_int_reserved4++);
  1160. list_int_reserved5.erase(it_int_reserved5++);
  1161. list_int_reserved6.erase(it_int_reserved6++);
  1162. list_int_reserved7.erase(it_int_reserved7++);
  1163. list_int_reserved8.erase(it_int_reserved8++);
  1164. list_int_reserved9.erase(it_int_reserved9++);
  1165. list_int_reserved10.erase(it_int_reserved10++);
  1166. list_bool_reserved1.erase(it_bool_reserved1++);
  1167. list_bool_reserved2.erase(it_bool_reserved2++);
  1168. list_bool_reserved3.erase(it_bool_reserved3++);
  1169. list_bool_reserved4.erase(it_bool_reserved4++);
  1170. list_bool_reserved5.erase(it_bool_reserved5++);
  1171. list_bool_reserved6.erase(it_bool_reserved6++);
  1172. list_bool_reserved7.erase(it_bool_reserved7++);
  1173. list_bool_reserved8.erase(it_bool_reserved8++);
  1174. list_bool_reserved9.erase(it_bool_reserved9++);
  1175. list_bool_reserved10.erase(it_bool_reserved10++);
  1176. }
  1177. return nRet;
  1178. }
  1179. //获取指定厂家的设备型号ID
  1180. INT CDBInterface::GetDriverName( int nDriverID, CString &sDriverName )
  1181. {
  1182. CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
  1183. list<string> list1;
  1184. list<string>::iterator it;
  1185. if (!_stricmp(m_chDBType, "SQL SERVER"))
  1186. {
  1187. sprintf(strSQLText, "select top 1 drivename from t_dev_drive where id = %d", nDriverID );
  1188. }
  1189. else if (!_stricmp(m_chDBType, "ACCESS97"))
  1190. {
  1191. sprintf(strSQLText, "select top 1 drivename from t_dev_drive where id = %d", nDriverID );
  1192. }
  1193. else if (!_stricmp(m_chDBType, "ACCESS2000"))
  1194. {
  1195. sprintf(strSQLText, "select top 1 drivename from t_dev_drive where id = %d", nDriverID );
  1196. }
  1197. else if(!_stricmp(m_chDBType, "PGSQL"))
  1198. {
  1199. sprintf(strSQLText, "select drivename from t_dev_drive where id = %d limit 1", nDriverID );
  1200. }
  1201. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList1(strSQLText, list1);
  1202. if( 0 == list1.size() )
  1203. {
  1204. return 0;
  1205. }
  1206. if( nRet != -1 )
  1207. {
  1208. sDriverName = list1.begin()->c_str();
  1209. //strcpy( pDriverName, list1.begin()->c_str() );
  1210. }
  1211. for( it = list1.begin(); it != list1.end(); )
  1212. {
  1213. list1.erase(it++);
  1214. }
  1215. return nRet;
  1216. }
  1217. //获取指定驱动ID和厂家ID的厂家名称
  1218. INT CDBInterface::GetFactoryName( int nDriverID, int nFactoryID, CString &sFactoryName )
  1219. {
  1220. CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
  1221. list<string> list1;
  1222. list<string>::iterator it;
  1223. if (!_stricmp(m_chDBType, "SQL SERVER"))
  1224. {
  1225. sprintf(strSQLText, "select top 1 factoryname from t_dev_factory where deviceid = %d and factoryid = %d", nDriverID, nFactoryID );
  1226. }
  1227. else if (!_stricmp(m_chDBType, "ACCESS97"))
  1228. {
  1229. sprintf(strSQLText, "select top 1 factoryname from t_dev_factory where deviceid = %d and factoryid = %d", nDriverID, nFactoryID );
  1230. }
  1231. else if (!_stricmp(m_chDBType, "ACCESS2000"))
  1232. {
  1233. sprintf(strSQLText, "select top 1 factoryname from t_dev_factory where deviceid = %d and factoryid = %d", nDriverID, nFactoryID );
  1234. }
  1235. else if(!_stricmp(m_chDBType, "PGSQL"))
  1236. {
  1237. sprintf(strSQLText, "select factoryname from t_dev_factory where deviceid = %d and factoryid = %d limit 1", nDriverID, nFactoryID );
  1238. }
  1239. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList1(strSQLText, list1);
  1240. if( 0 == list1.size() )
  1241. {
  1242. return 0;
  1243. }
  1244. if( nRet != -1 )
  1245. {
  1246. sFactoryName = list1.begin()->c_str();
  1247. //strcpy( pFactoryName, list1.begin()->c_str() );
  1248. }
  1249. for( it = list1.begin(); it != list1.end(); )
  1250. {
  1251. list1.erase(it++);
  1252. }
  1253. return nRet;
  1254. }
  1255. //获取指定驱动ID,厂家ID和设备类型ID的名称
  1256. INT CDBInterface::GetDevicesName( int nDriverID, int nFactoryID, int nDevicesID,CString &sDevicesName )
  1257. {
  1258. CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
  1259. list<string> list1;
  1260. list<string>::iterator it;
  1261. if (!_stricmp(m_chDBType, "SQL SERVER"))
  1262. {
  1263. sprintf(strSQLText, "select top 1 equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d", nDevicesID,nFactoryID, nDriverID );
  1264. }
  1265. else if (!_stricmp(m_chDBType, "ACCESS97"))
  1266. {
  1267. sprintf(strSQLText, "select top 1 equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d", nDevicesID,nFactoryID, nDriverID );
  1268. }
  1269. else if (!_stricmp(m_chDBType, "ACCESS2000"))
  1270. {
  1271. sprintf(strSQLText, "select top 1 equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d", nDevicesID,nFactoryID, nDriverID );
  1272. }
  1273. else if(!_stricmp(m_chDBType, "PGSQL"))
  1274. {
  1275. sprintf(strSQLText, "select equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d limit 1", nDevicesID,nFactoryID, nDriverID );
  1276. }
  1277. int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList1(strSQLText, list1);
  1278. if( 0 == list1.size() )
  1279. {
  1280. return 0;
  1281. }
  1282. if( nRet != -1 )
  1283. {
  1284. sDevicesName = list1.begin()->c_str();
  1285. //strcpy( pDevicesName, list1.begin()->c_str() );
  1286. }
  1287. for( it = list1.begin(); it != list1.end(); )
  1288. {
  1289. list1.erase(it++);
  1290. }
  1291. return nRet;
  1292. }
  1293. bool CDBInterface::FindDriverIsExist( CDevice* pDev,int iCommunicateType,int iAddr )
  1294. {
  1295. bool bRet = false;
  1296. bool bBreak = false;
  1297. for( int i = 0; i < pDevicesManager->m_channels.GetSize(); i++ )
  1298. {
  1299. CChannel *pChannel = pDevicesManager->m_channels.GetAt( i );
  1300. for( int j = 0; j <pChannel->m_Devices.GetSize(); j++ )
  1301. {
  1302. if( pChannel->m_Devices[j]->m_strName == pDev->m_strName )
  1303. {
  1304. LOG4C((LOG_NOTICE, "设备名重复 设备名:%s",pDev->m_strName ));
  1305. bRet = true;
  1306. bBreak = true;
  1307. break;
  1308. }
  1309. }
  1310. if( iCommunicateType==0 )
  1311. {
  1312. if( pChannel->m_nCommunicateType==iCommunicateType && pChannel->m_nAddr==iAddr )
  1313. {
  1314. for( int j = 0; j <pChannel->m_Devices.GetSize(); j++ )
  1315. {
  1316. if( pChannel->m_Devices[j]->m_Address == pDev->m_Address )
  1317. {
  1318. LOG4C((LOG_NOTICE, "设备地址重复 设备名:%s, 端口:%d, 地址:%d",pDev->m_strName,iAddr,pDev->m_Address ));
  1319. bRet = true;
  1320. bBreak = true;
  1321. break;
  1322. }
  1323. }
  1324. }
  1325. }
  1326. else
  1327. {
  1328. if( pChannel->m_nCommunicateType==iCommunicateType )
  1329. {
  1330. for( int j = 0; j <pChannel->m_Devices.GetSize(); j++ )
  1331. {
  1332. if( pChannel->m_Devices[j]->m_strDevIP == pDev->m_strDevIP )//&& pChannel->m_Devices[j]->m_nNetPort==pDev->m_nNetPort )
  1333. {
  1334. LOG4C((LOG_NOTICE, "设备IP重复 设备名:%s IP:%s",pDev->m_strName,pDev->m_strDevIP ));
  1335. bRet = true;
  1336. bBreak = true;
  1337. break;
  1338. }
  1339. }
  1340. }
  1341. }
  1342. if( bBreak )
  1343. break;
  1344. }
  1345. return bRet;
  1346. }
  1347. bool CDBInterface::FindVarIsExist( CAnalog *pBaseVar )
  1348. {
  1349. bool bRet = false;
  1350. for( int i = 0; i < pVariantsManager->m_analog.GetSize(); i++ )
  1351. {
  1352. CAnalog *pAnalog = pVariantsManager->m_analog.GetAt( i );
  1353. if( pAnalog->m_nVarID==pBaseVar->m_nVarID )
  1354. {
  1355. LOG4C((LOG_NOTICE, "变量ID重复 %d",pBaseVar->m_nVarID ));
  1356. }
  1357. if( pAnalog->m_strName==pBaseVar->m_strName )
  1358. {
  1359. LOG4C((LOG_NOTICE, "变量名重复 %s",pBaseVar->m_strName ));
  1360. }
  1361. break;
  1362. }
  1363. return bRet;
  1364. }
  1365. //得到不合法的变量问题
  1366. CString CDBInterface::GetInvalidMessage( CString sVarName,int iInitValue,int iMinValue,int iMaxValue,int iLowerValue,int iUpperValue,int iNormalValue,int iWarningLevel,int iIdentifyTime )
  1367. {
  1368. CString sRet,s;
  1369. if(sVarName=="" )
  1370. {
  1371. s = "变量名不能为空; ";
  1372. sRet += s;
  1373. }
  1374. for( int i=0;i<sVarName.GetLength();i++ )
  1375. {
  1376. if( (sVarName[i]>='0'&&sVarName[i]<='9') || (sVarName[i]>='a'&&sVarName[i]<='z') || (sVarName[i]>='A'&&sVarName[i]<='Z') || (sVarName[i]=='_' ))
  1377. {
  1378. if( i==0 && ( (sVarName[i]>='0'&&sVarName[i]<='9') || (sVarName[i]=='_' ) ) )
  1379. {
  1380. s = "变量名有误,只能是字母开头; ";
  1381. sRet += s;
  1382. break;
  1383. }
  1384. }
  1385. else
  1386. {
  1387. s = "变量名有误,含有非法字符; ";
  1388. sRet += s;
  1389. break;
  1390. }
  1391. }
  1392. if( iMaxValue==0 )
  1393. {
  1394. s = "变量最大值不能为0; ";
  1395. sRet += s;
  1396. }
  1397. if( iMinValue>iMaxValue )
  1398. {
  1399. s = "变量最小值不能大于变量最大值; ";
  1400. sRet += s;
  1401. }
  1402. if( iInitValue<iMinValue || iInitValue>iMaxValue )
  1403. {
  1404. s = "变量初始值有误,不在最小最大值之间; ";
  1405. sRet += s;
  1406. }
  1407. if( iLowerValue>iUpperValue )
  1408. {
  1409. s = "变量下限与上限设置有误; ";
  1410. sRet += s;
  1411. }
  1412. if( iLowerValue==0 && iUpperValue==0 )
  1413. {
  1414. if( iNormalValue != iInitValue )
  1415. {
  1416. s = "干接点变量的正常状态与初始值不相等; ";
  1417. sRet += s;
  1418. }
  1419. }
  1420. else
  1421. {
  1422. if( iInitValue<iLowerValue || iInitValue>iUpperValue )
  1423. {
  1424. s = "变量初始值有误,不在下限与上限之间; ";
  1425. sRet += s;
  1426. }
  1427. }
  1428. if( iWarningLevel==0 )
  1429. {
  1430. s = "变量的报警级别为0; ";
  1431. sRet += s;
  1432. }
  1433. if( iIdentifyTime==0 )
  1434. {
  1435. s = "变量的辨识时间不能等于0; ";
  1436. sRet += s;
  1437. }
  1438. return sRet;
  1439. }
  1440. };