ulysseskao
2016-05-01 8f5c8891aba521570fa63c4baf616e3a3c8d9526
CCSTrace/CCS/Object/EventQuery.cs
@@ -1,10 +1,13 @@
using System;
using System.Data.OracleClient;
using NLog;
namespace CCSTrace.CCS.Object
{
    public class EventQuery
    {
        private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
        //private CCS.Function.TransferDate convert = new CCS.Function.TransferDate();
        public string CcsId { get; set; }
@@ -27,56 +30,7 @@
        public string EventLocation { get; set; } = "";
        public bool Insert(RecordLog pLog, OracleConnection conn, OracleTransaction transaction)
        {
            string sqlStmt;
            if (!Check())
            {
                return false;
            }
            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('" + 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('"
                    + AssumedTimeNth + "','yyyy/mm/dd hh24:mi:ss')," + DelayTimes + ",'" + Reason + "',SYSDATE)";
            }
            var command = new OracleCommand(sqlStmt, conn, transaction);
            try
            {
                if (command.ExecuteNonQuery() > 0)
                    return true;
                else
                    return false;
            }
            catch (Exception e)
            {
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                return false;
            }
            finally
            {
                command.Dispose();
            }
        }
        public bool Insert(SEventLog pLog, OracleConnection conn, OracleTransaction transaction)
        public bool Insert(OracleConnection conn, OracleTransaction transaction)
        {
            string sqlStmt;
@@ -115,13 +69,8 @@
            }
            catch (Exception e)
            {
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                if (GlobalVariable.ShowError)
                    pLog.Error(e.StackTrace);
                throw e;
                Logger.Error(e, e.Message);
                throw;
            }
            finally
            {
@@ -129,7 +78,7 @@
            }
        }
        public bool Update(RecordLog pLog, OracleConnection conn, OracleTransaction transaction)
        public bool Update(OracleConnection conn, OracleTransaction transaction)
        {
            if (!Check())
            {
@@ -148,14 +97,13 @@
            {
                if (command.ExecuteNonQuery() <= 0)
                {
                    pLog.Error("更新CCS.EVENTQUERY資料失敗.");
                    Logger.Error("更新CCS.EVENTQUERY資料失敗.");
                    return false;
                }
            }
            catch (Exception e)
            {
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                Logger.Error(e, e.Message);
                return false;
            }
            finally
@@ -166,7 +114,7 @@
            return true;
        }
        public bool UpdateCaseStatus(SEventLog pLog, OracleConnection conn, OracleTransaction transaction)
        public bool UpdateCaseStatus(OracleConnection conn, OracleTransaction transaction)
        {
            var sqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS = " + CaseStatus + " WHERE CCSID = '" + CcsId + "'";
@@ -176,19 +124,14 @@
            {
                if (command.ExecuteNonQuery() <= 0)
                {
                    pLog.Error("更新CCS.EVENTQUERY的CASESTATUS失敗.");
                    Logger.Error("更新CCS.EVENTQUERY的CASESTATUS失敗.");
                    return false;
                }
            }
            catch (Exception e)
            {
                pLog.Error(e.Message);
                Console.WriteLine(e.StackTrace);
                if (GlobalVariable.ShowError)
                    pLog.Error(e.StackTrace);
                throw e;
                Logger.Error(e, e.Message);
                throw;
            }
            finally
            {