using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data.OracleClient;
|
using System.Net;
|
using System.Net.Sockets;
|
using CCSTrace.TPower.DMMS.Model.CCS;
|
using NLog;
|
|
namespace CCSTrace.CCS.Object
|
{
|
public class AlarmData
|
{
|
private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
|
|
public static AlarmData Instance { get; } = new AlarmData();
|
|
private readonly Dictionary<int, ALARMIP> _totalAddrData = new Dictionary<int, ALARMIP>();
|
|
private AlarmData()
|
{
|
}
|
|
public void Initialize(OracleConnection conn)
|
{
|
var sqlStmt = "SELECT DEPTID,IP1,IP2,IP_PATROL FROM CCS.ALARM_IP";
|
OracleCommand command = new OracleCommand(sqlStmt, conn);
|
OracleDataReader reader = command.ExecuteReader();
|
|
try
|
{
|
while (reader.Read())
|
{
|
ALARMIP tmp = new ALARMIP
|
{
|
DEPTID = Convert.ToInt32(reader["DEPTID"].ToString()),
|
IP1 = reader["IP1"].ToString(),
|
IP2 = reader["IP2"].ToString(),
|
IPPATROL = reader["IP_Patrol"].ToString()
|
};
|
|
_totalAddrData.Add(tmp.DEPTID, tmp);
|
}
|
}
|
catch (Exception e)
|
{
|
Logger.Error(e, "Problems occur when fetch alarm data: (" + e.Message + ")");
|
}
|
finally
|
{
|
reader.Close();
|
command.Dispose();
|
}
|
}
|
|
private int GetSscCode(int mScCode, int mWeek)
|
{
|
int ssccode = mScCode;
|
|
/* DateTime stime = DateTime.Now;
|
|
DateTime endtime = DateTime.Now;
|
|
String SqlStmt = "select g.ssc_code as SSCCODE,t.begintime as BEGINTIME,t.endtime as ENDTIME,t.week as WEEK from ccs.scgroup g,ccs.scgrouptime t where g.groupid=t.groupid and g.sc_code="
|
+ m_SCCode + " and t.week=" + m_Week;
|
|
try {
|
OracleCommand Command = new OracleCommand(SqlStmt, _ConnectionTPC);
|
OracleDataReader reader = Command.ExecuteReader();
|
|
while (reader.Read())
|
{
|
stime.set(Calendar.DAY_OF_WEEK, Rs.getInt("WEEK"));
|
endtime.set(Calendar.DAY_OF_WEEK, Rs.getInt("WEEK"));
|
stime.set(Calendar.HOUR_OF_DAY, Rs.getInt("BEGINTIME"));
|
endtime.set(Calendar.HOUR_OF_DAY, Rs.getInt("ENDTIME"));
|
|
if (stime.after(endtime))
|
endtime.roll(Calendar.DAY_OF_WEEK, 1);
|
|
if (stime.before(nowtime) && (endtime.after(nowtime)))
|
ssccode = Rs.getInt("SSCCODE");
|
}
|
reader.Close();
|
Command.Dispose();
|
} catch (Exception ex) {
|
_PLog.warn("無法取得SSCCode,以該案件所屬SCCode代替: (" + ex.Message + ")");
|
}*/
|
return ssccode;
|
}
|
|
private ALARMIP GetIpAddress(int deptCode)
|
{
|
return _totalAddrData[deptCode];
|
}
|
|
public bool Alarm(OracleConnection conn, OracleTransaction trx, string acceptNum, int dept)
|
{
|
Logger.Info("開始Alarm...");
|
Socket clientSocket;
|
ALARMIP alarmip = GetIpAddress(GetSscCode(dept, Convert.ToInt32(DateTime.Now.DayOfWeek)));
|
string ip1;
|
string ip2;
|
string ipPatrol;
|
System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
|
|
if (alarmip != null)
|
{
|
Logger.Info("已取得該部門所需通知的IP Address.");
|
ip1 = alarmip.IP1;
|
ip2 = alarmip.IP2;
|
ipPatrol = alarmip.IPPATROL;
|
}
|
else
|
{
|
Logger.Warn("無法取得該部門所需通知的IP Address!");
|
return false;
|
}
|
|
try
|
{
|
IPAddress serverIp = IPAddress.Parse(ip1);
|
var serverPort = Convert.ToInt32(GlobalVariable.AlermPort);
|
IPEndPoint iep = new IPEndPoint(serverIp, serverPort);
|
|
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
clientSocket.Connect(iep);
|
|
byte[] byteMessage = encoding.GetBytes(acceptNum);
|
|
clientSocket.Send(byteMessage);
|
clientSocket.Shutdown(SocketShutdown.Both);
|
clientSocket.Close();
|
RecordAlarmIp(conn, trx, acceptNum, ip1);
|
Logger.Info("已成功通知" + ip1 + " !");
|
return true;
|
}
|
catch (Exception e)
|
{
|
Logger.Warn("無法通知" + ip1 + ": " + e.Message);
|
}
|
|
try
|
{
|
IPAddress serverIp = IPAddress.Parse(ip2);
|
var serverPort = Convert.ToInt32(GlobalVariable.AlermPort);
|
IPEndPoint iep = new IPEndPoint(serverIp, serverPort);
|
|
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
clientSocket.Connect(iep);
|
|
byte[] byteMessage = encoding.GetBytes(acceptNum);
|
|
clientSocket.Send(byteMessage);
|
clientSocket.Shutdown(SocketShutdown.Both);
|
clientSocket.Close();
|
RecordAlarmIp(conn, trx, acceptNum, ip2);
|
Logger.Info("已成功通知" + ip2 + " !");
|
return true;
|
}
|
catch (Exception e)
|
{
|
Logger.Warn("無法通知" + ip2 + ": " + e.Message);
|
}
|
|
try
|
{
|
IPAddress serverIp = IPAddress.Parse(ipPatrol);
|
int serverPort = Convert.ToInt32(GlobalVariable.AlermPort);
|
IPEndPoint iep = new IPEndPoint(serverIp, serverPort);
|
|
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
clientSocket.Connect(iep);
|
|
byte[] byteMessage = encoding.GetBytes(acceptNum);
|
|
clientSocket.Send(byteMessage);
|
clientSocket.Shutdown(SocketShutdown.Both);
|
clientSocket.Close();
|
RecordAlarmIp(conn, trx, acceptNum, ipPatrol);
|
Logger.Info("已成功通知" + ipPatrol + " !");
|
return true;
|
}
|
catch (Exception e)
|
{
|
Logger.Warn("無法通知" + ipPatrol + ": " + e.Message);
|
Logger.Warn("三個IP均無法通知到!");
|
return false;
|
}
|
}
|
|
private void RecordAlarmIp(OracleConnection conn, OracleTransaction trx, string accNum, string ip)
|
{
|
string sqlStmt = "INSERT INTO EOS.CASE_DISPATCH (ACCEPTNUM,ALARMIP) VALUES('" + accNum + "','" + ip + "')";
|
|
OracleCommand command = new OracleCommand(sqlStmt, conn, trx);
|
|
try
|
{
|
if (command.ExecuteNonQuery() <= 0)
|
Logger.Warn("無法紀錄Alarm IP!");
|
}
|
catch (Exception e)
|
{
|
Logger.Error("recordAlarmIP Error." + e.Message);
|
}
|
finally
|
{
|
command.Dispose();
|
}
|
}
|
}
|
}
|
