1/10 同步删除1.0

src/main/java/com/glxp/api/constant/SocketMsgType.java

@@ -15,6 +15,8 @@ public interface SocketMsgType {
 
     String BASIC_DATA_DELETE = "BASIC_DATA_DELETE"; //耗材字典删除
 
+    String PRODUCT_LEVEL_DELETE = "PRODUCT_LEVEL_DELETE"; //产品层级删除
+
     String BASIC_MANAGE_DELETE = "BASIC_MANAGE_DELETE"; //入援物资维护
 
     String BASIC_CORP_MAINTAIN_DELETE = "BASIC_CORP_MAINTAIN_DELETE"; //供应商字典

src/main/java/com/glxp/api/constant/SyncDelType.java

@@ -7,6 +7,7 @@ public interface SyncDelType {
      */
     String BASIC_MAINTAIN = "BASIC_MAINTAIN";       //耗材字典
 
+
     String BASIC_MANAGE = "BASIC_MANAGE";  //供应商器械信息
 
     String BASIC_CORP_MAINTAIN = "BASIC_CORP_MAINTAIN"; //往来信息维护

src/main/java/com/glxp/api/controller/basic/UdiContrastController.java

@@ -9,21 +9,22 @@ import com.glxp.api.annotation.AuthRuleAnnotation;
 import com.glxp.api.annotation.Log;
 import com.glxp.api.common.res.BaseResponse;
 import com.glxp.api.common.util.ResultVOUtils;
-import com.glxp.api.constant.AsyncDiDlHelper;
-import com.glxp.api.constant.BusinessType;
-import com.glxp.api.constant.ConstantStatus;
+import com.glxp.api.constant.*;
 import com.glxp.api.controller.BaseController;
+import com.glxp.api.controller.sync.SpsSyncWebSocket;
 import com.glxp.api.dto.BasicProductsCreateDto;
 import com.glxp.api.entity.basic.CompanyProductRelevanceEntity;
 import com.glxp.api.entity.basic.ProductInfoEntity;
 import com.glxp.api.entity.basic.UdiProductEntity;
 import com.glxp.api.entity.basic.UdiRelevanceEntity;
+import com.glxp.api.entity.sync.SocketMsgEntity;
 import com.glxp.api.entity.system.CompanyEntity;
 import com.glxp.api.entity.thrsys.CodeRel;
 import com.glxp.api.entity.thrsys.ThrProductsEntity;
 import com.glxp.api.entity.thrsys.ThrSystemEntity;
 import com.glxp.api.http.NmpaUdiClient;
 import com.glxp.api.req.basic.*;
+import com.glxp.api.req.system.DeleteRequest;
 import com.glxp.api.req.thrsys.FilterBasicThirdSysRequest;
 import com.glxp.api.req.thrsys.ThirdAliDrugRequest;
 import com.glxp.api.res.DiLevelResponse;
@@ -54,7 +55,7 @@ import java.util.List;
  * 耗材字典关联相关接口
  */
 @RestController
-public class UdiContrastController {
+public class UdiContrastController extends BaseController{
 
     @Resource
     NmpaUdiClient udiDlHttpClient;
@@ -79,6 +80,9 @@ public class UdiContrastController {
     @Resource
     IoOrderDetailCodeService orderDetailCodeService;
 
+    @Resource
+    SpsSyncWebSocket webSocketServer;
+
     /**
      * 耗材字典添加
      */
@@ -414,6 +418,16 @@ public class UdiContrastController {
             codeRel.setDrugCode(addProductRequest.getNameCode());
             udiContrastService.deleteRelCode(codeRel);
         }
+        DeleteRequest deleteRequest = new DeleteRequest();
+        deleteRequest.setNameCode(addProductRequest.getNameCode());
+        BasicDataRequest basicDataRequest = new BasicDataRequest();
+        basicDataRequest.setDeleteRequest(deleteRequest);
+        Long userId = getUserId();
+        basicDataRequest.setKey(SyncDelType.BASIC_MAINTAIN);
+        //推送
+        BasicDataRequest request = webSocketServer.insert(basicDataRequest, userId + "");
+        request.setDeleteRequest(deleteRequest);
+        webSocketServer.sendMessage(SocketMsgEntity.builder().type(SocketMsgType.PRODUCT_LEVEL_DELETE).content(request).remark("产品层级删除").build(), null);
         return ResultVOUtils.success("删除成功！");
     }
 

src/main/java/com/glxp/api/req/system/DeleteRequest.java

@@ -13,4 +13,6 @@ public class DeleteRequest {
     List<String> billNos;
     String invoiceEncode;
     String userId;
+
+    private String nameCode;
 }