数据处理

客车厂售后平台管理系统（pc端+安卓端）：包含物流、车组远程故障及预警预测、数据分析、应急指挥、故障处理、售后管理等功能模块。我在项目组担任核心功能模块的设计及开发工作，解决技术难题。

技术栈：Flink，Flink CDC，Kafka，Redis，PolarDB 随着公司越来越多的业务场景对实时性要求越来越高，传统的Java程序已无法满足业务需求，需要采用Flink实时计算框架来对业务进行支撑。Flink大数据实时计算服务内部包含了多个Flink任务流，分别处理多个不同的业务流程。并且结合Flink cdc服务进行数据同步，使得业务处理更加高效、便捷。 我在该项目中的职责： 1.构建Flink实时计算项目框架，搭建整体服务架构，包括Flink项目工程样例创建，数据库工具类、Kafka工具类、Redis工具类、日期工具类等。 2.java程序改造Flink，某些新的功能需求使用Flink实现，具体的服务有： (1)电站潮流图秒级计算服务，实时接收设备上传的秒级测点数据，每10s一个窗口进行数据计算并推送结果给前端； (2)通信设备时区实时纠正服务，实时接收设备升级和时区设置成功指令数据，判断是否和电站时区一致，若不一致则下发时区指令进行通信设备时区纠正； (3)电站设备实时同步服务，实时接收Flink cdc服务推送的电站、设备相关表的变更数据，同步写入到ES索引中，

1.具体的模块可以看下面的截屏 2.我负责整个前后端的项目，包括运维测试等工作 3.使用的技术 有微服务，中间件，mq消息队列，redis，es，mybatis plus，vue mysql jmeter jenkins k8s docker maven spring cloud ，负载均衡等技术

功能模块：产品通过高级图形呈现技术实现了城市交通网络的立体展示。功能模块包括实时交通流量监控、交通效率分析、路网状态动态显示、以及交通数据统计等。页面提供了多个实用工具和视图选项，如不同角度的城市视图、路况监控图、以及性能监控指标，这些都为城市交通规划和管理提供了宝贵支持。 我负责：可视化数据处理，前端页面开发，性能调优

对资源信息、违法信息、过口信息更全面的、及时的、多维度的统计分析模块。更直观的展示了交通基础建设、实时交通情况、事故情 况、违法情况、⻋辆查控情况的信息 ，更强有力的辅助用户对交通情况的了解和把控。 国家文明城检板块 ，在交通方面 ，对行人、⻋ 辆、交通设施、工作人员及志愿者的数据进行统计分析。通过交警执勤、志愿者劝导和督促 ，有效减少交通违法情况 ，极大得保障了 人们的安全出行、顺畅出行。疫情防控板块 ，从两方面及时有效的对疫情进行追踪和管控。一方面 ，对疫情⻛险区进行维护 ，及时 了解疫情⻛险区的情况。另一方面 ，对疫情⻛险区的⻋辆在我市的情况进行统计 ，有效的辅助疫情管控工作的进行。 责任描述： 1. 参与前期系统的调研和参与数据库的设计工作 2. 智慧大屏使用 websocket 技术进行数据推送 3. 负责实时从摄像头设备上取过⻋数据 4. 旧系统数据迁移到新系统 5. 后期的维护 bug 修改并且参与测试 6. ⻋辆管理、驾驶证管理、违法处理记录、统计分析、国家文明城检大屏模块、疫情防控大屏板块模块功能设计与开发 7. 负责准备上线工作 ，协同项目经理在经警队内

银行监控巡检系统相关的一些设计文档UML设计，我主要负责项目核心功能模块的设计和开发工作，解决项目中遇到的技术问题等工作，项目中包含自己公司开发的一套工作流系统。 技术栈:springboot+redis+RabbitMQ+mybatis+mysql+SQLite+vue.js

用户通过 ci-manager 服务配置搭建流水线，设置配置文件，根据配置文件中的需求，进行 构建，处理得到用户需要的结果，进行后续发布。补丁方面，当最新发布版本与其他部件不 适配时，需要回退到某个代码节点，工具节点，针对这种情况，用户可以合理修改配置文件， 完成特殊构建任务

技术栈：Flink，Spark，Kafka，HBase，Mysql ，语种识别引擎，语音转写引擎 该项目主要是建设重点人管控分析平台，利用只能语音技术，意图分析技术，实现重点管控人员的的及时发现，并进行预警防范。系统依托大数据平台的存储与运算能力，实时接入通话、短信、上网、轨迹数据，分别按照多种规则进行分析过滤后，实现重点人员的识别入库以及敏感行为的预警触发。 我在项目中的职责： 1.预处理服务：使用 Flink 实时从 Kafka 接入通话、短信、上网数据，并分别按照不同规则进行分析，若满足一定条件则将该数据对应人保存至重点人库中。 2.重点人预警服务：使用 Flink 实时从 Kafka 接入重点人的通话、短信、上网、轨迹数据，开关机数据，分别按照不同规则进行预警，满足预警条件则推送至前端展示；