//--------------------------------------------------------------------------- #include #include "VMSCommLibF.h" #pragma hdrstop #include "DbmThreadF.h" #include "CDSProcessF.h" #include "CDSManagerF.h" #include "CDSImageF.h" #include "CDSFormF.h" #include "CDSIfscF.h" #pragma package(smart_init) TDbmThread *DbmThread = NULL; //--------------------------------------------------------------------------- TDbmThread::TDbmThread() { FPnlState = NULL; FTmrDb = NULL; } //--------------------------------------------------------------------------- TDbmThread::~TDbmThread() { } //--------------------------------------------------------------------------- int __fastcall TDbmThread::CloseDb() { try { if (FDb) { FDb->Close(); } } catch(Exception &e) { } return 0; } //--------------------------------------------------------------------------- void __fastcall TDbmThread::updateLedColor(TColor AColor) { try { if (FPnlState) { PostMessage((HWND)g_AppCfg.lMainWinHandle, WM_PANEL_REFRESH, 2, (LPARAM)AColor); } } catch(Exception &e) {} } //--------------------------------------------------------------------------- DWORD __fastcall TDbmThread::Process(LPVOID AParam) { IPC_DBM_MESSAGE *pDbm; DWORD dwJob; AnsiString sSysTime; bool isDbOk; CoInitialize(NULL); FDb = new TDMAdoDb(NULL); if (g_AppCfg.IsDbConnectPerJob == false) { FDb->Connect(g_AppCfg.db.sConnectStr); } UINT nMsg = WM_DB_WRITE_THREAD; while(!IsTerm() && !g_AppCfg.bThrExit) { updateLedColor(clGreen); updateLedColor(clGreen); if (!g_dbmQ.PopBlocking(dwJob)) { continue; } if (dwJob == Q_CLOSE) { break; } else if (dwJob == Q_TICK) { updateLedColor(clRed); continue; } updateLedColor(clLime); pDbm = (IPC_DBM_MESSAGE*)dwJob; int nRes = 0; try { if (g_AppCfg.IsDbConnectPerJob == true) { FDb->Connect(g_AppCfg.db.sConnectStr); } if (FDb->IsDbConnected() == false) { if (!FDb->Connect(g_AppCfg.db.sConnectStr)) { nRes = -1; FDb->SetDbState(false, nMsg); MERROR("DBMW=============> Database connect failed..."); } } AnsiString dbJobName = APP_GetDbJobName(pDbm->Command); DWORD starDbJobTick = GetTickCount(); if (pDbm->Command != dbm_save_ctlr_stts) { MINFO("DBMW=============> DBMS JOB START: %s", dbJobName.c_str()); } if (nRes == 0) { if (FTmrDb) { FTmrDb->Tag = (int)pDbm->Command; } SendMessage((HWND)g_AppCfg.lMainWinHandle, nMsg, dbm_job_start, pDbm->Command); switch(pDbm->Command) { case dbm_save_unit_stts: nRes = CDSProcessManager->SaveUnitStts(FDb->GetConnection()); break; //case dbm_save_unit_stts_hs: // nRes = CDSProcessManager->SaveUnitSttsHs(FDb->GetConnection()); // break; case dbm_save_ctlr_stts: nRes = CDSCtlrManager->SaveCtlrStts(FDb->GetConnection(), pDbm->U.Data); break; case dbm_parma_res: nRes = CDSCtlrManager->SaveCtlrParam(FDb->GetConnection(), pDbm->U.Data); break; case dbm_save_ctlr_stts_all: nRes = CDSCtlrManager->SaveCtlrSttsAll(FDb->GetConnection()); break; case dbm_load_onoff_time: nRes = CDSManager->LoadVmsOnOffTime(FDb->GetConnection()); break; case dbm_load_download_job: nRes = CDSManager->LoadVmsDownLoadJob(FDb->GetConnection()); break; case dbm_save_form_download: nRes = CDSManager->SaveVmsDownloadForm(FDb->GetConnection()); break; case dbm_dnld_form_init: case dbm_dnld_form_cycle: case dbm_dnld_form_mode: /* * VMS 정보제공구간 교통정보를 생성한 후 VMS 메세지를 생성하는 경우 */ if (CDSVmsIfscTrafManager) { nRes = CDSVmsIfscTrafManager->CreateVmsIfscTraffic(FDb->GetConnection()); } nRes = CDSManager->DownloadVmsForm(FDb->GetConnection(), pDbm->Command); break; // static_cycle, mode_change case dbm_provide_result: nRes = CDSManager->SaveProvideResult(FDb->GetConnection(), pDbm->U.Data); break; case dbm_master_symbol_image: case dbm_master_symbol_traffic: nRes = CDSImageManager->LoadVmsSymbolInfo(FDb->GetConnection()); break; case dbm_master_form: nRes = CDSFormManager->LoadVmsFormInfo(FDb->GetConnection()); break; case dbm_master_vms_ifsc: /* * VMS 정보제공구간 교통정보를 생성한 후 VMS 메세지를 생성하는 경우 */ if (CDSVmsIfscTrafManager) { nRes = CDSVmsIfscTrafManager->InitVmsIfscTraffic(FDb->GetConnection()); } nRes = CDSIfscManager->LoadVmsIfscInfo(FDb->GetConnection()); break; case dbm_check_db_alive: nRes = FDb->IsDbAlive(sSysTime); break; case dbm_initialize: nRes = app_initialize(); break; default: MERROR("DBMW=============> Unknown DBMS Job Type: %d", pDbm->Command); break; } if (nRes < 0) { FDb->SetDbState(false, nMsg); FDb->Close(); MERROR("DBMW=============> Database job error: %d", pDbm->Command); } else { FDb->SetDbState(true, nMsg); } } if (pDbm->Command != dbm_save_ctlr_stts) { MINFO("DBMW=============> DBMS JOB ..END: %s, %d, Elapsed: %u ms.", dbJobName.c_str(), nRes, GetTickCount() - starDbJobTick); } } __finally { if (g_AppCfg.IsDbConnectPerJob == true) { FDb->Close(); } SendMessage((HWND)g_AppCfg.lMainWinHandle, nMsg, pDbm->Command, nRes); //SAFE_DELETE(pDbm); } } if (g_AppCfg.IsDbConnectPerJob == false) { FDb->Close(); } SAFE_DELETE(FDb); Term(); CoUninitialize(); return 0; } //--------------------------------------------------------------------------- int __fastcall TDbmThread::app_initialize() { #if 0 MINFO("DCOM Process Information initialize..."); if (DMManager->GetProcessInfo() != VERR_NONE) { MERROR("DCOM Process Information initialize failed. Program abnormal terminate."); return -1; } MINFO("DCOM VMS Information initialize..."); if (DMManager->GeTCDSCtlrInfo() != VERR_NONE) { MERROR("DCOM VMS Information initialize failed. Program abnormal terminate."); return -2; } MINFO("DCOM VMS Scetion Information initialize..."); if (DMManager->GetVmsIfscInfo() != VERR_NONE) { MERROR("DCOM VMS Scetion Information initialize failed. Program abnormal terminate."); return -3; } MINFO("DCOM VMS Form Information initialize..."); if (DMManager->GetVmsImage() != VERR_NONE) { MERROR("DCOM VMS Form Information initialize failed. Program abnormal terminate."); return -4; } MINFO("DCOM VMS Form Information initialize..."); if (DMManager->LoadVmsForm() != VERR_NONE) { MERROR("DCOM VMS Form Information initialize failed. Program abnormal terminate."); return -5; } #endif return 0; } //---------------------------------------------------------------------------