wyw/mh_jy_safe
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

动作作业

Browse Source
This commit is contained in:
何美荣 2025-11-21 00:34:07 +08:00
parent c1c43bd636
commit ab40fdc893
9 changed files with 136376 additions and 145 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
APT.BaseData.Services/Services/PF/PFApproveCallBackService.cs
View File

@ -2486,6 +2486,7 @@ namespace APT.BaseData.Services.DomainServices
{ {
var entity = this.GetEntity<T_FO_FIRE_JOB>(modelApp.DATA_ID); var entity = this.GetEntity<T_FO_FIRE_JOB>(modelApp.DATA_ID);
entity.STATUS = PFStandardStatus.Archived; entity.STATUS = PFStandardStatus.Archived;
entity.FIRE_STATUS = FOFireStatus.ApprovingFinish;
UnifiedCommit(() => UnifiedCommit(() =>
{ {
if (modelApp != null) if (modelApp != null)
@ -2535,6 +2536,7 @@ namespace APT.BaseData.Services.DomainServices
{ {
var entity = this.GetEntity<T_FO_FIRE_JOB_WB>(modelApp.DATA_ID); var entity = this.GetEntity<T_FO_FIRE_JOB_WB>(modelApp.DATA_ID);
entity.STATUS = PFStandardStatus.Archived; entity.STATUS = PFStandardStatus.Archived;
entity.FIRE_STATUS = FOFireStatus.ApprovingFinish;
UnifiedCommit(() => UnifiedCommit(() =>
{ {
if (modelApp != null) if (modelApp != null)

135979
APT.Data.Migrations/Migrations/20251120163211_hmr2025112101.Designer.cs generated Normal file
View File

File diff suppressed because it is too large Load Diff

35
APT.Data.Migrations/Migrations/20251120163211_hmr2025112101.cs Normal file
View File

@ -0,0 +1,35 @@
using Microsoft.EntityFrameworkCore.Migrations;
namespace APT.Data.Migrations.Migrations
{
public partial class hmr2025112101 : Migration
{
protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.AddColumn<bool>(
name: "IS_RUN",
table: "T_FO_FIRE_JOB_WB",
type: "bit",
nullable: false,
defaultValue: false);
migrationBuilder.AddColumn<bool>(
name: "IS_RUN",
table: "T_FO_FIRE_JOB",
type: "bit",
nullable: false,
defaultValue: false);
}
protected override void Down(MigrationBuilder migrationBuilder)
{
migrationBuilder.DropColumn(
name: "IS_RUN",
table: "T_FO_FIRE_JOB_WB");
migrationBuilder.DropColumn(
name: "IS_RUN",
table: "T_FO_FIRE_JOB");
}
}
}

6
APT.Data.Migrations/Migrations/MigrationContextModelSnapshot.cs
View File

@ -33016,6 +33016,9 @@ namespace APT.Data.Migrations.Migrations
b.Property<int?>("IS_LEAVE") b.Property<int?>("IS_LEAVE")
.HasColumnType("int"); .HasColumnType("int");
b.Property<bool>("IS_RUN")
.HasColumnType("bit");
b.Property<string>("JOB_CONTENT") b.Property<string>("JOB_CONTENT")
.HasMaxLength(500) .HasMaxLength(500)
.HasColumnType("nvarchar(500)"); .HasColumnType("nvarchar(500)");
@ -33662,6 +33665,9 @@ namespace APT.Data.Migrations.Migrations
b.Property<int?>("IS_LEAVE") b.Property<int?>("IS_LEAVE")
.HasColumnType("int"); .HasColumnType("int");
b.Property<bool>("IS_RUN")
.HasColumnType("bit");
b.Property<string>("JOB_CONTENT") b.Property<string>("JOB_CONTENT")
.HasMaxLength(500) .HasMaxLength(500)
.HasColumnType("nvarchar(500)"); .HasColumnType("nvarchar(500)");

2
APT.MS.Domain/Entities/FO/T_FO_FIRE_JOB.cs
View File

@ -245,5 +245,7 @@ namespace APT.MS.Domain.Entities.FO
[Description("动火流程状态")] [Description("动火流程状态")]
[EnumName("FOFireStatus")] [EnumName("FOFireStatus")]
public FOFireStatus FIRE_STATUS { get; set; } public FOFireStatus FIRE_STATUS { get; set; }
[Description("是否已触发")]
public bool IS_RUN { get; set; } = false;
} }
} }

3
APT.MS.Domain/Entities/FO/T_FO_FIRE_JOB_WB.cs
View File

@ -235,5 +235,8 @@ namespace APT.MS.Domain.Entities.FO
[Description("动火流程状态")] [Description("动火流程状态")]
[EnumName("FOFireStatus")] [EnumName("FOFireStatus")]
public FOFireStatus FIRE_STATUS { get; set; } public FOFireStatus FIRE_STATUS { get; set; }
[Description("是否已触发")]
public bool IS_RUN { get; set; } = false;
} }
} }

257
APT.MicroApi/APT.FO.WebApi/Controllers/FireJobController.cs
View File

@ -7,6 +7,7 @@ using APT.BaseData.Services.DomainServices;
using APT.BaseData.Services.Services.FM; using APT.BaseData.Services.Services.FM;
using APT.Infrastructure.Core; using APT.Infrastructure.Core;
using APT.MS.Domain.Entities.FO; using APT.MS.Domain.Entities.FO;
using APT.MS.Domain.Entities.OG;
using APT.MS.Domain.Enums; using APT.MS.Domain.Enums;
using APT.Utility; using APT.Utility;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
@ -147,7 +148,7 @@ namespace APT.FO.WebApi.Controllers
var userList = new List<T_FO_FIRE_JOB_USER>(); var userList = new List<T_FO_FIRE_JOB_USER>();
if (users != null && users.Any()) if (users != null && users.Any())
{ {
var userTypes = this.GetEntities<T_FO_USER_TYPE>(t => t.NAME == "动火操作人员" || t.NAME == "瓦检员" || t.NAME == "喷水人员", new BaseFilter(entity.ORG_ID)); var userTypes = this.GetEntities<T_OG_RELATED_USER_TYPE>(t => t.NAME == "动火操作人员" || t.NAME == "瓦检员" || t.NAME == "喷水人员", new BaseFilter(entity.ORG_ID));
var userTypeIds = userTypes.Select(m => m.ID).ToList(); var userTypeIds = userTypes.Select(m => m.ID).ToList();
var dhUser = userTypes.FirstOrDefault(t => t.NAME == "动火操作人员"); var dhUser = userTypes.FirstOrDefault(t => t.NAME == "动火操作人员");
if (dhUser == null) if (dhUser == null)
@ -248,62 +249,114 @@ namespace APT.FO.WebApi.Controllers
monitorFileList.Add(item); monitorFileList.Add(item);
} }
} }
List<T_FM_NOTIFICATION_TASK> notices = new List<T_FM_NOTIFICATION_TASK>();
if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify")) if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify"))
{ {
//触发审批 //监护人员填写
entity.STATUS = BaseData.Domain.Enums.PF.PFStandardStatus.Approving; if (entity.FIRE_STATUS == FOFireStatus.Monitor)
entity.FIRE_STATUS = FOFireStatus.Approving;
//取审批流水码
var sysFilter = new SystemCodeFilter();
sysFilter.CodeType = (int)PFCodeRuleType.审批流编码;
sysFilter.Count = 1;
sysFilter.OrgId = entity.ORG_ID;
var codes = CodeRuleService.NewGenSerial(sysFilter);
var serialCode = codes.Split(new char[] { ',' });
var department = this.GetEntity<T_FM_DEPARTMENT>(t => t.ID == departmentId);
var param = Enum.GetName(typeof(FMDepartmentType), department.DEPARTMENT_TYPE);
if (department.DEPARTMENT_STATUS == 2)
{ {
param = "公司"; //触发给动火部门负责人、安全管理人员审阅
var sendUser = this.GetEntities<T_FM_USER>(t => t.ID == entity.FIRE_USER_ID || t.ID == entity.SAFE_USER_ID, new BaseFilter(entity.ORG_ID)).ToList();
if (sendUser != null && sendUser.Any())
{
var sendUserIds = sendUser.Select(t => t.ID).Distinct().ToList();
var sendUserNames = sendUser.Select(t => t.NAME).Distinct().ToList();
entity.FIRE_STATUS = FOFireStatus.ReadingFinish;
notices = NotificationTaskService.InsertUserNoticeTaskModels("动火作业工作票完工验收", entity.ID, entity.ORG_ID, sendUserIds, sendUserNames, DateTime.Now,
DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO043_SHOWPRINT");
}
else
{
//直接归档
entity.FIRE_STATUS = FOFireStatus.Archived;
}
} }
MFlowPermitService.InsertApprove(serialCode[0], "FO043", param, entity.ID, "FO043_SHOWPRINT", entity.TaskID, true, () => //动火作业人员填写
else if (entity.FIRE_STATUS == FOFireStatus.Sign)
{ {
if (detailFileIds != null && detailFileIds.Any()) //触发给动火部门负责人、安全管理人员、矿调度人员审阅
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_DETAIL_FILE>(detailFileIds); var sendUser = this.GetEntities<T_FM_USER>(t => t.ID == entity.FIRE_USER_ID || t.ID == entity.SAFE_USER_ID || t.ID == entity.DISPATCH_USER_ID, new BaseFilter(entity.ORG_ID)).ToList();
if (detailIds != null && detailIds.Any()) if (sendUser != null && sendUser.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_DETAIL>(detailIds); {
if (userFileIds != null && userFileIds.Any()) var sendUserIds = sendUser.Select(t => t.ID).Distinct().ToList();
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_USER_FILE>(userFileIds); var sendUserNames = sendUser.Select(t => t.NAME).Distinct().ToList();
if (userIds != null && userIds.Any()) entity.FIRE_STATUS = FOFireStatus.Reading;
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_USER>(userIds); notices = NotificationTaskService.InsertUserNoticeTaskModels("动火作业工作票审阅", entity.ID, entity.ORG_ID, sendUserIds, sendUserNames, DateTime.Now,
if (fileIds != null && fileIds.Any()) DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO043_SHOWPRINT");
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_FILE>(fileIds); }
if (fireFileIds != null && fireFileIds.Any()) else
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_FIRE_FILE>(fireFileIds); {
if (monitorFileIds != null && monitorFileIds.Any()) //没有审阅人就触发给监护人填写
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_MONITOR_FILE>(monitorFileIds); var monitorUser = this.GetEntity<T_FM_USER>(t => t.ID == entity.MONITOR_USER_ID);
if (riskIds != null && riskIds.Any()) if (monitorUser != null)
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_RISK>(riskIds); {
if (entity != null) entity.FIRE_STATUS = FOFireStatus.Monitor;
UpdateEntityNoCommit(entity); notices.Add(NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票全程监护", entity.ID, entity.ORG_ID, monitorUser.ID, monitorUser.NAME, DateTime.Now,
if (detailList != null && detailList.Any()) DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO043"));
this.BantchSaveEntityNoCommit(detailList); }
if (detailFileList != null && detailFileList.Any()) else
this.BantchSaveEntityNoCommit(detailFileList); {
if (userList != null && userList.Any()) throw new Exception("监护人不能为空，请联系管理员补充填写");
this.BantchSaveEntityNoCommit(userList); }
if (userFileList != null && userFileList.Any()) }
this.BantchSaveEntityNoCommit(userFileList); }
if (riskList != null && riskList.Any()) else
this.BantchSaveEntityNoCommit(riskList); {
if (monitorFileList != null && monitorFileList.Any()) //触发审批
this.BantchSaveEntityNoCommit(monitorFileList); entity.STATUS = BaseData.Domain.Enums.PF.PFStandardStatus.Approving;
if (fireFileList != null && fireFileList.Any()) entity.FIRE_STATUS = FOFireStatus.Approving;
this.BantchSaveEntityNoCommit(fireFileList); //取审批流水码
if (fileList != null && fileList.Any()) var sysFilter = new SystemCodeFilter();
this.BantchSaveEntityNoCommit(fileList); sysFilter.CodeType = (int)PFCodeRuleType.审批流编码;
}, null, null, null, null, null, "FO043_SHOWPRINT", null, "动火作业工作票", FMTASKTYPE.JobSite); sysFilter.Count = 1;
return true; sysFilter.OrgId = entity.ORG_ID;
var codes = CodeRuleService.NewGenSerial(sysFilter);
var serialCode = codes.Split(new char[] { ',' });
var department = this.GetEntity<T_FM_DEPARTMENT>(t => t.ID == departmentId);
var param = Enum.GetName(typeof(FMDepartmentType), department.DEPARTMENT_TYPE);
if (department.DEPARTMENT_STATUS == 2)
{
param = "公司";
}
MFlowPermitService.InsertApprove(serialCode[0], "FO043", param, entity.ID, "FO043_SHOWPRINT", entity.TaskID, true, () =>
{
if (detailFileIds != null && detailFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_DETAIL_FILE>(detailFileIds);
if (detailIds != null && detailIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_DETAIL>(detailIds);
if (userFileIds != null && userFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_USER_FILE>(userFileIds);
if (userIds != null && userIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_USER>(userIds);
if (fileIds != null && fileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_FILE>(fileIds);
if (fireFileIds != null && fireFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_FIRE_FILE>(fireFileIds);
if (monitorFileIds != null && monitorFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_MONITOR_FILE>(monitorFileIds);
if (riskIds != null && riskIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_RISK>(riskIds);
if (entity != null)
UpdateEntityNoCommit(entity);
if (detailList != null && detailList.Any())
this.BantchSaveEntityNoCommit(detailList);
if (detailFileList != null && detailFileList.Any())
this.BantchSaveEntityNoCommit(detailFileList);
if (userList != null && userList.Any())
this.BantchSaveEntityNoCommit(userList);
if (userFileList != null && userFileList.Any())
this.BantchSaveEntityNoCommit(userFileList);
if (riskList != null && riskList.Any())
this.BantchSaveEntityNoCommit(riskList);
if (monitorFileList != null && monitorFileList.Any())
this.BantchSaveEntityNoCommit(monitorFileList);
if (fireFileList != null && fireFileList.Any())
this.BantchSaveEntityNoCommit(fireFileList);
if (fileList != null && fileList.Any())
this.BantchSaveEntityNoCommit(fileList);
}, null, null, null, null, null, "FO043_SHOWPRINT", null, "动火作业工作票", FMTASKTYPE.JobSite);
return true;
}
} }
this.UnifiedCommit(() => this.UnifiedCommit(() =>
{ {
@ -341,6 +394,100 @@ namespace APT.FO.WebApi.Controllers
this.BantchSaveEntityNoCommit(fireFileList); this.BantchSaveEntityNoCommit(fireFileList);
if (fileList != null && fileList.Any()) if (fileList != null && fileList.Any())
this.BantchSaveEntityNoCommit(fileList); this.BantchSaveEntityNoCommit(fileList);
if (notices != null && notices.Any())
this.BantchSaveEntityNoCommit(notices);
});
return true;
});
}
/// <summary>
/// 部门负责人、安全管理人员审阅
/// </summary>
/// <param name="entity"></param>
/// <returns></returns>
[HttpPost, Route("IdentityUpdate")]
public JsonActionResult<bool> IdentityUpdate([FromBody] T_FO_FIRE_JOB entity)
{
return SafeExecute(() =>
{
var fire = this.GetEntity<T_FO_FIRE_JOB>(entity.ID);
var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
if (entity.TaskID != Guid.Empty)
{
var currTask = GetEntity<T_FM_NOTIFICATION_TASK>(t => t.ID == entity.TaskID);
if (currTask != null)
{
userId = currTask.USER_ID;
}
}
if (fire == null)
{
throw new Exception("未获取到动火作业工作票数据，请联系管理员确认");
}
T_FM_NOTIFICATION_TASK notice = null;
if (fire.FIRE_STATUS == FOFireStatus.Reading)
{
if (fire.FIRE_USER_ID == userId)
{
fire.USER_DEAL_STATUS = FOUserShiftStatusEnum.已处理;
}
if (fire.SAFE_USER_ID == userId)
{
fire.SAFE_DEAL_STATUS = FOUserShiftStatusEnum.已处理;
}
if (fire.DISPATCH_USER_ID == userId)
{
fire.DISPATCH_DEAL_STATUS = FOUserShiftStatusEnum.已处理;
}
if (fire.USER_DEAL_STATUS == FOUserShiftStatusEnum.已处理 && fire.SAFE_DEAL_STATUS == FOUserShiftStatusEnum.已处理 && fire.DISPATCH_DEAL_STATUS == FOUserShiftStatusEnum.已处理)
{
//触发给监护人填写
var monitorUser = this.GetEntity<T_FM_USER>(t => t.ID == fire.MONITOR_USER_ID);
if (monitorUser != null)
{
fire.FIRE_STATUS = FOFireStatus.Monitor;
notice = NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票全程监护", fire.ID, fire.ORG_ID, monitorUser.ID, monitorUser.NAME, DateTime.Now,
DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO043");
}
else
{
throw new Exception("监护人不能为空，请联系管理员补充填写");
}
}
}
else if (fire.FIRE_STATUS == FOFireStatus.ReadingFinish)
{
if (fire.FIRE_USER_ID == userId)
{
fire.USER_DEAL_FINISH_STATUS = FOUserShiftStatusEnum.已处理;
}
if (fire.SAFE_USER_ID == userId)
{
fire.SAFE_DEAL_FINISH_STATUS = FOUserShiftStatusEnum.已处理;
}
if (fire.USER_DEAL_FINISH_STATUS == FOUserShiftStatusEnum.已处理 && fire.SAFE_DEAL_FINISH_STATUS == FOUserShiftStatusEnum.已处理)
{
fire.FIRE_STATUS = FOFireStatus.Archived;
}
}
else
{
throw new Exception("当前非审阅状态，请联系管理员排查");
}
T_FM_NOTIFICATION_TASK task = null;
if (entity.TaskID != Guid.Empty)
{
task = NotificationTaskService.GetTaskFinishModel(entity.TaskID);
task.SOURCE_FORMCODE = "FO043_SHOWPRINT";
}
UnifiedCommit(() =>
{
if (fire != null)
this.UpdateEntityNoCommit(fire);
if (task != null)
this.UpdateEntityNoCommit(task);
if (notice != null)
this.UpdateEntityNoCommit(notice);
}); });
return true; return true;
}); });
@ -381,6 +528,12 @@ namespace APT.FO.WebApi.Controllers
throw new Exception("获取驳回信息失败！"); throw new Exception("获取驳回信息失败！");
var entity = this.GetEntity<T_FO_FIRE_JOB>(model.DATA_ID, new string[] { "Nav_ApplyUser" }); var entity = this.GetEntity<T_FO_FIRE_JOB>(model.DATA_ID, new string[] { "Nav_ApplyUser" });
entity.STATUS = BaseData.Domain.Enums.PF.PFStandardStatus.Rejected; entity.STATUS = BaseData.Domain.Enums.PF.PFStandardStatus.Rejected;
entity.FIRE_STATUS = FOFireStatus.Rejected;
entity.USER_DEAL_STATUS = FOUserShiftStatusEnum.待处理;
entity.USER_DEAL_FINISH_STATUS = FOUserShiftStatusEnum.待处理;
entity.SAFE_DEAL_STATUS = FOUserShiftStatusEnum.待处理;
entity.SAFE_DEAL_FINISH_STATUS = FOUserShiftStatusEnum.待处理;
entity.DISPATCH_DEAL_STATUS = FOUserShiftStatusEnum.待处理;
var persons = this.GetEntities<T_FO_FIRE_JOB_USER>(t => t.FIRE_JOB_ID == model.DATA_ID, new BaseFilter(entity.ORG_ID)); var persons = this.GetEntities<T_FO_FIRE_JOB_USER>(t => t.FIRE_JOB_ID == model.DATA_ID, new BaseFilter(entity.ORG_ID));
if (persons.Any()) if (persons.Any())
persons.ForEach(t => { t.DEAL_STATUS = 0; t.Nav_User = null; }); persons.ForEach(t => { t.DEAL_STATUS = 0; t.Nav_User = null; });

143
APT.MicroApi/APT.FO.WebApi/Controllers/FireJobWbController.cs
View File

@ -7,6 +7,7 @@ using APT.BaseData.Services.DomainServices;
using APT.BaseData.Services.Services.FM; using APT.BaseData.Services.Services.FM;
using APT.Infrastructure.Core; using APT.Infrastructure.Core;
using APT.MS.Domain.Entities.FO; using APT.MS.Domain.Entities.FO;
using APT.MS.Domain.Entities.OG;
using APT.MS.Domain.Enums; using APT.MS.Domain.Enums;
using APT.Utility; using APT.Utility;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
@ -147,7 +148,7 @@ namespace APT.FO.WebApi.Controllers
var userList = new List<T_FO_FIRE_JOB_WB_USER>(); var userList = new List<T_FO_FIRE_JOB_WB_USER>();
if (users != null && users.Any()) if (users != null && users.Any())
{ {
var userTypes = this.GetEntities<T_FO_USER_TYPE>(t => t.NAME == "动火操作人员" || t.NAME == "瓦检员" || t.NAME == "喷水人员", new BaseFilter(entity.ORG_ID)); var userTypes = this.GetEntities<T_OG_RELATED_USER_TYPE>(t => t.NAME == "动火操作人员" || t.NAME == "瓦检员" || t.NAME == "喷水人员", new BaseFilter(entity.ORG_ID));
var userTypeIds = userTypes.Select(m => m.ID).ToList(); var userTypeIds = userTypes.Select(m => m.ID).ToList();
var dhUser = userTypes.FirstOrDefault(t => t.NAME == "动火操作人员"); var dhUser = userTypes.FirstOrDefault(t => t.NAME == "动火操作人员");
if (dhUser == null) if (dhUser == null)
@ -262,62 +263,98 @@ namespace APT.FO.WebApi.Controllers
monitorFileList.Add(item); monitorFileList.Add(item);
} }
} }
List<T_FM_NOTIFICATION_TASK> notices = new List<T_FM_NOTIFICATION_TASK>();
if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify")) if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify"))
{ {
//触发审批 //监护人员填写
entity.STATUS = BaseData.Domain.Enums.PF.PFStandardStatus.Approving; if (entity.FIRE_STATUS == FOFireStatus.Monitor)
entity.FIRE_STATUS = FOFireStatus.Approving;
//取审批流水码
var sysFilter = new SystemCodeFilter();
sysFilter.CodeType = (int)PFCodeRuleType.审批流编码;
sysFilter.Count = 1;
sysFilter.OrgId = entity.ORG_ID;
var codes = CodeRuleService.NewGenSerial(sysFilter);
var serialCode = codes.Split(new char[] { ',' });
var department = this.GetEntity<T_FM_DEPARTMENT>(t => t.ID == departmentId);
var param = Enum.GetName(typeof(FMDepartmentType), department.DEPARTMENT_TYPE);
if (department.DEPARTMENT_STATUS == 2)
{ {
param = "公司"; //外部施工单位，安全员自动置为已审阅
entity.USER_DEAL_FINISH_STATUS = FOUserShiftStatusEnum.已处理;
entity.SAFE_DEAL_FINISH_STATUS = FOUserShiftStatusEnum.已处理;
//直接归档
entity.FIRE_STATUS = FOFireStatus.Archived;
} }
MFlowPermitService.InsertApprove(serialCode[0], "FO045", param, entity.ID, "FO045_SHOWPRINT", entity.TaskID, true, () => //发起人填写
else if (entity.FIRE_STATUS == FOFireStatus.Sign)
{ {
if (detailFileIds != null && detailFileIds.Any()) //外部施工单位，安全员自动置为已审阅
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_DETAIL_FILE>(detailFileIds); entity.USER_DEAL_STATUS = FOUserShiftStatusEnum.已处理;
if (detailIds != null && detailIds.Any()) entity.SAFE_DEAL_STATUS = FOUserShiftStatusEnum.已处理;
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_DETAIL>(detailIds); //触发给监护人员
if (userFileIds != null && userFileIds.Any()) entity.FIRE_STATUS = FOFireStatus.Monitor;
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_USER_FILE>(userFileIds); //触发给监护人填写
if (userIds != null && userIds.Any()) var monitorUser = this.GetEntity<T_FM_USER>(t => t.ID == entity.MONITOR_USER_ID);
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_USER>(userIds); if (monitorUser != null)
if (fileIds != null && fileIds.Any()) {
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_FILE>(fileIds); entity.FIRE_STATUS = FOFireStatus.Monitor;
if (fireFileIds != null && fireFileIds.Any()) notices.Add(NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票全程监护(外包)", entity.ID, entity.ORG_ID, monitorUser.ID, monitorUser.NAME, DateTime.Now,
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_FIRE_FILE>(fireFileIds); DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO045"));
if (monitorFileIds != null && monitorFileIds.Any()) }
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_MONITOR_FILE>(monitorFileIds); else
if (riskIds != null && riskIds.Any()) {
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_RISK>(riskIds); throw new Exception("监护人不能为空，请联系管理员补充填写");
if (entity != null) }
UpdateEntityNoCommit(entity); }
if (detailList != null && detailList.Any()) else
this.BantchSaveEntityNoCommit(detailList); {
if (detailFileList != null && detailFileList.Any()) //触发审批
this.BantchSaveEntityNoCommit(detailFileList); entity.STATUS = BaseData.Domain.Enums.PF.PFStandardStatus.Approving;
if (userList != null && userList.Any()) entity.FIRE_STATUS = FOFireStatus.Approving;
this.BantchSaveEntityNoCommit(userList); //取审批流水码
if (userFileList != null && userFileList.Any()) var sysFilter = new SystemCodeFilter();
this.BantchSaveEntityNoCommit(userFileList); sysFilter.CodeType = (int)PFCodeRuleType.审批流编码;
if (riskList != null && riskList.Any()) sysFilter.Count = 1;
this.BantchSaveEntityNoCommit(riskList); sysFilter.OrgId = entity.ORG_ID;
if (monitorFileList != null && monitorFileList.Any()) var codes = CodeRuleService.NewGenSerial(sysFilter);
this.BantchSaveEntityNoCommit(monitorFileList); var serialCode = codes.Split(new char[] { ',' });
if (fireFileList != null && fireFileList.Any()) var department = this.GetEntity<T_FM_DEPARTMENT>(t => t.ID == departmentId);
this.BantchSaveEntityNoCommit(fireFileList); var param = Enum.GetName(typeof(FMDepartmentType), department.DEPARTMENT_TYPE);
if (fileList != null && fileList.Any()) if (department.DEPARTMENT_STATUS == 2)
this.BantchSaveEntityNoCommit(fileList); {
}, null, null, null, null, null, "FO045_SHOWPRINT", null, "动火作业工作票(外包)", FMTASKTYPE.JobSite); param = "公司";
return true; }
MFlowPermitService.InsertApprove(serialCode[0], "FO045", param, entity.ID, "FO045_SHOWPRINT", entity.TaskID, true, () =>
{
if (detailFileIds != null && detailFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_DETAIL_FILE>(detailFileIds);
if (detailIds != null && detailIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_DETAIL>(detailIds);
if (userFileIds != null && userFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_USER_FILE>(userFileIds);
if (userIds != null && userIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_USER>(userIds);
if (fileIds != null && fileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_FILE>(fileIds);
if (fireFileIds != null && fireFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_FIRE_FILE>(fireFileIds);
if (monitorFileIds != null && monitorFileIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_MONITOR_FILE>(monitorFileIds);
if (riskIds != null && riskIds.Any())
this.BantchDeleteEntityNoCommit<T_FO_FIRE_JOB_WB_RISK>(riskIds);
if (entity != null)
UpdateEntityNoCommit(entity);
if (detailList != null && detailList.Any())
this.BantchSaveEntityNoCommit(detailList);
if (detailFileList != null && detailFileList.Any())
this.BantchSaveEntityNoCommit(detailFileList);
if (userList != null && userList.Any())
this.BantchSaveEntityNoCommit(userList);
if (userFileList != null && userFileList.Any())
this.BantchSaveEntityNoCommit(userFileList);
if (riskList != null && riskList.Any())
this.BantchSaveEntityNoCommit(riskList);
if (monitorFileList != null && monitorFileList.Any())
this.BantchSaveEntityNoCommit(monitorFileList);
if (fireFileList != null && fireFileList.Any())
this.BantchSaveEntityNoCommit(fireFileList);
if (fileList != null && fileList.Any())
this.BantchSaveEntityNoCommit(fileList);
}, null, null, null, null, null, "FO045_SHOWPRINT", null, "动火作业工作票(外包)", FMTASKTYPE.JobSite);
return true;
}
} }
this.UnifiedCommit(() => this.UnifiedCommit(() =>
{ {
@ -355,6 +392,8 @@ namespace APT.FO.WebApi.Controllers
this.BantchSaveEntityNoCommit(fireFileList); this.BantchSaveEntityNoCommit(fireFileList);
if (fileList != null && fileList.Any()) if (fileList != null && fileList.Any())
this.BantchSaveEntityNoCommit(fileList); this.BantchSaveEntityNoCommit(fileList);
if (notices != null && notices.Any())
this.BantchSaveEntityNoCommit(notices);
}); });
return true; return true;
}); });

56
APT.MicroApi/APT.PP.WebApi/Controllers/Api/FOController.cs
View File

@ -1,28 +1,29 @@
using APT.BaseData.Domain.Entities.FM; using APT.BaseData.Domain.ApiModel;
using APT.BaseData.Domain.Enums;
using APT.BaseData.Domain.Entities; using APT.BaseData.Domain.Entities;
using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Domain.Enums;
using APT.BaseData.Domain.IServices; using APT.BaseData.Domain.IServices;
using APT.BaseData.Domain.IServices.FM;
using APT.BaseData.Services.DomainServices;
using APT.Infrastructure.Core; using APT.Infrastructure.Core;
using APT.MS.Domain.Entities.FO; using APT.MS.Domain.Entities.FO;
using APT.MS.Domain.Entities.HM;
using APT.MS.Domain.Entities.OG;
using APT.MS.Domain.Enums;
using APT.Utility; using APT.Utility;
using APT.WebApi.Models;
using Castle.Core.Internal;
using InfluxData.Net.InfluxDb.Models.Responses;
using log4net.Filter;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Microsoft.VisualBasic;
using NPOI.SS.Formula.Functions;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using APT.BaseData.Domain.IServices.FM;
using APT.MS.Domain.Enums;
using APT.MS.Domain.Entities.HM;
using InfluxData.Net.InfluxDb.Models.Responses;
using NPOI.SS.Formula.Functions;
using APT.BaseData.Services.DomainServices;
using log4net.Filter;
using Castle.Core.Internal;
using APT.WebApi.Models;
using static Microsoft.AspNetCore.Razor.Language.TagHelperMetadata;
using APT.BaseData.Domain.ApiModel;
using System.Numerics; using System.Numerics;
using Microsoft.VisualBasic; using static Microsoft.AspNetCore.Razor.Language.TagHelperMetadata;
using Microsoft.Extensions.Logging;
namespace APT.PP.WebApi.Controllers.Api.PP namespace APT.PP.WebApi.Controllers.Api.PP
{ {
@ -1911,15 +1912,18 @@ namespace APT.PP.WebApi.Controllers.Api.PP
try try
{ {
var notices = new List<T_FM_NOTIFICATION_TASK>(); var notices = new List<T_FM_NOTIFICATION_TASK>();
var dt = DateTime.Now.AddMinutes(-30); var dt = DateTime.Now.AddMinutes(-60);
var userType = this.GetEntity<T_FO_USER_TYPE>(t => t.NAME == "动火操作人员"); var dtEnd = DateTime.Now.AddMinutes(-30);
var userType = this.GetEntity<T_OG_RELATED_USER_TYPE>(t => t.NAME == "动火操作人员");
var steps = this.GetEntities<T_HM_OPERATION_STEP>(t =>t.IS_DELETED ==false, new BaseFilter(filter.OrgId)); var steps = this.GetEntities<T_HM_OPERATION_STEP>(t =>t.IS_DELETED ==false, new BaseFilter(filter.OrgId));
var users = this.GetEntities<T_FM_USER>(t => t.ENABLE_STATUS == 0 && !t.CODE.Contains("admin"), new BaseFilter(filter.OrgId)); var users = this.GetEntities<T_FM_USER>(t => t.ENABLE_STATUS == 0 && !t.CODE.Contains("admin"), new BaseFilter(filter.OrgId));
var jobs = this.GetEntities<T_FO_FIRE_JOB>(t => t.STATUS == BaseData.Domain.Enums.PF.PFStandardStatus.Archived && t.JOB_DATE <= dt, new BaseFilter(filter.OrgId), "Nav_Users"); var jobs = this.GetEntities<T_FO_FIRE_JOB>(t => t.STATUS == BaseData.Domain.Enums.PF.PFStandardStatus.Archived && t.JOB_DATE >= dt && t.JOB_DATE <= dtEnd && t.IS_RUN == false, new BaseFilter(filter.OrgId), "Nav_Users");
if (userType!=null &&jobs != null && jobs.Any()) if (userType!=null &&jobs != null && jobs.Any())
{ {
foreach (var item in jobs) foreach (var item in jobs)
{ {
item.IS_RUN = true;
item.FIRE_STATUS = FOFireStatus.Sign;
var step = steps.FirstOrDefault(t => t.ID == item.OPERATION_STEP_ID); var step = steps.FirstOrDefault(t => t.ID == item.OPERATION_STEP_ID);
if (item.Nav_Users != null && item.Nav_Users.Any()) if (item.Nav_Users != null && item.Nav_Users.Any())
{ {
@ -1927,30 +1931,38 @@ namespace APT.PP.WebApi.Controllers.Api.PP
if (sendUser != null) if (sendUser != null)
{ {
var userName = users.FirstOrDefault(t => t.ID == sendUser.USER_ID)?.NAME; var userName = users.FirstOrDefault(t => t.ID == sendUser.USER_ID)?.NAME;
var notice = NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票" + step?.NAME, item.ID, item.ORG_ID, (Guid)sendUser.USER_ID, userName, DateTime.Now, var notice = NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票现场验收" + step?.NAME, item.ID, item.ORG_ID, (Guid)sendUser.USER_ID, userName, DateTime.Now,
DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO043"); DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO043");
notices.Add(notice); notices.Add(notice);
} }
} }
} }
} }
var jobWbs = this.GetEntities<T_FO_FIRE_JOB_WB>(t => t.STATUS == BaseData.Domain.Enums.PF.PFStandardStatus.Archived && t.JOB_DATE <= dt, new BaseFilter(filter.OrgId), "Nav_Users"); var jobWbs = this.GetEntities<T_FO_FIRE_JOB_WB>(t => t.STATUS == BaseData.Domain.Enums.PF.PFStandardStatus.Archived && t.JOB_DATE >= dt && t.JOB_DATE <= dtEnd && t.IS_RUN == false, new BaseFilter(filter.OrgId), "Nav_Users");
if (userType != null && jobWbs != null && jobWbs.Any()) if (userType != null && jobWbs != null && jobWbs.Any())
{ {
foreach (var item in jobs) foreach (var item in jobWbs)
{ {
item.IS_RUN = true;
item.FIRE_STATUS = FOFireStatus.Sign;
var step = steps.FirstOrDefault(t => t.ID == item.OPERATION_STEP_ID); var step = steps.FirstOrDefault(t => t.ID == item.OPERATION_STEP_ID);
if (item.APPLY_USER_ID != null ) if (item.APPLY_USER_ID != null )
{ {
var userName = users.FirstOrDefault(t => t.ID == item.APPLY_USER_ID)?.NAME; var userName = users.FirstOrDefault(t => t.ID == item.APPLY_USER_ID)?.NAME;
var notice = NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票(外包)" + step?.NAME, item.ID, item.ORG_ID, (Guid)item.APPLY_USER_ID, userName, DateTime.Now, var notice = NotificationTaskService.InsertUserNoticeTaskModel("动火作业工作票现场验收(外包)" + step?.NAME, item.ID, item.ORG_ID, (Guid)item.APPLY_USER_ID, userName, DateTime.Now,
DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO045"); DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "FO045");
notices.Add(notice); notices.Add(notice);
} }
} }
} }
jobs.ForEach(t => t.Nav_Users = null);
jobWbs.ForEach(t => t.Nav_Users = null);
UnifiedCommit(() => UnifiedCommit(() =>
{ {
if (jobs != null && jobs.Any())
BantchSaveEntityNoCommit(jobs);
if (jobWbs != null && jobWbs.Any())
BantchSaveEntityNoCommit(jobWbs);
if (notices != null && notices.Any()) if (notices != null && notices.Any())
BantchSaveEntityNoCommit(notices); BantchSaveEntityNoCommit(notices);
}); });