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/ProcessEvent.cs | 123 +++++++++++++++++++---------------------
1 files changed, 58 insertions(+), 65 deletions(-)
diff --git a/CCSTrace/CCS/ProcessEvent.cs b/CCSTrace/CCS/ProcessEvent.cs
index eb3c519..6dad3c0 100644
--- a/CCSTrace/CCS/ProcessEvent.cs
+++ b/CCSTrace/CCS/ProcessEvent.cs
@@ -12,13 +12,12 @@
public class ProcessEvent
{
- private static Logger logger = LogManager.GetCurrentClassLogger();
+ private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
private readonly OracleConnection _connectionTpc;
private readonly CcsRecord _mCcsRecord;
private EventRecord _mEventRecord;
- private readonly RecordLog _pLog;
private readonly string _traceConnectionString = string.Empty;
private OracleTransaction _trx;
@@ -27,7 +26,6 @@
_mCcsRecord = record;
_connectionTpc = conn;
_traceConnectionString = traceConnection;
- _pLog = new RecordLog(GlobalVariable.CcsListPath + record.CcsId + ".txt");
}
public event ThreadEndEventHandler ThreadFinish;
@@ -74,47 +72,47 @@
*/
if (InitialEventRecord(_mCcsRecord.CcsId))
{
- var mLeach = new Leach(_connectionTpc, _trx, _traceConnectionString, _pLog); // 案件過濾與合併
- _pLog.Info("過濾案件...");
+ var mLeach = new Leach(_connectionTpc, _trx, _traceConnectionString); // 案件過濾與合併
+ Logger.Info("過濾案件...");
var returnStatus = mLeach.LeachCase(_mEventRecord);
switch (returnStatus)
{
case GlobalVariable.Success:
- _pLog.Info("案件過濾完畢....");
+ Logger.Info("案件過濾完畢....");
Process(GlobalVariable.Success);
break;
case GlobalVariable.NoMeter:
- _pLog.Info("案件過濾完畢,用戶無電號....");
+ Logger.Info("案件過濾完畢,用戶無電號....");
_mEventRecord.TraceFinish = GlobalVariable.TraceFinish;
Process(GlobalVariable.NoMeter);
break;
case GlobalVariable.SameCustomer:
- _pLog.Info("相同用戶重複來電....");
+ Logger.Info("相同用戶重複來電....");
ProcessSameCustomer(_mCcsRecord, _mEventRecord);
break;
case GlobalVariable.NoSupplyElc:
- _pLog.Warn("該饋線未供電,無法作事故案件追蹤合併....");
+ Logger.Warn("該饋線未供電,無法作事故案件追蹤合併....");
_mEventRecord.TraceFinish = GlobalVariable.TraceFinish;
Process(GlobalVariable.NoMeter);
break;
case GlobalVariable.NoSxfmr:
- _pLog.Warn("該案件無變壓器....");
+ Logger.Warn("該案件無變壓器....");
_mEventRecord.TraceFinish = GlobalVariable.TraceFinish;
Process(GlobalVariable.NoMeter);
break;
case GlobalVariable.CaseTypeChanged:
- _pLog.Info("變更案件狀態....");
+ Logger.Info("變更案件狀態....");
Process(GlobalVariable.CaseTypeChanged);
break;
case GlobalVariable.TraceFailure:
- _pLog.Error("故障追蹤錯誤，以一般無電號案件方式受理....");
+ Logger.Error("故障追蹤錯誤，以一般無電號案件方式受理....");
_mEventRecord.TraceFinish = GlobalVariable.TraceFinish;
Process(GlobalVariable.NoMeter);
break;
@@ -130,13 +128,13 @@
_trx.Dispose();
if (returnStatus == GlobalVariable.CaseTransfer)
- _pLog.Error("案件已移轉，此事故案件暫不被受理....");
+ Logger.Error("案件已移轉，此事故案件暫不被受理....");
else if (returnStatus == GlobalVariable.FailureByDb)
- _pLog.Error("資料庫錯誤，此事故案件暫不被受理....");
+ Logger.Error("資料庫錯誤，此事故案件暫不被受理....");
else if (returnStatus == GlobalVariable.FdrLocked)
- _pLog.Error("饋線被鎖定，此事故案件暫不被受理....");
+ Logger.Error("饋線被鎖定，此事故案件暫不被受理....");
else
- _pLog.Error("發生非預期錯誤，此事故案件暫不被受理....");
+ Logger.Error("發生非預期錯誤，此事故案件暫不被受理....");
if (traceCount == 0)
UpdateTraceCount(_mCcsRecord.CcsId, true);
@@ -149,7 +147,7 @@
if (returnStatus == GlobalVariable.TraceCounts3)
_mEventRecord.Note = _mEventRecord.Note+ "(本案用戶供電資料追蹤失敗)";
- _pLog.Error("事故案件處理次數3次，仍無法正常處理，以一般無電號案件方式受理....");
+ Logger.Error("事故案件處理次數3次，仍無法正常處理，以一般無電號案件方式受理....");
_mEventRecord.TraceFinish = GlobalVariable.TraceFinish;
Process(GlobalVariable.NoMeter);
sendMail = true;
@@ -239,8 +237,7 @@
}
catch (Exception e)
{
- Console.WriteLine("Error = " + e.Message + ". CCSID = " + _mCcsRecord.CcsId);
- _pLog.Error("Error = " + e.Message + ". CCSID = " + _mCcsRecord.CcsId);
+ Logger.Error(e, e.Message + ". CCSID = " + _mCcsRecord.CcsId);
if (_trx != null)
{
@@ -256,7 +253,6 @@
}
finally
{
- _pLog.Close();
CcsMain.ProcessCases.Remove(_mCcsRecord.CcsId);
OnThreadFinish(new ThreadEndEvent(_connectionTpc));
}
@@ -271,12 +267,12 @@
try
{
- if (finishEvent.Finish(kind, _mEventRecord, _connectionTpc, _trx, _pLog))
+ if (finishEvent.Finish(kind, _mEventRecord, _connectionTpc, _trx))
{
- _pLog.Info("OMS資料更新成功!");
+ Logger.Info("OMS資料更新成功!");
if (UpdateCcsData(_mEventRecord, _mCcsRecord, (int) CCSCaseState.WaitForDespatch))
{
- _pLog.Info("CCS資料更新成功!");
+ Logger.Info("CCS資料更新成功!");
}
else
{
@@ -284,7 +280,7 @@
_trx.Rollback();
_trx.Dispose();
- _pLog.Error("CCS資料更新程序發生錯誤!");
+ Logger.Error("CCS資料更新程序發生錯誤!");
return;
}
@@ -292,7 +288,7 @@
_trx.Commit();
_trx.Dispose();
;
- var alarmClient = new AlarmData(_connectionTpc, _trx, _pLog);
+ var alarmClient = new AlarmData(_connectionTpc, _trx);
alarmClient.Alarm(_mEventRecord.AcceptNum, _mEventRecord.Dept);
}
else
@@ -303,9 +299,9 @@
_trx.Dispose();
;
- _pLog.Error("OMS資料更新程序發生錯誤!");
+ Logger.Error("OMS資料更新程序發生錯誤!");
}
- _pLog.Info("CCS 案件受理程序結束.");
+ Logger.Info("CCS 案件受理程序結束.");
}
catch (Exception e)
{
@@ -323,7 +319,7 @@
private bool UpdateCcsData(EventRecord mRecord, CcsRecord mCcsRecord, int caseStatus)
{
- _pLog.Info("進行CCS資料更新程序...");
+ Logger.Info("進行CCS資料更新程序...");
var eventQuery = new EventQuery();
var status = caseStatus;
// 設定CCSID
@@ -355,12 +351,12 @@
}
eventQuery.CaseStatus = status;
// 更新CCS.EventQuery
- if (!eventQuery.Update(_pLog, _connectionTpc, _trx))
+ if (!eventQuery.Update(_connectionTpc, _trx))
{
- _pLog.Error("更新ccs.eventquery失敗!");
+ Logger.Error("更新ccs.eventquery失敗!");
return false;
}
- _pLog.Info("更新ccs.eventquery成功!");
+ Logger.Info("更新ccs.eventquery成功!");
var numberContrast = new NumberContrast();
numberContrast.SetAcceptNum(mRecord.AcceptNum);
numberContrast.SetCaseId(mRecord.CaseId);
@@ -368,16 +364,16 @@
// 更新CCS.Num_Contrast
if (!numberContrast.Update(_connectionTpc, _trx))
{
- _pLog.Error("更新ccs.num_contrast失敗!");
+ Logger.Error("更新ccs.num_contrast失敗!");
return false;
}
- _pLog.Info("更新ccs.num_contrast成功!");
+ Logger.Info("更新ccs.num_contrast成功!");
return true;
}
private bool InitialEventRecord(string ccsid)
{
- var initialData = new InitialEventData(_connectionTpc, _pLog);
+ var initialData = new InitialEventData(_connectionTpc);
var mContrast = new NumberContrast();
DeptContrast deptContrast = null;
@@ -394,7 +390,7 @@
if (!mContrast.Insert(_connectionTpc, _trx))
{
- _pLog.Error("初始化寫入CCS.Num_Contrast時發生錯誤！");
+ Logger.Error("初始化寫入CCS.Num_Contrast時發生錯誤！");
if (_trx.Connection.State.ToString().Equals("Open"))
_trx.Rollback();
@@ -435,7 +431,7 @@
if (mAddr.Trim().Length == 0)
{
- _pLog.Error("CCS 案件受理程序初始化失敗...地址為空白");
+ Logger.Error("CCS 案件受理程序初始化失敗...地址為空白");
if (_trx.Connection.State.ToString().Equals("Open"))
_trx.Rollback();
@@ -506,7 +502,7 @@
_mEventRecord.IsReCall = GlobalVariable.NotReCall;
}
- _pLog.Info("初始化EOS.EVENTRECORD成功!");
+ Logger.Info("初始化EOS.EVENTRECORD成功!");
return true;
}
@@ -546,7 +542,7 @@
}
catch (Exception ex)
{
- _pLog.Warn("Problems occur during checking process: " + ex.Message);
+ Logger.Warn(ex, "Problems occur during checking process: " + ex.Message);
}
finally
{
@@ -557,7 +553,7 @@
private int FindoutDeptByAddr(CcsRecord ccsRecord, OracleTransaction trx)
{
- var addrContrast = new AddrContrast(_connectionTpc, trx, _pLog);
+ var addrContrast = new AddrContrast(_connectionTpc, trx);
return addrContrast.FindDeptId(ccsRecord.AddressCity, ccsRecord.AddressTown, ccsRecord.AddressRoad);
}
@@ -596,9 +592,10 @@
status = Convert.ToInt32(reader["CaseStatus"].ToString());
}
}
- catch (Exception)
+ catch (Exception e)
{
- _pLog.Warn("無法取得正確之母案件狀態.");
+ Logger.Error(e, e.Message);
+ Logger.Warn("無法取得正確之母案件狀態.");
}
finally
{
@@ -632,9 +629,10 @@
mEventQry.EventLocation = reader["eventlocation"].ToString();
}
}
- catch (Exception)
+ catch (Exception e)
{
- _pLog.Warn("無法取得母案件派工資訊.");
+ Logger.Error(e, e.Message);
+ Logger.Warn("無法取得母案件派工資訊.");
}
finally
{
@@ -648,7 +646,7 @@
private void ProcessSameCustomer(CcsRecord mCcsRecord, EventRecord mEventRec)
{
- _pLog.Info("處理相同用戶重複來電...");
+ Logger.Info("處理相同用戶重複來電...");
StringBuilder note = null;
var sqlStmt = "select note from eos.eventrecord where caseid = " + mEventRec.TmpCaseId;
@@ -662,8 +660,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
@@ -780,7 +777,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
+ Logger.Error(e, e.Message);
}
finally
{
@@ -792,10 +789,10 @@
}
}
- var updEosEventRecord = "update eos.eventrecord set note = '" + TrimToLimit(note.ToString(), 127)
+ var updEosEventRecord = "UPDATE EOS.EVENTRECORD SET NOTE = '" + TrimToLimit(note.ToString(), 127)
+ "' where caseid = " + _mEventRecord.TmpCaseId;
- var updCcsNumContrast = "update ccs.num_contrast set(acceptnum,caseid) = (select acceptnum," +
- mEventRec.TmpCaseId + " from eos.eventrecord where caseid = " + mEventRec.TmpCaseId+
+ var updCcsNumContrast = "UPDATE CCS.NUM_CONTRAST SET(acceptnum,caseid) = (SELECT acceptnum," +
+ mEventRec.TmpCaseId + " FROM eos.eventrecord WHERE caseid = " + mEventRec.TmpCaseId+
") where ccsid='" + mCcsRecord.CcsId + "'";
var exeCommand = new OracleCommand(updCcsEventQuery, _connectionTpc, _trx);
@@ -808,7 +805,7 @@
_trx.Rollback();
_trx.Dispose();
- _pLog.Error("Fail in write back to ccs.eventquery");
+ Logger.Error("Fail in write back to ccs.eventquery");
return;
}
@@ -822,7 +819,7 @@
_trx.Rollback();
_trx.Dispose();
- _pLog.Error("Fail in update eos.eventquery");
+ Logger.Error("Fail in update eos.eventquery");
return;
}
@@ -835,14 +832,14 @@
_trx.Rollback();
_trx.Dispose();
- _pLog.Error("Fail in insert into ccs.num_contrast");
+ Logger.Error("Fail in insert into ccs.num_contrast");
return;
}
exeCommand.Dispose();
_trx.Commit();
_trx.Dispose();
- _pLog.Info("CCS 案件受理程序結束");
+ Logger.Info("CCS 案件受理程序結束");
}
private string TrimToLimit(string msg, int maxLen)
@@ -857,12 +854,12 @@
{
return msg;
}
- msg = msg.Substring(msg.IndexOf("|") + 1);
+ msg = msg.Substring(msg.IndexOf("|", StringComparison.Ordinal) + 1);
return TrimToLimit(msg, maxLen);
}
- catch (Exception ex)
+ catch (Exception e)
{
- Console.WriteLine(ex.StackTrace);
+ Logger.Error(e, e.Message);
return "";
}
}
@@ -882,8 +879,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
@@ -947,8 +943,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
@@ -973,8 +968,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
@@ -1004,8 +998,7 @@
}
catch (Exception e)
{
- Console.WriteLine(e.Message);
- Console.WriteLine(e.StackTrace);
+ Logger.Error(e, e.Message);
}
finally
{
--
Gitblit v0.0.0-SNAPSHOT