using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.FriendlyException;
|
using iWare.Wms.Core;
|
using iWare.Wms.Core.Util;
|
using Magicodes.ExporterAndImporter.Core.Extension;
|
using Mapster;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using System.Linq.Dynamic.Core;
|
using System.Text;
|
using System.Web;
|
|
namespace iWare.Wms.Application
|
{
|
/// <summary>
|
/// 设备运行历史服务
|
/// </summary>
|
[ApiDescriptionSettings("数据查询服务", Name = "EquipmentWorkingLog", Order = 100)]
|
[Route("api/[Controller]")]
|
public class EquipmentWorkingLogService : IEquipmentWorkingLogService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<EquipmentWorkingLog,MasterDbContextLocator> _equipmentWorkingLogRep;
|
private readonly IRepository<EquipmentBaseInfo, MasterDbContextLocator> _equipmentBaseInfoRep;
|
private readonly IRepository<SysDictType, MasterDbContextLocator> _sysDictTypeRep;
|
private readonly IRepository<SysDictData, MasterDbContextLocator> _sysDictDataRep;
|
|
/// <summary>
|
/// 设备运行历史服务构造函数
|
/// </summary>
|
/// <param name="equipmentWorkingLogRep"></param>
|
/// <param name="equipmentBaseInfoRep"></param>
|
/// <param name="sysDictTypeRep"></param>
|
/// <param name="sysDictDataRep"></param>
|
public EquipmentWorkingLogService(
|
IRepository<EquipmentWorkingLog,MasterDbContextLocator> equipmentWorkingLogRep,
|
IRepository<EquipmentBaseInfo, MasterDbContextLocator> equipmentBaseInfoRep,
|
IRepository<SysDictType, MasterDbContextLocator> sysDictTypeRep,
|
IRepository<SysDictData, MasterDbContextLocator> sysDictDataRep
|
)
|
{
|
_equipmentWorkingLogRep = equipmentWorkingLogRep;
|
_equipmentBaseInfoRep = equipmentBaseInfoRep;
|
_sysDictTypeRep = sysDictTypeRep;
|
_sysDictDataRep = sysDictDataRep;
|
}
|
|
/// <summary>
|
/// 分页查询设备运行历史
|
/// </summary>
|
/// <param name="input">设备运行历史分页查询参数</param>
|
/// <returns></returns>
|
[HttpGet("page")]
|
public async Task<PageResult<EquipmentWorkingLogOutput>> Page([FromQuery] EquipmentWorkingLogSearch input)
|
{
|
var list = await _equipmentWorkingLogRep.DetachedEntities
|
.Join(_equipmentBaseInfoRep.DetachedEntities,u => u.EquipmentID, e => e.EquipmentId, (u, e) => new { u, e })
|
.Where(!string.IsNullOrEmpty(input.EquipmentID), w => w.u.EquipmentID == input.EquipmentID)
|
.Where(input.isSelectRedio == 1, w => w.u.FailureType != null && w.u.FailureType != "")
|
.Where(input.logAddBeginTime != null, w => w.u.LogAddTime >= input.logAddBeginTime)
|
.Where(input.logAddEndTime != null, w => w.u.LogAddTime <= input.logAddEndTime)
|
.Select(s => new EquipmentWorkingLogOutput
|
{
|
Id = s.u.Id,
|
EquipmentName = s.e.EquipmentName,
|
EquipmentID = s.u.EquipmentID,
|
LogAddTime = s.u.LogAddTime,
|
Remarks = s.u.Remarks,
|
FailureType = s.u.FailureType,
|
FailureStartTime=s.u.FailureStartTime,
|
FailureEndTime=s.u.FailureEndTime,
|
FailureMsg = s.u.FailureMsg,
|
EquipmentState = s.u.EquipmentState,
|
EquipmentStateStartTime = s.u.EquipmentStateStartTime,
|
EquipmentStateEndTime = s.u.EquipmentStateEndTime,
|
WarnType = s.u.WarnType,
|
Warnmsg = s.u.Warnmsg,
|
WarnStartTime = s.u.WarnStartTime,
|
WarnEndTime = s.u.WarnEndTime,
|
UpdateDesc = s.u.UpdateDesc,
|
})
|
.OrderBy(PageInputOrder.OrderBuilder<EquipmentWorkingLogSearch>(input))
|
.ProjectToType<EquipmentWorkingLogOutput>()
|
.ToADPagedListAsync(input.PageNo, input.PageSize);
|
|
|
//public string EquipmentState { get; set; }
|
//public DateTime? EquipmentStateStartTime { get; set; }
|
//public DateTime? EquipmentStateEndTime { get; set; }
|
//public string WarnType { get; set; }
|
//public DateTime? WarnStartTime { get; set; }
|
//public DateTime? WarnEndTime { get; set; }
|
//public string Warnmsg { get; set; }
|
//public string UpdateDesc { get; set; }
|
return list;
|
}
|
|
/// <summary>
|
/// 根据设备运行历史查询参数导出Excel
|
/// </summary>
|
/// <param name="input">设备运行历史查询参数</param>
|
/// <returns>导出的Excel文件</returns>
|
[HttpGet("toExcel")]
|
public async Task<IActionResult> ToExcelAsync([FromQuery] EquipmentWorkingLogSearch input)
|
{
|
|
var equipmentLogList = await _equipmentWorkingLogRep.DetachedEntities
|
.Join(_equipmentBaseInfoRep.DetachedEntities, u => u.EquipmentID, e => e.EquipmentId, (u, e) => new { u, e })
|
.Where(!string.IsNullOrEmpty(input.EquipmentID), w => w.u.EquipmentID == input.EquipmentID)
|
.Where(input.isSelectRedio == 1, w => w.u.FailureType != null && w.u.FailureType != "")
|
.Where(input.logAddBeginTime != null, w => w.u.LogAddTime >= input.logAddBeginTime)
|
.Where(input.logAddEndTime != null, w => w.u.LogAddTime <= input.logAddEndTime)
|
.Select(s => new EquipmentWorkingLogOutput
|
{
|
Id=s.u.Id,
|
EquipmentID = s.u.EquipmentID,
|
EquipmentName = s.e.EquipmentName,
|
//FailureType = s.u.FailureType,
|
//FailureMsg= s.u.FailureMsg,
|
LogAddTime = s.u.LogAddTime,
|
Remarks = s.u.Remarks,
|
FailureType = s.u.FailureType,
|
FailureStartTime = s.u.FailureStartTime,
|
FailureEndTime = s.u.FailureEndTime,
|
FailureMsg = s.u.FailureMsg,
|
EquipmentState = s.u.EquipmentState,
|
EquipmentStateStartTime = s.u.EquipmentStateStartTime,
|
EquipmentStateEndTime = s.u.EquipmentStateEndTime,
|
WarnType = s.u.WarnType,
|
Warnmsg = s.u.Warnmsg,
|
WarnStartTime = s.u.WarnStartTime,
|
WarnEndTime = s.u.WarnEndTime,
|
UpdateDesc = s.u.UpdateDesc,
|
})
|
.OrderBy(PageInputOrder.OrderBuilder<EquipmentWorkingLogSearch>(input))
|
.ProjectToType<EquipmentExcelOutput>()
|
.ToListAsync();
|
|
|
|
MemoryStream ms = new();
|
DataConvertUtil.ToExcelData(equipmentLogList, _sysDictTypeRep, _sysDictDataRep, out List<string> headers,
|
out List<List<object>> data, out string sheetName);
|
|
ExcelUtil.ToExcel(headers, data, sheetName, ms);
|
ms.Position = 0;
|
var fileName = HttpUtility.UrlEncode($"{sheetName}[{DateTimeOffset.Now:yyyy-MM-dd}].xlsx", Encoding.GetEncoding("UTF-8"));
|
return new FileStreamResult(ms, "application/octet-stream") { FileDownloadName = fileName };
|
}
|
}
|
}
|
