From 1ddd9712e87a5b4dedfe88c66dbb9343ac8b6bed Mon Sep 17 00:00:00 2001
From: userA <geniusssbg@gmail.com>
Date: Tue, 17 Oct 2023 02:18:40 +0800
Subject: [PATCH] =?UTF-8?q?=E8=99=8E=E7=89=99=E5=B9=B3=E5=8F=B0=E7=88=AC?=
 =?UTF-8?q?=E8=99=AB=20=E8=9E=8D=E5=85=A5ChopperBot=20#33?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/compiler.xml                            |   2 +-
 .../main/java/org/example/api/VideoApi.java   |   3 +-
 .../core/LiveAndBarrageHandlerObserver.java   |   2 +
 .../instantslicing/ScheduleTimeHandler.java   |  16 +++--
 .../HuyaLiveBarrageLoadConfigBuilder.java     |  24 ++++++++
 .../group/BilibiliLiveBarrageGroup.java       |  23 --------
 .../creeper/group/DouyuLiveBarrageGroup.java  |  24 --------
 .../group/DouyuRecordBarrageGroup.java        |  24 --------
 .../creeper/group/HuyaLiveBarrageGroup.java   |  21 -------
 .../loadconfig/HuyaLiveBarrageLoadConfig.java |   2 +-
 .../loadtask/DouyuLiveBarrageLoadTask.java    |   3 +-
 .../loadtask/HuyaLiveBarrageLoadTask.java     |  36 +++++-------
 .../core/creeper/protocl/HuyaProtocol.java    |   7 +--
 .../src/main/java/org/example/bean/Live.java  |   5 ++
 .../example/bean/hotmodule/HuyaHotModule.java |  15 +++++
 .../java/org/example/bean/live/HuyaLive.java  |  34 +++++++++++
 .../main/java/org/example/core/SafeBag.java   |  24 ++++++++
 .../org/example/init/CommonInitMachine.java   |   3 +-
 .../org/example/init/InitPluginRegister.java  |   3 +-
 .../org/example/init/ModuleInitMachine.java   |   3 +-
 .../java/org/example/util/ExceptionUtil.java  |  12 ++++
 .../org/example/controller/HotController.java |  16 +----
 .../main/java/org/example/init/InitWorld.java |   3 +-
 .../org/example/init/WorldInitMachine.java    |   3 +-
 .../org/example/service/HotModuleService.java |   3 +-
 .../service/impl/HotModuleServiceImpl.java    |  23 ++------
 chopperbot-creeper/pom.xml                    |   6 ++
 .../core/loadtask/WebSocketLoadTask.java      |   3 +-
 .../core/manager/AbstractCreeperGroup.java    |  10 +++-
 .../core/manager/CreeperGroupCenter.java      |  25 ++++++--
 .../example/core/manager/CreeperManager.java  |   5 --
 .../core/taskcenter/task/ReptileTask.java     |  11 ++--
 .../core/taskcenter/task/TaskRecord.java      |   3 +-
 .../core/taskmonitor/MonitorCenter.java       |   3 +-
 .../java/org/example/cache/FileCache.java     |   3 +-
 .../org/example/init/ConfigInitMachine.java   |   3 +-
 .../init/FileCacheManagerInitMachine.java     |   3 +-
 .../src/main/java/org/example/App.java        |   7 ++-
 .../java/org/example/api/HotModuleApi.java    |  31 +++++-----
 .../java/org/example/bean/FocusLiver.java     |   2 +
 .../org/example/core/HotModuleDataCenter.java |  20 ++++---
 .../builder/BilibiliHotLiveBuilder.java       |  24 ++++++++
 .../creeper/builder/DouyuHotLiveBuilder.java  |  23 ++++++++
 .../creeper/builder/HuyaHotLiveBuilder.java   |  23 ++++++++
 .../builder/HuyaLiverCheckerBuilder.java      |  21 +++++++
 .../creeper/group/BilibiliHotLiveGroup.java   |  25 --------
 .../creeper/group/BilibiliHotModuleGroup.java |  24 --------
 .../group/BilibiliLiverCheckerGroup.java      |  24 --------
 .../core/creeper/group/DouyuHotLiveGroup.java |  25 --------
 .../creeper/group/DouyuHotModuleGroup.java    |  24 --------
 .../creeper/group/DouyuLiverCheckerGroup.java |  23 --------
 .../loadconfig/BilibiliHotLiveConfig.java     |   2 -
 .../creeper/loadconfig/HuyaHotLiveConfig.java |  33 +++++++++++
 .../loadconfig/HuyaHotModuleConfig.java       |  26 +++++++++
 .../loadconfig/HuyaLiverCheckerConfig.java    |  36 ++++++++++++
 .../creeper/loadtask/HotModuleLoadTask.java   |   3 +-
 .../creeper/loadtask/HuyaHotLiveLoadTask.java |  48 +++++++++++++++
 .../loadtask/HuyaHotModuleLoadTask.java       |  47 +++++++++++++++
 .../loadtask/HuyaLiverCheckerLoadTask.java    |  45 ++++++++++++++
 .../processor/HuyaHotLiveProcessor.java       |  54 +++++++++++++++++
 .../processor/HuyaLiverCheckerProcessor.java  |  55 ++++++++++++++++++
 .../core/component/LiveStreamTask.java        |   3 +
 .../example/core/component/M3U8Handle.java    |   3 +-
 .../builder/HuyaLiveLoadConfigBuilder.java    |  36 ++++++++++++
 .../core/creeper/group/BiliBiliLiveGroup.java |  24 --------
 .../core/creeper/group/DouyuLiveGroup.java    |  23 --------
 .../core/creeper/group/DouyuRecordGroup.java  |  23 --------
 .../core/creeper/group/HuyaLiveGroup.java     |  21 -------
 .../creeper/loadtask/DouyuRecordLoadTask.java |   3 +-
 .../example/core/factory/LiveTaskFactory.java |   5 +-
 .../example/init/LiveConfigInitMachine.java   |   3 +-
 .../main/java/org/example/util/VideoUtil.java |   4 +-
 .../example/barrage/BarrageCreeperTest.java   |   4 +-
 .../org/example/barrage/BarrageCurveTest.java |  46 +++++++--------
 .../barrage/BarragePoupularRangeTest.java     |   8 +--
 config/chopperBotConfig.json                  |   2 +-
 database.db                                   | Bin 77824 -> 94208 bytes
 77 files changed, 779 insertions(+), 483 deletions(-)
 create mode 100644 chopperbot-barrage/src/main/java/org/example/core/creeper/builder/HuyaLiveBarrageLoadConfigBuilder.java
 delete mode 100644 chopperbot-barrage/src/main/java/org/example/core/creeper/group/BilibiliLiveBarrageGroup.java
 delete mode 100644 chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuLiveBarrageGroup.java
 delete mode 100644 chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuRecordBarrageGroup.java
 delete mode 100644 chopperbot-barrage/src/main/java/org/example/core/creeper/group/HuyaLiveBarrageGroup.java
 create mode 100644 chopperbot-common/src/main/java/org/example/bean/hotmodule/HuyaHotModule.java
 create mode 100644 chopperbot-common/src/main/java/org/example/bean/live/HuyaLive.java
 create mode 100644 chopperbot-common/src/main/java/org/example/core/SafeBag.java
 create mode 100644 chopperbot-common/src/main/java/org/example/util/ExceptionUtil.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/builder/BilibiliHotLiveBuilder.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/builder/DouyuHotLiveBuilder.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaHotLiveBuilder.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaLiverCheckerBuilder.java
 delete mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotLiveGroup.java
 delete mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotModuleGroup.java
 delete mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliLiverCheckerGroup.java
 delete mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotLiveGroup.java
 delete mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotModuleGroup.java
 delete mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuLiverCheckerGroup.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotLiveConfig.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotModuleConfig.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaLiverCheckerConfig.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotLiveLoadTask.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotModuleLoadTask.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaLiverCheckerLoadTask.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaHotLiveProcessor.java
 create mode 100644 chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaLiverCheckerProcessor.java
 create mode 100644 chopperbot-live/src/main/java/org/example/core/creeper/builder/HuyaLiveLoadConfigBuilder.java
 delete mode 100644 chopperbot-live/src/main/java/org/example/core/creeper/group/BiliBiliLiveGroup.java
 delete mode 100644 chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuLiveGroup.java
 delete mode 100644 chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuRecordGroup.java
 delete mode 100644 chopperbot-live/src/main/java/org/example/core/creeper/group/HuyaLiveGroup.java

diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index d529ac8..93225a1 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -38,7 +38,7 @@
   </component>
   <component name="JavacSettings">
     <option name="ADDITIONAL_OPTIONS_OVERRIDE">
-      <module name="ChopperBot" options="-parameters" />
+      <module name="ChopperBot" options="" />
       <module name="chopperbot-account" options="-parameters" />
       <module name="chopperbot-barrage" options="-parameters" />
       <module name="chopperbot-common" options="-parameters" />
diff --git a/chopperbot-account/src/main/java/org/example/api/VideoApi.java b/chopperbot-account/src/main/java/org/example/api/VideoApi.java
index 37ca009..4b58433 100644
--- a/chopperbot-account/src/main/java/org/example/api/VideoApi.java
+++ b/chopperbot-account/src/main/java/org/example/api/VideoApi.java
@@ -2,6 +2,7 @@ package org.example.api;
 
 import org.example.constpool.ConstPool;
 import org.example.constpool.GlobalFileCache;
+import org.example.util.ExceptionUtil;
 
 import java.io.File;
 import java.util.*;
@@ -45,7 +46,7 @@ public class VideoApi {
                 return false;
             }
         }catch (SecurityException e) {
-            System.out.println("删除文件时发生安全异常: " + e.getMessage());
+            System.out.println("删除文件时发生安全异常: " +  ExceptionUtil.getCause(e));
             return false;
         }
     }
diff --git a/chopperbot-barrage/src/main/java/org/example/core/LiveAndBarrageHandlerObserver.java b/chopperbot-barrage/src/main/java/org/example/core/LiveAndBarrageHandlerObserver.java
index d102de9..1d76dd1 100644
--- a/chopperbot-barrage/src/main/java/org/example/core/LiveAndBarrageHandlerObserver.java
+++ b/chopperbot-barrage/src/main/java/org/example/core/LiveAndBarrageHandlerObserver.java
@@ -9,6 +9,7 @@ import org.example.core.bgevnet.BarrageEventCenter;
 import org.example.core.bgevnet.instantslicing.InstantSlicingPlugin;
 import org.example.core.section.SectionRequest;
 import org.example.core.section.VideoSectionWorkShop;
+import org.example.core.taskcenter.TaskCenter;
 import org.example.core.taskcenter.observer.AbstractTaskCenterObserver;
 import org.example.core.taskcenter.task.ReptileTask;
 import org.example.init.InitPluginRegister;
@@ -36,6 +37,7 @@ public class LiveAndBarrageHandlerObserver extends AbstractTaskCenterObserver {
 
     @Override
     public void onFinish(ReptileTask task) {
+        taskCenter.stopTask(task.getTaskId().replace("live","barrage"));
         if(!InitPluginRegister.isRegister(PluginName.INSTANT_SLICING_PLUGIN)){
             PluginCheckAndDo.CheckAndDo((plugin)->{
                 Object param = task.getRequest().getParam();
diff --git a/chopperbot-barrage/src/main/java/org/example/core/bgevnet/instantslicing/ScheduleTimeHandler.java b/chopperbot-barrage/src/main/java/org/example/core/bgevnet/instantslicing/ScheduleTimeHandler.java
index fe04d90..e4423c0 100644
--- a/chopperbot-barrage/src/main/java/org/example/core/bgevnet/instantslicing/ScheduleTimeHandler.java
+++ b/chopperbot-barrage/src/main/java/org/example/core/bgevnet/instantslicing/ScheduleTimeHandler.java
@@ -15,9 +15,7 @@ import org.example.init.InitPluginRegister;
 import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
 import org.example.thread.NamedThreadFactory;
-import org.example.util.BarrageUtil;
-import org.example.util.TimeUtil;
-import org.example.util.VideoUtil;
+import org.example.util.*;
 
 import java.nio.file.Path;
 import java.util.HashMap;
@@ -103,18 +101,24 @@ public class ScheduleTimeHandler implements InstantSlicingHandler {
                     }
                 }
             }catch (Exception e){
-                ChopperLogFactory.getLogger(LoggerType.Barrage).error("Error:{}",e.toString());
+                ChopperLogFactory.getLogger(LoggerType.Barrage).error("Error:{}", ExceptionUtil.getCause(e));
             }
         }
     }
 
 
     private boolean splitBarrageFile(String oldPath,String newPath,long startTime,long endTime){
-        return BarrageUtil.cutBarrageFile(oldPath,newPath,startTime,endTime);
+        if(FileUtil.isFileExist(oldPath)){
+            return BarrageUtil.cutBarrageFile(oldPath,newPath,startTime,endTime);
+        }
+        return false;
     }
 
     private boolean spiltVideoFile(String oldPath,String newPath,long startSecond,long endSecond){
-        return VideoUtil.cutVideoByFFMpeg(oldPath,newPath,startSecond,endSecond);
+        if(FileUtil.isFileExist(oldPath)){
+            return VideoUtil.cutVideoByFFMpeg(oldPath,newPath,startSecond,endSecond);
+        }
+       return false;
     }
 
     @Override
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/builder/HuyaLiveBarrageLoadConfigBuilder.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/builder/HuyaLiveBarrageLoadConfigBuilder.java
new file mode 100644
index 0000000..f02cda6
--- /dev/null
+++ b/chopperbot-barrage/src/main/java/org/example/core/creeper/builder/HuyaLiveBarrageLoadConfigBuilder.java
@@ -0,0 +1,24 @@
+package org.example.core.creeper.builder;
+
+import org.example.bean.live.DouyuLive;
+import org.example.bean.live.HuyaLive;
+import org.example.core.creeper.loadconfig.DouyuLiveBarrageLoadConfig;
+import org.example.core.creeper.loadconfig.HuyaLiveBarrageLoadConfig;
+import org.example.core.manager.CommonLoadConfigBuilder;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 22:03
+ **/
+
+@Component
+public class HuyaLiveBarrageLoadConfigBuilder extends CommonLoadConfigBuilder<HuyaLiveBarrageLoadConfig> {
+    @Override
+    public HuyaLiveBarrageLoadConfig build(Object obj) {
+        if(obj instanceof HuyaLive){
+            return new HuyaLiveBarrageLoadConfig(((HuyaLive) obj).getLiver(),((HuyaLive) obj).getLiveId());
+        }
+        return null;
+    }
+}
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/BilibiliLiveBarrageGroup.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/group/BilibiliLiveBarrageGroup.java
deleted file mode 100644
index a294f4f..0000000
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/BilibiliLiveBarrageGroup.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:22
- **/
-@Component
-public class BilibiliLiveBarrageGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.BILIBILI;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.BARRAGE_ONLINE;
-    }
-}
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuLiveBarrageGroup.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuLiveBarrageGroup.java
deleted file mode 100644
index 3558b41..0000000
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuLiveBarrageGroup.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.example.core.creeper.group;
-
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/12 23:02
- **/
-@Component
-public class DouyuLiveBarrageGroup  extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.DOUYU;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.BARRAGE_ONLINE;
-    }
-}
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuRecordBarrageGroup.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuRecordBarrageGroup.java
deleted file mode 100644
index dabe54f..0000000
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/DouyuRecordBarrageGroup.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.example.ws.handler.AbstractMessageHandler;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:28
- **/
-@Component
-public class DouyuRecordBarrageGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.DOUYU;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.BARRAGE_RECORD;
-    }
-}
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/HuyaLiveBarrageGroup.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/group/HuyaLiveBarrageGroup.java
deleted file mode 100644
index 0a60dc6..0000000
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/group/HuyaLiveBarrageGroup.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-
-/**
- * @author dhx
- * @date 2023/10/16 15:59
- */
-public class HuyaLiveBarrageGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.HUYA;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.BARRAGE_ONLINE;
-    }
-}
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/loadconfig/HuyaLiveBarrageLoadConfig.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/loadconfig/HuyaLiveBarrageLoadConfig.java
index 399d074..2f1a3bd 100644
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/loadconfig/HuyaLiveBarrageLoadConfig.java
+++ b/chopperbot-barrage/src/main/java/org/example/core/creeper/loadconfig/HuyaLiveBarrageLoadConfig.java
@@ -23,7 +23,7 @@ public class HuyaLiveBarrageLoadConfig extends LoadBarrageConfig{
     private String roomId;
 
     public HuyaLiveBarrageLoadConfig(String anchorName,String roomId) {
-        super(ConstPool.DOUYU, CreeperModuleConstPool.ACTION_LIVE, anchorName);
+        super(ConstPool.HUYA, CreeperModuleConstPool.ACTION_LIVE, anchorName);
         this.roomId = roomId;
         this.url = "wss://cdnws.api.huya.com/";
     }
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/DouyuLiveBarrageLoadTask.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/DouyuLiveBarrageLoadTask.java
index 8a92a77..f8722af 100644
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/DouyuLiveBarrageLoadTask.java
+++ b/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/DouyuLiveBarrageLoadTask.java
@@ -13,6 +13,7 @@ import org.example.core.taskmonitor.Monitor;
 import org.example.core.taskmonitor.MonitorCenter;
 import org.example.exception.FileCacheException;
 import org.example.plugin.PluginCheckAndDo;
+import org.example.util.ExceptionUtil;
 import org.java_websocket.handshake.ServerHandshake;
 
 import java.nio.ByteBuffer;
@@ -113,7 +114,7 @@ public class DouyuLiveBarrageLoadTask extends WebSocketLoadTask<List<DouyuBarrag
     @Override
     public void onError(Exception e) {
         client.close();
-        this.logger.error("Douyu Live Barrage Error:{}",e.getMessage());
+        this.logger.error("Douyu Live Barrage Error:{}", ExceptionUtil.getCause(e));
     }
 
     public DouyuBarrage wrapperBarrage(ByteBuffer buffer, long startTime){
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/HuyaLiveBarrageLoadTask.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/HuyaLiveBarrageLoadTask.java
index 8183edc..7ee15d4 100644
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/HuyaLiveBarrageLoadTask.java
+++ b/chopperbot-barrage/src/main/java/org/example/core/creeper/loadtask/HuyaLiveBarrageLoadTask.java
@@ -17,6 +17,7 @@ import org.example.core.taskmonitor.Monitor;
 import org.example.core.taskmonitor.MonitorCenter;
 import org.example.exception.FileCacheException;
 import org.example.plugin.PluginCheckAndDo;
+import org.example.util.ExceptionUtil;
 import org.java_websocket.handshake.ServerHandshake;
 
 import java.io.UnsupportedEncodingException;
@@ -46,14 +47,6 @@ public class HuyaLiveBarrageLoadTask extends WebSocketLoadTask<List<HuyaBarrage>
         fileCache = new BarrageFileCache(new BarrageSaveFile<>(loadConfig,new ConcurrentLinkedQueue<>()));
     }
 
-    public static String stringToHex(String input) {
-        StringBuilder hexString = new StringBuilder();
-        for (char c : input.toCharArray()) {
-            hexString.append(String.format("%02X ", (int) c));
-        }
-        return hexString.toString();
-    }
-
     @Override
     public List<HuyaBarrage> handler() {
         return list;
@@ -100,7 +93,15 @@ public class HuyaLiveBarrageLoadTask extends WebSocketLoadTask<List<HuyaBarrage>
 
     @Override
     public void onMessage(ByteBuffer buffer) {
-        HuyaBarrage huyaBarrage = wrapperBarrage(buffer,0);
+        HuyaBarrage huyaBarrage = wrapperBarrage(buffer);
+        if(huyaBarrage!=null){
+            list.add(huyaBarrage);
+            try {
+                fileCache.append(huyaBarrage,"-1");
+            }catch (FileCacheException | InterruptedException e){
+                throw new RuntimeException(e);
+            }
+        }
     }
 
     @Override
@@ -111,13 +112,13 @@ public class HuyaLiveBarrageLoadTask extends WebSocketLoadTask<List<HuyaBarrage>
     @Override
     public void onError(Exception e) {
         client.close();
-        this.logger.error("Huya Live Barrage Error:{}",e.getMessage());
+        this.logger.error("Huya Live Barrage Error:{}", ExceptionUtil.getCause(e));
     }
 
-    public HuyaBarrage wrapperBarrage(ByteBuffer buffer, long startTime){
-        String name = "";
+    public HuyaBarrage wrapperBarrage(ByteBuffer buffer){
         String content = "";
         TarsInputStream tarsInputStream = new TarsInputStream(buffer);
+        long nowTime = System.currentTimeMillis();
         int int32 = 0;
         long int64 = 0L;
         byte[] bytes = null;
@@ -125,18 +126,13 @@ public class HuyaLiveBarrageLoadTask extends WebSocketLoadTask<List<HuyaBarrage>
             tarsInputStream = new TarsInputStream(tarsInputStream.read(bytes,1,false));
             if(tarsInputStream.read(int64,1,false)==1400){
                 tarsInputStream = new TarsInputStream(tarsInputStream.read(bytes,2,false));
-//                name = tarsInputStream.read("",0,false);
+                tarsInputStream.setServerEncoding("utf-8");
                 content = tarsInputStream.read("", 3, true);
                 try {
-                    System.out.println(new String(content.getBytes("GBK")));
-                    System.out.println(stringToHex(content));
-                    System.out.println(new String(content.replaceAll("\uFFFD", "").getBytes("GBK")));
-                    System.out.println(stringToHex(new String(content.getBytes("GBK"))));
-                } catch (UnsupportedEncodingException e) {
+                    return new HuyaBarrage("",nowTime,nowTime-startTime,content);
+                } catch (Exception e) {
                     e.printStackTrace();
                 }
-                System.out.println(name);
-
             }
         }
         return null;
diff --git a/chopperbot-barrage/src/main/java/org/example/core/creeper/protocl/HuyaProtocol.java b/chopperbot-barrage/src/main/java/org/example/core/creeper/protocl/HuyaProtocol.java
index e072d3f..7361415 100644
--- a/chopperbot-barrage/src/main/java/org/example/core/creeper/protocl/HuyaProtocol.java
+++ b/chopperbot-barrage/src/main/java/org/example/core/creeper/protocl/HuyaProtocol.java
@@ -75,16 +75,11 @@ public class HuyaProtocol {
             regDatas = wscmd.toByteArray();
             return regDatas;
         }catch (Exception e){
-            e.printStackTrace();
+            throw new RuntimeException("解析失败");
         }
-        return null;
     }
     public static byte[] getHeartbeat(){
         return heartbeat;
     }
-    public static void main(String[] args) throws IOException {
-        String roomId = "dank1ng";
-        System.out.println(HexUtil.encodeHex(getWsInfo(roomId)));
-    }
 
 }
diff --git a/chopperbot-common/src/main/java/org/example/bean/Live.java b/chopperbot-common/src/main/java/org/example/bean/Live.java
index 6dadebf..4d556e2 100644
--- a/chopperbot-common/src/main/java/org/example/bean/Live.java
+++ b/chopperbot-common/src/main/java/org/example/bean/Live.java
@@ -16,6 +16,7 @@ import java.time.LocalDateTime;
  */
 @Data
 public abstract class Live implements Serializable {
+
     private int watcherNum;  //直播间观众数目
     private String liveId;      //直播间ID
     private String liveName; //直播间名字
@@ -33,6 +34,9 @@ public abstract class Live implements Serializable {
 
     private String roomPic;
 
+    public Live() {
+    }
+
     public Live(int watcherNum, String liveId, String liveName, String description) {
         this.watcherNum = watcherNum;
         this.liveId = liveId;
@@ -68,4 +72,5 @@ public abstract class Live implements Serializable {
         this.moduleName = moduleName;
     }
 
+
 }
diff --git a/chopperbot-common/src/main/java/org/example/bean/hotmodule/HuyaHotModule.java b/chopperbot-common/src/main/java/org/example/bean/hotmodule/HuyaHotModule.java
new file mode 100644
index 0000000..c9cf950
--- /dev/null
+++ b/chopperbot-common/src/main/java/org/example/bean/hotmodule/HuyaHotModule.java
@@ -0,0 +1,15 @@
+package org.example.bean.hotmodule;
+
+import org.example.bean.HotModule;
+import org.example.bean.live.HuyaLive;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 00:42
+ **/
+public class HuyaHotModule extends HotModule<HuyaLive> {
+
+    public HuyaHotModule(String tagId, String tagName) {
+        super(tagId, tagName);
+    }
+}
diff --git a/chopperbot-common/src/main/java/org/example/bean/live/HuyaLive.java b/chopperbot-common/src/main/java/org/example/bean/live/HuyaLive.java
new file mode 100644
index 0000000..e841ca4
--- /dev/null
+++ b/chopperbot-common/src/main/java/org/example/bean/live/HuyaLive.java
@@ -0,0 +1,34 @@
+package org.example.bean.live;
+
+import lombok.Data;
+import org.example.bean.Live;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 22:04
+ **/
+@Data
+public class HuyaLive extends Live {
+
+    private String uid;
+
+    public HuyaLive(String uid) {
+        this.uid = uid;
+    }
+
+    public HuyaLive(int watcherNum, String liveId, String liveName, String description) {
+        super(watcherNum, liveId, liveName, description);
+    }
+
+    public HuyaLive(int watcherNum, String liveId, String liveName, String liver, String description) {
+        super(watcherNum, liveId, liveName, liver, description);
+    }
+
+    public HuyaLive(int watcherNum, String liveId, String liveName, String liver, String description, String platform) {
+        super(watcherNum, liveId, liveName, liver, description, platform);
+    }
+
+    public HuyaLive(int watcherNum, String liveId, String liveName, String liver, String description, String platform, String moduleId, String moduleName) {
+        super(watcherNum, liveId, liveName, liver, description, platform, moduleId, moduleName);
+    }
+}
diff --git a/chopperbot-common/src/main/java/org/example/core/SafeBag.java b/chopperbot-common/src/main/java/org/example/core/SafeBag.java
new file mode 100644
index 0000000..1f7327f
--- /dev/null
+++ b/chopperbot-common/src/main/java/org/example/core/SafeBag.java
@@ -0,0 +1,24 @@
+package org.example.core;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 01:30
+ **/
+public class SafeBag<T> {
+    T data;
+
+    public SafeBag(T data) {
+        this.data = data;
+    }
+
+    public SafeBag() {
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data){
+        this.data = data;
+    }
+}
diff --git a/chopperbot-common/src/main/java/org/example/init/CommonInitMachine.java b/chopperbot-common/src/main/java/org/example/init/CommonInitMachine.java
index ff55696..07e21aa 100644
--- a/chopperbot-common/src/main/java/org/example/init/CommonInitMachine.java
+++ b/chopperbot-common/src/main/java/org/example/init/CommonInitMachine.java
@@ -8,6 +8,7 @@ package org.example.init;
 import org.example.log.ResultLogger;
 import org.example.plugin.CommonPlugin;
 import org.example.plugin.annotation.Plugin;
+import org.example.util.ExceptionUtil;
 import org.slf4j.Logger;
 
 import java.util.ArrayList;
@@ -89,7 +90,7 @@ public abstract class CommonInitMachine implements ComponentInitMachine, ResultL
                 return fail();
             }
         }catch (Exception e){
-            return fail(e.getMessage());
+            return fail(ExceptionUtil.getCause(e));
         }
     }
 
diff --git a/chopperbot-common/src/main/java/org/example/init/InitPluginRegister.java b/chopperbot-common/src/main/java/org/example/init/InitPluginRegister.java
index 6ac7622..32d6950 100644
--- a/chopperbot-common/src/main/java/org/example/init/InitPluginRegister.java
+++ b/chopperbot-common/src/main/java/org/example/init/InitPluginRegister.java
@@ -13,6 +13,7 @@ import org.example.plugin.CommonPlugin;
 import org.example.plugin.annotation.Plugin;
 import org.example.thread.ChopperBotGuardPool;
 import org.example.util.ClassUtil;
+import org.example.util.ExceptionUtil;
 import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Component;
 
@@ -161,7 +162,7 @@ public class InitPluginRegister {
                     }
                 }catch (Exception e){
                     ChopperLogFactory.getLogger(LoggerType.System)
-                            .error(String.format("❌ %s plugin start failed ! error:%s", pluginName,e.getMessage()));
+                            .error(String.format("❌ %s plugin start failed ! error:%s", pluginName, ExceptionUtil.getCause(e)));
                 }
             }else{
                 return false;
diff --git a/chopperbot-common/src/main/java/org/example/init/ModuleInitMachine.java b/chopperbot-common/src/main/java/org/example/init/ModuleInitMachine.java
index a16437f..c91fbfc 100644
--- a/chopperbot-common/src/main/java/org/example/init/ModuleInitMachine.java
+++ b/chopperbot-common/src/main/java/org/example/init/ModuleInitMachine.java
@@ -1,5 +1,6 @@
 package org.example.init;
 
+import org.example.util.ExceptionUtil;
 import org.example.util.PluginUtil;
 import org.slf4j.Logger;
 
@@ -50,7 +51,7 @@ public abstract class ModuleInitMachine extends CommonInitMachine{
                 }
             }
         } catch (Exception e) {
-            return fail(e.getMessage());
+            return fail( ExceptionUtil.getCause(e));
         }
 
         return initLogger(()->{
diff --git a/chopperbot-common/src/main/java/org/example/util/ExceptionUtil.java b/chopperbot-common/src/main/java/org/example/util/ExceptionUtil.java
new file mode 100644
index 0000000..bbc5fff
--- /dev/null
+++ b/chopperbot-common/src/main/java/org/example/util/ExceptionUtil.java
@@ -0,0 +1,12 @@
+package org.example.util;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 01:51
+ **/
+public class ExceptionUtil {
+
+    public static  <T extends Exception> String getCause(T e){
+       return e.getMessage()!=null?e.getMessage():e.getCause()!=null?e.getCause().toString():e.getLocalizedMessage();
+    }
+}
diff --git a/chopperbot-console/src/main/java/org/example/controller/HotController.java b/chopperbot-console/src/main/java/org/example/controller/HotController.java
index fcfac57..877265b 100644
--- a/chopperbot-console/src/main/java/org/example/controller/HotController.java
+++ b/chopperbot-console/src/main/java/org/example/controller/HotController.java
@@ -32,12 +32,7 @@ public class HotController {
     @CheckPlugin(needPlugin = {PluginName.HOT_GUARD_PLUGIN})
     @GetMapping("/hotLive/live")
     public Result getAllHotLive(@RequestParam(defaultValue = "0") int latest,@RequestParam String platform){
-        List<? extends Live> lives;
-        if(latest==1){
-            lives = HotModuleApi.getDouyuHotLive();
-        }else{
-            lives = HotModuleDataCenter.DataCenter().getLiveList(platform);
-        }
+        List<? extends Live> lives = hotModuleService.hotModuleApi().getHotLiveList(platform);
         if(lives==null){
             return Result.error("403","暂无该数据");
         }
@@ -47,12 +42,7 @@ public class HotController {
     @CheckPlugin(needPlugin = {PluginName.HOT_GUARD_PLUGIN})
     @GetMapping("/hotLive/module")
     public Result getAllHotModule(@RequestParam(defaultValue = "0") int latest,@RequestParam String platform){
-        HotModuleList hotModuleList;
-        if(latest==1){
-            hotModuleList = HotModuleApi.getDouyuAllHotModule();
-        }else{
-            hotModuleList = HotModuleDataCenter.DataCenter().getModuleList(platform);
-        }
+        HotModuleList hotModuleList = hotModuleService.hotModuleApi().getAllHotModule(platform);
         if(hotModuleList==null||hotModuleList.getHotModuleList()==null){
             return Result.error("403","暂无该数据");
         }
@@ -62,7 +52,7 @@ public class HotController {
     @CheckPlugin(needPlugin = {PluginName.HOT_GUARD_PLUGIN})
     @GetMapping("/hotLive/modelLive")
     public Result getHotModuleLives(@RequestParam String moduleId,@RequestParam String platform){
-        HotModule moduleHotLives = hotModuleService.getModuleHotLives(platform, moduleId);
+        HotModule moduleHotLives = hotModuleService.hotModuleApi().getModuleList(platform, moduleId);
         if(moduleHotLives==null||moduleHotLives.getHotLives()==null){
             return Result.error("403","暂无该数据");
         }
diff --git a/chopperbot-console/src/main/java/org/example/init/InitWorld.java b/chopperbot-console/src/main/java/org/example/init/InitWorld.java
index 85cb9c4..f75e5c1 100644
--- a/chopperbot-console/src/main/java/org/example/init/InitWorld.java
+++ b/chopperbot-console/src/main/java/org/example/init/InitWorld.java
@@ -11,6 +11,7 @@ import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
 import org.example.plugin.annotation.Plugin;
 import org.example.util.ClassUtil;
+import org.example.util.ExceptionUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
@@ -73,7 +74,7 @@ public class InitWorld implements CommandLineRunner {
                 close();
             }
         }catch (Exception e){
-            ChopperLogFactory.getLogger(LoggerType.System).error("Init Plugins Error:{}",e.getMessage());
+            ChopperLogFactory.getLogger(LoggerType.System).error("Init Plugins Error:{}",ExceptionUtil.getCause(e));
             close();
         }
 
diff --git a/chopperbot-console/src/main/java/org/example/init/WorldInitMachine.java b/chopperbot-console/src/main/java/org/example/init/WorldInitMachine.java
index a56333b..690bac3 100644
--- a/chopperbot-console/src/main/java/org/example/init/WorldInitMachine.java
+++ b/chopperbot-console/src/main/java/org/example/init/WorldInitMachine.java
@@ -4,6 +4,7 @@ import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
 import org.example.thread.ChopperBotGuardPool;
 import org.example.thread.oddjob.OddJobBoy;
+import org.example.util.ExceptionUtil;
 import org.example.util.PluginUtil;
 
 import java.util.ArrayList;
@@ -50,7 +51,7 @@ public class WorldInitMachine extends ModuleInitMachine{
 
             });
         } catch (Exception e) {
-            return fail(e.getMessage());
+            return fail( ExceptionUtil.getCause(e));
         }
     }
 
diff --git a/chopperbot-console/src/main/java/org/example/service/HotModuleService.java b/chopperbot-console/src/main/java/org/example/service/HotModuleService.java
index a04be51..47838d0 100644
--- a/chopperbot-console/src/main/java/org/example/service/HotModuleService.java
+++ b/chopperbot-console/src/main/java/org/example/service/HotModuleService.java
@@ -1,6 +1,7 @@
 package org.example.service;
 
 import org.example.api.HeatRecommendApi;
+import org.example.api.HotModuleApi;
 import org.example.api.HotModuleGuardApi;
 import org.example.api.LiverFollowApi;
 import org.example.bean.HotModule;
@@ -13,8 +14,8 @@ import java.util.List;
 public interface HotModuleService {
 
 
-    HotModule getModuleHotLives(String platform, String moduleId);
 
+    HotModuleApi hotModuleApi();
     LiverFollowApi liverFollowApi();
 
     HotModuleGuardApi hotModuleGuardApi();
diff --git a/chopperbot-console/src/main/java/org/example/service/impl/HotModuleServiceImpl.java b/chopperbot-console/src/main/java/org/example/service/impl/HotModuleServiceImpl.java
index 6716b0a..4a79a53 100644
--- a/chopperbot-console/src/main/java/org/example/service/impl/HotModuleServiceImpl.java
+++ b/chopperbot-console/src/main/java/org/example/service/impl/HotModuleServiceImpl.java
@@ -1,6 +1,7 @@
 package org.example.service.impl;
 
 import org.example.api.HeatRecommendApi;
+import org.example.api.HotModuleApi;
 import org.example.api.HotModuleGuardApi;
 import org.example.api.LiverFollowApi;
 import org.example.bean.Live;
@@ -21,6 +22,8 @@ import java.util.List;
 @Service
 public class HotModuleServiceImpl implements HotModuleService {
 
+    @Resource
+    HotModuleApi hotModuleApi;
     @Resource
     LiverFollowApi liverFollowApi;
 
@@ -34,24 +37,10 @@ public class HotModuleServiceImpl implements HotModuleService {
      * @param moduleId
      * @return
      */
+
     @Override
-    public HotModule getModuleHotLives(String platform,String moduleId) {
-        HotModuleList moduleList = HotModuleDataCenter.DataCenter().getModuleList(platform);
-        if(moduleList==null){
-            return null;
-        }
-        HotModule hotModule = moduleList.findHotModuleById(moduleId);
-        if(hotModule!=null){
-            try {
-                List<? extends Live> moduleLiveList = HotModuleDataCenter.DataCenter().getModuleLiveList(platform, hotModule);
-                hotModule.setHotLives(moduleLiveList);
-                return hotModule;
-            }catch (Exception e){
-                //TODO 交给Spring全局异常处理器
-                return null;
-            }
-        }
-        return null;
+    public HotModuleApi hotModuleApi() {
+        return hotModuleApi;
     }
 
     @Override
diff --git a/chopperbot-creeper/pom.xml b/chopperbot-creeper/pom.xml
index 1db7ec5..9373afb 100644
--- a/chopperbot-creeper/pom.xml
+++ b/chopperbot-creeper/pom.xml
@@ -19,6 +19,12 @@
 
     <dependencies>
 
+        <dependency>
+            <groupId>org.jsoup</groupId>
+            <artifactId>jsoup</artifactId>
+            <version>1.14.3</version>
+        </dependency>
+
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
diff --git a/chopperbot-creeper/src/main/java/org/example/core/loadtask/WebSocketLoadTask.java b/chopperbot-creeper/src/main/java/org/example/core/loadtask/WebSocketLoadTask.java
index 9ecf8e8..5d34a2c 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/loadtask/WebSocketLoadTask.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/loadtask/WebSocketLoadTask.java
@@ -2,6 +2,7 @@ package org.example.core.loadtask;
 
 import org.example.bean.barrage.DouyuBarrage;
 import org.example.core.loadconfig.LoadConfig;
+import org.example.util.ExceptionUtil;
 import org.example.ws.Draft_6455;
 import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.handshake.ServerHandshake;
@@ -58,7 +59,7 @@ public abstract class WebSocketLoadTask<T> extends CommonLoadTask<T>{
             client.setSocketFactory(sslSocketFactory);
             client.connectBlocking(60, TimeUnit.SECONDS);
         }catch (URISyntaxException | InterruptedException e){
-            this.logger.error("Websocket creeper error:{}",e.getMessage());
+            this.logger.error("Websocket creeper error:{}", ExceptionUtil.getCause(e));
             return null;
         }
         if(client==null){
diff --git a/chopperbot-creeper/src/main/java/org/example/core/manager/AbstractCreeperGroup.java b/chopperbot-creeper/src/main/java/org/example/core/manager/AbstractCreeperGroup.java
index 29d35a0..3e8ddd5 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/manager/AbstractCreeperGroup.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/manager/AbstractCreeperGroup.java
@@ -17,7 +17,7 @@ import java.util.TreeSet;
  * @date 2023/09/07 14:54
  **/
 @Component
-public abstract class AbstractCreeperGroup implements Serializable  {
+public class AbstractCreeperGroup implements Serializable  {
 
     private final Set<CreeperMember> creeperMember;
 
@@ -51,9 +51,13 @@ public abstract class AbstractCreeperGroup implements Serializable  {
         return null;
     }
 
-    public abstract String getPlatform();
+    public String getPlatform(){
+        return null;
+    }
 
-    public abstract String getFunctionName();
+    public String getFunctionName(){
+        return null;
+    }
 
     public String getGroupName(){
         return getPlatform()+"_"+getFunctionName();
diff --git a/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperGroupCenter.java b/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperGroupCenter.java
index 0d83886..cb9f9b0 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperGroupCenter.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperGroupCenter.java
@@ -1,12 +1,14 @@
 package org.example.core.manager;
 
 import lombok.Data;
+import org.example.constpool.ConstGroup;
 import org.example.core.loadconfig.LoadConfig;
 import org.example.util.ClassUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationContext;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
 
 import java.io.Serializable;
 import java.util.HashMap;
@@ -25,10 +27,25 @@ public class CreeperGroupCenter implements Serializable {
 
     @Autowired
     public CreeperGroupCenter(ApplicationContext context){
-        Map<String, AbstractCreeperGroup> beans = context.getBeansOfType(AbstractCreeperGroup.class);
-        beans.forEach((k,v)->{
-            groupMap.put(v.getGroupName(),v);
-        });
+        Set<Class<?>> creepers = ClassUtil.getAnnotationClass(PROJECT_PATH + ".core.creeper.loadconfig", Creeper.class);
+        for (Class<?> creeper : creepers) {
+            Creeper annotation = creeper.getAnnotation(Creeper.class);
+            String name = annotation.creeperName();
+            boolean discard = annotation.discard();
+            String platform = annotation.platform();
+            String groupName = StringUtils.hasText(platform)?CreeperGroupCenter.getGroupName(platform,annotation.group()):annotation.group();
+            int priority = annotation.priority();
+
+            AbstractCreeperGroup.CreeperMember member = new AbstractCreeperGroup.CreeperMember(priority, (Class<? extends LoadConfig>) creeper, discard, name);
+            if (CreeperGroupCenter.GroupMap().containsKey(groupName)) {
+                AbstractCreeperGroup group = CreeperGroupCenter.GroupMap().get(groupName);
+                group.addMember(member);
+            }else{
+                AbstractCreeperGroup group = new AbstractCreeperGroup();
+                groupMap.put(groupName,group);
+                group.addMember(member);
+            }
+        }
     }
 
     public static Map<String,AbstractCreeperGroup> GroupMap(){
diff --git a/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperManager.java b/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperManager.java
index 70c6786..21ae331 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperManager.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/manager/CreeperManager.java
@@ -39,11 +39,6 @@ public class CreeperManager extends CommonPlugin {
             String groupName = CreeperGroupCenter.getGroupName(annotation.platform(),annotation.group());
             int priority = annotation.priority();
 
-            if (CreeperGroupCenter.GroupMap().containsKey(groupName)) {
-                AbstractCreeperGroup group = CreeperGroupCenter.GroupMap().get(groupName);
-                group.addMember(new AbstractCreeperGroup.CreeperMember(priority, (Class<? extends LoadConfig>) creeper,discard,name));
-            }
-
             creeperBeans.add(new CreeperBean(name,description,author,groupName,discard,priority));
         }
         return true;
diff --git a/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/ReptileTask.java b/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/ReptileTask.java
index 2e53bac..5ec6426 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/ReptileTask.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/ReptileTask.java
@@ -12,6 +12,7 @@ import org.example.init.InitPluginRegister;
 import org.example.core.taskcenter.request.ReptileRequest;
 import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
+import org.example.util.ExceptionUtil;
 import org.example.util.TimeUtil;
 
 import java.io.Serializable;
@@ -50,8 +51,8 @@ public class ReptileTask implements Serializable {
     }
 
     public void reptile(){
+        TaskCenter plugin = InitPluginRegister.getPlugin(PluginName.TASK_CENTER_PLUGIN,TaskCenter.class);
         try {
-            TaskCenter plugin = InitPluginRegister.getPlugin(PluginName.TASK_CENTER_PLUGIN,TaskCenter.class);
             assert plugin != null;
             //开始任务
             this.startTime = TimeUtil.getNowTime_YMDHMS();
@@ -63,15 +64,17 @@ public class ReptileTask implements Serializable {
             Object res = loadTask.start();
             request.response(res); //让请求响应结果
 
+        }catch (Exception e){
+            ChopperLogFactory.getLogger(LoggerType.Creeper).info("[{}] {} stop, Error:{}",
+                    PluginName.TASK_CENTER_PLUGIN,taskId, ExceptionUtil.getCause(e));
+        }finally {
+            assert plugin != null;
             //完成任务
             plugin.finishTask(taskId);
             plugin.info(String.format("%s end reptile!", taskId));
             this.type = TaskStatus.Finish;
             this.endTime = TimeUtil.getNowTime_YMDHMS();
             plugin.getTaskCenterLogger().setEndTime(taskId,endTime);
-        }catch (Exception e){
-            ChopperLogFactory.getLogger(LoggerType.Creeper).info("[{}] {} stop, Error:{}",
-                    PluginName.TASK_CENTER_PLUGIN,taskId,e.getCause());
         }
     }
 
diff --git a/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/TaskRecord.java b/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/TaskRecord.java
index 8152b99..525c440 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/TaskRecord.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/taskcenter/task/TaskRecord.java
@@ -6,6 +6,7 @@ import lombok.Data;
 import org.example.core.taskcenter.task.serializer.TaskStatusEnumDeserializer;
 import org.example.core.taskcenter.task.serializer.TaskStatusEnumSerializer;
 import org.example.exception.taskcenter.TaskSerializationException;
+import org.example.util.ExceptionUtil;
 
 
 import java.io.ByteArrayInputStream;
@@ -51,7 +52,7 @@ public class TaskRecord {
             oos.writeObject(reptileTask);
             return baos.toByteArray();
         }catch (Exception e){
-            throw new TaskSerializationException(reptileTask.getTaskId(),e.getMessage());
+            throw new TaskSerializationException(reptileTask.getTaskId(), ExceptionUtil.getCause(e));
         }
     }
 
diff --git a/chopperbot-creeper/src/main/java/org/example/core/taskmonitor/MonitorCenter.java b/chopperbot-creeper/src/main/java/org/example/core/taskmonitor/MonitorCenter.java
index 43d8b2e..44d9a1f 100644
--- a/chopperbot-creeper/src/main/java/org/example/core/taskmonitor/MonitorCenter.java
+++ b/chopperbot-creeper/src/main/java/org/example/core/taskmonitor/MonitorCenter.java
@@ -5,6 +5,7 @@ import org.example.constpool.PluginName;
 import org.example.core.loadtask.LoadTask;
 import org.example.plugin.CommonPlugin;
 import org.example.thread.NamedThreadFactory;
+import org.example.util.ExceptionUtil;
 
 import java.util.HashMap;
 import java.util.List;
@@ -52,7 +53,7 @@ public class MonitorCenter extends CommonPlugin {
                 this.info(String.format("%s no setting monitor", taskId));
             }
         }catch (Exception e){
-            this.error(String.format("Error:%s",e.getMessage()));
+            this.error(String.format("Error:%s", ExceptionUtil.getCause(e)));
         }
     }
 
diff --git a/chopperbot-file/src/main/java/org/example/cache/FileCache.java b/chopperbot-file/src/main/java/org/example/cache/FileCache.java
index 14a6b7a..ddf76b1 100644
--- a/chopperbot-file/src/main/java/org/example/cache/FileCache.java
+++ b/chopperbot-file/src/main/java/org/example/cache/FileCache.java
@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONObject;
 import org.example.bean.ConfigFile;
 import org.example.bean.FileType;
 import org.example.exception.FileCacheException;
+import org.example.util.ExceptionUtil;
 import org.example.util.JsonFileUtil;
 import org.example.util.TimeUtil;
 import org.slf4j.Logger;
@@ -259,7 +260,7 @@ public class FileCache <T extends ConfigFile>{
         try {
             syncChannel.put(temp);
         } catch (InterruptedException e) {
-            logger.error("自动刷入失败,Error:{}",e.getMessage());
+            logger.error("自动刷入失败,Error:{}", ExceptionUtil.getCause(e));
         }
     }
 
diff --git a/chopperbot-file/src/main/java/org/example/init/ConfigInitMachine.java b/chopperbot-file/src/main/java/org/example/init/ConfigInitMachine.java
index 23d3f16..84a3cb7 100644
--- a/chopperbot-file/src/main/java/org/example/init/ConfigInitMachine.java
+++ b/chopperbot-file/src/main/java/org/example/init/ConfigInitMachine.java
@@ -7,6 +7,7 @@ import org.example.plugin.CommonPlugin;
 import org.example.plugin.PluginCheckAndDo;
 import org.example.plugin.annotation.Plugin;
 import org.example.util.ConfigFileUtil;
+import org.example.util.ExceptionUtil;
 
 import java.nio.file.Path;
 import java.nio.file.Paths;
@@ -40,7 +41,7 @@ public abstract class ConfigInitMachine extends CommonInitMachine{
                 return false;
             }
         }catch (Exception e){
-            return fail(e.getMessage());
+            return fail( ExceptionUtil.getCause(e));
         }
     }
 
diff --git a/chopperbot-file/src/main/java/org/example/init/FileCacheManagerInitMachine.java b/chopperbot-file/src/main/java/org/example/init/FileCacheManagerInitMachine.java
index b819c67..dbf8636 100644
--- a/chopperbot-file/src/main/java/org/example/init/FileCacheManagerInitMachine.java
+++ b/chopperbot-file/src/main/java/org/example/init/FileCacheManagerInitMachine.java
@@ -7,6 +7,7 @@ import org.example.constpool.ModuleName;
 import org.example.constpool.PluginName;
 import org.example.plugin.CommonPlugin;
 import org.example.plugin.annotation.Plugin;
+import org.example.util.ExceptionUtil;
 
 import java.util.List;
 
@@ -43,7 +44,7 @@ public class FileCacheManagerInitMachine extends CommonInitMachine{
                 return fail();
             }
         }catch (Exception e){
-            return fail(e.getMessage());
+            return fail(ExceptionUtil.getCause(e));
         }
     }
 
diff --git a/chopperbot-hot/src/main/java/org/example/App.java b/chopperbot-hot/src/main/java/org/example/App.java
index 667ab86..c510f27 100644
--- a/chopperbot-hot/src/main/java/org/example/App.java
+++ b/chopperbot-hot/src/main/java/org/example/App.java
@@ -2,7 +2,12 @@ package org.example;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;
+import org.jsoup.Jsoup;
+import org.jsoup.nodes.Document;
+import org.jsoup.nodes.Element;
+import org.jsoup.select.Elements;
 
+import java.io.IOException;
 import java.util.TreeSet;
 
 /**
@@ -11,7 +16,7 @@ import java.util.TreeSet;
  */
 public class App
 {
-    public static void main(String[] args) {
+    public static void main(String[] args) throws IOException {
 
     }
 }
diff --git a/chopperbot-hot/src/main/java/org/example/api/HotModuleApi.java b/chopperbot-hot/src/main/java/org/example/api/HotModuleApi.java
index b9349e2..ff55229 100644
--- a/chopperbot-hot/src/main/java/org/example/api/HotModuleApi.java
+++ b/chopperbot-hot/src/main/java/org/example/api/HotModuleApi.java
@@ -1,6 +1,7 @@
 package org.example.api;
 
 
+import org.example.bean.HotModule;
 import org.example.bean.Live;
 import org.example.bean.live.BiliBiliLive;
 import org.example.bean.live.DouyuLive;
@@ -35,19 +36,23 @@ public class HotModuleApi {
        return HotModuleDataCenter.DataCenter().getLiveList(platform);
     }
 
-    public static HotModuleList getDouyuAllHotModule(){
-        return new DouyuHotModuleLoadTask(new DouyuHotModuleConfig()).start();
+    public HotModule getModuleList(String platform,String moduleId){
+        HotModuleList moduleList = HotModuleDataCenter.DataCenter().getModuleList(platform);
+        if(moduleList==null){
+            return null;
+        }
+        HotModule hotModule = moduleList.findHotModuleById(moduleId);
+        if(hotModule!=null){
+            try {
+                List<? extends Live> moduleLiveList = HotModuleDataCenter.DataCenter().getModuleLiveList(platform, hotModule);
+                hotModule.setHotLives(moduleLiveList);
+                return hotModule;
+            }catch (Exception e){
+                //TODO 交给Spring全局异常处理器
+                return null;
+            }
+        }
+        return null;
     }
 
-    public static List<DouyuLive> getDouyuHotLive(){
-        return new DouyuHotLiveLoadTask(new DouyuHotLiveConfig()).start();
-    }
-
-    public static List<DouyuLive> getDouyuHotLive(int moduleId){
-        return new DouyuHotLiveLoadTask(new DouyuHotLiveConfig(moduleId)).start();
-    }
-
-    public static List<BiliBiliLive> getBiliBiliHotLive(String parentId,String areaId,int page){
-        return new BiliBiliHotLiveLoadTask(new BilibiliHotLiveConfig(parentId,areaId,page)).start();
-    }
 }
diff --git a/chopperbot-hot/src/main/java/org/example/bean/FocusLiver.java b/chopperbot-hot/src/main/java/org/example/bean/FocusLiver.java
index d448334..fa39842 100644
--- a/chopperbot-hot/src/main/java/org/example/bean/FocusLiver.java
+++ b/chopperbot-hot/src/main/java/org/example/bean/FocusLiver.java
@@ -30,4 +30,6 @@ public class FocusLiver implements Serializable {
     private String platform;
 
     private String tag;
+
+    private Boolean isAuto;
 }
diff --git a/chopperbot-hot/src/main/java/org/example/core/HotModuleDataCenter.java b/chopperbot-hot/src/main/java/org/example/core/HotModuleDataCenter.java
index f01cd8d..f22dbf6 100644
--- a/chopperbot-hot/src/main/java/org/example/core/HotModuleDataCenter.java
+++ b/chopperbot-hot/src/main/java/org/example/core/HotModuleDataCenter.java
@@ -10,6 +10,7 @@ import org.example.bean.hotmodule.HotModuleList;
 import org.example.constpool.ConstGroup;
 import org.example.constpool.ConstPool;
 import org.example.constpool.PluginName;
+import org.example.core.creeper.loadtask.HotModuleLoadTask;
 import org.example.core.loadtask.LoadTask;
 import org.example.core.manager.CreeperGroupCenter;
 import org.example.core.manager.CreeperManager;
@@ -25,7 +26,9 @@ import org.springframework.stereotype.Component;
 import javax.annotation.Resource;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
@@ -159,14 +162,15 @@ public class HotModuleDataCenter{
     }
 
     private List<? extends Live> checkPlatformAndGetList(String platform,HotModule hotModule){
-        List<? extends Live> lives = new ArrayList<>();
-        if(ConstPool.PLATFORM.DOUYU.getName().equals(platform)){
-            lives = HotModuleApi.getDouyuHotLive(Integer.parseInt(hotModule.getTagId()));
-        }else if (ConstPool.PLATFORM.BILIBILI.getName().equals(platform)){
-            BilibiliHotModule temp = (BilibiliHotModule) hotModule;
-            lives = HotModuleApi.getBiliBiliHotLive(temp.getParent_id(),temp.getTagId(),1);
-        }
-        return lives;
+        SafeBag<List<? extends Live>> bag = new SafeBag<>();
+        Optional.ofNullable(InitPluginRegister.getPlugin(PluginName.CREEPER_MANAGER_PLUGIN, CreeperManager.class))
+        .ifPresent(
+                (plugin)->{
+                    HotModuleLoadTask<List<? extends Live>> loadTask = plugin.getLoadTask(CreeperGroupCenter.getGroupName(platform, ConstGroup.HOT_LIVE), hotModule);
+                    bag.setData((loadTask.start()));
+                }
+        );
+        return bag.getData();
     }
 
     //根据平台的模块名获取某模块
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/builder/BilibiliHotLiveBuilder.java b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/BilibiliHotLiveBuilder.java
new file mode 100644
index 0000000..f052d13
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/BilibiliHotLiveBuilder.java
@@ -0,0 +1,24 @@
+package org.example.core.creeper.builder;
+
+import org.example.api.HotModuleApi;
+import org.example.bean.HotModule;
+import org.example.bean.hotmodule.BilibiliHotModule;
+import org.example.core.creeper.loadconfig.BilibiliHotLiveConfig;
+import org.example.core.manager.CommonLoadConfigBuilder;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 01:17
+ **/
+@Component
+public class BilibiliHotLiveBuilder extends CommonLoadConfigBuilder<BilibiliHotLiveConfig> {
+
+    @Override
+    public BilibiliHotLiveConfig build(Object obj) {
+        if(obj instanceof BilibiliHotModule){
+           return new BilibiliHotLiveConfig(((BilibiliHotModule) obj).getParent_id(),((BilibiliHotModule) obj).getAct_id(),1);
+        }
+        return null;
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/builder/DouyuHotLiveBuilder.java b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/DouyuHotLiveBuilder.java
new file mode 100644
index 0000000..4be8483
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/DouyuHotLiveBuilder.java
@@ -0,0 +1,23 @@
+package org.example.core.creeper.builder;
+
+import org.example.bean.HotModule;
+import org.example.bean.hotmodule.DouyuHotModule;
+import org.example.core.creeper.loadconfig.DouyuHotLiveConfig;
+import org.example.core.manager.CommonLoadConfigBuilder;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 01:18
+ **/
+
+@Component
+public class DouyuHotLiveBuilder extends CommonLoadConfigBuilder<DouyuHotLiveConfig> {
+    @Override
+    public DouyuHotLiveConfig build(Object obj) {
+        if(obj instanceof DouyuHotModule){
+            return new DouyuHotLiveConfig(Integer.parseInt(((DouyuHotModule) obj).getTagId()));
+        }
+        return null;
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaHotLiveBuilder.java b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaHotLiveBuilder.java
new file mode 100644
index 0000000..82b01ec
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaHotLiveBuilder.java
@@ -0,0 +1,23 @@
+package org.example.core.creeper.builder;
+
+import org.example.bean.HotModule;
+import org.example.bean.hotmodule.HuyaHotModule;
+import org.example.core.creeper.loadconfig.HuyaHotLiveConfig;
+import org.example.core.manager.CommonLoadConfigBuilder;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 01:17
+ **/
+@Component
+public class HuyaHotLiveBuilder extends CommonLoadConfigBuilder<HuyaHotLiveConfig> {
+
+    @Override
+    public HuyaHotLiveConfig build(Object obj) {
+        if(obj instanceof HuyaHotModule){
+            return new HuyaHotLiveConfig(((HuyaHotModule) obj).getTagId());
+        }
+        return null;
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaLiverCheckerBuilder.java b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaLiverCheckerBuilder.java
new file mode 100644
index 0000000..b57906d
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/builder/HuyaLiverCheckerBuilder.java
@@ -0,0 +1,21 @@
+package org.example.core.creeper.builder;
+
+import org.example.bean.live.HuyaLive;
+import org.example.core.creeper.loadconfig.HuyaLiverCheckerConfig;
+import org.example.core.manager.CommonLoadConfigBuilder;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 23:06
+ **/
+@Component
+public class HuyaLiverCheckerBuilder extends CommonLoadConfigBuilder<HuyaLiverCheckerConfig> {
+    @Override
+    public HuyaLiverCheckerConfig build(Object obj) {
+        if(obj instanceof HuyaLive){
+            return new HuyaLiverCheckerConfig(((HuyaLive) obj).getLiveId());
+        }
+        return null;
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotLiveGroup.java b/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotLiveGroup.java
deleted file mode 100644
index 4b40cdf..0000000
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotLiveGroup.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:11
- **/
-@Component
-public class BilibiliHotLiveGroup extends AbstractCreeperGroup {
-
-    @Override
-    public String getPlatform() {
-        return ConstPool.PLATFORM.BILIBILI.getName();
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.HOT_LIVE;
-    }
-
-}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotModuleGroup.java b/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotModuleGroup.java
deleted file mode 100644
index a5ea491..0000000
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliHotModuleGroup.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 16:52
- **/
-@Component
-public class BilibiliHotModuleGroup extends AbstractCreeperGroup {
-
-    @Override
-    public String getPlatform() {
-        return ConstPool.PLATFORM.BILIBILI.getName();
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.HOT_MODULE;
-    }
-}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliLiverCheckerGroup.java b/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliLiverCheckerGroup.java
deleted file mode 100644
index 1183c5a..0000000
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/group/BilibiliLiverCheckerGroup.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/10 01:02
- **/
-@Component
-public class BilibiliLiverCheckerGroup extends AbstractCreeperGroup {
-
-    @Override
-    public String getPlatform() {
-        return ConstPool.BILIBILI;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.LIVER_CHECKER;
-    }
-}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotLiveGroup.java b/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotLiveGroup.java
deleted file mode 100644
index 2ada5fa..0000000
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotLiveGroup.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:10
- **/
-@Component
-public class DouyuHotLiveGroup extends AbstractCreeperGroup {
-
-
-    @Override
-    public String getPlatform() {
-        return ConstPool.PLATFORM.DOUYU.getName();
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.HOT_LIVE;
-    }
-}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotModuleGroup.java b/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotModuleGroup.java
deleted file mode 100644
index c1b434e..0000000
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuHotModuleGroup.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 16:54
- **/
-@Component
-public class DouyuHotModuleGroup extends AbstractCreeperGroup {
-
-    @Override
-    public String getPlatform() {
-        return ConstPool.PLATFORM.DOUYU.getName();
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.HOT_MODULE;
-    }
-}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuLiverCheckerGroup.java b/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuLiverCheckerGroup.java
deleted file mode 100644
index cd1bb47..0000000
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/group/DouyuLiverCheckerGroup.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/10 01:54
- **/
-@Component
-public class DouyuLiverCheckerGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.DOUYU;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.LIVER_CHECKER;
-    }
-}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/BilibiliHotLiveConfig.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/BilibiliHotLiveConfig.java
index c8c616d..0aa55fc 100644
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/BilibiliHotLiveConfig.java
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/BilibiliHotLiveConfig.java
@@ -2,10 +2,8 @@ package org.example.core.creeper.loadconfig;
 
 import org.example.constpool.ConstGroup;
 import org.example.constpool.ConstPool;
-import org.example.core.creeper.group.BilibiliHotModuleGroup;
 import org.example.core.creeper.loadtask.BiliBiliHotLiveLoadTask;
 import org.example.core.manager.Creeper;
-import org.example.core.manager.CreeperGroupCenter;
 
 /**
  * @author Genius
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotLiveConfig.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotLiveConfig.java
new file mode 100644
index 0000000..e64550f
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotLiveConfig.java
@@ -0,0 +1,33 @@
+package org.example.core.creeper.loadconfig;
+
+import org.example.constpool.ConstGroup;
+import org.example.constpool.ConstPool;
+import org.example.core.creeper.loadtask.HuyaHotLiveLoadTask;
+import org.example.core.creeper.loadtask.HuyaHotModuleLoadTask;
+import org.example.core.manager.Creeper;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 00:47
+ **/
+@Creeper(creeperName = "虎牙热门直播模块",
+        loadTask = HuyaHotLiveLoadTask.class,
+        creeperDescription = "获取虎牙的热门直播，按照人气排行，也可以获取热门模块下的直播",
+        priority = 10,
+        group = ConstGroup.HOT_LIVE,
+        platform = ConstPool.HUYA
+)
+public class HuyaHotLiveConfig extends LoadHotModuleConfig{
+
+    private String moduleId;
+
+    public HuyaHotLiveConfig(String moduleId) {
+        this.url = String.format("https://live.huya.com/liveHttpUI/getLiveList?iGid=%s&iPageNo=1&iPageSize=120", moduleId);
+    }
+
+    public HuyaHotLiveConfig() {
+        moduleId = "0";
+        this.url = String.format("https://live.huya.com/liveHttpUI/getLiveList?iGid=%s&iPageNo=1&iPageSize=120", moduleId);
+    }
+
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotModuleConfig.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotModuleConfig.java
new file mode 100644
index 0000000..699331c
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaHotModuleConfig.java
@@ -0,0 +1,26 @@
+package org.example.core.creeper.loadconfig;
+
+import org.example.constpool.ConstGroup;
+import org.example.constpool.ConstPool;
+import org.example.core.creeper.loadtask.BilibiliHotModuleLoadTask;
+import org.example.core.creeper.loadtask.HuyaHotModuleLoadTask;
+import org.example.core.manager.Creeper;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 00:39
+ **/
+
+@Creeper(creeperName = "虎牙热门模块",
+        loadTask = HuyaHotModuleLoadTask.class,
+        creeperDescription = "获取虎牙的热门模块，按照人气排行",
+        priority = 10,
+        group = ConstGroup.HOT_MODULE,
+        platform = ConstPool.HUYA
+)
+public class HuyaHotModuleConfig extends LoadHotModuleConfig{
+
+    public HuyaHotModuleConfig() {
+        this.url = "https://www.huya.com/g";
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaLiverCheckerConfig.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaLiverCheckerConfig.java
new file mode 100644
index 0000000..453aabe
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadconfig/HuyaLiverCheckerConfig.java
@@ -0,0 +1,36 @@
+package org.example.core.creeper.loadconfig;
+
+import lombok.Data;
+import org.example.constpool.ConstGroup;
+import org.example.constpool.ConstPool;
+import org.example.core.creeper.loadtask.HuyaLiverCheckerLoadTask;
+import org.example.core.loadconfig.LoadConfig;
+import org.example.core.manager.Creeper;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 23:01
+ **/
+
+@Data
+@Creeper(creeperName = "虎牙直播检测爬虫",
+        loadTask = HuyaLiverCheckerLoadTask.class,
+        creeperDescription = "用于检测虎牙主播是否开播，并且获取直播详细信息",
+        priority = 10,
+        group = ConstGroup.LIVER_CHECKER,
+        platform = ConstPool.HUYA
+)
+public class HuyaLiverCheckerConfig extends LoadConfig {
+
+    private String roomId;
+
+    public HuyaLiverCheckerConfig(String roomId){
+        this.roomId = roomId;
+        this.url = String.format(String.format("https://search.cdn.huya.com/?m=Search&do=getSearchContent&q=%s&typ=-5&rows=16",  roomId));
+    }
+
+    @Override
+    public String getTaskId() {
+        return super.getTaskId()+"_"+roomId;
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HotModuleLoadTask.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HotModuleLoadTask.java
index 5eba42d..0beba62 100644
--- a/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HotModuleLoadTask.java
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HotModuleLoadTask.java
@@ -4,6 +4,7 @@ import org.example.core.loadtask.WebMagicLoadTask;
 import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
 import org.example.core.loadconfig.LoadConfig;
+import org.example.util.ExceptionUtil;
 
 /**
  * @author Genius
@@ -27,7 +28,7 @@ public abstract class HotModuleLoadTask<T> extends WebMagicLoadTask<T> {
 
     protected void fail(Exception e){
         finishFlag = FinishFlag.FAIL;
-        ChopperLogFactory.getLogger(LoggerType.Hot).error("loadTask{} finish fail Error:{}",this.getClass().getName(),e.getMessage());
+        ChopperLogFactory.getLogger(LoggerType.Hot).error("loadTask{} finish fail Error:{}",this.getClass().getName(), ExceptionUtil.getCause(e));
     }
 
     protected void success(){
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotLiveLoadTask.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotLiveLoadTask.java
new file mode 100644
index 0000000..ef89c9e
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotLiveLoadTask.java
@@ -0,0 +1,48 @@
+package org.example.core.creeper.loadtask;
+
+import org.example.bean.live.BiliBiliLive;
+import org.example.bean.live.HuyaLive;
+import org.example.constpool.ConstPool;
+import org.example.core.creeper.loadconfig.HuyaHotLiveConfig;
+import org.example.core.creeper.processor.BiliBiliHotLiveProcessor;
+import org.example.core.creeper.processor.HuyaHotLiveProcessor;
+import org.example.core.factory.SpiderFactory;
+import org.example.core.loadconfig.LoadConfig;
+import org.example.core.loadtask.WebMagicLoadTask;
+import us.codecraft.webmagic.Spider;
+
+import java.util.List;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 00:50
+ **/
+public class HuyaHotLiveLoadTask extends HotModuleLoadTask<List<HuyaLive>> {
+
+    public HuyaHotLiveLoadTask(HuyaHotLiveConfig loadConfig) {
+        super(loadConfig);
+    }
+
+    @Override
+    public List<HuyaLive> start() {
+        clearFinishFlag();
+        List<HuyaLive> lives;
+        HuyaHotLiveProcessor huyaHotLiveProcessor = new HuyaHotLiveProcessor();
+        Spider spider = SpiderFactory.buildSpider(ConstPool.PLATFORM.HUYA.getName(),
+                huyaHotLiveProcessor,
+                loadConfig.getUrl());
+        try {
+            lives = getData(spider,loadConfig.getUrl());
+        }catch (Exception e){
+            fail(e);
+            return null;
+        }
+        success();
+        return lives;
+    }
+
+    @Override
+    public void end() {
+
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotModuleLoadTask.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotModuleLoadTask.java
new file mode 100644
index 0000000..31cf67a
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaHotModuleLoadTask.java
@@ -0,0 +1,47 @@
+package org.example.core.creeper.loadtask;
+
+import org.example.bean.hotmodule.HotModuleList;
+import org.example.bean.hotmodule.HuyaHotModule;
+import org.example.core.creeper.loadconfig.HuyaHotModuleConfig;
+import org.example.core.loadconfig.LoadConfig;
+import org.jsoup.Jsoup;
+import org.jsoup.nodes.Document;
+import org.jsoup.nodes.Element;
+import org.jsoup.select.Elements;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 00:38
+ **/
+public class HuyaHotModuleLoadTask extends HotModuleLoadTask<HotModuleList>{
+
+    public HuyaHotModuleLoadTask(HuyaHotModuleConfig loadConfig) {
+        super(loadConfig);
+    }
+
+    @Override
+    public HotModuleList start() {
+        HotModuleList data = null;
+        clearFinishFlag();
+        try {
+            Document doc = Jsoup.connect(loadConfig.getUrl()).get();
+            Element ul = doc.selectFirst("ul#js-game-list");
+            if (ul != null) {
+                Elements liElements = ul.select("li"); // 获取ul下的所有li元素
+                data = new HotModuleList();
+                for (Element li : liElements) {
+                    String dataGid = li.attr("data-gid");
+                    String gName = li.text();
+                    data.getHotModuleList().add(new HuyaHotModule(dataGid, gName));
+                }
+            }
+        }catch (Exception e){
+            fail(e);
+        }
+        success();
+        return data;
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaLiverCheckerLoadTask.java b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaLiverCheckerLoadTask.java
new file mode 100644
index 0000000..d92efa0
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/loadtask/HuyaLiverCheckerLoadTask.java
@@ -0,0 +1,45 @@
+package org.example.core.creeper.loadtask;
+
+import org.example.bean.live.DouyuLive;
+import org.example.bean.live.HuyaLive;
+import org.example.constpool.ConstPool;
+import org.example.core.creeper.loadconfig.HuyaLiverCheckerConfig;
+import org.example.core.creeper.processor.DouyuLiverCheckerProcessor;
+import org.example.core.creeper.processor.HuyaLiverCheckerProcessor;
+import org.example.core.factory.SpiderFactory;
+import org.example.core.loadconfig.LoadConfig;
+import org.example.core.loadtask.WebMagicLoadTask;
+import us.codecraft.webmagic.Spider;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 23:01
+ **/
+public class HuyaLiverCheckerLoadTask extends WebMagicLoadTask<HuyaLive> {
+
+    public HuyaLiverCheckerLoadTask(HuyaLiverCheckerConfig loadConfig) {
+        super(loadConfig);
+
+    }
+
+    @Override
+    public HuyaLive start() {
+        HuyaLive live = null;
+        Spider spider = SpiderFactory.buildSpider(
+                ConstPool.PLATFORM.HUYA.getName(),
+                new HuyaLiverCheckerProcessor(),
+                loadConfig.getUrl()
+        );
+        try {
+            live = getData(spider,loadConfig.getUrl());
+        }catch (Exception e){
+            return null;
+        }
+        return live;
+    }
+
+    @Override
+    public void end() {
+
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaHotLiveProcessor.java b/chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaHotLiveProcessor.java
new file mode 100644
index 0000000..a6b13e8
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaHotLiveProcessor.java
@@ -0,0 +1,54 @@
+package org.example.core.creeper.processor;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import org.example.bean.live.BiliBiliLive;
+import org.example.bean.live.HuyaLive;
+import org.example.constpool.ConstPool;
+import org.example.core.processor.AbstractProcessor;
+import us.codecraft.webmagic.Page;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Genius
+ * @date 2023/10/17 00:52
+ **/
+public class HuyaHotLiveProcessor extends AbstractProcessor {
+    @Override
+    public void process(Page page) {
+        List<HuyaLive> liveList = new ArrayList<>();
+        try {
+            JSONArray Lives = JSON.parseObject(page.getRawText()).getJSONArray("vList");
+            for (Object live : Lives) {
+                if(live instanceof JSONObject){
+                    JSONObject jsonLive = (JSONObject) live;
+                    String lUid = jsonLive.getString("lUid");
+                    String nickName = jsonLive.getString("sNick");
+                    Integer watchNum = jsonLive.getInteger("lActivityCount");
+                    String moduleId = jsonLive.getString("iGid");
+                    String moduleName = jsonLive.getString("sGameFullName");
+                    String introduction = jsonLive.getString("sIntroduction");
+                    String roomId = jsonLive.getString("lProfileRoom");
+                    String pic = jsonLive.getString("sScreenshot");
+                    HuyaLive huyaLive = new HuyaLive(lUid);
+                    huyaLive.setLiveName(introduction);
+                    huyaLive.setPlatform(ConstPool.HUYA);
+                    huyaLive.setDescription(introduction);
+                    huyaLive.setLiver(nickName);
+                    huyaLive.setWatcherNum(watchNum);
+                    huyaLive.setModuleId(moduleId);
+                    huyaLive.setModuleName(moduleName);
+                    huyaLive.setLiveId(roomId);
+                    huyaLive.setRoomPic(pic);
+                    liveList.add(huyaLive);
+                }
+            }
+        }catch (Exception e){
+            throw e;
+        }
+        page.putField("data",liveList);
+    }
+}
diff --git a/chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaLiverCheckerProcessor.java b/chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaLiverCheckerProcessor.java
new file mode 100644
index 0000000..6ac5c11
--- /dev/null
+++ b/chopperbot-hot/src/main/java/org/example/core/creeper/processor/HuyaLiverCheckerProcessor.java
@@ -0,0 +1,55 @@
+package org.example.core.creeper.processor;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import org.example.bean.live.HuyaLive;
+import org.example.constpool.ConstPool;
+import org.example.core.processor.AbstractProcessor;
+import org.example.util.TimeUtil;
+import us.codecraft.webmagic.Page;
+
+import java.util.Optional;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 23:37
+ **/
+public class HuyaLiverCheckerProcessor extends AbstractProcessor {
+    @Override
+    public void process(Page page) {
+        JSONObject live = JSON.parseObject(page.getRawText()).getJSONObject("response").getJSONObject("1");
+        if(live!=null){
+            JSONArray array = Optional.ofNullable(live.getJSONArray("docs")).orElse(new JSONArray());
+            for (Object doc : array) {
+                if(doc instanceof JSONObject){
+                    if (Boolean.TRUE.equals(((JSONObject) doc).getBoolean("gameLiveOn"))) {
+                        String uid = ((JSONObject) doc).getString("uid");
+                        Integer activityCount = ((JSONObject) doc).getInteger("game_activityCount");
+                        String avatar = ((JSONObject) doc).getString("game_avatarUrl180");
+                        String moduleName = ((JSONObject) doc).getString("game_name");
+                        Integer moduleId = ((JSONObject) doc).getInteger("game_id");
+                        String roomId = ((JSONObject) doc).getString("room_id");
+                        String liver = ((JSONObject) doc).getString("game_nick");
+                        String liveName = ((JSONObject) doc).getString("live_intro");
+                        Long showTime = ((JSONObject) doc).getLong("rec_live_time") * 1000;
+                        HuyaLive huyaLive = new HuyaLive(uid);
+                        huyaLive.setWatcherNum(activityCount);
+                        huyaLive.setRoomPic(avatar);
+                        huyaLive.setModuleName(moduleName);
+                        huyaLive.setModuleId(moduleId.toString());
+                        huyaLive.setLiveId(roomId);
+                        huyaLive.setLiver(liver);
+                        huyaLive.setLiveName(liveName);
+                        huyaLive.setDescription(liveName);
+                        huyaLive.setShowTime(TimeUtil.getFormatDate(showTime));
+                        huyaLive.setPlatform(ConstPool.HUYA);
+                        page.putField("data",huyaLive);
+                        return;
+                    }
+                }
+            }
+        }
+
+    }
+}
diff --git a/chopperbot-live/src/main/java/org/example/core/component/LiveStreamTask.java b/chopperbot-live/src/main/java/org/example/core/component/LiveStreamTask.java
index 908fde3..a4565bd 100644
--- a/chopperbot-live/src/main/java/org/example/core/component/LiveStreamTask.java
+++ b/chopperbot-live/src/main/java/org/example/core/component/LiveStreamTask.java
@@ -1,6 +1,8 @@
 package org.example.core.component;
 
 import lombok.Data;
+import org.example.constpool.PluginName;
+import org.example.log.ChopperLogFactory;
 
 import java.io.InputStream;
 import java.io.OutputStream;
@@ -33,6 +35,7 @@ public class LiveStreamTask {
                 f.parseStream(in, taskId, fileIO);
             }
         } catch (Exception e) {
+            ChopperLogFactory.getLogger(PluginName.LIVE_MANAGER_PLUGIN).error("LiveStreamTask start error:", e);
             return;
         }
     }
diff --git a/chopperbot-live/src/main/java/org/example/core/component/M3U8Handle.java b/chopperbot-live/src/main/java/org/example/core/component/M3U8Handle.java
index 4b9ed7c..9923b00 100644
--- a/chopperbot-live/src/main/java/org/example/core/component/M3U8Handle.java
+++ b/chopperbot-live/src/main/java/org/example/core/component/M3U8Handle.java
@@ -3,6 +3,7 @@ package org.example.core.component;
 import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
 import org.example.pool.LiveModuleConstPool;
+import org.example.util.ExceptionUtil;
 import org.slf4j.Logger;
 
 import java.io.BufferedReader;
@@ -50,7 +51,7 @@ public class M3U8Handle {
             int exitCode = process.waitFor();
             logger.error("Exit code: {}",exitCode);
         } catch (IOException | InterruptedException e) {
-            logger.error("Error during video processing: {}",e.getMessage());
+            logger.error("Error during video processing: {}", ExceptionUtil.getCause(e));
             e.printStackTrace();
         }
     }
diff --git a/chopperbot-live/src/main/java/org/example/core/creeper/builder/HuyaLiveLoadConfigBuilder.java b/chopperbot-live/src/main/java/org/example/core/creeper/builder/HuyaLiveLoadConfigBuilder.java
new file mode 100644
index 0000000..f8745f1
--- /dev/null
+++ b/chopperbot-live/src/main/java/org/example/core/creeper/builder/HuyaLiveLoadConfigBuilder.java
@@ -0,0 +1,36 @@
+package org.example.core.creeper.builder;
+
+import org.example.bean.live.DouyuLive;
+import org.example.bean.live.HuyaLive;
+import org.example.constpool.ConstPool;
+import org.example.constpool.FileNameBuilder;
+import org.example.core.creeper.loadconfig.DouyuLiveOnlineConfig;
+import org.example.core.creeper.loadconfig.HuyaLiveOnlineConfig;
+import org.example.core.manager.CommonLoadConfigBuilder;
+import org.example.pool.LiveModuleConstPool;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Genius
+ * @date 2023/10/16 22:10
+ **/
+@Component
+public class HuyaLiveLoadConfigBuilder extends CommonLoadConfigBuilder<HuyaLiveOnlineConfig> {
+    @Override
+    public HuyaLiveOnlineConfig build(Object obj) {
+        if(obj instanceof HuyaLive){
+            String liveId = ((HuyaLive) obj).getLiveId();
+            String liver = ((HuyaLive) obj).getLiver();
+            String path = LiveModuleConstPool.getPlatformLiveSavePath(ConstPool.PLATFORM.HUYA);
+            String showTime = ((HuyaLive) obj).getShowTime();
+            HuyaLiveOnlineConfig huyaLiveOnlineConfig = new HuyaLiveOnlineConfig(liveId, path, null, false);
+            huyaLiveOnlineConfig.setShowTime(showTime);
+            huyaLiveOnlineConfig.setVideoName(FileNameBuilder.buildVideoFileNameNoSuffix(liver,huyaLiveOnlineConfig.getStartTime()));
+            huyaLiveOnlineConfig.setShowDownloadTable(true);
+            huyaLiveOnlineConfig.setLiverName(liver);
+            huyaLiveOnlineConfig.setRoomName(((HuyaLive) obj).getLiveName());
+            return huyaLiveOnlineConfig;
+        }
+        return null;
+    }
+}
diff --git a/chopperbot-live/src/main/java/org/example/core/creeper/group/BiliBiliLiveGroup.java b/chopperbot-live/src/main/java/org/example/core/creeper/group/BiliBiliLiveGroup.java
deleted file mode 100644
index 3a7ad15..0000000
--- a/chopperbot-live/src/main/java/org/example/core/creeper/group/BiliBiliLiveGroup.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:31
- **/
-@Component
-public class BiliBiliLiveGroup extends AbstractCreeperGroup {
-
-    @Override
-    public String getPlatform() {
-        return ConstPool.BILIBILI;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.LIVE_ONLINE;
-    }
-}
diff --git a/chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuLiveGroup.java b/chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuLiveGroup.java
deleted file mode 100644
index f4f767f..0000000
--- a/chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuLiveGroup.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:32
- **/
-@Component
-public class DouyuLiveGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.DOUYU;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.LIVE_ONLINE;
-    }
-}
diff --git a/chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuRecordGroup.java b/chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuRecordGroup.java
deleted file mode 100644
index 32947f9..0000000
--- a/chopperbot-live/src/main/java/org/example/core/creeper/group/DouyuRecordGroup.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-import org.springframework.stereotype.Component;
-
-/**
- * @author Genius
- * @date 2023/09/07 17:33
- **/
-@Component
-public class DouyuRecordGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.DOUYU;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.LIVE_RECORD;
-    }
-}
diff --git a/chopperbot-live/src/main/java/org/example/core/creeper/group/HuyaLiveGroup.java b/chopperbot-live/src/main/java/org/example/core/creeper/group/HuyaLiveGroup.java
deleted file mode 100644
index 434ed19..0000000
--- a/chopperbot-live/src/main/java/org/example/core/creeper/group/HuyaLiveGroup.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package org.example.core.creeper.group;
-
-import org.example.constpool.ConstGroup;
-import org.example.constpool.ConstPool;
-import org.example.core.manager.AbstractCreeperGroup;
-
-/**
- * @author dhx
- * @date 2023/10/10 10:53
- */
-public class HuyaLiveGroup extends AbstractCreeperGroup {
-    @Override
-    public String getPlatform() {
-        return ConstPool.HUYA;
-    }
-
-    @Override
-    public String getFunctionName() {
-        return ConstGroup.LIVE_ONLINE;
-    }
-}
diff --git a/chopperbot-live/src/main/java/org/example/core/creeper/loadtask/DouyuRecordLoadTask.java b/chopperbot-live/src/main/java/org/example/core/creeper/loadtask/DouyuRecordLoadTask.java
index 8c40479..7124ff1 100644
--- a/chopperbot-live/src/main/java/org/example/core/creeper/loadtask/DouyuRecordLoadTask.java
+++ b/chopperbot-live/src/main/java/org/example/core/creeper/loadtask/DouyuRecordLoadTask.java
@@ -8,6 +8,7 @@ import org.example.core.parser.impl.DouyuFlvUrlParser;
 import org.example.core.parser.impl.DouyuM3u8UrlParser;
 import org.example.log.ChopperLogFactory;
 import org.example.log.LoggerType;
+import org.example.util.ExceptionUtil;
 import org.slf4j.Logger;
 
 /**
@@ -37,7 +38,7 @@ public class DouyuRecordLoadTask extends CommonLoadTask<String> {
                     douyuRecordConfig.getVideoPath(),
                     douyuRecordConfig.getVideoName());
         }catch (Exception e){
-            logger.info("{} 录播爬取失败,error:{}",douyuRecordConfig.getVideoName(),e.getMessage());
+            logger.info("{} 录播爬取失败,error:{}",douyuRecordConfig.getVideoName(), ExceptionUtil.getCause(e));
         }
         return url;
     }
diff --git a/chopperbot-live/src/main/java/org/example/core/factory/LiveTaskFactory.java b/chopperbot-live/src/main/java/org/example/core/factory/LiveTaskFactory.java
index 44c6cf6..e993375 100644
--- a/chopperbot-live/src/main/java/org/example/core/factory/LiveTaskFactory.java
+++ b/chopperbot-live/src/main/java/org/example/core/factory/LiveTaskFactory.java
@@ -2,11 +2,13 @@ package org.example.core.factory;
 
 import org.example.core.creeper.loadconfig.BilibiliLiveOnlineConfig;
 import org.example.core.creeper.loadconfig.DouyuLiveOnlineConfig;
+import org.example.core.creeper.loadconfig.HuyaLiveOnlineConfig;
 import org.example.core.creeper.loadconfig.LoadLiveConfig;
 import org.example.core.parser.PlatformVideoUrlParser;
 import org.example.core.parser.impl.BilibiliFlvUrlParser;
 import org.example.core.component.LiveStreamTask;
 import org.example.core.parser.impl.DouyuFlvUrlParser;
+import org.example.core.parser.impl.HuyaFlvUrlParser;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -20,7 +22,8 @@ public class LiveTaskFactory {
 
     private final Map<Class<? extends LoadLiveConfig>, PlatformVideoUrlParser> parserMap = Map.of(
             BilibiliLiveOnlineConfig.class,new BilibiliFlvUrlParser(),
-            DouyuLiveOnlineConfig.class, new DouyuFlvUrlParser()
+            DouyuLiveOnlineConfig.class, new DouyuFlvUrlParser(),
+            HuyaLiveOnlineConfig.class, new HuyaFlvUrlParser()
     );
 
     public LiveTaskFactory() {
diff --git a/chopperbot-live/src/main/java/org/example/init/LiveConfigInitMachine.java b/chopperbot-live/src/main/java/org/example/init/LiveConfigInitMachine.java
index 8b6a02d..4c983e9 100644
--- a/chopperbot-live/src/main/java/org/example/init/LiveConfigInitMachine.java
+++ b/chopperbot-live/src/main/java/org/example/init/LiveConfigInitMachine.java
@@ -7,6 +7,7 @@ import org.example.constpool.PluginName;
 import org.example.plugin.CommonPlugin;
 import org.example.plugin.annotation.Plugin;
 import org.example.pool.LiveModuleConstPool;
+import org.example.util.ExceptionUtil;
 import org.example.util.FileUtil;
 
 import java.nio.file.Files;
@@ -56,7 +57,7 @@ public class LiveConfigInitMachine extends ConfigInitMachine{
                 }
             }
         }catch (Exception e){
-            return fail(e.getMessage());
+            return fail( ExceptionUtil.getCause(e));
         }
         return super.init();
     }
diff --git a/chopperbot-section/src/main/java/org/example/util/VideoUtil.java b/chopperbot-section/src/main/java/org/example/util/VideoUtil.java
index 5f6b737..7c255ab 100644
--- a/chopperbot-section/src/main/java/org/example/util/VideoUtil.java
+++ b/chopperbot-section/src/main/java/org/example/util/VideoUtil.java
@@ -299,7 +299,7 @@ public class VideoUtil {
             }
             logger.info("转码完成，视频帧:{}，音频帧:{}，数据帧:{}", videoFrameNum, audioFrameNum, dataFrameNum);
         } catch (Exception e) {
-            logger.error(e.getMessage());
+            logger.error( ExceptionUtil.getCause(e));
             return "error";
         } finally {
             if (recorder != null) {
@@ -394,7 +394,7 @@ public class VideoUtil {
                 i++;
             }
         } catch (Exception e) {
-            logger.error(e.getMessage());
+            logger.error( ExceptionUtil.getCause(e));
             return "error";
         }finally {
             if (recorder != null) {
diff --git a/chopperbot-test/src/test/java/org/example/barrage/BarrageCreeperTest.java b/chopperbot-test/src/test/java/org/example/barrage/BarrageCreeperTest.java
index 8df596b..caf19b6 100644
--- a/chopperbot-test/src/test/java/org/example/barrage/BarrageCreeperTest.java
+++ b/chopperbot-test/src/test/java/org/example/barrage/BarrageCreeperTest.java
@@ -21,7 +21,7 @@ import java.util.List;
  **/
 
 @RunWith(SpringRunner.class)
-@SpringBootTest(classes = ConsoleApplication.class)
+@SpringBootTest(classes = ConsoleApplication.class,webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
 public class BarrageCreeperTest {
 
     @Test
@@ -33,7 +33,7 @@ public class BarrageCreeperTest {
 
     @Test
     public void testHuyaBarrageCreeper(){
-        HuyaLiveBarrageLoadConfig config = new HuyaLiveBarrageLoadConfig("123","lwz6038");
+        HuyaLiveBarrageLoadConfig config = new HuyaLiveBarrageLoadConfig("123", "243547");
         try {
             List<HuyaBarrage> start = new HuyaLiveBarrageLoadTask(config).start();
         } catch (FileCacheException e) {
diff --git a/chopperbot-test/src/test/java/org/example/barrage/BarrageCurveTest.java b/chopperbot-test/src/test/java/org/example/barrage/BarrageCurveTest.java
index 920b732..dc1f033 100644
--- a/chopperbot-test/src/test/java/org/example/barrage/BarrageCurveTest.java
+++ b/chopperbot-test/src/test/java/org/example/barrage/BarrageCurveTest.java
@@ -53,29 +53,29 @@ public class BarrageCurveTest {
     @Test
     public void testCurve(){
         long l = System.currentTimeMillis();
-        List<BarragePoint> list = plugin.generateCurve(new BarrageEvent("bilibili", "online", "Asaki大人", "2023-09-19 22_00_06"));
-        System.out.println(System.currentTimeMillis()-l);
-        LineChartDemo demo = new LineChartDemo("Asaki大人",list);
-        demo.pack();
-        RefineryUtilities.centerFrameOnScreen(demo);
-        demo.setVisible(true);
-        List<PopularRange> range = popularRangePlugin.findRange(list);
-        System.out.println(range);
-        int i = 0;
-        for (PopularRange popularRange : range) {
-            long timeNaos = TimeUtil.getTimeNaos("2023-09-19 22:00:06");
-            long videoStartTime = popularRange.getStartTime()-timeNaos;
-            videoStartTime = videoStartTime<0?0:videoStartTime;
-            long videoEndTime = popularRange.getEndTime()-timeNaos;
-            System.out.println(videoStartTime+" "+videoEndTime);
-            VideoUtil.cutVideoByFFMpeg("E:\\Project\\ChopperBot\\chopperbot-test\\config\\LiveRecord\\online\\bilibili\\Asaki大人_2023-09-19 22_00_06.flv",
-                    "E:\\Project\\ChopperBot\\chopperbot-test\\config\\LiveRecord\\online\\bilibili\\Asaki大人_2023-09-19 22_00_06"+i+".flv",
-                    videoStartTime/1000,videoEndTime/1000);
-            i++;
-        }
-        while (true){
-
-        }
+//        List<BarragePoint> list = plugin.generateCurve(new BarrageEvent("bilibili", "online", "Asaki大人", "2023-09-19 22_00_06"));
+//        System.out.println(System.currentTimeMillis()-l);
+//        LineChartDemo demo = new LineChartDemo("Asaki大人",list);
+//        demo.pack();
+//        RefineryUtilities.centerFrameOnScreen(demo);
+//        demo.setVisible(true);
+//        List<PopularRange> range = popularRangePlugin.findRange(list);
+//        System.out.println(range);
+//        int i = 0;
+//        for (PopularRange popularRange : range) {
+//            long timeNaos = TimeUtil.getTimeNaos("2023-09-19 22:00:06");
+//            long videoStartTime = popularRange.getStartTime()-timeNaos;
+//            videoStartTime = videoStartTime<0?0:videoStartTime;
+//            long videoEndTime = popularRange.getEndTime()-timeNaos;
+//            System.out.println(videoStartTime+" "+videoEndTime);
+//            VideoUtil.cutVideoByFFMpeg("E:\\Project\\ChopperBot\\chopperbot-test\\config\\LiveRecord\\online\\bilibili\\Asaki大人_2023-09-19 22_00_06.flv",
+//                    "E:\\Project\\ChopperBot\\chopperbot-test\\config\\LiveRecord\\online\\bilibili\\Asaki大人_2023-09-19 22_00_06"+i+".flv",
+//                    videoStartTime/1000,videoEndTime/1000);
+//            i++;
+//        }
+//        while (true){
+//
+//        }
     }
 
     class LineChartDemo extends ApplicationFrame {
diff --git a/chopperbot-test/src/test/java/org/example/barrage/BarragePoupularRangeTest.java b/chopperbot-test/src/test/java/org/example/barrage/BarragePoupularRangeTest.java
index 1dbde10..f07be64 100644
--- a/chopperbot-test/src/test/java/org/example/barrage/BarragePoupularRangeTest.java
+++ b/chopperbot-test/src/test/java/org/example/barrage/BarragePoupularRangeTest.java
@@ -26,10 +26,10 @@ public class BarragePoupularRangeTest {
 
     @Test
     public void Test(){
-        BarrageEvent event = new BarrageEvent("douyu","online",null,null,"即将拥有人鱼线的PDD_2023-09-14 14_37_54.json");
-        List<BarragePoint> points = InitPluginRegister.getPlugin(PluginName.BARRAGE_SCORE_CURVE_PLUGIN, BarrageScoreCurvePlugin.class).generateCurve(event);
-        List<PopularRange> ranges = InitPluginRegister.getPlugin(PluginName.BARRAGE_POPULAR_RANGE_PLUGIN, BarragePopularRangePlugin.class).findRange(points);
-        System.out.println(ranges);
+//        BarrageEvent event = new BarrageEvent("douyu","online",null,null,"即将拥有人鱼线的PDD_2023-09-14 14_37_54.json");
+//        List<BarragePoint> points = InitPluginRegister.getPlugin(PluginName.BARRAGE_SCORE_CURVE_PLUGIN, BarrageScoreCurvePlugin.class).generateCurve(event);
+//        List<PopularRange> ranges = InitPluginRegister.getPlugin(PluginName.BARRAGE_POPULAR_RANGE_PLUGIN, BarragePopularRangePlugin.class).findRange(points);
+//        System.out.println(ranges);
 
     }
 }
diff --git a/config/chopperBotConfig.json b/config/chopperBotConfig.json
index 83c4806..7dce64d 100644
--- a/config/chopperBotConfig.json
+++ b/config/chopperBotConfig.json
@@ -32,5 +32,5 @@
 			"CreeperConfig":true
 		}
 	},
-	"updateTime":"2023-10-16 17:13:50"
+	"updateTime":"2023-10-17 02:15:29"
 }
\ No newline at end of file
diff --git a/database.db b/database.db
index 0940a93b417f013e93162aa02e832c97683aa706..8558b3711fe9ab32a04a3c3a5cc441016f646d61 100644
GIT binary patch
delta 883
zcmb7CPe>F|9DZ+ScHYc5Ge2#0H<fH!|75v3J1eUMK~1tjf20x(6l&Pb4K}Q`cI^;B
z(x0Q1ylz545MDZ%1K}Z>V;(wmlNAqEhl(&(vO}GEvl=8rhu-7kz4v|J@BKa=Z*rBN
zTn#>KtXV(^MYh1R_3(78`@jO~I#g1Li*_(dYmzOkq&*UU$_n|Wlu256u1pCH!I@wK
zkCe0OCv^^PY|a<c2Loq_8#o#<415<C)0wes;p$k%E@m%}+m)kj`UuiDkg^6-`k-~>
zWJ-_vbb3jpVl-E<(-Xx!U9W01%$O{l9yr!-4GiliQp4@h+-Ov{h6Ya&7q@x6?@Sca
zw<9qUX>MkFnp79JU4TuxEVVcd!M6cUhzZUY($7cL4y3ae*fy+vLS)FmD0gKvo9v|L
zpj|aD<}XYX?6KVS>@|^2DUW$=9NnXang}HKdk*>vl*TY4l|PkM=U=xN%+rIrww$Wd
zq;Z&h@Va)ZRFe~Q1a!eNyb79zogKdCu)BSf%&Pk~{jEOHPWUKkzWOy_$#Hidk4uZN
z3NPUq+;{fqH=!QNs2%$%co6BVZ40vqmSC1SXF%@aMP!B|tw^Ht`8IhkC!$^TmE-%o
zUd18>U<1J~*l=p%pMjQd@wGf3<S^zqFK_@>5PXLfroIEZ{Gg?FlU+lw20xfVWFSmk
z0_W?KaCH@oAfg!pywTPjW$vRU!$^WBXs9kE(Tp3Tt!~o$!b#`6`*d7U*%no!|H)gi
o|1)nz-Imwuzy`+<W~gJRWqC^wB3uZY@i;GY_1H}IBzk+f-{nB(ApigX

delta 501
zcmZp8z}oPDWrDQeS_TFNVIYP9i-|hM;%gc7>~He2?`IHVm15wN<JIOr$v=rddSaf`
zW<>#E79(~oCKqviea5EflEkE()Z)UNr1+B5+=6&8H{KXSKyWe}vz&mjl7a>or&4KV
ziV|mtYedN8k8I+brC84}O$^}J{Epp&g@vzxA$;P(;K{u_^H>@S*w`oQ^BPSyW0^Dg
zKC|d#K31O1a(v8;?6x4s8uL!(<1(5Y#jh~AftP#oEnYrGj>)n7vOu0VGp8v#l+8W4
zfrodKz&?IPj?Me!y$slw@}J;;z`t#?qQX>uCVr;L%j4tORx<G4;9m(8>gAU-V`67;
z78X}!c-p)9>4vsvx-9Grh9LgrjrnSvYRv2mvXUU)!+Zs9{%;IS{2v(jKk)zBENJkA
zUxt;Lk&&4h=sFe<i-m;?$YkQb#l-)S{}xciQGQN&W@kpQ$&>H&tMKjG1yS*qf&VT4
zSD=df{F`6T7Zc#-d(Xhmr_aKFoIh$a&xXf*W<Z0?Ld8Wnc@s^{4J^!3Om!_&Oigr6
w(o79?6D>@PbW_ukjZ95b%?(VGQd9CvD@z><QY$8_?l)yI2Kr!g-2O!c07LVNQ~&?~