using Hanhe.iWCS.Business;
using Hanhe.iWCS.DeviceDriver;
using Hanhe.iWCS.Factroy;
using Hanhe.iWCS.Interface;
using Hanhe.iWCS.Model;
using SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System;
using System.Configuration;
using System.Linq;

namespace Hanhe.iWCS.TaizhouGEMTwoTCP
{
	public class WCSServer : AppServer<WCSSession, BinaryRequestInfo> {
		/// <summary>
		/// 兼容CommandLine  命令行方式的协议 和 纯字符串的协议 都是以$$为结束符
		/// </summary>
		public WCSServer()
			: base(new YourReceiveFilter()) {
			//: base(new CommandLineReceiveFilterFactory("$$", Encoding.UTF8, new BasicRequestInfoParser(",", "&"))) {
			//设备初始化
			HardwareAccessHelper.Instance.Initialize();
			HardwareAccessHelper.Instance.ProgramDataInit();
			HardwareAccessHelper.Instance.ArchivesInit();
			SessionInstance.Instance.Initialize();
			Console.WriteLine("amswcs service CopyRight haninfo.cc " + DateTime.Now.Year);
			StockInstance.Instance.Initialize();

            //添加开启线程

            //任务拦截
            IEnentListen agvStateListen = DataAccess.CreateEnentListen();
            agvStateListen.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 1027 });

            //10001-读取包装线信号-3楼包装取料
            IEnentListen CheckPackingMachine = DataAccess.CreateEnentListen();
            CheckPackingMachine.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10001 });

            ////10002-读取复称平台信号-复称入缓存架
            //IEnentListen FuChengInCache = DataAccess.CreateEnentListen();
            //FuChengInCache.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10002 });

            //10003-读取叠包机信号（三楼双层缓存架入叠盘机流程）-3楼缓存架入叠托
            IEnentListen CacheStackingMouth = DataAccess.CreateEnentListen();
            CacheStackingMouth.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10003 });

            //10004-读包装机信号（包装机补空托流程）-3楼包装补空
            IEnentListen PickUpBlank = DataAccess.CreateEnentListen();
            PickUpBlank.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10004 });

            //10005-打包线空托补料请求（3楼拆盘机补空托）-3楼拆盘补空
            IEnentListen CheckPackingLineEmpty = DataAccess.CreateEnentListen();
            CheckPackingLineEmpty.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10005 });

			//10006 - 三楼叠盘机请求 - 3楼叠盘下线 - 二期新增任务流程
			IEnentListen CheckLineEmtpy = DataAccess.CreateEnentListen();
			CheckLineEmtpy.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10006 });

			//10007-打包线下线-满托入库
			IEnentListen CheckPackingLineFull = DataAccess.CreateEnentListen();
            CheckPackingLineFull.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10007 });

            //电梯任务
            IEnentListen plcListen = DataAccess.CreateEnentListen();
            plcListen.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 1000 });

            //MODBUS通道任务中间表处理
            IEnentListen ModBusTask = DataAccess.CreateEnentListen();
            ModBusTask.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 1001 });

            //充电任务
            IEnentListen BatteryTime = DataAccess.CreateEnentListen();
			BatteryTime.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 2000 });

			//写电量任务
			IEnentListen WirteBattery = DataAccess.CreateEnentListen();
			WirteBattery.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 2001 });

			//任务动作线程
			IEnentListen ActionControl = DataAccess.CreateEnentListen();
			ActionControl.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10010 });

			//写入小车状态
			IEnentListen changeSingal = DataAccess.CreateEnentListen();
			ActionControl.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10012 });

			//入库任务完成发送ERP批号等信息
			IEnentListen sendErpMsg = DataAccess.CreateEnentListen();
			sendErpMsg.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10013 });

            //读取包装线信号-3楼包装取料
            IEnentListen CheckPackingMachineTetracobalt = DataAccess.CreateEnentListen();
            CheckPackingMachineTetracobalt.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10014 });

            //ERP变更功能 将物料表数据插入中间表
            IEnentListen insertMidTable = DataAccess.CreateEnentListen();
            insertMidTable.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10015 });

            //打包线下线-3楼打包下线--已完成
            IEnentListen CheckPackingLineFullTwo = DataAccess.CreateEnentListen();
            CheckPackingLineFullTwo.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10016 });

            //给电梯发送心跳指令--已完成
            IEnentListen SendHeartBeat = DataAccess.CreateEnentListen();
            SendHeartBeat.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10017 });
		}
		public class YourReceiveFilter : IReceiveFilterFactory<BinaryRequestInfo> {
			public IReceiveFilter<BinaryRequestInfo> CreateFilter(IAppServer appServer, IAppSession appSession, System.Net.IPEndPoint remoteEndPoint) {
				return new MsgPackReceiveFilter();
			}
		}
		public class MsgPackReceiveFilter : TerminatorReceiveFilter<BinaryRequestInfo> {
			public MsgPackReceiveFilter()
				: base(new byte[] { 36, 36 }) {
			}
			public override BinaryRequestInfo Filter(byte[] readBuffer, int offset, int length, bool toBeCopied, out int rest) {
				return base.Filter(readBuffer, offset, length, toBeCopied, out rest);
			}
			protected override BinaryRequestInfo ProcessMatchedRequest(byte[] data, int offset, int length) {
				return new BinaryRequestInfo("", data.Skip(offset).Take(length).ToArray());
			}
		}
	}
}