fix: 获取job列表接口改为三个月以内的数据

Signed-off-by: skyyemperor <skyyemperor@qq.com>
This commit is contained in:
2022-09-29 20:58:05 +08:00
parent 34e481f0a5
commit 7a5e6586a8
6 changed files with 40 additions and 34 deletions

View File

@@ -59,12 +59,23 @@ public class JobService {
@Autowired
private TaskExecutorUtil<?> taskExecutorUtil;
private static final String SUBJECT = "【DeepBIO Result Notice】";
private static final String SUCCESS_EMAIL_CONTENT = "Your request has been completed, click http://server.wei-group.net/front/biology/#/resultMail?jobId=%s to check the detail information";
private static final String FAIL_EMAIL_CONTENT = "We are very sorry, but some errors occurred in the task you submitted, click http://server.wei-group.net/front/biology/#/resultMail?jobId=%s to check the detail information";
private static final String TIMEOUT_EMAIL_CONTENT = "We are very sorry, but the task you submitted was overtime, click http://server.wei-group.net/front/biology/#/resultMail?jobId=%s to check the detail information";
private static final String RECEIVED_EMAIL_CONTENT = "Your request has been received, click http://server.wei-group.net/front/biology/#/resultMail?jobId=%s to check the detail information";
private static final String START_RUNNING_EMAIL_CONTENT = "Your task has started running, click http://server.wei-group.net/front/biology/#/resultMail?jobId=%s to check the detail information";
@Value("${email.subject}")
private String SUBJECT;
@Value("${email.content.success}")
private String SUCCESS_EMAIL_CONTENT;
@Value("${email.content.fail}")
private String FAIL_EMAIL_CONTENT;
@Value("${email.content.timeout}")
private String TIMEOUT_EMAIL_CONTENT;
@Value("${email.content.received}")
private String RECEIVED_EMAIL_CONTENT;
@Value("${email.content.running}")
private String START_RUNNING_EMAIL_CONTENT;
/**
* 提交job
@@ -156,7 +167,7 @@ public class JobService {
}
public Result getJobList(Integer type) {
List<Job> jobs = jobMapper.selectJobList(type, 200);
List<Job> jobs = jobMapper.selectJobList(type);
return Result.success(jobs.stream().map(JobLessDto::parseJob).collect(Collectors.toList()));
}