185 lines
7.2 KiB
Python
185 lines
7.2 KiB
Python
|
# -*- coding: utf-8 -*-
|
|||
|
|
"""
|
|||
|
|
cron: 0 8 * * *
|
|||
|
|
new Env('网易音乐合伙人');
|
|||
|
|
"""
|
|||
|
|
import requests
|
|||
|
|
import base64
|
|||
|
|
import codecs
|
|||
|
|
import execjs
|
|||
|
|
import json
|
|||
|
|
|
|||
|
|
from Crypto.Cipher import AES
|
|||
|
|
from notify import send
|
|||
|
|
|
|||
|
|
|
|||
|
|
def to_16(key):
|
|||
|
|
while len(key) % 16 != 0:
|
|||
|
|
key += '\0'
|
|||
|
|
return str.encode(key)
|
|||
|
|
|
|||
|
|
|
|||
|
|
def aes_encrypt(text, key, iv):
|
|||
|
|
bs = AES.block_size
|
|||
|
|
pad2 = lambda s: s + (bs - len(s) % bs) * chr(bs - len(s) % bs)
|
|||
|
|
encryptor = AES.new(to_16(key), AES.MODE_CBC, to_16(iv))
|
|||
|
|
encrypt_aes = encryptor.encrypt(str.encode(pad2(text)))
|
|||
|
|
encrypt_text = str(base64.encodebytes(encrypt_aes), encoding='utf-8')
|
|||
|
|
return encrypt_text
|
|||
|
|
|
|||
|
|
|
|||
|
|
def rsa_encrypt(text, pubKey, modulus):
|
|||
|
|
text = text[::-1]
|
|||
|
|
rs = int(codecs.encode(text.encode('utf-8'), 'hex_codec'), 16) ** int(pubKey, 16) % int(modulus, 16)
|
|||
|
|
return format(rs, 'x').zfill(256)
|
|||
|
|
|
|||
|
|
|
|||
|
|
# 获取i值的函数，即随机生成长度为16的字符串
|
|||
|
|
get_i = execjs.compile(r"""
|
|||
|
|
function a(a) {
|
|||
|
|
var d, e, b = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", c = "";
|
|||
|
|
for (d = 0; a > d; d += 1)
|
|||
|
|
e = Math.random() * b.length,
|
|||
|
|
e = Math.floor(e),
|
|||
|
|
c += b.charAt(e);
|
|||
|
|
return c
|
|||
|
|
}
|
|||
|
|
""")
|
|||
|
|
|
|||
|
|
|
|||
|
|
class Copartner():
|
|||
|
|
name = "音乐合伙人"
|
|||
|
|
|
|||
|
|
def __init__(self, check_item):
|
|||
|
|
self.csrf = None
|
|||
|
|
self.musicDataUrl = "http://interface.music.163.com/api/music/partner/daily/task/get"
|
|||
|
|
self.userInfoUrl = "https://music.163.com/api/nuser/account/get"
|
|||
|
|
self.signUrl = "https://interface.music.163.com/weapi/music/partner/work/evaluate?csrf_token="
|
|||
|
|
self.g = '0CoJUm6Qyw8W8jud' # buU9L(["爱心", "女孩", "惊恐", "大笑"])的值
|
|||
|
|
self.b = "010001" # buU9L(["流泪", "强"])的值
|
|||
|
|
# buU9L(Rg4k.md)的值
|
|||
|
|
self.c = '00e0b509f6259df8642dbc35662901477df22677ec152b5ff68ace615bb7b725152b3ab17a876aea8a5aa76d2e417629ec4ee341f56135fccf695280104e0312ecbda92557c93870114af6c9d05c4f7f0c3685b7a46bee255932575cce10b424d813cfe4875d3e82047b97ddef52741d546b8e289dc6935b3ece0462db0a22b8e7'
|
|||
|
|
self.i = get_i.call('a', 16) # 随机生成长度为16的字符串
|
|||
|
|
self.iv = "0102030405060708" # 偏移量
|
|||
|
|
self.headers = {
|
|||
|
|
"Accept": "application/json, text/javascript",
|
|||
|
|
"Accept-Encoding": "gzip, deflate",
|
|||
|
|
"Accept-Language": "zh-CN,zh-Hans;q=0.9",
|
|||
|
|
"Content-Type": "application/x-www-form-urlencoded",
|
|||
|
|
"Origin": "http://mp.music.163.com",
|
|||
|
|
"User-Agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 15_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 CloudMusic/0.1.1 NeteaseMusic/8.8.01"
|
|||
|
|
}
|
|||
|
|
self.musicTags = "3-A-1"
|
|||
|
|
self.musicScore = "3"
|
|||
|
|
self.check_item = check_item
|
|||
|
|
|
|||
|
|
def get_enc_sec_key(self):
|
|||
|
|
return rsa_encrypt(self.i, self.b, self.c)
|
|||
|
|
|
|||
|
|
def get_params(self, data):
|
|||
|
|
enc_text = str(data)
|
|||
|
|
return aes_encrypt(aes_encrypt(enc_text, self.g, self.iv), self.i, self.iv)
|
|||
|
|
|
|||
|
|
def sign(self, session, music_data, msg):
|
|||
|
|
works = music_data['works']
|
|||
|
|
task_id = music_data['id']
|
|||
|
|
begin = False
|
|||
|
|
for work in works:
|
|||
|
|
_work = work['work']
|
|||
|
|
if work['completed']:
|
|||
|
|
msg.append({
|
|||
|
|
"name": f"{_work['name']}（{_work['authorName']}）",
|
|||
|
|
"value": f"评分完成：{work['score']}分"
|
|||
|
|
})
|
|||
|
|
else:
|
|||
|
|
if not begin:
|
|||
|
|
msg.append({"name": "本次进度", "value": ""})
|
|||
|
|
begin = True
|
|||
|
|
data = {
|
|||
|
|
"params": self.get_params({
|
|||
|
|
"taskId": task_id,
|
|||
|
|
"workId": _work['id'],
|
|||
|
|
"score": self.musicScore,
|
|||
|
|
"tags": self.musicTags,
|
|||
|
|
"customTags": "%5B%5D",
|
|||
|
|
"comment": "",
|
|||
|
|
"syncYunCircle": "true",
|
|||
|
|
"csrf_token": self.csrf
|
|||
|
|
}).replace("\n", ""),
|
|||
|
|
"encSecKey": self.get_enc_sec_key()
|
|||
|
|
}
|
|||
|
|
try:
|
|||
|
|
response = session.post(
|
|||
|
|
url=f"{self.signUrl}={self.csrf}",
|
|||
|
|
data=data, headers=self.headers).json()
|
|||
|
|
if response["code"] == 200:
|
|||
|
|
msg.append({
|
|||
|
|
"name": f"{_work['name']}（{_work['authorName']}）",
|
|||
|
|
"value": f"评分完成：{self.musicScore}分"
|
|||
|
|
})
|
|||
|
|
except Exception as e:
|
|||
|
|
print(f"歌曲 {_work['name']} 评分异常,原因{str(e)}")
|
|||
|
|
|
|||
|
|
def valid(self, session):
|
|||
|
|
try:
|
|||
|
|
content = session.get(url=self.musicDataUrl,
|
|||
|
|
headers={**self.headers, "Referer": "https://mp.music.163.com/"})
|
|||
|
|
except Exception as e:
|
|||
|
|
return False, f"登录验证异常,错误信息: {e}"
|
|||
|
|
data = content.json()
|
|||
|
|
if data["code"] == 301:
|
|||
|
|
return False, data["message"]
|
|||
|
|
if data["code"] == 200:
|
|||
|
|
music_data = data["data"]
|
|||
|
|
user_name = self.login_info(session=session)["profile"]["nickname"]
|
|||
|
|
return music_data, user_name
|
|||
|
|
return False, "登录信息异常"
|
|||
|
|
|
|||
|
|
def login_info(self, session):
|
|||
|
|
try:
|
|||
|
|
return session.get(url=self.userInfoUrl, headers=self.headers).json()
|
|||
|
|
except Exception as e:
|
|||
|
|
print(e)
|
|||
|
|
return {
|
|||
|
|
"profile": {
|
|||
|
|
"nickname": "获取用户信息异常"
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
def main(self):
|
|||
|
|
session = requests.session()
|
|||
|
|
cookie = self.check_item.get("cookie")
|
|||
|
|
music_cookie = {item.split("=")[0]: item.split("=")[1] for item in cookie.split("; ")}
|
|||
|
|
self.csrf = music_cookie['__csrf']
|
|||
|
|
requests.utils.add_dict_to_cookiejar(session.cookies, music_cookie)
|
|||
|
|
music_data, user_name = self.valid(session)
|
|||
|
|
if music_data:
|
|||
|
|
completed = music_data['completed']
|
|||
|
|
msg = [
|
|||
|
|
{"name": "帐号信息", "value": f"{user_name}"},
|
|||
|
|
{"name": "当前进度", "value": ""},
|
|||
|
|
{"name": "今日完成状态", "value": f"{'已完成' if completed else '未完成'}"},
|
|||
|
|
{"name": "当前获得积分", "value": music_data['integral']},
|
|||
|
|
{"name": "已完成评定数", "value": music_data["completedCount"]},
|
|||
|
|
]
|
|||
|
|
if not completed:
|
|||
|
|
self.sign(session, music_data, msg)
|
|||
|
|
else:
|
|||
|
|
msg = [
|
|||
|
|
{"name": "帐号信息", "value": user_name},
|
|||
|
|
{"name": "cookie信息", "value": "Cookie 可能过期"},
|
|||
|
|
]
|
|||
|
|
msg = "\n".join([f"{one.get('name')}: {one.get('value')}" for one in msg])
|
|||
|
|
return msg
|
|||
|
|
|
|||
|
|
|
|||
|
|
if __name__ == "__main__":
|
|||
|
|
with open("/ql/config/netease_music_cookie.json", "r", encoding="utf-8") as f:
|
|||
|
|
all_data = json.loads(f.read())
|
|||
|
|
_check_item = all_data.get("MUSIC_COPARTNER", [])
|
|||
|
|
res = ""
|
|||
|
|
for index, item in enumerate(_check_item):
|
|||
|
|
res = f'{res}账号{index + 1}：\n{Copartner(item).main()}\n'
|
|||
|
|
print(res)
|
|||
|
|
send('网易音乐合伙人', res)
|