371 lines
19 KiB
Python
371 lines
19 KiB
Python
# coding:utf-8
|
||
from __future__ import annotations
|
||
|
||
import json
|
||
from typing import Optional, Union
|
||
|
||
from pydantic import BaseSettings, Field
|
||
|
||
|
||
class GlobalConfig(BaseSettings):
|
||
"""Global configurations."""
|
||
|
||
# This variable will be loaded from the .env file. However, if there is a
|
||
# shell environment variable having the same name, that will take precedence.
|
||
|
||
# the class Field is necessary while defining the global variables
|
||
ENV_STATE: Optional[str] = Field(..., env="ENV_STATE")
|
||
|
||
class Config:
|
||
"""Loads the dotenv file."""
|
||
|
||
env_file: str = ".env"
|
||
|
||
# 事件映射 legu->shoumeng
|
||
legu_to_sm_event = {'pay': 'role_pay',
|
||
'create_account': 'role_create',
|
||
'login': 'role_login',
|
||
'animation': 'animation',
|
||
'guide': 'guide_flow',
|
||
'ping': 'role_logout',
|
||
'level_up': 'role_rank',
|
||
'vip_level': 'vip_rank',
|
||
'fight': 'role_power',
|
||
'mission_completed': 'task_flow',
|
||
'enter_stage': 'dungeon_flow',
|
||
'end_stage': 'dungeon_flow',
|
||
'resource_change': 'resource_flow',
|
||
'get_item': 'item_flow',
|
||
'cost_item': 'item_flow',
|
||
'summon': 'recruit',
|
||
'ask_for_join_guild': 'guild_apply',
|
||
'leave_guild': 'guild_quit',
|
||
'create_guild': 'guild_set',
|
||
'get_hero': 'hero_get',
|
||
'hero_up': 'hero_rank',
|
||
'hero_star_up': 'hero_advanced',
|
||
'hero_sudden':'hero_sudden',
|
||
'hero_skill_get': 'hero_skill_get',
|
||
'hero_equip': 'equip_get',
|
||
'equip_level_up': 'hero_equip_rank',
|
||
'rune_forge': 'rune_flow',
|
||
'rune_strengthen':'rune_flow',
|
||
'refine_rune':'rune_flow',
|
||
'event_participate': 'activity_flow',
|
||
'event_centered': 'activity_flow',
|
||
'event_finish': 'activity_flow',
|
||
'home_rank': 'home_rank',
|
||
'fishing_flow': 'fishing_flow',
|
||
'binfen_participate': 'activity_flow',
|
||
'binfen_finish': 'activity_flow',
|
||
'xitian_road_participate': 'activity_flow',
|
||
'xitian_road_finish': 'activity_flow',
|
||
'leiyin_participate': 'activity_flow',
|
||
'leiyin_finish': 'activity_flow',
|
||
'tyemple_soul': 'tyemple_soul',
|
||
'hell_gate': 'hell_gate',
|
||
'dzsf_participate': 'activity_flow',
|
||
'dzsf_finish': 'activity_flow',
|
||
'dzsftiaozhan_participate': 'dzsftiaozhan_participate',
|
||
'dzsftiaozhan_finish': 'dzsftiaozhan_finish',
|
||
'baoxiang':'activity_flow',
|
||
'yuanxiao':'activity_flow',
|
||
'yxxq_cunjie':'activity_flow',
|
||
'drhz':'activity_flow'}
|
||
# 公共属性映射 legu->shoumeng
|
||
legu_to_sm_attr_base = {
|
||
# 基础属性
|
||
'channel': 'channel_name',
|
||
'svrindex': 'game_server',
|
||
'#os': 'platform_id',
|
||
'binduid': 'sm_user_id',
|
||
'user_id': 'user_id', # 避免重复key，使用的是binduid
|
||
'#account_id': 'role_id',
|
||
'role_name': 'role_name',
|
||
'ghid': 'guild_id',
|
||
'ghname': 'guild',
|
||
'zhanli': 'power',
|
||
'lv': 'role_rank',
|
||
'vip': 'role_vip',
|
||
# '':'castle_rank', # 城堡等级
|
||
'exp': 'exp',
|
||
'data_id': 'data_id'
|
||
|
||
}
|
||
# 事件属性映射
|
||
legu_to_sm_attr = {'pay': {'unitPrice': 'pay_amount',
|
||
'orderid': 'pay_product_id',
|
||
'proid': 'pay_product',
|
||
'pay_product_json': 'pay_product_json',
|
||
'pay_ip': 'pay_ip'},
|
||
'create_account': {},
|
||
'login': {},
|
||
'ta_app_end': {},
|
||
'animation': {'animation_seconds': 'animation_seconds',
|
||
'animation_result': 'result'},
|
||
'guide': {'step_id': 'guide_id', 'step_name': 'guide_name'},
|
||
'ping': {'online_ts': 'online_time'},
|
||
'level_up': {'role_level': 'rank',
|
||
'before_level': 'rank_before',
|
||
'after_level': 'rank_change'},
|
||
'vip_level': {'before_vip': 'vip_rank_before',
|
||
'after_vip': 'vip_rank'},
|
||
'fight': {'fighting_capacity': 'power',
|
||
'fighting_before': 'power_before',
|
||
'after_fighting': 'power_change'},
|
||
'mission_completed': {'mission_type': 'task_type',
|
||
'mission_id': 'task_id',
|
||
'mission_name': 'task_name',
|
||
'reward_list': 'task_reward_content',
|
||
'reward_type': 'task_result'},
|
||
'enter_stage': {},
|
||
'end_stage': {'stage_id': 'dungeon_id',
|
||
'stage_name': 'dungeon_name',
|
||
'stage_type': 'dungeon_type',
|
||
'reward_list': 'dungeon_result'},
|
||
'shopping': {},
|
||
'idle_reward': {},
|
||
'online_reward': {},
|
||
'sign': {},
|
||
'resource_change': {'resource_id': 'resource_id',
|
||
'resource_name': 'resource_name',
|
||
'change_type': 'add_or_reduce',
|
||
'change_num': 'count_change',
|
||
'change_before': 'count_before',
|
||
'change_after': 'count',
|
||
'change_reason': 'sub_reason'},
|
||
'get_item': {'item_id': 'item_id',
|
||
'item_name': 'item_name',
|
||
'change_type': 'add_or_reduce',
|
||
'change_num': 'count_change',
|
||
'change_before': 'count_before',
|
||
'change_after': 'count',
|
||
'change_reason': 'sub_reason'},
|
||
'cost_item': {'item_id': 'item_id',
|
||
'item_name': 'item_name',
|
||
'change_type': 'item_type',
|
||
'change_num': 'count_change',
|
||
'change_before': 'count_before',
|
||
'change_after': 'count',
|
||
'change_reason': 'sub_reason'},
|
||
'summon': {'summon_type': 'recruit_type',
|
||
'item_list': 'item_id',
|
||
'item_name': 'reward_content',
|
||
'summon_cost_type': 'cost_name',
|
||
'summon_cost_num': 'cost_count'},
|
||
'ask_for_join_guild': {'guild_level': 'guiild_rank',
|
||
'guild_id': 'guild_id',
|
||
'guild_name': 'guild_name',
|
||
'guild_position': 'guild_position'},
|
||
'leave_guild': {'guild_level': 'guiild_rank',
|
||
'guild_id': 'guild_id',
|
||
'guild_name': 'guild_name',
|
||
'guild_position': 'guild_position'},
|
||
'create_guild': {'guild_level': 'guiild_rank',
|
||
'guild_id': 'guild_id',
|
||
'guild_name': 'guild_name',
|
||
'guild_fighting_capacity': 'guild_position'},
|
||
'guild_donate': {},
|
||
'get_hero': {'hero_name': 'hero_name',
|
||
'hero_job': 'hero_type',
|
||
'get_type': 'reason'},
|
||
'hero_up': {'hero_name': 'hero_name',
|
||
'hero_job': 'hero_type',
|
||
'original_level': 'hero_status_before',
|
||
'new_level': 'hero_rank',
|
||
'item_name': 'item_name',
|
||
'cost_count': 'cost_count'},
|
||
'hero_star_up': {'hero_name': 'hero_name',
|
||
'hero_id': 'hero_id',
|
||
'before_awake': 'hero_status_before',
|
||
'after_awake': 'hero_status',
|
||
'item_name': 'item_name',
|
||
'cost_count': 'cost_count'},
|
||
'hero_sudden': {'hero_name': 'hero_name',
|
||
'hero_id': 'hero_id',
|
||
'hero_status': 'hero_status',
|
||
'hero_status_before': 'hero_status_before',
|
||
'item_name': 'item_name',
|
||
'cost_count': 'cost_count'},
|
||
'hero_skill_get': {'hero_name': 'hero_name',
|
||
'hero_job': 'hero_job',
|
||
'skill_rank_before': 'skill_rank_before',
|
||
'skill_rank': 'skill_rank',
|
||
'skill_name': 'skill_name'},
|
||
'hero_equip': {'equip_id': 'equip_id',
|
||
'after_fight': 'equip_name',
|
||
'equip_quality': 'equip_quality',
|
||
'reason': 'sub_reason'},
|
||
'equip_level_up': {'equip_name': 'equip_name',
|
||
'equip_quality': 'equip_id',
|
||
'strength_level': 'equip_rank_before',
|
||
'equip_rank': 'equip_rank'},
|
||
'rune_forge': {'rune_id': 'rune_id',
|
||
'rune_type': 'rune_type',
|
||
'rune_name': 'rune_name',
|
||
'reason': 'reason',
|
||
'sub_reason': 'sub_reason'},
|
||
'rune_strengthen': {'rune_id': 'rune_id',
|
||
'rune_type': 'rune_type',
|
||
'rune_name': 'rune_name',
|
||
'item_name': 'item_name',
|
||
'cost_count': 'cost_count',
|
||
'rune_rank': 'rune_rank'},
|
||
'event_participate': {'activity_id': 'activity_id',
|
||
'activity_name': 'activity_name',
|
||
'activity_type': 'activity_type'},
|
||
'event_centered': {'activity_id': 'activity_id',
|
||
'activity_name': 'activity_name',
|
||
'activity_type': 'activity_type'},
|
||
'event_finish': {'activity_id': 'activity_id',
|
||
'activity_name': 'activity_name',
|
||
'activity_type': 'activity_type',
|
||
'reward_list': 'activity_reward_content'
|
||
},
|
||
'home_rank': {'home_rank_before': 'home_rank_before',
|
||
'new_home_rank': 'home_rank'},
|
||
'fishing_flow': {'fishing_result': 'result',
|
||
'reward_content': 'reward_content',
|
||
'fish_time_rest': 'fish_time_rest'},
|
||
'training_room': {},
|
||
'plant': {},
|
||
'loot': {},
|
||
'harvest': {},
|
||
'banquet': {},
|
||
'home_hero_list': {},
|
||
'mine_layer': {},
|
||
'buy_strength': {},
|
||
'expend_strength': {},
|
||
'decoration_recycle': {},
|
||
'complete_build': {},
|
||
'binfen_participate': {'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'turntable_type': 'turntable_type',
|
||
'cost_count': 'cost_count',
|
||
'reward_list': 'activity_reward_content'},
|
||
'binfen_finish': {'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'turntable_type': 'turntable_type',
|
||
'cost_count': 'cost_count',
|
||
'reward_list': 'activity_reward_content'},
|
||
'xitian_road_participate': {'gaolaozhuang': 'gaolaozhuang'},
|
||
'xitian_road_finish': {'huaguoshan': 'huaguoshan'},
|
||
'leiyin_participate': {'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'turntable_type': 'turntable_type',
|
||
'cost_count': 'cost_count',
|
||
'reward_list': 'activity_reward_content'},
|
||
'leiyin_finish': {'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'turntable_type': 'turntable_type',
|
||
'cost_count': 'cost_count',
|
||
'reward_list': 'activity_reward_content'},
|
||
'tyemple_soul': {'zhanchang_name': 'zhanchang_name',
|
||
'zhanchang_type': 'zhanchang_type',
|
||
'reward_list': 'reward_list'},
|
||
'hell_gate': {'stage_id': 'stage_id',
|
||
'stage_name': 'stage_name',
|
||
'reward_list': 'reward_list'},
|
||
'dzsf_participate': {'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'turntable_type': 'turntable_type',
|
||
'cost_count': 'cost_count',
|
||
'reward_list': 'activity_reward_content'},
|
||
'dzsf_finish': {'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'turntable_type': 'turntable_type',
|
||
'cost_count': 'cost_count',
|
||
'reward_list': 'activity_reward_content'},
|
||
'dzsftiaozhan_participate': {'butianzhidi': 'butianzhidi'},
|
||
'dzsftiaozhan_finish': {'jzzk': 'jzzk'},
|
||
'baoxiang':{'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'reward_list':'activity_reward_content'},
|
||
'yuanxiao':{'yuanxiao_finish':'activity_reward_content'},
|
||
'yxxq_cunjie':{'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'reward_list':'activity_reward_content'},
|
||
'drhz':{'activity_id':'activity_id',
|
||
'activity_name':'activity_name',
|
||
'reward_list':'activity_reward_content'}
|
||
}
|
||
# 手盟上报模板
|
||
template_data = {
|
||
"cp_game_id": 682,
|
||
"category": "cp_api",
|
||
"event": {
|
||
'event_access': 'realtime',
|
||
"event_time": 0,
|
||
"event_name": ""
|
||
},
|
||
"data": {
|
||
|
||
}
|
||
}
|
||
|
||
|
||
class DevConfig(GlobalConfig):
|
||
"""Development configurations."""
|
||
SM_API = 'https://data.910app.com/cp_test'
|
||
SM_CHECK_API = 'http://datacheck.910app.com:8099/cp/check'
|
||
|
||
KAFKA_CONSUMER_CONF: dict = {
|
||
'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
|
||
'value_deserializer': json.loads,
|
||
'auto_offset_reset': 'earliest',
|
||
'max_poll_interval_ms': 600000,
|
||
'session_timeout_ms': 600000,
|
||
'connections_max_idle_ms': 655000,
|
||
'request_timeout_ms': 605000,
|
||
'enable_auto_commit': False,
|
||
|
||
# 每个游戏不一样
|
||
'group_id': 'shoumeng_xiangsu_debug' # '测试'
|
||
}
|
||
SUBSCRIBE_TOPIC: str = 'debug'
|
||
|
||
class Config:
|
||
env_prefix: str = "DEV_"
|
||
|
||
|
||
class ProdConfig(GlobalConfig):
|
||
"""Production configurations."""
|
||
|
||
SM_API = 'https://data.910app.com/cp'
|
||
|
||
KAFKA_CONSUMER_CONF = {
|
||
'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
|
||
'value_deserializer': json.loads,
|
||
'auto_offset_reset': 'earliest',
|
||
'max_poll_interval_ms': 600000,
|
||
'session_timeout_ms': 600000,
|
||
'connections_max_idle_ms': 655000,
|
||
'request_timeout_ms': 605000,
|
||
'enable_auto_commit': False,
|
||
|
||
# 每个游戏不一样
|
||
'group_id': 'shou_meng_xiangsu2' # '正式的'
|
||
}
|
||
SUBSCRIBE_TOPIC = 'xiangsu'
|
||
|
||
class Config:
|
||
env_prefix: str = "PROD_"
|
||
|
||
|
||
class FactoryConfig:
|
||
"""Returns a config instance dependending on the ENV_STATE variable."""
|
||
|
||
def __init__(self, env_state: Optional[str]) -> None:
|
||
self.env_state = env_state
|
||
|
||
def __call__(self) -> Union[DevConfig, ProdConfig]:
|
||
if self.env_state == "dev":
|
||
return DevConfig()
|
||
|
||
elif self.env_state == "prod":
|
||
return ProdConfig()
|
||
|
||
|
||
settings = FactoryConfig(GlobalConfig().ENV_STATE)()
|
||
print(11)
|