feat(mes): 新增防伪防窜货功能模块

云

3 小时以前 b29d86d9ed34fd890eb14cb7a75f6ae4f7148865

feat(mes): 新增防伪防窜货功能模块

- 添加消费者扫码访问事件、防窜货规则配置、窜货预警记录、数据完整性校验记录四张数据表
- 新增防伪防窜货相关错误码常量定义
- 扩展出库单数据结构，增加经销商名称快照、实际出库时间和操作人字段
- 在批次服务中集成数据完整性校验，在创建和更新时生成完整性摘要
- 完善追溯码公开接口，增加消费者扫码事件记录和防伪验证信息展示
- 实现出库单页面查询和展示优化，支持按出库时间范围筛选
- 移除过期的测试页面配置文件

 .playwright-mcp/img.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-05-51-287Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-21T07-06-20-697Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-21T07-06-46-253Z.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-08-30-493Z.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-08-59-408Z.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-09-42-959Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-21T07-09-59-810Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-21T07-11-18-147Z.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-13-43-647Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-21T07-14-06-572Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-21T07-14-13-732Z.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-14-34-792Z.png

Binary files differ

 .playwright-mcp/page-2026-07-21T07-57-24-131Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-40-35-404Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-42-11-724Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-42-36-804Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-43-35-225Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-47-24-223Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-47-38-983Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-47-57-125Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-51-00-932Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-56-04-077Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T06-56-14-335Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T07-10-45-745Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T07-12-31-548Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T07-14-24-445Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T07-14-44-587Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-07-29T07-14-58-476Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-03T09-16-38-621Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-03T09-20-27-740Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-03T09-20-36-226Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-03T09-22-30-620Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-03T09-22-42-679Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-03T09-22-54-018Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-04T07-44-03-300Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-04T07-44-19-942Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-04T07-44-38-346Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T07-36-48-990Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T07-36-56-155Z.png

Binary files differ

 .playwright-mcp/page-2026-08-05T07-41-09-497Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T07-41-21-485Z.png

Binary files differ

 .playwright-mcp/page-2026-08-05T07-51-48-188Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T07-54-21-100Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T07-58-12-325Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T07-58-23-056Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T08-54-54-463Z.yml

 .playwright-mcp/page-2026-08-05T08-59-40-566Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-17-10-326Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-17-21-418Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-18-45-630Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-18-52-745Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-20-49-932Z.png

Binary files differ

 .playwright-mcp/page-2026-08-05T09-25-58-846Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-27-33-763Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-27-39-409Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-29-05-292Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-29-11-606Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-33-00-314Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-39-43-280Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-39-54-145Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-09-408Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-13-937Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-19-588Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-24-098Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-28-333Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-33-342Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-42-217Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-40-49-786Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-53-15-917Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-53-22-647Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-53-30-790Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-05T09-53-35-271Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-12T08-14-30-909Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-12T08-14-46-176Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-12T08-15-00-361Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-12T08-16-45-289Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-14T05-18-36-135Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-14T05-18-50-100Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-14T05-19-08-995Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-08-16-647Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-08-37-184Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-08-56-287Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-09-14-099Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-09-33-409Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-09-41-564Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-09-59-674Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-10-25-770Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-10-38-848Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-11-23-345Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-11-29-772Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-11-35-526Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-11-46-362Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-12-10-057Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-12-24-644Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-13-07-718Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-13-18-864Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-13-38-423Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-19-51-138Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-21-00-151Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-21-47-467Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-22-01-568Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-23-09-413Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-23-20-161Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-23-34-308Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-23-42-579Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-23-57-412Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-24-05-557Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-24-41-010Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-24-47-027Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-25-41-120Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-25-58-788Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-26-27-866Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-26-48-898Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-27-07-283Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-39-14-991Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-39-53-074Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-40-08-857Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-41-15-036Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-42-30-730Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-18T08-42-38-843Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-17-17-019Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-17-32-337Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-22-56-693Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-23-31-534Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-23-37-571Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-24-27-322Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-25-12-056Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-25-31-773Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-26-06-325Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-26-42-507Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-28-43-496Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-28-56-514Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-29-21-301Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-29-31-299Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-29-38-624Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-29-47-885Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-31-28-342Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-31-43-280Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-31-49-797Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-32-09-962Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-32-18-582Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-33-50-857Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-33-58-475Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-19T02-34-08-855Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-21T03-59-08-154Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-21T03-59-21-224Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-21T04-00-18-943Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-21T04-00-37-255Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-21T04-00-59-933Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-21T04-01-18-956Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T06-48-56-741Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T07-07-54-966Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T07-11-38-160Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T07-31-24-236Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T08-09-30-148Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T08-47-21-216Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-06-04-966Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-06-42-806Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-06-50-446Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-07-17-780Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-07-28-054Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-07-53-861Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-08-01-907Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-20-39-383Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-44-56-418Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-25T09-50-51-027Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-29-23-803Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-29-42-173Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-30-00-661Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-30-23-438Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-33-08-854Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-33-35-681Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-41-21-761Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-41-44-827Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-42-08-037Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-48-07-459Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-48-24-872Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-48-51-155Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T07-49-26-431Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T08-59-32-379Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T08-59-49-723Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-00-00-757Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-00-15-736Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-02-56-093Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-03-07-573Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-03-14-535Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-04-30-577Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-04-44-764Z.yml

ÎļþÒÑɾ³ý

 .playwright-mcp/page-2026-08-28T09-04-52-568Z.yml

ÎļþÒÑɾ³ý

 docs/anti_cross_region_integrity_integration.md

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,157 @@
# é˜²ä¼ªé˜²çªœè´§ç®¡ç† - å‰ç«¯è”调方案

## æ¶‰åŠé¡µé¢

- çªœè´§é¢„警管理页（新增菜单：防伪防窜货管理 â†’ çªœè´§é¢„警）
- æ‰«ç åœ°ç†åˆ†å¸ƒé¡µï¼ˆå¤ç”¨æ¶ˆè´¹è€…扫码统计接口）
- æ•°æ®å®Œæ•´æ€§æ ¡éªŒé¡µï¼ˆæ–°å¢žèœå•ï¼šé˜²ä¼ªé˜²çªœè´§ç®¡ç† â†’ æ•°æ®å®Œæ•´æ€§æ ¡éªŒï¼‰
- æ¶ˆè´¹è€…溯源 H5 é¡µé¢ï¼ˆæ­£å“éªŒè¯ä¿¡æ¯å±•ç¤ºå¢žå¼ºï¼‰

## ä¸šåŠ¡æµç¨‹ä¸Žæ•°æ®å¸¦å…¥

1. **窜货预警的产生**：消费者扫码溯源成功后，后端自动比对「扫码 IP å½’属地」与「袋码出库经销商地区」；不一致时自动生成预警记录。预警无需前端触发，只需提供查询、处理、统计入口。
2. **预警 â†’ æ˜Žç»†**：窜货预警分页列表中，可查看预警涉及的袋码/托盘码、批次号、经销商、扫码地区、预警类型与状态。
3. **完整性校验的入口**：数据完整性校验页输入「业务类型 + ä¸šåŠ¡ç¼–号」发起校验。业务编号可从对应业务列表（批次 / å‡ºåº“单 / æ‰«ç äº‹ä»¶ï¼‰å¸¦å…¥ï¼Œé¿å…æ‰‹å·¥å¡«å†™ã€‚
4. **H5 æ­£å“éªŒè¯**：溯源接口响应新增 `antiFake` åŒºå—，展示该追溯码累计扫码次数、首次/最近扫码时间，帮助消费者识别被多次扫描的疑似复制码。

## API

### 1. çªœè´§é¢„è­¦

| æ–¹æ³• | è·¯å¾„ | è¯´æ˜Ž | æƒé™ |
|------|------|------|------|
| GET | `/mes/trace-cross-region/page` | çªœè´§é¢„警分页 | `mes:trace-cross-region:query` |
| PUT | `/mes/trace-cross-region/handle` | å¤„理预警（已处理/误报） | `mes:trace-cross-region:handle` |
| GET | `/mes/trace-cross-region/summary` | é¢„警汇总（总数/待处理/跨省/跨市） | `mes:trace-cross-region:query` |
| GET | `/mes/trace-cross-region/statistics` | é¢„警分布统计（按省份/经销商/物料等分组） | `mes:trace-cross-region:query` |
| GET | `/mes/trace-cross-region/config` | æŸ¥è¯¢åˆ¤å®šè§„则配置 | `mes:trace-cross-region:query` |
| PUT | `/mes/trace-cross-region/config` | æ›´æ–°åˆ¤å®šè§„则（省/市粒度切换） | `mes:trace-cross-region:handle` |

**GET /page è¯·æ±‚参数：**

| å‚æ•° | ç±»åž‹ | å¿…å¡« | è¯´æ˜Ž |
|------|------|------|------|
| status | Integer | å¦ | çŠ¶æ€ï¼š10 å¾…处理 / 20 å·²å¤„理 / 30 è¯¯æŠ¥ |
| warningType | String | å¦ | é¢„警类型：CROSS_PROVINCE / CROSS_CITY |
| batchId | Long | å¦ | æ‰¹æ¬¡ç¼–号 |
| batchCode | String | å¦ | æ‰¹æ¬¡å·ï¼ˆæ¨¡ç³Šï¼‰ |
| bagCode | String | å¦ | è¢‹ç ï¼ˆæ¨¡ç³Šï¼‰ |
| clientId | Long | å¦ | ç»é”€å•†ç¼–号 |
| clientName | String | å¦ | ç»é”€å•†åç§°ï¼ˆæ¨¡ç³Šï¼‰ |
| eventTime[] | LocalDateTime[] | å¦ | é¢„警产生时间范围 |
| pageNo / pageSize | - | å¦ | åˆ†é¡µå‚æ•° |

**GET /page å“åº”字段：**

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| warningNo | String | é¢„警编号 |
| bagCode / palletCode | String | è¢‹ç  / æ‰˜ç›˜ç  |
| batchCode | String | æ‰¹æ¬¡å· |
| itemName | String | ç‰©æ–™åç§° |
| salesCode | String | å‡ºåº“单号 |
| clientName | String | ç»é”€å•†åç§° |
| dealerProvince / dealerCity | String | ç»é”€å•†çœä»½ / åŸŽå¸‚ |
| scanProvince / scanCity | String | æ‰«ç çœä»½ / åŸŽå¸‚ |
| warningType / warningTypeName | String | é¢„警类型 / ç±»åž‹åç§° |
| status / statusName | Integer / String | çŠ¶æ€ / çŠ¶æ€åç§° |
| handleRemark | String | å¤„理备注 |
| handleUserName | String | å¤„理人姓名 |
| handleTime / eventTime | LocalDateTime | å¤„理时间 / é¢„警产生时间 |

**PUT /handle è¯·æ±‚体：**

| å‚æ•° | ç±»åž‹ | å¿…å¡« | è¯´æ˜Ž |
|------|------|------|------|
| id | Long | æ˜¯ | é¢„警编号 |
| status | Integer | æ˜¯ | å¤„理状态：20 å·²å¤„理 / 30 è¯¯æŠ¥ |
| handleRemark | String | å¦ | å¤„理备注 |

**GET /summary è¯·æ±‚参数：** `startTime`、`endTime`（可选，LocalDateTime，格式 `yyyy-MM-dd HH:mm:ss`）

**GET /summary å“åº”字段：**

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| total / pending / handled / falseAlarm | Long | æ€»æ•° / å¾…处理 / å·²å¤„理 / è¯¯æŠ¥ |
| crossProvince / crossCity | Long | è·¨çœé¢„警数 / è·¨å¸‚预警数 |

**GET /statistics è¯·æ±‚参数：**

| å‚æ•° | ç±»åž‹ | å¿…å¡« | è¯´æ˜Ž |
|------|------|------|------|
| groupBy | String | æ˜¯ | åˆ†ç»„维度：scanProvince / scanCity / clientId / itemId / batchId |
| startTime / endTime | LocalDateTime | å¦ | æ—¶é—´èŒƒå›´ |

**GET /statistics å“åº”字段：** `name`（分组名）、`count`（数量），按数量倒序。

**GET /config å“åº”字段：** `warningLevel`（PROVINCE è·¨çœ / CITY è·¨å¸‚）、`remark`。

**PUT /config è¯·æ±‚参数：** `warningLevel`（必填，仅支持 PROVINCE / CITY）。

### 2. æ•°æ®å®Œæ•´æ€§æ ¡éªŒ

| æ–¹æ³• | è·¯å¾„ | è¯´æ˜Ž | æƒé™ |
|------|------|------|------|
| GET | `/mes/trace-integrity/verify` | æ ¡éªŒæ•°æ®å®Œæ•´æ€§ï¼ˆé‡ç®—摘要比对） | `mes:trace-integrity:verify` |
| GET | `/mes/trace-integrity/page` | å®Œæ•´æ€§è®°å½•åˆ†é¡µ | `mes:trace-integrity:query` |

**GET /verify è¯·æ±‚参数：**

| å‚æ•° | ç±»åž‹ | å¿…å¡« | è¯´æ˜Ž |
|------|------|------|------|
| bizType | String | æ˜¯ | ä¸šåŠ¡ç±»åž‹ï¼šBATCH æ‰¹æ¬¡ / SALES é”€å”®å‡ºåº“ / SCAN æ¶ˆè´¹è€…扫码 |
| bizId | Long | æ˜¯ | ä¸šåŠ¡è®°å½•ç¼–号 |

**GET /verify å“åº”字段：**

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| bizType / bizId / bizCode | - | ä¸šåŠ¡ç±»åž‹ / ç¼–号 / ç¼–码 |
| matched | Boolean | æ˜¯å¦æ ¡éªŒé€šè¿‡ |
| storedHash | String | å­˜å‚¨çš„摘要 SHA-256 |
| currentHash | String | å½“前数据重算摘要 SHA-256 |
| bagSetHash | String | ä»… BATCH æ ¡éªŒè¿”回：批次当前袋码集合摘要（供人工比对袋码防篡改） |
| message | String | æ ¡éªŒè¯´æ˜Ž |

**GET /page è¯·æ±‚参数：** `bizType`、`bizId`、`bizCode`（均可选）。

**GET /page å“åº”字段：** `id`、`bizType`、`bizId`、`bizCode`、`contentHash`、`eventTime`。

### 3. æ¶ˆè´¹è€…溯源 H5 å“åº”新增区块

溯源接口（`/public/mes/trace/query`）响应新增 `antiFake` åŒºå—（有扫码记录才返回）：

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| antiFake.scanCount | Long | è¯¥è¿½æº¯ç ç´¯è®¡æ‰«ç æ¬¡æ•° |
| antiFake.firstScanTime | LocalDateTime | é¦–次扫码时间 |
| antiFake.lastScanTime | LocalDateTime | æœ€è¿‘扫码时间 |

## å­—段展示规则

| å­—段 | å±•ç¤ºä½ç½® | è¯´æ˜Ž |
|------|----------|------|
| é¢„警类型 | çªœè´§é¢„警列表、详情 | CROSS_PROVINCE=跨省 / CROSS_CITY=跨市 |
| çŠ¶æ€ | çªœè´§é¢„警列表、详情 | å¾…处理 / å·²å¤„理 / è¯¯æŠ¥ï¼Œåˆ—表建议按状态着色 |
| ç»é”€å•† vs æ‰«ç åœ°åŒº | çªœè´§é¢„警详情 | ä¸¤åˆ—对比展示，异常字段高亮 |
| å¤„理备注 | çªœè´§é¢„警详情 | å¤„理时可填写 |
| matched | æ•°æ®å®Œæ•´æ€§æ ¡éªŒé¡µ | æ ¡éªŒç»“果，通过显示绿色、不通过显示红色并给出两个摘要值 |

## ä¸šåŠ¡è§„则说明

| åœºæ™¯ | è§„则 |
|------|------|
| åˆ¤å®šç²’度 | ç®¡ç†ç«¯å¯åœ¨ `PROVINCE`（跨省）与 `CITY`（跨市）间切换；`CITY` ç²’度下若扫码市与经销商市都为空则退回省级判断 |
| ä¸äº§ç”Ÿé¢„警的情况 | æ‰¹æ¬¡ç å…¥å£æ‰«ç ã€æ‰«ç æ— åœ°åŒºï¼ˆIP è§£æžå¤±è´¥ï¼‰ã€è¢‹ç æœªå‡ºåº“、经销商无地区信息 |
| é¢„警处理 | ä»…「待处理」状态可处理为「已处理」或「误报」；处理后不可再次处理 |
| å®Œæ•´æ€§è¦†ç›–范围 | åªæ ¡éªŒä¸å¯å˜æ ¸å¿ƒå­—段，正常业务流转（草稿→生产中→完成、出库后状态更新）不会导致校验误报 |
| æœªç”Ÿæˆæ‘˜è¦ | è‹¥ä¸šåŠ¡æ•°æ®æœªç”Ÿæˆè¿‡æ‘˜è¦ï¼ˆå¦‚历史数据），`verify` è¿”回"数据完整性记录不存在"错误码 |

## æ³¨æ„äº‹é¡¹

- çªœè´§é¢„警分页的 `eventTime` ä¼ ä¸¤ä¸ªå€¼ï¼ˆ`eventTime[0]` èµ·ã€`eventTime[1]` æ­¢ï¼‰è¡¨ç¤ºæ—¶é—´èŒƒå›´ã€‚
- `statistics` çš„ `groupBy` åªèƒ½ä¼ ç™½åå•å†…的维度，传其他值后端会拒绝。
- æ•°æ®å®Œæ•´æ€§æ ¡éªŒçš„业务编号建议从对应列表带入，SCAN ç±»åž‹çš„ bizId ä¸ºæ¶ˆè´¹è€…扫码事件主键，可在扫码统计记录中查看。
- æ¶ˆè´¹è€… H5 ç«¯ `antiFake` åŒºå—无扫码记录时不返回该字段，前端需做空值兜底。
- çªœè´§é¢„警、完整性校验菜单需后端执行菜单 SQL åŽæ‰ä¼šåœ¨ç®¡ç†åŽå°å¯è§ã€‚

 docs/consumer_trace_scan_statistics_api.md

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,111 @@
# æ¶ˆè´¹è€…扫码访问事件与统计 - å‰ç«¯è”调方案

## æ¶‰åŠé¡µé¢

- H5 æ¶ˆè´¹è€…溯源查询页（仅由后端自动记录访问事件）
- MES ç®¡ç†ç«¯æ¶ˆè´¹è€…扫码访问统计页

## ä¸šåŠ¡æµç¨‹ä¸Žæ•°æ®å¸¦å…¥

1. æ¶ˆè´¹è€…访问 H5 æº¯æºæŸ¥è¯¢æŽ¥å£æ—¶ï¼ŒåŽç«¯ä½¿ç”¨åŽŸå§‹æ‰«ç å†…容解析追溯码。
2. æŸ¥è¯¢æˆåŠŸåŽè®°å½•å…¥å£ç±»åž‹å’Œç”Ÿäº§æ‰¹æ¬¡ç¼–号；查询失败时记录失败事件及失败编码。
3. äº‹ä»¶è®°å½•å¤±è´¥ä¸ä¼šå½±å“ H5 æº¯æºæŸ¥è¯¢ç»“果。
4. ç®¡ç†ç«¯ç»Ÿè®¡æŽ¥å£æŒ‰è®¿é—®æ—¶é—´ç­›é€‰ï¼›åˆ†å¸ƒæŽ¥å£ä»…支持 `sourceType`、`success`、`channel`、`province`、`city`、`batchId` å…­ä¸ªå›ºå®šç»´åº¦ï¼Œä¸å…è®¸ä¼ å…¥ä»»æ„æ•°æ®åº“字段。
5. `channel` æ ¹æ® User-Agent å½’类为微信、支付宝或浏览器；`province`、`city` æ ¹æ®å®¢æˆ·ç«¯ IP å½’属地解析，解析不到时展示“未知”。

## API

### H5 æº¯æºæŸ¥è¯¢ï¼ˆå·²æœ‰æŽ¥å£ï¼Œæ–°å¢žäº‹ä»¶è®°å½•ï¼‰

| æ–¹æ³• | è·¯å¾„ | è¯´æ˜Ž |
|---|---|---|
| GET | `/public/mes/trace/query` | æŸ¥è¯¢è¿½æº¯ä¿¡æ¯ï¼ŒåŒæ—¶è®°å½•æˆåŠŸæˆ–失败访问事件 |

请求参数 `code` ä¸ºè¿½æº¯ç æˆ–包含 `code` å‚数的二维码 URL。事件记录失败时接口仍按原有规则返回查询结果或业务错误。

### ç®¡ç†ç«¯æ±‡æ€»

| æ–¹æ³• | è·¯å¾„ | æƒé™ |
|---|---|---|
| GET | `/mes/trace-consumer-scan/summary` | `mes:trace-consumer-scan:query` |

可选参数：`startTime`、`endTime`，格式为 `yyyy-MM-dd HH:mm:ss`，统计范围为开始时间（含）至结束时间（不含）。

响应字段：`total` æ€»è®¿é—®æ¬¡æ•°ã€`success` æˆåŠŸæ¬¡æ•°ã€`failed` å¤±è´¥æ¬¡æ•°ã€`uniqueBatchCount` æ—¶é—´èŒƒå›´å†… `batch_id` éžç©ºçš„去重批次数量。该口径与 `batchId` åˆ†å¸ƒä¸­çš„非“未知”分组数量一致。

### ç®¡ç†ç«¯è¶‹åŠ¿

| æ–¹æ³• | è·¯å¾„ | æƒé™ |
|---|---|---|
| GET | `/mes/trace-consumer-scan/trend` | `mes:trace-consumer-scan:query` |

可选参数同汇总。响应为数组，字段包括 `date`、`total`、`success`、`failed`。

### ç®¡ç†ç«¯åˆ†å¸ƒ

| æ–¹æ³• | è·¯å¾„ | æƒé™ |
|---|---|---|
| GET | `/mes/trace-consumer-scan/distribution` | `mes:trace-consumer-scan:query` |

请求参数：

| å‚æ•° | ç±»åž‹ | å¿…å¡« | å…è®¸å€¼ | è¯´æ˜Ž |
|---|---|---|---|---|
| `groupBy` | String | æ˜¯ | `sourceType`、`success`、`channel`、`province`、`city`、`batchId` | åˆ†ç»„维度；后端采用固定白名单映射，非法值拒绝 |
| `startTime` | DateTime | å¦ | `yyyy-MM-dd HH:mm:ss` | å¼€å§‹æ—¶é—´ï¼ˆå«ï¼‰ |
| `endTime` | DateTime | å¦ | `yyyy-MM-dd HH:mm:ss` | ç»“束时间（不含） |

响应数组字段：`name` åˆ†ç»„名称、`count` è®¿é—®æ¬¡æ•°ã€‚空值分组名称返回“未知”。

## å­—段展示规则

| å­—段 | å±•ç¤ºä½ç½® | è¯´æ˜Ž |
|---|---|---|
| `total`、`success`、`failed`、`uniqueBatchCount` | æ±‡æ€»å¡ç‰‡ | å±•ç¤ºè®¿é—®æ€»é‡ã€æˆåŠŸ/失败量及非空批次去重数量 |
| `date`、`total`、`success`、`failed` | è¶‹åŠ¿å›¾ | åŽç«¯å·²è¡¥é½æŸ¥è¯¢åŒºé—´å†…无数据日期，数值为 0 |
| `name`、`count` | åˆ†å¸ƒå›¾/表格 | æ ¹æ®é€‰æ‹©çš„固定分组维度展示 |

## ä¸šåŠ¡è§„则说明

| åœºæ™¯ | è§„则 |
|---|---|
| æˆåŠŸæŸ¥è¯¢ | è®°å½• `success=1`、入口类型、渠道、省份、城市及批次编号 |
| è¿½æº¯ç ä¸ºç©ºæˆ–不存在 | è®°å½• `success=0` å’Œå¤±è´¥ç¼–码 |
| è®°å½•äº‹ä»¶å¼‚常 | ä»…记录后端日志，不改变溯源接口返回结果 |
| IP ä¸Ž User-Agent | IP ä¸Ž User-Agent ä»…保存 SHA-256 æ‘˜è¦ï¼›æ¸ é“、省份、城市只保存归类/归属地名称 |
| åˆ†ç»„参数 | åŽç«¯åªæŽ¥å—固定白名单值，非法值返回参数错误 |

## å‰ç«¯é¡µé¢æŽ¥å…¥

### èœå•ä¸Žè·¯ç”±

- èœå•å·²åˆå§‹åŒ–（`sql/mysql/mes_trace_consumer_scan_menu.sql`），挂在 MES ç³»ç»Ÿ(5100) ä¸‹ï¼Œé¡µé¢è·¯å¾„ `mes/trace-consumer-scan/index`，组件名建议 `MesTraceConsumerScan`。
- é¡µé¢æŸ¥è¯¢æƒé™æ ‡è¯†ï¼š`mes:trace-consumer-scan:query`。登录用户需被授予该权限才能看到菜单并调用接口。
- ç»Ÿè®¡æŽ¥å£ç»Ÿä¸€è·¯å¾„前缀 `/mes/trace-consumer-scan`，共三个：`/summary`、`/trend`、`/distribution`。

### é¡µé¢åŒºå—建议

| åŒºå— | æ•°æ®æ¥æº | å±•ç¤ºå»ºè®® |
|---|---|---|
| æ±‡æ€»å¡ç‰‡ | `/summary` | æ€»è®¿é—®ã€æˆåŠŸã€å¤±è´¥ã€éžç©ºæ‰¹æ¬¡åŽ»é‡æ•° |
| è¶‹åŠ¿å›¾ | `/trend` | æŒ‰æ—¥æŠ˜çº¿/柱状，展示总量与成功/失败；后端已补齐无数据日期为 0 |
| åˆ†å¸ƒå›¾ | `/distribution` | æŒ‰ `sourceType/success/channel/province/city/batchId` åˆ‡æ¢åˆ†ç»„，展示名称与访问量 |

### æ—¶é—´èŒƒå›´äº¤äº’

- ä¸‰ä¸ªæŽ¥å£å‡å¯é€‰ä¼  `startTime`/`endTime`（格式 `yyyy-MM-dd HH:mm:ss`），范围左闭右开。
- é¡µé¢æä¾›é»˜è®¤æ—¶é—´èŒƒå›´ï¼ˆå¦‚è¿‘ 30 å¤©ï¼‰ï¼Œç”±å‰ç«¯åœ¨è¯·æ±‚时传入；不传则后端按已有数据区间统计。

### ç©ºæ•°æ®å¤„理

- `trend` ç©ºæ•°æ®æ—¶è¿”回补 0 çš„日期序列，前端直接渲染即可。
- `distribution` ç©ºæ•°æ®æ—¶è¿”回空数组，页面展示"暂无扫码数据"。
- `province`/`city` è§£æžä¸åˆ°æ—¶åˆ†ç»„名为"未知"。

## æ³¨æ„äº‹é¡¹

- éœ€è¦å…ˆæ‰§è¡Œ `sql/mysql/mes_trace_consumer_scan_event.sql` åˆ›å»ºäº‹ä»¶è¡¨ã€‚
- éœ€è¦æ‰§è¡Œ `sql/mysql/mes_trace_consumer_scan_menu.sql` åˆå§‹åŒ–菜单权限（若使用 `ruoyi-vue-pro` ç­‰å…¶å®ƒåº“，注意同步表结构）。
- ç®¡ç†ç«¯é¡µé¢éœ€è¦æ ¹æ®æƒé™æŽ§åˆ¶èœå•å’ŒæŽ¥å£è®¿é—®ã€‚
- ç»Ÿè®¡æŽ¥å£çš„时间参数应使用后端约定格式，结束时间不包含边界时刻。
- ä¸éœ€è¦æ–°å¢žå‰ç«¯ä¸Šä¼ æˆ–事件写入接口。

 docs/qr_trace_modal_url_integration.md

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,65 @@
# ç®¡ç†ç«¯ã€ŒæŸ¥çœ‹äºŒç»´ç ã€é¢„览统一为 H5 é“¾æŽ¥ - å‰ç«¯è”调方案

## èƒŒæ™¯

管理端批次/袋码/托盘页面的「查看二维码」弹窗，二维码预览此前直接用**码值编号**（如 `PB-00000102`、`BAG-00000102`）生成，而打印/导出标签的二维码内容是 **H5 æº¯æºé“¾æŽ¥**（`http://host:port/trace.html?code=xxx`）。两者不一致，导致扫码效果不同，易造成误解。

本次改动让管理端「查看二维码」预览/下载的二维码内容与打印标签完全一致（均为 H5 é“¾æŽ¥ï¼‰ã€‚

## æ¶‰åŠé¡µé¢

- ç”Ÿäº§æ‰¹æ¬¡ç®¡ç†ï¼ˆæ‰¹æ¬¡ã€ŒæŸ¥çœ‹äºŒç»´ç ã€ï¼‰
- è¢‹ç ç®¡ç†ï¼ˆè¢‹ç ã€ŒæŸ¥çœ‹äºŒç»´ç ã€ï¼‰
- æ‰˜ç›˜ç®¡ç†ï¼ˆæ‰˜ç›˜ã€ŒæŸ¥çœ‹äºŒç»´ç ã€ï¼‰

以上三处共用组件 `src/views/mes/pro/components/qr-trace-modal.vue`，仅需改动该共享组件一次。

## API

| æ–¹æ³• | è·¯å¾„ | è¯´æ˜Ž |
|------|------|------|
| GET | /admin-api/mes/trace-config/qr-config | èŽ·å¾—溯源 H5 é¡µé¢åŸºç¡€åœ°å€ï¼ˆäºŒç»´ç å†…容前缀） |

**请求参数：** æ— ï¼ˆç™»å½•æ€å³å¯è®¿é—®ï¼‰

**响应示例：**

```json
{
  "code": 0,
  "data": {
    "traceBaseUrl": "http://192.168.0.10:48080/trace.html"
  },
  "msg": ""
}
```

**字段说明：**

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| traceBaseUrl | String | æº¯æº H5 é¡µé¢åŸºç¡€åœ°å€ï¼Œå¯¹åº”后端配置 `mes.trace-base-url`；为空时前端二维码回退为纯码值 |

## å‰ç«¯ä¿®æ”¹ç‚¹

### 1. æ–°å¢ž API æ¨¡å—

新增 `src/api/mes/trace/config.ts`，封装 `getQrConfig()` è°ƒç”¨ `/mes/trace-config/qr-config`。

### 2. å…±äº«ç»„件 qr-trace-modal.vue

- å¼¹çª—打开时拉取一次 `traceBaseUrl`（会话内缓存，避免重复请求）。
- äºŒç»´ç å±•ç¤ºå†…容由「码值编号」改为「H5 é“¾æŽ¥ã€ï¼š`traceBaseUrl + "?code=" + encodeURIComponent(码值)`。
- ä¸‹è½½ / æ‰“印二维码使用二维码图片 base64，内容随之变为 H5 é“¾æŽ¥ï¼Œä¸ŽåŽç«¯ `QrCodeImageUtils` å¯¼å‡ºçš„标签一致。
- è¾“入框反查兼容：扫描枪扫到打印标签的完整 H5 é“¾æŽ¥æ—¶ï¼Œè‡ªåŠ¨ä»Žé“¾æŽ¥ä¸­æå– `code` å‚数再进行追溯查询；直接输入码值编号同样可用。
- `traceBaseUrl` ä¸ºç©ºï¼ˆæœªé…ç½® `mes.trace-base-url` çš„环境）时，二维码回退为纯码值，行为与后端一致，不报错。

## æ•°æ®å¸¦å…¥è¯´æ˜Ž

- ã€ŒæŸ¥çœ‹äºŒç»´ç ã€å…¥å£æ²¿ç”¨çŽ°æœ‰é€»è¾‘：批次用 `code`（正式批次号）优先、其次 `tempCode`；袋码/托盘码同理。弹窗内展示的追溯信息仍按码值编号查询，二维码展示内容才拼接为 H5 é“¾æŽ¥ã€‚

## æ³¨æ„äº‹é¡¹

1. åŽç«¯éœ€**重新编译并重启**后才提供新接口 `/mes/trace-config/qr-config`；重启前前端调用返回 404，`traceBaseUrl` ä¸ºç©ºï¼ŒäºŒç»´ç ä»æ˜¾ç¤ºçº¯ç å€¼ï¼ˆé™çº§å¯ç”¨ï¼Œä¸å½±å“åŽŸæœ‰åæŸ¥åŠŸèƒ½ï¼‰ã€‚
2. äºŒç»´ç å†…容的 H5 é“¾æŽ¥ä¸Ž `mes.trace-base-url` é…ç½®å¼ºç›¸å…³ï¼Œä¸åŒçŽ¯å¢ƒï¼ˆlocal/test/生产）地址不同，前端不硬编码。
3. äºŒç»´ç é«˜å®¹é”™çº§åˆ«ã€å°ºå¯¸ç­‰å±•ç¤ºæ ·å¼ä¸å˜ã€‚

 docs/sales_outbound_traceability_integration.md

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,120 @@
# å‡ºåº“流通管理 - å‰ç«¯è”调方案

## æ¶‰åŠé¡µé¢

- é”€å”®å‡ºåº“单列表页
- é”€å”®å‡ºåº“单新增/编辑页
- é”€å”®å‡ºåº“拣货页
- é”€å”®å‡ºåº“单详情页
- æ‰˜ç›˜ç /袋码流向追踪页（可在销售出库明细区域实现）

## ä¸šåŠ¡æµç¨‹ä¸Žæ•°æ®å¸¦å…¥

1. CRM å®¢æˆ·ä½œä¸ºç»é”€å•†ä¸»æ•°æ®ï¼Œåˆ›å»ºé”€å”®å‡ºåº“单时通过 `clientId` é€‰æ‹©ç»é”€å•†ã€‚
2. å‘货通知单生成销售出库单时，沿用发货通知单的 `clientId`，作为本次出库的经销商。
3. é”€å”®å‡ºåº“单提交后进入待拣货状态，扫描托盘码或袋码调用扫码接口，系统自动解析码类型、定位生产批次和合格库存。
4. æ‰«ç æˆåŠŸåŽç”Ÿæˆé”€å”®å‡ºåº“明细，记录托盘码或袋码、批次、仓库、库区、库位和拣货数量。
5. æ‰§è¡Œæ‹£è´§åŽå ç”¨åº“存，执行最终出库时扣减库存并生成库存事务流水。
6. å‡ºåº“完成时固化经销商名称、实际出库时间和执行出库操作人，作为历史流向快照。
7. å‰ç«¯æŸ¥è¯¢é”€å”®å‡ºåº“明细时，通过托盘码或袋码明细关联销售出库单，即可反查工厂、批次、经销商和实际出库信息。

## API

| æ–¹æ³• | è·¯å¾„ | è¯´æ˜Ž |
|------|------|------|
| POST | `/mes/wm/product-sales/create` | åˆ›å»ºé”€å”®å‡ºåº“单 |
| PUT | `/mes/wm/product-sales/update` | ä¿®æ”¹è‰ç¨¿é”€å”®å‡ºåº“单 |
| PUT | `/mes/wm/product-sales/submit` | æäº¤é”€å”®å‡ºåº“单 |
| POST | `/mes/wm/product-sales/scan` | æ‰«ææ‰˜ç›˜ç æˆ–袋码生成拣货明细 |
| PUT | `/mes/wm/product-sales/stock` | æ‰§è¡Œæ‹£è´§å¹¶å ç”¨åº“å­˜ |
| PUT | `/mes/wm/product-sales/shipping` | å¡«å†™æ‰¿è¿å•†å’Œè¿è¾“单号 |
| PUT | `/mes/wm/product-sales/finish` | æ‰§è¡Œæœ€ç»ˆå‡ºåº“、扣减库存并固化流向信息 |
| GET | `/mes/wm/product-sales/page` | åˆ†é¡µæŸ¥è¯¢é”€å”®å‡ºåº“单，支持实际出库时间范围筛选 |
| GET | `/mes/wm/product-sales/get` | æŸ¥è¯¢é”€å”®å‡ºåº“单详情 |
| GET | `/mes/wm/product-sales-detail/list-by-line` | æŸ¥è¯¢æŒ‡å®šé”€å”®å‡ºåº“行的托盘/袋码明细 |
| GET | `/mes/wm/transaction/page` | æŸ¥è¯¢å‡ºåº“库存流水 |

### åˆ›å»º/修改请求参数

| å‚æ•° | ç±»åž‹ | å¿…å¡« | è¯´æ˜Ž |
|------|------|------|------|
| clientId | Long | æ˜¯ | CRM å®¢æˆ·ç¼–号，同时作为经销商编号 |
| salesDate | DateTime | æ˜¯ | è®¡åˆ’或业务出库日期 |
| noticeId | Long | å¦ | æ¥æºå‘货通知单编号 |
| contactName | String | å¦ | æ”¶è´§äºº |
| contactTelephone | String | å¦ | è”系电话 |
| contactAddress | String | å¦ | æ”¶è´§åœ°å€ |
| carrier | String | å¦ | æ‰¿è¿å•† |
| shippingNumber | String | å¦ | è¿è¾“单号 |

### æ‰«ç è¯·æ±‚参数

| å‚æ•° | ç±»åž‹ | å¿…å¡« | è¯´æ˜Ž |
|------|------|------|------|
| salesId | Long | æ˜¯ | é”€å”®å‡ºåº“单编号 |
| scanContent | String | æ˜¯ | æ‰˜ç›˜ç ã€è¢‹ç æˆ–可解析的追溯码 |
| quantity | Decimal | å¦ | æœ¬æ¬¡æ‹£è´§æ•°é‡ï¼›ä¸ä¼ æ—¶æŒ‰é”€å”®å‡ºåº“行数量处理 |

### æ‰«ç å“åº”重点字段

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| scanType | String | `PALLET` æ‰˜ç›˜ç ï¼Œ`BAG` è¢‹ç  |
| scanContent | String | åŽŸå§‹æ‰«æå†…容 |
| itemId | Long | ç‰©æ–™ç¼–号 |
| batchId | Long | ä»“库批次编号 |
| batchCode | String | ä»“库批次号 |
| materialStockId | Long | åº“存记录编号 |
| warehouseId | Long | ä»“库编号 |
| locationId | Long | åº“区编号 |
| areaId | Long | åº“位编号 |
| scanQuantity | Decimal | æœ¬æ¬¡æ‰«ææ•°é‡ |
| alreadyScanned | Boolean | æ˜¯å¦å·²æ‰«æè¿‡ |
| detailId | Long | é”€å”®å‡ºåº“明细编号 |

### é”€å”®å‡ºåº“单响应新增字段

| å­—段 | ç±»åž‹ | è¯´æ˜Ž |
|------|------|------|
| clientName | String | ç»é”€å•†åç§°å¿«ç…§ï¼›å‡ºåº“完成时固化 |
| outboundTime | DateTime | å®žé™…执行出库时间；未完成时为空 |
| outboundUserId | Long | æ‰§è¡Œæœ€ç»ˆå‡ºåº“操作人的用户编号；未完成时为空 |
| outboundUserName | String | æ‰§è¡Œæœ€ç»ˆå‡ºåº“操作人的名称；未完成或用户已删除时为空 |

## å­—段展示规则

| å­—段 | å±•ç¤ºä½ç½® | è¯´æ˜Ž |
|------|----------|------|
| clientName | å‡ºåº“单列表、详情、流向追踪 | å±•ç¤ºå‡ºåº“完成时固化的经销商名称；草稿可展示 CRM å½“前名称 |
| outboundTime | å‡ºåº“单列表、详情 | ä»…已完成单据展示实际出库时间 |
| outboundUserId | å‡ºåº“单详情 | æ“ä½œäººç”¨æˆ·ç¼–号 |
| outboundUserName | å‡ºåº“单列表、详情、流向追踪 | åŽç«¯å·²é€šè¿‡ç³»ç»Ÿç”¨æˆ·æŽ¥å£è½¬æ¢ä¸ºæ“ä½œäººåç§°ï¼Œå‰ç«¯ç›´æŽ¥å±•ç¤º |
| scanType | æ‰«ç ç»“果、出库明细 | åŒºåˆ†æ‰˜ç›˜ç å’Œè¢‹ç  |
| scanContent | æ‰«ç ç»“果、出库明细 | å±•ç¤ºå®žé™…扫描的追溯码 |
| batchCode | å‡ºåº“明细、流向追踪 | å±•ç¤ºç”Ÿäº§æ‰¹æ¬¡å· |
| warehouseName | å‡ºåº“明细、流向追踪 | å±•ç¤ºå‡ºåº“仓库 |
| quantity | å‡ºåº“明细、库存流水 | å±•ç¤ºæ‹£è´§æ•°é‡ï¼›æµæ°´å‡ºåº“数量为负数 |
| bizCode | åº“存流水 | å…³è”销售出库单号 |

## ä¸šåŠ¡è§„则说明

| åœºæ™¯ | è§„则 |
|------|------|
| ç»é”€å•†æ¥æº | `clientId` å¤ç”¨ CRM å®¢æˆ·ç¼–号，不新建重复的经销商主数据 |
| æ‰˜ç›˜ç æ‰«æ | æ‰˜ç›˜å¿…须已绑定生产批次，否则不允许销售出库 |
| è¢‹ç æ‰«æ | è¢‹ç å¿…须能定位生产批次和合格库存 |
| é‡å¤æ‰«æ | è¿”回 `alreadyScanned=true`，前端提示已扫描，不重复生成明细 |
| åº“存不足 | æ‰«ç æˆ–拣货校验失败时，不生成出库明细或库存占用 |
| æ‹£è´§ | æ‹£è´§é˜¶æ®µåªå ç”¨åº“存，不减少实际在库数量 |
| æœ€ç»ˆå‡ºåº“ | ä»…待出库状态允许执行，成功后扣减库存并写入库存流水 |
| å‡ºåº“å¿«ç…§ | æœ€ç»ˆå‡ºåº“时保存经销商名称、实际出库时间和操作人编号，后续 CRM æ”¹åä¸å½±å“åŽ†å²æµå‘ |
| æµå‘追踪 | é€šè¿‡é”€å”®å‡ºåº“明细中的 `palletCodeId` æˆ– `bagCodeId` åæŸ¥å‡ºåº“单、批次、仓库和经销商 |
| å–消单据 | æœªå®Œæˆå•æ®å¯å–消并释放库存占用；已完成单据不可取消 |

## æ³¨æ„äº‹é¡¹

- éƒ¨ç½²å‰éœ€æ‰§è¡Œ `sql/mysql/mes_wm_sales_outbound_traceability.sql`，为销售出库主表增加流向快照字段；脚本应在确认目标数据库后逐条执行。
- è¯¥è¿ç§»è„šæœ¬ä¸åŒ…含 `tenant_id` å­—段，符合当前项目数据库规范。
- å½“前代码记录的是操作人用户编号，前端应通过系统用户信息接口显示操作人名称。
- `/mes/wm/product-sales/finish` æ˜¯å®žé™…扣库存和产生库存流水的时点，扫码成功不代表已经完成出库。
- æŸ¥è¯¢æ‰˜ç›˜ç æˆ–袋码流向时，应优先使用出库明细中的码编号及销售出库单状态过滤，避免将已取消单据作为有效流向。

 sql/mysql/mes_dealer_menu_init.sql

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,67 @@
-- MES ç»é”€å•†ç®¡ç†èœå•åˆå§‹åŒ–
-- ç»é”€å•†å¤ç”¨ CRM å®¢æˆ·ä¸»æ•°æ®ï¼Œä¸æ–°å¢žä¸šåŠ¡è¡¨å’ŒåŽç«¯æƒé™ã€‚
-- æ‰§è¡Œå‰è¯·ç¡®è®¤å½“前数据库为项目实际业务库。

SET @dealer_menu_id = (SELECT id FROM system_menu
                        WHERE parent_id = 5780 AND path = 'dealer' AND deleted = b'0'
                        ORDER BY id LIMIT 1);

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6740, '经销商管理', '', 2, 11, 5780, 'dealer', 'ep:user', 'crm/customer/index', 'MesWmDealer',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE @dealer_menu_id IS NULL
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6740);

SET @dealer_menu_id = COALESCE(@dealer_menu_id, (SELECT id FROM system_menu WHERE id = 6740 AND deleted = b'0'));

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6741, '查询经销商', 'crm:customer:query', 3, 1, @dealer_menu_id, '', '', '', NULL,
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE EXISTS (SELECT 1 FROM system_menu WHERE id = @dealer_menu_id AND deleted = b'0')
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6741);

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6742, '创建经销商', 'crm:customer:create', 3, 2, @dealer_menu_id, '', '', '', NULL,
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE EXISTS (SELECT 1 FROM system_menu WHERE id = @dealer_menu_id AND deleted = b'0')
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6742);

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6743, '更新经销商', 'crm:customer:update', 3, 3, @dealer_menu_id, '', '', '', NULL,
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE EXISTS (SELECT 1 FROM system_menu WHERE id = @dealer_menu_id AND deleted = b'0')
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6743);

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6744, '删除经销商', 'crm:customer:delete', 3, 4, @dealer_menu_id, '', '', '', NULL,
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE EXISTS (SELECT 1 FROM system_menu WHERE id = @dealer_menu_id AND deleted = b'0')
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6744);

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6745, '导出经销商', 'crm:customer:export', 3, 5, @dealer_menu_id, '', '', '', NULL,
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE EXISTS (SELECT 1 FROM system_menu WHERE id = @dealer_menu_id AND deleted = b'0')
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6745);

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6746, '导入经销商', 'crm:customer:import', 3, 6, @dealer_menu_id, '', '', '', NULL,
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE EXISTS (SELECT 1 FROM system_menu WHERE id = @dealer_menu_id AND deleted = b'0')
  AND NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6746);

SET @dealer_menu_id = NULL;

 sql/mysql/mes_trace_anti_cross_region_init.sql

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
-- é˜²ä¼ªé˜²çªœè´§ç®¡ç†ï¼šçªœè´§é¢„è­¦ + æ•°æ®å®Œæ•´æ€§æ ¡éªŒ å»ºè¡¨è„šæœ¬ï¼ˆä¸ä½¿ç”¨ tenant_id）
-- æ‰§è¡Œå‰è¯·ç¡®è®¤ç›®æ ‡æ•°æ®åº“为项目实际业务库，并逐条执行。

-- 1. é˜²çªœè´§è§„则配置表（key-value é£Žæ ¼ï¼Œé¢„置判定粒度配置）
CREATE TABLE IF NOT EXISTS mes_trace_anti_config (
    id BIGINT NOT NULL AUTO_INCREMENT COMMENT '主键',
    config_key VARCHAR(64) NOT NULL COMMENT '配置项Key',
    config_value VARCHAR(255) NOT NULL COMMENT '配置值',
    remark VARCHAR(255) DEFAULT NULL COMMENT '配置说明',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    creator VARCHAR(64) DEFAULT NULL COMMENT '创建者',
    updater VARCHAR(64) DEFAULT NULL COMMENT '更新者',
    deleted BIT(1) NOT NULL DEFAULT 0 COMMENT '是否删除',
    PRIMARY KEY (id),
    KEY idx_anti_config_key (config_key)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='防窜货规则配置';

-- é¢„置判定粒度：PROVINCE è·¨çœ / CITY è·¨å¸‚
INSERT INTO mes_trace_anti_config (config_key, config_value, remark)
SELECT 'warning_level', 'PROVINCE', '窜货判定粒度：PROVINCE è·¨çœ / CITY è·¨å¸‚'
WHERE NOT EXISTS (SELECT 1 FROM mes_trace_anti_config WHERE config_key = 'warning_level' AND deleted = b'0');

-- 2. çªœè´§é¢„警记录表
CREATE TABLE IF NOT EXISTS mes_trace_cross_region_warning (
    id BIGINT NOT NULL AUTO_INCREMENT COMMENT '主键',
    warning_no VARCHAR(64) DEFAULT NULL COMMENT '预警编号',
    bag_code_id BIGINT DEFAULT NULL COMMENT '袋码编号',
    bag_code VARCHAR(64) DEFAULT NULL COMMENT '袋码',
    pallet_code_id BIGINT DEFAULT NULL COMMENT '托盘码编号',
    pallet_code VARCHAR(64) DEFAULT NULL COMMENT '托盘码',
    batch_id BIGINT DEFAULT NULL COMMENT '生产批次编号',
    batch_code VARCHAR(64) DEFAULT NULL COMMENT '批次号',
    item_id BIGINT DEFAULT NULL COMMENT '物料编号',
    item_code VARCHAR(64) DEFAULT NULL COMMENT '物料编码',
    item_name VARCHAR(128) DEFAULT NULL COMMENT '物料名称',
    sales_id BIGINT DEFAULT NULL COMMENT '销售出库单编号',
    sales_code VARCHAR(64) DEFAULT NULL COMMENT '出库单号',
    client_id BIGINT DEFAULT NULL COMMENT '经销商编号',
    client_name VARCHAR(128) DEFAULT NULL COMMENT '经销商名称',
    dealer_province VARCHAR(64) DEFAULT NULL COMMENT '经销商省份',
    dealer_city VARCHAR(64) DEFAULT NULL COMMENT '经销商城市',
    scan_province VARCHAR(64) DEFAULT NULL COMMENT '扫码省份',
    scan_city VARCHAR(64) DEFAULT NULL COMMENT '扫码城市',
    warning_type VARCHAR(32) DEFAULT NULL COMMENT '预警类型：CROSS_PROVINCE / CROSS_CITY',
    scan_event_id BIGINT DEFAULT NULL COMMENT '关联消费者扫码事件编号',
    status TINYINT NOT NULL DEFAULT 10 COMMENT '状态：10 å¾…处理 / 20 å·²å¤„理 / 30 è¯¯æŠ¥',
    handle_user_id BIGINT DEFAULT NULL COMMENT '处理人编号',
    handle_time DATETIME DEFAULT NULL COMMENT '处理时间',
    handle_remark VARCHAR(255) DEFAULT NULL COMMENT '处理备注',
    event_time DATETIME NOT NULL COMMENT '预警产生时间',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    creator VARCHAR(64) DEFAULT NULL COMMENT '创建者',
    updater VARCHAR(64) DEFAULT NULL COMMENT '更新者',
    deleted BIT(1) NOT NULL DEFAULT 0 COMMENT '是否删除',
    PRIMARY KEY (id),
    KEY idx_cross_region_status (status),
    KEY idx_cross_region_batch (batch_id),
    KEY idx_cross_region_bag (bag_code_id),
    KEY idx_cross_region_sales (sales_id),
    KEY idx_cross_region_event_time (event_time),
    KEY idx_cross_region_scan_province (scan_province)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='窜货预警记录';

-- 3. æ•°æ®å®Œæ•´æ€§æ ¡éªŒè®°å½•è¡¨
CREATE TABLE IF NOT EXISTS mes_trace_integrity_record (
    id BIGINT NOT NULL AUTO_INCREMENT COMMENT '主键',
    biz_type VARCHAR(32) NOT NULL COMMENT '业务类型：BATCH æ‰¹æ¬¡ / SALES é”€å”®å‡ºåº“ / SCAN æ¶ˆè´¹è€…扫码',
    biz_id BIGINT NOT NULL COMMENT '业务记录编号',
    biz_code VARCHAR(64) DEFAULT NULL COMMENT '业务编码（批次号/出库单号/追溯码）',
    content_hash CHAR(64) NOT NULL COMMENT '内容摘要 SHA-256',
    event_time DATETIME NOT NULL COMMENT '摘要生成时间',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    creator VARCHAR(64) DEFAULT NULL COMMENT '创建者',
    updater VARCHAR(64) DEFAULT NULL COMMENT '更新者',
    deleted BIT(1) NOT NULL DEFAULT 0 COMMENT '是否删除',
    PRIMARY KEY (id),
    UNIQUE KEY uk_integrity_biz (biz_type, biz_id),
    KEY idx_integrity_event_time (event_time)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='数据完整性校验记录';

 sql/mysql/mes_trace_anti_module_menu.sql

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,66 @@
-- é˜²ä¼ªé˜²çªœè´§ç®¡ç†èœå•ä¸ŽæŒ‰é’®æƒé™åˆå§‹åŒ–
-- ç‹¬ç«‹ä¸€çº§èœå•ï¼ˆparent_id=0，type=1），采用 WHERE NOT EXISTS å¹‚等插入。
-- æ‰§è¡Œå‰è¯·ç¡®è®¤ç›®æ ‡æ•°æ®åº“为项目实际业务库，并逐条执行。

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6070, '防伪防窜货管理', '', 1, 21, 0, 'trace-anti', 'ep:warning', '', '',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6070 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6071, '窜货预警', '', 2, 1, 6070, 'cross-region', 'ep:location-danger', 'mes/trace/crossregion/index', 'MesTraceCrossRegion',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6071 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6072, '窜货预警查询', 'mes:trace-cross-region:query', 3, 1, 6071, '', '', '', '',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6072 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6073, '窜货预警处理', 'mes:trace-cross-region:handle', 3, 2, 6071, '', '', '', '',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6073 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6074, '扫码地理分布', '', 2, 2, 6070, 'scan-distribution', 'ep:map-location', 'mes/trace-consumer-scan/index', 'MesConsumerScanDistribution',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6074 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6075, '扫码分布查询', 'mes:trace-consumer-scan:query', 3, 1, 6074, '', '', '', '',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6075 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6076, '数据完整性校验', '', 2, 3, 6070, 'integrity', 'ep:lock', 'mes/trace/integrity/index', 'MesTraceIntegrity',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6076 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6077, '完整性记录查询', 'mes:trace-integrity:query', 3, 1, 6076, '', '', '', '',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6077 AND deleted = b'0');

INSERT INTO system_menu
    (id, name, permission, type, sort, parent_id, path, icon, component, component_name,
     status, visible, keep_alive, always_show, creator, create_time, updater, update_time, deleted)
SELECT 6078, '数据完整性校验', 'mes:trace-integrity:verify', 3, 2, 6076, '', '', '', '',
       0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0'
WHERE NOT EXISTS (SELECT 1 FROM system_menu WHERE id = 6078 AND deleted = b'0');

 sql/mysql/mes_trace_consumer_scan_event.sql

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
-- æ¶ˆè´¹è€…扫码访问事件表（不使用 tenant_id）
CREATE TABLE IF NOT EXISTS mes_trace_consumer_scan_event (
    id BIGINT NOT NULL AUTO_INCREMENT COMMENT '主键',
    trace_code VARCHAR(255) NOT NULL COMMENT '扫码原始内容（必要时截断）',
    normalized_code VARCHAR(128) DEFAULT NULL COMMENT '解析后的追溯码',
    source_type VARCHAR(32) DEFAULT NULL COMMENT '入口类型：BAG/PALLET/BATCH',
    channel VARCHAR(32) DEFAULT NULL COMMENT '扫码入口渠道：微信/支付宝/浏览器',
    province VARCHAR(64) DEFAULT NULL COMMENT '省份（IP å½’属地）',
    city VARCHAR(64) DEFAULT NULL COMMENT '城市（IP å½’属地）',
    batch_id BIGINT DEFAULT NULL COMMENT '生产批次编号',
    success TINYINT(1) NOT NULL DEFAULT 0 COMMENT '是否查询成功',
    error_code VARCHAR(64) DEFAULT NULL COMMENT '失败编码',
    ip_hash CHAR(64) DEFAULT NULL COMMENT '客户端 IP SHA-256 æ‘˜è¦',
    user_agent_hash CHAR(64) DEFAULT NULL COMMENT 'User-Agent SHA-256 æ‘˜è¦',
    event_time DATETIME NOT NULL COMMENT '访问时间',
    create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    creator VARCHAR(64) DEFAULT NULL COMMENT '创建者',
    updater VARCHAR(64) DEFAULT NULL COMMENT '更新者',
    deleted BIT(1) NOT NULL DEFAULT 0 COMMENT '是否删除',
    PRIMARY KEY (id),
    KEY idx_trace_consumer_event_time (event_time),
    KEY idx_trace_consumer_batch_id (batch_id),
    KEY idx_trace_consumer_success (success),
    KEY idx_trace_consumer_source_type (source_type),
    KEY idx_trace_consumer_channel (channel),
    KEY idx_trace_consumer_province (province)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='消费者扫码访问事件';

 sql/mysql/mes_trace_consumer_scan_menu.sql

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
-- =============================================
-- MES æ¶ˆè´¹è€…扫码访问统计 èœå•åˆå§‹åŒ–
-- æ–°å»ºé¡¶çº§ç›®å½•ã€Œæº¯æºåˆ†æžã€ï¼Œåœ¨å…¶ä¸‹æŒ‚「消费者扫码统计」页面
-- é¡µé¢è·¯ç”± /trace/consumer-scan/index，权限标识 mes:trace-consumer-scan:query
-- ç®¡ç†ç«¯æŽ¥å£è·¯å¾„ /mes/trace-consumer-scan/*
-- ç›®æ ‡åº“：mom-thzy（application-local.yaml é»˜è®¤åº“）
-- =============================================

-- é¡¶çº§ç›®å½•ï¼šæº¯æºåˆ†æžï¼ˆtype=1 ç›®å½•ï¼Œparent_id=0，path=/trace）
INSERT INTO `system_menu` (`id`, `name`, `permission`, `type`, `sort`, `parent_id`, `path`, `icon`, `component`, `component_name`, `status`, `visible`, `keep_alive`, `always_show`, `creator`, `create_time`, `updater`, `update_time`, `deleted`)
VALUES (602634, '溯源分析', '', 1, 24, 0, '/trace', 'ep:data-analysis', '', '', 0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0');

-- æ¶ˆè´¹è€…扫码统计（二级页面，挂在「溯源分析」目录下，path ä¸å«çˆ¶çº§å‰ç¼€ï¼‰
INSERT INTO `system_menu` (`id`, `name`, `permission`, `type`, `sort`, `parent_id`, `path`, `icon`, `component`, `component_name`, `status`, `visible`, `keep_alive`, `always_show`, `creator`, `create_time`, `updater`, `update_time`, `deleted`)
VALUES (602632, '消费者扫码统计', '', 2, 1, 602634, 'consumer-scan/index', 'ep:data-line', 'mes/trace-consumer-scan/index', 'MesConsumerScanStatistics', 0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0');

-- æ¶ˆè´¹è€…扫码统计 - æŒ‰é’®æƒé™
INSERT INTO `system_menu` (`id`, `name`, `permission`, `type`, `sort`, `parent_id`, `path`, `icon`, `component`, `component_name`, `status`, `visible`, `keep_alive`, `always_show`, `creator`, `create_time`, `updater`, `update_time`, `deleted`)
VALUES
(602633, '消费者扫码统计查询', 'mes:trace-consumer-scan:query', 3, 1, 602632, '', '', '', '', 0, b'1', b'1', b'1', '1', NOW(), '1', NOW(), b'0');

 sql/mysql/mes_wm_sales_outbound_traceability.sql

@@ -1,6 +1,15 @@
-- å‡ºåº“流通管理：销售出库与袋码/托盘码关联（无租户字段）
-- æ‰§è¡Œå‰è¯·ç¡®è®¤ç›®æ ‡æ•°æ®åº“为 mom-thzy，并逐条执行。

ALTER TABLE mes_wm_product_sales
  ADD COLUMN client_name varchar(255) DEFAULT NULL COMMENT '经销商名称快照' AFTER client_id;
ALTER TABLE mes_wm_product_sales
  ADD COLUMN outbound_time datetime DEFAULT NULL COMMENT '实际出库时间' AFTER sales_date;
ALTER TABLE mes_wm_product_sales
  ADD COLUMN outbound_user_id bigint DEFAULT NULL COMMENT '执行出库操作人ID' AFTER outbound_time;
ALTER TABLE mes_wm_product_sales
  ADD INDEX idx_product_sales_outbound_time (outbound_time);

ALTER TABLE mes_wm_product_sales_detail
  ADD COLUMN bag_code_id bigint DEFAULT NULL COMMENT '袋码编号' AFTER area_id;
ALTER TABLE mes_wm_product_sales_detail

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/MesTraceConfigController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace;

import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.vo.MesTraceQrConfigRespVO;
import cn.iocoder.yudao.module.mes.framework.config.MesProperties;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;

/**
 * ç®¡ç†åŽå° - MES æº¯æºé…ç½®
 * <p>
 * å‘管理端前端暴露溯源 H5 é¡µé¢åŸºç¡€åœ°å€ï¼Œç”¨äºŽ"查看二维码"预览/下载与打印标签保持一致的二维码内容。
 */
@Tag(name = "管理后台 - MES æº¯æºé…ç½®")
@RestController
@RequestMapping("/mes/trace-config")
@Validated
public class MesTraceConfigController {

    @Resource
    private MesProperties mesProperties;

    @GetMapping("/qr-config")
    @Operation(summary = "获得溯源 H5 é¡µé¢åŸºç¡€åœ°å€ï¼ˆäºŒç»´ç å†…容前缀）")
    public CommonResult<MesTraceQrConfigRespVO> getQrConfig() {
        MesTraceQrConfigRespVO respVO = new MesTraceQrConfigRespVO();
        respVO.setTraceBaseUrl(mesProperties.getTraceBaseUrl());
        return success(respVO);
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/consumer/MesTraceConsumerScanController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,63 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.consumer;

import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanTrendRespVO;
import cn.iocoder.yudao.module.mes.service.trace.consumer.MesTraceConsumerScanStatisticsService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalDateTime;
import java.util.List;

import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;

@Tag(name = "管理后台 - MES æ¶ˆè´¹è€…扫码访问统计")
@RestController
@RequestMapping("/mes/trace-consumer-scan")
@Validated
public class MesTraceConsumerScanController {

    @Resource
    private MesTraceConsumerScanStatisticsService statisticsService;

    @GetMapping("/summary")
    @Operation(summary = "消费者扫码访问汇总")
    @PreAuthorize("@ss.hasPermission('mes:trace-consumer-scan:query')")
    public CommonResult<MesTraceConsumerScanSummaryRespVO> getSummary(
            @RequestParam(value = "startTime", required = false) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime startTime,
            @RequestParam(value = "endTime", required = false) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime endTime) {
        return success(statisticsService.getSummary(startTime, endTime));
    }

    @GetMapping("/trend")
    @Operation(summary = "消费者扫码访问趋势")
    @PreAuthorize("@ss.hasPermission('mes:trace-consumer-scan:query')")
    public CommonResult<List<MesTraceConsumerScanTrendRespVO>> getTrend(
            @RequestParam(value = "startTime", required = false) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime startTime,
            @RequestParam(value = "endTime", required = false) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime endTime) {
        return success(statisticsService.getTrend(startTime, endTime));
    }

    @GetMapping("/distribution")
    @Operation(summary = "消费者扫码访问分布")
    @PreAuthorize("@ss.hasPermission('mes:trace-consumer-scan:query')")
    public CommonResult<List<MesTraceConsumerScanDistributionRespVO>> getDistribution(
            @Valid MesTraceConsumerScanDistributionReqVO reqVO) {
        return success(statisticsService.getDistribution(reqVO));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/consumer/vo/MesTraceConsumerScanDistributionReqVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotBlank;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;

import java.time.LocalDateTime;

import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;

@Data
@Schema(description = "消费者扫码访问分布查询参数")
public class MesTraceConsumerScanDistributionReqVO {

    @Schema(description = "分组维度：sourceType/success/channel/province/city/batchId", example = "sourceType")
    @NotBlank(message = "分组维度不能为空")
    private String groupBy;

    @Schema(description = "开始时间")
    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
    private LocalDateTime startTime;

    @Schema(description = "结束时间")
    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
    private LocalDateTime endTime;
}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/consumer/vo/MesTraceConsumerScanDistributionRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,11 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Data
@Schema(description = "消费者扫码访问分布")
public class MesTraceConsumerScanDistributionRespVO {
    private String name;
    private Long count;
}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/consumer/vo/MesTraceConsumerScanSummaryRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,13 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Data
@Schema(description = "消费者扫码访问汇总")
public class MesTraceConsumerScanSummaryRespVO {
    private Long total;
    private Long success;
    private Long failed;
    private Long uniqueBatchCount;
}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/consumer/vo/MesTraceConsumerScanTrendRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,13 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Data
@Schema(description = "消费者扫码访问趋势")
public class MesTraceConsumerScanTrendRespVO {
    private String date;
    private Long total;
    private Long success;
    private Long failed;
}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/MesTraceCrossRegionController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,89 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion;

import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceAntiConfigRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionHandleReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningRespVO;
import cn.iocoder.yudao.module.mes.service.trace.crossregion.MesTraceCrossRegionService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalDateTime;
import java.util.List;

import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;

@Tag(name = "管理后台 - MES çªœè´§é¢„è­¦")
@RestController
@RequestMapping("/mes/trace-cross-region")
@Validated
public class MesTraceCrossRegionController {

    @Resource
    private MesTraceCrossRegionService crossRegionService;

    @GetMapping("/page")
    @Operation(summary = "获得窜货预警分页")
    @PreAuthorize("@ss.hasPermission('mes:trace-cross-region:query')")
    public CommonResult<PageResult<MesTraceCrossRegionWarningRespVO>> getWarningPage(@Valid MesTraceCrossRegionWarningPageReqVO reqVO) {
        return success(crossRegionService.getWarningPage(reqVO));
    }

    @PutMapping("/handle")
    @Operation(summary = "处理窜货预警")
    @PreAuthorize("@ss.hasPermission('mes:trace-cross-region:handle')")
    public CommonResult<Boolean> handleWarning(@Valid @RequestBody MesTraceCrossRegionHandleReqVO reqVO) {
        crossRegionService.handleWarning(reqVO);
        return success(true);
    }

    @GetMapping("/summary")
    @Operation(summary = "获得窜货预警汇总")
    @PreAuthorize("@ss.hasPermission('mes:trace-cross-region:query')")
    public CommonResult<MesTraceCrossRegionSummaryRespVO> getWarningSummary(
            @RequestParam(value = "startTime", required = false) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime startTime,
            @RequestParam(value = "endTime", required = false) @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime endTime) {
        return success(crossRegionService.getWarningSummary(startTime, endTime));
    }

    @GetMapping("/statistics")
    @Operation(summary = "获得窜货预警分布统计")
    @PreAuthorize("@ss.hasPermission('mes:trace-cross-region:query')")
    public CommonResult<List<MesTraceCrossRegionStatisticsRespVO>> getWarningStatistics(@Valid MesTraceCrossRegionStatisticsReqVO reqVO) {
        return success(crossRegionService.getWarningStatistics(reqVO));
    }

    @GetMapping("/config")
    @Operation(summary = "获得防窜货规则配置")
    @PreAuthorize("@ss.hasPermission('mes:trace-cross-region:query')")
    public CommonResult<MesTraceAntiConfigRespVO> getConfig() {
        return success(crossRegionService.getConfig());
    }

    @PutMapping("/config")
    @Operation(summary = "更新防窜货规则配置")
    @PreAuthorize("@ss.hasPermission('mes:trace-cross-region:handle')")
    public CommonResult<Boolean> updateConfig(@RequestParam("warningLevel") @Parameter(description = "判定粒度：PROVINCE è·¨çœ / CITY è·¨å¸‚", example = "PROVINCE") String warningLevel) {
        crossRegionService.updateConfig(warningLevel);
        return success(true);
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceAntiConfigRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Schema(description = "管理后台 - é˜²çªœè´§è§„则配置 Response VO")
@Data
public class MesTraceAntiConfigRespVO {

    @Schema(description = "判定粒度：PROVINCE è·¨çœ / CITY è·¨å¸‚", example = "PROVINCE")
    private String warningLevel;

    @Schema(description = "配置说明", example = "窜货判定粒度：PROVINCE è·¨çœ / CITY è·¨å¸‚")
    private String remark;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceCrossRegionHandleReqVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotNull;
import lombok.Data;

@Schema(description = "管理后台 - çªœè´§é¢„警处理 Request VO")
@Data
public class MesTraceCrossRegionHandleReqVO {

    @Schema(description = "预警编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
    @NotNull(message = "预警编号不能为空")
    private Long id;

    @Schema(description = "处理状态：20 å·²å¤„理 / 30 è¯¯æŠ¥", requiredMode = Schema.RequiredMode.REQUIRED, example = "20")
    @NotNull(message = "处理状态不能为空")
    private Integer status;

    @Schema(description = "处理备注", example = "确认为物流中转，非窜货")
    private String handleRemark;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceCrossRegionStatisticsReqVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotBlank;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;

import java.time.LocalDateTime;

import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;

@Schema(description = "管理后台 - çªœè´§é¢„警分布统计 Request VO")
@Data
public class MesTraceCrossRegionStatisticsReqVO {

    @Schema(description = "分组维度：scanProvince/scanCity/clientId/itemId/batchId", example = "scanProvince")
    @NotBlank(message = "分组维度不能为空")
    private String groupBy;

    @Schema(description = "开始时间")
    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
    private LocalDateTime startTime;

    @Schema(description = "结束时间")
    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
    private LocalDateTime endTime;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceCrossRegionStatisticsRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Schema(description = "管理后台 - çªœè´§é¢„警分布统计 Response VO")
@Data
public class MesTraceCrossRegionStatisticsRespVO {

    @Schema(description = "分组名称", example = "广东省")
    private String name;

    @Schema(description = "预警数量", example = "30")
    private Long count;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceCrossRegionSummaryRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Schema(description = "管理后台 - çªœè´§é¢„警汇总 Response VO")
@Data
public class MesTraceCrossRegionSummaryRespVO {

    @Schema(description = "预警总数", example = "100")
    private Long total;

    @Schema(description = "待处理数量", example = "30")
    private Long pending;

    @Schema(description = "已处理数量", example = "60")
    private Long handled;

    @Schema(description = "误报数量", example = "10")
    private Long falseAlarm;

    @Schema(description = "跨省窜货数量", example = "80")
    private Long crossProvince;

    @Schema(description = "跨市窜货数量", example = "20")
    private Long crossCity;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceCrossRegionWarningPageReqVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,45 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import cn.iocoder.yudao.framework.common.pojo.PageParam;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;
import org.springframework.format.annotation.DateTimeFormat;

import java.time.LocalDateTime;

import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;

@Schema(description = "管理后台 - çªœè´§é¢„警分页 Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class MesTraceCrossRegionWarningPageReqVO extends PageParam {

    @Schema(description = "状态：10 å¾…处理 / 20 å·²å¤„理 / 30 è¯¯æŠ¥", example = "10")
    private Integer status;

    @Schema(description = "预警类型：CROSS_PROVINCE / CROSS_CITY", example = "CROSS_PROVINCE")
    private String warningType;

    @Schema(description = "批次编号")
    private Long batchId;

    @Schema(description = "批次号", example = "PC20260901L001M001_001")
    private String batchCode;

    @Schema(description = "袋码", example = "BAG-00000001")
    private String bagCode;

    @Schema(description = "经销商编号")
    private Long clientId;

    @Schema(description = "经销商名称", example = "华东区域经销商")
    private String clientName;

    @Schema(description = "预警产生时间范围")
    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
    private LocalDateTime[] eventTime;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/crossregion/vo/MesTraceCrossRegionWarningRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,99 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

import java.time.LocalDateTime;

@Schema(description = "管理后台 - çªœè´§é¢„è­¦ Response VO")
@Data
public class MesTraceCrossRegionWarningRespVO {

    @Schema(description = "编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
    private Long id;

    @Schema(description = "预警编号", example = "WARN202609010001")
    private String warningNo;

    @Schema(description = "袋码编号", example = "1")
    private Long bagCodeId;

    @Schema(description = "袋码", example = "BAG-00000001")
    private String bagCode;

    @Schema(description = "托盘码编号", example = "1")
    private Long palletCodeId;

    @Schema(description = "托盘码", example = "BAG-00000001-P1")
    private String palletCode;

    @Schema(description = "生产批次编号", example = "1")
    private Long batchId;

    @Schema(description = "批次号", example = "PC20260901L001M001_001")
    private String batchCode;

    @Schema(description = "物料编号", example = "1")
    private Long itemId;

    @Schema(description = "物料编码", example = "M001")
    private String itemCode;

    @Schema(description = "物料名称", example = "杂交水稻种子")
    private String itemName;

    @Schema(description = "销售出库单编号", example = "1")
    private Long salesId;

    @Schema(description = "出库单号", example = "PS202609010001")
    private String salesCode;

    @Schema(description = "经销商编号", example = "1")
    private Long clientId;

    @Schema(description = "经销商名称", example = "华东区域经销商")
    private String clientName;

    @Schema(description = "经销商省份", example = "江苏省")
    private String dealerProvince;

    @Schema(description = "经销商城市", example = "南京市")
    private String dealerCity;

    @Schema(description = "扫码省份", example = "广东省")
    private String scanProvince;

    @Schema(description = "扫码城市", example = "广州市")
    private String scanCity;

    @Schema(description = "预警类型：CROSS_PROVINCE / CROSS_CITY", example = "CROSS_PROVINCE")
    private String warningType;

    @Schema(description = "预警类型名称", example = "跨省窜货")
    private String warningTypeName;

    @Schema(description = "关联消费者扫码事件编号", example = "1")
    private Long scanEventId;

    @Schema(description = "状态：10 å¾…处理 / 20 å·²å¤„理 / 30 è¯¯æŠ¥", example = "10")
    private Integer status;

    @Schema(description = "状态名称", example = "待处理")
    private String statusName;

    @Schema(description = "处理人编号", example = "1")
    private Long handleUserId;

    @Schema(description = "处理人姓名", example = "张三")
    private String handleUserName;

    @Schema(description = "处理时间")
    private LocalDateTime handleTime;

    @Schema(description = "处理备注", example = "确认为物流中转，非窜货")
    private String handleRemark;

    @Schema(description = "预警产生时间")
    private LocalDateTime eventTime;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/integrity/MesTraceIntegrityController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,45 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.integrity;

import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityRecordPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityVerifyReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityVerifyRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.integrity.MesTraceIntegrityRecordDO;
import cn.iocoder.yudao.module.mes.service.trace.integrity.MesTraceIntegrityService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;

@Tag(name = "管理后台 - MES æ•°æ®å®Œæ•´æ€§æ ¡éªŒ")
@RestController
@RequestMapping("/mes/trace-integrity")
@Validated
public class MesTraceIntegrityController {

    @Resource
    private MesTraceIntegrityService integrityService;

    @GetMapping("/verify")
    @Operation(summary = "校验数据完整性（重算摘要比对）")
    @PreAuthorize("@ss.hasPermission('mes:trace-integrity:verify')")
    public CommonResult<MesTraceIntegrityVerifyRespVO> verify(@Valid MesTraceIntegrityVerifyReqVO reqVO) {
        return success(integrityService.verify(reqVO.getBizType(), reqVO.getBizId()));
    }

    @GetMapping("/page")
    @Operation(summary = "获得数据完整性记录分页")
    @PreAuthorize("@ss.hasPermission('mes:trace-integrity:query')")
    public CommonResult<PageResult<MesTraceIntegrityRecordDO>> getIntegrityPage(@Valid MesTraceIntegrityRecordPageReqVO reqVO) {
        return success(integrityService.getIntegrityPage(reqVO));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/integrity/vo/MesTraceIntegrityRecordPageReqVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo;

import cn.iocoder.yudao.framework.common.pojo.PageParam;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;

@Schema(description = "管理后台 - æ•°æ®å®Œæ•´æ€§è®°å½•åˆ†é¡µ Request VO")
@Data
@EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true)
public class MesTraceIntegrityRecordPageReqVO extends PageParam {

    @Schema(description = "业务类型：BATCH / SALES / SCAN", example = "BATCH")
    private String bizType;

    @Schema(description = "业务记录编号", example = "1")
    private Long bizId;

    @Schema(description = "业务编码", example = "PC20260901L001M001_001")
    private String bizCode;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/integrity/vo/MesTraceIntegrityVerifyReqVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data;

@Schema(description = "管理后台 - æ•°æ®å®Œæ•´æ€§æ ¡éªŒ Request VO")
@Data
public class MesTraceIntegrityVerifyReqVO {

    @Schema(description = "业务类型：BATCH æ‰¹æ¬¡ / SALES é”€å”®å‡ºåº“ / SCAN æ¶ˆè´¹è€…扫码", requiredMode = Schema.RequiredMode.REQUIRED, example = "BATCH")
    @NotBlank(message = "业务类型不能为空")
    private String bizType;

    @Schema(description = "业务记录编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
    @NotNull(message = "业务记录编号不能为空")
    private Long bizId;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/integrity/vo/MesTraceIntegrityVerifyRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

@Schema(description = "管理后台 - æ•°æ®å®Œæ•´æ€§æ ¡éªŒ Response VO")
@Data
public class MesTraceIntegrityVerifyRespVO {

    @Schema(description = "业务类型：BATCH / SALES / SCAN", example = "BATCH")
    private String bizType;

    @Schema(description = "业务记录编号", example = "1024")
    private Long bizId;

    @Schema(description = "业务编码", example = "PC20260901L001M001_001")
    private String bizCode;

    @Schema(description = "是否校验通过", example = "true")
    private Boolean matched;

    @Schema(description = "存储的摘要 SHA-256", example = "a1b2c3...")
    private String storedHash;

    @Schema(description = "当前数据重算摘要 SHA-256", example = "a1b2c3...")
    private String currentHash;

    @Schema(description = "批次当前袋码集合摘要（仅 BATCH æ ¡éªŒè¿”回，供人工比对袋码防篡改）", example = "d4e5f6...")
    private String bagSetHash;

    @Schema(description = "校验说明", example = "数据完整，未被篡改")
    private String message;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/trace/vo/MesTraceQrConfigRespVO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package cn.iocoder.yudao.module.mes.controller.admin.trace.vo;

import lombok.Data;

/**
 * MES æº¯æº H5 é…ç½® Resp VO
 */
@Data
public class MesTraceQrConfigRespVO {

    /**
     * æº¯æº H5 é¡µé¢åŸºç¡€åœ°å€ï¼ˆäºŒç»´ç å†…容前缀，如 http://host:port/trace.html）
     */
    private String traceBaseUrl;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/productsales/MesWmProductSalesController.java

@@ -10,6 +10,8 @@
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesSaveReqVO;
@@ -47,6 +49,8 @@
    private MesWmProductSalesService productSalesService;
    @Resource
    private CrmCustomerApi crmCustomerApi;
    @Resource
    private AdminUserApi adminUserApi;
    @Resource
    private MesWmSalesNoticeService salesNoticeService;

@@ -178,12 +182,19 @@
                convertSet(list, MesWmProductSalesDO::getClientId));
        Map<Long, MesWmSalesNoticeDO> noticeMap = salesNoticeService.getSalesNoticeMap(
                convertSet(list, MesWmProductSalesDO::getNoticeId));
        Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(
                convertSet(list, MesWmProductSalesDO::getOutboundUserId));
        // 2. æž„建结果
        return BeanUtils.toBean(list, MesWmProductSalesRespVO.class, vo -> {
            MapUtils.findAndThen(customerMap, vo.getClientId(), customer ->
                    vo.setClientName(customer.getName()));
            if (vo.getClientName() == null) {
                MapUtils.findAndThen(customerMap, vo.getClientId(), customer -> vo.setClientName(customer.getName()));
            }
            MapUtils.findAndThen(noticeMap, vo.getNoticeId(),
                    notice -> vo.setNoticeCode(notice.getCode()));
            MapUtils.findAndThen(userMap, vo.getOutboundUserId(),
                    user -> vo.setOutboundUserName(user.getNickname()));
        });
    }


 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/productsales/vo/MesWmProductSalesPageReqVO.java

@@ -26,6 +26,10 @@
    @Schema(description = "客户编号", example = "1")
    private Long clientId;

    @Schema(description = "实际出库时间范围")
    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
    private LocalDateTime[] outboundTime;

    @Schema(description = "状态", example = "0")
    private Integer status;


 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/productsales/vo/MesWmProductSalesRespVO.java

@@ -31,6 +31,17 @@
    @ExcelProperty("客户")
    private String clientName;

    @Schema(description = "实际出库时间")
    @ExcelProperty("实际出库时间")
    private LocalDateTime outboundTime;

    @Schema(description = "执行出库操作人ID")
    private Long outboundUserId;

    @Schema(description = "执行出库操作人名称")
    @ExcelProperty("出库操作人")
    private String outboundUserName;

    @Schema(description = "销售订单号", example = "SO2026030001")
    @ExcelProperty("销售订单号")
    private String salesOrderCode;

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/pub/trace/vo/MesProTracePublicRespVO.java

@@ -105,6 +105,10 @@
    @Schema(description = "种子质检信息")
    private QualityVO quality;

    // ====== é˜²ä¼ªéªŒè¯åŒºå— ======
    @Schema(description = "防伪验证信息（该追溯码扫码次数与时间）")
    private AntiFakeVO antiFake;

    // ====== å¯é€‰æ‰©å±•åŒºå—（有数据才返回，空表返回空列表） ======
    @Schema(description = "采购来源（可选）")
    private List<MesWmBatchPurchaseSourceRespVO> purchaseSources;
@@ -175,6 +179,17 @@
        private LocalDateTime eventTime;
    }

    @Schema(description = "防伪验证信息")
    @Data
    public static class AntiFakeVO {
        @Schema(description = "该追溯码累计扫码次数", example = "3")
        private Long scanCount;
        @Schema(description = "首次扫码时间")
        private LocalDateTime firstScanTime;
        @Schema(description = "最近扫码时间")
        private LocalDateTime lastScanTime;
    }

    @Schema(description = "种子质检信息")
    @Data
    public static class QualityVO {

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/trace/consumer/MesTraceConsumerScanEventDO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,69 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer;

import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;

import java.time.LocalDateTime;

/**
 * æ¶ˆè´¹è€…扫码访问事件 DO
 * <p>
 * è®°å½•å…¬ä¼—通过二维码/H5 æ‰«ææº¯æºé¡µé¢çš„访问情况（成功与失败均记录），
 * ç”¨äºŽåˆ†æžæ¶ˆè´¹è€…溯源访问量、趋势与分布。
 */
@TableName("mes_trace_consumer_scan_event")
@KeySequence("mes_trace_consumer_scan_event_seq")
@Data
@EqualsAndHashCode(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class MesTraceConsumerScanEventDO extends BaseDO {

    @TableId
    private Long id;

    /** æ‰«ç åŽŸå§‹å†…容（必要时截断） */
    private String traceCode;

    /** è§£æžåŽçš„追溯码 */
    private String normalizedCode;

    /** å…¥å£ç±»åž‹ï¼šBAG/PALLET/BATCH */
    private String sourceType;

    /** æ‰«ç å…¥å£æ¸ é“：微信/支付宝/浏览器 */
    private String channel;

    /** çœä»½ï¼ˆIP å½’属地，仅存地名不存敏感信息） */
    private String province;

    /** åŸŽå¸‚（IP å½’属地，仅存地名不存敏感信息） */
    private String city;

    /** ç”Ÿäº§æ‰¹æ¬¡ç¼–号 */
    private Long batchId;

    /** æ˜¯å¦æŸ¥è¯¢æˆåŠŸï¼ˆ0 å¤±è´¥ï¼Œ1 æˆåŠŸï¼‰ */
    private Boolean success;

    /** å¤±è´¥ç¼–码 */
    private String errorCode;

    /** å®¢æˆ·ç«¯ IP SHA-256 æ‘˜è¦ï¼ˆä¸ä¿å­˜æ˜Žæ–‡ï¼‰ */
    private String ipHash;

    /** User-Agent SHA-256 æ‘˜è¦ï¼ˆä¸ä¿å­˜æ˜Žæ–‡ï¼‰ */
    private String userAgentHash;

    /** è®¿é—®æ—¶é—´ */
    private LocalDateTime eventTime;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/trace/crossregion/MesTraceAntiConfigDO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,37 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion;

import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;

/**
 * é˜²çªœè´§è§„则配置 DO（key-value）
 */
@TableName("mes_trace_anti_config")
@KeySequence("mes_trace_anti_config_seq")
@Data
@EqualsAndHashCode(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class MesTraceAntiConfigDO extends BaseDO {

    @TableId
    private Long id;

    /** é…ç½®é¡¹ Key（如 warning_level） */
    private String configKey;

    /** é…ç½®å€¼ï¼ˆwarning_level：PROVINCE è·¨çœ / CITY è·¨å¸‚） */
    private String configValue;

    /** é…ç½®è¯´æ˜Ž */
    private String remark;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/trace/crossregion/MesTraceCrossRegionWarningDO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,107 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion;

import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;

import java.time.LocalDateTime;

/**
 * çªœè´§é¢„警记录 DO
 * <p>
 * æ¶ˆè´¹è€…扫码地区与袋码出库经销商所在地区不一致时，系统自动生成预警，供管理端稽查与处理。
 */
@TableName("mes_trace_cross_region_warning")
@KeySequence("mes_trace_cross_region_warning_seq")
@Data
@EqualsAndHashCode(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class MesTraceCrossRegionWarningDO extends BaseDO {

    @TableId
    private Long id;

    /** é¢„警编号 */
    private String warningNo;

    /** è¢‹ç ç¼–号 */
    private Long bagCodeId;

    /** è¢‹ç  */
    private String bagCode;

    /** æ‰˜ç›˜ç ç¼–号 */
    private Long palletCodeId;

    /** æ‰˜ç›˜ç  */
    private String palletCode;

    /** ç”Ÿäº§æ‰¹æ¬¡ç¼–号 */
    private Long batchId;

    /** æ‰¹æ¬¡å· */
    private String batchCode;

    /** ç‰©æ–™ç¼–号 */
    private Long itemId;

    /** ç‰©æ–™ç¼–码 */
    private String itemCode;

    /** ç‰©æ–™åç§° */
    private String itemName;

    /** é”€å”®å‡ºåº“单编号 */
    private Long salesId;

    /** å‡ºåº“单号 */
    private String salesCode;

    /** ç»é”€å•†ç¼–号 */
    private Long clientId;

    /** ç»é”€å•†åç§° */
    private String clientName;

    /** ç»é”€å•†çœä»½ */
    private String dealerProvince;

    /** ç»é”€å•†åŸŽå¸‚ */
    private String dealerCity;

    /** æ‰«ç çœä»½ */
    private String scanProvince;

    /** æ‰«ç åŸŽå¸‚ */
    private String scanCity;

    /** é¢„警类型：CROSS_PROVINCE / CROSS_CITY */
    private String warningType;

    /** å…³è”消费者扫码事件编号 */
    private Long scanEventId;

    /** çŠ¶æ€ï¼š10 å¾…处理 / 20 å·²å¤„理 / 30 è¯¯æŠ¥ */
    private Integer status;

    /** å¤„理人编号 */
    private Long handleUserId;

    /** å¤„理时间 */
    private LocalDateTime handleTime;

    /** å¤„理备注 */
    private String handleRemark;

    /** é¢„警产生时间 */
    private LocalDateTime eventTime;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/trace/integrity/MesTraceIntegrityRecordDO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package cn.iocoder.yudao.module.mes.dal.dataobject.trace.integrity;

import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;

import java.time.LocalDateTime;

/**
 * æ•°æ®å®Œæ•´æ€§æ ¡éªŒè®°å½• DO
 * <p>
 * åœ¨æ‰¹æ¬¡åˆ›å»ºã€é”€å”®å‡ºåº“、消费者扫码等关键事件发生时，对不可变核心字段生成 SHA-256 æ‘˜è¦ï¼Œ
 * ä¾›ç®¡ç†ç«¯é‡æ–°è®¡ç®—比对，发现事后篡改。
 */
@TableName("mes_trace_integrity_record")
@KeySequence("mes_trace_integrity_record_seq")
@Data
@EqualsAndHashCode(callSuper = true)
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class MesTraceIntegrityRecordDO extends BaseDO {

    @TableId
    private Long id;

    /** ä¸šåŠ¡ç±»åž‹ï¼šBATCH æ‰¹æ¬¡ / SALES é”€å”®å‡ºåº“ / SCAN æ¶ˆè´¹è€…扫码 */
    private String bizType;

    /** ä¸šåŠ¡è®°å½•ç¼–号 */
    private Long bizId;

    /** ä¸šåŠ¡ç¼–码（批次号 / å‡ºåº“单号 / è¿½æº¯ç ï¼‰ */
    private String bizCode;

    /** å†…容摘要 SHA-256 */
    private String contentHash;

    /** æ‘˜è¦ç”Ÿæˆæ—¶é—´ */
    private LocalDateTime eventTime;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/wm/productsales/MesWmProductSalesDO.java

@@ -46,6 +46,10 @@
     */
    private Long clientId;
    /**
     * ç»é”€å•†åç§°å¿«ç…§
     */
    private String clientName;
    /**
     * é”€å”®è®¢å•ID
     */
    private Long saleOrderId;
@@ -63,6 +67,14 @@
     * å‡ºåº“日期
     */
    private LocalDateTime salesDate;
    /**
     * å®žé™…出库时间
     */
    private LocalDateTime outboundTime;
    /**
     * æ‰§è¡Œå‡ºåº“操作人ID
     */
    private Long outboundUserId;

    /**
     * è”系人

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/batch/MesProBatchMapper.java

@@ -24,8 +24,9 @@
        return selectOne(MesProBatchDO::getTempCode, tempCode);
    }

    /** ç”Ÿæˆä¸´æ—¶æ‰¹æ¬¡ç ç”¨çš„全局序号：解析 temp_code çš„数字后缀，不存在则返回 0 */
    @Select("SELECT IFNULL(MAX(CAST(SUBSTRING(temp_code, 4) AS UNSIGNED)), 0) FROM mes_pro_batch WHERE deleted = 0")
    /** ç”Ÿæˆä¸´æ—¶æ‰¹æ¬¡ç ç”¨çš„全局序号：解析 temp_code çš„数字后缀，不存在则返回 0。
     *  ä¸èƒ½è¿‡æ»¤ deleted，唯一索引 uk_temp_code å¯¹é€»è¾‘删除行仍生效，忽略软删会导致序号回退、码值重复 */
    @Select("SELECT IFNULL(MAX(CAST(SUBSTRING(temp_code, 4) AS UNSIGNED)), 0) FROM mes_pro_batch")
    Integer selectMaxTempCodeSeq();

    default Long selectCountByLineId(Long lineId) {

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/pro/pallet/MesProPalletMapper.java

@@ -27,8 +27,9 @@
        return selectOne(MesProPalletDO::getTempCode, tempCode);
    }

    /** ç”Ÿæˆä¸´æ—¶æ‰˜ç›˜ç ç”¨çš„全局序号：解析 temp_code çš„数字后缀，不存在则返回 0 */
    @Select("SELECT IFNULL(MAX(CAST(SUBSTRING(temp_code, 4) AS UNSIGNED)), 0) FROM mes_pro_pallet WHERE deleted = 0")
    /** ç”Ÿæˆä¸´æ—¶æ‰˜ç›˜ç ç”¨çš„全局序号：解析 temp_code çš„数字后缀，不存在则返回 0。
     *  ä¸èƒ½è¿‡æ»¤ deleted，唯一索引 uk_temp_code å¯¹é€»è¾‘删除行仍生效，忽略软删会导致序号回退、码值重复 */
    @Select("SELECT IFNULL(MAX(CAST(SUBSTRING(temp_code, 4) AS UNSIGNED)), 0) FROM mes_pro_pallet")
    Integer selectMaxTempCodeSeq();

    @Select("SELECT * FROM mes_pro_pallet WHERE id = #{id} AND deleted = 0 FOR UPDATE")

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/trace/consumer/MesTraceConsumerScanEventMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer;

import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * æ¶ˆè´¹è€…扫码访问事件 Mapper
 *
 * @author è¶…级管理员
 */
@Mapper
public interface MesTraceConsumerScanEventMapper extends BaseMapperX<MesTraceConsumerScanEventDO> {

    /**
     * æŒ‰è¿½æº¯ç æŸ¥è¯¢æ‰«ç äº‹ä»¶ï¼ˆæ­£åºï¼Œä¾›é˜²ä¼ªéªŒè¯ç»Ÿè®¡æ‰«ç æ¬¡æ•°ä¸Žé¦–次/最近扫码时间）
     *
     * @param normalizedCode è§£æžåŽçš„追溯码
     * @return æ‰«ç äº‹ä»¶åˆ—表
     */
    default List<MesTraceConsumerScanEventDO> selectListByNormalizedCode(String normalizedCode) {
        return selectList(new LambdaQueryWrapperX<MesTraceConsumerScanEventDO>()
                .eq(MesTraceConsumerScanEventDO::getNormalizedCode, normalizedCode)
                .orderByAsc(MesTraceConsumerScanEventDO::getEventTime));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/trace/consumer/MesTraceConsumerScanStatisticsMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,31 @@
package cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer;

import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import org.apache.ibatis.annotations.Mapper;

import java.time.LocalDateTime;
import java.util.List;

/**
 * æ¶ˆè´¹è€…扫码访问统计 Mapper
 * <p>
 * ç»Ÿè®¡é‡‡ç”¨æŸ¥æ˜Žç»† + Java ä¾§èšåˆï¼Œé¿å…ç»Ÿè®¡ SQL ä¸Ž MySQL/H2 æ–¹è¨€å·®å¼‚，并消除动态列拼接注入面。
 *
 * @author è¶…级管理员
 */
@Mapper
public interface MesTraceConsumerScanStatisticsMapper extends BaseMapperX<MesTraceConsumerScanEventDO> {

    /**
     * æŸ¥è¯¢ç»Ÿè®¡æ—¶é—´èŒƒå›´å†…（开始时间含、结束时间不含）的消费者扫码访问事件
     */
    default List<MesTraceConsumerScanEventDO> selectListByTime(LocalDateTime startTime, LocalDateTime endTime) {
        return selectList(new LambdaQueryWrapperX<MesTraceConsumerScanEventDO>()
                .geIfPresent(MesTraceConsumerScanEventDO::getEventTime, startTime)
                .ltIfPresent(MesTraceConsumerScanEventDO::getEventTime, endTime)
                .orderByAsc(MesTraceConsumerScanEventDO::getEventTime));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/trace/crossregion/MesTraceAntiConfigMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package cn.iocoder.yudao.module.mes.dal.mysql.trace.crossregion;

import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion.MesTraceAntiConfigDO;
import org.apache.ibatis.annotations.Mapper;

/**
 * é˜²çªœè´§è§„则配置 Mapper
 *
 * @author è¶…级管理员
 */
@Mapper
public interface MesTraceAntiConfigMapper extends BaseMapperX<MesTraceAntiConfigDO> {

    default MesTraceAntiConfigDO selectByConfigKey(String configKey) {
        return selectOne(MesTraceAntiConfigDO::getConfigKey, configKey);
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/trace/crossregion/MesTraceCrossRegionWarningMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,42 @@
package cn.iocoder.yudao.module.mes.dal.mysql.trace.crossregion;

import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningPageReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion.MesTraceCrossRegionWarningDO;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * çªœè´§é¢„警记录 Mapper
 *
 * @author è¶…级管理员
 */
@Mapper
public interface MesTraceCrossRegionWarningMapper extends BaseMapperX<MesTraceCrossRegionWarningDO> {

    default PageResult<MesTraceCrossRegionWarningDO> selectPage(MesTraceCrossRegionWarningPageReqVO reqVO) {
        return selectPage(reqVO, new LambdaQueryWrapperX<MesTraceCrossRegionWarningDO>()
                .eqIfPresent(MesTraceCrossRegionWarningDO::getStatus, reqVO.getStatus())
                .eqIfPresent(MesTraceCrossRegionWarningDO::getWarningType, reqVO.getWarningType())
                .eqIfPresent(MesTraceCrossRegionWarningDO::getBatchId, reqVO.getBatchId())
                .likeIfPresent(MesTraceCrossRegionWarningDO::getBatchCode, reqVO.getBatchCode())
                .likeIfPresent(MesTraceCrossRegionWarningDO::getBagCode, reqVO.getBagCode())
                .eqIfPresent(MesTraceCrossRegionWarningDO::getClientId, reqVO.getClientId())
                .likeIfPresent(MesTraceCrossRegionWarningDO::getClientName, reqVO.getClientName())
                .betweenIfPresent(MesTraceCrossRegionWarningDO::getEventTime, reqVO.getEventTime())
                .orderByDesc(MesTraceCrossRegionWarningDO::getId));
    }

    /**
     * æŒ‰æ—¶é—´èŒƒå›´æŸ¥è¯¢é¢„警列表（供统计分组使用）
     */
    default List<MesTraceCrossRegionWarningDO> selectListByEventTimeBetween(java.time.LocalDateTime startTime,
                                                                            java.time.LocalDateTime endTime) {
        return selectList(new LambdaQueryWrapperX<MesTraceCrossRegionWarningDO>()
                .betweenIfPresent(MesTraceCrossRegionWarningDO::getEventTime, startTime, endTime));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/trace/integrity/MesTraceIntegrityRecordMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,32 @@
package cn.iocoder.yudao.module.mes.dal.mysql.trace.integrity;

import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityRecordPageReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.integrity.MesTraceIntegrityRecordDO;
import org.apache.ibatis.annotations.Mapper;

/**
 * æ•°æ®å®Œæ•´æ€§æ ¡éªŒè®°å½• Mapper
 *
 * @author è¶…级管理员
 */
@Mapper
public interface MesTraceIntegrityRecordMapper extends BaseMapperX<MesTraceIntegrityRecordDO> {

    default MesTraceIntegrityRecordDO selectByBiz(String bizType, Long bizId) {
        return selectOne(new LambdaQueryWrapperX<MesTraceIntegrityRecordDO>()
                .eq(MesTraceIntegrityRecordDO::getBizType, bizType)
                .eq(MesTraceIntegrityRecordDO::getBizId, bizId));
    }

    default PageResult<MesTraceIntegrityRecordDO> selectPage(MesTraceIntegrityRecordPageReqVO reqVO) {
        return selectPage(reqVO, new LambdaQueryWrapperX<MesTraceIntegrityRecordDO>()
                .eqIfPresent(MesTraceIntegrityRecordDO::getBizType, reqVO.getBizType())
                .eqIfPresent(MesTraceIntegrityRecordDO::getBizId, reqVO.getBizId())
                .likeIfPresent(MesTraceIntegrityRecordDO::getBizCode, reqVO.getBizCode())
                .orderByDesc(MesTraceIntegrityRecordDO::getId));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/wm/productsales/MesWmProductSalesDetailMapper.java

@@ -42,4 +42,24 @@
        delete(MesWmProductSalesDetailDO::getSalesId, salesId);
    }

    /**
     * æ ¹æ®è¢‹ç ç¼–号查询最近的出库明细（供窜货稽查反查出库去向）
     */
    default MesWmProductSalesDetailDO selectLatestByBagCodeId(Long bagCodeId) {
        return selectOne(new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<MesWmProductSalesDetailDO>()
                .eq(MesWmProductSalesDetailDO::getBagCodeId, bagCodeId)
                .orderByDesc(MesWmProductSalesDetailDO::getId)
                .last("LIMIT 1"));
    }

    /**
     * æ ¹æ®æ‰˜ç›˜ç ç¼–号查询最近的出库明细（供窜货稽查反查出库去向）
     */
    default MesWmProductSalesDetailDO selectLatestByPalletCodeId(Long palletCodeId) {
        return selectOne(new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<MesWmProductSalesDetailDO>()
                .eq(MesWmProductSalesDetailDO::getPalletCodeId, palletCodeId)
                .orderByDesc(MesWmProductSalesDetailDO::getId)
                .last("LIMIT 1"));
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/mysql/wm/productsales/MesWmProductSalesMapper.java

@@ -25,6 +25,7 @@
                .eqIfPresent(MesWmProductSalesDO::getClientId, reqVO.getClientId())
                .eqIfPresent(MesWmProductSalesDO::getStatus, reqVO.getStatus())
                .betweenIfPresent(MesWmProductSalesDO::getSalesDate, reqVO.getShipmentDate())
                .betweenIfPresent(MesWmProductSalesDO::getOutboundTime, reqVO.getOutboundTime())
                .orderByDesc(MesWmProductSalesDO::getId));
    }

@@ -38,6 +39,7 @@
                .eqIfPresent(MesWmProductSalesDO::getClientId, reqVO.getClientId())
                .eqIfPresent(MesWmProductSalesDO::getStatus, reqVO.getStatus())
                .betweenIfPresent(MesWmProductSalesDO::getSalesDate, reqVO.getShipmentDate())
                .betweenIfPresent(MesWmProductSalesDO::getOutboundTime, reqVO.getOutboundTime())
                .orderByDesc(MesWmProductSalesDO::getId);
        if (permittedClientIds != null) {
            if (CollUtil.isEmpty(permittedClientIds)) {

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/ErrorCodeConstants.java

@@ -877,4 +877,15 @@
    // ========== MES å…¬å¼€æ‰«ç æº¯æºï¼ˆ1-040-760-000） ==========
    ErrorCode MES_TRACE_CODE_NOT_FOUND = new ErrorCode(1_040_760_000, "未查询到该追溯码，请核对二维码或联系官方");

    // ========== MES é˜²ä¼ªé˜²çªœè´§-窜货预警（1-040-761-000） ==========
    ErrorCode MES_TRACE_CROSS_REGION_WARNING_NOT_EXISTS = new ErrorCode(1_040_761_000, "窜货预警记录不存在");
    ErrorCode MES_TRACE_CROSS_REGION_STATUS_INVALID = new ErrorCode(1_040_761_001, "窜货预警状态无效，仅待处理预警可处理");
    ErrorCode MES_TRACE_ANTI_CONFIG_NOT_EXISTS = new ErrorCode(1_040_761_002, "防窜货规则配置不存在");
    ErrorCode MES_TRACE_ANTI_CONFIG_VALUE_INVALID = new ErrorCode(1_040_761_003, "防窜货规则配置值无效，仅支持 PROVINCE/CITY");

    // ========== MES é˜²ä¼ªé˜²çªœè´§-数据完整性（1-040-762-000） ==========
    ErrorCode MES_TRACE_INTEGRITY_RECORD_NOT_EXISTS = new ErrorCode(1_040_762_000, "数据完整性记录不存在，请先对业务数据生成摘要");
    ErrorCode MES_TRACE_INTEGRITY_BIZ_TYPE_INVALID = new ErrorCode(1_040_762_001, "数据完整性业务类型无效，仅支持 BATCH/SALES/SCAN");
    ErrorCode MES_TRACE_INTEGRITY_BIZ_NOT_EXISTS = new ErrorCode(1_040_762_002, "待校验的业务数据不存在");

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/trace/MesTraceIntegrityBizTypeEnum.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,43 @@
package cn.iocoder.yudao.module.mes.enums.trace;

import lombok.AllArgsConstructor;
import lombok.Getter;

/**
 * æ•°æ®å®Œæ•´æ€§ä¸šåŠ¡ç±»åž‹æžšä¸¾
 *
 * @author è¶…级管理员
 */
@Getter
@AllArgsConstructor
public enum MesTraceIntegrityBizTypeEnum {

    BATCH("BATCH", "生产批次"),
    SALES("SALES", "销售出库"),
    SCAN("SCAN", "消费者扫码");

    /**
     * ä¸šåŠ¡ç±»åž‹
     */
    private final String type;
    /**
     * ç±»åž‹åç§°
     */
    private final String name;

    /**
     * åˆ¤æ–­ä¸šåŠ¡ç±»åž‹æ˜¯å¦åˆæ³•
     *
     * @param type ä¸šåŠ¡ç±»åž‹
     * @return æ˜¯å¦åˆæ³•
     */
    public static boolean isValid(String type) {
        for (MesTraceIntegrityBizTypeEnum e : values()) {
            if (e.type.equals(type)) {
                return true;
            }
        }
        return false;
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/trace/MesTraceWarningStatusEnum.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
package cn.iocoder.yudao.module.mes.enums.trace;

import cn.iocoder.yudao.framework.common.core.ArrayValuable;
import lombok.AllArgsConstructor;
import lombok.Getter;

import java.util.Arrays;

/**
 * çªœè´§é¢„警状态枚举
 *
 * @author è¶…级管理员
 */
@Getter
@AllArgsConstructor
public enum MesTraceWarningStatusEnum implements ArrayValuable<Integer> {

    PENDING(10, "待处理"),
    HANDLED(20, "已处理"),
    FALSE_ALARM(30, "误报");

    public static final Integer[] ARRAYS = Arrays.stream(values()).map(MesTraceWarningStatusEnum::getStatus).toArray(Integer[]::new);

    /**
     * çŠ¶æ€
     */
    private final Integer status;
    /**
     * çŠ¶æ€åç§°
     */
    private final String name;

    @Override
    public Integer[] array() {
        return ARRAYS;
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/trace/MesTraceWarningTypeEnum.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package cn.iocoder.yudao.module.mes.enums.trace;

import lombok.AllArgsConstructor;
import lombok.Getter;

/**
 * çªœè´§é¢„警类型枚举
 *
 * @author è¶…级管理员
 */
@Getter
@AllArgsConstructor
public enum MesTraceWarningTypeEnum {

    CROSS_PROVINCE("CROSS_PROVINCE", "跨省窜货"),
    CROSS_CITY("CROSS_CITY", "跨市窜货");

    /**
     * ç±»åž‹
     */
    private final String type;
    /**
     * ç±»åž‹åç§°
     */
    private final String name;

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/batch/MesProBatchServiceImpl.java

@@ -20,6 +20,7 @@
import cn.iocoder.yudao.module.mes.service.md.autocode.MesMdAutoCodeRecordService;
import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
import cn.iocoder.yudao.module.mes.service.pro.line.MesProLineService;
import cn.iocoder.yudao.module.mes.service.trace.integrity.MesTraceIntegrityService;
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
@@ -65,6 +66,8 @@
    private MesMdmItemService mdmItemService;
    @Resource
    private MesProLineService lineService;
    @Resource
    private MesTraceIntegrityService integrityService;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -89,6 +92,8 @@

        // 4. æ’入生产人员配置
        insertBatchWorkers(batch.getId(), createReqVO.getWorkers());
        // 5. ç”Ÿæˆæ‰¹æ¬¡å®Œæ•´æ€§æ‘˜è¦
        integrityService.recordBatchIntegrity(batch.getId());
        return batch.getId();
    }

@@ -139,6 +144,8 @@
        // 4. é‡å»ºç”Ÿäº§äººå‘˜é…ç½®
        batchWorkerMapper.deleteByBatchId(fillReqVO.getId());
        insertBatchWorkers(fillReqVO.getId(), fillReqVO.getWorkers());
        // 5. ç”Ÿæˆæ‰¹æ¬¡å®Œæ•´æ€§æ‘˜è¦ï¼ˆè¡¥å½•æ­£å¼ä¿¡æ¯åŽè¦†ç›–）
        integrityService.recordBatchIntegrity(fillReqVO.getId());
    }

    @Override
@@ -172,6 +179,8 @@
        // 5. é‡å»ºç”Ÿäº§äººå‘˜é…ç½®
        batchWorkerMapper.deleteByBatchId(updateReqVO.getId());
        insertBatchWorkers(updateReqVO.getId(), updateReqVO.getWorkers());
        // 6. æ‘˜è¦è¦†ç›–范围含品种/产线/生产日期/计划数量，编辑后重新生成避免误报篡改
        integrityService.recordBatchIntegrity(updateReqVO.getId());
    }

    @Override

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/MesProTracePublicServiceImpl.java

@@ -22,7 +22,12 @@
import cn.iocoder.yudao.module.mes.service.pro.batch.MesProBatchService;
import cn.iocoder.yudao.module.mes.service.pro.pallet.MesProPalletService;
import cn.iocoder.yudao.module.mes.service.pro.scan.MesProScanEventService;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import cn.iocoder.yudao.module.mes.service.qc.seedquality.MesQcSeedQualityService;
import cn.iocoder.yudao.module.mes.service.trace.consumer.MesTraceConsumerScanEventService;
import cn.iocoder.yudao.module.mes.service.trace.crossregion.MesTraceCrossRegionService;
import cn.iocoder.yudao.module.mes.service.trace.integrity.MesTraceIntegrityService;
import cn.iocoder.yudao.module.mes.service.wm.batch.MesWmBatchService;
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO;
@@ -73,21 +78,62 @@
    private AdminUserApi adminUserApi;
    @Resource
    private MesWmBatchService mesWmBatchService;
    @Resource
    private MesTraceConsumerScanEventService consumerScanEventService;
    @Resource
    private MesTraceCrossRegionService crossRegionService;
    @Resource
    private MesTraceIntegrityService integrityService;
    @Resource
    private MesTraceConsumerScanEventMapper consumerScanEventMapper;

    @Override
    public MesProTracePublicRespVO queryTrace(String code) {
        String rawCode = StrUtil.trim(StrUtil.nullToEmpty(code));
        String traceCode = normalize(rawCode);
        if (StrUtil.isEmpty(traceCode)) {
            recordConsumerScan(rawCode, traceCode, null, null, false);
            throw exception(MES_TRACE_CODE_NOT_FOUND);
        }
        // 1. è§£æžè¿½æº¯å…¥å£ï¼Œå®šä½æ‰¹æ¬¡
        TraceEntry entry = resolveEntry(traceCode);
        if (entry.batchId == null) {
            throw exception(MES_TRACE_CODE_NOT_FOUND);
        TraceEntry entry = null;
        try {
            // 1. è§£æžè¿½æº¯å…¥å£ï¼Œå®šä½æ‰¹æ¬¡
            entry = resolveEntry(traceCode);
            if (entry.batchId == null) {
                throw exception(MES_TRACE_CODE_NOT_FOUND);
            }
            // 2. èšåˆå…¨ç¨‹ä¿¡æ¯
            MesProTracePublicRespVO result = buildRespVO(rawCode, traceCode, entry.sourceType, entry.batchId);
            recordConsumerScan(rawCode, traceCode, entry.sourceType, entry.batchId, true);
            return result;
        } catch (RuntimeException ex) {
            recordConsumerScan(rawCode, traceCode, entry == null ? null : entry.sourceType,
                    entry == null ? null : entry.batchId, false);
            throw ex;
        }
        // 2. èšåˆå…¨ç¨‹ä¿¡æ¯
        return buildRespVO(rawCode, traceCode, entry.sourceType, entry.batchId);
    }

    /**
     * è®°å½•æ¶ˆè´¹è€…扫码事件，并触发防伪防窜货扩展（窜货判定 + æ‰«ç æ‘˜è¦ï¼‰ï¼Œå‡å®¹é”™ä¸å½±å“æº¯æºä¸»æµç¨‹
     */
    private MesTraceConsumerScanEventDO recordConsumerScan(String rawCode, String traceCode, String sourceType,
                                                           Long batchId, boolean success) {
        MesTraceConsumerScanEventDO event = consumerScanEventService.recordScan(rawCode, traceCode, sourceType,
                batchId, success, success ? null : MES_TRACE_CODE_NOT_FOUND.getCode().toString());
        if (event == null) {
            return null;
        }
        try {
            crossRegionService.checkAndCreateWarning(event);
        } catch (Exception ex) {
            log.warn("[recordConsumerScan][窜货判定失败] eventId={}", event.getId(), ex);
        }
        try {
            integrityService.recordScanIntegrity(event);
        } catch (Exception ex) {
            log.warn("[recordConsumerScan][扫码摘要生成失败] eventId={}", event.getId(), ex);
        }
        return event;
    }

    // ==================== è¿½æº¯ç è§£æž ====================
@@ -162,6 +208,8 @@
        resp.setInbound(buildInbound(batchId));
        // è´¨æ£€åŒºå—
        resp.setQuality(buildQuality(batch));
        // é˜²ä¼ªéªŒè¯åŒºå—
        fillAntiFake(resp, traceCode);
        // å¯é€‰æ‰©å±•åŒºå—（有数据才返回）
        fillOptionalModules(resp, batch);
        return resp;
@@ -254,6 +302,25 @@
        return vo;
    }

    /**
     * å¡«å……防伪验证区块：该追溯码累计扫码次数、首次/最近扫码时间（正品验证增强）
     */
    private void fillAntiFake(MesProTracePublicRespVO resp, String traceCode) {
        try {
            List<MesTraceConsumerScanEventDO> events = consumerScanEventMapper.selectListByNormalizedCode(traceCode);
            if (CollUtil.isEmpty(events)) {
                return;
            }
            MesProTracePublicRespVO.AntiFakeVO vo = new MesProTracePublicRespVO.AntiFakeVO();
            vo.setScanCount((long) events.size());
            vo.setFirstScanTime(events.get(0).getEventTime());
            vo.setLastScanTime(events.get(events.size() - 1).getEventTime());
            resp.setAntiFake(vo);
        } catch (Exception ex) {
            log.warn("[fillAntiFake][追溯码 {} é˜²ä¼ªéªŒè¯ç»Ÿè®¡å¤±è´¥: {}]", traceCode, ex.getMessage());
        }
    }

    private void fillOptionalModules(MesProTracePublicRespVO resp, MesProBatchDO batch) {
        try {
            List<MesWmBatchPurchaseSourceRespVO> purchaseSources = mesWmBatchService.getPurchaseSourceList(batch.getCode());

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/consumer/MesTraceConsumerScanEventService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;

/**
 * æ¶ˆè´¹è€…扫码访问事件 Service æŽ¥å£
 * <p>
 * è®°å½•å…¬ä¼—溯源扫码访问情况。记录失败不得影响溯源查询主流程，故实现层需保证不抛异常。
 *
 * @author è¶…级管理员
 */
public interface MesTraceConsumerScanEventService {

    /**
     * è®°å½•ä¸€æ¬¡æ¶ˆè´¹è€…扫码访问事件
     *
     * @param traceCode       æ‰«ç åŽŸå§‹å†…容
     * @param normalizedCode  è§£æžåŽçš„追溯码
     * @param sourceType      å…¥å£ç±»åž‹ï¼šBAG/PALLET/BATCH
     * @param batchId         ç”Ÿäº§æ‰¹æ¬¡ç¼–号，可空
     * @param success        æ˜¯å¦æŸ¥è¯¢æˆåŠŸ
     * @param errorCode       å¤±è´¥ç¼–码，成功传 null
     * @return äº‹ä»¶è®°å½•ï¼ˆå«ä¸»é”®ä¸Žæ‰«ç åœ°åŒºï¼‰ï¼›è®°å½•å¤±è´¥è¿”回 null
     */
    MesTraceConsumerScanEventDO recordScan(String traceCode, String normalizedCode, String sourceType, Long batchId,
                                           boolean success, String errorCode);

    /**
     * æ ¹æ® ID æŸ¥è¯¢äº‹ä»¶ï¼ˆä¾›æ ¡éªŒ/调试使用）
     *
     * @param id ä¸»é”®
     * @return äº‹ä»¶
     */
    MesTraceConsumerScanEventDO getEvent(Long id);

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/consumer/MesTraceConsumerScanEventServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,118 @@
package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.digest.DigestUtil;
import cn.iocoder.yudao.framework.common.util.servlet.ServletUtils;
import cn.iocoder.yudao.framework.ip.core.Area;
import cn.iocoder.yudao.framework.ip.core.enums.AreaTypeEnum;
import cn.iocoder.yudao.framework.ip.core.utils.IPUtils;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;

/**
 * æ¶ˆè´¹è€…扫码访问事件 Service å®žçŽ°
 *
 * @author è¶…级管理员
 */
@Service
@Slf4j
public class MesTraceConsumerScanEventServiceImpl implements MesTraceConsumerScanEventService {

    private static final int TRACE_CODE_MAX_LENGTH = 255;
    private static final int NORMALIZED_CODE_MAX_LENGTH = 128;

    @Resource
    private MesTraceConsumerScanEventMapper eventMapper;

    @Override
    public MesTraceConsumerScanEventDO recordScan(String traceCode, String normalizedCode, String sourceType,
                                                  Long batchId, boolean success, String errorCode) {
        try {
            MesTraceConsumerScanEventDO event = new MesTraceConsumerScanEventDO();
            event.setTraceCode(limit(traceCode, TRACE_CODE_MAX_LENGTH));
            event.setNormalizedCode(limit(normalizedCode, NORMALIZED_CODE_MAX_LENGTH));
            event.setSourceType(sourceType);
            event.setChannel(limit(channel(), 32));
            String[] region = region(ServletUtils.getClientIP());
            event.setProvince(limit(region[0], 64));
            event.setCity(limit(region[1], 64));
            event.setBatchId(batchId);
            event.setSuccess(success);
            event.setErrorCode(limit(errorCode, 64));
            event.setIpHash(hash(ServletUtils.getClientIP()));
            event.setUserAgentHash(hash(ServletUtils.getUserAgent()));
            event.setEventTime(LocalDateTime.now());
            eventMapper.insert(event);
            return event;
        } catch (Exception ex) {
            log.warn("[recordScan][记录消费者扫码访问事件失败] traceCode={}", limit(traceCode, 64), ex);
            return null;
        }
    }

    @Override
    public MesTraceConsumerScanEventDO getEvent(Long id) {
        return eventMapper.selectById(id);
    }

    /**
     * æ ¹æ® User-Agent è¯†åˆ«æ‰«ç å…¥å£æ¸ é“
     */
    private String channel() {
        String ua = ServletUtils.getUserAgent();
        if (StrUtil.isBlank(ua)) {
            return null;
        }
        String lower = ua.toLowerCase();
        if (lower.contains("micromessenger")) {
            return "微信";
        }
        if (lower.contains("alipayclient")) {
            return "支付宝";
        }
        return "浏览器";
    }

    /**
     * æ ¹æ®å®¢æˆ·ç«¯ IP è§£æžçœä»½ã€åŸŽå¸‚；解析失败返回空，不影响事件记录
     */
    private String[] region(String ip) {
        if (StrUtil.isBlank(ip)) {
            return new String[]{null, null};
        }
        Area area = IPUtils.getArea(ip);
        if (area == null) {
            return new String[]{null, null};
        }
        String province = null;
        String city = null;
        Area node = area;
        while (node != null) {
            Integer type = node.getType();
            if (AreaTypeEnum.PROVINCE.getType().equals(type)) {
                province = node.getName();
            } else if (AreaTypeEnum.CITY.getType().equals(type)) {
                city = node.getName();
            }
            node = node.getParent();
        }
        return new String[]{province, city};
    }

    private String hash(String value) {
        return value == null || value.isBlank() ? null : DigestUtil.sha256Hex(value);
    }

    private String limit(String value, int maxLength) {
        if (value == null || value.length() <= maxLength) {
            return value;
        }
        return value.substring(0, maxLength);
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/consumer/MesTraceConsumerScanStatisticsService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanTrendRespVO;

import java.time.LocalDateTime;
import java.util.List;

public interface MesTraceConsumerScanStatisticsService {
    MesTraceConsumerScanSummaryRespVO getSummary(LocalDateTime startTime, LocalDateTime endTime);
    List<MesTraceConsumerScanTrendRespVO> getTrend(LocalDateTime startTime, LocalDateTime endTime);
    List<MesTraceConsumerScanDistributionRespVO> getDistribution(MesTraceConsumerScanDistributionReqVO reqVO);
}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/consumer/MesTraceConsumerScanStatisticsServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,150 @@
package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanTrendRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanStatisticsMapper;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
 * æ¶ˆè´¹è€…扫码访问统计 Service å®žçŽ°
 * <p>
 * é‡‡ç”¨æŸ¥æ˜Žç»† + Java ä¾§èšåˆï¼šé¿å…ç»Ÿè®¡ SQL ä¸Ž MySQL/H2 æ–¹è¨€å·®å¼‚，同时不暴露动态列 SQL。
 *
 * @author è¶…级管理员
 */
@Service
public class MesTraceConsumerScanStatisticsServiceImpl implements MesTraceConsumerScanStatisticsService {

    /**
     * åˆ†ç»„维度白名单：仅允许按固定字段聚合，非法维度直接拒绝
     */
    private static final Map<String, Function<MesTraceConsumerScanEventDO, String>> GROUP_COLUMNS = Map.of(
            "sourceType", e -> e.getSourceType(),
            "success", e -> Boolean.TRUE.equals(e.getSuccess()) ? "1" : "0",
            "channel", MesTraceConsumerScanEventDO::getChannel,
            "province", MesTraceConsumerScanEventDO::getProvince,
            "city", MesTraceConsumerScanEventDO::getCity,
            "batchId", e -> e.getBatchId() == null ? null : String.valueOf(e.getBatchId()));

    /**
     * ç©ºåˆ†ç»„键占位符：Collectors.groupingBy ä¸æŽ¥å— null key，先统一替换再在展示时映射为"未知"
     */
    private static final String UNKNOWN_KEY = "__unknown__";

    @Resource
    private MesTraceConsumerScanStatisticsMapper mapper;

    @Override
    public MesTraceConsumerScanSummaryRespVO getSummary(LocalDateTime startTime, LocalDateTime endTime) {
        List<MesTraceConsumerScanEventDO> events = mapper.selectListByTime(startTime, endTime);
        MesTraceConsumerScanSummaryRespVO vo = new MesTraceConsumerScanSummaryRespVO();
        vo.setTotal((long) events.size());
        vo.setSuccess(events.stream().filter(e -> Boolean.TRUE.equals(e.getSuccess())).count());
        vo.setFailed(events.stream().filter(e -> !Boolean.TRUE.equals(e.getSuccess())).count());
        vo.setUniqueBatchCount(events.stream().map(MesTraceConsumerScanEventDO::getBatchId)
                .filter(java.util.Objects::nonNull).distinct().count());
        return vo;
    }

    @Override
    public List<MesTraceConsumerScanTrendRespVO> getTrend(LocalDateTime startTime, LocalDateTime endTime) {
        List<MesTraceConsumerScanEventDO> events = mapper.selectListByTime(startTime, endTime);
        // æŒ‰æ—¥æœŸèšåˆ
        Map<LocalDate, MesTraceConsumerScanTrendRespVO> data = new TreeMap<>();
        LocalDate min = null;
        LocalDate max = null;
        for (MesTraceConsumerScanEventDO event : events) {
            LocalDate date = event.getEventTime().toLocalDate();
            MesTraceConsumerScanTrendRespVO vo = data.computeIfAbsent(date, d -> {
                MesTraceConsumerScanTrendRespVO v = new MesTraceConsumerScanTrendRespVO();
                v.setDate(d.toString());
                v.setTotal(0L);
                v.setSuccess(0L);
                v.setFailed(0L);
                return v;
            });
            vo.setTotal(vo.getTotal() + 1);
            if (Boolean.TRUE.equals(event.getSuccess())) {
                vo.setSuccess(vo.getSuccess() + 1);
            } else {
                vo.setFailed(vo.getFailed() + 1);
            }
            if (min == null || date.isBefore(min)) {
                min = date;
            }
            if (max == null || date.isAfter(max)) {
                max = date;
            }
        }
        // è¡¥é½åŒºé—´å†…无数据的日期（时间参数为空时退回已有数据的最小/最大日期区间）
        LocalDate start = startTime != null ? startTime.toLocalDate() : min;
        LocalDate end = endTime != null
                ? (endTime.toLocalTime().equals(LocalTime.MIDNIGHT) ? endTime.toLocalDate().minusDays(1) : endTime.toLocalDate())
                : max;
        if (start != null && end != null && !start.isAfter(end)) {
            for (LocalDate day = start; !day.isAfter(end); day = day.plusDays(1)) {
                data.computeIfAbsent(day, d -> {
                    MesTraceConsumerScanTrendRespVO v = new MesTraceConsumerScanTrendRespVO();
                    v.setDate(d.toString());
                    v.setTotal(0L);
                    v.setSuccess(0L);
                    v.setFailed(0L);
                    return v;
                });
            }
        }
        return new ArrayList<>(data.values());
    }

    @Override
    public List<MesTraceConsumerScanDistributionRespVO> getDistribution(MesTraceConsumerScanDistributionReqVO reqVO) {
        Function<MesTraceConsumerScanEventDO, String> extractor = GROUP_COLUMNS.get(reqVO.getGroupBy());
        if (extractor == null) {
            throw new IllegalArgumentException("不支持的分组维度");
        }
        List<MesTraceConsumerScanEventDO> events = mapper.selectListByTime(reqVO.getStartTime(), reqVO.getEndTime());
        // æŒ‰æ•°é‡å€’序分组；groupingBy ä¸æŽ¥å— null key，先统一替换为占位符再聚合
        Map<String, Long> counts = events.stream().collect(Collectors.groupingBy(e -> {
            String key = extractor.apply(e);
            return key == null ? UNKNOWN_KEY : key;
        }, Collectors.counting()));
        return counts.entrySet().stream()
                .sorted(Comparator.comparing(Map.Entry<String, Long>::getValue).reversed()
                        .thenComparing(Map.Entry.comparingByKey()))
                .map(entry -> {
                    MesTraceConsumerScanDistributionRespVO vo = new MesTraceConsumerScanDistributionRespVO();
                    String name = entry.getKey();
                    vo.setName(UNKNOWN_KEY.equals(name) ? "未知" : displayName(reqVO.getGroupBy(), name));
                    vo.setCount(entry.getValue());
                    return vo;
                })
                .collect(Collectors.toCollection(ArrayList::new));
    }

    /**
     * å¸ƒå°”分区做可读映射，保证统计口径与前端展示一致
     */
    private String displayName(String groupBy, String name) {
        if ("success".equals(groupBy)) {
            return "1".equals(name) ? "成功" : "失败";
        }
        return name;
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/crossregion/MesTraceCrossRegionService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,80 @@
package cn.iocoder.yudao.module.mes.service.trace.crossregion;

import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceAntiConfigRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionHandleReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;

import java.time.LocalDateTime;
import java.util.List;

/**
 * çªœè´§é¢„è­¦ Service æŽ¥å£
 * <p>
 * æ¶ˆè´¹è€…扫码地区与袋码出库经销商所在地区不一致时自动生成预警，并提供管理端稽查、处理与统计能力。
 *
 * @author è¶…级管理员
 */
public interface MesTraceCrossRegionService {

    /**
     * æ¶ˆè´¹è€…扫码成功后进行窜货判定，异常流向自动生成预警
     * <p>
     * åˆ¤å®šå¤±è´¥ä¸å½±å“æº¯æºä¸»æµç¨‹ï¼Œå®žçŽ°å±‚需保证不抛异常。
     *
     * @param event æ¶ˆè´¹è€…扫码事件（含解析后的追溯码、入口类型、扫码地区）
     */
    void checkAndCreateWarning(MesTraceConsumerScanEventDO event);

    /**
     * èŽ·å¾—窜货预警分页
     *
     * @param reqVO æŸ¥è¯¢æ¡ä»¶
     * @return çªœè´§é¢„警分页
     */
    PageResult<MesTraceCrossRegionWarningRespVO> getWarningPage(MesTraceCrossRegionWarningPageReqVO reqVO);

    /**
     * å¤„理窜货预警（已处理 / è¯¯æŠ¥ï¼‰ï¼Œä»…待处理状态可处理
     *
     * @param reqVO å¤„理信息
     */
    void handleWarning(MesTraceCrossRegionHandleReqVO reqVO);

    /**
     * èŽ·å¾—窜货预警汇总
     *
     * @param startTime å¼€å§‹æ—¶é—´ï¼Œå¯ç©º
     * @param endTime   ç»“束时间，可空
     * @return æ±‡æ€»ä¿¡æ¯
     */
    MesTraceCrossRegionSummaryRespVO getWarningSummary(LocalDateTime startTime, LocalDateTime endTime);

    /**
     * èŽ·å¾—窜货预警分布统计（按省份/城市/经销商/物料/批次分组）
     *
     * @param reqVO åˆ†ç»„条件
     * @return åˆ†å¸ƒç»Ÿè®¡åˆ—表
     */
    List<MesTraceCrossRegionStatisticsRespVO> getWarningStatistics(MesTraceCrossRegionStatisticsReqVO reqVO);

    /**
     * èŽ·å¾—防窜货规则配置
     *
     * @return è§„则配置
     */
    MesTraceAntiConfigRespVO getConfig();

    /**
     * æ›´æ–°é˜²çªœè´§è§„则配置（判定粒度切换：PROVINCE è·¨çœ / CITY è·¨å¸‚）
     *
     * @param warningLevel åˆ¤å®šç²’度
     */
    void updateConfig(String warningLevel);

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/crossregion/MesTraceCrossRegionServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,423 @@
package cn.iocoder.yudao.module.mes.service.trace.crossregion;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.collection.MapUtils;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.ip.core.Area;
import cn.iocoder.yudao.framework.ip.core.enums.AreaTypeEnum;
import cn.iocoder.yudao.framework.ip.core.utils.AreaUtils;
import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceAntiConfigRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionHandleReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.mdm.MesMdmItemDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.batch.MesProBatchDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.pallet.MesProPalletDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion.MesTraceAntiConfigDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion.MesTraceCrossRegionWarningDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDetailDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.crossregion.MesTraceAntiConfigMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.crossregion.MesTraceCrossRegionWarningMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesDetailMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesMapper;
import cn.iocoder.yudao.module.mes.enums.trace.MesTraceWarningStatusEnum;
import cn.iocoder.yudao.module.mes.enums.trace.MesTraceWarningTypeEnum;
import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
import cn.iocoder.yudao.module.mes.service.pro.bagcode.MesProBagCodeService;
import cn.iocoder.yudao.module.mes.service.pro.batch.MesProBatchService;
import cn.iocoder.yudao.module.mes.service.pro.pallet.MesProPalletService;
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_ANTI_CONFIG_NOT_EXISTS;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_ANTI_CONFIG_VALUE_INVALID;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_CROSS_REGION_STATUS_INVALID;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_CROSS_REGION_WARNING_NOT_EXISTS;

/**
 * çªœè´§é¢„è­¦ Service å®žçŽ°ç±»
 *
 * @author è¶…级管理员
 */
@Service
@Validated
@Slf4j
public class MesTraceCrossRegionServiceImpl implements MesTraceCrossRegionService {

    private static final String CONFIG_KEY_WARNING_LEVEL = "warning_level";

    /**
     * åˆ†å¸ƒç»Ÿè®¡åˆ†ç»„白名单：仅允许固定业务字段分组，防止任意 key ä¼ å…¥ã€‚
     */
    private static final Map<String, java.util.function.Function<MesTraceCrossRegionWarningDO, String>> STAT_GROUP_EXTRACTORS =
            Map.ofEntries(
                    Map.entry("scanProvince", w -> w.getScanProvince()),
                    Map.entry("scanCity", w -> w.getScanCity()),
                    Map.entry("clientId", w -> w.getClientName()),
                    Map.entry("itemId", w -> w.getItemName()),
                    Map.entry("batchId", w -> w.getBatchCode()));

    @Resource
    private MesTraceCrossRegionWarningMapper warningMapper;
    @Resource
    private MesTraceAntiConfigMapper antiConfigMapper;
    @Resource
    private MesWmProductSalesMapper productSalesMapper;
    @Resource
    private MesWmProductSalesDetailMapper productSalesDetailMapper;
    @Resource
    private MesProBagCodeService bagCodeService;
    @Resource
    private MesProPalletService palletService;
    @Resource
    private MesProBatchService batchService;
    @Resource
    private MesMdmItemService mdmItemService;
    @Resource
    private CrmCustomerApi customerApi;
    @Resource
    private AdminUserApi adminUserApi;

    @Override
    public void checkAndCreateWarning(MesTraceConsumerScanEventDO event) {
        try {
            doCheckAndCreateWarning(event);
        } catch (Exception ex) {
            // çªœè´§åˆ¤å®šå¤±è´¥ä¸å½±å“æ¶ˆè´¹è€…溯源主流程
            log.warn("[checkAndCreateWarning][窜货判定失败] traceCode={}", event == null ? null : event.getNormalizedCode(), ex);
        }
    }

    private void doCheckAndCreateWarning(MesTraceConsumerScanEventDO event) {
        if (event == null) {
            return;
        }
        // 1. ä»…袋码/托盘入口可精确定位出库去向，批次码跳过
        String sourceType = event.getSourceType();
        boolean bag = "BAG".equals(sourceType);
        boolean pallet = "PALLET".equals(sourceType);
        if (!bag && !pallet) {
            return;
        }
        // 2. æ‰«ç åœ°åŒºï¼ˆIP å½’属地，记录事件时已解析），无地区无法判定
        String scanProvince = event.getProvince();
        String scanCity = event.getCity();
        if (StrUtil.isBlank(scanProvince) && StrUtil.isBlank(scanCity)) {
            return;
        }
        // 3. åæŸ¥è¢‹ç /托盘，定位出库单
        Long codeId;
        Long batchId;
        String code;
        Long salesId;
        if (bag) {
            MesProBagCodeDO bagCode = bagCodeService.getBagCodeByCode(event.getNormalizedCode());
            if (bagCode == null) {
                return;
            }
            codeId = bagCode.getId();
            code = bagCode.getCode();
            batchId = bagCode.getBatchId();
            salesId = bagCode.getSalesId();
        } else {
            MesProPalletDO palletCode = palletService.getPalletByCode(event.getNormalizedCode());
            if (palletCode == null) {
                return;
            }
            codeId = palletCode.getId();
            code = palletCode.getCode();
            batchId = palletCode.getBatchId();
            salesId = palletCode.getSalesId();
        }
        // 4. è¢‹ç æœªå›žå†™å‡ºåº“单（历史数据）时，兜底查明细表
        if (salesId == null) {
            MesWmProductSalesDetailDO detail = bag
                    ? productSalesDetailMapper.selectLatestByBagCodeId(codeId)
                    : productSalesDetailMapper.selectLatestByPalletCodeId(codeId);
            if (detail == null || detail.getSalesId() == null) {
                return; // æœªå‡ºåº“，无窜货比对基础
            }
            salesId = detail.getSalesId();
        }
        // 5. æŸ¥å‡ºåº“单与经销商地区
        MesWmProductSalesDO sales = productSalesMapper.selectById(salesId);
        if (sales == null || sales.getClientId() == null) {
            return;
        }
        CrmCustomerRespDTO customer = customerApi.getCustomer(sales.getClientId());
        if (customer == null || customer.getAreaId() == null) {
            return;
        }
        String[] dealerRegion = resolveRegion(customer.getAreaId());
        String dealerProvince = dealerRegion[0];
        String dealerCity = dealerRegion[1];
        if (StrUtil.isBlank(dealerProvince)) {
            return;
        }
        // 6. æŒ‰åˆ¤å®šç²’度比对
        String warningType = matchWarningType(getWarningLevel(), scanProvince, scanCity, dealerProvince, dealerCity);
        if (warningType == null) {
            return;
        }
        // 7. å†—余填充物料/批次信息
        MesProBatchDO batch = batchId != null ? batchService.getBatch(batchId) : null;
        MesMdmItemDO item = batch != null && batch.getItemId() != null ? mdmItemService.getItem(batch.getItemId()) : null;
        // 8. å†™å…¥é¢„è­¦
        MesTraceCrossRegionWarningDO warning = MesTraceCrossRegionWarningDO.builder()
                .warningNo(generateWarningNo())
                .bagCodeId(bag ? codeId : null)
                .bagCode(bag ? code : null)
                .palletCodeId(pallet ? codeId : null)
                .palletCode(pallet ? code : null)
                .batchId(batch != null ? batch.getId() : null)
                .batchCode(batch != null ? batch.getCode() : null)
                .itemId(item != null ? item.getId() : null)
                .itemCode(item != null ? item.getCode() : null)
                .itemName(item != null ? item.getName() : null)
                .salesId(sales.getId())
                .salesCode(sales.getCode())
                .clientId(sales.getClientId())
                .clientName(sales.getClientName())
                .dealerProvince(dealerProvince)
                .dealerCity(dealerCity)
                .scanProvince(scanProvince)
                .scanCity(scanCity)
                .warningType(warningType)
                .scanEventId(event.getId())
                .status(MesTraceWarningStatusEnum.PENDING.getStatus())
                .eventTime(event.getEventTime() != null ? event.getEventTime() : LocalDateTime.now())
                .build();
        warningMapper.insert(warning);
    }

    @Override
    public PageResult<MesTraceCrossRegionWarningRespVO> getWarningPage(MesTraceCrossRegionWarningPageReqVO reqVO) {
        PageResult<MesTraceCrossRegionWarningDO> pageResult = warningMapper.selectPage(reqVO);
        if (CollUtil.isEmpty(pageResult.getList())) {
            return PageResult.empty();
        }
        // æ‰¹é‡æŸ¥å¤„理人姓名
        Set<Long> handleUserIds = convertSet(pageResult.getList(), MesTraceCrossRegionWarningDO::getHandleUserId);
        Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(handleUserIds);
        List<MesTraceCrossRegionWarningRespVO> list = BeanUtils.toBean(pageResult.getList(),
                MesTraceCrossRegionWarningRespVO.class, vo -> {
                    MesTraceCrossRegionWarningDO warning = pageResult.getList().stream()
                            .filter(w -> ObjUtil.equal(w.getId(), vo.getId())).findFirst().orElse(null);
                    if (warning == null) {
                        return;
                    }
                    vo.setStatusName(statusName(warning.getStatus()));
                    vo.setWarningTypeName(warningTypeName(warning.getWarningType()));
                    MapUtils.findAndThen(userMap, warning.getHandleUserId(),
                            user -> vo.setHandleUserName(user.getNickname()));
                });
        return new PageResult<>(list, pageResult.getTotal());
    }

    @Override
    public void handleWarning(MesTraceCrossRegionHandleReqVO reqVO) {
        MesTraceCrossRegionWarningDO warning = warningMapper.selectById(reqVO.getId());
        if (warning == null) {
            throw exception(MES_TRACE_CROSS_REGION_WARNING_NOT_EXISTS);
        }
        if (!ObjUtil.equal(MesTraceWarningStatusEnum.PENDING.getStatus(), warning.getStatus())) {
            throw exception(MES_TRACE_CROSS_REGION_STATUS_INVALID);
        }
        if (!ObjUtil.equal(MesTraceWarningStatusEnum.HANDLED.getStatus(), reqVO.getStatus())
                && !ObjUtil.equal(MesTraceWarningStatusEnum.FALSE_ALARM.getStatus(), reqVO.getStatus())) {
            throw exception(MES_TRACE_CROSS_REGION_STATUS_INVALID);
        }
        warningMapper.updateById(new MesTraceCrossRegionWarningDO()
                .setId(warning.getId())
                .setStatus(reqVO.getStatus())
                .setHandleRemark(reqVO.getHandleRemark())
                .setHandleUserId(SecurityFrameworkUtils.getLoginUserId())
                .setHandleTime(LocalDateTime.now()));
    }

    @Override
    public MesTraceCrossRegionSummaryRespVO getWarningSummary(LocalDateTime startTime, LocalDateTime endTime) {
        List<MesTraceCrossRegionWarningDO> list = warningMapper.selectListByEventTimeBetween(startTime, endTime);
        MesTraceCrossRegionSummaryRespVO vo = new MesTraceCrossRegionSummaryRespVO();
        long total = list.size();
        long pending = 0L;
        long handled = 0L;
        long falseAlarm = 0L;
        long crossProvince = 0L;
        long crossCity = 0L;
        for (MesTraceCrossRegionWarningDO w : list) {
            if (ObjUtil.equal(MesTraceWarningStatusEnum.PENDING.getStatus(), w.getStatus())) {
                pending++;
            } else if (ObjUtil.equal(MesTraceWarningStatusEnum.HANDLED.getStatus(), w.getStatus())) {
                handled++;
            } else if (ObjUtil.equal(MesTraceWarningStatusEnum.FALSE_ALARM.getStatus(), w.getStatus())) {
                falseAlarm++;
            }
            if (ObjUtil.equal(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType(), w.getWarningType())) {
                crossProvince++;
            } else if (ObjUtil.equal(MesTraceWarningTypeEnum.CROSS_CITY.getType(), w.getWarningType())) {
                crossCity++;
            }
        }
        vo.setTotal(total).setPending(pending).setHandled(handled).setFalseAlarm(falseAlarm)
                .setCrossProvince(crossProvince).setCrossCity(crossCity);
        return vo;
    }

    @Override
    public List<MesTraceCrossRegionStatisticsRespVO> getWarningStatistics(MesTraceCrossRegionStatisticsReqVO reqVO) {
        java.util.function.Function<MesTraceCrossRegionWarningDO, String> extractor = STAT_GROUP_EXTRACTORS.get(reqVO.getGroupBy());
        if (extractor == null) {
            throw new IllegalArgumentException("不支持的分组维度");
        }
        List<MesTraceCrossRegionWarningDO> list = warningMapper.selectListByEventTimeBetween(reqVO.getStartTime(), reqVO.getEndTime());
        Map<String, Long> counts = new LinkedHashMap<>();
        for (MesTraceCrossRegionWarningDO w : list) {
            String key = StrUtil.nullToDefault(extractor.apply(w), "未知");
            counts.merge(key, 1L, Long::sum);
        }
        return counts.entrySet().stream()
                .sorted(Map.Entry.<String, Long>comparingByValue().reversed())
                .map(entry -> new MesTraceCrossRegionStatisticsRespVO().setName(entry.getKey()).setCount(entry.getValue()))
                .toList();
    }

    @Override
    public MesTraceAntiConfigRespVO getConfig() {
        MesTraceAntiConfigDO config = antiConfigMapper.selectByConfigKey(CONFIG_KEY_WARNING_LEVEL);
        if (config == null) {
            throw exception(MES_TRACE_ANTI_CONFIG_NOT_EXISTS);
        }
        return new MesTraceAntiConfigRespVO().setWarningLevel(config.getConfigValue()).setRemark(config.getRemark());
    }

    @Override
    public void updateConfig(String warningLevel) {
        if (!ObjUtil.equal("PROVINCE", warningLevel) && !ObjUtil.equal("CITY", warningLevel)) {
            throw exception(MES_TRACE_ANTI_CONFIG_VALUE_INVALID);
        }
        MesTraceAntiConfigDO config = antiConfigMapper.selectByConfigKey(CONFIG_KEY_WARNING_LEVEL);
        if (config == null) {
            throw exception(MES_TRACE_ANTI_CONFIG_NOT_EXISTS);
        }
        antiConfigMapper.updateById(new MesTraceAntiConfigDO().setId(config.getId()).setConfigValue(warningLevel));
    }

    // ==================== ç§æœ‰æ–¹æ³• ====================

    /**
     * è¯»å–判定粒度：PROVINCE è·¨çœ / CITY è·¨å¸‚，配置缺失时默认按省判定
     */
    private String getWarningLevel() {
        MesTraceAntiConfigDO config = antiConfigMapper.selectByConfigKey(CONFIG_KEY_WARNING_LEVEL);
        return config != null ? StrUtil.nullToDefault(config.getConfigValue(), "PROVINCE") : "PROVINCE";
    }

    /**
     * æŒ‰åˆ¤å®šç²’度比对扫码地区与经销商地区，返回命中预警类型，未命中返回 null
     */
    private String matchWarningType(String level, String scanProvince, String scanCity,
                                    String dealerProvince, String dealerCity) {
        if ("CITY".equals(level)) {
            // åŸŽå¸‚粒度：扫码市与经销商市不一致（需双方都有城市，否则退回省级判断）
            if (StrUtil.isNotBlank(scanCity) && StrUtil.isNotBlank(dealerCity) && !scanCity.equals(dealerCity)) {
                return MesTraceWarningTypeEnum.CROSS_CITY.getType();
            }
            if (StrUtil.isNotBlank(scanProvince) && StrUtil.isNotBlank(dealerProvince) && !scanProvince.equals(dealerProvince)) {
                return MesTraceWarningTypeEnum.CROSS_PROVINCE.getType();
            }
            return null;
        }
        // çœçº§ç²’度
        if (StrUtil.isNotBlank(scanProvince) && StrUtil.isNotBlank(dealerProvince) && !scanProvince.equals(dealerProvince)) {
            return MesTraceWarningTypeEnum.CROSS_PROVINCE.getType();
        }
        return null;
    }

    /**
     * æ ¹æ® Area id å‘上解析省市区（与消费者扫码事件 IP å½’属地解析口径一致，保证可比较）
     */
    private String[] resolveRegion(Integer areaId) {
        if (areaId == null) {
            return new String[]{null, null};
        }
        Area area = AreaUtils.getArea(areaId);
        if (area == null) {
            return new String[]{null, null};
        }
        String province = null;
        String city = null;
        Area node = area;
        while (node != null) {
            Integer type = node.getType();
            if (AreaTypeEnum.PROVINCE.getType().equals(type)) {
                province = node.getName();
            } else if (AreaTypeEnum.CITY.getType().equals(type)) {
                city = node.getName();
            }
            node = node.getParent();
        }
        return new String[]{province, city};
    }

    /**
     * ç”Ÿæˆé¢„警编号：WARN + æ—¶é—´æˆ³ + éšæœºåºå·
     */
    private String generateWarningNo() {
        return "WARN" + java.time.LocalDateTime.now()
                .format(java.time.format.DateTimeFormatter.ofPattern("yyyyMMddHHmmss"))
                + StrUtil.sub(IdUtil.fastSimpleUUID(), 0, 6).toUpperCase();
    }

    private String statusName(Integer status) {
        if (status == null) {
            return "";
        }
        for (MesTraceWarningStatusEnum e : MesTraceWarningStatusEnum.values()) {
            if (ObjUtil.equal(e.getStatus(), status)) {
                return e.getName();
            }
        }
        return String.valueOf(status);
    }

    private String warningTypeName(String type) {
        if (type == null) {
            return "";
        }
        for (MesTraceWarningTypeEnum e : MesTraceWarningTypeEnum.values()) {
            if (ObjUtil.equal(e.getType(), type)) {
                return e.getName();
            }
        }
        return type;
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/integrity/MesTraceIntegrityService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,57 @@
package cn.iocoder.yudao.module.mes.service.trace.integrity;

import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityRecordPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityVerifyRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.integrity.MesTraceIntegrityRecordDO;

/**
 * æ•°æ®å®Œæ•´æ€§ Service æŽ¥å£
 * <p>
 * åœ¨æ‰¹æ¬¡åˆ›å»ºã€é”€å”®å‡ºåº“、消费者扫码等关键事件发生时，对不可变核心字段生成 SHA-256 æ‘˜è¦å¹¶å­˜å‚¨ï¼›
 * æä¾›é‡ç®—比对能力，供管理端发现事后篡改。摘要生成失败不得阻断业务主流程。
 *
 * @author è¶…级管理员
 */
public interface MesTraceIntegrityService {

    /**
     * ç”Ÿæˆå¹¶ä¿å­˜æ‰¹æ¬¡å®Œæ•´æ€§æ‘˜è¦ï¼ˆcode|itemId|lineCode|produceDate|planQuantity）
     *
     * @param batchId æ‰¹æ¬¡ç¼–号
     */
    void recordBatchIntegrity(Long batchId);

    /**
     * ç”Ÿæˆå¹¶ä¿å­˜é”€å”®å‡ºåº“完整性摘要（code|clientId|salesDate|明细袋码/托盘码id列表）
     *
     * @param salesId é”€å”®å‡ºåº“单编号
     */
    void recordSalesIntegrity(Long salesId);

    /**
     * ç”Ÿæˆå¹¶ä¿å­˜æ¶ˆè´¹è€…扫码事件完整性摘要（normalizedCode|sourceType|province|city|success|eventTime）
     *
     * @param event æ¶ˆè´¹è€…扫码事件
     */
    void recordScanIntegrity(MesTraceConsumerScanEventDO event);

    /**
     * æ ¡éªŒæ•°æ®å®Œæ•´æ€§ï¼šé‡ç®—当前数据摘要，与存储摘要比对
     *
     * @param bizType ä¸šåŠ¡ç±»åž‹ï¼šBATCH / SALES / SCAN
     * @param bizId   ä¸šåŠ¡è®°å½•ç¼–号
     * @return æ ¡éªŒç»“æžœ
     */
    MesTraceIntegrityVerifyRespVO verify(String bizType, Long bizId);

    /**
     * èŽ·å¾—数据完整性记录分页
     *
     * @param reqVO æŸ¥è¯¢æ¡ä»¶
     * @return è®°å½•åˆ†é¡µ
     */
    PageResult<MesTraceIntegrityRecordDO> getIntegrityPage(MesTraceIntegrityRecordPageReqVO reqVO);

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/trace/integrity/MesTraceIntegrityServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,237 @@
package cn.iocoder.yudao.module.mes.service.trace.integrity;

import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.digest.DigestUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityRecordPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityVerifyRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.batch.MesProBatchDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.integrity.MesTraceIntegrityRecordDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDetailDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.bagcode.MesProBagCodeMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.batch.MesProBatchMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.integrity.MesTraceIntegrityRecordMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesDetailMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesMapper;
import cn.iocoder.yudao.module.mes.enums.trace.MesTraceIntegrityBizTypeEnum;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

import java.time.LocalDateTime;
import java.util.Comparator;
import java.util.List;
import java.util.Objects;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_INTEGRITY_BIZ_NOT_EXISTS;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_INTEGRITY_BIZ_TYPE_INVALID;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_INTEGRITY_RECORD_NOT_EXISTS;

/**
 * æ•°æ®å®Œæ•´æ€§ Service å®žçŽ°ç±»
 * <p>
 * æ‘˜è¦ä»…覆盖不可变核心字段，避免正常业务流转（草稿→生产中→完成、出库后状态更新等）导致误报。
 *
 * @author è¶…级管理员
 */
@Service
@Validated
@Slf4j
public class MesTraceIntegrityServiceImpl implements MesTraceIntegrityService {

    @Resource
    private MesTraceIntegrityRecordMapper integrityRecordMapper;
    @Resource
    private MesProBatchMapper batchMapper;
    @Resource
    private MesProBagCodeMapper bagCodeMapper;
    @Resource
    private MesWmProductSalesMapper productSalesMapper;
    @Resource
    private MesWmProductSalesDetailMapper productSalesDetailMapper;
    @Resource
    private MesTraceConsumerScanEventMapper scanEventMapper;

    @Override
    public void recordBatchIntegrity(Long batchId) {
        try {
            MesProBatchDO batch = batchMapper.selectById(batchId);
            if (batch == null) {
                return;
            }
            upsertRecord(MesTraceIntegrityBizTypeEnum.BATCH.getType(), batch.getId(), batch.getCode(), batchHash(batch));
        } catch (Exception ex) {
            log.warn("[recordBatchIntegrity][批次摘要生成失败] batchId={}", batchId, ex);
        }
    }

    @Override
    public void recordSalesIntegrity(Long salesId) {
        try {
            MesWmProductSalesDO sales = productSalesMapper.selectById(salesId);
            if (sales == null) {
                return;
            }
            String hash = salesHash(sales, productSalesDetailMapper.selectListBySalesId(salesId));
            upsertRecord(MesTraceIntegrityBizTypeEnum.SALES.getType(), sales.getId(), sales.getCode(), hash);
        } catch (Exception ex) {
            log.warn("[recordSalesIntegrity][出库摘要生成失败] salesId={}", salesId, ex);
        }
    }

    @Override
    public void recordScanIntegrity(MesTraceConsumerScanEventDO event) {
        if (event == null || event.getId() == null) {
            return;
        }
        try {
            upsertRecord(MesTraceIntegrityBizTypeEnum.SCAN.getType(), event.getId(), event.getNormalizedCode(), scanHash(event));
        } catch (Exception ex) {
            log.warn("[recordScanIntegrity][扫码摘要生成失败] scanEventId={}", event.getId(), ex);
        }
    }

    @Override
    public MesTraceIntegrityVerifyRespVO verify(String bizType, Long bizId) {
        if (!MesTraceIntegrityBizTypeEnum.isValid(bizType)) {
            throw exception(MES_TRACE_INTEGRITY_BIZ_TYPE_INVALID);
        }
        MesTraceIntegrityRecordDO record = integrityRecordMapper.selectByBiz(bizType, bizId);
        if (record == null) {
            throw exception(MES_TRACE_INTEGRITY_RECORD_NOT_EXISTS);
        }
        String currentHash;
        String bizCode = record.getBizCode();
        String bagSetHash = null;
        if (MesTraceIntegrityBizTypeEnum.BATCH.getType().equals(bizType)) {
            MesProBatchDO batch = batchMapper.selectById(bizId);
            if (batch == null) {
                throw exception(MES_TRACE_INTEGRITY_BIZ_NOT_EXISTS);
            }
            bizCode = batch.getCode();
            currentHash = batchHash(batch);
            bagSetHash = bagSetHash(bizId);
        } else if (MesTraceIntegrityBizTypeEnum.SALES.getType().equals(bizType)) {
            MesWmProductSalesDO sales = productSalesMapper.selectById(bizId);
            if (sales == null) {
                throw exception(MES_TRACE_INTEGRITY_BIZ_NOT_EXISTS);
            }
            bizCode = sales.getCode();
            currentHash = salesHash(sales, productSalesDetailMapper.selectListBySalesId(bizId));
        } else {
            MesTraceConsumerScanEventDO event = scanEventMapper.selectById(bizId);
            if (event == null) {
                throw exception(MES_TRACE_INTEGRITY_BIZ_NOT_EXISTS);
            }
            bizCode = event.getNormalizedCode();
            currentHash = scanHash(event);
        }
        boolean matched = StrUtil.equals(record.getContentHash(), currentHash);
        return new MesTraceIntegrityVerifyRespVO()
                .setBizType(bizType)
                .setBizId(bizId)
                .setBizCode(bizCode)
                .setMatched(matched)
                .setStoredHash(record.getContentHash())
                .setCurrentHash(currentHash)
                .setBagSetHash(bagSetHash)
                .setMessage(matched ? "数据完整，未被篡改" : "数据不一致，可能存在篡改");
    }

    @Override
    public PageResult<MesTraceIntegrityRecordDO> getIntegrityPage(MesTraceIntegrityRecordPageReqVO reqVO) {
        return integrityRecordMapper.selectPage(reqVO);
    }

    // ==================== ç§æœ‰æ–¹æ³• ====================

    /**
     * æ‰¹æ¬¡æ‘˜è¦ï¼šä»…覆盖创建后不再变更的核心字段，不含状态、袋码数量等可变字段
     */
    private String batchHash(MesProBatchDO batch) {
        StringBuilder sb = new StringBuilder();
        sb.append(StrUtil.nullToEmpty(batch.getCode())).append('|')
                .append(nvl(batch.getItemId())).append('|')
                .append(StrUtil.nullToEmpty(batch.getLineCode())).append('|')
                .append(nvl(batch.getProduceDate())).append('|')
                .append(nvl(batch.getPlanQuantity()));
        return DigestUtil.sha256Hex(sb.toString());
    }

    /**
     * å‡ºåº“摘要：明细袋码/托盘码 id æŽ’序后拼入，保证明细顺序不影响摘要
     */
    private String salesHash(MesWmProductSalesDO sales, List<MesWmProductSalesDetailDO> details) {
        List<Long> codeIds = details.stream()
                .map(d -> d.getBagCodeId() != null ? d.getBagCodeId() : d.getPalletCodeId())
                .filter(Objects::nonNull)
                .sorted(Comparator.naturalOrder())
                .toList();
        StringBuilder sb = new StringBuilder();
        sb.append(StrUtil.nullToEmpty(sales.getCode())).append('|')
                .append(nvl(sales.getClientId())).append('|')
                .append(nvl(sales.getSalesDate())).append('|')
                .append(codeIds);
        return DigestUtil.sha256Hex(sb.toString());
    }

    /**
     * æ‰«ç äº‹ä»¶æ‘˜è¦ï¼šäº‹ä»¶ä»… insert ä¸æ”¹ï¼Œå…¨å­—段安全
     */
    private String scanHash(MesTraceConsumerScanEventDO event) {
        StringBuilder sb = new StringBuilder();
        sb.append(StrUtil.nullToEmpty(event.getNormalizedCode())).append('|')
                .append(StrUtil.nullToEmpty(event.getSourceType())).append('|')
                .append(StrUtil.nullToEmpty(event.getProvince())).append('|')
                .append(StrUtil.nullToEmpty(event.getCity())).append('|')
                .append(nvl(event.getSuccess())).append('|')
                .append(nvl(event.getEventTime()));
        return DigestUtil.sha256Hex(sb.toString());
    }

    /**
     * æ‰¹æ¬¡å½“前袋码集合摘要（实时计算，供人工比对袋码防篡改，不入库）
     */
    private String bagSetHash(Long batchId) {
        List<String> codes = bagCodeMapper.selectListByBatchId(batchId).stream()
                .map(MesProBagCodeDO::getCode)
                .filter(StrUtil::isNotBlank)
                .sorted()
                .toList();
        return DigestUtil.sha256Hex(String.join("|", codes));
    }

    /**
     * æ‘˜è¦ä¸å­˜åœ¨æ—¶æ›´æ–°ï¼Œå¦åˆ™è¦†ç›–（同一业务记录只保留最新摘要）
     */
    private void upsertRecord(String bizType, Long bizId, String bizCode, String hash) {
        MesTraceIntegrityRecordDO record = integrityRecordMapper.selectByBiz(bizType, bizId);
        if (record == null) {
            integrityRecordMapper.insert(MesTraceIntegrityRecordDO.builder()
                    .bizType(bizType)
                    .bizId(bizId)
                    .bizCode(bizCode)
                    .contentHash(hash)
                    .eventTime(LocalDateTime.now())
                    .build());
        } else {
            integrityRecordMapper.updateById(MesTraceIntegrityRecordDO.builder()
                    .id(record.getId())
                    .bizCode(bizCode)
                    .contentHash(hash)
                    .eventTime(LocalDateTime.now())
                    .build());
        }
    }

    private String nvl(Object value) {
        return value == null ? "" : String.valueOf(value);
    }

}

 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/wm/productsales/MesWmProductSalesServiceImpl.java

@@ -6,6 +6,7 @@
import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesSaveReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.productsales.vo.MesWmProductSalesShippingReqVO;
@@ -32,9 +33,11 @@
import cn.iocoder.yudao.module.mes.enums.wm.MesWmStockReserveBizTypeEnum;
import cn.iocoder.yudao.module.mes.enums.wm.MesWmTransactionTypeEnum;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.mes.service.wm.materialstock.MesWmMaterialStockService;
import cn.iocoder.yudao.module.mes.service.wm.salesnotice.MesWmSalesNoticeService;
import cn.iocoder.yudao.module.mes.service.pro.batch.MesProBatchService;
import cn.iocoder.yudao.module.mes.service.trace.integrity.MesTraceIntegrityService;
import cn.iocoder.yudao.module.mes.service.wm.batch.MesWmBatchService;
import cn.iocoder.yudao.module.mes.service.wm.stockreserve.MesWmStockReserveService;
import cn.iocoder.yudao.module.mes.service.wm.transaction.MesWmTransactionService;
@@ -98,6 +101,9 @@
    @Resource
    @Lazy
    private MesQcOqcService oqcService;

    @Resource
    private MesTraceIntegrityService integrityService;

    @Resource
    private ErpSaleOrderApi saleOrderApi;
@@ -372,9 +378,14 @@
        // 3. éåŽ†æ‰€æœ‰æ˜Žç»†ï¼Œåˆ›å»ºåº“存事务（扣减库存 + è®°å½•æµæ°´ï¼‰
        createTransactionList(sales);

        // 4. æ›´æ–°å‡ºåº“单状态
        // 4. å›ºåŒ–经销商与实际出库操作信息
        CrmCustomerRespDTO customer = customerApi.getCustomer(sales.getClientId());
        productSalesMapper.updateById(new MesWmProductSalesDO()
                .setId(id).setStatus(MesWmProductSalesStatusEnum.FINISHED.getStatus()));
                .setId(id)
                .setClientName(customer != null ? customer.getName() : null)
                .setOutboundTime(java.time.LocalDateTime.now())
                .setOutboundUserId(SecurityFrameworkUtils.getLoginUserId())
                .setStatus(MesWmProductSalesStatusEnum.FINISHED.getStatus()));

        // 5. æ›´æ–°å…³è”的发货通知单出库数量和状态
        if (sales.getNoticeId() != null) {
@@ -383,6 +394,18 @@

        // 6. å›žå†™ ERP é”€å”®è®¢å•çš„出库数量和状态
        updateErpSaleOrderOutCount(sales);

        // 7. å›žå†™è¢‹ç /托盘出库去向（供窜货稽查定位经销商地区），并生成出库完整性摘要
        List<MesWmProductSalesDetailDO> outDetails = productSalesDetailService.getProductSalesDetailListBySalesId(id);
        for (MesWmProductSalesDetailDO detail : outDetails) {
            if (detail.getBagCodeId() != null) {
                bagCodeService.markOutbound(detail.getBagCodeId(), id);
            }
            if (detail.getPalletCodeId() != null) {
                palletService.markOutbound(detail.getPalletCodeId(), id);
            }
        }
        integrityService.recordSalesIntegrity(id);
    }

    /**

 yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/trace/consumer/MesTraceConsumerScanEventServiceImplTest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,89 @@
package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.context.annotation.Import;

import java.util.List;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;

/**
 * {@link MesTraceConsumerScanEventServiceImpl} çš„单元测试
 *
 * @author è¶…级管理员
 */
@Import(MesTraceConsumerScanEventServiceImpl.class)
public class MesTraceConsumerScanEventServiceImplTest extends BaseDbUnitTest {

    @Resource
    private MesTraceConsumerScanEventService eventService;

    @Resource
    private MesTraceConsumerScanEventMapper eventMapper;

    /**
     * æŸ¥è¯¢åˆšæ’入的第一条事件（id ç”±åºåˆ—/雪花算法生成，不固定为 1）
     */
    private MesTraceConsumerScanEventDO getFirstEvent() {
        List<MesTraceConsumerScanEventDO> list = eventMapper.selectList(null);
        return list.isEmpty() ? null : list.get(0);
    }

    @Test
    public void testRecordScan_成功事件落库() {
        // æ— è¯·æ±‚上下文时 IP/UA/渠道为空，但事件仍应落库且不抛异常
        eventService.recordScan("PC-RAW-CODE", "PC-CODE-001", "BAG", 100L, true, null);

        MesTraceConsumerScanEventDO event = getFirstEvent();
        assertNotNull(event);
        assertEquals("PC-RAW-CODE", event.getTraceCode());
        assertEquals("PC-CODE-001", event.getNormalizedCode());
        assertEquals("BAG", event.getSourceType());
        assertEquals(100L, event.getBatchId());
        assertTrue(Boolean.TRUE.equals(event.getSuccess()));
        assertNull(event.getErrorCode());
        assertNull(event.getIpHash()); // æ— è¯·æ±‚上下文无明文 IP，也不应保存
        assertNull(event.getChannel());
        assertNotNull(event.getEventTime());
    }

    @Test
    public void testRecordScan_失败事件落库() {
        eventService.recordScan("NOT-EXIST", null, null, null, false, "MES_TRACE_CODE_NOT_FOUND");

        MesTraceConsumerScanEventDO event = getFirstEvent();
        assertNotNull(event);
        assertFalse(Boolean.TRUE.equals(event.getSuccess()));
        assertEquals("MES_TRACE_CODE_NOT_FOUND", event.getErrorCode());
        assertNull(event.getSourceType());
        assertNull(event.getBatchId());
    }

    @Test
    public void testRecordScan_超长码截断() {
        String longCode = "X".repeat(500);
        eventService.recordScan(longCode, longCode, "BATCH", null, true, null);

        MesTraceConsumerScanEventDO event = getFirstEvent();
        assertNotNull(event);
        // traceCode æˆªæ–­åˆ° 255、normalizedCode æˆªæ–­åˆ° 128
        assertEquals(255, event.getTraceCode().length());
        assertEquals(128, event.getNormalizedCode().length());
    }

    @Test
    public void testRecordScan_记录异常不影响接口() {
        // recordScan å†…部吞掉异常，事件仍应正常落库
        eventService.recordScan("CODE", "CODE", "BATCH", null, true, null);
        assertNotNull(getFirstEvent());
    }

}

 yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/trace/consumer/MesTraceConsumerScanStatisticsServiceImplTest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,154 @@
package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanDistributionRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.consumer.vo.MesTraceConsumerScanTrendRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.context.annotation.Import;

import java.time.LocalDateTime;
import java.util.List;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows;

/**
 * {@link MesTraceConsumerScanStatisticsServiceImpl} çš„单元测试
 *
 * @author è¶…级管理员
 */
@Import(MesTraceConsumerScanStatisticsServiceImpl.class)
public class MesTraceConsumerScanStatisticsServiceImplTest extends BaseDbUnitTest {

    @Resource
    private MesTraceConsumerScanStatisticsService statisticsService;

    @Resource
    private MesTraceConsumerScanEventMapper eventMapper;

    private MesTraceConsumerScanEventDO buildEvent(String traceCode, String sourceType, String channel,
                                                   String province, Long batchId, boolean success,
                                                   LocalDateTime eventTime) {
        return MesTraceConsumerScanEventDO.builder()
                .traceCode(traceCode).normalizedCode(traceCode).sourceType(sourceType)
                .channel(channel).province(province).batchId(batchId).success(success)
                .eventTime(eventTime).build();
    }

    @Test
    public void testGetSummary_统计口径() {
        LocalDateTime t1 = LocalDateTime.of(2026, 9, 1, 10, 0);
        LocalDateTime t2 = LocalDateTime.of(2026, 9, 2, 11, 0);
        eventMapper.insert(buildEvent("B1", "BAG", "微信", "江苏省", 100L, true, t1));
        eventMapper.insert(buildEvent("B2", "BAG", "浏览器", "江苏省", 100L, true, t2));
        eventMapper.insert(buildEvent("B3", "BATCH", null, null, null, false, t2));

        MesTraceConsumerScanSummaryRespVO vo = statisticsService.getSummary(
                LocalDateTime.of(2026, 9, 1, 0, 0), LocalDateTime.of(2026, 9, 3, 0, 0));

        assertNotNull(vo);
        assertEquals(3L, vo.getTotal());
        assertEquals(2L, vo.getSuccess());
        assertEquals(1L, vo.getFailed());
        assertEquals(1L, vo.getUniqueBatchCount()); // ä»… batchId éžç©ºä¸”去重
    }

    @Test
    public void testGetTrend_补齐无数据日期() {
        // 9 æœˆ 1 æ—¥ä¸¤æ¡ã€9 æœˆ 3 æ—¥ä¸€æ¡ï¼›9 æœˆ 2 æ—¥æ— æ•°æ®åº”è¡¥ 0
        eventMapper.insert(buildEvent("B1", "BAG", "微信", null, 100L, true,
                LocalDateTime.of(2026, 9, 1, 9, 0)));
        eventMapper.insert(buildEvent("B2", "BATCH", null, null, null, false,
                LocalDateTime.of(2026, 9, 1, 10, 0)));
        eventMapper.insert(buildEvent("B3", "BAG", "浏览器", null, 100L, true,
                LocalDateTime.of(2026, 9, 3, 9, 0)));

        List<MesTraceConsumerScanTrendRespVO> list = statisticsService.getTrend(
                LocalDateTime.of(2026, 9, 1, 0, 0), LocalDateTime.of(2026, 9, 4, 0, 0));

        assertNotNull(list);
        assertEquals(3, list.size());
        assertEquals("2026-09-01", list.get(0).getDate());
        assertEquals(2L, list.get(0).getTotal());
        assertEquals("2026-09-02", list.get(1).getDate());
        assertEquals(0L, list.get(1).getTotal()); // è¡¥ 0
        assertEquals("2026-09-03", list.get(2).getDate());
        assertEquals(1L, list.get(2).getTotal());
    }

    @Test
    public void testGetDistribution_bySourceType() {
        eventMapper.insert(buildEvent("B1", "BAG", null, null, 100L, true,
                LocalDateTime.of(2026, 9, 1, 9, 0)));
        eventMapper.insert(buildEvent("B2", "PALLET", null, null, 100L, true,
                LocalDateTime.of(2026, 9, 1, 10, 0)));
        eventMapper.insert(buildEvent("B3", "PALLET", null, null, null, false,
                LocalDateTime.of(2026, 9, 1, 11, 0)));

        MesTraceConsumerScanDistributionReqVO reqVO = new MesTraceConsumerScanDistributionReqVO();
        reqVO.setGroupBy("sourceType");
        List<MesTraceConsumerScanDistributionRespVO> list = statisticsService.getDistribution(reqVO);

        assertNotNull(list);
        // PALLET 2 æ¡ > BAG 1 æ¡ï¼ˆæŒ‰ count å€’序）
        assertEquals("PALLET", list.get(0).getName());
        assertEquals(2L, list.get(0).getCount());
        assertEquals("BAG", list.get(1).getName());
        assertEquals(1L, list.get(1).getCount());
    }

    @Test
    public void testGetDistribution_nullKey映射未知() {
        // è§£æžå¤±è´¥çš„事件 sourceType ä¸º null，不得因 groupBy ç©ºé”®æŠ› NPE，应聚合为"未知"
        eventMapper.insert(buildEvent("B1", "BAG", null, null, 100L, true,
                LocalDateTime.of(2026, 9, 1, 9, 0)));
        eventMapper.insert(buildEvent("B2", null, null, null, null, false,
                LocalDateTime.of(2026, 9, 1, 10, 0)));
        eventMapper.insert(buildEvent("B3", null, null, null, null, false,
                LocalDateTime.of(2026, 9, 1, 11, 0)));

        MesTraceConsumerScanDistributionReqVO reqVO = new MesTraceConsumerScanDistributionReqVO();
        reqVO.setGroupBy("sourceType");
        List<MesTraceConsumerScanDistributionRespVO> list = statisticsService.getDistribution(reqVO);

        assertNotNull(list);
        // æŒ‰ count å€’序：未知(2) åœ¨ BAG(1) ä¹‹å‰
        assertEquals(2, list.size());
        assertEquals("未知", list.get(0).getName());
        assertEquals(2L, list.get(0).getCount());
        assertEquals("BAG", list.get(1).getName());
        assertEquals(1L, list.get(1).getCount());
    }

    @Test
    public void testGetDistribution_success显示名称() {
        eventMapper.insert(buildEvent("B1", "BAG", null, null, 100L, true,
                LocalDateTime.of(2026, 9, 1, 9, 0)));
        eventMapper.insert(buildEvent("B2", "BAG", null, null, null, false,
                LocalDateTime.of(2026, 9, 1, 10, 0)));

        MesTraceConsumerScanDistributionReqVO reqVO = new MesTraceConsumerScanDistributionReqVO();
        reqVO.setGroupBy("success");
        List<MesTraceConsumerScanDistributionRespVO> list = statisticsService.getDistribution(reqVO);

        assertNotNull(list);
        assertEquals(2, list.size());
        // æ•°é‡ç›¸åŒæ—¶æŒ‰åˆ†ç»„名升序："0"(失败) åœ¨ "1"(成功) ä¹‹å‰
        assertEquals("失败", list.get(0).getName());
        assertEquals("成功", list.get(1).getName());
    }

    @Test
    public void testGetDistribution_非法维度拒绝() {
        MesTraceConsumerScanDistributionReqVO reqVO = new MesTraceConsumerScanDistributionReqVO();
        reqVO.setGroupBy("item_code; DROP TABLE x");
        assertThrows(IllegalArgumentException.class, () -> statisticsService.getDistribution(reqVO));
    }

}

 yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/trace/crossregion/MesTraceCrossRegionServiceImplTest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,367 @@
package cn.iocoder.yudao.module.mes.service.trace.crossregion;

import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.ip.core.utils.AreaUtils;
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionHandleReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionStatisticsRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningPageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceCrossRegionWarningRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.trace.crossregion.vo.MesTraceAntiConfigRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.mdm.MesMdmItemDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.batch.MesProBatchDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion.MesTraceAntiConfigDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.crossregion.MesTraceCrossRegionWarningDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.productsales.MesWmProductSalesDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.crossregion.MesTraceAntiConfigMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.crossregion.MesTraceCrossRegionWarningMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesDetailMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.productsales.MesWmProductSalesMapper;
import cn.iocoder.yudao.module.mes.enums.trace.MesTraceWarningStatusEnum;
import cn.iocoder.yudao.module.mes.enums.trace.MesTraceWarningTypeEnum;
import cn.iocoder.yudao.module.mes.service.mdm.MesMdmItemService;
import cn.iocoder.yudao.module.mes.service.pro.bagcode.MesProBagCodeService;
import cn.iocoder.yudao.module.mes.service.pro.batch.MesProBatchService;
import cn.iocoder.yudao.module.mes.service.pro.pallet.MesProPalletService;
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.context.annotation.Import;
import org.springframework.test.context.bean.override.mockito.MockitoBean;

import java.time.LocalDateTime;
import java.util.Collections;
import java.util.List;

import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_ANTI_CONFIG_VALUE_INVALID;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_CROSS_REGION_STATUS_INVALID;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

/**
 * {@link MesTraceCrossRegionServiceImpl} çš„单元测试
 *
 * @author è¶…级管理员
 */
@Import(MesTraceCrossRegionServiceImpl.class)
public class MesTraceCrossRegionServiceImplTest extends BaseDbUnitTest {

    @Resource
    private MesTraceCrossRegionService crossRegionService;
    @Resource
    private MesTraceCrossRegionWarningMapper warningMapper;
    @Resource
    private MesTraceAntiConfigMapper antiConfigMapper;

    @MockitoBean
    private MesProBagCodeService bagCodeService;
    @MockitoBean
    private MesProPalletService palletService;
    @MockitoBean
    private MesProBatchService batchService;
    @MockitoBean
    private MesMdmItemService mdmItemService;
    @MockitoBean
    private CrmCustomerApi customerApi;
    @MockitoBean
    private AdminUserApi adminUserApi;
    @MockitoBean
    private MesWmProductSalesMapper productSalesMapper;
    @MockitoBean
    private MesWmProductSalesDetailMapper productSalesDetailMapper;

    // ==================== çªœè´§åˆ¤å®š ====================

    @Test
    public void testCheckAndCreateWarning_跨省触发() {
        // é…ç½®çœçº§ç²’度
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());
        mockDealer("江苏省", "南京市");
        MesTraceConsumerScanEventDO event = buildEvent("BAG", "浙江省", "杭州市", true);

        crossRegionService.checkAndCreateWarning(event);

        List<MesTraceCrossRegionWarningDO> warnings = warningMapper.selectList();
        assertEquals(1, warnings.size());
        MesTraceCrossRegionWarningDO warning = warnings.get(0);
        assertEquals(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType(), warning.getWarningType());
        assertEquals("江苏省", warning.getDealerProvince());
        assertEquals("浙江省", warning.getScanProvince());
        assertEquals("SO-001", warning.getSalesCode());
        assertEquals("华东经销商", warning.getClientName());
        assertEquals(event.getId(), warning.getScanEventId());
        assertEquals(MesTraceWarningStatusEnum.PENDING.getStatus(), warning.getStatus());
    }

    @Test
    public void testCheckAndCreateWarning_跨市触发() {
        // å¸‚级粒度：扫码市 â‰  ç»é”€å•†å¸‚ â†’ CROSS_CITY
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("CITY").build());
        mockDealer("江苏省", "南京市");
        MesTraceConsumerScanEventDO event = buildEvent("BAG", "江苏省", "苏州市", true);

        crossRegionService.checkAndCreateWarning(event);

        List<MesTraceCrossRegionWarningDO> warnings = warningMapper.selectList();
        assertEquals(1, warnings.size());
        assertEquals(MesTraceWarningTypeEnum.CROSS_CITY.getType(), warnings.get(0).getWarningType());
        assertEquals("南京市", warnings.get(0).getDealerCity());
        assertEquals("苏州市", warnings.get(0).getScanCity());
    }

    @Test
    public void testCheckAndCreateWarning_同地区不预警() {
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());
        mockDealer("江苏省", "南京市");
        MesTraceConsumerScanEventDO event = buildEvent("BAG", "江苏省", "南京市", true);

        crossRegionService.checkAndCreateWarning(event);

        assertEquals(0, warningMapper.selectCount());
    }

    @Test
    public void testCheckAndCreateWarning_扫码无地区容错() {
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());
        mockDealer("江苏省", "南京市");
        MesTraceConsumerScanEventDO event = buildEvent("BAG", null, null, true);

        crossRegionService.checkAndCreateWarning(event);

        assertEquals(0, warningMapper.selectCount());
    }

    @Test
    public void testCheckAndCreateWarning_批次入口跳过() {
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());
        mockDealer("江苏省", "南京市");
        MesTraceConsumerScanEventDO event = buildEvent("BATCH", "浙江省", "杭州市", true);

        crossRegionService.checkAndCreateWarning(event);

        assertEquals(0, warningMapper.selectCount());
    }

    @Test
    public void testCheckAndCreateWarning_袋码未出库跳过() {
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());
        // è¢‹ç æœªå›žå†™å‡ºåº“单，且明细表无记录 â†’ ä¸é¢„è­¦
        when(bagCodeService.getBagCodeByCode("BAG-00000001")).thenReturn(
                MesProBagCodeDO.builder().id(1L).code("BAG-00000001").batchId(10L).build());
        MesTraceConsumerScanEventDO event = buildEvent("BAG", "浙江省", "杭州市", true);

        crossRegionService.checkAndCreateWarning(event);

        verify(productSalesDetailMapper).selectLatestByBagCodeId(1L);
        assertEquals(0, warningMapper.selectCount());
    }

    @Test
    public void testCheckAndCreateWarning_袋码未绑定批次跳过() {
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());
        when(bagCodeService.getBagCodeByCode("BAG-00000001")).thenReturn(null);
        MesTraceConsumerScanEventDO event = buildEvent("BAG", "浙江省", "杭州市", true);

        crossRegionService.checkAndCreateWarning(event);

        assertEquals(0, warningMapper.selectCount());
    }

    // ==================== çŠ¶æ€æµè½¬ ====================

    @Test
    public void testHandleWarning_状态流转() {
        MesTraceCrossRegionWarningDO warning = buildWarning(MesTraceWarningStatusEnum.PENDING.getStatus());
        warningMapper.insert(warning);

        MesTraceCrossRegionHandleReqVO reqVO = new MesTraceCrossRegionHandleReqVO();
        reqVO.setId(warning.getId());
        reqVO.setStatus(MesTraceWarningStatusEnum.HANDLED.getStatus());
        reqVO.setHandleRemark("确认为物流中转");
        crossRegionService.handleWarning(reqVO);

        MesTraceCrossRegionWarningDO updated = warningMapper.selectById(warning.getId());
        assertEquals(MesTraceWarningStatusEnum.HANDLED.getStatus(), updated.getStatus());
        assertEquals("确认为物流中转", updated.getHandleRemark());
    }

    @Test
    public void testHandleWarning_已处理不可再处理() {
        MesTraceCrossRegionWarningDO warning = buildWarning(MesTraceWarningStatusEnum.HANDLED.getStatus());
        warningMapper.insert(warning);

        MesTraceCrossRegionHandleReqVO reqVO = new MesTraceCrossRegionHandleReqVO();
        reqVO.setId(warning.getId());
        reqVO.setStatus(MesTraceWarningStatusEnum.FALSE_ALARM.getStatus());
        ServiceException ex = assertThrows(ServiceException.class,
                () -> crossRegionService.handleWarning(reqVO));
        assertEquals(MES_TRACE_CROSS_REGION_STATUS_INVALID.getCode(), ex.getCode());
    }

    // ==================== é…ç½® ====================

    @Test
    public void testGetConfig_updateConfig() {
        antiConfigMapper.insert(MesTraceAntiConfigDO.builder()
                .configKey("warning_level").configValue("PROVINCE").build());

        MesTraceAntiConfigRespVO config = crossRegionService.getConfig();
        assertEquals("PROVINCE", config.getWarningLevel());

        crossRegionService.updateConfig("CITY");
        assertEquals("CITY", antiConfigMapper.selectByConfigKey("warning_level").getConfigValue());

        ServiceException ex = assertThrows(ServiceException.class,
                () -> crossRegionService.updateConfig("INVALID"));
        assertEquals(MES_TRACE_ANTI_CONFIG_VALUE_INVALID.getCode(), ex.getCode());
    }

    // ==================== æ±‡æ€»ä¸Žç»Ÿè®¡ ====================

    @Test
    public void testGetWarningSummary() {
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.PENDING.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType()));
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.HANDLED.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_CITY.getType()));
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.FALSE_ALARM.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType()));

        MesTraceCrossRegionSummaryRespVO vo = crossRegionService.getWarningSummary(null, null);

        assertEquals(3L, vo.getTotal());
        assertEquals(1L, vo.getPending());
        assertEquals(1L, vo.getHandled());
        assertEquals(1L, vo.getFalseAlarm());
        assertEquals(2L, vo.getCrossProvince());
        assertEquals(1L, vo.getCrossCity());
    }

    @Test
    public void testGetWarningStatistics_分组统计() {
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.PENDING.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType()).setScanProvince("浙江省"));
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.PENDING.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType()).setScanProvince("浙江省"));
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.PENDING.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType()).setScanProvince("江苏省"));

        MesTraceCrossRegionStatisticsReqVO reqVO = new MesTraceCrossRegionStatisticsReqVO();
        reqVO.setGroupBy("scanProvince");
        List<MesTraceCrossRegionStatisticsRespVO> list = crossRegionService.getWarningStatistics(reqVO);

        assertEquals(2, list.size());
        assertEquals("浙江省", list.get(0).getName());
        assertEquals(2L, list.get(0).getCount());
        assertEquals("江苏省", list.get(1).getName());
        assertEquals(1L, list.get(1).getCount());
    }

    @Test
    public void testGetWarningStatistics_非法维度拒绝() {
        MesTraceCrossRegionStatisticsReqVO reqVO = new MesTraceCrossRegionStatisticsReqVO();
        reqVO.setGroupBy("item_code; DROP TABLE x");
        assertThrows(IllegalArgumentException.class,
                () -> crossRegionService.getWarningStatistics(reqVO));
    }

    // ==================== åˆ†é¡µ ====================

    @Test
    public void testGetWarningPage() {
        when(adminUserApi.getUserMap(any())).thenReturn(Collections.emptyMap());
        warningMapper.insert(buildWarning(MesTraceWarningStatusEnum.PENDING.getStatus())
                .setWarningType(MesTraceWarningTypeEnum.CROSS_PROVINCE.getType())
                .setScanProvince("浙江省").setDealerProvince("江苏省"));

        MesTraceCrossRegionWarningPageReqVO reqVO = new MesTraceCrossRegionWarningPageReqVO();
        reqVO.setStatus(MesTraceWarningStatusEnum.PENDING.getStatus());
        var page = crossRegionService.getWarningPage(reqVO);

        assertEquals(1L, page.getTotal());
        MesTraceCrossRegionWarningRespVO vo = page.getList().get(0);
        assertEquals(MesTraceWarningStatusEnum.PENDING.getName(), vo.getStatusName());
        assertEquals(MesTraceWarningTypeEnum.CROSS_PROVINCE.getName(), vo.getWarningTypeName());
        assertTrue(vo.getWarningNo() != null);
    }

    // ==================== è¾…助方法 ====================

    /**
     * æž„建消费者扫码事件（id å›ºå®šï¼Œä¾¿äºŽæ–­è¨€å…³è”）
     */
    private MesTraceConsumerScanEventDO buildEvent(String sourceType, String province, String city, boolean success) {
        return MesTraceConsumerScanEventDO.builder()
                .id(1L)
                .normalizedCode("BAG-00000001")
                .sourceType(sourceType)
                .province(province)
                .city(city)
                .batchId(10L)
                .success(success)
                .eventTime(LocalDateTime.of(2026, 9, 1, 10, 0))
                .build();
    }

    /**
     * Mock è¢‹ç  â†’ å‡ºåº“单 â†’ ç»é”€å•†ï¼ˆæŒ‡å®šåœ°åŒºï¼‰é“¾è·¯
     */
    private void mockDealer(String dealerProvince, String dealerCity) {
        MesProBagCodeDO bag = MesProBagCodeDO.builder().id(1L).code("BAG-00000001")
                .batchId(10L).salesId(100L).build();
        when(bagCodeService.getBagCodeByCode("BAG-00000001")).thenReturn(bag);

        MesWmProductSalesDO sales = MesWmProductSalesDO.builder().id(100L).code("SO-001")
                .clientId(200L).clientName("华东经销商").build();
        when(productSalesMapper.selectById(100L)).thenReturn(sales);

        Integer areaId = AreaUtils.parseArea(dealerProvince + "/" + dealerCity).getId();
        CrmCustomerRespDTO customer = new CrmCustomerRespDTO();
        customer.setId(200L);
        customer.setName("华东经销商");
        customer.setAreaId(areaId);
        when(customerApi.getCustomer(200L)).thenReturn(customer);

        MesProBatchDO batch = MesProBatchDO.builder().id(10L).itemId(5L).build();
        when(batchService.getBatch(10L)).thenReturn(batch);

        MesMdmItemDO item = MesMdmItemDO.builder().id(5L).code("ITEM001").name("水稻种子").build();
        when(mdmItemService.getItem(5L)).thenReturn(item);
    }

    private MesTraceCrossRegionWarningDO buildWarning(Integer status) {
        return MesTraceCrossRegionWarningDO.builder()
                .warningNo("WARN20260901100000ABCDEF")
                .batchId(10L)
                .batchCode("PC20260901L001M001_001")
                .salesId(100L)
                .salesCode("SO-001")
                .clientId(200L)
                .clientName("华东经销商")
                .dealerProvince("江苏省")
                .dealerCity("南京市")
                .scanProvince("浙江省")
                .scanCity("杭州市")
                .status(status)
                .eventTime(LocalDateTime.of(2026, 9, 1, 10, 0))
                .build();
    }

}

 yudao-module-mes/src/test/java/cn/iocoder/yudao/module/mes/service/trace/integrity/MesTraceIntegrityServiceImplTest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,129 @@
package cn.iocoder.yudao.module.mes.service.trace.integrity;

import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.controller.admin.trace.integrity.vo.MesTraceIntegrityVerifyRespVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.integrity.MesTraceIntegrityRecordDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.integrity.MesTraceIntegrityRecordMapper;
import cn.iocoder.yudao.module.mes.enums.trace.MesTraceIntegrityBizTypeEnum;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.context.annotation.Import;

import java.time.LocalDateTime;

import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_INTEGRITY_BIZ_TYPE_INVALID;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_TRACE_INTEGRITY_RECORD_NOT_EXISTS;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;

/**
 * {@link MesTraceIntegrityServiceImpl} çš„单元测试
 *
 * @author è¶…级管理员
 */
@Import(MesTraceIntegrityServiceImpl.class)
public class MesTraceIntegrityServiceImplTest extends BaseDbUnitTest {

    @Resource
    private MesTraceIntegrityService integrityService;
    @Resource
    private MesTraceIntegrityRecordMapper integrityRecordMapper;
    @Resource
    private MesTraceConsumerScanEventMapper scanEventMapper;

    @Test
    public void testRecordScanIntegrity_生成摘要并入库() {
        MesTraceConsumerScanEventDO event = insertEvent("江苏省", "南京市");
        integrityService.recordScanIntegrity(event);

        MesTraceIntegrityRecordDO record = integrityRecordMapper.selectByBiz(
                MesTraceIntegrityBizTypeEnum.SCAN.getType(), event.getId());
        assertNotNull(record);
        assertEquals(64, record.getContentHash().length());
        assertEquals(event.getNormalizedCode(), record.getBizCode());
    }

    @Test
    public void testVerify_数据完整通过() {
        MesTraceConsumerScanEventDO event = insertEvent("江苏省", "南京市");
        integrityService.recordScanIntegrity(event);

        MesTraceIntegrityVerifyRespVO vo = integrityService.verify(
                MesTraceIntegrityBizTypeEnum.SCAN.getType(), event.getId());

        assertTrue(vo.getMatched());
        assertEquals(vo.getStoredHash(), vo.getCurrentHash());
        assertEquals(event.getNormalizedCode(), vo.getBizCode());
    }

    @Test
    public void testVerify_篡改检测失败() {
        MesTraceConsumerScanEventDO event = insertEvent("江苏省", "南京市");
        integrityService.recordScanIntegrity(event);
        // æ¨¡æ‹Ÿäº‹åŽç¯¡æ”¹æ‰«ç åœ°åŒº
        scanEventMapper.updateById(new MesTraceConsumerScanEventDO().setId(event.getId()).setProvince("浙江省"));

        MesTraceIntegrityVerifyRespVO vo = integrityService.verify(
                MesTraceIntegrityBizTypeEnum.SCAN.getType(), event.getId());

        assertFalse(vo.getMatched());
        assertEquals("数据不一致，可能存在篡改", vo.getMessage());
    }

    @Test
    public void testVerify_覆盖更新不产生重复记录() {
        MesTraceConsumerScanEventDO event = insertEvent("江苏省", "南京市");
        integrityService.recordScanIntegrity(event);
        integrityService.recordScanIntegrity(event);

        assertEquals(1L, integrityRecordMapper.selectCount());
        MesTraceIntegrityRecordDO record = integrityRecordMapper.selectByBiz(
                MesTraceIntegrityBizTypeEnum.SCAN.getType(), event.getId());
        assertEquals(64, record.getContentHash().length());
    }

    @Test
    public void testVerify_无摘要记录异常() {
        ServiceException ex = assertThrows(ServiceException.class,
                () -> integrityService.verify(MesTraceIntegrityBizTypeEnum.SCAN.getType(), 99999L));
        assertEquals(MES_TRACE_INTEGRITY_RECORD_NOT_EXISTS.getCode(), ex.getCode());
    }

    @Test
    public void testVerify_非法业务类型() {
        ServiceException ex = assertThrows(ServiceException.class,
                () -> integrityService.verify("XXX", 1L));
        assertEquals(MES_TRACE_INTEGRITY_BIZ_TYPE_INVALID.getCode(), ex.getCode());
    }

    @Test
    public void testRecordScanIntegrity_null事件容错() {
        integrityService.recordScanIntegrity(null);
        integrityService.recordScanIntegrity(MesTraceConsumerScanEventDO.builder().id(null).build());
        assertEquals(0L, integrityRecordMapper.selectCount());
    }

    // ==================== è¾…助方法 ====================

    private MesTraceConsumerScanEventDO insertEvent(String province, String city) {
        MesTraceConsumerScanEventDO event = MesTraceConsumerScanEventDO.builder()
                .traceCode("BAG-00000001")
                .normalizedCode("BAG-00000001")
                .sourceType("BAG")
                .province(province)
                .city(city)
                .batchId(10L)
                .success(true)
                .eventTime(LocalDateTime.of(2026, 9, 1, 10, 0))
                .build();
        scanEventMapper.insert(event);
        return event;
    }

}

 yudao-module-mes/src/test/resources/sql/clean.sql

@@ -21,3 +21,7 @@
DELETE FROM "mes_pro_task";
DELETE FROM "mes_pro_route_process";
DELETE FROM "mes_qc_indicator_result";
DELETE FROM "mes_trace_consumer_scan_event";
DELETE FROM "mes_trace_anti_config";
DELETE FROM "mes_trace_cross_region_warning";
DELETE FROM "mes_trace_integrity_record";

 yudao-module-mes/src/test/resources/sql/create_tables.sql

@@ -830,3 +830,101 @@
    "tenant_id" bigint NOT NULL DEFAULT 0,
    PRIMARY KEY ("id")
);

-- ----------------------------
-- MES æ¶ˆè´¹è€…扫码访问事件
-- ----------------------------
CREATE TABLE IF NOT EXISTS "mes_trace_consumer_scan_event" (
    "id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
    "trace_code" varchar(255) NOT NULL,
    "normalized_code" varchar(128) DEFAULT NULL,
    "source_type" varchar(32) DEFAULT NULL,
    "channel" varchar(32) DEFAULT NULL,
    "province" varchar(64) DEFAULT NULL,
    "city" varchar(64) DEFAULT NULL,
    "batch_id" bigint DEFAULT NULL,
    "success" bit NOT NULL DEFAULT FALSE,
    "error_code" varchar(64) DEFAULT NULL,
    "ip_hash" varchar(64) DEFAULT NULL,
    "user_agent_hash" varchar(64) DEFAULT NULL,
    "event_time" timestamp NOT NULL,
    "creator" varchar(64) DEFAULT '',
    "create_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "updater" varchar(64) DEFAULT '',
    "update_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "deleted" bit NOT NULL DEFAULT FALSE,
    "tenant_id" bigint NOT NULL DEFAULT 0,
    PRIMARY KEY ("id")
);

-- ----------------------------
-- MES é˜²çªœè´§è§„则配置
-- ----------------------------
CREATE TABLE IF NOT EXISTS "mes_trace_anti_config" (
    "id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
    "config_key" varchar(64) DEFAULT NULL,
    "config_value" varchar(255) DEFAULT NULL,
    "remark" varchar(255) DEFAULT NULL,
    "creator" varchar(64) DEFAULT '',
    "create_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "updater" varchar(64) DEFAULT '',
    "update_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "deleted" bit NOT NULL DEFAULT FALSE,
    PRIMARY KEY ("id")
);

-- ----------------------------
-- MES çªœè´§é¢„警记录
-- ----------------------------
CREATE TABLE IF NOT EXISTS "mes_trace_cross_region_warning" (
    "id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
    "warning_no" varchar(64) DEFAULT NULL,
    "bag_code_id" bigint DEFAULT NULL,
    "bag_code" varchar(64) DEFAULT NULL,
    "pallet_code_id" bigint DEFAULT NULL,
    "pallet_code" varchar(64) DEFAULT NULL,
    "batch_id" bigint DEFAULT NULL,
    "batch_code" varchar(64) DEFAULT NULL,
    "item_id" bigint DEFAULT NULL,
    "item_code" varchar(64) DEFAULT NULL,
    "item_name" varchar(128) DEFAULT NULL,
    "sales_id" bigint DEFAULT NULL,
    "sales_code" varchar(64) DEFAULT NULL,
    "client_id" bigint DEFAULT NULL,
    "client_name" varchar(128) DEFAULT NULL,
    "dealer_province" varchar(64) DEFAULT NULL,
    "dealer_city" varchar(64) DEFAULT NULL,
    "scan_province" varchar(64) DEFAULT NULL,
    "scan_city" varchar(64) DEFAULT NULL,
    "warning_type" varchar(32) DEFAULT NULL,
    "scan_event_id" bigint DEFAULT NULL,
    "status" tinyint NOT NULL DEFAULT 10,
    "handle_user_id" bigint DEFAULT NULL,
    "handle_time" timestamp DEFAULT NULL,
    "handle_remark" varchar(255) DEFAULT NULL,
    "event_time" timestamp NOT NULL,
    "creator" varchar(64) DEFAULT '',
    "create_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "updater" varchar(64) DEFAULT '',
    "update_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "deleted" bit NOT NULL DEFAULT FALSE,
    PRIMARY KEY ("id")
);

-- ----------------------------
-- MES æ•°æ®å®Œæ•´æ€§æ ¡éªŒè®°å½•
-- ----------------------------
CREATE TABLE IF NOT EXISTS "mes_trace_integrity_record" (
    "id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY,
    "biz_type" varchar(32) NOT NULL,
    "biz_id" bigint NOT NULL,
    "biz_code" varchar(64) DEFAULT NULL,
    "content_hash" varchar(64) NOT NULL,
    "event_time" timestamp NOT NULL,
    "creator" varchar(64) DEFAULT '',
    "create_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "updater" varchar(64) DEFAULT '',
    "update_time" timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    "deleted" bit NOT NULL DEFAULT FALSE,
    PRIMARY KEY ("id")
);

 yudao-server/src/main/resources/static/trace.html

@@ -141,6 +141,34 @@
  .scroll-list::-webkit-scrollbar { width: 4px; }
  .scroll-list::-webkit-scrollbar-thumb { background: #d1d5db; border-radius: 2px; }

  /* æ­£å“éªŒè¯å¡ï¼ˆé¡¶éƒ¨ï¼Œæ‰«ç ä¼˜å…ˆå±•ç¤ºï¼‰ */
  .verify-card {
    border: 1px solid var(--primary-light);
    background: linear-gradient(180deg, #eef8ee, #fff);
  }
  .verify-card .card-bd { padding: 14px 16px; }
  .verify-title {
    display: flex; align-items: center; gap: 8px;
    font-size: 16px; font-weight: 700; color: var(--primary);
    margin-bottom: 4px;
  }
  .verify-title::before { content: ""; width: 5px; height: 16px; border-radius: 2px; background: var(--primary); }
  .verify-sub { font-size: 12px; color: var(--text-sub); margin-bottom: 10px; }
  .verify-badge { margin-bottom: 10px; }
  .verify-stats { margin-top: 10px; border-top: 1px dashed var(--border); padding-top: 4px; }

  /* å¯æŠ˜å å¡ç‰‡ */
  .card.collapsible .card-hd { cursor: pointer; position: relative; padding-right: 30px; }
  .card.collapsible .card-hd::after {
    content: "▾"; position: absolute; right: 12px; top: 50%;
    transform: translateY(-50%); color: var(--text-sub); font-size: 12px;
    transition: transform .2s;
  }
  .card.collapsible:not(.open) .card-hd::after { transform: translateY(-50%) rotate(-90deg); }
  .card.collapsible .card-hd .count { margin-right: 16px; }
  .card.collapsible .card-bd { display: none; }
  .card.collapsible.open .card-bd { display: block; }

  footer {
    max-width: 480px; margin: 0 auto;
    padding: 20px 16px 28px; text-align: center;
@@ -207,11 +235,17 @@
    return '<span class="badge ' + item[1] + '">' + esc(item[0]) + '</span>';
  }

  function card(title, countHtml, bodyHtml) {
    return '<div class="card">' +
      '<div class="card-hd"><span class="bar"></span>' + esc(title) +
  function card(title, countHtml, bodyHtml, opts) {
    opts = opts || {};
    var collapsible = !!opts.collapsible;
    var open = collapsible && !!opts.open;
    var hd = '<div class="card-hd"' +
      (collapsible ? ' onclick="this.parentNode.classList.toggle(\'open\')"' : '') +
      '><span class="bar"></span>' + esc(title) +
      (countHtml ? '<span class="count">' + countHtml + '</span>' : '') +
      '</div>' + '<div class="card-bd">' + bodyHtml + '</div>' + '</div>';
      '</div>';
    return '<div class="card' + (collapsible ? ' collapsible' : '') + (open ? ' open' : '') + '">' +
      hd + '<div class="card-bd">' + bodyHtml + '</div>' + '</div>';
  }

  function kv(k, v, dim) {
@@ -257,6 +291,7 @@
      return;
    }
    var html = '';
    html += buildVerifyCard(d);
    html += buildItemCard(d);
    html += buildBatchCard(d);
    html += buildQualityCard(d);
@@ -269,13 +304,59 @@
    window.scrollTo({ top: 0, behavior: 'smooth' });
  }

  // åŒºå—0：正品验证（顶部，扫码优先展示验证结论与查询统计）
  function stripUrl(v) {
    if (!v) return v;
    if (/^https?:\/\//i.test(v)) {
      var m = v.match(/[?&]code=([^&]*)/);
      return m ? decodeURIComponent(m[1]) : '';
    }
    return v;
  }

  function buildVerifyCard(d) {
    var typeLabel = { BAG: '袋码', PALLET: '托盘码', BATCH: '批次码' }[d.sourceType] || '追溯码';
    var code = stripUrl(d.requestCode) || d.batchCode || d.tempCode || '-';
    var bagNo = '-';
    if (d.sourceType === 'BAG' && d.bags) {
      for (var i = 0; i < d.bags.length; i++) {
        if (d.bags[i].code === code) {
          bagNo = d.bags[i].bagNo;
          break;
        }
      }
    }
    var statsHtml = '<div class="verify-stats">';
    if (d.antiFake && d.antiFake.scanCount > 0) {
      statsHtml += kv('累计查询', esc(d.antiFake.scanCount) + ' æ¬¡') +
        kv('首次查询', fmtDate(d.antiFake.firstScanTime)) +
        kv('最近查询', fmtDate(d.antiFake.lastScanTime));
    } else {
      statsHtml += kv('累计查询', '暂无查询记录');
    }
    statsHtml += '</div>';
    return '<div class="card verify-card">' +
      '<div class="card-bd">' +
      '<div class="verify-title">正品验证</div>' +
      '<div class="verify-badge"><span class="badge-big green">✅ æ­£å“éªŒè¯é€šè¿‡</span></div>' +
      '<div class="verify-sub">该追溯码为正规渠道产品，溯源信息真实有效</div>' +
      kv('追溯类型', typeLabel) +
      kv(typeLabel, text(code)) +
      (d.sourceType === 'BAG' ? kv('袋号', bagNo) : '') +
      kv('批次号', text(d.batchCode)) +
      kv('品种', text(d.itemName)) +
      statsHtml +
      '</div></div>';
  }

  // åŒºå—1：品种信息
  function buildItemCard(d) {
    if (!d.itemCode && !d.itemName && !d.itemSpecification) return '';
    return card('品种信息', null,
      kv('品种名称', text(d.itemName)) +
      kv('规格', text(d.itemSpecification)) +
      kv('品种编码', text(d.itemCode))
      kv('品种编码', text(d.itemCode)),
      { collapsible: true, open: true }
    );
  }

@@ -293,7 +374,8 @@
      kv('已生成袋码', fmtNum(d.bagQuantity)) +
      kv('已生成托盘', fmtNum(d.palletQuantity)) +
      kv('入库时间', fmtDate(d.inboundTime)) +
      (d.remark ? kv('备注', text(d.remark)) : '')
      (d.remark ? kv('备注', text(d.remark)) : ''),
      { collapsible: true, open: true }
    );
  }

@@ -325,7 +407,8 @@
      kv('检验员', text(q.inspectorName)) +
      kv('检验时间', fmtDate(q.inspectedAt)) +
      (q.reason ? kv('不合格原因', text(q.reason)) : '') +
      (rows ? '<div style="margin-top:8px">' + rows + '</div>' : '')
      (rows ? '<div style="margin-top:8px">' + rows + '</div>' : ''),
      { collapsible: true, open: false }
    );
  }

@@ -341,7 +424,7 @@
        esc(type) + '：' + esc(name) + '</span>';
    });
    html += '</div>';
    return card('生产人员', null, html);
    return card('生产人员', null, html, { collapsible: true, open: false });
  }

  // åŒºå—5：扫码入库事件
@@ -353,7 +436,8 @@
      kv('入库数量', fmtNum(e.quantity)) +
      kv('设备编码', text(e.deviceCode)) +
      kv('产线', text(e.lineCode)) +
      kv('入库时间', fmtDate(e.eventTime))
      kv('入库时间', fmtDate(e.eventTime)),
      { collapsible: true, open: false }
    );
  }

@@ -367,7 +451,7 @@
        fmtNum(p.bagCount) + ' / ' + fmtNum(p.capacity) + '</td></tr>';
    });
    rows += '</tbody></table>';
    return card('托盘信息', countHtml, rows);
    return card('托盘信息', countHtml, rows, { collapsible: true, open: false });
  }

  // åŒºå—7：袋码（一袋一码）
@@ -381,7 +465,8 @@
    });
    rows += '</tbody></table>';
    return card('袋码信息', countHtml,
      '<div class="scroll-list">' + rows + '</div>'
      '<div class="scroll-list">' + rows + '</div>',
      { collapsible: true, open: false }
    );
  }

@@ -394,7 +479,7 @@
        rows += '<tr><td>' + text(s.receiptCode) + '</td><td>' + text(s.vendorName) + '</td><td>' + fmtNum(s.receivedQuantity) + '</td><td>' + fmtDate(s.receiptDate) + '</td></tr>';
      });
      rows += '</tbody></table>';
      html += card('采购来源', null, rows);
      html += card('采购来源', null, rows, { collapsible: true, open: false });
    }
    if (!isEmptyList(d.salesTargets)) {
      var rows2 = '<table class="mini-table"><thead><tr><th>销售出库单</th><th>客户</th><th>数量</th><th>日期</th></tr></thead><tbody>';
@@ -402,7 +487,7 @@
        rows2 += '<tr><td>' + text(s.outCode || s.salesOrderCode || '') + '</td><td>' + text(s.customerName) + '</td><td>' + fmtNum(s.quantity) + '</td><td>' + fmtDate(s.outTime) + '</td></tr>';
      });
      rows2 += '</tbody></table>';
      html += card('销售去向', null, rows2);
      html += card('销售去向', null, rows2, { collapsible: true, open: false });
    }
    if (!isEmptyList(d.processTraces)) {
      var rows3 = '<table class="mini-table"><thead><tr><th>节点</th><th>说明</th><th>时间</th></tr></thead><tbody>';
@@ -410,7 +495,7 @@
        rows3 += '<tr><td>' + text(t.nodeName) + '</td><td>' + text(t.description) + '</td><td>' + fmtDate(t.processTime) + '</td></tr>';
      });
      rows3 += '</tbody></table>';
      html += card('加工流转', null, rows3);
      html += card('加工流转', null, rows3, { collapsible: true, open: false });
    }
    return html;
  }