From f7b2baec57a19039ca85880bbba4e17fe27f0511 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 10 三月 2021 18:21:13 +0800
Subject: [PATCH] 删除冗余代码，初步优化首页的推荐专题，3.8.7之后在我的里面添加VIP分类
---
src/main/java/com/yeshi/buwan/service/imp/ClearService.java | 238 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 119 insertions(+), 119 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/ClearService.java b/src/main/java/com/yeshi/buwan/service/imp/ClearService.java
index 32217d5..4256f57 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/ClearService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/ClearService.java
@@ -23,139 +23,139 @@
//娓呴櫎鏁版嵁搴撲腑鐨勬鏁版嵁
@Service
public class ClearService {
- @Resource
- private VideoInfoDao videoInfoDao;
+ @Resource
+ private VideoInfoDao videoInfoDao;
- @SuppressWarnings("rawtypes")
- public void clearVideos(long[] ls, String date) {
- final List<JSONObject> list = new ArrayList<JSONObject>();
+ @SuppressWarnings("rawtypes")
+ public void clearVideos(long[] ls, String date) {
+ final List<JSONObject> list = new ArrayList<>();
- for (long id : ls) {
- JSONObject json = new JSONObject();
- json.put("videotype", id);
- json.put("time", TimeUtil.convertGernalTime(date, "yyyy-MM-dd"));
- list.add(json);
- }
+ for (long id : ls) {
+ JSONObject json = new JSONObject();
+ json.put("videotype", id);
+ json.put("time", TimeUtil.convertGernalTime(date, "yyyy-MM-dd"));
+ list.add(json);
+ }
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- for (JSONObject item : list) {
- List list = session
- .createSQLQuery(String.format(
- "SELECT cv.`videoid` FROM wk_category_video cv LEFT JOIN wk_video_video v ON v.`id`=cv.`videoid` WHERE cv.`videotypeid`=%s AND v.`createtime`<%s",
- item.getLong("videotype"), item.getLong("time")))
- .setFirstResult(0).setMaxResults(1000).list();
- session.getTransaction().begin();
- if (list != null) {
- int pagecount = 50;
- int pages = list.size() % pagecount == 0 ? list.size() / pagecount
- : list.size() / pagecount + 1;
- for (int i = 0; i < pages; i++) {
- String where = "";
- for (int p = 0; p < pagecount; p++) {
- int pos = i * pagecount + p;
- pos = pos >= list.size() ? list.size() - 1 : pos;
- where += String.format("id=%s or ", list.get(pos) + "");
- }
- if (where.endsWith("or "))
- where = where.substring(0, where.length() - 3);
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ for (JSONObject item : list) {
+ List list = session
+ .createSQLQuery(String.format(
+ "SELECT cv.`videoid` FROM wk_category_video cv LEFT JOIN wk_video_video v ON v.`id`=cv.`videoid` WHERE cv.`videotypeid`=%s AND v.`createtime`<%s",
+ item.getLong("videotype"), item.getLong("time")))
+ .setFirstResult(0).setMaxResults(1000).list();
+ session.getTransaction().begin();
+ if (list != null) {
+ int pagecount = 50;
+ int pages = list.size() % pagecount == 0 ? list.size() / pagecount
+ : list.size() / pagecount + 1;
+ for (int i = 0; i < pages; i++) {
+ String where = "";
+ for (int p = 0; p < pagecount; p++) {
+ int pos = i * pagecount + p;
+ pos = pos >= list.size() ? list.size() - 1 : pos;
+ where += String.format("id=%s or ", list.get(pos) + "");
+ }
+ if (where.endsWith("or "))
+ where = where.substring(0, where.length() - 3);
- session.createSQLQuery("delete from wk_video_video where " + where).executeUpdate();
- }
- }
- session.flush();
- session.getTransaction().commit();
- }
- return null;
- }
- });
+ session.createSQLQuery("delete from wk_video_video where " + where).executeUpdate();
+ }
+ }
+ session.flush();
+ session.getTransaction().commit();
+ }
+ return null;
+ }
+ });
- }
+ }
- // 娓呮渚濊禆VideoInfo鐨勬暟鎹�
- @SuppressWarnings("rawtypes")
- public void clearDependVideo() {
- String[] tables = new String[] { "wk_category_video", "wk_resource_video", "wk_video_attention",
- "wk_video_banquan_video", "wk_video_banquan_webvideo", "wk_video_collection", "wk_video_comment",
- "wk_video_comment2", "wk_video_getscore_collect", "wk_video_homead", "wk_video_homevideo",
- "wk_video_hotstar_video", "wk_video_iqiyi", "wk_video_letv", "wk_video_play_statistics",
- "wk_video_pptv", "wk_video_sohu", "wk_video_special_video", "wk_video_youku", "wk_video_youku_dj" };
+ // 娓呮渚濊禆VideoInfo鐨勬暟鎹�
+ @SuppressWarnings("rawtypes")
+ public void clearDependVideo() {
+ String[] tables = new String[]{"wk_category_video", "wk_resource_video", "wk_video_attention",
+ "wk_video_banquan_video", "wk_video_banquan_webvideo", "wk_video_collection", "wk_video_comment",
+ "wk_video_comment2", "wk_video_getscore_collect", "wk_video_homead", "wk_video_homevideo",
+ "wk_video_hotstar_video", "wk_video_iqiyi", "wk_video_letv", "wk_video_play_statistics",
+ "wk_video_pptv", "wk_video_sohu", "wk_video_special_video", "wk_video_youku", "wk_video_youku_dj"};
- for (String table : tables) {
- final String sql = String.format(
- "SELECT vv.id FROM `%s` vv LEFT JOIN wk_video_video v ON v.`id`=vv.`videoid` WHERE v.`id` IS NULL",
- table);
- Object obj = videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- return session.createSQLQuery(sql).setFirstResult(0).setMaxResults(1000).list();
- }
- });
+ for (String table : tables) {
+ final String sql = String.format(
+ "SELECT vv.id FROM `%s` vv LEFT JOIN wk_video_video v ON v.`id`=vv.`videoid` WHERE v.`id` IS NULL",
+ table);
+ Object obj = videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ return session.createSQLQuery(sql).setFirstResult(0).setMaxResults(1000).list();
+ }
+ });
- final List list = (List) obj;
+ final List list = (List) obj;
- if (list != null && list.size() > 0) {
- String idsStr = "";
- for (int i = 0; i < list.size(); i++) {
- idsStr += " or id=" + list.get(i);
- }
- if (idsStr.startsWith(" or"))
- idsStr = idsStr.substring(3);
- final String tempTable = table;
- final String tempIds = idsStr;
- try {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- session.getTransaction().begin();
- if (!StringUtil.isNullOrEmpty(tempIds.trim())) {
- session.createSQLQuery(
- String.format("delete from %s where %s", tempTable, tempIds + ""))
- .executeUpdate();
- }
- session.flush();
- session.getTransaction().commit();
- return null;
- }
- });
- } catch (Exception e) {
+ if (list != null && list.size() > 0) {
+ String idsStr = "";
+ for (int i = 0; i < list.size(); i++) {
+ idsStr += " or id=" + list.get(i);
+ }
+ if (idsStr.startsWith(" or"))
+ idsStr = idsStr.substring(3);
+ final String tempTable = table;
+ final String tempIds = idsStr;
+ try {
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ session.getTransaction().begin();
+ if (!StringUtil.isNullOrEmpty(tempIds.trim())) {
+ session.createSQLQuery(
+ String.format("delete from %s where %s", tempTable, tempIds + ""))
+ .executeUpdate();
+ }
+ session.flush();
+ session.getTransaction().commit();
+ return null;
+ }
+ });
+ } catch (Exception e) {
- }
+ }
- }
+ }
- }
- }
+ }
+ }
- /**
- * 娓呴櫎鏃犳晥鐨勭埍濂囪壓瑙嗛
- */
- @SuppressWarnings("unchecked")
- public void clearInvalidIqiyiVideo() {
- IqiyiService iqiyiService = com.yeshi.buwan.util.BeanUtil.getBean(IqiyiService.class);
+ /**
+ * 娓呴櫎鏃犳晥鐨勭埍濂囪壓瑙嗛
+ */
+ @SuppressWarnings("unchecked")
+ public void clearInvalidIqiyiVideo() {
+ IqiyiService iqiyiService = com.yeshi.buwan.util.BeanUtil.getBean(IqiyiService.class);
- // 鏌ヨ鍑�
- // SELECT DISTINCT(i.videoid) FROM `wk_video_iqiyi` i LEFT JOIN
- // wk_video_video v ON v.id=i.videoid WHERE v.show=1;
- // 鏌ヨ鍑烘墍鏈夌殑iqiyi瑙嗛
+ // 鏌ヨ鍑�
+ // SELECT DISTINCT(i.videoid) FROM `wk_video_iqiyi` i LEFT JOIN
+ // wk_video_video v ON v.id=i.videoid WHERE v.show=1;
+ // 鏌ヨ鍑烘墍鏈夌殑iqiyi瑙嗛
- for (int i = 1; i < 100; i++) {
- final int p = i;
- List<BigInteger> videoList = (List<BigInteger>) videoInfoDao
- .excute(new HibernateCallback<List<BigInteger>>() {
+ for (int i = 1; i < 100; i++) {
+ final int p = i;
+ List<BigInteger> videoList = (List<BigInteger>) videoInfoDao
+ .excute(new HibernateCallback<List<BigInteger>>() {
- @Override
- public List<BigInteger> doInHibernate(Session session) throws HibernateException {
- return session
- .createSQLQuery(
- "SELECT DISTINCT(i.videoid) FROM `wk_video_iqiyi` i LEFT JOIN wk_video_video v ON v.id=i.videoid WHERE v.show=1")
- .setFirstResult(p * 10000).setMaxResults(10000).list();
- }
- });
- for (BigInteger videoId : videoList) {
- List<VideoDetailInfo> list = iqiyiService.getVideoDetailList(videoId.toString());
- if (list == null) {
- iqiyiService.deleteIqiyiVideoByVideoId(videoId.toString());
- }
- }
- }
- }
+ @Override
+ public List<BigInteger> doInHibernate(Session session) throws HibernateException {
+ return session
+ .createSQLQuery(
+ "SELECT DISTINCT(i.videoid) FROM `wk_video_iqiyi` i LEFT JOIN wk_video_video v ON v.id=i.videoid WHERE v.show=1")
+ .setFirstResult(p * 10000).setMaxResults(10000).list();
+ }
+ });
+ for (BigInteger videoId : videoList) {
+ List<VideoDetailInfo> list = iqiyiService.getVideoDetailList(videoId.toString(), 1, 2000);
+ if (list == null) {
+ iqiyiService.deleteIqiyiVideoByVideoId(videoId.toString());
+ }
+ }
+ }
+ }
}
--
Gitblit v1.8.0