dev

src/main/java/com/its/op/entity/its/scrs/TbScSgnlCtlr.java

@@ -270,13 +270,13 @@ public class TbScSgnlCtlr implements Serializable {
             dto.setCycl(this.stts.getCycl());
             dto.setOfst(this.stts.getOfst());
             dto.setAring1phas(this.stts.getAring1phas());
-            dto.setAring2phas(this.stts.getAring1phas());
-            dto.setAring3phas(this.stts.getAring2phas());
-            dto.setAring4phas(this.stts.getAring3phas());
-            dto.setAring5phas(this.stts.getAring4phas());
-            dto.setAring6phas(this.stts.getAring5phas());
-            dto.setAring7phas(this.stts.getAring6phas());
-            dto.setAring8phas(this.stts.getAring7phas());
+            dto.setAring2phas(this.stts.getAring2phas());
+            dto.setAring3phas(this.stts.getAring3phas());
+            dto.setAring4phas(this.stts.getAring4phas());
+            dto.setAring5phas(this.stts.getAring5phas());
+            dto.setAring6phas(this.stts.getAring6phas());
+            dto.setAring7phas(this.stts.getAring7phas());
+            dto.setAring8phas(this.stts.getAring8phas());
             dto.setBring1phas(this.stts.getBring1phas());
             dto.setBring2phas(this.stts.getBring2phas());
             dto.setBring3phas(this.stts.getBring3phas());

src/main/java/com/its/op/websocket/ItsWebSocketSessionManager.java

@@ -60,16 +60,16 @@ public class ItsWebSocketSessionManager {
     }
 
     public void sendBroadcastMessage(String command, TextMessage message) {
-        this.sessionMap.forEach((key, value) -> {
-            log.info("{}, {}, {}", command, message, key);
-            value.sendMessage(command, message);
+        this.sessionMap.forEach((key, session) -> {
+            //log.info("{}, {}, {}", command, message, key);
+            session.sendMessage(command, message);
         });
     }
 
     public void sendBroadcastSigPhaseMessage(String command, TextMessage message) {
-        this.sessionMap.forEach((key, value) -> {
-            log.info("{}, {}, {}", command, message, key);
-            value.sendMessage(command, message);
+        this.sessionMap.forEach((key, session) -> {
+            //log.info("{}, {}, {}", command, message, key);
+            session.sendMessage(command, message);
         });
     }
 }