ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add tags field

Browse Source
This commit is contained in:
pengtao 2019-11-06 15:38:21 +08:00
parent 25267f44ff
commit bf55ed09a7
1 changed files with 24 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
taptap/taptap_report_new.py
View File

@ -44,9 +44,28 @@ class TapTapReport:
for key in gameid_order.keys():
all.setdefault(key, {})['gameid'] = key.split("#")[0]
all[key]['catename'] = key.split('#')[1]
all[key]['date'] = self.day
all[key]['diff_order'] = gameid_order[key].get(self.bday, 301) - gameid_order[key].get(self.day, 301)
all.setdefault(key, {})['current_order'] = gameid_order[key].get(self.day, 301)
all[key]['date'] = self.bday
if gameid_order[key].get(self.bday, 0) and gameid_order[key].get(self.bbday, 0):
all[key]['diff_order'] = gameid_order[key].get(self.bbday, 0) - gameid_order[key].get(self.bday, 0)
all.setdefault(key, {})['current_order'] = gameid_order[key].get(self.bday, 0)
elif not gameid_order[key].get(self.bday, 0):
if gameid_order[key].get(self.day, 0):
# 当前没数据，取后一天的值
all[key]['diff_order'] = gameid_order[key].get(self.bbday, 0) - gameid_order[key].get(self.day, 0)
all.setdefault(key, {})['current_order'] = gameid_order[key].get(self.day, 0)
else:
# 前2天都没数据，默认为游戏下架
pass
elif not gameid_order[key].get(self.bbday, 0):
if gameid_order[key].get(self.day, 0):
# 一天前没数据，取2天前的数据
all[key]['diff_order'] = gameid_order[key].get(self.day, 0)
all.setdefault(key, {})['current_order'] = gameid_order[key].get(self.day, 0)
else:
# 前2天都没数据，默认为游戏上架
all[key]['diff_order'] = gameid_order[key].get(self.bday, 0)
all.setdefault(key, {})['current_order'] = gameid_order[key].get(self.bday, 0)
for key in gameid_info.keys():
all[key]['title'] = gameid_info[key]['title']
@ -79,8 +98,8 @@ class TapTapReport:
for line in all.values():
try:
print(line)
# mydb.insert("taptap_data", line)
#print(line)
mydb.insert("taptap_data_new", line)
except Exception:
log.error(f"install 2 db failed ,values={line}", exc_info=True)