ConfigService.cs 60 KB

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