Skip to content

Commit

Permalink
PUSH 7 (#6)
Browse files Browse the repository at this point in the history 
* PUSH 6

* PUSH 6 modify 2

* PUSH 7 modify 1

* PUSH 6

* PUSH 6 modify 2
  • Loading branch information
@MeowDWing
MeowDWing authored Aug 30, 2023
1 parent 2c5ddc8 commit 7ee0088
Show file tree
Hide file tree
Showing 5 changed files with 117 additions and 31 deletions.
60 changes: 56 additions & 4 deletions README.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,16 +7,17 @@
* **读取弹幕本直播间有粉丝牌的粉丝弹幕**


* **设置屏蔽词（完全匹配）**
* **设置屏蔽词**


* 参照b站up资深小狐狸直播时的需要设计
* 自动追赶机制：帮助你直击最新弹幕（PUSH4 发布后）
* 绝对的排外政策：可调节读取所需要的牌子等级（默认1级），只要不是自己直播间的牌子多少级都不读（PUSH4 发布后）
* 没有阀门制度：跳过弹幕时不看等级，一视同仁（PUSH5 发布后）
* 预设屏蔽词：符合狐宝直播需要，包含 。/ 赞 / ？ 和所有个位数字（PUSH5 发布后）
* 预设屏蔽词：符合狐宝直播需要，包含 。/ 赞 和所有个位数字（PUSH5 发布后）
* 当消息仅包含中英文常用符号时，拒绝加入消息队列（PUSH5发布后）
* 自动储存字符长度3以下的字符串（PUSH5发布后）
* 正则表达式匹配（PUSH7 发布后）



* 基于pyttsx3
Expand All @@ -43,9 +44,60 @@

****
**使用方法：**
* py文件
* py文件（推荐）（需要库：bilibili-api-python、pyttsx3）
* 直接运行main.py即可根据提示操作
* 由于未知bug，需要在启动后手动启动reader.py
* release
* 直接运行main.exe即可根据提示操作，如果reader没有自动打开，可以手动启动


*****
**配置说明**
* 打开main文件后，选择c.查看可以看到ban文件和settigns文件，选择即可打开文件，之后保存并关闭文件即可进一步操作


* ban_words：
* 你可以在文件后面添加词或句子以达到匹配屏蔽
* '$'(美元)符号开头的句子被认为是注释
* '-'开头的句子被认为是匹配词（注意-后不要有空格，除非你需要空格加入匹配词）


* settings
* 目前包含rid和min_level选项
* rid代表接入直播间的直播间id， minlevel表示读取弹幕所需的最小本直播间粉丝牌等级
* 由于api问题（没有牌子的直播徽章返回值是None而不是0），所以没有专门做所有人可阅读的设置，如有需要联系作者（github或b站均可）


*****
**机制说明**
* 弹幕追赶机制
* 机制保证在队列有50个以上词时，清空队列
* 机制保证在队列有40个以上词时，每5个词只读1个词，并在保持40个以上词5次读取后清理10个词
* 机制保证在队列有30个以上词时，每4个词只读1个词，并在保持30个以上词10次读取后清理10个词
* 机制保证在队列有20个以上词时，每3个词只读1个词，并在保持20个以上词15次读取后清理10个词
* 机制保证在队列有10个以上词时，每2个词只读1个词，并在保持10个以上词20次读取后清理5个词
* 机制保证在队列有5个以上词时，每3个词只读2个词。


*****
**其他说明（Q&A）**

* Q:为什么没有做重置弹幕机制？
* A:已经有弹幕追赶机制了，不用重置也会一直保持在最新弹幕（追赶机制可以完全保证在大多数时间内在读最新弹幕）


* Q:我该怎么知道这些机制都正常运行了？
* A:在reader界面，每个机制的每次运行都会发送运行消息，该界面是重要的调试界面，如果你无意调试，可以无视这个界面的输出。


* Q:为什么没有做界面？为什么需要打开两个窗口才能运行？
* A:很简单，因为作者不会，没学过。


* Q:作者怎么连这么简单的东西都不会？
* A:因为这是计算机的活，作者是做通信的，不会很正常。


* Q:我该怎么帮助狐宝或者作者？
* A:你可以访问本项目的github页面提issue或者在b站联系：吾名喵喵之翼。作者只要闲着看到就会回复你（大概会在每天的23点后）
* 仓库地址：https://github.com/MeowDWing/DanmakuReader
10 changes: 7 additions & 3 deletions initial.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,11 +26,15 @@ def _initial():
except FileNotFoundError:
print('正在初始化屏蔽词文件')
with open('ban_word.txt', mode='w', encoding='utf-8') as f:
f.write('$在该文件下写入的所有词会被屏蔽,每行只写一个词,只屏蔽完全一致的弹幕\n'
'$本文件中$（美元）符号开头的句子会被视为注释\n'
'$更改屏蔽词需要重启应用\n'
f.write('$ 在该文件下写入的所有词会被屏蔽,每行只写一个词,只屏蔽完全一致的弹幕\n'
'$ 本文件中$（美元）符号开头的句子会被视为注释\n'
'$ 更改屏蔽词需要重启应用（如果已经启动的话）'
'$ 更多操作请参看README.MD文件（可以直接以文本形式打开）\n'
'。\n'
'赞\n'
"$ '-'(减号)开头的会作为匹配词屏蔽。"
"$ 系统会屏蔽所有包含匹配词的弹幕，请谨慎选择\n"
'-红包\n'
)

try:
Expand Down
36 changes: 24 additions & 12 deletions main.py
View file
Original file line number Diff line number Diff line change
@@ -1,15 +1,23 @@
import os

import iosetting as ios
import liveget as lg
import initial


__VERSION__ = 'v1.4-demo-PUSH7'


def caseA():
file_clearer('./files')
if os.path.exists('ban_word.txt'):
os.remove('ban_word.txt')
initial.initial()

ios.print_set('执行初始化将重置所有文件，你确定要继续吗(Y/y)?', tag='WARNING', end='')
key = input("").strip().upper()
if key == 'Y':
file_clearer('./files')
if os.path.exists('ban_word.txt'):
os.remove('ban_word.txt')
initial.initial()
else:
return


def file_clearer(path):
Expand Down Expand Up @@ -48,7 +56,7 @@ def caseC():
os.system('cls')
print('|*===================================================================*|\n'
'|*| DANMAKU READER |*|\n'
'|*| main -> 查看 DEMO 1.3 |*|\n'
f'|*| main -> 查看 {__VERSION__} |*|\n'
'|*===================================================================*|\n'
'|*| |*|\n'
'|*| B(b).禁读词列表 S(s).设置文件 |*|\n'
Expand Down Expand Up @@ -77,15 +85,13 @@ def caseC():

def settings():
settings_dict = {
'API_KEY': None,
'SECRET_KEY': None,
'cuid': None,
'rid': None,
'min_level': None
'min_level': None,
}
have = set()

with open('./files/settings.txt', mode='r', encoding='utf-8') as f:
lines = f.readlines()

for line in lines:
line = line.strip().split('=')
if line[0] in settings_dict:
Expand Down Expand Up @@ -154,7 +160,7 @@ def main():
os.system('cls')
print('|*===================================================================*|\n'
'|*| DANMAKU READER |*|\n'
'|*| DEMO 1.3 |*|\n'
f'|*| {__VERSION__} |*|\n'
'|*===================================================================*|\n'
'|*| |*|\n'
'|*| A(a).初始化 B(b).启动 C(c).查看 |*|\n'
Expand All @@ -165,6 +171,12 @@ def main():
'|*===================================================================*|')
ios.print_set('Tips:如果你想直接修改文件，只需在c.查看中打开对应文件并直接修改，本程序中的所有改动会在重启后生效',
tag='CTRL')
ios.print_set('Tips:作者是搞机器学习的不会写QT不会搞协程，如果想帮助作者或者up，'
'欢迎来:https://github.com/MeowDWing/DanmakuReader'
'，或者b站私信：吾名喵喵之翼',
tag='CTRL')
ios.print_set('Tips:设置的内容还没做好，建议所有更改现在查看里看',
tag='CTRL')

print('>>>', end='')
get = input()
Expand Down
Binary file removed project_picture/testresult.png
View file
Binary file not shown.
42 changes: 30 additions & 12 deletions reader.py
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,9 @@
import os
import time
from collections import deque
import iosetting as ios
import pyttsx3
import re


class Reader:
Expand All @@ -18,6 +20,7 @@ def __init__(self):
self.force_reset_limit = 50

self.ban_word_set = set("1234567890")
self.re_ban_str = ''
self.ban_word_set_initial()
self.symbol_set = set("~!@#$%^&*()_+=-`[]\\|}{;':\",./<>?~！@#￥%……&*（）——+=-|}{【】、|‘’；：“”《》？，。、")
ios.print_set('本项目基于bilibili_api， 如有任何需要，请联系作者，与狐宝同在\n'
Expand All @@ -36,8 +39,15 @@ def ban_word_set_initial(self):
for line in lines:
line = line.strip()
if line[0] != '$':
self.ban_word_set.add(line)
if line[0] == '-':
line = line[1:]
self.re_ban_str = self.re_ban_str + line + '|'
else:
self.ban_word_set.add(line)

self.re_ban_str = self.re_ban_str[:-1]
ios.print_set(f'屏蔽词列表{str(self.ban_word_set)}', tag='UP')
ios.print_set(f"屏蔽匹配词列表{self.re_ban_str.split('|')}", tag='UP')

def reader(self):
former = ''
Expand All @@ -59,14 +69,18 @@ def reader(self):

for line in lines:
line = line.strip()
if line not in self.ban_word_set:
line_set = set(line)
if len(line_set - self.symbol_set) > 0:
self.danmaku_queue.append(line)
self.danmaku_len += 1
ios.print_set(line+':加入了待读队列', tag='SPECIAL', head='QUEUE', special_color='#50FF50')
else:
ios.print_set(f'检测到{line}中仅包含符号，拒绝加入队列')
re_flag = re.search(self.re_ban_str, line)
if re_flag is None:
if line not in self.ban_word_set:
line_set = set(line)
if len(line_set - self.symbol_set) > 0:
self.danmaku_queue.append(line)
self.danmaku_len += 1
ios.print_set(line+':加入了待读队列', tag='SPECIAL', head='QUEUE', special_color='#50FF50')
else:
ios.print_set(f'检测到{line}中仅包含符号，拒绝加入队列')
else:
ios.print_set(f'屏蔽{line}由于其中含有{re_flag.group()}')

# 追赶机制
if self.danmaku_len > self.force_reset_limit:
Expand All @@ -78,6 +92,7 @@ def reader(self):
self.popleft_n(4)
self.force_chasing_40 += 1
if self.force_chasing_40 > 5:
self.force_chasing_40 = 0
self.popleft_n(10)
ios.print_set('强制更新机制已减少10个弹幕', tag='CTRL', head='SYSTEM', prefix='CHASING')
ios.print_set('队列已大于40，自动跳过80%弹幕', tag='SYSTEM', prefix='CHASING')
Expand All @@ -86,6 +101,7 @@ def reader(self):
self.popleft_n(3)
self.force_chasing_30 += 1
if self.force_chasing_30 > 10:
self.force_chasing_30 = 0
self.popleft_n(10)
ios.print_set('强制更新机制已减少10个弹幕', tag='CTRL', head='SYSTEM', prefix='CHASING')
ios.print_set('队列已大于30，自动跳过75%弹幕', tag='SYSTEM', prefix='CHASING')
Expand All @@ -94,6 +110,7 @@ def reader(self):
self.popleft_n(2)
self.force_chasing_20 += 1
if self.force_chasing_20 > 15:
self.force_chasing_20 = 0
self.popleft_n(10)
ios.print_set('强制更新机制已减少10个弹幕', tag='CTRL', head='SYSTEM', prefix='CHASING')
ios.print_set('队列已大于20，自动跳过66%弹幕', tag='SYSTEM', prefix='CHASING')
Expand All @@ -102,13 +119,14 @@ def reader(self):
self.popleft_n(1)
self.force_chasing_10 += 1
if self.force_chasing_10 > 20:
self.force_chasing_10 = 0
self.popleft_n(5)
ios.print_set('强制更新机制已减少5个弹幕', tag='CTRL', head='SYSTEM', prefix='CHASING')
ios.print_set('队列已大于10，自动跳过50%弹幕', tag='SYSTEM', prefix='CHASING')
elif self.danmaku_len > 5 and self.tmp % 3 == 0:
self.tmp = 0
self.popleft_n(1)
ios.print_set('队列已大于10，自动跳过33%弹幕', tag='SYSTEM', prefix='CHASING')
ios.print_set('队列已大于5，自动跳过33%弹幕', tag='SYSTEM', prefix='CHASING')

# 处理与读取机制
if self.danmaku_len != 0:
Expand All @@ -121,7 +139,6 @@ def reader(self):
self.danmaku_len -= 1
former = now


else:
time.sleep(3)

Expand All @@ -140,7 +157,7 @@ class TxtProcess:
def __init__(self):
self.say_engin = pyttsx3.init()
self.say_engin.setProperty('rate', 250)
self.say_engin.setProperty('volume', 0.6)
self.say_engin.setProperty('volume', 1)
voices = self.say_engin.getProperty('voices')
self.say_engin.setProperty('voice', voices[0].id)

Expand All @@ -151,6 +168,7 @@ def txt2audio(self, message: str):


def main():
os.system('cls')
read = Reader()
read.reader()

Expand Down

0 comments on commit 7ee0088

Please sign in to comment.