package com.dy.pipIrrSell.client;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
|
import com.aliyuncs.exceptions.ClientException;
|
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 com.dy.pipIrrSell.result.SellResultCode;
|
import com.dy.pipIrrSell.sms.AliyunSmsSv;
|
import com.dy.pipIrrSell.sms.RandomCode;
|
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.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 AliyunSmsSv aliyunSmsSv;
|
//private final RedisUtils redisUtils;
|
|
/**
|
* 获取农户列表
|
* @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 = countyNum + townNum + villageNum;
|
// 生成农户编号
|
String clientNum = generateClientNum(district8);
|
// 生成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 "农户编号超限";
|
}
|
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 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);
|
}
|
|
/**
|
* 发送验证码
|
* @param phoneNumber
|
* @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 = "send_sms")
|
@SsoAop()
|
public BaseResponse<Boolean> sendSms(@RequestParam(name = "phoneNumber", required = true) String phoneNumber) throws ClientException {
|
if(phoneNumber == null || phoneNumber.length() <= 0) {
|
return BaseResponseUtils.buildFail(SellResultCode.PHONE_NUMBER_CANNOT_BE_NULL.getMessage());
|
}
|
|
// 生成6位验证码并转为Json格式
|
String securityCode = String.valueOf(RandomCode.genCode());
|
JSONObject param = new JSONObject();
|
param.put("code", securityCode);
|
String templateParam = param.toJSONString();
|
|
//redisUtils.set(phoneNumber, securityCode, 60);
|
|
SendSmsResponse response = aliyunSmsSv.sendSms(phoneNumber, templateParam);
|
if (response.getCode().equals("OK")) {
|
// 发送成功处理逻辑
|
return BaseResponseUtils.buildSuccess(true) ;
|
} else {
|
// 发送失败处理逻辑
|
return BaseResponseUtils.buildFail(SellResultCode.SECURITY_CODE_SEND_FAIL.getMessage()) ;
|
}
|
}
|
|
/**
|
* 校验验证码
|
* @param phoneNumber
|
* @param code
|
* @return
|
* @throws ClientException
|
*/
|
@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 = "verify")
|
@SsoAop()
|
public BaseResponse<Boolean> verify(@RequestParam("phoneNumber") String phoneNumber, @RequestParam("code") String code) throws ClientException {
|
if(phoneNumber == null || phoneNumber.length() <= 0 || code == null || code.length() <=0) {
|
return BaseResponseUtils.buildFail(SellResultCode.VERIFY_PARAMS_INCOMPLETE.getMessage());
|
}
|
|
// redis中键不存在或键值不存在则提示校验失败
|
//if(!redisUtils.hasKey(phoneNumber) || redisUtils.get(phoneNumber) == null)
|
// return BaseResponseUtils.buildFail(SellResultCode.CODE_VERIFY_FAIL.getMessage());
|
//
|
//String code_redis = redisUtils.get(phoneNumber).toString();
|
//System.out.println("--------------------: " + code_redis);
|
//
|
//if(code_redis != null && code_redis.equals(code)) {
|
// return BaseResponseUtils.buildSuccess(true) ;
|
//}else {
|
// return BaseResponseUtils.buildFail(SellResultCode.CODE_VERIFY_FAIL.getMessage());
|
//}
|
|
return BaseResponseUtils.buildSuccess(true) ;
|
}
|
|
/**
|
* 根据村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);
|
|
Map map = new HashMap();
|
map.put("districtNum", districtNum);
|
return BaseResponseUtils.buildSuccess(map) ;
|
}
|
}
|
