From 45fba5697e0757041521ad43df0d8d813a3be448 Mon Sep 17 00:00:00 2001
From: win <win@windeMacBook-Pro.local>
Date: Sun, 22 Mar 2026 22:01:06 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=20c?=
 =?UTF-8?q?ompany=20channel=20=E7=9A=84=20job=20=E4=B9=9F=E8=B5=B0=20push?=
 =?UTF-8?q?=5Fmapper=20+=20enrichment?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

company_cleaning_job → sync_company_jobs → store_batch(channel="company")
之前 channel="company" 的 job 配置没有 push_mapper，导致：
- 不会生成 push_data_list → 不调 push_to_remote
- 不触发 company_desc 补全

三个平台 channel="company" 配置加上对应的 push_mapper
---
 app/services/ingest/configs/boss.py    | 1 +
 app/services/ingest/configs/qcwy.py    | 1 +
 app/services/ingest/configs/zhilian.py | 1 +
 3 files changed, 3 insertions(+)

diff --git a/app/services/ingest/configs/boss.py b/app/services/ingest/configs/boss.py
index 0896b1c..86d9818 100644
--- a/app/services/ingest/configs/boss.py
+++ b/app/services/ingest/configs/boss.py
@@ -105,4 +105,5 @@ register(PlatformConfig(
     platform="boss", channel="company", data_type="job",
     table="boss_job",
     dedup_fields=(DedupFieldSpec(column="job_id", extractor=_extract_job_id),),
+    push_mapper=_build_boss_push,
 ))
diff --git a/app/services/ingest/configs/qcwy.py b/app/services/ingest/configs/qcwy.py
index 891e04c..51ac7b4 100644
--- a/app/services/ingest/configs/qcwy.py
+++ b/app/services/ingest/configs/qcwy.py
@@ -105,4 +105,5 @@ register(PlatformConfig(
         DedupFieldSpec(column="job_id", extractor=_extract_job_id),
         DedupFieldSpec(column="update_date_time", extractor=_extract_update_dt),
     ),
+    push_mapper=_build_qcwy_push,
 ))
diff --git a/app/services/ingest/configs/zhilian.py b/app/services/ingest/configs/zhilian.py
index 6a85ee8..7e7331c 100644
--- a/app/services/ingest/configs/zhilian.py
+++ b/app/services/ingest/configs/zhilian.py
@@ -78,4 +78,5 @@ register(PlatformConfig(
         DedupFieldSpec(column="number", extractor=_extract_number),
         DedupFieldSpec(column="first_publish_time", extractor=_extract_fpt),
     ),
+    push_mapper=_build_zhilian_push,
 ))