123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403 |
- ///////////////////////////////////////////////////////////
- //
- // File:
- // DBConnection.cpp
- // Author:
- // 严晓斌
- // Date:
- // 2008-05-23
- // Comments:
- // 主要处理数据库连接任务
- //
- ///////////////////////////////////////////////////////////
- #include "stdafx.h"
- #include "Global.h"
- //#include <windows.h>
- #include <stdio.h>
- #include <stdlib.h>
- #include <memory.h>
- #include "mdlProject.h"
- //#include "Ado.h"
- #include "DBConnection.h"
- //#include <list>
- HANDLE m_hDBConnectionThread = NULL;
- BOOL m_bBeep = FALSE;
- BOOL m_bDBConnected = FALSE;
- BOOL DBConnectionThreadStart()
- {
- HANDLE hThread = NULL;
- INT iConfMemberIndex = 0;
- INT iConfGroupIndex = 0;
-
- //数据库连接串
- if (!_stricmp(g_strDBType, "SQL SERVER"))
- sprintf(g_strConnectString, "Provider=sqloledb;Data Source=%s,1433;Initial Catalog=%s;User Id=%s;Password=%s; ",
- g_strServerName, g_strDataBaseName, g_strUserName, g_strPassword);
- else if (!_stricmp(g_strDBType, "ACCESS97"))
- sprintf(g_strConnectString, "Provider=Microsoft.Jet.OLEDB.3.51;Data Source=%s", g_strAccessFile);
- else if (!_stricmp(g_strDBType, "ACCESS2000"))
- sprintf(g_strConnectString, "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%s", g_strAccessFile);
- else if(!_stricmp(g_strDBType, "PGSQL"))
- sprintf(g_strConnectString, "DRIVER={PostgreSQL ODBC Driver(UNICODE)}; SERVER=%s; port=5432; DATABASE=%s; UID=%s; PWD=%s;",
- g_strServerName, g_strDataBaseName, g_strDBUserName, g_strPassword);
- else
- sprintf(g_strConnectString, "Provider=sqloledb;Data Source=%s;Initial Catalog=%s;User Id=%s;Password=%s; ",
- g_strServerName, g_strDataBaseName, g_strUserName, g_strPassword);
- g_pADODatabase = new CADODatabase;
- if (g_pADODatabase != NULL)
- {
- g_pADODatabase->SetConnectionString(g_strConnectString);
- if (FALSE == g_pADODatabase->Open())
- {
- g_pADODatabase->Close();
- delete g_pADODatabase;
- g_pADODatabase = NULL;
- m_bBeep = TRUE;
- }
- else
- {
- m_bDBConnected = TRUE;
- }
- }
- return TRUE;
- }
- BOOL DBConnectionThreadEnd()
- {
- if ((g_pADODatabase != NULL) && (g_pADODatabase->IsOpen()))
- {
- g_pADODatabase->Close();
- delete g_pADODatabase;
- g_pADODatabase = NULL;
- }
- return TRUE;
- }
- //获取表最大的ID, 通用函数
- INT GetMaxID( CHAR *pTableName, CHAR *pFieldName, CHAR *pMaxID )
- {
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- list<string> list1;
- list<string>::iterator it;
- sprintf(strSQLText, "select max(%s) as maxid from %s", pFieldName, pTableName);
- int nRet = GetFieldValueList1(strSQLText, list1);
- if( 0 == list1.size() )
- {
- return 0;
- }
- if( nRet != -1 )
- {
- strcpy(pMaxID, list1.begin()->c_str());
- }
- for( it = list1.begin(); it != list1.end(); )
- {
- list1.erase(it++);
- }
- return nRet;
- }
- //获取t_dev_variant变量属性表字段ID的最大值
- INT GetVarMaxID( CHAR *pMaxID )
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- sprintf(strSQLText, "select max(id) as maxid from t_dev_variant");
- iRetCode = pRSet->Open(strSQLText, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- // 获取最大的设备ID
- if (!pRSet->IsFieldNull("maxid"))
- {
- pRSet->GetFieldValue("maxid", strID);
- strcpy(pMaxID, (char *)(LPCTSTR)strID);
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- //插入设备资料
- INT InsertVarInfo(int nID, CHAR *pUid, CHAR *pVarName, CHAR *pDesc, int nVarTypeID, int nDataLen,
- CHAR *pOnDesc, CHAR *pOffDesc, int nMaxValues, int nMinValues,
- int nMaxScale, int nMinScale, int nLowerLimit, int nUpperLimit,
- int nNormalState, CHAR *pSetValue, int nRearm, int nOffset, CHAR *pUnit,
- int nCollentFreq, float fCoef, int nWarnLevel, int nReadOnly, int nIsSave,
- int nRealtimeFlag, int nRecCurve, int nIsDDE, int nRegNum, int nFuncID,
- int nChildID, int nVarItemID, CHAR *pSnmpOid, CHAR *pField, int nDevID,
- int nRegStartAddr, CHAR *pRs232Cmd, CHAR *pRs232Type, int nRs232Index,
- int nIdentifyTime, int nReDetectTime, int nNormIsNotice,
- char *pStrReserved1, char *pStrReserved2, char *pStrReserved3, char *pStrReserved4,
- char *pStrReserved5, char *pStrReserved6, char *pStrReserved7, char *pStrReserved8,
- char *pStrReserved9, char *pStrReserved10,
- int nReserved1, int nReserved2, int nReserved3, int nReserved4, int nReserved5,
- int nReserved6, int nReserved7, int nReserved8, int nReserved9, int nReserved10,
- int bReserved1, int bReserved2, int bReserved3, int bReserved4, int bReserved5,
- int bReserved6, int bReserved7, int bReserved8, int bReserved9, int bReserved10)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[409600] = "";
- INT iRetCode = 0;
- CString strIsDDE, strRecCurve, strRealtimeFlag, strIsSave, strNormalIsNotice, strReadOnly;
- CString strbResrved1, strbResrved2, strbResrved3, strbResrved4, strbResrved5;
- CString strbResrved6, strbResrved7, strbResrved8, strbResrved9, strbResrved10;
- strIsDDE = (nIsDDE == 0)?"FALSE":"TRUE";
- strRecCurve = (nRecCurve == 0)?"FALSE":"TRUE";
- strRealtimeFlag = (nRealtimeFlag == 0)?"FALSE":"TRUE";
-
- strIsSave = (nIsSave == 0)?"FALSE":"TRUE";
- strNormalIsNotice = (nNormIsNotice == 0)?"FALSE":"TRUE";
- strbResrved1 = (bReserved1 == 0)?"FALSE":"TRUE";
- strbResrved2 = (bReserved2 == 0)?"FALSE":"TRUE";
- strbResrved3 = (bReserved3 == 0)?"FALSE":"TRUE";
- strbResrved4 = (bReserved4 == 0)?"FALSE":"TRUE";
- strbResrved5 = (bReserved5 == 0)?"FALSE":"TRUE";
- strbResrved6 = (bReserved6 == 0)?"FALSE":"TRUE";
- strbResrved7 = (bReserved7 == 0)?"FALSE":"TRUE";
- strbResrved8 = (bReserved8 == 0)?"FALSE":"TRUE";
- strbResrved9 = (bReserved9 == 0)?"FALSE":"TRUE";
- strbResrved10 = (bReserved10 == 0)?"FALSE":"TRUE";
- strReadOnly.Format("%d", nReadOnly);
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- if (!_stricmp(g_strDBType, "SQL SERVER"))
- {
- sprintf(strSQLText, "insert into t_dev_variant(id, uid, varname, description, vartypeid, " \
- "datalen, ondesc, offdesc, maxvalues, minvalues, maxconvtrate, minconvtrate, " \
- "lowerlimit, upperlimit, normalstate, setvalue, rearm, [offsets], unit, collectfrequence, " \
- "coefficient, warnlevel, readonly, issave, realtimeflag, reccurve, isdde, " \
- "registernum, funcid, childid, var_item_id, snmpoid, fields, devtypeid, address, " \
- "rs232cmd, rs232type, rs232index, identifytime, redetecttime, normalisnotice, " \
- "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) values(" \
- "%d, \'%s\', \'%s\', \'%s\', %d, " \
- "%d, \'%s\', \'%s\', %d, %d, %d, %d, " \
- "%d, %d, %d, \'%s\', %d, %d, \'%s\', %d," \
- "%.10f, %d, \'%s\', %d, %d, %d, %d," \
- "%d, %d, %d, %d, \'%s\', \'%s\', %d, %d, " \
- "\'%s\', \'%s\', %d, %d, %d, %d, " \
- "\'%s\', \'%s\', \'%s\', \'%s\', \'%s\', " \
- "\'%s\', \'%s\', \'%s\', \'%s\', \'%s\', " \
- "%d, %d, %d, %d, %d, " \
- "%d, %d, %d, %d, %d, " \
- "%d, %d, %d, %d, %d, " \
- "%d, %d, %d, %d, %d)",
- nID, pUid, pVarName, pDesc, nVarTypeID,
- nDataLen, pOnDesc, pOffDesc, nMaxValues, nMinValues, nMaxScale, nMinScale,
- nLowerLimit, nUpperLimit, nNormalState, pSetValue, nRearm, nOffset, pUnit, nCollentFreq,
- fCoef, nWarnLevel, strReadOnly, nIsSave, nRealtimeFlag, nRecCurve, nIsDDE,
- nRegNum, nFuncID, nChildID, nVarItemID, pSnmpOid, pField, nDevID, nRegStartAddr,
- pRs232Cmd, pRs232Type, nRs232Index, nIdentifyTime, nReDetectTime, nNormIsNotice,
- pStrReserved1, pStrReserved2, pStrReserved3, pStrReserved4, pStrReserved5,
- pStrReserved6, pStrReserved7, pStrReserved8, pStrReserved9, pStrReserved10,
- nReserved1, nReserved2, nReserved3, nReserved4, nReserved5,
- nReserved6, nReserved7, nReserved8, nReserved9, nReserved10,
- bReserved1, bReserved2, bReserved3, bReserved4, bReserved5,
- bReserved6, bReserved7, bReserved8, bReserved9, bReserved10);
- }
- else if (!_stricmp(g_strDBType, "ACCESS97"))
- {
- sprintf(strSQLText, "select tel, mobiletel, fax, email from " \
- "t_role_equip a left outer join t_user_info b on a.userid = b.uid " \
- "where a.uid = \'%s\' and b.status = 0 or b.status is null and b.uid <> 'admin'",
- pUid);
- }
- else if (!_stricmp(g_strDBType, "ACCESS2000"))
- {
- sprintf(strSQLText, "select tel, mobiletel, fax, email from " \
- "t_role_equip a left outer join t_user_info b on a.userid = b.uid " \
- "where a.uid = \'%s\' and b.status = 0 or b.status is null and b.uid <> 'admin'",
- pUid);
- }
- else if(!_stricmp(g_strDBType, "PGSQL"))
- {
- sprintf(strSQLText, "insert into t_dev_variant(id, uid, varname, description, vartypeid, " \
- "datalen, ondesc, offdesc, maxvalues, minvalues, maxconvtrate, minconvtrate, " \
- "lowerlimit, upperlimit, normalstate, setvalue, rearm, offsets, unit, collectfrequence, " \
- "coefficient, warnlevel, readonly, issave, realtimeflag, reccurve, isdde, " \
- "registernum, funcid, childid, var_item_id, snmpoid, fields, devtypeid, address, " \
- "rs232cmd, rs232type, rs232index, identifytime, redetecttime, normalisnotice, " \
- "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) values(" \
- "%d, \'%s\', \'%s\', \'%s\', %d, " \
- "%d, \'%s\', \'%s\', %d, %d, %d, %d, " \
- "%d, %d, %d, \'%s\', %d, %d, \'%s\', %d," \
- "%.10f, %d, \'%s\', %s, %s, %s, %s," \
- "%d, %d, %d, %d, \'%s\', \'%s\', %d, %d, " \
- "\'%s\', \'%s\', %d, %d, %d, %s, " \
- "\'%s\', \'%s\', \'%s\', \'%s\', \'%s\', " \
- "\'%s\', \'%s\', \'%s\', \'%s\', \'%s\', " \
- "%d, %d, %d, %d, %d, " \
- "%d, %d, %d, %d, %d, " \
- "%s, %s, %s, %s, %s, " \
- "%s, %s, %s, %s, %s)",
- nID, pUid, pVarName, pDesc, nVarTypeID,
- nDataLen, pOnDesc, pOffDesc, nMaxValues, nMinValues, nMaxScale, nMinScale,
- nLowerLimit, nUpperLimit, nNormalState, pSetValue, nRearm, nOffset, pUnit, nCollentFreq,
- fCoef, nWarnLevel, strReadOnly, strIsSave, strRealtimeFlag, strRecCurve, strIsDDE,
- nRegNum, nFuncID, nChildID, nVarItemID, pSnmpOid, pField, nDevID, nRegStartAddr,
- pRs232Cmd, pRs232Type, nRs232Index, nIdentifyTime, nReDetectTime, strNormalIsNotice,
- pStrReserved1, pStrReserved2, pStrReserved3, pStrReserved4, pStrReserved5,
- pStrReserved6, pStrReserved7, pStrReserved8, pStrReserved9, pStrReserved10,
- nReserved1, nReserved2, nReserved3, nReserved4, nReserved5,
- nReserved6, nReserved7, nReserved8, nReserved9, nReserved10,
- strbResrved1, strbResrved2, strbResrved3, strbResrved4, strbResrved5,
- strbResrved6, strbResrved7, strbResrved8, strbResrved9, strbResrved10);
- }
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //获取t_dev_variant_item资料
- INT GetVarItem( CHAR *pUid, int nVarItemID )
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- sprintf(strSQLText, "select id from t_dev_variant_item where uid = \'%s\' and id = %d", pUid, nVarItemID);
- iRetCode = pRSet->Open(strSQLText, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- //插入Bit位表
- INT InsertVarItemInfo(int nID, CHAR *pUid, int nStartBit, int nEndBit)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_dev_variant_item(id, uid, startbit, endbit) values(" \
- "%d, \'%s\', %d, %d)",
- nID, pUid, nStartBit, nEndBit);
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //插入数据记录
- INT InsertDataRecord(
- CHAR* pDevName, // 设备名称
- CHAR* pHappenTime, // 发生时间
- CHAR* pVarName, // 变量名称
- CHAR *pVarDesc, // 变量描述
- double dbCurrValue // 当前值
- )
- {
- INT iRetCode = 0;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- static int iMaxID = 1;
- //CHAR chMaxID[MAX_ID] = {0};
- //GetMaxID("t_data_rec", "id", chMaxID);
- //if( 0 == atoi(chMaxID) )
- //{
- // iMaxID = 1;
- //}
- //else
- //{
- // iMaxID = atoi(chMaxID) + 1;
- //}
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_data_rec(id,devname, happentime,varname,vardesc,datavalue) values(" \
- "%d, \'%s\', \'%s\', \'%s\', \'%s\', %.1f)",
- iMaxID, pDevName, pHappenTime,pVarName, pVarDesc, dbCurrValue );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- iMaxID++;
- }
- return iRetCode;
- }
- //插入控制器记录
- INT InsertControlInfo(
- int nbrandtype,
- CHAR* scontrolname,
- CHAR* ssn,
- int nwordmode,
- int ncomport,
- CHAR* sip,
- CHAR* sport,
- int nforbid,
- int ndoorconut,
- CHAR* sdoor1,
- CHAR* sdoor2,
- CHAR* sdoor3,
- CHAR* sdoor4,
- CHAR* sdoor5,
- CHAR* sdoor6,
- CHAR* sdoor7,
- CHAR* sdoor8
- )
- {
- CString sShow,sTemp;
- sTemp.Format( "%s",scontrolname );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strControlName,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- sTemp.Format( "%s",ssn );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strControlSN,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_control","scontrolname",scontrolname ) )
- {
- sShow.Format("%s%s",g_strControlName,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_control","ssn",ssn ) )
- {
- sShow.Format("%s%s",g_strControlSN,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- INT iRetCode = -1;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- int iMaxID = 0;
- CHAR chMaxID[MAX_ID] = {0};
- GetMaxID("t_door_control", "id", chMaxID);
- if( 0 == atoi(chMaxID) )
- {
- iMaxID = 1;
- }
- else
- {
- iMaxID = atoi(chMaxID) + 1;
- }
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_door_control( id,nbrandtype,scontrolname,ssn,nwordmode,ncomport,sip,sport,nforbid,ndoorconut,sdoor1,sdoor2,sdoor3,sdoor4,sdoor5,sdoor6,sdoor7,sdoor8 ) values(" \
- "%d, %d,\'%s\',\'%s\',%d,%d,\'%s\',\'%s\',%d,%d,\'%s\',\'%s\',\'%s\',\'%s\',\'%s\',\'%s\',\'%s\',\'%s\')",
- iMaxID, nbrandtype,scontrolname,ssn,nwordmode,ncomport,sip,sport,nforbid,ndoorconut,sdoor1,sdoor2,sdoor3,sdoor4,sdoor5,sdoor6,sdoor7,sdoor8 );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- return iMaxID;
- }
- //更新控制器记录
- INT UpdateControlInfo(
- int nID,
- int nbrandtype,
- CHAR* scontrolname,
- CHAR* ssn,
- int nwordmode,
- int ncomport,
- CHAR* sip,
- CHAR* sport,
- int nforbid,
- int ndoorconut,
- CHAR* sdoor1,
- CHAR* sdoor2,
- CHAR* sdoor3,
- CHAR* sdoor4,
- CHAR* sdoor5,
- CHAR* sdoor6,
- CHAR* sdoor7,
- CHAR* sdoor8
- )
- {
- CString sShow,sTemp;
- sTemp.Format( "%s",scontrolname );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strControlName,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- sTemp.Format( "%s",ssn );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strControlSN,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_control","scontrolname",scontrolname,nID ) )
- {
- sShow.Format("%s%s",g_strControlName,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_control","ssn",ssn,nID ) )
- {
- sShow.Format("%s%s",g_strControlSN,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "update t_door_control set nbrandtype=%d,scontrolname=\'%s\',ssn=\'%s\',nwordmode=%d,ncomport=%d,sip=\'%s\',sport=\'%s\',nforbid=%d,ndoorconut=%d, "\
- " sdoor1=\'%s\',sdoor2=\'%s\',sdoor3=\'%s\',sdoor4=\'%s\',sdoor5=\'%s\',sdoor6=\'%s\',sdoor7=\'%s\',sdoor8=\'%s\' where id = %d",
- nbrandtype,scontrolname,ssn,nwordmode,ncomport,sip,sport,nforbid,ndoorconut,sdoor1,sdoor2,sdoor3,sdoor4,sdoor5,sdoor6,sdoor7,sdoor8,nID );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //插入卡记录
- INT InsertCardInfo(
- CHAR* susername,
- CHAR* scardnumber,
- CHAR* sclass,
- CHAR* sjobnumber,
- CHAR* sremarks
- )
- {
- CString sShow,sTemp;
- sTemp.Format( "%s",susername );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strUserName,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- sTemp.Format( "%s",scardnumber );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strCardNumber,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_card","susername",susername ) )
- {
- sShow.Format("%s%s",g_strUserName,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_card","scardnumber",scardnumber ) )
- {
- sShow.Format("%s%s",g_strCardNumber,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- INT iRetCode = 0;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- int iMaxID = 0;
- CHAR chMaxID[MAX_ID] = {0};
- GetMaxID("t_door_card", "id", chMaxID);
- if( 0 == atoi(chMaxID) )
- {
- iMaxID = 1;
- }
- else
- {
- iMaxID = atoi(chMaxID) + 1;
- }
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_door_card( id,susername,scardnumber,sclass,sjobnumber,sremarks ) values(" \
- "%d, \'%s\',\'%s\',\'%s\',\'%s\',\'%s\')",
- iMaxID,susername,scardnumber,sclass,sjobnumber,sremarks );
- g_pADODatabase->Execute(strSQLText);
- }
- return iMaxID;
- }
- //插入卡记录_导入
- INT InsertCardInfo_INPUT(
- CHAR* susername,
- CHAR* scardnumber,
- CHAR* sclass,
- CHAR* sjobnumber,
- CHAR* sremarks
- )
- {
- CString sShow,sTemp;
- sTemp.Format( "%s",susername );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strUserName,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- sTemp.Format( "%s",scardnumber );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strCardNumber,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_card","susername",susername ) )
- {
- sShow.Format("%s%s",g_strUserName,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_card","scardnumber",scardnumber ) )
- {
- sShow.Format("%s%s",g_strCardNumber,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
-
- INT iRetCode = -1;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- int iMaxID = 0;
- CHAR chMaxID[MAX_ID] = {0};
- GetMaxID("t_door_card", "id", chMaxID);
- if( 0 == atoi(chMaxID) )
- {
- iMaxID = 1;
- }
- else
- {
- iMaxID = atoi(chMaxID) + 1;
- }
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_door_card( id,susername,scardnumber,sclass,sjobnumber,sremarks ) values(" \
- "%d, \'%s\',\'%s\',\'%s\',\'%s\',\'%s\')",
- iMaxID,susername,scardnumber,sclass,sjobnumber,sremarks );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- return iMaxID;
- }
- //更新卡记录
- INT UpdateCardInfo(
- int nID,
- CHAR* susername,
- CHAR* scardnumber,
- CHAR* sclass,
- CHAR* sjobnumber,
- CHAR* sremarks
- )
- {
- CString sShow,sTemp;
- sTemp.Format( "%s",susername );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strUserName,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- sTemp.Format( "%s",scardnumber );
- if( sTemp=="" )
- {
- sShow.Format("%s%s",g_strCardNumber,g_strNotNull );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_card","susername",susername,nID ) )
- {
- sShow.Format("%s%s",g_strUserName,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- if( IsExistItem( "t_door_card","scardnumber",scardnumber,nID ) )
- {
- sShow.Format("%s%s",g_strCardNumber,g_strExist );
- MessageBox( g_pDlgMain->GetSafeHwnd(),sShow, g_strTip, MB_ICONINFORMATION);
- return -1;
- }
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "update t_door_card set susername=\'%s\',scardnumber=\'%s\',sclass=\'%s\',sjobnumber=\'%s\',sremarks=\'%s\' where id = %d",
- susername,scardnumber,sclass,sjobnumber,sremarks,nID );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //插入进出记录
- INT InsertRecordInfo(
- CHAR* scardnumber,
- CHAR* speople,
- CHAR* sinout,
- CHAR* sinfo,
- CHAR* stime
- )
- {
- INT iRetCode = 0;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- int iMaxID = 0;
- CHAR chMaxID[MAX_ID] = {0};
- GetMaxID("t_door_record", "id", chMaxID);
- if( 0 == atoi(chMaxID) )
- {
- iMaxID = 1;
- }
- else
- {
- iMaxID = atoi(chMaxID) + 1;
- }
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_door_record( id,scardnumber,speople,sinout,sinfo,stime ) values(" \
- "%d, \'%s\',\'%s\',\'%s\',\'%s\',\'%s\')",
- iMaxID,scardnumber,speople,sinout,sinfo,stime );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- return iRetCode;
- }
- //更新Bit位表
- INT UpdateVarItemInfo(int nID, CHAR *pUid, int nStartBit, int nEndBit)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "update t_dev_variant_item set startbit = %d, endbit = %d where id = %d and uid = \'%s\'",
- nStartBit, nEndBit, nID, pUid);
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //插入变量状态描述
- INT InsertVarStatusInfo(int nID, CHAR *pUid, int nVarID, int nStatusID, CHAR *pStatusDesc)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "insert into t_var_status(id, devuid, varid, statusid, statusdesc, normalstatus) values(" \
- "%d, \'%s\', %d, %d, \'%s\', %d)",
- nID, pUid, nVarID, nStatusID, pStatusDesc, 0);
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //删除变量状态描述
- INT DeleteVarStatusInfo(CHAR *pUid, int nVarID)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "delete from t_var_status where devuid = \'%s\' and varid = %d ",
- pUid, nVarID);
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //清空表
- INT CleanTable( CHAR *pTableName )
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "delete from %s where id >0 ", pTableName);
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- //删除表中的项
- INT DelItemFromTable( CHAR *pTableName,CHAR* iItem,int nData )
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "delete from %s where %s = %d ", pTableName,iItem,nData );
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
- bool IsExistItem( CHAR *pTableName,CHAR* iItem,CHAR* sData )
- {
- bool bRet = false;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- list<string> list1;
- list<string>::iterator it;
- sprintf(strSQLText, "select id from %s where %s=\'%s\'", pTableName,iItem,sData );
- int nRet = GetFieldValueList1(strSQLText, list1);
- if( 0 == list1.size() )
- {
- return bRet;
- }
- if( nRet != -1 )
- {
- bRet = true;
- }
- for( it = list1.begin(); it != list1.end(); )
- {
- list1.erase(it++);
- }
- return bRet;
- }
- bool IsExistItem( CHAR *pTableName,CHAR* iItem,CHAR* sData,int iID )
- {
- bool bRet = false;
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- list<string> list1;
- list<string>::iterator it;
- sprintf(strSQLText, "select id from %s where %s=\'%s\'", pTableName,iItem,sData );
- int nRet = GetFieldValueList1(strSQLText, list1);
- if( 0 == list1.size() )
- {
- return bRet;
- }
- if( nRet != -1 )
- {
- it=list1.begin();
- CString s = (*it).c_str();
- if( atoi( (*it).c_str() ) != iID )
- {
- bRet = true;
- }
- }
- for( it = list1.begin(); it != list1.end(); )
- {
- list1.erase(it++);
- }
- return bRet;
- }
- //获取变量报警状态最大的ID
- INT GetVarStatusMaxID( CHAR *pMaxID )
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(strSQLText, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- // 获取最大的设备ID
- if (!pRSet->IsFieldNull("maxid"))
- {
- pRSet->GetFieldValue("maxid", strID);
- strcpy(pMaxID, (char *)(LPCTSTR)strID);
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList1(char *pSql, list<string>& list1)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 1 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }// end if( !pRSet->IsFieldNull(0) )
-
- }// end if( pRSet->GetFieldCount() >= 2 )
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList2(char *pSql, list<string>& list1, list<string>& list2)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 2 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }// end if( !pRSet->IsFieldNull(0) )
-
- if( !pRSet->IsFieldNull(1) )
- {
- pRSet->GetFieldValue(1, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list2.insert(list2.end(), strFieldValue);
- }
- else
- {
- list2.insert(list2.end(), "");
- }// end if( !pRSet->IsFieldNull(1) )
- }// end if( pRSet->GetFieldCount() >= 2 )
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList3(char *pSql, list<string>& list1, list<string>& list2, list<string>& list3)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 2 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }// end if( !pRSet->IsFieldNull(0) )
-
- if( !pRSet->IsFieldNull(1) )
- {
- pRSet->GetFieldValue(1, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list2.insert(list2.end(), strFieldValue);
- }
- else
- {
- list2.insert(list2.end(), "");
- }// end if( !pRSet->IsFieldNull(1) )
- if( !pRSet->IsFieldNull(2) )
- {
- pRSet->GetFieldValue(2, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list3.insert(list3.end(), strFieldValue);
- }
- else
- {
- list3.insert(list3.end(), "");
- }// end if( !pRSet->IsFieldNull(1) )
- }// end if( pRSet->GetFieldCount() >= 2 )
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList6(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 5 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }
-
- if( !pRSet->IsFieldNull(1) )
- {
- pRSet->GetFieldValue(1, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list2.insert(list2.end(), strFieldValue);
- }
- else
- {
- list2.insert(list2.end(), "");
- }
- if( !pRSet->IsFieldNull(2) )
- {
- pRSet->GetFieldValue(2, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list3.insert(list3.end(), strFieldValue);
- }
- else
- {
- list3.insert(list3.end(), "");
- }
- if( !pRSet->IsFieldNull(3) )
- {
- pRSet->GetFieldValue(3, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list4.insert(list4.end(), strFieldValue);
- }
- else
- {
- list4.insert(list4.end(), "");
- }
- if( !pRSet->IsFieldNull(4) )
- {
- pRSet->GetFieldValue(4, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list5.insert(list5.end(), strFieldValue);
- }
- else
- {
- list5.insert(list5.end(), "");
- }
- if( !pRSet->IsFieldNull(5) )
- {
- pRSet->GetFieldValue(5, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list6.insert(list6.end(), strFieldValue);
- }
- else
- {
- list6.insert(list6.end(), "");
- }
- }
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList9(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6,list<string>& list7,list<string>& list8,list<string>& list9)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 5 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }
-
- if( !pRSet->IsFieldNull(1) )
- {
- pRSet->GetFieldValue(1, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list2.insert(list2.end(), strFieldValue);
- }
- else
- {
- list2.insert(list2.end(), "");
- }
- if( !pRSet->IsFieldNull(2) )
- {
- pRSet->GetFieldValue(2, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list3.insert(list3.end(), strFieldValue);
- }
- else
- {
- list3.insert(list3.end(), "");
- }
- if( !pRSet->IsFieldNull(3) )
- {
- pRSet->GetFieldValue(3, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list4.insert(list4.end(), strFieldValue);
- }
- else
- {
- list4.insert(list4.end(), "");
- }
- if( !pRSet->IsFieldNull(4) )
- {
- pRSet->GetFieldValue(4, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list5.insert(list5.end(), strFieldValue);
- }
- else
- {
- list5.insert(list5.end(), "");
- }
- if( !pRSet->IsFieldNull(5) )
- {
- pRSet->GetFieldValue(5, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list6.insert(list6.end(), strFieldValue);
- }
- else
- {
- list6.insert(list6.end(), "");
- }
- if( !pRSet->IsFieldNull(6) )
- {
- pRSet->GetFieldValue(6, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list7.insert(list7.end(), strFieldValue);
- }
- else
- {
- list7.insert(list7.end(), "");
- }
- if( !pRSet->IsFieldNull(7) )
- {
- pRSet->GetFieldValue(7, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list8.insert(list8.end(), strFieldValue);
- }
- else
- {
- list8.insert(list8.end(), "");
- }
- if( !pRSet->IsFieldNull(8) )
- {
- pRSet->GetFieldValue(8, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list9.insert(list9.end(), strFieldValue);
- }
- else
- {
- list9.insert(list9.end(), "");
- }
- }
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList13(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6,
- list<string>& list7,list<string>& list8,list<string>& list9,list<string>& list10,list<string>& list11,list<string>& list12,list<string>& list13)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 13 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }
-
- if( !pRSet->IsFieldNull(1) )
- {
- pRSet->GetFieldValue(1, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list2.insert(list2.end(), strFieldValue);
- }
- else
- {
- list2.insert(list2.end(), "");
- }
- if( !pRSet->IsFieldNull(2) )
- {
- pRSet->GetFieldValue(2, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list3.insert(list3.end(), strFieldValue);
- }
- else
- {
- list3.insert(list3.end(), "");
- }
- if( !pRSet->IsFieldNull(3) )
- {
- pRSet->GetFieldValue(3, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list4.insert(list4.end(), strFieldValue);
- }
- else
- {
- list4.insert(list4.end(), "");
- }
- if( !pRSet->IsFieldNull(4) )
- {
- pRSet->GetFieldValue(4, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list5.insert(list5.end(), strFieldValue);
- }
- else
- {
- list5.insert(list5.end(), "");
- }
- if( !pRSet->IsFieldNull(5) )
- {
- pRSet->GetFieldValue(5, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list6.insert(list6.end(), strFieldValue);
- }
- else
- {
- list6.insert(list6.end(), "");
- }
- if( !pRSet->IsFieldNull(6) )
- {
- pRSet->GetFieldValue(6, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list7.insert(list7.end(), strFieldValue);
- }
- else
- {
- list7.insert(list7.end(), "");
- }
- if( !pRSet->IsFieldNull(7) )
- {
- pRSet->GetFieldValue(7, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list8.insert(list8.end(), strFieldValue);
- }
- else
- {
- list8.insert(list8.end(), "");
- }
- if( !pRSet->IsFieldNull(8) )
- {
- pRSet->GetFieldValue(8, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list9.insert(list9.end(), strFieldValue);
- }
- else
- {
- list9.insert(list9.end(), "");
- }
- if( !pRSet->IsFieldNull(9) )
- {
- pRSet->GetFieldValue(9, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list10.insert(list10.end(), strFieldValue);
- }
- else
- {
- list10.insert(list10.end(), "");
- }
- if( !pRSet->IsFieldNull(10) )
- {
- pRSet->GetFieldValue(10, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list11.insert(list11.end(), strFieldValue);
- }
- else
- {
- list11.insert(list11.end(), "");
- }
- if( !pRSet->IsFieldNull(11) )
- {
- pRSet->GetFieldValue(11, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list12.insert(list12.end(), strFieldValue);
- }
- else
- {
- list12.insert(list12.end(), "");
- }
- if( !pRSet->IsFieldNull(12) )
- {
- pRSet->GetFieldValue(12, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list13.insert(list13.end(), strFieldValue);
- }
- else
- {
- list13.insert(list13.end(), "");
- }
- }
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- int GetFieldValueList30(char *pSql,list<string>& list1,list<string>& list2,list<string>& list3,list<string>& list4,list<string>& list5,list<string>& list6,
- list<string>& list7,list<string>& list8,list<string>& list9,list<string>& list10,list<string>& list11,list<string>& list12,list<string>& list13
- ,list<string>& list14,list<string>& list15,list<string>& list16,list<string>& list17,list<string>& list18,list<string>& list19,list<string>& list20
- ,list<string>& list21,list<string>& list22,list<string>& list23,list<string>& list24,list<string>& list25
- ,list<string>& list26,list<string>& list27,list<string>& list28,list<string>& list29,list<string>& list30)
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- CString strID;
- CADORecordset* pRSet = NULL;
- INT iRetCode = 0;
- int nCount = 0;
- _variant_t vtFieldValue;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- pRSet = new CADORecordset(g_pADODatabase);
- if (NULL == pRSet)
- {
- return -1;
- }
- //sprintf(strSQLText, "select max(id) as maxid from t_var_status");
- iRetCode = pRSet->Open(pSql, CADORecordset::openQuery);
- if (iRetCode == 0)
- {
- delete pRSet;
- pRSet = NULL;
- return -1;
- }
- nCount = pRSet->GetRecordCount();
- if (nCount == 0)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- for( int i = 0; i < nCount; i++ )
- {
- if( pRSet->GetFieldCount() >= 30 )
- {
- if( !pRSet->IsFieldNull(0) )
- {
- pRSet->GetFieldValue(0, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list1.insert(list1.end(), strFieldValue);
- }
- else
- {
- list1.insert(list1.end(), "");
- }
-
- if( !pRSet->IsFieldNull(1) )
- {
- pRSet->GetFieldValue(1, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list2.insert(list2.end(), strFieldValue);
- }
- else
- {
- list2.insert(list2.end(), "");
- }
- if( !pRSet->IsFieldNull(2) )
- {
- pRSet->GetFieldValue(2, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list3.insert(list3.end(), strFieldValue);
- }
- else
- {
- list3.insert(list3.end(), "");
- }
- if( !pRSet->IsFieldNull(3) )
- {
- pRSet->GetFieldValue(3, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list4.insert(list4.end(), strFieldValue);
- }
- else
- {
- list4.insert(list4.end(), "");
- }
- if( !pRSet->IsFieldNull(4) )
- {
- pRSet->GetFieldValue(4, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list5.insert(list5.end(), strFieldValue);
- }
- else
- {
- list5.insert(list5.end(), "");
- }
- if( !pRSet->IsFieldNull(5) )
- {
- pRSet->GetFieldValue(5, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list6.insert(list6.end(), strFieldValue);
- }
- else
- {
- list6.insert(list6.end(), "");
- }
- if( !pRSet->IsFieldNull(6) )
- {
- pRSet->GetFieldValue(6, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list7.insert(list7.end(), strFieldValue);
- }
- else
- {
- list7.insert(list7.end(), "");
- }
- if( !pRSet->IsFieldNull(7) )
- {
- pRSet->GetFieldValue(7, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list8.insert(list8.end(), strFieldValue);
- }
- else
- {
- list8.insert(list8.end(), "");
- }
- if( !pRSet->IsFieldNull(8) )
- {
- pRSet->GetFieldValue(8, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list9.insert(list9.end(), strFieldValue);
- }
- else
- {
- list9.insert(list9.end(), "");
- }
- if( !pRSet->IsFieldNull(9) )
- {
- pRSet->GetFieldValue(9, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list10.insert(list10.end(), strFieldValue);
- }
- else
- {
- list10.insert(list10.end(), "");
- }
- if( !pRSet->IsFieldNull(10) )
- {
- pRSet->GetFieldValue(10, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list11.insert(list11.end(), strFieldValue);
- }
- else
- {
- list11.insert(list11.end(), "");
- }
- if( !pRSet->IsFieldNull(11) )
- {
- pRSet->GetFieldValue(11, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list12.insert(list12.end(), strFieldValue);
- }
- else
- {
- list12.insert(list12.end(), "");
- }
- if( !pRSet->IsFieldNull(12) )
- {
- pRSet->GetFieldValue(12, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list13.insert(list13.end(), strFieldValue);
- }
- else
- {
- list13.insert(list13.end(), "");
- }
- if( !pRSet->IsFieldNull(13) )
- {
- pRSet->GetFieldValue(13, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list14.insert(list14.end(), strFieldValue);
- }
- else
- {
- list14.insert(list14.end(), "");
- }
- if( !pRSet->IsFieldNull(14) )
- {
- pRSet->GetFieldValue(14, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list15.insert(list15.end(), strFieldValue);
- }
- else
- {
- list15.insert(list15.end(), "");
- }
- if( !pRSet->IsFieldNull(15) )
- {
- pRSet->GetFieldValue(15, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list16.insert(list16.end(), strFieldValue);
- }
- else
- {
- list16.insert(list16.end(), "");
- }
- if( !pRSet->IsFieldNull(16) )
- {
- pRSet->GetFieldValue(16, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list17.insert(list17.end(), strFieldValue);
- }
- else
- {
- list17.insert(list17.end(), "");
- }
- if( !pRSet->IsFieldNull(17) )
- {
- pRSet->GetFieldValue(17, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list18.insert(list18.end(), strFieldValue);
- }
- else
- {
- list18.insert(list18.end(), "");
- }
- if( !pRSet->IsFieldNull(18) )
- {
- pRSet->GetFieldValue(18, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list19.insert(list19.end(), strFieldValue);
- }
- else
- {
- list19.insert(list19.end(), "");
- }
- if( !pRSet->IsFieldNull(19) )
- {
- pRSet->GetFieldValue(19, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list20.insert(list20.end(), strFieldValue);
- }
- else
- {
- list20.insert(list20.end(), "");
- }
- if( !pRSet->IsFieldNull(20) )
- {
- pRSet->GetFieldValue(20, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list21.insert(list21.end(), strFieldValue);
- }
- else
- {
- list21.insert(list21.end(), "");
- }
- if( !pRSet->IsFieldNull(21) )
- {
- pRSet->GetFieldValue(21, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list22.insert(list22.end(), strFieldValue);
- }
- else
- {
- list22.insert(list22.end(), "");
- }
- if( !pRSet->IsFieldNull(22) )
- {
- pRSet->GetFieldValue(22, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list23.insert(list23.end(), strFieldValue);
- }
- else
- {
- list23.insert(list23.end(), "");
- }
- if( !pRSet->IsFieldNull(23) )
- {
- pRSet->GetFieldValue(23, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list24.insert(list24.end(), strFieldValue);
- }
- else
- {
- list24.insert(list24.end(), "");
- }
- if( !pRSet->IsFieldNull(24) )
- {
- pRSet->GetFieldValue(24, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list25.insert(list25.end(), strFieldValue);
- }
- else
- {
- list25.insert(list25.end(), "");
- }
- if( !pRSet->IsFieldNull(25) )
- {
- pRSet->GetFieldValue(25, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list26.insert(list26.end(), strFieldValue);
- }
- else
- {
- list26.insert(list26.end(), "");
- }
- if( !pRSet->IsFieldNull(26) )
- {
- pRSet->GetFieldValue(26, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list27.insert(list27.end(), strFieldValue);
- }
- else
- {
- list27.insert(list27.end(), "");
- }
- if( !pRSet->IsFieldNull(27) )
- {
- pRSet->GetFieldValue(27, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list28.insert(list28.end(), strFieldValue);
- }
- else
- {
- list28.insert(list28.end(), "");
- }
- if( !pRSet->IsFieldNull(28) )
- {
- pRSet->GetFieldValue(28, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list29.insert(list29.end(), strFieldValue);
- }
- else
- {
- list29.insert(list29.end(), "");
- }
- if( !pRSet->IsFieldNull(29) )
- {
- pRSet->GetFieldValue(29, vtFieldValue);
- string strFieldValue = string((char*)(_bstr_t)vtFieldValue);
- list30.insert(list30.end(), strFieldValue);
- }
- else
- {
- list30.insert(list30.end(), "");
- }
- }
- pRSet->MoveNext();
- }// end for( int i = 0; i < nRecordCount; i++ )
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return nCount;
- }
- }
- catch (_com_error &e)
- {
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return -1;
- }
- if( pRSet )
- {
- delete pRSet;
- pRSet = NULL;
- }
- return 0;
- }
- //更新变量是否要SNMP发送
- INT UpdateVarSnmpStatus( int nID, bool bStatus )
- {
- CHAR strMsg[MAX_MSG_LENGTH + 1] = "";
- CHAR strSQLText[MAX_SQL_LENGTH + 1] = "";
- INT iRetCode = 0;
- try
- {
- if (g_pADODatabase != NULL && g_pADODatabase->IsOpen())
- {
- sprintf(strSQLText, "update t_dev_variant set boolreserved4 = \'%d\' where id = %d ",bStatus, nID);
- iRetCode = g_pADODatabase->Execute(strSQLText);
- }
- }
- catch (_com_error &e)
- {
- //sprintf(strMsg, g_strErrorExecSql, strSQLText, e.ErrorMessage());
- //AddToPrintQueue(MSG_ERROR, MSG_DB_MD, strMsg, strlen(strMsg));
- return 0;
- }
- return iRetCode;
- }
|