From 8f5c8891aba521570fa63c4baf616e3a3c8d9526 Mon Sep 17 00:00:00 2001
From: ulysseskao <ulysseskao@gmail.com>
Date: Sun, 01 May 2016 01:12:51 +0800
Subject: [PATCH] update for logger
---
CCSTrace/CCS/Function/Leach.cs | 82 ++++++++++++++++++++---------------------
1 files changed, 40 insertions(+), 42 deletions(-)
diff --git a/CCSTrace/CCS/Function/Leach.cs b/CCSTrace/CCS/Function/Leach.cs
index e5aa02d..21312e1 100644
--- a/CCSTrace/CCS/Function/Leach.cs
+++ b/CCSTrace/CCS/Function/Leach.cs
@@ -2,23 +2,24 @@
using System.Data.OracleClient;
using CCSTrace.CCS.Domain;
+using NLog;
namespace CCSTrace.CCS.Function
{
public class Leach
{
+ private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
+
private readonly MergeCase _mergeCase = new MergeCase();
- private readonly RecordLog _pLog;
private readonly OracleConnection _connectionTpc;
private readonly OracleTransaction _transaction;
private readonly string _traceConnectionString;
- public Leach(OracleConnection conn, OracleTransaction trx, string traceConnection, RecordLog log)
+ public Leach(OracleConnection conn, OracleTransaction trx, string traceConnection)
{
_connectionTpc = conn;
_transaction = trx;
_traceConnectionString = traceConnection;
- _pLog = log;
}
public int LeachCase(Object.EventRecord mNewRec)
@@ -58,7 +59,7 @@
int importCase = -1;
int tmpCaseId = 0;
int caseType = -1;
- _pLog.Info("利用電號或地址檢查是否有已成立之案件.");
+ Logger.Info("利用電號或地址檢查是否有已成立之案件.");
// 檢查資料庫中此電號或地址是否已成立案件
if (mNewRec.Meter.Trim().Length != 0)
@@ -83,13 +84,12 @@
tmpCaseId = Convert.ToInt32(reader["CASEID"].ToString());
caseType = Convert.ToInt32(reader["CASETYPE"].ToString());
mNewRec.TmpCaseId = tmpCaseId;
- _pLog.Info("案件已成立:" + reader["ACCEPTNUM"].ToString() + " " + tmpCaseId + " " + caseType);
+ Logger.Info("案件已成立:" + reader["ACCEPTNUM"].ToString() + " " + tmpCaseId + " " + caseType);
}
}
catch (Exception e)
{
- _pLog.Error(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e.Message);
return GlobalVariable.FailureByDb;
}
finally
@@ -118,10 +118,10 @@
break;
default:
- _pLog.Error("無法辨別案件種類.");
+ Logger.Error("無法辨別案件種類.");
return GlobalVariable.FailureByDb;
}
- _pLog.Info("檢查該案件有無切開關紀錄.");
+ Logger.Info("檢查該案件有無切開關紀錄.");
try
{
@@ -133,7 +133,7 @@
// 有開關尚未恢復
if (reader["CLOSETIME"] == null)
{
- _pLog.Info("有切開關且尚未恢復.");
+ Logger.Info("有切開關且尚未恢復.");
if ((mNewRec.ImportCase== importCase) || (importCase == GlobalVariable.IsImportCase))
{
mResult = AddCount(tmpCaseId);
@@ -146,7 +146,7 @@
else
{
// 開關都已恢復(同用戶須重新受理)
- _pLog.Info("有切開關且已經恢復.");
+ Logger.Info("有切開關且已經恢復.");
int caseId;
// 找出案件編號需以母案件編號或該案件編號去找casestatus
@@ -172,7 +172,7 @@
else
{
// 未切過開關
- _pLog.Info("無切開關紀錄.");
+ Logger.Info("無切開關紀錄.");
if ((mNewRec.ImportCase== importCase) || (importCase == GlobalVariable.IsImportCase))
{
mResult = AddCount(tmpCaseId);
@@ -204,8 +204,7 @@
}
catch (Exception e)
{
- _pLog.Error(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
return GlobalVariable.FailureByDb;
}
finally
@@ -218,18 +217,16 @@
private int AddCount(int mCaseId)
{
- string sqlStmt = "UPDATE EOS.EVENTS SET COUNT = COUNT + 1 WHERE CASEID = " + mCaseId;
+ var sqlStmt = "UPDATE EOS.EVENTS SET COUNT = COUNT + 1 WHERE CASEID = " + mCaseId;
OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);
try
{
- if (command.ExecuteNonQuery() > 0)
- return GlobalVariable.SameCustomer;
- else
- return GlobalVariable.FailureByDb;
+ return command.ExecuteNonQuery() > 0 ? GlobalVariable.SameCustomer : GlobalVariable.FailureByDb;
}
- catch (Exception)
+ catch (Exception e)
{
+ Logger.Warn(e, e.Message);
return GlobalVariable.FailureByDb;
}
finally
@@ -240,10 +237,9 @@
private int GetCastStatus(int caseId)
{
- string sqlStmt;
int status = 0;
- sqlStmt = "SELECT CASESTATUS FROM CCS.EVENTQUERY WHERE CCSID IN (SELECT CCSID FROM CCS.NUM_CONTRAST " + "WHERE CASEID = " + caseId + ")";
+ var sqlStmt = "SELECT CASESTATUS FROM CCS.EVENTQUERY WHERE CCSID IN (SELECT CCSID FROM CCS.NUM_CONTRAST " + "WHERE CASEID = " + caseId + ")";
OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc, _transaction);
OracleDataReader reader = null;
@@ -256,8 +252,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
@@ -285,30 +280,32 @@
{
mNewRec.LocateEquipment.SetFsc(GlobalVariable.Breaker);
mNewRec.LocateEquipment.SetUfid(mNewRec.Ufid);
- _pLog.Info("饋線全停:" + mNewRec.Fsc+ ", " + mNewRec.Ufid);
- _mergeCase.Merge(mNewRec, _connectionTpc, _transaction, _traceConnectionString, _pLog);
+ Logger.Info("饋線全停:" + mNewRec.Fsc+ ", " + mNewRec.Ufid);
+ _mergeCase.Merge(mNewRec, _connectionTpc, _transaction, _traceConnectionString);
return GlobalVariable.Success;
}
}
- catch (EventAI.TraceLoopException)
+ catch (EventAI.TraceLoopException e)
{
+ Logger.Warn(e, e.Message);
return GlobalVariable.TraceCounts3;
}
- catch (TraceException)
+ catch (TraceException e)
{
+ Logger.Warn(e, e.Message);
return GlobalVariable.TraceFailure;
}
catch (Exception ex)
{
- _pLog.Error(ex.Message);
+ Logger.Error(ex, ex.Message);
return GlobalVariable.FailureByDb;
}
try
{
- _pLog.Info("定位損壞設備!");
+ Logger.Info("定位損壞設備!");
int result = GetEquipment(mNewRec);
- _pLog.Info("FSC:" + mNewRec.Fsc+ ", Ufid:" + mNewRec.Ufid+ ", Tpclid:" + mNewRec.Tpclid+ ", FeederID:" + mNewRec.FdrId);
+ Logger.Info("FSC:" + mNewRec.Fsc+ ", Ufid:" + mNewRec.Ufid+ ", Tpclid:" + mNewRec.Tpclid+ ", FeederID:" + mNewRec.FdrId);
switch (result)
{ // get fsc,ufid,fdrid of sxfmr by meter
@@ -324,12 +321,12 @@
if (mNewRec.Brief.Length != 0 && mNewRec.Brief.Substring(0, 1).Equals("A"))
{ // A類事故原因,做追蹤合併
- _pLog.Info("<A類案件>");
- _mergeCase.Merge(mNewRec, _connectionTpc, _transaction, _traceConnectionString, _pLog);
+ Logger.Info("<A類案件>");
+ _mergeCase.Merge(mNewRec, _connectionTpc, _transaction, _traceConnectionString);
}
else
{
- _pLog.Info("<非A類案件>");
+ Logger.Info("<非A類案件>");
}
if (changeCaseType)
@@ -352,17 +349,19 @@
break;
}
}
- catch (EventAI.TraceLoopException)
+ catch (EventAI.TraceLoopException e)
{
+ Logger.Warn(e, e.Message);
return GlobalVariable.TraceCounts3;
}
- catch (TraceException)
+ catch (TraceException e)
{
+ Logger.Warn(e, e.Message);
mResult = GlobalVariable.TraceFailure;
}
catch (Exception ex1)
{
- _pLog.Error(ex1.Message);
+ Logger.Error(ex1, ex1.Message);
mResult = GlobalVariable.FailureByDb;
}
return mResult;
@@ -408,7 +407,7 @@
}
catch (Exception e)
{
- _pLog.Error(e.Message);
+ Logger.Error(e.Message);
Console.WriteLine(e.StackTrace);
return GlobalVariable.FailureByDb;
}
@@ -452,7 +451,7 @@
}
catch (Exception ex)
{
- _pLog.Error(ex.Message);
+ Logger.Error(ex, ex.Message);
}
finally
{
@@ -494,7 +493,7 @@
}
catch (Exception ex)
{
- _pLog.Error(ex.Message);
+ Logger.Error(ex, ex.Message);
return GlobalVariable.FailureByDb;
}
finally
@@ -532,8 +531,7 @@
}
catch (Exception e)
{
- _pLog.Error(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
--
Gitblit v0.0.0-SNAPSHOT