CDSVmsCtlrF.cpp 62 KB

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