Springboot整合微信支付(订单过期取消及商户主动查单)
作者:肇事司机赵四 发布时间:2023-05-15 23:40:50
一:问题引入
前面讲到用户支付完成之后微信支付服务器会发送回调通知给商户,商户要能够正常处理这个回调通知并返回正确的状态码给微信支付后台服务器,不然微信支付后台服务器就会在一段时间之内重复发送回调通知给商户。具体流程见下图:
那么这时候问题就来了,微信后台发送回调通知次数也是有限制的,而且,微信支付开发文档中这样说到:对后台通知交互时,如果微信收到商户的应答不符合规范或超时,微信认为通知失败,微信会通过一定的策略定期重新发起通知,尽可能提高通知的成功率,但微信不保证通知最终能成功。也就是说我们不能单单通过微信支付的回调通知来被动地更新订单状态,假如接收微信回调通知失败但是这时候用户是已经付了款的,而商户这边却显示未付款状态,假如没有作进一步处理就会造成一些不必要的麻烦。这时候就需要商户主动向微信支付后台查询订单状态。
二:处理流程
一开始我采用的策略并不是延迟队列,而是采用定时器定时查询数据库来实现商户主动查单并实现订单过期自动取消功能,但是这一做法十分不友好,体现在下面几个方面:
定时查询数据库会加大数据库负担
假如数据量很大,频繁查询数据库消耗的时间较多
会造成时间误差,定时时间过长误差大,定时时间过短查询又太频繁
假如我设定的定时时间是5分钟查询一次,那么假如定时器还有1秒就要去查询一次,但是有一批订单还有2秒才到期,这时候定时器就处理不到这批订单。等下次再进行处理时候这批订单已经过期差不多5分钟了,这显然是很大的一个缺陷。此外假如很长一段时间都没有用户下单,但是由于定时器并不知道什么时候有用户下单什么时候没有用户下单,它只是个一到点就开始定时查询的无感情机器,这样就会产生一些不必要的开销。
实现订单过期自动删除的策略有很多,其中一种就是我上面提到的数据库轮询方法,此外,还可以采用的策略有:JDK的延迟队列、时间轮算法、redis缓存、使用消息队列等等,我选用的策略是采用RabbitMQ的延迟队列来实现,至于延迟队列的实现细节我将在下一篇文章讲解,这里仅介绍订单处理部分。
处理策略为商户下单之后生成订单存入数据库并将该订单号存入延迟队列,此时订单状态为“未支付”,假如接收微信回调成功并且验证到用户已付款,这时候就更新数据库中该订单状态为“已付款”。当延迟队列到期进行消费时,根据延迟队列中的订单号先在数据库中进行查询,假如这时候数据库中该订单状态为“已支付”,这时候就不需要进行处理,假如订单状态为“未支付”,商户程序应主动向微信支付后台进行订单状态查询,如果订单状态为已支付,这时候就不需要进行处理,如果订单状态为未支付,这时候就将订单状态改为“已取消”。一开始我的做法为无论数据库中该订单状态是否已支付都向微信支付后台进行订单状态查询,然后再根据查询结果做进一步处理,显然这种做法存在缺陷,就是每一笔订单都主动向微信支付后台进行查询会消耗很大的网络带宽,而且假如已经成功接收到微信支付回调通知的订单并不需要进行再次查询确认。
三:代码实现
3.1:orderServiceImpl.java
/**
* 提交订单
* @param orders
* @param session
*/
@Override
@Transactional
public Orders createOrder(Orders orders, HttpSession session) {
//获取当前用户信息
Long userId = (Long) session.getAttribute("user");
//查询地址数据
Long addressBookId = orders.getAddressBookId();
AddressBook addressBook = addressBookService.getById(addressBookId);
if(addressBook == null) {
throw new CustomException("用户地址信息有误,不能下单");
}
//获取当前用户购物车数据
LambdaQueryWrapper<ShoppingCart> SCLqw = new LambdaQueryWrapper<>();
SCLqw.eq(ShoppingCart::getUserId,userId);
List<ShoppingCart> shoppingCartList = shoppingCartService.list(SCLqw);
//生成订单号
long orderId = IdWorker.getId();
//设置订单号
orders.setNumber(String.valueOf(orderId));
//设置订单状态(待付款)
orders.setStatus(1);
//设置下单用户id
orders.setUserId(userId);
//设置下单时间
orders.setOrderTime(LocalDateTime.now());
//设置付款时间
orders.setCheckoutTime(LocalDateTime.now());
//设置实收金额
AtomicInteger amount = new AtomicInteger(0);
for(ShoppingCart shoppingCart : shoppingCartList) {
amount.addAndGet(shoppingCart.getAmount().multiply(new BigDecimal(100)).multiply(new BigDecimal(shoppingCart.getNumber())).intValue());
}
orders.setAmount(BigDecimal.valueOf(amount.get()));
//设置用户信息
User user = userService.getById(userId);
orders.setPhone(addressBook.getPhone());
orders.setAddress(addressBook.getDetail());
orders.setUserName(user.getPhone());
orders.setConsignee(addressBook.getConsignee());
//保存单条订单信息
this.save(orders);
//设置订单详细信息
List<OrderDetail> orderDetailList = new ArrayList<>();
for(ShoppingCart shoppingCart : shoppingCartList) {
OrderDetail orderDetail = new OrderDetail();
orderDetail.setName(shoppingCart.getName());
orderDetail.setImage(shoppingCart.getImage());
orderDetail.setOrderId(orderId);
orderDetail.setDishId(shoppingCart.getDishId());
orderDetail.setSetmealId(shoppingCart.getSetmealId());
orderDetail.setDishFlavor(shoppingCart.getDishFlavor());
orderDetail.setNumber(shoppingCart.getNumber());
AtomicInteger detailAmount = new AtomicInteger(0);
detailAmount.addAndGet(shoppingCart.getAmount().multiply(new BigDecimal(shoppingCart.getNumber())).intValue());
orderDetail.setAmount(BigDecimal.valueOf(detailAmount.get()));
orderDetailList.add(orderDetail);
}
//批量保存订单详细数据
orderDetailService.saveBatch(orderDetailList);
//清空购物车数据
shoppingCartService.remove(SCLqw);
//设置延迟队列,过期时间为5分钟
log.info("订单编号:{}进入延迟队列...",orders.getNumber());
delayProducer.publish(orders.getNumber(),String.valueOf(orders.getId()),
DelayMessageConfig.DELAY_EXCHANGE_NAME,DelayMessageConfig.ROUTING_KEY_ORDER,1000*60*5);
return orders;
}
3.2:RabbitmqDelayConsumer.java
/**
* 监听订单延迟队列
* @param orderNo
* @throws Exception
*/
@RabbitListener(queues = {"plugin.delay.order.queue"})
public void orderDelayQueue(String orderNo, Message message, Channel channel) throws Exception {
log.info("订单延迟队列开始消费...");
try {
//处理订单
wxPayService.checkOrderStatus(orderNo);
//告诉服务器收到这条消息 已经被我消费了 可以在队列删掉 这样以后就不会再发了 否则消息服务器以为这条消息没处理掉 后续还会在发
channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
log.info("消息接收成功");
} catch (Exception e) {
e.printStackTrace();
//消息重新入队
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,true);
log.info("消息接收失败,重新入队");
}
}
3.3:WxPayServiceImpl.java
/**
* 商户主动查询订单状态
* 当核实到订单超时未支付则取消订单
* 当核实到订单已支付则更新订单状态
*/
@Transactional(rollbackFor = Exception.class)
@Override
public void checkOrderStatus(String orderNo) throws Exception {
log.info("根据订单号核实订单状态==>{}",orderNo);
log.info("在数据库中查询订单状态....");
Integer status = ordersService.getOrderStatus(orderNo);
if(status != 1) {
//订单不是”未支付“状态
log.info("订单不是”未支付“状态,无需进行进一步处理");
return;
}
String result = this.queryOrder(orderNo);
Gson gson = new Gson();
Map<String,String> map = gson.fromJson(result, HashMap.class);
//获取订单状态
String tradeState = map.get("trade_state");
//判断订单状态
if(WxTradeState.NOTPAY.getType().equals(tradeState)) {
log.info("核实到订单超时未支付==>{}",orderNo);
//关闭订单
log.info("订单已自动取消");
this.closeOrder(orderNo);
//更新本地订单状态
ordersService.updateStatusByOrderNo(orderNo,"5");
}
else if(WxTradeState.SUCCESS.getType().equals(tradeState)) {
log.info("核实到订单已支付==>{}",orderNo);
Integer orderStatus = ordersService.getOrderStatus(orderNo);
if(orderStatus != null && orderStatus != 2) {
//更新本地订单状态
ordersService.updateStatusByOrderNo(orderNo,"2");
//保存订单记录
paymentInfoService.saveInfo(result);
}
}
else if(WxTradeState.CLOSED.getType().equals(tradeState)) {
log.info("核实到订单已取消==>{}",orderNo);
Integer orderStatus = ordersService.getOrderStatus(orderNo);
if(orderStatus != null && orderStatus != 5) {
//更新本地订单状态
ordersService.updateStatusByOrderNo(orderNo,"5");
//保存订单记录
paymentInfoService.saveInfo(result);
}
}
}
/**
* 查询订单
* @param orderNo
* @return
*/
@Override
public String queryOrder(String orderNo) throws Exception {
log.info("查单接口调用===>{}",orderNo);
//构建请求链接
String url = String.format(WxApiType.ORDER_QUERY_BY_NO.getType(),orderNo);
url = wxPayConfig.getDomain().concat(url).concat("?mchid=").concat(wxPayConfig.getMchId());
URIBuilder uriBuilder = new URIBuilder(url);
HttpGet httpGet = new HttpGet(uriBuilder.build());
httpGet.addHeader("Accept","application/json");
CloseableHttpResponse response = wxPayClient.execute(httpGet);
return EntityUtils.toString(response.getEntity());
}
来源:https://blog.csdn.net/weixin_45750572/article/details/125534014
猜你喜欢
- @Conditional的使用@Conditional可以根据条件来判断是否注入某些Bean。package com.morris.spri
- 1.什么是结构化编程编程中只使用三大结构不能使用goto语句1972年美国科学家,发表论文证明所有的程序流程,只需要三大结构完成。2.为什么
- List接口是Collection接口的子接口,List有一个重要的实现类--ArrayList类,List中的元素是有序排列的而且可重复,
- springboot + docker + jenkins自动化部署项目,jenkins、mysql、redis都是docker运行的,并且
- 本文实例为大家分享了java实现页显示效果的具体代码,供大家参考,具体内容如下效果图如下:实现步骤:1.创建实体User.class,参考代
- 项目场景:适用于接口数据敏感信息,比如 明文传输姓名、居住地址、手机号等信息,如果存在明文传输敏感数据问题、及数据泄漏风险,则可使用此方法加
- 1.用途在SpringBoot中,通过jasypt可以进行加密解密. 这个是双向的, 且可以配置密钥.2.使用:2.1通过UT创建工具类,并
- 实现的效果图:自定义Fragment继承BottomSheetDialogFragment重写它的三个方法:onCreateDialog()
- 这篇文章主要介绍了Spring-boot的debug调试代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值
- web.xml中设置:<servlet> <servlet-name>DisplayChart</servle
- Java——获取字符串编码格式判断一个字符串的编码格式: public static St
- ArrayList和LinkedList区别、扩容机制及底层实现ArrayListArrayList的底层实现为数组存储在内存中,线程不同步
- 本章目标整合 Mybatis ,并集成 Druid 数据源可视化监控 Druid 数据源使用 JPA 生成数据表利用注解实现数据库的事物利用
- 实践过程效果代码public partial class Form1 : Form{ public Form1()
- Java读文件修改默认换行符Java默认换行符是'\n'。但有时数据并不以'\n'进行换行方法如下publi
- 前言当系统的并发比较高的时候,日志的处理输出也是一种性能的开销负担,所以,选择一个中间件来处理消费日志必不可少!下面是spring boot
- 一、前言canal:阿里巴巴 MySQL binlog 增量订阅&消费组件https://github.com/alibaba/ca
- 近几天又温习了一下SpringMVC的运行机制以及原理我理解的springmvc,是设计模式MVC中C层,也就是Controller(控制)
- 假如是在同一台机器上开发,前后端分离的工程中出现跨域问题的原因是,前端工程和后端工程运行在不同的端口上。只要协议、域名、端口有一个不同就会产
- java.util.concurrent包中的工具实现核心都是AQS,了解ReentrantLock的实现原理,需要先分析AQS以及AQS与