using CMS.Plugin.PipeLineLems.Application.Contracts.Dtos.CallMaterialOrderRecord;
using CMS.Plugin.PipeLineLems.Application.Contracts.Services;
using CMS.Plugin.PipeLineLems.Domain.Shared;
using CmsQueryExtensions;
using CMS.Plugin.PipeLineLems.Domain.CallMaterialOrderRecord;
using CmsQueryExtensions.Extension;
using System.Linq.Expressions;
using Volo.Abp;
using Volo.Abp.Application.Dtos;
using Volo.Abp.Data;
using Volo.Abp.ObjectExtending;
using Volo.Abp.ObjectMapping;
namespace CMS.Plugin.PipeLineLems.Application.Implements;
///
/// 叫料记录表应用服务
///
public class CallMaterialOrderRecordAppService : CMSPluginAppService, ICallMaterialOrderRecordAppService
{
private readonly ICallMaterialOrderRecordRepository callMaterialOrderRecordRepository;
///
/// Initializes a new instance of the class.
///
/// The task job repository.
public CallMaterialOrderRecordAppService(ICallMaterialOrderRecordRepository _CallMaterialOrderRecordRepository)
{
callMaterialOrderRecordRepository = _CallMaterialOrderRecordRepository;
}
///
/// 获取指定叫料记录表
///
///
///
public virtual async Task GetAsync(Guid id)
{
return ObjectMapper.Map(await callMaterialOrderRecordRepository.GetAsync(id));
}
///
/// 分页获取叫料记录表
///
///
///
public virtual async Task> GetListAsync(GetCallMaterialOrderRecordInput input)
{
Check.NotNull(input, nameof(input));
if (input.Sorting.IsNullOrWhiteSpace())
{
input.Sorting = nameof(CallMaterialOrderRecord.Sort);
}
#region 动态构造查询条件
//动态构造查询条件
var whereConditions = DynamicGetQueryParams(input);
#endregion
var count = await callMaterialOrderRecordRepository.GetCountAsync(whereConditions);
var list = await callMaterialOrderRecordRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount);
return new PagedResultDto(count, ObjectMapper.Map, List>(list));
}
///
/// 动态构造查询条件
///
/// 输入参数
///
private FunReturnResultModel>> DynamicGetQueryParams(GetCallMaterialOrderRecordInput input)
{
//动态构造查询条件
var whereConditions = WhereConditionsExtensions.GetWhereConditions(input);
if (!whereConditions.IsSuccess)
{
throw new Exception("动态构造查询条件失败:" + whereConditions.ErrMsg);
}
//也可再次自定义构建查询条件
Expression> extendExpression = a => a.IsDeleted == false;
// 使用 System.Linq.PredicateBuilder 的 And
var pres = (System.Linq.Expressions.Expression>)(whereConditions.data);
whereConditions.data = System.Linq.PredicateBuilder.And(pres, extendExpression);
return whereConditions;
}
///
/// 新建叫料记录表
///
///
///
///
public virtual async Task CreateAsync(CallMaterialOrderRecordCreateDto input)
{
await CheckCreateOrUpdateDtoAsync(input);
var exist = await callMaterialOrderRecordRepository.NameExistAsync(input.DataIdentifier);
if (exist)
{
throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.DataIdentifier]);
}
var maxSort = await callMaterialOrderRecordRepository.GetMaxSortAsync();
var sort = input.Sort ?? maxSort;
var insertObj = ObjectMapper.Map(input);
insertObj.Sort = sort;
input.MapExtraPropertiesTo(insertObj, MappingPropertyDefinitionChecks.None);
await callMaterialOrderRecordRepository.InsertAsync(insertObj);
//if (input.Sort.HasValue && insertObj.Sort != maxSort)
//{
// await AdjustSortAsync(insertObj.Id, insertObj.Sort);
//}
return ObjectMapper.Map(insertObj);
}
///
/// 更新叫料记录表
///
///
///
///
///
public virtual async Task UpdateAsync(Guid id, CallMaterialOrderRecordUpdateDto input)
{
await CheckCreateOrUpdateDtoAsync(input);
var updateObj = await callMaterialOrderRecordRepository.GetAsync(id);
var exist = await callMaterialOrderRecordRepository.NameExistAsync(input.DataIdentifier, updateObj.Id);
if (exist)
{
throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.DataIdentifier]);
}
updateObj.SetConcurrencyStampIfNotNull(input.ConcurrencyStamp);
input.MapExtraPropertiesTo(updateObj, MappingPropertyDefinitionChecks.None);
updateObj.DataIdentifier = input.DataIdentifier;
updateObj.MaterialMode = input.MaterialMode;
updateObj.CallMaterialStatus = input.CallMaterialStatus;
updateObj.Quantity = input.Quantity;
updateObj.WmsRetResult = input.WmsRetResult;
updateObj.WmsTaskNo = input.WmsTaskNo;
updateObj.Remark = input.Remark;
await callMaterialOrderRecordRepository.UpdateAsync(updateObj);
return ObjectMapper.Map(updateObj);
}
///
/// 克隆叫料记录表
///
///
///
public async Task> CloneAsync(IEnumerable ids)
{
//var callMaterialOrderRecords = new List();
//if (ids != null)
//{
// var sort = await callMaterialOrderRecordRepository.GetMaxSortAsync();
// foreach (var id in ids)
// {
// var CallMaterialOrderRecord = await callMaterialOrderRecordRepository.FindAsync(id);
// if (CallMaterialOrderRecord != null)
// {
// var name = CallMaterialOrderRecord.Name + CallMaterialOrderRecordConsts.CloneTag;
// var notExist = false;
// while (!notExist)
// {
// var exist = await callMaterialOrderRecordRepository.NameExistAsync(name);
// if (exist || callMaterialOrderRecords.Any(x => x.Name == name))
// {
// name += CallMaterialOrderRecordConsts.CloneTag;
// continue;
// }
// notExist = true;
// }
// //CallMaterialOrderRecord = await callMaterialOrderRecordRepository.InsertAsync(CallMaterialOrderRecord.Clone(GuidGenerator.Create(), name, sort++));
// callMaterialOrderRecords.Add(CallMaterialOrderRecord);
// }
// }
//}
//return ObjectMapper.Map, List>(callMaterialOrderRecords);
return new List();
}
///
/// 删除单个叫料记录表
///
///
///
public virtual Task DeleteAsync(Guid id)
{
return callMaterialOrderRecordRepository.DeleteAsync(id);
}
///
/// 删除多个叫料记录表
///
///
///
public async Task DeleteManyAsync(IEnumerable ids)
{
foreach (var id in ids)
{
await DeleteAsync(id);
}
}
///
/// 调整排序叫料记录表
///
///
///
///
public virtual async Task AdjustSortAsync(Guid id, int sort)
{
var list = await callMaterialOrderRecordRepository.GetListAsync(null, nameof(CallMaterialOrderRecord.Sort));
if (list != null && list.Any())
{
var initSort = 1;
list.ForEach(x => x.AdjustSort(initSort++));
var entity = list.FirstOrDefault(x => x.Id == id);
if (entity != null)
{
if (sort == 1)
{
list.Where(x => x.Id != id).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1));
}
else if (entity.Sort > sort)
{
list.Where(x => x.Id != id && x.Sort >= sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1));
list.Where(x => x.Id != id && x.Sort < sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort - 1));
}
else if (entity.Sort < sort)
{
list.Where(x => x.Id != id && x.Sort > sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort + 1));
list.Where(x => x.Id != id && x.Sort <= sort).ToList()?.ForEach(x => x.AdjustSort(x.Sort - 1));
}
entity.AdjustSort(sort);
}
}
await callMaterialOrderRecordRepository.UpdateManyAsync(list);
}
///
/// 导入叫料记录表
///
///
///
///
public async Task ImportAsync(CallMaterialOrderRecordsImportModel input)
{
Check.NotNull(input, nameof(input));
var callMaterialOrderRecordCreateDtos = new List<(int RowIndex, CallMaterialOrderRecordCreateDto Item)>();
var callMaterialOrderRecordUpdateDtos = new List<(int RowIndex, Guid Id, CallMaterialOrderRecordUpdateDto Item)>();
var importItems = input.CallMaterialOrderRecords;
if (importItems != null && importItems.Any())
{
#region 导入校验
// 判断名称是否重复,并输出第几行重复
var duplicateCallMaterialOrderRecords = importItems.GroupBy(x => x.DataIdentifier).Where(x => x.Count() > 1).ToList();
if (duplicateCallMaterialOrderRecords?.Any() == true)
{
var duplicateCallMaterialOrderRecordMsgs = duplicateCallMaterialOrderRecords.Select(x => $"第 {string.Join(",", x.Select(x => x.RowIndex))} 行:{x.Key} 名称重复");
var errorMsg = $"导入失败!配置, {string.Join(",", duplicateCallMaterialOrderRecordMsgs)},终止导入";
throw new UserFriendlyException(errorMsg);
}
#endregion
foreach (var impItem in importItems)
{
if (impItem.DataIdentifier.IsNullOrWhiteSpace())
{
continue;
}
if (impItem.DataIdentifier.IsNullOrWhiteSpace())
{
var errorMsg = $"导入失败!配置,第{impItem.RowIndex}行:CallMaterialOrderRecord名称不能为空";
throw new UserFriendlyException(errorMsg);
}
var oldCallMaterialOrderRecord = await callMaterialOrderRecordRepository.FindByNameAsync(impItem.DataIdentifier);
if (oldCallMaterialOrderRecord != null)
{
var callMaterialOrderRecordUpdateDto = new CallMaterialOrderRecordUpdateDto
{
DataIdentifier = impItem.DataIdentifier,
MaterialMode = impItem.MaterialMode,
CallMaterialStatus = impItem.CallMaterialStatus,
Quantity = impItem.Quantity,
WmsRetResult = impItem.WmsRetResult,
WmsTaskNo = impItem.WmsTaskNo,
Remark = impItem.Remark,
};
callMaterialOrderRecordUpdateDtos.Add((impItem.RowIndex, oldCallMaterialOrderRecord.Id, callMaterialOrderRecordUpdateDto));
}
else
{
var callMaterialOrderRecordCreateDto = new CallMaterialOrderRecordCreateDto
{
DataIdentifier = impItem.DataIdentifier,
MaterialMode = impItem.MaterialMode,
CallMaterialStatus = impItem.CallMaterialStatus,
Quantity = impItem.Quantity,
WmsRetResult = impItem.WmsRetResult,
WmsTaskNo = impItem.WmsTaskNo,
Remark = impItem.Remark,
};
callMaterialOrderRecordCreateDtos.Add((impItem.RowIndex, callMaterialOrderRecordCreateDto));
}
}
}
// 新增
foreach (var callMaterialOrderRecordDto in callMaterialOrderRecordCreateDtos)
{
try
{
await CreateAsync(callMaterialOrderRecordDto.Item);
}
catch (Exception e)
{
var errorMsg = $"导入失败!配置,第{callMaterialOrderRecordDto.RowIndex}行:{e.Message},终止导入";
throw new UserFriendlyException(errorMsg);
}
}
// 更新
foreach (var callMaterialOrderRecordDto in callMaterialOrderRecordUpdateDtos)
{
try
{
await UpdateAsync(callMaterialOrderRecordDto.Id, callMaterialOrderRecordDto.Item);
}
catch (Exception e)
{
var errorMsg = $"导入失败!配置,第{callMaterialOrderRecordDto.RowIndex}行:{e.Message},终止导入";
throw new UserFriendlyException(errorMsg);
}
}
}
///
/// 导出叫料记录表
///
///
///
public async Task<(Dictionary Sheets, string FileName)> ExportAsync(GetCallMaterialOrderRecordInput input)
{
Check.NotNull(input, nameof(input));
if (input.Sorting.IsNullOrWhiteSpace())
{
input.Sorting = nameof(CallMaterialOrderRecord.Sort);
}
#region 动态构造查询条件
//动态构造查询条件
var whereConditions = DynamicGetQueryParams(input);
#endregion
var list = await callMaterialOrderRecordRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true);
var result = ObjectMapper.Map, List>(list);
var sheets = new Dictionary
{
["配置"] = ExportHelper.ConvertListToExportData(result),
};
var fileName = "叫料记录";
return (sheets, fileName);
}
///
/// 校验叫料记录表,当新建或更新时
///
///
///
protected Task CheckCreateOrUpdateDtoAsync(CallMaterialOrderRecordCreateOrUpdateDtoBase input)
{
Check.NotNull(input, nameof(input));
Check.NotNullOrWhiteSpace(input.DataIdentifier, "原料标识", 256);
Check.NotNull(input.CallMaterialStatus, "叫料状态");
Check.NotNull(input.Quantity, "叫料数量");
return Task.CompletedTask;
}
}