PM> Install-Package WorkflowCore

    public class HelloWorldWorkflow : IWorkflow{public string Id => "HelloWorld";public int Version => 1;public void Build(IWorkflowBuilder<object> builder){builder.StartWith<HelloWorld>().Then<ActiveWorld>().Then<GoodbyeWorld>();}}

    public class HelloWorld : StepBody{public override ExecutionResult Run(IStepExecutionContext context){Console.WriteLine("Hello World!");return ExecutionResult.Next();}}public class ActiveWorld : StepBody{public override ExecutionResult Run(IStepExecutionContext context){Console.WriteLine("I am activing in the World!");return ExecutionResult.Next();}}public class GoodbyeWorld : StepBody{public override ExecutionResult Run(IStepExecutionContext context){Console.WriteLine("Goodbye World!");return ExecutionResult.Next();}}

    private static IServiceProvider ConfigureServices(){IServiceCollection services = new ServiceCollection();services.AddLogging(); // WorkflowCore需要用到logging service
        services.AddWorkflow();var serviceProvider = services.BuildServiceProvider();
return serviceProvider;}

        public static void Main(string[] args){var serviceProvider = ConfigureServices();var host = serviceProvider.GetService<IWorkflowHost>();host.RegisterWorkflow<HelloWorldWorkflow>();host.Start();// Demo1:Hello Worldhost.StartWorkflow("HelloWorld");Console.ReadKey();host.Stop();}    

    public class IfStatementWorkflow : IWorkflow<MyData>{public string Id => "if-sample";public int Version => 1;public void Build(IWorkflowBuilder<MyData> builder){builder.StartWith<SayHello>().If(data => data.Counter < 3).Do(then => then.StartWith<PrintMessage>().Input(step => step.Message, data => "Outcome is less than 3")).If(data => data.Counter < 5).Do(then => then.StartWith<PrintMessage>().Input(step => step.Message, data => "Outcome is less than 5")).Then<SayGoodbye>();}}

    public class MyData{public int Counter { get; set; }}

PM> Install-Package WorkflowCore.Persistence.MySQL

services.AddWorkflow(x => x.UseMySQL(@"Server=127.0.0.1;Database=workflow;User=root;Password=password;", true, true));

builder.StartWith(context => Console.WriteLine("Hello")).Schedule(data => TimeSpan.FromSeconds(5)).Do(schedule => schedule.StartWith(context => Console.WriteLine("Doing scheduled tasks"))).Then(context => Console.WriteLine("Doing normal tasks"));

builder.StartWith(context => Console.WriteLine("Hello")).Recur(data => TimeSpan.FromSeconds(5), data => data.Counter > 5).Do(recur => recur.StartWith(context => Console.WriteLine("Doing recurring task"))).Then(context => Console.WriteLine("Carry on"));

    　　builder.StartWith<CreateCustomer>().Then<PushToSalesforce>().OnError(WorkflowErrorHandling.Retry, TimeSpan.FromMinutes(10)).Then<PushToERP>().OnError(WorkflowErrorHandling.Retry, TimeSpan.FromMinutes(10));

builder.StartWith<LogStart>().Saga(saga => saga.StartWith<Task1>().CompensateWith<UndoTask1>().Then<Task2>().CompensateWith<UndoTask2>().Then<Task3>().CompensateWith<UndoTask3>()).OnError(Models.WorkflowErrorHandling.Retry, TimeSpan.FromMinutes(10)).Then<LogEnd>();

        public void ConfigureServices(IServiceCollection services){services.AddWorkflow();services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);}

    public void Configure(IApplicationBuilder app, IHostingEnvironment env){.......      app.UseWorkflow();}

    public static class ConfigureExtensions{public static IApplicationBuilder UseWorkflow(this IApplicationBuilder app){var host = app.ApplicationServices.GetService<IWorkflowHost>();host.RegisterWorkflow<EdcWorkflow>();host.RegisterWorkflow<EdcDataWorkflow, EdcData>();host.Start();var appLifetime = app.ApplicationServices.GetService<IApplicationLifetime>();appLifetime.ApplicationStopping.Register(() =>{host.Stop();});return app;}}

    [Route("api/[controller]")][ApiController]public class ValuesController : ControllerBase{private IWorkflowController _workflowService;public ValuesController(IWorkflowController workflowService){_workflowService = workflowService;}// GET api/values
        [HttpGet]public async Task<IEnumerable<string>> Get(){await _workflowService.StartWorkflow("EdcWorkflow");return new string[] { "EdcWorkflow v1" };}// GET api/values/5[HttpGet("{id}")]public async Task<string> Get(int id){await _workflowService.StartWorkflow("EdcDataWorkflow", new EdcData() { Id = id });return "EdcDataWorkflow v1";}}

    public class EdcWorkflow : IWorkflow{public string Id => "EdcWorkflow";public int Version => 1;public void Build(IWorkflowBuilder<object> builder){builder.StartWith<HelloWorld>().Then<GoodbyeWorld>();}}public class EdcDataWorkflow : IWorkflow<EdcData>{public string Id => "EdcDataWorkflow";public int Version => 1;public void Build(IWorkflowBuilder<EdcData> builder){builder.StartWith<HelloWorld>().If(data => data.Id < 3).Do(then => then.StartWith<PrintMessage>().Input(step => step.Message, data => "Passed Id is less than 3")).If(data => data.Id < 5).Do(then => then.StartWith<PrintMessage>().Input(step => step.Message, data => "Passed Id is less than 5")).Then<GoodbyeWorld>();}}

作者：周旭龙

出处：https://edisonchou.cnblogs.com

本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文链接。