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语句都是基于该权限接着客户端就可以向数据库发送…