using iWare.Wms.Core;
|
using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.Extras.iWare.Wms.Util.LowCode.Front.Model;
|
using Furion.FriendlyException;
|
using Mapster;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
|
namespace iWare.Wms.Application
|
{
|
/// <summary>
|
/// 字典值服务
|
/// </summary>
|
[ApiDescriptionSettings(Name = "DictData", Order = 100)]
|
[AllowAnonymous]
|
[Route("api")]
|
public class SysDictDataService : ISysDictDataService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<SysDictData> _sysDictDataRep; // 字典明细表仓储
|
private readonly IRepository<SysDictType> _sysDictTypeRep; // 字典类型表仓储
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
/// <param name="sysDictDataRep"></param>
|
/// <param name="sysDictTypeRep"></param>
|
public SysDictDataService(IRepository<SysDictData> sysDictDataRep, IRepository<SysDictType> sysDictTypeRep)
|
{
|
_sysDictDataRep = sysDictDataRep;
|
_sysDictTypeRep = sysDictTypeRep;
|
}
|
|
/// <summary>
|
/// 分页查询字典值
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysDictData/page")]
|
public async Task<PageResult<DictDataOutput>> QueryDictDataPageList([FromQuery] DictDataPageInput input)
|
{
|
bool supperAdmin = CurrentUserInfo.IsSuperAdmin;
|
var code = !string.IsNullOrEmpty(input.Code?.Trim());
|
var value = !string.IsNullOrEmpty(input.Value?.Trim());
|
var dictDatas = await _sysDictDataRep.DetachedEntities
|
.Where(u => u.TypeId == input.TypeId)
|
.Where((code, u => EF.Functions.Like(u.Code, $"%{input.Code.Trim()}%")),
|
(value, u => EF.Functions.Like(u.Value, $"%{input.Value.Trim()}%")))
|
.Where(u => (u.Status != CommonStatus.DELETED && !supperAdmin) || (u.Status <= CommonStatus.DELETED && supperAdmin))
|
.OrderBy(u => u.Sort)
|
.ProjectToType<DictDataOutput>()
|
.ToADPagedListAsync(input.PageNo, input.PageSize);
|
return dictDatas;
|
}
|
|
/// <summary>
|
/// 获取某个字典类型下字典值列表
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet("sysDictData/list")]
|
public async Task<List<SysDictData>> GetDictDataList([FromQuery] QueryDictDataListInput input)
|
{
|
return await _sysDictDataRep.DetachedEntities.Where(u => u.TypeId == input.TypeId)
|
.Where(u => u.Status != CommonStatus.DELETED)
|
.OrderBy(u => u.Sort)
|
.ToListAsync();
|
}
|
|
/// <summary>
|
/// 获取某个字典类型下字典值列表
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet("sysDictData/listbycode")]
|
public async Task<List<Front_Option>> GetDictDataListByCode([FromQuery] QueryDictDataListByCodeInput input)
|
{
|
var typeid = await _sysDictTypeRep.Where(x => x.Code == input.Code).Select(x => x.Id).FirstOrDefaultAsync();
|
|
return await _sysDictDataRep.DetachedEntities.Where(u => u.TypeId == typeid)
|
.Where(u => u.Status != CommonStatus.DELETED)
|
.OrderBy(u => u.Sort)
|
.Select(u => new Front_Option() { Label = u.Value, Value = u.Code })
|
.ToListAsync();
|
}
|
|
/// <summary>
|
/// 增加字典值
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("sysDictData/add")]
|
public async Task AddDictData(AddDictDataInput input)
|
{
|
var isExist = await _sysDictDataRep.AnyAsync(u => (u.Code == input.Code || u.Value == input.Value) && u.TypeId == input.TypeId, false);
|
if (isExist) throw Oops.Oh(ErrorCode.D3003);
|
|
var dictData = input.Adapt<SysDictData>();
|
await _sysDictDataRep.InsertAsync(dictData);
|
}
|
|
/// <summary>
|
/// 删除字典值
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("sysDictData/delete")]
|
public async Task DeleteDictData(DeleteDictDataInput input)
|
{
|
var dictData = await _sysDictDataRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
if (dictData == null) throw Oops.Oh(ErrorCode.D3004);
|
if (dictData.Status == CommonStatus.DELETED)
|
{
|
await dictData.DeleteAsync();
|
}
|
else
|
{
|
dictData.Status = CommonStatus.DELETED;
|
dictData.IsDeleted = true;
|
}
|
}
|
|
/// <summary>
|
/// 更新字典值
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("sysDictData/edit")]
|
public async Task UpdateDictData(UpdateDictDataInput input)
|
{
|
var isExist = await _sysDictDataRep.AnyAsync(u => u.Id == input.Id, false);
|
if (!isExist) throw Oops.Oh(ErrorCode.D3004);
|
|
// 排除自己并且判断与其他是否相同
|
isExist = await _sysDictDataRep.AnyAsync(u => (u.Value == input.Value || u.Code == input.Code) && u.TypeId == input.TypeId && u.Id != input.Id, false);
|
if (isExist) throw Oops.Oh(ErrorCode.D3003);
|
|
var dictData = input.Adapt<SysDictData>();
|
await _sysDictDataRep.UpdateAsync(dictData, ignoreNullValues: true);
|
}
|
|
/// <summary>
|
/// 字典值详情
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("sysDictData/detail")]
|
public async Task<SysDictData> GetDictData([FromQuery] QueryDictDataInput input)
|
{
|
return await _sysDictDataRep.FirstOrDefaultAsync(u => u.Id == input.Id, false);
|
}
|
|
/// <summary>
|
/// 修改字典值状态
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("sysDictData/changeStatus")]
|
public async Task ChangeDictDataStatus(ChageStateDictDataInput input)
|
{
|
var dictData = await _sysDictDataRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
if (dictData == null) throw Oops.Oh(ErrorCode.D3004);
|
|
if (!Enum.IsDefined(typeof(CommonStatus), input.Status))
|
throw Oops.Oh(ErrorCode.D3005);
|
|
dictData.Status = input.Status;
|
dictData.IsDeleted = false;
|
}
|
|
/// <summary>
|
/// 根据字典类型Id获取字典值集合
|
/// </summary>
|
/// <param name="dictTypeId"></param>
|
/// <returns></returns>
|
[NonAction]
|
public async Task<List<SysDictData>> GetDictDataListByDictTypeId(long dictTypeId)
|
{
|
return await _sysDictDataRep.DetachedEntities.Where(u => u.SysDictType.Id == dictTypeId)
|
.Where(u => u.Status == CommonStatus.ENABLE).OrderBy(u => u.Sort)
|
.ToListAsync();
|
}
|
|
/// <summary>
|
/// 删除字典下所有值
|
/// </summary>
|
/// <param name="dictTypeId"></param>
|
[NonAction]
|
public async Task DeleteByTypeId(long dictTypeId)
|
{
|
var dictDatas = await _sysDictDataRep.Where(u => u.TypeId == dictTypeId).ToListAsync();
|
await _sysDictDataRep.DeleteAsync(dictDatas);
|
}
|
}
|
}
|
