Преглед изворни кода

add:jsoupJavbusProfile jobv1

lvzhiqiang пре 3 година
родитељ
комит
43c38a2751

+ 14 - 1
src/main/java/top/lvzhiqiang/config/MyJobs.java

@@ -13,6 +13,7 @@ import top.lvzhiqiang.entity.DicCode;
 import top.lvzhiqiang.entity.VideoSitePool;
 import top.lvzhiqiang.mapper.VideoSitePoolMapper;
 import top.lvzhiqiang.service.BgService;
+import top.lvzhiqiang.service.Crawler4JavbusService;
 import top.lvzhiqiang.service.CrawlerService;
 
 import javax.annotation.Resource;
@@ -39,11 +40,13 @@ public class MyJobs {
     private BgService bgService;
     @Resource
     private CrawlerService crawlerService;
+    @Resource
+    private Crawler4JavbusService crawler4JavbusService;
 
     private static final String SCHEDULED_ZONE = "Asia/Shanghai";
 
     /**
-     * 每天6点校验站点有效性
+     * 每天06:00 校验站点有效性
      */
     @Scheduled(cron = "0 0 6 * * ?", zone = SCHEDULED_ZONE)
     //@Scheduled(cron = "0 10 19 * * ?",zone = SCHEDULED_ZONE)
@@ -174,4 +177,14 @@ public class MyJobs {
 
         crawlerService.jsoupXiaoeknowCourse(null, 2, null);
     }
+
+    /**
+     * 每天1:30 jsoupJavbusProfile
+     */
+    @Scheduled(cron = "0 30 1 * * ?", zone = SCHEDULED_ZONE)
+    public void jsoupJavbusProfileJob() throws Exception {
+        log.warn("jsoupJavbusProfileJob开始==============================");
+
+        crawler4JavbusService.jsoupJavbusProfile(null, null);
+    }
 }

+ 2 - 2
src/main/java/top/lvzhiqiang/service/impl/Crawler4JavbusServiceImpl.java

@@ -94,7 +94,7 @@ public class Crawler4JavbusServiceImpl implements Crawler4JavbusService {
         // 代理及TOKEN设置
         beforeJavbus();
         // 获取个人资料
-        jsoupJavbusProfileSub(proxy, start, limit);
+        jsoupJavbusProfileSub(start, limit);
         log.warn("jsoupJavbusProfile 结束:time={}", stopWatch.getTotalTimeSeconds());
     }
 
@@ -154,7 +154,7 @@ public class Crawler4JavbusServiceImpl implements Crawler4JavbusService {
         }
     }
 
-    private void jsoupJavbusProfileSub(Proxy proxy, Long start, Integer limit) throws Exception {
+    private void jsoupJavbusProfileSub(Long start, Integer limit) throws Exception {
         CrawlerJavbusProfile latestJavbusProfile = crawlerJavbusProfileMapper.findLatestInfo();
         if (start == null && latestJavbusProfile == null) {
             start = 1L;