| | |
| | | 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; |
| | |
| | | caseTaskQueryWrapper.eq("node_id", FlowNodeEnum.FLOW_NODE_DSRPJ.getIndex()) |
| | | .eq("status", 1).le("expire_time", now); |
| | | List<CaseTask> caseTaskList = caseTaskService.list(caseTaskQueryWrapper); |
| | | if(CollectionUtils.isNotEmpty(caseTaskList)){ |
| | | List<String> caseIdList = caseTaskList.stream().map(CaseTask::getCaseId).collect(Collectors.toList()); |
| | | evaluateService.autoArchive(caseIdList); |
| | | } |
| | | } |
| | | } |