元谋二期后端软件系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wuzeyu
2024-08-01 beca4894acec49f29f7283f3c76c8da5e1c9bfe8 
 pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/client/ClientCtrl.java


@@ -1,8 +1,5 @@


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;


@@ -10,15 +7,7 @@


import com.dy.common.webUtil.ResultCodeMsg;


import com.dy.pipIrrGlobal.pojoBa.BaClient;


import com.dy.pipIrrGlobal.pojoSe.SeClient;


import com.dy.pipIrrGlobal.pojoSe.SeCodeVerify;


import com.dy.pipIrrGlobal.pojoSe.SeOpenId;


import com.dy.pipIrrGlobal.voSe.VoClient;


import com.dy.pipIrrSell.client.dto.CodeVerifyDTO;


import com.dy.pipIrrSell.result.SellResultCode;


import com.dy.pipIrrSell.sms.AliyunSmsSv;


import com.dy.pipIrrSell.sms.RandomCode;


import com.dy.pipIrrSell.util.RestTemplateUtil;


import com.dy.pipIrrSell.wechatpay.PayInfo;


import io.swagger.v3.oas.annotations.Operation;


import io.swagger.v3.oas.annotations.media.Content;


import io.swagger.v3.oas.annotations.media.Schema;


@@ -34,7 +23,6 @@


import org.springframework.validation.BindingResult;


import org.springframework.web.bind.annotation.*;




import java.io.IOException;


import java.util.*;




/**


@@ -51,20 +39,7 @@


@RequiredArgsConstructor


public class ClientCtrl {


    private final ClientSv clientSv;


    private final AliyunSmsSv aliyunSmsSv;


    //private final RedisUtils redisUtils;


    private final RestTemplateUtil restTemplateUtil;




    private final String privateCertFileName = PayInfo.privateCertFileName;


    private final String appid = PayInfo.appid;


    private final String secret = PayInfo.secret;


    private final String mchid = PayInfo.mchid;


    private final String schema = PayInfo.schema;


    private final String signType = PayInfo.signType;


    private final String description = PayInfo.description;


    private final String loginUrl = PayInfo.loginUrl;


    private final String notifyUrl = PayInfo.notifyUrl;


    private final String grantType = PayInfo.grantType;




    /**


     * 获取农户列表


@@ -165,9 +140,12 @@


        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);


        if(clientNum == null) {


            return BaseResponseUtils.buildErrorMsg("农户编号超限");


        }


        // 生成12位5级行政区划编码串及名称串


        Long districtNum = Long.parseLong(provinceNum + cityNum + district8);


        String districtTitle = countryName + townName + villageName;


@@ -220,7 +198,7 @@


            Integer number = Integer.parseInt(clientNum.substring(8));


            number = number + 1;


            if(number > 9999) {


                return "农户编号超限";


                return null;


            }


            clientNum = clientNum.substring(0, 8) + String.format("%04d", number);


        } else {


@@ -275,7 +253,8 @@


        String villageName = map_districts.get("villageName").toString();




        // 生成8位行政区划编码，生成农户编号用


        String district8 = countyNum + townNum + villageNum;


        //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级行政区划编码串及名称串


@@ -350,132 +329,6 @@


            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);




        // 获取当前时间戳并延后3分钟


        Long timestamp = System.currentTimeMillis();


        Calendar calendar = Calendar.getInstance();


        calendar.setTimeInMillis(timestamp);


        calendar.add(Calendar.SECOND, 180);


        Long expires = calendar.getTimeInMillis();




        SeCodeVerify codeVerify = new SeCodeVerify();


        codeVerify.setPhoneNumber(phoneNumber);


        codeVerify.setSecurityCode(securityCode);


        codeVerify.setExpires(expires);


        clientSv.addCodeVerify(codeVerify);




        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 po


     * @param bindingResult


     * @return


     * @throws IOException


     */


    @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", consumes = MediaType.APPLICATION_JSON_VALUE)


    @Transactional(rollbackFor = Exception.class)


    @SsoAop()


    public BaseResponse<Boolean> verify(@RequestBody @Valid CodeVerifyDTO po, BindingResult bindingResult) throws IOException {


        if(bindingResult != null && bindingResult.hasErrors()){


            return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());


        }




        String phoneNumber = po.getPhoneNumber();


        String securityCode = po.getSecurityCode();


        String code = po.getCode();




        // 进行手机号、验证码、过期时间校验


        SeCodeVerify codeVerify = clientSv.getCodeVerify(phoneNumber);


        if(codeVerify == null) {


            return BaseResponseUtils.buildFail(SellResultCode.NO_SECURITY_CODE_FOR_PHONE.getMessage());


        }




        if(!codeVerify.getSecurityCode().equals(securityCode)) {


            return BaseResponseUtils.buildFail(SellResultCode.SECURITY_CODE_ERROR.getMessage());


        }




        Long currentTimestamp = System.currentTimeMillis();


        if(currentTimestamp > codeVerify.getExpires() ) {


            return BaseResponseUtils.buildFail(SellResultCode.VALIDATION_TIMEOUT.getMessage());


        }




        // 校验通过，进行登录凭证校验


        Map<String, Object> queryParams = new HashMap<>();


        queryParams.put("appid", appid);


        queryParams.put("secret", secret);


        queryParams.put("js_code", code);


        queryParams.put("grant_type", grantType);


        Map<String, String> headerParams = new HashMap<>();


        JSONObject job = restTemplateUtil.get(loginUrl, queryParams, headerParams);




        if(job.getLong("errcode") != null && job.getLong("errcode") >= -1) {


            return BaseResponseUtils.buildFail("登录凭证校验失败");


        }


        String openid = job.getString("openid");


        String sessionKey = job.getString("session_key");




        Long clientId = clientSv.getClientIdByPhone(phoneNumber);


        if(clientId != null) {


            // 添加微信用户账户记录


            SeOpenId seOpenId = new SeOpenId();


            seOpenId.setClientId(clientId);


            seOpenId.setOpenId(openid);


            seOpenId.setSessionKey(sessionKey);


            seOpenId.setCreateTime(new Date());


            Long SessionId = clientSv.addOpenId(seOpenId);


            return BaseResponseUtils.buildSuccess(SessionId);




        } else {


            return BaseResponseUtils.buildError(SellResultCode.PHONE_NUMBER_IS_ERROR.getMessage());


        }


    }




    /**