CDSVmsCtlrF.cpp 67 KB

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