程序聚合软件案例负责物联大数据数据部门管理及大数据架构及大数据核心代码开发、JAVA系统架构及核心代码开发

负责物联大数据数据部门管理及大数据架构及大数据核心代码开发、JAVA系统架构及核心代码开发

2025-05-26 15:37:56

行业：企业服务(saas)、物联网

载体：云服务/云平台、框架或代码包

技术：Java、Kafka、Redis、InfluxDB

业务和功能介绍

以围绕客户的物理业务管理“对象”（关键人、关键物）提供场景化联结服务;提供一站式的场景落地物联解决方案和服务，平台内“纵向贯通端边云网，闭环物联场景的落地实施；全周期、全链路的物联运维运营服务，保障业务场景持续可靠、可用、好用; 沉淀行业knowhow的“物联模型”、“特色场景”、“专业智能算法”。
告警中心：提供面向物联海量时序数据根据配置规则进行业务告警、告警消息触达（短信、邮件、消息队列）、告警合并、告警恢复。
数据质量保障平台：提供面向物联海量时序数据根据配置规则进行数据质量校验、处理以及数据质量告警触达（短信、邮件、消息队列）、智能分析（综合监控、多维分析、预测性维护、使用行为分析）。
指标计算平台：提供面向物联海量时序数据根据配置规则进行业务指标、统计报表计算。
物联知识图谱平台：以设备和事件处置为核心、立足于物联设备管理、管控，数字孪生体构建、业务流程、业务规则，目标支撑项目、场景级的知识复用，并提供告警、故障的诊断，定位、自动处置，事件及应急事件的处置支撑等核心主题域，提升规划、开发、测试、运维、实施的效率和效果。

项目实现

1.项目参与人12人，分为前端web应用系统及后端大数据服务，我主要负责：物联平告警中心、数据质量保障平台、指标计算平台、物联知识图谱平台相关产品架构及研发、测试、部署、上线。包括saas环境、项目私有化环境的支持。
2.基于Kafka+redis+Flink+TDengine+StarRocks的架构对数据进行接入和预处理；
基于Flink、Janusgraph组件作为基础计算引擎；
基于Flink实时接收和处理数据，对数据进行提取、清洗、关联、标识，以及对象抽取等操作；
基于FLink 和Janusgraph 图计算进行对象化分析和标注；
基于FLink、TDengine和进行业务建模和分析；
基于FLink+StarRocks/ClickHouse实时数仓，数据分析；
基于Elasticsearch建立非结构化文本数据的索引，支持关键词检索；建立结构化数据和对象数据的结构化索引，支持复杂条件的查询和检索；
基于Spring Cloud Alibaba、Spring Boot前台应用微服务架构；

示例图片视频

简单

30天前活跃

方向：后端-Java、后端-Python、

交付率：100.00%

查看主页

相似推荐

企业数字化管理系统-企航 EasyOps

这个系统主要是给中小企业用来管理日常业务的。很多小公司平时用 Excel 记录客户、订单和库存，时间久了数据容易乱，也不好查。这个项目就是把客户、订单、库存、审批和报表这些内容集中到一个系统里管理.系统里有工作台、客户管理、订单管理、库存管理、审批中心和经营报表。用户可以在系统里录入客户信息，查看客户跟进情况；也可以创建订单、查看订单状态和订单金额；库存数量可以统一管理，库存低了系统会提醒；一些订单折扣、合同、退款申请可以走审批；最后还能通过报表查看销售额、客户数量、库存预警等经营数据。

基于多智能体与知识图谱的复杂知识分析平台

1. 立项背景和目标面向复杂知识问答、多步任务拆解和证据驱动分析场景，搭建统一的 AI Agent 平台。旨在解决传统问答系统在复杂任务中可分解性不足、证据链不可追溯、文档与图谱数据割裂、模型选型缺乏统一评测等痛点，降低知识密集型分析任务的人工操作成本。 2. 核心功能模块多智能体协作：采用 planner -> dispatcher -> summary 主链路，支持任务拆解、依赖编排和拓扑执行。知识检索与定位：集成文档多格式解析、片段级检索、页级定位及 Neo4j 知识图谱 Cypher 检索。评测与选型底座：支持对不同模型、提示词策略和子代理组合进行横向对比与流程稳定性观察。前端工作台：支持多会话聊天、模型参数配置、执行轨迹面板、知识图谱可视化及结果下载。 3. 业务流程与功能路径用户上传多格式文档或输入复杂分析任务 -> 系统提取分析并构建图谱 -> 多智能体协作编排并调度任务（子代理执行文档精读和图谱检索） -> 聚合生成可追溯、可信的结构化报告或演示文稿 -> 通过 SSE 流式反馈、渲染任务轨迹并展示给前端。

豪视界-AI 图像处理平台

AI 图像处理平台（"流行智能"后更名"豪视界"） —— 一个面向电商卖家的 SaaS 化 AI图像处理工具站。核心业务逻辑:卖家上传商品图,平台调用多个 AI引擎完成换背景、生成模特图、扩图/高清/去水印等处理,按张扣积分,处理结果存云端图库。支撑业务的系统能力 - 账户体系:邮箱/手机注册登录、JWT 鉴权、图形验证码、访客可浏览(登录才可下单) - 积分计费系统:注册赠送 100 积分、按任务类型差异化定价(可后台配置)、消费流水记录、积分套餐 - 异步任务系统:任务状态机(等待→处理中→完成/失败)、批量提交、全局任务列表、结果轮询 - 图库:处理结果云端存储(阿里云 OSS)、缩略图、任务详情回看 - 管理后台:用户管理(禁用/启用/改积分)、任务监控与重试、系统配置、积分规则/套餐配置、操作日志、仪表盘统计

企业内部ERP系统

面向鞋类全栈 ERP 系统，覆盖从客户接单、模具管理、BOM 拆解、生产排程、出入库管理到标签打印、报表分析的全链路业务流程。系统采用前后端分离架构，后端基于 Spring Boot 3 提供 RESTful API，前端为 Vue 3 + Vite SPA，支持本地开发与 Docker 生产部署两套环境。

统一开发平台-统一开发平台

1. **雪花算法**：支持 5 种 WorkerId 分配策略（配置固定值、本地随机、Redis、ZooKeeper、Nacos） 2. **号码段模式**：数据库维护号码段，应用启动时自动建表，支持步长和号段缓存 3. **号码段链模式**：优化号码段的双 Buffer 机制，消除号码段切换时的耗时 4. **缓存集成**：号码段和号码段链支持本地（Caffeine）+ Redis 双级缓存 5. **代理服务**：独立部署的 ID 代理服务，提供 HTTP + Dubbo 接口 6. **Starter 集成**：应用通过 Starter 直接集成 ID 生成能力 7. **MyBatis 自动注入**：通过 MyBatis-Plus MetaObjectHandler 自动填充 ID 8. **独立 ID 池**：每个 `表名 + 主键字段名` 可拥有独立的 ID 池配置