using Confluent.Kafka;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using OfficeOpenXml.FormulaParsing.Excel.Operators;
using WIDESEA_Comm.LogInfo;
using WIDESEA_Comm.MES_Info;
using WIDESEA_Comm.MES_Info.Request;
using WIDESEA_Common;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.FreeDB;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Entity.ToAGV;
using WIDESEA_WMS.IRepositories;
using WIDESEA_WMS.Repositories;
using static WIDESEA_Comm.MES_Info.BasicSN;

namespace WIDESEA_WMS.Common.AGVTask
{
    public class HandleTask_Mes
    {
        static FreeDB FreeDB = new FreeDB();
        /// <summary>
        /// 向MES反馈出入库信息
        /// </summary>
        /// <param name="task"></param>
        /// <exception cref="Exception"></exception>
        public static void UploadMESInfo(dt_agvtask task)
        {
            object obj = new object();  //上传MES数据
            string ActionName = "";  //调用MES方法名
            string name = "";
            MES_Response requestMes = new MES_Response();
            try
            {
                List<detail> list = new List<detail>(); //车轮信息
                if (task == null)
                {
                    throw new Exception("无任务数据");
                }
                VOLContext context = new VOLContext();
                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(context);
                Idt_info_to_mesRepository mesRepository = new dt_info_to_mesRepository(context);
                if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Outbound.ToString() || task.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceCarry.ToString())
                {
                    if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Outbound.ToString())
                    {
                        foreach (var item in task.bindSN.Split(","))
                        {
                            var work = workinfoRepository.Find(x => x.SN == item && x.processCode == task.agv_worktype.ToString()).FirstOrDefault();
                            detail detail = new detail();
                            detail.sn = item;
                            detail.jobID = work.jobID;
                            detail.processCode = work.processCode;
                            list.Add(detail);
                        }
                    }
                    else
                    {
                        foreach (var item in task.bindSN.Split(","))
                        {
                            detail detail = new detail();
                            detail.sn = item;
                            detail.jobID = task.jobID;
                            detail.processCode = task.agv_worktype.ToString();
                            list.Add(detail);
                        }
                    }

                    agvInWarehousePara outWarehousePara = new agvInWarehousePara()
                    {
                        WorkOrder = task.jobID,
                        zoneID = task.agv_fromaddress,
                        details = list,
                        layerNo = 1,
                        stackID = "1",
                        warehouseName = "Agv库",
                        Operator = "AGV自动",
                    };
                    obj = outWarehousePara;
                    ActionName = "agvOutWarehouse";//AGV->MES车轮出库
                    name = "AGV同步MES车轮出库";
                }
                else if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Inbound.ToString())
                {
                    foreach (var item in task.bindSN.Split(","))
                    {
                        var work = workinfoRepository.Find(x => x.SN == item && x.processCode == task.agv_worktype.ToString()).FirstOrDefault();
                        detail detail = new detail();
                        detail.sn = item;
                        detail.jobID = work.jobID;
                        detail.processCode = work.processCode;
                        list.Add(detail);
                    }
                    agvInWarehousePara inWarehousePara = new agvInWarehousePara()
                    {
                        WorkOrder = task.jobID,
                        zoneID = task.agv_toaddress,
                        details = list,
                        layerNo = 1,
                        stackID = "1",
                        warehouseName = "Agv库",
                        Operator = "AGV自动",
                    };
                    obj = inWarehousePara;
                    ActionName = "agvInWarehouse";//AGV->MES车轮入库
                    name = "AGV同步MES车轮入库";
                }
                else if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Carry.ToString())  //移库区分  库内移库
                {
                    List<detail1> list1 = new List<detail1>(); //车轮信息
                    foreach (var item in task.bindSN.Split(","))
                    {
                        detail1 detail = new detail1();
                        detail.sn = item;
                        list1.Add(detail);
                    }
                    agvMoveWarehousePara moveWarehousePara = new agvMoveWarehousePara()
                    {
                        fromZoneID = task.agv_fromaddress,
                        toZoneID = task.agv_toaddress,
                        details = list1,
                        fromLayerNo = "1",
                        fromStackID = "1",
                        fromWarehouseName = "Agv库",
                        toLayerNo = "1",
                        toStackID = "1",
                        toWarehouseName = "Agv库",
                        Operator = "AGV自动",
                    };
                    obj = moveWarehousePara;
                    ActionName = "agvMoveWarehouse";//AGV->MES车轮移库
                    name = "AGV同步MES车轮AB库移库";
                }
                var postJson = JsonConvert.SerializeObject(obj);
                if (!string.IsNullOrEmpty(ActionName))
                {
                    dt_info_to_mes info_To_Mes = new dt_info_to_mes()
                    {
                        Info = postJson,
                        ActionName = ActionName,
                        Createtime = DateTime.Now,
                        Remark = name,
                        State = false
                    };
                    mesRepository.Add(info_To_Mes, true);
                }
            }
            catch (Exception ex)
            {

            }
        }
    }
}