|
@@ -349,7 +349,6 @@ public class MailInfoServiceImpl extends ServiceImpl<MailInfoMapper, MailInfo> i
|
|
mailAddressService.saveBatch(mailAddressList);
|
|
mailAddressService.saveBatch(mailAddressList);
|
|
update(Wrappers.<MailInfo>lambdaUpdate().eq(MailInfo::getId, mailId).set(MailInfo::getAddressSync, 1));
|
|
update(Wrappers.<MailInfo>lambdaUpdate().eq(MailInfo::getId, mailId).set(MailInfo::getAddressSync, 1));
|
|
// 提交事务
|
|
// 提交事务
|
|
- transactionStatus.flush();
|
|
|
|
platformTransactionManager.commit(transactionStatus);
|
|
platformTransactionManager.commit(transactionStatus);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
// 回滚事务
|
|
// 回滚事务
|
|
@@ -369,9 +368,7 @@ public class MailInfoServiceImpl extends ServiceImpl<MailInfoMapper, MailInfo> i
|
|
mailAttachmentService.saveBatch(mailAttachmentList);
|
|
mailAttachmentService.saveBatch(mailAttachmentList);
|
|
update(Wrappers.<MailInfo>lambdaUpdate().eq(MailInfo::getId, mailId)
|
|
update(Wrappers.<MailInfo>lambdaUpdate().eq(MailInfo::getId, mailId)
|
|
.set(MailInfo::getMessageSync, 1).set(MailInfo::getAttachmentSync, 1));
|
|
.set(MailInfo::getMessageSync, 1).set(MailInfo::getAttachmentSync, 1));
|
|
-
|
|
|
|
// 提交事务
|
|
// 提交事务
|
|
- transactionStatus.flush();
|
|
|
|
platformTransactionManager.commit(transactionStatus);
|
|
platformTransactionManager.commit(transactionStatus);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
// 回滚事务
|
|
// 回滚事务
|