| | |
|---|
| | | import com.dy.pipIrrGlobal.pojoSe.SeCodeVerify; |
|---|
| | | import com.dy.pipIrrGlobal.pojoSe.SeOpenId; |
|---|
| | | import com.dy.pipIrrGlobal.voSe.VoClientWechat; |
|---|
| | | import com.dy.pipIrrSell.wechatpay.PayInfo; |
|---|
| | | import com.dy.pipIrrWechat.client.dto.CodeLoginDTO; |
|---|
| | | import com.dy.pipIrrWechat.client.dto.CodeVerifyDTO; |
|---|
| | | import com.dy.pipIrrWechat.result.WechatResultCode; |
|---|
| | |
|---|
| | | * @throws IOException |
|---|
| | | */ |
|---|
| | | @PostMapping(path = "code_login", consumes = MediaType.APPLICATION_JSON_VALUE) |
|---|
| | | public BaseResponse<VoClientWechat> codeLogin(@RequestBody @Valid CodeLoginDTO po, BindingResult bindingResult) throws IOException { |
|---|
| | | public BaseResponse<JSONObject> codeLogin(@RequestBody @Valid CodeLoginDTO po, BindingResult bindingResult) throws IOException { |
|---|
| | | if(bindingResult != null && bindingResult.hasErrors()){ |
|---|
| | | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
|---|
| | | } |
|---|
| | |
|---|
| | | Map<String, String> headerParams = new HashMap<>(); |
|---|
| | | JSONObject job = restTemplateUtil.get(loginUrl, queryParams, headerParams); |
|---|
| | | |
|---|
| | | if(job.containsKey("errmsg ")) { |
|---|
| | | return BaseResponseUtils.buildErrorMsg(WechatResultCode.INVALID_CODE.getMessage()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | String openId = job.getString("openid"); |
|---|
| | | if(openId == null) { |
|---|
| | | return BaseResponseUtils.buildErrorMsg(WechatResultCode.LOGIN_FAIL.getMessage()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | try { |
|---|
| | | JSONObject job_client = new JSONObject(); |
|---|
| | | VoClientWechat res = clientSv.getSimpleClientInfo(null, openId); |
|---|
| | | return BaseResponseUtils.buildSuccess(res); |
|---|
| | | if(res != null) { |
|---|
| | | job_client.put("client", res); |
|---|
| | | } else { |
|---|
| | | VoClientWechat voClientWechat = new VoClientWechat(); |
|---|
| | | job_client.put("client", voClientWechat); |
|---|
| | | } |
|---|
| | | return BaseResponseUtils.buildSuccess(job_client); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("查询农户异常", e); |
|---|
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
|---|
