using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using NPOI.HPSF;
using NPOI.SS.UserModel;
using NPOI.Util;
using NPOI.XWPF.UserModel;
using Ropin.Inspection.Api.Common;
using Ropin.Inspection.Common.Helper;
using Ropin.Inspection.Model;
using Ropin.Inspection.Model.Common;
using Ropin.Inspection.Model.SearchModel;
using Ropin.Inspection.Model.ViewModel;
using Ropin.Inspection.Service;
using Ropin.Inspection.Service.Interface;
using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Threading.Tasks;
namespace Ropin.Inspection.Api.Controllers
{
/// <summary>
/// 巡检详细记录
/// </summary>
public class TispRecordItemController : BaseController
{
public ILogger<TispRecordItemController> _logger { get; }
private readonly ITispRecordItemService _tispRecordItemService;
private readonly ITispRecordImageService _tispRecordImageService;
private readonly IReportService _reportService;
/// <summary>
///
/// </summary>
/// <param name="tispRecordItemService"></param>
/// <param name="tispRecordImageService"></param>
/// <param name="logger"></param>
public TispRecordItemController(ITispRecordItemService tispRecordItemService, IReportService reportService, ITispRecordImageService tispRecordImageService, ILogger<TispRecordItemController> logger)
{
_tispRecordItemService = tispRecordItemService;
_tispRecordImageService = tispRecordImageService;
_reportService = reportService;
_logger = logger;
}
/// <summary>
/// 通过巡检记录ID获取巡检信息
/// </summary>
/// <param name="recordId"></param>
/// <returns></returns>
[HttpGet("GetRecordItemsAsync/{recordId}")]
public async Task<ApiResult> GetRecordItemsAsync(Guid recordId)
{
if (Guid.Empty == recordId)
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
IEnumerable<TispRecordItemDetailViewModel> recordItems = await _tispRecordItemService.GetRecordsConditionAsync(recordId);
return new ApiResult<IEnumerable<TispRecordItemDetailViewModel>>(recordItems);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 通过巡检记录ID获取巡检详细信息，通过内容分组
/// </summary>
/// <param name="recordId"></param>
/// <returns></returns>
[HttpGet("GetRecordItemsByRecordIdAsync/{recordId}")]
[AllowAnonymous]
public async Task<ApiResult> GetRecordItemsByRecordIdAsync(Guid recordId)
{
if (Guid.Empty == recordId)
{
return new ApiResult(ReturnCode.ArgsError);
}
try
{
List<List<TispRecordItemDetailViewModel>> recordItems = await _tispRecordItemService.GetRecordItemsByRecordIdAsync(recordId);
return new ApiResult<List<List<TispRecordItemDetailViewModel>>>(recordItems);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 通过详细记录ID获取巡检信息
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
[HttpGet("GetRecordItemByIdAsync/{id}")]
public async Task<ApiResult> GetRecordItemByIdAsync(Guid id)
{
if (Guid.Empty == id)
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
IEnumerable<TispRecordItemDetailViewModel> recordItems = await _tispRecordItemService.GetRecordItemByIdAsync(id);
return new ApiResult<IEnumerable<TispRecordItemDetailViewModel>>(recordItems);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 获取异常上报记录
/// </summary>
/// <param name="searchModel"></param>
/// <returns></returns>
[HttpPost("GetAlarmRecordsAsync")]
public async Task<ApiResult> GetAlarmRecordsAsync(TispRecordAlarmSearchModel searchModel)
{
if (null == searchModel || string.IsNullOrEmpty(searchModel.C_StoreCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
IEnumerable<TispRecordItemDetailViewModel> recordItems = await _tispRecordItemService.GetAlarmRecordsAsync(searchModel);
return new ApiResult<PagesModel<TispRecordItemDetailViewModel>>(new PagesModel<TispRecordItemDetailViewModel>(recordItems?.ToList(), searchModel));
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 后台管理平台，获取异常上报记录
/// </summary>
/// <param name="searchModel"></param>
/// <returns></returns>
[HttpPost("GetAlarmRecordListAsync")]
public async Task<ApiResult> GetAlarmRecordListAsync(TispRecordAlarmSearchModel searchModel)
{
if (null == searchModel || string.IsNullOrEmpty(searchModel.C_StoreCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
IEnumerable<TispRecordItemDetailViewModel> recordItems = await _tispRecordItemService.GetAlarmRecordListAsync(searchModel);
return new ApiResult<PagesModel<TispRecordItemDetailViewModel>>(new PagesModel<TispRecordItemDetailViewModel>(recordItems?.ToList(), searchModel));
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 扫巡检点二维码获取异常记录
/// </summary>
/// <param name="QRCode"></param>
/// <param name="storeCode"></param>
/// <returns></returns>
[HttpGet("GetAlarmRecordsByQRCodeAsync/{QRCode}/{storeCode}")]
//[AllowAnonymous]
public async Task<ApiResult> GetAlarmRecordsByQRCodeAsync(string QRCode,string storeCode)
{
try
{
if (string.IsNullOrEmpty(QRCode)|| string.IsNullOrEmpty(storeCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
IEnumerable<TispRecordItemAlarmDetailViewModel> recordItems = await _tispRecordItemService.GetAlarmRecordsByQRCodeAsync(QRCode, storeCode);
return new ApiResult<IEnumerable<TispRecordItemAlarmDetailViewModel>>(recordItems?.ToList());
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 根据巡检点二维码获取最新巡检记录
/// </summary>
/// <param name="QRCode"></param>
/// <param name="storeCode"></param>
/// <returns></returns>
[HttpGet("GetNewRecordByQRCodeAsync/{QRCode}/{storeCode}")]
public async Task<ApiResult> GetNewRecordByQRCodeAsync(string QRCode,string storeCode)
{
try
{
if (string.IsNullOrEmpty(QRCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
IEnumerable<TispRecordItemAlarmDetailViewModel> recordItems = await _tispRecordItemService.GetNewRecordByQRCodeAsync(QRCode, storeCode);
return new ApiResult<IEnumerable<TispRecordItemAlarmDetailViewModel>>(recordItems?.ToList());
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 获取异常上报记录数
/// </summary>
/// <param name="searchModel"></param>
/// <returns></returns>
[HttpGet("GetAlarmRecordsCountAsync")]
public async Task<ApiResult> GetAlarmRecordsCountAsync([FromQuery] TispRecordAlarmSearchModel searchModel)
{
if (null == searchModel || string.IsNullOrEmpty(searchModel.C_StoreCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
int recordCount = await _tispRecordItemService.GetAlarmRecordsCountAsync(searchModel);
return new ApiResult<int>(recordCount);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 获取异常处理记录
/// </summary>
/// <param name="searchModel"></param>
/// <returns></returns>
[HttpPost("GetAlarmRecoveryRecordsAsync")]
[AllowAnonymous]
public async Task<ApiResult> GetAlarmRecoveryRecordsAsync(TispRecordAlarmSearchModel searchModel)
{
if (null == searchModel || string.IsNullOrEmpty(searchModel.C_StoreCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
IEnumerable<TispRecordItemDetailViewModel> recordItems = await _tispRecordItemService.GetAlarmRecoveryRecordsAsync(searchModel);
//if (null == recordItems)
// return new ApiResult<IEnumerable<TispRecordItemDetailViewModel>>(recordItems);
//else
return new ApiResult<PagesModel<TispRecordItemDetailViewModel>>(new PagesModel<TispRecordItemDetailViewModel>(recordItems?.ToList(), searchModel));
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 获取异常处理记录数
/// </summary>
/// <param name="searchModel"></param>
/// <returns></returns>
[HttpGet("GetAlarmRecoveryRecordsCountAsync")]
public async Task<ApiResult> GetAlarmRecoveryRecordsCountAsync([FromQuery] TispRecordAlarmSearchModel searchModel)
{
if (null == searchModel || string.IsNullOrEmpty(searchModel.C_StoreCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
int recordCount = await _tispRecordItemService.GetAlarmRecoveryRecordsCountAsync(searchModel);
return new ApiResult<int>(recordCount);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 巡检异常恢复处理
/// </summary>
/// <param name="recordItemId"></param>
/// <param name="updateModel"></param>
/// <returns></returns>
[HttpPut("RecoveryRecordItemAlarmAsync/{recordItemId}")]
public async Task<ApiResult> RecoveryRecordItemAlarmAsync(Guid recordItemId, TispRecoveryRecordItemAlarmUpdateViewModel updateModel)
{
if (Guid.Empty == recordItemId)
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
await _tispRecordItemService.RecoveryRecordItemAlarmAsync(recordItemId, updateModel);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
return new ApiResult(ReturnCode.Success);
}
/// <summary>
/// 巡检异常确认处理
/// </summary>
/// <param name="recordItemId"></param>
/// <param name="updateModel"></param>
/// <returns></returns>
[HttpPut("ConfirmRecordItemAlarmAsync/{recordItemId}")]
public async Task<ApiResult> ConfirmRecordItemAlarmAsync(Guid recordItemId, TispRecoveryRecordItemAlarmUpdateViewModel updateModel)
{
if (Guid.Empty == recordItemId)
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
await _tispRecordItemService.ConfirmRecordItemAlarmAsync(recordItemId, updateModel);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
return new ApiResult(ReturnCode.Success);
}
/// <summary>
/// 巡检异常确认处理
/// </summary>
/// <param name="updateModel"></param>
/// <returns></returns>
[HttpPost("ConfirmAlarmAsync")]
public async Task<ApiResult> ConfirmAlarmAsync(TispRecoveryAlarmUpdateViewModel updateModel)
{
if (string.IsNullOrEmpty(updateModel.recordItemId))
{
return new ApiResult(ReturnCode.GeneralError);
}
Guid id = Guid.Parse(updateModel.recordItemId);
try
{
await _tispRecordItemService.ConfirmRecordItemAlarmAsync(id, new TispRecoveryRecordItemAlarmUpdateViewModel { C_Remark = updateModel.C_Remark,FilePaths = updateModel.FilePaths });
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
return new ApiResult(ReturnCode.Success);
}
/// <summary>
/// 巡检异常取消处理
/// </summary>
/// <param name="recordItemId"></param>
/// <param name="updateModel"></param>
/// <returns></returns>
[HttpPut("CancelRecordItemAlarmAsync/{recordItemId}")]
public async Task<ApiResult> CancelRecordItemAlarmAsync(Guid recordItemId, TispRecoveryRecordItemAlarmUpdateViewModel updateModel)
{
if (Guid.Empty == recordItemId)
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
await _tispRecordItemService.CancelRecordItemAlarmAsync(recordItemId, updateModel);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
return new ApiResult(ReturnCode.Success);
}
/// <summary>
/// 巡检记录修改
/// </summary>
/// <param name="recordItemId"></param>
/// <param name="updateModel"></param>
/// <returns></returns>
[HttpPut("UpdateRecordItemAsync/{recordItemId}")]
public async Task<ApiResult> UpdateRecordItemAsync(Guid recordItemId, TispRecordItemUpdateViewModel updateModel)
{
if (Guid.Empty == recordItemId)
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
await _tispRecordItemService.UpdateRecordItemAsync(recordItemId, updateModel);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
return new ApiResult(ReturnCode.Success);
}
/// <summary>
/// 消防设施每周检查记录
/// </summary>
/// <param name="start"></param>
/// <param name="end"></param>
/// <returns></returns>
[HttpGet("GetFireFightingFacilitiesAsync")]
public async Task<ApiResult> GetFireFightingFacilitiesAsync(DateTime start, DateTime end, string storeCode)
{
if (start.Year < 2010 || end.Year < 2010 || string.IsNullOrEmpty(storeCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
object o = await _tispRecordItemService.GetFireFightingFacilitiesAsync(start, end.AddDays(1), storeCode);
ReportViewModel reportViewModel = new ReportViewModel
{
G_ID = Guid.NewGuid(),
C_StoreCode = storeCode,
I_Type = 3,
C_GroupName = "设备设施检查",
C_Name = "设备设施点检记录" + "(" + DateTime.Now.AddDays(1).ToString("yyyy/MM/dd HH:mm") + ")",
C_Status = "1",
D_CreateTime = DateTime.Parse(DateTime.Now.AddDays(1).ToString("yyyy/MM/dd HH:mm")),
D_Start = start,
D_End = end,
C_Data = JsonConvert.SerializeObject(o)
};
await _reportService.CreateOneAsync(reportViewModel);
return new ApiResult<object>(o);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 防火巡检记录表
/// </summary>
/// <param name="start"></param>
/// <param name="end"></param>
/// <returns></returns>
[HttpGet("GetFireInspectionRecordAsync")]
public async Task<ApiResult> GetFireInspectionRecordAsync(DateTime start, DateTime end, string storeCode)
{
if (start.Year < 2010 || end.Year < 2010 || string.IsNullOrEmpty(storeCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
var work = this.ActualWork(start, end.AddDays(1), storeCode);
var timeout = this.Timeout(20000);
object o = null;
var finishedTask = await Task.WhenAny(timeout, work);
if (finishedTask == timeout)
{
return new ApiResult(ReturnCode.GeneralError, "请求超时");
}
else
{
o = work.Result;
}
return new ApiResult<object>(o);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
private async Task<object> ActualWork(DateTime start, DateTime end, string storeCode)
{
return await _tispRecordItemService.GetFireInspectionRecordAsync(start, end, storeCode);
}
private async Task Timeout(int timeoutValue)
{
await Task.Delay(timeoutValue);
}
/// <summary>
/// 防火检查记录(周)
/// </summary>
/// <param name="start"></param>
/// <param name="end"></param>
/// <returns></returns>
[HttpGet("GetFirePreventionWeekRecordAsync")]
public async Task<ApiResult> GetFirePreventionWeekRecordAsync(DateTime start, DateTime end, string storeCode)
{
if (start.Year < 2010 || end.Year < 2010 || string.IsNullOrEmpty(storeCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
object o = await _tispRecordItemService.GetFirePreventionWeekRecordAsync(start, end.AddDays(1), storeCode);
return new ApiResult<object>(o);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 隐患整改验收单
/// </summary>
/// <param name="start"></param>
/// <param name="end"></param>
/// <returns></returns>
[HttpGet("HiddenDangerRectificationAcceptanceForm")]
public async Task<ApiResult> HiddenDangerRectificationAcceptanceForm(DateTime start, DateTime end,string storeCode)
{
if (start.Year < 2010 || end.Year < 2010 || string.IsNullOrEmpty(storeCode))
{
return new ApiResult(ReturnCode.GeneralError);
}
try
{
object o = await _tispRecordItemService.HiddenDangerRectificationAcceptanceForm(start, end.AddDays(1), storeCode);
return new ApiResult<object>(o);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
/// <summary>
/// 发送点检邮件【大屏-详情】
/// </summary>
/// <param name="searchModel"></param>
/// <returns></returns>
[HttpPost("SendEmilOrderItem")]
[AllowAnonymous]
public async Task<ApiResult> SendEmilOrderItem(SendRecordToEmailModel searchModel)
{
try
{
if (searchModel == null && searchModel.C_ID!=Guid.Empty)
{
return new ApiResult(ReturnCode.ArgsError, "请输入参数");
}
List<List<TispRecordItemDetailViewModel>> recordItems = await _tispRecordItemService.GetRecordItemsByRecordIdAsync(searchModel.C_ID);
string zip = @"wwwroot\\ZipFile";
if (!System.IO.Directory.Exists(zip))
{
Directory.CreateDirectory(zip);
}
string zipPaht = zip + $"\\{searchModel.C_ID}点检详情下载.zip";
if (recordItems.Count > 0)
{
XWPFDocument doc = new XWPFDocument();
var paragraph = doc.CreateParagraph();
var run1 = paragraph.CreateRun();
run1.FontSize = 18;
int serialNum = 1;
run1.SetText(searchModel.DevName);
foreach (var itemList in recordItems)
{
if (itemList==null)
{
continue;
}
var p0 = doc.CreateParagraph();
var run0 = p0.CreateRun();
run0.FontSize = 16;
run0.SetText(" " + serialNum.ToString() + "、" + itemList.FirstOrDefault()?.C_Name);
int serialNum1 = 1;
foreach (var item in itemList)
{
if (item == null) { continue; }
var p1 = doc.CreateParagraph();
var run = p1.CreateRun();
run.FontSize = 14;
string status = string.Empty;
//1 = 正常；0 = 异常；2 = 恢复；3 = 确认异常；4 = 取消异常
switch (item.C_Status)
{
case "1":
status = "正常";
break;
case "2":
status = "异常已处理";
break;
case "3":
status = "确认异常";
break;
case "4":
status = "取消异常";
break;
case "0":
status = "巡检异常";
break;
}
run.SetText(" " + serialNum.ToString() + "." + serialNum1.ToString());
run.AddCarriageReturn();
run.AppendText(" 操作时间：" + item.D_CreateOn.ToString("yyyy-MM-dd HH:mm"));
run.AddCarriageReturn();
run.AppendText(" 状态：" + status);
run.AddCarriageReturn();
run.AppendText(" 处理人员：" + item.ReportUserName);
if (item.RecordImageList != null && item.RecordImageList.Count() > 0)
{
run.AddCarriageReturn();
run.AppendText(" 现场拍照：");
foreach (var path in item.RecordImageList)
{
string pathFile = path.C_ImageURL;
if (pathFile != null)
{
if (pathFile[0].ToString() == @"/")
{
pathFile = pathFile.Substring(1);
}
if (!System.IO.File.Exists(pathFile))
{
pathFile = @"wwwroot/error.png";
}
FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
run.AddCarriageReturn();
run.AddPicture(fileStream, 6, pathFile, Units.ToEMU(100), Units.ToEMU(100));
}
}
}
run.AddCarriageReturn();
run.AppendText(" 现场描述：" + item.C_Remark);
serialNum1++;
}
serialNum++;
}
using (var zipFile = new FileStream(zipPaht, FileMode.Create))
{
using (var memoryStream = new NpoiMemoryStream())
{
doc.Write(memoryStream);
byte[] excelData = memoryStream.ToArray();
using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
{
archive.CreateEntry($"{searchModel.C_ID}点检详情.docx").Open().Write(excelData, 0, excelData.Length);
}
}
}
}
string emailName = $"{searchModel.DevName}-点检详情";
using (var zipFile1 = new FileStream(zipPaht, FileMode.Open))
{
await Task.Run(() =>
{
EmailHelper.SendEmail(searchModel.Mails, emailName, "", "详情见附件", $"{emailName}.zip", "application/zip", zipFile1);
});
}
System.IO.File.Delete(zipPaht);
return new ApiResult(ReturnCode.Success);
}
catch (Exception ex)
{
return new ApiResult(ReturnCode.GeneralError, ex.Message);
}
}
}
}