mirror of
https://gitee.com/dotnetchina/OpenAuth.Net.git
synced 2025-04-05 17:38:01 +08:00
826 lines
34 KiB
C#
826 lines
34 KiB
C#
/*
|
||
* @Author: yubaolee <yubaolee@163.com> | ahfu~ <954478625@qq.com>
|
||
* @Date: 2024-12-13 16:55:17
|
||
* @Description: 工作流实例表操作
|
||
* @LastEditTime: 2025-02-25 22:42:53
|
||
* Copyright (c) 2024 by yubaolee | ahfu~ , All Rights Reserved.
|
||
*/
|
||
|
||
using Infrastructure;
|
||
using OpenAuth.App.Flow;
|
||
using OpenAuth.App.Interface;
|
||
using OpenAuth.App.Request;
|
||
using OpenAuth.App.Response;
|
||
using OpenAuth.Repository.Domain;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Net.Http;
|
||
using System.Threading.Tasks;
|
||
using Castle.Core.Internal;
|
||
using Infrastructure.Const;
|
||
using Infrastructure.Extensions;
|
||
using Infrastructure.Helpers;
|
||
using Newtonsoft.Json.Linq;
|
||
using SqlSugar;
|
||
using Yitter.IdGenerator;
|
||
|
||
namespace OpenAuth.App
|
||
{
|
||
/// <summary>
|
||
/// 工作流实例表操作
|
||
/// </summary>
|
||
public class FlowInstanceApp : SqlSugarBaseApp<FlowInstance>
|
||
{
|
||
private RevelanceManagerApp _revelanceApp;
|
||
private FlowSchemeApp _flowSchemeApp;
|
||
private FormApp _formApp;
|
||
private IHttpClientFactory _httpClientFactory;
|
||
private IServiceProvider _serviceProvider;
|
||
private SysMessageApp _messageApp;
|
||
private DbExtension _dbExtension;
|
||
private UserManagerApp _userManagerApp;
|
||
private FlowApproverApp _flowApproverApp;
|
||
private RevelanceManagerApp _revelanceManagerApp;
|
||
|
||
#region 流程处理API
|
||
|
||
/// <summary>
|
||
/// 创建一个实例
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public bool CreateInstance(AddFlowInstanceReq addFlowInstanceReq)
|
||
{
|
||
CheckNodeDesignate(addFlowInstanceReq);
|
||
FlowScheme scheme = null;
|
||
if (!string.IsNullOrEmpty(addFlowInstanceReq.SchemeId))
|
||
{
|
||
scheme = _flowSchemeApp.Get(addFlowInstanceReq.SchemeId);
|
||
}
|
||
|
||
if ((scheme == null) && !string.IsNullOrEmpty(addFlowInstanceReq.SchemeCode))
|
||
{
|
||
scheme = _flowSchemeApp.FindByCode(addFlowInstanceReq.SchemeCode);
|
||
}
|
||
|
||
if (scheme == null)
|
||
{
|
||
throw new Exception("该流程模板已不存在，请重新设计流程");
|
||
}
|
||
|
||
addFlowInstanceReq.SchemeContent = scheme.SchemeContent;
|
||
|
||
var form = _formApp.FindSingle(scheme.FrmId);
|
||
if (form == null)
|
||
{
|
||
throw new Exception("该流程模板对应的表单已不存在，请重新设计流程");
|
||
}
|
||
|
||
addFlowInstanceReq.FrmContentData = form.ContentData;
|
||
addFlowInstanceReq.FrmContentParse = form.ContentParse;
|
||
addFlowInstanceReq.FrmType = form.FrmType;
|
||
addFlowInstanceReq.FrmId = form.Id;
|
||
|
||
var flowInstance = addFlowInstanceReq.MapTo<FlowInstance>();
|
||
|
||
//创建运行实例
|
||
var wfruntime = new FlowRuntime(flowInstance);
|
||
var user = _auth.GetCurrentUser();
|
||
|
||
#region 根据运行实例改变当前节点状态
|
||
|
||
flowInstance.ActivityId = wfruntime.nextNodeId;
|
||
flowInstance.ActivityType = wfruntime.GetNextNodeType();
|
||
flowInstance.ActivityName = wfruntime.nextNode.name;
|
||
flowInstance.PreviousId = wfruntime.currentNodeId;
|
||
flowInstance.CreateUserId = user.User.Id;
|
||
addFlowInstanceReq.CreateUserId = user.User.Id;
|
||
flowInstance.CreateUserName = user.User.Account;
|
||
addFlowInstanceReq.CreateUserName = user.User.Account;
|
||
|
||
flowInstance.MakerList =
|
||
wfruntime.GetNextNodeType() != 4 ? wfruntime.GetNextMakers(addFlowInstanceReq) : "";
|
||
flowInstance.IsFinish = wfruntime.GetNextNodeType() == 4
|
||
? FlowInstanceStatus.Finished
|
||
: FlowInstanceStatus.Running;
|
||
|
||
|
||
SugarClient.Ado.BeginTran();
|
||
SugarClient.Insertable(flowInstance).ExecuteCommand();
|
||
|
||
//知会
|
||
if (!addFlowInstanceReq.NoticeType.IsNullOrEmpty() && addFlowInstanceReq.NoticeIds != null)
|
||
{
|
||
_revelanceApp.Assign(new AssignReq
|
||
{
|
||
type = addFlowInstanceReq.NoticeType,
|
||
firstId = flowInstance.Id,
|
||
secIds = addFlowInstanceReq.NoticeIds.ToArray()
|
||
});
|
||
}
|
||
|
||
if (flowInstance.FrmType == 1) //如果是开发者自定义的表单
|
||
{
|
||
var t = Type.GetType("OpenAuth.App." + flowInstance.DbName + "App");
|
||
ICustomerForm icf = (ICustomerForm)_serviceProvider.GetService(t);
|
||
try
|
||
{
|
||
icf.Add(flowInstance.Id, flowInstance.FrmData);
|
||
}
|
||
catch (Exception)
|
||
{
|
||
throw new Exception("流程表单数据解析失败,请检查表单是否填写完整");
|
||
}
|
||
}
|
||
|
||
//如果工作流配置的表单配置有对应的数据库
|
||
if (!string.IsNullOrEmpty(form.DbName))
|
||
{
|
||
var dbcolumns = _dbExtension.GetDbTableStructure(form.DbName);
|
||
var json = JsonHelper.Instance.Deserialize<JObject>(addFlowInstanceReq.FrmData);
|
||
var columnstr = string.Empty; //字段
|
||
var valstr = string.Empty; //值字符串
|
||
|
||
|
||
foreach (var column in dbcolumns)
|
||
{
|
||
if (column.ColumnName == "Id" || column.ColumnName == "id")
|
||
{
|
||
var options = new IdGeneratorOptions()
|
||
{
|
||
Method = 1,
|
||
WorkerId = 1
|
||
};
|
||
|
||
YitIdHelper.SetIdGenerator(options);
|
||
columnstr += "Id,";
|
||
valstr += "'" + YitIdHelper.NextId().ToString() + "',";
|
||
continue;
|
||
}
|
||
|
||
//讲流程实例ID赋值到表单数据表中，实现表单记录与流程实例关联
|
||
if (column.ColumnName == Define.DEFAULT_FORM_INSTANCE_ID_NAME)
|
||
{
|
||
columnstr += $"{Define.DEFAULT_FORM_INSTANCE_ID_NAME},";
|
||
valstr += "'" + flowInstance.Id + "',";
|
||
continue;
|
||
}
|
||
|
||
var val = json[column.ColumnName];
|
||
if (val == null)
|
||
{
|
||
switch (column.EntityType)
|
||
{
|
||
case "int":
|
||
val = 0;
|
||
break;
|
||
case "string":
|
||
val = "";
|
||
break;
|
||
case "DateTime":
|
||
val = DateTime.Now.ToString("yyyy-MM-dd");
|
||
break;
|
||
}
|
||
}
|
||
|
||
if (val == null) continue;
|
||
columnstr += column.ColumnName + ",";
|
||
valstr += "'" + val + "',";
|
||
}
|
||
|
||
columnstr = columnstr.TrimEnd(',');
|
||
valstr = valstr.TrimEnd(',');
|
||
var sql = $"insert into {form.DbName}({columnstr}) values ({valstr})";
|
||
SugarClient.Ado.ExecuteCommand(sql);
|
||
}
|
||
|
||
#endregion 根据运行实例改变当前节点状态
|
||
|
||
wfruntime.SaveOperationHis($"【创建】{user.User.Name}创建了流程实例【{addFlowInstanceReq.CustomName}】");
|
||
|
||
wfruntime.SaveTransitionHis();
|
||
SugarClient.Ado.CommitTran();
|
||
return true;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新流程
|
||
/// <para>更新时可以修改表单内容，可以修改流程基本信息，但不能更换表单模版</para>
|
||
/// </summary>
|
||
/// <param name="req"></param>
|
||
public void Update(UpdateFlowInstanceReq req)
|
||
{
|
||
var flowinstance = Get(req.Id);
|
||
|
||
if (flowinstance.IsFinish != FlowInstanceStatus.Draft &&
|
||
flowinstance.IsFinish != FlowInstanceStatus.Rejected)
|
||
{
|
||
throw new Exception("只能修改【草稿】和【驳回】状态的流程");
|
||
}
|
||
|
||
var form = _formApp.Get(flowinstance.FrmId);
|
||
|
||
if (form != null)
|
||
{
|
||
if (form.FrmType == 1) //如果是开发者自定义的表单,更新对应数据库表数据
|
||
{
|
||
var t = Type.GetType("OpenAuth.App." + req.DbName + "App");
|
||
ICustomerForm icf = (ICustomerForm)_serviceProvider.GetService(t);
|
||
icf.Update(req.Id, req.FrmData);
|
||
}
|
||
else if (form.FrmType == 2 && !string.IsNullOrEmpty(form.DbName)) //拖拽表单定义了关联数据库
|
||
{
|
||
var dbcolumns = _dbExtension.GetDbTableStructure(form.DbName);
|
||
var json = JsonHelper.Instance.Deserialize<JObject>(req.FrmData);
|
||
var updatestr = string.Empty; //字段
|
||
|
||
foreach (var column in dbcolumns)
|
||
{
|
||
if (column.ColumnName == "Id" || column.ColumnName == "id")
|
||
{
|
||
continue;
|
||
}
|
||
|
||
//流程实例ID不能修改
|
||
if (column.ColumnName == Define.DEFAULT_FORM_INSTANCE_ID_NAME)
|
||
{
|
||
continue;
|
||
}
|
||
|
||
var val = json[column.ColumnName];
|
||
if (val == null)
|
||
{
|
||
continue;
|
||
}
|
||
|
||
updatestr += $"{column.ColumnName} = '{val}',";
|
||
}
|
||
|
||
updatestr = updatestr.TrimEnd(',');
|
||
if (!string.IsNullOrEmpty(updatestr))
|
||
{
|
||
var sql =
|
||
$"update {form.DbName} set {updatestr} where {Define.DEFAULT_FORM_INSTANCE_ID_NAME}='{req.Id}'";
|
||
SugarClient.Ado.ExecuteCommand(sql);
|
||
}
|
||
}
|
||
}
|
||
|
||
flowinstance.Description = req.Description;
|
||
flowinstance.Code = req.Code;
|
||
flowinstance.FrmData = req.FrmData;
|
||
flowinstance.DbName = req.DbName;
|
||
flowinstance.CustomName = req.CustomName;
|
||
SugarClient.Updateable(flowinstance).ExecuteCommand();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 节点审核
|
||
/// </summary>
|
||
/// <param name="instanceId"></param>
|
||
/// <returns></returns>
|
||
public bool NodeVerification(VerificationReq request)
|
||
{
|
||
var user = _auth.GetCurrentUser().User;
|
||
var instanceId = request.FlowInstanceId;
|
||
|
||
var tag = new Tag
|
||
{
|
||
UserName = user.Name,
|
||
UserId = user.Id,
|
||
Description = request.VerificationOpinion,
|
||
Taged = Int32.Parse(request.VerificationFinally)
|
||
};
|
||
|
||
FlowInstance flowInstance = Get(instanceId);
|
||
var approvers = _flowApproverApp.GetApproverIds(new QueryApproverReq
|
||
{
|
||
FlowInstanceId = instanceId,
|
||
ActivityId = flowInstance.ActivityId
|
||
});
|
||
|
||
if (flowInstance.MakerList != "1" && !flowInstance.MakerList.Contains(user.Id) &&
|
||
!approvers.Contains(user.Id))
|
||
{
|
||
throw new Exception("当前用户没有审批该节点权限");
|
||
}
|
||
|
||
FlowRuntime wfruntime = new FlowRuntime(flowInstance);
|
||
|
||
if (flowInstance.ActivityType == 0) //当前节点是会签节点
|
||
{
|
||
CounterSign(wfruntime, tag, flowInstance);
|
||
}
|
||
else
|
||
{
|
||
VerifyNode(request, tag, flowInstance);
|
||
}
|
||
|
||
//自定义开发表单，需要更新对应的数据库
|
||
if (!string.IsNullOrEmpty(request.FrmData) && flowInstance.FrmType == 1)
|
||
{
|
||
var t = Type.GetType("OpenAuth.App." + flowInstance.DbName + "App");
|
||
ICustomerForm icf = (ICustomerForm)_serviceProvider.GetService(t);
|
||
icf.Update(flowInstance.Id, flowInstance.FrmData);
|
||
}
|
||
|
||
//给流程创建人发送通知信息
|
||
_messageApp.SendMsgTo(flowInstance.CreateUserId,
|
||
$"你的流程[{flowInstance.CustomName}]已被{user.Name}处理。");
|
||
|
||
wfruntime.NotifyThirdParty(_httpClientFactory.CreateClient(), wfruntime.currentNode, tag);
|
||
return true;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 会签
|
||
/// </summary>
|
||
private void CounterSign(FlowRuntime wfruntime, Tag tag, FlowInstance flowInstance)
|
||
{
|
||
string res = wfruntime.NodeConfluence(_httpClientFactory.CreateClient(), tag);
|
||
|
||
if (res == TagState.No.ToString("D"))
|
||
{
|
||
flowInstance.IsFinish = FlowInstanceStatus.Disagree;
|
||
}
|
||
else if (!string.IsNullOrEmpty(res)) //会签结束，当前活动节点变为会签结束节点的下一个节点
|
||
{
|
||
flowInstance.PreviousId = flowInstance.ActivityId;
|
||
flowInstance.ActivityId = wfruntime.nextNodeId;
|
||
flowInstance.ActivityType = wfruntime.nextNodeType;
|
||
flowInstance.ActivityName = wfruntime.nextNode.name;
|
||
flowInstance.IsFinish = wfruntime.nextNodeType == 4
|
||
? FlowInstanceStatus.Finished
|
||
: FlowInstanceStatus.Running;
|
||
flowInstance.MakerList =
|
||
wfruntime.nextNodeType == 4 ? "" : wfruntime.GetNextMakers();
|
||
|
||
wfruntime.SaveTransitionHis();
|
||
}
|
||
else
|
||
{
|
||
//会签过程中，需要更新用户
|
||
flowInstance.MakerList = wfruntime.GetForkNodeMakers(wfruntime.currentNodeId);
|
||
wfruntime.SaveTransitionHis();
|
||
}
|
||
|
||
flowInstance.SchemeContent = JsonHelper.Instance.Serialize(wfruntime.ToSchemeObj());
|
||
|
||
SugarClient.Updateable(flowInstance).ExecuteCommand();
|
||
SugarClient.Ado.CommitTran();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 普通的节点审批
|
||
/// </summary>
|
||
private void VerifyNode(VerificationReq request, Tag tag, FlowInstance flowInstance)
|
||
{
|
||
var user = _auth.GetCurrentUser().User;
|
||
|
||
if (!string.IsNullOrEmpty(request.FrmData))
|
||
{
|
||
flowInstance.FrmData = request.FrmData;
|
||
}
|
||
|
||
FlowRuntime wfruntime = new FlowRuntime(flowInstance);
|
||
wfruntime.MakeTagNode(wfruntime.currentNodeId, tag);
|
||
if (tag.Taged == (int)TagState.Ok)
|
||
{
|
||
bool canNext = true;
|
||
var approvers = _flowApproverApp.GetApprovers(new QueryApproverReq
|
||
{
|
||
FlowInstanceId = flowInstance.Id,
|
||
ActivityId = flowInstance.ActivityId
|
||
});
|
||
|
||
var approverInfo = approvers?.Find(u => u.ApproverId == user.Id);
|
||
if (approverInfo != null)
|
||
{
|
||
//如果是加签，则调整加签状态
|
||
bool isfinish = _flowApproverApp.Verify(new VerifyApproverReq()
|
||
{
|
||
Id = approverInfo.Id,
|
||
Status = (int)TagState.Ok,
|
||
VerifyComment = tag.Description
|
||
});
|
||
if (!isfinish) //如果没有完成，不能到下一步
|
||
{
|
||
canNext = false;
|
||
}
|
||
else if (approverInfo.ReturnToSignNode == null || !approverInfo.ReturnToSignNode.Value)
|
||
{
|
||
//加签完成后，不需要返回原节点,则直接审批加签的节点
|
||
tag.UserId = approverInfo.CreateUserId;
|
||
tag.UserName = approverInfo.CreateUserName;
|
||
//把当前审批人变成加签人，从而可以自动审批
|
||
wfruntime.MakeTagNode(wfruntime.currentNodeId, tag);
|
||
}
|
||
else
|
||
{
|
||
canNext = false; //加签完成了，但还需要回到该节点审批
|
||
}
|
||
}
|
||
|
||
if (wfruntime.currentNode.setInfo.NodeDesignate == Setinfo.RUNTIME_MANY_PARENTS)
|
||
{
|
||
List<string> roles;
|
||
if (user.Id != tag.UserId)
|
||
{
|
||
//最后一个执行加签的用户，tag.UserId就是加签人id，需要找他的角色
|
||
roles = _revelanceManagerApp.Get(Define.USERROLE, true, tag.UserId);
|
||
}
|
||
else
|
||
{
|
||
roles = _auth.GetCurrentUser().Roles.Select(u => u.Id).ToList();
|
||
}
|
||
|
||
//如果是连续多级直属上级且还没到指定的角色，只改变执行人，不到下一个节点
|
||
if (!wfruntime.currentNode.setInfo.NodeDesignateData.roles.Intersect(roles).Any())
|
||
{
|
||
canNext = false;
|
||
var parentId = _userManagerApp.GetParent(tag.UserId);
|
||
flowInstance.MakerList = parentId;
|
||
}
|
||
}
|
||
|
||
if (canNext)
|
||
{
|
||
flowInstance.PreviousId = flowInstance.ActivityId;
|
||
flowInstance.ActivityId = wfruntime.nextNodeId;
|
||
flowInstance.ActivityType = wfruntime.nextNodeType;
|
||
flowInstance.ActivityName = wfruntime.nextNode.name;
|
||
flowInstance.MakerList = wfruntime.nextNodeType == 4 ? "" : wfruntime.GetNextMakers(request);
|
||
flowInstance.IsFinish = wfruntime.nextNodeType == 4
|
||
? FlowInstanceStatus.Finished
|
||
: FlowInstanceStatus.Running;
|
||
}
|
||
}
|
||
else //审批结果为不同意
|
||
{
|
||
flowInstance.IsFinish = FlowInstanceStatus.Disagree;
|
||
wfruntime.nextNodeId = "-1";
|
||
wfruntime.nextNodeType = 4;
|
||
}
|
||
|
||
var content =
|
||
$"{user.Account}-{DateTime.Now.ToString("yyyy-MM-dd HH:mm")}审批了【{wfruntime.currentNode.name}】" +
|
||
$"结果：{(tag.Taged == 1 ? "同意" : "不同意")}，备注：{tag.Description}";
|
||
wfruntime.SaveOperationHis(tag.UserId, tag.UserName, content);
|
||
|
||
if (flowInstance.IsFinish == 1)
|
||
{
|
||
//给知会人员发送通知信息
|
||
var userids = _userManagerApp.GetNoticeUsers(flowInstance.Id);
|
||
if (userids.Count > 0)
|
||
{
|
||
foreach (var userid in userids)
|
||
{
|
||
_messageApp.SendMsgTo(userid,
|
||
$"[{flowInstance.CustomName}]已完成，您可以在我的流程中查看。");
|
||
}
|
||
}
|
||
}
|
||
|
||
flowInstance.SchemeContent = JsonHelper.Instance.Serialize(wfruntime.ToSchemeObj());
|
||
|
||
SugarClient.Updateable(flowInstance).ExecuteCommand();
|
||
SugarClient.Ado.CommitTran();
|
||
|
||
//如果审批通过，且下一个审批人是自己，则自动审批
|
||
if (tag.Taged == (int)TagState.Ok)
|
||
{
|
||
if (flowInstance.MakerList != "1" && (!flowInstance.MakerList.Contains(user.Id)))
|
||
{
|
||
return;
|
||
}
|
||
|
||
NodeVerification(request);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 驳回
|
||
/// 如果NodeRejectStep不为空，优先使用；否则按照NodeRejectType驳回
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public bool RejectNode(VerificationReq reqest)
|
||
{
|
||
var user = _auth.GetCurrentUser().User;
|
||
FlowInstance flowInstance = Get(reqest.FlowInstanceId);
|
||
|
||
var approvers = _flowApproverApp.GetApproverIds(new QueryApproverReq
|
||
{
|
||
FlowInstanceId = reqest.FlowInstanceId,
|
||
ActivityId = flowInstance.ActivityId
|
||
});
|
||
|
||
if (flowInstance.MakerList != "1" && !flowInstance.MakerList.Contains(user.Id) &&
|
||
!approvers.Contains(user.Id))
|
||
{
|
||
throw new Exception("当前用户没有驳回该节点权限");
|
||
}
|
||
|
||
FlowRuntime wfruntime = new FlowRuntime(flowInstance);
|
||
wfruntime.RejectNode(_httpClientFactory.CreateClient(), reqest);
|
||
|
||
//给流程创建人发送通知信息
|
||
_messageApp.SendMsgTo(flowInstance.CreateUserId,
|
||
$"你的流程[{flowInstance.CustomName}]已被{user.Name}驳回。备注信息:{reqest.VerificationOpinion}");
|
||
|
||
SugarClient.Ado.CommitTran();
|
||
|
||
return true;
|
||
}
|
||
|
||
#endregion 流程处理API
|
||
|
||
/// <summary>
|
||
/// 审核流程
|
||
/// </summary>
|
||
public void Verification(VerificationReq request)
|
||
{
|
||
//如果是同意，需要判断是否为运行时选定下一步执行角色/执行人
|
||
if (request.VerificationFinally == "1")
|
||
{
|
||
CheckNodeDesignate(request);
|
||
}
|
||
|
||
bool isReject = TagState.Reject.Equals((TagState)Int32.Parse(request.VerificationFinally));
|
||
if (isReject) //驳回
|
||
{
|
||
RejectNode(request);
|
||
}
|
||
else
|
||
{
|
||
NodeVerification(request);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 判定节点需要选择执行人或执行角色
|
||
/// </summary>
|
||
/// <param name="request"></param>
|
||
/// <exception cref="Exception"></exception>
|
||
private void CheckNodeDesignate(NodeDesignateReq request)
|
||
{
|
||
if ((request.NodeDesignateType == Setinfo.RUNTIME_SPECIAL_ROLE
|
||
|| request.NodeDesignateType == Setinfo.RUNTIME_SPECIAL_USER) && request.NodeDesignates.Length == 0)
|
||
{
|
||
throw new Exception("下个节点需要选择执行人或执行角色");
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 返回用于处理流程节点
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
public FlowVerificationResp GetForVerification(string id)
|
||
{
|
||
var flowinstance = Get(id);
|
||
var resp = flowinstance.MapTo<FlowVerificationResp>();
|
||
var runtime = new FlowRuntime(flowinstance);
|
||
if (runtime.currentNode != null && runtime.currentNode.setInfo != null)
|
||
{
|
||
resp.CanWriteFormItemIds = runtime.currentNode.setInfo.CanWriteFormItemIds;
|
||
}
|
||
|
||
if (runtime.nextNode != null && runtime.nextNode.setInfo != null && runtime.nextNodeType != 4)
|
||
{
|
||
resp.NextNodeDesignateType = runtime.nextNode.setInfo.NodeDesignate;
|
||
resp.CanWriteFormItemIds = runtime.currentNode.setInfo.CanWriteFormItemIds;
|
||
}
|
||
|
||
return resp;
|
||
}
|
||
|
||
public async Task<TableData> Load(QueryFlowInstanceListReq request)
|
||
{
|
||
var result = new TableData();
|
||
var user = _auth.GetCurrentUser();
|
||
//行转列专用SQL
|
||
string groupConcatSql = $@" ( SELECT GROUP_CONCAT(Account SEPARATOR ',')
|
||
FROM `SysUser`
|
||
WHERE fi.MakerList like concat('%', Id, '%') ) ";
|
||
//sqlserver的行转列需要特殊处理
|
||
if(SugarClient.CurrentConnectionConfig.DbType == DbType.SqlServer)
|
||
{
|
||
groupConcatSql = $@" STUFF((
|
||
SELECT ',' + Account
|
||
FROM [SysUser]
|
||
WHERE fi.MakerList LIKE '%' + Id + '%'
|
||
FOR XML PATH(''), TYPE).value('.', 'NVARCHAR(MAX)'), 1, 1, '') ";
|
||
}
|
||
else if (SugarClient.CurrentConnectionConfig.DbType == DbType.Oracle)
|
||
{
|
||
groupConcatSql = $@" (select listagg(Account, ',') within group (order by Account)
|
||
from SysUser
|
||
where fi.MakerList like '%' || Id || '%') ";
|
||
}
|
||
|
||
string sql = String.Empty;
|
||
|
||
if (request.type == "wait") //待办事项（即需要我处理的流程）
|
||
{
|
||
sql = $@"
|
||
SELECT fi.Id,
|
||
fi.CreateUserName,
|
||
fi.ActivityName,
|
||
fi.CreateDate,
|
||
fi.CustomName,
|
||
fi.Code,
|
||
fi.Description,
|
||
fi.IsFinish,
|
||
CASE
|
||
WHEN fi.MakerList = '1' THEN '所有人'
|
||
WHEN fi.MakerList = '00000000-0000-0000-0000-000000000000' THEN 'System'
|
||
ELSE {groupConcatSql}
|
||
END AS MakerList
|
||
FROM FlowInstance fi
|
||
JOIN (SELECT fith.Id
|
||
FROM FlowInstance fith
|
||
WHERE (MakerList = '1' or MakerList LIKE '%{user.User.Id}%')
|
||
and (fith.IsFinish = {FlowInstanceStatus.Running} or fith.IsFinish = {FlowInstanceStatus.Rejected})
|
||
and not exists (select 1
|
||
from flowapprover
|
||
where fith.Id = InstanceId
|
||
and fith.ActivityId = ActivityId
|
||
and Status = 0)
|
||
UNION
|
||
SELECT fa.InstanceId
|
||
FROM FlowApprover fa
|
||
WHERE fa.Status = 0
|
||
AND fa.ApproverId = '{user.User.Id}') UniqueInstanceIds
|
||
ON fi.Id = UniqueInstanceIds.Id";
|
||
}
|
||
else if (request.type == "disposed") //已办事项（即我参与过的流程）
|
||
{
|
||
sql = $@"
|
||
SELECT fi.Id,
|
||
fi.CreateUserName,
|
||
fi.ActivityName,
|
||
fi.CreateDate,
|
||
fi.CustomName,
|
||
fi.Code,
|
||
fi.Description,
|
||
fi.IsFinish,
|
||
CASE
|
||
WHEN fi.MakerList = '1' THEN '所有人'
|
||
WHEN fi.MakerList = '00000000-0000-0000-0000-000000000000' THEN 'System'
|
||
ELSE {groupConcatSql}
|
||
END AS MakerList
|
||
FROM FlowInstance fi
|
||
JOIN (SELECT fith.InstanceId
|
||
FROM FlowInstanceOperationHistory fith
|
||
WHERE fith.CreateUserId = '{user.User.Id}'
|
||
UNION
|
||
SELECT fa.InstanceId
|
||
FROM FlowApprover fa
|
||
WHERE fa.Status <> 0
|
||
AND fa.ApproverId = '{user.User.Id}') UniqueInstanceIds
|
||
ON fi.Id = UniqueInstanceIds.InstanceId
|
||
";
|
||
}
|
||
else //我的流程（我创建的及知会我的）
|
||
{
|
||
sql = $@"
|
||
SELECT fi.Id,
|
||
fi.CreateUserName,
|
||
fi.ActivityName,
|
||
fi.CreateDate,
|
||
fi.CustomName,
|
||
fi.Code,
|
||
fi.Description,
|
||
fi.IsFinish,
|
||
CASE
|
||
WHEN fi.MakerList = '1' THEN '所有人'
|
||
WHEN fi.MakerList = '00000000-0000-0000-0000-000000000000' THEN 'System'
|
||
ELSE {groupConcatSql}
|
||
END AS MakerList
|
||
FROM FlowInstance fi
|
||
JOIN (select Id as InstanceId
|
||
from FlowInstance
|
||
where CreateUserId = '{user.User.Id}'
|
||
union
|
||
select distinct FirstId as InstanceId
|
||
from Relevance rel
|
||
inner join FlowInstance flow on rel.FirstId = flow.Id and flow.IsFinish = 1
|
||
where `Key` = '{Define.INSTANCE_NOTICE_USER}'
|
||
and SecondId = '{user.User.Id}'
|
||
union
|
||
select distinct a.FirstId as InstanceId
|
||
from Relevance a
|
||
inner join (select SecondId as RoleId
|
||
from Relevance
|
||
where `Key` = 'UserRole'
|
||
and FirstId = '{user.User.Id}') b on a.SecondId = b.RoleId
|
||
inner join FlowInstance flow on a.FirstId = flow.Id and flow.IsFinish = 1
|
||
where a.`Key` = '{Define.INSTANCE_NOTICE_ROLE}') UniqueInstanceIds
|
||
ON fi.Id = UniqueInstanceIds.InstanceId
|
||
";
|
||
}
|
||
|
||
switch (SugarClient.CurrentConnectionConfig.DbType)
|
||
{
|
||
case DbType.SqlServer:
|
||
sql = sql.Replace("`Key`", "[Key]");
|
||
sql = sql.Replace("from dual", "");
|
||
break;
|
||
case DbType.Oracle:
|
||
sql = sql.Replace("`Key`", "\"KEY\"");
|
||
break;
|
||
}
|
||
|
||
var finalQuery = SugarClient.SqlQueryable<FlowInstance>(sql)
|
||
.WhereIF(!string.IsNullOrEmpty(request.key), t => t.CustomName.Contains(request.key));
|
||
|
||
result.count = await finalQuery.CountAsync();
|
||
result.data = await finalQuery.OrderByDescending(u => u.CreateDate)
|
||
.ToPageListAsync(request.page, request.limit);
|
||
|
||
return result;
|
||
}
|
||
|
||
public List<FlowInstanceOperationHistory> QueryHistories(QueryFlowInstanceHistoryReq request)
|
||
{
|
||
return SugarClient.Queryable<FlowInstanceOperationHistory>()
|
||
.Where(u => u.InstanceId == request.FlowInstanceId)
|
||
.OrderByDescending(u => u.CreateDate).ToList();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 召回流程
|
||
/// </summary>
|
||
public void ReCall(RecallFlowInstanceReq request)
|
||
{
|
||
FlowInstance flowInstance = Get(request.FlowInstanceId);
|
||
if (flowInstance.IsFinish == FlowInstanceStatus.Draft
|
||
|| flowInstance.IsFinish == FlowInstanceStatus.Finished)
|
||
{
|
||
throw new Exception("当前流程状态不能召回");
|
||
}
|
||
|
||
FlowRuntime wfruntime = new FlowRuntime(flowInstance);
|
||
wfruntime.ReCall(request);
|
||
}
|
||
|
||
/// <summary>启动流程</summary>
|
||
/// <remarks> 通常是对状态为【草稿】的流程进行操作，进入运行状态 </remarks>
|
||
public void Start(StartFlowInstanceReq request)
|
||
{
|
||
FlowInstance flowInstance = Get(request.FlowInstanceId);
|
||
if (flowInstance.IsFinish != FlowInstanceStatus.Draft)
|
||
{
|
||
throw new Exception("当前流程不是草稿状态，不能启动");
|
||
}
|
||
|
||
var wfruntime = new FlowRuntime(flowInstance);
|
||
var user = _auth.GetCurrentUser();
|
||
|
||
if (wfruntime.nextNode.setInfo.NodeDesignate == Setinfo.RUNTIME_SPECIAL_USER
|
||
|| wfruntime.nextNode.setInfo.NodeDesignate == Setinfo.RUNTIME_SPECIAL_ROLE)
|
||
{
|
||
throw new Exception("暂不支持【第二执行节点为运行时指定角色/账号执行】的流程恢复");
|
||
}
|
||
|
||
#region 根据运行实例改变当前节点状态
|
||
|
||
flowInstance.ActivityId = wfruntime.nextNodeId;
|
||
flowInstance.ActivityType = wfruntime.GetNextNodeType();
|
||
flowInstance.ActivityName = wfruntime.nextNode.name;
|
||
flowInstance.PreviousId = wfruntime.currentNodeId;
|
||
flowInstance.CreateUserId = user.User.Id;
|
||
flowInstance.CreateUserName = user.User.Account;
|
||
flowInstance.MakerList = wfruntime.GetNextNodeType() != 4 ? wfruntime.GetNextMakers() : "";
|
||
flowInstance.IsFinish = wfruntime.GetNextNodeType() == 4
|
||
? FlowInstanceStatus.Finished
|
||
: FlowInstanceStatus.Running;
|
||
|
||
SugarClient.Updateable(flowInstance).ExecuteCommand();
|
||
|
||
#endregion 根据运行实例改变当前节点状态
|
||
|
||
wfruntime.SaveOperationHis($"【启动】由用户{user.User.Name}启动");
|
||
wfruntime.SaveTransitionHis();
|
||
SugarClient.Ado.CommitTran();
|
||
}
|
||
|
||
public FlowInstanceApp(ISqlSugarClient client, IAuth auth, RevelanceManagerApp revelanceApp,
|
||
FlowSchemeApp flowSchemeApp, FormApp formApp, IHttpClientFactory httpClientFactory,
|
||
SysMessageApp messageApp, UserManagerApp userManagerApp,
|
||
IServiceProvider serviceProvider, FlowApproverApp flowApproverApp,
|
||
RevelanceManagerApp revelanceManagerApp, DbExtension dbExtension) : base(client, auth)
|
||
{
|
||
_revelanceApp = revelanceApp;
|
||
_flowSchemeApp = flowSchemeApp;
|
||
_formApp = formApp;
|
||
_httpClientFactory = httpClientFactory;
|
||
_messageApp = messageApp;
|
||
_userManagerApp = userManagerApp;
|
||
_serviceProvider = serviceProvider;
|
||
_flowApproverApp = flowApproverApp;
|
||
_revelanceManagerApp = revelanceManagerApp;
|
||
_dbExtension = dbExtension;
|
||
}
|
||
}
|
||
} |