serein-flow/Net461DllTest/LogicControl/ParkingLogicControl.cs

using Net461DllTest.Device;
using Net461DllTest.Signal;
using Net461DllTest.ViewModel;
using Serein.Library.Api;
using Serein.Library.Attributes;
using Serein.Library.Enums;
using Serein.Library.Ex;
using Serein.Library.Framework.NodeFlow;
using Serein.Library.NodeFlow.Tool;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Net461DllTest.LogicControl
{

    public enum ParkingCommand
    {
        GetPparkingSpace,
    }


    [DynamicFlow]
    public class ParkingLogicControl
    {
        [AutoInjection]
        public PrakingDevice PrakingDevice { get; set; }


        [NodeAction(NodeType.Init)]
        public void Init(IDynamicContext context)
        {
            
            context.Env.IOC.Register<PrakingDevice>();
        }



        [NodeAction(NodeType.Flipflop, "等待车位调取命令",ReturnType=typeof(string))]
        public async Task<IFlipflopContext> GetPparkingSpace(ParkingCommand parkingCommand = ParkingCommand.GetPparkingSpace)
        {
            try
            {
                TriggerData triggerData = await PrakingDevice.CreateChannelWithTimeoutAsync(parkingCommand, TimeSpan.FromMinutes(5), 0);
                if (triggerData.Type == TriggerType.Overtime)
                {
                    throw new FlipflopException("超时取消");
                }
                if(triggerData.Value is string spaceNum)
                {
                    await Console.Out.WriteLineAsync("收到命令：调取车位，车位号"+ spaceNum);
                    return new FlipflopContext(FlipflopStateType.Succeed, spaceNum);
                }
                else
                {
                    throw new FlipflopException("并非车位号");
                }
              
            }
            catch (FlipflopException)
            {
                throw;
            }
            catch (Exception)
            {
                return new FlipflopContext(FlipflopStateType.Error);
            }
        }


        [NodeAction(NodeType.Action, "手动触发模拟调取车位")]
        public void Storage(string spaceNum = "101")
        {
           if (PrakingDevice.TriggerSignal(ParkingCommand.GetPparkingSpace, spaceNum))
            {
                Console.WriteLine("发送命令成功：调取车位" + spaceNum);

            }
            else
            {
                Console.WriteLine("发送命令失败：调取车位" + spaceNum);

            }
        }



    }
}