|
@@ -57,10 +57,11 @@ class PushScanThread:
|
|
|
for staff_user in self.service.user_relation_manager.list_staff_users(staff_id=self.staff_id):
|
|
|
staff_id = staff_user['staff_id']
|
|
|
user_id = staff_user['user_id']
|
|
|
- abtest_params = get_abtest_info(user_id).params
|
|
|
- if abtest_params.get('agent_push_enabled', 'false').lower() != 'true':
|
|
|
- logger.debug(f"User {user_id} not enabled agent push, skipping.")
|
|
|
- continue
|
|
|
+ # 通过AB实验配置控制用户组是否启用push
|
|
|
+ # abtest_params = get_abtest_info(user_id).params
|
|
|
+ # if abtest_params.get('agent_push_enabled', 'false').lower() != 'true':
|
|
|
+ # logger.debug(f"User {user_id} not enabled agent push, skipping.")
|
|
|
+ # continue
|
|
|
agent = self.service.get_agent_instance(staff_id, user_id)
|
|
|
should_initiate = agent.should_initiate_conversation()
|
|
|
user_tags = self.service.user_relation_manager.get_user_tags(user_id)
|