2. \u6574\u4f53\u67b6\u6784（\u4e09\u5c42\u59d4\u6258 + \u4e09\u7aef\u89e3\u8026）<\/h4>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260205171643-6984d07ba2b2f.png\")
<\/p>\n
3. \u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u591a\u7ed3\u6784\u62fc\u63a5\u8bbe\u8ba1）<\/h4>\n
\u91c7\u7528\u4e09\u7ea7\u59d4\u6258\u62fc\u63a5，\u4ece\u539f\u5b50\u64cd\u4f5c\u5230\u5b8c\u6574\u6d41\u7a0b，\u652f\u6301\u65e0\u9650\u7ec4\u5408，\u9002\u914d\u4efb\u610f\u5de5\u5e8f\u7ed3\u6784：<\/p>\n
\u4e8c\u3001\u524d\u7f6e\u51c6\u5907<\/h3>\n1. \u73af\u5883\u4e0e NuGet \u4f9d\u8d56<\/h4>\n\n- \u5f00\u53d1\u73af\u5883：.NET Framework 4.8（WinForm \u517c\u5bb9\u6027\u6700\u4f18）\u3001Visual Studio 2022+<\/li>\n
- \u6838\u5fc3 NuGet \u5305：\n
bash<\/p>\n
\u8fd0\u884c<\/p>\n
Install-Package Dapper # \u8f7b\u91cfORM，\u672c\u5730\/ERP\u6570\u636e\u4ea4\u4e92
\nInstall-Package System.Data.SQLite.Core # \u672c\u5730\u5de5\u5e8f\/\u59d4\u6258\u914d\u7f6e\u5b58\u50a8
\nInstall-Package Newtonsoft.Json # JSON\u5e8f\u5217\u5316，\u5de5\u827a\u8def\u7ebf\/\u59d4\u6258\u53c2\u6570\u89e3\u6790
\nInstall-Package System.Configuration # \u914d\u7f6e\u6587\u4ef6\u7ba1\u7406，ERP\/MES\u63a5\u53e3\u914d\u7f6e\n <\/li>\n<\/ul>\n
2. \u6838\u5fc3\u679a\u4e3e（MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u6807\u51c6\u5316）<\/h4>\n
\u5c01\u88c5 MES\/ERP \u901a\u7528\u7684\u5de5\u5e8f\u3001\u6d41\u7a0b\u3001\u4e8b\u4ef6\u679a\u4e3e，\u4f5c\u4e3a\u59d4\u6258\u4e8b\u4ef6\u548c\u4e1a\u52a1\u6267\u884c\u7684\u57fa\u7840\u6807\u8bc6：<\/p>\n
using System;
\nusing System.Collections.Generic;
\nusing System.Threading;
\nusing System.Threading.Tasks;
\nusing System.Windows.Forms;
\nusing Dapper;
\nusing System.Data.SQLite;
\nusing System.IO;
\nusing Newtonsoft.Json;<\/p>\n
#region MES\/ERP\u6838\u5fc3\u679a\u4e3e
\n\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6267\u884c\u72b6\u6001（MES\/ERP\u901a\u7528\u6807\u51c6）
\n\/\/\/ <\/summary>
\npublic enum ProcessStatus
\n{
\n UnInitialized = 0, \/\/ \u672a\u521d\u59cb\u5316
\n Ready = 1, \/\/ \u5c31\u7eea（\u53ef\u6267\u884c）
\n Running = 2, \/\/ \u6267\u884c\u4e2d
\n Completed = 3, \/\/ \u6267\u884c\u5b8c\u6210
\n Exception = 4, \/\/ \u6267\u884c\u5f02\u5e38
\n Paused = 5, \/\/ \u6682\u505c
\n Skipped = 6 \/\/ \u5de5\u5e8f\u8df3\u8fc7
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6\u7c7b\u578b（\u751f\u547d\u5468\u671f\u5168\u8282\u70b9，\u59d4\u6258\u7ed1\u5b9a\u6838\u5fc3）
\n\/\/\/ <\/summary>
\npublic enum ProcessFlowEventType
\n{
\n ProcessInit, \/\/ \u5de5\u5e8f\u521d\u59cb\u5316
\n ProcessStart, \/\/ \u5de5\u5e8f\u542f\u52a8
\n ProcessExec, \/\/ \u5de5\u5e8f\u6267\u884c\u4e2d（\u5b9e\u65f6）
\n ProcessComplete, \/\/ \u5de5\u5e8f\u5b8c\u6210
\n ProcessException, \/\/ \u5de5\u5e8f\u5f02\u5e38
\n ProcessRecover, \/\/ \u5f02\u5e38\u6062\u590d
\n ProcessPause, \/\/ \u5de5\u5e8f\u6682\u505c
\n ProcessResume, \/\/ \u5de5\u5e8f\u6062\u590d
\n FlowStart, \/\/ \u6d41\u7a0b\u6574\u4f53\u542f\u52a8
\n FlowComplete, \/\/ \u6d41\u7a0b\u6574\u4f53\u5b8c\u6210
\n FlowException \/\/ \u6d41\u7a0b\u6574\u4f53\u5f02\u5e38
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u59d4\u6258\u62fc\u63a5\u7c7b\u578b（\u63a7\u5236\u591a\u59d4\u6258\u6267\u884c\u903b\u8f91）
\n\/\/\/ <\/summary>
\npublic enum DelegateCombineType
\n{
\n Serial, \/\/ \u4e32\u884c\u6267\u884c（\u6309\u6ce8\u518c\u987a\u5e8f）
\n Parallel, \/\/ \u5e76\u884c\u6267\u884c（\u540c\u65f6\u89e6\u53d1）
\n Conditional \/\/ \u6761\u4ef6\u6267\u884c（\u6ee1\u8db3\u524d\u7f6e\u6761\u4ef6\u624d\u6267\u884c）
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6d41\u7a0b\u6267\u884c\u6a21\u5f0f
\n\/\/\/ <\/summary>
\npublic enum FlowExecuteMode
\n{
\n WinFormUI, \/\/ UI\u7ebf\u7a0b\u6267\u884c（\u5e26\u8fdb\u5ea6\u53cd\u9988）
\n BackendService \/\/ \u540e\u53f0\u670d\u52a1\u6267\u884c（\u65e0UI\u963b\u585e，\u63a8\u8350）
\n}
\n#endregion<\/p>\n
\u4e09\u3001\u6838\u5fc3\u6a21\u578b（MES\/ERP \u5de5\u5e8f\u6d41\u7a0b + \u59d4\u6258\u5c01\u88c5）<\/h3>\n
\u8bbe\u8ba1\u4e0e ERP\/MES \u65e0\u7f1d\u5bf9\u63a5\u7684\u4e1a\u52a1\u6a21\u578b，\u540c\u65f6\u5c01\u88c5\u59d4\u6258\u62fc\u63a5\u7684\u6838\u5fc3\u6a21\u578b，\u652f\u6301\u59d4\u6258\u7684\u6ce8\u518c\u3001\u7ec4\u5408\u3001\u5b58\u50a8\u3001\u6267\u884c：<\/p>\n
#region MES\/ERP\u4e1a\u52a1\u6838\u5fc3\u6a21\u578b
\n\/\/\/ <summary>
\n\/\/\/ ERP\u5de5\u5355\u4fe1\u606f（\u4e0a\u6e38ERP\u4e0b\u53d1，MES\u6267\u884c\u4f9d\u636e）
\n\/\/\/ <\/summary>
\npublic class ErpWorkOrder
\n{
\n public string OrderNo { get; set; } \/\/ \u5de5\u5355\u53f7（ERP\u552f\u4e00\u6807\u8bc6）
\n public string ProductCode { get; set; } \/\/ \u4ea7\u54c1\u7f16\u7801
\n public string ProductName { get; set; } \/\/ \u4ea7\u54c1\u540d\u79f0
\n public int PlanQty { get; set; } \/\/ \u8ba1\u5212\u4ea7\u91cf
\n public int CompleteQty { get; set; } \/\/ \u5b8c\u6210\u4ea7\u91cf
\n public DateTime CreateTime { get; set; } = DateTime.Now; \/\/ \u5de5\u5355\u521b\u5efa\u65f6\u95f4
\n public string LineCode { get; set; } \/\/ \u7ed1\u5b9a\u4ea7\u7ebf\u7f16\u7801
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5de5\u827a\u8def\u7ebf（ERP\u4e0b\u53d1，\u5b9a\u4e49\u5de5\u5e8f\u6267\u884c\u987a\u5e8f\u548c\u53c2\u6570）
\n\/\/\/ <\/summary>
\npublic class ProcessRoute
\n{
\n public string RouteId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u5de5\u827a\u8def\u7ebfID
\n public string OrderNo { get; set; } \/\/ \u5173\u8054\u5de5\u5355\u53f7
\n public List<ProcessNode> ProcessNodes { get; set; } = new List<ProcessNode>(); \/\/ \u5de5\u5e8f\u8282\u70b9\u5217\u8868
\n public string LineCode { get; set; } \/\/ \u4ea7\u7ebf\u7f16\u7801
\n public int CurrentProcessIndex { get; set; } = 0; \/\/ \u5f53\u524d\u6267\u884c\u5de5\u5e8f\u7d22\u5f15
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u8282\u70b9（\u5de5\u827a\u8def\u7ebf\u6700\u5c0f\u5355\u4f4d，\u7ed1\u5b9a\u59d4\u6258\u7ec4\u5408）
\n\/\/\/ <\/summary>
\npublic class ProcessNode
\n{
\n public string ProcessId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u5de5\u5e8fID
\n public string ProcessCode { get; set; } \/\/ \u5de5\u5e8f\u7f16\u7801（MES\/ERP\u6807\u51c6\u5316）
\n public string ProcessName { get; set; } \/\/ \u5de5\u5e8f\u540d\u79f0
\n public int SortNo { get; set; } \/\/ \u5de5\u5e8f\u6267\u884c\u987a\u5e8f
\n public ProcessStatus Status { get; set; } = ProcessStatus.UnInitialized; \/\/ \u5de5\u5e8f\u72b6\u6001
\n public string DelegateCombineId { get; set; } \/\/ \u7ed1\u5b9a\u7684\u59d4\u6258\u7ec4\u5408ID
\n public Dictionary<string, string> Params { get; set; } = new Dictionary<string, string>(); \/\/ \u5de5\u5e8f\u53c2\u6570（\u5982PLC\u5730\u5740\u3001\u76ee\u6807\u4ea7\u91cf）
\n public int CompleteQty { get; set; } = 0; \/\/ \u672c\u5de5\u5e8f\u5b8c\u6210\u4ea7\u91cf
\n}
\n#endregion<\/p>\n
#region \u59d4\u6258\u62fc\u63a5\u6838\u5fc3\u6a21\u578b
\n\/\/\/ <summary>
\n\/\/\/ \u57fa\u7840\u59d4\u6258\u4fe1\u606f（\u539f\u5b50\u64cd\u4f5c，\u53ef\u72ec\u7acb\u6267\u884c\/\u7ec4\u5408\u6267\u884c）
\n\/\/\/ <\/summary>
\npublic class BaseDelegateInfo
\n{
\n public string DelegateId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u59d4\u6258ID
\n public string DelegateName { get; set; } \/\/ \u59d4\u6258\u540d\u79f0（\u5982"PLC\u53d1\u9001\u542f\u52a8\u6307\u4ee4"）
\n public ProcessFlowEventType BindEvent { get; set; } \/\/ \u7ed1\u5b9a\u7684\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6
\n public string MethodName { get; set; } \/\/ \u59d4\u6258\u7ed1\u5b9a\u7684\u65b9\u6cd5\u540d（\u53cd\u5c04\/\u76f4\u63a5\u7ed1\u5b9a）
\n public Delegate DelegateFunc { get; set; } \/\/ \u5b9e\u9645\u59d4\u6258\u51fd\u6570
\n public Dictionary<string, string> Params { get; set; } = new Dictionary<string, string>(); \/\/ \u59d4\u6258\u6267\u884c\u53c2\u6570
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u59d4\u6258\u7ec4\u5408\u4fe1\u606f（\u591a\u4e2a\u57fa\u7840\u59d4\u6258\u62fc\u63a5\u6210\u5de5\u5e8f\u7ea7\u903b\u8f91）
\n\/\/\/ <\/summary>
\npublic class DelegateCombineInfo
\n{
\n public string CombineId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u7ec4\u5408ID（\u5de5\u5e8f\u8282\u70b9\u7ed1\u5b9a）
\n public string CombineName { get; set; } \/\/ \u7ec4\u5408\u540d\u79f0（\u5982"\u9884\u88c5\u5de5\u5e8f\u5b8c\u6574\u6267\u884c\u903b\u8f91"）
\n public DelegateCombineType CombineType { get; set; } \/\/ \u62fc\u63a5\u7c7b\u578b（\u4e32\u884c\/\u5e76\u884c\/\u6761\u4ef6）
\n public List<BaseDelegateInfo> BaseDelegates { get; set; } = new List<BaseDelegateInfo>(); \/\/ \u5305\u542b\u7684\u57fa\u7840\u59d4\u6258
\n public string ConditionalExpr { get; set; } = "true"; \/\/ \u6761\u4ef6\u6267\u884c\u8868\u8fbe\u5f0f（\u5982"CompleteQty>0"）
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u6d41\u7a0b\u59d4\u6258\u62fc\u63a5（\u591a\u4e2a\u5de5\u5e8f\u7ec4\u5408\u59d4\u6258\u62fc\u63a5\u6210\u4ea7\u7ebf\u6d41\u7a0b\u903b\u8f91）
\n\/\/\/ <\/summary>
\npublic class FlowDelegateCombineInfo
\n{
\n public string FlowCombineId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u6d41\u7a0b\u7ec4\u5408ID
\n public string FlowName { get; set; } \/\/ \u6d41\u7a0b\u540d\u79f0（\u5982"B\u4ea7\u54c1\u603b\u88c5\u6d41\u7a0b"）
\n public string RouteId { get; set; } \/\/ \u5173\u8054\u5de5\u827a\u8def\u7ebfID
\n public List<DelegateCombineInfo> ProcessCombines { get; set; } = new List<DelegateCombineInfo>(); \/\/ \u5de5\u5e8f\u7ec4\u5408\u59d4\u6258\u5217\u8868
\n public FlowExecuteMode ExecuteMode { get; set; } = FlowExecuteMode.BackendService; \/\/ \u6267\u884c\u6a21\u5f0f
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587（\u4f20\u9012\u7ed9\u6240\u6709\u59d4\u6258，\u5305\u542b\u5168\u91cf\u4e1a\u52a1\u4fe1\u606f）
\n\/\/\/ <\/summary>
\npublic class DelegateExecuteContext
\n{
\n public ErpWorkOrder WorkOrder { get; set; } \/\/ \u5173\u8054\u5de5\u5355
\n public ProcessRoute ProcessRoute { get; set; } \/\/ \u5173\u8054\u5de5\u827a\u8def\u7ebf
\n public ProcessNode CurrentProcess { get; set; } \/\/ \u5f53\u524d\u6267\u884c\u5de5\u5e8f
\n public ProcessFlowEventType CurrentEvent { get; set; } \/\/ \u5f53\u524d\u89e6\u53d1\u4e8b\u4ef6
\n public CancellationToken Cts { get; set; } \/\/ \u53d6\u6d88\u4ee4\u724c（\u7528\u4e8e\u7ec8\u6b62\u6267\u884c）
\n public string ErrorMsg { get; set; } \/\/ \u6267\u884c\u9519\u8bef\u4fe1\u606f
\n public bool IsSuccess { get; set; } = true; \/\/ \u6267\u884c\u662f\u5426\u6210\u529f
\n}
\n#endregion<\/p>\n
\u56db\u3001\u6838\u5fc3\u59d4\u6258\u5b9a\u4e49（MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e13\u7528）<\/h3>\n
\u5c01\u88c5\u4e0e\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6\u5f3a\u7ed1\u5b9a\u7684\u901a\u7528\u59d4\u6258\u7c7b\u578b，\u8986\u76d6\u65e0\u8fd4\u56de\u503c \/ \u6709\u8fd4\u56de\u503c \/ \u5f02\u6b65\u6267\u884c\u4e09\u79cd\u573a\u666f，\u9002\u914d MES\/ERP \u7684\u5b9e\u65f6\u6027\u548c\u590d\u6742\u6027\u8981\u6c42：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
#region MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u4e13\u7528\u59d4\u6258\u5b9a\u4e49
\n\/\/\/ <summary>
\n\/\/\/ \u57fa\u7840\u65e0\u8fd4\u56de\u503c\u59d4\u6258（\u6700\u5e38\u7528，\u5982\u65e5\u5fd7\u3001PLC\u6307\u4ee4\u3001\u72b6\u6001\u66f4\u65b0）
\n\/\/\/ \u5165\u53c2：\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587
\n\/\/\/ <\/summary>
\n\/\/\/ <param name="context">\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587<\/param>
\npublic delegate void ProcessFlowBaseDelegate(DelegateExecuteContext context);<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u6709\u8fd4\u56de\u503c\u59d4\u6258（\u5982\u6570\u636e\u67e5\u8be2\u3001\u53c2\u6570\u6821\u9a8c\u3001\u6761\u4ef6\u5224\u65ad）
\n\/\/\/ \u5165\u53c2：\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587；\u8fd4\u56de\u503c：\u6267\u884c\u7ed3\u679c（bool）
\n\/\/\/ <\/summary>
\n\/\/\/ <param name="context">\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587<\/param>
\n\/\/\/ <returns>\u6267\u884c\u7ed3\u679c<\/returns>
\npublic delegate bool ProcessFlowFuncDelegate(DelegateExecuteContext context);<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5f02\u6b65\u59d4\u6258（\u5982\u8017\u65f6\u64cd\u4f5c：PLC\u901a\u4fe1\u3001ERP\u6570\u636e\u4ea4\u4e92\u3001\u8bbe\u5907\u6821\u51c6）
\n\/\/\/ \u5165\u53c2：\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587+\u53d6\u6d88\u4ee4\u724c；\u8fd4\u56de\u503c：\u5f02\u6b65\u4efb\u52a1
\n\/\/\/ <\/summary>
\n\/\/\/ <param name="context">\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587<\/param>
\n\/\/\/ <param name="cancellationToken">\u53d6\u6d88\u4ee4\u724c<\/param>
\n\/\/\/ <returns>\u5f02\u6b65\u4efb\u52a1<\/returns>
\npublic delegate Task ProcessFlowAsyncDelegate(DelegateExecuteContext context, CancellationToken cancellationToken);
\n#endregion<\/p>\n
\u4e94\u3001\u6838\u5fc3\u670d\u52a1\u5c01\u88c5（\u59d4\u6258\u7ba1\u7406 + \u6d41\u7a0b\u5f15\u64ce + \u540e\u53f0\u670d\u52a1）<\/h3>\n1. \u672c\u5730\u6570\u636e\u5e93\u52a9\u624b（SQLite）<\/h4>\n
\u5c01\u88c5\u5de5\u5e8f\u6d41\u7a0b \/ \u59d4\u6258\u914d\u7f6e \/ \u5de5\u5355\u4fe1\u606f\u7684\u672c\u5730\u5b58\u50a8，\u5b9e\u73b0\u914d\u7f6e\u6301\u4e45\u5316，\u7a0b\u5e8f\u91cd\u542f\u540e\u59d4\u6258\u62fc\u63a5\u5173\u7cfb\u3001\u5de5\u5e8f\u72b6\u6001\u4e0d\u4e22\u5931：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ SQLite\u672c\u5730\u6570\u636e\u5e93\u52a9\u624b（\u5355\u4f8b）- MES\/ERP\u5de5\u5e8f\u59d4\u6258\u4e13\u7528
\n\/\/\/ \u5b58\u50a8：\u5de5\u5355\u3001\u5de5\u827a\u8def\u7ebf\u3001\u5de5\u5e8f\u8282\u70b9\u3001\u59d4\u6258\u914d\u7f6e\u3001\u59d4\u6258\u7ec4\u5408
\n\/\/\/ <\/summary>
\npublic sealed class MesErpDbHelper
\n{
\n \/\/ \u5355\u4f8b\u5b9e\u4f8b
\n private static readonly Lazy<MesErpDbHelper> _instance = new Lazy<MesErpDbHelper>(() => new MesErpDbHelper());
\n public static MesErpDbHelper Instance => _instance.Value;<\/p>\n
\/\/ \u6570\u636e\u5e93\u8def\u5f84（\u7a0b\u5e8f\u76ee\u5f55\u4e0bMesErpProcessDelegate.db）
\n private readonly string _dbPath;
\n private readonly string _connStr;
\n private readonly object _dbLock = new object();<\/p>\n
private MesErpDbHelper()
\n {
\n _dbPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "MesErpProcessDelegate.db");
\n \/\/ \u5f00\u542fWAL\u6a21\u5f0f，\u63d0\u5347\u540e\u53f0\u670d\u52a1\u591a\u7ebf\u7a0b\u8bfb\u5199\u6027\u80fd
\n _connStr = $"Data Source={_dbPath};Version=3;Journal Mode=WAL;Pooling=true;Max Pool Size=20;";
\n \/\/ \u521d\u59cb\u5316\u6570\u636e\u5e93\u8868\u7ed3\u6784
\n InitDbTables();
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u521d\u59cb\u5316\u6570\u636e\u5e93\u8868（\u4e0d\u5b58\u5728\u5219\u521b\u5efa）
\n \/\/\/ <\/summary>
\n private void InitDbTables()
\n {
\n lock (_dbLock)
\n {
\n if (!File.Exists(_dbPath)) SQLiteConnection.CreateFile(_dbPath);<\/p>\n
using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n \/\/ 1. ERP\u5de5\u5355\u8868
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS ErpWorkOrder (
\n OrderNo TEXT PRIMARY KEY, ProductCode TEXT, ProductName TEXT, PlanQty INT,
\n CompleteQty INT, CreateTime DATETIME, LineCode TEXT)");<\/p>\n
\/\/ 2. \u5de5\u827a\u8def\u7ebf\u8868
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS ProcessRoute (
\n RouteId TEXT PRIMARY KEY, OrderNo TEXT, LineCode TEXT, CurrentProcessIndex INT,
\n ProcessNodes TEXT, FOREIGN KEY(OrderNo) REFERENCES ErpWorkOrder(OrderNo))");<\/p>\n
\/\/ 3. \u59d4\u6258\u7ec4\u5408\u8868（\u5de5\u5e8f\u7ea7）
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS DelegateCombine (
\n CombineId TEXT PRIMARY KEY, CombineName TEXT, CombineType INT,
\n ConditionalExpr TEXT, BaseDelegates TEXT)");<\/p>\n
\/\/ 4. \u6d41\u7a0b\u59d4\u6258\u7ec4\u5408\u8868（\u4ea7\u7ebf\u7ea7）
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS FlowDelegateCombine (
\n FlowCombineId TEXT PRIMARY KEY, FlowName TEXT, RouteId TEXT,
\n ExecuteMode INT, ProcessCombines TEXT,
\n FOREIGN KEY(RouteId) REFERENCES ProcessRoute(RouteId))");<\/p>\n
LogHelper.Info("MES\/ERP\u672c\u5730\u6570\u636e\u5e93\u521d\u59cb\u5316\u5b8c\u6210，\u8def\u5f84：" + _dbPath);
\n }
\n }
\n }<\/p>\n
#region \u901a\u7528CRUD\u65b9\u6cd5
\n public T QueryFirst<T>(string sql, object param = null)
\n {
\n lock (_dbLock)
\n {
\n using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n return conn.QueryFirstOrDefault<T>(sql, param);
\n }
\n }
\n }<\/p>\n
public List<T> QueryList<T>(string sql, object param = null)
\n {
\n lock (_dbLock)
\n {
\n using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n return conn.Query<T>(sql, param).ToList();
\n }
\n }
\n }<\/p>\n
public int Execute(string sql, object param = null)
\n {
\n lock (_dbLock)
\n {
\n using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n using (var tran = conn.BeginTransaction())
\n {
\n try
\n {
\n var rows = conn.Execute(sql, param, tran);
\n tran.Commit();
\n return rows;
\n }
\n catch (Exception ex)
\n {
\n tran.Rollback();
\n LogHelper.Error("SQL\u6267\u884c\u5931\u8d25：" + sql, ex);
\n throw;
\n }
\n }
\n }
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u4fdd\u5b58\u5bf9\u8c61\u5230\u6570\u636e\u5e93（JSON\u5e8f\u5217\u5316\u590d\u6742\u5b57\u6bb5）
\n \/\/\/ <\/summary>
\n public void SaveObject<T>(string tableName, string keyCol, T model)
\n {
\n var jsonProps = model.GetType().GetProperties()
\n .Where(p => p.PropertyType.IsGenericType || p.PropertyType == typeof(Dictionary<string, string>))
\n .Select(p => p.Name).ToList();<\/p>\n
var sqlCols = string.Join(",", model.GetType().GetProperties()
\n .Where(p => !jsonProps.Contains(p.Name))
\n .Select(p => p.Name));
\n var sqlVals = string.Join(",", model.GetType().GetProperties()
\n .Where(p => !jsonProps.Contains(p.Name))
\n .Select(p => $"@{p.Name}"));<\/p>\n
\/\/ \u5148\u5220\u9664\u539f\u6709\u6570\u636e
\n Execute($"DELETE FROM {tableName} WHERE {keyCol} = @{keyCol}", model);
\n \/\/ \u63d2\u5165\u65b0\u6570\u636e（\u590d\u6742\u5b57\u6bb5JSON\u5e8f\u5217\u5316）
\n var insertSql = $"INSERT INTO {tableName} ({sqlCols},{string.Join(",", jsonProps)}) VALUES ({sqlVals},{string.Join(",", jsonProps.Select(p => $"@{p}"))})";
\n var param = new DynamicParameters(model);
\n foreach (var prop in jsonProps)
\n {
\n var val = model.GetType().GetProperty(prop).GetValue(model);
\n param.Add(prop, JsonConvert.SerializeObject(val));
\n }
\n Execute(insertSql, param);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u8bfb\u53d6\u5bf9\u8c61\u4ece\u6570\u636e\u5e93（JSON\u53cd\u5e8f\u5217\u5316\u590d\u6742\u5b57\u6bb5）
\n \/\/\/ <\/summary>
\n public T GetObject<T>(string tableName, string keyCol, string keyVal)
\n {
\n var sql = $"SELECT * FROM {tableName} WHERE {keyCol} = @KeyVal";
\n var dynamicModel = QueryFirst<dynamic>(sql, new { KeyVal = keyVal });
\n if (dynamicModel == null) return default;<\/p>\n
var model = JsonConvert.DeserializeObject<T>(JsonConvert.SerializeObject(dynamicModel));
\n var jsonProps = typeof(T).GetProperties()
\n .Where(p => p.PropertyType.IsGenericType || p.PropertyType == typeof(Dictionary<string, string>))
\n .Select(p => p.Name).ToList();<\/p>\n
foreach (var prop in jsonProps)
\n {
\n var jsonVal = dynamicModel.GetType().GetProperty(prop)?.GetValue(dynamicModel)?.ToString();
\n if (!string.IsNullOrEmpty(jsonVal))
\n {
\n var val = JsonConvert.DeserializeObject(jsonVal, typeof(T).GetProperty(prop).PropertyType);
\n typeof(T).GetProperty(prop).SetValue(model, val);
\n }
\n }
\n return model;
\n }
\n #endregion
\n}<\/p>\n
2. \u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3（\u6838\u5fc3，\u591a\u7ed3\u6784\u62fc\u63a5 + \u52a8\u6001\u6ce8\u518c）<\/h4>\n
\u5b9e\u73b0\u57fa\u7840\u59d4\u6258\u7684\u6ce8\u518c \/ \u6ce8\u9500\u3001\u59d4\u6258\u7684\u7ec4\u5408\u62fc\u63a5\u3001\u59d4\u6258\u7684\u6301\u4e45\u5316 \/ \u52a0\u8f7d，\u662f\u6574\u4e2a\u4e2d\u95f4\u4ef6\u7684\u59d4\u6258\u5927\u8111，\u652f\u6301\u53ef\u89c6\u5316\u914d\u7f6e\u548c\u52a8\u6001\u4fee\u6539：<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3（\u5355\u4f8b）- MES\/ERP\u4e13\u7528
\n\/\/\/ \u6838\u5fc3：\u57fa\u7840\u59d4\u6258\u6ce8\u518c\u3001\u591a\u7ed3\u6784\u62fc\u63a5\u3001\u59d4\u6258\u52a0\u8f7d\/\u4fdd\u5b58\u3001\u59d4\u6258\u6267\u884c
\n\/\/\/ <\/summary>
\npublic sealed class ProcessDelegateManager
\n{
\n \/\/ \u5355\u4f8b\u5b9e\u4f8b
\n private static readonly Lazy<ProcessDelegateManager> _instance = new Lazy<ProcessDelegateManager>(() => new ProcessDelegateManager());
\n public static ProcessDelegateManager Instance => _instance.Value;<\/p>\n
\/\/ \u672c\u5730\u6570\u636e\u5e93\u52a9\u624b
\n private readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;
\n \/\/ \u57fa\u7840\u59d4\u6258\u6ce8\u518c\u8868（\u5185\u5b58\u7f13\u5b58，\u63d0\u9ad8\u6267\u884c\u6548\u7387）
\n private readonly Dictionary<string, BaseDelegateInfo> _baseDelegateDict = new Dictionary<string, BaseDelegateInfo>();
\n \/\/ \u59d4\u6258\u7ec4\u5408\u6ce8\u518c\u8868
\n private readonly Dictionary<string, DelegateCombineInfo> _combineDelegateDict = new Dictionary<string, DelegateCombineInfo>();
\n \/\/ \u6d41\u7a0b\u59d4\u6258\u7ec4\u5408\u6ce8\u518c\u8868
\n private readonly Dictionary<string, FlowDelegateCombineInfo> _flowCombineDelegateDict = new Dictionary<string, FlowDelegateCombineInfo>();
\n \/\/ \u7ebf\u7a0b\u5b89\u5168\u9501
\n private readonly object _delegateLock = new object();<\/p>\n
private ProcessDelegateManager()
\n {
\n \/\/ \u7a0b\u5e8f\u542f\u52a8\u65f6\u52a0\u8f7d\u672c\u5730\u5b58\u50a8\u7684\u59d4\u6258\u914d\u7f6e
\n LoadAllDelegatesFromDb();
\n \/\/ \u6ce8\u518cMES\/ERP\u901a\u7528\u57fa\u7840\u59d4\u6258（\u539f\u5b50\u64cd\u4f5c，\u53ef\u76f4\u63a5\u4f7f\u7528）
\n RegisterDefaultBaseDelegates();
\n }<\/p>\n
#region \u57fa\u7840\u59d4\u6258\u64cd\u4f5c（\u6ce8\u518c\/\u6ce8\u9500\/\u52a0\u8f7d\/\u4fdd\u5b58）
\n \/\/\/ <summary>
\n \/\/\/ \u6ce8\u518c\u57fa\u7840\u59d4\u6258（\u652f\u6301\u4efb\u610f\u7c7b\u578b\u59d4\u6258：Base\/Func\/Async）
\n \/\/\/ <\/summary>
\n public void RegisterBaseDelegate(BaseDelegateInfo delegateInfo)
\n {
\n lock (_delegateLock)
\n {
\n if (_baseDelegateDict.ContainsKey(delegateInfo.DelegateId))
\n _baseDelegateDict[delegateInfo.DelegateId] = delegateInfo;
\n else
\n _baseDelegateDict.Add(delegateInfo.DelegateId, delegateInfo);
\n LogHelper.Info($"\u57fa\u7840\u59d4\u6258\u6ce8\u518c\u6210\u529f：{delegateInfo.DelegateName}（ID：{delegateInfo.DelegateId}）");
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6ce8\u9500\u57fa\u7840\u59d4\u6258
\n \/\/\/ <\/summary>
\n public void UnRegisterBaseDelegate(string delegateId)
\n {
\n lock (_delegateLock)
\n {
\n if (_baseDelegateDict.ContainsKey(delegateId))
\n {
\n _baseDelegateDict.Remove(delegateId);
\n LogHelper.Info($"\u57fa\u7840\u59d4\u6258\u6ce8\u9500\u6210\u529f：ID={delegateId}");
\n }
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6ce8\u518cMES\/ERP\u901a\u7528\u9ed8\u8ba4\u57fa\u7840\u59d4\u6258（\u5f00\u7bb1\u5373\u7528）
\n \/\/\/ <\/summary>
\n private void RegisterDefaultBaseDelegates()
\n {
\n \/\/ 1. \u5de5\u5e8f\u72b6\u6001\u66f4\u65b0\u59d4\u6258（\u7ed1\u5b9aProcessStart\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5de5\u5e8f\u72b6\u6001\u66f4\u65b0\u4e3a\u6267\u884c\u4e2d",
\n BindEvent = ProcessFlowEventType.ProcessStart,
\n DelegateFunc = new ProcessFlowBaseDelegate(DefaultDelegates.UpdateProcessStatusToRunning)
\n });<\/p>\n
\/\/ 2. \u4ea7\u91cf\u4e0a\u62a5\u59d4\u6258（\u7ed1\u5b9aProcessComplete\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5de5\u5e8f\u4ea7\u91cf\u4e0a\u62a5\u5230\u672c\u5730\u5e93",
\n BindEvent = ProcessFlowEventType.ProcessComplete,
\n DelegateFunc = new ProcessFlowBaseDelegate(DefaultDelegates.ReportProcessYieldToDb)
\n });<\/p>\n
\/\/ 3. ERP\u5de5\u5355\u8fdb\u5ea6\u66f4\u65b0\u59d4\u6258（\u5f02\u6b65，\u7ed1\u5b9aFlowComplete\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5f02\u6b65\u66f4\u65b0ERP\u5de5\u5355\u8fdb\u5ea6",
\n BindEvent = ProcessFlowEventType.FlowComplete,
\n DelegateFunc = new ProcessFlowAsyncDelegate(DefaultDelegates.AsyncUpdateErpOrderProgress)
\n });<\/p>\n
\/\/ 4. \u5de5\u5e8f\u5f02\u5e38\u65e5\u5fd7\u59d4\u6258（\u7ed1\u5b9aProcessException\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5de5\u5e8f\u5f02\u5e38\u65e5\u5fd7\u8bb0\u5f55",
\n BindEvent = ProcessFlowEventType.ProcessException,
\n DelegateFunc = new ProcessFlowBaseDelegate(DefaultDelegates.RecordProcessExceptionLog)
\n });
\n }
\n #endregion<\/p>\n
#region \u59d4\u6258\u7ec4\u5408\u64cd\u4f5c（\u5de5\u5e8f\u7ea7\/\u6d41\u7a0b\u7ea7\u62fc\u63a5）
\n \/\/\/ <summary>
\n \/\/\/ \u62fc\u63a5\u5de5\u5e8f\u7ea7\u59d4\u6258\u7ec4\u5408（\u591a\u4e2a\u57fa\u7840\u59d4\u6258\u6309\u89c4\u5219\u7ec4\u5408）
\n \/\/\/ <\/summary>
\n public DelegateCombineInfo CombineProcessDelegates(string combineName, DelegateCombineType combineType, List<BaseDelegateInfo> baseDelegates, string conditionalExpr = "true")
\n {
\n lock (_delegateLock)
\n {
\n var combine = new DelegateCombineInfo
\n {
\n CombineName = combineName,
\n CombineType = combineType,
\n BaseDelegates = baseDelegates,
\n ConditionalExpr = conditionalExpr
\n };
\n _combineDelegateDict.Add(combine.CombineId, combine);
\n \/\/ \u6301\u4e45\u5316\u5230\u672c\u5730\u5e93
\n _dbHelper.SaveObject("DelegateCombine", "CombineId", combine);
\n LogHelper.Info($"\u5de5\u5e8f\u59d4\u6258\u7ec4\u5408\u62fc\u63a5\u6210\u529f：{combineName}（\u5305\u542b{baseDelegates.Count}\u4e2a\u57fa\u7840\u59d4\u6258）");
\n return combine;
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u62fc\u63a5\u4ea7\u7ebf\u7ea7\u6d41\u7a0b\u59d4\u6258（\u591a\u4e2a\u5de5\u5e8f\u7ec4\u5408\u59d4\u6258\u62fc\u63a5\u6210\u5b8c\u6574\u6d41\u7a0b）
\n \/\/\/ <\/summary>
\n public FlowDelegateCombineInfo CombineFlowDelegates(string flowName, string routeId, List<DelegateCombineInfo> processCombines, FlowExecuteMode executeMode)
\n {
\n lock (_delegateLock)
\n {
\n var flowCombine = new FlowDelegateCombineInfo
\n {
\n FlowName = flowName,
\n RouteId = routeId,
\n ProcessCombines = processCombines,
\n ExecuteMode = executeMode
\n };
\n _flowCombineDelegateDict.Add(flowCombine.FlowCombineId, flowCombine);
\n \/\/ \u6301\u4e45\u5316\u5230\u672c\u5730\u5e93
\n _dbHelper.SaveObject("FlowDelegateCombine", "FlowCombineId", flowCombine);
\n LogHelper.Info($"\u6d41\u7a0b\u59d4\u6258\u62fc\u63a5\u6210\u529f：{flowName}（\u5305\u542b{processCombines.Count}\u4e2a\u5de5\u5e8f\u7ec4\u5408）");
\n return flowCombine;
\n }
\n }
\n #endregion<\/p>\n
#region \u59d4\u6258\u52a0\u8f7d\/\u4fdd\u5b58
\n \/\/\/ <summary>
\n \/\/\/ \u4ece\u672c\u5730\u5e93\u52a0\u8f7d\u6240\u6709\u59d4\u6258\u914d\u7f6e
\n \/\/\/ <\/summary>
\n private void LoadAllDelegatesFromDb()
\n {
\n \/\/ \u52a0\u8f7d\u5de5\u5e8f\u59d4\u6258\u7ec4\u5408
\n var processCombines = _dbHelper.QueryList<dynamic>("SELECT CombineId FROM DelegateCombine");
\n foreach (var item in processCombines)
\n {
\n var combine = _dbHelper.GetObject<DelegateCombineInfo>("DelegateCombine", "CombineId", item.CombineId);
\n _combineDelegateDict.Add(combine.CombineId, combine);
\n }<\/p>\n
\/\/ \u52a0\u8f7d\u6d41\u7a0b\u59d4\u6258\u7ec4\u5408
\n var flowCombines = _dbHelper.QueryList<dynamic>("SELECT FlowCombineId FROM FlowDelegateCombine");
\n foreach (var item in flowCombines)
\n {
\n var flowCombine = _dbHelper.GetObject<FlowDelegateCombineInfo>("FlowDelegateCombine", "FlowCombineId", item.FlowCombineId);
\n _flowCombineDelegateDict.Add(flowCombine.FlowCombineId, flowCombine);
\n }<\/p>\n
LogHelper.Info($"\u4ece\u672c\u5730\u5e93\u52a0\u8f7d\u59d4\u6258\u914d\u7f6e\u5b8c\u6210：\u5de5\u5e8f\u7ec4\u5408{_combineDelegateDict.Count}\u4e2a，\u6d41\u7a0b\u7ec4\u5408{_flowCombineDelegateDict.Count}\u4e2a");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6839\u636e\u5de5\u5e8fID\u83b7\u53d6\u7ed1\u5b9a\u7684\u59d4\u6258\u7ec4\u5408
\n \/\/\/ <\/summary>
\n public DelegateCombineInfo GetProcessCombineByProcessId(string processId, ProcessRoute route)
\n {
\n var processNode = route.ProcessNodes.FirstOrDefault(p => p.ProcessId == processId);
\n if (processNode == null || string.IsNullOrEmpty(processNode.DelegateCombineId))
\n throw new KeyNotFoundException($"\u5de5\u5e8f{processId}\u672a\u7ed1\u5b9a\u59d4\u6258\u7ec4\u5408");<\/p>\n
return _combineDelegateDict.TryGetValue(processNode.DelegateCombineId, out var combine) ? combine : null;
\n }
\n #endregion<\/p>\n
#region \u59d4\u6258\u6267\u884c（\u6838\u5fc3，\u652f\u6301\u591a\u7c7b\u578b\/\u591a\u62fc\u63a5\u89c4\u5219）
\n \/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u59d4\u6258\u7ec4\u5408（\u81ea\u52a8\u8bc6\u522b\u4e32\u884c\/\u5e76\u884c\/\u6761\u4ef6，\u652f\u6301\u5f02\u6b65）
\n \/\/\/ <\/summary>
\n public async Task ExecuteCombineDelegate(DelegateCombineInfo combine, DelegateExecuteContext context)
\n {
\n if (combine == null || !combine.BaseDelegates.Any()) return;
\n \/\/ \u6761\u4ef6\u6267\u884c：\u5148\u5224\u65ad\u6761\u4ef6\u662f\u5426\u6ee1\u8db3
\n if (!EvaluateConditionalExpr(combine.ConditionalExpr, context))
\n {
\n LogHelper.Info($"\u59d4\u6258\u7ec4\u5408{combine.CombineName}\u6761\u4ef6\u4e0d\u6ee1\u8db3，\u8df3\u8fc7\u6267\u884c");
\n return;
\n }<\/p>\n
LogHelper.Info($"\u5f00\u59cb\u6267\u884c\u59d4\u6258\u7ec4\u5408：{combine.CombineName}（\u7c7b\u578b：{combine.CombineType}）");
\n switch (combine.CombineType)
\n {
\n case DelegateCombineType.Serial:
\n \/\/ \u4e32\u884c\u6267\u884c：\u6309\u987a\u5e8f\u6267\u884c\u6bcf\u4e2a\u57fa\u7840\u59d4\u6258
\n foreach (var baseDel in combine.BaseDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n await ExecuteBaseDelegate(baseDel, context);
\n }
\n break;
\n case DelegateCombineType.Parallel:
\n \/\/ \u5e76\u884c\u6267\u884c：\u6240\u6709\u59d4\u6258\u540c\u65f6\u6267\u884c，\u7b49\u5f85\u5168\u90e8\u5b8c\u6210
\n var parallelTasks = new List<Task>();
\n foreach (var baseDel in combine.BaseDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n parallelTasks.Add(ExecuteBaseDelegate(baseDel, context));
\n }
\n await Task.WhenAll(parallelTasks);
\n break;
\n case DelegateCombineType.Conditional:
\n \/\/ \u6761\u4ef6\u6267\u884c：\u6bcf\u4e2a\u59d4\u6258\u72ec\u7acb\u5224\u65ad\u6761\u4ef6（\u7b80\u5316\u7248，\u53ef\u6269\u5c55）
\n foreach (var baseDel in combine.BaseDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n var expr = baseDel.Params.ContainsKey("ConditionalExpr") ? baseDel.Params["ConditionalExpr"] : "true";
\n if (EvaluateConditionalExpr(expr, context))
\n await ExecuteBaseDelegate(baseDel, context);
\n }
\n break;
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u57fa\u7840\u59d4\u6258（\u81ea\u52a8\u8bc6\u522b\u59d4\u6258\u7c7b\u578b：Base\/Func\/Async）
\n \/\/\/ <\/summary>
\n private async Task ExecuteBaseDelegate(BaseDelegateInfo baseDel, DelegateExecuteContext context)
\n {
\n if (baseDel.DelegateFunc == null)
\n {
\n LogHelper.Warn($"\u57fa\u7840\u59d4\u6258{baseDel.DelegateName}\u672a\u7ed1\u5b9a\u51fd\u6570，\u8df3\u8fc7");
\n return;
\n }<\/p>\n
try
\n {
\n LogHelper.Info($"\u6267\u884c\u57fa\u7840\u59d4\u6258：{baseDel.DelegateName}");
\n \/\/ \u6309\u59d4\u6258\u7c7b\u578b\u5206\u53d1\u6267\u884c
\n if (baseDel.DelegateFunc is ProcessFlowBaseDelegate baseFunc)
\n {
\n baseFunc(context); \/\/ \u540c\u6b65\u65e0\u8fd4\u56de\u503c
\n }
\n else if (baseDel.DelegateFunc is ProcessFlowFuncDelegate func)
\n {
\n context.IsSuccess = func(context); \/\/ \u540c\u6b65\u6709\u8fd4\u56de\u503c
\n }
\n else if (baseDel.DelegateFunc is ProcessFlowAsyncDelegate asyncFunc)
\n {
\n await asyncFunc(context, context.Cts); \/\/ \u5f02\u6b65\u6267\u884c
\n }
\n else
\n {
\n throw new NotSupportedException($"\u4e0d\u652f\u6301\u7684\u59d4\u6258\u7c7b\u578b：{baseDel.DelegateFunc.GetType().Name}");
\n }
\n }
\n catch (Exception ex)
\n {
\n context.IsSuccess = false;
\n context.ErrorMsg = ex.Message;
\n LogHelper.Error($"\u57fa\u7840\u59d4\u6258{baseDel.DelegateName}\u6267\u884c\u5931\u8d25：{ex.Message}", ex);
\n throw;
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u89e3\u6790\u6761\u4ef6\u6267\u884c\u8868\u8fbe\u5f0f（\u7b80\u5316\u7248，\u53ef\u6269\u5c55\u4e3a\u8868\u8fbe\u5f0f\u5f15\u64ce）
\n \/\/\/ <\/summary>
\n private bool EvaluateConditionalExpr(string expr, DelegateExecuteContext context)
\n {
\n \/\/ \u57fa\u7840\u5b9e\u73b0：\u652f\u6301\u7b80\u5355\u8868\u8fbe\u5f0f\u5982"true"\u3001"CompleteQty>0"\u3001"Status==2"
\n if (expr.Trim().ToLower() == "true") return true;
\n if (expr.Trim().ToLower() == "false") return false;<\/p>\n
\/\/ \u6269\u5c55\u70b9：\u96c6\u6210\u8868\u8fbe\u5f0f\u5f15\u64ce（\u5982NCalc）\u652f\u6301\u590d\u6742\u8868\u8fbe\u5f0f
\n try
\n {
\n \/\/ \u793a\u4f8b：\u89e3\u6790CompleteQty>0
\n if (expr.Contains("CompleteQty>"))
\n {
\n var qty = int.Parse(expr.Split('>')[1].Trim());
\n return context.CurrentProcess.CompleteQty > qty;
\n }
\n return true;
\n }
\n catch
\n {
\n return false;
\n }
\n }
\n #endregion
\n}<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u901a\u7528\u9ed8\u8ba4\u59d4\u6258\u5b9e\u73b0（\u539f\u5b50\u64cd\u4f5c，\u5f00\u7bb1\u5373\u7528）
\n\/\/\/ <\/summary>
\npublic static class DefaultDelegates
\n{
\n private static readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u57fa\u7840\u59d4\u6258：\u66f4\u65b0\u5de5\u5e8f\u72b6\u6001\u4e3a\u6267\u884c\u4e2d
\n \/\/\/ <\/summary>
\n public static void UpdateProcessStatusToRunning(DelegateExecuteContext context)
\n {
\n context.CurrentProcess.Status = ProcessStatus.Running;
\n \/\/ \u6301\u4e45\u5316\u5de5\u5e8f\u72b6\u6001
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", context.ProcessRoute);
\n LogHelper.Info($"\u5de5\u5e8f{context.CurrentProcess.ProcessCode}\u72b6\u6001\u66f4\u65b0\u4e3a：\u6267\u884c\u4e2d");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u57fa\u7840\u59d4\u6258：\u5de5\u5e8f\u4ea7\u91cf\u4e0a\u62a5\u5230\u672c\u5730\u5e93
\n \/\/\/ <\/summary>
\n public static void ReportProcessYieldToDb(DelegateExecuteContext context)
\n {
\n context.WorkOrder.CompleteQty = context.ProcessRoute.ProcessNodes.Sum(p => p.CompleteQty);
\n \/\/ \u66f4\u65b0\u5de5\u5355\u548c\u5de5\u827a\u8def\u7ebf
\n _dbHelper.SaveObject("ErpWorkOrder", "OrderNo", context.WorkOrder);
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", context.ProcessRoute);
\n LogHelper.Info($"\u5de5\u5e8f{context.CurrentProcess.ProcessCode}\u4ea7\u91cf\u4e0a\u62a5：{context.CurrentProcess.CompleteQty}\u4ef6，\u5de5\u5355\u7d2f\u8ba1：{context.WorkOrder.CompleteQty}\u4ef6");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u5f02\u6b65\u59d4\u6258：\u66f4\u65b0ERP\u5de5\u5355\u8fdb\u5ea6（\u6a21\u62dfERP\u63a5\u53e3\u8c03\u7528，\u5b9e\u9645\u66ff\u6362\u4e3a\u771f\u5b9eERP\u4ea4\u4e92\u4ee3\u7801）
\n \/\/\/ <\/summary>
\n public static async Task AsyncUpdateErpOrderProgress(DelegateExecuteContext context, CancellationToken ct)
\n {
\n \/\/ \u6a21\u62dfERP\u63a5\u53e3\u7f51\u7edc\u8bf7\u6c42（\u8017\u65f62\u79d2）
\n await Task.Delay(2000, ct);
\n \/\/ \u5b9e\u9645\u573a\u666f：\u8c03\u7528ERP\u7684WebAPI\/WS\u66f4\u65b0\u5de5\u5355\u8fdb\u5ea6
\n var progress = (double)context.WorkOrder.CompleteQty \/ context.WorkOrder.PlanQty * 100;
\n LogHelper.Info($"\u5f02\u6b65\u66f4\u65b0ERP\u5de5\u5355{context.WorkOrder.OrderNo}\u8fdb\u5ea6：{progress:F2}%");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u57fa\u7840\u59d4\u6258：\u8bb0\u5f55\u5de5\u5e8f\u5f02\u5e38\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void RecordProcessExceptionLog(DelegateExecuteContext context)
\n {
\n LogHelper.Error($"\u3010\u5de5\u5e8f\u5f02\u5e38\u3011{context.CurrentProcess.ProcessCode}：{context.ErrorMsg}，\u5de5\u5355：{context.WorkOrder.OrderNo}");
\n context.CurrentProcess.Status = ProcessStatus.Exception;
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", context.ProcessRoute);
\n }
\n}<\/p>\n
3. \u5de5\u5e8f\u6d41\u7a0b\u5f15\u64ce（\u59d4\u6258\u6267\u884c + \u6d41\u7a0b\u63a7\u5236）<\/h4>\n
\u5b9e\u73b0\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u7ba1\u7406，\u89e6\u53d1\u5bf9\u5e94\u4e8b\u4ef6\u5e76\u5206\u53d1\u5230\u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3\u6267\u884c\u62fc\u63a5\u540e\u7684\u59d4\u6258，\u652f\u6301\u4e32\u884c \/ \u5e76\u884c\u5de5\u5e8f\u3001\u5f02\u5e38\u5904\u7406\u3001\u6d41\u7a0b\u6682\u505c \/ \u6062\u590d \/ \u7ec8\u6b62：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u5f15\u64ce（\u5355\u4f8b）
\n\/\/\/ \u6838\u5fc3：\u6d41\u7a0b\u751f\u547d\u5468\u671f\u7ba1\u7406\u3001\u4e8b\u4ef6\u89e6\u53d1\u3001\u59d4\u6258\u5206\u53d1\u3001\u6d41\u7a0b\u63a7\u5236（\u6682\u505c\/\u6062\u590d\/\u7ec8\u6b62）
\n\/\/\/ <\/summary>
\npublic sealed class ProcessFlowEngine
\n{
\n \/\/ \u5355\u4f8b\u5b9e\u4f8b
\n private static readonly Lazy<ProcessFlowEngine> _instance = new Lazy<ProcessFlowEngine>(() => new ProcessFlowEngine());
\n public static ProcessFlowEngine Instance => _instance.Value;<\/p>\n
\/\/ \u4f9d\u8d56\u670d\u52a1
\n private readonly ProcessDelegateManager _delegateManager = ProcessDelegateManager.Instance;
\n private readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;
\n \/\/ \u6b63\u5728\u6267\u884c\u7684\u6d41\u7a0b（\u6d41\u7a0bID->\u53d6\u6d88\u4ee4\u724c\u6e90）
\n private readonly Dictionary<string, CancellationTokenSource> _runningFlows = new Dictionary<string, CancellationTokenSource>();
\n private readonly object _flowLock = new object();<\/p>\n
#region \u6d41\u7a0b\u751f\u547d\u5468\u671f\u64cd\u4f5c（\u542f\u52a8\/\u6682\u505c\/\u6062\u590d\/\u7ec8\u6b62）
\n \/\/\/ <summary>
\n \/\/\/ \u542f\u52a8\u5de5\u5e8f\u6d41\u7a0b（\u6838\u5fc3\u5165\u53e3）
\n \/\/\/ <\/summary>
\n \/\/\/ <param name="flowCombine">\u6d41\u7a0b\u59d4\u6258\u7ec4\u5408<\/param>
\n \/\/\/ <param name="workOrder">ERP\u5de5\u5355<\/param>
\n \/\/\/ <param name="route">\u5de5\u827a\u8def\u7ebf<\/param>
\n \/\/\/ <returns>\u6267\u884c\u4efb\u52a1<\/returns>
\n public async Task StartFlowAsync(FlowDelegateCombineInfo flowCombine, ErpWorkOrder workOrder, ProcessRoute route)
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.ContainsKey(flowCombine.FlowCombineId))
\n throw new InvalidOperationException($"\u6d41\u7a0b{flowCombine.FlowName}\u5df2\u5728\u6267\u884c\u4e2d");<\/p>\n
\/\/ \u521b\u5efa\u53d6\u6d88\u4ee4\u724c\u6e90（\u7528\u4e8e\u6682\u505c\/\u7ec8\u6b62\u6d41\u7a0b）
\n var cts = new CancellationTokenSource();
\n _runningFlows.Add(flowCombine.FlowCombineId, cts);
\n \/\/ \u540e\u53f0\u6267\u884c\u6d41\u7a0b，\u4e0d\u963b\u585eUI
\n Task.Run(async () => await ExecuteFlowAsync(flowCombine, workOrder, route, cts.Token), cts.Token);
\n }<\/p>\n
LogHelper.Info($"\u6d41\u7a0b{flowCombine.FlowName}\u542f\u52a8\u6210\u529f（\u5de5\u5355：{workOrder.OrderNo}），\u6267\u884c\u6a21\u5f0f：{flowCombine.ExecuteMode}");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6682\u505c\u5de5\u5e8f\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n public void PauseFlow(string flowCombineId)
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.TryGetValue(flowCombineId, out var cts))
\n {
\n cts.Cancel();
\n LogHelper.Info($"\u6d41\u7a0b{flowCombineId}\u5df2\u6682\u505c");
\n }
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u7ec8\u6b62\u5de5\u5e8f\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n public void StopFlow(string flowCombineId)
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.TryGetValue(flowCombineId, out var cts))
\n {
\n cts.Cancel();
\n _runningFlows.Remove(flowCombineId);
\n cts.Dispose();
\n LogHelper.Info($"\u6d41\u7a0b{flowCombineId}\u5df2\u7ec8\u6b62");
\n }
\n }
\n }
\n #endregion<\/p>\n
#region \u6d41\u7a0b\u6267\u884c\u6838\u5fc3\u903b\u8f91
\n \/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u5b8c\u6574\u5de5\u5e8f\u6d41\u7a0b（\u89e6\u53d1\u4e8b\u4ef6+\u6267\u884c\u59d4\u6258+\u6d41\u7a0b\u63a7\u5236）
\n \/\/\/ <\/summary>
\n private async Task ExecuteFlowAsync(FlowDelegateCombineInfo flowCombine, ErpWorkOrder workOrder, ProcessRoute route, CancellationToken ct)
\n {
\n var flowContext = new DelegateExecuteContext
\n {
\n WorkOrder = workOrder,
\n ProcessRoute = route,
\n CurrentEvent = ProcessFlowEventType.FlowStart,
\n Cts = ct
\n };<\/p>\n
try
\n {
\n \/\/ \u89e6\u53d1\u6d41\u7a0b\u542f\u52a8\u4e8b\u4ef6
\n await TriggerFlowEvent(ProcessFlowEventType.FlowStart, flowContext);<\/p>\n
\/\/ \u6309\u5de5\u827a\u8def\u7ebf\u987a\u5e8f\u6267\u884c\u6bcf\u4e2a\u5de5\u5e8f
\n while (route.CurrentProcessIndex < route.ProcessNodes.Count && !ct.IsCancellationRequested)
\n {
\n var currentProcess = route.ProcessNodes[route.CurrentProcessIndex];
\n flowContext.CurrentProcess = currentProcess;
\n flowContext.CurrentEvent = ProcessFlowEventType.ProcessInit;<\/p>\n
\/\/ \u6267\u884c\u5355\u4e2a\u5de5\u5e8f\u7684\u5b8c\u6574\u751f\u547d\u5468\u671f
\n await ExecuteSingleProcessAsync(currentProcess, flowCombine, flowContext, ct);<\/p>\n
\/\/ \u5de5\u5e8f\u6267\u884c\u6210\u529f，\u5207\u6362\u5230\u4e0b\u4e00\u4e2a\u5de5\u5e8f
\n if (currentProcess.Status == ProcessStatus.Completed || currentProcess.Status == ProcessStatus.Skipped)
\n {
\n route.CurrentProcessIndex++;
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);
\n }
\n \/\/ \u5de5\u5e8f\u5f02\u5e38，\u7ec8\u6b62\u6d41\u7a0b
\n else if (currentProcess.Status == ProcessStatus.Exception)
\n {
\n throw new Exception($"\u5de5\u5e8f{currentProcess.ProcessCode}\u6267\u884c\u5f02\u5e38，\u6d41\u7a0b\u7ec8\u6b62");
\n }
\n }<\/p>\n
\/\/ \u6240\u6709\u5de5\u5e8f\u6267\u884c\u5b8c\u6210，\u89e6\u53d1\u6d41\u7a0b\u5b8c\u6210\u4e8b\u4ef6
\n if (!ct.IsCancellationRequested)
\n {
\n flowContext.CurrentEvent = ProcessFlowEventType.FlowComplete;
\n await TriggerFlowEvent(ProcessFlowEventType.FlowComplete, flowContext);
\n LogHelper.Info($"\u6d41\u7a0b{flowCombine.FlowName}\u6267\u884c\u5b8c\u6210（\u5de5\u5355：{workOrder.OrderNo}），\u5b8c\u6210\u4ea7\u91cf：{workOrder.CompleteQty}\u4ef6");
\n }
\n }
\n catch (OperationCanceledException)
\n {
\n LogHelper.Info($"\u6d41\u7a0b{flowCombine.FlowName}\u5df2\u6682\u505c\/\u7ec8\u6b62（\u5de5\u5355：{workOrder.OrderNo}）");
\n }
\n catch (Exception ex)
\n {
\n flowContext.CurrentEvent = ProcessFlowEventType.FlowException;
\n flowContext.IsSuccess = false;
\n flowContext.ErrorMsg = ex.Message;
\n await TriggerFlowEvent(ProcessFlowEventType.FlowException, flowContext);
\n LogHelper.Error($"\u6d41\u7a0b{flowCombine.FlowName}\u6267\u884c\u5931\u8d25（\u5de5\u5355：{workOrder.OrderNo}）：{ex.Message}", ex);
\n }
\n finally
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.ContainsKey(flowCombine.FlowCombineId))
\n {
\n _runningFlows[flowCombine.FlowCombineId].Dispose();
\n _runningFlows.Remove(flowCombine.FlowCombineId);
\n }
\n }
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u5355\u4e2a\u5de5\u5e8f\u7684\u5b8c\u6574\u751f\u547d\u5468\u671f（\u521d\u59cb\u5316->\u542f\u52a8->\u6267\u884c->\u5b8c\u6210）
\n \/\/\/ <\/summary>
\n private async Task ExecuteSingleProcessAsync(ProcessNode process, FlowDelegateCombineInfo flowCombine, DelegateExecuteContext context, CancellationToken ct)
\n {
\n \/\/ 1. \u5de5\u5e8f\u521d\u59cb\u5316\u4e8b\u4ef6
\n context.CurrentEvent = ProcessFlowEventType.ProcessInit;
\n process.Status = ProcessStatus.Ready;
\n await TriggerFlowEvent(ProcessFlowEventType.ProcessInit, context);
\n await Task.Delay(500, ct); \/\/ \u6a21\u62df\u5de5\u5e8f\u521d\u59cb\u5316\u8017\u65f6<\/p>\n
\/\/ 2. \u5de5\u5e8f\u542f\u52a8\u4e8b\u4ef6
\n context.CurrentEvent = ProcessFlowEventType.ProcessStart;
\n await TriggerFlowEvent(ProcessFlowEventType.ProcessStart, context);<\/p>\n
\/\/ 3. \u6267\u884c\u5de5\u5e8f\u7ed1\u5b9a\u7684\u59d4\u6258\u7ec4\u5408（\u6838\u5fc3）
\n var processCombine = _delegateManager.GetProcessCombineByProcessId(process.ProcessId, context.ProcessRoute);
\n await _delegateManager.ExecuteCombineDelegate(processCombine, context);<\/p>\n
\/\/ 4. \u5de5\u5e8f\u5b8c\u6210\u4e8b\u4ef6
\n if (context.IsSuccess && !ct.IsCancellationRequested)
\n {
\n context.CurrentEvent = ProcessFlowEventType.ProcessComplete;
\n process.Status = ProcessStatus.Completed;
\n await TriggerFlowEvent(ProcessFlowEventType.ProcessComplete, context);
\n }
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u89e6\u53d1\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6（\u5206\u53d1\u5230\u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3\u6267\u884c\u7ed1\u5b9a\u7684\u59d4\u6258）
\n \/\/\/ <\/summary>
\n private async Task TriggerFlowEvent(ProcessFlowEventType eventType, DelegateExecuteContext context)
\n {
\n context.CurrentEvent = eventType;
\n LogHelper.Info($"\u89e6\u53d1\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6：{eventType}（\u5de5\u5e8f：{context.CurrentProcess?.ProcessCode ?? "\u6d41\u7a0b\u6574\u4f53"}）");<\/p>\n
\/\/ \u6267\u884c\u6240\u6709\u7ed1\u5b9a\u8be5\u4e8b\u4ef6\u7684\u57fa\u7840\u59d4\u6258（\u7b80\u5316\u7248，\u53ef\u6269\u5c55\u4e3a\u6309\u6d41\u7a0b\/\u5de5\u5e8f\u8fc7\u6ee4）
\n var allBaseDelegates = _delegateManager.GetType().GetField("_baseDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, BaseDelegateInfo>;<\/p>\n
var bindDelegates = allBaseDelegates?.Values.Where(d => d.BindEvent == eventType).ToList() ?? new List<BaseDelegateInfo>();
\n foreach (var del in bindDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n await _delegateManager.ExecuteBaseDelegate(del, context);
\n }
\n }
\n #endregion
\n}<\/p>\n
4. \u540e\u53f0\u670d\u52a1\u7ba1\u7406\u5668（WinForm \u65e0 UI \u963b\u585e\u6267\u884c）<\/h4>\n
\u5b9e\u73b0WinForm \u754c\u9762\u4e0e\u540e\u53f0\u670d\u52a1\u89e3\u8026，\u652f\u6301\u6d41\u7a0b\u540e\u53f0\u8fd0\u884c\u3001\u6700\u5c0f\u5316\u5230\u7cfb\u7edf\u6258\u76d8\u3001\u540e\u53f0\u65e5\u5fd7\u8bb0\u5f55\u3001\u72b6\u6001\u5b9e\u65f6\u540c\u6b65\u5230 UI：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u540e\u53f0\u670d\u52a1\u7ba1\u7406\u5668
\n\/\/\/ \u6838\u5fc3：\u65e0UI\u963b\u585e\u6267\u884c\u3001\u7cfb\u7edf\u6258\u76d8\u3001\u540e\u53f0\u7ebf\u7a0b\u6c60\u3001UI\u72b6\u6001\u540c\u6b65
\n\/\/\/ <\/summary>
\npublic class ProcessFlowBackendService
\n{
\n \/\/ \u540e\u53f0\u670d\u52a1\u7ebf\u7a0b\u6c60
\n private readonly TaskFactory _backendTaskFactory;
\n \/\/ UI\u72b6\u6001\u66f4\u65b0\u59d4\u6258（\u8de8\u7ebf\u7a0b\u5b89\u5168）
\n public Action<string, string> UiStatusUpdateAction;
\n \/\/ \u540e\u53f0\u65e5\u5fd7\u59d4\u6258
\n public Action<string> BackendLogAction;<\/p>\n
public ProcessFlowBackendService()
\n {
\n \/\/ \u914d\u7f6e\u540e\u53f0\u7ebf\u7a0b\u6c60（\u65e0\u540c\u6b65\u4e0a\u4e0b\u6587，\u907f\u514dUI\u963b\u585e）
\n var scheduler = TaskScheduler.Default;
\n _backendTaskFactory = new TaskFactory(CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskContinuationOptions.None, scheduler);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u540e\u53f0\u6267\u884c\u5de5\u5e8f\u6d41\u7a0b（\u65e0UI\u963b\u585e）
\n \/\/\/ <\/summary>
\n public void RunFlowInBackend(FlowDelegateCombineInfo flowCombine, ErpWorkOrder workOrder, ProcessRoute route)
\n {
\n _backendTaskFactory.StartNew(async () =>
\n {
\n try
\n {
\n UiStatusUpdateAction?.Invoke(flowCombine.FlowName, "\u540e\u53f0\u6267\u884c\u4e2d");
\n BackendLogAction?.Invoke($"\u540e\u53f0\u670d\u52a1\u542f\u52a8\u6d41\u7a0b：{flowCombine.FlowName}（\u5de5\u5355：{workOrder.OrderNo}）");
\n \/\/ \u8c03\u7528\u6d41\u7a0b\u5f15\u64ce\u542f\u52a8\u6d41\u7a0b
\n await ProcessFlowEngine.Instance.StartFlowAsync(flowCombine, workOrder, route);
\n UiStatusUpdateAction?.Invoke(flowCombine.FlowName, "\u6267\u884c\u5b8c\u6210");
\n }
\n catch (Exception ex)
\n {
\n UiStatusUpdateAction?.Invoke(flowCombine.FlowName, "\u6267\u884c\u5931\u8d25");
\n BackendLogAction?.Invoke($"\u540e\u53f0\u6d41\u7a0b\u6267\u884c\u5931\u8d25：{ex.Message}");
\n LogHelper.Error("\u540e\u53f0\u670d\u52a1\u6267\u884c\u5f02\u5e38", ex);
\n }
\n }, CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6ce8\u518c\u7cfb\u7edf\u6258\u76d8（WinForm\u6700\u5c0f\u5316\u5230\u540e\u53f0\u8fd0\u884c）
\n \/\/\/ <\/summary>
\n public void RegisterSystemTray(Form mainForm, NotifyIcon notifyIcon)
\n {
\n \/\/ \u521d\u59cb\u5316\u6258\u76d8\u56fe\u6807
\n notifyIcon.Icon = SystemIcons.Application;
\n notifyIcon.Text = "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u4e2d\u95f4\u4ef6";
\n notifyIcon.Visible = true;<\/p>\n
\/\/ \u6258\u76d8\u53f3\u952e\u83dc\u5355
\n var contextMenu = new ContextMenuStrip();
\n contextMenu.Items.Add("\u663e\u793a\u754c\u9762", null, (s, e) => { mainForm.Show(); mainForm.WindowState = FormWindowState.Normal; });
\n contextMenu.Items.Add("\u9000\u51fa", null, (s, e) => { Application.Exit(); });
\n notifyIcon.ContextMenuStrip = contextMenu;<\/p>\n
\/\/ \u7a97\u4f53\u6700\u5c0f\u5316\u5230\u6258\u76d8
\n mainForm.Resize += (s, e) =>
\n {
\n if (mainForm.WindowState == FormWindowState.Minimized)
\n {
\n mainForm.Hide();
\n notifyIcon.ShowBalloonTip(2000, "\u63d0\u793a", "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u4e2d\u95f4\u4ef6\u5df2\u6700\u5c0f\u5316\u5230\u540e\u53f0\u8fd0\u884c", ToolTipIcon.Info);
\n }
\n };<\/p>\n
\/\/ \u6258\u76d8\u5de6\u952e\u53cc\u51fb\u663e\u793a\u754c\u9762
\n notifyIcon.MouseDoubleClick += (s, e) =>
\n {
\n if (e.Button == MouseButtons.Left)
\n {
\n mainForm.Show();
\n mainForm.WindowState = FormWindowState.Normal;
\n }
\n };<\/p>\n
BackendLogAction?.Invoke("\u7cfb\u7edf\u6258\u76d8\u6ce8\u518c\u6210\u529f，\u652f\u6301\u540e\u53f0\u8fd0\u884c");
\n }
\n}<\/p>\n
5. \u901a\u7528\u65e5\u5fd7\u52a9\u624b<\/h4>\n
\u5c01\u88c5\u6587\u4ef6\u65e5\u5fd7 + \u63a7\u5236\u53f0\u65e5\u5fd7，\u652f\u6301\u5206\u7ea7\u65e5\u5fd7（Info\/Warn\/Error），\u65b9\u4fbf MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u7684\u95ee\u9898\u6392\u67e5：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u901a\u7528\u65e5\u5fd7\u52a9\u624b
\n\/\/\/ <\/summary>
\npublic static class LogHelper
\n{
\n private static readonly string _logDir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "MesErpLogs");<\/p>\n
static LogHelper()
\n {
\n if (!Directory.Exists(_logDir)) Directory.CreateDirectory(_logDir);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u4fe1\u606f\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void Info(string msg)
\n {
\n WriteLog("INFO", msg);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u8b66\u544a\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void Warn(string msg)
\n {
\n WriteLog("WARN", msg);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u9519\u8bef\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void Error(string msg, Exception ex = null)
\n {
\n var fullMsg = ex == null ? msg : $"{msg}\\\\r\\\\n\u5f02\u5e38\u4fe1\u606f：{ex.Message}\\\\r\\\\n\u5806\u6808\u8ddf\u8e2a：{ex.StackTrace}";
\n WriteLog("ERROR", fullMsg);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u5199\u5165\u65e5\u5fd7\u6587\u4ef6
\n \/\/\/ <\/summary>
\n private static void WriteLog(string level, string msg)
\n {
\n var logContent = $"[{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}] [{level}] {msg}\\\\r\\\\n";
\n \/\/ \u63a7\u5236\u53f0\u8f93\u51fa
\n Console.WriteLine(logContent);
\n \/\/ \u6587\u4ef6\u8f93\u51fa（\u6309\u65e5\u671f\u5206\u6587\u4ef6）
\n var logFile = Path.Combine(_logDir, $"MesErp_ProcessDelegate_{DateTime.Now:yyyyMMdd}.log");
\n try
\n {
\n File.AppendAllText(logFile, logContent, System.Text.Encoding.UTF8);
\n }
\n catch
\n {
\n \/\/ \u5ffd\u7565\u65e5\u5fd7\u5199\u5165\u5f02\u5e38，\u907f\u514d\u5f71\u54cd\u4e3b\u6d41\u7a0b
\n }
\n }
\n}<\/p>\n
\u516d\u3001WinForm \u754c\u9762\u5b9e\u73b0（\u53ef\u89c6\u5316\u4e2d\u95f4\u4ef6）<\/h3>\n
\u8bbe\u8ba1\u7b80\u6d01\u6613\u7528\u7684 WinForm \u754c\u9762，\u5b9e\u73b0ERP \u5de5\u5355\u5bfc\u5165 \/ \u5de5\u827a\u8def\u7ebf\u914d\u7f6e \/ \u59d4\u6258\u62fc\u63a5 \/ \u6d41\u7a0b\u542f\u52a8 \/ \u540e\u53f0\u8fd0\u884c \/ \u72b6\u6001\u76d1\u63a7 \/ \u65e5\u5fd7\u67e5\u770b\u5168\u529f\u80fd，\u652f\u6301\u8de8\u7ebf\u7a0b UI \u72b6\u6001\u540c\u6b65：<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u4e2d\u95f4\u4ef6\u4e3b\u754c\u9762
\n\/\/\/ \u6838\u5fc3\u529f\u80fd：\u5de5\u5355\u7ba1\u7406\u3001\u5de5\u827a\u8def\u7ebf\u914d\u7f6e\u3001\u59d4\u6258\u62fc\u63a5\u3001\u6d41\u7a0b\u6267\u884c\u3001\u540e\u53f0\u8fd0\u884c\u3001\u72b6\u6001\u76d1\u63a7\u3001\u65e5\u5fd7\u67e5\u770b
\n\/\/\/ <\/summary>
\npublic partial class MainForm : Form
\n{
\n #region \u670d\u52a1\u5b9e\u4f8b
\n private readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;
\n private readonly ProcessDelegateManager _delegateManager = ProcessDelegateManager.Instance;
\n private readonly ProcessFlowEngine _flowEngine = ProcessFlowEngine.Instance;
\n private readonly ProcessFlowBackendService _backendService = new ProcessFlowBackendService();
\n private readonly NotifyIcon _notifyIcon = new NotifyIcon();
\n #endregion<\/p>\n
#region \u754c\u9762\u63a7\u4ef6
\n private ComboBox cboWorkOrder;
\n private Button btnAddOrder;
\n private Button btnAddProcess;
\n private Button btnCombineDelegate;
\n private Button btnStartFlow;
\n private Button btnPauseFlow;
\n private Button btnStopFlow;
\n private DataGridView dgvProcessRoute;
\n private DataGridView dgvRunningFlow;
\n private TextBox txtLog;
\n private Label lblBackendStatus;
\n private ComboBox cboExecuteMode;
\n #endregion<\/p>\n
public MainForm()
\n {
\n InitializeComponent();
\n \/\/ \u521d\u59cb\u5316UI
\n InitMainUI();
\n \/\/ \u6ce8\u518c\u540e\u53f0\u670d\u52a1\u59d4\u6258（UI\u72b6\u6001\u540c\u6b65+\u65e5\u5fd7）
\n RegisterBackendServiceDelegates();
\n \/\/ \u6ce8\u518c\u7cfb\u7edf\u6258\u76d8（\u540e\u53f0\u8fd0\u884c）
\n _backendService.RegisterSystemTray(this, _notifyIcon);
\n \/\/ \u52a0\u8f7d\u521d\u59cb\u6570\u636e
\n LoadInitData();
\n }<\/p>\n
#region UI\u521d\u59cb\u5316
\n private void InitMainUI()
\n {
\n \/\/ \u7a97\u4f53\u57fa\u7840\u8bbe\u7f6e
\n this.Text = "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u4e2d\u95f4\u4ef6\u670d\u52a1";
\n this.Size = new Size(1000, 600);
\n this.StartPosition = FormStartPosition.CenterScreen;
\n this.FormClosing += (s, e) => { _notifyIcon.Visible = false; };<\/p>\n
\/\/ \u63a7\u4ef6\u521d\u59cb\u5316
\n cboWorkOrder = new ComboBox { Location = new Point(10, 10), Size = new Size(200, 23), DropDownStyle = ComboBoxStyle.DropDownList };
\n btnAddOrder = new Button { Location = new Point(220, 10), Size = new Size(80, 23), Text = "\u65b0\u589e\u5de5\u5355" };
\n btnAddProcess = new Button { Location = new Point(310, 10), Size = new Size(80, 23), Text = "\u65b0\u589e\u5de5\u5e8f" };
\n btnCombineDelegate = new Button { Location = new Point(400, 10), Size = new Size(100, 23), Text = "\u59d4\u6258\u62fc\u63a5" };
\n cboExecuteMode = new ComboBox { Location = new Point(510, 10), Size = new Size(120, 23), DataSource = Enum.GetValues(typeof(FlowExecuteMode)) };
\n btnStartFlow = new Button { Location = new Point(640, 10), Size = new Size(80, 23), Text = "\u542f\u52a8\u6d41\u7a0b", BackColor = Color.LightGreen };
\n btnPauseFlow = new Button { Location = new Point(730, 10), Size = new Size(80, 23), Text = "\u6682\u505c\u6d41\u7a0b", BackColor = Color.Orange };
\n btnStopFlow = new Button { Location = new Point(820, 10), Size = new Size(80, 23), Text = "\u7ec8\u6b62\u6d41\u7a0b", BackColor = Color.LightPink };
\n lblBackendStatus = new Label { Location = new Point(910, 10), Size = new Size(80, 23), Text = "\u540e\u53f0\u72b6\u6001：\u7a7a\u95f2" };<\/p>\n
\/\/ \u5de5\u827a\u8def\u7ebf\u7f51\u683c
\n dgvProcessRoute = new DataGridView { Location = new Point(10, 40), Size = new Size(980, 200), ReadOnly = true, AllowUserToAddRows = false };
\n dgvProcessRoute.Columns.AddRange(new[]
\n {
\n new DataGridViewTextBoxColumn { Name = "ProcessCode", HeaderText = "\u5de5\u5e8f\u7f16\u7801", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "ProcessName", HeaderText = "\u5de5\u5e8f\u540d\u79f0", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "SortNo", HeaderText = "\u6267\u884c\u987a\u5e8f", Width = 80 },
\n new DataGridViewTextBoxColumn { Name = "Status", HeaderText = "\u5de5\u5e8f\u72b6\u6001", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "CompleteQty", HeaderText = "\u5b8c\u6210\u4ea7\u91cf", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "DelegateCombine", HeaderText = "\u59d4\u6258\u7ec4\u5408", Width = 200 },
\n new DataGridViewTextBoxColumn { Name = "Params", HeaderText = "\u5de5\u5e8f\u53c2\u6570", Width = 300 }
\n });<\/p>\n
\/\/ \u8fd0\u884c\u6d41\u7a0b\u7f51\u683c
\n dgvRunningFlow = new DataGridView { Location = new Point(10, 250), Size = new Size(980, 100), ReadOnly = true, AllowUserToAddRows = false };
\n dgvRunningFlow.Columns.AddRange(new[]
\n {
\n new DataGridViewTextBoxColumn { Name = "FlowName", HeaderText = "\u6d41\u7a0b\u540d\u79f0", Width = 200 },
\n new DataGridViewTextBoxColumn { Name = "OrderNo", HeaderText = "\u5173\u8054\u5de5\u5355", Width = 150 },
\n new DataGridViewTextBoxColumn { Name = "ExecuteMode", HeaderText = "\u6267\u884c\u6a21\u5f0f", Width = 150 },
\n new DataGridViewTextBoxColumn { Name = "Status", HeaderText = "\u6d41\u7a0b\u72b6\u6001", Width = 150 },
\n new DataGridViewTextBoxColumn { Name = "CurrentProcess", HeaderText = "\u5f53\u524d\u5de5\u5e8f", Width = 200 },
\n new DataGridViewTextBoxColumn { Name = "CompleteQty", HeaderText = "\u5b8c\u6210\u4ea7\u91cf", Width = 130 }
\n });<\/p>\n
\/\/ \u65e5\u5fd7\u6587\u672c\u6846
\n txtLog = new TextBox { Location = new Point(10, 360), Size = new Size(980, 220), Multiline = true, ReadOnly = true, ScrollBars = ScrollBars.Vertical };<\/p>\n
\/\/ \u7ed1\u5b9a\u63a7\u4ef6\u4e8b\u4ef6
\n btnAddOrder.Click += BtnAddOrder_Click;
\n btnAddProcess.Click += BtnAddProcess_Click;
\n btnCombineDelegate.Click += BtnCombineDelegate_Click;
\n btnStartFlow.Click += BtnStartFlow_Click;
\n btnPauseFlow.Click += BtnPauseFlow_Click;
\n btnStopFlow.Click += BtnStopFlow_Click;
\n cboWorkOrder.SelectedIndexChanged += CboWorkOrder_SelectedIndexChanged;<\/p>\n
\/\/ \u6dfb\u52a0\u63a7\u4ef6\u5230\u7a97\u4f53
\n this.Controls.AddRange(new Control[] { cboWorkOrder, btnAddOrder, btnAddProcess, btnCombineDelegate, cboExecuteMode,
\n btnStartFlow, btnPauseFlow, btnStopFlow, lblBackendStatus, dgvProcessRoute, dgvRunningFlow, txtLog });
\n }
\n #endregion<\/p>\n
#region \u59d4\u6258\u6ce8\u518c（\u8de8\u7ebf\u7a0bUI\u540c\u6b65）
\n private void RegisterBackendServiceDelegates()
\n {
\n \/\/ \u540e\u53f0\u670d\u52a1\u72b6\u6001\u66f4\u65b0
\n _backendService.UiStatusUpdateAction = (flowName, status) =>
\n {
\n if (this.InvokeRequired)
\n this.Invoke(new Action<string, string>((f, s) => { lblBackendStatus.Text = $"\u540e\u53f0\u72b6\u6001：{s}"; }), flowName, status);
\n else
\n lblBackendStatus.Text = $"\u540e\u53f0\u72b6\u6001：{status}";
\n };<\/p>\n
\/\/ \u540e\u53f0\u670d\u52a1\u65e5\u5fd7\u540c\u6b65\u5230UI
\n _backendService.BackendLogAction = (log) =>
\n {
\n if (txtLog.InvokeRequired)
\n txtLog.Invoke(new Action<string>(AddLogToUi), log);
\n else
\n AddLogToUi(log);
\n };<\/p>\n
\/\/ \u5168\u5c40\u65e5\u5fd7\u540c\u6b65\u5230UI
\n typeof(LogHelper).GetField("_logDir", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Static);
\n LogHelper.Info("UI\u59d4\u6258\u6ce8\u518c\u6210\u529f，\u652f\u6301\u8de8\u7ebf\u7a0b\u72b6\u6001\u540c\u6b65");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6dfb\u52a0\u65e5\u5fd7\u5230UI\u6587\u672c\u6846
\n \/\/\/ <\/summary>
\n private void AddLogToUi(string log)
\n {
\n txtLog.AppendText($"[{DateTime.Now:HH:mm:ss.fff}] {log}\\\\r\\\\n");
\n txtLog.ScrollToCaret();
\n }
\n #endregion<\/p>\n
#region \u6570\u636e\u52a0\u8f7d
\n private void LoadInitData()
\n {
\n \/\/ \u52a0\u8f7dERP\u5de5\u5355\u5230\u4e0b\u62c9\u6846
\n var orders = _dbHelper.QueryList<ErpWorkOrder>("SELECT * FROM ErpWorkOrder");
\n cboWorkOrder.DataSource = orders;
\n cboWorkOrder.DisplayMember = "OrderNo";
\n cboWorkOrder.ValueMember = "OrderNo";<\/p>\n
AddLogToUi("\u521d\u59cb\u6570\u636e\u52a0\u8f7d\u5b8c\u6210，\u5de5\u5355\u6570\u91cf：" + orders.Count);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u52a0\u8f7d\u9009\u4e2d\u5de5\u5355\u7684\u5de5\u827a\u8def\u7ebf
\n \/\/\/ <\/summary>
\n private void LoadProcessRoute(string orderNo)
\n {
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n if (route == null) return;<\/p>\n
dgvProcessRoute.Rows.Clear();
\n foreach (var process in route.ProcessNodes.OrderBy(p => p.SortNo))
\n {
\n var row = dgvProcessRoute.Rows.Add();
\n dgvProcessRoute.Rows[row].Cells["ProcessCode"].Value = process.ProcessCode;
\n dgvProcessRoute.Rows[row].Cells["ProcessName"].Value = process.ProcessName;
\n dgvProcessRoute.Rows[row].Cells["SortNo"].Value = process.SortNo;
\n dgvProcessRoute.Rows[row].Cells["Status"].Value = process.Status;
\n dgvProcessRoute.Rows[row].Cells["CompleteQty"].Value = process.CompleteQty;
\n dgvProcessRoute.Rows[row].Cells["DelegateCombine"].Value = process.DelegateCombineId;
\n dgvProcessRoute.Rows[row].Cells["Params"].Value = JsonConvert.SerializeObject(process.Params);
\n }
\n }
\n #endregion<\/p>\n
#region \u754c\u9762\u4e8b\u4ef6\u5904\u7406（\u6838\u5fc3\u529f\u80fd）
\n \/\/\/ <summary>
\n \/\/\/ \u65b0\u589eERP\u5de5\u5355
\n \/\/\/ <\/summary>
\n private void BtnAddOrder_Click(object sender, EventArgs e)
\n {
\n var order = new ErpWorkOrder
\n {
\n OrderNo = "WO-" + DateTime.Now.ToString("yyyyMMddHHmmss"),
\n ProductCode = "PROD-" + new Random().Next(1000, 9999),
\n ProductName = "\u6d4b\u8bd5\u4ea7\u54c1-" + new Random().Next(100, 999),
\n PlanQty = 1000,
\n LineCode = "LINE-001"
\n };
\n _dbHelper.SaveObject("ErpWorkOrder", "OrderNo", order);
\n \/\/ \u521d\u59cb\u5316\u5de5\u827a\u8def\u7ebf
\n var route = new ProcessRoute { OrderNo = order.OrderNo, LineCode = order.LineCode };
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);<\/p>\n
LoadInitData();
\n AddLogToUi($"\u65b0\u589eERP\u5de5\u5355\u6210\u529f：{order.OrderNo}，\u4ea7\u54c1：{order.ProductName}，\u8ba1\u5212\u4ea7\u91cf：{order.PlanQty}\u4ef6");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u65b0\u589e\u5de5\u5e8f\u8282\u70b9
\n \/\/\/ <\/summary>
\n private void BtnAddProcess_Click(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue == null)
\n {
\n MessageBox.Show("\u8bf7\u5148\u9009\u62e9\u5de5\u5355！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\n
var orderNo = cboWorkOrder.SelectedValue.ToString();
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n if (route == null) route = new ProcessRoute { OrderNo = orderNo };<\/p>\n
var process = new ProcessNode
\n {
\n ProcessCode = "PROC-" + new Random().Next(1000, 9999),
\n ProcessName = "\u6d4b\u8bd5\u5de5\u5e8f-" + new Random().Next(100, 999),
\n SortNo = route.ProcessNodes.Count + 1,
\n Status = ProcessStatus.UnInitialized
\n };
\n route.ProcessNodes.Add(process);
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);<\/p>\n
LoadProcessRoute(orderNo);
\n AddLogToUi($"\u65b0\u589e\u5de5\u5e8f\u6210\u529f：{process.ProcessCode}，\u5de5\u5e8f\u540d\u79f0：{process.ProcessName}，\u6267\u884c\u987a\u5e8f：{process.SortNo}");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u59d4\u6258\u62fc\u63a5（\u57fa\u7840\u59d4\u6258->\u5de5\u5e8f\u7ec4\u5408\u59d4\u6258）
\n \/\/\/ <\/summary>
\n private void BtnCombineDelegate_Click(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue == null || dgvProcessRoute.SelectedRows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u9009\u62e9\u5de5\u5355\u548c\u5de5\u5e8f！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\n
var orderNo = cboWorkOrder.SelectedValue.ToString();
\n var processRow = dgvProcessRoute.SelectedRows[0];
\n var processCode = processRow.Cells["ProcessCode"].Value.ToString();
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n var process = route.ProcessNodes.First(p => p.ProcessCode == processCode);<\/p>\n
\/\/ \u83b7\u53d6\u6240\u6709\u57fa\u7840\u59d4\u6258（\u7b80\u5316\u7248，\u5b9e\u9645\u53ef\u505a\u53ef\u89c6\u5316\u9009\u62e9）
\n var allBaseDelegates = _delegateManager.GetType().GetField("_baseDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, BaseDelegateInfo>;
\n var selectBaseDelegates = allBaseDelegates.Values.Take(2).ToList(); \/\/ \u9009\u62e9\u524d2\u4e2a\u57fa\u7840\u59d4\u6258<\/p>\n
\/\/ \u62fc\u63a5\u5de5\u5e8f\u7ea7\u59d4\u6258\u7ec4\u5408（\u4e32\u884c\u6267\u884c）
\n var combine = _delegateManager.CombineProcessDelegates($"{processCode}\u59d4\u6258\u7ec4\u5408", DelegateCombineType.Serial, selectBaseDelegates);
\n \/\/ \u7ed1\u5b9a\u5230\u5de5\u5e8f\u8282\u70b9
\n process.DelegateCombineId = combine.CombineId;
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);<\/p>\n
LoadProcessRoute(orderNo);
\n AddLogToUi($"\u5de5\u5e8f{processCode}\u59d4\u6258\u62fc\u63a5\u6210\u529f，\u7ed1\u5b9a\u7ec4\u5408ID：{combine.CombineId}，\u5305\u542b{selectBaseDelegates.Count}\u4e2a\u57fa\u7840\u59d4\u6258");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u542f\u52a8\u5de5\u5e8f\u6d41\u7a0b（UI\/\u540e\u53f0\u6a21\u5f0f\u53ef\u9009）
\n \/\/\/ <\/summary>
\n private void BtnStartFlow_Click(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue == null || dgvProcessRoute.Rows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u5148\u914d\u7f6e\u5de5\u5355\u548c\u5de5\u5e8f！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\n
var orderNo = cboWorkOrder.SelectedValue.ToString();
\n var order = _dbHelper.GetObject<ErpWorkOrder>("ErpWorkOrder", "OrderNo", orderNo);
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n var executeMode = (FlowExecuteMode)cboExecuteMode.SelectedValue;<\/p>\n
\/\/ \u62fc\u63a5\u4ea7\u7ebf\u7ea7\u6d41\u7a0b\u59d4\u6258
\n var processCombines = route.ProcessNodes.Where(p => !string.IsNullOrEmpty(p.DelegateCombineId))
\n .Select(p => _delegateManager.GetProcessCombineByProcessId(p.ProcessId, route)).ToList();
\n var flowCombine = _delegateManager.CombineFlowDelegates($"{orderNo}\u6d41\u7a0b", route.RouteId, processCombines, executeMode);<\/p>\n
\/\/ \u6267\u884c\u6d41\u7a0b（UI\u6a21\u5f0f\/\u540e\u53f0\u6a21\u5f0f）
\n if (executeMode == FlowExecuteMode.WinFormUI)
\n {
\n _flowEngine.StartFlowAsync(flowCombine, order, route);
\n AddLogToUi($"UI\u6a21\u5f0f\u542f\u52a8\u6d41\u7a0b：{flowCombine.FlowName}，\u5de5\u5355：{orderNo}");
\n }
\n else
\n {
\n _backendService.RunFlowInBackend(flowCombine, order, route);
\n AddLogToUi($"\u540e\u53f0\u6a21\u5f0f\u542f\u52a8\u6d41\u7a0b：{flowCombine.FlowName}，\u5de5\u5355：{orderNo}，\u540e\u53f0\u670d\u52a1\u5df2\u63a5\u7ba1");
\n }<\/p>\n
\/\/ \u66f4\u65b0\u8fd0\u884c\u6d41\u7a0b\u7f51\u683c
\n UpdateRunningFlowGrid(flowCombine, order, route);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u6682\u505c\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n private void BtnPauseFlow_Click(object sender, EventArgs e)
\n {
\n if (dgvRunningFlow.SelectedRows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u9009\u62e9\u8fd0\u884c\u4e2d\u7684\u6d41\u7a0b！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\n
var flowName = dgvRunningFlow.SelectedRows[0].Cells["FlowName"].Value.ToString();
\n var flowCombine = _delegateManager.GetType().GetField("_flowCombineDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, FlowDelegateCombineInfo>;
\n var flow = flowCombine.Values.First(f => f.FlowName == flowName);<\/p>\n
_flowEngine.PauseFlow(flow.FlowCombineId);
\n AddLogToUi($"\u6682\u505c\u6d41\u7a0b：{flowName}，\u6d41\u7a0bID：{flow.FlowCombineId}");
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u7ec8\u6b62\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n private void BtnStopFlow_Click(object sender, EventArgs e)
\n {
\n if (dgvRunningFlow.SelectedRows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u9009\u62e9\u8fd0\u884c\u4e2d\u7684\u6d41\u7a0b！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\n
var flowName = dgvRunningFlow.SelectedRows[0].Cells["FlowName"].Value.ToString();
\n var flowCombine = _delegateManager.GetType().GetField("_flowCombineDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, FlowDelegateCombineInfo>;
\n var flow = flowCombine.Values.First(f => f.FlowName == flowName);<\/p>\n
_flowEngine.StopFlow(flow.FlowCombineId);
\n AddLogToUi($"\u7ec8\u6b62\u6d41\u7a0b：{flowName}，\u6d41\u7a0bID：{flow.FlowCombineId}");
\n dgvRunningFlow.Rows.Remove(dgvRunningFlow.SelectedRows[0]);
\n }<\/p>\n
\/\/\/ <summary>
\n \/\/\/ \u5de5\u5355\u9009\u62e9\u53d8\u66f4，\u52a0\u8f7d\u5bf9\u5e94\u5de5\u827a\u8def\u7ebf
\n \/\/\/ <\/summary>
\n private void CboWorkOrder_SelectedIndexChanged(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue != null)
\n LoadProcessRoute(cboWorkOrder.SelectedValue.ToString());
\n }
\n #endregion<\/p>\n
#region UI\u8f85\u52a9\u65b9\u6cd5
\n \/\/\/ <summary>
\n \/\/\/ \u66f4\u65b0\u8fd0\u884c\u6d41\u7a0b\u7f51\u683c
\n \/\/\/ <\/summary>
\n private void UpdateRunningFlowGrid(FlowDelegateCombineInfo flowCombine, ErpWorkOrder order, ProcessRoute route)
\n {
\n var row = dgvRunningFlow.Rows.Add();
\n dgvRunningFlow.Rows[row].Cells["FlowName"].Value = flowCombine.FlowName;
\n dgvRunningFlow.Rows[row].Cells["OrderNo"].Value = order.OrderNo;
\n dgvRunningFlow.Rows[row].Cells["ExecuteMode"].Value = flowCombine.ExecuteMode;
\n dgvRunningFlow.Rows[row].Cells["Status"].Value = "\u6267\u884c\u4e2d";
\n dgvRunningFlow.Rows[row].Cells["CurrentProcess"].Value = route.ProcessNodes[route.CurrentProcessIndex].ProcessCode;
\n dgvRunningFlow.Rows[row].Cells["CompleteQty"].Value = order.CompleteQty;
\n }
\n #endregion<\/p>\n
\/\/ \u8bbe\u8ba1\u5668\u4ee3\u7801（\u81ea\u52a8\u751f\u6210，\u65e0\u9700\u624b\u52a8\u7f16\u5199）
\n private void InitializeComponent()
\n {
\n this.SuspendLayout();
\n this.ClientSize = new System.Drawing.Size(1000, 600);
\n this.Name = "MainForm";
\n this.Text = "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u4e2d\u95f4\u4ef6\u670d\u52a1";
\n this.ResumeLayout(false);
\n }
\n}<\/p>\n
\/\/ \u7a0b\u5e8f\u5165\u53e3
\nstatic class Program
\n{
\n [STAThread]
\n static void Main()
\n {
\n Application.EnableVisualStyles();
\n Application.SetCompatibleTextRenderingDefault(false);
\n Application.Run(new MainForm());
\n }
\n}<\/p>\n
\u4e03\u3001\u90e8\u7f72\u4e0e\u4f7f\u7528\u8bf4\u660e<\/h3>\n1. \u90e8\u7f72\u6b65\u9aa4<\/h4>\n
- \u521b\u5efa\u9879\u76ee：\u5728 Visual Studio 2022 \u4e2d\u521b\u5efa\u300cWindows \u7a97\u4f53\u5e94\u7528（.NET Framework 4.8）\u300d\u9879\u76ee；<\/li>\n
- \u5b89\u88c5 NuGet \u5305：\u6267\u884c\u524d\u7f6e\u51c6\u5907\u4e2d\u7684 NuGet \u5b89\u88c5\u547d\u4ee4，\u5b89\u88c5\u6240\u6709\u4f9d\u8d56；<\/li>\n
- \u6dfb\u52a0\u4ee3\u7801：\u5c06\u4e0a\u8ff0\u6240\u6709\u4ee3\u7801\u6309\u7c7b\u62c6\u5206\u5230\u5bf9\u5e94\u6587\u4ef6\u4e2d（\u6216\u76f4\u63a5\u590d\u5236\u5230 Program.cs，\u5220\u9664\u539f\u6709\u4ee3\u7801）；<\/li>\n
- \u7f16\u8bd1\u9879\u76ee：\u751f\u6210 EXE \u53ef\u6267\u884c\u6587\u4ef6（\u9ed8\u8ba4\u5728 bin\/Debug\/ \u4e0b）；<\/li>\n
- \u76f4\u63a5\u8fd0\u884c：\u65e0\u9700\u5b89\u88c5\u6570\u636e\u5e93 \/ ERP\/MES \u73af\u5883，\u8fd0\u884c EXE \u5373\u53ef，\u7a0b\u5e8f\u4f1a\u81ea\u52a8\u521b\u5efa\u672c\u5730\u6570\u636e\u5e93\u548c\u65e5\u5fd7\u76ee\u5f55\u3002<\/li>\n
2. \u6838\u5fc3\u529f\u80fd\u64cd\u4f5c\u6d41\u7a0b<\/h4>\n
- \u65b0\u589e ERP \u5de5\u5355：\u70b9\u51fb\u300c\u65b0\u589e\u5de5\u5355\u300d，\u7a0b\u5e8f\u81ea\u52a8\u751f\u6210\u6807\u51c6\u5316 ERP \u5de5\u5355（\u5305\u542b\u5de5\u5355\u53f7\u3001\u4ea7\u54c1\u3001\u8ba1\u5212\u4ea7\u91cf）；<\/li>\n
- \u65b0\u589e\u5de5\u5e8f\u8282\u70b9：\u9009\u62e9\u5de5\u5355，\u70b9\u51fb\u300c\u65b0\u589e\u5de5\u5e8f\u300d，\u751f\u6210\u5de5\u5e8f\u8282\u70b9\u5e76\u6dfb\u52a0\u5230\u5de5\u827a\u8def\u7ebf；<\/li>\n
- \u59d4\u6258\u62fc\u63a5：\u9009\u62e9\u5de5\u5e8f，\u70b9\u51fb\u300c\u59d4\u6258\u62fc\u63a5\u300d，\u7a0b\u5e8f\u81ea\u52a8\u5c06\u901a\u7528\u9ed8\u8ba4\u57fa\u7840\u59d4\u6258\u62fc\u63a5\u6210\u5de5\u5e8f\u7ea7\u7ec4\u5408\u59d4\u6258\u5e76\u7ed1\u5b9a\u5230\u5de5\u5e8f；<\/li>\n
- \u9009\u62e9\u6267\u884c\u6a21\u5f0f：\u4e0b\u62c9\u6846\u9009\u62e9\u300cWinFormUI\u300d（\u5e26 UI \u8fdb\u5ea6\u53cd\u9988）\u6216\u300cBackendService\u300d（\u540e\u53f0\u65e0 UI \u963b\u585e\u8fd0\u884c）；<\/li>\n
- \u542f\u52a8\u6d41\u7a0b：\u70b9\u51fb\u300c\u542f\u52a8\u6d41\u7a0b\u300d，\u7a0b\u5e8f\u81ea\u52a8\u62fc\u63a5\u4ea7\u7ebf\u7ea7\u6d41\u7a0b\u59d4\u6258\u5e76\u6267\u884c，\u65e5\u5fd7\u5b9e\u65f6\u540c\u6b65\u5230 UI；<\/li>\n
- \u6d41\u7a0b\u63a7\u5236：\u70b9\u51fb\u300c\u6682\u505c\u6d41\u7a0b \/ \u7ec8\u6b62\u6d41\u7a0b\u300d，\u53ef\u5bf9\u8fd0\u884c\u4e2d\u7684\u6d41\u7a0b\u8fdb\u884c\u7ba1\u63a7；<\/li>\n
- \u540e\u53f0\u8fd0\u884c：\u5c06\u7a97\u4f53\u6700\u5c0f\u5316，\u7a0b\u5e8f\u81ea\u52a8\u9690\u85cf\u5230\u7cfb\u7edf\u6258\u76d8，\u540e\u53f0\u7ee7\u7eed\u6267\u884c\u6d41\u7a0b\u3002<\/li>\n
3. \u4e0e\u5b9e\u9645 MES\/ERP \u5bf9\u63a5\u6269\u5c55<\/h4>\n
- ERP \u5de5\u5355\u5bfc\u5165：\u4fee\u6539BtnAddOrder_Click\u65b9\u6cd5，\u6dfb\u52a0 ERP \u63a5\u53e3\u8c03\u7528\u4ee3\u7801（\u5982 WebAPI\/WS\/SQL），\u5b9e\u73b0\u4ece\u5b9e\u9645 ERP \u7cfb\u7edf\u5bfc\u5165\u5de5\u5355；<\/li>\n
- MES \u6570\u636e\u4ea4\u4e92：\u6269\u5c55DefaultDelegates\u7c7b，\u6dfb\u52a0 MES \u63a5\u53e3\u59d4\u6258（\u5982 MES \u5de5\u5e8f\u72b6\u6001\u4e0a\u62a5\u3001MES \u4ea7\u91cf\u540c\u6b65）；<\/li>\n
- \u8bbe\u5907\u5bf9\u63a5：\u5728\u57fa\u7840\u59d4\u6258\u4e2d\u6dfb\u52a0 PLC \/ \u4f20\u611f\u5668 \/ \u673a\u5668\u4eba\u901a\u4fe1\u4ee3\u7801（\u5982S7.Net\u3001Modbus\u3001OPC UA），\u5b9e\u73b0\u5de5\u5e8f\u6267\u884c\u7684\u8bbe\u5907\u63a7\u5236；<\/li>\n
- \u590d\u6742\u8868\u8fbe\u5f0f：\u96c6\u6210 NCalc\/EL \u8868\u8fbe\u5f0f\u5f15\u64ce，\u66ff\u6362EvaluateConditionalExpr\u65b9\u6cd5，\u652f\u6301\u590d\u6742\u7684\u59d4\u6258\u6761\u4ef6\u6267\u884c\u8868\u8fbe\u5f0f；<\/li>\n
- \u53ef\u89c6\u5316\u59d4\u6258\u914d\u7f6e：\u65b0\u589e\u59d4\u6258\u914d\u7f6e\u7a97\u4f53，\u5b9e\u73b0\u57fa\u7840\u59d4\u6258\u7684\u53ef\u89c6\u5316\u9009\u62e9\u3001\u53c2\u6570\u914d\u7f6e\u3001\u62fc\u63a5\u89c4\u5219\u8bbe\u7f6e\u3002<\/li>\n
\u516b\u3001\u6838\u5fc3\u4f18\u52bf\u4e0e\u603b\u7ed3<\/h3>\n\u6838\u5fc3\u4f18\u52bf<\/h4>\n
- \u59d4\u6258\u591a\u7ed3\u6784\u62fc\u63a5：\u72ec\u521b\u300c\u57fa\u7840\u59d4\u6258 + \u5de5\u5e8f\u7ec4\u5408\u59d4\u6258 + \u6d41\u7a0b\u62fc\u63a5\u59d4\u6258\u300d\u4e09\u7ea7\u4f53\u7cfb，\u652f\u6301\u4efb\u610f\u5de5\u5e8f\u6d41\u7a0b\u7ed3\u6784，\u9002\u914d MES\/ERP \u7684\u4e2a\u6027\u5316\u5de5\u827a\u8def\u7ebf；<\/li>\n
- \u4e1a\u52a1\u4e0e UI \u5b8c\u5168\u89e3\u8026：\u59d4\u6258\u51fd\u6570\u5c01\u88c5\u6240\u6709\u4e1a\u52a1\u903b\u8f91，UI \u5c42\u4ec5\u8d1f\u8d23\u5c55\u793a\u548c\u64cd\u4f5c，\u4fee\u6539\u4e1a\u52a1\u903b\u8f91\u65e0\u9700\u6539\u52a8 UI \u4ee3\u7801；<\/li>\n
- \u540e\u53f0\u670d\u52a1\u5316\u80fd\u529b：\u652f\u6301 WinForm UI \u6267\u884c\u548c\u540e\u53f0\u65e0 UI \u963b\u585e\u6267\u884c，\u6700\u5c0f\u5316\u5230\u7cfb\u7edf\u6258\u76d8，\u9002\u914d\u4ea7\u7ebf 7*24 \u5c0f\u65f6\u8fd0\u884c\u9700\u6c42；<\/li>\n
- \u914d\u7f6e\u6301\u4e45\u5316：\u57fa\u4e8e SQLite \u672c\u5730\u6570\u636e\u5e93，\u59d4\u6258\u62fc\u63a5\u5173\u7cfb\u3001\u5de5\u5355\u3001\u5de5\u827a\u8def\u7ebf\u3001\u5de5\u5e8f\u72b6\u6001\u5168\u6301\u4e45\u5316，\u7a0b\u5e8f\u91cd\u542f\u4e0d\u4e22\u5931；<\/li>\n
- \u9ad8\u6269\u5c55\u6027：\u9ed8\u8ba4\u63d0\u4f9b MES\/ERP \u901a\u7528\u57fa\u7840\u59d4\u6258，\u652f\u6301\u81ea\u5b9a\u4e49\u57fa\u7840\u59d4\u6258\u6ce8\u518c\u3001\u59d4\u6258\u7ec4\u5408\u89c4\u5219\u4fee\u6539\u3001\u8bbe\u5907 \/ \u7cfb\u7edf\u63a5\u53e3\u6269\u5c55；<\/li>\n
- \u7ebf\u7a0b\u5b89\u5168：\u5168\u6d41\u7a0b\u52a0\u9501 + \u5f02\u6b65\u6267\u884c + \u53d6\u6d88\u4ee4\u724c，\u652f\u6301\u591a\u6d41\u7a0b\u5e76\u53d1\u6267\u884c，\u65e0\u8d44\u6e90\u7ade\u4e89\u548c UI \u963b\u585e\u95ee\u9898\u3002<\/li>\n
\u5173\u952e\u70b9\u56de\u987e<\/h4>\n
- \u56f4\u7ed5MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u751f\u547d\u5468\u671f\u5c01\u88c5\u6807\u51c6\u5316\u4e8b\u4ef6\u59d4\u6258，\u8986\u76d6\u4ece\u6d41\u7a0b\u542f\u52a8\u5230\u5b8c\u6210\u7684\u5168\u8282\u70b9；<\/li>\n
- \u91c7\u7528\u4e09\u7ea7\u59d4\u6258\u62fc\u63a5\u8bbe\u8ba1，\u5b9e\u73b0\u539f\u5b50\u64cd\u4f5c\u5230\u5b8c\u6574\u6d41\u7a0b\u7684\u65e0\u9650\u7ec4\u5408，\u89e3\u51b3\u5de5\u5e8f\u6d41\u7a0b\u914d\u7f6e\u5316\u95ee\u9898；<\/li>\n
- \u8bbe\u8ba1\u540e\u53f0\u670d\u52a1\u7ba1\u7406\u5668，\u5b9e\u73b0 WinForm \u754c\u9762\u4e0e\u540e\u53f0\u6267\u884c\u89e3\u8026，\u652f\u6301\u7cfb\u7edf\u6258\u76d8\u540e\u53f0\u8fd0\u884c；<\/li>\n
- \u57fa\u4e8eSQLite \u672c\u5730\u6570\u636e\u5e93\u5b9e\u73b0\u914d\u7f6e\u548c\u72b6\u6001\u6301\u4e45\u5316，\u964d\u4f4e\u90e8\u7f72\u4f9d\u8d56，\u9002\u914d\u4ea7\u7ebf\u8fb9\u7f18\u8282\u70b9；<\/li>\n
- \u63d0\u4f9b\u5f00\u7bb1\u5373\u7528\u7684\u901a\u7528\u57fa\u7840\u59d4\u6258，\u540c\u65f6\u652f\u6301\u81ea\u5b9a\u4e49\u59d4\u6258\u6ce8\u518c，\u5feb\u901f\u5bf9\u63a5\u5b9e\u9645 MES\/ERP\/ \u8bbe\u5907\u7cfb\u7edf\u3002<\/li>\n
\u8be5\u4e2d\u95f4\u4ef6\u5b8c\u5168\u9002\u914d MES\/ERP \u7684\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u573a\u666f，\u53ef\u76f4\u63a5\u4f5c\u4e3a\u72ec\u7acb\u7684\u5de5\u5e8f\u6267\u884c\u4e2d\u95f4\u4ef6\u4f7f\u7528，\u4e5f\u53ef\u96c6\u6210\u5230\u73b0\u6709 MES\/ERP \u7cfb\u7edf\u4e2d，\u4f5c\u4e3a\u5de5\u5e8f\u6d41\u7a0b\u6267\u884c\u7684\u6838\u5fc3\u5f15\u64ce\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6
\nMES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u5c01\u88c5 WinForm \u4e2d\u95f4\u4ef6\u89e3\u51b3\u65b9\u6848
\n\u672c\u6b21\u4e3a MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6，\u6838\u5fc3\u56f4\u7ed5\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u4e8b\u4ef6（\u521d\u59cb\u5316\u3001\u542f\u52a8\u3001\u6267\u884c\u3001\u5b8c\u6210\u3001\u5f02\u5e38\u3001\u8df3\u8f6c\u7b49），\u8bbe\u8ba1\u591a\u7ed3\u6784\u62fc\u63a5\u7684\u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u57fa\u7840\u59d4\u6258\u3001\u7ec4\u5408\u59d4\u6258\u3001\u6d41\u7a0b\u59d4\u6258<\/p>\n","protected":false},"author":2,"featured_media":72578,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[7639,7638,7637],"topic":[],"class_list":["post-72579","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-7639","tag-7638","tag-7637"],"yoast_head":"\n
MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/72579.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6 MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u5c01\u88c5 WinForm \u4e2d\u95f4\u4ef6\u89e3\u51b3\u65b9\u6848 \u672c\u6b21\u4e3a MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6，\u6838\u5fc3\u56f4\u7ed5\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u4e8b\u4ef6（\u521d\u59cb\u5316\u3001\u542f\u52a8\u3001\u6267\u884c\u3001\u5b8c\u6210\u3001\u5f02\u5e38\u3001\u8df3\u8f6c\u7b49），\u8bbe\u8ba1\u591a\u7ed3\u6784\u62fc\u63a5\u7684\u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u57fa\u7840\u59d4\u6258\u3001\u7ec4\u5408\u59d4\u6258\u3001\u6d41\u7a0b\u59d4\u6258\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/72579.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-02-05T17:16:46+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260205171643-6984d07ba2b2f.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"26 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/72579.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/72579.html\",\"name\":\"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-02-05T17:16:46+00:00\",\"dateModified\":\"2026-02-05T17:16:46+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/72579.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/72579.html","og_locale":"zh_CN","og_type":"article","og_title":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6 MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u5c01\u88c5 WinForm \u4e2d\u95f4\u4ef6\u89e3\u51b3\u65b9\u6848 \u672c\u6b21\u4e3a MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6，\u6838\u5fc3\u56f4\u7ed5\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u4e8b\u4ef6（\u521d\u59cb\u5316\u3001\u542f\u52a8\u3001\u6267\u884c\u3001\u5b8c\u6210\u3001\u5f02\u5e38\u3001\u8df3\u8f6c\u7b49），\u8bbe\u8ba1\u591a\u7ed3\u6784\u62fc\u63a5\u7684\u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u57fa\u7840\u59d4\u6258\u3001\u7ec4\u5408\u59d4\u6258\u3001\u6d41\u7a0b\u59d4\u6258","og_url":"https:\/\/www.wsisp.com\/helps\/72579.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-02-05T17:16:46+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260205171643-6984d07ba2b2f.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"26 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/72579.html","url":"https:\/\/www.wsisp.com\/helps\/72579.html","name":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-02-05T17:16:46+00:00","dateModified":"2026-02-05T17:16:46+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/72579.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/72579","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=72579"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/72579\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/72578"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=72579"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=72579"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=72579"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=72579"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
- \n
- \u5f00\u53d1\u73af\u5883：.NET Framework 4.8（WinForm \u517c\u5bb9\u6027\u6700\u4f18）\u3001Visual Studio 2022+<\/li>\n
- \u6838\u5fc3 NuGet \u5305：\n
bash<\/p>\n
\u8fd0\u884c<\/p>\n
Install-Package Dapper # \u8f7b\u91cfORM，\u672c\u5730\/ERP\u6570\u636e\u4ea4\u4e92
\nInstall-Package System.Data.SQLite.Core # \u672c\u5730\u5de5\u5e8f\/\u59d4\u6258\u914d\u7f6e\u5b58\u50a8
\nInstall-Package Newtonsoft.Json # JSON\u5e8f\u5217\u5316，\u5de5\u827a\u8def\u7ebf\/\u59d4\u6258\u53c2\u6570\u89e3\u6790
\nInstall-Package System.Configuration # \u914d\u7f6e\u6587\u4ef6\u7ba1\u7406，ERP\/MES\u63a5\u53e3\u914d\u7f6e\n <\/li>\n<\/ul>\n2. \u6838\u5fc3\u679a\u4e3e（MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u6807\u51c6\u5316）<\/h4>\n
\u5c01\u88c5 MES\/ERP \u901a\u7528\u7684\u5de5\u5e8f\u3001\u6d41\u7a0b\u3001\u4e8b\u4ef6\u679a\u4e3e，\u4f5c\u4e3a\u59d4\u6258\u4e8b\u4ef6\u548c\u4e1a\u52a1\u6267\u884c\u7684\u57fa\u7840\u6807\u8bc6：<\/p>\n
using System;
\nusing System.Collections.Generic;
\nusing System.Threading;
\nusing System.Threading.Tasks;
\nusing System.Windows.Forms;
\nusing Dapper;
\nusing System.Data.SQLite;
\nusing System.IO;
\nusing Newtonsoft.Json;<\/p>\n#region MES\/ERP\u6838\u5fc3\u679a\u4e3e
\n\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6267\u884c\u72b6\u6001（MES\/ERP\u901a\u7528\u6807\u51c6）
\n\/\/\/ <\/summary>
\npublic enum ProcessStatus
\n{
\n UnInitialized = 0, \/\/ \u672a\u521d\u59cb\u5316
\n Ready = 1, \/\/ \u5c31\u7eea（\u53ef\u6267\u884c）
\n Running = 2, \/\/ \u6267\u884c\u4e2d
\n Completed = 3, \/\/ \u6267\u884c\u5b8c\u6210
\n Exception = 4, \/\/ \u6267\u884c\u5f02\u5e38
\n Paused = 5, \/\/ \u6682\u505c
\n Skipped = 6 \/\/ \u5de5\u5e8f\u8df3\u8fc7
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6\u7c7b\u578b（\u751f\u547d\u5468\u671f\u5168\u8282\u70b9，\u59d4\u6258\u7ed1\u5b9a\u6838\u5fc3）
\n\/\/\/ <\/summary>
\npublic enum ProcessFlowEventType
\n{
\n ProcessInit, \/\/ \u5de5\u5e8f\u521d\u59cb\u5316
\n ProcessStart, \/\/ \u5de5\u5e8f\u542f\u52a8
\n ProcessExec, \/\/ \u5de5\u5e8f\u6267\u884c\u4e2d（\u5b9e\u65f6）
\n ProcessComplete, \/\/ \u5de5\u5e8f\u5b8c\u6210
\n ProcessException, \/\/ \u5de5\u5e8f\u5f02\u5e38
\n ProcessRecover, \/\/ \u5f02\u5e38\u6062\u590d
\n ProcessPause, \/\/ \u5de5\u5e8f\u6682\u505c
\n ProcessResume, \/\/ \u5de5\u5e8f\u6062\u590d
\n FlowStart, \/\/ \u6d41\u7a0b\u6574\u4f53\u542f\u52a8
\n FlowComplete, \/\/ \u6d41\u7a0b\u6574\u4f53\u5b8c\u6210
\n FlowException \/\/ \u6d41\u7a0b\u6574\u4f53\u5f02\u5e38
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u59d4\u6258\u62fc\u63a5\u7c7b\u578b（\u63a7\u5236\u591a\u59d4\u6258\u6267\u884c\u903b\u8f91）
\n\/\/\/ <\/summary>
\npublic enum DelegateCombineType
\n{
\n Serial, \/\/ \u4e32\u884c\u6267\u884c（\u6309\u6ce8\u518c\u987a\u5e8f）
\n Parallel, \/\/ \u5e76\u884c\u6267\u884c（\u540c\u65f6\u89e6\u53d1）
\n Conditional \/\/ \u6761\u4ef6\u6267\u884c（\u6ee1\u8db3\u524d\u7f6e\u6761\u4ef6\u624d\u6267\u884c）
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6d41\u7a0b\u6267\u884c\u6a21\u5f0f
\n\/\/\/ <\/summary>
\npublic enum FlowExecuteMode
\n{
\n WinFormUI, \/\/ UI\u7ebf\u7a0b\u6267\u884c（\u5e26\u8fdb\u5ea6\u53cd\u9988）
\n BackendService \/\/ \u540e\u53f0\u670d\u52a1\u6267\u884c（\u65e0UI\u963b\u585e，\u63a8\u8350）
\n}
\n#endregion<\/p>\n\u4e09\u3001\u6838\u5fc3\u6a21\u578b（MES\/ERP \u5de5\u5e8f\u6d41\u7a0b + \u59d4\u6258\u5c01\u88c5）<\/h3>\n
\u8bbe\u8ba1\u4e0e ERP\/MES \u65e0\u7f1d\u5bf9\u63a5\u7684\u4e1a\u52a1\u6a21\u578b，\u540c\u65f6\u5c01\u88c5\u59d4\u6258\u62fc\u63a5\u7684\u6838\u5fc3\u6a21\u578b，\u652f\u6301\u59d4\u6258\u7684\u6ce8\u518c\u3001\u7ec4\u5408\u3001\u5b58\u50a8\u3001\u6267\u884c：<\/p>\n
#region MES\/ERP\u4e1a\u52a1\u6838\u5fc3\u6a21\u578b
\n\/\/\/ <summary>
\n\/\/\/ ERP\u5de5\u5355\u4fe1\u606f（\u4e0a\u6e38ERP\u4e0b\u53d1，MES\u6267\u884c\u4f9d\u636e）
\n\/\/\/ <\/summary>
\npublic class ErpWorkOrder
\n{
\n public string OrderNo { get; set; } \/\/ \u5de5\u5355\u53f7（ERP\u552f\u4e00\u6807\u8bc6）
\n public string ProductCode { get; set; } \/\/ \u4ea7\u54c1\u7f16\u7801
\n public string ProductName { get; set; } \/\/ \u4ea7\u54c1\u540d\u79f0
\n public int PlanQty { get; set; } \/\/ \u8ba1\u5212\u4ea7\u91cf
\n public int CompleteQty { get; set; } \/\/ \u5b8c\u6210\u4ea7\u91cf
\n public DateTime CreateTime { get; set; } = DateTime.Now; \/\/ \u5de5\u5355\u521b\u5efa\u65f6\u95f4
\n public string LineCode { get; set; } \/\/ \u7ed1\u5b9a\u4ea7\u7ebf\u7f16\u7801
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u5de5\u827a\u8def\u7ebf（ERP\u4e0b\u53d1，\u5b9a\u4e49\u5de5\u5e8f\u6267\u884c\u987a\u5e8f\u548c\u53c2\u6570）
\n\/\/\/ <\/summary>
\npublic class ProcessRoute
\n{
\n public string RouteId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u5de5\u827a\u8def\u7ebfID
\n public string OrderNo { get; set; } \/\/ \u5173\u8054\u5de5\u5355\u53f7
\n public List<ProcessNode> ProcessNodes { get; set; } = new List<ProcessNode>(); \/\/ \u5de5\u5e8f\u8282\u70b9\u5217\u8868
\n public string LineCode { get; set; } \/\/ \u4ea7\u7ebf\u7f16\u7801
\n public int CurrentProcessIndex { get; set; } = 0; \/\/ \u5f53\u524d\u6267\u884c\u5de5\u5e8f\u7d22\u5f15
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u8282\u70b9（\u5de5\u827a\u8def\u7ebf\u6700\u5c0f\u5355\u4f4d，\u7ed1\u5b9a\u59d4\u6258\u7ec4\u5408）
\n\/\/\/ <\/summary>
\npublic class ProcessNode
\n{
\n public string ProcessId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u5de5\u5e8fID
\n public string ProcessCode { get; set; } \/\/ \u5de5\u5e8f\u7f16\u7801（MES\/ERP\u6807\u51c6\u5316）
\n public string ProcessName { get; set; } \/\/ \u5de5\u5e8f\u540d\u79f0
\n public int SortNo { get; set; } \/\/ \u5de5\u5e8f\u6267\u884c\u987a\u5e8f
\n public ProcessStatus Status { get; set; } = ProcessStatus.UnInitialized; \/\/ \u5de5\u5e8f\u72b6\u6001
\n public string DelegateCombineId { get; set; } \/\/ \u7ed1\u5b9a\u7684\u59d4\u6258\u7ec4\u5408ID
\n public Dictionary<string, string> Params { get; set; } = new Dictionary<string, string>(); \/\/ \u5de5\u5e8f\u53c2\u6570（\u5982PLC\u5730\u5740\u3001\u76ee\u6807\u4ea7\u91cf）
\n public int CompleteQty { get; set; } = 0; \/\/ \u672c\u5de5\u5e8f\u5b8c\u6210\u4ea7\u91cf
\n}
\n#endregion<\/p>\n#region \u59d4\u6258\u62fc\u63a5\u6838\u5fc3\u6a21\u578b
\n\/\/\/ <summary>
\n\/\/\/ \u57fa\u7840\u59d4\u6258\u4fe1\u606f（\u539f\u5b50\u64cd\u4f5c，\u53ef\u72ec\u7acb\u6267\u884c\/\u7ec4\u5408\u6267\u884c）
\n\/\/\/ <\/summary>
\npublic class BaseDelegateInfo
\n{
\n public string DelegateId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u59d4\u6258ID
\n public string DelegateName { get; set; } \/\/ \u59d4\u6258\u540d\u79f0（\u5982"PLC\u53d1\u9001\u542f\u52a8\u6307\u4ee4"）
\n public ProcessFlowEventType BindEvent { get; set; } \/\/ \u7ed1\u5b9a\u7684\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6
\n public string MethodName { get; set; } \/\/ \u59d4\u6258\u7ed1\u5b9a\u7684\u65b9\u6cd5\u540d（\u53cd\u5c04\/\u76f4\u63a5\u7ed1\u5b9a）
\n public Delegate DelegateFunc { get; set; } \/\/ \u5b9e\u9645\u59d4\u6258\u51fd\u6570
\n public Dictionary<string, string> Params { get; set; } = new Dictionary<string, string>(); \/\/ \u59d4\u6258\u6267\u884c\u53c2\u6570
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u59d4\u6258\u7ec4\u5408\u4fe1\u606f（\u591a\u4e2a\u57fa\u7840\u59d4\u6258\u62fc\u63a5\u6210\u5de5\u5e8f\u7ea7\u903b\u8f91）
\n\/\/\/ <\/summary>
\npublic class DelegateCombineInfo
\n{
\n public string CombineId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u7ec4\u5408ID（\u5de5\u5e8f\u8282\u70b9\u7ed1\u5b9a）
\n public string CombineName { get; set; } \/\/ \u7ec4\u5408\u540d\u79f0（\u5982"\u9884\u88c5\u5de5\u5e8f\u5b8c\u6574\u6267\u884c\u903b\u8f91"）
\n public DelegateCombineType CombineType { get; set; } \/\/ \u62fc\u63a5\u7c7b\u578b（\u4e32\u884c\/\u5e76\u884c\/\u6761\u4ef6）
\n public List<BaseDelegateInfo> BaseDelegates { get; set; } = new List<BaseDelegateInfo>(); \/\/ \u5305\u542b\u7684\u57fa\u7840\u59d4\u6258
\n public string ConditionalExpr { get; set; } = "true"; \/\/ \u6761\u4ef6\u6267\u884c\u8868\u8fbe\u5f0f（\u5982"CompleteQty>0"）
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u6d41\u7a0b\u59d4\u6258\u62fc\u63a5（\u591a\u4e2a\u5de5\u5e8f\u7ec4\u5408\u59d4\u6258\u62fc\u63a5\u6210\u4ea7\u7ebf\u6d41\u7a0b\u903b\u8f91）
\n\/\/\/ <\/summary>
\npublic class FlowDelegateCombineInfo
\n{
\n public string FlowCombineId { get; set; } = Guid.NewGuid().ToString("N"); \/\/ \u6d41\u7a0b\u7ec4\u5408ID
\n public string FlowName { get; set; } \/\/ \u6d41\u7a0b\u540d\u79f0（\u5982"B\u4ea7\u54c1\u603b\u88c5\u6d41\u7a0b"）
\n public string RouteId { get; set; } \/\/ \u5173\u8054\u5de5\u827a\u8def\u7ebfID
\n public List<DelegateCombineInfo> ProcessCombines { get; set; } = new List<DelegateCombineInfo>(); \/\/ \u5de5\u5e8f\u7ec4\u5408\u59d4\u6258\u5217\u8868
\n public FlowExecuteMode ExecuteMode { get; set; } = FlowExecuteMode.BackendService; \/\/ \u6267\u884c\u6a21\u5f0f
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587（\u4f20\u9012\u7ed9\u6240\u6709\u59d4\u6258，\u5305\u542b\u5168\u91cf\u4e1a\u52a1\u4fe1\u606f）
\n\/\/\/ <\/summary>
\npublic class DelegateExecuteContext
\n{
\n public ErpWorkOrder WorkOrder { get; set; } \/\/ \u5173\u8054\u5de5\u5355
\n public ProcessRoute ProcessRoute { get; set; } \/\/ \u5173\u8054\u5de5\u827a\u8def\u7ebf
\n public ProcessNode CurrentProcess { get; set; } \/\/ \u5f53\u524d\u6267\u884c\u5de5\u5e8f
\n public ProcessFlowEventType CurrentEvent { get; set; } \/\/ \u5f53\u524d\u89e6\u53d1\u4e8b\u4ef6
\n public CancellationToken Cts { get; set; } \/\/ \u53d6\u6d88\u4ee4\u724c（\u7528\u4e8e\u7ec8\u6b62\u6267\u884c）
\n public string ErrorMsg { get; set; } \/\/ \u6267\u884c\u9519\u8bef\u4fe1\u606f
\n public bool IsSuccess { get; set; } = true; \/\/ \u6267\u884c\u662f\u5426\u6210\u529f
\n}
\n#endregion<\/p>\n\u56db\u3001\u6838\u5fc3\u59d4\u6258\u5b9a\u4e49（MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e13\u7528）<\/h3>\n
\u5c01\u88c5\u4e0e\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6\u5f3a\u7ed1\u5b9a\u7684\u901a\u7528\u59d4\u6258\u7c7b\u578b，\u8986\u76d6\u65e0\u8fd4\u56de\u503c \/ \u6709\u8fd4\u56de\u503c \/ \u5f02\u6b65\u6267\u884c\u4e09\u79cd\u573a\u666f，\u9002\u914d MES\/ERP \u7684\u5b9e\u65f6\u6027\u548c\u590d\u6742\u6027\u8981\u6c42：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
#region MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u4e13\u7528\u59d4\u6258\u5b9a\u4e49
\n\/\/\/ <summary>
\n\/\/\/ \u57fa\u7840\u65e0\u8fd4\u56de\u503c\u59d4\u6258（\u6700\u5e38\u7528，\u5982\u65e5\u5fd7\u3001PLC\u6307\u4ee4\u3001\u72b6\u6001\u66f4\u65b0）
\n\/\/\/ \u5165\u53c2：\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587
\n\/\/\/ <\/summary>
\n\/\/\/ <param name="context">\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587<\/param>
\npublic delegate void ProcessFlowBaseDelegate(DelegateExecuteContext context);<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u6709\u8fd4\u56de\u503c\u59d4\u6258（\u5982\u6570\u636e\u67e5\u8be2\u3001\u53c2\u6570\u6821\u9a8c\u3001\u6761\u4ef6\u5224\u65ad）
\n\/\/\/ \u5165\u53c2：\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587；\u8fd4\u56de\u503c：\u6267\u884c\u7ed3\u679c（bool）
\n\/\/\/ <\/summary>
\n\/\/\/ <param name="context">\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587<\/param>
\n\/\/\/ <returns>\u6267\u884c\u7ed3\u679c<\/returns>
\npublic delegate bool ProcessFlowFuncDelegate(DelegateExecuteContext context);<\/p>\n\/\/\/ <summary>
\n\/\/\/ \u5f02\u6b65\u59d4\u6258（\u5982\u8017\u65f6\u64cd\u4f5c：PLC\u901a\u4fe1\u3001ERP\u6570\u636e\u4ea4\u4e92\u3001\u8bbe\u5907\u6821\u51c6）
\n\/\/\/ \u5165\u53c2：\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587+\u53d6\u6d88\u4ee4\u724c；\u8fd4\u56de\u503c：\u5f02\u6b65\u4efb\u52a1
\n\/\/\/ <\/summary>
\n\/\/\/ <param name="context">\u59d4\u6258\u6267\u884c\u4e0a\u4e0b\u6587<\/param>
\n\/\/\/ <param name="cancellationToken">\u53d6\u6d88\u4ee4\u724c<\/param>
\n\/\/\/ <returns>\u5f02\u6b65\u4efb\u52a1<\/returns>
\npublic delegate Task ProcessFlowAsyncDelegate(DelegateExecuteContext context, CancellationToken cancellationToken);
\n#endregion<\/p>\n\u4e94\u3001\u6838\u5fc3\u670d\u52a1\u5c01\u88c5（\u59d4\u6258\u7ba1\u7406 + \u6d41\u7a0b\u5f15\u64ce + \u540e\u53f0\u670d\u52a1）<\/h3>\n
1. \u672c\u5730\u6570\u636e\u5e93\u52a9\u624b（SQLite）<\/h4>\n
\u5c01\u88c5\u5de5\u5e8f\u6d41\u7a0b \/ \u59d4\u6258\u914d\u7f6e \/ \u5de5\u5355\u4fe1\u606f\u7684\u672c\u5730\u5b58\u50a8，\u5b9e\u73b0\u914d\u7f6e\u6301\u4e45\u5316，\u7a0b\u5e8f\u91cd\u542f\u540e\u59d4\u6258\u62fc\u63a5\u5173\u7cfb\u3001\u5de5\u5e8f\u72b6\u6001\u4e0d\u4e22\u5931：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ SQLite\u672c\u5730\u6570\u636e\u5e93\u52a9\u624b（\u5355\u4f8b）- MES\/ERP\u5de5\u5e8f\u59d4\u6258\u4e13\u7528
\n\/\/\/ \u5b58\u50a8：\u5de5\u5355\u3001\u5de5\u827a\u8def\u7ebf\u3001\u5de5\u5e8f\u8282\u70b9\u3001\u59d4\u6258\u914d\u7f6e\u3001\u59d4\u6258\u7ec4\u5408
\n\/\/\/ <\/summary>
\npublic sealed class MesErpDbHelper
\n{
\n \/\/ \u5355\u4f8b\u5b9e\u4f8b
\n private static readonly Lazy<MesErpDbHelper> _instance = new Lazy<MesErpDbHelper>(() => new MesErpDbHelper());
\n public static MesErpDbHelper Instance => _instance.Value;<\/p>\n\/\/ \u6570\u636e\u5e93\u8def\u5f84（\u7a0b\u5e8f\u76ee\u5f55\u4e0bMesErpProcessDelegate.db）
\n private readonly string _dbPath;
\n private readonly string _connStr;
\n private readonly object _dbLock = new object();<\/p>\nprivate MesErpDbHelper()
\n {
\n _dbPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "MesErpProcessDelegate.db");
\n \/\/ \u5f00\u542fWAL\u6a21\u5f0f，\u63d0\u5347\u540e\u53f0\u670d\u52a1\u591a\u7ebf\u7a0b\u8bfb\u5199\u6027\u80fd
\n _connStr = $"Data Source={_dbPath};Version=3;Journal Mode=WAL;Pooling=true;Max Pool Size=20;";
\n \/\/ \u521d\u59cb\u5316\u6570\u636e\u5e93\u8868\u7ed3\u6784
\n InitDbTables();
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u521d\u59cb\u5316\u6570\u636e\u5e93\u8868（\u4e0d\u5b58\u5728\u5219\u521b\u5efa）
\n \/\/\/ <\/summary>
\n private void InitDbTables()
\n {
\n lock (_dbLock)
\n {
\n if (!File.Exists(_dbPath)) SQLiteConnection.CreateFile(_dbPath);<\/p>\nusing (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n \/\/ 1. ERP\u5de5\u5355\u8868
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS ErpWorkOrder (
\n OrderNo TEXT PRIMARY KEY, ProductCode TEXT, ProductName TEXT, PlanQty INT,
\n CompleteQty INT, CreateTime DATETIME, LineCode TEXT)");<\/p>\n\/\/ 2. \u5de5\u827a\u8def\u7ebf\u8868
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS ProcessRoute (
\n RouteId TEXT PRIMARY KEY, OrderNo TEXT, LineCode TEXT, CurrentProcessIndex INT,
\n ProcessNodes TEXT, FOREIGN KEY(OrderNo) REFERENCES ErpWorkOrder(OrderNo))");<\/p>\n\/\/ 3. \u59d4\u6258\u7ec4\u5408\u8868（\u5de5\u5e8f\u7ea7）
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS DelegateCombine (
\n CombineId TEXT PRIMARY KEY, CombineName TEXT, CombineType INT,
\n ConditionalExpr TEXT, BaseDelegates TEXT)");<\/p>\n\/\/ 4. \u6d41\u7a0b\u59d4\u6258\u7ec4\u5408\u8868（\u4ea7\u7ebf\u7ea7）
\n conn.Execute($@"CREATE TABLE IF NOT EXISTS FlowDelegateCombine (
\n FlowCombineId TEXT PRIMARY KEY, FlowName TEXT, RouteId TEXT,
\n ExecuteMode INT, ProcessCombines TEXT,
\n FOREIGN KEY(RouteId) REFERENCES ProcessRoute(RouteId))");<\/p>\nLogHelper.Info("MES\/ERP\u672c\u5730\u6570\u636e\u5e93\u521d\u59cb\u5316\u5b8c\u6210，\u8def\u5f84：" + _dbPath);
\n }
\n }
\n }<\/p>\n#region \u901a\u7528CRUD\u65b9\u6cd5
\n public T QueryFirst<T>(string sql, object param = null)
\n {
\n lock (_dbLock)
\n {
\n using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n return conn.QueryFirstOrDefault<T>(sql, param);
\n }
\n }
\n }<\/p>\npublic List<T> QueryList<T>(string sql, object param = null)
\n {
\n lock (_dbLock)
\n {
\n using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n return conn.Query<T>(sql, param).ToList();
\n }
\n }
\n }<\/p>\npublic int Execute(string sql, object param = null)
\n {
\n lock (_dbLock)
\n {
\n using (var conn = new SQLiteConnection(_connStr))
\n {
\n conn.Open();
\n using (var tran = conn.BeginTransaction())
\n {
\n try
\n {
\n var rows = conn.Execute(sql, param, tran);
\n tran.Commit();
\n return rows;
\n }
\n catch (Exception ex)
\n {
\n tran.Rollback();
\n LogHelper.Error("SQL\u6267\u884c\u5931\u8d25：" + sql, ex);
\n throw;
\n }
\n }
\n }
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u4fdd\u5b58\u5bf9\u8c61\u5230\u6570\u636e\u5e93（JSON\u5e8f\u5217\u5316\u590d\u6742\u5b57\u6bb5）
\n \/\/\/ <\/summary>
\n public void SaveObject<T>(string tableName, string keyCol, T model)
\n {
\n var jsonProps = model.GetType().GetProperties()
\n .Where(p => p.PropertyType.IsGenericType || p.PropertyType == typeof(Dictionary<string, string>))
\n .Select(p => p.Name).ToList();<\/p>\nvar sqlCols = string.Join(",", model.GetType().GetProperties()
\n .Where(p => !jsonProps.Contains(p.Name))
\n .Select(p => p.Name));
\n var sqlVals = string.Join(",", model.GetType().GetProperties()
\n .Where(p => !jsonProps.Contains(p.Name))
\n .Select(p => $"@{p.Name}"));<\/p>\n\/\/ \u5148\u5220\u9664\u539f\u6709\u6570\u636e
\n Execute($"DELETE FROM {tableName} WHERE {keyCol} = @{keyCol}", model);
\n \/\/ \u63d2\u5165\u65b0\u6570\u636e（\u590d\u6742\u5b57\u6bb5JSON\u5e8f\u5217\u5316）
\n var insertSql = $"INSERT INTO {tableName} ({sqlCols},{string.Join(",", jsonProps)}) VALUES ({sqlVals},{string.Join(",", jsonProps.Select(p => $"@{p}"))})";
\n var param = new DynamicParameters(model);
\n foreach (var prop in jsonProps)
\n {
\n var val = model.GetType().GetProperty(prop).GetValue(model);
\n param.Add(prop, JsonConvert.SerializeObject(val));
\n }
\n Execute(insertSql, param);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u8bfb\u53d6\u5bf9\u8c61\u4ece\u6570\u636e\u5e93（JSON\u53cd\u5e8f\u5217\u5316\u590d\u6742\u5b57\u6bb5）
\n \/\/\/ <\/summary>
\n public T GetObject<T>(string tableName, string keyCol, string keyVal)
\n {
\n var sql = $"SELECT * FROM {tableName} WHERE {keyCol} = @KeyVal";
\n var dynamicModel = QueryFirst<dynamic>(sql, new { KeyVal = keyVal });
\n if (dynamicModel == null) return default;<\/p>\nvar model = JsonConvert.DeserializeObject<T>(JsonConvert.SerializeObject(dynamicModel));
\n var jsonProps = typeof(T).GetProperties()
\n .Where(p => p.PropertyType.IsGenericType || p.PropertyType == typeof(Dictionary<string, string>))
\n .Select(p => p.Name).ToList();<\/p>\nforeach (var prop in jsonProps)
\n {
\n var jsonVal = dynamicModel.GetType().GetProperty(prop)?.GetValue(dynamicModel)?.ToString();
\n if (!string.IsNullOrEmpty(jsonVal))
\n {
\n var val = JsonConvert.DeserializeObject(jsonVal, typeof(T).GetProperty(prop).PropertyType);
\n typeof(T).GetProperty(prop).SetValue(model, val);
\n }
\n }
\n return model;
\n }
\n #endregion
\n}<\/p>\n2. \u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3（\u6838\u5fc3，\u591a\u7ed3\u6784\u62fc\u63a5 + \u52a8\u6001\u6ce8\u518c）<\/h4>\n
\u5b9e\u73b0\u57fa\u7840\u59d4\u6258\u7684\u6ce8\u518c \/ \u6ce8\u9500\u3001\u59d4\u6258\u7684\u7ec4\u5408\u62fc\u63a5\u3001\u59d4\u6258\u7684\u6301\u4e45\u5316 \/ \u52a0\u8f7d，\u662f\u6574\u4e2a\u4e2d\u95f4\u4ef6\u7684\u59d4\u6258\u5927\u8111，\u652f\u6301\u53ef\u89c6\u5316\u914d\u7f6e\u548c\u52a8\u6001\u4fee\u6539：<\/p>\n
\/\/\/ <summary>
\n\/\/\/ \u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3（\u5355\u4f8b）- MES\/ERP\u4e13\u7528
\n\/\/\/ \u6838\u5fc3：\u57fa\u7840\u59d4\u6258\u6ce8\u518c\u3001\u591a\u7ed3\u6784\u62fc\u63a5\u3001\u59d4\u6258\u52a0\u8f7d\/\u4fdd\u5b58\u3001\u59d4\u6258\u6267\u884c
\n\/\/\/ <\/summary>
\npublic sealed class ProcessDelegateManager
\n{
\n \/\/ \u5355\u4f8b\u5b9e\u4f8b
\n private static readonly Lazy<ProcessDelegateManager> _instance = new Lazy<ProcessDelegateManager>(() => new ProcessDelegateManager());
\n public static ProcessDelegateManager Instance => _instance.Value;<\/p>\n\/\/ \u672c\u5730\u6570\u636e\u5e93\u52a9\u624b
\n private readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;
\n \/\/ \u57fa\u7840\u59d4\u6258\u6ce8\u518c\u8868（\u5185\u5b58\u7f13\u5b58，\u63d0\u9ad8\u6267\u884c\u6548\u7387）
\n private readonly Dictionary<string, BaseDelegateInfo> _baseDelegateDict = new Dictionary<string, BaseDelegateInfo>();
\n \/\/ \u59d4\u6258\u7ec4\u5408\u6ce8\u518c\u8868
\n private readonly Dictionary<string, DelegateCombineInfo> _combineDelegateDict = new Dictionary<string, DelegateCombineInfo>();
\n \/\/ \u6d41\u7a0b\u59d4\u6258\u7ec4\u5408\u6ce8\u518c\u8868
\n private readonly Dictionary<string, FlowDelegateCombineInfo> _flowCombineDelegateDict = new Dictionary<string, FlowDelegateCombineInfo>();
\n \/\/ \u7ebf\u7a0b\u5b89\u5168\u9501
\n private readonly object _delegateLock = new object();<\/p>\nprivate ProcessDelegateManager()
\n {
\n \/\/ \u7a0b\u5e8f\u542f\u52a8\u65f6\u52a0\u8f7d\u672c\u5730\u5b58\u50a8\u7684\u59d4\u6258\u914d\u7f6e
\n LoadAllDelegatesFromDb();
\n \/\/ \u6ce8\u518cMES\/ERP\u901a\u7528\u57fa\u7840\u59d4\u6258（\u539f\u5b50\u64cd\u4f5c，\u53ef\u76f4\u63a5\u4f7f\u7528）
\n RegisterDefaultBaseDelegates();
\n }<\/p>\n#region \u57fa\u7840\u59d4\u6258\u64cd\u4f5c（\u6ce8\u518c\/\u6ce8\u9500\/\u52a0\u8f7d\/\u4fdd\u5b58）
\n \/\/\/ <summary>
\n \/\/\/ \u6ce8\u518c\u57fa\u7840\u59d4\u6258（\u652f\u6301\u4efb\u610f\u7c7b\u578b\u59d4\u6258：Base\/Func\/Async）
\n \/\/\/ <\/summary>
\n public void RegisterBaseDelegate(BaseDelegateInfo delegateInfo)
\n {
\n lock (_delegateLock)
\n {
\n if (_baseDelegateDict.ContainsKey(delegateInfo.DelegateId))
\n _baseDelegateDict[delegateInfo.DelegateId] = delegateInfo;
\n else
\n _baseDelegateDict.Add(delegateInfo.DelegateId, delegateInfo);
\n LogHelper.Info($"\u57fa\u7840\u59d4\u6258\u6ce8\u518c\u6210\u529f：{delegateInfo.DelegateName}（ID：{delegateInfo.DelegateId}）");
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6ce8\u9500\u57fa\u7840\u59d4\u6258
\n \/\/\/ <\/summary>
\n public void UnRegisterBaseDelegate(string delegateId)
\n {
\n lock (_delegateLock)
\n {
\n if (_baseDelegateDict.ContainsKey(delegateId))
\n {
\n _baseDelegateDict.Remove(delegateId);
\n LogHelper.Info($"\u57fa\u7840\u59d4\u6258\u6ce8\u9500\u6210\u529f：ID={delegateId}");
\n }
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6ce8\u518cMES\/ERP\u901a\u7528\u9ed8\u8ba4\u57fa\u7840\u59d4\u6258（\u5f00\u7bb1\u5373\u7528）
\n \/\/\/ <\/summary>
\n private void RegisterDefaultBaseDelegates()
\n {
\n \/\/ 1. \u5de5\u5e8f\u72b6\u6001\u66f4\u65b0\u59d4\u6258（\u7ed1\u5b9aProcessStart\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5de5\u5e8f\u72b6\u6001\u66f4\u65b0\u4e3a\u6267\u884c\u4e2d",
\n BindEvent = ProcessFlowEventType.ProcessStart,
\n DelegateFunc = new ProcessFlowBaseDelegate(DefaultDelegates.UpdateProcessStatusToRunning)
\n });<\/p>\n\/\/ 2. \u4ea7\u91cf\u4e0a\u62a5\u59d4\u6258（\u7ed1\u5b9aProcessComplete\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5de5\u5e8f\u4ea7\u91cf\u4e0a\u62a5\u5230\u672c\u5730\u5e93",
\n BindEvent = ProcessFlowEventType.ProcessComplete,
\n DelegateFunc = new ProcessFlowBaseDelegate(DefaultDelegates.ReportProcessYieldToDb)
\n });<\/p>\n\/\/ 3. ERP\u5de5\u5355\u8fdb\u5ea6\u66f4\u65b0\u59d4\u6258（\u5f02\u6b65，\u7ed1\u5b9aFlowComplete\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5f02\u6b65\u66f4\u65b0ERP\u5de5\u5355\u8fdb\u5ea6",
\n BindEvent = ProcessFlowEventType.FlowComplete,
\n DelegateFunc = new ProcessFlowAsyncDelegate(DefaultDelegates.AsyncUpdateErpOrderProgress)
\n });<\/p>\n\/\/ 4. \u5de5\u5e8f\u5f02\u5e38\u65e5\u5fd7\u59d4\u6258（\u7ed1\u5b9aProcessException\u4e8b\u4ef6）
\n RegisterBaseDelegate(new BaseDelegateInfo
\n {
\n DelegateName = "\u5de5\u5e8f\u5f02\u5e38\u65e5\u5fd7\u8bb0\u5f55",
\n BindEvent = ProcessFlowEventType.ProcessException,
\n DelegateFunc = new ProcessFlowBaseDelegate(DefaultDelegates.RecordProcessExceptionLog)
\n });
\n }
\n #endregion<\/p>\n#region \u59d4\u6258\u7ec4\u5408\u64cd\u4f5c（\u5de5\u5e8f\u7ea7\/\u6d41\u7a0b\u7ea7\u62fc\u63a5）
\n \/\/\/ <summary>
\n \/\/\/ \u62fc\u63a5\u5de5\u5e8f\u7ea7\u59d4\u6258\u7ec4\u5408（\u591a\u4e2a\u57fa\u7840\u59d4\u6258\u6309\u89c4\u5219\u7ec4\u5408）
\n \/\/\/ <\/summary>
\n public DelegateCombineInfo CombineProcessDelegates(string combineName, DelegateCombineType combineType, List<BaseDelegateInfo> baseDelegates, string conditionalExpr = "true")
\n {
\n lock (_delegateLock)
\n {
\n var combine = new DelegateCombineInfo
\n {
\n CombineName = combineName,
\n CombineType = combineType,
\n BaseDelegates = baseDelegates,
\n ConditionalExpr = conditionalExpr
\n };
\n _combineDelegateDict.Add(combine.CombineId, combine);
\n \/\/ \u6301\u4e45\u5316\u5230\u672c\u5730\u5e93
\n _dbHelper.SaveObject("DelegateCombine", "CombineId", combine);
\n LogHelper.Info($"\u5de5\u5e8f\u59d4\u6258\u7ec4\u5408\u62fc\u63a5\u6210\u529f：{combineName}（\u5305\u542b{baseDelegates.Count}\u4e2a\u57fa\u7840\u59d4\u6258）");
\n return combine;
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u62fc\u63a5\u4ea7\u7ebf\u7ea7\u6d41\u7a0b\u59d4\u6258（\u591a\u4e2a\u5de5\u5e8f\u7ec4\u5408\u59d4\u6258\u62fc\u63a5\u6210\u5b8c\u6574\u6d41\u7a0b）
\n \/\/\/ <\/summary>
\n public FlowDelegateCombineInfo CombineFlowDelegates(string flowName, string routeId, List<DelegateCombineInfo> processCombines, FlowExecuteMode executeMode)
\n {
\n lock (_delegateLock)
\n {
\n var flowCombine = new FlowDelegateCombineInfo
\n {
\n FlowName = flowName,
\n RouteId = routeId,
\n ProcessCombines = processCombines,
\n ExecuteMode = executeMode
\n };
\n _flowCombineDelegateDict.Add(flowCombine.FlowCombineId, flowCombine);
\n \/\/ \u6301\u4e45\u5316\u5230\u672c\u5730\u5e93
\n _dbHelper.SaveObject("FlowDelegateCombine", "FlowCombineId", flowCombine);
\n LogHelper.Info($"\u6d41\u7a0b\u59d4\u6258\u62fc\u63a5\u6210\u529f：{flowName}（\u5305\u542b{processCombines.Count}\u4e2a\u5de5\u5e8f\u7ec4\u5408）");
\n return flowCombine;
\n }
\n }
\n #endregion<\/p>\n#region \u59d4\u6258\u52a0\u8f7d\/\u4fdd\u5b58
\n \/\/\/ <summary>
\n \/\/\/ \u4ece\u672c\u5730\u5e93\u52a0\u8f7d\u6240\u6709\u59d4\u6258\u914d\u7f6e
\n \/\/\/ <\/summary>
\n private void LoadAllDelegatesFromDb()
\n {
\n \/\/ \u52a0\u8f7d\u5de5\u5e8f\u59d4\u6258\u7ec4\u5408
\n var processCombines = _dbHelper.QueryList<dynamic>("SELECT CombineId FROM DelegateCombine");
\n foreach (var item in processCombines)
\n {
\n var combine = _dbHelper.GetObject<DelegateCombineInfo>("DelegateCombine", "CombineId", item.CombineId);
\n _combineDelegateDict.Add(combine.CombineId, combine);
\n }<\/p>\n\/\/ \u52a0\u8f7d\u6d41\u7a0b\u59d4\u6258\u7ec4\u5408
\n var flowCombines = _dbHelper.QueryList<dynamic>("SELECT FlowCombineId FROM FlowDelegateCombine");
\n foreach (var item in flowCombines)
\n {
\n var flowCombine = _dbHelper.GetObject<FlowDelegateCombineInfo>("FlowDelegateCombine", "FlowCombineId", item.FlowCombineId);
\n _flowCombineDelegateDict.Add(flowCombine.FlowCombineId, flowCombine);
\n }<\/p>\nLogHelper.Info($"\u4ece\u672c\u5730\u5e93\u52a0\u8f7d\u59d4\u6258\u914d\u7f6e\u5b8c\u6210：\u5de5\u5e8f\u7ec4\u5408{_combineDelegateDict.Count}\u4e2a，\u6d41\u7a0b\u7ec4\u5408{_flowCombineDelegateDict.Count}\u4e2a");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6839\u636e\u5de5\u5e8fID\u83b7\u53d6\u7ed1\u5b9a\u7684\u59d4\u6258\u7ec4\u5408
\n \/\/\/ <\/summary>
\n public DelegateCombineInfo GetProcessCombineByProcessId(string processId, ProcessRoute route)
\n {
\n var processNode = route.ProcessNodes.FirstOrDefault(p => p.ProcessId == processId);
\n if (processNode == null || string.IsNullOrEmpty(processNode.DelegateCombineId))
\n throw new KeyNotFoundException($"\u5de5\u5e8f{processId}\u672a\u7ed1\u5b9a\u59d4\u6258\u7ec4\u5408");<\/p>\nreturn _combineDelegateDict.TryGetValue(processNode.DelegateCombineId, out var combine) ? combine : null;
\n }
\n #endregion<\/p>\n#region \u59d4\u6258\u6267\u884c（\u6838\u5fc3，\u652f\u6301\u591a\u7c7b\u578b\/\u591a\u62fc\u63a5\u89c4\u5219）
\n \/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u59d4\u6258\u7ec4\u5408（\u81ea\u52a8\u8bc6\u522b\u4e32\u884c\/\u5e76\u884c\/\u6761\u4ef6，\u652f\u6301\u5f02\u6b65）
\n \/\/\/ <\/summary>
\n public async Task ExecuteCombineDelegate(DelegateCombineInfo combine, DelegateExecuteContext context)
\n {
\n if (combine == null || !combine.BaseDelegates.Any()) return;
\n \/\/ \u6761\u4ef6\u6267\u884c：\u5148\u5224\u65ad\u6761\u4ef6\u662f\u5426\u6ee1\u8db3
\n if (!EvaluateConditionalExpr(combine.ConditionalExpr, context))
\n {
\n LogHelper.Info($"\u59d4\u6258\u7ec4\u5408{combine.CombineName}\u6761\u4ef6\u4e0d\u6ee1\u8db3，\u8df3\u8fc7\u6267\u884c");
\n return;
\n }<\/p>\nLogHelper.Info($"\u5f00\u59cb\u6267\u884c\u59d4\u6258\u7ec4\u5408：{combine.CombineName}（\u7c7b\u578b：{combine.CombineType}）");
\n switch (combine.CombineType)
\n {
\n case DelegateCombineType.Serial:
\n \/\/ \u4e32\u884c\u6267\u884c：\u6309\u987a\u5e8f\u6267\u884c\u6bcf\u4e2a\u57fa\u7840\u59d4\u6258
\n foreach (var baseDel in combine.BaseDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n await ExecuteBaseDelegate(baseDel, context);
\n }
\n break;
\n case DelegateCombineType.Parallel:
\n \/\/ \u5e76\u884c\u6267\u884c：\u6240\u6709\u59d4\u6258\u540c\u65f6\u6267\u884c，\u7b49\u5f85\u5168\u90e8\u5b8c\u6210
\n var parallelTasks = new List<Task>();
\n foreach (var baseDel in combine.BaseDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n parallelTasks.Add(ExecuteBaseDelegate(baseDel, context));
\n }
\n await Task.WhenAll(parallelTasks);
\n break;
\n case DelegateCombineType.Conditional:
\n \/\/ \u6761\u4ef6\u6267\u884c：\u6bcf\u4e2a\u59d4\u6258\u72ec\u7acb\u5224\u65ad\u6761\u4ef6（\u7b80\u5316\u7248，\u53ef\u6269\u5c55）
\n foreach (var baseDel in combine.BaseDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n var expr = baseDel.Params.ContainsKey("ConditionalExpr") ? baseDel.Params["ConditionalExpr"] : "true";
\n if (EvaluateConditionalExpr(expr, context))
\n await ExecuteBaseDelegate(baseDel, context);
\n }
\n break;
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u57fa\u7840\u59d4\u6258（\u81ea\u52a8\u8bc6\u522b\u59d4\u6258\u7c7b\u578b：Base\/Func\/Async）
\n \/\/\/ <\/summary>
\n private async Task ExecuteBaseDelegate(BaseDelegateInfo baseDel, DelegateExecuteContext context)
\n {
\n if (baseDel.DelegateFunc == null)
\n {
\n LogHelper.Warn($"\u57fa\u7840\u59d4\u6258{baseDel.DelegateName}\u672a\u7ed1\u5b9a\u51fd\u6570，\u8df3\u8fc7");
\n return;
\n }<\/p>\ntry
\n {
\n LogHelper.Info($"\u6267\u884c\u57fa\u7840\u59d4\u6258：{baseDel.DelegateName}");
\n \/\/ \u6309\u59d4\u6258\u7c7b\u578b\u5206\u53d1\u6267\u884c
\n if (baseDel.DelegateFunc is ProcessFlowBaseDelegate baseFunc)
\n {
\n baseFunc(context); \/\/ \u540c\u6b65\u65e0\u8fd4\u56de\u503c
\n }
\n else if (baseDel.DelegateFunc is ProcessFlowFuncDelegate func)
\n {
\n context.IsSuccess = func(context); \/\/ \u540c\u6b65\u6709\u8fd4\u56de\u503c
\n }
\n else if (baseDel.DelegateFunc is ProcessFlowAsyncDelegate asyncFunc)
\n {
\n await asyncFunc(context, context.Cts); \/\/ \u5f02\u6b65\u6267\u884c
\n }
\n else
\n {
\n throw new NotSupportedException($"\u4e0d\u652f\u6301\u7684\u59d4\u6258\u7c7b\u578b：{baseDel.DelegateFunc.GetType().Name}");
\n }
\n }
\n catch (Exception ex)
\n {
\n context.IsSuccess = false;
\n context.ErrorMsg = ex.Message;
\n LogHelper.Error($"\u57fa\u7840\u59d4\u6258{baseDel.DelegateName}\u6267\u884c\u5931\u8d25：{ex.Message}", ex);
\n throw;
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u89e3\u6790\u6761\u4ef6\u6267\u884c\u8868\u8fbe\u5f0f（\u7b80\u5316\u7248，\u53ef\u6269\u5c55\u4e3a\u8868\u8fbe\u5f0f\u5f15\u64ce）
\n \/\/\/ <\/summary>
\n private bool EvaluateConditionalExpr(string expr, DelegateExecuteContext context)
\n {
\n \/\/ \u57fa\u7840\u5b9e\u73b0：\u652f\u6301\u7b80\u5355\u8868\u8fbe\u5f0f\u5982"true"\u3001"CompleteQty>0"\u3001"Status==2"
\n if (expr.Trim().ToLower() == "true") return true;
\n if (expr.Trim().ToLower() == "false") return false;<\/p>\n\/\/ \u6269\u5c55\u70b9：\u96c6\u6210\u8868\u8fbe\u5f0f\u5f15\u64ce（\u5982NCalc）\u652f\u6301\u590d\u6742\u8868\u8fbe\u5f0f
\n try
\n {
\n \/\/ \u793a\u4f8b：\u89e3\u6790CompleteQty>0
\n if (expr.Contains("CompleteQty>"))
\n {
\n var qty = int.Parse(expr.Split('>')[1].Trim());
\n return context.CurrentProcess.CompleteQty > qty;
\n }
\n return true;
\n }
\n catch
\n {
\n return false;
\n }
\n }
\n #endregion
\n}<\/p>\n\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u901a\u7528\u9ed8\u8ba4\u59d4\u6258\u5b9e\u73b0（\u539f\u5b50\u64cd\u4f5c，\u5f00\u7bb1\u5373\u7528）
\n\/\/\/ <\/summary>
\npublic static class DefaultDelegates
\n{
\n private static readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u57fa\u7840\u59d4\u6258：\u66f4\u65b0\u5de5\u5e8f\u72b6\u6001\u4e3a\u6267\u884c\u4e2d
\n \/\/\/ <\/summary>
\n public static void UpdateProcessStatusToRunning(DelegateExecuteContext context)
\n {
\n context.CurrentProcess.Status = ProcessStatus.Running;
\n \/\/ \u6301\u4e45\u5316\u5de5\u5e8f\u72b6\u6001
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", context.ProcessRoute);
\n LogHelper.Info($"\u5de5\u5e8f{context.CurrentProcess.ProcessCode}\u72b6\u6001\u66f4\u65b0\u4e3a：\u6267\u884c\u4e2d");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u57fa\u7840\u59d4\u6258：\u5de5\u5e8f\u4ea7\u91cf\u4e0a\u62a5\u5230\u672c\u5730\u5e93
\n \/\/\/ <\/summary>
\n public static void ReportProcessYieldToDb(DelegateExecuteContext context)
\n {
\n context.WorkOrder.CompleteQty = context.ProcessRoute.ProcessNodes.Sum(p => p.CompleteQty);
\n \/\/ \u66f4\u65b0\u5de5\u5355\u548c\u5de5\u827a\u8def\u7ebf
\n _dbHelper.SaveObject("ErpWorkOrder", "OrderNo", context.WorkOrder);
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", context.ProcessRoute);
\n LogHelper.Info($"\u5de5\u5e8f{context.CurrentProcess.ProcessCode}\u4ea7\u91cf\u4e0a\u62a5：{context.CurrentProcess.CompleteQty}\u4ef6，\u5de5\u5355\u7d2f\u8ba1：{context.WorkOrder.CompleteQty}\u4ef6");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u5f02\u6b65\u59d4\u6258：\u66f4\u65b0ERP\u5de5\u5355\u8fdb\u5ea6（\u6a21\u62dfERP\u63a5\u53e3\u8c03\u7528，\u5b9e\u9645\u66ff\u6362\u4e3a\u771f\u5b9eERP\u4ea4\u4e92\u4ee3\u7801）
\n \/\/\/ <\/summary>
\n public static async Task AsyncUpdateErpOrderProgress(DelegateExecuteContext context, CancellationToken ct)
\n {
\n \/\/ \u6a21\u62dfERP\u63a5\u53e3\u7f51\u7edc\u8bf7\u6c42（\u8017\u65f62\u79d2）
\n await Task.Delay(2000, ct);
\n \/\/ \u5b9e\u9645\u573a\u666f：\u8c03\u7528ERP\u7684WebAPI\/WS\u66f4\u65b0\u5de5\u5355\u8fdb\u5ea6
\n var progress = (double)context.WorkOrder.CompleteQty \/ context.WorkOrder.PlanQty * 100;
\n LogHelper.Info($"\u5f02\u6b65\u66f4\u65b0ERP\u5de5\u5355{context.WorkOrder.OrderNo}\u8fdb\u5ea6：{progress:F2}%");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u57fa\u7840\u59d4\u6258：\u8bb0\u5f55\u5de5\u5e8f\u5f02\u5e38\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void RecordProcessExceptionLog(DelegateExecuteContext context)
\n {
\n LogHelper.Error($"\u3010\u5de5\u5e8f\u5f02\u5e38\u3011{context.CurrentProcess.ProcessCode}：{context.ErrorMsg}，\u5de5\u5355：{context.WorkOrder.OrderNo}");
\n context.CurrentProcess.Status = ProcessStatus.Exception;
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", context.ProcessRoute);
\n }
\n}<\/p>\n3. \u5de5\u5e8f\u6d41\u7a0b\u5f15\u64ce（\u59d4\u6258\u6267\u884c + \u6d41\u7a0b\u63a7\u5236）<\/h4>\n
\u5b9e\u73b0\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u7ba1\u7406，\u89e6\u53d1\u5bf9\u5e94\u4e8b\u4ef6\u5e76\u5206\u53d1\u5230\u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3\u6267\u884c\u62fc\u63a5\u540e\u7684\u59d4\u6258，\u652f\u6301\u4e32\u884c \/ \u5e76\u884c\u5de5\u5e8f\u3001\u5f02\u5e38\u5904\u7406\u3001\u6d41\u7a0b\u6682\u505c \/ \u6062\u590d \/ \u7ec8\u6b62：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u5f15\u64ce（\u5355\u4f8b）
\n\/\/\/ \u6838\u5fc3：\u6d41\u7a0b\u751f\u547d\u5468\u671f\u7ba1\u7406\u3001\u4e8b\u4ef6\u89e6\u53d1\u3001\u59d4\u6258\u5206\u53d1\u3001\u6d41\u7a0b\u63a7\u5236（\u6682\u505c\/\u6062\u590d\/\u7ec8\u6b62）
\n\/\/\/ <\/summary>
\npublic sealed class ProcessFlowEngine
\n{
\n \/\/ \u5355\u4f8b\u5b9e\u4f8b
\n private static readonly Lazy<ProcessFlowEngine> _instance = new Lazy<ProcessFlowEngine>(() => new ProcessFlowEngine());
\n public static ProcessFlowEngine Instance => _instance.Value;<\/p>\n\/\/ \u4f9d\u8d56\u670d\u52a1
\n private readonly ProcessDelegateManager _delegateManager = ProcessDelegateManager.Instance;
\n private readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;
\n \/\/ \u6b63\u5728\u6267\u884c\u7684\u6d41\u7a0b（\u6d41\u7a0bID->\u53d6\u6d88\u4ee4\u724c\u6e90）
\n private readonly Dictionary<string, CancellationTokenSource> _runningFlows = new Dictionary<string, CancellationTokenSource>();
\n private readonly object _flowLock = new object();<\/p>\n#region \u6d41\u7a0b\u751f\u547d\u5468\u671f\u64cd\u4f5c（\u542f\u52a8\/\u6682\u505c\/\u6062\u590d\/\u7ec8\u6b62）
\n \/\/\/ <summary>
\n \/\/\/ \u542f\u52a8\u5de5\u5e8f\u6d41\u7a0b（\u6838\u5fc3\u5165\u53e3）
\n \/\/\/ <\/summary>
\n \/\/\/ <param name="flowCombine">\u6d41\u7a0b\u59d4\u6258\u7ec4\u5408<\/param>
\n \/\/\/ <param name="workOrder">ERP\u5de5\u5355<\/param>
\n \/\/\/ <param name="route">\u5de5\u827a\u8def\u7ebf<\/param>
\n \/\/\/ <returns>\u6267\u884c\u4efb\u52a1<\/returns>
\n public async Task StartFlowAsync(FlowDelegateCombineInfo flowCombine, ErpWorkOrder workOrder, ProcessRoute route)
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.ContainsKey(flowCombine.FlowCombineId))
\n throw new InvalidOperationException($"\u6d41\u7a0b{flowCombine.FlowName}\u5df2\u5728\u6267\u884c\u4e2d");<\/p>\n\/\/ \u521b\u5efa\u53d6\u6d88\u4ee4\u724c\u6e90（\u7528\u4e8e\u6682\u505c\/\u7ec8\u6b62\u6d41\u7a0b）
\n var cts = new CancellationTokenSource();
\n _runningFlows.Add(flowCombine.FlowCombineId, cts);
\n \/\/ \u540e\u53f0\u6267\u884c\u6d41\u7a0b，\u4e0d\u963b\u585eUI
\n Task.Run(async () => await ExecuteFlowAsync(flowCombine, workOrder, route, cts.Token), cts.Token);
\n }<\/p>\nLogHelper.Info($"\u6d41\u7a0b{flowCombine.FlowName}\u542f\u52a8\u6210\u529f（\u5de5\u5355：{workOrder.OrderNo}），\u6267\u884c\u6a21\u5f0f：{flowCombine.ExecuteMode}");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6682\u505c\u5de5\u5e8f\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n public void PauseFlow(string flowCombineId)
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.TryGetValue(flowCombineId, out var cts))
\n {
\n cts.Cancel();
\n LogHelper.Info($"\u6d41\u7a0b{flowCombineId}\u5df2\u6682\u505c");
\n }
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u7ec8\u6b62\u5de5\u5e8f\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n public void StopFlow(string flowCombineId)
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.TryGetValue(flowCombineId, out var cts))
\n {
\n cts.Cancel();
\n _runningFlows.Remove(flowCombineId);
\n cts.Dispose();
\n LogHelper.Info($"\u6d41\u7a0b{flowCombineId}\u5df2\u7ec8\u6b62");
\n }
\n }
\n }
\n #endregion<\/p>\n#region \u6d41\u7a0b\u6267\u884c\u6838\u5fc3\u903b\u8f91
\n \/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u5b8c\u6574\u5de5\u5e8f\u6d41\u7a0b（\u89e6\u53d1\u4e8b\u4ef6+\u6267\u884c\u59d4\u6258+\u6d41\u7a0b\u63a7\u5236）
\n \/\/\/ <\/summary>
\n private async Task ExecuteFlowAsync(FlowDelegateCombineInfo flowCombine, ErpWorkOrder workOrder, ProcessRoute route, CancellationToken ct)
\n {
\n var flowContext = new DelegateExecuteContext
\n {
\n WorkOrder = workOrder,
\n ProcessRoute = route,
\n CurrentEvent = ProcessFlowEventType.FlowStart,
\n Cts = ct
\n };<\/p>\ntry
\n {
\n \/\/ \u89e6\u53d1\u6d41\u7a0b\u542f\u52a8\u4e8b\u4ef6
\n await TriggerFlowEvent(ProcessFlowEventType.FlowStart, flowContext);<\/p>\n\/\/ \u6309\u5de5\u827a\u8def\u7ebf\u987a\u5e8f\u6267\u884c\u6bcf\u4e2a\u5de5\u5e8f
\n while (route.CurrentProcessIndex < route.ProcessNodes.Count && !ct.IsCancellationRequested)
\n {
\n var currentProcess = route.ProcessNodes[route.CurrentProcessIndex];
\n flowContext.CurrentProcess = currentProcess;
\n flowContext.CurrentEvent = ProcessFlowEventType.ProcessInit;<\/p>\n\/\/ \u6267\u884c\u5355\u4e2a\u5de5\u5e8f\u7684\u5b8c\u6574\u751f\u547d\u5468\u671f
\n await ExecuteSingleProcessAsync(currentProcess, flowCombine, flowContext, ct);<\/p>\n\/\/ \u5de5\u5e8f\u6267\u884c\u6210\u529f，\u5207\u6362\u5230\u4e0b\u4e00\u4e2a\u5de5\u5e8f
\n if (currentProcess.Status == ProcessStatus.Completed || currentProcess.Status == ProcessStatus.Skipped)
\n {
\n route.CurrentProcessIndex++;
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);
\n }
\n \/\/ \u5de5\u5e8f\u5f02\u5e38，\u7ec8\u6b62\u6d41\u7a0b
\n else if (currentProcess.Status == ProcessStatus.Exception)
\n {
\n throw new Exception($"\u5de5\u5e8f{currentProcess.ProcessCode}\u6267\u884c\u5f02\u5e38，\u6d41\u7a0b\u7ec8\u6b62");
\n }
\n }<\/p>\n\/\/ \u6240\u6709\u5de5\u5e8f\u6267\u884c\u5b8c\u6210，\u89e6\u53d1\u6d41\u7a0b\u5b8c\u6210\u4e8b\u4ef6
\n if (!ct.IsCancellationRequested)
\n {
\n flowContext.CurrentEvent = ProcessFlowEventType.FlowComplete;
\n await TriggerFlowEvent(ProcessFlowEventType.FlowComplete, flowContext);
\n LogHelper.Info($"\u6d41\u7a0b{flowCombine.FlowName}\u6267\u884c\u5b8c\u6210（\u5de5\u5355：{workOrder.OrderNo}），\u5b8c\u6210\u4ea7\u91cf：{workOrder.CompleteQty}\u4ef6");
\n }
\n }
\n catch (OperationCanceledException)
\n {
\n LogHelper.Info($"\u6d41\u7a0b{flowCombine.FlowName}\u5df2\u6682\u505c\/\u7ec8\u6b62（\u5de5\u5355：{workOrder.OrderNo}）");
\n }
\n catch (Exception ex)
\n {
\n flowContext.CurrentEvent = ProcessFlowEventType.FlowException;
\n flowContext.IsSuccess = false;
\n flowContext.ErrorMsg = ex.Message;
\n await TriggerFlowEvent(ProcessFlowEventType.FlowException, flowContext);
\n LogHelper.Error($"\u6d41\u7a0b{flowCombine.FlowName}\u6267\u884c\u5931\u8d25（\u5de5\u5355：{workOrder.OrderNo}）：{ex.Message}", ex);
\n }
\n finally
\n {
\n lock (_flowLock)
\n {
\n if (_runningFlows.ContainsKey(flowCombine.FlowCombineId))
\n {
\n _runningFlows[flowCombine.FlowCombineId].Dispose();
\n _runningFlows.Remove(flowCombine.FlowCombineId);
\n }
\n }
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6267\u884c\u5355\u4e2a\u5de5\u5e8f\u7684\u5b8c\u6574\u751f\u547d\u5468\u671f（\u521d\u59cb\u5316->\u542f\u52a8->\u6267\u884c->\u5b8c\u6210）
\n \/\/\/ <\/summary>
\n private async Task ExecuteSingleProcessAsync(ProcessNode process, FlowDelegateCombineInfo flowCombine, DelegateExecuteContext context, CancellationToken ct)
\n {
\n \/\/ 1. \u5de5\u5e8f\u521d\u59cb\u5316\u4e8b\u4ef6
\n context.CurrentEvent = ProcessFlowEventType.ProcessInit;
\n process.Status = ProcessStatus.Ready;
\n await TriggerFlowEvent(ProcessFlowEventType.ProcessInit, context);
\n await Task.Delay(500, ct); \/\/ \u6a21\u62df\u5de5\u5e8f\u521d\u59cb\u5316\u8017\u65f6<\/p>\n\/\/ 2. \u5de5\u5e8f\u542f\u52a8\u4e8b\u4ef6
\n context.CurrentEvent = ProcessFlowEventType.ProcessStart;
\n await TriggerFlowEvent(ProcessFlowEventType.ProcessStart, context);<\/p>\n\/\/ 3. \u6267\u884c\u5de5\u5e8f\u7ed1\u5b9a\u7684\u59d4\u6258\u7ec4\u5408（\u6838\u5fc3）
\n var processCombine = _delegateManager.GetProcessCombineByProcessId(process.ProcessId, context.ProcessRoute);
\n await _delegateManager.ExecuteCombineDelegate(processCombine, context);<\/p>\n\/\/ 4. \u5de5\u5e8f\u5b8c\u6210\u4e8b\u4ef6
\n if (context.IsSuccess && !ct.IsCancellationRequested)
\n {
\n context.CurrentEvent = ProcessFlowEventType.ProcessComplete;
\n process.Status = ProcessStatus.Completed;
\n await TriggerFlowEvent(ProcessFlowEventType.ProcessComplete, context);
\n }
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u89e6\u53d1\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6（\u5206\u53d1\u5230\u59d4\u6258\u7ba1\u7406\u4e2d\u5fc3\u6267\u884c\u7ed1\u5b9a\u7684\u59d4\u6258）
\n \/\/\/ <\/summary>
\n private async Task TriggerFlowEvent(ProcessFlowEventType eventType, DelegateExecuteContext context)
\n {
\n context.CurrentEvent = eventType;
\n LogHelper.Info($"\u89e6\u53d1\u5de5\u5e8f\u6d41\u7a0b\u4e8b\u4ef6：{eventType}（\u5de5\u5e8f：{context.CurrentProcess?.ProcessCode ?? "\u6d41\u7a0b\u6574\u4f53"}）");<\/p>\n\/\/ \u6267\u884c\u6240\u6709\u7ed1\u5b9a\u8be5\u4e8b\u4ef6\u7684\u57fa\u7840\u59d4\u6258（\u7b80\u5316\u7248，\u53ef\u6269\u5c55\u4e3a\u6309\u6d41\u7a0b\/\u5de5\u5e8f\u8fc7\u6ee4）
\n var allBaseDelegates = _delegateManager.GetType().GetField("_baseDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, BaseDelegateInfo>;<\/p>\nvar bindDelegates = allBaseDelegates?.Values.Where(d => d.BindEvent == eventType).ToList() ?? new List<BaseDelegateInfo>();
\n foreach (var del in bindDelegates)
\n {
\n if (context.Cts.IsCancellationRequested) break;
\n await _delegateManager.ExecuteBaseDelegate(del, context);
\n }
\n }
\n #endregion
\n}<\/p>\n4. \u540e\u53f0\u670d\u52a1\u7ba1\u7406\u5668（WinForm \u65e0 UI \u963b\u585e\u6267\u884c）<\/h4>\n
\u5b9e\u73b0WinForm \u754c\u9762\u4e0e\u540e\u53f0\u670d\u52a1\u89e3\u8026，\u652f\u6301\u6d41\u7a0b\u540e\u53f0\u8fd0\u884c\u3001\u6700\u5c0f\u5316\u5230\u7cfb\u7edf\u6258\u76d8\u3001\u540e\u53f0\u65e5\u5fd7\u8bb0\u5f55\u3001\u72b6\u6001\u5b9e\u65f6\u540c\u6b65\u5230 UI：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u540e\u53f0\u670d\u52a1\u7ba1\u7406\u5668
\n\/\/\/ \u6838\u5fc3：\u65e0UI\u963b\u585e\u6267\u884c\u3001\u7cfb\u7edf\u6258\u76d8\u3001\u540e\u53f0\u7ebf\u7a0b\u6c60\u3001UI\u72b6\u6001\u540c\u6b65
\n\/\/\/ <\/summary>
\npublic class ProcessFlowBackendService
\n{
\n \/\/ \u540e\u53f0\u670d\u52a1\u7ebf\u7a0b\u6c60
\n private readonly TaskFactory _backendTaskFactory;
\n \/\/ UI\u72b6\u6001\u66f4\u65b0\u59d4\u6258（\u8de8\u7ebf\u7a0b\u5b89\u5168）
\n public Action<string, string> UiStatusUpdateAction;
\n \/\/ \u540e\u53f0\u65e5\u5fd7\u59d4\u6258
\n public Action<string> BackendLogAction;<\/p>\npublic ProcessFlowBackendService()
\n {
\n \/\/ \u914d\u7f6e\u540e\u53f0\u7ebf\u7a0b\u6c60（\u65e0\u540c\u6b65\u4e0a\u4e0b\u6587，\u907f\u514dUI\u963b\u585e）
\n var scheduler = TaskScheduler.Default;
\n _backendTaskFactory = new TaskFactory(CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskContinuationOptions.None, scheduler);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u540e\u53f0\u6267\u884c\u5de5\u5e8f\u6d41\u7a0b（\u65e0UI\u963b\u585e）
\n \/\/\/ <\/summary>
\n public void RunFlowInBackend(FlowDelegateCombineInfo flowCombine, ErpWorkOrder workOrder, ProcessRoute route)
\n {
\n _backendTaskFactory.StartNew(async () =>
\n {
\n try
\n {
\n UiStatusUpdateAction?.Invoke(flowCombine.FlowName, "\u540e\u53f0\u6267\u884c\u4e2d");
\n BackendLogAction?.Invoke($"\u540e\u53f0\u670d\u52a1\u542f\u52a8\u6d41\u7a0b：{flowCombine.FlowName}（\u5de5\u5355：{workOrder.OrderNo}）");
\n \/\/ \u8c03\u7528\u6d41\u7a0b\u5f15\u64ce\u542f\u52a8\u6d41\u7a0b
\n await ProcessFlowEngine.Instance.StartFlowAsync(flowCombine, workOrder, route);
\n UiStatusUpdateAction?.Invoke(flowCombine.FlowName, "\u6267\u884c\u5b8c\u6210");
\n }
\n catch (Exception ex)
\n {
\n UiStatusUpdateAction?.Invoke(flowCombine.FlowName, "\u6267\u884c\u5931\u8d25");
\n BackendLogAction?.Invoke($"\u540e\u53f0\u6d41\u7a0b\u6267\u884c\u5931\u8d25：{ex.Message}");
\n LogHelper.Error("\u540e\u53f0\u670d\u52a1\u6267\u884c\u5f02\u5e38", ex);
\n }
\n }, CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6ce8\u518c\u7cfb\u7edf\u6258\u76d8（WinForm\u6700\u5c0f\u5316\u5230\u540e\u53f0\u8fd0\u884c）
\n \/\/\/ <\/summary>
\n public void RegisterSystemTray(Form mainForm, NotifyIcon notifyIcon)
\n {
\n \/\/ \u521d\u59cb\u5316\u6258\u76d8\u56fe\u6807
\n notifyIcon.Icon = SystemIcons.Application;
\n notifyIcon.Text = "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u4e2d\u95f4\u4ef6";
\n notifyIcon.Visible = true;<\/p>\n\/\/ \u6258\u76d8\u53f3\u952e\u83dc\u5355
\n var contextMenu = new ContextMenuStrip();
\n contextMenu.Items.Add("\u663e\u793a\u754c\u9762", null, (s, e) => { mainForm.Show(); mainForm.WindowState = FormWindowState.Normal; });
\n contextMenu.Items.Add("\u9000\u51fa", null, (s, e) => { Application.Exit(); });
\n notifyIcon.ContextMenuStrip = contextMenu;<\/p>\n\/\/ \u7a97\u4f53\u6700\u5c0f\u5316\u5230\u6258\u76d8
\n mainForm.Resize += (s, e) =>
\n {
\n if (mainForm.WindowState == FormWindowState.Minimized)
\n {
\n mainForm.Hide();
\n notifyIcon.ShowBalloonTip(2000, "\u63d0\u793a", "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u4e2d\u95f4\u4ef6\u5df2\u6700\u5c0f\u5316\u5230\u540e\u53f0\u8fd0\u884c", ToolTipIcon.Info);
\n }
\n };<\/p>\n\/\/ \u6258\u76d8\u5de6\u952e\u53cc\u51fb\u663e\u793a\u754c\u9762
\n notifyIcon.MouseDoubleClick += (s, e) =>
\n {
\n if (e.Button == MouseButtons.Left)
\n {
\n mainForm.Show();
\n mainForm.WindowState = FormWindowState.Normal;
\n }
\n };<\/p>\nBackendLogAction?.Invoke("\u7cfb\u7edf\u6258\u76d8\u6ce8\u518c\u6210\u529f，\u652f\u6301\u540e\u53f0\u8fd0\u884c");
\n }
\n}<\/p>\n5. \u901a\u7528\u65e5\u5fd7\u52a9\u624b<\/h4>\n
\u5c01\u88c5\u6587\u4ef6\u65e5\u5fd7 + \u63a7\u5236\u53f0\u65e5\u5fd7，\u652f\u6301\u5206\u7ea7\u65e5\u5fd7（Info\/Warn\/Error），\u65b9\u4fbf MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u7684\u95ee\u9898\u6392\u67e5：<\/p>\n
csharp<\/p>\n
\u8fd0\u884c<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u901a\u7528\u65e5\u5fd7\u52a9\u624b
\n\/\/\/ <\/summary>
\npublic static class LogHelper
\n{
\n private static readonly string _logDir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "MesErpLogs");<\/p>\nstatic LogHelper()
\n {
\n if (!Directory.Exists(_logDir)) Directory.CreateDirectory(_logDir);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u4fe1\u606f\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void Info(string msg)
\n {
\n WriteLog("INFO", msg);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u8b66\u544a\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void Warn(string msg)
\n {
\n WriteLog("WARN", msg);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u9519\u8bef\u65e5\u5fd7
\n \/\/\/ <\/summary>
\n public static void Error(string msg, Exception ex = null)
\n {
\n var fullMsg = ex == null ? msg : $"{msg}\\\\r\\\\n\u5f02\u5e38\u4fe1\u606f：{ex.Message}\\\\r\\\\n\u5806\u6808\u8ddf\u8e2a：{ex.StackTrace}";
\n WriteLog("ERROR", fullMsg);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u5199\u5165\u65e5\u5fd7\u6587\u4ef6
\n \/\/\/ <\/summary>
\n private static void WriteLog(string level, string msg)
\n {
\n var logContent = $"[{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}] [{level}] {msg}\\\\r\\\\n";
\n \/\/ \u63a7\u5236\u53f0\u8f93\u51fa
\n Console.WriteLine(logContent);
\n \/\/ \u6587\u4ef6\u8f93\u51fa（\u6309\u65e5\u671f\u5206\u6587\u4ef6）
\n var logFile = Path.Combine(_logDir, $"MesErp_ProcessDelegate_{DateTime.Now:yyyyMMdd}.log");
\n try
\n {
\n File.AppendAllText(logFile, logContent, System.Text.Encoding.UTF8);
\n }
\n catch
\n {
\n \/\/ \u5ffd\u7565\u65e5\u5fd7\u5199\u5165\u5f02\u5e38，\u907f\u514d\u5f71\u54cd\u4e3b\u6d41\u7a0b
\n }
\n }
\n}<\/p>\n\u516d\u3001WinForm \u754c\u9762\u5b9e\u73b0（\u53ef\u89c6\u5316\u4e2d\u95f4\u4ef6）<\/h3>\n
\u8bbe\u8ba1\u7b80\u6d01\u6613\u7528\u7684 WinForm \u754c\u9762，\u5b9e\u73b0ERP \u5de5\u5355\u5bfc\u5165 \/ \u5de5\u827a\u8def\u7ebf\u914d\u7f6e \/ \u59d4\u6258\u62fc\u63a5 \/ \u6d41\u7a0b\u542f\u52a8 \/ \u540e\u53f0\u8fd0\u884c \/ \u72b6\u6001\u76d1\u63a7 \/ \u65e5\u5fd7\u67e5\u770b\u5168\u529f\u80fd，\u652f\u6301\u8de8\u7ebf\u7a0b UI \u72b6\u6001\u540c\u6b65：<\/p>\n
\/\/\/ <summary>
\n\/\/\/ MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u4e2d\u95f4\u4ef6\u4e3b\u754c\u9762
\n\/\/\/ \u6838\u5fc3\u529f\u80fd：\u5de5\u5355\u7ba1\u7406\u3001\u5de5\u827a\u8def\u7ebf\u914d\u7f6e\u3001\u59d4\u6258\u62fc\u63a5\u3001\u6d41\u7a0b\u6267\u884c\u3001\u540e\u53f0\u8fd0\u884c\u3001\u72b6\u6001\u76d1\u63a7\u3001\u65e5\u5fd7\u67e5\u770b
\n\/\/\/ <\/summary>
\npublic partial class MainForm : Form
\n{
\n #region \u670d\u52a1\u5b9e\u4f8b
\n private readonly MesErpDbHelper _dbHelper = MesErpDbHelper.Instance;
\n private readonly ProcessDelegateManager _delegateManager = ProcessDelegateManager.Instance;
\n private readonly ProcessFlowEngine _flowEngine = ProcessFlowEngine.Instance;
\n private readonly ProcessFlowBackendService _backendService = new ProcessFlowBackendService();
\n private readonly NotifyIcon _notifyIcon = new NotifyIcon();
\n #endregion<\/p>\n#region \u754c\u9762\u63a7\u4ef6
\n private ComboBox cboWorkOrder;
\n private Button btnAddOrder;
\n private Button btnAddProcess;
\n private Button btnCombineDelegate;
\n private Button btnStartFlow;
\n private Button btnPauseFlow;
\n private Button btnStopFlow;
\n private DataGridView dgvProcessRoute;
\n private DataGridView dgvRunningFlow;
\n private TextBox txtLog;
\n private Label lblBackendStatus;
\n private ComboBox cboExecuteMode;
\n #endregion<\/p>\npublic MainForm()
\n {
\n InitializeComponent();
\n \/\/ \u521d\u59cb\u5316UI
\n InitMainUI();
\n \/\/ \u6ce8\u518c\u540e\u53f0\u670d\u52a1\u59d4\u6258（UI\u72b6\u6001\u540c\u6b65+\u65e5\u5fd7）
\n RegisterBackendServiceDelegates();
\n \/\/ \u6ce8\u518c\u7cfb\u7edf\u6258\u76d8（\u540e\u53f0\u8fd0\u884c）
\n _backendService.RegisterSystemTray(this, _notifyIcon);
\n \/\/ \u52a0\u8f7d\u521d\u59cb\u6570\u636e
\n LoadInitData();
\n }<\/p>\n#region UI\u521d\u59cb\u5316
\n private void InitMainUI()
\n {
\n \/\/ \u7a97\u4f53\u57fa\u7840\u8bbe\u7f6e
\n this.Text = "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u4e2d\u95f4\u4ef6\u670d\u52a1";
\n this.Size = new Size(1000, 600);
\n this.StartPosition = FormStartPosition.CenterScreen;
\n this.FormClosing += (s, e) => { _notifyIcon.Visible = false; };<\/p>\n\/\/ \u63a7\u4ef6\u521d\u59cb\u5316
\n cboWorkOrder = new ComboBox { Location = new Point(10, 10), Size = new Size(200, 23), DropDownStyle = ComboBoxStyle.DropDownList };
\n btnAddOrder = new Button { Location = new Point(220, 10), Size = new Size(80, 23), Text = "\u65b0\u589e\u5de5\u5355" };
\n btnAddProcess = new Button { Location = new Point(310, 10), Size = new Size(80, 23), Text = "\u65b0\u589e\u5de5\u5e8f" };
\n btnCombineDelegate = new Button { Location = new Point(400, 10), Size = new Size(100, 23), Text = "\u59d4\u6258\u62fc\u63a5" };
\n cboExecuteMode = new ComboBox { Location = new Point(510, 10), Size = new Size(120, 23), DataSource = Enum.GetValues(typeof(FlowExecuteMode)) };
\n btnStartFlow = new Button { Location = new Point(640, 10), Size = new Size(80, 23), Text = "\u542f\u52a8\u6d41\u7a0b", BackColor = Color.LightGreen };
\n btnPauseFlow = new Button { Location = new Point(730, 10), Size = new Size(80, 23), Text = "\u6682\u505c\u6d41\u7a0b", BackColor = Color.Orange };
\n btnStopFlow = new Button { Location = new Point(820, 10), Size = new Size(80, 23), Text = "\u7ec8\u6b62\u6d41\u7a0b", BackColor = Color.LightPink };
\n lblBackendStatus = new Label { Location = new Point(910, 10), Size = new Size(80, 23), Text = "\u540e\u53f0\u72b6\u6001：\u7a7a\u95f2" };<\/p>\n\/\/ \u5de5\u827a\u8def\u7ebf\u7f51\u683c
\n dgvProcessRoute = new DataGridView { Location = new Point(10, 40), Size = new Size(980, 200), ReadOnly = true, AllowUserToAddRows = false };
\n dgvProcessRoute.Columns.AddRange(new[]
\n {
\n new DataGridViewTextBoxColumn { Name = "ProcessCode", HeaderText = "\u5de5\u5e8f\u7f16\u7801", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "ProcessName", HeaderText = "\u5de5\u5e8f\u540d\u79f0", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "SortNo", HeaderText = "\u6267\u884c\u987a\u5e8f", Width = 80 },
\n new DataGridViewTextBoxColumn { Name = "Status", HeaderText = "\u5de5\u5e8f\u72b6\u6001", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "CompleteQty", HeaderText = "\u5b8c\u6210\u4ea7\u91cf", Width = 100 },
\n new DataGridViewTextBoxColumn { Name = "DelegateCombine", HeaderText = "\u59d4\u6258\u7ec4\u5408", Width = 200 },
\n new DataGridViewTextBoxColumn { Name = "Params", HeaderText = "\u5de5\u5e8f\u53c2\u6570", Width = 300 }
\n });<\/p>\n\/\/ \u8fd0\u884c\u6d41\u7a0b\u7f51\u683c
\n dgvRunningFlow = new DataGridView { Location = new Point(10, 250), Size = new Size(980, 100), ReadOnly = true, AllowUserToAddRows = false };
\n dgvRunningFlow.Columns.AddRange(new[]
\n {
\n new DataGridViewTextBoxColumn { Name = "FlowName", HeaderText = "\u6d41\u7a0b\u540d\u79f0", Width = 200 },
\n new DataGridViewTextBoxColumn { Name = "OrderNo", HeaderText = "\u5173\u8054\u5de5\u5355", Width = 150 },
\n new DataGridViewTextBoxColumn { Name = "ExecuteMode", HeaderText = "\u6267\u884c\u6a21\u5f0f", Width = 150 },
\n new DataGridViewTextBoxColumn { Name = "Status", HeaderText = "\u6d41\u7a0b\u72b6\u6001", Width = 150 },
\n new DataGridViewTextBoxColumn { Name = "CurrentProcess", HeaderText = "\u5f53\u524d\u5de5\u5e8f", Width = 200 },
\n new DataGridViewTextBoxColumn { Name = "CompleteQty", HeaderText = "\u5b8c\u6210\u4ea7\u91cf", Width = 130 }
\n });<\/p>\n\/\/ \u65e5\u5fd7\u6587\u672c\u6846
\n txtLog = new TextBox { Location = new Point(10, 360), Size = new Size(980, 220), Multiline = true, ReadOnly = true, ScrollBars = ScrollBars.Vertical };<\/p>\n\/\/ \u7ed1\u5b9a\u63a7\u4ef6\u4e8b\u4ef6
\n btnAddOrder.Click += BtnAddOrder_Click;
\n btnAddProcess.Click += BtnAddProcess_Click;
\n btnCombineDelegate.Click += BtnCombineDelegate_Click;
\n btnStartFlow.Click += BtnStartFlow_Click;
\n btnPauseFlow.Click += BtnPauseFlow_Click;
\n btnStopFlow.Click += BtnStopFlow_Click;
\n cboWorkOrder.SelectedIndexChanged += CboWorkOrder_SelectedIndexChanged;<\/p>\n\/\/ \u6dfb\u52a0\u63a7\u4ef6\u5230\u7a97\u4f53
\n this.Controls.AddRange(new Control[] { cboWorkOrder, btnAddOrder, btnAddProcess, btnCombineDelegate, cboExecuteMode,
\n btnStartFlow, btnPauseFlow, btnStopFlow, lblBackendStatus, dgvProcessRoute, dgvRunningFlow, txtLog });
\n }
\n #endregion<\/p>\n#region \u59d4\u6258\u6ce8\u518c（\u8de8\u7ebf\u7a0bUI\u540c\u6b65）
\n private void RegisterBackendServiceDelegates()
\n {
\n \/\/ \u540e\u53f0\u670d\u52a1\u72b6\u6001\u66f4\u65b0
\n _backendService.UiStatusUpdateAction = (flowName, status) =>
\n {
\n if (this.InvokeRequired)
\n this.Invoke(new Action<string, string>((f, s) => { lblBackendStatus.Text = $"\u540e\u53f0\u72b6\u6001：{s}"; }), flowName, status);
\n else
\n lblBackendStatus.Text = $"\u540e\u53f0\u72b6\u6001：{status}";
\n };<\/p>\n\/\/ \u540e\u53f0\u670d\u52a1\u65e5\u5fd7\u540c\u6b65\u5230UI
\n _backendService.BackendLogAction = (log) =>
\n {
\n if (txtLog.InvokeRequired)
\n txtLog.Invoke(new Action<string>(AddLogToUi), log);
\n else
\n AddLogToUi(log);
\n };<\/p>\n\/\/ \u5168\u5c40\u65e5\u5fd7\u540c\u6b65\u5230UI
\n typeof(LogHelper).GetField("_logDir", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Static);
\n LogHelper.Info("UI\u59d4\u6258\u6ce8\u518c\u6210\u529f，\u652f\u6301\u8de8\u7ebf\u7a0b\u72b6\u6001\u540c\u6b65");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6dfb\u52a0\u65e5\u5fd7\u5230UI\u6587\u672c\u6846
\n \/\/\/ <\/summary>
\n private void AddLogToUi(string log)
\n {
\n txtLog.AppendText($"[{DateTime.Now:HH:mm:ss.fff}] {log}\\\\r\\\\n");
\n txtLog.ScrollToCaret();
\n }
\n #endregion<\/p>\n#region \u6570\u636e\u52a0\u8f7d
\n private void LoadInitData()
\n {
\n \/\/ \u52a0\u8f7dERP\u5de5\u5355\u5230\u4e0b\u62c9\u6846
\n var orders = _dbHelper.QueryList<ErpWorkOrder>("SELECT * FROM ErpWorkOrder");
\n cboWorkOrder.DataSource = orders;
\n cboWorkOrder.DisplayMember = "OrderNo";
\n cboWorkOrder.ValueMember = "OrderNo";<\/p>\nAddLogToUi("\u521d\u59cb\u6570\u636e\u52a0\u8f7d\u5b8c\u6210，\u5de5\u5355\u6570\u91cf：" + orders.Count);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u52a0\u8f7d\u9009\u4e2d\u5de5\u5355\u7684\u5de5\u827a\u8def\u7ebf
\n \/\/\/ <\/summary>
\n private void LoadProcessRoute(string orderNo)
\n {
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n if (route == null) return;<\/p>\ndgvProcessRoute.Rows.Clear();
\n foreach (var process in route.ProcessNodes.OrderBy(p => p.SortNo))
\n {
\n var row = dgvProcessRoute.Rows.Add();
\n dgvProcessRoute.Rows[row].Cells["ProcessCode"].Value = process.ProcessCode;
\n dgvProcessRoute.Rows[row].Cells["ProcessName"].Value = process.ProcessName;
\n dgvProcessRoute.Rows[row].Cells["SortNo"].Value = process.SortNo;
\n dgvProcessRoute.Rows[row].Cells["Status"].Value = process.Status;
\n dgvProcessRoute.Rows[row].Cells["CompleteQty"].Value = process.CompleteQty;
\n dgvProcessRoute.Rows[row].Cells["DelegateCombine"].Value = process.DelegateCombineId;
\n dgvProcessRoute.Rows[row].Cells["Params"].Value = JsonConvert.SerializeObject(process.Params);
\n }
\n }
\n #endregion<\/p>\n#region \u754c\u9762\u4e8b\u4ef6\u5904\u7406（\u6838\u5fc3\u529f\u80fd）
\n \/\/\/ <summary>
\n \/\/\/ \u65b0\u589eERP\u5de5\u5355
\n \/\/\/ <\/summary>
\n private void BtnAddOrder_Click(object sender, EventArgs e)
\n {
\n var order = new ErpWorkOrder
\n {
\n OrderNo = "WO-" + DateTime.Now.ToString("yyyyMMddHHmmss"),
\n ProductCode = "PROD-" + new Random().Next(1000, 9999),
\n ProductName = "\u6d4b\u8bd5\u4ea7\u54c1-" + new Random().Next(100, 999),
\n PlanQty = 1000,
\n LineCode = "LINE-001"
\n };
\n _dbHelper.SaveObject("ErpWorkOrder", "OrderNo", order);
\n \/\/ \u521d\u59cb\u5316\u5de5\u827a\u8def\u7ebf
\n var route = new ProcessRoute { OrderNo = order.OrderNo, LineCode = order.LineCode };
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);<\/p>\nLoadInitData();
\n AddLogToUi($"\u65b0\u589eERP\u5de5\u5355\u6210\u529f：{order.OrderNo}，\u4ea7\u54c1：{order.ProductName}，\u8ba1\u5212\u4ea7\u91cf：{order.PlanQty}\u4ef6");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u65b0\u589e\u5de5\u5e8f\u8282\u70b9
\n \/\/\/ <\/summary>
\n private void BtnAddProcess_Click(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue == null)
\n {
\n MessageBox.Show("\u8bf7\u5148\u9009\u62e9\u5de5\u5355！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\nvar orderNo = cboWorkOrder.SelectedValue.ToString();
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n if (route == null) route = new ProcessRoute { OrderNo = orderNo };<\/p>\nvar process = new ProcessNode
\n {
\n ProcessCode = "PROC-" + new Random().Next(1000, 9999),
\n ProcessName = "\u6d4b\u8bd5\u5de5\u5e8f-" + new Random().Next(100, 999),
\n SortNo = route.ProcessNodes.Count + 1,
\n Status = ProcessStatus.UnInitialized
\n };
\n route.ProcessNodes.Add(process);
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);<\/p>\nLoadProcessRoute(orderNo);
\n AddLogToUi($"\u65b0\u589e\u5de5\u5e8f\u6210\u529f：{process.ProcessCode}，\u5de5\u5e8f\u540d\u79f0：{process.ProcessName}，\u6267\u884c\u987a\u5e8f：{process.SortNo}");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u59d4\u6258\u62fc\u63a5（\u57fa\u7840\u59d4\u6258->\u5de5\u5e8f\u7ec4\u5408\u59d4\u6258）
\n \/\/\/ <\/summary>
\n private void BtnCombineDelegate_Click(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue == null || dgvProcessRoute.SelectedRows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u9009\u62e9\u5de5\u5355\u548c\u5de5\u5e8f！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\nvar orderNo = cboWorkOrder.SelectedValue.ToString();
\n var processRow = dgvProcessRoute.SelectedRows[0];
\n var processCode = processRow.Cells["ProcessCode"].Value.ToString();
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n var process = route.ProcessNodes.First(p => p.ProcessCode == processCode);<\/p>\n\/\/ \u83b7\u53d6\u6240\u6709\u57fa\u7840\u59d4\u6258（\u7b80\u5316\u7248，\u5b9e\u9645\u53ef\u505a\u53ef\u89c6\u5316\u9009\u62e9）
\n var allBaseDelegates = _delegateManager.GetType().GetField("_baseDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, BaseDelegateInfo>;
\n var selectBaseDelegates = allBaseDelegates.Values.Take(2).ToList(); \/\/ \u9009\u62e9\u524d2\u4e2a\u57fa\u7840\u59d4\u6258<\/p>\n\/\/ \u62fc\u63a5\u5de5\u5e8f\u7ea7\u59d4\u6258\u7ec4\u5408（\u4e32\u884c\u6267\u884c）
\n var combine = _delegateManager.CombineProcessDelegates($"{processCode}\u59d4\u6258\u7ec4\u5408", DelegateCombineType.Serial, selectBaseDelegates);
\n \/\/ \u7ed1\u5b9a\u5230\u5de5\u5e8f\u8282\u70b9
\n process.DelegateCombineId = combine.CombineId;
\n _dbHelper.SaveObject("ProcessRoute", "RouteId", route);<\/p>\nLoadProcessRoute(orderNo);
\n AddLogToUi($"\u5de5\u5e8f{processCode}\u59d4\u6258\u62fc\u63a5\u6210\u529f，\u7ed1\u5b9a\u7ec4\u5408ID：{combine.CombineId}，\u5305\u542b{selectBaseDelegates.Count}\u4e2a\u57fa\u7840\u59d4\u6258");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u542f\u52a8\u5de5\u5e8f\u6d41\u7a0b（UI\/\u540e\u53f0\u6a21\u5f0f\u53ef\u9009）
\n \/\/\/ <\/summary>
\n private void BtnStartFlow_Click(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue == null || dgvProcessRoute.Rows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u5148\u914d\u7f6e\u5de5\u5355\u548c\u5de5\u5e8f！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\nvar orderNo = cboWorkOrder.SelectedValue.ToString();
\n var order = _dbHelper.GetObject<ErpWorkOrder>("ErpWorkOrder", "OrderNo", orderNo);
\n var route = _dbHelper.GetObject<ProcessRoute>("ProcessRoute", "OrderNo", orderNo);
\n var executeMode = (FlowExecuteMode)cboExecuteMode.SelectedValue;<\/p>\n\/\/ \u62fc\u63a5\u4ea7\u7ebf\u7ea7\u6d41\u7a0b\u59d4\u6258
\n var processCombines = route.ProcessNodes.Where(p => !string.IsNullOrEmpty(p.DelegateCombineId))
\n .Select(p => _delegateManager.GetProcessCombineByProcessId(p.ProcessId, route)).ToList();
\n var flowCombine = _delegateManager.CombineFlowDelegates($"{orderNo}\u6d41\u7a0b", route.RouteId, processCombines, executeMode);<\/p>\n\/\/ \u6267\u884c\u6d41\u7a0b（UI\u6a21\u5f0f\/\u540e\u53f0\u6a21\u5f0f）
\n if (executeMode == FlowExecuteMode.WinFormUI)
\n {
\n _flowEngine.StartFlowAsync(flowCombine, order, route);
\n AddLogToUi($"UI\u6a21\u5f0f\u542f\u52a8\u6d41\u7a0b：{flowCombine.FlowName}，\u5de5\u5355：{orderNo}");
\n }
\n else
\n {
\n _backendService.RunFlowInBackend(flowCombine, order, route);
\n AddLogToUi($"\u540e\u53f0\u6a21\u5f0f\u542f\u52a8\u6d41\u7a0b：{flowCombine.FlowName}，\u5de5\u5355：{orderNo}，\u540e\u53f0\u670d\u52a1\u5df2\u63a5\u7ba1");
\n }<\/p>\n\/\/ \u66f4\u65b0\u8fd0\u884c\u6d41\u7a0b\u7f51\u683c
\n UpdateRunningFlowGrid(flowCombine, order, route);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u6682\u505c\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n private void BtnPauseFlow_Click(object sender, EventArgs e)
\n {
\n if (dgvRunningFlow.SelectedRows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u9009\u62e9\u8fd0\u884c\u4e2d\u7684\u6d41\u7a0b！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\nvar flowName = dgvRunningFlow.SelectedRows[0].Cells["FlowName"].Value.ToString();
\n var flowCombine = _delegateManager.GetType().GetField("_flowCombineDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, FlowDelegateCombineInfo>;
\n var flow = flowCombine.Values.First(f => f.FlowName == flowName);<\/p>\n_flowEngine.PauseFlow(flow.FlowCombineId);
\n AddLogToUi($"\u6682\u505c\u6d41\u7a0b：{flowName}，\u6d41\u7a0bID：{flow.FlowCombineId}");
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u7ec8\u6b62\u6d41\u7a0b
\n \/\/\/ <\/summary>
\n private void BtnStopFlow_Click(object sender, EventArgs e)
\n {
\n if (dgvRunningFlow.SelectedRows.Count == 0)
\n {
\n MessageBox.Show("\u8bf7\u9009\u62e9\u8fd0\u884c\u4e2d\u7684\u6d41\u7a0b！", "\u63d0\u793a", MessageBoxButtons.OK, MessageBoxIcon.Warning);
\n return;
\n }<\/p>\nvar flowName = dgvRunningFlow.SelectedRows[0].Cells["FlowName"].Value.ToString();
\n var flowCombine = _delegateManager.GetType().GetField("_flowCombineDelegateDict", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)
\n .GetValue(_delegateManager) as Dictionary<string, FlowDelegateCombineInfo>;
\n var flow = flowCombine.Values.First(f => f.FlowName == flowName);<\/p>\n_flowEngine.StopFlow(flow.FlowCombineId);
\n AddLogToUi($"\u7ec8\u6b62\u6d41\u7a0b：{flowName}，\u6d41\u7a0bID：{flow.FlowCombineId}");
\n dgvRunningFlow.Rows.Remove(dgvRunningFlow.SelectedRows[0]);
\n }<\/p>\n\/\/\/ <summary>
\n \/\/\/ \u5de5\u5355\u9009\u62e9\u53d8\u66f4，\u52a0\u8f7d\u5bf9\u5e94\u5de5\u827a\u8def\u7ebf
\n \/\/\/ <\/summary>
\n private void CboWorkOrder_SelectedIndexChanged(object sender, EventArgs e)
\n {
\n if (cboWorkOrder.SelectedValue != null)
\n LoadProcessRoute(cboWorkOrder.SelectedValue.ToString());
\n }
\n #endregion<\/p>\n#region UI\u8f85\u52a9\u65b9\u6cd5
\n \/\/\/ <summary>
\n \/\/\/ \u66f4\u65b0\u8fd0\u884c\u6d41\u7a0b\u7f51\u683c
\n \/\/\/ <\/summary>
\n private void UpdateRunningFlowGrid(FlowDelegateCombineInfo flowCombine, ErpWorkOrder order, ProcessRoute route)
\n {
\n var row = dgvRunningFlow.Rows.Add();
\n dgvRunningFlow.Rows[row].Cells["FlowName"].Value = flowCombine.FlowName;
\n dgvRunningFlow.Rows[row].Cells["OrderNo"].Value = order.OrderNo;
\n dgvRunningFlow.Rows[row].Cells["ExecuteMode"].Value = flowCombine.ExecuteMode;
\n dgvRunningFlow.Rows[row].Cells["Status"].Value = "\u6267\u884c\u4e2d";
\n dgvRunningFlow.Rows[row].Cells["CurrentProcess"].Value = route.ProcessNodes[route.CurrentProcessIndex].ProcessCode;
\n dgvRunningFlow.Rows[row].Cells["CompleteQty"].Value = order.CompleteQty;
\n }
\n #endregion<\/p>\n\/\/ \u8bbe\u8ba1\u5668\u4ee3\u7801（\u81ea\u52a8\u751f\u6210，\u65e0\u9700\u624b\u52a8\u7f16\u5199）
\n private void InitializeComponent()
\n {
\n this.SuspendLayout();
\n this.ClientSize = new System.Drawing.Size(1000, 600);
\n this.Name = "MainForm";
\n this.Text = "MES\/ERP\u5de5\u5e8f\u6d41\u7a0b\u59d4\u6258\u4e2d\u95f4\u4ef6\u670d\u52a1";
\n this.ResumeLayout(false);
\n }
\n}<\/p>\n\/\/ \u7a0b\u5e8f\u5165\u53e3
\nstatic class Program
\n{
\n [STAThread]
\n static void Main()
\n {
\n Application.EnableVisualStyles();
\n Application.SetCompatibleTextRenderingDefault(false);
\n Application.Run(new MainForm());
\n }
\n}<\/p>\n\u4e03\u3001\u90e8\u7f72\u4e0e\u4f7f\u7528\u8bf4\u660e<\/h3>\n
1. \u90e8\u7f72\u6b65\u9aa4<\/h4>\n
- \u521b\u5efa\u9879\u76ee：\u5728 Visual Studio 2022 \u4e2d\u521b\u5efa\u300cWindows \u7a97\u4f53\u5e94\u7528（.NET Framework 4.8）\u300d\u9879\u76ee；<\/li>\n
- \u5b89\u88c5 NuGet \u5305：\u6267\u884c\u524d\u7f6e\u51c6\u5907\u4e2d\u7684 NuGet \u5b89\u88c5\u547d\u4ee4，\u5b89\u88c5\u6240\u6709\u4f9d\u8d56；<\/li>\n
- \u6dfb\u52a0\u4ee3\u7801：\u5c06\u4e0a\u8ff0\u6240\u6709\u4ee3\u7801\u6309\u7c7b\u62c6\u5206\u5230\u5bf9\u5e94\u6587\u4ef6\u4e2d（\u6216\u76f4\u63a5\u590d\u5236\u5230 Program.cs，\u5220\u9664\u539f\u6709\u4ee3\u7801）；<\/li>\n
- \u7f16\u8bd1\u9879\u76ee：\u751f\u6210 EXE \u53ef\u6267\u884c\u6587\u4ef6（\u9ed8\u8ba4\u5728 bin\/Debug\/ \u4e0b）；<\/li>\n
- \u76f4\u63a5\u8fd0\u884c：\u65e0\u9700\u5b89\u88c5\u6570\u636e\u5e93 \/ ERP\/MES \u73af\u5883，\u8fd0\u884c EXE \u5373\u53ef，\u7a0b\u5e8f\u4f1a\u81ea\u52a8\u521b\u5efa\u672c\u5730\u6570\u636e\u5e93\u548c\u65e5\u5fd7\u76ee\u5f55\u3002<\/li>\n
2. \u6838\u5fc3\u529f\u80fd\u64cd\u4f5c\u6d41\u7a0b<\/h4>\n
- \u65b0\u589e ERP \u5de5\u5355：\u70b9\u51fb\u300c\u65b0\u589e\u5de5\u5355\u300d，\u7a0b\u5e8f\u81ea\u52a8\u751f\u6210\u6807\u51c6\u5316 ERP \u5de5\u5355（\u5305\u542b\u5de5\u5355\u53f7\u3001\u4ea7\u54c1\u3001\u8ba1\u5212\u4ea7\u91cf）；<\/li>\n
- \u65b0\u589e\u5de5\u5e8f\u8282\u70b9：\u9009\u62e9\u5de5\u5355，\u70b9\u51fb\u300c\u65b0\u589e\u5de5\u5e8f\u300d，\u751f\u6210\u5de5\u5e8f\u8282\u70b9\u5e76\u6dfb\u52a0\u5230\u5de5\u827a\u8def\u7ebf；<\/li>\n
- \u59d4\u6258\u62fc\u63a5：\u9009\u62e9\u5de5\u5e8f，\u70b9\u51fb\u300c\u59d4\u6258\u62fc\u63a5\u300d，\u7a0b\u5e8f\u81ea\u52a8\u5c06\u901a\u7528\u9ed8\u8ba4\u57fa\u7840\u59d4\u6258\u62fc\u63a5\u6210\u5de5\u5e8f\u7ea7\u7ec4\u5408\u59d4\u6258\u5e76\u7ed1\u5b9a\u5230\u5de5\u5e8f；<\/li>\n
- \u9009\u62e9\u6267\u884c\u6a21\u5f0f：\u4e0b\u62c9\u6846\u9009\u62e9\u300cWinFormUI\u300d（\u5e26 UI \u8fdb\u5ea6\u53cd\u9988）\u6216\u300cBackendService\u300d（\u540e\u53f0\u65e0 UI \u963b\u585e\u8fd0\u884c）；<\/li>\n
- \u542f\u52a8\u6d41\u7a0b：\u70b9\u51fb\u300c\u542f\u52a8\u6d41\u7a0b\u300d，\u7a0b\u5e8f\u81ea\u52a8\u62fc\u63a5\u4ea7\u7ebf\u7ea7\u6d41\u7a0b\u59d4\u6258\u5e76\u6267\u884c，\u65e5\u5fd7\u5b9e\u65f6\u540c\u6b65\u5230 UI；<\/li>\n
- \u6d41\u7a0b\u63a7\u5236：\u70b9\u51fb\u300c\u6682\u505c\u6d41\u7a0b \/ \u7ec8\u6b62\u6d41\u7a0b\u300d，\u53ef\u5bf9\u8fd0\u884c\u4e2d\u7684\u6d41\u7a0b\u8fdb\u884c\u7ba1\u63a7；<\/li>\n
- \u540e\u53f0\u8fd0\u884c：\u5c06\u7a97\u4f53\u6700\u5c0f\u5316，\u7a0b\u5e8f\u81ea\u52a8\u9690\u85cf\u5230\u7cfb\u7edf\u6258\u76d8，\u540e\u53f0\u7ee7\u7eed\u6267\u884c\u6d41\u7a0b\u3002<\/li>\n
3. \u4e0e\u5b9e\u9645 MES\/ERP \u5bf9\u63a5\u6269\u5c55<\/h4>\n
- ERP \u5de5\u5355\u5bfc\u5165：\u4fee\u6539BtnAddOrder_Click\u65b9\u6cd5，\u6dfb\u52a0 ERP \u63a5\u53e3\u8c03\u7528\u4ee3\u7801（\u5982 WebAPI\/WS\/SQL），\u5b9e\u73b0\u4ece\u5b9e\u9645 ERP \u7cfb\u7edf\u5bfc\u5165\u5de5\u5355；<\/li>\n
- MES \u6570\u636e\u4ea4\u4e92：\u6269\u5c55DefaultDelegates\u7c7b，\u6dfb\u52a0 MES \u63a5\u53e3\u59d4\u6258（\u5982 MES \u5de5\u5e8f\u72b6\u6001\u4e0a\u62a5\u3001MES \u4ea7\u91cf\u540c\u6b65）；<\/li>\n
- \u8bbe\u5907\u5bf9\u63a5：\u5728\u57fa\u7840\u59d4\u6258\u4e2d\u6dfb\u52a0 PLC \/ \u4f20\u611f\u5668 \/ \u673a\u5668\u4eba\u901a\u4fe1\u4ee3\u7801（\u5982S7.Net\u3001Modbus\u3001OPC UA），\u5b9e\u73b0\u5de5\u5e8f\u6267\u884c\u7684\u8bbe\u5907\u63a7\u5236；<\/li>\n
- \u590d\u6742\u8868\u8fbe\u5f0f：\u96c6\u6210 NCalc\/EL \u8868\u8fbe\u5f0f\u5f15\u64ce，\u66ff\u6362EvaluateConditionalExpr\u65b9\u6cd5，\u652f\u6301\u590d\u6742\u7684\u59d4\u6258\u6761\u4ef6\u6267\u884c\u8868\u8fbe\u5f0f；<\/li>\n
- \u53ef\u89c6\u5316\u59d4\u6258\u914d\u7f6e：\u65b0\u589e\u59d4\u6258\u914d\u7f6e\u7a97\u4f53，\u5b9e\u73b0\u57fa\u7840\u59d4\u6258\u7684\u53ef\u89c6\u5316\u9009\u62e9\u3001\u53c2\u6570\u914d\u7f6e\u3001\u62fc\u63a5\u89c4\u5219\u8bbe\u7f6e\u3002<\/li>\n
\u516b\u3001\u6838\u5fc3\u4f18\u52bf\u4e0e\u603b\u7ed3<\/h3>\n
\u6838\u5fc3\u4f18\u52bf<\/h4>\n
- \u59d4\u6258\u591a\u7ed3\u6784\u62fc\u63a5：\u72ec\u521b\u300c\u57fa\u7840\u59d4\u6258 + \u5de5\u5e8f\u7ec4\u5408\u59d4\u6258 + \u6d41\u7a0b\u62fc\u63a5\u59d4\u6258\u300d\u4e09\u7ea7\u4f53\u7cfb，\u652f\u6301\u4efb\u610f\u5de5\u5e8f\u6d41\u7a0b\u7ed3\u6784，\u9002\u914d MES\/ERP \u7684\u4e2a\u6027\u5316\u5de5\u827a\u8def\u7ebf；<\/li>\n
- \u4e1a\u52a1\u4e0e UI \u5b8c\u5168\u89e3\u8026：\u59d4\u6258\u51fd\u6570\u5c01\u88c5\u6240\u6709\u4e1a\u52a1\u903b\u8f91，UI \u5c42\u4ec5\u8d1f\u8d23\u5c55\u793a\u548c\u64cd\u4f5c，\u4fee\u6539\u4e1a\u52a1\u903b\u8f91\u65e0\u9700\u6539\u52a8 UI \u4ee3\u7801；<\/li>\n
- \u540e\u53f0\u670d\u52a1\u5316\u80fd\u529b：\u652f\u6301 WinForm UI \u6267\u884c\u548c\u540e\u53f0\u65e0 UI \u963b\u585e\u6267\u884c，\u6700\u5c0f\u5316\u5230\u7cfb\u7edf\u6258\u76d8，\u9002\u914d\u4ea7\u7ebf 7*24 \u5c0f\u65f6\u8fd0\u884c\u9700\u6c42；<\/li>\n
- \u914d\u7f6e\u6301\u4e45\u5316：\u57fa\u4e8e SQLite \u672c\u5730\u6570\u636e\u5e93，\u59d4\u6258\u62fc\u63a5\u5173\u7cfb\u3001\u5de5\u5355\u3001\u5de5\u827a\u8def\u7ebf\u3001\u5de5\u5e8f\u72b6\u6001\u5168\u6301\u4e45\u5316，\u7a0b\u5e8f\u91cd\u542f\u4e0d\u4e22\u5931；<\/li>\n
- \u9ad8\u6269\u5c55\u6027：\u9ed8\u8ba4\u63d0\u4f9b MES\/ERP \u901a\u7528\u57fa\u7840\u59d4\u6258，\u652f\u6301\u81ea\u5b9a\u4e49\u57fa\u7840\u59d4\u6258\u6ce8\u518c\u3001\u59d4\u6258\u7ec4\u5408\u89c4\u5219\u4fee\u6539\u3001\u8bbe\u5907 \/ \u7cfb\u7edf\u63a5\u53e3\u6269\u5c55；<\/li>\n
- \u7ebf\u7a0b\u5b89\u5168：\u5168\u6d41\u7a0b\u52a0\u9501 + \u5f02\u6b65\u6267\u884c + \u53d6\u6d88\u4ee4\u724c，\u652f\u6301\u591a\u6d41\u7a0b\u5e76\u53d1\u6267\u884c，\u65e0\u8d44\u6e90\u7ade\u4e89\u548c UI \u963b\u585e\u95ee\u9898\u3002<\/li>\n
\u5173\u952e\u70b9\u56de\u987e<\/h4>\n
- \u56f4\u7ed5MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u751f\u547d\u5468\u671f\u5c01\u88c5\u6807\u51c6\u5316\u4e8b\u4ef6\u59d4\u6258，\u8986\u76d6\u4ece\u6d41\u7a0b\u542f\u52a8\u5230\u5b8c\u6210\u7684\u5168\u8282\u70b9；<\/li>\n
- \u91c7\u7528\u4e09\u7ea7\u59d4\u6258\u62fc\u63a5\u8bbe\u8ba1，\u5b9e\u73b0\u539f\u5b50\u64cd\u4f5c\u5230\u5b8c\u6574\u6d41\u7a0b\u7684\u65e0\u9650\u7ec4\u5408，\u89e3\u51b3\u5de5\u5e8f\u6d41\u7a0b\u914d\u7f6e\u5316\u95ee\u9898；<\/li>\n
- \u8bbe\u8ba1\u540e\u53f0\u670d\u52a1\u7ba1\u7406\u5668，\u5b9e\u73b0 WinForm \u754c\u9762\u4e0e\u540e\u53f0\u6267\u884c\u89e3\u8026，\u652f\u6301\u7cfb\u7edf\u6258\u76d8\u540e\u53f0\u8fd0\u884c；<\/li>\n
- \u57fa\u4e8eSQLite \u672c\u5730\u6570\u636e\u5e93\u5b9e\u73b0\u914d\u7f6e\u548c\u72b6\u6001\u6301\u4e45\u5316，\u964d\u4f4e\u90e8\u7f72\u4f9d\u8d56，\u9002\u914d\u4ea7\u7ebf\u8fb9\u7f18\u8282\u70b9；<\/li>\n
- \u63d0\u4f9b\u5f00\u7bb1\u5373\u7528\u7684\u901a\u7528\u57fa\u7840\u59d4\u6258，\u540c\u65f6\u652f\u6301\u81ea\u5b9a\u4e49\u59d4\u6258\u6ce8\u518c，\u5feb\u901f\u5bf9\u63a5\u5b9e\u9645 MES\/ERP\/ \u8bbe\u5907\u7cfb\u7edf\u3002<\/li>\n
\u8be5\u4e2d\u95f4\u4ef6\u5b8c\u5168\u9002\u914d MES\/ERP \u7684\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u573a\u666f，\u53ef\u76f4\u63a5\u4f5c\u4e3a\u72ec\u7acb\u7684\u5de5\u5e8f\u6267\u884c\u4e2d\u95f4\u4ef6\u4f7f\u7528，\u4e5f\u53ef\u96c6\u6210\u5230\u73b0\u6709 MES\/ERP \u7cfb\u7edf\u4e2d，\u4f5c\u4e3a\u5de5\u5e8f\u6d41\u7a0b\u6267\u884c\u7684\u6838\u5fc3\u5f15\u64ce\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6
\nMES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u5c01\u88c5 WinForm \u4e2d\u95f4\u4ef6\u89e3\u51b3\u65b9\u6848
\n\u672c\u6b21\u4e3a MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6，\u6838\u5fc3\u56f4\u7ed5\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u4e8b\u4ef6（\u521d\u59cb\u5316\u3001\u542f\u52a8\u3001\u6267\u884c\u3001\u5b8c\u6210\u3001\u5f02\u5e38\u3001\u8df3\u8f6c\u7b49），\u8bbe\u8ba1\u591a\u7ed3\u6784\u62fc\u63a5\u7684\u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u57fa\u7840\u59d4\u6258\u3001\u7ec4\u5408\u59d4\u6258\u3001\u6d41\u7a0b\u59d4\u6258<\/p>\n","protected":false},"author":2,"featured_media":72578,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[7639,7638,7637],"topic":[],"class_list":["post-72579","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-7639","tag-7638","tag-7637"],"yoast_head":"\nMES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/72579.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6 MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u5c01\u88c5 WinForm \u4e2d\u95f4\u4ef6\u89e3\u51b3\u65b9\u6848 \u672c\u6b21\u4e3a MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6，\u6838\u5fc3\u56f4\u7ed5\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u4e8b\u4ef6（\u521d\u59cb\u5316\u3001\u542f\u52a8\u3001\u6267\u884c\u3001\u5b8c\u6210\u3001\u5f02\u5e38\u3001\u8df3\u8f6c\u7b49），\u8bbe\u8ba1\u591a\u7ed3\u6784\u62fc\u63a5\u7684\u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u57fa\u7840\u59d4\u6258\u3001\u7ec4\u5408\u59d4\u6258\u3001\u6d41\u7a0b\u59d4\u6258\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/72579.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-02-05T17:16:46+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260205171643-6984d07ba2b2f.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"26 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/72579.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/72579.html\",\"name\":\"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-02-05T17:16:46+00:00\",\"dateModified\":\"2026-02-05T17:16:46+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/72579.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/72579.html","og_locale":"zh_CN","og_type":"article","og_title":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6 MES\/ERP \u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u5c01\u88c5 WinForm \u4e2d\u95f4\u4ef6\u89e3\u51b3\u65b9\u6848 \u672c\u6b21\u4e3a MES\/ERP \u573a\u666f\u6253\u9020\u5de5\u5e8f\u6d41\u7a0b\u4e1a\u52a1\u6267\u884c\u4e8b\u4ef6\u7684\u591a\u5c42\u7ea7\u59d4\u6258\u62fc\u63a5\u5c01\u88c5WinForm \u4fe1\u606f\u4e2d\u95f4\u4ef6，\u6838\u5fc3\u56f4\u7ed5\u5de5\u5e8f\u6d41\u7a0b\u7684\u751f\u547d\u5468\u671f\u4e8b\u4ef6（\u521d\u59cb\u5316\u3001\u542f\u52a8\u3001\u6267\u884c\u3001\u5b8c\u6210\u3001\u5f02\u5e38\u3001\u8df3\u8f6c\u7b49），\u8bbe\u8ba1\u591a\u7ed3\u6784\u62fc\u63a5\u7684\u59d4\u6258\u51fd\u6570\u4f53\u7cfb（\u57fa\u7840\u59d4\u6258\u3001\u7ec4\u5408\u59d4\u6258\u3001\u6d41\u7a0b\u59d4\u6258","og_url":"https:\/\/www.wsisp.com\/helps\/72579.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-02-05T17:16:46+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260205171643-6984d07ba2b2f.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"26 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/72579.html","url":"https:\/\/www.wsisp.com\/helps\/72579.html","name":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-02-05T17:16:46+00:00","dateModified":"2026-02-05T17:16:46+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/72579.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/72579.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"MES\/ERP \u573a\u666f\u591a\u5c42\u7ea7\u59d4\u6258\u5c01\u88c5\u7ec4\u4ef6"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/72579","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=72579"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/72579\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/72578"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=72579"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=72579"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=72579"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=72579"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}