风行爱奇艺视频更新

admin

2020-10-26 89e370bfdda29ac8a8f7080a18dc09a6ddc75c09

 src/main/java/com/yeshi/buwan/util/SpringContext.java

@@ -2,12 +2,11 @@

import com.yeshi.buwan.domain.ResourceVideo;
import com.yeshi.buwan.domain.VideoInfo;
import com.yeshi.buwan.dto.mq.CMQConsumeMsg;
import com.yeshi.buwan.dto.mq.CMQResult;
import com.yeshi.buwan.dto.mq.FunTVAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
import com.yeshi.buwan.funtv.entity.FunTVAlbum2;
import com.yeshi.buwan.funtv.entity.FunTVVideo2;
import com.yeshi.buwan.iqiyi.entity.IqiyiAlbum2;
import com.yeshi.buwan.service.imp.JobThreadExecutorServiceImpl;
import com.yeshi.buwan.service.imp.ResourceVideoService;
@@ -33,7 +32,6 @@
@Component
public class SpringContext implements ApplicationListener<ContextRefreshedEvent> {


    @Resource
    private VideoInfoService videoInfoService;

@@ -48,7 +46,6 @@

    @Resource
    private ResourceVideoService resourceVideoService;


    private static boolean isInited = false;

@@ -157,9 +154,9 @@
            @Override
            public void run() {
                while (true) {
                    List<CMQConsumeMsg> cmqMsgList = CMQManager.getInstance().consumeVideoResourceDeleteMsg(16);
                    List<CMQResult> cmqMsgList = CMQManager.getInstance().consumeVideoResourceDeleteMsg(16);
                    if (cmqMsgList != null)
                        for (CMQConsumeMsg msg : cmqMsgList) {
                        for (CMQResult msg : cmqMsgList) {
                            try {
                                String videoId = msg.getData() + "";
                                //查询资源列表