CSFramework.Workflow - 可视化工作流引擎 - 业务系统集成解决方案

using CSFramework.Workflow.Common;
using CSFramework.Workflow.Common.Enums;
using CSFramework.Workflow.Common.Events;
using CSFramework.Workflow.Common.Models;
using CSFramework.Workflow.Engine;
using CSFramework.Workflow.Engine.DataProvider;
using System;
using System.Collections.Generic;
using System.Data.Entity.Migrations;
using System.Linq;

namespace CSFramework.Workflow.Demo
{
    /// <summary>
    /// 《费用申请单》业务系统数据提供者
    /// </summary>
    public class BusinessProvider_Demo_FeeApply : BusinessDataProviderBase
    {
        public BusinessProvider_Demo_FeeApply() : base()
        {
            BusinessClientDataProvider.InitConnection(this);//设置数据库连接            
            BusinessClientDataProvider.InitPermission(this);//设置权限数据

            this.ApprovalForm = new frmApprovalFlow();//用户自定义流程审核窗体            
            this.ApprovalForm.OnApprovalFinish += ApprovalForm_OnApprovalFinish;
            this.ApprovalForm.OnApprovalOperation += ApprovalForm_OnApprovalOperation;
        }

        /// <summary>
        /// 节点审批事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void ApprovalForm_OnApprovalOperation(object sender, OnApprovalOperationEventArgs e)
        {
            if (e.Success && (e.ActionName == ApprovalAction.Approval || e.ActionName == ApprovalAction.CancelApproval))
            {
                if (e.Data is WorkflowApprovalData data)
                {
                    this.UpdateBusinessDocApproval(data, false);
                }
            }
        }

        /// <summary>
        /// 审批完成事件
        /// </summary>
        /// <param name="data"></param>
        private void ApprovalForm_OnApprovalFinish(WorkflowApprovalData data)
        {
            this.UpdateBusinessDocApproval(data, true);
        }

        /// <summary>
        /// 业务系统是否使用了流程图
        /// </summary>
        /// <param name="flowKey">流程图Id</param>
        /// <returns></returns>
        public override bool IsWorkflowReferenced(string flowKey)
        {
            return BusinessClientDataProvider.IsWorkflowReferenced(flowKey);
        }

        /// <summary>
        /// 获取实例数据（表单数据）
        /// </summary>
        /// <param name="businessKey">业务系统单据号码或主键值</param>
        /// <param name="flowKey">流程图Id</param>
        /// <param name="nodeKey">流程节点Id</param>
        /// <returns></returns>
        public override InstanceData GetInstanceData(string businessKey, string flowKey, string nodeKey = null)
        {
            InstanceData result = new InstanceData();

            //当前【费用申请单】的数据
            Dictionary<String, String> dict = new Dictionary<string, string>();
            dict["员工编码"] = "E2093981";
            dict["员工姓名"] = "张三";
            dict["期间"] = "2023/11";
            dict["差旅费"] = "3500";
            dict["电话费"] = "1300";
            dict["其他补贴"] = "1000";
            dict["总费用"] = "5800";

            //当前【费用申请单】的附件
            var files = new List<WorkflowNodeFiles>
            {
                new WorkflowNodeFiles { DataKey="001", FileName="费用申请.pdf", FileData=new byte[]{ }, FileType=".pdf"},
            };

            result.KeyValues = dict;
            result.AttachedFiles = files;

            return result;
        }

        /// <summary>
        /// 审批条件参数
        /// </summary>
        public override List<ConditionParam> ConditionParams
        {
            get
            {
                return new List<ConditionParam>
                {
                    new ConditionParam("FY","差旅费","差旅费",typeof(Decimal)),
                    new ConditionParam("FY","电话费","电话费",typeof(Decimal)),
                    new ConditionParam("FY","其他补贴","其他补贴",typeof(Decimal)),
                    new ConditionParam("FY","总费用","TotalAmount",typeof(Decimal)),
                };
            }
        }

        /// <summary>
        /// 执行节点指令
        /// </summary>
        /// <param name="businessKey">业务系统单据号码或主键值</param>
        /// <param name="flowNode">流程节点数据</param>
        /// <returns></returns>
        public override ExecuteCommandResult ExecuteCommand(string businessKey, WorkflowNodeData flowNode)
        {
            var result = new ExecuteCommandResult();
            try
            {
                //
                //编写代码：在这里执行节点指令
                //

                //demo1: 更新数据
                if (flowNode.FunctionImplement.ToLower() == "cmd01")
                {
                    //
                    //调用更新数据接口
                    //
                    result.ResultType = "调用更新数据接口";
                }

                result.CommandId = flowNode.FunctionImplement;
                result.TaskId = IdHelper.GetTimeId();
                result.Success = true;
                result.ResultMessage = $"执行指令成功，cmdId={flowNode.FunctionImplement}";

                return result;
            }
            catch (Exception ex)
            {
                result.Success = false;
                result.ResultMessage = ex.Message;
                return result;
            }
        }

        /// <summary>
        /// 更新当前单据的审批状态
        /// </summary>
        /// <param name="data"></param>
        /// <param name="isFinish"></param>
        /// <returns></returns>
        internal bool UpdateBusinessDocApproval(WorkflowApprovalData data, bool isFinish)
        {
            using (var db = DemoDataDbContext.Create())
            {
                var obj = db.Demo_FeeApplyModel.Where(w => w.FANO == data.BusinessKey).FirstOrDefault();
                if (obj != null)
                {
                    obj.FlagApp = isFinish ? "Y" : "N";
                    obj.AppUser = this.LoginUser.UserId;
                    obj.AppUserName = this.LoginUser.UserName;
                    obj.AppTime = DateTime.Now;
                    obj.AppComment = data.ApprovalComments;
                    obj.AppStatus = data.ApprovalStatus;
                    obj.AppWorkflowKey = data.FlowDataKey;//工作流key

                    db.Demo_FeeApplyModel.AddOrUpdate(obj);
                    return db.SaveChanges() == 1;
                }
                else
                {
                    return false;
                }
            }
        }

        /// <summary>
        /// 获取《费用申请单》单据列表
        /// </summary>
        /// <returns></returns>
        internal List<Demo_FeeApplyModel> GetDemoData()
        {
            using (var context = new DemoDataDbContext(BusinessClientDataProvider.ConnectionString))
            {
                return context.Demo_FeeApplyModel.ToList();
            }
        }

    }

}