From 7affc2d940df6572c98b0f4b26b3a82081f56082 Mon Sep 17 00:00:00 2001 From: lwl0608 Date: Fri, 13 Sep 2024 18:26:32 +0800 Subject: [PATCH] fix --- bi/vas_cur_steamer_income.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/bi/vas_cur_steamer_income.py b/bi/vas_cur_steamer_income.py index c86f6e8..4fbfd30 100644 --- a/bi/vas_cur_steamer_income.py +++ b/bi/vas_cur_steamer_income.py @@ -44,6 +44,7 @@ class S: sql = "SELECT mid, SUM(`change`) AS income FROM `vas_ch_income` WHERE mid>0 AND ct>={} AND ct<{} GROUP BY mid".format(st, et) rows = self.mysql_db_vas.query(sql) print("len(rows): {}".format(len(rows))) + sort_dict_list(rows, "income", desc=True) dt = datetime.datetime.fromtimestamp(st) formatted_dt = dt.strftime('%Y-%m-%d 00:00:00') @@ -56,8 +57,8 @@ class S: income = safe_get_int(row, "income") sql_q = "select * from vas_cur_streamer_income where mid={} and pdate='{}'".format(mid, formatted_dt) - rows = self.mysql_db_bi.query(sql_q) - if len(rows) > 0: + rows_bi = self.mysql_db_bi.query(sql_q) + if len(rows_bi) > 0: sql_u = "update vas_cur_streamer_income set income=%s where mid=%s and pdate=%s" self.mysql_db_bi.exec(sql_u, (income, mid, formatted_dt)) else: