补贴统计 生产规模

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

@@ -1,10 +1,17 @@
 package com.huimv.cattle.controller;
 
 
+import com.huimv.cattle.service.ProductionCapacityService;
+import com.huimv.common.utils.Result;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Map;
+
 /**
  * <p>
  *  前端控制器
@@ -14,8 +21,20 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2022-12-15
  */
 @RestController
-@RequestMapping("/production-capacity")
+@RequestMapping("/v1.0.0/productionCapacity")
 public class ProductionCapacityController {
+    @Autowired
+    private ProductionCapacityService productionCapacityService;
+
+    @PostMapping("/getProductionCapacity")
+    public Result getProductionCapacity(@RequestBody Map<String, String> paramsMap){
+        return productionCapacityService.getProductionCapacity(paramsMap);
+    }
+
+    @PostMapping("/saveProductionCapacity")
+    public Result saveProductionCapacity(@RequestBody Map<String, String> paramsMap){
+        return productionCapacityService.saveProductionCapacity(paramsMap);
+    }
 
 }
 

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

@@ -1,10 +1,17 @@
 package com.huimv.cattle.controller;
 
 
+import com.huimv.cattle.service.SubsidyCountService;
+import com.huimv.common.utils.Result;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Map;
+
 /**
  * <p>
  *  前端控制器
@@ -14,8 +21,19 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2022-12-15
  */
 @RestController
-@RequestMapping("/subsidy-count")
+@RequestMapping("/v1.0.0/subsidyCount")
 public class SubsidyCountController {
+    @Autowired
+    private SubsidyCountService subsidyCountService;
+
+    @PostMapping("/getSubsidyCount")
+    public Result getSubsidyCount(@RequestBody Map<String, String> paramsMap){
+        return subsidyCountService.getSubsidyCount(paramsMap);
+    }
 
+    @PostMapping("/saveSubsidyCount")
+    public Result saveSubsidyCount(@RequestBody Map<String, String> paramsMap){
+        return subsidyCountService.saveSubsidyCount(paramsMap);
+    }
 }
 

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

@@ -2,6 +2,10 @@ package com.huimv.cattle.mapper;
 
 import com.huimv.cattle.pojo.ProductionCapacity;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
 
 /**
  * <p>
@@ -11,6 +15,10 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  * @author zn
  * @since 2022-12-15
  */
+@Repository
 public interface ProductionCapacityMapper extends BaseMapper<ProductionCapacity> {
 
+    List<ProductionCapacity> getProductionCapacity(@Param("yearNum") String yearNum);
+
+    void deleteAll();
 }

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

@@ -2,6 +2,10 @@ package com.huimv.cattle.mapper;
 
 import com.huimv.cattle.pojo.SubsidyCount;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
 
 /**
  * <p>
@@ -11,6 +15,10 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  * @author zn
  * @since 2022-12-15
  */
+@Repository
 public interface SubsidyCountMapper extends BaseMapper<SubsidyCount> {
 
+    List<SubsidyCount> getSubsidyCount(@Param("yearNum") String yearNum);
+
+    void deleteAll();
 }

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

@@ -14,4 +14,12 @@
         id, year, production_count
     </sql>
 
+    <select id="getProductionCapacity" resultType="com.huimv.cattle.pojo.ProductionCapacity">
+        SELECT * FROM production_capacity ORDER BY YEAR DESC LIMIT ${yearNum}
+    </select>
+
+    <delete id="deleteAll">
+        delete from production_capacity
+    </delete>
+
 </mapper>

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

@@ -14,4 +14,12 @@
         id, year, subsidy_count
     </sql>
 
+    <select id="getSubsidyCount" resultType="com.huimv.cattle.pojo.SubsidyCount">
+        SELECT * FROM subsidy_count ORDER BY YEAR DESC LIMIT ${yearNum}
+    </select>
+
+    <delete id="deleteAll">
+        delete from subsidy_count
+    </delete>
+
 </mapper>

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

@@ -2,6 +2,9 @@ package com.huimv.cattle.service;
 
 import com.huimv.cattle.pojo.ProductionCapacity;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huimv.common.utils.Result;
+
+import java.util.Map;
 
 /**
  * <p>
@@ -13,4 +16,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface ProductionCapacityService extends IService<ProductionCapacity> {
 
+    Result getProductionCapacity(Map<String, String> paramsMap);
+
+    Result saveProductionCapacity(Map<String, String> paramsMap);
 }

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

@@ -2,6 +2,9 @@ package com.huimv.cattle.service;
 
 import com.huimv.cattle.pojo.SubsidyCount;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huimv.common.utils.Result;
+
+import java.util.Map;
 
 /**
  * <p>
@@ -13,4 +16,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface SubsidyCountService extends IService<SubsidyCount> {
 
+    Result getSubsidyCount(Map<String, String> paramsMap);
+
+    Result saveSubsidyCount(Map<String, String> paramsMap);
 }

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

@@ -1,10 +1,23 @@
 package com.huimv.cattle.service.impl;
 
+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.pojo.ProductionCapacity;
 import com.huimv.cattle.mapper.ProductionCapacityMapper;
+import com.huimv.cattle.pojo.SubsidyCount;
 import com.huimv.cattle.service.ProductionCapacityService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huimv.cattle.utils.DateUtil;
+import com.huimv.common.utils.Result;
+import com.huimv.common.utils.ResultCode;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -16,5 +29,42 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class ProductionCapacityServiceImpl extends ServiceImpl<ProductionCapacityMapper, ProductionCapacity> implements ProductionCapacityService {
+    @Autowired
+    private ProductionCapacityMapper productionCapacityMapper;
+
+    @Autowired
+    private DateUtil dateUtil;
+
+    @Override
+    public Result getProductionCapacity(Map<String, String> paramsMap) {
+        String yearNum = paramsMap.get("yearNum");
+        List<ProductionCapacity> productionCapacity = productionCapacityMapper.getProductionCapacity(yearNum);
+        if (ObjectUtil.isEmpty(productionCapacity)){
+            ProductionCapacity productionCapacity1 = new ProductionCapacity();
+            productionCapacity1.setYear(Integer.valueOf(dateUtil.getThisYear()));
+            productionCapacity.add(productionCapacity1);
+            productionCapacityMapper.insert(productionCapacity1);
+        }
+        return new Result(ResultCode.SUCCESS,productionCapacity);
+    }
 
+    @Override
+    //目前没有判断重复年份
+    public Result saveProductionCapacity(Map<String, String> paramsMap) {
+        productionCapacityMapper.deleteAll();
+        String list = paramsMap.get("list");
+        JSONArray listJa = JSONArray.parseArray(list);
+        for (int a = listJa.size()-1; a >= 0 ; a--){
+            JSONObject jsonObject = listJa.getJSONObject(a);
+            Integer year = jsonObject.getInteger("year");
+            ProductionCapacity productionCapacity = new ProductionCapacity();
+            productionCapacity.setYear(year);
+//            if (ObjectUtil.isNotEmpty(productionCapacityMapper.selectOne(new QueryWrapper<ProductionCapacity>().eq("year",year)))){
+//                return new Result(10001,"存在重复年份",false);
+//            }
+            productionCapacity.setProductionCount(jsonObject.getInteger("productionCount"));
+            productionCapacityMapper.insert(productionCapacity);
+        }
+        return new Result(ResultCode.SUCCESS);
+    }
 }

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

@@ -1,10 +1,23 @@
 package com.huimv.cattle.service.impl;
 
+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.pojo.IndustryOutput;
 import com.huimv.cattle.pojo.SubsidyCount;
 import com.huimv.cattle.mapper.SubsidyCountMapper;
 import com.huimv.cattle.service.SubsidyCountService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huimv.cattle.utils.DateUtil;
+import com.huimv.common.utils.Result;
+import com.huimv.common.utils.ResultCode;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -16,5 +29,42 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class SubsidyCountServiceImpl extends ServiceImpl<SubsidyCountMapper, SubsidyCount> implements SubsidyCountService {
+    @Autowired
+    private SubsidyCountMapper subsidyCountMapper;
+
+    @Autowired
+    private DateUtil dateUtil;
+
+    @Override
+    public Result getSubsidyCount(Map<String, String> paramsMap) {
+        String yearNum = paramsMap.get("yearNum");
+        List<SubsidyCount> subsidyCount = subsidyCountMapper.getSubsidyCount(yearNum);
+        if (ObjectUtil.isEmpty(subsidyCount)){
+            SubsidyCount subsidyCount1 = new SubsidyCount();
+            subsidyCount1.setYear(Integer.valueOf(dateUtil.getThisYear()));
+            subsidyCount.add(subsidyCount1);
+            subsidyCountMapper.insert(subsidyCount1);
+        }
+        return new Result(ResultCode.SUCCESS,subsidyCount);
+    }
 
+    @Override
+    //目前没有判断重复年份
+    public Result saveSubsidyCount(Map<String, String> paramsMap) {
+        subsidyCountMapper.deleteAll();
+        String list = paramsMap.get("list");
+        JSONArray listJa = JSONArray.parseArray(list);
+        for (int a = listJa.size()-1; a >= 0 ; a--){
+            JSONObject jsonObject = listJa.getJSONObject(a);
+            Integer year = jsonObject.getInteger("year");
+            SubsidyCount subsidyCount = new SubsidyCount();
+            subsidyCount.setYear(year);
+//            if (ObjectUtil.isNotEmpty(subsidyCountMapper.selectOne(new QueryWrapper<SubsidyCount>().eq("year",year)))){
+//                return new Result(10001,"存在重复年份",false);
+//            }
+            subsidyCount.setSubsidyCount(jsonObject.getBigDecimal("subsidyCount"));
+            subsidyCountMapper.insert(subsidyCount);
+        }
+        return new Result(ResultCode.SUCCESS);
+    }
 }