using HH.WCS.Hexafluo;
using HH.WCS.Hexafluo.util;
using HH.WCS.Hexafluo.wms;
using HH.WCS.SJML.Bll;
using HH.WCS.SJML.Comm;
using HH.WCS.SJML.Dto;
using HH.WCS.ZCQTJ.Entitys;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;

namespace HH.WCS.SJML.dispatch
{
    public class WcsTask
    {
        private static readonly HttpHelper apiHelper = new HttpHelper();
        private static readonly string baseUrl = Settings.WcsHelperList;

        /// <summary>
        /// 任务下达
        /// </summary>
        /// <param name="mst"></param>
        /// <returns></returns>
        public OperateResult WcsTaskEntity(WMSTask mst, CntrItemRel Item = null)
        {
            string Type = "";
            string TrayType = "";
            string Traycode = mst.S_CNTRS;
            string isFull = "";
            if (mst.S_TYPE == "入库")
            {
                Type = "1";

            }
            else if (mst.S_TYPE == "出库")
            {
                Type = "2";
            }
            else if (mst.S_TYPE == "移库")
            {
                Type = "3";
            }
            if (string.IsNullOrEmpty(Item?.S_ITEM_CODE))
            {
                isFull = "0";
            }
            else
            {
                isFull = "1";
            }
            if (mst.S_CNTRS.Contains("KJZ"))
            {
                TrayType = "KJZ";
                isFull = "2";
            }


            // return OperateResult.Succeed();
            var interact = new
            {
                requestPk = mst.S_TASK_NO,//任务号
                contNo = Traycode,//托盘号
                contType = TrayType,//托盘类型
                trkType = Type,//任务类型
                trkPrty = mst.N_PRIORITY,//任务优先级
                frmPos = mst.S_START_LOC,//起始位置
                toPos = mst.S_END_LOC,//目的地
                isFull = isFull,//空托 满托  空架子
                groupNo = Item?.S_ITEM_NAME,//搬送组号
                clientCode = "WMS",//操作人
                operationTime = DateTime.Now.ToString()//操作时间
            };
            LogHelper.Info("立库", "给立库下达任务 参数为:" + JsonConvert.SerializeObject(interact));
            LogHelper.Info("立库", " 给立库下达任务 地址为:" + baseUrl + "/wcs-admin/api/receive");
            //return OperateResult.Succeed();
            var result = apiHelper.Post(baseUrl + "/wcs-admin/api/receive", JsonConvert.SerializeObject(interact));
            LogHelper.Info("立库", "给立库下达任务 立库返回参数为:" + result);
            if (string.IsNullOrEmpty(result))
            {
                throw new Exception("未得到任何来自于立库的反馈信息");
            }
            var data = JsonConvert.DeserializeObject<WcsReturnEntity>(result);

            if (data.code == "0")
            {
                return OperateResult.Succeed();
            }
            else
            {
                LogHelper.Info("立库", "立库返回:" + JsonConvert.SerializeObject(data));
                if (data.msg != null && data.msg.Contains("已存在执行托盘"))
                {
                    return OperateResult.Succeed();
                }
                return OperateResult.Error(data.msg);
            }
        }
        private static object locko = new object();
        /// <summary>
        /// 安全请求
        /// </summary>
        /// <param name="mst"></param>
        /// <returns></returns>
        public OperateResult WcsCallback(WMSTask mst, int state, string forkliftNo = "")
        {
            //查询表数据是否发送过该信号
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            var tac = newDb.Queryable<TN_NdcSignEntitys>().Where(a => a.TaskNo == mst.S_TASK_NO && a.Sign == state).ToList();
            if (tac.Count() > 0)
            {
                LogHelper.Info("立库", "查询到安全请求信号记录表已经存在数据,此次信号不下达给立库");
                return OperateResult.Succeed();
            }
            string Type = "";
            string bit = "";
            var Meshod = "";
            if (mst.S_TYPE == "入库")
            {
                if (!string.IsNullOrEmpty(mst.mark))
                {
                    Type = "1";
                    bit = mst.S_END_LOC;
                    if (state == 1101)
                    {
                        Meshod = "AgvRequest";
                        bit = mst.S_START_LOC;
                    }
                    else if (state == 7)
                    {
                        Type = "3";
                        Meshod = "AgvRequestCancel";
                        bit = mst.S_END_LOC;
                    }
                    else if (state == 8)
                    {
                        Type = "3";
                        Meshod = "AgvRequestCancel";
                        bit = mst.S_Jb_Bit;
                    }
                    else if (state == 1102)
                    {
                        Meshod = "Complete";
                        bit = mst.S_START_LOC;
                    }
                    else
                    {
                        Meshod = "Complete";
                    }
                }
                else
                {
                    Type = "2";
                    bit = mst.S_END_LOC;
                    if (state == 1103)
                    {
                        Meshod = "AgvRequest";
                    }
                    else if (state == 7)
                    {
                        Type = "3";
                        Meshod = "AgvRequestCancel";
                        bit = mst.S_END_LOC;
                    }
                    else
                    {
                        Meshod = "Complete";
                    }
                }
            }
            else if (mst.S_TYPE == "出库")
            {
                Type = "1";
                bit = mst.S_START_LOC;
                if (state == 1101)
                {
                    Meshod = "AgvRequest";
                }
                else if (state == 7)
                {
                    Meshod = "AgvRequestCancel";
                }
                else
                {
                    Meshod = "Complete";
                }
            }
            else
            {
                return OperateResult.Error("除了出入库 其余不需要安全请求");
            }
            // return OperateResult.Succeed();
            var interact = new
            {
                requestPk = mst.S_TASK_NO,//任务号
                trkType = Type,//任务类型
                method = Meshod,//API名称
                stnNo = bit,//目的地站台号
                carNo = forkliftNo,// 车号
                clientCode = "",//操作人
                operationTime = DateTime.Now.ToString()//操作时间
            };

            //return OperateResult.Succeed();
            try
            {
                LogHelper.Info("立库", "给立库下达安全请求 参数为:" + JsonConvert.SerializeObject(interact));
                LogHelper.Info("立库", "给立库下达安全请求 地址为:" + baseUrl + "/wcs-admin/api/agvCallback");
                lock (locko)
                {
                    var result = apiHelper.Post(baseUrl + "/wcs-admin/api/agvCallback", JsonConvert.SerializeObject(interact));
                    LogHelper.Info("立库", "给立库下达安全请求 立库返回参数为:" + result);
                    if ((state == 1102 || state == 1104) && string.IsNullOrEmpty(result))
                    {
                        try
                        {
                            TN_AsyncEntitys As = new TN_AsyncEntitys();
                            As.JsonValue = JsonConvert.SerializeObject(interact);
                            As.S_IsCall = "Y";
                            As.S_PortID = "1";
                            As.S_Note = "返回参数为空";
                            newDb.BeginTran();
                            var B = newDb.Insertable(As).ExecuteCommand();
                            if (B == 0)
                            {
                                newDb.RollbackTran();
                            }
                            newDb.CommitTran();
                            LogHelper.Info("立库", $"添加异步接口缓存影响行数:{B}");
                        }
                        catch (Exception ex)
                        {
                            LogHelper.Info("立库", $"异步接口缓存报错:{ex.Message}");
                            newDb.RollbackTran();
                        }
                    }
                    if (string.IsNullOrEmpty(result))
                    {
                        return OperateResult.Error("立库未返回参数");
                    }
                    var data = JsonConvert.DeserializeObject<WcsReturnEntity>(result);

                    if (data.code == "0")
                    {
                        //通知立库成功后忘表中插入数据
                        TN_NdcSignEntitys Sign = new TN_NdcSignEntitys();
                        Sign.TaskNo = mst.S_TASK_NO;
                        Sign.Sign = state;
                        newDb.BeginTran();
                        var B = newDb.Insertable(Sign).ExecuteCommand();
                        if (B == 0)
                        {
                            newDb.RollbackTran();
                        }
                        newDb.CommitTran();
                        LogHelper.Info("立库", "NDC--是否成功信号记录表:" + JsonConvert.SerializeObject(Sign));
                        return OperateResult.Succeed();
                    }
                    else
                    {
                        LogHelper.Info("立库", "立库返回" + JsonConvert.SerializeObject(data));
                        return OperateResult.Error(data.msg);
                    }
                }
            }
            catch (Exception ex)
            {
                if ((state == 1102 || state == 1104))
                {

                }
                LogHelper.Info("立库", "安全请求 调立库接口异常 " + JsonConvert.SerializeObject(ex.Message));
                return OperateResult.Error("调接口异常");
            }

        }



        public WcsReturnEntityTwo WcsPositionAvailable(string S_TASK_NO, List<string> SoList)
        {
            //查询表数据是否发送过该信号
            WcsReturnEntityTwo entityTwo = new WcsReturnEntityTwo();
            entityTwo.code = "1";
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            var interact = new
            {
                requestPk = S_TASK_NO,//任务号
                stnNo = SoList,//接驳位
                operationTime = DateTime.Now.ToString()//操作时间
            };

            //return OperateResult.Succeed();
            try
            {
                LogHelper.Info("立库", "查询立库接驳位(集合)接口 参数为:" + JsonConvert.SerializeObject(interact));
                LogHelper.Info("立库", "查询立库接驳位(集合)接口 地址为:" + baseUrl + "/wcs-admin/api/positionAvailable");
                lock (locko)
                {
                    var result = apiHelper.Post(baseUrl + "/wcs-admin/api/positionAvailable", JsonConvert.SerializeObject(interact));
                    LogHelper.Info("立库", "查询立库接驳位(集合) 立库返回参数为:" + result);
                    if (string.IsNullOrEmpty(result))
                    {
                        return entityTwo;
                    }
                    var data = JsonConvert.DeserializeObject<WcsReturnEntityTwo>(result);
                    return data;
                }
            }
            catch (Exception ex)
            {
                entityTwo.msg = ex.Message;
                return entityTwo;
            }

        }


        public WcsReturnEntityTwo WcsPositionAvailableCk(string S_TASK_NO)
        {
            //查询表数据是否发送过该信号
            WcsReturnEntityTwo entityTwo = new WcsReturnEntityTwo();
            entityTwo.code = "1";
            var chi = new SqlHelper<object>().GetInstance();
            var newDb = chi.CopyNew();
            var interact = new
            {
                requestPk = S_TASK_NO,//任务号
                stnNo = new List<string>() { "TMCKJBW-01", "TMCKJBW-02", "TMCKJBW-03", "TMCKJBW-04", "TMCKJBW-05", "TMCKJBW-06", "TMCKHCW-01", "TMCKHCW-02" },//接驳位
                operationTime = DateTime.Now.ToString()//操作时间
            };

            //return OperateResult.Succeed();
            try
            {
                LogHelper.Info("立库", "查询立库接驳位(集合)接口 参数为:" + JsonConvert.SerializeObject(interact));
                LogHelper.Info("立库", "查询立库接驳位(集合)接口 地址为:" + baseUrl + "/wcs-admin/api/positionAvailable");
                lock (locko)
                {
                    var result = apiHelper.Post(baseUrl + "/wcs-admin/api/positionAvailable", JsonConvert.SerializeObject(interact));
                    LogHelper.Info("立库", "查询立库接驳位(集合) 立库返回参数为:" + result);
                    if (string.IsNullOrEmpty(result))
                    {
                        return entityTwo;
                    }
                    var data = JsonConvert.DeserializeObject<WcsReturnEntityTwo>(result);
                    return data;
                }
            }
            catch (Exception ex)
            {
                entityTwo.msg = ex.Message;
                return entityTwo;
            }

        }

        public WcsReturnEntityWtp WcsgetContNo(WMSTask task)
        {
            WcsReturnEntityWtp returnEntity = new WcsReturnEntityWtp();
            returnEntity.code = "1";
            try
            {
                var interact = new
                {
                    requestPk = task.S_TASK_NO,
                    stnNo = task.S_END_LOC,
                    reqTime = DateTime.Now.ToString()
                };
                LogHelper.Info("立库", "获取托盘码 参数为:" + JsonConvert.SerializeObject(interact));
                LogHelper.Info("立库", "获取托盘码 地址为:" + baseUrl + "/wcs-admin/api/getContNo");
                var result = apiHelper.Post(baseUrl + "/wcs-admin/api/getContNo", JsonConvert.SerializeObject(interact));
                LogHelper.Info("立库", "获取托盘码 立库返回参数为:" + result);
                if (string.IsNullOrEmpty(result))
                {
                    throw new Exception("未得到任何来自于立库的反馈信息");
                }
                var data = JsonConvert.DeserializeObject<WcsReturnEntityWtp>(result);

                if (data.code == "0")
                {
                    return data;
                }
                else
                {
                    LogHelper.Info("立库", "立库返回:" + JsonConvert.SerializeObject(data));
                    return data;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Info("立库", " 获取托盘码 报错:" + JsonConvert.SerializeObject(ex));
                return returnEntity;
            }
        }


        /// <summary>
        /// WCS设备信息查询
        /// </summary>
        /// <returns></returns>
        public List<WcsCarryMsg> WcsdataBoard()
        {
            List<WcsCarryMsg> WcsCarry = new List<WcsCarryMsg>();
            try
            {
                var interact = new
                {
                    requestPk = BLLCreator.Create<IdWorker>().nextId("CX"),
                    reqTime = DateTime.Now
                };
                LogHelper.Info("立库", "查询立库设备信息 参数为:" + JsonConvert.SerializeObject(interact));
                var result = apiHelper.Post(baseUrl + "/wcs-admin/api/dataBoard", JsonConvert.SerializeObject(interact));
                LogHelper.Info("立库", "给立库下达安全请求 立库返回参数为:" + result);
                if (string.IsNullOrEmpty(result))
                {
                    return WcsCarry;
                }
                var data = JsonConvert.DeserializeObject<List<WcsCarryMsg>>(result);
                return data;

            }
            catch (Exception ex)
            {
                LogHelper.Info("立库", "查询立库设备信息 报错:" + ex.Message);
                return WcsCarry;
            }
        }
        public OperateResult WcsCallbackAnyc(string JsonValue)
        {
            try
            {

                var result = apiHelper.Post(baseUrl + "/wcs-admin/api/agvCallback", JsonValue);
                LogHelper.Info("立库", "给立库下达安全请求 立库返回参数为:" + result);
                if (string.IsNullOrEmpty(result))
                {
                    return OperateResult.Error("立库未返回参数");
                }
                var data = JsonConvert.DeserializeObject<WcsReturnEntity>(result);

                if (data.code == "0")
                {
                    return OperateResult.Succeed();
                }
                else
                {
                    LogHelper.Info("立库", "立库返回" + JsonConvert.SerializeObject(data));
                    return OperateResult.Error(data.msg);
                }
            }
            catch (Exception ex)
            {

                throw;
            }
        }

        /// <summary>
        /// 取消任务
        /// </summary>
        /// <returns></returns>
        public OperateResult WcsCancellTask(WMSTask mst)
        {
            var interact = new
            {
                requestPk = mst.S_TASK_NO,
                contNo = mst.S_CNTRS,//托盘号
                clientCode = "",
                reqTime = DateTime.Now.ToString()//操作时间
            };
            LogHelper.Info("立库", "给立库下达取消 参数为:" + JsonConvert.SerializeObject(interact));
            LogHelper.Info("立库", "给立库下达取消 地址为:" + baseUrl + "/wcs-admin/api/cancel");
            var result = apiHelper.Post(baseUrl + "/wcs-admin/api/cancel", JsonConvert.SerializeObject(interact));
            LogHelper.Info("立库", "给立库下达取消 立库返回参数为:" + result);
            var data = JsonConvert.DeserializeObject<WcsReturnEntity>(result);
            if (data.code == "0")
            {
                return OperateResult.Succeed();
            }
            else
            {
                LogHelper.Info("立库", "立库返回" + JsonConvert.SerializeObject(data));
                return OperateResult.Error(data.msg);
            }
        }


        /// <summary>
        /// 输送线状态查询
        /// </summary>
        /// <returns></returns>
        public OperateResult WcsCvstate(AloneWcsTaskUnbingEntitys aloneWcsTask)
        {
            var interact = new
            {
                requestPk = aloneWcsTask.S_TASK_NO,//请求编号
                clientCode = "WMS",// 操作人 如WMS/MES等
                stnNo = aloneWcsTask.JbLocation,
                reqTime = DateTime.Now.ToString()//操作时间
            };
            LogHelper.Info("立库", "查询立库接驳位状态 参数为:" + JsonConvert.SerializeObject(interact));
            LogHelper.Info("立库", "查询立库接驳位状态 地址为:" + baseUrl + "/wcs-admin/api/CV-state");
            var result = apiHelper.Post(baseUrl + "/wcs-admin/api/CV-state", JsonConvert.SerializeObject(interact));
            LogHelper.Info("立库", "查询立库接驳位状态 立库返回参数为:" + result);
            var data = JsonConvert.DeserializeObject<WcsReturnEntity>(result);
            if (data.status == "1")
            {
                return OperateResult.Succeed();
            }
            else
            {
                LogHelper.Info("立库", "立库返回" + JsonConvert.SerializeObject(data));
                return OperateResult.Error(data.msg);
            }
        }
    }
    public class WcsReturnEntity
    {
        public string code { get; set; }
        public string msg { get; set; }
        public string requestPk { get; set; }
        public string status { get; set; }

    }
    public class WcsReturnEntityTwo
    {
        public string code { get; set; }
        public string msg { get; set; }
        public string requestPk { get; set; }
        public List<string> available { get; set; }

    }


    public class WcsReturnEntityWtp
    {
        public string code { get; set; }
        public string msg { get; set; }
        public string contNo { get; set; }
        public string contType { get; set; }
        public string requestPk { get; set; }
    }
}