|
@@ -1,5 +1,6 @@
|
|
|
package com.huimv.farm.damsubsidy.service.impl;
|
|
|
|
|
|
+import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.date.DateTime;
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
@@ -19,6 +20,7 @@ import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.huimv.farm.damsubsidy.common.utils.Result;
|
|
|
import com.huimv.farm.damsubsidy.common.utils.ResultCode;
|
|
|
+import com.huimv.farm.damsubsidy.entity.vo.BillSubsidyDto;
|
|
|
import com.huimv.farm.damsubsidy.entity.vo.BillSubsidyReportVo;
|
|
|
import com.huimv.farm.damsubsidy.mapper.*;
|
|
|
import com.huimv.farm.damsubsidy.service.IBillSubsidyService;
|
|
@@ -132,7 +134,7 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
baseAnimal.setIsLoated(0);
|
|
|
if (animalMapper.updateById(baseAnimal) != 1) {
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
- return new Result(10001,"操作失败",false);
|
|
|
+ return new Result(10001, "操作失败", false);
|
|
|
}
|
|
|
}
|
|
|
billSubsidy.setRefuseReason(refuseReason);
|
|
@@ -184,7 +186,7 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
baseAnimal.setAnimalStatus(1);
|
|
|
if (animalMapper.updateById(baseAnimal) != 1) {
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
- return new Result(10001,"操作失败",false);
|
|
|
+ return new Result(10001, "操作失败", false);
|
|
|
}
|
|
|
}
|
|
|
subsidyMapper.updateById(billSubsidy);
|
|
@@ -238,28 +240,28 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
public Result addApplication(HttpServletRequest httpServletRequest, BillSubsidy billSubsidy) {
|
|
|
Integer type = sysUserMapper.selectOne(new QueryWrapper<SysUser>().eq("id", TokenSign.getMemberIdByJwtToken(httpServletRequest))).getUserType();
|
|
|
|
|
|
- if (type == 2){
|
|
|
- if ("".equals(billSubsidy.getFarmName())){
|
|
|
- return new Result(10001,"牧场名称不能为空",false);
|
|
|
+ if (type == 2) {
|
|
|
+ if ("".equals(billSubsidy.getFarmName())) {
|
|
|
+ return new Result(10001, "牧场名称不能为空", false);
|
|
|
}
|
|
|
- if ("".equals(billSubsidy.getNameTwo())){
|
|
|
- return new Result(10001,"负责人不能为空",false);
|
|
|
+ if ("".equals(billSubsidy.getNameTwo())) {
|
|
|
+ return new Result(10001, "负责人不能为空", false);
|
|
|
}
|
|
|
billSubsidy.setSubsidyType(1);
|
|
|
}
|
|
|
- if (type == 3){
|
|
|
- if ("".equals(billSubsidy.getFarmerName())){
|
|
|
- return new Result(10001,"农户姓名不能为空",false);
|
|
|
+ if (type == 3) {
|
|
|
+ if ("".equals(billSubsidy.getFarmerName())) {
|
|
|
+ return new Result(10001, "农户姓名不能为空", false);
|
|
|
}
|
|
|
- if ("".equals(billSubsidy.getFarmerType())){
|
|
|
- return new Result(10001,"农户类型不能为空",false);
|
|
|
+ if ("".equals(billSubsidy.getFarmerType())) {
|
|
|
+ return new Result(10001, "农户类型不能为空", false);
|
|
|
}
|
|
|
billSubsidy.setSubsidyType(0);
|
|
|
}
|
|
|
String eartagNo = billSubsidy.getEartagNo();
|
|
|
String[] eartags = eartagNo.split(",");
|
|
|
- if (eartags.length != billSubsidy.getRewardNum()){
|
|
|
- return new Result(10001,"奖补数应与实际耳标号数量相同",false);
|
|
|
+ if (eartags.length != billSubsidy.getRewardNum()) {
|
|
|
+ return new Result(10001, "奖补数应与实际耳标号数量相同", false);
|
|
|
}
|
|
|
Long id = TokenSign.getMemberIdByJwtToken(httpServletRequest);
|
|
|
SysUser sysUser = sysUserMapper.selectOne(new QueryWrapper<SysUser>().eq("id", id));
|
|
@@ -286,7 +288,7 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
animal.setIsLoated(1);
|
|
|
if (baseAnimalMapper.updateById(animal) != 1) {
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
- return new Result(10001,"操作失败",false);
|
|
|
+ return new Result(10001, "操作失败", false);
|
|
|
}
|
|
|
} else {
|
|
|
String start = eartag.substring(0, eartag.indexOf("-"));
|
|
@@ -303,7 +305,7 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
animal.setIsLoated(1);
|
|
|
if (baseAnimalMapper.updateById(animal) != 1) {
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
- return new Result(10001,"操作失败",false);
|
|
|
+ return new Result(10001, "操作失败", false);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -320,10 +322,10 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
BillLandingInspection billLandingInspection = billLandingInspectionMapper.selectOne(new QueryWrapper<BillLandingInspection>()
|
|
|
.eq("inspection_num", billSubsidy.getInspectionNum())
|
|
|
// .ne("inspection_type",0)
|
|
|
- .eq("inspection_sch",4));
|
|
|
+ .eq("inspection_sch", 4));
|
|
|
Integer userType = sysUserMapper.selectOne(new QueryWrapper<SysUser>().eq("id", billLandingInspection.getCreateUser())).getUserType();
|
|
|
|
|
|
- if (count != 0 && userType == 2){
|
|
|
+ if (count != 0 && userType == 2) {
|
|
|
billSubsidy.setSaleName(billLandingInspection.getCargoOwner());
|
|
|
}
|
|
|
billSubsidy.setSubsidySch(0);
|
|
@@ -397,24 +399,24 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
String addressCode = TokenSign.getAddressCode(httpServletRequest);
|
|
|
QueryWrapper<BillSubsidy> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.between(StringUtils.isNotBlank(date), "create_time", date + " 00:00:00", date + " 23:59:59")
|
|
|
- .like(StringUtils.isNotBlank(userName), "farmer_name", userName).like("brief_address_code",addressCode);
|
|
|
+ .like(StringUtils.isNotBlank(userName), "farmer_name", userName).like("brief_address_code", addressCode);
|
|
|
|
|
|
if (Integer.parseInt(type) == 7) {
|
|
|
- queryWrapper.eq("is_pay", 1).orderByDesc("create_time").like("brief_address_code",addressCode);
|
|
|
+ queryWrapper.eq("is_pay", 1).orderByDesc("create_time").like("brief_address_code", addressCode);
|
|
|
Page<BillSubsidy> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
|
|
|
return new Result(ResultCode.SUCCESS, subsidyMapper.selectPage(page, queryWrapper));
|
|
|
}
|
|
|
if (Integer.parseInt(type) == 6) {
|
|
|
- queryWrapper.eq("is_pay", 2).orderByDesc("create_time").like("brief_address_code",addressCode);
|
|
|
+ queryWrapper.eq("is_pay", 2).orderByDesc("create_time").like("brief_address_code", addressCode);
|
|
|
Page<BillSubsidy> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
|
|
|
return new Result(ResultCode.SUCCESS, subsidyMapper.selectPage(page, queryWrapper));
|
|
|
}
|
|
|
if (Integer.parseInt(type) == 3) {
|
|
|
- queryWrapper.in("is_pay", 0, 1).eq("subsidy_sch", 3).orderByDesc("create_time").like("brief_address_code",addressCode);
|
|
|
+ queryWrapper.in("is_pay", 0, 1).eq("subsidy_sch", 3).orderByDesc("create_time").like("brief_address_code", addressCode);
|
|
|
Page<BillSubsidy> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
|
|
|
return new Result(ResultCode.SUCCESS, subsidyMapper.selectPage(page, queryWrapper));
|
|
|
}
|
|
|
- queryWrapper.eq(StringUtils.isNotBlank(type), "subsidy_sch", type).orderByDesc("create_time").like("brief_address_code",addressCode);
|
|
|
+ queryWrapper.eq(StringUtils.isNotBlank(type), "subsidy_sch", type).orderByDesc("create_time").like("brief_address_code", addressCode);
|
|
|
Page<BillSubsidy> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
|
|
|
return new Result(ResultCode.SUCCESS, subsidyMapper.selectPage(page, queryWrapper));
|
|
|
}
|
|
@@ -447,7 +449,7 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
baseAnimal.setIsLoated(0);
|
|
|
if (baseAnimalMapper.updateById(baseAnimal) != 1) {
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
- return new Result(10001,"操作失败",false);
|
|
|
+ return new Result(10001, "操作失败", false);
|
|
|
}
|
|
|
}
|
|
|
this.removeById(billSubsidy);
|
|
@@ -790,8 +792,8 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
String endTime = endDate + " 23:59:59";
|
|
|
wrapper.le("create_time", endTime);
|
|
|
} else {
|
|
|
- startDate = startDate + " 00:00:00";
|
|
|
- endDate = endDate + " 23:59:59";
|
|
|
+ startDate = startDate + " 00:00:00";
|
|
|
+ endDate = endDate + " 23:59:59";
|
|
|
wrapper.between("create_time", startDate, endDate);
|
|
|
}
|
|
|
wrapper.eq("is_pay", 1);
|
|
@@ -885,22 +887,22 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
String end = paramsMap.get("end");
|
|
|
Date date = new Date();
|
|
|
String format = DateUtil.format(date, "yyyy-MM-dd");
|
|
|
- if (StringUtils.isBlank(start)){
|
|
|
- start = format+" 00:00:00";
|
|
|
- }else {
|
|
|
- start = start+" 00:00:00";
|
|
|
+ if (StringUtils.isBlank(start)) {
|
|
|
+ start = format + " 00:00:00";
|
|
|
+ } else {
|
|
|
+ start = start + " 00:00:00";
|
|
|
}
|
|
|
- if (StringUtils.isBlank(end)){
|
|
|
- end = format+" 23:59:59";
|
|
|
- }else {
|
|
|
- end = end+" 23:59:59";
|
|
|
+ if (StringUtils.isBlank(end)) {
|
|
|
+ end = format + " 23:59:59";
|
|
|
+ } else {
|
|
|
+ end = end + " 23:59:59";
|
|
|
}
|
|
|
QueryWrapper<AreaAll> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("id", code);
|
|
|
AreaAll all = areaAllMapper.selectOne(queryWrapper);
|
|
|
QueryWrapper<BillSubsidy> subsidyQueryWrapper = new QueryWrapper<>();
|
|
|
|
|
|
- subsidyQueryWrapper.like(StringUtils.isNotBlank(code),"detailed_adress_code", code)
|
|
|
+ subsidyQueryWrapper.like(StringUtils.isNotBlank(code), "detailed_adress_code", code)
|
|
|
.between("create_time", start, end).eq("subsidy_sch", 3).eq("is_pay", 1)
|
|
|
.groupBy("id_card");
|
|
|
List<BillSubsidy> subsidyList = subsidyMapper.selectList(subsidyQueryWrapper);
|
|
@@ -946,19 +948,19 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
String end = paramsMap.get("endDate");
|
|
|
Date date = new Date();
|
|
|
String format = DateUtil.format(date, "yyyy-MM-dd");
|
|
|
- if (StringUtils.isBlank(start)){
|
|
|
- start = format+" 00:00:00";
|
|
|
- }else {
|
|
|
- start = start+" 00:00:00";
|
|
|
+ if (StringUtils.isBlank(start)) {
|
|
|
+ start = format + " 00:00:00";
|
|
|
+ } else {
|
|
|
+ start = start + " 00:00:00";
|
|
|
}
|
|
|
- if (StringUtils.isBlank(end)){
|
|
|
- end = format+" 23:59:59";
|
|
|
- }else {
|
|
|
- end = end+" 23:59:59";
|
|
|
+ if (StringUtils.isBlank(end)) {
|
|
|
+ end = format + " 23:59:59";
|
|
|
+ } else {
|
|
|
+ end = end + " 23:59:59";
|
|
|
}
|
|
|
|
|
|
QueryWrapper<BillSubsidy> subsidyQueryWrapper = new QueryWrapper<>();
|
|
|
- subsidyQueryWrapper.like(StringUtils.isNotBlank(code),"detailed_adress_code", code)
|
|
|
+ subsidyQueryWrapper.like(StringUtils.isNotBlank(code), "detailed_adress_code", code)
|
|
|
.between("create_time", start, end).eq("subsidy_sch", 3).eq("is_pay", 1)
|
|
|
.groupBy("id_card");
|
|
|
List<BillSubsidy> subsidyList = subsidyMapper.selectList(subsidyQueryWrapper);
|
|
@@ -976,8 +978,8 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
BillSubsidy billSubsidy = subsidyMapper.selectById(id);
|
|
|
String[] beforeSplit = billSubsidy.getEartagNo().split(",");
|
|
|
String[] afterSplit = afterEartagNo.split(",");
|
|
|
- if (afterSplit.length != Integer.parseInt(afterRewardNum)){
|
|
|
- return new Result(10001,"奖补数量与实际耳标号数量不符",false);
|
|
|
+ if (afterSplit.length != Integer.parseInt(afterRewardNum)) {
|
|
|
+ return new Result(10001, "奖补数量与实际耳标号数量不符", false);
|
|
|
}
|
|
|
List<String> afterList = Arrays.asList(afterSplit);
|
|
|
List<String> beforeList = Arrays.asList(beforeSplit);
|
|
@@ -993,7 +995,7 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
baseAnimal.setAnimalStatus(4);
|
|
|
if (baseAnimalMapper.updateById(baseAnimal) != 1) {
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
- return new Result(10001,"耳标号"+baseAnimal.getEaratgNo()+"修改失败",false);
|
|
|
+ return new Result(10001, "耳标号" + baseAnimal.getEaratgNo() + "修改失败", false);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -1017,5 +1019,31 @@ public class BillSubsidyServiceImpl extends ServiceImpl<BillSubsidyMapper, BillS
|
|
|
return Result.SUCCESS();
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public Result payList(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
|
+ String code = paramsMap.get("code");//所选乡镇的编码
|
|
|
+ String name = paramsMap.get("name");
|
|
|
+
|
|
|
+ QueryWrapper<BillSubsidy> subsidyQueryWrapper = new QueryWrapper<>();
|
|
|
+ subsidyQueryWrapper.like(StringUtils.isNotBlank(code), "detailed_adress_code", code).like(StringUtils.isNotBlank(name),"farmer_name", name)
|
|
|
+ .eq("subsidy_sch", 3).eq("is_pay", 1)
|
|
|
+ .eq("is_batch", 0)
|
|
|
+ .groupBy("id_card");
|
|
|
+ List<BillSubsidy> subsidyList = subsidyMapper.selectList(subsidyQueryWrapper);
|
|
|
+ JSONArray jsonArray = new JSONArray();
|
|
|
+ for (BillSubsidy billSubsidy : subsidyList) {
|
|
|
+ BillSubsidyDto subsidyDto = new BillSubsidyDto();
|
|
|
+ BeanUtil.copyProperties(billSubsidy,subsidyDto);
|
|
|
+ String detailedAdressCode = billSubsidy.getDetailedAdressCode();
|
|
|
+ String[] split = detailedAdressCode.split(",");
|
|
|
+ QueryWrapper<AreaAll> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.eq("id", split[2]);
|
|
|
+ AreaAll areaAll = areaAllMapper.selectOne(queryWrapper);
|
|
|
+ subsidyDto.setCountry(areaAll.getName());
|
|
|
+ jsonArray.add(subsidyDto);
|
|
|
+ }
|
|
|
+ return new Result(ResultCode.SUCCESS, jsonArray);
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
}
|