using Newtonsoft.Json;
using Quartz;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Common.DBHelper;
using WIDESEA_Common.Tools;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Entity.DomainModels.Equipment;
using WIDESEA_WCS.Jobs;
using WIDESEA_WCS.JobsPart.Public;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS
{
    /// <summary>
    /// 提升机调度【西门子】
    /// </summary>
    [DisallowConcurrentExecution]
    public class StackerJob : JobBase, IJob
    {
        static List<AGVCenterEqDB> centerEqDBList;
        static FreeDB freeDB = new FreeDB();

        public StackerJob()
        {
            if (centerEqDBList == null || centerEqDBList.Count == 0)
            {

                string tsjJson = File.ReadAllText(AppContext.BaseDirectory + "/提升机.json", Encoding.UTF8);
                centerEqDBList = JsonConvert.DeserializeObject<List<AGVCenterEqDB>>(tsjJson);
            }
        }

        public Task Execute(IJobExecutionContext context)
        {
            //return null;//停用提升机调度
            try
            {
                ExecuteJob(context, DoAction);
            }
            catch { }
            return Task.FromResult(string.Empty);
        }


        private void DoAction(IJobExecutionContext context)
        {
            PLCClient client = context.JobDetail.JobDataMap.Get("JobParams") as PLCClient;
            if (client==null)
            {
                return;
            }
            var stationList = centerEqDBList.FirstOrDefault(t => t.tiShenJiName == client.PLCName);
            if (stationList != null)
            {
                foreach (var station in stationList.stationInfos)
                {
                    var clientData = (byte[])client.ReadDBValue(station.eqDBList[0], 100);
                    TransferData(station, client, clientData);

                    try
                    {
                        //入口无料
                        if (station.stationType == "in" && clientData[93] == 0x00)
                        {
                            //提升机入口无料不主动叫料
                            //WCSCommon.CreateTask(station, true);
                        }
                        //出口有料
                        else if (station.stationType == "out" && clientData[93] == 0x01)
                        {
                            //物料类型,传任务号
                            var taskNo = DataTrans.GetStr(clientData, 26) + "_T";
                            WriteLog.GetLog().Write($"【info】任务{taskNo}请求任务完成。" + "\n", client.PLCName);

                            if (!string.IsNullOrEmpty(taskNo))
                            {
                                FinshTiShenJiTask(taskNo);
                            }
                            WCSCommon.CreateTask(station, false);
                        }
                    }
                    catch (Exception ex)
                    {
                        WriteLog.GetLog().Write($"【提升机任务请求异常】{client.PLCName},{station.stationCode}口。{ex.Message}" + "\n", client.PLCName);
                    }
                }
            }
        }

        /// <summary>
        /// 完成提升机任务
        /// </summary>
        /// <param name="taskNo">提升机任务号</param>
        private void FinshTiShenJiTask(string taskNo)
        {
            var task = freeDB.Select<dt_agvtask>().Where(t => t.agv_tasknum == taskNo).ToOne();
            if (task != null)
            {
                freeDB.Add(new dt_agvtask_hty()
                {
                    hty_pkid = Guid.NewGuid(),
                    agv_id = Guid.Empty,
                    agv_tasknum = task.agv_tasknum,
                    agv_materielid = task.agv_materielid,
                    agv_qty = task.agv_qty,
                    agv_createtime = task.agv_createtime,
                    agv_realesstime = task.agv_realesstime,
                    agv_executingBeginTime = task.agv_executingBeginTime,
                    agv_executingEndTime = task.agv_executingEndTime,
                    agv_completeBeginTime = task.agv_completeBeginTime,
                    agv_finishedtime = DateTime.Now,
                    agv_taskstate = AGVTaskStateEnum.Complete1.ToString(),
                    agv_tasktype = task.agv_tasktype,
                    agv_fromaddress = task.agv_fromaddress,
                    agv_toaddress = task.agv_toaddress,
                    agv_operatetype = string.Empty,
                    agv_compeletor = "wcs",
                    agv_completedate = DateTime.Now,
                    agv_grade = task.agv_grade,
                    agv_userid = "wcs",
                    agv_barcode = task.agv_barcode,
                    agv_code = task.agv_code,
                    agv_worktype = task.agv_worktype
                });
                freeDB.Remove(task);
            }
        }

        /// <summary>
        /// 中转AGV对接数据
        /// </summary>
        /// <param name="station"></param>
        /// <param name="tsj_Client"></param>
        /// <param name="tsjData"></param>
        private void TransferData(StationInfo station, PLCClient tsj_Client, byte[] tsjData)
        {
            var agv_Client = WIDESEA_WCS.WCSService.Clients.FirstOrDefault(t => t.PLCName == station.agvCenterName);
            if (agv_Client != null)
            {
                var agvData = (byte[])agv_Client.ReadDBValue(station.agvDBList[0], 200);

                //90,流程步骤非0，开始对接
                if (agvData[90 + 1] != 0x0 && station.stationType == "in")
                {
                    //目的地址
                    agvData[96] = (byte)station.tiShenJiEndUniCode;
                    //托盘码
                    OperateDB.WriteData(agvData, 58, "null");
                }

                ////tsj_Client.WriteDBValue(station.eqDBList[1], agvData);
                /// agv_Client.WriteDBValue(station.agvDBList[1], tsjData);
            }
            else
            {
                WriteLog.GetLog().Write($"【异常】{station.agvCenterName}，读取调度中心PLC失败" + "\n", tsj_Client.PLCName);
            }
        }
    }
}