调度任务与可确认的外部业务入口进入主表；内部公共 Service 不单列。
Database usage dossier · 2026-08-05
df_risk_judgement_structure_cp 使用分析
覆盖 xinshu、xinshu-spider、small-platform、data_scout、fengniao(shuren)、fengniao(master_qbb)、python_projs、dataplatform、datacenter，按项目、具体任务或业务入口、读写类型、字段和用途梳理裁判文书结构化压缩表的真实调用链，调度状态与频率作为补充信息展示。
分析起因：该表数据量和表空间较大，正文、角色、审理过程、法院观点等字段包含大量文本或 JSON 内容；现有业务又基本通过裁判文书 id 点查。此次分析用于摸清真实字段依赖，为后续评估 key-value 存储、冷热字段拆分或其他按 ID 读取的存储重构方案提供依据。
INDEX
全量任务索引
| 所属项目 | 具体任务 / 业务入口 | 操作 | 使用字段 | 核心使用方式 / 用途 | 触发类型 |
|---|---|---|---|---|---|
全部字段 |
不包含已排除任务和未发现使用的项目。
01
核查口径与项目结论
xinshu-spider展示原则
以 DF 生产、DS 清洗和 Solr 索引任务为主，调度信息仅作为任务属性补充。
xinshu覆盖 ES、主体还原、caseflow、工行及外部推数任务，8 个任务已确认启动。
fengniao(shuren)列出实际 Action/Job 触发方、调用链和前端 URL，调度状态与频率仅作为任务属性补充。
fengniao(master_qbb)源码不直接映射 CP 表；确认 10 个页面或接口入口通过 dataplatform 间接读取 CP。
python_projs确认 1 个读写 role 的任务；源码注明 APS 每小时 15 分调度，在线状态尚未核实。
确认 1 个项目内 Quartz Job 和 18 个页面、资源接口、报告或监控入口，不使用 XXL-JOB。
datacenter确认 1 个 XXL 调度链、17 个监控事项类和 4 个按需接口入口。
| 项目 | 主清单数量 | 当前结论 | 备注 |
|---|---|---|---|
| xinshu-spider | 5 | 5 个已确认启动 | CP 表生产、DS 消费及二级索引 |
| xinshu | 8 | 8 个已确认启动 | ES、主体还原、caseflow、工行推送及 4 个系统 crontab 推数任务 |
| fengniao(shuren) | 5 个触发方 | 配置已确认 | 3 个 Job 启用，2 个 Action 按需触发；已禁用任务移入“已排除” |
| fengniao(master_qbb) | 10 个入口 | 调用链已确认 | 均为页面或接口按需触发，经 dataplatform 间接读取 CP；无有效 CP 调度任务 |
| python_projs | 1 | 在线状态待核实 | 源码注明 APS 每小时 15 分调度，读写 role |
| dataplatform | 19 条明细 | 配置已确认 | 1 个 Quartz Job 启用，18 个页面、资源接口、报告或监控入口按需触发 |
| datacenter | 21 条明细 | 配置已确认 | 1 个 XXL 调度链覆盖 17 个监控 Provider，另有 4 个按需接口入口 |
| small-platform | 0 | 源码无 CP 表引用 | 其裁判文书上游清洗任务不直接使用本表 |
| data_scout | 0 | 源码无 CP 表引用 | 未对历史发布 JAR 做字节码反编译 |
路由事实：
xinshu-spider、xinshu、fengniao(shuren)、fengniao(master_qbb)、python_projs、dataplatform、datacenter 的已确认调用链均直接或经 dataplatform / 统一访问层固定访问 CP 表；注释中的“按 ID 切换新旧表”已不符合实际代码。02
关联关系与字段职责
DF 主表df_risk_judgement.id
→
结构表df_risk_judgement_structure_cp.id
←
DS 主表ds_risk_judgement.df_id
占用估算口径：表级统计约 8,895 万行、物理数据容量约 1.05 TiB、平均物理行长约 12.70 KiB。字段数据来自 40 个等距主键窗口共 3,901 行的
OCTET_LENGTH 抽样，8 个业务字段的逻辑载荷合计估算约 291.3 GiB；占比为字段逻辑载荷占比。InnoDB 页、行记录及大字段页外存储开销无法精确拆分到单列，因此下表不是各列的精确物理磁盘占用。| 字段 | 数据内容 / 来源与解析重点 | 主要用途 | 典型消费者 | 估算逻辑占用（抽样） |
|---|---|---|---|---|
content | 字段描述：裁判文书正文。 解析逻辑：来源于 SP 正文，通过字符有效性规则过滤无有效中文或异常问号文本；写入 CP 时使用 GZIP 压缩。 | DS 清洗、内容索引、详情展示和数据推送 | DS 裁判文书 ETL、工行及客户推送、数据平台与数据中台裁判详情 | 约 136.5 GiB 1.61 KiB/行 · 非空 99.9% · 占 46.9% |
role | 字段描述：当事人、诉讼地位、胜败诉 JSON。 解析逻辑：基于正文、标题、案号和爬取当事人，通过正则分段及角色 NLP 识别角色，补全诉讼地位与胜败诉，并还原可识别的打码名称。 | 当事人反补、主体识别、胜败诉和图谱节点 | DS 裁判文书 ETL、胜败诉结果回写、司法 caseflow、工行推送、树仁、数据平台及数据中台司法查询与监控 | 约 66.3 GiB 799.86 B/行 · 非空 99.8% · 占 22.7% |
price_result | 字段描述：涉案金额 JSON。 解析逻辑：将裁判结果、角色和被害人信息交给金额解析服务，保留有效金额并规范付款方、收款方、币种和单位。 | 金额索引、金额汇总、详情展示和客户推送 | 裁判文书 ES 同步、失信 DS ETL、工行推送、树仁、数据平台及数据中台司法查询 | 约 13.9 GiB 167.82 B/行 · 非空 47.6% · 占 4.8% |
related_case_code | 字段描述：关联案号 JSON。 解析逻辑：通过案号正则优先从审理经过提取，否则读取正文首段，并结合裁判结果识别；排除当前案号并记录来源区段。 | 案件链条、司法图谱和关联文书查询 | 司法 caseflow、客户推送、树仁司法关系查询、数据平台与数据中台裁判详情 | 约 1.9 GiB 22.87 B/行 · 非空 38.9% · 占 0.7% |
trial_result | 字段描述：裁判结果。 解析逻辑：先清理附件，再通过正文区段正则定位裁判主文并截除审判人员、书记员等尾部内容；通知书未识别到结果时使用专门规则补取。 | 裁判结果展示、监控结果和客户推送 | 工行推送、终本案件推送、树仁司法关系查询、数据平台与数据中台司法图谱 | 约 21.3 GiB 257.14 B/行 · 非空 92.9% · 占 7.3% |
trial_process | 字段描述：审理经过。 解析逻辑：截去裁判结果后，从正文主体起通过通用或案件类型正则定位审理过程结束位置；案件类型分支不超过法院观点起点。 | 裁判文书结构化解析和保存 | DF 裁判文书 ETL | 约 16.9 GiB 203.62 B/行 · 非空 69.7% · 占 5.8% |
court_opinion | 字段描述：法院观点。 解析逻辑：在已移除审理经过的正文中，先以裁判依据截定结束边界，再通过正则取最后一个法院观点起点后的说理内容。 | 裁判文书结构化解析和保存 | DF 裁判文书 ETL | 约 25.6 GiB 308.74 B/行 · 非空 64.2% · 占 8.8% |
law_clause | 字段描述：裁判条款。 解析逻辑：去除附件后，按案件类型通过法律依据关键词和正则提取援引条款，并用于校验裁判结果是否发生异常重叠。 | 条款解析、详情展示、监控结果和客户推送 | DF 裁判文书 ETL、工行推送、数据平台与数据中台裁判详情 | 约 9.0 GiB 108.45 B/行 · 非空 86.5% · 占 3.1% |
03
xinshu-spider：具体使用任务
| 具体任务 | 操作 | 使用字段 | 具体使用方式 | 调度状态与频率 | 代码路径 |
|---|---|---|---|---|---|
| DfRiskJudgementEtl | 写 | 全部核心结构字段 | 按 DF 裁判文书 id 写入 CP 同主键记录，保存正文、关联案号、审理结构、角色、裁判结果和金额等字段。 | 启动 每小时 35、55 分 0 35/20 * * * ? | task/etl/df/risk/DfRiskJudgementEtl.java |
| DfRiskJudgementUpdateEtl | 写 / 更新 | 全部核心结构字段 | 按 t_sp_judge_record 变更定位 DF 裁判文书 id，重新解析并更新 CP 同主键的全部核心字段。 | 启动 每小时 22 分 0 22 * * * ? | task/etl/df/risk/DfRiskJudgementUpdateEtl.java |
| DsRiskJudgementEtl | 读 | role、price_result、content | 按裁判文书 df_id = CP.id 查询，读取角色、金额和正文，生成 DS 主体、金额及正文信息。 | 启动 每小时 08 分 0 8 * * * ? | task/etl/ds/risk/DsRiskJudgementEtl.java |
| DsRiskDishonestyEtl | 读 | price_result | 按 gist_id = case_code、失信人名称 = 当事人名称匹配同案同人，再以裁判文书 df_id = CP.id 读取 price_result，汇总该当事人的有效金额。 | 启动 每小时 15 分 0 15 * * * ? | task/etl/ds/risk/DsRiskDishonestyEtl.java |
| DsRiskJudgementContentSSolrBuild | 读 | role | 按裁判文书 df_id = CP.id 读取角色，与案号、标题拼装裁判文书摘要二级索引。 | 启动 每小时 11、41 分 11 秒 11 11,41 * * * ? | task/solr/ds/risk/DsRiskJudgementContentSSolrBuild.java |
已排除：
DfRiskJudgementParseTtileJob 已 Deprecated 且调度配置为禁用，历史频率为每小时 35 分（0 35 */1 * * ?）；RiskJudgementDataProcessJob 属于一次性临时修复任务；DsRiskJudgementContentSolrBuild 已 Deprecated 且未发现调度配置；内部调用 Service 不作为任务单列。04
xinshu：具体使用任务
| 具体任务 | 操作 | 使用字段 | 具体使用方式 | 调度状态与频率 | 代码路径 |
|---|---|---|---|---|---|
| DsRiskJudgementToEsEtl | 读 | price_result | 按裁判文书 df_id = CP.id 读取金额结构，补充 ES 实体并写入 judgement_search_v* 索引。 | 启动 每小时 55 分 0 55 * * * ? | xinshu-spider/.../etl2/elasticsearch/DsRiskJudgementToEsEtl.java |
| DsRiskJudgementEntMaskEtl | 读 | role、price_result | 按裁判文书 df_id = CP.id 读取角色和金额，还原打码当事人并统计角色、金额及胜败诉数量。 | 启动 每小时 09 分 58 秒 58 9 * * * ? | xinshu-spider/.../etl2/dsRiskEnt/DsRiskJudgementEntMaskEtl.java |
| CpwsDsChangeEtl | 读 | role、related_case_code | 按裁判文书 df_id = CP.id 读取角色和关联案号，生成图谱当事人并筛选有效案件关系。 | 启动 每 2 小时 25 分 10 秒 10 25 0/2 * * ? | xinshu-spider/.../sfcaseflow/to_update_sf/step1/CpwsDsChangeEtl.java |
| JudgeStructDailyPushNewTask | 读 | content、law_clause、trial_result、related_case_code、role、price_result | 按裁判文书 df_id = CP.id 读取正文、条款、裁判结果、案件关系、角色和金额，生成工行推送数据。 | 启动 每天 01:10 0 10 1 * * ? * | xinshu-spider/.../tasks/JudgeStructDailyPushNewTask.java |
| mayi/JudgementPush | 读 | content | 按增量裁判文书的 df_id = CP.id 读取正文，生成蚂蚁裁判文书日增量推送文件。 | 启动 系统 crontab 每天凌晨 | xinshu-spider/.../push/mayi/JudgementPush.java |
| tanji/JudgementPush | 读 | content、related_case_code、role、price_result | 按增量裁判文书的 df_id = CP.id 读取正文、关联案号、角色和金额，清理角色字段后生成探迹推送数据。 | 启动 系统 crontab 每天凌晨 | xinshu-spider/.../push/tanji/JudgementPush.java |
| songji/ExecutedEndPush | 读 | content、trial_result | 先按终本案件 case_unique_id 关联 DS 裁判文书，再以一批 df_id IN CP.id 读取正文和裁判结果，随终本数据推送。 | 启动 系统 crontab 每天凌晨 | xinshu-spider/.../push/songji/ExecutedEndPush.java |
| THSCleanTaskDBNew | 读 | content、related_case_code、trial_result、law_clause、court_opinion、trial_process、role、price_result | 按一批 DS 裁判文书 df_id IN CP.id 读取结构化记录，将正文、关联案号、裁判结果、条款、审理过程、角色和金额等字段整理为同花顺推送数据。 | 启动 系统 crontab 每天凌晨 | xinshu-spider/.../push/tonghuashun/THSCleanTaskDBNew.java |
调度核查：mayi/JudgementPush、tanji/JudgementPush、songji/ExecutedEndPush、THSCleanTaskDBNew 不通过 XXL-JOB 调度，均由推数机器的系统 crontab 每天凌晨启动。
已排除：handi/JudgementPush 未确认有效调度；JudgeStructDailyPushNewTaskStockPush、JudgeStructDailyPushNewTaskStockInrPush、JudgeContentStockDailyPush 属于存量或一次性工具；抽象推送基类和查询辅助工具不作为任务单列。
05
fengniao(shuren)：实际触发入口
| 触发方 | 触发方式 / URL | 调度状态与频率 | 使用字段 / 用途 | 调用链与代码路径 |
|---|---|---|---|---|
| QueryPersonCpwsAction | GET /web/queryPersonCpws/pageQueryCountPOST /web/queryPersonCpws/pageQueryData | 前端按需触发 无固定频率 | 按裁判文书 df_id = CP.id 读取 related_case_code，在人名查询结果中返回关联案号。 | QueryPersonCpwsAction → PersonCpwsQueryService → DfRiskJudgementStructureAllService web/action/query/QueryPersonCpwsAction.java |
| MonitorJusticeRelateJob | 遍历链条监控企业，调用 updateJusticeRelate | 启用 每天 02:00 0 0 2 * * ? | 按企业关联裁判文书的 df_id = CP.id 读取 related_case_code、price_result、trial_result，更新司法链条监控数据。 | MonitorJusticeRelateJob → QueryJusticeRelateService → DfRiskJudgementStructureAllService utils/job/MonitorJusticeRelateJob.java |
| JusticeRelateChangeJob | 生成裁判链、最大裁判金额、执行链等动态；包含 zcxs_yzqybzxr、zcxs_zxl、zcxs_sfpm 分支 | 启用 每天 07:03 0 3 7 * * ? | 按动态涉及裁判文书的 df_id = CP.id 读取 related_case_code、price_result、trial_result，生成司法链条及资产线索动态。 | JusticeRelateChangeJob → QueryJusticeRelateService / QueryJusticeRelateByDsRiskService → DfRiskJudgementStructureAllService utils/job/JusticeRelateChangeJob.java |
| MonitorJusticeRelateAction | POST /web/monitor/justiceRelate/querySubmitPOST /web/monitor/justiceRelate/batchQuerySubmit | 前端按需触发 无固定频率 | 前端按企业名称和查询类型提交订单；异步任务再按裁判文书 df_id = CP.id 读取 related_case_code、price_result、trial_result。 | MonitorJusticeRelateAction → MonitorJusticeRelateService.createQuery → ProcessNoQueryJusticeRelateJob → MonitorJusticeRelateService.runQuery → DfRiskJudgementStructureAllService web/action/query/MonitorJusticeRelateAction.java |
| ProcessNoQueryJusticeRelateJob | 处理新下单但尚未查询的查链条、查资产订单，调用 runQuery | 启用 每分钟 0 0/1 * * * ? | 按待处理订单查询裁判文书，再以 df_id = CP.id 读取 related_case_code、price_result、trial_result，执行司法链及查资产查询。 | ProcessNoQueryJusticeRelateJob → MonitorJusticeRelateService → QueryJusticeRelateService → DfRiskJudgementStructureAllService utils/job/ProcessNoQueryJusticeRelateJob.java |
已排除：
AssetChangeJob 调度配置为 disabled=1，原频率为每天 01:45（0 45 1 * * ?），因此不进入主表。06
fengniao(master_qbb)：实际触发入口
| 任务类 / 外部触发类 | 操作 | 使用字段 | 具体使用方式 | 调度状态与频率 | 触发方式与调用链 |
|---|---|---|---|---|---|
| QueryAction.querySubmit 查公司 / 查文书首次查询 | 读 | role、price_result | queryType=1 查公司时，综合详情会查询裁判文书；queryType=5 且按企业名查文书时，也会进入同一新版列表链。下游按 DS 文书 df_id = CP.id 读取角色和金额，用于诉讼身份、胜败诉和涉案金额列表；人员或案号检索仍走旧检索链，未确认消费 CP。 | 页面按需触发 无固定频率 | POST /web/query/querySubmitQueryAction → QibabaQueryService.startEntQuery / startCpwsSearchQuery → courtFnSearchV2 / courtFnSearchCpws → CourtFengNiaoAppService → JudgeCommonService |
| QueryAction.orderBind 查公司 / 查文书订单重新查询 | 读 | role、price_result | 重新绑定历史订单；原订单为 queryType=1，或为 queryType=5 的企业名查文书时，会再次进入 CP 列表链，按 df_id = CP.id 取得角色和金额。 | 页面按需触发 无固定频率 | POST /web/query/orderBindQueryAction → QibabaQueryService.createQuery/startQuery → courtFnSearchV2 / courtFnSearchCpws → CourtFengNiaoAppService → JudgeCommonService |
| QueryAction.pageQueryCourtData 裁判文书列表分页 | 读 | role、price_result | 对查公司或查文书订单进行分页；查公司以及企业名查文书路径调用 courtFnSearchV2 或 courtFnSearchCpws，下游批量按 df_id IN CP.id 补充角色、胜败诉和金额。人员或案号路径使用旧检索链，不计为 CP 字段消费。 | 页面按需触发 无固定频率 | POST /web/query/pageQueryCourtDataQueryAction → /ws/repository/courtFnSearchV2 或 courtFnSearchCpws → CourtFengNiaoAppService → JudgeCommonService |
| DetailAction.judgeStructInfo 监控结果裁判文书结构详情 | 读 | content、role、price_result、related_case_code | 将页面传入的加密 DS 文书 ID 提交给裁判文书详情接口；下游取得 df_id 后读取 CP 的正文、角色、金额和关联案号。基础案情字段来自 DS/Solr，本链未使用 CP 的 law_clause、trial_result。 | 页面按需触发 无固定频率 | GET /web/detail/judgeStructInfoDetailAction → /ws/repository/detailJudgeStruct → JudgementIcbcDetailService → JudgeCommonService |
| DetailAction.content 裁判文书正文详情 | 读 | content、role、price_result、related_case_code | 校验订单或监控记录归属后调用同一详情接口；页面重点展示 CP 正文，同时服务链解析角色、金额和关联案号。本链未读取 CP 的 law_clause、trial_result。 | 页面按需触发 无固定频率 | GET /web/detail/contentDetailAction → /ws/repository/detailJudgeStruct → JudgementIcbcDetailService → JudgeCommonService |
| QueryAction.asyncExport 裁判文书列表异步导出 | 读 | role、price_result | 当 reportType=cpws 且为查公司或企业名查文书路径时，分页调用新版裁判文书列表接口，读取 CP 的角色和金额生成导出数据；条款和裁判结果的导出补充来自 Solr，不计为本入口对 CP 对应字段的消费。 | 前端导出触发 无固定频率 | POST /web/query/asyncExportQueryAction → asyncExportGetApiDataList → courtFnSearchV2 → CourtFengNiaoAppService → JudgeCommonService |
| QueryAction.appEntReportDownload 移动端企业报告生成 | 读 | role、price_result | 移动端企业报告会重新调用 courtFnSearchV2 获取裁判文书列表；下游按 df_id IN CP.id 补充角色、胜败诉和金额并写入报告。非查公司订单使用旧接口，不计为本入口的 CP 消费分支。 | 接口按需触发 无固定频率 | GET /web/query/appEntReportDownloadQueryAction → reportQueryAndDownload → /ws/repository/courtFnSearchV2 → CourtFengNiaoAppService → JudgeCommonService |
| QueryAction.entReportDownload Web 企业报告生成 | 读 | role、price_result | Web 企业报告异步重新汇总司法数据；查公司订单的裁判文书列表通过 courtFnSearchV2 读取 CP 的角色和金额用于报告明细，其他订单类型仍走旧接口。 | 前端导出触发 无固定频率 | POST /web/query/entReportDownloadQueryAction → reportQueryAndDownload → /ws/repository/courtFnSearchV2 → CourtFengNiaoAppService → JudgeCommonService |
| QueryAction.searchList 风险扫描裁判文书明细 | 读 | content、role、price_result、related_case_code | 仅在风险扫描的裁判文书明细类型下进入详情链；服务按 DS 文书 df_id = CP.id 读取正文，并解析角色、金额和关联案号。基础案情来自 DS/Solr，本链未使用 CP 的 law_clause、trial_result。 | 接口按需触发 无固定频率 | POST /web/query/searchListQueryAction → /ws/repository/riskWarnSearchList → RiskWarnSearchListService → JudgementIcbcDetailService → JudgeCommonService |
| QuerySFAction.sfAllDetail 司法案件图详情 | 读 | trial_result | 按司法图节点 vid 查询案件详情；下游遇到裁判文书节点且缺少结果时，以 DS 文书 df_id = CP.id 读取裁判结果补充图节点。 | 页面按需触发 无固定频率 | GET /web/sf/sfAllDetailQuerySFAction → QuerySFActionService → /ws/repository/sf_graph_detail → QueryDetailGraphNewService → ParseGraphDataTools → JudgeCommonService |
调用边界：master_qbb 源码未定义 CP 实体、Mapper 或表名 SQL；主表记录的是可确认会触发 dataplatform 读取 CP 的外部入口，因此操作标记为“读”，但实际数据库连接发生在 dataplatform。
调度核查：t_fn_sys_task 位于 ubm1.dataplatform；本项目有效 CP 使用入口均为页面或接口按需触发，没有进入主表的有效 CP 定时任务。
已排除：AppReportGenerateJob 已禁用，原频率每 5 秒；AssetChangeJob 已禁用，原频率每天 01:45；ProcessNoQueryJob 已禁用，原频率每分钟。
已排除：MonitorJusticeRelateJob 虽配置启用、每天 02:00，但当前分支 execute 业务主体已全部注释；ProcessNoQueryJusticeRelateJob、JusticeRelateChangeJob 等启用任务读取拆分后的 DS/链条业务表，不直接或经接口消费 CP，因此不列入本项目主表。
07
python_projs：具体使用任务
| 具体任务 | 操作 | 使用字段 | 具体使用方式 | 调度状态与频率 | 代码路径 |
|---|---|---|---|---|---|
| win_loss_update_struct.py | 读 / 更新 | role | 从 llm_result.df_risk_judgement_win_loss_llm 取得 run_status=2 的结果，按大模型记录 id = CP.id 读取 role；按当事人名称合并胜败诉结果，仅在结果变化时按同一 id 更新 role。 | 在线状态待核实 源码注明 APS 每小时 15 分 | daily_task/judgement/llm/win_loss_update_struct.py 游标：win_loss_llm_post_proc · 批量：1000 |
调度核查：源码部署注释注明该任务通过 APS 每小时 15 分运行，不使用 XXL-JOB；当前服务器不在可执行只读清单中，未取得在线 APS 配置或近期运行记录，因此不标记为“已确认启动”。
monitor_etl.py 存在游标监控逻辑，但不能替代在线调度状态证据。一次性目录中的历史处理脚本未进入主表。08
dataplatform：具体任务与业务入口
| 任务类 / 外部触发类 | 操作 | 使用字段 | 具体使用方式 | 调度状态与频率 | 触发方式与代码路径 |
|---|---|---|---|---|---|
| FnMonitorChangeDataJob | 读 | role、law_clause、trial_result | 按监控命中的 DS 裁判文书 df_id = CP.id 读取当事人角色、裁判条款和裁判结果，生成风鸟裁判文书监控变更明细。 | 启用 每天 02:00 0 0 2 * * ? | FnMonitorChangeDataJob → FnMonitorResultService → CpwsFnMonitorService → JudgementListFnService / JudgeCommonService utils/job/FnMonitorChangeDataJob.java |
| JudgementAction.judgeStructInfo | 读 | role、price_result、related_case_code、law_clause、trial_result | 根据页面传入的加密 DS 裁判文书 ID 查询 df_id，再以 df_id = CP.id 读取角色、金额、关联案号、裁判条款和裁判结果，展示结构化详情。 | 页面按需触发 无固定频率 | GET /web/repository/judgeStructInfoJudgementAction → JudgementIcbcDetailService → JudgeCommonService |
| JudgementAction.judgeDetail | 读 | content | 根据页面传入的加密 DS 裁判文书 ID 查询 df_id，再以 df_id = CP.id 读取正文并展示裁判文书详情。 | 页面按需触发 无固定频率 | GET /web/repository/judgeDetailJudgementAction → JudgementDetailService → JudgeCommonService |
| JudgementAction.content | 读 | content | 根据详情弹窗传入的 DS 裁判文书 ID 查询 df_id，再以 df_id = CP.id 读取正文并返回详情页面。 | 页面按需触发 无固定频率 | GET /web/repository/contentJudgementAction → JudgementDetailService → JudgeCommonService |
| JudgementDetailService 裁判文书详情资源 | 读 | content | 按接口传入的 DS 裁判文书 ID 查询 df_id，再以 df_id = CP.id 读取正文并返回裁判文书详情。 | 接口按需触发 无固定频率 | /ws/repository/judgementDetailJudgementDetailService → JudgeCommonService |
| JudgementIcbcListService 裁判文书检索 3.0 | 读 | role | 按检索结果对应的裁判文书 df_id = CP.id 读取 role，补充当事人、诉讼地位和查询主体立场。 | 接口按需触发 无固定频率 | /ws/repository/listJudgeStructJudgementIcbcListService → JudgeCommonService |
| JudgementIcbcListV4Service 裁判文书检索 4.0 | 读 | role | 按检索结果对应的裁判文书 df_id = CP.id 读取 role，补充当事人、诉讼地位和查询主体立场。 | 接口按需触发 无固定频率 | /ws/repository/listJudgeStruct_v4JudgementIcbcListV4Service → JudgementIcbcListService → JudgeCommonService |
| JudgementIcbcDetailService 裁判文书详情 3.0 | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 根据加密 DS 裁判文书 ID 取得 df_id，再按 df_id = CP.id 读取正文、角色、金额、关联案号、条款和裁判结果。 | 接口按需触发 无固定频率 | /ws/repository/detailJudgeStructJudgementIcbcDetailService → JudgeCommonService |
| JudgementIcbcDetailService 法院数据综合全量查询 | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 根据加密 DS 裁判文书 ID 取得 df_id，再按 df_id = CP.id 读取全部裁判文书详情字段。 | 接口按需触发 无固定频率 | /ws/repository/court_cpwsJudgementIcbcDetailService → JudgeCommonService |
| JudgementIcbcDetailService 裁判文书详情 4.0 | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 根据加密 DS 裁判文书 ID 取得 df_id，再按 df_id = CP.id 读取全部裁判文书详情字段。 | 接口按需触发 无固定频率 | /ws/repository/detailJudgeStruct_v4JudgementIcbcDetailService → JudgeCommonService |
| CourtFengNiaoAppService 查公司（风鸟）2.0 | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 列表按一批 df_id IN CP.id 读取角色和金额；详情按单个 df_id = CP.id 读取正文、条款、裁判结果、关联案号、角色和金额。 | 接口按需触发 无固定频率 | /ws/repository/courtFnSearchV2CourtFengNiaoAppService → RiskBirdJudgementServiceV2 → JudgeCommonService |
| CourtFengNiaoAppService 查文书（风鸟） | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 根据请求中的裁判文书查询类型，按 df_id 批量或单条读取 CP 表的列表、金额和详情字段。 | 接口按需触发 无固定频率 | /ws/repository/courtFnSearchCpwsCourtFengNiaoAppService → RiskBirdJudgementServiceV2 → JudgeCommonService |
| JudgDocThreeEelementSearchHDService 裁判文书三要素查询 HD | 读 | content | 按案号与公布日期/裁判日期定位 DF 裁判文书 id，再以 DF.id = CP.id 读取正文并返回标题与正文。 | 接口按需触发 无固定频率 | /ws/repository/judgDocThreeEelementSearchJudgDocThreeEelementSearchHDService → JudgeCommonService.queryTitleAndContent |
| NegativeReportAction 企业负面报告 | 读 | content | 按企业负面报告中的加密 DS 裁判文书 ID 查询 df_id，再以 df_id = CP.id 读取正文，写入 Word 或 Excel 报告的裁判文书明细。 | 前端导出触发 无固定频率 | /web/query/negativeReport/*NegativeReportAction → NegativeReport → JudgementContentQueryService |
| NegativePersonReportAction 个人负面报告 | 读 | content | 按个人负面报告中的加密 DS 裁判文书 ID 查询 df_id，再以 df_id = CP.id 读取正文，写入 Word 或 Excel 报告的裁判文书明细。 | 前端导出触发 无固定频率 | /web/query/negativePersonReport/*NegativePersonReportAction → NegativePersonReport2 → JudgementContentQueryService |
| ZsJudgementIcbcListService 织橙裁判文书列表 | 读 | content | 将 ES 结果中的 data_id 作为 DS 裁判文书 ID，批量取得 df_id，再按 df_id IN CP.id 读取正文并截取前 1000 字返回。 | 资源接口按需触发 无固定频率 | /ws/repository/listJudgeStruct_zsZsJudgementIcbcListService → JudgementContentQueryService → JudgeCommonService |
| GetEntMonitorInfo 企业监控变更详情 | 读 | content | 按监控变更记录中的 DS 裁判文书 dataId 查询 df_id，再以 df_id = CP.id 读取正文，补充变更前后详情。 | 监控详情请求触发 无固定频率 | GetEntMonitorInfo → JudgementContentQueryService → JudgeCommonService service/entmonitor/GetEntMonitorInfo.java |
| RiskWarnSearchListService 分页查询风险数据 | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 按风险预警明细中的裁判文书 dataId 查询 DS 记录和 df_id，再读取 CP 详情，返回案件基础信息与角色列表；当前内部详情服务同时解析金额、关联案号、条款和裁判结果。 | 接口按需触发 无固定频率 | /ws/repository/riskWarnSearchListRiskWarnSearchListService → RiskWarnService → JudgementRiskWarnService → JudgementIcbcDetailService |
| QueryGraphNewService 司法图谱查询 | 读 | trial_result | 图谱节点为裁判文书且缺少结果字段时，按 DS 裁判文书 ID 取得 df_id，再以 df_id = CP.id 读取裁判结果补充 result_content。 | 接口按需触发 无固定频率 | /ws/repository/sf_graphQueryGraphNewService → ParseGraphDataTools → JudgeCommonService |
调度与资源核查：FnMonitorChangeDataJob 已在 dataplatform.t_sys_task 核实为启用，频率为每天 02:00；18 个按需入口按具体 Action、资源 URL 或业务触发类逐行展示，相关 t_res.res_state=0 的资源已确认启用。项目使用自身 Quartz/任务表和在线请求机制，不使用 XXL-JOB。
字段口径：JudgeCommonService.getJudgementStructureRow/List 通过实体查询读取 CP 整行；表格“使用字段”表示业务实际消费或内部详情链实际解析的字段，不代表 SQL 只投影这些列。
已排除：JudgeCommonService、JudgementContentQueryService 等公共访问层不单列；已 Deprecated 的 QueryGraphService 和测试类不进入主表。
09
datacenter：具体任务与业务入口
| 任务类 / 外部触发类 | 操作 | 使用字段 | 具体使用方式 | 调度状态与频率 | 触发方式与代码路径 |
|---|---|---|---|---|---|
| CourtFengNiaoAppService.process dataType=cpws_search | 读 | role、price_result | 按裁判文书列表中的 DS 主表 ID 取得 df_id，再按一批 df_id IN CP.id 读取角色和金额，补充查询主体的诉讼身份、胜败诉及涉案金额。 | 代码入口已确认 路由配置待环境核实 | POST /ws/qy/courtFnSearchCourtFengNiaoAppService.handleLegacyCpwsSearch → DfRiskJudgementStructureCpMapper |
| CourtFengNiaoAppService.process dataType=appJudgeDetail | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 按详情请求的 DS 裁判文书 ID 取得 df_id，再以 df_id = CP.id 读取正文、角色、金额、关联案号、条款和裁判结果。 | 代码入口已确认 路由配置待环境核实 | POST /ws/qy/courtFnSearchCourtFengNiaoAppService.handleJudgementDetail → JudgementServiceImpl → JudgementStructureServiceImpl |
| CompanyDetailInfoService.process version=C7 · judgement | 读 | content、role、price_result、related_case_code、law_clause、trial_result | 按公司详情请求中的裁判文书 ID 查询 DS 记录和 df_id，再以 df_id = CP.id 读取全部详情字段，返回裁判文书明细。 | 接口按需触发 无固定频率 | POST /ws/gs/companyDetailInfoCompanyDetailInfoService → JudgementServiceImpl → JudgementStructureServiceImpl |
| QueryDetailGraphService.process 司法案件图详情 | 读 | trial_result | 案件流程节点为裁判文书且尚无结果字段时，按 DS 裁判文书 ID 取得 df_id，再以 df_id = CP.id 读取裁判结果，补充流程节点的 result_content。 | 接口按需触发 无固定频率 | POST /ws/qy/sfGraphDetailQueryDetailGraphService → SfajCaseFlowSearchService → SfajProcessCaseNodeConvert → JudgementStructureServiceImpl |
| B0803MonitorEventSourceProvider 新增执行裁判文书（被执行人） | 读 | role | 按 dataId 查询 DS 裁判文书后，立即以 df_id = CP.id 读取 CP 记录；优先使用 ds_risk_judgement_ent，主体未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 0 0/10 * * * ? | POST /job/monitor/event-increment/processMonitorRecentWeekIncrementService → B0803MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0804MonitorEventSourceProvider 新增胜诉裁判文书（原告） | 读 | role | 按 dataId 查询 DS 裁判文书后，立即以 df_id = CP.id 读取 CP 记录；优先使用 ds_risk_judgement_ent，主体未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 0 0/10 * * * ? | MonitorRecentWeekIncrementService → B0804MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0805MonitorEventSourceProvider 新增民事裁判文书（原告/上诉人胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0805MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0806MonitorEventSourceProvider 新增裁判文书 | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0806MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0807MonitorEventSourceProvider 新增民事裁判文书（原告/上诉人败诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0807MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0808MonitorEventSourceProvider 新增民事裁判文书（被告/被上诉人败诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0808MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0809MonitorEventSourceProvider 新增民事裁判文书（原告/上诉人部分胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0809MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0810MonitorEventSourceProvider 新增民事裁判文书（被告/被上诉人部分胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0810MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0811MonitorEventSourceProvider 新增行政裁判文书（原告/上诉人） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0811MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0812MonitorEventSourceProvider 新增行政裁判文书（被告/被上诉人） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0812MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0813MonitorEventSourceProvider 新增其他裁判文书 | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0813MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0814MonitorEventSourceProvider 新增刑事裁判文书（原告/上诉人胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0814MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0815MonitorEventSourceProvider 新增刑事裁判文书（被告人/被上诉人胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0815MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0816MonitorEventSourceProvider 新增刑事裁判文书（原告/上诉人败诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0816MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0817MonitorEventSourceProvider 新增刑事裁判文书（被告人/被上诉人败诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0817MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0818MonitorEventSourceProvider 新增刑事裁判文书（原告/上诉人部分胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0818MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
| B0819MonitorEventSourceProvider 新增刑事裁判文书（被告人/被上诉人部分胜诉） | 读 | role | 每条监控裁判文书均先以 df_id = CP.id 读取 CP 记录；主体表未匹配时解析 role 补充诉讼身份和胜败诉。 | 启用 每 10 分钟 | MonitorRecentWeekIncrementService → B0819MonitorEventSourceProvider → B0801MonitorEventSourceProvider |
调度核查：生产 XXL-JOB 2517 已启用，每 10 分钟调用 POST /job/monitor/event-increment/process；17 个 Provider 共用这一调度链。最近 5 次执行样本中 4 次成功，最新一次（2026-08-04 16:30）handle_code=500，因此“启用”仅表示调度配置状态，不代表最近一次运行成功。源码默认配置为 enabled=false，生产环境存在覆盖启用。
读取口径：B0801MonitorEventSourceProvider 对每条裁判文书都会先按 df_id = CP.id 读取 CP 整行，再优先使用 ds_risk_judgement_ent；只有主体未匹配时才解析 CP 的 role。selectById/selectBatchIds 和 JudgementStructureServiceImpl.queryOne 当前均读取 CP 整行，后者还会解析全部详情字段；表格“使用字段”表示最终业务用途，不代表底层只读取这些列。
接口边界：/ws/gs/companyDetailInfo、/ws/qy/sfGraphDetail 已在当前可访问配置中确认启用；/ws/qy/courtFnSearch 来自项目接口文档，但当前 dev_dc 配置未查到对应映射，需在目标环境再次核实。
已排除：B0801MonitorEventSourceProvider 是未注册为组件的公共父类，不单列；一次性 bootstrap、恢复、历史回填和测试环境 Job 当前均禁用；JudgementStructureServiceImpl 等内部公共 Service 不作为入口单列。
10
未发现使用的项目
| 项目 | 搜索范围 | 结果 | 结论边界 |
|---|---|---|---|
| small-platform | 表名、实体类、统一服务名、judgement_structure / structure_cp | 0 匹配 | 当前源码未使用该表。 |
| data_scout | 表名、实体类、统一服务名、judgement_structure / structure_cp | 0 匹配 | 当前源码未使用；未对历史发布 JAR 做字节码反编译。 |