支付宝支付开发代码-java版

package com.yz.commons.settlement.channel.ali;import com.alibaba.fastjson.JSONObject;import com.alipay.api.AlipayApiException;import com.alipay.api.AlipayClient;import com.alipay.api.DefaultAlipayClient;import com.alipay.api.domain.AlipayTradeAppPayModel;import com.alipay.api.internal.util.AlipaySignature;import com.alipay.api.request.AlipayTradeAppPayRequest;import com.alipay.api.request.AlipayTradeQueryRequest;import com.alipay.api.response.AlipayTradeAppPayResponse;import com.alipay.api.response.AlipayTradeQueryResponse;import lombok.extern.slf4j.Slf4j;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.stereotype.Service;import org.springframework.util.StringUtils;import java.math.BigDecimal;import java.util.HashMap;import java.util.Map;import java.util.Optional;@Slf4j@Service("ALI_APP_PAY")public class AliAppPay implements PayFacade {    private final ApplicationProperties applicationProperties;    private final ChargeOrderRepository chargeOrderRepository;    private final PayAccountConfigRepository payAccountConfigRepository;    private final StringRedisTemplate stringRedisTemplate;    private final PackagePayAccountRepository packagePayAccountRepository;    private final PackageInfoRepository packageInfoRepository;    private final NotifyUtil notifyUtil;    /**     * 账号缓存key     */    private final String configKey = "pay_config";    public AliAppPay (ApplicationProperties applicationProperties, ChargeOrderRepository chargeOrderRepository,                      PayAccountConfigRepository payAccountConfigRepository, StringRedisTemplate stringRedisTemplate,                      PackagePayAccountRepository packagePayAccountRepository, NotifyUtil notifyUtil, PackageInfoRepository packageInfoRepository) {        this.applicationProperties = applicationProperties;        this.chargeOrderRepository = chargeOrderRepository;        this.payAccountConfigRepository = payAccountConfigRepository;        this.stringRedisTemplate = stringRedisTemplate;        this.packagePayAccountRepository = packagePayAccountRepository;        this.notifyUtil = notifyUtil;        this.packageInfoRepository = packageInfoRepository;    }    /**     * 支付宝订单统一下单     * @param payPreParam     * @return     */    @Override    public PayPreResult unifiedOrder(PayPreParam payPreParam) {        PayPreResult payPreResult = new PayPreResult();        payPreResult.setOrderNo(payPreParam.getOrderNo());        payPreResult.setOrderStatus(GoldFlowStatus.SUCCESS);        payPreResult.setPayChannel(payPreParam.getPayChannelCode());        PayAccountConfig payAccountConfig = payPreParam.getPayAccountConfig();        String orderNo = payPreParam.getOrderNo();        AttachParam attachParam = payPreParam.getAttachParam();        String body = attachParam.getBody();        // 分， 需要转换成元        Long orderAmount = payPreParam.getOrderAmount();        String amount = new BigDecimal(orderAmount).divide(new BigDecimal("100")).toString();        //1  实例化客户端        AlipayClient alipayClient = getAlipayClient(payAccountConfig);        //2  实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay        AlipayTradeAppPayRequest request = new AlipayTradeAppPayRequest();        //3  SDK已经封装掉了公共参数，这里只需要传入业务参数。以下方法为sdk的model入参方式(model和biz_content同时存在的情况下取biz_content)。        AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();        model.setSubject(body);        model.setOutTradeNo(orderNo);        // 超时时间十五分钟        model.setTimeoutExpress("15m");        model.setTotalAmount(amount);        model.setProductCode("QUICK_MSECURITY_PAY");        request.setBizModel(model);        request.setNotifyUrl(notifyUtil.getNotifyUrl(payPreParam.getAttachParam().getPackageName(), ChargeOrderType.ALI_APP_PAY));        try {            //这里和普通的接口调用不同，使用的是sdkExecute            AlipayTradeAppPayResponse response = alipayClient.sdkExecute(request);            payPreResult.setPayInfo(response.getBody());        } catch (AlipayApiException e) {            e.printStackTrace();            payPreResult.setOrderStatus(GoldFlowStatus.REJECT);            payPreResult.setPayInfo("");        }        return payPreResult;    }    /**     * 订单查询     * @param payQueryParam     * @return     */    @Override    public PayQueryResult orderQuery(PayQueryParam payQueryParam) {        PayQueryResult payQueryResult = new PayQueryResult();        payQueryResult.setOrderStatus(GoldFlowStatus.PROCESSING);        payQueryResult.setPayMsg("请求状态未知");        String orderNo = payQueryParam.getOrderNo();        PayAccountConfig payAccountConfig = payQueryParam.getPayAccountConfig();        AlipayClient alipayClient = getAlipayClient(payAccountConfig);        AlipayTradeQueryRequest request = new AlipayTradeQueryRequest();        request.setBizContent("{\"out_trade_no\": " + orderNo + "}");        try {            AlipayTradeQueryResponse response = alipayClient.execute(request);            if (response.isSuccess()) {                String tradeStatus = response.getTradeStatus();                if ("TRADE_SUCCESS".equals(tradeStatus) || "TRADE_FINISHED".equals(tradeStatus)){                    payQueryResult.setOrderStatus(GoldFlowStatus.SUCCESS);                } else if ("TRADE_CLOSED".equals(tradeStatus)) {                    payQueryResult.setOrderStatus(GoldFlowStatus.REJECT);                }            }        } catch (AlipayApiException e) {            e.printStackTrace();        }        return payQueryResult;    }    /**     * 支付宝回调     * @param verifyParam     * @return     */    @Override    public VerifyResult orderVerify(VerifyParam verifyParam) {        VerifyResult verifyResult = new VerifyResult();        verifyResult.setOrderStatus(GoldFlowStatus.PROCESSING);        verifyResult.setResponseStr("failure");        Map<String, Object> parameterMap = verifyParam.getParameterMap();        Map<String,String> newMap = mapConvert(parameterMap);        String orderNo = newMap.get("out_trade_no");        ChargeOrder repository = chargeOrderRepository.findByOrderNo(orderNo);        String aliPublicKey = getAliPublicKey(repository.getPackageName(), repository.getCtype());        verifyResult.setOrderNo(orderNo);        try {            boolean isVerfied = AlipaySignature.rsaCheckV1(newMap, aliPublicKey, "UTF-8", SystemContants.ALI_SIGN_TYPE);            if (isVerfied) {                // 延签成功                String orderStatus = newMap.get("trade_status");                if ("TRADE_SUCCESS".equals(orderStatus) || "TRADE_FINISHED".equals(orderStatus)){                    verifyResult.setOrderStatus(GoldFlowStatus.SUCCESS);                    verifyResult.setResponseStr("success");                    // 支付包订单金额为元，转化成分                    String totalAmount = newMap.get("total_amount");                    Long orderAmount = new BigDecimal(totalAmount).multiply(new BigDecimal("100")).longValue();                    verifyResult.setOrderAmount(orderAmount);                } else if ("TRADE_CLOSED".equals(orderStatus)){                    verifyResult.setOrderStatus(GoldFlowStatus.REJECT);                    verifyResult.setResponseStr("success");                }            } else {                log.error("ali order verify check sign append error : {}", orderNo);            }        } catch (AlipayApiException e) {            e.printStackTrace();        }        return verifyResult;    }    private AlipayClient getAlipayClient(PayAccountConfig payAccountConfig){        AlipayClient alipayClient = new DefaultAlipayClient(applicationProperties.getPay().getAliAppPayUrl(),            payAccountConfig.getAppId(),            payAccountConfig.getAliPrivateKey(),            "json", "UTF-8",            payAccountConfig.getAliPublicKey(),            SystemContants.ALI_SIGN_TYPE);        return alipayClient;    }    /**     * 转换Map     * @param map     * @return     */    private static Map<String, String> mapConvert(Map<String , Object> map){        Map<String, String> resultMap = new HashMap<>();        for (String key : map.keySet()) {            resultMap.put(key, map.get(key)+"");        }        return resultMap;    }    private String getAliPublicKey(String packageName, String plant) {        PayAccountConfig payAccountConfig;        Object configObj = stringRedisTemplate.opsForHash().get(configKey, packageName + "." + plant);        if (null != configObj) {            payAccountConfig = JSONObject.parseObject(configObj.toString(), PayAccountConfig.class);            return payAccountConfig.getAliPublicKey();        } else {            PackageInfo packageInfo = packageInfoRepository.findByPackageName(packageName);            PackagePayAccount packagePayAccount = packagePayAccountRepository.findByPackageIdAndPlant(packageInfo.getId(), plant);            Optional<PayAccountConfig> optional = payAccountConfigRepository.findById(packagePayAccount.getAccountId());            payAccountConfig = optional.get();            payAccountConfig.setPlant(plant);            payAccountConfig.setPackageName(packageName);            return payAccountConfig.getAliPublicKey();        }    }}
更多相关文章

随机推荐
