数据处理

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

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

技术栈：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索引中，

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

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