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.Xml;
|
using System.Runtime.CompilerServices;
|
using System.Threading;
|
|
|
namespace CCSTrace.CCS
|
{
|
public class CCSMain
|
{
|
private static CCSMain _instance;
|
public static CCS.Object.CCSCodelist CCSCodelist;
|
public static CCS.Object.EOSCodelist EOSCodelist;
|
public static System.Collections.ArrayList DBConnList = new System.Collections.ArrayList();
|
public static System.Collections.ArrayList ProcessCases = new System.Collections.ArrayList();
|
|
private string LoadFilename = "DBConfig.xml";
|
private string ConnectionString = String.Empty;
|
private string traceConnectionString = String.Empty;
|
private int ConnectionCount = 1;
|
public static System.Data.OracleClient.OracleConnection MainConn = null;
|
static SEventLog _MainLog = null;
|
|
public static System.Collections.Hashtable ProcessFDR = new System.Collections.Hashtable();//Record the processing FDR
|
public static System.Collections.ArrayList WaitingCases = new System.Collections.ArrayList();//Record the case when the case's FDR processed by another
|
|
public CCSMain()
|
{
|
Initial();
|
}
|
|
public static CCSMain Instance()
|
{
|
|
// Uses lazy initialization.
|
|
// Note: this is not thread safe.
|
|
if (_instance == null)
|
{
|
_instance = new CCSMain();
|
|
}
|
return _instance;
|
|
}
|
|
private void Initial()
|
{
|
_MainLog = new SEventLog();
|
|
try
|
{
|
ReadXML();
|
|
if (MainConn == null)
|
MainConn = CreateConnection();
|
//MainConn = CreateMainConnection();
|
|
CCSCodelist = new CCSTrace.CCS.Object.CCSCodelist(MainConn);
|
EOSCodelist = new CCSTrace.CCS.Object.EOSCodelist(MainConn);
|
|
for (int i = 0; i < ConnectionCount; i++)
|
DBConnList.Add(CreateConnection());
|
}
|
catch(Exception e)
|
{
|
Console.WriteLine(e.Message);
|
Console.WriteLine(e.StackTrace);
|
_MainLog.Error(e.Message);
|
|
if (LocalVariable.ShowError)
|
_MainLog.Error(e.StackTrace);
|
|
throw e;
|
}
|
finally
|
{
|
_MainLog.Close();
|
}
|
|
Object.CCSRecord m_Record = getWaitRecord();
|
|
if (m_Record != null)
|
{
|
System.Data.OracleClient.OracleConnection _Conn = (System.Data.OracleClient.OracleConnection)DBConnList[0];
|
DBConnList.Remove(_Conn);
|
|
ProcessCase(m_Record, _Conn);
|
}
|
|
}
|
|
public void AcceptEvent(Object.CCSRecord _Record)
|
{
|
int i = 0;
|
int ReConnectCount = 1;
|
|
|
while ( i <= ReConnectCount )
|
{
|
try
|
{
|
if (InsertEventRecord(_Record))
|
{
|
if (DBConnList.Count > 0)
|
{
|
|
//將EVETNQUERY的案件狀態改為開始處理
|
Object.CCSRecord m_Record = getWaitRecord();
|
|
if (m_Record != null)
|
{
|
System.Data.OracleClient.OracleConnection _Conn = (System.Data.OracleClient.OracleConnection)DBConnList[0];
|
DBConnList.Remove(_Conn);
|
|
ProcessCase(m_Record, _Conn);
|
}
|
}
|
|
break;
|
}
|
}
|
catch (Exception ex)
|
{
|
if (MainConn.State.ToString().Equals("Closed"))
|
{
|
i++;
|
if (i > ReConnectCount)
|
throw ex;
|
}
|
else
|
throw ex;
|
}
|
}
|
|
|
}
|
|
private void ReadXML()
|
{
|
XmlReader reader = null;
|
|
try
|
{
|
// 建立 XML 讀取器
|
XmlReaderSettings settings = new XmlReaderSettings();
|
settings.IgnoreComments = true; // 不處理註解
|
settings.IgnoreWhitespace = true; // 跳過空白
|
settings.ValidationType = ValidationType.None; // 不驗證任何資料
|
reader = XmlTextReader.Create(System.AppDomain.CurrentDomain.BaseDirectory + "\\" + LoadFilename, settings);
|
|
// 進入讀取主要部分
|
while (reader.Read())
|
{
|
switch (reader.NodeType)
|
{
|
case XmlNodeType.Element:
|
string LocalName = reader.LocalName; // 取得標籤名稱
|
|
// Step 3: 讀取 FileInfo 標籤的屬性
|
if (LocalName.Equals("DBSetting"))
|
{
|
ConnectionString = String.Format("Data source={0};User Id={1};Password={2};", reader["DataSource"], reader["UserId"], reader["Password"]) ;
|
traceConnectionString = String.Format("{0}/{1}@{2}", reader["UserId"], reader["Password"], reader["DataSource"]);
|
ConnectionCount = Int32.Parse(reader["ConnectionCount"]);
|
LocalVariable.ShowError = bool.Parse(reader["ShowError"]);
|
}
|
|
break;
|
}
|
}
|
reader.Close();
|
|
}
|
catch (System.Xml.XmlException xe)
|
{
|
Console.WriteLine(xe.StackTrace);
|
reader.Close();
|
}
|
}
|
|
private System.Data.OracleClient.OracleConnection CreateConnection()
|
{
|
System.Data.OracleClient.OracleConnection DBConn = new System.Data.OracleClient.OracleConnection(ConnectionString);
|
|
DBConn.Open();
|
|
return DBConn;
|
}
|
|
[MethodImpl(MethodImplOptions.Synchronized)]
|
private bool InsertEventRecord(Object.CCSRecord _Record)
|
{
|
Object.EventQuery _EventQuery = null;
|
System.Data.OracleClient.OracleTransaction _Transaction = null;
|
|
try
|
{
|
_MainLog = new SEventLog();
|
|
if (MainConn.State.ToString().Equals("Closed"))
|
MainConn.Open();
|
|
_Transaction = MainConn.BeginTransaction();
|
|
if (_Record.InsertDB(MainConn, _Transaction, _MainLog))
|
{
|
_EventQuery = new CCSTrace.CCS.Object.EventQuery();
|
|
_EventQuery.setCCSID(_Record.getCCSID());
|
_EventQuery.setMeter(_Record.getMeter());
|
_EventQuery.setCaseStatus(LocalVariable.EventInitial);
|
_EventQuery.setChangeTime(_Record.getAcceptTime());
|
|
if (_EventQuery.Insert(_MainLog, MainConn, _Transaction))
|
_Transaction.Commit();
|
else
|
{
|
if (_Transaction.Connection.State.ToString().Equals("Open"))
|
_Transaction.Rollback();
|
|
throw new Exception("案件未受理成功。");
|
}
|
}
|
else
|
{
|
if (_Transaction.Connection.State.ToString().Equals("Open"))
|
_Transaction.Rollback();
|
|
throw new Exception("案件未受理成功。");
|
}
|
|
}
|
catch (System.Data.OracleClient.OracleException e)
|
{
|
Console.WriteLine(e.Message);
|
Console.WriteLine(e.StackTrace);
|
_MainLog.Error(e.Message);
|
|
if (LocalVariable.ShowError)
|
_MainLog.Error(e.StackTrace);
|
|
if (_Transaction != null && _Transaction.Connection.State.ToString().Equals("Open") )
|
_Transaction.Rollback();
|
|
throw e;
|
}
|
catch(Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
Console.WriteLine(ex.StackTrace);
|
_MainLog.Error(ex.Message);
|
|
if (LocalVariable.ShowError)
|
_MainLog.Error(ex.StackTrace);
|
|
if (_Transaction != null && _Transaction.Connection.State.ToString().Equals("Open") )
|
_Transaction.Rollback();
|
|
throw ex;
|
}
|
finally
|
{
|
_MainLog.Close();
|
}
|
|
return true;
|
}
|
|
delegate void WorkerThreadHandler();
|
|
private void ProcessCase(Object.CCSRecord _Record, System.Data.OracleClient.OracleConnection _Conn)
|
{
|
try
|
{
|
if (_Conn.State.ToString().Equals("Closed"))
|
_Conn.Open();
|
|
ProcessEvent _ProcessEvent = new ProcessEvent(_Record, _Conn, traceConnectionString);
|
_ProcessEvent.ThreadFinish += new ThreadEndEventHandler(ThreadEndEventProcess);
|
|
System.Threading.ThreadStart _ThreadStart = new System.Threading.ThreadStart(_ProcessEvent.Run);
|
System.Threading.Thread _Thread = new System.Threading.Thread(_ThreadStart);
|
_Thread.Start();
|
}
|
catch
|
{
|
DBConnList.Add(_Conn);
|
}
|
}
|
|
private void ThreadEndEventProcess(object sender, ThreadEndEvent e)
|
{
|
//將EVETNQUERY的案件狀態改為開始處理
|
Object.CCSRecord m_Record = getWaitRecord();
|
|
try
|
{
|
if (m_Record != null)
|
ProcessCase(m_Record, e.getConnection());
|
else
|
DBConnList.Add(e.getConnection());
|
}
|
catch
|
{
|
DBConnList.Add(e.getConnection());
|
}
|
}
|
|
[MethodImpl(MethodImplOptions.Synchronized)]
|
private Object.CCSRecord getWaitRecord()
|
{
|
String ProcessCCSID = "";
|
String CCSID = "";
|
Object.CCSRecord _Record = null;
|
|
foreach (String[] Obj in WaitingCases)
|
{
|
String _CCSID = Obj[0];
|
String _FDRID = Obj[1];
|
|
if (ProcessFDR.ContainsKey(_FDRID)) //該條饋線仍有案件在處理中
|
ProcessCCSID = ProcessCCSID + "'" + _CCSID + "',";
|
else
|
{
|
CCSID = _CCSID;
|
WaitingCases.Remove(Obj);
|
break;
|
}
|
}
|
|
if (CCSID.Length == 0) //沒有因同饋線而在等候中的案件
|
{
|
String SqlStmt = "SELECT Q.CCSID AS CCSID FROM CCS.EVENTQUERY Q,CCS.EVENTRECORD R WHERE Q.CASESTATUS IN (" + LocalVariable.EventInitial + "," + LocalVariable.EventProcess + ")";
|
System.Collections.IEnumerator Enum = ProcessCases.GetEnumerator();
|
|
while (Enum.MoveNext())
|
ProcessCCSID = ProcessCCSID + "'" + Enum.Current.ToString() + "',";
|
|
if (ProcessCCSID.Length != 0)
|
SqlStmt = SqlStmt + " AND Q.CCSID NOT IN (" + ProcessCCSID.Substring(0, ProcessCCSID.Length - 1) + ")";
|
|
SqlStmt = SqlStmt + " AND Q.CCSID = R.CCSID AND ROWNUM < 2 ORDER BY Q.ChangeTime";
|
System.Data.OracleClient.OracleCommand Command = new System.Data.OracleClient.OracleCommand(SqlStmt, MainConn);
|
System.Data.OracleClient.OracleDataReader reader = Command.ExecuteReader();
|
|
try
|
{
|
if (reader.Read())
|
CCSID = reader["CCSID"].ToString();
|
}
|
catch (Exception e)
|
{
|
Log(e.Message);
|
_MainLog.Error("無法取得等候處理CCS案件資料。錯誤訊息 = " + e.Message);
|
|
if (LocalVariable.ShowError)
|
_MainLog.Error(e.StackTrace);
|
}
|
finally
|
{
|
reader.Close();
|
Command.Dispose();
|
}
|
}
|
|
if (CCSID.Length != 0)
|
_Record = new Object.CCSRecord(CCSID, MainConn, _MainLog);
|
|
if (_Record != null)
|
{
|
CCS.Object.EventQuery EventQuery = new CCSTrace.CCS.Object.EventQuery();
|
//先將EVETNQUERY的案件狀態改為開始處理
|
EventQuery.setCCSID(_Record.getCCSID());
|
EventQuery.setCaseStatus(LocalVariable.EventProcess);
|
|
System.Data.OracleClient.OracleTransaction _Transaction = MainConn.BeginTransaction();
|
|
try
|
{
|
|
if (EventQuery.UpdateCaseStatus(_MainLog, MainConn, _Transaction))
|
{
|
_MainLog.Info("更新EVENTQUERY的案件狀態為處理中.(CCSID = " + _Record.getCCSID() + ")");
|
_Transaction.Commit();
|
ProcessCases.Add(_Record.getCCSID());
|
}
|
else
|
{
|
_MainLog.Error("無法更新EVENTQUERY的案件狀態.(CCSID = " + _Record.getCCSID() + ")");
|
|
if (_Transaction.Connection.State.ToString().Equals("Open"))
|
_Transaction.Rollback();
|
}
|
}
|
catch (Exception e)
|
{
|
if (_Transaction.Connection.State.ToString().Equals("Open"))
|
_Transaction.Rollback();
|
|
Log(e.Message);
|
_Record = null;
|
}
|
}
|
|
return _Record;
|
}
|
|
private void Log(String message)
|
{
|
RecordLog _PLog = null;
|
try
|
{
|
_PLog = new RecordLog(CCS.LocalVariable.CCS_ListPath + "MAIN.txt");
|
_PLog.Error(message);
|
}
|
finally
|
{
|
if (_PLog != null)
|
{
|
_PLog.Close();
|
}
|
}
|
}
|
|
}
|
}
|
