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.JingmenGLMNorthTCP
{
	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-读取包装线信号-3楼包装取料
            IEnentListen CheckPackingMachineTwo = DataAccess.CreateEnentListen();
            CheckPackingMachineTwo.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10002 });

            //10003-读取包装线信号-3楼包装取料 一号厂房
            IEnentListen CheckPackingMachineThree = DataAccess.CreateEnentListen();
            CheckPackingMachineThree.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10003 });

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

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

            //10006 - 打包线空托补料请求
            IEnentListen CheckPackingLineEmpty = DataAccess.CreateEnentListen();
            CheckPackingLineEmpty.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10006 });

            //10007-叠盘机满托下线（3楼叠盘下线）
            IEnentListen StackingLineEmpty = DataAccess.CreateEnentListen();
            StackingLineEmpty.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10007 });

            //10008-打包线下线-3楼打包下线
            IEnentListen CheckPackingLineFull = DataAccess.CreateEnentListen();
            CheckPackingLineFull.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10008 });

            //电梯任务
            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 });

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

            //10010 - 写入小车状态
            IEnentListen changeSignal = DataAccess.CreateEnentListen();
			changeSignal.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10010 });

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

            //10013 - ERP变更功能 将物料表数据插入中间表 一号厂房
            IEnentListen insertMidTableTwo = DataAccess.CreateEnentListen();
            insertMidTableTwo.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10013 });

            //10014 - 写入货位信息 三元车间
            IEnentListen insertLocInfo = DataAccess.CreateEnentListen();
            insertLocInfo.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10014 });

		}
		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());
			}
		}
	}
}