es

src/main/java/com/sooka/sponest/middleware/data/consumer/DataListener.java

@@ -389,23 +389,7 @@ public class DataListener {
                 break;
             case DocumentNameConstants.ENVIRONMENT_BIGGAS1:// 大气监测点管理
                 if (BusinessType.DELETE.equals(dataBO.getType())) {
-                    SpringUtils.getBean(CenterdataTEnvironmentBiggasDao.class).deleteAllById(result);
-                } else {
-                    EnvironmentBiggas environmentBiggas = JSON.parseObject(dataBO.getModelStr(), EnvironmentBiggas.class);
-                    SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).save(environmentBiggas);
-                }
-                break;
-            case DocumentNameConstants.ENVIRONMENT_BIGGAS2:// 水质监测点管理
-                if (BusinessType.DELETE.equals(dataBO.getType())) {
-                    SpringUtils.getBean(CenterdataTEnvironmentBiggas2Dao.class).deleteAllById(result);
-                } else {
-                    EnvironmentBiggas environmentBiggas = JSON.parseObject(dataBO.getModelStr(), EnvironmentBiggas.class);
-                    SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).save(environmentBiggas);
-                }
-                break;
-            case DocumentNameConstants.ENVIRONMENT_BIGGAS3:// 污染源监测点管理
-                if (BusinessType.DELETE.equals(dataBO.getType())) {
-                    SpringUtils.getBean(CenterdataTEnvironmentBiggas3Dao.class).deleteAllById(result);
+                    SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).deleteAllById(result);
                 } else {
                     EnvironmentBiggas environmentBiggas = JSON.parseObject(dataBO.getModelStr(), EnvironmentBiggas.class);
                     SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).save(environmentBiggas);

src/main/java/com/sooka/sponest/middleware/data/digitalenvironment/service/ICenterdataTEnvironmentBiggasService.java

@@ -2,6 +2,8 @@ package com.sooka.sponest.middleware.data.digitalenvironment.service;
 
 import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentBiggas;
 
+import java.util.List;
+
 /**
  * @author zhaozhan
  * @date 2023/7/21
@@ -9,4 +11,6 @@ import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentBiggas;
 public interface ICenterdataTEnvironmentBiggasService {
 
     void save(EnvironmentBiggas environmentBiggas);
+
+    void deleteAllById(List<String> ids);
 }

src/main/java/com/sooka/sponest/middleware/data/digitalenvironment/service/impl/CenterdataTEnvironmentBiggasServiceImpl.java

@@ -14,6 +14,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.elasticsearch.core.geo.GeoPoint;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * @author zhaozhan
  * @date 2023/7/21
@@ -50,4 +52,11 @@ public class CenterdataTEnvironmentBiggasServiceImpl implements ICenterdataTEnvi
                 break;
         }
     }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTEnvironmentBiggasDao.deleteAllById(ids);
+        centerdataTEnvironmentBiggas2Dao.deleteAllById(ids);
+        centerdataTEnvironmentBiggas3Dao.deleteAllById(ids);
+    }
 }