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;
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 _readFJCBJSignalso = 0;
        /// <summary>
        /// 拆包站逻辑流程
        /// </summary>
        /// <param name="client"></param>
        /// <returns></returns>
        public static void CBJtask()
        {
            if (Interlocked.Exchange(ref _readFJCBJSignalso, 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);

                    // 抓取PDA主盘表数据
                    var PDAtask = pdaRepository.FindFirst(v => v.ishandle == 1);
                    if (PDAtask != null)
                    {
                        //查询起点站台的路由
                        var routes = routingRepository.Find(v => v.route_began == PDAtask.Devid).ToList();
                        foreach (var route in routes)
                        {
                            //判断终点位置是否可用
                            PLCClient plc = WCSService.Clients.Find(v => v.PLCName == "负极1号AGV");
                            //读取PLC信号是否能放货
                            string isWork = plc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), route.route_end).ToString();
                            //查询WCS自己的货位判断是否有货
                            var location = locRepository.FindFirst(v => v.upper_code == route.route_end);
                            if (isWork == "1" && location.location_state == LocationStateEnum.LocationState_Empty.ToString())
                            {
                                //条件通过即可创建AGV任务
                                dt_agvtask agvtask = new dt_agvtask
                                {
                                    agv_materbarcode = PDAtask.BarCode,
                                    agv_barcode = "",
                                    agv_code = "负极1号AGV",
                                    agv_createtime = DateTime.Now,
                                    agv_fromaddress = route.route_began,
                                    agv_grade = 1,
                                    agv_materielid = PDAtask.MaterialType,
                                    agv_qty = 1,
                                    agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
                                    agv_taskstate = "Create",
                                    agv_tasktype = "TaskType_Outbound",
                                    agv_toaddress = route.route_end,
                                    agv_userid = "WCS",
                                    agv_worktype = 1
                                };
                                agvRepository.Add(agvtask, true);
                                WriteLog.Info("CBJtask").Write("CBJtask接口" + agvtask.agv_tasknum + DateTime.Now, "CBJtask");
                                //AGV任务生成后修改PDA组盘表
                                PDAtask.ishandle = 0;
                                //pdaRepository.Delete(item, true);
                                //修改终点货架存储状态
                                location.location_state = LocationStateEnum.LocationState_Lock.ToString();
                                locRepository.Update(location, true);
                                //添加库存信息
                                bill_group_stock stock = new bill_group_stock();
                                stock.stock_id = Guid.NewGuid();
                                stock.MaterialType = PDAtask.MaterialType;
                                stock.BarCode = PDAtask.BarCode;
                                stock.MaterialStatus = PDAtask.MaterialStatus;
                                stock.first_tb = 0;
                                stock.TB_Status = "";
                                stock.FQ_Status = "";
                                stock.GY_Status = "";
                                stock.QX_Status = "";
                                stock.created_user = "WCS";
                                stock.created_time = DateTime.Now;
                                stock.updated_user = "WCS";
                                stock.updated_time = DateTime.Now;
                                groupRepository.Add(stock, true);
                                //给MES回传物料移动信息
                                //MESAPIInvoke.BindMaterialDevid(PDAtask.Devid, route.route_end, PDAtask.MaterialType, PDAtask.BarCode, PDAtask.MaterialStatus);
                                break;
                            }
                        }
                    }
                  
                }

                catch (Exception ex)
                {

                }
                finally
                {
                    Interlocked.Exchange(ref _readCBJSignalso, 0);
                }
                //responseContent = SendTask(client.PLCName, () =>
                //{
                //    //任务下发逻辑编写
                //    throw new Exception();
                //});
            }

            }
    }
}