tujidelv 3 jaren geleden
bovenliggende
commit
d889f43f01

+ 5 - 5
src/main/java/top/lvzhiqiang/config/MyJobs.java

@@ -46,7 +46,7 @@ public class MyJobs {
     //@Scheduled(cron = "0 10 19 * * ?",zone = SCHEDULED_ZONE)
     @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
     public void checkVideoSite() {
-        log.info("checkVideoSite开始==============================");
+        log.warn("checkVideoSite开始==============================");
 
         // 获取javbus官方地址
         DicCode dicCode = WebAppConfig.dicCodeList.stream().filter(x -> 2 == x.getType() && "javbus".equals(x.getCodeKey())).findFirst().get();
@@ -68,7 +68,7 @@ public class MyJobs {
             Elements ahrefList = document.select("strong:contains(防屏蔽地址)").next("a");
             for (Element element : ahrefList) {
                 String text = element.text();
-                log.info("Jsoup获取{}防屏蔽地址:{}", dicCode.getCodeValue(), text);
+                log.warn("Jsoup获取{}防屏蔽地址:{}", dicCode.getCodeValue(), text);
                 javbusNewUrlList.add(text);
             }
         } catch (Exception e) {
@@ -117,7 +117,7 @@ public class MyJobs {
                 videoSitePool.setUrl(javbusNewUrlFinal);
                 videoSitePool.setType(1);
                 videoSitePoolList.add(videoSitePool);
-                log.info("javbusNewUrlFinalList:javbus防屏蔽地址有效!javbusUrl={}", javbusNewUrlFinal);
+                log.warn("javbusNewUrlFinalList:javbus防屏蔽地址有效!javbusUrl={}", javbusNewUrlFinal);
             } catch (Exception e) {
                 log.error("javbusNewUrlFinalList:javbus防屏蔽地址失效!javbusUrl={}", javbusNewUrlFinal, e);
             }
@@ -130,7 +130,7 @@ public class MyJobs {
             int deleteFlag = 1;
             try {
                 Jsoup.connect(javbusUrl).timeout(50000);
-                log.info("javbusUrlList:javbus防屏蔽地址有效!javbusUrl={}", javbusUrl);
+                log.warn("javbusUrlList:javbus防屏蔽地址有效!javbusUrl={}", javbusUrl);
             } catch (Exception e) {
                 deleteFlag = 2;
                 log.error("javbusUrlList:javbus防屏蔽地址失效!javbusUrl={}", javbusUrl, e);
@@ -138,7 +138,7 @@ public class MyJobs {
             videoSitePoolMapper.updateDeleteFlag(javbusUrl, deleteFlag);
         }
 
-        log.info("checkVideoSite结束==============================");
+        log.warn("checkVideoSite结束==============================");
     }
 
     /**

+ 9 - 9
src/main/java/top/lvzhiqiang/service/impl/BgServiceImpl.java

@@ -267,7 +267,7 @@ public class BgServiceImpl implements BgService {
     @Async
     @Override
     public void jsoupVideoInfoUncensored(Integer status) {
-        log.info("jsoupVideoInfoUncensored 开始:status={}", status);
+        log.warn("jsoupVideoInfoUncensored 开始:status={}", status);
 
         // 获取待抓取码列表
         List<String> icodeList = videoInfoUncensoredMapper.findIcodeByStatus(status);
@@ -315,7 +315,7 @@ public class BgServiceImpl implements BgService {
 
                     j++;
 
-                    log.info("jsoupVideoInfoUncensored success:i={},time={},identificationCode={}", i, System.currentTimeMillis() - start, identificationCode);
+                    log.warn("jsoupVideoInfoUncensored success:i={},time={},identificationCode={}", i, System.currentTimeMillis() - start, identificationCode);
                     break;
                 } catch (Exception e) {
                     ++retryCount;
@@ -329,7 +329,7 @@ public class BgServiceImpl implements BgService {
                 }
             }
         }
-        log.info("jsoupVideoInfoUncensored 统计:total={},success={}", icodeList.size(), j);
+        log.warn("jsoupVideoInfoUncensored 统计:total={},success={}", icodeList.size(), j);
     }
 
     /**
@@ -341,7 +341,7 @@ public class BgServiceImpl implements BgService {
     @Async
     @Override
     public void jsoupVideoInfo(Integer status) {
-        log.info("jsoupVideoInfo 开始:status={}", status);
+        log.warn("jsoupVideoInfo 开始:status={}", status);
 
         // 获取待抓取码列表
         List<String> icodeList = videoInfoMapper.findIcodeByStatus(status);
@@ -386,7 +386,7 @@ public class BgServiceImpl implements BgService {
 
                     j++;
 
-                    log.info("jsoupVideoInfo success:i={},time={},identificationCode={}", i, System.currentTimeMillis() - start, identificationCode);
+                    log.warn("jsoupVideoInfo success:i={},time={},identificationCode={}", i, System.currentTimeMillis() - start, identificationCode);
                     break;
                 } catch (Exception e) {
                     ++retryCount;
@@ -400,7 +400,7 @@ public class BgServiceImpl implements BgService {
                 }
             }
         }
-        log.info("jsoupVideoInfo 统计:total={},success={}", icodeList.size(), j);
+        log.warn("jsoupVideoInfo 统计:total={},success={}", icodeList.size(), j);
     }
 
     /**
@@ -513,7 +513,7 @@ public class BgServiceImpl implements BgService {
     @Async
     @Override
     public void jsoupIcodePool(Integer status, Integer isDel) {
-        log.info("jsoupIcodePool 开始:status={},isDel={}", status, isDel);
+        log.warn("jsoupIcodePool 开始:status={},isDel={}", status, isDel);
         if (isDel == 1) {
             videoInfoPoolMapper.deleteAll();
         }
@@ -581,7 +581,7 @@ public class BgServiceImpl implements BgService {
                         j++;
                     }
 
-                    log.info("jsoupIcodePool success:i={},picTime={},time={},identificationCode={}", i, picTime, System.currentTimeMillis() - start, identificationCode);
+                    log.warn("jsoupIcodePool success:i={},picTime={},time={},identificationCode={}", i, picTime, System.currentTimeMillis() - start, identificationCode);
                     break;
                 } catch (Exception e) {
                     ++retryCount;
@@ -598,7 +598,7 @@ public class BgServiceImpl implements BgService {
                 }
             }
         }
-        log.info("jsoupIcodePool 统计:total={},success={}", icodePoolList.size(), j);
+        log.warn("jsoupIcodePool 统计:total={},success={}", icodePoolList.size(), j);
     }
 
     private String getUserAgent() {