农村集体耕地

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

@@ -216,6 +216,14 @@ public class DataListener {
                     SpringUtils.getBean(ICenterdataTFarmGreenhouseFilmInfoService.class).save(centerdataTEnvironmentSewageOutlet);
                 }
                 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())) {

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