From 9d2218f786abccbaacaa9fc1e2c5d46bf2b7c18f Mon Sep 17 00:00:00 2001 From: wjn Date: Wed, 10 Apr 2024 15:03:00 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ChangeShiftRecordController.cs | 2 +- .../Controllers/TeamActivityController.cs | 45 +++-- .../Controllers/Api/HazardTaskController.cs | 25 ++- .../Controllers/Api/RiskTaskController.cs | 167 +++++++++--------- .../SEController/5SETTrainNotifyController.cs | 2 +- .../Api/SEController/SETestController.cs | 1 - 6 files changed, 128 insertions(+), 114 deletions(-) diff --git a/APT.MicroApi/APT.FO.WebApi/Controllers/ChangeShiftRecordController.cs b/APT.MicroApi/APT.FO.WebApi/Controllers/ChangeShiftRecordController.cs index 7d35bb1..2ea9fba 100644 --- a/APT.MicroApi/APT.FO.WebApi/Controllers/ChangeShiftRecordController.cs +++ b/APT.MicroApi/APT.FO.WebApi/Controllers/ChangeShiftRecordController.cs @@ -44,7 +44,7 @@ namespace APT.FO.WebApi.Controllers.Api.FO throw new Exception("对应岗位人员已填写，请刷新确认!"); } var userID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID; - var afterUsers = entity.Nav_AfterUsers; + var afterUsers = entity.Nav_AfterUsers.Where(t=>t.IS_DELETED==false); if (afterUsers.Count() == 0) { throw new Exception("请选择接班人员!"); diff --git a/APT.MicroApi/APT.FO.WebApi/Controllers/TeamActivityController.cs b/APT.MicroApi/APT.FO.WebApi/Controllers/TeamActivityController.cs index 0bc63b4..5a26eeb 100644 --- a/APT.MicroApi/APT.FO.WebApi/Controllers/TeamActivityController.cs +++ b/APT.MicroApi/APT.FO.WebApi/Controllers/TeamActivityController.cs @@ -92,10 +92,10 @@ namespace APT.FO.WebApi.Controllers.Api.FO if (entity != null && entity.OpType == 0) { - if (files==null||files.Count()==0) - { - throw new Exception("请上传附件!"); - } + if (files == null || files.Count() == 0) + { + throw new Exception("请上传附件!"); + } //通知参会人员签到 var userID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID; var baseFilter = new BaseFilter(entity.ORG_ID); @@ -154,7 +154,25 @@ namespace APT.FO.WebApi.Controllers.Api.FO return true; }); } + /// + /// 更新--已阅 + /// + [HttpPost, Route("TeamActivityUserRead")] + public JsonActionResult TeamActivityUserRead([FromBody] T_FO_TEAM_ACTIVITY entity) + { + return SafeExecute(() => + { + if (entity.TaskID == Guid.Empty) + { + throw new Exception("没有待办任务ID,请刷新重试!"); + } + NotificationTaskService.NotificationTaskFinish(entity.TaskID, () => + { + }); + return true; + }); + } /// /// 更新--保存签到 /// @@ -204,25 +222,6 @@ namespace APT.FO.WebApi.Controllers.Api.FO }); } /// - /// 更新--已阅 - /// - [HttpPost, Route("TeamActivityUserRead")] - public JsonActionResult TeamActivityUserRead([FromBody] T_FO_TEAM_ACTIVITY entity) - { - return SafeExecute(() => - { - if (entity.TaskID == Guid.Empty) - { - throw new Exception("没有待办任务ID,请刷新重试!"); - } - NotificationTaskService.NotificationTaskFinish(entity.TaskID, () => - { - - }); - return true; - }); - } - /// /// 排序分页查询数据 /// /// 分页过滤实体 diff --git a/APT.MicroApi/APT.HM.WebApi/Controllers/Api/HazardTaskController.cs b/APT.MicroApi/APT.HM.WebApi/Controllers/Api/HazardTaskController.cs index 8de8ad4..40f53c1 100644 --- a/APT.MicroApi/APT.HM.WebApi/Controllers/Api/HazardTaskController.cs +++ b/APT.MicroApi/APT.HM.WebApi/Controllers/Api/HazardTaskController.cs @@ -76,7 +76,7 @@ namespace APT.HM.WebApi.Controllers.Api detail.Nav_Identifyings = null; } }); - if (entity.LIABLE_USER_ID == Guid.Empty||entity.LIABLE_USER_ID==null) + if (entity.LIABLE_USER_ID == Guid.Empty || entity.LIABLE_USER_ID == null) { entity.LIABLE_USER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID; } @@ -97,18 +97,27 @@ namespace APT.HM.WebApi.Controllers.Api entity.APPROVECODE = null; //是否需要发审批流，false不发，true的时候默认只发当前审核人 var isSendApprove = false; - var isFinish = Guid.Empty; + //var isFinish = Guid.Empty; + T_FM_NOTIFICATION_TASK task = null; if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify")) { entity.STATUS = FOPreMeetingStatusEnum.审核中; isSendApprove = true; entity.APPROVECODE = DateTime.Now.ToString("yyyyMMddHHmmss"); - isFinish = entity.TaskID; + //isFinish = entity.TaskID; + if (entity.TaskID != Guid.Empty) + { + task = NotificationTaskService.GetEntityTask(entity.TaskID, "HM101_SHOWPRINT"); + if (task.SOURCE_DATA_ID == null) + task.SOURCE_DATA_ID = entity.ID; + } } - MFlowPermitService.InsertApprove(entity.APPROVECODE, "HM102", null, entity.ID, "HM101_SHOWPRINT", isFinish, isSendApprove, () => + MFlowPermitService.InsertApprove(entity.APPROVECODE, "HM102", null, entity.ID, "HM101_SHOWPRINT", null, isSendApprove, () => { if (entity != null) UpdateEntityNoCommit(entity); //保存主表 + if (task != null) + UpdateEntityNoCommit(task); if (files != null && files.Any()) BantchSaveEntityNoCommit(files); //保存子表 if (riskDetail != null && riskDetail.Any()) @@ -234,10 +243,10 @@ namespace APT.HM.WebApi.Controllers.Api hazardRecord.ORG_ID = orgId; hazardRecord.LIABLE_USER_ID = entity.LIABLE_USER_ID; hazardRecord.PLAN_ID = entity.PLAN_ID; - hazardRecord.AREAS = string.Join("、", entity.Nav_Areas.Select(t => t.Nav_Area.NAME)); + hazardRecord.AREAS = string.Join("、", entity.Nav_Areas.Select(t => t.Nav_Area.NAME)); hazardRecord.IDENTIFYINGS = string.Join("、", entity.Nav_Identifyings.Select(t => t.Nav_Identifying.NAME)); hazardRecords.Add(hazardRecord); - noticeTitles.Add("职业危害辨识记录"+DateTime.Now.ToShortDateString()); + noticeTitles.Add("职业危害辨识记录" + DateTime.Now.ToShortDateString()); noticeUserIds.Add((Guid)userID); noticeUserNames.Add(currDetail.FirstOrDefault().Nav_User.NAME); noticeDataIds.Add(hazardRecord.ID); @@ -249,7 +258,7 @@ namespace APT.HM.WebApi.Controllers.Api var dangerDB = this.GetEntities(t => areaList.Contains((Guid)t.AREA_ID) && t.STATUS == (int)HMOperationStepEnum.有效, baseFilter); foreach (var detail in currDetail) { - var dangerDBAreas = dangerDB.Where(t => t.AREA_ID == detail.AREA_ID&& detail.Nav_Identifyings.Select(x=>x.ID).Contains(t.IDENTIFYING_ID)); + var dangerDBAreas = dangerDB.Where(t => t.AREA_ID == detail.AREA_ID && detail.Nav_Identifyings.Select(x => x.ID).Contains(t.IDENTIFYING_ID)); if (dangerDBAreas.Any()) { foreach (var danger in dangerDBAreas) @@ -311,7 +320,7 @@ namespace APT.HM.WebApi.Controllers.Api } if (model.TaskID != null) { - finishNotice = NotificationTaskService.FOGetTaskFinishModel(model.TaskID,model.ID); + finishNotice = NotificationTaskService.FOGetTaskFinishModel(model.TaskID, model.ID); } UnifiedCommit(() => { diff --git a/APT.MicroApi/APT.HM.WebApi/Controllers/Api/RiskTaskController.cs b/APT.MicroApi/APT.HM.WebApi/Controllers/Api/RiskTaskController.cs index db32d8b..6497c6a 100644 --- a/APT.MicroApi/APT.HM.WebApi/Controllers/Api/RiskTaskController.cs +++ b/APT.MicroApi/APT.HM.WebApi/Controllers/Api/RiskTaskController.cs @@ -44,104 +44,111 @@ namespace APT.HM.WebApi.Controllers.Api [HttpPost, Route("FullUpdate")] public JsonActionResult FullUpdate([FromBody] T_HM_RISK_TASK entity) { + return SafeExecute(() => { - return SafeExecute(() => + var files = entity.Nav_Files; + var riskDetail = entity.Nav_Detail; + var identifyings = entity.Nav_Identifyings; + if (identifyings.Count == 0) { - var files = entity.Nav_Files; - var riskDetail = entity.Nav_Detail; - var identifyings = entity.Nav_Identifyings; - if (identifyings.Count == 0) + throw new Exception("请选择辨识对象!"); + } + var areas = entity.Nav_Areas; + List users = new List(); + foreach (var detail in riskDetail) + { + if (detail.AREA_ID == Guid.Empty || detail.AREA_ID == null) { - throw new Exception("请选择辨识对象!"); + throw new Exception("请填写区域!"); } - var areas = entity.Nav_Areas; - List users = new List(); - foreach (var detail in riskDetail) + if (detail.RECORD_USER_ID == Guid.Empty || detail.AREA_ID == null) { - if (detail.AREA_ID == Guid.Empty || detail.AREA_ID == null) + throw new Exception("请选择记录人员!"); + } + if (detail.Nav_Users != null) + { + detail.Nav_Users.ForEach(user => { - throw new Exception("请填写区域!"); - } - if (detail.RECORD_USER_ID == Guid.Empty || detail.AREA_ID == null) - { - throw new Exception("请选择记录人员!"); - } - if (detail.Nav_Users != null) - { - detail.Nav_Users.ForEach(user => + if (user.USER_ID != detail.RECORD_USER_ID) { - if (user.USER_ID != detail.RECORD_USER_ID) - { - user.ROW_NO = 999; - } - }); - users.AddRange(detail.Nav_Users); - detail.Nav_Users = null; - } - }; - if (entity.LIABLE_USER_ID == Guid.Empty || entity.LIABLE_USER_ID == null) - { - entity.LIABLE_USER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID; + user.ROW_NO = 999; + } + }); + users.AddRange(detail.Nav_Users); + detail.Nav_Users = null; } - entity.Nav_Files = null; - entity.Nav_Detail = null; - entity.Nav_Identifyings = null; - entity.Nav_Areas = null; - identifyings?.ForEach(identifying => { identifying.Nav_Identifying = null; identifying.Nav_Task = null; }); - areas?.ForEach(areas => { areas.Nav_Area = null; areas.Nav_Task = null; }); + }; + if (entity.LIABLE_USER_ID == Guid.Empty || entity.LIABLE_USER_ID == null) + { + entity.LIABLE_USER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID; + } + entity.Nav_Files = null; + entity.Nav_Detail = null; + entity.Nav_Identifyings = null; + entity.Nav_Areas = null; + identifyings?.ForEach(identifying => { identifying.Nav_Identifying = null; identifying.Nav_Task = null; }); + areas?.ForEach(areas => { areas.Nav_Area = null; areas.Nav_Task = null; }); - if (entity.INITIATING_DEPARTMENT == null) - { - var user = GetEntity(t => t.ID == APT.Infrastructure.Api.AppContext.CurrentSession.UserID); - if (user != null) - entity.INITIATING_DEPARTMENT = user.DEPARTMENT_ID; - } - var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId; - entity.STATUS = FOPreMeetingStatusEnum.草稿; - entity.APPROVECODE = null; + if (entity.INITIATING_DEPARTMENT == null) + { + var user = GetEntity(t => t.ID == APT.Infrastructure.Api.AppContext.CurrentSession.UserID); + if (user != null) + entity.INITIATING_DEPARTMENT = user.DEPARTMENT_ID; + } + var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId; + entity.STATUS = FOPreMeetingStatusEnum.草稿; + entity.APPROVECODE = null; //是否需要发审批流，false不发，true的时候默认只发当前审核人 var isSendApprove = false; - var isFinish = Guid.Empty; - if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify")) + //var isFinish = Guid.Empty; + T_FM_NOTIFICATION_TASK task = null; + if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify")) + { + entity.STATUS = FOPreMeetingStatusEnum.审核中; + isSendApprove = true; + entity.APPROVECODE = DateTime.Now.ToString("yyyyMMddHHmmss"); + //isFinish = entity.TaskID; + if (entity.TaskID != Guid.Empty) { - entity.STATUS = FOPreMeetingStatusEnum.审核中; - isSendApprove = true; - entity.APPROVECODE = DateTime.Now.ToString("yyyyMMddHHmmss"); - isFinish = entity.TaskID; + task = NotificationTaskService.GetEntityTask(entity.TaskID, "HM061_SHOWPRINT"); + if (task.SOURCE_DATA_ID == null) + task.SOURCE_DATA_ID = entity.ID; } - var param = ""; + } + var param = ""; //0908 修改按最高层级触发审批 if (entity.LEVEL.Contains("3")) - { - param = "GS"; - } - else if (entity.LEVEL.Contains("0")) - { - param = "BM"; - } - else - { - param = "CJ"; - } + { + param = "GS"; + } + else if (entity.LEVEL.Contains("0")) + { + param = "BM"; + } + else + { + param = "CJ"; + } - MFlowPermitService.InsertApprove(entity.APPROVECODE, "HM062", param, entity.ID, "HM061_SHOWPRINT", isFinish, isSendApprove, () => - { - if (entity != null) - UpdateEntityNoCommit(entity); //保存主表 - if (files != null && files.Any()) - BantchSaveEntityNoCommit(files); //保存子表 + MFlowPermitService.InsertApprove(entity.APPROVECODE, "HM062", param, entity.ID, "HM061_SHOWPRINT", null, isSendApprove, () => + { + if (entity != null) + UpdateEntityNoCommit(entity); //保存主表 + if (task != null) + UpdateEntityNoCommit(task); + if (files != null && files.Any()) + BantchSaveEntityNoCommit(files); //保存子表 if (identifyings != null && identifyings.Any()) - BantchSaveEntityNoCommit(identifyings); - if (riskDetail != null && riskDetail.Any()) - BantchSaveEntityNoCommit(riskDetail); - if (areas != null && areas.Any()) - BantchSaveEntityNoCommit(areas); - if (users.Any()) - BantchSaveEntityNoCommit(users); //保存孙表 + BantchSaveEntityNoCommit(identifyings); + if (riskDetail != null && riskDetail.Any()) + BantchSaveEntityNoCommit(riskDetail); + if (areas != null && areas.Any()) + BantchSaveEntityNoCommit(areas); + if (users.Any()) + BantchSaveEntityNoCommit(users); //保存孙表 }); - return true; - }); - } + return true; + }); } /// diff --git a/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/5SETTrainNotifyController.cs b/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/5SETTrainNotifyController.cs index 3e4353c..5730953 100644 --- a/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/5SETTrainNotifyController.cs +++ b/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/5SETTrainNotifyController.cs @@ -46,7 +46,7 @@ namespace APT.SC.WebApi.Controllers.Api.SE throw new Exception("通知发送，不可更改"); } var Nav_TrainContentList = entity.Nav_TrainContentList; - if (Nav_TrainContentList.Count()==0) + if (Nav_TrainContentList.Count()==0) { throw new Exception("请选择培训内容"); } diff --git a/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/SETestController.cs b/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/SETestController.cs index d2e02d9..8906473 100644 --- a/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/SETestController.cs +++ b/APT.MicroApi/APT.SC.WebApi/Controllers/Api/SEController/SETestController.cs @@ -8,7 +8,6 @@ using System.Collections.Generic; using System.Linq; using APT.Infrastructure.Core; using APT.BaseData.Domain.ApiModel; - using System.Data; using System.IO; using APT.BaseData.Domain.Entities.FM;