StaffPerformance/wispro.sp.api/Controllers/WorkflowEngineController.cs

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using wispro.sp.entity;
using wispro.sp.entity.workflowInstance;
using wispro.sp.share;

namespace wispro.sp.api.Controllers
{
    [Route("api/[controller]/[action]")]
    [ApiController]
    public class WorkflowEngineController : ControllerBase
    {
        spDbContext Context;

        public WorkflowEngineController(spDbContext context)
        {
            Context = context;
        }

        public void DoAction(int instanceId,int stepId,int ActionId,List<InputValue> inputValues)
        {
            //1、取实例对象

            //2、取步骤对象

            //3、判断Action定义对象

            //4、判断输入值合法性

            //5、保存数据
        }

        [HttpPost]
        public ApiSaveResponse AddNew(NewWorkflowObject workflowObject)
        {
            ApiSaveResponse ret = new ApiSaveResponse();
            ret.Success = true;

            using(var t = Context.Database.BeginTransaction())
            {
                try
                {
                    if (workflowObject.InitAction != null)
                    {
                        Context.Actions.Add(workflowObject.InitAction);
                        Context.SaveChanges();
                    }
                    else
                    {
                        throw new ApplicationException("没有设定初始化Action！");
                    }

                    workflowObject.Workflow.InitActionId  = workflowObject.InitAction.Id;
                    workflowObject.Workflow.CreateTime = DateTime.Now;
                    workflowObject.Workflow.CreateUserId = Context.Staffs.FirstOrDefault<Staff>(s => s.Name == User.Identity.Name).Id;
                    Context.Workflows.Add(workflowObject.Workflow);

                    
                    Context.SaveChanges();

                    entity.workflowDefine.Step endStep = new entity.workflowDefine.Step() { 
                        Name = "结束", 
                        workflowId = workflowObject.Workflow.Id ,
                    };
                    Context.Steps.Add(endStep);
                    Context.SaveChanges();

                    workflowObject.Workflow.EndStepId = endStep.Id;
                    Context.SaveChanges();

                    t.Commit();
                }
                catch(Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public ApiSaveResponse DeleteWorkflow(int workflowId)
        {
            ApiSaveResponse ret = new ApiSaveResponse();
            ret.Success = true;

            using (var t = Context.Database.BeginTransaction())
            {
                try
                {
                    var wInstanes = Context.WorkflowInstances.Where<WorkflowInstance>(w => w.workflowId == workflowId);
                    if(wInstanes.Count() > 0)
                    {
                        ret.Success = false;
                        ret.ErrorMessage = "流程已经使用，删除会影响到已有流程实例数据!";
                        return ret;
                    }
                    else
                    {
                        var wf = Context.Workflows.FirstOrDefault(w=>w.Id == workflowId);
                        if (wf != null)
                        {
                            entity.workflowDefine.Action  initAction = new entity.workflowDefine.Action() { Id = wf.InitActionId};
                            var tfs = GetTrasfers(workflowId);
                            var Actions = GetActions(workflowId);
                            var Steps = GetSteps(workflowId);

                            foreach (var tf in tfs)
                            {
                                Context.TrasferConditions.Remove(tf);
                            }

                            Context.SaveChanges();

                            foreach (var action in Actions)
                            {
                                
                                var ivSettings1 = Context.InputValueSettings.Where<entity.workflowDefine.InputValueSetting>(
                                    s => s.actionId == action.Id).ToList();

                                foreach(var iv in ivSettings1)
                                {
                                    Context.InputValueSettings.Remove(iv);
                                }
                                if (action.Id != wf.InitActionId)
                                {

                                    Context.Actions.Remove(action);
                                }
                                else
                                {
                                    initAction = action;
                                }
                                
                            }
                            Context.SaveChanges();

                            foreach (var step in Steps)
                            {
                                Context.Steps.Remove(step);
                            }
                            Context.SaveChanges();

                            Context.Workflows.Remove(wf);
                            Context.Actions.Remove(initAction);

                            Context.SaveChanges();
                            t.Commit();
                        }
                    }
                }
                catch(Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public ApiSaveResponse SaveStep(NewStepObject stepObj)
        {
            var ret = new ApiSaveResponse();
            ret.Success = true;
            
            using (var t = Context.Database.BeginTransaction())
            {
                try
                {
                    var step = stepObj.Step;
                    var wf = GetWorkflow(step.workflowId);

                    if(wf == null)
                    {
                        throw new ApplicationException("步骤所属流程不存在！");
                    }

                    if (step.Id == 0)
                    {
                        Context.Steps.Add(step);
                        Context.SaveChanges();

                        if (stepObj.actions != null)
                        {
                            foreach (var ac in stepObj.actions)
                            {
                                var temAc = Context.Actions.FirstOrDefault(a => a.Id == ac.Id);

                                if (temAc == null)
                                {
                                    ac.StepId = step.Id;
                                    Context.Actions.Add(ac);
                                    Context.SaveChanges();
                                }
                                else
                                {
                                    temAc.Name = ac.Name;
                                    temAc.InputForm = ac.InputForm;
                                    temAc.OnActionObjectType = ac.OnActionObjectType;
                                    temAc.StepId = ac.StepId;
                                    Context.SaveChanges();
                                }

                                if (ac.inputValuesSettings != null)
                                {
                                    foreach (var iv in ac.inputValuesSettings)
                                    {
                                        var temIV = Context.InputValueSettings.FirstOrDefault(p => p.Id == iv.Id);
                                        if (temIV == null)
                                        {
                                            iv.actionId = temAc.Id;
                                            Context.InputValueSettings.Add(iv);
                                            Context.SaveChanges();
                                        }
                                        else
                                        {
                                            temIV.actionId = temAc.Id;
                                            temIV.bindField = iv.bindField;
                                            temIV.bindFieldSavetoObjectCondition = iv.bindFieldSavetoObjectCondition;
                                            temIV.DisplayName = iv.DisplayName;
                                            temIV.Options = iv.Options;
                                            temIV.ParentSettingId = iv.ParentSettingId;
                                            temIV.valueType = iv.valueType;
                                            Context.SaveChanges();
                                        }
                                    }
                                }
                            }
                        }
                        
                    }
                    else
                    {
                        var temStep = Context.Steps.FirstOrDefault(a => a.Id == step.Id);
                        if (temStep != null)
                        {
                            if(temStep.workflowId != step.workflowId)
                            {
                                throw new ApplicationException("修改步骤时，不能修改步骤所属流程！");
                            }

                            temStep.Name = step.Name;
                            temStep.stepType = step.stepType;
                            temStep.defaultResponseSetting = step.defaultResponseSetting;

                            foreach (var ac in stepObj.actions)
                            {
                                var temAc = Context.Actions.FirstOrDefault(a => a.Id == ac.Id);

                                if (temAc == null)
                                {
                                    ac.StepId = step.Id;
                                    Context.Actions.Add(ac);
                                    Context.SaveChanges();
                                }
                                else
                                {
                                    temAc.Name = ac.Name;
                                    temAc.InputForm = ac.InputForm;
                                    temAc.OnActionObjectType = ac.OnActionObjectType;
                                    temAc.StepId = ac.StepId;
                                    Context.SaveChanges();
                                }

                                if (ac.inputValuesSettings != null)
                                {
                                    foreach (var iv in ac.inputValuesSettings)
                                    {
                                        var temIV = Context.InputValueSettings.FirstOrDefault(p => p.Id == iv.Id);
                                        if (temIV == null)
                                        {
                                            iv.actionId = temAc.Id;
                                            Context.InputValueSettings.Add(iv);
                                            Context.SaveChanges();
                                        }
                                        else
                                        {
                                            temIV.actionId = temAc.Id;
                                            temIV.bindField = iv.bindField;
                                            temIV.bindFieldSavetoObjectCondition = iv.bindFieldSavetoObjectCondition;
                                            temIV.DisplayName = iv.DisplayName;
                                            temIV.Options = iv.Options;
                                            temIV.ParentSettingId = iv.ParentSettingId;
                                            temIV.valueType = iv.valueType;
                                            Context.SaveChanges();
                                        }
                                    }
                                }
                            }

                            
                        }
                        else
                        {
                            throw new ApplicationException("Id不存在！");
                        }
                    }

                    Context.SaveChanges();
                    t.Commit();
                }
                catch(Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }
        public ApiSaveResponse DeleteAction(int Id)
        {
            ApiSaveResponse ret = new ApiSaveResponse();
            ret.Success = true;

            using (var t = Context.Database.BeginTransaction())
            {
                try
                {
                    var action = Context.Actions.Where<entity.workflowDefine.Action>(w => w.Id == Id).FirstOrDefault();
                    if (action != null)
                    {
                        var ivSettings1 = Context.InputValueSettings.Where<entity.workflowDefine.InputValueSetting>(
                            s => s.actionId == action.Id).ToList();

                        foreach (var iv in ivSettings1)
                        {
                            Context.InputValueSettings.Remove(iv);
                        }

                        Context.Actions.Remove(action);

                        Context.SaveChanges();
                        t.Commit();
                    }
                }
                catch (Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public ApiSaveResponse DeleteTransfer(int Id)
        {
            ApiSaveResponse ret = new ApiSaveResponse();
            ret.Success = true;

            using (var t = Context.Database.BeginTransaction())
            {
                try
                {
                    Context.TrasferConditions.Remove(new entity.workflowDefine.TrasferCondition() { Id=Id });
                    Context.SaveChanges();
                    t.Commit();
                }
                catch (Exception ex) 
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public ApiSaveResponse DeleteStep(int Id)
        {
            ApiSaveResponse ret = new ApiSaveResponse();
            ret.Success = true;

            using (var t = Context.Database.BeginTransaction())
            {
                try
                {
                    var step = Context.Steps.FirstOrDefault(s=>s.Id == Id);

                    if(step != null)
                    {
                        var Transfers = Context.TrasferConditions.Where<entity.workflowDefine.TrasferCondition>(t => t.StepId == step.Id || t.nextStepId == step.Id).ToList();
                        if(Transfers != null)
                        {
                            foreach(var tf in Transfers)
                            {
                                Context.TrasferConditions.Remove(tf);
                            }

                            Context.SaveChanges();
                        }

                        var Actions = Context.Actions.Where<entity.workflowDefine.Action>(s => s.StepId == step.Id).ToList();

                        if(Actions != null)
                        {
                            foreach(var ac in Actions)
                            {
                                foreach(var iv in Context.InputValueSettings.Where(p=>p.actionId== ac.Id).ToList())
                                {
                                    Context.InputValueSettings.Remove(iv);
                                }
                                

                                Context.Actions.Remove(ac);
                            }

                            Context.SaveChanges();
                        }

                        Context.Steps.Remove(step);
                        Context.SaveChanges();
                    }





                    t.Commit();
                }
                catch (Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public ApiSaveResponse SaveAction(entity.workflowDefine.Action action)
        {
            var ret = new ApiSaveResponse();
            ret.Success = true;
            using (var t = Context.Database.BeginTransaction())
            {
                try
                {

                    if (action.Id == 0)
                    {
                        Context.Actions.Add(action);
                    }
                    else
                    {
                        var temAtion = Context.Actions.FirstOrDefault(a => a.Id == action.Id);
                        if (temAtion != null)
                        {
                            temAtion.InputForm = action.InputForm;
                            temAtion.Name = action.Name;
                            temAtion.StepId = action.StepId;
                            temAtion.inputValuesSettings = action.inputValuesSettings;
                            temAtion.OnActionObjectType = action.OnActionObjectType;
                        }
                        else
                        {
                            throw new ApplicationException("Id不存在！");
                        }

                    }
                    Context.SaveChanges();

                    t.Commit();
                }
                catch (Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public ApiSaveResponse SaveTransfer(entity.workflowDefine.TrasferCondition trasfer)
        {
            var ret = new ApiSaveResponse();
            ret.Success = true;

            using (var t = Context.Database.BeginTransaction())
            {
                try
                {
                    
                    

                    if (trasfer.Id == 0)
                    {
                        Context.TrasferConditions.Add(trasfer);
                    }
                    else
                    {
                        var temTransfer = Context.TrasferConditions.FirstOrDefault(a => a.Id == trasfer.Id);
                        if (temTransfer != null)
                        {
                            temTransfer.StepId  = trasfer.StepId;
                            temTransfer.nextStepId = trasfer.nextStepId;
                            temTransfer.Condition = trasfer.Condition;
                        }
                        else
                        {
                            throw new ApplicationException("Id不存在！");
                        }
                    }

                    Context.SaveChanges();
                    t.Commit();
                }
                catch (Exception ex)
                {
                    t.Rollback();
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                }
            }

            return ret;
        }

        public List<entity.workflowDefine.Workflow> GetAllWorkflows()
        {
            return Context.Workflows.Include(d => d.CreateUser).ToList();
        }

        public entity.workflowDefine.Workflow GetWorkflow(int workflowId)
        {
            return Context.Workflows.Include(d=>d.InitAction).Include(d=>d.CreateUser).FirstOrDefault<entity.workflowDefine.Workflow>(w => w.Id == workflowId);
        }

        public List<entity.workflowDefine.Step> GetSteps(int workflowId)
        {
            return Context.Steps.Where<entity.workflowDefine.Step>(w => w.workflowId  == workflowId).ToList();
        }

        public List<entity.workflowDefine.Action> GetActions(int workflowId)
        {
            var workflow = Context.Workflows.FirstOrDefault<entity.workflowDefine.Workflow>(w => w.Id == workflowId);
            return Context.Actions.Include(s=>s.step).Where<entity.workflowDefine.Action>(d => d.step.workflowId == workflowId || d.Id == workflow.InitActionId).ToList();
        }

        public List<entity.workflowDefine.TrasferCondition> GetTrasfers(int workflowId)
        {
            return Context.TrasferConditions.Where(d => d.Step.workflowId == workflowId || d.nextStep.workflowId == workflowId).ToList();
        }

        public List<entity.workflowDefine.InputValueSetting>  getInputValueSteein(int actionId)
        {
            var retList=  Context.InputValueSettings.Where<entity.workflowDefine.InputValueSetting>(p => p.actionId == actionId).ToList();
            return retList;
        }

    }
}