C#工作流示例(WorkflowCore)

using Microsoft.Extensions.DependencyInjection;
using WorkflowCore.Interface;
using WorkflowCore.Models;namespace LeaveRequestWorkflow
{// 請假申請單public class LeaveBill{/// <summary>/// 申請人/// </summary>public string EmployeeName { get; set; }/// <summary>/// 請假起始時間/// </summary>public DateTime StartDate { get; set; }/// <summary>/// 請假結束時間/// </summary>public DateTime EndDate { get; set; }/// <summary>/// 請假原因/// </summary>public string Reason { get; set; }/// <summary>/// 經理意見/// </summary>public string ManagerComment { get; set; }/// <summary>/// 是否同意/// </summary>public bool IsApproved { get; set; }/// <summary>/// 創建時間/// </summary>public DateTime CreateAt { get; set; } /// <summary>/// 處理時間/// </summary>public DateTime ProcessedAt { get; set; }}// 請假申請public class ApplyLeave : StepBody{ public override ExecutionResult Run(IStepExecutionContext context){var bill = (LeaveBill)context.Workflow.Data;bill.CreateAt = DateTime.Now;Console.WriteLine($"請假申請已提交 - 員工: {bill.EmployeeName},時間: {bill.StartDate.ToShortDateString()} 到 {bill.EndDate.ToShortDateString()}, 原因: {bill.Reason}");return ExecutionResult.Next();}}// 經理審批public class ManagerApproval : StepBody{  public override ExecutionResult Run(IStepExecutionContext context){var bill = (LeaveBill)context.Workflow.Data;bill.ProcessedAt = DateTime.Now;Console.WriteLine($"經理審批中 - {bill.EmployeeName} 的請假申請");// 簡單模擬:請假天數小于5天自動批準,否則拒絕var leaveDays = (bill.EndDate - bill.StartDate).Days;if (leaveDays <= 5){bill.IsApproved = true;bill.ManagerComment = "申請已批準,祝你休假愉快!"; }else{bill.IsApproved = false;bill.ManagerComment = "請假時間過長,請縮短假期或聯系HR"; }Console.WriteLine($"經理決定: {(bill.IsApproved ? "批準" : "拒絕")}");return ExecutionResult.Next();}}// 通知結果public class NotifyResult : StepBody{ public override ExecutionResult Run(IStepExecutionContext context){var bill = (LeaveBill)context.Workflow.Data; bill.ProcessedAt = DateTime.Now;Console.WriteLine($"消息通知 - {bill.EmployeeName},你的請假申請{(bill.IsApproved ? "已批準" : "未被批準")}。備注: {bill.ManagerComment}");return ExecutionResult.Next();}}// 定義請假工作流public class LeaveWorkflow : IWorkflow<LeaveBill>{public string Id => "LeaveRequestWorkflow";public int Version => 1;public void Build(IWorkflowBuilder<LeaveBill> builder){builder.StartWith<ApplyLeave>() .Then<ManagerApproval>() .Then<NotifyResult>(); }}class Program{static IServiceProvider ConfigureServices(){IServiceCollection services = new ServiceCollection();// 添加日志服務services.AddLogging();// 添加 WorkflowCoreservices.AddWorkflow();// 注冊你的工作流步驟(確保它們可以被DI容器創建)services.AddTransient<ApplyLeave>();services.AddTransient<ManagerApproval>();services.AddTransient<NotifyResult>();return services.BuildServiceProvider();}static async Task Main(string[] args){IServiceProvider serviceProvider = ConfigureServices();var host = serviceProvider.GetService<IWorkflowHost>();// 注冊工作流host?.RegisterWorkflow<LeaveWorkflow, LeaveBill>();// 啟動工作流主機host?.Start(); Console.WriteLine("\r\n工作流示例(WorkflowCore)\r\n");// 創建新的請假申請var request = new LeaveBill();Console.WriteLine(">>> 請假申請單 <<<\r\n");Console.Write("員工姓名: ");request.EmployeeName = Console.ReadLine();Console.Write("開始日期 (yyyy-mm-dd): ");if (DateTime.TryParse(Console.ReadLine(), out DateTime startDate))request.StartDate = startDate;elserequest.StartDate = DateTime.Now.AddDays(1);Console.Write("結束日期 (yyyy-mm-dd): ");if (DateTime.TryParse(Console.ReadLine(), out DateTime endDate))request.EndDate = endDate;elserequest.EndDate = DateTime.Now.AddDays(2);Console.Write("請假原因: ");request.Reason = Console.ReadLine();// 啟動工作流var workflowId = await host.StartWorkflow("LeaveRequestWorkflow", request);Console.WriteLine($"請假申請已提交,工作流ID: {workflowId}");// 等待一會兒讓工作流處理await Task.Delay(2000);host?.Stop();}}
}

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/web/95519.shtml
繁體地址,請注明出處:http://hk.pswp.cn/web/95519.shtml
英文地址,請注明出處:http://en.pswp.cn/web/95519.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

兩個子進程之間使用命名pipe

兩個子進程間可以使用命名管道&#xff0c;非常簡單。管道如果文件一樣存在硬盤中&#xff0c;使用ls可以查看&#xff0c;管道文件0字節。使用fork函數分別創建兩個子進程。 一個負責讀數據&#xff0c;一個負責寫數據。 #define _GNU_SOURCE #include <stdio.h> #inclu…

第一講、Kafka 初識與環境搭建

一、Kafka 是什么&#xff1f; Apache Kafka 是一個分布式的消息隊列&#xff08;Message Queue&#xff09;與流處理平臺。 它最早由 LinkedIn 開發&#xff0c;后來捐贈給 Apache 基金會&#xff0c;現已廣泛應用于日志收集、實時數據管道和大數據處理。 Kafka 的特點&…

Conda相關的用法

1、背景 此文主要記錄conda的一些用法&#xff0c;大部分命令來自ai搜索以及自己的理解。 2、安裝conda 2.1 選擇 conda 版本 2.1.1 Anaconda 含有 Conda 大量科學計算包&#xff08;NumPy、Pandas、Matplotlib 等&#xff09;適合數據科學、機器學習初學者下載地址&…

數據庫選擇有講究?SQLite、PostgreSQL還是MySQL?

不同規模的項目&#xff0c;數據庫選擇有講究。大家好&#xff0c;我是技術支持彼得&#xff0c;每天兩眼一睜就是為客戶解決問題。在日常使用我們的視頻平臺時&#xff0c;很多用戶會問到數據庫選擇的問題。今天就來詳細說說EasyGBS、EasyNVR和EasyCVR三大平臺該如何選擇數據庫…

在VMware的Win10虛擬機中安裝使用ENSP

VMware安裝Windows10 安裝ENSP及相關軟件 把安裝ENSP所使用的相關復制到已安裝好的Windows10虛擬機中&#xff0c;如下圖所示。 安裝VirtualBox 安裝時請確保路徑為英文目錄&#xff0c;并在出現"安裝設備軟件"或"Oracle USB設備"提示時選擇安裝選項。具…

Go 語言面試題詳解之接口 (Interface) 詳解一文吃透

自古流傳著一個傳言...在 Go 語言面試的時候必有人會問接口&#xff08;interface&#xff09;的實現原理。這又是為什么&#xff1f;為何對接口如此執著&#xff1f;實際上&#xff0c;Go 語言的接口設計在整體扮演著非常重要的角色&#xff0c;沒有他&#xff0c;很多程序估計…

ansible循環+判斷(with,loop,when,if,for)

一、文檔核心定位 本文檔聚焦Ansible自動化運維中的兩大核心功能——循環與判斷&#xff0c;通過“功能說明完整Playbook代碼”的形式&#xff0c;覆蓋循環迭代場景&#xff08;列表、字典、文件等&#xff09;、數據處理過濾器&#xff08;字符串、數字、加密等&#xff09;、…

在linux下使用MySQL常用的命令集合

1. 數據庫查看和選擇-- 查看所有數據庫 SHOW DATABASES;-- 選擇使用某個數據庫&#xff08;需要修改&#xff1a;your_database_name&#xff09; USE your_database_name;-- 查看當前正在使用的數據庫 SELECT DATABASE();說明&#xff1a;your_database_name 替換為你要操作的…

mysy2使用

參考鏈接 https://blog.csdn.net/qq_36525177/article/details/115279468 介紹 要把linux程序在windows上編譯&#xff0c;且最好兼容posix標準&#xff0c;就用msys2。 使用 1、先下載安裝&#xff0c;我裝在D:\mysy2 2、打開vscode&#xff0c;不要切換目錄&#xff0c;…

【Protues仿真】基于AT89C52單片機的溫濕度測量

目錄 0案例視頻效果展示 1DHT11溫度濕度傳感器 1.1傳感器簡介 1.2引腳定義&#xff08;從左到右&#xff0c;面對網格面&#xff09; 1.3時序 & 校驗&#xff08;原理速覽&#xff09; 1.4常見故障排查 2 DHT11溫度濕度傳感器數據 2.1 DHT11溫度濕度傳感器數據格式…

JavaScript箭頭函數與普通函數:兩種工作方式的深度解析

文章目錄JavaScript箭頭函數與普通函數&#xff1a;兩種"工作方式"的深度解析 &#x1f3f9;&#x1f19a;&#x1f468;&#x1f4bc;引言&#xff1a;為什么需要箭頭函數&#xff1f;核心區別全景圖對比表格&#xff1a;箭頭函數 vs 普通函數關系示意圖一、this綁定…

藍光三維掃描技術賦能內衣胸墊設計:從精準制造到個性化體驗的革新之旅

在競爭激烈的內衣市場中&#xff0c;產品設計的精準性、舒適度和個性化已成為品牌制勝的關鍵。傳統內衣設計依賴主觀經驗與樣品反復調整&#xff0c;不僅周期長、成本高&#xff0c;且難以實現對復雜胸型的精準適配。為應對這一挑戰&#xff0c;某知名內衣品牌采用新拓三維XTOM…

內存保護單元MPU

一、介紹內存保護單元 是一種硬件模塊&#xff0c;通常集成在處理器內核中&#xff0c;用于管理和管理對內存的訪問&#xff0c;以提高系統的可靠性和安全性。它的核心任務是保護。想象一下&#xff0c;一個操作系統中有多個任務在運行&#xff1a;* 任務A的代碼 bug 可能會錯誤…

【Kubernetes知識點】監控升級,備份及Kustomize管理

目錄 1.舉例說明K8s中都有哪些常規的維護管理操作。 2.如何升級K8s到新的版本&#xff1f;在升級過程中應該注意哪些事項&#xff1f; 3.解釋ETCD及其備份和恢復的過程。 4.Kustomization在Kubernetes中的作用 1.舉例說明K8s中都有哪些常規的維護管理操作。 集群狀態監控…

《Effective Java》第4條:通過私有構造器強化不可實例化的能力

說明&#xff1a; 關于本博客使用的書籍&#xff0c;源代碼Gitee倉庫 和 其他的相關問題&#xff0c;請查看本專欄置頂文章&#xff1a;《Effective Java》第0條&#xff1a;寫在前面&#xff0c;用一年時間來深度解讀《Effective Java》這本書 正文&#xff1a; 原文P15&am…

20.Linux進程信號(一)

信號: 產生->保存->處理一、預備知識信號vs信號量->沒有任何關系什么叫做信號&#xff1f;中斷我們正在做的事情&#xff0c;是一種事件的異步通知機制。同步和異步理解&#xff1a;同步指事件發生具有一定的順序性&#xff08;如命名管道中服務端讀方式打開會阻塞&am…

【C++】Vector核心實現:類設計到迭代器陷阱

vector 模擬實現代碼的核心下面從類設計、核心接口、內存安全、常見陷阱、測試場景5 個維度&#xff0c;提煉需重點掌握的知識點&#xff0c;覆蓋面試高頻考點與實踐易錯點&#xff1a;一、類結構與成員變量&#xff08;基礎框架&#xff09;vector 的核心是通過三個迭代器&…

并發編程指南 內存模型

文章目錄5.1 內存模型5.1.1 對象和內存位置5.1.2 對象、內存位置和并發5.1.3 修改順序5.1 內存模型 內存模型&#xff1a;一方面是內存布局&#xff0c;另一方面是并發。并發的基本結構很重要&#xff0c;特別是低層原子操作。因為C所有的對象都和內存位置有關&#xff0c;所以…

血緣元數據采集開放標準:OpenLineage Integrations Compatibility Tests Structure

OpenLineage 是一個用于元數據和血緣采集的開放標準&#xff0c;專為在作業運行時動態采集數據而設計。它通過統一的命名策略定義了由作業&#xff08;Job&#xff09;、運行實例&#xff08;Run&#xff09;和數據集&#xff08;Dataset&#xff09; 組成的通用模型&#xff0…

執行一條select語句期間發生了什么?

首先是連接器的工作&#xff0c;嗯&#xff0c;與客戶端進行TCP三次握手建立連接&#xff0c;校驗客戶端的用戶名和密碼&#xff0c;如果用戶名和密碼都對了&#xff0c;那么就會檢查該用戶的權限&#xff0c;之后執行的所有SQL語句都是基于該權限接著客戶端就可以向數據庫發送…