| | |
| | | doInternetSearchVideoUpdateJob(); |
| | | doUpdateResourceVideoJob(); |
| | | } |
| | | // doUpdateResourceVideoJob(); |
| | | } |
| | | |
| | | private void doSolrJob() { |
| | |
| | | new JobThreadExecutorServiceImpl().run(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | System.out.println("消费结束:doUpdateResourceVideoJob"); |
| | | List<UpdateResourceVideoMQMsg> msgList = CMQManager.getInstance().consumeUpdateResourceVideoMsg(16); |
| | | System.out.println("消费结束:doUpdateResourceVideoJob"); |
| | | if (msgList != null) |
| | | for (UpdateResourceVideoMQMsg videoMQMsg : msgList) { |
| | | try { |
| | |
| | | iqiyi2Service.offlineIqiyiAlbum(Long.parseLong(videoMQMsg.getId())); |
| | | } else { |
| | | //保存 |
| | | iqiyiUtil2.syncByAid(iqiyiAlbum2.getId(),false); |
| | | iqiyiUtil2.syncByAid(iqiyiAlbum2.getId(), false); |
| | | } |
| | | break; |
| | | } |