ITS_OP/SRC/ITS_OPLib/CDS/CDSIncCctvCtlrF.cpp

//---------------------------------------------------------------------------

#pragma hdrstop

#include "CDSIncCctvCtlrF.h"
#include "ITS_OPLibF.h"

//---------------------------------------------------------------------------

#pragma package(smart_init)


//---------------------------------------------------------------------------
TIncCctvCtlr::TIncCctvCtlr()
{
}
//---------------------------------------------------------------------------

TIncCctvCtlr::~TIncCctvCtlr()
{
}
//---------------------------------------------------------------------------

//---------------------------------------------------------------------------
TIncCctvCtlrManager *IncCctvCtlrManager = NULL;
//---------------------------------------------------------------------------

TIncCctvCtlrManager::TIncCctvCtlrManager()
{
    FImgStream = NULL;
}
//---------------------------------------------------------------------------
TIncCctvCtlrManager::~TIncCctvCtlrManager()
{
    FLists.RemoveAll();
    if (FImgStream) delete FImgStream;
    FImgStream = NULL;
}
//---------------------------------------------------------------------------
bool TIncCctvCtlrManager::LoadFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT A.*                  \r\n"
           "  FROM VW_INC_CCTV_CTLR A   \r\n";
           " WHERE A.DEL_YN = 'N'       \r\n";

    FLists.Lock();
    try
    {
        FLists.RemoveAll();
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            pADO->Prepared = true;
			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
				TIncCctvCtlr *pObj = new TIncCctvCtlr();

#if 0
                pObj->CTLR_NMBR      = pADO->FieldByName("CCTV_CTLR_NMBR")->AsString;             //	N	NUMBER(10)	    N			CCTV 제어기 번호
                pObj->NAME             = pADO->FieldByName("CCTV_NM")->AsString.Trim();              //	N	VARCHAR2(40)	Y			CCTV 명칭
                pObj->CCTV_TYPE_CD        = pADO->FieldByName("CCTV_TYPE_CD")->AsString.Trim();         //	N	VARCHAR2(7)	    Y			CCTV 유형
                pObj->CCTV_CTLR_LOCAL_NO  = pADO->FieldByName("CCTV_CTLR_LOCAL_NO")->AsInteger;         //	N	NUMBER(5)	    Y			CCTV 제어기 지역번호
                pObj->STRM_STOR_ADDR      = pADO->FieldByName("STRM_STOR_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			스트리밍 저장 주소
                pObj->INTR_RTSP_ADDR      = pADO->FieldByName("INTR_RTSP_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			내부 RTSP 주소
                pObj->INTR_RTMP_ADDR      = pADO->FieldByName("INTR_RTMP_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			내부 RTMP 주소
                pObj->INTR_HTTP_ADDR      = pADO->FieldByName("INTR_HTTP_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			내부 HTTP 주소
                pObj->CCTV_SBST_DSPL_YN   = pADO->FieldByName("CCTV_SBST_DSPL_YN")->AsString.Trim();    //	N	CHAR(1)	        Y	'N'		CCTV 대체 표출 여부
                pObj->SYOP_CNTL_YN        = pADO->FieldByName("SYOP_CNTL_YN")->AsString.Trim();         //	N	CHAR(1)	        Y	'N'		운영자 제어 여부
                pObj->CCTV_IP             = pADO->FieldByName("CCTV_IP")->AsString.Trim();              //	N	VARCHAR2(20)	Y			목포 CCTV 제어 IP
                pObj->CCTV_PORT           = pADO->FieldByName("CCTV_PORT")->AsInteger;                  //	N	NUMBER(5)	    Y	1852		목포 CCTV 제어 PORT
                pObj->CCTV_ID             = pADO->FieldByName("CCTV_ID")->AsString.Trim();              //	N	VARCHAR2(20)	Y	'root'		목포 CCTV 제어 ID
                pObj->CCTV_PSWD           = pADO->FieldByName("CCTV_PSWD")->AsString.Trim();            //	N	VARCHAR2(20)	Y	'1234'		목포 CCTV 제어 PSWD
                pObj->CCTV_CHNL           = pADO->FieldByName("CCTV_CHNL")->AsInteger;                  //	N	NUMBER(5)	    Y	1		목포 CCTV 제어 CHANNEL
#else
                pObj->CTLR_NMBR      = pADO->FieldByName("CCTV_MNGM_NMBR")->AsString;             //	N	NUMBER(10)	    N			CCTV 제어기 번호
                pObj->NAME             = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();        //	N	VARCHAR2(40)	Y			CCTV 명칭
#endif
                pObj->CTLR_ID        = pADO->FieldByName("CCTV_CTLR_ID")->AsString.Trim();         //	N	VARCHAR2(30)	Y			CCTV 제어기 ID
                pObj->CTLR_IP        = pADO->FieldByName("CCTV_CTLR_IP")->AsString.Trim();         //	N	VARCHAR2(20)	Y			CCTV 제어기 아이피
                pObj->CTLR_PORT      = pADO->FieldByName("CCTV_CTLR_PORT")->AsInteger;             //	N	NUMBER(5)	    Y			CCTV 제어기 포트
                pObj->ISTL_LCTN_NM        = pADO->FieldByName("ISTL_LCTN_NM")->AsString.Trim();         //	N	VARCHAR2(40)	Y			설치 위치 명
                pObj->X_CRDN              = pADO->FieldByName("X_CRDN")->AsFloat;                       //	N	NUMBER(11,8)	Y			X 좌표
                pObj->Y_CRDN              = pADO->FieldByName("Y_CRDN")->AsFloat;                       //	N	NUMBER(10,8)	Y			Y 좌표
                pObj->DEL_YN              = pADO->FieldByName("DEL_YN")->AsString.Trim();               //	N	CHAR(1)	        Y	'N'		삭제 여부
                pObj->CCTV_CAPT_IP        = pADO->FieldByName("CCTV_CAPT_IP")->AsString.Trim();         //	N	VARCHAR2(20)	Y			CCTV 자막기 아이피
                pObj->CCTV_CAPT_PORT      = pADO->FieldByName("CCTV_CAPT_PORT")->AsString.Trim();       //	N	VARCHAR2(5)	    Y			CCTV 자막기 포트
                pObj->CCTV_FIBR_IP        = pADO->FieldByName("CCTV_FIBR_IP")->AsString.Trim();         //	N	VARCHAR2(20)	Y			CCTV 광장비 아이피
                pObj->CCTV_ENCD_IP        = pADO->FieldByName("CCTV_ENCD_IP")->AsString.Trim();         //	N	VARCHAR2(20)	Y			CCTV 인코더 아이피
                pObj->STRM_SVR_IP         = pADO->FieldByName("STRM_SVR_IP")->AsString.Trim();          //	N	VARCHAR2(20)	Y			스트리밍 서버 아이피
                pObj->STRM_SVR_PORT       = pADO->FieldByName("STRM_SVR_PORT")->AsString.Trim();        //	N	VARCHAR2(5)	    Y			스트리밍 서버 포트
                pObj->STRM_SESN_NM        = pADO->FieldByName("STRM_SESN_NM")->AsString.Trim();         //	N	VARCHAR2(200)	Y			스트리밍 세션 명
                pObj->STRM_RTSP_ADDR      = pADO->FieldByName("STRM_RTSP_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			스트리밍 RTSP 주소
                pObj->STRM_RTMP_ADDR      = pADO->FieldByName("STRM_RTMP_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			스트리밍 RTMP 주소
                pObj->STRM_HTTP_ADDR      = pADO->FieldByName("STRM_HTTP_ADDR")->AsString.Trim();       //	N	VARCHAR2(200)	Y			스트리밍 HTTP 주소
                //pObj->CCTV_SBST_IMGN      = pADO->FieldByName("CCTV_SBST_IMGN")->AsString.Trim();       //	N	BLOB	        Y			CCTV 대체 영상

                pObj->STRM_ADDR      = pObj->STRM_SESN_NM;
                pObj->FULL_STRM_ADDR = "";

                pObj->STATE.Comm = cctv_error;

				FLists.Push(pObj->CTLR_NMBR, pObj);
                pObj->Completed  = true;
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("TIncCctvCtlrManager::LoadFromDb", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORMSG("TIncCctvCtlrManager::LoadFromDb", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::LoadStatusFromDb(TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT *                                                        \r\n"
           "  FROM TB_CCTV_CTLR_STTS A,                                     \r\n"
           "       VW_INC_CCTV_CTLR      B                                  \r\n"
           " WHERE A.CCTV_CTLR_NMBR = B.CCTV_CTLR_NMBR                      \r\n"
           "   AND A.UPDT_DT >= TO_CHAR(SYSDATE-2/1440, 'YYYYMMDDHH24MISS') \r\n";

    FLists.Lock();
    try
    {
        TIncCctvCtlr *pObj = NULL;
        try
        {
            int nORD;

            pADO = new TADOQuery(NULL);
            pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
            pADO->SQL->Clear();
            pADO->SQL->Text = sQry;

            pADO->Prepared = true;
            pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                String CCTV_CTLR_NMBR = pADO->FieldByName("CCTV_CTLR_NMBR")->AsString;
                pObj = FLists.Find(CCTV_CTLR_NMBR);
                if (!pObj) continue;

                String UPDT_DT      = pADO->FieldByName("UPDT_DT")->AsString;
                String CONN_STTS_CD = pADO->FieldByName("CONN_STTS_CD")->AsString;
                if (CONN_STTS_CD != "CMS0")
                {
                    //통신장애
                    continue;
                }
                pObj->STATE.Comm = (CONN_STTS_CD == "CMS0") ? cctv_normal : cctv_error;
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::LoadStatusFromDb", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::LoadStatusFromDb", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        FLists.UnLock();

        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::DeleteCctv(TIncCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    sQry = "UPDATE VW_INC_CCTV_CTLR      \r\n"
           "   SET DEL_YN = 'Y'          \r\n"
           " WHERE CCTV_CTLR_NMBR = :p01 \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_NMBR;
			pADO->ExecSQL();

        sQry = "DELETE TB_FCLT_INFR      \r\n"
               " WHERE FCLT_ID = :p01    \r\n";

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_ID;
			pADO->ExecSQL();

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::DeleteCctv", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::DeleteCctv", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::InsertCctv(TIncCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    sQry = "MERGE INTO VW_INC_CCTV_CTLR L               \r\n"
           "USING (SELECT                               \r\n"
           "              :p01 AS CCTV_CTLR_NMBR,       \r\n"
           "              :p02 AS CCTV_CTLR_ID,         \r\n"
           "              :p03 AS CCTV_NM,              \r\n"
           "              :p04 AS CCTV_CTLR_IP,         \r\n"
           "              :p05 AS CCTV_CTLR_PORT,       \r\n"
           "              :p06 AS CCTV_CTLR_LOCAL_NO,   \r\n"
           "              :p07 AS CCTV_TYPE_CD,         \r\n"
           "              :p08 AS ISTL_LCTN_NM,         \r\n"
           "              :p09 AS X_CRDN,               \r\n"
           "              :p10 AS Y_CRDN,               \r\n"
           "              :p11 AS DEL_YN,               \r\n"
           "              :p12 AS STRM_SVR_IP,          \r\n"
           "              :p13 AS STRM_SESN_NM,         \r\n"
           "              :p14 AS STRM_RTSP_ADDR,       \r\n"
           "              :p15 AS STRM_RTMP_ADDR,       \r\n"
           "              :p16 AS STRM_HTTP_ADDR,       \r\n"
           "              :p17 AS CCTV_IP,              \r\n"
           "              :p18 AS CCTV_PORT,            \r\n"
           "              :p19 AS CCTV_ID,              \r\n"
           "              :p20 AS CCTV_PSWD,            \r\n"
           "              :p21 AS CCTV_CHNL             \r\n"
           "         FROM DUAL) M                       \r\n"
           "        ON (L.CCTV_CTLR_NMBR = M.CCTV_CTLR_NMBR)            \r\n"
           "WHEN MATCHED THEN                                           \r\n"
           "   UPDATE SET L.CCTV_CTLR_ID       = M.CCTV_CTLR_ID,        \r\n"
           "              L.CCTV_NM            = M.CCTV_NM,             \r\n"
           "              L.CCTV_CTLR_IP       = M.CCTV_CTLR_IP,        \r\n"
           "              L.CCTV_CTLR_PORT     = M.CCTV_CTLR_PORT,      \r\n"
           "              L.CCTV_CTLR_LOCAL_NO = M.CCTV_CTLR_LOCAL_NO,  \r\n"
           "              L.CCTV_TYPE_CD       = M.CCTV_TYPE_CD,        \r\n"
           "              L.ISTL_LCTN_NM       = M.ISTL_LCTN_NM,        \r\n"
           "              L.X_CRDN             = M.X_CRDN,              \r\n"
           "              L.Y_CRDN             = M.Y_CRDN,              \r\n"
           "              L.DEL_YN             = M.DEL_YN,              \r\n"
           "              L.STRM_SVR_IP        = M.STRM_SVR_IP,         \r\n"
           "              L.STRM_SESN_NM       = M.STRM_SESN_NM,        \r\n"
           "              L.STRM_RTSP_ADDR     = M.STRM_RTSP_ADDR,      \r\n"
           "              L.STRM_RTMP_ADDR     = M.STRM_RTMP_ADDR,      \r\n"
           "              L.STRM_HTTP_ADDR     = M.STRM_HTTP_ADDR,      \r\n"
           "              L.CCTV_IP            = M.CCTV_IP,             \r\n"
           "              L.CCTV_PORT          = M.CCTV_PORT,           \r\n"
           "              L.CCTV_ID            = M.CCTV_ID,             \r\n"
           "              L.CCTV_PSWD          = M.CCTV_PSWD,           \r\n"
           "              L.CCTV_CHNL          = M.CCTV_CHNL            \r\n"
           "WHEN NOT MATCHED THEN               \r\n"
           "   INSERT (                         \r\n"
           "           CCTV_CTLR_NMBR,          \r\n"
           "           CCTV_CTLR_ID,            \r\n"
           "           CCTV_NM,                 \r\n"
           "           CCTV_CTLR_IP,            \r\n"
           "           CCTV_CTLR_PORT,          \r\n"
           "           CCTV_CTLR_LOCAL_NO,      \r\n"
           "           CCTV_TYPE_CD,            \r\n"
           "           ISTL_LCTN_NM,            \r\n"
           "           X_CRDN,                  \r\n"
           "           Y_CRDN,                  \r\n"
           "           DEL_YN,                  \r\n"
           "           STRM_SVR_IP,             \r\n"
           "           STRM_SESN_NM	,           \r\n"
           "           STRM_RTSP_ADDR,          \r\n"
           "           STRM_RTMP_ADDR,          \r\n"
           "           STRM_HTTP_ADDR,          \r\n"
           "           CCTV_IP,                 \r\n"
           "           CCTV_PORT,               \r\n"
           "           CCTV_ID,                 \r\n"
           "           CCTV_PSWD,               \r\n"
           "           CCTV_CHNL                \r\n"
           "           )                        \r\n"
           "   VALUES (                         \r\n"
           "           M.CCTV_CTLR_NMBR,        \r\n"
           "           M.CCTV_CTLR_ID,          \r\n"
           "           M.CCTV_NM,               \r\n"
           "           M.CCTV_CTLR_IP,          \r\n"
           "           M.CCTV_CTLR_PORT,        \r\n"
           "           M.CCTV_CTLR_LOCAL_NO,    \r\n"
           "           M.CCTV_TYPE_CD,          \r\n"
           "           M.ISTL_LCTN_NM,          \r\n"
           "           M.X_CRDN,                \r\n"
           "           M.Y_CRDN,                \r\n"
           "           M.DEL_YN,                \r\n"
           "           M.STRM_SVR_IP,           \r\n"
           "           M.STRM_SESN_NM	,       \r\n"
           "           M.STRM_RTSP_ADDR,        \r\n"
           "           M.STRM_RTMP_ADDR,        \r\n"
           "           M.STRM_HTTP_ADDR,        \r\n"
           "           M.CCTV_IP,               \r\n"
           "           M.CCTV_PORT,             \r\n"
           "           M.CCTV_ID,               \r\n"
           "           M.CCTV_PSWD,             \r\n"
           "           M.CCTV_CHNL              \r\n"
           "           )                        \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_NMBR;
            pADO->Parameters->ParamByName("p02")->Value = AObj->CTLR_ID;
            pADO->Parameters->ParamByName("p03")->Value = AObj->NAME;
            pADO->Parameters->ParamByName("p04")->Value = AObj->CTLR_IP;
            pADO->Parameters->ParamByName("p05")->Value = AObj->CTLR_PORT;
            pADO->Parameters->ParamByName("p06")->Value = AObj->CTLR_LOCAL_NO;
            pADO->Parameters->ParamByName("p07")->Value = AObj->TYPE_CD;
            pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
            pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
            pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
            pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
            pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
            pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SESN_NM;
            pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_RTSP_ADDR;
            pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTMP_ADDR;
            pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_HTTP_ADDR;
            pADO->Parameters->ParamByName("p17")->Value = AObj->CCTV_IP;
            pADO->Parameters->ParamByName("p18")->Value = AObj->CCTV_PORT;
            pADO->Parameters->ParamByName("p19")->Value = AObj->CCTV_ID;
            pADO->Parameters->ParamByName("p20")->Value = AObj->CCTV_PSWD;
            pADO->Parameters->ParamByName("p21")->Value = AObj->CCTV_CHNL;

			pADO->ExecSQL();

            return MergeFcltInfo(AObj, ADbConn);
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::InsertCctv", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::InsertCctv", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::UpdateCctv(TIncCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    return MergeCctv(AObj, ADbConn);
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::MergeCctv(TIncCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "MERGE INTO VW_INC_CCTV_CTLR L               \r\n"
           "USING (SELECT                               \r\n"
           "              :p01 AS CCTV_CTLR_NMBR,       \r\n"
           "              :p02 AS CCTV_CTLR_ID,         \r\n"
           "              :p03 AS CCTV_NM,              \r\n"
           "              :p04 AS CCTV_CTLR_IP,         \r\n"
           "              :p05 AS CCTV_CTLR_PORT,       \r\n"
           "              :p06 AS CCTV_CTLR_LOCAL_NO,   \r\n"
           "              :p07 AS CCTV_TYPE_CD,         \r\n"
           "              :p08 AS ISTL_LCTN_NM,         \r\n"
           "              :p09 AS X_CRDN,               \r\n"
           "              :p10 AS Y_CRDN,               \r\n"
           "              :p11 AS DEL_YN,               \r\n"
           "              :p12 AS STRM_SVR_IP,          \r\n"
           "              :p13 AS STRM_SESN_NM,         \r\n"
           "              :p14 AS STRM_RTSP_ADDR,       \r\n"
           "              :p15 AS STRM_RTMP_ADDR,       \r\n"
           "              :p16 AS STRM_HTTP_ADDR,       \r\n"
           "              :p17 AS CCTV_IP,              \r\n"
           "              :p18 AS CCTV_PORT,            \r\n"
           "              :p19 AS CCTV_ID,              \r\n"
           "              :p20 AS CCTV_PSWD,            \r\n"
           "              :p21 AS CCTV_CHNL             \r\n"
           "         FROM DUAL) M                       \r\n"
           "        ON (L.CCTV_CTLR_NMBR = M.CCTV_CTLR_NMBR)            \r\n"
           "WHEN MATCHED THEN                                           \r\n"
           "   UPDATE SET L.CCTV_CTLR_ID       = M.CCTV_CTLR_ID,        \r\n"
           "              L.CCTV_NM            = M.CCTV_NM,             \r\n"
           "              L.CCTV_CTLR_IP       = M.CCTV_CTLR_IP,        \r\n"
           "              L.CCTV_CTLR_PORT     = M.CCTV_CTLR_PORT,      \r\n"
           "              L.CCTV_CTLR_LOCAL_NO = M.CCTV_CTLR_LOCAL_NO,  \r\n"
           "              L.CCTV_TYPE_CD       = M.CCTV_TYPE_CD,        \r\n"
           "              L.ISTL_LCTN_NM       = M.ISTL_LCTN_NM,        \r\n"
           "              L.X_CRDN             = M.X_CRDN,              \r\n"
           "              L.Y_CRDN             = M.Y_CRDN,              \r\n"
           "              L.DEL_YN             = M.DEL_YN,              \r\n"
           "              L.STRM_SVR_IP        = M.STRM_SVR_IP,         \r\n"
           "              L.STRM_SESN_NM       = M.STRM_SESN_NM,        \r\n"
           "              L.STRM_RTSP_ADDR     = M.STRM_RTSP_ADDR,      \r\n"
           "              L.STRM_RTMP_ADDR     = M.STRM_RTMP_ADDR,      \r\n"
           "              L.STRM_HTTP_ADDR     = M.STRM_HTTP_ADDR,      \r\n"
           "              L.CCTV_IP            = M.CCTV_IP,             \r\n"
           "              L.CCTV_PORT          = M.CCTV_PORT,           \r\n"
           "              L.CCTV_ID            = M.CCTV_ID,             \r\n"
           "              L.CCTV_PSWD          = M.CCTV_PSWD,           \r\n"
           "              L.CCTV_CHNL          = M.CCTV_CHNL            \r\n"
           "WHEN NOT MATCHED THEN               \r\n"
           "   INSERT (                         \r\n"
           "           CCTV_CTLR_NMBR,          \r\n"
           "           CCTV_CTLR_ID,            \r\n"
           "           CCTV_NM,                 \r\n"
           "           CCTV_CTLR_IP,            \r\n"
           "           CCTV_CTLR_PORT,          \r\n"
           "           CCTV_CTLR_LOCAL_NO,      \r\n"
           "           CCTV_TYPE_CD,            \r\n"
           "           ISTL_LCTN_NM,            \r\n"
           "           X_CRDN,                  \r\n"
           "           Y_CRDN,                  \r\n"
           "           DEL_YN,                  \r\n"
           "           STRM_SVR_IP,             \r\n"
           "           STRM_SESN_NM	,           \r\n"
           "           STRM_RTSP_ADDR,          \r\n"
           "           STRM_RTMP_ADDR,          \r\n"
           "           STRM_HTTP_ADDR,          \r\n"
           "           CCTV_IP,                 \r\n"
           "           CCTV_PORT,               \r\n"
           "           CCTV_ID,                 \r\n"
           "           CCTV_PSWD,               \r\n"
           "           CCTV_CHNL                \r\n"
           "           )                        \r\n"
           "   VALUES (                         \r\n"
           "           M.CCTV_CTLR_NMBR,        \r\n"
           "           M.CCTV_CTLR_ID,          \r\n"
           "           M.CCTV_NM,               \r\n"
           "           M.CCTV_CTLR_IP,          \r\n"
           "           M.CCTV_CTLR_PORT,        \r\n"
           "           M.CCTV_CTLR_LOCAL_NO,    \r\n"
           "           M.CCTV_TYPE_CD,          \r\n"
           "           M.ISTL_LCTN_NM,          \r\n"
           "           M.X_CRDN,                \r\n"
           "           M.Y_CRDN,                \r\n"
           "           M.DEL_YN,                \r\n"
           "           M.STRM_SVR_IP,           \r\n"
           "           M.STRM_SESN_NM	,       \r\n"
           "           M.STRM_RTSP_ADDR,        \r\n"
           "           M.STRM_RTMP_ADDR,        \r\n"
           "           M.STRM_HTTP_ADDR,        \r\n"
           "           M.CCTV_IP,               \r\n"
           "           M.CCTV_PORT,             \r\n"
           "           M.CCTV_ID,               \r\n"
           "           M.CCTV_PSWD,             \r\n"
           "           M.CCTV_CHNL              \r\n"
           "           )                        \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_NMBR;
            pADO->Parameters->ParamByName("p02")->Value = AObj->CTLR_ID;
            pADO->Parameters->ParamByName("p03")->Value = AObj->NAME;
            pADO->Parameters->ParamByName("p04")->Value = AObj->CTLR_IP;
            pADO->Parameters->ParamByName("p05")->Value = AObj->CTLR_PORT;
            pADO->Parameters->ParamByName("p06")->Value = AObj->CTLR_LOCAL_NO;
            pADO->Parameters->ParamByName("p07")->Value = AObj->TYPE_CD;
            pADO->Parameters->ParamByName("p08")->Value = AObj->ISTL_LCTN_NM;
            pADO->Parameters->ParamByName("p09")->Value = AObj->X_CRDN;
            pADO->Parameters->ParamByName("p10")->Value = AObj->Y_CRDN;
            pADO->Parameters->ParamByName("p11")->Value = AObj->DEL_YN;
            pADO->Parameters->ParamByName("p12")->Value = AObj->STRM_SVR_IP;
            pADO->Parameters->ParamByName("p13")->Value = AObj->STRM_SESN_NM;
            pADO->Parameters->ParamByName("p14")->Value = AObj->STRM_RTSP_ADDR;
            pADO->Parameters->ParamByName("p15")->Value = AObj->STRM_RTMP_ADDR;
            pADO->Parameters->ParamByName("p16")->Value = AObj->STRM_HTTP_ADDR;
            pADO->Parameters->ParamByName("p17")->Value = AObj->CCTV_IP;
            pADO->Parameters->ParamByName("p18")->Value = AObj->CCTV_PORT;
            pADO->Parameters->ParamByName("p19")->Value = AObj->CCTV_ID;
            pADO->Parameters->ParamByName("p20")->Value = AObj->CCTV_PSWD;
            pADO->Parameters->ParamByName("p21")->Value = AObj->CCTV_CHNL;

			pADO->ExecSQL();

            return MergeFcltInfo(AObj, ADbConn);
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::MergeCctv", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::MergeCctv", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::MergeFcltInfo(TIncCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "MERGE INTO TB_FCLT_INFR L                                         \r\n"
           "USING (SELECT :p01 AS FCLT_ID,                                    \r\n"
           "              :p02 AS FCLT_TYPE,                                  \r\n"
           "              :p03 AS FCLT_LCTN                                   \r\n"
           "         FROM DUAL) M                                             \r\n"
           "        ON (L.FCLT_ID = M.FCLT_ID AND L.FCLT_TYPE = M.FCLT_TYPE)  \r\n"
           "WHEN MATCHED                                                      \r\n"
           "THEN                                                              \r\n"
           "   UPDATE SET L.FCLT_LCTN = M.FCLT_LCTN,                          \r\n"
           "              L.DEL_YN    = 'N'                                   \r\n"
           "WHEN NOT MATCHED                                                  \r\n"
           "THEN                                                              \r\n"
           "   INSERT (  FCLT_ID,   FCLT_TYPE,   FCLT_LCTN)                   \r\n"
           "   VALUES (M.FCLT_ID, M.FCLT_TYPE, M.FCLT_LCTN)                   \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_ID;
			pADO->Parameters->ParamByName("p02")->Value = "ICAM";
			pADO->Parameters->ParamByName("p03")->Value = AObj->NAME;
			pADO->ExecSQL();

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::MergeFcltInfo", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::MergeFcltInfo", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::GetNextCctvId(int &ANmbr, int &AId, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    sQry = "SELECT NVL(MAX(CCTV_CTLR_NMBR), 10000) + 1 AS NEWID FROM VW_INC_CCTV_CTLR \r\n";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            pADO->Prepared = true;
			pADO->Open();
            ANmbr = pADO->FieldByName("NEWID")->AsInteger;
            AId = ANmbr / 10000;
            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::GetNextCctvId", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::GetNextCctvId", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }
    return false;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::LoadPreSet(TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    FLists.Lock();
    try
    {
        FOR_STL(TIncCctvCtlr*, pObj, FLists)
        {
            pObj->FLists.RemoveAll();
        }
    }
    __finally
    {
        FLists.UnLock();
    }

    sQry = "SELECT B.*                                 \r\n"
           "  FROM VW_INC_CCTV_CTLR A,                 \r\n"
           "       TB_CCTV_PSET B                      \r\n"
           " WHERE A.CCTV_CTLR_NMBR = B.CCTV_CTLR_NMBR \r\n"
           " ORDER BY B.CCTV_CTLR_NMBR, B.PSET_NMBR    \r\n";
    try
    {
        String CCTV_CTLR_NMBR;

        FLists.Lock();
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            pADO->Prepared = true;
			pADO->Open();
            for( ; !pADO->Eof; pADO->Next())
            {
                CCTV_CTLR_NMBR = pADO->FieldByName("CCTV_CTLR_NMBR")->AsString;
				TIncCctvCtlr *pCctv = FLists.Find(String(CCTV_CTLR_NMBR));
                if (!pCctv) continue;

                TIncCctvPset *pObj = new TIncCctvPset();
                if (pObj)
                {
                    pObj->CCTV_CTLR_NMBR = CCTV_CTLR_NMBR;
                    pObj->PSET_NMBR     = pADO->FieldByName("PSET_NMBR")->AsInteger;
                    pObj->PSET_NM       = pADO->FieldByName("PSET_NM")->AsString;
                    pObj->PAN           = pADO->FieldByName("PAN")->AsInteger;
                    pObj->TILT          = pADO->FieldByName("TILT")->AsInteger;
                    pObj->ZOOM          = pADO->FieldByName("ZOOM")->AsInteger;
                    pObj->FOCS          = pADO->FieldByName("FOCS")->AsInteger;
                    pObj->ANGLE         = pADO->FieldByName("ANGLE")->AsInteger;
                    pObj->DFLT_YN       = pADO->FieldByName("DFLT_YN")->AsString;

                    pObj->DEL_YN         = "N";

                    pCctv->FLists.Push(pObj->PSET_NMBR, pObj);
                }
            }
        }
        catch(EDatabaseError &E)
        {
            DBERRORMSG("TIncCctvCtlrManager::LoadPreSet", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORMSG("TIncCctvCtlrManager::LoadPreSet", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
        FLists.UnLock();
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::SavePreSet(TIncCctvCtlr *AObj, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();

sQry = "DELETE FROM TB_CCTV_PSET WHERE CCTV_CTLR_NMBR = :p01";
			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
			pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_NMBR;
			pADO->ExecSQL();

sQry = "INSERT INTO TB_CCTV_PSET(                               \r\n"
       "        CCTV_CTLR_NMBR,                                 \r\n"
       "        PSET_NMBR,                                      \r\n"
       "        PSET_NM,                                        \r\n"
       "        PAN,                                            \r\n"
       "        TILT,                                           \r\n"
       "        ZOOM,                                           \r\n"
       "        FOCS,                                           \r\n"
       "        DFLT_YN )                                       \r\n"
       " VALUES(:p01, :p02, :p03, :p04, :p05, :p06, :p07, :p08) \r\n";

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
            FOR_STL(TIncCctvPset *, pObj, AObj->FLists)
            {
                if (pObj->DEL_YN != "N") continue;

                pADO->Parameters->ParamByName("p01")->Value = pObj->CCTV_CTLR_NMBR;
                pADO->Parameters->ParamByName("p02")->Value = pObj->PSET_NMBR;
                pADO->Parameters->ParamByName("p03")->Value = pObj->PSET_NM;
                pADO->Parameters->ParamByName("p04")->Value = pObj->PAN;
                pADO->Parameters->ParamByName("p05")->Value = pObj->TILT;
                pADO->Parameters->ParamByName("p06")->Value = pObj->ZOOM;
                pADO->Parameters->ParamByName("p07")->Value = pObj->FOCS;
                pADO->Parameters->ParamByName("p08")->Value = pObj->DFLT_YN;

    			pADO->ExecSQL();
            }
            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::DeletePreSet(TIncCctvCtlr *AObj, int APsetNmbr, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    TIncCctvPset* pObj = AObj->FLists.Find(APsetNmbr);
    if (!pObj) return false;

    sQry = "DELETE FROM TB_CCTV_PSET WHERE CCTV_CTLR_NMBR = :p01 AND PSET_NMBR = :p02";

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

			pADO->Parameters->ParamByName("p01")->Value = AObj->CTLR_NMBR;
			pADO->Parameters->ParamByName("p02")->Value = APsetNmbr;

			pADO->ExecSQL();

            pObj->DEL_YN = "Y";

            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::DeletePreSet", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::DeletePreSet", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::MergePreSet(TIncCctvCtlr *AObj, TIncCctvPset* APset, TADOConnection *ADbConn/*=NULL*/)
{
    String sQry;
    TADOQuery *pADO = NULL;

    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();

    sQry = "MERGE INTO TB_CCTV_PSET L                       \r\n"
           "USING (SELECT                                   \r\n"
           "              :p01 AS CCTV_CTLR_NMBR,           \r\n"
           "              :p02 AS PSET_NMBR,                \r\n"
           "              :p03 AS PSET_NM,                  \r\n"
           "              :p04 AS PAN,                      \r\n"
           "              :p05 AS TILT,                     \r\n"
           "              :p06 AS ZOOM,                     \r\n"
           "              :p07 AS FOCS,                     \r\n"
           "              :p08 AS DFLT_YN                   \r\n"
           "         FROM DUAL) M                           \r\n"
           "        ON (L.CCTV_CTLR_NMBR = M.CCTV_CTLR_NMBR \r\n"
           "        AND L.PSET_NMBR      = M.PSET_NMBR )    \r\n"
           "WHEN MATCHED THEN                               \r\n"
           "   UPDATE SET L.PSET_NM = M.PSET_NM,            \r\n"
           "              L.PAN     = M.PAN,                \r\n"
           "              L.TILT    = M.TILT,               \r\n"
           "              L.ZOOM    = M.ZOOM,               \r\n"
           "              L.FOCS    = M.FOCS,               \r\n"
           "              L.DFLT_YN = M.DFLT_YN             \r\n"
           "WHEN NOT MATCHED THEN                           \r\n"
           "   INSERT (                                     \r\n"
           "        CCTV_CTLR_NMBR,                         \r\n"
           "        PSET_NMBR,                              \r\n"
           "        PSET_NM,                                \r\n"
           "        PAN,                                    \r\n"
           "        TILT,                                   \r\n"
           "        ZOOM,                                   \r\n"
           "        FOCS,                                   \r\n"
           "        DFLT_YN )                               \r\n"
           "   VALUES (                                     \r\n"
           "        M.CCTV_CTLR_NMBR,                       \r\n"
           "        M.PSET_NMBR,                            \r\n"
           "        M.PSET_NM,                              \r\n"
           "        M.PAN,                                  \r\n"
           "        M.TILT,                                 \r\n"
           "        M.ZOOM,                                 \r\n"
           "        M.FOCS,                                 \r\n"
           "        M.DFLT_YN )                             \r\n";

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;
            FOR_STL(TIncCctvPset *, pObj, AObj->FLists)
            {
                if (pObj->DEL_YN != "N") continue;

                pADO->Parameters->ParamByName("p01")->Value = APset->CCTV_CTLR_NMBR;
                pADO->Parameters->ParamByName("p02")->Value = APset->PSET_NMBR;
                pADO->Parameters->ParamByName("p03")->Value = APset->PSET_NM;
                pADO->Parameters->ParamByName("p04")->Value = APset->PAN;
                pADO->Parameters->ParamByName("p05")->Value = APset->TILT;
                pADO->Parameters->ParamByName("p06")->Value = APset->ZOOM;
                pADO->Parameters->ParamByName("p07")->Value = APset->FOCS;
                pADO->Parameters->ParamByName("p08")->Value = APset->DFLT_YN;

    			pADO->ExecSQL();

                TIncCctvPset* pObj = AObj->FLists.Find(APset->PSET_NMBR);
                if (pObj)
                {
                    pObj->CCTV_CTLR_NMBR = APset->CCTV_CTLR_NMBR;
                    pObj->PSET_NMBR      = APset->PSET_NMBR;
                    pObj->PSET_NM        = APset->PSET_NM;
                    pObj->PAN            = APset->PAN;
                    pObj->TILT           = APset->TILT;
                    pObj->ZOOM           = APset->ZOOM;
                    pObj->FOCS           = APset->FOCS;
                    pObj->DFLT_YN        = APset->DFLT_YN;
                }
                else
                {
                    AObj->FLists.Push(APset->PSET_NMBR, APset);
                }
            }
            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::SavePreSet", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::SavePreSet", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------

bool TIncCctvCtlrManager::InsCctvControlHs(String ACtlDt, String ACctvNmbr, String ACtlType, String ACtlVal, String ACtlRes, String AUserId, TADOConnection *ADbConn/*=NULL*/)
{
    String     sQry;
    TADOQuery *pADO = NULL;

    sQry = "INSERT INTO TB_CCTV_CTRL_HS(               \r\n"
           "                          CTRL_DT,         \r\n"
           "                          CCTV_CTLR_NMBR,  \r\n"
           "                          CTRL_TYPE,       \r\n"
           "                          CTRL_VAL,        \r\n"
           "                          CTRL_RESULT,     \r\n"
           "                          USER_ID          \r\n"
           "                         )                 \r\n"
           "                   VALUES(                 \r\n"
           "                          :p01,            \r\n"
           "                          :p02,            \r\n"
           "                          :p03,            \r\n"
           "                          :p04,            \r\n"
           "                          :p05,            \r\n"
           "                          :p06             \r\n"
           "                         )                 \r\n";
    try
    {
        try
        {
            pADO = new TADOQuery(NULL);
			pADO->Close();
            pADO->Connection = (NULL != ADbConn) ? ADbConn : ITSDb_GetConnection();

			pADO->SQL->Clear();
			pADO->SQL->Text = sQry;

            pADO->Parameters->ParamByName("p01")->Value = ACtlDt;
            pADO->Parameters->ParamByName("p02")->Value = ACctvNmbr;
            pADO->Parameters->ParamByName("p03")->Value = ACtlType;
            pADO->Parameters->ParamByName("p04")->Value = ACtlVal;
            pADO->Parameters->ParamByName("p05")->Value = ACtlRes;
            pADO->Parameters->ParamByName("p06")->Value = AUserId;
            pADO->ExecSQL();
            return true;
        }
        catch(EDatabaseError &E)
        {
            DBERRORLOG("TIncCctvCtlrManager::InsCctvControlHs", String(E.ClassName()), E.Message, sQry);
            throw Exception(String(E.ClassName()) + E.Message);
        }
        catch(Exception &e)
        {
            DBERRORLOG("TIncCctvCtlrManager::InsCctvControlHs", String(e.ClassName()), e.Message, sQry);
            throw Exception(String(e.ClassName()) + e.Message);
        }
    }
    __finally
    {
        if (pADO)
        {
            pADO->Close();
            delete pADO;
        }
    }

    return true;
}
//---------------------------------------------------------------------------