From 4ebe7c447e964e1b3ead12abb1d95b75faf67426 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 27 二月 2021 15:22:46 +0800
Subject: [PATCH] PPTV完善，兼容多个系统的框架搭建
---
src/main/java/com/yeshi/buwan/service/manager/SolrAlbumDataManager.java | 73 ++++++++++++++++++------------------
1 files changed, 37 insertions(+), 36 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/manager/SolrAlbumDataManager.java b/src/main/java/com/yeshi/buwan/service/manager/SolrAlbumDataManager.java
index cc55f50..1403b5d 100644
--- a/src/main/java/com/yeshi/buwan/service/manager/SolrAlbumDataManager.java
+++ b/src/main/java/com/yeshi/buwan/service/manager/SolrAlbumDataManager.java
@@ -74,21 +74,18 @@
}
/**
- *鍒犻櫎鎵�鏈�
+ * 鍒犻櫎鎵�鏈�
*/
- public void clear() {
- Query query = new SimpleQuery("name:*");
- UpdateResponse updateResponse = solrTemplate.delete(query);
- if (updateResponse.getStatus() == 0) {
- solrTemplate.commit();
- } else {
- solrTemplate.rollback();
- }
- }
-
+// public void clear() {
+// Query query = new SimpleQuery("name:*");
+// UpdateResponse updateResponse = solrTemplate.delete(query);
+// if (updateResponse.getStatus() == 0) {
+// solrTemplate.commit();
+// } else {
+// solrTemplate.rollback();
+// }
+// }
public void deleteById(String id) {
-
-
UpdateResponse updateResponse = solrTemplate.deleteById(id);
if (updateResponse.getStatus() == 0) {
solrTemplate.commit();
@@ -158,31 +155,35 @@
long count = albumVideoMapService.countAll();
int pageSize = 100;
int pageCount = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
- for (int i = 3; i < pageCount; i++) {
- List<String> videoIds = new ArrayList<>();
- List<AlbumVideoMap> albumVideoMapList = albumVideoMapService.listAll(i + 1, pageSize);
- for (AlbumVideoMap map : albumVideoMapList) {
- videoIds.add(map.getVideoId());
- }
- List<VideoInfo> videoList = videoInfoService.listByVideoIds(videoIds);
-
- //鑾峰彇璧勬簮ID
- List<ResourceVideo> rvList = resourceVideoService.getResourceList(videoList);
- Map<String, List<VideoResource>> map = new HashMap<>();
- for (ResourceVideo rv : rvList) {
- if (rv.getVideo() != null && rv.getResource() != null) {
- if (map.get(rv.getVideo().getId()) == null)
- map.put(rv.getVideo().getId(), new ArrayList<>());
- map.get(rv.getVideo().getId()).add(rv.getResource());
+ for (int i = 0; i < pageCount; i++) {
+ try {
+ List<String> videoIds = new ArrayList<>();
+ List<AlbumVideoMap> albumVideoMapList = albumVideoMapService.listAll(i + 1, pageSize);
+ for (AlbumVideoMap map : albumVideoMapList) {
+ videoIds.add(map.getVideoId());
}
- }
- for (VideoInfo vi : videoList) {
- if (map.get(vi.getId()) != null) {
- vi.setResourceList(map.get(vi.getId()));
- }
- }
+ List<VideoInfo> videoList = videoInfoService.listByVideoIds(videoIds);
- saveOrUpdate(videoList);
+ //鑾峰彇璧勬簮ID
+ List<ResourceVideo> rvList = resourceVideoService.getResourceList(videoList);
+ Map<String, List<VideoResource>> map = new HashMap<>();
+ for (ResourceVideo rv : rvList) {
+ if (rv.getVideo() != null && rv.getResource() != null) {
+ if (map.get(rv.getVideo().getId()) == null)
+ map.put(rv.getVideo().getId(), new ArrayList<>());
+ map.get(rv.getVideo().getId()).add(rv.getResource());
+ }
+ }
+ for (VideoInfo vi : videoList) {
+ if (map.get(vi.getId()) != null) {
+ vi.setResourceList(map.get(vi.getId()));
+ }
+ }
+
+ saveOrUpdate(videoList);
+ } catch (Exception e) {
+ logger.error("涓撹緫鎼滅储寮曟搸鏁版嵁鍚屾澶辫触");
+ }
}
}
--
Gitblit v1.8.0