ConfigService.cs 50 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249
  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.IO;
  8. using System.Linq;
  9. using System.Threading.Tasks;
  10. using TeamAAS_VP.Core;
  11. using TeamAAS_VP.Interfaces;
  12. using TeamAAS_VP.Models;
  13. using TeamAAS_VP.Models.Calibration;
  14. using TeamAAS_VP.Models.Feeder;
  15. using TeamAAS_VP.Models.Lights;
  16. using TeamAAS_VP.Models.PLC;
  17. using TeamAAS_VP.Models.ScrewDriver;
  18. using TeamAAS_VP.Data; // for ISystemDatabaseService (if used)
  19. using System.Threading;
  20. namespace TeamAAS_VP.Services
  21. {
  22. /// <summary>
  23. /// 配置参数服务实现类。
  24. /// 线程安全:内部使用私有锁字段 <see cref="_sync"/> 来保护对内存集合的并发访问。
  25. /// 持久化:对集合的修改会写回到对应的配置文件(路径由内部静态类 <see cref="ConfigPaths"/> 定义)。
  26. /// </summary>
  27. public class ConfigService : IConfigService
  28. {
  29. private static class ConfigPaths
  30. {
  31. // 将路径集中管理于本类,当前使用现有 FilePath 值以保持兼容
  32. public static readonly string CamerasConfigurationPath = "..//Config//CameraConfiguration.cfg";
  33. public static readonly string RobotsConfigurationPath = "..//Config//RobotsConfiguration.cfg";
  34. public static readonly string FeedersConfigurationPath = "..//Config//FeedersConfiguration.cfg";
  35. public static readonly string PlcConfigurationPath = "..//Config//PlcConfiguration.cfg";
  36. public static readonly string BgTcpIpConfigurationPath = "..//Config//BgTcpIpConfiguration.cfg";
  37. public static readonly string BgModbusTcpConfigurationPath = "..//Config//BgModbusTcpConfiguration.cfg";
  38. public static readonly string SystemConfigurationPath = "..//Config//SystemConfiguration.cfg";
  39. // Feeder清料任务配置路径
  40. public static readonly string FeederClearanceTasksConfigurationPath = "..//Config//FeederClearanceTasksConfiguration.cfg";
  41. // 光源控制器配置路径
  42. public static readonly string LightControllersConfigurationPath = "..//Config//LightControllersConfiguration.cfg";
  43. // 电批配置路径(单设备)
  44. public static readonly string ScrewDriverConfigurationPath = "..//Config//ScrewDriverConfiguration.cfg";
  45. // 螺丝供料器(物料)配置路径
  46. public static readonly string ScrewFeedersConfigurationPath = "..//Config//ScrewFeedersConfiguration.cfg";
  47. }
  48. private readonly object _sync = new object();
  49. private ObservableCollection<CameraInfo> Cameras { get; set; }
  50. private ObservableCollection<RobotInfo> Robots { get; set; }
  51. private ObservableCollection<FeederInfo> Feeders { get; set; }
  52. // 螺丝供料器(物料)集合
  53. private ObservableCollection<ScrewFeederInfo> ScrewFeeders { get; set; }
  54. private ObservableCollection<PlcInfo> Plcs { get; set; }
  55. private BgTcpIP BgCommunicate { get; set; }
  56. private BgModbusTcp BgModbusCommunicate { get; set; }
  57. private ObservableCollection<FeederClearWork> FeederClearanceTasks { get; set; }
  58. // 光源控制器配置
  59. private ObservableCollection<LightControllerConfig> LightControllers { get; set; }
  60. private PlcAddressConfig PlcAddressConfig { get; set; }
  61. // 单个电批配置
  62. private TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig _screwDriverConfig;
  63. public TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig ScrewDriverConfig { get { lock(_sync) { return _screwDriverConfig; } } }
  64. private ISystemDatabaseService _systemDatabaseService;
  65. /// <summary>
  66. /// 注入系统数据库服务(可选),用于记录螺丝批次变更等记录。
  67. /// </summary>
  68. /// <param name="svc"></param>
  69. public void SetSystemDatabaseService(ISystemDatabaseService svc)
  70. {
  71. lock (_sync)
  72. {
  73. _systemDatabaseService = svc;
  74. }
  75. }
  76. /// <summary>
  77. /// 将螺丝供料器批次变更记录写入数据库(若已注入 ISystemDatabaseService)。
  78. /// </summary>
  79. public async System.Threading.Tasks.Task RecordScrewFeederBatchAsync(ScrewFeederBatchRecord record)
  80. {
  81. if (record == null) throw new ArgumentNullException(nameof(record));
  82. try
  83. {
  84. if (_systemDatabaseService != null)
  85. {
  86. await _systemDatabaseService.RecordScrewFeederBatchAsync(record);
  87. }
  88. }
  89. catch
  90. {
  91. // 忽略数据库写入错误,记录可添加日志
  92. }
  93. }
  94. /// <summary>
  95. /// 初始化一个新的 <see cref="ConfigService"/> 实例。
  96. /// 构造函数不会自动加载配置文件(避免在构造期间进行 I/O 操作);可调用 <see cref="LoadAll"/> 或 <see cref="LoadAllAsync"/> 显式加载。
  97. /// </summary>
  98. public ConfigService()
  99. {
  100. //LoadAll();
  101. }
  102. /// <summary>
  103. /// 同步加载所有配置文件至内存(若对应文件不存在,将创建默认空集合/对象并写入文件)。
  104. /// 线程安全:方法内部对共享资源使用 <see cref="_sync"/> 加锁。
  105. /// </summary>
  106. public void LoadAll()
  107. {
  108. lock (_sync)
  109. {
  110. // 读取各配置,如果文件不存在,则保持 DeviceConfig 默认值
  111. if (File.Exists(ConfigPaths.CamerasConfigurationPath))
  112. Cameras = FileHelper.ReadJsonFile<ObservableCollection<CameraInfo>>(ConfigPaths.CamerasConfigurationPath);
  113. else
  114. {
  115. Cameras = new ObservableCollection<CameraInfo>();
  116. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  117. }
  118. if (File.Exists(ConfigPaths.RobotsConfigurationPath))
  119. Robots = FileHelper.ReadJsonFile<ObservableCollection<RobotInfo>>(ConfigPaths.RobotsConfigurationPath);
  120. else
  121. {
  122. Robots = new ObservableCollection<RobotInfo>();
  123. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  124. }
  125. if (File.Exists(ConfigPaths.FeedersConfigurationPath))
  126. Feeders = FileHelper.ReadJsonFile<ObservableCollection<FeederInfo>>(ConfigPaths.FeedersConfigurationPath);
  127. else
  128. {
  129. Feeders = new ObservableCollection<FeederInfo>();
  130. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  131. }
  132. // load screw feeders (material) configuration
  133. if (File.Exists(ConfigPaths.ScrewFeedersConfigurationPath))
  134. ScrewFeeders = FileHelper.ReadJsonFile<ObservableCollection<ScrewFeederInfo>>(ConfigPaths.ScrewFeedersConfigurationPath);
  135. else
  136. {
  137. ScrewFeeders = new ObservableCollection<ScrewFeederInfo>();
  138. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  139. }
  140. if (File.Exists(ConfigPaths.PlcConfigurationPath))
  141. Plcs = FileHelper.ReadJsonFile<ObservableCollection<PlcInfo>>(ConfigPaths.PlcConfigurationPath);
  142. else
  143. {
  144. Plcs = new ObservableCollection<PlcInfo>();
  145. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  146. }
  147. if (File.Exists(ConfigPaths.BgTcpIpConfigurationPath))
  148. BgCommunicate = FileHelper.ReadJsonFile<BgTcpIP>(ConfigPaths.BgTcpIpConfigurationPath);
  149. else
  150. {
  151. BgCommunicate = new BgTcpIP();
  152. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  153. }
  154. if (File.Exists(ConfigPaths.BgModbusTcpConfigurationPath))
  155. BgModbusCommunicate = FileHelper.ReadJsonFile<BgModbusTcp>(ConfigPaths.BgModbusTcpConfigurationPath);
  156. else
  157. {
  158. BgModbusCommunicate = new BgModbusTcp();
  159. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  160. }
  161. if (!File.Exists(ConfigPaths.FeederClearanceTasksConfigurationPath))
  162. {
  163. FeederClearanceTasks = new ObservableCollection<FeederClearWork>();
  164. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  165. }
  166. else
  167. {
  168. // 读取 Feeder清料任务 配置
  169. FeederClearanceTasks = FileHelper.ReadJsonFile<ObservableCollection<FeederClearWork>>(ConfigPaths.FeederClearanceTasksConfigurationPath);
  170. }
  171. // 读取光源控制器配置
  172. if (!File.Exists(ConfigPaths.LightControllersConfigurationPath))
  173. {
  174. LightControllers = new ObservableCollection<LightControllerConfig>();
  175. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  176. }
  177. else
  178. {
  179. LightControllers = FileHelper.ReadJsonFile<ObservableCollection<LightControllerConfig>>(ConfigPaths.LightControllersConfigurationPath);
  180. }
  181. // load plc addresses
  182. var plcAddressPath = "..//Config//PlcAddressConfiguration.cfg";
  183. if (File.Exists(plcAddressPath))
  184. PlcAddressConfig = FileHelper.ReadJsonFile<PlcAddressConfig>(plcAddressPath);
  185. else
  186. {
  187. PlcAddressConfig = new PlcAddressConfig();
  188. PlcAddressConfig.SetDefaultValue();
  189. FileHelper.WriteJsonFile(PlcAddressConfig, plcAddressPath);
  190. }
  191. // load screw driver config (single device)
  192. if (File.Exists(ConfigPaths.ScrewDriverConfigurationPath))
  193. _screwDriverConfig = FileHelper.ReadJsonFile<TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig>(ConfigPaths.ScrewDriverConfigurationPath);
  194. else
  195. {
  196. _screwDriverConfig = new TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig();
  197. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  198. }
  199. }
  200. }
  201. /// <summary>
  202. /// 异步执行 <see cref="LoadAll"/> 操作。
  203. /// </summary>
  204. /// <returns>表示异步加载操作的任务。</returns>
  205. public Task LoadAllAsync()
  206. {
  207. return Task.Run(() => LoadAll());
  208. }
  209. /// <summary>
  210. /// 将内存中的所有配置写回到对应配置文件。
  211. /// 线程安全:方法内部对写入操作使用 <see cref="_sync"/> 加锁。
  212. /// </summary>
  213. public void SaveAll()
  214. {
  215. lock (_sync)
  216. {
  217. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  218. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  219. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  220. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  221. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  222. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  223. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.ScrewDriverConfigurationPath);
  224. // save screw driver config
  225. if (_screwDriverConfig != null)
  226. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  227. // save screw feeders
  228. if (ScrewFeeders != null)
  229. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  230. // save plc addresses
  231. //FileHelper.WriteJsonFile(PlcAddressConfig, "..//Config//PlcAddressConfiguration.cfg");
  232. }
  233. }
  234. /// <summary>
  235. /// 异步执行 <see cref="SaveAll"/> 操作。
  236. /// </summary>
  237. /// <returns>表示异步保存操作的任务。</returns>
  238. public Task SaveAllAsync()
  239. {
  240. return Task.Run(() => SaveAll());
  241. }
  242. #region Cameras
  243. /// <summary>
  244. /// 获取所有相机配置的只读集合。
  245. /// 线程安全:在内部加锁以保证并发读取的一致性。
  246. /// </summary>
  247. /// <returns>相机配置的只读集合。</returns>
  248. public IReadOnlyCollection<CameraInfo> GetAllCameras()
  249. {
  250. lock (_sync) { return Cameras.ToList().AsReadOnly(); }
  251. }
  252. /// <summary>
  253. /// 根据标识获取单个相机配置信息。
  254. /// </summary>
  255. /// <param name="id">相机的 Guid 标识。</param>
  256. /// <returns>找到则返回对应的 <see cref="CameraInfo"/>,否则返回 <c>null</c>。</returns>
  257. public CameraInfo GetCamera(Guid id)
  258. {
  259. lock (_sync) { return Cameras.FirstOrDefault(c => c.Id == id); }
  260. }
  261. /// <summary>
  262. /// 新增或更新相机配置。
  263. /// - 若传入 <paramref name="camera"/> 为 <c>null</c> 返回 <c>null</c>。
  264. /// - 若 Id 已存在则替换;否则追加并设置连续的 CameraNo 编号。
  265. /// 方法结束后会将相机集合持久化到配置文件。
  266. /// </summary>
  267. /// <param name="camera">要添加或更新的相机配置。</param>
  268. /// <returns>已添加或更新的 <see cref="CameraInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  269. public CameraInfo AddOrUpdateCamera(CameraInfo camera)
  270. {
  271. if (camera == null) return null;
  272. lock (_sync)
  273. {
  274. var exist = Cameras.FirstOrDefault(c => c.Id == camera.Id);
  275. if (exist != null)
  276. {
  277. var idx = Cameras.IndexOf(exist);
  278. Cameras[idx] = camera;
  279. }
  280. else
  281. {
  282. camera.CameraNo = Cameras.Count + 1;
  283. Cameras.Add(camera);
  284. }
  285. }
  286. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  287. return camera;
  288. }
  289. /// <summary>
  290. /// 根据标识移除相机配置并重新编号剩余相机的 CameraNo。
  291. /// 方法结束后会将相机集合持久化到配置文件。
  292. /// </summary>
  293. /// <param name="id">要移除的相机 Guid。</param>
  294. /// <returns>若找到并成功移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  295. public bool RemoveCamera(Guid id)
  296. {
  297. bool result = false;
  298. lock (_sync)
  299. {
  300. var exist = Cameras.FirstOrDefault(c => c.Id == id);
  301. if (exist != null) result = Cameras.Remove(exist);
  302. //重新编号
  303. int no = 1;
  304. //对所有相机按CameraNo排序
  305. var sortedCameras = Cameras.OrderBy(c => c.CameraNo).ToList();
  306. foreach (var cam in sortedCameras)
  307. {
  308. cam.CameraNo = no;
  309. no++;
  310. }
  311. Cameras.Clear();
  312. foreach (var cam in sortedCameras)
  313. {
  314. Cameras.Add(cam);
  315. }
  316. }
  317. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  318. return result;
  319. }
  320. /// <summary>
  321. /// 检查是否包含指定 Id 的相机配置。
  322. /// </summary>
  323. /// <param name="id">相机的 Guid。</param>
  324. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  325. public bool ContainsCamera(Guid id) { lock (_sync) { return Cameras.Any(c => c.Id == id); } }
  326. #endregion
  327. #region Robots
  328. /// <summary>
  329. /// 获取所有机器人配置的只读集合。
  330. /// </summary>
  331. /// <returns>机器人配置的只读集合。</returns>
  332. public IReadOnlyCollection<RobotInfo> GetAllRobots() { lock (_sync) { return Robots.ToList().AsReadOnly(); } }
  333. /// <summary>
  334. /// 根据标识获取单个机器人配置。
  335. /// </summary>
  336. /// <param name="id">机器人的 Guid 标识。</param>
  337. /// <returns>找到则返回对应的 <see cref="RobotInfo"/>,否则返回 <c>null</c>。</returns>
  338. public RobotInfo GetRobot(Guid id) { lock (_sync) { return Robots.FirstOrDefault(r => r.Id == id); } }
  339. /// <summary>
  340. /// 新增或更新机器人配置,操作后持久化至配置文件。
  341. /// 新增时为机器人分配连续的 RobotNo 编号。
  342. /// </summary>
  343. /// <param name="robot">要添加或更新的机器人配置。</param>
  344. /// <returns>已添加或更新的 <see cref="RobotInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  345. public RobotInfo AddOrUpdateRobot(RobotInfo robot)
  346. {
  347. if (robot == null) return null;
  348. lock (_sync)
  349. {
  350. var exist = Robots.FirstOrDefault(r => r.Id == robot.Id);
  351. if (exist != null)
  352. {
  353. var idx = Robots.IndexOf(exist);
  354. Robots[idx] = robot;
  355. }
  356. else
  357. {
  358. robot.RobotNo = Robots.Count + 1;
  359. Robots.Add(robot);
  360. }
  361. }
  362. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  363. return robot;
  364. }
  365. /// <summary>
  366. /// 根据标识移除机器人配置并重新编号剩余机器人。
  367. /// 操作后持久化配置文件。
  368. /// </summary>
  369. /// <param name="id">要移除的机器人 Guid。</param>
  370. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  371. public bool RemoveRobot(Guid id)
  372. {
  373. bool result = false;
  374. lock (_sync)
  375. {
  376. var e = Robots.FirstOrDefault(r => r.Id == id);
  377. if (e != null)
  378. result = Robots.Remove(e);
  379. //重新编号
  380. int no = 1;
  381. //对所有机器人按RobotNo排序
  382. var sortedRobots = Robots.OrderBy(r => r.RobotNo).ToList();
  383. foreach (var r in sortedRobots)
  384. {
  385. r.RobotNo = no;
  386. no++;
  387. }
  388. Robots.Clear();
  389. foreach (var r in sortedRobots)
  390. {
  391. Robots.Add(r);
  392. }
  393. }
  394. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  395. return result;
  396. }
  397. /// <summary>
  398. /// 判断是否包含指定 Id 的机器人配置。
  399. /// </summary>
  400. /// <param name="id">机器人的 Guid。</param>
  401. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  402. public bool ContainsRobot(Guid id) { lock (_sync) { return Robots.Any(r => r.Id == id); } }
  403. /// <summary>
  404. /// 修改指定机器人 Id的步进距离并持久化机器人配置。
  405. /// </summary>
  406. /// <param name="id">机器人唯一标识符。</param>
  407. /// <param name="stepDistance">步进距离。</param>
  408. /// <returns>更新成功返回 <c>true</c>,找不到机器人返回 <c>false</c>。</returns>
  409. public bool UpdateRobotStepDistance(Guid id, double stepDistance)
  410. {
  411. lock (_sync)
  412. {
  413. var robot = Robots.FirstOrDefault(r => r.Id == id);
  414. if (robot != null)
  415. {
  416. robot.StepDistance = stepDistance;
  417. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  418. return true;
  419. }
  420. else
  421. {
  422. return false;
  423. }
  424. }
  425. }
  426. /// <summary>
  427. /// 获取指定机器人 Id 的步进距离。
  428. /// </summary>
  429. /// <param name="id">机器人 Guid。</param>
  430. /// <returns>若找到则返回对应的步进距离,否则返回默认值 1.0。</returns>
  431. public double GetRobotStepDistance(Guid id)
  432. {
  433. lock (_sync)
  434. {
  435. var robot = Robots.FirstOrDefault(r => r.Id == id);
  436. if (robot != null)
  437. {
  438. return robot.StepDistance;
  439. }
  440. else
  441. {
  442. return 1.0;
  443. }
  444. }
  445. }
  446. #endregion
  447. #region Feeders
  448. /// <summary>
  449. /// 获取所有供料器配置的只读集合。
  450. /// </summary>
  451. /// <returns>供料器配置的只读集合。</returns>
  452. public IReadOnlyCollection<FeederInfo> GetAllFeeders() { lock (_sync) { return Feeders.ToList().AsReadOnly(); } }
  453. /// <summary>
  454. /// 根据标识获取单个供料器配置。
  455. /// </summary>
  456. /// <param name="id">供料器的 Guid 标识。</param>
  457. /// <returns>找到则返回对应的 <see cref="FeederInfo"/>,否则返回 <c>null</c>。</returns>
  458. public FeederInfo GetFeeder(Guid id) { lock (_sync) { return Feeders.FirstOrDefault(f => f.Id == id); } }
  459. /// <summary>
  460. /// 新增或更新供料器配置,操作后持久化至配置文件。
  461. /// 新增时为供料器分配连续的 FeederNo 编号。
  462. /// </summary>
  463. /// <param name="feeder">要添加或更新的供料器配置。</param>
  464. /// <returns>已添加或更新的 <see cref="FeederInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  465. public FeederInfo AddOrUpdateFeeder(FeederInfo feeder)
  466. {
  467. if (feeder == null) return null;
  468. lock (_sync)
  469. {
  470. var exist = Feeders.FirstOrDefault(f => f.Id == feeder.Id);
  471. if (exist != null)
  472. {
  473. var idx = Feeders.IndexOf(exist);
  474. Feeders[idx] = feeder;
  475. }
  476. else
  477. {
  478. feeder.FeederNo = Feeders.Count + 1;
  479. Feeders.Add(feeder);
  480. }
  481. }
  482. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  483. return feeder;
  484. }
  485. /// <summary>
  486. /// 根据标识移除供料器配置并重新编号剩余供料器。
  487. /// 操作后持久化配置文件。
  488. /// </summary>
  489. /// <param name="id">要移除的供料器 Guid。</param>
  490. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  491. public bool RemoveFeeder(Guid id)
  492. {
  493. bool result = false;
  494. lock (_sync)
  495. {
  496. var e = Feeders.FirstOrDefault(f => f.Id == id);
  497. if (e != null) result = Feeders.Remove(e);
  498. //重新编号
  499. int no = 1;
  500. //对所有供料器按FeederNo排序
  501. var sortedFeeders = Feeders.OrderBy(f => f.FeederNo).ToList();
  502. foreach (var f in sortedFeeders)
  503. {
  504. f.FeederNo = no;
  505. no++;
  506. }
  507. Feeders.Clear();
  508. foreach (var f in sortedFeeders)
  509. {
  510. Feeders.Add(f);
  511. }
  512. }
  513. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  514. return result;
  515. }
  516. /// <summary>
  517. /// 判断是否包含指定 Id 的供料器配置。
  518. /// </summary>
  519. /// <param name="id">供料器 Guid。</param>
  520. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  521. public bool ContainsFeeder(Guid id) { lock (_sync) { return Feeders.Any(f => f.Id == id); } }
  522. #endregion
  523. #region PLC
  524. /// <summary>
  525. /// 获取所有 PLC 配置的只读集合。
  526. /// </summary>
  527. /// <returns>PLC 配置的只读集合。</returns>
  528. public IReadOnlyCollection<PlcInfo> GetAllPlcs() { lock (_sync) { return Plcs.ToList().AsReadOnly(); } }
  529. /// <summary>
  530. /// 根据标识获取单个 PLC 配置。
  531. /// </summary>
  532. /// <param name="id">PLC 的 Guid 标识。</param>
  533. /// <returns>匹配的 <see cref="PlcInfo"/> 实例,找不到返回 <c>null</c>。</returns>
  534. public PlcInfo GetPlc(Guid id) { lock (_sync) { return Plcs.FirstOrDefault(p => p.Id == id); } }
  535. /// <summary>
  536. /// 新增或更新 PLC 配置,操作后持久化至配置文件;新增时分配连续 PlcNo 编号。
  537. /// </summary>
  538. /// <param name="plc">要添加或更新的 PLC 配置。</param>
  539. /// <returns>已添加或更新的 <see cref="PlcInfo"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  540. public PlcInfo AddOrUpdatePlc(PlcInfo plc)
  541. {
  542. if (plc == null) return null;
  543. lock (_sync)
  544. {
  545. var exist = Plcs.FirstOrDefault(p => p.Id == plc.Id);
  546. if (exist != null)
  547. {
  548. var idx = Plcs.IndexOf(exist);
  549. Plcs[idx] = plc;
  550. }
  551. else
  552. {
  553. plc.PlcNo = Plcs.Count + 1;
  554. Plcs.Add(plc);
  555. }
  556. }
  557. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  558. return plc;
  559. }
  560. /// <summary>
  561. /// 根据标识移除 PLC 配置并重新编号剩余 PLC。
  562. /// 操作后持久化配置文件。
  563. /// </summary>
  564. /// <param name="id">要移除的 PLC Guid。</param>
  565. /// <returns>移除成功返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  566. public bool RemovePlc(Guid id)
  567. {
  568. bool result = false;
  569. lock (_sync)
  570. {
  571. var e = Plcs.FirstOrDefault(p => p.Id == id);
  572. if (e != null) result = Plcs.Remove(e);
  573. //重新编号
  574. int no = 1;
  575. //对所有PLC按PlcNo排序
  576. var sortedPlcs = Plcs.OrderBy(p => p.PlcNo).ToList();
  577. foreach (var p in sortedPlcs)
  578. {
  579. p.PlcNo = no;
  580. no++;
  581. }
  582. Plcs.Clear();
  583. foreach (var p in sortedPlcs)
  584. {
  585. Plcs.Add(p);
  586. }
  587. }
  588. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  589. return result;
  590. }
  591. /// <summary>
  592. /// 判断是否包含指定 Id 的 PLC 配置。
  593. /// </summary>
  594. /// <param name="id">PLC 的 Guid。</param>
  595. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  596. public bool ContainsPlc(Guid id) { lock (_sync) { return Plcs.Any(p => p.Id == id); } }
  597. #endregion
  598. #region BgTcp
  599. /// <summary>
  600. /// 获取 BG TCP/IP 通信配置(内存对象,可能为 null)。
  601. /// </summary>
  602. /// <returns>当前的 <see cref="BgTcpIP"/> 配置对象。</returns>
  603. public BgTcpIP GetBgTcp() { lock (_sync) { return BgCommunicate; } }
  604. /// <summary>
  605. /// 设置 BG TCP/IP 通信配置(仅更新内存对象,不会自动持久化)。
  606. /// 若需持久化请调用 <see cref="SaveBgTcp"/>。
  607. /// </summary>
  608. /// <param name="cfg">新的 <see cref="BgTcpIP"/> 配置对象。</param>
  609. public void SetBgTcp(BgTcpIP cfg) { lock (_sync) { BgCommunicate = cfg; } }
  610. /// <summary>
  611. /// 将当前内存中的 BG TCP/IP 配置持久化到配置文件。
  612. /// </summary>
  613. public void SaveBgTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath); } }
  614. #endregion
  615. #region BgModbus
  616. /// <summary>
  617. /// 获取 BG Modbus TCP 通信配置(内存对象)。
  618. /// </summary>
  619. /// <returns>当前的 <see cref="BgModbusTcp"/> 配置对象。</returns>
  620. public BgModbusTcp GetBgModbusTcp() { lock (_sync) { return BgModbusCommunicate; } }
  621. /// <summary>
  622. /// 设置 BG Modbus TCP 通信配置(仅更新内存对象,不会自动持久化)。
  623. /// </summary>
  624. /// <param name="cfg">新的 <see cref="BgModbusTcp"/> 配置对象。</param>
  625. public void SetBgModbusTcp(BgModbusTcp cfg) { lock (_sync) { BgModbusCommunicate = cfg; } }
  626. /// <summary>
  627. /// 将当前内存中的 BG Modbus TCP 配置持久化到配置文件。
  628. /// </summary>
  629. public void SaveBgModbusTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath); } }
  630. #endregion
  631. #region 系统参数
  632. /// <summary>
  633. /// 获取系统设置(从配置文件读取)。
  634. /// 线程安全:方法内部加锁以保证读取一致性。
  635. /// </summary>
  636. /// <returns>读取到的 <see cref="SystemConfiguration"/> 对象;若文件不存在则返回默认的新实例。</returns>
  637. public SystemConfiguration GetSystemConfiguration()
  638. {
  639. lock (_sync)
  640. {
  641. var config = new SystemConfiguration();
  642. if (File.Exists(ConfigPaths.SystemConfigurationPath))
  643. {
  644. config = FileHelper.ReadJsonFile<SystemConfiguration>(ConfigPaths.SystemConfigurationPath);
  645. }
  646. return config;
  647. }
  648. }
  649. /// <summary>
  650. /// 保存系统设置到配置文件(会覆盖现有文件)。
  651. /// </summary>
  652. /// <param name="systemConfiguration">要保存的系统配置对象。</param>
  653. public void SaveSystemConfiguration(SystemConfiguration systemConfiguration)
  654. {
  655. lock (_sync)
  656. {
  657. FileHelper.WriteJsonFile(systemConfiguration, ConfigPaths.SystemConfigurationPath);
  658. }
  659. }
  660. #endregion
  661. #region Feeder清料任务
  662. /// <summary>
  663. /// 获取所有清料任务的只读集合。
  664. /// </summary>
  665. /// <returns>清料任务的只读集合。</returns>
  666. public IReadOnlyCollection<FeederClearWork> GetAllClearanceTasks() { lock (_sync) { return FeederClearanceTasks.ToList().AsReadOnly(); } }
  667. /// <summary>
  668. /// 新增或更新清料任务,新增时为任务分配递增的 TaskCode,完成后持久化配置文件。
  669. /// </summary>
  670. /// <param name="task">要添加或更新的清料任务对象。</param>
  671. /// <returns>已添加或更新的 <see cref="FeederClearWork"/>;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  672. public FeederClearWork AddOrUpdateClearanceTask(FeederClearWork task)
  673. {
  674. if (task == null) return null;
  675. lock (_sync)
  676. {
  677. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == task.Id);
  678. if (exist != null)
  679. {
  680. var idx = FeederClearanceTasks.IndexOf(exist);
  681. FeederClearanceTasks[idx] = task;
  682. }
  683. else
  684. {
  685. // 设置任务编号为当前最大编号加1
  686. task.TaskCode = FeederClearanceTasks.Count > 0 ? FeederClearanceTasks.Max(t => t.TaskCode) + 1 : 1;
  687. FeederClearanceTasks.Add(task);
  688. }
  689. }
  690. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  691. return task;
  692. }
  693. /// <summary>
  694. /// 根据标识移除清料任务并持久化配置文件。
  695. /// </summary>
  696. /// <param name="id">要移除的清料任务 Guid。</param>
  697. /// <returns>若找到并移除返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  698. public bool RemoveClearanceTask(Guid id)
  699. {
  700. lock (_sync)
  701. {
  702. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == id);
  703. if (exist != null)
  704. {
  705. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  706. return FeederClearanceTasks.Remove(exist);
  707. }
  708. else
  709. return false;
  710. }
  711. }
  712. /// <summary>
  713. /// 清除所有清料任务并持久化空集合到配置文件。
  714. /// </summary>
  715. public void ClearAllClearanceTasks()
  716. {
  717. lock (_sync)
  718. {
  719. FeederClearanceTasks.Clear();
  720. }
  721. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  722. }
  723. /// <summary>
  724. /// 判断是否包含指定 Id 的清料任务。
  725. /// </summary>
  726. /// <param name="id">清料任务 Guid。</param>
  727. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  728. public bool ContainsClearanceTask(Guid id)
  729. {
  730. lock (_sync) { return FeederClearanceTasks.Any(t => t.Id == id); }
  731. }
  732. /// <summary>
  733. /// 根据标识获取单个清料任务信息。
  734. /// </summary>
  735. /// <param name="id">清料任务 Guid。</param>
  736. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  737. public FeederClearWork GetClearanceTask(Guid id)
  738. {
  739. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.Id == id); }
  740. }
  741. /// <summary>
  742. /// 判断是否包含指定任务编号的清料任务。
  743. /// </summary>
  744. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  745. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  746. public bool ContainsClearanceTaskByNumber(int taskNumber)
  747. {
  748. lock (_sync) { return FeederClearanceTasks.Any(t => t.TaskCode == taskNumber); }
  749. }
  750. /// <summary>
  751. /// 根据任务编号获取单个清料任务信息。
  752. /// </summary>
  753. /// <param name="taskNumber">任务编号(TaskCode)。</param>
  754. /// <returns>匹配的 <see cref="FeederClearWork"/>,找不到返回 <c>null</c>。</returns>
  755. public FeederClearWork GetClearanceTaskByNumber(int taskNumber)
  756. {
  757. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.TaskCode == taskNumber); }
  758. }
  759. #endregion
  760. #region Light controllers and channels
  761. /// <summary>
  762. /// 获取所有光源控制器配置的只读集合。
  763. /// 线程安全:在内部使用 <see cref="_sync"/> 进行锁定以保证并发访问安全。
  764. /// </summary>
  765. /// <returns>按当前内存中存储顺序返回的只读 <see cref="LightControllerConfig"/> 集合。</returns>
  766. public IReadOnlyCollection<LightControllerConfig> GetAllLightControllers()
  767. {
  768. lock (_sync) { return LightControllers.ToList().AsReadOnly(); }
  769. }
  770. /// <summary>
  771. /// 根据控制器标识获取单个光源控制器配置。
  772. /// 线程安全:该方法对内存集合进行只读访问并在内部加锁。
  773. /// </summary>
  774. /// <param name="id">控制器的整数标识(Id)。</param>
  775. /// <returns>匹配的 <see cref="LightControllerConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  776. public LightControllerConfig GetLightController(int id)
  777. {
  778. lock (_sync) { return LightControllers.FirstOrDefault(c => c.Id == id); }
  779. }
  780. /// <summary>
  781. /// 新增或更新光源控制器配置。
  782. /// - 若 <paramref name="controller"/> 为 <c>null</c> 返回 <c>null</c>。
  783. /// - 更新时以 Id 匹配现有项并替换。
  784. /// - 新增时分配连续的控制器 Id,并为控制器内的每个通道分配全局通道编号(GlobalIndex)。
  785. /// 线程安全:在内部使用 <see cref="_sync"/> 锁定集合。
  786. /// </summary>
  787. /// <param name="controller">要添加或更新的 <see cref="LightControllerConfig"/> 实例。</param>
  788. /// <returns>已添加或更新的 <see cref="LightControllerConfig"/> 实例;输入为 <c>null</c> 时返回 <c>null</c>。</returns>
  789. /// <exception cref="ArgumentException">当要添加/更新的控制器名称与现有其他控制器重复时抛出。</exception>
  790. public LightControllerConfig AddOrUpdateLightController(LightControllerConfig controller)
  791. {
  792. if (controller == null) return null;
  793. lock (_sync)
  794. {
  795. // 名称不得与其他控制器重复(同名但不同 Id 不允许)
  796. if (LightControllers.Any(c => c.Name == controller.Name && c.Id != controller.Id))
  797. throw new ArgumentException("Controller name must be unique");
  798. var exist = LightControllers.FirstOrDefault(c => c.Id == controller.Id);
  799. if (exist != null)
  800. {
  801. // 更新现有控制器(按索引替换)
  802. var idx = LightControllers.IndexOf(exist);
  803. LightControllers[idx] = controller;
  804. }
  805. else
  806. {
  807. // 新增控制器
  808. // 分配控制器编号为当前最大 Id + 1(若集合为空则为 1)
  809. controller.Id = LightControllers.Count > 0 ? LightControllers.Max(c => c.Id) + 1 : 1;
  810. // 计算下一个全局通道索引:在所有已存在控制器的通道 GlobalIndex 上取最大值并加1
  811. int nextGlobal = 0;
  812. if (LightControllers.SelectMany(c => c.ChannelConfigs).Any())
  813. {
  814. nextGlobal = LightControllers.SelectMany(c => c.ChannelConfigs).Max(ch => ch.GlobalIndex) + 1;
  815. }
  816. // 遍历新增控制器的通道,若通道的 GlobalIndex 无效(<0)或与现有通道冲突,则重新分配
  817. for (int i = 0; i < controller.ChannelConfigs.Count; i++)
  818. {
  819. var ch = controller.ChannelConfigs[i];
  820. if (ch.GlobalIndex < 0 || LightControllers.SelectMany(c => c.ChannelConfigs).Any(existingCh => existingCh.GlobalIndex == ch.GlobalIndex))
  821. {
  822. ch.GlobalIndex = nextGlobal;
  823. nextGlobal++;
  824. }
  825. }
  826. LightControllers.Add(controller);
  827. }
  828. }
  829. // 持久化更新后的光源控制器配置
  830. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  831. return controller;
  832. }
  833. /// <summary>
  834. /// 根据 Id 移除光源控制器配置并对剩余控制器重新编号(从 1 开始连续编号)。
  835. /// 操作后持久化配置文件。
  836. /// </summary>
  837. /// <param name="id">要移除的控制器 Id。</param>
  838. /// <returns>如果成功移除返回 <c>true</c>,否则返回 <c>false</c>(比如未找到该 Id)。</returns>
  839. public bool RemoveLightController(int id)
  840. {
  841. bool result = false;
  842. lock (_sync)
  843. {
  844. var e = LightControllers.FirstOrDefault(c => c.Id == id);
  845. if (e != null)
  846. result = LightControllers.Remove(e);
  847. // 重新按 Id 排序并从 1 开始重新编号,以保持连续性
  848. int no = 1;
  849. var sorted = LightControllers.OrderBy(c => c.Id).ToList();
  850. foreach (var c in sorted)
  851. {
  852. c.Id = no;
  853. no++;
  854. }
  855. LightControllers.Clear();
  856. foreach (var c in sorted)
  857. {
  858. LightControllers.Add(c);
  859. }
  860. }
  861. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  862. return result;
  863. }
  864. /// <summary>
  865. /// 判断是否包含指定 Id 的光源控制器。
  866. /// </summary>
  867. /// <param name="id">控制器 Id。</param>
  868. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  869. public bool ContainsLightController(int id) { lock (_sync) { return LightControllers.Any(c => c.Id == id); } }
  870. /// <summary>
  871. /// 获取所有光源通道的只读集合,按 GlobalIndex 升序返回。
  872. /// </summary>
  873. /// <returns>按 GlobalIndex 排序的 <see cref="ChannelConfig"/> 只读集合。</returns>
  874. public IReadOnlyCollection<ChannelConfig> GetAllLightChannels()
  875. {
  876. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).OrderBy(ch => ch.GlobalIndex).ToList().AsReadOnly(); }
  877. }
  878. /// <summary>
  879. /// 根据全局通道索引获取单个通道配置。
  880. /// </summary>
  881. /// <param name="globalIndex">通道的全局索引(GlobalIndex)。</param>
  882. /// <returns>匹配的 <see cref="ChannelConfig"/> 实例,找不到则返回 <c>null</c>。</returns>
  883. public ChannelConfig GetLightChannelByGlobalIndex(int globalIndex)
  884. {
  885. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(ch => ch.GlobalIndex == globalIndex); }
  886. }
  887. /// <summary>
  888. /// 判断是否存在指定全局通道索引的通道配置。
  889. /// </summary>
  890. /// <param name="globalIndex">全局通道索引。</param>
  891. /// <returns>存在返回 <c>true</c>,否则返回 <c>false</c>。</returns>
  892. public bool ContainsLightChannelByGlobalIndex(int globalIndex)
  893. {
  894. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).Any(ch => ch.GlobalIndex == globalIndex); }
  895. }
  896. /// <summary>
  897. /// 更新指定全局通道的默认亮度(DefaultBrightness),并持久化光源控制器配置。
  898. /// </summary>
  899. /// <param name="globalIndex">目标通道的全局索引(GlobalIndex)。</param>
  900. /// <param name="brightness">要设置的亮度值。</param>
  901. /// <returns>更新成功返回 <c>true</c>;找不到对应通道返回 <c>false</c>。</returns>
  902. public bool UpdateChannelDefaultBrightness(int globalIndex, int brightness)
  903. {
  904. lock (_sync)
  905. {
  906. var ch = LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(x => x.GlobalIndex == globalIndex);
  907. if (ch == null) return false;
  908. ch.DefaultBrightness = brightness;
  909. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  910. return true;
  911. }
  912. }
  913. #endregion
  914. #region Plc Addresses
  915. public PlcAddressConfig GetPlcAddresses() { lock (_sync) { return PlcAddressConfig; } }
  916. #endregion
  917. #region ScrewDriver config (single device)
  918. /// <summary>
  919. /// 获取电批配置(单设备)。
  920. /// </summary>
  921. /// <returns>当前的 <see cref="ScrewDriverConfig"/>,若未加载则返回 null。</returns>
  922. public ScrewDriverConfig GetScrewDriverConfig()
  923. {
  924. lock (_sync) { return _screwDriverConfig; }
  925. }
  926. /// <summary>
  927. /// 设置并持久化电批配置(单设备)。
  928. /// </summary>
  929. /// <param name="cfg">新的配置对象,不能为空。</param>
  930. public void SetScrewDriverConfig(ScrewDriverConfig cfg)
  931. {
  932. if (cfg == null) throw new ArgumentNullException(nameof(cfg));
  933. lock (_sync)
  934. {
  935. _screwDriverConfig = cfg;
  936. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  937. }
  938. }
  939. /// <summary>
  940. /// 仅将当前内存中的电批配置保存到文件。
  941. /// </summary>
  942. public void SaveScrewDriverConfig()
  943. {
  944. lock (_sync)
  945. {
  946. if (_screwDriverConfig != null)
  947. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  948. }
  949. }
  950. #endregion
  951. #region Screw Feeders (material)
  952. /// <summary>
  953. /// 获取所有螺丝供料器配置的只读集合。
  954. /// </summary>
  955. public IReadOnlyCollection<ScrewFeederInfo> GetAllScrewFeeders() { lock (_sync) { return ScrewFeeders.ToList().AsReadOnly(); } }
  956. /// <summary>
  957. /// 根据 Id 获取单个螺丝供料器配置。
  958. /// </summary>
  959. public ScrewFeederInfo GetScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.FirstOrDefault(s => s.Id == id); } }
  960. /// <summary>
  961. /// 新增或更新螺丝供料器配置。
  962. /// 新增时若未指定 FeederNumber 则分配为当前数量+1。
  963. /// </summary>
  964. public ScrewFeederInfo AddOrUpdateScrewFeeder(ScrewFeederInfo feeder)
  965. {
  966. if (feeder == null) return null;
  967. lock (_sync)
  968. {
  969. var exist = ScrewFeeders.FirstOrDefault(f => f.Id == feeder.Id);
  970. if (exist != null)
  971. {
  972. var idx = ScrewFeeders.IndexOf(exist);
  973. ScrewFeeders[idx] = feeder;
  974. }
  975. else
  976. {
  977. if (feeder.FeederNumber <= 0) feeder.FeederNumber = ScrewFeeders.Count + 1;
  978. ScrewFeeders.Add(feeder);
  979. }
  980. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  981. }
  982. return feeder;
  983. }
  984. /// <summary>
  985. /// 移除螺丝供料器配置。
  986. /// </summary>
  987. public bool RemoveScrewFeeder(Guid id)
  988. {
  989. bool result = false;
  990. lock (_sync)
  991. {
  992. var e = ScrewFeeders.FirstOrDefault(s => s.Id == id);
  993. if (e != null) result = ScrewFeeders.Remove(e);
  994. }
  995. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  996. return result;
  997. }
  998. public bool ContainsScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.Any(s => s.Id == id); } }
  999. // event for low level alarm
  1000. public event Action<ScrewFeederInfo> ScrewFeederLowLevelAlarmTriggered;
  1001. /// <summary>
  1002. /// 获取指定供料器编号的剩余螺丝数量(找不到返回 -1)
  1003. /// </summary>
  1004. public int GetRemainingCountByFeederNumber(int feederNumber)
  1005. {
  1006. lock (_sync)
  1007. {
  1008. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1009. if (f == null) return -1;
  1010. return f.RemainingCount;
  1011. }
  1012. }
  1013. /// <summary>
  1014. /// 获取指定供料器编号的低量报警状态(找不到返回 false)
  1015. /// </summary>
  1016. public bool GetLowLevelAlarmStatusByFeederNumber(int feederNumber)
  1017. {
  1018. lock (_sync)
  1019. {
  1020. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1021. if (f == null) return false;
  1022. return f.IsLowLevelAlarmActive;
  1023. }
  1024. }
  1025. // helper: check and raise low level alarm when necessary
  1026. private void CheckAndTriggerLowLevelAlarm(ScrewFeederInfo f)
  1027. {
  1028. if (f == null) return;
  1029. if (f.LowLevelAlarmEnabled && f.RemainingCount <= f.LowLevelThreshold)
  1030. {
  1031. if (!f.IsLowLevelAlarmActive)
  1032. {
  1033. f.IsLowLevelAlarmActive = true;
  1034. try
  1035. {
  1036. ScrewFeederLowLevelAlarmTriggered?.Invoke(f.Clone());
  1037. }
  1038. catch { }
  1039. }
  1040. }
  1041. else
  1042. {
  1043. if (f.IsLowLevelAlarmActive)
  1044. {
  1045. f.IsLowLevelAlarmActive = false;
  1046. }
  1047. }
  1048. }
  1049. /// <summary>
  1050. /// 为指定供料器编号递减指定数量,若数量不足返回 false
  1051. /// </summary>
  1052. public bool DecrementScrewCountByFeederNumber(int feederNumber, int decrement = 1)
  1053. {
  1054. lock (_sync)
  1055. {
  1056. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1057. if (f == null) return false;
  1058. if (decrement <= 0) decrement = 1;
  1059. if (f.RemainingCount < decrement) return false;
  1060. f.RemainingCount -= decrement;
  1061. // check alarm
  1062. CheckAndTriggerLowLevelAlarm(f);
  1063. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1064. return true;
  1065. }
  1066. }
  1067. /// <summary>
  1068. /// 清除指定供料器编号的螺丝信息(批次号置空,剩余数量置0)
  1069. /// </summary>
  1070. public void ClearScrewFeederByNumber(int feederNumber)
  1071. {
  1072. lock (_sync)
  1073. {
  1074. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1075. if (f == null) return;
  1076. f.BatchNumber = string.Empty;
  1077. f.RemainingCount = 0;
  1078. // check alarm
  1079. CheckAndTriggerLowLevelAlarm(f);
  1080. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1081. }
  1082. }
  1083. /// <summary>
  1084. /// 为指定供料器编号设置批次号,并在原有剩余数量上增加一包(PackSize)
  1085. /// </summary>
  1086. public void SetBatchForFeederNumber(int feederNumber, string batchNumber)
  1087. {
  1088. if (string.IsNullOrWhiteSpace(batchNumber)) return;
  1089. // capture values under lock, then record to DB outside lock
  1090. ScrewFeederInfo target = null;
  1091. int remainingAfter = 0;
  1092. int packSize = 0;
  1093. string feederName = null;
  1094. lock (_sync)
  1095. {
  1096. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1097. if (f == null) return;
  1098. f.BatchNumber = batchNumber;
  1099. f.RemainingCount += Math.Max(0, f.PackSize);
  1100. // prepare capture values
  1101. target = f;
  1102. remainingAfter = f.RemainingCount;
  1103. packSize = f.PackSize;
  1104. feederName = f.Name;
  1105. // check alarm
  1106. CheckAndTriggerLowLevelAlarm(f);
  1107. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1108. }
  1109. try
  1110. {
  1111. var record = new ScrewFeederBatchRecord
  1112. {
  1113. BatchNumber = batchNumber,
  1114. PackSize = packSize,
  1115. ChangeTime = DateTime.UtcNow,
  1116. RemainingCount = remainingAfter,
  1117. FeederNumber = feederNumber,
  1118. FeederName = feederName
  1119. };
  1120. // try get operator name from system database service if available
  1121. try
  1122. {
  1123. var user = _systemDatabaseService?.GetCurrentUser();
  1124. if (user != null)
  1125. record.OperatorName = user.UserName;
  1126. }
  1127. catch
  1128. {
  1129. // ignore getting user failure
  1130. }
  1131. // fire-and-forget recording (ConfigService will forward to DB service if set)
  1132. _ = RecordScrewFeederBatchAsync(record);
  1133. }
  1134. catch
  1135. {
  1136. // ignore any error creating/recording the batch record
  1137. }
  1138. }
  1139. #endregion
  1140. /// <summary>
  1141. /// 释放资源并保存当前内存中的所有配置到文件。
  1142. /// </summary>
  1143. public void Dispose()
  1144. {
  1145. SaveAll();
  1146. GC.SuppressFinalize(this);
  1147. }
  1148. }
  1149. }