ConfigService.cs 37 KB

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