diff --git a/bi/vas_day_detail.py b/bi/vas_day_detail.py index 6372748..f2bdc18 100644 --- a/bi/vas_day_detail.py +++ b/bi/vas_day_detail.py @@ -5,19 +5,26 @@ log_dir = '/app/log' logger = Logger(service_name, log_dir=log_dir) hds = [ - "时间", - "会员数", "会员流水", - "空间解锁数", "空间解锁流水", - "空间超粉数", "空间超粉流水", - "空间动态数", "空间动态流水", - "其他数(微信+金币)", "其他流水(微信+金币)", - "总流水", "主播分成", "净收入", - "利润率", - "会员流水占比", - "空间解锁占比", - "空间超粉占比", - "空间动态占比", - "其他占比", + '时间', + '会员数', + '会员流水', + '空间解锁数', + '空间解锁流水', + '空间超粉数', + '空间超粉流水', + '空间动态数', + '空间动态流水', + '其他数(微信+金币)', + '其他流水(微信+金币)', + '总流水', + '主播分成', + '净收入', + '利润率', + '会员流水占比', + '空间解锁占比', + '空间超粉占比', + '空间动态占比', + '其他占比', ] @@ -63,10 +70,26 @@ and mid>0 def insert_day_detail(self, data: tuple): sql = '''insert into vas_day_detail ( - ptime, membership_cnt, membership_flow, zone_admission_cnt, zone_admission_flow, - zone_superfan_cnt, zone_superfan_flow, zone_moment_cnt, zone_moment_flow, - other_cnt, other_flow, total_flow, streamer_flow, official_flow, - profit_rate, membership_rate, zone_admission_rate, zone_superfan_rate, zone_moment_rate, other_rate + ptime, + membership_cnt, + membership_flow, + zone_admission_cnt, + zone_admission_flow, + zone_superfan_cnt, + zone_superfan_flow, + zone_moment_cnt, + zone_moment_flow, + other_cnt, + other_flow, + total_flow, + streamer_flow, + official_flow, + profit_rate, + membership_rate, + zone_admission_rate, + zone_superfan_rate, + zone_moment_rate, + other_rate ) values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)''' return self.mysql_db_bi.exec(sql, data) @@ -126,12 +149,20 @@ and mid>0 print(data) -st_et_str_map = gen_st_et_str_map_v2( - "2024-04-16 00:00:00", "2024-05-11 00:00:00" -) +# st_et_str_map = gen_st_et_str_map_v2( +# "2024-04-16 00:00:00", "2024-05-11 00:00:00" +# ) +# +# for st_str, et_str in st_et_str_map.items(): +# s = S( +# get_ts_by_str(st_str), get_ts_by_str(et_str) +# ) +# s.proc() -for st_str, et_str in st_et_str_map.items(): - s = S( - get_ts_by_str(st_str), get_ts_by_str(et_str) - ) - s.proc() +st = get_today_zero_time() - 86400 +et = st + 86400 + +s = S( + st, et +) +s.proc()