/************************************************************* /* Copyright (C), 2008-2010, StoneU Tech. Co., Ltd. /* 文件名: DBInterface.h /* 作者: Jesse /* 创建日期: 2010-08-02 /* 版本号: V1.0 /* 描述: 实现多种数据库的支持 /* 其它: /* 主要类模块: CDBInterface /* 历史修改记录: 作者 时间 版本 描述 Jesse 10/08/02 1.0 创建这个模块 ***************************************************************/ #include "stdafx.h" #include "DBInterface.h" #include "kernel.h" namespace DBInterface { CDBInterface* CDBInterface::m_pDBInterface = NULL; // 静态成员函数，提供全局访问的接口 CDBInterface* CDBInterface::GetInstancePtr() { if( NULL == m_pDBInterface ) { m_pDBInterface = new CDBInterface(); } return m_pDBInterface; } // 释放资源 void CDBInterface::Release() { if( m_pDBInterface ) delete m_pDBInterface; m_pDBInterface = NULL; } // 设置数据库类型 void CDBInterface::SetDBType(char *pDBType) { strcpy(m_chDBType, pDBType); } //得到时间计划 INT CDBInterface::GetDatePlan( int nPlanType, CHAR *pPlanID, unsigned char nBufDate[7][24] ) {//0：星期一 1：星期二 6：星期天 CHAR strSQLText[MAX_SQL_LENGTH + 1] = ""; list list1, list2, list3, list4; list::iterator it_list1, it_list2, it_list3, it_list4; sprintf(strSQLText, "select starttime, endtime, startweekofday, endweekofday " \ "from t_plan_info where planid=\'%s\' and plantype = %d", pPlanID, nPlanType); int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList4(strSQLText, list1, list2, list3, list4); if( list1.size() == 0 || list2.size() == 0 || list3.size() == 0 || list4.size() == 0 ) { return 0; } if( nRet != -1 ) { for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin(); it_list1 != list1.end() && it_list2 != list2.end() && it_list3 != list3.end() && it_list4 != list4.end(); it_list1++, it_list2++, it_list3++, it_list4++) { for( int i = atoi((*it_list3).c_str()); i < atoi((*it_list4).c_str()) + 1; i++ ) { for( int j = atoi((*it_list1).c_str()); j < atoi((*it_list2).c_str()) + 1; j++ ) { nBufDate[i][j] = 15; } } } } for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin(); it_list1 != list1.end(), it_list2 != list2.end(), it_list3 != list3.end(), it_list4 != list4.end(); ) { list1.erase(it_list1++); list2.erase(it_list2++); list3.erase(it_list3++); list4.erase(it_list4++); } return nRet; } //得到时间计划 INT CDBInterface::GetDatePlan( int nPlanType, CHAR *pUid, int nVarID, unsigned char nBufDate[7][24] ) { CHAR strSQLText[MAX_SQL_LENGTH + 1] = ""; list list1, list2, list3, list4; list::iterator it_list1, it_list2, it_list3, it_list4; sprintf(strSQLText, "select starttime, endtime, startweekofday, endweekofday " \ "from t_plan_info where uid=\'%s\' and varid = %d and plantype = %d", pUid, nVarID, nPlanType); int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList4(strSQLText, list1, list2, list3, list4); if( list1.size() == 0 || list2.size() == 0 || list3.size() == 0 || list4.size() == 0 ) { return 0; } if( nRet != -1 ) { for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin(); it_list1 != list1.end() && it_list2 != list2.end() && it_list3 != list3.end() && it_list4 != list4.end(); it_list1++, it_list2++, it_list3++, it_list4++ ) { for( int i = atoi((*it_list3).c_str()); i < atoi((*it_list4).c_str()) + 1; i++ ) { for( int j = atoi((*it_list1).c_str()); j < atoi((*it_list2).c_str()) + 1; j++ ) { nBufDate[i][j] = 15; } } } } for( it_list1 = list1.begin(), it_list2 = list2.begin(), it_list3 = list3.begin(), it_list4 = list4.begin(); it_list1 != list1.end(), it_list2 != list2.end(), it_list3 != list3.end(), it_list4 != list4.end(); ) { list1.erase(it_list1++); list2.erase(it_list2++); list3.erase(it_list3++); list4.erase(it_list4++); } return nRet; } //获取变量 INT CDBInterface::GetVarInfo() { CHAR strSQLText[MAX_SQL_LENGTH * 2] = {0}; list list_var_id, list_set_value, list_var_name, list_uid, list_upper_limit; list list_lower_limit, list_normal_state, list_identify_time, list_redetect_time; list list_normal_is_notice, list_warn_level, list_snmp_oid, list_fields, list_description; list list_max_values, list_min_values, list_max_convtrate, list_min_convtrate, list_is_save; list list_collect_freq, list_var_type_id, list_readonly, list_is_dde, list_address, list_unit; list list_reccurve, list_register_num, list_child_id, list_var_item_id, list_rearm, list_offsets; list list_funcid, list_data_len, list_coefficient, list_realtimeflag; list list_rs232_cmd, list_rs232_type, list_rs232_index; list list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5; list list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10; list list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5; list list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10; list list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5; list list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10; list::iterator it_var_id, it_set_value, it_var_name, it_uid, it_upper_limit; list::iterator it_lower_limit, it_normal_state, it_identify_time, it_redetect_time; list::iterator it_normal_is_notice, it_warn_level, it_snmp_oid, it_fields, it_description; list::iterator it_max_values, it_min_values, it_max_convtrate, it_min_convtrate, it_is_save; list::iterator it_collect_freq, it_var_type_id, it_readonly, it_is_dde, it_address, it_unit; list::iterator it_reccurve, it_register_num, it_child_id, it_var_item_id, it_rearm, it_offsets; list::iterator it_funcid, it_data_len, it_coefficient, it_realtimeflag; list::iterator it_rs232_cmd, it_rs232_type, it_rs232_index; list::iterator it_str_reserved1, it_str_reserved2, it_str_reserved3, it_str_reserved4, it_str_reserved5; list::iterator it_str_reserved6, it_str_reserved7, it_str_reserved8, it_str_reserved9, it_str_reserved10; list::iterator it_int_reserved1, it_int_reserved2, it_int_reserved3, it_int_reserved4, it_int_reserved5; list::iterator it_int_reserved6, it_int_reserved7, it_int_reserved8, it_int_reserved9, it_int_reserved10; list::iterator it_bool_reserved1, it_bool_reserved2, it_bool_reserved3, it_bool_reserved4, it_bool_reserved5; list::iterator it_bool_reserved6, it_bool_reserved7, it_bool_reserved8, it_bool_reserved9, it_bool_reserved10; if (!_stricmp(m_chDBType, "SQL SERVER")) { sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \ "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \ "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \ "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \ "var_item_id, rearm, [offsets], funcid, datalen, coefficient, realtimeflag, " \ "rs232cmd, rs232type, rs232index, " \ "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \ "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \ "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \ "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \ "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \ "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \ "from t_dev_variant order by id"); } else if (!_stricmp(m_chDBType, "ACCESS97")) { sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \ "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \ "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \ "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \ "var_item_id, rearm, [offsets], funcid, datalen, coefficient, realtimeflag, " \ "rs232cmd, rs232type, rs232index, " \ "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \ "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \ "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \ "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \ "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \ "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \ "from t_dev_variant order by id"); } else if (!_stricmp(m_chDBType, "ACCESS2000")) { sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \ "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \ "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \ "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \ "var_item_id, rearm, [offsets], funcid, datalen, coefficient, realtimeflag, " \ "rs232cmd, rs232type, rs232index, " \ "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \ "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \ "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \ "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \ "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \ "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \ "from t_dev_variant order by id"); } else if(!_stricmp(m_chDBType, "PGSQL")) { sprintf(strSQLText, "select id, setvalue, varname, uid, upperlimit, lowerlimit, normalstate, " \ "identifytime, redetecttime, normalisnotice, warnlevel, snmpoid, fields, description, " \ "maxvalues, minvalues, maxconvtrate, minconvtrate, issave, collectfrequence, " \ "vartypeid, readonly, isdde, address, unit, reccurve, registernum, childid, " \ "var_item_id, rearm, offsets, funcid, datalen, coefficient, realtimeflag, " \ "rs232cmd, rs232type, rs232index, " \ "strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \ "strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \ "intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \ "intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \ "boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \ "boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \ "from t_dev_variant order by id"); } //LOG4C((LOG_NOTICE, "%s", strSQLText)); int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList68(strSQLText ,list_var_id, list_set_value, list_var_name, list_uid, list_upper_limit ,list_lower_limit, list_normal_state, list_identify_time, list_redetect_time ,list_normal_is_notice, list_warn_level, list_snmp_oid, list_fields, list_description ,list_max_values, list_min_values, list_max_convtrate, list_min_convtrate, list_is_save ,list_collect_freq, list_var_type_id, list_readonly, list_is_dde, list_address, list_unit ,list_reccurve, list_register_num, list_child_id, list_var_item_id, list_rearm, list_offsets ,list_funcid, list_data_len, list_coefficient, list_realtimeflag ,list_rs232_cmd, list_rs232_type, list_rs232_index ,list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5 ,list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10 ,list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5 ,list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10 ,list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5 ,list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10); if( 0 == list_var_id.size() || 0 == list_set_value.size() || 0 == list_var_name.size() || 0 == list_uid.size() || 0 == list_upper_limit.size() || 0 == list_lower_limit.size() || 0 == list_normal_state.size() || 0 == list_identify_time.size() || 0 == list_redetect_time.size() || 0 == list_normal_is_notice.size() || 0 == list_warn_level.size() || 0 == list_snmp_oid.size() || 0 == list_fields.size() || 0 == list_description.size() || 0 == list_max_values.size() || 0 == list_min_values.size() || 0 == list_max_convtrate.size() || 0 == list_min_convtrate.size() || 0 == list_is_save.size() || 0 == list_collect_freq.size() || 0 == list_var_type_id.size() || 0 == list_readonly.size() || 0 == list_is_dde.size() || 0 == list_address.size() || 0 == list_unit.size() || 0 == list_reccurve.size() || 0 == list_register_num.size() || 0 == list_child_id.size() || 0 == list_var_item_id.size() || 0 == list_rearm.size() || 0 == list_offsets.size() || 0 == list_funcid.size() || 0 == list_data_len.size() || 0 == list_coefficient.size() || 0 == list_realtimeflag.size() || 0 == list_rs232_cmd.size() || 0 == list_rs232_type.size() || 0 == list_rs232_index.size() || 0 == list_str_reserved1.size() || 0 == list_str_reserved2.size() || 0 == list_str_reserved3.size() || 0 == list_str_reserved4.size() || 0 == list_str_reserved5.size() || 0 == list_str_reserved6.size() || 0 == list_str_reserved7.size() || 0 == list_str_reserved8.size() || 0 == list_str_reserved9.size() || 0 == list_str_reserved10.size() || 0 == list_int_reserved1.size() || 0 == list_int_reserved2.size() || 0 == list_int_reserved3.size() || 0 == list_int_reserved4.size() || 0 == list_int_reserved5.size() || 0 == list_int_reserved6.size() || 0 == list_int_reserved7.size() || 0 == list_int_reserved8.size() || 0 == list_int_reserved9.size() || 0 == list_int_reserved10.size() || 0 == list_bool_reserved1.size() || 0 == list_bool_reserved2.size() || 0 == list_bool_reserved3.size() || 0 == list_bool_reserved4.size() || 0 == list_bool_reserved5.size() || 0 == list_bool_reserved6.size() || 0 == list_bool_reserved7.size() || 0 == list_bool_reserved8.size() || 0 == list_bool_reserved9.size() || 0 == list_bool_reserved10.size() ) { return 0; } if( nRet != -1 ) { for( it_var_id = list_var_id.begin(), it_set_value = list_set_value.begin(), it_var_name = list_var_name.begin() ,it_uid = list_uid.begin(), it_upper_limit = list_upper_limit.begin() ,it_lower_limit = list_lower_limit.begin(), it_normal_state = list_normal_state.begin() ,it_identify_time = list_identify_time.begin(),it_redetect_time = list_redetect_time.begin() ,it_normal_is_notice = list_normal_is_notice.begin(), it_warn_level = list_warn_level.begin() ,it_snmp_oid = list_snmp_oid.begin(), it_fields = list_fields.begin(), it_description = list_description.begin() ,it_max_values = list_max_values.begin(), it_min_values = list_min_values.begin() ,it_max_convtrate = list_max_convtrate.begin(), it_min_convtrate = list_min_convtrate.begin() ,it_is_save = list_is_save.begin(), it_collect_freq = list_collect_freq.begin(), it_var_type_id = list_var_type_id.begin() ,it_readonly = list_readonly.begin(), it_is_dde = list_is_dde.begin(), it_address = list_address.begin() ,it_unit = list_unit.begin(), it_reccurve = list_reccurve.begin(), it_register_num = list_register_num.begin() ,it_child_id = list_child_id.begin(), it_var_item_id = list_var_item_id.begin() ,it_rearm = list_rearm.begin(), it_offsets = list_offsets.begin(), it_funcid = list_funcid.begin() ,it_data_len = list_data_len.begin(), it_coefficient = list_coefficient.begin(), it_realtimeflag = list_realtimeflag.begin() ,it_rs232_cmd = list_rs232_cmd.begin(), it_rs232_type = list_rs232_type.begin(), it_rs232_index = list_rs232_index.begin() ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin() ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin() ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin() ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin() ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin() ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin() ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin() ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin() ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin() ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin() ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin() ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin() ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin() ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin() ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin(); it_var_id != list_var_id.end(), it_set_value != list_set_value.end(), it_var_name != list_var_name.end() ,it_uid != list_uid.end(), it_upper_limit != list_upper_limit.end() ,it_lower_limit != list_lower_limit.end(), it_normal_state != list_normal_state.end() ,it_identify_time != list_identify_time.end(),it_redetect_time != list_redetect_time.end() ,it_normal_is_notice != list_normal_is_notice.end(), it_warn_level != list_warn_level.end() ,it_snmp_oid != list_snmp_oid.end(), it_fields != list_fields.end(), it_description != list_description.end() ,it_max_values != list_max_values.end(), it_min_values != list_min_values.end() ,it_max_convtrate != list_max_convtrate.end(), it_min_convtrate != list_min_convtrate.end() ,it_is_save != list_is_save.end(), it_collect_freq != list_collect_freq.end(), it_var_type_id != list_var_type_id.end() ,it_readonly != list_readonly.end(), it_is_dde != list_is_dde.end(), it_address != list_address.end() ,it_unit != list_unit.end(), it_reccurve != list_reccurve.end(), it_register_num != list_register_num.end() ,it_child_id != list_child_id.end(), it_var_item_id != list_var_item_id.end() ,it_rearm != list_rearm.end(), it_offsets != list_offsets.end(), it_funcid != list_funcid.end() ,it_data_len != list_data_len.end(), it_coefficient != list_coefficient.end(), it_realtimeflag != list_realtimeflag.end() ,it_rs232_cmd != list_rs232_cmd.end(), it_rs232_type != list_rs232_type.end(), it_rs232_index != list_rs232_index.end() ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end() ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end() ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end() ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end() ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end() ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end() ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end() ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end() ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end() ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end() ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end() ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end() ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end() ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end() ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end(); ) { //CBaseVar *pBaseVar; //pBaseVar = new CBaseVar(); CAnalog *pBaseVar; pBaseVar = new CAnalog(); int nVarID; CString strUid; nVarID = atoi((*it_var_id++).c_str()); strUid = (*it_uid++).c_str(); // 变量ID pBaseVar->m_nVarID = nVarID; // 设定值 pBaseVar->m_strSetValue = (*it_set_value++).c_str(); // 变量名称 pBaseVar->m_strName = (*it_var_name++).c_str(); // 变量Uid pBaseVar->m_strVarUID = strUid; // 上限 pBaseVar->m_nUpperLimit = atoi((*it_upper_limit++).c_str()); //LOG4C((LOG_NOTICE, "GetVarInfo pBaseVar->m_nUpperLimit = %d", pBaseVar->m_nUpperLimit)); // 下限 pBaseVar->m_nLowerLimit = atoi((*it_lower_limit++).c_str()); // 正常状态 pBaseVar->m_nNormalState = atoi((*it_normal_state++).c_str()); // 辨识时间 pBaseVar->m_nIdentifyTime = atoi((*it_identify_time++).c_str()); // 重新检测时间 pBaseVar->m_nRedetectTime = atoi((*it_redetect_time++).c_str()); // 恢复正常是否触发远程报警 CString strNormalIsNotice = (*it_normal_is_notice++).c_str(); if( 0 == atoi(strNormalIsNotice) ) { pBaseVar->m_bIsNormalAlarm = FALSE; } else { pBaseVar->m_bIsNormalAlarm = TRUE; } // 报警级别 pBaseVar->m_nWaringLevel = atoi((*it_warn_level++).c_str()); // Snmp对象OID pBaseVar->m_strSnmpOid = (*it_snmp_oid++).c_str(); // Snmp对象域 pBaseVar->m_strFields = (*it_fields++).c_str(); // 变量描述 pBaseVar->m_strDesc = (*it_description++).c_str(); // 最大值 pBaseVar->m_nMaxValues = atoi((*it_max_values++).c_str()); // 最小值 pBaseVar->m_nMinValues = atoi((*it_min_values++).c_str()); // 最大比例 pBaseVar->m_nMaxConvtRate = atoi((*it_max_convtrate++).c_str()); // 最小比例 pBaseVar->m_nMinConvtRate = atoi((*it_min_convtrate++).c_str()); // 是否保存数值 CString strIsSave = (*it_is_save++).c_str(); if( 0 == atoi(strIsSave) ) { pBaseVar->m_bIsSave = FALSE; } else { pBaseVar->m_bIsSave = TRUE; } //LOG4C((LOG_NOTICE, "var desc = %s, pBaseVar->m_bIsSave = %d, strIsSave = %s", pBaseVar->m_strDesc, pBaseVar->m_bIsSave, strIsSave)); // 采集频率 pBaseVar->m_nCollectFreq = atoi((*it_collect_freq++).c_str()); // 变量类型ID pBaseVar->m_nVarTypeID = atoi((*it_var_type_id++).c_str()); // 读写权限 CString strReadOnly = (*it_readonly++).c_str(); if( 0 == atoi(strReadOnly) ) { pBaseVar->m_nPurview = FALSE; } else { pBaseVar->m_nPurview = TRUE; } // 是否DDE CString strDDE = (*it_is_dde++).c_str(); if( 0 == atoi(strDDE) ) { pBaseVar->m_bIsDDE = FALSE; } else { pBaseVar->m_bIsDDE = TRUE; } // 寄存器起始地址 pBaseVar->m_nRegStartAddr = atoi((*it_address++).c_str()); // 单位 pBaseVar->m_strUnit = (*it_unit++).c_str(); // 是否记录实时曲线 CString strRecCurve = (*it_reccurve++).c_str(); if( 0 == atoi(strRecCurve) ) { pBaseVar->m_bRecCurve = FALSE; } else { pBaseVar->m_bRecCurve = TRUE; } // 寄存器个数 pBaseVar->m_nRegNum = atoi((*it_register_num++).c_str()); // 变量子ID pBaseVar->m_nVarChildID = atoi((*it_child_id++).c_str()); // t_dev_varint_item表的ID pBaseVar->m_nVarItemID = atoi((*it_var_item_id++).c_str()); // 校正值 pBaseVar->m_nRearm = atoi((*it_rearm++).c_str()); // 偏移值 pBaseVar->m_nOffset = atoi((*it_offsets++).c_str()); // 功能码ID pBaseVar->m_nFuncCode = atoi((*it_funcid++).c_str()); // 数据长度 pBaseVar->m_nDataLen = atoi((*it_data_len++).c_str()); // 系数 pBaseVar->m_fCoef = atof((*it_coefficient++).c_str()); // 是否实时采集 CString strRealTimeFlag = (*it_realtimeflag++).c_str(); //LOG4C((LOG_NOTICE, "strRealTimeFlag = %s, atoi(strRealTimeFlag) = %d", strRealTimeFlag, atoi(strRealTimeFlag))); if( 0 == atoi(strRealTimeFlag) ) { pBaseVar->m_bRealtimeFlag = FALSE; } else { pBaseVar->m_bRealtimeFlag = TRUE; } //LOG4C((LOG_NOTICE, "pBaseVar->m_bRealTimeflag = %d", pBaseVar->m_bRealTimeflag)); // RS232命令 pBaseVar->m_strRs232Cmd = (*it_rs232_cmd++).c_str(); // RS232类型 pBaseVar->m_strRs232Type = (*it_rs232_type++).c_str(); // RS232索引 pBaseVar->m_nRs232Index = atoi((*it_rs232_index++).c_str()); //LOG4C((LOG_NOTICE, "pBaseVar->m_strRs232Index = %s", pBaseVar->m_strRs232Index)); // 字符串预留1 pBaseVar->m_strReserved1 = (*it_str_reserved1++).c_str(); // 字符串预留2 pBaseVar->m_strReserved2 = (*it_str_reserved2++).c_str(); // 字符串预留3 pBaseVar->m_strReserved3 = (*it_str_reserved3++).c_str(); // 字符串预留4 pBaseVar->m_strReserved4 = (*it_str_reserved4++).c_str(); // 字符串预留5 pBaseVar->m_strReserved5 = (*it_str_reserved5++).c_str(); // 字符串预留6 pBaseVar->m_strReserved6 = (*it_str_reserved6++).c_str(); // 字符串预留7 pBaseVar->m_strReserved7 = (*it_str_reserved7++).c_str(); // 字符串预留8 pBaseVar->m_strReserved8 = (*it_str_reserved8++).c_str(); // 字符串预留9 pBaseVar->m_strReserved9 = (*it_str_reserved9++).c_str(); // 字符串预留10 pBaseVar->m_strReserved10 = (*it_str_reserved10++).c_str(); // 整形预留1 pBaseVar->m_nReserved1 = atoi((*it_int_reserved1++).c_str()); // 整形预留2 pBaseVar->m_nReserved2 = atoi((*it_int_reserved2++).c_str()); // 整形预留3 pBaseVar->m_nReserved3 = atoi((*it_int_reserved3++).c_str()); // 整形预留4 pBaseVar->m_nReserved4 = atoi((*it_int_reserved4++).c_str()); // 整形预留5 pBaseVar->m_nReserved5 = atoi((*it_int_reserved5++).c_str()); // 整形预留6 pBaseVar->m_nReserved6 = atoi((*it_int_reserved6++).c_str()); // 整形预留7 pBaseVar->m_nReserved7 = atoi((*it_int_reserved7++).c_str()); // 整形预留8 pBaseVar->m_nReserved8 = atoi((*it_int_reserved8++).c_str()); // 整形预留9 pBaseVar->m_nReserved9 = atoi((*it_int_reserved9++).c_str()); // 整形预留10 pBaseVar->m_nReserved10 = atoi((*it_int_reserved10++).c_str()); CString strBoolReserved1 = (*it_bool_reserved1++).c_str(); //布尔型预留1 if( 0 == atoi(strBoolReserved1) ) { pBaseVar->m_bReserved1 = false; } else { pBaseVar->m_bReserved1 = true; } //布尔型预留2 if( 0 == atoi((*it_bool_reserved2++).c_str()) ) { pBaseVar->m_bReserved2 = false; } else { pBaseVar->m_bReserved2 = true; } CString strBoolReserved3 = (*it_bool_reserved3++).c_str(); //LOG4C((LOG_NOTICE, "strBoolReserved3=%s", strBoolReserved3)); //布尔型预留3 if( 0 == atoi(strBoolReserved3) ) { pBaseVar->m_bReserved3 = false; } else { pBaseVar->m_bReserved3 = true; } //布尔型预留4 if( 0 == atoi((*it_bool_reserved4++).c_str()) ) { pBaseVar->m_bReserved4 = false; } else { pBaseVar->m_bReserved4 = true; } //布尔型预留5 if( 0 == atoi((*it_bool_reserved5++).c_str()) ) { pBaseVar->m_bReserved5 = false; } else { pBaseVar->m_bReserved5 = true; } //布尔型预留6 if( 0 == atoi((*it_bool_reserved6++).c_str()) ) { pBaseVar->m_bReserved6 = false; } else { pBaseVar->m_bReserved6 = true; } //布尔型预留7 if( 0 == atoi((*it_bool_reserved7++).c_str()) ) { pBaseVar->m_bReserved7 = false; } else { pBaseVar->m_bReserved7 = true; } //布尔型预留8 if( 0 == atoi((*it_bool_reserved8++).c_str()) ) { pBaseVar->m_bReserved8 = false; } else { pBaseVar->m_bReserved8 = true; } //布尔型预留9 if( 0 == atoi((*it_bool_reserved9++).c_str()) ) { pBaseVar->m_bReserved9 = false; } else { pBaseVar->m_bReserved9 = true; } //布尔型预留10 if( 0 == atoi((*it_bool_reserved10++).c_str()) ) { pBaseVar->m_bReserved10 = false; } else { pBaseVar->m_bReserved10 = true; } pBaseVar->m_fData = pBaseVar->m_nReserved1; if( pVariantsManager ) { CString sMsg = GetInvalidMessage( pBaseVar->m_strName,pBaseVar->m_nReserved1,pBaseVar->m_nReserved2,pBaseVar->m_nReserved3, pBaseVar->m_nLowerLimit,pBaseVar->m_nUpperLimit,pBaseVar->m_nNormalState,pBaseVar->m_nWaringLevel,pBaseVar->m_nIdentifyTime ); if( sMsg!="" ) { LOG4C((LOG_NOTICE, "变量 %s %s",pBaseVar->m_strName,sMsg )); } FindVarIsExist( pBaseVar ); pVariantsManager->m_analog.Add( pBaseVar ); } } } for( it_var_id = list_var_id.begin(), it_set_value = list_set_value.begin(), it_var_name = list_var_name.begin() ,it_uid = list_uid.begin(), it_upper_limit = list_upper_limit.begin() ,it_lower_limit = list_lower_limit.begin(), it_normal_state = list_normal_state.begin() ,it_identify_time = list_identify_time.begin(),it_redetect_time = list_redetect_time.begin() ,it_normal_is_notice = list_normal_is_notice.begin(), it_warn_level = list_warn_level.begin() ,it_snmp_oid = list_snmp_oid.begin(), it_fields = list_fields.begin(), it_description = list_description.begin() ,it_max_values = list_max_values.begin(), it_min_values = list_min_values.begin() ,it_max_convtrate = list_max_convtrate.begin(), it_min_convtrate = list_min_convtrate.begin() ,it_is_save = list_is_save.begin(), it_collect_freq = list_collect_freq.begin(), it_var_type_id = list_var_type_id.begin() ,it_readonly = list_readonly.begin(), it_is_dde = list_is_dde.begin(), it_address = list_address.begin() ,it_unit = list_unit.begin(), it_reccurve = list_reccurve.begin(), it_register_num = list_register_num.begin() ,it_child_id = list_child_id.begin(), it_var_item_id = list_var_item_id.begin() ,it_rearm = list_rearm.begin(), it_offsets = list_offsets.begin(), it_funcid = list_funcid.begin() ,it_data_len = list_data_len.begin(), it_coefficient = list_coefficient.begin(), it_realtimeflag = list_realtimeflag.begin() ,it_rs232_cmd = list_rs232_cmd.begin(), it_rs232_type = list_rs232_type.begin(), it_rs232_index = list_rs232_index.begin() ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin() ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin() ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin() ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin() ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin() ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin() ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin() ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin() ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin() ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin() ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin() ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin() ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin() ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin() ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin(); it_var_id != list_var_id.end(), it_set_value != list_set_value.end(), it_var_name != list_var_name.end() ,it_uid != list_uid.end(), it_upper_limit != list_upper_limit.end() ,it_lower_limit != list_lower_limit.end(), it_normal_state != list_normal_state.end() ,it_identify_time != list_identify_time.end(),it_redetect_time != list_redetect_time.end() ,it_normal_is_notice != list_normal_is_notice.end(), it_warn_level != list_warn_level.end() ,it_snmp_oid != list_snmp_oid.end(), it_fields != list_fields.end(), it_description != list_description.end() ,it_max_values != list_max_values.end(), it_min_values != list_min_values.end() ,it_max_convtrate != list_max_convtrate.end(), it_min_convtrate != list_min_convtrate.end() ,it_is_save != list_is_save.end(), it_collect_freq != list_collect_freq.end(), it_var_type_id != list_var_type_id.end() ,it_readonly != list_readonly.end(), it_is_dde != list_is_dde.end(), it_address != list_address.end() ,it_unit != list_unit.end(), it_reccurve != list_reccurve.end(), it_register_num != list_register_num.end() ,it_child_id != list_child_id.end(), it_var_item_id != list_var_item_id.end() ,it_rearm != list_rearm.end(), it_offsets != list_offsets.end(), it_funcid != list_funcid.end() ,it_data_len != list_data_len.end(), it_coefficient != list_coefficient.end(), it_realtimeflag != list_realtimeflag.end() ,it_rs232_cmd != list_rs232_cmd.end(), it_rs232_type != list_rs232_type.end(), it_rs232_index != list_rs232_index.end() ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end() ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end() ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end() ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end() ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end() ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end() ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end() ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end() ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end() ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end() ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end() ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end() ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end() ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end() ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end(); ) { list_var_id.erase(it_var_id++); list_set_value.erase(it_set_value++); list_var_name.erase(it_var_name++); list_uid.erase(it_uid++); list_upper_limit.erase(it_upper_limit++); list_lower_limit.erase(it_lower_limit++); list_normal_state.erase(it_normal_state++); list_identify_time.erase(it_identify_time++); list_redetect_time.erase(it_redetect_time++); list_normal_is_notice.erase(it_normal_is_notice++); list_warn_level.erase(it_warn_level++); list_snmp_oid.erase(it_snmp_oid++); list_fields.erase(it_fields++); list_description.erase(it_description++); list_max_values.erase(it_max_values++); list_min_values.erase(it_min_values++); list_max_convtrate.erase(it_max_convtrate++); list_min_convtrate.erase(it_min_convtrate++); list_is_save.erase(it_is_save++); list_collect_freq.erase(it_collect_freq++); list_var_type_id.erase(it_var_type_id++); list_readonly.erase(it_readonly++); list_is_dde.erase(it_is_dde++); list_address.erase(it_address++); list_unit.erase(it_unit++); list_reccurve.erase(it_reccurve++); list_register_num.erase(it_register_num++); list_child_id.erase(it_child_id++); list_var_item_id.erase(it_var_item_id++); list_rearm.erase(it_rearm++); list_offsets.erase(it_offsets++); list_funcid.erase(it_funcid++); list_data_len.erase(it_data_len++); list_coefficient.erase(it_coefficient++); list_realtimeflag.erase(it_realtimeflag++); list_rs232_cmd.erase(it_rs232_cmd++); list_rs232_type.erase(it_rs232_type++); list_rs232_index.erase(it_rs232_index++); list_str_reserved1.erase(it_str_reserved1++); list_str_reserved2.erase(it_str_reserved2++); list_str_reserved3.erase(it_str_reserved3++); list_str_reserved4.erase(it_str_reserved4++); list_str_reserved5.erase(it_str_reserved5++); list_str_reserved6.erase(it_str_reserved6++); list_str_reserved7.erase(it_str_reserved7++); list_str_reserved8.erase(it_str_reserved8++); list_str_reserved9.erase(it_str_reserved9++); list_str_reserved10.erase(it_str_reserved10++); list_int_reserved1.erase(it_int_reserved1++); list_int_reserved2.erase(it_int_reserved2++); list_int_reserved3.erase(it_int_reserved3++); list_int_reserved4.erase(it_int_reserved4++); list_int_reserved5.erase(it_int_reserved5++); list_int_reserved6.erase(it_int_reserved6++); list_int_reserved7.erase(it_int_reserved7++); list_int_reserved8.erase(it_int_reserved8++); list_int_reserved9.erase(it_int_reserved9++); list_int_reserved10.erase(it_int_reserved10++); list_bool_reserved1.erase(it_bool_reserved1++); list_bool_reserved2.erase(it_bool_reserved2++); list_bool_reserved3.erase(it_bool_reserved3++); list_bool_reserved4.erase(it_bool_reserved4++); list_bool_reserved5.erase(it_bool_reserved5++); list_bool_reserved6.erase(it_bool_reserved6++); list_bool_reserved7.erase(it_bool_reserved7++); list_bool_reserved8.erase(it_bool_reserved8++); list_bool_reserved9.erase(it_bool_reserved9++); list_bool_reserved10.erase(it_bool_reserved10++); } return nRet; } void GetID( CString sInfo,int &iDriverID, int &iFactoryID, int &iDevicesID ) { int nPos1=0,nPos2=0; CString s; nPos2 = sInfo.Find( ".",nPos1 ); iDriverID = atoi( sInfo.Mid( nPos1+0,nPos2-nPos1-0 ) ); nPos1 = nPos2; nPos2 = sInfo.Find( ".",nPos1+1 ); iFactoryID = atoi( sInfo.Mid( nPos1+1,nPos2-nPos1-1 ) ); nPos1 = nPos2; nPos2 = sInfo.Find( ".",nPos1+1 ); iDevicesID = atoi( sInfo.Mid( nPos1+1,nPos2-nPos1-1 ) ); nPos1 = nPos2; } // 获取设备资料 INT CDBInterface::GetDevInfo() { CHAR strSQLText[MAX_SQL_LENGTH + 1] = {0}; list list_dev_id, list_uid, list_port, list_device_name, list_device_baudrate; list list_commmode, list_devide_addr, list_is_use, list_protocol_dll_name; list list_special_device, list_data_bit, list_stop_bit, list_parity_bit, list_ip, list_ip_port, list_ini_name; list list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5; list list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10; list list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5; list list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10; list list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5; list list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10; list::iterator it_dev_id, it_uid, it_port, it_device_name, it_device_baudrate; list::iterator it_commmode, it_devide_addr, it_is_use, it_protocol_dll_name; list::iterator it_special_device, it_data_bit, it_stop_bit, it_parity_bit, it_ip, it_ip_port, it_ini_name; list::iterator it_str_reserved1, it_str_reserved2, it_str_reserved3, it_str_reserved4, it_str_reserved5; list::iterator it_str_reserved6, it_str_reserved7, it_str_reserved8, it_str_reserved9, it_str_reserved10; list::iterator it_int_reserved1, it_int_reserved2, it_int_reserved3, it_int_reserved4, it_int_reserved5; list::iterator it_int_reserved6, it_int_reserved7, it_int_reserved8, it_int_reserved9, it_int_reserved10; list::iterator it_bool_reserved1, it_bool_reserved2, it_bool_reserved3, it_bool_reserved4, it_bool_reserved5; list::iterator it_bool_reserved6, it_bool_reserved7, it_bool_reserved8, it_bool_reserved9, it_bool_reserved10; sprintf(strSQLText, "select id as devId, uid, port, devicename, baudrate, commmode, devideaddr, isuse, protocoldllname, " \ " specialdevice, databit, stopbit, paritybit, ip, ipport, ininame, " \ " strreserved1, strreserved2, strreserved3, strreserved4, strreserved5, " \ " strreserved6, strreserved7, strreserved8, strreserved9, strreserved10, " \ " intreserved1, intreserved2, intreserved3, intreserved4, intreserved5, " \ " intreserved6, intreserved7, intreserved8, intreserved9, intreserved10, " \ " boolreserved1, boolreserved2, boolreserved3, boolreserved4, boolreserved5, " \ " boolreserved6, boolreserved7, boolreserved8, boolreserved9, boolreserved10 " \ " from t_dev_property");// where isuse = '1' modify at 08.30 int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList46(strSQLText ,list_dev_id, list_uid, list_port, list_device_name, list_device_baudrate ,list_commmode, list_devide_addr, list_is_use, list_protocol_dll_name ,list_special_device, list_data_bit, list_stop_bit, list_parity_bit, list_ip, list_ip_port, list_ini_name ,list_str_reserved1, list_str_reserved2, list_str_reserved3, list_str_reserved4, list_str_reserved5 ,list_str_reserved6, list_str_reserved7, list_str_reserved8, list_str_reserved9, list_str_reserved10 ,list_int_reserved1, list_int_reserved2, list_int_reserved3, list_int_reserved4, list_int_reserved5 ,list_int_reserved6, list_int_reserved7, list_int_reserved8, list_int_reserved9, list_int_reserved10 ,list_bool_reserved1, list_bool_reserved2, list_bool_reserved3, list_bool_reserved4, list_bool_reserved5 ,list_bool_reserved6, list_bool_reserved7, list_bool_reserved8, list_bool_reserved9, list_bool_reserved10); if( 0 == list_dev_id.size() || 0 == list_uid.size() || 0 == list_port.size() || 0 == list_device_name.size() || 0 == list_device_baudrate.size() || 0 == list_commmode.size() || 0 == list_devide_addr.size() || 0 == list_is_use.size() || 0 == list_protocol_dll_name.size() || 0 == list_special_device.size() || 0 == list_data_bit.size() || 0 == list_stop_bit.size() || 0 == list_parity_bit.size() || 0 == list_ip.size() || 0 == list_ip_port.size() || 0 == list_ini_name.size() || 0 == list_str_reserved1.size() || 0 == list_str_reserved2.size() || 0 == list_str_reserved3.size() || 0 == list_str_reserved4.size() || 0 == list_str_reserved5.size() || 0 == list_str_reserved6.size() || 0 == list_str_reserved7.size() || 0 == list_str_reserved8.size() || 0 == list_str_reserved9.size() || 0 == list_str_reserved10.size() || 0 == list_int_reserved1.size() || 0 == list_int_reserved2.size() || 0 == list_int_reserved3.size() || 0 == list_int_reserved4.size() || 0 == list_int_reserved5.size() || 0 == list_int_reserved6.size() || 0 == list_int_reserved7.size() || 0 == list_int_reserved8.size() || 0 == list_int_reserved9.size() || 0 == list_int_reserved10.size() || 0 == list_bool_reserved1.size() || 0 == list_bool_reserved2.size() || 0 == list_bool_reserved3.size() || 0 == list_bool_reserved4.size() || 0 == list_bool_reserved5.size() || 0 == list_bool_reserved6.size() || 0 == list_bool_reserved7.size() || 0 == list_bool_reserved8.size() || 0 == list_bool_reserved9.size() || 0 == list_bool_reserved10.size() ) { return 0; } if( nRet != -1 ) { for( it_dev_id = list_dev_id.begin(), it_uid = list_uid.begin(), it_port = list_port.begin() ,it_device_name = list_device_name.begin(), it_device_baudrate = list_device_baudrate.begin() ,it_commmode = list_commmode.begin(), it_devide_addr = list_devide_addr.begin() ,it_is_use = list_is_use.begin(),it_protocol_dll_name = list_protocol_dll_name.begin() ,it_special_device = list_special_device.begin(), it_data_bit = list_data_bit.begin() ,it_stop_bit = list_stop_bit.begin(), it_parity_bit = list_parity_bit.begin(), it_ip = list_ip.begin() ,it_ip_port = list_ip_port.begin(), it_ini_name = list_ini_name.begin() ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin() ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin() ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin() ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin() ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin() ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin() ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin() ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin() ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin() ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin() ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin() ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin() ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin() ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin() ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin(); it_dev_id != list_dev_id.end(), it_uid != list_uid.end(), it_port != list_port.end() ,it_device_name != list_device_name.end(), it_device_baudrate != list_device_baudrate.end() ,it_commmode != list_commmode.end(), it_devide_addr != list_devide_addr.end() ,it_is_use != list_is_use.end(),it_protocol_dll_name != list_protocol_dll_name.end() ,it_special_device != list_special_device.end(), it_data_bit != list_data_bit.end() ,it_stop_bit != list_stop_bit.end(), it_parity_bit != list_parity_bit.end(), it_ip != list_ip.end() ,it_ip_port != list_ip_port.end(), it_ini_name != list_ini_name.end() ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end() ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end() ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end() ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end() ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end() ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end() ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end() ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end() ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end() ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end() ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end() ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end() ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end() ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end() ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end(); ) { CDevice* pDev = new CDevice(); CChannel *pChannel = new CChannel(); // 获取设备ID pDev->m_iID = atoi((*it_dev_id++).c_str()); // 获取设备UID pDev->m_strUID = (*it_uid++).c_str(); int nDriverID=0, nFactoryID=0, nDevicesID=0; GetID( pDev->m_strUID,nDriverID,nFactoryID,nDevicesID ); GetDriverName( nDriverID,pDev->m_strDevDriveName ); GetFactoryName( nDriverID,nFactoryID,pDev->m_strDevFactoryName ); GetDevicesName( nDriverID,nFactoryID,nDevicesID,pDev->m_strType ); // 获取设备端口号 pChannel->m_nAddr = atoi((*it_port++).c_str()); pChannel->m_strPort.Format( "COM%d",pChannel->m_nAddr ); // 获取设备名称 pDev->m_strName = (*it_device_name++).c_str(); // 获取设备的波特率 pChannel->m_nBaudRate = atoi((*it_device_baudrate++).c_str()); // 获取设备的数据位 pChannel->m_nByteSize = atoi((*it_data_bit++).c_str()); // 获取设备的停止位 pChannel->m_nStopBits = atoi((*it_stop_bit++).c_str()); // 获取设备的校验位 pChannel->m_nParity = atoi((*it_parity_bit++).c_str()); // 通信的方式 pChannel->m_nCommunicateType = atoi((*it_commmode++).c_str()); if( pChannel->m_nCommunicateType==0 ) pChannel->m_strName.Format( "COM%d",pChannel->m_nAddr ); else pChannel->m_strName = ""; // 设备地址 pDev->m_Address = atoi((*it_devide_addr++).c_str()); // 设备是否启用 CString strIsUse = (*it_is_use++).c_str(); if( 0 == atoi(strIsUse) ) { pDev->m_bUsed = 0; } else { pDev->m_bUsed = 1; } // 协议DLL名称 pDev->m_strProtocolName = (*it_protocol_dll_name++).c_str(); // Modbus Rtu;Modbus Ascii;Modbus Tcp;Snmp;RS232; pDev->m_nProtocolType = atoi( (*it_special_device++).c_str() ); //pDev->m_bySpecialdevice = atoi(strSpecialDevice); //LOG4C((LOG_NOTICE, "device name = %s, specialdevice = %d, %s", pDev->m_strDeviceName, pDev->m_bySpecialdevice, strSpecialDevice)); // 设备IP pDev->m_strDevIP = (*it_ip++).c_str(); // 网络通信端口 pDev->m_nNetPort = atoi((*it_ip_port++).c_str()); // ini配置文件名称 pDev->m_strIniName = (*it_ini_name++).c_str(); // 字符串预留1 pDev->m_strReserved1 = (*it_str_reserved1++).c_str(); // 字符串预留2 pDev->m_strReserved2 = (*it_str_reserved2++).c_str(); // 字符串预留3 pDev->m_strReserved3 = (*it_str_reserved3++).c_str(); // 字符串预留4 pDev->m_strReserved4 = (*it_str_reserved4++).c_str(); // 字符串预留5 pDev->m_strReserved5 = (*it_str_reserved5++).c_str(); // 字符串预留6 pDev->m_strReserved6 = (*it_str_reserved6++).c_str(); // 字符串预留7 pDev->m_strReserved7 = (*it_str_reserved7++).c_str(); // 字符串预留8 pDev->m_strReserved8 = (*it_str_reserved8++).c_str(); // 字符串预留9 pDev->m_strReserved9 = (*it_str_reserved9++).c_str(); // 字符串预留10 pDev->m_strReserved10 = (*it_str_reserved10++).c_str(); // 整形预留1 pDev->m_nReserved1 = atoi((*it_int_reserved1++).c_str()); // 整形预留2 pDev->m_nReserved2 = atoi((*it_int_reserved2++).c_str()); // 整形预留3 pDev->m_nReserved3 = atoi((*it_int_reserved3++).c_str()); // 整形预留4 pDev->m_nReserved4 = atoi((*it_int_reserved4++).c_str()); // 整形预留5 pDev->m_nReserved5 = atoi((*it_int_reserved5++).c_str()); // 整形预留6 pDev->m_nReserved6 = atoi((*it_int_reserved6++).c_str()); // 整形预留7 pDev->m_nReserved7 = atoi((*it_int_reserved7++).c_str()); // 整形预留8 pDev->m_nReserved8 = atoi((*it_int_reserved8++).c_str()); // 整形预留9 pDev->m_nReserved9 = atoi((*it_int_reserved9++).c_str()); // 整形预留10 pDev->m_nReserved10 = atoi((*it_int_reserved10++).c_str()); CString strBoolReserved1 = (*it_bool_reserved1++).c_str(); //LOG4C((LOG_NOTICE, "strBoolReserved1=%s", strBoolReserved1)); //布尔型预留1 if( 0 == atoi(strBoolReserved1) ) { pDev->m_bReserved1 = false; } else { pDev->m_bReserved1 = true; } //布尔型预留2 if( 0 == atoi((*it_bool_reserved2++).c_str()) ) { pDev->m_bReserved2 = false; } else { pDev->m_bReserved2 = true; } //布尔型预留3 if( 0 == atoi((*it_bool_reserved3++).c_str()) ) { pDev->m_bReserved3 = false; } else { pDev->m_bReserved3 = true; } //布尔型预留4 if( 0 == atoi((*it_bool_reserved4++).c_str()) ) { pDev->m_bReserved4 = false; } else { pDev->m_bReserved4 = true; } //布尔型预留5 if( 0 == atoi((*it_bool_reserved5++).c_str()) ) { pDev->m_bReserved5 = false; } else { pDev->m_bReserved5 = true; } //布尔型预留6 if( 0 == atoi((*it_bool_reserved6++).c_str()) ) { pDev->m_bReserved6 = false; } else { pDev->m_bReserved6 = true; } //布尔型预留7 if( 0 == atoi((*it_bool_reserved7++).c_str()) ) { pDev->m_bReserved7 = false; } else { pDev->m_bReserved7 = true; } //布尔型预留8 if( 0 == atoi((*it_bool_reserved8++).c_str()) ) { pDev->m_bReserved8 = false; } else { pDev->m_bReserved8 = true; } //布尔型预留9 if( 0 == atoi((*it_bool_reserved9++).c_str()) ) { pDev->m_bReserved9 = false; } else { pDev->m_bReserved9 = true; } //布尔型预留10 if( 0 == atoi((*it_bool_reserved10++).c_str()) ) { pDev->m_bReserved10 = false; } else { pDev->m_bReserved10 = true; } if( pDevicesManager ) { FindDriverIsExist( pDev,pChannel->m_nCommunicateType,pChannel->m_nAddr ); int nTmpChannelIndex=0,nTmpDeviceIndex=0; if( pChannel->m_nCommunicateType==0 ) { int nChannelsSize = pDevicesManager->m_channels.GetCount(); int nRet = pDevicesManager->FindCommPort( pChannel->m_strName ); if( nRet != -1 ) { delete pChannel;//##### pDevicesManager->m_channels[nRet]->m_Devices.Add( pDev ); } else { pDevicesManager->m_channels.Add( pChannel ); pDevicesManager->m_channels[nChannelsSize]->m_Devices.Add( pDev ); } } else { int nChannelsSize = pDevicesManager->m_channels.GetCount(); int nRet = pDevicesManager->FindCommPort( pChannel->m_strName ); if( nRet != -1 ) { delete pChannel;//##### pDevicesManager->m_channels[nRet]->m_Devices.Add( pDev ); } else { pChannel->m_strPort = ""; pDevicesManager->m_channels.Add( pChannel ); pDevicesManager->m_channels[nChannelsSize]->m_Devices.Add( pDev ); } } } } } for( it_dev_id = list_dev_id.begin(), it_uid = list_uid.begin(), it_port = list_port.begin() ,it_device_name = list_device_name.begin(), it_device_baudrate = list_device_baudrate.begin() ,it_commmode = list_commmode.begin(), it_devide_addr = list_devide_addr.begin() ,it_is_use = list_is_use.begin(),it_protocol_dll_name = list_protocol_dll_name.begin() ,it_special_device = list_special_device.begin(), it_data_bit = list_data_bit.begin() ,it_stop_bit = list_stop_bit.begin(), it_parity_bit = list_parity_bit.begin(), it_ip = list_ip.begin() ,it_ip_port = list_ip_port.begin(), it_ini_name = list_ini_name.begin() ,it_str_reserved1 = list_str_reserved1.begin(), it_str_reserved2 = list_str_reserved2.begin() ,it_str_reserved3 = list_str_reserved3.begin(), it_str_reserved4 = list_str_reserved4.begin() ,it_str_reserved5 = list_str_reserved5.begin(), it_str_reserved6 = list_str_reserved6.begin() ,it_str_reserved7 = list_str_reserved7.begin(), it_str_reserved8 = list_str_reserved8.begin() ,it_str_reserved9 = list_str_reserved9.begin(), it_str_reserved10 = list_str_reserved10.begin() ,it_int_reserved1 = list_int_reserved1.begin(), it_int_reserved2 = list_int_reserved2.begin() ,it_int_reserved3 = list_int_reserved3.begin(), it_int_reserved4 = list_int_reserved4.begin() ,it_int_reserved5 = list_int_reserved5.begin(), it_int_reserved6 = list_int_reserved6.begin() ,it_int_reserved7 = list_int_reserved7.begin(), it_int_reserved8 = list_int_reserved8.begin() ,it_int_reserved9 = list_int_reserved9.begin(), it_int_reserved10 = list_int_reserved10.begin() ,it_bool_reserved1 = list_bool_reserved1.begin(), it_bool_reserved2 = list_bool_reserved2.begin() ,it_bool_reserved3 = list_bool_reserved3.begin(), it_bool_reserved4 = list_bool_reserved4.begin() ,it_bool_reserved5 = list_bool_reserved5.begin(), it_bool_reserved6 = list_bool_reserved6.begin() ,it_bool_reserved7 = list_bool_reserved7.begin(), it_bool_reserved8 = list_bool_reserved8.begin() ,it_bool_reserved9 = list_bool_reserved9.begin(), it_bool_reserved10 = list_bool_reserved10.begin(); it_dev_id != list_dev_id.end(), it_uid != list_uid.end(), it_port != list_port.end() ,it_device_name != list_device_name.end(), it_device_baudrate != list_device_baudrate.end() ,it_commmode != list_commmode.end(), it_devide_addr != list_devide_addr.end() ,it_is_use != list_is_use.end(),it_protocol_dll_name != list_protocol_dll_name.end() ,it_special_device != list_special_device.end(), it_data_bit != list_data_bit.end() ,it_stop_bit != list_stop_bit.end(), it_parity_bit != list_parity_bit.end(), it_ip != list_ip.end() ,it_ip_port != list_ip_port.end(), it_ini_name != list_ini_name.end() ,it_str_reserved1 != list_str_reserved1.end(), it_str_reserved2 != list_str_reserved2.end() ,it_str_reserved3 != list_str_reserved3.end(), it_str_reserved4 != list_str_reserved4.end() ,it_str_reserved5 != list_str_reserved5.end(), it_str_reserved6 != list_str_reserved6.end() ,it_str_reserved7 != list_str_reserved7.end(), it_str_reserved8 != list_str_reserved8.end() ,it_str_reserved9 != list_str_reserved9.end(), it_str_reserved10 != list_str_reserved10.end() ,it_int_reserved1 != list_int_reserved1.end(), it_int_reserved2 != list_int_reserved2.end() ,it_int_reserved3 != list_int_reserved3.end(), it_int_reserved4 != list_int_reserved4.end() ,it_int_reserved5 != list_int_reserved5.end(), it_int_reserved6 != list_int_reserved6.end() ,it_int_reserved7 != list_int_reserved7.end(), it_int_reserved8 != list_int_reserved8.end() ,it_int_reserved9 != list_int_reserved9.end(), it_int_reserved10 != list_int_reserved10.end() ,it_bool_reserved1 != list_bool_reserved1.end(), it_bool_reserved2 != list_bool_reserved2.end() ,it_bool_reserved3 != list_bool_reserved3.end(), it_bool_reserved4 != list_bool_reserved4.end() ,it_bool_reserved5 != list_bool_reserved5.end(), it_bool_reserved6 != list_bool_reserved6.end() ,it_bool_reserved7 != list_bool_reserved7.end(), it_bool_reserved8 != list_bool_reserved8.end() ,it_bool_reserved9 != list_bool_reserved9.end(), it_bool_reserved10 != list_bool_reserved10.end(); ) { list_dev_id.erase(it_dev_id++); list_uid.erase(it_uid++); list_port.erase(it_port++); list_device_name.erase(it_device_name++); list_device_baudrate.erase(it_device_baudrate++); list_commmode.erase(it_commmode++); list_devide_addr.erase(it_devide_addr++); list_is_use.erase(it_is_use++); list_protocol_dll_name.erase(it_protocol_dll_name++); list_special_device.erase(it_special_device++); list_data_bit.erase(it_data_bit++); list_stop_bit.erase(it_stop_bit++); list_parity_bit.erase(it_parity_bit++); list_ip.erase(it_ip++); list_ip_port.erase(it_ip_port++); list_ini_name.erase(it_ini_name++); list_str_reserved1.erase(it_str_reserved1++); list_str_reserved2.erase(it_str_reserved2++); list_str_reserved3.erase(it_str_reserved3++); list_str_reserved4.erase(it_str_reserved4++); list_str_reserved5.erase(it_str_reserved5++); list_str_reserved6.erase(it_str_reserved6++); list_str_reserved7.erase(it_str_reserved7++); list_str_reserved8.erase(it_str_reserved8++); list_str_reserved9.erase(it_str_reserved9++); list_str_reserved10.erase(it_str_reserved10++); list_int_reserved1.erase(it_int_reserved1++); list_int_reserved2.erase(it_int_reserved2++); list_int_reserved3.erase(it_int_reserved3++); list_int_reserved4.erase(it_int_reserved4++); list_int_reserved5.erase(it_int_reserved5++); list_int_reserved6.erase(it_int_reserved6++); list_int_reserved7.erase(it_int_reserved7++); list_int_reserved8.erase(it_int_reserved8++); list_int_reserved9.erase(it_int_reserved9++); list_int_reserved10.erase(it_int_reserved10++); list_bool_reserved1.erase(it_bool_reserved1++); list_bool_reserved2.erase(it_bool_reserved2++); list_bool_reserved3.erase(it_bool_reserved3++); list_bool_reserved4.erase(it_bool_reserved4++); list_bool_reserved5.erase(it_bool_reserved5++); list_bool_reserved6.erase(it_bool_reserved6++); list_bool_reserved7.erase(it_bool_reserved7++); list_bool_reserved8.erase(it_bool_reserved8++); list_bool_reserved9.erase(it_bool_reserved9++); list_bool_reserved10.erase(it_bool_reserved10++); } return nRet; } //获取指定厂家的设备型号ID INT CDBInterface::GetDriverName( int nDriverID, CString &sDriverName ) { CHAR strSQLText[MAX_SQL_LENGTH + 1] = ""; list list1; list::iterator it; if (!_stricmp(m_chDBType, "SQL SERVER")) { sprintf(strSQLText, "select top 1 drivename from t_dev_drive where id = %d", nDriverID ); } else if (!_stricmp(m_chDBType, "ACCESS97")) { sprintf(strSQLText, "select top 1 drivename from t_dev_drive where id = %d", nDriverID ); } else if (!_stricmp(m_chDBType, "ACCESS2000")) { sprintf(strSQLText, "select top 1 drivename from t_dev_drive where id = %d", nDriverID ); } else if(!_stricmp(m_chDBType, "PGSQL")) { sprintf(strSQLText, "select drivename from t_dev_drive where id = %d limit 1", nDriverID ); } int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList1(strSQLText, list1); if( 0 == list1.size() ) { return 0; } if( nRet != -1 ) { sDriverName = list1.begin()->c_str(); //strcpy( pDriverName, list1.begin()->c_str() ); } for( it = list1.begin(); it != list1.end(); ) { list1.erase(it++); } return nRet; } //获取指定驱动ID和厂家ID的厂家名称 INT CDBInterface::GetFactoryName( int nDriverID, int nFactoryID, CString &sFactoryName ) { CHAR strSQLText[MAX_SQL_LENGTH + 1] = ""; list list1; list::iterator it; if (!_stricmp(m_chDBType, "SQL SERVER")) { sprintf(strSQLText, "select top 1 factoryname from t_dev_factory where deviceid = %d and factoryid = %d", nDriverID, nFactoryID ); } else if (!_stricmp(m_chDBType, "ACCESS97")) { sprintf(strSQLText, "select top 1 factoryname from t_dev_factory where deviceid = %d and factoryid = %d", nDriverID, nFactoryID ); } else if (!_stricmp(m_chDBType, "ACCESS2000")) { sprintf(strSQLText, "select top 1 factoryname from t_dev_factory where deviceid = %d and factoryid = %d", nDriverID, nFactoryID ); } else if(!_stricmp(m_chDBType, "PGSQL")) { sprintf(strSQLText, "select factoryname from t_dev_factory where deviceid = %d and factoryid = %d limit 1", nDriverID, nFactoryID ); } int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList1(strSQLText, list1); if( 0 == list1.size() ) { return 0; } if( nRet != -1 ) { sFactoryName = list1.begin()->c_str(); //strcpy( pFactoryName, list1.begin()->c_str() ); } for( it = list1.begin(); it != list1.end(); ) { list1.erase(it++); } return nRet; } //获取指定驱动ID，厂家ID和设备类型ID的名称 INT CDBInterface::GetDevicesName( int nDriverID, int nFactoryID, int nDevicesID,CString &sDevicesName ) { CHAR strSQLText[MAX_SQL_LENGTH + 1] = ""; list list1; list::iterator it; if (!_stricmp(m_chDBType, "SQL SERVER")) { sprintf(strSQLText, "select top 1 equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d", nDevicesID,nFactoryID, nDriverID ); } else if (!_stricmp(m_chDBType, "ACCESS97")) { sprintf(strSQLText, "select top 1 equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d", nDevicesID,nFactoryID, nDriverID ); } else if (!_stricmp(m_chDBType, "ACCESS2000")) { sprintf(strSQLText, "select top 1 equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d", nDevicesID,nFactoryID, nDriverID ); } else if(!_stricmp(m_chDBType, "PGSQL")) { sprintf(strSQLText, "select equiptype from t_dev_type where id = %d and factoryid = %d and driveid = %d limit 1", nDevicesID,nFactoryID, nDriverID ); } int nRet = CDBConnection::GetInstancePtr()->GetFieldValueList1(strSQLText, list1); if( 0 == list1.size() ) { return 0; } if( nRet != -1 ) { sDevicesName = list1.begin()->c_str(); //strcpy( pDevicesName, list1.begin()->c_str() ); } for( it = list1.begin(); it != list1.end(); ) { list1.erase(it++); } return nRet; } bool CDBInterface::FindDriverIsExist( CDevice* pDev,int iCommunicateType,int iAddr ) { bool bRet = false; bool bBreak = false; for( int i = 0; i < pDevicesManager->m_channels.GetSize(); i++ ) { CChannel *pChannel = pDevicesManager->m_channels.GetAt( i ); for( int j = 0; j m_Devices.GetSize(); j++ ) { if( pChannel->m_Devices[j]->m_strName == pDev->m_strName ) { LOG4C((LOG_NOTICE, "设备名重复 设备名:%s",pDev->m_strName )); bRet = true; bBreak = true; break; } } if( iCommunicateType==0 ) { if( pChannel->m_nCommunicateType==iCommunicateType && pChannel->m_nAddr==iAddr ) { for( int j = 0; j m_Devices.GetSize(); j++ ) { if( pChannel->m_Devices[j]->m_Address == pDev->m_Address ) { LOG4C((LOG_NOTICE, "设备地址重复 设备名:%s, 端口：%d, 地址：%d",pDev->m_strName,iAddr,pDev->m_Address )); bRet = true; bBreak = true; break; } } } } else { if( pChannel->m_nCommunicateType==iCommunicateType ) { for( int j = 0; j m_Devices.GetSize(); j++ ) { if( pChannel->m_Devices[j]->m_strDevIP == pDev->m_strDevIP )//&& pChannel->m_Devices[j]->m_nNetPort==pDev->m_nNetPort ) { LOG4C((LOG_NOTICE, "设备IP重复 设备名:%s IP：%s",pDev->m_strName,pDev->m_strDevIP )); bRet = true; bBreak = true; break; } } } } if( bBreak ) break; } return bRet; } bool CDBInterface::FindVarIsExist( CAnalog *pBaseVar ) { bool bRet = false; for( int i = 0; i < pVariantsManager->m_analog.GetSize(); i++ ) { CAnalog *pAnalog = pVariantsManager->m_analog.GetAt( i ); if( pAnalog->m_nVarID==pBaseVar->m_nVarID ) { LOG4C((LOG_NOTICE, "变量ID重复 %d",pBaseVar->m_nVarID )); } if( pAnalog->m_strName==pBaseVar->m_strName ) { LOG4C((LOG_NOTICE, "变量名重复 %s",pBaseVar->m_strName )); } break; } return bRet; } //得到不合法的变量问题 CString CDBInterface::GetInvalidMessage( CString sVarName,int iInitValue,int iMinValue,int iMaxValue,int iLowerValue,int iUpperValue,int iNormalValue,int iWarningLevel,int iIdentifyTime ) { CString sRet,s; if(sVarName=="" ) { s = "变量名不能为空； "; sRet += s; } for( int i=0;i='0'&&sVarName[i]<='9') || (sVarName[i]>='a'&&sVarName[i]<='z') || (sVarName[i]>='A'&&sVarName[i]<='Z') || (sVarName[i]=='_' )) { if( i==0 && ( (sVarName[i]>='0'&&sVarName[i]<='9') || (sVarName[i]=='_' ) ) ) { s = "变量名有误,只能是字母开头； "; sRet += s; break; } } else { s = "变量名有误,含有非法字符； "; sRet += s; break; } } if( iMaxValue==0 ) { s = "变量最大值不能为0； "; sRet += s; } if( iMinValue>iMaxValue ) { s = "变量最小值不能大于变量最大值； "; sRet += s; } if( iInitValueiMaxValue ) { s = "变量初始值有误,不在最小最大值之间； "; sRet += s; } if( iLowerValue>iUpperValue ) { s = "变量下限与上限设置有误； "; sRet += s; } if( iLowerValue==0 && iUpperValue==0 ) { if( iNormalValue != iInitValue ) { s = "干接点变量的正常状态与初始值不相等； "; sRet += s; } } else { if( iInitValueiUpperValue ) { s = "变量初始值有误,不在下限与上限之间； "; sRet += s; } } if( iWarningLevel==0 ) { s = "变量的报警级别为0； "; sRet += s; } if( iIdentifyTime==0 ) { s = "变量的辨识时间不能等于0； "; sRet += s; } return sRet; } };