using OnlineStore.Common;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace OnlineStore.DeviceLibrary
{
    public class SServerManager
    {
        //http://localhost/myproject/service/store/emptyPosForPutin
        private static string Addr_PosForPutin = "/service/store/emptyPosForPutin";
        /// <summary>
        /// 1  皮带线扫码后调用,用于获取尺寸后升起气缸
        ///  地址: /rest/api/qisda/device/getSize
        /// </summary>
        private static string Addr_getSize = "/rest/api/qisda/device/getSize";

        /// <summary>
        /// 2  料盘流转位置信息更新
        ///     地址: /rest/api/qisda/device/updateLocInfo
        /// </summary>
        private static string Addr_updateLocInfo = "/rest/api/qisda/device/updateLocInfo";
        ///// <summary>
        ///// 3  放入料架(A,B,C,D)后调用,根据返回值决定当前料架是否放满,以及后续是否还有任务
        ////        地址: /rest/api/qisda/device/putShelfFinished
        ///// </summary>
        //private static string Addr_putShelfFinished = "/rest/api/qisda/device/putShelfFinished";

        private static string serverAddr = ConfigAppSettings.GetValue(Setting_Init.http_server);
        private static string GetAddr(string addr, Dictionary<string, string> paramsMap)
        {

            if (serverAddr.EndsWith("/"))
            {
                serverAddr = serverAddr.Substring(0, serverAddr.Length - 1);
            }
            string path = serverAddr + 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;
        }
        //## 100 循环获取库位。服务器超时：循环获取库位
        private static string spiltStr = "##";
       
        public static string ProcessCodeList(List<string> codeList)
        {
            string codeStr = "";
            List<string> list = new List<string>();
            foreach (string str in codeList)
            {
                if (list.Contains(str.Trim()) || String.IsNullOrEmpty(str.Trim()))
                {
                    continue;
                }
                codeStr = codeStr + str.Trim() + spiltStr;
            }
            return codeStr;
        }
        public static string GetTraySize(string deviceName, int robotIndex, string codeStr, out int outSize, out bool isNg)
        {
            outSize = 0;
            isNg = false;
            string msg = "";
            try
            {
                if (String.IsNullOrEmpty(codeStr))
                {
                    return msg = deviceName + "未扫到条码";
                }
                string logName = $"GetTraySize   [{robotIndex }]  [{codeStr}]  :";
                if (string.IsNullOrEmpty(serverAddr))
                {
                    LogUtil.error(deviceName + $"{logName}未找到服务器地址");
                    return msg;
                }
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("robotIndex", robotIndex.ToString());// 参数: robotIndex = 机器人编号,IP为51的机器人为1, 52的机器人为2, 53的机器人为3
                paramMap.Add("barcode", codeStr);//  barcode = 扫到的条码

                string server = GetAddr(Addr_getSize, paramMap);
                DateTime startTime = DateTime.Now;
                bool isTimeOut = false;
                string resultStr = HttpHelper.Post(server, "", Encoding.UTF8, 5000, out isTimeOut);

                LogUtil.info("GetTraySize   " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
                if (isTimeOut)
                {
                    return msg = "获取尺寸超时";
                }
                //返回: { "code": 0, "msg":"ok", data: 7} 
                ServerData serverResult = JsonHelper.DeserializeJsonToObject<ServerData>(resultStr);
                if (serverResult == null)
                {
                    return msg = "没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    //   code: 0为正常,其他为异常, 
                    //code不是0，直接NG
                    isNg = true;
                    return msg = $" [{ serverResult.code}]:" + serverResult.msg;
                }

                if (!serverResult.data.Equals(""))
                {
                    //   data:料盘直径,= 7时升起气缸
                    outSize = Convert.ToInt32(serverResult.data);
                    LogUtil.info(deviceName + $"{ logName} 获得尺寸：" + outSize);
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ", ex);
            }
            return "";
        }



        public static string UpdateTrayLoc(string deviceName, string barcode, string status, string locInfo)
        {
            string msg = "";
            try
            {
                if (String.IsNullOrEmpty(barcode))
                {
                    return msg;
                }
                if (string.IsNullOrEmpty(serverAddr))
                {
                    LogUtil.error(deviceName + "UpdateTrayLoc   [" + barcode + "]  [" + status + "]  :未找到服务器地址");
                    return msg;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("barcode", barcode);//barcode = 料盘的条码
                paramMap.Add("status", status);   // status = 状态信息, 移栽 = MOVING, 流水线 = INLINE, 皮带线 = INBELT
                paramMap.Add("locInfo", locInfo);  // locInfo = 位置信息,移栽时为移栽编号,流水线时为托盘号,皮带线时为皮带线编号,机器人时为机器人编号
                string server = GetAddr(Addr_updateLocInfo, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info("UpdateTrayLoc   " + 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 + "】没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    // code: 0为正常,其他为异常, msg: 消息, data: 为空
                    msg = deviceName + " UpdateTrayLoc【 " + barcode + "】【" + status + "】【" + locInfo + "】  ：" + "[" + serverResult.code + "]" + serverResult.msg;
                }
                if (!msg.Equals(""))
                {
                    LogUtil.error(msg);
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ", ex);
            }
            return msg;
        }

        private static string Addr_clearPutInRfid = "/service/store/qisda/clearPutInRfid";
        public static string clearPutInRfid(string deviceName, string rfid)
        {
            string msg = "";
            try
            {
                if (String.IsNullOrEmpty(rfid))
                {
                    return msg;
                }
                if (string.IsNullOrEmpty(serverAddr))
                {
                    LogUtil.error(deviceName + "clearPutInRfid   [" + rfid + "]  :未找到服务器地址");
                    return msg;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", rfid);//rfid   
                string server = GetAddr(Addr_clearPutInRfid, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "clearPutInRfid    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");

            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }


        //皮带线获取尺寸后,料盘到达机器人取料位置进调用,如果未扫到码,或者没等到取料位置信号亮,可以不用调用

        //> 地址:
        //>>/rest/api/qisda/device/arrive3fRobotLocation
        //>
        //> 参数: 
        //>> - robotIndex=机器人编号,IP为51的机器人为1, 52的机器人为2, 53的机器人为3
        //>
        //> 返回: 
        //>>``
        private static string Addr_arrive3fRobotLocation = "/rest/api/qisda/device/arrive3fRobotLocation";
        public static string arrive3fRobotLocation(string deviceName, int robotIndex, string barcode)
        {
            string msg = "";
            if (string.IsNullOrEmpty(serverAddr))
            {
                LogUtil.error(deviceName + "arrive3fRobotLocation   [" + robotIndex + "][" + barcode + "]  :未找到服务器地址");
                return msg;
            }
            try
            {
                if (robotIndex <= 0)
                {
                    return "robotIndex="+robotIndex;
                }
                DateTime startTime = DateTime.Now;
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("robotIndex", robotIndex.ToString());//rfid   
                paramMap.Add("barcode", barcode);
                string server = GetAddr(Addr_arrive3fRobotLocation, paramMap);
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "arrive3fRobotLocation      " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
            }
            catch (Exception ex)
            {
                msg = deviceName + " " + ex.ToString();
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }


        //        分盘料/紧急料放上料串或料架时调用 /rest/api/qisda/device/afterPutCut
        private static string Addr_afterPutCut = "/rest/api/qisda/device/afterPutCut";
        public static string afterPutCut(string deviceName, string rfid, string barcode, string cid, int rfidLoc, out TaskData afterData)
        {
            afterData = null;
            string msg = "";
            if (string.IsNullOrEmpty(serverAddr))
            {
                LogUtil.error(deviceName + "afterPutCut   [" + rfid + "][" + barcode + "][" + cid + "][" + rfidLoc + "] :未找到服务器地址");
                return msg;
            }
            try
            {
                //参数:
                //cid:  料仓cid,流水线可传入空
                //barcode : 条码
                //rfid :  RFID
                //rfidLoc: 料架位置,流水线可传-1

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("barcode", barcode);      // 参数: barcode=料盘的条码
                paramMap.Add("rfid", rfid);                     // rfid = 料架的RFID信息
                paramMap.Add("rfidLoc", rfidLoc.ToString());     // rfidLoc=料架的架位信息 
                paramMap.Add("cid", cid);     // 料仓cid,流水线可传入空
                string server = GetAddr(Addr_afterPutCut, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                if (barcode != "")
                {
                    LogUtil.info(deviceName + "afterPutCut    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");
                }
                else
                {
                    LogUtil.debug(deviceName + "afterPutCut    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");
                }
                //>   返回: 
                //>>` {"code": 0, "msg":"ok", "data":{"cutPackageTask":"0","urgentPackageTask":"20","cutTask":"21","urgentTask":"22"}} `
                //>>
                //>> - code: 0为正常,其他为异常, 
                //>> - msg:消息, 
                //>> - data:为包装料仓的空闲仓位数(key为与客户端一致的料仓标识, value为空闲仓位)
                //>> - cutPackageTask: 表示当前包装仓的分盘任务数
                //>> - urgentPackageTask: 表示当前包装仓的紧急料任务数
                //>> - cutTask: 表示流水线分盘任务数
                //>> - urgentTask: 表示流水线紧急料任务数
                AfterPutData serverResult = JsonHelper.DeserializeJsonToObject<AfterPutData>(resultStr);

                if (serverResult == null)
                {
                    return msg = deviceName + "afterPutCut【 " + barcode + "】【" + rfid + "】【" + rfidLoc + "】没有收到服务器反馈";
                }
                else if (serverResult.code.Equals(0).Equals(false))
                {
                    return msg = deviceName + " afterPutCut【 " + barcode + "】【" + rfid + "】【" + rfidLoc + "】  ：" + serverResult.msg;
                }
                afterData = serverResult.data;
                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }


        //        分盘料/紧急料启动时获取料架的虚拟RFID调用  地址:   /rest/api/qisda/device/findTempRfid
        private static string Addr_findTempRfid = "/rest/api/qisda/device/findTempRfid";
        public static string findTempRfid(string deviceName, string rfid, out string tempRfid)
        {
            tempRfid = "";
            string msg = "";
            if (string.IsNullOrEmpty(serverAddr))
            {
                LogUtil.error(deviceName + "findTempRfid   [" + rfid + "] :未找到服务器地址");
                return msg;
            }
            try
            {
                //            参数:         rfid: RFID
                //           返回:       "code": 0, "msg":"ok", "data":{ "tempRfid":""}
                //                 code: 0为正常,其他为异常,
                //msg: 消息,
                //data:  tempRfid: 表示当前料架(料串)对应的虚拟RFID

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", rfid);      // rfid: RFID

                string server = GetAddr(Addr_findTempRfid, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "findTempRfid    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");

                RfidData data = JsonHelper.DeserializeJsonToObject<RfidData>(resultStr);

                if (data == null)
                {
                    return msg = deviceName + " findTempRfid【 " + rfid + "】 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = deviceName + " findTempRfid【 " + rfid + "】   ：" + data.msg;
                }
                if (data.data != null && data.data.ContainsKey("tempRfid"))
                {
                    tempRfid = data.data["tempRfid"];
                }
                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }


        //        取消任务地址:   /cancelPutInTask      //参数: barcode
        private static string Addr_cancelPutInTask = "/rest/api/qisda/device/cancelPutInTask";
        public static string cancelPutInTask(string deviceName, string barcode,bool disablePos)
        {
            string msg = "";
            try
            {
                if (string.IsNullOrEmpty(serverAddr))
                {
                    LogUtil.error(deviceName + "cancelPutInTask   [" + barcode + "] :未找到服务器地址");
                    return msg;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("barcode", barcode);
                paramMap.Add("disablePos", disablePos.ToString());

                string server = GetAddr(Addr_cancelPutInTask, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "cancelPutInTask    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");

                CancelData data = JsonHelper.DeserializeJsonToObject<CancelData>(resultStr);

                if (data == null)
                {
                    return msg = deviceName + " cancelPutInTask【  " + barcode + "," + disablePos + "】 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = deviceName + " cancelPutInTask【  " + barcode + "," + disablePos + "】   ：" + data.msg;
                }

                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }

        private static string Addr_clearOutTask = "/rest/api/qisda/device/clearOutTask";
        public static string clearOutTask(string deviceName, string barcode)
        {
            string msg = "";
            try
            {
                if (string.IsNullOrEmpty(serverAddr))
                {
                    LogUtil.error(deviceName + "clearOutTask   [" + barcode + "] :未找到服务器地址");
                    return msg;
                }

                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("barcode", barcode);

                string server = GetAddr(Addr_clearOutTask, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.info(deviceName + "clearOutTask    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");

                CancelData data = JsonHelper.DeserializeJsonToObject<CancelData>(resultStr);

                if (data == null)
                {
                    return msg = deviceName + " cancelPutInTask【  " + barcode + "】 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = deviceName + " cancelPutInTask【  " + barcode + "】   ：" + data.msg;
                }

                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return msg;
        }
        public static GetPosResult GetPosId(string deviceName, List<string> codeList, int height, int width, string rfid, int feedEquipId)
        {
            GetPosResult result = new GetPosResult();          
            try
            {
                string codeStr = "";
                List<string> list = new List<string>();
                foreach (string str in codeList)
                {
                    if (list.Contains(str.Trim()) || String.IsNullOrEmpty(str.Trim()))
                    {
                        continue;
                    }
                    list.Add(str.Trim());
                    string code = "=" + width + "x" + height + "=" + str.Trim();
                    codeStr = codeStr + code + spiltStr;
                }
                codeStr = CodeManager.ReplaceCode(codeStr);

                //判断是否不连接服务器
                if (string.IsNullOrEmpty(serverAddr))
                {
                    LogUtil.error (deviceName + "GetPosId[" + codeStr + "][" + height + "][" + width + "]：未找到服务器地址 ");
                    result.Msg = "未找到服务器地址";
                    result.Param = new InOutParam(0, codeStr, "", height, width, true);
                    return result;
                }

                //http://localhost/myproject/service/store/emptyPosForPutin
                // 参数：cids: 多个 cid
                //code: 条码内容
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("cids", LineServer.GetAllCID(feedEquipId));
                paramMap.Add("code", codeStr);
                paramMap.Add("entrance", deviceName);
                paramMap.Add(ParamDefine.rfid, rfid);

                string server = GetAddr(Addr_PosForPutin, paramMap);
                DateTime startTime = DateTime.Now;
                LogUtil.info(deviceName + "【" + rfid + "】【 " + codeStr + "】 ，获取入库库位：");

                string resultStr = HttpHelper.Post(server, "", Encoding.UTF8, 10000, out result.IsTimeOut);

                LogUtil.info(deviceName + "CodeReceived " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
                if (result.IsTimeOut)
                {
                    return result;
                }
                //{"result":"0","msg":"","pos":"11#AC1_18_4_28","barcode":"R506072019102200414","cid":"line-ac-11"}
                ForPutinData serverResult = JsonHelper.DeserializeJsonToObject<ForPutinData>(resultStr);

                if (serverResult == null)
                {
                    result.Msg = deviceName + "  【" + codeStr + "】结果：没有收到服务器反馈，调用 cancelPutInTask ";
                    cancelPutInTask(deviceName, codeStr,false );
                    result.Param = new InOutParam(0, codeStr, "", height, width, true);
                    result.Param.rfid = rfid;
                    result.Param.IsNG = true;
                    result.Param.NgMsg = "没有收到服务器反馈";
                    return result;
                }
                else if ((!string.IsNullOrEmpty(serverResult.msg)) && serverResult.result.Equals(98))
                {
                    result.Result = serverResult.result;
                    result.Msg = "";
                    bool cutReel = serverResult.cutReel.ToLower().Equals("true");
                    bool urgentReel = serverResult.urgentReel.ToLower().Equals("true");
                    bool smallReel = serverResult.smallReel.ToLower().Equals("true");
                    int rfidloc = FormUtil.GetIntValue(serverResult.rfidLoc);
                    int pH = FormUtil.GetIntValue(serverResult.plateH);
                    int pW = FormUtil.GetIntValue(serverResult.plateW);
                    result.Param = new InOutParam(0, serverResult.barcode, serverResult.posId, pH, pW, false, urgentReel, cutReel, smallReel, serverResult.rfid, rfidloc);

                    LogUtil.info(deviceName + "收到出库命令： " + result.Param.ToStr() + "  ");
                    return result;
                }
                else if ((!string.IsNullOrEmpty(serverResult.msg)) || serverResult.result.Equals(0).Equals(false))
                {
                    result.Result = serverResult.result;
                    //result.Msg = deviceName + "  【" + codeStr + "】结果：" + serverResult.msg;
                    result.Msg =   serverResult.msg;
                    result.Param = new InOutParam(0, codeStr, "", height, width, true);
                    result.Param.rfid = rfid;
                    result.Param.IsNG = true;
                    result.Param.NgMsg = "" + serverResult.msg;
                    return result;
                }
                result.Result = serverResult.result;
                if (!serverResult.pos.Equals(""))
                {
                    // 仓位命名: 4D01020304
                    //第1和第2位表示楼层(4D)
                    //第3和第4位表示料仓(01) 01 - 18为流水线料仓, 19 - 24为包装料仓
                    //第5和第6位表示列(02)
                    //第7和第8位表示行(03)
                    //第9和第10位表示隔板位置(04)
                    //例如: 4D12010124 表示4楼12号料仓第1列第1行架子上的第24个隔板位置
                    //4D19050208 表示4楼19号料仓(包装料仓)第5列第2行架子上的第8个隔板位置
                    string posId = serverResult.pos;

                    //根据库位号查找移栽
                    //  判断PosID是否已经在入库或者在排队列表中，如果已经存在，加入列表失败     
                    result.Param = new InOutParam(0, serverResult.barcode, posId, height, width);
                    result.Param.rfid = rfid;
                    int storeId = result.Param.GetStoreId();
                    if (LineManager.Line.MoveEquipMap.ContainsKey(storeId))
                    {
                        MoveEquip moveEquip = LineManager.Line.MoveEquipMap[storeId];
                        if (LineManager.Line.IsReviceInPosId(moveEquip, posId))
                        {
                            result.Param.IsNG = true;
                            result.Param.NgMsg = "入库库位重复";
                            result.Msg = deviceName + ("收到服务器入库命令  " + "入库库位重复： " + result.Param.ToStr() + " ，入库失败！");
                            return result;
                        }
                        LogUtil.info(deviceName + "收到入库命令： " + result.Param.ToStr() + "  ");
                    }
                    else
                    {
                        result.Param.IsNG = true;
                        result.Param.NgMsg = "未找到料仓[" + storeId + "]";
                        result.Msg = deviceName + ("收到服务器入库命令  " + "未找到料仓[" + storeId + "]： " + result.Param.ToStr() + " ，入库失败！");
                        return result;
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " ", ex);
            }
            return result;
        }
        public static void SendPosToStoreCheck(string deviceName, InOutParam param)
        {
            if (param == null || param.IsNG)
            {
                return;
            }
            int storeId = param.GetStoreId();
            MoveEquip moveEquip = LineManager.Line.MoveEquipMap[storeId];
            if (LineServer.BoxCanInStore(moveEquip.DeviceID))
            {
                LineServer.CheckInStorePos(storeId, param);
            }
            else
            {
                //等待3秒后重发验证
                Task.Factory.StartNew(delegate
                {
                    LogUtil.error(deviceName + "[" + moveEquip.Name + " ]入库命令： " + param.ToStr() + " 给料仓发送验证失败，等待3秒后重发 ");
                    Thread.Sleep(3000);
                    LineServer.CheckInStorePos(storeId, param);
                });
            }
            lock (moveEquip.waitInListLock)
            {
                //如果当前正在出入库中，需要记录下来，等待空闲时执行
                LogUtil.info(deviceName + "[" + moveEquip.Name + " ]入库命令： " + param.ToStr() + "加入等待列表中！");
                moveEquip.waitInStoreList.Add(param);
            }
        }

        //14.异常看板

        //   > 地址: 
        //>>/ rest / api / qisda / device / updateDeviceAlarmMsg


        //    >
        //    > 参数:
        //>> deviceAlarmList : 异常列表Json字符串  `[{"name":"移栽5", "msgKey":"line.move5.timeOut", "msgValue":"运动超时"},{"name":"移栽4", "msgKey":"line.move4.timeOut", "msgValue":"误差过大"}]`
        //>>>name :  异常位置名称
        //>>>msgKey :  异常信息唯一标识
        //>>>msgValue :  异常信息
        //>
        //>   返回: 
        //>>` {"code":0,"msg":"ok","data":""}`
        //>>
        //>> - code: 0为正常,其他为异常, 
        //          >> - msg:消息, 
        //          >> - data:
        private static string Addr_updateDeviceAlarmMsg = "/rest/api/qisda/device/updateDeviceAlarmMsg";
        public static string updateDeviceAlarmMsg(List<AlarmMsg> msgList)
        {
            string msg = "";
            try
            {
                if (string.IsNullOrEmpty(serverAddr))
                { 
                    return msg;
                }
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                string msgListStr = JsonHelper.SerializeObject(msgList);
                paramMap.Add("deviceAlarmList", msgListStr);
                string server = GetAddr(Addr_updateDeviceAlarmMsg, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "",5000);
                LogUtil.debug("updateDeviceAlarmMsg    " + FormUtil.GetSpanStr(DateTime.Now - startTime) + "  【" + server + "】【" + resultStr + "】");

                RfidData data = JsonHelper.DeserializeJsonToObject<RfidData>(resultStr);

                if (data == null)
                {
                    return msg = " updateDeviceAlarmMsg 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = " updateDeviceAlarmMsg   【" + server + "】【" + resultStr + "】" + data.msg;
                }
                return "";
            }
            catch (Exception ex)
            {
                LogUtil.error("  updateDeviceAlarmMsg Error:  " + ex.ToString());
            }
            return msg;
        }
        //        流水线料盘移动到皮带线时进行判断: 地址：  /rest/api/qisda/device/canReelToBelt 参数:barcode: 料盘条码
        private static string Addr_canReelToBelt = "/rest/api/qisda/device/canReelToBelt";
        public static bool canReelToBelt(string deviceName, string barcode,bool defaultPut=true)
        {
            //            返回:   //            { "code":0,"msg":"ok","data":true}
            //            code: 0为正常,其他为异常,(未传参数, 未找到有效条码, 多个有效条码)
            //            msg:消息,
            //data: true 可以放上皮带线 false 继续留在环形线。默认直接放到皮带线

            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("barcode", barcode);

                string server = GetAddr(Addr_canReelToBelt, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.debug($"{deviceName }canReelToBelt   {FormUtil.GetSpanStr(DateTime.Now - startTime) }  【{ server }】【{resultStr }】");
                //{ "code":0,"msg":"ok","data":true}
                ReturnData data = JsonHelper.DeserializeJsonToObject<ReturnData>(resultStr);

                if (data != null)
                {
                    bool result = Convert.ToBoolean(data.data);
                    if (data.code.Equals(0))
                    {
                        return result;
                    }
                    else if (!data.code.Equals(0))
                    {
                        LogUtil.error($"{deviceName }canReelToBelt【 { barcode   }】 返回错误 ：{ data.msg}={data.msg}");
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return defaultPut;
        }

        public static bool IgnoreServerStop = false;
        private static string Addr_stopRun = "/rest/api/qisda/device/stopRun";
        /// <summary>
        /// 流水线停止运行
        /// </summary>
        /// <param name="deviceName"></param>
        /// <returns>true：停止运行</returns>
        public static bool stopRun(string deviceName)
        {
            if (IgnoreServerStop) return false;
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                //paramMap.Add("barcode", barcode);

                string server = GetAddr(Addr_stopRun, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.debug($"{deviceName}stopRun   {FormUtil.GetSpanStr(DateTime.Now - startTime)}  【{server}】【{resultStr}】");

                ReturnData2 data = JsonHelper.DeserializeJsonToObject<ReturnData2>(resultStr);

                if (data != null)
                {
                    bool result = data.data.stopOut;
                    if (data.code.Equals(0))
                    {
                        return result && data.data.unfinishedTask < 1;
                    }
                    else if (!data.code.Equals(0))
                    {
                        LogUtil.error($"{deviceName} stopRun 返回错误 ：{data.msg}={data.msg}");
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return false;
        }
        private static string Addr_putInEnable = "/rest/api/qisda/device/putInEnable";
        /// <summary>
        /// 流水线抓取料盘前获取是否可以继续抓取料盘
        /// </summary>
        /// <param name="deviceName"></param>
        /// <returns></returns>
        public static bool putInEnable(string deviceName)
        {
            if (IgnoreServerStop) return true;
            //            返回:   //            { "code":0,"msg":"ok","data":{"putInEnable":true}}
            //            code: 0为正常,其他为异常
            //            msg:消息,
            //putInEnable: false 时不允许抓取下一盘，true时允许抓取

            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                //paramMap.Add("barcode", barcode);

                string server = GetAddr(Addr_putInEnable, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                LogUtil.debug($"{deviceName}putInEnable   {FormUtil.GetSpanStr(DateTime.Now - startTime)}  【{server}】【{resultStr}】");

                ReturnData1 data = JsonHelper.DeserializeJsonToObject<ReturnData1>(resultStr);

                if (data != null)
                {
                    bool result = data.data.putInEnable;
                    if (data.code.Equals(0))
                    {
                        return result;
                    }
                    else if (!data.code.Equals(0))
                    {
                        LogUtil.error($"{deviceName} putInEnable 返回错误 ：{data.msg}={data.msg}");
                    }
                }
            }
            catch (Exception ex)
            {
                LogUtil.error(deviceName + " " + ex.ToString());
            }
            return false;
        }
         

        ///rest/api/qisda/device/updateTray?trayId=xxx
        private static string Addr_updateTray = "/rest/api/qisda/device/updateTray";
        public static void updateTray(int trayNum)
        {
            if (trayNum <= 0)
            {
                return;
            }
            Task.Factory.StartNew(delegate
            {
                try
                {

                    //code= 0 表示正常,其他为异常
                    Dictionary<string, string> paramMap = new Dictionary<string, string>();
                    paramMap.Add("trayId", "E" + trayNum);//  

                    string server = GetAddr(Addr_updateTray, paramMap);
                    DateTime startTime = DateTime.Now;
                    string resultStr = HttpHelper.Get(server);

                    LogUtil.debug("updateTray  [" + trayNum + "] " + FormUtil.GetSpanStr(DateTime.Now - startTime) + " 【" + server + "】【" + resultStr + "】");
                }
                catch (Exception ex)
                {
                    LogUtil.error("updateTray  [" + trayNum + "]  出错", ex);
                }
            });
        }

    }
    public class ReturnData
    {
        // { "code":0,"msg":"ok","data":true}
        public int code { get; set; }

        public string msg { get; set; }

        public object data { get; set; }
    }
    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 GetPosResult
    {
        public string Msg = "";
        /// <summary>
        /// 0=成功，98=此盘为出库盘。99:暂时不能入库，需要重新获取库位。100：服务器需要更新，需要重新获取库位
        /// </summary>
        public int Result = 0;
        /// <summary>
        /// 获取超时，需要重新获取库位
        /// </summary>
        public bool IsTimeOut = false;
        public InOutParam Param = null;
    }
    public class RfidData
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public Dictionary<string, string> data { get; set; }
    }
    public class CancelData
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public object data { get; set; }
    }
    public class LocStatus
    {
        /// <summary>
        /// 料盘位置：移栽 = MOVING
        /// </summary>
        public static string MOVING = "MOVING";
        /// <summary>
        /// 料盘位置：流水线 = INLINE
        /// </summary>
        public static string INLINE = "INLINE";
        /// <summary>
        /// 料盘位置：皮带线 = INBELT
        /// </summary>
        public static string INBELT = "INBELT";
    }
    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 AfterPutData
    {
        //>>` {"code": 0, "msg":"ok", "data":{"cutPackageTask":"0","urgentPackageTask":"20","cutTask":"21","urgentTask":"22"}} `
        //>>
        //>> - code: 0为正常,其他为异常, 
        //>> - msg:消息, 
        //>> - data:为包装料仓的空闲仓位数(key为与客户端一致的料仓标识, value为空闲仓位)
        //>> - cutPackageTask: 表示当前包装仓的分盘任务数
        //>> - urgentPackageTask: 表示当前包装仓的紧急料任务数
        //>> - cutTask: 表示流水线分盘任务数
        //>> - urgentTask: 表示流水线紧急料任务数
        public int code { get; set; }

        public string msg { get; set; }

        public TaskData data { get; set; }
    }
    public class TaskData
    {
        /// <summary>
        /// urgentPackageTask: 表示当前包装仓的紧急料任务数
        /// </summary>
        public int urgentPackageTask { get; set; }
        /// <summary>
        /// cutPackageTask: 表示当前包装仓的分盘任务数
        /// </summary>
        public int cutPackageTask { get; set; }
        /// <summary>
        /// cutTask: 表示流水线分盘任务数
        /// </summary>
        public int cutTask { get; set; }
        /// <summary>
        /// urgentTask: 表示流水线紧急料任务数
        /// </summary>
        public int urgentTask { get; set; }

        public string ToStr()
        {
            return "[分盘料=" + cutTask + "][紧急料=" + urgentTask+"]";
        }

    }
    public class ReturnData2
    {
        // { "code":0,"msg":"ok","data":true}
        public int code { get; set; }

        public string msg { get; set; }

        public StopRun data { get; set; }
    }
    public class StopRun
    {
        public int unfinishedTask { get; set; }
        public bool stopOut { get; set; }
    }
    public class ReturnData1
    {
        // { "code":0,"msg":"ok","data":true}
        public int code { get; set; }

        public string msg { get; set; }

        public PutInEnable data { get; set; }
    }
    public class PutInEnable
    {
        public bool putInEnable { get; set; }
    }
}