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