smart-man-boot/src/main/java/com/qianwen/smartman/modules/trace/service/impl/NgReasonInfoServiceImpl.java
@@ -1,18 +1,20 @@ package com.qianwen.smartman.modules.trace.service.impl; import com.baomidou.mybatisplus.core.conditions.Wrapper; import java.util.List; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import java.lang.invoke.SerializedLambda; import java.util.List; import com.qianwen.smartman.common.constant.CommonGroupConstant; import com.qianwen.smartman.common.enums.CommonGroupTypeEnum; import com.qianwen.smartman.common.utils.MessageUtils; import com.qianwen.core.log.exception.ServiceException; import com.qianwen.core.mp.base.BaseServiceImpl; import com.qianwen.core.mp.support.Condition; import com.qianwen.core.mp.support.Query; import com.qianwen.core.tool.utils.Func; import com.qianwen.smartman.common.constant.CommonGroupConstant; import com.qianwen.smartman.common.enums.CommonGroupTypeEnum; import com.qianwen.smartman.common.utils.MessageUtils; import com.qianwen.smartman.modules.cps.entity.CommonGroupOfItem; import com.qianwen.smartman.modules.cps.service.ICommonGroupOfItemService; import com.qianwen.smartman.modules.trace.convert.NgReasonInfoConvert; @@ -22,78 +24,12 @@ import com.qianwen.smartman.modules.trace.vo.NgReasonInfoSubmitVO; import com.qianwen.smartman.modules.trace.vo.NgReasonInfoUpdateVO; import com.qianwen.smartman.modules.trace.vo.NgReasonInfoVO; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @Service /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/trace/service/impl/NgReasonInfoServiceImpl.class */ public class NgReasonInfoServiceImpl extends BaseServiceImpl<NgReasonInfoMapper, NgReasonInfo> implements INgReasonInfoService { private final ICommonGroupOfItemService commonGroupOfItemService; private final NgReasonInfoMapper ngReasonInfoMapper; private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { String implMethodName = lambda.getImplMethodName(); boolean z = true; switch (implMethodName.hashCode()) { case 98245393: if (implMethodName.equals("getId")) { z = true; break; } break; case 424389191: if (implMethodName.equals("getReasonCode")) { z = true; break; } break; case 517353092: if (implMethodName.equals("getItemId")) { z = false; break; } break; } switch (z) { case false: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CommonGroupOfItem") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getItemId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CommonGroupOfItem") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getItemId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/NgReasonInfo") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getReasonCode(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/NgReasonInfo") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getReasonCode(); }; } break; } throw new IllegalArgumentException("Invalid lambda deserialization"); } public NgReasonInfoServiceImpl(final ICommonGroupOfItemService commonGroupOfItemService, final NgReasonInfoMapper ngReasonInfoMapper) { this.commonGroupOfItemService = commonGroupOfItemService; @@ -105,9 +41,10 @@ NgReasonInfo ngReasonInfo = NgReasonInfoConvert.INSTANCE.convertVO(ngReasonInfoSubmitVO); checkNgInfo(ngReasonInfo); save(ngReasonInfo); if (Func.isNotEmpty(ngReasonInfoSubmitVO.getGroupId()) && Func.isEmpty(this.commonGroupOfItemService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getItemId(); }, ngReasonInfo.getId())))) { List<CommonGroupOfItem> items = this.commonGroupOfItemService.list(Wrappers.<CommonGroupOfItem>lambdaQuery().eq(CommonGroupOfItem::getItemId, ngReasonInfo.getId())); if (Func.isNotEmpty(ngReasonInfoSubmitVO.getGroupId()) && Func.isEmpty(items)) { CommonGroupOfItem commonGroupOfItem = new CommonGroupOfItem(ngReasonInfoSubmitVO.getGroupId(), ngReasonInfo.getId(), CommonGroupTypeEnum.NG_REASON.getName(), CommonGroupConstant.DEFAULT_CATEGORY); this.commonGroupOfItemService.save(commonGroupOfItem); } @@ -125,9 +62,11 @@ @Override // org.springblade.modules.trace.service.INgReasonInfoService public Boolean delete(List<Long> ids) { this.commonGroupOfItemService.remove(Wrappers.<CommonGroupOfItem>lambdaQuery().in(CommonGroupOfItem::getItemId, ids)); /* this.commonGroupOfItemService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> { return v0.getItemId(); }, ids)); }, ids));*/ return Boolean.valueOf(removeByIds(ids)); } @@ -146,11 +85,14 @@ @Override // org.springblade.modules.trace.service.INgReasonInfoService public Boolean isReasonCodeRepeat(Long id, String code) { long count = count(Wrappers.<NgReasonInfo>lambdaQuery().ne(Func.isNotEmpty(id), NgReasonInfo::getId, id).eq(NgReasonInfo::getReasonCode, code)); /* long count = count((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(id), (v0) -> { return v0.getId(); }, id).eq((v0) -> { return v0.getReasonCode(); }, code)); }, code));*/ return Boolean.valueOf(count > 0); } @@ -163,11 +105,14 @@ if (Func.isNotEmpty(ngReasonInfo.getReasonCode()) && ngReasonInfo.getReasonCode().length() > 24) { throw new ServiceException(MessageUtils.message("cps.ng.reasoncode.length.too.long", new Object[0])); } Long count = Long.valueOf(count(Wrappers.<NgReasonInfo>lambdaQuery().ne(Func.isNotEmpty(ngReasonInfo.getId()), NgReasonInfo::getId, ngReasonInfo.getId()) .eq(NgReasonInfo::getReasonCode, ngReasonInfo.getReasonCode()))); /* Long count = Long.valueOf(count((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(ngReasonInfo.getId()), (v0) -> { return v0.getId(); }, ngReasonInfo.getId()).eq((v0) -> { return v0.getReasonCode(); }, ngReasonInfo.getReasonCode()))); }, ngReasonInfo.getReasonCode())));*/ if (count.longValue() > 0) { throw new ServiceException(MessageUtils.message("cps.ng.reasoncode.already.exists", new Object[0])); } smart-man-boot/src/main/java/com/qianwen/smartman/modules/trace/service/impl/TraceFlowRecordServiceImpl.java
@@ -1,13 +1,5 @@ package com.qianwen.smartman.modules.trace.service.impl; import cn.hutool.core.date.DateTime; import com.alibaba.excel.write.merge.AbstractMergeStrategy; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import java.lang.invoke.SerializedLambda; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; @@ -21,11 +13,14 @@ import java.util.concurrent.atomic.AtomicReference; import java.util.function.Function; import java.util.stream.Collectors; import com.qianwen.smartman.common.constant.CommonConstant; import com.qianwen.smartman.common.constant.DateConstant; import com.qianwen.smartman.common.constant.ExcelConstant; import com.qianwen.smartman.common.constant.TraceConstant; import com.qianwen.smartman.common.utils.MessageUtils; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import com.alibaba.excel.write.merge.AbstractMergeStrategy; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.qianwen.core.excel.util.ExcelUtil; import com.qianwen.core.log.exception.ServiceException; import com.qianwen.core.mp.base.BaseServiceImpl; @@ -34,6 +29,11 @@ import com.qianwen.core.oss.model.BladeFile; import com.qianwen.core.tool.utils.DateUtil; import com.qianwen.core.tool.utils.Func; import com.qianwen.smartman.common.constant.CommonConstant; import com.qianwen.smartman.common.constant.DateConstant; import com.qianwen.smartman.common.constant.ExcelConstant; import com.qianwen.smartman.common.constant.TraceConstant; import com.qianwen.smartman.common.utils.MessageUtils; import com.qianwen.smartman.modules.cps.enums.WorkTypeEnum; import com.qianwen.smartman.modules.cps.vo.ConfigVO; import com.qianwen.smartman.modules.mdc.enums.ProcessParamEnum; @@ -64,8 +64,8 @@ import com.qianwen.smartman.modules.trace.vo.TraceFlowRecordVO; import com.qianwen.smartman.modules.trace.vo.WorkpieceTraceSearchVO; import com.qianwen.smartman.modules.trace.vo.WorkpieceTraceVO; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import cn.hutool.core.date.DateTime; @Service /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/trace/service/impl/TraceFlowRecordServiceImpl.class */ @@ -76,70 +76,6 @@ private final TraceCatalogMapper traceCatalogMapper; private final OssBuilder ossBuilder; private final ConfigVO configVO; private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { String implMethodName = lambda.getImplMethodName(); boolean z = true; switch (implMethodName.hashCode()) { case -557259320: if (implMethodName.equals("getWorkstationId")) { z = false; break; } break; case -75622813: if (implMethodName.equals("getCode")) { z = true; break; } break; case 700604426: if (implMethodName.equals("getPartNo")) { z = true; break; } break; } switch (z) { case false: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowRecord") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getWorkstationId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowRecord") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getPartNo(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceCatalog") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getPartNo(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceCatalog") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getPartNo(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowSettings") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getCode(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowSettings") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getCode(); }; } break; } throw new IllegalArgumentException("Invalid lambda deserialization"); } public TraceFlowRecordServiceImpl(final ITraceFlowSettingsService flowSettingsService, final IProcessParameterService processParameterService, final ITraceCatalogService traceCatalogService, final TraceCatalogMapper traceCatalogMapper, final OssBuilder ossBuilder, final ConfigVO configVO) { this.flowSettingsService = flowSettingsService; @@ -152,14 +88,17 @@ @Override // org.springblade.modules.trace.service.ITraceFlowRecordService public List<TraceFlowRecordVO> getTraceFlowRecord(String partNo, String workstationId) { Map<String, TraceFlowSettings> settingsMap = (Map) this.flowSettingsService.list().stream().collect(Collectors.toMap((v0) -> { Map<String, TraceFlowSettings> settingsMap = this.flowSettingsService.list().stream().collect(Collectors.toMap((v0) -> { return v0.getCode(); }, Function.identity())); List<TraceFlowRecord> list = list(Wrappers.<TraceFlowRecord>lambdaQuery().eq(TraceFlowRecord::getPartNo, partNo) .eq(Func.isNotBlank(workstationId), TraceFlowRecord::getWorkstationId, workstationId)); /* List<TraceFlowRecord> list = list(((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getPartNo(); }, partNo)).eq(Func.isNotBlank(workstationId), (v0) -> { return v0.getWorkstationId(); }, workstationId)); }, workstationId));*/ if (Func.isNotEmpty(list)) { List<TraceFlowRecordVO> convert = TraceFlowRecordConvert.INSTANCE.convert(list); convert.forEach(s -> { @@ -173,7 +112,7 @@ } } }); return (List) convert.stream().sorted(Comparator.comparing((v0) -> { return convert.stream().sorted(Comparator.comparing((v0) -> { return v0.getEntryTime(); })).collect(Collectors.toList()); } @@ -183,9 +122,12 @@ @Override // org.springblade.modules.trace.service.ITraceFlowRecordService public TraceCatalogAndFlowRecordVO getTraceCatalogAndFlowRecord(String partNo, String workstationId) { TraceCatalogAndFlowRecordVO traceCatalogAndFlowRecordVO = null; TraceCatalog one = this.traceCatalogService.getOne(Wrappers.<TraceCatalog>lambdaQuery().eq(TraceCatalog::getPartNo, partNo)); /* TraceCatalog one = (TraceCatalog) this.traceCatalogService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getPartNo(); }, partNo)); }, partNo));*/ if (one != null) { traceCatalogAndFlowRecordVO = new TraceCatalogAndFlowRecordVO(); traceCatalogAndFlowRecordVO.setPartNo(partNo).setIsReworkPart(one.getIsReworkPart()).setQualified(one.getQualified()).setBatchNumber(one.getBatchNumber()).setOnlineTime(one.getOnlineTime()).setOfflineTime(one.getOfflineTime()).setShiftIndex(one.getShiftIndex()).setShiftIndexName(one.getShiftIndexName()).setFlowRecordVOS(getTraceFlowRecord(partNo, null)); @@ -197,13 +139,16 @@ public OtherWorkstationVO getOtherProcessParameter(String partNo, String id) { TraceFlowSettings traceFlowSettings; OtherWorkstationVO otherWorkstationVO = null; TraceCatalog traceCatalog = this.traceCatalogService.getOne(Wrappers.<TraceCatalog>lambdaQuery().eq(TraceCatalog::getPartNo, partNo)); /* TraceCatalog traceCatalog = (TraceCatalog) this.traceCatalogService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getPartNo(); }, partNo)); }, partNo));*/ TraceFlowRecord traceFlowRecord = (TraceFlowRecord) getById(id); if (traceCatalog != null && traceFlowRecord != null && (traceFlowSettings = (TraceFlowSettings) this.flowSettingsService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getCode(); }, traceFlowRecord.getFlowCode()))) != null) { traceFlowSettings = this.flowSettingsService.getOne(Wrappers.<TraceFlowSettings>lambdaQuery().eq(TraceFlowSettings::getCode, traceFlowRecord.getFlowCode())); if (traceCatalog != null && traceFlowRecord != null && traceFlowSettings != null) { otherWorkstationVO = new OtherWorkstationVO(); otherWorkstationVO.setFlowTag(traceFlowRecord.getFlowTag()).setEntryTime(traceFlowRecord.getEntryTime()).setLeftTime(traceFlowRecord.getLeftTime()).setBatchNumber(traceCatalog.getBatchNumber()).setStationType(traceFlowSettings.getStationType()); } @@ -214,9 +159,12 @@ public ProParamSheetVO getProcessParameter(String id, Integer shiftIndex) { TraceFlowRecord traceFlowRecord = (TraceFlowRecord) getById(id); if (traceFlowRecord != null) { TraceFlowSettings traceFlowSettings = this.flowSettingsService.getOne(Wrappers.<TraceFlowSettings>lambdaQuery() .eq(TraceFlowSettings::getCode, traceFlowRecord.getFlowCode())); /* TraceFlowSettings traceFlowSettings = (TraceFlowSettings) this.flowSettingsService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getCode(); }, traceFlowRecord.getFlowCode())); }, traceFlowRecord.getFlowCode()));*/ if (traceFlowSettings != null) { ProcessParameterSearchVO processParameterSearchVO = new ProcessParameterSearchVO(); processParameterSearchVO.setMethodEnum(ProcessParamEnum.HOUR); @@ -243,13 +191,18 @@ } List<TraceCatalogFlowRecordExportVO> exportData = ((TraceFlowRecordMapper) this.baseMapper).getExportData(traceCatalogSearchVO); if (Func.isNotEmpty(exportData)) { List<TraceCatalogFlowRecordExportVO> exportData2 = exportData.stream() .sorted(Comparator.comparing(TraceCatalogFlowRecordExportVO::getOnlineTime, Comparator.reverseOrder()) .thenComparing(TraceCatalogFlowRecordExportVO::getFlowSeq, Comparator.nullsLast(Long::compareTo))) .collect(Collectors.toList()); /* List<TraceCatalogFlowRecordExportVO> exportData2 = (List) exportData.stream().sorted(Comparator.comparing((v0) -> { return v0.getOnlineTime(); }, Comparator.reverseOrder()).thenComparing((v0) -> { return v0.getFlowSeq(); }, Comparator.nullsLast((v0, v1) -> { return v0.compareTo(v1); }))).collect(Collectors.toList()); }))).collect(Collectors.toList());*/ exportData2.forEach(s -> { s.setQualifiedDesc(TraceQualifiedEnum.findDescByValue(s.getQualified())); s.setIsReworkPartDesc(TraceIsReworkEnum.findDescByValue(s.getIsReworkPart())); @@ -258,14 +211,14 @@ }); return exportData2; } return new ArrayList(); return new ArrayList<>(); } @Override // org.springblade.modules.trace.service.ITraceFlowRecordService public IPage<WorkpieceTraceVO> workpieceTracePage(WorkpieceTraceSearchVO vo, Query query) { IPage<WorkpieceTraceVO> relatedTracePages = ((TraceFlowRecordMapper) this.baseMapper).getNgTraceFlowRecord(Condition.getPage(query), vo); if (Func.isNotEmpty(relatedTracePages.getRecords())) { List<Long> relatedRecordIds = (List) relatedTracePages.getRecords().stream().map((v0) -> { List<Long> relatedRecordIds = relatedTracePages.getRecords().stream().map((v0) -> { return v0.getRecordId(); }).collect(Collectors.toList()); relatedTracePages.setRecords(((TraceFlowRecordMapper) this.baseMapper).getNgFullTraceFlowRecord(relatedRecordIds)); @@ -283,23 +236,28 @@ Object endTime = getEndTime(vo.getEndTime()); List<WorkpieceTraceDTO> dto = ((TraceFlowRecordMapper) this.baseMapper).exportNgTraceRecord(vo); List<WorkpieceTraceDTO> resultList = new ArrayList<>(1000); ((Map) dto.parallelStream().collect(Collectors.groupingBy(a -> { (dto.parallelStream().collect(Collectors.groupingBy(a -> { return a.getPartNo() + "_" + a.getWorkstationCode() + "_" + a.getWorkbenchName(); }, Collectors.toList()))).forEach(key, transfer -> { Optional reduce = transfer.stream().reduce(a2, b -> { }, Collectors.toList()))).forEach((key, transfer) -> { Optional<WorkpieceTraceDTO> reduce = transfer.stream().reduce((a2, b) -> { return new WorkpieceTraceDTO(a2.getBatchNumber(), a2.getPartNo(), a2.getOnlineTime(), a2.getOfflineTime(), a2.getWorkstationCode(), a2.getWorkstationName(), a2.getWorkbenchName(), a2.getShiftIndexName(), a2.getTraceStatus(), a2.getReasonCode() + "," + b.getReasonCode()); }); resultList.getClass(); //resultList.getClass(); reduce.ifPresent((v1) -> { r1.add(v1); resultList.add(v1); //r1.add(v1); }); }); }//end of foreach ); AtomicReference<Integer> sort = new AtomicReference<>(1); List<WorkpieceTraceExport> collect = resultList.stream().map(c -> convert(c, sort)).sorted(Comparator.comparing(WorkpieceTraceExport::getOnlineTime).reversed()).collect(Collectors.toList()); /* List<WorkpieceTraceExport> collect = (List) resultList.stream().map(c -> { return convert(c, sort); }).sorted(Comparator.comparing((v0) -> { return v0.getOnlineTime(); }).reversed()).collect(Collectors.toList()); */ Map<String, Object> timeMap = new HashMap<>(2); timeMap.put("startTime", startTime); timeMap.put("endTime", endTime); @@ -317,13 +275,22 @@ private Wrapper<WorkpieceTraceSearchVO> getWrapper(WorkpieceTraceSearchVO vo, String startTime, String endTime) { boolean isOracle = CommonConstant.ORACLE.equals(this.configVO.getType()); return Wrappers.<WorkpieceTraceSearchVO>query().in(Func.isNotEmpty(vo.getGroupIds()), "btc.workstation_group_id", vo.getGroupIds()).eq(Func.isNotEmpty(vo.getWorkstationId()), "btfr.workstation_id", vo.getWorkstationId()).nested(i -> { i.ge("btc.online_time", isOracle ? DateUtil.parse(startTime, DateConstant.PATTERN_DATE_TIME) : startTime).le("btc.online_time", isOracle ? DateUtil.parse(endTime, DateConstant.PATTERN_DATE_TIME) : endTime); }).nested(i2 -> { i2.ge("btc.offline_time", isOracle ? DateUtil.parse(startTime, DateConstant.PATTERN_DATE_TIME) : startTime).le("btc.offline_time", isOracle ? DateUtil.parse(endTime, DateConstant.PATTERN_DATE_TIME) : endTime); }).and(Func.isNotEmpty(vo.getKeyword()), i3 -> { i3.likeRight("btfr.part_no", vo.getKeyword()).or().likeRight("btc.batch_number", vo.getKeyword()).or().likeRight("btfr.workstation_code", vo.getKeyword()).or().likeRight("btfr.workstation_name", vo.getKeyword()).or().likeRight("btfr.workbench_name", vo.getKeyword()); }); /* return ((QueryWrapper) ((QueryWrapper) Wrappers.query().in(Func.isNotEmpty(vo.getGroupIds()), "btc.workstation_group_id", vo.getGroupIds()).eq(Func.isNotEmpty(vo.getWorkstationId()), "btfr.workstation_id", vo.getWorkstationId()).nested(i -> { QueryWrapper queryWrapper = (QueryWrapper) ((QueryWrapper) i.ge("btc.online_time", isOracle ? DateUtil.parse(startTime, DateConstant.PATTERN_DATE_TIME) : startTime)).le("btc.online_time", isOracle ? DateUtil.parse(endTime, DateConstant.PATTERN_DATE_TIME) : endTime); })).nested(i2 -> { QueryWrapper queryWrapper = (QueryWrapper) ((QueryWrapper) i2.ge("btc.offline_time", isOracle ? DateUtil.parse(startTime, DateConstant.PATTERN_DATE_TIME) : startTime)).le("btc.offline_time", isOracle ? DateUtil.parse(endTime, DateConstant.PATTERN_DATE_TIME) : endTime); })).and(Func.isNotEmpty(vo.getKeyword()), i3 -> { QueryWrapper queryWrapper = (QueryWrapper) ((QueryWrapper) ((QueryWrapper) ((QueryWrapper) ((QueryWrapper) ((QueryWrapper) ((QueryWrapper) ((QueryWrapper) ((QueryWrapper) i3.likeRight("btfr.part_no", vo.getKeyword())).or()).likeRight("btc.batch_number", vo.getKeyword())).or()).likeRight("btfr.workstation_code", vo.getKeyword())).or()).likeRight("btfr.workstation_name", vo.getKeyword())).or()).likeRight("btfr.workbench_name", vo.getKeyword()); }); });*/ } private String getStartTime(Date startTime) { smart-man-boot/src/main/java/com/qianwen/smartman/modules/trace/service/impl/TraceFlowSettingsServiceImpl.java
@@ -1,20 +1,21 @@ package com.qianwen.smartman.modules.trace.service.impl; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import java.lang.invoke.SerializedLambda; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import com.qianwen.smartman.common.utils.MessageUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.qianwen.core.log.exception.ServiceException; import com.qianwen.core.mp.base.BaseServiceImpl; import com.qianwen.core.mp.support.Condition; import com.qianwen.core.mp.support.Query; import com.qianwen.core.tool.utils.Func; import com.qianwen.smartman.common.utils.MessageUtils; import com.qianwen.smartman.modules.trace.convert.TraceFlowSettingsConvert; import com.qianwen.smartman.modules.trace.convert.TraceRelatedWorkstationConvert; import com.qianwen.smartman.modules.trace.entity.TraceFlowSettings; @@ -28,8 +29,6 @@ import com.qianwen.smartman.modules.trace.vo.TraceFlowSettingsVO; import com.qianwen.smartman.modules.trace.vo.TraceFlowSettingsWorkstationVO; import com.qianwen.smartman.modules.trace.vo.TraceRelatedWorkstationVO; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @Service /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/trace/service/impl/TraceFlowSettingsServiceImpl.class */ @@ -38,105 +37,6 @@ private final TraceRelatedWorkstationMapper traceRelatedWorkstationMapper; private final Long CURRENT_FLOW = 1L; private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { String implMethodName = lambda.getImplMethodName(); boolean z = true; switch (implMethodName.hashCode()) { case -910828604: if (implMethodName.equals("getQualityMakerFlowId")) { z = false; break; } break; case -871043410: if (implMethodName.equals("getTraceFlowSettingId")) { z = true; break; } break; case -307107987: if (implMethodName.equals("getWorkstationGroupId")) { z = true; break; } break; case -75622813: if (implMethodName.equals("getCode")) { z = true; break; } break; case 98245393: if (implMethodName.equals("getId")) { z = true; break; } break; } switch (z) { case false: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowSettings") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getQualityMakerFlowId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceRelatedWorkstation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getTraceFlowSettingId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceRelatedWorkstation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getTraceFlowSettingId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowSettings") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getWorkstationGroupId(); }; } if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowSettings") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getWorkstationGroupId(); }; } break; case true: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceFlowSettings") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { return (v0) -> { return v0.getCode(); }; } break; } throw new IllegalArgumentException("Invalid lambda deserialization"); } public TraceFlowSettingsServiceImpl(final ITraceRelatedWorkstationService traceRelatedWorkstationService, final TraceRelatedWorkstationMapper traceRelatedWorkstationMapper) { this.traceRelatedWorkstationService = traceRelatedWorkstationService; @@ -150,6 +50,10 @@ TraceFlowSettingsVO traceFlowSettingsVO = traceFlowSettingsWorkstationVO.getTraceFlowSettingsVO(); TraceFlowSettings traceFlowSettings = TraceFlowSettingsConvert.INSTANCE.convert(traceFlowSettingsVO); if (Func.isEmpty(traceFlowSettingsVO.getId())) { Integer maxSeq = list(Wrappers.<TraceFlowSettings>lambdaQuery() .ne(Func.isNotEmpty(traceFlowSettingsVO.getId()), TraceFlowSettings::getId, traceFlowSettingsVO.getId()) .eq(TraceFlowSettings::getWorkstationGroupId, traceFlowSettingsVO.getWorkstationGroupId())).stream().map(TraceFlowSettings::getFlowSeq).max(Integer::compare).orElse(-1); /* Integer maxSeq = (Integer) list((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(traceFlowSettingsVO.getId()), (v0) -> { return v0.getId(); }, traceFlowSettingsVO.getId()).eq((v0) -> { @@ -158,7 +62,7 @@ return v0.getFlowSeq(); }).max((v0, v1) -> { return Integer.compare(v0, v1); }).orElse(-1); }).orElse(-1);*/ traceFlowSettings.setFlowSeq(Integer.valueOf(maxSeq.intValue() + 1)); } checkSetting(traceFlowSettingsVO); @@ -169,9 +73,11 @@ } TraceFlowSettingsVO traceFlowSettingsVOReturn = TraceFlowSettingsConvert.INSTANCE.convert(traceFlowSettings); List<TraceRelatedWorkstationVO> traceRelatedWorkstationVOS = traceFlowSettingsWorkstationVO.getTraceRelatedWorkstationVOList(); this.traceRelatedWorkstationService.remove(Wrappers.<TraceRelatedWorkstation>lambdaQuery().eq(TraceRelatedWorkstation::getTraceFlowSettingId, traceFlowSettingsVOReturn.getId())); /* this.traceRelatedWorkstationService.remove((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getTraceFlowSettingId(); }, traceFlowSettingsVOReturn.getId())); }, traceFlowSettingsVOReturn.getId()));*/ if (Func.isNotEmpty(traceRelatedWorkstationVOS)) { List<TraceRelatedWorkstation> traceRelatedWorkstations = TraceRelatedWorkstationConvert.INSTANCE.convertVo(traceRelatedWorkstationVOS); checkRelatedWorkstation(traceRelatedWorkstations); @@ -204,7 +110,7 @@ @Override // org.springblade.modules.trace.service.ITraceFlowSettingsService public Boolean changeSort(List<TraceFlowSettingsVO> traceFlowSettingsVOList) { List<TraceFlowSettings> collect = (List) traceFlowSettingsVOList.stream().map(t -> { List<TraceFlowSettings> collect = traceFlowSettingsVOList.stream().map(t -> { TraceFlowSettings traceFlowSettings = (TraceFlowSettings) getById(t.getId()); traceFlowSettings.setFlowSeq(t.getFlowSeq()); return traceFlowSettings; @@ -217,35 +123,49 @@ public boolean remove(List<String> ids) { List<Long> idList = Func.toLongList(ids); idList.forEach(id -> { long count = count(Wrappers.<TraceFlowSettings>lambdaQuery().eq(TraceFlowSettings::getQualityMakerFlowId, id).ne(TraceFlowSettings::getId, id)); /* long count = count((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getQualityMakerFlowId(); }, id)).ne((v0) -> { return v0.getId(); }, id)); }, id));*/ if (count > 0) { throw new ServiceException(MessageUtils.message("cps.traceFlowSettings.ids.have.been.bound", new Object[0])); } }); removeByIds(idList); this.traceRelatedWorkstationService.remove(Wrappers.<TraceRelatedWorkstation>lambdaQuery().in(TraceRelatedWorkstation::getTraceFlowSettingId, idList)); /* this.traceRelatedWorkstationService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> { return v0.getTraceFlowSettingId(); }, idList)); }, idList));*/ return true; } public void checkSetting(TraceFlowSettingsVO traceFlowSettingsVO) { Long id = traceFlowSettingsVO.getId(); long count = count(Wrappers.<TraceFlowSettings>lambdaQuery() .ne(Func.isNotEmpty(id), TraceFlowSettings::getId, id) .eq(TraceFlowSettings::getCode, traceFlowSettingsVO.getCode())); /* long count = count((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(id), (v0) -> { return v0.getId(); }, id).eq((v0) -> { return v0.getCode(); }, traceFlowSettingsVO.getCode())); }, traceFlowSettingsVO.getCode()));*/ if (count > 0) { throw new ServiceException(MessageUtils.message("cps.traceFlowSettings.code.already.exists", new Object[0])); } if (FlowTypeEnum.ONLINE_STATION.getCode().equals(traceFlowSettingsVO.getFlowType()) && !TriggerEndFlowStyleEnum.SELF_FLOW.getCode().equals(traceFlowSettingsVO.getTriggerEndFlowStyle())) { throw new ServiceException(MessageUtils.message("cps.trace.flow.settings.only.this.flow", new Object[0])); } List<Integer> flowSeqs = list(Wrappers.<TraceFlowSettings>lambdaQuery() .ne(Func.isNotEmpty(traceFlowSettingsVO.getId()), TraceFlowSettings::getId, traceFlowSettingsVO.getId()) .eq(TraceFlowSettings::getWorkstationGroupId, traceFlowSettingsVO.getWorkstationGroupId())) .stream().map(TraceFlowSettings::getFlowSeq).filter(Func::isNotEmpty).collect(Collectors.toList()); /* List<Integer> flowSeqs = (List) list((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(traceFlowSettingsVO.getId()), (v0) -> { return v0.getId(); }, traceFlowSettingsVO.getId()).eq((v0) -> { @@ -254,17 +174,17 @@ return v0.getFlowSeq(); }).filter((v0) -> { return Func.isNotEmpty(v0); }).collect(Collectors.toList()); }).collect(Collectors.toList());*/ if (flowSeqs.contains(traceFlowSettingsVO.getFlowSeq())) { throw new ServiceException(MessageUtils.message("cps.traceFlowSettings.flowSeq.already.exists", new Object[0])); } } public void checkRelatedWorkstation(List<TraceRelatedWorkstation> traceRelatedWorkstations) { Map<String, List<TraceRelatedWorkstation>> collect = (Map) traceRelatedWorkstations.stream().collect(Collectors.groupingBy(t -> { Map<String, List<TraceRelatedWorkstation>> collect = traceRelatedWorkstations.stream().collect(Collectors.groupingBy(t -> { return (t.getWorkstationId().longValue() + t.getWorkbenchId().longValue()) + t.getMachiningPosition(); })); collect.forEach(key, list -> { collect.forEach((key, list) -> { if (list.size() > 1) { throw new ServiceException(MessageUtils.message("cps.relatedWorkstation.already.exists", new Object[0])); } smart-man-boot/src/main/java/com/qianwen/smartman/modules/trace/service/impl/TraceRecordNgReasonServiceImpl.java
@@ -1,9 +1,9 @@ package com.qianwen.smartman.modules.trace.service.impl; import com.baomidou.mybatisplus.core.conditions.Wrapper; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import java.lang.invoke.SerializedLambda; import com.qianwen.core.mp.service.impl.BladeServiceImpl; import com.qianwen.core.mp.support.Condition; import com.qianwen.core.mp.support.Query; @@ -14,34 +14,11 @@ import com.qianwen.smartman.modules.trace.service.ITraceRecordNgReasonService; import com.qianwen.smartman.modules.trace.vo.TraceRecordNgReasonAddVO; import com.qianwen.smartman.modules.trace.vo.TraceRecordNgReasonVO; import org.springframework.stereotype.Service; @Service /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/trace/service/impl/TraceRecordNgReasonServiceImpl.class */ public class TraceRecordNgReasonServiceImpl extends BladeServiceImpl<TraceRecordNgReasonMapper, TraceRecordNgReason> implements ITraceRecordNgReasonService { private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { String implMethodName = lambda.getImplMethodName(); boolean z = true; switch (implMethodName.hashCode()) { case 1278665410: if (implMethodName.equals("getRecordId")) { z = false; break; } break; } switch (z) { case false: if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/trace/entity/TraceRecordNgReason") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { return (v0) -> { return v0.getRecordId(); }; } break; } throw new IllegalArgumentException("Invalid lambda deserialization"); } @Override // org.springblade.modules.trace.service.ITraceRecordNgReasonService public TraceRecordNgReasonVO insertReason(TraceRecordNgReasonAddVO vo) { TraceRecordNgReason reason = TraceRecordNgReasonConvert.INSTANCE.convert(vo); @@ -52,9 +29,11 @@ @Override // org.springblade.modules.trace.service.ITraceRecordNgReasonService public IPage<TraceRecordNgReasonVO> pageReason(Long recordId, Query query) { IPage<TraceRecordNgReason> page = page(Condition.getPage(query), Wrappers.<TraceRecordNgReason>lambdaQuery().eq(TraceRecordNgReason::getRecordId, recordId)); /* IPage<TraceRecordNgReason> page = page(Condition.getPage(query), (Wrapper) Wrappers.lambdaQuery().eq((v0) -> { return v0.getRecordId(); }, recordId)); }, recordId));*/ return TraceRecordNgReasonConvert.INSTANCE.convert(page); } }