ConfigService.cs 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934
  1. using Cognex.VisionPro;
  2. using Cognex.VisionPro.ToolBlock;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Collections.ObjectModel;
  6. using System.IO;
  7. using System.Linq;
  8. using System.Threading.Tasks;
  9. using TeamAAS_VP.Core;
  10. using TeamAAS_VP.Interfaces;
  11. using TeamAAS_VP.Models;
  12. using TeamAAS_VP.Models.Calibration;
  13. using TeamAAS_VP.Models.Feeder;
  14. using TeamAAS_VP.Models.Lights;
  15. using TeamAAS_VP.Models.PLC;
  16. namespace TeamAAS_VP.Services
  17. {
  18. /// <summary>
  19. /// 配置参数服务实现类。
  20. /// 线程安全:内部使用私有锁字段 <see cref="_sync"/> 来保护对内存集合的并发访问。
  21. /// 持久化:对集合的修改会写回到对应的配置文件(路径由内部静态类 <see cref="ConfigPaths"/> 定义)。
  22. /// </summary>
  23. public class ConfigService : IConfigService
  24. {
  25. private static class ConfigPaths
  26. {
  27. // 将路径集中管理于本类,当前使用现有 FilePath 值以保持兼容
  28. public static readonly string CamerasConfigurationPath = "..//Config//CameraConfiguration.cfg";
  29. public static readonly string RobotsConfigurationPath = "..//Config//RobotsConfiguration.cfg";
  30. public static readonly string FeedersConfigurationPath = "..//Config//FeedersConfiguration.cfg";
  31. public static readonly string PlcConfigurationPath = "..//Config//PlcConfiguration.cfg";
  32. public static readonly string BgTcpIpConfigurationPath = "..//Config//BgTcpIpConfiguration.cfg";
  33. public static readonly string BgModbusTcpConfigurationPath = "..//Config//BgModbusTcpConfiguration.cfg";
  34. public static readonly string SystemConfigurationPath = "..//Config//SystemConfiguration.cfg";
  35. // Feeder清料任务配置路径
  36. public static readonly string FeederClearanceTasksConfigurationPath = "..//Config//FeederClearanceTasksConfiguration.cfg";
  37. // 光源控制器配置路径
  38. public static readonly string LightControllersConfigurationPath = "..//Config//LightControllersConfiguration.cfg";
  39. }
  40. private readonly object _sync = new object();
  41. private ObservableCollection<CameraInfo> Cameras { get; set; }
  42. private ObservableCollection<RobotInfo> Robots { get; set; }
  43. private ObservableCollection<FeederInfo> Feeders { get; set; }
  44. private ObservableCollection<PlcInfo> Plcs { get; set; }
  45. private BgTcpIP BgCommunicate { get; set; }
  46. private BgModbusTcp BgModbusCommunicate { get; set; }
  47. private ObservableCollection<FeederClearWork> FeederClearanceTasks { get; set; }
  48. // 光源控制器配置
  49. private ObservableCollection<LightControllerConfig> LightControllers { get; set; }
  50. private PlcAddressConfig PlcAddressConfig { get; set; }
  51. /// <summary>
  52. /// 初始化一个新的 <see cref="ConfigService"/> 实例。
  53. /// 构造函数不会自动加载配置文件(避免在构造期间进行 I/O 操作);可调用 <see cref="LoadAll"/> 或 <see cref="LoadAllAsync"/> 显式加载。
  54. /// </summary>
  55. public ConfigService()
  56. {
  57. //LoadAll();
  58. }
  59. /// <summary>
  60. /// 同步加载所有配置文件至内存(若对应文件不存在,将创建默认空集合/对象并写入文件)。
  61. /// 线程安全:方法内部对共享资源使用 <see cref="_sync"/> 加锁。
  62. /// </summary>
  63. public void LoadAll()
  64. {
  65. lock (_sync)
  66. {
  67. // 读取各配置,如果文件不存在,则保持 DeviceConfig 默认值
  68. if (File.Exists(ConfigPaths.CamerasConfigurationPath))
  69. Cameras = FileHelper.ReadJsonFile<ObservableCollection<CameraInfo>>(ConfigPaths.CamerasConfigurationPath);
  70. else
  71. {
  72. Cameras = new ObservableCollection<CameraInfo>();
  73. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  74. }
  75. if (File.Exists(ConfigPaths.RobotsConfigurationPath))
  76. Robots = FileHelper.ReadJsonFile<ObservableCollection<RobotInfo>>(ConfigPaths.RobotsConfigurationPath);
  77. else
  78. {
  79. Robots = new ObservableCollection<RobotInfo>();
  80. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  81. }
  82. if (File.Exists(ConfigPaths.FeedersConfigurationPath))
  83. Feeders = FileHelper.ReadJsonFile<ObservableCollection<FeederInfo>>(ConfigPaths.FeedersConfigurationPath);
  84. else
  85. {
  86. Feeders = new ObservableCollection<FeederInfo>();
  87. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  88. }
  89. if (File.Exists(ConfigPaths.PlcConfigurationPath))
  90. Plcs = FileHelper.ReadJsonFile<ObservableCollection<PlcInfo>>(ConfigPaths.PlcConfigurationPath);
  91. else
  92. {
  93. Plcs = new ObservableCollection<PlcInfo>();
  94. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  95. }
  96. if (File.Exists(ConfigPaths.BgTcpIpConfigurationPath))
  97. BgCommunicate = FileHelper.ReadJsonFile<BgTcpIP>(ConfigPaths.BgTcpIpConfigurationPath);
  98. else
  99. {
  100. BgCommunicate = new BgTcpIP();
  101. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  102. }
  103. if (File.Exists(ConfigPaths.BgModbusTcpConfigurationPath))
  104. BgModbusCommunicate = FileHelper.ReadJsonFile<BgModbusTcp>(ConfigPaths.BgModbusTcpConfigurationPath);
  105. else
  106. {
  107. BgModbusCommunicate = new BgModbusTcp();
  108. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  109. }
  110. if (!File.Exists(ConfigPaths.FeederClearanceTasksConfigurationPath))
  111. {
  112. FeederClearanceTasks = new ObservableCollection<FeederClearWork>();
  113. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  114. }
  115. else
  116. {
  117. // 读取 Feeder清料任务 配置
  118. FeederClearanceTasks = FileHelper.ReadJsonFile<ObservableCollection<FeederClearWork>>(ConfigPaths.FeederClearanceTasksConfigurationPath);
  119. }
  120. // 读取光源控制器配置
  121. if (!File.Exists(ConfigPaths.LightControllersConfigurationPath))
  122. {
  123. LightControllers = new ObservableCollection<LightControllerConfig>();
  124. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  125. }
  126. else
  127. {
  128. LightControllers = FileHelper.ReadJsonFile<ObservableCollection<LightControllerConfig>>(ConfigPaths.LightControllersConfigurationPath);
  129. }
  130. // load plc addresses
  131. var plcAddressPath = "..//Config//PlcAddressConfiguration.cfg";
  132. if (File.Exists(plcAddressPath))
  133. PlcAddressConfig = FileHelper.ReadJsonFile<PlcAddressConfig>(plcAddressPath);
  134. else
  135. {
  136. PlcAddressConfig = new PlcAddressConfig();
  137. PlcAddressConfig.SetDefaultValue();
  138. FileHelper.WriteJsonFile(PlcAddressConfig, plcAddressPath);
  139. }
  140. }
  141. }
  142. /// <summary>
  143. /// 异步执行 <see cref="LoadAll"/> 操作。
  144. /// </summary>
  145. /// <returns>表示异步加载操作的任务。</returns>
  146. public Task LoadAllAsync()
  147. {
  148. return Task.Run(() => LoadAll());
  149. }
  150. /// <summary>
  151. /// 将内存中的所有配置写回到对应配置文件。
  152. /// 线程安全:方法内部对写入操作使用 <see cref="_sync"/> 加锁。
  153. /// </summary>
  154. public void SaveAll()
  155. {
  156. lock (_sync)
  157. {
  158. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  159. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  160. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  161. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  162. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  163. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  164. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  165. // save plc addresses
  166. //FileHelper.WriteJsonFile(PlcAddressConfig, "..//Config//PlcAddressConfiguration.cfg");
  167. }
  168. }
  169. /// <summary>
  170. /// 异步执行 <see cref="SaveAll"/> 操作。
  171. /// </summary>
  172. /// <returns>表示异步保存操作的任务。</returns>
  173. public Task SaveAllAsync()
  174. {
  175. return Task.Run(() => SaveAll());
  176. }
  177. #region Cameras
  178. /// <summary>
  179. /// 获取所有相机配置的只读集合。
  180. /// 线程安全:在内部加锁以保证并发读取的一致性。
  181. /// </summary>
  182. /// <returns>相机配置的只读集合。</returns>
  183. public IReadOnlyCollection<CameraInfo> GetAllCameras()
  184. {
  185. lock (_sync) { return Cameras.ToList().AsReadOnly(); }
  186. }
  187. /// <summary>
  188. /// 根据标识获取单个相机配置信息。
  189. /// </summary>
  190. /// <param name="id">相机的 Guid 标识。</param>
  191. /// <returns>找到则返回对应的 <see cref="CameraInfo"/>,否则返回 <c>null</c>。</returns>
  192. public CameraInfo GetCamera(Guid id)
  193. {
  194. lock (_sync) { return Cameras.FirstOrDefault(c => c.Id == id); }
  195. }
  196. /// <summary>
  197. /// 新增或更新相机配置。
  198. /// - 若传入 <paramref name="camera"/> 为 <c>null</c> 返回 <c>null</c>。
  199. /// - 若 Id 已存在则替换;否则追加并设置连续的 CameraNo 编号。
  200. /// 方法结束后会将相机集合持久化到配置文件。
  201. /// </summary>
  202. /// <param name="camera">要添加或更新的相机配置。</param>
  203. /// <returns>已添加或更新的 <see cref="CameraInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  204. public CameraInfo AddOrUpdateCamera(CameraInfo camera)
  205. {
  206. if (camera == null) return null;
  207. lock (_sync)
  208. {
  209. var exist = Cameras.FirstOrDefault(c => c.Id == camera.Id);
  210. if (exist != null)
  211. {
  212. var idx = Cameras.IndexOf(exist);
  213. Cameras[idx] = camera;
  214. }
  215. else
  216. {
  217. camera.CameraNo = Cameras.Count + 1;
  218. Cameras.Add(camera);
  219. }
  220. }
  221. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  222. return camera;
  223. }
  224. /// <summary>
  225. /// 根据标识移除相机配置并重新编号剩余相机的 CameraNo。
  226. /// 方法结束后会将相机集合持久化到配置文件。
  227. /// </summary>
  228. /// <param name="id">要移除的相机 Guid。</param>
  229. /// <returns>若找到并成功移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  230. public bool RemoveCamera(Guid id)
  231. {
  232. bool result = false;
  233. lock (_sync)
  234. {
  235. var exist = Cameras.FirstOrDefault(c => c.Id == id);
  236. if (exist != null) result = Cameras.Remove(exist);
  237. //重新编号
  238. int no = 1;
  239. //对所有相机按CameraNo排序
  240. var sortedCameras = Cameras.OrderBy(c => c.CameraNo).ToList();
  241. foreach (var cam in sortedCameras)
  242. {
  243. cam.CameraNo = no;
  244. no++;
  245. }
  246. Cameras.Clear();
  247. foreach (var cam in sortedCameras)
  248. {
  249. Cameras.Add(cam);
  250. }
  251. }
  252. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  253. return result;
  254. }
  255. /// <summary>
  256. /// 检查是否包含指定 Id 的相机配置。
  257. /// </summary>
  258. /// <param name="id">相机的 Guid。</param>
  259. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  260. public bool ContainsCamera(Guid id) { lock (_sync) { return Cameras.Any(c => c.Id == id); } }
  261. #endregion
  262. #region Robots
  263. /// <summary>
  264. /// 获取所有机器人配置的只读集合。
  265. /// </summary>
  266. /// <returns>机器人配置的只读集合。</returns>
  267. public IReadOnlyCollection<RobotInfo> GetAllRobots() { lock (_sync) { return Robots.ToList().AsReadOnly(); } }
  268. /// <summary>
  269. /// 根据标识获取单个机器人配置。
  270. /// </summary>
  271. /// <param name="id">机器人的 Guid 标识。</param>
  272. /// <returns>找到则返回对应的 <see cref="RobotInfo"/>,否则返回 <c>null</c>。</returns>
  273. public RobotInfo GetRobot(Guid id) { lock (_sync) { return Robots.FirstOrDefault(r => r.Id == id); } }
  274. /// <summary>
  275. /// 新增或更新机器人配置,操作后持久化至配置文件。
  276. /// 新增时为机器人分配连续的 RobotNo 编号。
  277. /// </summary>
  278. /// <param name="robot">要添加或更新的机器人配置。</param>
  279. /// <returns>已添加或更新的 <see cref="RobotInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  280. public RobotInfo AddOrUpdateRobot(RobotInfo robot)
  281. {
  282. if (robot == null) return null;
  283. lock (_sync)
  284. {
  285. var exist = Robots.FirstOrDefault(r => r.Id == robot.Id);
  286. if (exist != null)
  287. {
  288. var idx = Robots.IndexOf(exist);
  289. Robots[idx] = robot;
  290. }
  291. else
  292. {
  293. robot.RobotNo = Robots.Count + 1;
  294. Robots.Add(robot);
  295. }
  296. }
  297. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  298. return robot;
  299. }
  300. /// <summary>
  301. /// 根据标识移除机器人配置并重新编号剩余机器人。
  302. /// 操作后持久化配置文件。
  303. /// </summary>
  304. /// <param name="id">要移除的机器人 Guid。</param>
  305. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  306. public bool RemoveRobot(Guid id)
  307. {
  308. bool result = false;
  309. lock (_sync)
  310. {
  311. var e = Robots.FirstOrDefault(r => r.Id == id);
  312. if (e != null)
  313. result = Robots.Remove(e);
  314. //重新编号
  315. int no = 1;
  316. //对所有机器人按RobotNo排序
  317. var sortedRobots = Robots.OrderBy(r => r.RobotNo).ToList();
  318. foreach (var r in sortedRobots)
  319. {
  320. r.RobotNo = no;
  321. no++;
  322. }
  323. Robots.Clear();
  324. foreach (var r in sortedRobots)
  325. {
  326. Robots.Add(r);
  327. }
  328. }
  329. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  330. return result;
  331. }
  332. /// <summary>
  333. /// 判断是否包含指定 Id 的机器人配置。
  334. /// </summary>
  335. /// <param name="id">机器人的 Guid。</param>
  336. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  337. public bool ContainsRobot(Guid id) { lock (_sync) { return Robots.Any(r => r.Id == id); } }
  338. /// <summary>
  339. /// 修改指定机器人 Id的步进距离并持久化机器人配置。
  340. /// </summary>
  341. /// <param name="id">机器人唯一标识符。</param>
  342. /// <param name="stepDistance">步进距离。</param>
  343. /// <returns>更新成功返回 <c>true</c>,找不到机器人返回 <c>false</c>。</returns>
  344. public bool UpdateRobotStepDistance(Guid id, double stepDistance)
  345. {
  346. lock (_sync)
  347. {
  348. var robot = Robots.FirstOrDefault(r => r.Id == id);
  349. if (robot != null)
  350. {
  351. robot.StepDistance = stepDistance;
  352. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  353. return true;
  354. }
  355. else
  356. {
  357. return false;
  358. }
  359. }
  360. }
  361. /// <summary>
  362. /// 获取指定机器人 Id 的步进距离。
  363. /// </summary>
  364. /// <param name="id">机器人 Guid。</param>
  365. /// <returns>若找到则返回对应的步进距离,否则返回默认值 1.0。</returns>
  366. public double GetRobotStepDistance(Guid id)
  367. {
  368. lock (_sync)
  369. {
  370. var robot = Robots.FirstOrDefault(r => r.Id == id);
  371. if (robot != null)
  372. {
  373. return robot.StepDistance;
  374. }
  375. else
  376. {
  377. return 1.0;
  378. }
  379. }
  380. }
  381. #endregion
  382. #region Feeders
  383. /// <summary>
  384. /// 获取所有供料器配置的只读集合。
  385. /// </summary>
  386. /// <returns>供料器配置的只读集合。</returns>
  387. public IReadOnlyCollection<FeederInfo> GetAllFeeders() { lock (_sync) { return Feeders.ToList().AsReadOnly(); } }
  388. /// <summary>
  389. /// 根据标识获取单个供料器配置。
  390. /// </summary>
  391. /// <param name="id">供料器的 Guid 标识。</param>
  392. /// <returns>找到则返回对应的 <see cref="FeederInfo"/>,否则返回 <c>null</c>。</returns>
  393. public FeederInfo GetFeeder(Guid id) { lock (_sync) { return Feeders.FirstOrDefault(f => f.Id == id); } }
  394. /// <summary>
  395. /// 新增或更新供料器配置,操作后持久化至配置文件。
  396. /// 新增时为供料器分配连续的 FeederNo 编号。
  397. /// </summary>
  398. /// <param name="feeder">要添加或更新的供料器配置。</param>
  399. /// <returns>已添加或更新的 <see cref="FeederInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  400. public FeederInfo AddOrUpdateFeeder(FeederInfo feeder)
  401. {
  402. if (feeder == null) return null;
  403. lock (_sync)
  404. {
  405. var exist = Feeders.FirstOrDefault(f => f.Id == feeder.Id);
  406. if (exist != null)
  407. {
  408. var idx = Feeders.IndexOf(exist);
  409. Feeders[idx] = feeder;
  410. }
  411. else
  412. {
  413. feeder.FeederNo = Feeders.Count + 1;
  414. Feeders.Add(feeder);
  415. }
  416. }
  417. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  418. return feeder;
  419. }
  420. /// <summary>
  421. /// 根据标识移除供料器配置并重新编号剩余供料器。
  422. /// 操作后持久化配置文件。
  423. /// </summary>
  424. /// <param name="id">要移除的供料器 Guid。</param>
  425. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  426. public bool RemoveFeeder(Guid id)
  427. {
  428. bool result = false;
  429. lock (_sync)
  430. {
  431. var e = Feeders.FirstOrDefault(f => f.Id == id);
  432. if (e != null) result = Feeders.Remove(e);
  433. //重新编号
  434. int no = 1;
  435. //对所有供料器按FeederNo排序
  436. var sortedFeeders = Feeders.OrderBy(f => f.FeederNo).ToList();
  437. foreach (var f in sortedFeeders)
  438. {
  439. f.FeederNo = no;
  440. no++;
  441. }
  442. Feeders.Clear();
  443. foreach (var f in sortedFeeders)
  444. {
  445. Feeders.Add(f);
  446. }
  447. }
  448. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  449. return result;
  450. }
  451. /// <summary>
  452. /// 判断是否包含指定 Id 的供料器配置。
  453. /// </summary>
  454. /// <param name="id">供料器 Guid。</param>
  455. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  456. public bool ContainsFeeder(Guid id) { lock (_sync) { return Feeders.Any(f => f.Id == id); } }
  457. #endregion
  458. #region PLC
  459. /// <summary>
  460. /// 获取所有 PLC 配置的只读集合。
  461. /// </summary>
  462. /// <returns>PLC 配置的只读集合。</returns>
  463. public IReadOnlyCollection<PlcInfo> GetAllPlcs() { lock (_sync) { return Plcs.ToList().AsReadOnly(); } }
  464. /// <summary>
  465. /// 根据标识获取单个 PLC 配置。
  466. /// </summary>
  467. /// <param name="id">PLC 的 Guid 标识。</param>
  468. /// <returns>匹配的 <see cref="PlcInfo"/> 实例,找不到返回 <c>null</c>。</returns>
  469. public PlcInfo GetPlc(Guid id) { lock (_sync) { return Plcs.FirstOrDefault(p => p.Id == id); } }
  470. /// <summary>
  471. /// 新增或更新 PLC 配置,操作后持久化至配置文件;新增时分配连续 PlcNo 编号。
  472. /// </summary>
  473. /// <param name="plc">要添加或更新的 PLC 配置。</param>
  474. /// <returns>已添加或更新的 <see cref="PlcInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  475. public PlcInfo AddOrUpdatePlc(PlcInfo plc)
  476. {
  477. if (plc == null) return null;
  478. lock (_sync)
  479. {
  480. var exist = Plcs.FirstOrDefault(p => p.Id == plc.Id);
  481. if (exist != null)
  482. {
  483. var idx = Plcs.IndexOf(exist);
  484. Plcs[idx] = plc;
  485. }
  486. else
  487. {
  488. plc.PlcNo = Plcs.Count + 1;
  489. Plcs.Add(plc);
  490. }
  491. }
  492. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  493. return plc;
  494. }
  495. /// <summary>
  496. /// 根据标识移除 PLC 配置并重新编号剩余 PLC。
  497. /// 操作后持久化配置文件。
  498. /// </summary>
  499. /// <param name="id">要移除的 PLC Guid。</param>
  500. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  501. public bool RemovePlc(Guid id)
  502. {
  503. bool result = false;
  504. lock (_sync)
  505. {
  506. var e = Plcs.FirstOrDefault(p => p.Id == id);
  507. if (e != null) result = Plcs.Remove(e);
  508. //重新编号
  509. int no = 1;
  510. //对所有PLC按PlcNo排序
  511. var sortedPlcs = Plcs.OrderBy(p => p.PlcNo).ToList();
  512. foreach (var p in sortedPlcs)
  513. {
  514. p.PlcNo = no;
  515. no++;
  516. }
  517. Plcs.Clear();
  518. foreach (var p in sortedPlcs)
  519. {
  520. Plcs.Add(p);
  521. }
  522. }
  523. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  524. return result;
  525. }
  526. /// <summary>
  527. /// 判断是否包含指定 Id 的 PLC 配置。
  528. /// </summary>
  529. /// <param name="id">PLC 的 Guid。</param>
  530. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  531. public bool ContainsPlc(Guid id) { lock (_sync) { return Plcs.Any(p => p.Id == id); } }
  532. #endregion
  533. #region BgTcp
  534. /// <summary>
  535. /// 获取 BG TCP/IP 通信配置(内存对象,可能为 null)。
  536. /// </summary>
  537. /// <returns>当前的 <see cref="BgTcpIP"/> 配置对象。</returns>
  538. public BgTcpIP GetBgTcp() { lock (_sync) { return BgCommunicate; } }
  539. /// <summary>
  540. /// 设置 BG TCP/IP 通信配置(仅更新内存对象,不会自动持久化)。
  541. /// 若需持久化请调用 <see cref="SaveBgTcp"/>。
  542. /// </summary>
  543. /// <param name="cfg">新的 <see cref="BgTcpIP"/> 配置对象。</param>
  544. public void SetBgTcp(BgTcpIP cfg) { lock (_sync) { BgCommunicate = cfg; } }
  545. /// <summary>
  546. /// 将当前内存中的 BG TCP/IP 配置持久化到配置文件。
  547. /// </summary>
  548. public void SaveBgTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath); } }
  549. #endregion
  550. #region BgModbus
  551. /// <summary>
  552. /// 获取 BG Modbus TCP 通信配置(内存对象)。
  553. /// </summary>
  554. /// <returns>当前的 <see cref="BgModbusTcp"/> 配置对象。</returns>
  555. public BgModbusTcp GetBgModbusTcp() { lock (_sync) { return BgModbusCommunicate; } }
  556. /// <summary>
  557. /// 设置 BG Modbus TCP 通信配置(仅更新内存对象,不会自动持久化)。
  558. /// </summary>
  559. /// <param name="cfg">新的 <see cref="BgModbusTcp"/> 配置对象。</param>
  560. public void SetBgModbusTcp(BgModbusTcp cfg) { lock (_sync) { BgModbusCommunicate = cfg; } }
  561. /// <summary>
  562. /// 将当前内存中的 BG Modbus TCP 配置持久化到配置文件。
  563. /// </summary>
  564. public void SaveBgModbusTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath); } }
  565. #endregion
  566. #region 系统参数
  567. /// <summary>
  568. /// 获取系统设置(从配置文件读取)。
  569. /// 线程安全:方法内部加锁以保证读取一致性。
  570. /// </summary>
  571. /// <returns>读取到的 <see cref="SystemConfiguration"/> 对象;若文件不存在则返回默认的新实例。</returns>
  572. public SystemConfiguration GetSystemConfiguration()
  573. {
  574. lock (_sync)
  575. {
  576. var config = new SystemConfiguration();
  577. if (File.Exists(ConfigPaths.SystemConfigurationPath))
  578. {
  579. config = FileHelper.ReadJsonFile<SystemConfiguration>(ConfigPaths.SystemConfigurationPath);
  580. }
  581. return config;
  582. }
  583. }
  584. /// <summary>
  585. /// 保存系统设置到配置文件(会覆盖现有文件)。
  586. /// </summary>
  587. /// <param name="systemConfiguration">要保存的系统配置对象。</param>
  588. public void SaveSystemConfiguration(SystemConfiguration systemConfiguration)
  589. {
  590. lock (_sync)
  591. {
  592. FileHelper.WriteJsonFile(systemConfiguration, ConfigPaths.SystemConfigurationPath);
  593. }
  594. }
  595. #endregion
  596. #region Feeder清料任务
  597. /// <summary>
  598. /// 获取所有清料任务的只读集合。
  599. /// </summary>
  600. /// <returns>清料任务的只读集合。</returns>
  601. public IReadOnlyCollection<FeederClearWork> GetAllClearanceTasks() { lock (_sync) { return FeederClearanceTasks.ToList().AsReadOnly(); } }
  602. /// <summary>
  603. /// 新增或更新清料任务,新增时为任务分配递增的 TaskCode,完成后持久化配置文件。
  604. /// </summary>
  605. /// <param name="task">要添加或更新的清料任务对象。</param>
  606. /// <returns>已添加或更新的 <see cref="FeederClearWork"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  607. public FeederClearWork AddOrUpdateClearanceTask(FeederClearWork task)
  608. {
  609. if (task == null) return null;
  610. lock (_sync)
  611. {
  612. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == task.Id);
  613. if (exist != null)
  614. {
  615. var idx = FeederClearanceTasks.IndexOf(exist);
  616. FeederClearanceTasks[idx] = task;
  617. }
  618. else
  619. {
  620. // 设置任务编号为当前最大编号加1
  621. task.TaskCode = FeederClearanceTasks.Count > 0 ? FeederClearanceTasks.Max(t => t.TaskCode) + 1 : 1;
  622. FeederClearanceTasks.Add(task);
  623. }
  624. }
  625. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  626. return task;
  627. }
  628. /// <summary>
  629. /// 根据标识移除清料任务并持久化配置文件。
  630. /// </summary>
  631. /// <param name="id">要移除的清料任务 Guid。</param>
  632. /// <returns>若找到并移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  633. public bool RemoveClearanceTask(Guid id)
  634. {
  635. lock (_sync)
  636. {
  637. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == id);
  638. if (exist != null)
  639. {
  640. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  641. return FeederClearanceTasks.Remove(exist);
  642. }
  643. else
  644. return false;
  645. }
  646. }
  647. /// <summary>
  648. /// 清除所有清料任务并持久化空集合到配置文件。
  649. /// </summary>
  650. public void ClearAllClearanceTasks()
  651. {
  652. lock (_sync)
  653. {
  654. FeederClearanceTasks.Clear();
  655. }
  656. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  657. }
  658. /// <summary>
  659. /// 判断是否包含指定 Id 的清料任务。
  660. /// </summary>
  661. /// <param name="id">清料任务 Guid。</param>
  662. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  663. public bool ContainsClearanceTask(Guid id)
  664. {
  665. lock (_sync) { return FeederClearanceTasks.Any(t => t.Id == id); }
  666. }
  667. /// <summary>
  668. /// 根据标识获取单个清料任务信息。
  669. /// </summary>
  670. /// <param name="id">清料任务 Guid。</param>
  671. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  672. public FeederClearWork GetClearanceTask(Guid id)
  673. {
  674. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.Id == id); }
  675. }
  676. /// <summary>
  677. /// 判断是否包含指定任务编号的清料任务。
  678. /// </summary>
  679. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  680. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  681. public bool ContainsClearanceTaskByNumber(int taskNumber)
  682. {
  683. lock (_sync) { return FeederClearanceTasks.Any(t => t.TaskCode == taskNumber); }
  684. }
  685. /// <summary>
  686. /// 根据任务编号获取单个清料任务信息。
  687. /// </summary>
  688. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  689. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  690. public FeederClearWork GetClearanceTaskByNumber(int taskNumber)
  691. {
  692. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.TaskCode == taskNumber); }
  693. }
  694. #endregion
  695. #region Light controllers and channels
  696. /// <summary>
  697. /// 获取所有光源控制器配置的只读集合。
  698. /// 线程安全:在内部使用 <see cref="_sync"/> 进行锁定以保证并发访问安全。
  699. /// </summary>
  700. /// <returns>按当前内存中存储顺序返回的只读 <see cref="LightControllerConfig"/> 集合。</returns>
  701. public IReadOnlyCollection<LightControllerConfig> GetAllLightControllers()
  702. {
  703. lock (_sync) { return LightControllers.ToList().AsReadOnly(); }
  704. }
  705. /// <summary>
  706. /// 根据控制器标识获取单个光源控制器配置。
  707. /// 线程安全:该方法对内存集合进行只读访问并在内部加锁。
  708. /// </summary>
  709. /// <param name="id">控制器的整数标识(Id)。</param>
  710. /// <returns>匹配的 <see cref="LightControllerConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  711. public LightControllerConfig GetLightController(int id)
  712. {
  713. lock (_sync) { return LightControllers.FirstOrDefault(c => c.Id == id); }
  714. }
  715. /// <summary>
  716. /// 新增或更新光源控制器配置。
  717. /// - 若 <paramref name="controller"/> 为 <c>null</c> 返回 <c>null</c>。
  718. /// - 更新时以 Id 匹配现有项并替换。
  719. /// - 新增时分配连续的控制器 Id,并为控制器内的每个通道分配全局通道编号(GlobalIndex)。
  720. /// 线程安全:在内部使用 <see cref="_sync"/> 锁定集合。
  721. /// </summary>
  722. /// <param name="controller">要添加或更新的 <see cref="LightControllerConfig"/> 实例。</param>
  723. /// <returns>已添加或更新的 <see cref="LightControllerConfig"/> 实例;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  724. /// <exception cref="ArgumentException">当要添加/更新的控制器名称与现有其他控制器重复时抛出。</exception>
  725. public LightControllerConfig AddOrUpdateLightController(LightControllerConfig controller)
  726. {
  727. if (controller == null) return null;
  728. lock (_sync)
  729. {
  730. // 名称不得与其他控制器重复(同名但不同 Id 不允许)
  731. if (LightControllers.Any(c => c.Name == controller.Name && c.Id != controller.Id))
  732. throw new ArgumentException("Controller name must be unique");
  733. var exist = LightControllers.FirstOrDefault(c => c.Id == controller.Id);
  734. if (exist != null)
  735. {
  736. // 更新现有控制器(按索引替换)
  737. var idx = LightControllers.IndexOf(exist);
  738. LightControllers[idx] = controller;
  739. }
  740. else
  741. {
  742. // 新增控制器
  743. // 分配控制器编号为当前最大 Id + 1(若集合为空则为 1)
  744. controller.Id = LightControllers.Count > 0 ? LightControllers.Max(c => c.Id) + 1 : 1;
  745. // 计算下一个全局通道索引:在所有已存在控制器的通道 GlobalIndex 上取最大值并加1
  746. int nextGlobal = 0;
  747. if (LightControllers.SelectMany(c => c.ChannelConfigs).Any())
  748. {
  749. nextGlobal = LightControllers.SelectMany(c => c.ChannelConfigs).Max(ch => ch.GlobalIndex) + 1;
  750. }
  751. // 遍历新增控制器的通道,若通道的 GlobalIndex 无效(<0)或与现有通道冲突,则重新分配
  752. for (int i = 0; i < controller.ChannelConfigs.Count; i++)
  753. {
  754. var ch = controller.ChannelConfigs[i];
  755. if (ch.GlobalIndex < 0 || LightControllers.SelectMany(c => c.ChannelConfigs).Any(existingCh => existingCh.GlobalIndex == ch.GlobalIndex))
  756. {
  757. ch.GlobalIndex = nextGlobal;
  758. nextGlobal++;
  759. }
  760. }
  761. LightControllers.Add(controller);
  762. }
  763. }
  764. // 持久化更新后的光源控制器配置
  765. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  766. return controller;
  767. }
  768. /// <summary>
  769. /// 根据 Id 移除光源控制器配置并对剩余控制器重新编号(从 1 开始连续编号)。
  770. /// 操作后持久化配置文件。
  771. /// </summary>
  772. /// <param name="id">要移除的控制器 Id。</param>
  773. /// <returns>如果成功移除返回 <c>true</c>,否则返回 <c>false</c>(比如未找到该 Id)。</returns>
  774. public bool RemoveLightController(int id)
  775. {
  776. bool result = false;
  777. lock (_sync)
  778. {
  779. var e = LightControllers.FirstOrDefault(c => c.Id == id);
  780. if (e != null)
  781. result = LightControllers.Remove(e);
  782. // 重新按 Id 排序并从 1 开始重新编号,以保持连续性
  783. int no = 1;
  784. var sorted = LightControllers.OrderBy(c => c.Id).ToList();
  785. foreach (var c in sorted)
  786. {
  787. c.Id = no;
  788. no++;
  789. }
  790. LightControllers.Clear();
  791. foreach (var c in sorted)
  792. {
  793. LightControllers.Add(c);
  794. }
  795. }
  796. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  797. return result;
  798. }
  799. /// <summary>
  800. /// 判断是否包含指定 Id 的光源控制器。
  801. /// </summary>
  802. /// <param name="id">控制器 Id。</param>
  803. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  804. public bool ContainsLightController(int id) { lock (_sync) { return LightControllers.Any(c => c.Id == id); } }
  805. /// <summary>
  806. /// 获取所有光源通道的只读集合,按 GlobalIndex 升序返回。
  807. /// </summary>
  808. /// <returns>按 GlobalIndex 排序的 <see cref="ChannelConfig"/> 只读集合。</returns>
  809. public IReadOnlyCollection<ChannelConfig> GetAllLightChannels()
  810. {
  811. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).OrderBy(ch => ch.GlobalIndex).ToList().AsReadOnly(); }
  812. }
  813. /// <summary>
  814. /// 根据全局通道索引获取单个通道配置。
  815. /// </summary>
  816. /// <param name="globalIndex">通道的全局索引(GlobalIndex)。</param>
  817. /// <returns>匹配的 <see cref="ChannelConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  818. public ChannelConfig GetLightChannelByGlobalIndex(int globalIndex)
  819. {
  820. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(ch => ch.GlobalIndex == globalIndex); }
  821. }
  822. /// <summary>
  823. /// 判断是否存在指定全局通道索引的通道配置。
  824. /// </summary>
  825. /// <param name="globalIndex">全局通道索引。</param>
  826. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  827. public bool ContainsLightChannelByGlobalIndex(int globalIndex)
  828. {
  829. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).Any(ch => ch.GlobalIndex == globalIndex); }
  830. }
  831. /// <summary>
  832. /// 更新指定全局通道的默认亮度(DefaultBrightness),并持久化光源控制器配置。
  833. /// </summary>
  834. /// <param name="globalIndex">目标通道的全局索引(GlobalIndex)。</param>
  835. /// <param name="brightness">要设置的亮度值。</param>
  836. /// <returns>更新成功返回 <c>true</c>;找不到对应通道返回 <c>false</c>。</returns>
  837. public bool UpdateChannelDefaultBrightness(int globalIndex, int brightness)
  838. {
  839. lock (_sync)
  840. {
  841. var ch = LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(x => x.GlobalIndex == globalIndex);
  842. if (ch == null) return false;
  843. ch.DefaultBrightness = brightness;
  844. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  845. return true;
  846. }
  847. }
  848. #endregion
  849. #region Plc Addresses
  850. public PlcAddressConfig GetPlcAddresses() { lock (_sync) { return PlcAddressConfig; } }
  851. #endregion
  852. /// <summary>
  853. /// 释放资源并保存当前内存中的所有配置到文件。
  854. /// </summary>
  855. public void Dispose()
  856. {
  857. SaveAll();
  858. GC.SuppressFinalize(this);
  859. }
  860. }
  861. }