-
Notifications
You must be signed in to change notification settings - Fork 0
/
AnyPod.py
407 lines (361 loc) · 16.9 KB
/
AnyPod.py
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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
import string
import os
import sys
import time
import requests
import tkinter as tk
import tkinter.ttk as ttk
import tkinter.filedialog as filebox
import tkinter.messagebox as msgbox
import win32.win32api as win32api
import win32.lib.win32con as win32con
import time
from PIL import ImageTk,Image
import pystray
import threading
import hashlib
import eyed3
from eyed3.id3.frames import ImageFrame
import datetime
#杂项准备工作
#屏幕尺寸
scr_w=win32api.GetSystemMetrics(win32con.SM_CXSCREEN)
scr_h=win32api.GetSystemMetrics(win32con.SM_CYSCREEN)
#定义一个全局变量，表示程序是否计划继续运行，若为“否”，则表示程序即将（3秒后）退出
running=True
def loginui(event=''):
global up,e_usr,e_pwd,e_api
up = tk.Tk()
up.title("登录")
#第一行，用户名标签及输入框
tk.Label(up,text='邮箱').pack(fill=tk.X)
e_usr = ttk.Entry(up)
e_usr.pack(fill=tk.X)
tk.Label(up,text='密码').pack(fill=tk.X)
e_pwd = ttk.Entry(up,show='●')
e_pwd.pack(fill=tk.X)
tk.Label(up,text='API域名').pack(fill=tk.X)
e_api = ttk.Entry(up)
e_api.pack(fill=tk.X)
e_api.insert(0,"cloudmusic-api.txm.world")
#第三行登陆按扭，command绑定事件
tk.Label(up,text='您的密码将会以MD5存储于软件目录下，\nMD5编码是不可解码的\n作者保证不会窃取您的密码，登录即表示您信任我',fg='grey').pack(side=tk.BOTTOM,fill=tk.X)
ttk.Button(up,text='登录并存储',command=login).pack(side=tk.BOTTOM,fill=tk.X)
e_usr.bind('<KeyPress-Return>',lambda event:e_pwd.focus())
e_pwd.bind('<KeyPress-Return>',lambda event:login())
e_usr.focus()
up.update()
up.geometry('350x'+str(int(up.winfo_height())))
up.resizable(0,0)
up.mainloop()
def login():
global usr,pwd,api#,path
usr=e_usr.get()
pwd=e_pwd.get()
api=e_api.get()
pwd=hashlib.md5(pwd.encode(encoding='UTF-8')).hexdigest()
f=open("./usr.dat",'w',encoding='utf-8')
f.write(usr+'\n'+pwd+'\n'+api)
#path=filebox.askdirectory(title='请选择音乐保存路径')
up.destroy()
def rpg(a,b,c):
global pwin,pga,pgb,pgc
pga['text']=str(a)
pgb['text']=str(b)
pgc['value']=int(c)
pwin.update()
def rename():
global filename,e_name,rwin
filename=e_name.get()
rwin.destroy()
#toaster.show_toast('程序仍在工作','请勿惊慌，程序仍在后台工作！',threaded=True)
def favdown(path,test=False):
global usr,pwd,pga,pgb,pgc,pwin,filename,e_name,rwin,running
if not bool(os.path.exists(path)):
os.makedirs(path)
try:
pwin.overrideredirect(True)
pwin.attributes('-topmost',True)
#imagine_this_is_an(error)#取消注释这行代码可以直接跳进异常处理部分来测试异常处理是否出问题
rpg('准备下载','获取登录Cookie',0)
res=requests.get(url="https://"+api+"/login?email="+usr+"&md5_password="+pwd)
json=res.json()
cookie=json['cookie']
#过渡动画
for i in range(1,12+1):
pgc['value']+=2
pwin.update()
time.sleep(0.01)
rpg('准备下载','获取用户ID',25)
res=requests.get(url="https://"+api+"/user/account?cookie="+str(cookie))
json=res.json()
uid=str(json['account']['id'])
#过渡动画
for i in range(1,12+1):
pgc['value']+=2
pwin.update()
time.sleep(0.01)
rpg('准备下载','获取收藏歌单ID',50)
res=requests.get(url="https://"+api+"/user/playlist?limit=1&uid="+uid)
json=res.json()
favlstid=str(json['playlist'][0]['id'])
#过渡动画
for i in range(1,12+1):
pgc['value']+=2
pwin.update()
time.sleep(0.01)
rpg('准备下载','获取收藏歌单',75)
res=requests.get(url="https://"+api+"/playlist/track/all?id="+favlstid+"&cookie="+cookie)
json=res.json()
#过渡动画
for i in range(1,12+1):
pgc['value']+=2
pwin.update()
time.sleep(0.01)
favlst=[]#id
favnamelst=[]#歌名
favarlst=[]#艺人
favallst=[]#专辑
rpg('准备下载','整理信息',100)
#收藏音乐信息挨个存列表
for song in json['songs']:
favlst.append(str(song['id']))
favnamelst.append(str(song['name']))
favallst.append(str(song['al']['name']))
favarlst.append([])
for ar in song['ar']:
favarlst[json['songs'].index(song)].append(ar['name'])
flst=[]#Fail List，用于存储失败的歌曲
done=True#多数情况指是否完成，实际表示退出循环的原因，“是”则为全部完成后退出循环，“否”则为主程序退出导致退出循环，将影响循环退出后是否提示下载完成
for mid in favlst:
print(running)
if not running:
done=False
break
rpg('正在下载（'+str(favlst.index(mid)+1)+'/'+str(len(favlst))+'）',favnamelst[favlst.index(mid)],(favlst.index(mid)/len(favlst))*100)
if not os.path.exists(path+'/'+favnamelst[favlst.index(mid)]+".mp3"):#避免重复下载
try:#遇到问题跳过而不中断
res=requests.get(url="https://"+api+"/song/url?id="+mid+"&br=320000"+'&cookie='+cookie)
json=res.json()
murl=json['data'][0]['url']
if murl==None:
pga['text']='无版权 将跳过'
icon.notify('无版权，将跳过 '+favnamelst[favlst.index(mid)],title='可接受的错误')
pwin.update()
time.sleep(5)
pwin.update()
else:
if 'freeTrialInfo' in list(json['data'][0].keys()):
if json['data'][0]['freeTrialInfo']!=None:
freesec=json['data'][0]['freeTrialInfo']['end']-json['data'][0]['freeTrialInfo']['start']
pga['text']='试听 将跳过'
icon.notify(favnamelst[favlst.index(mid)]+' 仅可试听 '+str(freesec)+' 秒，将跳过',title='可接受的错误')
pwin.update()
time.sleep(5)
pwin.update()
continue
filename=favnamelst[favlst.index(mid)]
if ('*' in favnamelst[favlst.index(mid)] or '/' in favnamelst[favlst.index(mid)] or '\\' in favnamelst[favlst.index(mid)] or ':' in favnamelst[favlst.index(mid)] or '"' in favnamelst[favlst.index(mid)] or \
'?' in favnamelst[favlst.index(mid)] or '|' in favnamelst[favlst.index(mid)]) and not test:#防止歌曲名称带非法字符导致下载失败
dorename=msgbox.askyesno('网易云收藏音乐下载','歌曲 '+favnamelst[favlst.index(mid)]+' 无法按照原名保存，您需要重命名吗？')
if dorename:
rwin = tk.Tk()
rwin.title("重命名音乐")
tk.Label(rwin,text='旧名称：'+favnamelst[favlst.index(mid)]+'.mp3').pack(fill=tk.X)
ef=tk.Frame(rwin)
tk.Label(ef,text='新名称：').pack(fill=tk.X,side=tk.LEFT)
e_name = ttk.Entry(ef)
tk.Label(ef,text='.mp3').pack(fill=tk.X,side=tk.RIGHT)
e_name.pack(fill=tk.X)
ef.pack(fill=tk.X)
ttk.Button(rwin,text='以该名称保存',command=rename).pack(fill=tk.X,expand=True)
e_name.bind('<KeyPress-Return>',lambda event:rename())
e_name.focus()
rwin.update()
if rwin.winfo_width()<=350:
rwin.geometry('350x'+str(int(rwin.winfo_height())))
else:
rwin.geometry(str(int(rwin.winfo_width()))+'x'+str(int(rwin.winfo_height())))
rwin.resizable(0,0)
while True:
try:#别无选择，只能通过在无法成功刷新的时候break出循环来实现效果
rwin.update()
except:
break
#print('重命名操作完成 '+favnamelst[favlst.index(mid)])
if test:
filename='TEST'
res=requests.get(url=murl)
m=res.content
#print('正在下载 '+favnamelst[favlst.index(mid)]+' 至目录 '+path+filename+".mp3")
f=open(path+filename+".mp3",'wb')
f.write(m)
f.close()
#编辑信息
try:
infres=requests.get(url="https://cloudmusic-api.txm.world/song/detail?ids="+mid)
infjson=infres.json()
inf=infjson['songs'][0]
ars=''
for i in inf['ar']:
ars+=i['name']+';'
ars=ars[0:len(ars)-1]
if inf['publishTime']!=0:#如果年份未知，则API返回0，程序会将年份误标为1970，故加上判断
pubyear=datetime.datetime.fromtimestamp(inf['publishTime']/1000.0).strftime('%Y')
else:
pubyear=''
res=requests.get(inf['al']['picUrl'])
img=res.content
audiofile = eyed3.load(path+filename+".mp3")
audiofile.initTag()
audiofile.tag.title = inf['name']
audiofile.tag.artist = ars
audiofile.tag.album = inf['al']['name']
audiofile.tag.images.set(ImageFrame.FRONT_COVER, img, 'image/jpeg')
audiofile.tag.recording_date = str(pubyear) # 年份
audiofile.tag.save(version=eyed3.id3.ID3_V2_3)
except Exception as e:
pga['text']='歌曲信息未填入'
print(str(e))
pwin.update()
time.sleep(5)
pwin.update()
except Exception as e:
#toaster.show_toast('可接受的错误','下载 '+favnamelst[favlst.index(mid)]+' 时遇到错误，将跳过本音乐\n\n'+str(e),duration=10)
print(str(e))
pga['text']='下载错误 将跳过'
pwin.update()
time.sleep(5)
pwin.update()
flst.append(mid)
if done:
pga['text']='下载完成！'
pgb['text']='恭喜！全部音乐下载完成！'
icon.notify('恭喜！全部音乐下载完成！\n\n成功 '+str(len(favlst)-len(flst))+' 首\n失败 '+str(len(flst))+' 首',title='下载完成！')
pwin.update()
except Exception as e:
icon.notify('无法同步到路径 '+path+'\n\n错误：\n'+str(e),title='同步失败')
try:
pwin.configure(background='#FF9090')
pga['bg']='#FF9090'
pgb['bg']='#FF9090'
pwin.attributes('-alpha',1)
pga['text']='错误'
pgb['text']=json['message']
#pframe.add_info((4,2),info_text=pga['text']+'：'+pgb['text'])
print(str(e))
except:
pwin.configure(background='#FF9090')
pga['bg']='#FF9090'
pgb['bg']='#FF9090'
pwin.attributes('-alpha',1)
pga['text']='本地错误'
pgb['text']=str(e)
#pframe.add_info((4,2),info_text=pga['text']+'：'+pgb['text'])
print(str(e))
def get_disklist():#获取所有盘符（暴力警告
disk_list = []
for c in string.ascii_uppercase:
disk = c + ':'
if os.path.isdir(disk):
disk_list.append(disk)
return disk_list
def change_icon(icona,item):
icon.notify('抱歉，但是本功能尚不可用',title='尚不可用')
def show_window():#显示/隐藏进度窗
global show
if not show:
pwin.deiconify()
for i in range(1,27+1):
pwin.geometry('250x68'+'+'+str(int(scr_w-250))+'+'+str(int(scr_h-(108-28*4+i*4))))
time.sleep(0.005)
pwin.update()
pwin.geometry('250x68+'+str(int(scr_w-250))+'+'+str(int(scr_h-108)))
pwin.update()
show=True
else:
for i in range(1,27+1):
pwin.geometry('250x68'+'+'+str(int(scr_w-250))+'+'+str(int(scr_h-(108-i*4))))
time.sleep(0.005)
pwin.update()
pwin.withdraw()
pwin.update()
show=False
def sync():#同步函数
lastdsks=[]
while True:
if not running:
break
dsks=get_disklist()
for dsk in dsks:
if dsk not in lastdsks:#这意味着这是一个新插入的磁盘
if os.path.isfile(dsk+'/anypod.cfg'):#如果这里有配置文件，说明这是AnyPod设备
icon.notify(dsk+'是AnyPod设备，将开始同步',title=dsk+'是AnyPod设备')
f=open(dsk+'/anypod.cfg','r',encoding='utf-8')
dirstr=f.read()
f.close()
dirs=dirstr.split('\n')
if '' in dirs:
dirs.remove('')#去除空行，避免出错
for i in dirs:
i.replace('\\','/')#反斜杠换正斜杠
if i[len(i)-1]!='/':#给目录结尾加上斜杠
i+='/'
favdown(dsk+i)
lastdsks=dsks
time.sleep(0.5)
def test_down_to():
path=filebox.askdirectory(title='选择测试路径')
path.replace('\\','/')#反斜杠换正斜杠
if path[len(path)-1]!='/':#给目录结尾加上斜杠
path+='/'
downtot=threading.Thread(target=lambda:favdown(path))
downtot.start()
def close():#Pyinstaller打包的EXE无法调用exit()
global icon,pwin,running
running=False
time.sleep(3)
pwin.destroy()
os._exit(0)
if os.path.exists("./usr.dat"):
f=open("./usr.dat",'r',encoding='utf-8')
try:
data=f.read().split('\n')
usr=data[0]
pwd=data[1]
api=data[2]
except:
msgbox.showerror('错误','账户数据文件格式错误，请删除配置文件（usr.dat）后重启软件重新登录。')
os._exit(0)
else:
loginui()
pwin=tk.Tk()
pwin.title('网易云收藏音乐下载')
pwin.overrideredirect(True)
pga=tk.Label(pwin,text='进度A未显示')
pga.pack(fill=tk.X)
pgb=tk.Label(pwin,text='进度B未显示')
pgb.pack(fill=tk.X)
pgc=ttk.Progressbar(pwin,length=250,value=0)
pgc.pack(fill=tk.X)
show=False
pwin.withdraw()
testt=threading.Thread(target=lambda:favdown("./",test=True))
#托盘
use_color_icon=False
menu = (pystray.MenuItem('显示进度',show_window,default=True),
pystray.MenuItem('退出',close),
pystray.MenuItem('添加新设备',lambda:os.system('start newdevice.py')),
pystray.MenuItem('调试选项',pystray.Menu(
pystray.MenuItem('下载全部音乐并覆盖至TEST.MP3',testt.start),
pystray.MenuItem('下载至指定位置（即使未插入任何设备）',test_down_to),
pystray.MenuItem('注：此处的任何操作都不会影响主同步线程',lambda:msgbox.showinfo('所以','你点我做什么？'),enabled=False)
))
)
iconimg = Image.open("icon.png")
icon = pystray.Icon("AnyPod",iconimg,"AnyPod",menu)
icon.run_detached()
#lastdsks=get_disklist()
synct=threading.Thread(target=sync)
synct.start()
pwin.mainloop()