websocket日志

single-manager/src/main/java/com/mortals/xhx/common/utils/CustomerWebSocketClient.java

@@ -6,6 +6,7 @@ import com.mortals.xhx.module.apply.model.MatterApplyDatumQuery;
 import com.mortals.xhx.module.apply.model.MatterApplyEntity;
 import com.mortals.xhx.module.apply.service.MatterApplyDatumService;
 import com.mortals.xhx.module.apply.service.MatterApplyService;
+import lombok.extern.slf4j.Slf4j;
 import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.handshake.ServerHandshake;
 import java.net.URI;
@@ -14,6 +15,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+@Slf4j
 public class CustomerWebSocketClient extends WebSocketClient {
 
     private MatterApplyDatumService matterApplyDatumService;
@@ -65,20 +67,20 @@ public class CustomerWebSocketClient extends WebSocketClient {
 
     @Override
     public void onOpen(ServerHandshake handshake) {
-        System.out.println("连接已建立:");
+        log.info("连接已建立:");
         currentTime1 = System.currentTimeMillis();
     }
 
     @Override
     public void onMessage(String message) {
         this.close();
-        System.out.println("收到消息: " + message);
-        System.out.println("耗时间:"+(System.currentTimeMillis()-currentTime1));
-        System.out.println("ApplyDatumId: " + ApplyDatumId);
+        log.info("收到消息: " + message);
+        //log.info("耗时间:"+(System.currentTimeMillis()-currentTime1));
+        //System.out.println("ApplyDatumId: " + ApplyDatumId);
         JSONObject jsonObject = JSONObject.parseObject(message);
-        System.out.println("serial_number: " + jsonObject.getLongValue("serial_number"));
+        log.info("serial_number: " + jsonObject.getLongValue("serial_number"));
         Long serial_number = jsonObject.getLongValue("serial_number");
-        System.out.println("耗时:"+(System.currentTimeMillis()-currentTime)+"毫秒");
+        log.info("耗时:"+(System.currentTimeMillis()-currentTime)+"毫秒");
         if(null != matterApplyDatumService && null != matterApplyService){
             MatterApplyDatumEntity datumEntity = matterApplyDatumService.get(serial_number);
             boolean apply = true;
@@ -141,7 +143,7 @@ public class CustomerWebSocketClient extends WebSocketClient {
 
     @Override
     public void onClose(int code, String reason, boolean remote) {
-        System.out.println("连接关闭: " + reason);
+        log.info("连接关闭: " + reason);
     }
 
     @Override

single-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/SingleApplyreviewService.java

@@ -98,7 +98,7 @@ public class SingleApplyreviewService implements IApplicationStartedService {
                                 if(webSocketClient.isOpen()) {
                                     webSocketClient.setCurrentTime(System.currentTimeMillis());
                                     webSocketClient.send(JSONObject.toJSONString(processUserImage));
-                                    System.out.println("发送消息: " + JSONObject.toJSONString(processUserImage));
+                                    log.info("发送消息: " + JSONObject.toJSONString(processUserImage));
                                 }
                                 try {
                                     Thread.sleep(15000);