using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Threading;
using WIDESEA_Common;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS.Jobs
{
    public partial class EquipmentExecutor : SchedulerExecuteBase
    {
        private static int _readJRSignalso = 0;

        public static void JRSB_UpTask()
        {
            if (Interlocked.Exchange(ref _readJRSignalso, 1) == 0)
            {
                try
                {
                    VOLContext Context = new VOLContext();
                    WebResponseContent responseContent = new WebResponseContent();
                    Idt_task_numberRepository tasknumberRep = new dt_task_numberRepository(Context);
                    dt_task_numberService tasknumber = new dt_task_numberService(tasknumberRep);
                    Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
                    IJROutBindRepository jrRepository = new JROutBindRepository(Context);
                    List<string> JRSBS = new List<string> { "格林晟1号卷绕机", "格林晟2号卷绕机", "格林晟3号卷绕机", "格林晟4号卷绕机", "格林晟5号卷绕机", "格林晟6号卷绕机", "格林晟7号卷绕机", "格林晟8号卷绕机", "格林晟9号卷绕机", "格林晟10号卷绕机" };
                    foreach (var JRSB in JRSBS)
                    {
                        WriteLog.Info($"{JRSB}下料").Write($"{JRSB}开始,时间：" + DateTime.Now + "   ----------", $"{JRSB}下料");
                        PLCClient plc = WCSService.Clients.Find(v => v.PLCName == JRSB);
                        if (plc == null) { continue; }
                        //当前设备有没有上料请求
                        string isSBWork1 = plc.ReadValue(ConveyorLineInfoDBName.R_GLSJRSB1_UPrequest.ToString(), plc.PLCName).ToString();
                        string isSBWork2 = plc.ReadValue(ConveyorLineInfoDBName.R_GLSJRSB2_UPrequest.ToString(), plc.PLCName).ToString();
                        string isSBWork3 = plc.ReadValue(ConveyorLineInfoDBName.R_GLSJRSB3_UPrequest.ToString(), plc.PLCName).ToString();
                        string isSBWork4 = plc.ReadValue(ConveyorLineInfoDBName.R_GLSJRSB4_UPrequest.ToString(), plc.PLCName).ToString();
                        //读取设备的工单号
                        string batchNo = plc.ReadValue(ConveyorLineInfoDBName.R_JRSB_UPbatchNo.ToString(), plc.PLCName).ToString();
                        if (batchNo == null) { continue; }
                        WriteLog.Info("格林晟卷绕上料").Write(JRSB + "\t" + "上料口1:" + isSBWork1 + "\t" + "上料口2:" + isSBWork2 + "\t" + "上料口3:" + isSBWork3 + "\t" + "上料口4:" + isSBWork4 + "\t" + batchNo + "\t" + DateTime.Now, "格林晟卷绕上料");
                        dt_agvtask agvtask = new dt_agvtask();
                        if (bool.Parse(isSBWork1) || bool.Parse(isSBWork2) || bool.Parse(isSBWork3) || bool.Parse(isSBWork4))
                        {
                            if (bool.Parse(isSBWork1))
                            {
                                int number = Convert.ToInt32(JRSB.Substring(3, 1));
                                if (JRSB == "格林晟10号卷绕机") { number = 10; }
                                int num = 1 + (number - 1) * 4;
                                string sum = "";
                                if (num >= 10)
                                {
                                    sum = "0" + num;
                                }
                                else
                                {
                                    sum = "00" + num;
                                }
                                agvtask.agv_toaddress = "FJSL-JRSB" + sum + "-B";
                                agvtask.agv_barcode = "";
                                agvtask.agv_code = "负极2号AGV";
                                agvtask.agv_createtime = DateTime.Now;
                                agvtask.agv_fromaddress = "nou";
                                agvtask.agv_grade = 1;
                                agvtask.agv_materbarcode = "daiding";
                                agvtask.agv_qty = 1;
                                agvtask.agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep);
                                agvtask.agv_taskstate = "WaitStockOut";
                                agvtask.agv_tasktype = "TaskType_Outbound";
                                agvtask.agv_userid = "WCS";
                                agvtask.agv_worktype = 1;
                                agvtask.agv_materielid = batchNo;
                                var task = agvRepository.FindFirst(f => f.agv_toaddress == agvtask.agv_toaddress);
                                if (task == null)
                                {
                                    List<string> StockList = new List<string> { "FJXL-FBT001", "FJXL-FBT002" };
                                    MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 4, batchNo, "", agvtask.agv_toaddress);
                                    WriteLog.Info($"{JRSB}下料").Write($"isSBWork1:MES返回数据：{JsonConvert.SerializeObject(WMSbackresult)},时间：" + DateTime.Now + "   ----------", $"{JRSB}下料");
                                    if (WMSbackresult.Code > 0)
                                    {
                                        WriteLog.Info("格林晟卷绕上料").Write(JRSB + "要料失败" + WMSbackresult.Message + "\t" + DateTime.Now, "格林晟卷绕上料");
                                        break;
                                    }
                                    agvRepository.Add(agvtask, true);
                                }
                            }
                            if (bool.Parse(isSBWork2))
                            {
                                int number = Convert.ToInt32(JRSB.Substring(3, 1));
                                if (JRSB == "格林晟10号卷绕机") { number = 10; }
                                int num = 2 + (number - 1) * 4;
                                string sum = "";
                                if (num >= 10)
                                {
                                    sum = "0" + num;
                                }
                                else
                                {
                                    sum = "00" + num;
                                }
                                agvtask.agv_toaddress = "FJSL-JRSB" + sum + "-B";
                                agvtask.agv_barcode = "";
                                agvtask.agv_code = "负极2号AGV";
                                agvtask.agv_createtime = DateTime.Now;
                                agvtask.agv_fromaddress = "nou";
                                agvtask.agv_grade = 1;
                                agvtask.agv_materbarcode = "daiding";
                                agvtask.agv_qty = 1;
                                agvtask.agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep);
                                agvtask.agv_taskstate = "WaitStockOut";
                                agvtask.agv_tasktype = "TaskType_Outbound";
                                agvtask.agv_userid = "WCS";
                                agvtask.agv_worktype = 1;
                                agvtask.agv_materielid = batchNo;
                                var task = agvRepository.FindFirst(f => f.agv_toaddress == agvtask.agv_toaddress);
                                if (task == null)
                                {
                                    List<string> StockList = new List<string> { "FJXL-FBT001", "FJXL-FBT002" };
                                    MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 4, batchNo, "", agvtask.agv_toaddress);
                                    WriteLog.Info($"{JRSB}下料").Write($"isSBWork2:MES返回数据：{JsonConvert.SerializeObject(WMSbackresult)},时间：" + DateTime.Now + "   ----------", $"{JRSB}下料");
                                    if (WMSbackresult.Code > 0)
                                    {
                                        WriteLog.Info("格林晟卷绕上料").Write(JRSB + "要料失败" + WMSbackresult.Message + "\t" + DateTime.Now, "格林晟卷绕上料");
                                        break;
                                    }
                                    agvRepository.Add(agvtask, true);
                                }
                            }
                            if (bool.Parse(isSBWork3))
                            {
                                int number = Convert.ToInt32(JRSB.Substring(3, 1));
                                if (JRSB == "格林晟10号卷绕机") { number = 10; }
                                int num = 3 + (number - 1) * 4;
                                string sum = "";
                                if (num >= 10)
                                {
                                    sum = "0" + num;
                                }
                                else
                                {
                                    sum = "00" + num;
                                }
                                agvtask.agv_toaddress = "ZJSL-JRSB" + sum + "-B";
                                agvtask.agv_barcode = "";
                                agvtask.agv_code = "负极2号AGV";
                                agvtask.agv_createtime = DateTime.Now;
                                agvtask.agv_fromaddress = "nou";
                                agvtask.agv_grade = 1;
                                agvtask.agv_materbarcode = "daiding";
                                agvtask.agv_qty = 1;
                                agvtask.agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep);
                                agvtask.agv_taskstate = "WaitStockOut";
                                agvtask.agv_tasktype = "TaskType_Outbound";
                                agvtask.agv_userid = "WCS";
                                agvtask.agv_worktype = 1;
                                agvtask.agv_materielid = batchNo;
                                var task = agvRepository.FindFirst(f => f.agv_toaddress == agvtask.agv_toaddress);
                                if (task == null)
                                {
                                    List<string> StockList = new List<string> { "FJXL-FBT001", "FJXL-FBT002" };
                                    MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 4, batchNo, "", agvtask.agv_toaddress);
                                    WriteLog.Info($"{JRSB}下料").Write($"isSBWork3:MES返回数据：{JsonConvert.SerializeObject(WMSbackresult)},时间：" + DateTime.Now + "   ----------", $"{JRSB}下料");
                                    if (WMSbackresult.Code > 0)
                                    {
                                        WriteLog.Info("格林晟卷绕上料").Write(JRSB + "要料失败" + WMSbackresult.Message + "\t" + DateTime.Now, "格林晟卷绕上料");
                                        break;
                                    }
                                    agvRepository.Add(agvtask, true);
                                }
                            }
                            if (bool.Parse(isSBWork4))
                            {
                                int number = Convert.ToInt32(JRSB.Substring(3, 1));
                                if (JRSB == "格林晟10号卷绕机") { number = 10; }
                                int num = 4 + (number - 1) * 4;
                                string sum = "";
                                if (num >= 10)
                                {
                                    sum = "0" + num;
                                }
                                else
                                {
                                    sum = "00" + num;
                                }
                                agvtask.agv_toaddress = "ZJSL-JRSB" + sum + "-B";
                                agvtask.agv_barcode = "";
                                agvtask.agv_code = "负极2号AGV";
                                agvtask.agv_createtime = DateTime.Now;
                                agvtask.agv_fromaddress = "nou";
                                agvtask.agv_grade = 1;
                                agvtask.agv_materbarcode = "daiding";
                                agvtask.agv_qty = 1;
                                agvtask.agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep);
                                agvtask.agv_taskstate = "WaitStockOut";
                                agvtask.agv_tasktype = "TaskType_Outbound";
                                agvtask.agv_userid = "WCS";
                                agvtask.agv_worktype = 1;
                                agvtask.agv_materielid = batchNo;
                                var task = agvRepository.FindFirst(f => f.agv_toaddress == agvtask.agv_toaddress);
                                if (task == null)
                                {
                                    List<string> StockList = new List<string> { "FJXL-FBT001", "FJXL-FBT002" };
                                    MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 4, batchNo, "", agvtask.agv_toaddress);
                                    WriteLog.Info($"{JRSB}下料").Write($"isSBWork4:MES返回数据：{JsonConvert.SerializeObject(WMSbackresult)},时间：" + DateTime.Now + "   ----------", $"{JRSB}下料");
                                    if (WMSbackresult.Code > 0)
                                    {
                                        WriteLog.Info("格林晟卷绕上料").Write(JRSB + "要料失败" + WMSbackresult.Message + "\t" + DateTime.Now, "格林晟卷绕上料");
                                        break;
                                    }
                                    agvRepository.Add(agvtask, true);
                                }
                            }
                            #region
                            //var bind = new JROutBind();
                            //if (agvtask.agv_toaddress.Contains("ZJ"))
                            //{
                            //    bind = jrRepository.FindFirst(f => f.Devid == "ZJXL-FBT001");
                            //}
                            //else if (agvtask.agv_toaddress.Contains("FJ"))
                            //{
                            //    bind = jrRepository.FindFirst(f => f.Devid == "ZJXL-FBT002");
                            //}
                            //if (bind.materialtype != batchNo)
                            //{
                            //    bind = new JROutBind()
                            //    {
                            //        barcode = "",
                            //        materialtype = "",
                            //        sum = 0,
                            //        taskid = ""
                            //    };
                            //    jrRepository.Update(bind, true);
                            //var task = agvRepository.FindFirst(f => f.agv_toaddress ==agvtask.agv_toaddress);
                            //if (task != null) { continue; }
                            //List<string> StockList = new List<string> { "ZJXL-FBT001", "ZJXL-FBT002" };
                            //MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 4, batchNo, "", agvtask.agv_toaddress);
                            //if (WMSbackresult.Code > 0)
                            //{
                            //    WriteLog.Info("格林晟卷绕上料").Write(JRSB + "要料失败" + WMSbackresult.Message + "\t" + DateTime.Now, "格林晟卷绕上料");
                            //    break;
                            //}
                            //agvRepository.Add(agvtask, true);
                            #endregion
                            WriteLog.Info("格林晟卷绕上料").Write(JRSB + "\t" + agvtask.agv_tasknum + "\t" + "上料口1:" + isSBWork1 + "\t" + "上料口2:" + isSBWork2 + "\t" + "上料口3:" + isSBWork3 + "\t" + "上料口4:" + isSBWork4 + "\t" + batchNo + "\t" + DateTime.Now, "格林晟卷绕上料");
                            //    }
                            break;
                        }
                        else
                        {
                            continue;
                        }
                    }
                }
                catch (Exception ex)
                {
                    WriteLog.Info("JRSB_UpTask").Write("JRSB_UpTask" + ex.Message, "JRSB_UpTask");
                }
                finally
                {
                    Interlocked.Exchange(ref _readJRSignalso, 0);
                }
            }
        }
    }
}