提交

src/main/java/com/fjhx/controller/AccountController.java

@@ -50,7 +50,7 @@ public class AccountController {
      */
     @PostMapping("/listener")
     public R post(@RequestBody ListenerVo listenerVo) {
-        // accountService.listener(listenerVo);
+        accountService.listener(listenerVo);
         return R.ok();
     }
 

src/main/java/com/fjhx/service/impl/AccountServiceImpl.java

@@ -64,11 +64,10 @@ public class AccountServiceImpl implements IAccountService {
         if (emailInfo != null) {
             return emailInfo;
         }
-
-        // 添加账号
-        EmailEngineUtil.createAccount(bindingVo);
         // 保存账号信息到数据库
         emailInfo = this.saveEmailInfo(bindingVo);
+        // 添加账号
+        EmailEngineUtil.createAccount(bindingVo);
         // 查询邮箱文件夹
         List<EmailMailboxVo.MailboxesDTO> mailboxList = EmailEngineUtil.getMailboxList(email);
         // 添加邮箱文件夹
@@ -76,8 +75,7 @@ public class AccountServiceImpl implements IAccountService {
         // redis添加同步进度
         this.synchronizationProgressInitialization(email, bindingVo.getPages(), mailboxList);
         // 异步遍历文件夹下的所有邮件
-        this.asyncReadEmail(email, bindingVo.getPages(), emailMailboxList);
-
+        // this.asyncReadEmail(email, bindingVo.getPages(), emailMailboxList);
         return emailInfo;
     }