取消协作移除项目场景

src/main/java/com/fdkankan/manage_jp/mq/consumer/LaserSceneGpsConsumer.java

@@ -3,6 +3,7 @@ package com.fdkankan.manage_jp.mq.consumer;
 import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.manage_jp.mq.vo.LaserSceneGpsVo;
 import com.fdkankan.manage_jp.mq.vo.LaserSceneTitleVo;
+import com.fdkankan.manage_jp.service.IProjectNumService;
 import com.fdkankan.manage_jp.service.IProjectSceneGpsService;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
@@ -25,6 +26,8 @@ public class LaserSceneGpsConsumer {
 
     @Autowired
     IProjectSceneGpsService projectSceneGpsService;
+    @Autowired
+    IProjectNumService projectNumService;
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.laser.update-scene.location:save-scene-location}")
     )
@@ -42,6 +45,7 @@ public class LaserSceneGpsConsumer {
                 projectSceneGpsService.updateGps(vo.getNum(),lat,lon,2);
             }
             if(vo != null && vo.getStatus() == 0){
+                projectNumService.delNum(vo.getNum());
                 projectSceneGpsService.updateGps(vo.getNum(),0);
             }
 

src/main/java/com/fdkankan/manage_jp/service/IProjectNumService.java

@@ -22,4 +22,6 @@ public interface IProjectNumService extends IService<ProjectNum> {
     void addNumList(Integer projectId, List<String> addNumList);
 
     void delByProjectId(Integer projectId);
+
+    void delNum(String num);
 }

src/main/java/com/fdkankan/manage_jp/service/impl/ProjectNumServiceImpl.java

@@ -39,6 +39,13 @@ public class ProjectNumServiceImpl extends ServiceImpl<IProjectNumMapper, Projec
     }
 
     @Override
+    public void delNum(String num) {
+        LambdaQueryWrapper<ProjectNum> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ProjectNum::getNum,num);
+        this.remove(wrapper);
+    }
+
+    @Override
     public void delNumList(Integer projectId, List<String> delNumList) {
         if(delNumList.isEmpty()){
             return;