From 49138a936668c30fbb4063e5d0bb518a400e6c39 Mon Sep 17 00:00:00 2001
From: 懒羊羊 <15939171744@163.com>
Date: 星期五, 26 一月 2024 09:30:45 +0800
Subject: [PATCH] 工位终端
---
jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java | 7 +++++++
1 files changed, 7 insertions(+), 0 deletions(-)
diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java b/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java
index b2ce549..2f5a299 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java
@@ -1,5 +1,7 @@
package com.jcdm.main.da.opcuaconfig.cert;
+import com.jcdm.framework.websocket.WebSocketServer;
+import com.jcdm.framework.websocket.WebSocketUsers;
import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf;
import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService;
import com.jcdm.main.da.opcuaconfig.client.ClientHandler;
@@ -13,14 +15,17 @@
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
+import javax.websocket.Session;
import java.util.Date;
import java.util.List;
+import java.util.Map;
import java.util.stream.Collectors;
import static com.jcdm.main.da.opcuaconfig.client.ClientHandler.readValues;
@Slf4j
public class MethodName {
+ Map<String, Session> map = WebSocketUsers.getUsers();
private IDaCollectionParamConfService collectionParamConfService = BeanUtils.getBean(IDaCollectionParamConfService.class);
private IDaParamCollectionService daParamCollectionService = BeanUtils.getBean(IDaParamCollectionService.class);
private IDaPassingStationCollectionService daPassingStationCollectionService = BeanUtils.getBean(IDaPassingStationCollectionService.class);
@@ -47,6 +52,7 @@
PassingStationCollection.setInboundTime(new Date());
daPassingStationCollectionService.insertDaPassingStationCollection(PassingStationCollection);
log.info("鑺傜偣:{},鍝嶅簲缁撴灉:{}", node1.getIdentifier(),out1);
+ WebSocketUsers.sendMessageToUserByText(map.get(parts[1]), "IN");
break;
case "2": //璇锋眰璁板綍宸ヤ綅鏁版嵁
List<DaCollectionParamConf> b;
@@ -83,6 +89,7 @@
//鏇存柊PLC鑺傜偣鐘舵��
NodeEntity node2= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".RecordDataDone").value("21").type("short").build();
Boolean out2=clientHandler.write(node2);
+ WebSocketUsers.sendMessageToUserByText(map.get(parts[1]), "OUT");
log.info("鑺傜偣:{},鍝嶅簲缁撴灉:{}", node2.getIdentifier(),out2);
break;
default:
--
Gitblit v1.9.3