CDSManagerF.cpp 117 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385
  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. " :p13 AS VMS_DSPL_MSG_INFO \r\n"
  1448. " FROM DUAL) M \r\n"
  1449. " ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR AND L.PHASE = M.PHASE) \r\n"
  1450. "WHEN MATCHED THEN \r\n"
  1451. "UPDATE SET L.DSPL_DT = M.DSPL_DT, \r\n"
  1452. " L.VMS_SCH_TYPE = M.VMS_SCH_TYPE, \r\n"
  1453. " L.VMS_SCH_FORM_TYPE = M.VMS_SCH_FORM_TYPE, \r\n"
  1454. " L.VMS_FORM_ID = M.VMS_FORM_ID, \r\n"
  1455. " L.DSPL_HH = M.DSPL_HH, \r\n"
  1456. " L.VMS_DSPL_MSG_DATA = M.VMS_DSPL_MSG_DATA, \r\n"
  1457. " L.VMS_DSPL_MSG_TXT = M.VMS_DSPL_MSG_TXT, \r\n"
  1458. " L.VMS_FORM_DSPL_DRCT_CD = M.VMS_FORM_DSPL_DRCT_CD, \r\n"
  1459. " L.VMS_FORM_DSPL_MTHD_CD = M.VMS_FORM_DSPL_MTHD_CD, \r\n"
  1460. " L.DNLD_YN = M.DNLD_YN, \r\n"
  1461. " L.VMS_DSPL_MSG_INFO = M.VMS_DSPL_MSG_INFO \r\n"
  1462. "WHEN NOT MATCHED THEN \r\n"
  1463. "INSERT (VMS_CTLR_NMBR, PHASE, DSPL_DT, \r\n"
  1464. " VMS_SCH_TYPE, VMS_SCH_FORM_TYPE, \r\n"
  1465. " VMS_FORM_ID, DSPL_HH, \r\n"
  1466. " VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT, \r\n"
  1467. " VMS_FORM_DSPL_DRCT_CD, VMS_FORM_DSPL_MTHD_CD, \r\n"
  1468. " DNLD_YN, VMS_DSPL_MSG_INFO) \r\n"
  1469. "VALUES (M.VMS_CTLR_NMBR, M.PHASE, M.DSPL_DT, \r\n"
  1470. " M.VMS_SCH_TYPE, M.VMS_SCH_FORM_TYPE, \r\n"
  1471. " M.VMS_FORM_ID, M.DSPL_HH, \r\n"
  1472. " M.VMS_DSPL_MSG_DATA, M.VMS_DSPL_MSG_TXT, \r\n"
  1473. " M.VMS_FORM_DSPL_DRCT_CD, M.VMS_FORM_DSPL_MTHD_CD, \r\n"
  1474. " M.DNLD_YN, VMS_DSPL_MSG_INFO) \r\n";
  1475. uQry = "UPDATE TB_VMS_DSPL_PRST \r\n"
  1476. " SET VMS_DSPL_MSG_IMAG = :p03 \r\n"
  1477. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1478. " AND PHASE = :p02 \r\n";
  1479. try
  1480. {
  1481. pSADO = new TADOQuery(NULL);
  1482. pSADO->Connection = ADbConn;
  1483. pUADO = new TADOQuery(NULL);
  1484. pUADO->Connection = ADbConn;
  1485. try
  1486. {
  1487. AObj->pForms->Lock();
  1488. SQLText(pSADO, sQry, false);
  1489. SQLText(pUADO, uQry, false);
  1490. for (int ii = 0; ii < nFormCnt; ii++)
  1491. {
  1492. TVmsForm *pForm = AObj->pForms->GetItem(ii);
  1493. int nDSPL_HH = pForm->DSPL_HH;
  1494. if (nDSPL_HH == 0) {
  1495. nDSPL_HH = 5;
  1496. }
  1497. String VMS_CTLR_NMBR = AObj->CTLR_NMBR;
  1498. String PHASE = String(ii+1);
  1499. String DSPL_DT = AObj->CTRLMODE->SvcDate;
  1500. String VMS_SCH_TYPE = pForm->VMS_SCH_TYPE;
  1501. String VMS_SCH_FORM_TYPE = pForm->VMS_SCH_FORM_TYPE;
  1502. String VMS_FORM_ID = pForm->VMS_FORM_ID;
  1503. String DSPL_HH = String(nDSPL_HH);
  1504. String VMS_DSPL_MSG_DATA = "";
  1505. String VMS_DSPL_MSG_TXT = "";
  1506. String VMS_FORM_DSPL_DRCT_CD = pForm->VMS_FORM_DSPL_DRCT_CD;
  1507. String VMS_FORM_DSPL_MTHD_CD = pForm->VMS_FORM_DSPL_MTHD_CD;
  1508. String DNLD_YN = pForm->SvcRes ? "Y" : "N";
  1509. String VMS_DSPL_MSG_INFO = pForm->STRM_ADDR;
  1510. AnsiString sTmp = "";
  1511. AnsiString sCont = "";
  1512. int nObjCnt, nObjType;
  1513. try
  1514. {
  1515. //폼종류/표출시간/배경색상
  1516. sCont.printf("%02X%02X%02X|", pForm->VMS_FORM_TYPE_CD, pForm->DSPL_HH, pForm->VMS_FORM_COLR_CD);
  1517. VMS_DSPL_MSG_DATA += sCont;
  1518. nObjCnt = pForm->Count();
  1519. for (int jj = 0; jj < nObjCnt; jj++)
  1520. {
  1521. TVmsFormObj *pFormObj = pForm->GetItem(jj);
  1522. if (pFormObj->ImageId == "") pFormObj->ImageId = "1"; //이력저장용
  1523. if (pFormObj->TextData == "") pFormObj->TextData = " "; //이력저장용
  1524. switch(pFormObj->ObjectType)
  1525. {
  1526. case 1: //심볼
  1527. case 2: //이미지
  1528. case 167: //@우회소통정보이미지
  1529. case 200: //동영상
  1530. case 300: //스티리밍영상
  1531. case 406: //@통합대기등급 이미지
  1532. case 407: //@미세먼지등급 이미지
  1533. case 408: //@초미세먼지등급 이미지
  1534. case 413: //@오존등급이미지
  1535. nObjType = vms_obj_bitmap;
  1536. sTmp.printf("%02X%04X%04X%02X%04X%04X%s|",
  1537. pFormObj->IsBlinking,
  1538. pFormObj->PosX,
  1539. pFormObj->PosY,
  1540. pFormObj->BkColor,
  1541. pFormObj->Width,
  1542. pFormObj->Height,
  1543. pFormObj->ImageId.c_str());
  1544. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1545. VMS_DSPL_MSG_DATA += sCont;
  1546. break;
  1547. case 3: //소통정보배경이미지
  1548. case 17: //1단,소통정보이미지1
  1549. case 27: //2단,소통정보이미지2
  1550. case 37: //3단,소통정보이미지3
  1551. case 47: //4단,소통정보이미지4
  1552. {
  1553. nObjType = vms_obj_draw;
  1554. sTmp.printf("%02X%04X%04X%02X%04X%04X%s+",
  1555. pFormObj->IsBlinking,
  1556. pFormObj->PosX,
  1557. pFormObj->PosY,
  1558. pFormObj->BkColor,
  1559. pFormObj->Width,
  1560. pFormObj->Height,
  1561. pFormObj->ImageId.c_str());
  1562. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1563. VMS_DSPL_MSG_DATA += sCont;
  1564. AnsiString sVertex = "";
  1565. TCDSImage *pSymbol = CDSImageManager->FLists.Find(pFormObj->ImageId);
  1566. if (pSymbol)
  1567. {
  1568. sTmp = "";
  1569. int nCnt = 0;
  1570. FOR_STL(TCDSImageCell*, pCell, pSymbol->FLists)
  1571. {
  1572. TCDSIfsc *pIfsc = NULL;
  1573. if (pFormObj->ObjectType == 3)
  1574. pIfsc = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  1575. else
  1576. pIfsc = CDSIfscManager->FLists.Find(pFormObj->IFSC_ID);
  1577. if (pIfsc)
  1578. {
  1579. sVertex.sprintf("%03d%03d%d", pCell->POSX, pCell->POSY, pIfsc->CMTR_GRAD_CD.ToIntDef(0));
  1580. sTmp += sVertex;
  1581. nCnt++;
  1582. }
  1583. }
  1584. sCont.printf("%02X%s|", nCnt, sTmp.c_str());
  1585. VMS_DSPL_MSG_DATA += sCont;
  1586. }
  1587. else
  1588. {
  1589. VMS_DSPL_MSG_DATA += "X|";
  1590. }
  1591. }
  1592. break;
  1593. default://기타 문자열
  1594. VMS_DSPL_MSG_TXT += pFormObj->TextData;
  1595. VMS_DSPL_MSG_TXT += " ";
  1596. nObjType = vms_obj_text;
  1597. sTmp.printf("%02X%04X%04X%02X%02X%02X%02X%02X%02X%s|",
  1598. pFormObj->IsBlinking,
  1599. pFormObj->PosX,
  1600. pFormObj->PosY,
  1601. pFormObj->BkColor,
  1602. pFormObj->TextFontSize,
  1603. pFormObj->TextFontColor,
  1604. pFormObj->TextFontName,
  1605. pFormObj->TextFontBold,
  1606. pFormObj->TextData.Length(),
  1607. pFormObj->TextData);
  1608. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1609. VMS_DSPL_MSG_DATA += sCont;
  1610. break;
  1611. }
  1612. }
  1613. /*
  1614. * 웹접근성에서 홍보이미지도 alt 로 내용을 지원해야 하기때문에
  1615. * 폼의 설명이 우선적으로 설정되도록 프로그램 수정(20210615)
  1616. */
  1617. if (VMS_DSPL_MSG_TXT == "")
  1618. {
  1619. TCDSForm *pCDSForm = CDSFormManager->FLists.Find(pForm->VMS_FORM_ID);
  1620. if (pCDSForm)
  1621. {
  1622. if (pCDSForm->VMS_FORM_EXPL.Length() > pCDSForm->VMS_FORM_NM.Length())
  1623. {
  1624. VMS_DSPL_MSG_TXT = pCDSForm->VMS_FORM_EXPL;
  1625. }
  1626. else
  1627. {
  1628. VMS_DSPL_MSG_TXT = pCDSForm->VMS_FORM_NM;
  1629. }
  1630. }
  1631. }
  1632. if (VMS_DSPL_MSG_DATA.Length() > 1500) VMS_DSPL_MSG_DATA = VMS_DSPL_MSG_DATA.SubString(1, 1499);
  1633. if (VMS_DSPL_MSG_TXT.Length() > 400) VMS_DSPL_MSG_TXT = VMS_DSPL_MSG_TXT.SubString(1, 399);
  1634. SQLBind(pSADO, "p01", VMS_CTLR_NMBR);
  1635. SQLBind(pSADO, "p02", PHASE);
  1636. SQLBind(pSADO, "p03", DSPL_DT);
  1637. SQLBind(pSADO, "p04", VMS_SCH_TYPE);
  1638. SQLBind(pSADO, "p05", VMS_SCH_FORM_TYPE);
  1639. SQLBind(pSADO, "p06", VMS_FORM_ID);
  1640. SQLBind(pSADO, "p07", DSPL_HH);
  1641. SQLBind(pSADO, "p08", VMS_DSPL_MSG_DATA);
  1642. SQLBind(pSADO, "p09", VMS_DSPL_MSG_TXT);
  1643. SQLBind(pSADO, "p10", VMS_FORM_DSPL_DRCT_CD);
  1644. SQLBind(pSADO, "p11", VMS_FORM_DSPL_MTHD_CD);
  1645. SQLBind(pSADO, "p12", DNLD_YN);
  1646. SQLBind(pSADO, "p13", VMS_DSPL_MSG_INFO);
  1647. SQLExec(pSADO);
  1648. try
  1649. {
  1650. SQLBind(pUADO, "p01", VMS_CTLR_NMBR);
  1651. SQLBind(pUADO, "p02", PHASE);
  1652. //pUADO->Parameters->ParamByName("p03")->LoadFromStream(pStream, ftBlob);
  1653. pUADO->Parameters->ParamByName("p03")->LoadFromStream(pForm->pStream, ftBlob);
  1654. //MINFO("[%s] [%d] [%s] [%d]",
  1655. //AnsiString(VMS_CTLR_NMBR).c_str(), (ii+1), AnsiString(VMS_SCH_FORM_TYPE).c_str(),
  1656. //VMS_DSPL_MSG_DATA.Length());
  1657. SQLExec(pUADO);
  1658. //pForm->pBitmap->SaveToFile(g_sFtpFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
  1659. //pImage->Picture->SaveToFile(g_sFtpFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
  1660. }
  1661. catch(Exception &e)
  1662. {
  1663. DBERROR(String(e.ClassName()), e.Message, sQry);
  1664. }
  1665. nSelCnt++;
  1666. }
  1667. __finally
  1668. {
  1669. }
  1670. }
  1671. }
  1672. catch(EDatabaseError &E)
  1673. {
  1674. DBERROR(String(E.ClassName()), E.Message, sQry);
  1675. return -1;
  1676. }
  1677. catch(Exception &e)
  1678. {
  1679. DBERROR(String(e.ClassName()), e.Message, sQry);
  1680. return -1;
  1681. }
  1682. }
  1683. __finally
  1684. {
  1685. AObj->pForms->UnLock();
  1686. SQLFree(pSADO);
  1687. SQLFree(pUADO);
  1688. }
  1689. MINFO("DCOM %30.30s: %s, %d EA", "SaveVmsProvideForm", AObj->CTLR_NMBR.c_str(), nSelCnt);
  1690. //IDBSTOP(nSelCnt);
  1691. return nSelCnt;
  1692. }
  1693. //---------------------------------------------------------------------------
  1694. int TCDSManager::LoadVmsOnOffTime(TADOConnection *ADbConn)
  1695. {
  1696. String sQry;
  1697. TADOQuery *pADO = NULL;
  1698. int nSelCnt = 0;
  1699. DDBSTART;
  1700. sQry = "SELECT A.VMS_CTLR_NMBR, \r\n"
  1701. " A.PANL_ON_TIME, \r\n"
  1702. " A.PANL_OFF_TIME \r\n"
  1703. " FROM TB_VMS_CTLR A \r\n"
  1704. " WHERE A.DEL_YN = 'N' \r\n";
  1705. BYTE OnOff, OldOnOff;
  1706. int nOnTime, nOffTime, nCurrTime;
  1707. nCurrTime = Now().FormatString("hhnn").ToIntDef(0);
  1708. try
  1709. {
  1710. try
  1711. {
  1712. pADO = new TADOQuery(NULL);
  1713. pADO->Connection = ADbConn;
  1714. SQLText(pADO, sQry, true);
  1715. SQLOpen(pADO);
  1716. for( ; !pADO->Eof; pADO->Next())
  1717. {
  1718. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
  1719. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1720. if (!pObj) continue;
  1721. pObj->PANL_ON_TIME = pADO->FieldByName("PANL_ON_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0400' 전광판 ON TIME
  1722. pObj->PANL_OFF_TIME = pADO->FieldByName("PANL_OFF_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0200' 전광판 OFF TIME
  1723. if (pObj->PANL_ON_TIME == "9999" || pObj->PANL_ON_TIME.Length() != 4) pObj->PANL_ON_TIME = "0000";
  1724. if (pObj->PANL_OFF_TIME == "9999" || pObj->PANL_OFF_TIME.Length() != 4) pObj->PANL_OFF_TIME = "0000";
  1725. pObj->MODULE.PowerOnTime = Now().FormatString("yyyymmdd") + pObj->PANL_ON_TIME;
  1726. pObj->MODULE.PowerOffTime = Now().FormatString("yyyymmdd") + pObj->PANL_OFF_TIME;
  1727. pObj->MODULE.Retry = VMS_MAX_RETRY_COUNT;
  1728. OldOnOff = pObj->MODULE.OnOff;
  1729. OnOff = vms_req_board_power_on;
  1730. nOnTime = pObj->PANL_ON_TIME.ToIntDef(0);
  1731. nOffTime = pObj->PANL_OFF_TIME.ToIntDef(0);
  1732. if (nOnTime != nOffTime)
  1733. {
  1734. if (nOnTime > nOffTime)
  1735. {
  1736. // 0100(off), 0500(on)
  1737. if (nCurrTime >= nOffTime && nCurrTime < nOnTime)
  1738. {
  1739. OnOff = vms_req_board_power_off;
  1740. }
  1741. }
  1742. else
  1743. if (nOffTime > nOnTime)
  1744. {
  1745. // 2300(off), 0500(on)
  1746. if (nCurrTime >= nOffTime || nCurrTime < nOnTime)
  1747. {
  1748. OnOff = vms_req_board_power_off;
  1749. }
  1750. }
  1751. }
  1752. if (OldOnOff != OnOff)
  1753. {
  1754. if (pObj->FSession && pObj->FSession->State == eSS_Connected)
  1755. {
  1756. pObj->MODULE.IsOnOff = true;
  1757. pObj->MODULE.OnOff = OnOff;
  1758. IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
  1759. pMsg->Type = eVmsStatusControl;
  1760. pMsg->ObjPtr = (DWORD)pObj->FSession;
  1761. pMsg->Buff[0] = 0x01;
  1762. pMsg->Buff[1] = OnOff;
  1763. pMsg->Len = 2;
  1764. g_jobQ.PushBlocking((DWORD)pMsg);
  1765. }
  1766. }
  1767. #if 0
  1768. if (pObj->FSession && pObj->FSession->State == eSS_Connected && pObj->MODULE.OnOff != pObj->PANL_PWER_MODE)
  1769. {
  1770. pObj->MODULE.IsOnOff = true;
  1771. }
  1772. #endif
  1773. nSelCnt++;
  1774. }
  1775. }
  1776. catch(EDatabaseError &E)
  1777. {
  1778. DBERROR(String(E.ClassName()), E.Message, sQry);
  1779. return -1;
  1780. }
  1781. catch(Exception &e)
  1782. {
  1783. DBERROR(String(e.ClassName()), e.Message, sQry);
  1784. return -1;
  1785. }
  1786. }
  1787. __finally
  1788. {
  1789. SQLFree(pADO);
  1790. }
  1791. // MINFO("DCOM <<< Check VMS Job Schedule: OnOffTime, %d EA", nSelCnt);
  1792. IDBSTOP(nSelCnt);
  1793. return nSelCnt;
  1794. }
  1795. //---------------------------------------------------------------------------
  1796. int TCDSManager::LoadVmsDownLoadJob(TADOConnection *ADbConn)
  1797. {
  1798. String sQry;
  1799. TADOQuery *pADO = NULL;
  1800. int nSelCnt = 0;
  1801. int nDnIdx;
  1802. VMS_DOWNLOAD_INFO *pInfo;
  1803. //return nSelCnt;
  1804. DDBSTART;
  1805. sQry = "SELECT A.VMS_CTLR_NMBR, A.RGST_DT, \r\n"
  1806. " A.FILETYPE, A.FILEID \r\n"
  1807. " FROM TB_VMS_DOWNLOAD A \r\n"
  1808. " WHERE A.SENDSTARTDATE <= TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') \r\n"
  1809. " AND A.SENDRESULT = 0 \r\n"
  1810. " ORDER BY A.VMS_CTLR_NMBR, A.RGST_DT DESC, A.FILETYPE, A.FILEID \r\n";
  1811. CtlrItr it;
  1812. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1813. {
  1814. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1815. pObj->InitDownLoadInfo();
  1816. }
  1817. try
  1818. {
  1819. try
  1820. {
  1821. pADO = new TADOQuery(NULL);
  1822. pADO->Connection = ADbConn;
  1823. SQLText(pADO, sQry, true);
  1824. SQLOpen(pADO);
  1825. for( ; !pADO->Eof; pADO->Next())
  1826. {
  1827. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
  1828. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1829. if (!pObj) continue;
  1830. if (pObj->DOWNLOAD->Count < VMS_MAX_DOWNLOAD)
  1831. {
  1832. pInfo = pObj->DOWNLOAD;
  1833. nDnIdx = pInfo->Count++;
  1834. pInfo->Unit[nDnIdx].RegDate = pADO->FieldByName("RGST_DT")->AsString;
  1835. pInfo->Unit[nDnIdx].FileType = pADO->FieldByName("FILETYPE")->AsString;
  1836. pInfo->Unit[nDnIdx].FileId = pADO->FieldByName("FILEID")->AsString;
  1837. pInfo->Unit[nDnIdx].SendEndDate = Now().FormatString("yyyymmddhhnnss");
  1838. pInfo->Unit[nDnIdx].SendStep = send_wait;
  1839. pInfo->Unit[nDnIdx].SendResult = vms_download_fail;
  1840. }
  1841. nSelCnt++;
  1842. }
  1843. }
  1844. catch(EDatabaseError &E)
  1845. {
  1846. DBERROR(String(E.ClassName()), E.Message, sQry);
  1847. return -1;
  1848. }
  1849. catch(Exception &e)
  1850. {
  1851. DBERROR(String(e.ClassName()), e.Message, sQry);
  1852. return -1;
  1853. }
  1854. }
  1855. __finally
  1856. {
  1857. SQLFree(pADO);
  1858. }
  1859. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1860. {
  1861. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1862. if (pObj->DOWNLOAD->Count > 0)
  1863. {
  1864. pObj->DOWNLOAD->Enable = vms_download_enable;
  1865. pObj->DOWNLOAD->SaveFlag = true;
  1866. }
  1867. }
  1868. // MINFO("DCOM <<< Check VMS Job Schedule: DownloadJob, %d EA", nSelCnt);
  1869. IDBSTOP(nSelCnt);
  1870. return nSelCnt;
  1871. }
  1872. //---------------------------------------------------------------------------
  1873. int TCDSManager::SaveVmsDownLoadJob(TADOConnection *ADbConn, void *ACtlrObj)
  1874. {
  1875. int nSelCnt = 0;
  1876. AnsiString sQry;
  1877. TADOQuery *pADO = NULL;
  1878. DDBSTART;
  1879. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1880. if (!AObj) return VERR_MEMORY_ALLOC;
  1881. sQry = "UPDATE TB_VMS_DOWNLOAD \r\n"
  1882. " SET SENDENDDATE = :p05, \r\n"
  1883. " SENDSTEP = :p06, \r\n"
  1884. " SENDRESULT = :p07 \r\n"
  1885. " WHERE RGST_DT = :p01 \r\n"
  1886. " AND VMS_CTLR_NMBR = :p02 \r\n"
  1887. " AND FILETYPE = :p03 \r\n"
  1888. " AND FILEID = :p04 \r\n";
  1889. try
  1890. {
  1891. pADO = new TADOQuery(NULL);
  1892. pADO->Connection = ADbConn;
  1893. try
  1894. {
  1895. SQLText(pADO, sQry, false);
  1896. for (int ii = 0; ii < AObj->DOWNLOAD->Count && ii < VMS_MAX_DOWNLOAD; ii++)
  1897. {
  1898. SQLBind(pADO, "p01", AObj->DOWNLOAD->Unit[ii].RegDate);
  1899. SQLBind(pADO, "p02", AObj->CTLR_NMBR);
  1900. SQLBind(pADO, "p03", AObj->DOWNLOAD->Unit[ii].FileType);
  1901. SQLBind(pADO, "p04", AObj->DOWNLOAD->Unit[ii].FileId);
  1902. SQLBind(pADO, "p05", AObj->DOWNLOAD->Unit[ii].SendEndDate);
  1903. SQLBind(pADO, "p06", AObj->DOWNLOAD->Unit[ii].SendStep);
  1904. SQLBind(pADO, "p07", AObj->DOWNLOAD->Unit[ii].SendResult);
  1905. nSelCnt = SQLExec(pADO);
  1906. }
  1907. pADO->Connection->CommitTrans();
  1908. }
  1909. catch(EDatabaseError &E)
  1910. {
  1911. DBERROR(String(E.ClassName()), E.Message, sQry);
  1912. return -1;
  1913. }
  1914. catch(Exception &e)
  1915. {
  1916. DBERROR(String(e.ClassName()), e.Message, sQry);
  1917. return -1;
  1918. }
  1919. }
  1920. __finally
  1921. {
  1922. SQLFree(pADO);
  1923. }
  1924. MDEBUG("SaveVmsDownLoad: End, %s", AObj->CTLR_NMBR.c_str());
  1925. IDBSTOP(nSelCnt);
  1926. return nSelCnt;
  1927. }
  1928. //---------------------------------------------------------------------------
  1929. int TCDSManager::SaveVmsDownloadForm(TADOConnection *ADbConn)
  1930. {
  1931. int nSaveVmsCnt = 0;
  1932. int nSaveFormCnt = 0;
  1933. DDBSTART;
  1934. //생성한 폼을 데이터베이스에 저장한다.
  1935. CtlrItr it;
  1936. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1937. {
  1938. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1939. if (pObj->Server.useFlag != use_enable) continue;
  1940. if (!pObj->FProvide) continue;
  1941. nSaveFormCnt += SaveVmsProvideForm(ADbConn, (void*)pObj);
  1942. nSaveVmsCnt++;
  1943. }
  1944. //생성한 폼을 제어기에 전송할 수 있도록 플래그를 설정한다.
  1945. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1946. {
  1947. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1948. if (pObj->Server.useFlag != use_enable) continue;
  1949. if (!pObj->FProvide) continue;
  1950. if (pObj->pForms->Count() > 0)
  1951. {
  1952. pObj->CTRLMODE->Enable = object_enable;
  1953. pObj->CTRLMODE->SaveFlag = true;
  1954. pObj->CTRLMODE->Result = false;
  1955. }
  1956. }
  1957. IDBSTOP(nSaveVmsCnt);
  1958. return nSaveVmsCnt;
  1959. }
  1960. //---------------------------------------------------------------------------
  1961. int TCDSManager::SendVmsDownloadForm()
  1962. {
  1963. INT_VMS_FORM_SAVE_REQ Req;
  1964. memset((char*)&Req, 0x00, sizeof(Req));
  1965. memcpy(Req.Date, FFormDsplDt.c_str(), INT_VMS_MAX_DATETIME);
  1966. return CComm_VmsFormSaveNotify(&Req);
  1967. }
  1968. //---------------------------------------------------------------------------
  1969. int TCDSManager::MakeVmsScenarioForm(TADOConnection *ADbConn)
  1970. {
  1971. int nResult = VERR_NONE;
  1972. DDBSTART;
  1973. CDSManager->ClearVmsProvideMode();
  1974. if (LOAD_DB)
  1975. {
  1976. if (CDSFontManager) CDSFontManager->LoadFontNameInfo(ADbConn);
  1977. if (CDSImageManager) CDSImageManager->LoadVmsSymbolInfo(ADbConn);
  1978. if (CDSFormManager) CDSFormManager->LoadVmsFormInfo(ADbConn);
  1979. if (CDSIfscManager) CDSIfscManager->LoadVmsIfscInfo(ADbConn);
  1980. if (CDSAtmpManager) CDSAtmpManager->LoadAtmpInfo(ADbConn);
  1981. }
  1982. //재난재해가 발생한 정보를 VMS에 맵핑한다.
  1983. if (CDSSafeManager)
  1984. {
  1985. nResult = CDSSafeManager->LoadSafeOccrInfo(ADbConn);
  1986. if (nResult < 0)
  1987. {
  1988. MERROR("LoadSafeOccrInfo: error: %d", nResult);
  1989. }
  1990. }
  1991. //대기환경정보를 읽어온다
  1992. if (CDSAtmpManager)
  1993. {
  1994. nResult = CDSAtmpManager->LoadAtmpRtPnstInfo(ADbConn);
  1995. if (nResult < 0)
  1996. {
  1997. MERROR("LoadAtmpRtPnstInfo: error: %d", nResult);
  1998. }
  1999. }
  2000. //주차정보를 읽어온다
  2001. if (CDSParkManager)
  2002. {
  2003. nResult = CDSParkManager->LoadFromDb(ADbConn);
  2004. if (nResult < 0)
  2005. {
  2006. MERROR("CDSParkManager->LoadFromDb: error: %d", nResult);
  2007. }
  2008. }
  2009. //돌발/공사/행사가 발생한 정보를 VMS에 맵핑한다.
  2010. nResult = CDSManager->LoadVmsEventOccrInf(ADbConn);
  2011. if (nResult < 0)
  2012. {
  2013. MERROR("LoadVmsEventOccrInf: error: %d", nResult);
  2014. }
  2015. // VMS구간 소통정보를 모두 읽어오자..(데이터가 많을 경우 해당되는 정보만 읽어오도록 수정
  2016. nResult = CDSIfscManager->LoadVmsIfscTrafficInfo(ADbConn);
  2017. if (nResult < 0)
  2018. {
  2019. MERROR("LoadVmsIfscTrafficInfo: error: %d", nResult);
  2020. }
  2021. //정체폼을 위한 정체정보 판정
  2022. //스케쥴정보를 읽기전에 VMS별 정체판정조건에 따라 정체정보를 판정한다.
  2023. if (CDSManager->FIsStaticCycle)
  2024. {
  2025. try
  2026. {
  2027. CtlrItr it;
  2028. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  2029. {
  2030. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  2031. FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
  2032. {
  2033. if (!pIfsc->IsUsed) continue;
  2034. if (!pIfsc->CNGS_CNFM_YN) continue; //정체판정이 아닌경우
  2035. TCDSIfsc *pTrfIfsc = CDSIfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
  2036. if (!pTrfIfsc)
  2037. {
  2038. pIfsc->CNGST_CNT = 0;
  2039. continue;
  2040. }
  2041. if (pTrfIfsc->SPED <= pIfsc->CNGS_CNFM_SPED)
  2042. {
  2043. //현재속도값이 정체판정속도 이하이면 정체판정 횟수를 증가
  2044. if (pIfsc->CNGST_CNT == 0)
  2045. {
  2046. pIfsc->dtCngst = Now();
  2047. }
  2048. pIfsc->CNGST_CNT++;
  2049. }
  2050. else
  2051. {
  2052. //정체판정속도보다 크면 정체횟수를 초기화
  2053. pIfsc->CNGST_CNT = 0;
  2054. }
  2055. }
  2056. }
  2057. }
  2058. catch(Exception &e)
  2059. {
  2060. }
  2061. }
  2062. //VMS의 스케줄정보를 조회한다.
  2063. nResult = LoadVmsScheduleInfo(ADbConn);
  2064. if (nResult < 0)
  2065. {
  2066. MERROR("LoadVmsScheduleInfo: error: %d", nResult);
  2067. }
  2068. CDSManager->FIsStaticCycle = false; //정주기 정보제공주기 플래그 설정
  2069. IDBSTOP(nResult);
  2070. return nResult;
  2071. }
  2072. //---------------------------------------------------------------------------
  2073. int TCDSManager::DownloadVmsForm(TADOConnection *ADbConn, int ACommand)
  2074. {
  2075. int nResult = 0;
  2076. DDBSTART;
  2077. if (ACommand == dbm_dnld_form_cycle || ACommand == dbm_dnld_form_init)
  2078. {
  2079. //정주기 다운로드 이면 모든 VMS에 메시지다운로드 플래그 활성화 시킴
  2080. //모드변경에 의한 다운로드인경우에는 내부통신을 수신한 곳에서 플래그를 활성화 시켰음.
  2081. //1. 현재 운영모드를 다시 한번 읽음
  2082. if (LoadVmsOperationMode(ADbConn) < 0)
  2083. {
  2084. return -1;
  2085. }
  2086. //모든 VMS에 메시지다운로드 플래그 활성화 시킴
  2087. CDSCtlrManager->InitProvide(NULL);
  2088. }
  2089. nResult = MakeVmsScenarioForm(ADbConn);
  2090. IDBSTOP(nResult);
  2091. return nResult;
  2092. }
  2093. //---------------------------------------------------------------------------
  2094. int TCDSManager::SaveProvideResult(TADOConnection *ADbConn, void *AData)
  2095. {
  2096. int ii;
  2097. TCDSCtlr *pObj;
  2098. int nJobCnt = 0;
  2099. int nResult;
  2100. VMS_PROVIDE_RESULE *pSave;
  2101. DDBSTART;
  2102. pSave = (VMS_PROVIDE_RESULE*)AData;
  2103. if (!pSave)
  2104. {
  2105. MERROR("SaveProvideResult: Data NULL");
  2106. return -1;
  2107. }
  2108. switch(pSave->Type)
  2109. {
  2110. case provide_form:
  2111. {
  2112. INT_VMS_FORM_DOWNLOAD_REQ VmsSave;
  2113. memset(&VmsSave, 0x00, sizeof(VmsSave));
  2114. VmsSave.Count = 0;
  2115. MINFO("DCOM %30.30s: %d EA", "VMS Msg Provide Result Save", pSave->Count);
  2116. for (ii = 0; ii < pSave->Count && ii < MAX_VMS_PROVIDE_RESULT; ii++)
  2117. {
  2118. pObj = (TCDSCtlr*)pSave->pObj[ii];
  2119. if (!pObj) continue;
  2120. if ((nResult = UpdateVmsProvideResult(ADbConn, (void*)pObj)) < 0)
  2121. {
  2122. MERROR("ProvideSave: UpdateVmsProvideResult failed: %d", nResult);
  2123. }
  2124. else
  2125. {
  2126. nJobCnt++;
  2127. memcpy(VmsSave.Unit[VmsSave.Count].VmsId, pObj->CTLR_NMBR.c_str(), INT_VMS_MAX_ID);
  2128. memcpy(VmsSave.Unit[VmsSave.Count].Date, pObj->CTRLMODE->SvcDate.c_str(), INT_VMS_MAX_DATETIME);
  2129. VmsSave.Unit[VmsSave.Count].Result = pObj->CTRLMODE->Result ? vms_download_succ : vms_download_fail;
  2130. VmsSave.Count++;
  2131. if (VmsSave.Count >= INT_VMS_MAX_FORM_DOWNLOAD)
  2132. {
  2133. CComm_VmsFormDownLoadNotify(&VmsSave);
  2134. VmsSave.Count = 0;
  2135. }
  2136. }
  2137. }
  2138. if (VmsSave.Count > 0)
  2139. {
  2140. CComm_VmsFormDownLoadNotify(&VmsSave);
  2141. }
  2142. }
  2143. break;
  2144. case provide_download:
  2145. for (ii = 0; ii < pSave->Count && ii < MAX_VMS_PROVIDE_RESULT; ii++)
  2146. {
  2147. pObj = (TCDSCtlr*)pSave->pObj[ii];
  2148. if (!pObj) continue;
  2149. nJobCnt++;
  2150. if ((nResult = SaveVmsDownLoadJob(ADbConn, (void*)pObj)) < 0)
  2151. {
  2152. MERROR("SaveProvideResult: SaveVmsDownLoadJob failed: %d", nResult);
  2153. }
  2154. }
  2155. break;
  2156. }
  2157. IDBSTOP(nJobCnt);
  2158. return nJobCnt;
  2159. }
  2160. //---------------------------------------------------------------------------