package com.dy.pipIrrSell.client;
|
|
import com.dy.common.aop.SsoAop;
|
import com.dy.common.webUtil.BaseResponse;
|
import com.dy.common.webUtil.BaseResponseUtils;
|
import com.dy.common.webUtil.QueryResultVo;
|
import com.dy.common.webUtil.ResultCodeMsg;
|
import com.dy.pipIrrGlobal.pojoBa.BaClient;
|
import com.dy.pipIrrGlobal.pojoSe.SeClient;
|
import com.dy.pipIrrGlobal.voSe.VoClient;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.media.Content;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.responses.ApiResponse;
|
import io.swagger.v3.oas.annotations.responses.ApiResponses;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jakarta.validation.Valid;
|
import jakarta.validation.constraints.NotNull;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.http.MediaType;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.BindingResult;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.*;
|
|
/**
|
* @author ZhuBaoMin
|
* @date 2023/12/21 19:17
|
* @LastEditTime 2023/12/21 19:17
|
* @Description
|
*/
|
|
@Slf4j
|
@Tag(name = "农户管理", description = "农户操作")
|
@RestController
|
@RequestMapping(path = "client")
|
@RequiredArgsConstructor
|
public class ClientCtrl {
|
private final ClientSv clientSv;
|
//private final RedisUtils redisUtils;
|
@Value("${project.projectNo}")
|
private Integer projectNo;
|
|
/**
|
* 获取农户列表
|
* @param vo
|
* @return
|
*/
|
@Operation(summary = "获得一页农户", description = "返回一页农户数据")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "返回一页农户数据（BaseResponse.content:QueryResultVo[{}]）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = BaClient.class))}
|
)
|
})
|
@GetMapping(path = "get")
|
@SsoAop()
|
public BaseResponse<QueryResultVo<List<VoClient>>> get(QueryVo vo){
|
try {
|
QueryResultVo<List<VoClient>> res = clientSv.getClients(vo);
|
return BaseResponseUtils.buildSuccess(res);
|
} catch (Exception e) {
|
log.error("查询农户异常", e);
|
return BaseResponseUtils.buildException(e.getMessage()) ;
|
}
|
}
|
|
/**
|
* 根据主键获取一个农户对象
|
* @param id
|
* @return
|
*/
|
@Operation(summary = "获得一个农户", description = "返回一个农户数据")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "返回一页农户数据（BaseResponse.content:QueryResultVo[{}]）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = BaClient.class))}
|
)
|
})
|
@GetMapping(path = "/getone/{id}")
|
@SsoAop()
|
public BaseResponse<VoClient> getOneClient(@PathVariable("id") Long id){
|
try {
|
VoClient res = clientSv.getOneClient(id);
|
return BaseResponseUtils.buildSuccess(res);
|
} catch (Exception e) {
|
log.error("查询农户异常", e);
|
return BaseResponseUtils.buildException(e.getMessage()) ;
|
}
|
}
|
|
|
/**
|
* 添加一个农户对象
|
* @param po
|
* @param bindingResult
|
* @return
|
*/
|
@Operation(summary = "添加农户记录", description = "添加农户记录")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "操作结果：true：成功，false：失败（BaseResponse.content）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = Boolean.class))}
|
)
|
})
|
@PostMapping(path = "add", consumes = MediaType.APPLICATION_JSON_VALUE)
|
@Transactional(rollbackFor = Exception.class)
|
@SsoAop()
|
public BaseResponse<Boolean> add(@RequestBody @Valid DtoClient po, BindingResult bindingResult) {
|
if(bindingResult != null && bindingResult.hasErrors()){
|
return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
|
}
|
|
// 接收村编号（主键）
|
Long villageId = po.getVillageId();
|
|
/**
|
* 获取5级行政区划信息
|
*/
|
Map map_districts = Optional.ofNullable(clientSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
|
if(map_districts.size() <= 0) {
|
return BaseResponseUtils.buildFail("区划信息有误");
|
}
|
|
String provinceNum = map_districts.get("provinceNum").toString();
|
String cityNum = map_districts.get("cityNum").toString();
|
Long countryId = Long.parseLong(map_districts.get("countryId").toString());
|
String countyNum = map_districts.get("countyNum").toString();
|
String countryName = map_districts.get("countryName").toString();
|
Long townId = Long.parseLong(map_districts.get("townId").toString());
|
String townNum = map_districts.get("townNum").toString();
|
String townName = map_districts.get("townName").toString();
|
String villageNum = map_districts.get("villageNum").toString();
|
String villageName = map_districts.get("villageName").toString();
|
|
// 生成8位行政区划编码，生成农户编号用
|
String district8 = String.format("%02d", Integer.parseInt(countyNum)) + String.format("%03d", Integer.parseInt(townNum)) + String.format("%03d", Integer.parseInt(villageNum));
|
// 生成农户编号
|
String clientNum = generateClientNum(district8);
|
if(clientNum == null) {
|
return BaseResponseUtils.buildErrorMsg("农户编号超限");
|
}
|
// 生成12位5级行政区划编码串及名称串
|
Long districtNum = Long.parseLong(provinceNum + cityNum + district8);
|
String districtTitle = countryName + townName + villageName;
|
|
// 生成虚拟卡号
|
Long virtualId = Optional.ofNullable(clientSv.getMa1xVirtualId()).orElse(0L);
|
if(virtualId == 0) {
|
virtualId = 1000000000L;
|
}else {
|
virtualId = virtualId + 1;
|
if(virtualId > 10000000000L) {
|
return BaseResponseUtils.buildFail("虚拟卡号超限");
|
}
|
}
|
|
SeClient seClient = DtoClientToSeClient.INSTANCT.po2vo(po);
|
seClient.setCountyid(countryId);
|
seClient.setTownid(townId);
|
seClient.setVirtualid(virtualId);
|
seClient.setClientnum(clientNum);
|
seClient.setDistrictnum(districtNum);
|
seClient.setDistricttitle(districtTitle);
|
Date operateTime = new Date();
|
seClient.setOperatedt(operateTime);
|
|
seClient.setDisabled((byte)0);
|
seClient.setDeleted((byte)0);
|
Integer rec = Optional.ofNullable(clientSv.addClient(seClient)).orElse(0);
|
if(rec == 0) {
|
return BaseResponseUtils.buildFail("添加农户失败");
|
}
|
return BaseResponseUtils.buildSuccess(true) ;
|
}
|
|
/**
|
* 生成10位农户编号
|
* 1. 到农户表中查询6位区划串开头的最大的农户编号
|
* 2. 是否取到记录
|
* 2.1 取到
|
* 2.1.1 取出后4位顺序号并转成整形
|
* 2.1.2. 整形格式的顺序号加1并判断是否大于9999
|
* 2.1.2.1 如果大于则提示用户编号已满
|
* 2.1.2.2 如果不大 6位区划加上格式化后的顺序号
|
* 2.2 未取到 6位区划加上0001
|
* 3. 返回农户编号
|
*/
|
private String generateClientNum(String district8) {
|
String clientNum = Optional.ofNullable(clientSv.getClientNumOfMax(district8)).orElse("");
|
if(clientNum != null && clientNum.trim().length() > 0) {
|
Integer number = Integer.parseInt(clientNum.substring(8));
|
number = number + 1;
|
if(number > 9999) {
|
return null;
|
}
|
clientNum = clientNum.substring(0, 8) + String.format("%04d", number);
|
} else {
|
clientNum = district8 + "0001";
|
}
|
return clientNum;
|
}
|
|
/**
|
* 修改农户对象（虚拟卡号、禁止标志、逻辑删除标识不参与修改）
|
* @param po 农户对象
|
* @param bindingResult
|
* @return
|
*/
|
@Operation(summary = "修改农户记录", description = "修改农户记录")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "操作结果：true：成功，false：失败（BaseResponse.content）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = Boolean.class))}
|
)
|
})
|
@PostMapping(path = "update", consumes = MediaType.APPLICATION_JSON_VALUE)
|
@Transactional(rollbackFor = Exception.class)
|
@SsoAop()
|
public BaseResponse<Boolean> update(@RequestBody @Valid DtoClient po, BindingResult bindingResult){
|
if(bindingResult != null && bindingResult.hasErrors()){
|
return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
|
}
|
|
// 接收村编号（主键）
|
Long villageId = po.getVillageId();
|
|
/**
|
* 获取5级行政区划信息
|
*/
|
Map map_districts = Optional.ofNullable(clientSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
|
if(map_districts.size() <= 0) {
|
return BaseResponseUtils.buildFail("区划信息有误");
|
}
|
|
String provinceNum = map_districts.get("provinceNum").toString();
|
String cityNum = map_districts.get("cityNum").toString();
|
Long countryId = Long.parseLong(map_districts.get("countryId").toString());
|
String countyNum = map_districts.get("countyNum").toString();
|
String countryName = map_districts.get("countryName").toString();
|
Long townId = Long.parseLong(map_districts.get("townId").toString());
|
String townNum = map_districts.get("townNum").toString();
|
String townName = map_districts.get("townName").toString();
|
String villageNum = map_districts.get("villageNum").toString();
|
String villageName = map_districts.get("villageName").toString();
|
|
// 生成8位行政区划编码，生成农户编号用
|
//String district8 = countyNum + townNum + villageNum;
|
String district8 = String.format("%02d", Integer.parseInt(countyNum)) + String.format("%03d", Integer.parseInt(townNum)) + String.format("%03d", Integer.parseInt(villageNum));
|
// 生成农户编号
|
String clientNum = generateClientNum(district8);
|
// 生成12位5级行政区划编码串及名称串
|
Long districtNum = Long.parseLong(provinceNum + cityNum + district8);
|
String districtTitle = countryName + townName + villageName;
|
|
SeClient seClient = DtoClientToSeClient.INSTANCT.po2vo(po);
|
seClient.setCountyid(countryId);
|
seClient.setTownid(townId);
|
seClient.setClientnum(clientNum);
|
seClient.setDistrictnum(districtNum);
|
seClient.setDistricttitle(districtTitle);
|
Date operateTime = new Date();
|
seClient.setOperatedt(operateTime);
|
|
Integer rec = Optional.ofNullable(clientSv.updateByPrimaryKey(seClient)).orElse(0);
|
if(rec == 0) {
|
return BaseResponseUtils.buildFail("农户修改失败");
|
}
|
return BaseResponseUtils.buildSuccess(true) ;
|
}
|
|
/**
|
* 根据农户ID逻辑删除农户
|
* @param id
|
* @return
|
*/
|
@Operation(summary = "删除一个农户", description = "删除一个农户数据")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "返回一页农户数据（BaseResponse.content:QueryResultVo[{}]）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = BaClient.class))}
|
)
|
})
|
|
@GetMapping(path = "/delone/{id}")
|
@SsoAop()
|
public BaseResponse<Boolean> deleteClientById(@PathVariable("id") Long id){
|
try {
|
Integer res = Optional.ofNullable(clientSv.deleteClientById(id)).orElse(0);
|
if(res == 0) {
|
return BaseResponseUtils.buildFail("农户删除失败");
|
}
|
return BaseResponseUtils.buildSuccess(true);
|
} catch (Exception e) {
|
log.error("查询农户异常", e);
|
return BaseResponseUtils.buildException(e.getMessage()) ;
|
}
|
}
|
|
/**
|
* 获取用水方式列表
|
* @param
|
* @return
|
*/
|
@Operation(summary = "获得用水方式列表", description = "返回用水方式列表")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "返回一页农户数据（BaseResponse.content:QueryResultVo[{}]）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = BaClient.class))}
|
)
|
})
|
@GetMapping(path = "/watertypes")
|
@SsoAop()
|
public BaseResponse<QueryResultVo<List<Map<String, Object>>>> getWaterTypes(){
|
List<Map<String, Object>> map_WaterTypes = Optional.ofNullable(clientSv.getWaterTypes()).orElse(new ArrayList<>());
|
if(map_WaterTypes == null || map_WaterTypes.size() == 0) {
|
return BaseResponseUtils.buildFail("没有用水方式") ;
|
}
|
return BaseResponseUtils.buildSuccess(map_WaterTypes);
|
}
|
|
/**
|
* 根据村ID获取12位行政区划
|
* @param villageId
|
* @return
|
*/
|
@Operation(summary = "根据村ID获取12位行政区划", description = "根据村ID获取12位行政区划")
|
@ApiResponses(value = {
|
@ApiResponse(
|
responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE,
|
description = "操作结果：true：成功，false：失败（BaseResponse.content）",
|
content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE,
|
schema = @Schema(implementation = Boolean.class))}
|
)
|
})
|
@GetMapping(path = "district")
|
@SsoAop()
|
public BaseResponse<Boolean> getDistrictNum(@RequestParam("villageId") @NotNull(message = "村编号不能为空") Long villageId){
|
/**
|
* 获取5级行政区划信息
|
*/
|
Map map_districts = Optional.ofNullable(clientSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
|
if(map_districts.size() <= 0) {
|
return BaseResponseUtils.buildFail("区划信息有误");
|
}
|
|
String provinceNum = map_districts.get("provinceNum").toString();
|
String cityNum = map_districts.get("cityNum").toString();
|
String countyNum = map_districts.get("countyNum").toString();
|
String townNum = map_districts.get("townNum").toString();
|
String villageNum = map_districts.get("villageNum").toString();
|
|
// 生成12位5级行政区划编码串及名称串
|
Long districtNum = Long.parseLong(provinceNum + cityNum + countyNum + townNum + villageNum);
|
//获取项目编码
|
// String projectNo = clientSv.getItemValue("projectNo");
|
// //转为int
|
// Integer projectNo1 = Integer.valueOf(projectNo);
|
// //转为16进制
|
//// String projectNo2 = Integer.toHexString(projectNo1);
|
//// log.info(projectNo2);
|
String projectNo3 = String.format("%02x", projectNo);
|
log.info(projectNo3);
|
|
Map map = new HashMap();
|
map.put("districtNum", districtNum);
|
map.put("projectNo",projectNo3);
|
return BaseResponseUtils.buildSuccess(map);
|
}
|
}
|
