提交推送任务

This commit is contained in:
Guava
2023-06-26 10:04:30 +08:00
parent 42844af8b9
commit 2ff8bc42d5
2 changed files with 20 additions and 45 deletions

View File

@@ -42,7 +42,7 @@ public class CasesRecommendPushSchedule {
/**
* 每分钟执行一次
*/
@Scheduled(cron = "0 * * * * ? ")
@Scheduled(cron = "0 */1 * * * ?")
public void execute() {
List<CasesRecommend> casesRecommends = casesRecommendService.queryByPushProgress(CasesPushStatusEnum.WAIT_PUSH.name());
if (CollectionUtils.isEmpty(casesRecommends)) {
@@ -81,6 +81,7 @@ public class CasesRecommendPushSchedule {
pushRecordTemp.setPushStatus(CasesPushStatusEnum.PUSH_SUCCESS.getStatus());
} catch (Exception e) {
log.error("推荐案例失败", e);
pushRecordTemp.setPushStatus(CasesPushStatusEnum.PUSH_FAIL.getStatus());
}
casesRecommendPushRecordService.update(pushRecordTemp);