CMQ转为Rabbitmq

admin

2024-10-17 b30fb8afd3cd6228bda9b182dc412bb3c8daf69c

 src/main/java/com/yeshi/buwan/videos/iqiyi/util/IqiyiUtil2.java

@@ -3,14 +3,14 @@
import com.yeshi.buwan.domain.AdminInfo;
import com.yeshi.buwan.domain.VideoDetailInfo;
import com.yeshi.buwan.domain.VideoType;
import com.yeshi.buwan.videos.iqiyi.IqiYiNewAPI;
import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum2;
import com.yeshi.buwan.videos.iqiyi.vo.IqiyiAlbumListResult;
import com.yeshi.buwan.service.inter.juhe.Iqiyi2Service;
import com.yeshi.buwan.util.TimeUtil;
import com.yeshi.buwan.util.log.VideoLogFactory;
import com.yeshi.buwan.util.mq.CMQManager;
import com.yeshi.buwan.util.mq.rabbit.RabbitmqManager;
import com.yeshi.buwan.util.video.VideoConstant;
import com.yeshi.buwan.videos.iqiyi.IqiYiNewAPI;
import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum2;
import com.yeshi.buwan.videos.iqiyi.vo.IqiyiAlbumListResult;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
@@ -36,6 +36,9 @@
    public final static String RESOURCE_NAME = "爱奇艺.";
    @Resource
    private Iqiyi2Service iqiyi2Service;

    @Resource
    private RabbitmqManager rabbitmqManager;

    private void saveAlbumAndVideo(List<IqiyiAlbum2> list) {
        if (list == null)
@@ -94,7 +97,7 @@
                }
            }
            iqiyi2Service.saveIqiyiAlbum(album);
            CMQManager.getInstance().addIqiyiAlbumUpdateMsg(album.getId());
            rabbitmqManager.addIqiyiAlbumUpdateMsg(album.getId());
        }
    }

@@ -143,7 +146,7 @@
                iqiyi2Service.deleteByAid(album.getId());
            }else {
                iqiyi2Service.saveIqiyiAlbum(album);
                CMQManager.getInstance().addIqiyiAlbumUpdateMsg(album.getId());
                rabbitmqManager.addIqiyiAlbumUpdateMsg(album.getId());
            }
        }
    }