init

pom.xml

@@ -0,0 +1,125 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>ruoyi-modules</artifactId>
+        <groupId>com.ruoyi</groupId>
+        <version>3.4.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.sooka.onest</groupId>
+    <artifactId>sooka-middleware</artifactId>
+
+    <dependencies>
+
+        <!-- SpringCloud Alibaba Nacos -->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
+        </dependency>
+
+        <!-- SpringCloud Alibaba Nacos Config -->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
+        </dependency>
+
+        <!-- SpringCloud Alibaba Sentinel -->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
+        </dependency>
+
+        <!-- SpringBoot Actuator -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+
+        <!-- Swagger UI -->
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger-ui</artifactId>
+            <version>${swagger.fox.version}</version>
+        </dependency>
+
+        <!-- Mysql Connector -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+
+        <!-- RuoYi Common DataSource -->
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>sooka-sponest-common-datasource</artifactId>
+        </dependency>
+
+        <!-- RuoYi Common DataScope -->
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>sooka-sponest-common-datascope</artifactId>
+        </dependency>
+
+        <!-- RuoYi Common Log -->
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>sooka-sponest-common-log</artifactId>
+        </dependency>
+
+        <!-- RuoYi Common Swagger -->
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>sooka-sponest-common-swagger</artifactId>
+        </dependency>
+
+        <!-- es springboot连接es-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
+        </dependency>
+
+        <!--rabbitmq参数类型用json格式-->
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
+
+        <!--  RabbitMQ的Stream实现  -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>sooka-sponest-api-data</artifactId>
+            <version>3.4.0</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.1.5.RELEASE</version>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>

src/main/java/com/sooka/sponest/middleware/SookaMiddleWareApplication.java

@@ -0,0 +1,29 @@
+package com.sooka.sponest.middleware;
+
+import com.ruoyi.common.security.annotation.EnableCustomConfig;
+import com.ruoyi.common.security.annotation.EnableRyFeignClients;
+import com.ruoyi.common.swagger.annotation.EnableCustomSwagger2;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
+
+@EnableCustomConfig
+@EnableCustomSwagger2
+@EnableRyFeignClients
+@EnableElasticsearchRepositories
+@MapperScan("com.sooka.sponest.middleware.**.dao")
+@SpringBootApplication
+public class SookaMiddleWareApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(SookaMiddleWareApplication.class, args);
+        System.out.println("(♥◠‿◠)ﾉﾞ  首佳科技 中间件 启动成功   ლ(´ڡ`ლ)ﾞ  \n" +
+                "  __________   ____ |  | _______          ____________   ____   ____   ____   _______/  |_\n" +
+                " /  ___/  _ \\ /  _ \\|  |/ /\\__  \\        /  ___/\\____ \\ /  _ \\ /    \\_/ __ \\ /  ___/\\   __\\\n" +
+                " \\___ (  <_> |  <_> )    <  / __ \\_      \\___ \\ |  |_> >  <_> )   |  \\  ___/ \\___ \\  |  |\n" +
+                "/____  >____/ \\____/|__|_ \\(____  /     /____  >|   __/ \\____/|___|  /\\___  >____  > |__|\n" +
+                "     \\/                  \\/     \\/           \\/ |__|               \\/     \\/     \\/\n"
+        );
+    }
+}

src/main/java/com/sooka/sponest/middleware/base/config/ElasticsearchClientConfig.java

@@ -0,0 +1,125 @@
+package com.sooka.sponest.middleware.base.config;
+
+import org.apache.http.HttpHost;
+import org.apache.http.auth.AuthScope;
+import org.apache.http.auth.UsernamePasswordCredentials;
+import org.apache.http.client.CredentialsProvider;
+import org.apache.http.impl.client.BasicCredentialsProvider;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestClientBuilder;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.Arrays;
+import java.util.Objects;
+
+/**
+ * @Auther: mjq
+ * @Date: 2023/7/5 - 07 - 05 - 22:52
+ * @Description: com.sooka.sponest.rabbitmq.config
+ * @version: 1.0
+ */
+@Configuration
+public class ElasticsearchClientConfig {
+
+    private static final int ADDRESS_LENGTH = 2;
+
+    /**
+     * 协议
+     */
+    @Value("${spring.elasticsearch.scheme:http}")
+    private String scheme;
+
+    /**
+     * 集群地址，如果有多个用,隔开
+     */
+    @Value("${spring.elasticsearch.address}")
+    private String address;
+
+    /**
+     * 获取连接的超时时间
+     */
+    @Value("${spring.elasticsearch.connectionRequestTimeout}")
+    private Integer connectionRequestTimeout;
+
+    /**
+     * Socket 连接超时时间
+     */
+    @Value("${spring.elasticsearch.socketTimeout}")
+    private Integer socketTimeout;
+
+    /**
+     * 连接超时时间
+     */
+    @Value("${spring.elasticsearch.connectTimeout}")
+    private Integer connectTimeout;
+
+    /**
+     * 最大连接数
+     */
+    @Value("${spring.elasticsearch.maxConnectNum}")
+    private Integer maxConnectNum;
+
+    /**
+     * 最大路由连接数
+     */
+    @Value("${spring.elasticsearch.maxConnectPerRoute}")
+    private Integer maxConnectPerRoute;
+
+    @Value("${spring.elasticsearch.username}")
+    private String username;
+
+    @Value("${spring.elasticsearch.password}")
+    private String password;
+
+    @Bean
+    public RestClientBuilder restClientBuilder() {
+        HttpHost[] hosts = Arrays.stream(address.split(","))
+                .map(this::makeHttpHost)
+                .filter(Objects::nonNull)
+                .toArray(HttpHost[]::new);
+        RestClientBuilder restClientBuilder = RestClient.builder(hosts);
+        // 异步连接数配置
+        restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> {
+            httpClientBuilder.setMaxConnTotal(maxConnectNum);
+            httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);
+            return httpClientBuilder;
+        });
+        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
+        restClientBuilder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider));
+        // 异步连接延时配置
+        restClientBuilder.setRequestConfigCallback(requestConfigBuilder -> {
+            requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeout);
+            requestConfigBuilder.setSocketTimeout(socketTimeout);
+            requestConfigBuilder.setConnectTimeout(connectTimeout);
+            return requestConfigBuilder;
+        });
+        return restClientBuilder;
+    }
+
+    @Bean(name = "restHighLevelClient")
+    public RestHighLevelClient restHighLevelClient(@Autowired RestClientBuilder restClientBuilder) {
+        return new RestHighLevelClient(restClientBuilder);
+    }
+
+    /**
+     * 根据配置创建HttpHost
+     *
+     * @param s
+     * @return
+     */
+    private HttpHost makeHttpHost(String s) {
+        String[] addr = s.split(":");
+        if (addr.length == ADDRESS_LENGTH) {
+            String ip = addr[0];
+            int port = Integer.parseInt(addr[1]);
+            return new HttpHost(ip, port, scheme);
+        } else {
+            return null;
+        }
+    }
+}

src/main/java/com/sooka/sponest/middleware/base/config/JacksonConfig.java

@@ -0,0 +1,21 @@
+package com.sooka.sponest.middleware.base.config;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import org.elasticsearch.search.aggregations.bucket.terms.ParsedStringTerms;
+import org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class JacksonConfig {
+
+    @Bean
+    public Jackson2ObjectMapperBuilderCustomizer changeKeyAsNumber() {
+        return jacksonObjectMapperBuilder -> jacksonObjectMapperBuilder.mixIn(ParsedStringTerms.ParsedBucket.class, MixIn.class);
+    }
+
+    interface MixIn {
+        @JsonIgnore
+        Number getKeyAsNumber();
+    }
+}

src/main/java/com/sooka/sponest/middleware/base/config/ParamConfig.java

@@ -0,0 +1,41 @@
+package com.sooka.sponest.middleware.base.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ParamConfig {
+
+    private static String dataDB;
+
+    private static String monitorDB;
+
+    private static String systemDB;
+
+    public static String getDataDB() {
+        return dataDB;
+    }
+
+    @Value("${sooka.database.data}")
+    public void setDataDB(String dataDB) {
+        ParamConfig.dataDB = dataDB;
+    }
+
+    public static String getMonitorDB() {
+        return monitorDB;
+    }
+
+    @Value("${sooka.database.monitor}")
+    public void setMonitorDB(String monitorDB) {
+        ParamConfig.monitorDB = monitorDB;
+    }
+
+    public static String getSystemDB() {
+        return systemDB;
+    }
+
+    @Value("${sooka.database.system}")
+    public void setSystemDB(String systemDB) {
+        ParamConfig.systemDB = systemDB;
+    }
+}

src/main/java/com/sooka/sponest/middleware/base/controller/BaseESController.java

@@ -0,0 +1,143 @@
+package com.sooka.sponest.middleware.base.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.core.constant.HttpStatus;
+import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.common.core.web.page.TableDataInfo;
+import com.ruoyi.common.datascope.base.domain.BaseBusinessEntity;
+import com.sooka.sponest.middleware.base.entity.bo.BaseESBO;
+import com.sooka.sponest.middleware.base.entity.vo.CameraVO;
+import com.sooka.sponest.middleware.base.service.IBaseESService;
+import org.elasticsearch.action.search.SearchRequest;
+import org.elasticsearch.action.search.SearchResponse;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.elasticsearch.common.geo.GeoDistance;
+import org.elasticsearch.common.geo.GeoPoint;
+import org.elasticsearch.common.unit.DistanceUnit;
+import org.elasticsearch.index.query.BoolQueryBuilder;
+import org.elasticsearch.index.query.QueryBuilders;
+import org.elasticsearch.search.SearchHit;
+import org.elasticsearch.search.builder.SearchSourceBuilder;
+import org.elasticsearch.search.sort.SortBuilder;
+import org.elasticsearch.search.sort.SortBuilders;
+import org.elasticsearch.search.sort.SortOrder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.io.IOException;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+public class BaseESController {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    private IBaseESService baseESService;
+
+    static final String LOCATION = "location";
+
+    public void dataPower(BoolQueryBuilder queryBuilder, String field, Long deptId) {
+        List<Long> deptIds = null;
+        if (StringUtils.isNotNull(deptId)) {
+            deptIds = baseESService.getDeptAndChildIds(deptId);
+        } else {
+            deptIds = baseESService.getDeptIds(new BaseBusinessEntity());
+        }
+        if (StringUtils.isNotEmpty(deptIds)) {
+            BoolQueryBuilder queryBuilderOr = QueryBuilders.boolQuery();
+            deptIds.forEach(item -> queryBuilderOr.should().add(QueryBuilders.termQuery(field, item)));
+            queryBuilder.must(queryBuilderOr);
+        }
+    }
+
+    public List<CameraVO> getCameraList(List<JSONObject> pointList) {
+        return baseESService.getCameraList(pointList);
+    }
+
+    public List<String> getPictureList(String busId) {
+        return baseESService.getPictureList(busId);
+    }
+
+    @Autowired
+    private RestHighLevelClient restHighLevelClient;
+
+    /**
+     * ES全文搜索
+     *
+     * @param esbo
+     * @param sourceBuilder
+     * @return
+     */
+    public SearchResponse getResponse(BaseESBO esbo, SearchSourceBuilder sourceBuilder) {
+        sourceBuilder.trackTotalHits(true);// 返回所有命中，默认返回10000条
+        // 分页查询
+        if (StringUtils.isNotNull(esbo.getPageNum()) && StringUtils.isNotNull(esbo.getPageSize())) {
+            sourceBuilder.from((esbo.getPageNum() - 1) * esbo.getPageSize()).size(esbo.getPageSize());
+        }
+        // 排序，默认按创建时间降序
+        SortBuilder sortBuilder = null;
+        if (StringUtils.isBlank(esbo.getSortFiled())) {
+            sortBuilder = SortBuilders.fieldSort("createTime").order(SortOrder.DESC);
+        } else if (LOCATION.equals(esbo.getSortFiled())) {
+            // 按照距离排序
+            sortBuilder = SortBuilders.geoDistanceSort(LOCATION,
+                    new GeoPoint(Double.parseDouble(esbo.getLatitude()), Double.parseDouble(esbo.getLongitude())))
+                    .order(esbo.getSortOrder()).unit(DistanceUnit.METERS).geoDistance(GeoDistance.PLANE);
+        } else {
+            sortBuilder = SortBuilders.fieldSort(esbo.getSortFiled()).order(esbo.getSortOrder());
+        }
+        sourceBuilder.sort(sortBuilder);
+        // 包含、不包含
+        if (StringUtils.isNotEmpty(esbo.getIncludeFields()) || StringUtils.isNotEmpty(esbo.getExcludeFields())) {
+            sourceBuilder.fetchSource(esbo.getIncludeFields(), esbo.getExcludeFields());
+        }
+        // 根据索引名创建搜索请求
+        SearchRequest request = new SearchRequest(esbo.getIndexNames());
+        request.source(sourceBuilder);// 将构建查询放进请求中
+        SearchResponse response = null;
+        try {
+            // 获取请求的响应数据
+            response = restHighLevelClient.search(request, RequestOptions.DEFAULT);
+            logger.info("花费的时长：{}", response.getTook());
+        } catch (IOException e) {
+            logger.error(e.getMessage());
+        }
+        return response;
+    }
+
+    public List<JSONObject> getDataList(BaseESBO esbo, SearchResponse response) {
+        if (StringUtils.isNull(response)) {
+            return new ArrayList<>();
+        }
+        // 解析响应
+        SearchHit[] searchHits = response.getHits().getHits();// 获取命中
+        List<JSONObject> resultList = new ArrayList<>();
+        for (SearchHit hit : searchHits) {
+            String json = hit.getSourceAsString();// 获取文档source
+            JSONObject jsonObject = JSONObject.parseObject(json);// 反序列化
+            jsonObject.put("indexName", hit.getIndex());
+            if (LOCATION.equals(esbo.getSortFiled())) {
+                BigDecimal geoDis = new BigDecimal(hit.getSortValues()[0].toString());
+                jsonObject.put("distance", geoDis.setScale(0, BigDecimal.ROUND_HALF_DOWN));
+            }
+            resultList.add(jsonObject);
+        }
+        return resultList;
+    }
+
+    public TableDataInfo getDataTable(BaseESBO esbo, SearchResponse response) {
+        if (StringUtils.isNull(response)) {
+            return new TableDataInfo();
+        }
+        TableDataInfo rspData = new TableDataInfo();
+        rspData.setTotal(response.getHits().getTotalHits().value);
+        rspData.setRows(getDataList(esbo, response));
+        rspData.setCode(HttpStatus.SUCCESS);
+        rspData.setMsg("查询成功");
+        return rspData;
+    }
+}

src/main/java/com/sooka/sponest/middleware/base/dao/BaseMapper.java

@@ -0,0 +1,24 @@
+package com.sooka.sponest.middleware.base.dao;
+
+import com.ruoyi.common.datascope.base.domain.BaseBusinessEntity;
+import com.sooka.sponest.middleware.base.entity.vo.CameraVO;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * @Auther: mjq
+ * @Date: 2023/7/5 - 07 - 05 - 23:13
+ * @Description: com.sooka.sponest.rabbitmq.base.bean.service.Impl
+ * @version: 1.0
+ */
+public interface BaseMapper {
+
+    List<Long> getDeptIds(BaseBusinessEntity baseBusinessEntity);
+
+    List<Long> getDeptAndChildIds(@Param("systemDB") String systemDB, @Param("deptId") Long deptId);
+
+    List<CameraVO> getCameraList(@Param("monitorDB") String monitorDB, @Param("ids") List<String> ids);
+
+    List<String> getPictureList(@Param("dataDB") String dataDB, @Param("systemDB") String systemDB, @Param("busId") String busId);
+}

src/main/java/com/sooka/sponest/middleware/base/entity/bo/BaseESBO.java

@@ -0,0 +1,34 @@
+package com.sooka.sponest.middleware.base.entity.bo;
+
+import lombok.Data;
+import org.elasticsearch.search.sort.SortOrder;
+
+/**
+ * @Auther: lyq
+ * @Date: 2023/7/25
+ * @Description: com.sooka.sponest.middleware.base.bo
+ * @version: 1.0
+ */
+@Data
+public class BaseESBO {
+
+    private String[] indexNames;
+
+    private String[] includeFields = {};
+
+    private String[] excludeFields = {};
+
+    private Integer pageNum;
+
+    private Integer pageSize;
+
+    private String sortFiled;
+
+    private SortOrder sortOrder;
+
+    private String latitude;
+
+    private String longitude;
+
+    private Long radius;// 距离，单位：米
+}

src/main/java/com/sooka/sponest/middleware/base/entity/vo/CameraVO.java

@@ -0,0 +1,52 @@
+package com.sooka.sponest.middleware.base.entity.vo;
+
+import lombok.Data;
+
+/**
+ * 摄像头对象 centerdata_t_camera
+ *
+ * @author ruoyi
+ * @date 2022-05-13
+ */
+@Data
+public class CameraVO {
+
+    /**
+     * 摄像头id
+     */
+    private String cameraId;
+
+    /**
+     * 摄像头编码
+     */
+    private String cameraCode;
+    /**
+     * 摄像头名称
+     */
+    private String cameraName;
+
+    /**
+     * 摄像头厂家(海康、大华)
+     */
+    private String cameraFactory;
+
+    /**
+     * 经度
+     */
+    private String longitude;
+
+    /**
+     * 维度
+     */
+    private String latitude;
+
+    /**
+     * 半径
+     */
+    private String cameraRadius;
+
+    /**
+     * 摄像头类型
+     */
+    private String cameraType;
+}

src/main/java/com/sooka/sponest/middleware/base/service/IBaseESService.java

@@ -0,0 +1,24 @@
+package com.sooka.sponest.middleware.base.service;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.datascope.base.domain.BaseBusinessEntity;
+import com.sooka.sponest.middleware.base.entity.vo.CameraVO;
+
+import java.util.List;
+
+/**
+ * @Auther: mjq
+ * @Date: 2023/7/5 - 07 - 05 - 23:13
+ * @Description: com.sooka.sponest.rabbitmq.base.bean.service.Impl
+ * @version: 1.0
+ */
+public interface IBaseESService {
+
+    List<Long> getDeptIds(BaseBusinessEntity baseBusinessEntity);
+
+    List<Long> getDeptAndChildIds(Long deptId);
+
+    List<CameraVO> getCameraList(List<JSONObject> pointList);
+
+    List<String> getPictureList(String busId);
+}

src/main/java/com/sooka/sponest/middleware/base/service/impl/BaseESServiceImpl.java

@@ -0,0 +1,54 @@
+package com.sooka.sponest.middleware.base.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.common.datascope.annotation.DataScopeMutiDept;
+import com.ruoyi.common.datascope.base.domain.BaseBusinessEntity;
+import com.sooka.sponest.middleware.base.config.ParamConfig;
+import com.sooka.sponest.middleware.base.dao.BaseMapper;
+import com.sooka.sponest.middleware.base.entity.vo.CameraVO;
+import com.sooka.sponest.middleware.base.service.IBaseESService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Auther: mjq
+ * @Date: 2023/7/5 - 07 - 05 - 23:13
+ * @Description: com.sooka.sponest.rabbitmq.base.bean.service.Impl
+ * @version: 1.0
+ */
+@Service
+public class BaseESServiceImpl implements IBaseESService {
+
+    @Autowired
+    private BaseMapper baseMapper;
+
+    @DataScopeMutiDept(deptAlias = "d")
+    @Override
+    public List<Long> getDeptIds(BaseBusinessEntity baseBusinessEntity) {
+        baseBusinessEntity.setDatabase_system(ParamConfig.getSystemDB());
+        return baseMapper.getDeptIds(baseBusinessEntity);
+    }
+
+    @Override
+    public List<Long> getDeptAndChildIds(Long deptId) {
+        return baseMapper.getDeptAndChildIds(ParamConfig.getSystemDB(), deptId);
+    }
+
+    @Override
+    public List<CameraVO> getCameraList(List<JSONObject> pointList) {
+        if (StringUtils.isEmpty(pointList) || StringUtils.isEmpty(pointList.get(0).getJSONArray("deviceList"))) {
+            return new ArrayList<>();
+        }
+        List<String> ids = pointList.get(0).getJSONArray("deviceList").toJavaList(String.class);
+        return baseMapper.getCameraList(ParamConfig.getMonitorDB(), ids);
+    }
+
+    @Override
+    public List<String> getPictureList(String busId) {
+        return baseMapper.getPictureList(ParamConfig.getDataDB(), ParamConfig.getSystemDB(), busId);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/dao/Firehydrant1Dao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.basicdata.dao;
+
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface Firehydrant1Dao extends ElasticsearchRepository<Firehydrant, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/dao/Firehydrant2Dao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.basicdata.dao;
+
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant2;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface Firehydrant2Dao extends ElasticsearchRepository<Firehydrant2, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/dao/Firehydrant3Dao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.basicdata.dao;
+
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant3;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface Firehydrant3Dao extends ElasticsearchRepository<Firehydrant3, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/dao/WatercraneDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.basicdata.dao;
+
+import com.sooka.sponest.data.api.basicdata.domain.Watercrane;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface WatercraneDao extends ElasticsearchRepository<Watercrane, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/dao/WaterintakeDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.basicdata.dao;
+
+import com.sooka.sponest.data.api.basicdata.domain.Waterintake;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface WaterintakeDao extends ElasticsearchRepository<Waterintake, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/service/IFirehydrantService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.basicdata.service;
+
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant;
+
+import java.util.List;
+
+public interface IFirehydrantService {
+
+    void save(Firehydrant firehydrant);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/service/IWatercraneService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.basicdata.service;
+
+import com.sooka.sponest.data.api.basicdata.domain.Watercrane;
+
+import java.util.List;
+
+public interface IWatercraneService {
+
+    void save(Watercrane watercrane);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/service/IWaterintakeService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.basicdata.service;
+
+import com.sooka.sponest.data.api.basicdata.domain.Waterintake;
+
+import java.util.List;
+
+public interface IWaterintakeService {
+
+    void save(Waterintake waterintake);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/service/impl/FirehydrantServiceImpl.java

@@ -0,0 +1,68 @@
+package com.sooka.sponest.middleware.data.basicdata.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant;
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant2;
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant3;
+import com.sooka.sponest.middleware.data.basicdata.dao.Firehydrant1Dao;
+import com.sooka.sponest.middleware.data.basicdata.dao.Firehydrant2Dao;
+import com.sooka.sponest.middleware.data.basicdata.dao.Firehydrant3Dao;
+import com.sooka.sponest.middleware.data.basicdata.service.IFirehydrantService;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class FirehydrantServiceImpl implements IFirehydrantService {
+
+    @Autowired
+    private Firehydrant1Dao firehydrant1Dao;
+
+    @Autowired
+    private Firehydrant2Dao firehydrant2Dao;
+
+    @Autowired
+    private Firehydrant3Dao firehydrant3Dao;
+
+    @Override
+    public void save(Firehydrant firehydrant) {
+        firehydrant.setLocation(new GeoPoint(Double.valueOf(firehydrant.getLatitude()), Double.valueOf(firehydrant.getLongitude())));
+        firehydrant.setFirehydrantTypeLabel(DictUtils.getDictDataByValue("firehydrant",firehydrant.getFirehydrantType()));
+        String type = firehydrant.getFirehydrantType();
+        // 判断是否需要删除原有索引数据
+        if (firehydrant1Dao.existsById(firehydrant.getId()) && !type.equals("firehydrant_1")) {
+            firehydrant1Dao.deleteById(firehydrant.getId());
+        } else if (firehydrant2Dao.existsById(firehydrant.getId()) && !type.equals("firehydrant_2")) {
+            firehydrant2Dao.deleteById(firehydrant.getId());
+        } else if (firehydrant3Dao.existsById(firehydrant.getId()) && !type.equals("firehydrant_3")) {
+            firehydrant3Dao.deleteById(firehydrant.getId());
+        }
+        switch (type) {
+            case "firehydrant_1":
+                firehydrant1Dao.save(firehydrant);
+                break;
+            case "firehydrant_2":
+                Firehydrant2 firehydrant2 = new Firehydrant2();
+                BeanUtils.copyProperties(firehydrant, firehydrant2);
+                firehydrant2Dao.save(firehydrant2);
+                break;
+            case "firehydrant_3":
+                Firehydrant3 firehydrant3 = new Firehydrant3();
+                BeanUtils.copyProperties(firehydrant, firehydrant3);
+                firehydrant3Dao.save(firehydrant3);
+                break;
+            default:
+                break;
+        }
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        firehydrant1Dao.deleteAllById(ids);
+        firehydrant2Dao.deleteAllById(ids);
+        firehydrant3Dao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/service/impl/WatercraneServiceImpl.java

@@ -0,0 +1,27 @@
+package com.sooka.sponest.middleware.data.basicdata.service.impl;
+
+import com.sooka.sponest.data.api.basicdata.domain.Watercrane;
+import com.sooka.sponest.middleware.data.basicdata.dao.WatercraneDao;
+import com.sooka.sponest.middleware.data.basicdata.service.IWatercraneService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class WatercraneServiceImpl implements IWatercraneService {
+
+    @Autowired
+    private WatercraneDao watercraneDao;
+
+    @Override
+    public void save(Watercrane watercrane) {
+        watercrane.setLocation(new GeoPoint(Double.valueOf(watercrane.getLatitude()), Double.valueOf(watercrane.getLongitude())));
+        watercraneDao.save(watercrane);
+    }
+
+    public void deleteAllById(List<String> ids) {
+        watercraneDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/basicdata/service/impl/WaterintakeServiceImpl.java

@@ -0,0 +1,27 @@
+package com.sooka.sponest.middleware.data.basicdata.service.impl;
+
+import com.sooka.sponest.data.api.basicdata.domain.Waterintake;
+import com.sooka.sponest.middleware.data.basicdata.dao.WaterintakeDao;
+import com.sooka.sponest.middleware.data.basicdata.service.IWaterintakeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class WaterintakeServiceImpl implements IWaterintakeService {
+
+    @Autowired
+    private WaterintakeDao waterintakeDao;
+
+    @Override
+    public void save(Waterintake waterintake) {
+        waterintake.setLocation(new GeoPoint(Double.valueOf(waterintake.getLatitude()), Double.valueOf(waterintake.getLongitude())));
+        waterintakeDao.save(waterintake);
+    }
+
+    public void deleteAllById(List<String> ids) {
+        waterintakeDao.deleteAllById(ids);
+    }
+}

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

@@ -0,0 +1,502 @@
+package com.sooka.sponest.middleware.data.consumer;
+
+import com.alibaba.fastjson.JSON;
+import com.ruoyi.common.core.constant.DocumentNameConstants;
+import com.ruoyi.common.core.utils.SpringUtils;
+import com.ruoyi.common.log.enums.BusinessType;
+import com.sooka.sponest.data.api.basicdata.domain.Firehydrant;
+import com.sooka.sponest.data.api.basicdata.domain.Watercrane;
+import com.sooka.sponest.data.api.basicdata.domain.Waterintake;
+import com.sooka.sponest.data.api.digitalagriculture.domain.*;
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyEnterprises;
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyTeam;
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyWarehouse;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentKeyEnterprise;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSewageOutlet;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSourcePollution;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentWaterMonitor;
+import com.sooka.sponest.data.api.digitalfire.domain.*;
+import com.sooka.sponest.data.api.digitalforest.domain.Channel;
+import com.sooka.sponest.data.api.digitalforest.domain.Fireteam;
+import com.sooka.sponest.data.api.digitalforest.domain.KeyFireproofPlots;
+import com.sooka.sponest.data.api.digitalforest.domain.Landing;
+import com.sooka.sponest.data.api.digitalresource.domain.Deposit;
+import com.sooka.sponest.data.api.digitalresource.domain.GeologicHazard;
+import com.sooka.sponest.data.api.digitalresource.domain.IllegalConstruction;
+import com.sooka.sponest.data.api.digitaltraffic.domain.Bridge;
+import com.sooka.sponest.data.api.digitaltraffic.domain.Culvert;
+import com.sooka.sponest.data.api.digitaltraffic.domain.WarningSign;
+import com.sooka.sponest.data.api.digitalwater.domain.*;
+import com.sooka.sponest.middleware.data.basicdata.service.IFirehydrantService;
+import com.sooka.sponest.middleware.data.basicdata.service.IWatercraneService;
+import com.sooka.sponest.middleware.data.basicdata.service.IWaterintakeService;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.*;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyEnterprisesService;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyTeamService;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyWarehouseService;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentKeyEnterpriseDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentSewageOutletDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentSourcePollutionDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentWaterMonitorDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentKeyEnterpriseService;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentSewageOutletService;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentSourcePollutionService;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentWaterMonitorService;
+import com.sooka.sponest.middleware.data.digitalfirecontrol.service.*;
+import com.sooka.sponest.middleware.data.digitalforest.service.IChannelDaoService;
+import com.sooka.sponest.middleware.data.digitalforest.service.IFireTeamDaoService;
+import com.sooka.sponest.middleware.data.digitalforest.service.IKeyFireproofPlotsDaoService;
+import com.sooka.sponest.middleware.data.digitalforest.service.ILandingDaoService;
+import com.sooka.sponest.middleware.data.digitalresource.dao.DepositDao;
+import com.sooka.sponest.middleware.data.digitalresource.dao.GeologicHazardDao;
+import com.sooka.sponest.middleware.data.digitalresource.dao.IllegalConstructionDao;
+import com.sooka.sponest.middleware.data.digitalresource.service.IDepositService;
+import com.sooka.sponest.middleware.data.digitalresource.service.IGeologicHazardService;
+import com.sooka.sponest.middleware.data.digitalresource.service.IIllegalConstructionService;
+import com.sooka.sponest.middleware.data.digitaltraffic.dao.BridgeDao;
+import com.sooka.sponest.middleware.data.digitaltraffic.dao.CulvertDao;
+import com.sooka.sponest.middleware.data.digitaltraffic.dao.WarningSignDao;
+import com.sooka.sponest.middleware.data.digitaltraffic.service.IBridgeService;
+import com.sooka.sponest.middleware.data.digitaltraffic.service.ICulvertService;
+import com.sooka.sponest.middleware.data.digitaltraffic.service.IWarningSignService;
+import com.sooka.sponest.middleware.data.digitalwater.dao.*;
+import com.sooka.sponest.middleware.data.digitalwater.service.*;
+import com.sooka.sponest.middleware.data.visual.entity.bo.DataBO;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.annotation.StreamListener;
+import org.springframework.cloud.stream.messaging.Sink;
+import org.springframework.messaging.Message;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+
+@EnableBinding({Sink.class, DataSink.class}) // （Sink也是spring的）
+public class DataListener {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @StreamListener(DataSink.INPUT1) // 监听
+    public void input1(Message<DataBO> message) {
+        DataBO dataBO = message.getPayload();
+        logger.info("---消费者---{}", dataBO);
+        List<String> result = new ArrayList<>();
+        if (BusinessType.DELETE.equals(dataBO.getType())) {
+            String ids = dataBO.getModelStr().replace("\"", "").replace("[", "").replace("]", "");
+            if (ids.contains(",")) {
+                result = Arrays.asList(ids.split(","));
+            } else {
+                result = Collections.singletonList(ids);
+            }
+        }
+        switch (dataBO.getIndexName()) {
+            // 基础数据
+            case DocumentNameConstants.FOREST_WATERINTAKE:// 取水口
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IWaterintakeService.class).deleteAllById(result);
+                } else {
+                    Waterintake waterintake = JSON.parseObject(dataBO.getModelStr(), Waterintake.class);
+                    SpringUtils.getBean(IWaterintakeService.class).save(waterintake);
+                }
+                break;
+            case DocumentNameConstants.FOREST_WATERCRANE:// 水鹤
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IWatercraneService.class).deleteAllById(result);
+                } else {
+                    Watercrane watercrane = JSON.parseObject(dataBO.getModelStr(), Watercrane.class);
+                    SpringUtils.getBean(IWatercraneService.class).save(watercrane);
+                }
+                break;
+            case DocumentNameConstants.FOREST_FIREHYDRANT1:// 消火栓
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFirehydrantService.class).deleteAllById(result);
+                } else {
+                    Firehydrant firehydrant = JSON.parseObject(dataBO.getModelStr(), Firehydrant.class);
+                    SpringUtils.getBean(IFirehydrantService.class).save(firehydrant);
+                }
+                break;
+            // 数字林业
+            case DocumentNameConstants.FOREST_LANDING:// 起降点
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ILandingDaoService.class).deleteAllById(result);
+                } else {
+                    Landing landing = JSON.parseObject(dataBO.getModelStr(), Landing.class);
+                    SpringUtils.getBean(ILandingDaoService.class).save(landing);
+                }
+                break;
+            case DocumentNameConstants.FOREST_CHANNEL:// 水源渠道信息
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IChannelDaoService.class).deleteAllById(result);
+                } else {
+                    Channel channel = JSON.parseObject(dataBO.getModelStr(), Channel.class);
+                    SpringUtils.getBean(IChannelDaoService.class).save(channel);
+                }
+                break;
+            case DocumentNameConstants.FOREST_FIRETEAM:// 森林防火队
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFireTeamDaoService.class).deleteAllById(result);
+                } else {
+                    Fireteam fireteam = JSON.parseObject(dataBO.getModelStr(), Fireteam.class);
+                    SpringUtils.getBean(IFireTeamDaoService.class).save(fireteam);
+                }
+                break;
+            case DocumentNameConstants.FOREST_KEY_FIREPROOF_PLOTS:// 重点防火地块管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IKeyFireproofPlotsDaoService.class).deleteAllById(result);
+                } else {
+                    KeyFireproofPlots keyFireproofPlots = JSON.parseObject(dataBO.getModelStr(), KeyFireproofPlots.class);
+                    SpringUtils.getBean(IKeyFireproofPlotsDaoService.class).save(keyFireproofPlots);
+                }
+                break;
+            // 数字农业
+            case DocumentNameConstants.FARM_AGRICULTURAL_COOPERATIVES:// 农业合作社
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmAgriculturalCooperativesService.class).deleteAllById(result);
+                } else {
+                    FarmAgriculturalCooperatives centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmAgriculturalCooperatives.class);
+                    SpringUtils.getBean(ICenterdataTFarmAgriculturalCooperativesService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_BOTANY_PROTECT_INFO:// 农业技术推广总站信息
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmBotanyProtectInfoService.class).deleteAllById(result);
+                } else {
+                    FarmBotanyProtectInfo centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmBotanyProtectInfo.class);
+                    SpringUtils.getBean(ICenterdataTFarmBotanyProtectInfoService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_ENTERPRISE1:// 生鲜乳收购站、屠宰企业、饲料企业
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmEnterpriseService.class).deleteAllById(result);
+                } else {
+                    FarmEnterprise centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmEnterprise.class);
+                    SpringUtils.getBean(ICenterdataTFarmEnterpriseService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_FILINGS_LIVESTOCK:// 备案畜禽规模养殖场
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmFilingsLivestockService.class).deleteAllById(result);
+                } else {
+                    FarmFilingsLivestock centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmFilingsLivestock.class);
+                    SpringUtils.getBean(ICenterdataTFarmFilingsLivestockService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_LIVESTOCK:// 种畜禽养殖场
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmLivestockService.class).deleteAllById(result);
+                } else {
+                    FarmLivestock centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmLivestock.class);
+                    SpringUtils.getBean(ICenterdataTFarmLivestockService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_EXCREMENT_DISPOSE:// 区域性粪污处置中心
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmExcrementDisposeService.class).deleteAllById(result);
+                } else {
+                    FarmExcrementDispose centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmExcrementDispose.class);
+                    SpringUtils.getBean(ICenterdataTFarmExcrementDisposeService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_COMPLEX_MODIFICATION:// 肉牛基层繁改站
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmComplexModificationService.class).deleteAllById(result);
+                } else {
+                    FarmComplexModification centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmComplexModification.class);
+                    SpringUtils.getBean(ICenterdataTFarmComplexModificationService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_GREENHOUSE_FILM:// 棚膜信息
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmGreenhouseFilmInfoService.class).deleteAllById(result);
+                } else {
+                    FarmGreenhouseFilmInfo centerdataTEnvironmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), FarmGreenhouseFilmInfo.class);
+                    SpringUtils.getBean(ICenterdataTFarmGreenhouseFilmInfoService.class).save(centerdataTEnvironmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.FARM_TRASHCAN:// 垃圾桶
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmTrashCanService.class).deleteAllById(result);
+                } else {
+                    FarmTrashCan farmTrashCan = JSON.parseObject(dataBO.getModelStr(), FarmTrashCan.class);
+                    SpringUtils.getBean(ICenterdataTFarmTrashCanService.class).save(farmTrashCan);
+                }
+                break;
+            case DocumentNameConstants.FARM_GARBAGE_TRANSFER:// 垃圾转输站
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmGarbageTransferService.class).deleteAllById(result);
+                } else {
+                    FarmGarbageTransfer farmGarbageTransfer = JSON.parseObject(dataBO.getModelStr(), FarmGarbageTransfer.class);
+                    SpringUtils.getBean(ICenterdataTFarmGarbageTransferService.class).save(farmGarbageTransfer);
+                }
+                break;
+            case DocumentNameConstants.FARM_CESSPIT_COLLECT:// 粪污收集点
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmCesspitCollectService.class).deleteAllById(result);
+                } else {
+                    FarmCesspitCollect farmCesspitCollect = JSON.parseObject(dataBO.getModelStr(), FarmCesspitCollect.class);
+                    SpringUtils.getBean(ICenterdataTFarmCesspitCollectService.class).save(farmCesspitCollect);
+                }
+                break;
+            case DocumentNameConstants.FARM_BREEDING_FARM:// 养殖场
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmBreedingFarmService.class).deleteAllById(result);
+                } else {
+                    FarmBreedingFarm farmBreedingFarm = JSON.parseObject(dataBO.getModelStr(), FarmBreedingFarm.class);
+                    SpringUtils.getBean(ICenterdataTFarmBreedingFarmService.class).save(farmBreedingFarm);
+                }
+                break;
+            case DocumentNameConstants.FARM_COLLECTIVE_FARMLAND:// 农村集体耕地
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmCollectiveFarmlandService.class).deleteAllById(result);
+                } else {
+                    FarmCollectiveFarmland farmCollectiveFarmland = JSON.parseObject(dataBO.getModelStr(), FarmCollectiveFarmland.class);
+                    SpringUtils.getBean(ICenterdataTFarmCollectiveFarmlandService.class).save(farmCollectiveFarmland);
+                }
+                break;
+            // 数字水利
+            case DocumentNameConstants.HYDRAULIC_BATTLEFIELD:// 沙场资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicBattlefieldDao.class).deleteAllById(result);
+                } else {
+                    HydraulicBattlefield hydraulicBattlefield = JSON.parseObject(dataBO.getModelStr(), HydraulicBattlefield.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicBattlefieldService.class).save(hydraulicBattlefield);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_CHANNEL_BLUELINE:// 河道蓝线资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicChannelBluelineDao.class).deleteAllById(result);
+                } else {
+                    HydraulicChannelBluelineApp centerdataTHydraulicChannelBlueline = JSON.parseObject(dataBO.getModelStr(), HydraulicChannelBluelineApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicChannelBluelineService.class).save(centerdataTHydraulicChannelBlueline);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_GARBAGE_STATION:// 垃圾站资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicGarbageStationDao.class).deleteAllById(result);
+                } else {
+                    HydraulicGarbageStationApp centerdataTHydraulicGarbageStation = JSON.parseObject(dataBO.getModelStr(), HydraulicGarbageStationApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicGarbageStationService.class).save(centerdataTHydraulicGarbageStation);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_OUTLET_SEWAGE:// 排污口资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicOutletSewageDao.class).deleteAllById(result);
+                } else {
+                    HydraulicOutletSewageApp centerdataTHydraulicOutletSewage = JSON.parseObject(dataBO.getModelStr(), HydraulicOutletSewageApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicOutletSewageService.class).save(centerdataTHydraulicOutletSewage);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_REACH:// 河段资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicReachDao.class).deleteAllById(result);
+                } else {
+                    HydraulicReachApp hydraulicReachApp = JSON.parseObject(dataBO.getModelStr(), HydraulicReachApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicReachService.class).save(hydraulicReachApp);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_RESERVOIR:// 水库资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicReservoirDao.class).deleteAllById(result);
+                } else {
+                    HydraulicReservoirApp hydraulicReservoirApp = JSON.parseObject(dataBO.getModelStr(), HydraulicReservoirApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicReservoirService.class).save(hydraulicReservoirApp);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_RIVER:// 河流资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicRiverDao.class).deleteAllById(result);
+                } else {
+                    HydraulicRiverApp hydraulicRiverApp = JSON.parseObject(dataBO.getModelStr(), HydraulicRiverApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicRiverService.class).save(hydraulicRiverApp);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_WADE_BRIDGE_CULVERT:// 涉水桥涵资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicWadeBridgeCulvertDao.class).deleteAllById(result);
+                } else {
+                    HydraulicWadeBridgeCulvertApp hydraulicWadeBridgeCulvertApp = JSON.parseObject(dataBO.getModelStr(), HydraulicWadeBridgeCulvertApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicWadeBridgeCulvertService.class).save(hydraulicWadeBridgeCulvertApp);
+                }
+                break;
+            case DocumentNameConstants.HYDRAULIC_WATER_GATE:// 闸口资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTHydraulicWaterGateDao.class).deleteAllById(result);
+                } else {
+                    HydraulicWaterGateApp hydraulicWaterGateApp = JSON.parseObject(dataBO.getModelStr(), HydraulicWaterGateApp.class);
+                    SpringUtils.getBean(ICenterdataTHydraulicWaterGateService.class).save(hydraulicWaterGateApp);
+                }
+                break;
+            // 数字环保
+            case DocumentNameConstants.ENVIRONMENT_KEY_ENTERPRISE:// 重点企业管理
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentKeyEnterpriseDao.class).deleteAllById(result);
+                } else {
+                    EnvironmentKeyEnterprise environmentKeyEnterprise = JSON.parseObject(dataBO.getModelStr(), EnvironmentKeyEnterprise.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentKeyEnterpriseService.class).save(environmentKeyEnterprise);
+                }
+                break;
+            case DocumentNameConstants.ENVIRONMENT_SOURCE_POLLUTION:// 污染源管理
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentSourcePollutionDao.class).deleteAllById(result);
+                } else {
+                    EnvironmentSourcePollution environmentSourcePollution = JSON.parseObject(dataBO.getModelStr(), EnvironmentSourcePollution.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentSourcePollutionService.class).save(environmentSourcePollution);
+                }
+                break;
+            case DocumentNameConstants.ENVIRONMENT_SEWAGE_OUTLET:// 排污口
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentSewageOutletDao.class).deleteAllById(result);
+                } else {
+                    EnvironmentSewageOutlet environmentSewageOutlet = JSON.parseObject(dataBO.getModelStr(), EnvironmentSewageOutlet.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentSewageOutletService.class).save(environmentSewageOutlet);
+                }
+                break;
+            case DocumentNameConstants.ENVIRONMENT_WATER_MONITOR:// 水质断面监测
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentWaterMonitorDao.class).deleteAllById(result);
+                } else {
+                    EnvironmentWaterMonitor environmentWaterMonitor = JSON.parseObject(dataBO.getModelStr(), EnvironmentWaterMonitor.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentWaterMonitorService.class).save(environmentWaterMonitor);
+                }
+                break;
+            // 数字应急
+            case DocumentNameConstants.EMERGENCY_WAREHOUSE:// 应急仓库
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTEmergencyWarehouseService.class).deleteAllById(result);
+                } else {
+                    EmergencyWarehouse emergencyWarehouse = JSON.parseObject(dataBO.getModelStr(), EmergencyWarehouse.class);
+                    SpringUtils.getBean(ICenterdataTEmergencyWarehouseService.class).save(emergencyWarehouse);
+                }
+                break;
+            case DocumentNameConstants.EMERGENCY_TEAM:// 应急队伍
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTEmergencyTeamService.class).deleteAllById(result);
+                } else {
+                    EmergencyTeam emergencyTeam = JSON.parseObject(dataBO.getModelStr(), EmergencyTeam.class);
+                    SpringUtils.getBean(ICenterdataTEmergencyTeamService.class).save(emergencyTeam);
+                }
+                break;
+            case DocumentNameConstants.EMERGENCY_IDLH_ENTERPRISES:// 危化企业
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTEmergencyEnterprisesService.class).deleteAllById(result);
+                } else {
+                    EmergencyEnterprises emergencyEnterprises = JSON.parseObject(dataBO.getModelStr(), EmergencyEnterprises.class);
+                    SpringUtils.getBean(ICenterdataTEmergencyEnterprisesService.class).save(emergencyEnterprises);
+                }
+                break;
+            // 数字交通
+            case DocumentNameConstants.TRAFFIC_WARNING_SIGN:// 警示牌资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(WarningSignDao.class).deleteAllById(result);
+                } else {
+                    WarningSign warningSign = JSON.parseObject(dataBO.getModelStr(), WarningSign.class);
+                    SpringUtils.getBean(IWarningSignService.class).save(warningSign);
+                }
+                break;
+            case DocumentNameConstants.TRAFFIC_BRIDGE:// 桥梁资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(BridgeDao.class).deleteAllById(result);
+                } else {
+                    Bridge bridge = JSON.parseObject(dataBO.getModelStr(), Bridge.class);
+                    SpringUtils.getBean(IBridgeService.class).save(bridge);
+                }
+                break;
+            case DocumentNameConstants.TRAFFIC_CULVERT:// 涵洞资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CulvertDao.class).deleteAllById(result);
+                } else {
+                    Culvert culvert = JSON.parseObject(dataBO.getModelStr(), Culvert.class);
+                    SpringUtils.getBean(ICulvertService.class).save(culvert);
+                }
+                break;
+            // 数字资源
+            case DocumentNameConstants.RESOURCES_DEPOSIT:// 矿产资源
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(DepositDao.class).deleteAllById(result);
+                } else {
+                    Deposit deposit = JSON.parseObject(dataBO.getModelStr(), Deposit.class);
+                    SpringUtils.getBean(IDepositService.class).save(deposit);
+                }
+                break;
+            case DocumentNameConstants.RESOURCES_GEOLOGIC_HAZARD:// 地质灾害易发区
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(GeologicHazardDao.class).deleteAllById(result);
+                } else {
+                    GeologicHazard geologicHazard = JSON.parseObject(dataBO.getModelStr(), GeologicHazard.class);
+                    SpringUtils.getBean(IGeologicHazardService.class).save(geologicHazard);
+                }
+                break;
+            case DocumentNameConstants.RESOURCES_ILLEGAL_CONSTRUCTION:// 违建信息
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(IllegalConstructionDao.class).deleteAllById(result);
+                } else {
+                    IllegalConstruction illegalConstruction = JSON.parseObject(dataBO.getModelStr(), IllegalConstruction.class);
+                    SpringUtils.getBean(IIllegalConstructionService.class).save(illegalConstruction);
+                }
+                break;
+            // 数字消防
+            case DocumentNameConstants.FIRECONTROL_FIRE_FORCE:// 消防力量管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFireForceService.class).deleteAllById(result);
+                } else {
+                    FireForce fireForce = JSON.parseObject(dataBO.getModelStr(), FireForce.class);
+                    SpringUtils.getBean(IFireForceService.class).save(fireForce);
+                }
+                break;
+            case DocumentNameConstants.FIRECONTROL_FIRE_KEY_PLACES:// 重点场所管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFireKeyPlacesService.class).deleteAllById(result);
+                } else {
+                    FireKeyPlaces fireKeyPlaces = JSON.parseObject(dataBO.getModelStr(), FireKeyPlaces.class);
+                    SpringUtils.getBean(IFireKeyPlacesService.class).save(fireKeyPlaces);
+                }
+                break;
+            case DocumentNameConstants.FIRECONTROL_FIRE_PRESSURE_SENSOR:// 压力传感器管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFirePressureSensorService.class).deleteAllById(result);
+                } else {
+                    FirePressureSensor firePressureSensor = JSON.parseObject(dataBO.getModelStr(), FirePressureSensor.class);
+                    SpringUtils.getBean(IFirePressureSensorService.class).save(firePressureSensor);
+                }
+                break;
+            case DocumentNameConstants.FIRECONTROL_BASIC_LINKAGE_FORCE:// 基本联动力量管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IBasicLinkageForceService.class).deleteAllById(result);
+                } else {
+                    BasicLinkageForce basicLinkageForce = JSON.parseObject(dataBO.getModelStr(), BasicLinkageForce.class);
+                    SpringUtils.getBean(IBasicLinkageForceService.class).save(basicLinkageForce);
+                }
+                break;
+            case DocumentNameConstants.FIRECONTROL_OTHER_LINKAGE_FORCE:// 其他联动力量管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFireOtherLinkageForceService.class).deleteAllById(result);
+                } else {
+                    FireOtherLinkageForce fireOtherLinkageForce = JSON.parseObject(dataBO.getModelStr(), FireOtherLinkageForce.class);
+                    SpringUtils.getBean(IFireOtherLinkageForceService.class).save(fireOtherLinkageForce);
+                }
+                break;
+            case DocumentNameConstants.FIRECONTROL_FOAM_LIQUID:// 泡沫液管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFireFoamLiquidService.class).deleteAllById(result);
+                } else {
+                    FireFoamLiquid fireteam = JSON.parseObject(dataBO.getModelStr(), FireFoamLiquid.class);
+                    SpringUtils.getBean(IFireFoamLiquidService.class).save(fireteam);
+                }
+                break;
+            case DocumentNameConstants.FIRECONTROL_FULLTIME_STATION:// 专职站管理
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(IFireFultimeStationService.class).deleteAllById(result);
+                } else {
+                    FireFulltimeStation fireFulltimeStation = JSON.parseObject(dataBO.getModelStr(), FireFulltimeStation.class);
+                    SpringUtils.getBean(IFireFultimeStationService.class).save(fireFulltimeStation);
+                }
+                break;
+            default:
+                logger.info("无效索引---{}", dataBO.getIndexName());
+                break;
+        }
+    }
+}

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

@@ -0,0 +1,18 @@
+package com.sooka.sponest.middleware.data.consumer;
+
+import org.springframework.cloud.stream.annotation.Input;
+import org.springframework.messaging.SubscribableChannel;
+
+public interface DataSink {
+
+    /**
+     * Input channel name.
+     */
+    String INPUT1 = "centerdata-in-0";
+
+    /**
+     * @return input channel.
+     */
+    @Input(INPUT1)
+    SubscribableChannel input();
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmAgriculturalCooperativesDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmAgriculturalCooperatives;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmAgriculturalCooperativesDao extends ElasticsearchRepository<FarmAgriculturalCooperatives, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmBotanyProtectInfoDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBotanyProtectInfo;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmBotanyProtectInfoDao extends ElasticsearchRepository<FarmBotanyProtectInfo, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmBreedingFarmDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBreedingFarm;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmBreedingFarmDao extends ElasticsearchRepository<FarmBreedingFarm, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmCesspitCollectDao.java

@@ -0,0 +1,11 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmCesspitCollect;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/8
+ */
+public interface CenterdataTFarmCesspitCollectDao extends ElasticsearchRepository<FarmCesspitCollect, String> {
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmCollectiveFarmlandDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmCollectiveFarmland;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmCollectiveFarmlandDao extends ElasticsearchRepository<FarmCollectiveFarmland, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmComplexModificationDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmComplexModification;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmComplexModificationDao extends ElasticsearchRepository<FarmComplexModification, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmEnterprise1Dao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmEnterprise1Dao extends ElasticsearchRepository<FarmEnterprise, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmEnterprise2Dao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise2;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmEnterprise2Dao extends ElasticsearchRepository<FarmEnterprise2, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmEnterprise3Dao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise3;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmEnterprise3Dao extends ElasticsearchRepository<FarmEnterprise3, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmExcrementDisposeDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmExcrementDispose;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmExcrementDisposeDao extends ElasticsearchRepository<FarmExcrementDispose, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmFilingsLivestockDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmFilingsLivestock;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmFilingsLivestockDao extends ElasticsearchRepository<FarmFilingsLivestock, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmGarbageTransferDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGarbageTransfer;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmGarbageTransferDao extends ElasticsearchRepository<FarmGarbageTransfer, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmGreenhouseFilmInfoDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGreenhouseFilmInfo;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmGreenhouseFilmInfoDao extends ElasticsearchRepository<FarmGreenhouseFilmInfo, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmLivestockDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmLivestock;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmLivestockDao extends ElasticsearchRepository<FarmLivestock, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/dao/CenterdataTFarmTrashCanDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.dao;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmTrashCan;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTFarmTrashCanDao extends ElasticsearchRepository<FarmTrashCan, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmAgriculturalCooperativesService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmAgriculturalCooperatives;
+
+import java.util.List;
+
+public interface ICenterdataTFarmAgriculturalCooperativesService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmAgriculturalCooperatives farmAgriculturalCooperatives);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmBotanyProtectInfoService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBotanyProtectInfo;
+
+import java.util.List;
+
+public interface ICenterdataTFarmBotanyProtectInfoService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmBotanyProtectInfo farmBotanyProtectInfo);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmBreedingFarmService.java

@@ -0,0 +1,24 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBreedingFarm;
+
+import java.util.List;
+
+public interface ICenterdataTFarmBreedingFarmService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmBreedingFarm farmBreedingFarm);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmCesspitCollectService.java

@@ -0,0 +1,24 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmCesspitCollect;
+
+import java.util.List;
+
+public interface ICenterdataTFarmCesspitCollectService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmCesspitCollect farmCesspitCollect);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmCollectiveFarmlandService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmCollectiveFarmland;
+
+import java.util.List;
+
+public interface ICenterdataTFarmCollectiveFarmlandService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmCollectiveFarmland farmCollectiveFarmland);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmComplexModificationService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmComplexModification;
+
+import java.util.List;
+
+public interface ICenterdataTFarmComplexModificationService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmComplexModification farmComplexModification);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmEnterpriseService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise;
+
+import java.util.List;
+
+public interface ICenterdataTFarmEnterpriseService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmEnterprise farmEnterprise);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmExcrementDisposeService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmExcrementDispose;
+
+import java.util.List;
+
+public interface ICenterdataTFarmExcrementDisposeService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmExcrementDispose farmExcrementDispose);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmFilingsLivestockService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmFilingsLivestock;
+
+import java.util.List;
+
+public interface ICenterdataTFarmFilingsLivestockService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmFilingsLivestock farmFilingsLivestock);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmGarbageTransferService.java

@@ -0,0 +1,24 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGarbageTransfer;
+
+import java.util.List;
+
+public interface ICenterdataTFarmGarbageTransferService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmGarbageTransfer farmGarbageTransfer);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmGreenhouseFilmInfoService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGreenhouseFilmInfo;
+
+import java.util.List;
+
+public interface ICenterdataTFarmGreenhouseFilmInfoService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmGreenhouseFilmInfo farmGreenhouseFilmInfo);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmLivestockService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmLivestock;
+
+import java.util.List;
+
+public interface ICenterdataTFarmLivestockService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmLivestock farmLivestock);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/ICenterdataTFarmTrashCanService.java

@@ -0,0 +1,23 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmTrashCan;
+
+import java.util.List;
+
+public interface ICenterdataTFarmTrashCanService {
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    void save(FarmTrashCan farmTrashCan);
+
+    /**
+     * 批量删除
+     *
+     * @param
+     * @return
+     */
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmAgriculturalCooperativesServiceImpl.java

@@ -0,0 +1,39 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmAgriculturalCooperatives;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmAgriculturalCooperativesDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmAgriculturalCooperativesService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmAgriculturalCooperativesServiceImpl implements ICenterdataTFarmAgriculturalCooperativesService {
+
+    @Autowired
+    private CenterdataTFarmAgriculturalCooperativesDao centerdataTFarmAgriculturalCooperativesDao;
+
+    /**
+     * 新增
+     *
+     * @param
+     */
+    @Override
+    public void save(FarmAgriculturalCooperatives farmAgriculturalCooperatives) {
+        farmAgriculturalCooperatives.setLocation(new GeoPoint(Double.valueOf(farmAgriculturalCooperatives.getLatitude()), Double.valueOf(farmAgriculturalCooperatives.getLongitude())));
+        centerdataTFarmAgriculturalCooperativesDao.save(farmAgriculturalCooperatives);
+    }
+
+    /**
+     * 删除
+     *
+     * @param
+     * @return
+     */
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmAgriculturalCooperativesDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmBotanyProtectInfoServiceImpl.java

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBotanyProtectInfo;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmBotanyProtectInfoDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmBotanyProtectInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmBotanyProtectInfoServiceImpl implements ICenterdataTFarmBotanyProtectInfoService {
+
+    @Autowired
+    private CenterdataTFarmBotanyProtectInfoDao centerdataTFarmBotanyProtectInfoDao;
+
+    @Override
+    public void save(FarmBotanyProtectInfo farmBotanyProtectInfo) {
+        farmBotanyProtectInfo.setLocation(new GeoPoint(Double.valueOf(farmBotanyProtectInfo.getLatitude()), Double.valueOf(farmBotanyProtectInfo.getLongitude())));
+        centerdataTFarmBotanyProtectInfoDao.save(farmBotanyProtectInfo);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmBotanyProtectInfoDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmBreedingFarmServiceImpl.java

@@ -0,0 +1,30 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBreedingFarm;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGarbageTransfer;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmBreedingFarmDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmCesspitCollectDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmGarbageTransferDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmBreedingFarmService;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmGarbageTransferService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmBreedingFarmServiceImpl implements ICenterdataTFarmBreedingFarmService {
+
+    @Autowired
+    private CenterdataTFarmBreedingFarmDao centerdataTFarmBreedingFarmDao;
+
+    @Override
+    public void save(FarmBreedingFarm farmBreedingFarm) {
+        centerdataTFarmBreedingFarmDao.save(farmBreedingFarm);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmBreedingFarmDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmCesspitCollectServiceImpl.java

@@ -0,0 +1,26 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmCesspitCollect;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmCesspitCollectDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmCesspitCollectService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmCesspitCollectServiceImpl implements ICenterdataTFarmCesspitCollectService {
+
+    @Autowired
+    private CenterdataTFarmCesspitCollectDao centerdataTFarmCesspitCollectDao;
+
+    @Override
+    public void save(FarmCesspitCollect farmCesspitCollect) {
+        centerdataTFarmCesspitCollectDao.save(farmCesspitCollect);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmCesspitCollectDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmCollectiveFarmlandServiceImpl.java

@@ -0,0 +1,26 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmCollectiveFarmland;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmCollectiveFarmlandDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmCollectiveFarmlandService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmCollectiveFarmlandServiceImpl implements ICenterdataTFarmCollectiveFarmlandService {
+
+    @Autowired
+    private CenterdataTFarmCollectiveFarmlandDao centerdataTFarmCollectiveFarmlandDao;
+
+    @Override
+    public void save(FarmCollectiveFarmland farmCollectiveFarmland) {
+        centerdataTFarmCollectiveFarmlandDao.save(farmCollectiveFarmland);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmCollectiveFarmlandDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmComplexModificationServiceImpl.java

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmComplexModification;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmComplexModificationDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmComplexModificationService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmComplexModificationServiceImpl implements ICenterdataTFarmComplexModificationService {
+
+    @Autowired
+    private CenterdataTFarmComplexModificationDao centerdataTFarmComplexModificationDao;
+
+    @Override
+    public void save(FarmComplexModification farmComplexModification) {
+        farmComplexModification.setLocation(new GeoPoint(Double.valueOf(farmComplexModification.getLatitude()), Double.valueOf(farmComplexModification.getLongitude())));
+        centerdataTFarmComplexModificationDao.save(farmComplexModification);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmComplexModificationDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmEnterpriseServiceImpl.java

@@ -0,0 +1,58 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise2;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise3;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmEnterprise1Dao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmEnterprise2Dao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmEnterprise3Dao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmEnterpriseService;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmEnterpriseServiceImpl implements ICenterdataTFarmEnterpriseService {
+
+    @Autowired
+    private CenterdataTFarmEnterprise1Dao centerdataTFarmEnterprise1Dao;
+
+    @Autowired
+    private CenterdataTFarmEnterprise2Dao centerdataTFarmEnterprise2Dao;
+
+    @Autowired
+    private CenterdataTFarmEnterprise3Dao centerdataTFarmEnterprise3Dao;
+
+    @Override
+    public void save(FarmEnterprise farmEnterprise) {
+        farmEnterprise.setLocation(new GeoPoint(Double.valueOf(farmEnterprise.getLatitude()), Double.valueOf(farmEnterprise.getLongitude())));
+        String type = farmEnterprise.getType();
+        switch (type) {
+            case "1":
+                centerdataTFarmEnterprise1Dao.save(farmEnterprise);
+                break;
+            case "2":
+                FarmEnterprise2 farmEnterprise2 = new FarmEnterprise2();
+                BeanUtils.copyProperties(farmEnterprise, farmEnterprise2);
+                centerdataTFarmEnterprise2Dao.save(farmEnterprise2);
+                break;
+            case "3":
+                FarmEnterprise3 farmEnterprise3 = new FarmEnterprise3();
+                BeanUtils.copyProperties(farmEnterprise, farmEnterprise3);
+                centerdataTFarmEnterprise3Dao.save(farmEnterprise3);
+                break;
+            default:
+                break;
+        }
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmEnterprise1Dao.deleteAllById(ids);
+        centerdataTFarmEnterprise2Dao.deleteAllById(ids);
+        centerdataTFarmEnterprise3Dao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmExcrementDisposeServiceImpl.java

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmExcrementDispose;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmExcrementDisposeDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmExcrementDisposeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmExcrementDisposeServiceImpl implements ICenterdataTFarmExcrementDisposeService {
+
+    @Autowired
+    private CenterdataTFarmExcrementDisposeDao centerdataTFarmExcrementDisposeDao;
+
+    @Override
+    public void save(FarmExcrementDispose farmExcrementDispose) {
+        farmExcrementDispose.setLocation(new GeoPoint(Double.valueOf(farmExcrementDispose.getLatitude()), Double.valueOf(farmExcrementDispose.getLongitude())));
+        centerdataTFarmExcrementDisposeDao.save(farmExcrementDispose);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmExcrementDisposeDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmFilingsLivestockServiceImpl.java

@@ -0,0 +1,30 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmFilingsLivestock;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmFilingsLivestockDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmFilingsLivestockService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmFilingsLivestockServiceImpl implements ICenterdataTFarmFilingsLivestockService {
+
+    @Autowired
+    private CenterdataTFarmFilingsLivestockDao centerdataTFarmFilingsLivestockDao;
+
+    @Override
+    public void save(FarmFilingsLivestock farmFilingsLivestock) {
+        farmFilingsLivestock.setLocation(new GeoPoint(Double.valueOf(farmFilingsLivestock.getLatitude()), Double.valueOf(farmFilingsLivestock.getLongitude())));
+        farmFilingsLivestock.setVarietiesLabel(DictUtils.getDictDataByValue("centerdata_breeding_variety",farmFilingsLivestock.getVarieties()));
+        centerdataTFarmFilingsLivestockDao.save(farmFilingsLivestock);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmFilingsLivestockDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmGarbageTransferServiceImpl.java

@@ -0,0 +1,26 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGarbageTransfer;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmGarbageTransferDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmGarbageTransferService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmGarbageTransferServiceImpl implements ICenterdataTFarmGarbageTransferService {
+
+    @Autowired
+    private CenterdataTFarmGarbageTransferDao centerdataTFarmGarbageTransferDao;
+
+    @Override
+    public void save(FarmGarbageTransfer farmGarbageTransfer) {
+        centerdataTFarmGarbageTransferDao.save(farmGarbageTransfer);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmGarbageTransferDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmGreenhouseFilmInfoServiceImpl.java

@@ -0,0 +1,36 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmGreenhouseFilmInfo;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmGreenhouseFilmInfoDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmGreenhouseFilmInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmGreenhouseFilmInfoServiceImpl implements ICenterdataTFarmGreenhouseFilmInfoService {
+
+    @Autowired
+    private CenterdataTFarmGreenhouseFilmInfoDao centerdataTFarmGreenhouseFilmInfoDao;
+
+    @Override
+    public void save(FarmGreenhouseFilmInfo farmGreenhouseFilmInfo) {
+        farmGreenhouseFilmInfo.setLocation(new GeoPoint(Double.valueOf(farmGreenhouseFilmInfo.getLatitude()), Double.valueOf(farmGreenhouseFilmInfo.getLongitude())));
+        if (StringUtils.isNotEmpty(farmGreenhouseFilmInfo.getPlantType())) {
+            farmGreenhouseFilmInfo.setPlantTypeLabel(DictUtils.getDictDataListByValue("plant_category", farmGreenhouseFilmInfo.getPlantType()));
+        }
+        if (StringUtils.isNotEmpty(farmGreenhouseFilmInfo.getParkNature())) {
+            farmGreenhouseFilmInfo.setParkNatureLabel(DictUtils.getDictDataListByValue("park_nature", farmGreenhouseFilmInfo.getParkNature()));
+        }
+        centerdataTFarmGreenhouseFilmInfoDao.save(farmGreenhouseFilmInfo);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmGreenhouseFilmInfoDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmLivestockServiceImpl.java

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmLivestock;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmLivestockDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmLivestockService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmLivestockServiceImpl implements ICenterdataTFarmLivestockService {
+
+    @Autowired
+    private CenterdataTFarmLivestockDao centerdataTFarmLivestockDao;
+
+    @Override
+    public void save(FarmLivestock farmLivestock) {
+        farmLivestock.setLocation(new GeoPoint(Double.valueOf(farmLivestock.getLatitude()), Double.valueOf(farmLivestock.getLongitude())));
+        centerdataTFarmLivestockDao.save(farmLivestock);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmLivestockDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalagriculture/service/impl/ICenterdataTFarmTrashCanServiceImpl.java

@@ -0,0 +1,26 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmTrashCan;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmTrashCanDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmTrashCanService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class ICenterdataTFarmTrashCanServiceImpl implements ICenterdataTFarmTrashCanService {
+
+    @Autowired
+    private CenterdataTFarmTrashCanDao centerdataTFarmTrashCanDao;
+
+    @Override
+    public void save(FarmTrashCan farmTrashCan) {
+        centerdataTFarmTrashCanDao.save(farmTrashCan);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmTrashCanDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/dao/CenterdataTEmergencyEnterprisesDao.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalemergency.dao;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyEnterprises;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author phy
+ * @date 2023/7/21
+ */
+public interface CenterdataTEmergencyEnterprisesDao extends ElasticsearchRepository<EmergencyEnterprises, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/dao/CenterdataTEmergencyTeamDao.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalemergency.dao;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyTeam;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author phy
+ * @date 2023/7/21
+ */
+public interface CenterdataTEmergencyTeamDao extends ElasticsearchRepository<EmergencyTeam, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/dao/CenterdataTEmergencyWarehouseDao.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalemergency.dao;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyWarehouse;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author phy
+ * @date 2023/7/21
+ */
+public interface CenterdataTEmergencyWarehouseDao extends ElasticsearchRepository<EmergencyWarehouse, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/ICenterdataTEmergencyEnterprisesService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyEnterprises;
+
+import java.util.List;
+
+public interface ICenterdataTEmergencyEnterprisesService {
+
+    void save(EmergencyEnterprises emergencyEnterprises);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/ICenterdataTEmergencyTeamService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyTeam;
+
+import java.util.List;
+
+public interface ICenterdataTEmergencyTeamService {
+
+    void save(EmergencyTeam emergencyTeam);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/ICenterdataTEmergencyWarehouseService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyWarehouse;
+
+import java.util.List;
+
+public interface ICenterdataTEmergencyWarehouseService {
+
+    void save(EmergencyWarehouse emergencyWarehouse);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/impl/CenterdataTEmergencyEnterprisesServiceImpl.java

@@ -0,0 +1,30 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyEnterprises;
+import com.sooka.sponest.middleware.data.digitalemergency.dao.CenterdataTEmergencyEnterprisesDao;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyEnterprisesService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class CenterdataTEmergencyEnterprisesServiceImpl implements ICenterdataTEmergencyEnterprisesService {
+
+    @Autowired
+    private CenterdataTEmergencyEnterprisesDao centerdataTEmergencyEnterprisesDao;
+
+    @Override
+    public void save(EmergencyEnterprises emergencyEnterprises) {
+        emergencyEnterprises.setLocation(new GeoPoint(Double.valueOf(emergencyEnterprises.getLatitude()), Double.valueOf(emergencyEnterprises.getLongitude())));
+        emergencyEnterprises.setCategoryLabel(DictUtils.getDictDataByValue("enterprises_type",emergencyEnterprises.getCategory()));
+        centerdataTEmergencyEnterprisesDao.save(emergencyEnterprises);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTEmergencyEnterprisesDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/impl/CenterdataTEmergencyTeamServiceImpl.java

@@ -0,0 +1,30 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyTeam;
+import com.sooka.sponest.middleware.data.digitalemergency.dao.CenterdataTEmergencyTeamDao;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyTeamService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class CenterdataTEmergencyTeamServiceImpl implements ICenterdataTEmergencyTeamService {
+
+    @Autowired
+    private CenterdataTEmergencyTeamDao centerdataTEmergencyTeamDao;
+
+    @Override
+    public void save(EmergencyTeam emergencyTeam) {
+        emergencyTeam.setLocation(new GeoPoint(Double.valueOf(emergencyTeam.getLatitude()), Double.valueOf(emergencyTeam.getLongitude())));
+        emergencyTeam.setTeamNatureLabel(DictUtils.getDictDataByValue( "emergency_team_nature",emergencyTeam.getTeamNature()));
+        centerdataTEmergencyTeamDao.save(emergencyTeam);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTEmergencyTeamDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/impl/CenterdataTEmergencyWarehouseServiceImpl.java

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service.impl;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyWarehouse;
+import com.sooka.sponest.middleware.data.digitalemergency.dao.CenterdataTEmergencyWarehouseDao;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyWarehouseService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class CenterdataTEmergencyWarehouseServiceImpl implements ICenterdataTEmergencyWarehouseService {
+
+    @Autowired
+    private CenterdataTEmergencyWarehouseDao centerdataTEmergencyWarehouseDao;
+
+    @Override
+    public void save(EmergencyWarehouse emergencyWarehouse) {
+        emergencyWarehouse.setLocation(new GeoPoint(Double.valueOf(emergencyWarehouse.getLatitude()), Double.valueOf(emergencyWarehouse.getLongitude())));
+        centerdataTEmergencyWarehouseDao.save(emergencyWarehouse);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTEmergencyWarehouseDao.deleteAllById(ids);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalenvironment/dao/CenterdataTEnvironmentKeyEnterpriseDao.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.dao;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentKeyEnterprise;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+public interface CenterdataTEnvironmentKeyEnterpriseDao extends ElasticsearchRepository<EnvironmentKeyEnterprise, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalenvironment/dao/CenterdataTEnvironmentSewageOutletDao.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.dao;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSewageOutlet;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+public interface CenterdataTEnvironmentSewageOutletDao extends ElasticsearchRepository<EnvironmentSewageOutlet, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalenvironment/dao/CenterdataTEnvironmentSourcePollutionDao.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.dao;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSourcePollution;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+public interface CenterdataTEnvironmentSourcePollutionDao extends ElasticsearchRepository<EnvironmentSourcePollution, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalenvironment/dao/CenterdataTEnvironmentWaterMonitorDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.dao;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentWaterMonitor;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface CenterdataTEnvironmentWaterMonitorDao extends ElasticsearchRepository<EnvironmentWaterMonitor, String> {
+
+}

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

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentKeyEnterprise;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+public interface ICenterdataTEnvironmentKeyEnterpriseService {
+
+    EnvironmentKeyEnterprise save(EnvironmentKeyEnterprise environmentKeyEnterprise);
+}

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

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSewageOutlet;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+public interface ICenterdataTEnvironmentSewageOutletService {
+
+    EnvironmentSewageOutlet save(EnvironmentSewageOutlet environmentSewageOutlet);
+}

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

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSourcePollution;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+public interface ICenterdataTEnvironmentSourcePollutionService {
+
+    EnvironmentSourcePollution save(EnvironmentSourcePollution environmentSourcePollution);
+}

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

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentWaterMonitor;
+
+/**
+ * @author hanfucheng
+ * @date 2023/8/7 13:47
+ */
+public interface ICenterdataTEnvironmentWaterMonitorService {
+
+    EnvironmentWaterMonitor save(EnvironmentWaterMonitor environmentWaterMonitor);
+}

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

@@ -0,0 +1,26 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service.impl;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentKeyEnterprise;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentKeyEnterpriseDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentKeyEnterpriseService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+@Service
+public class CenterdataTEnvironmentKeyEnterpriseServiceImpl implements ICenterdataTEnvironmentKeyEnterpriseService {
+
+    @Autowired
+    private CenterdataTEnvironmentKeyEnterpriseDao centerdataTEnvironmentKeyEnterpriseDao;
+
+    @Override
+    public EnvironmentKeyEnterprise save(EnvironmentKeyEnterprise environmentKeyEnterprise) {
+        environmentKeyEnterprise.setLocation(new GeoPoint(Double.valueOf(environmentKeyEnterprise.getLatitude()), Double.valueOf(environmentKeyEnterprise.getLongitude())));
+        centerdataTEnvironmentKeyEnterpriseDao.save(environmentKeyEnterprise);
+        return environmentKeyEnterprise;
+    }
+}

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

@@ -0,0 +1,30 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSewageOutlet;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentSewageOutletDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentSewageOutletService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+@Service
+public class CenterdataTEnvironmentSewageOutletServiceImpl implements ICenterdataTEnvironmentSewageOutletService {
+
+    @Autowired
+    private CenterdataTEnvironmentSewageOutletDao centerdataTEnvironmentSewageOutletDao;
+
+    @Override
+    public EnvironmentSewageOutlet save(EnvironmentSewageOutlet environmentSewageOutlet) {
+        environmentSewageOutlet.setLocation(new GeoPoint(Double.valueOf(environmentSewageOutlet.getLatitude()), Double.valueOf(environmentSewageOutlet.getLongitude())));
+        environmentSewageOutlet.setSewageOneClassificationLabel(DictUtils.getDictDataByValue("centerdata_sewage_oneclassification",environmentSewageOutlet.getSewageOneClassification()));
+        environmentSewageOutlet.setSewageTwoClassificationLabel(DictUtils.getDictDataByValue("centerdata_sewage_twoclassification",environmentSewageOutlet.getSewageTwoClassification()));
+        environmentSewageOutlet.setTypeLabel(DictUtils.getDictDataByValue("centerdata_sewage_type",environmentSewageOutlet.getType()));
+        centerdataTEnvironmentSewageOutletDao.save(environmentSewageOutlet);
+        return environmentSewageOutlet;
+    }
+}

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

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentSourcePollution;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentSourcePollutionDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentSourcePollutionService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+@Service
+public class CenterdataTEnvironmentSourcePollutionServiceImpl implements ICenterdataTEnvironmentSourcePollutionService {
+
+    @Autowired
+    private CenterdataTEnvironmentSourcePollutionDao centerdataTEnvironmentSourcePollutionDao;
+
+    @Override
+    public EnvironmentSourcePollution save(EnvironmentSourcePollution environmentSourcePollution) {
+        environmentSourcePollution.setLocation(new GeoPoint(Double.valueOf(environmentSourcePollution.getLatitude()), Double.valueOf(environmentSourcePollution.getLongitude())));
+        environmentSourcePollution.setTypeLabel(DictUtils.getDictDataByValue("centerdata_sourcepollution_type", String.valueOf(environmentSourcePollution.getType())));
+        centerdataTEnvironmentSourcePollutionDao.save(environmentSourcePollution);
+        return environmentSourcePollution;
+    }
+}

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

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service.impl;
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentWaterMonitor;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentWaterMonitorDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentWaterMonitorService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author hanfucheng
+ * @date 2023/8/7 13:47
+ */
+@Service
+public class CenterdataTEnvironmentWaterMonitorServiceImpl implements ICenterdataTEnvironmentWaterMonitorService {
+
+    @Autowired
+    private CenterdataTEnvironmentWaterMonitorDao centerdataTEnvironmentWaterMonitorDao;
+
+    @Override
+    public EnvironmentWaterMonitor save(EnvironmentWaterMonitor environmentWaterMonitor) {
+        environmentWaterMonitor.setLocation(new GeoPoint(Double.parseDouble(environmentWaterMonitor.getLatitude()), Double.parseDouble(environmentWaterMonitor.getLongitude())));
+        environmentWaterMonitor.setCycleLabel(DictUtils.getDictDataByValue("centerdata_monitor_cycle", String.valueOf(environmentWaterMonitor.getCycle())));
+        centerdataTEnvironmentWaterMonitorDao.save(environmentWaterMonitor);
+        return environmentWaterMonitor;
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/BasicLinkageForceDao.java

@@ -0,0 +1,14 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.BasicLinkageForce;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * 基本联动力量管理对象 centerdata_t_firecontrol_basic_linkage_force
+ *
+ * @author lyq
+ * @date 2022-10-31
+ */
+public interface BasicLinkageForceDao extends ElasticsearchRepository<BasicLinkageForce, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/FireFoamLiquidDao.java

@@ -0,0 +1,14 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireFoamLiquid;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * 泡沫液管理对象 centerdata_t_firecontrol_foam_liquid
+ *
+ * @author lyq
+ * @date 2022-11-03
+ */
+public interface FireFoamLiquidDao extends ElasticsearchRepository<FireFoamLiquid, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/FireForceDao.java

@@ -0,0 +1,14 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireForce;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * 消防力量管理对象 centerdata_t_firecontrol_fire_force
+ *
+ * @author lyq
+ * @date 2022-10-31
+ */
+public interface FireForceDao extends ElasticsearchRepository<FireForce, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/FireFulltimeStationDao.java

@@ -0,0 +1,14 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireFulltimeStation;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * 专职站管理对象 centerdata_t_firecontrol_fulltime_station
+ *
+ * @author lyq
+ * @date 2022-11-03
+ */
+public interface FireFulltimeStationDao extends ElasticsearchRepository<FireFulltimeStation, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/FireKeyPlacesDao.java

@@ -0,0 +1,14 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireKeyPlaces;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * 重点场所管理对象 centerdata_t_firecontrol_fire_key_places
+ *
+ * @author ruoyi
+ * @date 2023-02-25
+ */
+public interface FireKeyPlacesDao extends ElasticsearchRepository<FireKeyPlaces, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/FireOtherLinkageForceDao.java

@@ -0,0 +1,14 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireOtherLinkageForce;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+/**
+ * 其他联动力量管理对象 centerdata_t_firecontrol_other_linkage_force
+ *
+ * @author lyq
+ * @date 2022-10-31
+ */
+public interface FireOtherLinkageForceDao extends ElasticsearchRepository<FireOtherLinkageForce, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/dao/FirePressureSensorDao.java

@@ -0,0 +1,8 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.dao;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FirePressureSensor;
+import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
+
+public interface FirePressureSensorDao extends ElasticsearchRepository<FirePressureSensor, String> {
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/service/IBasicLinkageForceService.java

@@ -0,0 +1,19 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.service;
+
+import com.sooka.sponest.data.api.digitalfire.domain.BasicLinkageForce;
+
+import java.util.List;
+
+public interface IBasicLinkageForceService {
+
+    /**
+     * 批量新增
+     *
+     * @param basicLinkageForces
+     * @return
+     */
+    void save(BasicLinkageForce basicLinkageForces);
+
+    void deleteAllById(List<String> ids);
+}
+

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/service/IFireFoamLiquidService.java

@@ -0,0 +1,18 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.service;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireFoamLiquid;
+
+import java.util.List;
+
+public interface IFireFoamLiquidService {
+
+    /**
+     * 批量新增
+     *
+     * @param fireFoamLiquids
+     * @return
+     */
+    void save(FireFoamLiquid fireFoamLiquids);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/service/IFireForceService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.service;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireForce;
+
+import java.util.List;
+
+public interface IFireForceService {
+
+    void save(FireForce fireForces);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/service/IFireFultimeStationService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.service;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireFulltimeStation;
+
+import java.util.List;
+
+public interface IFireFultimeStationService {
+
+    void save(FireFulltimeStation fireFulltimeStations);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/service/IFireKeyPlacesService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.service;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireKeyPlaces;
+
+import java.util.List;
+
+public interface IFireKeyPlacesService {
+
+    void save(FireKeyPlaces fireKeyPlaces);
+
+    void deleteAllById(List<String> ids);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalfirecontrol/service/IFireOtherLinkageForceService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalfirecontrol.service;
+
+import com.sooka.sponest.data.api.digitalfire.domain.FireOtherLinkageForce;
+
+import java.util.List;
+
+public interface IFireOtherLinkageForceService {
+
+    void save(FireOtherLinkageForce fireOtherLinkageForces);
+
+    void deleteAllById(List<String> ids);
+}