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.Collections;
using System.Data.OracleClient;
using System.Net;
using System.Net.Sockets;
using System.IO;

namespace CCSTrace.CCS.Object
{
    public class AlarmData
    {
        private Hashtable m_TotalData = new Hashtable();
        private RecordLog _PLog;
        private OracleConnection _ConnectionTPC;
        private OracleTransaction _Transaction;

        public AlarmData(OracleConnection _Conn,OracleTransaction _Trx, RecordLog _Log)
        {
            _ConnectionTPC = _Conn;
            _Transaction = _Trx;
            _PLog = _Log;

            String SqlStmt;

            SqlStmt = "SELECT DEPTID,IP1,IP2,IP_PATROL FROM CCS.ALARM_IP";
            OracleCommand Command = new OracleCommand(SqlStmt, _ConnectionTPC, _Transaction);
            OracleDataReader reader = Command.ExecuteReader();

            try
            {
                while (reader.Read())
                {
                    ArrayList Tmp = new ArrayList();
                    Tmp.Add(Convert.ToInt32(reader["DEPTID"].ToString()));
                    Tmp.Add(reader["IP1"].ToString());
                    Tmp.Add(reader["IP2"].ToString());
                    Tmp.Add(reader["IP_Patrol"].ToString());

                    m_TotalData.Add(Convert.ToInt32(reader["DeptID"].ToString()), Tmp);
                }
            }
            catch (Exception e)
            {
                _PLog.Error("Problems occur when fetch alarm data: (" + e.Message + ")");
                Console.WriteLine(e.StackTrace);
            }
            finally
            { 
                reader.Close();
                Command.Dispose();
            }
        }

        private int getSSCCode(int m_SCCode, int m_Week) {
            int ssccode = m_SCCode;

/*            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 ArrayList getIPAddress(int DeptCode) {
            return (ArrayList) m_TotalData[Convert.ToInt32(DeptCode)];
        }

        public bool alarm(String AcceptNum, int Dept) 
        {
            
            _PLog.Info("開始Alarm...");
            System.Net.Sockets.Socket m_Client;
            ArrayList IPAddressSet = this.getIPAddress(this.getSSCCode(Dept, Convert.ToInt32(DateTime.Now.DayOfWeek)));
            String IP1;
            String IP2;
            String IP_Patrol;
            System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();

            if (IPAddressSet != null)
            {
                _PLog.Info("已取得該部門所需通知的IP Address.");
                IP1 = IPAddressSet[1].ToString();
                IP2 = IPAddressSet[2].ToString();
                IP_Patrol = IPAddressSet[3].ToString();
            } else {
                _PLog.Warn("無法取得該部門所需通知的IP Address!");
                return false;
            }

            try {
                IPAddress serverIp = IPAddress.Parse(IP1);
                int serverPort = Convert.ToInt32(CCS.LocalVariable.AlermPort);
                IPEndPoint iep = new IPEndPoint(serverIp, serverPort);

                m_Client = new System.Net.Sockets.Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                m_Client.Connect(iep);

                byte[] byteMessage = encoding.GetBytes(AcceptNum);

                m_Client.Send(byteMessage);
                m_Client.Shutdown(SocketShutdown.Both);
                m_Client.Close();
                this.recordAlarmIP(AcceptNum, IP1);
                _PLog.Info("已成功通知" + IP1 + " !");
                return true;

            } catch (Exception e) {
                _PLog.Warn("無法通知" + IP1 + ": " + e.Message);
            }

            try {
                IPAddress serverIp = IPAddress.Parse(IP2);
                int serverPort = Convert.ToInt32(CCS.LocalVariable.AlermPort);
                IPEndPoint iep = new IPEndPoint(serverIp, serverPort);

                m_Client = new System.Net.Sockets.Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                m_Client.Connect(iep);

                byte[] byteMessage = encoding.GetBytes(AcceptNum);

                m_Client.Send(byteMessage);
                m_Client.Shutdown(SocketShutdown.Both);
                m_Client.Close();
                this.recordAlarmIP(AcceptNum, IP2);
                _PLog.Info("已成功通知" + IP2 + " !");
                return true;
            }
            catch (Exception e)
            {
                _PLog.Warn("無法通知" + IP2 + ": " + e.Message);
            }

            try {
                IPAddress serverIp = IPAddress.Parse(IP_Patrol);
                int serverPort = Convert.ToInt32(CCS.LocalVariable.AlermPort);
                IPEndPoint iep = new IPEndPoint(serverIp, serverPort);

                m_Client = new System.Net.Sockets.Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                m_Client.Connect(iep);

                byte[] byteMessage = encoding.GetBytes(AcceptNum);

                m_Client.Send(byteMessage);
                m_Client.Shutdown(SocketShutdown.Both);
                m_Client.Close();
                this.recordAlarmIP(AcceptNum, IP_Patrol);
                _PLog.Info("已成功通知" + IP_Patrol + " !");
                return true;
            }
            catch (Exception e)
            {
                _PLog.Warn("無法通知" + IP_Patrol + ": " + e.Message);
                _PLog.Warn("三個IP均無法通知到!");
                return false;
            }
        }

        private void recordAlarmIP(String AccNum, String IP) {
            String SqlStmt = "insert into eos.case_dispatch (acceptnum,alarmip) values('" + AccNum + "','" + IP + "')";

            OracleCommand Command = new OracleCommand(SqlStmt, _ConnectionTPC, _Transaction);

            try
            {

                if (Command.ExecuteNonQuery() <= 0)
                    _PLog.Warn("無法紀錄Alarm IP!");
            }
            catch (Exception e)
            {
                _PLog.Error("recordAlarmIP Error." + e.Message);
                return;
            }
            finally
            {
                Command.Dispose();
            }

        }

    }
}