接入视频直播

admin

2021-09-24 f788607ff771a47bc60d6a86e00b3433c40f3d2c

 src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiQueueService.java

@@ -8,8 +8,8 @@
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;

import com.yeshi.buwan.dao.juhe.IqiyiUpdateQueueDao;
import com.yeshi.buwan.iqiyi.entity.IqiyiUpdateQueue;
import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiUpdateQueueDao;
import com.yeshi.buwan.videos.iqiyi.entity.IqiyiUpdateQueue;
import com.yeshi.buwan.util.Constant;

@Service
@@ -25,7 +25,7 @@
    * @param url
    */
   public void addToUpdateQueue(String name, String url) {
      List<IqiyiUpdateQueue> list = iqiyiUpdateQueueDao.list("from IqiyiUpdateQueue queue where queue.url=?",
      List<IqiyiUpdateQueue> list = iqiyiUpdateQueueDao.list("from IqiyiUpdateQueue mq where mq.url=?",
            new Serializable[] { url });
      if (list != null && list.size() > 1)
         return;
@@ -56,14 +56,14 @@
   public List<IqiyiUpdateQueue> listUpdateQueue(String key, int page) {
      key = key == null ? "" : key;
      List<IqiyiUpdateQueue> list = iqiyiUpdateQueueDao.list(
            "from IqiyiUpdateQueue queue where queue.name like ? order by queue.id desc",
            "from IqiyiUpdateQueue mq where mq.name like ? order by mq.id desc",
            (page - 1) * Constant.pageCount, Constant.pageCount, new Serializable[] { "%" + key + "%" });
      return list;
   }

   public long countUpdateQueue(String key, int page) {
      key = key == null ? "" : key;
      return iqiyiUpdateQueueDao.getCount("from IqiyiUpdateQueue queue where queue.name like ?",
      return iqiyiUpdateQueueDao.getCount("from IqiyiUpdateQueue mq where mq.name like ?",
            new Serializable[] { "%" + key + "%" });
   }