fix: approve imported companies and clean duplicates

sql/cleanup_duplicate_companies_and_external_defaults.sql

@@ -0,0 +1,145 @@
+-- 测试/目标环境企业去重与外部导入默认状态修复。
+--
+-- 规则：仅合并名称在忽略大小写和所有空白后完全一致的有效企业；不会做简称、
+-- 有限公司后缀等近似匹配。保留企业优先级为：外部有效岗位数、有效岗位数、
+-- 已审核通过、创建时间、企业 ID。无实时关联的冗余企业才会物理删除；保留
+-- job_bak202607071415 历史快照中的原始 company_id，不将其作为实时引用。
+--
+-- 可重复执行：已删除企业不再进入映射；状态已符合默认值的岗位/企业不会重复更新。
+
+BEGIN;
+
+SELECT pg_advisory_xact_lock(hashtext('shz.cleanup_duplicate_companies_and_external_defaults'));
+
+CREATE TABLE IF NOT EXISTS "shz"."company_duplicate_cleanup_audit" (
+    "duplicate_company_id" BIGINT PRIMARY KEY,
+    "canonical_company_id" BIGINT NOT NULL,
+    "normalized_name" VARCHAR(500) NOT NULL,
+    "duplicate_company_name" VARCHAR(500) NOT NULL,
+    "cleaned_at" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "cleaned_by" VARCHAR(64) NOT NULL DEFAULT 'external-import-cleanup'
+);
+
+CREATE TEMP TABLE company_duplicate_merge_map ON COMMIT DROP AS
+WITH current_company AS (
+    SELECT c.company_id,
+           c.name,
+           c.status,
+           c.create_time,
+           LOWER(REGEXP_REPLACE(BTRIM(c.name), '[[:space:]]+', '', 'g')) AS normalized_name,
+           COUNT(j.job_id) FILTER (WHERE j.del_flag = '0') AS active_job_count,
+           COUNT(j.job_id) FILTER (WHERE j.del_flag = '0' AND j.external_import_flag = '1') AS active_external_job_count
+    FROM shz.company c
+    LEFT JOIN shz.job j ON j.company_id = c.company_id
+    WHERE c.del_flag = '0'
+      AND NULLIF(BTRIM(c.name), '') IS NOT NULL
+    GROUP BY c.company_id, c.name, c.status, c.create_time
+), ranked AS (
+    SELECT current_company.*,
+           FIRST_VALUE(company_id) OVER (
+               PARTITION BY normalized_name
+               ORDER BY active_external_job_count DESC,
+                        active_job_count DESC,
+                        CASE WHEN status = 1 THEN 0 ELSE 1 END,
+                        create_time NULLS LAST,
+                        company_id
+           ) AS canonical_company_id,
+           COUNT(*) OVER (PARTITION BY normalized_name) AS duplicate_group_size
+    FROM current_company
+)
+SELECT company_id AS duplicate_company_id,
+       canonical_company_id,
+       normalized_name
+FROM ranked
+WHERE duplicate_group_size > 1
+  AND company_id <> canonical_company_id;
+
+-- 若将来的数据在删除前已经关联了冗余企业，先无损迁移岗位归属。
+UPDATE shz.job j
+SET company_id = map.canonical_company_id,
+    update_by = 'external-import-cleanup',
+    update_time = CURRENT_TIMESTAMP
+FROM company_duplicate_merge_map map
+WHERE j.company_id = map.duplicate_company_id;
+
+-- 仅删除无实时关联记录的企业。所有业务关联表均纳入保护条件；若将来出现新的
+-- 关联数据，脚本会保留该企业而不是产生孤儿数据。
+CREATE TEMP TABLE deletable_duplicate_company ON COMMIT DROP AS
+SELECT map.duplicate_company_id,
+       map.canonical_company_id,
+       map.normalized_name
+FROM company_duplicate_merge_map map
+WHERE NOT EXISTS (SELECT 1 FROM shz.app_user_block_company t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.cms_outdoor_fair_booth_booking t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.cms_outdoor_fair_device t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.cms_outdoor_fair_job t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.cms_project t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.company_collection t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.company_contact t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.company_job_live t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.company_label t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.employee_confirm t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.fair_company t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.hr_company_talent_collect t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.interview_invitation t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.public_job_fair_company t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.public_job_fair_job t WHERE t.company_id = map.duplicate_company_id)
+  AND NOT EXISTS (SELECT 1 FROM shz.resume_access_log t WHERE t.company_id = map.duplicate_company_id);
+
+INSERT INTO shz.company_duplicate_cleanup_audit (
+    duplicate_company_id, canonical_company_id, normalized_name, duplicate_company_name, cleaned_at, cleaned_by
+)
+SELECT target.duplicate_company_id,
+       target.canonical_company_id,
+       target.normalized_name,
+       c.name,
+       CURRENT_TIMESTAMP,
+       'external-import-cleanup'
+FROM deletable_duplicate_company target
+JOIN shz.company c ON c.company_id = target.duplicate_company_id
+ON CONFLICT (duplicate_company_id) DO NOTHING;
+
+DELETE FROM shz.company c
+USING deletable_duplicate_company target
+WHERE c.company_id = target.duplicate_company_id;
+
+-- 外部岗位对用户可见；关联企业视为审核通过且上架。
+UPDATE shz.job
+SET is_publish = 1,
+    job_status = '0',
+    update_by = 'external-import-cleanup',
+    update_time = CURRENT_TIMESTAMP
+WHERE external_import_flag = '1'
+  AND del_flag = '0'
+  AND (is_publish IS DISTINCT FROM 1 OR job_status IS DISTINCT FROM '0');
+
+UPDATE shz.company c
+SET status = 1,
+    company_status = '0',
+    not_pass_reason = NULL,
+    update_by = 'external-import-cleanup',
+    update_time = CURRENT_TIMESTAMP
+WHERE c.del_flag = '0'
+  AND EXISTS (
+      SELECT 1
+      FROM shz.job j
+      WHERE j.company_id = c.company_id
+        AND j.external_import_flag = '1'
+        AND j.del_flag = '0'
+  )
+  AND (c.status IS DISTINCT FROM 1 OR c.company_status IS DISTINCT FROM '0' OR c.not_pass_reason IS NOT NULL);
+
+SELECT 'duplicate_companies_detected' AS metric, COUNT(*)::TEXT AS value FROM company_duplicate_merge_map
+UNION ALL
+SELECT 'duplicate_companies_deleted', COUNT(*)::TEXT FROM deletable_duplicate_company
+UNION ALL
+SELECT 'duplicate_companies_retained_for_references',
+       (SELECT COUNT(*) - COUNT(*) FILTER (WHERE duplicate_company_id IN (SELECT duplicate_company_id FROM deletable_duplicate_company)) FROM company_duplicate_merge_map)::TEXT
+UNION ALL
+SELECT 'active_external_jobs', COUNT(*)::TEXT FROM shz.job WHERE external_import_flag = '1' AND del_flag = '0'
+UNION ALL
+SELECT 'approved_active_external_companies', COUNT(*)::TEXT FROM shz.company c
+WHERE c.del_flag = '0' AND c.status = 1 AND c.company_status = '0'
+  AND EXISTS (SELECT 1 FROM shz.job j WHERE j.company_id = c.company_id AND j.external_import_flag = '1' AND j.del_flag = '0');
+
+COMMIT;