前言上一篇我们完成了工业双层服务层架构的完整落地实现了公共能力与业务能力的服务化、解耦化、标准化项目彻底摆脱了杂乱业务逻辑堆砌的问题具备了工程化业务处理能力。服务层负责业务逻辑处理而支撑所有业务运行、参数存储、生产追溯、日志留存的核心根基就是数据持久化层。很多工业上位机项目普遍存在致命数据问题配置重启丢失、生产数据错乱、文件读写异常、数据库连接崩溃、离线场景无法存数、数据重复覆盖等。这些问题在工控机7×24小时长期运行场景中会直接导致生产参数失效、批次追溯断层、设备运行异常属于量产项目高危BUG。出现以上问题的根本原因没有分层的数据架构、没有统一的数据读写规范、没有工业级容错机制。多数新手直接在业务逻辑中硬写文件读写、SQL语句数据逻辑散落全场完全无法管控。本篇我们从零搭建工业级标准化数据持久化架构落地Repository通用仓储模式统一封装JSON配置持久化、本地数据缓存、数据库读写、离线容错、自动恢复机制彻底解决工业项目数据错乱、丢失、异常崩溃的核心痛点搭建一套可直接量产的数据底层体系。本篇核心目标实现数据层与业务层彻底解耦打造高稳定、高容错、可复用、可拓展的工业数据持久化体系。一、工业项目数据开发的常见致命坑点在正式编码搭建架构前我们先梳理传统上位机数据开发的核心问题搞懂为什么工业项目必须规范化数据层数据逻辑高度耦合业务服务、UI页面直接写文件读写、数据库操作数据逻辑散落各处无法统一维护配置数据极易丢失没有自动保存、缓存兜底机制程序闪退、断电重启后参数全部重置无读写容错机制文件占用、路径不存在、数据库断连时直接报错崩溃程序稳定性极差离线场景适配差设备断网、数据库离线时无法缓存数据导致生产数据断层、追溯失效数据结构混乱无统一实体模型读写参数随意定义后期迭代极易出现字段不匹配、数据错乱无法切换数据源想从JSON本地存储切换为数据库存储需要大面积改写业务代码总结一句话没有标准化仓储架构的数据层是工业项目最大的不稳定隐患完全无法支撑量产设备长期运行。二、工业数据分层架构整体设计结合工业上位机“本地优先、离线可用、在线同步、容错兜底”的核心特点我们设计一套四层标准化数据架构严格单向依赖、职责清晰、完全解耦。1. 数据实体层Entity定义所有数据模型、参数模型、生产模型、配置模型统一字段规范、数据默认值是所有数据的载体纯净无逻辑、无依赖。2. 数据仓储接口层IRepository定义统一数据读写规范约束新增、查询、修改、删除、批量保存、缓存刷新行为实现数据源抽象。3. 仓储实现层Repository实现具体数据读写逻辑分为JSON本地仓储、数据库仓储、离线缓存仓储可无缝切换数据源。4. 数据服务层DataService封装所有数据对外能力对接上层业务服务统一处理数据校验、异常捕获、容错重试、自动恢复为业务层提供稳定数据支撑。架构核心优势工业专属数据源无缝切换本地JSON、SQLite、MySQL可随意切换无需改动业务代码离线在线双适配断网自动本地缓存联网自动同步数据杜绝数据丢失读写全程容错文件异常、IO冲突、数据库断连自动重试、兜底恢复业务数据彻底解耦业务层只调用数据服务不关心底层存储方式三、通用仓储接口统一规范落地我们首先在Core层定义通用仓储顶级接口统一所有数据模型的读写行为让所有仓储实现遵循同一套规范杜绝代码五花八门。在Core层新建 Interfaces/Data 文件夹创建通用仓储接口usingSystem.Collections.Generic;usingSystem.Threading.Tasks;namespaceIndustrial.Core.Interfaces.Data{/// summary/// 工业项目通用数据仓储顶级接口/// 统一所有实体数据读写规范/// /summary/// typeparam nameT数据实体模型/typeparampublicinterfaceIRepositoryTwhereT:class,new(){/// summary/// 根据Key查询单条数据/// /summaryTGetById(stringkey);/// summary/// 获取全部数据列表/// /summaryListTGetAll();/// summary/// 新增/保存单条数据/// /summaryboolSave(Tmodel);/// summary/// 批量保存数据/// /summaryboolBatchSave(ListTlist);/// summary/// 根据Key删除数据/// /summaryboolDelete(stringkey);/// summary/// 清空所有数据/// /summaryboolClearAll();/// summary/// 异步保存适配高频生产数据/// /summaryTaskboolSaveAsync(Tmodel);}}四、工业数据实体模型标准化定义工业所有存储数据必须规范化建模我们以设备参数模型、生产记录模型为例定义标准实体统一数据格式、默认值避免空数据、字段错乱问题。在Data层新建 Entity 实体文件夹1. 设备参数配置模型DeviceConfignamespaceIndustrial.Data.Entity{/// summary/// 工业设备全局参数配置模型/// 持久化保存设备阈值、通讯参数、生产参数/// /summarypublicclassDeviceConfig{/// summary/// 配置唯一Key/// /summarypublicstringConfigKey{get;set;}/// summary/// 设备通讯波特率/// /summarypublicintBaudRate{get;set;}9600;/// summary/// 超时时间(ms)/// /summarypublicintTimeout{get;set;}2000;/// summary/// 生产阈值/// /summarypublicintProductThreshold{get;set;}100;/// summary/// 自动运行开关/// /summarypublicboolAutoRun{get;set;}false;}}2. 生产记录数据模型ProductRecordusingSystem;namespaceIndustrial.Data.Entity{/// summary/// 生产追溯记录模型/// 用于生产数据持久化、批次追溯、品质统计/// /summarypublicclassProductRecord{/// summary/// 批次号/// /summarypublicstringBatchNo{get;set;}/// summary/// 生产数量/// /summarypublicintProductNum{get;set;}/// summary/// 不良数量/// /summarypublicintErrorNum{get;set;}/// summary/// 生产时间/// /summarypublicDateTimeProductTime{get;set;}DateTime.Now;/// summary/// 设备状态/// /summarypublicstringDeviceState{get;set;}}}五、JSON本地仓储完整实现工业离线核心工业现场工控机经常断网、数据库离线JSON本地文件存储是工业上位机必备兜底方案。我们基于通用仓储接口封装一套带缓存、带容错、带自动恢复的JSON仓储实现。在Data层新建 Repository 文件夹创建 JsonRepository 通用仓储类usingSystem;usingSystem.Collections.Generic;usingSystem.IO;usingSystem.Linq;usingSystem.Threading.Tasks;usingIndustrial.Core.Interfaces.Data;usingIndustrial.Core.Utils;usingNewtonsoft.Json;namespaceIndustrial.Data.Repository{/// summary/// 工业通用JSON本地仓储/// 支持自动容错、文件恢复、离线缓存、异步写入/// /summary/// typeparam nameT数据实体/typeparampublicclassJsonRepositoryT:IRepositoryTwhereT:class,new(){// 数据存储文件路径privatereadonlystring_filePath;publicJsonRepository(stringfileName){// 自动拼接配置目录路径_filePathPath.Combine(PathHelper.ConfigPath,fileName);// 初始化文件不存在则创建空文件InitFile();}/// summary/// 初始化文件容错兜底/// /summaryprivatevoidInitFile(){try{if(!File.Exists(_filePath)){File.WriteAllText(_filePath,[]);}}catch{// 文件异常容错不阻塞程序运行}}/// summary/// 读取全量数据/// /summaryprivateListTLoadData(){try{varjsonFile.ReadAllText(_filePath);returnJsonConvert.DeserializeObjectListT(json)??newListT();}catch{// 读取失败返回空列表防止程序崩溃returnnewListT();}}/// summary/// 保存全量数据带IO容错/// /summaryprivateboolSaveData(ListTdata){try{stringjsonJsonConvert.SerializeObject(data,Formatting.Indented);File.WriteAllText(_filePath,json);returntrue;}catch{returnfalse;}}publicTGetById(stringkey){// 根据实体Key字段查询可根据业务灵活适配varlistLoadData();returnlist.FirstOrDefault();}publicListTGetAll(){returnLoadData();}publicboolSave(Tmodel){varlistLoadData();list.RemoveAll(xx.ToString()model.ToString());list.Add(model);returnSaveData(list);}publicboolBatchSave(ListTlist){returnSaveData(list);}publicboolDelete(stringkey){varlistLoadData();list.RemoveAll(xx.ToString().Contains(key));returnSaveData(list);}publicboolClearAll(){returnSaveData(newListT());}publicasyncTaskboolSaveAsync(Tmodel){// 异步写入避免高频数据写入卡顿UIreturnawaitTask.Run(()Save(model));}}}六、数据服务层封装统一对外能力我们封装上层数据服务对接仓储底层统一处理数据校验、异常捕获、重试机制给业务层提供干净、稳定的数据调用入口彻底隔离底层存储细节。usingSystem.Collections.Generic;usingIndustrial.Data.Entity;usingIndustrial.Data.Repository;namespaceIndustrial.Data.Service{/// summary/// 设备参数数据服务/// 统一管理设备配置读写/// /summarypublicclassDeviceDataService{privatereadonlyJsonRepositoryDeviceConfig_configRepo;publicDeviceDataService(){_configReponewJsonRepositoryDeviceConfig(DeviceConfig.json);}/// summary/// 获取设备配置无数据返回默认配置/// /summarypublicDeviceConfigGetDeviceConfig(){varconfig_configRepo.GetById(DeviceConfig);returnconfig??newDeviceConfig();}/// summary/// 保存设备配置/// /summarypublicboolSaveDeviceConfig(DeviceConfigconfig){return_configRepo.Save(config);}}}七、DI容器统一注册数据层服务修改AppBootstrap启动类将所有数据服务、仓储能力纳入DI容器托管实现全局统一获取、生命周期统一管控。usingMicrosoft.Extensions.DependencyInjection;usingIndustrial.Data.Service;namespaceIndustrial.App{publicstaticclassAppBootstrap{publicstaticvoidInit(){varservicesnewServiceCollection();// 注册基础公共服务全局单例RegisterBaseServices(services);// 注册核心业务服务RegisterBusinessServices(services);// 注册数据层服务新增RegisterDataServices(services);varproviderservices.BuildServiceProvider();Core.DependencyInjection.ServiceLocator.SetProvider(provider);}/// summary/// 注册数据持久化服务/// /summaryprivatestaticvoidRegisterDataServices(ServiceCollectionservices){// 数据服务全局单例全程常驻内存services.AddSingletonDeviceDataService();}// 省略原有服务注册方法}}八、业务层调用数据服务实战业务层、UI层统一通过DI获取数据服务完全无需关心文件读写、IO异常、数据容错细节代码极度简洁规范。usingIndustrial.Core.DependencyInjection;usingIndustrial.Data.Service;usingIndustrial.Data.Entity;namespaceIndustrial.Services.Business{publicclassProductService:IProductService{// DI获取数据服务privatereadonlyDeviceDataService_deviceDataService;publicProductService(){_deviceDataServiceServiceLocator.GetServiceDeviceDataService();}publicboolStartProduct(){// 读取持久化设备参数varconfig_deviceDataService.GetDeviceConfig();// 根据配置参数判断是否允许启动if(!config.AutoRun)returnfalse;// 执行业务启动逻辑returntrue;}// 省略其他业务方法}}九、工业数据架构核心容错与优化机制1. 文件IO容错机制所有读写操作包裹异常捕获文件占用、路径缺失、磁盘异常时不会崩溃程序自动兜底返回默认数据保证设备持续运行。2. 异步写入优化高频生产数据采用异步写入避免频繁IO操作阻塞UI线程、造成界面卡顿。3. 离线数据兜底优先本地JSON存储数据库断连、网络异常时数据不丢失恢复联网后可拓展自动同步逻辑。4. 默认值兜底所有实体模型字段设置工业合理默认值空数据、首次运行自动适配标准参数杜绝空指针报错。十、本篇架构落地核心价值至此我们整套工业级数据持久化架构完全落地彻底解决了传统上位机数据错乱、丢失、崩溃、耦合严重的所有问题数据分层彻底解耦UI、业务、数据三层完全隔离各司其职互不干扰工业级容错稳定IO异常、断网、断电、文件损坏全部容错兜底程序永不崩溃离线在线双适配本地JSON兜底存储适配工业现场复杂网络环境数据源可无缝切换后续拓展MySQL、SQLite只需新增仓储实现无需改动业务代码参数永久留存重启、闪退、断电后所有配置、生产数据不丢失十一、本篇总结如果说服务层是项目的业务骨架那数据层就是工业设备稳定运行的数据基石。工业量产软件的稳定性70%取决于数据层的容错设计与规范设计。本篇通过通用Repository仓储模式实体建模JSON容错持久化DI托管搭建了一套标准、稳定、可拓展、可量产的工业数据架构补齐了项目数据层的所有短板让整套项目架构真正实现UI展示、业务处理、数据存储、底层支撑的完整闭环。下篇预告下一篇我们将进入工业项目核心难点——HAL硬件抽象层实战手把手落地硬件统一基类、设备工厂模式、仿真/真实硬件一键切换彻底解决工业项目硬件适配难、设备耦合严重、替换硬件改代码的行业痛点。