From b30fb8afd3cd6228bda9b182dc412bb3c8daf69c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 17 十月 2024 16:28:48 +0800
Subject: [PATCH] CMQ转为Rabbitmq
---
src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java | 76 ++++++++++++++++---------------------
1 files changed, 33 insertions(+), 43 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java b/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java
index aa694e2..e519825 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java
@@ -1,44 +1,31 @@
package com.yeshi.buwan.service.imp.juhe;
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.Collections;
-import java.util.Comparator;
-import java.util.List;
-
-import javax.annotation.Resource;
-
+import com.yeshi.buwan.dao.ResourceVideoDao;
+import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiVideoInfoDao;
+import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyiDao;
+import com.yeshi.buwan.domain.*;
+import com.yeshi.buwan.domain.push.VideoPushHistory;
import com.yeshi.buwan.dto.mq.VideoDataChangeMQMsg;
-import com.yeshi.buwan.util.mq.CMQManager;
+import com.yeshi.buwan.log.LogHelper;
+import com.yeshi.buwan.service.imp.StatisticsService;
+import com.yeshi.buwan.service.imp.push.PushService;
+import com.yeshi.buwan.util.StringUtil;
+import com.yeshi.buwan.util.TimeUtil;
+import com.yeshi.buwan.util.mq.rabbit.RabbitmqManager;
+import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum;
+import com.yeshi.buwan.videos.iqiyi.entity.IqiyiVideoInfo;
+import com.yeshi.buwan.videos.iqiyi.entity.VideoIqiyi;
+import com.yeshi.buwan.videos.iqiyi.util.IqiyiUtil;
+import net.sf.json.JSONArray;
import org.apache.log4j.Logger;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
import org.springframework.stereotype.Service;
-import com.yeshi.buwan.dao.ResourceVideoDao;
-import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiVideoInfoDao;
-import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyiDao;
-import com.yeshi.buwan.domain.AdminInfo;
-import com.yeshi.buwan.domain.CategoryVideo;
-import com.yeshi.buwan.domain.ResourceVideo;
-import com.yeshi.buwan.domain.VideoDetailInfo;
-import com.yeshi.buwan.domain.VideoInfo;
-import com.yeshi.buwan.domain.VideoResource;
-import com.yeshi.buwan.domain.VideoType;
-import com.yeshi.buwan.domain.push.VideoPushHistory;
-import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum;
-import com.yeshi.buwan.videos.iqiyi.entity.IqiyiVideoInfo;
-import com.yeshi.buwan.videos.iqiyi.entity.VideoIqiyi;
-import com.yeshi.buwan.videos.iqiyi.util.IqiyiUtil;
-import com.yeshi.buwan.log.LogHelper;
-import com.yeshi.buwan.service.imp.StatisticsService;
-import com.yeshi.buwan.service.imp.push.PushService;
-import com.yeshi.buwan.util.StringUtil;
-import com.yeshi.buwan.util.TimeUtil;
-
-import net.sf.json.JSONArray;
+import javax.annotation.Resource;
+import java.io.Serializable;
+import java.util.*;
@Service
public class IqiyiService {
@@ -54,6 +41,9 @@
@Resource
private ResourceVideoDao resourceVideoDao;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
static {
@@ -292,7 +282,7 @@
String id = "";
if (same == null) {
id = session.save(vi).toString();
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, id, VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, id, VideoDataChangeMQMsg.ACTION_ADD));
// if(id!=null)
// session.createSQLQuery(String.format("CALL
// copyvideotemp(%s)",id)).executeUpdate();
@@ -323,7 +313,7 @@
}
session.update(same);// 鏇存柊鍘熸潵鐨勮棰�
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, same.getId(), VideoDataChangeMQMsg.ACTION_UPDATE));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, same.getId(), VideoDataChangeMQMsg.ACTION_UPDATE));
Object obj = session
.createQuery(
@@ -336,7 +326,7 @@
rv.setResource(new VideoResource("13"));
rv.setVideo(new VideoInfo(same.getId()));
session.persist(rv);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
}
}
@@ -352,7 +342,7 @@
rv.setResource(new VideoResource("13"));
rv.setVideo(new VideoInfo(id));
session.persist(rv);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
}
VideoIqiyi vii = new VideoIqiyi();
@@ -402,7 +392,7 @@
}
session.update(list.get(0).getVideo());
vid = list.get(0).getVideo().getId();
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, vid, VideoDataChangeMQMsg.ACTION_UPDATE));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, vid, VideoDataChangeMQMsg.ACTION_UPDATE));
Object obj = session
.createQuery(
@@ -416,7 +406,7 @@
rv.setResource(new VideoResource("13"));
rv.setVideo(new VideoInfo(list.get(0).getVideo().getId()));
session.persist(rv);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
}
}
// 鏇存柊tag
@@ -443,7 +433,7 @@
if (same == null) {
vi.setVideocount(videoDetailCount);
videoid = session.save(vi).toString();
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_ADD));
} else
videoid = same.getId();
@@ -464,7 +454,7 @@
rv.setResource(new VideoResource("13"));
rv.setVideo(new VideoInfo(videoid));
session.persist(rv);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
}
if (same != null)// 鏇存柊鍐呭
@@ -489,7 +479,7 @@
+ "");
session.update(same);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_UPDATE));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_UPDATE));
obj = session
.createQuery(
@@ -503,7 +493,7 @@
rv.setResource(new VideoResource("13"));
rv.setVideo(same);
session.persist(rv);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
}
}
@@ -567,7 +557,7 @@
rv.setResource(new VideoResource("13"));
rv.setVideo(list.get(0).getVideo());
session.persist(rv);
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
}
vid = list.get(0).getVideo().getId();
}
--
Gitblit v1.8.0