xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

自动处理邮箱部分邮箱提示停止语句内容修改，输出方式改为log输出

Browse Source
This commit is contained in:
qiaoqinzheng 2024-02-20 14:59:03 +08:00
parent 735d9a1c59
commit 8219e50afe
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jeecg-module-auto-process/src/main/java/org/jeecg/modules/EmailParsingActuator.java
View File

@ -1,10 +1,12 @@
package org.jeecg.modules; package org.jeecg.modules;
import lombok.Setter; import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ArrayUtils; import org.apache.commons.lang3.ArrayUtils;
import org.jeecg.common.email.EmailLogManager; import org.jeecg.common.email.EmailLogManager;
import org.jeecg.common.email.EmailServiceManager; import org.jeecg.common.email.EmailServiceManager;
import org.jeecg.common.properties.TaskProperties; import org.jeecg.common.properties.TaskProperties;
import org.jeecg.common.util.DateUtils;
import org.jeecg.modules.email.EmailProperties; import org.jeecg.modules.email.EmailProperties;
import org.jeecg.modules.spectrum.EmailCounter; import org.jeecg.modules.spectrum.EmailCounter;
import org.jeecg.modules.spectrum.SpectrumLogManager; import org.jeecg.modules.spectrum.SpectrumLogManager;
@ -22,6 +24,7 @@ import java.util.concurrent.*;
/** /**
* 邮件解析执行器 * 邮件解析执行器
*/ */
@Slf4j
public class EmailParsingActuator extends Thread{ public class EmailParsingActuator extends Thread{
private TaskProperties taskProperties; private TaskProperties taskProperties;
@ -58,7 +61,8 @@ public class EmailParsingActuator extends Thread{
public void run() { public void run() {
for(;;){ for(;;){
if (isStop) { if (isStop) {
System.out.println("EmailParsingActuator is Stop!"); String nowDate = DateUtils.formatDate(new Date(), "yyyy-MM-dd HH:mm:ss");
log.info(nowDate + " " +this.emailProperties.getName()+" EmailParsingActuator is Stop!");
return; return;
} }
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();