From b66af4500c0b5d6a923d864eb4047b5150c8aac1 Mon Sep 17 00:00:00 2001 From: ulysseskao <ulysseskao@gmail.com> Date: Tue, 03 May 2016 18:36:24 +0800 Subject: [PATCH] refator code --- CCSTrace/CCS/Object/CCSEventQuery.cs | 319 ++++++++++++++++++++++++++-------------------------- 1 files changed, 160 insertions(+), 159 deletions(-) diff --git a/CCSTrace/CCS/Object/EventQuery.cs b/CCSTrace/CCS/Object/CCSEventQuery.cs similarity index 95% rename from CCSTrace/CCS/Object/EventQuery.cs rename to CCSTrace/CCS/Object/CCSEventQuery.cs index 2c247cb..d514e6e 100644 --- a/CCSTrace/CCS/Object/EventQuery.cs +++ b/CCSTrace/CCS/Object/CCSEventQuery.cs @@ -1,160 +1,161 @@ -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; } - - public string Meter { get; set; } - - public int CaseStatus { get; set; } - - public string ChangeTime { get; set; } - - public string HandlingSummary { get; set; } - - public string AssumedTime { get; set; } - - public string AssumedTimeNth { get; set; } - - public int DelayTimes { get; set; } = 0; - - public string Reason { get; set; } - - public string EventLocation { get; set; } = ""; - - public bool Insert(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) - { - Logger.Error(e, e.Message); - throw; - } - finally - { - command.Dispose(); - } - } - - public bool Update(OracleConnection conn, OracleTransaction transaction) - { - if (!Check()) - { - return false; - } - - 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 + "'"; - - var command = new OracleCommand(sqlStmt, conn, transaction); - - try - { - if (command.ExecuteNonQuery() <= 0) - { - Logger.Error("更新CCS.EVENTQUERY資料失敗."); - return false; - } - } - catch (Exception e) - { - Logger.Error(e, e.Message); - return false; - } - finally - { - command.Dispose(); - } - - return true; - } - - public bool UpdateCaseStatus(OracleConnection conn, OracleTransaction transaction) - { - var sqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS = " + CaseStatus + " WHERE CCSID = '" + CcsId + "'"; - - var command = new OracleCommand(sqlStmt, conn, transaction); - - try - { - if (command.ExecuteNonQuery() <= 0) - { - Logger.Error("更新CCS.EVENTQUERY的CASESTATUS失敗."); - return false; - } - } - catch (Exception e) - { - Logger.Error(e, e.Message); - throw; - } - finally - { - command.Dispose(); - } - - return true; - } - - // Not Null Check - private bool Check() - { - if (CcsId == null) - { - return false; - } - - if (CaseStatus == 0) - { - return false; - } - Reason = Reason ?? ""; - return true; - } - } +using System; +using System.Data.OracleClient; +using NLog; + +namespace CCSTrace.CCS.Object +{ + public class CCSEventQuery + { + private static readonly Logger Logger = LogManager.GetCurrentClassLogger(); + + //private CCS.Function.TransferDate convert = new CCS.Function.TransferDate(); + + public string CcsId { get; set; } + + public string Meter { get; set; } + + public int CaseStatus { get; set; } + + public string ChangeTime { get; set; } + + public string HandlingSummary { get; set; } + + public string AssumedTime { get; set; } + + public string AssumedTimeNth { get; set; } + + public int DelayTimes { get; set; } = 0; + + public string Reason { get; set; } + + public string EventLocation { get; set; } = ""; + + public bool Insert(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) + { + Logger.Error(e, e.Message); + throw; + } + finally + { + command.Dispose(); + } + } + + public bool Update(OracleConnection conn, OracleTransaction transaction) + { + if (!Check()) + { + return false; + } + + 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 + "'"; + + var command = new OracleCommand(sqlStmt, conn, transaction); + + try + { + if (command.ExecuteNonQuery() <= 0) + { + Logger.Error("更新CCS.EVENTQUERY資料失敗."); + return false; + } + } + catch (Exception e) + { + Logger.Error(e, e.Message); + return false; + } + finally + { + command.Dispose(); + } + + return true; + } + + public bool UpdateCaseStatus(OracleConnection conn, OracleTransaction transaction) + { + var sqlStmt = "UPDATE CCS.EVENTQUERY SET CASESTATUS = " + CaseStatus + " WHERE CCSID = '" + CcsId + "'"; + var command = new OracleCommand(sqlStmt, conn, transaction); + + try + { + if (command.ExecuteNonQuery() <= 0) + { + Logger.Error("更新CCS.EVENTQUERY的CASESTATUS失敗."); + return false; + } + } + catch (Exception e) + { + Logger.Error(e, e.Message); + throw; + } + finally + { + command.Dispose(); + } + + return true; + } + + // Not Null Check + private bool Check() + { + if (CcsId == null) + { + return false; + } + + if (CaseStatus == 0) + { + return false; + } + Reason = Reason ?? ""; + return true; + } + } } \ No newline at end of file -- Gitblit v0.0.0-SNAPSHOT