1. 农业数据底座:全球农业生产、农产品价格、气象、农业指标、作物、国家地区六大主数据域的统一管理(insight_agri_* 6 张表)。
2. 多源数据采集与治理(ETL 管线):API / 网页 / 文件三类采集器 → CSV / JSON / HTML 表格解析 → 字段映射与维度标准化(国家/地区/作物/单位/币种/时间粒度,别名库 60s 内存缓存)→ 数据质量校验(完整性/唯一性/格式/值域/一致性)→ 场景化入库 → Schema 结构指纹变更检测(待人工确认)。
3. 农副产品集散中心:集散中心市场档案与交易流水管理,日/周/月价格聚合、品种对比、产地对比。
4. 多维统计分析:产量趋势(按地区分序列)、国家对比排名、价格/气象/指标趋势、产量-气象 Pearson + Spearman 相关性分析。
5. 统计预测:产量 / 价格 / 单产三类预测对象,内置趋势回归、移动平均、Holt 线性二次指数平滑三个预测器(SPI),输出预测值 + 置信区间上下界。
6. 风险预警:规则引擎(价格上涨/下跌、产量预测下降、天气异常、价格异常波动 + 自定义),命中规则自动生成风险事件与预警。
7. AI 分析报告:组装分析概览 + 趋势 + 预测 + 风险快照数据上下文,AI 工作流生成 Markdown 报告(模板生成器兜底),支持定时调度自动生成并站内信推送。
8. C 端自助洞察门户:免登录试用(按 IP 每日限次)、上传 CSV/Excel 自动产出 ECharts 图表与描述性统计、上传 PDF/Word 建立个人知识库并 RAG 问答(引用来源可溯源)、注册享每月免费分析额度。
9. AI 平台底座与智能审批:平台同时集成 AI 对话 / AI 知识库 / AI 工作流(yudao-module-ai)与数字员工 AI 审批工作流(yudao-mod
B 端管理后台(21 个业务控制器)
模块
功能
农业数据
作物、国家地区、生产数据、农产品价格、天气数据、农业指标六大数据域管理(支持 Excel 导出)
数据采集
数据源管理(API/网页/文件/数据库/RSS)、采集任务(Cron 调度 + 手动触发)、数据质量报告、Schema 变更审核
标准化
标准化维度(country/region/crop/unit/currency/time_grain)、别名库(采集数据自动归一)
集散中心
市场管理、交易流水管理(Excel 导出)、价格趋势/品种对比/产地对比分析
农业分析
数据概览 Dashboard、产量/价格/气象/指标趋势、国家对比、相关性分析
预测服务
选择预测对象(产量/价格/单产)与模型(趋势回归/移动平均/Holt),一键预测并留存历史结果
风险预警
风险规则配置(JSON 阈值)、手动/批量风险检测、风险事件处理、预警列表
AI 报告
分析报告生成与历史管理、报告调度(频率/启停/执行日志)
C 端洞察门户(3 个 App 控制器,免登录可用)
- 门户首页:平台能力介绍、使用流程(四步获得分析)、公开分析浏览、免费额度说明;
- 资产上传:数据文件(CSV/Excel,≤20MB,EasyExcel 采样解析)与知识文档(PDF/Word/TXT/MD,自动创建 AI 知识库文档并向量化);
- 自助分析:匿名试用(IP 限次)/ 登录提问,按场景自动路由——数据统计(描述性统计 + ECharts 图表)/ 知识库检索(RAG,按文档隔离召回)/ 综合链路;额度管理(免费月度额度、失败回滚);
- 我的工作台:分析历史、图表渲染(ChartRenderer)、Markdown 结论展示(引用来源标注)。
平台公共能力(同账号体系)
- AI 大模型中心:AI 对话(多模型、上下文/联网开关)、AI
2. 后端核心实现(yudao-module-insight:309 个 Java 源文件 / 24 个控制器 / 25 张 insight_ 表 / 23 个业务枚举)
- 六组策略模式 SPI,扩展点清晰:
- Collector(ApiCollector / WebCollector / FileCollector + Factory 路由)
- Parser(CsvParser / JsonParser / HtmlTableParser,recordPath 如 $.data.records)
- RecordNormalizer(fieldMapping 字段映射 + 维度标准化,NormalizerRegistry 别名→标准编码内存缓存 60s TTL)
- DataQualityChecker(完整性/唯一性/数值格式/一致性四类检查)
- SceneStorage + SceneStorageRouter(一期 5 个入库目标:产量/价格/气象/指标/集散中心流水)
- Predictor(趋势回归 / 移动平均 / Holt 线性)、RiskRuleEvaluator(4 个评估器 + 阈值 JSON 解析基类)、ReportGenerator(AI 工作流生成器 + 模板兜底生成器)
- 采集调度:CollectionTaskJob 每分钟扫描启用数据源,CronExpression 判定到期触发异步执行(线程池 core 2 / max 4),AtomicBoolean 防重入、@TenantIgnore + TenantUtils.execute 保租户上下文;ReportScheduleJob 同模式驱动报告定时生成。
- 分析算法:AnalysisServiceImpl(35KB)实现 11 个分析方法,含 Pears
声明:本文仅代表作者观点,不代表本站立场。如果侵犯到您的合法权益,请联系我们删除侵权资源!如果遇到资源链接失效,请您通过评论或工单的方式通知管理员。未经允许,不得转载,本站所有资源文章禁止商业使用运营!

下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态
评论