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

调整HTML模板

Browse Source
This commit is contained in:
pengtao 2019-11-20 15:49:03 +08:00
parent 49cbbcaf33
commit df89597db2
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
taptap/tap_weekly_mail.py
View File

@ -5,8 +5,9 @@ import logging
import datetime import datetime
import json import json
from collections import defaultdict from collections import defaultdict
define_logger("/data/logs/ops/tap_weekly.log")
define_logger("/data/logs/ops/tap_weekly.log")
log = logging.getLogger(__name__)
db_conf = {'user': 'mytga', 'pswd': 'gzVwh4HGR68G', 'host': '10.10.3.5', 'db': 'external_data'} db_conf = {'user': 'mytga', 'pswd': 'gzVwh4HGR68G', 'host': '10.10.3.5', 'db': 'external_data'}
@ -32,7 +33,6 @@ class TapWeeklyReport:
for tap_type in tap_types: for tap_type in tap_types:
sql = f"""select sql = f"""select
gameid, gameid,
title,
min(`order`), max(order) min(`order`), max(order)
from from
taptap_collect taptap_collect
@ -45,7 +45,31 @@ class TapWeeklyReport:
data = self.db_conn.query(sql) data = self.db_conn.query(sql)
if data: if data:
all_data[tap_type].append(data) # print(f"{tap_type}\t{data}") try:
for line in data:
gameid, min_order, max_order = line
all_data[gameid][tap_type]["min_order"] = min_order
all_data[gameid][tap_type]["max_order"] = max_order
# all_data[tap_type].append(data)
except Exception:
log.error(f"get {tap_type} min/max order failed!", exc_info=True)
sql02 = f"""select gameid,title,score,tags,order,watch,download,sell,review,reserve,topic from
taptap_collect
where
catename='{tap_type}'
and date ='{self.day}'
"""
data02 = self.db_conn.query(sql02)
if data02:
try:
for line in data02:
gameid, title, score, tags, order, watch, download, sell, review, reserve, topic = line
all_data[gameid][tap_type]["title"] = title
all_data[gameid][tap_type]["score"] = score
except Exception:
log.error(f"get {tap_type} details failed!", exc_info=True)
return all_data return all_data
def run(self): def run(self):