ulysseskao
2016-04-29 b0c18d369abd06075c83759b0e19823c2a11d716
CCSTrace/CCS/Object/EventQuery.cs
@@ -1,138 +1,35 @@
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.HtmlControls;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Data.OracleClient;
namespace CCSTrace.CCS.Object
{
    public class EventQuery
    {
        private String CCSID;
        private String Meter;
        private int CaseStatus;
        private String ChangeTime;
        private String HandlingSummary;
        private String AssumedTime;
        private String AssumedTime_Nth;
        private int DelayTimes = 0;
        private String Reason;
        private String EventLocation = "";
        //private CCS.Function.TransferDate convert = new CCS.Function.TransferDate();
        public EventQuery()
        {
        }
        public string CcsId { get; set; }
        public void setCCSID(String m_CCSID)
        {
            this.CCSID = m_CCSID;
        }
        public string Meter { get; set; }
        public String getCCSID()
        {
            return this.CCSID;
        }
        public int CaseStatus { get; set; }
        public void setMeter(String m_Meter)
        {
            this.Meter = m_Meter;
        }
        public string ChangeTime { get; set; }
        public String getMeter()
        {
            return this.Meter;
        }
        public string HandlingSummary { get; set; }
        /**
         * @return Returns the eventLocation.
         */
        public String getEventLocation()
        {
            return EventLocation;
        }
        public string AssumedTime { get; set; }
        /**
         * @param m_eventLocation The eventLocation to set.
         */
        public void setEventLocation(String m_eventLocation)
        {
            EventLocation = m_eventLocation;
        }
        public string AssumedTimeNth { get; set; }
        public void setCaseStatus(int m_CaseStatus)
        {
            this.CaseStatus = m_CaseStatus;
        }
        public int DelayTimes { get; set; } = 0;
        public void setChangeTime(String m_ChangeTime)
        {
            this.ChangeTime = m_ChangeTime;
        }
        public string Reason { get; set; }
        public String getChangeTime()
        {
            return this.ChangeTime;
        }
        public string EventLocation { get; set; } = "";
        public void setHandlingSummary(String m_HandlingSummary)
        public bool Insert(RecordLog pLog, OracleConnection conn, OracleTransaction transaction)
        {
            this.HandlingSummary = m_HandlingSummary;
        }
        public String getHandlingSummary()
        {
            return this.HandlingSummary;
        }
        public void setAssumedTime(String m_AssumedTime)
        {
            this.AssumedTime = m_AssumedTime;
        }
        public String getAssumedTime()
        {
            return this.AssumedTime;
        }
        public void setAssumedTime_Nth(String m_AssumedTime_Nth)
        {
            this.AssumedTime_Nth = m_AssumedTime_Nth;
        }
        public String getAssumedTime_Nth()
        {
            return this.AssumedTime_Nth;
        }
        public void setDelayTimes(int m_DelayTimes)
        {
            this.DelayTimes = m_DelayTimes;
        }
        public int getDelayTimes()
        {
            return this.DelayTimes;
        }
        public void setReason(String m_Reason)
        {
            this.Reason = m_Reason;
        }
        public String getReason()
        {
            return this.Reason;
        }
        public bool Insert(RecordLog _PLog, OracleConnection _Conn, OracleTransaction _Transaction)
        {
            String SqlStmt;
            string sqlStmt;
            if (!Check())
            {
@@ -141,42 +38,47 @@
            if (Meter == null)
            {
                SqlStmt = "INSERT INTO CCS.EVENTQUERY (CCSID,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" + "'" + CCSID
                        + "'," + CaseStatus + ",to_date('" + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                        + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTime_Nth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
                sqlStmt =
                    $"INSERT INTO CCS.EVENTQUERY (CCSID,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" +
                    "'" + CcsId
                    + "'," + CaseStatus + ",to_date('" + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                    + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTimeNth +
                    "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
            }
            else
            {
                SqlStmt = "INSERT INTO CCS.EVENTQUERY (CCSID,METER,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" + "'"
                        + CCSID + "','" + Meter + "'," + CaseStatus + ",to_date('" + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                        + AssumedTime_Nth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
                sqlStmt =
                    $"INSERT INTO CCS.EVENTQUERY (CCSID,METER,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" +
                    "'"
                    + CcsId + "','" + Meter + "'," + CaseStatus + ",to_date('" + ChangeTime +
                    "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                    + AssumedTimeNth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
            }
            OracleCommand Command = new OracleCommand(SqlStmt, _Conn, _Transaction);
            var command = new OracleCommand(sqlStmt, conn, transaction);
            try
            {
                if (Command.ExecuteNonQuery() > 0)
                if (command.ExecuteNonQuery() > 0)
                    return true;
                else
                    return false;
            }
            catch (Exception e)
            {
                _PLog.Error(e.Message);
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                return false;
            }
            finally
            {
                Command.Dispose();
                command.Dispose();
            }
        }
        public bool Insert(SEventLog _PLog, OracleConnection _Conn, OracleTransaction _Transaction)
        public bool Insert(SEventLog pLog, OracleConnection conn, OracleTransaction transaction)
        {
            String SqlStmt;
            string sqlStmt;
            if (!Check())
            {
@@ -185,107 +87,112 @@
            if (Meter == null)
            {
                SqlStmt = "INSERT INTO CCS.EVENTQUERY (CCSID,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" + "'" + CCSID
                        + "'," + CaseStatus + ",to_date('" + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                        + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTime_Nth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
                sqlStmt =
                    "INSERT INTO CCS.EVENTQUERY (CCSID,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" +
                    "'" + CcsId
                    + "'," + CaseStatus + ",to_date('" + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                    + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTimeNth +
                    "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
            }
            else
            {
                SqlStmt = "INSERT INTO CCS.EVENTQUERY (CCSID,METER,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" + "'"
                        + CCSID + "','" + Meter + "'," + CaseStatus + ",to_date('" + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                        + AssumedTime_Nth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
                sqlStmt =
                    "INSERT INTO CCS.EVENTQUERY (CCSID,METER,CASESTATUS,CHANGETIME,ASSUMEDTIME,ASSUMEDTIME_NTH,DELAYTIMES,REASON,INPUTTIME) values(" +
                    "'"
                    + CcsId + "','" + Meter + "'," + CaseStatus + ",to_date('" + ChangeTime +
                    "','yyyy/mm/dd hh24:mi:ss'),to_date('" + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),to_date('"
                    + AssumedTimeNth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
            }
            OracleCommand Command = new OracleCommand(SqlStmt, _Conn, _Transaction);
            var command = new OracleCommand(sqlStmt, conn, transaction);
            try
            {
                if (Command.ExecuteNonQuery() > 0)
                if (command.ExecuteNonQuery() > 0)
                    return true;
                else
                    return false;
            }
            catch (Exception e)
            {
                _PLog.Error(e.Message);
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                if (LocalVariable.ShowError)
                    _PLog.Error(e.StackTrace);
                if (GlobalVariable.ShowError)
                    pLog.Error(e.StackTrace);
                throw e;
            }
            finally
            {
                Command.Dispose();
                command.Dispose();
            }
        }
        public bool Update(RecordLog _PLog, OracleConnection _Conn, OracleTransaction _Transaction)
        public bool Update(RecordLog pLog, OracleConnection conn, OracleTransaction transaction)
        {
            if (!Check())
            {
                return false;
            }
            String SqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS=" + this.CaseStatus + ",CHANGETIME=to_date('"
                    + this.ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),ASSUMEDTIME=to_date('"
                    + this.AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),ASSUMEDTIME_NTH=to_date('"
                    + this.AssumedTime_Nth + "','yyyy/mm/dd hh24:mi:ss'),DELAYTIMES=" + this.DelayTimes + ",REASON='"
                    + this.Reason + "',EVENTLOCATION ='" + this.EventLocation + "' WHERE CCSID='" + this.CCSID + "'";
            var sqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS=" + CaseStatus + ",CHANGETIME=to_date('"
                          + ChangeTime + "','yyyy/mm/dd hh24:mi:ss'),ASSUMEDTIME=to_date('"
                          + AssumedTime + "','yyyy/mm/dd hh24:mi:ss'),ASSUMEDTIME_NTH=to_date('"
                          + AssumedTimeNth + "','yyyy/mm/dd hh24:mi:ss'),DELAYTIMES=" + DelayTimes + ",REASON='"
                          + Reason + "',EVENTLOCATION ='" + EventLocation + "' WHERE CCSID='" + CcsId + "'";
            OracleCommand Command = new OracleCommand(SqlStmt, _Conn, _Transaction);
            var command = new OracleCommand(sqlStmt, conn, transaction);
            try
            {
                if (Command.ExecuteNonQuery() <= 0)
                if (command.ExecuteNonQuery() <= 0)
                {
                    _PLog.Error("更新CCS.EVENTQUERY資料失敗.");
                    pLog.Error("更新CCS.EVENTQUERY資料失敗.");
                    return false;
                }
            }
            catch (Exception e)
            {
                _PLog.Error(e.Message);
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                return false;
            }
            finally
            {
                Command.Dispose();
                command.Dispose();
            }
            return true;
        }
        public bool UpdateCaseStatus(SEventLog _PLog, OracleConnection _Conn, OracleTransaction _Transaction)
        public bool UpdateCaseStatus(SEventLog pLog, OracleConnection conn, OracleTransaction transaction)
        {
            String SqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS = " + CaseStatus + " WHERE CCSID = '" + CCSID + "'";
            var sqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS = " + CaseStatus + " WHERE CCSID = '" + CcsId + "'";
            OracleCommand Command = new OracleCommand(SqlStmt, _Conn, _Transaction);
            var command = new OracleCommand(sqlStmt, conn, transaction);
            try
            {
                if (Command.ExecuteNonQuery() <= 0)
                if (command.ExecuteNonQuery() <= 0)
                {
                    _PLog.Error("更新CCS.EVENTQUERY的CASESTATUS失敗.");
                    pLog.Error("更新CCS.EVENTQUERY的CASESTATUS失敗.");
                    return false;
                }
            }
            catch (Exception e)
            {
                _PLog.Error(e.Message);
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                if (LocalVariable.ShowError)
                    _PLog.Error(e.StackTrace);
                if (GlobalVariable.ShowError)
                    pLog.Error(e.StackTrace);
                throw e;
            }
            finally
            {
                Command.Dispose();
                command.Dispose();
            }
            return true;
@@ -294,7 +201,7 @@
        // Not Null Check
        private bool Check()
        {
            if (CCSID == null)
            if (CcsId == null)
            {
                return false;
            }
@@ -303,10 +210,8 @@
            {
                return false;
            }
            Reason = (Reason == null ? "" : Reason);
            Reason = Reason ?? "";
            return true;
        }
    }
}
}