From f537abe9f3646c739beaf15076246a2f71a347e9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 20 二月 2025 16:57:55 +0800
Subject: [PATCH] IOS广告增加区域屏蔽
---
src/main/java/com/yeshi/buwan/job/SolrJob.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 51 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/job/SolrJob.java b/src/main/java/com/yeshi/buwan/job/SolrJob.java
index d03134e..2c2c0cf 100644
--- a/src/main/java/com/yeshi/buwan/job/SolrJob.java
+++ b/src/main/java/com/yeshi/buwan/job/SolrJob.java
@@ -2,8 +2,14 @@
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
+import com.yeshi.buwan.service.manager.search.SolrAlbumVideoDataManager;
+import com.yeshi.buwan.service.manager.SolrCommonVideoDataManager;
+import com.yeshi.buwan.util.SolrUtil;
+import com.yeshi.buwan.util.StringUtil;
import org.springframework.stereotype.Component;
import org.yeshi.utils.LinuxRemoteCommandUtil;
+
+import javax.annotation.Resource;
/**
@@ -12,6 +18,12 @@
@Component
public class SolrJob {
+ @Resource
+ private SolrAlbumVideoDataManager solrAlbumDataManager;
+
+ @Resource
+ private SolrCommonVideoDataManager solrCommonVideoDataManager;
+
@XxlJob("solr-watch")
public ReturnT<String> reStartSolr(String param) throws Exception {
String solrIP = "172.16.16.12";
@@ -21,4 +33,43 @@
return ReturnT.SUCCESS;
}
+
+ /**
+ * 鍚屾涓撹緫
+ *
+ * @param param
+ * @return
+ * @throws Exception
+ */
+ @XxlJob("solr-syncAlbum")
+ public ReturnT<String> syncAlbum(String param) throws Exception {
+ solrAlbumDataManager.syncAllAlbum();
+ return ReturnT.SUCCESS;
+ }
+
+ /**
+ * 鍚屾甯歌鎼滅储
+ *
+ * @param param
+ * @return
+ * @throws Exception
+ */
+ @XxlJob("solr-syncVideoCore")
+ public ReturnT<String> syncCore(String param) throws Exception {
+ //鍚屾瑙嗛
+ SolrUtil.dataimportVideo(param);
+ return ReturnT.SUCCESS;
+ }
+
+ @XxlJob("solr-syncCommonVideo")
+ public ReturnT<String> syncCommonVideo(String param) throws Exception {
+ Long minId = null;
+ if (!StringUtil.isNullOrEmpty(param)) {
+ minId = Long.parseLong(param);
+ }
+ //鍚屾瑙嗛
+ solrCommonVideoDataManager.syncAllVideo(minId);
+ return ReturnT.SUCCESS;
+ }
+
}
--
Gitblit v1.8.0