| | |
| | | using Volo.Abp.Data; |
| | | using Volo.Abp.ObjectExtending; |
| | | using Volo.Abp.ObjectMapping; |
| | | using CMS.Plugin.FormulaManagement.Abstractions; |
| | | using CMS.Plugin.OrderManagement.Abstractions.Enums; |
| | | using CMS.Plugin.OrderManagement.Abstractions.Models; |
| | | using CMS.Plugin.OrderManagement.Abstractions; |
| | | using CMS.Plugin.ProductManagement.Abstractions; |
| | | using Microsoft.Extensions.DependencyInjection; |
| | | using Volo.Abp.Users; |
| | | |
| | | namespace CMS.Plugin.PipeLineLems.Application.Implements; |
| | | |
| | |
| | | /// </summary> |
| | | public class WorkPlanAppService : CMSPluginAppService, IWorkPlanAppService |
| | | { |
| | | private readonly IWorkPlanRepository workPlanRepository; |
| | | private readonly IServiceProvider _serviceProvider; |
| | | private readonly IWorkPlanRepository _workPlanRepository; |
| | | private readonly SharedService _sharedService; |
| | | |
| | | private readonly IServiceProvider _serviceProvider; |
| | | /// <summary> |
| | | /// Initializes a new instance of the <see cref="WorkPlanAppService"/> class. |
| | | /// </summary> |
| | | /// <param name="WorkPlanRepository">The task job repository.</param> |
| | | public WorkPlanAppService(IWorkPlanRepository _WorkPlanRepository, IServiceProvider serviceProvider, SharedService sharedService) |
| | | public WorkPlanAppService(IWorkPlanRepository workPlanRepository, SharedService sharedService, IServiceProvider serviceProvider) |
| | | { |
| | | workPlanRepository = _WorkPlanRepository; |
| | | _serviceProvider = serviceProvider; |
| | | _workPlanRepository = workPlanRepository; |
| | | _sharedService = sharedService; |
| | | _serviceProvider = serviceProvider; |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// <returns></returns> |
| | | public virtual async Task<WorkPlanDto> GetAsync(Guid id) |
| | | { |
| | | return ObjectMapper.Map<WorkPlan, WorkPlanDto>(await workPlanRepository.GetAsync(id)); |
| | | return ObjectMapper.Map<WorkPlan, WorkPlanDto>(await _workPlanRepository.GetAsync(id)); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 按照 原料标记 查找作业计划表 |
| | | /// </summary> |
| | | /// <param name="name"></param> |
| | | /// <param name="cancellationToken"></param> |
| | | /// <returns></returns> |
| | | public virtual async Task<List<WorkPlan>> FindByDataIdentifierAsync(string dataIdentifier) |
| | | { |
| | | return await _workPlanRepository.FindByDataIdentifierAsync(dataIdentifier); |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | |
| | | #endregion |
| | | |
| | | var count = await workPlanRepository.GetCountAsync(whereConditions); |
| | | var list = await workPlanRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount); |
| | | var count = await _workPlanRepository.GetCountAsync(whereConditions); |
| | | var list = await _workPlanRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount); |
| | | |
| | | return new PagedResultDto<WorkPlanDto>(count, ObjectMapper.Map<List<WorkPlan>, List<WorkPlanDto>>(list)); |
| | | } |
| | |
| | | { |
| | | await CheckCreateOrUpdateDtoAsync(input); |
| | | |
| | | var exist = await workPlanRepository.NameExistAsync(input.TaskCode); |
| | | var exist = await _workPlanRepository.NameExistAsync(input.TaskCode); |
| | | if (exist) |
| | | { |
| | | throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.TaskCode]); |
| | | } |
| | | |
| | | var maxSort = await workPlanRepository.GetMaxSortAsync(); |
| | | var maxSort = await _workPlanRepository.GetMaxSortAsync(); |
| | | var sort = input.Sort ?? maxSort; |
| | | |
| | | var insertObj = ObjectMapper.Map<WorkPlanCreateDto, WorkPlan>(input); |
| | | insertObj.Sort = sort; |
| | | insertObj.CreatorName = "SuperAdmin"; |
| | | input.MapExtraPropertiesTo(insertObj, MappingPropertyDefinitionChecks.None); |
| | | |
| | | await workPlanRepository.InsertAsync(insertObj); |
| | | await _workPlanRepository.InsertAsync(insertObj); |
| | | |
| | | //if (input.Sort.HasValue && insertObj.Sort != maxSort) |
| | | //{ |
| | |
| | | { |
| | | await CheckCreateOrUpdateDtoAsync(input); |
| | | |
| | | var updateObj = await workPlanRepository.GetAsync(id); |
| | | var exist = await workPlanRepository.NameExistAsync(input.TaskCode, updateObj.Id); |
| | | var updateObj = await _workPlanRepository.GetAsync(id); |
| | | var exist = await _workPlanRepository.NameExistAsync(input.TaskCode, updateObj.Id); |
| | | if (exist) |
| | | { |
| | | throw new UserFriendlyException(L[CMSPluginDomainErrorCodes.NameAlreadyExists, input.TaskCode]); |
| | |
| | | input.MapExtraPropertiesTo(updateObj, MappingPropertyDefinitionChecks.None); |
| | | |
| | | updateObj.TaskCode = input.TaskCode; |
| | | updateObj.WorkPlanStatus = input.WorkPlanStatus; |
| | | updateObj.CallMaterialStatus = input.CallMaterialStatus; |
| | | updateObj.DataIdentifier = input.DataIdentifier; |
| | | updateObj.MaterialMode = input.MaterialMode; |
| | | updateObj.Length = input.Length; |
| | |
| | | updateObj.OuterDiameter = input.OuterDiameter; |
| | | updateObj.Thickness = input.Thickness; |
| | | updateObj.Material = input.Material; |
| | | updateObj.HasMainSignature = input.HasMainSignature; |
| | | updateObj.ProcessRouteNumber = input.ProcessRouteNumber; |
| | | updateObj.PlannedStartTime = input.PlannedStartTime; |
| | | updateObj.PlannedEndTime = input.PlannedEndTime; |
| | |
| | | updateObj.Remark = input.Remark; |
| | | |
| | | |
| | | await workPlanRepository.UpdateAsync(updateObj); |
| | | await _workPlanRepository.UpdateAsync(updateObj); |
| | | |
| | | return ObjectMapper.Map<WorkPlan, WorkPlanDto>(updateObj); |
| | | } |
| | |
| | | /// <returns></returns> |
| | | public virtual Task DeleteAsync(Guid id) |
| | | { |
| | | return workPlanRepository.DeleteAsync(id); |
| | | return _workPlanRepository.DeleteAsync(id); |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// <returns></returns> |
| | | public virtual async Task AdjustSortAsync(Guid id, int sort) |
| | | { |
| | | var list = await workPlanRepository.GetListAsync(null, nameof(WorkPlan.Sort)); |
| | | var list = await _workPlanRepository.GetListAsync(null, nameof(WorkPlan.Sort)); |
| | | if (list != null && list.Any()) |
| | | { |
| | | var initSort = 1; |
| | |
| | | } |
| | | } |
| | | |
| | | await workPlanRepository.UpdateManyAsync(list); |
| | | await _workPlanRepository.UpdateManyAsync(list); |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// <param name="input"></param> |
| | | /// <returns></returns> |
| | | /// <exception cref="UserFriendlyException"></exception> |
| | | public async Task ImportAsync(WorkPlansImportModel input) |
| | | public async Task ImportAsync(WorkPlansImportModel input, string userId, string userAccount) |
| | | { |
| | | |
| | | //转换数据 |
| | | var result = ObjectMapper.Map<List<WorkPlansImportModel.WorkPlanImportModel>, List<WorkPlanInput>>(input.WorkPlans); |
| | | |
| | | //await CreatebyApsAsync(result); |
| | | await _sharedService.CommonCreatebyApsAsync(result, _serviceProvider, this); |
| | | await _sharedService.CommonCreatebyApsAsync(result, _serviceProvider, this, userId, userAccount); |
| | | // Check.NotNull(input, nameof(input)); |
| | | |
| | | // var workPlanCreateDtos = new List<(int RowIndex, WorkPlanCreateDto Item)>(); |
| | | // var workPlanUpdateDtos = new List<(int RowIndex, Guid Id, WorkPlanUpdateDto Item)>(); |
| | | // var importItems = input.WorkPlans; |
| | | |
| | | // if (importItems != null && importItems.Any()) |
| | | // { |
| | | // #region 导入校验 |
| | | |
| | | // // 判断名称是否重复,并输出第几行重复 |
| | | // var duplicateWorkPlans = importItems.GroupBy(x => x.TaskCode).Where(x => x.Count() > 1).ToList(); |
| | | // if (duplicateWorkPlans?.Any() == true) |
| | | // { |
| | | // var duplicateWorkPlanMsgs = duplicateWorkPlans.Select(x => $"第 {string.Join(",", x.Select(x => x.RowIndex))} 行:{x.Key} 名称重复"); |
| | | // var errorMsg = $"导入失败!配置, {string.Join(",", duplicateWorkPlanMsgs)},终止导入"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | |
| | | // #endregion |
| | | |
| | | // foreach (var impItem in importItems) |
| | | // { |
| | | // if (impItem.TaskCode.IsNullOrWhiteSpace()) |
| | | // { |
| | | // continue; |
| | | // } |
| | | |
| | | // if (impItem.TaskCode.IsNullOrWhiteSpace()) |
| | | // { |
| | | // var errorMsg = $"导入失败!配置,第{impItem.RowIndex}行:WorkPlan名称不能为空"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | |
| | | // var oldWorkPlan = await workPlanRepository.FindByNameAsync(impItem.TaskCode); |
| | | // if (oldWorkPlan != null) |
| | | // { |
| | | // var workPlanUpdateDto = new WorkPlanUpdateDto |
| | | // { |
| | | // TaskCode = impItem.TaskCode, |
| | | //WorkPlanStatus = impItem.WorkPlanStatus, |
| | | //CallMaterialStatus = impItem.CallMaterialStatus, |
| | | //DataIdentifier = impItem.DataIdentifier, |
| | | //MaterialMode = impItem.MaterialMode, |
| | | //Length = impItem.Length, |
| | | //MarkingContent = impItem.MarkingContent, |
| | | //MarkingPosition = impItem.MarkingPosition, |
| | | //CuttingPosition = impItem.CuttingPosition, |
| | | //Quantity = impItem.Quantity, |
| | | //FlangeThickness = impItem.FlangeThickness, |
| | | //FlangeInnerDiameter = impItem.FlangeInnerDiameter, |
| | | //WeldingHeatInput = impItem.WeldingHeatInput, |
| | | //PipeAllowableStress = impItem.PipeAllowableStress, |
| | | //PipeDiameter = impItem.PipeDiameter, |
| | | //PipeWallThickness = impItem.PipeWallThickness, |
| | | //FactoryCode = impItem.FactoryCode, |
| | | //ProductCode = impItem.ProductCode, |
| | | //WorkstationCode = impItem.WorkstationCode, |
| | | //EquipmentCode = impItem.EquipmentCode, |
| | | //WorkpieceName = impItem.WorkpieceName, |
| | | //ProcessName = impItem.ProcessName, |
| | | //PipeFittingCode = impItem.PipeFittingCode, |
| | | //PreSerialNumber = impItem.PreSerialNumber, |
| | | //PipeSpecCode = impItem.PipeSpecCode, |
| | | //PipeSectionName = impItem.PipeSectionName, |
| | | //OuterDiameter = impItem.OuterDiameter, |
| | | //Thickness = impItem.Thickness, |
| | | //Material = impItem.Material, |
| | | //ProcessRouteNumber = impItem.ProcessRouteNumber, |
| | | //PlannedStartTime = impItem.PlannedStartTime, |
| | | //PlannedEndTime = impItem.PlannedEndTime, |
| | | //TeamInfo = impItem.TeamInfo, |
| | | //Timestamp = impItem.Timestamp, |
| | | //Remark = impItem.Remark, |
| | | |
| | | // }; |
| | | |
| | | // workPlanUpdateDtos.Add((impItem.RowIndex, oldWorkPlan.Id, workPlanUpdateDto)); |
| | | // } |
| | | // else |
| | | // { |
| | | // var workPlanCreateDto = new WorkPlanCreateDto |
| | | // { |
| | | // TaskCode = impItem.TaskCode, |
| | | //WorkPlanStatus = impItem.WorkPlanStatus, |
| | | //CallMaterialStatus = impItem.CallMaterialStatus, |
| | | //DataIdentifier = impItem.DataIdentifier, |
| | | //MaterialMode = impItem.MaterialMode, |
| | | //Length = impItem.Length, |
| | | //MarkingContent = impItem.MarkingContent, |
| | | //MarkingPosition = impItem.MarkingPosition, |
| | | //CuttingPosition = impItem.CuttingPosition, |
| | | //Quantity = impItem.Quantity, |
| | | //FlangeThickness = impItem.FlangeThickness, |
| | | //FlangeInnerDiameter = impItem.FlangeInnerDiameter, |
| | | //WeldingHeatInput = impItem.WeldingHeatInput, |
| | | //PipeAllowableStress = impItem.PipeAllowableStress, |
| | | //PipeDiameter = impItem.PipeDiameter, |
| | | //PipeWallThickness = impItem.PipeWallThickness, |
| | | //FactoryCode = impItem.FactoryCode, |
| | | //ProductCode = impItem.ProductCode, |
| | | //WorkstationCode = impItem.WorkstationCode, |
| | | //EquipmentCode = impItem.EquipmentCode, |
| | | //WorkpieceName = impItem.WorkpieceName, |
| | | //ProcessName = impItem.ProcessName, |
| | | //PipeFittingCode = impItem.PipeFittingCode, |
| | | //PreSerialNumber = impItem.PreSerialNumber, |
| | | //PipeSpecCode = impItem.PipeSpecCode, |
| | | //PipeSectionName = impItem.PipeSectionName, |
| | | //OuterDiameter = impItem.OuterDiameter, |
| | | //Thickness = impItem.Thickness, |
| | | //Material = impItem.Material, |
| | | //ProcessRouteNumber = impItem.ProcessRouteNumber, |
| | | //PlannedStartTime = impItem.PlannedStartTime, |
| | | //PlannedEndTime = impItem.PlannedEndTime, |
| | | //TeamInfo = impItem.TeamInfo, |
| | | //Timestamp = impItem.Timestamp, |
| | | //Remark = impItem.Remark, |
| | | |
| | | // }; |
| | | |
| | | // workPlanCreateDtos.Add((impItem.RowIndex, workPlanCreateDto)); |
| | | // } |
| | | // } |
| | | // } |
| | | |
| | | // // 新增 |
| | | // foreach (var workPlanDto in workPlanCreateDtos) |
| | | // { |
| | | // try |
| | | // { |
| | | // await CreateAsync(workPlanDto.Item); |
| | | // } |
| | | // catch (Exception e) |
| | | // { |
| | | // var errorMsg = $"导入失败!配置,第{workPlanDto.RowIndex}行:{e.Message},终止导入"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | // } |
| | | |
| | | // // 更新 |
| | | // foreach (var workPlanDto in workPlanUpdateDtos) |
| | | // { |
| | | // try |
| | | // { |
| | | // await UpdateAsync(workPlanDto.Id, workPlanDto.Item); |
| | | // } |
| | | // catch (Exception e) |
| | | // { |
| | | // var errorMsg = $"导入失败!配置,第{workPlanDto.RowIndex}行:{e.Message},终止导入"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | // } |
| | | } |
| | | |
| | | |
| | | public async Task<MesOrderResponse> CreatebyApsAsync(List<WorkPlanInput> input) |
| | | { |
| | | var response=await _sharedService.CommonCreatebyApsAsync(input, _serviceProvider, this); |
| | | |
| | | return response; |
| | | } |
| | | |
| | | ///// <summary> |
| | | ///// 导入作业计划表 |
| | | ///// </summary> |
| | | ///// <param name="input"></param> |
| | | ///// <returns></returns> |
| | | ///// <exception cref="UserFriendlyException"></exception> |
| | | //public async Task ImportAsync(WorkPlansImportModel input) |
| | | //{ |
| | | // Check.NotNull(input, nameof(input)); |
| | | |
| | | // var workPlanCreateDtos = new List<(int RowIndex, WorkPlanCreateDto Item)>(); |
| | | // var workPlanUpdateDtos = new List<(int RowIndex, Guid Id, WorkPlanUpdateDto Item)>(); |
| | | // var importItems = input.WorkPlans; |
| | | |
| | | // if (importItems != null && importItems.Any()) |
| | | // { |
| | | // #region 导入校验 |
| | | |
| | | // // 判断名称是否重复,并输出第几行重复 |
| | | // var duplicateWorkPlans = importItems.GroupBy(x => x.TaskCode).Where(x => x.Count() > 1).ToList(); |
| | | // if (duplicateWorkPlans?.Any() == true) |
| | | // { |
| | | // var duplicateWorkPlanMsgs = duplicateWorkPlans.Select(x => $"第 {string.Join(",", x.Select(x => x.RowIndex))} 行:{x.Key} 名称重复"); |
| | | // var errorMsg = $"导入失败!配置, {string.Join(",", duplicateWorkPlanMsgs)},终止导入"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | |
| | | // #endregion |
| | | |
| | | // foreach (var impItem in importItems) |
| | | // { |
| | | // if (impItem.TaskCode.IsNullOrWhiteSpace()) |
| | | // { |
| | | // continue; |
| | | // } |
| | | |
| | | // if (impItem.TaskCode.IsNullOrWhiteSpace()) |
| | | // { |
| | | // var errorMsg = $"导入失败!配置,第{impItem.RowIndex}行:WorkPlan名称不能为空"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | |
| | | // var oldWorkPlan = await workPlanRepository.FindByNameAsync(impItem.TaskCode); |
| | | // if (oldWorkPlan != null) |
| | | // { |
| | | // var workPlanUpdateDto = new WorkPlanUpdateDto |
| | | // { |
| | | // TaskCode = impItem.TaskCode, |
| | | // DataIdentifier = impItem.DataIdentifier, |
| | | // MaterialMode = impItem.MaterialMode, |
| | | // Length = impItem.Length, |
| | | // MarkingContent = impItem.MarkingContent, |
| | | // MarkingPosition = impItem.MarkingPosition, |
| | | // CuttingPosition = impItem.CuttingPosition, |
| | | // Quantity = impItem.Quantity, |
| | | // FlangeThickness = impItem.FlangeThickness, |
| | | // FlangeInnerDiameter = impItem.FlangeInnerDiameter, |
| | | // WeldingHeatInput = impItem.WeldingHeatInput, |
| | | // PipeAllowableStress = impItem.PipeAllowableStress, |
| | | // PipeDiameter = impItem.PipeDiameter, |
| | | // PipeWallThickness = impItem.PipeWallThickness, |
| | | // FactoryCode = impItem.FactoryCode, |
| | | // ProductCode = impItem.ProductCode, |
| | | // WorkstationCode = impItem.WorkstationCode, |
| | | // EquipmentCode = impItem.EquipmentCode, |
| | | // WorkpieceName = impItem.WorkpieceName, |
| | | // ProcessName = impItem.ProcessName, |
| | | // PipeFittingCode = impItem.PipeFittingCode, |
| | | // PreSerialNumber = impItem.PreSerialNumber, |
| | | // PipeSpecCode = impItem.PipeSpecCode, |
| | | // PipeSectionName = impItem.PipeSectionName, |
| | | // OuterDiameter = impItem.OuterDiameter, |
| | | // Thickness = impItem.Thickness, |
| | | // Material = impItem.Material, |
| | | // HasMainSignature = impItem.HasMainSignature, |
| | | // ProcessRouteNumber = impItem.ProcessRouteNumber, |
| | | // PlannedStartTime = impItem.PlannedStartTime, |
| | | // PlannedEndTime = impItem.PlannedEndTime, |
| | | // TeamInfo = impItem.TeamInfo, |
| | | // Timestamp = impItem.Timestamp, |
| | | // Remark = impItem.Remark, |
| | | |
| | | // }; |
| | | |
| | | // workPlanUpdateDtos.Add((impItem.RowIndex, oldWorkPlan.Id, workPlanUpdateDto)); |
| | | // } |
| | | // else |
| | | // { |
| | | // var workPlanCreateDto = new WorkPlanCreateDto |
| | | // { |
| | | // TaskCode = impItem.TaskCode, |
| | | // DataIdentifier = impItem.DataIdentifier, |
| | | // MaterialMode = impItem.MaterialMode, |
| | | // Length = impItem.Length, |
| | | // MarkingContent = impItem.MarkingContent, |
| | | // MarkingPosition = impItem.MarkingPosition, |
| | | // CuttingPosition = impItem.CuttingPosition, |
| | | // Quantity = impItem.Quantity, |
| | | // FlangeThickness = impItem.FlangeThickness, |
| | | // FlangeInnerDiameter = impItem.FlangeInnerDiameter, |
| | | // WeldingHeatInput = impItem.WeldingHeatInput, |
| | | // PipeAllowableStress = impItem.PipeAllowableStress, |
| | | // PipeDiameter = impItem.PipeDiameter, |
| | | // PipeWallThickness = impItem.PipeWallThickness, |
| | | // FactoryCode = impItem.FactoryCode, |
| | | // ProductCode = impItem.ProductCode, |
| | | // WorkstationCode = impItem.WorkstationCode, |
| | | // EquipmentCode = impItem.EquipmentCode, |
| | | // WorkpieceName = impItem.WorkpieceName, |
| | | // ProcessName = impItem.ProcessName, |
| | | // PipeFittingCode = impItem.PipeFittingCode, |
| | | // PreSerialNumber = impItem.PreSerialNumber, |
| | | // PipeSpecCode = impItem.PipeSpecCode, |
| | | // PipeSectionName = impItem.PipeSectionName, |
| | | // OuterDiameter = impItem.OuterDiameter, |
| | | // Thickness = impItem.Thickness, |
| | | // Material = impItem.Material, |
| | | // HasMainSignature = impItem.HasMainSignature, |
| | | // ProcessRouteNumber = impItem.ProcessRouteNumber, |
| | | // PlannedStartTime = impItem.PlannedStartTime, |
| | | // PlannedEndTime = impItem.PlannedEndTime, |
| | | // TeamInfo = impItem.TeamInfo, |
| | | // Timestamp = impItem.Timestamp, |
| | | // Remark = impItem.Remark, |
| | | |
| | | // }; |
| | | |
| | | // workPlanCreateDtos.Add((impItem.RowIndex, workPlanCreateDto)); |
| | | // } |
| | | // } |
| | | // } |
| | | |
| | | // // 新增 |
| | | // foreach (var workPlanDto in workPlanCreateDtos) |
| | | // { |
| | | // try |
| | | // { |
| | | // await CreateAsync(workPlanDto.Item); |
| | | // } |
| | | // catch (Exception e) |
| | | // { |
| | | // var errorMsg = $"导入失败!配置,第{workPlanDto.RowIndex}行:{e.Message},终止导入"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | // } |
| | | |
| | | // // 更新 |
| | | // foreach (var workPlanDto in workPlanUpdateDtos) |
| | | // { |
| | | // try |
| | | // { |
| | | // await UpdateAsync(workPlanDto.Id, workPlanDto.Item); |
| | | // } |
| | | // catch (Exception e) |
| | | // { |
| | | // var errorMsg = $"导入失败!配置,第{workPlanDto.RowIndex}行:{e.Message},终止导入"; |
| | | // throw new UserFriendlyException(errorMsg); |
| | | // } |
| | | // } |
| | | //} |
| | | |
| | | /// <summary> |
| | | /// 导出作业计划表 |
| | |
| | | #endregion |
| | | |
| | | |
| | | var list = await workPlanRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true); |
| | | var list = await _workPlanRepository.GetListAsync(whereConditions, input.Sorting, input.MaxResultCount, input.SkipCount, includeDetails: true); |
| | | var result = ObjectMapper.Map<List<WorkPlan>, List<WorkPlanDto>>(list); |
| | | |
| | | var sheets = new Dictionary<string, object> |
| | |
| | | { |
| | | Check.NotNull(input, nameof(input)); |
| | | Check.NotNullOrWhiteSpace(input.TaskCode, "任务编码", 256); |
| | | Check.NotNull(input.WorkPlanStatus, "计划状态"); |
| | | Check.NotNull(input.CallMaterialStatus, "叫料状态"); |
| | | Check.NotNull(input.Length, "长度(mm)"); |
| | | Check.NotNull(input.MarkingPosition, "打码位置"); |
| | | Check.NotNull(input.CuttingPosition, "切割位置"); |
| | |
| | | Check.NotNull(input.PipeWallThickness, "套管直径(mm)"); |
| | | Check.NotNull(input.OuterDiameter, "外径(mm)"); |
| | | Check.NotNull(input.Thickness, "壁厚(mm)"); |
| | | Check.NotNull(input.HasMainSignature, "是否主支管"); |
| | | |
| | | return Task.CompletedTask; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据条件获取作业计划表列表 |
| | | /// </summary> |
| | | /// <param name="whereConditions"></param> |
| | | /// <param name="cancellationToken"></param> |
| | | /// <returns></returns> |
| | | public async Task<List<WorkPlan>> GetListByFilterAsync(Expression<Func<WorkPlan, bool>> whereConditions, CancellationToken cancellationToken = default) |
| | | { |
| | | return await _workPlanRepository.GetListByFilterAsync(whereConditions); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据条件获取单个作业计划表 |
| | | /// </summary> |
| | | /// <param name="whereConditions"></param> |
| | | /// <param name="isMultipleThrowException">是否查询出多条就报错</param> |
| | | /// <param name="cancellationToken"></param> |
| | | /// <returns></returns> |
| | | /// <exception cref="UserFriendlyException"></exception> |
| | | public async Task<WorkPlan> GetSingleByFilterAsync(Expression<Func<WorkPlan, bool>> whereConditions, bool isMultipleThrowException = false, CancellationToken cancellationToken = default) |
| | | { |
| | | return await _workPlanRepository.GetSingleByFilterAsync(whereConditions, isMultipleThrowException); |
| | | } |
| | | } |