using System;
using System.Collections.Generic;
using System.Linq;
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 _readXJJKSignalso = 0;
        /// <summary>
        /// 正极和负极小极卷库入中转料架逻辑
        /// </summary>
        /// <returns></returns>
        public static void ZF_XJJK_DownTask()
        {
            if (Interlocked.Exchange(ref _readXJJKSignalso, 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);
                    Ibase_routing_tableRepository routingRepository = new base_routing_tableRepository(Context);
                    Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
                   List<string> ZZLJS = new List<string> { "ZJXL-ZZLJ001", "ZJXL-ZZLJ004","ZJXL-ZZLJ002", "ZJXL-ZZLJ003", "FJXL-ZZLJ001",
                        "FJXL-ZZLJ002", "FJXL-ZZLJ003", "FJXL-ZZLJ004" };
                    //  List<string> ZZLJS = new List<string> { "FJXL-ZZLJ002", "FJXL-ZZLJ003","FJXL-ZZLJ001", "FJXL-ZZLJ004" };
                    PLCClient plc = null;
                    foreach (var ZZLJ in ZZLJS)
                    {
                        var location = locRepository.FindFirst(v => v.down_code == ZZLJ);
                        if (ZZLJ.Contains("ZJXL"))
                        {
                            plc = WCSService.Clients.Find(v => v.PLCName == "正极1号AGV");
                            if (plc == null)
                                continue;
                            string isZWork = plc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), ZZLJ).ToString();
                            if (isZWork == "2")
                                continue;
                            var routes = routingRepository.Find(v => v.route_end == ZZLJ).ToList();
                            foreach (var route in routes)
                            {
                                var task = agvRepository.FindFirst(v => v.agv_fromaddress == ZZLJ || v.agv_toaddress == location.upper_code || v.agv_toaddress == ZZLJ);
                                if (task != null)
                                    continue;
                                if (location.location_state == LocationStateEnum.LocationState_Empty.ToString())
                                {
                                    responseContent = locRepository.DbContextBeginTransaction(() =>
                                    {
                                        dt_agvtask agvtask = new dt_agvtask
                                        {
                                            agv_materbarcode = "",
                                            agv_barcode = "",
                                            agv_code = "正极1号AGV",
                                            agv_createtime = DateTime.Now,
                                            agv_fromaddress = "nou",
                                            agv_grade = 1,
                                            agv_materielid = "空托盘",
                                            agv_qty = 1,
                                            agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
                                            agv_taskstate = "WaitStockOut",
                                            agv_tasktype = "TaskType_Outbound",
                                            agv_toaddress = ZZLJ,
                                            agv_userid = "WCS",
                                            agv_worktype = 2
                                        };
                                        List<string> StockList = new List<string> { "ZXD0201", "ZXC0201", "ZXB0201", "ZXA0201" };
                                        MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 3, "空托盘", "", "");
                                        if (WMSbackresult == null) { return WebResponseContent.Instance.Error("正极小极卷库不通过要料申请"); }
                                        location.location_state = LocationStateEnum.LocationState_Lock.ToString();
                                        locRepository.Update(location, true);
                                        agvRepository.Add(agvtask, true);
                                        WriteLog.Info("ZF_XJJK_DownTask").Write("ZF_XJJK_DownTask" + agvtask.agv_tasknum + DateTime.Now, "ZF_XJJK_DownTask");
                                        return WebResponseContent.Instance.OK();
                                    });
                                    break;
                                }
                            }
                        }
                        else if (ZZLJ.Contains("FJXL"))
                        {
                            plc = WCSService.Clients.Find(v => v.PLCName == "负极1号AGV");
                            if (plc == null)
                                continue;
                            string isZWork = plc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), ZZLJ).ToString();
                            if (isZWork == "2")
                                continue;
                            var routes = routingRepository.Find(v => v.route_end == ZZLJ).ToList();
                            foreach (var route in routes)
                            {
                                var task = agvRepository.FindFirst(v => v.agv_fromaddress == route.route_end || v.agv_toaddress == route.route_end || v.agv_toaddress == location.upper_code || v.agv_toaddress == ZZLJ);
                                if (task != null)
                                    continue;
                                if (location.location_state == LocationStateEnum.LocationState_Empty.ToString())
                                {
                                    responseContent = locRepository.DbContextBeginTransaction(() =>
                                    {
                                        dt_agvtask agvtask = new dt_agvtask
                                        {
                                            agv_materbarcode = "",
                                            agv_barcode = "",
                                            agv_code = "负极1号AGV",
                                            agv_createtime = DateTime.Now,
                                            agv_fromaddress = "nou",
                                            agv_grade = 1,
                                            agv_materielid = "空托盘",
                                            agv_qty = 1,
                                            agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
                                            agv_taskstate = "WaitStockOut",
                                            agv_tasktype = "TaskType_Outbound",
                                            agv_toaddress = ZZLJ,
                                            agv_userid = "WCS",
                                            agv_worktype = 2
                                        };
                                        List<string> StockList = new List<string> { "FXD0201", "FXC0201", "FXB0201", "FXA0201" };
                                        MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, StockList, 3, "空托盘", "", "");
                                        if (WMSbackresult == null) { return WebResponseContent.Instance.Error("负极小极卷库不通过要料申请"); }
                                        location.location_state = LocationStateEnum.LocationState_Lock.ToString();
                                        locRepository.Update(location, true);
                                        agvRepository.Add(agvtask, true);
                                        WriteLog.Info("ZF_XJJK_DownTask").Write("ZF_XJJK_DownTask" + agvtask.agv_tasknum + DateTime.Now, "ZF_XJJK_DownTask");
                                        return WebResponseContent.Instance.OK();
                                    });
                                    break;
                                }
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    WriteLog.Info("ZF_XJJK_DownTask").Write("ZF_XJJK_DownTask" + ex.Message + DateTime.Now, "ZF_XJJK_DownTask");
                }
                finally
                {
                    Interlocked.Exchange(ref _readXJJKSignalso, 0);
                }
            }
        }
    }
}