using Mushiny;
using OnlineStore.Common;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace CtuDeviceLib
{
    public class SMFManager
    {
        #region 原材料 ctu
        /// <summary>
        /// 原材料-出库更改任务状态
        /// </summary>
        private static string Addr_finished_ctu_updateTaskStatus = "/cdevice/updateTaskStatus";
        /// <summary>
        /// 原材料-出库更改任务状态
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <param name="boxStr"></param>
        /// <param name="status"></param>
        /// <param name="locInfo"></param>
        /// <param name="canRemove"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool updateFinishedTaskStatus(string deviceName, string serverBase, string boxStr, string status, out bool canRemove, out string msg)
        {
            msg = "";
            canRemove = false;
            try
            {
                if (String.IsNullOrEmpty(boxStr))
                {
                    return true;
                }
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + " updateTaskStatus   [" + boxStr + "]  [" + status + "]  :未找到服务器地址");
                    return false;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                    { "boxStr", boxStr },//barcode = 料箱码
                    { "statusStr", status },   // status = 状态信息
                };
                string server = GetAddr(serverBase, Addr_finished_ctu_updateTaskStatus, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, JsonHelper.SerializeObject(paramMap));
                msg = deviceName + " " + ("updateTaskStatus   " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】" + $"【boxStr={boxStr}】【statusStr={status}】" + "【" + resultStr + "】");
                // 返回: { "code": 0, "msg":"ok", "data":""}
                ServerData serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(303).Equals(true))
                {
                    canRemove = true;
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " updateTaskStatus ", ex);
            }
            return false;
        }
        public static string LineToShelfTasksStr = "";
        /// <summary>
        /// 原材料CTU-获取线体到架子的入库任务(入满箱或出库后回库)
        /// </summary>
        private static string Addr_finished_ctu_lineToShelfTasks = "/cdevice/lineToShelfTasks";
        /// <summary>
        /// 原材料CTU-获取线体到架子的入库任务(入满箱或出库后回库)
        /// </summary>
        public static List<FinishedCtuTask> GetLineToShelfTasks(string deviceName, string serverBase)
        {
            var list = new List<FinishedCtuTask>();
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "GetLineToShelfTask :未找到服务器地址");
                    return list;
                }
                string server = GetAddr(serverBase, Addr_finished_ctu_lineToShelfTasks, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<SmfFinishedData>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "GetLineToShelfTask 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " GetLineToShelfTask【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return list;
                }
                if (serverResult.data != null)
                {
                    list = serverResult.data;
                    if (list != null && list.Count > 0)
                    {
                        StringBuilder sb = new StringBuilder();
                        sb.AppendLine($"任务数量：{list.Count}");
                        list.ForEach(s => sb.AppendLine($"【{s.boxCode}】【{s.fromLoc}】->【{s.toLoc}】"));
                        LineToShelfTasksStr = sb.ToString();
                    }
                    else
                    {
                        LineToShelfTasksStr = "";
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " GetLineToShelfTask ", ex);
            }
            return list;
        }
        public static string ShelfToLineTasksStr = "";
        /// <summary>
        /// 原材料CTU获取架子到线体的出库任务(出空箱到入料机构或出库到出料机构)
        /// </summary>
        private static string Addr_finished_ctu_shelfToLineTasks = "/cdevice/shelfToLineTasks";
        public static List<FinishedCtuTask> GetShelfToLineTasks(string deviceName, string serverBase)
        {
            var list = new List<FinishedCtuTask>();
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "GetShelfToLineTasks :未找到服务器地址");
                    return list;
                }
                string server = GetAddr(serverBase, Addr_finished_ctu_shelfToLineTasks, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<SmfFinishedData>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "GetShelfToLineTasks 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " GetShelfToLineTasks【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return list;
                }
                if (serverResult.data != null)
                {
                    list = serverResult.data;
                    if (list != null && list.Count > 0)
                    {
                        StringBuilder sb = new StringBuilder();
                        sb.AppendLine($"任务数量：{list.Count}");
                        list.ForEach(s => sb.AppendLine($"【{s.boxCode}】【{s.fromLoc}】->【{s.toLoc}】"));
                        ShelfToLineTasksStr = sb.ToString();
                    }
                    else
                    {
                        ShelfToLineTasksStr = "";
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " GetShelfToLineTasks ", ex);
            }
            return list;
        }

        /// <summary>
        /// 原材料CTU获取架子到线体的出库任务(出空箱到入料机构或出库到出料机构)
        /// </summary>
        private static string Addr_finished_ctu_allShelfToLineTasks = "/cdevice/allShelfToLineTasks";
        public static List<FinishedCtuTask> GetAllShelfToLineTasks(string deviceName, string serverBase)
        {
            var list = new List<FinishedCtuTask>();
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "GetAllShelfToLineTasks :未找到服务器地址");
                    return list;
                }
                string server = GetAddr(serverBase, Addr_finished_ctu_allShelfToLineTasks, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<SmfFinishedData>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "GetAllShelfToLineTasks 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " GetAllShelfToLineTasks【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return list;
                }
                if (serverResult.data != null)
                {
                    list = serverResult.data;
                    if (list != null && list.Count > 0)
                    {
                        StringBuilder sb = new StringBuilder();
                        sb.AppendLine($"任务数量：{list.Count}");
                        list.ForEach(s => sb.AppendLine($"【{s.boxCode}】【{s.fromLoc}】->【{s.toLoc}】"));
                        ShelfToLineTasksStr = sb.ToString();
                    }
                    else
                    {
                        ShelfToLineTasksStr = "";
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " GetAllShelfToLineTasks ", ex);
            }
            return list;
        }
        /// <summary>
        /// 原材料CTU更新料箱位置信息
        /// </summary>
        private static string Addr_finished_ctu_updateBoxLoc = "/cdevice/updateBoxLoc";
        /// <summary>
        /// 用于生成CTU位置
        /// </summary>
        /// <param name="ctuIdx"></param>
        /// <param name="basketRow"></param>
        /// <returns></returns>
        public static string GenCtuLoc(CTU ctu, string taskId)
        {
            var row = ctu.Baskets.Find(s => s.TaskId == taskId);
            return $"CTU{ctu.Name}_{row?.Row}";
        }
        /// <summary>
        /// 更新料箱位置信息
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <param name="loc">料箱位置信息</param>
        /// <param name="boxStr">料箱编码</param>
        /// <returns></returns>
        public static bool UpdateBoxLoc(string deviceName, string serverBase, string loc, string boxStr)
        {
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "UpdateBoxLoc :未找到服务器地址");
                    return false;
                }
                var para = new Dictionary<string, string>()
                {
                    { "loc",loc},
                    {"boxStr" ,boxStr}
                };
                string server = GetAddr(serverBase, Addr_finished_ctu_updateBoxLoc, para);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "UpdateBoxLoc 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " UpdateBoxLoc【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return false;
                }
                if (serverResult.data != null && serverResult.code == 0)
                {
                    LogUtil.info($"【{deviceName}】UpdateBoxLoc【{server}】【{resultStr}】");
                    return true;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " UpdateBoxLoc ", ex);
            }
            return false;
        }

        /// <summary>
        /// 原材料CTU 定时获取出库任务料箱目的地
        /// </summary>
        private static string Addr_finished_ctu_getOutTargetByBox = " /cdevice/getOutTargetByBox";
        /// <summary>
        /// 入料机构使用--定时获取出库任务料箱目的地
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <param name="boxStr"></param>
        /// <param name="loc"></param>
        /// <returns></returns>
        public static bool GetOutTargetByBox(string deviceName, string serverBase, string boxStr, out string loc)
        {
            loc = "";
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "GetOutTargetByBox :未找到服务器地址");
                    return false;
                }
                var para = new Dictionary<string, string>()
                {
                    {"boxStr" ,boxStr}
                };
                string server = GetAddr(serverBase, Addr_finished_ctu_getOutTargetByBox, para);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "GetOutTargetByBox 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " GetOutTargetByBox【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return false;
                }
                if (serverResult.data != null && serverResult.code == 0)
                {
                    loc = serverResult.data;
                    return true;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " GetOutTargetByBox ", ex);
            }
            return false;
        }

        private static string Addr_finished_ctu_manualCanPut = "/cdevice/manualCanPut";
        /// <summary>
        /// CTU是否可以放入人工工位
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <returns></returns>
        public static bool ManualCanPut(string deviceName, string serverBase)
        {
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "GetOutTargetByBox :未找到服务器地址");
                    return false;
                }
                var para = new Dictionary<string, string>()
                {

                };
                string server = GetAddr(serverBase, Addr_finished_ctu_manualCanPut, para);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "ManualCanPut 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " ManualCanPut【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return false;
                }
                if (serverResult.data != null && serverResult.code == 0)
                {
                    return true;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ManualCanPut ", ex);
            }
            return false;
        }
        /// <summary>
        /// 获取所有空隔口的箱子
        /// </summary>
        private static string Addr_finished_ctu_getInStoreBarcode = "/cdevice/getInStoreBarcode";

        public static string InletOutStoreBoxs = "";
        /// <summary>
        /// 获取所有空隔口的箱子
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <returns></returns>
        public static List<InletOutBox> getInStoreBarcode(string deviceName, string serverBase)
        {
            var list = new List<InletOutBox>();
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "getInStoreBarcode :未找到服务器地址");
                    return list;
                }
                string server = GetAddr(serverBase, Addr_finished_ctu_getInStoreBarcode, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                var serverResult = JsonHelper.DeserializeJsonToObject<FinishedInletTask>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "getInStoreBarcode 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " getInStoreBarcode【" + serverResult.code + "】" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                    return list;
                }
                if (serverResult.data != null)
                {
                    list = serverResult.data;
                    if (list != null && list.Count > 0)
                    {
                        StringBuilder sb = new StringBuilder();
                        sb.AppendLine($"空箱总数：{list.Count}");
                        var size7 = list.FindAll(s => "7".Equals(s.size));
                        var size13 = list.FindAll(s => "13".Equals(s.size));
                        var size15 = list.FindAll(s => "15".Equals(s.size));
                        sb.AppendLine($"7寸总数：{size7?.Count}");
                        sb.AppendLine($"13寸总数：{size13?.Count}");
                        sb.AppendLine($"15寸总数：{size15?.Count}");
                        list.ForEach(s => sb.AppendLine($"【{s.box}】【{s.size}】【{s.posName}】【{s.remainNum}】【{s.warehouseCode}】"));
                        InletOutStoreBoxs = sb.ToString();
                    }
                    else
                    {
                        InletOutStoreBoxs = "";
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " getInStoreBarcode ", ex);
            }
            return list;
        }

        private static string Addr_finished_ctu_boxCheckOut = "/cdevice/boxCheckOut";
        public static bool boxCheckOut(string serverBase, string boxCode)
        {
            try
            {
                List<string> param = new List<string> { boxCode };
                DateTime startTime = DateTime.Now;
                string server = "";
                if (serverBase.EndsWith("/"))
                {
                    server = serverBase.Substring(0, serverBase.Length - 1);
                }
                else
                {
                    server = serverBase;
                }
                string resultStr = HttpHelper.Post(server + Addr_finished_ctu_boxCheckOut, JsonHelper.SerializeObject(param));
                // 返回: { "code": 0, "msg":"ok", "data":""}
                var serverResult = JsonHelper.DeserializeJsonToObject<CheckOutRtnData>(resultStr);
                LogUtil.error($"{serverBase + Addr_finished_ctu_boxCheckOut} [{boxCode}]创建空箱任务：{resultStr}");
                if (serverResult == null)
                {
                    return false;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    if (serverResult.data != null)
                    {
                        var find = serverResult.data.Find(s => boxCode.Equals(s.box));
                        return find != null;
                    }
                    return false;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error($"boxCheckOut [{boxCode}]error ", ex);
            }
            return false;

        }

        /// <summary>
        /// 原材料-定时获取出库任务-张少辉-不用
        /// </summary>
        //private static string Addr_finished_ctu_checkOutTask = "/cdevice/checkOutTask";
        ///// <summary>
        ///// 原材料-获取出库任务列表-不用
        ///// </summary>
        //public static List<FinishedOutTask> GetFinishedOutTask(string deviceName, string serverBase)
        //{
        //    List<FinishedOutTask> list = new List<FinishedOutTask>();
        //    //判断任务数》-30 不获取出库任务
        //    //if (!LineManager.CheckTaskCntIsInLimit()) return list;
        //    try
        //    {
        //        string msg = "";
        //        if (string.IsNullOrEmpty(serverBase))
        //        {
        //            LogUtil.error(deviceName + "GetFinishedOutTask :未找到服务器地址");
        //            return list;
        //        }
        //        string server = GetAddr(serverBase, Addr_finished_ctu_checkOutTask, new Dictionary<string, string>());
        //        DateTime startTime = DateTime.Now;
        //        string resultStr = HttpHelper.Get(server);
        //        // ServerData4 serverResult = JsonHelper.DeserializeJsonToObject<ServerData4>(resultStr);
        //        var serverResult = JsonHelper.DeserializeJsonToList<FinishedOutTask>(resultStr);
        //        if (serverResult == null)
        //        {
        //            msg = deviceName + "GetFinishedOutTask 没有收到服务器反馈";
        //        }
        //        else
        //        {
        //            list = serverResult.ToList();                   
        //        }
        //        //else if (serverResult.code.Equals(0).Equals(false))
        //        //{
        //        //    // code: 0为正常,其他为异常, msg: 消息, data: 为空
        //        //    msg = deviceName + " GetFinishedOutTask【" + serverResult.code + "】" + serverResult.msg;
        //        //}
        //        //if (!msg.Equals(""))
        //        //{
        //        //    LogUtil.error(msg);
        //        //    return list;
        //        //}
        //        //if (serverResult.data != null)
        //        //{
        //        //    list = serverResult.data;
        //        //}
        //    }
        //    catch (Exception ex)
        //    {
        //        LogUtil.error(deviceName + " ", ex);
        //    }
        //    return list;
        //}

        /// <summary>
        /// 原材料-料箱入库的时候,调用,返回库位名称-张少辉-不用
        /// </summary>
        //private static string Addr_finifhed_ctu_getTargetByBox = "/cdevice/getTargetByBox";
        ///// <summary>
        ///// 原材料-获取料箱目的地-张少辉-不用
        ///// </summary>
        ///// <param name="deviceName"></param>
        ///// <param name="serverBase"></param>
        ///// <param name="boxStr"></param>
        ///// <param name="posName"></param>
        ///// <returns></returns>
        //public static bool getTargetByBox(string deviceName, string serverBase, string boxStr,out string posName)
        //{
        //    posName = "";
        //    try
        //    {
        //        string msg = "";
        //        if (string.IsNullOrEmpty(serverBase))
        //        {
        //            LogUtil.error(deviceName + " getTargetByBox :未找到服务器地址");
        //            return false;
        //        }
        //        Dictionary<string, string> param = new Dictionary<string, string>
        //        {
        //            { "boxStr", boxStr }
        //        };
        //        string server = GetAddr(serverBase, Addr_finifhed_ctu_getTargetByBox, param);
        //        DateTime startTime = DateTime.Now;
        //        string resultStr = HttpHelper.Get(server);
        //        ServerData serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
        //        if (serverResult == null)
        //        {
        //            msg = deviceName + " getTargetByBox 没有收到服务器反馈";
        //        }
        //        else if (serverResult.code.Equals(0).Equals(false))
        //        {
        //            // code: 0为正常,其他为异常, msg: 消息, data: 为空
        //            msg = deviceName + " getTargetByBox【" + serverResult.code + "】" + serverResult.msg;
        //        }
        //        if (!msg.Equals(""))
        //        {
        //            LogUtil.error(msg);
        //            return false;
        //        }
        //        if (serverResult.data != null)
        //        {
        //            posName = serverResult.data;
        //            return true;
        //        }
        //    }
        //    catch (Exception ex)
        //    {
        //        LogUtil.error(deviceName + " ", ex);
        //    }
        //    return false;
        //}
        #endregion

        #region 半成品 ctu

        public static string SemiFinishedOutTaskStr = "";
        /// <summary>
        /// 取消入库任务
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <returns></returns>
        public static bool CanPutInTask(string serverBase, string barcode)
        {
            List<FinishedOutTask> list = new List<FinishedOutTask>();
            //判断任务数》-30 不获取出库任务
            //if (!LineManager.CheckTaskCntIsInLimit()) return list;
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error($"semiCanPutInTask [{barcode}] :未找到服务器地址");
                    return false;
                }
                Dictionary<string, string> para = new Dictionary<string, string>()
                {
                    {"barcode",barcode}
                };
                string server = GetAddr(serverBase, "/service/store/cancelPutInTask", para);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                // ServerData4 serverResult = JsonHelper.DeserializeJsonToObject<ServerData4>(resultStr);
                var serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                msg = $" semiCanPutInTask 【{server}】【{resultStr}】";
                LogUtil.info(msg);
                if (serverResult == null)
                {
                    msg = "semiCanPutInTask 没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    return true;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error($"semiCanPutInTask 【{barcode}】", ex);
            }
            return false;
        }
        /// <summary>
        /// 半成品CTU-定时获取出库任务
        /// </summary>
        private static string Addr_semiFinished_ctu_checkOutTask = "/agvDevice/getCheckOutTask";
        /// <summary>
        /// 半成品CTU-获取出库任务列表
        /// </summary>
        public static List<FinishedOutTask> GetSemiFinishedOutTask(string deviceName, string serverBase)
        {
            List<FinishedOutTask> list = new List<FinishedOutTask>();
            //判断任务数》-30 不获取出库任务
            //if (!LineManager.CheckTaskCntIsInLimit()) return list;
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "GetSemiFinishedOutTask :未找到服务器地址");
                    return list;
                }
                string server = GetAddr(serverBase, Addr_semiFinished_ctu_checkOutTask, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                // ServerData4 serverResult = JsonHelper.DeserializeJsonToObject<ServerData4>(resultStr);
                var serverResult = JsonHelper.DeserializeJsonToList<FinishedOutTask>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "GetSemiFinishedOutTask 没有收到服务器反馈";
                }
                else
                {
                    list = serverResult.ToList();
                    if (list != null && list.Count > 0)
                    {
                        StringBuilder sb = new StringBuilder();
                        sb.AppendLine($"任务数量：{list.Count}");
                        list.ForEach(s => sb.AppendLine($"【{s.barcode}】【{s.posName}】->【{s.loc}】"));
                        SemiFinishedOutTaskStr = sb.ToString();
                    }
                    else
                    {
                        SemiFinishedOutTaskStr = "";
                    }
                }
                //else if (serverResult.code.Equals(0).Equals(false))
                //{
                //    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                //    msg = deviceName + " GetFinishedOutTask【" + serverResult.code + "】" + serverResult.msg;
                //}
                //if (!msg.Equals(""))
                //{
                //    LogUtil.error(msg);
                //    return list;
                //}
                //if (serverResult.data != null)
                //{
                //    list = serverResult.data;
                //}
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ", ex);
            }
            return list;
        }

        /// <summary>
        /// 半成品-出库更改任务状态
        /// </summary>
        private static string Addr_SemiFinished_ctu_updateTaskStatus = "/agvDevice/updateTaskStatus";
        /// <summary>
        /// 成品-出库更改任务状态
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <param name="boxStr"></param>
        /// <param name="status"></param>
        /// <param name="locInfo"></param>
        /// <param name="canRemove"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool updateSemiFinishedTaskStatus(string deviceName, string serverBase, string boxStr, string status, out bool canRemove, out string msg)
        {
            msg = "";
            canRemove = false;
            try
            {
                if (String.IsNullOrEmpty(boxStr))
                {
                    return true;
                }
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + " updateSemiFinishedTaskStatus   [" + boxStr + "]  [" + status + "]  :未找到服务器地址");
                    return false;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                    { "boxStr", boxStr },//barcode = 料箱码
                    { "statusStr", status },   // status = 状态信息
                };
                string server = GetAddr(serverBase, Addr_SemiFinished_ctu_updateTaskStatus, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, JsonHelper.SerializeObject(paramMap));
                msg = deviceName + " " + ("updateSemiFinishedTaskStatus   " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
                // 返回: { "code": 0, "msg":"ok", "data":""}
                ServerData serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(303).Equals(true))
                {
                    canRemove = true;
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    // msg = deviceName + " UpdateTrayLoc 任务已完成【" + barcode + "】【" + status + "】【" + locInfo + "】  ：" + "【" + serverResult.code + "】" + serverResult.msg;
                    //LogUtil.info(msg);
                    return true;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    // msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】  ：" + "【" + serverResult.code + "】" + serverResult.msg;
                    // LogUtil.info(msg);
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " updateTaskStatus ", ex);
            }
            return false;
        }

        /// <summary>
        /// 半成品-转库更改任务状态
        /// </summary>
        private static string Addr_SemiFinished_ctu_updateSwitchTaskStatus = "/boxTrans/updateBoxTransStatus";
        /// <summary>
        /// 半成品-转库更改任务状态
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <param name="boxStr"></param>
        /// <param name="status"></param>
        /// <param name="locInfo"></param>
        /// <param name="canRemove"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public static bool updateSemiFinishedSwitchTaskStatus(string deviceName, string serverBase, string boxStr, string status, out bool canRemove, out string msg)
        {
            msg = "";
            canRemove = false;
            try
            {
                if (String.IsNullOrEmpty(boxStr))
                {
                    return true;
                }
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + " updateSemiFinishedSwitchTaskStatus   [" + boxStr + "]  [" + status + "]  :未找到服务器地址");
                    return false;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>
                {
                    { "boxStr", boxStr },//barcode = 料箱码
                    { "statusStr", status },   // status = 状态信息
                };
                string server = GetAddr(serverBase, Addr_SemiFinished_ctu_updateSwitchTaskStatus, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, JsonHelper.SerializeObject(paramMap));
                msg = deviceName + " " + ("updateSemiFinishedSwitchTaskStatus   " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
                // 返回: { "code": 0, "msg":"ok", "data":""}
                ServerData serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    //msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】没有收到服务器反馈";
                    return false;
                }
                else if (serverResult.code.Equals(303).Equals(true))
                {
                    canRemove = true;
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    // msg = deviceName + " UpdateTrayLoc 任务已完成【" + barcode + "】【" + status + "】【" + locInfo + "】  ：" + "【" + serverResult.code + "】" + serverResult.msg;
                    //LogUtil.info(msg);
                    return true;
                }
                else if (serverResult.code.Equals(0).Equals(true))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    // msg = deviceName + " UpdateTrayLoc【" + barcode + "】【" + status + "】【" + locInfo + "】  ：" + "【" + serverResult.code + "】" + serverResult.msg;
                    // LogUtil.info(msg);
                    return true;
                }
                else
                    return false;
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " updateSemiFinishedSwitchTaskStatus ", ex);
            }
            return false;
        }


        public static string SemiFinishedPutInTaskStr = "";
        /// <summary>
        /// 半成品-定时获取入库任务
        /// </summary>
        private static string Addr_SemiFinifhed_ctu_getPutInTask = "/agvDevice/getPutInTask";
        /// <summary>
        /// 半成品--定时获取入库任务
        /// </summary>
        /// <param name="deviceName"></param>
        /// <param name="serverBase"></param>
        /// <returns></returns>
        public static List<FinishedOutTask> getSemiPutInTask(string deviceName, string serverBase)
        {
            List<FinishedOutTask> list = new List<FinishedOutTask>();
            //判断任务数》-30 不获取出库任务
            //if (!LineManager.CheckTaskCntIsInLimit()) return list;
            try
            {
                string msg = "";
                if (string.IsNullOrEmpty(serverBase))
                {
                    LogUtil.error(deviceName + "getSemiPutInTask :未找到服务器地址");
                    return list;
                }
                string server = GetAddr(serverBase, Addr_SemiFinifhed_ctu_getPutInTask, new Dictionary<string, string>());
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                // ServerData4 serverResult = JsonHelper.DeserializeJsonToObject<ServerData4>(resultStr);
                var serverResult = JsonHelper.DeserializeJsonToList<FinishedOutTask>(resultStr);
                if (serverResult == null)
                {
                    msg = deviceName + "getSemiPutInTask 没有收到服务器反馈";
                }
                else
                {
                    list = serverResult.ToList();
                    if (list != null && list.Count > 0)
                    {
                        StringBuilder sb = new StringBuilder();
                        sb.AppendLine($"任务数量：{list.Count}");
                        list?.ForEach(s => sb.AppendLine($"【{s.barcode}】【{s.loc}】->【{s.posName}】"));
                        SemiFinishedPutInTaskStr = sb.ToString();
                    }
                    else
                    {
                        SemiFinishedPutInTaskStr = "";
                    }
                }
                //else if (serverResult.code.Equals(0).Equals(false))
                //{
                //    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                //    msg = deviceName + " GetFinishedOutTask【" + serverResult.code + "】" + serverResult.msg;
                //}
                //if (!msg.Equals(""))
                //{
                //    LogUtil.error(msg);
                //    return list;
                //}
                //if (serverResult.data != null)
                //{
                //    list = serverResult.data;
                //}
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ", ex);
            }
            return list;
        }
        #endregion

        /// <summary>
        /// AGV状态上报
        /// </summary>
        static string Addr_agvStatus = "/service/store/agvStatus/agvInfo";

        private static string GetAddr(string serverBaseAddr, string addr, Dictionary<string, string> paramsMap)
        {

            if (serverBaseAddr.EndsWith("/"))
            {
                serverBaseAddr = serverBaseAddr.Substring(0, serverBaseAddr.Length - 1);
            }
            string path = serverBaseAddr + addr.Trim() + "?";
            foreach (string paramName in paramsMap.Keys)
            {
                string par = System.Web.HttpUtility.UrlEncode(paramsMap[paramName], System.Text.Encoding.UTF8);
                path += paramName + "=" + par + "&";
            }
            path = path.Substring(0, path.Length - 1);
            return path;
        }
        #region AGV状态上报
        static string agvStr = "";
        /// <summary>
        /// AGV状态上报
        /// </summary>
        /// <param name="agvStatuses"></param>
        /// <returns></returns>
        public static bool UpdateAgvStatus(string serverBase, List<AgvStatus> agvStatuses)
        {
            return true;
            try
            {
                if (agvStatuses == null || agvStatuses.Count == 0)
                {
                    LogUtil.error($"UpdateAgvStatus 无信息");
                    return false;
                }
                Dictionary<string, string> queryStr = new Dictionary<string, string>();
                //queryStr.Add("rfid", rfid);
                string server = GetAddr(serverBase, Addr_agvStatus, queryStr);
                string content = JsonHelper.SerializeObject(agvStatuses);
                string json = HttpHelper.Post(server, content);
                ServerData rtnData = JsonHelper.DeserializeJsonToObject<ServerData>(json);
                if (string.IsNullOrEmpty(json))
                {
                    LogUtil.error($"UpdateAgvStatus【{content}】【{json}】");
                }
                else if (!agvStr.Equals(content))
                {
                    LogUtil.debug($"UpdateAgvStatus【{content}】【{json}】");
                    agvStr = content;
                }
                if (rtnData != null && rtnData.code == 0)
                {
                    return true;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error($"UpdateAgvStatus 【{JsonHelper.SerializeObject(agvStatuses)}】", ex);

            }
            return false;
        }

        #endregion


    }
    public class AgvStatus
    {
        /// <summary>
        /// 小车名称
        /// </summary>
        public string name { get; set; }
        /// <summary>
        /// 小车电量
        /// </summary>
        public string elec { get; set; }
        /// <summary>
        /// 小车位置
        /// </summary>
        public string loc { get; set; }
        /// <summary>
        /// 错误消息
        /// </summary>
        public string message { get; set; }
        public int type { get; set; }
    }
    /// <summary>
    /// 原材料CTU任务
    /// </summary>
    public class FinishedCtuTask
    {
        /// <summary>
        /// 任务标识
        /// </summary>
        public string id { get; set; }
        /// <summary>
        /// 料箱号
        /// </summary>
        public string boxCode { get; set; }
        /// <summary>
        /// 任务类型
        /// </summary>
        public SmfTaskType taskType { get; set; }
        /// <summary>
        /// 目的地位置
        /// </summary>
        public string toLoc { set; get; }
        /// <summary>
        /// 起点位置
        /// </summary>
        public string fromLoc { get; set; }
        /// <summary>
        /// 任务创建时间
        /// </summary>
        public DateTime createDate { get; set; }
        /// <summary>
        /// 优先级
        /// </summary>
        public int priority { get; set; }
        //        "outCount": {
        //    "C0700379-06": 1
        //},
        /// <summary>
        /// 格口出库数量
        /// </summary>
        public Dictionary<string, int> outCount { get; set; }
    }


    public class FinishedInletTask
    {
        public int code { get; set; }
        public string msg { get; set; }
        public List<InletOutBox> data { get; set; }
    }
    /// <summary>
    /// 入料机构出库料箱
    /// </summary>
    public class InletOutBox
    {
        //                "remainNum": 1,
        //"size": "7",
        //"box": "C0702059",
        //"warehouseCode": "W10B"
        /// <summary>
        /// 剩余隔口数量
        /// </summary>
        public int remainNum { get; set; }
        /// <summary>
        /// 尺寸
        /// </summary>
        public string size { get; set; }
        /// <summary>
        /// 料箱号
        /// </summary>
        public string box { get; set; }
        /// <summary>
        /// 库别
        /// </summary>
        public string warehouseCode { get; set; }
        /// <summary>
        /// 库位
        /// </summary>
        public string posName { get; set; }
    }
    public class FinishedOutTask
    {
        /// <summary>
        /// 料箱号
        /// </summary>
        public string barcode { get; set; }
        /// <summary>
        /// 出库目的地
        /// </summary>
        public string loc { set; get; }
        /// <summary>
        /// 库位号
        /// </summary>
        public string posName { get; set; }
        /// <summary>
        /// 任务创建时间
        /// </summary>
        public DateTime createDate { get; set; }
        //        "extraDataMap": {
        //    "targetPos": "1ABAR00003016R01"
        //},
        /// <summary>
        /// 转库信息
        /// </summary>
        public Dictionary<string, string> extraDataMap { get; set; }
    }
    /// <summary>
    /// 任务类型
    /// </summary>
    public enum SmfTaskType
    {
        Instore = 1,
        OutStore = 2
    }
    /// <summary>
    /// 任务状态
    /// </summary>
    public class TaskStatus
    {
        /// <summary>
        /// 初始状态
        /// </summary>
        public const string WAIT = "WAIT";
        /// <summary>
        /// 已发送到AGV
        /// </summary>
        public const string EXECUTING = "EXECUTING";
        /// <summary>
        ///入库时，人员推上线体
        /// </summary>
        public const string IN_ON_LINE = "IN_ON_LINE";
        /// <summary>
        /// 入库时，AGV从线体上抓起料箱
        /// </summary>
        public const string IN_ON_AGV = "IN_ON_AGV";
        /// <summary>
        /// 出库时,AGV将料箱从库位中取出
        /// </summary>
        public const string OUT_ON_AGV = "OUT_ON_AGV";
        /// <summary>
        ///  出库时,AGV将料箱放上线体，
        /// </summary>
        public const string OUT_ON_LINE = "OUT_ON_LINE";
        /// <summary>
        /// 任务完成
        /// 入库时，AGV将料箱放入库位
        /// 出库时，料箱到达工位
        /// </summary>
        public const string FINISHED = "FINISHED";
        /// <summary>
        /// 任务异常
        /// </summary>
       // public const string ERROR = "ERROR";
        /// <summary>
        /// 出库时，料箱到达工位前
        /// </summary>
        //public const string NEED_AWAY = "NEED_AWAY";
    }
    public class AlarmMsg
    {

        //>>>name :  异常位置名称
        public string name = "";
        //>>>msgKey :  异常信息唯一标识
        public string msgKey = "";
        //>>>msgValue :  异常信息
        public string msgValue = "";

        public AlarmMsg(string n, string key, string value)
        {
            this.name = n;
            this.msgKey = key;
            this.msgValue = value;
        }
    }
    public class ContainerTarget
    {
        public string slotCode { get; set; } = "";
        public string barcode { get; set; } = "";
    }
    public class ServerData
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public string data { get; set; }
    }
    public class ServerData1
    {
        public int code { get; set; }

        public string msg { get; set; }
        public Dictionary<string, object> data { get; set; }
    }
    public class ServerData2
    {
        public int code { get; set; }

        public string msg { get; set; }
        public object data { get; set; }
    }
    public class ServerData3
    {
        public int code { get; set; }

        public string msg { get; set; }
        public NeedInStation data { get; set; }
    }
    public class NeedInStation
    {
        public List<string> needInStation { get; set; }
    }
    public class SmfFinishedData
    {
        public int code { get; set; }

        public string msg { get; set; }
        public List<FinishedCtuTask> data { get; set; }
    }

    public class CheckOutRtnData
    {
        public int code { get; set; }

        public string msg { get; set; }
        public List<PosBox> data { get; set; }
    }
    public class PosBox
    {
        public string posName { get; set; }
        public string box { get; set; }
    }
}