同步删除基础数据

api-admin/src/main/java/com/glxp/sale/admin/constant/SocketMsgType.java

@@ -4,4 +4,10 @@ public interface SocketMsgType {
 
 
     String DL_ALL_DATA = "DL_ALL_DATA";
+    String BASIC_DATA_DELETE = "BASIC_DATA_DELETE";
+    String BASIC_MANAGE_DELETE = "BASIC_MANAGE_DELETE";
+
+    String BASIC_CORP_MAINTAIN_DELETE = "BASIC_CORP_MAINTAIN_DELETE"; //供应商字典
+
+    String BASIC_BUSINESS_TYPE_DELETE = "BASIC_BUSINESS_TYPE_DELETE"; //单据类型
 }

api-admin/src/main/java/com/glxp/sale/admin/entity/sync/SocketMsgEntity.java

@@ -5,6 +5,8 @@ import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.util.Objects;
+
 /**
  * websocket 消息体
  */
@@ -14,6 +16,6 @@ import lombok.NoArgsConstructor;
 @NoArgsConstructor
 public class SocketMsgEntity {
     private String type;
-    private String content;
+    private Object content;
     private String remark;
 }

api-admin/src/main/java/com/glxp/sale/admin/socket/client/SpsWebSocketClient.java

@@ -49,12 +49,21 @@ public class SpsWebSocketClient extends WebSocketClient {
     }
 
     @Override
-    public void onMessage(String s) {
+    public synchronized void onMessage(String s) {
         log.info("收到消息：" + s);
         //收到更新下载数据则赋值由外部处理，多个任务只处理一次避免重复处理
         if (s.contains(SocketMsgType.DL_ALL_DATA)) {
             this.excptMessage = s;
-        } else {
+        } else if(s.contains(SocketMsgType.BASIC_DATA_DELETE)) {
+           this.excptMessage = s;
+        }else if(s.contains(SocketMsgType.BASIC_MANAGE_DELETE)){
+            this.excptMessage = s;
+        }else if(s.contains(SocketMsgType.BASIC_CORP_MAINTAIN_DELETE)){
+            this.excptMessage = s;
+        }else if(s.contains(SocketMsgType.BASIC_BUSINESS_TYPE_DELETE)){
+            this.excptMessage = s;
+        }
+        else {
                 //通知类消息则需转发
                 socketMsgService.sendNoticeMsg(s);
         }

api-admin/src/main/java/com/glxp/sale/admin/socket/client/WebSocketComponent.java

@@ -2,6 +2,7 @@ package com.glxp.sale.admin.socket.client;
 
 import com.glxp.sale.admin.constant.SocketMsgType;
 import com.glxp.sale.admin.service.param.SystemParamConfigService;
+import com.glxp.sale.admin.socket.server.SpsSyncWebSocket;
 import com.glxp.sale.admin.thread.HeartTask;
 import com.glxp.sale.admin.thread.HeartTaskService;
 import lombok.extern.slf4j.Slf4j;
@@ -26,6 +27,8 @@ public class WebSocketComponent implements CommandLineRunner {
     HeartTaskService heartTaskService;
     @Resource
     SocketMsgService socketMsgService;
+    @Resource
+    SpsSyncWebSocket spsSyncWebSocket;
 
     @Override
     public void run(String... args) throws Exception {
@@ -47,7 +50,16 @@ public class WebSocketComponent implements CommandLineRunner {
                 }
                 if (message.contains(SocketMsgType.DL_ALL_DATA)) {
                     heartTaskService.dlAllData();
+                } else if(message.contains(SocketMsgType.BASIC_DATA_DELETE)){
+                    spsSyncWebSocket.sendMessage(message,"2:"+socketToken);
+                }else if(message.contains(SocketMsgType.BASIC_MANAGE_DELETE)){
+                    spsSyncWebSocket.sendMessage(message,"2:"+socketToken);
+                }else if(message.contains(SocketMsgType.BASIC_CORP_MAINTAIN_DELETE)){
+                    spsSyncWebSocket.sendMessage(message,"2:"+socketToken);
+                }else if(message.contains(SocketMsgType.BASIC_BUSINESS_TYPE_DELETE)){
+                    spsSyncWebSocket.sendMessage(message,"2:"+socketToken);
                 }
+
                 //打印服务端返回的数据
                 log.info("成功获取数据：" + message);
             }