using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
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.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 _readZLJSignalso = 0;
        public static object requestFX = new object();
        public static object requestZX = new object();
        /// <summary>
        /// 中转料架逻辑流程
        /// </summary>
        /// <returns></returns>
        public static void Z_ZZLJ_Task()
        {
            if (Interlocked.Exchange(ref _readZLJSignalso, 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);
                    Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
                    Ibase_routing_tableRepository routingRepository = new base_routing_tableRepository(Context);
                    Ibill_pda_groupdiskRepository pdaRepository = new bill_pda_groupdiskRepository(Context);
                    Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
                    Ibill_group_stockRepository groupRepository = new bill_group_stockRepository(Context);
                    Idt_agvtask_htyRepository agvtask_HtyRepository = new dt_agvtask_htyRepository(Context);
                    List<string> ZZLJS = new List<string> { "ZJXL-ZZLJ001", "ZJXL-ZZLJ002", "ZJXL-ZZLJ003", "ZJXL-ZZLJ004", "FJXL-ZZLJ001",
                        "FJXL-ZZLJ002", "FJXL-ZZLJ003", "FJXL-ZZLJ004" };
                    foreach (var ZZLJ in ZZLJS)
                    {
                        var location = locRepository.FindFirst(v => v.down_code == ZZLJ);
                        var stocks = groupRepository.Find(v => v.location_id == location.id);
                        var stock = new bill_group_stock();
                        if (stocks.Count() > 0)
                        {
                            stock = stocks.OrderByDescending(o => o.created_time).First();
                        }
                        else
                        {
                            continue;
                        }
                        //判断分切的状态
                        if (stock != null && (stock.FQ_Status == "OK" || stock.FQ_Status == "NG"))
                        {
                            string address = "";
                            bool choose = false;
                            var KClocation = new base_ware_location();
                            string toaddressnum = "";
                            if (location.location_state == LocationStateEnum.LocationState_Stored.ToString())
                            {
                                if (ZZLJ.Contains("ZJXL"))
                                {
                                    lock (requestZX)
                                    {
                                        var tasks = agvRepository.Find(f => f.agv_toaddress.Contains("ZX"));
                                        if (tasks.Count() == 0)
                                        {
                                            var taskthy = agvtask_HtyRepository.Find(f => f.agv_toaddress.Contains("ZX") && (f.agv_taskstate == "Finished" || f.agv_taskstate == "ManualCompletion")).OrderByDescending(o => o.agv_createtime).First();
                                            toaddressnum = taskthy.agv_toaddress.Substring(2, 1);
                                        }
                                        else
                                        {
                                            var task = tasks.OrderByDescending(o => o.agv_createtime).First();
                                            toaddressnum = task.agv_toaddress.Substring(2, 1);
                                        }
                                        List<string> nums = new List<string>() { "ZXD0101", "ZXB0101", "ZXC0101", "ZXA0101" };
                                        int count = 0;
                                        for (int i=0;i<nums.Count();i++)
                                        {
                                            var loc = locRepository.FindFirst(f=>f.upper_code==nums[i]);
                                            if (loc.location_state==LocationStateEnum.LocationState_Empty.ToString())
                                            {
                                                 count = 1;
                                            }
                                        }
                                        if (count==0) { continue; }
                                        for (int i = 1; i < 5; i++)
                                        {
                                            if (choose)
                                            {
                                                KClocation = locRepository.FindFirst(v => v.upper_code == nums[i - 1]);
                                                if (KClocation.location_state == LocationStateEnum.LocationState_Empty.ToString())
                                                {
                                                    address = KClocation.upper_code;
                                                    choose = false;
                                                    break;
                                                }
                                                else
                                                {
                                                    if (nums[i - 1].Contains("A")) { i = 0; }
                                                    continue;
                                                }
                                            }
                                            else if (nums[i - 1].Contains(toaddressnum))
                                            {
                                                choose = true;
                                                if (toaddressnum == "A") { i = 0; }
                                                continue;
                                            }
                                            else
                                            {
                                                continue;
                                            }
                                        }
                                    }
                                }
                                else if (ZZLJ.Contains("FJXL"))
                                {
                                    lock (requestFX)
                                    {
                                        var tasks = agvRepository.Find(f => f.agv_toaddress.Contains("FX"));
                                        if (tasks.Count() == 0)
                                        {
                                            var taskthy = agvtask_HtyRepository.Find(f => f.agv_toaddress.Contains("FX") && (f.agv_taskstate == "Finished" || f.agv_taskstate == "ManualCompletion")).OrderByDescending(o => o.agv_createtime).First();
                                            toaddressnum = taskthy.agv_toaddress.Substring(2, 1);
                                        }
                                        else
                                        {
                                            var task = tasks.OrderByDescending(o => o.agv_createtime).First();
                                            toaddressnum = task.agv_toaddress.Substring(2, 1);
                                        }
                                        List<string> nums = new List<string>() { "FXD0101", "FXB0101", "FXC0101", "FXA0101" };
                                        int count = 0;
                                        for (int i = 0; i < nums.Count(); i++)
                                        {
                                            var loc = locRepository.FindFirst(f => f.upper_code == nums[i]);
                                            if (loc.location_state == LocationStateEnum.LocationState_Empty.ToString())
                                            {
                                                count = 1;
                                            }
                                        }
                                        if (count == 0) { continue; }
                                        for (int i = 1; i < 5; i++)
                                        {
                                            if (choose)
                                            {
                                                KClocation = locRepository.FindFirst(v => v.upper_code == nums[i - 1]);
                                                if (KClocation.location_state == LocationStateEnum.LocationState_Empty.ToString())
                                                {
                                                    address = KClocation.upper_code;
                                                    choose = false;
                                                    break;
                                                }
                                                else
                                                {
                                                    if (nums[i - 1].Contains("A")) { i = 0; }
                                                    continue;
                                                }
                                            }
                                            else if (nums[i - 1].Contains(toaddressnum))
                                            {
                                                choose = true;
                                                if (toaddressnum == "A") { i = 0; }
                                                continue;
                                            }
                                            else
                                            {
                                                continue;
                                            }
                                        }
                                    }
                                }
                                    if (!string.IsNullOrEmpty(address))
                                    {
                                    responseContent = locRepository.DbContextBeginTransaction(() =>
                                    {
                                        //条件全部通过，生成AGV任务
                                        dt_agvtask agvtask = new dt_agvtask
                                        {
                                            agv_materbarcode = stock.BarCode,
                                            agv_barcode = "",
                                            agv_createtime = DateTime.Now,
                                            agv_fromaddress = ZZLJ,
                                            agv_grade = 1,
                                            agv_materielid = stock.MaterialType,
                                            agv_qty = 1,
                                            agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
                                            agv_taskstate = "Create",
                                            agv_tasktype = "TaskType_Outbound",
                                            agv_toaddress = address,
                                            agv_userid = "WCS",
                                            agv_worktype = 1
                                        };
                                        if (ZZLJ.Contains("ZJXL"))
                                        {
                                            agvtask.agv_code = "正极1号AGV";
                                        }
                                        else
                                        {
                                            agvtask.agv_code = "负极1号AGV";
                                        }
                                        stock.FQ_Status = stock.FQ_Status + "doing";
                                        groupRepository.Update(stock, true);
                                        agvRepository.Add(agvtask, true);
                                        WriteLog.Info("Z_ZZLJ_Task").Write("Z_ZZLJ_Task" + agvtask.agv_tasknum + stock.BarCode + DateTime.Now, "Z_ZZLJ_Task");
                                        location.location_state = LocationStateEnum.LocationState_Lock.ToString();
                                        locRepository.Update(location, true);
                                        KClocation.location_state = LocationStateEnum.LocationState_Lock.ToString();
                                        locRepository.Update(KClocation, true);
                                        return WebResponseContent.Instance.OK();
                                    });
                                        break;
                                    }
                                }
                            
                        }
                    }
                }
                catch (Exception ex)
                {
                    WriteLog.Info("Z_ZZLJ_Task").Write("Z_ZZLJ_Task" + ex.Message + DateTime.Now, "Z_ZZLJ_Task");
                    throw new Exception(ex.Message);
                }
                finally
                {
                    Interlocked.Exchange(ref _readZLJSignalso, 0);
                }
            }
        }
    }
}