forked from gzzfw/backEnd/gz-dyh

wangwh
2024-10-09 59c1eb27e839b65e59a16d459695cceb75eaa106
自动评价定时任务添加判空
1 files modified
7 ■■■■ changed files
dyh-service/dyh-mediate/src/main/java/cn/huge/module/timer/scheduledTask.java 7 ●●●● patch | view | raw | blame | history
dyh-service/dyh-mediate/src/main/java/cn/huge/module/timer/scheduledTask.java
@@ -12,6 +12,7 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import dm.jdbc.internal.convert.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -46,7 +47,9 @@
        caseTaskQueryWrapper.eq("node_id", FlowNodeEnum.FLOW_NODE_DSRPJ.getIndex())
                .eq("status", 1).le("expire_time", now);
        List<CaseTask> caseTaskList = caseTaskService.list(caseTaskQueryWrapper);
        List<String> caseIdList = caseTaskList.stream().map(CaseTask::getCaseId).collect(Collectors.toList());
        evaluateService.autoArchive(caseIdList);
        if(CollectionUtils.isNotEmpty(caseTaskList)){
            List<String> caseIdList = caseTaskList.stream().map(CaseTask::getCaseId).collect(Collectors.toList());
            evaluateService.autoArchive(caseIdList);
        }
    }
}