From 258a769f6790f832d1c67839d59be04a118767e5 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期日, 28 四月 2024 10:50:48 +0800
Subject: [PATCH] 用时分析代码整理+注释整理
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/WorkstationWcsServiceImpl.java | 60 +++++++++++++++++++++++++-----------------------------------
1 files changed, 25 insertions(+), 35 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 1b5480d..ef80713 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
@@ -1,13 +1,6 @@
package com.qianwen.smartman.modules.cps.service.impl;
-import cn.hutool.core.lang.Assert;
-import cn.hutool.core.util.HexUtil;
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import java.lang.invoke.SerializedLambda;
import java.util.ArrayList;
-import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
@@ -17,15 +10,20 @@
import java.util.stream.Collectors;
import java.util.stream.Stream;
import java.util.zip.CRC32;
-import com.qianwen.smartman.common.cache.RegionCache;
-import com.qianwen.smartman.common.cache.cps.WorkstationCache;
-import com.qianwen.smartman.common.enums.WcsDataTypeEnums;
-import com.qianwen.smartman.common.utils.ExtraLambdaQueryWrapper;
-import com.qianwen.smartman.common.utils.Lambda;
-import com.qianwen.smartman.common.utils.MessageUtils;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+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.tool.utils.Func;
+import com.qianwen.smartman.common.cache.cps.WorkstationCache;
+import com.qianwen.smartman.common.enums.WcsDataTypeEnums;
+import com.qianwen.smartman.common.utils.Lambda;
+import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.smartman.modules.cps.convert.WorkstationWcsConvert;
import com.qianwen.smartman.modules.cps.entity.DmpVariables;
import com.qianwen.smartman.modules.cps.entity.WorkstationOfMachine;
@@ -43,10 +41,9 @@
import com.qianwen.smartman.modules.cps.vo.WorkstationWcsSaveVO;
import com.qianwen.smartman.modules.cps.vo.WorkstationWcsVO;
import com.qianwen.smartman.modules.tdengine.service.IWorkstationDynamicCollectService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Lazy;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
+
+import cn.hutool.core.lang.Assert;
+import cn.hutool.core.util.HexUtil;
@Service
public class WorkstationWcsServiceImpl extends BaseServiceImpl<WorkstationWcsMapper, WorkstationWcs> implements IWorkstationWcsService {
@@ -126,7 +123,7 @@
return convert;
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
@Transactional(rollbackFor = {Exception.class})
public List<WorkstationWcsVO> insert(List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
Long workstationId = workstationWcsSaveVOList.get(0).getWorkstationId();
@@ -142,14 +139,7 @@
.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()))));*/
+
deleteByWorkstationIdList(Collections.singletonList(workstationId));
for (WorkstationWcs workstationWcs : saveWorkstationWcsList) {
checkWorkstationWcs(workstationWcs);
@@ -218,7 +208,7 @@
workstationWcs.setDataItemCrc(dataItemCrc);
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public WorkstationWcsVO updateSetting(WorkstationWcsSaveVO workstationWcsSaveVO) {
WorkstationWcs workstationWcs = WorkstationWcsConvert.INSTANCE.convert(workstationWcsSaveVO);
checkSetting(workstationWcs);
@@ -228,7 +218,7 @@
return workstationWcsVO;
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public List<WorkstationWcsVO> listWcsSetting() {
List<WorkstationWcs> list = list( Wrappers.<WorkstationWcs>lambdaQuery().isNull(WorkstationWcs::getWorkstationId));
List<WorkstationWcsVO> convert = WorkstationWcsConvert.INSTANCE.convert(list);
@@ -236,7 +226,7 @@
return convert;
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
@Transactional(rollbackFor = {Exception.class})
public List<WorkstationWcsVO> saveSetting(List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
List<WorkstationWcs> workstationWcsList = WorkstationWcsConvert.INSTANCE.convertVOToEntity(workstationWcsSaveVOList);
@@ -269,7 +259,7 @@
}
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public Boolean deleteByWorkstationIdList(List<Long> workstationIdList) {
remove(Wrappers.<WorkstationWcs>lambdaQuery().in(WorkstationWcs::getWorkstationId, workstationIdList));
/*
@@ -280,7 +270,7 @@
return true;
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public List<WorkstationWcsVO> listWorkstationWcsByWorkstationId(Long workstationId) {
List<WorkstationWcsVO> workstationWcsVOList = ((WorkstationWcsMapper) this.baseMapper).listWcs(workstationId);
wrapperVO(workstationWcsVOList);
@@ -316,7 +306,7 @@
});*/
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public Boolean delete(List<Long> workstationWcsIdList) {
List<WorkstationWcs> workstationWcs = listByIds(workstationWcsIdList);
removeByIds(workstationWcsIdList);
@@ -330,7 +320,7 @@
return null;
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public void clearWorkstationParamTypeCacheByWorkstationId(List<Long> workstationIdList) {
List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery()
.in(WorkstationOfMachine::getWorkstationId, workstationIdList));
@@ -346,7 +336,7 @@
}
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
@Transactional(rollbackFor = {Exception.class})
public List<WorkstationWcsVO> insertNew(List<WorkstationWcsSaveNewVO> workstationWcsSaveNewVOList, List<Long> workstationIdList) {
List<WorkstationWcsSaveVO> workstationWcsSaveVOList = new ArrayList<>();
@@ -404,7 +394,7 @@
return convert;
}
- @Override // org.springblade.modules.cps.service.IWorkstationWcsService
+ @Override
public String isExists(List<WorkstationWcsSaveNewVO> workstationWcsSaveNewVOList, List<Long> workstationIdList) {
Map<Long, String> workstationIdToName = this.workstationService.listByIds(workstationIdList).stream().collect(Collectors.toMap((v0) -> {
return v0.getId();
--
Gitblit v1.9.3