XXL Job

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/adweb/seo/mapper/SeoKeywordsMapper.java

@@ -10,19 +10,18 @@ import org.jeecg.modules.adweb.seo.vo.RankInfoVO;
 import java.util.List;
 
 /**
- * @Description: 关键词
- * @Author: jeecg-boot
- * @Date:   2024-10-15
- * @Version: V1.0
+ * @Description: 关键词 @Author: jeecg-boot @Date: 2024-10-15 @Version: V1.0
  */
 public interface SeoKeywordsMapper extends BaseMapper<SeoKeywords> {
     /**
      * 根据站点和套餐id
+     *
      * @param siteCode
      * @param subscriptionId
      * @return
      */
-    List<String> getKeywordsLastSevenDays(String siteCode, String subscriptionId, Integer keywordType);
+    List<String> getKeywordsLastSevenDays(
+            String siteCode, String subscriptionId, Integer keywordType);
 
     /**
      * 查询关键词排名数据
@@ -30,7 +29,13 @@ public interface SeoKeywordsMapper extends BaseMapper<SeoKeywords> {
      * @param siteCode siteCode
      * @return 当日排名在前n页的数量
      */
-    RankInfoVO queryKeywordNumByRankRange(@Param("siteCode") String siteCode, @Param("subscriptionId") String subscriptionId, @Param("rankStart") Integer rankStart, @Param("rankEnd") Integer rankEnd, @Param("dateStr") String dateStr, @Param("keywordType") String keywordType);
+    RankInfoVO queryKeywordNumByRankRange(
+            @Param("siteCode") String siteCode,
+            @Param("subscriptionId") String subscriptionId,
+            @Param("rankStart") Integer rankStart,
+            @Param("rankEnd") Integer rankEnd,
+            @Param("dateStr") String dateStr,
+            @Param("keywordType") String keywordType);
 
     /**
      * 根据站点code获取关键词达标标准
@@ -45,25 +50,25 @@ public interface SeoKeywordsMapper extends BaseMapper<SeoKeywords> {
      *
      * @return 关键词列表
      */
-    IPage<SeoKeywords> getKeywordList(IPage<SeoKeywords> page,
-                                      Integer rankStart,
-                                      Integer rankEnd,
-                                      boolean isCustomer,
-                                      String keyword,
-                                      String siteCode,
-                                      Integer keywordType,
-                                      String datesStr,
-                                      String subscriptionId,
-                                      String column,
-                                      String order,
-                                      String buttonColumn,
-                                      String buttonSort);
+    IPage<SeoKeywords> getKeywordList(
+            IPage<SeoKeywords> page,
+            Integer rankStart,
+            Integer rankEnd,
+            boolean isCustomer,
+            String keyword,
+            String siteCode,
+            Integer keywordType,
+            String datesStr,
+            String subscriptionId,
+            String column,
+            String order,
+            String buttonColumn,
+            String buttonSort);
 
     /**
      * 获取当日需要DateForSEO Serp查询的关键词列表
      *
      * @return 关键词列表
      */
-    List<SeoKeywords> getKeywordsToSerp(int keywordType, int limit);
-
+    List<SeoKeywords> getKeywordsToSerp(List<String> sideCodes, int keywordType, int limit);
 }

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/adweb/seo/mapper/xml/SeoKeywordsMapper.xml

@@ -167,22 +167,16 @@
         FROM
         seo_keywords
         WHERE
-        `status` = 1
+        status = 1
         AND
-        'search_status' != 1
-        AND site_code IN (
-        SELECT
-        `code`
-        FROM
-        adweb_site
-        WHERE
-        run_status = 1
-        AND `status` = 1
-        )
+        search_status != 1
+        AND site_code IN
+        <foreach collection="sideCodes" item="sideCode" open="(" separator="," close=")">
+            #{sideCode}
+        </foreach>
         <if test = "keywordType != null">
             AND keyword_type = #{keywordType}
         </if>
-        AND last_search_time <![CDATA[ <]]> CURDATE()
         LIMIT #{limit}
     </select>
 </mapper>

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/adweb/seo/service/dataforseo/DataForSEOService.java

@@ -27,6 +27,8 @@ import org.jeecg.modules.adweb.seo.entity.SeoKeywordsSerp;
 import org.jeecg.modules.adweb.seo.mapper.SeoKeywordsMapper;
 import org.jeecg.modules.adweb.seo.service.ISeoKeywordsSerpService;
 import org.jeecg.modules.adweb.seo.service.ISeoKeywordsService;
+import org.jeecg.modules.adweb.site.entity.AdwebSite;
+import org.jeecg.modules.adweb.site.service.IAdwebSiteService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -61,6 +63,8 @@ public class DataForSEOService {
     @Value("${dataforseo.api-path}")
     private String apiPath;
 
+    @Autowired private IAdwebSiteService adwebSiteService;
+
     @Autowired private SeoKeywordsMapper seoKeywordsMapper;
 
     @Autowired private ISeoKeywordsService seoKeywordsService;
@@ -92,8 +96,21 @@ public class DataForSEOService {
      * @param keywordType 1 - 指定词; 2 - 长尾词
      * @param limit 最大查询条数
      */
-    public void runKeywordsSerpTasks(int keywordType, int limit) {
-        List<SeoKeywords> seoKeywords = seoKeywordsMapper.getKeywordsToSerp(keywordType, limit);
+    public void runKeywordsSerpTasks(List<String> siteCodes, int keywordType, int limit) {
+        if (ListUtil.isEmpty(siteCodes)) {
+            siteCodes =
+                    adwebSiteService
+                            .list(
+                                    new LambdaQueryWrapper<AdwebSite>()
+                                            .eq(AdwebSite::getStatus, 1)
+                                            .eq(AdwebSite::getRunStatus, 1))
+                            .stream()
+                            .map(AdwebSite::getCode)
+                            .toList();
+        }
+
+        List<SeoKeywords> seoKeywords =
+                seoKeywordsMapper.getKeywordsToSerp(siteCodes, keywordType, limit);
 
         if (ListUtil.isEmpty(seoKeywords)) {
             log.info("暂无需要Serp查询的关键词");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/xxl/DataForSEOJob.java

@@ -1,5 +1,6 @@
 package org.jeecg.modules.xxl;
 
+import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
 
 import lombok.extern.slf4j.Slf4j;
@@ -9,6 +10,11 @@ import org.jeecg.modules.adweb.seo.service.dataforseo.DataForSEOService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+
 /**
  * DataForSEO Serp查询及同步任务，{@link DataForSEOService}
  *
@@ -21,25 +27,39 @@ public class DataForSEOJob {
     @Autowired private DataForSEOService dataForSEOService;
 
     @XxlJob("runLongTailKeywordsSerpTasksHandler")
-    public void runLongTailKeywordsSerpTasksHandler() {
-        log.info("执行长尾词Serp查询...");
+    public ReturnT<String> runLongTailKeywordsSerpTasksHandler(String param) {
+        log.info("执行长尾词Serp查询..., param = {}", param);
         dataForSEOService.runKeywordsSerpTasks(
-                AdwebConstant.KEYWORD_TYPE_LONG_TAIL, Integer.MAX_VALUE);
+                this.parseSiteCodes(param),
+                AdwebConstant.KEYWORD_TYPE_LONG_TAIL,
+                Integer.MAX_VALUE);
         log.info("执行长尾词Serp查询结束");
+
+        return ReturnT.SUCCESS;
     }
 
     @XxlJob("runAppointKeywordsSerpTasksHandler")
-    public void runAppointKeywordsSerpTasksHandler() {
-        log.info("执行指定词Serp查询...");
+    public ReturnT<String> runAppointKeywordsSerpTasksHandler(String param) {
+        log.info("执行指定词Serp查询..., param = {}", param);
         dataForSEOService.runKeywordsSerpTasks(
-                AdwebConstant.KEYWORD_TYPE_APPOINT, Integer.MAX_VALUE);
+                this.parseSiteCodes(param), AdwebConstant.KEYWORD_TYPE_APPOINT, Integer.MAX_VALUE);
         log.info("执行指定词Serp查询结束");
+
+        return ReturnT.SUCCESS;
     }
 
     @XxlJob("syncKeywordsSerpResultsHandler")
-    public void syncKeywordsSerpResultsHandler() {
+    public ReturnT<String> syncKeywordsSerpResultsHandler(String param) {
         log.info("同步关键词Serp查询结果...");
         dataForSEOService.syncKeywordsSerpResults();
         log.info("同步关键词Serp查询结果结束");
+
+        return ReturnT.SUCCESS;
+    }
+
+    private List<String> parseSiteCodes(String param) {
+        return Objects.nonNull(param)
+                ? Arrays.stream(param.split(",")).map(siteCode -> siteCode.trim()).toList()
+                : Collections.EMPTY_LIST;
     }
 }

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/xxl/GAReportJob.java

@@ -1,5 +1,6 @@
 package org.jeecg.modules.xxl;
 
+import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
 
 import lombok.extern.slf4j.Slf4j;
@@ -20,9 +21,11 @@ public class GAReportJob {
     @Autowired private GAReportService gaReportService;
 
     @XxlJob("syncGAReportHandler")
-    public void syncGAReportHandler() {
+    public ReturnT<String> syncGAReportHandler(String param) {
         log.info("同步GA报表数据...");
         gaReportService.syncGAReport();
         log.info("同步GA报表数据结束");
+
+        return ReturnT.SUCCESS;
     }
 }

jeecg-module-system/jeecg-system-start/src/test/java/org/jeecg/modules/adweb/seo/service/DataForSEOTest.java

@@ -8,6 +8,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.ActiveProfiles;
 
+import java.util.Collections;
+
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
 @ActiveProfiles("dev")
 public class DataForSEOTest {
@@ -17,7 +19,8 @@ public class DataForSEOTest {
     @Test
     @Disabled
     public void testRunKeywordsSerpTasks() {
-        dataForSEOService.runKeywordsSerpTasks(AdwebConstant.KEYWORD_TYPE_APPOINT, 10);
+        dataForSEOService.runKeywordsSerpTasks(
+                Collections.EMPTY_LIST, AdwebConstant.KEYWORD_TYPE_APPOINT, 10);
     }
 
     @Test