| | |
| | | return null; |
| | | } |
| | | logger.debug("开始启动批次查询:" + this.currentVideoSearchMeta.getBatchId()); |
| | | } else { |
| | | // 如果 this.videoSearchTask 已经初始化,但 currentVideoSearchMeta == null,则需要查询数据库状态 |
| | | Object[] params = new Object[]{this.videoSearchTask.getSql(), new Object[]{}}; |
| | | this.currentVideoSearchMeta = (VideoSearchMeta)this.videoSearchTask.run(null, null, null, params); |
| | | } |
| | | if(this.currentVideoSearchMeta == null){ |
| | | // 说明上次已经创建 videoSearchTask 任务,但没有返回有效任务记录 |
| | | logger.debug(".........没有查询到要采集的记录:currentVideoSearchMeta"); |
| | | return null; |
| | | } |
| | | |