wyw/mh_jy_safe
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
afc11ea268
mh_jy_safe/APT.MicroApi/APT.PP.WebApi/Controllers/Api/PTController.cs

1298 lines
75 KiB
C#
Raw Normal View History

仓库复制
2025-08-25 09:56:57 +08:00
using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Domain.IServices.FM;
using APT.Infrastructure.Core;
using APT.MS.Domain.Entities.SE;
using APT.MS.Domain.Enums;
using APT.Utility;
using Microsoft.AspNetCore.Mvc;
using System.Collections.Generic;
using System.Linq;
using System;
using APT.MS.Domain.Entities.FO;
using APT.MS.Domain.Entities.SC.PT;
using APT.BaseData.Domain.Entities;
using APT.MS.Domain.Entities.SC;
using System.Linq.Expressions;
using APT.BaseData.Domain.Enums;
using System.Net.WebSockets;
using Microsoft.CodeAnalysis.Differencing;
using Org.BouncyCastle.Crypto.Modes.Gcm;
using NPOI.SS.Formula.Functions;
using APT.BaseData.Domain.Enums.PF;
using APT.BaseData.Domain.ApiModel.PF;
using System.Reflection.Metadata;
using System.Threading.Tasks;
using APT.WebApi.Models;
using log4net.Filter;
using APT.MS.Domain.Entities.SC.PE;
using APT.PP.WebApi.Controllers.Api.PP;
using System.ComponentModel.Design;
using System.Threading;
using APT.MS.Domain.Entities.BS;
using System.Collections;
namespace APT.PP.WebApi.Controllers.Api
{
/// <summary>
/// 方针与目标管理跑批任务
/// </summary>
[Route("api/PP/PTController")]
[TypeFilter(typeof(CustomActionFilterAttribute))]
public class PTController : AuthorizeApiController<T_FM_BASE_CONFIG>
{
IFMNotificationTaskService NotificationTaskService { get; set; }
public PTController(IFMNotificationTaskService notificationTaskService)
{
NotificationTaskService = notificationTaskService;
}
[HttpPost, Route("MonitorSync")]
public JsonActionResult<bool> MonitorSync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
var dateTime = DateTime.Parse("2024-12-01");
List<T_FM_NOTIFICATION_TASK> noticeList = new List<T_FM_NOTIFICATION_TASK>();
Expression<Func<T_PT_MONITOR_ASSESSMENT, bool>> expression = e => e.IS_DELETED == false && e.STATUS == PFStandardStatus.Archived && e.CREATE_TIME >= dateTime;
var monitors = this.GetEntities<T_PT_MONITOR_ASSESSMENT>(expression, filter,new string[] { "Nav_Details" });
if (monitors != null && monitors.Any())
{
var monitor = monitors.Where(e => e.IS_DELETED == false && e.STATUS == PFStandardStatus.Archived && e.CREATE_TIME >= dateTime).ToList();
var users = this.GetEntities<T_FM_USER>(t => t.ENABLE_STATUS == 0, new BaseFilter(filter.OrgId));
foreach (var item in monitor)
{
if (item.Nav_Details != null && item.Nav_Details.Any())
{
var userIds = item.Nav_Details.Where(t => t.USER_ID != null).Select(m =>(Guid)m.USER_ID).Distinct().ToList();
var userNames = users.Where(t => userIds.Contains(t.ID)).Select(m => m.NAME).ToList();
//发消息
var notices = NotificationTaskService.InsertUserNoticeTaskModels("(月度)个人监测与考核记录-查阅", item.ID, item.ORG_ID, userIds, userNames, DateTime.Now,
DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "PT029_SHOWPRINT");
noticeList.AddRange(notices);
}
}
}
UnifiedCommit(() =>
{
if (noticeList != null && noticeList.Any())
BantchAddEntityNoCommit(noticeList);
});
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 方针与目标模块所有跑批
/// </summary>
/// <returns></returns>
[HttpPost, Route("SafetyPolicySync")]
public JsonActionResult<bool> SafetyPolicySync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
//触发安全方针调查表
CreateSafePolicy(filter);
////触发安全生产目标与指标制定
CreateIndicatorFormulation(filter);
////触发安全生产方针征集表
//CreateSafePolicyCollect(filter);
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 触发安全生产方针征集表
/// </summary>
/// <returns></returns>
[HttpPost, Route("SafePolicyCollectSync")]
public JsonActionResult<bool> SafePolicyCollectSync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
////触发安全生产方针征集表
CreateSafePolicyCollect(filter);
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 触发班组监测与考核记录表
/// </summary>
/// <param name="filter"></param>
[HttpPost, Route("MonitorAssessmentSync")]
public JsonActionResult<bool> MonitorAssessmentSync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
var dtNow = DateTime.Now;
var month = dtNow.Month;
var day = dtNow.Day;
var time = dtNow.TimeOfDay;
var week = dtNow.DayOfWeek;
Expression<Func<T_PT_TIME_SET, bool>> expression = e => e.IS_DELETED == false && e.ENABLE_STATUS == 0;
var timeSet = this.GetOrderEntities<T_PT_TIME_SET>(expression, filter).ToList();
if (timeSet.Count < 1)
return true;
List<T_PT_TIME_SET> runList = new List<T_PT_TIME_SET>();
List<T_PT_MONITOR_ASSESSMENT> monitorList = new List<T_PT_MONITOR_ASSESSMENT>();
List<T_PT_MONITOR_ASSESSMENT_DETAIL> monitorDetailList = new List<T_PT_MONITOR_ASSESSMENT_DETAIL>();
List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT> detailContentList = new List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT>();
List<T_FM_NOTIFICATION_TASK> notices = new List<T_FM_NOTIFICATION_TASK>();
foreach (var item in timeSet)
{
switch (item.PLANCHECKFREQUENCY)
{
//case BSPLANCHECKFREQUENCYEnum.OneTime:
case BSPLANCHECKFREQUENCYEnum.Year:
if (item.MONTH == month && item.DATA == day)
runList.Add(item);
break;
case BSPLANCHECKFREQUENCYEnum.HalfYear:
if ((item.MONTH == month && item.DATA == day) || ((item.MONTH + 6) == month && (item.DATA + 183) == day))
runList.Add(item);
break;
case BSPLANCHECKFREQUENCYEnum.Date:
runList.Add(item);
break;
case BSPLANCHECKFREQUENCYEnum.Week:
if (item.WEEKDATA != null && (int)item.WEEKDATA.Value == (int)week)
runList.Add(item);
break;
case BSPLANCHECKFREQUENCYEnum.Month:
if (item.DATA == day)
runList.Add(item);
break;
case BSPLANCHECKFREQUENCYEnum.Quarter:
if (item.MONTH == 1)
{
if ((month == 1 || month == 4 || month == 7 || month == 10) && day == item.DATA)
{
runList.Add(item);
}
}
else if (item.MONTH == 2)
{
if ((month == 2 || month == 5 || month == 8 || month == 11) && day == item.DATA)
{
runList.Add(item);
}
}
else if (item.MONTH == 3)
{
if ((month == 3 || month == 6 || month == 9 || month == 12) && day == item.DATA)
{
runList.Add(item);
}
}
break;
default:
break;
}
}
if (runList != null && runList.Any())
{
Expression<Func<T_FM_DEPARTMENT, bool>> departExpression = e => e.IS_DELETED == false && e.ENABLE_STATUS == 0;
var departInfos = this.GetOrderEntities<T_FM_DEPARTMENT>(departExpression, filter, new string[] { "Nav_User" }).ToList();
Expression<Func<T_FM_USER, bool>> userExpression = e => e.IS_DELETED == false && e.ENABLE_STATUS == 0;
var userInfos = this.GetOrderEntities<T_FM_USER>(userExpression, filter, new string[] { "Nav_Department" }).ToList();
Expression<Func<T_PT_ASSESSMENT_PLAN_AUDIT_TEMP_DETAIL, bool>> detailExpression = e => e.IS_DELETED == false;
var tempDetails = this.GetOrderEntities<T_PT_ASSESSMENT_PLAN_AUDIT_TEMP_DETAIL>(detailExpression, filter, new string[] { "Nav_Contents" }).ToList();
foreach (var item in runList)
{
var type = PTAssessmentCycleEnums.Year;
switch (item.PLANCHECKFREQUENCY)
{
//case BSPLANCHECKFREQUENCYEnum.OneTime:
case BSPLANCHECKFREQUENCYEnum.Year:
type = PTAssessmentCycleEnums.Year;
break;
//case BSPLANCHECKFREQUENCYEnum.HalfYear:
// type = PTAssessmentCycleEnums.Year;
// break;
case BSPLANCHECKFREQUENCYEnum.Date:
type = PTAssessmentCycleEnums.Day;
break;
case BSPLANCHECKFREQUENCYEnum.Week:
type = PTAssessmentCycleEnums.Week;
break;
case BSPLANCHECKFREQUENCYEnum.Month:
type = PTAssessmentCycleEnums.Month;
break;
case BSPLANCHECKFREQUENCYEnum.Quarter:
type = PTAssessmentCycleEnums.Quarter;
break;
default:
break;
}
var departType = -1;
switch (item.DEPARTMENT_TYPE)
{
人员导入 功能添加 子公司 自行导入 总公司人员 同步导入到各子公司 FMDepartmentType 修改
2025-09-05 14:37:58 +08:00
case FMDepartmentType.Company:
仓库复制
2025-08-25 09:56:57 +08:00
departType = 0;
break;
人员导入 功能添加 子公司 自行导入 总公司人员 同步导入到各子公司 FMDepartmentType 修改
2025-09-05 14:37:58 +08:00
case FMDepartmentType.Department:
仓库复制
2025-08-25 09:56:57 +08:00
departType = 1;
break;
人员导入 功能添加 子公司 自行导入 总公司人员 同步导入到各子公司 FMDepartmentType 修改
2025-09-05 14:37:58 +08:00
case FMDepartmentType.Workshop:
仓库复制
2025-08-25 09:56:57 +08:00
departType = 2;
break;
人员导入 功能添加 子公司 自行导入 总公司人员 同步导入到各子公司 FMDepartmentType 修改
2025-09-05 14:37:58 +08:00
case FMDepartmentType.Class:
仓库复制
2025-08-25 09:56:57 +08:00
departType = -1;
break;
default:
departType = -1;
break;
}
monitorList.AddRange(CreateDepartMonitor(item, type, departInfos, userInfos, tempDetails, departType, ref notices));
}
}
if (monitorList != null && monitorList.Any())
{
monitorList.ForEach(t =>
{
if (t.Nav_Details != null && t.Nav_Details.Any())
{
t.Nav_Details.ForEach(t1 =>
{
if (t1.Nav_Contents != null && t1.Nav_Contents.Any())
{
detailContentList.AddRange(t1.Nav_Contents);
t1.Nav_Contents = null;
}
});
monitorDetailList.AddRange(t.Nav_Details);
t.Nav_Details = null;
}
});
}
UnifiedCommit(() =>
{
if (monitorList != null && monitorList.Any())
BantchAddEntityNoCommit(monitorList);
if (monitorDetailList != null && monitorDetailList.Any())
BantchAddEntityNoCommit(monitorDetailList);
if (detailContentList != null && detailContentList.Any())
BantchAddEntityNoCommit(detailContentList);
if (notices != null && notices.Any())
BantchAddEntityNoCommit(notices);
});
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 触发班组监测与考核记录表(新)
/// </summary>
/// <param name="filter"></param>
[HttpPost, Route("MonitorAssessmentNewSync")]
public JsonActionResult<bool> MonitorAssessmentNewSync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
var dtNow = DateTime.Now;
var year = dtNow.Year;
var month = dtNow.Month;
var day = dtNow.Day;
var week = dtNow.DayOfWeek;
filter.IgnoreDataRule = true;
//var planAudits = this.GetEntities<T_PT_ASSESSMENT_PLAN_AUDIT>(e => e.STATUS == PFStandardStatus.Archived && e.IS_DELETED == false && e.YEAR == year.ToString(), filter, "Nav_User", "Nav_Details", "Nav_Details.Nav_Contents").GroupBy(m=>new { m.DEPARTMENT_ID,m.DEPARTMENT_TYPE }).Select(y=>y.OrderByDescending(t => t.CREATE_TIME).FirstOrDefault()).ToList();
//if (planAudits.Count < 1)
//{
// year = year - 1;
// planAudits = this.GetEntities<T_PT_ASSESSMENT_PLAN_AUDIT>(e => e.STATUS == PFStandardStatus.Archived && e.IS_DELETED == false && e.YEAR == year.ToString(), filter, "Nav_User", "Nav_Details", "Nav_Details.Nav_Contents").GroupBy(m => new { m.DEPARTMENT_ID,m.DEPARTMENT_TYPE}).Select(y => y.OrderByDescending(t => t.CREATE_TIME).FirstOrDefault()).ToList();
//}
//if (planAudits.Count < 1)
// return true;
List<T_PT_MONITOR_ASSESSMENT> monitorList = new List<T_PT_MONITOR_ASSESSMENT>();
List<T_PT_MONITOR_ASSESSMENT_DETAIL> monitorDetailList = new List<T_PT_MONITOR_ASSESSMENT_DETAIL>();
List<T_PT_MONITOR_ASSESSMENT_USER> monitorUserList = new List<T_PT_MONITOR_ASSESSMENT_USER>();
List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT> detailContentList = new List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT>();
List<T_FM_NOTIFICATION_TASK> notices = new List<T_FM_NOTIFICATION_TASK>();
var timeSet = GetEntities<T_PT_TIME_SET>(i => i.SET_TYPE == PTSetTypeEnum.MonitorAssessment && i.ENABLE_STATUS == 0, new BaseFilter(filter.OrgId)).ToList();
if (timeSet.Count < 1)
return true;
bool isSend = false;var cycle = PTAssessmentCycleEnums.Year;
var departments = this.GetEntities<T_FM_DEPARTMENT>(t => t.ENABLE_STATUS==0, new BaseFilter(filter.OrgId), "Nav_User").ToList();
if (filter.OrgId.ToString() == "b043b28b-bbc3-c452-6052-4fba1457abfa")
{
var idList = new List<Guid>();
var allIdList = new List<Guid>();
var nameList = new List<string>();
nameList.Add("安全环保管理部");
nameList.Add("办公室");
nameList.Add("设备能源部");
nameList.Add("财务部");
nameList.Add("企业管理部");
nameList.Add("营销部");
nameList.Add("技术管理部");
nameList.Add("总经理班子");
nameList.Add("矿山部");
var depaerts = departments.Where(t => nameList.Contains(t.NAME)).ToList();
if (depaerts.Any())
{
foreach (var item in depaerts)
{
allIdList.Add(item.ID);
var depatIds = departments.Where(t => t.PARENT_ID == item.ID).Select(m => m.ID).ToList();
if (depatIds.Any())
{
idList.AddRange(depatIds);
allIdList.AddRange(depatIds);
}
}
}
if (idList.Any())
{
var depatIds = departments.Where(t => t.PARENT_ID != null && idList.Contains((Guid)t.PARENT_ID)).Select(m => m.ID).ToList();
if (depatIds.Any())
{
allIdList.AddRange(depatIds);
}
}
if (allIdList.Any())
{
departments = departments.Where(t => !allIdList.Contains(t.ID)).ToList();
}
}
var users = this.GetEntities<T_FM_USER>(t => t.ENABLE_STATUS == 0, new BaseFilter(filter.OrgId)).ToList();
var contents = this.GetEntities<T_PT_ASSESSMENT_PLAN_AUDIT_TEMP_DETAIL>(t => !t.IS_DELETED, new BaseFilter(filter.OrgId), "Nav_Contents").ToList();
foreach (var set in timeSet)
{
switch (set.PLANCHECKFREQUENCY)
{
case BSPLANCHECKFREQUENCYEnum.Year:
cycle = PTAssessmentCycleEnums.Year;
if (set.MONTH == month && set.DATA == day)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.HalfYear:
cycle = PTAssessmentCycleEnums.HalfYear;
if ((set.MONTH == month && set.DATA == day) || ((set.MONTH + 6) == month && (set.DATA + 183) == day))
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Date:
cycle = PTAssessmentCycleEnums.Day;
isSend = true;
break;
case BSPLANCHECKFREQUENCYEnum.Week:
cycle = PTAssessmentCycleEnums.Week;
if (set.WEEKDATA != null && (int)set.WEEKDATA.Value == (int)week)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Month:
cycle = PTAssessmentCycleEnums.Month;
if (set.DATA == day)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Quarter:
cycle = PTAssessmentCycleEnums.Quarter;
if (set.MONTH == 1)
{
if ((month == 1 || month == 4 || month == 7 || month == 10) && set.DATA == day)
{
isSend = true;
}
}
if (set.MONTH == 2)
{
if ((month == 2 || month == 5 || month == 8 || month == 11) && set.DATA == day)
{
isSend = true;
}
}
if (set.MONTH == 3)
{
if ((month == 3 || month == 6 || month == 9 || month == 12) && set.DATA == day)
{
isSend = true;
}
}
break;
default:
break;
}
if (isSend)
{
人员导入 功能添加 子公司 自行导入 总公司人员 同步导入到各子公司 FMDepartmentType 修改
2025-09-05 14:37:58 +08:00
if (set.DEPARTMENT_TYPE == FMDepartmentType.Company)
仓库复制
2025-08-25 09:56:57 +08:00
{
var depart = departments.FirstOrDefault(t => t.NAME.Contains("安全环保") && t.DEPARTMENT_TYPE != 1 && t.DEPARTMENT_TYPE != 2);
if (depart != null)
{
var departList = departments.Where(t => t.DEPARTMENT_TYPE == 3 || t.DEPARTMENT_TYPE == 0).ToList();
var companyId = departList.FirstOrDefault(t => t.DEPARTMENT_TYPE == 3).ID;
var userIds = departList.Where(t => t.DEPARTMENT_TYPE != 3).Select(m => m.USER_ID).ToList();
var userList = users.Where(t => userIds.Contains(t.ID) || t.DEPARTMENT_ID == companyId).ToList();
if (!departList.Any() && !userList.Any())
{
}
else
{
monitorList.Add(CreateDepartMonitorNew(depart, departList, userList, contents, cycle, year.ToString(), ref notices));
}
}
}
人员导入 功能添加 子公司 自行导入 总公司人员 同步导入到各子公司 FMDepartmentType 修改
2025-09-05 14:37:58 +08:00
else if (set.DEPARTMENT_TYPE == FMDepartmentType.Class)
仓库复制
2025-08-25 09:56:57 +08:00
{
var departList = departments.Where(t => t.DEPARTMENT_TYPE == 2).ToList();
if (departList.Any())
{
foreach (var item in departList)
{
var userList = users.Where(t => t.DEPARTMENT_ID == item.ID && t.ID != item.USER_ID).ToList();
if (userList.Any())
{
monitorList.Add(CreateDepartMonitorNew(item, null, userList, contents, cycle, year.ToString(), ref notices));
}
}
}
}
else
{
var departs = departments.Where(t => t.DEPARTMENT_TYPE == (int)set.DEPARTMENT_TYPE).ToList();
if (departs.Any())
{
foreach (var item in departs)
{
var departList = departments.Where(t => t.PARENT_ID == item.ID).ToList();
var childUserIds = departList.Select(t => t.USER_ID).ToList();
var userList = users.Where(t => t.DEPARTMENT_ID == item.ID || childUserIds.Contains(t.ID)).ToList();
if (!departList.Any() && !userList.Any())
{
}
else
{
monitorList.Add(CreateDepartMonitorNew(item, departList, userList, contents, cycle, year.ToString(), ref notices));
}
}
}
}
//年度
//var dataYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.Year && t.YEAR == year.ToString()).ToList();
//if (dataYears.Count() > 0)
//{
// monitorList.Add(CreateDepartMonitorNew(item, dataYears, PTAssessmentCycleEnums.Year, year.ToString(), ref notices));
//}
////上半年度
//List<int> monthTemp = new List<int>() { 1, 2, 3, 4, 5, 6 };
//var dataHalfYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.HalfYear && t.YEAR == year.ToString() && monthTemp.Contains(t.CREATE_TIME.Value.Month)).ToList();
//if (dataHalfYears.Count() > 0)
//{
// monitorList.Add(CreateDepartMonitorNew(item, dataHalfYears, PTAssessmentCycleEnums.HalfYear, year.ToString(), ref notices));
//}
////下半年度
//monthTemp = new List<int>() { 7, 8, 9, 10, 11, 12 };
//var dataHalfSecondYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.HalfYear && t.YEAR == (year - 1).ToString() && monthTemp.Contains(t.CREATE_TIME.Value.Month)).ToList();
//if (dataHalfSecondYears.Count() > 0)
//{
// if (month == 1 && day == 1)
// {
// monitorList.Add(CreateDepartMonitorNew(item, dataHalfSecondYears, PTAssessmentCycleEnums.HalfYear, (year - 1).ToString(), ref notices));
// }
//}
////季度(第四季度)
//monthTemp = new List<int>() { 12 };
//var dataThirdQuarterYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.Quarter && t.YEAR == (year - 1).ToString() && monthTemp.Contains(t.CREATE_TIME.Value.Month)).ToList();
//if (dataThirdQuarterYears.Count() > 0)
//{
// if (month == 1 && day == 1)
// {
// monitorList.Add(CreateDepartMonitorNew(item, dataThirdQuarterYears, PTAssessmentCycleEnums.Quarter, (year - 1).ToString(), ref notices));
// }
//}
////季度(第1、2、3季度)
//var dataQuarterYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.Quarter && t.YEAR == year.ToString() && monthTemp.Contains(t.CREATE_TIME.Value.Month)).ToList();
//if (dataQuarterYears.Count() > 0)
//{
// if ((month == 4 && day == 1) || (month == 7 && day == 1) || (month == 10 && (day == 28 || day == 29)))
// {
// monthTemp = new List<int>() { month - 1 };
// monitorList.Add(CreateDepartMonitorNew(item, dataQuarterYears, PTAssessmentCycleEnums.Quarter, year.ToString(), ref notices));
// }
//}
////月度
//monthTemp = new List<int>() { month - 1 };
//var dataMonthYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.Month && t.YEAR == year.ToString() && monthTemp.Contains(t.CREATE_TIME.Value.Month)).ToList();
//if (dataMonthYears.Count() > 0)
//{
// if (month != 1 && day == 1)
// {
// monitorList.Add(CreateDepartMonitorNew(item, dataMonthYears, PTAssessmentCycleEnums.Month, year.ToString(), ref notices));
// }
//}
////月度(第十二月)
//monthTemp = new List<int>() { 12 };
//var dataLastMonthYears = item.Nav_Details.Where(t => t.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.Month && t.YEAR == (year - 1).ToString() && monthTemp.Contains(t.CREATE_TIME.Value.Month)).ToList();
//if (dataLastMonthYears.Count() > 0)
//{
// if (month == 1 && day == 1)
// {
// monitorList.Add(CreateDepartMonitorNew(item, dataLastMonthYears, PTAssessmentCycleEnums.Month, (year - 1).ToString(), ref notices));
// }
//}
}
}
if (monitorList != null && monitorList.Any())
{
monitorList = monitorList.Where(t => t != null).ToList();
monitorList.ForEach(t =>
{
if (t != null && t.Nav_Details != null && t.Nav_Details.Any())
{
t.Nav_Details.ForEach(t1 =>
{
if (t1 != null && t1.Nav_Contents != null && t1.Nav_Contents.Any())
{
detailContentList.AddRange(t1.Nav_Contents);
t1.Nav_Contents = null;
}
});
monitorDetailList.AddRange(t.Nav_Details);
t.Nav_Details = null;
}
if (t != null && t.Nav_MonitorUser != null && t.Nav_MonitorUser.Any())
{
monitorUserList.AddRange(t.Nav_MonitorUser);
t.Nav_MonitorUser = null;
}
});
}
UnifiedCommit(() =>
{
//if (planAuditList != null && planAuditList.Any())
// BantchSaveEntityNoCommit(planAuditList);
if (monitorList != null && monitorList.Any())
BantchSaveEntityNoCommit(monitorList);
if (monitorDetailList != null && monitorDetailList.Any())
BantchAddEntityNoCommit(monitorDetailList);
if (monitorUserList != null && monitorUserList.Any())
BantchAddEntityNoCommit(monitorUserList);
if (detailContentList != null && detailContentList.Any())
BantchAddEntityNoCommit(detailContentList);
if (notices != null && notices.Any())
BantchAddEntityNoCommit(notices);
});
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 触发年度监测汇总表
/// </summary>
/// <param name="filter"></param>
[HttpPost, Route("YearMonitorSummarySync")]
public JsonActionResult<bool> YearMonitorSummarySync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
var dtNow = DateTime.Now;
var year = dtNow.Year;
var month = dtNow.Month;
var day = dtNow.Day;
var time = dtNow.TimeOfDay;
var week = dtNow.DayOfWeek;
T_PT_ANNUAL_MONOTOR_SUMMARY summary = null;
List<T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL> summaryDetailList = new List<T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL>();
List<T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT> detailContentList = new List<T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT>();
T_FM_NOTIFICATION_TASK notice = null;
if (month == 1 && day == 15)
{
var userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部负责人" && t.ENABLE_STATUS == 0);
if (userInfo == null && filter.OrgId.ToString() == "3efd5276-632b-e379-9ff3-7a7546591fca")
{
userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部安全员" && t.ENABLE_STATUS == 0);
}
if (userInfo != null)
{
Expression<Func<T_PT_MONITOR_ASSESSMENT, bool>> expression = e => e.IS_DELETED == false && e.YEAR == (year - 1).ToString() && e.ASSESSMENT_CYCLE == PTAssessmentCycleEnums.Quarter;
var monitorAssessment = this.GetOrderEntities<T_PT_MONITOR_ASSESSMENT>(expression, filter).ToList();
if (monitorAssessment.Count < 1)
return true;
summary = new T_PT_ANNUAL_MONOTOR_SUMMARY();
summary.ORG_ID = filter.OrgId;
summary.YEAR = (year - 1).ToString();
summary.SET_TIME = dtNow;
summary.STATUS = PFStandardStatus.Sign;
Expression<Func<T_FM_DEPARTMENT, bool>> departExpression = e => e.IS_DELETED == false && e.ENABLE_STATUS == 0;
var departmentIds = this.GetOrderEntities<T_FM_DEPARTMENT>(departExpression, filter).Select(t => new { t.ID, t.DEPARTMENT_TYPE }).Distinct().ToList();
if (departmentIds != null && departmentIds.Any())
{
foreach (var department in departmentIds)
{
T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL detail = new T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL();
detail.ORG_ID = filter.OrgId;
detail.MONITOR_SUMMARY_ID = summary.ID;
detail.DEPARTMENT_ID = department.ID;
detail.DEPARTMENT_TYPE = (FMDepartmentType)department.DEPARTMENT_TYPE;
summaryDetailList.Add(detail);
}
}
Expression<Func<T_FM_USER, bool>> userExpression = e => e.IS_DELETED == false && e.ENABLE_STATUS == 0;
var userIds = this.GetOrderEntities<T_FM_USER>(userExpression, filter, "Nav_Department").Where(m => m.DEPARTMENT_ID != null).Select(t => new { t.ID, t.DEPARTMENT_ID, DEPARTMENT_TYPE = t.Nav_Department.DEPARTMENT_TYPE }).Distinct().ToList();
if (userIds != null && userIds.Any())
{
foreach (var user in userIds)
{
T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL detail = new T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL();
detail.ORG_ID = filter.OrgId;
detail.MONITOR_SUMMARY_ID = summary.ID;
detail.DEPARTMENT_ID = user.DEPARTMENT_ID;
detail.USER_ID = user.ID;
detail.DEPARTMENT_TYPE = (FMDepartmentType)user.DEPARTMENT_TYPE;
summaryDetailList.Add(detail);
}
}
if (departmentIds.Count() == 0 && userIds.Count() == 0)
summary = null;
if (summaryDetailList != null && summaryDetailList.Any())
{
var monitorIds = monitorAssessment.Select(t => t.ID).ToList();
var monitorDetails = this.GetEntities<T_PT_MONITOR_ASSESSMENT_DETAIL>(t => monitorIds.Contains(t.MONITOR_ASSESSMENT_ID), new BaseFilter(filter.OrgId), "Nav_Contents").ToList();
foreach (var summaryDetail in summaryDetailList)
{
//第一季度
var firtstQuarter = monitorDetails.FirstOrDefault(t => t.DEPARTMENT_ID == summaryDetail.DEPARTMENT_ID && t.USER_ID == summaryDetail.USER_ID && t.CREATE_TIME.Value.Year == (year - 1) && t.CREATE_TIME.Value.Month == 4 && t.CREATE_TIME.Value.Day == 1);
if (firtstQuarter != null && firtstQuarter.Nav_Contents != null && firtstQuarter.Nav_Contents.Any())
{
summaryDetail.FIRST_SCORE = firtstQuarter.Nav_Contents.Where(m => m.RESULT_SCORE != null).Sum(t => t.RESULT_SCORE);
foreach (var c in firtstQuarter.Nav_Contents)
{
T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT content = new T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT();
content.ORG_ID = c.ORG_ID;
content.MONOTOR_SUMMARY_DETAIL_ID = summaryDetail.ID;
content.ROW_NO = c.ROW_NO;
content.METHOD = c.METHOD;
content.SCORE = c.SCORE;
content.NAME = c.NAME;
content.QUARTER_TYPE = PTQuarterTypeEnum.FirstQuarter;
detailContentList.Add(content);
}
}
//第二季度
var secondQuarter = monitorDetails.FirstOrDefault(t => t.DEPARTMENT_ID == summaryDetail.DEPARTMENT_ID && t.USER_ID == summaryDetail.USER_ID && t.CREATE_TIME.Value.Year == (year - 1) && t.CREATE_TIME.Value.Month == 7 && t.CREATE_TIME.Value.Day == 1);
if (secondQuarter != null && secondQuarter.Nav_Contents != null && secondQuarter.Nav_Contents.Any())
{
summaryDetail.SECOND_SCORE = secondQuarter.Nav_Contents.Where(m => m.RESULT_SCORE != null).Sum(t => t.RESULT_SCORE);
foreach (var c in secondQuarter.Nav_Contents)
{
T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT content = new T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT();
content.ORG_ID = c.ORG_ID;
content.MONOTOR_SUMMARY_DETAIL_ID = summaryDetail.ID;
content.ROW_NO = c.ROW_NO;
content.METHOD = c.METHOD;
content.SCORE = c.SCORE;
content.NAME = c.NAME;
content.QUARTER_TYPE = PTQuarterTypeEnum.SecondQuarter;
detailContentList.Add(content);
}
}
//第三季度
var thirdQuarter = monitorDetails.FirstOrDefault(t => t.DEPARTMENT_ID == summaryDetail.DEPARTMENT_ID && t.USER_ID == summaryDetail.USER_ID && t.CREATE_TIME.Value.Year == (year - 1) && t.CREATE_TIME.Value.Month == 10 && t.CREATE_TIME.Value.Day == 11);
if (thirdQuarter != null && thirdQuarter.Nav_Contents != null && thirdQuarter.Nav_Contents.Any())
{
summaryDetail.THIRD_SCORE = thirdQuarter.Nav_Contents.Where(m => m.RESULT_SCORE != null).Sum(t => t.RESULT_SCORE);
foreach (var c in thirdQuarter.Nav_Contents)
{
T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT content = new T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT();
content.ORG_ID = c.ORG_ID;
content.MONOTOR_SUMMARY_DETAIL_ID = summaryDetail.ID;
content.ROW_NO = c.ROW_NO;
content.METHOD = c.METHOD;
content.SCORE = c.SCORE;
content.NAME = c.NAME;
content.QUARTER_TYPE = PTQuarterTypeEnum.ThirdQuarter;
detailContentList.Add(content);
}
}
//第四季度
var fourthQuarter = monitorDetails.FirstOrDefault(t => t.DEPARTMENT_ID == summaryDetail.DEPARTMENT_ID && t.USER_ID == summaryDetail.USER_ID && t.CREATE_TIME.Value.Year == year && t.CREATE_TIME.Value.Month == 1 && t.CREATE_TIME.Value.Day == 1);
if (fourthQuarter != null && fourthQuarter.Nav_Contents != null && fourthQuarter.Nav_Contents.Any())
{
summaryDetail.FOURTH_SCORE = fourthQuarter.Nav_Contents.Where(m => m.RESULT_SCORE != null).Sum(t => t.RESULT_SCORE);
foreach (var c in fourthQuarter.Nav_Contents)
{
T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT content = new T_PT_ANNUAL_MONOTOR_SUMMARY_DETAIL_CONTENT();
content.ORG_ID = c.ORG_ID;
content.MONOTOR_SUMMARY_DETAIL_ID = summaryDetail.ID;
content.ROW_NO = c.ROW_NO;
content.METHOD = c.METHOD;
content.SCORE = c.SCORE;
content.NAME = c.NAME;
content.QUARTER_TYPE = PTQuarterTypeEnum.FourthQuarter;
detailContentList.Add(content);
}
}
//年度
summaryDetail.YEAR_SCORE = (summaryDetail.FIRST_SCORE ?? 0) + (summaryDetail.SECOND_SCORE ?? 0) + (summaryDetail.THIRD_SCORE ?? 0) + (summaryDetail.FOURTH_SCORE ?? 0);
}
}
notice = NotificationTaskService.InsertUserNoticeTaskModel("年度监测汇总表", summary.ID, filter.GetOrgId(), userInfo.ID, userInfo.NAME, DateTime.Now, DateTime.Now.AddDays(30), (int)FMNoticeTypeEnum.消息, "PT036_SHOWPRINT");
}
}
UnifiedCommit(() =>
{
if (summary != null)
UpdateEntityNoCommit(summary);
if (summaryDetailList != null && summaryDetailList.Any())
BantchAddEntityNoCommit(summaryDetailList);
if (detailContentList != null && detailContentList.Any())
BantchAddEntityNoCommit(detailContentList);
if (notice != null)
UpdateEntityNoCommit(notice);
});
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 清除安全生产方针调查表待办
/// </summary>
/// <returns></returns>
[HttpPost, Route("DealSafePolicySync")]
public JsonActionResult<bool> DealSafePolicySync([FromBody] KeywordFilter filter)
{
return SafeExecute<bool>(() =>
{
try
{
var miniTime = DateTime.Now.ToString("yyyy/MM/dd 00:00:00", System.Globalization.DateTimeFormatInfo.InvariantInfo);
var maxTime = DateTime.Now.ToString("yyyy/MM/dd 23:59:59", System.Globalization.DateTimeFormatInfo.InvariantInfo);
var tasks = new List<T_FM_NOTIFICATION_TASK>();
var safetys = GetEntities<T_PT_SAFETY_POLICY_SURVEY>(i => i.COMPLETE_DATE >= Convert.ToDateTime(miniTime) && i.COMPLETE_DATE <= Convert.ToDateTime(maxTime) && i.IS_DEAL == 0, new BaseFilter(filter.OrgId));
if (safetys != null && safetys.Any())
{
var createTime = safetys.FirstOrDefault().CREATE_TIME;
safetys.ForEach(t =>
{
t.IS_DEAL = 1;
if (t.CREATE_TIME < createTime)
createTime = t.CREATE_TIME;
});
var safetyIds = safetys.Select(i => i.ID).ToList();
tasks = this.GetEntities<T_FM_NOTIFICATION_TASK>(t => t.CREATE_TIME > createTime && safetyIds.Contains(t.SOURCE_DATA_ID.Value) && t.NOTICE_STATUS == 0, new BaseFilter(filter.OrgId)).ToList();
if (tasks != null && tasks.Any())
{
tasks.ForEach(t =>
{
t.NOTICE_STATUS = 4;
});
}
}
UnifiedCommit(() =>
{
if (safetys != null && safetys.Any())
BantchSaveEntityNoCommit(safetys);
if (tasks != null && tasks.Any())
BantchSaveEntityNoCommit(tasks);
});
}
catch (Exception ex)
{
if (!string.IsNullOrEmpty(ex.StackTrace))
throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
else
throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
}
return true;
});
}
/// <summary>
/// 触发安全生产方针征集表
/// </summary>
/// <param name="filter"></param>
private void CreateSafePolicyCollect([FromBody] KeywordFilter filter)
{
var miniTime = DateTime.Now.ToString("yyyy/MM/dd 00:00:00", System.Globalization.DateTimeFormatInfo.InvariantInfo);
var maxTime = DateTime.Now.ToString("yyyy/MM/dd 23:59:59", System.Globalization.DateTimeFormatInfo.InvariantInfo);
filter.IgnoreDataRule = true;
var safetyLists = GetEntities<T_PT_SAFETY_POLICY_SURVEY>(i => i.COMPLETE_DATE >= Convert.ToDateTime(miniTime) && i.COMPLETE_DATE <= Convert.ToDateTime(maxTime) && i.IS_RUN == 0, filter).ToList();
List<T_FM_NOTIFICATION_TASK> sendNotices = null;
//List<T_PT_SAFETY_POLICY_SURVEY> survey = null;
if (safetyLists != null && safetyLists.Any())
{
var userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部负责人" && t.ENABLE_STATUS == 0);
if (userInfo == null && filter.OrgId.ToString() == "3efd5276-632b-e379-9ff3-7a7546591fca")
{
userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部安全员" && t.ENABLE_STATUS == 0);
}
if (userInfo != null)
{
sendNotices = new List<T_FM_NOTIFICATION_TASK>();
safetyLists.ForEach(t =>
{
t.IS_RUN = 1;
//survey.Add(t);
sendNotices.Add(NotificationTaskService.InsertUserNoticeTaskModel("安全生产方针征集表", t.ID, filter.GetOrgId(), userInfo.ID, userInfo.NAME, DateTime.Now, DateTime.Now.AddDays(30), (int)FMNoticeTypeEnum.消息, "PT014_SHOWPRINT"));
});
}
}
UnifiedCommit(() =>
{
if (safetyLists != null && safetyLists.Any())
BantchSaveEntityNoCommit(safetyLists);
if (sendNotices != null && sendNotices.Any())
BantchAddEntityNoCommit(sendNotices);
});
}
/// <summary>
/// 触发安全方针调查表
/// </summary>
/// <param name="filter"></param>
private void CreateSafePolicy([FromBody] KeywordFilter filter)
{
var dtNow = DateTime.Now;
var year = dtNow.Year;
var month = dtNow.Month;
var day = dtNow.Day;
var time = dtNow.TimeOfDay;
var week = dtNow.DayOfWeek;
T_FM_NOTIFICATION_TASK sendNotice = null;
T_PT_SAFETY_POLICY_SURVEY safety = null;
var newFilter = new BaseFilter(filter.OrgId);
newFilter.SelectField = new List<string> { "ID", "NAME" };
var userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部负责人" && t.ENABLE_STATUS == 0, newFilter);
if (userInfo == null && filter.OrgId.ToString() == "3efd5276-632b-e379-9ff3-7a7546591fca")
{
userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部安全员" && t.ENABLE_STATUS == 0);
}
if (userInfo != null)
{
bool isSend = false;
newFilter.SelectField = new List<string> { "PLANCHECKFREQUENCY", "MONTH", "DATA", "WEEKDATA" };
var timeSet = GetEntity<T_PT_TIME_SET>(i => i.SET_TYPE == PTSetTypeEnum.SafePolicy && i.ENABLE_STATUS == 0, newFilter);
if (timeSet != null && dtNow.Hour == 8)
{
switch (timeSet.PLANCHECKFREQUENCY)
{
case BSPLANCHECKFREQUENCYEnum.Year:
if (timeSet.MONTH == month && timeSet.DATA == day)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.HalfYear:
if ((timeSet.MONTH == month && timeSet.DATA == day) || ((timeSet.MONTH + 6) == month && (timeSet.DATA + 183) == day))
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Date:
isSend = true;
break;
case BSPLANCHECKFREQUENCYEnum.Week:
if (timeSet.WEEKDATA != null && (int)timeSet.WEEKDATA.Value == (int)week)
isSend = true;
break;
case BSPLANCHECKFREQUENCYEnum.Month:
if (timeSet.DATA == day)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Quarter:
if (timeSet.MONTH == 1)
{
if ((month == 1 || month == 4 || month == 7 || month == 10) && timeSet.DATA == day)
isSend = true;
}
if (timeSet.MONTH == 2)
{
if ((month == 2 || month == 5 || month == 8 || month == 11) && timeSet.DATA == day)
isSend = true;
}
if (timeSet.MONTH == 3)
{
if ((month == 3 || month == 6 || month == 9 || month == 12) && timeSet.DATA == day)
isSend = true;
}
break;
default:
break;
}
}
if (isSend)
{
var safe = this.GetEntity<T_PT_SAFETY_POLICY_SURVEY>(t => t.USER_ID == userInfo.ID && t.CREATE_TIME.Value.Date == dtNow.Date);
if (safe == null)
{
safety = new T_PT_SAFETY_POLICY_SURVEY();
safety.ORG_ID = filter.GetOrgId();
safety.USER_ID = userInfo.ID;
safety.DEPARTMENT_ID = userInfo.DEPARTMENT_ID;
safety.YEAR = DateTime.Now.Year.ToString();
sendNotice = NotificationTaskService.InsertUserNoticeTaskModel("安全生产方针调查表", safety.ID, filter.GetOrgId(), userInfo.ID, userInfo.NAME, DateTime.Now, DateTime.Now.AddDays(30), (int)FMNoticeTypeEnum.消息, "PT014");
}
}
}
UnifiedCommit(() =>
{
if (safety != null)
UpdateEntityNoCommit(safety);
if (sendNotice != null)
UpdateEntityNoCommit(sendNotice);
});
}
/// <summary>
/// 触发安全生产目标与指标制定
/// </summary>
/// <param name="filter"></param>
private void CreateIndicatorFormulation([FromBody] KeywordFilter filter)
{
var dtNow = DateTime.Now;
var year = dtNow.Year;
var month = dtNow.Month;
var day = dtNow.Day;
var time = dtNow.TimeOfDay;
var week = dtNow.DayOfWeek;
T_FM_NOTIFICATION_TASK sendNotice = null;
T_PT_INDICATOR_FORMULATION indicator = null;
var newFilter = new BaseFilter(filter.OrgId);
newFilter.SelectField = new List<string> { "ID", "NAME" };
var userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部负责人" && t.ENABLE_STATUS == 0, newFilter);
if (userInfo == null && filter.OrgId.ToString() == "3efd5276-632b-e379-9ff3-7a7546591fca")
{
userInfo = this.GetEntity<T_FM_USER>(t => t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME == "安环部安全员" && t.ENABLE_STATUS == 0);
}
if (userInfo != null)
{
bool isSend = false;
newFilter.SelectField = new List<string> { "PLANCHECKFREQUENCY", "MONTH", "DATA", "WEEKDATA" };
var timeSet = GetEntity<T_PT_TIME_SET>(i => i.SET_TYPE == PTSetTypeEnum.IndicatorForm && i.ENABLE_STATUS == 0, newFilter);
if (timeSet != null && dtNow.Hour == 8)
{
switch (timeSet.PLANCHECKFREQUENCY)
{
case BSPLANCHECKFREQUENCYEnum.Year:
if (timeSet.MONTH == month && timeSet.DATA == day)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.HalfYear:
if ((timeSet.MONTH == month && timeSet.DATA == day) || ((timeSet.MONTH + 6) == month && (timeSet.DATA + 183) == day))
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Date:
isSend = true;
break;
case BSPLANCHECKFREQUENCYEnum.Week:
if (timeSet.WEEKDATA != null && (int)timeSet.WEEKDATA.Value == (int)week)
isSend = true;
break;
case BSPLANCHECKFREQUENCYEnum.Month:
if (timeSet.DATA == day)
{
isSend = true;
}
break;
case BSPLANCHECKFREQUENCYEnum.Quarter:
if (timeSet.MONTH == 1)
{
if ((month == 1 || month == 4 || month == 7 || month == 10) && timeSet.DATA == day)
isSend = true;
}
if (timeSet.MONTH == 2)
{
if ((month == 2 || month == 5 || month == 8 || month == 11) && timeSet.DATA == day)
isSend = true;
}
if (timeSet.MONTH == 3)
{
if ((month == 3 || month == 6 || month == 9 || month == 12) && timeSet.DATA == day)
isSend = true;
}
break;
default:
break;
}
}
if (isSend)
{
var safe = this.GetEntity<T_PT_INDICATOR_FORMULATION>(t => t.USER_ID == userInfo.ID && t.CREATE_TIME.Value.Date == dtNow.Date);
if (safe == null)
{
indicator = new T_PT_INDICATOR_FORMULATION();
indicator.ORG_ID = filter.GetOrgId();
indicator.USER_ID = userInfo.ID;
indicator.DEPARTMENT_ID = userInfo.DEPARTMENT_ID;
indicator.YEAR = DateTime.Now.Year.ToString();
indicator.NAME = "安全生产目标与指标制定";
sendNotice = NotificationTaskService.InsertUserNoticeTaskModel("安全生产目标与指标制定表", indicator.ID, filter.GetOrgId(), userInfo.ID, userInfo.NAME, DateTime.Now, DateTime.Now.AddDays(30), (int)FMNoticeTypeEnum.消息, "PT017");
}
}
}
UnifiedCommit(() =>
{
if (indicator != null)
UpdateEntityNoCommit(indicator);
if (sendNotice != null)
UpdateEntityNoCommit(sendNotice);
});
}
/// <summary>
/// 触发班组监测与考核记录表
/// </summary>
/// <param name="item"></param>
/// <param name="type"></param>
/// <param name="departInfos"></param>
/// <param name="tempDetails"></param>
/// <param name="userInfos"></param>
/// <param name="departType"></param>
/// <param name="notices"></param>
private List<T_PT_MONITOR_ASSESSMENT> CreateDepartMonitor(T_PT_TIME_SET item, PTAssessmentCycleEnums type, List<T_FM_DEPARTMENT> departInfos, List<T_FM_USER> userInfos, List<T_PT_ASSESSMENT_PLAN_AUDIT_TEMP_DETAIL> tempDetails, int departType, ref List<T_FM_NOTIFICATION_TASK> notices)
{
var result = new List<T_PT_MONITOR_ASSESSMENT>();
var departAlls = departInfos.Where(t => t.DEPARTMENT_TYPE == (int)item.DEPARTMENT_TYPE).ToList();
if (departAlls != null && departAlls.Any())
{
//var userIds = departmentInfos.Select(t => t.USER_ID).Distinct().ToList();
foreach (var depart in departAlls)
{
if (depart.USER_ID != null)
{
T_PT_MONITOR_ASSESSMENT newDepart = new T_PT_MONITOR_ASSESSMENT();
newDepart.ORG_ID = depart.ORG_ID;
newDepart.DEPARTMENT_TYPE = (FMDepartmentType)depart.DEPARTMENT_TYPE;
newDepart.SET_TIME = DateTime.Now;
newDepart.USER_ID = depart.USER_ID;
newDepart.DEPARTMENT_ID = depart.ID;
newDepart.YEAR = DateTime.Now.Year.ToString();
newDepart.ASSESSMENT_CYCLE = type;
var details = new List<T_PT_MONITOR_ASSESSMENT_DETAIL>();
var departIds = departInfos.Where(t => t.DEPARTMENT_TYPE == departType && t.PARENT_ID == depart.ID).Select(t => t.ID).ToList();
var userInfoTemps = userInfos.Where(t => t.DEPARTMENT_ID == depart.ID).ToList();
var userIds = userInfoTemps.Select(t => t.ID).ToList();
if (departIds.Any())
{
foreach (var department in departIds)
{
//细表
T_PT_MONITOR_ASSESSMENT_DETAIL detail = new T_PT_MONITOR_ASSESSMENT_DETAIL();
detail.ORG_ID = newDepart.ORG_ID;
detail.DEPARTMENT_ID = department;
detail.MONITOR_ASSESSMENT_ID = newDepart.ID;
details.Add(detail);
}
}
if (userInfoTemps.Any())
{
foreach (var user in userInfoTemps)
{
//细表
T_PT_MONITOR_ASSESSMENT_DETAIL detail = new T_PT_MONITOR_ASSESSMENT_DETAIL();
detail.ORG_ID = newDepart.ORG_ID;
detail.DEPARTMENT_ID = user.DEPARTMENT_ID;
detail.USER_ID = user.ID;
detail.MONITOR_ASSESSMENT_ID = newDepart.ID;
details.Add(detail);
}
}
var temps = tempDetails.Where(t => (t.DEPARTMENT_ID != null && departIds.Contains(t.DEPARTMENT_ID.Value)) || (t.USER_ID != null && userIds.Contains(t.USER_ID.Value))).ToList();
if (details != null && details.Any())
{
details.ForEach(t =>
{
var tempCurrent = tempDetails.FirstOrDefault(t1 => t1.DEPARTMENT_ID == t.DEPARTMENT_ID && t1.USER_ID == t.USER_ID && t1.YEAR == newDepart.YEAR);
if (tempCurrent != null && tempCurrent.Nav_Contents != null && tempCurrent.Nav_Contents.Any())
{
var contents = new List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT>();
tempCurrent.Nav_Contents.ForEach(t1 =>
{
T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT content = new T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT();
content.ORG_ID = t1.ORG_ID;
content.MONITOR_ASSESSMENT_DETAIL_ID = t.ID;
content.ROW_NO = t1.ROW_NO;
content.METHOD = t1.METHOD;
content.SCORE = t1.SCORE;
content.NAME = t1.NAME;
contents.Add(content);
});
t.Nav_Contents = contents;
}
//details.Add(t);
});
newDepart.Nav_Details = details;
}
result.Add(newDepart);
var name = Enum.GetName(typeof(FMDepartmentType), depart.DEPARTMENT_TYPE);
//发消息
notices.Add(NotificationTaskService.InsertUserNoticeTaskModel(name + "监测与考核记录", newDepart.ID, newDepart.ORG_ID, newDepart.USER_ID.Value, depart?.Nav_User?.NAME, DateTime.Now,
DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.消息, "PT029"));
}
}
}
return result;
}
/// <summary>
/// 触发班组监测与考核记录表
/// </summary>
/// <param name="depart"></param>
/// <param name="departments"></param>
/// <param name="users"></param>
/// <param name="contentList"></param>
/// <param name="notices"></param>
private T_PT_MONITOR_ASSESSMENT CreateDepartMonitorNew(T_FM_DEPARTMENT depart, List<T_FM_DEPARTMENT> departments, List<T_FM_USER> users, List<T_PT_ASSESSMENT_PLAN_AUDIT_TEMP_DETAIL> contentList, PTAssessmentCycleEnums cycle, string year, ref List<T_FM_NOTIFICATION_TASK> notices)
{
T_PT_MONITOR_ASSESSMENT monitor = null;
if (depart != null && depart.USER_ID != null)
{
monitor = new T_PT_MONITOR_ASSESSMENT();
monitor.ORG_ID = depart.ORG_ID;
monitor.DEPARTMENT_TYPE = (FMDepartmentType)depart.DEPARTMENT_TYPE;
monitor.SET_TIME = DateTime.Now;
monitor.USER_ID = depart.USER_ID;
monitor.DEPARTMENT_ID = depart.ID;
monitor.YEAR = year;
monitor.ASSESSMENT_CYCLE = cycle;
monitor.STATUS = PFStandardStatus.Draft;
var monitorUsers = new List<T_PT_MONITOR_ASSESSMENT_USER>();
T_PT_MONITOR_ASSESSMENT_USER user = new T_PT_MONITOR_ASSESSMENT_USER();
user.ORG_ID = depart.ORG_ID;
user.MONITOR_ASSESSMENT_ID = monitor.ID;
user.USER_ID = depart.USER_ID;
monitorUsers.Add(user);
monitor.Nav_MonitorUser = monitorUsers;
var monitorDetails = new List<T_PT_MONITOR_ASSESSMENT_DETAIL>();
if (departments != null && departments.Any())
{
foreach (var d in departments)
{
T_PT_MONITOR_ASSESSMENT_DETAIL detail = new T_PT_MONITOR_ASSESSMENT_DETAIL();
detail.ORG_ID = monitor.ORG_ID;
detail.DEPARTMENT_ID = d.ID;
detail.USER_ID = null;
detail.MONITOR_ASSESSMENT_ID = monitor.ID;
var con = contentList.FirstOrDefault(t => t.DEPARTMENT_ID == d.ID && t.USER_ID == null);
if (con != null && con.Nav_Contents != null && con.Nav_Contents.Any())
{
var contents = new List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT>();
foreach (var c in con.Nav_Contents)
{
T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT content = new T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT();
content.ORG_ID = c.ORG_ID;
content.MONITOR_ASSESSMENT_DETAIL_ID = detail.ID;
content.ROW_NO = c.ROW_NO;
content.METHOD = c.METHOD;
content.SCORE = c.SCORE;
content.NAME = c.NAME;
contents.Add(content);
}
detail.Nav_Contents = contents;
}
monitorDetails.Add(detail);
}
}
if (users != null && users.Any())
{
foreach (var d in users)
{
T_PT_MONITOR_ASSESSMENT_DETAIL detail = new T_PT_MONITOR_ASSESSMENT_DETAIL();
detail.ORG_ID = monitor.ORG_ID;
detail.DEPARTMENT_ID = d.DEPARTMENT_ID;
detail.USER_ID = d.ID;
detail.MONITOR_ASSESSMENT_ID = monitor.ID;
var con = contentList.FirstOrDefault(t => t.DEPARTMENT_ID == d.DEPARTMENT_ID && t.USER_ID == d.ID);
if (con != null && con.Nav_Contents != null && con.Nav_Contents.Any())
{
var contents = new List<T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT>();
foreach (var c in con.Nav_Contents)
{
T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT content = new T_PT_MONITOR_ASSESSMENT_DETAIL_CONTENT();
content.ORG_ID = c.ORG_ID;
content.MONITOR_ASSESSMENT_DETAIL_ID = detail.ID;
content.ROW_NO = c.ROW_NO;
content.METHOD = c.METHOD;
content.SCORE = c.SCORE;
content.NAME = c.NAME;
contents.Add(content);
}
detail.Nav_Contents = contents;
}
monitorDetails.Add(detail);
}
}
monitor.Nav_Details = monitorDetails;
var name = Enum.GetName(typeof(FMDepartmentType), depart.DEPARTMENT_TYPE);
var cycleName = monitor.ASSESSMENT_CYCLE.GetDescription();
//发消息
notices.Add(NotificationTaskService.InsertUserNoticeTaskModel("(" + cycleName + ")" + name + "监测与考核记录", monitor.ID, monitor.ORG_ID, depart.USER_ID.Value, depart?.Nav_User?.NAME, DateTime.Now,
DateTime.Now.AddDays(3), (int)FMNoticeTypeEnum.消息, "PT029"));
}
return monitor;
}
}
}
Reference in New Issue Copy Permalink