259 lines
12 KiB
C#
259 lines
12 KiB
C#
using APT.BaseData.Domain.Entities;
|
|
using APT.BaseData.Domain.Entities.FM;
|
|
using APT.BaseData.Domain.Enums;
|
|
using APT.BaseData.Domain.Enums.PF;
|
|
using APT.BaseData.Domain.IServices;
|
|
using APT.BaseData.Domain.IServices.FM;
|
|
using APT.Infrastructure.Core;
|
|
using APT.MS.Domain.Entities.HM;
|
|
using APT.MS.Domain.Enums;
|
|
using APT.Utility;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
|
|
namespace APT.HM.WebApi.Controllers.Api
|
|
{
|
|
[Route("api/HM/HMHazardRecord")]
|
|
public partial class HazardRecordController : AuthorizeApiController<T_HM_HAZARD_RECORD>
|
|
{
|
|
IFMNotificationTaskService NotificationTaskService { get; set; }
|
|
IFMFlowPermitService MFlowPermitService { get; set; }
|
|
IPFApproveCallBackService ApproveCallBackService { get; set; }
|
|
/// <summary>
|
|
/// 作业任务分析
|
|
/// </summary>
|
|
public HazardRecordController(IFMNotificationTaskService notificationTaskService, IFMFlowPermitService mFlowPermitService, IPFApproveCallBackService approveCallBackService)
|
|
{
|
|
NotificationTaskService = notificationTaskService;
|
|
MFlowPermitService = mFlowPermitService;
|
|
ApproveCallBackService = approveCallBackService;
|
|
}
|
|
/// <summary>
|
|
/// 更新
|
|
/// </summary>
|
|
/// <param name="entity"></param>
|
|
/// <returns></returns>
|
|
[HttpPost, Route("FullUpdate")]
|
|
public JsonActionResult<bool> FullUpdate([FromBody] T_HM_HAZARD_RECORD entity)
|
|
{
|
|
return SafeExecute<bool>(() =>
|
|
{
|
|
var users = entity.Nav_Users;
|
|
var files = entity.Nav_Files;
|
|
var details = entity.Nav_Details;
|
|
entity.Nav_Users = null;
|
|
entity.Nav_Files = null;
|
|
entity.Nav_Details = null;
|
|
List<T_FM_NOTIFICATION_TASK> sendNotices = null;
|
|
T_FM_NOTIFICATION_TASK finishNotice = null;
|
|
if (entity.PUBLISH != null && entity.PUBLISH.Equals("SaveAndNotify"))
|
|
{
|
|
entity.STATUS = FOPreMeetingStatusEnum.签到中;
|
|
var noticeTitles = new List<string>();
|
|
var noticeUserIds = new List<Guid>();
|
|
var noticeUserNames = new List<string>();
|
|
var noticeDataIds = new List<Guid>();
|
|
var userDeal = users.Where(t => t.DEAL_STATUS == FOUserShiftStatusEnum.待处理);
|
|
if (userDeal.Count() > 0)
|
|
{
|
|
var allusers = GetEntities<T_FM_USER>(null, new BaseFilter(entity.ORG_ID));
|
|
var allsendUsers = users.Where(t => t.DEAL_STATUS == FOUserShiftStatusEnum.待处理).Select(t => t.USER_ID).Distinct();
|
|
foreach (var user in allsendUsers)
|
|
{
|
|
var userName = allusers.Where(t => t.ID == user).FirstOrDefault();
|
|
noticeUserIds.Add(user);
|
|
noticeUserNames.Add(userName.NAME);
|
|
noticeTitles.Add("职业危害辨识记录待确认");
|
|
noticeDataIds.Add(entity.ID);
|
|
}
|
|
sendNotices = NotificationTaskService.InsertUserNoticeTaskModels(noticeTitles, noticeDataIds, entity.ORG_ID, noticeUserIds, noticeUserNames, DateTime.Now, DateTime.Parse(DateTime.Now.AddDays(1).ToShortDateString() + " 23:59:59"), 1, "HM099_SHOWPRINT");
|
|
finishNotice = NotificationTaskService.FOGetTaskFinishModel(entity.TaskID, entity.ID, "HM099_SHOWPRINT");
|
|
}
|
|
else
|
|
{
|
|
entity.STATUS = FOPreMeetingStatusEnum.审核中;
|
|
entity.APPROVECODE = DateTime.Now.ToString("yyyyMMddHHmmss");
|
|
MFlowPermitService.InsertApprove(entity.APPROVECODE, "HM100", "", entity.ID, "HM099_SHOWPRINT", entity.TaskID, true, () =>
|
|
{
|
|
}, null, entity.NOTE_TAKER_ID,null, null, null, "HM099_SHOWPRINT");
|
|
}
|
|
}
|
|
this.UnifiedCommit(() =>
|
|
{
|
|
if (entity != null)
|
|
UpdateEntityNoCommit(entity); //保存主表
|
|
if (users != null && users.Any())
|
|
BantchSaveEntityNoCommit(users); //保存子表
|
|
if (files != null && files.Any())
|
|
BantchSaveEntityNoCommit(files); //保存子表
|
|
if (details != null && details.Any())
|
|
BantchSaveEntityNoCommit(details); //保存子表
|
|
if (sendNotices != null && sendNotices.Any())
|
|
BantchSaveEntityNoCommit(sendNotices);
|
|
if (finishNotice != null)
|
|
UpdateEntityNoCommit(finishNotice);
|
|
});
|
|
return true;
|
|
});
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取个人的风险记录
|
|
/// </summary>
|
|
/// <param name="pageFilter"></param>
|
|
/// <returns></returns>
|
|
[HttpPost, Route("GetHazardRecord")]
|
|
public JsonActionResult<bool> GetHazardRecord([FromBody] T_HM_HAZARD_RECORD entity)
|
|
{
|
|
return SafeExecute<bool>(() =>
|
|
{
|
|
var model = GetEntity<T_HM_HAZARD_RECORD>(entity.ID.ToString());
|
|
if (model.STATUS != FOPreMeetingStatusEnum.签到中)
|
|
return false;
|
|
var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
|
|
var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
|
var count = GetCount<T_HM_HAZARD_RECORD_USER>(t => t.RECORD_ID == entity.ID && t.USER_ID == userId && t.DEAL_STATUS == 0, new BaseFilter());
|
|
if (count > 0) //该用户在该记录中是否参与且未同意则显示同意按钮
|
|
{
|
|
return true;
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
});
|
|
}
|
|
|
|
/// <summary>
|
|
/// 同意
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpPost, Route("PersonalAgree")]
|
|
public JsonActionResult<bool> PersonalAgree([FromBody] T_HM_HAZARD_RECORD entity)
|
|
{
|
|
return SafeExecute<bool>(() =>
|
|
{
|
|
var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
|
|
var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
|
var taskId = entity.TaskID;
|
|
var recordUsers = GetEntities<T_HM_HAZARD_RECORD_USER>(t => t.RECORD_ID == entity.ID, new BaseFilter(orgId));
|
|
var currUsers = recordUsers.Where(t => t.USER_ID == userId);
|
|
foreach (var user in currUsers)
|
|
{
|
|
user.DEAL_STATUS = FOUserShiftStatusEnum.已处理;
|
|
user.MODIFY_TIME = DateTime.Now;
|
|
}
|
|
var todoCount = recordUsers.Count(t => t.DEAL_STATUS == 0);
|
|
#region 判断是否全部人员同意
|
|
if (todoCount == 0)
|
|
{
|
|
entity = GetEntity<T_HM_HAZARD_RECORD>(entity.ID.ToString());
|
|
entity.STATUS = FOPreMeetingStatusEnum.审核中;
|
|
#region 提交风险记录审批
|
|
MFlowPermitService.InsertApprove(DateTime.Now.ToString("yyyyMMddHHmmss"), "HM100", "", entity.ID, "HM099_SHOWPRINT", taskId, true, () =>
|
|
{
|
|
if (currUsers != null)
|
|
BantchUpdateEntityNoCommit(currUsers, "DEAL_STATUS", "MODIFY_TIME");
|
|
if (entity != null)
|
|
UpdateEntityNoCommit(entity, "STATUS");
|
|
}, null, entity.LIABLE_USER_ID);
|
|
#endregion
|
|
}
|
|
else
|
|
{
|
|
NotificationTaskService.NotificationTaskFinish(taskId, () =>
|
|
{
|
|
if (currUsers != null)
|
|
BantchUpdateEntityNoCommit(currUsers, "DEAL_STATUS", "MODIFY_TIME");
|
|
});
|
|
}
|
|
#endregion
|
|
return true;
|
|
});
|
|
}
|
|
/// <summary>
|
|
/// 审批流回调
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpGet, Route("PersonalApprove")]
|
|
public JsonActionResult<bool> PersonalApprove(string id)
|
|
{
|
|
return SafeExecute<bool>(() =>
|
|
{
|
|
return ApproveCallBackService.CallBack("HM/HMHazardRecord/PersonalApprove", id);
|
|
});
|
|
}
|
|
/// <summary>
|
|
/// 审批流回调
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpPost, Route("RejectUpdate")]
|
|
public JsonActionResult<bool> RejectUpdate([FromBody] T_PF_APPROVE entity)
|
|
{
|
|
return SafeExecute<bool>(() =>
|
|
{
|
|
T_PF_APPROVE modelApp = null;
|
|
List<T_PF_APPROVE_DETAIL> listAppDetail = null;
|
|
T_FM_NOTIFICATION_TASK taskFinish = null;
|
|
string Msg = string.Empty;
|
|
var record = GetEntity<T_HM_HAZARD_RECORD>(entity.DATA_ID, new string[] { "Nav_NoteTaker" });
|
|
var recordUsers = GetEntities<T_HM_HAZARD_RECORD_USER>(t => t.RECORD_ID == entity.DATA_ID && t.USER_ID != record.NOTE_TAKER_ID, new BaseFilter(record.ORG_ID));
|
|
bool ResultGetInfo = ApproveCallBackService.GetApproject(entity, ref modelApp, ref listAppDetail, ref taskFinish, ref Msg);
|
|
if (!ResultGetInfo)
|
|
throw new Exception("驳回失败！");
|
|
foreach (var user in recordUsers)
|
|
{
|
|
user.DEAL_STATUS = 0;
|
|
}
|
|
record.STATUS = FOPreMeetingStatusEnum.审批拒绝;
|
|
var sendNotice = NotificationTaskService.InsertUserNoticeTaskModel("职业危害辨识记录-驳回", entity.DATA_ID, record.ORG_ID, (Guid)record.NOTE_TAKER_ID, record.Nav_NoteTaker.NAME, DateTime.Now, DateTime.Parse(DateTime.Now.AddDays(1).ToShortDateString() + " 23:59:59"), 0, "HM100");
|
|
UnifiedCommit(() =>
|
|
{
|
|
if (record != null)
|
|
UpdateEntityNoCommit(record); //保存主表
|
|
if (sendNotice != null)
|
|
AddEntityNoCommit(sendNotice);
|
|
if (recordUsers.Any())
|
|
BantchSaveEntityNoCommit(recordUsers);
|
|
});
|
|
|
|
return true;
|
|
|
|
|
|
});
|
|
}
|
|
/// <summary>
|
|
/// 归档
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpPost, Route("GetRejectContent")]
|
|
public JsonActionResult<string> GetRejectContent([FromBody] T_HM_HAZARD_RECORD entity)
|
|
{
|
|
return SafeExecute<string>(() =>
|
|
{
|
|
var result = string.Empty;
|
|
var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
|
|
var newFilter = new BaseFilter(orgId);
|
|
newFilter.SelectField = new List<string> { "Nav_ApproveDetails" };
|
|
var approveInfo = this.GetEntities<T_PF_APPROVE>(t => t.DATA_ID == entity.ID, newFilter).OrderByDescending(m => m.CREATE_TIME).FirstOrDefault();
|
|
if (approveInfo != null && approveInfo.Nav_ApproveDetails.Any())
|
|
{
|
|
var detail = approveInfo.Nav_ApproveDetails.FirstOrDefault(t => t.NODE_APPROVE_STATUS == 20);
|
|
if (detail != null)
|
|
{
|
|
var userInfo = this.GetEntity<T_FM_USER>(t => t.ID == detail.APPROVE_USER_ID);
|
|
result = userInfo?.NAME + "驳回，内容：" + detail.CONTEXT;
|
|
}
|
|
}
|
|
return result;
|
|
});
|
|
}
|
|
}
|
|
}
|