wishpal_ironfan
/
scripts
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

day detail

This commit is contained in:
lwl0608 2024-05-12 22:40:16 +08:00
parent 6cfbbefbf7
commit a608d4af29
1 changed files with 56 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
bi/vas_day_detail.py
View File

@ -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()