1

src/main/java/com/fdkankan/fusion/controller/CaseFusionController.java

@@ -65,10 +65,7 @@ public class CaseFusionController extends BaseController{
         if(param.getFusionNumId() == null){
             throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
         }
-        FusionNum fusionNum = fusionNumService.getById(param.getFusionNumId());
-        fusionMeterService.deleteByModelId(fusionNum.getModelId());
-        caseTagPointService.deleteByModelIds(Arrays.asList(fusionNum.getModelId()));
-        fusionNumService.removeById(param.getFusionNumId());
+        fusionNumService.deleteById(param.getFusionNumId());
         return ResultData.ok();
     }
 }

src/main/java/com/fdkankan/fusion/controller/ModelController.java

@@ -10,10 +10,7 @@ import com.fdkankan.fusion.entity.Model;
 import com.fdkankan.fusion.exception.BusinessException;
 import com.fdkankan.fusion.request.ModelPram;
 import com.fdkankan.fusion.request.ScenePram;
-import com.fdkankan.fusion.service.ICaseFusionService;
-import com.fdkankan.fusion.service.ICaseNumService;
-import com.fdkankan.fusion.service.IFusionMeterService;
-import com.fdkankan.fusion.service.IModelService;
+import com.fdkankan.fusion.service.*;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -35,7 +32,7 @@ public class ModelController extends BaseController{
     @Autowired
     IModelService modelService;
     @Autowired
-    IFusionMeterService fusionMeterService;
+    IFusionNumService fusionNumService;
 
 
     @PostMapping("/uploadObj")
@@ -71,7 +68,7 @@ public class ModelController extends BaseController{
             throw  new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
         }
         modelService.delete(param.getModelId());
-        fusionMeterService.deleteByModelId(param.getModelId());
+        fusionNumService.deleteByModelId(param.getModelId());
         return ResultData.ok();
     }
 

src/main/java/com/fdkankan/fusion/entity/CaseTagPoint.java

@@ -51,11 +51,9 @@ public class CaseTagPoint implements Serializable {
     @TableField("sort")
     private Integer sort;
 
-    @TableField("fusion_id")
-    private Integer fusionId;
 
-    @TableField("model_id")
-    private Integer modelId;
+    @TableField("fusion_num_id")
+    private Integer fusionNumId;
 
     @TableField("tb_status")
     @TableLogic

src/main/java/com/fdkankan/fusion/service/ICaseTagPointService.java

@@ -24,7 +24,7 @@ public interface ICaseTagPointService extends IService<CaseTagPoint> {
 
     Object allList(Integer tagId);
 
-    void deleteByModelIds(List<Integer> modelIds);
+    void deleteByFusionNumIds(List<Integer> modelIds);
 
     void deleteByTagIds(List<Integer> tagIds);
 }

src/main/java/com/fdkankan/fusion/service/IFusionMeterService.java

@@ -19,9 +19,9 @@ public interface IFusionMeterService extends IService<FusionMeter> {
 
     FusionMeter add(FusionMeter fusionMeter);
 
-    void deleteByModelId(Integer modelId);
-
     void deleteByFusionId(Integer fusionId);
 
     void deleteByCaseId(Integer caseId);
+
+    void deleteByFusionNumIds(List<Integer> fusionNunIds);
 }

src/main/java/com/fdkankan/fusion/service/IFusionNumService.java

@@ -32,4 +32,6 @@ public interface IFusionNumService extends IService<FusionNum> {
     void deleteByNumList(Integer caseId,List<String> updateNumList);
 
     void deleteByModelId(Integer modelId);
+
+    void deleteById(Integer fusionNumId);
 }

src/main/java/com/fdkankan/fusion/service/impl/CaseNumServiceImpl.java

@@ -227,12 +227,9 @@ public class CaseNumServiceImpl extends ServiceImpl<ICaseNumMapper, CaseNumEntit
         this.remove(wrapper);
         List<Model> modelList = modelService.getListByNum(Arrays.asList(num));
         if(modelList.size() >0){
-            List<Integer> modelIds = modelList.parallelStream().map(Model::getModelId).collect(Collectors.toList());
             for (Model model : modelList) {
                 fusionNumService.deleteByModelId(model.getModelId());
-                fusionMeterService.deleteByModelId(model.getModelId());
             }
-            caseTagPointService.deleteByModelIds(modelIds);
         }
         caseViewService.deleteByNum(num);
 

src/main/java/com/fdkankan/fusion/service/impl/CaseTagPointServiceImpl.java

@@ -83,10 +83,10 @@ public class CaseTagPointServiceImpl extends ServiceImpl<ICaseTagPointMapper, Ca
     }
 
     @Override
-    public void deleteByModelIds(List<Integer> modelIds) {
-        if(modelIds.size() >0){
+    public void deleteByFusionNumIds(List<Integer> FusionNumIds) {
+        if(FusionNumIds.size() >0){
             LambdaQueryWrapper<CaseTagPoint> wrapper = new LambdaQueryWrapper<>();
-            wrapper.in(CaseTagPoint::getModelId,modelIds);
+            wrapper.in(CaseTagPoint::getFusionNumId,FusionNumIds);
             this.remove(wrapper);
         }
     }

src/main/java/com/fdkankan/fusion/service/impl/FusionMeterServiceImpl.java

@@ -60,11 +60,14 @@ public class FusionMeterServiceImpl extends ServiceImpl<IFusionMeterMapper, Fusi
 
     }
 
+
     @Override
-    public void deleteByModelId(Integer modelId) {
-        LambdaQueryWrapper<FusionMeter> wrapper = new LambdaQueryWrapper<>();
-        wrapper.like(FusionMeter::getPosition,"\"modelId\":\""+modelId+"\"");
-        this.remove(wrapper);
+    public void deleteByFusionNumIds(List<Integer> fusionNunIds) {
+        for (Integer fusionNunId : fusionNunIds) {
+            LambdaQueryWrapper<FusionMeter> wrapper = new LambdaQueryWrapper<>();
+            wrapper.like(FusionMeter::getPosition,"\"fusionNunId\":\""+fusionNunId+"\"");
+            this.remove(wrapper);
+        }
     }
 
     @Override

src/main/java/com/fdkankan/fusion/service/impl/FusionNumServiceImpl.java

@@ -218,11 +218,9 @@ public class FusionNumServiceImpl extends ServiceImpl<IFusionNumMapper, FusionNu
                 deleteWr.in(FusionNum::getFusionId,fusionIds);
                 deleteWr.in(FusionNum::getModelId,modelIds);
                 List<FusionNum> list1 = this.list(deleteWr);
-                for (FusionNum fusionNum : list1) {
-                    fusionMeterService.deleteByModelId(fusionNum.getModelId());
-                }
-                List<Integer> models = list1.parallelStream().map(FusionNum::getModelId).collect(Collectors.toList());
-                caseTagPointService.deleteByModelIds(models);
+                List<Integer> fusionNumIds = list1.parallelStream().map(FusionNum::getFusionNumId).collect(Collectors.toList());
+                fusionMeterService.deleteByFusionNumIds(fusionNumIds);
+                caseTagPointService.deleteByFusionNumIds(fusionNumIds);
                 this.remove(deleteWr);
             }
         }
@@ -233,6 +231,20 @@ public class FusionNumServiceImpl extends ServiceImpl<IFusionNumMapper, FusionNu
     public void deleteByModelId(Integer modelId) {
         LambdaQueryWrapper<FusionNum> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(FusionNum::getModelId,modelId);
+        List<FusionNum> list = this.list(wrapper);
+        List<Integer> fusionNunIds = list.parallelStream().map(FusionNum::getFusionNumId).collect(Collectors.toList());
+        caseTagPointService.deleteByFusionNumIds(fusionNunIds);
+        fusionMeterService.deleteByFusionNumIds(fusionNunIds);
         this.remove(wrapper);
     }
+
+    @Override
+    public void deleteById(Integer fusionNumId) {
+        FusionNum fusionNum = this.getById(fusionNumId);
+        if(fusionNum!=null){
+            fusionMeterService.deleteByFusionNumIds(Arrays.asList(fusionNum.getFusionNumId()));
+            caseTagPointService.deleteByFusionNumIds(Arrays.asList(fusionNum.getFusionNumId()));
+            this.removeById(fusionNumId);
+        }
+    }
 }