From 56599835685c0deb29601d9eb287b9436324b824 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期四, 16 一月 2025 13:43:11 +0800
Subject: [PATCH] 1、统一各个模块端口,避免端口冲突

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java |   33 ++++++++++++++++++---------------
 1 files changed, 18 insertions(+), 15 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java
index b2f6827..5f12d21 100644
--- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java
+++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java
@@ -1,16 +1,13 @@
 package com.mes.job;
 
 import cn.hutool.json.JSONObject;
-import cn.smallbun.screw.core.util.CollectionUtils;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.kangaroohy.milo.model.ReadWriteEntity;
 import com.kangaroohy.milo.service.MiloService;
-import com.mes.bigstorage.entity.BigStorageCageDetails;
 import com.mes.bigstorage.service.BigStorageCageDetailsService;
 import com.mes.bigstorage.service.BigStorageCageService;
 import com.mes.bigstoragecagetask.entity.BigStorageCageTask;
 import com.mes.bigstoragecagetask.service.BigStorageCageTaskService;
-import com.mes.glassinfo.entity.GlassInfo;
 import com.mes.glassinfo.service.GlassInfoService;
 import com.mes.temperingglass.entity.TemperingGlassInfo;
 import com.mes.temperingglass.service.TemperingGlassInfoService;
@@ -18,14 +15,10 @@
 import com.mes.utils.RedisUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
-import java.net.Socket;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -53,12 +46,6 @@
     @Autowired(required = false)
     MiloService miloService;
 
-    @Value("${mes.scan.ip}")
-    private String scanIp;
-
-    @Value("${mes.scan.port}")
-    private Integer scanPort;
-
     private JSONObject jsonObject = new JSONObject();
 
     public void queryDataSource1() throws Exception {
@@ -67,7 +54,7 @@
         carPostion.add(0.5);
         jsonObject.append("carPostion", carPostion);
         //鐣岄潰灞曠ず绗煎瓙淇℃伅
-        jsonObject.append("bigStorageCageInfos", bigStorageCageService.querybigStorageCageDetail());
+      jsonObject.append("bigStorageCageInfos", bigStorageCageDetailsService.querybigStorageCageDetail());
 
         try{
             //杩涚墖浠诲姟鏁版嵁
@@ -88,6 +75,22 @@
                 }
             }
             jsonObject.append("bigStorageCageDetailsFeedTask", inTaskList);
+
+            //杩涚墖鑱旀満
+            ReadWriteEntity inkageEntity = miloService.readFromOpcUa("DLP1A.DLP1A.mesControl");
+            jsonObject.append("inkageEntity", inkageEntity.getValue());
+            //杩涚墖璇锋眰
+            ReadWriteEntity requestEntity = miloService.readFromOpcUa("DLP1A.DLP1A.RequestMes");
+            jsonObject.append("requestEntity", requestEntity.getValue());
+            //鍚姩鍛戒护
+            ReadWriteEntity mesReplyEntity = miloService.readFromOpcUa("DLP1A.DLP1A.MesReply");
+            jsonObject.append("mesReplyEntity", mesReplyEntity.getValue());
+            //鍑虹墖鑱旀満
+            ReadWriteEntity outInkageEntity = miloService.readFromOpcUa("DLP1B.DLP1B.mesControl");
+            jsonObject.append("outInkageEntity", outInkageEntity.getValue());
+            //鍑虹墖璇锋眰
+            ReadWriteEntity outRequestEntity = miloService.readFromOpcUa("DLP1B.DLP1B.RequestMes");
+            jsonObject.append("outRequestEntity", outRequestEntity.getValue());
         }catch(Exception e){
             //todo:涓嶅仛浠诲姟澶勭悊
         }
@@ -162,7 +165,7 @@
             //鏌ヨ浣跨敤鏁版嵁婧�1鏌ヨ鏁版嵁
             queryDataSource1();
             //鏌ヨ浣跨敤鏁版嵁婧�2鏌ヨ鏁版嵁
-            queryDataSource2();
+//            queryDataSource2();
 
             ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("slicecage");
             if (sendwServer != null) {

--
Gitblit v1.8.0