安全一体化平台

2026-04-28 09:20:21

行业：工业互联网

载体：网站、安卓APP

技术：Java、MyBatis、Kubernetes、Spring Cloud

业务和功能介绍

立项背景和目标
为规范石化企业安全生产管理，建设安全一体化平台，实现承包商入场、施工作业、特殊作业许可、HSE检查到集团上报的全链路数字化管控，消除人工管理盲区，提升本质安全水平。

软件功能
系统涵盖承包商管理（企业入库/审批/评估/黑名单、人员档案/审核/门禁/健康/保险）、作业票管理（特殊作业许可、JSA分析、签到巡检）、HSE检查（检查→问题确认→整改→验收→罚款闭环）、机具车辆管理、临时入场审批、风险分区、集团数据上报、第三方系统对接（定位、门禁、培训、闸控等8+系统）等模块。

核心功能介绍
核心为承包商全生命周期管理：企业入库→资质审核→人员准入→作业许可→过程监管→评估退场；以及HSE检查闭环和作业票审批流转。

业务流程
承包商企业注册→资质审批→项目分配→人员准入审核→门禁授权→特殊作业票申请→JSA分析→审批签发→现场签到/巡检→HSE检查→问题整改验收→评估打分→集团数据上报。

功能路径描述
门户首页→承包商管理→企业/人员入库审核→作业票申请审批→HSE检查整改→集团上报；公共模块对接定位/门禁/培训/视频等8+外部系统实现数据联动。

项目实现

架构：采用Maven多模块单体架构，分为API接口层（api-contractor/api-construction/api-factoryinfo/api-risk）和业务实现层（system下14个业务模块），通过web模块启动。架构设计上接口与实现分离，API模块定义Feign接口供微服务间调用，system模块实现具体业务。采用Controller → Service → Mapper三层架构，Activiti工作流引擎驱动审批流程（承包商审批、作业票审批、临时入场审批等），Nacos作为注册中心和配置中心支持动态配置热更新。
框架:Spring Boot 2.7.x + Spring Cloud + OpenFeign
Web容器 :Undertow
ORM:MyBatis-Plus
工作流:Activiti
分布式事务:Seata
注册/配置中心:Nacos
PDF打印:wkhtmltox
部署:Docker + K3s + GitLab CI/CD + Kuboard

我负责的模块
承包商管理模块（系统最大模块，20+个Controller，核心Service ConUserArchivesServiceImpl）：实现企业入库审批、人员档案全流程、资质证书预警、黑名单管理、门禁卡管理、工时策略等，涵盖承包商从入场到退场的完整生命周期。
MySQL到达梦8数据库迁移：完成全量SQL语法适配、函数兼容改造、数据类型映射，系统成功在DM8上稳定运行（详见DM8_MIGRATION_REPORT.md）。
Docker容器化部署与CI/CD：编写Dockerfile、基础镜像（Zulu JDK + CentOS + 中文字体 + wkhtmltox），配置GitLab CI/CD自动构建部署到K3s集群，实现dev-dm分支推送自动部署。
第三方系统对接（module-common）：实现8+外部系统（人员定位、门禁、培训、闸控、车辆等）的数据对接与同步。
AssignGroupUtil工作流组指派：实现Long型用户组ID的Base64压缩编码，解决Activiti流程中用户组指派的标识问题。

遇到的难点、坑和解决方案
MySQL到达梦8迁移：DM8语法与MySQL存在差异（如分页、日期函数、关键字冲突），需逐表逐SQL适配，最终通过全量SQL审查+函数替换+数据类型映射完成迁移，系统零停机切换。
Activiti工作流与业务深度耦合：流程审批节点需动态指派用户组并关联部门，开发AssignGroupUtil实现组ID压缩编码（_G_前缀+Base64），在流程引擎中透传组指派信息，解耦流程与业务。
多第三方系统对接：8+外部系统接口协议各异、数据格式不统一，通过统一Controller封装+API日志记录

示例图片视频

舔砖java

15天前活跃

方向：后端-Java、

交付率：100.00%

查看主页

相似推荐

java赛事爬虫

## 一、项目概述本项目是一个基于 Java 的**东京奥运会（2020）赛事数据爬虫与可视化系统**，以新浪体育东京奥运专题页面（`http://2020.sina.com.cn/`）为数据来源，自动抓取奥运**新闻资讯**和**中国代表团各项目奖牌数据**，持久化存储至本地 MySQL 数据库，并通过图形化桌面界面（Java Swing）进行数据展示与查询。 --- ## 二、业务背景东京奥运会于 2021 年 7 月 23 日至 8 月 8 日举行（因疫情延期一年）。新浪体育为此开设了专题页面，提供实时新闻报道和各项目奖牌查询 API。本项目通过爬虫技术对上述数据进行采集，服务于以下业务场景： - **赛事跟踪**：快速聚合奥运新闻，方便集中浏览。 - **奖牌统计**：自动汇总中国代表团在射击、乒乓球、举重、跳水等 13 个重点项目的金/银/铜牌数量。 - **数据查询**：支持按关键词检索新闻标题和赛事名称，实现快速定位。 --- ## 三、系统功能介绍 ### 3.1 主界面 — 爬虫启动 | 功能 | 说明 | |------|------| | **一键爬取** | 点击"开始爬取"按钮，系统自动清空旧数据并重新采集 | | **新闻采集** | 抓取新浪奥运首页的新闻链接，逐条进入详情页提取完整内容 | | **奖牌采集** | 依次调用新浪奥运奖牌 API，获取 13 个运动项目的实时奖牌数据 | | **进度反馈** | 控制台打印"....."进度提示；采集完成后弹出"爬取成功"对话框 | | **自动跳转** | 成功后自动关闭启动窗口，打开"奥运数据一览"展示窗口 | ### 3.2 数据展示界面 — 奥运数据一览 #### Tab 1：新闻信息 | 功能 | 说明 | |------|------| | **列表展示** | 以表格展示所有新闻的标题、发布时间、发布者、正文内容 | | **关键词搜索** | 在搜索框输入新闻标题关键词，点击"查询"进行模糊匹配过滤 | | **实时刷新** | 界面加载时自动从数据库读取最新数据 | #### Tab 2：奖牌信息 | 功能 | 说明 | |------|------| | **列表展示** | 以表格展示 13 个运动项目的金牌、银牌、铜牌合计数 | | **关键词搜索** | 支持按赛事名称（如"乒乓球"）进行模糊查询 | | **实时刷新** | 组件渲染时自动加载数据库记录 | **涵盖的 13 个赛事项目：** > 射击、篮球、三对三篮球、田径、游泳、乒乓球、羽毛球、举重、跳水、蹦床、竞技体操、艺术体操、赛艇

分布式电商数据采集与分析系统

【立项背景与目标】随着电商平台竞争加剧，企业对竞品价格监控、市场趋势分析和用户评论洞察的需求日益迫切。传统人工采集方式效率低下、覆盖不全、数据滞后。本系统旨在构建一套自动化、分布式的电商数据采集与分析平台，实现对主流电商平台（淘宝、京东、拼多多、抖音）商品数据的全天候自动采集与智能分析，为企业提供实时、准确的市场情报和决策支持。【核心功能模块】 1. 分布式采集引擎：基于Scrapy+Redis构建，支持多节点并行采集，内置代理IP池自动切换、Cookie管理、验证码识别等反爬对抗模块，日均采集能力超过120万条商品数据。 2. 任务调度中心：提供可视化任务配置界面，支持Cron定时调度、实时流式采集与手动触发三种模式，可自定义目标平台、商品品类、采集字段（标题、价格、销量、评价、店铺信息等）。 3. 数据清洗与存储管道：自动完成数据去重、格式标准化、异常值过滤，结构化存入MySQL集群，同时同步至Elasticsearch实现毫秒级全文检索。 4. 智能分析模块：提供价格波动趋势分析、竞品销量排名、用户评论情感分析（好评/中评/差评自动分类），通过ECharts大屏实时可视化呈现。 5. 异常告警系统：支持价格突变、商品下架、评论异常等场景的阈值告警，通过钉钉/邮件/飞书实时推送。【业务流程】用户配置采集任务（选择平台→品类→字段→调度策略）→系统自动分发至Celery任务队列→Redis去重后分配给各Worker节点→Scrapy/Playwright执行页面抓取→数据经清洗管道处理后入库→前端Dashboard实时展示采集进度与数据分析结果→异常数据触发告警通知。

某部数据中台

建设目标在于解决前台数据服务需求与后台数据服务供给相匹配的问题，提高数据产品服务的规模化生产能力、快速需求响应能力和组件化可复用能力。在产品层面，数据中台的总体架构分为16个子域：数据门户、数据展示中心、自助查询中心、数据交换中心、作业调度中心、元数据资产中心、文件管理中心、智能AI分析中心、流数据实时分析中心、数据标签中心、数据指标中心、自然语言NLP中心、图像识别OCR中心、智能推荐中心、知识图谱中心、时序预测中心。

可视化建模平台-可视化建模平台

一、项目背景面向市大数据局、公安、市监局等政务部门开展项目，各部门已完成数据治理工作，但数据加工需开发人员手写代码实现，存在需求响应慢、业务人员无法自主操作、数据处理效率低等痛点，亟需搭建低门槛数据处理平台。二、项目目标 1. 采集政务数据元数据信息，实现库表、字段及业务含义统一管理 2. 搭建拖拽式可视化建模平台，通过算子实现数据自助加工，降低使用门槛 3. 新增定时任务调度功能，实现建模任务自动化执行 4. 对接BI报表模块，实现加工数据可视化展示 5. 提升数据处理与需求交付效率，支撑政务业务自助数据分析三、项目概述搭建政务低代码可视化数据建模平台，自动采集治理后数据的元数据信息，提供过滤、排重、聚合、拆分等拖拽式算子，实现业务人员自主数据加工。支持建模任务定时调度、结果数据异构系统同步与级联分析，同时打通BI报表模块，可自主生成柱状图、折线图、甘特图等图表，完成数据加工到可视化全流程自助化。

物联网实时大数据清洗BI报表-实时报表

一、项目背景工厂内机床、设备通过PLC采集温湿度、压力、电量、加工计数等实时物联网数据，经Modbus 等协议接入Kafka。原始数据存在大量重复、异常、乱序、跳变问题，无法直接用于MES系统与生产大屏；设备运行状态（绿/黄/红/灰）无统一规则，加工计数易重复统计，亟需一套从0到1的实时数据清洗与治理体系。二、项目目标 1. 建立设备状态标准化规则，自动识别正常、告警、故障、停机状态并统计各状态持续时长； 2. 构建生产加工计数清洗规则，过滤重复上报数据，处理人工重置等异常场景，保证计数准确； 3. 输出标准结构化数据，支撑MES系统、生产可视化大屏分钟/小时/日报表展示。三、项目概述该项目为工业物联网数据治理从0到1建设，采用Flink +Doris 技术架构。从Kafka消费设备实时采集数据，通过自定义清洗规工重置场景处理。清洗后数据写入聚合表，为下游MES系统、可视化大屏提供分钟级至日报级的标准化数据，支撑生产监控、趋势分析与产能统计。项目职责： 1. 独立负责工业物联网数据治理项目从0到1设计与落地，参与整体架构方案讨论，最终确定并实现Flink +Doris 实时数仓架构； 2. 全程负责从Kafka消费设备实时数据，完成数据清洗、去重、异常过滤、乱序处理、状态计算、指标聚合等全流程开发； 3. 设计并实现设备运行状态（正常/告警/故障/停机）规则引擎，自动统计各状态持续时长并结构化落表； 4. 开发生产加工计数精准清洗逻辑，处理重复上报、人工重置等复杂业务场景，确保计数准确； 5. 构建标准聚合层数据模型，对外提供数据接口，支撑下游MES系统、生产可视化大屏实时展示与报表统计； 6. 负责需求变更、接口迭代及历史数据重刷、补算等运维工作，保障数据一致性。 7、使用AI工具(WorkBuddy后者TRAE CN)辅助提高开发效率技术栈：Kafka+Flink+Doris+SpringBoot+Redis+Minio+Python