ccy/mh_sms
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
07b47b5399
mh_sms/APT.MS.Services/Services/BS/BSOperateLogService.cs

302 lines
18 KiB
C#
Raw Normal View History

代码同步
2024-03-25 13:56:33 +08:00
using APT.BaseData.Domain.Entities;
using APT.BaseData.Domain.Enums;
using APT.Infrastructure.Core;
using System;
using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Domain.IServices.FM;
using APT.Infrastructure.Api;
using System.Collections.Generic;
using System.Linq;
using APT.MS.Domain.Enums;
using APT.BaseData.Domain.Enums.PF;
using APT.BaseData.Domain.IServices;
using System.Linq.Expressions;
using Newtonsoft.Json;
using APT.BaseData.Domain.IServices.BS;
using APT.MS.Domain.Entities.BS;
代码合并 T_FM_SYNC_LOG 添加 时间限制才入库 log4Net 年月 添加 跑批 部分添加 try catch 记录错误（大概率比较少错误了懒得全部添加过来） 隐患整改单 获取数据改进 （检查库 添加 整改单 查看） FMFlowPermitService 添加 记录信息 防止 全部注入依赖
2024-04-09 13:56:33 +08:00
namespace APT.BaseData.Services.DomainServices
代码同步
2024-03-25 13:56:33 +08:00
{
/// <summary>
/// 安全检查
/// </summary>
public class BSOperateLogService : CommonService, IBSOperateLogService
{
public BSOperateLogService(IRepository repository) : base(repository)
{
}
/// <summary>
/// 直接添加多个操作
/// 或者 一个操作 引起多个后续操作人
/// </summary>
/// <param name="OPERATEPOINT">操作的节点</param>
/// <param name="DATA_ID">SafeCheckID RiskSubmitID</param>
/// <param name="UserIDLogin">登入人ID</param>
/// <param name="ListDATA_ID">可为null与 DATA_ID 只有一个</param>
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
/// <param name="ListUserID">可为null 需要添加下一个节点的人员ID</param>
/// <param name="ListUserName">可为null需要添加下一个节点的人员姓名</param>
代码同步
2024-03-25 13:56:33 +08:00
/// <param name="ORG_ID"></param>
/// <param name="DATA_ID_SUB"></param>
/// <param name="ListUserIDDone">默认操作通过的</param>
/// <param name="isEnd"></param>
/// <returns></returns>
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
public List<T_BS_OPERATE_LOG> GetListOperateLog(OPERATEPOINT_Enums OPERATEPOINT, Guid DATA_ID, Guid UserIDLogin, List<Guid> ListDATA_ID, List<Guid> ListUserID, List<string> ListUserName, Guid? ORG_ID, Guid? DATA_ID_SUB = null, List<Guid> ListUserIDDone = null, bool isEnd = false, DateTime? TASK_ENDDT = null)
代码同步
2024-03-25 13:56:33 +08:00
{
List<T_BS_OPERATE_LOG> listResult = new List<T_BS_OPERATE_LOG>();
T_BS_OPERATE_LOG modelLogUpdate = null;
switch (OPERATEPOINT)
{
case OPERATEPOINT_Enums.GotCheck:
//系统触发 只是新增
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (ListUserID != null && ListUserName != null && ListUserID.Any())
代码同步
2024-03-25 13:56:33 +08:00
for (int i = 0; i < ListUserID.Count; i++)
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
listResult.Add(AddModel(OPERATEPOINT, ListDATA_ID[i], ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
case OPERATEPOINT_Enums.CheckForm:
//BS032保存并发送 到审批流
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT_Enums.GotCheck, DATA_ID, UserIDLogin, null, TASK_ENDDT);
代码同步
2024-03-25 13:56:33 +08:00
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (ListUserID != null && ListUserName != null && ListUserID.Any())
代码同步
2024-03-25 13:56:33 +08:00
for (int i = 0; i < ListUserID.Count; i++)
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
listResult.Add(AddModel(OPERATEPOINT, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
case OPERATEPOINT_Enums.CheckAudit:
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的待办日志
代码同步
2024-03-25 13:56:33 +08:00
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (ListUserID != null && ListUserName != null && ListUserID.Any())
代码同步
2024-03-25 13:56:33 +08:00
for (int i = 0; i < ListUserID.Count; i++)//最后一个审批人 添加 通知
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
listResult.Add(AddModel(OPERATEPOINT_Enums.CheckerCheck, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
case OPERATEPOINT_Enums.CheckerCheck:
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
代码同步
2024-03-25 13:56:33 +08:00
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
break;
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
case OPERATEPOINT_Enums.CheckRegisterRun:
//检查登记
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++) //发起检查登记
listResult.Add(AddModel(OPERATEPOINT_Enums.CheckRegister, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
代码同步
2024-03-25 13:56:33 +08:00
case OPERATEPOINT_Enums.CheckRegister:
//检查登记
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
代码同步
2024-03-25 13:56:33 +08:00
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (ListUserID != null && ListUserName != null && ListUserID.Any())
代码同步
2024-03-25 13:56:33 +08:00
for (int i = 0; i < ListUserID.Count; i++) //发起检查结果确认
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
listResult.Add(AddModel(OPERATEPOINT_Enums.CheckAgree, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
case OPERATEPOINT_Enums.CheckAgree:
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
代码同步
2024-03-25 13:56:33 +08:00
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (ListUserID != null && ListUserName != null && ListUserID.Any())
代码同步
2024-03-25 13:56:33 +08:00
for (int i = 0; i < ListUserID.Count; i++) //检查结果确认完 直接到审批
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
listResult.Add(AddModel(OPERATEPOINT_Enums.CheckResultAudit, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
case OPERATEPOINT_Enums.CheckResultAudit:
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
代码同步
2024-03-25 13:56:33 +08:00
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (isEnd) //最后一个审批就归档
{
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
var logEnd = AddModel(OPERATEPOINT_Enums.CheckEnd, DATA_ID, UserIDLogin, APT.Infrastructure.Api.AppContext.CurrentSession.UserName, ORG_ID);
logEnd.OPERTETIME = DateTime.Now;
if (modelLogUpdate != null)
logEnd.ISINTTIME = modelLogUpdate.ISINTTIME;
listResult.Add(logEnd);
}
else if (DATA_ID_SUB != null)
{
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskGet, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
}
break;
case OPERATEPOINT_Enums.CheckEnd:
//此处没操作
break;
case OPERATEPOINT_Enums.RiskNoticeSD:
break;
case OPERATEPOINT_Enums.RiskUpSD:
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
//有用
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskUpSD, DATA_ID, UserIDLogin, APT.Infrastructure.Api.AppContext.CurrentSession.UserName, ORG_ID, 1, true, DATA_ID_SUB));
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskInfoCompleteSD, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
case OPERATEPOINT_Enums.RiskInfoCompleteSD:
break;
case OPERATEPOINT_Enums.RiskGet:
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
代码同步
2024-03-25 13:56:33 +08:00
for (int i = 0; i < ListUserID.Count; i++)
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskSendAudit, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
代码同步
2024-03-25 13:56:33 +08:00
break;
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
//case OPERATEPOINT_Enums.RiskSend:
// modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
// if (modelLogUpdate != null)
// listResult.Add(modelLogUpdate);
// if (ListUserID != null && ListUserName != null && ListUserID.Any())
// for (int i = 0; i < ListUserID.Count; i++)
// listResult.Add(AddModel(OPERATEPOINT_Enums.RiskSendAudit, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
// break;
case OPERATEPOINT_Enums.RiskSendAudit:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, null, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskAssignActure, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskAssignActure:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskNoticeCheckerCheck, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskNoticeCheckerCheck:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskNoticeActureCheck, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskNoticeActureCheck:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskDeal, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskDeal:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskDealDealCheck, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskDealDealCheck:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskDealCheckerCheck, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskDealCheckerCheck:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
if (ListUserID != null && ListUserName != null && ListUserID.Any())
for (int i = 0; i < ListUserID.Count; i++)
listResult.Add(AddModel(OPERATEPOINT_Enums.RiskDealAudit, DATA_ID, ListUserID[i], ListUserName[i], ORG_ID, i, false, DATA_ID_SUB));
break;
case OPERATEPOINT_Enums.RiskDealAudit:
modelLogUpdate = GetUpdateDeal(OPERATEPOINT, DATA_ID, UserIDLogin, DATA_ID_SUB, TASK_ENDDT);//处理自己的
if (modelLogUpdate != null)
listResult.Add(modelLogUpdate);
var logEndRisk = AddModel(OPERATEPOINT_Enums.RiskEnd, DATA_ID, UserIDLogin, APT.Infrastructure.Api.AppContext.CurrentSession.UserName, ORG_ID);
logEndRisk.OPERTETIME = DateTime.Now;
if (modelLogUpdate != null)
logEndRisk.ISINTTIME = modelLogUpdate.ISINTTIME;
listResult.Add(logEndRisk);
break;
case OPERATEPOINT_Enums.RiskEnd:
代码同步
2024-03-25 13:56:33 +08:00
break;
default:
break;
}
if (ListUserIDDone != null && ListUserIDDone.Count > 0)
{
//除了登陆者 需要默认操作的
listResult.ForEach(e =>
{
if (ListUserIDDone.Contains(e.USER_ID))
e.OPERTETIME = DateTime.Now;
});
}
return listResult;
}
/// <summary>
/// 获取新记录
/// </summary>
/// <param name="OPERATEPOINT"></param>
/// <param name="DATA_ID"></param>
/// <param name="UserID"></param>
/// <param name="UserName"></param>
/// <param name="ORG_ID"></param>
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
/// <param name="ORDERNO"></param>
/// <param name="isAddLog">是否添加记录 比如没找到记录 直接添加记录</param>
代码同步
2024-03-25 13:56:33 +08:00
/// <returns></returns>
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
private T_BS_OPERATE_LOG AddModel(OPERATEPOINT_Enums OPERATEPOINT, Guid DATA_ID, Guid UserID, string UserName, Guid? ORG_ID, int ORDERNO = 0, bool isAddLog = false, Guid? DATA_ID_SUB = null)
代码同步
2024-03-25 13:56:33 +08:00
{
T_BS_OPERATE_LOG ModelAdd = new T_BS_OPERATE_LOG()
{
ID = Guid.NewGuid(),
ORG_ID = ORG_ID,
LOGTYPE = ((int)OPERATEPOINT) > 80 ? LOGTYPE_Enums.RiskSubmit : LOGTYPE_Enums.SafeCheck,
DATA_ID = DATA_ID,
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
DATA_ID_SUB = DATA_ID_SUB,
代码同步
2024-03-25 13:56:33 +08:00
OPERATEPOINT = OPERATEPOINT,
USER_ID = UserID,
USRTNAME = UserName,
ORDERNO = ORDERNO,
//OPERTETIME = null,
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
//ISINTTIME = false,
代码同步
2024-03-25 13:56:33 +08:00
CREATE_TIME = DateTime.Now,
CREATER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID
};
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (isAddLog || (APT.Infrastructure.Api.AppContext.CurrentSession.UserID.HasValue && APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value == UserID))
代码同步
2024-03-25 13:56:33 +08:00
{
ModelAdd.OPERTETIME = DateTime.Now;//默认通过
}
return ModelAdd;
}
/// <summary>
/// 获取需要修改的Model
/// </summary>
/// <param name="OPERATEPOINT">操作节点</param>
/// <param name="DATA_ID"></param>
/// <param name="UserID"></param>
/// <param name="DATA_ID_SUB"></param>
/// <returns></returns>
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
private T_BS_OPERATE_LOG GetUpdateDeal(OPERATEPOINT_Enums OPERATEPOINT, Guid DATA_ID, Guid UserID, Guid? DATA_ID_SUB = null, DateTime? TASK_ENDDT = null)
代码同步
2024-03-25 13:56:33 +08:00
{
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (UserID == Guid.Empty)
{
return null;
}
代码同步
2024-03-25 13:56:33 +08:00
Expression<Func<T_BS_OPERATE_LOG, bool>> expression = e => e.DATA_ID == DATA_ID && e.OPERATEPOINT == OPERATEPOINT && e.USER_ID == UserID;
if (DATA_ID_SUB.HasValue)
expression = expression.And(e => e.DATA_ID_SUB.HasValue && e.DATA_ID_SUB == DATA_ID_SUB);
var model = GetEntity(expression);
安全检查记录 null 处理
2024-03-26 11:50:40 +08:00
if (model != null)
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
{
安全检查记录 null 处理
2024-03-26 11:50:40 +08:00
model.OPERTETIME = DateTime.Now;
代码同步 SPS=>SMS
2024-05-23 13:49:45 +08:00
if (TASK_ENDDT != null)
model.ISINTTIME = (model.OPERTETIME > TASK_ENDDT.Value ? false : true);
}
代码同步
2024-03-25 13:56:33 +08:00
return model;
}
}
}
Reference in New Issue Copy Permalink