531 lines
21 KiB
C#
531 lines
21 KiB
C#
using Microsoft.EntityFrameworkCore;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Reflection;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using iMES.Core.DBManager;
|
||
using iMES.Core.EFDbContext;
|
||
using iMES.Core.Extensions;
|
||
using iMES.Core.ManageUser;
|
||
using iMES.Core.Services;
|
||
using iMES.Core.Utilities;
|
||
using iMES.Entity.DomainModels;
|
||
|
||
namespace iMES.Core.WorkFlow
|
||
{
|
||
public static class WorkFlowManager
|
||
{
|
||
public static bool Exists<T>()
|
||
{
|
||
return WorkFlowContainer.Exists<T>();
|
||
}
|
||
|
||
public static bool Exists<T>(T entity)
|
||
{
|
||
return WorkFlowContainer.Exists<T>() && GetAuditFlowTable<T>(typeof(T).GetKeyProperty().GetValue(entity).ToString()) != null;
|
||
}
|
||
public static bool Exists(string table)
|
||
{
|
||
return WorkFlowContainer.Exists(table);
|
||
}
|
||
|
||
public static int GetAuditStatus<T>(string value)
|
||
{
|
||
return GetAuditFlowTable<T>(value)?.AuditStatus ?? 0;
|
||
}
|
||
|
||
public static Sys_WorkFlowTable GetAuditFlowTable<T>(string workTableKey)
|
||
{
|
||
var table = DBServerProvider.DbContext.Set<Sys_WorkFlowTable>()
|
||
.Where(x => x.WorkTable == typeof(T).GetEntityTableName() && x.WorkTableKey == workTableKey)
|
||
// .Select(s => new { s.CurrentStepId,s.AuditStatus})
|
||
.FirstOrDefault();
|
||
return table;
|
||
}
|
||
|
||
private static void Rewrite<T>(T entity, Sys_WorkFlow workFlow, bool changeTableStatus) where T : class
|
||
{
|
||
var autditProperty = typeof(T).GetProperties().Where(x => x.Name.ToLower() == "auditstatus").FirstOrDefault();
|
||
if (autditProperty == null)
|
||
{
|
||
return;
|
||
}
|
||
|
||
string value = typeof(T).GetKeyProperty().GetValue(entity).ToString();
|
||
|
||
var dbContext = DBServerProvider.DbContext;
|
||
|
||
|
||
var workTable = dbContext.Set<Sys_WorkFlowTable>().Where(x => x.WorkTableKey == value && x.WorkFlow_Id == workFlow.WorkFlow_Id)
|
||
.AsNoTracking()
|
||
.Include(x => x.Sys_WorkFlowTableStep).FirstOrDefault();
|
||
if (workTable == null || workFlow.Sys_WorkFlowStep == null || workFlow.Sys_WorkFlowStep.Count == 0)
|
||
{
|
||
Console.WriteLine($"未查到流程数据，id：{ workFlow.WorkFlow_Id}");
|
||
return;
|
||
}
|
||
// workTable.CurrentOrderId = 1;
|
||
|
||
//这里还未处理回退到上一个节点
|
||
|
||
//重新设置第一个节点(有可能是返回上一个节点)
|
||
string startStepId = workTable.Sys_WorkFlowTableStep.Where(x => x.StepAttrType == StepType.start.ToString())
|
||
.Select(s => s.StepId).FirstOrDefault();
|
||
|
||
workTable.CurrentStepId = workTable.Sys_WorkFlowTableStep.Where(x => x.ParentId == startStepId).Select(s => s.StepId).FirstOrDefault();
|
||
|
||
workTable.AuditStatus = (int)AuditStatus.待审核;
|
||
workTable.Sys_WorkFlowTableStep.ForEach(item =>
|
||
{
|
||
item.Enable = 0;
|
||
item.AuditId = null;
|
||
item.Auditor = null;
|
||
item.AuditDate = null;
|
||
item.Remark = null;
|
||
});
|
||
|
||
if (changeTableStatus)
|
||
{
|
||
dbContext.Entry(entity).State = EntityState.Detached;
|
||
autditProperty.SetValue(entity, 0);
|
||
dbContext.Entry(entity).Property(autditProperty.Name).IsModified = true;
|
||
}
|
||
|
||
dbContext.Entry(workTable).State = EntityState.Detached;
|
||
dbContext.Update(workTable);
|
||
dbContext.SaveChanges();
|
||
|
||
}
|
||
/// <summary>
|
||
/// 新建时写入流程
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="entity"></param>
|
||
/// <param name="rewrite">是否重新生成流程</param>
|
||
/// <param name="changeTableStatus">是否修改原表的审批状态</param>
|
||
public static void AddProcese<T>(T entity, bool rewrite = false, bool changeTableStatus = true) where T : class
|
||
{
|
||
WorkFlowTableOptions workFlow = WorkFlowContainer.GetFlowOptions(entity);
|
||
//没有对应的流程信息
|
||
if (workFlow == null || workFlow.FilterList.Count == 0)
|
||
{
|
||
return;
|
||
}
|
||
workFlow.WorkTableName = WorkFlowContainer.GetName<T>();
|
||
string workTable = typeof(T).GetEntityTableName();
|
||
|
||
////重新生成流程
|
||
if (rewrite)
|
||
{
|
||
Rewrite(entity, workFlow, changeTableStatus);
|
||
return;
|
||
}
|
||
|
||
var userInfo = UserContext.Current.UserInfo;
|
||
Guid workFlowTable_Id = Guid.NewGuid();
|
||
Sys_WorkFlowTable workFlowTable = new Sys_WorkFlowTable()
|
||
{
|
||
WorkFlowTable_Id = workFlowTable_Id,
|
||
AuditStatus = (int)AuditStatus.待审核,
|
||
Enable = 1,
|
||
WorkFlow_Id = workFlow.WorkFlow_Id,
|
||
WorkName = workFlow.WorkName,
|
||
WorkTable = workTable,
|
||
WorkTableKey = typeof(T).GetKeyProperty().GetValue(entity).ToString(),
|
||
WorkTableName = workFlow.WorkTableName,
|
||
CreateID = userInfo.User_Id,
|
||
CreateDate = DateTime.Now,
|
||
Creator = userInfo.UserTrueName
|
||
};
|
||
//生成流程的下一步
|
||
var steps = workFlow.FilterList.Where(x => x.StepAttrType == StepType.start.ToString()).Select(s => new Sys_WorkFlowTableStep()
|
||
{
|
||
Sys_WorkFlowTableStep_Id = Guid.NewGuid(),
|
||
WorkFlowTable_Id = workFlowTable_Id,
|
||
WorkFlow_Id = workFlow.WorkFlow_Id,
|
||
StepId = s.StepId,
|
||
StepName = s.StepName ?? "流程开始",
|
||
StepAttrType = s.StepAttrType,
|
||
NextStepId = null,
|
||
ParentId = null,
|
||
StepType = s.StepType,
|
||
StepValue = s.StepValue,
|
||
OrderId = 0,
|
||
Enable = 1,
|
||
CreateDate = DateTime.Now,
|
||
Creator = userInfo.UserTrueName,
|
||
CreateID = userInfo.User_Id
|
||
}).ToList();
|
||
|
||
var entities = new List<T>() { entity };
|
||
for (int i = 0; i < steps.Count; i++)
|
||
{
|
||
var item = steps[i];
|
||
//查找下一个满足条件的节点数据
|
||
FilterOptions filter = workFlow.FilterList.Where(c => c.ParentIds.Contains(item.StepId)
|
||
&& c.Expression != null
|
||
&& entities.Any(((Func<T, bool>)c.Expression))
|
||
).FirstOrDefault();
|
||
//未找到满足条件的找无条件的节点
|
||
if (filter == null)
|
||
{
|
||
filter = workFlow.FilterList.Where(c => c.ParentIds.Contains(item.StepId) && c.Expression == null).FirstOrDefault();
|
||
}
|
||
if (filter != null)
|
||
{
|
||
var setp = workFlow.Sys_WorkFlowStep.Where(x => x.StepId == filter.StepId).Select(s => new Sys_WorkFlowTableStep()
|
||
{
|
||
Sys_WorkFlowTableStep_Id = Guid.NewGuid(),
|
||
WorkFlowTable_Id = workFlowTable_Id,
|
||
WorkFlow_Id = s.WorkFlow_Id,
|
||
|
||
StepId = s.StepId,
|
||
StepName = s.StepName,
|
||
StepAttrType = s.StepAttrType,
|
||
NextStepId = null,
|
||
ParentId = item.StepId,
|
||
StepType = s.StepType,
|
||
StepValue = s.StepValue,
|
||
OrderId = i + 1,
|
||
Enable = 1,
|
||
CreateDate = DateTime.Now,
|
||
}).FirstOrDefault();
|
||
|
||
//显示后续部门与角色审批人待完
|
||
|
||
//设置下个审核节点
|
||
item.NextStepId = setp.StepId;
|
||
if (!steps.Any(x => x.StepId == setp.StepId))
|
||
{
|
||
steps.Add(setp);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//找不到满足条件的节点，直接结束流程
|
||
var end = workFlow.Sys_WorkFlowStep.Where(c => c.StepAttrType == StepType.end.ToString()).ToList();
|
||
|
||
if (end.Count > 0)
|
||
{
|
||
item.NextStepId = end[0].StepId;
|
||
steps.Add(end.Select(s => new Sys_WorkFlowTableStep()
|
||
{
|
||
Sys_WorkFlowTableStep_Id = Guid.NewGuid(),
|
||
WorkFlowTable_Id = workFlowTable_Id,
|
||
WorkFlow_Id = s.WorkFlow_Id,
|
||
StepId = s.StepId,
|
||
StepName = s.StepName,
|
||
StepAttrType = s.StepAttrType,
|
||
NextStepId = null,
|
||
ParentId = item.StepId,
|
||
StepType = s.StepType,
|
||
StepValue = s.StepValue,
|
||
OrderId = i + 1,
|
||
Enable = 1,
|
||
CreateDate = DateTime.Now,
|
||
}).FirstOrDefault());
|
||
i = steps.Count + 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
foreach (var setp in steps)
|
||
{
|
||
if (setp.StepType == (int)AuditType.用户审批)
|
||
{
|
||
setp.AuditId = setp.StepValue.GetInt();
|
||
}
|
||
}
|
||
|
||
//没有满足流程的数据不走流程
|
||
int count = steps.Where(x => x.StepAttrType != StepType.start.ToString() && x.StepAttrType != StepType.end.ToString()).Count();
|
||
if (count == 0)
|
||
{
|
||
return;
|
||
}
|
||
|
||
//设置进入流程后的第一个审核节点,(开始节点的下一个节点)
|
||
var nodeInfo = steps.Where(x => x.ParentId == steps[0].StepId).Select(s => new { s.StepId, s.StepName }).FirstOrDefault();
|
||
workFlowTable.CurrentStepId = nodeInfo.StepId;
|
||
workFlowTable.StepName = nodeInfo.StepName;
|
||
|
||
workFlowTable.Sys_WorkFlowTableStep = steps;
|
||
|
||
//写入日志
|
||
var log = new Sys_WorkFlowTableAuditLog()
|
||
{
|
||
Id = Guid.NewGuid(),
|
||
WorkFlowTable_Id = workFlowTable.WorkFlowTable_Id,
|
||
CreateDate = DateTime.Now,
|
||
AuditStatus = (int)AuditStatus.待审核,
|
||
Remark = $"[{userInfo.UserTrueName}]提交了数据"
|
||
};
|
||
var dbContext = DBServerProvider.DbContext;
|
||
dbContext.Set<Sys_WorkFlowTable>().Add(workFlowTable);
|
||
dbContext.Set<Sys_WorkFlowTableAuditLog>().Add(log);
|
||
dbContext.SaveChanges();
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 审核
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="entity"></param>
|
||
/// <param name="status"></param>
|
||
/// <param name="remark"></param>
|
||
/// <param name="autditProperty"></param>
|
||
/// <param name="workFlowExecuting"></param>
|
||
/// <param name="workFlowExecuted"></param>
|
||
/// <returns></returns>
|
||
public static WebResponseContent Audit<T>(T entity, AuditStatus status, string remark,
|
||
PropertyInfo autditProperty,
|
||
Func<T, AuditStatus, bool, WebResponseContent> workFlowExecuting,
|
||
Func<T, AuditStatus, List<int>, bool, WebResponseContent> workFlowExecuted,
|
||
bool init = false,
|
||
Action<T, List<int>> initInvoke = null
|
||
) where T : class
|
||
{
|
||
WebResponseContent webResponse = new WebResponseContent(true);
|
||
if (init)
|
||
{
|
||
if (!WorkFlowContainer.Exists<T>())
|
||
{
|
||
return webResponse;
|
||
}
|
||
}
|
||
var dbContext = DBServerProvider.DbContext;
|
||
dbContext.QueryTracking = true; ;
|
||
var query = dbContext.Set<T>();
|
||
|
||
var keyProperty = typeof(T).GetKeyProperty();
|
||
string key = keyProperty.GetValue(entity).ToString();
|
||
string workTable = typeof(T).GetEntityTableName();
|
||
|
||
Sys_WorkFlowTable workFlow = dbContext.Set<Sys_WorkFlowTable>()
|
||
.Where(x => x.WorkTable == workTable && x.WorkTableKey == key)
|
||
.Include(x => x.Sys_WorkFlowTableStep)
|
||
.FirstOrDefault();
|
||
|
||
if (workFlow == null)
|
||
{
|
||
return webResponse.Error("未查到流程信息,请检查数据是否被删除");
|
||
}
|
||
|
||
|
||
workFlow.AuditStatus = (int)status;
|
||
|
||
var currentStep = workFlow.Sys_WorkFlowTableStep.Where(x => x.StepId == workFlow.CurrentStepId).FirstOrDefault();
|
||
|
||
if (currentStep == null)
|
||
{
|
||
return webResponse.Error($"未查到流程陈点[workFlow.CurrentStepId]信息,请检查数据是否被删除");
|
||
}
|
||
var user = UserContext.Current.UserInfo;
|
||
//生成审核记录
|
||
var log = new Sys_WorkFlowTableAuditLog()
|
||
{
|
||
Id = Guid.NewGuid(),
|
||
StepId = currentStep.StepId,
|
||
WorkFlowTable_Id = currentStep.WorkFlowTable_Id,
|
||
WorkFlowTableStep_Id = currentStep.Sys_WorkFlowTableStep_Id,
|
||
AuditDate = DateTime.Now,
|
||
AuditId = user.User_Id,
|
||
Auditor = user.UserTrueName,
|
||
AuditResult = remark,
|
||
Remark = remark,
|
||
AuditStatus = (int)status,
|
||
CreateDate = DateTime.Now,
|
||
StepName = currentStep.StepName
|
||
};
|
||
|
||
if (autditProperty == null)
|
||
{
|
||
autditProperty = typeof(T).GetProperties().Where(s => s.Name.ToLower() == "auditstatus").FirstOrDefault();
|
||
}
|
||
bool isLast = false;
|
||
Sys_WorkFlowTableStep nextStep = null;
|
||
|
||
//更新明细记录
|
||
workFlow.Sys_WorkFlowTableStep.ForEach(x =>
|
||
{
|
||
if (workFlow.CurrentStepId == x.StepId)
|
||
{
|
||
x.AuditId = user.User_Id;
|
||
x.Auditor = user.UserTrueName;
|
||
x.AuditDate = DateTime.Now;
|
||
//如果审核拒绝或驳回并退回上一步，待完
|
||
x.AuditStatus = (int)status;
|
||
x.Remark = remark;
|
||
}
|
||
});
|
||
//获取下一步审核id
|
||
var nextStepId = currentStep.NextStepId;
|
||
|
||
nextStep = workFlow.Sys_WorkFlowTableStep.Where(x => x.StepId == nextStepId).FirstOrDefault();
|
||
//没有找到下一步审批，审核完成
|
||
if ((nextStep == null || nextStep.StepAttrType == StepType.end.ToString()))
|
||
{
|
||
if (status == AuditStatus.审核通过)
|
||
{
|
||
workFlow.CurrentStepId = "审核完成";
|
||
}
|
||
else
|
||
{
|
||
workFlow.CurrentStepId = "流程结束";
|
||
}
|
||
var filterOptions = WorkFlowContainer.GetFlowOptions(x => x.WorkTable == workTable)
|
||
.FirstOrDefault()
|
||
?.FilterList
|
||
?.Where(x => x.StepId == currentStep.StepId)
|
||
?.FirstOrDefault();
|
||
|
||
workFlow.AuditStatus = (int)status;
|
||
|
||
if (filterOptions != null)
|
||
{
|
||
//发送邮件(appsettings.json配置文件里添加邮件信息)
|
||
SendMail(workFlow, filterOptions, nextStep, dbContext);
|
||
//如果审核拒绝或驳回并退回上一步，待完
|
||
//重新配置流程待完
|
||
if (status == AuditStatus.审核未通过)
|
||
{
|
||
if (filterOptions.AuditRefuse == (int)AuditRefuse.返回上一节点)
|
||
{
|
||
|
||
}
|
||
else if (filterOptions.AuditRefuse == (int)AuditRefuse.流程重新开始)
|
||
{
|
||
|
||
}
|
||
}
|
||
else if (status == AuditStatus.驳回)
|
||
{
|
||
if (filterOptions.AuditBack == (int)AuditBack.返回上一节点)
|
||
{
|
||
|
||
}
|
||
else if (filterOptions.AuditBack == (int)AuditBack.流程重新开始)
|
||
{
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
autditProperty.SetValue(entity, (int)status);
|
||
dbContext.Set<Sys_WorkFlowTable>().Update(workFlow);
|
||
query.Update(entity);
|
||
dbContext.Set<Sys_WorkFlowTableAuditLog>().Add(log);
|
||
dbContext.SaveChanges();
|
||
return webResponse;
|
||
}
|
||
//指向下一个人审批
|
||
if (nextStep != null && status == AuditStatus.审核通过)
|
||
{
|
||
workFlow.CurrentStepId = nextStep.StepId;
|
||
//原表显示审核中状态
|
||
autditProperty.SetValue(entity, (int)AuditStatus.审核中);
|
||
workFlow.AuditStatus = (int)AuditStatus.审核中;
|
||
}
|
||
else
|
||
{
|
||
autditProperty.SetValue(entity, (int)status);
|
||
}
|
||
|
||
|
||
//下一个节点=null或节下一个节点为结束节点，流程结束
|
||
if (nextStep == null || workFlow.Sys_WorkFlowTableStep.Exists(c => c.StepId == nextStep.StepId && c.StepAttrType == StepType.end.ToString()))
|
||
{
|
||
isLast = true;
|
||
}
|
||
|
||
if (workFlowExecuting != null)
|
||
{
|
||
webResponse = workFlowExecuting.Invoke(entity, status, isLast);
|
||
if (!webResponse.Status)
|
||
{
|
||
return webResponse;
|
||
}
|
||
}
|
||
|
||
query.Update(entity);
|
||
|
||
|
||
dbContext.Set<Sys_WorkFlowTable>().Update(workFlow);
|
||
dbContext.Set<Sys_WorkFlowTableAuditLog>().Add(log);
|
||
|
||
dbContext.SaveChanges();
|
||
dbContext.Entry(workFlow).State = EntityState.Detached;
|
||
if (workFlowExecuted != null)
|
||
{
|
||
webResponse = workFlowExecuted.Invoke(entity, status, GetAuditUserIds(nextStep?.StepType ?? 0, nextStep?.StepValue), isLast);
|
||
}
|
||
return webResponse;
|
||
}
|
||
|
||
private static void SendMail(Sys_WorkFlowTable workFlow, FilterOptions filterOptions, Sys_WorkFlowTableStep nextStep, SysDbContext dbContext)
|
||
{
|
||
if (filterOptions.SendMail != 1)
|
||
{
|
||
return;
|
||
}
|
||
//审核发送邮件通知待完
|
||
var userIds = GetAuditUserIds(nextStep.StepType ?? 0, nextStep.StepValue);
|
||
if (userIds.Count == 0)
|
||
{
|
||
return;
|
||
}
|
||
var emails = dbContext.Set<Sys_User>()
|
||
.Where(x => userIds.Contains(x.User_Id) && x.Email != null & x.Email != "").Select(s => s.Email)
|
||
.ToList();
|
||
Task.Run(() =>
|
||
{
|
||
string msg = "";
|
||
try
|
||
{
|
||
string title = $"有新的任务待审批：流程【{workFlow.WorkName}】,任务【{nextStep.StepName}】";
|
||
MailHelper.Send(title, title, string.Join(";", emails));
|
||
msg = $"审批流程发送邮件,流程名称：{workFlow.WorkName},流程id:{workFlow.WorkFlow_Id},步骤:{nextStep.StepName},步骤Id:{nextStep.StepId},收件人:{ string.Join(";", emails)}";
|
||
Logger.AddAsync(msg);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
msg += "邮件发送异常：";
|
||
Logger.AddAsync(msg, ex.Message + ex.StackTrace);
|
||
}
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取审批人的id
|
||
/// </summary>
|
||
/// <param name="stepType"></param>
|
||
/// <returns></returns>
|
||
private static List<int> GetAuditUserIds(int stepType, string nextId = null)
|
||
{
|
||
List<int> userIds = new List<int>();
|
||
if (stepType == 0 || string.IsNullOrEmpty(nextId))
|
||
{
|
||
return userIds;
|
||
}
|
||
if (stepType == (int)AuditType.角色审批)
|
||
{
|
||
int roleId = nextId.GetInt();
|
||
userIds = DBServerProvider.DbContext.Set<Sys_User>().Where(s => s.Role_Id == roleId).Take(50).Select(s => s.User_Id).ToList();
|
||
}
|
||
else if (stepType == (int)AuditType.部门审批)
|
||
{
|
||
Guid departmentId = nextId.GetGuid() ?? Guid.Empty;
|
||
userIds = DBServerProvider.DbContext.Set<Sys_UserDepartment>().Where(s => s.DepartmentId == departmentId && s.Enable == 1).Take(50).Select(s => s.UserId).ToList();
|
||
}
|
||
else
|
||
{
|
||
userIds.Add(nextId.GetInt());
|
||
}
|
||
return userIds;
|
||
}
|
||
}
|
||
}
|