using Amqp.Framing;
using CFX;
using CFX.Structures.PressInsertion;
using HslCommunication;
using Sln.Iot.CFX.CFXConnect;
using Sln.Iot.CFX.Event;
using Sln.Iot.Common;
using Sln.Iot.PLC;
using Sln.Iot.Repository;
using Sln.Iot.Repository.dao;
using Sln.Iot.Repository.service;
using Sln.Iot.Serilog;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;
using TouchSocket.Core;
using static System.Runtime.CompilerServices.RuntimeHelpers;

namespace Sln.Iot.Business
{
    public class RFID01Business
    {
        private Timer _timer;

        private readonly PLCConnect _plc = PLCConnect.Instance;

        private readonly SerilogHelper _log = SerilogHelper.Instance;

        private UnitsArrivedEvent unitsArrivedEvent = new UnitsArrivedEvent();
        private WorkStartedEvent workStartedEvent = new WorkStartedEvent();
        private WorkStageStartedEvent workStageStartedEvent = new WorkStageStartedEvent();
        private WorkCompletedEvent workCompletedEvent = new WorkCompletedEvent();
        private UnitsDepartedEvent unitsDepartedEvent = new UnitsDepartedEvent();

        private TrayBindingService trayBindingService = TrayBindingService.Instance;
        private CFXConnect1 connect1 = CFXConnect1.Instance;
        private CFXConnect2 connect2 = CFXConnect2.Instance;
        private CFXConnect3 connect3 = CFXConnect3.Instance;

        public RFID01Business()
        {
            _timer = new Timer(TimerCallback, null, 0, 2000);
        }

        /// <summary>
        /// RFID01上料提升机数据处理流程业务刷新
        /// </summary>
        /// <param name="state"></param>
        public void TimerCallback(object? state)
        {
            try
            {
                // 定时任务逻辑
                //读取信号
                OperateResult<short> signalRes = _plc.ReadInt16(_plc.DeltaInstance3, "D500");
                //成功验证
                if (signalRes.IsSuccess)
                {
                    short signalValue = signalRes.Content;
                    //如果有读取信号
                    if (signalValue == 1001)
                    {
                        //读取托盘码和产品码
                        OperateResult<byte[]> trayBytesResult = _plc.ReadBytes(_plc.DeltaInstance3, "D5000", 10);
                        OperateResult<byte[]> pordBytesResult1 = _plc.ReadBytes(_plc.DeltaInstance3, "D8000", 90);
                        OperateResult<byte[]> pordBytesResult2 = _plc.ReadBytes(_plc.DeltaInstance3, "D8090", 90);
                        //成功验证
                        if (trayBytesResult.IsSuccess && pordBytesResult1.IsSuccess && pordBytesResult2.IsSuccess)
                        {

                            //转换托盘码
                            string traycode = Encoding.ASCII.GetString(trayBytesResult.Content);
                            traycode = traycode.Replace("?", "");
                            traycode = traycode.Replace("\0", "");
                            _log.Info($"托盘到达-RFID01-托盘号-[{traycode}]");
                            byte[] prodBytes = pordBytesResult1.Content.Concat(pordBytesResult2.Content).ToArray();
                            string[] prodcode = new string[6];
                            //分割转换产品码
                            for (int i = 0; i < 6; i++)
                            {
                                prodcode[i] = Encoding.ASCII.GetString(prodBytes[(i * 60)..(i * 60 + 60)]);
                                prodcode[i] = prodcode[i].Replace("\0", "");
                                if (!string.IsNullOrEmpty(prodcode[i]))
                                {
                                    // 将相邻偶数位和奇数位字符对调
                                    char[] chars = prodcode[i].ToCharArray();
                                    for (int j = 0; j < chars.Length - 1; j += 2)
                                    {
                                        // 交换相邻的两个字符
                                        char temp = chars[j];
                                        chars[j] = chars[j + 1];
                                        chars[j + 1] = temp;
                                    }
                                    prodcode[i] = new string(chars);
                                    GlobalVar.Connect2Entity.InputQuantity++;
                                    GlobalVar.Connect2Entity.PassQuantity++;
                                    GlobalVar.Connect3Entity.InputQuantity++;
                                    GlobalVar.Connect1Entity.InputQuantity++;
                                    GlobalVar.Connect1Entity.PassQuantity++;
                                    GlobalVar.Connect3Entity.PassQuantity++;
                                    GlobalVar.Connect4Entity.InputQuantity++;
                                    GlobalVar.Connect4Entity.PassQuantity++;
                                    _log.Info($"{prodcode[i]}进入产线");
                                }
                            }


                            //connect1.SendValidateUnitsRequest("", traycode, prodcode);

                            //生成work唯一guid(tid)
                            Guid tid = Guid.NewGuid();
                            //sql更新
                            bool res = trayBindingService.TrayBindingRefresh(tid, traycode, prodcode);
                            if (!res)
                            {
                                _log.Error("上料提升机数据库写入异常");
                            }

                            //写入完成信号
                            res = _plc.PlcWrite(_plc.DeltaInstance3, "D500", 1002, DataTypeEnum.UInt16).IsSuccess;
                            if (!res)
                            {
                                _log.Error("上料提升机PLC写入完成信号异常");
                            }

                            //CFX
                            Task.Run(() =>
                            {

                                //单元抵达事件
                                connect1.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle(traycode, prodcode)));
                                connect2.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle(traycode, prodcode)));
                                connect3.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle(traycode, prodcode)));
                                _log.Info($"{traycode} 抵达设备");
                                //工作开始事件
                                connect1.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(tid, traycode, prodcode)));
                                connect2.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(tid, traycode, prodcode)));
                                connect3.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(tid, traycode, prodcode)));
                                _log.Info($"工作开始，ID:{tid}");
                                connect2.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(tid, traycode, prodcode)));
                                connect2.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(traycode, prodcode)));

                                //预热炉工段开启
                                connect3.PublishEvent(new CFXEnvelope(workStageStartedEvent.Handle(tid, "PreHeatOven", 1)));
                                _log.Info($"预热炉工段开始 ID:{tid}");
                            });
                        }
                        else
                        {
                            _log.Error($"PLC读取失败，原因1：{trayBytesResult.Message} 2：{pordBytesResult1.Message} 3：{pordBytesResult2.Message}");
                        }
                        //流程完成
                    }
                }
                else
                {
                    _log.Error($"上料提升机PLC读取信号异常,原因：{signalRes.Message}");
                }
            }
            catch (Exception ex)
            {
                _log.Error("RFID01业务出现异常", ex);
            }
        }
    }
}