917 lines
42 KiB
C#
917 lines
42 KiB
C#
|
using APT.BaseData.Domain.Entities;
|
|||
|
|
using APT.BaseData.Domain.Enums;
|
|||
|
|
using APT.BaseData.Domain.IServices;
|
|||
|
|
using APT.Infrastructure.Core;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Linq;
|
|||
|
|
using APT.Infrastructure.Api;
|
|||
|
|
using APT.MS.Domain.Entities.BS;
|
|||
|
|
using APT.MS.Domain.Enums;
|
|||
|
|
using APT.BaseData.Domain.IServices.FM;
|
|||
|
|
using APT.BaseData.Domain.Entities.FM;
|
|||
|
|
using APT.MS.Domain.Entities.FO;
|
|||
|
|
using APT.MS.Domain.Entities.HM;
|
|||
|
|
using APT.BaseData.Domain.Enums.PF;
|
|||
|
|
using APT.MS.Domain.Entities.PF;
|
|||
|
|
using APT.MS.Domain.Entities.SC;
|
|||
|
|
using APT.MS.Domain.Entities.TI;
|
|||
|
|
using APT.MS.Domain.Entities.AE;
|
|||
|
|
using APT.MS.Domain.Entities.OH;
|
|||
|
|
using APT.MS.Domain.Entities.CM;
|
|||
|
|
using log4net.Filter;
|
|||
|
|
using Autofac.Features.Metadata;
|
|||
|
|
using APT.MS.Domain.Entities.DM;
|
|||
|
|
|
|||
|
|
namespace APT.BaseData.Services.DomainServices
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 会议
|
|||
|
|
/// </summary>
|
|||
|
|
public class PFApproveCallBackMTService : CommonService, IPFApproveCallBackMTService
|
|||
|
|
{
|
|||
|
|
IPFCodeRuleService CodeRuleService { get; set; }
|
|||
|
|
IFMNotificationTaskService NotificationTaskService { get; set; }
|
|||
|
|
IPFSysLogService SysLogService { get; set; }
|
|||
|
|
IFMDepartmentService DepartmentService { get; set; }
|
|||
|
|
IFMUserService UserService { get; set; }
|
|||
|
|
public PFApproveCallBackMTService(IRepository repository, IPFCodeRuleService codeRuleService, IFMNotificationTaskService notificationTaskService, IPFSysLogService sysLogService, IFMDepartmentService departmentService, IFMUserService userService)
|
|||
|
|
: base(repository)
|
|||
|
|
{
|
|||
|
|
CodeRuleService = codeRuleService;
|
|||
|
|
NotificationTaskService = notificationTaskService;
|
|||
|
|
SysLogService = sysLogService;
|
|||
|
|
DepartmentService = departmentService;
|
|||
|
|
UserService = userService;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 会议模块审批回调
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 会议发布审批回调
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool MeetingNoticeBack(string id)
|
|||
|
|
{
|
|||
|
|
//状态修改 给 所有参会人 发送（参加、请假）待办
|
|||
|
|
Guid MeetingId = new Guid(id);
|
|||
|
|
T_SC_MT_MEETING entity = GetEntity<T_SC_MT_MEETING>(MeetingId, new string[] { "Nav_ListPAll.Nav_User", "Nav_ListPReView.Nav_User", "Nav_UserRecorder", "Nav_UserHost" });// 参会人 评审人 记录人 主持人
|
|||
|
|
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
//如果是年度生产作业计划触发的，审批结束后发今日提醒给企管部负责人
|
|||
|
|
T_FM_NOTIFICATION_TASK sendNotice = null;
|
|||
|
|
if (entity.CREACTTYPE == CREACTTYPEEnum.YearPlanAdd)
|
|||
|
|
{
|
|||
|
|
var userInfo = this.GetEntity<T_FM_PARAM_SET>(t => t.NAME == "企管部负责人", "Nav_User");
|
|||
|
|
if (userInfo != null)
|
|||
|
|
{
|
|||
|
|
sendNotice = NotificationTaskService.InsertUserNoticeTaskModel("请上传下年度生产作业计划至文件库。", entity.ID, entity.ORG_ID, userInfo.USER_ID.Value, userInfo.Nav_User.NAME, DateTime.Now, DateTime.Now.AddDays(30), (int)FMNoticeTypeEnum.今日提醒, "PF135");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// XXXX 会 参会通知
|
|||
|
|
string perNoticeTitle = entity.MEETINGTYPE.GetDescription() + "参会通知";
|
|||
|
|
List<Guid> ListNoticeAll = new List<Guid>();
|
|||
|
|
List<string> ListNoticeAllNAME = new List<string>();
|
|||
|
|
|
|||
|
|
var listUser = entity.Nav_ListPAll.Where(e => !e.IS_DELETED).Select(e => e.Nav_User).ToList();
|
|||
|
|
for (int i = 0; i < listUser.Count; i++)
|
|||
|
|
{
|
|||
|
|
if (ListNoticeAll.Contains(listUser[i].ID))
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
ListNoticeAll.Add(listUser[i].ID);
|
|||
|
|
ListNoticeAllNAME.Add(listUser[i].NAME);
|
|||
|
|
}
|
|||
|
|
//主持人
|
|||
|
|
if (!ListNoticeAll.Contains(entity.USER_ID_HOST.Value))
|
|||
|
|
{
|
|||
|
|
ListNoticeAll.Add(entity.USER_ID_HOST.Value);
|
|||
|
|
ListNoticeAllNAME.Add(entity.Nav_UserHost.NAME);
|
|||
|
|
}
|
|||
|
|
//记录人
|
|||
|
|
if (!ListNoticeAll.Contains(entity.USER_ID_RECORDER.Value))
|
|||
|
|
{
|
|||
|
|
ListNoticeAll.Add(entity.USER_ID_RECORDER.Value);
|
|||
|
|
ListNoticeAllNAME.Add(entity.Nav_UserRecorder.NAME);
|
|||
|
|
}
|
|||
|
|
//评审人
|
|||
|
|
if (entity.Nav_ListPReView != null && entity.Nav_ListPReView.Any())
|
|||
|
|
{
|
|||
|
|
var ReView = entity.Nav_ListPReView.ToList();
|
|||
|
|
for (int i = 0; i < ReView.Count; i++)
|
|||
|
|
{
|
|||
|
|
if (ListNoticeAll.Contains(ReView[i].USER_ID))
|
|||
|
|
{
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
ListNoticeAll.Add(ReView[i].USER_ID);
|
|||
|
|
ListNoticeAllNAME.Add(ReView[i].Nav_User.NAME);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//给责任人 发送通知
|
|||
|
|
List<T_FM_NOTIFICATION_TASK> listNoticeDeals = NotificationTaskService.InsertUserNoticeTaskModels(perNoticeTitle, entity.ID, entity.ORG_ID, ListNoticeAll, ListNoticeAllNAME, DateTime.Now, entity.BEGIN_TIME.Value, (int)FMNoticeTypeEnum.消息, "SC028_SHOWPRINT");
|
|||
|
|
//如果会议已经开始了 待办变成已完成
|
|||
|
|
if (entity.BEGIN_TIME.Value < DateTime.Now)
|
|||
|
|
foreach (var item in listNoticeDeals)
|
|||
|
|
{
|
|||
|
|
item.NOTICE_STATUS = 1;
|
|||
|
|
}
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
if (listNoticeDeals != null && listNoticeDeals.Any())//隐患上报明细表
|
|||
|
|
BantchSaveEntityNoCommit(listNoticeDeals);
|
|||
|
|
if (sendNotice != null)
|
|||
|
|
UpdateEntityNoCommit(sendNotice);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 会议纪要审批回调
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool MeetingMinutesBack(string id)
|
|||
|
|
{
|
|||
|
|
//状态修改
|
|||
|
|
Guid MeetingMinutesId = new Guid(id);
|
|||
|
|
T_SC_MT_MEETING_MINUTES entity = GetEntity<T_SC_MT_MEETING_MINUTES>(MeetingMinutesId);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
|
|||
|
|
T_SC_MT_MEETING_END modelEnd = new T_SC_MT_MEETING_END();
|
|||
|
|
modelEnd.ID = Guid.NewGuid();
|
|||
|
|
modelEnd.ORG_ID = entity.ORG_ID;
|
|||
|
|
modelEnd.MEETING_ID = entity.MEETING_ID;
|
|||
|
|
modelEnd.ISEND = false;
|
|||
|
|
modelEnd.RUN_COUNT = 0;
|
|||
|
|
modelEnd.CREATE_TIME = DateTime.Now;
|
|||
|
|
//会议结束的逻辑请转至 PP/SC/MeetingEndToOther 处理
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
UpdateEntityNoCommit(modelEnd);//添加结束表 隔离会议模块
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 安全科技 保险单
|
|||
|
|
//TI/TISafePdtCostRecordType/RecordBack
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 安全生产费用使用记录审批
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool RecordBack(string id)
|
|||
|
|
{
|
|||
|
|
Guid MeetingMinutesId = new Guid(id);
|
|||
|
|
T_TI_SAFE_PDT_COST_RECORD entity = GetEntity<T_TI_SAFE_PDT_COST_RECORD>(MeetingMinutesId);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 事故事件上报
|
|||
|
|
|
|||
|
|
//AE/AEAccidentEventReport/EventBack
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 事故事件上报审批
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool EventBack(string id)
|
|||
|
|
{
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
|
|||
|
|
T_AE_ACCIDENT_EVENT_REPORT entity = GetEntity<T_AE_ACCIDENT_EVENT_REPORT>(GUID);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
|
|||
|
|
//重伤及以上：安环部负责人
|
|||
|
|
//轻伤：部门级部门负责人
|
|||
|
|
//微伤：部门级部门负责人
|
|||
|
|
//险肇：部门级部门负责人
|
|||
|
|
T_FM_USER user = new T_FM_USER();
|
|||
|
|
T_PF_APPROVAL_ROLE approveRole = null;
|
|||
|
|
|
|||
|
|
#region 获取负责人
|
|||
|
|
|
|||
|
|
switch (entity.ACCIDENT_LEVEL)
|
|||
|
|
{
|
|||
|
|
case AEAccidentLevel.Jumbo:
|
|||
|
|
case AEAccidentLevel.Major:
|
|||
|
|
case AEAccidentLevel.Larger:
|
|||
|
|
case AEAccidentLevel.General:
|
|||
|
|
case AEAccidentLevel.SeriouslyInjured:
|
|||
|
|
var ToUser = GetEntity<T_AE_DOSET_DEPARTMENT_USER>(e => e.EVENTTYPE == EventType.AE006ToAE008);//触发设置
|
|||
|
|
if (ToUser == null)
|
|||
|
|
{
|
|||
|
|
//安环部负责人
|
|||
|
|
approveRole = GetEntity<T_PF_APPROVAL_ROLE>(e => e.NAME.Contains("安环部负责人"));
|
|||
|
|
if (approveRole != null)
|
|||
|
|
{
|
|||
|
|
user = GetEntity<T_FM_USER>(e => e.APPROVE_ROLE_ID == approveRole.ID);
|
|||
|
|
if (user == null)
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到安环部负责人【" + approveRole.ID + "】！");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到审批角色安环部负责人");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
//部门岗位人员
|
|||
|
|
string Msg = string.Empty;
|
|||
|
|
var listUser = UserService.GetDepPostUser(ref Msg, ToUser.DEPARTMENT_ID, ToUser.POST_ID, true);
|
|||
|
|
if (listUser != null && listUser.Any())
|
|||
|
|
{
|
|||
|
|
user = listUser[0];
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到配置的部门岗位人员！");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
case AEAccidentLevel.MinorJuries:
|
|||
|
|
case AEAccidentLevel.Aminor:
|
|||
|
|
case AEAccidentLevel.Risk:
|
|||
|
|
//部门级部门负责人
|
|||
|
|
if (entity.DEPARTMENT_ID.HasValue)
|
|||
|
|
{
|
|||
|
|
var dep = DepartmentService.GetDEPARTMENTLevel(entity.DEPARTMENT_ID.Value);
|
|||
|
|
if (dep != null)
|
|||
|
|
{
|
|||
|
|
approveRole = GetEntity<T_PF_APPROVAL_ROLE>(e => e.NAME.Contains("部门负责人"));
|
|||
|
|
if (approveRole != null)
|
|||
|
|
{
|
|||
|
|
user = GetEntity<T_FM_USER>(e => e.DEPARTMENT_ID == dep.ID && e.APPROVE_ROLE_ID == approveRole.ID);
|
|||
|
|
if (user == null)
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到部门【" + entity.DEPARTMENT_ID.Value + "】（审批角色）负责人【" + approveRole.ID + "】！");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到审批角色部门负责人");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到部门【" + entity.DEPARTMENT_ID.Value + "】的部门级");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "部门ID为空");
|
|||
|
|
}
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
T_AE_ACCIDENT_SURVEY_TEAM_MEMBER member = null;
|
|||
|
|
T_FM_NOTIFICATION_TASK task = null;
|
|||
|
|
T_SC_MT_MEETING_BEGIN modelBegin = null;
|
|||
|
|
if (user != null)
|
|||
|
|
{
|
|||
|
|
//全部对接 流程修改 为 发起会议 归档后 到 会议开始
|
|||
|
|
////找到了负责人
|
|||
|
|
//member = new T_AE_ACCIDENT_SURVEY_TEAM_MEMBER();
|
|||
|
|
//member.ID = Guid.NewGuid();
|
|||
|
|
//member.REPORT_ID = entity.ID;
|
|||
|
|
//member.STATUS = PFStandardStatus.Draft;
|
|||
|
|
//member.IS_DELETED = false;
|
|||
|
|
//member.ORG_ID = entity.ORG_ID;
|
|||
|
|
//member.CREATE_TIME = DateTime.Now;
|
|||
|
|
//member.CREATER_ID = user.ID;
|
|||
|
|
////member.LEADER_USER_ID = ;
|
|||
|
|
////member.SURVEY_USER_ID = ;
|
|||
|
|
////member.ENTITY_ORG_TPYE = ;
|
|||
|
|
////member.FORM_ID = ;
|
|||
|
|
////member.FLOW_STATUS = ;
|
|||
|
|
////member.FLOW_SEND_STATUS = ;
|
|||
|
|
////member.FLOW_ID = ;
|
|||
|
|
////member.MODIFY_TIME = ;
|
|||
|
|
//member.MODIFIER_ID = user.ID;
|
|||
|
|
//task = NotificationTaskService.InsertUserNoticeTaskModel("事故调查小组成员", member.ID, entity.ORG_ID, user.ID, user.NAME, DateTime.Now, DateTime.Now.AddDays(1), (int)FMNoticeTypeEnum.消息, "AE008");
|
|||
|
|
|
|||
|
|
//勘察记录结束后 触发 调查报告讨论 会议
|
|||
|
|
modelBegin = new T_SC_MT_MEETING_BEGIN();
|
|||
|
|
modelBegin.ID = Guid.NewGuid();
|
|||
|
|
modelBegin.ORG_ID = entity.ORG_ID;
|
|||
|
|
modelBegin.SOURCETYPE = SOURCETYPE.AE006ToMeet;//事故事件上报[AE006] 对接到 会议开始
|
|||
|
|
modelBegin.TABLENAME = "T_AE_ACCIDENT_EVENT_REPORT";
|
|||
|
|
modelBegin.DATA_ID = entity.ID;
|
|||
|
|
modelBegin.ISBEGIN = false;
|
|||
|
|
modelBegin.USER_ID = user.ID;
|
|||
|
|
modelBegin.CREATE_TIME = DateTime.Now;
|
|||
|
|
modelBegin.CREATER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
if (modelBegin != null)
|
|||
|
|
UpdateEntityNoCommit(modelBegin);
|
|||
|
|
if (task != null)
|
|||
|
|
AddEntityNoCommit(task);
|
|||
|
|
if (member != null)
|
|||
|
|
AddEntityNoCommit(member);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
//AE/AEInvestigationRecord/LeaderCheck
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 勘察记录组长审批完成后回调
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool LeaderCheck(string id)
|
|||
|
|
{
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
T_AE_INVESTIGATION_RECORD entity = GetEntity<T_AE_INVESTIGATION_RECORD>(GUID);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
|
|||
|
|
var appDet = GetEntity<T_PF_APPROVE_DETAIL>(e => e.APPROVE_ID == entity.APPROVE_ID);
|
|||
|
|
entity.REVIEW_OK = appDet.NODE_APPROVE_STATUS == 10 ? true : false;// 组长审阅状态
|
|||
|
|
entity.REVIEW_COMMENT = appDet.CONTEXT;// 审阅意见
|
|||
|
|
|
|||
|
|
//事故调查小组成员表 填写 给记录人 触发勘察记录表 审批通过后 再给记录人 发送 事故事件调查结果报送表
|
|||
|
|
T_AE_ACCIDENT_SURVEY_TEAM_MEMBER member = GetEntity<T_AE_ACCIDENT_SURVEY_TEAM_MEMBER>(e => e.REPORT_ID == entity.ACCIDENT_ID, new string[] { "Nav_SurveyUser" });
|
|||
|
|
|
|||
|
|
|
|||
|
|
//勘察记录结束后 触发 调查报告讨论 会议
|
|||
|
|
T_SC_MT_MEETING_BEGIN modelBegin = new T_SC_MT_MEETING_BEGIN();
|
|||
|
|
modelBegin.ID = Guid.NewGuid();
|
|||
|
|
modelBegin.ORG_ID = entity.ORG_ID;
|
|||
|
|
modelBegin.SOURCETYPE = SOURCETYPE.AE018ToMeet;
|
|||
|
|
modelBegin.TABLENAME = "T_AE_INVESTIGATION_RECORD";
|
|||
|
|
modelBegin.DATA_ID = GUID;
|
|||
|
|
modelBegin.ISBEGIN = false;
|
|||
|
|
modelBegin.USER_ID = member.SURVEY_USER_ID.Value;
|
|||
|
|
modelBegin.CREATE_TIME = DateTime.Now;
|
|||
|
|
modelBegin.CREATER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
|||
|
|
|
|||
|
|
|
|||
|
|
//#region 这段代码应该是得移走 到会议结束后触发
|
|||
|
|
|
|||
|
|
//T_AE_ACCIDENT_EVENT_SURVEY_RESULT modelResult = new T_AE_ACCIDENT_EVENT_SURVEY_RESULT();
|
|||
|
|
//modelResult.ID = Guid.NewGuid();
|
|||
|
|
//modelResult.REPORT_ID = entity.ACCIDENT_ID;
|
|||
|
|
//modelResult.STATUS = PFStandardStatus.Draft;
|
|||
|
|
//modelResult.IS_DELETED = false;
|
|||
|
|
//modelResult.ORG_ID = entity.ORG_ID;
|
|||
|
|
|
|||
|
|
////modelResult.CASUALTY_COUNT = "";
|
|||
|
|
////modelResult.ECONOMIC_LOSSES = "";
|
|||
|
|
////modelResult.ACCIDENT_COURSE = "";
|
|||
|
|
////modelResult.TIME = "";
|
|||
|
|
////modelResult.RISK_SUBMIT_ID = "";
|
|||
|
|
////modelResult.ENTITY_ORG_TPYE = "";
|
|||
|
|
////modelResult.FORM_ID = "";
|
|||
|
|
////modelResult.FLOW_STATUS = "";
|
|||
|
|
////modelResult.FLOW_SEND_STATUS = "";
|
|||
|
|
////modelResult.FLOW_ID = "";
|
|||
|
|
////modelResult.CREATE_TIME = "";
|
|||
|
|
////modelResult.MODIFY_TIME = "";
|
|||
|
|
////modelResult.CREATER_ID = "";
|
|||
|
|
////modelResult.MODIFIER_ID = "";
|
|||
|
|
|
|||
|
|
//T_FM_NOTIFICATION_TASK taskAdd = NotificationTaskService.InsertUserNoticeTaskModel("事故事件调查结果填报", modelResult.ID, entity.ORG_ID, member.SURVEY_USER_ID.Value, member.Nav_SurveyUser.NAME, DateTime.Now, DateTime.Now.AddDays(1), (int)FMNoticeTypeEnum.消息, "AE010");
|
|||
|
|
|
|||
|
|
//#endregion
|
|||
|
|
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
UpdateEntityNoCommit(modelBegin);//会议开始
|
|||
|
|
//if (modelResult != null)//添加 事故事件调查结果填报
|
|||
|
|
// AddEntityNoCommit(modelResult);
|
|||
|
|
//if (taskAdd != null)//添加 事故事件调查结果填报 待办
|
|||
|
|
// AddEntityNoCommit(taskAdd);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 事故事件调查结果审批
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool EventResultBack(string id)
|
|||
|
|
{
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
|
|||
|
|
T_AE_ACCIDENT_EVENT_SURVEY_RESULT entity = GetEntity<T_AE_ACCIDENT_EVENT_SURVEY_RESULT>(GUID);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
|
|||
|
|
////重伤及以上：安环部负责人
|
|||
|
|
////轻伤：部门级部门负责人
|
|||
|
|
////微伤：部门级部门负责人
|
|||
|
|
////险肇：部门级部门负责人
|
|||
|
|
//T_FM_USER user = new T_FM_USER();
|
|||
|
|
//T_PF_APPROVAL_ROLE approveRole = null;
|
|||
|
|
|
|||
|
|
//#region 获取负责人
|
|||
|
|
|
|||
|
|
//switch (entity.ACCIDENT_LEVEL)
|
|||
|
|
//{
|
|||
|
|
// case AEAccidentLevel.Jumbo:
|
|||
|
|
// case AEAccidentLevel.Major:
|
|||
|
|
// case AEAccidentLevel.Larger:
|
|||
|
|
// case AEAccidentLevel.General:
|
|||
|
|
// case AEAccidentLevel.SeriouslyInjured:
|
|||
|
|
// //安环部负责人
|
|||
|
|
// approveRole = GetEntity<T_PF_APPROVAL_ROLE>(e => e.NAME.Contains("安环部负责人"));
|
|||
|
|
// if (approveRole != null)
|
|||
|
|
// {
|
|||
|
|
// user = GetEntity<T_FM_USER>(e => e.APPROVE_ROLE_ID == approveRole.ID);
|
|||
|
|
// if (user == null)
|
|||
|
|
// {
|
|||
|
|
// SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到安环部负责人【" + approveRole.ID + "】！");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// else
|
|||
|
|
// {
|
|||
|
|
// SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到审批角色安环部负责人");
|
|||
|
|
// }
|
|||
|
|
// break;
|
|||
|
|
// case AEAccidentLevel.MinorJuries:
|
|||
|
|
// case AEAccidentLevel.Aminor:
|
|||
|
|
// case AEAccidentLevel.Risk:
|
|||
|
|
// //部门级部门负责人
|
|||
|
|
// if (entity.DEPARTMENT_ID.HasValue)
|
|||
|
|
// {
|
|||
|
|
// var dep = DepartmentService.GetDEPARTMENTLevel(entity.DEPARTMENT_ID.Value);
|
|||
|
|
// if (dep != null)
|
|||
|
|
// {
|
|||
|
|
// approveRole = GetEntity<T_PF_APPROVAL_ROLE>(e => e.NAME.Contains("部门负责人"));
|
|||
|
|
// if (approveRole != null)
|
|||
|
|
// {
|
|||
|
|
// user = GetEntity<T_FM_USER>(e => e.DEPARTMENT_ID == dep.ID && e.APPROVE_ROLE_ID == approveRole.ID);
|
|||
|
|
// if (user == null)
|
|||
|
|
// {
|
|||
|
|
// SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到部门【" + entity.DEPARTMENT_ID.Value + "】（审批角色）负责人【" + approveRole.ID + "】！");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// else
|
|||
|
|
// {
|
|||
|
|
// SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到审批角色部门负责人");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// else
|
|||
|
|
// {
|
|||
|
|
// SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "未找到部门【" + entity.DEPARTMENT_ID.Value + "】的部门级");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// else
|
|||
|
|
// {
|
|||
|
|
// SysLogService.AddAddLog(APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value, "AE006", entity.ID.ToString(), "", "部门ID为空");
|
|||
|
|
// }
|
|||
|
|
// break;
|
|||
|
|
// default:
|
|||
|
|
// break;
|
|||
|
|
//}
|
|||
|
|
//#endregion
|
|||
|
|
//T_AE_ACCIDENT_SURVEY_TEAM_MEMBER member = null;
|
|||
|
|
//T_FM_NOTIFICATION_TASK task = null;
|
|||
|
|
|
|||
|
|
//if (user != null)
|
|||
|
|
//{
|
|||
|
|
// //找到了负责人
|
|||
|
|
// member = new T_AE_ACCIDENT_SURVEY_TEAM_MEMBER();
|
|||
|
|
// member.ID = Guid.NewGuid();
|
|||
|
|
// member.REPORT_ID = entity.ID;
|
|||
|
|
// member.STATUS = PFStandardStatus.Draft;
|
|||
|
|
// member.IS_DELETED = false;
|
|||
|
|
// member.ORG_ID = entity.ORG_ID;
|
|||
|
|
// member.CREATE_TIME = DateTime.Now;
|
|||
|
|
// member.CREATER_ID = user.ID;
|
|||
|
|
// //member.LEADER_USER_ID = ;
|
|||
|
|
// //member.SURVEY_USER_ID = ;
|
|||
|
|
// //member.ENTITY_ORG_TPYE = ;
|
|||
|
|
// //member.FORM_ID = ;
|
|||
|
|
// //member.FLOW_STATUS = ;
|
|||
|
|
// //member.FLOW_SEND_STATUS = ;
|
|||
|
|
// //member.FLOW_ID = ;
|
|||
|
|
// //member.MODIFY_TIME = ;
|
|||
|
|
// member.MODIFIER_ID = user.ID;
|
|||
|
|
// task = NotificationTaskService.InsertUserNoticeTaskModel("事故调查小组成员", member.ID, entity.ORG_ID, user.ID, user.NAME, DateTime.Now, DateTime.Now.AddDays(1), (int)FMNoticeTypeEnum.消息, "AE008");
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 给人事专员触发工伤保险理赔信息记录
|
|||
|
|
//TI021 发起部门 姓名 事故事件 受伤日期 发起部门：受伤人 所在部门
|
|||
|
|
|
|||
|
|
|
|||
|
|
List<T_TI_INSURANCE_CLAIM_RECORD> listClaim = null;
|
|||
|
|
List<T_FM_NOTIFICATION_TASK> listTask = null;
|
|||
|
|
|
|||
|
|
if (entity.REPORT_ID.HasValue)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
var listUsers = GetEntities<T_AE_ACCIDENT_EVENT_SURVEY_CASUALTIES>(e => e.RESULT_ID == entity.ID && !e.IS_DELETED, "Nav_User");
|
|||
|
|
if (listUsers != null && listUsers.Any())
|
|||
|
|
{
|
|||
|
|
var doSet = GetEntity<T_AE_DOSET_DEPARTMENT_USER>(e => e.EVENTTYPE == EventType.ClaimRecord && !e.IS_DELETED);
|
|||
|
|
if (doSet != null)
|
|||
|
|
{
|
|||
|
|
//给对应部门人员 发送待办
|
|||
|
|
var user = GetEntity<T_FM_USER>(e => e.DEPARTMENT_ID.HasValue && e.ENABLE_STATUS == 0 && !e.IS_DELETED && e.DEPARTMENT_ID.Value == doSet.DEPARTMENT_ID && e.PERSON_ID.HasValue && e.Nav_Person.POST_ID.HasValue && e.Nav_Person.POST_ID.Value == doSet.POST_ID, "Nav_Person");
|
|||
|
|
if (user != null)
|
|||
|
|
{
|
|||
|
|
listClaim = new List<T_TI_INSURANCE_CLAIM_RECORD>();
|
|||
|
|
listTask = new List<T_FM_NOTIFICATION_TASK>();
|
|||
|
|
|
|||
|
|
foreach (var item in listUsers)
|
|||
|
|
{
|
|||
|
|
T_TI_INSURANCE_CLAIM_RECORD claim = new T_TI_INSURANCE_CLAIM_RECORD();
|
|||
|
|
claim.ID = Guid.NewGuid();
|
|||
|
|
claim.ORG_ID = doSet.ORG_ID;
|
|||
|
|
claim.ACCIDENT_ID = entity.REPORT_ID;
|
|||
|
|
claim.DEPARTMENT_ID = item.Nav_User.DEPARTMENT_ID;
|
|||
|
|
claim.INJURE_TIME = item.INJURED_TIME;
|
|||
|
|
claim.USER_ID = item.USER_ID;
|
|||
|
|
claim.STATUS = PFStandardStatus.Draft;
|
|||
|
|
listTask.Add(NotificationTaskService.InsertUserNoticeTaskModel("工伤保险理赔 事故事件：" + item.Nav_User.NAME, claim.ID, claim.ORG_ID, user.ID, user.NAME, DateTime.Now, 0, "TI021", FMTASKTYPE.Default));
|
|||
|
|
listClaim.Add(claim);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
//if (task != null)
|
|||
|
|
// AddEntityNoCommit<T_FM_NOTIFICATION_TASK>(task);
|
|||
|
|
//if (member != null)
|
|||
|
|
// AddEntityNoCommit<T_AE_ACCIDENT_SURVEY_TEAM_MEMBER>(member);
|
|||
|
|
if (listClaim != null && listClaim.Count > 0)
|
|||
|
|
BantchSaveEntityNoCommit(listClaim);
|
|||
|
|
if (listTask != null && listTask.Count > 0)
|
|||
|
|
BantchSaveEntityNoCommit(listTask);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 职业卫生
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 职业卫生 体检计划 人事部经理审批
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool PlanMasterBack(string id)
|
|||
|
|
{
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
|
|||
|
|
string Msg = string.Empty;
|
|||
|
|
var member = UserService.GetPostUser(ref Msg, "人事专员");
|
|||
|
|
if (member == null)
|
|||
|
|
{
|
|||
|
|
if (!string.IsNullOrEmpty(Msg))
|
|||
|
|
{
|
|||
|
|
throw new Exception(Msg);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
throw new Exception("获取人事专员岗位信息失败！");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
T_OH_HEALTH_EXAM_PLAN entity = GetEntity<T_OH_HEALTH_EXAM_PLAN>(GUID, new string[] { "Nav_ListPlanRegister.Nav_ListHazard" });
|
|||
|
|
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;//变成已归档
|
|||
|
|
|
|||
|
|
DateTime dtNow = DateTime.Now;
|
|||
|
|
//给人事专员发送 体检填表
|
|||
|
|
T_OH_HEALTH_EXAM_NOTICE notice = new T_OH_HEALTH_EXAM_NOTICE();
|
|||
|
|
notice.ID = Guid.NewGuid();
|
|||
|
|
notice.CODE = "TJ" + dtNow.ToString("yyyyMMddHHmmss");
|
|||
|
|
//notice.NAME ="";
|
|||
|
|
//notice.OTHER_STUFF =;
|
|||
|
|
notice.STATUS = PFStandardStatus.Draft;
|
|||
|
|
//notice.APPROVE_ID =;
|
|||
|
|
notice.IS_DELETED = false;
|
|||
|
|
notice.ORG_ID = entity.ORG_ID;
|
|||
|
|
//notice.ENTITY_ORG_TPYE =;
|
|||
|
|
//notice.FORM_ID =;
|
|||
|
|
//notice.FLOW_STATUS =;
|
|||
|
|
//notice.FLOW_SEND_STATUS =;
|
|||
|
|
//notice.FLOW_ID =;
|
|||
|
|
//notice.CREATE_TIME =;
|
|||
|
|
//notice.MODIFY_TIME =;
|
|||
|
|
//notice.CREATER_ID =;
|
|||
|
|
//notice.MODIFIER_ID =;
|
|||
|
|
|
|||
|
|
List<T_OH_HEALTH_EXAM_NOTICE_REGISTER> listRegister = new List<T_OH_HEALTH_EXAM_NOTICE_REGISTER>();
|
|||
|
|
IEnumerable<T_OH_HEALTH_EXAM_NOTICE_REGISTER> listRegisterCheck = null;
|
|||
|
|
T_OH_HEALTH_EXAM_NOTICE_REGISTER modelLast = null;
|
|||
|
|
List<T_OH_EXAM_NOTICE_OCC_HAZARD> listOccHazard = new List<T_OH_EXAM_NOTICE_OCC_HAZARD>();
|
|||
|
|
|
|||
|
|
Guid LoginID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value;
|
|||
|
|
|
|||
|
|
BaseFilter basFiliter = new BaseFilter();
|
|||
|
|
basFiliter.Order = DbOrder.DESC;
|
|||
|
|
basFiliter.Orders.Add(new DataOrder() { Field = "THISDATE", Order = DbOrder.DESC });
|
|||
|
|
|
|||
|
|
foreach (var item in entity.Nav_ListPlanRegister)
|
|||
|
|
{
|
|||
|
|
T_OH_HEALTH_EXAM_NOTICE_REGISTER model = new T_OH_HEALTH_EXAM_NOTICE_REGISTER();
|
|||
|
|
model.ID = Guid.NewGuid();
|
|||
|
|
model.NOTICE_ID = notice.ID;
|
|||
|
|
model.USER_ID = item.USER_ID;
|
|||
|
|
model.DEPARTMENT_ID = item.DEPARTMENT_ID;
|
|||
|
|
model.DEPARTMENT_ID_WORKSHOP = item.DEPARTMENT_ID_WORKSHOP;
|
|||
|
|
model.CYCLE_ID = item.EXAM_CYCLE_ID;
|
|||
|
|
//model.EXAM_BATCH_ID
|
|||
|
|
model.TYPE = OHHealthExamType.Post;
|
|||
|
|
model.STATUS = OHHealthExamNoticeRegisterStatus.WaitNotice;
|
|||
|
|
model.IS_DELETED = false;
|
|||
|
|
model.ORG_ID = item.ORG_ID;
|
|||
|
|
//model.ENTITY_ORG_TPYE
|
|||
|
|
//model.FORM_ID
|
|||
|
|
//model.FLOW_STATUS
|
|||
|
|
//model.FLOW_SEND_STATUS
|
|||
|
|
//model.FLOW_ID
|
|||
|
|
model.LASTDATE = dtNow;//上次体检时间
|
|||
|
|
|
|||
|
|
//新方法
|
|||
|
|
modelLast = GetEntity<T_OH_HEALTH_EXAM_NOTICE_REGISTER>(e => !e.IS_DELETED && e.USER_ID == model.USER_ID && e.STATUS >= OHHealthExamNoticeRegisterStatus.NoticeResult, basFiliter, "");
|
|||
|
|
//modelLast = GetEntity<T_OH_HEALTH_EXAM_NOTICE_REGISTER>(e => !e.IS_DELETED && e.USER_ID == model.USER_ID && e.STATUS >= OHHealthExamNoticeRegisterStatus.MasterRead, basFiliter, "");
|
|||
|
|
|
|||
|
|
if (modelLast != null && modelLast.THISDATE.HasValue)
|
|||
|
|
{
|
|||
|
|
model.LASTDATE = modelLast.THISDATE;//上次体检时间 就是上次通知的本次时间
|
|||
|
|
}
|
|||
|
|
//旧方法
|
|||
|
|
//listRegisterCheck = GetEntities<T_OH_HEALTH_EXAM_NOTICE_REGISTER>(e => !e.IS_DELETED && e.USER_ID == model.USER_ID && e.STATUS >= OHHealthExamNoticeRegisterStatus.NoticeResult).OrderByDescending(e => e.THISDATE);
|
|||
|
|
//if (listRegisterCheck != null && listRegisterCheck.Any())
|
|||
|
|
//{
|
|||
|
|
// modelLast = listRegisterCheck.ToList()[0];
|
|||
|
|
// if (modelLast.EXAM_BATCH_ID.HasValue)
|
|||
|
|
// {
|
|||
|
|
// model.LASTDATE = modelLast.THISDATE;//上次体检时间 就是上次通知的本次时间
|
|||
|
|
// //if (!listBatchID.Contains(modelLast.EXAM_BATCH_ID.Value))
|
|||
|
|
// //{
|
|||
|
|
// // listBatchID.Add(modelLast.EXAM_BATCH_ID.Value);
|
|||
|
|
// // modelBatch = GetEntity<T_OH_HEALTH_EXAM_BATCH>(modelLast.EXAM_BATCH_ID.Value);
|
|||
|
|
// // listLastBatch.Add(modelBatch);
|
|||
|
|
// //}
|
|||
|
|
// //else
|
|||
|
|
// //{
|
|||
|
|
// // modelBatch = listLastBatch.First(e => e.ID == modelLast.EXAM_BATCH_ID.Value);
|
|||
|
|
// //}
|
|||
|
|
// //model.LASTDATE = modelBatch.START_TIME;//上次体检时间
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
model.CREATE_TIME = dtNow;
|
|||
|
|
model.MODIFY_TIME = dtNow;
|
|||
|
|
model.CREATER_ID = LoginID;
|
|||
|
|
//model.MODIFIER_ID
|
|||
|
|
model.PLAN_ID_DEP = item.PLAN_ID_DEP;
|
|||
|
|
model.PLAN_REGISTER_ID = item.ID;
|
|||
|
|
listRegister.Add(model);
|
|||
|
|
|
|||
|
|
foreach (var itemHaz in item.Nav_ListHazard)
|
|||
|
|
{
|
|||
|
|
listOccHazard.Add(new T_OH_EXAM_NOTICE_OCC_HAZARD()
|
|||
|
|
{
|
|||
|
|
ID = Guid.NewGuid(),
|
|||
|
|
REGISTER_ID = model.ID,
|
|||
|
|
HAZARD_ID = itemHaz.HAZARD_ID,
|
|||
|
|
ORG_ID = notice.ORG_ID,
|
|||
|
|
CREATE_TIME = dtNow,
|
|||
|
|
MODIFY_TIME = dtNow
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
//人事专员 发送 体检通知 安排
|
|||
|
|
T_FM_NOTIFICATION_TASK taskAdd = NotificationTaskService.InsertUserNoticeTaskModel("体检通知表", notice.ID, entity.ORG_ID, member.ID, member.NAME, DateTime.Now, DateTime.Now.AddDays(1), (int)FMNoticeTypeEnum.消息, "OH010");
|
|||
|
|
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
if (notice != null)//体检通知
|
|||
|
|
AddEntityNoCommit(notice);
|
|||
|
|
if (listRegister != null && listRegister.Count > 0)//人员
|
|||
|
|
BantchAddEntityNoCommit(listRegister);
|
|||
|
|
if (taskAdd != null)//添加 事故事件调查结果填报 待办
|
|||
|
|
AddEntityNoCommit(taskAdd);
|
|||
|
|
if (listOccHazard != null && listOccHazard.Count > 0)//人员
|
|||
|
|
BantchAddEntityNoCommit(listOccHazard);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region CM
|
|||
|
|
|
|||
|
|
public bool EstimateBack(string id)
|
|||
|
|
{
|
|||
|
|
//流程完毕，触发给一条今日提醒给安环部负责人，消息类型：召开会议，消息内容：请召开应急预案审核会
|
|||
|
|
//培训水平选中“不充分”，触发给一条今日提醒给事故 / 事件单位负责人，消息类型：组织培训，消息内容：请组织应急知识和技能培训
|
|||
|
|
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
var entity = GetEntity<T_CM_RSP_ESTIMATE>(GUID);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;
|
|||
|
|
|
|||
|
|
T_FM_NOTIFICATION_TASK modelSafeMeeting = null;//今日提醒给安环部负责人
|
|||
|
|
string Msg = string.Empty;
|
|||
|
|
var userSafeMaster = UserService.GetRoleUser(ref Msg, "安环部负责人", null, null);
|
|||
|
|
if (userSafeMaster != null)
|
|||
|
|
{
|
|||
|
|
modelSafeMeeting = NotificationTaskService.InsertUserNoticeTaskModel("请召开应急预案审核会", Guid.Empty, entity.ORG_ID, userSafeMaster.ID, userSafeMaster.NAME, DateTime.Now, DateTime.Now.AddDays(1), 2, null);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
T_FM_NOTIFICATION_TASK modelNotEnougth = null;//培训水平选中“不充分”
|
|||
|
|
if (entity.RSP_TRAINING_LEVEL.HasValue && entity.RSP_TRAINING_LEVEL.Value == CMRspTrainingLevel.NotEnough && entity.DEPARTMENT_ID_REPORT.HasValue)
|
|||
|
|
{
|
|||
|
|
var dep = GetEntity<T_FM_DEPARTMENT>(entity.DEPARTMENT_ID_REPORT.Value, "Nav_User");
|
|||
|
|
if (dep != null && dep.USER_ID.HasValue)
|
|||
|
|
{
|
|||
|
|
modelNotEnougth = NotificationTaskService.InsertUserNoticeTaskModel("请组织应急知识和技能培训", Guid.Empty, entity.ORG_ID, dep.USER_ID.Value, dep.Nav_User.NAME, DateTime.Now, DateTime.Now.AddDays(1), 2, null);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)//状态修改
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
if (modelSafeMeeting != null)//今日提醒给安环部负责人
|
|||
|
|
UpdateEntityNoCommit(modelSafeMeeting);
|
|||
|
|
if (modelNotEnougth != null)//不充分
|
|||
|
|
UpdateEntityNoCommit(modelNotEnougth);
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 年度应急演练计划表 审批流回调
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool DrillPlanEnd(string id)
|
|||
|
|
{
|
|||
|
|
//“演练方案触发时间”触发一条今日提醒给责任人，消息类型：召开会议，消息内容：请编制应急演练方案并召开应急演练方案讨论会
|
|||
|
|
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
var entity = GetEntity<T_CM_DRILL_PLAN>(GUID);
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 设备设施维保
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool Audit(string id)
|
|||
|
|
{
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
var entity = GetEntity<T_DM_DEVICE_MAINTENANCE_CHECK>(GUID);
|
|||
|
|
entity.STATUS_APPROVE = PFStandardStatus.Archived;
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 应急演练活动记录表
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public bool DrillRecordEnd(string id)
|
|||
|
|
{
|
|||
|
|
//“应急演练活动记录表“审核完成后触发两个待办事项：事项一：演练效果评估表、事项二：演练人员自我评估调查表（在问卷调查模块、后续开发），给第一个评估人员
|
|||
|
|
//待办事项”演练效果评估表“在工作台中任务名称中添加”待调查结束后填写“
|
|||
|
|
|
|||
|
|
//给第一个评估人员 添加 [演练效果评估表]
|
|||
|
|
Guid GUID = new Guid(id);
|
|||
|
|
var entity = GetEntity<T_CM_DRILL_RECORD>(GUID, "Nav_ListUserEstimate");
|
|||
|
|
entity.STATUS = PFStandardStatus.Archived;
|
|||
|
|
T_FM_USER userRec = null;
|
|||
|
|
List<T_CM_DRILL_ESTIMATE_RECORD> listEstimateRecord = null;
|
|||
|
|
if (entity.Nav_ListUserEstimate != null && entity.Nav_ListUserEstimate.Any())
|
|||
|
|
{
|
|||
|
|
var userSign = entity.Nav_ListUserEstimate.FirstOrDefault(e => e.ISSIGN);
|
|||
|
|
if (userSign != null)
|
|||
|
|
userRec = GetEntity<T_FM_USER>(userSign.USER_ID);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
T_FM_NOTIFICATION_TASK task = null;//演练效果评估表待办
|
|||
|
|
T_CM_DRILL_ESTIMATE modelEstimate = null;
|
|||
|
|
if (userRec != null)
|
|||
|
|
{
|
|||
|
|
modelEstimate = new T_CM_DRILL_ESTIMATE();
|
|||
|
|
modelEstimate.ID = Guid.NewGuid();
|
|||
|
|
modelEstimate.CODE = "YLPG" + DateTime.Now.ToString("yyyyMMddHHmmss");
|
|||
|
|
modelEstimate.RECORD_ID = entity.ID;
|
|||
|
|
//modelEstimate.ADVISE = ;
|
|||
|
|
modelEstimate.STATUS = PFStandardStatus.Draft;
|
|||
|
|
modelEstimate.IS_DELETED = false;
|
|||
|
|
modelEstimate.ORG_ID = entity.ORG_ID;
|
|||
|
|
//modelEstimate.ENTITY_ORG_TPYE = ;
|
|||
|
|
//modelEstimate.FORM_ID = ;
|
|||
|
|
//modelEstimate.FLOW_STATUS = ;
|
|||
|
|
//modelEstimate.FLOW_SEND_STATUS = ;
|
|||
|
|
//modelEstimate.FLOW_ID = ;
|
|||
|
|
modelEstimate.CREATE_TIME = DateTime.Now;
|
|||
|
|
modelEstimate.MODIFY_TIME = DateTime.Now;
|
|||
|
|
modelEstimate.CREATER_ID = userRec.ID;
|
|||
|
|
modelEstimate.MODIFIER_ID = userRec.ID;
|
|||
|
|
listEstimateRecord = new List<T_CM_DRILL_ESTIMATE_RECORD>();
|
|||
|
|
var listEstimateItem = GetEntities<T_CM_DRILL_ESTIMATE_ITEM_TYPE>(null);
|
|||
|
|
foreach (var item in listEstimateItem)
|
|||
|
|
{
|
|||
|
|
listEstimateRecord.Add(new T_CM_DRILL_ESTIMATE_RECORD()
|
|||
|
|
{
|
|||
|
|
ID = Guid.NewGuid(),
|
|||
|
|
ESTIMEATE_ID = modelEstimate.ID,
|
|||
|
|
ITEM_ID = item.ID,
|
|||
|
|
//SCORE = ,
|
|||
|
|
//ADVISE = ,
|
|||
|
|
IS_DELETED = false,
|
|||
|
|
ORG_ID = item.ORG_ID,
|
|||
|
|
//ENTITY_ORG_TPYE = ,
|
|||
|
|
//FORM_ID = ,
|
|||
|
|
//FLOW_STATUS = ,
|
|||
|
|
//FLOW_SEND_STATUS = ,
|
|||
|
|
//FLOW_ID = ,
|
|||
|
|
CREATE_TIME = modelEstimate.CREATE_TIME,
|
|||
|
|
MODIFY_TIME = modelEstimate.CREATE_TIME,
|
|||
|
|
CREATER_ID = userRec.ID,
|
|||
|
|
MODIFIER_ID = userRec.ID,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
task = NotificationTaskService.InsertUserNoticeTaskModel("演练效果评估", modelEstimate.ID, modelEstimate.ORG_ID, userRec.ID, userRec.NAME, DateTime.Now, DateTime.Now.AddDays(1), 1, "CM036");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
this.UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (entity != null)
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
if (task != null)//演练效果评估表待办
|
|||
|
|
UpdateEntityNoCommit(task);
|
|||
|
|
if (modelEstimate != null)//演练效果评估表待办
|
|||
|
|
UpdateEntityNoCommit(modelEstimate);
|
|||
|
|
if (listEstimateRecord != null && listEstimateRecord.Any())
|
|||
|
|
BantchAddEntityNoCommit(listEstimateRecord);
|
|||
|
|
});
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
}
|
|||
|
|
}
|