From 7d18c733d4c4109f2bc8e5b176cfde74c490a207 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 29 三月 2024 10:30:48 +0800
Subject: [PATCH] cps ok
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsServiceImpl.java | 354 +++++++---------------------
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsUsageServiceImpl.java | 112 ++-------
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/wrapper/EmployeeWrapper.java | 15 +
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWorkbenchServiceImpl.java | 201 ++++------------
4 files changed, 184 insertions(+), 498 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsServiceImpl.java
index 42b4bb0..1b5480d 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsServiceImpl.java
@@ -30,6 +30,7 @@
import com.qianwen.smartman.modules.cps.entity.DmpVariables;
import com.qianwen.smartman.modules.cps.entity.WorkstationOfMachine;
import com.qianwen.smartman.modules.cps.entity.WorkstationWcs;
+import com.qianwen.smartman.modules.cps.entity.WorkstationWcsUsage;
import com.qianwen.smartman.modules.cps.mapper.WorkstationWcsMapper;
import com.qianwen.smartman.modules.cps.service.IDmpVariablesService;
import com.qianwen.smartman.modules.cps.service.IWorkstationOfMachineService;
@@ -48,7 +49,6 @@
import org.springframework.transaction.annotation.Transactional;
@Service
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/WorkstationWcsServiceImpl.class */
public class WorkstationWcsServiceImpl extends BaseServiceImpl<WorkstationWcsMapper, WorkstationWcs> implements IWorkstationWcsService {
@Autowired
private IWorkstationOfMachineService workstationOfMachineService;
@@ -65,223 +65,19 @@
private IWorkstationWcsUsageService workstationWcsUsageService;
private static final String SUFFIX = "_____0";
- private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
- String implMethodName = lambda.getImplMethodName();
- boolean z = true;
- switch (implMethodName.hashCode()) {
- case -1453405940:
- if (implMethodName.equals("getMachineId")) {
- z = true;
- break;
- }
- break;
- case -557259320:
- if (implMethodName.equals("getWorkstationId")) {
- z = false;
- break;
- }
- break;
- case -428329133:
- if (implMethodName.equals("getDataItem")) {
- z = true;
- break;
- }
- break;
- case -427996294:
- if (implMethodName.equals("getDataType")) {
- z = true;
- break;
- }
- break;
- case 64117345:
- if (implMethodName.equals("getDmpVariablesId")) {
- z = true;
- break;
- }
- break;
- case 98245393:
- if (implMethodName.equals("getId")) {
- z = true;
- break;
- }
- break;
- case 1431273455:
- if (implMethodName.equals("getCollectSettingItem")) {
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWcs") && 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/cps/entity/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getCollectSettingItem();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getCollectSettingItem();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getCollectSettingItem();
- };
- }
- 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/DmpVariables") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getMachineId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getDmpVariablesId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getDmpVariablesId();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getDataType();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getDataType();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getDataType();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getDataType();
- };
- }
- break;
- case RegionCache.VILLAGE_LEVEL /* 5 */:
- 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/cps/entity/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getDataItem();
- };
- }
- 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/WorkstationWcs") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getDataItem();
- };
- }
- break;
- }
- throw new IllegalArgumentException("Invalid lambda deserialization");
- }
-
@Transactional(rollbackFor = {Exception.class})
public List<WorkstationWcsVO> updateBatch(List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
List<WorkstationWcs> workstationWcsList = WorkstationWcsConvert.INSTANCE.convertVOToEntity(workstationWcsSaveVOList);
List<Long> workstationWcsIdList = new ArrayList<>();
List<WorkstationWcs> wcsList = new ArrayList<>();
for (WorkstationWcs workstationWcs : workstationWcsList) {
+ List<Long> ids = list(Wrappers.<WorkstationWcs>lambdaQuery()
+ .eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId, workstationWcs.getWorkstationId())
+ .eq(WorkstationWcs::getCollectSettingItem, workstationWcs.getCollectSettingItem())
+ .eq(WorkstationWcs::getDataType, workstationWcs.getDataType())
+ .eq(WorkstationWcs::getDataItem, workstationWcs.getDataItem()))
+ .stream().map(WorkstationWcs::getId).collect(Collectors.toList());
+ /*
List<Long> ids = (List) list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), (v0) -> {
return v0.getWorkstationId();
}, workstationWcs.getWorkstationId()).eq((v0) -> {
@@ -292,7 +88,7 @@
return v0.getDataItem();
}, workstationWcs.getDataItem())).stream().map((v0) -> {
return v0.getId();
- }).collect(Collectors.toList());
+ }).collect(Collectors.toList());*/
if (Func.isNotEmpty(ids)) {
workstationWcsIdList.addAll(ids);
} else {
@@ -302,11 +98,11 @@
MachineDmpVariablesVO machineDmpVariablesVO = this.dmpVariablesService.listByWorkstationId(workstationWcs.getWorkstationId());
List<DmpVariablesVO> dmpVariablesVOList = machineDmpVariablesVO.getDmpVariablesVOList();
if (Func.isNotEmpty(dmpVariablesVOList)) {
- List<String> nameList = (List) dmpVariablesVOList.stream().map((v0) -> {
+ List<String> nameList = dmpVariablesVOList.stream().map((v0) -> {
return v0.getName();
}).collect(Collectors.toList());
if (nameList.contains(workstationWcs.getCollectSettingItem())) {
- Map<String, Long> dmpNameToId = (Map) dmpVariablesVOList.stream().collect(Collectors.toMap((v0) -> {
+ Map<String, Long> dmpNameToId = dmpVariablesVOList.stream().collect(Collectors.toMap((v0) -> {
return v0.getName();
}, (v0) -> {
return v0.getId();
@@ -318,7 +114,7 @@
}
removeByIds(workstationWcsIdList);
saveBatch(wcsList);
- List<Long> workstationIds = (List) wcsList.stream().map((v0) -> {
+ List<Long> workstationIds = wcsList.stream().map((v0) -> {
return v0.getWorkstationId();
}).collect(Collectors.toList());
if (Func.isNotEmpty(workstationIds)) {
@@ -334,30 +130,36 @@
@Transactional(rollbackFor = {Exception.class})
public List<WorkstationWcsVO> insert(List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
Long workstationId = workstationWcsSaveVOList.get(0).getWorkstationId();
- List<WorkstationWcsSaveVO> checkedVoList = (List) workstationWcsSaveVOList.stream().filter((v0) -> {
+ List<WorkstationWcsSaveVO> checkedVoList = workstationWcsSaveVOList.stream().filter((v0) -> {
return v0.checkedItem();
}).collect(Collectors.toList());
validWorkstationExistsWcs(checkedVoList);
List<DmpVariables> dmpVariablesList = validDmpName(workstationId, checkedVoList);
List<WorkstationWcs> saveWorkstationWcsList = WorkstationWcsConvert.INSTANCE.convertVOToEntity(checkedVoList);
this.dynamicCollectService.removeTableUpdateWcs(saveWorkstationWcsList);
+
+ this.dynamicCollectService.removeTableDeleteWcs(list(Lambda.eq(WorkstationWcs::getWorkstationId, workstationId)
+ .notIn(Func.isNotEmpty(saveWorkstationWcsList), WorkstationWcs::getCollectSettingItem, saveWorkstationWcsList
+ .stream().map(WorkstationWcs::getCollectSettingItem)
+ .collect(Collectors.toList()))));
+ /*
this.dynamicCollectService.removeTableDeleteWcs(list(Lambda.eq((v0) -> {
return v0.getWorkstationId();
}, workstationId).notIn(Func.isNotEmpty(saveWorkstationWcsList), (v0) -> {
return v0.getCollectSettingItem();
}, (Collection) saveWorkstationWcsList.stream().map((v0) -> {
return v0.getCollectSettingItem();
- }).collect(Collectors.toList()))));
+ }).collect(Collectors.toList()))));*/
deleteByWorkstationIdList(Collections.singletonList(workstationId));
for (WorkstationWcs workstationWcs : saveWorkstationWcsList) {
checkWorkstationWcs(workstationWcs);
setCrc(workstationWcs);
}
- List<WorkstationWcs> collect = (List) saveWorkstationWcsList.stream().filter(w -> {
+ List<WorkstationWcs> collect = saveWorkstationWcsList.stream().filter(w -> {
return Func.isNotEmpty(w.getDataItem());
}).collect(Collectors.toList());
saveOrUpdateBatch(collect);
- Map<Long, Integer> idToIdx = (Map) workstationWcsSaveVOList.stream().collect(Collectors.toMap((v0) -> {
+ Map<Long, Integer> idToIdx = workstationWcsSaveVOList.stream().collect(Collectors.toMap((v0) -> {
return v0.getDmpVariablesId();
}, (v0) -> {
return v0.getSort();
@@ -366,7 +168,7 @@
dmpVariables.setIdx((Integer) idToIdx.get(dmpVariables.getId()));
});
this.dmpVariablesService.updateBatchById(dmpVariablesList);
- List<Long> workstationIds = (List) workstationWcsSaveVOList.stream().map((v0) -> {
+ List<Long> workstationIds = workstationWcsSaveVOList.stream().map((v0) -> {
return v0.getWorkstationId();
}).collect(Collectors.toList());
WorkstationCache.clearDmpStatus(workstationIds);
@@ -378,7 +180,7 @@
}
private void validWorkstationExistsWcs(final List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
- boolean exist = ((Map) workstationWcsSaveVOList.stream().filter(it -> {
+ boolean exist = (workstationWcsSaveVOList.stream().filter(it -> {
return !it.getDataType().equals(WcsDataTypeEnums.WcsDataType.OTHER.getCode());
}).filter(it2 -> {
return it2.getUsageId() != null;
@@ -392,18 +194,18 @@
private List<DmpVariables> validDmpName(Long workstationId, List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
WorkstationOfMachine one = this.workstationOfMachineService.getWorkstationOfMachineByWorkstationId(workstationId);
- List<DmpVariables> dmpVariablesList = this.dmpVariablesService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
- return v0.getMachineId();
- }, one.getMachineId()));
- Map<Long, String> dmpIdToName = (Map) dmpVariablesList.stream().collect(Collectors.toMap((v0) -> {
+
+ List<DmpVariables> dmpVariablesList = this.dmpVariablesService.list(Wrappers.<DmpVariables>lambdaQuery().eq(DmpVariables::getMachineId, one.getMachineId()));
+
+ Map<Long, String> dmpIdToName = dmpVariablesList.stream().collect(Collectors.toMap((v0) -> {
return v0.getId();
}, (v0) -> {
return v0.getName();
}));
- List<String> collectItemList = (List) workstationWcsSaveVOList.stream().map(w -> {
+ List<String> collectItemList = workstationWcsSaveVOList.stream().map(w -> {
return (String) dmpIdToName.get(w.getDmpVariablesId());
}).collect(Collectors.toList());
- List<String> collectItemDistinctList = (List) collectItemList.stream().distinct().collect(Collectors.toList());
+ List<String> collectItemDistinctList = collectItemList.stream().distinct().collect(Collectors.toList());
Assert.isTrue(collectItemList.size() == collectItemDistinctList.size(), MessageUtils.message("workstationWcs.collectItem.already.exists", new Object[0]), new Object[0]);
return dmpVariablesList;
}
@@ -428,9 +230,7 @@
@Override // org.springblade.modules.cps.service.IWorkstationWcsService
public List<WorkstationWcsVO> listWcsSetting() {
- List<WorkstationWcs> list = list((Wrapper) Wrappers.lambdaQuery().isNull((v0) -> {
- return v0.getWorkstationId();
- }));
+ List<WorkstationWcs> list = list( Wrappers.<WorkstationWcs>lambdaQuery().isNull(WorkstationWcs::getWorkstationId));
List<WorkstationWcsVO> convert = WorkstationWcsConvert.INSTANCE.convert(list);
wrapperVO(convert);
return convert;
@@ -448,7 +248,14 @@
}
public void checkSetting(WorkstationWcs workstationWcs) {
- Long count = Long.valueOf(count((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(workstationWcs.getId()), (v0) -> {
+ Long count = Long.valueOf(count(Wrappers.<WorkstationWcs>lambdaQuery()
+ .ne(Func.isNotEmpty(workstationWcs.getId()), WorkstationWcs::getId, workstationWcs.getId())
+ .eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId, workstationWcs.getWorkstationId())
+ .isNull(Func.isEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId)
+ .eq(WorkstationWcs::getCollectSettingItem, workstationWcs.getCollectSettingItem())));
+
+ /*
+ Long count = Long.valueOf(count( Wrappers.lambdaQuery().ne(Func.isNotEmpty(workstationWcs.getId()), (v0) -> {
return v0.getId();
}, workstationWcs.getId()).eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), (v0) -> {
return v0.getWorkstationId();
@@ -456,7 +263,7 @@
return v0.getWorkstationId();
}).eq((v0) -> {
return v0.getCollectSettingItem();
- }, workstationWcs.getCollectSettingItem())));
+ }, workstationWcs.getCollectSettingItem())));*/
if (count.longValue() > 0) {
throw new ServiceException(MessageUtils.message("workstationWcs.collectItem.already.exists", new Object[0]));
}
@@ -464,9 +271,11 @@
@Override // org.springblade.modules.cps.service.IWorkstationWcsService
public Boolean deleteByWorkstationIdList(List<Long> workstationIdList) {
+ remove(Wrappers.<WorkstationWcs>lambdaQuery().in(WorkstationWcs::getWorkstationId, workstationIdList));
+ /*
remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
return v0.getWorkstationId();
- }, workstationIdList));
+ }, workstationIdList));*/
clearWorkstationParamTypeCacheByWorkstationId(workstationIdList);
return true;
}
@@ -479,6 +288,21 @@
}
private void wrapperVO(final List<WorkstationWcsVO> workstationWcsVOList) {
+ workstationWcsVOList
+ .forEach(it -> {
+ it.setDataTypeDesc(WcsDataTypeEnums.WcsDataType.getNameByCode(it.getDataType()));
+
+ //WorkstationWcsUsage usage = workstationWcsUsageService.getById(it.getUsageId());
+ //it.setUsageName(usage.getUsageName());
+ Optional.<Long>ofNullable(it.getUsageId()).map(usageId -> {
+ WorkstationWcsUsage usage = workstationWcsUsageService.getById(usageId);
+ return usage;
+ }).ifPresent(usage2 -> {
+ it.setUsageName(usage2.getUsageName());
+ });
+ //Optional.<Long>ofNullable(it.getUsageId()).map(this.workstationWcsUsageService::getById).ifPresent(());
+ });
+ /*
workstationWcsVOList.forEach(it -> {
it.setDataTypeDesc(WcsDataTypeEnums.WcsDataType.getNameByCode(it.getDataType()));
Optional ofNullable = Optional.ofNullable(it.getUsageId());
@@ -489,14 +313,14 @@
}).ifPresent(usage -> {
it.setUsageName(usage.getUsageName());
});
- });
+ });*/
}
@Override // org.springblade.modules.cps.service.IWorkstationWcsService
public Boolean delete(List<Long> workstationWcsIdList) {
List<WorkstationWcs> workstationWcs = listByIds(workstationWcsIdList);
removeByIds(workstationWcsIdList);
- List<Long> workstationIds = (List) workstationWcs.stream().map((v0) -> {
+ List<Long> workstationIds = workstationWcs.stream().map((v0) -> {
return v0.getWorkstationId();
}).collect(Collectors.toList());
workstationIds.forEach(id -> {
@@ -508,10 +332,13 @@
@Override // org.springblade.modules.cps.service.IWorkstationWcsService
public void clearWorkstationParamTypeCacheByWorkstationId(List<Long> workstationIdList) {
+ List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery()
+ .in(WorkstationOfMachine::getWorkstationId, workstationIdList));
+ /*
List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
return v0.getWorkstationId();
- }, workstationIdList));
- List<Long> machineIdList = (List) workstationOfMachineList.stream().map((v0) -> {
+ }, workstationIdList));*/
+ List<Long> machineIdList = workstationOfMachineList.stream().map((v0) -> {
return v0.getMachineId();
}).collect(Collectors.toList());
for (Long id : machineIdList) {
@@ -525,7 +352,7 @@
List<WorkstationWcsSaveVO> workstationWcsSaveVOList = new ArrayList<>();
workstationIdList.forEach(workstationId -> {
List<WorkstationWcsVO> workstationWcsVOList = listWorkstationWcsByWorkstationId(workstationId);
- Map<String, Long> wcsCollectItemToId = (Map) workstationWcsVOList.stream().collect(Collectors.toMap((v0) -> {
+ Map<String, Long> wcsCollectItemToId = workstationWcsVOList.stream().collect(Collectors.toMap((v0) -> {
return v0.getCollectItemDesc();
}, (v0) -> {
return v0.getId();
@@ -539,6 +366,18 @@
});
List<WorkstationWcs> workstationWcsList = WorkstationWcsConvert.INSTANCE.convertVOToEntity(workstationWcsSaveVOList);
workstationWcsList.forEach(this::setCrc);
+
+ Stream<WorkstationWcsSaveVO> stream = workstationWcsSaveVOList.stream();
+ Stream<WorkstationWcsSaveVO> stream2 = list(Lambda.in(WorkstationWcs::getWorkstationId, workstationIdList)
+ .notIn(WorkstationWcs::getId,workstationWcsList
+ .stream().map(WorkstationWcs::getId).collect(Collectors.toList()))
+ .ne(WorkstationWcs::getDataType, WcsDataTypeEnums.WcsDataType.OTHER.getCode()))
+ .stream().map(WorkstationWcsConvert.INSTANCE::convert);
+
+ //Stream.concat(stream, stream2);
+ validWorkstationExistsWcs(Stream.concat(stream, stream2).collect(Collectors.toList()));
+
+ /*
Stream<WorkstationWcsSaveVO> stream = workstationWcsSaveVOList.stream();
Stream stream2 = list((Wrapper) ((ExtraLambdaQueryWrapper) Lambda.in((v0) -> {
return v0.getWorkstationId();
@@ -552,6 +391,7 @@
WorkstationWcsConvert workstationWcsConvert = WorkstationWcsConvert.INSTANCE;
workstationWcsConvert.getClass();
validWorkstationExistsWcs((List) Stream.concat(stream, stream2.map(this::convert)).collect(Collectors.toList()));
+ */
this.dynamicCollectService.removeTableUpdateWcs(workstationWcsList);
updateBatchById(workstationWcsList);
WorkstationCache.clearDmpStatus(workstationIdList);
@@ -566,7 +406,7 @@
@Override // org.springblade.modules.cps.service.IWorkstationWcsService
public String isExists(List<WorkstationWcsSaveNewVO> workstationWcsSaveNewVOList, List<Long> workstationIdList) {
- Map<Long, String> workstationIdToName = (Map) this.workstationService.listByIds(workstationIdList).stream().collect(Collectors.toMap((v0) -> {
+ Map<Long, String> workstationIdToName = this.workstationService.listByIds(workstationIdList).stream().collect(Collectors.toMap((v0) -> {
return v0.getId();
}, (v0) -> {
return v0.getName();
@@ -575,6 +415,10 @@
Set<Long> idSet = new HashSet<>();
for (Long workstationId : workstationIdList) {
for (WorkstationWcsSaveNewVO w : workstationWcsSaveNewVOList) {
+ Long count = Long.valueOf(count(Wrappers.<WorkstationWcs>lambdaQuery()
+ .eq(WorkstationWcs::getWorkstationId, workstationId).eq(WorkstationWcs::getDmpVariablesId, w.getDmpVariablesId())
+ .eq(WorkstationWcs::getDataType, w.getDataType()).eq(WorkstationWcs::getDataItem, w.getDataItem())));
+ /*
Long count = Long.valueOf(count((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
return v0.getWorkstationId();
}, workstationId)).eq((v0) -> {
@@ -583,7 +427,7 @@
return v0.getDataType();
}, w.getDataType())).eq((v0) -> {
return v0.getDataItem();
- }, w.getDataItem())));
+ }, w.getDataItem())));*/
if (count.longValue() > 0) {
idSet.add(workstationId);
}
@@ -597,28 +441,20 @@
private void checkWorkstationWcs(WorkstationWcs workstationWcs) {
if (WcsDataTypeEnums.ONLY_ONE_LIST.contains(workstationWcs.getDataType())) {
- Long count = Long.valueOf(count((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(workstationWcs.getId()), (v0) -> {
- return v0.getId();
- }, workstationWcs.getId()).eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), (v0) -> {
- return v0.getWorkstationId();
- }, workstationWcs.getWorkstationId()).isNotNull(Func.isNotEmpty(workstationWcs.getWorkstationId()), (v0) -> {
- return v0.getWorkstationId();
- }).eq((v0) -> {
- return v0.getDataType();
- }, workstationWcs.getDataType())));
+ Long count = Long.valueOf(count(Wrappers.<WorkstationWcs>lambdaQuery()
+ .ne(Func.isNotEmpty(workstationWcs.getId()), WorkstationWcs::getId, workstationWcs.getId())
+ .eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId, workstationWcs.getWorkstationId())
+ .isNotNull(Func.isNotEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId)
+ .eq(WorkstationWcs::getDataType, workstationWcs.getDataType())));
if (count.longValue() > 0) {
throw new ServiceException(MessageUtils.message("workstationWcs.dataType.already.exists", new Object[0]));
}
}
- Long count2 = Long.valueOf(count((Wrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(workstationWcs.getId()), (v0) -> {
- return v0.getId();
- }, workstationWcs.getId()).eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), (v0) -> {
- return v0.getWorkstationId();
- }, workstationWcs.getWorkstationId()).isNotNull(Func.isNotEmpty(workstationWcs.getWorkstationId()), (v0) -> {
- return v0.getWorkstationId();
- }).eq((v0) -> {
- return v0.getDmpVariablesId();
- }, workstationWcs.getDmpVariablesId())));
+ Long count2 = Long.valueOf(count(Wrappers.<WorkstationWcs>lambdaQuery()
+ .ne(Func.isNotEmpty(workstationWcs.getId()), WorkstationWcs::getId, workstationWcs.getId())
+ .eq(Func.isNotEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId, workstationWcs.getWorkstationId())
+ .isNotNull(Func.isNotEmpty(workstationWcs.getWorkstationId()), WorkstationWcs::getWorkstationId)
+ .eq(WorkstationWcs::getDmpVariablesId, workstationWcs.getDmpVariablesId())));
if (count2.longValue() > 0) {
throw new ServiceException(MessageUtils.message("workstationWcs.collectItem.already.exists", new Object[0]));
}
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsUsageServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsUsageServiceImpl.java
index fd18bc2..64254e4 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsUsageServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsUsageServiceImpl.java
@@ -1,31 +1,33 @@
package com.qianwen.smartman.modules.cps.service.impl;
-import cn.hutool.core.lang.Assert;
-import cn.hutool.json.JSONUtil;
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import java.io.Serializable;
-import java.lang.invoke.SerializedLambda;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.function.Function;
import java.util.stream.Collectors;
+
import javax.validation.constraints.NotNull;
+
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.common.constant.DictConstant;
import com.qianwen.smartman.common.utils.Lambda;
import com.qianwen.smartman.common.utils.MessageUtils;
-import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.modules.cps.entity.WorkstationWcsUsage;
import com.qianwen.smartman.modules.cps.mapper.WorkstationWcsUsageMapper;
import com.qianwen.smartman.modules.cps.service.IWorkstationWcsUsageService;
import com.qianwen.smartman.modules.cps.vo.WorkstationWcsUsageVO;
import com.qianwen.smartman.modules.system.service.IDictService;
import com.qianwen.smartman.modules.tdengine.service.IWorkstationDynamicCollectService;
-import org.springframework.cache.annotation.CacheEvict;
-import org.springframework.cache.annotation.Cacheable;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
+
+import cn.hutool.core.lang.Assert;
+import cn.hutool.json.JSONUtil;
@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/WorkstationWcsUsageServiceImpl.class */
@@ -34,82 +36,7 @@
private final IDictService dictService;
private final IWorkstationDynamicCollectService workstationDynamicCollectService;
- 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 764041336:
- if (implMethodName.equals("getUsageCode")) {
- z = false;
- break;
- }
- break;
- case 764355862:
- if (implMethodName.equals("getUsageName")) {
- z = true;
- break;
- }
- break;
- case 1213007438:
- if (implMethodName.equals("getCollectType")) {
- 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/WorkstationWcsUsage") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getUsageCode();
- };
- }
- 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/WorkstationWcsUsage") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getUsageCode();
- };
- }
- 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/WorkstationWcsUsage") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getCollectType();
- };
- }
- 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/WorkstationWcsUsage") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getUsageName();
- };
- }
- 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/WorkstationWcsUsage") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getUsageName();
- };
- }
- 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/WorkstationWcsUsage") && 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/modules/cps/entity/WorkstationWcsUsage") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getId();
- };
- }
- break;
- }
- throw new IllegalArgumentException("Invalid lambda deserialization");
- }
+
public WorkstationWcsUsageServiceImpl(final IDictService dictService, final IWorkstationDynamicCollectService workstationDynamicCollectService) {
this.dictService = dictService;
@@ -125,12 +52,12 @@
@Override // org.springblade.modules.cps.service.IWorkstationWcsUsageService
@Cacheable(cacheNames = {WORKSTATION_WCS_USAGE_EXP}, key = "'usage:list'")
public List<WorkstationWcsUsageVO> listVO() {
- Map<Integer, String> wcsMap = (Map) this.dictService.getList(DictConstant.WORKSTATION_PARAM_TYPE).stream().collect(Collectors.toMap(dict -> {
+ Map<Integer, String> wcsMap = this.dictService.getList(DictConstant.WORKSTATION_PARAM_TYPE).stream().collect(Collectors.toMap(dict -> {
return Integer.valueOf(Func.toInt(dict.getDictKey()));
}, (v0) -> {
return v0.getDictValue();
}));
- return (List) list(Lambda.asc((v0) -> {
+ return list(Lambda.asc((v0) -> {
return v0.getCollectType();
})).stream().map(it -> {
WorkstationWcsUsageVO vo = new WorkstationWcsUsageVO();
@@ -169,6 +96,14 @@
@CacheEvict(cacheNames = {WORKSTATION_WCS_USAGE_EXP}, allEntries = true)
public Boolean update(final WorkstationWcsUsageVO workstationWcsVO) {
Assert.notNull(workstationWcsVO.getId());
+
+ Assert.isTrue(
+ (list(Lambda.eq(WorkstationWcsUsage::getUsageName, workstationWcsVO.getUsageName()).ne(WorkstationWcsUsage::getId, workstationWcsVO.getId())).size() == 0),
+ MessageUtils.message("workstation.wcs.usage.usageName.exists", new Object[0]), new Object[0]);
+ Assert.isTrue(
+ (list(Lambda.eq(WorkstationWcsUsage::getUsageCode, workstationWcsVO.getUsageCode()).ne(WorkstationWcsUsage::getId, workstationWcsVO.getId())).size() == 0),
+ MessageUtils.message("workstation.wcs.usage.usageCode.exists", new Object[0]), new Object[0]);
+ /*
Assert.isTrue(list((Wrapper) Lambda.eq((v0) -> {
return v0.getUsageName();
}, workstationWcsVO.getUsageName()).ne((v0) -> {
@@ -179,6 +114,7 @@
}, workstationWcsVO.getUsageCode()).ne((v0) -> {
return v0.getId();
}, workstationWcsVO.getId())).size() == 0, MessageUtils.message("workstation.wcs.usage.usageCode.exists", new Object[0]), new Object[0]);
+ */
Assert.isTrue(Func.isEmpty(workstationWcsVO.getParameter()) || JSONUtil.isJsonObj(workstationWcsVO.getParameter()), MessageUtils.message("workstation.wcs.usage.parameter.nojson", new Object[0]), new Object[0]);
wcsUsageUsedValid(workstationWcsVO.getId(), oldUsage -> {
return Boolean.valueOf((oldUsage.getUsageCode().equals(workstationWcsVO.getUsageCode()) && oldUsage.getCollectType().equals(workstationWcsVO.getCollectType()) && oldUsage.getUsageName().equals(workstationWcsVO.getUsageName())) ? false : true);
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWorkbenchServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWorkbenchServiceImpl.java
index 412fa2d..eeb72a9 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWorkbenchServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWorkbenchServiceImpl.java
@@ -26,6 +26,8 @@
import com.qianwen.smartman.modules.dnc.entity.TransferDirectory;
import com.qianwen.smartman.modules.dnc.service.IDncWsRelationTdService;
import com.qianwen.smartman.modules.dnc.service.ITransferDirectoryService;
+import com.qianwen.smartman.modules.trace.entity.TraceFlowSettings;
+import com.qianwen.smartman.modules.trace.entity.TraceRelatedWorkstation;
import com.qianwen.smartman.modules.trace.service.ITraceFlowSettingsService;
import com.qianwen.smartman.modules.trace.service.ITraceRelatedWorkstationService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -33,7 +35,6 @@
import org.springframework.stereotype.Service;
@Service
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/WorkstationWorkbenchServiceImpl.class */
public class WorkstationWorkbenchServiceImpl extends BaseServiceImpl<WorkstationWorkbenchMapper, WorkstationWorkbench> implements IWorkstationWorkbenchService {
@Autowired
@Lazy
@@ -49,156 +50,18 @@
private final Integer SORT = 1;
private final Integer DEFAULT = 1;
- private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
- String implMethodName = lambda.getImplMethodName();
- boolean z = true;
- switch (implMethodName.hashCode()) {
- case -871043410:
- if (implMethodName.equals("getTraceFlowSettingId")) {
- z = true;
- break;
- }
- break;
- case -557259320:
- if (implMethodName.equals("getWorkstationId")) {
- z = false;
- break;
- }
- break;
- case -307107987:
- if (implMethodName.equals("getWorkstationGroupId")) {
- z = true;
- break;
- }
- break;
- case -75308287:
- if (implMethodName.equals("getName")) {
- z = true;
- break;
- }
- break;
- case -75145708:
- if (implMethodName.equals("getSort")) {
- 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/cps/entity/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/dnc/entity/DncWsRelationTd") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getWorkstationId();
- };
- }
- 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/WorkstationWorkbench") && 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/cps/entity/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getSort();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
- return (v0) -> {
- return v0.getSort();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getName();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getName();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getName();
- };
- }
- 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/WorkstationWorkbench") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
- return (v0) -> {
- return v0.getName();
- };
- }
- 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/TraceRelatedWorkstation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
- return (v0) -> {
- return v0.getTraceFlowSettingId();
- };
- }
- break;
- case RegionCache.VILLAGE_LEVEL /* 5 */:
- 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;
- }
- throw new IllegalArgumentException("Invalid lambda deserialization");
- }
@Override // org.springblade.modules.cps.service.IWorkstationWorkbenchService
public Boolean saveWorkstationWorkbench(WorkstationWorkbenchVO vo) {
+ WorkstationWorkbench workbench = (WorkstationWorkbench)getOne(Wrappers.<WorkstationWorkbench>query().lambda()
+ .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId())
+ .eq(WorkstationWorkbench::getName, vo.getName()));
+ /*
WorkstationWorkbench workbench = (WorkstationWorkbench) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
return v0.getWorkstationId();
}, vo.getWorkstationId())).eq((v0) -> {
return v0.getName();
- }, vo.getName()));
+ }, vo.getName()));*/
if (Func.isNull(workbench)) {
WorkstationWorkbench workstationWorkbench = WorkstationWorkbenchConvert.INSTANCE.convert(vo);
workstationWorkbench.setId(vo.getId());
@@ -212,11 +75,16 @@
public MachineInformationVO listWorkstationWorkbench(Long workstationId) {
TransferDirectory transferDirectory;
MachineInformationVO machineInformationVO = new MachineInformationVO();
+
+ List<WorkstationWorkbench> workbenchList = list(Wrappers.<WorkstationWorkbench>query().lambda()
+ .eq(WorkstationWorkbench::getWorkstationId, workstationId)
+ .orderByAsc(WorkstationWorkbench::getSort));
+ /*
List<WorkstationWorkbench> workbenchList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
return v0.getWorkstationId();
}, workstationId)).orderByAsc((v0) -> {
return v0.getSort();
- }));
+ }));*/
WorkstationVO workstationVO = this.workstationService.getDetail(workstationId);
if (Func.isEmpty(workstationVO)) {
return machineInformationVO;
@@ -243,23 +111,36 @@
if (vo.getWorkbenchDefault().equals(this.DEFAULT)) {
throw new ServiceException(MessageUtils.message("work.station.default.work.bench.not.delete", new Object[0]));
}
+ List<WorkstationWorkbench> list = list(Wrappers.<WorkstationWorkbench>query().lambda()
+ .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId()));
+ /*
List<WorkstationWorkbench> list = list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
return v0.getWorkstationId();
- }, vo.getWorkstationId()));
+ }, vo.getWorkstationId()));*/
if (list.size() <= 1) {
throw new ServiceException(MessageUtils.message("work.station.work.bench.is.only.so.not.delete", new Object[0]));
}
+
+ boolean remove = remove(Wrappers.<WorkstationWorkbench>update().lambda()
+ .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId())
+ .eq(WorkstationWorkbench::getName, vo.getName()));
+ /*
boolean remove = remove((Wrapper) ((LambdaUpdateWrapper) Wrappers.update().lambda().eq((v0) -> {
return v0.getWorkstationId();
}, vo.getWorkstationId())).eq((v0) -> {
return v0.getName();
- }, vo.getName()));
+ }, vo.getName()));*/
+
if (remove) {
+ List<WorkstationWorkbench> workbenchList = list(Wrappers.<WorkstationWorkbench>query().lambda()
+ .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId())
+ .ge(WorkstationWorkbench::getSort, vo.getSort()));
+ /*
List<WorkstationWorkbench> workbenchList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
return v0.getWorkstationId();
}, vo.getWorkstationId())).ge((v0) -> {
return v0.getSort();
- }, vo.getSort()));
+ }, vo.getSort()));*/
if (Func.isNotEmpty(workbenchList)) {
workbenchList.forEach(workbench -> {
workbench.setSort(Integer.valueOf(workbench.getSort().intValue() - this.SORT.intValue()));
@@ -272,17 +153,26 @@
@Override // org.springblade.modules.cps.service.IWorkstationWorkbenchService
public Boolean updateWorkstationWorkbench(WorkstationWorkbenchVO vo) {
+ WorkstationWorkbench workbench = getOne(Wrappers.<WorkstationWorkbench>query().lambda()
+ .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId())
+ .eq(WorkstationWorkbench::getName, vo.getName()));
+ /*
WorkstationWorkbench workbench = (WorkstationWorkbench) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
return v0.getWorkstationId();
}, vo.getWorkstationId())).eq((v0) -> {
return v0.getName();
}, vo.getName()));
+ */
if (Func.isNull(workbench) || vo.getId().equals(workbench.getId())) {
+ return Boolean.valueOf(update(Wrappers.<WorkstationWorkbench>update().lambda()
+ .eq(WorkstationWorkbench::getId, vo.getId())
+ .set(WorkstationWorkbench::getName, vo.getName())));
+ /*
return Boolean.valueOf(update((Wrapper) ((LambdaUpdateWrapper) Wrappers.update().lambda().eq((v0) -> {
return v0.getId();
}, vo.getId())).set((v0) -> {
return v0.getName();
- }, vo.getName())));
+ }, vo.getName())));*/
}
throw new ServiceException(MessageUtils.message("work.station.work.bench.name.already.exist", new Object[0]));
}
@@ -293,21 +183,30 @@
if (Func.isEmpty(groupId)) {
return ((WorkstationWorkbenchMapper) this.baseMapper).listByGroupId(groupIds, keyWord);
}
+ List<Long> settingsIdList = this.traceFlowSettingsService.list(Wrappers.<TraceFlowSettings>lambdaQuery()
+ .eq(TraceFlowSettings::getWorkstationGroupId, groupId)
+ .ne(Func.isNotEmpty(settingsId), TraceFlowSettings::getId, settingsId))
+ .stream().map(TraceFlowSettings::getId).collect(Collectors.toList());
+ /*
List<Long> settingsIdList = (List) this.traceFlowSettingsService.list(((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
return v0.getWorkstationGroupId();
}, groupId)).ne(Func.isNotEmpty(settingsId), (v0) -> {
return v0.getId();
}, settingsId)).stream().map((v0) -> {
return v0.getId();
- }).collect(Collectors.toList());
+ }).collect(Collectors.toList());*/
if (Func.isEmpty(settingsIdList)) {
return ((WorkstationWorkbenchMapper) this.baseMapper).listByGroupId(groupIds, keyWord);
}
+ List<Long> workstationIdList = this.traceRelatedWorkstationService.list(Wrappers.<TraceRelatedWorkstation>lambdaQuery()
+ .in(TraceRelatedWorkstation::getTraceFlowSettingId, settingsIdList))
+ .stream().map(TraceRelatedWorkstation::getWorkstationId).collect(Collectors.toList());
+ /*
List<Long> workstationIdList = (List) this.traceRelatedWorkstationService.list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
return v0.getTraceFlowSettingId();
}, settingsIdList)).stream().map((v0) -> {
return v0.getWorkstationId();
- }).collect(Collectors.toList());
+ }).collect(Collectors.toList());*/
return ((WorkstationWorkbenchMapper) this.baseMapper).listByGroupIdAndWorkstationNotIn(groupIds, keyWord, workstationIdList);
}
}
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/wrapper/EmployeeWrapper.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/wrapper/EmployeeWrapper.java
index bb215e4..b841b2f 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/wrapper/EmployeeWrapper.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/wrapper/EmployeeWrapper.java
@@ -10,6 +10,7 @@
import com.qianwen.core.tool.utils.SpringUtil;
import com.qianwen.smartman.modules.cps.convert.EmployeeConvert;
import com.qianwen.smartman.modules.cps.dto.EmployeeDTO;
+import com.qianwen.smartman.modules.cps.entity.CommonGroup;
import com.qianwen.smartman.modules.cps.service.ICommonGroupService;
import com.qianwen.smartman.modules.cps.vo.EmployeeDetailVO;
import com.qianwen.smartman.modules.system.entity.User;
@@ -30,6 +31,18 @@
employeeDetailVO.setPostName(Func.join(postName));
employeeDetailVO.setAccount(Func.isNotEmpty(user) ? user.getAccount() : null);
employeeDetailVO.setRoleName(Func.join(roleName));
+
+ employeeDetailVO.setOrganizationName(
+ Optional.<String>ofNullable(employeeDetailVO.getOrganizationId())
+ .map(orgid -> {
+ ICommonGroupService groupService = SpringUtil.getBean(ICommonGroupService.class);
+ return groupService.getById(orgid);
+ //return null;
+ })
+ .map(CommonGroup::getName)
+ .orElse(null)
+ );
+ /*
Optional ofNullable = Optional.ofNullable(employeeDetailVO.getOrganizationId());
ICommonGroupService iCommonGroupService = (ICommonGroupService) SpringUtil.getBean(ICommonGroupService.class);
iCommonGroupService.getClass();
@@ -38,6 +51,8 @@
}).map((v0) -> {
return v0.getName();
}).orElse(null));
+ */
+
return employeeDetailVO;
}
}
--
Gitblit v1.9.3