From af614e521a0b6b5c62e83929b1f0a981f55ac60d Mon Sep 17 00:00:00 2001
From: leomonM <2233021400@qq.com>
Date: Fri, 22 Aug 2025 14:57:34 +0800
Subject: [PATCH] Transaction
---
oying-system/src/main/java/com/oying/modules/message/service/impl/MesMsgRecordServiceImpl.java | 10 ++++------
1 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/oying-system/src/main/java/com/oying/modules/message/service/impl/MesMsgRecordServiceImpl.java b/oying-system/src/main/java/com/oying/modules/message/service/impl/MesMsgRecordServiceImpl.java
index 0f6416b..165b41c 100644
--- a/oying-system/src/main/java/com/oying/modules/message/service/impl/MesMsgRecordServiceImpl.java
+++ b/oying-system/src/main/java/com/oying/modules/message/service/impl/MesMsgRecordServiceImpl.java
@@ -114,6 +114,7 @@
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public void insertOrderMsg(String orderNo, OrderStatusEnum content, Long shopId) {
MesMsgRecord record = new MesMsgRecord();
record.setOrderNo(orderNo);
@@ -123,14 +124,11 @@
record.setIsRead(MesReadEnum.UNREAD.getKey()); // 默认未读 0
record.setCreateTime(new Timestamp(System.currentTimeMillis()));
record.setUpdateTime(new Timestamp(System.currentTimeMillis()));
- try {
- mesMsgRecordMapper.insert(record);
- } catch (Exception e) {
- log.error("插入订单消息失败：{}", e);
- }
-
+ mesMsgRecordMapper.insert(record); // 让异常直接往外抛
+
}
+
@Override
public List<MesMsgRecordQueryPollDto> PollMesAll(Long platform) {
return mesMsgRecordMapper.PollMesAll(platform);
--
Gitblit v1.9.3