using HH.WCS.HangYang.dispatch;
using HH.WCS.HangYang.process;
using HH.WCS.HangYang.util;
using HH.WCS.HangYang.wms;
using System;
using System.Collections.Generic;
using System.Linq;
using static HH.WCS.HangYang.api.ApiModel;

namespace HH.WCS.HangYang.core
{
    internal class WCSCore
    {
        public static void OperateAgvTaskStatus(AgvTaskState model)
        {
            var TN_Task = WCSHelper.GetTask(model.No);
            if (TN_Task != null)
            {
                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:
                            WCSHelper.UpdateStatus(TN_Task, "卸货完成");
                            TaskProcess.OperateStatus(TN_Task, 6);
                            break;
                        #endregion
                        case 2:
                            WCSHelper.End(TN_Task);
                            //根据任务类型更新作业状态和终点
                            var taskList = Settings.CompleteTasks;
                            if (taskList.taskType.Contains(TN_Task.S_TYPE))
                            {
                                //完成作业
                                WMSHelper.UpdateWmsTask(TN_Task, 3);
                            }
                            WMSHelper.AddChange(TN_Task);
                            WMSHelper.DeleteChange(TN_Task);
                            break;
                        case 7:
                            TaskProcess.OperateStatus(TN_Task, 7);
                            WCSHelper.Fail(TN_Task);
                            break;
                    }
                    WCSHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);

                }

            }
        }

        /// <summary>
        /// 任务分发，根据调度类型发给不同的调度系统
        /// </summary>
        internal static void Dispatch()
        {
            //查询任务
            //获取所有等待的任务
            var list = WCSHelper.GetTaskListByState("等待"); ;
            if (list.Count > 0)
            {
                list.ForEach(task =>
                {
                    //使用自定义任务推送
                    TaskProcess.SendGZTask(task);
                });
            }
        }


        #region 杭氧任务服务
        /// <summary>
        /// 循环作业生成任务
        /// </summary>
        internal static void ExecuteJob()
        {
            try
            {
                //查询任务
                //获取所有等待的作业
                var list = WMSHelper.GetWmsTaskListByState("等待"); ;
                if (list.Count > 0)
                {

                    list.ForEach(task =>
                    {
                        //生成入库任务
                        TaskProcess.CreateInTask(task);
                    });
                }
            }
            catch (Exception ex)
            {
                var st = new System.Diagnostics.StackTrace(ex, true);
                var frame = st.GetFrame(0); // 获取第一个堆栈帧
                if (frame != null)
                {
                    LogHelper.Error($"CreateInTask获取作业创建入库任务出现错误！！", ex);
                    LogHelper.Error($"文件名: {frame.GetFileName()}", ex);
                    LogHelper.Error($"行号: {frame.GetFileLineNumber()}", ex);
                    LogHelper.Error($"列号: {frame.GetFileColumnNumber()}", ex);
                }
            }

        }


        /// <summary>
        /// 循环接驳位生成入库任务
        /// </summary>
        private static readonly object _inventoryLock = new object();
        internal static void ProcessZoneInventoryCycle()
        {
            try
            {
                lock (_inventoryLock)  // 加锁确保同一时间只有一个线程执行
                {
                    //循环入库暂存区生成合托或入库任务
                    TaskProcess.BatchInWork();
                }
            }
            catch (Exception ex)
            {
                var st = new System.Diagnostics.StackTrace(ex, true);
                var frame = st.GetFrame(0); // 获取第一个堆栈帧
                if (frame != null)
                {
                    LogHelper.Error($"循环接驳位生成入库任务！！", ex);
                    LogHelper.Error($"文件名: {frame.GetFileName()}", ex);
                    LogHelper.Error($"行号: {frame.GetFileLineNumber()}", ex);
                    LogHelper.Error($"列号: {frame.GetFileColumnNumber()}", ex);
                }
            }

        }

        /// <summary>
        /// 根据配盘单生成出库任务
        /// </summary>
        internal static void GenerateFromPicking()
        {
            try
            {
                //查询已配盘的配盘单
                var list = WMSHelper.GetPickingListByState("配货完成");
                if (list.Count > 0)
                {
                    TaskProcess.GenerateFromPicking(list);
                }
            }
            catch (Exception ex)
            {
                var st = new System.Diagnostics.StackTrace(ex, true);
                var frame = st.GetFrame(0); // 获取第一个堆栈帧
                if (frame != null)
                {
                    LogHelper.Error($"根据配盘单生成出库任务！！", ex);
                    LogHelper.Error($"文件名: {frame.GetFileName()}", ex);
                    LogHelper.Error($"行号: {frame.GetFileLineNumber()}", ex);
                    LogHelper.Error($"列号: {frame.GetFileColumnNumber()}", ex);
                }
            }
        }
        #endregion
    }
}