APAC Tenant Monitoring and Scoring

1. 整体流程

目标是在 APAC 租户中找到更值得 Support / Sales 关注的对象。系统先确定租户范围，再补充组织、产品使用和 Billing 信息，最后计算分数与优先级。

流程同时处理两类租户：

• Active candidate：当前满足 APAC 存量口径的租户，执行完整的信息查询和打分。
• New signup：上一 CST 自然日注册的 APAC 租户，先做组织识别并进入评分；不查询集群和 Billing。

Dispatcher 每次运行先尝试同步完整的 HubSpot Company 目标列表，再从 DevOps DB 读取租户并发送到 Monitor SQS。HubSpot 同步逻辑位于独立模块；如果本次同步失败，租户处理不会被阻塞，Worker 会回退到最近一次成功快照。

2. 租户筛选条件

2.1 Active candidate

用于筛选 APAC 存量监控对象，并作为周报中 stock 类指标的范围。条件全部满足才会入选：

status = 'active'
AND kind = 'external'
AND sales_force_region = 'APAC'
AND country NOT IN ('JP')
AND plan NOT IN ('free_trial', 'new_user', 'closing')

2.2 Previous-day new signup

用于发现刚注册的新租户。时间范围是上一 CST 自然日，不是过去 24 小时；数据库时间仍按 UTC 存储，查询使用 CST 零点对应的 UTC 边界：

created_at >= 上一 CST 自然日 00:00 对应的 UTC 时间
AND created_at < 当前 CST 自然日 00:00 对应的 UTC 时间
AND country_region = 'APAC'
AND country NOT IN ('JP')

2.3 读取的基础租户字段

两类筛选都会读取以下字段，作为统一画像的基础：

id、created_at、updated_at、name、email、country、time_zone、status、kind、plan、alias、country_region、sales_owner_email、custom_id、segmentation、sales_force_region、sales_force_kind、tam_name。

3. Worker 查询哪些信息

3.1 Domain Intelligence

从租户邮箱中提取 domain，补充以下信息：

1. 空邮箱或无效 domain：记为 unknown。
2. Gmail、Outlook、QQ、163 等已知公共邮箱：直接记为 individual，不做网络查询。
3. 其他 domain：先读取缓存；缓存默认 30 天有效。
4. 缓存不存在或过期：通过 Web Search 识别组织、业务和 AI 属性。

教育机构不会因此停止处理。只要是 Active candidate，Domain Intelligence 完成后仍会继续查询集群和 Billing。

3.2 集群和使用情况

如果任意一个集群的 Clinic 查询失败，本轮 QPS 也写为 NULL，避免把不完整结果误认为真实的低 QPS。

3.3 Billing 信息

每次处理 Active candidate 都会刷新 Billing 信号：

已有的 billing_config_id 只用于优先定位，不能跳过信用卡验证。如果缓存配置无卡、失效或不存在，会重新扫描该租户的 active Billing configs。

3.4 New signup 的简化路径

New signup 只做 Domain Intelligence，然后按 HubSpot / Sales owner 规则写入对应租户表并触发评分。它不查询集群、QPS、信用卡或 credits。当同一租户后来进入 Active candidate 流程时，这些信息会被完整补齐。

4. 打分模型

total_score = Activity + Fit + Urgency，总分最高 100。三部分分别表示实际使用程度、目标画像匹配度和当前跟进紧迫度。

4.1 Activity，最高 40 分

以下信号累加，最后封顶 40 分：

集群阈值是累加的：1、3、10 个及以上集群分别贡献 10、18、23 分，再受 Activity 40 分上限约束。

4.2 Fit，最高 30 分

Fit 只选择一项，不累加：

空 domain 既不属于企业 domain，也不属于已识别的公共邮箱；例如 company_non_ai 但 domain 为空时会落到 3 分。

4.3 Urgency，最高 30 分

以下信号累加，最后封顶 30 分：

4.4 “已识别组织”的定义

以下五类属于 non-individual / known organization：

company_ai_core、company_ai_related、company_non_ai、institution_ai_related、institution_non_ai。

individual、unknown、空值和未识别分类不满足仅限组织的加急条件。

5. P0 / P1 / P2 优先级规则

优先级不是简单按总分排序。先判断所有 P0 条件；没有命中 P0，再判断 P1；其余为 P2。

5.1 P0：满足任意一项

• cluster_count >= 50，不限制组织分类；
• tenant_avg_qps >= 50；
• tenant_avg_qps >= 10 且为 company_ai_core；
• 创建不超过 24 小时且为 company_ai_core；
• plan = poc 且为 company_ai_core 或 company_ai_related；
• total_score >= 75 且为已识别组织。

5.2 P1：未命中 P0，并满足任意一项

• total_score >= 45；
• 创建不超过 48 小时且为 company_ai_related；
• 创建不超过 24 小时、为 company_non_ai，且使用非公共邮箱 domain；
• cluster_count >= 10 且为已识别组织；
• cluster_count >= 3、无信用卡，且为已识别组织。

5.3 P2

没有命中任何 P0 或 P1 条件。

6. 特殊处理与性能取舍

6.1 10 个及以上集群

• DevOps 集群列表仍读取全部分页，集群总数和 service plan 数量必须准确。
• 跳过 Clinic 的逐集群 QPS 查询，QPS 保存为 NULL。
• 评分时 NULL QPS 按数值 0 处理，不获得 QPS 分。
• 10–49 个集群的已识别组织至少为 P1；individual 或 unknown 不会只因达到 10 个集群而升级。

6.2 50 个及以上集群

所有分类直接为 P0，包括 individual 和 unknown。这样即使跳过 QPS，也不会低估超大规模租户。

6.3 三个已知超大租户

以下租户走强制 Sales-owned 快速路径：保留 P0，直接写入 apac_sales_owned_tenants 并从 Active 删除，同时跳过 Domain Intelligence、集群、Clinic、Billing 和后续评分：

• 1372813089209260919
• 1372813089209300444
• 1372813089209301246

6.4 HubSpot Target 与 Sales-owned 分流

除三个强制 Sales-owned 租户外，Worker 在完成必要画像后按以下顺序处理；顺序不可交换：

1. HubSpot Target 命中：写入 apac_active_tenants，正常计算 total_score，最终优先级强制为 P0。
2. 否则，sales_owner_email 命中配置的 APAC Sales 邮箱集合：写入 apac_sales_owned_tenants，分数和优先级均按普通规则计算。
3. 否则：写入 apac_active_tenants，按普通规则评分。

HubSpot 依次尝试 portal ID、account ID、唯一的非个人邮箱根域名和唯一的官网根域名匹配。个人邮箱域名和存在歧义的域名不会自动命中。租户切换分流表时，会在同一事务中从另一张表删除同一 tenant ID，并保留已有评分和人工跟进字段。

6.5 查询失败

Domain、集群和 Billing 失败互相隔离：某一类信息失败时尽量保留数据库中的上一次结果，并继续收集其他信号。错误写入 error_message，但错误本身不参与打分，也不会自动提升优先级。

7. 日报与周报口径

7.1 每日 Summary

日报使用确定性 SQL 统计，不重新调用 Domain Intelligence，也不重新计算分数。日报包含两个租户范围：

P0 和 P1 的总数及明细使用以上两个范围的并集，不是只统计 Active stock。因此，上一 CST 日的 new signup 在完成 Worker 和 Scoring 后，也会进入 P0 / P1 统计。

日报主要内容包括：

• 上一 CST 日 APAC new signups 总数；
• 其中真实 non-individual 数量；
• 其中 AI-related 数量；
• 统一 Summary 范围内的 P0、P1 数量；
• 最近 7 天有成功 import 的租户数和 import event 数。

P0、P1 和 import 明细区每类最多展示前 10 条。tenant_avg_qps = NULL 显示为 N/A，真实测量结果为零时显示 0。

7.2 Weekly Metrics

周报统计上一完整 CST 周（周日 00:00 到下一周日 00:00）的 new signups，并统计当前 APAC stock、P0 + P1、connected 和 paid 等指标。存量指标与 Active candidate 使用相同范围，signup 指标仍按 created_at 和 country_region 计算。

7.3 报告的数据边界

Summary 和 Weekly 只读取 apac_active_tenants，不会扫描 apac_sales_owned_tenants。最近 24 小时、最近 7 天等滚动窗口仍按实际时间长度计算；CST 只用于“自然日”和“完整周”的边界。

8. 数据结果与职责

当前实现由五个 Lambda 分别负责 Dispatcher、单租户 Worker、Scoring、日报和周报。Dispatcher 的 HubSpot 同步已拆到独立模块。Key Leads 功能、apac_key_leads 表和 key_lead 字段均已彻底移除。