SDSDYLH_WCS/WcfControlMonitorLib/CCallService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using System.Data;
using System.Collections;
//using System.Web.Script.Serialization;
using System.Text.RegularExpressions;
using CommonLib;
using System.Threading;
using DBFactory;
using ICommLayer;
using CommLayerFactory;
//using System.Security;
using System.Security.Cryptography;
using System.Web;
using System.Net;
using System.IO;
using System.Xml.Serialization;
using Newtonsoft.Json;
using System.Threading.Tasks;
using System.Timers;


namespace WcfControlMonitorLib
{
    public class CCallService
    {
       
        public class WMS_WCS_PARAM_OUT_MOVE
        {
            public string groupid { get; set; }//任务组号
            public string msgTime { get; set; }//下发时间
            public string externalOrderNo { get; set; }//业务单号
            public string region { get; set; }//出库的库位组
            public int priority { get; set; }// 优先级
            public List<OUT_MOVE_DATA> tasks { get; set; }
            //检查参数是否缺失
            public bool CheckParamNotNull(out string error)
            {

                StringBuilder message = new StringBuilder();
                if (groupid == String.Empty)
                {
                    message.Append("缺少groupid参数。");

                }
                if (msgTime == String.Empty)
                {
                    message.Append("缺少msgTime参数。");

                }
                if (externalOrderNo == String.Empty)
                {
                    message.Append("缺少externalOrderNo参数。");

                }
                if (region == String.Empty)
                {
                    message.Append("缺少region参数。");

                }
                //if (priority == String.Empty)
                //{
                //    message.Append("缺少timestamp参数。");

                //}
                if (tasks == null||tasks.Count==0)
                {
                    message.Append("缺少tasks参数。");

                }

                error = message.ToString();

                if (message.Length == 0)
                {
                    return true;
                }
                else
                {
                    return false;
                }
            }
      
        }

        #region OUT_MOVE_DATA  下发任务 山东时代
        public class OUT_MOVE_DATA 
            //JSON格式业务数据
        {
                /// <summary>
                ///  任务ID
                /// </summary>
                public string taskId { get; set; }
                /// <summary>
                /// 业务单号
                /// </summary>
            public string externalOrderNo { get; set; }
            /// <summary>
            /// 任务类型 1.入库，2:出库，3:移库，4.越库？
            /// </summary>
            public int taskType { get; set; }
            /// <summary>
            /// 任务起点
            /// </summary>
            public string startNode { get; set; }
            /// <summary>
            /// 起始巷道
            /// </summary>
            public string startLaneway { get; set; }
            /// <summary>
            /// 起始排
            /// </summary>
            public int startRow { get; set; }
                /// <summary>
                /// 起始列
                /// </summary>
                public int startColumn { get; set; }
            /// <summary>
            /// 起始层
            /// </summary>
            public int startLayer { get; set; }
                /// <summary>
                /// 起始深度
                /// </summary>
                public int startDepth { get; set; }
            /// <summary>
            /// 任务终点
            /// </summary>
            public string endNode { get; set; }
            /// <summary>
            /// 目标巷道
            /// </summary>
            public string endLaneway { get; set; }
            /// <summary>
            /// 目标排
            /// </summary>
            public int endRow { get; set; }
            /// <summary>
            /// 目标列
            /// </summary>
            public int endColumn { get; set; }
            /// <summary>
            /// 目标层
            /// </summary>
            public int endLayer { get; set; }
            /// <summary>
            /// 目标深度
            /// </summary>
            public int endDepth { get; set; }
            /// <summary>
            /// 目标库位组
            /// </summary>
            public string endGroup { get; set; }
            /// <summary>
            //拆包间编码
            /// </summary>
            public string unpackingRomCode { get; set; }
            /// <summary>
            /// 拆包间库位编码
            /// </summary>
            public string unpackingRomWhLocationCode { get; set; }
            /// <summary>
            /// 搬运类型
            /// </summary>
            public int carryType { get; set; }
            /// <summary>
            /// 容器编码
            /// </summary>
            public string containerCode { get; set; }
            /// <summary>
            /// 物料编码
            /// </summary>
            public string materialCode { get; set; }
            /// <summary>
            /// 物料名称
            /// </summary>
            public string materialName { get; set; } 
            /// <summary>
            /// 物料类型
            /// </summary>
            public string materialType { get; set; }
            /// <summary>
            /// 批次号
            /// </summary>
            public string batchNo { get; set; }
            /// <summary>
            /// 宽度
            /// </summary>
            public string referTag { get; set; }
            /// <summary>
            /// 供应商批次号
            /// </summary>
            public string supplierBatch { get; set; }
            /// <summary>
            /// 载具尺寸
            /// </summary>
            public string containerSize { get; set; }
            /// <summary>
            /// 数量
            /// </summary>
            public double qty { get; set; }
            /// <summary>
            /// 贴纸信息
            /// </summary>
            public List<LCS_lotInfo> lotInfo { get; set; }
        }
        public class LCS_lotInfo { 
            /// <summary>
            /// 贴纸编号
            /// </summary>
            public string lotID { get; set; }
            /// <summary>
            /// 物料编码
            /// </summary>
            public string MaterialCode { get; set; }
            /// <summary>
            /// 物料名称
            /// </summary>
            public string MaterialName { get; set; }
            /// <summary>
            /// 批次号
            /// </summary>
            public string batchNo { get; set; }
            /// <summary>
            /// 宽度
            /// </summary>
            public string referTag { get; set; }
            /// <summary>
            /// 供应商批次号
            /// </summary>
            public string supplierBatchNo { get; set; }
            /// <summary>
            /// 数量
            /// </summary>
            public double qty { get; set; }
        }

        #endregion

        #region OUT_MOVE_RES 出库返回 山东时代

        public class OUT_MOVE_RES  //JSON格式业务数据
        {
            public int code { get; set; }//处理状态。0，成功，1异常
            public string msg { get; set; }//返回消息
            public object data { get; set; }
        }
        #endregion


        #region//test stackstatus
        public class WMS_WCS_111
        {
            public string method { get; set; }
            //public string client_customerid { get; set; }
            //public string client_db { get; set; }
            //public string messageid { get; set; }
            //public string apptoken { get; set; }
            //public string appkey { get; set; }
            //public string sign { get; set; }
            public string timestamp { get; set; }

            //public object data { get; set; }   //需要根据method进行类型转换
            public List<STATUS_111> data { get; set; }


            //检查参数是否缺失
            public bool CheckParamNotNull(out string error)
            {

                StringBuilder message = new StringBuilder();
                if (method == String.Empty)
                {
                    message.Append("缺少method参数。");

                }
                //if (client_customerid == String.Empty)
                //{
                //    message.Append("缺少client_customerid参数。");

                //}
                //if (client_db == String.Empty)
                //{
                //    message.Append("缺少client_db参数。");

                //}
                //if (messageid == String.Empty)
                //{
                //    message.Append("缺少messageid参数。");

                //}
                //if (apptoken == String.Empty)
                //{
                //    message.Append("缺少apptoken参数。");

                //}
                //if (appkey == String.Empty)
                //{
                //    message.Append("缺少appkey参数。");

                //}
                //if (sign == String.Empty)
                //{
                //    message.Append("缺少sign参数。");

                //}
                if (timestamp == String.Empty)
                {
                    message.Append("缺少timestamp参数。");

                }
                if (data == null)
                {
                    message.Append("缺少data参数。");

                }

                error = message.ToString();

                if (message.Length == 0)
                {
                    return true;
                }
                else
                {
                    return false;
                }
            }

            //public FLUX_SYSTEM_PARAM(string[]  str)
            //{
            //    for (int i = 0; i < str.Length; i++)
            //    {
            //        if (str[i].Contains("method") == true)
            //        {
            //            this.method = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("client_customerid") == true)
            //        {
            //            this.client_customerid = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("client_db") == true)
            //        {
            //            this.client_db = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("messageid") == true)
            //        {
            //            this.messageid = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("apptoken") == true)
            //        {
            //            this.apptoken = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("appkey") == true)
            //        {
            //            this.appkey = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("sign") == true)
            //        {
            //            this.sign = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("timestamp") == true)
            //        {
            //            this.timestamp = str[i].Split('=')[1];
            //            continue;
            //        }
            //        if (str[i].Contains("data") == true)
            //        {
            //            //this.data = str[i].Split('=')[1];   //业务数据
            //            continue;
            //        }
            //    }
            //}
        }
        public class WCS_WMS_111
        {
            public string method { get; set; }
            //public string client_customerid { get; set; }
            //public string client_db { get; set; }
            //public string messageid { get; set; }
            //public string apptoken { get; set; }
            //public string appkey { get; set; }
            //public string sign { get; set; }
            public string timestamp { get; set; }

            //public object data { get; set; }   //  //dzf 出库和移库
            public List<OUT_MOVE_RES> data { get; set; }

            //public WCS_WMS_PARAM()
            //{
            //    method = "";
            //    //client_customerid = "aa";
            //    //client_db = " ";
            //    //messageid = "";
            //    //apptoken = "";
            //    //appkey = "";
            //    //sign = "";
            //    timestamp = "";
            //    data = new object();
            //}

            //public static string MD5Encrypt64(string data)
            //{
            //    MD5 md5 = new MD5CryptoServiceProvider();
            //    Encoding utf8 = Encoding.UTF8;
            //    string sign2 = HttpUtility.UrlEncode((Convert.ToBase64String(md5.ComputeHash(Encoding.Default.GetBytes(appSecret + data + appSecret)))).ToUpper(), utf8);
            //    return sign2;
            //}

            //检查参数是否缺失
            public bool CheckParamNotNull(out string error)
            {

                StringBuilder message = new StringBuilder();
                if (method == String.Empty)
                {
                    message.Append("缺少method参数。");

                }
                //if (client_customerid == String.Empty)
                //{
                //    message.Append("缺少client_customerid参数。");

                //}
                //if (client_db == String.Empty)
                //{
                //    message.Append("缺少client_db参数。");

                //}
                //if (messageid == String.Empty)
                //{
                //    message.Append("缺少messageid参数。");

                //}
                //if (apptoken == String.Empty)
                //{
                //    message.Append("缺少apptoken参数。");

                //}
                //if (appkey == String.Empty)
                //{
                //    message.Append("缺少appkey参数。");

                //}
                //if (sign == String.Empty)
                //{
                //    message.Append("缺少sign参数。");

                //}
                if (timestamp == String.Empty)
                {
                    message.Append("缺少timestamp参数。");

                }
                if (data == null)
                {
                    message.Append("缺少data参数。");

                }

                error = message.ToString();

                if (message.Length == 0)
                {
                    return true;
                }
                else
                {
                    return false;
                }
            }

        }

        #region STATUS_111 多穿设备状态

        public class STATUS_111 //JSON格式业务数据
        {
            public string stackindex { get; set; }//任务编号（索引）
            public string positon { get; set; }//层
            public string battery { get; set; }//电量
            public string laneout { get; set; }//巷道内外
            public string runstatus { get; set; }//状态
        }
        #endregion
        #endregion

        #region 入库WCS山东时代
        public class WMS_WCS_PARAM_IN
        {
            /// <summary>
            /// 任务ID
            /// </summary>
           public string taskId { get; set; }
            /// <summary>
            /// 任务类型
            /// </summary>
            public int taskType { get; set; }                
            /// <summary>
            /// 任务起点
            /// </summary>
            public string startNode { get; set; }
            /// <summary>
            /// 起始巷道
            /// </summary>
            public string startLaneway { get; set; }
            /// <summary>
            /// 优先级
            /// </summary>
            public string priority { get; set; }
            /// <summary>
            /// 任务终点
            /// </summary>
            public string endNode { get; set; }
            /// <summary>
            /// 目标巷道
            /// </summary>
            public string endLaneway { get; set; }
            /// <summary>
            /// 目标排
            /// </summary>
            public int endRow { get; set; }
            /// <summary>
            /// 目标列
            /// </summary>
            public int endColumn { get; set; }
            /// <summary>
            /// 目标层
            /// </summary>
            public int endLayer { get; set; }
            /// <summary>
            /// 目标深度
            /// </summary>
            public int endDepth { get; set; }
            /// <summary>
            /// 目标库位组
            /// </summary>
            public string endGroup { get; set; }
            /// <summary>
            /// 容器编码
            /// </summary>
            public string containerCode { get; set; }
        }
        public class WCS_WMS_PARAM_IN
        {
            public int code { get; set; }
           
            public string msg { get; set; }

            public object data { get; set; }   
           
          

        }
        #endregion

        //#region IN_DATA 入库  民航二所
        //public class IN_DATA
        ////JSON格式业务数据
        //{
        //    /// <summary>
        //    /// 
        //    /// </summary>
        //    public string taskId { get; set; }
        //    /// <summary>
        //    /// 
        //    /// </summary>
        //    public string containerCode { get; set; }
        //    /// <summary>
        //    /// 
        //    /// </summary>
        //    public string sourceAddress { get; set; }
        //    /// <summary>
        //    /// 
        //    /// </summary>
        //    public string targetAddress { get; set; }
        //    /// <summary>
        //    /// 
        //    /// </summary>
        //    public string tasklevel { get; set; }

        //}
        //#endregion

        //#region IN_RES 入库返回

        //public class IN_RES  //JSON格式业务数据
        //{
        //    public string code { get; set; }//处理状态。00，成功，01异常
        //    public string msg { get; set; }//返回消息
        //    public string taskId { get; set; }
        //}
        //#endregion


        #region CANCEL_DATA WMS取消任务 山东时代
        public class WMS_WCS_PARAM_CANCEL
        {
            public string taskId { get; set; }//任务编号（索引）
            public string msgTime { get; set; }//
        }
        
        public class WCS_WMS_PARAM_CANCEL
        {

            public int code { get; set; }//处理状态。0，成功，1异常
            public string msg { get; set; }//返回消息
            public object data { get; set; }

        }
        #endregion


        #region CANCEL_RES_Priority WMS调整任务优先级
        public class WMS_WCS_PARAM_Priority { 
            /// <summary>
            /// 任务编码
            /// </summary>
            public string taskId { get; set; }
            /// <summary>
            /// 任务优先级
            /// </summary>
            public int priority { get; set; }
            /// <summary>
            /// 下发时间
            /// </summary>
            public string msgTime { get; set; }
        }

        public class WCS_WMS_PARAM_Priority //JSON格式业务数据
        {
            public int code { get; set; }//状态（0 成功，1 失败）
            public string msg { get; set; }//返回消息，描述信息
            public object data { get; set; }
        }
        #endregion




        #region 状态上报 山东
        /// <summary>
        /// 任务上报
        /// </summary>
        public class WCS_WMS_PARAM_UPDATE
        {
            /// <summary>
            /// 任务ID
            /// </summary>
            public string taskId { get; set; }
            /// <summary>
            /// 任务状态任务执行过程中的状态，1：任务 开始 2：任务结束
            /// </summary>
            public int taskStatus { get; set; }
            /// <summary>
            /// 出库取货库位编码 出库取到货时传 入（取到货时必 填）出库及移库 必填
            /// </summary>
            public string startSpaceCode{ get; set; }
            /// <summary>
            /// 入库放货库位编码 入库放完货后传 入（放货完成后必填）入库及移库必填
            /// </summary>
            public string endSpaceCode { get; set;}
            /// <summary>
            /// 是否需要给AGV下发搬运任务 后续任务是否需要下发给 AGV搬运；0：不需要1：需要；如出库到输送线末端，需要 AGV 搬运则需回传 1，如某个出库口临时需要人工搬运，则为 0
            /// </summary>
            public string sendAgv { get; set; }
            /// <summary>
            /// 上报时间
            /// </summary>
            public string reportTime { get; set; }
            /// <summary>
            /// 上报信息
            /// </summary>
            public string reportInfo { get; set; }
        }

        public class WMS_WCS_PARAM_UPDATE
        {
            public int code { get; set; }
            public string msg { get; set; }
            public object data { get; set; }
        }
        #endregion
        #region 入库申请 山东
       

        public class InboundApply   //JSON格式业务数据
        {
            /// <summary>
            /// 容器编码
            /// </summary>
            public string containerCode { get; set; }
            /// <summary>
            /// 任务起点 输送线号
            /// </summary>
            public string startNode { get; set; }
            /// <summary>
            /// 请求类型 1实物，2空托
            /// </summary>
            public int requestType { get; set; }//状态（10 执行中 30故障 999完成）
            /// <summary>
            /// 请求任务类型 1入库请求 2.请求库位为 1 时 WMS 仅校验任务是否允许入库，
            /// 不返回具体的目标库位，为 2 时WMS 返回具体的目标库位 
            /// </summary>
            public int requestTaskType { get; set; }// 
            /// <summary>
            ////高度 1.低，2高
            /// </summary>
            public int requestHeight { get; set; }
            /// <summary>
            /// 载具尺寸 载具尺寸(不是必须)
            /// </summary>
            public string containerSize { get; set; }
            /// <summary>
            /// 载具重量
            /// </summary>
            public double weight { get; set; } 
            /// <summary>
            /// 上报时间
            /// </summary>
            public string msgTime { get; set; }       
        }

        public class InboundApplyBack
        {
            public int code { get; set; }//状态（0 成功，1 失败）
            public string msg { get; set; }//返回消息，描述信息
            public InBoundApplyBackData data { get; set; }
        }
        public class InBoundApplyBackData {
            /// <summary>
            /// 返回时间
            /// </summary>
            public string msgTime { get; set; }
            /// <summary>
            /// 任务ID
            /// </summary>
            public string taskId { get; set; }
            /// <summary>
            /// 任务类型
            /// </summary>
            public int taskType { get; set; }
            /// <summary>
            /// 任务起点
            /// </summary>
            public string startNode { get; set; }
            /// <summary>
            /// 任务终点
            /// </summary>
            public string endNode { get; set; }
            /// <summary>
            /// 目标巷道
            /// </summary>
            public string endLaneway { get; set; }
            /// <summary>
            /// 目标排
            /// </summary>
            public int endRow { get; set; }
            /// <summary>
            /// 目标列
            /// </summary>
            public int endColumn { get; set; }
            /// <summary>
            /// 目标层
            /// </summary>
            public int endLayer { get; set; }
            /// <summary>
            /// 目标深位
            /// </summary>
            public int endDepth { get; set; }
            /// <summary>
            /// 物料编码
            /// </summary>
            public string materialCode { get; set; }
            /// <summary>
            /// 物流名称
            /// </summary>
            public string materialName { get; set; }
            /// <summary>
            /// 物料类型
            /// </summary>
            public string materialType { get; set; }
            /// <summary>
            /// 批次号
            /// </summary>
            public string batchNo { get; set; }
            /// <summary>
            /// 数量
            /// </summary>
            public double qty { get; set; }
            /// <summary>
            /// 载具尺寸
            /// </summary>
            public string containerSize { get; set; }
            /// <summary>
            /// 优先级
            /// </summary>
            public int priority { get; set; }
            /// <summary>
            /// 载具重量
            /// </summary>
            public double weight { get; set; }
            /// <summary>
            /// 容器条码
            /// </summary>
            public string containerCode { get; set; }
        }
        #endregion
        #region WCS->LCS请求AGV 取货  无用
        public class WCS_WMS_RequestAGV {
            /// <summary>
            /// 任务ID
            /// </summary>
            public string taskId { get; set; }
            /// <summary>
            /// (站台号)
            /// </summary>
            public string fromStation { get; set; }
            /// <summary>
            /// (拆包间/产线投料口,站点，站台)
            /// </summary>
            public string toStation { get; set; }
            /// <summary>
            /// 目标库位组
            /// </summary>
            public string endGroup { get; set; }
            /// <summary>
            /// 
            /// </summary>
            public string pallteId { get; set; }
            /// <summary>
            /// 0-小（粉料），1-中（箔材），2-大。根据需要可以扩展成托盘轮廓尺寸
            /// </summary>
            public string pallteType { get; set; }
            /// <summary>
            /// 包括物料号和箱号，json  数组，例如 [{"lotId":"S23333","material":"Aa123"}]。支持一托多箱一物料号，也支持一托多箱多物料号。
            /// </summary>
            public string lotInfo { get; set; }
            /// <summary>
            /// 1-100 ,数值越大越优先
            /// </summary>
            public int priorityP { get; set; }
            /// <summary>
            /// 1-物料 2-空托盘
            /// </summary>
            public int taskType { get; set; }
        }
        public class WCS_WMS_RequestAGVBack {
            public int code { get; set; }
            public string msg { get; set; }
            public RequestAGVBackData data { get; set; }

        }
        public class RequestAGVBackData { 
            public string msgTime { get; set; }
            public string taskId { get; set; }
        }
        #endregion
        #region 
        #region WCS 允许 AGV 可取可放 返回站台状态
        public class LCS_WCS_AGVStationStauts {
            public string taskId { get; set; }
            /// <summary>
            /// 
            /// </summary>
            public int pickput { get; set; }
            /// <summary>
            /// 需要入库的载具条码，如托盘条码
            /// </summary>
            public string containerCode{get;set;}
            /// <summary>
            /// WCS站台号
            /// </summary>
            public string toStation { get; set; }
            /// <summary>
            /// 是否需要整形 送出 true(需要)|false（不需要）
            /// </summary>
            public bool isReshaping { get; set; }
            /// <summary>
            /// 1-物料 2-空托
            /// </summary>
            public int cargoType { get; set; }
        }

        public class LCS_WCS_AGVStationStautsBack { 
        public int code { get; set; }
            public string msg { get; set; }
            public LCS_WCS_AGVStationStautsBackData data { get; set; }

        }
        public class LCS_WCS_AGVStationStautsBackData { 
        public int putStatus { get; set; }
         public string taskId { get; set; }
        }
        #endregion

        #endregion
        #region LCS 返回 AGV 取放货状态给 WCS 取放完成与否
        public class LCS_WCS_AGVStatus { 
            /// <summary>
            /// 任务ID
            /// </summary>
            public string taskId { get; set; }
            /// <summary>
            /// 目标站台
            /// </summary>
            public string toStation { get; set; }
            /// <summary>
            /// AGV运行状态 21-取货完成 23-放货完成 56 已离开
            /// </summary>
            public int agvTaskStatus { get; set; }
        }
        public class LCS_WCS_AGVStatusBack { 
            public int code { get; set; }
            public string msg { get; set; }
            public LCS_WCS_AGVStatusBackData data { get; set; }
        }
        public class LCS_WCS_AGVStatusBackData {       
            /// <summary>
            /// 任务ID唯一
            /// </summary>
        public string taskId { get; set; }
        }
        #endregion

        //#region DELETE_TASK_DATA  向管理申请删除任务
        //public class DELETE_TASK_DATA
        //{
            
        //    public string taskId { get; set; }//任务编号（索引）
        //    public string containerCode { get; set; }//条码

        //}
        //#endregion

        //#region DELETE_TASK_RES 取消任务返回
        //public class DELETE_TASK_RES
        //{
        //    public string code { get; set; }//状态（0 成功，1 失败）
        //    public string msg { get; set; }//返回消息，描述信息
        //    public string taskId { get; set; }
        //}
        //#endregion



        public static event RefreshMonitorEventHandler RefreshMonitor;
        public static void OnRefreshMonitor(RefreshMonitorEventArgs e)
        {
            if (RefreshMonitor != null)
            {
                RefreshMonitor(e);
            }
        }
        /// <summary>
        /// post请求方法
        /// </summary>
        /// <param name="pContent"></param>
        /// <param name="address"></param>
        /// <param name="sResult"></param>
        /// <returns></returns>

        public static bool Invok_WMS_new( string pContent, string address, out string sResult)
        {
            object result = new object();
            try

            {            
                    CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "DealCallService", "发送报文:", pContent, "");

                //json参数  //创建一个HTTP请求
                HttpWebRequest request = (HttpWebRequest)WebRequest.Create(address);
                //Post请求方式 
                request.Method = "POST";
                request.Timeout = 4500;
                //内容类型
                request.ContentType = "application/json;charset=UTF-8";
                //将Json字符串转化为字节
                byte[] byteData = Encoding.UTF8.GetBytes(pContent);
                
                int length = byteData.Length;
                //设置请求的ContentLength
                request.ContentLength = length;
                //发送请求，获得请求流  
                Stream writer = request.GetRequestStream();//获取用于写入请求数据的Stream对象
                //将请求参数写入流
                writer.Write(byteData, 0, length);
                writer.Close();
                //获得响应流
                var response = (HttpWebResponse)request.GetResponse();
                var responseString = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("utf-8")).ReadToEnd();
                sResult = responseString;
                if (!address.Contains("state"))
                {
                    CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "DealCallService", "收到报文:", responseString, "");
                }
                return true;
                    
            }
            catch (System.Net.WebException ex)
            {
                sResult = ex.Message;
                var mResponse = ex.Response as HttpWebResponse;
                var responseStream = mResponse.GetResponseStream();
                if (responseStream != null)
                {
                    var streamReader = new StreamReader(responseStream, Encoding.GetEncoding("utf-8"));
                    //获取返回的信息
                    result = streamReader.ReadToEnd();
                    streamReader.Close();
                    responseStream.Close();
                }
                result = "获取数据失败，请重试！" + address + ex.ToString() + "         返回数据" + result;
                return false;
            }
        }

      
        /// <summary>
        /// 任务状态上报
        /// </summary>
        /// <param name="ask_data"></param>
        /// <param name="resp_data"></param>
        /// <returns></returns>
        public static string UpdateTaskStatusToWMS(long Managertask_Id,int state,out WMS_WCS_PARAM_UPDATE resp_data)
        {
            string bResult = string.Empty;
            bool sResult = true;
            string outJson = string.Empty;
            resp_data = null;
            try
            {
                sql.Clear();
                DataView data = new DataView();
                sql.Append(string.Format("select * from IO_CONTROL where CONTROL_ID={0}", Managertask_Id));
                   data  = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView; 
                WCS_WMS_PARAM_UPDATE upd = new WCS_WMS_PARAM_UPDATE();//传参解析使用
                if (data.Count > 0) {
                    upd.taskId = "DC"+Managertask_Id.ToString();
                    upd.taskStatus = state;
                    if (Convert.ToInt32(data[0]["CONTROL_TASK_TYPE"]) == 1) {
                        upd.endSpaceCode = data[0]["END_DEVICE_CODE"].ToString();
                    }
                    else if (Convert.ToInt32(data[0]["CONTROL_TASK_TYPE"]) == 2) {
                        upd.startSpaceCode = data[0]["START_DEVICE_CODE"].ToString();
                    }
                    else if (Convert.ToInt32(data[0]["CONTROL_TASK_TYPE"]) == 3) {
                        upd.startSpaceCode = data[0]["START_DEVICE_CODE"].ToString();
                        upd.endSpaceCode = data[0]["END_DEVICE_CODE"].ToString();
                    }
                    //upd.sendAgv =data[0]["NeedAGV"].ToString();
                    upd.reportTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                    upd.reportInfo = null;
                  //  WMS_WCS_PARAM_UPDATE upd_res = new WMS_WCS_PARAM_UPDATE();//返回值

                    string data_json_string = Model.JsonHelper.Serializer(upd);

                    sResult = Invok_WMS_new(data_json_string, CStaticClass.ManageServiceAddress, out outJson);
                    
                    if (sResult == false)
                    {
                        resp_data = Model.JsonHelper.Deserialize<WMS_WCS_PARAM_UPDATE>(outJson);
                        bResult = outJson;
                    }
                    else
                    {
                        resp_data = Model.JsonHelper.Deserialize<WMS_WCS_PARAM_UPDATE>(outJson);//WMS的返回值需要反序列化

                    }
                }
                return bResult;
            }
            catch (Exception ex)
            {
                bResult = ex.Message;
                return bResult;
            }
        }    

        /// <summary>
        ///输送线入库申请
        /// </summary>
        /// <param name="barcode">条码</param>
        /// <param name="startNode">扫码站台</param>
        /// <param name="requestType">1: 入库申请2：请求库位</param>
        /// <param name="resp_data">返回数据</param>
        /// <returns></returns>
        public static ResultMessage RequestToWMS(string barcode, string startNode,string requestType, out InboundApplyBack resp_data)
        {
            ResultMessage result = new ResultMessage();
            //string bResult = string.Empty;
           // bool sResult = false;
            string outJson = string.Empty;
            resp_data = null;
            try
            {
                InboundApply inboundApply = new InboundApply();
              //  InboundApplyBack inboundApplyBack = new InboundApplyBack();
                inboundApply.msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                inboundApply.containerCode = barcode;
                inboundApply.weight = 0;
                inboundApply.requestType = 1; //1 实物2 空托 / 空箱
                inboundApply.startNode =startNode;
                inboundApply.containerSize = null;
                inboundApply.requestHeight = 1;//1低，2高
                inboundApply.requestTaskType = 2;//1: 入库申请2：请求库位为 1 时 WMS 仅校验任务是否允许入库，不返回具体的目标库位，为 2 时WMS 返回具体的目标库位
                string data_json_string = Model.JsonHelper.Serializer(inboundApply);
                result.sResult = Invok_WMS_new(data_json_string, CStaticClass.ManageServiceAddressTwo, out outJson);
                if (result.sResult == false)
                {
                    result.message = outJson;
                }
                else
                {
                    resp_data = Model.JsonHelper.Deserialize<InboundApplyBack>(outJson);//将wms回复的信息反序列化
                   //返回
                    if (resp_data.code == 0)//成功
                    {
                        result.sResult = true;
                        result.message = resp_data.msg;
                    }
                    else//失败
                    {
                        if (resp_data.msg == "")
                        {
                            result.sResult = false;
                            result.message = "返回为null";
                        }
                        else
                        {
                            result.sResult = false;
                            result.message = resp_data.msg;
                        }
                    }
                }
                return result;
            }
            catch (Exception ex)
            {
                resp_data.code = 1;
                resp_data.msg=ex.Message;
               
                result.sResult = false;
                result.message = ex.Message;
                return result;
            }
        }

        #region 不使用
        //public static string RequestAGV (int Managertask_Id, string requestType, out RequestAGVBackData resp_data)
        //{
        //    string bResult = string.Empty;
        //    bool sResult = false;
        //    string outJson = string.Empty;
        //    resp_data = null;
        //    try
        //    {
        //        WCS_WMS_RequestAGV RequestAGV = new WCS_WMS_RequestAGV();//传入参数
        //        WCS_WMS_RequestAGVBack RequestAGVBack = new WCS_WMS_RequestAGVBack();//传出参数
        //        sql.Clear();
        //        DataView data = new DataView();
        //        sql.Append(string.Format("select CONTROL_ID,MANAGE_ID,CONTROL_TASK_TYPE,  STOCK_BARCODE, START_WAREHOUSE_CODE,START_DEVICE_CODE, END_WAREHOUSE_CODE, END_DEVICE_CODE, CONTROL_BEGIN_TIME,CONTROL_STATUS,NeedAGV from IO_CONTROL where FMANAGE_ID={0}", Managertask_Id));
        //        data = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
        //        if (data.Count > 0) {
        //            RequestAGV.taskId = Managertask_Id.ToString();
        //            RequestAGV.fromStation = data[0]["START_DEVICE_CODE"].ToString();
        //            RequestAGV.toStation = data[0]["END_DEVICE_CODE"].ToString();
        //            RequestAGV.pallteId= data[0]["STOCK_BARCOD"].ToString();
        //            RequestAGV.pallteType = "1";
        //            RequestAGV.taskType = 1;
        //            string data_json_string = Model.JsonHelper.Serializer(RequestAGVBack);
        //            sResult = Invok_WMS_new(data_json_string, CStaticClass.ManageServiceAddressThree, out outJson);
        //            if (sResult == false)
        //            {
        //                bResult = outJson;
        //            }
        //            else
        //            {
        //                RequestAGVBack = Model.JsonHelper.Deserialize<WCS_WMS_RequestAGVBack>(outJson);//将wms回复的信息反序列化

        //                if (RequestAGVBack.code == 0)
        //                {
        //                    bResult = "";
        //                    resp_data = RequestAGVBack.data;
        //                }
        //                else
        //                {
        //                    if (RequestAGVBack.msg == "")
        //                    {
        //                        bResult = "返回为null";
        //                    }
        //                    else
        //                    {
        //                        bResult = RequestAGVBack.msg;
        //                    }
        //                }
        //            }
        //        }
        //        return bResult;
        //    }
        //    catch (Exception ex)
        //    {
        //        bResult = ex.Message;
        //        return bResult;
        //    }
        //}
        //public static string UpdateStatusToWMS(List<STACKSTATUS_DATA> ask_data, out STACKSTATUS_RES_DATA resp_data)
        //{
        //    string bResult = string.Empty;
        //    bool sResult = true;
        //    string outJson = string.Empty;
        //    resp_data = null;
        //    try
        //    {
        //        WCS_WMS_PARAM_STACK_STATUS updatestatus = new WCS_WMS_PARAM_STACK_STATUS();
        //        WMS_WCS_PARAM_STACK_STATUS updatestatusres = new WMS_WCS_PARAM_STACK_STATUS();
        //        updatestatus.method = "wcs_stack_status";
        //        updatestatus.timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
        //        updatestatus.data = ask_data;

        //        string data_json_string = Model.JsonHelper.Serializer(updatestatus);


        //        sResult = Invok_WMS_new(data_json_string, CStaticClass.ManageServiceAddressThree, out outJson);

        //        if (sResult == false)
        //        {
        //            bResult = outJson;

        //        }
        //        else
        //        {
        //            updatestatusres = Model.JsonHelper.Deserialize<WMS_WCS_PARAM_STACK_STATUS>(outJson);//将wms回复的信息反序列化
        //            STACKSTATUS_RES_DATA outdata = updatestatusres.data;

        //            if (outdata.code == "00" || outdata.code == "0")
        //            {
        //                bResult = "";
        //                resp_data = outdata;
        //            }
        //            else
        //            {
        //                if (outdata.msg == "")
        //                {
        //                    bResult = "返回为null";
        //                }
        //                else
        //                {
        //                    bResult = outdata.msg;
        //                }
        //            }
        //        }
        //        return bResult;
        //    }
        //    catch (Exception ex)
        //    {
        //        bResult = ex.Message;
        //        return bResult;
        //    }
        //}



        //向wms上报纸箱任务


        //测试出库任务
        //public static string TestOut(OUT_DATA ask_data, out string resp_data1)
        //{

        //    OUT_RES resp_data = new OUT_RES();


        //    string bResult = string.Empty;
        //    bool sResult = true;
        //    string outJson = string.Empty;
        //    resp_data = null;
        //    try
        //    {
        //        WCS_WMS_PARAM outData = new WCS_WMS_PARAM();
        //        outData.method = "wcs_request_out";
        //        outData.client_customerid = "aa";
        //        outData.client_db = "";
        //        outData.messageid = "";
        //        outData.apptoken = "";
        //        outData.appkey = "";
        //        outData.sign = "";
        //        outData.timestamp = "";
        //        outData.data = ask_data;

        //        string data_json_string = Model.JsonHelper.Serializer(outData);

        //        sResult = Invok_WMS_new( data_json_string, out outJson);



        //        if (sResult == false)
        //        {
        //            bResult = outJson;
        //        }
        //        else
        //        {
        //            resp_data = Model.JsonHelper.Deserialize<OUT_RES>(outJson);
        //            if (resp_data.code != "1")
        //            {
        //                if (resp_data.msg == "")
        //                {
        //                    bResult = "返回为null";
        //                }
        //                else
        //                {
        //                    bResult = resp_data.msg;
        //                }
        //            }
        //            else
        //            {
        //                bResult = "";
        //                //resp_data = outdata;
        //            }
        //        }
        //        resp_data1 = "true";

        //        return bResult;
        //    }
        //    catch (Exception ex)
        //    {
        //        bResult = ex.Message;
        //        resp_data1 = "false";
        //        return bResult;
        //    }
        //}
        #endregion

        static DBOperator dbo = CStaticClass.dbo;
        static DBOperator dboMan = CStaticClass.dboM;
        static StringBuilder sql = new StringBuilder();
        static StringBuilder sql2 = new StringBuilder();
        static StringBuilder[] wv = { new StringBuilder("2") };
        static StringBuilder[] witemnames = { new StringBuilder("") };
        static Model.MDevice devinfo = new Model.MDevice();
        static CCommonFunction ccf = new CCommonFunction();
        static Thread mythread;
        static Thread mythreadUpdatestatus;
        static Thread threadAGVStatusSend;
        static bool exitThread = false;
        static bool exitThreadInRequestDeal = false;
        static bool exitThreadInAGVPLCAsk = false;
        static CGetState cgs = new CGetState();
        
        static string _CCallServiceError = "";//监控调度类错误说明

        public static string CCallServiceError
        {
            get { return _CCallServiceError; }
            set { _CCallServiceError = value; }
        }

        //static Dictionary<string, string> ErrorStation = new Dictionary<string, string> 
        //{
        //    {"12005","12006"},{"12008","12007"},{"22009","22008"}
        //};

        //任务执行状态上报定时器
        private static void BeginListen()
        {//20091107
            while (!exitThread)
            {
                try
                {
                    StringBuilder sql = new StringBuilder();
                    StringBuilder sql2 = new StringBuilder();
                    string bResult = "";
                    DataView dataIOtaskstart = new DataView();
                    //DataView dvl = new DataView();
                    DataView dataIOtask2finish = new DataView();
                    DataView dataIOBacktaskfinish = new DataView();
                    string dtime = DateTime.Now.ToString("u");
                    dtime = dtime.Substring(0, dtime.Length - 1);
                    //int AutoManageIdx = 0; int a = 0;
                    //string FSTARTCELL = ""; string FENDCELL = "";
                    //int FSTARTDEVICE = 0; int FENDDEVICE = 0;
                    //int flaneway = 0; int fstack = 0;
                    //int FControlTaskType = 0;
                    #region 发送任务开始执行给LCS
                    sql.Clear();
                    sql.Append("select * from IO_CONTROL WHERE CONTROL_STATUS < 900 and CONTROL_Status<>0 and IsSendLCS=0 and CONTROL_TASK_TYPE<>99 ");//查询还未发送给WMS但是任务状态已经是拆分完的状态的任务 数据库加一个IsSendLCS字段
                    dataIOtaskstart = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    if (dataIOtaskstart.Count > 0) {
                        for (int i = 0; i < dataIOtaskstart.Count; i++)
                        {
                            CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "taskStatusReporstart", "准备开始调用wms服务:", $"ID：{dataIOtaskstart[i]["CONTROL_ID"]},条码{dataIOtaskstart[i]["STOCK_BARCODE"]}");
                            UpdateTaskStatusToWMS(Convert.ToInt64(dataIOtaskstart[i]["CONTROL_ID"]),1,out WMS_WCS_PARAM_UPDATE resp_data);//1任务开始
                            if (resp_data.code == 0)
                            { //成功
                                sql.Clear();
                                sql.Append($"update IO_Control set IsSendLCS=1 where CONTROL_ID={dataIOtaskstart[i]["CONTROL_ID"]}");//查询还未发送给WMS但是任务状态已经是拆分完的状态的任务
                                dbo.ExceSQL(sql.ToString());
                            }
                            else {
                                CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "taskStatusReporstart", "开始调用wms服务失败:", $"返回报错{resp_data.data}:{resp_data.msg}");
                                return;
                            }
                        }
                    }
                    #endregion
                    #region 发送任务完成给LCS
                    sql.Clear();
                    sql.Append("select * from IO_CONTROL WHERE (CONTROL_STATUS = 999 OR CONTROL_STATUS = 900  OR CONTROL_STATUS = 970)  and   CONTROL_TASK_TYPE<>99 ");//查询还未发送给WMS但是任务状态已经是完成的状态的任务  不用校验issendlcs=1的情况，防止还没上传给WMS就报错了
                  
                    dataIOtask2finish = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    if (dataIOtask2finish.Count > 0)
                    {
                        for (int i = 0; i < dataIOtask2finish.Count; i++)
                        {
                            CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "taskStatusReporfinish", "准备开始调用wms服务:", $"ID：{dataIOtask2finish[i]["CONTROL_ID"]},条码{dataIOtask2finish[i]["STOCK_BARCODE"]}");
                            UpdateTaskStatusToWMS(Convert.ToInt64(dataIOtask2finish[i]["CONTROL_ID"]),2, out WMS_WCS_PARAM_UPDATE resp_data);//2任务结束
                            if (resp_data.code == 0)
                            { //成功
                                sql.Clear();
                                sql.Append($"delete from IO_CONTROL  where CONTROL_ID={dataIOtask2finish[i]["CONTROL_ID"]}");//查询还未发送给WMS但是任务状态已经是拆分完的状态的任务
                                dbo.ExceSQL(sql.ToString());
                            }
                            else {
                                CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "taskStatusReporstart", "开始调用wms服务失败:", $"返回报错{resp_data.data}:{resp_data.msg}");
                                return;
                            }
                        }
                    }
                    #endregion
                    #region 处理回退任务
                    sql.Clear();
                    sql.Append("select * from IO_CONTROL WHERE ( CONTROL_STATUS = 999 OR CONTROL_STATUS = 900  OR CONTROL_STATUS = 970 ) and CONTROL_TASK_TYPE=99");//直接删除回退任务 //ControlTaskType=99是回退任务
                     dataIOBacktaskfinish = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    if (dataIOBacktaskfinish.Count > 0)
                    {
                        for (int i = 0; i < dataIOBacktaskfinish.Count; i++)
                        {                     
                                sql.Clear();
                                sql.Append($"delete from IO_CONTROL  where CONTROL_ID={dataIOBacktaskfinish[i]["CONTROL_ID"]}");//查询还未发送给WMS但是任务状态已经是拆分完的状态的任务
                                dbo.ExceSQL(sql.ToString());                        
                        }
                    }
                    #endregion
                }
                catch (Exception ex)
                {
                    _CCallServiceError = ex.StackTrace + ex.Message;
                    CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "DealCallService", "调用接口时异常:", "19999", ex.Message.ToString());
                    //dbo.ExecuteSql(string.Format("UPDATE IO_CONTROL_APPLY set APPLY_TASK_STATUS = 2 where APPLY_TASK_STATUS = 0"));
                }
                finally
                {
                    Thread.Sleep(1000);
                }
            }
        }
        /// <summary>
        /// 扫码请求
        /// </summary>
        private static void BeginListenUpdatestatus()
        {//20091107
            while (!exitThreadInRequestDeal)
            {
                try
                {
                    StringBuilder sql =new StringBuilder();
                    StringBuilder sql2 = new StringBuilder();
                    StringBuilder sql3 = new StringBuilder();
                    StringBuilder sql4 = new StringBuilder();
                    DataView dv = new DataView(); DataView dvl = new DataView();
                    string dtime = DateTime.Now.ToString("u");
                    dtime = dtime.Substring(0, dtime.Length - 1);
                    sql.Clear();//
                    sql.Append("select * from IO_CONTROL_APPLY WHERE CONTROL_APPLY_TYPE =1 ");//扫码请求
                    DataView dataInRequest = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView; 
                    if (dataInRequest.Count > 0)
                    {
                        for (int i = 0; i < dataInRequest.Count; i++)
                        {
                            CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "inboundApply", "准备开始调用wms服务:", $"Barcode：{dataInRequest[i]["STOCK_BARCODE"]},站台{dataInRequest[i]["DEVICE_CODE"]}");
                            ResultMessage result = RequestToWMS(dataInRequest[i]["STOCK_BARCODE"].ToString(), dataInRequest[i]["DEVICE_CODE"].ToString(), "2", out InboundApplyBack resp_data);
                            if (result.sResult)
                            { //成功
                                IO_CONTROL iO_CONTROL = new IO_CONTROL(resp_data.data, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                                iO_CONTROL.Insert_IOCONTROL();//暂不考虑插入失败的情况     写入IO入库任务
                                CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", " ", "开始调用wms服务成功败:", $"返回信息{resp_data.data}:{resp_data.msg}");

                            }
                            else
                            { 
                                //暂定通讯失败和接口返回失败都直接回退
                                sql2.Clear();
                                sql2.Append("select F_EndDevice from T_Base_Route WHERE F_StartDevice =").Append(dataInRequest[i]["DEVICE_CODE"]).Append(" and F_RouteKind=4");//查询回退任务的终点位置
                                DataView dataBackTask = dbo.ExceSQL(sql2.ToString()).Tables[0].DefaultView;
                                IO_CONTROL iO_CONTROL = new IO_CONTROL(dataInRequest[i]["DEVICE_CODE"].ToString(), dataBackTask[0]["F_EndDevice"].ToString(), dataInRequest[i]["STOCK_BARCODE"].ToString());
                                iO_CONTROL.Insert_IOCONTROL();//暂不考虑插入失败的情况     写入IO入库任务   
                                                              // sql3.Clear();
                                #region 添加LCS返回异常日志显示在客户端
                                string sql5 = string.Format("insert into IO_CONTROL_APPLY_HIS(CONTROL_APPLY_ID,CONTROL_ID,CONTROL_APPLY_TYPE,WAREHOUSE_CODE,DEVICE_CODE,STOCK_BARCODE,APPLY_TASK_STATUS,CREATE_TIME,CONTROL_APPLY_PARAMETER,CONTROL_APPLY_PARA01,CONTROL_APPLY_PARA02,CONTROL_APPLY_REMARK) values ({0},{1},'{2}','{3}','{4}','{5}',{6},'{7}','{8}','{9}','{10}','{11}')",
                                                                                                   dataInRequest[i]["CONTROL_APPLY_ID"], dataInRequest[i]["CONTROL_ID"], dataInRequest[i]["CONTROL_APPLY_TYPE"], dataInRequest[i]["WAREHOUSE_CODE"], dataInRequest[i]["DEVICE_CODE"],
                                                                                                  dataInRequest[i]["STOCK_BARCODE"], dataInRequest[i]["APPLY_TASK_STATUS"], dataInRequest[i]["CREATE_TIME"], resp_data.msg.Substring(0, 200), dataInRequest[i]["CONTROL_APPLY_PARA01"], dataInRequest[i]["CONTROL_APPLY_PARA02"], dataInRequest[i]["CONTROL_APPLY_REMARK"],"");
                                dbo.ExceSQL(sql5.ToString());
                                #endregion
                                CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "inboundApply", "开始调用wms服务失败:", $"返回报错{resp_data.data}:{resp_data.msg}");
                            }
                            //删除IOControlApply的扫码请求
                            sql.Clear(); 
                            sql.Append($"delete from IO_CONTROL_APPLY  where STOCK_BARCODE='{dataInRequest[i]["STOCK_BARCODE"]}' and  CONTROL_APPLY_TYPE =1 ");//查询回退任务的终点位置
                             dbo.ExceSQL(sql.ToString());
                        }
                    }
                }
                catch (Exception ex)
                {

                    _CCallServiceError = ex.StackTrace + ex.Message;
                    CommonClassLib.CCarryConvert.WriteDarkCasket("CallService", "inboundApply", "调用WMS接口失败", "19999", $"{ex.Message}");
                }
                finally
                {
                    Thread.Sleep(1000);
                }
            }
        }


        private static void BeginListenAgvData(){
            while (!exitThreadInAGVPLCAsk)
            {
                try {
                    StringBuilder sql = new StringBuilder();
                    StringBuilder sql2 = new StringBuilder();
                    DataView dv = new DataView(); DataView dvl = new DataView();
                    string dtime = DateTime.Now.ToString("u");
                    dtime = dtime.Substring(0, dtime.Length - 1);
                    sql.Clear();
                    sql.Append("select * from T_AGVIOStation ");//AGV进出站台
                    DataView data = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    for (int i=0; i < data.Count;i++) {
                        Model.MDevice md = Model.CGetInfo.GetDeviceInfo(Convert.ToInt32(dv[i]["F_DeviceIndex"]));
                        if (md.RunState.ToString()!= data[i]["F_AGVStatus"].ToString())//当前状态和数据库不一样，则下发数据
                        {
                            SControlMonitor sControl = new SControlMonitor();
                            sControl.WriteDBDataConveyor(Convert.ToInt32(dv[i]["F_DeviceIndex"]), "DB2", dv[i]["F_AGVStatus"].ToString(), out string errtext);
                            //
                        }
                    }
                } 
                catch(Exception ex) { 
                }
            }
        }
        public static void EndListen()
        {//20091107
            exitThread = true;

            if (mythread != null)
            {

                mythread.Abort();
                mythread = null;
            }


            exitThreadInRequestDeal = true;

            if (mythreadUpdatestatus != null)
            {

                mythreadUpdatestatus.Abort();
                mythreadUpdatestatus = null;
            }
         
        }

        public static void StartListen()
        {
            //LayerStatus.LAYER.Clear();
            //sql.Clear();
            //sql.Append("select * from SHUTTLE_LAYER_STATUS");
            //DataView dv = new DataView();
            //dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
            //for (int i = 0; i < dv.Count; i++)
            //{
            //    LayerStatus.LAYER.Add(Convert.ToInt32(dv[i]["F_Layer"]), Convert.ToInt32(dv[i]["F_UpdateNo"]));
            //}
            exitThread = false;
            mythread = new Thread(new ThreadStart(BeginListen));
            mythread.IsBackground = true;
            mythread.Start();

            exitThreadInRequestDeal = false;
            mythreadUpdatestatus = new Thread(new ThreadStart(BeginListenUpdatestatus));    //
            mythreadUpdatestatus.IsBackground = true;
            mythreadUpdatestatus.Start();

          

        }
        public static void StartListenPLC() {
            try
            {
                exitThreadInAGVPLCAsk = false;
                threadAGVStatusSend = new Thread(new ThreadStart(BeginListenAgvData));    //
                threadAGVStatusSend.IsBackground = true;
                threadAGVStatusSend.Start();
                //threadAGVStatusSend.Join();
            }catch (Exception ex)
            {

            }
        }
        public static void EndListenPLC()
        {
            exitThreadInAGVPLCAsk = true;

            if (threadAGVStatusSend != null)
            {

                threadAGVStatusSend.Abort();
                threadAGVStatusSend = null;
            }
        }
    }
    public class ResultMessage {//通用返回信息类
        public bool sResult { get; set; }
        public string message { get; set; }
    }
    public static class LayerStatus
    {
        public static Dictionary<int, int> LAYER = new Dictionary<int, int>();


    }
    #region IOControl
    public class IO_CONTROL
    {
        static DBOperator dbo = CStaticClass.dbo;
        static DBOperator dboMan = CStaticClass.dboM;
        string wms_id;
        int relative_id;
        string barcode;
        string startdevice;
        string enddevice;
        string begintime;
        int control_type;
        string warehouse = "1";
        string tasklevel;
        int needAgv = 0;
        public StringBuilder error_code = new StringBuilder();

        StringBuilder sql = new StringBuilder();
         
        //public IO_CONTROL(CCallService.WMS_WCS_PARAM_IN indata, string time, string level)//入库
        //{
        //    error_code.Clear();
        //    wms_id = indata.taskId;
        //    relative_id = -1;
        //    barcode = indata.containerCode;
        //    if (indata.taskType == 2 || indata.taskType == 3)
        //    { //起点是库位
        //      // startdevice = outdata.startRow.ToString("D2") + "-" + outdata.startColumn.ToString("D2") + "-" + outdata.startLayer.ToString("D2");
        //        enddevice = indata.endNode;
        //    }
        //    else if (indata.taskType == 1 || indata.taskType == 4) //终点是库位
        //    {
        //        startdevice = indata.startNode;
        //        enddevice = indata.endRow.ToString("D2") + "-" + indata.endColumn.ToString("D2") + "-" + indata.endLayer.ToString("D2");
        //    }
        //    control_type = 1;
        //    string dTime1 = DateTime.Now.ToString("u");
        //    begintime = dTime1.Substring(0, dTime1.Length - 1);
        //    tasklevel = level;

        //}
        public IO_CONTROL(CCallService.InBoundApplyBackData indata, string time) {
            error_code.Clear();
            wms_id = indata.taskId.Trim('D').Trim('C');
            relative_id = -1;
            barcode = indata.containerCode;
            if (indata.taskType == 2 || indata.taskType == 3)
            { //起点是库位
              // startdevice = outdata.startRow.ToString("D2") + "-" + outdata.startColumn.ToString("D2") + "-" + outdata.startLayer.ToString("D2");
                enddevice = indata.endNode;
            }
            else if (indata.taskType == 1 ) //终点是库位
            {
                startdevice = indata.startNode;
                enddevice = indata.endRow.ToString("D2") + "-" + indata.endColumn.ToString("D2") + "-" + indata.endLayer.ToString("D2");
            }
            control_type = 1;
            string dTime1 = DateTime.Now.ToString("u");
            begintime = dTime1.Substring(0, dTime1.Length - 1);
            tasklevel = "10";
        }

        public IO_CONTROL(string startStation,string endStation,string Barcode)
        {
            error_code.Clear();
            DataSet ds = dbo.ExceSQL("select F_ManageTaskIndex from T_Base_Manage_Task_Index_Auto_Task");
            DataView dv = ds.Tables[0].DefaultView;
            if (dv.Count > 0)
            {
                     wms_id =( Convert.ToInt32(dv[0]["F_ManageTaskIndex"])+1).ToString(); //获取回退任务号回退任务不需要DC开头         
                    //20101124
                    sql.Append("UPDATE T_Base_Manage_Task_Index_Auto_Task SET F_ManageTaskIndex =").Append(Convert.ToInt32(wms_id));
                    dbo.ExceSQL(sql.ToString());
            }
           
            relative_id = -1;
            barcode = Barcode;
            startdevice = startStation;
            enddevice = endStation;      
            control_type = 99;//标记回退任务，完成后不请求LCS直接删除
            string dTime1 = DateTime.Now.ToString("u");
            begintime = dTime1.Substring(0, dTime1.Length - 1);
            tasklevel = "10";
        }

        public IO_CONTROL(CCallService.OUT_MOVE_DATA outdata, string time, int controltype, string level)//出库 移库
        {
            error_code.Clear();
            wms_id = outdata.taskId.Trim('D').Trim('C');
            relative_id = -1;
            barcode = outdata.containerCode;
            if (outdata.taskType == 2 || outdata.taskType == 3)
            { //起点是库位
                startdevice = outdata.startRow.ToString("D2") + "-" + outdata.startColumn.ToString("D2") + "-" + outdata.startLayer.ToString("D2");
                enddevice = outdata.endNode;
            }
            else if (outdata.taskType == 1 || outdata.taskType == 4) //终点是库位
            {
                startdevice = outdata.startNode;
                enddevice = outdata.endRow.ToString("D2") + "-" + outdata.endColumn.ToString("D2") + "-" + outdata.endLayer.ToString("D2");
            }
            control_type = controltype;
            string dTime1 = DateTime.Now.ToString("u");
            begintime = dTime1.Substring(0, dTime1.Length - 1);
            tasklevel = level;
          //  needAgv = outdata.carryType == 2 ? 1 : 0;
        }
        //检查参数是否正确  需要优化
        public bool CheckData(out string msg)
        {
            Dictionary<string, WEBAPI_CKECKING> all_checking = new Dictionary<string, WEBAPI_CKECKING>();

            #region 从数据库中读取要检测的SQL
            sql.Clear();
            sql.Append("select * from WEBAPI_CKECKING");
            DataView dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
            for (int i = 0; i < dv.Count; i++)
            {
                WEBAPI_CKECKING wac = new WEBAPI_CKECKING();

                wac.check_id = dv[i]["CKECK_ID"].ToString();
                wac.check_name = dv[i]["CKECK_NAME"].ToString();
                wac.sql = dv[i]["SQL"].ToString();
                wac.des = dv[i]["DESCRIPTION"].ToString();

                all_checking.Add(wac.check_name, wac);
            }
            #endregion

            error_code.Clear();

            #region 检查是否重复，CONTROL_ID, 托盘码重复， 起始货位重复，终止货位重复(结果大于零)

            sql.Clear();
            sql.Append(string.Format(all_checking["CONTROL_ID_REPEAT"].sql, wms_id));
            if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
            {
                error_code.Append(";").Append(all_checking["CONTROL_ID_REPEAT"].des);  //fid重复
            }

            //sql.Clear();
            //sql.Append(string.Format(all_checking["BARCODE_REPEAT"].sql, barcode));
            //if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
            //{
            //    error_code.Append(";").Append(all_checking["BARCODE_REPEAT"].des);  //托盘条码重复
            //}
            if (string.IsNullOrEmpty(tasklevel))
            {
                error_code.Append(";").Append("任务优先级为空");
            }
            if (string.IsNullOrEmpty(wms_id))
            {
                error_code.Append(";").Append("任务号为空");
            }
            if (string.IsNullOrEmpty(barcode))
            {
                error_code.Append(";").Append("条码为空");
            }

            //if (int.TryParse(this.wms_id, out int controlid) == false)
            //{
            //    error_code.Append(";").Append(all_checking["CONTROL_ID_NOT_NUM"].des);  //controlid不为数字
            //}


            if (control_type == 2)//出库任务
            {

                sql.Clear();
                sql.Append(string.Format(all_checking["START_CEEE_REPEAT"].sql, startdevice, control_type));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
                {
                    error_code.Append(";").Append(all_checking["START_CEEE_REPEAT"].des);  //起始货位重复
                }
                if (this.startdevice.Length != 8)
                {
                    error_code.Append(";").Append("起点").Append(all_checking["CELL_LENGTH_ERROR"].des);  //起点货位编码长度错误
                }
                sql.Clear();
                sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, startdevice));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
                {
                    error_code.Append(";").Append("起点").Append(all_checking["CELL_NOT_EXIST"].des);  //起点货位不存在

                }

                int endGate = 0;
                if (int.TryParse(this.enddevice, out endGate) == false)
                {
                    error_code.Append(";").Append(all_checking["END_GATE_ERROR"].des);  //终点站台不正确，无法转为整数
                }

                sql.Clear();
                sql.Append(string.Format(all_checking["END_GATE_NOT_EXIST"].sql, enddevice));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
                {
                    error_code.Append(";").Append(all_checking["END_GATE_NOT_EXIST"].des);  //终点站台不存在
                }

            }

            if (control_type == 1)//入库任务
            {
                sql.Clear();
                sql.Append(string.Format(all_checking["END_CEEE_REPEAT"].sql, enddevice, control_type));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
                {
                    error_code.Append(";").Append(all_checking["END_CEEE_REPEAT"].des);  //终点货位重复
                }
                if (this.enddevice.Length != 8)
                {
                    error_code.Append(";").Append("终点").Append(all_checking["CELL_LENGTH_ERROR"].des);  //终点货位编码长度错误
                }

                sql.Clear();
                sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, enddevice));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
                {
                    error_code.Append(";").Append("终点").Append(all_checking["CELL_NOT_EXIST"].des);  //终点货位不存在
                }
                sql.Clear();
                sql.Append(string.Format(all_checking["START_GATE_NOT_EXIST"].sql, startdevice));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
                {
                    error_code.Append(";").Append(all_checking["START_GATE_NOT_EXIST"].des);  //起点站台不存在
                }
            }
            #region 校验代码需优化20250310
            if (control_type == 3) //移库任务
            {
                if (this.startdevice.Length != 8)
                {
                    error_code.Append(";").Append("起点").Append(all_checking["CELL_LENGTH_ERROR"].des);  //终点货位编码长度错误
                }
                if (this.enddevice.Length != 8)
                {
                    error_code.Append(";").Append("终点").Append(all_checking["CELL_LENGTH_ERROR"].des);  //终点货位编码长度错误
                }

                sql.Clear();
                sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, startdevice));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
                {
                    error_code.Append(";").Append("起点").Append(all_checking["CELL_NOT_EXIST"].des);  //起点货位不存在

                }
                sql.Clear();
                sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, enddevice));
                if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
                {
                    error_code.Append(";").Append("终点").Append(all_checking["CELL_NOT_EXIST"].des);  //终点货位不存在
                }

                //移库任务如果不同层，校验不要移
                if (startdevice.Substring(6, 2) != enddevice.Substring(6, 2))
                {
                    error_code.Append(";").Append("移库任务起点终点层值不同");
                }
                if (startdevice == enddevice)
                {
                    error_code.Append(";").Append("移库任务起点终点相同");
                }

            }
            #endregion
            #endregion

            //检查托盘码

            if (error_code.Length == 0)
            {
                msg = "";
                return true;
            }
            else
            {
                msg = error_code.ToString();
                return false;
            }
        }

        //
        public bool Insert_IOCONTROL()
        {
            if (CheckData(out string msg) == true)
            {
                try
                {
                    sql.Clear();
                    sql.Append(string.Format("INSERT INTO IO_CONTROL (CONTROL_ID, RELATIVE_CONTROL_ID, MANAGE_ID, STOCK_BARCODE, CONTROL_TASK_TYPE, CONTROL_TASK_LEVEL," +
                        " START_WAREHOUSE_CODE, START_DEVICE_CODE, END_WAREHOUSE_CODE, END_DEVICE_CODE, CONTROL_BEGIN_TIME,CONTROL_STATUS) " +
                        "VALUES( '{0}','{1}','{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}',{11})",
                        wms_id, -1, wms_id, barcode, control_type, tasklevel, warehouse, startdevice, warehouse, enddevice, begintime, 0));
                    dbo.ExceSQL(sql.ToString());
                    return true;
                }
                catch (Exception ex)
                {
                    error_code.Append("WCS插入IO_ONTROL表失败！");
                    return false;
                }
            }

            return false;
        }


    }
    public class WEBAPI_CKECKING
    {
        public string check_id;
        public string check_name;
        public string sql;
        public string des;
    }
    #endregion
}