ufo / yohoufo-fore · Commits

Go to a project

Authored by DengXinFei
Commit cc78e9584a08d9ab0d21185eaa937b52324612d3 2 parents 2e4b0d7b 237b604c

支付宝实名认证

Inline Side-by-side
Showing 4 changed files with 78 additions and 20 deletions
... ... @@ -94,6 +94,25 @@ public class CertificationController {
return apiResponse;
}
/**
* 身份认证记录查询
* @param reqVO
* @return true: 通过, false: 不通过
* @throws GatewayException
*/
@RequestMapping(params = "method=ufo.user.alipayCertifyResultQuery")
public ApiResponse alipayCertifyResultQuery(RealNameAuthorizeReqVO reqVO) throws GatewayException {
logger.info("CertificationController.alipayCertifyResultQuery: Enter. RealNameAuthorizeReqVO is {}", reqVO);
//(1) 校验请求的参数
if (reqVO == null || StringUtils.isBlank(reqVO.getZhiMaBizNo())){
throw new GatewayException(400, "参数错误，zhiMaBizNo不能为空！");
}
//(2) 调用支付宝接口查询认证结果
ApiResponse result = certificationService.queryUserCertify(reqVO);
logger.info("CertificationController.alipayCertifyResultQuery: End. result is {}", result);
return result;
}
... ...
... ... @@ -12,7 +12,6 @@ import com.alipay.api.response.AlipayUserCertifyOpenInitializeResponse;
import com.alipay.api.response.AlipayUserCertifyOpenQueryResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.UUID;
/**
... ... @@ -124,38 +123,23 @@ public class AlipayCertHelper {
//生成请求链接，这里一定要使用GET模式
AlipayUserCertifyOpenCertifyResponse response = alipayClient.pageExecute(request, "GET");
if(response.isSuccess()){
System.out.println("开始认证服务调用成功");
String certifyUrl = response.getBody();
return certifyUrl;
} else {
System.out.println("调用失败");
}
return null;
}
public static String alipayCertifyResult(String certify_id) throws AlipayApiException {
public static AlipayUserCertifyOpenQueryResponse alipayCertifyResult(String certify_id) throws AlipayApiException {
//获取alipay client
AlipayClient alipayClient = new DefaultAlipayClient(ALI_URL, APP_ID, APP_PRIVATE_KEY, FORMAT, CHARSET, ALIPAY_PUBLIC_KEY, SIGN_TYPE);
AlipayUserCertifyOpenQueryRequest request = new AlipayUserCertifyOpenQueryRequest();
//设置certifyId
AlipayUserCertifyOpenQueryRequest request = new AlipayUserCertifyOpenQueryRequest ();
JSONObject bizContentObj = new JSONObject();
//certifyId是初始化接口返回
bizContentObj.put("certify_id", certify_id);
bizContentObj.put("certify_id", certify_id);//本次申请操作的唯一标识，由开放认证初始化接口调用后生成
request.setBizContent(bizContentObj.toString());
AlipayUserCertifyOpenQueryResponse response = alipayClient.execute(request);
if(response.isSuccess()){
System.out.println("开始认证服务调用成功");
String certifyUrl = response.getBody();
response.getPassed();
response.isSuccess();
return alipayClient.execute(request);
//执行后续流程...
} else {
System.out.println("调用失败");
}
return null;
}
... ...
package com.yohoufo.user.service;
import com.yoho.tools.common.beans.ApiResponse;
import com.yohobuy.ufo.model.user.resp.AuthorizeResultRespVO;
import com.yohoufo.dal.user.model.ZhiMaCert;
import com.yohoufo.user.requestVO.RealNameAuthorizeReqVO;
... ... @@ -22,4 +23,12 @@ public interface ICertificationService {
* @return 认证结果
*/
AuthorizeResultRespVO beginCertificate(RealNameAuthorizeReqVO realNameAuthorizeReqVO);
/**
* 身份认证记录查询
* @param reqVO
* @return
*/
ApiResponse queryUserCertify(RealNameAuthorizeReqVO reqVO);
}
... ...
package com.yohoufo.user.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.alipay.api.response.AlipayUserCertifyOpenQueryResponse;
import com.alipay.api.response.ZhimaCustomerCertificationQueryResponse;
import com.yoho.tools.common.beans.ApiResponse;
import com.yohobuy.ufo.model.user.resp.AuthorizeResultRespVO;
import com.yohoufo.common.constant.CertPhotoEnum;
import com.yohoufo.common.exception.UfoServiceException;
import com.yohoufo.dal.user.IZhiMaCertDao;
import com.yohoufo.dal.user.model.ZhiMaCert;
import com.yohoufo.user.helper.AlipayCertHelper;
import com.yohoufo.user.requestVO.RealNameAuthorizeReqVO;
import com.yohoufo.user.service.ICertificationService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
... ... @@ -26,6 +32,7 @@ public class CertificationServiceImpl implements ICertificationService {
private final Logger logger = LoggerFactory.getLogger(CertificationServiceImpl.class);
@Autowired
private IZhiMaCertDao zhiMaCertDao;
... ... @@ -92,4 +99,43 @@ public class CertificationServiceImpl implements ICertificationService {
}
return respBO;
}
@Override
public ApiResponse queryUserCertify(RealNameAuthorizeReqVO reqVO) {
try {
logger.info("queryUserCertify: enter. reqVO is {}", reqVO);
//(1) 根据 bizNo 查询认证信息是否存在
ZhiMaCert zhiMaCert = zhiMaCertDao.selectByBizNo(reqVO.getZhiMaBizNo());
if (zhiMaCert == null || StringUtils.isEmpty(zhiMaCert.getBizNo())) {
logger.warn("queryUserCertify: certInfo is null. reqVO is {}", reqVO);
throw new UfoServiceException(400, "未找到身份认证信息！");
}
//(2) 身份认证结果获取(调用支付宝接口)并更新
AlipayUserCertifyOpenQueryResponse response = AlipayCertHelper.alipayCertifyResult(zhiMaCert.getBizNo());
logger.info("queryUserCertify: queryUserCert by alipay success. reqVO is {}, certResult is {}", reqVO, response);
if(!response.isSuccess()){
logger.info("queryUserCertify: fail. reqVO is {}", reqVO);
throw new UfoServiceException(400, "查询身份认证结果失败");
}
JSONObject result = JSONObject.parseObject(response.getBody()).getJSONObject("alipay_user_certify_open_query_response");
if("Success".equals(result.get("msg")) && "T".equals(result.get("passed"))){
int updateCount = zhiMaCertDao.updateValidStatusByPrimaryKey(zhiMaCert.getId());
if(updateCount < 1){
logger.warn("queryUserCertify: update certResult fail. reqVO is {}", reqVO);
throw new UfoServiceException(400, "更新身份认证结果失败！");
}
logger.info("queryUserCertify: userCert pass. reqVO is {}, certResult is {}", reqVO, response);
return new ApiResponse<>(200, "身份认证通过", true);
}else{
String errorMsg = result.getString("sub_msg");//认证不通过可能是出现异常情况
logger.info("queryUserCertify: userCert notPass. reqVO is {}, certResult is {}", reqVO, response);
return new ApiResponse<>(400, StringUtils.isEmpty(errorMsg) ? "身份认证不通过" : errorMsg ,false);
}
}catch(Exception e){
logger.warn("queryUserCertify: error. reqVO is {}, e is {}", reqVO, e);
throw new UfoServiceException(400, "查询身份认证结果失败");
}
}
}
\ No newline at end of file
... ...