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

tap order 数据写入mysql

Browse Source
This commit is contained in:
pengtao 2019-10-16 15:22:55 +08:00
parent 56b287c9b0
commit e9d98600b5
1 changed files with 52 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
taptap/taptap_report.py
View File

@ -26,23 +26,71 @@ class TapTapReport:
def build_report(self):
all = dict()
gameid_order = dict()
gameid_info = dict()
gameid_info = self.get_gameid_info()
for item in (self.day, self.bday):
b_d = self.split_order_data(item)
for key in b_d:
gameid_order.setdefault(key, {}).update(b_d[key])
for key in gameid_order:
for key in gameid_order.keys():
all.setdefault(key, {})['gameid'] = key.split("#")[0]
all.setdefault(key, {})['catename'] = key.split('#')[1]
all.setdefault(key, {})['diff_order'] = gameid_order[key].get(self.day, 301) - gameid_order[key].get(
self.bday, 301)
all.setdefault(key, {})['current_order'] = gameid_order[key].get(self.day, 301)
for key in gameid_info.keys():
all.setdefault(key, {})['title'] = gameid_info[key]['title']
all.setdefault(key, {})['cate'] = gameid_info[key]['cate']
all.setdefault(key, {})['topic'] = gameid_info[key]['topic']
all.setdefault(key, {})['score'] = gameid_info[key]['score']
all.setdefault(key, {})['reserve'] = gameid_info[key]['reserve']
all.setdefault(key, {})['watch'] = gameid_info[key]['watch']
all.setdefault(key, {})['download'] = gameid_info[key]['download']
all.setdefault(key, {})['sell'] = gameid_info[key]['sell']
all.setdefault(key, {})['review'] = gameid_info[key]['review']
print(all)
def get_gameid_info(self):
all_data = dict()
sql = f"""SELECT
gameid,
catename,
title,
cate,
topic,,
score,
reserve,
watch,
download,
sell,
review
FROM
v_event_25
where
"$part_date"='{self.day}'"""
data = self.tga.get_data(sql)
if data:
for line in data:
try:
gameid, catename, title, cate, topic, score, reserve, watch, download, sell, review = line
key = f"{gameid}#{catename}"
all_data.setdefault(key, {})["key"] = key
all_data.setdefault(key, {})["catename"] = catename
all_data.setdefault(key, {})["title"] = title
all_data.setdefault(key, {})["cate"] = cate
all_data.setdefault(key, {})["topic"] = topic
all_data.setdefault(key, {})["score"] = score
all_data.setdefault(key, {})["reserve"] = reserve
all_data.setdefault(key, {})["watch"] = watch
all_data.setdefault(key, {})["download"] = download
all_data.setdefault(key, {})["sell"] = sell
all_data.setdefault(key, {})["review"] = review
except Exception:
log.error(f"split {line} failed", exc_info=True)
return all_data
def split_order_data(self, day):