大数据中台，数字资源

src/main/java/com/sooka/sponest/data/digitalresource/controller/ResourceBigDataController.java

@@ -4,9 +4,7 @@ import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.web.controller.BaseController;
 import com.sooka.sponest.data.app.domain.VisuForestCloudMapVO;
 import com.sooka.sponest.data.digitalforest.domain.CenterdataTForestGrid;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesDeposit;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesGeologicHazard;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesIllegalConstruction;
+import com.sooka.sponest.data.digitalresource.domain.*;
 import com.sooka.sponest.data.digitalresource.service.IResourceBigDataService;
 import com.sooka.sponest.data.other.land.domain.CenterdataTResourcesLand;
 import io.swagger.annotations.Api;
@@ -117,4 +115,35 @@ public class ResourceBigDataController extends BaseController {
     public R getConstructionGroupByResourcesConservancy(@ApiIgnore CenterdataTResourcesIllegalConstruction centerdataTResourcesIllegalConstruction) {
         return R.ok(resourceBigDataService.getConstructionGroupByResourcesConservancy(centerdataTResourcesIllegalConstruction));
     }
+
+    /**
+     * 资源耕地
+     * @return
+     */
+    @ApiOperation(value = "查询资源耕地按耕地属性统计面积", notes = "查询资源耕地按耕地属性统计面积")
+    @PostMapping("/selectResourcesLandInfoCount")
+    public R selectResourcesLandInfoCount() {
+        CenterdataTResourcesLandInfo centerdataTResourcesLandInfo = new CenterdataTResourcesLandInfo();
+        return R.ok(resourceBigDataService.selectResourcesLandInfoCount(centerdataTResourcesLandInfo));
+    }
+    /**
+     * 永久基本农田
+     * @return
+     */
+    @ApiOperation(value = "查询永久基本农田按耕地属性统计面积", notes = "查询永久基本农田按耕地属性统计面积")
+    @PostMapping("/selectFarmBasicFarmlandCount")
+    public R selectFarmBasicFarmlandCount() {
+        CenterdataTFarmBasicFarmland centerdataTFarmBasicFarmland = new CenterdataTFarmBasicFarmland();
+        return R.ok(resourceBigDataService.selectFarmBasicFarmlandCount(centerdataTFarmBasicFarmland));
+    }
+
+    /**
+     * 地质灾害易发区
+     * @return
+     */
+    @ApiOperation("远端调用查询地质灾害易发区按类型")
+    @PostMapping("/getResourcesGeologicHazard")
+    public R getResourcesGeologicHazard() {
+        return R.ok(resourceBigDataService.selectResourcesGeologicHazard(new CenterdataTResourcesGeologicHazard()));
+    }
 }

src/main/java/com/sooka/sponest/data/digitalresource/mapper/DigitalResourcesBigDataMapper.java

@@ -3,9 +3,7 @@ package com.sooka.sponest.data.digitalresource.mapper;
 import com.sooka.sponest.data.app.domain.VisuForestCloudMapVO;
 import com.sooka.sponest.data.digitalforest.domain.CenterdataTForestGrid;
 import com.sooka.sponest.data.digitalforest.domain.bo.VisuForestCloudEventTypeBO;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesDeposit;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesGeologicHazard;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesIllegalConstruction;
+import com.sooka.sponest.data.digitalresource.domain.*;
 import com.sooka.sponest.data.other.land.domain.CenterdataTResourcesLand;
 
 import java.util.List;
@@ -68,4 +66,17 @@ public interface DigitalResourcesBigDataMapper {
      * @return
      */
     List getConstructionGroupByResourcesConservancy(CenterdataTResourcesIllegalConstruction centerdataTResourcesIllegalConstruction);
+
+    /**
+     * 资源耕地
+     * @return
+     */
+    List<Map<String, Object>> selectResourcesLandInfoCount(CenterdataTResourcesLandInfo centerdataTResourcesLandInfo);
+
+    /**
+     * 地质灾害易发区
+     * @param centerdataTFarmBasicFarmland
+     * @return
+     */
+    List<Map<String, Object>> selectFarmBasicFarmlandCount(CenterdataTFarmBasicFarmland centerdataTFarmBasicFarmland);
 }

src/main/java/com/sooka/sponest/data/digitalresource/service/IResourceBigDataService.java

@@ -4,9 +4,7 @@ import com.sooka.sponest.data.app.domain.VisuForestCloudMapVO;
 import com.sooka.sponest.data.base.service.IBaseService;
 import com.sooka.sponest.data.digitalforest.domain.CenterdataTForestGrid;
 import com.sooka.sponest.data.digitalforest.domain.bo.VisuForestCloudEventTypeBO;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesDeposit;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesGeologicHazard;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesIllegalConstruction;
+import com.sooka.sponest.data.digitalresource.domain.*;
 import com.sooka.sponest.data.other.land.domain.CenterdataTResourcesLand;
 
 import java.util.List;
@@ -72,4 +70,24 @@ public interface IResourceBigDataService extends IBaseService {
      * @return
      */
     List getConstructionGroupByResourcesConservancy(CenterdataTResourcesIllegalConstruction centerdataTResourcesIllegalConstruction);
+
+    /**
+     * 资源耕地
+     * @return
+     */
+    List<Map<String, Object>> selectResourcesLandInfoCount(CenterdataTResourcesLandInfo centerdataTResourcesLandInfo);
+
+    /**
+     * 永久基本农田
+     * @param centerdataTFarmBasicFarmland
+     * @return
+     */
+    List<Map<String, Object>> selectFarmBasicFarmlandCount(CenterdataTFarmBasicFarmland centerdataTFarmBasicFarmland);
+
+    /**
+     * 地质灾害易发区
+     * @param centerdataTResourcesGeologicHazard
+     * @return
+     */
+    List<Map<String, Object>> selectResourcesGeologicHazard(CenterdataTResourcesGeologicHazard centerdataTResourcesGeologicHazard);
 }

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

@@ -1,20 +1,24 @@
 package com.sooka.sponest.data.digitalresource.service.impl;
 
+import com.alibaba.fastjson.JSONArray;
+import com.ruoyi.common.core.utils.StringUtils;
 import com.ruoyi.common.datascope.annotation.DataScopeMutiDept;
 import com.sooka.sponest.data.app.domain.VisuForestCloudMapVO;
 import com.sooka.sponest.data.base.service.impl.BaseServiceImpl;
 import com.sooka.sponest.data.digitalforest.domain.CenterdataTForestGrid;
 import com.sooka.sponest.data.digitalforest.domain.bo.VisuForestCloudEventTypeBO;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesDeposit;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesGeologicHazard;
-import com.sooka.sponest.data.digitalresource.domain.CenterdataTResourcesIllegalConstruction;
+import com.sooka.sponest.data.digitalresource.domain.*;
 import com.sooka.sponest.data.digitalresource.mapper.DigitalResourcesBigDataMapper;
 import com.sooka.sponest.data.digitalresource.service.IResourceBigDataService;
 import com.sooka.sponest.data.digitalwater.domain.CenterdataTHydraulicOutletSewage;
+import com.sooka.sponest.data.digitalwater.domain.CenterdataTHydraulicPatrolTask;
 import com.sooka.sponest.data.other.land.domain.CenterdataTResourcesLand;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -128,4 +132,36 @@ public class ResourceBigDataServiceImpl extends BaseServiceImpl implements IReso
         setSookaDataBase(centerdataTResourcesIllegalConstruction);
         return digitalResourcesBigDataMapper.getConstructionGroupByResourcesConservancy(centerdataTResourcesIllegalConstruction);
     }
+
+    /**
+     * 资源耕地
+     * @return
+     */
+    @DataScopeMutiDept(deptAlias = "d")
+    @Override
+    public List<Map<String, Object>> selectResourcesLandInfoCount(CenterdataTResourcesLandInfo centerdataTResourcesLandInfo) {
+        setSookaDataBase(centerdataTResourcesLandInfo);
+        return digitalResourcesBigDataMapper.selectResourcesLandInfoCount(centerdataTResourcesLandInfo);
+    }
+    /**
+     * 永久基本农田
+     * @return
+     */
+    @DataScopeMutiDept(deptAlias = "d")
+    @Override
+    public List<Map<String, Object>> selectFarmBasicFarmlandCount(CenterdataTFarmBasicFarmland centerdataTFarmBasicFarmland) {
+        setSookaDataBase(centerdataTFarmBasicFarmland);
+        return digitalResourcesBigDataMapper.selectFarmBasicFarmlandCount(centerdataTFarmBasicFarmland);
+    }
+    /**
+     * 地质灾害易发区
+     * @return
+     */
+    @DataScopeMutiDept(deptAlias = "d")
+    @Override
+    public List<Map<String, Object>> selectResourcesGeologicHazard(CenterdataTResourcesGeologicHazard centerdataTResourcesGeologicHazard) {
+        setSookaDataBase(centerdataTResourcesGeologicHazard);
+        return digitalResourcesBigDataMapper.getHazardResources(centerdataTResourcesGeologicHazard);
+    }
+
 }

src/main/resources/mapper/digitalresource/DigitalResourcesBigDataMapper.xml

@@ -142,6 +142,24 @@
         <result property="attachId" column="attach_id"/>
 
     </resultMap>
+    <resultMap type="CenterdataTHydraulicPatrolTask" id="CenterdataTHydraulicPatrolTaskMap">
+        <result property="id" column="id"/>
+        <result property="taskName" column="task_name"/>
+        <result property="planId" column="plan_id"/>
+        <result property="planName" column="plan_name"/>
+        <result property="status" column="status"/>
+        <result property="deptId" column="dept_id"/>
+        <result property="deptName" column="dept_name"/>
+        <result property="dataStatus" column="data_status"/>
+        <result property="userId" column="user_id"/>
+        <result property="type" column="type"/>
+        <result property="planCount" column="plan_count"/>
+        <result property="recordCount" column="record_count"/>
+        <result property="patrolTrajectory" column="patrol_trajectory"/>
+        <result property="planLength" column="plan_length"/>
+        <result property="realLength" column="realLength"/>
+        <result property="leadType" column="lead_type"/>
+    </resultMap>
 
     <select id="selectDepositResourcesCount" parameterType="CenterdataTResourcesDeposit"
             resultType="java.util.Map">
@@ -265,4 +283,21 @@
         where dict.dict_type = 'centerdata_construction_type'
         group by a.construction_type
     </select>
+
+    <select id="selectResourcesLandInfoCount" parameterType="CenterdataTResourcesLandInfo"  resultType="java.util.Map">
+        select  dict.dict_label name,sum(a.area) value from centerdata_t_resources_land_info a
+        left join ${database_system}.sys_dict_data dict on dict.dict_value = a.attribute
+        left join ${database_system}.sys_dept d on a.dept_id=d.dept_id
+        where dict.dict_type = 'farm_field_attribute'
+        group by a.attribute
+    </select>
+
+    <select id="selectFarmBasicFarmlandCount" parameterType="CenterdataTFarmBasicFarmland" resultType="java.util.Map">
+        select dict.dict_label name,sum(a.area) value from centerdata_t_farm_basic_farmland a
+        left join ${database_system}.sys_dict_data dict on dict.dict_value = a.attribute
+        left join ${database_system}.sys_dept d on a.dept_id=d.dept_id
+        where dict.dict_type = 'farm_field_attribute'
+        group by a.attribute
+    </select>
+
 </mapper>