邮件服务

bladex-saas-project/new-mail/src/main/java/com/fjhx/service/impl/CoreServiceImpl.java

@@ -325,6 +325,7 @@ public class CoreServiceImpl implements ApplicationRunner {
             mailFolderService.updateById(mailFolder);
             mailInfoService.saveBatch(mailInfoList);
             // 提交事务
+            transactionStatus.flush();
             platformTransactionManager.commit(transactionStatus);
         } catch (Exception e) {
             // 回滚事务

bladex-saas-project/new-mail/src/main/java/com/fjhx/service/impl/MailInfoServiceImpl.java

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