CDSCctvCtlrF.cpp 45 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077
  1. //---------------------------------------------------------------------------
  2. #pragma hdrstop
  3. #include "CDSCctvCtlrF.h"
  4. #include "AppGlobalF.h"
  5. //---------------------------------------------------------------------------
  6. #pragma package(smart_init)
  7. //---------------------------------------------------------------------------
  8. TCctvCtlr::TCctvCtlr()
  9. {
  10. }
  11. //---------------------------------------------------------------------------
  12. TCctvCtlr::~TCctvCtlr()
  13. {
  14. }
  15. //---------------------------------------------------------------------------
  16. //---------------------------------------------------------------------------
  17. TCctvCtlrManager *CctvCtlrManager = NULL;
  18. //---------------------------------------------------------------------------
  19. TCctvCtlrManager::TCctvCtlrManager()
  20. {
  21. FImgStream = NULL;
  22. }
  23. //---------------------------------------------------------------------------
  24. TCctvCtlrManager::~TCctvCtlrManager()
  25. {
  26. FLists.RemoveAll();
  27. if (FImgStream) delete FImgStream;
  28. FImgStream = NULL;
  29. }
  30. //---------------------------------------------------------------------------
  31. bool TCctvCtlrManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
  32. {
  33. String sQry;
  34. TADOQuery *pADO = NULL;
  35. sQry = "SELECT A.* \r\n"
  36. " FROM TB_CCTV_CTLR A \r\n";
  37. " WHERE A.DEL_YN = 'N' \r\n";
  38. FLists.Lock();
  39. try
  40. {
  41. FLists.RemoveAll();
  42. try
  43. {
  44. pADO = new TADOQuery(NULL);
  45. pADO->Close();
  46. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  47. pADO->SQL->Clear();
  48. pADO->SQL->Text = sQry;
  49. pADO->Prepared = true;
  50. pADO->Open();
  51. for( ; !pADO->Eof; pADO->Next())
  52. {
  53. TCctvCtlr *pObj = new TCctvCtlr();
  54. pObj->CCTV_CTLR_NMBR = pADO->FieldByName("CCTV_CTLR_NMBR")->AsString; // N NUMBER(10) N CCTV 제어기 번호
  55. pObj->CCTV_CTLR_ID = pADO->FieldByName("CCTV_CTLR_ID")->AsString.Trim(); // N VARCHAR2(30) Y CCTV 제어기 ID
  56. pObj->CCTV_NM = pADO->FieldByName("CCTV_NM")->AsString.Trim(); // N VARCHAR2(40) Y CCTV 명칭
  57. pObj->CCTV_CTLR_IP = pADO->FieldByName("CCTV_CTLR_IP")->AsString.Trim(); // N VARCHAR2(20) Y CCTV 제어기 아이피
  58. pObj->CCTV_CTLR_PORT = pADO->FieldByName("CCTV_CTLR_PORT")->AsInteger; // N NUMBER(5) Y CCTV 제어기 포트
  59. pObj->CCTV_CTLR_LOCAL_NO = pADO->FieldByName("CCTV_CTLR_LOCAL_NO")->AsInteger; // N NUMBER(5) Y CCTV 제어기 지역번호
  60. pObj->CCTV_TYPE_CD = pADO->FieldByName("CCTV_TYPE_CD")->AsString.Trim(); // N VARCHAR2(7) Y CCTV 유형
  61. pObj->ISTL_LCTN_NM = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim(); // N VARCHAR2(40) Y 설치 위치 명
  62. pObj->X_CRDN = pADO->FieldByName("X_CRDN")->AsFloat; // N NUMBER(11,8) Y X 좌표
  63. pObj->Y_CRDN = pADO->FieldByName("Y_CRDN")->AsFloat; // N NUMBER(10,8) Y Y 좌표
  64. pObj->DEL_YN = pADO->FieldByName("DEL_YN")->AsString.Trim(); // N CHAR(1) Y 'N' 삭제 여부
  65. pObj->CCTV_CAPT_IP = pADO->FieldByName("CCTV_CAPT_IP")->AsString.Trim(); // N VARCHAR2(20) Y CCTV 자막기 아이피
  66. pObj->CCTV_CAPT_PORT = pADO->FieldByName("CCTV_CAPT_PORT")->AsString.Trim(); // N VARCHAR2(5) Y CCTV 자막기 포트
  67. pObj->CCTV_FIBR_IP = pADO->FieldByName("CCTV_FIBR_IP")->AsString.Trim(); // N VARCHAR2(20) Y CCTV 광장비 아이피
  68. pObj->CCTV_ENCD_IP = pADO->FieldByName("CCTV_ENCD_IP")->AsString.Trim(); // N VARCHAR2(20) Y CCTV 인코더 아이피
  69. pObj->STRM_SVR_IP = pADO->FieldByName("STRM_SVR_IP")->AsString.Trim(); // N VARCHAR2(20) Y 스트리밍 서버 아이피
  70. pObj->STRM_SVR_PORT = pADO->FieldByName("STRM_SVR_PORT")->AsString.Trim(); // N VARCHAR2(5) Y 스트리밍 서버 포트
  71. pObj->STRM_SESN_NM = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim(); // N VARCHAR2(200) Y 스트리밍 세션 명
  72. pObj->STRM_STOR_ADDR = pADO->FieldByName("STRM_STOR_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 스트리밍 저장 주소
  73. pObj->STRM_RTSP_ADDR = pADO->FieldByName("STRM_RTSP_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 스트리밍 RTSP 주소
  74. pObj->STRM_RTMP_ADDR = pADO->FieldByName("STRM_RTMP_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 스트리밍 RTMP 주소
  75. pObj->STRM_HTTP_ADDR = pADO->FieldByName("STRM_HTTP_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 스트리밍 HTTP 주소
  76. pObj->INTR_RTSP_ADDR = pADO->FieldByName("INTR_RTSP_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 내부 RTSP 주소
  77. pObj->INTR_RTMP_ADDR = pADO->FieldByName("INTR_RTMP_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 내부 RTMP 주소
  78. pObj->INTR_HTTP_ADDR = pADO->FieldByName("INTR_HTTP_ADDR")->AsString.Trim(); // N VARCHAR2(200) Y 내부 HTTP 주소
  79. //pObj->CCTV_SBST_IMGN = pADO->FieldByName("CCTV_SBST_IMGN")->AsString.Trim(); // N BLOB Y CCTV 대체 영상
  80. pObj->CCTV_SBST_DSPL_YN = pADO->FieldByName("CCTV_SBST_DSPL_YN")->AsString.Trim(); // N CHAR(1) Y 'N' CCTV 대체 표출 여부
  81. pObj->SYOP_CNTL_YN = pADO->FieldByName("SYOP_CNTL_YN")->AsString.Trim(); // N CHAR(1) Y 'N' 운영자 제어 여부
  82. pObj->CCTV_IP = pADO->FieldByName("CCTV_IP")->AsString.Trim(); // N VARCHAR2(20) Y 목포 CCTV 제어 IP
  83. pObj->CCTV_PORT = pADO->FieldByName("CCTV_PORT")->AsInteger; // N NUMBER(5) Y 1852 목포 CCTV 제어 PORT
  84. pObj->CCTV_ID = pADO->FieldByName("CCTV_ID")->AsString.Trim(); // N VARCHAR2(20) Y 'root' 목포 CCTV 제어 ID
  85. pObj->CCTV_PSWD = pADO->FieldByName("CCTV_PSWD")->AsString.Trim(); // N VARCHAR2(20) Y '1234' 목포 CCTV 제어 PSWD
  86. pObj->CCTV_CHNL = pADO->FieldByName("CCTV_CHNL")->AsInteger; // N NUMBER(5) Y 1 목포 CCTV 제어 CHANNEL
  87. pObj->STATE.Comm = cctv_error;
  88. FLists.Push(pObj->CCTV_CTLR_NMBR, pObj);
  89. pObj->Completed = true;
  90. }
  91. }
  92. catch(EDatabaseError &E)
  93. {
  94. DBERRORMSG("TCctvCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
  95. throw Exception(String(E.ClassName()) + E.Message);
  96. }
  97. catch(Exception &e)
  98. {
  99. DBERRORMSG("TCctvCtlrManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
  100. throw Exception(String(e.ClassName()) + e.Message);
  101. }
  102. }
  103. __finally
  104. {
  105. if (pADO)
  106. {
  107. pADO->Close();
  108. delete pADO;
  109. }
  110. FLists.UnLock();
  111. }
  112. return true;
  113. }
  114. //---------------------------------------------------------------------------
  115. bool TCctvCtlrManager::LoadStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
  116. {
  117. String sQry;
  118. TADOQuery *pADO = NULL;
  119. sQry = "SELECT * \r\n"
  120. " FROM TB_CCTV_CTLR_STTS A, \r\n"
  121. " TB_CCTV_CTLR B \r\n"
  122. " WHERE A.CCTV_CTLR_NMBR = B.CCTV_CTLR_NMBR \r\n"
  123. " AND A.UPDT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";
  124. FLists.Lock();
  125. try
  126. {
  127. TCctvCtlr *pObj = NULL;
  128. try
  129. {
  130. int nORD;
  131. pADO = new TADOQuery(NULL);
  132. pADO->Close();
  133. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  134. pADO->SQL->Clear();
  135. pADO->SQL->Text = sQry;
  136. pADO->Prepared = true;
  137. pADO->Open();
  138. for( ; !pADO->Eof; pADO->Next())
  139. {
  140. String CCTV_CTLR_NMBR = pADO->FieldByName("CCTV_CTLR_NMBR")->AsString;
  141. pObj = FLists.Find(CCTV_CTLR_NMBR);
  142. if (!pObj) continue;
  143. String UPDT_DT = pADO->FieldByName("UPDT_DT")->AsString;
  144. String CONN_STTS_CD = pADO->FieldByName("CONN_STTS_CD")->AsString;
  145. if (CONN_STTS_CD != "CMS0")
  146. {
  147. //통신장애
  148. continue;
  149. }
  150. pObj->STATE.Comm = (CONN_STTS_CD == "CMS0") ? cctv_normal : cctv_error;
  151. }
  152. }
  153. catch(EDatabaseError &E)
  154. {
  155. DBERRORLOG("TCctvCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
  156. throw Exception(String(E.ClassName()) + E.Message);
  157. }
  158. catch(Exception &e)
  159. {
  160. DBERRORLOG("TCctvCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
  161. throw Exception(String(e.ClassName()) + e.Message);
  162. }
  163. }
  164. __finally
  165. {
  166. FLists.UnLock();
  167. if (pADO)
  168. {
  169. pADO->Close();
  170. delete pADO;
  171. }
  172. }
  173. return true;
  174. }
  175. //---------------------------------------------------------------------------
  176. bool TCctvCtlrManager::DeleteCctv(TCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  177. {
  178. String sQry;
  179. TADOQuery *pADO = NULL;
  180. sQry = "UPDATE TB_CCTV_CTLR \r\n"
  181. " SET DEL_YN = 'Y' \r\n"
  182. " WHERE CCTV_CTLR_NMBR = :p01 \r\n";
  183. try
  184. {
  185. try
  186. {
  187. pADO = new TADOQuery(NULL);
  188. pADO->Close();
  189. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  190. pADO->SQL->Clear();
  191. pADO->SQL->Text = sQry;
  192. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_NMBR;
  193. pADO->ExecSQL();
  194. sQry = "DELETE TB_FCLT_INFR \r\n"
  195. " WHERE FCLT_ID = :p01 \r\n";
  196. pADO->SQL->Clear();
  197. pADO->SQL->Text = sQry;
  198. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_ID;
  199. pADO->ExecSQL();
  200. return true;
  201. }
  202. catch(EDatabaseError &E)
  203. {
  204. DBERRORLOG("TCctvCtlrManager::DeleteCctv", String(E.ClassName()), E.Message, sQry);
  205. throw Exception(String(E.ClassName()) + E.Message);
  206. }
  207. catch(Exception &e)
  208. {
  209. DBERRORLOG("TCctvCtlrManager::DeleteCctv", String(e.ClassName()), e.Message, sQry);
  210. throw Exception(String(e.ClassName()) + e.Message);
  211. }
  212. }
  213. __finally
  214. {
  215. if (pADO)
  216. {
  217. pADO->Close();
  218. delete pADO;
  219. }
  220. }
  221. return true;
  222. }
  223. //---------------------------------------------------------------------------
  224. bool TCctvCtlrManager::InsertCctv(TCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  225. {
  226. String sQry;
  227. TADOQuery *pADO = NULL;
  228. sQry = "MERGE INTO TB_CCTV_CTLR L \r\n"
  229. "USING (SELECT \r\n"
  230. " :p01 AS CCTV_CTLR_NMBR, \r\n"
  231. " :p02 AS CCTV_CTLR_ID, \r\n"
  232. " :p03 AS CCTV_NM, \r\n"
  233. " :p04 AS CCTV_CTLR_IP, \r\n"
  234. " :p05 AS CCTV_CTLR_PORT, \r\n"
  235. " :p06 AS CCTV_CTLR_LOCAL_NO, \r\n"
  236. " :p07 AS CCTV_TYPE_CD, \r\n"
  237. " :p08 AS ISTL_LCTN_NM, \r\n"
  238. " :p09 AS X_CRDN, \r\n"
  239. " :p10 AS Y_CRDN, \r\n"
  240. " :p11 AS DEL_YN, \r\n"
  241. " :p12 AS STRM_SVR_IP, \r\n"
  242. " :p13 AS STRM_SESN_NM, \r\n"
  243. " :p14 AS STRM_RTSP_ADDR, \r\n"
  244. " :p15 AS STRM_RTMP_ADDR, \r\n"
  245. " :p16 AS STRM_HTTP_ADDR, \r\n"
  246. " :p17 AS CCTV_IP, \r\n"
  247. " :p18 AS CCTV_PORT, \r\n"
  248. " :p19 AS CCTV_ID, \r\n"
  249. " :p20 AS CCTV_PSWD, \r\n"
  250. " :p21 AS CCTV_CHNL \r\n"
  251. " FROM DUAL) M \r\n"
  252. " ON (L.CCTV_CTLR_NMBR = M.CCTV_CTLR_NMBR) \r\n"
  253. "WHEN MATCHED THEN \r\n"
  254. " UPDATE SET L.CCTV_CTLR_ID = M.CCTV_CTLR_ID, \r\n"
  255. " L.CCTV_NM = M.CCTV_NM, \r\n"
  256. " L.CCTV_CTLR_IP = M.CCTV_CTLR_IP, \r\n"
  257. " L.CCTV_CTLR_PORT = M.CCTV_CTLR_PORT, \r\n"
  258. " L.CCTV_CTLR_LOCAL_NO = M.CCTV_CTLR_LOCAL_NO, \r\n"
  259. " L.CCTV_TYPE_CD = M.CCTV_TYPE_CD, \r\n"
  260. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  261. " L.X_CRDN = M.X_CRDN, \r\n"
  262. " L.Y_CRDN = M.Y_CRDN, \r\n"
  263. " L.DEL_YN = M.DEL_YN, \r\n"
  264. " L.STRM_SVR_IP = M.STRM_SVR_IP, \r\n"
  265. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  266. " L.STRM_RTSP_ADDR = M.STRM_RTSP_ADDR, \r\n"
  267. " L.STRM_RTMP_ADDR = M.STRM_RTMP_ADDR, \r\n"
  268. " L.STRM_HTTP_ADDR = M.STRM_HTTP_ADDR, \r\n"
  269. " L.CCTV_IP = M.CCTV_IP, \r\n"
  270. " L.CCTV_PORT = M.CCTV_PORT, \r\n"
  271. " L.CCTV_ID = M.CCTV_ID, \r\n"
  272. " L.CCTV_PSWD = M.CCTV_PSWD, \r\n"
  273. " L.CCTV_CHNL = M.CCTV_CHNL \r\n"
  274. "WHEN NOT MATCHED THEN \r\n"
  275. " INSERT ( \r\n"
  276. " CCTV_CTLR_NMBR, \r\n"
  277. " CCTV_CTLR_ID, \r\n"
  278. " CCTV_NM, \r\n"
  279. " CCTV_CTLR_IP, \r\n"
  280. " CCTV_CTLR_PORT, \r\n"
  281. " CCTV_CTLR_LOCAL_NO, \r\n"
  282. " CCTV_TYPE_CD, \r\n"
  283. " ISTL_LCTN_NM, \r\n"
  284. " X_CRDN, \r\n"
  285. " Y_CRDN, \r\n"
  286. " DEL_YN, \r\n"
  287. " STRM_SVR_IP, \r\n"
  288. " STRM_SESN_NM , \r\n"
  289. " STRM_RTSP_ADDR, \r\n"
  290. " STRM_RTMP_ADDR, \r\n"
  291. " STRM_HTTP_ADDR, \r\n"
  292. " CCTV_IP, \r\n"
  293. " CCTV_PORT, \r\n"
  294. " CCTV_ID, \r\n"
  295. " CCTV_PSWD, \r\n"
  296. " CCTV_CHNL \r\n"
  297. " ) \r\n"
  298. " VALUES ( \r\n"
  299. " M.CCTV_CTLR_NMBR, \r\n"
  300. " M.CCTV_CTLR_ID, \r\n"
  301. " M.CCTV_NM, \r\n"
  302. " M.CCTV_CTLR_IP, \r\n"
  303. " M.CCTV_CTLR_PORT, \r\n"
  304. " M.CCTV_CTLR_LOCAL_NO, \r\n"
  305. " M.CCTV_TYPE_CD, \r\n"
  306. " M.ISTL_LCTN_NM, \r\n"
  307. " M.X_CRDN, \r\n"
  308. " M.Y_CRDN, \r\n"
  309. " M.DEL_YN, \r\n"
  310. " M.STRM_SVR_IP, \r\n"
  311. " M.STRM_SESN_NM , \r\n"
  312. " M.STRM_RTSP_ADDR, \r\n"
  313. " M.STRM_RTMP_ADDR, \r\n"
  314. " M.STRM_HTTP_ADDR, \r\n"
  315. " M.CCTV_IP, \r\n"
  316. " M.CCTV_PORT, \r\n"
  317. " M.CCTV_ID, \r\n"
  318. " M.CCTV_PSWD, \r\n"
  319. " M.CCTV_CHNL \r\n"
  320. " ) \r\n";
  321. try
  322. {
  323. try
  324. {
  325. pADO = new TADOQuery(NULL);
  326. pADO->Close();
  327. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  328. pADO->SQL->Clear();
  329. pADO->SQL->Text = sQry;
  330. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_NMBR;
  331. pADO->Parameters->ParamByName("p02")->Value = AObj->CCTV_CTLR_ID;
  332. pADO->Parameters->ParamByName("p03")->Value = AObj->CCTV_NM;
  333. pADO->Parameters->ParamByName("p04")->Value = AObj->CCTV_CTLR_IP;
  334. pADO->Parameters->ParamByName("p05")->Value = AObj->CCTV_CTLR_PORT;
  335. pADO->Parameters->ParamByName("p06")->Value = AObj->CCTV_CTLR_LOCAL_NO;
  336. pADO->Parameters->ParamByName("p07")->Value = AObj->CCTV_TYPE_CD;
  337. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  338. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  339. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  340. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  341. pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
  342. pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SESN_NM;
  343. pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_RTSP_ADDR;
  344. pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTMP_ADDR;
  345. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_HTTP_ADDR;
  346. pADO->Parameters->ParamByName("p17")->Value = AObj->CCTV_IP;
  347. pADO->Parameters->ParamByName("p18")->Value = AObj->CCTV_PORT;
  348. pADO->Parameters->ParamByName("p19")->Value = AObj->CCTV_ID;
  349. pADO->Parameters->ParamByName("p20")->Value = AObj->CCTV_PSWD;
  350. pADO->Parameters->ParamByName("p21")->Value = AObj->CCTV_CHNL;
  351. pADO->ExecSQL();
  352. return MergeFcltInfo(AObj, ADbConn);
  353. }
  354. catch(EDatabaseError &E)
  355. {
  356. DBERRORLOG("TCctvCtlrManager::InsertCctv", String(E.ClassName()), E.Message, sQry);
  357. throw Exception(String(E.ClassName()) + E.Message);
  358. }
  359. catch(Exception &e)
  360. {
  361. DBERRORLOG("TCctvCtlrManager::InsertCctv", String(e.ClassName()), e.Message, sQry);
  362. throw Exception(String(e.ClassName()) + e.Message);
  363. }
  364. }
  365. __finally
  366. {
  367. if (pADO)
  368. {
  369. pADO->Close();
  370. delete pADO;
  371. }
  372. }
  373. return true;
  374. }
  375. //---------------------------------------------------------------------------
  376. bool TCctvCtlrManager::UpdateCctv(TCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  377. {
  378. return MergeCctv(AObj, ADbConn);
  379. }
  380. //---------------------------------------------------------------------------
  381. bool TCctvCtlrManager::MergeCctv(TCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  382. {
  383. String sQry;
  384. TADOQuery *pADO = NULL;
  385. sQry = "MERGE INTO TB_CCTV_CTLR L \r\n"
  386. "USING (SELECT \r\n"
  387. " :p01 AS CCTV_CTLR_NMBR, \r\n"
  388. " :p02 AS CCTV_CTLR_ID, \r\n"
  389. " :p03 AS CCTV_NM, \r\n"
  390. " :p04 AS CCTV_CTLR_IP, \r\n"
  391. " :p05 AS CCTV_CTLR_PORT, \r\n"
  392. " :p06 AS CCTV_CTLR_LOCAL_NO, \r\n"
  393. " :p07 AS CCTV_TYPE_CD, \r\n"
  394. " :p08 AS ISTL_LCTN_NM, \r\n"
  395. " :p09 AS X_CRDN, \r\n"
  396. " :p10 AS Y_CRDN, \r\n"
  397. " :p11 AS DEL_YN, \r\n"
  398. " :p12 AS STRM_SVR_IP, \r\n"
  399. " :p13 AS STRM_SESN_NM, \r\n"
  400. " :p14 AS STRM_RTSP_ADDR, \r\n"
  401. " :p15 AS STRM_RTMP_ADDR, \r\n"
  402. " :p16 AS STRM_HTTP_ADDR, \r\n"
  403. " :p17 AS CCTV_IP, \r\n"
  404. " :p18 AS CCTV_PORT, \r\n"
  405. " :p19 AS CCTV_ID, \r\n"
  406. " :p20 AS CCTV_PSWD, \r\n"
  407. " :p21 AS CCTV_CHNL \r\n"
  408. " FROM DUAL) M \r\n"
  409. " ON (L.CCTV_CTLR_NMBR = M.CCTV_CTLR_NMBR) \r\n"
  410. "WHEN MATCHED THEN \r\n"
  411. " UPDATE SET L.CCTV_CTLR_ID = M.CCTV_CTLR_ID, \r\n"
  412. " L.CCTV_NM = M.CCTV_NM, \r\n"
  413. " L.CCTV_CTLR_IP = M.CCTV_CTLR_IP, \r\n"
  414. " L.CCTV_CTLR_PORT = M.CCTV_CTLR_PORT, \r\n"
  415. " L.CCTV_CTLR_LOCAL_NO = M.CCTV_CTLR_LOCAL_NO, \r\n"
  416. " L.CCTV_TYPE_CD = M.CCTV_TYPE_CD, \r\n"
  417. " L.ISTL_LCTN_NM = M.ISTL_LCTN_NM, \r\n"
  418. " L.X_CRDN = M.X_CRDN, \r\n"
  419. " L.Y_CRDN = M.Y_CRDN, \r\n"
  420. " L.DEL_YN = M.DEL_YN, \r\n"
  421. " L.STRM_SVR_IP = M.STRM_SVR_IP, \r\n"
  422. " L.STRM_SESN_NM = M.STRM_SESN_NM, \r\n"
  423. " L.STRM_RTSP_ADDR = M.STRM_RTSP_ADDR, \r\n"
  424. " L.STRM_RTMP_ADDR = M.STRM_RTMP_ADDR, \r\n"
  425. " L.STRM_HTTP_ADDR = M.STRM_HTTP_ADDR, \r\n"
  426. " L.CCTV_IP = M.CCTV_IP, \r\n"
  427. " L.CCTV_PORT = M.CCTV_PORT, \r\n"
  428. " L.CCTV_ID = M.CCTV_ID, \r\n"
  429. " L.CCTV_PSWD = M.CCTV_PSWD, \r\n"
  430. " L.CCTV_CHNL = M.CCTV_CHNL \r\n"
  431. "WHEN NOT MATCHED THEN \r\n"
  432. " INSERT ( \r\n"
  433. " CCTV_CTLR_NMBR, \r\n"
  434. " CCTV_CTLR_ID, \r\n"
  435. " CCTV_NM, \r\n"
  436. " CCTV_CTLR_IP, \r\n"
  437. " CCTV_CTLR_PORT, \r\n"
  438. " CCTV_CTLR_LOCAL_NO, \r\n"
  439. " CCTV_TYPE_CD, \r\n"
  440. " ISTL_LCTN_NM, \r\n"
  441. " X_CRDN, \r\n"
  442. " Y_CRDN, \r\n"
  443. " DEL_YN, \r\n"
  444. " STRM_SVR_IP, \r\n"
  445. " STRM_SESN_NM , \r\n"
  446. " STRM_RTSP_ADDR, \r\n"
  447. " STRM_RTMP_ADDR, \r\n"
  448. " STRM_HTTP_ADDR, \r\n"
  449. " CCTV_IP, \r\n"
  450. " CCTV_PORT, \r\n"
  451. " CCTV_ID, \r\n"
  452. " CCTV_PSWD, \r\n"
  453. " CCTV_CHNL \r\n"
  454. " ) \r\n"
  455. " VALUES ( \r\n"
  456. " M.CCTV_CTLR_NMBR, \r\n"
  457. " M.CCTV_CTLR_ID, \r\n"
  458. " M.CCTV_NM, \r\n"
  459. " M.CCTV_CTLR_IP, \r\n"
  460. " M.CCTV_CTLR_PORT, \r\n"
  461. " M.CCTV_CTLR_LOCAL_NO, \r\n"
  462. " M.CCTV_TYPE_CD, \r\n"
  463. " M.ISTL_LCTN_NM, \r\n"
  464. " M.X_CRDN, \r\n"
  465. " M.Y_CRDN, \r\n"
  466. " M.DEL_YN, \r\n"
  467. " M.STRM_SVR_IP, \r\n"
  468. " M.STRM_SESN_NM , \r\n"
  469. " M.STRM_RTSP_ADDR, \r\n"
  470. " M.STRM_RTMP_ADDR, \r\n"
  471. " M.STRM_HTTP_ADDR, \r\n"
  472. " M.CCTV_IP, \r\n"
  473. " M.CCTV_PORT, \r\n"
  474. " M.CCTV_ID, \r\n"
  475. " M.CCTV_PSWD, \r\n"
  476. " M.CCTV_CHNL \r\n"
  477. " ) \r\n";
  478. try
  479. {
  480. try
  481. {
  482. pADO = new TADOQuery(NULL);
  483. pADO->Close();
  484. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  485. pADO->SQL->Clear();
  486. pADO->SQL->Text = sQry;
  487. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_NMBR;
  488. pADO->Parameters->ParamByName("p02")->Value = AObj->CCTV_CTLR_ID;
  489. pADO->Parameters->ParamByName("p03")->Value = AObj->CCTV_NM;
  490. pADO->Parameters->ParamByName("p04")->Value = AObj->CCTV_CTLR_IP;
  491. pADO->Parameters->ParamByName("p05")->Value = AObj->CCTV_CTLR_PORT;
  492. pADO->Parameters->ParamByName("p06")->Value = AObj->CCTV_CTLR_LOCAL_NO;
  493. pADO->Parameters->ParamByName("p07")->Value = AObj->CCTV_TYPE_CD;
  494. pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
  495. pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
  496. pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
  497. pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
  498. pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
  499. pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SESN_NM;
  500. pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_RTSP_ADDR;
  501. pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTMP_ADDR;
  502. pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_HTTP_ADDR;
  503. pADO->Parameters->ParamByName("p17")->Value = AObj->CCTV_IP;
  504. pADO->Parameters->ParamByName("p18")->Value = AObj->CCTV_PORT;
  505. pADO->Parameters->ParamByName("p19")->Value = AObj->CCTV_ID;
  506. pADO->Parameters->ParamByName("p20")->Value = AObj->CCTV_PSWD;
  507. pADO->Parameters->ParamByName("p21")->Value = AObj->CCTV_CHNL;
  508. pADO->ExecSQL();
  509. return MergeFcltInfo(AObj, ADbConn);
  510. }
  511. catch(EDatabaseError &E)
  512. {
  513. DBERRORLOG("TCctvCtlrManager::MergeCctv", String(E.ClassName()), E.Message, sQry);
  514. throw Exception(String(E.ClassName()) + E.Message);
  515. }
  516. catch(Exception &e)
  517. {
  518. DBERRORLOG("TCctvCtlrManager::MergeCctv", String(e.ClassName()), e.Message, sQry);
  519. throw Exception(String(e.ClassName()) + e.Message);
  520. }
  521. }
  522. __finally
  523. {
  524. if (pADO)
  525. {
  526. pADO->Close();
  527. delete pADO;
  528. }
  529. }
  530. return true;
  531. }
  532. //---------------------------------------------------------------------------
  533. bool TCctvCtlrManager::MergeFcltInfo(TCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  534. {
  535. String sQry;
  536. TADOQuery *pADO = NULL;
  537. sQry = "MERGE INTO TB_FCLT_INFR L \r\n"
  538. "USING (SELECT :p01 AS FCLT_ID, \r\n"
  539. " :p02 AS FCLT_TYPE, \r\n"
  540. " :p03 AS FCLT_LCTN \r\n"
  541. " FROM DUAL) M \r\n"
  542. " ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE) \r\n"
  543. "WHEN MATCHED \r\n"
  544. "THEN \r\n"
  545. " UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN, \r\n"
  546. " L.DEL_YN = 'N' \r\n"
  547. "WHEN NOT MATCHED \r\n"
  548. "THEN \r\n"
  549. " INSERT ( FCLT_ID, FCLT_TYPE, FCLT_LCTN) \r\n"
  550. " VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN) \r\n";
  551. try
  552. {
  553. try
  554. {
  555. pADO = new TADOQuery(NULL);
  556. pADO->Close();
  557. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  558. pADO->SQL->Clear();
  559. pADO->SQL->Text = sQry;
  560. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_ID;
  561. pADO->Parameters->ParamByName("p02")->Value = "CCTV";
  562. pADO->Parameters->ParamByName("p03")->Value = AObj->CCTV_NM;
  563. pADO->ExecSQL();
  564. return true;
  565. }
  566. catch(EDatabaseError &E)
  567. {
  568. DBERRORLOG("TCctvCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
  569. throw Exception(String(E.ClassName()) + E.Message);
  570. }
  571. catch(Exception &e)
  572. {
  573. DBERRORLOG("TCctvCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
  574. throw Exception(String(e.ClassName()) + e.Message);
  575. }
  576. }
  577. __finally
  578. {
  579. if (pADO)
  580. {
  581. pADO->Close();
  582. delete pADO;
  583. }
  584. }
  585. return true;
  586. }
  587. //---------------------------------------------------------------------------
  588. bool TCctvCtlrManager::GetNextCctvId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
  589. {
  590. String sQry;
  591. TADOQuery *pADO = NULL;
  592. sQry = "SELECT NVL(MAX(CCTV_CTLR_NMBR), 10000) + 1 AS NEWID FROM TB_CCTV_CTLR \r\n";
  593. try
  594. {
  595. try
  596. {
  597. pADO = new TADOQuery(NULL);
  598. pADO->Close();
  599. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  600. pADO->SQL->Clear();
  601. pADO->SQL->Text = sQry;
  602. pADO->Prepared = true;
  603. pADO->Open();
  604. ANmbr = pADO->FieldByName("NEWID")->AsInteger;
  605. AId = ANmbr / 10000;
  606. return true;
  607. }
  608. catch(EDatabaseError &E)
  609. {
  610. DBERRORLOG("TCctvCtlrManager::GetNextCctvId", String(E.ClassName()), E.Message, sQry);
  611. throw Exception(String(E.ClassName()) + E.Message);
  612. }
  613. catch(Exception &e)
  614. {
  615. DBERRORLOG("TCctvCtlrManager::GetNextCctvId", String(e.ClassName()), e.Message, sQry);
  616. throw Exception(String(e.ClassName()) + e.Message);
  617. }
  618. }
  619. __finally
  620. {
  621. if (pADO)
  622. {
  623. pADO->Close();
  624. delete pADO;
  625. }
  626. }
  627. return false;
  628. }
  629. //---------------------------------------------------------------------------
  630. bool TCctvCtlrManager::LoadPreSet(TADOConnection *ADbConn/*=NULL*/)
  631. {
  632. String sQry;
  633. TADOQuery *pADO = NULL;
  634. FLists.Lock();
  635. try
  636. {
  637. FOR_STL(TCctvCtlr*, pObj, FLists)
  638. {
  639. pObj->FLists.RemoveAll();
  640. }
  641. }
  642. __finally
  643. {
  644. FLists.UnLock();
  645. }
  646. sQry = "SELECT B.* \r\n"
  647. " FROM TB_CCTV_CTLR A, \r\n"
  648. " TB_CCTV_PSET B \r\n"
  649. " WHERE A.CCTV_CTLR_NMBR = B.CCTV_CTLR_NMBR \r\n"
  650. " ORDER BY B.CCTV_CTLR_NMBR, B.PSET_NMBR \r\n";
  651. try
  652. {
  653. String CCTV_CTLR_NMBR;
  654. FLists.Lock();
  655. try
  656. {
  657. pADO = new TADOQuery(NULL);
  658. pADO->Close();
  659. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  660. pADO->SQL->Clear();
  661. pADO->SQL->Text = sQry;
  662. pADO->Prepared = true;
  663. pADO->Open();
  664. for( ; !pADO->Eof; pADO->Next())
  665. {
  666. CCTV_CTLR_NMBR = pADO->FieldByName("CCTV_CTLR_NMBR")->AsString;
  667. TCctvCtlr *pCctv = FLists.Find(String(CCTV_CTLR_NMBR));
  668. if (!pCctv) continue;
  669. TCctvPset *pObj = new TCctvPset();
  670. if (pObj)
  671. {
  672. pObj->CCTV_CTLR_NMBR = CCTV_CTLR_NMBR;
  673. pObj->PSET_NMBR = pADO->FieldByName("PSET_NMBR")->AsInteger;
  674. pObj->PSET_NM = pADO->FieldByName("PSET_NM")->AsString;
  675. pObj->PAN = pADO->FieldByName("PAN")->AsInteger;
  676. pObj->TILT = pADO->FieldByName("TILT")->AsInteger;
  677. pObj->ZOOM = pADO->FieldByName("ZOOM")->AsInteger;
  678. pObj->FOCS = pADO->FieldByName("FOCS")->AsInteger;
  679. pObj->ANGLE = pADO->FieldByName("ANGLE")->AsInteger;
  680. pObj->DFLT_YN = pADO->FieldByName("DFLT_YN")->AsString;
  681. pObj->DEL_YN = "N";
  682. pCctv->FLists.Push(pObj->PSET_NMBR, pObj);
  683. }
  684. }
  685. }
  686. catch(EDatabaseError &E)
  687. {
  688. DBERRORMSG("TCctvCtlrManager::LoadPreSet", String(E.ClassName()), E.Message, sQry);
  689. throw Exception(String(E.ClassName()) + E.Message);
  690. }
  691. catch(Exception &e)
  692. {
  693. DBERRORMSG("TCctvCtlrManager::LoadPreSet", String(e.ClassName()), e.Message, sQry);
  694. throw Exception(String(e.ClassName()) + e.Message);
  695. }
  696. }
  697. __finally
  698. {
  699. if (pADO)
  700. {
  701. pADO->Close();
  702. delete pADO;
  703. }
  704. FLists.UnLock();
  705. }
  706. return true;
  707. }
  708. //---------------------------------------------------------------------------
  709. bool TCctvCtlrManager::SavePreSet(TCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
  710. {
  711. String sQry;
  712. TADOQuery *pADO = NULL;
  713. try
  714. {
  715. try
  716. {
  717. pADO = new TADOQuery(NULL);
  718. pADO->Close();
  719. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  720. sQry = "DELETE FROM TB_CCTV_PSET WHERE CCTV_CTLR_NMBR = :p01";
  721. pADO->SQL->Clear();
  722. pADO->SQL->Text = sQry;
  723. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_NMBR;
  724. pADO->ExecSQL();
  725. sQry = "INSERT INTO TB_CCTV_PSET( \r\n"
  726. " CCTV_CTLR_NMBR, \r\n"
  727. " PSET_NMBR, \r\n"
  728. " PSET_NM, \r\n"
  729. " PAN, \r\n"
  730. " TILT, \r\n"
  731. " ZOOM, \r\n"
  732. " FOCS, \r\n"
  733. " DFLT_YN ) \r\n"
  734. " VALUES(:p01, :p02, :p03, :p04, :p05, :p06, :p07, :p08) \r\n";
  735. pADO->SQL->Clear();
  736. pADO->SQL->Text = sQry;
  737. FOR_STL(TCctvPset *, pObj, AObj->FLists)
  738. {
  739. if (pObj->DEL_YN != "N") continue;
  740. pADO->Parameters->ParamByName("p01")->Value = pObj->CCTV_CTLR_NMBR;
  741. pADO->Parameters->ParamByName("p02")->Value = pObj->PSET_NMBR;
  742. pADO->Parameters->ParamByName("p03")->Value = pObj->PSET_NM;
  743. pADO->Parameters->ParamByName("p04")->Value = pObj->PAN;
  744. pADO->Parameters->ParamByName("p05")->Value = pObj->TILT;
  745. pADO->Parameters->ParamByName("p06")->Value = pObj->ZOOM;
  746. pADO->Parameters->ParamByName("p07")->Value = pObj->FOCS;
  747. pADO->Parameters->ParamByName("p08")->Value = pObj->DFLT_YN;
  748. pADO->ExecSQL();
  749. }
  750. return true;
  751. }
  752. catch(EDatabaseError &E)
  753. {
  754. DBERRORLOG("TCctvCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  755. throw Exception(String(E.ClassName()) + E.Message);
  756. }
  757. catch(Exception &e)
  758. {
  759. DBERRORLOG("TCctvCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  760. throw Exception(String(e.ClassName()) + e.Message);
  761. }
  762. }
  763. __finally
  764. {
  765. if (pADO)
  766. {
  767. pADO->Close();
  768. delete pADO;
  769. }
  770. }
  771. return true;
  772. }
  773. //---------------------------------------------------------------------------
  774. bool TCctvCtlrManager::DeletePreSet(TCctvCtlr *AObj, int APsetNmbr, TADOConnection *ADbConn/*=NULL*/)
  775. {
  776. String sQry;
  777. TADOQuery *pADO = NULL;
  778. TCctvPset* pObj = AObj->FLists.Find(APsetNmbr);
  779. if (!pObj) return false;
  780. sQry = "DELETE FROM TB_CCTV_PSET WHERE CCTV_CTLR_NMBR = :p01 AND PSET_NMBR = :p02";
  781. try
  782. {
  783. try
  784. {
  785. pADO = new TADOQuery(NULL);
  786. pADO->Close();
  787. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  788. pADO->SQL->Clear();
  789. pADO->SQL->Text = sQry;
  790. pADO->Parameters->ParamByName("p01")->Value = AObj->CCTV_CTLR_NMBR;
  791. pADO->Parameters->ParamByName("p02")->Value = APsetNmbr;
  792. pADO->ExecSQL();
  793. pObj->DEL_YN = "Y";
  794. return true;
  795. }
  796. catch(EDatabaseError &E)
  797. {
  798. DBERRORLOG("TCctvCtlrManager::DeletePreSet", String(E.ClassName()), E.Message, sQry);
  799. throw Exception(String(E.ClassName()) + E.Message);
  800. }
  801. catch(Exception &e)
  802. {
  803. DBERRORLOG("TCctvCtlrManager::DeletePreSet", String(e.ClassName()), e.Message, sQry);
  804. throw Exception(String(e.ClassName()) + e.Message);
  805. }
  806. }
  807. __finally
  808. {
  809. if (pADO)
  810. {
  811. pADO->Close();
  812. delete pADO;
  813. }
  814. }
  815. return true;
  816. }
  817. //---------------------------------------------------------------------------
  818. bool TCctvCtlrManager::MergePreSet(TCctvCtlr *AObj, TCctvPset* APset, TADOConnection *ADbConn/*=NULL*/)
  819. {
  820. String sQry;
  821. TADOQuery *pADO = NULL;
  822. try
  823. {
  824. try
  825. {
  826. pADO = new TADOQuery(NULL);
  827. pADO->Close();
  828. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  829. sQry = "MERGE INTO TB_CCTV_PSET L \r\n"
  830. "USING (SELECT \r\n"
  831. " :p01 AS CCTV_CTLR_NMBR, \r\n"
  832. " :p02 AS PSET_NMBR, \r\n"
  833. " :p03 AS PSET_NM, \r\n"
  834. " :p04 AS PAN, \r\n"
  835. " :p05 AS TILT, \r\n"
  836. " :p06 AS ZOOM, \r\n"
  837. " :p07 AS FOCS, \r\n"
  838. " :p08 AS DFLT_YN \r\n"
  839. " FROM DUAL) M \r\n"
  840. " ON (L.CCTV_CTLR_NMBR = M.CCTV_CTLR_NMBR \r\n"
  841. " AND L.PSET_NMBR = M.PSET_NMBR ) \r\n"
  842. "WHEN MATCHED THEN \r\n"
  843. " UPDATE SET L.PSET_NM = M.PSET_NM, \r\n"
  844. " L.PAN = M.PAN, \r\n"
  845. " L.TILT = M.TILT, \r\n"
  846. " L.ZOOM = M.ZOOM, \r\n"
  847. " L.FOCS = M.FOCS, \r\n"
  848. " L.DFLT_YN = M.DFLT_YN \r\n"
  849. "WHEN NOT MATCHED THEN \r\n"
  850. " INSERT ( \r\n"
  851. " CCTV_CTLR_NMBR, \r\n"
  852. " PSET_NMBR, \r\n"
  853. " PSET_NM, \r\n"
  854. " PAN, \r\n"
  855. " TILT, \r\n"
  856. " ZOOM, \r\n"
  857. " FOCS, \r\n"
  858. " DFLT_YN ) \r\n"
  859. " VALUES ( \r\n"
  860. " M.CCTV_CTLR_NMBR, \r\n"
  861. " M.PSET_NMBR, \r\n"
  862. " M.PSET_NM, \r\n"
  863. " M.PAN, \r\n"
  864. " M.TILT, \r\n"
  865. " M.ZOOM, \r\n"
  866. " M.FOCS, \r\n"
  867. " M.DFLT_YN ) \r\n";
  868. pADO->SQL->Clear();
  869. pADO->SQL->Text = sQry;
  870. FOR_STL(TCctvPset *, pObj, AObj->FLists)
  871. {
  872. if (pObj->DEL_YN != "N") continue;
  873. pADO->Parameters->ParamByName("p01")->Value = APset->CCTV_CTLR_NMBR;
  874. pADO->Parameters->ParamByName("p02")->Value = APset->PSET_NMBR;
  875. pADO->Parameters->ParamByName("p03")->Value = APset->PSET_NM;
  876. pADO->Parameters->ParamByName("p04")->Value = APset->PAN;
  877. pADO->Parameters->ParamByName("p05")->Value = APset->TILT;
  878. pADO->Parameters->ParamByName("p06")->Value = APset->ZOOM;
  879. pADO->Parameters->ParamByName("p07")->Value = APset->FOCS;
  880. pADO->Parameters->ParamByName("p08")->Value = APset->DFLT_YN;
  881. pADO->ExecSQL();
  882. TCctvPset* pObj = AObj->FLists.Find(APset->PSET_NMBR);
  883. if (pObj)
  884. {
  885. pObj->CCTV_CTLR_NMBR = APset->CCTV_CTLR_NMBR;
  886. pObj->PSET_NMBR = APset->PSET_NMBR;
  887. pObj->PSET_NM = APset->PSET_NM;
  888. pObj->PAN = APset->PAN;
  889. pObj->TILT = APset->TILT;
  890. pObj->ZOOM = APset->ZOOM;
  891. pObj->FOCS = APset->FOCS;
  892. pObj->DFLT_YN = APset->DFLT_YN;
  893. }
  894. else
  895. {
  896. AObj->FLists.Push(APset->PSET_NMBR, APset);
  897. }
  898. }
  899. return true;
  900. }
  901. catch(EDatabaseError &E)
  902. {
  903. DBERRORLOG("TCctvCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
  904. throw Exception(String(E.ClassName()) + E.Message);
  905. }
  906. catch(Exception &e)
  907. {
  908. DBERRORLOG("TCctvCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
  909. throw Exception(String(e.ClassName()) + e.Message);
  910. }
  911. }
  912. __finally
  913. {
  914. if (pADO)
  915. {
  916. pADO->Close();
  917. delete pADO;
  918. }
  919. }
  920. return true;
  921. }
  922. //---------------------------------------------------------------------------
  923. bool TCctvCtlrManager::InsCctvControlHs(String ACtlDt, String ACctvNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
  924. {
  925. String sQry;
  926. TADOQuery *pADO = NULL;
  927. sQry = "INSERT INTO TB_CCTV_CTRL_HS( \r\n"
  928. " CTRL_DT, \r\n"
  929. " CCTV_CTLR_NMBR, \r\n"
  930. " CTRL_TYPE, \r\n"
  931. " CTRL_VAL, \r\n"
  932. " CTRL_RESULT, \r\n"
  933. " USER_ID \r\n"
  934. " ) \r\n"
  935. " VALUES( \r\n"
  936. " :p01, \r\n"
  937. " :p02, \r\n"
  938. " :p03, \r\n"
  939. " :p04, \r\n"
  940. " :p05, \r\n"
  941. " :p06 \r\n"
  942. " ) \r\n";
  943. try
  944. {
  945. try
  946. {
  947. pADO = new TADOQuery(NULL);
  948. pADO->Close();
  949. pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
  950. pADO->SQL->Clear();
  951. pADO->SQL->Text = sQry;
  952. pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
  953. pADO->Parameters->ParamByName("p02")->Value = ACctvNmbr;
  954. pADO->Parameters->ParamByName("p03")->Value = ACtlType;
  955. pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
  956. pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
  957. pADO->Parameters->ParamByName("p06")->Value = AUserId;
  958. pADO->ExecSQL();
  959. return true;
  960. }
  961. catch(EDatabaseError &E)
  962. {
  963. DBERRORLOG("TCctvCtlrManager::InsCctvControlHs", String(E.ClassName()), E.Message, sQry);
  964. throw Exception(String(E.ClassName()) + E.Message);
  965. }
  966. catch(Exception &e)
  967. {
  968. DBERRORLOG("TCctvCtlrManager::InsCctvControlHs", String(e.ClassName()), e.Message, sQry);
  969. throw Exception(String(e.ClassName()) + e.Message);
  970. }
  971. }
  972. __finally
  973. {
  974. if (pADO)
  975. {
  976. pADO->Close();
  977. delete pADO;
  978. }
  979. }
  980. return true;
  981. }
  982. //---------------------------------------------------------------------------