重构中day1，写了很多，不知道怎么说清楚

Workbench/Services/FlowEEForwardingService.cs

@@ -0,0 +1,344 @@
+
+using Newtonsoft.Json.Linq;
+using Serein.Library.Api;
+using Serein.NodeFlow;
+using System;
+using System.Collections.Generic;
+using System.Drawing;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Serein.Library;
+using Serein.Library.Utils;
+using Serein.Workbench.Avalonia.Api;
+using Serein.Workbench.Api;
+
+namespace Serein.Workbench.Services
+{
+
+
+
+    internal class FlowEEForwardingService : IFlowEEForwardingService
+    {
+        /// <summary>
+        /// 流程运行环境
+        /// </summary>
+        private readonly IFlowEnvironment flowEnvironment;
+        private readonly IFlowEnvironmentEvent flowEnvironmentEvent;
+
+        /// <summary>
+        /// 转发流程运行环境各个事件的实现类
+        /// </summary>
+        /// <param name="flowEnvironment"></param>
+        /// <param name="flowNodeControlService"></param>
+        public FlowEEForwardingService(IFlowEnvironment flowEnvironment,
+                                       IFlowEnvironmentEvent flowEnvironmentEvent)
+        {
+            this.flowEnvironment = flowEnvironment;
+            this.flowEnvironmentEvent = flowEnvironmentEvent;
+            InitFlowEnvironmentEvent();
+        }
+
+        #region 工作台事件转发
+        /// <summary>
+        /// 加载了依赖文件事件
+        /// </summary>
+        public event LoadDllHandler? OnDllLoad;
+        /// <summary>
+        /// 项目加载完成事件
+        /// </summary>
+        public event ProjectLoadedHandler? OnProjectLoaded;
+        /// <summary>
+        /// 项目保存中事件
+        /// </summary>
+        public event ProjectSavingHandler? OnProjectSaving;
+        /// <summary>
+        /// 节点连接改变事件
+        /// </summary>
+        public event NodeConnectChangeHandler? OnNodeConnectChange;
+        /// <summary>
+        /// 节点创建事件
+        /// </summary>
+        public event NodeCreateHandler? OnNodeCreate;
+        /// <summary>
+        /// 节点移除事件
+        /// </summary>
+        public event NodeRemoveHandler? OnNodeRemove;
+        /// <summary>
+        /// 节点放置容器事件
+        /// </summary>
+        public event NodePlaceHandler? OnNodePlace;
+        /// <summary>
+        /// 节点取出事件
+        /// </summary>
+        public event NodeTakeOutHandler? OnNodeTakeOut;
+        /// <summary>
+        /// 流程起始节点改变事件
+        /// </summary>
+        public event StartNodeChangeHandler? OnStartNodeChange;
+        /// <summary>
+        /// 流程运行完毕事件
+        /// </summary>
+        public event FlowRunCompleteHandler? OnFlowRunComplete;
+        /// <summary>
+        /// 被监视的对象数据改变事件
+        /// </summary>
+        public event MonitorObjectChangeHandler? OnMonitorObjectChange;
+        /// <summary>
+        /// 节点中断状态改变事件
+        /// </summary>
+        public event NodeInterruptStateChangeHandler? OnNodeInterruptStateChange;
+        /// <summary>
+        /// 表达式中断触发事件
+        /// </summary>
+        public event ExpInterruptTriggerHandler? OnInterruptTrigger;
+        /// <summary>
+        /// 容器对象改变事件
+        /// </summary>
+        public event IOCMembersChangedHandler? OnIOCMembersChanged;
+        /// <summary>
+        /// 节点定位事件
+        /// </summary>
+        public event NodeLocatedHandler? OnNodeLocated;
+        /// <summary>
+        /// 节点移动事件
+        /// </summary>
+        public event NodeMovedHandler? OnNodeMoved;
+        /// <summary>
+        /// 运行环境输出事件
+        /// </summary>
+        public event EnvOutHandler? OnEnvOut;
+
+        #endregion
+
+        #region 流程运行环境事件
+
+        private void InitFlowEnvironmentEvent()
+        {
+            flowEnvironmentEvent.OnDllLoad += FlowEnvironment_DllLoadEvent;
+            flowEnvironmentEvent.OnProjectSaving += EnvDecorator_OnProjectSaving;
+            flowEnvironmentEvent.OnProjectLoaded += FlowEnvironment_OnProjectLoaded;
+            flowEnvironmentEvent.OnStartNodeChange += FlowEnvironment_StartNodeChangeEvent;
+            flowEnvironmentEvent.OnNodeConnectChange += FlowEnvironment_NodeConnectChangeEvemt;
+            flowEnvironmentEvent.OnNodeCreate += FlowEnvironment_NodeCreateEvent;
+            flowEnvironmentEvent.OnNodeRemove += FlowEnvironment_NodeRemoveEvent;
+            flowEnvironmentEvent.OnNodePlace += EnvDecorator_OnNodePlaceEvent;
+            flowEnvironmentEvent.OnNodeTakeOut += EnvDecorator_OnNodeTakeOutEvent;
+            flowEnvironmentEvent.OnFlowRunComplete += FlowEnvironment_OnFlowRunCompleteEvent;
+            
+            flowEnvironmentEvent.OnMonitorObjectChange += FlowEnvironment_OnMonitorObjectChangeEvent;
+            flowEnvironmentEvent.OnNodeInterruptStateChange += FlowEnvironment_OnNodeInterruptStateChangeEvent;
+            flowEnvironmentEvent.OnInterruptTrigger += FlowEnvironment_OnInterruptTriggerEvent;
+            
+            flowEnvironmentEvent.OnIOCMembersChanged += FlowEnvironment_OnIOCMembersChangedEvent;
+            
+            flowEnvironmentEvent.OnNodeLocated += FlowEnvironment_OnNodeLocateEvent;
+            flowEnvironmentEvent.OnNodeMoved += FlowEnvironment_OnNodeMovedEvent;
+            
+            flowEnvironmentEvent.OnEnvOut += FlowEnvironment_OnEnvOutEvent;
+        }
+
+        private void ResetFlowEnvironmentEvent()
+        {
+           flowEnvironmentEvent.OnDllLoad -= FlowEnvironment_DllLoadEvent;
+           flowEnvironmentEvent.OnProjectSaving -= EnvDecorator_OnProjectSaving;
+           flowEnvironmentEvent.OnProjectLoaded -= FlowEnvironment_OnProjectLoaded;
+           flowEnvironmentEvent.OnStartNodeChange -= FlowEnvironment_StartNodeChangeEvent;
+           flowEnvironmentEvent.OnNodeConnectChange -= FlowEnvironment_NodeConnectChangeEvemt;
+           flowEnvironmentEvent.OnNodeCreate -= FlowEnvironment_NodeCreateEvent;
+           flowEnvironmentEvent.OnNodeRemove -= FlowEnvironment_NodeRemoveEvent;
+           flowEnvironmentEvent.OnNodePlace -= EnvDecorator_OnNodePlaceEvent;
+           flowEnvironmentEvent.OnNodeTakeOut -= EnvDecorator_OnNodeTakeOutEvent;
+            flowEnvironmentEvent.OnFlowRunComplete -= FlowEnvironment_OnFlowRunCompleteEvent;
+
+
+           flowEnvironmentEvent.OnMonitorObjectChange -= FlowEnvironment_OnMonitorObjectChangeEvent;
+           flowEnvironmentEvent.OnNodeInterruptStateChange -= FlowEnvironment_OnNodeInterruptStateChangeEvent;
+            flowEnvironmentEvent.OnInterruptTrigger -= FlowEnvironment_OnInterruptTriggerEvent;
+
+            flowEnvironmentEvent.OnIOCMembersChanged -= FlowEnvironment_OnIOCMembersChangedEvent;
+            flowEnvironmentEvent.OnNodeLocated -= FlowEnvironment_OnNodeLocateEvent;
+            flowEnvironmentEvent.OnNodeMoved -= FlowEnvironment_OnNodeMovedEvent;
+
+            flowEnvironmentEvent.OnEnvOut -= FlowEnvironment_OnEnvOutEvent;
+
+        }
+
+        #region 运行环境事件
+
+        /// <summary>
+        /// 环境内容输出
+        /// </summary>
+        /// <param name="type"></param>
+        /// <param name="value"></param>
+        private void FlowEnvironment_OnEnvOutEvent(InfoType type, string value)
+        {
+            //LogOutWindow.AppendText($"{DateTime.Now} [{type}] : {value}{Environment.NewLine}");
+        }
+
+        /// <summary>
+        /// 需要保存项目
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void EnvDecorator_OnProjectSaving(ProjectSavingEventArgs eventArgs)
+        {
+            OnProjectSaving?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 加载完成
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FlowEnvironment_OnProjectLoaded(ProjectLoadedEventArgs eventArgs)
+        {
+            OnProjectLoaded?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 运行完成
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void FlowEnvironment_OnFlowRunCompleteEvent(FlowEventArgs eventArgs)
+        {
+            SereinEnv.WriteLine(InfoType.INFO, "-------运行完成---------\r\n");
+            OnFlowRunComplete?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 加载了DLL文件，dll内容
+        /// </summary>
+        private void FlowEnvironment_DllLoadEvent(LoadDllEventArgs eventArgs)
+        {
+            OnDllLoad?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 节点连接关系变更
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FlowEnvironment_NodeConnectChangeEvemt(NodeConnectChangeEventArgs eventArgs)
+        {
+            OnNodeConnectChange?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 节点移除事件
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FlowEnvironment_NodeRemoveEvent(NodeRemoveEventArgs eventArgs)
+        {
+            OnNodeRemove?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 添加节点事件
+        /// </summary>
+        /// <param name="eventArgs">添加节点事件参数</param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void FlowEnvironment_NodeCreateEvent(NodeCreateEventArgs eventArgs)
+        {
+            OnNodeCreate?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 放置一个节点
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void EnvDecorator_OnNodePlaceEvent(NodePlaceEventArgs eventArgs)
+        {
+            OnNodePlace?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 取出一个节点
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void EnvDecorator_OnNodeTakeOutEvent(NodeTakeOutEventArgs eventArgs)
+        {
+            OnNodeTakeOut?.Invoke(eventArgs);
+
+        }
+
+        /// <summary>
+        /// 设置了流程起始控件
+        /// </summary>
+        /// <param name="oldNodeGuid"></param>
+        /// <param name="newNodeGuid"></param>
+        private void FlowEnvironment_StartNodeChangeEvent(StartNodeChangeEventArgs eventArgs)
+        {
+
+            OnStartNodeChange?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 被监视的对象发生改变
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FlowEnvironment_OnMonitorObjectChangeEvent(MonitorObjectEventArgs eventArgs)
+        {
+            OnMonitorObjectChange?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 节点中断状态改变。
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FlowEnvironment_OnNodeInterruptStateChangeEvent(NodeInterruptStateChangeEventArgs eventArgs)
+        {
+            OnNodeInterruptStateChange?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// 节点触发了中断
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void FlowEnvironment_OnInterruptTriggerEvent(InterruptTriggerEventArgs eventArgs)
+        {
+            OnInterruptTrigger?.Invoke(eventArgs);
+        }
+
+        /// <summary>
+        /// IOC变更
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void FlowEnvironment_OnIOCMembersChangedEvent(IOCMembersChangedEventArgs eventArgs)
+        {
+            OnIOCMembersChanged?.Invoke(eventArgs);
+
+        }
+
+        /// <summary>
+        /// 节点需要定位
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void FlowEnvironment_OnNodeLocateEvent(NodeLocatedEventArgs eventArgs)
+        {
+            OnNodeLocated?.Invoke(eventArgs);
+        }
+
+       
+        /// <summary>
+        /// 节点移动
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FlowEnvironment_OnNodeMovedEvent(NodeMovedEventArgs eventArgs)
+        {
+            OnNodeMoved?.Invoke(eventArgs);
+        }
+
+
+        #endregion
+
+
+        #endregion
+
+
+    }
+}

Workbench/Services/KeyEventService.cs

@@ -0,0 +1,80 @@
+/*
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Serein.Workbench.Services
+{
+    delegate void KeyDownEventHandler(Key key);
+    delegate void KeyUpEventHandler(Key key);
+
+    /// <summary>
+    /// 全局事件服务
+    /// </summary>
+    internal interface IKeyEventService
+    {
+        event KeyDownEventHandler KeyDown;
+        event KeyUpEventHandler KeyUp;
+
+        /// <summary>
+        /// 获取某个按键状态
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        bool GetKeyState(Key key);
+        /// <summary>
+        /// 设置某个按键的状态
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="state"></param>
+        void SetKeyState(Key key, bool statestate);
+    }
+
+    /// <summary>
+    /// 管理按键状态
+    /// </summary>
+    internal class KeyEventService : IKeyEventService
+    {
+
+        /// <summary>
+        /// 按键按下
+        /// </summary>
+        public event KeyDownEventHandler KeyDown;
+        /// <summary>
+        /// 按键松开
+        /// </summary>
+        public event KeyUpEventHandler KeyUp;
+
+        public KeyEventService()
+        {
+            var arr = Enum.GetValues<Key>();
+            KeysState = new bool[arr.Length];
+
+            // 绑定快捷键
+            //HotKeyManager.SetHotKey(saveMenuItem, new KeyGesture(Key.S, KeyModifiers.Control));
+        }
+
+        private readonly bool[] KeysState;
+        public bool GetKeyState(Key key)
+        {
+            return KeysState[(int)key];
+        }
+        public void SetKeyState(Key key, bool state)
+        {
+            if (state)
+            {
+                KeyDown?.Invoke(key);
+            }
+            else
+            {
+                KeyUp?.Invoke(key);
+            }
+            //Debug.WriteLine($"按键事件：{key} - {state}");
+            KeysState[(int)key] = state;
+        }
+    }
+}
+*/

Workbench/Services/NodeOperationService.cs

@@ -0,0 +1,406 @@
+
+using Newtonsoft.Json;
+using Serein.Library;
+using Serein.Library.Api;
+using Serein.Library.Utils;
+using Serein.NodeFlow;
+using Serein.NodeFlow.Env;
+using Serein.Workbench.Api;
+using Serein.Workbench.Avalonia.Api;
+using Serein.Workbench.Node;
+using Serein.Workbench.Node.View;
+using Serein.Workbench.Node.ViewModel;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
+using System.Windows.Controls;
+
+
+
+
+
+namespace Serein.Workbench.Api
+{
+
+    /// <summary>
+    /// 提供节点操作的接口
+    /// </summary>
+    internal interface INodeOperationService
+    {
+        /// <summary>
+        /// 连接数据
+        /// </summary>
+        // ConnectingManage ConnectingManage { get; }
+
+        /// <summary>
+        /// 主画布
+        /// </summary>
+        Canvas MainCanvas { get; set; }
+
+        /// <summary>
+        /// 节点创建事件
+        /// </summary>
+
+        event NodeViewCreateHandle OnNodeViewCreate;
+
+        /// <summary>
+        /// 创建节点控件
+        /// </summary>
+        /// <param name="nodeType">控件类型</param>
+        /// <param name="position">创建坐标</param>
+        /// <param name="methodDetailsInfo">节点方法信息</param>
+        public void CreateNodeView(MethodDetailsInfo methodDetailsInfo, PositionOfUI position);
+
+        /// <summary>
+        /// 尝试从连接控制点创建连接
+        /// </summary>
+        /// <param name="startJunction"></param>
+        //void TryCreateConnectionOnJunction(NodeJunctionView startJunction);
+
+    }
+
+
+
+
+    #region 事件与事件参数
+    /// <summary>
+    /// 创建节点控件事件
+    /// </summary>
+    /// <param name="eventArgs"></param>
+
+    internal delegate bool NodeViewCreateHandle(NodeViewCreateEventArgs eventArgs);
+
+    /// <summary>
+    /// 创建节点控件事件参数
+    /// </summary>
+
+
+
+    internal class NodeViewCreateEventArgs : EventArgs
+    {
+        internal NodeViewCreateEventArgs(NodeControlBase nodeControl, PositionOfUI position)
+        {
+            this.NodeControl = nodeControl;
+            this.Position = position;
+        }
+        public NodeControlBase NodeControl { get; private set; }
+        public PositionOfUI Position { get; private set; }
+    }
+
+
+    #endregion
+
+
+
+
+
+}
+
+namespace Serein.Workbench.Services
+{
+    /// <summary>
+    /// 节点操作相关服务
+    /// </summary>
+    internal class NodeOperationService : INodeOperationService
+    {
+
+        public NodeOperationService(IFlowEnvironment flowEnvironment,
+                                    IFlowEEForwardingService feefService)
+        {
+            this.flowEnvironment = flowEnvironment;
+            this.feefService = feefService;
+            feefService.OnNodeCreate += FeefService_OnNodeCreate; // 订阅运行环境创建节点事件
+            feefService.OnNodeConnectChange += FeefService_OnNodeConnectChange; // 订阅运行环境连接了节点事件
+            // 手动加载项目
+            _ = Task.Run(async delegate
+            {
+                await Task.Delay(1000);
+                var flowEnvironment = new FlowEnvironment();// App.GetService<IFlowEnvironment>();
+                var filePath = @"C:\Users\Az\source\repos\CLBanyunqiState\CLBanyunqiState\bin\debug\net8.0\project.dnf";
+                string content = System.IO.File.ReadAllText(filePath); // 读取整个文件内容
+                var projectData = JsonConvert.DeserializeObject<SereinProjectData>(content);
+                var projectDfilePath = System.IO.Path.GetDirectoryName(filePath)!;
+                flowEnvironment.LoadProject(new FlowEnvInfo { Project = projectData }, projectDfilePath);
+            }, CancellationToken.None);
+        }
+
+
+        #region 接口属性
+        //public ConnectingManage ConnectingManage { get; private set; } = new ConnectingManage();
+        public Canvas MainCanvas { get; set; }
+
+        #endregion
+
+        #region 私有变量
+
+        /// <summary>
+        /// 存储所有与节点有关的控件
+        /// </summary>
+        private Dictionary<string, NodeControlBase> NodeControls { get; } = [];
+
+        /// <summary>
+        /// 存储所有连接
+        /// </summary>
+        //private List<NodeConnectionLineControl> Connections { get; } = [];
+
+
+
+        /// <summary>
+        /// 流程运行环境
+        /// </summary>
+        private readonly IFlowEnvironment flowEnvironment;
+
+        /// <summary>
+        /// 流程运行环境事件转发
+        /// </summary>
+        private readonly IFlowEEForwardingService feefService;
+        #endregion
+
+        #region 节点操作事件
+
+        /// <summary>
+        /// 创建了节点控件
+        /// </summary>
+        public event NodeViewCreateHandle OnNodeViewCreate;
+
+        #endregion
+
+        #region 转发事件的处理
+
+        /// <summary>
+        /// 从工作台事件转发器监听节点创建事件
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        private void FeefService_OnNodeCreate(NodeCreateEventArgs eventArgs)
+        {
+            var nodeModel = eventArgs.NodeModel;
+            if (NodeControls.ContainsKey(nodeModel.Guid))
+            {
+                SereinEnv.WriteLine(InfoType.WARN, $"OnNodeCreate 事件意外触发，节点Guid重复 - {nodeModel.Guid}");
+                return;
+            }
+            if (!flowEnvironment.NodeMVVMManagement.TryGetType(nodeModel.ControlType, out var nodeMVVM))
+            {
+                SereinEnv.WriteLine(InfoType.INFO, $"无法创建{nodeModel.ControlType}节点，节点类型尚未注册。");
+                return;
+            }
+            if (nodeMVVM.ControlType == null
+                || nodeMVVM.ViewModelType == null)
+            {
+                SereinEnv.WriteLine(InfoType.INFO, $"无法创建{nodeModel.ControlType}节点，UI类型尚未注册（请通过 NodeMVVMManagement.RegisterUI() 方法进行注册）。");
+                return;
+            }
+
+            var isSuccessful = TryCreateNodeView(nodeMVVM.ControlType, // 控件UI类型
+                                                nodeMVVM.ViewModelType, // 控件VIewModel类型
+                                                nodeModel, // 控件数据实体
+                                                out var nodeControl); // 成功创建后传出的节点控件实体
+            if (!isSuccessful || nodeControl is null)
+            {
+                SereinEnv.WriteLine(InfoType.INFO, $"无法创建{nodeModel.ControlType}节点，节点创建失败。");
+                return;
+            }
+
+
+            var e = new NodeViewCreateEventArgs(nodeControl, eventArgs.Position);
+            if (OnNodeViewCreate?.Invoke(e) == true)
+            {
+                // 成功创建
+                NodeControls.TryAdd(nodeModel.Guid, nodeControl); // 缓存起来，通知其它地方拿取这个控件
+            }
+
+        }
+
+
+        /// <summary>
+        /// 运行环境连接了节点事件
+        /// </summary>
+        /// <param name="eventArgs"></param>
+        /// <exception cref="NotImplementedException"></exception>
+        private void FeefService_OnNodeConnectChange(NodeConnectChangeEventArgs eventArgs)
+        {
+            string fromNodeGuid = eventArgs.FromNodeGuid;
+            string toNodeGuid = eventArgs.ToNodeGuid;
+            if (!TryGetControl(fromNodeGuid, out var fromNodeControl)
+               || !TryGetControl(toNodeGuid, out var toNodeControl))
+            {
+                return;
+            }
+
+
+            if (eventArgs.JunctionOfConnectionType == JunctionOfConnectionType.Invoke)
+            {
+                ConnectionInvokeType connectionType = eventArgs.ConnectionInvokeType;
+                #region 创建/删除节点之间的调用关系
+                #region 创建连接
+                if (eventArgs.ChangeType == NodeConnectChangeEventArgs.ConnectChangeType.Create) // 添加连接
+                {
+                    if (fromNodeControl is not INodeJunction IFormJunction || toNodeControl is not INodeJunction IToJunction)
+                    {
+                        SereinEnv.WriteLine(InfoType.INFO, "非预期的连接");
+                        return;
+                    }
+                    var startJunction = IFormJunction.NextStepJunction;
+                    var endJunction = IToJunction.ExecuteJunction;
+
+                    // NodeConnectionLineControl nodeConnectionLineControl = new NodeConnectionLineControl(MainCanvas, startJunction, endJunction);
+
+                    //startJunction.TransformToVisual(MainCanvas);
+
+                    //// 添加连接
+                    //var shape = new ConnectionLineShape(
+                    //    FlowChartCanvas,
+                    //    connectionType,
+                    //    startJunction,
+                    //    endJunction
+                    //);
+
+
+                    //NodeConnectionLine nodeConnectionLine = new NodeConnectionLine(MainCanvas, shape);
+
+                    //if (toNodeControl is FlipflopNodeControl flipflopControl
+                    //    && flipflopControl?.ViewModel?.NodeModel is NodeModelBase nodeModel) // 某个节点连接到了触发器，尝试从全局触发器视图中移除该触发器
+                    //{
+                    //    NodeTreeViewer.RemoveGlobalFlipFlop(nodeModel); // 从全局触发器树树视图中移除
+                    //}
+
+                    //Connections.Add(nodeConnectionLineControl);
+                    //fromNodeControl.AddConnection(nodeConnectionLineControl);
+                    //toNodeControl.AddConnection(nodeConnectionLineControl);
+                }
+                #endregion
+
+
+                #region 移除连接
+               /* else if (eventArgs.ChangeType == NodeConnectChangeEventArgs.ConnectChangeType.Remove) // 移除连接
+                {
+                    // 需要移除连接
+                    var removeConnections = Connections.Where(c =>
+                                               c.Start.MyNode.Guid.Equals(fromNodeGuid)
+                                            && c.End.MyNode.Guid.Equals(toNodeGuid)
+                                            && (c.Start.JunctionType.ToConnectyionType() == JunctionOfConnectionType.Invoke
+                                            || c.End.JunctionType.ToConnectyionType() == JunctionOfConnectionType.Invoke))
+                                            .ToList();
+
+
+                    foreach (var connection in removeConnections)
+                    {
+                        Connections.Remove(connection);
+                        fromNodeControl.RemoveConnection(connection); // 移除连接
+                        toNodeControl.RemoveConnection(connection); // 移除连接
+                        if (NodeControls.TryGetValue(connection.End.MyNode.Guid, out var control))
+                        {
+                            JudgmentFlipFlopNode(control); // 连接关系变更时判断
+                        }
+                    }
+                }*/
+                #endregion
+
+
+                #endregion
+            }
+
+        }
+        #endregion
+
+        #region 私有方法
+
+        /// <summary>
+        /// 创建节点控件
+        /// </summary>
+        /// <param name="viewType">节点控件视图控件类型</param>
+        /// <param name="viewModelType">节点控件ViewModel类型</param>
+        /// <param name="nodeModel">节点Model实例</param>
+        /// <param name="nodeView">返回的节点对象</param>
+        /// <returns>是否创建成功</returns>
+        /// <exception cref="Exception">无法创建节点控件</exception>
+        private bool TryCreateNodeView(Type viewType, Type viewModelType, NodeModelBase nodeModel, out NodeControlBase? nodeView)
+        {
+            if (string.IsNullOrEmpty(nodeModel.Guid))
+            {
+                nodeModel.Guid = Guid.NewGuid().ToString();
+            }
+            var t_ViewModel = Activator.CreateInstance(viewModelType, nodeModel);
+            if (t_ViewModel is not NodeControlViewModelBase viewModelBase)
+            {
+                nodeView = null;
+                return false;
+            }
+            var controlObj = Activator.CreateInstance(viewType);
+            if (controlObj is NodeControlBase nodeControl)
+            {
+                nodeControl.DataContext = viewModelBase;
+                nodeView = nodeControl;
+                return true;
+            }
+            else
+            {
+                nodeView = null;
+                return false;
+            }
+
+            // 在其它地方验证过了，所以注释
+            //if ((viewType is null)
+            //    || viewModelType is null
+            //    || nodeModel is null)
+            //{
+            //    nodeView = null;
+            //    return false;
+            //}
+            //if (typeof(INodeControl).IsSubclassOf(viewType) 
+            // || typeof(NodeViewModelBase).IsSubclassOf(viewModelType))
+            //{
+            //    nodeView = null;
+            //    return false;
+            //}
+        }
+
+        private bool TryGetControl(string nodeGuid, out NodeControlBase nodeControl)
+        {
+            if (string.IsNullOrEmpty(nodeGuid))
+            {
+                nodeControl = null;
+                return false;
+            }
+            if (!NodeControls.TryGetValue(nodeGuid, out nodeControl))
+            {
+                nodeControl = null;
+                return false;
+            }
+            if (nodeControl is null)
+            {
+                return false;
+            }
+            return true;
+        }
+
+        #endregion
+
+        #region 操作接口对外暴露的接口
+
+        /// <summary>
+        /// 创建节点控件
+        /// </summary>
+        /// <param name="nodeType">控件类型</param>
+        /// <param name="position">创建坐标</param>
+        /// <param name="methodDetailsInfo">节点方法信息（基础节点传null）</param>
+        public void CreateNodeView(MethodDetailsInfo methodDetailsInfo, PositionOfUI position)
+        {
+            Task.Run(async () =>
+            {
+                if (EnumHelper.TryConvertEnum<NodeControlType>(methodDetailsInfo.NodeType, out var nodeType))
+                {
+                    await flowEnvironment.CreateNodeAsync(nodeType, position, methodDetailsInfo);
+                }
+            });
+        }
+
+
+
+
+        #endregion
+    }
+
+}

Workbench/Services/ProjectService.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Serein.Workbench.Services
+{
+    internal class ProjectService
+    {
+
+    }
+}

Workbench/Services/WorkbenchEventService.cs

@@ -0,0 +1,90 @@
+using Serein.Library;
+using Serein.Library.Api;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Security.Cryptography.X509Certificates;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Serein.Workbench.Services
+{
+
+    #region 工作台事件
+
+    public delegate void PreviewlMethodInfoHandler(PreviewlMethodInfoEventArgs eventArgs);
+
+    #endregion
+
+    #region 工作台事件参数
+    public class PreviewlMethodInfoEventArgs(MethodDetailsInfo mdInfo) : EventArgs
+    {
+        /// <summary>
+        /// 方法信息
+        /// </summary>
+        public MethodDetailsInfo MethodDetailsInfo { get; } = mdInfo;
+    }
+    #endregion
+
+
+    /// <summary>
+    /// 工作台事件管理
+    /// </summary>
+    internal interface IWorkbenchEventService
+    {
+        /// <summary>
+        /// 预览了某个方法信息（待创建）
+        /// </summary>
+        event PreviewlMethodInfoHandler OnPreviewlMethodInfo;
+
+        /// <summary>
+        /// 预览依赖方法信息
+        /// </summary>
+        void PreviewLibraryMethodInfo(MethodDetailsInfo mdInfo);
+    }
+
+    /// <summary>
+    /// 工作台事件的实现类
+    /// </summary>
+    internal class WorkbenchEventService : IWorkbenchEventService
+    {
+
+        private readonly IFlowEnvironment flowEnvironment;
+        /// <summary>
+        /// 管理工作台的事件
+        /// </summary>
+        /// <param name="flowEnvironment"></param>
+        public WorkbenchEventService(IFlowEnvironment flowEnvironment)
+        {
+            this.flowEnvironment = flowEnvironment;
+            
+        }
+
+        private void SubscribeEvents()
+        {
+            
+        }
+
+        /// <summary>
+        /// 预览了某个方法信息（待创建）
+        /// </summary>
+        public event PreviewlMethodInfoHandler? OnPreviewlMethodInfo;
+        /// <summary>
+        /// 预览依赖方法信息
+        /// </summary>
+        public void PreviewLibraryMethodInfo(MethodDetailsInfo mdInfo)
+        {
+            OnPreviewlMethodInfo?.Invoke(new PreviewlMethodInfoEventArgs(mdInfo));
+        }
+
+        /// <summary>
+        /// 需要放置节点控件
+        /// </summary>
+        public void PlateNodeControl()
+        {
+
+        }
+    }
+    
+}
+