es

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

@@ -9,20 +9,13 @@ 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.EmergencyPatrolpoint;
 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.digitalenvironment.domain.*;
 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.digitalforest.domain.*;
+import com.sooka.sponest.data.api.digitalresource.domain.*;
 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;
@@ -31,28 +24,19 @@ 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.dao.CenterdataTEmergencyPatrolpointDao;
 import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyEnterprisesService;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyPatrolpointService;
 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.digitalenvironment.dao.*;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.*;
 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.digitalforest.dao.CheckpointDao;
+import com.sooka.sponest.middleware.data.digitalforest.dao.WeatherstationDao;
+import com.sooka.sponest.middleware.data.digitalforest.service.*;
+import com.sooka.sponest.middleware.data.digitalresource.dao.*;
+import com.sooka.sponest.middleware.data.digitalresource.service.*;
 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;
@@ -151,6 +135,22 @@ public class DataListener {
                     SpringUtils.getBean(IKeyFireproofPlotsDaoService.class).save(keyFireproofPlots);
                 }
                 break;
+            case DocumentNameConstants.FOREST_WEATHERSTATION:// 气象站
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(WeatherstationDao.class).deleteAllById(result);
+                } else {
+                    Weatherstation weatherstation = JSON.parseObject(dataBO.getModelStr(), Weatherstation.class);
+                    SpringUtils.getBean(IWeatherstationDaoService.class).save(weatherstation);
+                }
+                break;
+            case DocumentNameConstants.FOREST_CHECKPOINT:// 防火检查站
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(CheckpointDao.class).deleteAllById(result);
+                } else {
+                    Checkpoint checkpoint = JSON.parseObject(dataBO.getModelStr(), Checkpoint.class);
+                    SpringUtils.getBean(ICheckpointDaoService.class).save(checkpoint);
+                }
+                break;
             // 数字农业
             case DocumentNameConstants.FARM_AGRICULTURAL_COOPERATIVES:// 农业合作社
                 if (dataBO.getType().equals(BusinessType.DELETE)) {
@@ -256,6 +256,22 @@ public class DataListener {
                     SpringUtils.getBean(ICenterdataTFarmCollectiveFarmlandService.class).save(farmCollectiveFarmland);
                 }
                 break;
+            case DocumentNameConstants.FARM_LIVESTOCK_PROTECT_INFO:// 畜保站
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmLivestockProtectInfoService.class).deleteAllById(result);
+                } else {
+                    FarmLivestockProtectInfo farmLivestockProtectInfo = JSON.parseObject(dataBO.getModelStr(), FarmLivestockProtectInfo.class);
+                    SpringUtils.getBean(ICenterdataTFarmLivestockProtectInfoService.class).save(farmLivestockProtectInfo);
+                }
+                break;
+            case DocumentNameConstants.FARM_BREED_RESOURCES:// 养殖资源
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(ICenterdataTFarmBreedResourcesService.class).deleteAllById(result);
+                } else {
+                    FarmBreedResources farmBreedResources = JSON.parseObject(dataBO.getModelStr(), FarmBreedResources.class);
+                    SpringUtils.getBean(ICenterdataTFarmBreedResourcesService.class).save(farmBreedResources);
+                }
+                break;
             // 数字水利
             case DocumentNameConstants.HYDRAULIC_BATTLEFIELD:// 沙场资源
                 if (BusinessType.DELETE.equals(dataBO.getType())) {
@@ -362,6 +378,38 @@ public class DataListener {
                     SpringUtils.getBean(ICenterdataTEnvironmentWaterMonitorService.class).save(environmentWaterMonitor);
                 }
                 break;
+            case DocumentNameConstants.ENVIRONMENT_PROHIBITION_AREA:// 禁烧区管理
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentProhibitionAreaDao.class).deleteAllById(result);
+                } else {
+                    EnvironmentProhibitionArea environmentProhibitionArea = JSON.parseObject(dataBO.getModelStr(), EnvironmentProhibitionArea.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentProhibitionAreaService.class).save(environmentProhibitionArea);
+                }
+                break;
+            case DocumentNameConstants.ENVIRONMENT_BIGGAS1:// 大气监测点管理
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentBiggasDao.class).deleteAllById(result);
+                } else {
+                    EnvironmentBiggas environmentBiggas = JSON.parseObject(dataBO.getModelStr(), EnvironmentBiggas.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).save(environmentBiggas);
+                }
+                break;
+            case DocumentNameConstants.ENVIRONMENT_BIGGAS2:// 水质监测点管理
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentBiggas2Dao.class).deleteAllById(result);
+                } else {
+                    EnvironmentBiggas environmentBiggas = JSON.parseObject(dataBO.getModelStr(), EnvironmentBiggas.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).save(environmentBiggas);
+                }
+                break;
+            case DocumentNameConstants.ENVIRONMENT_BIGGAS3:// 污染源监测点管理
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(CenterdataTEnvironmentBiggas3Dao.class).deleteAllById(result);
+                } else {
+                    EnvironmentBiggas environmentBiggas = JSON.parseObject(dataBO.getModelStr(), EnvironmentBiggas.class);
+                    SpringUtils.getBean(ICenterdataTEnvironmentBiggasService.class).save(environmentBiggas);
+                }
+                break;
             // 数字应急
             case DocumentNameConstants.EMERGENCY_WAREHOUSE:// 应急仓库
                 if (dataBO.getType().equals(BusinessType.DELETE)) {
@@ -387,6 +435,14 @@ public class DataListener {
                     SpringUtils.getBean(ICenterdataTEmergencyEnterprisesService.class).save(emergencyEnterprises);
                 }
                 break;
+            case DocumentNameConstants.EMERGENCY_PATROLPOINT:// 巡更点
+                if (dataBO.getType().equals(BusinessType.DELETE)) {
+                    SpringUtils.getBean(CenterdataTEmergencyPatrolpointDao.class).deleteAllById(result);
+                } else {
+                    EmergencyPatrolpoint emergencyPatrolpoint = JSON.parseObject(dataBO.getModelStr(), EmergencyPatrolpoint.class);
+                    SpringUtils.getBean(ICenterdataTEmergencyPatrolpointService.class).save(emergencyPatrolpoint);
+                }
+                break;
             // 数字交通
             case DocumentNameConstants.TRAFFIC_WARNING_SIGN:// 警示牌资源
                 if (BusinessType.DELETE.equals(dataBO.getType())) {
@@ -437,6 +493,30 @@ public class DataListener {
                     SpringUtils.getBean(IIllegalConstructionService.class).save(illegalConstruction);
                 }
                 break;
+            case DocumentNameConstants.RESOURCES_LAND:// 土地资源管理信息
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(LandDao.class).deleteAllById(result);
+                } else {
+                    Land land = JSON.parseObject(dataBO.getModelStr(), Land.class);
+                    SpringUtils.getBean(ILandService.class).save(land);
+                }
+                break;
+            case DocumentNameConstants.RESOURCES_FOREST:// 森林资源管理信息
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(ForestDao.class).deleteAllById(result);
+                } else {
+                    Forest forest = JSON.parseObject(dataBO.getModelStr(), Forest.class);
+                    SpringUtils.getBean(IForestService.class).save(forest);
+                }
+                break;
+            case DocumentNameConstants.RESOURCES_HYDROENERGY:// 水能资源信息
+                if (BusinessType.DELETE.equals(dataBO.getType())) {
+                    SpringUtils.getBean(HydroenergyDao.class).deleteAllById(result);
+                } else {
+                    Hydroenergy hydroenergy = JSON.parseObject(dataBO.getModelStr(), Hydroenergy.class);
+                    SpringUtils.getBean(IHydroenergyService.class).save(hydroenergy);
+                }
+                break;
             // 数字消防
             case DocumentNameConstants.FIRECONTROL_FIRE_FORCE:// 消防力量管理
                 if (dataBO.getType().equals(BusinessType.DELETE)) {

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

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

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

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

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

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

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

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

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

@@ -0,0 +1,31 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmBreedResources;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmLivestockProtectInfo;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmBreedResourcesDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmExcrementDisposeDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmBreedResourcesService;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmLivestockProtectInfoService;
+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 ICenterdataTFarmBreedResourcesServiceImpl implements ICenterdataTFarmBreedResourcesService {
+
+    @Autowired
+    private CenterdataTFarmBreedResourcesDao centerdataTFarmBreedResourcesDao;
+
+    @Override
+    public void save(FarmBreedResources farmBreedResources) {
+        farmBreedResources.setLocation(new GeoPoint(Double.valueOf(farmBreedResources.getLatitude()), Double.valueOf(farmBreedResources.getLongitude())));
+        centerdataTFarmBreedResourcesDao.save(farmBreedResources);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmBreedResourcesDao.deleteAllById(ids);
+    }
+}

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

@@ -0,0 +1,32 @@
+package com.sooka.sponest.middleware.data.digitalagriculture.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmExcrementDispose;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmLivestockProtectInfo;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmBreedResourcesDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmExcrementDisposeDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.dao.CenterdataTFarmLivestockProtectInfoDao;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmExcrementDisposeService;
+import com.sooka.sponest.middleware.data.digitalagriculture.service.ICenterdataTFarmLivestockProtectInfoService;
+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 ICenterdataTFarmLivestockProtectInfoServiceImpl implements ICenterdataTFarmLivestockProtectInfoService {
+
+    @Autowired
+    private CenterdataTFarmLivestockProtectInfoDao centerdataTFarmLivestockProtectInfoDao;
+
+    @Override
+    public void save(FarmLivestockProtectInfo farmLivestockProtectInfo) {
+        farmLivestockProtectInfo.setLocation(new GeoPoint(Double.valueOf(farmLivestockProtectInfo.getLatitude()), Double.valueOf(farmLivestockProtectInfo.getLongitude())));
+        centerdataTFarmLivestockProtectInfoDao.save(farmLivestockProtectInfo);
+    }
+
+    @Override
+    public void deleteAllById(List<String> ids) {
+        centerdataTFarmLivestockProtectInfoDao.deleteAllById(ids);
+    }
+}

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

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

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

@@ -0,0 +1,11 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyPatrolpoint;
+
+import java.util.List;
+
+public interface ICenterdataTEmergencyPatrolpointService {
+
+    void save(EmergencyPatrolpoint emergencyPatrolpoint);
+
+}

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

@@ -0,0 +1,22 @@
+package com.sooka.sponest.middleware.data.digitalemergency.service.impl;
+
+import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyPatrolpoint;
+import com.sooka.sponest.middleware.data.digitalemergency.dao.CenterdataTEmergencyPatrolpointDao;
+import com.sooka.sponest.middleware.data.digitalemergency.service.ICenterdataTEmergencyPatrolpointService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+@Service
+public class CenterdataTEmergencyPatrolpointServiceImpl implements ICenterdataTEmergencyPatrolpointService {
+
+    @Autowired
+    private CenterdataTEmergencyPatrolpointDao centerdataTEmergencyPatrolpointDao;
+
+    @Override
+    public void save(EmergencyPatrolpoint emergencyPatrolpoint) {
+        emergencyPatrolpoint.setLocation(new GeoPoint(Double.valueOf(emergencyPatrolpoint.getLatitude()), Double.valueOf(emergencyPatrolpoint.getLongitude())));
+        centerdataTEmergencyPatrolpointDao.save(emergencyPatrolpoint);
+    }
+
+}

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

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

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

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

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

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

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

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

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

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

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

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

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

@@ -0,0 +1,53 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service.impl;
+
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise2;
+import com.sooka.sponest.data.api.digitalagriculture.domain.FarmEnterprise3;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentBiggas;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentBiggas2;
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentBiggas3;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentBiggas2Dao;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentBiggas3Dao;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentBiggasDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentBiggasService;
+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;
+
+/**
+ * @author zhaozhan
+ * @date 2023/7/21
+ */
+@Service
+public class CenterdataTEnvironmentBiggasServiceImpl implements ICenterdataTEnvironmentBiggasService {
+
+    @Autowired
+    private CenterdataTEnvironmentBiggasDao centerdataTEnvironmentBiggasDao;
+    @Autowired
+    private CenterdataTEnvironmentBiggas2Dao centerdataTEnvironmentBiggas2Dao;
+    @Autowired
+    private CenterdataTEnvironmentBiggas3Dao centerdataTEnvironmentBiggas3Dao;
+
+    @Override
+    public void save(EnvironmentBiggas environmentBiggas) {
+        environmentBiggas.setLocation(new GeoPoint(Double.valueOf(environmentBiggas.getLatitude()), Double.valueOf(environmentBiggas.getLongitude())));
+        String type = environmentBiggas.getType();
+        switch (type) {
+            case "1":
+                centerdataTEnvironmentBiggasDao.save(environmentBiggas);
+                break;
+            case "2":
+                EnvironmentBiggas2 environmentBiggas2 = new EnvironmentBiggas2();
+                BeanUtils.copyProperties(environmentBiggas, environmentBiggas2);
+                centerdataTEnvironmentBiggas2Dao.save(environmentBiggas2);
+                break;
+            case "3":
+                EnvironmentBiggas3 environmentBiggas3 = new EnvironmentBiggas3();
+                BeanUtils.copyProperties(environmentBiggas, environmentBiggas3);
+                centerdataTEnvironmentBiggas3Dao.save(environmentBiggas3);
+                break;
+            default:
+                break;
+        }
+    }
+}

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

@@ -0,0 +1,25 @@
+package com.sooka.sponest.middleware.data.digitalenvironment.service.impl;
+
+import com.sooka.sponest.data.api.digitalenvironment.domain.EnvironmentProhibitionArea;
+import com.sooka.sponest.middleware.data.digitalenvironment.dao.CenterdataTEnvironmentProhibitionAreaDao;
+import com.sooka.sponest.middleware.data.digitalenvironment.service.ICenterdataTEnvironmentProhibitionAreaService;
+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 CenterdataTEnvironmentProhibitionAreaServiceImpl implements ICenterdataTEnvironmentProhibitionAreaService {
+
+    @Autowired
+    private CenterdataTEnvironmentProhibitionAreaDao centerdataTEnvironmentProhibitionAreaDao;
+
+    @Override
+    public void save(EnvironmentProhibitionArea environmentProhibitionArea) {
+        environmentProhibitionArea.setLocation(new GeoPoint(Double.valueOf(environmentProhibitionArea.getLatitude()), Double.valueOf(environmentProhibitionArea.getLongitude())));
+        centerdataTEnvironmentProhibitionAreaDao.save(environmentProhibitionArea);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalforest/dao/CheckpointDao.java

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

src/main/java/com/sooka/sponest/middleware/data/digitalforest/dao/WeatherstationDao.java

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

src/main/java/com/sooka/sponest/middleware/data/digitalforest/service/ICheckpointDaoService.java

@@ -0,0 +1,15 @@
+package com.sooka.sponest.middleware.data.digitalforest.service;
+
+import com.sooka.sponest.data.api.digitalforest.domain.Checkpoint;
+
+public interface ICheckpointDaoService {
+
+    /**
+     * 新增
+     *
+     * @param checkpoint
+     * @return
+     */
+    void save(Checkpoint checkpoint);
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalforest/service/IWeatherstationDaoService.java

@@ -0,0 +1,15 @@
+package com.sooka.sponest.middleware.data.digitalforest.service;
+
+import com.sooka.sponest.data.api.digitalforest.domain.Weatherstation;
+
+public interface IWeatherstationDaoService {
+
+    /**
+     * 新增
+     *
+     * @param weatherstation
+     * @return
+     */
+    void save(Weatherstation weatherstation);
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalforest/service/impl/CheckpointDaoServiceImpl.java

@@ -0,0 +1,26 @@
+package com.sooka.sponest.middleware.data.digitalforest.service.impl;
+
+import com.sooka.sponest.data.api.digitalforest.domain.Channel;
+import com.sooka.sponest.data.api.digitalforest.domain.Checkpoint;
+import com.sooka.sponest.middleware.data.digitalforest.dao.CheckpointDao;
+import com.sooka.sponest.middleware.data.digitalforest.service.ICheckpointDaoService;
+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 CheckpointDaoServiceImpl implements ICheckpointDaoService {
+
+
+    @Autowired
+    private CheckpointDao checkpointDao;
+
+    @Override
+    public void save(Checkpoint checkpoint) {
+        checkpoint.setLocation(new GeoPoint(Double.valueOf(checkpoint.getLatitude()), Double.valueOf(checkpoint.getLongitude())));
+        checkpointDao.save(checkpoint);
+    }
+
+}

src/main/java/com/sooka/sponest/middleware/data/digitalforest/service/impl/WeatherstationDaoServiceImpl.java

@@ -0,0 +1,25 @@
+package com.sooka.sponest.middleware.data.digitalforest.service.impl;
+
+import com.sooka.sponest.data.api.digitalforest.domain.Channel;
+import com.sooka.sponest.data.api.digitalforest.domain.Weatherstation;
+import com.sooka.sponest.middleware.data.digitalforest.dao.WeatherstationDao;
+import com.sooka.sponest.middleware.data.digitalforest.service.IWeatherstationDaoService;
+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 WeatherstationDaoServiceImpl implements IWeatherstationDaoService {
+
+
+    @Autowired
+    private WeatherstationDao weatherstationDao;
+
+    @Override
+    public void save(Weatherstation weatherstation) {
+        weatherstation.setLocation(new GeoPoint(Double.valueOf(weatherstation.getLatitude()), Double.valueOf(weatherstation.getLongitude())));
+        weatherstationDao.save(weatherstation);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalresource/dao/ForestDao.java

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

src/main/java/com/sooka/sponest/middleware/data/digitalresource/dao/HydroenergyDao.java

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

src/main/java/com/sooka/sponest/middleware/data/digitalresource/dao/LandDao.java

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

src/main/java/com/sooka/sponest/middleware/data/digitalresource/service/IForestService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalresource.service;
+
+import com.sooka.sponest.data.api.digitalresource.domain.Forest;
+
+/**
+ * @author lidongyu
+ * @date 2023/7/26
+ */
+public interface IForestService {
+
+    void save(Forest forest);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalresource/service/IHydroenergyService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalresource.service;
+
+import com.sooka.sponest.data.api.digitalresource.domain.Hydroenergy;
+
+/**
+ * @author lidongyu
+ * @date 2023/7/26
+ */
+public interface IHydroenergyService {
+
+    void save(Hydroenergy hydroenergy);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalresource/service/ILandService.java

@@ -0,0 +1,12 @@
+package com.sooka.sponest.middleware.data.digitalresource.service;
+
+import com.sooka.sponest.data.api.digitalresource.domain.Land;
+
+/**
+ * @author lidongyu
+ * @date 2023/7/26
+ */
+public interface ILandService {
+
+    void save(Land land);
+}

src/main/java/com/sooka/sponest/middleware/data/digitalresource/service/impl/ForestServiceImpl.java

@@ -0,0 +1,30 @@
+package com.sooka.sponest.middleware.data.digitalresource.service.impl;
+
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalresource.domain.Deposit;
+import com.sooka.sponest.data.api.digitalresource.domain.Forest;
+import com.sooka.sponest.middleware.data.digitalresource.dao.DepositDao;
+import com.sooka.sponest.middleware.data.digitalresource.dao.ForestDao;
+import com.sooka.sponest.middleware.data.digitalresource.service.IDepositService;
+import com.sooka.sponest.middleware.data.digitalresource.service.IForestService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lidongyu
+ * @date 2023/7/26
+ */
+@Service
+public class ForestServiceImpl implements IForestService {
+
+    @Autowired
+    private ForestDao forestDao;
+
+    @Override
+    public void save(Forest forest) {
+        forest.setLocation(new GeoPoint(Double.valueOf(forest.getLatitude()), Double.valueOf(forest.getLongitude())));
+        forestDao.save(forest);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalresource/service/impl/HydroenergyServiceImpl.java

@@ -0,0 +1,28 @@
+package com.sooka.sponest.middleware.data.digitalresource.service.impl;
+
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalresource.domain.Hydroenergy;
+import com.sooka.sponest.middleware.data.digitalresource.dao.HydroenergyDao;
+import com.sooka.sponest.middleware.data.digitalresource.service.IHydroenergyService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lidongyu
+ * @date 2023/7/26
+ */
+@Service
+public class HydroenergyServiceImpl implements IHydroenergyService {
+
+    @Autowired
+    private HydroenergyDao hydroenergyDao;
+
+    @Override
+    public void save(Hydroenergy hydroenergy) {
+        hydroenergy.setLocation(new GeoPoint(Double.valueOf(hydroenergy.getLatitude()), Double.valueOf(hydroenergy.getLongitude())));
+        hydroenergy.setHydroenergyTypeLabel(DictUtils.getDictDataByValue("centerdata_hydroenergy_type",hydroenergy.getHydroenergyType()));
+        hydroenergyDao.save(hydroenergy);
+    }
+}

src/main/java/com/sooka/sponest/middleware/data/digitalresource/service/impl/LandServiceImpl.java

@@ -0,0 +1,29 @@
+package com.sooka.sponest.middleware.data.digitalresource.service.impl;
+
+
+import com.ruoyi.common.security.utils.DictUtils;
+import com.sooka.sponest.data.api.digitalresource.domain.Deposit;
+import com.sooka.sponest.data.api.digitalresource.domain.Land;
+import com.sooka.sponest.middleware.data.digitalresource.dao.LandDao;
+import com.sooka.sponest.middleware.data.digitalresource.service.ILandService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.elasticsearch.core.geo.GeoPoint;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author lidongyu
+ * @date 2023/7/26
+ */
+@Service
+public class LandServiceImpl implements ILandService {
+
+    @Autowired
+    private LandDao landDao;
+
+    @Override
+    public void save(Land land) {
+        land.setLocation(new GeoPoint(Double.valueOf(land.getLatitude()), Double.valueOf(land.getLongitude())));
+        land.setLandTypeLabel(DictUtils.getDictDataByValue("centerdata_landType",land.getLandType()));
+        landDao.save(land);
+    }
+}