refator code

ulysseskao

2016-05-03 410dc2d04dbecf019129cd8cd65a3be2c62b4d0c

 CCSTrace/CCS/FinishEvent.cs

@@ -1,5 +1,4 @@
using System;



using System.Data.OracleClient;

using CCSTrace.CCS.Domain;

using NLog;

@@ -12,7 +11,7 @@


        private bool _upLevel;

        private int _originCaseStatus = 0;

        private Object.EventRecord _mEventRec = null;

        private Object.EOSEventRecord _eosEventRecord = null;

        private OracleConnection _connectionTpc;

        private OracleTransaction _transaction;



@@ -20,24 +19,26 @@
        {

        }



        public bool Finish(int mKind, Object.EventRecord mRecord, OracleConnection conn, OracleTransaction trx)

        public bool Finish(int mKind, Object.EOSEventRecord eosEventRecord, OracleConnection conn, OracleTransaction trx)

        {

            _mEventRec = mRecord;

            _eosEventRecord = eosEventRecord;

            _connectionTpc = conn;

            _transaction = trx;



            Logger.Info("進行OMS資料更新程序...");

            if (mRecord.ParentId== 0)

            { // Original Case

                if (!(ProcessSingalCase(mRecord)))

            if (eosEventRecord.ParentId == 0)

            {

                // Original Case

                if (!(ProcessSingalCase(eosEventRecord)))

                {

                    return false;

                }

                Logger.Info("更新eos.events成功!");

            }

            else

            { // Child Case

                if (!(ProcessMergeCase(mRecord)))

            {

                // Child Case

                if (!(ProcessMergeCase(eosEventRecord)))

                {

                    return false;

                }

@@ -45,7 +46,7 @@
            }



            // inert into eos.eventrecord && eos.eventrecord_ex

            OracleCommand command = new OracleCommand(mRecord.GetSqlStmt(), _connectionTpc, _transaction);

            OracleCommand command = new OracleCommand(eosEventRecord.GetInsertSqlStmt(), _connectionTpc, _transaction);

            OracleCommand command1 = null;



            try

@@ -57,7 +58,7 @@
                    return false;

                }



                command.CommandText = mRecord.LocateEquipment.GetSqlStmt();

                command.CommandText = eosEventRecord.LocateEquipment.GetInsertSqlStmt();

                if (command.ExecuteNonQuery() <= 0)

                {

                    Logger.Error("儲存資料時發生錯誤: 無法更新eos.eventrecord_ex");

@@ -69,9 +70,9 @@
                if ((mKind == GlobalVariable.Success) || (mKind == GlobalVariable.CaseTypeChanged))

                {

                    /* 當饋線全停時不需注意影響虛擬用戶，影響用戶資料會由實際切開關產生 */

                    if (mRecord.Fsc!= GlobalVariable.Breaker)

                    if (eosEventRecord.Fsc != GlobalVariable.Breaker)

                    {

                        if (!SetVisualCustomer(mRecord))

                        if (!SetVisualCustomer(eosEventRecord))

                        {

                            Logger.Error("新增影響用戶資料錯誤.");

                            return false;

@@ -81,14 +82,14 @@


                    _upLevel = false; /* 判斷交辦案件是否升級為母案件 */



                    if (!(UpdateImportCase(mRecord)))

                    if (!(UpdateImportCase(eosEventRecord)))

                    {

                        Logger.Error("處理案件等級變更時發生錯誤.");

                        return false;

                    }

                    Logger.Info("處理案件等級變更成功!");



                    if (!(UpdateRecuseOrder(mRecord)))

                    if (!(UpdateRecuseOrder(eosEventRecord)))

                    {

                        Logger.Error("新增搶修順序資料時發生錯誤.");

                        return false;

@@ -97,7 +98,7 @@


                    if (mKind == GlobalVariable.CaseTypeChanged)

                    {

                        if (!DeleteOldCase(mRecord))

                        if (!DeleteOldCase(eosEventRecord))

                        {

                            Logger.Error("案件轉換發生錯誤");

                            return false;

@@ -105,7 +106,7 @@
                        Logger.Info("案件轉換成功!");

                    }



                    if (!SaveCustomerTel(mRecord))

                    if (!SaveCustomerTel(eosEventRecord))

                    {

                        Logger.Error("無法將用戶電話回存回資料庫.");

                        return false;

@@ -114,9 +115,9 @@
                }

                else if (mKind == GlobalVariable.NoMeter)

                {

                    var sqlStmt = "INSERT INTO EOS.RESCUE_ORDER SELECT " + mRecord.CaseId+ ",999,COUNT(*) + 1,'',"

                                     + mRecord.LocateEquipment.GetDsufid() + " FROM EOS.RESCUE_ORDER WHERE DSUFID = "

                                     + mRecord.LocateEquipment.GetDsufid();

                    var sqlStmt = "INSERT INTO EOS.RESCUE_ORDER SELECT " + eosEventRecord.CaseId + ",999,COUNT(*) + 1,'',"

                                  + eosEventRecord.LocateEquipment.DsUfid + " FROM EOS.RESCUE_ORDER WHERE DSUFID = "

                                  + eosEventRecord.LocateEquipment.DsUfid;



                    command1 = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

                    if (command1.ExecuteNonQuery() <= 0)

@@ -129,9 +130,9 @@
                    Logger.Info("新增搶修順序成功!");

                }



                if (mRecord.ParentId== 0)

                if (eosEventRecord.ParentId == 0)

                {

                    if (!InsertIntoSri(mRecord))

                    if (!InsertIntoSri(eosEventRecord))

                    {

                        Logger.Error("新增資料庫(OCSDB.SRI)錯誤.");

                        return false;

@@ -153,11 +154,11 @@
            return true;

        }



        private bool ProcessSingalCase(Object.EventRecord mRecord)

        private bool ProcessSingalCase(Object.EOSEventRecord eosEventRecord)

        {

            var result = false;

            var sqlStmt = "INSERT INTO EOS.EVENTS VALUES(" + mRecord.CaseId+ "," + CCSCaseState.WaitForDespatch + ",1,"

                             + GlobalVariable.OriginalCase + ",0)";

            var sqlStmt = "INSERT INTO EOS.EVENTS VALUES(" + eosEventRecord.CaseId + "," + CCSCaseState.WaitForDespatch + ",1,"

                          + GlobalVariable.OriginalCase + ",0)";



            OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);



@@ -179,11 +180,11 @@
            return result;

        }



        private bool ProcessMergeCase(Object.EventRecord mRecord)

        private bool ProcessMergeCase(Object.EOSEventRecord eosEventRecord)

        {

            // insert eos.events

            var sqlStmt = "INSERT INTO EOS.EVENTS VALUES(" + mRecord.CaseId+ "," + CCSCaseState.WaitForDespatch + ",1,"

                             + GlobalVariable.ChildCase + ",0)";

            var sqlStmt = "INSERT INTO EOS.EVENTS VALUES(" + eosEventRecord.CaseId + "," + CCSCaseState.WaitForDespatch + ",1,"

                          + GlobalVariable.ChildCase + ",0)";



            OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);



@@ -197,7 +198,8 @@
                }



                // insert into eos.mergecase

                sqlStmt = "INSERT INTO EOS.MERGECASE VALUES(" + mRecord.CaseId+ ",'" + mRecord.AcceptNum+ "'," + mRecord.ParentId+ ")";

                sqlStmt = "INSERT INTO EOS.MERGECASE VALUES(" + eosEventRecord.CaseId + ",'" + eosEventRecord.AcceptNum + "'," +

                          eosEventRecord.ParentId + ")";



                command.CommandText = sqlStmt;

                if (command.ExecuteNonQuery() <= 0)

@@ -208,8 +210,9 @@
                }



                // update parent case data(EOS.EVENTS)

                sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.ParentCase + ",MERGECASECOUNT = MERGECASECOUNT + 1 " + "WHERE CASEID = "

                        + mRecord.ParentId;

                sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.ParentCase +

                          ",MERGECASECOUNT = MERGECASECOUNT + 1 " + "WHERE CASEID = "

                          + eosEventRecord.ParentId;



                command.CommandText = sqlStmt;

                if (command.ExecuteNonQuery() <= 0)

@@ -220,8 +223,10 @@
                }



                // update parent case data(EOS.EVENTRECORD)

                sqlStmt = "UPDATE EOS.EVENTRECORD SET FSC = " + mRecord.Fsc+ ",UFID = " + mRecord.Ufid                        + " WHERE CASEID in (SELECT CASEID FROM EOS.MERGECASE WHERE PARENTID = " + mRecord.ParentId+ ") OR CASEID = "

                        + mRecord.ParentId;

                sqlStmt = "UPDATE EOS.EVENTRECORD SET FSC = " + eosEventRecord.Fsc + ",UFID = " + eosEventRecord.Ufid +

                          " WHERE CASEID in (SELECT CASEID FROM EOS.MERGECASE WHERE PARENTID = " + eosEventRecord.ParentId +

                          ") OR CASEID = "

                          + eosEventRecord.ParentId;



                command.CommandText = sqlStmt;

                if (command.ExecuteNonQuery() <= 0)

@@ -242,12 +247,12 @@
            return true;

        }



        private bool SetVisualCustomer(Object.EventRecord mRecord)

        private bool SetVisualCustomer(Object.EOSEventRecord eosEventRecord)

        {

            string sqlStmt = "";

            string customerKind = "C"; // 高壓用戶or一般用戶

            var sqlStmt = "";

            var customerKind = "C"; // 高壓用戶or一般用戶



            sqlStmt = "SELECT COUNT(*) as COUNT FROM BASEDB.HICUSTOMER WHERE METR_NUMB = '" + mRecord.Meter+ "'";

            sqlStmt = "SELECT COUNT(*) as COUNT FROM BASEDB.HICUSTOMER WHERE METR_NUMB = '" + eosEventRecord.Meter + "'";

            OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

            OracleDataReader reader = command.ExecuteReader();



@@ -272,11 +277,13 @@
                command.Dispose();

            }



            if (mRecord.ParentId== 0)

            if (eosEventRecord.ParentId == 0)

            {

                sqlStmt = "INSERT INTO EOS.TMPAFFECTCUSTMS SELECT " + mRecord.CaseId+ ",A.M_NAME,"

                        + "M.TELE_NUMB,M.METR_NUMB,A.M_ADDR,M.TRAN_CORD,M.CUST_TYPE,'" + customerKind + "' "

                        + "FROM BASEDB.METER M,BASEDB.MSTADDR A WHERE M.METR_NUMB = A.M_CUST_NO(+) AND M.METR_NUMB = '" + mRecord.Meter+ "'";

                sqlStmt = "INSERT INTO EOS.TMPAFFECTCUSTMS SELECT " + eosEventRecord.CaseId + ",A.M_NAME,"

                          + "M.TELE_NUMB,M.METR_NUMB,A.M_ADDR,M.TRAN_CORD,M.CUST_TYPE,'" + customerKind + "' "

                          +

                          "FROM BASEDB.METER M,BASEDB.MSTADDR A WHERE M.METR_NUMB = A.M_CUST_NO(+) AND M.METR_NUMB = '" +

                          eosEventRecord.Meter + "'";



                OracleCommand command1 = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

                if (command1.ExecuteNonQuery() >= 0)

@@ -289,18 +296,19 @@
            }

            else

            {

                return InsertMutilCustomer(customerKind, mRecord);

                return InsertMutilCustomer(customerKind, eosEventRecord);

            }

        }



        private bool InsertMutilCustomer(string customerKind, Object.EventRecord mRecord)

        private bool InsertMutilCustomer(string customerKind, Object.EOSEventRecord eosEventRecord)

        {

            string sqlStmt = "";

            bool updateCustomer = false;

            string mTpclidGroupId = "";

            string mCustomerKind = "C";



            sqlStmt = "SELECT COUNT(*) as COUNT FROM EOS.TMPAFFECTCUSTMS WHERE CASEID = " + mRecord.ParentId                    + " OR CASEID IN (SELECT CASEID FROM EOS.MERGECASE WHERE PARENTID = " + mRecord.ParentId+ ")";

            sqlStmt = "SELECT COUNT(*) as COUNT FROM EOS.TMPAFFECTCUSTMS WHERE CASEID = " + eosEventRecord.ParentId +

                      " OR CASEID IN (SELECT CASEID FROM EOS.MERGECASE WHERE PARENTID = " + eosEventRecord.ParentId + ")";



            OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

            OracleDataReader reader = command.ExecuteReader();

@@ -331,7 +339,8 @@
            if (updateCustomer)

            {

                /* 找出原始案件的影響用戶資料 */

                sqlStmt = "SELECT TPCLIDGROUPID,CUSTOMERKIND FROM EOS.TMPAFFECTCUSTMS WHERE CASEID = " + mRecord.ParentId;

                sqlStmt = "SELECT TPCLIDGROUPID,CUSTOMERKIND FROM EOS.TMPAFFECTCUSTMS WHERE CASEID = " +

                          eosEventRecord.ParentId;



                try

                {

@@ -349,7 +358,7 @@
                    if (mCustomerKind.Equals("C"))

                    {

                        /* 刪除原始案件的既有用戶資料 */

                        sqlStmt = "DELETE EOS.TMPAFFECTCUSTMS WHERE CASEID = " + mRecord.ParentId;

                        sqlStmt = "DELETE EOS.TMPAFFECTCUSTMS WHERE CASEID = " + eosEventRecord.ParentId;



                        command1.CommandText = sqlStmt;

                        if (command1.ExecuteNonQuery() < 0)

@@ -360,10 +369,13 @@
                        }



                        /* 將原始案件的影響用戶數改為變壓器的全部用戶 */

                        sqlStmt = "INSERT INTO EOS.TMPAFFECTCUSTMS SELECT " + mRecord.ParentId+ ",A.M_NAME,"

                                + "M.TELE_NUMB,M.METR_NUMB,A.M_ADDR,M.TPCLIDGROUPID,M.CUST_TYPE,'" + mCustomerKind + "' "

                                + "FROM (SELECT TELE_NUMB,METR_NUMB,TRAN_CORD as TPCLIDGROUPID,CUST_TYPE FROM BASEDB.METER " + "WHERE TRAN_CORD = '"

                                + mTpclidGroupId + "') M,BASEDB.MSTADDR A WHERE M.METR_NUMB = A.M_CUST_NO(+) ";

                        sqlStmt = "INSERT INTO EOS.TMPAFFECTCUSTMS SELECT " + eosEventRecord.ParentId + ",A.M_NAME,"

                                  + "M.TELE_NUMB,M.METR_NUMB,A.M_ADDR,M.TPCLIDGROUPID,M.CUST_TYPE,'" + mCustomerKind +

                                  "' "

                                  +

                                  "FROM (SELECT TELE_NUMB,METR_NUMB,TRAN_CORD as TPCLIDGROUPID,CUST_TYPE FROM BASEDB.METER " +

                                  "WHERE TRAN_CORD = '"

                                  + mTpclidGroupId + "') M,BASEDB.MSTADDR A WHERE M.METR_NUMB = A.M_CUST_NO(+) ";



                        command1.CommandText = sqlStmt;

                        if (command1.ExecuteNonQuery() <= 0)

@@ -384,10 +396,11 @@
            }



            /* 新受理案件的影響用戶資料 */

            sqlStmt = "INSERT INTO EOS.TMPAFFECTCUSTMS SELECT " + mRecord.CaseId+ ",A.M_NAME,"

                    + "M.TELE_NUMB,M.METR_NUMB,A.M_ADDR,M.TPCLIDGROUPID,M.CUST_TYPE,'" + customerKind + "' "

                    + "FROM (SELECT TELE_NUMB,METR_NUMB,TRAN_CORD as TPCLIDGROUPID,CUST_TYPE FROM BASEDB.METER "

                    + "WHERE TRAN_CORD = (SELECT TRAN_CORD FROM BASEDB.METER WHERE METR_NUMB = '" + mRecord.Meter                    + "')) M,BASEDB.MSTADDR A WHERE M.METR_NUMB = A.M_CUST_NO(+) ";

            sqlStmt = "INSERT INTO EOS.TMPAFFECTCUSTMS SELECT " + eosEventRecord.CaseId + ",A.M_NAME,"

                      + "M.TELE_NUMB,M.METR_NUMB,A.M_ADDR,M.TPCLIDGROUPID,M.CUST_TYPE,'" + customerKind + "' "

                      + "FROM (SELECT TELE_NUMB,METR_NUMB,TRAN_CORD as TPCLIDGROUPID,CUST_TYPE FROM BASEDB.METER "

                      + "WHERE TRAN_CORD = (SELECT TRAN_CORD FROM BASEDB.METER WHERE METR_NUMB = '" + eosEventRecord.Meter +

                      "')) M,BASEDB.MSTADDR A WHERE M.METR_NUMB = A.M_CUST_NO(+) ";



            OracleCommand command2 = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

            if (command2.ExecuteNonQuery() < 0)

@@ -400,22 +413,22 @@
            return true;

        }



        private bool UpdateImportCase(Object.EventRecord mRecord)

        private bool UpdateImportCase(Object.EOSEventRecord eosEventRecord)

        {

            /* 該案件不為交辦案件 */

            if (mRecord.ImportCase!= GlobalVariable.IsImportCase)

            if (eosEventRecord.ImportCase != GlobalVariable.IsImportCase)

            {

                return true;

            }



            /* 該交辦案件為原始案件 */

            if (mRecord.ParentId== 0)

            if (eosEventRecord.ParentId == 0)

            {

                return true;

            }



            /* 若母案件已為交辦案件，則不需再作任何更動 */

            var sqlStmt = "SELECT IMPORTCASE FROM EOS.EVENTRECORD WHERE CASEID = " + mRecord.ParentId;

            var sqlStmt = "SELECT IMPORTCASE FROM EOS.EVENTRECORD WHERE CASEID = " + eosEventRecord.ParentId;

            OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

            OracleDataReader reader = command.ExecuteReader();



@@ -443,7 +456,8 @@


            /* 將交辦案件改為母案件 */

            sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.ParentCase + ",MERGECASECOUNT = "

                    + "(SELECT MERGECASECOUNT FROM EOS.EVENTS WHERE CASEID = " + mRecord.ParentId+ ") WHERE CASEID = " + mRecord.CaseId;

                      + "(SELECT MERGECASECOUNT FROM EOS.EVENTS WHERE CASEID = " + eosEventRecord.ParentId +

                      ") WHERE CASEID = " + eosEventRecord.CaseId;



            OracleCommand command1 = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

            if (command1.ExecuteNonQuery() <= 0)

@@ -454,7 +468,8 @@
            }



            /* 將母案件改為子案件 */

            sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.ChildCase + ",MERGECASECOUNT = 0 WHERE CASEID = " + mRecord.ParentId;

            sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.ChildCase +

                      ",MERGECASECOUNT = 0 WHERE CASEID = " + eosEventRecord.ParentId;



            command1.CommandText = sqlStmt;

            if (command1.ExecuteNonQuery() <= 0)

@@ -465,7 +480,7 @@
            }



            // 將EOS.MERGECASE內的資料修正 1.將原先該母案件下的子案件都改掛在交辦案件下 2.將已INSERT入EOS.MERGECASE內的交辦案件資料改為原先母案件的資料(CaseID,AcceptNum)

            sqlStmt = "UPDATE EOS.MERGECASE SET PARENTID = " + mRecord.CaseId+ " WHERE PARENTID = " + mRecord.ParentId;

            sqlStmt = "UPDATE EOS.MERGECASE SET PARENTID = " + eosEventRecord.CaseId + " WHERE PARENTID = " + eosEventRecord.ParentId;



            command1.CommandText = sqlStmt;

            if (command1.ExecuteNonQuery() <= 0)

@@ -476,7 +491,7 @@
            }



            sqlStmt = "UPDATE EOS.MERGECASE SET (CASEID,ACCEPTNUM) = (SELECT CASEID,ACCEPTNUM FROM EOS.EVENTRECORD WHERE CASEID = "

                    + mRecord.ParentId+ ") WHERE CASEID = " + mRecord.CaseId;

                      + eosEventRecord.ParentId + ") WHERE CASEID = " + eosEventRecord.CaseId;



            command1.CommandText = sqlStmt;

            if (command1.ExecuteNonQuery() <= 0)

@@ -487,7 +502,7 @@
            }

            command1.Dispose();



            return UpdateOtherTable(mRecord.ParentId, mRecord.CaseId, mRecord.AcceptNum);

            return UpdateOtherTable(eosEventRecord.ParentId, eosEventRecord.CaseId, eosEventRecord.AcceptNum);

        }



        private bool UpdateOtherTable(int oldCaseId, int newCaseId, string newAcceptNum)

@@ -525,7 +540,8 @@
                            return false;

                        }



                        sqlStmt = "update eos.events set casestatus=" + CCSCaseState.WaitForSponsor + " where caseid=" + newCaseId;

                        sqlStmt = "update eos.events set casestatus=" + CCSCaseState.WaitForSponsor + " where caseid=" +

                                  newCaseId;

                        command.CommandText = sqlStmt;

                        if (command.ExecuteNonQuery() < 0)

                        {

@@ -534,11 +550,12 @@
                            return false;

                        }



                        _mEventRec.IsDespatched = true;

                        _eosEventRecord.IsDespatched = true;

                        break;

                }



                sqlStmt = "UPDATE EOS.EVENTS SET CASESTATUS = " + CCSCaseState.WaitForDespatch + " WHERE CASEID = " + oldCaseId;

                sqlStmt = "UPDATE EOS.EVENTS SET CASESTATUS = " + CCSCaseState.WaitForDespatch + " WHERE CASEID = " +

                          oldCaseId;



                command.CommandText = sqlStmt;

                if (command.ExecuteNonQuery() <= 0)

@@ -548,8 +565,9 @@
                    return false;

                }



                sqlStmt = "UPDATE OCSDB.SRI SET SCENENAME = '" + newAcceptNum + "' WHERE SCENENAME = (SELECT ACCEPTNUM FROM "

                        + "EOS.EVENTRECORD WHERE CASEID = " + oldCaseId + ")";

                sqlStmt = "UPDATE OCSDB.SRI SET SCENENAME = '" + newAcceptNum +

                          "' WHERE SCENENAME = (SELECT ACCEPTNUM FROM "

                          + "EOS.EVENTRECORD WHERE CASEID = " + oldCaseId + ")";



                command.CommandText = sqlStmt;

                if (command.ExecuteNonQuery() < 0)

@@ -611,8 +629,9 @@
                    //                    return false;

                    //                }



                    sqlStmt = "UPDATE OCSDB.LOCKFEATURE SET DESCRIPTION = '" + newAcceptNum + "' WHERE DESCRIPTION = (SELECT ACCEPTNUM FROM "

                            + "EOS.EVENTRECORD WHERE CASEID = " + oldCaseId + ")";

                    sqlStmt = "UPDATE OCSDB.LOCKFEATURE SET DESCRIPTION = '" + newAcceptNum +

                              "' WHERE DESCRIPTION = (SELECT ACCEPTNUM FROM "

                              + "EOS.EVENTRECORD WHERE CASEID = " + oldCaseId + ")";



                    command.CommandText = sqlStmt;

                    if (command.ExecuteNonQuery() < 0)

@@ -634,14 +653,14 @@
            return true;

        }



        private bool UpdateRecuseOrder(Object.EventRecord mRecord)

        private bool UpdateRecuseOrder(Object.EOSEventRecord eosEventRecord)

        {

            int rank = 999;

            int priority = 1;

            OracleCommand command = null;



            /* 單純的子案件或不需升級的交辦案件,不需要更新EOS.RESCUE_ORDER */

            if ((mRecord.ParentId!= 0) && !(_upLevel))

            if ((eosEventRecord.ParentId != 0) && !(_upLevel))

            {

                return true;

            }

@@ -658,7 +677,9 @@
                if (_upLevel)

                {

                    /* 將原先母案件的編號改為新的母案件編號 */

                    sqlStmt = "UPDATE EOS.RESCUE_ORDER SET CASEID = " + mRecord.CaseId+ " WHERE CASEID = " + mRecord.ParentId                            + " AND DSUFID = " + mRecord.LocateEquipment.GetDsufid();

                    sqlStmt = "UPDATE EOS.RESCUE_ORDER SET CASEID = " + eosEventRecord.CaseId + " WHERE CASEID = " +

                              eosEventRecord.ParentId +

                              " AND DSUFID = " + eosEventRecord.LocateEquipment.DsUfid;



                    command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

                    if (command.ExecuteNonQuery() <= 0)

@@ -671,7 +692,7 @@
                else

                {

                    /* 找出該饋線的等級 */

                    sqlStmt = "SELECT RANK FROM EOS.IMP_FEEDER WHERE FEEDERID = " + mRecord.FdrId;

                    sqlStmt = "SELECT RANK FROM EOS.IMP_FEEDER WHERE FEEDERID = " + eosEventRecord.FdrId;



                    command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);

                    OracleDataReader reader = command.ExecuteReader();

@@ -683,8 +704,9 @@
                    reader.Close();



                    /* 找出同等級饋線中的最大搶修順序號碼 */

                    sqlStmt = "SELECT MAX(PRIORITY) as PRIORITY FROM EOS.RESCUE_ORDER WHERE RANK = " + rank + " AND DSUFID = "

                            + mRecord.LocateEquipment.GetDsufid();

                    sqlStmt = "SELECT MAX(PRIORITY) as PRIORITY FROM EOS.RESCUE_ORDER WHERE RANK = " + rank +

                              " AND DSUFID = "

                              + eosEventRecord.LocateEquipment.DsUfid;



                    command.CommandText = sqlStmt;

                    reader = command.ExecuteReader();

@@ -699,8 +721,8 @@
                    if (priority == 0 && rank > 0)

                    {

                        sqlStmt = "SELECT MAX(PRIORITY) as PRIORITY FROM EOS.RESCUE_ORDER WHERE RANK = "

                                + "(SELECT MAX(RANK) FROM EOS.RESCUE_ORDER WHERE RANK < " + rank + " AND DSUFID = "

                                + mRecord.LocateEquipment.GetDsufid() + ")";

                                  + "(SELECT MAX(RANK) FROM EOS.RESCUE_ORDER WHERE RANK < " + rank + " AND DSUFID = "

                                  + eosEventRecord.LocateEquipment.DsUfid + ")";



                        command.CommandText = sqlStmt;

                        reader = command.ExecuteReader();

@@ -715,13 +737,15 @@


                    /* 如果還是沒找到，就設Priority = 0 (只有當新增案件的Rank為最小時或第一筆案件才可能發生) */

                    if (priority == 0)

                    { // 若不寫清楚會看不懂

                    {

                        // 若不寫清楚會看不懂

                        priority = 0;



                        /* 將搶修順序號碼大於等於找出來號碼的都加1 */

                    }

                    sqlStmt = "UPDATE EOS.RESCUE_ORDER SET PRIORITY = PRIORITY + 1 WHERE PRIORITY > " + priority + " AND DSUFID = "

                            + mRecord.LocateEquipment.GetDsufid();

                    sqlStmt = "UPDATE EOS.RESCUE_ORDER SET PRIORITY = PRIORITY + 1 WHERE PRIORITY > " + priority +

                              " AND DSUFID = "

                              + eosEventRecord.LocateEquipment.DsUfid;



                    command.CommandText = sqlStmt;

                    if (command.ExecuteNonQuery() < 0)

@@ -732,8 +756,9 @@
                    }



                    /* 將本身資料存入資料庫內 */

                    sqlStmt = "INSERT INTO EOS.RESCUE_ORDER (CASEID,RANK,PRIORITY,DSUFID) VALUES (" + mRecord.CaseId+ "," + rank + ","

                            + (priority + 1) + "," + mRecord.LocateEquipment.GetDsufid() + ")";

                    sqlStmt = "INSERT INTO EOS.RESCUE_ORDER (CASEID,RANK,PRIORITY,DSUFID) VALUES (" + eosEventRecord.CaseId +

                              "," + rank + ","

                              + (priority + 1) + "," + eosEventRecord.LocateEquipment.DsUfid + ")";



                    command.CommandText = sqlStmt;

                    if (command.ExecuteNonQuery() <= 0)

@@ -759,7 +784,7 @@
        }



        // 當原先同一用戶在事故受理後又報案，不過從一般案件轉為交辦案件所需作的轉換工作

        private bool DeleteOldCase(Object.EventRecord mRecord)

        private bool DeleteOldCase(Object.EOSEventRecord eosEventRecord)

        {

            string sqlStmt;

            int caseId = 0; // 原先的事故號碼

@@ -769,8 +794,9 @@
            OracleCommand command = null;



            sqlStmt = "SELECT R.CASEID as CASEID,E.CASETYPE as CASETYPE,E.CASESTATUS as CASESTATUS,E.COUNT as COUNT FROM "

                    + "EOS.EVENTRECORD R,EOS.EVENTS E WHERE R.CASEID = E.CASEID AND R.CUSTOMERMETER = '" + mRecord.Meter+ "' AND R.CASEID <> "

                    + mRecord.CaseId+ " AND E.CASESTATUS <= " + CCSCaseState.WaitForSponsor;

                      + "EOS.EVENTRECORD R,EOS.EVENTS E WHERE R.CASEID = E.CASEID AND R.CUSTOMERMETER = '" +

                      eosEventRecord.Meter + "' AND R.CASEID <> "

                      + eosEventRecord.CaseId + " AND E.CASESTATUS <= " + CCSCaseState.WaitForSponsor;



            try

            {

@@ -833,9 +859,10 @@
                    return false;

                }



                if (mRecord.ParentId== caseId)

                { // 原本舊案件為母案件

                    sqlStmt = "SELECT COUNT(*) as COUNT FROM EOS.MERGECASE WHERE PARENTID = " + mRecord.CaseId;

                if (eosEventRecord.ParentId == caseId)

                {

                    // 原本舊案件為母案件

                    sqlStmt = "SELECT COUNT(*) as COUNT FROM EOS.MERGECASE WHERE PARENTID = " + eosEventRecord.CaseId;



                    command.CommandText = sqlStmt;

                    reader = command.ExecuteReader();

@@ -851,8 +878,9 @@
                                return false;



                            case 1: // 子案件為之前受理的同一事故案件

                                sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.OriginalCase + ",COUNT = " + (count + 1)

                                        + ",MERGECASECOUNT = 0 WHERE CASEID = " + mRecord.CaseId;

                                sqlStmt = "UPDATE EOS.EVENTS SET CASETYPE = " + GlobalVariable.OriginalCase +

                                          ",COUNT = " + (count + 1)

                                          + ",MERGECASECOUNT = 0 WHERE CASEID = " + eosEventRecord.CaseId;



                                command.CommandText = sqlStmt;

                                if (command.ExecuteNonQuery() <= 0)

@@ -863,8 +891,9 @@
                                    return false;

                                }



                                sqlStmt = "DELETE EOS.TMPAFFECTCUSTMS WHERE CUSTOMERMETER <> '" + mRecord.Meter+ "' AND CASEID = "

                                        + mRecord.CaseId;

                                sqlStmt = "DELETE EOS.TMPAFFECTCUSTMS WHERE CUSTOMERMETER <> '" + eosEventRecord.Meter +

                                          "' AND CASEID = "

                                          + eosEventRecord.CaseId;



                                command.CommandText = sqlStmt;

                                if (command.ExecuteNonQuery() < 0)

@@ -877,8 +906,9 @@
                                break;



                            default:

                                sqlStmt = "UPDATE EOS.EVENTS SET MERGECASECOUNT = MERGECASECOUNT - 1,COUNT = " + (count + 1) + " WHERE CASEID = "

                                        + mRecord.CaseId;

                                sqlStmt = "UPDATE EOS.EVENTS SET MERGECASECOUNT = MERGECASECOUNT - 1,COUNT = " +

                                          (count + 1) + " WHERE CASEID = "

                                          + eosEventRecord.CaseId;



                                command.CommandText = sqlStmt;

                                if (command.ExecuteNonQuery() < 0)

@@ -925,13 +955,13 @@
            return true;

        }



        private bool InsertIntoSri(Object.EventRecord mRecord)

        private bool InsertIntoSri(Object.EOSEventRecord eosEventRecord)

        {

            int count = 0;

            OracleCommand command = null;

            OracleDataReader reader = null;



            var sqlStmt = "SELECT COUNT(*) as COUNT FROM OCSDB.SRI WHERE SCENENAME = '" + mRecord.AcceptNum+ "'";

            var sqlStmt = "SELECT COUNT(*) AS COUNT FROM OCSDB.SRI WHERE SCENENAME = '" + eosEventRecord.AcceptNum + "'";



            try

            {

@@ -957,7 +987,7 @@
                return true;

            }



            sqlStmt = "INSERT INTO OCSDB.SRI VALUES('" + mRecord.AcceptNum+ "',2,-1)";

            sqlStmt = "INSERT INTO OCSDB.SRI VALUES('" + eosEventRecord.AcceptNum + "',2,-1)";



            try

            {

@@ -978,29 +1008,28 @@
            return true;

        }



        private bool SaveCustomerTel(Object.EventRecord mRecord)

        private bool SaveCustomerTel(Object.EOSEventRecord eosEventRecord)

        {

            string sqlStmt;



            // 無電號資料

            /*

             * if (m_Record.getisReCall() == CCS.GlobalVariable.NotReCall) { return true; }

             */



            // 沒有回覆電話可供回存

            if (mRecord.Tel== null || mRecord.Tel.Trim().Length == 0)

            if (eosEventRecord.Tel == null || eosEventRecord.Tel.Trim().Length == 0)

            {

                return true;

            }



            // 電話資料過長

            if (mRecord.Tel.Trim().Length > 24)

            if (eosEventRecord.Tel.Trim().Length > 24)

            {

                Logger.Warn("電話過長號碼，無法回存資料庫.");

                return true;

            }



            sqlStmt = "UPDATE BASEDB.METER SET TELE_NUMB = '" + mRecord.Tel.Trim() + "' WHERE METR_NUMB = '" + mRecord.Meter+ "'";

            var sqlStmt = "UPDATE BASEDB.METER SET TELE_NUMB = '" + eosEventRecord.Tel.Trim() + "' WHERE METR_NUMB = '" +

                          eosEventRecord.Meter + "'";



            OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);