This commit is contained in:
wuaho 2021-08-23 12:29:15 +08:00
parent 3942ae17ae
commit 5aa182da11
2 changed files with 5 additions and 4 deletions

View File

@ -169,7 +169,8 @@ class BehaviorAnalysis:
res_json = await self.rdb.get(f'{self.game}_event')
columns = json.loads(res_json).keys()
metadata = sa.MetaData(schema=self.game)
self.event_tbl = sa.Table('event_view', metadata, *[sa.Column(column) for column in columns])
# self.event_tbl = sa.Table('event_view', metadata, *[sa.Column(column) for column in columns])
self.event_tbl = sa.Table('event', metadata, *[sa.Column(column) for column in columns])
def handler_filts(self, *ext_filters, g_f=True):
user_filter = []

View File

@ -124,7 +124,7 @@ class XAnalysis:
cnt1,
{select_ltv_str}
FROM (SELECT toDate(addHours(`#event_time`, `#zone_offset`)) as date, uniqExact(`{quota}`) cnt1
FROM {self.game}.event_view
FROM {self.game}.event
where `#event_name` = 'create_account'
AND {where_str}
GROUP BY toDate(addHours(`#event_time`, `#zone_offset`))) as reg
@ -132,11 +132,11 @@ class XAnalysis:
(select a.date,
{sumpay_str}
from (SELECT toDate(addHours(`#event_time`, `#zone_offset`)) as date, `{quota}`
FROM {self.game}.event_view
FROM {self.game}.event
where `#event_name` = 'create_account'
and {where_str}) as a
left join (select `{quota}`, unitPrice/100 as money, toDate(addHours(`#event_time`, `#zone_offset`)) as date
from {self.game}.event_view
from {self.game}.event
where `#event_name` = 'pay' and {where_order_str}) b
on a.`{quota}` = b.`{quota}`
group by a.date) log on reg.date = log.date