From 4e7de25c4ca3d0980721a061a6aa8f081aa0925c Mon Sep 17 00:00:00 2001
From: pengtao <pengtao@kingsome.cn>
Date: Wed, 20 Nov 2019 11:47:21 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=91=A8=E6=8A=A5=E8=84=9A?=
 =?UTF-8?q?=E6=9C=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 taptap/tap_weekly_mail.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/taptap/tap_weekly_mail.py b/taptap/tap_weekly_mail.py
index fef0ea4..5c31aee 100644
--- a/taptap/tap_weekly_mail.py
+++ b/taptap/tap_weekly_mail.py
@@ -4,6 +4,7 @@ from ops.plog import define_logger
 import logging
 import datetime
 import json
+from collections import defaultdict
 define_logger("/data/logs/ops/tap_weekly.log")
 
 db_conf = {'user': 'mytga', 'pswd': 'gzVwh4HGR68G', 'host': '10.10.3.5', 'db': 'external_data'}
@@ -27,6 +28,7 @@ class TapWeeklyReport:
     def build(self):
         weekly_day = json.dumps(self.get_weekly_days()).strip('[]')
         tap_types = ("new", "download", "reserve", "sell", "played")
+        all_data = defaultdict(list)
         for tap_type in tap_types:
             sql = f"""select
                     gameid,
@@ -44,8 +46,8 @@ class TapWeeklyReport:
 
             data = self.db_conn.query(sql)
             if data:
-                print(f"{tap_type}\t{data}")
-        return True
+                all_data[tap_type].append(data)  # print(f"{tap_type}\t{data}")
+        return all_data
 
     def run(self):
         data = self.build()