From 0e3064b8722b33ee2cf67f8fac581a8b0e04832b Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 22 Dec 2023 18:15:58 +0800 Subject: [PATCH] 富文本框输入版本变化 --- src/main/java/cc/mrbird/febs/pay/service/impl/xcxCodePayServiceImpl.java | 136 +++++++++++++++++++++++++-------------------- 1 files changed, 76 insertions(+), 60 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/pay/service/impl/xcxCodePayServiceImpl.java b/src/main/java/cc/mrbird/febs/pay/service/impl/xcxCodePayServiceImpl.java index 950130a..f5980d6 100644 --- a/src/main/java/cc/mrbird/febs/pay/service/impl/xcxCodePayServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/pay/service/impl/xcxCodePayServiceImpl.java @@ -13,6 +13,7 @@ import cc.mrbird.febs.pay.util.WeixinServiceUtil; import cc.mrbird.febs.rabbit.producter.AgentProducer; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -46,43 +47,45 @@ private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final WeixinServiceUtil weixinServiceUtil; private final AgentProducer agentProducer; + private final WxPayService wxPayService; private static final String PAY_SUCCESS = "SUCCESS"; private static final String PAY_USERPAYING = "USERPAYING"; + private static final String PAY_FAIL = "FAIL"; @Override public String pay(MallOrderInfo mallOrderInfo) { - String appId = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.XCX_APP_ID.getType(), - DataDictionaryEnum.XCX_APP_ID.getCode() - ).getValue(); - String mchId = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.XCX_MCH_ID.getType(), - DataDictionaryEnum.XCX_MCH_ID.getCode() - ).getValue(); - String paySecret = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.XCX_MCH_KEY.getType(), - DataDictionaryEnum.XCX_MCH_KEY.getCode() - ).getValue(); - String keyPath = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.XCX_MCH_KEY_PATH_P12.getType(), - DataDictionaryEnum.XCX_MCH_KEY_PATH_P12.getCode() - ).getValue(); - String notifyUrl = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.XCX_NOTICE_URL.getType(), - DataDictionaryEnum.XCX_NOTICE_URL.getCode() - ).getValue(); - WxPayConfig payConfig = new WxPayConfig(); - payConfig.setAppId(StrUtil.trim(appId)); - payConfig.setMchId(StrUtil.trim(mchId)); - payConfig.setMchKey(StrUtil.trim(paySecret)); - payConfig.setKeyPath(StrUtil.trim(keyPath)); - payConfig.setNotifyUrl(StrUtil.trim(notifyUrl)); +// String appId = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( +// DataDictionaryEnum.XCX_APP_ID.getType(), +// DataDictionaryEnum.XCX_APP_ID.getCode() +// ).getValue(); +// String mchId = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( +// DataDictionaryEnum.XCX_MCH_ID.getType(), +// DataDictionaryEnum.XCX_MCH_ID.getCode() +// ).getValue(); +// String paySecret = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( +// DataDictionaryEnum.XCX_MCH_KEY.getType(), +// DataDictionaryEnum.XCX_MCH_KEY.getCode() +// ).getValue(); +// String keyPath = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( +// DataDictionaryEnum.XCX_MCH_KEY_PATH_P12.getType(), +// DataDictionaryEnum.XCX_MCH_KEY_PATH_P12.getCode() +// ).getValue(); +// String notifyUrl = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( +// DataDictionaryEnum.XCX_NOTICE_URL.getType(), +// DataDictionaryEnum.XCX_NOTICE_URL.getCode() +// ).getValue(); +// WxPayConfig payConfig = new WxPayConfig(); +// payConfig.setAppId(StrUtil.trim(appId)); +// payConfig.setMchId(StrUtil.trim(mchId)); +// payConfig.setMchKey(StrUtil.trim(paySecret)); +// payConfig.setKeyPath(StrUtil.trim(keyPath)); +// payConfig.setNotifyUrl(StrUtil.trim(notifyUrl)); // 可以指定是否使用沙箱环境 - payConfig.setUseSandboxEnv(false); - - WxPayService wxPayService = new WxPayServiceImpl(); - wxPayService.setConfig(payConfig); +// payConfig.setUseSandboxEnv(false); +// +// WxPayService wxPayService = new WxPayServiceImpl(); +// wxPayService.setConfig(payConfig); WxPayMicropayRequest request = new WxPayMicropayRequest(); /** * @@ -99,8 +102,8 @@ String sign = WXPayUtil.generateSignature(map, config.getKey()); map.put("sign", sign); */ - request.setAppid(appId); - request.setMchId(mchId); +// request.setAppid(appId); +// request.setMchId(mchId); request.setNonceStr(RandomStringGenerator.getRandomStringByLength(32)); request.setBody(mallOrderInfo.getName()); request.setOutTradeNo(mallOrderInfo.getOrderNo()); @@ -110,7 +113,7 @@ request.setAuthCode(mallOrderInfo.getTakeCode()); try { - request.setSign(Signature.getSign(request,paySecret)); + request.setSign(Signature.getSign(request,wxPayService.getConfig().getMchKey())); } catch (IllegalAccessException e) { e.printStackTrace(); throw new FebsException("签名异常"); @@ -128,38 +131,51 @@ if(PAY_SUCCESS.equals(returnCode) && PAY_SUCCESS.equals(resultCode)){ log.info("微信免密支付成功"); + MallOrderInfo orderInfo = mallOrderInfoMapper.selectByOrderNo(mallOrderInfo.getOrderNo()); + if(ObjectUtil.isNotEmpty(orderInfo)){ + if (OrderStatusEnum.FINISH.getValue() != orderInfo.getStatus()) { + orderInfo.setStatus(OrderStatusEnum.FINISH.getValue()); + orderInfo.setPayResult(1); + orderInfo.setPayTime(DateUtil.date()); + mallOrderInfoMapper.updateById(orderInfo); + } + } agentProducer.sendSyAppOrderPayDoneQueue(outTradeNo); return PAY_SUCCESS; - } else if (PAY_USERPAYING.equals(errCode)){//等待用户输入密码 - for(int i = 0; i < 4; i++){ - try { - Thread.sleep(5000); - } catch (InterruptedException e) { - e.printStackTrace(); - } - //调用微信的查询接口 - /** - * 交易成功判断条件: return_code、result_code和trade_state都为SUCCESS - */ - WxPayOrderQueryRequest wxPayOrderQueryRequest = new WxPayOrderQueryRequest(); - wxPayOrderQueryRequest.setOutTradeNo(outTradeNo); - WxPayOrderQueryResult wxPayOrderQueryResult = wxPayService.queryOrder(wxPayOrderQueryRequest); - String returnCodePaying = wxPayOrderQueryResult.getReturnCode(); - String resultCodePaying = wxPayOrderQueryResult.getResultCode(); - String tradeTypePaying = wxPayOrderQueryResult.getTradeType(); - if(PAY_SUCCESS.equals(tradeTypePaying)&& PAY_SUCCESS.equals(returnCodePaying)&& PAY_SUCCESS.equals(resultCodePaying)){ - log.info("微信加密支付成功!"); - agentProducer.sendSyAppOrderPayDoneQueue(outTradeNo); - return PAY_SUCCESS; - } - log.info("正在支付" + wxPayOrderQueryResult.getDetail()); - } } - log.error("微信支付失败!"); +// else if (PAY_USERPAYING.equals(errCode)){//等待用户输入密码 +// for(int i = 0; i < 4; i++){ +// try { +// Thread.sleep(5000); +// } catch (InterruptedException e) { +// e.printStackTrace(); +// } +// //调用微信的查询接口 +// /** +// * 交易成功判断条件: return_code、result_code和trade_state都为SUCCESS +// */ +// WxPayOrderQueryRequest wxPayOrderQueryRequest = new WxPayOrderQueryRequest(); +// wxPayOrderQueryRequest.setOutTradeNo(outTradeNo); +// log.info("付款码支付订单查询"); +// WxPayOrderQueryResult wxPayOrderQueryResult = wxPayService.queryOrder(wxPayOrderQueryRequest); +// String returnCodePaying = wxPayOrderQueryResult.getReturnCode(); +// String resultCodePaying = wxPayOrderQueryResult.getResultCode(); +// String tradeTypePaying = wxPayOrderQueryResult.getTradeType(); +// if(PAY_SUCCESS.equals(tradeTypePaying)&& PAY_SUCCESS.equals(returnCodePaying)&& PAY_SUCCESS.equals(tradeTypePaying)){ +// log.info("微信加密支付成功!"); +// agentProducer.sendSyAppOrderPayDoneQueue(outTradeNo); +// return PAY_SUCCESS; +// } +// log.info("正在支付" + wxPayOrderQueryResult.getDetail()); +// } +// } + else if(PAY_FAIL.equals(resultCode)){ + return errCodeDes; + } return errCodeDes; } catch (WxPayException e) { e.printStackTrace(); - throw new FebsException("支付异常"); + throw new FebsException(e.getErrCodeDes()); } } @@ -174,7 +190,7 @@ return; } orderInfo.setStatus(OrderStatusEnum.FINISH.getValue()); - orderInfo.setPayResult("1"); + orderInfo.setPayResult(1); orderInfo.setPayTime(DateUtil.date()); orderInfo.setPayTradeNo(params.get("transaction_id")); mallOrderInfoMapper.updateById(orderInfo); -- Gitblit v1.9.1