czg_team
/
cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

事务执行消息推送

This commit is contained in:
wangw 2025-09-30 15:27:13 +08:00
parent 0e53da8d18
commit 22042eb66e
2 changed files with 63 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
cash-api/order-server/src/main/java/com/czg/mq/PrintMqListener.java
View File

@ -66,11 +66,6 @@ public class PrintMqListener {
@RabbitListener(queues = {"${spring.profiles.active}-" + RabbitConstants.Queue.ORDER_MACHINE_PRINT_QUEUE}) @RabbitListener(queues = {"${spring.profiles.active}-" + RabbitConstants.Queue.ORDER_MACHINE_PRINT_QUEUE})
public void orderPrint(String req) { public void orderPrint(String req) {
// 使用异步线程池执行延迟任务，不阻塞当前消费者线程
CompletableFuture.runAsync(() -> {
try {
// 延迟3秒处理
TimeUnit.SECONDS.sleep(3);
// 执行核心打印逻辑 // 执行核心打印逻辑
invokeFun("orderPrint", "java.order", req, (data) -> { invokeFun("orderPrint", "java.order", req, (data) -> {
JSONObject jsonObject = JSONObject.parseObject(data); JSONObject jsonObject = JSONObject.parseObject(data);
@ -84,15 +79,33 @@ public class PrintMqListener {
return null; return null;
}, RedisCst.getLockKey("orderPrint", orderId)); }, RedisCst.getLockKey("orderPrint", orderId));
}); });
} catch (InterruptedException e) { // // 使用异步线程池执行延迟任务，不阻塞当前消费者线程
Thread.currentThread().interrupt(); // CompletableFuture.runAsync(() -> {
// 记录中断日志 // try {
log.warn("打印任务被中断，req:{}", req, e); // // 延迟3秒处理
} catch (Exception e) { // TimeUnit.SECONDS.sleep(3);
// 记录业务异常日志 // // 执行核心打印逻辑
log.error("打印任务处理失败，req:{}", req, e); // invokeFun("orderPrint", "java.order", req, (data) -> {
} // JSONObject jsonObject = JSONObject.parseObject(data);
}, asyncExecutor); // String orderId = jsonObject.getString("orderId");
// if (orderId == null) {
// throw new RuntimeException("订单打印失败，未传递orderId");
// }
// Boolean printOrder = jsonObject.getBoolean("printOrder");
// funUtil.runFunAndCheckKey(() -> {
// printerHandler.handler(orderId, printOrder != null && !printOrder ? PrinterHandler.PrintTypeEnum.ONE : PrinterHandler.PrintTypeEnum.ONE_AND_ORDER);
// return null;
// }, RedisCst.getLockKey("orderPrint", orderId));
// });
// } catch (InterruptedException e) {
// Thread.currentThread().interrupt();
// // 记录中断日志
// log.warn("打印任务被中断，req:{}", req, e);
// } catch (Exception e) {
// // 记录业务异常日志
// log.error("打印任务处理失败，req:{}", req, e);
// }
// }, asyncExecutor);
} }
/** /**

30
cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java
View File

@ -55,6 +55,8 @@ import org.apache.dubbo.config.annotation.DubboService;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.springframework.context.annotation.Lazy; import org.springframework.context.annotation.Lazy;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
@ -1026,13 +1028,29 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
shopTableService.updateById(table); shopTableService.updateById(table);
} }
} }
orderDetailService.updateChain().set(OrderDetail::getStatus, OrderStatusEnums.DONE.getCode()).eq(OrderDetail::getOrderId, orderInfo.getId()).update(); // 保存消息参数（避免闭包中引用的变量被修改）
// if (!"after-pay".equals(orderInfo.getPayMode())) { final Long orderId = orderInfo.getId();
//发送打票信息 final boolean isPrint = orderInfo.getIsPrint() == 1;
final String payMode = orderInfo.getPayMode();
// 【关键改造】注册事务同步器，在事务提交后发送消息
if (TransactionSynchronizationManager.isSynchronizationActive()) {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override
public void afterCommit() {
// 事务成功提交后执行消息发送
String printParam = orderId + "_" + (!"after-pay".equals(payMode) ? 1 : 0) + "_1";
rabbitPublisher.sendOrderPrintMsg(printParam, isPrint);
// log.info("订单{}事务提交后，发送打印消息", orderId);
}
});
} else {
// 非事务环境下直接发送（兼容无事务场景）
String printParam = orderId + "_" + (!"after-pay".equals(payMode) ? 1 : 0) + "_1";
rabbitPublisher.sendOrderPrintMsg(printParam, isPrint);
// log.info("非事务环境下，直接发送订单{}打印消息", orderId);
}
//orderId_0_0 订单ID_先付后付(1先付0后付)_订单状态 0未完成 1完成
rabbitPublisher.sendOrderPrintMsg(orderInfo.getId() + "_" + (!"after-pay".equals(orderInfo.getPayMode()) ? 1 : 0) + "_1", orderInfo.getIsPrint() == 1);
// }
redisService.del(RedisCst.classKeyExpired.EXPIRED_ORDER + orderInfo.getId()); redisService.del(RedisCst.classKeyExpired.EXPIRED_ORDER + orderInfo.getId());
} }