From c9b04383c77f91ac309e37e70783edcf8a9298b5 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 18 五月 2024 23:24:12 +0800
Subject: [PATCH] websocket代码整理
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/ProcessAssociationServiceImpl.java | 126 ++++++++---------------------------------
1 files changed, 25 insertions(+), 101 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/ProcessAssociationServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/ProcessAssociationServiceImpl.java
index 5d8496d..657ff8a 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/ProcessAssociationServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/ProcessAssociationServiceImpl.java
@@ -30,85 +30,11 @@
import org.springframework.stereotype.Service;
@Service
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/ProcessAssociationServiceImpl.class */
public class ProcessAssociationServiceImpl extends ServiceImpl<ProcessAssociationMapper, ProcessAssociation> implements IProcessAssociationService {
private final IWorkstationService workstationService;
private final ISupplierService supplierService;
private final IWarehouseAreaService warehouseAreaService;
- private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
- String implMethodName = lambda.getImplMethodName();
- boolean z = true;
- switch (implMethodName.hashCode()) {
- case -1104365260:
- if (implMethodName.equals("getProcessId")) {
- z = false;
- break;
- }
- break;
- case 98245393:
- if (implMethodName.equals("getId")) {
- z = true;
- break;
- }
- break;
- case 1949578200:
- if (implMethodName.equals("getBizId")) {
- 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/cps/entity/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getProcessId();
- };
- }
- 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getProcessId();
- };
- }
- 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getProcessId();
- };
- }
- 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();
- };
- }
- 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/cps/entity/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getBizId();
- };
- }
- 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getBizId();
- };
- }
- break;
- }
- throw new IllegalArgumentException("Invalid lambda deserialization");
- }
public ProcessAssociationServiceImpl(final IWorkstationService workstationService, final ISupplierService supplierService, final IWarehouseAreaService warehouseAreaService) {
this.workstationService = workstationService;
@@ -116,27 +42,29 @@
this.warehouseAreaService = warehouseAreaService;
}
- @Override // org.springblade.modules.cps.service.IProcessAssociationService
+
public ProcessAssociationVO listAssociation(Long processId) {
ProcessAssociationVO processAssociationVO = new ProcessAssociationVO();
+ List<ProcessAssociation> processAssociationList = list(Wrappers.<ProcessAssociation>query()
+ .lambda()
+ .eq(ProcessAssociation::getProcessId, processId));
+ /*
List<ProcessAssociation> processAssociationList = list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
return v0.getProcessId();
- }, processId));
+ }, processId));*/
if (Func.isNotEmpty(processAssociationList)) {
- Map<Integer, List<ProcessAssociation>> map = (Map) processAssociationList.stream().filter(type -> {
+ Map<Integer, List<ProcessAssociation>> map = processAssociationList.stream().filter(type -> {
return type.getType() != null;
}).collect(Collectors.groupingBy((v0) -> {
return v0.getType();
}));
- map.forEach(type2, value -> {
+ map.forEach((type2, value) -> {
switch (type2.intValue()) {
case 1:
- List<Long> list = (List) value.stream().map((v0) -> {
+ List<Long> list = value.stream().map((v0) -> {
return v0.getBizId();
}).collect(Collectors.toList());
- List<Workstation> workstationList = this.workstationService.list((Wrapper) Wrappers.query().lambda().in((v0) -> {
- return v0.getId();
- }, list));
+ List<Workstation> workstationList = this.workstationService.list(Wrappers.<Workstation>query().lambda().in(Workstation::getId, list));
List<ProcessWorkstationTypeVO> processWorkstationTypeVOList = new ArrayList<>();
workstationList.forEach(record -> {
ProcessWorkstationTypeVO processWorkstationTypeVO = ProcessWorkstationTypeVO.builder().id(record.getId()).workstationCode(record.getCode()).workstationName(record.getName()).build();
@@ -145,12 +73,8 @@
processAssociationVO.setWorkstationList(processWorkstationTypeVOList);
return;
case 2:
- List<Long> list2 = (List) value.stream().map((v0) -> {
- return v0.getBizId();
- }).collect(Collectors.toList());
- List<WarehouseArea> warehouseAreaList = this.warehouseAreaService.list((Wrapper) Wrappers.query().lambda().in((v0) -> {
- return v0.getId();
- }, list2));
+ List<Long> list2 = value.stream().map(ProcessAssociation::getBizId).collect(Collectors.toList());
+ List<WarehouseArea> warehouseAreaList = this.warehouseAreaService.list(Wrappers.<WarehouseArea>query().lambda().in(WarehouseArea::getId, list2));
List<ProcessWarehouseAreaTypeVO> areaTypeVOList = new ArrayList<>();
warehouseAreaList.forEach(record2 -> {
ProcessWarehouseAreaTypeVO processWarehouseAreaTypeVO = ProcessWarehouseAreaTypeVO.builder().id(record2.getId()).warehouseAreaCode(record2.getCode()).warehouseAreaName(record2.getName()).build();
@@ -159,12 +83,8 @@
processAssociationVO.setWarehouseAreaList(areaTypeVOList);
return;
case 3:
- List<Long> list3 = (List) value.stream().map((v0) -> {
- return v0.getBizId();
- }).collect(Collectors.toList());
- List<Supplier> supplierList = this.supplierService.list((Wrapper) Wrappers.query().lambda().in((v0) -> {
- return v0.getId();
- }, list3));
+ List<Long> list3 = value.stream().map(ProcessAssociation::getBizId).collect(Collectors.toList());
+ List<Supplier> supplierList = this.supplierService.list(Wrappers.<Supplier>query().lambda().in(Supplier::getId, list3));
List<ProcessSupplierTypeVO> processSupplierTypeVOList = new ArrayList<>();
supplierList.forEach(record3 -> {
ProcessSupplierTypeVO processSupplierTypeVO = ProcessSupplierTypeVO.builder().id(record3.getId()).supplierCode(record3.getCode()).supplierName(record3.getName()).build();
@@ -180,7 +100,7 @@
return processAssociationVO;
}
- @Override // org.springblade.modules.cps.service.IProcessAssociationService
+
public ProcessAssociationDetailVO insert(ProcessAssociationSaveVO processAssociationSaveVO) {
checkProcessAssociation(processAssociationSaveVO);
ProcessAssociation processAssociation = ProcessAssociationConvert.INSTANCE.convert(processAssociationSaveVO);
@@ -188,21 +108,25 @@
return ProcessAssociationConvert.INSTANCE.convert(processAssociation);
}
- @Override // org.springblade.modules.cps.service.IProcessAssociationService
+
public Boolean delete(Long bizId, Long processId) {
+ return Boolean.valueOf(remove(Wrappers.<ProcessAssociation>query().lambda()
+ .eq(Func.isNotEmpty(bizId), ProcessAssociation::getBizId, bizId)
+ .eq(Func.isNotEmpty(processId), ProcessAssociation::getProcessId, processId)));
+
+ /*
return Boolean.valueOf(remove(Wrappers.query().lambda().eq(Func.isNotEmpty(bizId), (v0) -> {
return v0.getBizId();
}, bizId).eq(Func.isNotEmpty(processId), (v0) -> {
return v0.getProcessId();
}, processId)));
+ */
}
private void checkProcessAssociation(ProcessAssociationSaveVO processAssociationSaveVO) {
- Long count = Long.valueOf(count(Wrappers.query().lambda().eq(Func.isNotEmpty(processAssociationSaveVO.getProcessId()), (v0) -> {
- return v0.getProcessId();
- }, processAssociationSaveVO.getProcessId()).eq(Func.isNotEmpty(processAssociationSaveVO.getBizId()), (v0) -> {
- return v0.getBizId();
- }, processAssociationSaveVO.getBizId())));
+ Long count = Long.valueOf(count(Wrappers.<ProcessAssociation>query().lambda()
+ .eq(Func.isNotEmpty(processAssociationSaveVO.getProcessId()), ProcessAssociation::getProcessId, processAssociationSaveVO.getProcessId())
+ .eq(Func.isNotEmpty(processAssociationSaveVO.getBizId()), ProcessAssociation::getBizId, processAssociationSaveVO.getBizId())));
if (count.longValue() > 0) {
throw new ServiceException(MessageUtils.message("cps.process.association.type.already.exists", new Object[0]));
}
--
Gitblit v1.9.3