ConfigService.cs 50 KB

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