1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
#!/usr/bin/env python3
# -*- encoding: utf-8 -*-
'''
@File : __init__.py
@Time : 2020/10/11 14:43:20
@Author : Kyomotoi
@Contact : [email protected]
@Github : https://github.com/Kyomotoi
@License : Copyright © 2018-2020 Kyomotoi, All Rights Reserved.
'''
__author__ = 'kyomotoi'
import os
import json
from pathlib import Path
from typing import Optional
def saveMessage(message_id: str, message: str, user: str, group: Optional[str] = None) -> None:
"""
:说明:
获取信息并进行存储。
:参数:
* ``message_id: str``: 消息id
* ``message: str``: 目标信息
* ``user: str``: 发出用户
* ``group: Optional[str] = None``: 发出群号，若不传入则归入私聊消息
:返回:
None
:用法:
.. code-block:: python
getMessage(message='test', user=123456789, group=123456789)
"""
file_group = Path('.') / 'ATRI' / 'data' / 'data_Group' / f'{group}' / 'message.json'
file_private = Path('.') / 'ATRI' / 'data' / 'data_Log' / 'message_private.json'
try:
with open(file_group, 'r') as f:
data_group = json.load(f)
except:
data_group = {}
try:
with open(file_private, 'r') as f:
data_private = json.load(f)
except:
data_private = {}
if group:
data_group[f"{message_id}"] = {"message": f"{message}", "user_id": f"{user}", "group_id": f"{group}"}
try:
with open(file_group, 'w') as f:
f.write(json.dumps(data_group))
f.close()
except:
os.mkdir(Path('.') / 'ATRI' / 'data' / 'data_Group' / f'{group}')
with open(file_group, 'w') as f:
f.write(json.dumps(data_group))
f.close()
else:
data_private[f"{message_id}"] = {"message": f"{message}", "user_id": f"{user}"}
try:
with open(file_private, 'w') as f:
f.write(json.dumps(data_private))
f.close()
except:
os.mkdir(Path('.') / 'ATRI' / 'data' / 'data_Log')
with open(file_private, 'w') as f:
f.write(json.dumps(data_private))
f.close()
def getMessage(message_id: str, group: Optional[str] = None) -> dict:
"""
:说明:
通过 message_id 获取到对应消息参数: message, user, group
:参数:
* ``message_id: str``: 目标消息id
* ``group: Optional[str] = None``: 对应群号，若不传入则获取私聊消息
:返回:
消息内容，类型为: dict
:用法:
.. code-block:: python
loadMessage(message_id=123456789)
"""
file_group = Path('.') / 'ATRI' / 'data' / 'data_Group' / f'{group}' / 'message.json'
file_private = Path('.') / 'ATRI' / 'data' / 'data_Log' / 'message_private.json'
if group:
try:
with open(file_group, 'r') as f:
data_group = json.load(f)
return data_group
except:
return {"status": "None"}
else:
try:
with open(file_private, 'r') as f:
data_private = json.load(f)
return data_private
except:
return {"status": "None"}
|
