From fc7a6634496066fe45dca8ea9832bdd2f7341db4 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 13 十月 2020 10:25:39 +0800
Subject: [PATCH] 百度内容联盟前端分类,首页弹窗广告

---
 src/main/java/com/yeshi/buwan/job/SolrJob.java |   35 +++++++++++++++++++++++++++++++++++
 1 files changed, 35 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..b203fef 100644
--- a/src/main/java/com/yeshi/buwan/job/SolrJob.java
+++ b/src/main/java/com/yeshi/buwan/job/SolrJob.java
@@ -2,8 +2,12 @@
 
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
+import com.yeshi.buwan.service.manager.SolrAlbumDataManager;
+import com.yeshi.buwan.util.SolrUtil;
 import org.springframework.stereotype.Component;
 import org.yeshi.utils.LinuxRemoteCommandUtil;
+
+import javax.annotation.Resource;
 
 
 /**
@@ -12,6 +16,9 @@
 @Component
 public class SolrJob {
 
+    @Resource
+    private SolrAlbumDataManager solrAlbumDataManager;
+
     @XxlJob("solr-watch")
     public ReturnT<String> reStartSolr(String param) throws Exception {
         String solrIP = "172.16.16.12";
@@ -21,4 +28,32 @@
         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;
+    }
+
 }

--
Gitblit v1.8.0