Skip to content

Commit

Permalink
add user level
Browse files Browse the repository at this point in the history
  • Loading branch information
@zephyrzoom
zephyrzoom committed Nov 17, 2015
1 parent 7a7050b commit 79f337b
Show file tree
Hide file tree
Showing 4 changed files with 147 additions and 60 deletions.
174 changes: 126 additions & 48 deletions douyu/douyu.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,31 +27,30 @@ def __init__(self, root):

self.g_exit= False


self.p=None
self.mutex = 0
self.m_list = {} # list from search netcloud
self.selected = False
#self.FOLD = r'E:\m\music'
self.FOLD = 'Documents/sublime/danmu_diange/music'




self.FOLD = r'E:\m\music'
#self.FOLD = 'Documents/sublime/danmu_diange/music'
self.VIP_LIST=r'E:\m\douyu_0.0.4\level.json'
with open(self.VIP_LIST, 'r') as f:
self.vips = json.loads(f.read())



def initUI(self):
self.MUSIC_LIST='Documents/sublime/danmu_diange/douyu_0.0.3/music_list.json'
self.MUSIC_LIST=r'E:\m\douyu_0.0.4\music_list.json'
with open(self.MUSIC_LIST,'r') as f:
self.play_list = json.loads(f.read()) # list from json
self.root.protocol("WM_DELETE_WINDOW", self.on_closing)

mainframe = ttk.Frame(self.root)
bigFont = font.Font(size=12, weight='bold')
self.text = Text(mainframe, bg="white", width=50, height=25, state=DISABLED, font=bigFont)
self.text = Text(mainframe, bg="white", width=50, height=30, state=DISABLED, font=bigFont)
self.lb_play_list=StringVar()
self.lb_play_list.set(self.play_list_4_show())
print(self.play_list)
self.label = ttk.Label(mainframe, textvariable=self.lb_play_list, font=bigFont, width=20)
mainframe.grid(column=0,row=0)
self.text.grid(column=0,row=0)
Expand All @@ -69,11 +68,13 @@ def on_closing(self):
if messagebox.askokcancel("Quit", "Do you want to quit?"):
with open(self.MUSIC_LIST,'w') as f:
json.dump(self.play_list, f)
with open(self.VIP_LIST,'w') as f:
json.dump(self.vips, f)
self.root.destroy()



###############################################################################
#####################################弹幕#####################################
def is_exit(self):
self.g_exit
return self.g_exit
Expand Down Expand Up @@ -153,15 +154,15 @@ def get_longinres(self,s_ip=b'117.79.132.20', s_port=8001, rid=b'265352'):

self.sendmsg(s,b'type@=loginreq/username@=/password@=/roomid@='+rid+b'/\x00')

#print('==========longinres')
print('==========longinres')
longinres= self.unpackage(self.recvmsg(s))

#print('==========msgrepeaterlist')
print('==========msgrepeaterlist')
msgrepeaterlist= self.unpackage(self.recvmsg(s))
lst= self.unpackage(msgrepeaterlist[b'list'])
tb= self.unpackage(random.choice(tuple(lst.values())))

#print('==========setmsggroup')
print('==========setmsggroup')
setmsggroup= self.unpackage(self.recvmsg(s))

ret= {'rid':rid,
Expand All @@ -176,7 +177,9 @@ def keepalive_send():
try:
self.sendmsg(s,b'type@=keeplive/tick@='+str(random.randint(1,99)).encode('ascii')+b'/\x00')
except Exception as e:
threading.Thread(target=keepalive_send).start()
print(e)
threading.Thread(target=self.main).start()
exit()
time.sleep(45)
s.close()
threading.Thread(target=keepalive_send).start()
Expand All @@ -185,15 +188,17 @@ def keepalive_recv():
try:
bmsg= self.recvmsg(s)
except Exception as e:
threading.Thread(target=keepalive_recv).start()
#print('*** usr alive:',unpackage(bmsg),'***')
print(e)
threading.Thread(target=self.main).start()
exit()
print('*** usr alive:',self.unpackage(bmsg),'***')
s.close()
threading.Thread(target=keepalive_recv).start()
return ret

def get_danmu(self,rid=b'5275', ip=b'danmu.douyutv.com', port=8001, username=b'visitor42', gid=b'0'):
"args needs bytes not str"
#print('==========danmu')
print('==========danmu')

s= socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((ip,int(port)))
Expand All @@ -206,7 +211,9 @@ def keepalive():
try:
self.sendmsg(s,b'type@=keeplive/tick@='+str(random.randint(1,99)).encode('ascii')+b'/\x00')
except Exception as e:
threading.Thread(target=keepalive).start()
print(e)
threading.Thread(target=self.main).start()
exit()
time.sleep(45)
s.close()
threading.Thread(target=keepalive).start()
Expand All @@ -215,9 +222,9 @@ def keepalive():
try:
bmsg= self.recvmsg(s)
except Exception as e:
print('restarting...')
print(e)
threading.Thread(target=self.main).start()
break
exit()
if not bmsg:
print('*** connection break ***')

Expand All @@ -238,8 +245,15 @@ def keepalive():
elif msgtype==b'donateres':
sui= self.unpackage(msg.get(b'sui',b'nick@=undifined//00'))
nick= sui[b'nick'].decode('utf8')
#print('***', nick, '送给主播', int(msg[b'ms']),\
# '个鱼丸 (', cast_wetght(msg[b'dst_weight']), ') ***')
print(self.vips)
self.handle_lvl(nick, 10)
with open(self.VIP_LIST,'w') as f:
json.dump(self.vips, f)
print(self.vips)
print(type(nick))
print(type(msg[b'ms']))
print('***', nick, '送给主播', int(msg[b'ms']),\
'个鱼丸 (', self.cast_wetght(msg[b'dst_weight']), ') ***')
#notify(nick, '送给主播' + str(int(msg[b'ms'])) + '个鱼丸')
elif msgtype==b'keeplive':
pass
Expand Down Expand Up @@ -365,6 +379,7 @@ def main(self,url='http://www.douyutv.com/im707'):
#print('login_room_info', login_room_info)
self.write_text('系统','已启动...')
self.get_danmu(**login_room_info)



###############################################################################
Expand All @@ -377,7 +392,7 @@ def time_count(self,nick, times):
time.sleep(0.1)
count = times*10+1-i
if count % 100 == 0:
self.write_text('系统','将在%d秒之后自动播放第一首歌' % int(count/10))
self.write_text('系统','将在%d秒之后自动选择第一首歌' % int(count/10))
else:
return

Expand Down Expand Up @@ -410,12 +425,13 @@ def show_music_list(self):
"""
def analysis_danmu(self, nick, content):
#print(self.vips)
#self.write_text('测试',str(self.mutex))
content = content.split(' ')
if content[0] == '点歌':
contents = content.split(' ')
if contents[0] == '点歌':
if self.mutex == 0:
self.mutex = nick
song_name = ''.join(content[1:])
song_name = ''.join(contents[1:])
self.m_list = mplay.search_song_by_name(song_name)
if self.m_list == -1:
self.mutex = 0
Expand All @@ -426,7 +442,7 @@ def analysis_danmu(self, nick, content):
threading.Thread(target=self.time_count, args=([nick, 30])).start()
elif self.mutex == nick:
self.selected = True
song_name = ''.join(content[1:])
song_name = ''.join(contents[1:])
self.m_list = mplay.search_song_by_name(song_name)
if self.m_list == -1:
self.mutex = 0
Expand All @@ -436,51 +452,71 @@ def analysis_danmu(self, nick, content):
self.show_music_list()
threading.Thread(target=self.time_count, args=([nick, 30])).start()
else:
self.write_text('系统','%s 请等待 %s 点歌' % (nick, self.mutex))
elif content[0] == '选歌':
self.write_text('%s' % self.mutex,'%s 等我选完,我手速慢' % nick)
elif contents[0] == '选歌':
if self.mutex == 0:
self.write_text('系统','%s 请先点歌' % nick)
elif self.mutex == nick:
selected_song = ''.join(content[1:])
selected_song = ''.join(contents[1:])
try:
selected_song = int(selected_song)
song = mplay.select(selected_song, self.m_list)
if song != -1:
self.selected = True
self.mutex = 0
self.write_text('系统','%s 正在对选择进行处理...' % nick)
music_path = mplay.save_song_to_disk(song, self.FOLD)
# add to list
print(music_path)
print(self.play_list)
self.play_list['music list'].append({'id':nick,'mname':song['name'],'mpath':music_path})
self.lb_play_list.set(self.play_list_4_show())
# with open(self.MUSIC_LIST, 'w') as f:
# json.dump(m_list, f)
print(self.play_list['music list'][-1])

# with open(self.MUSIC_LIST, 'r') as f:
# m_list = json.loads(f.read())
# self.write_text('song',m_list['music list'][1]['mname'])


self.write_text('系统','%s 选歌成功' % nick)
self.handle_lvl(nick,1)
with open(self.VIP_LIST,'w') as f:
json.dump(self.vips, f)
else:
self.write_text('系统','%s 请按照序号选歌' % nick)
except:
self.write_text('系统', '%s 请注意选歌格式' % nick)
else:
self.write_text('系统','%s 请等待 %s 选歌' % (nick, self.mutex))
self.write_text('%s' % self.mutex,'%s 等我选完,我手速慢' % nick)
elif content.strip() == '切歌':
if self.play_list['music list']:
cut_nick=self.play_list['music list'][0]['id']
for i in self.vips['vips']:
if cut_nick==i['name']:
cut_lvl=self.calc_level(i['lvl'])
break
for i in self.vips['vips']:
if nick == i['name']:
lvl = self.calc_level(i['lvl'])
break
else:
lvl = 0
if cut_lvl >= lvl and nick != cut_nick:

self.write_text('%s(%d级)' % (cut_nick,cut_lvl),'%s(%d级) 你比我级高?还想切我的歌' % (nick,lvl))
else:
mplay.killu(self.p)
if nick == cut_nick:
self.write_text('%s' % nick,'我把自己的歌切了')
else:
self.write_text('%s' % nick,'%s 我把你的的歌切了,你打我啊' % cut_nick)
else:
self.write_text('系统','哪有歌让你切啊!')
elif content.strip() == '等级':
self.write_text('%s' % nick,'我怎么才%d级' % self.get_level(nick))
else:
pass

def play_mp3(self):
while 1:
while self.play_list['music list']:
p = mplay.playmp3(self.play_list['music list'][0]['mpath'])
# while not p.returncode:
# print(p)
# time.sleep(5)
self.p = mplay.playmp3(self.play_list['music list'][0]['mpath'])
self.p.wait()
self.f5_list()
self.lb_play_list.set(self.play_list_4_show()) # refresh play list
print(self.play_list)
#print(self.play_list)
else:
time.sleep(10)# no music play, wait for sb diange

Expand All @@ -490,16 +526,56 @@ def f5_list(self):
def play_list_4_show(self):
tmp_str=' 播放列表\n\n'
for i,v in enumerate(self.play_list['music list']):
tmp_str=''.join([tmp_str,str(i+1),'. %s:\n %s' % (v['id'],v['mname']), '\n'])
tmp_str=''.join([tmp_str,str(i+1),'. %s:\n %s' % (v['id'],v['mname']), '\n'])
return tmp_str

def get_level(self,nick):
print(nick)
print(self.vips)
for i in self.vips['vips']:
if nick == i['name']:
return self.calc_level(i['lvl'])
else:
return -1

def calc_level(self,lvl):
start=1
MAX=100
while start < MAX:
lvl_value=(start*(start+1))/2
if lvl < lvl_value:
return start-1
else:
start += 1
else:
self.write_text('系统','等级已到上限')
return -1

def write_level(self,nick,lvl):
for i in self.vips['vips']:
if i['name'] == nick:
i['lvl'] += lvl
break
else:
self.vips['vips'].append({'name':nick,'lvl':lvl})

def handle_lvl(self,nick, exp):
lvl = self.get_level(nick)
self.write_level(nick,exp) #100鱼丸=10点经验
after_lvl=self.get_level(nick)
if after_lvl > lvl:
self.write_text('%s' % nick,'我终于升到%d级了' % after_lvl)

###############################################################################

def maintk():
root = Tk()
app = my_gui(root)
#app.delete_music_start()

threading.Thread(target=app.main).start()


threading.Thread(target=app.play_mp3).start()
#root.after(2000, app.main)
root.mainloop()
Expand All @@ -510,4 +586,6 @@ def maintk():
# url= sys.argv[1] if len(sys.argv)>1 else 'http://www.douyutv.com/im707'
# #danmu_play_music.delete_music_start()
# main(url)

maintk()

1 change: 1 addition & 0 deletions douyu/level.json
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
{"vips": [{"lvl": 1, "name": "\u95f2\u8c08\u8005"}, {"lvl": 15, "name": "707472783"}, {"lvl": 3, "name": "\u9a6c\u95f9\u817ei"}, {"lvl": 42, "name": "\u661f\u8fb0\u98de\u626c"}, {"lvl": 10, "name": "\u9189\u751f\u5922\u6b7bmagura"}, {"lvl": 61, "name": "\u8bbd\u523a\u7684\u6bcd\u732a"}, {"lvl": 43, "name": "15281469825"}, {"lvl": 5, "name": "718133435"}, {"lvl": 1, "name": "1310300339"}, {"lvl": 2, "name": "\u53eb\u6211\u50bb\u68fa\u6750"}, {"lvl": 1, "name": "1094230867"}, {"lvl": 1, "name": "\u5948\u6587\u6469\u5c14nm"}, {"lvl": 63, "name": "abcdefg78563"}, {"lvl": 1, "name": "\u53cc\u6728\u68ee\u5fb7"}, {"lvl": 169, "name": "qq_xcY6kK"}, {"lvl": 1, "name": "Xanver"}, {"lvl": 3, "name": "1176681832"}, {"lvl": 1, "name": "\u4e03\u559c\u5148\u751f"}, {"lvl": 1, "name": "\u50cfUZI\u7684\u5c0f\u53f6\u5b50"}, {"lvl": 1, "name": "\u4eca\u5e74\u79cb\u5929"}, {"lvl": 2, "name": "\u65f6\u5149\u672a\u8001\u7231\u5df2\u8352\u51c9"}, {"lvl": 36, "name": "douyuing"}, {"lvl": 5, "name": "316124707"}, {"lvl": 12, "name": "\u5eb8\u4eba\u5eb8\u81ea\u5eb8"}, {"lvl": 2, "name": "\u8c01\u4eba\u4f7f\u4f60\u7231\u504f\u79bb"}, {"lvl": 1, "name": "a398818898"}, {"lvl": 2, "name": "chenteng730"}, {"lvl": 2, "name": "\u55b5\u8bfa"}, {"lvl": 9, "name": "Yjnnnnnnnnnnnnnnnnnnnnnn"}, {"lvl": 15, "name": "\u5c0f\u5c0f\u9f8d"}, {"lvl": 1, "name": "asdbbsb123"}, {"lvl": 15, "name": "\u5979\u662f\u6211\u7684\u6d77\u8d3c\u738b"}, {"lvl": 1, "name": "\u7edf\u4e00\u51bb\u67e0\u6aac"}, {"lvl": 1, "name": "\u963f\u79657373"}, {"lvl": 1, "name": "691130"}]}
Loading

0 comments on commit 79f337b

Please sign in to comment.