CDSManagerF.cpp 117 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSManagerF.h"
  4. #include "CDSCtlrF.h"
  5. #include "CDSIfscF.h"
  6. #include "CDSFormF.h"
  7. #include "CDSImageF.h"
  8. #include "CDSAtmpF.h"
  9. #include "CDSSafeF.h"
  10. #include "CDSParkF.h"
  11. #include "VmsUtilsF.h"
  12. #include "VMSCommLibF.h"
  13. //---------------------------------------------------------------------------
  14. #pragma package(smart_init)
  15. //---------------------------------------------------------------------------
  16. TCDSManager *CDSManager = NULL;
  17. //---------------------------------------------------------------------------
  18. TCDSManager::TCDSManager()
  19. {
  20. FIsStaticCycle = false;
  21. }
  22. //---------------------------------------------------------------------------
  23. TCDSManager::~TCDSManager()
  24. {
  25. }
  26. //---------------------------------------------------------------------------
  27. int TCDSManager::ClearVmsProvideMode()
  28. {
  29. int nSelCnt= 0;
  30. DDBSTART;
  31. FFormDsplDt = Now().FormatString("yyyymmddhhnnss");
  32. CtlrItr it;
  33. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  34. {
  35. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  36. if (pObj->Server.useFlag != use_enable) continue;
  37. if (!pObj->FProvide) continue;
  38. pObj->CTRLMODE->MaxDisplayForm = 0;//pObj->VMS_MAX_PHSE_NUM; //0
  39. pObj->CTRLMODE->Enable = object_disable;
  40. pObj->CTRLMODE->SvcDate = FFormDsplDt;
  41. pObj->CTRLMODE->SaveFlag = true;
  42. pObj->CTRLMODE->pTimer = Now();
  43. pObj->CTRLMODE->Result = false;
  44. pObj->InitSchedule(); //스케줄정보
  45. pObj->InitIncident(); //돌발정보
  46. pObj->InitEvent(); //이벤트(공사/행사)정보
  47. pObj->InitSafe(); //재난안전정보
  48. pObj->FExistCngsForm = false; //정체폼이 없는것으로 초기화
  49. pObj->pForms->Clear();
  50. nSelCnt++;
  51. }
  52. IDBSTOP(nSelCnt);
  53. return nSelCnt;
  54. }
  55. //---------------------------------------------------------------------------
  56. int TCDSManager::LoadVmsEventOccrInf(TADOConnection *ADbConn)
  57. {
  58. AnsiString sQry;
  59. int nSelCnt = 0;
  60. TADOQuery *pADO = NULL;
  61. DDBSTART;
  62. sQry = "SELECT V.VMS_CTLR_NMBR, V.LINK_ID, V.IFSC_ID, V.VMS_IFSC_ID, \r\n"
  63. " V.VMS_IFSC_NM, V.DSPL_STRT_NODE_NM, V.DSPL_END_NODE_NM, \r\n"
  64. " V.DETR_ID, V.DSPL_PRRT, I.INCD_OCRR_ID, I.STRT_LCTN_NM, \r\n"
  65. " V.ROAD_NM, V.SPOT_NM, \r\n"
  66. " I.END_LCTN_NM, I.OCRR_LCTN_NM, I.INCD_TITL, \r\n"
  67. " (SELECT CMMN_CD_KOR_NM \r\n"
  68. " FROM TB_CMMN_CD \r\n"
  69. " WHERE CMMN_CD = I.VMS_INCD_TYPE_CD \r\n"
  70. " AND CMMN_CLSF_CD = 'VIT') AS VMS_INCD_TYPE_NM, \r\n"
  71. " I.VMS_INCD_TYPE_CD, \r\n"
  72. " CASE WHEN I.VMS_INCD_TYPE_CD = 'VIT1' THEN \r\n"
  73. " (SELECT CMMN_CD_KOR_NM \r\n"
  74. " FROM TB_CMMN_CD \r\n"
  75. " WHERE CMMN_CD = I.VMS_INCD_DETL_TYPE_CD \r\n"
  76. " AND CMMN_CLSF_CD = 'IDT') \r\n"
  77. " ELSE \r\n"
  78. " (SELECT CMMN_CD_KOR_NM \r\n"
  79. " FROM TB_CMMN_CD \r\n"
  80. " WHERE CMMN_CD = I.VMS_INCD_DETL_TYPE_CD \r\n"
  81. " AND CMMN_CLSF_CD = 'EDT') \r\n"
  82. " END AS VMS_INCD_DETL_NM, \r\n"
  83. " I.VMS_INCD_DETL_TYPE_CD, \r\n"
  84. " (SELECT CMMN_CD_KOR_NM \r\n"
  85. " FROM TB_CMMN_CD \r\n"
  86. " WHERE CMMN_CD = I.CMTR_GRAD_CD \r\n"
  87. " AND CMMN_CLSF_CD = 'LTC') AS CMTR_GRAD_NM, \r\n"
  88. #if 0
  89. " I.VMS_INCD_RSTR_TYPE_CD, \r\n"
  90. " (SELECT CMMN_CD_KOR_NM \r\n"
  91. " FROM TB_CMMN_CD \r\n"
  92. " WHERE CMMN_CD = I.VMS_INCD_RSTR_TYPE_CD \r\n"
  93. " AND CMMN_CLSF_CD = 'VRT') AS VMS_INCD_RSTR_TYPE_NM, \r\n"
  94. #endif
  95. " I.CMTR_GRAD_CD, \r\n"
  96. " I.INCD_CLSR_LANE, \r\n"
  97. " I.INCD_STRT_DT, \r\n"
  98. " I.INCD_END_PRAR_DT \r\n"
  99. " FROM (SELECT D.VMS_CTLR_NMBR, A.LINK_ID, \r\n"
  100. " A.IFSC_ID, B.VMS_IFSC_ID, \r\n"
  101. " C.VMS_IFSC_NM, \r\n"
  102. " C.DSPL_STRT_NODE_NM, \r\n"
  103. " C.DSPL_END_NODE_NM, \r\n"
  104. " NVL(C.DETR_ID, 0) AS DETR_ID, \r\n"
  105. " C.ROAD_NM, C.SPOT_NM, \r\n"
  106. " D.DSPL_PRRT \r\n"
  107. " FROM TB_IFSC_LINK_RLTN A, \r\n"
  108. // " FROM TB_IFSC_RLTN_LINK A, \r\n"
  109. // " TB_VMS_IFSC_RLTN_IFSC B, \r\n"
  110. " TB_VMS_LINK_IFSC B, \r\n"
  111. " TB_VMS_IFSC C, \r\n"
  112. " TB_VMS_IFSC_RLTN D \r\n"
  113. " WHERE A.IFSC_ID = B.IFSC_ID \r\n"
  114. " AND B.VMS_IFSC_ID = C.VMS_IFSC_ID \r\n"
  115. " AND C.VMS_IFSC_ID = D.VMS_IFSC_ID ) V, \r\n"
  116. " (SELECT A.*, B.INCD_TITL \r\n"
  117. " FROM TB_INCD_OCRR_VMS A, \r\n"
  118. " TB_INCD_OCRR B \r\n"
  119. " WHERE A.INCD_PRGR_STEP_CD = 'ISS2' \r\n"
  120. " AND A.VMS_DSPL_YN = 'Y' \r\n"
  121. " AND A.INCD_OCRR_ID = B.INCD_OCRR_ID \r\n"
  122. " AND A.INCD_END_PRAR_DT > TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') \r\n"
  123. " AND A.VMS_INCD_TYPE_CD IN ('VIT1', 'VIT2') ) I \r\n"
  124. " WHERE V.LINK_ID = I.LINK_ID \r\n"
  125. " ORDER BY V.VMS_CTLR_NMBR \r\n";
  126. try
  127. {
  128. pADO = new TADOQuery(NULL);
  129. pADO->Connection = ADbConn;
  130. try
  131. {
  132. SQLText(pADO, sQry, false);
  133. SQLOpen(pADO);
  134. int nIdx;
  135. for( ; !pADO->Eof; pADO->Next())
  136. {
  137. AnsiString sVmsNmbr = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  138. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(sVmsNmbr);
  139. if (!pObj) continue;
  140. if (!pObj->FProvide) continue;
  141. AnsiString VMS_INCD_TYPE_CD = pADO->FieldByName("VMS_INCD_TYPE_CD")->AsString;
  142. AnsiString INCD_OCRR_ID = pADO->FieldByName("INCD_OCRR_ID")->AsString;
  143. VMS_EVENT_INFO *pEvt;
  144. if (VMS_INCD_TYPE_CD == "VIT1")
  145. {
  146. //사고
  147. if (pObj->INCIDENT->Count >= VMS_MAX_EVENT)
  148. {
  149. MERROR("VMS Incident Over: %s, %d", pObj->CTLR_NMBR.c_str(), pObj->INCIDENT->Count);
  150. continue;
  151. }
  152. bool bDup = false;
  153. for (int ii = 0; ii < pObj->INCIDENT->Count; ii++)
  154. {
  155. if (INCD_OCRR_ID == pObj->INCIDENT->Unit[ii].INCD_OCRR_ID)
  156. {
  157. bDup = true;
  158. break;
  159. }
  160. }
  161. if (bDup)
  162. {
  163. MERROR("VMS Incident dup: %s, %s", pObj->CTLR_NMBR.c_str(), INCD_OCRR_ID.c_str());
  164. continue;
  165. }
  166. nIdx = pObj->INCIDENT->Count;
  167. pEvt = pObj->INCIDENT;
  168. }
  169. else
  170. {
  171. //공사/행사
  172. if (pObj->EVENT->Count >= VMS_MAX_EVENT)
  173. {
  174. MERROR("VMS Event Over: %s, %d", pObj->CTLR_NMBR.c_str(), pObj->EVENT->Count);
  175. continue;
  176. }
  177. bool bDup = false;
  178. for (int ii = 0; ii < pObj->EVENT->Count; ii++)
  179. {
  180. if (INCD_OCRR_ID == pObj->EVENT->Unit[ii].INCD_OCRR_ID)
  181. {
  182. bDup = true;
  183. break;
  184. }
  185. }
  186. if (bDup)
  187. {
  188. MERROR("VMS Event dup: %s, %s", pObj->CTLR_NMBR.c_str(), INCD_OCRR_ID.c_str());
  189. continue;
  190. }
  191. nIdx = pObj->EVENT->Count;
  192. pEvt = pObj->EVENT;
  193. }
  194. pEvt->Unit[nIdx].LINK_ID = pADO->FieldByName("LINK_ID")->AsString;
  195. pEvt->Unit[nIdx].IFSC_ID = pADO->FieldByName("IFSC_ID")->AsString;
  196. pEvt->Unit[nIdx].VMS_IFSC_ID = pADO->FieldByName("VMS_IFSC_ID")->AsString;
  197. pEvt->Unit[nIdx].VMS_IFSC_NM = pADO->FieldByName("VMS_IFSC_NM")->AsString;
  198. pEvt->Unit[nIdx].DSPL_STRT_NODE_NM = pADO->FieldByName("DSPL_STRT_NODE_NM")->AsString;
  199. pEvt->Unit[nIdx].DSPL_END_NODE_NM = pADO->FieldByName("DSPL_END_NODE_NM")->AsString;
  200. pEvt->Unit[nIdx].DETR_ID = pADO->FieldByName("DETR_ID")->AsString.Trim();
  201. pEvt->Unit[nIdx].DSPL_PRRT = pADO->FieldByName("DSPL_PRRT")->AsString;
  202. pEvt->Unit[nIdx].INCD_OCRR_ID = INCD_OCRR_ID;
  203. pEvt->Unit[nIdx].STRT_LCTN_NM = pADO->FieldByName("STRT_LCTN_NM")->AsString;
  204. pEvt->Unit[nIdx].END_LCTN_NM = pADO->FieldByName("END_LCTN_NM")->AsString;
  205. if (pEvt->Unit[nIdx].STRT_LCTN_NM == "")
  206. {
  207. pEvt->Unit[nIdx].STRT_LCTN_NM = pEvt->Unit[nIdx].DSPL_STRT_NODE_NM;
  208. }
  209. if (pEvt->Unit[nIdx].END_LCTN_NM == "")
  210. {
  211. pEvt->Unit[nIdx].END_LCTN_NM = pEvt->Unit[nIdx].DSPL_END_NODE_NM;
  212. }
  213. pEvt->Unit[nIdx].OCRR_LCTN_NM = pADO->FieldByName("OCRR_LCTN_NM")->AsString;
  214. pEvt->Unit[nIdx].VMS_INCD_TYPE_NM = pADO->FieldByName("VMS_INCD_TYPE_NM")->AsString;
  215. pEvt->Unit[nIdx].VMS_INCD_TYPE_CD = pADO->FieldByName("VMS_INCD_TYPE_CD")->AsString;
  216. pEvt->Unit[nIdx].VMS_INCD_DETL_NM = pADO->FieldByName("VMS_INCD_DETL_NM")->AsString;
  217. pEvt->Unit[nIdx].VMS_INCD_DETL_TYPE_CD = pADO->FieldByName("VMS_INCD_DETL_TYPE_CD")->AsString;
  218. pEvt->Unit[nIdx].CMTR_GRAD_NM = pADO->FieldByName("CMTR_GRAD_NM")->AsString;
  219. pEvt->Unit[nIdx].CMTR_GRAD_CD = pADO->FieldByName("CMTR_GRAD_CD")->AsString;
  220. pEvt->Unit[nIdx].INCD_CLSR_LANE = pADO->FieldByName("INCD_CLSR_LANE")->AsString;
  221. pEvt->Unit[nIdx].INCD_STRT_DT = pADO->FieldByName("INCD_STRT_DT")->AsString;
  222. pEvt->Unit[nIdx].INCD_END_PRAR_DT = pADO->FieldByName("INCD_END_PRAR_DT")->AsString;
  223. pEvt->Unit[nIdx].ROAD_NM = pADO->FieldByName("ROAD_NM")->AsString;
  224. pEvt->Unit[nIdx].SPOT_NM = pADO->FieldByName("SPOT_NM")->AsString;
  225. #if 0
  226. pEvt->Unit[nIdx].VMS_INCD_RSTR_TYPE_CD = pADO->FieldByName("VMS_INCD_RSTR_TYPE_CD")->AsString;
  227. pEvt->Unit[nIdx].VMS_INCD_RSTR_TYPE_NM = pADO->FieldByName("VMS_INCD_RSTR_TYPE_NM")->AsString;
  228. #else
  229. pEvt->Unit[nIdx].VMS_INCD_RSTR_TYPE_CD = "X";
  230. pEvt->Unit[nIdx].VMS_INCD_RSTR_TYPE_NM = "주의요망";
  231. #endif
  232. pEvt->Unit[nIdx].INCD_TITL = pADO->FieldByName("INCD_TITL")->AsString;
  233. pEvt->Count++;
  234. nSelCnt++;
  235. }
  236. }
  237. catch(EDatabaseError &E)
  238. {
  239. DBERROR(String(E.ClassName()), E.Message, sQry);
  240. return -1;
  241. }
  242. catch(Exception &e)
  243. {
  244. DBERROR(String(e.ClassName()), e.Message, sQry);
  245. return -1;
  246. }
  247. }
  248. __finally
  249. {
  250. SQLFree(pADO);
  251. }
  252. if (0)
  253. {
  254. CtlrItr it;
  255. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  256. {
  257. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  258. if (!pObj->Used) continue;
  259. MDEBUG("VMS Event(I/E): %s, %d/%d EA", pObj->CTLR_NMBR.c_str(), pObj->INCIDENT->Count, pObj->EVENT->Count);
  260. }
  261. }
  262. IDBSTOP(nSelCnt);
  263. return nSelCnt;
  264. }
  265. //---------------------------------------------------------------------------
  266. int TCDSManager::LoadVmsScheduleInfo(TADOConnection *ADbConn)
  267. {
  268. AnsiString sQry;
  269. int nSelCnt = 0;
  270. TADOQuery *pADO = NULL;
  271. DDBSTART;
  272. sQry = "SELECT * \r\n"
  273. " FROM ( \r\n"
  274. " SELECT B.*, \r\n"
  275. " SUBSTR(DECODE(TO_CHAR(SYSDATE, 'D'), '1', B.SCH_WEEK1, \r\n"
  276. " '2', B.SCH_WEEK2, \r\n"
  277. " '3', B.SCH_WEEK3, \r\n"
  278. " '4', B.SCH_WEEK4, \r\n"
  279. " '5', B.SCH_WEEK5, \r\n"
  280. " '6', B.SCH_WEEK6, \r\n"
  281. " B.SCH_WEEK7), \r\n"
  282. " TO_NUMBER(TO_CHAR(SYSDATE, 'HH24'))+1, 1) AS SCH_YN \r\n"
  283. " FROM TB_VMS_CTLR A, \r\n"
  284. " TB_VMS_DSPL_SCH B, \r\n"
  285. " TB_VMS_FORM C \r\n"
  286. " WHERE A.DEL_YN = 'N' \r\n"
  287. " AND B.USE_YN = 'Y' \r\n"
  288. " AND C.VALID_YN = 'Y' \r\n"
  289. " AND A.VMS_CTLR_NMBR = B.VMS_CTLR_NMBR \r\n"
  290. " AND A.OPER_MODE = B.VMS_SCH_TYPE \r\n"
  291. " AND B.VMS_FORM_ID = C.VMS_FORM_ID \r\n"
  292. " AND TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') BETWEEN \r\n"
  293. " B.DSPL_STRT_HH AND B.DSPL_END_HH \r\n"
  294. " ) \r\n"
  295. " WHERE SCH_YN = '1' \r\n"
  296. " ORDER BY VMS_CTLR_NMBR ASC, PHASE ASC \r\n";
  297. TCDSForm *pCDSForm;
  298. try
  299. {
  300. pADO = new TADOQuery(NULL);
  301. pADO->Connection = ADbConn;
  302. try
  303. {
  304. SQLText(pADO, sQry, false);
  305. SQLOpen(pADO);
  306. int nIdx;
  307. AnsiString VMS_SCH_TYPE; //VARCHAR2(5) N VMS 스케줄 유형(A:자동,F:고정,B:기본)
  308. int VMS_SCH_FORM_TYPE; //NUMBER(3) N VMS 폼 스케쥴 유형(0:교통,1:돌발,2:공사행사,3:홍보,4:우회,5:정체,6:안전,7:동영상,8:스트리밍영상)
  309. int PHASE; //NUMBER(2) N PHASE
  310. AnsiString VMS_FORM_ID; //NUMBER(5) Y VMS FORM ID
  311. int DSPL_HH; //NUMBER(3) Y 0 표출 시간
  312. AnsiString DSPL_STRT_HH; //VARCHAR2(14) N 표출시작시간
  313. AnsiString DSPL_END_HH; //VARCHAR2(14) N 표출종료시간
  314. AnsiString SYMB_LIB_NMBR; //NUMBER(4) Y 0 동영상인 경우 동영상 파일 심벌 아이디
  315. AnsiString STRM_ADDR; //VARCHAR2(60) Y 스트리밍인경우 스트리밍 주소
  316. bool bBottomTraffic;
  317. TCDSIfsc *pCDSIfsc;
  318. int nBottomTrafficCnt;
  319. int nFigureTrafficCnt; //////////////////////// 20200515 추가함
  320. int nFigureDisplayTm; //////////////////////// 20200515 추가함
  321. String FIGURE_VMS_IFSC_ID; //////////////////////// 20200515 추가함
  322. bool DSPL_CNGS_YN;
  323. AnsiString FRST_VMS_IFSC_ID; //NUMBER(10) Y 1단 VMS 정보제공구간 ID
  324. AnsiString SECD_VMS_IFSC_ID; //NUMBER(10) Y 2단 VMS 정보제공구간 ID
  325. AnsiString THIR_VMS_IFSC_ID; //NUMBER(10) Y 3단 VMS 정보제공구간 ID
  326. AnsiString FOUR_VMS_IFSC_ID; //NUMBER(10) Y 4단 VMS 정보제공구간 ID
  327. AnsiString FRST_IMG_IFSC_ID; //NUMBER(10) Y 1단 이미지 정보제공구간 ID
  328. AnsiString SECD_IMG_IFSC_ID; //NUMBER(10) Y 2단 이미지 정보제공구간 ID
  329. AnsiString THIR_IMG_IFSC_ID; //NUMBER(10) Y 3단 이미지 정보제공구간 ID
  330. AnsiString FOUR_IMG_IFSC_ID; //NUMBER(10) Y 4단 이미지 정보제공구간 ID
  331. for( ; !pADO->Eof; pADO->Next())
  332. {
  333. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  334. //VMS 스케줄 유형(A:자동,F:고정,B:기본)
  335. VMS_SCH_TYPE = pADO->FieldByName("VMS_SCH_TYPE")->AsString;
  336. //VMS 폼 스케쥴 유형(0:교통, 1:돌발,2:공사행사, 3:홍보, 4:우회, 5:정체, 6:안전, 7:동영상, 8:스트리밍영상)
  337. VMS_SCH_FORM_TYPE = pADO->FieldByName("VMS_SCH_FORM_TYPE")->AsInteger;
  338. PHASE = pADO->FieldByName("PHASE")->AsInteger;
  339. VMS_FORM_ID = pADO->FieldByName("VMS_FORM_ID")->AsString.Trim();
  340. DSPL_HH = pADO->FieldByName("DSPL_HH")->AsInteger;
  341. DSPL_STRT_HH = pADO->FieldByName("DSPL_STRT_HH")->AsString.Trim();
  342. DSPL_END_HH = pADO->FieldByName("DSPL_END_HH")->AsString.Trim();
  343. SYMB_LIB_NMBR = pADO->FieldByName("SYMBLIB_NMBR")->AsString.Trim();
  344. STRM_ADDR = pADO->FieldByName("STRM_ADDR")->AsString.Trim();
  345. DSPL_CNGS_YN = pADO->FieldByName("DSPL_CNGS_YN")->AsString.Trim() == "Y" ? true : false;
  346. FRST_VMS_IFSC_ID = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString.Trim();
  347. SECD_VMS_IFSC_ID = pADO->FieldByName("SECD_VMS_IFSC_ID")->AsString.Trim();
  348. THIR_VMS_IFSC_ID = pADO->FieldByName("THIR_VMS_IFSC_ID")->AsString.Trim();
  349. FOUR_VMS_IFSC_ID = pADO->FieldByName("FOUR_VMS_IFSC_ID")->AsString.Trim();
  350. FRST_IMG_IFSC_ID = FRST_VMS_IFSC_ID;//pADO->FieldByName("FRST_IMG_IFSC_ID")->AsString;
  351. SECD_IMG_IFSC_ID = SECD_VMS_IFSC_ID;//pADO->FieldByName("SECD_IMG_IFSC_ID")->AsString;
  352. THIR_IMG_IFSC_ID = THIR_VMS_IFSC_ID;//pADO->FieldByName("THIR_IMG_IFSC_ID")->AsString;
  353. FOUR_IMG_IFSC_ID = FOUR_VMS_IFSC_ID;//pADO->FieldByName("FOUR_IMG_IFSC_ID")->AsString;
  354. if (VMS_SCH_FORM_TYPE < eSchTp_traffic ||
  355. VMS_SCH_FORM_TYPE >= eSchTp_max)
  356. {
  357. MERROR("Unknown Form Type: VmsNmbr(%s), FormId(%s), FormScheduleType(%d)", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str(), VMS_SCH_FORM_TYPE);
  358. continue;
  359. }
  360. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  361. if (!pObj)
  362. {
  363. MERROR("Not Found VMS: VmsNmbr(%s)", VMS_CTLR_NMBR.c_str());
  364. continue;
  365. }
  366. if (!pObj->FProvide)
  367. {
  368. //제공하지 않아도 돼는 VMS - mode change로 호출하는 경우임.
  369. continue;
  370. }
  371. pCDSForm = CDSFormManager->FLists.Find(VMS_FORM_ID);
  372. if (!pCDSForm)
  373. {
  374. MERROR("VMS Schedule Not Found Form: VmsNmbr(%s)-[%s]", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str());
  375. continue;
  376. }
  377. if (pObj->SCHEDULE->Count >= VMS_MAX_SCHEDULE)
  378. {
  379. MERROR("VMS Schedule Count Over: %s, %d", VMS_CTLR_NMBR.c_str(), pObj->SCHEDULE->Count);
  380. continue;
  381. }
  382. //TODO: 조회정렬은 기본,고정,자동(돌발,공사,행사,우회,교통,정체폼) 순으로 조회된다.
  383. // 따라서 각 폼에 대한처리를 수행하면 된다.
  384. //==> 신규작업에서 폼 표출 우선순위적용함 ==> 조회정렬이 영향이 있는지 확인해야함.
  385. //eFormTp_traf_1 = 11, // 소통상황(1단)
  386. //eFormTp_traf_2 = 12, // 소통상황(2단)
  387. //eFormTp_traf_3 = 13, // 소통상황(3단)
  388. //eFormTp_traf_4 = 14, // 소통상황(4단)
  389. if (VMS_SCH_FORM_TYPE == eSchTp_traffic && pCDSForm->VMS_FORM_TYPE_CD == eFormTp_traf_1)
  390. {
  391. //교통정보스케쥴이고 폼의 유형이 소통정보(1단) 인경우....
  392. //해당 폼이 돌발이나 이벤트가 등록되어 있다면
  393. //폼을 생성하지 않는다.
  394. AnsiString FRST_VMS_IFSC_ID = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
  395. if (FRST_VMS_IFSC_ID != "")
  396. {
  397. for (int ii = 0; ii < pObj->SCHEDULE->Count && ii < VMS_MAX_SCHEDULE; ii++)
  398. {
  399. if (pObj->SCHEDULE->Unit[ii].VMS_SCH_FORM_TYPE == eSchTp_incident || //돌발
  400. pObj->SCHEDULE->Unit[ii].VMS_SCH_FORM_TYPE == eSchTp_gongsa || //공사/행사
  401. pObj->SCHEDULE->Unit[ii].VMS_SCH_FORM_TYPE == eSchTp_deture ) //우회
  402. {
  403. if (pObj->SCHEDULE->Unit[ii].EVENT)
  404. {
  405. if (FRST_VMS_IFSC_ID == pObj->SCHEDULE->Unit[ii].EVENT->VMS_IFSC_ID)
  406. {
  407. //폼을 생성하지 않는다.
  408. continue;
  409. }
  410. }
  411. }
  412. }
  413. }
  414. }
  415. bBottomTraffic = false;
  416. nFigureDisplayTm = DSPL_HH;
  417. FIGURE_VMS_IFSC_ID = "";
  418. nFigureTrafficCnt = 0; //전체 표출할 하단 소통정보 갯수
  419. switch(VMS_SCH_FORM_TYPE)
  420. {
  421. case eSchTp_traffic: //교통정보
  422. //도형식 소통정보 인 경우 해당 도형의 소통정보가 존재하는지 확인
  423. if (pCDSForm->VMS_FORM_TYPE_CD == eFormtp_figure)
  424. {
  425. bool bTraffic = false;
  426. TCDSImage *pBakTrfImg = CDSImageManager->FLists.Find(pCDSForm->TrfBakImgId);
  427. if (pBakTrfImg)
  428. {
  429. FOR_STL(TCDSImageCell*, pCell, pBakTrfImg->FLists)
  430. {
  431. TCDSIfsc *pTmpIfsc1 = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  432. if (pTmpIfsc1)
  433. {
  434. if (pTmpIfsc1->CMTR_GRAD_CD != "0")
  435. {
  436. FIGURE_VMS_IFSC_ID = pCell->VMS_IFSC_ID; // 하단에 표출할 정보가 없을 경우 첫번째 제공구간을 표출하기 위함. 20200515 추가함
  437. bTraffic = true; //소통정보가 하나라도 존재함
  438. break;
  439. }
  440. }
  441. }
  442. }
  443. /////////////////////////////////////////////////////// TODO 20200528 ==> 민간정보 연계에서 정보가 수집되지 않는 경우 가 종종 있어서
  444. /////////////////////////////////////////////////////// 도형식 소통정보를 채우지 못한다.
  445. /////////////////////////////////////////////////////// 결측구간이 3구간 이상이면 도형식 소통정보 표출하지 말자
  446. if (bTraffic)
  447. {
  448. int nMissingCnt = 0;
  449. TCDSIfsc *pTmpIfsc1;
  450. FOR_STL(TCDSImageCell*, pCell, pBakTrfImg->FLists)
  451. {
  452. if (pCell->IsDup) continue; //중복 VMS_IFSC_ID 인 경우 skip...
  453. pTmpIfsc1 = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  454. if (pTmpIfsc1)
  455. {
  456. if (pTmpIfsc1->CMTR_GRAD_CD == "0")
  457. {
  458. nMissingCnt++;
  459. }
  460. }
  461. }
  462. if (nMissingCnt >= 3)
  463. {
  464. bTraffic == false;
  465. MERROR("VMS Figure IFSC Traffic Missing count over: VmsNmbr(%s)-[%s], %d EA Missing", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str(), nMissingCnt);
  466. }
  467. }
  468. if (bTraffic == false)
  469. {
  470. //도형식 구간의 모든 소통정보가 생성되지 않았음===> 가공서버가 죽었거나 수집되지 않았음.
  471. //표출할 내용이 없음==> skip 해야함
  472. MERROR("VMS Figure IFSC Traffic Failed: VmsNmbr(%s)-[%s]", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str());
  473. continue;
  474. }
  475. }
  476. //도형식 소통정보 폼일때 하단에 정보제공구간 소통정보를 표출해야 하는 경우
  477. if (pCDSForm->VMS_FORM_TYPE_CD == eFormtp_figure && pCDSForm->TrfIfsc)
  478. {
  479. //도형식 VMS인 경우 하단에 소통정보를 표출하는 경우 다중폼이 생성됨
  480. //제공구간소통정보가 정체, 지체인 경우만 하단 소통정보를 표출함
  481. //도형식 배경셀에 등록된 구간에 대해서 표출하도록함
  482. TCDSImage *pBakTrfImg = CDSImageManager->FLists.Find(pCDSForm->TrfBakImgId);
  483. if (pBakTrfImg)
  484. {
  485. TCDSIfsc *pTmpIfsc1;
  486. //정체구간 갯수 확인
  487. FOR_STL(TCDSImageCell*, pCell, pBakTrfImg->FLists)
  488. {
  489. if (pCell->IsDup) continue; //중복 VMS_IFSC_ID 인 경우 skip...
  490. pTmpIfsc1 = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  491. if (pTmpIfsc1)
  492. {
  493. if (pTmpIfsc1->CMTR_GRAD_CD == "3")
  494. {
  495. bBottomTraffic = true; //도형식배경소통정보의 셀내의 구간정보 소통정보가 하나라도 있으면
  496. //도형식 소통정보를 표출함
  497. nFigureTrafficCnt++;
  498. //break;
  499. }
  500. }
  501. }
  502. //지체(서행)구간 갯수 확인
  503. FOR_STL(TCDSImageCell*, pCell, pBakTrfImg->FLists)
  504. {
  505. if (pCell->IsDup) continue; //중복 VMS_IFSC_ID 인 경우 skip...
  506. pTmpIfsc1 = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  507. if (pTmpIfsc1)
  508. {
  509. if (pTmpIfsc1->CMTR_GRAD_CD == "2")
  510. {
  511. bBottomTraffic = true; //도형식배경소통정보의 셀내의 구간정보 소통정보가 하나라도 있으면
  512. //도형식 소통정보를 표출함
  513. nFigureTrafficCnt++;
  514. //break;
  515. }
  516. }
  517. }
  518. //////////////////////// 20200515 추가함(S)
  519. if (FIGURE_VMS_IFSC_ID != "" && bBottomTraffic == false)
  520. {
  521. //소통정보는 존재하지만 지체, 정체가 없는 경우 하단 소통정보를 표출못하게 된다.
  522. //만일 하단 고정문자가 존재하는 경우 하단 고정문자를 표출하면 되지만
  523. //고정문자가 존재하기 않으면 하단에 표출할 정보가 없으므로 첫번째 구간의 정보를 표출하도록 한다.
  524. if (pCDSForm->TrfFixed == false)
  525. {
  526. bBottomTraffic = true; //첫번째 소통정보가 표출되도록 함
  527. nFigureTrafficCnt++;
  528. }
  529. }
  530. //////////////////////// 20200515 추가함(E)
  531. }
  532. }
  533. //도형식 소통정보 폼일때 하단에 VMS 축 소통정보를 표출해야 하는 경우
  534. if (pCDSForm->VMS_FORM_TYPE_CD == eFormtp_figure && pCDSForm->TrfAxis)
  535. {
  536. //도형식 VMS인 경우 하단에 소통정보를 표출하는 경우 다중폼이 생성됨
  537. //축 소통정보인 경우 모든 축에 대해 소통정보를 표출, 최대 표출설정값이 설정된 경우 설정값만큼만 표출되게 수정(20200515)
  538. FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
  539. {
  540. if (!pIfsc->IsUsed) continue;
  541. pCDSIfsc = CDSIfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
  542. if (!pCDSIfsc) continue;
  543. if (pCDSIfsc->AXIS_YN != "Y") continue;
  544. if (pCDSIfsc->CMTR_GRAD_CD != "0")
  545. {
  546. if (FIGURE_VMS_IFSC_ID == "")
  547. {
  548. FIGURE_VMS_IFSC_ID = pIfsc->VMS_IFSC_ID; // 하단에 표출할 정보가 없을 경우 첫번째 제공구간을 표출하기 위함. 20200515 추가함
  549. }
  550. bBottomTraffic = true;
  551. nFigureTrafficCnt++;
  552. //break;
  553. }
  554. }
  555. //////////////////////// 20200515 추가함(S)
  556. if (FIGURE_VMS_IFSC_ID != "" && bBottomTraffic == false)
  557. {
  558. //소통정보는 존재하지만 지체, 정체가 없는 경우 하단 소통정보를 표출못하게 된다.
  559. //만일 하단 고정문자가 존재하는 경우 하단 고정문자를 표출하면 되지만
  560. //고정문자가 존재하기 않으면 하단에 표출할 정보가 없으므로 첫번째 구간의 정보를 표출하도록 한다.
  561. if (pCDSForm->TrfFixed == false)
  562. {
  563. bBottomTraffic = true; //첫번째 소통정보가 표출되도록 함
  564. nFigureTrafficCnt++;
  565. }
  566. }
  567. //////////////////////// 20200515 추가함(E)
  568. }
  569. //////////////////////// 20200515 추가함(S)
  570. if (bBottomTraffic && g_AppCfg.BottomTrafficMaxCnt > 0)
  571. {
  572. //하단소통정보를 일정갯수만 표출하는 경우 표출할 소통정보가 설정값보다 크면 설정값으로 맞춘다.
  573. if (nFigureTrafficCnt > g_AppCfg.BottomTrafficMaxCnt)
  574. {
  575. nFigureTrafficCnt = g_AppCfg.BottomTrafficMaxCnt;
  576. }
  577. if (g_AppCfg.BottomTrafficCycle > 0)
  578. {
  579. int nTm = nFigureDisplayTm / nFigureTrafficCnt;
  580. if (nTm < g_AppCfg.BottomTrafficCycle)
  581. {
  582. //표출할 시간이 설정값보다 작으로 설정값으로 표출시각을 설정
  583. nFigureDisplayTm = g_AppCfg.BottomTrafficCycle;
  584. }
  585. else
  586. {
  587. nFigureDisplayTm = nTm; // 설정값보다 크면 계산된 값을 표출시각으로 설정
  588. }
  589. }
  590. }
  591. //////////////////////// 20200515 추가함(E)
  592. nBottomTrafficCnt = 0;
  593. if (bBottomTraffic)
  594. {
  595. //도형식 다중 소통정보 표출인 경우
  596. //하단소통정보를 표출하는경우 정체, 지체 순으로 표출
  597. if (pCDSForm->TrfIfsc)
  598. {
  599. //정보제공구간 소통정보 순환표출(정체)
  600. //도형식 배경셀에 등록된 구간에 대해서 표출하도록함
  601. TCDSImage *pBakTrfImg1 = CDSImageManager->FLists.Find(pCDSForm->TrfBakImgId);
  602. if (pBakTrfImg1)
  603. {
  604. FOR_STL(TCDSImageCell*, pCell, pBakTrfImg1->FLists)
  605. {
  606. if (pCell->IsDup) continue; //중복 VMS_IFSC_ID 인 경우 skip...
  607. TCDSIfsc *pTmpIfsc1 = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  608. if (!pTmpIfsc1) continue;
  609. if (pTmpIfsc1->CMTR_GRAD_CD != "3") continue;
  610. nIdx = pObj->SCHEDULE->Count;
  611. if (nIdx < VMS_MAX_SCHEDULE)
  612. {
  613. nIdx = pObj->SCHEDULE->Count;
  614. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  615. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  616. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  617. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  618. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = pCell->VMS_IFSC_ID;
  619. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  620. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  621. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  622. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  623. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  624. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  625. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  626. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = nFigureDisplayTm; //도형식폼이 실제로 표출될 시간
  627. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pCell->VMS_IFSC_ID; //하단 제공구간 ID
  628. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  629. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  630. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  631. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  632. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  633. pObj->SCHEDULE->Count++;
  634. nSelCnt++;
  635. nBottomTrafficCnt++;
  636. if (g_AppCfg.BottomTrafficMaxCnt > 0 && nBottomTrafficCnt >= g_AppCfg.BottomTrafficMaxCnt)
  637. {
  638. break;
  639. }
  640. }
  641. }
  642. }
  643. //정보제공구간 소통정보 순환표출(지체)
  644. //도형식 배경셀에 등록된 구간에 대해서 표출
  645. TCDSImage *pBakTrfImg2 = CDSImageManager->FLists.Find(pCDSForm->TrfBakImgId);
  646. if (pBakTrfImg2)
  647. {
  648. FOR_STL(TCDSImageCell*, pCell, pBakTrfImg2->FLists)
  649. {
  650. if (pCell->IsDup) continue; //중복 VMS_IFSC_ID 인 경우 skip...
  651. TCDSIfsc *pTmpIfsc1 = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  652. if (!pTmpIfsc1) continue;
  653. if (pTmpIfsc1->CMTR_GRAD_CD != "2") continue;
  654. if (g_AppCfg.BottomTrafficMaxCnt > 0 && nBottomTrafficCnt >= g_AppCfg.BottomTrafficMaxCnt)
  655. {
  656. break;
  657. }
  658. nIdx = pObj->SCHEDULE->Count;
  659. if (nIdx < VMS_MAX_SCHEDULE)
  660. {
  661. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  662. nIdx = pObj->SCHEDULE->Count;
  663. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  664. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  665. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  666. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = pCell->VMS_IFSC_ID;
  667. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  668. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  669. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  670. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = nFigureDisplayTm; //도형식폼이 실제로 표출될 시간
  671. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pCell->VMS_IFSC_ID; //하단 제공구간 ID
  672. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  673. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  674. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  675. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  676. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  677. pObj->SCHEDULE->Count++;
  678. nSelCnt++;
  679. nBottomTrafficCnt++;
  680. }
  681. }
  682. }
  683. //////////////////////// 20200515 추가함(S)
  684. if (nBottomTrafficCnt == 0)
  685. {
  686. //소통정보가 모두 소통원활이고 하단고정문자표출도 없는 경우 첫번째 정보제공구간의 소통정보를 표출하도록 한다.
  687. nIdx = pObj->SCHEDULE->Count;
  688. if (nIdx < VMS_MAX_SCHEDULE)
  689. {
  690. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  691. nIdx = pObj->SCHEDULE->Count;
  692. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  693. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  694. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  695. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FIGURE_VMS_IFSC_ID;
  696. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  697. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  698. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  699. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = nFigureDisplayTm; //도형식폼이 실제로 표출될 시간
  700. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = FIGURE_VMS_IFSC_ID; //하단 제공구간 ID
  701. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  702. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  703. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  704. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  705. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  706. pObj->SCHEDULE->Count++;
  707. nSelCnt++;
  708. nBottomTrafficCnt++;
  709. }
  710. }
  711. //////////////////////// 20200515 추가함(E)
  712. } //도형식배경소통정보 처리 완료
  713. if (pCDSForm->TrfAxis)
  714. {
  715. //축소통정보 순환표출
  716. FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
  717. {
  718. if (!pIfsc->IsUsed) continue;
  719. pCDSIfsc = CDSIfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
  720. if (!pCDSIfsc) continue;
  721. if (pCDSIfsc->AXIS_YN != "Y") continue;
  722. if (pCDSIfsc->CMTR_GRAD_CD == "0") continue;
  723. nIdx = pObj->SCHEDULE->Count;
  724. if (nIdx < VMS_MAX_SCHEDULE)
  725. {
  726. nIdx = pObj->SCHEDULE->Count;
  727. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  728. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  729. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  730. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  731. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  732. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  733. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  734. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  735. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  736. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  737. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  738. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  739. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = nFigureDisplayTm; //도형식폼이 실제로 표출될 시간
  740. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pIfsc->VMS_IFSC_ID; //하단 제공구간 ID
  741. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  742. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  743. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  744. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  745. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  746. pObj->SCHEDULE->Count++;
  747. nSelCnt++;
  748. nBottomTrafficCnt++;
  749. if (g_AppCfg.BottomTrafficMaxCnt > 0 && nBottomTrafficCnt >= g_AppCfg.BottomTrafficMaxCnt)
  750. {
  751. break;
  752. }
  753. }
  754. }
  755. //////////////////////// 20200515 추가함(S)
  756. if (nBottomTrafficCnt == 0)
  757. {
  758. //소통정보가 모두 소통원활이고 하단고정문자표출도 없는 경우 첫번째 VMS축의 소통정보를 표출하도록 한다.
  759. nIdx = pObj->SCHEDULE->Count;
  760. if (nIdx < VMS_MAX_SCHEDULE)
  761. {
  762. nIdx = pObj->SCHEDULE->Count;
  763. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  764. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  765. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  766. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  767. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FIGURE_VMS_IFSC_ID;
  768. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = FIGURE_VMS_IFSC_ID;
  769. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = FIGURE_VMS_IFSC_ID;
  770. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FIGURE_VMS_IFSC_ID;
  771. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  772. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  773. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  774. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  775. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = nFigureDisplayTm; //도형식폼이 실제로 표출될 시간
  776. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = FIGURE_VMS_IFSC_ID; //하단 제공구간 ID
  777. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  778. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  779. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  780. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  781. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  782. pObj->SCHEDULE->Count++;
  783. nSelCnt++;
  784. nBottomTrafficCnt++;
  785. }
  786. }
  787. //////////////////////// 20200515 추가함(E)
  788. }
  789. }
  790. else
  791. {
  792. //도형식 다중표출이 아닌경우(하단소통정보가 없는 경우)
  793. nIdx = pObj->SCHEDULE->Count;
  794. if (nIdx < VMS_MAX_SCHEDULE)
  795. {
  796. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  797. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  798. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  799. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  800. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  801. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  802. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  803. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  804. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  805. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  806. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  807. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  808. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  809. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  810. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  811. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  812. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  813. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  814. pObj->SCHEDULE->Count++;
  815. nSelCnt++;
  816. }
  817. }
  818. break;
  819. case eSchTp_safe: //재난안전
  820. //재난안전 스케줄인 경우 해당 VMS에 발생한 모든 재난안전 정보를 표출하도록 스케줄 추가
  821. for (int ii = 0; ii < pObj->SAFE->Count && ii < VMS_MAX_SAFE; ii++)
  822. {
  823. //if (pForm->MSG_TP == pObj->SAFE->Unit[ii].MSG_TP) //재난안전 메시지 표출요형이 같은경우에만(2단,3단메시지)
  824. {
  825. nIdx = pObj->SCHEDULE->Count;
  826. if (nIdx < VMS_MAX_SCHEDULE)
  827. {
  828. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  829. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  830. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  831. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  832. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  833. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  834. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  835. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  836. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  837. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  838. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  839. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  840. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  841. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  842. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  843. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  844. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  845. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  846. pObj->SCHEDULE->Unit[nIdx].SAFE = &pObj->SAFE->Unit[ii];
  847. pObj->SCHEDULE->Count++;
  848. nSelCnt++;
  849. }
  850. }
  851. }
  852. break;
  853. case eSchTp_incident: //돌발
  854. //돌발 스케줄인 경우 해당 VMS에 발생한 모든 돌발 정보를 표출하도록 스케줄 추가
  855. for (int ii = 0; ii < pObj->INCIDENT->Count; ii++)
  856. {
  857. nIdx = pObj->SCHEDULE->Count;
  858. if (nIdx < VMS_MAX_SCHEDULE)
  859. {
  860. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  861. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  862. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  863. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  864. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  865. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  866. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  867. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  868. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  869. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  870. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  871. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  872. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  873. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pObj->INCIDENT->Unit[ii].VMS_IFSC_ID;
  874. pObj->SCHEDULE->Unit[nIdx].EVENT = &pObj->INCIDENT->Unit[ii];
  875. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  876. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  877. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  878. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  879. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  880. pObj->SCHEDULE->Count++;
  881. nSelCnt++;
  882. }
  883. }
  884. break;
  885. case eSchTp_gongsa: //공사/행사문안
  886. //공사/행사 스케줄인 경우 해당 VMS에 발생한 모든 돌발 정보를 표출하도록 스케줄 추가
  887. for (int ii = 0; ii < pObj->EVENT->Count; ii++)
  888. {
  889. nIdx = pObj->SCHEDULE->Count;
  890. if (nIdx < VMS_MAX_SCHEDULE)
  891. {
  892. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  893. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  894. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  895. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  896. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  897. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  898. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  899. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  900. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  901. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  902. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  903. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  904. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  905. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pObj->EVENT->Unit[ii].VMS_IFSC_ID;
  906. pObj->SCHEDULE->Unit[nIdx].EVENT = &pObj->EVENT->Unit[ii];
  907. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  908. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  909. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  910. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  911. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  912. pObj->SCHEDULE->Count++;
  913. nSelCnt++;
  914. }
  915. }
  916. break;
  917. case eSchTp_hongbo: //홍보
  918. nIdx = pObj->SCHEDULE->Count;
  919. if (nIdx < VMS_MAX_SCHEDULE)
  920. {
  921. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  922. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  923. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  924. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  925. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  926. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  927. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  928. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  929. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  930. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  931. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  932. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  933. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  934. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  935. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  936. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  937. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  938. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  939. pObj->SCHEDULE->Count++;
  940. nSelCnt++;
  941. }
  942. break;
  943. case eSchTp_deture: //우회도로
  944. //돌발발생한 구간중 우회도로 구간이 있는경우
  945. for (int ii = 0; ii < pObj->INCIDENT->Count; ii++)
  946. {
  947. if (pObj->INCIDENT->Unit[ii].DETR_ID == "0") continue;
  948. nIdx = pObj->SCHEDULE->Count;
  949. if (nIdx < VMS_MAX_SCHEDULE)
  950. {
  951. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  952. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  953. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  954. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  955. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  956. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  957. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  958. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  959. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  960. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  961. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  962. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  963. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  964. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pObj->INCIDENT->Unit[ii].VMS_IFSC_ID;
  965. pObj->SCHEDULE->Unit[nIdx].EVENT = &pObj->INCIDENT->Unit[ii];
  966. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  967. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  968. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  969. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  970. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  971. pObj->SCHEDULE->Count++;
  972. nSelCnt++;
  973. }
  974. }
  975. //공사/행사 발생한 구간중 우회도로 구간이 있는경우
  976. for (int ii = 0; ii < pObj->EVENT->Count; ii++)
  977. {
  978. if (pObj->EVENT->Unit[ii].DETR_ID == "0") continue;
  979. nIdx = pObj->SCHEDULE->Count;
  980. if (nIdx < VMS_MAX_SCHEDULE)
  981. {
  982. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  983. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  984. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  985. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  986. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  987. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  988. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  989. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  990. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  991. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  992. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  993. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  994. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  995. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pObj->EVENT->Unit[ii].VMS_IFSC_ID;
  996. pObj->SCHEDULE->Unit[nIdx].EVENT = &pObj->EVENT->Unit[ii];
  997. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  998. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  999. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1000. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1001. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1002. pObj->SCHEDULE->Count++;
  1003. nSelCnt++;
  1004. }
  1005. }
  1006. break;
  1007. case eSchTp_congest: //정체상황
  1008. {
  1009. //VMS에 설정된 모든 정체구간판정구간에 대하여 정체 판정
  1010. int nCngsCnt = 0;
  1011. FOR_STL(TVmsIfsc*, pCngs, pObj->FIfscLists)
  1012. {
  1013. if (!pCngs->IsUsed) continue;
  1014. if (!pCngs->CNGS_CNFM_YN) continue; //정체판정이 아닌경우
  1015. if (pCngs->CNGST_CNT < g_AppCfg.CngsContCnt) continue; //설정되어 있는 정체판정 횟수보다 작으면 정체아님
  1016. //정체판정된 정체폼 생성
  1017. //스케쥴갯수를 초과하지 않으면 폼 스케쥴추가
  1018. nIdx = pObj->SCHEDULE->Count;
  1019. if (nIdx < VMS_MAX_SCHEDULE && nCngsCnt <= pObj->FMaxCngsForm)
  1020. {
  1021. pObj->FExistCngsForm = true; // TODO: 해당 제어기에 정체폼이 존재하는지를 플래그 설정
  1022. // 다른 폼들은 정체폼이 존재할때 표출할지 여부가 결정됨
  1023. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1024. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1025. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1026. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1027. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = pCngs->VMS_IFSC_ID;
  1028. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  1029. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  1030. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  1031. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = "";
  1032. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = "";
  1033. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = "";
  1034. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = "";
  1035. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1036. pObj->SCHEDULE->Unit[nIdx].VMS_IFSC_ID = pCngs->VMS_IFSC_ID;
  1037. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1038. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1039. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1040. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1041. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1042. pObj->SCHEDULE->Count++;
  1043. nSelCnt++;
  1044. }
  1045. }
  1046. }
  1047. break;
  1048. case eSchTp_video: //동영상
  1049. case eSchTp_stream: //스트리밍영상
  1050. nIdx = pObj->SCHEDULE->Count;
  1051. if (nIdx < VMS_MAX_SCHEDULE)
  1052. {
  1053. //동영상명칭이나 스트리밍주소가 설정되지 않은 것은 표출하지 않는다.
  1054. #if 0
  1055. // TODO: 202411218
  1056. if ( (VMS_SCH_FORM_TYPE == eSchTp_video && SYMB_LIB_NMBR != "" && SYMB_LIB_NMBR == "200" && STRM_ADDR != "") ||
  1057. (VMS_SCH_FORM_TYPE == eSchTp_stream && SYMB_LIB_NMBR != "" && SYMB_LIB_NMBR == "300" && STRM_ADDR != "") )
  1058. #else
  1059. if ( (VMS_SCH_FORM_TYPE == eSchTp_video && SYMB_LIB_NMBR != "" && SYMB_LIB_NMBR == "200") ||
  1060. (VMS_SCH_FORM_TYPE == eSchTp_stream && SYMB_LIB_NMBR != "" && SYMB_LIB_NMBR == "300") )
  1061. #endif
  1062. {
  1063. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1064. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1065. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1066. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1067. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  1068. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  1069. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  1070. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  1071. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  1072. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  1073. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  1074. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  1075. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1076. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1077. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1078. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1079. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1080. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1081. pObj->SCHEDULE->Count++;
  1082. nSelCnt++;
  1083. }
  1084. }
  1085. break;
  1086. case eSchTp_atmp: //9:대기환경
  1087. {
  1088. AnsiString ATMP_STTN_NMBR = "";
  1089. bool isAtmp = false;
  1090. if (CDSAtmpManager)
  1091. {
  1092. FOR_STL(TCDSFormObj*, pTmpObj, pCDSForm->FLists)
  1093. {
  1094. if (pTmpObj->VMS_FORM_OBJECT_TYPE_CD >= 401 && pTmpObj->VMS_FORM_OBJECT_TYPE_CD <= 413)
  1095. {
  1096. ATMP_STTN_NMBR = pTmpObj->VMS_IFSC_ID;
  1097. TCDSAtmp *pAtmp = CDSAtmpManager->FLists.Find(pTmpObj->VMS_IFSC_ID);
  1098. if (pAtmp && pAtmp->SUCCESS)
  1099. {
  1100. isAtmp = true;
  1101. break;
  1102. }
  1103. }
  1104. }
  1105. }
  1106. if (isAtmp == false)
  1107. {
  1108. //폼에 속한 대기환경의 모든 정보가 유효하지 않는 경우 폼을 생성하지 않는다.
  1109. MERROR("VMS ATMP Failed: VmsNmbr(%s)-[%s]", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str());
  1110. break;
  1111. }
  1112. nIdx = pObj->SCHEDULE->Count;
  1113. if (nIdx < VMS_MAX_SCHEDULE)
  1114. {
  1115. #if 0
  1116. AnsiString ATMP_STTN_NMBR = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
  1117. TCDSAtmp *pAtmpObj = CDSAtmpManager->FLists.Find(ATMP_STTN_NMBR);
  1118. if (!pAtmpObj) break;
  1119. if (pAtmpObj->SUCCESS == false)
  1120. {
  1121. MERROR("VMS ATMP Failed: VmsNmbr(%s)-[%s], %s.%s", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str(), ATMP_STTN_NMBR.c_str(), pAtmpObj->ATMP_STTN_NM.c_str());
  1122. break;
  1123. }
  1124. #endif
  1125. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1126. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1127. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1128. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1129. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = ATMP_STTN_NMBR;
  1130. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  1131. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  1132. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  1133. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = "";
  1134. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = "";
  1135. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = "";
  1136. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = "";
  1137. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1138. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1139. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1140. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1141. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1142. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1143. pObj->SCHEDULE->Count++;
  1144. nSelCnt++;
  1145. }
  1146. }
  1147. break;
  1148. case eSchTp_park: //10:주차정보
  1149. {
  1150. bool isParkingForm = false;
  1151. FOR_STL(TCDSFormObj*, pTmpObj, pCDSForm->FLists)
  1152. {
  1153. if (pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 101 ||
  1154. pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 102 ||
  1155. pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 103 ||
  1156. pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 104)
  1157. {
  1158. TCDSPark *pPark = NULL;
  1159. if (CDSParkManager) {
  1160. pPark = CDSParkManager->FLists.Find(pTmpObj->VMS_IFSC_ID); //주차장아이디로 주차장정보를 찾음
  1161. }
  1162. if (pPark && pPark->SUCCESS)
  1163. {
  1164. isParkingForm = true;
  1165. break;
  1166. }
  1167. }
  1168. }
  1169. if (isParkingForm == false)
  1170. {
  1171. //폼에 속한 주차장의 모든 정보가 유효하지 않는 경우 폼을 생성하지 않는다.
  1172. MERROR("VMS PARKING Failed: VmsNmbr(%s)-[%s]", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str());
  1173. break;
  1174. }
  1175. nIdx = pObj->SCHEDULE->Count;
  1176. if (nIdx < VMS_MAX_SCHEDULE)
  1177. {
  1178. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1179. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1180. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1181. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1182. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = "";
  1183. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  1184. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  1185. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  1186. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = "";
  1187. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = "";
  1188. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = "";
  1189. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = "";
  1190. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1191. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1192. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1193. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1194. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1195. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1196. pObj->SCHEDULE->Count++;
  1197. nSelCnt++;
  1198. }
  1199. }
  1200. break;
  1201. }
  1202. }
  1203. }
  1204. catch(EDatabaseError &E)
  1205. {
  1206. DBERROR(String(E.ClassName()), E.Message, sQry);
  1207. return -1;
  1208. }
  1209. catch(Exception &e)
  1210. {
  1211. DBERROR(String(e.ClassName()), e.Message, sQry);
  1212. return -1;
  1213. }
  1214. }
  1215. __finally
  1216. {
  1217. SQLFree(pADO);
  1218. }
  1219. if (0)
  1220. {
  1221. CtlrItr it;
  1222. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1223. {
  1224. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1225. if (!pObj->Used) continue;
  1226. MDEBUG("VMS Schedule: %s, %d EA", pObj->CTLR_NMBR.c_str(), pObj->SCHEDULE->Count);
  1227. }
  1228. }
  1229. IDBSTOP(nSelCnt);
  1230. return nSelCnt;
  1231. }
  1232. //---------------------------------------------------------------------------
  1233. int TCDSManager::LoadVmsOperationMode(TADOConnection *ADbConn)
  1234. {
  1235. AnsiString sQry;
  1236. int nSelCnt = 0;
  1237. TADOQuery *pADO = NULL;
  1238. DDBSTART;
  1239. sQry = "SELECT A.VMS_CTLR_NMBR, A.OPER_MODE, \r\n"
  1240. " NVL(A.VMS_MAX_PHSE_NUM, 16) AS VMS_MAX_PHSE_NUM \r\n"
  1241. " FROM TB_VMS_CTLR A \r\n"
  1242. " WHERE A.DEL_YN = 'N' \r\n";
  1243. try
  1244. {
  1245. pADO = new TADOQuery(NULL);
  1246. pADO->Connection = ADbConn;
  1247. try
  1248. {
  1249. SQLText(pADO, sQry, false);
  1250. SQLOpen(pADO);
  1251. for( ; !pADO->Eof; pADO->Next())
  1252. {
  1253. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  1254. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1255. if (!pObj) continue;
  1256. pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString.Trim();
  1257. int nMaxFormCnt = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsInteger;
  1258. if (pObj->OPER_MODE != "A" && pObj->OPER_MODE != "F" && pObj->OPER_MODE != "B")
  1259. {
  1260. pObj->OPER_MODE = "A";
  1261. }
  1262. if (pObj->OPER_MODE == "A")
  1263. pObj->DSTATE.OprMode = 'A';
  1264. else
  1265. if (pObj->OPER_MODE == "B")
  1266. pObj->DSTATE.OprMode = 'B';
  1267. else
  1268. pObj->DSTATE.OprMode = 'F';
  1269. if (pObj->CTRLMODE->Control == pObj->DSTATE.OprMode)
  1270. pObj->FModeChange = false;
  1271. else
  1272. pObj->FModeChange = true;
  1273. pObj->CTRLMODE->Control = pObj->DSTATE.OprMode;
  1274. pObj->RSTATE.OprMode = pObj->CTRLMODE->Control;
  1275. //pObj->VMS_MAX_PHSE_NUM = INT_VMS_MAX_FORM; //nMaxFormCnt;
  1276. if (pObj->VMS_MAX_PHSE_NUM > INT_VMS_MAX_FORM)
  1277. pObj->VMS_MAX_PHSE_NUM = INT_VMS_MAX_FORM;
  1278. pObj->CTRLMODE->MaxDisplayForm = pObj->VMS_MAX_PHSE_NUM;
  1279. #if 0
  1280. if (pObj->CTRLMODE->MaxDisplayForm > INT_MAX_VMS_FORM)
  1281. pObj->CTRLMODE->MaxDisplayForm = INT_MAX_VMS_FORM;
  1282. #endif
  1283. //VMS별 정체폼갯수를 제한하는 경우 여기에서 처리하도록 하자
  1284. pObj->FMaxCngsForm = VMS_MAX_CNGS_FORM; //현재는 디폴트, 즉 모든정보 생성
  1285. nSelCnt++;
  1286. }
  1287. }
  1288. catch(EDatabaseError &E)
  1289. {
  1290. DBERROR(String(E.ClassName()), E.Message, sQry);
  1291. return -1;
  1292. }
  1293. catch(Exception &e)
  1294. {
  1295. DBERROR(String(e.ClassName()), e.Message, sQry);
  1296. return -1;
  1297. }
  1298. }
  1299. __finally
  1300. {
  1301. SQLFree(pADO);
  1302. }
  1303. IDBSTOP(nSelCnt);
  1304. return nSelCnt;
  1305. }
  1306. //---------------------------------------------------------------------------
  1307. int TCDSManager::UpdateVmsProvideResult(TADOConnection *ADbConn, void *ACtlrObj)
  1308. {
  1309. int nSelCnt = 0;
  1310. AnsiString sQry;
  1311. TADOQuery *pADO = NULL;
  1312. int nFormCnt = 0;
  1313. // DDBSTART;
  1314. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1315. if (!AObj) return VERR_MEMORY_ALLOC;
  1316. sQry = "UPDATE TB_VMS_DSPL_PRST \r\n"
  1317. " SET DSPL_DT = :p03, \r\n"
  1318. " DNLD_YN = :p04 \r\n"
  1319. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1320. " AND PHASE <= :p02 \r\n";
  1321. String VMS_CTLR_NMBR;
  1322. String PHASE;
  1323. String DSPL_DT;
  1324. String DNLD_YN;
  1325. try
  1326. {
  1327. nFormCnt = AObj->pForms->Count();
  1328. if (nFormCnt == 0) return VERR_NONE;
  1329. pADO = new TADOQuery(NULL);
  1330. pADO->Connection = ADbConn;
  1331. VMS_CTLR_NMBR = AObj->CTLR_NMBR;
  1332. PHASE = String(nFormCnt);
  1333. DSPL_DT = AObj->CTRLMODE->SvcDate;
  1334. DNLD_YN = AObj->CTRLMODE->Result ? "Y" : "N";
  1335. try
  1336. {
  1337. SQLText(pADO, sQry, false);
  1338. SQLBind(pADO, "p01", VMS_CTLR_NMBR);
  1339. SQLBind(pADO, "p02", PHASE);
  1340. SQLBind(pADO, "p03", DSPL_DT);
  1341. SQLBind(pADO, "p04", DNLD_YN);
  1342. nSelCnt = SQLExec(pADO);
  1343. }
  1344. catch(EDatabaseError &E)
  1345. {
  1346. DBERROR(String(E.ClassName()), E.Message, sQry);
  1347. return -1;
  1348. }
  1349. catch(Exception &e)
  1350. {
  1351. DBERROR(String(e.ClassName()), e.Message, sQry);
  1352. return -1;
  1353. }
  1354. if (AObj->DSPL_DT == DSPL_DT)
  1355. {
  1356. MWARN("DCOM %30.30s: %s, %d EA [%s], Already HS Insert.[%s][%s][%d]", "UpdateVmsProvideResult",
  1357. AObj->CTLR_NMBR.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str(), AnsiString(DSPL_DT).c_str(), AnsiString(AObj->DSPL_DT).c_str(), AObj->PHASE);
  1358. MINFO("DCOM %30.30s: %s, %d EA [%s]", "UpdateVmsProvideResult", AObj->CTLR_NMBR.c_str(), nFormCnt, DNLD_YN.c_str());
  1359. return nSelCnt;
  1360. }
  1361. // 이력 저장--제공시각이 동일한게 이력으로 저장될수 있기때문에 트랜잭션을 다시시작한다.
  1362. // 이전 VMS인 경우 임...
  1363. sQry = "INSERT INTO TB_VMS_DSPL_PRST_HS \r\n"
  1364. " (DSPL_DT, VMS_CTLR_NMBR, PHASE, \r\n"
  1365. " VMS_SCH_TYPE, VMS_SCH_FORM_TYPE, \r\n"
  1366. " VMS_FORM_ID, DSPL_HH, \r\n"
  1367. " VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT, \r\n"
  1368. " VMS_FORM_DSPL_DRCT_CD, VMS_FORM_DSPL_MTHD_CD, \r\n"
  1369. " DNLD_YN) \r\n"
  1370. " SELECT DSPL_DT, VMS_CTLR_NMBR, PHASE, \r\n"
  1371. " VMS_SCH_TYPE, VMS_SCH_FORM_TYPE, \r\n"
  1372. " VMS_FORM_ID, DSPL_HH, \r\n"
  1373. " VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT, \r\n"
  1374. " VMS_FORM_DSPL_DRCT_CD, VMS_FORM_DSPL_MTHD_CD, \r\n"
  1375. " DNLD_YN \r\n"
  1376. " FROM TB_VMS_DSPL_PRST \r\n"
  1377. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1378. " AND DSPL_DT = :p02 \r\n"
  1379. " AND PHASE <= :p03 \r\n";
  1380. try
  1381. {
  1382. SQLText(pADO, sQry, false);
  1383. SQLBind(pADO, "p01", VMS_CTLR_NMBR);
  1384. SQLBind(pADO, "p02", DSPL_DT);
  1385. SQLBind(pADO, "p03", PHASE);
  1386. nSelCnt += SQLExec(pADO);
  1387. AObj->DSPL_DT = DSPL_DT;
  1388. AObj->PHASE = nFormCnt;
  1389. AObj->CTRLMODE->SaveFlag = true;
  1390. AObj->CTRLMODE->pTimer = Now();
  1391. MINFO("DCOM %30.30s: %s, %d EA [%s], HS Insert.[%s][%d]", "UpdateVmsProvideResult",
  1392. AObj->CTLR_NMBR.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str(), AnsiString(AObj->DSPL_DT).c_str(), AObj->PHASE);
  1393. }
  1394. catch(EDatabaseError &E)
  1395. {
  1396. DBERROR(String(E.ClassName()), E.Message, sQry);
  1397. return -1;
  1398. }
  1399. catch(Exception &e)
  1400. {
  1401. DBERROR(String(e.ClassName()), e.Message, sQry);
  1402. return -1;
  1403. }
  1404. }
  1405. __finally
  1406. {
  1407. SQLFree(pADO);
  1408. }
  1409. MINFO("DCOM %30.30s: %s, %d EA [%s]", "UpdateVmsProvideResult", AObj->CTLR_NMBR.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str());
  1410. // IDBSTOP(nSelCnt);
  1411. return nSelCnt;
  1412. }
  1413. //---------------------------------------------------------------------------
  1414. int TCDSManager::SaveVmsProvideForm(TADOConnection *ADbConn, void *ACtlrObj)
  1415. {
  1416. // VMS 제공정보 객체 코드
  1417. typedef enum en_vms_object_type
  1418. {
  1419. vms_obj_none, /* 0:정보없음 */
  1420. vms_obj_text, /* 1:문자열 */
  1421. vms_obj_bitmap, /* 2:Bitmap ID */
  1422. vms_obj_draw, /* 3:Draw */
  1423. } EN_VMS_OBJECT_TYPE;
  1424. AnsiString sQry;
  1425. AnsiString uQry;
  1426. TADOQuery *pSADO = NULL;
  1427. TADOQuery *pUADO = NULL;
  1428. int nSelCnt = 0;
  1429. DDBSTART;
  1430. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1431. if (!AObj) return VERR_MEMORY_ALLOC;
  1432. int nFormCnt = AObj->pForms->Count();
  1433. if (nFormCnt == 0) return VERR_NONE;
  1434. sQry = "MERGE INTO TB_VMS_DSPL_PRST L \r\n"
  1435. "USING (SELECT :p01 AS VMS_CTLR_NMBR, \r\n"
  1436. " :p02 AS PHASE, \r\n"
  1437. " :p03 AS DSPL_DT, \r\n"
  1438. " :p04 AS VMS_SCH_TYPE, \r\n"
  1439. " :p05 AS VMS_SCH_FORM_TYPE, \r\n"
  1440. " :p06 AS VMS_FORM_ID, \r\n"
  1441. " :p07 AS DSPL_HH, \r\n"
  1442. " :p08 AS VMS_DSPL_MSG_DATA, \r\n"
  1443. " :p09 AS VMS_DSPL_MSG_TXT, \r\n"
  1444. " :p10 AS VMS_FORM_DSPL_DRCT_CD, \r\n"
  1445. " :p11 AS VMS_FORM_DSPL_MTHD_CD, \r\n"
  1446. " :p12 AS DNLD_YN \r\n"
  1447. " FROM DUAL) M \r\n"
  1448. " ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR AND L.PHASE = M.PHASE) \r\n"
  1449. "WHEN MATCHED THEN \r\n"
  1450. "UPDATE SET L.DSPL_DT = M.DSPL_DT, \r\n"
  1451. " L.VMS_SCH_TYPE = M.VMS_SCH_TYPE, \r\n"
  1452. " L.VMS_SCH_FORM_TYPE = M.VMS_SCH_FORM_TYPE, \r\n"
  1453. " L.VMS_FORM_ID = M.VMS_FORM_ID, \r\n"
  1454. " L.DSPL_HH = M.DSPL_HH, \r\n"
  1455. " L.VMS_DSPL_MSG_DATA = M.VMS_DSPL_MSG_DATA, \r\n"
  1456. " L.VMS_DSPL_MSG_TXT = M.VMS_DSPL_MSG_TXT, \r\n"
  1457. " L.VMS_FORM_DSPL_DRCT_CD = M.VMS_FORM_DSPL_DRCT_CD, \r\n"
  1458. " L.VMS_FORM_DSPL_MTHD_CD = M.VMS_FORM_DSPL_MTHD_CD, \r\n"
  1459. " L.DNLD_YN = M.DNLD_YN \r\n"
  1460. "WHEN NOT MATCHED THEN \r\n"
  1461. "INSERT (VMS_CTLR_NMBR, PHASE, DSPL_DT, \r\n"
  1462. " VMS_SCH_TYPE, VMS_SCH_FORM_TYPE, \r\n"
  1463. " VMS_FORM_ID, DSPL_HH, \r\n"
  1464. " VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT, \r\n"
  1465. " VMS_FORM_DSPL_DRCT_CD, VMS_FORM_DSPL_MTHD_CD, \r\n"
  1466. " DNLD_YN) \r\n"
  1467. "VALUES (M.VMS_CTLR_NMBR, M.PHASE, M.DSPL_DT, \r\n"
  1468. " M.VMS_SCH_TYPE, M.VMS_SCH_FORM_TYPE, \r\n"
  1469. " M.VMS_FORM_ID, M.DSPL_HH, \r\n"
  1470. " M.VMS_DSPL_MSG_DATA, M.VMS_DSPL_MSG_TXT, \r\n"
  1471. " M.VMS_FORM_DSPL_DRCT_CD, M.VMS_FORM_DSPL_MTHD_CD, \r\n"
  1472. " M.DNLD_YN) \r\n";
  1473. uQry = "UPDATE TB_VMS_DSPL_PRST \r\n"
  1474. " SET VMS_DSPL_MSG_IMAG = :p03 \r\n"
  1475. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1476. " AND PHASE = :p02 \r\n";
  1477. try
  1478. {
  1479. pSADO = new TADOQuery(NULL);
  1480. pSADO->Connection = ADbConn;
  1481. pUADO = new TADOQuery(NULL);
  1482. pUADO->Connection = ADbConn;
  1483. try
  1484. {
  1485. AObj->pForms->Lock();
  1486. SQLText(pSADO, sQry, false);
  1487. SQLText(pUADO, uQry, false);
  1488. for (int ii = 0; ii < nFormCnt; ii++)
  1489. {
  1490. TVmsForm *pForm = AObj->pForms->GetItem(ii);
  1491. int nDSPL_HH = pForm->DSPL_HH;
  1492. if (nDSPL_HH == 0) {
  1493. nDSPL_HH = 5;
  1494. }
  1495. String VMS_CTLR_NMBR = AObj->CTLR_NMBR;
  1496. String PHASE = String(ii+1);
  1497. String DSPL_DT = AObj->CTRLMODE->SvcDate;
  1498. String VMS_SCH_TYPE = pForm->VMS_SCH_TYPE;
  1499. String VMS_SCH_FORM_TYPE = pForm->VMS_SCH_FORM_TYPE;
  1500. String VMS_FORM_ID = pForm->VMS_FORM_ID;
  1501. String DSPL_HH = String(nDSPL_HH);
  1502. String VMS_DSPL_MSG_DATA = "";
  1503. String VMS_DSPL_MSG_TXT = "";
  1504. String VMS_FORM_DSPL_DRCT_CD = pForm->VMS_FORM_DSPL_DRCT_CD;
  1505. String VMS_FORM_DSPL_MTHD_CD = pForm->VMS_FORM_DSPL_MTHD_CD;
  1506. String DNLD_YN = pForm->SvcRes ? "Y" : "N";
  1507. AnsiString sTmp = "";
  1508. AnsiString sCont = "";
  1509. int nObjCnt, nObjType;
  1510. try
  1511. {
  1512. //폼종류/표출시간/배경색상
  1513. sCont.printf("%02X%02X%02X|", pForm->VMS_FORM_TYPE_CD, pForm->DSPL_HH, pForm->VMS_FORM_COLR_CD);
  1514. VMS_DSPL_MSG_DATA += sCont;
  1515. nObjCnt = pForm->Count();
  1516. for (int jj = 0; jj < nObjCnt; jj++)
  1517. {
  1518. TVmsFormObj *pFormObj = pForm->GetItem(jj);
  1519. if (pFormObj->ImageId == "") pFormObj->ImageId = "1"; //이력저장용
  1520. if (pFormObj->TextData == "") pFormObj->TextData = " "; //이력저장용
  1521. switch(pFormObj->ObjectType)
  1522. {
  1523. case 1: //심볼
  1524. case 2: //이미지
  1525. case 167: //@우회소통정보이미지
  1526. case 200: //동영상
  1527. case 300: //스티리밍영상
  1528. case 406: //@통합대기등급 이미지
  1529. case 407: //@미세먼지등급 이미지
  1530. case 408: //@초미세먼지등급 이미지
  1531. case 413: //@오존등급이미지
  1532. nObjType = vms_obj_bitmap;
  1533. sTmp.printf("%02X%04X%04X%02X%04X%04X%s|",
  1534. pFormObj->IsBlinking,
  1535. pFormObj->PosX,
  1536. pFormObj->PosY,
  1537. pFormObj->BkColor,
  1538. pFormObj->Width,
  1539. pFormObj->Height,
  1540. pFormObj->ImageId.c_str());
  1541. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1542. VMS_DSPL_MSG_DATA += sCont;
  1543. break;
  1544. case 3: //소통정보배경이미지
  1545. case 17: //1단,소통정보이미지1
  1546. case 27: //2단,소통정보이미지2
  1547. case 37: //3단,소통정보이미지3
  1548. case 47: //4단,소통정보이미지4
  1549. {
  1550. nObjType = vms_obj_draw;
  1551. sTmp.printf("%02X%04X%04X%02X%04X%04X%s+",
  1552. pFormObj->IsBlinking,
  1553. pFormObj->PosX,
  1554. pFormObj->PosY,
  1555. pFormObj->BkColor,
  1556. pFormObj->Width,
  1557. pFormObj->Height,
  1558. pFormObj->ImageId.c_str());
  1559. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1560. VMS_DSPL_MSG_DATA += sCont;
  1561. AnsiString sVertex = "";
  1562. TCDSImage *pSymbol = CDSImageManager->FLists.Find(pFormObj->ImageId);
  1563. if (pSymbol)
  1564. {
  1565. sTmp = "";
  1566. int nCnt = 0;
  1567. FOR_STL(TCDSImageCell*, pCell, pSymbol->FLists)
  1568. {
  1569. TCDSIfsc *pIfsc = NULL;
  1570. if (pFormObj->ObjectType == 3)
  1571. pIfsc = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  1572. else
  1573. pIfsc = CDSIfscManager->FLists.Find(pFormObj->IFSC_ID);
  1574. if (pIfsc)
  1575. {
  1576. sVertex.sprintf("%03d%03d%d", pCell->POSX, pCell->POSY, pIfsc->CMTR_GRAD_CD.ToIntDef(0));
  1577. sTmp += sVertex;
  1578. nCnt++;
  1579. }
  1580. }
  1581. sCont.printf("%02X%s|", nCnt, sTmp.c_str());
  1582. VMS_DSPL_MSG_DATA += sCont;
  1583. }
  1584. else
  1585. {
  1586. VMS_DSPL_MSG_DATA += "X|";
  1587. }
  1588. }
  1589. break;
  1590. default://기타 문자열
  1591. VMS_DSPL_MSG_TXT += pFormObj->TextData;
  1592. VMS_DSPL_MSG_TXT += " ";
  1593. nObjType = vms_obj_text;
  1594. sTmp.printf("%02X%04X%04X%02X%02X%02X%02X%02X%02X%s|",
  1595. pFormObj->IsBlinking,
  1596. pFormObj->PosX,
  1597. pFormObj->PosY,
  1598. pFormObj->BkColor,
  1599. pFormObj->TextFontSize,
  1600. pFormObj->TextFontColor,
  1601. pFormObj->TextFontName,
  1602. pFormObj->TextFontBold,
  1603. pFormObj->TextData.Length(),
  1604. pFormObj->TextData);
  1605. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1606. VMS_DSPL_MSG_DATA += sCont;
  1607. break;
  1608. }
  1609. }
  1610. /*
  1611. * 웹접근성에서 홍보이미지도 alt 로 내용을 지원해야 하기때문에
  1612. * 폼의 설명이 우선적으로 설정되도록 프로그램 수정(20210615)
  1613. */
  1614. if (VMS_DSPL_MSG_TXT == "")
  1615. {
  1616. TCDSForm *pCDSForm = CDSFormManager->FLists.Find(pForm->VMS_FORM_ID);
  1617. if (pCDSForm)
  1618. {
  1619. if (pCDSForm->VMS_FORM_EXPL.Length() > pCDSForm->VMS_FORM_NM.Length())
  1620. {
  1621. VMS_DSPL_MSG_TXT = pCDSForm->VMS_FORM_EXPL;
  1622. }
  1623. else
  1624. {
  1625. VMS_DSPL_MSG_TXT = pCDSForm->VMS_FORM_NM;
  1626. }
  1627. }
  1628. }
  1629. if (VMS_DSPL_MSG_DATA.Length() > 1500) VMS_DSPL_MSG_DATA = VMS_DSPL_MSG_DATA.SubString(1, 1499);
  1630. if (VMS_DSPL_MSG_TXT.Length() > 400) VMS_DSPL_MSG_TXT = VMS_DSPL_MSG_TXT.SubString(1, 399);
  1631. SQLBind(pSADO, "p01", VMS_CTLR_NMBR);
  1632. SQLBind(pSADO, "p02", PHASE);
  1633. SQLBind(pSADO, "p03", DSPL_DT);
  1634. SQLBind(pSADO, "p04", VMS_SCH_TYPE);
  1635. SQLBind(pSADO, "p05", VMS_SCH_FORM_TYPE);
  1636. SQLBind(pSADO, "p06", VMS_FORM_ID);
  1637. SQLBind(pSADO, "p07", DSPL_HH);
  1638. SQLBind(pSADO, "p08", VMS_DSPL_MSG_DATA);
  1639. SQLBind(pSADO, "p09", VMS_DSPL_MSG_TXT);
  1640. SQLBind(pSADO, "p10", VMS_FORM_DSPL_DRCT_CD);
  1641. SQLBind(pSADO, "p11", VMS_FORM_DSPL_MTHD_CD);
  1642. SQLBind(pSADO, "p12", DNLD_YN);
  1643. SQLExec(pSADO);
  1644. try
  1645. {
  1646. SQLBind(pUADO, "p01", VMS_CTLR_NMBR);
  1647. SQLBind(pUADO, "p02", PHASE);
  1648. //pUADO->Parameters->ParamByName("p03")->LoadFromStream(pStream, ftBlob);
  1649. pUADO->Parameters->ParamByName("p03")->LoadFromStream(pForm->pStream, ftBlob);
  1650. //MINFO("[%s] [%d] [%s] [%d]",
  1651. //AnsiString(VMS_CTLR_NMBR).c_str(), (ii+1), AnsiString(VMS_SCH_FORM_TYPE).c_str(),
  1652. //VMS_DSPL_MSG_DATA.Length());
  1653. SQLExec(pUADO);
  1654. //pForm->pBitmap->SaveToFile(g_sFtpFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
  1655. //pImage->Picture->SaveToFile(g_sFtpFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
  1656. }
  1657. catch(Exception &e)
  1658. {
  1659. DBERROR(String(e.ClassName()), e.Message, sQry);
  1660. }
  1661. nSelCnt++;
  1662. }
  1663. __finally
  1664. {
  1665. }
  1666. }
  1667. }
  1668. catch(EDatabaseError &E)
  1669. {
  1670. DBERROR(String(E.ClassName()), E.Message, sQry);
  1671. return -1;
  1672. }
  1673. catch(Exception &e)
  1674. {
  1675. DBERROR(String(e.ClassName()), e.Message, sQry);
  1676. return -1;
  1677. }
  1678. }
  1679. __finally
  1680. {
  1681. AObj->pForms->UnLock();
  1682. SQLFree(pSADO);
  1683. SQLFree(pUADO);
  1684. }
  1685. MINFO("DCOM %30.30s: %s, %d EA", "SaveVmsProvideForm", AObj->CTLR_NMBR.c_str(), nSelCnt);
  1686. //IDBSTOP(nSelCnt);
  1687. return nSelCnt;
  1688. }
  1689. //---------------------------------------------------------------------------
  1690. int TCDSManager::LoadVmsOnOffTime(TADOConnection *ADbConn)
  1691. {
  1692. String sQry;
  1693. TADOQuery *pADO = NULL;
  1694. int nSelCnt = 0;
  1695. DDBSTART;
  1696. sQry = "SELECT A.VMS_CTLR_NMBR, \r\n"
  1697. " A.PANL_ON_TIME, \r\n"
  1698. " A.PANL_OFF_TIME \r\n"
  1699. " FROM TB_VMS_CTLR A \r\n"
  1700. " WHERE A.DEL_YN = 'N' \r\n";
  1701. BYTE OnOff, OldOnOff;
  1702. int nOnTime, nOffTime, nCurrTime;
  1703. nCurrTime = Now().FormatString("hhnn").ToIntDef(0);
  1704. try
  1705. {
  1706. try
  1707. {
  1708. pADO = new TADOQuery(NULL);
  1709. pADO->Connection = ADbConn;
  1710. SQLText(pADO, sQry, true);
  1711. SQLOpen(pADO);
  1712. for( ; !pADO->Eof; pADO->Next())
  1713. {
  1714. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
  1715. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1716. if (!pObj) continue;
  1717. pObj->PANL_ON_TIME = pADO->FieldByName("PANL_ON_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0400' 전광판 ON TIME
  1718. pObj->PANL_OFF_TIME = pADO->FieldByName("PANL_OFF_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0200' 전광판 OFF TIME
  1719. if (pObj->PANL_ON_TIME == "9999" || pObj->PANL_ON_TIME.Length() != 4) pObj->PANL_ON_TIME = "0000";
  1720. if (pObj->PANL_OFF_TIME == "9999" || pObj->PANL_OFF_TIME.Length() != 4) pObj->PANL_OFF_TIME = "0000";
  1721. pObj->MODULE.PowerOnTime = Now().FormatString("yyyymmdd") + pObj->PANL_ON_TIME;
  1722. pObj->MODULE.PowerOffTime = Now().FormatString("yyyymmdd") + pObj->PANL_OFF_TIME;
  1723. pObj->MODULE.Retry = VMS_MAX_RETRY_COUNT;
  1724. OldOnOff = pObj->MODULE.OnOff;
  1725. OnOff = vms_req_board_power_on;
  1726. nOnTime = pObj->PANL_ON_TIME.ToIntDef(0);
  1727. nOffTime = pObj->PANL_OFF_TIME.ToIntDef(0);
  1728. if (nOnTime != nOffTime)
  1729. {
  1730. if (nOnTime > nOffTime)
  1731. {
  1732. // 0100(off), 0500(on)
  1733. if (nCurrTime >= nOffTime && nCurrTime < nOnTime)
  1734. {
  1735. OnOff = vms_req_board_power_off;
  1736. }
  1737. }
  1738. else
  1739. if (nOffTime > nOnTime)
  1740. {
  1741. // 2300(off), 0500(on)
  1742. if (nCurrTime >= nOffTime || nCurrTime < nOnTime)
  1743. {
  1744. OnOff = vms_req_board_power_off;
  1745. }
  1746. }
  1747. }
  1748. if (OldOnOff != OnOff)
  1749. {
  1750. if (pObj->FSession && pObj->FSession->State == eSS_Connected)
  1751. {
  1752. pObj->MODULE.IsOnOff = true;
  1753. pObj->MODULE.OnOff = OnOff;
  1754. IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
  1755. pMsg->Type = eVmsStatusControl;
  1756. pMsg->ObjPtr = (DWORD)pObj->FSession;
  1757. pMsg->Buff[0] = 0x01;
  1758. pMsg->Buff[1] = OnOff;
  1759. pMsg->Len = 2;
  1760. g_jobQ.PushBlocking((DWORD)pMsg);
  1761. }
  1762. }
  1763. #if 0
  1764. if (pObj->FSession && pObj->FSession->State == eSS_Connected && pObj->MODULE.OnOff != pObj->PANL_PWER_MODE)
  1765. {
  1766. pObj->MODULE.IsOnOff = true;
  1767. }
  1768. #endif
  1769. nSelCnt++;
  1770. }
  1771. }
  1772. catch(EDatabaseError &E)
  1773. {
  1774. DBERROR(String(E.ClassName()), E.Message, sQry);
  1775. return -1;
  1776. }
  1777. catch(Exception &e)
  1778. {
  1779. DBERROR(String(e.ClassName()), e.Message, sQry);
  1780. return -1;
  1781. }
  1782. }
  1783. __finally
  1784. {
  1785. SQLFree(pADO);
  1786. }
  1787. // MINFO("DCOM <<< Check VMS Job Schedule: OnOffTime, %d EA", nSelCnt);
  1788. IDBSTOP(nSelCnt);
  1789. return nSelCnt;
  1790. }
  1791. //---------------------------------------------------------------------------
  1792. int TCDSManager::LoadVmsDownLoadJob(TADOConnection *ADbConn)
  1793. {
  1794. String sQry;
  1795. TADOQuery *pADO = NULL;
  1796. int nSelCnt = 0;
  1797. int nDnIdx;
  1798. VMS_DOWNLOAD_INFO *pInfo;
  1799. //return nSelCnt;
  1800. DDBSTART;
  1801. sQry = "SELECT A.VMS_CTLR_NMBR, A.RGST_DT, \r\n"
  1802. " A.FILETYPE, A.FILEID \r\n"
  1803. " FROM TB_VMS_DOWNLOAD A \r\n"
  1804. " WHERE A.SENDSTARTDATE <= TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') \r\n"
  1805. " AND A.SENDRESULT = 0 \r\n"
  1806. " ORDER BY A.VMS_CTLR_NMBR, A.RGST_DT DESC, A.FILETYPE, A.FILEID \r\n";
  1807. CtlrItr it;
  1808. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1809. {
  1810. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1811. pObj->InitDownLoadInfo();
  1812. }
  1813. try
  1814. {
  1815. try
  1816. {
  1817. pADO = new TADOQuery(NULL);
  1818. pADO->Connection = ADbConn;
  1819. SQLText(pADO, sQry, true);
  1820. SQLOpen(pADO);
  1821. for( ; !pADO->Eof; pADO->Next())
  1822. {
  1823. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
  1824. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1825. if (!pObj) continue;
  1826. if (pObj->DOWNLOAD->Count < VMS_MAX_DOWNLOAD)
  1827. {
  1828. pInfo = pObj->DOWNLOAD;
  1829. nDnIdx = pInfo->Count++;
  1830. pInfo->Unit[nDnIdx].RegDate = pADO->FieldByName("RGST_DT")->AsString;
  1831. pInfo->Unit[nDnIdx].FileType = pADO->FieldByName("FILETYPE")->AsString;
  1832. pInfo->Unit[nDnIdx].FileId = pADO->FieldByName("FILEID")->AsString;
  1833. pInfo->Unit[nDnIdx].SendEndDate = Now().FormatString("yyyymmddhhnnss");
  1834. pInfo->Unit[nDnIdx].SendStep = send_wait;
  1835. pInfo->Unit[nDnIdx].SendResult = vms_download_fail;
  1836. }
  1837. nSelCnt++;
  1838. }
  1839. }
  1840. catch(EDatabaseError &E)
  1841. {
  1842. DBERROR(String(E.ClassName()), E.Message, sQry);
  1843. return -1;
  1844. }
  1845. catch(Exception &e)
  1846. {
  1847. DBERROR(String(e.ClassName()), e.Message, sQry);
  1848. return -1;
  1849. }
  1850. }
  1851. __finally
  1852. {
  1853. SQLFree(pADO);
  1854. }
  1855. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1856. {
  1857. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1858. if (pObj->DOWNLOAD->Count > 0)
  1859. {
  1860. pObj->DOWNLOAD->Enable = vms_download_enable;
  1861. pObj->DOWNLOAD->SaveFlag = true;
  1862. }
  1863. }
  1864. // MINFO("DCOM <<< Check VMS Job Schedule: DownloadJob, %d EA", nSelCnt);
  1865. IDBSTOP(nSelCnt);
  1866. return nSelCnt;
  1867. }
  1868. //---------------------------------------------------------------------------
  1869. int TCDSManager::SaveVmsDownLoadJob(TADOConnection *ADbConn, void *ACtlrObj)
  1870. {
  1871. int nSelCnt = 0;
  1872. AnsiString sQry;
  1873. TADOQuery *pADO = NULL;
  1874. DDBSTART;
  1875. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1876. if (!AObj) return VERR_MEMORY_ALLOC;
  1877. sQry = "UPDATE TB_VMS_DOWNLOAD \r\n"
  1878. " SET SENDENDDATE = :p05, \r\n"
  1879. " SENDSTEP = :p06, \r\n"
  1880. " SENDRESULT = :p07 \r\n"
  1881. " WHERE RGST_DT = :p01 \r\n"
  1882. " AND VMS_CTLR_NMBR = :p02 \r\n"
  1883. " AND FILETYPE = :p03 \r\n"
  1884. " AND FILEID = :p04 \r\n";
  1885. try
  1886. {
  1887. pADO = new TADOQuery(NULL);
  1888. pADO->Connection = ADbConn;
  1889. try
  1890. {
  1891. SQLText(pADO, sQry, false);
  1892. for (int ii = 0; ii < AObj->DOWNLOAD->Count && ii < VMS_MAX_DOWNLOAD; ii++)
  1893. {
  1894. SQLBind(pADO, "p01", AObj->DOWNLOAD->Unit[ii].RegDate);
  1895. SQLBind(pADO, "p02", AObj->CTLR_NMBR);
  1896. SQLBind(pADO, "p03", AObj->DOWNLOAD->Unit[ii].FileType);
  1897. SQLBind(pADO, "p04", AObj->DOWNLOAD->Unit[ii].FileId);
  1898. SQLBind(pADO, "p05", AObj->DOWNLOAD->Unit[ii].SendEndDate);
  1899. SQLBind(pADO, "p06", AObj->DOWNLOAD->Unit[ii].SendStep);
  1900. SQLBind(pADO, "p07", AObj->DOWNLOAD->Unit[ii].SendResult);
  1901. nSelCnt = SQLExec(pADO);
  1902. }
  1903. pADO->Connection->CommitTrans();
  1904. }
  1905. catch(EDatabaseError &E)
  1906. {
  1907. DBERROR(String(E.ClassName()), E.Message, sQry);
  1908. return -1;
  1909. }
  1910. catch(Exception &e)
  1911. {
  1912. DBERROR(String(e.ClassName()), e.Message, sQry);
  1913. return -1;
  1914. }
  1915. }
  1916. __finally
  1917. {
  1918. SQLFree(pADO);
  1919. }
  1920. MDEBUG("SaveVmsDownLoad: End, %s", AObj->CTLR_NMBR.c_str());
  1921. IDBSTOP(nSelCnt);
  1922. return nSelCnt;
  1923. }
  1924. //---------------------------------------------------------------------------
  1925. int TCDSManager::SaveVmsDownloadForm(TADOConnection *ADbConn)
  1926. {
  1927. int nSaveVmsCnt = 0;
  1928. int nSaveFormCnt = 0;
  1929. DDBSTART;
  1930. //생성한 폼을 데이터베이스에 저장한다.
  1931. CtlrItr it;
  1932. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1933. {
  1934. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1935. if (pObj->Server.useFlag != use_enable) continue;
  1936. if (!pObj->FProvide) continue;
  1937. nSaveFormCnt += SaveVmsProvideForm(ADbConn, (void*)pObj);
  1938. nSaveVmsCnt++;
  1939. }
  1940. //생성한 폼을 제어기에 전송할 수 있도록 플래그를 설정한다.
  1941. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1942. {
  1943. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1944. if (pObj->Server.useFlag != use_enable) continue;
  1945. if (!pObj->FProvide) continue;
  1946. if (pObj->pForms->Count() > 0)
  1947. {
  1948. pObj->CTRLMODE->Enable = object_enable;
  1949. pObj->CTRLMODE->SaveFlag = true;
  1950. pObj->CTRLMODE->Result = false;
  1951. }
  1952. }
  1953. IDBSTOP(nSaveVmsCnt);
  1954. return nSaveVmsCnt;
  1955. }
  1956. //---------------------------------------------------------------------------
  1957. int TCDSManager::SendVmsDownloadForm()
  1958. {
  1959. INT_VMS_FORM_SAVE_REQ Req;
  1960. memset((char*)&Req, 0x00, sizeof(Req));
  1961. memcpy(Req.Date, FFormDsplDt.c_str(), INT_VMS_MAX_DATETIME);
  1962. return CComm_VmsFormSaveNotify(&Req);
  1963. }
  1964. //---------------------------------------------------------------------------
  1965. int TCDSManager::MakeVmsScenarioForm(TADOConnection *ADbConn)
  1966. {
  1967. int nResult = VERR_NONE;
  1968. DDBSTART;
  1969. CDSManager->ClearVmsProvideMode();
  1970. if (LOAD_DB)
  1971. {
  1972. if (CDSFontManager) CDSFontManager->LoadFontNameInfo(ADbConn);
  1973. if (CDSImageManager) CDSImageManager->LoadVmsSymbolInfo(ADbConn);
  1974. if (CDSFormManager) CDSFormManager->LoadVmsFormInfo(ADbConn);
  1975. if (CDSIfscManager) CDSIfscManager->LoadVmsIfscInfo(ADbConn);
  1976. if (CDSAtmpManager) CDSAtmpManager->LoadAtmpInfo(ADbConn);
  1977. }
  1978. //재난재해가 발생한 정보를 VMS에 맵핑한다.
  1979. if (CDSSafeManager)
  1980. {
  1981. nResult = CDSSafeManager->LoadSafeOccrInfo(ADbConn);
  1982. if (nResult < 0)
  1983. {
  1984. MERROR("LoadSafeOccrInfo: error: %d", nResult);
  1985. }
  1986. }
  1987. //대기환경정보를 읽어온다
  1988. if (CDSAtmpManager)
  1989. {
  1990. nResult = CDSAtmpManager->LoadAtmpRtPnstInfo(ADbConn);
  1991. if (nResult < 0)
  1992. {
  1993. MERROR("LoadAtmpRtPnstInfo: error: %d", nResult);
  1994. }
  1995. }
  1996. //주차정보를 읽어온다
  1997. if (CDSParkManager)
  1998. {
  1999. nResult = CDSParkManager->LoadFromDb(ADbConn);
  2000. if (nResult < 0)
  2001. {
  2002. MERROR("CDSParkManager->LoadFromDb: error: %d", nResult);
  2003. }
  2004. }
  2005. //돌발/공사/행사가 발생한 정보를 VMS에 맵핑한다.
  2006. nResult = CDSManager->LoadVmsEventOccrInf(ADbConn);
  2007. if (nResult < 0)
  2008. {
  2009. MERROR("LoadVmsEventOccrInf: error: %d", nResult);
  2010. }
  2011. // VMS구간 소통정보를 모두 읽어오자..(데이터가 많을 경우 해당되는 정보만 읽어오도록 수정
  2012. nResult = CDSIfscManager->LoadVmsIfscTrafficInfo(ADbConn);
  2013. if (nResult < 0)
  2014. {
  2015. MERROR("LoadVmsIfscTrafficInfo: error: %d", nResult);
  2016. }
  2017. //정체폼을 위한 정체정보 판정
  2018. //스케쥴정보를 읽기전에 VMS별 정체판정조건에 따라 정체정보를 판정한다.
  2019. if (CDSManager->FIsStaticCycle)
  2020. {
  2021. try
  2022. {
  2023. CtlrItr it;
  2024. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  2025. {
  2026. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  2027. FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
  2028. {
  2029. if (!pIfsc->IsUsed) continue;
  2030. if (!pIfsc->CNGS_CNFM_YN) continue; //정체판정이 아닌경우
  2031. TCDSIfsc *pTrfIfsc = CDSIfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
  2032. if (!pTrfIfsc)
  2033. {
  2034. pIfsc->CNGST_CNT = 0;
  2035. continue;
  2036. }
  2037. if (pTrfIfsc->SPED <= pIfsc->CNGS_CNFM_SPED)
  2038. {
  2039. //현재속도값이 정체판정속도 이하이면 정체판정 횟수를 증가
  2040. if (pIfsc->CNGST_CNT == 0)
  2041. {
  2042. pIfsc->dtCngst = Now();
  2043. }
  2044. pIfsc->CNGST_CNT++;
  2045. }
  2046. else
  2047. {
  2048. //정체판정속도보다 크면 정체횟수를 초기화
  2049. pIfsc->CNGST_CNT = 0;
  2050. }
  2051. }
  2052. }
  2053. }
  2054. catch(Exception &e)
  2055. {
  2056. }
  2057. }
  2058. //VMS의 스케줄정보를 조회한다.
  2059. nResult = LoadVmsScheduleInfo(ADbConn);
  2060. if (nResult < 0)
  2061. {
  2062. MERROR("LoadVmsScheduleInfo: error: %d", nResult);
  2063. }
  2064. CDSManager->FIsStaticCycle = false; //정주기 정보제공주기 플래그 설정
  2065. IDBSTOP(nResult);
  2066. return nResult;
  2067. }
  2068. //---------------------------------------------------------------------------
  2069. int TCDSManager::DownloadVmsForm(TADOConnection *ADbConn, int ACommand)
  2070. {
  2071. int nResult = 0;
  2072. DDBSTART;
  2073. if (ACommand == dbm_dnld_form_cycle || ACommand == dbm_dnld_form_init)
  2074. {
  2075. //정주기 다운로드 이면 모든 VMS에 메시지다운로드 플래그 활성화 시킴
  2076. //모드변경에 의한 다운로드인경우에는 내부통신을 수신한 곳에서 플래그를 활성화 시켰음.
  2077. //1. 현재 운영모드를 다시 한번 읽음
  2078. if (LoadVmsOperationMode(ADbConn) < 0)
  2079. {
  2080. return -1;
  2081. }
  2082. //모든 VMS에 메시지다운로드 플래그 활성화 시킴
  2083. CDSCtlrManager->InitProvide(NULL);
  2084. }
  2085. nResult = MakeVmsScenarioForm(ADbConn);
  2086. IDBSTOP(nResult);
  2087. return nResult;
  2088. }
  2089. //---------------------------------------------------------------------------
  2090. int TCDSManager::SaveProvideResult(TADOConnection *ADbConn, void *AData)
  2091. {
  2092. int ii;
  2093. TCDSCtlr *pObj;
  2094. int nJobCnt = 0;
  2095. int nResult;
  2096. VMS_PROVIDE_RESULE *pSave;
  2097. DDBSTART;
  2098. pSave = (VMS_PROVIDE_RESULE*)AData;
  2099. if (!pSave)
  2100. {
  2101. MERROR("SaveProvideResult: Data NULL");
  2102. return -1;
  2103. }
  2104. switch(pSave->Type)
  2105. {
  2106. case provide_form:
  2107. {
  2108. INT_VMS_FORM_DOWNLOAD_REQ VmsSave;
  2109. memset(&VmsSave, 0x00, sizeof(VmsSave));
  2110. VmsSave.Count = 0;
  2111. MINFO("DCOM %30.30s: %d EA", "VMS Msg Provide Result Save", pSave->Count);
  2112. for (ii = 0; ii < pSave->Count && ii < MAX_VMS_PROVIDE_RESULT; ii++)
  2113. {
  2114. pObj = (TCDSCtlr*)pSave->pObj[ii];
  2115. if (!pObj) continue;
  2116. if ((nResult = UpdateVmsProvideResult(ADbConn, (void*)pObj)) < 0)
  2117. {
  2118. MERROR("ProvideSave: UpdateVmsProvideResult failed: %d", nResult);
  2119. }
  2120. else
  2121. {
  2122. nJobCnt++;
  2123. memcpy(VmsSave.Unit[VmsSave.Count].VmsId, pObj->CTLR_NMBR.c_str(), INT_VMS_MAX_ID);
  2124. memcpy(VmsSave.Unit[VmsSave.Count].Date, pObj->CTRLMODE->SvcDate.c_str(), INT_VMS_MAX_DATETIME);
  2125. VmsSave.Unit[VmsSave.Count].Result = pObj->CTRLMODE->Result ? vms_download_succ : vms_download_fail;
  2126. VmsSave.Count++;
  2127. if (VmsSave.Count >= INT_VMS_MAX_FORM_DOWNLOAD)
  2128. {
  2129. CComm_VmsFormDownLoadNotify(&VmsSave);
  2130. VmsSave.Count = 0;
  2131. }
  2132. }
  2133. }
  2134. if (VmsSave.Count > 0)
  2135. {
  2136. CComm_VmsFormDownLoadNotify(&VmsSave);
  2137. }
  2138. }
  2139. break;
  2140. case provide_download:
  2141. for (ii = 0; ii < pSave->Count && ii < MAX_VMS_PROVIDE_RESULT; ii++)
  2142. {
  2143. pObj = (TCDSCtlr*)pSave->pObj[ii];
  2144. if (!pObj) continue;
  2145. nJobCnt++;
  2146. if ((nResult = SaveVmsDownLoadJob(ADbConn, (void*)pObj)) < 0)
  2147. {
  2148. MERROR("SaveProvideResult: SaveVmsDownLoadJob failed: %d", nResult);
  2149. }
  2150. }
  2151. break;
  2152. }
  2153. IDBSTOP(nJobCnt);
  2154. return nJobCnt;
  2155. }
  2156. //---------------------------------------------------------------------------