From fe1e65520172d8c365d2fe75a843a44243f4faf6 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期一, 28 十月 2024 20:31:48 +0800
Subject: [PATCH] 2024-10-28 代码优化

---
 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtu/RtuCtrl.java |   44 +++++++++++---------------------------------
 1 files changed, 11 insertions(+), 33 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtu/RtuCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtu/RtuCtrl.java
index 5768ebf..55b2348 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtu/RtuCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtu/RtuCtrl.java
@@ -2,6 +2,7 @@
 
 import com.alibaba.fastjson2.JSONObject;
 import com.dy.common.aop.SsoAop;
+import com.dy.common.multiDataSource.DataSourceContext;
 import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
 import com.dy.common.mw.protocol.p206V1_0_0.downVos.*;
 import com.dy.common.mw.protocol.p206V202404.CodeV202404;
@@ -31,9 +32,6 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.Objects;
-
-//import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com97Vo;
-//import com.dy.common.mw.protocol.p206V1_0_0.downVos.ComXyVo;
 
 /**
  * @author ZhuBaoMin
@@ -94,11 +92,6 @@
         Long operator = po.getOperator();
         Long comId = idLongGenerator.generate();
 
-        // 鑾峰彇绯荤粺鍙傛暟
-        if(!setuped) {
-            setUp();
-        }
-
         // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚
         JSONObject job_rtu = getRtu(intakeId, null);
         if(job_rtu == null) {
@@ -106,7 +99,8 @@
         }
         String rtuAddr = job_rtu.getString("rtuAddr");
         String protocol = job_rtu.getString("protocol");
-        String orgTag = job_rtu.getString("orgTag");
+        //String orgTag = job_rtu.getString("orgTag");
+        String orgTag = DataSourceContext.get();
         comSendUrl = env.getProperty(pro_mw + "." + orgTag + "." + key_mw);
 
         // 鑾峰彇鍔熻兘鐮�
@@ -179,11 +173,6 @@
         Long operator = po.getOperator();
         Long comId = idLongGenerator.generate();
 
-        // 鑾峰彇绯荤粺鍙傛暟
-        if(!setuped) {
-            setUp();
-        }
-
         // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚
         JSONObject job_rtu = getRtu(intakeId, null);
         if(job_rtu == null) {
@@ -191,7 +180,8 @@
         }
         String rtuAddr = job_rtu.getString("rtuAddr");
         String protocol = job_rtu.getString("protocol");
-        String orgTag = job_rtu.getString("orgTag");
+        //String orgTag = job_rtu.getString("orgTag");
+        String orgTag = DataSourceContext.get();
         comSendUrl = env.getProperty(pro_mw + "." + orgTag + "." + key_mw);
 
         // 鑾峰彇鍔熻兘鐮�
@@ -244,11 +234,6 @@
         Long operator = po.getOperator();
         Long comId = idLongGenerator.generate();
 
-        // 鑾峰彇绯荤粺鍙傛暟
-        if(!setuped) {
-            setUp();
-        }
-
         // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚
         JSONObject job_rtu = getRtu(intakeId, null);
         if(job_rtu == null) {
@@ -256,7 +241,8 @@
         }
         String rtuAddr = job_rtu.getString("rtuAddr");
         String protocol = job_rtu.getString("protocol");
-        String orgTag = job_rtu.getString("orgTag");
+        //String orgTag = job_rtu.getString("orgTag");
+        String orgTag = DataSourceContext.get();
         comSendUrl = env.getProperty(pro_mw + "." + orgTag + "." + key_mw);
 
         // 鑾峰彇鍔熻兘鐮�
@@ -310,11 +296,6 @@
         Long operator = po.getOperator();
         Long comId = idLongGenerator.generate();
 
-        // 鑾峰彇绯荤粺鍙傛暟
-        if(!setuped) {
-            setUp();
-        }
-
         // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚
         JSONObject job_rtu = getRtu(intakeId, null);
         if(job_rtu == null) {
@@ -322,7 +303,8 @@
         }
         String rtuAddr = job_rtu.getString("rtuAddr");
         String protocol = job_rtu.getString("protocol");
-        String orgTag = job_rtu.getString("orgTag");
+        //String orgTag = job_rtu.getString("orgTag");
+        String orgTag = DataSourceContext.get();
         comSendUrl = env.getProperty(pro_mw + "." + orgTag + "." + key_mw);
 
         // 鑾峰彇鍔熻兘鐮�
@@ -375,11 +357,6 @@
         Long operator = po.getOperator();
         Long comId = idLongGenerator.generate();
 
-        // 鑾峰彇绯荤粺鍙傛暟
-        if(!setuped) {
-            setUp();
-        }
-
         // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚
         JSONObject job_rtu = getRtu(intakeId, null);
         if(job_rtu == null) {
@@ -387,7 +364,8 @@
         }
         String rtuAddr = job_rtu.getString("rtuAddr");
         String protocol = job_rtu.getString("protocol");
-        String orgTag = job_rtu.getString("orgTag");
+        //String orgTag = job_rtu.getString("orgTag");
+        String orgTag = DataSourceContext.get();
         comSendUrl = env.getProperty(pro_mw + "." + orgTag + "." + key_mw);
 
         // 鑾峰彇鍔熻兘鐮�

--
Gitblit v1.8.0