using iWareCommon.Utils;
using iWareModel.Entity.MES;
using iWareSql.MyDbContext;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Threading;
using System.Linq;
using Admin.NET.Core.TaskModule.Enum;
using System.Configuration;
using iWareModel.Entity.WCS;
using iWareCC.Common.Helper;
using Newtonsoft.Json.Bson;
using System.Data.Entity;
using System.Web;
using iWareModel.Entity.WMS;
using iWareCommon;
using System.Threading.Tasks;
using static System.Windows.Forms.VisualStyles.VisualStyleElement.TrackBar;
using System.Windows.Forms;
using iWareSql.DataAccess;
using iWareModel.Entity;

namespace iWareCC
{
    /// <summary>
    /// 下发任务处理的线程
    /// </summary>
    public class IssueTasHandler
    {
        public static List<CurLaneDataObj> curLaneDataObjs = new List<CurLaneDataObj>() {
         new CurLaneDataObj(){ Lane=1, LastRunTaskCategoryFun=null },
         new CurLaneDataObj(){ Lane=2, LastRunTaskCategoryFun=null}
        };
        public static void Handler()
        {
            var errMsg = "";
            while (true)
            {
                try
                {
                    SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "循环开始...";
                    if (SystemValue.isAllowRuning_OutTaskIssueTaskHandler && SystemValue.isStartedModel)
                    {
                        errMsg = "";//重置
                        try
                        {

                            #region 查询堆垛机是否空闲
                            //var utl = string.Format(WcsIp + @"GetDevicesInfo?Timestamp={0}&Creator={1}", DateTime.Now.ToString(), "cc");
                            //var result1 = HttpHelper.Post(utl, "");

                            WCSDevicesOutput data1 = null;
                            if (FormCC.IsSimulationPLC)
                            {//如果是模拟
                                data1 = MyExtendHelper.GetSimulationSrmDevicesOutput();
                                Log4NetHelper.WriteInfoLog(LogType.OutPlanTask, "出库处理的线程（OutPlanTaskHandler）查询堆垛机是否空闲，模拟环境");
                                SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "堆垛机状态查询模拟";
                            }
                            else
                            {
                                //var utl = string.Format(@"GetDevicesInfo?Timestamp={0}&Creator={1}", DateTime.Now.ToString(), "cc");
                                //IDictionary<string, string> parameter = new Dictionary<string, string>();
                                //var result1 = new HTTPService(FormCC.WcsIp).postContentForString(utl, parameter, "");

                                //Log4NetHelper.WriteInfoLog(LogType.OutPlanTask, "出库处理的线程（OutPlanTaskHandler）查询堆垛机是否空闲，返回结果:" + result1);
                                //if (result1 == null)
                                //{
                                //    SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "堆垛机状态查询失败，WCS返回NULL";
                                //    continue;//继续下一次循环
                                //}
                                //data1 = JsonConvert.DeserializeObject<WCSDevicesOutput>(result1);
                                //if (data1 == null || !data1.Success || data1.Data == null)
                                //{
                                //    SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "堆垛机状态查询失败,WCS返回结果:" + result1;
                                //    continue;//继续下一次循环
                                //}
                            }

                            if (data1.Data != null && data1.Data.SRM1 != null)
                            {
                                _Do(data1.Data.SRM1, 1, ref errMsg);
                            }
                            else
                            {
                                SystemWarningMsg._lbl_Alert_OutPlanTaskHandler += "|| 1号巷道无任务或者1号堆垛机不是空闲状态！";
                            }

                            if (data1.Data != null && data1.Data.SRM2 != null)
                            {
                                _Do(data1.Data.SRM2, 2, ref errMsg);
                            }
                            else
                            {
                                SystemWarningMsg._lbl_Alert_OutPlanTaskHandler += "|| 2号巷道无任务或者2号堆垛机不是空闲状态！";
                            }

                            #endregion
                            // SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "循环结束...";
                        }
                        catch (Exception ex)
                        {
                            Log4NetHelper.WriteErrorLog(LogType.OutPlanTask, "处理出入库下发=>" + errMsg + ",异常:" + ex.Message, ex);
                            SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "处理出入库下发=>" + errMsg + ",异常:" + ex.Message;
                        }
                    }
                }
                catch (Exception ex)
                {
                    SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "出现异常:" + ex.Message;
                    Log4NetHelper.WriteErrorLog(LogType.OutPlanTask, "OutPlanTaskHandler 出库任务 出现异常：" + ex.Message, ex);
                }
                Thread.Sleep(2 * 1000);//休眠2秒
            }
        }


        private static void _Do(WDO_Data wDO_Data, int flag, ref string errMsg)
        {
            wms_task model = null;
            if (wDO_Data != null)
            {
                int Lane = int.Parse(wDO_Data.SrmNo);

                Handler_Issue(model, Lane, flag, ref errMsg);
              
            }
            else
            {
                SystemWarningMsg._lbl_Alert_OutPlanTaskHandler += "|| " + flag + "号巷道无任务或者" + flag + "号堆垛机不是空闲状态！";
            }
        }

        /// <summary>
        /// 任务下发
        /// </summary>
        /// <param name="model"></param>
        /// <param name="Lane"></param>
        /// <param name="flag"></param>
        /// <param name="errMsg"></param>
        private static void Handler_Issue(wms_task model, int Lane, int flag, ref string errMsg)
        {
            model = null;
            using (MyDbContext mycontext1 = new MyDbContext())
            {
                model = mycontext1.wms_task.Where(x => ( x.IsDelete == false) && x.TaskStatus == (int)TaskStatusEnum.新建)
                  
                    .OrderByDescending(x => x.TaskPriority).FirstOrDefault();//查询未WCS下发未完成的任务
                if (model != null)
                {
                    int result = IssueTaskHelper.Put(mycontext1, FormCC.WcsIp, Lane, model, ref errMsg);
                    if (!string.IsNullOrEmpty(errMsg))
                    {
                        SystemWarningMsg._lbl_Alert_OutPlanTaskHandler += "|| " + flag + "巷道下发入库任务失败," + errMsg;
                    }
                }
            }
            //判断如果有错误日志，就更新任务表的消息
            if (model != null && !string.IsNullOrEmpty(errMsg))
            {
                TaskHandler.UpdateTaskMsg(model.Id, errMsg);
            }
        }


    }
}