using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.Extensions;
|
using Furion.FriendlyException;
|
using iWare.Wms.Core;
|
using iWare.Wms.Core.Util;
|
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 = "EquipmentBaseInfo", Order = 100)]
|
[Route("api/[Controller]")]
|
public class EquipmentBaseInfoService : IEquipmentBaseInfoService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<EquipmentBaseInfo,MasterDbContextLocator> _equipmentBaseInfoRep;
|
private readonly IRepository<V_GetEquipmentAlert, MasterDbContextLocator> _v_GetEquipmentAlertRep;
|
private readonly IRepository<SysDictType, MasterDbContextLocator> _sysDictTypeRep;
|
private readonly IRepository<SysDictData, MasterDbContextLocator> _sysDictDataRep;
|
private readonly IRepository<EquipmentCurrentMonitor, MasterDbContextLocator> _equipmentCurrentMonitorRep;
|
|
/// <summary>
|
/// 设备基础信息构造
|
/// </summary>
|
/// <param name="equipmentBaseInfoRep"></param>
|
/// <param name="v_GetEquipmentAlert"></param>
|
/// <param name="sysDictTypeRep"></param>
|
/// <param name="sysDictDataRep"></param>
|
/// <param name="equipmentCurrentMonitorRep"></param>
|
public EquipmentBaseInfoService(
|
IRepository<EquipmentBaseInfo,MasterDbContextLocator> equipmentBaseInfoRep,
|
IRepository<V_GetEquipmentAlert, MasterDbContextLocator> v_GetEquipmentAlert,
|
IRepository<SysDictType, MasterDbContextLocator> sysDictTypeRep,
|
IRepository<SysDictData, MasterDbContextLocator> sysDictDataRep,
|
IRepository<EquipmentCurrentMonitor, MasterDbContextLocator> equipmentCurrentMonitorRep
|
)
|
{
|
_equipmentBaseInfoRep = equipmentBaseInfoRep;
|
_v_GetEquipmentAlertRep = v_GetEquipmentAlert;
|
_sysDictTypeRep = sysDictTypeRep;
|
_sysDictDataRep = sysDictDataRep;
|
_equipmentCurrentMonitorRep = equipmentCurrentMonitorRep;
|
}
|
|
|
|
/// <summary>
|
/// 查询设备告警信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("getAlert")]
|
public async Task<List<EquipmentAlertInfoOutput>> Page([FromQuery] EquipmentAlertSearch input)
|
{
|
var equipmentAlertInfos = await _v_GetEquipmentAlertRep.DetachedEntities
|
.Where(!string.IsNullOrEmpty(input.EquipmentId), u => u.EquipmentId == input.EquipmentId)
|
.Where(!string.IsNullOrEmpty(input.EquipmentName), u => EF.Functions.Like(u.EquipmentName, $"%{input.EquipmentName.Trim()}%"))
|
.Where(!string.IsNullOrEmpty(input.WorkingProcedure), u => u.WorkingProcedure.Equals(input.WorkingProcedure))
|
.Where(!string.IsNullOrEmpty(input.AlertType),u=> (input.AlertType.Equals("1")&& u.IsAlertDetergent)
|
||(input.AlertType.Equals("2") && u.IsAlertKnifeTool)
|
||(input.AlertType.Equals("3") && u.IsAlertCuttingFluid)
|
||(input.AlertType.Equals("4") && u.IsAlert))
|
.OrderBy(PageInputOrder.OrderBuilder<EquipmentAlertSearch>(input))
|
.ProjectToType<EquipmentAlertInfoOutput>().ToListAsync();
|
return equipmentAlertInfos;
|
}
|
/// <summary>
|
/// 分页查询设备基础信息管理
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("page")]
|
public async Task<PageResult<EquipmentBaseInfoOutput>> Page([FromQuery] EquipmentBaseInfoSearch input)
|
{
|
var equipmentBaseInfos = await _equipmentBaseInfoRep.DetachedEntities
|
.Where(!string.IsNullOrEmpty(input.EquipmentId), u => u.EquipmentId == input.EquipmentId)
|
.Where(!string.IsNullOrEmpty(input.EquipmentName), u => u.EquipmentName == input.EquipmentName)
|
.Where(!string.IsNullOrEmpty(input.WorkingProcedure), u => EF.Functions.Like(u.WorkingProcedure, $"%{input.WorkingProcedure.Trim()}%"))
|
.Where(!string.IsNullOrEmpty(input.EquipmentModel), u => EF.Functions.Like(u.EquipmentModel, $"%{input.EquipmentModel.Trim()}%"))
|
.Select(s => new EquipmentBaseInfoOutput
|
{
|
Id = s.Id,
|
EquipmentId = s.EquipmentId,
|
EquipmentName = s.EquipmentName,
|
WorkingProcedure = s.WorkingProcedure,
|
EquipmentModel = s.EquipmentModel,
|
EquipmentIP = s.EquipmentIP,
|
EquipmentFunction = s.EquipmentFunction,
|
EquipmentBrand = s.EquipmentBrand,
|
EquipmentManufacturer = s.EquipmentManufacturer,
|
Detergentchangetime = s.Detergentchangetime,
|
DetergentChangeAlertThreshold = s.DetergentChangeAlertThreshold,
|
DetergentChangeCycle = s.DetergentChangeCycle,
|
KnifeToolChangeTime = s.KnifeToolChangeTime,
|
KnifeToolChangeAlertThreshold = s.KnifeToolChangeAlertThreshold,
|
CuttingFluidChangeAlertThreshold = s.CuttingFluidChangeAlertThreshold,
|
CuttingFluidChangeTime = s.CuttingFluidChangeTime,
|
Remarks = s.Remarks,
|
CreatedTime = s.CreatedTime,
|
TactTime=s.TactTime,
|
})
|
.Distinct()
|
.OrderBy(PageInputOrder.OrderBuilder<EquipmentBaseInfoSearch>(input))
|
.ProjectToType<EquipmentBaseInfoOutput>()
|
.ToADPagedListAsync(input.PageNo, input.PageSize);
|
return equipmentBaseInfos;
|
|
}
|
|
/// <summary>
|
/// 根据设备基础信息管理导出Excel
|
/// </summary>
|
/// <param name="input">设备基础信息管理</param>
|
/// <returns>导出的Excel文件</returns>
|
[HttpGet("toExcel")]
|
public async Task<IActionResult> ToExcelAsync([FromQuery] EquipmentBaseInfoSearch input)
|
{
|
var equipmentBaseInfos = await _equipmentBaseInfoRep.DetachedEntities
|
.Where(!string.IsNullOrEmpty(input.EquipmentId), u => u.EquipmentId == input.EquipmentId)
|
.Where(!string.IsNullOrEmpty(input.EquipmentName), u => u.EquipmentName == input.EquipmentName)
|
.Where(!string.IsNullOrEmpty(input.WorkingProcedure), u => EF.Functions.Like(u.WorkingProcedure, $"%{input.WorkingProcedure.Trim()}%"))
|
.Where(!string.IsNullOrEmpty(input.EquipmentModel), u => EF.Functions.Like(u.EquipmentModel, $"%{input.EquipmentModel.Trim()}%"))
|
.Select(s=>new EquipmentBaseInfoExcelOutput
|
{
|
Id = s.Id,
|
EquipmentId = s.EquipmentId,
|
EquipmentName = s.EquipmentName,
|
WorkingProcedure = s.WorkingProcedure,
|
EquipmentModel = s.EquipmentModel,
|
EquipmentIP = s.EquipmentIP,
|
EquipmentFunction = s.EquipmentFunction,
|
//EquipmentBrand = s.EquipmentBrand,
|
EquipmentManufacturer = s.EquipmentManufacturer,
|
Detergentchangetime = s.Detergentchangetime,
|
DetergentChangeAlertThreshold = s.DetergentChangeAlertThreshold,
|
//DetergentChangeCycle = s.DetergentChangeCycle,
|
CuttingFluidChangeTime = s.CuttingFluidChangeTime,
|
CuttingFluidChangeAlertThreshold = s.CuttingFluidChangeAlertThreshold,
|
CreatedTime = s.CreatedTime.ConvertToDateTime(),
|
UpdatedTime= s.UpdatedTime.ConvertToDateTime(),
|
TactTime = s.TactTime,
|
})
|
.Distinct()
|
.OrderBy(PageInputOrder.OrderBuilder<EquipmentBaseInfoSearch>(input))
|
.ProjectToType<EquipmentBaseInfoExcelOutput>().ToListAsync();
|
|
//foreach (EquipmentBaseInfoExcelOutput item in equipmentBaseInfos)
|
//{
|
// item.CreatedTime = !item.CreatedTime.HasValue ? null : Convert.ToDateTime(item.CreatedTime).ToString("yyyy-MM-dd hh:mm");
|
//}
|
|
MemoryStream ms = new();
|
DataConvertUtil.ToExcelData(equipmentBaseInfos, _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 };
|
}
|
|
/// <summary>
|
/// 增加设备基础信息管理
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("add")]
|
public async Task Add(AddEquipmentBaseInfoInput input)
|
{
|
var isExist = await _equipmentBaseInfoRep.AnyAsync(u => u.EquipmentId == input.EquipmentId, false);
|
if (isExist) throw Oops.Oh($"当前设备编号已存在，新增失败！");
|
|
var equipmentBaseInfo = input.Adapt<EquipmentBaseInfo>();
|
await _equipmentBaseInfoRep.InsertAsync(equipmentBaseInfo);
|
}
|
|
/// <summary>
|
/// 删除设备基础信息管理
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("delete")]
|
public async Task Delete(DeleteEquipmentBaseInfoInput input)
|
{
|
string[] EquiArr = new string[] {"EOP10", "EOP20", "EOP30", "EOP35", "EOP40", "EOP50", "EOP60", "EOP70", "EOP80" };
|
|
var equipmentBaseInfo = await _equipmentBaseInfoRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
|
if(EquiArr.Contains(equipmentBaseInfo.EquipmentId)) throw Oops.Oh($"系统默认的设备不能进行删除！");
|
|
await _equipmentBaseInfoRep.DeleteAsync(equipmentBaseInfo);
|
}
|
|
/// <summary>
|
/// 批量删除设备基础信息管理
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("selectDelete")]
|
public async Task SelectDelete(List<EquipmentBaseInfoInput> input)
|
{
|
StringBuilder builder = new StringBuilder();
|
string[] EquiArr = new string[] { "EOP10", "EOP20", "EOP30", "EOP35", "EOP40", "EOP50", "EOP60", "EOP70", "EOP80" };
|
foreach (EquipmentBaseInfoInput item in input)
|
{
|
if (EquiArr.Contains(item.EquipmentId)) {
|
|
if (string.IsNullOrEmpty(builder.ToString()))
|
{
|
builder.Append(item.EquipmentId);
|
}
|
else
|
{
|
builder.Append("," + item.EquipmentId);
|
}
|
}
|
}
|
|
if (!string.IsNullOrEmpty(builder.ToString()))
|
{
|
throw Oops.Oh($"系统默认的设备【"+builder.ToString()+"】不能进行删除！");
|
}
|
|
foreach (var item in input)
|
{
|
var equipmentBaseInfo = await _equipmentBaseInfoRep.FirstOrDefaultAsync(u => u.Id == item.Id);
|
await _equipmentBaseInfoRep.DeleteAsync(equipmentBaseInfo);
|
}
|
}
|
|
/// <summary>
|
/// 更新设备基础信息管理
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("edit")]
|
public async Task Update(UpdateEquipmentBaseInfoInput input)
|
{
|
var isExist = await _equipmentBaseInfoRep.AnyAsync(u => u.Id == input.Id && u.EquipmentId == input.EquipmentId, false);
|
if (!isExist) throw Oops.Oh($"设备编号不能进行变更，修改失败！");
|
|
var equipmentBaseInfo = input.Adapt<EquipmentBaseInfo>();
|
await _equipmentBaseInfoRep.UpdateAsync(equipmentBaseInfo,ignoreNullValues:false);
|
}
|
|
/// <summary>
|
/// 获取设备基础信息管理
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("detail")]
|
public async Task<EquipmentBaseInfoOutput> Get([FromQuery] QueryeEquipmentBaseInfoInput input)
|
{
|
return (await _equipmentBaseInfoRep.DetachedEntities.FirstOrDefaultAsync(u => u.Id == input.Id)).Adapt<EquipmentBaseInfoOutput>();
|
}
|
|
/// <summary>
|
/// 获取设备基础信息管理列表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("list")]
|
public async Task<List<EquipmentBaseInfoOutput>> List([FromQuery] EquipmentBaseInfoInput input)
|
{
|
return await _equipmentBaseInfoRep.DetachedEntities.ProjectToType<EquipmentBaseInfoOutput>().ToListAsync();
|
}
|
|
/// <summary>
|
/// 查询设备基础信息
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet("GetSelectEquipmentName")]
|
public async Task<List<EquipmentBaseInfoOutput>> GetSelectEquipmentName([FromQuery] string Type)
|
{
|
List<string> names = new List<string>();//有测量信息的设备
|
names.Add("EOP10");
|
names.Add("EOP20");
|
names.Add("EOP30");
|
names.Add("EOP35");
|
names.Add("EOP40");
|
names.Add("EOP60");
|
names.Add("EOP80");
|
List<string> KnifeToolnames = new List<string>();//有刀具的设备
|
KnifeToolnames.Add("EOP10");
|
KnifeToolnames.Add("EOP20");
|
KnifeToolnames.Add("EOP35");
|
KnifeToolnames.Add("EOP50");
|
KnifeToolnames.Add("EOP60");
|
var equipmentBaseInfos = await _equipmentBaseInfoRep.DetachedEntities
|
.Where(!string.IsNullOrEmpty(Type), u => (Type.ToUpper().Equals("QUALITY")?names.Contains(u.EquipmentId):false)||(Type.ToUpper().Equals("KNIFETOOL") ? KnifeToolnames.Contains(u.EquipmentId) : false))
|
.ProjectToType<EquipmentBaseInfoOutput>()
|
.OrderBy(o=>o.EquipmentId)
|
.ToListAsync();
|
return equipmentBaseInfos;
|
}
|
|
}
|
}
|
