using System;
|
using System.Data.OracleClient;
|
using System.Runtime.CompilerServices;
|
using NLog;
|
|
namespace CCSTrace.CCS.Function
|
{
|
public class InitialEventData
|
{
|
private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
|
|
private string _mAcceptNum = "";
|
private int _mCaseId = 0;
|
private int _mYear = 0;
|
private bool _mChangeYear = false;
|
private string _mNowYear = string.Empty;
|
private readonly string _mAcceptTime = "";
|
private readonly OracleConnection _connectionTpc;
|
|
//New CaseID and New AcceptNum must be seen by others,so it need not controled by transaction
|
[MethodImpl(MethodImplOptions.Synchronized)]
|
public InitialEventData(OracleConnection conn)
|
{
|
_connectionTpc = conn;
|
|
var sqlStmt = "SELECT ACCEPTNUM,CASEID,YEAR,TO_CHAR(SYSDATE,'YYYY/MM/DD') as ACCEPTTIME FROM EOS.EVENTNUM";
|
|
OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc);
|
OracleDataReader reader = command.ExecuteReader();
|
|
try
|
{
|
if (reader.Read())
|
{
|
_mAcceptNum = reader["ACCEPTNUM"].ToString();
|
_mCaseId = Convert.ToInt32(reader["CASEID"].ToString());
|
_mYear = Convert.ToInt32(reader["YEAR"].ToString());
|
_mAcceptTime = reader["ACCEPTTIME"].ToString();
|
}
|
else
|
{
|
Logger.Error("起始號碼資料遺失!");
|
return;
|
}
|
}
|
catch (Exception e)
|
{
|
Logger.Error(e, "Problems occur when Initializing EventData: " + e.Message);
|
Console.WriteLine(e.StackTrace);
|
return;
|
}
|
finally
|
{
|
reader.Close();
|
command.Dispose();
|
}
|
|
CheckAcceptNum();
|
|
while (!UpdateDataBase(_mChangeYear))
|
{
|
RegetNumber();
|
CheckAcceptNum();
|
}
|
}
|
|
public int GetNewCaseId()
|
{
|
return _mCaseId;
|
}
|
|
public string GetNewAcceptNum()
|
{
|
return _mAcceptNum;
|
}
|
|
private bool UpdateDataBase(bool mChangeYear)
|
{
|
string sqlStmt;
|
bool mResult = false;
|
|
if (mChangeYear)
|
sqlStmt = "UPDATE EOS.EVENTNUM SET ACCEPTNUM = '" + (Convert.ToInt32(_mAcceptNum) + 1).ToString() + "',CASEID = "
|
+ (_mCaseId + 1) + ",YEAR = " + _mNowYear + " WHERE CASEID = " + _mCaseId;
|
else
|
sqlStmt = "UPDATE EOS.EVENTNUM SET ACCEPTNUM = '" + (Convert.ToInt32(_mAcceptNum) + 1).ToString() + "',CASEID = "
|
+ (_mCaseId + 1) + " WHERE CASEID = " + _mCaseId + " AND ACCEPTNUM = '" + _mAcceptNum + "'";
|
|
OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc);
|
|
try
|
{
|
if (command.ExecuteNonQuery() > 0)
|
mResult = true;
|
}
|
catch (Exception e)
|
{
|
Logger.Error(e, "Problems occur during EventNumCreating: " + e.Message);
|
throw;
|
}
|
finally
|
{
|
command.Dispose();
|
}
|
|
return mResult;
|
}
|
|
private void CheckAcceptNum()
|
{
|
int nowYear = Convert.ToInt32(_mAcceptTime.Substring(0, 4)) - 1911;
|
int nowMonth = Convert.ToInt32(_mAcceptTime.Substring(5, 2));
|
string tmp = _mAcceptNum;
|
|
if (Convert.ToInt32(tmp.Substring(0, 3)) == nowYear)
|
{
|
if (Convert.ToInt32(tmp.Substring(3, 2)) != nowMonth)
|
{
|
// 新月份
|
if (nowMonth < 10)
|
_mAcceptNum = nowYear.ToString() + "0" + nowMonth.ToString() + "0001";
|
else
|
_mAcceptNum = nowYear.ToString() + nowMonth.ToString() + "0001";
|
}
|
}
|
else
|
{
|
_mAcceptNum = nowYear.ToString() + "010001"; // 新年度
|
_mNowYear = nowYear.ToString();
|
_mChangeYear = true;
|
}
|
|
if (!_mChangeYear)
|
{
|
}
|
}
|
|
private void RegetNumber()
|
{
|
var sqlStmt = "SELECT ACCEPTNUM,CASEID,YEAR FROM EOS.EVENTNUM";
|
OracleCommand command = new OracleCommand(sqlStmt, _connectionTpc);
|
OracleDataReader reader = command.ExecuteReader();
|
|
try
|
{
|
if (reader.Read())
|
{
|
_mAcceptNum = reader["ACCEPTNUM"].ToString();
|
_mCaseId = Convert.ToInt32(reader["CASEID"].ToString());
|
_mYear = Convert.ToInt32(reader["YEAR"].ToString());
|
}
|
}
|
catch (Exception e)
|
{
|
Console.WriteLine(e.Message);
|
Console.WriteLine(e.StackTrace);
|
}
|
finally
|
{
|
reader.Close();
|
command.Dispose();
|
}
|
}
|
}
|
}
|
