| | |
|---|
| | | private final ClientSv clientSv; |
|---|
| | | private final AliyunSmsSv aliyunSmsSv; |
|---|
| | | 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; |
|---|
| | |
|---|
| | | String sessionKey = job.getString("session_key"); |
|---|
| | | |
|---|
| | | Long clientId = clientSv.getClientIdByPhone(phoneNumber); |
|---|
| | | String SessionId = ""; |
|---|
| | | String sessionId = ""; |
|---|
| | | if(clientId != null) { |
|---|
| | | // 添加微信用户账户记录 |
|---|
| | | SeOpenId seOpenId = new SeOpenId(); |
|---|
| | |
|---|
| | | //Long SessionId = clientSv.addOpenId(seOpenId); |
|---|
| | | Long rec = clientSv.addOpenId(seOpenId); |
|---|
| | | if(rec != null) { |
|---|
| | | SessionId = String.valueOf(rec); |
|---|
| | | sessionId = String.valueOf(rec); |
|---|
| | | } |
|---|
| | | return BaseResponseUtils.buildSuccess(SessionId); |
|---|
| | | |
|---|
| | | JSONObject job_result = new JSONObject(); |
|---|
| | | job_result.put("clientId", clientId); |
|---|
| | | job_result.put("sessionId", sessionId); |
|---|
| | | return BaseResponseUtils.buildSuccess(job_result); |
|---|
| | | |
|---|
| | | } else { |
|---|
| | | return BaseResponseUtils.buildErrorMsg(WechatResultCode.PHONE_NUMBER_IS_ERROR.getMessage()); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 解绑农户与微信的绑定，根据sessionId删除绑定记录 |
|---|
| | | * @param sessionId |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @PostMapping(path = "unbind") |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public BaseResponse<Boolean> unbindWechat(@RequestParam("sessionId")Long sessionId) { |
|---|
| | | if(sessionId == null || sessionId <=0) { |
|---|
| | | return BaseResponseUtils.buildErrorMsg("sessionId无效"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | Integer rec = clientSv.unbindWechat(sessionId); |
|---|
| | | if(rec == null || rec == 0) { |
|---|
| | | return BaseResponseUtils.buildErrorMsg("sessionId错误"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return BaseResponseUtils.buildSuccess(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取农户基本信息，小程序首页使用 |
|---|
| | | * @param sessionId |
|---|
| | | * @return |
|---|
