1

czw

2025-07-06 b5abfccfa680c5ba4b37553990f4865c978dc418

 HnSx/Build/Project/´úÂë/VS×Ô¶¨ÒåÀà/AutoThread.cs

@@ -27,6 +27,20 @@
using NLog.Targets;
using NLog;
using ServiceStack.Messaging.Rcon;
using System.Runtime.ExceptionServices;
using System.Runtime.InteropServices;
using System.Security.RightsManagement;
using static GZ.Projects.HnSx.Clloc.sendTask;
using static GZ.Projects.HnSx.Clloc.modifyTaskPriority;
using static GZ.Projects.HnSx.Clloc.stockInException;
using static GZ.Projects.HnSx.Clloc.taskFeedback;
using static GZ.Projects.HnSx.Clloc.stockInInteraction;
using static GZ.Projects.HnSx.Clloc.cancelTask;
using static GZ.Projects.HnSx.Clloc.palletStackerInteraction;
using static GZ.Projects.HnSx.Clloc.putConveyorTask;
using static GZ.Projects.HnSx.Clloc.reportWeightinfo;
using System.Threading.Channels;
using static GZ.Projects.HnSx.Clloc;

namespace GZ.Projects.HnSx
{
@@ -104,11 +118,37 @@
        /// </summary>
        /// <param name="tag"></param>
        /// <param name="action"></param>
        public void ThreadSettingInit(Tag tag, Action action)
        public void ThreadSettingInit(Tag tag)
        {

            LogHelper.Info("<<<<<<<<<<<<<<<<<<<....Running....>>>>>>>>>>>>>>>");
        }
        public void TaskEverythingRun()

        public async void ThreadwebSoc()
        {
            //read Alldata from database
            //将数据缓存到内存。
            try
            {
                Thread.Sleep(1000);
                while (true)
                {
                    if (/*list.Count > 0 && */WebSocketClientWithReconnect.GetWebSocketState() == WebSocketState.Open)
                        for (int i = 60000; i < 70000; i++)
                        {
                            Thread.Sleep(1000);
                            Console.WriteLine($"{DateTime.Now.ToString("HH:mm:ss.fff")}>>>GGG{i}");
                            LogHelper.Info($"{DateTime.Now.ToString("HH:mm:ss.fff")}>>>GGG{i}");
                            var b = WebSocketClientWithReconnect.Instance?.SendAsync($"He >>GGG{i}").Result;
                            Console.WriteLine("发送完成！！" + b);
                        }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex.Message, ex);
            }
        }
        public async Task TaskEverythingRun()
        {
            var host = System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName());
            foreach (var ip in host.AddressList)
@@ -119,35 +159,11 @@
                    //new HttpServer(ip.ToString()).HttpServerRun();
                    //new TcpServer(ip.ToString());
                    //var server = new EnhancedWebSocketServer($"http://{ip.ToString()}:8809/").StartAsync();
                    var client = new WebSocketClientWithReconnect($"ws://{ip.ToString()}:8809/socket")/*.StartAsync()*/;
                    //Task.Run(async () =>
                    //{
                    client.StartAsync();
                    Task.Run(async () =>
                    new WebSocketClientWithReconnect($"ws://{ip.ToString()}:8809/socket").StartAsync();
                    WebSocketClientWithReconnect.Instance.OnMessageReceived += (msg) =>
                    {
                        while (true)
                        {
                            for (int i = 0; i < 10000; i++)
                            {
                                Thread.Sleep(1000);
                                Console.WriteLine($"{DateTime.Now.ToString("HH:mm:ss.fff")}>>>Server{i}");
                               await client.SendAsync($"Hello Server{i}!");
                            }
                        }
                    });
                    //Task.Run(async () =>
                    //{
                    //    while (true)
                    //    {
                    //        for (int i = 60000; i < 70000; i++)
                    //        {
                    //            Thread.Sleep(1000);
                    //            Console.WriteLine($"{DateTime.Now.ToString("HH:mm:ss.fff")}>>>GGG{i}");
                    //            await client.SendAsync($"Hello GGG{i}!");
                    //        }
                    //    }
                    //});
                    //});
                        reportWeightinfo.channel.Writer.TryWrite(JsonConvert.DeserializeObject<ReportWeightInfoResponse>(msg));
                    };
                    break;
                }
            }
@@ -158,6 +174,7 @@
    }
    public class HttpServer
    {
        public static readonly HttpHelper apiHelper = new HttpHelper();
        System.Net.HttpListener HttpSvcHost = null;

        public static string _listenerPrefix = "";
@@ -226,6 +243,9 @@
                Console.WriteLine(apth + "<<>>" + DateTime.Now.Subtract(data).TotalMilliseconds);
            }
        }
        public static List<SendTaskHeader> lstr = new List<SendTaskHeader>();
        public static List<PutConveyorTaskHeader> putConveyorTasks = new List<PutConveyorTaskHeader>();

        private System.String HttpSvcListenerCallback_he(System.String method, System.String path, System.String requestJson, out System.Net.HttpStatusCode statusCode)
        {
            try
@@ -240,67 +260,359 @@
                                case "/api/Wcs/sendTask":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;

                                        return JsonConvert.SerializeObject("");
                                        var req = JsonConvert.DeserializeObject<SendTaskRequest>(requestJson);
                                        if (lstr.Find(x => x.PalletId == req.Data.Header.PalletId) != null)
                                            return JsonConvert.SerializeObject(new SendTaskResponse
                                            {
                                                Response = new ResponseData
                                                {
                                                    Return = new ReturnInfo
                                                    {
                                                        ReturnCode = "0001",
                                                        ReturnDesc = "托盘重复下发！！！",
                                                        ReturnFlag = "0"
                                                    }
                                                }
                                            });
                                        return JsonConvert.SerializeObject(new SendTaskResponse
                                        {
                                            Response = new ResponseData
                                            {
                                                Return = new ReturnInfo
                                                {
                                                    ReturnCode = "0000",
                                                    ReturnDesc = "ok",
                                                    ReturnFlag = "1"
                                                }
                                            }
                                        });
                                    }
                                ///入库异常上报。 WCS-->WMS
                                case "/api/Wcs/stockInException":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;

                                        return JsonConvert.SerializeObject("");
                                        var f = lstr.FirstOrDefault();
                                        var str = apiHelper.Post("mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new StockInExceptionRequest
                                        {
                                            Data = new StockInExceptionData
                                            {
                                                Header = new StockInExceptionHeader
                                                {
                                                    OrganizationId = f.OrganizationId,
                                                    WarehouseId = f.WarehouseId,
                                                    GroupTaskId = f.GroupTaskId,
                                                    GroupTaskSequence = f.GroupTaskSequence,
                                                    PalletId = f.PalletId,
                                                    AddTime = f.AddTime,
                                                    AddWho = f.AddWho,
                                                    Reason = "库位有货不可用",
                                                    ReasonCode = "01"
                                                }
                                            }
                                        }));
                                        return str;
                                    }
                                ///任务状态反馈  WCS-->WM
                                case "/api/Wcs/taskFeedback":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;
                                        foreach (var statu in new List<string> { "", "" })
                                        {

                                            var f = lstr.FirstOrDefault();
                                            var str = apiHelper.Post("mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new TaskFeedbackRequest
                                            {
                                                Data = new TaskFeedbackData
                                                {
                                                    Header = new TaskFeedbackHeader
                                                    {
                                                        OrganizationId = f.OrganizationId,
                                                        WarehouseId = f.WarehouseId,
                                                        GroupTaskId = f.GroupTaskId,
                                                        GroupTaskSequence = f.GroupTaskSequence,
                                                        PalletId = f.PalletId,
                                                        FmLocation = f.FmLocation,
                                                        FmPosition = f.FmPosition,
                                                        ToLocation = f.ToLocation,
                                                        ToPosition = f.ToPosition,
                                                        TaskStatus = "80",
                                                        TaskType = f.TaskType,
                                                        CloseTime = DateTime.Now,
                                                        CloseWho = f.AddWho
                                                    }
                                                }
                                            }));
                                        }
                                        return JsonConvert.SerializeObject("");
                                    }
                                ///入库交互  ã€‚WCS-->WMS
                                case "/api/Wcs/stockInInteraction":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;

                                        return JsonConvert.SerializeObject("");
                                        var str = apiHelper.Post("mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new StockInInteractionRequest
                                        {
                                            Data = new StockInInteractionData
                                            {
                                                Header = new StockInInteractionHeader
                                                {
                                                    PalletId = "TP9901",
                                                    GrossWeight = 99,
                                                    PalletWidth = 99,
                                                    FmLocation = "",
                                                    FmPosition = "",
                                                    AddTime = DateTime.Now,
                                                    AddWho = ""
                                                }
                                            }
                                        }));
                                        return str;
                                    }

                                ///任务取消。 WMS-->WCS
                                case "/api/Wcs/cancelTask":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;

                                        return JsonConvert.SerializeObject("");
                                        var req = JsonConvert.DeserializeObject<CancelTaskRequest>(requestJson);
                                        var task = lstr.Find(x => x.GroupTaskId == req.Data.Header.GroupTaskId && x.GroupTaskSequence == req.Data.Header.GroupTaskSequence);
                                        if (task == null)
                                            return JsonConvert.SerializeObject(new CancelTaskResponse
                                            {
                                                Response = new ResponseData
                                                {
                                                    Return = new ReturnInfo
                                                    {
                                                        ReturnCode = "0001",
                                                        ReturnDesc = "任务不存在！！！",
                                                        ReturnFlag = "0"
                                                    }
                                                }
                                            });
                                        lstr.Remove(task);
                                        return JsonConvert.SerializeObject(new CancelTaskResponse
                                        {
                                            Response = new ResponseData
                                            {
                                                Return = new ReturnInfo
                                                {
                                                    ReturnCode = "0000",
                                                    ReturnDesc = "",
                                                    ReturnFlag = "1"
                                                }
                                            }
                                        });
                                    }
                                /// ç¢Ÿç›˜æœºç”³è¯·ä»»åŠ¡ã€‚  WCS-->WMS
                                case "/api/Wcs/palletStackerInteraction":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;

                                        return JsonConvert.SerializeObject("");
                                        var str = apiHelper.Post("mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new PalletStackerInteractionRequest
                                        {
                                            Data = new PalletStackerInteractionData
                                            {
                                                Header = new PalletStackerInteractionHeader
                                                {
                                                    PalletId = "TP9901",
                                                    TaskId = $"X{DateTime.Now.ToString("yyyy-MM-dd")}001",
                                                    TaskType = "PI",
                                                    FmLocation = "2FC1076",
                                                    AddTime = DateTime.Now,
                                                    AddWho = "wcs"
                                                }
                                            }
                                        }));
                                        return str;
                                        //return JsonConvert.SerializeObject("");
                                    }
                                ///修改任务优先级 ã€‚ WMS - WCS
                                case "/api/Wcs/modifyTaskPriority":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;
                                        var req = JsonConvert.DeserializeObject<ModifyTaskPriorityRequest>(requestJson);
                                        List<TaskErrorInfo> taskErrorInfos = new List<TaskErrorInfo>();
                                        if (req != null)
                                        {
                                            foreach (var item in req.Data.Header)
                                            {
                                                var task = lstr.Find(x => x.GroupTaskSequence == item.GroupTaskSequence && x.GroupTaskId == item.GroupTaskId);
                                                if (task != null)
                                                {
                                                    task.Priority = item.Priority;
                                                }
                                                else
                                                {
                                                    taskErrorInfos.Add(new TaskErrorInfo
                                                    {
                                                        GroupTaskId = item.GroupTaskId,
                                                        GroupTaskSequence = item.GroupTaskSequence,
                                                        ErrorCode = "0001",
                                                        ErrorDesc = "没这个任务"
                                                    });
                                                }
                                            }

                                        return JsonConvert.SerializeObject("");
                                        }

                                        if (req == null || req.Data.Header.Count == taskErrorInfos.Count)
                                            return JsonConvert.SerializeObject(new ModifyTaskPriorityResponse
                                            {
                                                Response = new ModifyTaskPriorityResponseData
                                                {
                                                    Return = new ModifyTaskPriorityReturnInfo
                                                    {
                                                        ReturnCode = "0001",
                                                        ReturnDesc = "没有任务可更改",
                                                        ReturnFlag = "0"
                                                    }
                                                }
                                            });
                                        else
                                        {
                                            if (taskErrorInfos.Count == 0)
                                                return JsonConvert.SerializeObject(new ModifyTaskPriorityResponse
                                                {
                                                    Response = new ModifyTaskPriorityResponseData
                                                    {
                                                        Return = new ModifyTaskPriorityReturnInfo
                                                        {
                                                            ReturnCode = "0000",
                                                            ReturnFlag = "1"
                                                        }
                                                    }
                                                });
                                            else
                                            {
                                                return JsonConvert.SerializeObject(new ModifyTaskPriorityResponse
                                                {
                                                    Response = new ModifyTaskPriorityResponseData
                                                    {
                                                        Return = new ModifyTaskPriorityReturnInfo
                                                        {
                                                            ReturnCode = "0001",
                                                            ReturnDesc = "部分任务可更改",
                                                            ReturnFlag = "2",
                                                            ResultInfo = taskErrorInfos
                                                        }
                                                    }
                                                });
                                            }
                                        }

                                    }
                                /// è¾“送线任务推送。 WMS-->WCS  -- è®°å½•ç®±å·æ•°æ®ï¼Œåˆ†æ‹£ä¸‹çº¿åŽæ ¹æ®æƒ³å¥½è¿›å…¥å¯¹åº”的区域。 
                                case "/api/Wcs/putConveyorTask":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;
                                        var req = JsonConvert.DeserializeObject<PutConveyorTaskRequest>(requestJson);
                                        List<TaskErrorInfo> taskErrorInfos = new List<TaskErrorInfo>();
                                        if (req != null)
                                        {
                                            foreach (var item in req.Data.Header)
                                            {
                                                var task = putConveyorTasks.Find(x => x.GroupTaskSequence == item.GroupTaskSequence && x.GroupTaskId == item.GroupTaskId);
                                                if (task == null)
                                                {
                                                    putConveyorTasks.Add(item);
                                                }
                                                else
                                                {
                                                    taskErrorInfos.Add(new TaskErrorInfo
                                                    {
                                                        GroupTaskId = item.GroupTaskId,
                                                        GroupTaskSequence = item.GroupTaskSequence,
                                                        ErrorCode = "0001",
                                                        ErrorDesc = "重复"
                                                    });
                                                }
                                            }

                                        return JsonConvert.SerializeObject("");
                                        }

                                        if (req == null || req.Data.Header.Count == taskErrorInfos.Count)
                                            return JsonConvert.SerializeObject(new PutConveyorTaskResponse
                                            {
                                                Response = new PutConveyorTaskResponseData
                                                {
                                                    Return = new PutConveyorTaskReturnInfo
                                                    {
                                                        ReturnCode = "0001",
                                                        ReturnDesc = "全部重复",
                                                        ReturnFlag = "0"
                                                    }
                                                }
                                            });
                                        else
                                        {
                                            if (taskErrorInfos.Count == 0)
                                                return JsonConvert.SerializeObject(new PutConveyorTaskResponse
                                                {
                                                    Response = new PutConveyorTaskResponseData
                                                    {
                                                        Return = new PutConveyorTaskReturnInfo
                                                        {
                                                            ReturnCode = "0000",
                                                            ReturnFlag = "1"
                                                        }
                                                    }
                                                });
                                            else
                                            {
                                                return JsonConvert.SerializeObject(new PutConveyorTaskResponse
                                                {
                                                    Response = new PutConveyorTaskResponseData
                                                    {
                                                        Return = new PutConveyorTaskReturnInfo
                                                        {
                                                            ReturnCode = "0001",
                                                            ReturnDesc = "部分重复",
                                                            ReturnFlag = "2",
                                                            ResultInfo = taskErrorInfos
                                                        }
                                                    }
                                                });
                                            }
                                        }
                                    }

                                ///上报称重尺寸 - websocket .这里写着作为记录 
                                case "/api/Wcs/reportWeightinfo":
                                    {
                                        statusCode = System.Net.HttpStatusCode.OK;
                                        if (/*list.Count > 0 && */WebSocketClientWithReconnect.GetWebSocketState() == WebSocketState.Open)
                                        //for (int i = 60000; i < 70000; i++)
                                        {
                                            //Thread.Sleep(1000);
                                            var req = new ReportWeightInfoRequest
                                            {
                                                Data = new ReportWeightInfoData
                                                {
                                                    Header = new ReportWeightInfoHeader
                                                    {
                                                        DeliveryNo = "F00001",
                                                        GrossWeight = 99,
                                                        Cube = 66,
                                                        AddTime = DateTime.Now,
                                                        AddWho = "WCS"
                                                    }
                                                }
                                            };
                                            //Console.WriteLine($"{DateTime.Now.ToString("HH:mm:ss.fff")}>>>GGG{i}");
                                            LogHelper.Info(JsonConvert.SerializeObject(req));
                                            var b = WebSocketClientWithReconnect.Instance?.SendAsync(JsonConvert.SerializeObject(req)).Result;
                                            Console.WriteLine(req.Data.Header.DeliveryNo + "发送完成！！" + b);
                                            if (b == true)
                                            {
                                                // ç­‰å¾…特定响应

                                        return JsonConvert.SerializeObject("");
                                                var rr = reportWeightinfo.GetChinnnl().Result;

                                                LogHelper.Info("接收" + JsonConvert.SerializeObject(rr));
                                                //}
                                                return JsonConvert.SerializeObject(rr);
                                            }
                                            else return "发送失败。";
                                        }
                                    }
                                    break;
                            }
                            break;
                        }
@@ -470,7 +782,10 @@

    public class WebSocketClientWithReconnect
    {
        private ClientWebSocket _webSocket;
        //public static List<object> SendList = new List<object>();

        public static ClientWebSocket _webSocket;
        private static WebSocketClientWithReconnect _instance;
        private readonly Uri _serverUri;
        private readonly CancellationTokenSource _cts = new CancellationTokenSource();
        private readonly int _reconnectDelayMs;
@@ -485,9 +800,18 @@
            _serverUri = new Uri(serverUrl);
            _reconnectDelayMs = reconnectDelayMs;
        }
        public static WebSocketClientWithReconnect Instance
        {
            get
            {
                return _instance;
            }
        }

        public static WebSocketState GetWebSocketState() => _webSocket != null ? _webSocket.State : WebSocketState.Closed;
        public async Task StartAsync()
        {
            _instance = this;
            while (!_cts.IsCancellationRequested)
            {
                try
@@ -570,7 +894,7 @@
            }
        }

        public async Task SendAsync(string message)
        public async Task<bool> SendAsync(string message)
        {
            if (_webSocket?.State != WebSocketState.Open)
            {
@@ -579,7 +903,7 @@

            var bytes = System.Text.Encoding.UTF8.GetBytes(message);
            await _webSocket.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Text, true, _cts.Token);

            return true;
        }
    }

@@ -849,7 +1173,7 @@
            else
            {
                logger = LogFactory.CreateLogger(name);
                if (logger != null)
                if (logger != null && !loggers.Keys.Contains(name))
                {
                    loggers.Add(name, logger);
                }
@@ -960,5 +1284,862 @@

        #endregion [自定义类][20250323145505759][LogFactory]
    }

    public class HttpHelper
    {
        #region    [自定义类][20250325095622918][HttpHelper]
        public string Post(string url, string postData, string contentType = "application/json", string sessionId = "")
        {
            LogHelper.Info(url + "+" + postData);
            WebRequest request = WebRequest.Create(url);
            request.Method = "POST";
            byte[] byteArray = Encoding.UTF8.GetBytes(postData);
            request.ContentType = contentType;
            request.ContentLength = byteArray.Length;
            request.Timeout = 15000;
            if (sessionId != "")
            {
                request.Headers.Set("ASP.NET_SessionId", sessionId);
            }

            //Authorization: UApGP6WW9FsBUqAlzxRGOw ==
            request.Headers.Set("Authorization", "UApGP6WW9FsBUqAlzxRGOw==");
            StreamReader reader = null;
            Stream stream = null;
            WebResponse rsp = null;
            try
            {
                stream = request.GetRequestStream();
                stream.Write(byteArray, 0, byteArray.Length);
                stream.Close();
                rsp = request.GetResponse();
                stream = rsp.GetResponseStream();
                reader = new StreamReader(stream);
                string rrend = reader.ReadToEnd();
                LogHelper.Info($"{url} response={rrend}");
                return rrend;
            }
            catch (Exception ex)
            {
                LogHelper.Info($"{url} err={ex.Message}");
                return "";
            }
            finally
            {
                // é‡Šæ”¾èµ„源
                if (reader != null) reader.Close();
                if (stream != null) stream.Close();
                if (rsp != null) rsp.Close();
            }

        }
        #endregion [自定义类][20250325095622918][HttpHelper]
    }
    public class Clloc
    {
        public class sendTask
        {
            /// <summary>
            /// ä»»åŠ¡ä¸‹å‘请求
            /// </summary>
            public class SendTaskRequest
            {
                /// <summary>
                /// è¯·æ±‚数据
                /// </summary>
                public SendTaskData Data { get; set; }
            }

            public class SendTaskData
            {
                /// <summary>
                /// è¯·æ±‚头信息
                /// </summary>
                public SendTaskHeader Header { get; set; }
            }

            public class SendTaskHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç»„编号 - ä¸»é”®
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号 - ä¸»é”®
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// æ‰˜ç›˜å·
                /// </summary>
                public string PalletId { get; set; }

                /// <summary>
                /// æ¥æºåº“位
                /// </summary>
                public string FmLocation { get; set; }

                /// <summary>
                /// æ¥æºç‚¹ä½
                /// </summary>
                public string FmPosition { get; set; }

                /// <summary>
                /// ç›®æ ‡åº“位号
                /// </summary>
                public string ToLocation { get; set; }

                /// <summary>
                /// ç›®æ ‡ç‚¹ä½
                /// </summary>
                public string ToPosition { get; set; }

                /// <summary>
                /// çŠ¶æ€ - 00:创建
                /// </summary>
                public string TaskStatus { get; set; } = "00";

                /// <summary>
                /// ä»»åŠ¡ç±»åž‹ - PA:入库(上架/回库/移库), PK:出库(拣货/移库/补货/盘点), MV:倒库
                /// </summary>
                public string TaskType { get; set; }

                /// <summary>
                /// åˆ›å»ºæ—¶é—´
                /// </summary>
                public DateTime AddTime { get; set; }

                /// <summary>
                /// åˆ›å»ºäºº
                /// </summary>
                public string AddWho { get; set; }

                /// <summary>
                /// ä¼˜å…ˆçº§ - 1-5(1最高,5最低),默认3
                /// </summary>
                public string Priority { get; set; } = "3";

            }

            /// <summary>
            /// ä»»åŠ¡ä¸‹å‘响应
            /// </summary>
            public class SendTaskResponse
            {
                public ResponseData Response { get; set; }
            }

            public class ResponseData
            {
                public ReturnInfo Return { get; set; }
            }

            public class ReturnInfo
            {
                /// <summary>
                /// è¿”回代码 - 0000:成功, å…¶ä»–:失败
                /// </summary>
                public string ReturnCode { get; set; }

                /// <summary>
                /// è¿”回描述
                /// </summary>
                public string ReturnDesc { get; set; }

                /// <summary>
                /// è¿”回标记 - 1:成功, 0:失败
                /// </summary>
                public string ReturnFlag { get; set; }
            }
        }

        public class stockInException
        {
            /// <summary>
            /// å…¥åº“异常请求
            /// </summary>
            public class StockInExceptionRequest
            {
                public StockInExceptionData Data { get; set; }
            }

            public class StockInExceptionData
            {
                public StockInExceptionHeader Header { get; set; }
            }

            public class StockInExceptionHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç»„编号 - ä¸»é”®
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号 - ä¸»é”®
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// æ‰˜ç›˜å·
                /// </summary>
                public string PalletId { get; set; }

                /// <summary>
                /// åˆ›å»ºæ—¶é—´
                /// </summary>
                public DateTime AddTime { get; set; }

                /// <summary>
                /// åˆ›å»ºè®¾å¤‡
                /// </summary>
                public string AddWho { get; set; }

                /// <summary>
                /// å¼‚常原因描述
                /// </summary>
                public string Reason { get; set; }

                /// <summary>
                /// å¼‚常原因代码 - 01:库位有货不可用, 03:入内伸位外伸位有货
                /// </summary>
                public string ReasonCode { get; set; }

                // ... UDF字段
            }

            /// <summary>
            /// å…¥åº“异常响应
            /// </summary>
            public class StockInExceptionResponse
            {
                public StockInExceptionResponseData Response { get; set; }
            }

            public class StockInExceptionResponseData
            {
                public StockInExceptionReturnInfo Return { get; set; }
            }

            public class StockInExceptionReturnInfo : ReturnInfo
            {
                /// <summary>
                /// æ–°åˆ†é…çš„目标库位
                /// </summary>
                public string ToLocation { get; set; }

                /// <summary>
                /// æ–°åˆ†é…çš„目标点位
                /// </summary>
                public string ToPosition { get; set; }
            }
        }

        public class taskFeedback
        {
            /// <summary>
            /// ä»»åŠ¡åé¦ˆè¯·æ±‚
            /// </summary>
            public class TaskFeedbackRequest
            {
                public TaskFeedbackData Data { get; set; }
            }

            public class TaskFeedbackData
            {
                public TaskFeedbackHeader Header { get; set; }
            }

            public class TaskFeedbackHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç»„编号 - ä¸»é”®
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号 - ä¸»é”®
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// æ‰˜ç›˜å·
                /// </summary>
                public string PalletId { get; set; }

                /// <summary>
                /// æ¥æºåº“位
                /// </summary>
                public string FmLocation { get; set; }

                /// <summary>
                /// æ¥æºç‚¹ä½
                /// </summary>
                public string FmPosition { get; set; }

                /// <summary>
                /// ç›®æ ‡åº“位号
                /// </summary>
                public string ToLocation { get; set; }

                /// <summary>
                /// ç›®æ ‡ç‚¹ä½
                /// </summary>
                public string ToPosition { get; set; }

                /// <summary>
                /// çŠ¶æ€ - 80:完成, 98:异常(取货无货)
                /// </summary>
                public string TaskStatus { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç±»åž‹ - PA:入库, PK:出库, MV:倒库
                /// </summary>
                public string TaskType { get; set; }

                /// <summary>
                /// å®Œæˆæ—¶é—´
                /// </summary>
                public DateTime CloseTime { get; set; }

                /// <summary>
                /// å®Œæˆäººå‘˜
                /// </summary>
                public string CloseWho { get; set; }

                // ... UDF字段
            }
        }
        public class stockInInteraction
        {
            /// <summary>
            /// å…¥åº“交互请求
            /// </summary>
            public class StockInInteractionRequest
            {
                public StockInInteractionData Data { get; set; }
            }

            public class StockInInteractionData
            {
                public StockInInteractionHeader Header { get; set; }
            }

            public class StockInInteractionHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// æ‰˜ç›˜å· - ä¸»é”®
                /// </summary>
                public string PalletId { get; set; }

                /// <summary>
                /// æ€»é‡é‡(kg)
                /// </summary>
                public decimal GrossWeight { get; set; }

                /// <summary>
                /// ç ç›˜å®½åº¦(cm)
                /// </summary>
                public decimal PalletWidth { get; set; }

                /// <summary>
                /// æ¥æºåº“位
                /// </summary>
                public string FmLocation { get; set; }

                /// <summary>
                /// æ¥æºç‚¹ä½
                /// </summary>
                public string FmPosition { get; set; }

                /// <summary>
                /// åˆ›å»ºæ—¶é—´
                /// </summary>
                public DateTime AddTime { get; set; }

                /// <summary>
                /// åˆ›å»ºäºº
                /// </summary>
                public string AddWho { get; set; }

                // ... UDF01-UDF10
            }

            /// <summary>
            /// å…¥åº“交互响应
            /// </summary>
            public class StockInInteractionResponse
            {
                public StockInInteractionResponseData Response { get; set; }
            }

            public class StockInInteractionResponseData
            {
                public StockInInteractionReturnInfo Return { get; set; }
            }

            public class StockInInteractionReturnInfo : ReturnInfo
            {
                /// <summary>
                /// ä»»åŠ¡ç»„编号
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// çŠ¶æ€ - 00:创建
                /// </summary>
                public string TaskStatus { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç±»åž‹ - PA:入库
                /// </summary>
                public string TaskType { get; set; }

                /// <summary>
                /// ä¼˜å…ˆçº§ - 1-5(1最高)
                /// </summary>
                public string Priority { get; set; }

                /// <summary>
                /// ç›®æ ‡åº“位号
                /// </summary>
                public string ToLocation { get; set; }

                /// <summary>
                /// ç›®æ ‡ç‚¹ä½
                /// </summary>
                public string ToPosition { get; set; }
            }
        }
        public class cancelTask
        {
            /// <summary>
            /// ä»»åŠ¡å–消请求
            /// </summary>
            public class CancelTaskRequest
            {
                public CancelTaskData Data { get; set; }
            }

            public class CancelTaskData
            {
                public CancelTaskHeader Header { get; set; }
            }

            public class CancelTaskHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç»„编号 - ä¸»é”®
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号 - ä¸»é”®
                /// </summary>
                public int GroupTaskSequence { get; set; }
            }

            /// <summary>
            /// ä»»åŠ¡å–消响应
            /// </summary>
            public class CancelTaskResponse
            {
                public ResponseData Response { get; set; }
            }
        }
        public class palletStackerInteraction
        {
            /// <summary>
            /// å ç›˜æœºäº¤äº’请求
            /// </summary>
            public class PalletStackerInteractionRequest
            {
                public PalletStackerInteractionData Data { get; set; }
            }

            public class PalletStackerInteractionData
            {
                public PalletStackerInteractionHeader Header { get; set; }
            }

            public class PalletStackerInteractionHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç¼–号 - ä¸»é”®ï¼Œè®¾å¤‡å‘出的请求ID
                /// </summary>
                public string TaskId { get; set; }

                /// <summary>
                /// æ‰˜ç›˜å·
                /// </summary>
                public string PalletId { get; set; }

                /// <summary>
                /// ç±»åž‹ - PI:入库, PT:出库(当前无出库场景)
                /// </summary>
                public string TaskType { get; set; }

                /// <summary>
                /// èµ·å§‹åº“位 - å ç›˜æœºç‰©ç†èµ·å§‹ä½ç½®
                /// </summary>
                public string FmLocation { get; set; }

                /// <summary>
                /// ä¼˜å…ˆçº§ - 1-5(1最高)
                /// </summary>
                public string Priority { get; set; } = "3";

                /// <summary>
                /// åˆ›å»ºæ—¶é—´
                /// </summary>
                public DateTime AddTime { get; set; }

                /// <summary>
                /// åˆ›å»ºè®¾å¤‡
                /// </summary>
                public string AddWho { get; set; }

                // ... UDF01-UDF10
            }

            /// <summary>
            /// å ç›˜æœºäº¤äº’响应
            /// </summary>
            public class PalletStackerInteractionResponse
            {
                public ResponseData Response { get; set; }
            }

        }
        public class modifyTaskPriority
        {
            /// <summary>
            /// ä¿®æ”¹ä»»åŠ¡ä¼˜å…ˆçº§è¯·æ±‚
            /// </summary>
            public class ModifyTaskPriorityRequest
            {
                public ModifyTaskPriorityData Data { get; set; }
            }

            public class ModifyTaskPriorityData
            {
                public List<ModifyTaskPriorityHeader> Header { get; set; }
            }

            public class ModifyTaskPriorityHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç»„编号 - ä¸»é”®
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号 - ä¸»é”®
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// ä¼˜å…ˆçº§ - 1-5(1最高)
                /// </summary>
                public string Priority { get; set; }
            }

            /// <summary>
            /// ä¿®æ”¹ä»»åŠ¡ä¼˜å…ˆçº§å“åº”(支持部分成功)
            /// </summary>
            public class ModifyTaskPriorityResponse
            {
                public ModifyTaskPriorityResponseData Response { get; set; }
            }

            public class ModifyTaskPriorityResponseData
            {
                public ModifyTaskPriorityReturnInfo Return { get; set; }
            }

            public class ModifyTaskPriorityReturnInfo : ReturnInfo
            {
                /// <summary>
                /// éƒ¨åˆ†æˆåŠŸæ—¶çš„错误详情
                /// </summary>
                public List<TaskErrorInfo> ResultInfo { get; set; }
            }

            public class TaskErrorInfo
            {
                /// <summary>
                /// ä»»åŠ¡ç»„编号
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// é”™è¯¯ä»£ç 
                /// </summary>
                public string ErrorCode { get; set; }

                /// <summary>
                /// é”™è¯¯åŽŸå› 
                /// </summary>
                public string ErrorDesc { get; set; }
            }
        }
        public class putConveyorTask
        {
            /// <summary>
            /// è¾“送线任务推送请求
            /// </summary>
            public class PutConveyorTaskRequest
            {
                public PutConveyorTaskData Data { get; set; }
            }

            public class PutConveyorTaskData
            {
                public List<PutConveyorTaskHeader> Header { get; set; }
            }

            public class PutConveyorTaskHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// ä»»åŠ¡ç»„编号 - ä¸»é”®
                /// </summary>
                public string GroupTaskId { get; set; }

                /// <summary>
                /// ä»»åŠ¡ç»„序号 - ä¸»é”®
                /// </summary>
                public int GroupTaskSequence { get; set; }

                /// <summary>
                /// ç®±å·
                /// </summary>
                public string PalletId { get; set; }

                /// <summary>
                /// ç®±åž‹ - å¤§ç®±/小箱/周转箱编码
                /// </summary>
                public string PalletIdType { get; set; }

                /// <summary>
                /// è´´æ ‡æ ‡è®° - Y:需要贴标, N:不需要
                /// </summary>
                public string SyncFlag { get; set; }

                /// <summary>
                /// ç›®æ ‡åŒºåŸŸ/道口 - ç‰©ç†ä½ç½®é“口编码或B2C复核台区域编码
                /// </summary>
                public string DLocation { get; set; }

                // ... UDF01-UDF10
            }

            /// <summary>
            /// è¾“送线任务推送响应(支持部分成功)
            /// </summary>
            public class PutConveyorTaskResponse
            {
                public PutConveyorTaskResponseData Response { get; set; }
            }

            public class PutConveyorTaskResponseData
            {
                public PutConveyorTaskReturnInfo Return { get; set; }
            }

            public class PutConveyorTaskReturnInfo : ReturnInfo
            {
                /// <summary>
                /// éƒ¨åˆ†æˆåŠŸæ—¶çš„错误详情
                /// </summary>
                public List<TaskErrorInfo> ResultInfo { get; set; }
            }
        }
        public class reportWeightinfo
        {
            public static Channel<ReportWeightInfoResponse> channel = Channel.CreateUnbounded<ReportWeightInfoResponse>();

            internal static async Task<ReportWeightInfoReturnInfo> GetChinnnl()
            {
                //var response = await reportWeightinfo.channel.Reader.ReadAllAsync();// foreach (var response in reportWeightinfo.channel.Reader.ReadAllAsync())
                //{
                //    return response?.Response?.Return ?? new ReportWeightInfoReturnInfo { ReturnCode = "0001", SortingChute = "0", ReturnDesc = "返回为空。" };
                //}
                while (await reportWeightinfo.channel.Reader.WaitToReadAsync(CancellationToken.None))
                {
                    while (reportWeightinfo.channel.Reader.TryRead(out var response))
                    {
                        return response?.Response?.Return ?? new ReportWeightInfoReturnInfo { ReturnCode = "0001", SortingChute = "0", ReturnDesc = "返回为空。" };
                    }
                }
                return new ReportWeightInfoReturnInfo { ReturnCode = "0001", SortingChute = "0", ReturnDesc = "返回为空。" };
            }

            /// <summary>
            /// ä¸ŠæŠ¥ç§°é‡ä¿¡æ¯è¯·æ±‚
            /// </summary>
            public class ReportWeightInfoRequest
            {
                public ReportWeightInfoData Data { get; set; }
            }

            public class ReportWeightInfoData
            {
                public ReportWeightInfoHeader Header { get; set; }
            }

            public class ReportWeightInfoHeader
            {
                /// <summary>
                /// ç»„织编号 - ä¸»é”®ï¼Œé»˜è®¤MERCURY
                /// </summary>
                public string OrganizationId { get; set; } = "MERCURY";

                /// <summary>
                /// ä»“库编号 - ä¸»é”®ï¼Œé»˜è®¤HN02
                /// </summary>
                public string WarehouseId { get; set; } = "HN02";

                /// <summary>
                /// é¢å•å· - ä¸»é”®
                /// </summary>
                public string DeliveryNo { get; set; }

                /// <summary>
                /// é‡é‡(kg)
                /// </summary>
                public decimal GrossWeight { get; set; }

                /// <summary>
                /// ä½“积(立方厘米)
                /// </summary>
                public decimal Cube { get; set; }

                /// <summary>
                /// åˆ›å»ºæ—¶é—´
                /// </summary>
                public DateTime AddTime { get; set; }

                /// <summary>
                /// åˆ›å»ºè®¾å¤‡
                /// </summary>
                public string AddWho { get; set; }

                // ... UDF字段
            }

            /// <summary>
            /// ä¸ŠæŠ¥ç§°é‡ä¿¡æ¯å“åº”
            /// </summary>
            public class ReportWeightInfoResponse
            {
                public ReportWeightInfoResponseData Response { get; set; }
            }

            public class ReportWeightInfoResponseData
            {
                public ReportWeightInfoReturnInfo Return { get; set; }
            }

            public class ReportWeightInfoReturnInfo : ReturnInfo
            {
                /// <summary>
                /// åˆ†æ‹£é“口 - è¾“送线快速分拣道口编码
                /// </summary>
                public string SortingChute { get; set; }
            }
        }

    }
}
#endregion [自定义类-VS][20250701112200484][AutoThread]