CDSVmsCtlrF.cpp 67 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSVmsCtlrF.h"
  4. #include "AppGlobalF.h"
  5. //---------------------------------------------------------------------------
  6. #pragma package(smart_init)
  7. //---------------------------------------------------------------------------
  8. TVmsIfscRltn::TVmsIfscRltn()
  9. {
  10. }
  11. //---------------------------------------------------------------------------
  12. TVmsIfscRltn::~TVmsIfscRltn()
  13. {
  14. }
  15. //---------------------------------------------------------------------------
  16. //---------------------------------------------------------------------------
  17. TVmsMsg::TVmsMsg()
  18. {
  19. for (int ii = 0; ii < INT_MAX_VMS_FORM; ii++)
  20. {
  21. PHASE[ii].pVmsBmp = NULL;
  22. }
  23. Init();
  24. };
  25. //---------------------------------------------------------------------------
  26. TVmsMsg::~TVmsMsg()
  27. {
  28. for (int ii = 0; ii < INT_MAX_VMS_FORM; ii++)
  29. {
  30. if (PHASE[ii].pVmsBmp)
  31. {
  32. PHASE[ii].pVmsBmp->FreeImage();
  33. PHASE[ii].pVmsBmp->Assign(NULL);
  34. delete PHASE[ii].pVmsBmp;
  35. PHASE[ii].pVmsBmp = NULL;
  36. }
  37. }
  38. };
  39. //---------------------------------------------------------------------------
  40. void TVmsMsg::Init()
  41. {
  42. Total = 0;
  43. Curr = 0;
  44. OFFER_DT = "19990101000000";
  45. OFFER_YN = false;
  46. for (int ii = 0; ii < INT_MAX_VMS_FORM; ii++)
  47. {
  48. PHASE[ii].DSPL_HH = 4; //표출시간
  49. PHASE[ii].DNLD_YN = "N"; //다운로드성공여부
  50. PHASE[ii].DSPL_CD = ""; //표출방법
  51. }
  52. };
  53. //---------------------------------------------------------------------------
  54. void VmsInitStatus(WIN_VMS_STATE *AState)
  55. {
  56. int ii;
  57. if (AState->Comm != vms_normal && AState->Wcomm != vms_normal)
  58. {
  59. AState->DoorStatus = vms_unknown; /* 도어상태정보코드, 0:열림 1:닫힘 2:알수없음 */
  60. AState->ModulePowerStatus = vms_unknown; /* 모듈전원상태정보코드, 0:켜짐 1:꺼짐 2:알수없음 */
  61. AState->BodyTemp = 0; /* 함체온도값(℃), 범위(-128~127) */
  62. AState->LuminanceStatus = 0; /* 화면의 밝기값 (최대 휘도값을 100으로 했을 때의 백분율 값), 범위(0~100) */
  63. AState->FanStatus = vms_unknown; /* Fan 동작상태정보코드, 0:켜짐, 1:꺼짐 2:알수없음 */
  64. AState->HeaterStatus = vms_unknown; /* Heater 동작상태정보코드, 0:켜짐, 1:꺼짐 2:알수없음 */
  65. AState->ExternalLightStatus = vms_unknown; /* 선택 외부조명 동작상태정보코드 0:켜짐, 1:꺼짐, 2:자동(공단은 미사용) */
  66. AState->AlarmLightStatus = vms_unknown; /* 선택 경광등 동작상태정보코드 0:켜짐, 1:꺼짐 */
  67. AState->SpeakerStatus = vms_unknown; /* 선택 스피커 동작상태정보코드 0:켜짐, 1:꺼짐 */
  68. //memset(&AState->ControllerCurrentTime, 0x00, sizeof(AState->ControllerCurrentTime)); /*선택 제어기 시간 (YYYYMMDDHHMMSS) */
  69. AState->Voltage = 0; /* 전압, 범위(0~255), 사용안함 */
  70. // AState->ModuleState = vms_unknown; /* 모듈 상태, 0:정상 1:장애 2:알수없음 */
  71. #if 0
  72. //AState->ModuleHorizontal = 0; /* 가로 모듈수 */
  73. //AState->ModuleVertical = 0; /* 세로 모듈수 */
  74. for (ii = 0; ii < INT_VMS_MAX_MODULE_BIT; ii++)
  75. AState->ModuleStatus[ii] = 0xFF;//vms_unknown; /* 모듈 개별 상태, 0:정상 1:장애 2:알수없음 */
  76. //AState->PowerCount = 0; /* 전원 갯수 */
  77. for (ii = 0; ii < INT_VMS_MAX_POWER_BIT; ii++)
  78. AState->PowerStatus[ii] = 0xFF;//vms_unknown; /* 전원 개별 상태, 0:켜짐 1:꺼짐 2:알수없음 */
  79. #endif
  80. #if 0
  81. AState->ScheduledMessageOperatingTime = 0; /* 필수 계획된 메시지의 동작시간(초) */
  82. AState->ModuleOperatingTemperature = 0; /* 필수 모듈 전원이 꺼지는 온도값(℃) */
  83. AState->FanOperatingTemperature = 0; /* 필수 Fan 동작 기준 온도값(℃) */
  84. AState->HeaterOperatingTemperature = 0; /* 필수 Heater 동작 기준 온도값(℃) */
  85. AState->ExternalLightOperatingLuminance = 0; /* 선택 외부전등 동작 기준 휘도값 */
  86. AState->ModuleBasicFailureRate = 0; /* 선택 모듈 장애율 (한 개의 모듈을 장애로 처리하기 위한 픽셀의 백분율값) */
  87. AState->MaximumRetry = 0; /* 선택 최대 재시도 횟수(회) */
  88. AState->ResponseTimeOut = 0; /* 선택 최대응답대기시간 (초) */
  89. AState->BlinkingCycleTime = 0; /* 선택 점멸시간 주기 ( 1/10초단위) */
  90. #endif
  91. }
  92. for (ii = 0; ii < INT_VMS_MAX_MODULE_BIT; ii++)
  93. AState->ModuleStatus[ii] = 0xFF;//vms_unknown; /* 모듈 개별 상태, 0:정상 1:장애 2:알수없음 */
  94. //AState->PowerCount = 0; /* 전원 갯수 */
  95. for (ii = 0; ii < INT_VMS_MAX_POWER_BIT; ii++)
  96. AState->PowerStatus[ii] = 0xFF;//vms_unknown; /* 전원 개별 상태, 0:켜짐 1:꺼짐 2:알수없음 */
  97. }
  98. //---------------------------------------------------------------------------
  99. void VmsStatusCopy(WIN_VMS_STATE *AState, INT_VMS_STATE *ASrc)
  100. {
  101. int ii;
  102. AState->OprMode = ASrc->OprMode; /* VMS운영모드, 0:auto, 1:Fix */
  103. AState->Comm = ASrc->Comm; /* 유선통신상태, 0:정상 1:장애 */
  104. AState->Wcomm = ASrc->Wcomm; /* 무선통신상태, 0:정상 1:장애 */
  105. AState->DoorStatus = ASrc->DoorStatus; /* 도어상태정보코드, 0:열림 1:닫힘 2:알수없음 */
  106. AState->ModulePowerStatus = ASrc->ModulePowerStatus; /* 모듈전원상태정보코드, 0:켜짐 1:꺼짐 2:알수없음 */
  107. AState->BodyTemp = ASrc->BodyTemp; /* 함체온도값(℃), 범위(-128~127) */
  108. AState->LuminanceStatus = ASrc->LuminanceStatus; /* 화면의 밝기값 (최대 휘도값을 100으로 했을 때의 백분율 값), 범위(0~100) */
  109. AState->FanStatus = ASrc->FanStatus; /* Fan 동작상태정보코드, 0:켜짐, 1:꺼짐 2:알수없음 */
  110. AState->HeaterStatus = ASrc->HeaterStatus; /* Heater 동작상태정보코드, 0:켜짐, 1:꺼짐 2:알수없음 */
  111. AState->ExternalLightStatus = ASrc->ExternalLightStatus; /* 선택 외부조명 동작상태정보코드 0:켜짐, 1:꺼짐, 2:자동(공단은 미사용) */
  112. AState->AlarmLightStatus = ASrc->AlarmLightStatus; /* 선택 경광등 동작상태정보코드 0:켜짐, 1:꺼짐 */
  113. AState->SpeakerStatus = ASrc->SpeakerStatus; /* 선택 스피커 동작상태정보코드 0:켜짐, 1:꺼짐 */
  114. for (ii = 0; ii < INT_VMS_MAX_DATETIME; ii++)
  115. AState->ControllerCurrentTime[ii] = ASrc->ControllerCurrentTime[ii]; /* 선택 제어기 시간 (YYYYMMDDHHMMSS) */
  116. AState->Voltage = ASrc->Voltage; /* 전압, 범위(0~255), 사용안함 */
  117. AState->ModuleState = ASrc->ModuleState; /* 모듈 상태, 0:정상 1:장애 2:알수없음 */
  118. AState->ModuleHorizontal = ASrc->ModuleHorizontal; /* 가로 모듈수 */
  119. AState->ModuleVertical = ASrc->ModuleVertical; /* 세로 모듈수 */
  120. for (ii = 0; ii < INT_VMS_MAX_MODULE_BIT; ii++)
  121. AState->ModuleStatus[ii] = ASrc->ModuleStatus[ii]; /* 모듈 개별 상태, 0:정상 1:장애 2:알수없음 */
  122. AState->PowerCount = ASrc->PowerCount; /* 전원 갯수 */
  123. for (ii = 0; ii < INT_VMS_MAX_POWER_BIT; ii++)
  124. AState->PowerStatus[ii] = ASrc->PowerStatus[ii]; /* 전원 개별 상태, 0:켜짐 1:꺼짐 2:알수없음 */
  125. AState->ScheduledMessageOperatingTime = ASrc->ScheduledMessageOperatingTime; /* 필수 계획된 메시지의 동작시간(초) */
  126. AState->ModuleOperatingTemperature = ASrc->ModuleOperatingTemperature; /* 필수 모듈 전원이 꺼지는 온도값(℃) */
  127. AState->FanOperatingTemperature = ASrc->FanOperatingTemperature; /* 필수 Fan 동작 기준 온도값(℃) */
  128. AState->HeaterOperatingTemperature = ASrc->HeaterOperatingTemperature; /* 필수 Heater 동작 기준 온도값(℃) */
  129. AState->ExternalLightOperatingLuminance = ASrc->ExternalLightOperatingLuminance; /* 선택 외부전등 동작 기준 휘도값 */
  130. AState->ModuleBasicFailureRate = ASrc->ModuleBasicFailureRate; /* 선택 모듈 장애율 (한 개의 모듈을 장애로 처리하기 위한 픽셀의 백분율값) */
  131. AState->MaximumRetry = ASrc->MaximumRetry; /* 선택 최대 재시도 횟수(회) */
  132. AState->ResponseTimeOut = ASrc->ResponseTimeOut; /* 선택 최대응답대기시간 (초) */
  133. AState->BlinkingCycleTime = ASrc->BlinkingCycleTime; /* 선택 점멸시간 주기 ( 1/10초단위) */
  134. }
  135. //---------------------------------------------------------------------------
  136. //---------------------------------------------------------------------------
  137. TVmsCtlr::TVmsCtlr()
  138. {
  139. InitializeCriticalSection(&FCS);
  140. FCompleted = false;
  141. FEditMode = DB_INIT;
  142. FGridIndex = -1;
  143. MEM_DEL = "N";
  144. VMS_NGHT_BRGH_STEP = 0; // NUMBER(2) Y VMS 야간 휘도 단계
  145. VMS_WEEK_BRGH_STEP = 0; // NUMBER(2) Y VMS 주간 휘도 단계
  146. CMNCFAIL_SLOT_NMBR = 0; // NUMBER(4) Y 0 통신장애 SLOT 번호
  147. PWER_FAIL_SLOT_NMBR = 0; // NUMBER(4) Y 0 전원 장애 SLOT 번호
  148. CMTRINFR_CNCT_YN = "N"; // CHAR(1) Y 'N' 소통정보 연계 여부
  149. WTHRINFR_CNCT_YN = "N"; // CHAR(1) Y 'N' 기상정보 연계 여부
  150. ENVRINFR_CNCT_YN = "N"; // CHAR(1) Y 'N' 환경정보 연계 여부
  151. PANL_ON_TIME = "0000"; // VARCHAR2(4) Y 전광판 ON TIME
  152. PANL_OFF_TIME = "0000"; // VARCHAR2(4) Y 전광판 OFF TIME
  153. X_CRDN = 0; // NUMBER(11,8) Y X 좌표
  154. Y_CRDN = 0; // NUMBER(10,8) Y Y 좌표
  155. TRFC_STRG_USE_YN = "Y"; // CHAR(1) Y 'N' 교통 전략 사용 여부
  156. VMS_LOC_IFSC_ID = ""; // NUMBER(10) Y VMS 위치 정보제공구간 ID
  157. OPER_MODE = "A";
  158. VMS_MAX_PHSE_NUM = 16; // NUMBER(2) Y VMS 최대 표출면 개수
  159. VMS_PHSE_CHNG_CYCL = 5; // NUMBER(3) Y VMS 표출면 변경 주기
  160. VMS_CMNC_ERR_BASS_VAL = 127; // NUMBER(3) Y VMS 통신 오류 기본 값(모듈 전원이 꺼지는 온도값(℃))
  161. FAN_MTNS_TMPR = 35; // NUMBER(6,3) Y 팬 동작 온도
  162. HETR_MTNS_TMPR = 0; // NUMBER(6,3) Y 히터 동작 온도
  163. VMS_MODL_ERR_RATE = 20; // NUMBER(3) Y VMS 모듈 오류 율(Options)
  164. WEB_CMRA_PORT = 0; // NUMBER(5) Y
  165. WEB_CMRA_ID = ""; // VARCHAR2(20) Y
  166. WEB_CMRA_PWD = ""; // VARCHAR2(20) Y
  167. STRM_SESN_NM = ""; // VARCHAR2(200) Y 스트리밍 세션 명
  168. DEL_YN = "N"; // CHAR(1) Y 'N' 삭제 여부
  169. memset(&WSTATE, 0x00, sizeof(WSTATE));
  170. WSTATE.Comm = vms_error;
  171. VmsInitStatus(&WSTATE);
  172. WSTATE.Comm = vms_error;
  173. InitFormCount();
  174. VmsMsg = NULL;
  175. VmsMsg = new TVmsMsg();
  176. VmsMsg->Init();
  177. FData1 = NULL;
  178. FData2 = NULL;
  179. FData3 = NULL;
  180. RunState = state_error;
  181. }
  182. //---------------------------------------------------------------------------
  183. TVmsCtlr::~TVmsCtlr()
  184. {
  185. FIfscRltn.RemoveAll();
  186. DeleteCriticalSection(&FCS);
  187. }
  188. //---------------------------------------------------------------------------
  189. void TVmsCtlr::Lock()
  190. {
  191. //EnterCriticalSection(&FCS);
  192. }
  193. //---------------------------------------------------------------------------
  194. void TVmsCtlr::UnLock()
  195. {
  196. //LeaveCriticalSection(&FCS);
  197. }
  198. //---------------------------------------------------------------------------
  199. void TVmsCtlr::CheckRunState()
  200. {
  201. RunState = WSTATE.Comm;
  202. if (RunState == vms_normal)
  203. {
  204. #if 0
  205. if (WSTATE.DoorStatus == vms_open)
  206. RunState = state_module;
  207. if (WSTATE.ModulePowerStatus == vms_error)
  208. RunState = state_module;
  209. if (WSTATE.ModuleState == vms_error)
  210. RunState = state_module;
  211. #endif
  212. }
  213. }
  214. //---------------------------------------------------------------------------
  215. TVmsSize::TVmsSize()
  216. {
  217. }
  218. //---------------------------------------------------------------------------
  219. //---------------------------------------------------------------------------
  220. TVmsCtlrManager *VmsManager = NULL;
  221. //---------------------------------------------------------------------------
  222. TVmsCtlrManager::TVmsCtlrManager()
  223. {
  224. FImgStream = NULL;
  225. }
  226. //---------------------------------------------------------------------------
  227. TVmsCtlrManager::~TVmsCtlrManager()
  228. {
  229. FVmsSize.RemoveAll();
  230. FLists.RemoveAll();
  231. if (FImgStream) delete FImgStream;
  232. FImgStream = NULL;
  233. }
  234. //---------------------------------------------------------------------------
  235. void TVmsCtlrManager::InitFormCount()
  236. {
  237. try
  238. {
  239. FLists.Lock();
  240. FOR_STL(TVmsCtlr*, pObj, FLists)
  241. {
  242. pObj->InitFormCount();
  243. }
  244. }
  245. __finally
  246. {
  247. FLists.UnLock();
  248. }
  249. };
  250. //---------------------------------------------------------------------------
  251. bool TVmsCtlrManager::LoadVmsSize(TADOConnection *ADbConn/*=NULL*/)
  252. {
  253. String sQry;
  254. TADOQuery *pADO = NULL;
  255. try
  256. {
  257. FVmsSize.Lock();
  258. FVmsSize.RemoveAll();
  259. }
  260. __finally
  261. {
  262. FVmsSize.UnLock();
  263. }
  264. #if 0
  265. sQry = "SELECT CMMN_CD, \r\n"
  266. " CMMN_CD_ENGL_NM AS CMMN_CD_KOR_NM, \r\n"
  267. " NVL(ATRB1, '320') AS FORMW, \r\n"
  268. " NVL(ATRB2, '64') AS FORMH \r\n"
  269. " FROM TB_CMMN_CD \r\n"
  270. " WHERE CMMN_CLSF_CD = 'VMP' \r\n"
  271. " AND USE_YN = 'Y' \r\n"
  272. " AND CMMN_CD IN (SELECT DISTINCT VMS_TYPE_CD \r\n"
  273. " FROM TB_VMS_CTLR) \r\n"
  274. " ORDER BY CMMN_CD DESC \r\n";
  275. #else
  276. sQry = "SELECT VMS_TYPE_CD, VMS_TYPE_NM, \r\n"
  277. " VMS_WDTH, VMS_HGHT, MODL_ROW_NUM, MODL_COL_NUM \r\n"
  278. " FROM TB_VMS_TYPE \r\n";
  279. #endif
  280. try
  281. {
  282. FVmsSize.Lock();
  283. try
  284. {
  285. pADO = new TADOQuery(NULL);
  286. pADO->Close();
  287. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  288. pADO->SQL->Clear();
  289. pADO->SQL->Text = sQry;
  290. pADO->Open();
  291. for( ; !pADO->Eof; pADO->Next())
  292. {
  293. TVmsSize *pObj = new TVmsSize();
  294. pObj->TypeCd = pADO->FieldByName("VMS_TYPE_CD")->AsString;
  295. pObj->TypeNm = pADO->FieldByName("VMS_TYPE_NM")->AsString;
  296. pObj->Width = pADO->FieldByName("VMS_WDTH")->AsInteger;
  297. pObj->Height = pADO->FieldByName("VMS_HGHT")->AsInteger;
  298. FVmsSize.Push(pObj->TypeCd, pObj);
  299. }
  300. }
  301. catch(EDatabaseError &E)
  302. {
  303. DBERRORMSG("TVmsCtlrManager::LoadVmsSize", String(E.ClassName()), E.Message, sQry);
  304. throw Exception(String(E.ClassName()) + E.Message);
  305. }
  306. catch(Exception &e)
  307. {
  308. DBERRORMSG("TVmsCtlrManager::LoadVmsSize", String(e.ClassName()), e.Message, sQry);
  309. throw Exception(String(e.ClassName()) + e.Message);
  310. }
  311. }
  312. __finally
  313. {
  314. if (pADO)
  315. {
  316. pADO->Close();
  317. delete pADO;
  318. }
  319. FVmsSize.UnLock();
  320. }
  321. return true;
  322. }
  323. //---------------------------------------------------------------------------
  324. bool TVmsCtlrManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  325. {
  326. String sQry;
  327. TADOQuery *pADO = NULL;
  328. FMinWidth = 1000;
  329. FMinHeight= 1000;
  330. FMaxWidth = 0;
  331. FMaxHeight= 0;
  332. try
  333. {
  334. FLists.Lock();
  335. FLists.RemoveAll();
  336. }
  337. __finally
  338. {
  339. FLists.UnLock();
  340. }
  341. #if 0
  342. sQry = "SELECT A.*, \r\n"
  343. " (SELECT NVL(ATRB1, '320') \r\n"
  344. " FROM TB_CMMN_CD \r\n"
  345. " WHERE CMMN_CLSF_CD = 'VMP' \r\n"
  346. " AND CMMN_CD = A.VMS_TYPE_CD) AS FORMW, \r\n"
  347. " (SELECT NVL(ATRB2, '64') \r\n"
  348. " FROM TB_CMMN_CD \r\n"
  349. " WHERE CMMN_CLSF_CD = 'VMP' \r\n"
  350. " AND CMMN_CD = A.VMS_TYPE_CD) AS FORMH \r\n"
  351. " FROM TB_VMS_CTLR A \r\n";
  352. #else
  353. sQry = "SELECT A.*, \r\n"
  354. " B.VMS_WDTH AS FORMW, \r\n"
  355. " B.VMS_HGHT AS FORMH, \r\n"
  356. " B.MODL_ROW_NUM AS MODV, \r\n"
  357. " B.MODL_COL_NUM AS MODH \r\n"
  358. " FROM TB_VMS_CTLR A, TB_VMS_TYPE B \r\n"
  359. " WHERE A.DEL_YN = 'N' \r\n"
  360. " AND A.VMS_TYPE_CD = B.VMS_TYPE_CD \r\n";
  361. #endif
  362. try
  363. {
  364. FLists.Lock();
  365. try
  366. {
  367. pADO = new TADOQuery(NULL);
  368. pADO->Close();
  369. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  370. pADO->SQL->Clear();
  371. pADO->SQL->Text = sQry;
  372. pADO->Open();
  373. for( ; !pADO->Eof; pADO->Next())
  374. {
  375. TVmsCtlr *pObj = new TVmsCtlr();
  376. pObj->VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsInteger;
  377. pObj->VMS_ID = pADO->FieldByName("VMS_ID")->AsString;
  378. pObj->VMS_CTLR_ID = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  379. pObj->VMS_NM = pADO->FieldByName("VMS_NM")->AsString;
  380. pObj->VMS_CTLR_IP = pADO->FieldByName("VMS_CTLR_IP")->AsString;
  381. pObj->VMS_CMNC_PORT = pADO->FieldByName("VMS_CMNC_PORT")->AsString;
  382. pObj->VMS_USAG_TYPE_CD = pADO->FieldByName("VMS_USAG_TYPE_CD")->AsString;
  383. pObj->VMS_FRM_TYPE_CD = pADO->FieldByName("VMS_FRM_TYPE_CD")->AsString;
  384. pObj->VMS_TYPE_CD = pADO->FieldByName("VMS_TYPE_CD")->AsString;
  385. pObj->VMS_MODL_TYPE_CD = pADO->FieldByName("VMS_MODL_TYPE_CD")->AsString;
  386. pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString;
  387. pObj->VMS_CMNC_ERR_BASS_VAL = pADO->FieldByName("VMS_CMNC_ERR_BASS_VAL")->AsInteger;
  388. pObj->VMS_NGHT_BRGH_STEP = pADO->FieldByName("VMS_NGHT_BRGH_STEP")->AsInteger;
  389. pObj->VMS_WEEK_BRGH_STEP = pADO->FieldByName("VMS_WEEK_BRGH_STEP")->AsInteger;
  390. pObj->VMS_PHSE_CHNG_CYCL = pADO->FieldByName("VMS_PHSE_CHNG_CYCL")->AsInteger;
  391. pObj->VMS_MODL_ERR_RATE = pADO->FieldByName("VMS_MODL_ERR_RATE")->AsInteger;
  392. pObj->VMS_MODL_CHK_CYCL = pADO->FieldByName("VMS_MODL_CHK_CYCL")->AsInteger;
  393. pObj->CMNCFAIL_SLOT_NMBR = pADO->FieldByName("CMNCFAIL_SLOT_NMBR")->AsInteger;
  394. pObj->PWER_FAIL_SLOT_NMBR = pADO->FieldByName("PWER_FAIL_SLOT_NMBR")->AsInteger;
  395. pObj->CMTRINFR_CNCT_YN = pADO->FieldByName("CMTRINFR_CNCT_YN")->AsString;
  396. pObj->WTHRINFR_CNCT_YN = pADO->FieldByName("WTHRINFR_CNCT_YN")->AsString;
  397. pObj->ENVRINFR_CNCT_YN = pADO->FieldByName("ENVRINFR_CNCT_YN")->AsString;
  398. pObj->VMS_MAX_PHSE_NUM = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsInteger;
  399. pObj->FRST_REGR_NMBR = pADO->FieldByName("FRST_REGR_NMBR")->AsString;
  400. pObj->FRST_RGST_DT = pADO->FieldByName("FRST_RGST_DT")->AsString;
  401. pObj->LAST_CRPR_NMBR = pADO->FieldByName("LAST_CRPR_NMBR")->AsString;
  402. pObj->LAST_CRCT_DT = pADO->FieldByName("LAST_CRCT_DT")->AsString;
  403. pObj->PANL_ON_TIME = pADO->FieldByName("PANL_ON_TIME")->AsString;
  404. pObj->PANL_OFF_TIME = pADO->FieldByName("PANL_OFF_TIME")->AsString;
  405. pObj->PANL_PWER_MODE = pADO->FieldByName("PANL_PWER_MODE")->AsString;
  406. pObj->BRGH_MODE = pADO->FieldByName("BRGH_MODE")->AsString;
  407. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat;
  408. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat;
  409. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString;
  410. pObj->TRFC_STRG_USE_YN = pADO->FieldByName("TRFC_STRG_USE_YN")->AsString;
  411. pObj->VMS_LOC_IFSC_ID = pADO->FieldByName("VMS_LOC_IFSC_ID")->AsString;
  412. pObj->FAN_MTNS_TMPR = pADO->FieldByName("FAN_MTNS_TMPR")->AsString.Trim().ToIntDef(0);
  413. pObj->HETR_MTNS_TMPR = pADO->FieldByName("HETR_MTNS_TMPR")->AsString.Trim().ToIntDef(0);
  414. pObj->WEB_CMRA_IP = pADO->FieldByName("WEB_CMRA_IP")->AsString;
  415. pObj->WEB_CMRA_PORT = pADO->FieldByName("WEB_CMRA_PORT")->AsString.Trim().ToIntDef(0);
  416. pObj->WEB_CMRA_ID = pADO->FieldByName("WEB_CMRA_ID")->AsString;
  417. pObj->WEB_CMRA_PWD = pADO->FieldByName("WEB_CMRA_PWD")->AsString;
  418. pObj->WEB_CMRA_CMPY = pADO->FieldByName("WEB_CMRA_CMPY")->AsString;
  419. pObj->WEB_CMRA_MDL = pADO->FieldByName("WEB_CMRA_MDL")->AsString;
  420. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString;
  421. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  422. pObj->DEF_PHSE_CHNG_CYCL = pADO->FieldByName("DEF_PHSE_CHNG_CYCL")->AsInteger;
  423. pObj->WIDTH = pADO->FieldByName("FORMW")->AsInteger;
  424. pObj->HEIGHT = pADO->FieldByName("FORMH")->AsInteger;
  425. pObj->ModVerCnt = pADO->FieldByName("MODV")->AsInteger;
  426. pObj->ModHorCnt = pADO->FieldByName("MODH")->AsInteger;
  427. if (pObj->WIDTH > FMaxWidth) FMaxWidth = pObj->WIDTH;
  428. if (pObj->WIDTH < FMinWidth) FMinWidth = pObj->WIDTH;
  429. if (pObj->HEIGHT > FMaxHeight) FMaxHeight = pObj->HEIGHT;
  430. if (pObj->HEIGHT < FMinHeight) FMinHeight = pObj->HEIGHT;
  431. pObj->WSTATE.ScheduledMessageOperatingTime = pObj->VMS_PHSE_CHNG_CYCL; /* 필수 계획된 메시지의 동작시간(초) */
  432. pObj->WSTATE.ModuleOperatingTemperature = pObj->VMS_CMNC_ERR_BASS_VAL; /* 필수 모듈 전원이 꺼지는 온도값(℃) */
  433. pObj->WSTATE.FanOperatingTemperature = pObj->FAN_MTNS_TMPR; /* 필수 Fan 동작 기준 온도값(℃) */
  434. pObj->WSTATE.HeaterOperatingTemperature = pObj->HETR_MTNS_TMPR; /* 필수 Heater 동작 기준 온도값(℃) */
  435. pObj->WSTATE.ModuleBasicFailureRate = pObj->VMS_MODL_ERR_RATE; /* 선택 모듈 장애율 (한 개의 모듈을 장애로 처리하기 위한 픽셀의 백분율값) */
  436. FLists.Push(String(pObj->VMS_CTLR_NMBR), pObj);
  437. pObj->Completed = true;
  438. }
  439. }
  440. catch(EDatabaseError &E)
  441. {
  442. DBERRORMSG("TVmsCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  443. throw Exception(String(E.ClassName()) + E.Message);
  444. }
  445. catch(Exception &e)
  446. {
  447. DBERRORMSG("TVmsCtlrManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
  448. throw Exception(String(e.ClassName()) + e.Message);
  449. }
  450. }
  451. __finally
  452. {
  453. if (pADO)
  454. {
  455. pADO->Close();
  456. delete pADO;
  457. }
  458. FLists.UnLock();
  459. }
  460. return true;
  461. }
  462. //---------------------------------------------------------------------------
  463. bool TVmsCtlrManager::LoadVmsStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  464. {
  465. String sQry;
  466. TADOQuery *pADO = NULL;
  467. #if 0
  468. //CONN_STTS_CD
  469. 1 CMS0 CMS 정상 connected Y
  470. 2 CMS1 CMS 통신두절 Not connected Y
  471. 3 CMS2 CMS 정보없음 Y
  472. //COBXDOOR_OPEN_STTS_CD
  473. 1 CDS0 CDS 닫힘 a door closed Y
  474. 2 CDS1 CDS 열림 a door opened Y
  475. 3 CDS2 CDS 정보없음 Y
  476. 1 CRS0 CRS 가동 operated Y
  477. 2 CRS1 CRS 중지 stopped Y
  478. 1 CPS0 CPS ON Power On Y
  479. 2 CPS1 CPS OFF Power Off Y
  480. //HETR_STTS_CD
  481. 1 HTS0 HTS 가동 operated Y
  482. 2 HTS1 HTS 중지 stopped Y
  483. 3 HTS2 HTS 정보없음 Y
  484. //PWER_STTS_CD
  485. 1 PWS0 PWS 정상 normal Y
  486. 2 PWS1 PWS 오류 abnormal Y
  487. //FAN_STTS_CD
  488. 1 PAS0 PAS 가동 operated Y
  489. 2 PAS1 PAS 중지 stopped Y
  490. 3 PAS2 PAS 정보없음 Y
  491. //모듈
  492. 1 MOS0 MOS 정상 normal Y
  493. 2 MOS1 MOS 오류 abnormal Y
  494. #endif
  495. sQry = "SELECT * \r\n"
  496. " FROM TB_VMS_STTS_PRST A, TB_VMS_CTLR B \r\n"
  497. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  498. " AND A.RGST_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";
  499. try
  500. {
  501. TVmsCtlr *pObj = NULL;
  502. FLists.Lock();
  503. #if 0
  504. FOR_STL(TVmsCtlr*, pTmp, FLists)
  505. {
  506. pTmp->WSTATE.Comm = vms_error;
  507. VmsInitStatus(&pTmp->WSTATE);
  508. pTmp->RunState = state_error;
  509. }
  510. #endif
  511. try
  512. {
  513. int nORD;
  514. pADO = new TADOQuery(NULL);
  515. pADO->Close();
  516. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  517. pADO->SQL->Clear();
  518. pADO->SQL->Text = sQry;
  519. pADO->Open();
  520. //int nRows = pADO->RecordCount;
  521. for( ; !pADO->Eof; pADO->Next())
  522. {
  523. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  524. pObj = FLists.Find(sVmsNmbr);
  525. if (!pObj) continue;
  526. String RGST_DT = pADO->FieldByName("RGST_DT")->AsString;
  527. String CONN_STTS_CD = pADO->FieldByName("CONN_STTS_CD")->AsString;
  528. if (CONN_STTS_CD != "CMS0")
  529. {
  530. //통신장애
  531. continue;
  532. }
  533. pObj->WSTATE.Comm = vms_normal;
  534. String CBOXDOOR_OPEN_STTS_CD = pADO->FieldByName("CBOXDOOR_OPEN_STTS_CD")->AsString;
  535. if (CBOXDOOR_OPEN_STTS_CD == "CDS0") pObj->WSTATE.DoorStatus = vms_close;
  536. else if (CBOXDOOR_OPEN_STTS_CD == "CDS1") pObj->WSTATE.DoorStatus = vms_open;
  537. String PWER_STTS_CD = pADO->FieldByName("PWER_STTS_CD")->AsString;
  538. if (PWER_STTS_CD == "PWS0") pObj->WSTATE.ModulePowerStatus = vms_normal;
  539. else if (PWER_STTS_CD == "PWS1") pObj->WSTATE.ModulePowerStatus = vms_error;
  540. String CBOX_TMPR = pADO->FieldByName("CBOX_TMPR")->AsString;
  541. pObj->WSTATE.BodyTemp = CBOX_TMPR.ToIntDef(0);
  542. String CBOX_HMDT = pADO->FieldByName("CBOX_HMDT")->AsString;
  543. pObj->WSTATE.LuminanceStatus = CBOX_HMDT.ToIntDef(0);
  544. String FAN_STTS_CD = pADO->FieldByName("FAN_STTS_CD")->AsString;
  545. if (FAN_STTS_CD == "PAS0") pObj->WSTATE.FanStatus = vms_on;
  546. else if (FAN_STTS_CD == "PAS1") pObj->WSTATE.FanStatus = vms_off;
  547. String HETR_STTS_CD = pADO->FieldByName("HETR_STTS_CD")->AsString;
  548. if (HETR_STTS_CD == "HTS0") pObj->WSTATE.HeaterStatus = vms_on;
  549. else if (HETR_STTS_CD == "HTS1") pObj->WSTATE.HeaterStatus = vms_off;
  550. String CBOXFAN_STTS_CD = pADO->FieldByName("CBOXFAN_STTS_CD")->AsString;
  551. if (CBOXFAN_STTS_CD == "MOS0") pObj->WSTATE.ModuleState = vms_normal;
  552. else if (CBOXFAN_STTS_CD == "MOS1") pObj->WSTATE.ModuleState = vms_error;
  553. //String CBOXHETR_STTS_CD = pADO->FieldByName("CBOXHETR_STTS_CD")->AsString;
  554. //String VMS_TMPR = pADO->FieldByName("VMS_TMPR")->AsString;
  555. //String MODL_STTS = pADO->FieldByName("MODL_STTS")->AsString;
  556. //String PWER_STTS = pADO->FieldByName("PWER_STTS")->AsString;
  557. pObj->CheckRunState();
  558. #if 0
  559. BYTE Comm; /* 유선통신상태, 0:정상 1:장애 */
  560. BYTE ModuleHorizontal; /* 가로 모듈수 */
  561. BYTE ModuleVertical; /* 세로 모듈수 */
  562. BYTE ModuleStatus[INT_VMS_MAX_MODULE_BIT]; /* 모듈 개별 상태, 0:정상 1:장애 2:알수없음 */
  563. BYTE PowerCount; /* 전원 갯수 */
  564. BYTE PowerStatus[INT_VMS_MAX_POWER_BIT]; /* 전원 개별 상태, 0:켜짐 1:꺼짐 2:알수없음 */
  565. #endif
  566. }
  567. }
  568. catch(EDatabaseError &E)
  569. {
  570. DBERRORLOG("TVmsCtlrManager::LoadVmsStatusFromDb", String(E.ClassName()), E.Message, sQry);
  571. throw Exception(String(E.ClassName()) + E.Message);
  572. }
  573. catch(Exception &e)
  574. {
  575. DBERRORLOG("TVmsCtlrManager::LoadVmsStatusFromDb", String(e.ClassName()), e.Message, sQry);
  576. throw Exception(String(e.ClassName()) + e.Message);
  577. }
  578. }
  579. __finally
  580. {
  581. if (pADO)
  582. {
  583. pADO->Close();
  584. delete pADO;
  585. }
  586. FLists.UnLock();
  587. }
  588. return true;
  589. }
  590. //---------------------------------------------------------------------------
  591. bool TVmsCtlrManager::DeleteVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  592. {
  593. String sQry;
  594. TADOQuery *pADO = NULL;
  595. sQry = "UPDATE TB_VMS_CTLR \r\n"
  596. " SET DEL_YN = 'Y' \r\n"
  597. " WHERE VMS_CTLR_NMBR = :p01 \r\n";
  598. try
  599. {
  600. try
  601. {
  602. pADO = new TADOQuery(NULL);
  603. pADO->Close();
  604. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  605. pADO->SQL->Clear();
  606. pADO->SQL->Text = sQry;
  607. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  608. pADO->ExecSQL();
  609. #if 0
  610. sQry = "UPDATE TB_FCLT_INFR \r\n"
  611. " SET DEL_YN = 'Y' \r\n"
  612. " WHERE FCLT_ID = :p01 \r\n";
  613. #else
  614. sQry = "DELETE TB_FCLT_INFR \r\n"
  615. " WHERE FCLT_ID = :p01 \r\n";
  616. //" AND FCLT_TYPE = 'DSRC' \r\n";
  617. #endif
  618. pADO->SQL->Clear();
  619. pADO->SQL->Text = sQry;
  620. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  621. pADO->ExecSQL();
  622. return true;
  623. }
  624. catch(EDatabaseError &E)
  625. {
  626. DBERRORLOG("TVmsCtlrManager::DeleteVms", String(E.ClassName()), E.Message, sQry);
  627. throw Exception(String(E.ClassName()) + E.Message);
  628. }
  629. catch(Exception &e)
  630. {
  631. DBERRORLOG("TVmsCtlrManager::DeleteVms", String(e.ClassName()), e.Message, sQry);
  632. throw Exception(String(e.ClassName()) + e.Message);
  633. }
  634. }
  635. __finally
  636. {
  637. if (pADO)
  638. {
  639. pADO->Close();
  640. delete pADO;
  641. }
  642. }
  643. return true;
  644. }
  645. //---------------------------------------------------------------------------
  646. bool TVmsCtlrManager::InsertVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  647. {
  648. String sQry;
  649. TADOQuery *pADO = NULL;
  650. sQry = "INSERT INTO TB_VMS_CTLR \r\n"
  651. " (VMS_CTLR_NMBR, \r\n"
  652. " VMS_ID, \r\n"
  653. " VMS_CTLR_ID, \r\n"
  654. " VMS_NM, \r\n"
  655. " VMS_USAG_TYPE_CD, \r\n"
  656. " VMS_TYPE_CD, \r\n"
  657. " X_CRDN, \r\n"
  658. " Y_CRDN, \r\n"
  659. " VMS_CTLR_IP, \r\n"
  660. " PANL_ON_TIME, \r\n"
  661. " PANL_OFF_TIME, \r\n"
  662. " WEB_CMRA_IP, \r\n"
  663. " WEB_CMRA_PORT, \r\n"
  664. " WEB_CMRA_ID, \r\n"
  665. " WEB_CMRA_PWD, \r\n"
  666. " STRM_SESN_NM, \r\n"
  667. " FRST_REGR_NMBR, \r\n"
  668. " FRST_RGST_DT, \r\n"
  669. " LAST_CRPR_NMBR, \r\n"
  670. " LAST_CRCT_DT, \r\n"
  671. " VMS_CMNC_PORT, \r\n"
  672. " VMS_MAX_PHSE_NUM, \r\n" //= 16; //VMS 최대 표출면 개수
  673. " VMS_PHSE_CHNG_CYCL, \r\n" //= 5; //VMS 표출면 변경 주기(계획된 메시지의 동작시간(초))
  674. " VMS_CMNC_ERR_BASS_VAL, \r\n" //= 127; //VMS 통신 오류 기본 값(모듈 전원이 꺼지는 온도값(℃))
  675. " FAN_MTNS_TMPR, \r\n" //= 35; //팬동작온도
  676. " HETR_MTNS_TMPR, \r\n" //= 0; //히터동작온도
  677. " VMS_MODL_ERR_RATE, \r\n"
  678. " OPER_MODE ) \r\n" // = 20; //모듈장애율(Options)
  679. " VALUES (:p01, \r\n"
  680. " :p02, \r\n"
  681. " :p03, \r\n"
  682. " :p04, \r\n"
  683. " :p05, \r\n"
  684. " :p06, \r\n"
  685. " :p07, \r\n"
  686. " :p08, \r\n"
  687. " :p09, \r\n"
  688. " :p10, \r\n"
  689. " :p11, \r\n"
  690. " :p12, \r\n"
  691. " :p13, \r\n"
  692. " :p14, \r\n"
  693. " :p15, \r\n"
  694. " :p16, \r\n"
  695. " :p17, \r\n"
  696. " :p18, \r\n"
  697. " :p19, \r\n"
  698. " :p20, \r\n"
  699. " :p21, \r\n"
  700. " :p22, \r\n"
  701. " :p23, \r\n"
  702. " :p24, \r\n"
  703. " :p25, \r\n"
  704. " :p26, \r\n"
  705. " :p27, \r\n"
  706. " :p28) \r\n";
  707. try
  708. {
  709. try
  710. {
  711. pADO = new TADOQuery(NULL);
  712. pADO->Close();
  713. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  714. pADO->SQL->Clear();
  715. pADO->SQL->Text = sQry;
  716. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  717. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_ID;
  718. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_CTLR_ID;
  719. pADO->Parameters->ParamByName("p04")->Value = AObj->VMS_NM;
  720. pADO->Parameters->ParamByName("p05")->Value = AObj->VMS_USAG_TYPE_CD;
  721. pADO->Parameters->ParamByName("p06")->Value = AObj->VMS_TYPE_CD;
  722. pADO->Parameters->ParamByName("p07")->Value = AObj->X_CRDN;
  723. pADO->Parameters->ParamByName("p08")->Value = AObj->Y_CRDN;
  724. pADO->Parameters->ParamByName("p09")->Value = AObj->VMS_CTLR_IP;
  725. pADO->Parameters->ParamByName("p10")->Value = AObj->PANL_ON_TIME;
  726. pADO->Parameters->ParamByName("p11")->Value = AObj->PANL_OFF_TIME;
  727. pADO->Parameters->ParamByName("p12")->Value = AObj->WEB_CMRA_IP;
  728. pADO->Parameters->ParamByName("p13")->Value = AObj->WEB_CMRA_PORT;
  729. pADO->Parameters->ParamByName("p14")->Value = AObj->WEB_CMRA_ID;
  730. pADO->Parameters->ParamByName("p15")->Value = AObj->WEB_CMRA_PWD;
  731. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_SESN_NM;
  732. pADO->Parameters->ParamByName("p17")->Value = AObj->FRST_REGR_NMBR;
  733. pADO->Parameters->ParamByName("p18")->Value = AObj->FRST_RGST_DT;
  734. pADO->Parameters->ParamByName("p19")->Value = AObj->LAST_CRPR_NMBR;
  735. pADO->Parameters->ParamByName("p20")->Value = AObj->LAST_CRCT_DT;
  736. pADO->Parameters->ParamByName("p21")->Value = AObj->VMS_CMNC_PORT;
  737. pADO->Parameters->ParamByName("p22")->Value = AObj->VMS_MAX_PHSE_NUM;
  738. pADO->Parameters->ParamByName("p23")->Value = AObj->VMS_PHSE_CHNG_CYCL;
  739. pADO->Parameters->ParamByName("p24")->Value = AObj->VMS_CMNC_ERR_BASS_VAL;
  740. pADO->Parameters->ParamByName("p25")->Value = AObj->FAN_MTNS_TMPR;
  741. pADO->Parameters->ParamByName("p26")->Value = AObj->HETR_MTNS_TMPR;
  742. pADO->Parameters->ParamByName("p27")->Value = AObj->VMS_MODL_ERR_RATE;
  743. pADO->Parameters->ParamByName("p28")->Value = AObj->OPER_MODE;
  744. pADO->ExecSQL();
  745. return MergeFcltInfo(AObj, ADbConn);
  746. }
  747. catch(EDatabaseError &E)
  748. {
  749. DBERRORLOG("TVmsCtlrManager::InsertVms", String(E.ClassName()), E.Message, sQry);
  750. throw Exception(String(E.ClassName()) + E.Message);
  751. }
  752. catch(Exception &e)
  753. {
  754. DBERRORLOG("TVmsCtlrManager::InsertVms", String(e.ClassName()), e.Message, sQry);
  755. throw Exception(String(e.ClassName()) + e.Message);
  756. }
  757. }
  758. __finally
  759. {
  760. if (pADO)
  761. {
  762. pADO->Close();
  763. delete pADO;
  764. }
  765. }
  766. return true;
  767. }
  768. //---------------------------------------------------------------------------
  769. bool TVmsCtlrManager::UpdateVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  770. {
  771. return MergeVms(AObj, ADbConn);
  772. }
  773. //---------------------------------------------------------------------------
  774. bool TVmsCtlrManager::MergeVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  775. {
  776. String sQry;
  777. TADOQuery *pADO = NULL;
  778. sQry = "MERGE INTO TB_VMS_CTLR L \r\n"
  779. "USING (SELECT :p01 AS VMS_CTLR_NMBR, \r\n"
  780. " :p02 AS VMS_ID, \r\n"
  781. " :p03 AS VMS_CTLR_ID, \r\n"
  782. " :p04 AS VMS_NM, \r\n"
  783. " :p05 AS VMS_USAG_TYPE_CD, \r\n"
  784. " :p06 AS VMS_TYPE_CD, \r\n"
  785. " :p07 AS X_CRDN, \r\n"
  786. " :p08 AS Y_CRDN, \r\n"
  787. " :p09 AS VMS_CTLR_IP, \r\n"
  788. " :p10 AS PANL_ON_TIME, \r\n"
  789. " :p11 AS PANL_OFF_TIME, \r\n"
  790. " :p12 AS WEB_CMRA_IP, \r\n"
  791. " :p13 AS WEB_CMRA_PORT, \r\n"
  792. " :p14 AS WEB_CMRA_ID, \r\n"
  793. " :p15 AS WEB_CMRA_PWD, \r\n"
  794. " :p16 AS STRM_SESN_NM, \r\n"
  795. " :p17 AS FRST_REGR_NMBR, \r\n"
  796. " :p18 AS FRST_RGST_DT, \r\n"
  797. " :p19 AS LAST_CRPR_NMBR, \r\n"
  798. " :p20 AS LAST_CRCT_DT, \r\n"
  799. " :p21 AS VMS_CMNC_PORT, \r\n"
  800. " :p22 AS VMS_MAX_PHSE_NUM \r\n"
  801. " FROM DUAL) M \r\n"
  802. " ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR) \r\n"
  803. "WHEN MATCHED \r\n"
  804. "THEN \r\n"
  805. " UPDATE SET L.VMS_ID = M.VMS_ID, \r\n"
  806. " L.VMS_CTLR_ID = M.VMS_CTLR_ID, \r\n"
  807. " L.VMS_NM = M.VMS_NM, \r\n"
  808. " L.VMS_USAG_TYPE_CD = M.VMS_USAG_TYPE_CD, \r\n"
  809. " L.VMS_TYPE_CD = M.VMS_TYPE_CD, \r\n"
  810. " L.X_CRDN = M.X_CRDN, \r\n"
  811. " L.Y_CRDN = M.Y_CRDN, \r\n"
  812. " L.VMS_CTLR_IP = M.VMS_CTLR_IP, \r\n"
  813. " L.PANL_ON_TIME = M.PANL_ON_TIME, \r\n"
  814. " L.PANL_OFF_TIME = M.PANL_OFF_TIME, \r\n"
  815. " L.WEB_CMRA_IP = M.WEB_CMRA_IP, \r\n"
  816. " L.WEB_CMRA_PORT = M.WEB_CMRA_PORT, \r\n"
  817. " L.WEB_CMRA_ID = M.WEB_CMRA_ID, \r\n"
  818. " L.WEB_CMRA_PWD = M.WEB_CMRA_PWD, \r\n"
  819. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  820. " L.FRST_REGR_NMBR = M.FRST_REGR_NMBR, \r\n"
  821. " L.FRST_RGST_DT = M.FRST_RGST_DT, \r\n"
  822. " L.LAST_CRPR_NMBR = M.LAST_CRPR_NMBR, \r\n"
  823. " L.LAST_CRCT_DT = M.LAST_CRCT_DT, \r\n"
  824. " L.VMS_CMNC_PORT = M.VMS_CMNC_PORT, \r\n"
  825. " L.VMS_MAX_PHSE_NUM = M.VMS_MAX_PHSE_NUM \r\n"
  826. "WHEN NOT MATCHED \r\n"
  827. "THEN \r\n"
  828. " INSERT (VMS_CTLR_NMBR, \r\n"
  829. " VMS_ID, \r\n"
  830. " VMS_CTLR_ID, \r\n"
  831. " VMS_NM, \r\n"
  832. " VMS_USAG_TYPE_CD, \r\n"
  833. " VMS_TYPE_CD, \r\n"
  834. " X_CRDN, \r\n"
  835. " Y_CRDN, \r\n"
  836. " VMS_CTLR_IP, \r\n"
  837. " PANL_ON_TIME, \r\n"
  838. " PANL_OFF_TIME, \r\n"
  839. " WEB_CMRA_IP, \r\n"
  840. " WEB_CMRA_PORT, \r\n"
  841. " WEB_CMRA_ID, \r\n"
  842. " WEB_CMRA_PWD, \r\n"
  843. " STRM_SESN_NM, \r\n"
  844. " FRST_REGR_NMBR, \r\n"
  845. " FRST_RGST_DT, \r\n"
  846. " LAST_CRPR_NMBR, \r\n"
  847. " LAST_CRCT_DT, \r\n"
  848. " VMS_CMNC_PORT, \r\n"
  849. " VMS_MAX_PHSE_NUM ) \r\n"
  850. " VALUES (M.VMS_CTLR_NMBR, \r\n"
  851. " M.VMS_ID, \r\n"
  852. " M.VMS_CTLR_ID, \r\n"
  853. " M.VMS_NM, \r\n"
  854. " M.VMS_USAG_TYPE_CD, \r\n"
  855. " M.VMS_TYPE_CD, \r\n"
  856. " M.X_CRDN, \r\n"
  857. " M.Y_CRDN, \r\n"
  858. " M.VMS_CTLR_IP, \r\n"
  859. " M.PANL_ON_TIME, \r\n"
  860. " M.PANL_OFF_TIME, \r\n"
  861. " M.WEB_CMRA_IP, \r\n"
  862. " M.WEB_CMRA_PORT, \r\n"
  863. " M.WEB_CMRA_ID, \r\n"
  864. " M.WEB_CMRA_PWD, \r\n"
  865. " M.STRM_SESN_NM, \r\n"
  866. " M.FRST_REGR_NMBR, \r\n"
  867. " M.FRST_RGST_DT, \r\n"
  868. " M.LAST_CRPR_NMBR, \r\n"
  869. " M.LAST_CRCT_DT, \r\n"
  870. " M.VMS_CMNC_PORT, \r\n"
  871. " M.VMS_MAX_PHSE_NUM ) \r\n";
  872. try
  873. {
  874. try
  875. {
  876. pADO = new TADOQuery(NULL);
  877. pADO->Close();
  878. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  879. pADO->SQL->Clear();
  880. pADO->SQL->Text = sQry;
  881. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  882. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_ID;
  883. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_CTLR_ID;
  884. pADO->Parameters->ParamByName("p04")->Value = AObj->VMS_NM;
  885. pADO->Parameters->ParamByName("p05")->Value = AObj->VMS_USAG_TYPE_CD;
  886. pADO->Parameters->ParamByName("p06")->Value = AObj->VMS_TYPE_CD;
  887. pADO->Parameters->ParamByName("p07")->Value = AObj->X_CRDN;
  888. pADO->Parameters->ParamByName("p08")->Value = AObj->Y_CRDN;
  889. pADO->Parameters->ParamByName("p09")->Value = AObj->VMS_CTLR_IP;
  890. pADO->Parameters->ParamByName("p10")->Value = AObj->PANL_ON_TIME;
  891. pADO->Parameters->ParamByName("p11")->Value = AObj->PANL_OFF_TIME;
  892. pADO->Parameters->ParamByName("p12")->Value = AObj->WEB_CMRA_IP;
  893. pADO->Parameters->ParamByName("p13")->Value = AObj->WEB_CMRA_PORT;
  894. pADO->Parameters->ParamByName("p14")->Value = AObj->WEB_CMRA_ID;
  895. pADO->Parameters->ParamByName("p15")->Value = AObj->WEB_CMRA_PWD;
  896. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_SESN_NM;
  897. pADO->Parameters->ParamByName("p17")->Value = AObj->FRST_REGR_NMBR;
  898. pADO->Parameters->ParamByName("p18")->Value = AObj->FRST_RGST_DT;
  899. pADO->Parameters->ParamByName("p19")->Value = AObj->LAST_CRPR_NMBR;
  900. pADO->Parameters->ParamByName("p20")->Value = AObj->LAST_CRCT_DT;
  901. pADO->Parameters->ParamByName("p21")->Value = AObj->VMS_CMNC_PORT;
  902. pADO->Parameters->ParamByName("p22")->Value = AObj->VMS_MAX_PHSE_NUM;
  903. pADO->ExecSQL();
  904. return MergeFcltInfo(AObj, ADbConn);
  905. }
  906. catch(EDatabaseError &E)
  907. {
  908. DBERRORLOG("TVmsCtlrManager::MergeVms", String(E.ClassName()), E.Message, sQry);
  909. throw Exception(String(E.ClassName()) + E.Message);
  910. }
  911. catch(Exception &e)
  912. {
  913. DBERRORLOG("TVmsCtlrManager::MergeVms", String(e.ClassName()), e.Message, sQry);
  914. throw Exception(String(e.ClassName()) + e.Message);
  915. }
  916. }
  917. __finally
  918. {
  919. if (pADO)
  920. {
  921. pADO->Close();
  922. delete pADO;
  923. }
  924. }
  925. return true;
  926. }
  927. //---------------------------------------------------------------------------
  928. bool TVmsCtlrManager::MergeFcltInfo(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  929. {
  930. String sQry;
  931. TADOQuery *pADO = NULL;
  932. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  933. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  934. " :p02 AS FCLT_TYPE, \r\n"
  935. " :p03 AS FCLT_LCTN \r\n"
  936. " FROM DUAL) M \r\n"
  937. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  938. "WHEN MATCHED \r\n"
  939. "THEN \r\n"
  940. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  941. " L.DEL_YN = 'N' \r\n"
  942. "WHEN NOT MATCHED \r\n"
  943. "THEN \r\n"
  944. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  945. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  946. try
  947. {
  948. try
  949. {
  950. pADO = new TADOQuery(NULL);
  951. pADO->Close();
  952. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  953. pADO->SQL->Clear();
  954. pADO->SQL->Text = sQry;
  955. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  956. pADO->Parameters->ParamByName("p02")->Value = "VMS";
  957. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  958. pADO->ExecSQL();
  959. return true;
  960. }
  961. catch(EDatabaseError &E)
  962. {
  963. DBERRORLOG("TVmsCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  964. throw Exception(String(E.ClassName()) + E.Message);
  965. }
  966. catch(Exception &e)
  967. {
  968. DBERRORLOG("TVmsCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  969. throw Exception(String(e.ClassName()) + e.Message);
  970. }
  971. }
  972. __finally
  973. {
  974. if (pADO)
  975. {
  976. pADO->Close();
  977. delete pADO;
  978. }
  979. }
  980. return true;
  981. }
  982. //---------------------------------------------------------------------------
  983. bool TVmsCtlrManager::GetNextVmsId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  984. {
  985. String sQry;
  986. TADOQuery *pADO = NULL;
  987. sQry = "SELECT NVL(MAX(VMS_CTLR_NMBR), 10000) + 1 AS NEWID FROM TB_VMS_CTLR \r\n";
  988. try
  989. {
  990. try
  991. {
  992. pADO = new TADOQuery(NULL);
  993. pADO->Close();
  994. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  995. pADO->SQL->Clear();
  996. pADO->SQL->Text = sQry;
  997. pADO->Open();
  998. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  999. AId = ANmbr / 10000;
  1000. return true;
  1001. }
  1002. catch(EDatabaseError &E)
  1003. {
  1004. DBERRORLOG("VmsCtlrManager::GetNextVmsId", String(E.ClassName()), E.Message, sQry);
  1005. throw Exception(String(E.ClassName()) + E.Message);
  1006. }
  1007. catch(Exception &e)
  1008. {
  1009. DBERRORLOG("VmsCtlrManager::GetNextVmsId", String(e.ClassName()), e.Message, sQry);
  1010. throw Exception(String(e.ClassName()) + e.Message);
  1011. }
  1012. }
  1013. __finally
  1014. {
  1015. if (pADO)
  1016. {
  1017. pADO->Close();
  1018. delete pADO;
  1019. }
  1020. }
  1021. return false;
  1022. }
  1023. //---------------------------------------------------------------------------
  1024. bool TVmsCtlrManager::UpdateCtlrInfo(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1025. {
  1026. String sQry;
  1027. TADOQuery *pADO = NULL;
  1028. sQry = "UPDATE TB_VMS_CTLR \r\n"
  1029. " SET PANL_ON_TIME = :p01, \r\n"
  1030. " PANL_OFF_TIME = :p02, \r\n"
  1031. " LAST_CRPR_NMBR = :p03, \r\n"
  1032. " LAST_CRCT_DT = :p04 \r\n"
  1033. " WHERE DEL_YN = 'N' \r\n";
  1034. try
  1035. {
  1036. try
  1037. {
  1038. pADO = new TADOQuery(NULL);
  1039. pADO->Close();
  1040. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1041. pADO->SQL->Clear();
  1042. pADO->SQL->Text = sQry;
  1043. pADO->Parameters->ParamByName("p01")->Value = AObj->PANL_ON_TIME;
  1044. pADO->Parameters->ParamByName("p02")->Value = AObj->PANL_OFF_TIME;
  1045. pADO->Parameters->ParamByName("p03")->Value = AObj->LAST_CRPR_NMBR;
  1046. pADO->Parameters->ParamByName("p04")->Value = AObj->LAST_CRCT_DT;
  1047. pADO->ExecSQL();
  1048. return true;
  1049. }
  1050. catch(EDatabaseError &E)
  1051. {
  1052. DBERRORLOG("TVmsCtlrManager::UpdateCtlrInfo", String(E.ClassName()), E.Message, sQry);
  1053. throw Exception(String(E.ClassName()) + E.Message);
  1054. }
  1055. catch(Exception &e)
  1056. {
  1057. DBERRORLOG("TVmsCtlrManager::UpdateCtlrInfo", String(e.ClassName()), e.Message, sQry);
  1058. throw Exception(String(e.ClassName()) + e.Message);
  1059. }
  1060. }
  1061. __finally
  1062. {
  1063. if (pADO)
  1064. {
  1065. pADO->Close();
  1066. delete pADO;
  1067. }
  1068. }
  1069. return true;
  1070. }
  1071. //---------------------------------------------------------------------------
  1072. bool TVmsCtlrManager::LoadIfscRltn(TADOConnection *ADbConn/*=NULL*/)
  1073. {
  1074. String sQry;
  1075. TADOQuery *pADO = NULL;
  1076. try
  1077. {
  1078. FLists.Lock();
  1079. FOR_STL(TVmsCtlr*, pObj, FLists)
  1080. {
  1081. pObj->FIfscRltn.RemoveAll();
  1082. }
  1083. }
  1084. __finally
  1085. {
  1086. FLists.UnLock();
  1087. }
  1088. sQry = "SELECT A.VMS_CTLR_NMBR, B.VMS_IFSC_ID, B.DSPL_PRRT \r\n"
  1089. " FROM TB_VMS_CTLR A, \r\n"
  1090. " TB_VMS_IFSC_RLTN B, \r\n"
  1091. " TB_VMS_IFSC C \r\n"
  1092. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  1093. " AND B.VMS_IFSC_ID = C.VMS_IFSC_ID \r\n"
  1094. " ORDER BY A.VMS_CTLR_NMBR, B.DSPL_PRRT \r\n";
  1095. try
  1096. {
  1097. int VMS_CTLR_NMBR;
  1098. FLists.Lock();
  1099. try
  1100. {
  1101. pADO = new TADOQuery(NULL);
  1102. pADO->Close();
  1103. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1104. pADO->SQL->Clear();
  1105. pADO->SQL->Text = sQry;
  1106. pADO->Open();
  1107. for( ; !pADO->Eof; pADO->Next())
  1108. {
  1109. VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsInteger;
  1110. TVmsCtlr *pVms = FLists.Find(String(VMS_CTLR_NMBR));
  1111. if (!pVms) continue;
  1112. TVmsIfscRltn *pObj = new TVmsIfscRltn();
  1113. if (pObj)
  1114. {
  1115. pObj->VMS_CTLR_NMBR = VMS_CTLR_NMBR;
  1116. pObj->VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsInteger;
  1117. pObj->DSPL_PRRT = pADO->FieldByName("DSPL_PRRT")->AsInteger;
  1118. pVms->FIfscRltn.Push(pObj->DSPL_PRRT, pObj);
  1119. }
  1120. }
  1121. }
  1122. catch(EDatabaseError &E)
  1123. {
  1124. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(E.ClassName()), E.Message, sQry);
  1125. throw Exception(String(E.ClassName()) + E.Message);
  1126. }
  1127. catch(Exception &e)
  1128. {
  1129. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(e.ClassName()), e.Message, sQry);
  1130. throw Exception(String(e.ClassName()) + e.Message);
  1131. }
  1132. }
  1133. __finally
  1134. {
  1135. if (pADO)
  1136. {
  1137. pADO->Close();
  1138. delete pADO;
  1139. }
  1140. FLists.UnLock();
  1141. }
  1142. return true;
  1143. }
  1144. //---------------------------------------------------------------------------
  1145. bool TVmsCtlrManager::SaveIfscRltn(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1146. {
  1147. String sQry;
  1148. TADOQuery *pADO = NULL;
  1149. int ii;
  1150. try
  1151. {
  1152. try
  1153. {
  1154. pADO = new TADOQuery(NULL);
  1155. pADO->Close();
  1156. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1157. sQry = "DELETE FROM TB_VMS_IFSC_RLTN WHERE VMS_CTLR_NMBR = :p01";
  1158. pADO->SQL->Clear();
  1159. pADO->SQL->Text = sQry;
  1160. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  1161. pADO->ExecSQL();
  1162. sQry = "INSERT INTO TB_VMS_IFSC_RLTN(VMS_CTLR_NMBR, VMS_IFSC_ID, DSPL_PRRT) VALUES(:p01, :p02, :p03)";
  1163. ii = 0;
  1164. pADO->SQL->Clear();
  1165. pADO->SQL->Text = sQry;
  1166. FOR_STL(TVmsIfscRltn *, pLink, AObj->FIfscRltn)
  1167. {
  1168. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  1169. pADO->Parameters->ParamByName("p02")->Value = pLink->VMS_IFSC_ID;
  1170. pADO->Parameters->ParamByName("p03")->Value = String(ii+1);
  1171. pADO->ExecSQL();
  1172. ii++;
  1173. }
  1174. return true;
  1175. }
  1176. catch(EDatabaseError &E)
  1177. {
  1178. DBERRORLOG("TVmsCtlrManager::SaveIfscRltn", String(E.ClassName()), E.Message, sQry);
  1179. throw Exception(String(E.ClassName()) + E.Message);
  1180. }
  1181. catch(Exception &e)
  1182. {
  1183. DBERRORLOG("TVmsCtlrManager::SaveIfscRltn", String(e.ClassName()), e.Message, sQry);
  1184. throw Exception(String(e.ClassName()) + e.Message);
  1185. }
  1186. }
  1187. __finally
  1188. {
  1189. if (pADO)
  1190. {
  1191. pADO->Close();
  1192. delete pADO;
  1193. }
  1194. }
  1195. return true;
  1196. }
  1197. //---------------------------------------------------------------------------
  1198. bool TVmsCtlrManager::LoadVmsMsg(TADOConnection *ADbConn/*=NULL*/)
  1199. {
  1200. String sQry;
  1201. TADOQuery *pADO = NULL;
  1202. sQry = "SELECT A.VMS_CTLR_NMBR, A.PHASE, A.DSPL_HH, A.DNLD_YN, \r\n"
  1203. " A.VMS_MSG_DSPL_MTHD_CD, A.TRFC_SITU_TYPE_CD, A.DSPL_DT, \r\n"
  1204. " TO_CHAR(SYSDATE - 6/1440, 'YYYYMMDDHH24MISS') AS SVC_DT, \r\n"
  1205. " A.VMS_DSPL_MSG_IMAG \r\n"
  1206. " FROM TB_VMS_DSPL_PRST A, \r\n"
  1207. " (SELECT VMS_CTLR_NMBR, MAX(DSPL_DT) AS DSPL_DT \r\n"
  1208. " FROM TB_VMS_DSPL_PRST \r\n"
  1209. " GROUP BY VMS_CTLR_NMBR) B \r\n"
  1210. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  1211. " AND A.DSPL_DT = B.DSPL_DT \r\n"
  1212. " ORDER BY A.VMS_CTLR_NMBR, A.PHASE \r\n";
  1213. try
  1214. {
  1215. FLists.Lock();
  1216. FOR_STL(TVmsCtlr*, pTmpObj, FLists)
  1217. {
  1218. pTmpObj->Lock();
  1219. pTmpObj->VmsMsg->Init();
  1220. pTmpObj->UnLock();
  1221. }
  1222. }
  1223. __finally
  1224. {
  1225. FLists.UnLock();
  1226. }
  1227. TVmsCtlr *pObj = NULL;
  1228. String sOldVmsNmbr = "";
  1229. int nPhase = 0;
  1230. try
  1231. {
  1232. try
  1233. {
  1234. pADO = new TADOQuery(NULL);
  1235. pADO->Close();
  1236. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1237. pADO->SQL->Clear();
  1238. pADO->SQL->Text = sQry;
  1239. pADO->Open();
  1240. for( ; !pADO->Eof; pADO->Next())
  1241. {
  1242. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsInteger;
  1243. if (sVmsNmbr != sOldVmsNmbr)
  1244. {
  1245. if (pObj)
  1246. {
  1247. pObj->VmsMsg->Total = nPhase;
  1248. pObj->VmsMsg->Curr = 0;
  1249. pObj->UnLock();
  1250. }
  1251. pObj = FLists.Find(sVmsNmbr);
  1252. if (pObj)
  1253. {
  1254. pObj->Lock();
  1255. nPhase = 0;
  1256. sOldVmsNmbr = sVmsNmbr;
  1257. }
  1258. else continue;
  1259. }
  1260. if (!pObj) continue;
  1261. if (nPhase >= INT_MAX_VMS_FORM) continue;
  1262. SAFE_DELETE(FImgStream);
  1263. FImgStream = pADO->CreateBlobStream(pADO->FieldByName("VMS_DSPL_MSG_IMAG"), bmRead);
  1264. if (FImgStream && FImgStream->Size > 0)
  1265. {
  1266. try
  1267. {
  1268. if (!pObj->VmsMsg->PHASE[nPhase].pVmsBmp)
  1269. {
  1270. pObj->VmsMsg->PHASE[nPhase].pVmsBmp = new Graphics::TBitmap();
  1271. }
  1272. pObj->VmsMsg->PHASE[nPhase].pVmsBmp->FreeImage();
  1273. pObj->VmsMsg->PHASE[nPhase].pVmsBmp->LoadFromStream(FImgStream);
  1274. int PHASE = pADO->FieldByName("PHASE")->AsInteger;
  1275. pObj->VmsMsg->PHASE[nPhase].DSPL_HH = pADO->FieldByName("DSPL_HH")->AsInteger;
  1276. pObj->VmsMsg->PHASE[nPhase].DNLD_YN = pADO->FieldByName("DNLD_YN")->AsString;
  1277. pObj->VmsMsg->PHASE[nPhase].DSPL_CD = pADO->FieldByName("VMS_MSG_DSPL_MTHD_CD")->AsString;
  1278. if (pObj->VmsMsg->PHASE[nPhase].DSPL_HH <= 0) pObj->VmsMsg->PHASE[nPhase].DSPL_HH = 3;
  1279. if (pObj->VmsMsg->PHASE[nPhase].DSPL_HH >= 10) pObj->VmsMsg->PHASE[nPhase].DSPL_HH = 10;
  1280. String DSPL_DT = pADO->FieldByName("DSPL_DT")->AsString;
  1281. String SVC_DT = pADO->FieldByName("SVC_DT")->AsString;
  1282. pObj->VmsMsg->OFFER_DT = DSPL_DT;
  1283. if (DSPL_DT >= SVC_DT)
  1284. {
  1285. pObj->VmsMsg->OFFER_YN = true;
  1286. }
  1287. else
  1288. {
  1289. pObj->VmsMsg->OFFER_YN = false;
  1290. }
  1291. if (pObj->VmsMsg->PHASE[nPhase].DNLD_YN == "N")
  1292. {
  1293. pObj->VmsMsg->OFFER_YN = false;
  1294. }
  1295. //TODO
  1296. if (pObj->WSTATE.Comm != vms_normal)
  1297. {
  1298. pObj->VmsMsg->OFFER_YN = false;
  1299. }
  1300. nPhase++;
  1301. }
  1302. catch(Exception &e)
  1303. {
  1304. }
  1305. }
  1306. }
  1307. if (pObj)
  1308. {
  1309. pObj->VmsMsg->Total = nPhase;
  1310. pObj->VmsMsg->Curr = 0;
  1311. pObj->UnLock();
  1312. }
  1313. }
  1314. catch(EDatabaseError &E)
  1315. {
  1316. DBERRORMSG("TVmsCtlrManager::LoadVmsMsg", String(E.ClassName()), E.Message, sQry);
  1317. throw Exception(String(E.ClassName()) + E.Message);
  1318. }
  1319. catch(Exception &e)
  1320. {
  1321. DBERRORMSG("TVmsCtlrManager::LoadVmsMsg", String(e.ClassName()), e.Message, sQry);
  1322. throw Exception(String(e.ClassName()) + e.Message);
  1323. }
  1324. }
  1325. __finally
  1326. {
  1327. if (pADO)
  1328. {
  1329. pADO->Close();
  1330. delete pADO;
  1331. }
  1332. }
  1333. return true;
  1334. }
  1335. //---------------------------------------------------------------------------
  1336. bool TVmsCtlrManager::LoadVmsFormUsage(TADOConnection *ADbConn/*=NULL*/)
  1337. {
  1338. InitFormCount();
  1339. String sQry;
  1340. TADOQuery *pADO = NULL;
  1341. sQry = "SELECT A.VMS_CTLR_NMBR, A.TRFC_SITU_TYPE_CD, \r\n"
  1342. " A.USE_YN, A.DSPL_STRT_HH, A.DSPL_END_HH, \r\n"
  1343. " TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') AS CURR_HH \r\n"
  1344. " FROM TB_VMS_TRFC_INFR_DSPL_SCH A, \r\n"
  1345. " TB_VMS_FORM B \r\n"
  1346. " WHERE A.VMS_FORM_ID = B.VMS_FORM_ID \r\n";
  1347. try
  1348. {
  1349. try
  1350. {
  1351. pADO = new TADOQuery(NULL);
  1352. pADO->Close();
  1353. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1354. ITSDb_SQLText(pADO, sQry);
  1355. ITSDb_SQLOpen(pADO);
  1356. for( ; !pADO->Eof; pADO->Next())
  1357. {
  1358. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  1359. TVmsCtlr *pObj = FLists.Find(sVmsNmbr);
  1360. if (!pObj) continue;
  1361. int nFormType = pADO->FieldByName("TRFC_SITU_TYPE_CD")->AsString.Trim().ToIntDef(-1);
  1362. switch(nFormType)
  1363. {
  1364. case enFormTraffic: // , ' 소통상황(1단)
  1365. // , ' 소통상황(2단)
  1366. // , ' 소통상황(3단)
  1367. // , ' 소통상황(4단)
  1368. // , ' 소통상황(도형식)
  1369. case enFormDolbal: // , ' 돌발문안
  1370. case enFormGongsa: // , ' 공사/행사문안
  1371. case enFormHongbo: // , ' 홍보문안
  1372. case enFormDeture: // , ' 우회도로
  1373. case enFormFixed: // , ' 고정
  1374. case enFormBase: // , ' 기본
  1375. case enFormCongest: // , ' 정체
  1376. break;
  1377. default: continue;
  1378. }
  1379. pObj->FormCnt[nFormType][0]++; //등록되어있는 전체 폼 숫자
  1380. String sUseYn = pADO->FieldByName("USE_YN")->AsString;
  1381. if (sUseYn == "N")
  1382. {
  1383. continue;
  1384. }
  1385. //사용하는 것중에 현재시각이 제공시각안에 들어있는것은 카운트하지 않음.
  1386. String sStrHH = pADO->FieldByName("DSPL_STRT_HH")->AsString;
  1387. String sEndHH = pADO->FieldByName("DSPL_END_HH")->AsString;
  1388. String sCurHH = pADO->FieldByName("CURR_HH")->AsString;
  1389. if (sCurHH >= sStrHH && sCurHH <= sEndHH)
  1390. {
  1391. pObj->FormCnt[nFormType][1]++; //사용가능 폼 숫자
  1392. }
  1393. }
  1394. }
  1395. catch(EDatabaseError &E)
  1396. {
  1397. DBERRORLOG("TVmsCtlrManager::LoadVmsFormUsage", String(E.ClassName()), E.Message, sQry);
  1398. throw Exception(String(E.ClassName()) + E.Message);
  1399. }
  1400. catch(Exception &e)
  1401. {
  1402. DBERRORLOG("TVmsCtlrManager::LoadVmsFormUsage", String(e.ClassName()), e.Message, sQry);
  1403. throw Exception(String(e.ClassName()) + e.Message);
  1404. }
  1405. }
  1406. __finally
  1407. {
  1408. if (pADO)
  1409. {
  1410. pADO->Close();
  1411. delete pADO;
  1412. }
  1413. }
  1414. return true;
  1415. }
  1416. //---------------------------------------------------------------------------
  1417. bool TVmsCtlrManager::InsVmsControlHs(String ACtlDt, String AVmsNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
  1418. {
  1419. String sQry;
  1420. TADOQuery *pADO = NULL;
  1421. sQry = "INSERT INTO TB_VMS_CTL_HS( \r\n"
  1422. " CTL_DT, \r\n"
  1423. " VMS_CTLR_NMBR, \r\n"
  1424. " CTL_TYPE, \r\n"
  1425. " CTL_VAL, \r\n"
  1426. " CTL_RESULT, \r\n"
  1427. " USER_ID \r\n"
  1428. " ) \r\n"
  1429. " VALUES( \r\n"
  1430. " :p01, \r\n"
  1431. " :p02, \r\n"
  1432. " :p03, \r\n"
  1433. " :p04, \r\n"
  1434. " :p05, \r\n"
  1435. " :p06 \r\n"
  1436. " ) \r\n";
  1437. try
  1438. {
  1439. try
  1440. {
  1441. pADO = new TADOQuery(NULL);
  1442. pADO->Close();
  1443. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1444. pADO->SQL->Clear();
  1445. pADO->SQL->Text = sQry;
  1446. pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
  1447. pADO->Parameters->ParamByName("p02")->Value = AVmsNmbr;
  1448. pADO->Parameters->ParamByName("p03")->Value = ACtlType;
  1449. pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
  1450. pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
  1451. pADO->Parameters->ParamByName("p06")->Value = AUserId;
  1452. pADO->ExecSQL();
  1453. return true;
  1454. }
  1455. catch(EDatabaseError &E)
  1456. {
  1457. DBERRORLOG("TVmsCtlrManager::InsVmsControlHs", String(E.ClassName()), E.Message, sQry);
  1458. throw Exception(String(E.ClassName()) + E.Message);
  1459. }
  1460. catch(Exception &e)
  1461. {
  1462. DBERRORLOG("TVmsCtlrManager::InsVmsControlHs", String(e.ClassName()), e.Message, sQry);
  1463. throw Exception(String(e.ClassName()) + e.Message);
  1464. }
  1465. }
  1466. __finally
  1467. {
  1468. if (pADO)
  1469. {
  1470. pADO->Close();
  1471. delete pADO;
  1472. }
  1473. }
  1474. return true;
  1475. }
  1476. //---------------------------------------------------------------------------