CDSCctvCtlrF.cpp 46 KB

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