CDSVmsCtlrF.cpp 61 KB

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