没有任何功能性更新
This commit is contained in:
parent
1f8c154a12
commit
557a2b1ca6
32
connect.py
32
connect.py
|
@ -15,8 +15,10 @@ from mcstatus import JavaServer
|
||||||
# 功能包引用处
|
# 功能包引用处
|
||||||
from module import hitokoto
|
from module import hitokoto
|
||||||
|
|
||||||
|
|
||||||
# 功能包结束引用
|
# 功能包结束引用
|
||||||
|
|
||||||
|
# 读取配置
|
||||||
def get_config() -> Tuple[str, str, int]:
|
def get_config() -> Tuple[str, str, int]:
|
||||||
with open('config.toml', 'r', encoding='utf-8') as f:
|
with open('config.toml', 'r', encoding='utf-8') as f:
|
||||||
config = qtoml.load(f)
|
config = qtoml.load(f)
|
||||||
|
@ -182,8 +184,10 @@ def safe_eval(code: str) -> str:
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
|
||||||
|
# 获取到新的消息
|
||||||
@sio.on('addMessage')
|
@sio.on('addMessage')
|
||||||
async def add_message(data: Dict[str, Any]):
|
async def add_message(data: Dict[str, Any]):
|
||||||
|
|
||||||
print(f"{Fore.MAGENTA}add_message: {data}{Style.RESET_ALL}")
|
print(f"{Fore.MAGENTA}add_message: {data}{Style.RESET_ALL}")
|
||||||
|
|
||||||
is_self = data['message']['senderId'] == SELF_ID
|
is_self = data['message']['senderId'] == SELF_ID
|
||||||
|
@ -191,13 +195,16 @@ async def add_message(data: Dict[str, Any]):
|
||||||
sender_id = data['message']['senderId']
|
sender_id = data['message']['senderId']
|
||||||
content = data['message']['content']
|
content = data['message']['content']
|
||||||
room_id = data['roomId']
|
room_id = data['roomId']
|
||||||
|
reply = ReplyMessage(id=data['message']['_id'])
|
||||||
|
|
||||||
if not is_self:
|
if not is_self:
|
||||||
|
# /bot
|
||||||
if data.get('message').get('content') == '/bot':
|
if data.get('message').get('content') == '/bot':
|
||||||
message = Message(content='icalingua bot test',
|
message = Message(content='icalingua bot test',
|
||||||
room_id=data['roomId'])
|
room_id=data['roomId'])
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!status
|
||||||
elif content == '!!status':
|
elif content == '!!status':
|
||||||
server = JavaServer.lookup("192.168.1.6:25565")
|
server = JavaServer.lookup("192.168.1.6:25565")
|
||||||
status=server.status()
|
status=server.status()
|
||||||
|
@ -208,37 +215,42 @@ async def add_message(data: Dict[str, Any]):
|
||||||
# else:
|
# else:
|
||||||
# message = Message(content=f"此服务器空无一人",room_id=data['roomId'])
|
# message = Message(content=f"此服务器空无一人",room_id=data['roomId'])
|
||||||
|
|
||||||
message = Message(content=f"此服务器有 {status.players.online} 个玩家在线",room_id=data['roomId'])
|
message = Message(content=f"此服务器有 {status.players.online} 个玩家在线",reply_to=reply,room_id=data['roomId'])
|
||||||
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!players
|
||||||
elif content == '!!players':
|
elif content == '!!players':
|
||||||
server = JavaServer.lookup("192.168.1.6:25565")
|
server = JavaServer.lookup("192.168.1.6:25565")
|
||||||
query = server.query()
|
query = server.query()
|
||||||
players = query.players.names
|
players = query.players.names
|
||||||
message = Message(content=f"此服务器当前在线玩家有 {players}",room_id=data['roomId'])
|
message = Message(content=f"此服务器当前在线玩家有 {players}",reply_to=reply,room_id=data['roomId'])
|
||||||
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!hitokoto
|
||||||
elif content.startswith("!!hitokoto"):
|
elif content.startswith("!!hitokoto"):
|
||||||
|
|
||||||
ctypet = content[len("!!hitokoto "):]
|
ctypet = content[len("!!hitokoto "):]
|
||||||
if content == "!!hitokoto":
|
if content == "!!hitokoto":
|
||||||
result_code, result_data = hitokoto.hitokoto("没有")
|
result_code, result_data, result_type= hitokoto.hitokoto(None)
|
||||||
else:
|
else:
|
||||||
result_code, result_data = hitokoto.hitokoto(ctypet)
|
result_code, result_data, result_type= hitokoto.hitokoto(ctypet)
|
||||||
|
|
||||||
if result_code == 3:
|
if result_code == 3:
|
||||||
message = Message(content=f"参数不对哦!",room_id=data['roomId'])
|
message = Message(content=f"参数不对哦!你可以输入!!hitokoto help查看帮助",reply_to=reply,room_id=data['roomId'])
|
||||||
elif result_code == 2:
|
elif result_code == 2:
|
||||||
message = Message(content=f"发生了不可描述的错误X_X", room_id=data['roomId'])
|
message = Message(content=f"发生了不可描述的错误X_X,但可以肯定的是模块炸了(",reply_to=reply,room_id=data['roomId'])
|
||||||
|
elif result_code == 1:
|
||||||
|
message = Message(content=f"(参数)句子类型如下\na 动画\nb 漫画\nc 游戏\nd 文学\ne 原创\nf 来自网络\ng 其他\nh 影视\ni 诗词\nj 网易云\nk 哲学\nl 抖机灵",reply_to=reply,room_id=data['roomId'])
|
||||||
elif result_code == 0:
|
elif result_code == 0:
|
||||||
message = Message(content=f"Hitokoto: {result_data['hitokoto']}", room_id=data['roomId'])
|
message = Message(content=f"“{result_data['hitokoto']}”\n来源:{result_data['from']}\n类型:{result_type}",reply_to=reply,room_id=data['roomId'])
|
||||||
else:
|
else:
|
||||||
message = Message(content=f"但你看到这条消息就代表有bug出炉", room_id=data['roomId'])
|
message = Message(content=f"你看到这条消息就代表有bug出炉,但肯定不是模块炸了(",reply_to=reply,room_id=data['roomId'])
|
||||||
|
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# 未知
|
||||||
elif data.get('message').get('content').startswith('=='):
|
elif data.get('message').get('content').startswith('=='):
|
||||||
|
|
||||||
evals: str = data.get('message').get('content')[2:]
|
evals: str = data.get('message').get('content')[2:]
|
||||||
|
@ -273,16 +285,18 @@ async def add_message(data: Dict[str, Any]):
|
||||||
|
|
||||||
await asyncio.sleep(random.random() * 2)
|
await asyncio.sleep(random.random() * 2)
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
|
# !!jrrp
|
||||||
elif data['message']['content'] == '!!jrrp':
|
elif data['message']['content'] == '!!jrrp':
|
||||||
randomer = random.Random(f'{sender_id}-{data["message"]["date"]}-jrrp-v2')
|
randomer = random.Random(f'{sender_id}-{data["message"]["date"]}-jrrp-v2')
|
||||||
result = randomer.randint(0, 50) + randomer.randint(0, 50)
|
result = randomer.randint(0, 50) + randomer.randint(0, 50)
|
||||||
print(f'{sender_name} 今日人品值为 {result}')
|
print(f'{sender_name} 今日人品值为 {result}')
|
||||||
reply = ReplyMessage(id=data['message']['_id'])
|
|
||||||
message = Message(content=f'{sender_name} 今日人品值为 {result}',
|
message = Message(content=f'{sender_name} 今日人品值为 {result}',
|
||||||
reply_to=reply,
|
reply_to=reply,
|
||||||
room_id=room_id)
|
room_id=room_id)
|
||||||
await asyncio.sleep(0.5)
|
await asyncio.sleep(0.5)
|
||||||
await sio.emit('sendMessage', message.to_json())
|
await sio.emit('sendMessage', message.to_json())
|
||||||
|
|
||||||
# 如果只包括一个或多个 6
|
# 如果只包括一个或多个 6
|
||||||
# elif data['message']['content'].replace(' ', '') in ('6', '666', '六', '3+3', '5+1', '4+2', '2+4', '1+5'):
|
# elif data['message']['content'].replace(' ', '') in ('6', '666', '六', '3+3', '5+1', '4+2', '2+4', '1+5'):
|
||||||
# reply = ReplyMessage(id=data['message']['_id'])
|
# reply = ReplyMessage(id=data['message']['_id'])
|
||||||
|
|
|
@ -1,8 +1,10 @@
|
||||||
import requests
|
import requests
|
||||||
import random
|
import random
|
||||||
|
|
||||||
|
|
||||||
def hitokoto(ctypet):
|
def hitokoto(ctypet):
|
||||||
|
|
||||||
|
result_type = None
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
|
||||||
if ctypet == '动画' or ctypet == 'a':
|
if ctypet == '动画' or ctypet == 'a':
|
||||||
|
@ -15,7 +17,7 @@ def hitokoto(ctypet):
|
||||||
ctype = 'd'
|
ctype = 'd'
|
||||||
elif ctypet == '原创' or ctypet == 'e':
|
elif ctypet == '原创' or ctypet == 'e':
|
||||||
ctype = 'e'
|
ctype = 'e'
|
||||||
elif ctypet == '网络' or ctypet == 'f':
|
elif ctypet == '来自网络' or ctypet == 'f':
|
||||||
ctype = 'f'
|
ctype = 'f'
|
||||||
elif ctypet == '其他' or ctypet == 'g':
|
elif ctypet == '其他' or ctypet == 'g':
|
||||||
ctype = 'g'
|
ctype = 'g'
|
||||||
|
@ -29,24 +31,48 @@ def hitokoto(ctypet):
|
||||||
ctype = 'k'
|
ctype = 'k'
|
||||||
elif ctypet == '抖机灵' or ctypet == 'l':
|
elif ctypet == '抖机灵' or ctypet == 'l':
|
||||||
ctype = 'l'
|
ctype = 'l'
|
||||||
|
elif ctypet == None:
|
||||||
elif ctypet == '没有':
|
|
||||||
ctype = random.choice('abcdefghijkl')
|
ctype = random.choice('abcdefghijkl')
|
||||||
params_value = {'c': ctype}
|
elif ctypet == 'help':
|
||||||
hitokoto = requests.get('https://v1.hitokoto.cn', params=params_value)
|
return 1, None, result_type
|
||||||
|
|
||||||
return 0, hitokoto.json()
|
|
||||||
else:
|
else:
|
||||||
return 3, None
|
return 3, None, result_type
|
||||||
|
|
||||||
params_value = {'c': ctype}
|
params_value = {'c': ctype}
|
||||||
hitokoto = requests.get('https://v1.hitokoto.cn', params=params_value)
|
hitokoto = requests.get('https://v1.hitokoto.cn', params=params_value)
|
||||||
|
|
||||||
return 0, hitokoto.json()
|
htype=hitokoto.json()['type']
|
||||||
|
if htype=='a':
|
||||||
|
result_type = '动画'
|
||||||
|
elif htype=='b':
|
||||||
|
result_type = '动漫'
|
||||||
|
elif htype=='c':
|
||||||
|
result_type = '游戏'
|
||||||
|
elif htype=='d':
|
||||||
|
result_type = '文学'
|
||||||
|
elif htype=='e':
|
||||||
|
result_type = '原创'
|
||||||
|
elif htype=='f':
|
||||||
|
result_type = '来自网络'
|
||||||
|
elif htype=='g':
|
||||||
|
result_type = '其他'
|
||||||
|
elif htype=='h':
|
||||||
|
result_type = '影视'
|
||||||
|
elif htype=='i':
|
||||||
|
result_type = '诗词'
|
||||||
|
elif htype=='j':
|
||||||
|
result_type = '网易云'
|
||||||
|
elif htype=='k':
|
||||||
|
result_type = '哲学'
|
||||||
|
elif htype=='l':
|
||||||
|
result_type = '抖机灵'
|
||||||
|
else:
|
||||||
|
result_type = '无法获取'
|
||||||
|
|
||||||
|
return 0, hitokoto.json(), result_type
|
||||||
|
|
||||||
except IOError:
|
except IOError:
|
||||||
return 2, None
|
return 2, None, result_type
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user