业务和功能介绍
1. 设备全生命周期管理
设备接入赋能：基于电信 IoT 平台（CTWing）的 MQTT/HTTP 接入协议，支持智能仪表、阀门控制器、传感器等多类型设备的批量注册与接入，实现设备唯一标识（IMEI/IMSI/GUID）与平台资源的绑定，兼容 4G/NB-IoT 等通信方式。
设备状态管控：提供设备在线状态监控、离线告警、远程重启 / 配置更新功能，支持设备固件升级（FOTA）的全流程管理，实现设备激活、运行、维护、注销的全生命周期可视化管控。
资产信息同步：对接电信 IoT 平台设备档案接口，同步设备型号、通信类型、安装位置、所属终端等核心信息，建立统一的设备资产台账，支持多维度筛选与导出。
2. 数据采集与解析
实时数据采集：通过电信 IoT 平台的数据上报通道，接收设备上传的计量数据（如能耗、流量）、状态数据（如开关状态、故障码）、环境数据（如温度、压力），采集频率支持 1 分钟 - 24 小时可配置。
协议解析适配：针对不同设备的私有协议（如 Modbus、TCP/UDP），结合电信 IoT 平台的协议解析能力，实现原始数据的标准化转换，输出结构化数据（JSON 格式）供下游系统调用。
数据清洗与补全：处理数据缺失、异常值过滤等问题，通过电信 IoT 平台的边缘计算节点实现部分数据预处理，降低云端处理压力，确保数据准确性与完整性。
3. 监控告警与远程控制
实时监控看板：基于电信 IoT 平台的时序数据存储能力，搭建设备运行状态监控大屏，展示关键指标（如在线率、数据上报成功率、告警数量）的实时统计与趋势分析。
多维度告警体系：支持阈值告警（如超温、低电量）、状态告警（如离线、故障）、自定义规则告警，通过短信、平台消息、邮件等方式推送告警信息，支持告警分级（紧急 / 重要 / 一般）与工单流转。
远程指令下发：通过电信 IoT 平台的下行指令接口，实现对设备的远程控制（如阀门开关、参数调整、数据采集指令触发），支持指令状态回调与执行结果确认，确保指令可达性与可靠性。
设备接入赋能：基于电信 IoT 平台（CTWing）的 MQTT/HTTP 接入协议，支持智能仪表、阀门控制器、传感器等多类型设备的批量注册与接入，实现设备唯一标识（IMEI/IMSI/GUID）与平台资源的绑定，兼容 4G/NB-IoT 等通信方式。
设备状态管控：提供设备在线状态监控、离线告警、远程重启 / 配置更新功能，支持设备固件升级（FOTA）的全流程管理，实现设备激活、运行、维护、注销的全生命周期可视化管控。
资产信息同步：对接电信 IoT 平台设备档案接口，同步设备型号、通信类型、安装位置、所属终端等核心信息，建立统一的设备资产台账，支持多维度筛选与导出。
2. 数据采集与解析
实时数据采集：通过电信 IoT 平台的数据上报通道，接收设备上传的计量数据（如能耗、流量）、状态数据（如开关状态、故障码）、环境数据（如温度、压力），采集频率支持 1 分钟 - 24 小时可配置。
协议解析适配：针对不同设备的私有协议（如 Modbus、TCP/UDP），结合电信 IoT 平台的协议解析能力，实现原始数据的标准化转换，输出结构化数据（JSON 格式）供下游系统调用。
数据清洗与补全：处理数据缺失、异常值过滤等问题，通过电信 IoT 平台的边缘计算节点实现部分数据预处理，降低云端处理压力，确保数据准确性与完整性。
3. 监控告警与远程控制
实时监控看板：基于电信 IoT 平台的时序数据存储能力，搭建设备运行状态监控大屏，展示关键指标（如在线率、数据上报成功率、告警数量）的实时统计与趋势分析。
多维度告警体系：支持阈值告警（如超温、低电量）、状态告警（如离线、故障）、自定义规则告警，通过短信、平台消息、邮件等方式推送告警信息，支持告警分级（紧急 / 重要 / 一般）与工单流转。
远程指令下发：通过电信 IoT 平台的下行指令接口，实现对设备的远程控制（如阀门开关、参数调整、数据采集指令触发），支持指令状态回调与执行结果确认，确保指令可达性与可靠性。
项目实现
1. 电信 IoT 平台对接模块开发
基于 OkHttpClient 封装电信 CTWing 平台 API 调用工具类，实现 Token 自动获取、刷新与缓存（基于 Redis），处理 API 调用异常（超时重试、断连重连），确保平台交互稳定性。
开发设备接入接口，通过电信 IoT 平台的 “设备注册” API 完成设备批量录入，实现设备 GUID 与平台 deviceId 的映射存储，支持设备接入状态实时回调更新。
对接平台数据上报接口，基于 MQTT 客户端（Eclipse Paho）订阅设备数据主题，接收设备上传的原始数据，结合平台提供的解析模板完成数据标准化转换。
2. 数据采集与处理模块实现
设计分布式数据采集架构，通过定时任务（Quartz）结合电信 IoT 平台的 “数据查询” API，主动拉取离线设备数据，补全数据链路，确保数据完整性。
开发数据清洗服务，基于规则引擎过滤异常数据（如超出合理范围、重复上报），通过 Redis 缓存热点数据（如设备在线状态），提升查询响应速度（从 500ms 优化至 100ms 以内）。
集成 InfluxDB 存储时序数据，设计合理的数据保留策略（如热数据保留 3 个月，冷数据归档），优化数据写入性能，支持每秒 1000 + 条数据的稳定写入。
项目亮点
深度融合电信 IoT 平台能力，封装可复用的平台对接工具类，降低后续同类项目的开发成本（复用率达 80%）。
基于 MQTT+RabbitMQ 实现异步通信，提升系统并发处理能力，支持设备规模弹性扩展（从 1000 台扩展至 10000 + 台无性能瓶颈）。
设计完善的数据备份与容灾机制，结合电信 IoT 平台的边缘计算能力，实现断网情况下的本地数据缓存与断点续传，确保数据不丢失。
基于 OkHttpClient 封装电信 CTWing 平台 API 调用工具类，实现 Token 自动获取、刷新与缓存（基于 Redis），处理 API 调用异常（超时重试、断连重连），确保平台交互稳定性。
开发设备接入接口，通过电信 IoT 平台的 “设备注册” API 完成设备批量录入，实现设备 GUID 与平台 deviceId 的映射存储，支持设备接入状态实时回调更新。
对接平台数据上报接口，基于 MQTT 客户端（Eclipse Paho）订阅设备数据主题，接收设备上传的原始数据，结合平台提供的解析模板完成数据标准化转换。
2. 数据采集与处理模块实现
设计分布式数据采集架构，通过定时任务（Quartz）结合电信 IoT 平台的 “数据查询” API，主动拉取离线设备数据，补全数据链路，确保数据完整性。
开发数据清洗服务，基于规则引擎过滤异常数据（如超出合理范围、重复上报），通过 Redis 缓存热点数据（如设备在线状态），提升查询响应速度（从 500ms 优化至 100ms 以内）。
集成 InfluxDB 存储时序数据，设计合理的数据保留策略（如热数据保留 3 个月，冷数据归档），优化数据写入性能，支持每秒 1000 + 条数据的稳定写入。
项目亮点
深度融合电信 IoT 平台能力，封装可复用的平台对接工具类，降低后续同类项目的开发成本（复用率达 80%）。
基于 MQTT+RabbitMQ 实现异步通信，提升系统并发处理能力，支持设备规模弹性扩展（从 1000 台扩展至 10000 + 台无性能瓶颈）。
设计完善的数据备份与容灾机制，结合电信 IoT 平台的边缘计算能力，实现断网情况下的本地数据缓存与断点续传，确保数据不丢失。
示例图片视频
相似推荐
memRagAgent - 智能认知记忆系统
开源地址：https://github.com/daoyou-zhang/memRangeAgent
### 记忆增强检索（Memory RAG）
系统的核心是三层记忆架构的实现。情节记忆（Episodic）采用 PostgreSQL 存储，每条记录包含对话内容、时间戳、用户 ID、会话 ID 等元数据，并通过向量化技术生成 embedding，支持语义检索。语义记忆（Semantic）通过 LLM 从情节记忆中提炼，存储抽象概念、用户偏好、领域知识等，形成结构化的知识条目。程序记忆（Procedural）记录成功的工具调用序列和操作流程，支持流程复用。
向量检索基于余弦相似度算法，将用户输入向量化后，在记忆库中检索最相关的历史记录。检索结果按相关性和时间衰减加权排序，确保既考虑语义相关性，又优先召回近期记忆。通过 Redis 缓存热点查询，将 RAG 检索延迟控制在 100ms 以内。
### 认知控制器（Cognitive Controller）
认知流程分为四个阶段：意图理解 → 上下文聚合 → 回复生成 → 学习闭环。意图理解使用独立的快速模型（qwen-flash），低温度（0.1）保证稳定的 JSON 输出，分析用户意图类别、实体、置信度和是否需要工具调用。上下文聚合从记忆服务获取用户画像、工作记忆（最近对话）和 RAG 检索结果，从知识服务获取图谱查询结果，融合成完整上下文。回复生成使用高质量模型（deepseek-v3），温度 0.5 保证创造性和稳定性的平衡。学习闭环将对话存入情节记忆，触发异步的画像聚合任务。
### 知识图谱集成
采用 Neo4j 图数据库构建知识图谱，支持实体（Entity）、关系（Relationship）、属性（Property）的灵活建模。实体包括人物、概念、事件等，关系包括"属于"、"相关"、"导致"等语义连接。通过 Cypher 查询语言实现路径查询、社区发现、中心性分析等图算法。
电商类型-Home Live
HomeLive是一款服务于全球用户的在线外贸交易平台，核心定位是打破跨境购物壁垒，满足中国消费者不出国门就能便捷选购全球商品的需求。平台汇集全球各地知名品牌供应商，打造多元化服务体系，涵盖在线直播带货频道、认证商家一站式购物服务，同时保障海外商品现货库存充足，提供全球货物护航直邮服务，全方位提升跨境购物的便捷性与安全性。
.该工具仅采集互联网上公开可商用、无版权声明且符合国家
为解决电商从业者手动整理商品信息效率低的问题，我用 Python 开发了一款自动爬取公开商品列表的小工具，能按设定的关键词抓取商品名称、价格和销量信息，并自动整理成表格格式，帮助快速汇总竞品或目标类目的基础数据，降低人工整理的时间成本。该工具仅支持爬取用户授权或平台公开可商用的非版权类图片与基础数据，不涉及影视、付费素材等有版权保护的内容，全程遵守网站 robots 协议和数据使用规范，确保爬取行为合法合规
本地生活小程序
本地生活小程序，为了相应政策的拉动消费，让本地人群实现物美价廉的购物体验，包括在线超市，本地商家等，超市支持配送到家，平台商户折扣消费后返积分，积分可以兑换优惠券，再次消费，打造良性循环。
充电宝小程序，用于充电宝租借，电池包租借小程序用于电池包租借
立项背景和目标：
随着共享经济发展，共享充电宝已成为人们外出时解决手机电量焦虑的刚需。本项目旨在开发一款跨平台的充电宝租借小程序/App，覆盖用户从查找附近机柜、扫码租借、在线支付到归还的全流程。同时通过电池包租借功能拓展业务场景（如便携充电包），提升用户体验与平台收益。
核心功能模块：
地图找点：基于LBS显示附近可用机柜，支持按距离/空闲状态筛选，一键导航。
扫码租借：扫描机柜二维码或手动输入编号，快速租借充电宝或电池包。
信用免押：接入第三方信用分（如芝麻信用），高信用用户免押金租借。
订单与支付：实时计费，支持微信/支付宝支付，订单历史可查，押金秒退。
用户中心：个人信息、优惠券、客服反馈、使用帮助等。
业务流程描述：
用户打开小程序 → 授权定位 → 首页地图展示附近机柜 → 点击机柜查看详情（剩余充电宝数、距离）→ 选择“扫码租借”扫描二维码 → 确认租借，系统判断信用分 → 免押/支付押金 → 机柜弹出充电宝 → 使用中可查看剩余电量/计费 → 归还时扫描任意同品牌机柜二维码 → 插入充电宝 → 系统自动结算费用并扣款 → 订单完成。
帮助文档
Copyright @ 2021-2024 程聚宝 | 浙ICP备2021014372号
人工客服