From 7becc97c5bfdd827b9a999c26746bb8e8bc3e25c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 13 三月 2021 16:23:36 +0800
Subject: [PATCH] 后台会员/会员订单查询,搜索结果高清标签添加,

---
 src/main/java/com/yeshi/buwan/service/imp/ClearService.java |   47 +++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 41 insertions(+), 6 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 4256f57..8e21f20 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/ClearService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/ClearService.java
@@ -2,6 +2,7 @@
 
 import java.math.BigInteger;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 
 import javax.annotation.Resource;
@@ -23,6 +24,14 @@
 //娓呴櫎鏁版嵁搴撲腑鐨勬鏁版嵁
 @Service
 public class ClearService {
+
+
+    private final String[] videoTables = 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"};
+
     @Resource
     private VideoInfoDao videoInfoDao;
 
@@ -75,13 +84,9 @@
     // 娓呮渚濊禆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) {
+
+        for (String table : videoTables) {
             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);
@@ -126,6 +131,36 @@
     }
 
     /**
+     * 娓呯悊SQL鏁版嵁搴撲緷璧栬棰�
+     *
+     * @param videoId
+     */
+    public void clearDependVideo(final String videoId) {
+        clearDependVideo(Arrays.asList(new String[]{videoId}));
+    }
+
+
+    public void clearDependVideo(final List<String> videoIds) {
+        videoInfoDao.excute(new HibernateCallback() {
+            public Object doInHibernate(Session session) throws HibernateException {
+                session.getTransaction().begin();
+                List<String> ors = new ArrayList<>();
+                for (String videoId : videoIds) {
+                    ors.add("videoid=" + videoId);
+                }
+
+                for (String table : videoTables)
+                    session.createSQLQuery(
+                            String.format("delete from %s where %s", table, org.yeshi.utils.StringUtil.concat(ors, " or ")))
+                            .executeUpdate();
+                session.flush();
+                session.getTransaction().commit();
+                return null;
+            }
+        });
+    }
+
+    /**
      * 娓呴櫎鏃犳晥鐨勭埍濂囪壓瑙嗛
      */
     @SuppressWarnings("unchecked")

--
Gitblit v1.8.0