ConfigService.cs 72 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716
  1. using Cognex.VisionPro;
  2. using Cognex.VisionPro.ToolBlock;
  3. using SqlSugar;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Collections.ObjectModel;
  7. using System.Globalization;
  8. using System.IO;
  9. using System.Linq;
  10. using System.Threading;
  11. using System.Threading.Tasks;
  12. using TeamAAS_VP.Core;
  13. using TeamAAS_VP.Data; // for ISystemDatabaseService (if used)
  14. using TeamAAS_VP.Enums;
  15. using TeamAAS_VP.Interfaces;
  16. using TeamAAS_VP.Models;
  17. using TeamAAS_VP.Models.Calibration;
  18. using TeamAAS_VP.Models.Feeder;
  19. using TeamAAS_VP.Models.Lights;
  20. using TeamAAS_VP.Models.PLC;
  21. using TeamAAS_VP.Models.Scanner;
  22. using TeamAAS_VP.Models.ScrewDriver;
  23. using TeamAAS_VP.Resources.Languages;
  24. using WPFLocalizeExtension.Engine;
  25. namespace TeamAAS_VP.Services
  26. {
  27. /// <summary>
  28. /// 配置参数服务实现类。
  29. /// 线程安全:内部使用私有锁字段 <see cref="_sync"/> 来保护对内存集合的并发访问。
  30. /// 持久化:对集合的修改会写回到对应的配置文件(路径由内部静态类 <see cref="ConfigPaths"/> 定义)。
  31. /// </summary>
  32. public class ConfigService : IConfigService
  33. {
  34. private static class ConfigPaths
  35. {
  36. // 将路径集中管理于本类,当前使用现有 FilePath 值以保持兼容
  37. public static readonly string CamerasConfigurationPath = "..//Config//CameraConfiguration.cfg";
  38. public static readonly string RobotsConfigurationPath = "..//Config//RobotsConfiguration.cfg";
  39. public static readonly string ScannersConfigurationPath = "..//Config//ScannersConfiguration.cfg";
  40. public static readonly string FeedersConfigurationPath = "..//Config//FeedersConfiguration.cfg";
  41. public static readonly string PlcConfigurationPath = "..//Config//PlcConfiguration.cfg";
  42. public static readonly string BgTcpIpConfigurationPath = "..//Config//BgTcpIpConfiguration.cfg";
  43. public static readonly string BgModbusTcpConfigurationPath = "..//Config//BgModbusTcpConfiguration.cfg";
  44. public static readonly string SystemConfigurationPath = "..//Config//SystemConfiguration.cfg";
  45. public static readonly string DeviceInfoConfigurationPath = "..//Config//DeviceInfo.cfg";
  46. // Feeder清料任务配置路径
  47. public static readonly string FeederClearanceTasksConfigurationPath = "..//Config//FeederClearanceTasksConfiguration.cfg";
  48. // 光源控制器配置路径
  49. public static readonly string LightControllersConfigurationPath = "..//Config//LightControllersConfiguration.cfg";
  50. // 电批配置路径(单设备)
  51. public static readonly string ScrewDriverConfigurationPath = "..//Config//ScrewDriverConfiguration.cfg";
  52. // 螺丝供料器(物料)配置路径
  53. public static readonly string ScrewFeedersConfigurationPath = "..//Config//ScrewFeedersConfiguration.cfg";
  54. // 刷卡器配置路径
  55. public static readonly string CardReaderConfigurationPath = "..//Config//CardReaderConfiguration.cfg";
  56. }
  57. private readonly object _sync = new object();
  58. private ObservableCollection<CameraInfo> Cameras { get; set; }
  59. private ObservableCollection<RobotInfo> Robots { get; set; }
  60. private ObservableCollection<ScannerInfo> Scanners { get; set; }
  61. private ObservableCollection<FeederInfo> Feeders { get; set; }
  62. // 螺丝供料器(物料)集合
  63. private ObservableCollection<ScrewFeederInfo> ScrewFeeders { get; set; }
  64. private ObservableCollection<PlcInfo> Plcs { get; set; }
  65. private BgTcpIP BgCommunicate { get; set; }
  66. private BgModbusTcp BgModbusCommunicate { get; set; }
  67. private ObservableCollection<FeederClearWork> FeederClearanceTasks { get; set; }
  68. // 光源控制器配置
  69. private ObservableCollection<LightControllerConfig> LightControllers { get; set; }
  70. private PlcAddressConfig PlcAddressConfig { get; set; }
  71. // 单个电批配置
  72. private TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig _screwDriverConfig;
  73. public TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig ScrewDriverConfig { get { lock (_sync) { return _screwDriverConfig; } } }
  74. private ISystemDatabaseService _systemDatabaseService;
  75. // 刷卡器配置
  76. private SerialPortConfig _cardReaderConfig;
  77. // Device info
  78. private DeviceInfo _deviceInfo;
  79. // Device info - 支持多设备
  80. private List<DeviceInfo> _deviceInfoList;
  81. /// <summary>
  82. /// 注入系统数据库服务(可选),用于记录螺丝批次变更等记录。
  83. /// </summary>
  84. /// <param name="svc"></param>
  85. public void SetSystemDatabaseService(ISystemDatabaseService svc)
  86. {
  87. lock (_sync)
  88. {
  89. _systemDatabaseService = svc;
  90. }
  91. }
  92. /// <summary>
  93. /// 将螺丝供料器批次变更记录写入数据库(若已注入 ISystemDatabaseService)。
  94. /// </summary>
  95. public async System.Threading.Tasks.Task RecordScrewFeederBatchAsync(ScrewFeederBatchRecord record)
  96. {
  97. if (record == null) throw new ArgumentNullException(nameof(record));
  98. try
  99. {
  100. if (_systemDatabaseService != null)
  101. {
  102. await _systemDatabaseService.RecordScrewFeederBatchAsync(record);
  103. }
  104. }
  105. catch
  106. {
  107. // 忽略数据库写入错误,记录可添加日志
  108. }
  109. }
  110. /// <summary>
  111. /// 初始化一个新的 <see cref="ConfigService"/> 实例。
  112. /// 构造函数不会自动加载配置文件(避免在构造期间进行 I/O 操作);可调用 <see cref="LoadAll"/> 或 <see cref="LoadAllAsync"/> 显式加载。
  113. /// </summary>
  114. public ConfigService()
  115. {
  116. //LoadAll();
  117. }
  118. /// <summary>
  119. /// 同步加载所有配置文件至内存(若对应文件不存在,将创建默认空集合/对象并写入文件)。
  120. /// 线程安全:方法内部对共享资源使用 <see cref="_sync"/> 加锁。
  121. /// </summary>
  122. public void LoadAll()
  123. {
  124. lock (_sync)
  125. {
  126. // 读取各配置,如果文件不存在,则保持 DeviceConfig 默认值
  127. if (File.Exists(ConfigPaths.CamerasConfigurationPath))
  128. {
  129. Cameras = FileHelper.ReadJsonFile<ObservableCollection<CameraInfo>>(ConfigPaths.CamerasConfigurationPath);
  130. foreach (var item in Cameras)
  131. {
  132. if (item.DisplatConfigs == null)
  133. {
  134. item.DisplatConfigs = new ObservableCollection<DisplayConfig>();
  135. item.DisplatConfigs.Add(new DisplayConfig(0,item.CameraName));
  136. }
  137. }
  138. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  139. }
  140. else
  141. {
  142. Cameras = new ObservableCollection<CameraInfo>();
  143. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  144. }
  145. if (File.Exists(ConfigPaths.RobotsConfigurationPath))
  146. Robots = FileHelper.ReadJsonFile<ObservableCollection<RobotInfo>>(ConfigPaths.RobotsConfigurationPath);
  147. else
  148. {
  149. Robots = new ObservableCollection<RobotInfo>();
  150. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  151. }
  152. if (File.Exists(ConfigPaths.ScannersConfigurationPath))
  153. Scanners = FileHelper.ReadJsonFile<ObservableCollection<ScannerInfo>>(ConfigPaths.ScannersConfigurationPath);
  154. else
  155. {
  156. Scanners = new ObservableCollection<ScannerInfo>();
  157. FileHelper.WriteJsonFile(Scanners, ConfigPaths.ScannersConfigurationPath);
  158. }
  159. if (File.Exists(ConfigPaths.FeedersConfigurationPath))
  160. Feeders = FileHelper.ReadJsonFile<ObservableCollection<FeederInfo>>(ConfigPaths.FeedersConfigurationPath);
  161. else
  162. {
  163. Feeders = new ObservableCollection<FeederInfo>();
  164. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  165. }
  166. // load screw feeders (material) configuration
  167. if (File.Exists(ConfigPaths.ScrewFeedersConfigurationPath))
  168. ScrewFeeders = FileHelper.ReadJsonFile<ObservableCollection<ScrewFeederInfo>>(ConfigPaths.ScrewFeedersConfigurationPath);
  169. else
  170. {
  171. ScrewFeeders = new ObservableCollection<ScrewFeederInfo>();
  172. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  173. }
  174. if (File.Exists(ConfigPaths.PlcConfigurationPath))
  175. Plcs = FileHelper.ReadJsonFile<ObservableCollection<PlcInfo>>(ConfigPaths.PlcConfigurationPath);
  176. else
  177. {
  178. Plcs = new ObservableCollection<PlcInfo>();
  179. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  180. }
  181. if (File.Exists(ConfigPaths.BgTcpIpConfigurationPath))
  182. BgCommunicate = FileHelper.ReadJsonFile<BgTcpIP>(ConfigPaths.BgTcpIpConfigurationPath);
  183. else
  184. {
  185. BgCommunicate = new BgTcpIP();
  186. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  187. }
  188. if (File.Exists(ConfigPaths.BgModbusTcpConfigurationPath))
  189. BgModbusCommunicate = FileHelper.ReadJsonFile<BgModbusTcp>(ConfigPaths.BgModbusTcpConfigurationPath);
  190. else
  191. {
  192. BgModbusCommunicate = new BgModbusTcp();
  193. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  194. }
  195. if (!File.Exists(ConfigPaths.FeederClearanceTasksConfigurationPath))
  196. {
  197. FeederClearanceTasks = new ObservableCollection<FeederClearWork>();
  198. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  199. }
  200. else
  201. {
  202. // 读取 Feeder清料任务 配置
  203. FeederClearanceTasks = FileHelper.ReadJsonFile<ObservableCollection<FeederClearWork>>(ConfigPaths.FeederClearanceTasksConfigurationPath);
  204. }
  205. // 读取光源控制器配置
  206. if (!File.Exists(ConfigPaths.LightControllersConfigurationPath))
  207. {
  208. LightControllers = new ObservableCollection<LightControllerConfig>();
  209. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  210. }
  211. else
  212. {
  213. LightControllers = FileHelper.ReadJsonFile<ObservableCollection<LightControllerConfig>>(ConfigPaths.LightControllersConfigurationPath);
  214. }
  215. // load plc addresses
  216. var plcAddressPath = "..//Config//PlcAddressConfiguration.cfg";
  217. if (File.Exists(plcAddressPath))
  218. PlcAddressConfig = FileHelper.ReadJsonFile<PlcAddressConfig>(plcAddressPath);
  219. else
  220. {
  221. PlcAddressConfig = new PlcAddressConfig();
  222. PlcAddressConfig.SetDefaultValue();
  223. FileHelper.WriteJsonFile(PlcAddressConfig, plcAddressPath);
  224. }
  225. // load screw driver config (single device)
  226. if (File.Exists(ConfigPaths.ScrewDriverConfigurationPath))
  227. _screwDriverConfig = FileHelper.ReadJsonFile<TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig>(ConfigPaths.ScrewDriverConfigurationPath);
  228. else
  229. {
  230. _screwDriverConfig = new TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig();
  231. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  232. }
  233. // load card reader configuration
  234. if (File.Exists(ConfigPaths.CardReaderConfigurationPath))
  235. _cardReaderConfig = FileHelper.ReadJsonFile<SerialPortConfig>(ConfigPaths.CardReaderConfigurationPath);
  236. else
  237. {
  238. _cardReaderConfig = new SerialPortConfig();
  239. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  240. }
  241. // load device info list (支持多设备)
  242. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  243. {
  244. try
  245. {
  246. // 尝试作为列表读取
  247. _deviceInfoList = FileHelper.ReadJsonFile<List<DeviceInfo>>(ConfigPaths.DeviceInfoConfigurationPath);
  248. }
  249. catch
  250. {
  251. // 兼容旧版单个 DeviceInfo,将其转换为列表
  252. var singleDevice = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  253. if (singleDevice != null)
  254. {
  255. singleDevice.DeviceNo = 0;
  256. _deviceInfoList = new List<DeviceInfo> { singleDevice };
  257. }
  258. else
  259. {
  260. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  261. }
  262. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  263. }
  264. }
  265. else
  266. {
  267. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  268. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  269. }
  270. }
  271. }
  272. /// <summary>
  273. /// 异步执行 <see cref="LoadAll"/> 操作。
  274. /// </summary>
  275. /// <returns>表示异步加载操作的任务。</returns>
  276. public Task LoadAllAsync()
  277. {
  278. return Task.Run(() => LoadAll());
  279. }
  280. /// <summary>
  281. /// 将内存中的所有配置写回到对应配置文件。
  282. /// 线程安全:方法内部对写入操作使用 <see cref="_sync"/> 加锁。
  283. /// </summary>
  284. public void SaveAll()
  285. {
  286. lock (_sync)
  287. {
  288. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  289. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  290. FileHelper.WriteJsonFile(Scanners, ConfigPaths.ScannersConfigurationPath);
  291. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  292. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  293. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  294. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  295. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.ScrewDriverConfigurationPath);
  296. // save screw driver config
  297. if (_screwDriverConfig != null)
  298. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  299. // save screw feeders
  300. if (ScrewFeeders != null)
  301. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  302. // save plc addresses
  303. //FileHelper.WriteJsonFile(PlcAddressConfig, "..//Config//PlcAddressConfiguration.cfg");
  304. // save card reader config
  305. if (_cardReaderConfig != null)
  306. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  307. // save device info
  308. if (_deviceInfo != null)
  309. FileHelper.WriteJsonFile(_deviceInfo, ConfigPaths.DeviceInfoConfigurationPath);
  310. }
  311. }
  312. /// <summary>
  313. /// 异步执行 <see cref="SaveAll"/> 操作。
  314. /// </summary>
  315. /// <returns>表示异步保存操作的任务。</returns>
  316. public Task SaveAllAsync()
  317. {
  318. return Task.Run(() => SaveAll());
  319. }
  320. #region Cameras
  321. /// <summary>
  322. /// 获取所有相机配置的只读集合。
  323. /// 线程安全:在内部加锁以保证并发读取的一致性。
  324. /// </summary>
  325. /// <returns>相机配置的只读集合。</returns>
  326. public IReadOnlyCollection<CameraInfo> GetAllCameras()
  327. {
  328. lock (_sync) { return Cameras.ToList().AsReadOnly(); }
  329. }
  330. /// <summary>
  331. /// 根据标识获取单个相机配置信息。
  332. /// </summary>
  333. /// <param name="id">相机的 Guid 标识。</param>
  334. /// <returns>找到则返回对应的 <see cref="CameraInfo"/>,否则返回 <c>null</c>。</returns>
  335. public CameraInfo GetCamera(Guid id)
  336. {
  337. lock (_sync) { return Cameras.FirstOrDefault(c => c.Id == id); }
  338. }
  339. /// <summary>
  340. /// 新增或更新相机配置。
  341. /// - 若传入 <paramref name="camera"/> 为 <c>null</c> 返回 <c>null</c>。
  342. /// - 若 Id 已存在则替换;否则追加并设置连续的 CameraNo 编号。
  343. /// 方法结束后会将相机集合持久化到配置文件。
  344. /// </summary>
  345. /// <param name="camera">要添加或更新的相机配置。</param>
  346. /// <returns>已添加或更新的 <see cref="CameraInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  347. public CameraInfo AddOrUpdateCamera(CameraInfo camera)
  348. {
  349. if (camera == null) return null;
  350. lock (_sync)
  351. {
  352. var exist = Cameras.FirstOrDefault(c => c.Id == camera.Id);
  353. if (exist != null)
  354. {
  355. var idx = Cameras.IndexOf(exist);
  356. Cameras[idx] = camera;
  357. if (Cameras[idx].DisplatConfigs == null)
  358. {
  359. Cameras[idx].DisplatConfigs = new ObservableCollection<DisplayConfig>();
  360. Cameras[idx].DisplatConfigs.Add(new DisplayConfig(0, Cameras[idx].CameraName));
  361. }
  362. }
  363. else
  364. {
  365. camera.CameraNo = Cameras.Count + 1;
  366. if (camera.DisplatConfigs == null)
  367. {
  368. camera.DisplatConfigs = new ObservableCollection<DisplayConfig>();
  369. camera.DisplatConfigs.Add(new DisplayConfig(0, camera.CameraName));
  370. }
  371. Cameras.Add(camera);
  372. }
  373. }
  374. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  375. return camera;
  376. }
  377. /// <summary>
  378. /// 根据标识移除相机配置并重新编号剩余相机的 CameraNo。
  379. /// 方法结束后会将相机集合持久化到配置文件。
  380. /// </summary>
  381. /// <param name="id">要移除的相机 Guid。</param>
  382. /// <returns>若找到并成功移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  383. public bool RemoveCamera(Guid id)
  384. {
  385. bool result = false;
  386. lock (_sync)
  387. {
  388. var exist = Cameras.FirstOrDefault(c => c.Id == id);
  389. if (exist != null) result = Cameras.Remove(exist);
  390. //重新编号
  391. int no = 1;
  392. //对所有相机按CameraNo排序
  393. var sortedCameras = Cameras.OrderBy(c => c.CameraNo).ToList();
  394. foreach (var cam in sortedCameras)
  395. {
  396. cam.CameraNo = no;
  397. no++;
  398. }
  399. Cameras.Clear();
  400. foreach (var cam in sortedCameras)
  401. {
  402. Cameras.Add(cam);
  403. }
  404. }
  405. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  406. return result;
  407. }
  408. /// <summary>
  409. /// 检查是否包含指定 Id 的相机配置。
  410. /// </summary>
  411. /// <param name="id">相机的 Guid。</param>
  412. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  413. public bool ContainsCamera(Guid id) { lock (_sync) { return Cameras.Any(c => c.Id == id); } }
  414. #endregion
  415. #region Robots
  416. /// <summary>
  417. /// 获取所有机器人配置的只读集合。
  418. /// </summary>
  419. /// <returns>机器人配置的只读集合。</returns>
  420. public IReadOnlyCollection<RobotInfo> GetAllRobots() { lock (_sync) { return Robots.ToList().AsReadOnly(); } }
  421. /// <summary>
  422. /// 根据标识获取单个机器人配置。
  423. /// </summary>
  424. /// <param name="id">机器人的 Guid 标识。</param>
  425. /// <returns>找到则返回对应的 <see cref="RobotInfo"/>,否则返回 <c>null</c>。</returns>
  426. public RobotInfo GetRobot(Guid id) { lock (_sync) { return Robots.FirstOrDefault(r => r.Id == id); } }
  427. /// <summary>
  428. /// 新增或更新机器人配置,操作后持久化至配置文件。
  429. /// 新增时为机器人分配连续的 RobotNo 编号。
  430. /// </summary>
  431. /// <param name="robot">要添加或更新的机器人配置。</param>
  432. /// <returns>已添加或更新的 <see cref="RobotInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  433. public RobotInfo AddOrUpdateRobot(RobotInfo robot)
  434. {
  435. if (robot == null) return null;
  436. lock (_sync)
  437. {
  438. var exist = Robots.FirstOrDefault(r => r.Id == robot.Id);
  439. if (exist != null)
  440. {
  441. var idx = Robots.IndexOf(exist);
  442. Robots[idx] = robot;
  443. }
  444. else
  445. {
  446. robot.RobotNo = Robots.Count + 1;
  447. Robots.Add(robot);
  448. }
  449. }
  450. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  451. return robot;
  452. }
  453. /// <summary>
  454. /// 根据标识移除机器人配置并重新编号剩余机器人。
  455. /// 操作后持久化配置文件。
  456. /// </summary>
  457. /// <param name="id">要移除的机器人 Guid。</param>
  458. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  459. public bool RemoveRobot(Guid id)
  460. {
  461. bool result = false;
  462. lock (_sync)
  463. {
  464. var e = Robots.FirstOrDefault(r => r.Id == id);
  465. if (e != null)
  466. result = Robots.Remove(e);
  467. //重新编号
  468. int no = 1;
  469. //对所有机器人按RobotNo排序
  470. var sortedRobots = Robots.OrderBy(r => r.RobotNo).ToList();
  471. foreach (var r in sortedRobots)
  472. {
  473. r.RobotNo = no;
  474. no++;
  475. }
  476. Robots.Clear();
  477. foreach (var r in sortedRobots)
  478. {
  479. Robots.Add(r);
  480. }
  481. }
  482. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  483. return result;
  484. }
  485. /// <summary>
  486. /// 判断是否包含指定 Id 的机器人配置。
  487. /// </summary>
  488. /// <param name="id">机器人的 Guid。</param>
  489. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  490. public bool ContainsRobot(Guid id) { lock (_sync) { return Robots.Any(r => r.Id == id); } }
  491. /// <summary>
  492. /// 修改指定机器人 Id的步进距离并持久化机器人配置。
  493. /// </summary>
  494. /// <param name="id">机器人唯一标识符。</param>
  495. /// <param name="stepDistance">步进距离。</param>
  496. /// <returns>更新成功返回 <c>true</c>,找不到机器人返回 <c>false</c>。</returns>
  497. public bool UpdateRobotStepDistance(Guid id, double stepDistance)
  498. {
  499. lock (_sync)
  500. {
  501. var robot = Robots.FirstOrDefault(r => r.Id == id);
  502. if (robot != null)
  503. {
  504. robot.StepDistance = stepDistance;
  505. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  506. return true;
  507. }
  508. else
  509. {
  510. return false;
  511. }
  512. }
  513. }
  514. /// <summary>
  515. /// 获取指定机器人 Id 的步进距离。
  516. /// </summary>
  517. /// <param name="id">机器人 Guid。</param>
  518. /// <returns>若找到则返回对应的步进距离,否则返回默认值 1.0。</returns>
  519. public double GetRobotStepDistance(Guid id)
  520. {
  521. lock (_sync)
  522. {
  523. var robot = Robots.FirstOrDefault(r => r.Id == id);
  524. if (robot != null)
  525. {
  526. return robot.StepDistance;
  527. }
  528. else
  529. {
  530. return 1.0;
  531. }
  532. }
  533. }
  534. #endregion
  535. #region Scanners
  536. /// <summary>
  537. /// 获取所有扫码枪配置的只读集合。
  538. /// </summary>
  539. /// <returns>扫码枪配置的只读集合。</returns>
  540. public IReadOnlyCollection<ScannerInfo> GetAllScanners() { lock (_sync) { return Scanners.ToList().AsReadOnly(); } }
  541. /// <summary>
  542. /// 根据标识获取单个扫码枪配置。
  543. /// </summary>
  544. /// <param name="id">扫码枪的 Guid 标识。</param>
  545. /// <returns>找到则返回对应的 <see cref="ScannerInfo"/>,否则返回 <c>null</c>。</returns>
  546. public ScannerInfo GetScanner(Guid id) { lock (_sync) { return Scanners.FirstOrDefault(r => r.Id == id); } }
  547. /// <summary>
  548. /// 新增或更新扫码枪配置,操作后持久化至配置文件。
  549. /// 新增时为扫码枪分配连续的 ScannerNo 编号。
  550. /// </summary>
  551. /// <param name="scanner">要添加或更新的扫码枪配置。</param>
  552. /// <returns>已添加或更新的 <see cref="ScannerInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  553. public ScannerInfo AddOrUpdateScanner(ScannerInfo scanner)
  554. {
  555. if (scanner == null) return null;
  556. lock (_sync)
  557. {
  558. var exist = Scanners.FirstOrDefault(r => r.Id == scanner.Id);
  559. if (exist != null)
  560. {
  561. var idx = Scanners.IndexOf(exist);
  562. Scanners[idx] = scanner;
  563. }
  564. else
  565. {
  566. scanner.ScannerNo = Scanners.Count + 1;
  567. Scanners.Add(scanner);
  568. }
  569. }
  570. FileHelper.WriteJsonFile(Scanners, ConfigPaths.ScannersConfigurationPath);
  571. return scanner;
  572. }
  573. /// <summary>
  574. /// 根据标识移除扫码枪配置并重新编号剩余扫码枪。
  575. /// 操作后持久化配置文件。
  576. /// </summary>
  577. /// <param name="id">要移除的扫码枪 Guid。</param>
  578. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  579. public bool RemoveScanner(Guid id)
  580. {
  581. bool result = false;
  582. lock (_sync)
  583. {
  584. var e = Scanners.FirstOrDefault(r => r.Id == id);
  585. if (e != null)
  586. result = Scanners.Remove(e);
  587. //重新编号
  588. int no = 1;
  589. //对所有扫码枪按ScannerNo排序
  590. var sortedScanners = Scanners.OrderBy(r => r.ScannerNo).ToList();
  591. foreach (var r in sortedScanners)
  592. {
  593. r.ScannerNo = no;
  594. no++;
  595. }
  596. Scanners.Clear();
  597. foreach (var r in sortedScanners)
  598. {
  599. Scanners.Add(r);
  600. }
  601. }
  602. FileHelper.WriteJsonFile(Scanners, ConfigPaths.ScannersConfigurationPath);
  603. return result;
  604. }
  605. /// <summary>
  606. /// 判断是否包含指定 Id 的扫码枪配置。
  607. /// </summary>
  608. /// <param name="id">扫码枪的 Guid。</param>
  609. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  610. public bool ContainsScanner(Guid id) { lock (_sync) { return Scanners.Any(r => r.Id == id); } }
  611. #endregion
  612. #region Feeders
  613. /// <summary>
  614. /// 获取所有供料器配置的只读集合。
  615. /// </summary>
  616. /// <returns>供料器配置的只读集合。</returns>
  617. public IReadOnlyCollection<FeederInfo> GetAllFeeders() { lock (_sync) { return Feeders.ToList().AsReadOnly(); } }
  618. /// <summary>
  619. /// 根据标识获取单个供料器配置。
  620. /// </summary>
  621. /// <param name="id">供料器的 Guid 标识。</param>
  622. /// <returns>找到则返回对应的 <see cref="FeederInfo"/>,否则返回 <c>null</c>。</returns>
  623. public FeederInfo GetFeeder(Guid id) { lock (_sync) { return Feeders.FirstOrDefault(f => f.Id == id); } }
  624. /// <summary>
  625. /// 新增或更新供料器配置,操作后持久化至配置文件。
  626. /// 新增时为供料器分配连续的 FeederNo 编号。
  627. /// </summary>
  628. /// <param name="feeder">要添加或更新的供料器配置。</param>
  629. /// <returns>已添加或更新的 <see cref="FeederInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  630. public FeederInfo AddOrUpdateFeeder(FeederInfo feeder)
  631. {
  632. if (feeder == null) return null;
  633. lock (_sync)
  634. {
  635. var exist = Feeders.FirstOrDefault(f => f.Id == feeder.Id);
  636. if (exist != null)
  637. {
  638. var idx = Feeders.IndexOf(exist);
  639. Feeders[idx] = feeder;
  640. }
  641. else
  642. {
  643. feeder.FeederNo = Feeders.Count + 1;
  644. Feeders.Add(feeder);
  645. }
  646. }
  647. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  648. return feeder;
  649. }
  650. /// <summary>
  651. /// 根据标识移除供料器配置并重新编号剩余供料器。
  652. /// 操作后持久化配置文件。
  653. /// </summary>
  654. /// <param name="id">要移除的供料器 Guid。</param>
  655. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  656. public bool RemoveFeeder(Guid id)
  657. {
  658. bool result = false;
  659. lock (_sync)
  660. {
  661. var e = Feeders.FirstOrDefault(f => f.Id == id);
  662. if (e != null) result = Feeders.Remove(e);
  663. //重新编号
  664. int no = 1;
  665. //对所有供料器按FeederNo排序
  666. var sortedFeeders = Feeders.OrderBy(f => f.FeederNo).ToList();
  667. foreach (var f in sortedFeeders)
  668. {
  669. f.FeederNo = no;
  670. no++;
  671. }
  672. Feeders.Clear();
  673. foreach (var f in sortedFeeders)
  674. {
  675. Feeders.Add(f);
  676. }
  677. }
  678. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  679. return result;
  680. }
  681. /// <summary>
  682. /// 判断是否包含指定 Id 的供料器配置。
  683. /// </summary>
  684. /// <param name="id">供料器 Guid。</param>
  685. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  686. public bool ContainsFeeder(Guid id) { lock (_sync) { return Feeders.Any(f => f.Id == id); } }
  687. #endregion
  688. #region PLC
  689. /// <summary>
  690. /// 获取所有 PLC 配置的只读集合。
  691. /// </summary>
  692. /// <returns>PLC 配置的只读集合。</returns>
  693. public IReadOnlyCollection<PlcInfo> GetAllPlcs() { lock (_sync) { return Plcs.ToList().AsReadOnly(); } }
  694. /// <summary>
  695. /// 根据标识获取单个 PLC 配置。
  696. /// </summary>
  697. /// <param name="id">PLC 的 Guid 标识。</param>
  698. /// <returns>匹配的 <see cref="PlcInfo"/> 实例,找不到返回 <c>null</c>。</returns>
  699. public PlcInfo GetPlc(Guid id) { lock (_sync) { return Plcs.FirstOrDefault(p => p.Id == id); } }
  700. /// <summary>
  701. /// 新增或更新 PLC 配置,操作后持久化至配置文件;新增时分配连续 PlcNo 编号。
  702. /// </summary>
  703. /// <param name="plc">要添加或更新的 PLC 配置。</param>
  704. /// <returns>已添加或更新的 <see cref="PlcInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  705. public PlcInfo AddOrUpdatePlc(PlcInfo plc)
  706. {
  707. if (plc == null) return null;
  708. lock (_sync)
  709. {
  710. var exist = Plcs.FirstOrDefault(p => p.Id == plc.Id);
  711. if (exist != null)
  712. {
  713. var idx = Plcs.IndexOf(exist);
  714. Plcs[idx] = plc;
  715. }
  716. else
  717. {
  718. plc.PlcNo = Plcs.Count + 1;
  719. Plcs.Add(plc);
  720. }
  721. }
  722. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  723. return plc;
  724. }
  725. /// <summary>
  726. /// 根据标识移除 PLC 配置并重新编号剩余 PLC。
  727. /// 操作后持久化配置文件。
  728. /// </summary>
  729. /// <param name="id">要移除的 PLC Guid。</param>
  730. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  731. public bool RemovePlc(Guid id)
  732. {
  733. bool result = false;
  734. lock (_sync)
  735. {
  736. var e = Plcs.FirstOrDefault(p => p.Id == id);
  737. if (e != null) result = Plcs.Remove(e);
  738. //重新编号
  739. int no = 1;
  740. //对所有PLC按PlcNo排序
  741. var sortedPlcs = Plcs.OrderBy(p => p.PlcNo).ToList();
  742. foreach (var p in sortedPlcs)
  743. {
  744. p.PlcNo = no;
  745. no++;
  746. }
  747. Plcs.Clear();
  748. foreach (var p in sortedPlcs)
  749. {
  750. Plcs.Add(p);
  751. }
  752. }
  753. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  754. return result;
  755. }
  756. /// <summary>
  757. /// 判断是否包含指定 Id 的 PLC 配置。
  758. /// </summary>
  759. /// <param name="id">PLC 的 Guid。</param>
  760. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  761. public bool ContainsPlc(Guid id) { lock (_sync) { return Plcs.Any(p => p.Id == id); } }
  762. #endregion
  763. #region BgTcp
  764. /// <summary>
  765. /// 获取 BG TCP/IP 通信配置(内存对象,可能为 null)。
  766. /// </summary>
  767. /// <returns>当前的 <see cref="BgTcpIP"/> 配置对象。</returns>
  768. public BgTcpIP GetBgTcp() { lock (_sync) { return BgCommunicate; } }
  769. /// <summary>
  770. /// 设置 BG TCP/IP 通信配置(仅更新内存对象,不会自动持久化)。
  771. /// 若需持久化请调用 <see cref="SaveBgTcp"/>。
  772. /// </summary>
  773. /// <param name="cfg">新的 <see cref="BgTcpIP"/> 配置对象。</param>
  774. public void SetBgTcp(BgTcpIP cfg) { lock (_sync) { BgCommunicate = cfg; } }
  775. /// <summary>
  776. /// 将当前内存中的 BG TCP/IP 配置持久化到配置文件。
  777. /// </summary>
  778. public void SaveBgTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath); } }
  779. #endregion
  780. #region BgModbus
  781. /// <summary>
  782. /// 获取 BG Modbus TCP 通信配置(内存对象)。
  783. /// </summary>
  784. /// <returns>当前的 <see cref="BgModbusTcp"/> 配置对象。</returns>
  785. public BgModbusTcp GetBgModbusTcp() { lock (_sync) { return BgModbusCommunicate; } }
  786. /// <summary>
  787. /// 设置 BG Modbus TCP 通信配置(仅更新内存对象,不会自动持久化)。
  788. /// </summary>
  789. /// <param name="cfg">新的 <see cref="BgModbusTcp"/> 配置对象。</param>
  790. public void SetBgModbusTcp(BgModbusTcp cfg) { lock (_sync) { BgModbusCommunicate = cfg; } }
  791. /// <summary>
  792. /// 将当前内存中的 BG Modbus TCP 配置持久化到配置文件。
  793. /// </summary>
  794. public void SaveBgModbusTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath); } }
  795. #endregion
  796. #region 系统参数
  797. /// <summary>
  798. /// 获取系统设置(从配置文件读取)。
  799. /// 线程安全:方法内部加锁以保证读取一致性。
  800. /// </summary>
  801. /// <returns>读取到的 <see cref="SystemConfiguration"/> 对象;若文件不存在则返回默认的新实例。</returns>
  802. public SystemConfiguration GetSystemConfiguration()
  803. {
  804. lock (_sync)
  805. {
  806. var config = new SystemConfiguration();
  807. if (File.Exists(ConfigPaths.SystemConfigurationPath))
  808. {
  809. config = FileHelper.ReadJsonFile<SystemConfiguration>(ConfigPaths.SystemConfigurationPath);
  810. }
  811. return config;
  812. }
  813. }
  814. /// <summary>
  815. /// 保存系统设置到配置文件(会覆盖现有文件)。
  816. /// </summary>
  817. /// <param name="systemConfiguration">要保存的系统配置对象。</param>
  818. public void SaveSystemConfiguration(SystemConfiguration systemConfiguration)
  819. {
  820. lock (_sync)
  821. {
  822. FileHelper.WriteJsonFile(systemConfiguration, ConfigPaths.SystemConfigurationPath);
  823. }
  824. }
  825. /// <summary>
  826. /// 获取当前语言
  827. /// </summary>
  828. /// <returns></returns>
  829. public Language GetCurrentLanguage()
  830. {
  831. lock (_sync)
  832. {
  833. var config = GetSystemConfiguration();
  834. return config.CurrentLanguage;
  835. }
  836. }
  837. /// <summary>
  838. /// 设置当前语言
  839. /// </summary>
  840. /// <param name="language"></param>
  841. public void SetCurrentLanguage(Language language)
  842. {
  843. lock (_sync)
  844. {
  845. var config = GetSystemConfiguration();
  846. config.CurrentLanguage = language;
  847. if (language == Enums.Language.ChineseSimplified)
  848. {
  849. var culture = new CultureInfo("zh-CN");
  850. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  851. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  852. LocalizeDictionary.Instance.Culture = culture;
  853. Lang.Culture = culture;
  854. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Microsoft YaHei");
  855. }
  856. else if (language == Enums.Language.ChineseTraditional)
  857. {
  858. var culture = new CultureInfo("zh-TW");
  859. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  860. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  861. LocalizeDictionary.Instance.Culture = culture;
  862. Lang.Culture = culture;
  863. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Microsoft YaHei");
  864. }
  865. else if (language == Enums.Language.English)
  866. {
  867. var culture = new CultureInfo("en");
  868. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  869. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  870. LocalizeDictionary.Instance.Culture = culture;
  871. Lang.Culture = culture;
  872. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Segoe UI");
  873. }
  874. else if (language == Enums.Language.Japanese)
  875. {
  876. var culture = new CultureInfo("ja-JP");
  877. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  878. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  879. LocalizeDictionary.Instance.Culture = culture;
  880. Lang.Culture = culture;
  881. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Segoe UI");
  882. }
  883. else if (language == Enums.Language.Vietnamese)
  884. {
  885. var culture = new CultureInfo("vi");
  886. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  887. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  888. LocalizeDictionary.Instance.Culture = culture;
  889. Lang.Culture = culture;
  890. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Segoe UI");
  891. }
  892. SaveSystemConfiguration(config);
  893. }
  894. }
  895. #endregion
  896. #region Feeder清料任务
  897. /// <summary>
  898. /// 获取所有清料任务的只读集合。
  899. /// </summary>
  900. /// <returns>清料任务的只读集合。</returns>
  901. public IReadOnlyCollection<FeederClearWork> GetAllClearanceTasks() { lock (_sync) { return FeederClearanceTasks.ToList().AsReadOnly(); } }
  902. /// <summary>
  903. /// 新增或更新清料任务,新增时为任务分配递增的 TaskCode,完成后持久化配置文件。
  904. /// </summary>
  905. /// <param name="task">要添加或更新的清料任务对象。</param>
  906. /// <returns>已添加或更新的 <see cref="FeederClearWork"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  907. public FeederClearWork AddOrUpdateClearanceTask(FeederClearWork task)
  908. {
  909. if (task == null) return null;
  910. lock (_sync)
  911. {
  912. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == task.Id);
  913. if (exist != null)
  914. {
  915. var idx = FeederClearanceTasks.IndexOf(exist);
  916. FeederClearanceTasks[idx] = task;
  917. }
  918. else
  919. {
  920. // 设置任务编号为当前最大编号加1
  921. task.TaskCode = FeederClearanceTasks.Count > 0 ? FeederClearanceTasks.Max(t => t.TaskCode) + 1 : 1;
  922. FeederClearanceTasks.Add(task);
  923. }
  924. }
  925. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  926. return task;
  927. }
  928. /// <summary>
  929. /// 根据标识移除清料任务并持久化配置文件。
  930. /// </summary>
  931. /// <param name="id">要移除的清料任务 Guid。</param>
  932. /// <returns>若找到并移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  933. public bool RemoveClearanceTask(Guid id)
  934. {
  935. lock (_sync)
  936. {
  937. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == id);
  938. if (exist != null)
  939. {
  940. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  941. return FeederClearanceTasks.Remove(exist);
  942. }
  943. else
  944. return false;
  945. }
  946. }
  947. /// <summary>
  948. /// 清除所有清料任务并持久化空集合到配置文件。
  949. /// </summary>
  950. public void ClearAllClearanceTasks()
  951. {
  952. lock (_sync)
  953. {
  954. FeederClearanceTasks.Clear();
  955. }
  956. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  957. }
  958. /// <summary>
  959. /// 判断是否包含指定 Id 的清料任务。
  960. /// </summary>
  961. /// <param name="id">清料任务 Guid。</param>
  962. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  963. public bool ContainsClearanceTask(Guid id)
  964. {
  965. lock (_sync) { return FeederClearanceTasks.Any(t => t.Id == id); }
  966. }
  967. /// <summary>
  968. /// 根据标识获取单个清料任务信息。
  969. /// </summary>
  970. /// <param name="id">清料任务 Guid。</param>
  971. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  972. public FeederClearWork GetClearanceTask(Guid id)
  973. {
  974. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.Id == id); }
  975. }
  976. /// <summary>
  977. /// 判断是否包含指定任务编号的清料任务。
  978. /// </summary>
  979. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  980. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  981. public bool ContainsClearanceTaskByNumber(int taskNumber)
  982. {
  983. lock (_sync) { return FeederClearanceTasks.Any(t => t.TaskCode == taskNumber); }
  984. }
  985. /// <summary>
  986. /// 根据任务编号获取单个清料任务信息。
  987. /// </summary>
  988. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  989. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  990. public FeederClearWork GetClearanceTaskByNumber(int taskNumber)
  991. {
  992. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.TaskCode == taskNumber); }
  993. }
  994. #endregion
  995. #region Light controllers and channels
  996. /// <summary>
  997. /// 获取所有光源控制器配置的只读集合。
  998. /// 线程安全:在内部使用 <see cref="_sync"/> 进行锁定以保证并发访问安全。
  999. /// </summary>
  1000. /// <returns>按当前内存中存储顺序返回的只读 <see cref="LightControllerConfig"/> 集合。</returns>
  1001. public IReadOnlyCollection<LightControllerConfig> GetAllLightControllers()
  1002. {
  1003. lock (_sync) { return LightControllers.ToList().AsReadOnly(); }
  1004. }
  1005. /// <summary>
  1006. /// 根据控制器标识获取单个光源控制器配置。
  1007. /// 线程安全:该方法对内存集合进行只读访问并在内部加锁。
  1008. /// </summary>
  1009. /// <param name="id">控制器的整数标识(Id)。</param>
  1010. /// <returns>匹配的 <see cref="LightControllerConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  1011. public LightControllerConfig GetLightController(int id)
  1012. {
  1013. lock (_sync) { return LightControllers.FirstOrDefault(c => c.Id == id); }
  1014. }
  1015. /// <summary>
  1016. /// 新增或更新光源控制器配置。
  1017. /// - 若 <paramref name="controller"/> 为 <c>null</c> 返回 <c>null</c>。
  1018. /// - 更新时以 Id 匹配现有项并替换。
  1019. /// - 新增时分配连续的控制器 Id,并为控制器内的每个通道分配全局通道编号(GlobalIndex)。
  1020. /// 线程安全:在内部使用 <see cref="_sync"/> 锁定集合。
  1021. /// </summary>
  1022. /// <param name="controller">要添加或更新的 <see cref="LightControllerConfig"/> 实例。</param>
  1023. /// <returns>已添加或更新的 <see cref="LightControllerConfig"/> 实例;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  1024. /// <exception cref="ArgumentException">当要添加/更新的控制器名称与现有其他控制器重复时抛出。</exception>
  1025. public LightControllerConfig AddOrUpdateLightController(LightControllerConfig controller)
  1026. {
  1027. if (controller == null) return null;
  1028. lock (_sync)
  1029. {
  1030. // 名称不得与其他控制器重复(同名但不同 Id 不允许)
  1031. if (LightControllers.Any(c => c.Name == controller.Name && c.Id != controller.Id))
  1032. throw new ArgumentException("Controller name must be unique");
  1033. var exist = LightControllers.FirstOrDefault(c => c.Id == controller.Id);
  1034. if (exist != null)
  1035. {
  1036. // 更新现有控制器(按索引替换)
  1037. var idx = LightControllers.IndexOf(exist);
  1038. LightControllers[idx] = controller;
  1039. }
  1040. else
  1041. {
  1042. // 新增控制器
  1043. // 分配控制器编号为当前最大 Id + 1(若集合为空则为 1)
  1044. controller.Id = LightControllers.Count > 0 ? LightControllers.Max(c => c.Id) + 1 : 1;
  1045. // 计算下一个全局通道索引:在所有已存在控制器的通道 GlobalIndex 上取最大值并加1
  1046. int nextGlobal = 0;
  1047. if (LightControllers.SelectMany(c => c.ChannelConfigs).Any())
  1048. {
  1049. nextGlobal = LightControllers.SelectMany(c => c.ChannelConfigs).Max(ch => ch.GlobalIndex) + 1;
  1050. }
  1051. // 遍历新增控制器的通道,若通道的 GlobalIndex 无效(<0)或与现有通道冲突,则重新分配
  1052. for (int i = 0; i < controller.ChannelConfigs.Count; i++)
  1053. {
  1054. var ch = controller.ChannelConfigs[i];
  1055. if (ch.GlobalIndex < 0 || LightControllers.SelectMany(c => c.ChannelConfigs).Any(existingCh => existingCh.GlobalIndex == ch.GlobalIndex))
  1056. {
  1057. ch.GlobalIndex = nextGlobal;
  1058. nextGlobal++;
  1059. }
  1060. }
  1061. LightControllers.Add(controller);
  1062. }
  1063. }
  1064. // 持久化更新后的光源控制器配置
  1065. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1066. return controller;
  1067. }
  1068. /// <summary>
  1069. /// 根据 Id 移除光源控制器配置并对剩余控制器重新编号(从 1 开始连续编号)。
  1070. /// 操作后持久化配置文件。
  1071. /// </summary>
  1072. /// <param name="id">要移除的控制器 Id。</param>
  1073. /// <returns>如果成功移除返回 <c>true</c>,否则返回 <c>false</c>(比如未找到该 Id)。</returns>
  1074. public bool RemoveLightController(int id)
  1075. {
  1076. bool result = false;
  1077. lock (_sync)
  1078. {
  1079. var e = LightControllers.FirstOrDefault(c => c.Id == id);
  1080. if (e != null)
  1081. result = LightControllers.Remove(e);
  1082. // 重新按 Id 排序并从 1 开始重新编号,以保持连续性
  1083. int no = 1;
  1084. var sorted = LightControllers.OrderBy(c => c.Id).ToList();
  1085. foreach (var c in sorted)
  1086. {
  1087. c.Id = no;
  1088. no++;
  1089. }
  1090. LightControllers.Clear();
  1091. foreach (var c in sorted)
  1092. {
  1093. LightControllers.Add(c);
  1094. }
  1095. }
  1096. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1097. return result;
  1098. }
  1099. /// <summary>
  1100. /// 判断是否包含指定 Id 的光源控制器。
  1101. /// </summary>
  1102. /// <param name="id">控制器 Id。</param>
  1103. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  1104. public bool ContainsLightController(int id) { lock (_sync) { return LightControllers.Any(c => c.Id == id); } }
  1105. /// <summary>
  1106. /// 获取所有光源通道的只读集合,按 GlobalIndex 升序返回。
  1107. /// </summary>
  1108. /// <returns>按 GlobalIndex 排序的 <see cref="ChannelConfig"/> 只读集合。</returns>
  1109. public IReadOnlyCollection<ChannelConfig> GetAllLightChannels()
  1110. {
  1111. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).OrderBy(ch => ch.GlobalIndex).ToList().AsReadOnly(); }
  1112. }
  1113. /// <summary>
  1114. /// 根据全局通道索引获取单个通道配置。
  1115. /// </summary>
  1116. /// <param name="globalIndex">通道的全局索引(GlobalIndex)。</param>
  1117. /// <returns>匹配的 <see cref="ChannelConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  1118. public ChannelConfig GetLightChannelByGlobalIndex(int globalIndex)
  1119. {
  1120. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(ch => ch.GlobalIndex == globalIndex); }
  1121. }
  1122. /// <summary>
  1123. /// 判断是否存在指定全局通道索引的通道配置。
  1124. /// </summary>
  1125. /// <param name="globalIndex">全局通道索引。</param>
  1126. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  1127. public bool ContainsLightChannelByGlobalIndex(int globalIndex)
  1128. {
  1129. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).Any(ch => ch.GlobalIndex == globalIndex); }
  1130. }
  1131. /// <summary>
  1132. /// 更新指定全局通道的默认亮度(DefaultBrightness),并持久化光源控制器配置。
  1133. /// </summary>
  1134. /// <param name="globalIndex">目标通道的全局索引(GlobalIndex)。</param>
  1135. /// <param name="brightness">要设置的亮度值。</param>
  1136. /// <returns>更新成功返回 <c>true</c>;找不到对应通道返回 <c>false</c>。</returns>
  1137. public bool UpdateChannelDefaultBrightness(int globalIndex, int brightness)
  1138. {
  1139. lock (_sync)
  1140. {
  1141. var ch = LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(x => x.GlobalIndex == globalIndex);
  1142. if (ch == null) return false;
  1143. ch.DefaultBrightness = brightness;
  1144. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1145. return true;
  1146. }
  1147. }
  1148. #endregion
  1149. #region Plc Addresses
  1150. public PlcAddressConfig GetPlcAddresses() { lock (_sync) { return PlcAddressConfig; } }
  1151. #endregion
  1152. #region ScrewDriver config (single device)
  1153. /// <summary>
  1154. /// 获取电批配置(单设备)。
  1155. /// </summary>
  1156. /// <returns>当前的 <see cref="ScrewDriverConfig"/>,若未加载则返回 null。</returns>
  1157. public ScrewDriverConfig GetScrewDriverConfig()
  1158. {
  1159. lock (_sync) { return _screwDriverConfig; }
  1160. }
  1161. /// <summary>
  1162. /// 设置并持久化电批配置(单设备)。
  1163. /// </summary>
  1164. /// <param name="cfg">新的配置对象,不能为空。</param>
  1165. public void SetScrewDriverConfig(ScrewDriverConfig cfg)
  1166. {
  1167. if (cfg == null) throw new ArgumentNullException(nameof(cfg));
  1168. lock (_sync)
  1169. {
  1170. _screwDriverConfig = cfg;
  1171. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  1172. }
  1173. }
  1174. /// <summary>
  1175. /// 仅将当前内存中的电批配置保存到文件。
  1176. /// </summary>
  1177. public void SaveScrewDriverConfig()
  1178. {
  1179. lock (_sync)
  1180. {
  1181. if (_screwDriverConfig != null)
  1182. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  1183. }
  1184. }
  1185. #endregion
  1186. #region Screw Feeders (material)
  1187. /// <summary>
  1188. /// 获取所有螺丝供料器配置的只读集合。
  1189. /// </summary>
  1190. public IReadOnlyCollection<ScrewFeederInfo> GetAllScrewFeeders() { lock (_sync) { return ScrewFeeders.ToList().AsReadOnly(); } }
  1191. /// <summary>
  1192. /// 根据 Id 获取单个螺丝供料器配置。
  1193. /// </summary>
  1194. public ScrewFeederInfo GetScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.FirstOrDefault(s => s.Id == id); } }
  1195. /// <summary>
  1196. /// 新增或更新螺丝供料器配置。
  1197. /// 新增时若未指定 FeederNumber 则分配为当前数量+1。
  1198. /// </summary>
  1199. public ScrewFeederInfo AddOrUpdateScrewFeeder(ScrewFeederInfo feeder)
  1200. {
  1201. if (feeder == null) return null;
  1202. lock (_sync)
  1203. {
  1204. var exist = ScrewFeeders.FirstOrDefault(f => f.Id == feeder.Id);
  1205. if (exist != null)
  1206. {
  1207. var idx = ScrewFeeders.IndexOf(exist);
  1208. ScrewFeeders[idx] = feeder;
  1209. }
  1210. else
  1211. {
  1212. if (feeder.FeederNumber <= 0) feeder.FeederNumber = ScrewFeeders.Count + 1;
  1213. ScrewFeeders.Add(feeder);
  1214. }
  1215. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1216. }
  1217. return feeder;
  1218. }
  1219. /// <summary>
  1220. /// 移除螺丝供料器配置。
  1221. /// </summary>
  1222. public bool RemoveScrewFeeder(Guid id)
  1223. {
  1224. bool result = false;
  1225. lock (_sync)
  1226. {
  1227. var e = ScrewFeeders.FirstOrDefault(s => s.Id == id);
  1228. if (e != null) result = ScrewFeeders.Remove(e);
  1229. }
  1230. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1231. return result;
  1232. }
  1233. public bool ContainsScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.Any(s => s.Id == id); } }
  1234. // event for low level alarm
  1235. public event Action<ScrewFeederInfo> ScrewFeederLowLevelAlarmTriggered;
  1236. /// <summary>
  1237. /// 获取指定供料器编号的剩余螺丝数量(找不到返回 -1)
  1238. /// </summary>
  1239. public int GetRemainingCountByFeederNumber(int feederNumber)
  1240. {
  1241. lock (_sync)
  1242. {
  1243. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1244. if (f == null) return -1;
  1245. return f.RemainingCount;
  1246. }
  1247. }
  1248. /// <summary>
  1249. /// 获取指定供料器编号的低量报警状态(找不到返回 false)
  1250. /// </summary>
  1251. public bool GetLowLevelAlarmStatusByFeederNumber(int feederNumber)
  1252. {
  1253. lock (_sync)
  1254. {
  1255. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1256. if (f == null) return false;
  1257. return f.IsLowLevelAlarmActive;
  1258. }
  1259. }
  1260. // helper: check and raise low level alarm when necessary
  1261. private void CheckAndTriggerLowLevelAlarm(ScrewFeederInfo f)
  1262. {
  1263. if (f == null) return;
  1264. if (f.LowLevelAlarmEnabled && f.RemainingCount <= f.LowLevelThreshold)
  1265. {
  1266. if (!f.IsLowLevelAlarmActive)
  1267. {
  1268. f.IsLowLevelAlarmActive = true;
  1269. try
  1270. {
  1271. ScrewFeederLowLevelAlarmTriggered?.Invoke(f.Clone());
  1272. }
  1273. catch { }
  1274. }
  1275. }
  1276. else
  1277. {
  1278. if (f.IsLowLevelAlarmActive)
  1279. {
  1280. f.IsLowLevelAlarmActive = false;
  1281. }
  1282. }
  1283. }
  1284. /// <summary>
  1285. /// 为指定供料器编号递减指定数量,若数量不足返回 false
  1286. /// </summary>
  1287. public bool DecrementScrewCountByFeederNumber(int feederNumber, int decrement = 1)
  1288. {
  1289. lock (_sync)
  1290. {
  1291. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1292. if (f == null) return false;
  1293. if (decrement <= 0) decrement = 1;
  1294. if (f.RemainingCount < decrement) return false;
  1295. f.RemainingCount -= decrement;
  1296. // check alarm
  1297. CheckAndTriggerLowLevelAlarm(f);
  1298. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1299. return true;
  1300. }
  1301. }
  1302. /// <summary>
  1303. /// 清除指定供料器编号的螺丝信息(批次号置空,剩余数量置0)
  1304. /// </summary>
  1305. public void ClearScrewFeederByNumber(int feederNumber)
  1306. {
  1307. lock (_sync)
  1308. {
  1309. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1310. if (f == null) return;
  1311. f.BatchNumber = string.Empty;
  1312. f.RemainingCount = 0;
  1313. // check alarm
  1314. CheckAndTriggerLowLevelAlarm(f);
  1315. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1316. }
  1317. }
  1318. /// <summary>
  1319. /// 为指定供料器编号设置批次号,并在原有剩余数量上增加一包(PackSize)
  1320. /// </summary>
  1321. public void SetBatchForFeederNumber(int feederNumber, string batchNumber)
  1322. {
  1323. if (string.IsNullOrWhiteSpace(batchNumber)) return;
  1324. // capture values under lock, then record to DB outside lock
  1325. ScrewFeederInfo target = null;
  1326. int remainingAfter = 0;
  1327. int packSize = 0;
  1328. string feederName = null;
  1329. lock (_sync)
  1330. {
  1331. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1332. if (f == null) return;
  1333. f.BatchNumber = batchNumber;
  1334. f.RemainingCount += Math.Max(0, f.PackSize);
  1335. // prepare capture values
  1336. target = f;
  1337. remainingAfter = f.RemainingCount;
  1338. packSize = f.PackSize;
  1339. feederName = f.Name;
  1340. // check alarm
  1341. CheckAndTriggerLowLevelAlarm(f);
  1342. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1343. }
  1344. try
  1345. {
  1346. var record = new ScrewFeederBatchRecord
  1347. {
  1348. BatchNumber = batchNumber,
  1349. PackSize = packSize,
  1350. ChangeTime = DateTime.UtcNow,
  1351. RemainingCount = remainingAfter,
  1352. FeederNumber = feederNumber,
  1353. FeederName = feederName
  1354. };
  1355. // try get operator name from system database service if available
  1356. try
  1357. {
  1358. var user = _systemDatabaseService?.GetCurrentUser();
  1359. if (user != null)
  1360. record.OperatorName = user.UserName;
  1361. }
  1362. catch
  1363. {
  1364. // ignore getting user failure
  1365. }
  1366. // fire-and-forget recording (ConfigService will forward to DB service if set)
  1367. _ = RecordScrewFeederBatchAsync(record);
  1368. }
  1369. catch
  1370. {
  1371. // ignore any error creating/recording the batch record
  1372. }
  1373. }
  1374. #endregion
  1375. #region 用户登录刷卡器
  1376. /// <summary>
  1377. /// 获取刷卡器配置
  1378. /// </summary>
  1379. /// <returns></returns>
  1380. public SerialPortConfig GetCardReaderConfig()
  1381. {
  1382. lock (_sync)
  1383. {
  1384. if (_cardReaderConfig != null)
  1385. return _cardReaderConfig;
  1386. if (File.Exists(ConfigPaths.CardReaderConfigurationPath))
  1387. {
  1388. try
  1389. {
  1390. _cardReaderConfig = FileHelper.ReadJsonFile<SerialPortConfig>(ConfigPaths.CardReaderConfigurationPath);
  1391. }
  1392. catch
  1393. {
  1394. // 若读取失败,创建默认配置并覆盖文件(与项目中其他配置策略一致)
  1395. _cardReaderConfig = new SerialPortConfig();
  1396. try { FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath); } catch { }
  1397. }
  1398. }
  1399. else
  1400. {
  1401. _cardReaderConfig = new SerialPortConfig();
  1402. try { FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath); } catch { }
  1403. }
  1404. return _cardReaderConfig;
  1405. }
  1406. }
  1407. /// <summary>
  1408. /// 保存刷卡器配置
  1409. /// </summary>
  1410. /// <param name="config"></param>
  1411. public void SaveCardReaderConfig(SerialPortConfig config)
  1412. {
  1413. if (config == null) return;
  1414. lock (_sync)
  1415. {
  1416. _cardReaderConfig = config;
  1417. try
  1418. {
  1419. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  1420. }
  1421. catch
  1422. {
  1423. // 忽略持久化错误(与项目中其它保存方法一致),可在需要时添加日志记录
  1424. }
  1425. }
  1426. }
  1427. #endregion
  1428. #region DeviceInfo
  1429. /// <summary>
  1430. /// 获取所有设备信息配置列表
  1431. /// </summary>
  1432. /// <returns>设备信息列表的只读集合</returns>
  1433. public IReadOnlyCollection<DeviceInfo> GetAllDeviceInfos()
  1434. {
  1435. lock (_sync)
  1436. {
  1437. if (_deviceInfoList == null)
  1438. {
  1439. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  1440. {
  1441. try
  1442. {
  1443. _deviceInfoList = FileHelper.ReadJsonFile<List<DeviceInfo>>(ConfigPaths.DeviceInfoConfigurationPath);
  1444. }
  1445. catch
  1446. {
  1447. // 兼容旧版单个 DeviceInfo
  1448. var singleDevice = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  1449. if (singleDevice != null)
  1450. {
  1451. singleDevice.DeviceNo = 0;
  1452. _deviceInfoList = new List<DeviceInfo> { singleDevice };
  1453. }
  1454. else
  1455. {
  1456. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  1457. }
  1458. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1459. }
  1460. }
  1461. else
  1462. {
  1463. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  1464. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1465. }
  1466. }
  1467. return _deviceInfoList.AsReadOnly();
  1468. }
  1469. }
  1470. /// <summary>
  1471. /// 根据设备编号获取设备信息
  1472. /// </summary>
  1473. /// <param name="deviceNo">设备编号</param>
  1474. /// <returns>设备信息,若不存在则返回 null</returns>
  1475. public DeviceInfo GetDeviceInfo(int deviceNo)
  1476. {
  1477. lock (_sync)
  1478. {
  1479. var allDevices = GetAllDeviceInfos();
  1480. return allDevices.FirstOrDefault(d => d.DeviceNo == deviceNo);
  1481. }
  1482. }
  1483. /// <summary>
  1484. /// 获取设备信息配置
  1485. /// </summary>
  1486. /// <returns></returns>
  1487. public DeviceInfo GetDeviceInfo()
  1488. {
  1489. lock (_sync)
  1490. {
  1491. if (_deviceInfo == null)
  1492. {
  1493. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  1494. _deviceInfo = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  1495. else
  1496. {
  1497. _deviceInfo = new DeviceInfo();
  1498. FileHelper.WriteJsonFile(_deviceInfo, ConfigPaths.DeviceInfoConfigurationPath);
  1499. }
  1500. if (_deviceInfo.DataInfo==null)
  1501. {
  1502. _deviceInfo.DataInfo = new CTQ_Data();
  1503. }
  1504. }
  1505. return _deviceInfo;
  1506. }
  1507. }
  1508. /// <summary>
  1509. /// 保存设备信息
  1510. /// </summary>
  1511. /// <param name="deviceInfo"></param>
  1512. public void SaveDeviceInfo(DeviceInfo deviceInfo)
  1513. {
  1514. if (deviceInfo == null) return;
  1515. lock (_sync)
  1516. {
  1517. _deviceInfo = deviceInfo;
  1518. FileHelper.WriteJsonFile(_deviceInfo, ConfigPaths.DeviceInfoConfigurationPath);
  1519. }
  1520. }
  1521. /// <summary>
  1522. /// 添加新设备
  1523. /// </summary>
  1524. /// <returns>新添加的设备</returns>
  1525. public DeviceInfo AddDeviceInfo()
  1526. {
  1527. lock (_sync)
  1528. {
  1529. if (_deviceInfoList == null)
  1530. {
  1531. _deviceInfoList = new List<DeviceInfo>();
  1532. }
  1533. // 计算新设备编号
  1534. int newDeviceNo = _deviceInfoList.Count > 0 ? _deviceInfoList.Max(d => d.DeviceNo) + 1 : 0;
  1535. var newDevice = new DeviceInfo { DeviceNo = newDeviceNo };
  1536. _deviceInfoList.Add(newDevice);
  1537. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1538. return newDevice;
  1539. }
  1540. }
  1541. /// <summary>
  1542. /// 删除设备
  1543. /// </summary>
  1544. /// <param name="deviceNo">设备编号</param>
  1545. /// <returns>是否删除成功</returns>
  1546. public bool RemoveDeviceInfo(int deviceNo)
  1547. {
  1548. lock (_sync)
  1549. {
  1550. if (_deviceInfoList == null) return false;
  1551. var device = _deviceInfoList.FirstOrDefault(d => d.DeviceNo == deviceNo);
  1552. if (device != null)
  1553. {
  1554. _deviceInfoList.Remove(device);
  1555. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1556. return true;
  1557. }
  1558. return false;
  1559. }
  1560. }
  1561. /// <summary>
  1562. /// 保存所有设备信息列表
  1563. /// </summary>
  1564. /// <param name="deviceInfoList">设备信息列表</param>
  1565. public void SaveAllDeviceInfos(IEnumerable<DeviceInfo> deviceInfoList)
  1566. {
  1567. if (deviceInfoList == null) return;
  1568. lock (_sync)
  1569. {
  1570. _deviceInfoList = deviceInfoList.OrderBy(d => d.DeviceNo).ToList();
  1571. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1572. }
  1573. }
  1574. #endregion
  1575. /// <summary>
  1576. /// 释放资源并保存当前内存中的所有配置到文件。
  1577. /// </summary>
  1578. public void Dispose()
  1579. {
  1580. SaveAll();
  1581. GC.SuppressFinalize(this);
  1582. }
  1583. }
  1584. }