Email扫描线程重构

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/EmailScanHelper.java

@@ -23,6 +23,7 @@ import java.util.concurrent.TimeUnit;
  **/
 @Component
 @Slf4j
+@Deprecated
 public class EmailScanHelper {
 
     private final DataSource dataSource;

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/EmailThreadRunHelper.java

 package com.byit.thread.helper;
 
 import cn.hutool.core.collection.CollectionUtil;
-import com.byit.factory.DaemonScanThreadRunHelper;
 import com.byit.model.EmailAlarm;
 import com.byit.model.vo.EmailAlarmVo;
 import com.byit.service.EmailAlarmService;
@@ -21,6 +20,7 @@ import java.util.List;
 public class EmailThreadRunHelper extends BaseThreadRunHelper {
     private static final String LOCK_NAME = "emali_alarm_lock";
     private final DataSource dataSource;
+
     private final EmailAlarmService emailAlarmService;
 
     public EmailThreadRunHelper(DataSource dataSource, EmailAlarmService emailAlarmService) {
@@ -29,8 +29,7 @@ public class EmailThreadRunHelper extends BaseThreadRunHelper {
     }
 
     @Override
-    public boolean start() {
-        boolean isSleep = false;
+    public Long start() {
         //查询未告警的邮箱
         List<EmailAlarm> emailAlarmByAlarmResults = emailAlarmService.findEmailAlarmByAlarmResult();
         if(CollectionUtil.isNotEmpty(emailAlarmByAlarmResults)){
@@ -40,9 +39,9 @@ public class EmailThreadRunHelper extends BaseThreadRunHelper {
                 emailAlarmService.sendEmail(emailAlarmVo);
             });
         }else{
-            isSleep = true;
+            return UNIVERSAL_WAIT_TIME;
         }
-        return isSleep;
+        return NOT_WAIT_TIME;
     }
 
     @Override