ConfigService.cs 63 KB

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