| | |
|---|
| | | 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; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // |
|---|
| | | this.videoSearchTask.checkExecutor(this.currentVideoSearchMeta); |
|---|
| | | // |
|---|
| | | int result = this.videoSearchTask.executeOneSearch(); |
|---|
| | | int result = 0; |
|---|
| | | try{ |
|---|
| | | result = this.videoSearchTask.executeOneSearch(); |
|---|
| | | } catch (Exception ex){ |
|---|
| | | logger.error("executeOneSearch(): 执行异常:" + ex.getMessage(), ex); |
|---|
| | | result = -1; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(result == 0){ |
|---|
| | | return SUCCESS; |
|---|
