CDSVmsCtlrF.cpp 62 KB

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