补贴统计村汇总

huimv-cattle/src/main/java/com/huimv/cattle/controller/SubsidyCountController.java

@@ -1,6 +1,8 @@
 package com.huimv.cattle.controller;
 
 
+import com.huimv.cattle.pojo.DataSource;
+import com.huimv.cattle.service.DataSourceService;
 import com.huimv.cattle.service.SubsidyCountService;
 import com.huimv.common.utils.Result;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,11 +25,23 @@ import java.util.Map;
 public class SubsidyCountController {
     @Autowired
     private SubsidyCountService subsidyCountService;
+    @Autowired
+    private DataSourceService dataSourceService;
 
     @PostMapping("/getSubsidyCount")
     public Result getSubsidyCount(HttpServletRequest request, @RequestBody Map<String, String> paramsMap){
         return subsidyCountService.getSubsidyCount(request,paramsMap);
     }
+    @PostMapping("/getSubsidyCountScreen")
+    public Result getSubsidyCountScreen(HttpServletRequest request, @RequestBody Map<String, String> paramsMap){
+        DataSource dataSource = dataSourceService.getDataSourceStatus();
+        if (dataSource.getDsStatus() == 1 && dataSource.getViewType() == 3){
+            return subsidyCountService.getSubsidyCountScreen(request,paramsMap);
+        }else {
+            return subsidyCountService.getSubsidyCount(request,paramsMap);
+        }
+
+    }
 
     @PostMapping("/saveSubsidyCount")
     public Result saveSubsidyCount(HttpServletRequest request, @RequestBody Map<String, String> paramsMap){

huimv-cattle/src/main/java/com/huimv/cattle/mapper/SubsidyCountMapper.java

@@ -1,5 +1,7 @@
 package com.huimv.cattle.mapper;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
 import com.huimv.cattle.pojo.SubsidyCount;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Param;
@@ -19,4 +21,6 @@ import java.util.List;
 public interface SubsidyCountMapper extends BaseMapper<SubsidyCount> {
 
     void deleteAll(@Param("farmCode") String farmCode);
+
+    List<SubsidyCount> getSubsidyCountScreen(String[] farmCode,@Param(Constants.WRAPPER) QueryWrapper<SubsidyCount> queryWrapper);
 }

huimv-cattle/src/main/java/com/huimv/cattle/mapper/xml/SubsidyCountMapper.xml

@@ -19,4 +19,14 @@
         delete from subsidy_count where farm_code = #{farmCode}
     </delete>
 
+    <select id="getSubsidyCountScreen" resultType="com.huimv.cattle.pojo.SubsidyCount">
+        SELECT YEAR,SUM(subsidy_count) subsidyCount,farm_code farmCode FROM `subsidy_count`
+        WHERE farm_code IN
+        <foreach collection="farmCode"   item="cityCode" open="(" separator="," close=")">
+            #{cityCode}
+        </foreach>
+        GROUP BY YEAR
+        ${ew.customSqlSegment}
+    </select>
+
 </mapper>

huimv-cattle/src/main/java/com/huimv/cattle/service/SubsidyCountService.java

@@ -20,4 +20,6 @@ public interface SubsidyCountService extends IService<SubsidyCount> {
     Result getSubsidyCount(HttpServletRequest request, Map<String, String> paramsMap);
 
     Result saveSubsidyCount(HttpServletRequest request, Map<String, String> paramsMap);
+
+    Result getSubsidyCountScreen(HttpServletRequest request, Map<String, String> paramsMap);
 }

huimv-cattle/src/main/java/com/huimv/cattle/service/impl/SubsidyCountServiceImpl.java

@@ -4,6 +4,7 @@ import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huimv.cattle.mapper.SysRegionCounTownVillMapper;
 import com.huimv.cattle.pojo.IndustryOutput;
 import com.huimv.cattle.pojo.SubsidyCount;
 import com.huimv.cattle.mapper.SubsidyCountMapper;
@@ -34,6 +35,8 @@ import java.util.*;
 public class SubsidyCountServiceImpl extends ServiceImpl<SubsidyCountMapper, SubsidyCount> implements SubsidyCountService {
     @Autowired
     private SubsidyCountMapper subsidyCountMapper;
+    @Autowired
+    private SysRegionCounTownVillMapper sysRegionCounTownVillMapper;
 
     @Autowired
     private DateUtil dateUtil;
@@ -94,6 +97,33 @@ public class SubsidyCountServiceImpl extends ServiceImpl<SubsidyCountMapper, Sub
         return new Result(ResultCode.SUCCESS);
     }
 
+    @Override
+    public Result getSubsidyCountScreen(HttpServletRequest request, Map<String, String> paramsMap) {
+        String farmCode = paramsMap.get("farmCode");
+        if (StringUtils.isBlank(farmCode)) {
+            farmCode = TokenSign.getFarmCode(request);
+        }
+        String[] city = sysRegionCounTownVillMapper.listSub(farmCode).split(",");
+        String yearNum = paramsMap.get("yearNum");
+        QueryWrapper<SubsidyCount> queryWrapper = new QueryWrapper<SubsidyCount>();
+        if(StringUtils.isNotBlank(yearNum)) {
+            queryWrapper.between("year", Integer.valueOf(dateUtil.getThisYear()) - Integer.valueOf(yearNum), Integer.valueOf(dateUtil.getThisYear()));
+            //        queryWrapper.last("LIMIT "+yearNum);
+        }
+        queryWrapper.orderByDesc("year");
+
+        List<SubsidyCount> subsidyCounts = subsidyCountMapper.getSubsidyCountScreen(city,queryWrapper);
+        if (ObjectUtil.isEmpty(subsidyCounts)) {
+            SubsidyCount subsidyCount1 = new SubsidyCount();
+            subsidyCount1.setYear(Integer.valueOf(dateUtil.getThisYear()));
+            subsidyCount1.setSubsidyCount(BigDecimal.ZERO);
+            subsidyCount1.setFarmCode(farmCode);
+            subsidyCounts.add(subsidyCount1);
+            subsidyCountMapper.insert(subsidyCount1);
+        }
+        return new Result(ResultCode.SUCCESS, subsidyCounts);
+    }
+
     private Boolean checkRepeat(List<SubsidyCount> list) {
         List<Integer> collectionOptionList = new ArrayList<>();
         for (SubsidyCount a : list) {