ConfigService.cs 63 KB

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