From 444b1808d73d21f9df361e64f44381b910947792 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 27 九月 2024 11:05:08 +0800
Subject: [PATCH] 去掉tdedgine，去掉一部分rocketmq，去掉dmplog模块
---
smart-man-boot/src/main/java/com/qianwen/smartman/common/cache/cps/WorkstationCache.java | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/common/cache/cps/WorkstationCache.java b/smart-man-boot/src/main/java/com/qianwen/smartman/common/cache/cps/WorkstationCache.java
index dcd8038..265a9d2 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/common/cache/cps/WorkstationCache.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/common/cache/cps/WorkstationCache.java
@@ -40,6 +40,7 @@
import com.qianwen.smartman.modules.mdc.dto.WorkstationDmpDTO;
import com.qianwen.smartman.modules.mdc.entity.WorkstationCollectData;
import com.qianwen.smartman.modules.mdc.mapper.SuperProcessParameterMapper;
+import com.qianwen.smartman.modules.mdc.service.IProcessParameterService;
public class WorkstationCache {
public static final String CRC = "crc:";
@@ -64,7 +65,8 @@
private static final IGlobalWcsService WCS_SERVICE = (IGlobalWcsService) SpringUtil.getBean(IGlobalWcsService.class);
private static final IWorkstationWcsService WORKSTATION_WCS_SERVICE = (IWorkstationWcsService) SpringUtil.getBean(IWorkstationWcsService.class);
private static final SuperProcessParameterMapper superProcessParameterMapper = (SuperProcessParameterMapper) SpringUtil.getBean(SuperProcessParameterMapper.class);
-
+ private static final IProcessParameterService processParameterService = SpringUtil.getBean(IProcessParameterService.class);
+
public static List<WorkstationWcsDmpDTO> getWorkstationWcsList(String workstationId) {
String redisKey = CommonUtil.getReallyCacheName(ExtCacheConstant.CPS_CACHE, WORKSTATION_WCS, "", workstationId);
SetOperations<String, Object> setOps = BLADE_REDIS.getSetOps();
@@ -138,7 +140,10 @@
String cacheName = CommonUtil.getReallyCacheName(ExtCacheConstant.CPS_CACHE, WORKSTATION_REAL_TIME, "", workstationId);
Map<String, Object> resultMapping = BLADE_REDIS.hGetAll(cacheName);
if (Func.isEmpty(resultMapping)) {
- List<WorkstationCollectData> workstationCollectData = superProcessParameterMapper.queryLastParameter(workstationId);
+ //
+ //List<WorkstationCollectData> workstationCollectData = superProcessParameterMapper.queryLastParameter(workstationId);
+ Long wid = Long.parseLong(workstationId);
+ List<WorkstationCollectData> workstationCollectData = processParameterService.queryLastParameter(wid);
if (Func.isNotEmpty(workstationCollectData)) {
resultMapping = workstationCollectData.stream().collect(Collectors.toMap((v0) -> {
return v0.getN();
@@ -149,6 +154,7 @@
return result;
}));
}
+
}
return resultMapping;
}
--
Gitblit v1.9.3