ConfigService.cs 68 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707
  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. SaveSystemConfiguration(config);
  884. }
  885. }
  886. #endregion
  887. #region Feeder清料任务
  888. /// <summary>
  889. /// 获取所有清料任务的只读集合。
  890. /// </summary>
  891. /// <returns>清料任务的只读集合。</returns>
  892. public IReadOnlyCollection<FeederClearWork> GetAllClearanceTasks() { lock (_sync) { return FeederClearanceTasks.ToList().AsReadOnly(); } }
  893. /// <summary>
  894. /// 新增或更新清料任务,新增时为任务分配递增的 TaskCode,完成后持久化配置文件。
  895. /// </summary>
  896. /// <param name="task">要添加或更新的清料任务对象。</param>
  897. /// <returns>已添加或更新的 <see cref="FeederClearWork"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  898. public FeederClearWork AddOrUpdateClearanceTask(FeederClearWork task)
  899. {
  900. if (task == null) return null;
  901. lock (_sync)
  902. {
  903. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == task.Id);
  904. if (exist != null)
  905. {
  906. var idx = FeederClearanceTasks.IndexOf(exist);
  907. FeederClearanceTasks[idx] = task;
  908. }
  909. else
  910. {
  911. // 设置任务编号为当前最大编号加1
  912. task.TaskCode = FeederClearanceTasks.Count > 0 ? FeederClearanceTasks.Max(t => t.TaskCode) + 1 : 1;
  913. FeederClearanceTasks.Add(task);
  914. }
  915. }
  916. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  917. return task;
  918. }
  919. /// <summary>
  920. /// 根据标识移除清料任务并持久化配置文件。
  921. /// </summary>
  922. /// <param name="id">要移除的清料任务 Guid。</param>
  923. /// <returns>若找到并移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  924. public bool RemoveClearanceTask(Guid id)
  925. {
  926. lock (_sync)
  927. {
  928. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == id);
  929. if (exist != null)
  930. {
  931. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  932. return FeederClearanceTasks.Remove(exist);
  933. }
  934. else
  935. return false;
  936. }
  937. }
  938. /// <summary>
  939. /// 清除所有清料任务并持久化空集合到配置文件。
  940. /// </summary>
  941. public void ClearAllClearanceTasks()
  942. {
  943. lock (_sync)
  944. {
  945. FeederClearanceTasks.Clear();
  946. }
  947. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  948. }
  949. /// <summary>
  950. /// 判断是否包含指定 Id 的清料任务。
  951. /// </summary>
  952. /// <param name="id">清料任务 Guid。</param>
  953. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  954. public bool ContainsClearanceTask(Guid id)
  955. {
  956. lock (_sync) { return FeederClearanceTasks.Any(t => t.Id == id); }
  957. }
  958. /// <summary>
  959. /// 根据标识获取单个清料任务信息。
  960. /// </summary>
  961. /// <param name="id">清料任务 Guid。</param>
  962. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  963. public FeederClearWork GetClearanceTask(Guid id)
  964. {
  965. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.Id == id); }
  966. }
  967. /// <summary>
  968. /// 判断是否包含指定任务编号的清料任务。
  969. /// </summary>
  970. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  971. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  972. public bool ContainsClearanceTaskByNumber(int taskNumber)
  973. {
  974. lock (_sync) { return FeederClearanceTasks.Any(t => t.TaskCode == taskNumber); }
  975. }
  976. /// <summary>
  977. /// 根据任务编号获取单个清料任务信息。
  978. /// </summary>
  979. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  980. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  981. public FeederClearWork GetClearanceTaskByNumber(int taskNumber)
  982. {
  983. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.TaskCode == taskNumber); }
  984. }
  985. #endregion
  986. #region Light controllers and channels
  987. /// <summary>
  988. /// 获取所有光源控制器配置的只读集合。
  989. /// 线程安全:在内部使用 <see cref="_sync"/> 进行锁定以保证并发访问安全。
  990. /// </summary>
  991. /// <returns>按当前内存中存储顺序返回的只读 <see cref="LightControllerConfig"/> 集合。</returns>
  992. public IReadOnlyCollection<LightControllerConfig> GetAllLightControllers()
  993. {
  994. lock (_sync) { return LightControllers.ToList().AsReadOnly(); }
  995. }
  996. /// <summary>
  997. /// 根据控制器标识获取单个光源控制器配置。
  998. /// 线程安全:该方法对内存集合进行只读访问并在内部加锁。
  999. /// </summary>
  1000. /// <param name="id">控制器的整数标识(Id)。</param>
  1001. /// <returns>匹配的 <see cref="LightControllerConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  1002. public LightControllerConfig GetLightController(int id)
  1003. {
  1004. lock (_sync) { return LightControllers.FirstOrDefault(c => c.Id == id); }
  1005. }
  1006. /// <summary>
  1007. /// 新增或更新光源控制器配置。
  1008. /// - 若 <paramref name="controller"/> 为 <c>null</c> 返回 <c>null</c>。
  1009. /// - 更新时以 Id 匹配现有项并替换。
  1010. /// - 新增时分配连续的控制器 Id,并为控制器内的每个通道分配全局通道编号(GlobalIndex)。
  1011. /// 线程安全:在内部使用 <see cref="_sync"/> 锁定集合。
  1012. /// </summary>
  1013. /// <param name="controller">要添加或更新的 <see cref="LightControllerConfig"/> 实例。</param>
  1014. /// <returns>已添加或更新的 <see cref="LightControllerConfig"/> 实例;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  1015. /// <exception cref="ArgumentException">当要添加/更新的控制器名称与现有其他控制器重复时抛出。</exception>
  1016. public LightControllerConfig AddOrUpdateLightController(LightControllerConfig controller)
  1017. {
  1018. if (controller == null) return null;
  1019. lock (_sync)
  1020. {
  1021. // 名称不得与其他控制器重复(同名但不同 Id 不允许)
  1022. if (LightControllers.Any(c => c.Name == controller.Name && c.Id != controller.Id))
  1023. throw new ArgumentException("Controller name must be unique");
  1024. var exist = LightControllers.FirstOrDefault(c => c.Id == controller.Id);
  1025. if (exist != null)
  1026. {
  1027. // 更新现有控制器(按索引替换)
  1028. var idx = LightControllers.IndexOf(exist);
  1029. LightControllers[idx] = controller;
  1030. }
  1031. else
  1032. {
  1033. // 新增控制器
  1034. // 分配控制器编号为当前最大 Id + 1(若集合为空则为 1)
  1035. controller.Id = LightControllers.Count > 0 ? LightControllers.Max(c => c.Id) + 1 : 1;
  1036. // 计算下一个全局通道索引:在所有已存在控制器的通道 GlobalIndex 上取最大值并加1
  1037. int nextGlobal = 0;
  1038. if (LightControllers.SelectMany(c => c.ChannelConfigs).Any())
  1039. {
  1040. nextGlobal = LightControllers.SelectMany(c => c.ChannelConfigs).Max(ch => ch.GlobalIndex) + 1;
  1041. }
  1042. // 遍历新增控制器的通道,若通道的 GlobalIndex 无效(<0)或与现有通道冲突,则重新分配
  1043. for (int i = 0; i < controller.ChannelConfigs.Count; i++)
  1044. {
  1045. var ch = controller.ChannelConfigs[i];
  1046. if (ch.GlobalIndex < 0 || LightControllers.SelectMany(c => c.ChannelConfigs).Any(existingCh => existingCh.GlobalIndex == ch.GlobalIndex))
  1047. {
  1048. ch.GlobalIndex = nextGlobal;
  1049. nextGlobal++;
  1050. }
  1051. }
  1052. LightControllers.Add(controller);
  1053. }
  1054. }
  1055. // 持久化更新后的光源控制器配置
  1056. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1057. return controller;
  1058. }
  1059. /// <summary>
  1060. /// 根据 Id 移除光源控制器配置并对剩余控制器重新编号(从 1 开始连续编号)。
  1061. /// 操作后持久化配置文件。
  1062. /// </summary>
  1063. /// <param name="id">要移除的控制器 Id。</param>
  1064. /// <returns>如果成功移除返回 <c>true</c>,否则返回 <c>false</c>(比如未找到该 Id)。</returns>
  1065. public bool RemoveLightController(int id)
  1066. {
  1067. bool result = false;
  1068. lock (_sync)
  1069. {
  1070. var e = LightControllers.FirstOrDefault(c => c.Id == id);
  1071. if (e != null)
  1072. result = LightControllers.Remove(e);
  1073. // 重新按 Id 排序并从 1 开始重新编号,以保持连续性
  1074. int no = 1;
  1075. var sorted = LightControllers.OrderBy(c => c.Id).ToList();
  1076. foreach (var c in sorted)
  1077. {
  1078. c.Id = no;
  1079. no++;
  1080. }
  1081. LightControllers.Clear();
  1082. foreach (var c in sorted)
  1083. {
  1084. LightControllers.Add(c);
  1085. }
  1086. }
  1087. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1088. return result;
  1089. }
  1090. /// <summary>
  1091. /// 判断是否包含指定 Id 的光源控制器。
  1092. /// </summary>
  1093. /// <param name="id">控制器 Id。</param>
  1094. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  1095. public bool ContainsLightController(int id) { lock (_sync) { return LightControllers.Any(c => c.Id == id); } }
  1096. /// <summary>
  1097. /// 获取所有光源通道的只读集合,按 GlobalIndex 升序返回。
  1098. /// </summary>
  1099. /// <returns>按 GlobalIndex 排序的 <see cref="ChannelConfig"/> 只读集合。</returns>
  1100. public IReadOnlyCollection<ChannelConfig> GetAllLightChannels()
  1101. {
  1102. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).OrderBy(ch => ch.GlobalIndex).ToList().AsReadOnly(); }
  1103. }
  1104. /// <summary>
  1105. /// 根据全局通道索引获取单个通道配置。
  1106. /// </summary>
  1107. /// <param name="globalIndex">通道的全局索引(GlobalIndex)。</param>
  1108. /// <returns>匹配的 <see cref="ChannelConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  1109. public ChannelConfig GetLightChannelByGlobalIndex(int globalIndex)
  1110. {
  1111. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(ch => ch.GlobalIndex == globalIndex); }
  1112. }
  1113. /// <summary>
  1114. /// 判断是否存在指定全局通道索引的通道配置。
  1115. /// </summary>
  1116. /// <param name="globalIndex">全局通道索引。</param>
  1117. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  1118. public bool ContainsLightChannelByGlobalIndex(int globalIndex)
  1119. {
  1120. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).Any(ch => ch.GlobalIndex == globalIndex); }
  1121. }
  1122. /// <summary>
  1123. /// 更新指定全局通道的默认亮度(DefaultBrightness),并持久化光源控制器配置。
  1124. /// </summary>
  1125. /// <param name="globalIndex">目标通道的全局索引(GlobalIndex)。</param>
  1126. /// <param name="brightness">要设置的亮度值。</param>
  1127. /// <returns>更新成功返回 <c>true</c>;找不到对应通道返回 <c>false</c>。</returns>
  1128. public bool UpdateChannelDefaultBrightness(int globalIndex, int brightness)
  1129. {
  1130. lock (_sync)
  1131. {
  1132. var ch = LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(x => x.GlobalIndex == globalIndex);
  1133. if (ch == null) return false;
  1134. ch.DefaultBrightness = brightness;
  1135. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1136. return true;
  1137. }
  1138. }
  1139. #endregion
  1140. #region Plc Addresses
  1141. public PlcAddressConfig GetPlcAddresses() { lock (_sync) { return PlcAddressConfig; } }
  1142. #endregion
  1143. #region ScrewDriver config (single device)
  1144. /// <summary>
  1145. /// 获取电批配置(单设备)。
  1146. /// </summary>
  1147. /// <returns>当前的 <see cref="ScrewDriverConfig"/>,若未加载则返回 null。</returns>
  1148. public ScrewDriverConfig GetScrewDriverConfig()
  1149. {
  1150. lock (_sync) { return _screwDriverConfig; }
  1151. }
  1152. /// <summary>
  1153. /// 设置并持久化电批配置(单设备)。
  1154. /// </summary>
  1155. /// <param name="cfg">新的配置对象,不能为空。</param>
  1156. public void SetScrewDriverConfig(ScrewDriverConfig cfg)
  1157. {
  1158. if (cfg == null) throw new ArgumentNullException(nameof(cfg));
  1159. lock (_sync)
  1160. {
  1161. _screwDriverConfig = cfg;
  1162. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  1163. }
  1164. }
  1165. /// <summary>
  1166. /// 仅将当前内存中的电批配置保存到文件。
  1167. /// </summary>
  1168. public void SaveScrewDriverConfig()
  1169. {
  1170. lock (_sync)
  1171. {
  1172. if (_screwDriverConfig != null)
  1173. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  1174. }
  1175. }
  1176. #endregion
  1177. #region Screw Feeders (material)
  1178. /// <summary>
  1179. /// 获取所有螺丝供料器配置的只读集合。
  1180. /// </summary>
  1181. public IReadOnlyCollection<ScrewFeederInfo> GetAllScrewFeeders() { lock (_sync) { return ScrewFeeders.ToList().AsReadOnly(); } }
  1182. /// <summary>
  1183. /// 根据 Id 获取单个螺丝供料器配置。
  1184. /// </summary>
  1185. public ScrewFeederInfo GetScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.FirstOrDefault(s => s.Id == id); } }
  1186. /// <summary>
  1187. /// 新增或更新螺丝供料器配置。
  1188. /// 新增时若未指定 FeederNumber 则分配为当前数量+1。
  1189. /// </summary>
  1190. public ScrewFeederInfo AddOrUpdateScrewFeeder(ScrewFeederInfo feeder)
  1191. {
  1192. if (feeder == null) return null;
  1193. lock (_sync)
  1194. {
  1195. var exist = ScrewFeeders.FirstOrDefault(f => f.Id == feeder.Id);
  1196. if (exist != null)
  1197. {
  1198. var idx = ScrewFeeders.IndexOf(exist);
  1199. ScrewFeeders[idx] = feeder;
  1200. }
  1201. else
  1202. {
  1203. if (feeder.FeederNumber <= 0) feeder.FeederNumber = ScrewFeeders.Count + 1;
  1204. ScrewFeeders.Add(feeder);
  1205. }
  1206. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1207. }
  1208. return feeder;
  1209. }
  1210. /// <summary>
  1211. /// 移除螺丝供料器配置。
  1212. /// </summary>
  1213. public bool RemoveScrewFeeder(Guid id)
  1214. {
  1215. bool result = false;
  1216. lock (_sync)
  1217. {
  1218. var e = ScrewFeeders.FirstOrDefault(s => s.Id == id);
  1219. if (e != null) result = ScrewFeeders.Remove(e);
  1220. }
  1221. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1222. return result;
  1223. }
  1224. public bool ContainsScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.Any(s => s.Id == id); } }
  1225. // event for low level alarm
  1226. public event Action<ScrewFeederInfo> ScrewFeederLowLevelAlarmTriggered;
  1227. /// <summary>
  1228. /// 获取指定供料器编号的剩余螺丝数量(找不到返回 -1)
  1229. /// </summary>
  1230. public int GetRemainingCountByFeederNumber(int feederNumber)
  1231. {
  1232. lock (_sync)
  1233. {
  1234. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1235. if (f == null) return -1;
  1236. return f.RemainingCount;
  1237. }
  1238. }
  1239. /// <summary>
  1240. /// 获取指定供料器编号的低量报警状态(找不到返回 false)
  1241. /// </summary>
  1242. public bool GetLowLevelAlarmStatusByFeederNumber(int feederNumber)
  1243. {
  1244. lock (_sync)
  1245. {
  1246. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1247. if (f == null) return false;
  1248. return f.IsLowLevelAlarmActive;
  1249. }
  1250. }
  1251. // helper: check and raise low level alarm when necessary
  1252. private void CheckAndTriggerLowLevelAlarm(ScrewFeederInfo f)
  1253. {
  1254. if (f == null) return;
  1255. if (f.LowLevelAlarmEnabled && f.RemainingCount <= f.LowLevelThreshold)
  1256. {
  1257. if (!f.IsLowLevelAlarmActive)
  1258. {
  1259. f.IsLowLevelAlarmActive = true;
  1260. try
  1261. {
  1262. ScrewFeederLowLevelAlarmTriggered?.Invoke(f.Clone());
  1263. }
  1264. catch { }
  1265. }
  1266. }
  1267. else
  1268. {
  1269. if (f.IsLowLevelAlarmActive)
  1270. {
  1271. f.IsLowLevelAlarmActive = false;
  1272. }
  1273. }
  1274. }
  1275. /// <summary>
  1276. /// 为指定供料器编号递减指定数量,若数量不足返回 false
  1277. /// </summary>
  1278. public bool DecrementScrewCountByFeederNumber(int feederNumber, int decrement = 1)
  1279. {
  1280. lock (_sync)
  1281. {
  1282. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1283. if (f == null) return false;
  1284. if (decrement <= 0) decrement = 1;
  1285. if (f.RemainingCount < decrement) return false;
  1286. f.RemainingCount -= decrement;
  1287. // check alarm
  1288. CheckAndTriggerLowLevelAlarm(f);
  1289. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1290. return true;
  1291. }
  1292. }
  1293. /// <summary>
  1294. /// 清除指定供料器编号的螺丝信息(批次号置空,剩余数量置0)
  1295. /// </summary>
  1296. public void ClearScrewFeederByNumber(int feederNumber)
  1297. {
  1298. lock (_sync)
  1299. {
  1300. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1301. if (f == null) return;
  1302. f.BatchNumber = string.Empty;
  1303. f.RemainingCount = 0;
  1304. // check alarm
  1305. CheckAndTriggerLowLevelAlarm(f);
  1306. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1307. }
  1308. }
  1309. /// <summary>
  1310. /// 为指定供料器编号设置批次号,并在原有剩余数量上增加一包(PackSize)
  1311. /// </summary>
  1312. public void SetBatchForFeederNumber(int feederNumber, string batchNumber)
  1313. {
  1314. if (string.IsNullOrWhiteSpace(batchNumber)) return;
  1315. // capture values under lock, then record to DB outside lock
  1316. ScrewFeederInfo target = null;
  1317. int remainingAfter = 0;
  1318. int packSize = 0;
  1319. string feederName = null;
  1320. lock (_sync)
  1321. {
  1322. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1323. if (f == null) return;
  1324. f.BatchNumber = batchNumber;
  1325. f.RemainingCount += Math.Max(0, f.PackSize);
  1326. // prepare capture values
  1327. target = f;
  1328. remainingAfter = f.RemainingCount;
  1329. packSize = f.PackSize;
  1330. feederName = f.Name;
  1331. // check alarm
  1332. CheckAndTriggerLowLevelAlarm(f);
  1333. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1334. }
  1335. try
  1336. {
  1337. var record = new ScrewFeederBatchRecord
  1338. {
  1339. BatchNumber = batchNumber,
  1340. PackSize = packSize,
  1341. ChangeTime = DateTime.UtcNow,
  1342. RemainingCount = remainingAfter,
  1343. FeederNumber = feederNumber,
  1344. FeederName = feederName
  1345. };
  1346. // try get operator name from system database service if available
  1347. try
  1348. {
  1349. var user = _systemDatabaseService?.GetCurrentUser();
  1350. if (user != null)
  1351. record.OperatorName = user.UserName;
  1352. }
  1353. catch
  1354. {
  1355. // ignore getting user failure
  1356. }
  1357. // fire-and-forget recording (ConfigService will forward to DB service if set)
  1358. _ = RecordScrewFeederBatchAsync(record);
  1359. }
  1360. catch
  1361. {
  1362. // ignore any error creating/recording the batch record
  1363. }
  1364. }
  1365. #endregion
  1366. #region 用户登录刷卡器
  1367. /// <summary>
  1368. /// 获取刷卡器配置
  1369. /// </summary>
  1370. /// <returns></returns>
  1371. public SerialPortConfig GetCardReaderConfig()
  1372. {
  1373. lock (_sync)
  1374. {
  1375. if (_cardReaderConfig != null)
  1376. return _cardReaderConfig;
  1377. if (File.Exists(ConfigPaths.CardReaderConfigurationPath))
  1378. {
  1379. try
  1380. {
  1381. _cardReaderConfig = FileHelper.ReadJsonFile<SerialPortConfig>(ConfigPaths.CardReaderConfigurationPath);
  1382. }
  1383. catch
  1384. {
  1385. // 若读取失败,创建默认配置并覆盖文件(与项目中其他配置策略一致)
  1386. _cardReaderConfig = new SerialPortConfig();
  1387. try { FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath); } catch { }
  1388. }
  1389. }
  1390. else
  1391. {
  1392. _cardReaderConfig = new SerialPortConfig();
  1393. try { FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath); } catch { }
  1394. }
  1395. return _cardReaderConfig;
  1396. }
  1397. }
  1398. /// <summary>
  1399. /// 保存刷卡器配置
  1400. /// </summary>
  1401. /// <param name="config"></param>
  1402. public void SaveCardReaderConfig(SerialPortConfig config)
  1403. {
  1404. if (config == null) return;
  1405. lock (_sync)
  1406. {
  1407. _cardReaderConfig = config;
  1408. try
  1409. {
  1410. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  1411. }
  1412. catch
  1413. {
  1414. // 忽略持久化错误(与项目中其它保存方法一致),可在需要时添加日志记录
  1415. }
  1416. }
  1417. }
  1418. #endregion
  1419. #region DeviceInfo
  1420. /// <summary>
  1421. /// 获取所有设备信息配置列表
  1422. /// </summary>
  1423. /// <returns>设备信息列表的只读集合</returns>
  1424. public IReadOnlyCollection<DeviceInfo> GetAllDeviceInfos()
  1425. {
  1426. lock (_sync)
  1427. {
  1428. if (_deviceInfoList == null)
  1429. {
  1430. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  1431. {
  1432. try
  1433. {
  1434. _deviceInfoList = FileHelper.ReadJsonFile<List<DeviceInfo>>(ConfigPaths.DeviceInfoConfigurationPath);
  1435. }
  1436. catch
  1437. {
  1438. // 兼容旧版单个 DeviceInfo
  1439. var singleDevice = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  1440. if (singleDevice != null)
  1441. {
  1442. singleDevice.DeviceNo = 0;
  1443. _deviceInfoList = new List<DeviceInfo> { singleDevice };
  1444. }
  1445. else
  1446. {
  1447. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  1448. }
  1449. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1450. }
  1451. }
  1452. else
  1453. {
  1454. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  1455. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1456. }
  1457. }
  1458. return _deviceInfoList.AsReadOnly();
  1459. }
  1460. }
  1461. /// <summary>
  1462. /// 根据设备编号获取设备信息
  1463. /// </summary>
  1464. /// <param name="deviceNo">设备编号</param>
  1465. /// <returns>设备信息,若不存在则返回 null</returns>
  1466. public DeviceInfo GetDeviceInfo(int deviceNo)
  1467. {
  1468. lock (_sync)
  1469. {
  1470. var allDevices = GetAllDeviceInfos();
  1471. return allDevices.FirstOrDefault(d => d.DeviceNo == deviceNo);
  1472. }
  1473. }
  1474. /// <summary>
  1475. /// 获取设备信息配置
  1476. /// </summary>
  1477. /// <returns></returns>
  1478. public DeviceInfo GetDeviceInfo()
  1479. {
  1480. lock (_sync)
  1481. {
  1482. if (_deviceInfo == null)
  1483. {
  1484. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  1485. _deviceInfo = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  1486. else
  1487. {
  1488. _deviceInfo = new DeviceInfo();
  1489. FileHelper.WriteJsonFile(_deviceInfo, ConfigPaths.DeviceInfoConfigurationPath);
  1490. }
  1491. if (_deviceInfo.DataInfo==null)
  1492. {
  1493. _deviceInfo.DataInfo = new CTQ_Data();
  1494. }
  1495. }
  1496. return _deviceInfo;
  1497. }
  1498. }
  1499. /// <summary>
  1500. /// 保存设备信息
  1501. /// </summary>
  1502. /// <param name="deviceInfo"></param>
  1503. public void SaveDeviceInfo(DeviceInfo deviceInfo)
  1504. {
  1505. if (deviceInfo == null) return;
  1506. lock (_sync)
  1507. {
  1508. _deviceInfo = deviceInfo;
  1509. FileHelper.WriteJsonFile(_deviceInfo, ConfigPaths.DeviceInfoConfigurationPath);
  1510. }
  1511. }
  1512. /// <summary>
  1513. /// 添加新设备
  1514. /// </summary>
  1515. /// <returns>新添加的设备</returns>
  1516. public DeviceInfo AddDeviceInfo()
  1517. {
  1518. lock (_sync)
  1519. {
  1520. if (_deviceInfoList == null)
  1521. {
  1522. _deviceInfoList = new List<DeviceInfo>();
  1523. }
  1524. // 计算新设备编号
  1525. int newDeviceNo = _deviceInfoList.Count > 0 ? _deviceInfoList.Max(d => d.DeviceNo) + 1 : 0;
  1526. var newDevice = new DeviceInfo { DeviceNo = newDeviceNo };
  1527. _deviceInfoList.Add(newDevice);
  1528. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1529. return newDevice;
  1530. }
  1531. }
  1532. /// <summary>
  1533. /// 删除设备
  1534. /// </summary>
  1535. /// <param name="deviceNo">设备编号</param>
  1536. /// <returns>是否删除成功</returns>
  1537. public bool RemoveDeviceInfo(int deviceNo)
  1538. {
  1539. lock (_sync)
  1540. {
  1541. if (_deviceInfoList == null) return false;
  1542. var device = _deviceInfoList.FirstOrDefault(d => d.DeviceNo == deviceNo);
  1543. if (device != null)
  1544. {
  1545. _deviceInfoList.Remove(device);
  1546. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1547. return true;
  1548. }
  1549. return false;
  1550. }
  1551. }
  1552. /// <summary>
  1553. /// 保存所有设备信息列表
  1554. /// </summary>
  1555. /// <param name="deviceInfoList">设备信息列表</param>
  1556. public void SaveAllDeviceInfos(IEnumerable<DeviceInfo> deviceInfoList)
  1557. {
  1558. if (deviceInfoList == null) return;
  1559. lock (_sync)
  1560. {
  1561. _deviceInfoList = deviceInfoList.OrderBy(d => d.DeviceNo).ToList();
  1562. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  1563. }
  1564. }
  1565. #endregion
  1566. /// <summary>
  1567. /// 释放资源并保存当前内存中的所有配置到文件。
  1568. /// </summary>
  1569. public void Dispose()
  1570. {
  1571. SaveAll();
  1572. GC.SuppressFinalize(this);
  1573. }
  1574. }
  1575. }