CDSManagerF.cpp 116 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367
  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 ( (VMS_SCH_FORM_TYPE == eSchTp_video && SYMB_LIB_NMBR != "" && SYMB_LIB_NMBR != "200" && STRM_ADDR != "") ||
  1055. (VMS_SCH_FORM_TYPE == eSchTp_stream && SYMB_LIB_NMBR != "" && SYMB_LIB_NMBR == "300" && STRM_ADDR != "") )
  1056. {
  1057. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1058. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1059. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1060. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1061. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = FRST_VMS_IFSC_ID;
  1062. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = SECD_VMS_IFSC_ID;
  1063. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = THIR_VMS_IFSC_ID;
  1064. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = FOUR_VMS_IFSC_ID;
  1065. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = FRST_IMG_IFSC_ID;
  1066. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = SECD_IMG_IFSC_ID;
  1067. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = THIR_IMG_IFSC_ID;
  1068. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = FOUR_IMG_IFSC_ID;
  1069. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1070. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1071. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1072. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1073. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1074. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1075. pObj->SCHEDULE->Count++;
  1076. nSelCnt++;
  1077. }
  1078. }
  1079. break;
  1080. case eSchTp_atmp: //9:대기환경
  1081. {
  1082. AnsiString ATMP_STTN_NMBR = "";
  1083. bool isAtmp = false;
  1084. if (CDSAtmpManager)
  1085. {
  1086. FOR_STL(TCDSFormObj*, pTmpObj, pCDSForm->FLists)
  1087. {
  1088. if (pTmpObj->VMS_FORM_OBJECT_TYPE_CD >= 401 && pTmpObj->VMS_FORM_OBJECT_TYPE_CD <= 413)
  1089. {
  1090. ATMP_STTN_NMBR = pTmpObj->VMS_IFSC_ID;
  1091. TCDSAtmp *pAtmp = CDSAtmpManager->FLists.Find(pTmpObj->VMS_IFSC_ID);
  1092. if (pAtmp && pAtmp->SUCCESS)
  1093. {
  1094. isAtmp = true;
  1095. break;
  1096. }
  1097. }
  1098. }
  1099. }
  1100. if (isAtmp == false)
  1101. {
  1102. //폼에 속한 대기환경의 모든 정보가 유효하지 않는 경우 폼을 생성하지 않는다.
  1103. MERROR("VMS ATMP Failed: VmsNmbr(%s)-[%s]", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str());
  1104. break;
  1105. }
  1106. nIdx = pObj->SCHEDULE->Count;
  1107. if (nIdx < VMS_MAX_SCHEDULE)
  1108. {
  1109. #if 0
  1110. AnsiString ATMP_STTN_NMBR = pADO->FieldByName("FRST_VMS_IFSC_ID")->AsString;
  1111. TCDSAtmp *pAtmpObj = CDSAtmpManager->FLists.Find(ATMP_STTN_NMBR);
  1112. if (!pAtmpObj) break;
  1113. if (pAtmpObj->SUCCESS == false)
  1114. {
  1115. 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());
  1116. break;
  1117. }
  1118. #endif
  1119. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1120. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1121. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1122. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1123. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = ATMP_STTN_NMBR;
  1124. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  1125. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  1126. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  1127. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = "";
  1128. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = "";
  1129. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = "";
  1130. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = "";
  1131. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1132. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1133. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1134. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1135. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1136. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1137. pObj->SCHEDULE->Count++;
  1138. nSelCnt++;
  1139. }
  1140. }
  1141. break;
  1142. case eSchTp_park: //10:주차정보
  1143. {
  1144. bool isParkingForm = false;
  1145. FOR_STL(TCDSFormObj*, pTmpObj, pCDSForm->FLists)
  1146. {
  1147. if (pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 101 ||
  1148. pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 102 ||
  1149. pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 103 ||
  1150. pTmpObj->VMS_FORM_OBJECT_TYPE_CD == 104)
  1151. {
  1152. TCDSPark *pPark = NULL;
  1153. if (CDSParkManager) {
  1154. pPark = CDSParkManager->FLists.Find(pTmpObj->VMS_IFSC_ID); //주차장아이디로 주차장정보를 찾음
  1155. }
  1156. if (pPark && pPark->SUCCESS)
  1157. {
  1158. isParkingForm = true;
  1159. break;
  1160. }
  1161. }
  1162. }
  1163. if (isParkingForm == false)
  1164. {
  1165. //폼에 속한 주차장의 모든 정보가 유효하지 않는 경우 폼을 생성하지 않는다.
  1166. MERROR("VMS PARKING Failed: VmsNmbr(%s)-[%s]", VMS_CTLR_NMBR.c_str(), VMS_FORM_ID.c_str());
  1167. break;
  1168. }
  1169. nIdx = pObj->SCHEDULE->Count;
  1170. if (nIdx < VMS_MAX_SCHEDULE)
  1171. {
  1172. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_TYPE = VMS_SCH_TYPE;
  1173. pObj->SCHEDULE->Unit[nIdx].VMS_SCH_FORM_TYPE = VMS_SCH_FORM_TYPE;
  1174. pObj->SCHEDULE->Unit[nIdx].PHASE = PHASE;
  1175. pObj->SCHEDULE->Unit[nIdx].VMS_FORM_ID = VMS_FORM_ID;
  1176. pObj->SCHEDULE->Unit[nIdx].FRST_VMS_IFSC_ID = "";
  1177. pObj->SCHEDULE->Unit[nIdx].SECD_VMS_IFSC_ID = "";
  1178. pObj->SCHEDULE->Unit[nIdx].THIR_VMS_IFSC_ID = "";
  1179. pObj->SCHEDULE->Unit[nIdx].FOUR_VMS_IFSC_ID = "";
  1180. pObj->SCHEDULE->Unit[nIdx].FRST_IMG_IFSC_ID = "";
  1181. pObj->SCHEDULE->Unit[nIdx].SECD_IMG_IFSC_ID = "";
  1182. pObj->SCHEDULE->Unit[nIdx].THIR_IMG_IFSC_ID = "";
  1183. pObj->SCHEDULE->Unit[nIdx].FOUR_IMG_IFSC_ID = "";
  1184. pObj->SCHEDULE->Unit[nIdx].DSPL_HH = DSPL_HH;
  1185. pObj->SCHEDULE->Unit[nIdx].DSPL_STRT_HH = DSPL_STRT_HH;
  1186. pObj->SCHEDULE->Unit[nIdx].DSPL_END_HH = DSPL_END_HH;
  1187. pObj->SCHEDULE->Unit[nIdx].SYMB_LIB_NMBR = SYMB_LIB_NMBR;
  1188. pObj->SCHEDULE->Unit[nIdx].STRM_ADDR = STRM_ADDR;
  1189. pObj->SCHEDULE->Unit[nIdx].DSPL_CNGS_YN = DSPL_CNGS_YN;
  1190. pObj->SCHEDULE->Count++;
  1191. nSelCnt++;
  1192. }
  1193. }
  1194. break;
  1195. }
  1196. }
  1197. }
  1198. catch(EDatabaseError &E)
  1199. {
  1200. DBERROR(String(E.ClassName()), E.Message, sQry);
  1201. return -1;
  1202. }
  1203. catch(Exception &e)
  1204. {
  1205. DBERROR(String(e.ClassName()), e.Message, sQry);
  1206. return -1;
  1207. }
  1208. }
  1209. __finally
  1210. {
  1211. SQLFree(pADO);
  1212. }
  1213. if (0)
  1214. {
  1215. CtlrItr it;
  1216. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1217. {
  1218. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1219. if (!pObj->Used) continue;
  1220. MDEBUG("VMS Schedule: %s, %d EA", pObj->CTLR_NMBR.c_str(), pObj->SCHEDULE->Count);
  1221. }
  1222. }
  1223. IDBSTOP(nSelCnt);
  1224. return nSelCnt;
  1225. }
  1226. //---------------------------------------------------------------------------
  1227. int TCDSManager::LoadVmsOperationMode(TADOConnection *ADbConn)
  1228. {
  1229. AnsiString sQry;
  1230. int nSelCnt = 0;
  1231. TADOQuery *pADO = NULL;
  1232. DDBSTART;
  1233. sQry = "SELECT A.VMS_CTLR_NMBR, A.OPER_MODE, \r\n"
  1234. " NVL(A.VMS_MAX_PHSE_NUM, 16) AS VMS_MAX_PHSE_NUM \r\n"
  1235. " FROM TB_VMS_CTLR A \r\n"
  1236. " WHERE A.DEL_YN = 'N' \r\n";
  1237. try
  1238. {
  1239. pADO = new TADOQuery(NULL);
  1240. pADO->Connection = ADbConn;
  1241. try
  1242. {
  1243. SQLText(pADO, sQry, false);
  1244. SQLOpen(pADO);
  1245. for( ; !pADO->Eof; pADO->Next())
  1246. {
  1247. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString;
  1248. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1249. if (!pObj) continue;
  1250. pObj->OPER_MODE = pADO->FieldByName("OPER_MODE")->AsString.Trim();
  1251. int nMaxFormCnt = pADO->FieldByName("VMS_MAX_PHSE_NUM")->AsInteger;
  1252. if (pObj->OPER_MODE != "A" && pObj->OPER_MODE != "F" && pObj->OPER_MODE != "B")
  1253. {
  1254. pObj->OPER_MODE = "A";
  1255. }
  1256. if (pObj->OPER_MODE == "A")
  1257. pObj->DSTATE.OprMode = 'A';
  1258. else
  1259. if (pObj->OPER_MODE == "B")
  1260. pObj->DSTATE.OprMode = 'B';
  1261. else
  1262. pObj->DSTATE.OprMode = 'F';
  1263. if (pObj->CTRLMODE->Control == pObj->DSTATE.OprMode)
  1264. pObj->FModeChange = false;
  1265. else
  1266. pObj->FModeChange = true;
  1267. pObj->CTRLMODE->Control = pObj->DSTATE.OprMode;
  1268. pObj->RSTATE.OprMode = pObj->CTRLMODE->Control;
  1269. //pObj->VMS_MAX_PHSE_NUM = INT_VMS_MAX_FORM; //nMaxFormCnt;
  1270. if (pObj->VMS_MAX_PHSE_NUM > INT_VMS_MAX_FORM)
  1271. pObj->VMS_MAX_PHSE_NUM = INT_VMS_MAX_FORM;
  1272. pObj->CTRLMODE->MaxDisplayForm = pObj->VMS_MAX_PHSE_NUM;
  1273. #if 0
  1274. if (pObj->CTRLMODE->MaxDisplayForm > INT_MAX_VMS_FORM)
  1275. pObj->CTRLMODE->MaxDisplayForm = INT_MAX_VMS_FORM;
  1276. #endif
  1277. //VMS별 정체폼갯수를 제한하는 경우 여기에서 처리하도록 하자
  1278. pObj->FMaxCngsForm = VMS_MAX_CNGS_FORM; //현재는 디폴트, 즉 모든정보 생성
  1279. nSelCnt++;
  1280. }
  1281. }
  1282. catch(EDatabaseError &E)
  1283. {
  1284. DBERROR(String(E.ClassName()), E.Message, sQry);
  1285. return -1;
  1286. }
  1287. catch(Exception &e)
  1288. {
  1289. DBERROR(String(e.ClassName()), e.Message, sQry);
  1290. return -1;
  1291. }
  1292. }
  1293. __finally
  1294. {
  1295. SQLFree(pADO);
  1296. }
  1297. IDBSTOP(nSelCnt);
  1298. return nSelCnt;
  1299. }
  1300. //---------------------------------------------------------------------------
  1301. int TCDSManager::UpdateVmsProvideResult(TADOConnection *ADbConn, void *ACtlrObj)
  1302. {
  1303. int nSelCnt = 0;
  1304. AnsiString sQry;
  1305. TADOQuery *pADO = NULL;
  1306. int nFormCnt = 0;
  1307. // DDBSTART;
  1308. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1309. if (!AObj) return VERR_MEMORY_ALLOC;
  1310. sQry = "UPDATE TB_VMS_DSPL_PRST \r\n"
  1311. " SET DSPL_DT = :p03, \r\n"
  1312. " DNLD_YN = :p04 \r\n"
  1313. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1314. " AND PHASE <= :p02 \r\n";
  1315. String VMS_CTLR_NMBR;
  1316. String PHASE;
  1317. String DSPL_DT;
  1318. String DNLD_YN;
  1319. try
  1320. {
  1321. nFormCnt = AObj->pForms->Count();
  1322. if (nFormCnt == 0) return VERR_NONE;
  1323. pADO = new TADOQuery(NULL);
  1324. pADO->Connection = ADbConn;
  1325. VMS_CTLR_NMBR = AObj->CTLR_NMBR;
  1326. PHASE = String(nFormCnt);
  1327. DSPL_DT = AObj->CTRLMODE->SvcDate;
  1328. DNLD_YN = AObj->CTRLMODE->Result ? "Y" : "N";
  1329. try
  1330. {
  1331. SQLText(pADO, sQry, false);
  1332. SQLBind(pADO, "p01", VMS_CTLR_NMBR);
  1333. SQLBind(pADO, "p02", PHASE);
  1334. SQLBind(pADO, "p03", DSPL_DT);
  1335. SQLBind(pADO, "p04", DNLD_YN);
  1336. nSelCnt = SQLExec(pADO);
  1337. }
  1338. catch(EDatabaseError &E)
  1339. {
  1340. DBERROR(String(E.ClassName()), E.Message, sQry);
  1341. return -1;
  1342. }
  1343. catch(Exception &e)
  1344. {
  1345. DBERROR(String(e.ClassName()), e.Message, sQry);
  1346. return -1;
  1347. }
  1348. if (AObj->DSPL_DT == DSPL_DT)
  1349. {
  1350. MWARN("DCOM %30.30s: %s, %d EA [%s], Already HS Insert.[%s][%s][%d]", "UpdateVmsProvideResult",
  1351. AObj->CTLR_NMBR.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str(), AnsiString(DSPL_DT).c_str(), AnsiString(AObj->DSPL_DT).c_str(), AObj->PHASE);
  1352. MINFO("DCOM %30.30s: %s, %d EA [%s]", "UpdateVmsProvideResult", AObj->CTLR_NMBR.c_str(), nFormCnt, DNLD_YN.c_str());
  1353. return nSelCnt;
  1354. }
  1355. // 이력 저장--제공시각이 동일한게 이력으로 저장될수 있기때문에 트랜잭션을 다시시작한다.
  1356. // 이전 VMS인 경우 임...
  1357. sQry = "INSERT INTO TB_VMS_DSPL_PRST_HS \r\n"
  1358. " (DSPL_DT, VMS_CTLR_NMBR, PHASE, \r\n"
  1359. " VMS_SCH_TYPE, VMS_SCH_FORM_TYPE, \r\n"
  1360. " VMS_FORM_ID, DSPL_HH, \r\n"
  1361. " VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT, \r\n"
  1362. " VMS_FORM_DSPL_DRCT_CD, VMS_FORM_DSPL_MTHD_CD, \r\n"
  1363. " DNLD_YN) \r\n"
  1364. " SELECT 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. " FROM TB_VMS_DSPL_PRST \r\n"
  1371. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1372. " AND DSPL_DT = :p02 \r\n"
  1373. " AND PHASE <= :p03 \r\n";
  1374. try
  1375. {
  1376. SQLText(pADO, sQry, false);
  1377. SQLBind(pADO, "p01", VMS_CTLR_NMBR);
  1378. SQLBind(pADO, "p02", DSPL_DT);
  1379. SQLBind(pADO, "p03", PHASE);
  1380. nSelCnt += SQLExec(pADO);
  1381. AObj->DSPL_DT = DSPL_DT;
  1382. AObj->PHASE = nFormCnt;
  1383. AObj->CTRLMODE->SaveFlag = true;
  1384. AObj->CTRLMODE->pTimer = Now();
  1385. MINFO("DCOM %30.30s: %s, %d EA [%s], HS Insert.[%s][%d]", "UpdateVmsProvideResult",
  1386. AObj->CTLR_NMBR.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str(), AnsiString(AObj->DSPL_DT).c_str(), AObj->PHASE);
  1387. }
  1388. catch(EDatabaseError &E)
  1389. {
  1390. DBERROR(String(E.ClassName()), E.Message, sQry);
  1391. return -1;
  1392. }
  1393. catch(Exception &e)
  1394. {
  1395. DBERROR(String(e.ClassName()), e.Message, sQry);
  1396. return -1;
  1397. }
  1398. }
  1399. __finally
  1400. {
  1401. SQLFree(pADO);
  1402. }
  1403. MINFO("DCOM %30.30s: %s, %d EA [%s]", "UpdateVmsProvideResult", AObj->CTLR_NMBR.c_str(), nFormCnt, AnsiString(DNLD_YN).c_str());
  1404. // IDBSTOP(nSelCnt);
  1405. return nSelCnt;
  1406. }
  1407. //---------------------------------------------------------------------------
  1408. int TCDSManager::SaveVmsProvideForm(TADOConnection *ADbConn, void *ACtlrObj)
  1409. {
  1410. // VMS 제공정보 객체 코드
  1411. typedef enum en_vms_object_type
  1412. {
  1413. vms_obj_none, /* 0:정보없음 */
  1414. vms_obj_text, /* 1:문자열 */
  1415. vms_obj_bitmap, /* 2:Bitmap ID */
  1416. vms_obj_draw, /* 3:Draw */
  1417. } EN_VMS_OBJECT_TYPE;
  1418. AnsiString sQry;
  1419. AnsiString uQry;
  1420. TADOQuery *pSADO = NULL;
  1421. TADOQuery *pUADO = NULL;
  1422. int nSelCnt = 0;
  1423. DDBSTART;
  1424. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1425. if (!AObj) return VERR_MEMORY_ALLOC;
  1426. int nFormCnt = AObj->pForms->Count();
  1427. if (nFormCnt == 0) return VERR_NONE;
  1428. sQry = "MERGE INTO TB_VMS_DSPL_PRST L \r\n"
  1429. "USING (SELECT :p01 AS VMS_CTLR_NMBR, \r\n"
  1430. " :p02 AS PHASE, \r\n"
  1431. " :p03 AS DSPL_DT, \r\n"
  1432. " :p04 AS VMS_SCH_TYPE, \r\n"
  1433. " :p05 AS VMS_SCH_FORM_TYPE, \r\n"
  1434. " :p06 AS VMS_FORM_ID, \r\n"
  1435. " :p07 AS DSPL_HH, \r\n"
  1436. " :p08 AS VMS_DSPL_MSG_DATA, \r\n"
  1437. " :p09 AS VMS_DSPL_MSG_TXT, \r\n"
  1438. " :p10 AS VMS_FORM_DSPL_DRCT_CD, \r\n"
  1439. " :p11 AS VMS_FORM_DSPL_MTHD_CD, \r\n"
  1440. " :p12 AS DNLD_YN \r\n"
  1441. " FROM DUAL) M \r\n"
  1442. " ON (L.VMS_CTLR_NMBR = M.VMS_CTLR_NMBR AND L.PHASE = M.PHASE) \r\n"
  1443. "WHEN MATCHED THEN \r\n"
  1444. "UPDATE SET L.DSPL_DT = M.DSPL_DT, \r\n"
  1445. " L.VMS_SCH_TYPE = M.VMS_SCH_TYPE, \r\n"
  1446. " L.VMS_SCH_FORM_TYPE = M.VMS_SCH_FORM_TYPE, \r\n"
  1447. " L.VMS_FORM_ID = M.VMS_FORM_ID, \r\n"
  1448. " L.DSPL_HH = M.DSPL_HH, \r\n"
  1449. " L.VMS_DSPL_MSG_DATA = M.VMS_DSPL_MSG_DATA, \r\n"
  1450. " L.VMS_DSPL_MSG_TXT = M.VMS_DSPL_MSG_TXT, \r\n"
  1451. " L.VMS_FORM_DSPL_DRCT_CD = M.VMS_FORM_DSPL_DRCT_CD, \r\n"
  1452. " L.VMS_FORM_DSPL_MTHD_CD = M.VMS_FORM_DSPL_MTHD_CD, \r\n"
  1453. " L.DNLD_YN = M.DNLD_YN \r\n"
  1454. "WHEN NOT MATCHED THEN \r\n"
  1455. "INSERT (VMS_CTLR_NMBR, PHASE, DSPL_DT, \r\n"
  1456. " VMS_SCH_TYPE, VMS_SCH_FORM_TYPE, \r\n"
  1457. " VMS_FORM_ID, DSPL_HH, \r\n"
  1458. " VMS_DSPL_MSG_DATA, VMS_DSPL_MSG_TXT, \r\n"
  1459. " VMS_FORM_DSPL_DRCT_CD, VMS_FORM_DSPL_MTHD_CD, \r\n"
  1460. " DNLD_YN) \r\n"
  1461. "VALUES (M.VMS_CTLR_NMBR, M.PHASE, M.DSPL_DT, \r\n"
  1462. " M.VMS_SCH_TYPE, M.VMS_SCH_FORM_TYPE, \r\n"
  1463. " M.VMS_FORM_ID, M.DSPL_HH, \r\n"
  1464. " M.VMS_DSPL_MSG_DATA, M.VMS_DSPL_MSG_TXT, \r\n"
  1465. " M.VMS_FORM_DSPL_DRCT_CD, M.VMS_FORM_DSPL_MTHD_CD, \r\n"
  1466. " M.DNLD_YN) \r\n";
  1467. uQry = "UPDATE TB_VMS_DSPL_PRST \r\n"
  1468. " SET VMS_DSPL_MSG_IMAG = :p03 \r\n"
  1469. " WHERE VMS_CTLR_NMBR = :p01 \r\n"
  1470. " AND PHASE = :p02 \r\n";
  1471. try
  1472. {
  1473. pSADO = new TADOQuery(NULL);
  1474. pSADO->Connection = ADbConn;
  1475. pUADO = new TADOQuery(NULL);
  1476. pUADO->Connection = ADbConn;
  1477. try
  1478. {
  1479. AObj->pForms->Lock();
  1480. SQLText(pSADO, sQry, false);
  1481. SQLText(pUADO, uQry, false);
  1482. for (int ii = 0; ii < nFormCnt; ii++)
  1483. {
  1484. TVmsForm *pForm = AObj->pForms->GetItem(ii);
  1485. String VMS_CTLR_NMBR = AObj->CTLR_NMBR;
  1486. String PHASE = String(ii+1);
  1487. String DSPL_DT = AObj->CTRLMODE->SvcDate;
  1488. String VMS_SCH_TYPE = pForm->VMS_SCH_TYPE;
  1489. String VMS_SCH_FORM_TYPE = pForm->VMS_SCH_FORM_TYPE;
  1490. String VMS_FORM_ID = pForm->VMS_FORM_ID;
  1491. String DSPL_HH = String(pForm->DSPL_HH);
  1492. String VMS_DSPL_MSG_DATA = "";
  1493. String VMS_DSPL_MSG_TXT = "";
  1494. String VMS_FORM_DSPL_DRCT_CD = pForm->VMS_FORM_DSPL_DRCT_CD;
  1495. String VMS_FORM_DSPL_MTHD_CD = pForm->VMS_FORM_DSPL_MTHD_CD;
  1496. String DNLD_YN = pForm->SvcRes ? "Y" : "N";
  1497. AnsiString sTmp = "";
  1498. AnsiString sCont = "";
  1499. int nObjCnt, nObjType;
  1500. try
  1501. {
  1502. //폼종류/표출시간/배경색상
  1503. sCont.printf("%02X%02X%02X|", pForm->VMS_FORM_TYPE_CD, pForm->DSPL_HH, pForm->VMS_FORM_COLR_CD);
  1504. VMS_DSPL_MSG_DATA += sCont;
  1505. nObjCnt = pForm->Count();
  1506. for (int jj = 0; jj < nObjCnt; jj++)
  1507. {
  1508. TVmsFormObj *pFormObj = pForm->GetItem(jj);
  1509. if (pFormObj->ImageId == "") pFormObj->ImageId = "1"; //이력저장용
  1510. if (pFormObj->TextData == "") pFormObj->TextData = " "; //이력저장용
  1511. switch(pFormObj->ObjectType)
  1512. {
  1513. case 1: //심볼
  1514. case 2: //이미지
  1515. case 167: //@우회소통정보이미지
  1516. case 200: //동영상
  1517. case 300: //스티리밍영상
  1518. case 406: //@통합대기등급 이미지
  1519. case 407: //@미세먼지등급 이미지
  1520. case 408: //@초미세먼지등급 이미지
  1521. case 413: //@오존등급이미지
  1522. nObjType = vms_obj_bitmap;
  1523. sTmp.printf("%02X%04X%04X%02X%04X%04X%s|",
  1524. pFormObj->IsBlinking,
  1525. pFormObj->PosX,
  1526. pFormObj->PosY,
  1527. pFormObj->BkColor,
  1528. pFormObj->Width,
  1529. pFormObj->Height,
  1530. pFormObj->ImageId.c_str());
  1531. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1532. VMS_DSPL_MSG_DATA += sCont;
  1533. break;
  1534. case 3: //소통정보배경이미지
  1535. case 17: //1단,소통정보이미지1
  1536. case 27: //2단,소통정보이미지2
  1537. case 37: //3단,소통정보이미지3
  1538. case 47: //4단,소통정보이미지4
  1539. {
  1540. nObjType = vms_obj_draw;
  1541. sTmp.printf("%02X%04X%04X%02X%04X%04X%s+",
  1542. pFormObj->IsBlinking,
  1543. pFormObj->PosX,
  1544. pFormObj->PosY,
  1545. pFormObj->BkColor,
  1546. pFormObj->Width,
  1547. pFormObj->Height,
  1548. pFormObj->ImageId.c_str());
  1549. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1550. VMS_DSPL_MSG_DATA += sCont;
  1551. AnsiString sVertex = "";
  1552. TCDSImage *pSymbol = CDSImageManager->FLists.Find(pFormObj->ImageId);
  1553. if (pSymbol)
  1554. {
  1555. sTmp = "";
  1556. int nCnt = 0;
  1557. FOR_STL(TCDSImageCell*, pCell, pSymbol->FLists)
  1558. {
  1559. TCDSIfsc *pIfsc = NULL;
  1560. if (pFormObj->ObjectType == 3)
  1561. pIfsc = CDSIfscManager->FLists.Find(pCell->VMS_IFSC_ID);
  1562. else
  1563. pIfsc = CDSIfscManager->FLists.Find(pFormObj->IFSC_ID);
  1564. if (pIfsc)
  1565. {
  1566. sVertex.sprintf("%03d%03d%d", pCell->POSX, pCell->POSY, pIfsc->CMTR_GRAD_CD.ToIntDef(0));
  1567. sTmp += sVertex;
  1568. nCnt++;
  1569. }
  1570. }
  1571. sCont.printf("%02X%s|", nCnt, sTmp.c_str());
  1572. VMS_DSPL_MSG_DATA += sCont;
  1573. }
  1574. else
  1575. {
  1576. VMS_DSPL_MSG_DATA += "X|";
  1577. }
  1578. }
  1579. break;
  1580. default://기타 문자열
  1581. VMS_DSPL_MSG_TXT += pFormObj->TextData;
  1582. VMS_DSPL_MSG_TXT += " ";
  1583. nObjType = vms_obj_text;
  1584. sTmp.printf("%02X%04X%04X%02X%02X%02X%02X%02X%02X%s|",
  1585. pFormObj->IsBlinking,
  1586. pFormObj->PosX,
  1587. pFormObj->PosY,
  1588. pFormObj->BkColor,
  1589. pFormObj->TextFontSize,
  1590. pFormObj->TextFontColor,
  1591. pFormObj->TextFontName,
  1592. pFormObj->TextFontBold,
  1593. pFormObj->TextData.Length(),
  1594. pFormObj->TextData);
  1595. sCont.printf("%02X%02X%s", nObjType, sTmp.Length(), sTmp.c_str());
  1596. VMS_DSPL_MSG_DATA += sCont;
  1597. break;
  1598. }
  1599. }
  1600. /*
  1601. * 웹접근성에서 홍보이미지도 alt 로 내용을 지원해야 하기때문에
  1602. * 폼의 설명이 우선적으로 설정되도록 프로그램 수정(20210615)
  1603. */
  1604. if (VMS_DSPL_MSG_TXT == "")
  1605. {
  1606. TCDSForm *pCDSForm = CDSFormManager->FLists.Find(pForm->VMS_FORM_ID);
  1607. if (pCDSForm)
  1608. {
  1609. if (pCDSForm->VMS_FORM_EXPL.Length() > pCDSForm->VMS_FORM_NM.Length())
  1610. {
  1611. VMS_DSPL_MSG_TXT = pCDSForm->VMS_FORM_EXPL;
  1612. }
  1613. else
  1614. {
  1615. VMS_DSPL_MSG_TXT = pCDSForm->VMS_FORM_NM;
  1616. }
  1617. }
  1618. }
  1619. if (VMS_DSPL_MSG_DATA.Length() > 1500) VMS_DSPL_MSG_DATA = VMS_DSPL_MSG_DATA.SubString(1, 1499);
  1620. if (VMS_DSPL_MSG_TXT.Length() > 400) VMS_DSPL_MSG_TXT = VMS_DSPL_MSG_TXT.SubString(1, 399);
  1621. SQLBind(pSADO, "p01", VMS_CTLR_NMBR);
  1622. SQLBind(pSADO, "p02", PHASE);
  1623. SQLBind(pSADO, "p03", DSPL_DT);
  1624. SQLBind(pSADO, "p04", VMS_SCH_TYPE);
  1625. SQLBind(pSADO, "p05", VMS_SCH_FORM_TYPE);
  1626. SQLBind(pSADO, "p06", VMS_FORM_ID);
  1627. SQLBind(pSADO, "p07", DSPL_HH);
  1628. SQLBind(pSADO, "p08", VMS_DSPL_MSG_DATA);
  1629. SQLBind(pSADO, "p09", VMS_DSPL_MSG_TXT);
  1630. SQLBind(pSADO, "p10", VMS_FORM_DSPL_DRCT_CD);
  1631. SQLBind(pSADO, "p11", VMS_FORM_DSPL_MTHD_CD);
  1632. SQLBind(pSADO, "p12", DNLD_YN);
  1633. SQLExec(pSADO);
  1634. try
  1635. {
  1636. SQLBind(pUADO, "p01", VMS_CTLR_NMBR);
  1637. SQLBind(pUADO, "p02", PHASE);
  1638. //pUADO->Parameters->ParamByName("p03")->LoadFromStream(pStream, ftBlob);
  1639. pUADO->Parameters->ParamByName("p03")->LoadFromStream(pForm->pStream, ftBlob);
  1640. SQLExec(pUADO);
  1641. //MINFO("[%s] FormImage Size: %d", AObj->VmsNo.c_str(), pForm->pStream->Size);
  1642. //pForm->pBitmap->SaveToFile(g_sFtpFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
  1643. //pImage->Picture->SaveToFile(g_sFtpFormDir + AObj->VmsId + "\\" + PHASE + ".bmp");
  1644. }
  1645. catch(Exception &e)
  1646. {
  1647. }
  1648. nSelCnt++;
  1649. }
  1650. __finally
  1651. {
  1652. }
  1653. }
  1654. }
  1655. catch(EDatabaseError &E)
  1656. {
  1657. DBERROR(String(E.ClassName()), E.Message, sQry);
  1658. return -1;
  1659. }
  1660. catch(Exception &e)
  1661. {
  1662. DBERROR(String(e.ClassName()), e.Message, sQry);
  1663. return -1;
  1664. }
  1665. }
  1666. __finally
  1667. {
  1668. AObj->pForms->UnLock();
  1669. SQLFree(pSADO);
  1670. SQLFree(pUADO);
  1671. }
  1672. MINFO("DCOM %30.30s: %s, %d EA", "SaveVmsProvideForm", AObj->CTLR_NMBR.c_str(), nSelCnt);
  1673. //IDBSTOP(nSelCnt);
  1674. return nSelCnt;
  1675. }
  1676. //---------------------------------------------------------------------------
  1677. int TCDSManager::LoadVmsOnOffTime(TADOConnection *ADbConn)
  1678. {
  1679. String sQry;
  1680. TADOQuery *pADO = NULL;
  1681. int nSelCnt = 0;
  1682. DDBSTART;
  1683. sQry = "SELECT A.VMS_CTLR_NMBR, \r\n"
  1684. " A.PANL_ON_TIME, \r\n"
  1685. " A.PANL_OFF_TIME \r\n"
  1686. " FROM TB_VMS_CTLR A \r\n"
  1687. " WHERE A.DEL_YN = 'N' \r\n";
  1688. BYTE OnOff, OldOnOff;
  1689. int nOnTime, nOffTime, nCurrTime;
  1690. nCurrTime = Now().FormatString("hhnn").ToIntDef(0);
  1691. try
  1692. {
  1693. try
  1694. {
  1695. pADO = new TADOQuery(NULL);
  1696. pADO->Connection = ADbConn;
  1697. SQLText(pADO, sQry, true);
  1698. SQLOpen(pADO);
  1699. for( ; !pADO->Eof; pADO->Next())
  1700. {
  1701. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
  1702. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1703. if (!pObj) continue;
  1704. pObj->PANL_ON_TIME = pADO->FieldByName("PANL_ON_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0400' 전광판 ON TIME
  1705. pObj->PANL_OFF_TIME = pADO->FieldByName("PANL_OFF_TIME")->AsString.Trim(); // N VARCHAR2(4) Y '0200' 전광판 OFF TIME
  1706. if (pObj->PANL_ON_TIME == "9999" || pObj->PANL_ON_TIME.Length() != 4) pObj->PANL_ON_TIME = "0000";
  1707. if (pObj->PANL_OFF_TIME == "9999" || pObj->PANL_OFF_TIME.Length() != 4) pObj->PANL_OFF_TIME = "0000";
  1708. pObj->MODULE.PowerOnTime = Now().FormatString("yyyymmdd") + pObj->PANL_ON_TIME;
  1709. pObj->MODULE.PowerOffTime = Now().FormatString("yyyymmdd") + pObj->PANL_OFF_TIME;
  1710. pObj->MODULE.Retry = VMS_MAX_RETRY_COUNT;
  1711. OldOnOff = pObj->MODULE.OnOff;
  1712. OnOff = vms_req_board_power_on;
  1713. nOnTime = pObj->PANL_ON_TIME.ToIntDef(0);
  1714. nOffTime = pObj->PANL_OFF_TIME.ToIntDef(0);
  1715. if (nOnTime != nOffTime)
  1716. {
  1717. if (nOnTime > nOffTime)
  1718. {
  1719. // 0100(off), 0500(on)
  1720. if (nCurrTime >= nOffTime && nCurrTime < nOnTime)
  1721. {
  1722. OnOff = vms_req_board_power_off;
  1723. }
  1724. }
  1725. else
  1726. if (nOffTime > nOnTime)
  1727. {
  1728. // 2300(off), 0500(on)
  1729. if (nCurrTime >= nOffTime || nCurrTime < nOnTime)
  1730. {
  1731. OnOff = vms_req_board_power_off;
  1732. }
  1733. }
  1734. }
  1735. if (OldOnOff != OnOff)
  1736. {
  1737. if (pObj->FSession && pObj->FSession->State == eSS_Connected)
  1738. {
  1739. pObj->MODULE.IsOnOff = true;
  1740. pObj->MODULE.OnOff = OnOff;
  1741. IPC_JOB_MESSAGE *pMsg = g_jobBuff.GetBuff();
  1742. pMsg->Type = eVmsStatusControl;
  1743. pMsg->ObjPtr = (DWORD)pObj->FSession;
  1744. pMsg->Buff[0] = 0x01;
  1745. pMsg->Buff[1] = OnOff;
  1746. pMsg->Len = 2;
  1747. g_jobQ.PushBlocking((DWORD)pMsg);
  1748. }
  1749. }
  1750. #if 0
  1751. if (pObj->FSession && pObj->FSession->State == eSS_Connected && pObj->MODULE.OnOff != pObj->PANL_PWER_MODE)
  1752. {
  1753. pObj->MODULE.IsOnOff = true;
  1754. }
  1755. #endif
  1756. nSelCnt++;
  1757. }
  1758. }
  1759. catch(EDatabaseError &E)
  1760. {
  1761. DBERROR(String(E.ClassName()), E.Message, sQry);
  1762. return -1;
  1763. }
  1764. catch(Exception &e)
  1765. {
  1766. DBERROR(String(e.ClassName()), e.Message, sQry);
  1767. return -1;
  1768. }
  1769. }
  1770. __finally
  1771. {
  1772. SQLFree(pADO);
  1773. }
  1774. // MINFO("DCOM <<< Check VMS Job Schedule: OnOffTime, %d EA", nSelCnt);
  1775. IDBSTOP(nSelCnt);
  1776. return nSelCnt;
  1777. }
  1778. //---------------------------------------------------------------------------
  1779. int TCDSManager::LoadVmsDownLoadJob(TADOConnection *ADbConn)
  1780. {
  1781. String sQry;
  1782. TADOQuery *pADO = NULL;
  1783. int nSelCnt = 0;
  1784. int nDnIdx;
  1785. VMS_DOWNLOAD_INFO *pInfo;
  1786. //return nSelCnt;
  1787. DDBSTART;
  1788. sQry = "SELECT A.VMS_CTLR_NMBR, A.RGST_DT, \r\n"
  1789. " A.FILETYPE, A.FILEID \r\n"
  1790. " FROM TB_VMS_DOWNLOAD A \r\n"
  1791. " WHERE A.SENDSTARTDATE <= TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') \r\n"
  1792. " AND A.SENDRESULT = 0 \r\n"
  1793. " ORDER BY A.VMS_CTLR_NMBR, A.RGST_DT DESC, A.FILETYPE, A.FILEID \r\n";
  1794. CtlrItr it;
  1795. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1796. {
  1797. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1798. pObj->InitDownLoadInfo();
  1799. }
  1800. try
  1801. {
  1802. try
  1803. {
  1804. pADO = new TADOQuery(NULL);
  1805. pADO->Connection = ADbConn;
  1806. SQLText(pADO, sQry, true);
  1807. SQLOpen(pADO);
  1808. for( ; !pADO->Eof; pADO->Next())
  1809. {
  1810. AnsiString VMS_CTLR_NMBR = pADO->FieldByName("VMS_CTLR_NMBR")->AsString.Trim();
  1811. TCDSCtlr *pObj = CDSCtlrManager->FLists.Find(VMS_CTLR_NMBR);
  1812. if (!pObj) continue;
  1813. if (pObj->DOWNLOAD->Count < VMS_MAX_DOWNLOAD)
  1814. {
  1815. pInfo = pObj->DOWNLOAD;
  1816. nDnIdx = pInfo->Count++;
  1817. pInfo->Unit[nDnIdx].RegDate = pADO->FieldByName("RGST_DT")->AsString;
  1818. pInfo->Unit[nDnIdx].FileType = pADO->FieldByName("FILETYPE")->AsString;
  1819. pInfo->Unit[nDnIdx].FileId = pADO->FieldByName("FILEID")->AsString;
  1820. pInfo->Unit[nDnIdx].SendEndDate = Now().FormatString("yyyymmddhhnnss");
  1821. pInfo->Unit[nDnIdx].SendStep = send_wait;
  1822. pInfo->Unit[nDnIdx].SendResult = vms_download_fail;
  1823. }
  1824. nSelCnt++;
  1825. }
  1826. }
  1827. catch(EDatabaseError &E)
  1828. {
  1829. DBERROR(String(E.ClassName()), E.Message, sQry);
  1830. return -1;
  1831. }
  1832. catch(Exception &e)
  1833. {
  1834. DBERROR(String(e.ClassName()), e.Message, sQry);
  1835. return -1;
  1836. }
  1837. }
  1838. __finally
  1839. {
  1840. SQLFree(pADO);
  1841. }
  1842. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1843. {
  1844. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1845. if (pObj->DOWNLOAD->Count > 0)
  1846. {
  1847. pObj->DOWNLOAD->Enable = vms_download_enable;
  1848. pObj->DOWNLOAD->SaveFlag = true;
  1849. }
  1850. }
  1851. // MINFO("DCOM <<< Check VMS Job Schedule: DownloadJob, %d EA", nSelCnt);
  1852. IDBSTOP(nSelCnt);
  1853. return nSelCnt;
  1854. }
  1855. //---------------------------------------------------------------------------
  1856. int TCDSManager::SaveVmsDownLoadJob(TADOConnection *ADbConn, void *ACtlrObj)
  1857. {
  1858. int nSelCnt = 0;
  1859. AnsiString sQry;
  1860. TADOQuery *pADO = NULL;
  1861. DDBSTART;
  1862. TCDSCtlr* AObj = (TCDSCtlr*)ACtlrObj;
  1863. if (!AObj) return VERR_MEMORY_ALLOC;
  1864. sQry = "UPDATE TB_VMS_DOWNLOAD \r\n"
  1865. " SET SENDENDDATE = :p05, \r\n"
  1866. " SENDSTEP = :p06, \r\n"
  1867. " SENDRESULT = :p07 \r\n"
  1868. " WHERE RGST_DT = :p01 \r\n"
  1869. " AND VMS_CTLR_NMBR = :p02 \r\n"
  1870. " AND FILETYPE = :p03 \r\n"
  1871. " AND FILEID = :p04 \r\n";
  1872. try
  1873. {
  1874. pADO = new TADOQuery(NULL);
  1875. pADO->Connection = ADbConn;
  1876. try
  1877. {
  1878. SQLText(pADO, sQry, false);
  1879. for (int ii = 0; ii < AObj->DOWNLOAD->Count && ii < VMS_MAX_DOWNLOAD; ii++)
  1880. {
  1881. SQLBind(pADO, "p01", AObj->DOWNLOAD->Unit[ii].RegDate);
  1882. SQLBind(pADO, "p02", AObj->CTLR_NMBR);
  1883. SQLBind(pADO, "p03", AObj->DOWNLOAD->Unit[ii].FileType);
  1884. SQLBind(pADO, "p04", AObj->DOWNLOAD->Unit[ii].FileId);
  1885. SQLBind(pADO, "p05", AObj->DOWNLOAD->Unit[ii].SendEndDate);
  1886. SQLBind(pADO, "p06", AObj->DOWNLOAD->Unit[ii].SendStep);
  1887. SQLBind(pADO, "p07", AObj->DOWNLOAD->Unit[ii].SendResult);
  1888. nSelCnt = SQLExec(pADO);
  1889. }
  1890. pADO->Connection->CommitTrans();
  1891. }
  1892. catch(EDatabaseError &E)
  1893. {
  1894. DBERROR(String(E.ClassName()), E.Message, sQry);
  1895. return -1;
  1896. }
  1897. catch(Exception &e)
  1898. {
  1899. DBERROR(String(e.ClassName()), e.Message, sQry);
  1900. return -1;
  1901. }
  1902. }
  1903. __finally
  1904. {
  1905. SQLFree(pADO);
  1906. }
  1907. MDEBUG("SaveVmsDownLoad: End, %s", AObj->CTLR_NMBR.c_str());
  1908. IDBSTOP(nSelCnt);
  1909. return nSelCnt;
  1910. }
  1911. //---------------------------------------------------------------------------
  1912. int TCDSManager::SaveVmsDownloadForm(TADOConnection *ADbConn)
  1913. {
  1914. int nSaveVmsCnt = 0;
  1915. int nSaveFormCnt = 0;
  1916. DDBSTART;
  1917. //생성한 폼을 데이터베이스에 저장한다.
  1918. CtlrItr it;
  1919. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1920. {
  1921. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1922. if (pObj->Server.useFlag != use_enable) continue;
  1923. if (!pObj->FProvide) continue;
  1924. nSaveFormCnt += SaveVmsProvideForm(ADbConn, (void*)pObj);
  1925. nSaveVmsCnt++;
  1926. }
  1927. //생성한 폼을 제어기에 전송할 수 있도록 플래그를 설정한다.
  1928. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  1929. {
  1930. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  1931. if (pObj->Server.useFlag != use_enable) continue;
  1932. if (!pObj->FProvide) continue;
  1933. if (pObj->pForms->Count() > 0)
  1934. {
  1935. pObj->CTRLMODE->Enable = object_enable;
  1936. pObj->CTRLMODE->SaveFlag = true;
  1937. pObj->CTRLMODE->Result = false;
  1938. }
  1939. }
  1940. IDBSTOP(nSaveVmsCnt);
  1941. return nSaveVmsCnt;
  1942. }
  1943. //---------------------------------------------------------------------------
  1944. int TCDSManager::SendVmsDownloadForm()
  1945. {
  1946. INT_VMS_FORM_SAVE_REQ Req;
  1947. memset((char*)&Req, 0x00, sizeof(Req));
  1948. memcpy(Req.Date, FFormDsplDt.c_str(), INT_VMS_MAX_DATETIME);
  1949. return CComm_VmsFormSaveNotify(&Req);
  1950. }
  1951. //---------------------------------------------------------------------------
  1952. int TCDSManager::MakeVmsScenarioForm(TADOConnection *ADbConn)
  1953. {
  1954. int nResult = VERR_NONE;
  1955. DDBSTART;
  1956. CDSManager->ClearVmsProvideMode();
  1957. if (LOAD_DB)
  1958. {
  1959. if (CDSFontManager) CDSFontManager->LoadFontNameInfo(ADbConn);
  1960. if (CDSImageManager) CDSImageManager->LoadVmsSymbolInfo(ADbConn);
  1961. if (CDSFormManager) CDSFormManager->LoadVmsFormInfo(ADbConn);
  1962. if (CDSIfscManager) CDSIfscManager->LoadVmsIfscInfo(ADbConn);
  1963. if (CDSAtmpManager) CDSAtmpManager->LoadAtmpInfo(ADbConn);
  1964. }
  1965. //재난재해가 발생한 정보를 VMS에 맵핑한다.
  1966. if (CDSSafeManager)
  1967. {
  1968. nResult = CDSSafeManager->LoadSafeOccrInfo(ADbConn);
  1969. if (nResult < 0)
  1970. {
  1971. MERROR("LoadSafeOccrInfo: error: %d", nResult);
  1972. }
  1973. }
  1974. //대기환경정보를 읽어온다
  1975. if (CDSAtmpManager)
  1976. {
  1977. nResult = CDSAtmpManager->LoadAtmpRtPnstInfo(ADbConn);
  1978. if (nResult < 0)
  1979. {
  1980. MERROR("LoadAtmpRtPnstInfo: error: %d", nResult);
  1981. }
  1982. }
  1983. //주차정보를 읽어온다
  1984. if (CDSParkManager)
  1985. {
  1986. nResult = CDSParkManager->LoadFromDb(ADbConn);
  1987. if (nResult < 0)
  1988. {
  1989. MERROR("CDSParkManager->LoadFromDb: error: %d", nResult);
  1990. }
  1991. }
  1992. //돌발/공사/행사가 발생한 정보를 VMS에 맵핑한다.
  1993. nResult = CDSManager->LoadVmsEventOccrInf(ADbConn);
  1994. if (nResult < 0)
  1995. {
  1996. MERROR("LoadVmsEventOccrInf: error: %d", nResult);
  1997. }
  1998. // VMS구간 소통정보를 모두 읽어오자..(데이터가 많을 경우 해당되는 정보만 읽어오도록 수정
  1999. nResult = CDSIfscManager->LoadVmsIfscTrafficInfo(ADbConn);
  2000. if (nResult < 0)
  2001. {
  2002. MERROR("LoadVmsIfscTrafficInfo: error: %d", nResult);
  2003. }
  2004. //정체폼을 위한 정체정보 판정
  2005. //스케쥴정보를 읽기전에 VMS별 정체판정조건에 따라 정체정보를 판정한다.
  2006. if (CDSManager->FIsStaticCycle)
  2007. {
  2008. try
  2009. {
  2010. CtlrItr it;
  2011. for(it=CDSCtlrManager->FLists.FObjects.begin(); it != CDSCtlrManager->FLists.FObjects.end(); ++it)
  2012. {
  2013. TCDSCtlr *pObj = (TCDSCtlr*)it->second;
  2014. FOR_STL(TVmsIfsc*, pIfsc, pObj->FIfscLists)
  2015. {
  2016. if (!pIfsc->IsUsed) continue;
  2017. if (!pIfsc->CNGS_CNFM_YN) continue; //정체판정이 아닌경우
  2018. TCDSIfsc *pTrfIfsc = CDSIfscManager->FLists.Find(pIfsc->VMS_IFSC_ID);
  2019. if (!pTrfIfsc)
  2020. {
  2021. pIfsc->CNGST_CNT = 0;
  2022. continue;
  2023. }
  2024. if (pTrfIfsc->SPED <= pIfsc->CNGS_CNFM_SPED)
  2025. {
  2026. //현재속도값이 정체판정속도 이하이면 정체판정 횟수를 증가
  2027. if (pIfsc->CNGST_CNT == 0)
  2028. {
  2029. pIfsc->dtCngst = Now();
  2030. }
  2031. pIfsc->CNGST_CNT++;
  2032. }
  2033. else
  2034. {
  2035. //정체판정속도보다 크면 정체횟수를 초기화
  2036. pIfsc->CNGST_CNT = 0;
  2037. }
  2038. }
  2039. }
  2040. }
  2041. catch(Exception &e)
  2042. {
  2043. }
  2044. }
  2045. //VMS의 스케줄정보를 조회한다.
  2046. nResult = LoadVmsScheduleInfo(ADbConn);
  2047. if (nResult < 0)
  2048. {
  2049. MERROR("LoadVmsScheduleInfo: error: %d", nResult);
  2050. }
  2051. CDSManager->FIsStaticCycle = false; //정주기 정보제공주기 플래그 설정
  2052. IDBSTOP(nResult);
  2053. return nResult;
  2054. }
  2055. //---------------------------------------------------------------------------
  2056. int TCDSManager::DownloadVmsForm(TADOConnection *ADbConn, int ACommand)
  2057. {
  2058. int nResult = 0;
  2059. DDBSTART;
  2060. if (ACommand == dbm_dnld_form_cycle || ACommand == dbm_dnld_form_init)
  2061. {
  2062. //정주기 다운로드 이면 모든 VMS에 메시지다운로드 플래그 활성화 시킴
  2063. //모드변경에 의한 다운로드인경우에는 내부통신을 수신한 곳에서 플래그를 활성화 시켰음.
  2064. //1. 현재 운영모드를 다시 한번 읽음
  2065. if (LoadVmsOperationMode(ADbConn) < 0)
  2066. {
  2067. return -1;
  2068. }
  2069. //모든 VMS에 메시지다운로드 플래그 활성화 시킴
  2070. CDSCtlrManager->InitProvide(NULL);
  2071. }
  2072. nResult = MakeVmsScenarioForm(ADbConn);
  2073. IDBSTOP(nResult);
  2074. return nResult;
  2075. }
  2076. //---------------------------------------------------------------------------
  2077. int TCDSManager::SaveProvideResult(TADOConnection *ADbConn, void *AData)
  2078. {
  2079. int ii;
  2080. TCDSCtlr *pObj;
  2081. int nJobCnt = 0;
  2082. int nResult;
  2083. VMS_PROVIDE_RESULE *pSave;
  2084. DDBSTART;
  2085. pSave = (VMS_PROVIDE_RESULE*)AData;
  2086. if (!pSave)
  2087. {
  2088. MERROR("SaveProvideResult: Data NULL");
  2089. return -1;
  2090. }
  2091. switch(pSave->Type)
  2092. {
  2093. case provide_form:
  2094. {
  2095. INT_VMS_FORM_DOWNLOAD_REQ VmsSave;
  2096. memset(&VmsSave, 0x00, sizeof(VmsSave));
  2097. VmsSave.Count = 0;
  2098. MINFO("DCOM %30.30s: %d EA", "VMS Msg Provide Result Save", pSave->Count);
  2099. for (ii = 0; ii < pSave->Count && ii < MAX_VMS_PROVIDE_RESULT; ii++)
  2100. {
  2101. pObj = (TCDSCtlr*)pSave->pObj[ii];
  2102. if (!pObj) continue;
  2103. if ((nResult = UpdateVmsProvideResult(ADbConn, (void*)pObj)) < 0)
  2104. {
  2105. MERROR("ProvideSave: UpdateVmsProvideResult failed: %d", nResult);
  2106. }
  2107. else
  2108. {
  2109. nJobCnt++;
  2110. memcpy(VmsSave.Unit[VmsSave.Count].VmsId, pObj->CTLR_NMBR.c_str(), INT_VMS_MAX_ID);
  2111. memcpy(VmsSave.Unit[VmsSave.Count].Date, pObj->CTRLMODE->SvcDate.c_str(), INT_VMS_MAX_DATETIME);
  2112. VmsSave.Unit[VmsSave.Count].Result = pObj->CTRLMODE->Result ? vms_download_succ : vms_download_fail;
  2113. VmsSave.Count++;
  2114. if (VmsSave.Count >= INT_VMS_MAX_FORM_DOWNLOAD)
  2115. {
  2116. CComm_VmsFormDownLoadNotify(&VmsSave);
  2117. VmsSave.Count = 0;
  2118. }
  2119. }
  2120. }
  2121. if (VmsSave.Count > 0)
  2122. {
  2123. CComm_VmsFormDownLoadNotify(&VmsSave);
  2124. }
  2125. }
  2126. break;
  2127. case provide_download:
  2128. for (ii = 0; ii < pSave->Count && ii < MAX_VMS_PROVIDE_RESULT; ii++)
  2129. {
  2130. pObj = (TCDSCtlr*)pSave->pObj[ii];
  2131. if (!pObj) continue;
  2132. nJobCnt++;
  2133. if ((nResult = SaveVmsDownLoadJob(ADbConn, (void*)pObj)) < 0)
  2134. {
  2135. MERROR("SaveProvideResult: SaveVmsDownLoadJob failed: %d", nResult);
  2136. }
  2137. }
  2138. break;
  2139. }
  2140. IDBSTOP(nJobCnt);
  2141. return nJobCnt;
  2142. }
  2143. //---------------------------------------------------------------------------