ConfigService.cs 59 KB

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