业务和功能介绍
1.本项目是一个面向加油站场景的智能视频监控系统,核心业务是 油罐车卸油作业的全程自动化监控与合规检测。系统通过海康威视 SDK 拉取摄像头实时视频流,利用 YOLO 目标检测 + YOLOv8-pose 姿态估计进行实时分析,自动完成"油罐车到达 → 静电消除 → 接地线连接 → 消防器材就位 → 卸油中持续监控 → 油罐车离开"的全流程合规检查,并自动录像归档。同时具备通用的事件规则引擎、动作识别、运动检测、音频检测等能力。
2.业务用途: 通用的规则评估与事件触发引擎,基于区域人数/物品统计和时间窗口判断是否触发告警事件。
2.业务用途: 通用的规则评估与事件触发引擎,基于区域人数/物品统计和时间窗口判断是否触发告警事件。
项目实现
3.核心功能:区域统计(update_zone_count): 为每个摄像头的每个区域(zone)维护时间序列统计,记录每帧的人数/物品数、检测明细(detections)、动作(actions),仅保留最近 10 秒数据。
规则评估(evaluate_rules): 评估摄像头下所有启用的规则,支持三种规则类别(rule_category):
simple(传统单次触发):默认,条件满足即触发。
continuous(持续监控):仅当卸油会话处于 UNLOADING 状态时生效。
flow_step(流程步骤):仅当卸油会话状态匹配 allowed_states 时生效。
条件评估(_evaluate_condition): 支持 6 种比较运算符(lt/le/gt/ge/eq/ne)对比阈值;可指定目标类型(target)、必需动作(action,如跌倒)、必需物品(required_objects,如安全帽)。条件 = 数量条件 AND 动作条件 AND 物品条件。
持续时间机制: 条件满足后需持续满足 duration 秒才触发(duration=0 则立即触发);条件中断则重置。
触发后动作: 生成事件消息 → 写入数据库 event_logs → 调用已注册的回调函数(用于 WebSocket 推送等)。
后台清理: 每 30 秒清理 60 秒前的过期统计数据和长时间未触发的规则状态。
单例模式 + 线程安全锁。
unload_oil_engine.py — 卸油作业状态机引擎(核心业务)
业务用途: 维护每个摄像头当前的卸油会话(session),驱动卸油作业全流程状态流转,自动检测每个步骤的合规性,并在卸油过程中持续监控违规行为。
4.完整流程逻辑：自动开会话: 无活跃会话且检测到 tanker ≥1 → 自动 start_session,写入数据库。
TRUCK_ARRIVED → 检测到 tanker + person 同时存在 → 自动推进到 STEP1。
STEP1 → 检测人在静电消除器附近(中心点距离 <120px)且持续 ≥3 秒 → 推进到 STEP2。
STEP2 → 检测接地线 + 油罐车同时存在且持续 ≥5 秒 → 推进到 STEP3。
STEP3 → 检测灭火器 ≥1 且消防桶 ≥1 且持续 ≥3 秒 → 推进到 UNLOADING。
UNLOADING → 持续监控三类违规(带 30 秒冷却去重):
人数不足: 现场 <3 人(warning)。
未穿工衣: 通过 person 与 safety_vest 的 bbox 配对(距离 <150px),未配对的视为未穿(warning)。
上车未戴安全帽: 人在油罐车 bbox 内 + 附近(100px)无安全帽(critical)。
自动结束: 连续 10 秒(TRUC
规则评估(evaluate_rules): 评估摄像头下所有启用的规则,支持三种规则类别(rule_category):
simple(传统单次触发):默认,条件满足即触发。
continuous(持续监控):仅当卸油会话处于 UNLOADING 状态时生效。
flow_step(流程步骤):仅当卸油会话状态匹配 allowed_states 时生效。
条件评估(_evaluate_condition): 支持 6 种比较运算符(lt/le/gt/ge/eq/ne)对比阈值;可指定目标类型(target)、必需动作(action,如跌倒)、必需物品(required_objects,如安全帽)。条件 = 数量条件 AND 动作条件 AND 物品条件。
持续时间机制: 条件满足后需持续满足 duration 秒才触发(duration=0 则立即触发);条件中断则重置。
触发后动作: 生成事件消息 → 写入数据库 event_logs → 调用已注册的回调函数(用于 WebSocket 推送等)。
后台清理: 每 30 秒清理 60 秒前的过期统计数据和长时间未触发的规则状态。
单例模式 + 线程安全锁。
unload_oil_engine.py — 卸油作业状态机引擎(核心业务)
业务用途: 维护每个摄像头当前的卸油会话(session),驱动卸油作业全流程状态流转,自动检测每个步骤的合规性,并在卸油过程中持续监控违规行为。
4.完整流程逻辑：自动开会话: 无活跃会话且检测到 tanker ≥1 → 自动 start_session,写入数据库。
TRUCK_ARRIVED → 检测到 tanker + person 同时存在 → 自动推进到 STEP1。
STEP1 → 检测人在静电消除器附近(中心点距离 <120px)且持续 ≥3 秒 → 推进到 STEP2。
STEP2 → 检测接地线 + 油罐车同时存在且持续 ≥5 秒 → 推进到 STEP3。
STEP3 → 检测灭火器 ≥1 且消防桶 ≥1 且持续 ≥3 秒 → 推进到 UNLOADING。
UNLOADING → 持续监控三类违规(带 30 秒冷却去重):
人数不足: 现场 <3 人(warning)。
未穿工衣: 通过 person 与 safety_vest 的 bbox 配对(距离 <150px),未配对的视为未穿(warning)。
上车未戴安全帽: 人在油罐车 bbox 内 + 附近(100px)无安全帽(critical)。
自动结束: 连续 10 秒(TRUC
示例图片视频
相似推荐
人寿保险核心业务系统-LIS
1，为人寿保险公司提供核心业务开展的软件支持，满足公司业务开展要求和监管审批条件
2，涉及投保，保全，理赔，监管等模块
3，投保模块从扫描开始，对保单数据提取，人工核对录入后，通过工作流审核，将保单存放系统并形成正式合同。监管模块通过配置规则，将业务订单和财务数据按监管要求进行提取，生成文件上报，对回执内容解析和生成后续工作流。
阿里某BU-对账结算系统
阿里某BU对账结算系统是面向交通出行场景的全链路财务结算平台，全面支撑机票、火车票、船票、租车等多条业务线的资金对账与结算工作，覆盖交易对账、账单核销、成本核算、利润结转、差错处理全流程核心能力，是BU出行交易资金闭环、账务合规、收益核算的核心底层系统。平台承接全品类出行订单的日均大规模账务计算任务，保障海量交易数据下账务精准、结算合规、异常可追溯。
系统采用主流Spring Boot微服务架构搭建后端服务，底层基于PolarDB分布式数据库完成亿级交易数据的稳定存储，依托MaxCompute Spark构建弹性算力引擎，搭建批流一体OLAP计算体系，支撑日均百万级的对账、结转计算任务，可弹性应对大促、峰值订单流量带来的账务计算压力，保障全业务线财务结算高效、稳定、准确落地。
Go+FFmpeg 抖音财经股票指标视频自动化生成系统
一、项目简介
本人自1993年接触证券市场，2004年尝试用PHP开发自动化指标筛选程序，因并发性能限制，批量数据运算耗时过长。2015年转向Go语言，依托原生并发模型，将运算耗时由半小时优化至1分钟内，期间对比Python、Julia等语言后，最终选定Go为主力开发语言。
2025年启动本项目：基于自研股票指标函数体系，搭建财经短视频自动化流水线，将量化指标可视化内容批量生成视频并适配抖音平台分发标准。
技术迭代上，初期采用fogleman/gg生成PNG图片序列，再由FFmpeg合成视频。经持续优化，现绝大部分素材渲染直接交由FFmpeg完成，仅在FFmpeg耗时过高、分辨率无法满足需求时，回退使用GG生成静态图片。整套系统已实现数据解析、图表渲染、视频合成一站式自动化。
二、业务功能
批量指标运算：批量读取量化数据，自动运算生成股票指标信号。
数据可视化渲染：支持FFmpeg滤镜实时绘图，兼容GG静态PNG绘图兜底方案。
短视频自动合成：按平台规范自动合成视频，适配抖音等主流短视频平台分辨率与码率要求。
全流程自动化调度：从数据到视频全链路自动化，支持持续产出可视化素材。
智能渲染链路切换：根据耗时、画质需求，自动选择最优渲染方案（FFmpeg主链路/GG兜底）。
三、技术栈
Go、FFmpeg、fogleman/gg、股票量化接口、自动化调度脚本
量化工作平台
1、项目是面向股票、ETF、指数和期货的本地量化数据与策略研究平台，覆盖数据维护、因子研究、策略回测及研究成果管理等环节。
2、支持从 Tushare 和期货 Tick 文件获取数据，完成增量更新、复权处理、标准化存储、失败重试以及数据完整性和质量检查。
3、内置 Basic、Alpha158、Alpha101 等因子体系，支持因子计算、覆盖率检查、IC/RankIC 分析、分组收益分析、稳定性评估和因子选股。
4、提供股票池筛选、组合回测、调仓、交易成本、涨跌停及 ST 等交易约束，并输出净值、交易、持仓、诊断和基准对比结果。
5、支持策略回测、跟踪。
6、提供本地可视化工作台，可查看数据状态、因子、策略、组合和研究产物，并通过 Watchlist 和生命周期机制管理候选策略及复盘记录。
报表中台
本模块提供多维度报表数据展示及多格式导出功能，支持将业务数据一键导出为 Excel、CSV 及 PDF 格式。系统内置高性能生成引擎，保障大数据量导出时的稳定与高效，满足用户离线分析、数据归档及财务对账等多样化业务需求。
帮助文档
Copyright @ 2021-2024 程聚宝 | 浙ICP备2021014372号
人工客服