CDSWCamCtlrF.cpp 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSWCamCtlrF.h"
  4. #include "AppGlobalF.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. sQry = "SELECT A.*, \r\n"
  36. " scp.dec_b64('DAMO','SCP','ARIA_256.SCPS',A.CMRA_PSWD) AS PWD, \r\n"
  37. " A.WCAM_TYPE_CD, \r\n"
  38. " (SELECT CMMN_CD_KOR_NM \r\n"
  39. " FROM TB_CMMN_CD \r\n"
  40. " WHERE CMMN_CLSF_CD = 'WCAM' \r\n"
  41. " AND CMMN_CD = A.WCAM_TYPE_CD) AS WCAM_TYPE_NM \r\n"
  42. " FROM TB_WCAM_CTLR A \r\n";
  43. " WHERE A.DEL_YN = 'N' \r\n";
  44. FLists.Lock();
  45. try
  46. {
  47. FLists.RemoveAll();
  48. try
  49. {
  50. pADO = new TADOQuery(NULL);
  51. pADO->Close();
  52. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  53. pADO->SQL->Clear();
  54. pADO->SQL->Text = sQry;
  55. pADO->Prepared = true;
  56. pADO->Open();
  57. for( ; !pADO->Eof; pADO->Next())
  58. {
  59. TWCamCtlr *pObj = new TWCamCtlr();
  60. pObj->WCAM_CTLR_NMBR = pADO->FieldByName("WCAM_CTLR_NMBR")->AsString;
  61. pObj->WCAM_CTLR_ID = pADO->FieldByName("WCAM_CTLR_ID")->AsString.Trim();
  62. pObj->WCAM_NM = pADO->FieldByName("WCAM_NM")->AsString.Trim();
  63. pObj->WCAM_CTLR_IP = pADO->FieldByName("WCAM_CTLR_IP")->AsString.Trim();
  64. pObj->WCAM_CTLR_PORT = pADO->FieldByName("WCAM_CTLR_PORT")->AsInteger;
  65. pObj->WCAM_CTLR_LOCAL_NO = pADO->FieldByName("WCAM_CTLR_LOCAL_NO")->AsInteger;
  66. pObj->WCAM_TYPE_CD = pADO->FieldByName("WCAM_TYPE_CD")->AsString.Trim();
  67. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();
  68. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat;
  69. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat;
  70. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString;
  71. pObj->STRM_SVR_IP = pADO->FieldByName("STRM_SVR_IP")->AsString.Trim();
  72. pObj->STRM_SVR_PORT = pADO->FieldByName("STRM_SVR_PORT")->AsString.Trim();
  73. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim();
  74. pObj->STRM_RTSP_ADDR = pADO->FieldByName("STRM_RTSP_ADDR")->AsString.Trim();
  75. pObj->STRM_RTMP_ADDR = pADO->FieldByName("STRM_RTMP_ADDR")->AsString.Trim();
  76. pObj->STRM_HTTP_ADDR = pADO->FieldByName("STRM_HTTP_ADDR")->AsString.Trim();
  77. pObj->STRM_STOR_ADDR = pADO->FieldByName("STRM_STOR_ADDR")->AsString.Trim();
  78. pObj->CMRA_PORT = pADO->FieldByName("CMRA_PORT")->AsInteger;
  79. pObj->CMRA_ID = pADO->FieldByName("CMRA_ID")->AsString.Trim();
  80. //pObj->CMRA_PSWD = pADO->FieldByName("CMRA_PSWD")->AsString.Trim();
  81. pObj->CMRA_PSWD = pADO->FieldByName("PWD")->AsString.Trim();
  82. pObj->CMRA_CHNL = pADO->FieldByName("CMRA_CHNL")->AsInteger;
  83. pObj->LINK_ID = pADO->FieldByName("LINK_ID")->AsString.Trim();
  84. pObj->ISTL_LCTN_ADDR = pADO->FieldByName("ISTL_LCTN_ADDR")->AsString.Trim();
  85. pObj->FULL_STRM_ADDR = pADO->FieldByName("FULL_STRM_SESN_NM")->AsString.Trim();
  86. pObj->WCAM_TYPE_NM = pADO->FieldByName("WCAM_TYPE_NM")->AsString.Trim();
  87. FLists.Push(pObj->WCAM_CTLR_NMBR, pObj);
  88. pObj->Completed = true;
  89. }
  90. }
  91. catch(EDatabaseError &E)
  92. {
  93. DBERRORMSG("TWCamCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  94. throw Exception(String(E.ClassName()) + E.Message);
  95. }
  96. catch(Exception &e)
  97. {
  98. DBERRORMSG("TWCamCtlrManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
  99. throw Exception(String(e.ClassName()) + e.Message);
  100. }
  101. }
  102. __finally
  103. {
  104. if (pADO)
  105. {
  106. pADO->Close();
  107. delete pADO;
  108. }
  109. FLists.UnLock();
  110. }
  111. return LoadPreSet(ADbConn);
  112. }
  113. //---------------------------------------------------------------------------
  114. bool TWCamCtlrManager::LoadStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  115. {
  116. String sQry;
  117. TADOQuery *pADO = NULL;
  118. sQry = "SELECT * \r\n"
  119. " FROM TB_WCAM_CTLR_STTS A, \r\n"
  120. " TB_WCAM_CTLR B \r\n"
  121. " WHERE A.WCAM_CTLR_NMBR = B.WCAM_CTLR_NMBR \r\n"
  122. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";
  123. FLists.Lock();
  124. try
  125. {
  126. FOR_STL(TWCamCtlr*, pTmp, FLists)
  127. {
  128. pTmp->STATE.Comm = wcam_error;
  129. }
  130. TWCamCtlr *pObj = NULL;
  131. try
  132. {
  133. int nORD;
  134. pADO = new TADOQuery(NULL);
  135. pADO->Close();
  136. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  137. pADO->SQL->Clear();
  138. pADO->SQL->Text = sQry;
  139. pADO->Prepared = true;
  140. pADO->Open();
  141. for( ; !pADO->Eof; pADO->Next())
  142. {
  143. String WCAM_CTLR_NMBR = pADO->FieldByName("WCAM_CTLR_NMBR")->AsString;
  144. pObj = FLists.Find(WCAM_CTLR_NMBR);
  145. if (!pObj) continue;
  146. String UPDT_DT = pADO->FieldByName("UPDT_DT")->AsString;
  147. String CMNC_STTS_CD = pADO->FieldByName("CMNC_STTS_CD")->AsString;
  148. if (CMNC_STTS_CD != "CMS0")
  149. {
  150. //Åë½ÅÀå¾Ö
  151. continue;
  152. }
  153. pObj->STATE.Comm = (CMNC_STTS_CD == "CMS0") ? wcam_normal : wcam_error;
  154. }
  155. }
  156. catch(EDatabaseError &E)
  157. {
  158. DBERRORLOG("TWCamCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
  159. throw Exception(String(E.ClassName()) + E.Message);
  160. }
  161. catch(Exception &e)
  162. {
  163. DBERRORLOG("TWCamCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
  164. throw Exception(String(e.ClassName()) + e.Message);
  165. }
  166. }
  167. __finally
  168. {
  169. FLists.UnLock();
  170. if (pADO)
  171. {
  172. pADO->Close();
  173. delete pADO;
  174. }
  175. }
  176. return true;
  177. }
  178. //---------------------------------------------------------------------------
  179. bool TWCamCtlrManager::DeleteWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  180. {
  181. String sQry;
  182. TADOQuery *pADO = NULL;
  183. sQry = "UPDATE TB_WCAM_CTLR \r\n"
  184. " SET DEL_YN = 'Y' \r\n"
  185. " WHERE WCAM_CTLR_NMBR = :p01 \r\n";
  186. try
  187. {
  188. try
  189. {
  190. pADO = new TADOQuery(NULL);
  191. pADO->Close();
  192. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  193. pADO->SQL->Clear();
  194. pADO->SQL->Text = sQry;
  195. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  196. pADO->ExecSQL();
  197. sQry = "DELETE TB_FCLT_INFR \r\n"
  198. " WHERE FCLT_ID = :p01 \r\n";
  199. pADO->SQL->Clear();
  200. pADO->SQL->Text = sQry;
  201. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_ID;
  202. pADO->ExecSQL();
  203. return true;
  204. }
  205. catch(EDatabaseError &E)
  206. {
  207. DBERRORLOG("TWCamCtlrManager::DeleteWCam", String(E.ClassName()), E.Message, sQry);
  208. throw Exception(String(E.ClassName()) + E.Message);
  209. }
  210. catch(Exception &e)
  211. {
  212. DBERRORLOG("TWCamCtlrManager::DeleteWCam", String(e.ClassName()), e.Message, sQry);
  213. throw Exception(String(e.ClassName()) + e.Message);
  214. }
  215. }
  216. __finally
  217. {
  218. if (pADO)
  219. {
  220. pADO->Close();
  221. delete pADO;
  222. }
  223. }
  224. return true;
  225. }
  226. //---------------------------------------------------------------------------
  227. bool TWCamCtlrManager::InsertWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  228. {
  229. return MergeWCam(AObj, ADbConn);
  230. }
  231. //---------------------------------------------------------------------------
  232. bool TWCamCtlrManager::UpdateWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  233. {
  234. return MergeWCam(AObj, ADbConn);
  235. }
  236. //---------------------------------------------------------------------------
  237. bool TWCamCtlrManager::MergeWCam(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  238. {
  239. String sQry;
  240. TADOQuery *pADO = NULL;
  241. sQry = "MERGE INTO TB_WCAM_CTLR L \r\n"
  242. "USING (SELECT :p01 AS WCAM_CTLR_NMBR, \r\n"
  243. " :p02 AS WCAM_CTLR_ID, \r\n"
  244. " :p03 AS WCAM_NM, \r\n"
  245. " :p04 AS WCAM_CTLR_IP, \r\n"
  246. " :p05 AS WCAM_CTLR_PORT, \r\n"
  247. " :p06 AS WCAM_CTLR_LOCAL_NO, \r\n"
  248. " :p07 AS WCAM_TYPE_CD, \r\n"
  249. " :p08 AS ISTL_LCTN_NM, \r\n"
  250. " :p09 AS X_CRDN, \r\n"
  251. " :p10 AS Y_CRDN, \r\n"
  252. " :p11 AS DEL_YN, \r\n"
  253. " :p12 AS STRM_SVR_IP, \r\n"
  254. " :p13 AS STRM_SVR_PORT, \r\n"
  255. " :p14 AS STRM_SESN_NM, \r\n"
  256. " :p15 AS STRM_RTSP_ADDR, \r\n"
  257. " :p16 AS STRM_RTMP_ADDR, \r\n"
  258. " :p17 AS STRM_HTTP_ADDR, \r\n"
  259. " :p18 AS STRM_STOR_ADDR, \r\n"
  260. " :p19 AS CMRA_PORT, \r\n"
  261. " :p20 AS CMRA_ID, \r\n"
  262. " :p21 AS CMRA_PSWD, \r\n"
  263. " :p22 AS CMRA_CHNL, \r\n"
  264. " :p23 AS LINK_ID, \r\n"
  265. " :p24 AS ISTL_LCTN_ADDR \r\n"
  266. " FROM DUAL) M \r\n"
  267. " ON (L.WCAM_CTLR_NMBR = M.WCAM_CTLR_NMBR) \r\n"
  268. "WHEN MATCHED THEN \r\n"
  269. " UPDATE SET L.WCAM_CTLR_ID = M.WCAM_CTLR_ID, \r\n"
  270. " L.WCAM_NM = M.WCAM_NM, \r\n"
  271. " L.WCAM_CTLR_IP = M.WCAM_CTLR_IP, \r\n"
  272. " L.WCAM_CTLR_PORT = M.WCAM_CTLR_PORT, \r\n"
  273. " L.WCAM_CTLR_LOCAL_NO = M.WCAM_CTLR_LOCAL_NO, \r\n"
  274. " L.WCAM_TYPE_CD = M.WCAM_TYPE_CD, \r\n"
  275. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  276. " L.X_CRDN = M.X_CRDN, \r\n"
  277. " L.Y_CRDN = M.Y_CRDN, \r\n"
  278. " L.DEL_YN = M.DEL_YN, \r\n"
  279. " L.STRM_SVR_IP = M.STRM_SVR_IP, \r\n"
  280. " L.STRM_SVR_PORT = M.STRM_SVR_PORT, \r\n"
  281. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  282. " L.STRM_RTSP_ADDR = M.STRM_RTSP_ADDR, \r\n"
  283. " L.STRM_RTMP_ADDR = M.STRM_RTMP_ADDR, \r\n"
  284. " L.STRM_HTTP_ADDR = M.STRM_HTTP_ADDR, \r\n"
  285. " L.STRM_STOR_ADDR = M.STRM_STOR_ADDR, \r\n"
  286. " L.CMRA_PORT = M.CMRA_PORT, \r\n"
  287. " L.CMRA_ID = M.CMRA_ID, \r\n"
  288. " L.CMRA_PSWD = M.CMRA_PSWD, \r\n"
  289. " L.CMRA_CHNL = M.CMRA_CHNL, \r\n"
  290. " L.LINK_ID = M.LINK_ID, \r\n"
  291. " L.ISTL_LCTN_ADDR = M.ISTL_LCTN_ADDR \r\n"
  292. "WHEN NOT MATCHED THEN \r\n"
  293. " INSERT (WCAM_CTLR_NMBR, \r\n"
  294. " WCAM_CTLR_ID, \r\n"
  295. " WCAM_NM, \r\n"
  296. " WCAM_CTLR_IP, \r\n"
  297. " WCAM_CTLR_PORT, \r\n"
  298. " WCAM_CTLR_LOCAL_NO, \r\n"
  299. " WCAM_TYPE_CD, \r\n"
  300. " ISTL_LCTN_NM, \r\n"
  301. " X_CRDN, \r\n"
  302. " Y_CRDN, \r\n"
  303. " DEL_YN, \r\n"
  304. " STRM_SVR_IP, \r\n"
  305. " STRM_SVR_PORT, \r\n"
  306. " STRM_SESN_NM, \r\n"
  307. " STRM_RTSP_ADDR, \r\n"
  308. " STRM_RTMP_ADDR, \r\n"
  309. " STRM_HTTP_ADDR, \r\n"
  310. " STRM_STOR_ADDR, \r\n"
  311. " CMRA_PORT, \r\n"
  312. " CMRA_ID, \r\n"
  313. " CMRA_PSWD, \r\n"
  314. " CMRA_CHNL, \r\n"
  315. " LINK_ID, \r\n"
  316. " ISTL_LCTN_ADDR ) \r\n"
  317. " VALUES (M.WCAM_CTLR_NMBR, \r\n"
  318. " M.WCAM_CTLR_ID, \r\n"
  319. " M.WCAM_NM, \r\n"
  320. " M.WCAM_CTLR_IP, \r\n"
  321. " M.WCAM_CTLR_PORT, \r\n"
  322. " M.WCAM_CTLR_LOCAL_NO, \r\n"
  323. " M.WCAM_TYPE_CD, \r\n"
  324. " M.ISTL_LCTN_NM, \r\n"
  325. " M.X_CRDN, \r\n"
  326. " M.Y_CRDN, \r\n"
  327. " M.DEL_YN, \r\n"
  328. " M.STRM_SVR_IP, \r\n"
  329. " M.STRM_SVR_PORT, \r\n"
  330. " M.STRM_SESN_NM, \r\n"
  331. " M.STRM_RTSP_ADDR, \r\n"
  332. " M.STRM_RTMP_ADDR, \r\n"
  333. " M.STRM_HTTP_ADDR, \r\n"
  334. " M.STRM_STOR_ADDR, \r\n"
  335. " M.CMRA_PORT, \r\n"
  336. " M.CMRA_ID, \r\n"
  337. " M.CMRA_PSWD, \r\n"
  338. " M.CMRA_CHNL, \r\n"
  339. " M.LINK_ID, \r\n"
  340. " M.ISTL_LCTN_ADDR ) \r\n";
  341. try
  342. {
  343. try
  344. {
  345. pADO = new TADOQuery(NULL);
  346. pADO->Close();
  347. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  348. pADO->SQL->Clear();
  349. pADO->SQL->Text = sQry;
  350. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  351. pADO->Parameters->ParamByName("p02")->Value = AObj->WCAM_CTLR_ID;
  352. pADO->Parameters->ParamByName("p03")->Value = AObj->WCAM_NM;
  353. pADO->Parameters->ParamByName("p04")->Value = AObj->WCAM_CTLR_IP;
  354. pADO->Parameters->ParamByName("p05")->Value = AObj->WCAM_CTLR_PORT;
  355. pADO->Parameters->ParamByName("p06")->Value = AObj->WCAM_CTLR_LOCAL_NO;
  356. pADO->Parameters->ParamByName("p07")->Value = AObj->WCAM_TYPE_CD;
  357. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  358. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  359. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  360. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  361. pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
  362. pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SVR_PORT;
  363. pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_SESN_NM;
  364. pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTSP_ADDR;
  365. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_RTMP_ADDR;
  366. pADO->Parameters->ParamByName("p17")->Value = AObj->STRM_HTTP_ADDR;
  367. pADO->Parameters->ParamByName("p18")->Value = AObj->STRM_STOR_ADDR;
  368. pADO->Parameters->ParamByName("p19")->Value = AObj->CMRA_PORT;
  369. pADO->Parameters->ParamByName("p20")->Value = AObj->CMRA_ID;
  370. pADO->Parameters->ParamByName("p21")->Value = AObj->CMRA_PSWD;
  371. pADO->Parameters->ParamByName("p22")->Value = AObj->CMRA_CHNL;
  372. pADO->Parameters->ParamByName("p23")->Value = AObj->LINK_ID;
  373. pADO->Parameters->ParamByName("p24")->Value = AObj->ISTL_LCTN_ADDR;
  374. pADO->ExecSQL();
  375. return MergeFcltInfo(AObj, ADbConn);
  376. }
  377. catch(EDatabaseError &E)
  378. {
  379. DBERRORLOG("TWCamCtlrManager::MergeWCam", String(E.ClassName()), E.Message, sQry);
  380. throw Exception(String(E.ClassName()) + E.Message);
  381. }
  382. catch(Exception &e)
  383. {
  384. DBERRORLOG("TWCamCtlrManager::MergeWCam", String(e.ClassName()), e.Message, sQry);
  385. throw Exception(String(e.ClassName()) + e.Message);
  386. }
  387. }
  388. __finally
  389. {
  390. if (pADO)
  391. {
  392. pADO->Close();
  393. delete pADO;
  394. }
  395. }
  396. return true;
  397. }
  398. //---------------------------------------------------------------------------
  399. bool TWCamCtlrManager::MergeFcltInfo(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  400. {
  401. String sQry;
  402. TADOQuery *pADO = NULL;
  403. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  404. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  405. " :p02 AS FCLT_TYPE, \r\n"
  406. " :p03 AS FCLT_LCTN \r\n"
  407. " FROM DUAL) M \r\n"
  408. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  409. "WHEN MATCHED \r\n"
  410. "THEN \r\n"
  411. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  412. " L.DEL_YN = 'N' \r\n"
  413. "WHEN NOT MATCHED \r\n"
  414. "THEN \r\n"
  415. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  416. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  417. try
  418. {
  419. try
  420. {
  421. pADO = new TADOQuery(NULL);
  422. pADO->Close();
  423. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  424. pADO->SQL->Clear();
  425. pADO->SQL->Text = sQry;
  426. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_ID;
  427. pADO->Parameters->ParamByName("p02")->Value = "WCAM";
  428. pADO->Parameters->ParamByName("p03")->Value = AObj->WCAM_NM;
  429. pADO->ExecSQL();
  430. return true;
  431. }
  432. catch(EDatabaseError &E)
  433. {
  434. DBERRORLOG("TWCamCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  435. throw Exception(String(E.ClassName()) + E.Message);
  436. }
  437. catch(Exception &e)
  438. {
  439. DBERRORLOG("TWCamCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  440. throw Exception(String(e.ClassName()) + e.Message);
  441. }
  442. }
  443. __finally
  444. {
  445. if (pADO)
  446. {
  447. pADO->Close();
  448. delete pADO;
  449. }
  450. }
  451. return true;
  452. }
  453. //---------------------------------------------------------------------------
  454. bool TWCamCtlrManager::GetNextWCamId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  455. {
  456. String sQry;
  457. TADOQuery *pADO = NULL;
  458. sQry = "SELECT NVL(MAX(WCAM_CTLR_NMBR), 10000) + 1 AS NEWID FROM TB_WCAM_CTLR \r\n";
  459. try
  460. {
  461. try
  462. {
  463. pADO = new TADOQuery(NULL);
  464. pADO->Close();
  465. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  466. pADO->SQL->Clear();
  467. pADO->SQL->Text = sQry;
  468. pADO->Prepared = true;
  469. pADO->Open();
  470. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  471. AId = ANmbr / 10000;
  472. return true;
  473. }
  474. catch(EDatabaseError &E)
  475. {
  476. DBERRORLOG("TWCamCtlrManager::GetNextWCamId", String(E.ClassName()), E.Message, sQry);
  477. throw Exception(String(E.ClassName()) + E.Message);
  478. }
  479. catch(Exception &e)
  480. {
  481. DBERRORLOG("TWCamCtlrManager::GetNextWCamId", String(e.ClassName()), e.Message, sQry);
  482. throw Exception(String(e.ClassName()) + e.Message);
  483. }
  484. }
  485. __finally
  486. {
  487. if (pADO)
  488. {
  489. pADO->Close();
  490. delete pADO;
  491. }
  492. }
  493. return false;
  494. }
  495. //---------------------------------------------------------------------------
  496. bool TWCamCtlrManager::LoadPreSet(TADOConnection *ADbConn/*=NULL*/)
  497. {
  498. String sQry;
  499. TADOQuery *pADO = NULL;
  500. FLists.Lock();
  501. try
  502. {
  503. FOR_STL(TWCamCtlr*, pObj, FLists)
  504. {
  505. pObj->FLists.RemoveAll();
  506. }
  507. }
  508. __finally
  509. {
  510. FLists.UnLock();
  511. }
  512. sQry = "SELECT B.* \r\n"
  513. " FROM TB_WCAM_CTLR A, \r\n"
  514. " TB_WCAM_PSET B \r\n"
  515. " WHERE A.WCAM_CTLR_NMBR = B.WCAM_CTLR_NMBR \r\n"
  516. " ORDER BY B.WCAM_CTLR_NMBR, B.PSET_NMBR \r\n";
  517. try
  518. {
  519. String WCAM_CTLR_NMBR;
  520. FLists.Lock();
  521. try
  522. {
  523. pADO = new TADOQuery(NULL);
  524. pADO->Close();
  525. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  526. pADO->SQL->Clear();
  527. pADO->SQL->Text = sQry;
  528. pADO->Prepared = true;
  529. pADO->Open();
  530. for( ; !pADO->Eof; pADO->Next())
  531. {
  532. WCAM_CTLR_NMBR = pADO->FieldByName("WCAM_CTLR_NMBR")->AsString;
  533. TWCamCtlr *pWCam = FLists.Find(String(WCAM_CTLR_NMBR));
  534. if (!pWCam) continue;
  535. TWCamPset *pObj = new TWCamPset();
  536. if (pObj)
  537. {
  538. pObj->WCAM_CTLR_NMBR = WCAM_CTLR_NMBR;
  539. pObj->PSET_NMBR = pADO->FieldByName("PSET_NMBR")->AsInteger;
  540. pObj->PSET_NM = pADO->FieldByName("PSET_NM")->AsString;
  541. pObj->PAN = pADO->FieldByName("PAN")->AsInteger;
  542. pObj->TILT = pADO->FieldByName("TILT")->AsInteger;
  543. pObj->ZOOM = pADO->FieldByName("ZOOM")->AsInteger;
  544. pObj->FOCS = pADO->FieldByName("FOCS")->AsInteger;
  545. pObj->ANGLE = pADO->FieldByName("ANGLE")->AsInteger;
  546. pObj->DFLT_YN = pADO->FieldByName("DFLT_YN")->AsString;
  547. pObj->DEL_YN = "N";
  548. pWCam->FLists.Push(pObj->PSET_NMBR, pObj);
  549. }
  550. }
  551. }
  552. catch(EDatabaseError &E)
  553. {
  554. DBERRORMSG("TWCamCtlrManager::LoadPreSet", String(E.ClassName()), E.Message, sQry);
  555. throw Exception(String(E.ClassName()) + E.Message);
  556. }
  557. catch(Exception &e)
  558. {
  559. DBERRORMSG("TWCamCtlrManager::LoadPreSet", String(e.ClassName()), e.Message, sQry);
  560. throw Exception(String(e.ClassName()) + e.Message);
  561. }
  562. }
  563. __finally
  564. {
  565. if (pADO)
  566. {
  567. pADO->Close();
  568. delete pADO;
  569. }
  570. FLists.UnLock();
  571. }
  572. return true;
  573. }
  574. //---------------------------------------------------------------------------
  575. bool TWCamCtlrManager::SavePreSet(TWCamCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  576. {
  577. String sQry;
  578. TADOQuery *pADO = NULL;
  579. try
  580. {
  581. try
  582. {
  583. pADO = new TADOQuery(NULL);
  584. pADO->Close();
  585. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  586. sQry = "DELETE FROM TB_WCAM_PSET WHERE WCAM_CTLR_NMBR = :p01";
  587. pADO->SQL->Clear();
  588. pADO->SQL->Text = sQry;
  589. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  590. pADO->ExecSQL();
  591. sQry = "INSERT INTO TB_WCAM_PSET ( \r\n"
  592. " WCAM_CTLR_NMBR, \r\n"
  593. " PSET_NMBR, \r\n"
  594. " PSET_NM, \r\n"
  595. " PAN, \r\n"
  596. " TILT, \r\n"
  597. " ZOOM, \r\n"
  598. " FOCS, \r\n"
  599. " ANGLE, \r\n"
  600. " DFLT_YN \r\n"
  601. " ) VALUES ( \r\n"
  602. " :p01, \r\n"
  603. " :p02, \r\n"
  604. " :p03, \r\n"
  605. " :p04, \r\n"
  606. " :p05, \r\n"
  607. " :p06, \r\n"
  608. " :p07, \r\n"
  609. " :p08, \r\n"
  610. " :p09 \r\n"
  611. " ) \r\n";
  612. pADO->SQL->Clear();
  613. pADO->SQL->Text = sQry;
  614. FOR_STL(TWCamPset *, pObj, AObj->FLists)
  615. {
  616. if (pObj->DEL_YN != "N") continue;
  617. pADO->Parameters->ParamByName("p01")->Value = pObj->WCAM_CTLR_NMBR;
  618. pADO->Parameters->ParamByName("p02")->Value = pObj->PSET_NMBR;
  619. pADO->Parameters->ParamByName("p03")->Value = pObj->PSET_NM;
  620. pADO->Parameters->ParamByName("p04")->Value = pObj->PAN;
  621. pADO->Parameters->ParamByName("p05")->Value = pObj->TILT;
  622. pADO->Parameters->ParamByName("p06")->Value = pObj->ZOOM;
  623. pADO->Parameters->ParamByName("p07")->Value = pObj->FOCS;
  624. pADO->Parameters->ParamByName("p08")->Value = pObj->ANGLE;
  625. pADO->Parameters->ParamByName("p09")->Value = pObj->DFLT_YN;
  626. pADO->ExecSQL();
  627. }
  628. return true;
  629. }
  630. catch(EDatabaseError &E)
  631. {
  632. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  633. throw Exception(String(E.ClassName()) + E.Message);
  634. }
  635. catch(Exception &e)
  636. {
  637. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  638. throw Exception(String(e.ClassName()) + e.Message);
  639. }
  640. }
  641. __finally
  642. {
  643. if (pADO)
  644. {
  645. pADO->Close();
  646. delete pADO;
  647. }
  648. }
  649. return true;
  650. }
  651. //---------------------------------------------------------------------------
  652. bool TWCamCtlrManager::DeletePreSet(TWCamCtlr *AObj, int APsetNmbr, TADOConnection *ADbConn/*=NULL*/)
  653. {
  654. String sQry;
  655. TADOQuery *pADO = NULL;
  656. TWCamPset* pObj = AObj->FLists.Find(APsetNmbr);
  657. if (!pObj) return false;
  658. sQry = "DELETE FROM TB_WCAM_PSET WHERE WCAM_CTLR_NMBR = :p01 AND PSET_NMBR = :p02";
  659. try
  660. {
  661. try
  662. {
  663. pADO = new TADOQuery(NULL);
  664. pADO->Close();
  665. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  666. pADO->SQL->Clear();
  667. pADO->SQL->Text = sQry;
  668. pADO->Parameters->ParamByName("p01")->Value = AObj->WCAM_CTLR_NMBR;
  669. pADO->Parameters->ParamByName("p02")->Value = APsetNmbr;
  670. pADO->ExecSQL();
  671. pObj->DEL_YN = "Y";
  672. return true;
  673. }
  674. catch(EDatabaseError &E)
  675. {
  676. DBERRORLOG("TWCamCtlrManager::DeletePreSet", String(E.ClassName()), E.Message, sQry);
  677. throw Exception(String(E.ClassName()) + E.Message);
  678. }
  679. catch(Exception &e)
  680. {
  681. DBERRORLOG("TWCamCtlrManager::DeletePreSet", String(e.ClassName()), e.Message, sQry);
  682. throw Exception(String(e.ClassName()) + e.Message);
  683. }
  684. }
  685. __finally
  686. {
  687. if (pADO)
  688. {
  689. pADO->Close();
  690. delete pADO;
  691. }
  692. }
  693. return true;
  694. }
  695. //---------------------------------------------------------------------------
  696. bool TWCamCtlrManager::MergePreSet(TWCamCtlr *AObj, TWCamPset* APset, TADOConnection *ADbConn/*=NULL*/)
  697. {
  698. String sQry;
  699. TADOQuery *pADO = NULL;
  700. try
  701. {
  702. try
  703. {
  704. pADO = new TADOQuery(NULL);
  705. pADO->Close();
  706. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  707. sQry = "MERGE INTO TB_WCAM_PSET L \r\n"
  708. "USING (SELECT :p01 AS WCAM_CTLR_NMBR, \r\n"
  709. " :p02 AS PSET_NMBR, \r\n"
  710. " :p03 AS PSET_NM, \r\n"
  711. " :p04 AS PAN, \r\n"
  712. " :p05 AS TILT, \r\n"
  713. " :p06 AS ZOOM, \r\n"
  714. " :p07 AS FOCS, \r\n"
  715. " :p08 AS ANGLE, \r\n"
  716. " :p09 AS DFLT_YN \r\n"
  717. " FROM DUAL) M \r\n"
  718. " ON (L.WCAM_CTLR_NMBR = M.WCAM_CTLR_NMBR) \r\n"
  719. "WHEN MATCHED THEN \r\n"
  720. " UPDATE SET L.PSET_NMBR = M.PSET_NMBR, \r\n"
  721. " L.PSET_NM = M.PSET_NM, \r\n"
  722. " L.PAN = M.PAN, \r\n"
  723. " L.TILT = M.TILT, \r\n"
  724. " L.ZOOM = M.ZOOM, \r\n"
  725. " L.FOCS = M.FOCS, \r\n"
  726. " L.ANGLE = M.ANGLE, \r\n"
  727. " L.DFLT_YN = M.DFLT_YN \r\n"
  728. "WHEN NOT MATCHED THEN \r\n"
  729. " INSERT (WCAM_CTLR_NMBR, \r\n"
  730. " PSET_NMBR, \r\n"
  731. " PSET_NM, \r\n"
  732. " PAN, \r\n"
  733. " TILT, \r\n"
  734. " ZOOM, \r\n"
  735. " FOCS, \r\n"
  736. " ANGLE, \r\n"
  737. " DFLT_YN ) \r\n"
  738. " VALUES (M.WCAM_CTLR_NMBR, \r\n"
  739. " M.PSET_NMBR, \r\n"
  740. " M.PSET_NM, \r\n"
  741. " M.PAN, \r\n"
  742. " M.TILT, \r\n"
  743. " M.ZOOM, \r\n"
  744. " M.FOCS, \r\n"
  745. " M.ANGLE, \r\n"
  746. " M.DFLT_YN ) \r\n";
  747. pADO->SQL->Clear();
  748. pADO->SQL->Text = sQry;
  749. FOR_STL(TWCamPset *, pObj, AObj->FLists)
  750. {
  751. if (pObj->DEL_YN != "N") continue;
  752. pADO->Parameters->ParamByName("p01")->Value = APset->WCAM_CTLR_NMBR;
  753. pADO->Parameters->ParamByName("p02")->Value = APset->PSET_NMBR;
  754. pADO->Parameters->ParamByName("p03")->Value = APset->PSET_NM;
  755. pADO->Parameters->ParamByName("p04")->Value = APset->PAN;
  756. pADO->Parameters->ParamByName("p05")->Value = APset->TILT;
  757. pADO->Parameters->ParamByName("p06")->Value = APset->ZOOM;
  758. pADO->Parameters->ParamByName("p07")->Value = APset->FOCS;
  759. pADO->Parameters->ParamByName("p08")->Value = APset->ANGLE;
  760. pADO->Parameters->ParamByName("p09")->Value = APset->DFLT_YN;
  761. pADO->ExecSQL();
  762. TWCamPset* pObj = AObj->FLists.Find(APset->PSET_NMBR);
  763. if (pObj)
  764. {
  765. pObj->WCAM_CTLR_NMBR = APset->WCAM_CTLR_NMBR;
  766. pObj->PSET_NMBR = APset->PSET_NMBR;
  767. pObj->PSET_NM = APset->PSET_NM;
  768. pObj->PAN = APset->PAN;
  769. pObj->TILT = APset->TILT;
  770. pObj->ZOOM = APset->ZOOM;
  771. pObj->FOCS = APset->FOCS;
  772. pObj->ANGLE = APset->ANGLE;
  773. pObj->DFLT_YN = APset->DFLT_YN;
  774. }
  775. else
  776. {
  777. AObj->FLists.Push(APset->PSET_NMBR, APset);
  778. }
  779. }
  780. return true;
  781. }
  782. catch(EDatabaseError &E)
  783. {
  784. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  785. throw Exception(String(E.ClassName()) + E.Message);
  786. }
  787. catch(Exception &e)
  788. {
  789. DBERRORLOG("TWCamCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  790. throw Exception(String(e.ClassName()) + e.Message);
  791. }
  792. }
  793. __finally
  794. {
  795. if (pADO)
  796. {
  797. pADO->Close();
  798. delete pADO;
  799. }
  800. }
  801. return true;
  802. }
  803. //---------------------------------------------------------------------------
  804. bool TWCamCtlrManager::InsWCamControlHs(String ACtlDt, String ACctvNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
  805. {
  806. String sQry;
  807. TADOQuery *pADO = NULL;
  808. sQry = "INSERT INTO TB_WCAM_CTRL_HS( \r\n"
  809. " CTRL_DT, \r\n"
  810. " WCAM_CTLR_NMBR, \r\n"
  811. " CTRL_TYPE, \r\n"
  812. " CTRL_VAL, \r\n"
  813. " CTRL_RESULT, \r\n"
  814. " USER_ID \r\n"
  815. " ) \r\n"
  816. " VALUES( \r\n"
  817. " :p01, \r\n"
  818. " :p02, \r\n"
  819. " :p03, \r\n"
  820. " :p04, \r\n"
  821. " :p05, \r\n"
  822. " :p06 \r\n"
  823. " ) \r\n";
  824. try
  825. {
  826. try
  827. {
  828. pADO = new TADOQuery(NULL);
  829. pADO->Close();
  830. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  831. pADO->SQL->Clear();
  832. pADO->SQL->Text = sQry;
  833. pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
  834. pADO->Parameters->ParamByName("p02")->Value = ACctvNmbr;
  835. pADO->Parameters->ParamByName("p03")->Value = ACtlType;
  836. pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
  837. pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
  838. pADO->Parameters->ParamByName("p06")->Value = AUserId;
  839. pADO->ExecSQL();
  840. return true;
  841. }
  842. catch(EDatabaseError &E)
  843. {
  844. DBERRORLOG("TWCamCtlrManager::InsWCamControlHs", String(E.ClassName()), E.Message, sQry);
  845. throw Exception(String(E.ClassName()) + E.Message);
  846. }
  847. catch(Exception &e)
  848. {
  849. DBERRORLOG("TWCamCtlrManager::InsWCamControlHs", String(e.ClassName()), e.Message, sQry);
  850. throw Exception(String(e.ClassName()) + e.Message);
  851. }
  852. }
  853. __finally
  854. {
  855. if (pADO)
  856. {
  857. pADO->Close();
  858. delete pADO;
  859. }
  860. }
  861. return true;
  862. }
  863. //---------------------------------------------------------------------------