CDSWCamCtlrF.cpp 60 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSWCamCtlrF.h"
  4. #include "ITS_OPLibF.h"
  5. //---------------------------------------------------------------------------
  6. #pragma package(smart_init)
  7. //---------------------------------------------------------------------------
  8. TWCamCtlr::TWCamCtlr()
  9. {
  10. }
  11. //---------------------------------------------------------------------------
  12. TWCamCtlr::~TWCamCtlr()
  13. {
  14. }
  15. //---------------------------------------------------------------------------
  16. //---------------------------------------------------------------------------
  17. TWCamCtlrManager *WCamCtlrManager = NULL;
  18. //---------------------------------------------------------------------------
  19. TWCamCtlrManager::TWCamCtlrManager()
  20. {
  21. FImgStream = NULL;
  22. }
  23. //---------------------------------------------------------------------------
  24. TWCamCtlrManager::~TWCamCtlrManager()
  25. {
  26. FLists.RemoveAll();
  27. if (FImgStream) delete FImgStream;
  28. FImgStream = NULL;
  29. }
  30. //---------------------------------------------------------------------------
  31. bool TWCamCtlrManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  32. {
  33. String sQry;
  34. TADOQuery *pADO = NULL;
  35. #ifdef USE_WEB_CMRA
  36. sQry = "SELECT A.*, \r\n"
  37. " A.CMRA_PSWD AS PWD \r\n"
  38. " FROM TB_WEB_CMRA A \r\n"
  39. " WHERE A.DEL_YN = 'N' \r\n";
  40. #else
  41. sQry = "SELECT A.*, \r\n"
  42. " scp.dec_b64('DAMO','SCP','ARIA_256.SCPS',A.CMRA_PSWD) AS PWD \r\n"
  43. " FROM TB_WCAM_CTLR A \r\n"
  44. " WHERE A.DEL_YN = 'N' \r\n";
  45. #endif
  46. FLists.Lock();
  47. try
  48. {
  49. FLists.RemoveAll();
  50. try
  51. {
  52. pADO = new TADOQuery(NULL);
  53. pADO->Close();
  54. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  55. pADO->SQL->Clear();
  56. pADO->SQL->Text = sQry;
  57. pADO->Prepared = true;
  58. pADO->Open();
  59. for( ; !pADO->Eof; pADO->Next())
  60. {
  61. TWCamCtlr *pObj = new TWCamCtlr();
  62. #ifdef USE_WEB_CMRA
  63. pObj->WCAM_CTLR_NMBR = pADO->FieldByName("WEB_CMRA_NMBR")->AsString;
  64. pObj->WCAM_CTLR_ID = pADO->FieldByName("WEB_CMRA_ID")->AsString.Trim();
  65. pObj->WCAM_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();
  66. pObj->WCAM_CTLR_IP = pADO->FieldByName("CMRA_IP")->AsString.Trim();
  67. pObj->WCAM_CTLR_PORT = pADO->FieldByName("CMRA_PORT")->AsInteger;
  68. pObj->WCAM_TYPE_CD = pADO->FieldByName("EQPM_KIND")->AsString.Trim();
  69. pObj->WCAM_MODL = pADO->FieldByName("WCAM_MODL")->AsString.Trim();
  70. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();
  71. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat;
  72. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat;
  73. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  74. pObj->STRM_SVR_IP = pADO->FieldByName("STRM_SVR_IP")->AsString.Trim();
  75. pObj->STRM_SVR_PORT = pADO->FieldByName("STRM_SVR_PORT")->AsString.Trim();
  76. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim();
  77. pObj->STRM_RTSP_ADDR = pADO->FieldByName("STRM_RTSP_ADDR")->AsString.Trim();
  78. pObj->STRM_RTMP_ADDR = pADO->FieldByName("STRM_RTMP_ADDR")->AsString.Trim();
  79. pObj->STRM_HTTP_ADDR = pADO->FieldByName("STRM_HTTP_ADDR")->AsString.Trim();
  80. pObj->STRM_STOR_ADDR = pADO->FieldByName("STRM_STOR_ADDR")->AsString.Trim();
  81. pObj->CMRA_PORT = pADO->FieldByName("CMRA_PORT")->AsInteger;
  82. pObj->CMRA_ID = pADO->FieldByName("CMRA_ID")->AsString.Trim();
  83. pObj->CMRA_PSWD = pADO->FieldByName("PWD")->AsString.Trim();
  84. pObj->CMRA_CHNL = pADO->FieldByName("CMRA_CHNL")->AsInteger;
  85. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString.Trim();
  86. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString.Trim();
  87. pObj->STRM_ADDR = pObj->STRM_SESN_NM;
  88. pObj->FULL_STRM_ADDR = pADO->FieldByName("FULL_STRM_SESN_NM")->AsString.Trim();
  89. #else
  90. pObj->WCAM_CTLR_NMBR = pADO->FieldByName("WCAM_CTLR_NMBR")->AsString;
  91. pObj->WCAM_CTLR_ID = pADO->FieldByName("WCAM_CTLR_ID")->AsString.Trim();
  92. pObj->WCAM_NM = pADO->FieldByName("WCAM_NM")->AsString.Trim();
  93. pObj->WCAM_CTLR_IP = pADO->FieldByName("WCAM_CTLR_IP")->AsString.Trim();
  94. pObj->WCAM_CTLR_PORT = pADO->FieldByName("WCAM_CTLR_PORT")->AsInteger;
  95. pObj->WCAM_CTLR_LOCAL_NO = pADO->FieldByName("WCAM_CTLR_LOCAL_NO")->AsInteger;
  96. pObj->WCAM_TYPE_CD = pADO->FieldByName("WCAM_TYPE_CD")->AsString.Trim();
  97. pObj->WCAM_MODL = pADO->FieldByName("WCAM_MODL")->AsString.Trim();
  98. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();
  99. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat;
  100. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat;
  101. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  102. pObj->STRM_SVR_IP = pADO->FieldByName("STRM_SVR_IP")->AsString.Trim();
  103. pObj->STRM_SVR_PORT = pADO->FieldByName("STRM_SVR_PORT")->AsString.Trim();
  104. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim();
  105. pObj->STRM_RTSP_ADDR = pADO->FieldByName("STRM_RTSP_ADDR")->AsString.Trim();
  106. pObj->STRM_RTMP_ADDR = pADO->FieldByName("STRM_RTMP_ADDR")->AsString.Trim();
  107. pObj->STRM_HTTP_ADDR = pADO->FieldByName("STRM_HTTP_ADDR")->AsString.Trim();
  108. pObj->STRM_STOR_ADDR = pADO->FieldByName("STRM_STOR_ADDR")->AsString.Trim();
  109. pObj->CMRA_PORT = pADO->FieldByName("CMRA_PORT")->AsInteger;
  110. pObj->CMRA_ID = pADO->FieldByName("CMRA_ID")->AsString.Trim();
  111. //pObj->CMRA_PSWD = pADO->FieldByName("CMRA_PSWD")->AsString.Trim();
  112. pObj->CMRA_PSWD = pADO->FieldByName("PWD")->AsString.Trim();
  113. pObj->CMRA_CHNL = pADO->FieldByName("CMRA_CHNL")->AsInteger;
  114. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString.Trim();
  115. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString.Trim();
  116. pObj->STRM_ADDR = pObj->STRM_SESN_NM;
  117. pObj->FULL_STRM_ADDR = pADO->FieldByName("FULL_STRM_SESN_NM")->AsString.Trim();
  118. #endif
  119. FLists.Push(pObj->WCAM_CTLR_NMBR, pObj);
  120. pObj->Completed = true;
  121. }
  122. }
  123. catch(EDatabaseError &E)
  124. {
  125. DBERRORMSG("TWCamCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  126. throw Exception(String(E.ClassName()) + E.Message);
  127. }
  128. catch(Exception &e)
  129. {
  130. DBERRORMSG("TWCamCtlrManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
  131. throw Exception(String(e.ClassName()) + e.Message);
  132. }
  133. }
  134. __finally
  135. {
  136. if (pADO)
  137. {
  138. pADO->Close();
  139. delete pADO;
  140. }
  141. FLists.UnLock();
  142. }
  143. return LoadPreSet(ADbConn);
  144. }
  145. //---------------------------------------------------------------------------
  146. bool TWCamCtlrManager::LoadStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  147. {
  148. String sQry;
  149. TADOQuery *pADO = NULL;
  150. #ifdef USE_WEB_CMRA
  151. sQry = "SELECT * \r\n"
  152. " FROM TB_WEB_CMRA_STTS_HS A, \r\n"
  153. " TB_WEB_CMRA B \r\n"
  154. " WHERE A.WEB_CMRA_NMBR = B.WEB_CMRA_NMBR \r\n"
  155. " AND A.CRTN_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";
  156. #else
  157. sQry = "SELECT * \r\n"
  158. " FROM TB_WCAM_CTLR_STTS A, \r\n"
  159. " TB_WCAM_CTLR B \r\n"
  160. " WHERE A.WCAM_CTLR_NMBR = B.WCAM_CTLR_NMBR \r\n"
  161. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";
  162. #endif
  163. FLists.Lock();
  164. try
  165. {
  166. FOR_STL(TWCamCtlr*, pTmp, FLists)
  167. {
  168. pTmp->STATE.Comm = wcam_error;
  169. }
  170. TWCamCtlr *pObj = NULL;
  171. try
  172. {
  173. int nORD;
  174. pADO = new TADOQuery(NULL);
  175. pADO->Close();
  176. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  177. pADO->SQL->Clear();
  178. pADO->SQL->Text = sQry;
  179. pADO->Prepared = true;
  180. pADO->Open();
  181. for( ; !pADO->Eof; pADO->Next())
  182. {
  183. String WCAM_CTLR_NMBR = pADO->FieldByName("WCAM_CTLR_NMBR")->AsString;
  184. pObj = FLists.Find(WCAM_CTLR_NMBR);
  185. if (!pObj) continue;
  186. String UPDT_DT = pADO->FieldByName("UPDT_DT")->AsString;
  187. String CMNC_STTS_CD = pADO->FieldByName("CMNC_STTS_CD")->AsString;
  188. if (CMNC_STTS_CD != "CMS0")
  189. {
  190. //Åë½ÅÀå¾Ö
  191. continue;
  192. }
  193. pObj->STATE.Comm = (CMNC_STTS_CD == "CMS0") ? wcam_normal : wcam_error;
  194. }
  195. }
  196. catch(EDatabaseError &E)
  197. {
  198. DBERRORLOG("TWCamCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
  199. throw Exception(String(E.ClassName()) + E.Message);
  200. }
  201. catch(Exception &e)
  202. {
  203. DBERRORLOG("TWCamCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
  204. throw Exception(String(e.ClassName()) + e.Message);
  205. }
  206. }
  207. __finally
  208. {
  209. FLists.UnLock();
  210. if (pADO)
  211. {
  212. pADO->Close();
  213. delete pADO;
  214. }
  215. }
  216. return true;
  217. }
  218. //---------------------------------------------------------------------------
  219. bool TWCamCtlrManager::DeleteWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  220. {
  221. String sQry;
  222. TADOQuery *pADO = NULL;
  223. #ifdef USE_WEB_CMRA
  224. sQry = "UPDATE TB_WEB_CMRA \r\n"
  225. " SET DEL_YN = 'Y' \r\n"
  226. " WHERE WEB_CMRA_NMBR = :p01 \r\n";
  227. #else
  228. sQry = "UPDATE TB_WCAM_CTLR \r\n"
  229. " SET DEL_YN = 'Y' \r\n"
  230. " WHERE WCAM_CTLR_NMBR = :p01 \r\n";
  231. #endif
  232. try
  233. {
  234. try
  235. {
  236. pADO = new TADOQuery(NULL);
  237. pADO->Close();
  238. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  239. pADO->SQL->Clear();
  240. pADO->SQL->Text = sQry;
  241. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  242. pADO->ExecSQL();
  243. sQry = "DELETE TB_FCLT_INFR \r\n"
  244. " WHERE FCLT_ID = :p01 \r\n";
  245. pADO->SQL->Clear();
  246. pADO->SQL->Text = sQry;
  247. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_ID;
  248. pADO->ExecSQL();
  249. return true;
  250. }
  251. catch(EDatabaseError &E)
  252. {
  253. DBERRORLOG("TWCamCtlrManager::DeleteWCam", String(E.ClassName()), E.Message, sQry);
  254. throw Exception(String(E.ClassName()) + E.Message);
  255. }
  256. catch(Exception &e)
  257. {
  258. DBERRORLOG("TWCamCtlrManager::DeleteWCam", String(e.ClassName()), e.Message, sQry);
  259. throw Exception(String(e.ClassName()) + e.Message);
  260. }
  261. }
  262. __finally
  263. {
  264. if (pADO)
  265. {
  266. pADO->Close();
  267. delete pADO;
  268. }
  269. }
  270. return true;
  271. }
  272. //---------------------------------------------------------------------------
  273. bool TWCamCtlrManager::InsertWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  274. {
  275. return MergeWCam(AObj, ADbConn);
  276. }
  277. //---------------------------------------------------------------------------
  278. bool TWCamCtlrManager::UpdateWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  279. {
  280. return MergeWCam(AObj, ADbConn);
  281. }
  282. //---------------------------------------------------------------------------
  283. #ifdef USE_WEB_CMAR
  284. bool TWCamCtlrManager::MergeWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  285. {
  286. String sQry;
  287. TADOQuery *pADO = NULL;
  288. sQry = "MERGE INTO TB_WEB_CMRA L \r\n"
  289. "USING (SELECT :p01 AS WEB_CMRA_NMBR, \r\n"
  290. " :p02 AS WEB_CMRA_ID, \r\n"
  291. " :p03 AS ISTL_LCTN_NM, \r\n"
  292. " :p04 AS CMRA_IP, \r\n"
  293. " :p05 AS CMRA_PORT, \r\n"
  294. " :p07 AS EQPM_KIND, \r\n"
  295. " :p25 AS WCAM_MODL, \r\n"
  296. " :p08 AS ISTL_LCTN_NM, \r\n"
  297. " :p09 AS X_CRDN, \r\n"
  298. " :p10 AS Y_CRDN, \r\n"
  299. " :p11 AS DEL_YN, \r\n"
  300. " :p12 AS STRM_SVR_IP, \r\n"
  301. " :p13 AS STRM_SVR_PORT, \r\n"
  302. " :p14 AS STRM_SESN_NM, \r\n"
  303. " :p15 AS STRM_RTSP_ADDR, \r\n"
  304. " :p16 AS STRM_RTMP_ADDR, \r\n"
  305. " :p17 AS STRM_HTTP_ADDR, \r\n"
  306. " :p18 AS STRM_STOR_ADDR, \r\n"
  307. " :p19 AS CMRA_PORT, \r\n"
  308. " :p20 AS CMRA_ID, \r\n"
  309. " :p21 AS CMRA_PSWD, \r\n"
  310. " :p22 AS CMRA_CHNL, \r\n"
  311. " :p23 AS LINK_ID, \r\n"
  312. " :p24 AS ISTL_LCTN_ADDR \r\n"
  313. " FROM DUAL) M \r\n"
  314. " ON (L.WEB_CMRA_NMBR = M.WEB_CMRA_NMBR) \r\n"
  315. "WHEN MATCHED THEN \r\n"
  316. " UPDATE SET L.WEB_CMRA_ID = M.WEB_CMRA_ID, \r\n"
  317. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  318. " L.CMRA_IP = M.CMRA_IP, \r\n"
  319. " L.CMRA_PORT = M.CMRA_PORT, \r\n"
  320. " L.EQPM_KIND = M.EQPM_KIND, \r\n"
  321. " L.WCAM_MODL = M.WCAM_MODL, \r\n"
  322. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  323. " L.X_CRDN = M.X_CRDN, \r\n"
  324. " L.Y_CRDN = M.Y_CRDN, \r\n"
  325. " L.DEL_YN = M.DEL_YN, \r\n"
  326. " L.STRM_SVR_IP = M.STRM_SVR_IP, \r\n"
  327. " L.STRM_SVR_PORT = M.STRM_SVR_PORT, \r\n"
  328. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  329. " L.STRM_RTSP_ADDR = M.STRM_RTSP_ADDR, \r\n"
  330. " L.STRM_RTMP_ADDR = M.STRM_RTMP_ADDR, \r\n"
  331. " L.STRM_HTTP_ADDR = M.STRM_HTTP_ADDR, \r\n"
  332. " L.STRM_STOR_ADDR = M.STRM_STOR_ADDR, \r\n"
  333. " L.CMRA_PORT = M.CMRA_PORT, \r\n"
  334. " L.CMRA_ID = M.CMRA_ID, \r\n"
  335. " L.CMRA_PSWD = M.CMRA_PSWD, \r\n"
  336. " L.CMRA_CHNL = M.CMRA_CHNL, \r\n"
  337. " L.LINK_ID = M.LINK_ID, \r\n"
  338. " L.ISTL_LCTN_ADDR = M.ISTL_LCTN_ADDR \r\n"
  339. "WHEN NOT MATCHED THEN \r\n"
  340. " INSERT (WEB_CMRA_NMBR, \r\n"
  341. " WEB_CMRA_ID, \r\n"
  342. " ISTL_LCTN_NM, \r\n"
  343. " CMRA_IP, \r\n"
  344. " CMRA_PORT, \r\n"
  345. " EQPM_KIND, \r\n"
  346. " WCAM_MODL, \r\n"
  347. " ISTL_LCTN_NM, \r\n"
  348. " X_CRDN, \r\n"
  349. " Y_CRDN, \r\n"
  350. " DEL_YN, \r\n"
  351. " STRM_SVR_IP, \r\n"
  352. " STRM_SVR_PORT, \r\n"
  353. " STRM_SESN_NM, \r\n"
  354. " STRM_RTSP_ADDR, \r\n"
  355. " STRM_RTMP_ADDR, \r\n"
  356. " STRM_HTTP_ADDR, \r\n"
  357. " STRM_STOR_ADDR, \r\n"
  358. " CMRA_PORT, \r\n"
  359. " CMRA_ID, \r\n"
  360. " CMRA_PSWD, \r\n"
  361. " CMRA_CHNL, \r\n"
  362. " LINK_ID, \r\n"
  363. " ISTL_LCTN_ADDR ) \r\n"
  364. " VALUES (M.WEB_CMRA_NMBR, \r\n"
  365. " M.WEB_CMRA_ID, \r\n"
  366. " M.ISTL_LCTN_NM, \r\n"
  367. " M.CMRA_IP, \r\n"
  368. " M.CMRA_PORT, \r\n"
  369. " M.EQPM_KIND, \r\n"
  370. " M.WCAM_MODL, \r\n"
  371. " M.ISTL_LCTN_NM, \r\n"
  372. " M.X_CRDN, \r\n"
  373. " M.Y_CRDN, \r\n"
  374. " M.DEL_YN, \r\n"
  375. " M.STRM_SVR_IP, \r\n"
  376. " M.STRM_SVR_PORT, \r\n"
  377. " M.STRM_SESN_NM, \r\n"
  378. " M.STRM_RTSP_ADDR, \r\n"
  379. " M.STRM_RTMP_ADDR, \r\n"
  380. " M.STRM_HTTP_ADDR, \r\n"
  381. " M.STRM_STOR_ADDR, \r\n"
  382. " M.CMRA_PORT, \r\n"
  383. " M.CMRA_ID, \r\n"
  384. " M.CMRA_PSWD, \r\n"
  385. " M.CMRA_CHNL, \r\n"
  386. " M.LINK_ID, \r\n"
  387. " M.ISTL_LCTN_ADDR ) \r\n";
  388. try
  389. {
  390. try
  391. {
  392. pADO = new TADOQuery(NULL);
  393. pADO->Close();
  394. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  395. pADO->SQL->Clear();
  396. pADO->SQL->Text = sQry;
  397. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  398. pADO->Parameters->ParamByName("p02")->Value = AObj->WCAM_CTLR_ID;
  399. pADO->Parameters->ParamByName("p03")->Value = AObj->WCAM_NM;
  400. pADO->Parameters->ParamByName("p04")->Value = AObj->WCAM_CTLR_IP;
  401. pADO->Parameters->ParamByName("p05")->Value = AObj->WCAM_CTLR_PORT;
  402. //pADO->Parameters->ParamByName("p06")->Value = AObj->WCAM_CTLR_LOCAL_NO;
  403. pADO->Parameters->ParamByName("p07")->Value = AObj->WCAM_TYPE_CD;
  404. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  405. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  406. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  407. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  408. pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
  409. pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SVR_PORT;
  410. pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_SESN_NM;
  411. pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTSP_ADDR;
  412. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_RTMP_ADDR;
  413. pADO->Parameters->ParamByName("p17")->Value = AObj->STRM_HTTP_ADDR;
  414. pADO->Parameters->ParamByName("p18")->Value = AObj->STRM_STOR_ADDR;
  415. pADO->Parameters->ParamByName("p19")->Value = AObj->CMRA_PORT;
  416. pADO->Parameters->ParamByName("p20")->Value = AObj->CMRA_ID;
  417. pADO->Parameters->ParamByName("p21")->Value = AObj->CMRA_PSWD;
  418. pADO->Parameters->ParamByName("p22")->Value = AObj->CMRA_CHNL;
  419. pADO->Parameters->ParamByName("p23")->Value = AObj->LINK_ID;
  420. pADO->Parameters->ParamByName("p24")->Value = AObj->ISTL_LCTN_ADDR;
  421. pADO->Parameters->ParamByName("p25")->Value = AObj->WCAM_MODL;
  422. pADO->ExecSQL();
  423. return MergeFcltInfo(AObj, ADbConn);
  424. }
  425. catch(EDatabaseError &E)
  426. {
  427. DBERRORLOG("TWCamCtlrManager::MergeWCam", String(E.ClassName()), E.Message, sQry);
  428. throw Exception(String(E.ClassName()) + E.Message);
  429. }
  430. catch(Exception &e)
  431. {
  432. DBERRORLOG("TWCamCtlrManager::MergeWCam", String(e.ClassName()), e.Message, sQry);
  433. throw Exception(String(e.ClassName()) + e.Message);
  434. }
  435. }
  436. __finally
  437. {
  438. if (pADO)
  439. {
  440. pADO->Close();
  441. delete pADO;
  442. }
  443. }
  444. return true;
  445. }
  446. //---------------------------------------------------------------------------
  447. #else
  448. bool TWCamCtlrManager::MergeWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  449. {
  450. String sQry;
  451. TADOQuery *pADO = NULL;
  452. sQry = "MERGE INTO TB_WCAM_CTLR L \r\n"
  453. "USING (SELECT :p01 AS WCAM_CTLR_NMBR, \r\n"
  454. " :p02 AS WCAM_CTLR_ID, \r\n"
  455. " :p03 AS WCAM_NM, \r\n"
  456. " :p04 AS WCAM_CTLR_IP, \r\n"
  457. " :p05 AS WCAM_CTLR_PORT, \r\n"
  458. " :p06 AS WCAM_CTLR_LOCAL_NO, \r\n"
  459. " :p07 AS WCAM_TYPE_CD, \r\n"
  460. " :p25 AS WCAM_MODL, \r\n"
  461. " :p08 AS ISTL_LCTN_NM, \r\n"
  462. " :p09 AS X_CRDN, \r\n"
  463. " :p10 AS Y_CRDN, \r\n"
  464. " :p11 AS DEL_YN, \r\n"
  465. " :p12 AS STRM_SVR_IP, \r\n"
  466. " :p13 AS STRM_SVR_PORT, \r\n"
  467. " :p14 AS STRM_SESN_NM, \r\n"
  468. " :p15 AS STRM_RTSP_ADDR, \r\n"
  469. " :p16 AS STRM_RTMP_ADDR, \r\n"
  470. " :p17 AS STRM_HTTP_ADDR, \r\n"
  471. " :p18 AS STRM_STOR_ADDR, \r\n"
  472. " :p19 AS CMRA_PORT, \r\n"
  473. " :p20 AS CMRA_ID, \r\n"
  474. // " scp.enc_b64('DAMO','SCP','ARIA_256.SCPS',:p21) AS CMRA_PSWD, \r\n"
  475. " :p21 AS CMRA_PSWD, \r\n"
  476. " :p22 AS CMRA_CHNL, \r\n"
  477. " :p23 AS LINK_ID, \r\n"
  478. " :p24 AS ISTL_LCTN_ADDR \r\n"
  479. " FROM DUAL) M \r\n"
  480. " ON (L.WCAM_CTLR_NMBR = M.WCAM_CTLR_NMBR) \r\n"
  481. "WHEN MATCHED THEN \r\n"
  482. " UPDATE SET L.WCAM_CTLR_ID = M.WCAM_CTLR_ID, \r\n"
  483. " L.WCAM_NM = M.WCAM_NM, \r\n"
  484. " L.WCAM_CTLR_IP = M.WCAM_CTLR_IP, \r\n"
  485. " L.WCAM_CTLR_PORT = M.WCAM_CTLR_PORT, \r\n"
  486. " L.WCAM_CTLR_LOCAL_NO = M.WCAM_CTLR_LOCAL_NO, \r\n"
  487. " L.WCAM_TYPE_CD = M.WCAM_TYPE_CD, \r\n"
  488. " L.WCAM_MODL = M.WCAM_MODL, \r\n"
  489. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  490. " L.X_CRDN = M.X_CRDN, \r\n"
  491. " L.Y_CRDN = M.Y_CRDN, \r\n"
  492. " L.DEL_YN = M.DEL_YN, \r\n"
  493. " L.STRM_SVR_IP = M.STRM_SVR_IP, \r\n"
  494. " L.STRM_SVR_PORT = M.STRM_SVR_PORT, \r\n"
  495. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  496. " L.STRM_RTSP_ADDR = M.STRM_RTSP_ADDR, \r\n"
  497. " L.STRM_RTMP_ADDR = M.STRM_RTMP_ADDR, \r\n"
  498. " L.STRM_HTTP_ADDR = M.STRM_HTTP_ADDR, \r\n"
  499. " L.STRM_STOR_ADDR = M.STRM_STOR_ADDR, \r\n"
  500. " L.CMRA_PORT = M.CMRA_PORT, \r\n"
  501. " L.CMRA_ID = M.CMRA_ID, \r\n"
  502. " L.CMRA_PSWD = M.CMRA_PSWD, \r\n"
  503. " L.CMRA_CHNL = M.CMRA_CHNL, \r\n"
  504. " L.LINK_ID = M.LINK_ID, \r\n"
  505. " L.ISTL_LCTN_ADDR = M.ISTL_LCTN_ADDR \r\n"
  506. "WHEN NOT MATCHED THEN \r\n"
  507. " INSERT (WCAM_CTLR_NMBR, \r\n"
  508. " WCAM_CTLR_ID, \r\n"
  509. " WCAM_NM, \r\n"
  510. " WCAM_CTLR_IP, \r\n"
  511. " WCAM_CTLR_PORT, \r\n"
  512. " WCAM_CTLR_LOCAL_NO, \r\n"
  513. " WCAM_TYPE_CD, \r\n"
  514. " WCAM_MODL, \r\n"
  515. " ISTL_LCTN_NM, \r\n"
  516. " X_CRDN, \r\n"
  517. " Y_CRDN, \r\n"
  518. " DEL_YN, \r\n"
  519. " STRM_SVR_IP, \r\n"
  520. " STRM_SVR_PORT, \r\n"
  521. " STRM_SESN_NM, \r\n"
  522. " STRM_RTSP_ADDR, \r\n"
  523. " STRM_RTMP_ADDR, \r\n"
  524. " STRM_HTTP_ADDR, \r\n"
  525. " STRM_STOR_ADDR, \r\n"
  526. " CMRA_PORT, \r\n"
  527. " CMRA_ID, \r\n"
  528. " CMRA_PSWD, \r\n"
  529. " CMRA_CHNL, \r\n"
  530. " LINK_ID, \r\n"
  531. " ISTL_LCTN_ADDR ) \r\n"
  532. " VALUES (M.WCAM_CTLR_NMBR, \r\n"
  533. " M.WCAM_CTLR_ID, \r\n"
  534. " M.WCAM_NM, \r\n"
  535. " M.WCAM_CTLR_IP, \r\n"
  536. " M.WCAM_CTLR_PORT, \r\n"
  537. " M.WCAM_CTLR_LOCAL_NO, \r\n"
  538. " M.WCAM_TYPE_CD, \r\n"
  539. " M.WCAM_MODL, \r\n"
  540. " M.ISTL_LCTN_NM, \r\n"
  541. " M.X_CRDN, \r\n"
  542. " M.Y_CRDN, \r\n"
  543. " M.DEL_YN, \r\n"
  544. " M.STRM_SVR_IP, \r\n"
  545. " M.STRM_SVR_PORT, \r\n"
  546. " M.STRM_SESN_NM, \r\n"
  547. " M.STRM_RTSP_ADDR, \r\n"
  548. " M.STRM_RTMP_ADDR, \r\n"
  549. " M.STRM_HTTP_ADDR, \r\n"
  550. " M.STRM_STOR_ADDR, \r\n"
  551. " M.CMRA_PORT, \r\n"
  552. " M.CMRA_ID, \r\n"
  553. " M.CMRA_PSWD, \r\n"
  554. " M.CMRA_CHNL, \r\n"
  555. " M.LINK_ID, \r\n"
  556. " M.ISTL_LCTN_ADDR ) \r\n";
  557. try
  558. {
  559. try
  560. {
  561. pADO = new TADOQuery(NULL);
  562. pADO->Close();
  563. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  564. pADO->SQL->Clear();
  565. pADO->SQL->Text = sQry;
  566. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  567. pADO->Parameters->ParamByName("p02")->Value = AObj->WCAM_CTLR_ID;
  568. pADO->Parameters->ParamByName("p03")->Value = AObj->WCAM_NM;
  569. pADO->Parameters->ParamByName("p04")->Value = AObj->WCAM_CTLR_IP;
  570. pADO->Parameters->ParamByName("p05")->Value = AObj->WCAM_CTLR_PORT;
  571. pADO->Parameters->ParamByName("p06")->Value = AObj->WCAM_CTLR_LOCAL_NO;
  572. pADO->Parameters->ParamByName("p07")->Value = AObj->WCAM_TYPE_CD;
  573. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  574. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  575. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  576. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  577. pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
  578. pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SVR_PORT;
  579. pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_SESN_NM;
  580. pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTSP_ADDR;
  581. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_RTMP_ADDR;
  582. pADO->Parameters->ParamByName("p17")->Value = AObj->STRM_HTTP_ADDR;
  583. pADO->Parameters->ParamByName("p18")->Value = AObj->STRM_STOR_ADDR;
  584. pADO->Parameters->ParamByName("p19")->Value = AObj->CMRA_PORT;
  585. pADO->Parameters->ParamByName("p20")->Value = AObj->CMRA_ID;
  586. pADO->Parameters->ParamByName("p21")->Value = AObj->CMRA_PSWD;
  587. pADO->Parameters->ParamByName("p22")->Value = AObj->CMRA_CHNL;
  588. pADO->Parameters->ParamByName("p23")->Value = AObj->LINK_ID;
  589. pADO->Parameters->ParamByName("p24")->Value = AObj->ISTL_LCTN_ADDR;
  590. pADO->Parameters->ParamByName("p25")->Value = AObj->WCAM_MODL;
  591. pADO->ExecSQL();
  592. return MergeFcltInfo(AObj, ADbConn);
  593. }
  594. catch(EDatabaseError &E)
  595. {
  596. DBERRORLOG("TWCamCtlrManager::MergeWCam", String(E.ClassName()), E.Message, sQry);
  597. throw Exception(String(E.ClassName()) + E.Message);
  598. }
  599. catch(Exception &e)
  600. {
  601. DBERRORLOG("TWCamCtlrManager::MergeWCam", String(e.ClassName()), e.Message, sQry);
  602. throw Exception(String(e.ClassName()) + e.Message);
  603. }
  604. }
  605. __finally
  606. {
  607. if (pADO)
  608. {
  609. pADO->Close();
  610. delete pADO;
  611. }
  612. }
  613. return true;
  614. }
  615. //---------------------------------------------------------------------------
  616. #endif
  617. bool TWCamCtlrManager::MergeFcltInfo(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  618. {
  619. String sQry;
  620. TADOQuery *pADO = NULL;
  621. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  622. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  623. " :p02 AS FCLT_TYPE, \r\n"
  624. " :p03 AS FCLT_LCTN \r\n"
  625. " FROM DUAL) M \r\n"
  626. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  627. "WHEN MATCHED \r\n"
  628. "THEN \r\n"
  629. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  630. " L.DEL_YN = 'N' \r\n"
  631. "WHEN NOT MATCHED \r\n"
  632. "THEN \r\n"
  633. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  634. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  635. try
  636. {
  637. try
  638. {
  639. pADO = new TADOQuery(NULL);
  640. pADO->Close();
  641. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  642. pADO->SQL->Clear();
  643. pADO->SQL->Text = sQry;
  644. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_ID;
  645. pADO->Parameters->ParamByName("p02")->Value = AObj->WCAM_TYPE_CD;//"WCAM";
  646. pADO->Parameters->ParamByName("p03")->Value = AObj->WCAM_NM;
  647. pADO->ExecSQL();
  648. return true;
  649. }
  650. catch(EDatabaseError &E)
  651. {
  652. DBERRORLOG("TWCamCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  653. throw Exception(String(E.ClassName()) + E.Message);
  654. }
  655. catch(Exception &e)
  656. {
  657. DBERRORLOG("TWCamCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  658. throw Exception(String(e.ClassName()) + e.Message);
  659. }
  660. }
  661. __finally
  662. {
  663. if (pADO)
  664. {
  665. pADO->Close();
  666. delete pADO;
  667. }
  668. }
  669. return true;
  670. }
  671. //---------------------------------------------------------------------------
  672. bool TWCamCtlrManager::GetNextWCamId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  673. {
  674. String sQry;
  675. TADOQuery *pADO = NULL;
  676. #ifdef USE_WEB_CMRA
  677. sQry = "SELECT NVL(MAX(WEB_CMRA_NMBR), 10000) + 1 AS NEWID FROM TB_WEB_CMRA \r\n";
  678. #else
  679. sQry = "SELECT NVL(MAX(WCAM_CTLR_NMBR), 10000) + 1 AS NEWID FROM TB_WCAM_CTLR \r\n";
  680. #endif
  681. try
  682. {
  683. try
  684. {
  685. pADO = new TADOQuery(NULL);
  686. pADO->Close();
  687. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  688. pADO->SQL->Clear();
  689. pADO->SQL->Text = sQry;
  690. pADO->Prepared = true;
  691. pADO->Open();
  692. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  693. AId = ANmbr / 10000;
  694. return true;
  695. }
  696. catch(EDatabaseError &E)
  697. {
  698. DBERRORLOG("TWCamCtlrManager::GetNextWCamId", String(E.ClassName()), E.Message, sQry);
  699. throw Exception(String(E.ClassName()) + E.Message);
  700. }
  701. catch(Exception &e)
  702. {
  703. DBERRORLOG("TWCamCtlrManager::GetNextWCamId", String(e.ClassName()), e.Message, sQry);
  704. throw Exception(String(e.ClassName()) + e.Message);
  705. }
  706. }
  707. __finally
  708. {
  709. if (pADO)
  710. {
  711. pADO->Close();
  712. delete pADO;
  713. }
  714. }
  715. return false;
  716. }
  717. //---------------------------------------------------------------------------
  718. bool TWCamCtlrManager::LoadPreSet(TADOConnection *ADbConn/*=NULL*/)
  719. {
  720. String sQry;
  721. TADOQuery *pADO = NULL;
  722. FLists.Lock();
  723. try
  724. {
  725. FOR_STL(TWCamCtlr*, pObj, FLists)
  726. {
  727. pObj->FLists.RemoveAll();
  728. }
  729. }
  730. __finally
  731. {
  732. FLists.UnLock();
  733. }
  734. #ifdef USE_WEB_CMRA
  735. sQry = "SELECT B.* \r\n"
  736. " FROM TB_WEB_CMRA A, \r\n"
  737. " TB_WEB_CMRA_PSET B \r\n"
  738. " WHERE A.WEB_CMRA_NMBR = B.WEB_CMRA_NMBR \r\n"
  739. " ORDER BY B.WEB_CMRA_NMBR, B.PSET_NMBR \r\n";
  740. #else
  741. sQry = "SELECT B.* \r\n"
  742. " FROM TB_WCAM_CTLR A, \r\n"
  743. " TB_WCAM_PSET B \r\n"
  744. " WHERE A.WCAM_CTLR_NMBR = B.WCAM_CTLR_NMBR \r\n"
  745. " ORDER BY B.WCAM_CTLR_NMBR, B.PSET_NMBR \r\n";
  746. #endif
  747. try
  748. {
  749. String WCAM_CTLR_NMBR;
  750. FLists.Lock();
  751. try
  752. {
  753. pADO = new TADOQuery(NULL);
  754. pADO->Close();
  755. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  756. pADO->SQL->Clear();
  757. pADO->SQL->Text = sQry;
  758. pADO->Prepared = true;
  759. pADO->Open();
  760. for( ; !pADO->Eof; pADO->Next())
  761. {
  762. //WCAM_CTLR_NMBR = pADO->FieldByName("WCAM_CTLR_NMBR")->AsString;
  763. WCAM_CTLR_NMBR = pADO->FieldByName("WEB_CMRA_NMBR")->AsString;
  764. TWCamCtlr *pWCam = FLists.Find(String(WCAM_CTLR_NMBR));
  765. if (!pWCam) continue;
  766. TWCamPset *pObj = new TWCamPset();
  767. if (pObj)
  768. {
  769. pObj->WCAM_CTLR_NMBR = WCAM_CTLR_NMBR;
  770. pObj->PSET_NMBR = pADO->FieldByName("PSET_NMBR")->AsInteger;
  771. pObj->PSET_NM = pADO->FieldByName("PSET_NM")->AsString;
  772. #ifdef USE_WEB_CMRA
  773. pObj->PAN = pADO->FieldByName("PAN_VAL")->AsInteger;
  774. pObj->TILT = pADO->FieldByName("TILT_VAL")->AsInteger;
  775. pObj->ZOOM = pADO->FieldByName("ZOOM_VAL")->AsInteger;
  776. pObj->FOCS = pADO->FieldByName("FOCS_VAL")->AsInteger;
  777. //pObj->ANGLE = pADO->FieldByName("ANGLE")->AsInteger;
  778. //pObj->DFLT_YN = pADO->FieldByName("DFLT_YN")->AsString;
  779. #else
  780. pObj->PAN = pADO->FieldByName("PAN")->AsInteger;
  781. pObj->TILT = pADO->FieldByName("TILT")->AsInteger;
  782. pObj->ZOOM = pADO->FieldByName("ZOOM")->AsInteger;
  783. pObj->FOCS = pADO->FieldByName("FOCS")->AsInteger;
  784. pObj->ANGLE = pADO->FieldByName("ANGLE")->AsInteger;
  785. pObj->DFLT_YN = pADO->FieldByName("DFLT_YN")->AsString;
  786. #endif
  787. pObj->DEL_YN = "N";
  788. pWCam->FLists.Push(pObj->PSET_NMBR, pObj);
  789. }
  790. }
  791. }
  792. catch(EDatabaseError &E)
  793. {
  794. DBERRORMSG("TWCamCtlrManager::LoadPreSet", String(E.ClassName()), E.Message, sQry);
  795. throw Exception(String(E.ClassName()) + E.Message);
  796. }
  797. catch(Exception &e)
  798. {
  799. DBERRORMSG("TWCamCtlrManager::LoadPreSet", String(e.ClassName()), e.Message, sQry);
  800. throw Exception(String(e.ClassName()) + e.Message);
  801. }
  802. }
  803. __finally
  804. {
  805. if (pADO)
  806. {
  807. pADO->Close();
  808. delete pADO;
  809. }
  810. FLists.UnLock();
  811. }
  812. return true;
  813. }
  814. //---------------------------------------------------------------------------
  815. bool TWCamCtlrManager::SavePreSet(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  816. {
  817. String sQry;
  818. TADOQuery *pADO = NULL;
  819. try
  820. {
  821. try
  822. {
  823. pADO = new TADOQuery(NULL);
  824. pADO->Close();
  825. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  826. #ifdef USE_WEB_CMAR
  827. sQry = "DELETE FROM TB_WEB_CMRA_PSET WHERE WEB_CMRA_NMBR = :p01";
  828. #else
  829. sQry = "DELETE FROM TB_WCAM_PSET WHERE WCAM_CTLR_NMBR = :p01";
  830. #endif
  831. pADO->SQL->Clear();
  832. pADO->SQL->Text = sQry;
  833. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  834. pADO->ExecSQL();
  835. #ifdef USE_WEB_CMAR
  836. sQry = "INSERT INTO TB_WEB_CMRA_PSET ( \r\n"
  837. " WEB_CMRA_NMBR, \r\n"
  838. " PSET_NMBR, \r\n"
  839. " PSET_NM, \r\n"
  840. " PAN_VAL, \r\n"
  841. " TILT_VAL, \r\n"
  842. " ZOOM_VAL, \r\n"
  843. " FOCS_VAL \r\n"
  844. " ) VALUES ( \r\n"
  845. " :p01, \r\n"
  846. " :p02, \r\n"
  847. " :p03, \r\n"
  848. " :p04, \r\n"
  849. " :p05, \r\n"
  850. " :p06, \r\n"
  851. " :p07 \r\n"
  852. " ) \r\n";
  853. #else
  854. sQry = "INSERT INTO TB_WCAM_PSET ( \r\n"
  855. " WCAM_CTLR_NMBR, \r\n"
  856. " PSET_NMBR, \r\n"
  857. " PSET_NM, \r\n"
  858. " PAN, \r\n"
  859. " TILT, \r\n"
  860. " ZOOM, \r\n"
  861. " FOCS, \r\n"
  862. " ANGLE, \r\n"
  863. " DFLT_YN \r\n"
  864. " ) VALUES ( \r\n"
  865. " :p01, \r\n"
  866. " :p02, \r\n"
  867. " :p03, \r\n"
  868. " :p04, \r\n"
  869. " :p05, \r\n"
  870. " :p06, \r\n"
  871. " :p07, \r\n"
  872. " :p08, \r\n"
  873. " :p09 \r\n"
  874. " ) \r\n";
  875. #endif
  876. pADO->SQL->Clear();
  877. pADO->SQL->Text = sQry;
  878. FOR_STL(TWCamPset *, pObj, AObj->FLists)
  879. {
  880. if (pObj->DEL_YN != "N") continue;
  881. pADO->Parameters->ParamByName("p01")->Value = pObj->WCAM_CTLR_NMBR;
  882. pADO->Parameters->ParamByName("p02")->Value = pObj->PSET_NMBR;
  883. pADO->Parameters->ParamByName("p03")->Value = pObj->PSET_NM;
  884. pADO->Parameters->ParamByName("p04")->Value = pObj->PAN;
  885. pADO->Parameters->ParamByName("p05")->Value = pObj->TILT;
  886. pADO->Parameters->ParamByName("p06")->Value = pObj->ZOOM;
  887. pADO->Parameters->ParamByName("p07")->Value = pObj->FOCS;
  888. #ifndef USE_WEB_CMRA
  889. pADO->Parameters->ParamByName("p08")->Value = pObj->ANGLE;
  890. pADO->Parameters->ParamByName("p09")->Value = pObj->DFLT_YN;
  891. #endif
  892. pADO->ExecSQL();
  893. }
  894. return true;
  895. }
  896. catch(EDatabaseError &E)
  897. {
  898. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  899. throw Exception(String(E.ClassName()) + E.Message);
  900. }
  901. catch(Exception &e)
  902. {
  903. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  904. throw Exception(String(e.ClassName()) + e.Message);
  905. }
  906. }
  907. __finally
  908. {
  909. if (pADO)
  910. {
  911. pADO->Close();
  912. delete pADO;
  913. }
  914. }
  915. return true;
  916. }
  917. //---------------------------------------------------------------------------
  918. bool TWCamCtlrManager::DeletePreSet(TWCamCtlr *AObj, int APsetNmbr, TADOConnection *ADbConn/*=NULL*/)
  919. {
  920. String sQry;
  921. TADOQuery *pADO = NULL;
  922. TWCamPset* pObj = AObj->FLists.Find(APsetNmbr);
  923. if (!pObj) return false;
  924. #ifdef USE_WEB_CMRA
  925. sQry = "DELETE FROM TB_WEB_CMRA_PSET WHERE WEB_CMRA_NMBR = :p01 AND PSET_NMBR = :p02";
  926. #else
  927. sQry = "DELETE FROM TB_WCAM_PSET WHERE WCAM_CTLR_NMBR = :p01 AND PSET_NMBR = :p02";
  928. #endif
  929. try
  930. {
  931. try
  932. {
  933. pADO = new TADOQuery(NULL);
  934. pADO->Close();
  935. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  936. pADO->SQL->Clear();
  937. pADO->SQL->Text = sQry;
  938. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  939. pADO->Parameters->ParamByName("p02")->Value = APsetNmbr;
  940. pADO->ExecSQL();
  941. pObj->DEL_YN = "Y";
  942. return true;
  943. }
  944. catch(EDatabaseError &E)
  945. {
  946. DBERRORLOG("TWCamCtlrManager::DeletePreSet", String(E.ClassName()), E.Message, sQry);
  947. throw Exception(String(E.ClassName()) + E.Message);
  948. }
  949. catch(Exception &e)
  950. {
  951. DBERRORLOG("TWCamCtlrManager::DeletePreSet", String(e.ClassName()), e.Message, sQry);
  952. throw Exception(String(e.ClassName()) + e.Message);
  953. }
  954. }
  955. __finally
  956. {
  957. if (pADO)
  958. {
  959. pADO->Close();
  960. delete pADO;
  961. }
  962. }
  963. return true;
  964. }
  965. //---------------------------------------------------------------------------
  966. #ifdef USE_WEB_CMRA
  967. bool TWCamCtlrManager::MergePreSet(TWCamCtlr *AObj, TWCamPset* APset, TADOConnection *ADbConn/*=NULL*/)
  968. {
  969. String sQry;
  970. TADOQuery *pADO = NULL;
  971. try
  972. {
  973. try
  974. {
  975. pADO = new TADOQuery(NULL);
  976. pADO->Close();
  977. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  978. sQry = "MERGE INTO TB_WEB_CMRA_PSET L \r\n"
  979. "USING (SELECT :p01 AS WEB_CMRA_NMBR, \r\n"
  980. " :p02 AS PSET_NMBR, \r\n"
  981. " :p03 AS PSET_NM, \r\n"
  982. " :p04 AS PAN_VAL, \r\n"
  983. " :p05 AS TILT_VAL, \r\n"
  984. " :p06 AS ZOOM_VAL, \r\n"
  985. " :p07 AS FOCS_VAL \r\n"
  986. " FROM DUAL) M \r\n"
  987. " ON (L.WCAM_CTLR_NMBR = M.WCAM_CTLR_NMBR) \r\n"
  988. "WHEN MATCHED THEN \r\n"
  989. " UPDATE SET L.PSET_NMBR = M.PSET_NMBR, \r\n"
  990. " L.PSET_NM = M.PSET_NM, \r\n"
  991. " L.PAN_VAL = M.PAN_VAL, \r\n"
  992. " L.TILT_VAL = M.TILT_VAL, \r\n"
  993. " L.ZOOM_VAL = M.ZOOM_VAL, \r\n"
  994. " L.FOCS_VAL = M.FOCS_VAL \r\n"
  995. "WHEN NOT MATCHED THEN \r\n"
  996. " INSERT (WEB_CMRA_NMBR, \r\n"
  997. " PSET_NMBR, \r\n"
  998. " PSET_NM, \r\n"
  999. " PAN_VAL, \r\n"
  1000. " TILT_VAL, \r\n"
  1001. " ZOOM_VAL, \r\n"
  1002. " FOCS_VAL ) \r\n"
  1003. " VALUES (M.WEB_CMRA_NMBR, \r\n"
  1004. " M.PSET_NMBR, \r\n"
  1005. " M.PSET_NM, \r\n"
  1006. " M.PAN_VAL, \r\n"
  1007. " M.TILT_VAL, \r\n"
  1008. " M.ZOOM_VAL, \r\n"
  1009. " M.FOCS_VAL ) \r\n";
  1010. pADO->SQL->Clear();
  1011. pADO->SQL->Text = sQry;
  1012. FOR_STL(TWCamPset *, pObj, AObj->FLists)
  1013. {
  1014. if (pObj->DEL_YN != "N") continue;
  1015. pADO->Parameters->ParamByName("p01")->Value = APset->WCAM_CTLR_NMBR;
  1016. pADO->Parameters->ParamByName("p02")->Value = APset->PSET_NMBR;
  1017. pADO->Parameters->ParamByName("p03")->Value = APset->PSET_NM;
  1018. pADO->Parameters->ParamByName("p04")->Value = APset->PAN;
  1019. pADO->Parameters->ParamByName("p05")->Value = APset->TILT;
  1020. pADO->Parameters->ParamByName("p06")->Value = APset->ZOOM;
  1021. pADO->Parameters->ParamByName("p07")->Value = APset->FOCS;
  1022. pADO->ExecSQL();
  1023. TWCamPset* pObj = AObj->FLists.Find(APset->PSET_NMBR);
  1024. if (pObj)
  1025. {
  1026. pObj->WCAM_CTLR_NMBR = APset->WCAM_CTLR_NMBR;
  1027. pObj->PSET_NMBR = APset->PSET_NMBR;
  1028. pObj->PSET_NM = APset->PSET_NM;
  1029. pObj->PAN = APset->PAN;
  1030. pObj->TILT = APset->TILT;
  1031. pObj->ZOOM = APset->ZOOM;
  1032. pObj->FOCS = APset->FOCS;
  1033. pObj->ANGLE = APset->ANGLE;
  1034. pObj->DFLT_YN = APset->DFLT_YN;
  1035. }
  1036. else
  1037. {
  1038. AObj->FLists.Push(APset->PSET_NMBR, APset);
  1039. }
  1040. }
  1041. return true;
  1042. }
  1043. catch(EDatabaseError &E)
  1044. {
  1045. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  1046. throw Exception(String(E.ClassName()) + E.Message);
  1047. }
  1048. catch(Exception &e)
  1049. {
  1050. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  1051. throw Exception(String(e.ClassName()) + e.Message);
  1052. }
  1053. }
  1054. __finally
  1055. {
  1056. if (pADO)
  1057. {
  1058. pADO->Close();
  1059. delete pADO;
  1060. }
  1061. }
  1062. return true;
  1063. }
  1064. //---------------------------------------------------------------------------
  1065. #else
  1066. bool TWCamCtlrManager::MergePreSet(TWCamCtlr *AObj, TWCamPset* APset, TADOConnection *ADbConn/*=NULL*/)
  1067. {
  1068. String sQry;
  1069. TADOQuery *pADO = NULL;
  1070. try
  1071. {
  1072. try
  1073. {
  1074. pADO = new TADOQuery(NULL);
  1075. pADO->Close();
  1076. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1077. sQry = "MERGE INTO TB_WCAM_PSET L \r\n"
  1078. "USING (SELECT :p01 AS WCAM_CTLR_NMBR, \r\n"
  1079. " :p02 AS PSET_NMBR, \r\n"
  1080. " :p03 AS PSET_NM, \r\n"
  1081. " :p04 AS PAN, \r\n"
  1082. " :p05 AS TILT, \r\n"
  1083. " :p06 AS ZOOM, \r\n"
  1084. " :p07 AS FOCS, \r\n"
  1085. " :p08 AS ANGLE, \r\n"
  1086. " :p09 AS DFLT_YN \r\n"
  1087. " FROM DUAL) M \r\n"
  1088. " ON (L.WCAM_CTLR_NMBR = M.WCAM_CTLR_NMBR) \r\n"
  1089. "WHEN MATCHED THEN \r\n"
  1090. " UPDATE SET L.PSET_NMBR = M.PSET_NMBR, \r\n"
  1091. " L.PSET_NM = M.PSET_NM, \r\n"
  1092. " L.PAN = M.PAN, \r\n"
  1093. " L.TILT = M.TILT, \r\n"
  1094. " L.ZOOM = M.ZOOM, \r\n"
  1095. " L.FOCS = M.FOCS, \r\n"
  1096. " L.ANGLE = M.ANGLE, \r\n"
  1097. " L.DFLT_YN = M.DFLT_YN \r\n"
  1098. "WHEN NOT MATCHED THEN \r\n"
  1099. " INSERT (WCAM_CTLR_NMBR, \r\n"
  1100. " PSET_NMBR, \r\n"
  1101. " PSET_NM, \r\n"
  1102. " PAN, \r\n"
  1103. " TILT, \r\n"
  1104. " ZOOM, \r\n"
  1105. " FOCS, \r\n"
  1106. " ANGLE, \r\n"
  1107. " DFLT_YN ) \r\n"
  1108. " VALUES (M.WCAM_CTLR_NMBR, \r\n"
  1109. " M.PSET_NMBR, \r\n"
  1110. " M.PSET_NM, \r\n"
  1111. " M.PAN, \r\n"
  1112. " M.TILT, \r\n"
  1113. " M.ZOOM, \r\n"
  1114. " M.FOCS, \r\n"
  1115. " M.ANGLE, \r\n"
  1116. " M.DFLT_YN ) \r\n";
  1117. pADO->SQL->Clear();
  1118. pADO->SQL->Text = sQry;
  1119. FOR_STL(TWCamPset *, pObj, AObj->FLists)
  1120. {
  1121. if (pObj->DEL_YN != "N") continue;
  1122. pADO->Parameters->ParamByName("p01")->Value = APset->WCAM_CTLR_NMBR;
  1123. pADO->Parameters->ParamByName("p02")->Value = APset->PSET_NMBR;
  1124. pADO->Parameters->ParamByName("p03")->Value = APset->PSET_NM;
  1125. pADO->Parameters->ParamByName("p04")->Value = APset->PAN;
  1126. pADO->Parameters->ParamByName("p05")->Value = APset->TILT;
  1127. pADO->Parameters->ParamByName("p06")->Value = APset->ZOOM;
  1128. pADO->Parameters->ParamByName("p07")->Value = APset->FOCS;
  1129. pADO->Parameters->ParamByName("p08")->Value = APset->ANGLE;
  1130. pADO->Parameters->ParamByName("p09")->Value = APset->DFLT_YN;
  1131. pADO->ExecSQL();
  1132. TWCamPset* pObj = AObj->FLists.Find(APset->PSET_NMBR);
  1133. if (pObj)
  1134. {
  1135. pObj->WCAM_CTLR_NMBR = APset->WCAM_CTLR_NMBR;
  1136. pObj->PSET_NMBR = APset->PSET_NMBR;
  1137. pObj->PSET_NM = APset->PSET_NM;
  1138. pObj->PAN = APset->PAN;
  1139. pObj->TILT = APset->TILT;
  1140. pObj->ZOOM = APset->ZOOM;
  1141. pObj->FOCS = APset->FOCS;
  1142. pObj->ANGLE = APset->ANGLE;
  1143. pObj->DFLT_YN = APset->DFLT_YN;
  1144. }
  1145. else
  1146. {
  1147. AObj->FLists.Push(APset->PSET_NMBR, APset);
  1148. }
  1149. }
  1150. return true;
  1151. }
  1152. catch(EDatabaseError &E)
  1153. {
  1154. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  1155. throw Exception(String(E.ClassName()) + E.Message);
  1156. }
  1157. catch(Exception &e)
  1158. {
  1159. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  1160. throw Exception(String(e.ClassName()) + e.Message);
  1161. }
  1162. }
  1163. __finally
  1164. {
  1165. if (pADO)
  1166. {
  1167. pADO->Close();
  1168. delete pADO;
  1169. }
  1170. }
  1171. return true;
  1172. }
  1173. //---------------------------------------------------------------------------
  1174. #endif
  1175. bool TWCamCtlrManager::InsWCamControlHs(String ACtlDt, String ACctvNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
  1176. {
  1177. String sQry;
  1178. TADOQuery *pADO = NULL;
  1179. sQry = "INSERT INTO TB_WCAM_CTRL_HS( \r\n"
  1180. " CTRL_DT, \r\n"
  1181. " WCAM_CTLR_NMBR, \r\n"
  1182. " CTRL_TYPE, \r\n"
  1183. " CTRL_VAL, \r\n"
  1184. " CTRL_RESULT, \r\n"
  1185. " USER_ID \r\n"
  1186. " ) \r\n"
  1187. " VALUES( \r\n"
  1188. " :p01, \r\n"
  1189. " :p02, \r\n"
  1190. " :p03, \r\n"
  1191. " :p04, \r\n"
  1192. " :p05, \r\n"
  1193. " :p06 \r\n"
  1194. " ) \r\n";
  1195. try
  1196. {
  1197. try
  1198. {
  1199. pADO = new TADOQuery(NULL);
  1200. pADO->Close();
  1201. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  1202. pADO->SQL->Clear();
  1203. pADO->SQL->Text = sQry;
  1204. pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
  1205. pADO->Parameters->ParamByName("p02")->Value = ACctvNmbr;
  1206. pADO->Parameters->ParamByName("p03")->Value = ACtlType;
  1207. pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
  1208. pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
  1209. pADO->Parameters->ParamByName("p06")->Value = AUserId;
  1210. pADO->ExecSQL();
  1211. return true;
  1212. }
  1213. catch(EDatabaseError &E)
  1214. {
  1215. DBERRORLOG("TWCamCtlrManager::InsWCamControlHs", String(E.ClassName()), E.Message, sQry);
  1216. throw Exception(String(E.ClassName()) + E.Message);
  1217. }
  1218. catch(Exception &e)
  1219. {
  1220. DBERRORLOG("TWCamCtlrManager::InsWCamControlHs", String(e.ClassName()), e.Message, sQry);
  1221. throw Exception(String(e.ClassName()) + e.Message);
  1222. }
  1223. }
  1224. __finally
  1225. {
  1226. if (pADO)
  1227. {
  1228. pADO->Close();
  1229. delete pADO;
  1230. }
  1231. }
  1232. return true;
  1233. }
  1234. //---------------------------------------------------------------------------