数字农业增加可视化

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

@@ -216,6 +216,38 @@ public class DataListener {
                     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);

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/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/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/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/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/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/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/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/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);
+    }
+}