jddlmZmZddlmZddlmZmZdedede fdZ dedefd Z de fd Z dee fd Z ddededee fdZddedee fdZdee fdZdee fdZdee fdZdS))build_age_exists_clauseget_age_filter_threshold)logger) query_all query_oneschematablereturncd} tt|||dS#t$r"}tjd|||Yd}~dSd}~wwxYw)Nz SELECT 1 AS exists FROM information_schema.tables WHERE table_schema = %(s)s AND table_name = %(t)s LIMIT 1 )stz-Distribution table probe failed for %s.%s: %sF)boolr Exceptionrwarning)rr sqlexcs Q/home/longshao/multi-rider-rag/modules/dashboard/services/distribution_service.py _table_existsrss CIce#<#<==>>> FPUWZ[[[uuuuus$ AA  A age_clausecd|dS)Nz SELECT a."ajxx_ay" AS label, COUNT(DISTINCT a."ajxx_ajbh") AS value FROM "ywdata"."zq_zfba_ajxx" a WHERE a."ajxx_ay" IS NOT NULL zO GROUP BY a."ajxx_ay" ORDER BY value DESC LIMIT 10 )rs r_case_type_sqlrs       ctdkrttdddStttdd}|r|ddSttdddS)NrF)itemsdegradedaxT)rrrr)rowss rget_case_type_distributionr!"s!!Q&&">"#5#566EJJJ ^$;C$E$EFF G GD 25111~b1122 E EErc$d}t|S)Nz SELECT risk_level AS label, COUNT(*) AS value FROM "jcgkzx_monitor"."wcnr_score" WHERE risk_level IS NOT NULL GROUP BY risk_level ORDER BY value DESC rrs rget_risk_level_distributionr%, C S>>r risk_count metriclimitc^|dkrd}t|d|iSd}t|d|iS)N case_counta- SELECT a."ajxx_cbdw_mc" AS label, COUNT(DISTINCT a."ajxx_ajbh") AS value FROM "ywdata"."zq_zfba_ajxx" a WHERE a."ajxx_cbdw_mc" IS NOT NULL GROUP BY a."ajxx_cbdw_mc" ORDER BY value DESC LIMIT %(limit)s r*az SELECT p.ssfj AS label, COUNT(*) AS value FROM "jcgkzx_monitor"."wcnr_score" s JOIN "jcgkzx_monitor"."wcnr_target_pool" p ON p.zjhm = s.zjhm WHERE s.total_score >= 60 AND p.ssfj IS NOT NULL AND BTRIM(p.ssfj) <> '' GROUP BY p.ssfj ORDER BY value DESC, label LIMIT %(limit)s r#)r)r*rs rget_area_distributionr-7sK w./// C S7E* + ++rcR|dkrd}t|Sd}t|S)Nr,a SELECT sfz."yxx" AS label, COUNT(DISTINCT a."ajxx_ajbh") AS value FROM "ywdata"."zq_zfba_ajxx" a JOIN "ywdata"."zq_zfba_xyrxx" x ON x."ajxx_join_ajxx_ajbh" = a."ajxx_ajbh" JOIN "ywdata"."zq_zfba_wcnr_sfzxx" sfz ON sfz."sfzhm" = x."xyrxx_sfzh" WHERE sfz."yxx" IS NOT NULL GROUP BY sfz."yxx" ORDER BY value DESC LIMIT 10 ac SELECT sfz."yxx" AS label, COUNT(DISTINCT s.zjhm) AS value FROM "jcgkzx_monitor"."wcnr_score" s JOIN "ywdata"."zq_zfba_wcnr_sfzxx" sfz ON sfz."sfzhm" = s.zjhm WHERE s.total_score >= 60 AND sfz."yxx" IS NOT NULL GROUP BY sfz."yxx" ORDER BY value DESC LIMIT 10 r#)r)rs rget_school_rankingr/Ws7   ~~ C S>>rcd}t|}|r|Stjdt|d}t|S)Nu SELECT CASE WHEN EXTRACT(YEAR FROM AGE(CURRENT_DATE, csrq::DATE)) < 14 THEN '14岁以下' WHEN EXTRACT(YEAR FROM AGE(CURRENT_DATE, csrq::DATE)) < 16 THEN '14-16岁' ELSE '16-18岁' END AS label, COUNT(*) AS value FROM "jcgkzx_monitor"."wcnr_target_pool" WHERE csrq IS NOT NULL AND LENGTH(csrq) >= 8 GROUP BY label ORDER BY label z=Age distribution fallback triggered, primary returned %d rowsu  SELECT CASE WHEN EXTRACT(YEAR FROM AGE(CURRENT_DATE, TO_DATE(SUBSTR(zjhm, 7, 8), 'YYYYMMDD'))) < 14 THEN '14岁以下' WHEN EXTRACT(YEAR FROM AGE(CURRENT_DATE, TO_DATE(SUBSTR(zjhm, 7, 8), 'YYYYMMDD'))) < 16 THEN '14-16岁' ELSE '16-18岁' END AS label, COUNT(*) AS value FROM "jcgkzx_monitor"."wcnr_target_pool" WHERE LENGTH(zjhm) >= 14 AND SUBSTR(zjhm, 7, 8) ~ '^[0-9]{8}$' GROUP BY label ORDER BY label )rrinfolen)rr fallback_sqls rget_age_distributionr4wsW C S>>D   KOQTUYQZQZ[[[ L \ " ""rc$d}t|S)Nu SELECT CASE WHEN xb = '男' THEN '男' WHEN xb = '女' THEN '女' ELSE '未知' END AS label, COUNT(*) AS value FROM "jcgkzx_monitor"."wcnr_target_pool" GROUP BY label r#r$s rget_gender_distributionr6r&rc$d}t|S)Nz SELECT source_type AS label, COUNT(*) AS value FROM "jcgkzx_monitor"."wcnr_target_pool" GROUP BY source_type ORDER BY value DESC r#r$s rget_source_distributionr8s C S>>rN)r'r()r')shared.age_filterrrshared.config.configrshared.db.kingbaserrstrrrrdictr!listr%intr-r/r4r6r8rrrr@sOOOOOOOO''''''33333333 # c d     s s    FDFFFFT$Z,, , , $Z,,,,@sd4j@!#d4j!#!#!#!#Hddr