1

cjs

2 天以前 ff48949f706e899725c1ef7d0426c12c2b3e674f

 ams/Hanhe.iWCS.JingmenGEMTwoTCP/WCSServer.cs

@@ -73,46 +73,74 @@
            IEnentListen InInlet = DataAccess.CreateEnentListen();
            InInlet.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10009 });

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

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

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

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

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

         //设备合格率
         //10011-设备合格率
         IEnentListen machine = DataAccess.CreateEnentListen();
            machine.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10011 });

            //删除变更中间表时间大于两周的任务
            //10012-删除变更中间表时间大于两周的任务
            IEnentListen deleteTableTask = DataAccess.CreateEnentListen();
            deleteTableTask.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10012 });

            //ERP变更功能 插入简单生产入库表
            //10013-ERP变更功能 插入简单生产入库表
            IEnentListen SendERPTaskCompleteFunc = DataAccess.CreateEnentListen();
            SendERPTaskCompleteFunc.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10013 });

            //车间看板内容写入通道
            //10014-车间看板内容写入通道
            IEnentListen writeCJQtt = DataAccess.CreateEnentListen();
            writeCJQtt.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10014 });

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

            //10016-MES入库反馈
            IEnentListen SendMESTaskCompleteFunc = DataAccess.CreateEnentListen();
            SendMESTaskCompleteFunc.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10016 });

            //10017-电钴A口
            IEnentListen AMachine = DataAccess.CreateEnentListen();
            AMachine.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10017 });
            
            //10018-电钴C口
            IEnentListen CMachine = DataAccess.CreateEnentListen();
            CMachine.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10018 });
            
            //10019-电钴D口
            IEnentListen DMachine = DataAccess.CreateEnentListen();
            DMachine.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10019 });
            
            //10020-电钴接驳位入立库
            IEnentListen DGInWarehouse = DataAccess.CreateEnentListen();
            DGInWarehouse.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10020 });

            //10021-erp简单生产入库表反馈失败，重新反馈
            IEnentListen SendERPTaskCompleteFuncThree = DataAccess.CreateEnentListen();
            SendERPTaskCompleteFuncThree.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10021 });

            //10022-反馈erp 插入简单生产入库表(电钴)
            IEnentListen SendERPTaskCompleteFuncDG = DataAccess.CreateEnentListen();
            SendERPTaskCompleteFuncDG.EnentSubscribe(new TN_I_TASK_DTL_ACTION() { CN_N_ACTION_CODE = 10021 });

        }
      public class YourReceiveFilter : IReceiveFilterFactory<BinaryRequestInfo> {
         public IReceiveFilter<BinaryRequestInfo> CreateFilter(IAppServer appServer, IAppSession appSession, System.Net.IPEndPoint remoteEndPoint) {