调度任务与可确认的外部业务入口进入主表；内部公共 Service 不单列。
Database usage dossier · 2026-08-04
df_risk_judgement_structure_cp 使用分析
覆盖 xinshu、xinshu-spider、small-platform、data_scout、fengniao(shuren)、python_projs、dataplatform、datacenter，按项目、具体任务或业务入口、读写类型、字段和用途梳理裁判文书结构化压缩表的真实调用链，调度状态与频率作为补充信息展示。
分析起因：该表数据量和表空间较大，正文、角色、审理过程、法院观点等字段包含大量文本或 JSON 内容；现有业务又基本通过裁判文书 id 点查。此次分析用于摸清真实字段依赖，为后续评估 key-value 存储、冷热字段拆分或其他按 ID 读取的存储重构方案提供依据。
01
核查口径与项目结论
xinshu-spider展示原则
以 DF 生产、DS 清洗和 Solr 索引任务为主，调度信息仅作为任务属性补充。
xinshu覆盖 ES、主体还原、caseflow、工行及客户数据推送任务。
fengniao(shuren)列出实际 Action/Job 触发方、调用链和前端 URL，调度状态与频率仅作为任务属性补充。
python_projs确认 1 个读写 role 的任务；源码注明 APS 每小时 15 分调度，在线状态尚未核实。
确认 1 个项目内 Quartz Job 和 18 个页面、资源接口、报告或监控入口，不使用 XXL-JOB。
datacenter确认 1 个 XXL 调度链、17 个监控事项类和 4 个按需接口入口。
| 项目 | 主清单数量 | 当前结论 | 备注 |
|---|---|---|---|
| xinshu-spider | 5 | 5 个已确认启动 | CP 表生产、DS 消费及二级索引 |
| xinshu | 4 | 4 个已确认启动 | ES、主体还原、caseflow 和工行推送 |
| fengniao(shuren) | 5 个触发方 | 配置已确认 | 3 个 Job 启用，2 个 Action 按需触发；已禁用任务移入“已排除” |
| 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)、python_projs、dataplatform、datacenter 的已确认调用链均直接或经统一访问层固定访问 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 | 压缩后的裁判文书正文 | DS 清洗、内容索引、详情展示和数据推送 | DS 裁判文书 ETL、工行及客户推送、数据平台与数据中台裁判详情 | 约 136.5 GiB 1.61 KiB/行 · 非空 99.9% · 占 46.9% |
role | 当事人、诉讼地位、胜败诉 JSON | 当事人反补、主体识别、胜败诉和图谱节点 | 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 |
已排除：
handi/JudgementPush、mayi/JudgementPush、tanji/JudgementPush、ExecutedEndPush、THSCleanTaskDBNew 未发现调度配置；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
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 存在游标监控逻辑，但不能替代在线调度状态证据。一次性目录中的历史处理脚本未进入主表。07
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 和测试类不进入主表。08
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 不作为入口单列。09
未发现使用的项目
| 项目 | 搜索范围 | 结果 | 结论边界 |
|---|---|---|---|
| small-platform | 表名、实体类、统一服务名、judgement_structure / structure_cp | 0 匹配 | 当前源码未使用该表。 |
| data_scout | 表名、实体类、统一服务名、judgement_structure / structure_cp | 0 匹配 | 当前源码未使用；未对历史发布 JAR 做字节码反编译。 |