From c27b939fa5fa6ce4d712f7e9ced2ad811d69d5ec Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 30 十月 2024 20:46:25 +0800
Subject: [PATCH] 去掉dnc部分
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/tdengine/service/impl/WorkstationDynamicCollectServiceImpl.java | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/tdengine/service/impl/WorkstationDynamicCollectServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/tdengine/service/impl/WorkstationDynamicCollectServiceImpl.java
index 4e67bd9..176a354 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/tdengine/service/impl/WorkstationDynamicCollectServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/tdengine/service/impl/WorkstationDynamicCollectServiceImpl.java
@@ -26,13 +26,13 @@
import com.qianwen.smartman.common.enums.WcsDataTypeEnums;
import com.qianwen.smartman.common.utils.DelayList;
import com.qianwen.smartman.common.utils.Lambda;
-import com.qianwen.smartman.modules.cps.dto.CalendarShiftTimeSlicesDTO;
-import com.qianwen.smartman.modules.cps.entity.Workstation;
-import com.qianwen.smartman.modules.cps.entity.WorkstationWcs;
-import com.qianwen.smartman.modules.cps.entity.WorkstationWcsUsage;
-import com.qianwen.smartman.modules.cps.service.IWorkstationService;
-import com.qianwen.smartman.modules.cps.service.IWorkstationWcsService;
-import com.qianwen.smartman.modules.cps.service.IWorkstationWcsUsageService;
+import com.qianwen.smartman.modules.smis.dto.CalendarShiftTimeSlicesDTO;
+import com.qianwen.smartman.modules.smis.entity.Workstation;
+import com.qianwen.smartman.modules.smis.entity.WorkstationWcs;
+import com.qianwen.smartman.modules.smis.entity.WorkstationWcsUsage;
+import com.qianwen.smartman.modules.smis.service.IWorkstationService;
+import com.qianwen.smartman.modules.smis.service.IWorkstationWcsService;
+import com.qianwen.smartman.modules.smis.service.IWorkstationWcsUsageService;
import com.qianwen.smartman.modules.mdc.entity.SuperAggregateOutput;
import com.qianwen.smartman.modules.tdengine.dto.RemoveTableDTO;
import com.qianwen.smartman.modules.tdengine.mapper.WorkstationDynamicCollectMapper;
@@ -81,7 +81,7 @@
@Override
public void removeTableUpdateWcs(List<WorkstationWcs> updateWcsList) {
Map<Long, WorkstationWcs> current = new HashMap<>();
-
+ //鍒犻櫎鏃跺簭鏁版嵁搴撲腑鐨勮〃
updateWcsList.stream().filter(it -> Func.isNotEmpty(it.getUsageId())).peek(it -> current.put(it.getWorkstationId(),it)).map(it ->{
return this.workstationWcsService.getOne(Lambda.<WorkstationWcs>eq(WorkstationWcs::getWorkstationId, it.getWorkstationId()).eq(WorkstationWcs::getCollectSettingItem, it.getCollectSettingItem()).ne(WorkstationWcs::getDataType, WcsDataTypeEnums.WcsDataType.OTHER.getCode()));
}) .filter(Func::notNull)
--
Gitblit v1.9.3