CDSVmsCtlrF.cpp 67 KB

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