CDSVmsCtlrF.cpp 62 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSVmsCtlrF.h"
  4. #include "ITS_OPLibF.h"
  5. #include "CDSFcltF.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. #if 0
  272. pObj->VMS_CTLR_PORT = pADO->FieldByName("VMS_CMNC_PORT")->AsString.Trim().ToIntDef(0); // N NUMBER(5) Y 0 VMS 제어기 포트
  273. pObj->VMS_CTLR_LOCAL_NO = pADO->FieldByName("VMS_ID")->AsInteger; // N NUMBER(5) Y 0 VMS 제어기 지역번호
  274. pObj->DEF_PHSE_CHNG_CYCL = pADO->FieldByName("VMS_PHSE_CHNG_CYCL")->AsInteger; // N NUMBER(3) Y 5 기본메시지주기
  275. pObj->FAN_MODE = pADO->FieldByName("FAN_MODE")->AsInteger; // N NUMBER(3) Y 2 FAN 동작모드(0x00:꺼짐,0x01:켜짐,0x02:자동,0x09:알수없음)
  276. pObj->FAN_RUN_TMPR = pADO->FieldByName("FAN_MTNS_TMPR")->AsInteger; // N NUMBER(3) Y 30 팬 동작 온도
  277. pObj->HETR_MODE = pADO->FieldByName("HETR_MODE")->AsInteger; // N NUMBER(3) Y 2 히터 동작모드(0x00:꺼짐,0x01:켜짐,0x02:자동,0x09:알수없음)
  278. pObj->HETR_RUN_TMPR = pADO->FieldByName("HETR_MTNS_TMPR")->AsInteger; // N NUMBER(3) Y 0 히터 동작 온도
  279. pObj->BRGH_CURR_STEP = pADO->FieldByName("BRGH_CURR_STEP")->AsInteger; // N NUMBER(3) Y 40 휘도 현재 단계(0~100)
  280. pObj->BRGH_WEEK_STEP = pADO->FieldByName("VMS_WEEK_BRGH_STEP")->AsString().Trim().ToIntDef(0); // N NUMBER(3) Y 64 휘도 주간 단계(0~100)
  281. pObj->BRGH_NGHT_STEP = pADO->FieldByName("VMS_NGHT_BRGH_STEP")->AsString().Trim().ToIntDef(0); // N NUMBER(3) Y 48 휘도 야간 단계(0~100)
  282. pObj->MODL_ERR_RATE = pADO->FieldByName("VMS_MODL_ERR_RATE")->AsInteger; // N NUMBER(3) Y 10 VMS 모듈 오류 율
  283. pObj->CMNC_FAIL_RATE = pADO->FieldByName("VMS_CMNC_ERR_BASS_VAL")->AsString().Trim().ToIntDef(0); // N NUMBER(3) Y 60 VMS 통신 오류 기본 값
  284. pObj->WEB_CMRA_CMPY = pADO->FieldByName("WEB_CMRA_CMPY")->AsString.Trim(); // N VARCHAR2(50) Y 웹카메라제조사(삼성카메라'Samsung')
  285. pObj->WEB_CMRA_MDL = pADO->FieldByName("WEB_CMRA_MDL")->AsString.Trim(); // N VARCHAR2(126) Y 웹카메라모델
  286. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 설치 위치 주소
  287. #else
  288. //pObj->VMS_CTLR_PORT = pADO->FieldByName("VMS_CMNC_PORT")->AsInteger; // N NUMBER(5) Y 0 VMS 제어기 포트
  289. pObj->VMS_CTLR_PORT = pADO->FieldByName("VMS_CMNC_PORT")->AsString.Trim().ToIntDef(0); // N NUMBER(5) Y 0 VMS 제어기 포트
  290. #endif
  291. pObj->VMS_TYPE_CD = pADO->FieldByName("VMS_TYPE_CD")->AsString.Trim(); // N VARCHAR2(7) Y VMS 유형 코드
  292. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim(); // N VARCHAR2(40) Y 설치 위치 명
  293. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat; // N NUMBER(11,8) Y X 좌표
  294. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat; // N NUMBER(10,8) Y Y 좌표
  295. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString.Trim(); // N CHAR(1) Y 'N' 삭제 여부
  296. pObj->WEB_CMRA_IP = pADO->FieldByName("WEB_CMRA_IP")->AsString.Trim(); // N VARCHAR2(20) Y 웹 카메라 아이피
  297. pObj->WEB_CMRA_PORT = pADO->FieldByName("WEB_CMRA_PORT")->AsString.Trim(); // N NUMBER(5) Y 웹카메라 포트
  298. pObj->WEB_CMRA_ID = pADO->FieldByName("WEB_CMRA_ID")->AsString.Trim(); // N VARCHAR2(20) Y 웹카메라 ID
  299. pObj->WEB_CMRA_PWD = pADO->FieldByName("WEB_CMRA_PWD")->AsString.Trim(); // N VARCHAR2(20) Y 웹카메라 비밀번호
  300. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim(); // N VARCHAR2(200) Y 스트리밍 세션 명
  301. pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString.Trim(); // N VARCHAR2(7) Y 'A' 운영 모드
  302. pObj->VMS_MAX_PHSE_NUM = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsInteger; // N NUMBER(2) Y 14 VMS 최대 표출면 개수
  303. pObj->PANL_ON_TIME = pADO->FieldByName("PANL_ON_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0400' 전광판 ON TIME
  304. pObj->PANL_OFF_TIME = pADO->FieldByName("PANL_OFF_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0200' 전광판 OFF TIME
  305. pObj->PANL_PWER_MODE = pADO->FieldByName("PANL_PWER_MODE")->AsInteger; // N NUMBER(3) Y 2 전광판 전원 모드(0x00:꺼짐,0x01:켜짐,0x02:자동,0x09:알수없음)
  306. pObj->BRGH_MODE = pADO->FieldByName("BRGH_MODE")->AsInteger; // N NUMBER(3) Y 2 휘도 모드(0x00:주간,0x01:야간,0x00:자동,0x09:알수없음)
  307. pObj->VMS_TYPE_NM = pADO->FieldByName("VMS_TYPE_NM")->AsString;
  308. pObj->WIDTH = pADO->FieldByName("VMS_WDTH")->AsString.Trim().ToIntDef(576);
  309. pObj->HEIGHT = pADO->FieldByName("VMS_HGHT")->AsString.Trim().ToIntDef(320);
  310. pObj->ROW_NUM = pADO->FieldByName("ROW_NUM")->AsInteger;
  311. pObj->COL_NUM = pADO->FieldByName("COL_NUM")->AsInteger;
  312. pObj->MODL_ROW_NUM = pADO->FieldByName("MODL_ROW_NUM")->AsInteger;
  313. pObj->MODL_COL_NUM = pADO->FieldByName("MODL_COL_NUM")->AsInteger;
  314. pObj->POWR_ROW_NUM = pADO->FieldByName("POWR_ROW_NUM")->AsInteger;
  315. pObj->POWR_COL_NUM = pADO->FieldByName("POWR_COL_NUM")->AsInteger;
  316. if (pObj->WIDTH > FMaxWidth) FMaxWidth = pObj->WIDTH;
  317. if (pObj->WIDTH < FMinWidth) FMinWidth = pObj->WIDTH;
  318. if (pObj->HEIGHT > FMaxHeight) FMaxHeight = pObj->HEIGHT;
  319. if (pObj->HEIGHT < FMinHeight) FMinHeight = pObj->HEIGHT;
  320. #if 0
  321. pObj->STATE.ScheduledMessageOperatingTime = pObj->VMS_PHSE_CHNG_CYCL; /* 필수 계획된 메시지의 동작시간(초) */
  322. pObj->STATE.ModuleOperatingTemperature = pObj->VMS_CMNC_ERR_BASS_VAL; /* 필수 모듈 전원이 꺼지는 온도값(℃) */
  323. pObj->STATE.FanOperatingTemperature = pObj->FAN_MTNS_TMPR; /* 필수 Fan 동작 기준 온도값(℃) */
  324. pObj->STATE.HeaterOperatingTemperature = pObj->HETR_MTNS_TMPR; /* 필수 Heater 동작 기준 온도값(℃) */
  325. pObj->STATE.ModuleBasicFailureRate = pObj->VMS_MODL_ERR_RATE; /* 선택 모듈 장애율 (한 개의 모듈을 장애로 처리하기 위한 픽셀의 백분율값) */
  326. #endif
  327. pObj->STRM_ADDR = pObj->STRM_SESN_NM;
  328. pObj->FULL_STRM_ADDR = "";
  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. #if 1
  389. sQry = "SELECT * \r\n"
  390. " FROM TB_VMS_CTLR_STTS A, TB_VMS_CTLR B \r\n"
  391. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  392. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n";
  393. #else
  394. sQry = "SELECT * \r\n"
  395. " FROM TB_VMS_STTS_PRST A, TB_VMS_CTLR B \r\n"
  396. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  397. " AND A.RGST_DT >= TO_CHAR(SYSDATE-5/1440, 'YYYYMMDDHH24MISS') \r\n";
  398. #endif
  399. FLists.Lock();
  400. try
  401. {
  402. TVmsCtlr *pObj = NULL;
  403. #if 0
  404. FOR_STL(TVmsCtlr*, pTmp, FLists)
  405. {
  406. pTmp->STATE.Comm = vms_comm_error;
  407. VmsInitStatus(&pTmp->STATE);
  408. pTmp->RunState = state_error;
  409. }
  410. #endif
  411. try
  412. {
  413. int nORD;
  414. pADO = new TADOQuery(NULL);
  415. pADO->Close();
  416. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  417. pADO->SQL->Clear();
  418. pADO->SQL->Text = sQry;
  419. pADO->Prepared = true;
  420. pADO->Open();
  421. //int nRows = pADO->RecordCount;
  422. for( ; !pADO->Eof; pADO->Next())
  423. {
  424. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  425. pObj = FLists.Find(sVmsNmbr);
  426. if (!pObj) continue;
  427. String UPDT_DT = pADO->FieldByName("UPDT_DT")->AsString;
  428. String CMNC_STTS_CD = pADO->FieldByName("CMNC_STTS_CD")->AsString;
  429. if (CMNC_STTS_CD != "CMS0")
  430. {
  431. //통신장애
  432. continue;
  433. }
  434. pObj->STATE.Comm = vms_comm_normal;
  435. String CBOXDOOR_OPEN_STTS_CD = pADO->FieldByName("CBOX_DOOR_STTS_CD")->AsString;
  436. if (CBOXDOOR_OPEN_STTS_CD == "CDS0") pObj->STATE.DoorStatus = vms_door_close;
  437. else if (CBOXDOOR_OPEN_STTS_CD == "CDS1") pObj->STATE.DoorStatus = vms_door_open;
  438. String CBOXFAN_STTS_CD = pADO->FieldByName("FAN_STTS_CD")->AsString;
  439. if (CBOXFAN_STTS_CD == "MOS0") pObj->STATE.ModulePowerStatus = vms_module_power_on;
  440. else if (CBOXFAN_STTS_CD == "MOS1") pObj->STATE.ModulePowerStatus = vms_module_power_off;
  441. String CBOX_TMPR = pADO->FieldByName("CBOX_TMPR")->AsString;
  442. pObj->STATE.BodyTemp = CBOX_TMPR.ToIntDef(0);
  443. String CBOX_HMDT = pADO->FieldByName("BRGH_VAL")->AsString;
  444. pObj->STATE.LuminanceStatus = CBOX_HMDT.ToIntDef(0);
  445. String FAN_STTS_CD = pADO->FieldByName("FAN_STTS_CD")->AsString;
  446. if (FAN_STTS_CD == "PAS0") pObj->STATE.FanStatus = vms_fan_on;
  447. else if (FAN_STTS_CD == "PAS1") pObj->STATE.FanStatus = vms_fan_off;
  448. String HETR_STTS_CD = pADO->FieldByName("HETR_STTS_CD")->AsString;
  449. if (HETR_STTS_CD == "HTS0") pObj->STATE.HeaterStatus = vms_heater_on;
  450. else if (HETR_STTS_CD == "HTS1") pObj->STATE.HeaterStatus = vms_heater_off;
  451. String COMM_STTS_CD = pADO->FieldByName("COMM_STTS_CD")->AsString;
  452. if (COMM_STTS_CD == "CMS0") pObj->STATE.Wcomm = vms_wcomm_normal;
  453. else if (COMM_STTS_CD == "CMS1") pObj->STATE.Wcomm = vms_wcomm_error;
  454. pObj->CheckRunState();
  455. }
  456. }
  457. catch(EDatabaseError &E)
  458. {
  459. DBERRORMSG("TVmsCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
  460. throw Exception(String(E.ClassName()) + E.Message);
  461. }
  462. catch(Exception &e)
  463. {
  464. DBERRORMSG("TVmsCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
  465. throw Exception(String(e.ClassName()) + e.Message);
  466. }
  467. }
  468. __finally
  469. {
  470. if (pADO)
  471. {
  472. pADO->Close();
  473. delete pADO;
  474. }
  475. FLists.UnLock();
  476. }
  477. return true;
  478. }
  479. //---------------------------------------------------------------------------
  480. bool TVmsCtlrManager::DeleteVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  481. {
  482. String sQry;
  483. TADOQuery *pADO = NULL;
  484. sQry = "UPDATE TB_VMS_CTLR \r\n"
  485. " SET DEL_YN = 'Y' \r\n"
  486. " WHERE VMS_CTLR_NMBR = :p01 \r\n";
  487. try
  488. {
  489. try
  490. {
  491. pADO = new TADOQuery(NULL);
  492. pADO->Close();
  493. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  494. pADO->SQL->Clear();
  495. pADO->SQL->Text = sQry;
  496. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  497. pADO->ExecSQL();
  498. sQry = "DELETE TB_FCLT_INFR \r\n"
  499. " WHERE FCLT_ID = :p01 \r\n";
  500. pADO->SQL->Clear();
  501. pADO->SQL->Text = sQry;
  502. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  503. pADO->ExecSQL();
  504. return true;
  505. }
  506. catch(EDatabaseError &E)
  507. {
  508. DBERRORMSG("TVmsCtlrManager::DeleteVms", String(E.ClassName()), E.Message, sQry);
  509. throw Exception(String(E.ClassName()) + E.Message);
  510. }
  511. catch(Exception &e)
  512. {
  513. DBERRORMSG("TVmsCtlrManager::DeleteVms", String(e.ClassName()), e.Message, sQry);
  514. throw Exception(String(e.ClassName()) + e.Message);
  515. }
  516. }
  517. __finally
  518. {
  519. if (pADO)
  520. {
  521. pADO->Close();
  522. delete pADO;
  523. }
  524. }
  525. return true;
  526. }
  527. //---------------------------------------------------------------------------
  528. bool TVmsCtlrManager::InsertVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  529. {
  530. String sQry;
  531. TADOQuery *pADO = NULL;
  532. sQry = "INSERT INTO TB_VMS_CTLR \r\n"
  533. " ( \r\n"
  534. " VMS_CTLR_NMBR, \r\n"
  535. " VMS_CTLR_ID, \r\n"
  536. " VMS_NM, \r\n"
  537. " VMS_CTLR_IP, \r\n"
  538. " VMS_CMNC_PORT, \r\n"
  539. " VMS_ID, \r\n"
  540. " VMS_TYPE_CD, \r\n"
  541. " ISTL_LCTN_NM, \r\n"
  542. " X_CRDN, \r\n"
  543. " Y_CRDN, \r\n"
  544. " DEL_YN, \r\n"
  545. " WEB_CMRA_IP, \r\n"
  546. " WEB_CMRA_PORT, \r\n"
  547. " WEB_CMRA_ID, \r\n"
  548. " WEB_CMRA_PWD, \r\n"
  549. " STRM_SESN_NM, \r\n"
  550. " VMS_MAX_PHSE_NUM, \r\n"
  551. " PANL_ON_TIME, \r\n"
  552. " PANL_OFF_TIME, \r\n"
  553. " ISTL_LCTN_ADDR \r\n"
  554. " ) \r\n"
  555. " VALUES (:p01, \r\n"
  556. " :p02, \r\n"
  557. " :p03, \r\n"
  558. " :p04, \r\n"
  559. " :p05, \r\n"
  560. " :p06, \r\n"
  561. " :p07, \r\n"
  562. " :p08, \r\n"
  563. " :p09, \r\n"
  564. " :p10, \r\n"
  565. " :p11, \r\n"
  566. " :p12, \r\n"
  567. " :p13, \r\n"
  568. " :p14, \r\n"
  569. " :p15, \r\n"
  570. " :p16, \r\n"
  571. " :p17, \r\n"
  572. " :p18, \r\n"
  573. " :p19, \r\n"
  574. " :p20) \r\n";
  575. try
  576. {
  577. try
  578. {
  579. pADO = new TADOQuery(NULL);
  580. pADO->Close();
  581. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  582. pADO->SQL->Clear();
  583. pADO->SQL->Text = sQry;
  584. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  585. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_CTLR_ID;
  586. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  587. pADO->Parameters->ParamByName("p04")->Value = AObj->VMS_CTLR_IP;
  588. pADO->Parameters->ParamByName("p05")->Value = AObj->VMS_CTLR_PORT;
  589. pADO->Parameters->ParamByName("p06")->Value = AObj->VMS_CTLR_LOCAL_NO;
  590. pADO->Parameters->ParamByName("p07")->Value = AObj->VMS_TYPE_CD;
  591. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  592. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  593. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  594. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  595. pADO->Parameters->ParamByName("p12")->Value = AObj->WEB_CMRA_IP;
  596. pADO->Parameters->ParamByName("p13")->Value = AObj->WEB_CMRA_PORT;
  597. pADO->Parameters->ParamByName("p14")->Value = AObj->WEB_CMRA_ID;
  598. pADO->Parameters->ParamByName("p15")->Value = AObj->WEB_CMRA_PWD;
  599. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_SESN_NM;
  600. pADO->Parameters->ParamByName("p17")->Value = AObj->VMS_MAX_PHSE_NUM;
  601. pADO->Parameters->ParamByName("p18")->Value = AObj->PANL_ON_TIME;
  602. pADO->Parameters->ParamByName("p19")->Value = AObj->PANL_OFF_TIME;
  603. pADO->Parameters->ParamByName("p20")->Value = AObj->ISTL_LCTN_ADDR;
  604. pADO->ExecSQL();
  605. return MergeFcltInfo(AObj, ADbConn);
  606. }
  607. catch(EDatabaseError &E)
  608. {
  609. DBERRORMSG("TVmsCtlrManager::InsertVms", String(E.ClassName()), E.Message, sQry);
  610. throw Exception(String(E.ClassName()) + E.Message);
  611. }
  612. catch(Exception &e)
  613. {
  614. DBERRORMSG("TVmsCtlrManager::InsertVms", String(e.ClassName()), e.Message, sQry);
  615. throw Exception(String(e.ClassName()) + e.Message);
  616. }
  617. }
  618. __finally
  619. {
  620. if (pADO)
  621. {
  622. pADO->Close();
  623. delete pADO;
  624. }
  625. }
  626. return true;
  627. }
  628. //---------------------------------------------------------------------------
  629. bool TVmsCtlrManager::UpdateVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  630. {
  631. return MergeVms(AObj, ADbConn);
  632. }
  633. //---------------------------------------------------------------------------
  634. bool TVmsCtlrManager::MergeVms(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  635. {
  636. String sQry;
  637. TADOQuery *pADO = NULL;
  638. sQry = "MERGE INTO TB_VMS_CTLR L \r\n"
  639. "USING (SELECT :p01 AS VMS_CTLR_NMBR, \r\n"
  640. " :p02 AS VMS_CTLR_ID, \r\n"
  641. " :p03 AS VMS_NM, \r\n"
  642. " :p04 AS VMS_CTLR_IP, \r\n"
  643. " :p05 AS VMS_CMNC_PORT, \r\n"
  644. " :p06 AS VMS_ID, \r\n"
  645. " :p07 AS VMS_TYPE_CD, \r\n"
  646. " :p08 AS ISTL_LCTN_NM, \r\n"
  647. " :p09 AS X_CRDN, \r\n"
  648. " :p10 AS Y_CRDN, \r\n"
  649. " :p11 AS DEL_YN, \r\n"
  650. " :p12 AS WEB_CMRA_IP, \r\n"
  651. " :p13 AS WEB_CMRA_PORT, \r\n"
  652. " :p14 AS WEB_CMRA_ID, \r\n"
  653. " :p15 AS WEB_CMRA_PWD, \r\n"
  654. " :p16 AS STRM_SESN_NM, \r\n"
  655. " :p17 AS VMS_MAX_PHSE_NUM, \r\n"
  656. " :p18 AS PANL_ON_TIME, \r\n"
  657. " :p19 AS PANL_OFF_TIME, \r\n"
  658. " :p20 AS ISTL_LCTN_ADDR \r\n"
  659. " FROM DUAL) M \r\n"
  660. " ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR) \r\n"
  661. "WHEN MATCHED THEN \r\n"
  662. " UPDATE SET L.VMS_CTLR_ID = M.VMS_CTLR_ID, \r\n"
  663. " L.VMS_NM = M.VMS_NM, \r\n"
  664. " L.VMS_CTLR_IP = M.VMS_CTLR_IP, \r\n"
  665. " L.VMS_CMNC_PORT = M.VMS_CMNC_PORT, \r\n"
  666. " L.VMS_ID = M.VMS_ID, \r\n"
  667. " L.VMS_TYPE_CD = M.VMS_TYPE_CD, \r\n"
  668. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  669. " L.X_CRDN = M.X_CRDN, \r\n"
  670. " L.Y_CRDN = M.Y_CRDN, \r\n"
  671. " L.DEL_YN = M.DEL_YN, \r\n"
  672. " L.WEB_CMRA_IP = M.WEB_CMRA_IP, \r\n"
  673. " L.WEB_CMRA_PORT = M.WEB_CMRA_PORT, \r\n"
  674. " L.WEB_CMRA_ID = M.WEB_CMRA_ID, \r\n"
  675. " L.WEB_CMRA_PWD = M.WEB_CMRA_PWD, \r\n"
  676. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  677. " L.VMS_MAX_PHSE_NUM = M.VMS_MAX_PHSE_NUM, \r\n"
  678. " L.PANL_ON_TIME = M.PANL_ON_TIME, \r\n"
  679. " L.PANL_OFF_TIME = M.PANL_OFF_TIME, \r\n"
  680. " L.ISTL_LCTN_ADDR = M.ISTL_LCTN_ADDR \r\n"
  681. "WHEN NOT MATCHED THEN \r\n"
  682. " INSERT ( \r\n"
  683. " VMS_CTLR_NMBR, \r\n"
  684. " VMS_CTLR_ID, \r\n"
  685. " VMS_NM, \r\n"
  686. " VMS_CTLR_IP, \r\n"
  687. " VMS_CMNC_PORT, \r\n"
  688. " VMS_ID, \r\n"
  689. " VMS_TYPE_CD, \r\n"
  690. " ISTL_LCTN_NM, \r\n"
  691. " X_CRDN, \r\n"
  692. " Y_CRDN, \r\n"
  693. " DEL_YN, \r\n"
  694. " WEB_CMRA_IP, \r\n"
  695. " WEB_CMRA_PORT, \r\n"
  696. " WEB_CMRA_ID, \r\n"
  697. " WEB_CMRA_PWD, \r\n"
  698. " STRM_SESN_NM, \r\n"
  699. " VMS_MAX_PHSE_NUM, \r\n"
  700. " PANL_ON_TIME, \r\n"
  701. " PANL_OFF_TIME, \r\n"
  702. " ISTL_LCTN_ADDR \r\n"
  703. " ) \r\n"
  704. " VALUES ( \r\n"
  705. " M.VMS_CTLR_NMBR, \r\n"
  706. " M.VMS_CTLR_ID, \r\n"
  707. " M.VMS_NM, \r\n"
  708. " M.VMS_CTLR_IP, \r\n"
  709. " M.VMS_CMNC_PORT, \r\n"
  710. " M.VMS_ID, \r\n"
  711. " M.VMS_TYPE_CD, \r\n"
  712. " M.ISTL_LCTN_NM, \r\n"
  713. " M.X_CRDN, \r\n"
  714. " M.Y_CRDN, \r\n"
  715. " M.DEL_YN, \r\n"
  716. " M.WEB_CMRA_IP, \r\n"
  717. " M.WEB_CMRA_PORT, \r\n"
  718. " M.WEB_CMRA_ID, \r\n"
  719. " M.WEB_CMRA_PWD, \r\n"
  720. " M.STRM_SESN_NM, \r\n"
  721. " M.VMS_MAX_PHSE_NUM, \r\n"
  722. " M.PANL_ON_TIME, \r\n"
  723. " M.PANL_OFF_TIME, \r\n"
  724. " M.ISTL_LCTN_ADDR \r\n"
  725. " ) \r\n";
  726. try
  727. {
  728. try
  729. {
  730. pADO = new TADOQuery(NULL);
  731. pADO->Close();
  732. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  733. pADO->SQL->Clear();
  734. pADO->SQL->Text = sQry;
  735. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  736. pADO->Parameters->ParamByName("p02")->Value = AObj->VMS_CTLR_ID;
  737. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  738. pADO->Parameters->ParamByName("p04")->Value = AObj->VMS_CTLR_IP;
  739. pADO->Parameters->ParamByName("p05")->Value = AObj->VMS_CTLR_PORT;
  740. pADO->Parameters->ParamByName("p06")->Value = AObj->VMS_CTLR_LOCAL_NO;
  741. pADO->Parameters->ParamByName("p07")->Value = AObj->VMS_TYPE_CD;
  742. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  743. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  744. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  745. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  746. pADO->Parameters->ParamByName("p12")->Value = AObj->WEB_CMRA_IP;
  747. pADO->Parameters->ParamByName("p13")->Value = AObj->WEB_CMRA_PORT;
  748. pADO->Parameters->ParamByName("p14")->Value = AObj->WEB_CMRA_ID;
  749. pADO->Parameters->ParamByName("p15")->Value = AObj->WEB_CMRA_PWD;
  750. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_SESN_NM;
  751. pADO->Parameters->ParamByName("p17")->Value = AObj->VMS_MAX_PHSE_NUM;
  752. pADO->Parameters->ParamByName("p18")->Value = AObj->PANL_ON_TIME;
  753. pADO->Parameters->ParamByName("p19")->Value = AObj->PANL_OFF_TIME;
  754. pADO->Parameters->ParamByName("p20")->Value = AObj->ISTL_LCTN_ADDR;
  755. pADO->ExecSQL();
  756. return MergeFcltInfo(AObj, ADbConn);
  757. }
  758. catch(EDatabaseError &E)
  759. {
  760. DBERRORMSG("TVmsCtlrManager::MergeVms", String(E.ClassName()), E.Message, sQry);
  761. throw Exception(String(E.ClassName()) + E.Message);
  762. }
  763. catch(Exception &e)
  764. {
  765. DBERRORMSG("TVmsCtlrManager::MergeVms", String(e.ClassName()), e.Message, sQry);
  766. throw Exception(String(e.ClassName()) + e.Message);
  767. }
  768. }
  769. __finally
  770. {
  771. if (pADO)
  772. {
  773. pADO->Close();
  774. delete pADO;
  775. }
  776. }
  777. return true;
  778. }
  779. //---------------------------------------------------------------------------
  780. bool TVmsCtlrManager::MergeFcltInfo(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  781. {
  782. String sQry;
  783. TADOQuery *pADO = NULL;
  784. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  785. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  786. " :p02 AS FCLT_TYPE, \r\n"
  787. " :p03 AS FCLT_LCTN \r\n"
  788. " FROM DUAL) M \r\n"
  789. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  790. "WHEN MATCHED \r\n"
  791. "THEN \r\n"
  792. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  793. " L.DEL_YN = 'N' \r\n"
  794. "WHEN NOT MATCHED \r\n"
  795. "THEN \r\n"
  796. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  797. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  798. try
  799. {
  800. try
  801. {
  802. pADO = new TADOQuery(NULL);
  803. pADO->Close();
  804. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  805. pADO->SQL->Clear();
  806. pADO->SQL->Text = sQry;
  807. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_ID;
  808. pADO->Parameters->ParamByName("p02")->Value = "VMS";
  809. pADO->Parameters->ParamByName("p03")->Value = AObj->VMS_NM;
  810. pADO->ExecSQL();
  811. return true;
  812. }
  813. catch(EDatabaseError &E)
  814. {
  815. DBERRORMSG("TVmsCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  816. throw Exception(String(E.ClassName()) + E.Message);
  817. }
  818. catch(Exception &e)
  819. {
  820. DBERRORMSG("TVmsCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  821. throw Exception(String(e.ClassName()) + e.Message);
  822. }
  823. }
  824. __finally
  825. {
  826. if (pADO)
  827. {
  828. pADO->Close();
  829. delete pADO;
  830. }
  831. }
  832. return true;
  833. }
  834. //---------------------------------------------------------------------------
  835. bool TVmsCtlrManager::GetNextVmsId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  836. {
  837. String sQry;
  838. TADOQuery *pADO = NULL;
  839. sQry = "SELECT NVL(MAX(VMS_CTLR_NMBR), 10000) + 1 AS NEWID FROM TB_VMS_CTLR \r\n";
  840. try
  841. {
  842. try
  843. {
  844. pADO = new TADOQuery(NULL);
  845. pADO->Close();
  846. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  847. pADO->SQL->Clear();
  848. pADO->SQL->Text = sQry;
  849. pADO->Prepared = true;
  850. pADO->Open();
  851. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  852. AId = ANmbr / 10000;
  853. return true;
  854. }
  855. catch(EDatabaseError &E)
  856. {
  857. DBERRORMSG("VmsCtlrManager::GetNextVmsId", String(E.ClassName()), E.Message, sQry);
  858. throw Exception(String(E.ClassName()) + E.Message);
  859. }
  860. catch(Exception &e)
  861. {
  862. DBERRORMSG("VmsCtlrManager::GetNextVmsId", String(e.ClassName()), e.Message, sQry);
  863. throw Exception(String(e.ClassName()) + e.Message);
  864. }
  865. }
  866. __finally
  867. {
  868. if (pADO)
  869. {
  870. pADO->Close();
  871. delete pADO;
  872. }
  873. }
  874. return false;
  875. }
  876. //---------------------------------------------------------------------------
  877. bool TVmsCtlrManager::UpdateCtlrInfo(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  878. {
  879. String sQry;
  880. TADOQuery *pADO = NULL;
  881. sQry = "UPDATE TB_VMS_CTLR \r\n"
  882. " SET PANL_ON_TIME = :p01, \r\n"
  883. " PANL_OFF_TIME = :p02 \r\n"
  884. " WHERE DEL_YN = 'N' \r\n";
  885. try
  886. {
  887. try
  888. {
  889. pADO = new TADOQuery(NULL);
  890. pADO->Close();
  891. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  892. pADO->SQL->Clear();
  893. pADO->SQL->Text = sQry;
  894. pADO->Parameters->ParamByName("p01")->Value = AObj->PANL_ON_TIME;
  895. pADO->Parameters->ParamByName("p02")->Value = AObj->PANL_OFF_TIME;
  896. pADO->ExecSQL();
  897. return true;
  898. }
  899. catch(EDatabaseError &E)
  900. {
  901. DBERRORMSG("TVmsCtlrManager::UpdateCtlrInfo", String(E.ClassName()), E.Message, sQry);
  902. throw Exception(String(E.ClassName()) + E.Message);
  903. }
  904. catch(Exception &e)
  905. {
  906. DBERRORMSG("TVmsCtlrManager::UpdateCtlrInfo", String(e.ClassName()), e.Message, sQry);
  907. throw Exception(String(e.ClassName()) + e.Message);
  908. }
  909. }
  910. __finally
  911. {
  912. if (pADO)
  913. {
  914. pADO->Close();
  915. delete pADO;
  916. }
  917. }
  918. return true;
  919. }
  920. //---------------------------------------------------------------------------
  921. bool TVmsCtlrManager::UpdateIfscCngsSpeedInfo(int ACngsSpd, TADOConnection *ADbConn/*=NULL*/)
  922. {
  923. String sQry;
  924. TADOQuery *pADO = NULL;
  925. sQry = "UPDATE TB_VMS_IFSC_RLTN \r\n"
  926. " SET CNGS_CNFM_SPED = :p01 \r\n";
  927. try
  928. {
  929. try
  930. {
  931. String sGradCd;
  932. pADO = new TADOQuery(NULL);
  933. pADO->Close();
  934. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  935. pADO->SQL->Clear();
  936. pADO->SQL->Text = sQry;
  937. pADO->Parameters->ParamByName("p01")->Value = ACngsSpd;
  938. pADO->ExecSQL();
  939. return true;
  940. }
  941. catch(EDatabaseError &E)
  942. {
  943. DBERRORLOG("TVmsCtlrManager::UpdateIfscCngsSpeedInfo", String(E.ClassName()), E.Message, sQry);
  944. throw Exception(String(E.ClassName()) + E.Message);
  945. }
  946. catch(Exception &e)
  947. {
  948. DBERRORLOG("TVmsCtlrManager::UpdateIfscCngsSpeedInfo", String(e.ClassName()), e.Message, sQry);
  949. throw Exception(String(e.ClassName()) + e.Message);
  950. }
  951. }
  952. __finally
  953. {
  954. if (pADO)
  955. {
  956. pADO->Close();
  957. delete pADO;
  958. }
  959. }
  960. return true;
  961. }
  962. //---------------------------------------------------------------------------
  963. bool TVmsCtlrManager::LoadIfscRltn(TADOConnection *ADbConn/*=NULL*/)
  964. {
  965. String sQry;
  966. TADOQuery *pADO = NULL;
  967. FLists.Lock();
  968. try
  969. {
  970. FOR_STL(TVmsCtlr*, pObj, FLists)
  971. {
  972. pObj->FIfscRltn.RemoveAll();
  973. }
  974. }
  975. __finally
  976. {
  977. FLists.UnLock();
  978. }
  979. #if 0
  980. sQry = "SELECT A.VMS_CTLR_NMBR, B.VMS_IFSC_ID, B.DSPL_PRRT, \r\n"
  981. " B.CNGS_CNFM_YN, B.CNGS_CNFM_SPED \r\n"
  982. " FROM TB_VMS_CTLR A, \r\n"
  983. " TB_VMS_IFSC_RLTN B, \r\n"
  984. " TB_VMS_IFSC C \r\n"
  985. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  986. " AND B.VMS_IFSC_ID = C.VMS_IFSC_ID \r\n"
  987. " ORDER BY A.VMS_CTLR_NMBR, B.DSPL_PRRT \r\n";
  988. #else
  989. //구미 컬럼 추가하지 않는 경우에는 alias 사용, 테이블 명칭 변경됨
  990. sQry = "SELECT A.VMS_CTLR_NMBR, B.VMS_IFSC_ID, B.DSPL_PRRT, \r\n"
  991. " 'N' AS CNGS_CNFM_YN, 5 AS CNGS_CNFM_SPED \r\n"
  992. " FROM TB_VMS_CTLR A, \r\n"
  993. " TB_VMS_IFSC_RLTN B, \r\n"
  994. " TB_VMS_IFSC C \r\n"
  995. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  996. " AND B.VMS_IFSC_ID = C.VMS_IFSC_ID \r\n"
  997. " ORDER BY A.VMS_CTLR_NMBR, B.DSPL_PRRT \r\n";
  998. #endif
  999. FLists.Lock();
  1000. try
  1001. {
  1002. String VMS_CTLR_NMBR;
  1003. try
  1004. {
  1005. pADO = new TADOQuery(NULL);
  1006. pADO->Close();
  1007. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1008. pADO->SQL->Clear();
  1009. pADO->SQL->Text = sQry;
  1010. pADO->Prepared = true;
  1011. pADO->Open();
  1012. for( ; !pADO->Eof; pADO->Next())
  1013. {
  1014. VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  1015. TVmsCtlr *pVms = FLists.Find(String(VMS_CTLR_NMBR));
  1016. if (!pVms) continue;
  1017. TVmsIfscRltn *pObj = new TVmsIfscRltn();
  1018. if (pObj)
  1019. {
  1020. pObj->VMS_CTLR_NMBR = VMS_CTLR_NMBR;
  1021. pObj->VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsInteger;
  1022. pObj->DSPL_PRRT = pADO->FieldByName("DSPL_PRRT")->AsInteger;
  1023. pObj->CNGS_CNFM_YN = pADO->FieldByName("CNGS_CNFM_YN")->AsString;
  1024. pObj->CNGS_CNFM_SPED= pADO->FieldByName("CNGS_CNFM_SPED")->AsInteger;
  1025. pVms->FIfscRltn.Push(pObj->DSPL_PRRT, pObj);
  1026. }
  1027. }
  1028. }
  1029. catch(EDatabaseError &E)
  1030. {
  1031. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(E.ClassName()), E.Message, sQry);
  1032. throw Exception(String(E.ClassName()) + E.Message);
  1033. }
  1034. catch(Exception &e)
  1035. {
  1036. DBERRORMSG("TVmsCtlrManager::LoadIfscRltn", String(e.ClassName()), e.Message, sQry);
  1037. throw Exception(String(e.ClassName()) + e.Message);
  1038. }
  1039. }
  1040. __finally
  1041. {
  1042. if (pADO)
  1043. {
  1044. pADO->Close();
  1045. delete pADO;
  1046. }
  1047. FLists.UnLock();
  1048. }
  1049. return true;
  1050. }
  1051. //---------------------------------------------------------------------------
  1052. bool TVmsCtlrManager::SaveIfscRltn(TVmsCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  1053. {
  1054. String sQry;
  1055. TADOQuery *pADO = NULL;
  1056. int ii;
  1057. try
  1058. {
  1059. try
  1060. {
  1061. pADO = new TADOQuery(NULL);
  1062. pADO->Close();
  1063. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1064. sQry = "DELETE FROM TB_VMS_IFSC_RLTN WHERE VMS_CTLR_NMBR = :p01";
  1065. pADO->SQL->Clear();
  1066. pADO->SQL->Text = sQry;
  1067. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  1068. pADO->ExecSQL();
  1069. sQry = "INSERT INTO TB_VMS_IFSC_RLTN(VMS_CTLR_NMBR, VMS_IFSC_ID, DSPL_PRRT, CNGS_CNFM_YN, CNGS_CNFM_SPED) VALUES(:p01, :p02, :p03, :p04, :p05)";
  1070. ii = 0;
  1071. pADO->SQL->Clear();
  1072. pADO->SQL->Text = sQry;
  1073. FOR_STL(TVmsIfscRltn *, pLink, AObj->FIfscRltn)
  1074. {
  1075. pADO->Parameters->ParamByName("p01")->Value = AObj->VMS_CTLR_NMBR;
  1076. pADO->Parameters->ParamByName("p02")->Value = pLink->VMS_IFSC_ID;
  1077. pADO->Parameters->ParamByName("p03")->Value = String(ii+1);
  1078. pADO->Parameters->ParamByName("p04")->Value = pLink->CNGS_CNFM_YN;
  1079. pADO->Parameters->ParamByName("p05")->Value = pLink->CNGS_CNFM_SPED;
  1080. pADO->ExecSQL();
  1081. ii++;
  1082. }
  1083. return true;
  1084. }
  1085. catch(EDatabaseError &E)
  1086. {
  1087. DBERRORMSG("TVmsCtlrManager::SaveIfscRltn", String(E.ClassName()), E.Message, sQry);
  1088. throw Exception(String(E.ClassName()) + E.Message);
  1089. }
  1090. catch(Exception &e)
  1091. {
  1092. DBERRORMSG("TVmsCtlrManager::SaveIfscRltn", String(e.ClassName()), e.Message, sQry);
  1093. throw Exception(String(e.ClassName()) + e.Message);
  1094. }
  1095. }
  1096. __finally
  1097. {
  1098. if (pADO)
  1099. {
  1100. pADO->Close();
  1101. delete pADO;
  1102. }
  1103. }
  1104. return true;
  1105. }
  1106. //---------------------------------------------------------------------------
  1107. bool TVmsCtlrManager::LoadVmsMsg(TADOConnection *ADbConn/*=NULL*/)
  1108. {
  1109. String sQry;
  1110. TADOQuery *pADO = NULL;
  1111. sQry = "SELECT A.*, \r\n"
  1112. " TO_CHAR(SYSDATE - 8/1440, 'YYYYMMDDHH24MISS') AS SVC_DT \r\n"
  1113. " FROM TB_VMS_DSPL_PRST A, \r\n"
  1114. " (SELECT VMS_CTLR_NMBR, MAX(DSPL_DT) AS DSPL_DT \r\n"
  1115. " FROM TB_VMS_DSPL_PRST \r\n"
  1116. " GROUP BY VMS_CTLR_NMBR) B \r\n"
  1117. " WHERE A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  1118. " AND A.DSPL_DT = B.DSPL_DT \r\n"
  1119. " ORDER BY A.VMS_CTLR_NMBR, A.PHASE \r\n";
  1120. FLists.Lock();
  1121. try
  1122. {
  1123. FOR_STL(TVmsCtlr*, pTmpObj, FLists)
  1124. {
  1125. pTmpObj->Lock();
  1126. pTmpObj->VmsMsg->Init();
  1127. pTmpObj->UnLock();
  1128. }
  1129. }
  1130. __finally
  1131. {
  1132. FLists.UnLock();
  1133. }
  1134. TVmsCtlr *pObj = NULL;
  1135. String sOldVmsNmbr = "";
  1136. int nPhase = 0;
  1137. try
  1138. {
  1139. try
  1140. {
  1141. pADO = new TADOQuery(NULL);
  1142. pADO->Close();
  1143. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1144. pADO->SQL->Clear();
  1145. pADO->SQL->Text = sQry;
  1146. pADO->Prepared = true;
  1147. pADO->Open();
  1148. for( ; !pADO->Eof; pADO->Next())
  1149. {
  1150. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  1151. if (sVmsNmbr != sOldVmsNmbr)
  1152. {
  1153. if (pObj)
  1154. {
  1155. pObj->VmsMsg->Total = nPhase;
  1156. pObj->VmsMsg->Curr = 0;
  1157. pObj->UnLock();
  1158. }
  1159. pObj = FLists.Find(sVmsNmbr);
  1160. if (pObj)
  1161. {
  1162. pObj->Lock();
  1163. nPhase = 0;
  1164. sOldVmsNmbr = sVmsNmbr;
  1165. }
  1166. else continue;
  1167. }
  1168. if (!pObj) continue;
  1169. if (nPhase >= INT_VMS_MAX_FORM) continue;
  1170. SAFE_DELETE(FImgStream);
  1171. FImgStream = pADO->CreateBlobStream(pADO->FieldByName("VMS_DSPL_MSG_IMAG"), bmRead);
  1172. if (FImgStream && FImgStream->Size > 0)
  1173. {
  1174. try
  1175. {
  1176. if (!pObj->VmsMsg->PHASE[nPhase].pVmsBmp)
  1177. {
  1178. pObj->VmsMsg->PHASE[nPhase].pVmsBmp = new Graphics::TBitmap();
  1179. }
  1180. pObj->VmsMsg->PHASE[nPhase].pVmsBmp->FreeImage();
  1181. pObj->VmsMsg->PHASE[nPhase].pVmsBmp->LoadFromStream(FImgStream);
  1182. int PHASE = pADO->FieldByName("PHASE")->AsInteger;
  1183. pObj->VmsMsg->PHASE[nPhase].DSPL_HH = pADO->FieldByName("DSPL_HH")->AsInteger;
  1184. pObj->VmsMsg->PHASE[nPhase].DNLD_YN = pADO->FieldByName("DNLD_YN")->AsString;
  1185. pObj->VmsMsg->PHASE[nPhase].DSPL_CD = pADO->FieldByName("VMS_FORM_DSPL_MTHD_CD")->AsString;
  1186. pObj->VmsMsg->PHASE[nPhase].VMS_SCH_FORM_TYPE = pADO->FieldByName("VMS_SCH_FORM_TYPE")->AsInteger;
  1187. if (pObj->VmsMsg->PHASE[nPhase].VMS_SCH_FORM_TYPE == eSchTp_video ||
  1188. pObj->VmsMsg->PHASE[nPhase].VMS_SCH_FORM_TYPE == eSchTp_stream )
  1189. {
  1190. pObj->VmsMsg->PHASE[nPhase].VMS_DSPL_MSG_TXT = pADO->FieldByName("VMS_DSPL_MSG_TXT")->AsString.Trim();
  1191. }
  1192. if (pObj->VmsMsg->PHASE[nPhase].DSPL_HH <= 0) pObj->VmsMsg->PHASE[nPhase].DSPL_HH = 3;
  1193. //if (pObj->VmsMsg->PHASE[nPhase].DSPL_HH >= 10) pObj->VmsMsg->PHASE[nPhase].DSPL_HH = 10;
  1194. String DSPL_DT = pADO->FieldByName("DSPL_DT")->AsString;
  1195. String SVC_DT = pADO->FieldByName("SVC_DT")->AsString;
  1196. pObj->VmsMsg->OFFER_DT = DSPL_DT;
  1197. if (DSPL_DT >= SVC_DT)
  1198. {
  1199. pObj->VmsMsg->OFFER_YN = true;
  1200. }
  1201. else
  1202. {
  1203. pObj->VmsMsg->OFFER_YN = false;
  1204. }
  1205. if (pObj->VmsMsg->PHASE[nPhase].DNLD_YN == "N")
  1206. {
  1207. pObj->VmsMsg->OFFER_YN = false;
  1208. }
  1209. //TODO
  1210. if (pObj->STATE.Comm != vms_comm_normal)
  1211. {
  1212. pObj->VmsMsg->OFFER_YN = false;
  1213. }
  1214. nPhase++;
  1215. }
  1216. catch(Exception &e)
  1217. {
  1218. }
  1219. }
  1220. }
  1221. if (pObj)
  1222. {
  1223. pObj->VmsMsg->Total = nPhase;
  1224. pObj->VmsMsg->Curr = 0;
  1225. pObj->UnLock();
  1226. }
  1227. }
  1228. catch(EDatabaseError &E)
  1229. {
  1230. DBERRORMSG("TVmsCtlrManager::LoadVmsMsg", String(E.ClassName()), E.Message, sQry);
  1231. throw Exception(String(E.ClassName()) + E.Message);
  1232. }
  1233. catch(Exception &e)
  1234. {
  1235. DBERRORMSG("TVmsCtlrManager::LoadVmsMsg", String(e.ClassName()), e.Message, sQry);
  1236. throw Exception(String(e.ClassName()) + e.Message);
  1237. }
  1238. }
  1239. __finally
  1240. {
  1241. if (pADO)
  1242. {
  1243. pADO->Close();
  1244. delete pADO;
  1245. }
  1246. }
  1247. return true;
  1248. }
  1249. //---------------------------------------------------------------------------
  1250. bool TVmsCtlrManager::LoadVmsFormUsage(TADOConnection *ADbConn/*=NULL*/)
  1251. {
  1252. InitFormCount();
  1253. String sQry;
  1254. TADOQuery *pADO = NULL;
  1255. #if 0
  1256. sQry = "SELECT A.VMS_CTLR_NMBR, \r\n"
  1257. " A.VMS_SCH_TYPE, \r\n"
  1258. " A.VMS_SCH_FORM_TYPE, \r\n"
  1259. " A.DSPL_STRT_HH, \r\n"
  1260. " A.DSPL_END_HH, \r\n"
  1261. " TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') AS CURR_HH, \r\n"
  1262. " A.USE_YN \r\n"
  1263. " FROM TB_VMS_DSPL_SCH A, \r\n"
  1264. " TB_VMS_FORM B \r\n"
  1265. " WHERE 1=1 \r\n"
  1266. // " AND B.VALID_YN = 'Y' \r\n"
  1267. " AND A.VMS_FORM_ID = B.VMS_FORM_ID \r\n";
  1268. #else
  1269. sQry = "SELECT A.VMS_CTLR_NMBR, \r\n"
  1270. " A.TRFC_SITU_TYPE_CD AS VMS_SCH_TYPE, \r\n"
  1271. " A.TRFC_SITU_TYPE_CD AS VMS_SCH_FORM_TYPE, \r\n"
  1272. " A.DSPL_STRT_HH, \r\n"
  1273. " A.DSPL_END_HH, \r\n"
  1274. " TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') AS CURR_HH, \r\n"
  1275. " 'Y' AS USE_YN \r\n"
  1276. " FROM TB_VMS_TRFC_INFR_DSPL_SCH A, \r\n"
  1277. " TB_VMS_FORM B \r\n"
  1278. " WHERE 1=1 \r\n"
  1279. " AND A.VMS_FORM_ID = B.VMS_FORM_ID \r\n";
  1280. #endif
  1281. try
  1282. {
  1283. try
  1284. {
  1285. pADO = new TADOQuery(NULL);
  1286. pADO->Close();
  1287. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1288. ITSDb_SQLText(pADO, sQry);
  1289. ITSDb_SQLOpen(pADO);
  1290. TVmsCtlr *pObj;
  1291. int nSchType, nFormType;
  1292. for( ; !pADO->Eof; pADO->Next())
  1293. {
  1294. String sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  1295. pObj = FLists.Find(sVmsNmbr);
  1296. if (!pObj) continue;
  1297. String sSchType = pADO->FieldByName("VMS_SCH_TYPE")->AsString.Trim();
  1298. if (sSchType == "A") nSchType = enScheduleAuto;
  1299. else if (sSchType == "F") nSchType = enScheduleFix;
  1300. else if (sSchType == "B") nSchType = enScheduleBase;
  1301. else continue;
  1302. nFormType = pADO->FieldByName("VMS_SCH_FORM_TYPE")->AsInteger;
  1303. if (nFormType < eSchTp_traffic && nFormType >= eSchTp_max) continue;
  1304. pObj->FormCnt[nSchType].Total[nFormType]++; //등록되어있는 전체 폼 숫자
  1305. if (pADO->FieldByName("USE_YN")->AsString != 'Y') continue;
  1306. //사용하는 것중에 현재시각이 제공시각안에 들어있는것은 카운트하지 않음.
  1307. String sStrHH = pADO->FieldByName("DSPL_STRT_HH")->AsString;
  1308. String sEndHH = pADO->FieldByName("DSPL_END_HH")->AsString;
  1309. String sCurHH = pADO->FieldByName("CURR_HH")->AsString;
  1310. if (sCurHH >= sStrHH && sCurHH <= sEndHH)
  1311. {
  1312. pObj->FormCnt[nSchType].Use[nFormType]++; //사용가능 폼 숫자
  1313. }
  1314. }
  1315. }
  1316. catch(EDatabaseError &E)
  1317. {
  1318. DBERRORMSG("TVmsCtlrManager::LoadVmsFormUsage", String(E.ClassName()), E.Message, sQry);
  1319. throw Exception(String(E.ClassName()) + E.Message);
  1320. }
  1321. catch(Exception &e)
  1322. {
  1323. DBERRORMSG("TVmsCtlrManager::LoadVmsFormUsage", String(e.ClassName()), e.Message, sQry);
  1324. throw Exception(String(e.ClassName()) + e.Message);
  1325. }
  1326. }
  1327. __finally
  1328. {
  1329. if (pADO)
  1330. {
  1331. pADO->Close();
  1332. delete pADO;
  1333. }
  1334. }
  1335. return true;
  1336. }
  1337. //---------------------------------------------------------------------------
  1338. bool TVmsCtlrManager::InsVmsControlHs(String ACtlDt, String AVmsNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
  1339. {
  1340. String sQry;
  1341. TADOQuery *pADO = NULL;
  1342. sQry = "INSERT INTO TB_VMS_CTRL_HS( \r\n"
  1343. " CTRL_DT, \r\n"
  1344. " VMS_CTLR_NMBR, \r\n"
  1345. " CTRL_TYPE, \r\n"
  1346. " CTRL_VAL, \r\n"
  1347. " CTRL_RESULT, \r\n"
  1348. " USER_ID \r\n"
  1349. " ) \r\n"
  1350. " VALUES( \r\n"
  1351. " :p01, \r\n"
  1352. " :p02, \r\n"
  1353. " :p03, \r\n"
  1354. " :p04, \r\n"
  1355. " :p05, \r\n"
  1356. " :p06 \r\n"
  1357. " ) \r\n";
  1358. try
  1359. {
  1360. try
  1361. {
  1362. pADO = new TADOQuery(NULL);
  1363. pADO->Close();
  1364. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1365. pADO->SQL->Clear();
  1366. pADO->SQL->Text = sQry;
  1367. pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
  1368. pADO->Parameters->ParamByName("p02")->Value = AVmsNmbr;
  1369. pADO->Parameters->ParamByName("p03")->Value = ACtlType;
  1370. pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
  1371. pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
  1372. pADO->Parameters->ParamByName("p06")->Value = AUserId;
  1373. pADO->ExecSQL();
  1374. return true;
  1375. }
  1376. catch(EDatabaseError &E)
  1377. {
  1378. DBERRORMSG("TVmsCtlrManager::InsVmsControlHs", String(E.ClassName()), E.Message, sQry);
  1379. throw Exception(String(E.ClassName()) + E.Message);
  1380. }
  1381. catch(Exception &e)
  1382. {
  1383. DBERRORMSG("TVmsCtlrManager::InsVmsControlHs", String(e.ClassName()), e.Message, sQry);
  1384. throw Exception(String(e.ClassName()) + e.Message);
  1385. }
  1386. }
  1387. __finally
  1388. {
  1389. if (pADO)
  1390. {
  1391. pADO->Close();
  1392. delete pADO;
  1393. }
  1394. }
  1395. return true;
  1396. }
  1397. //---------------------------------------------------------------------------
  1398. int VmsGetFormTypeIdx(int AFormType)
  1399. {
  1400. int nFormTypeIdx = -1;
  1401. switch(AFormType)
  1402. {
  1403. case eFormTp_traf_1: // 소통상황(1단)
  1404. case eFormTp_traf_2: // 소통상황(2단)
  1405. case eFormTp_traf_3: // 소통상황(3단)
  1406. case eFormTp_traf_4: // 소통상황(4단)
  1407. case eFormtp_figure: // 소통상황(도형식배경소통정보)
  1408. nFormTypeIdx = eSchTp_traffic;
  1409. break;
  1410. case eFormTp_congest: // 정체소통상황
  1411. nFormTypeIdx = eSchTp_congest;
  1412. break;
  1413. case eFormTp_incident: // 돌발문안
  1414. nFormTypeIdx = eSchTp_incident;
  1415. break;
  1416. case eFormTp_gongsa: // 공사/행사문안
  1417. nFormTypeIdx = eSchTp_gongsa;
  1418. break;
  1419. case eFormTp_hongbo: // 홍보문안
  1420. nFormTypeIdx = eSchTp_hongbo;
  1421. break;
  1422. case eFormTp_deture: // 우회도로
  1423. nFormTypeIdx = eSchTp_deture;
  1424. break;
  1425. case eFormTp_safe: // 재난안전
  1426. nFormTypeIdx = eSchTp_safe;
  1427. break;
  1428. case eFormTp_video: // 동영상
  1429. nFormTypeIdx = eSchTp_video;
  1430. break;
  1431. case eFormTp_stream: // 스트리밍영상
  1432. nFormTypeIdx = eSchTp_stream;
  1433. break;
  1434. case eFormTp_atmp: // 대기환경
  1435. nFormTypeIdx = eSchTp_atmp;
  1436. break;
  1437. case eFormTp_park: // 주차정보
  1438. nFormTypeIdx = eSchTp_park;
  1439. break;
  1440. default: break;
  1441. }
  1442. return nFormTypeIdx;
  1443. }