JavaWeb/biliob
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
Yutousama 2022-04-11 12:49:15 +08:00
parent 5c7b864259
commit 4e3810b256
2 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/yutou/bilibili/BiliBili/Controllers/BiliVideoController.java
View File

@ -49,6 +49,7 @@ public class BiliVideoController {
} }
if (ServiceTools.getInstance().auth(request, user.getUser(), "/bili/video/get/")) { if (ServiceTools.getInstance().auth(request, user.getUser(), "/bili/video/get/")) {
File file = new File(ConfigTools.load(ConfigTools.CONFIG,"liveSavePath",String.class)+File.separator+"live"); File file = new File(ConfigTools.load(ConfigTools.CONFIG,"liveSavePath",String.class)+File.separator+"live");
Log.i(file.getAbsolutePath());
if (!file.exists() || Objects.requireNonNull(file.listFiles()).length == 0) { if (!file.exists() || Objects.requireNonNull(file.listFiles()).length == 0) {
json.put("code", 0); json.put("code", 0);
json.put("msg", "文件夹为空"); json.put("msg", "文件夹为空");
@ -109,6 +110,7 @@ public class BiliVideoController {
if (!file.exists()) { if (!file.exists()) {
file = new File(ConfigTools.load(ConfigTools.CONFIG,"liveSavePath",String.class)+File.separator+"live" + File.separator + time + File.separator + fileName); file = new File(ConfigTools.load(ConfigTools.CONFIG,"liveSavePath",String.class)+File.separator+"live" + File.separator + time + File.separator + fileName);
} }
Log.i(file.getAbsolutePath());
com.yutou.bilibili.Tools.Log.i(file.getAbsolutePath()); com.yutou.bilibili.Tools.Log.i(file.getAbsolutePath());
return AppTools.getFile(file); return AppTools.getFile(file);
} }

26
src/main/java/com/yutou/bilibili/QQBot/QQBotManager.java
View File

@ -9,14 +9,20 @@ import com.yutou.bilibili.BilibiliApplication;
import com.yutou.bilibili.Tools.*; import com.yutou.bilibili.Tools.*;
import com.yutou.bilibili.interfaces.DownloadInterface; import com.yutou.bilibili.interfaces.DownloadInterface;
import com.yutou.bilibili.mybatis.Bili.mybatis.model.BilibiliUpInfo; import com.yutou.bilibili.mybatis.Bili.mybatis.model.BilibiliUpInfo;
import kotlin.coroutines.CoroutineContext;
import net.mamoe.mirai.Bot; import net.mamoe.mirai.Bot;
import net.mamoe.mirai.BotFactory; import net.mamoe.mirai.BotFactory;
import net.mamoe.mirai.event.EventHandler;
import net.mamoe.mirai.event.GlobalEventChannel; import net.mamoe.mirai.event.GlobalEventChannel;
import net.mamoe.mirai.event.ListeningStatus;
import net.mamoe.mirai.event.SimpleListenerHost;
import net.mamoe.mirai.event.events.GroupMessageEvent; import net.mamoe.mirai.event.events.GroupMessageEvent;
import net.mamoe.mirai.event.events.MessageEvent;
import net.mamoe.mirai.message.data.Image; import net.mamoe.mirai.message.data.Image;
import net.mamoe.mirai.message.data.MessageChainBuilder; import net.mamoe.mirai.message.data.MessageChainBuilder;
import net.mamoe.mirai.utils.BotConfiguration; import net.mamoe.mirai.utils.BotConfiguration;
import net.mamoe.mirai.utils.ExternalResource; import net.mamoe.mirai.utils.ExternalResource;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware; import org.springframework.context.ApplicationContextAware;
@ -99,7 +105,7 @@ public class QQBotManager implements ApplicationContextAware {
} }
}); });
//Events.registerEvents(bot, new MessageListener()); //Events.registerEvents(bot, new MessageListener());
GlobalEventChannel.INSTANCE.subscribeAlways(GroupMessageEvent.class, new MessageListener()); GlobalEventChannel.INSTANCE.registerListenerHost(new MessageListener());
Log.i("准备登陆"); Log.i("准备登陆");
bot.login(); bot.login();
Log.i("登陆成功"); Log.i("登陆成功");
@ -231,18 +237,17 @@ public class QQBotManager implements ApplicationContextAware {
getInstance(); getInstance();
} }
private static class MessageListener implements Consumer<GroupMessageEvent> { private static class MessageListener extends SimpleListenerHost {
@Override @Override
public void accept(GroupMessageEvent event) { public void handleException(@NotNull CoroutineContext context, @NotNull Throwable exception) {
String msg = event.getMessage().contentToString(); // super.handleException(context, exception);
if (qqGroup == event.getGroup().getId()) { exception.printStackTrace();
myGroup(msg);
}
} }
private void myGroup(String message) {
@EventHandler
public ListeningStatus onMessage(MessageEvent event) {
String message=event.getMessage().contentToString();
String msg = message.replace("！", "!").toLowerCase(); String msg = message.replace("！", "!").toLowerCase();
msg=msg.trim(); msg=msg.trim();
StringBuilder builder = new StringBuilder(); StringBuilder builder = new StringBuilder();
@ -368,6 +373,7 @@ public class QQBotManager implements ApplicationContextAware {
Log.i("未知指令:"+msg); Log.i("未知指令:"+msg);
} }
} }
return ListeningStatus.LISTENING; // 表示继续监听事件
} }
public void sendGiftData(int roomId, Date startTime, Date endTime) { public void sendGiftData(int roomId, Date startTime, Date endTime) {