363 lines
16 KiB
C#
363 lines
16 KiB
C#
|
using APT.BaseData.Domain.ApiModel;
|
|||
|
|
using APT.BaseData.Domain.Entities;
|
|||
|
|
using APT.BaseData.Domain.Entities.FM;
|
|||
|
|
using APT.BaseData.Domain.IServices;
|
|||
|
|
using APT.BaseData.Domain.IServices.FM;
|
|||
|
|
using APT.BaseData.Services.DomainServices;
|
|||
|
|
using APT.BaseData.Services.Services.FM;
|
|||
|
|
using APT.Infrastructure.Core;
|
|||
|
|
using APT.MS.Domain.Entities.BS;
|
|||
|
|
using APT.MS.Domain.Entities.FO;
|
|||
|
|
using APT.MS.Domain.Entities.LR;
|
|||
|
|
using APT.MS.Domain.Entities.SC.SC;
|
|||
|
|
using APT.MS.Domain.Enums;
|
|||
|
|
using APT.Utility;
|
|||
|
|
using InfluxData.Net.InfluxDb.Models.Responses;
|
|||
|
|
using Microsoft.AspNetCore.Mvc;
|
|||
|
|
using Microsoft.CodeAnalysis;
|
|||
|
|
using MySqlX.XDevAPI.Common;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Data;
|
|||
|
|
using System.IO;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Linq.Expressions;
|
|||
|
|
using System.Web;
|
|||
|
|
using static NPOI.HSSF.Util.HSSFColor;
|
|||
|
|
|
|||
|
|
namespace APT.LR.WebApi.Controllers.Api
|
|||
|
|
{
|
|||
|
|
[Route("api/LR/LRLaw")]
|
|||
|
|
public class LawController : AuthorizeApiController<T_LR_LAW>
|
|||
|
|
{
|
|||
|
|
IFMNotificationTaskService NotificationTaskService { get; set; }
|
|||
|
|
public LawController(IFMNotificationTaskService notificationTaskService)
|
|||
|
|
{
|
|||
|
|
NotificationTaskService = notificationTaskService;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 保存
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost, Route("FullUpdate")]
|
|||
|
|
public JsonActionResult<bool> FullUpdate([FromBody] T_LR_LAW entity)
|
|||
|
|
{
|
|||
|
|
return SafeExecute<bool>(() =>
|
|||
|
|
{
|
|||
|
|
T_FM_NOTIFICATION_TASK notice = null;
|
|||
|
|
List<T_LR_LAW_VERSION_FILE> lawVersionFiles = new List<T_LR_LAW_VERSION_FILE>();
|
|||
|
|
var lawSCSystem = entity.Nav_LawSCSystem;
|
|||
|
|
var lawVersion = entity.Nav_LawVersion;
|
|||
|
|
if (entity.USER_ID == Guid.Empty)
|
|||
|
|
{
|
|||
|
|
entity.USER_ID = (Guid)APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
|||
|
|
}
|
|||
|
|
entity.Nav_LawSCSystem = null;
|
|||
|
|
entity.Nav_LawVersion = null;
|
|||
|
|
|
|||
|
|
if (lawVersion != null)
|
|||
|
|
{
|
|||
|
|
int noVersionCount = lawVersion.Count(t => t.VERSION_STATUS == 0);
|
|||
|
|
if (lawVersion.Count() == noVersionCount)//都是废除状态
|
|||
|
|
{
|
|||
|
|
entity.LAW_STATUS = 0;
|
|||
|
|
entity.VERSION_NUM = lawVersion.Where(t => t.UPDATE_TIME == lawVersion.Max(m => m.UPDATE_TIME)).FirstOrDefault().VERSION_NUM;//现行版本号
|
|||
|
|
}
|
|||
|
|
else //现行法律
|
|||
|
|
{
|
|||
|
|
int versionCount = lawVersion.Count(t => t.VERSION_STATUS == BSLawStatusEnum.现行 && t.IS_DELETED == false);
|
|||
|
|
if (versionCount > 1)
|
|||
|
|
{
|
|||
|
|
throw new Exception("该法律为现行法律，必须只有一个版本现行！");
|
|||
|
|
}
|
|||
|
|
entity.LAW_STATUS = BSLawStatusEnum.现行;
|
|||
|
|
entity.VERSION_NUM = lawVersion.Where(t => t.VERSION_STATUS == BSLawStatusEnum.现行).FirstOrDefault().VERSION_NUM;//现行版本号
|
|||
|
|
entity.UPDATE_TIME = lawVersion.Where(t => t.VERSION_STATUS == BSLawStatusEnum.现行).FirstOrDefault().UPDATE_TIME;//现行版本制修订日期
|
|||
|
|
entity.EXECUTE_TIME = lawVersion.Where(t => t.VERSION_STATUS == BSLawStatusEnum.现行).FirstOrDefault().EXECUTE_TIME;//现行版本施行
|
|||
|
|
}
|
|||
|
|
lawVersion.ForEach(t =>
|
|||
|
|
{
|
|||
|
|
if (t.Nav_Files != null && t.Nav_Files.Count() > 0)
|
|||
|
|
{
|
|||
|
|
t.Nav_Files.ForEach(nf =>
|
|||
|
|
{
|
|||
|
|
nf.VERSION_ID = t.ID;
|
|||
|
|
});
|
|||
|
|
lawVersionFiles.AddRange(t.Nav_Files);
|
|||
|
|
t.Nav_Files = null;
|
|||
|
|
}
|
|||
|
|
else if (entity.LAW_STATUS == BSLawStatusEnum.现行)
|
|||
|
|
{
|
|||
|
|
throw new Exception("状态为现行,请上传法律法规附件！");
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#region 安全检查库
|
|||
|
|
|
|||
|
|
bool isUndateBSMain = false;
|
|||
|
|
string oldLAWName = string.Empty;
|
|||
|
|
ICollection<Guid> listMainID = null;
|
|||
|
|
|
|||
|
|
//var checkLaw = GetEntity<T_LR_LAW>(entity.ID);
|
|||
|
|
var checkLaw = GetEntity<T_SC_STANDARD_CREATE>(entity.ID);
|
|||
|
|
if (checkLaw != null && checkLaw.NAME != entity.NAME)
|
|||
|
|
{
|
|||
|
|
BaseFilter filterCheck = new BaseFilter();
|
|||
|
|
filterCheck.SelectField = new List<string> { "CHECK_MAIN_ID" };
|
|||
|
|
var listMain = GetEntities<T_BS_CHECK_MAIN_LAW>(e => e.STANDARD_ID == entity.ID, filterCheck, null);
|
|||
|
|
if (listMain != null && listMain.Any())
|
|||
|
|
{
|
|||
|
|
oldLAWName = checkLaw.NAME;
|
|||
|
|
listMainID = listMain.Select(e => e.CHECK_MAIN_ID).Distinct().ToList();
|
|||
|
|
isUndateBSMain = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
//判断法规库修改名称时，触发今日提醒给当前层级安全员
|
|||
|
|
var oldEntity= GetEntity<T_LR_LAW>(entity.ID);
|
|||
|
|
if (oldEntity != null && oldEntity.NAME != entity.NAME)
|
|||
|
|
{
|
|||
|
|
var depart = this.GetEntity<T_FM_DEPARTMENT>(t => t.ID == (Guid)APT.Infrastructure.Api.AppContext.CurrentSession.DepartmentID);
|
|||
|
|
if (depart != null)
|
|||
|
|
{
|
|||
|
|
var param = "安全员";
|
|||
|
|
if (depart.DEPARTMENT_TYPE == 3)
|
|||
|
|
{
|
|||
|
|
param = "安环部安全员";
|
|||
|
|
}
|
|||
|
|
if (depart.DEPARTMENT_TYPE == 2)
|
|||
|
|
{
|
|||
|
|
param = "负责人";
|
|||
|
|
}
|
|||
|
|
var user = this.GetEntity<T_FM_USER>(t => t.DEPARTMENT_ID == depart.ID && t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME.Contains(param));
|
|||
|
|
if(user == null)
|
|||
|
|
{
|
|||
|
|
user = this.GetEntity<T_FM_USER>(t => t.DEPARTMENT_ID == depart.ID && t.Nav_ApproveRole != null && t.Nav_ApproveRole.NAME.Contains("负责人"));
|
|||
|
|
}
|
|||
|
|
if (user != null)
|
|||
|
|
{
|
|||
|
|
notice = NotificationTaskService.InsertUserNoticeTaskModel("法律法规名称有变更，请对企业库检查依据进行变更", entity.ID, entity.ORG_ID, user.ID, user.NAME, DateTime.Now, DateTime.Now.AddHours(24), (int)FMNoticeTypeEnum.今日提醒, "PF135");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
UpdateEntityNoCommit(entity);
|
|||
|
|
if (lawSCSystem != null)
|
|||
|
|
BantchSaveEntityNoCommit(lawSCSystem);
|
|||
|
|
if (lawVersion != null)
|
|||
|
|
BantchSaveEntityNoCommit(lawVersion);
|
|||
|
|
if (lawVersionFiles.Any())
|
|||
|
|
BantchSaveEntityNoCommit(lawVersionFiles);
|
|||
|
|
if (notice != null)
|
|||
|
|
UpdateEntityNoCommit(notice);
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 同步修改 依据
|
|||
|
|
|
|||
|
|
if (isUndateBSMain)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var listCheckMain = GetEntities<T_BS_CHECK_MAIN>(e => listMainID.Contains(e.ID), null, null);
|
|||
|
|
List<string> listRoot = null;
|
|||
|
|
foreach (var item in listCheckMain)
|
|||
|
|
{
|
|||
|
|
listRoot = item.CHECKPROOF.Split('，', StringSplitOptions.RemoveEmptyEntries).ToList();
|
|||
|
|
for (int i = 0; i < listRoot.Count; i++)
|
|||
|
|
{
|
|||
|
|
if (listRoot[i] == oldLAWName)
|
|||
|
|
{
|
|||
|
|
listRoot[i] = entity.NAME;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
item.CHECKPROOF = String.Join('，', listRoot);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (listCheckMain != null && listCheckMain.Any())
|
|||
|
|
{
|
|||
|
|
UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
BantchSaveEntityNoCommit(listCheckMain);
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch
|
|||
|
|
{
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 排序分页查询数据
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="pageFilter">分页过滤实体</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost, Route("OrderPaged")]
|
|||
|
|
public PagedActionResult<T_LR_LAW> OrderPaged([FromBody] KeywordPageFilter pageFilter)
|
|||
|
|
{
|
|||
|
|
Expression<Func<T_LR_LAW, bool>> uExpress = t => t.IS_DELETED == false;
|
|||
|
|
if (pageFilter.Keyword != "")
|
|||
|
|
{
|
|||
|
|
List<Guid> ids = new List<Guid>();
|
|||
|
|
var tempids = pageFilter.Keyword.Split(",");
|
|||
|
|
foreach (var id in tempids)
|
|||
|
|
{
|
|||
|
|
ids.Add(Guid.Parse(id));
|
|||
|
|
}
|
|||
|
|
uExpress = uExpress.And(t => ids.Contains(t.TYPE_ID));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return WitOrderPaged(uExpress, pageFilter);
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取导入数据
|
|||
|
|
/// 参考 [Route("api/PF/Import")]
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost, Route("GetImportData")]
|
|||
|
|
public JsonActionResult<ImportDataModel> GetImportData()
|
|||
|
|
{
|
|||
|
|
return SafeExecute<ImportDataModel>(() =>
|
|||
|
|
{
|
|||
|
|
var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
|
|||
|
|
var httpRequest = this.HttpContext.Request;
|
|||
|
|
string orgIdStr = httpRequest.Form["OrgId"];// 获取 组织
|
|||
|
|
ImportDataModel result = new ImportDataModel();
|
|||
|
|
var dic = Path.Combine(System.AppContext.BaseDirectory, "tempImportFiles");
|
|||
|
|
if (!Directory.Exists(dic))
|
|||
|
|
Directory.CreateDirectory(dic);
|
|||
|
|
foreach (var key in httpRequest.Form.Files) // 文件键
|
|||
|
|
{
|
|||
|
|
var postedFile = key; // 获取文件键对应的文件对象
|
|||
|
|
string filePath = Path.Combine(dic, DateTime.Now.ToString("yyyy_MM_dd_hh_mm_ss") + "_" + postedFile.FileName);
|
|||
|
|
Byte[] fileData = new Byte[postedFile.Length];
|
|||
|
|
Stream sr = postedFile.OpenReadStream();//创建数据流对象
|
|||
|
|
sr.Read(fileData, 0, (int)postedFile.Length);
|
|||
|
|
using (FileStream fs = new FileStream(filePath, FileMode.CreateNew))
|
|||
|
|
{
|
|||
|
|
fs.Write(fileData, 0, fileData.Length);
|
|||
|
|
fs.Flush();
|
|||
|
|
fs.Close();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//获取数据
|
|||
|
|
Dictionary<int, int> startRowIndexs = new Dictionary<int, int>();
|
|||
|
|
startRowIndexs.Add(0, 1);//根据Excel格式数据赋值
|
|||
|
|
var dataTables = FileUtils.ReadExcelByOledb(filePath, startRowIndexs);
|
|||
|
|
string Msg = string.Empty;
|
|||
|
|
|
|||
|
|
bool isOK = InsertModel(dataTables.Tables[0], orgId, ref Msg);
|
|||
|
|
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
System.IO.File.Delete(filePath);
|
|||
|
|
}
|
|||
|
|
catch { }
|
|||
|
|
|
|||
|
|
result.Data = Msg;
|
|||
|
|
result.MessageList = new List<string> { Msg };
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return result;
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 数据插入
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="dtSource"></param>
|
|||
|
|
/// <param name="OrgID"></param>
|
|||
|
|
/// <param name="Msg"></param>
|
|||
|
|
/// <param name="rowIndex"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
/// <exception cref="Exception"></exception>
|
|||
|
|
public bool InsertModel(DataTable dtSource, Guid? orgId, ref string Msg, int rowIndex = 1)
|
|||
|
|
{
|
|||
|
|
var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
|||
|
|
if (dtSource == null || dtSource.Rows.Count < rowIndex)
|
|||
|
|
{
|
|||
|
|
Msg = "未获取到导入数据";
|
|||
|
|
throw new Exception(Msg);
|
|||
|
|
}
|
|||
|
|
int rowAll = dtSource.Rows.Count;
|
|||
|
|
if (!string.IsNullOrEmpty(Msg))
|
|||
|
|
{
|
|||
|
|
throw new Exception(Msg);
|
|||
|
|
}
|
|||
|
|
List<T_LR_LAW> laws = new List<T_LR_LAW>();
|
|||
|
|
List<T_LR_LAW_VERSION> lawVersions = new List<T_LR_LAW_VERSION>();
|
|||
|
|
var lawTypess = GetEntities<T_LR_LAW_TYPE>(t => t.IS_DELETED == false, new BaseFilter(orgId));
|
|||
|
|
DateTime dtNow = DateTime.Now;
|
|||
|
|
for (int i = 0; i < rowAll; i++)
|
|||
|
|
{
|
|||
|
|
T_LR_LAW law = new T_LR_LAW();
|
|||
|
|
law.ID = Guid.NewGuid();
|
|||
|
|
law.VERSION_NUM = dtSource.Rows[i][2].ToString().Trim();
|
|||
|
|
law.USER_ID = (Guid)userId;
|
|||
|
|
if (!string.IsNullOrEmpty(dtSource.Rows[i][0].ToString().Trim()))
|
|||
|
|
{
|
|||
|
|
law.NAME = dtSource.Rows[i][0].ToString().Trim();
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
throw new Exception("名称不能为空!");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(dtSource.Rows[i][3].ToString().Trim()))
|
|||
|
|
{
|
|||
|
|
law.UPDATE_TIME = DateTime.Parse(dtSource.Rows[i][3].ToString().Trim());
|
|||
|
|
}
|
|||
|
|
if (lawTypess.FirstOrDefault(t => t.NAME == dtSource.Rows[i][1].ToString().Trim()) != null)
|
|||
|
|
{
|
|||
|
|
law.TYPE_ID = lawTypess.FirstOrDefault(t => t.NAME == dtSource.Rows[i][1].ToString().Trim()).ID;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
throw new Exception("需求类别:" + dtSource.Rows[i][1].ToString().Trim() + "未找到");
|
|||
|
|
}
|
|||
|
|
law.LAW_STATUS = BSLawStatusEnum.现行;
|
|||
|
|
law.ORG_ID = orgId;
|
|||
|
|
T_LR_LAW_VERSION lawVersion = new T_LR_LAW_VERSION
|
|||
|
|
{
|
|||
|
|
ID = Guid.NewGuid(),
|
|||
|
|
LAW_ID = law.ID,
|
|||
|
|
VERSION_NUM = dtSource.Rows[i][2].ToString().Trim(),
|
|||
|
|
ENTER_TIME = dtNow,
|
|||
|
|
VERSION_STATUS = BSLawStatusEnum.现行,
|
|||
|
|
ORG_ID = orgId,
|
|||
|
|
};
|
|||
|
|
if (!string.IsNullOrEmpty(dtSource.Rows[i][3].ToString().Trim()))
|
|||
|
|
{
|
|||
|
|
lawVersion.UPDATE_TIME = DateTime.Parse(dtSource.Rows[i][3].ToString().Trim());
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(dtSource.Rows[i][4].ToString().Trim()))
|
|||
|
|
{
|
|||
|
|
lawVersion.EXECUTE_TIME = DateTime.Parse(dtSource.Rows[i][4].ToString().Trim());
|
|||
|
|
}
|
|||
|
|
laws.Add(law);
|
|||
|
|
lawVersions.Add(lawVersion);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
UnifiedCommit(() =>
|
|||
|
|
{
|
|||
|
|
if (laws != null && laws.Any())
|
|||
|
|
BantchAddEntityNoCommit(laws);
|
|||
|
|
if (lawVersions != null && lawVersions.Any())
|
|||
|
|
BantchAddEntityNoCommit(lawVersions);
|
|||
|
|
});
|
|||
|
|
Msg = "导入成功！";
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|