using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web.Script.Serialization;
using BLL;
using MessageLib;
using Model;

namespace ScreenDisplayService
{
 public class Service : WebSocketServer, IServiceUI
 {
 JavaScriptSerializer convert = new JavaScriptSerializer();
 byte[] btDisConn = new byte[] { 0x3, 0xe9 };
 internal Extra<IntPtr, DeviceInfo> deviceList = new Extra<IntPtr, DeviceInfo>();
 BCallBLL callBLL = new BCallBLL();
 TWindowBLL wBll = new TWindowBLL();
 TScreenConfigBLL sBll = new TScreenConfigBLL();
 List<BCallModel> aList = new List<BCallModel>();
 List<TWindowModel> wList = new List<TWindowModel>();
 List<TScreenConfigModel> screeList = new List<TScreenConfigModel>();
 public Service()
 {
 this.OnAccept += new TcpServerEvent.OnAcceptEventHandler(Service_OnAccept);
 this.OnClose += new TcpServerEvent.OnCloseEventHandler(Service_OnClose);
 this.OnWSMessageHeader += new WebSocketEvent.OnWSMessageHeaderEventHandler(Service_OnWSMessageHeader);
 this.OnWSMessageBody += new WebSocketEvent.OnWSMessageBodyEventHandler(Service_OnWSMessageBody);
 Task.Factory.StartNew(() =>
 {
 while (true)
 {
 this.RefreshConfig();
 Thread.Sleep(2 * 60 * 1000);
 }
 });
 Task.Factory.StartNew(() =>
 {
 while (true)
 {
 aList = callBLL.ScreenAllList();
 Thread.Sleep(1500);
 }
 });
 }

 internal void RefreshConfig()
 {
 wList = wBll.GetModelList();
 screeList = sBll.GetModelList();
 }

 HandleResult Service_OnAccept(TcpServer sender, IntPtr connId, IntPtr pClient)
 {
 string ip = "";
 ushort port = 0;
 this.GetRemoteAddress(connId, ref ip, ref port);
 deviceList.Set(connId, new DeviceInfo()
 {
 ID = connId,
 IP = ip,
 DeviceName = "",
 ConnTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
 });
 return HandleResult.Ignore;
 }

 HandleResult Service_OnClose(TcpServer sender, IntPtr connId, SocketOperation enOperation, int errorCode)
 {
 if (!this.deviceList.Dictionary.ContainsKey(connId))
 return HandleResult.Ignore;
 this.deviceList.Remove(connId);
 return HandleResult.Ignore;
 }

 HandleResult Service_OnWSMessageHeader(IntPtr connId, bool final, byte reserved, byte operationCode, byte[] mask, ulong bodyLength)
 {
 if ((WSOpcode)operationCode == WSOpcode.Close)
 this.Disconnect(connId);
 return HandleResult.Ignore;
 }

 HandleResult Service_OnWSMessageBody(IntPtr connId, byte[] data)
 {
 if (BitConverter.ToString(data) == BitConverter.ToString(btDisConn))
 return HandleResult.Ignore;
 var strData = Encoding.UTF8.GetString(data);
 RequestData requestData = null;
 try
 {
 requestData = convert.Deserialize<RequestData>(strData);
 }
 catch
 {
 return HandleResult.Ignore;
 }
 var method = requestData.method.Trim().ToLower();
 switch (method)
 {
 case "gethtml":
 {
 var rData = new ResponseData
 {
 method = requestData.method,
 code = "0",
 result = File.ReadAllText(AppDomain.CurrentDomain.BaseDirectory + "ScreenDisplay.html").Replace("0.0.0.0:0000", requestData.param.ToString())
 };
 this.SendWSMessage(connId, rData.ToBytes());
 }
 break;
 case "getconfig":
 {
 var rData = new ResponseData { code = "0", method = requestData.method, result = "" };
 var device = this.deviceList.Get(connId);
 var ip = device.IP;
 var config = screeList.Where(s => s.IP == ip).FirstOrDefault();
 if (config != null)
 {
 device.DeviceName = config.Name;
 this.deviceList.Set(connId, device);
 rData.result = convert.DeserializeObject(config.Config);
 this.SendWSMessage(connId, rData.ToBytes());
 }
 else
 {
 device.DeviceName = "未配置的设备";
 this.deviceList.Set(connId, device);
 rData.code = "-1";
 rData.result = "未获取到该设备的配置内容";
 this.SendWSMessage(connId, rData.ToBytes());
 }
 }
 break;
 case "getqueuelist":
 {
 var rData = new ResponseData { code = "0", method = requestData.method, result = "" };
 var param = requestData.param as Dictionary<string, object>;
 rData.result = GetCallByArea(param["winArea"].ToString());
 this.SendWSMessage(connId, rData.ToBytes());
 }
 break;
 default:
 {
 var rData = new ResponseData
 {
 method = requestData.method,
 code = "999",
 result = "未知指令"
 };
 this.SendWSMessage(connId, rData.ToBytes());
 }
 break;
 }
 return HandleResult.Ok;
 }

 Array GetCallByArea(string areas)
 {
 string[] areaList = areas.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
 var winList = wList.Where(q => areaList.Contains(q.AreaName.ToString())).Select(s => s.Number).ToList();
 var callList = aList.Where(q => winList.Contains(q.windowNumber)).ToList();
 var arr = callList.OrderByDescending(o => o.handleTime).Select(s => new { ticketNo = s.ticketNumber, winNo = s.windowNumber }).ToArray();
 return arr;
 }

 #region IServiceUI 成员

 public Type UIType
 {
 get { return typeof(FrmService); }
 }

 #endregion
 }
}