From 79b47321c5ba8dab9fc8f13566534b1f797de43d Mon Sep 17 00:00:00 2001 From: wuaho Date: Tue, 3 Aug 2021 17:51:21 +0800 Subject: [PATCH] =?UTF-8?q?=E5=83=8F=E7=B4=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- create_database.sql | 2 +- settings.py | 6 +++--- user_view.sql | 6 +++--- 充值视图.sql | 6 +++--- 初始化事件表.sql | 4 ++-- 初始化用户表.sql | 4 ++-- 新用户视图.sql | 6 +++--- 新账号付费.sql | 8 ++++---- 活跃账号视图.sql | 6 +++--- 9 files changed, 24 insertions(+), 24 deletions(-) diff --git a/create_database.sql b/create_database.sql index 6dcbef4..3c0f2f5 100644 --- a/create_database.sql +++ b/create_database.sql @@ -1 +1 @@ -create database zhengba; \ No newline at end of file +create database xiangsu; \ No newline at end of file diff --git a/settings.py b/settings.py index edec1fa..db46a55 100644 --- a/settings.py +++ b/settings.py @@ -8,7 +8,7 @@ class Config: 'send_receive_timeout': 30} # 每个游戏不一样 游戏上报 kafka 主题 - SUBSCRIBE_TOPIC = 'zhengba_test' + SUBSCRIBE_TOPIC = 'xiangsu_test' KAFKA_CONSUMER_CONF = { 'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"], @@ -18,14 +18,14 @@ class Config: 'auto_commit_interval_ms': 10000, # 每个游戏不一样 - 'group_id': 'zhengba_consumer_group' + 'group_id': 'xiangsu_consumer_group' } KAFKA_PRODUCER_CONF = { 'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"], 'value_serializer': lambda v: json.dumps(v).encode('utf-8'), } # 游戏数据库名 - GAME = 'zhengba' + GAME = 'xiangsu' STOP_SIGNAL = 'stop_MntxuXMc' diff --git a/user_view.sql b/user_view.sql index a4ef387..60ae7dc 100644 --- a/user_view.sql +++ b/user_view.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.user_view; -create view zhengba.user_view as select * - from zhengba.user +drop table if exists xiangsu.user_view; +create view xiangsu.user_view as select * + from xiangsu.user order by `#reg_time` desc LIMIT 1 by `#account_id` \ No newline at end of file diff --git a/充值视图.sql b/充值视图.sql index f32f0f6..1dc7f25 100644 --- a/充值视图.sql +++ b/充值视图.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.recharge_game; -create view zhengba.recharge_game as +drop table if exists xiangsu.recharge_game; +create view xiangsu.recharge_game as select toDate(addHours(`#event_time`, `#zone_offset`)) as date, `#os`, `#bundle_id`, @@ -8,6 +8,6 @@ select toDate(addHours(`#event_time`, `#zone_offset`)) as date, arrayDistinct(groupArray(binduid)) as account, length(account) as account_num, sum(money) as money -from zhengba.event +from xiangsu.event where `#event_name` = 'rechargeGame' group by toDate(addHours(`#event_time`, `#zone_offset`)), `#os`, `#bundle_id`, owner_name, channel \ No newline at end of file diff --git a/初始化事件表.sql b/初始化事件表.sql index 8148b00..3c38fab 100644 --- a/初始化事件表.sql +++ b/初始化事件表.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.event; -create table zhengba.event +drop table if exists xiangsu.event; +create table xiangsu.event ( `#ip` Nullable(IPv4), `#country` Nullable(String), diff --git a/初始化用户表.sql b/初始化用户表.sql index f98fc10..189a4b0 100644 --- a/初始化用户表.sql +++ b/初始化用户表.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.user; -create table zhengba.user +drop table if exists xiangsu.user; +create table xiangsu.user ( `#reg_time` DateTime('UTC'), diff --git a/新用户视图.sql b/新用户视图.sql index 1359076..fe48022 100644 --- a/新用户视图.sql +++ b/新用户视图.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.new_account; -create view zhengba.new_account as +drop table if exists xiangsu.new_account; +create view xiangsu.new_account as select toDate(addHours(`#event_time`, `#zone_offset`)) as date, `#os`, `#bundle_id`, @@ -7,6 +7,6 @@ select toDate(addHours(`#event_time`, `#zone_offset`)) as date, channel, groupArray(`binduid`) as account, length(account) as num -from zhengba.event +from xiangsu.event where role_idx = 1 group by toDate(addHours(`#event_time`, `#zone_offset`)), `#os`, `#bundle_id`, owner_name, channel \ No newline at end of file diff --git a/新账号付费.sql b/新账号付费.sql index 43f604a..65ed235 100644 --- a/新账号付费.sql +++ b/新账号付费.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.new_account_recharge; -create view zhengba.new_account_recharge as (select date, +drop table if exists xiangsu.new_account_recharge; +create view xiangsu.new_account_recharge as (select date, `#os`, `#bundle_id`, owner_name, @@ -13,11 +13,11 @@ from (select toDate(addHours(`#event_time`, `#zone_offset`)) as date, channel, binduid, money - from zhengba.event + from xiangsu.event where `#event_name` = 'rechargeGame') as tb1 right join (select toDate(addHours(`#event_time`, `#zone_offset`)) as date, binduid - from zhengba.event + from xiangsu.event where role_idx = 1) as tb2 on tb1.date = tb2.date and tb2.binduid = tb1.binduid group by date, `#os`, `#bundle_id`, owner_name, channel) \ No newline at end of file diff --git a/活跃账号视图.sql b/活跃账号视图.sql index 260bd88..dc9de4b 100644 --- a/活跃账号视图.sql +++ b/活跃账号视图.sql @@ -1,5 +1,5 @@ -drop table if exists zhengba.active_account; -create view zhengba.active_account as +drop table if exists xiangsu.active_account; +create view xiangsu.active_account as select toDate(addHours(`#event_time`, `#zone_offset`)) as date, `#os`, `#bundle_id`, @@ -7,5 +7,5 @@ select toDate(addHours(`#event_time`, `#zone_offset`)) as date, channel, uniqCombined(binduid) as num, arrayDistinct(groupArray(binduid)) as account -from zhengba.event +from xiangsu.event group by toDate(addHours(`#event_time`, `#zone_offset`)), `#os`, `#bundle_id`, owner_name, channel \ No newline at end of file