using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Text;
using System.Web.Script.Serialization;
using MessageLib;
using QueueMessage;

namespace QueueService
{
 public class WebService : WebSocketServer, IServiceUI
 {
 JavaScriptSerializer convert = new JavaScriptSerializer();
 byte[] btDisConn = new byte[] { 0x3, 0xe9 };
 internal Extra<DeviceInfo> deviceList = new Extra<DeviceInfo>();
 internal bool deviceListChanged = false;

 public WebService()
 {
 this.OnPrepareListen += new TcpServerEvent.OnPrepareListenEventHandler(Service_OnPrepareListen);
 this.OnClose += new TcpServerEvent.OnCloseEventHandler(Service_OnClose);
 this.OnWSMessageBody += new WebSocketEvent.OnWSMessageBodyEventHandler(Service_OnWSMessageBody);
 loginOperation.AddRange("raterequest,rateoperate,ratesubmit".Split(','));
 }

 HandleResult Service_OnPrepareListen(TcpServer sender, IntPtr soListen)
 {
 dynamic section = ConfigurationManager.GetSection("ServiceConfig");
 var port = section.Configs["排队消息服务"].Port;
 this.client.Connect("127.0.0.1", ushort.Parse(port));
 return HandleResult.Ignore;
 }

 void client_ReceiveMessage(IntPtr connId, Message message)
 {
 switch (message.GetType().Name)
 {
 case MessageName.ClientQueryMessage:
 #region clientQuery
 {
 var msg = message as ClientQueryMessage;
 var allClient = this.deviceList.Dictionary.Values.ToArray();
 Dictionary<string, string> dic = new Dictionary<string, string>();
 foreach (var client in allClient)
 {
 dic[client.WindowNumber] = client.UserID;
 }
 msg.QueryType = ClientQueryType.Response;
 msg.ClientList = dic;
 this.client.SendMessage(msg);
 }
 #endregion
 break;
 case MessageName.RateMessage:
 #region rateRequest
 {
 var msg = message as RateMessage;
 var allClient = this.deviceList.Dictionary.Values.ToArray();
 var listRate = allClient.Where(p => p.WindowNumber == msg.WindowNo);
 foreach (var client in listRate)
 {
 var rateData = new RequestData
 {
 method = "RateQuest",
 param = new
 {
 rateId = msg.RateId,
 transactor = msg.Transactor,
 item = msg.ItemName,
 date = msg.WorkDate,
 reserveSeq = msg.reserveSeq
 }
 };
 this.SendWSMessage(client.ID, rateData.ToResultData());
 }
 }
 #endregion
 break;
 case MessageName.OperateMessage:
 #region operate
 {
 var msg = message as OperateMessage;
 var allClient = this.deviceList.Dictionary.Values.ToArray();
 var listRate = allClient.Where(p => p.WindowNumber == msg.WindowNo);
 foreach (var client in listRate)
 {
 var rateData = new RequestData
 {
 method = "RateOperate",
 param = new
 {
 operate = msg.Operate.ToString()
 }
 };
 this.SendWSMessage(client.ID, rateData.ToResultData());
 }
 }
 #endregion
 break;
 }
 }

 HandleResult Service_OnClose(TcpServer sender, IntPtr connId, SocketOperation enOperation, int errorCode)
 {
 if (!this.deviceList.Dictionary.ContainsKey(connId))
 return HandleResult.Ignore;
 var deviceInfo = this.deviceList.Dictionary[connId];
 this.client.SendMessage(new ClientChangedMessage()
 {
 ChangedType = ClientChangedType.Remove,
 UserID = deviceInfo.UserID,
 WindowNumber = deviceInfo.WindowNumber
 });
 this.deviceList.Remove(connId);
 deviceListChanged = true;
 return HandleResult.Ignore;
 }

 HandleResult Service_OnWSMessageBody(IntPtr connId, byte[] data)
 {
 try
 {
 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();
 var device = this.deviceList.Get(connId);
 if (loginOperation.Contains(method) && string.IsNullOrEmpty(device == null ? "" : device.UserCode))
 {
 var rData = new ResponseData { code = "1000", request = requestData.method, result = "当前用户尚未登录" };
 this.SendWSMessage(connId, rData.ToResultData());
 return HandleResult.Ignore;
 }
 switch (method)
 {
 #region debug
 case "raterequest":
 if (device.UserCode == "QueueService")
 {
 var param = requestData.param as Dictionary<string, object>;
 var targetList = this.deviceList.Dictionary.Values.Where(p => p.WindowNumber == param["winNum"].ToString()).ToList();
 foreach (var target in targetList)
 {
 var rateData = new RequestData
 {
 method = "RateQuest",
 param = new
 {
 rateId = param["rateId"] == null ? "" : param["rateId"].ToString(),
 transactor = param["transactor"] == null ? "" : param["transactor"].ToString(),
 item = param["item"] == null ? "" : param["item"].ToString(),
 date = param["date"] == null ? "" : param["date"].ToString(),
 reserveSeq = param["reserveSeq"] == null ? "" : param["reserveSeq"].ToString()
 }
 };
 this.SendWSMessage(target.ID, rateData.ToResultData());
 }
 var rData = new ResponseData { code = "0", request = requestData.method, result = targetList.Count == 0 ? "无此用户信息" : "已发送评价请求" };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 else
 {
 var rData = new ResponseData { code = "1001", request = requestData.method, result = "该用户无此操作权限" };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 case "rateoperate":
 if (device.UserCode == "QueueService")
 {
 var param = requestData.param as Dictionary<string, object>;
 var targetList = this.deviceList.Dictionary.Values.Where(p => p.WindowNumber == param["winNum"].ToString()).ToList();
 foreach (var target in targetList)
 {
 var rateData = new RequestData
 {
 method = "RateOperate",
 param = new
 {
 operate = param["operate"].ToString()
 }
 };
 this.SendWSMessage(target.ID, rateData.ToResultData());
 }
 var rData = new ResponseData { code = "0", request = requestData.method, result = targetList.Count == 0 ? "无此用户信息" : "已发送操作请求" };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 else
 {
 var rData = new ResponseData { code = "1001", request = requestData.method, result = "该用户无此操作权限" };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 #endregion
 case "getwindowlist":
 {
 var param = requestData.param as Dictionary<string, object>;
 var rData = new ResponseData { code = "0", request = requestData.method, result = this.rateProcess.RS_GetWindowList() };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 case "getuserlist":
 {
 var param = requestData.param as Dictionary<string, object>;
 var rData = new ResponseData { code = "0", request = requestData.method, result = this.rateProcess.RS_GetUserListByWindowNo(param["winNum"].ToString()) };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 case "getupdateinfo":
 {
 var rData = new ResponseData
 {
 code = "0",
 request = requestData.method,
 result = new
 {
 version = ini.ReadString("Config", "Version"),
 url = ini.ReadString("Config", "Url")
 }
 };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 case "getuserphoto":
 {
 var param = requestData.param as Dictionary<string, object>;
 var rData = new ResponseData { code = "0", request = requestData.method, result = this.rateProcess.GetUserPhoto(param["userCode"].ToString()) };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 case "login":
 {
 ResponseData rData = null;
 var param = requestData.param as Dictionary<string, object>;
 string winNum = param["winNum"].ToString(), userCode = param["userCode"].ToString();
 string userId = rateProcess.GetUserIdByCode(userCode);
 if (rateProcess.Login(winNum, userCode))
 {
 string ip = "";
 ushort port = 0;
 this.GetRemoteAddress(connId, ref ip, ref port);
 this.deviceList.Set(connId, new DeviceInfo()
 {
 ID = connId,
 IP = ip + ":" + port,
 WindowNumber = winNum,
 UserID = userId,
 UserCode = userCode,
 ConnTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
 });
 rData = new ResponseData { code = "0", request = requestData.method, result = "登录成功!" };
 deviceListChanged = true;
 }
 else
 rData = new ResponseData { code = "1002", request = requestData.method, result = "窗口或用户信息不正确!" };
 this.SendWSMessage(connId, rData.ToResultData());
 this.client.SendMessage(new ClientChangedMessage()
 {
 ChangedType = ClientChangedType.Add,
 UserID = userId,
 WindowNumber = winNum
 });
 }
 break;
 case "ratesubmit":
 {
 var param = requestData.param as Dictionary<string, object>;
 ResponseData rData = null;
 if (rateProcess.RateSubmit(device.UserID, device.WindowNumber, param["rateId"].ToString(), param["attitude"].ToString(), param["quality"].ToString(), param["efficiency"].ToString(), param["honest"].ToString()))
 rData = new ResponseData { code = "0", request = requestData.method, result = "评价成功!" };
 else
 rData = new ResponseData { code = "1003", request = requestData.method, result = "评价失败!" };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 default:
 {
 var rData = new ResponseData
 {
 code = "999",
 request = requestData.method,
 result = "未知指令"
 };
 this.SendWSMessage(connId, rData.ToResultData());
 }
 break;
 }
 }
 catch (Exception ex)
 {
 this.SDK_OnError(this, connId, ex);
 }
 return HandleResult.Ok;
 }

 #region IServiceUI 成员

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

 #endregion
 }
}