Shihong-Delta.Injection.Iot/Sln.Iot.Business/RecipeBusiness.cs

using CFX;
using CFX.Structures.UVCuring;
using Sln.Iot.CFX.CFXConnect;
using Sln.Iot.CFX.Event;
using Sln.Iot.PLC;
using Sln.Iot.Serilog;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Sln.Iot.Business
{
    /// <summary>
    /// 配方支持类
    /// </summary>
    public class RecipeBusiness
    {
        private Timer _timer;

        private readonly PLCConnect _plc = PLCConnect.Instance;
        private readonly SerilogHelper _log = SerilogHelper.Instance;

        private readonly RecipeActivatedEvent recipeActivatedEvent = new RecipeActivatedEvent();
        private readonly RecipeModifiedEvent recipeModifiedEvent = new RecipeModifiedEvent();

        private readonly CFXConnect1 connect1 = CFXConnect1.Instance;

        public RecipeBusiness()
        {
            _timer = new Timer(TimerCallback, null, 0, 1500);
        }

        /// <summary>
        /// 检测配方变化
        /// </summary>
        /// <param name="state"></param>
        public void TimerCallback(object? state)
        {
            string recipeName1 = "recipeName";
            string recipeName2 = "recipeName";
            try
            {
                var Result1 = _plc.ReadInt16(_plc.DeltaInstance1, "D6");
                var Result2 = _plc.ReadInt16(_plc.DeltaInstance2, "D6");

                //_log.Info($"真空箱1配方标识{Result1.Content}");
                //_log.Info($"真空箱2配方标识{Result2.Content}");
                //_log.Info($"————————————————————");

                if (Result1.Content != 0 || Result2.Content != 0)
                {
                    //获取现在激活的配方
                    var res1 = _plc.ReadBytes(_plc.DeltaInstance1, "D600", 10);
                    var res2 = _plc.ReadBytes(_plc.DeltaInstance2, "D600", 10);
                    if (res1.IsSuccess)
                    {
                        recipeName1 = Encoding.ASCII.GetString(ToolBusiness.SwapAdjacentBytes(res1.Content));
                    }
                    if (res2.IsSuccess)
                    {
                        recipeName2 = Encoding.ASCII.GetString(ToolBusiness.SwapAdjacentBytes(res2.Content));
                    }
                }

                if (Result1.IsSuccess)
                {
                    if (Result1.Content == 2)
                    {
                        //发布消息
                        connect1.PublishEvent(new CFXEnvelope(recipeModifiedEvent.Handle(recipeName1)));
                        _plc.PlcWrite(_plc.DeltaInstance1, "D6", 0, DataTypeEnum.Int16);
                        _log.Info($"真空箱1配方修改{recipeName1}");
                    }
                    else if (Result1.Content == 4)
                    {
                        //发布消息
                        connect1.PublishEvent(new CFXEnvelope(recipeActivatedEvent.Handle(recipeName1, "VacuumInjection1", 1)));
                        _plc.PlcWrite(_plc.DeltaInstance1, "D6", 0, DataTypeEnum.Int16);
                        _log.Info($"真空箱1配方激活{recipeName1}");
                    }
                }

                if (Result2.IsSuccess)
                {
                    if (Result2.Content == 2)
                    {
                        //发布消息
                        connect1.PublishEvent(new CFXEnvelope(recipeModifiedEvent.Handle(recipeName2)));
                        _plc.PlcWrite(_plc.DeltaInstance2, "D6", 0, DataTypeEnum.Int16);
                        _log.Info($"真空箱2配方修改{recipeName2}");
                    }
                    else if (Result2.Content == 4)
                    {
                        //发布消息
                        connect1.PublishEvent(new CFXEnvelope(recipeActivatedEvent.Handle(recipeName2, "VacuumInjection2", 2)));
                        _plc.PlcWrite(_plc.DeltaInstance2, "D6", 0, DataTypeEnum.Int16);
                        _log.Info($"真空箱2配方激活{recipeName2}");
                    }
                }
            }
            catch (Exception ex)
            {
                _log.Error($"RecipeBusiness定时任务异常：{ex.Message}");
            }
            
            
        }
    }
}