|
@@ -226,7 +226,7 @@ def update_ad_abtest_threshold(project, table, dt, ad_abtest_abcode_config, ad_t
|
|
|
return robot_msg_record
|
|
|
|
|
|
|
|
|
-def get_ad_target_uv():
|
|
|
+def get_ad_target_uv(now_h):
|
|
|
"""获取管理后台开启自动调整阈值开关的目标uv值"""
|
|
|
ad_target_uv = {}
|
|
|
result = request_get(request_url=config_.GET_AD_TARGET_UV_URL)
|
|
@@ -241,9 +241,16 @@ def get_ad_target_uv():
|
|
|
for item in result['content']:
|
|
|
app_type = item['productId']
|
|
|
target_uv_mapping = {}
|
|
|
+ target_uv_param = config_.AD_ABTEST_ABCODE_CONFIG.get(int(app_type)).get('target_uv_param', {})
|
|
|
for uv_item in item['uvTargetDetails']:
|
|
|
ab_group = uv_item['abParam']
|
|
|
target_uv = uv_item['uvTarget']
|
|
|
+ target_uv_param_group = target_uv_param.get(ab_group, None)
|
|
|
+ if target_uv_param_group is not None:
|
|
|
+ update_hours = target_uv_param_group.get('update_hours')
|
|
|
+ update_param = target_uv_param_group.get('update_param')
|
|
|
+ if now_h in update_hours:
|
|
|
+ target_uv *= update_param
|
|
|
target_uv_mapping[ab_group] = target_uv
|
|
|
ad_target_uv[app_type] = target_uv_mapping
|
|
|
return ad_target_uv
|
|
@@ -260,11 +267,12 @@ def timer_check():
|
|
|
project = config_.AD_THRESHOLD_AUTO_UPDATE_DATA.get('project')
|
|
|
table = config_.AD_THRESHOLD_AUTO_UPDATE_DATA.get('table')
|
|
|
now_date = datetime.datetime.today()
|
|
|
+ now_h = datetime.datetime.now().hour
|
|
|
now_min = datetime.datetime.now().minute
|
|
|
log_.info(f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d%H')}")
|
|
|
|
|
|
# 管理后台获取开启自动调整阈值开关的目标uv值
|
|
|
- ad_target_uv = get_ad_target_uv()
|
|
|
+ ad_target_uv = get_ad_target_uv(now_h=now_h)
|
|
|
log_.info(f"ad_target_uv: {ad_target_uv}")
|
|
|
if len(ad_target_uv) == 0:
|
|
|
return
|