using HH.WCS.JunzhouNongfu.device;
using HH.WCS.Mobox3.YNJT_BZP.api;
using HH.WCS.Mobox3.YNJT_BZP.dispatch;
using HH.WCS.Mobox3.YNJT_BZP.models;
using HH.WCS.Mobox3.YNJT_BZP.process;
using HH.WCS.Mobox3.YNJT_BZP.util;
using HH.WCS.Mobox3.YNJT_BZP.wms;
using Newtonsoft.Json;
using Org.BouncyCastle.Asn1.X509;
using S7.Net;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;
using System.Runtime.Remoting.Metadata.W3cXsd2001;
using System.Threading.Tasks;
using static HH.WCS.Mobox3.YNJT_BZP.api.AgvController;
using static HH.WCS.Mobox3.YNJT_BZP.api.ApiModel;
using static HH.WCS.Mobox3.YNJT_BZP.dispatch.GtDispatch;

namespace HH.WCS.Mobox3.YNJT_BZP.core {
    internal class WCSCore {
        public static void OperateAgvTaskStatus(AgvTaskState model) {
            try
            {
                if (string.IsNullOrEmpty(model.No))
                {
                    LogHelper.Info("任务号为空", "AGV");
                }
                else
                {
                    var TN_Task = WCSHelper.GetTask(model.No);
                    if (TN_Task != null)
                    {
                        bool isExist = WCSHelper.CheckActionRecordExist(TN_Task.S_CODE, model.State);
                        if (!isExist)
                        {
                            WCSHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
                            if (model.State <= 7)
                            {
                                //有任务号请求
                                switch (model.State)
                                {
                                    case 1:
                                        WCSHelper.Begin(TN_Task);
                                        break;
                                    #region MyRegion
                                    case 3:
                                        WCSHelper.UpdateStatus(TN_Task, "开始取货");
                                        break;
                                    case 4:
                                        WCSHelper.UpdateStatus(TN_Task, "取货完成");
                                        TaskProcess.OperateStatus(TN_Task, 4);
                                        break;
                                    case 5:
                                        WCSHelper.UpdateStatus(TN_Task, "开始卸货");
                                        break;
                                    case 6:
                                        TaskProcess.OperateStatus(TN_Task, 6);
                                        WCSHelper.UpdateStatus(TN_Task, "卸货完成");
                                        break;
                                    #endregion
                                    case 2:
                                        WCSHelper.End(TN_Task);

                                        var cntrItemRels = ContainerHelper.GetCntrItemRel(TN_Task.S_CNTR_CODE);
                                        if (cntrItemRels.Count > 0) 
                                        {
                                            string shift = ApiHelper.getShift(DateTime.Now.TimeOfDay);
                                            string ydate_shiftName = "";
                                            if (shift == "III")
                                            {
                                                ydate_shiftName = DateTime.Now.AddDays(-1).ToString("yy/MM/dd") + "-" + shift;
                                            }
                                            else 
                                            {
                                                ydate_shiftName = DateTime.Now.ToString("yy/MM/dd") + "-" + shift;
                                            }
                                            WmsToGtLokasiModel wmsToGtLokasiModel = new WmsToGtLokasiModel()
                                            {
                                                ydate_shiftName = ydate_shiftName,
                                                bc_entried = cntrItemRels[0].S_CG_ID,
                                                loc_from = TN_Task.S_START_LOC,
                                                loc_to = TN_Task.S_END_LOC,
                                                qty = 1,
                                                lot = 1,
                                                scantime = TN_Task.T_CREATE.ToString("yyyy-MM-dd HH:mm:ss"),
                                                pic = model.ForkliftNo
                                            };
                                            GtDispatch.agvTaskFeedback(wmsToGtLokasiModel);
                                        }
                                        break;
                                    case 7:
                                        //判断是否收到过强制取消，有就不做任何处理
                                        if (!WCSHelper.CheckActionRecordExist(TN_Task.S_CODE, 17))
                                        {
                                            TaskProcess.OperateStatus(TN_Task, 7);
                                            WCSHelper.Cancel(TN_Task);
                                        }
                                        break;
                                }
                            }
                            else if (model.State == 2001) 
                            {
                                //申请新终点
                                string endLoc = AGVApplyEndLoc(model.No);
                            }
                            else
                            {
                                //安全请求等
                                TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData);
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Info($"agv回报错误，错误原因：{ex.Message}", "AGV");
            }
        }

        /// <summary>
        /// 创建最后一个任务
        /// </summary>
        /// <param name="startLocCode"></param>
        /// <param name="mst"></param>
        /// <param name="actType">1.入库 2.出库</param>
        /// <returns></returns>
        public static bool createLastTask(string startLocCode , WMSTask mst ,int actType) 
        {
            LogHelper.Info("创建下一段任务", "WMS");
            var startLoc = LocationHelper.GetLoc(startLocCode);
            if (startLoc != null) 
            {
                string cntrCode = "";
                string scheduleType = "";
                if (actType == 1) 
                {
                    var locCntrRels = LocationHelper.GetLocCntr(startLocCode);
                    if (locCntrRels.Count > 0)
                    {
                        foreach (var cntr in locCntrRels)
                        {
                            cntrCode = cntrCode + ","+ cntr.S_CNTR_CODE;
                        }
                        cntrCode = cntrCode.Substring(1, cntrCode.Length-1);
                    }
                    scheduleType = "WCS";
                }

                if (actType == 2)
                {
                    cntrCode = mst.S_CNTR_CODE;
                    scheduleType = "AGV";
                }

                // 创建一段入库任务
                WCSTask wcsTask = new WCSTask()
                {
                    S_OP_NAME = mst.S_OP_DEF_NAME,
                    S_OP_CODE = mst.S_CODE,
                    S_CODE = WCSHelper.GenerateTaskNo(),
                    S_CNTR_CODE = cntrCode,
                    S_TYPE = mst.S_TYPE + "-2",
                    S_START_LOC = startLoc.S_CODE,
                    S_START_AREA = startLoc.S_AREA_CODE,
                    S_END_LOC = mst.S_END_LOC,
                    S_END_AREA = mst.S_END_AREA,
                    S_SCHEDULE_TYPE = scheduleType,
                    N_PRIORITY = mst.N_PRIORITY,
                    T_START_TIME = DateTime.Now,
                };

                if (WCSHelper.CreateTask(wcsTask))
                {
                    // 起点、接驳点、终点加锁
                    LocationHelper.LockLoc(wcsTask.S_START_LOC, 2);
                    LocationHelper.LockLoc(wcsTask.S_END_LOC, 1);

                    WMSHelper.UpdateTaskEnd(mst);
                    return true;
                }
            }
            return false;
        }

        /// <summary>
        /// 任务分发，根据调度类型发给不同的调度系统
        /// </summary>
        internal static void Dispatch() {
            var db = new SqlHelper<object>().GetInstance();
            //查询任务
            //获取所有等待的任务
            var list = WCSHelper.GetWaitingTaskList();
            if (list.Count > 0) {
                foreach (var task in list)
                {
                    if (!TaskProcess.Intercept(task))
                    {
                        //使用自定义任务推送
                        TaskProcess.SendTask(task);
                    }
                }
            }
        }



        /// <summary>
        /// agv申请终点
        /// </summary>
        /// <param name="taskNo"></param>
        public static string AGVApplyEndLoc(string taskNo) 
        {
            LogHelper.Info("【agv申请终点】", "AGV");
            string endLocCode = null;
            var cst = WCSHelper.GetTask(taskNo);
            if (cst != null && cst.N_B_STATE < 3) 
            {
                var mst = WMSHelper.GetWmsTask(cst.S_OP_CODE);
                if (mst != null && mst.N_B_STATE < 2 && mst.S_END_LOC == "虚拟货位") 
                {
                    var container = ContainerHelper.GetCntr(cst.S_CNTR_CODE);
                    if (container != null) 
                    {
                        var endLoc = WMSHelper.GetInstockEndLoc(container.N_TYPE);
                        if (endLoc != null)
                        {
                            Location agvLoc = null;
                            var locCodes = Settings.getAgvJBLocList(1, endLoc.N_ROADWAY, 1);
                            if (locCodes.Count > 0) 
                            {
                                agvLoc = LocationHelper.GetLoc(locCodes[0]);
                            }

                            if (agvLoc != null && agvLoc.C_ENABLE == "Y") 
                            {
                                var wcsTask = WCSHelper.GetTaskByStartAndEnd(agvLoc.S_CODE);
                                if (wcsTask == null && agvLoc.N_LOCK_STATE == 0)
                                {
                                    // 胎圈入库，下发母拖出库任务 \ 帘布、内衬入库，下发托盘回库任务
                                    if (mst.S_TYPE.Contains("入库"))
                                    {
                                        if (agvLoc.N_CURRENT_NUM == 1)
                                        {
                                            var locCntrRels = LocationHelper.GetLocCntr(agvLoc.S_CODE);
                                            if (locCntrRels.Count > 0)
                                            {
                                                var container1 = ContainerHelper.GetCntr(locCntrRels[0].S_CNTR_CODE);
                                                if (container1.N_TYPE == 0)
                                                {
                                                    if (container.N_TYPE == 4 || container.N_TYPE == 5)
                                                    {
                                                        ApiHelper.baseTrayInStockAgv(agvLoc.S_CODE, mst.S_CODE);
                                                    }
                                                }
                                                else 
                                                {
                                                    LogHelper.Info($"接驳位:{agvLoc.S_CODE},存在非母拖容器", "AGV");
                                                }
                                            }
                                            else 
                                            {
                                                LogHelper.Info($"接驳位:{agvLoc.S_CODE}的当前数量与容器数量不匹配", "AGV");
                                            }
                                        }
                                        else if (agvLoc.N_CURRENT_NUM == 0)
                                        {
                                            if (container.N_TYPE == 6)
                                            {
                                                ApiHelper.baseTrayOutStockAgv(agvLoc.S_CODE, mst.S_CODE);
                                            }
                                        }
                                        else 
                                        {
                                            return endLocCode;
                                        }
                                    }
                                    cst.S_END_LOC = agvLoc.S_CODE;
                                    cst.S_END_AREA = agvLoc.S_AREA_CODE;
                                    WCSHelper.UpdateTaskEnd(cst);

                                    mst.S_END_LOC = endLoc.S_CODE;
                                    mst.S_END_AREA = endLoc.S_AREA_CODE;
                                    WMSHelper.UpdateTaskEnd(mst);

                                    LocationHelper.LockLoc(agvLoc.S_CODE, 1);
                                    LocationHelper.LockLoc(endLoc.S_CODE, 1);
                                    endLocCode = agvLoc.S_CODE;
                                }
                                else 
                                {
                                    LogHelper.Info("接驳位当前有任务未完成，请稍等", "AGV");
                                }
                            }
                            else
                            {
                                LogHelper.Info("没有可用的入库接驳位", "AGV");
                            }
                        }
                        else 
                        {
                            LogHelper.Info("没有空余的货位", "AGV");
                        }
                    }
                }
            }
            return endLocCode;
        }

    }
}