CDSVmsCtlrF.cpp 66 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSVmsCtlrF.h"
  4. #include "ITSUtilF.h"
  5. #include "VmsCommonLibF.h"
  6. //---------------------------------------------------------------------------
  7. #pragma package(smart_init)
  8. //---------------------------------------------------------------------------
  9. TVmsIfscRltn::TVmsIfscRltn()
  10. {
  11. }
  12. //---------------------------------------------------------------------------
  13. TVmsIfscRltn::~TVmsIfscRltn()
  14. {
  15. }
  16. //---------------------------------------------------------------------------
  17. //---------------------------------------------------------------------------
  18. TVmsEvspRltn::TVmsEvspRltn()
  19. {
  20. }
  21. //---------------------------------------------------------------------------
  22. TVmsEvspRltn::~TVmsEvspRltn()
  23. {
  24. }
  25. //---------------------------------------------------------------------------
  26. //---------------------------------------------------------------------------
  27. TVmsMsg::TVmsMsg()
  28. {
  29. for (int ii = 0; ii < INT_VMS_MAX_FORM; ii++)
  30. {
  31. PHASE[ii].pVmsBmp = NULL;
  32. }
  33. Init();
  34. };
  35. //---------------------------------------------------------------------------
  36. TVmsMsg::~TVmsMsg()
  37. {
  38. for (int ii = 0; ii < INT_VMS_MAX_FORM; ii++)
  39. {
  40. if (PHASE[ii].pVmsBmp)
  41. {
  42. PHASE[ii].pVmsBmp->FreeImage();
  43. PHASE[ii].pVmsBmp->Assign(NULL);
  44. delete PHASE[ii].pVmsBmp;
  45. PHASE[ii].pVmsBmp = NULL;
  46. }
  47. }
  48. };
  49. //---------------------------------------------------------------------------
  50. void TVmsMsg::Init()
  51. {
  52. Total = 0;
  53. Curr = 0;
  54. OFFER_DT = "19990101000000";
  55. OFFER_YN = false;
  56. IsLoading= true;
  57. for (int ii = 0; ii < INT_VMS_MAX_FORM; ii++)
  58. {
  59. PHASE[ii].DSPL_HH = 4; //표출시간
  60. PHASE[ii].DNLD_YN = "N"; //다운로드성공여부
  61. PHASE[ii].DSPL_CD = ""; //표출방법
  62. PHASE[ii].VMS_SCH_FORM_TYPE = 0;
  63. PHASE[ii].VMS_DSPL_MSG_TXT = "";
  64. }
  65. };
  66. //---------------------------------------------------------------------------
  67. void VmsInitStatus(INT_VMS_STATE *AState)
  68. {
  69. int ii;
  70. if (AState->Comm != vms_comm_normal && AState->Wcomm != vms_wcomm_normal)
  71. {
  72. AState->DoorStatus = vms_door_unknown; /* 도어상태정보코드, 0:열림 1:닫힘 2:알수없음 */
  73. AState->ModulePowerStatus = vms_module_power_unknown; /* 모듈전원상태정보코드, 0:켜짐 1:꺼짐 2:알수없음 */
  74. AState->BodyTemp = 0; /* 함체온도값(℃), 범위(-128~127) */
  75. AState->LuminanceStatus = 0; /* 화면의 밝기값 (최대 휘도값을 100으로 했을 때의 백분율 값), 범위(0~100) */
  76. AState->FanStatus = vms_fan_unknown; /* Fan 동작상태정보코드, 0:켜짐, 1:꺼짐 2:알수없음 */
  77. AState->HeaterStatus = vms_heater_unknown; /* Heater 동작상태정보코드, 0:켜짐, 1:꺼짐 2:알수없음 */
  78. AState->ExternalLightStatus = vms_unknown; /* 선택 외부조명 동작상태정보코드 0:켜짐, 1:꺼짐, 2:자동(공단은 미사용) */
  79. AState->AlarmLightStatus = vms_unknown; /* 선택 경광등 동작상태정보코드 0:켜짐, 1:꺼짐 */
  80. AState->SpeakerStatus = vms_unknown; /* 선택 스피커 동작상태정보코드 0:켜짐, 1:꺼짐 */
  81. //memset(&AState->ControllerCurrentTime, 0x00, sizeof(AState->ControllerCurrentTime)); /*선택 제어기 시간 (YYYYMMDDHHMMSS) */
  82. AState->Voltage = 0; /* 전압, 범위(0~255), 사용안함 */
  83. // AState->ModuleState = vms_unknown; /* 모듈 상태, 0:정상 1:장애 2:알수없음 */
  84. #if 0
  85. //AState->ModuleHorizontal = 0; /* 가로 모듈수 */
  86. //AState->ModuleVertical = 0; /* 세로 모듈수 */
  87. for (ii = 0; ii < INT_VMS_MAX_MODULE_BIT; ii++)
  88. AState->ModuleStatus[ii] = 0xFF;//vms_unknown; /* 모듈 개별 상태, 0:정상 1:장애 2:알수없음 */
  89. //AState->PowerCount = 0; /* 전원 갯수 */
  90. for (ii = 0; ii < INT_VMS_MAX_POWER_BIT; ii++)
  91. AState->PowerStatus[ii] = 0xFF;//vms_unknown; /* 전원 개별 상태, 0:켜짐 1:꺼짐 2:알수없음 */
  92. #endif
  93. #if 0
  94. AState->ScheduledMessageOperatingTime = 0; /* 필수 계획된 메시지의 동작시간(초) */
  95. AState->ModuleOperatingTemperature = 0; /* 필수 모듈 전원이 꺼지는 온도값(℃) */
  96. AState->FanOperatingTemperature = 0; /* 필수 Fan 동작 기준 온도값(℃) */
  97. AState->HeaterOperatingTemperature = 0; /* 필수 Heater 동작 기준 온도값(℃) */
  98. AState->ExternalLightOperatingLuminance = 0; /* 선택 외부전등 동작 기준 휘도값 */
  99. AState->ModuleBasicFailureRate = 0; /* 선택 모듈 장애율 (한 개의 모듈을 장애로 처리하기 위한 픽셀의 백분율값) */
  100. AState->MaximumRetry = 0; /* 선택 최대 재시도 횟수(회) */
  101. AState->ResponseTimeOut = 0; /* 선택 최대응답대기시간 (초) */
  102. AState->BlinkingCycleTime = 0; /* 선택 점멸시간 주기 ( 1/10초단위) */
  103. #endif
  104. }
  105. #if 0
  106. for (ii = 0; ii < INT_VMS_MAX_MODULE_BIT; ii++)
  107. AState->ModuleStatus[ii] = 0xFF;//vms_unknown; /* 모듈 개별 상태, 0:정상 1:장애 2:알수없음 */
  108. //AState->PowerCount = 0; /* 전원 갯수 */
  109. for (ii = 0; ii < INT_VMS_MAX_POWER_BIT; ii++)
  110. AState->PowerStatus[ii] = 0xFF;//vms_unknown; /* 전원 개별 상태, 0:켜짐 1:꺼짐 2:알수없음 */
  111. #endif
  112. }
  113. //---------------------------------------------------------------------------
  114. TVmsStts::TVmsStts(String AVMS_CTLR_ID)
  115. {
  116. VMS_CTLR_ID = AVMS_CTLR_ID;
  117. Init();
  118. };
  119. //---------------------------------------------------------------------------
  120. TVmsStts::~TVmsStts()
  121. {
  122. };
  123. //---------------------------------------------------------------------------
  124. void TVmsStts::Init()
  125. {
  126. IsLoading = false;
  127. };
  128. //---------------------------------------------------------------------------
  129. //---------------------------------------------------------------------------
  130. TVmsCtlr::TVmsCtlr()
  131. {
  132. memset(&STATE, 0x00, sizeof(STATE));
  133. STATE.Comm = vms_comm_error;
  134. VmsInitStatus(&STATE);
  135. STATE.Comm = vms_comm_error;
  136. InitFormCount();
  137. VmsMsg = NULL;
  138. VmsMsg = new TVmsMsg();
  139. VmsMsg->Init();
  140. RunState = state_error;
  141. }
  142. //---------------------------------------------------------------------------
  143. TVmsCtlr::~TVmsCtlr()
  144. {
  145. FIfscRltn.RemoveAll();
  146. }
  147. //---------------------------------------------------------------------------
  148. void TVmsCtlr::Lock()
  149. {
  150. //EnterCriticalSection(&FCS);
  151. }
  152. //---------------------------------------------------------------------------
  153. void TVmsCtlr::UnLock()
  154. {
  155. //LeaveCriticalSection(&FCS);
  156. }
  157. //---------------------------------------------------------------------------
  158. void TVmsCtlr::CheckRunState()
  159. {
  160. RunState = STATE.Comm;
  161. if (STATE.Comm == vms_comm_normal && STATE.Wcomm != vms_wcomm_normal)
  162. {
  163. STATE.DoorStatus = vms_door_unknown;
  164. STATE.ModulePowerStatus = vms_module_power_unknown;
  165. STATE.PowerCtrlStatus = vms_module_power_unknown;
  166. STATE.BodyTemp = 0;
  167. STATE.LuminanceStatus = 0;
  168. STATE.FanStatus = vms_fan_unknown;
  169. STATE.HeaterStatus = vms_heater_unknown;
  170. }
  171. }
  172. //---------------------------------------------------------------------------
  173. TVmsModlSize::TVmsModlSize()
  174. {
  175. }
  176. //---------------------------------------------------------------------------
  177. TVmsModlSize::~TVmsModlSize()
  178. {
  179. }
  180. //---------------------------------------------------------------------------
  181. TVmsSize::TVmsSize()
  182. {
  183. }
  184. //---------------------------------------------------------------------------
  185. //---------------------------------------------------------------------------
  186. TVmsCtlrManager *VmsCtlrManager = NULL;
  187. //---------------------------------------------------------------------------
  188. TVmsCtlrManager::TVmsCtlrManager()
  189. {
  190. FImgStream = NULL;
  191. }
  192. //---------------------------------------------------------------------------
  193. TVmsCtlrManager::~TVmsCtlrManager()
  194. {
  195. FVmsSize.RemoveAll();
  196. FLists.RemoveAll();
  197. if (FImgStream) delete FImgStream;
  198. FImgStream = NULL;
  199. }
  200. //---------------------------------------------------------------------------
  201. void TVmsCtlrManager::InitFormCount()
  202. {
  203. FLists.Lock();
  204. try
  205. {
  206. FOR_STL(TVmsCtlr*, pObj, FLists)
  207. {
  208. pObj->InitFormCount();
  209. }
  210. }
  211. __finally
  212. {
  213. FLists.UnLock();
  214. }
  215. };
  216. //---------------------------------------------------------------------------
  217. #if 0
  218. void TVmsCtlrManager::FillVmsType(TcxComboBox *cboBox, bool bAddAll/*=false*/)
  219. {
  220. String sQry;
  221. TStrings *pStrItems;
  222. TADOQuery *pADO = NULL;
  223. if (!VmsTypeManager)
  224. {
  225. VmsTypeManager = new TVmsTypeManager();
  226. VmsTypeManager->LoadFromDb();
  227. }
  228. APP_DelVmsSizeCombo(cboBox);
  229. pStrItems = ((TcxComboBox *)cboBox)->Properties->Items;
  230. ((TcxComboBox *)cboBox)->Properties->Items->Clear();
  231. FOR_STL(TVmsType*, pObj, VmsTypeManager->FLists)
  232. {
  233. String sTypeCd = pObj->VMS_MODL_KIND;
  234. String sTypeNm = pObj->VMS_MODL_KIND_NM;
  235. int nW = pObj->VMS_WDTH;
  236. int nH = pObj->VMS_HGHT;
  237. int nR = pObj->VMS_MODL_ROW;
  238. int nC = pObj->VMS_MODL_COL;
  239. pStrItems->AddObject(" [" + sTypeCd + "] " + sTypeNm + " (" + String(nW) + "x" + String(nH) + ")", new TVmsSizeType(sTypeCd, sTypeNm, nW, nH, nR, nC) );
  240. }
  241. if (bAddAll)
  242. {
  243. String sAllName = "전체";
  244. pStrItems->AddObject(" [ALL] 전체" , new TVmsSizeType("ALL", sAllName, 384, 64, 2, 12));
  245. }
  246. cboBox->ItemIndex = 0;
  247. }
  248. //---------------------------------------------------------------------------
  249. void TVmsCtlrManager::FillVmsModlSizeType(TcxComboBox *cboBox, bool bAddAll/*=false*/)
  250. {
  251. String sQry;
  252. TStrings *pStrItems;
  253. TADOQuery *pADO = NULL;
  254. if (!VmsTypeManager)
  255. {
  256. VmsTypeManager = new TVmsTypeManager();
  257. VmsTypeManager->LoadFromDb();
  258. }
  259. APP_DelVmsSizeCombo(cboBox);
  260. pStrItems = ((TcxComboBox *)cboBox)->Properties->Items;
  261. ((TcxComboBox *)cboBox)->Properties->Items->Clear();
  262. FOR_STL(TVmsType*, pObj, VmsTypeManager->FLists)
  263. {
  264. String sTypeCd = pObj->VMS_MODL_KIND;
  265. String sTypeNm = pObj->VMS_MODL_KIND_NM;
  266. int nW = pObj->VMS_WDTH;
  267. int nH = pObj->VMS_HGHT;
  268. int nR = pObj->VMS_MODL_ROW;
  269. int nC = pObj->VMS_MODL_COL;
  270. pStrItems->AddObject(" [" + sTypeCd + "] " + sTypeNm + " (" + String(nW) + "x" + String(nH) + ")", new TVmsSizeType(sTypeCd, sTypeNm, nW, nH, nR, nC) );
  271. }
  272. if (bAddAll)
  273. {
  274. String sAllName = "전체";
  275. pStrItems->AddObject(" [ALL] 전체" , new TVmsSizeType("ALL", sAllName, 384, 64, 2, 12));
  276. }
  277. cboBox->ItemIndex = 0;
  278. }
  279. //---------------------------------------------------------------------------
  280. #endif
  281. bool TVmsCtlrManager::LoadVmsModlSize(TADOConnection *ADbConn/*=NULL*/)
  282. {
  283. String sQry;
  284. TADOQuery *pADO = NULL;
  285. FVmsSize.Lock();
  286. try
  287. {
  288. FVmsSize.RemoveAll();
  289. }
  290. __finally
  291. {
  292. FVmsSize.UnLock();
  293. }
  294. sQry = "SELECT T1.VMS_MODL_KIND, T1.VMS_MODL_KIND_NM, \r\n"
  295. " T1.VMS_MODL_COL * T1.MODL_PIXL_WDTH AS VMS_WDTH, \r\n"
  296. " T1.VMS_MODL_ROW * T1.MODL_PIXL_HGHT AS VMS_HGHT \r\n"
  297. " FROM TB_VMS_MODL_KIND T1 \r\n"
  298. " WHERE 1=1 \r\n"
  299. " AND T1.USE_YN = 'Y' \r\n"
  300. " ORDER BY T1.VMS_MODL_KIND \r\n";
  301. FVmsSize.Lock();
  302. try
  303. {
  304. try
  305. {
  306. pADO = new TADOQuery(NULL);
  307. pADO->Close();
  308. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  309. pADO->SQL->Clear();
  310. pADO->SQL->Text = sQry;
  311. pADO->Prepared = true;
  312. pADO->Open();
  313. for( ; !pADO->Eof; pADO->Next())
  314. {
  315. TVmsSize *pObj = new TVmsSize();
  316. pObj->TypeCd = pADO->FieldByName("VMS_MODL_KIND")->AsString;
  317. pObj->TypeNm = pADO->FieldByName("VMS_MODL_KIND_NM")->AsString;
  318. pObj->Width = pADO->FieldByName("VMS_WDTH")->AsInteger;
  319. pObj->Height = pADO->FieldByName("VMS_HGHT")->AsInteger;
  320. FVmsSize.Push(pObj->TypeCd, pObj);
  321. }
  322. }
  323. catch(EDatabaseError &E)
  324. {
  325. DBERRORMSG("TVmsCtlrManager::LoadVmsModlSize", String(E.ClassName()), E.Message, sQry);
  326. throw Exception(String(E.ClassName()) + E.Message);
  327. }
  328. catch(Exception &e)
  329. {
  330. DBERRORMSG("TVmsCtlrManager::LoadVmsModlSize", String(e.ClassName()), e.Message, sQry);
  331. throw Exception(String(e.ClassName()) + e.Message);
  332. }
  333. }
  334. __finally
  335. {
  336. if (pADO)
  337. {
  338. pADO->Close();
  339. delete pADO;
  340. }
  341. FVmsSize.UnLock();
  342. }
  343. return true;
  344. }
  345. //---------------------------------------------------------------------------
  346. bool TVmsCtlrManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  347. {
  348. String sQry;
  349. TADOQuery *pADO = NULL;
  350. FMinWidth = 1000;
  351. FMinHeight= 1000;
  352. FMaxWidth = 0;
  353. FMaxHeight= 0;
  354. sQry = "SELECT T1.*, \r\n"
  355. " T2.VMS_MODL_KIND_NM, \r\n"
  356. " T2.VMS_MODL_COL, T2.MODL_PIXL_WDTH, \r\n"
  357. " T2.VMS_MODL_ROW, T2.MODL_PIXL_HGHT, T2.MODL_CLR, \r\n"
  358. " NVL(TRIM(T1.CMRA_IMG_ADDR), '-') AS VMS_RTSP_ADDR, \r\n"
  359. " T3.CMNC_IP AS VMS_CTLR_IP, \r\n"
  360. " NVL(T4.CD_NM, T1.VMS_TYPE || '-?-') AS VMS_TYPE_NM, \r\n"
  361. " NVL(T5.CD_NM, T1.OPER_MODE || '-?-') AS OPER_MODE_NM \r\n"
  362. " FROM TB_VMS_CTLR T1, TB_VMS_MODL_KIND T2, TB_FCLT T3, \r\n"
  363. " (SELECT * FROM TB_SYS_CD T4 WHERE T4.CLSS_CD = 'VMS_TYPE_CD') T4, \r\n"
  364. " (SELECT * FROM TB_SYS_CD T4 WHERE T4.CLSS_CD = 'VMS_OPER_MODE_CD') T5 \r\n"
  365. " WHERE 1=1 \r\n"
  366. " AND T1.USE_YN = 'Y' \r\n"
  367. " AND T1.VMS_MODL_KIND = T2.VMS_MODL_KIND \r\n"
  368. " AND T1.FCLT_ID = T3.FCLT_ID \r\n"
  369. " AND T1.VMS_TYPE = T4.CODE_NO(+) \r\n"
  370. " AND T1.OPER_MODE = T5.CODE_NO(+) \r\n"
  371. " ORDER BY VMS_CTLR_ID \r\n";
  372. FLists.Lock();
  373. try
  374. {
  375. FLists.RemoveAll();
  376. try
  377. {
  378. pADO = new TADOQuery(NULL);
  379. pADO->Close();
  380. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  381. pADO->SQL->Clear();
  382. pADO->SQL->Text = sQry;
  383. pADO->Prepared = true;
  384. pADO->Open();
  385. for( ; !pADO->Eof; pADO->Next())
  386. {
  387. TVmsCtlr *pObj = new TVmsCtlr();
  388. pObj->VMS_CTLR_ID = pADO->FieldByName("VMS_CTLR_ID")->AsString; //N VARCHAR2(10) N VMS제어기ID
  389. pObj->FCLT_ID = pADO->FieldByName("FCLT_ID")->AsString; //N VARCHAR2(10) N 시설물ID
  390. pObj->VMS_NM = pADO->FieldByName("VMS_NM")->AsString; //N VARCHAR2(32) N VMS명
  391. pObj->VMS_TYPE = pADO->FieldByName("VMS_TYPE")->AsString; //N VARCHAR2(3) N VMS유형
  392. pObj->STD_SECT_ID = pADO->FieldByName("STD_SECT_ID")->AsString; //N CHAR(10) N 표준구간ID
  393. pObj->INSTL_MILE = pADO->FieldByName("INSTL_MILE")->AsInteger; //N NUMBER(5) Y 설치이정
  394. pObj->CRDN_X = pADO->FieldByName("CRDN_X")->AsFloat; //N NUMBER(13,10) N 좌표X
  395. pObj->CRDN_Y = pADO->FieldByName("CRDN_Y")->AsFloat; //N NUMBER(12,10) N 좌표Y
  396. pObj->VMS_MODL_KIND = pADO->FieldByName("VMS_MODL_KIND")->AsString; //N VARCHAR2(10) N VMS모듈종류
  397. pObj->CMNC_PORT = pADO->FieldByName("CMNC_PORT")->AsInteger; //N NUMBER(5) N 통신포트
  398. pObj->EQMT_NO = pADO->FieldByName("EQMT_NO")->AsInteger; //N NUMBER(3) N 장비번호
  399. pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString; //N VARCHAR2(3) N 운영모드
  400. pObj->CMRA_IND = pADO->FieldByName("CMRA_IND")->AsString; //N CHAR(1) N 카메라유무
  401. pObj->CMRA_IMG_ADDR = pADO->FieldByName("CMRA_IMG_ADDR")->AsString; //N VARCHAR2(128) Y 카메라영상주소
  402. pObj->CMRA_LGIN_ID = pADO->FieldByName("CMRA_LGIN_ID")->AsString; //N VARCHAR2(32) Y 카메라로그인ID
  403. pObj->CMRA_LGIN_PW = pADO->FieldByName("CMRA_LGIN_PW")->AsString; //N VARCHAR2(32) Y 카메라로그인암호
  404. pObj->VMS_SCNR_ID = pADO->FieldByName("VMS_SCNR_ID")->AsString; //N VARCHAR2(10) Y VMS시나리오ID
  405. pObj->VMS_ON_HM = pADO->FieldByName("VMS_ON_HM")->AsString; //N CHAR(4) Y VMS ON시분
  406. pObj->VMS_OFF_HM = pADO->FieldByName("VMS_OFF_HM")->AsString; //N CHAR(4) Y VMS OFF시분
  407. pObj->MAX_DSPL_FORM_CNT = pADO->FieldByName("MAX_DSPL_FORM_CNT")->AsInteger; //N NUMBER(2) N 최대표출폼수
  408. pObj->USE_YN = pADO->FieldByName("USE_YN")->AsString;
  409. pObj->VMS_CTLR_IP = pADO->FieldByName("VMS_CTLR_IP")->AsString;
  410. pObj->WEB_CMRA_IP = "";
  411. pObj->VMS_RTSP_ADDR = pADO->FieldByName("VMS_RTSP_ADDR")->AsString;
  412. if (pObj->VMS_RTSP_ADDR == "-") {
  413. pObj->VMS_RTSP_ADDR = "";
  414. }
  415. pObj->VMS_TYPE_NM = pADO->FieldByName("VMS_TYPE_NM")->AsString;
  416. pObj->OPER_MODE_NM = pADO->FieldByName("OPER_MODE_NM")->AsString;
  417. pObj->FULL_STRM_SESN_NM = pObj->VMS_RTSP_ADDR;
  418. pObj->VMS_MODL_KIND_NM = pADO->FieldByName("VMS_MODL_KIND_NM")->AsString.Trim();
  419. pObj->VMS_MODL_ROW = pADO->FieldByName("VMS_MODL_ROW")->AsInteger;
  420. pObj->VMS_MODL_COL = pADO->FieldByName("VMS_MODL_COL")->AsInteger;
  421. pObj->MODL_PIXL_WDTH = pADO->FieldByName("MODL_PIXL_WDTH")->AsInteger;
  422. pObj->MODL_PIXL_HGHT = pADO->FieldByName("MODL_PIXL_HGHT")->AsInteger;
  423. pObj->POWR_MODL_ROW = 2;//pADO->FieldByName("POWR_ROW_NUM")->AsInteger;
  424. pObj->POWR_MODL_COL = 6;//pADO->FieldByName("POWR_COL_NUM")->AsInteger;
  425. pObj->MODL_CLR = pADO->FieldByName("MODL_CLR")->AsString.Trim();
  426. pObj->WIDTH = pObj->VMS_MODL_COL * pObj->MODL_PIXL_WDTH;
  427. pObj->HEIGHT = pObj->VMS_MODL_ROW * pObj->MODL_PIXL_HGHT;
  428. pObj->Stts = new TVmsStts(pObj->VMS_CTLR_ID);
  429. FLists.Push(pObj->VMS_CTLR_ID, pObj);
  430. }
  431. }
  432. catch(EDatabaseError &E)
  433. {
  434. DBERRORMSG("TVmsCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  435. throw Exception(String(E.ClassName()) + E.Message);
  436. }
  437. catch(Exception &e)
  438. {
  439. DBERRORMSG("TVmsCtlrManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
  440. throw Exception(String(e.ClassName()) + e.Message);
  441. }
  442. }
  443. __finally
  444. {
  445. if (pADO)
  446. {
  447. pADO->Close();
  448. delete pADO;
  449. }
  450. FLists.UnLock();
  451. }
  452. return true;
  453. }
  454. //---------------------------------------------------------------------------
  455. bool TVmsCtlrManager::LoadStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  456. {
  457. String sQry;
  458. TADOQuery *pADO = NULL;
  459. sQry = "SELECT T1.*, \r\n"
  460. " TO_CHAR(T1.LAST_DT, 'YYYY-MM-DD HH24:MI:SS') AS LAST_DT_FMT \r\n"
  461. " FROM TB_VMS_CTLR_STTS_PRST T1 \r\n";
  462. FLists.Lock();
  463. try
  464. {
  465. TVmsCtlr *pVmsCtlr = NULL;
  466. FOR_STL(TVmsCtlr*, pVms, FLists) {
  467. pVms->Stts->IsLoading = false;
  468. }
  469. try
  470. {
  471. pADO = new TADOQuery(NULL);
  472. pADO->Close();
  473. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  474. pADO->SQL->Clear();
  475. pADO->SQL->Text = sQry;
  476. pADO->Prepared = true;
  477. pADO->Open();
  478. for( ; !pADO->Eof; pADO->Next())
  479. {
  480. String VMS_CTLR_ID = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  481. pVmsCtlr = FLists.Find(VMS_CTLR_ID);
  482. if (pVmsCtlr == NULL) {
  483. continue;
  484. }
  485. TVmsStts* Stts = pVmsCtlr->Stts;
  486. Stts->LAST_DT = pADO->FieldByName("LAST_DT")->AsString; // N DATE N 최종일시
  487. Stts->LAST_DT_FMT = pADO->FieldByName("LAST_DT_FMT")->AsString; // N DATE N 최종일시
  488. Stts->RPRS_STTS = pADO->FieldByName("RPRS_STTS")->AsString; // N VARCHAR2(3) N 대표상태
  489. Stts->CMNC_STTS = pADO->FieldByName("CMNC_STTS")->AsString; // N VARCHAR2(3) Y 통신상태
  490. Stts->PS_STTS = pADO->FieldByName("PS_STTS")->AsString; // N VARCHAR2(3) Y 전원상태
  491. Stts->FAN_STTS = pADO->FieldByName("FAN_STTS")->AsString; // N VARCHAR2(3) Y 팬상태
  492. Stts->HTER_STTS = pADO->FieldByName("HTER_STTS")->AsString; // N VARCHAR2(3) Y 히터상태
  493. Stts->BOX_DOOR_STTS = pADO->FieldByName("BOX_DOOR_STTS")->AsString; // N VARCHAR2(3) Y 함체문상태
  494. Stts->BOX_FAN_STTS = pADO->FieldByName("BOX_FAN_STTS")->AsString; // N VARCHAR2(3) Y 함체팬상태
  495. Stts->BOX_HTER_STTS = pADO->FieldByName("BOX_HTER_STTS")->AsString; // N VARCHAR2(3) Y 함체히터상태
  496. Stts->SGNBRD_ON = pADO->FieldByName("SGNBRD_ON")->AsString; // N VARCHAR2(3) Y 전광판ON
  497. Stts->SGNBRD_STTS = pADO->FieldByName("SGNBRD_STTS")->AsString; // N VARCHAR2(3) Y 전광판상태
  498. Stts->BOX_TMPR = pADO->FieldByName("BOX_TMPR")->AsInteger; // N NUMBER(3) Y 함체온도
  499. Stts->BOX_HMD = pADO->FieldByName("BOX_HMD")->AsInteger; // N NUMBER(3) Y 함체습도
  500. Stts->VMS_TMPR = pADO->FieldByName("VMS_TMPR")->AsInteger; // N NUMBER(3) Y VMS온도
  501. Stts->IsLoading = true;
  502. }
  503. }
  504. catch(EDatabaseError &E)
  505. {
  506. DBERRORMSG("TVmsCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
  507. throw Exception(String(E.ClassName()) + E.Message);
  508. }
  509. catch(Exception &e)
  510. {
  511. DBERRORMSG("TVmsCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
  512. throw Exception(String(e.ClassName()) + e.Message);
  513. }
  514. }
  515. __finally
  516. {
  517. if (pADO)
  518. {
  519. pADO->Close();
  520. delete pADO;
  521. }
  522. FLists.UnLock();
  523. }
  524. return true;
  525. }
  526. //---------------------------------------------------------------------------
  527. bool TVmsCtlrManager::DeleteVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  528. {
  529. String sQry;
  530. TADOQuery *pADO = NULL;
  531. sQry = "UPDATE TB_VMS_CTLR \r\n"
  532. " SET USE_YN = 'N' \r\n"
  533. " WHERE VMS_CTLR_ID = :p01 \r\n";
  534. try
  535. {
  536. try
  537. {
  538. pADO = new TADOQuery(NULL);
  539. pADO->Close();
  540. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  541. pADO->SQL->Clear();
  542. pADO->SQL->Text = sQry;
  543. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  544. pADO->ExecSQL();
  545. return true;
  546. }
  547. catch(EDatabaseError &E)
  548. {
  549. DBERRORMSG("TVmsCtlrManager::DeleteVms", String(E.ClassName()), E.Message, sQry);
  550. throw Exception(String(E.ClassName()) + E.Message);
  551. }
  552. catch(Exception &e)
  553. {
  554. DBERRORMSG("TVmsCtlrManager::DeleteVms", String(e.ClassName()), e.Message, sQry);
  555. throw Exception(String(e.ClassName()) + e.Message);
  556. }
  557. }
  558. __finally
  559. {
  560. if (pADO)
  561. {
  562. pADO->Close();
  563. delete pADO;
  564. }
  565. }
  566. return true;
  567. }
  568. //---------------------------------------------------------------------------
  569. bool TVmsCtlrManager::InsertVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  570. {
  571. String sQry;
  572. TADOQuery *pADO = NULL;
  573. #if 0
  574. sQry = "INSERT INTO TB_VMS_CTLR \r\n"
  575. " ( \r\n"
  576. " VMS_CTLR_ID, \r\n"
  577. " VMS_CTLR_ID, \r\n"
  578. " VMS_NM, \r\n"
  579. " VMS_CTLR_IP, \r\n"
  580. " VMS_CTLR_PORT, \r\n"
  581. " VMS_CTLR_LOCAL_NO, \r\n"
  582. " VMS_MODL_KIND, \r\n"
  583. " ISTL_LCTN_NM, \r\n"
  584. " X_CRDN, \r\n"
  585. " Y_CRDN, \r\n"
  586. " DEL_YN, \r\n"
  587. " WEB_CMRA_IP, \r\n"
  588. " WEB_CMRA_PORT, \r\n"
  589. " WEB_CMRA_ID, \r\n"
  590. " WEB_CMRA_PWD, \r\n"
  591. " STRM_SESN_NM, \r\n"
  592. " VMS_MAX_PHSE_NUM, \r\n"
  593. " VMS_OFF_HM, \r\n"
  594. " VMS_OFF_HM, \r\n"
  595. " ISTL_LCTN_ADDR \r\n"
  596. " ) \r\n"
  597. " VALUES (:p01, \r\n"
  598. " :p02, \r\n"
  599. " :p03, \r\n"
  600. " :p04, \r\n"
  601. " :p05, \r\n"
  602. " :p06, \r\n"
  603. " :p07, \r\n"
  604. " :p08, \r\n"
  605. " :p09, \r\n"
  606. " :p10, \r\n"
  607. " :p11, \r\n"
  608. " :p12, \r\n"
  609. " :p13, \r\n"
  610. " :p14, \r\n"
  611. " :p15, \r\n"
  612. " :p16, \r\n"
  613. " :p17, \r\n"
  614. " :p18, \r\n"
  615. " :p19, \r\n"
  616. " :p20) \r\n";
  617. try
  618. {
  619. try
  620. {
  621. pADO = new TADOQuery(NULL);
  622. pADO->Close();
  623. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  624. pADO->SQL->Clear();
  625. pADO->SQL->Text = sQry;
  626. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  627. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_CTLR_ID;
  628. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  629. pADO->Parameters->ParamByName("p04")->Value = AObj->VMS_CTLR_IP;
  630. pADO->Parameters->ParamByName("p05")->Value = AObj->VMS_CTLR_PORT;
  631. pADO->Parameters->ParamByName("p06")->Value = AObj->VMS_CTLR_LOCAL_NO;
  632. pADO->Parameters->ParamByName("p07")->Value = AObj->VMS_MODL_KIND;
  633. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  634. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  635. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  636. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  637. pADO->Parameters->ParamByName("p12")->Value = AObj->WEB_CMRA_IP;
  638. pADO->Parameters->ParamByName("p13")->Value = AObj->WEB_CMRA_PORT;
  639. pADO->Parameters->ParamByName("p14")->Value = AObj->WEB_CMRA_ID;
  640. pADO->Parameters->ParamByName("p15")->Value = AObj->WEB_CMRA_PWD;
  641. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_SESN_NM;
  642. pADO->Parameters->ParamByName("p17")->Value = AObj->VMS_MAX_PHSE_NUM;
  643. pADO->Parameters->ParamByName("p18")->Value = AObj->VMS_ON_HM;
  644. pADO->Parameters->ParamByName("p19")->Value = AObj->VMS_OFF_HM;
  645. pADO->Parameters->ParamByName("p20")->Value = AObj->ISTL_LCTN_ADDR;
  646. pADO->ExecSQL();
  647. return MergeFcltInfo(AObj, ADbConn);
  648. }
  649. catch(EDatabaseError &E)
  650. {
  651. DBERRORMSG("TVmsCtlrManager::InsertVms", String(E.ClassName()), E.Message, sQry);
  652. throw Exception(String(E.ClassName()) + E.Message);
  653. }
  654. catch(Exception &e)
  655. {
  656. DBERRORMSG("TVmsCtlrManager::InsertVms", String(e.ClassName()), e.Message, sQry);
  657. throw Exception(String(e.ClassName()) + e.Message);
  658. }
  659. }
  660. __finally
  661. {
  662. if (pADO)
  663. {
  664. pADO->Close();
  665. delete pADO;
  666. }
  667. }
  668. #endif
  669. return true;
  670. }
  671. //---------------------------------------------------------------------------
  672. bool TVmsCtlrManager::UpdateVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  673. {
  674. return MergeVms(AObj, ADbConn);
  675. }
  676. //---------------------------------------------------------------------------
  677. bool TVmsCtlrManager::MergeVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  678. {
  679. String sQry;
  680. TADOQuery *pADO = NULL;
  681. #if 0
  682. sQry = "MERGE INTO TB_VMS_CTLR L \r\n"
  683. "USING (SELECT :p01 AS VMS_CTLR_ID, \r\n"
  684. " :p02 AS VMS_CTLR_ID, \r\n"
  685. " :p03 AS VMS_NM, \r\n"
  686. " :p04 AS VMS_CTLR_IP, \r\n"
  687. " :p05 AS VMS_CTLR_PORT, \r\n"
  688. " :p06 AS VMS_CTLR_LOCAL_NO, \r\n"
  689. " :p07 AS VMS_MODL_KIND, \r\n"
  690. " :p08 AS ISTL_LCTN_NM, \r\n"
  691. " :p09 AS X_CRDN, \r\n"
  692. " :p10 AS Y_CRDN, \r\n"
  693. " :p11 AS DEL_YN, \r\n"
  694. " :p12 AS WEB_CMRA_IP, \r\n"
  695. " :p13 AS WEB_CMRA_PORT, \r\n"
  696. " :p14 AS WEB_CMRA_ID, \r\n"
  697. " :p15 AS WEB_CMRA_PWD, \r\n"
  698. " :p16 AS STRM_SESN_NM, \r\n"
  699. " :p17 AS VMS_MAX_PHSE_NUM, \r\n"
  700. " :p18 AS VMS_OFF_HM, \r\n"
  701. " :p19 AS VMS_OFF_HM, \r\n"
  702. " :p20 AS ISTL_LCTN_ADDR \r\n"
  703. " FROM DUAL) M \r\n"
  704. " ON (L.VMS_CTLR_ID = M.VMS_CTLR_ID) \r\n"
  705. "WHEN MATCHED THEN \r\n"
  706. " UPDATE SET L.VMS_CTLR_ID = M.VMS_CTLR_ID, \r\n"
  707. " L.VMS_NM = M.VMS_NM, \r\n"
  708. " L.VMS_CTLR_IP = M.VMS_CTLR_IP, \r\n"
  709. " L.VMS_CTLR_PORT = M.VMS_CTLR_PORT, \r\n"
  710. " L.VMS_CTLR_LOCAL_NO = M.VMS_CTLR_LOCAL_NO, \r\n"
  711. " L.VMS_MODL_KIND = M.VMS_MODL_KIND, \r\n"
  712. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  713. " L.X_CRDN = M.X_CRDN, \r\n"
  714. " L.Y_CRDN = M.Y_CRDN, \r\n"
  715. " L.DEL_YN = M.DEL_YN, \r\n"
  716. " L.WEB_CMRA_IP = M.WEB_CMRA_IP, \r\n"
  717. " L.WEB_CMRA_PORT = M.WEB_CMRA_PORT, \r\n"
  718. " L.WEB_CMRA_ID = M.WEB_CMRA_ID, \r\n"
  719. " L.WEB_CMRA_PWD = M.WEB_CMRA_PWD, \r\n"
  720. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  721. " L.VMS_MAX_PHSE_NUM = M.VMS_MAX_PHSE_NUM, \r\n"
  722. " L.VMS_OFF_HM = M.VMS_OFF_HM, \r\n"
  723. " L.VMS_OFF_HM = M.VMS_OFF_HM, \r\n"
  724. " L.ISTL_LCTN_ADDR = M.ISTL_LCTN_ADDR \r\n"
  725. "WHEN NOT MATCHED THEN \r\n"
  726. " INSERT ( \r\n"
  727. " VMS_CTLR_ID, \r\n"
  728. " VMS_CTLR_ID, \r\n"
  729. " VMS_NM, \r\n"
  730. " VMS_CTLR_IP, \r\n"
  731. " VMS_CTLR_PORT, \r\n"
  732. " VMS_CTLR_LOCAL_NO, \r\n"
  733. " VMS_MODL_KIND, \r\n"
  734. " ISTL_LCTN_NM, \r\n"
  735. " X_CRDN, \r\n"
  736. " Y_CRDN, \r\n"
  737. " DEL_YN, \r\n"
  738. " WEB_CMRA_IP, \r\n"
  739. " WEB_CMRA_PORT, \r\n"
  740. " WEB_CMRA_ID, \r\n"
  741. " WEB_CMRA_PWD, \r\n"
  742. " STRM_SESN_NM, \r\n"
  743. " VMS_MAX_PHSE_NUM, \r\n"
  744. " VMS_OFF_HM, \r\n"
  745. " VMS_OFF_HM, \r\n"
  746. " ISTL_LCTN_ADDR \r\n"
  747. " ) \r\n"
  748. " VALUES ( \r\n"
  749. " M.VMS_CTLR_ID, \r\n"
  750. " M.VMS_CTLR_ID, \r\n"
  751. " M.VMS_NM, \r\n"
  752. " M.VMS_CTLR_IP, \r\n"
  753. " M.VMS_CTLR_PORT, \r\n"
  754. " M.VMS_CTLR_LOCAL_NO, \r\n"
  755. " M.VMS_MODL_KIND, \r\n"
  756. " M.ISTL_LCTN_NM, \r\n"
  757. " M.X_CRDN, \r\n"
  758. " M.Y_CRDN, \r\n"
  759. " M.DEL_YN, \r\n"
  760. " M.WEB_CMRA_IP, \r\n"
  761. " M.WEB_CMRA_PORT, \r\n"
  762. " M.WEB_CMRA_ID, \r\n"
  763. " M.WEB_CMRA_PWD, \r\n"
  764. " M.STRM_SESN_NM, \r\n"
  765. " M.VMS_MAX_PHSE_NUM, \r\n"
  766. " M.VMS_OFF_HM, \r\n"
  767. " M.VMS_OFF_HM, \r\n"
  768. " M.ISTL_LCTN_ADDR \r\n"
  769. " ) \r\n";
  770. try
  771. {
  772. try
  773. {
  774. pADO = new TADOQuery(NULL);
  775. pADO->Close();
  776. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  777. pADO->SQL->Clear();
  778. pADO->SQL->Text = sQry;
  779. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  780. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_CTLR_ID;
  781. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  782. pADO->Parameters->ParamByName("p04")->Value = AObj->VMS_CTLR_IP;
  783. pADO->Parameters->ParamByName("p05")->Value = AObj->VMS_CTLR_PORT;
  784. pADO->Parameters->ParamByName("p06")->Value = AObj->CMNC_PORT;
  785. pADO->Parameters->ParamByName("p07")->Value = AObj->VMS_MODL_KIND;
  786. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  787. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  788. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  789. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  790. pADO->Parameters->ParamByName("p12")->Value = AObj->WEB_CMRA_IP;
  791. pADO->Parameters->ParamByName("p13")->Value = AObj->WEB_CMRA_PORT;
  792. pADO->Parameters->ParamByName("p14")->Value = AObj->WEB_CMRA_ID;
  793. pADO->Parameters->ParamByName("p15")->Value = AObj->WEB_CMRA_PWD;
  794. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_SESN_NM;
  795. pADO->Parameters->ParamByName("p17")->Value = AObj->VMS_MAX_PHSE_NUM;
  796. pADO->Parameters->ParamByName("p18")->Value = AObj->VMS_ON_HM;
  797. pADO->Parameters->ParamByName("p19")->Value = AObj->VMS_OFF_HM;
  798. pADO->Parameters->ParamByName("p20")->Value = AObj->ISTL_LCTN_ADDR;
  799. pADO->ExecSQL();
  800. return MergeFcltInfo(AObj, ADbConn);
  801. }
  802. catch(EDatabaseError &E)
  803. {
  804. DBERRORMSG("TVmsCtlrManager::MergeVms", String(E.ClassName()), E.Message, sQry);
  805. throw Exception(String(E.ClassName()) + E.Message);
  806. }
  807. catch(Exception &e)
  808. {
  809. DBERRORMSG("TVmsCtlrManager::MergeVms", String(e.ClassName()), e.Message, sQry);
  810. throw Exception(String(e.ClassName()) + e.Message);
  811. }
  812. }
  813. __finally
  814. {
  815. if (pADO)
  816. {
  817. pADO->Close();
  818. delete pADO;
  819. }
  820. }
  821. #endif
  822. return true;
  823. }
  824. //---------------------------------------------------------------------------
  825. bool TVmsCtlrManager::MergeFcltInfo(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  826. {
  827. String sQry;
  828. TADOQuery *pADO = NULL;
  829. #if 0
  830. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  831. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  832. " :p02 AS FCLT_TYPE, \r\n"
  833. " :p03 AS FCLT_LCTN \r\n"
  834. " FROM DUAL) M \r\n"
  835. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  836. "WHEN MATCHED \r\n"
  837. "THEN \r\n"
  838. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  839. " L.DEL_YN = 'N' \r\n"
  840. "WHEN NOT MATCHED \r\n"
  841. "THEN \r\n"
  842. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  843. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  844. try
  845. {
  846. try
  847. {
  848. pADO = new TADOQuery(NULL);
  849. pADO->Close();
  850. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  851. pADO->SQL->Clear();
  852. pADO->SQL->Text = sQry;
  853. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  854. pADO->Parameters->ParamByName("p02")->Value = "VMS";
  855. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  856. pADO->ExecSQL();
  857. return true;
  858. }
  859. catch(EDatabaseError &E)
  860. {
  861. DBERRORMSG("TVmsCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  862. throw Exception(String(E.ClassName()) + E.Message);
  863. }
  864. catch(Exception &e)
  865. {
  866. DBERRORMSG("TVmsCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  867. throw Exception(String(e.ClassName()) + e.Message);
  868. }
  869. }
  870. __finally
  871. {
  872. if (pADO)
  873. {
  874. pADO->Close();
  875. delete pADO;
  876. }
  877. }
  878. #endif
  879. return true;
  880. }
  881. //---------------------------------------------------------------------------
  882. bool TVmsCtlrManager::GetNextVmsId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  883. {
  884. String sQry;
  885. TADOQuery *pADO = NULL;
  886. #if 0
  887. sQry = "SELECT NVL(MAX(VMS_CTLR_ID), 10000) + 1 AS NEWID FROM TB_VMS_CTLR \r\n";
  888. try
  889. {
  890. try
  891. {
  892. pADO = new TADOQuery(NULL);
  893. pADO->Close();
  894. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  895. pADO->SQL->Clear();
  896. pADO->SQL->Text = sQry;
  897. pADO->Prepared = true;
  898. pADO->Open();
  899. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  900. AId = ANmbr / 10000;
  901. return true;
  902. }
  903. catch(EDatabaseError &E)
  904. {
  905. DBERRORMSG("VmsCtlrManager::GetNextVmsId", String(E.ClassName()), E.Message, sQry);
  906. throw Exception(String(E.ClassName()) + E.Message);
  907. }
  908. catch(Exception &e)
  909. {
  910. DBERRORMSG("VmsCtlrManager::GetNextVmsId", String(e.ClassName()), e.Message, sQry);
  911. throw Exception(String(e.ClassName()) + e.Message);
  912. }
  913. }
  914. __finally
  915. {
  916. if (pADO)
  917. {
  918. pADO->Close();
  919. delete pADO;
  920. }
  921. }
  922. #endif
  923. return false;
  924. }
  925. //---------------------------------------------------------------------------
  926. bool TVmsCtlrManager::UpdateCtlrInfo(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  927. {
  928. String sQry;
  929. TADOQuery *pADO = NULL;
  930. sQry = "UPDATE TB_VMS_CTLR \r\n"
  931. " SET VMS_ON_HM = :p01, \r\n"
  932. " VMS_OFF_HM = :p02 \r\n"
  933. " WHERE USE_YN = 'Y' \r\n";
  934. try
  935. {
  936. try
  937. {
  938. pADO = new TADOQuery(NULL);
  939. pADO->Close();
  940. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  941. pADO->SQL->Clear();
  942. pADO->SQL->Text = sQry;
  943. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_ON_HM;
  944. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_ON_HM;
  945. pADO->ExecSQL();
  946. return true;
  947. }
  948. catch(EDatabaseError &E)
  949. {
  950. DBERRORMSG("TVmsCtlrManager::UpdateCtlrInfo", String(E.ClassName()), E.Message, sQry);
  951. throw Exception(String(E.ClassName()) + E.Message);
  952. }
  953. catch(Exception &e)
  954. {
  955. DBERRORMSG("TVmsCtlrManager::UpdateCtlrInfo", String(e.ClassName()), e.Message, sQry);
  956. throw Exception(String(e.ClassName()) + e.Message);
  957. }
  958. }
  959. __finally
  960. {
  961. if (pADO)
  962. {
  963. pADO->Close();
  964. delete pADO;
  965. }
  966. }
  967. return true;
  968. }
  969. //---------------------------------------------------------------------------
  970. bool TVmsCtlrManager::UpdateIfscCngsSpeedInfo(int ACngsSpd, TADOConnection *ADbConn/*=NULL*/)
  971. {
  972. String sQry;
  973. TADOQuery *pADO = NULL;
  974. #if 0
  975. sQry = "UPDATE TB_VMS_RLTN_IFSC \r\n"
  976. " SET CNGS_CNFM_SPED = :p01 \r\n";
  977. try
  978. {
  979. try
  980. {
  981. String sGradCd;
  982. pADO = new TADOQuery(NULL);
  983. pADO->Close();
  984. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  985. pADO->SQL->Clear();
  986. pADO->SQL->Text = sQry;
  987. pADO->Parameters->ParamByName("p01")->Value = ACngsSpd;
  988. pADO->ExecSQL();
  989. return true;
  990. }
  991. catch(EDatabaseError &E)
  992. {
  993. DBERRORLOG("TVmsCtlrManager::UpdateIfscCngsSpeedInfo", String(E.ClassName()), E.Message, sQry);
  994. throw Exception(String(E.ClassName()) + E.Message);
  995. }
  996. catch(Exception &e)
  997. {
  998. DBERRORLOG("TVmsCtlrManager::UpdateIfscCngsSpeedInfo", String(e.ClassName()), e.Message, sQry);
  999. throw Exception(String(e.ClassName()) + e.Message);
  1000. }
  1001. }
  1002. __finally
  1003. {
  1004. if (pADO)
  1005. {
  1006. pADO->Close();
  1007. delete pADO;
  1008. }
  1009. }
  1010. #endif
  1011. return true;
  1012. }
  1013. //---------------------------------------------------------------------------
  1014. bool TVmsCtlrManager::LoadIfscRltn(TADOConnection *ADbConn/*=NULL*/)
  1015. {
  1016. String sQry;
  1017. TADOQuery *pADO = NULL;
  1018. #if 0
  1019. FLists.Lock();
  1020. try
  1021. {
  1022. FOR_STL(TVmsCtlr*, pObj, FLists)
  1023. {
  1024. pObj->FIfscRltn.RemoveAll();
  1025. }
  1026. }
  1027. __finally
  1028. {
  1029. FLists.UnLock();
  1030. }
  1031. sQry = "SELECT A.VMS_CTLR_ID, B.VMS_IFSC_ID, B.DSPL_PRRT, \r\n"
  1032. " B.CNGS_CNFM_YN, B.CNGS_CNFM_SPED \r\n"
  1033. " FROM TB_VMS_CTLR A, \r\n"
  1034. " TB_VMS_RLTN_IFSC B, \r\n"
  1035. " TB_VMS_IFSC C \r\n"
  1036. " WHERE A.VMS_CTLR_ID = B.VMS_CTLR_ID \r\n"
  1037. " AND B.VMS_IFSC_ID = C.VMS_IFSC_ID \r\n"
  1038. " ORDER BY A.VMS_CTLR_ID, B.DSPL_PRRT \r\n";
  1039. FLists.Lock();
  1040. try
  1041. {
  1042. String VMS_CTLR_ID;
  1043. try
  1044. {
  1045. pADO = new TADOQuery(NULL);
  1046. pADO->Close();
  1047. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1048. pADO->SQL->Clear();
  1049. pADO->SQL->Text = sQry;
  1050. pADO->Prepared = true;
  1051. pADO->Open();
  1052. for( ; !pADO->Eof; pADO->Next())
  1053. {
  1054. VMS_CTLR_ID = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  1055. TVmsCtlr *pVms = FLists.Find(String(VMS_CTLR_ID));
  1056. if (!pVms) continue;
  1057. TVmsIfscRltn *pObj = new TVmsIfscRltn();
  1058. if (pObj)
  1059. {
  1060. pObj->VMS_CTLR_ID = VMS_CTLR_ID;
  1061. pObj->VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsInteger;
  1062. pObj->DSPL_PRRT = pADO->FieldByName("DSPL_PRRT")->AsInteger;
  1063. pObj->CNGS_CNFM_YN = pADO->FieldByName("CNGS_CNFM_YN")->AsString;
  1064. pObj->CNGS_CNFM_SPED= pADO->FieldByName("CNGS_CNFM_SPED")->AsInteger;
  1065. pVms->FIfscRltn.Push(pObj->DSPL_PRRT, pObj);
  1066. }
  1067. }
  1068. }
  1069. catch(EDatabaseError &E)
  1070. {
  1071. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(E.ClassName()), E.Message, sQry);
  1072. throw Exception(String(E.ClassName()) + E.Message);
  1073. }
  1074. catch(Exception &e)
  1075. {
  1076. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(e.ClassName()), e.Message, sQry);
  1077. throw Exception(String(e.ClassName()) + e.Message);
  1078. }
  1079. }
  1080. __finally
  1081. {
  1082. if (pADO)
  1083. {
  1084. pADO->Close();
  1085. delete pADO;
  1086. }
  1087. FLists.UnLock();
  1088. }
  1089. #endif
  1090. return true;
  1091. }
  1092. //---------------------------------------------------------------------------
  1093. bool TVmsCtlrManager::LoadEvspRltn(TADOConnection *ADbConn/*=NULL*/)
  1094. {
  1095. String sQry;
  1096. TADOQuery *pADO = NULL;
  1097. #if 0
  1098. FLists.Lock();
  1099. try
  1100. {
  1101. FOR_STL(TVmsCtlr*, pObj, FLists)
  1102. {
  1103. pObj->FEvspRltn.RemoveAll();
  1104. }
  1105. }
  1106. __finally
  1107. {
  1108. FLists.UnLock();
  1109. }
  1110. sQry = "SELECT A.VMS_CTLR_ID, B.VMS_EVSP_ID, B.DSPL_PRRT, \r\n"
  1111. " B.CNGS_CNFM_YN, B.CNGS_CNFM_SPED \r\n"
  1112. " FROM TB_VMS_CTLR A, \r\n"
  1113. " TB_VMS_RLTN_EVSP B, \r\n"
  1114. " TB_VMS_EVSP C \r\n"
  1115. " WHERE A.VMS_CTLR_ID = B.VMS_CTLR_ID \r\n"
  1116. " AND B.VMS_EVSP_ID = C.VMS_EVSP_ID \r\n"
  1117. " ORDER BY A.VMS_CTLR_ID, B.DSPL_PRRT \r\n";
  1118. FLists.Lock();
  1119. try
  1120. {
  1121. String VMS_CTLR_ID;
  1122. try
  1123. {
  1124. pADO = new TADOQuery(NULL);
  1125. pADO->Close();
  1126. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1127. pADO->SQL->Clear();
  1128. pADO->SQL->Text = sQry;
  1129. pADO->Prepared = true;
  1130. pADO->Open();
  1131. for( ; !pADO->Eof; pADO->Next())
  1132. {
  1133. VMS_CTLR_ID = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  1134. TVmsCtlr *pVms = FLists.Find(String(VMS_CTLR_ID));
  1135. if (!pVms) continue;
  1136. TVmsEvspRltn *pObj = new TVmsEvspRltn();
  1137. if (pObj)
  1138. {
  1139. pObj->VMS_CTLR_ID = VMS_CTLR_ID;
  1140. pObj->VMS_EVSP_ID = pADO->FieldByName("VMS_EVSP_ID")->AsInteger;
  1141. pObj->DSPL_PRRT = pADO->FieldByName("DSPL_PRRT")->AsInteger;
  1142. pObj->CNGS_CNFM_YN = pADO->FieldByName("CNGS_CNFM_YN")->AsString;
  1143. pObj->CNGS_CNFM_SPED= pADO->FieldByName("CNGS_CNFM_SPED")->AsInteger;
  1144. pVms->FEvspRltn.Push(pObj->DSPL_PRRT, pObj);
  1145. }
  1146. }
  1147. }
  1148. catch(EDatabaseError &E)
  1149. {
  1150. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(E.ClassName()), E.Message, sQry);
  1151. throw Exception(String(E.ClassName()) + E.Message);
  1152. }
  1153. catch(Exception &e)
  1154. {
  1155. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(e.ClassName()), e.Message, sQry);
  1156. throw Exception(String(e.ClassName()) + e.Message);
  1157. }
  1158. }
  1159. __finally
  1160. {
  1161. if (pADO)
  1162. {
  1163. pADO->Close();
  1164. delete pADO;
  1165. }
  1166. FLists.UnLock();
  1167. }
  1168. #endif
  1169. return true;
  1170. }
  1171. //---------------------------------------------------------------------------
  1172. bool TVmsCtlrManager::SaveIfscRltn(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1173. {
  1174. String sQry;
  1175. TADOQuery *pADO = NULL;
  1176. int ii;
  1177. #if 0
  1178. try
  1179. {
  1180. try
  1181. {
  1182. pADO = new TADOQuery(NULL);
  1183. pADO->Close();
  1184. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1185. sQry = "DELETE FROM TB_VMS_RLTN_IFSC WHERE VMS_CTLR_ID = :p01";
  1186. pADO->SQL->Clear();
  1187. pADO->SQL->Text = sQry;
  1188. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  1189. pADO->ExecSQL();
  1190. sQry = "INSERT INTO TB_VMS_RLTN_IFSC(VMS_CTLR_ID, VMS_IFSC_ID, DSPL_PRRT, CNGS_CNFM_YN, CNGS_CNFM_SPED) VALUES(:p01, :p02, :p03, :p04, :p05)";
  1191. ii = 0;
  1192. pADO->SQL->Clear();
  1193. pADO->SQL->Text = sQry;
  1194. FOR_STL(TVmsIfscRltn *, pLink, AObj->FIfscRltn)
  1195. {
  1196. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  1197. pADO->Parameters->ParamByName("p02")->Value = pLink->VMS_IFSC_ID;
  1198. pADO->Parameters->ParamByName("p03")->Value = String(ii+1);
  1199. pADO->Parameters->ParamByName("p04")->Value = pLink->CNGS_CNFM_YN;
  1200. pADO->Parameters->ParamByName("p05")->Value = pLink->CNGS_CNFM_SPED;
  1201. pADO->ExecSQL();
  1202. ii++;
  1203. }
  1204. return true;
  1205. }
  1206. catch(EDatabaseError &E)
  1207. {
  1208. DBERRORMSG("TVmsCtlrManager::SaveIfscRltn", String(E.ClassName()), E.Message, sQry);
  1209. throw Exception(String(E.ClassName()) + E.Message);
  1210. }
  1211. catch(Exception &e)
  1212. {
  1213. DBERRORMSG("TVmsCtlrManager::SaveIfscRltn", String(e.ClassName()), e.Message, sQry);
  1214. throw Exception(String(e.ClassName()) + e.Message);
  1215. }
  1216. }
  1217. __finally
  1218. {
  1219. if (pADO)
  1220. {
  1221. pADO->Close();
  1222. delete pADO;
  1223. }
  1224. }
  1225. #endif
  1226. return true;
  1227. }
  1228. //---------------------------------------------------------------------------
  1229. bool TVmsCtlrManager::SaveEvspRltn(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1230. {
  1231. String sQry;
  1232. TADOQuery *pADO = NULL;
  1233. int ii;
  1234. #if 0
  1235. try
  1236. {
  1237. try
  1238. {
  1239. pADO = new TADOQuery(NULL);
  1240. pADO->Close();
  1241. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1242. sQry = "DELETE FROM TB_VMS_RLTN_EVSP WHERE VMS_CTLR_ID = :p01";
  1243. pADO->SQL->Clear();
  1244. pADO->SQL->Text = sQry;
  1245. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  1246. pADO->ExecSQL();
  1247. sQry = "INSERT INTO TB_VMS_RLTN_EVSP(VMS_CTLR_ID, VMS_EVSP_ID, DSPL_PRRT, CNGS_CNFM_YN, CNGS_CNFM_SPED) VALUES(:p01, :p02, :p03, :p04, :p05)";
  1248. ii = 0;
  1249. pADO->SQL->Clear();
  1250. pADO->SQL->Text = sQry;
  1251. FOR_STL(TVmsEvspRltn *, pLink, AObj->FEvspRltn)
  1252. {
  1253. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  1254. pADO->Parameters->ParamByName("p02")->Value = pLink->VMS_EVSP_ID;
  1255. pADO->Parameters->ParamByName("p03")->Value = String(ii+1);
  1256. pADO->Parameters->ParamByName("p04")->Value = pLink->CNGS_CNFM_YN;
  1257. pADO->Parameters->ParamByName("p05")->Value = pLink->CNGS_CNFM_SPED;
  1258. pADO->ExecSQL();
  1259. ii++;
  1260. }
  1261. return true;
  1262. }
  1263. catch(EDatabaseError &E)
  1264. {
  1265. DBERRORMSG("TVmsCtlrManager::SaveEvspRltn", String(E.ClassName()), E.Message, sQry);
  1266. throw Exception(String(E.ClassName()) + E.Message);
  1267. }
  1268. catch(Exception &e)
  1269. {
  1270. DBERRORMSG("TVmsCtlrManager::SaveEvspRltn", String(e.ClassName()), e.Message, sQry);
  1271. throw Exception(String(e.ClassName()) + e.Message);
  1272. }
  1273. }
  1274. __finally
  1275. {
  1276. if (pADO)
  1277. {
  1278. pADO->Close();
  1279. delete pADO;
  1280. }
  1281. }
  1282. #endif
  1283. return true;
  1284. }
  1285. //---------------------------------------------------------------------------
  1286. bool TVmsCtlrManager::LoadVmsMsg(TADOConnection *ADbConn/*=NULL*/)
  1287. {
  1288. String sQry;
  1289. TADOQuery *pADO = NULL;
  1290. sQry = "SELECT A.*, \r\n"
  1291. " TO_CHAR(SYSDATE - 8/1440, 'YYYYMMDDHH24MISS') AS SVC_DT \r\n"
  1292. " FROM TB_VMS_DSPL_PRST A, \r\n"
  1293. " (SELECT VMS_CTLR_ID, MAX(DSPL_DT) AS DSPL_DT \r\n"
  1294. " FROM TB_VMS_DSPL_PRST \r\n"
  1295. " GROUP BY VMS_CTLR_ID) B \r\n"
  1296. " WHERE A.VMS_CTLR_ID = B.VMS_CTLR_ID \r\n"
  1297. " AND A.DSPL_DT = B.DSPL_DT \r\n"
  1298. " ORDER BY A.VMS_CTLR_ID, A.PHASE \r\n";
  1299. FLists.Lock();
  1300. try
  1301. {
  1302. FOR_STL(TVmsCtlr*, pTmpObj, FLists)
  1303. {
  1304. //pTmpObj->Lock();
  1305. pTmpObj->VmsMsg->Init();
  1306. //pTmpObj->UnLock();
  1307. }
  1308. }
  1309. __finally
  1310. {
  1311. FLists.UnLock();
  1312. }
  1313. TVmsCtlr *pObj = NULL;
  1314. String sOldVmsNmbr = "";
  1315. int nPhase = 0;
  1316. try
  1317. {
  1318. try
  1319. {
  1320. pADO = new TADOQuery(NULL);
  1321. pADO->Close();
  1322. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1323. pADO->SQL->Clear();
  1324. pADO->SQL->Text = sQry;
  1325. pADO->Prepared = true;
  1326. pADO->Open();
  1327. for( ; !pADO->Eof; pADO->Next())
  1328. {
  1329. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  1330. if (sVmsNmbr != sOldVmsNmbr)
  1331. {
  1332. if (pObj)
  1333. {
  1334. pObj->VmsMsg->Total = nPhase;
  1335. pObj->VmsMsg->Curr = 0;
  1336. pObj->VmsMsg->IsLoading = false;
  1337. //pObj->UnLock();
  1338. }
  1339. pObj = FLists.Find(sVmsNmbr);
  1340. if (pObj)
  1341. {
  1342. //pObj->Lock();
  1343. nPhase = 0;
  1344. sOldVmsNmbr = sVmsNmbr;
  1345. }
  1346. else continue;
  1347. }
  1348. if (!pObj) continue;
  1349. if (nPhase >= INT_VMS_MAX_FORM) continue;
  1350. SAFE_DELETE(FImgStream);
  1351. FImgStream = pADO->CreateBlobStream(pADO->FieldByName("VMS_DSPL_MSG_IMAG"), bmRead);
  1352. if (FImgStream && FImgStream->Size > 0)
  1353. {
  1354. try
  1355. {
  1356. if (!pObj->VmsMsg->PHASE[nPhase].pVmsBmp)
  1357. {
  1358. pObj->VmsMsg->PHASE[nPhase].pVmsBmp = new Graphics::TBitmap();
  1359. }
  1360. pObj->VmsMsg->PHASE[nPhase].pVmsBmp->FreeImage();
  1361. pObj->VmsMsg->PHASE[nPhase].pVmsBmp->LoadFromStream(FImgStream);
  1362. int PHASE = pADO->FieldByName("PHASE")->AsInteger;
  1363. pObj->VmsMsg->PHASE[nPhase].DSPL_HH = pADO->FieldByName("DSPL_HH")->AsInteger;
  1364. pObj->VmsMsg->PHASE[nPhase].DNLD_YN = pADO->FieldByName("DNLD_YN")->AsString;
  1365. pObj->VmsMsg->PHASE[nPhase].DSPL_CD = pADO->FieldByName("VMS_FORM_DSPL_MTHD_CD")->AsString;
  1366. pObj->VmsMsg->PHASE[nPhase].VMS_SCH_FORM_TYPE = pADO->FieldByName("VMS_SCH_FORM_TYPE")->AsInteger;
  1367. if (pObj->VmsMsg->PHASE[nPhase].VMS_SCH_FORM_TYPE == eSchTp_video ||
  1368. pObj->VmsMsg->PHASE[nPhase].VMS_SCH_FORM_TYPE == eSchTp_stream )
  1369. {
  1370. pObj->VmsMsg->PHASE[nPhase].VMS_DSPL_MSG_TXT = pADO->FieldByName("VMS_DSPL_MSG_TXT")->AsString.Trim();
  1371. }
  1372. if (pObj->VmsMsg->PHASE[nPhase].DSPL_HH <= 0) pObj->VmsMsg->PHASE[nPhase].DSPL_HH = 3;
  1373. //if (pObj->VmsMsg->PHASE[nPhase].DSPL_HH >= 10) pObj->VmsMsg->PHASE[nPhase].DSPL_HH = 10;
  1374. String DSPL_DT = pADO->FieldByName("DSPL_DT")->AsString;
  1375. String SVC_DT = pADO->FieldByName("SVC_DT")->AsString;
  1376. pObj->VmsMsg->OFFER_DT = DSPL_DT;
  1377. if (DSPL_DT >= SVC_DT)
  1378. {
  1379. pObj->VmsMsg->OFFER_YN = true;
  1380. }
  1381. else
  1382. {
  1383. pObj->VmsMsg->OFFER_YN = false;
  1384. }
  1385. if (pObj->VmsMsg->PHASE[nPhase].DNLD_YN == "N")
  1386. {
  1387. pObj->VmsMsg->OFFER_YN = false;
  1388. }
  1389. //TODO
  1390. if (pObj->STATE.Comm != vms_comm_normal)
  1391. {
  1392. pObj->VmsMsg->OFFER_YN = false;
  1393. }
  1394. nPhase++;
  1395. }
  1396. catch(Exception &e)
  1397. {
  1398. }
  1399. }
  1400. }
  1401. if (pObj)
  1402. {
  1403. pObj->VmsMsg->Total = nPhase;
  1404. pObj->VmsMsg->Curr = 0;
  1405. //pObj->UnLock();
  1406. }
  1407. }
  1408. catch(EDatabaseError &E)
  1409. {
  1410. DBERRORMSG("TVmsCtlrManager::LoadVmsMsg", String(E.ClassName()), E.Message, sQry);
  1411. throw Exception(String(E.ClassName()) + E.Message);
  1412. }
  1413. catch(Exception &e)
  1414. {
  1415. DBERRORMSG("TVmsCtlrManager::LoadVmsMsg", String(e.ClassName()), e.Message, sQry);
  1416. throw Exception(String(e.ClassName()) + e.Message);
  1417. }
  1418. }
  1419. __finally
  1420. {
  1421. if (pADO)
  1422. {
  1423. pADO->Close();
  1424. delete pADO;
  1425. }
  1426. }
  1427. return true;
  1428. }
  1429. //---------------------------------------------------------------------------
  1430. bool TVmsCtlrManager::LoadVmsFormUsage(TADOConnection *ADbConn/*=NULL*/)
  1431. {
  1432. InitFormCount();
  1433. String sQry;
  1434. TADOQuery *pADO = NULL;
  1435. sQry = "SELECT A.VMS_CTLR_ID, \r\n"
  1436. " A.VMS_SCH_TYPE, \r\n"
  1437. " A.VMS_SCH_FORM_TYPE, \r\n"
  1438. " A.DSPL_STRT_HH, \r\n"
  1439. " A.DSPL_END_HH, \r\n"
  1440. " TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') AS CURR_HH, \r\n"
  1441. " A.USE_YN \r\n"
  1442. " FROM TB_VMS_DSPL_SCH A, \r\n"
  1443. " TB_VMS_FORM B \r\n"
  1444. " WHERE 1=1 \r\n"
  1445. " AND A.VMS_FORM_ID = B.VMS_FORM_ID \r\n";
  1446. // " AND B.VALID_YN = 'Y' \r\n"
  1447. try
  1448. {
  1449. try
  1450. {
  1451. pADO = new TADOQuery(NULL);
  1452. pADO->Close();
  1453. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1454. ITSDb_SQLText(pADO, sQry);
  1455. ITSDb_SQLOpen(pADO);
  1456. TVmsCtlr *pObj;
  1457. int nSchType, nFormType;
  1458. for( ; !pADO->Eof; pADO->Next())
  1459. {
  1460. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_ID")->AsString;
  1461. pObj = FLists.Find(sVmsNmbr);
  1462. if (!pObj) continue;
  1463. String sSchType = pADO->FieldByName("VMS_SCH_TYPE")->AsString.Trim();
  1464. if (sSchType == "A") nSchType = enScheduleAuto;
  1465. else if (sSchType == "F") nSchType = enScheduleFix;
  1466. else if (sSchType == "B") nSchType = enScheduleBase;
  1467. else continue;
  1468. nFormType = pADO->FieldByName("VMS_SCH_FORM_TYPE")->AsInteger;
  1469. if (nFormType < eSchTp_traffic && nFormType >= eSchTp_max) continue;
  1470. pObj->FormCnt[nSchType].Total[nFormType]++; //등록되어있는 전체 폼 숫자
  1471. if (pADO->FieldByName("USE_YN")->AsString != 'Y') continue;
  1472. //사용하는 것중에 현재시각이 제공시각안에 들어있는것은 카운트하지 않음.
  1473. String sStrHH = pADO->FieldByName("DSPL_STRT_HH")->AsString;
  1474. String sEndHH = pADO->FieldByName("DSPL_END_HH")->AsString;
  1475. String sCurHH = pADO->FieldByName("CURR_HH")->AsString;
  1476. if (sCurHH >= sStrHH && sCurHH <= sEndHH)
  1477. {
  1478. if (nFormType >= eSchTp_traffic && nFormType < eSchTp_max) {
  1479. pObj->FormCnt[nSchType].Use[nFormType]++; //사용가능 폼 숫자
  1480. }
  1481. }
  1482. }
  1483. }
  1484. catch(EDatabaseError &E)
  1485. {
  1486. DBERRORMSG("TVmsCtlrManager::LoadVmsFormUsage", String(E.ClassName()), E.Message, sQry);
  1487. throw Exception(String(E.ClassName()) + E.Message);
  1488. }
  1489. catch(Exception &e)
  1490. {
  1491. DBERRORMSG("TVmsCtlrManager::LoadVmsFormUsage", String(e.ClassName()), e.Message, sQry);
  1492. throw Exception(String(e.ClassName()) + e.Message);
  1493. }
  1494. }
  1495. __finally
  1496. {
  1497. if (pADO)
  1498. {
  1499. pADO->Close();
  1500. delete pADO;
  1501. }
  1502. }
  1503. return true;
  1504. }
  1505. //---------------------------------------------------------------------------
  1506. bool TVmsCtlrManager::InsVmsControlHs(String ACtlDt, String AVmsNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
  1507. {
  1508. String sQry;
  1509. TADOQuery *pADO = NULL;
  1510. sQry = "INSERT INTO TB_VMS_CTRL_HS( \r\n"
  1511. " CTRL_DT, \r\n"
  1512. " VMS_CTLR_ID, \r\n"
  1513. " CTRL_TYPE, \r\n"
  1514. " CTRL_VAL, \r\n"
  1515. " CTRL_RESULT, \r\n"
  1516. " USER_ID \r\n"
  1517. " ) \r\n"
  1518. " VALUES( \r\n"
  1519. " :p01, \r\n"
  1520. " :p02, \r\n"
  1521. " :p03, \r\n"
  1522. " :p04, \r\n"
  1523. " :p05, \r\n"
  1524. " :p06 \r\n"
  1525. " ) \r\n";
  1526. try
  1527. {
  1528. try
  1529. {
  1530. pADO = new TADOQuery(NULL);
  1531. pADO->Close();
  1532. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1533. pADO->SQL->Clear();
  1534. pADO->SQL->Text = sQry;
  1535. pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
  1536. pADO->Parameters->ParamByName("p02")->Value = AVmsNmbr;
  1537. pADO->Parameters->ParamByName("p03")->Value = ACtlType;
  1538. pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
  1539. pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
  1540. pADO->Parameters->ParamByName("p06")->Value = AUserId;
  1541. pADO->ExecSQL();
  1542. return true;
  1543. }
  1544. catch(EDatabaseError &E)
  1545. {
  1546. DBERRORMSG("TVmsCtlrManager::InsVmsControlHs", String(E.ClassName()), E.Message, sQry);
  1547. throw Exception(String(E.ClassName()) + E.Message);
  1548. }
  1549. catch(Exception &e)
  1550. {
  1551. DBERRORMSG("TVmsCtlrManager::InsVmsControlHs", String(e.ClassName()), e.Message, sQry);
  1552. throw Exception(String(e.ClassName()) + e.Message);
  1553. }
  1554. }
  1555. __finally
  1556. {
  1557. if (pADO)
  1558. {
  1559. pADO->Close();
  1560. delete pADO;
  1561. }
  1562. }
  1563. return true;
  1564. }
  1565. //---------------------------------------------------------------------------
  1566. int VmsGetFormTypeIdx(int AFormType)
  1567. {
  1568. int nFormTypeIdx = -1;
  1569. switch(AFormType)
  1570. {
  1571. case eFormTp_traf_1: // 소통상황(1단)
  1572. case eFormTp_traf_2: // 소통상황(2단)
  1573. case eFormTp_traf_3: // 소통상황(3단)
  1574. case eFormTp_traf_4: // 소통상황(4단)
  1575. case eFormtp_figure: // 소통상황(도형식배경소통정보)
  1576. nFormTypeIdx = eSchTp_traffic;
  1577. break;
  1578. case eFormTp_congest: // 정체소통상황
  1579. nFormTypeIdx = eSchTp_congest;
  1580. break;
  1581. case eFormTp_incident: // 돌발문안
  1582. nFormTypeIdx = eSchTp_incident;
  1583. break;
  1584. case eFormTp_gongsa: // 공사/행사문안
  1585. nFormTypeIdx = eSchTp_gongsa;
  1586. break;
  1587. case eFormTp_hongbo: // 홍보문안
  1588. nFormTypeIdx = eSchTp_hongbo;
  1589. break;
  1590. case eFormTp_deture: // 우회도로
  1591. nFormTypeIdx = eSchTp_deture;
  1592. break;
  1593. case eFormTp_safe: // 재난안전
  1594. nFormTypeIdx = eSchTp_safe;
  1595. break;
  1596. case eFormTp_video: // 동영상
  1597. nFormTypeIdx = eSchTp_video;
  1598. break;
  1599. case eFormTp_stream: // 스트리밍영상
  1600. nFormTypeIdx = eSchTp_stream;
  1601. break;
  1602. case eFormTp_atmp: // 대기환경
  1603. nFormTypeIdx = eSchTp_atmp;
  1604. break;
  1605. case eFormTp_park: // 주차정보
  1606. nFormTypeIdx = eSchTp_park;
  1607. break;
  1608. //TODO: 2023PRJ S
  1609. case eFormTp_evehicle: // 긴급차량우선신호
  1610. nFormTypeIdx = eSchTp_evehicle;
  1611. break;
  1612. //TODO: 2023PRJ E
  1613. default: break;
  1614. }
  1615. return nFormTypeIdx;
  1616. }