ConfigService.cs 80 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803
  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.Core.Robots;
  14. using TeamAAS_VP.Data; // for ISystemDatabaseService (if used)
  15. using TeamAAS_VP.Enums;
  16. using TeamAAS_VP.Interfaces;
  17. using TeamAAS_VP.Models;
  18. using TeamAAS_VP.Models.Calibration;
  19. using TeamAAS_VP.Models.Feeder;
  20. using TeamAAS_VP.Models.Lights;
  21. using TeamAAS_VP.Models.PLC;
  22. using TeamAAS_VP.Models.ScrewDriver;
  23. using TeamAAS_VP.Models.Torque;
  24. using TeamAAS_VP.Resources.Languages;
  25. using WPFLocalizeExtension.Engine;
  26. namespace TeamAAS_VP.Services
  27. {
  28. /// <summary>
  29. /// 锟斤拷锟矫诧拷锟斤拷锟斤拷锟斤拷实锟斤拷锟洁。
  30. /// 锟竭程帮拷全锟斤拷锟节诧拷使锟斤拷私锟斤拷锟斤拷锟街讹拷 <see cref="_sync"/> 锟斤拷锟斤拷锟斤拷锟斤拷锟节存集锟较的诧拷锟斤拷锟斤拷锟绞★拷
  31. /// 锟街久伙拷锟斤拷锟皆硷拷锟较碉拷锟睫改伙拷写锟截碉拷锟斤拷应锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷路锟斤拷锟斤拷锟节诧拷锟斤拷态锟斤拷 <see cref="ConfigPaths"/> 锟斤拷锟藉)锟斤拷
  32. /// </summary>
  33. public class ConfigService : IConfigService
  34. {
  35. private static class ConfigPaths
  36. {
  37. // 锟斤拷路锟斤拷锟斤拷锟叫癸拷锟斤拷锟节憋拷锟洁,锟斤拷前使锟斤拷锟斤拷锟斤拷 FilePath 值锟皆憋拷锟街硷拷锟斤拷
  38. public static readonly string CamerasConfigurationPath = "..//Config//CameraConfiguration.cfg";
  39. public static readonly string RobotsConfigurationPath = "..//Config//RobotsConfiguration.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. // 锟斤拷丝锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟较o拷锟斤拷锟斤拷路锟斤拷
  53. public static readonly string ScrewFeedersConfigurationPath = "..//Config//ScrewFeedersConfiguration.cfg";
  54. // 刷锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷
  55. public static readonly string CardReaderConfigurationPath = "..//Config//CardReaderConfiguration.cfg";
  56. // 锟斤拷锟斤拷锟斤拷锟斤拷路锟斤拷
  57. public static readonly string TorqueReaderConfigurationPath = "..//Config//TorqueReaderConfiguration.cfg";
  58. public static readonly string DataConfigurationPath = "..//Config//DataConfiguration.cfg";
  59. }
  60. private readonly object _sync = new object();
  61. private ObservableCollection<CameraInfo> Cameras { get; set; }
  62. private ObservableCollection<RobotInfo> Robots { get; set; }
  63. private ObservableCollection<FeederInfo> Feeders { get; set; }
  64. // 锟斤拷丝锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟较o拷锟斤拷锟斤拷
  65. private ObservableCollection<ScrewFeederInfo> ScrewFeeders { get; set; }
  66. private ObservableCollection<PlcInfo> Plcs { get; set; }
  67. private BgTcpIP BgCommunicate { get; set; }
  68. private BgModbusTcp BgModbusCommunicate { get; set; }
  69. private ObservableCollection<FeederClearWork> FeederClearanceTasks { get; set; }
  70. // 锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
  71. private ObservableCollection<LightControllerConfig> LightControllers { get; set; }
  72. // Device info - 鏀�寔澶氳�澶?
  73. private List<DeviceInfo> _deviceInfoList;
  74. public CTQ_Data CtqData { get; set; }
  75. private PlcAddressConfig PlcAddressConfig { get; set; }
  76. // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
  77. private TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig _screwDriverConfig;
  78. public TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig ScrewDriverConfig { get { lock (_sync) { return _screwDriverConfig; } } }
  79. private ISystemDatabaseService _systemDatabaseService;
  80. // 刷锟斤拷锟斤拷锟斤拷锟斤拷
  81. private SerialPortConfig _cardReaderConfig;
  82. private TorqueSerialPortConfig _torqueReaderConfig;
  83. /// <summary>
  84. /// 注锟斤拷系统锟斤拷锟捷匡拷锟斤拷瘢ǹ锟窖★拷锟斤拷锟斤拷锟斤拷诩锟铰硷拷锟剿匡拷锟斤拷伪锟斤拷锟饺硷拷录锟斤拷
  85. /// </summary>
  86. /// <param name="svc"></param>
  87. public void SetSystemDatabaseService(ISystemDatabaseService svc)
  88. {
  89. lock (_sync)
  90. {
  91. _systemDatabaseService = svc;
  92. }
  93. }
  94. /// <summary>
  95. /// 锟斤拷始锟斤拷一锟斤拷锟铰碉拷 <see cref="ConfigService"/> 实锟斤拷锟斤拷
  96. /// 锟斤拷锟届函锟斤拷锟斤拷锟斤拷锟皆讹拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟斤拷锟斤拷锟节癸拷锟斤拷锟节硷拷锟斤拷锟?I/O 锟斤拷锟斤拷锟斤拷锟斤拷锟缴碉拷锟斤拷 <see cref="LoadAll"/> 锟斤拷 <see cref="LoadAllAsync"/> 锟斤拷式锟斤拷锟截★拷
  97. /// </summary>
  98. public ConfigService()
  99. {
  100. //LoadAll();
  101. }
  102. /// <summary>
  103. /// 同锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟节存(锟斤拷锟斤拷应锟侥硷拷锟斤拷锟斤拷锟节o拷锟斤拷锟斤拷锟斤拷默锟较空硷拷锟斤拷/锟斤拷锟斤拷写锟斤拷锟侥硷拷锟斤拷锟斤拷
  104. /// 锟竭程帮拷全锟斤拷锟斤拷锟斤拷锟节诧拷锟皆癸拷锟斤拷锟斤拷源使锟斤拷 <see cref="_sync"/> 锟斤拷锟斤拷锟斤拷
  105. /// </summary>
  106. public void LoadAll()
  107. {
  108. lock (_sync)
  109. {
  110. // 锟斤拷取锟斤拷锟斤拷锟矫o拷锟斤拷锟斤拷募锟斤拷锟斤拷锟斤拷冢锟斤拷虮3锟?DeviceConfig 默锟斤拷值
  111. if (File.Exists(ConfigPaths.CamerasConfigurationPath))
  112. Cameras = FileHelper.ReadJsonFile<ObservableCollection<CameraInfo>>(ConfigPaths.CamerasConfigurationPath);
  113. else
  114. {
  115. Cameras = new ObservableCollection<CameraInfo>();
  116. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  117. }
  118. if (File.Exists(ConfigPaths.RobotsConfigurationPath))
  119. Robots = FileHelper.ReadJsonFile<ObservableCollection<RobotInfo>>(ConfigPaths.RobotsConfigurationPath);
  120. else
  121. {
  122. Robots = new ObservableCollection<RobotInfo>();
  123. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  124. }
  125. if (File.Exists(ConfigPaths.FeedersConfigurationPath))
  126. Feeders = FileHelper.ReadJsonFile<ObservableCollection<FeederInfo>>(ConfigPaths.FeedersConfigurationPath);
  127. else
  128. {
  129. Feeders = new ObservableCollection<FeederInfo>();
  130. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  131. }
  132. // load screw feeders (material) configuration
  133. if (File.Exists(ConfigPaths.ScrewFeedersConfigurationPath))
  134. ScrewFeeders = FileHelper.ReadJsonFile<ObservableCollection<ScrewFeederInfo>>(ConfigPaths.ScrewFeedersConfigurationPath);
  135. else
  136. {
  137. ScrewFeeders = new ObservableCollection<ScrewFeederInfo>();
  138. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  139. }
  140. if (File.Exists(ConfigPaths.PlcConfigurationPath))
  141. Plcs = FileHelper.ReadJsonFile<ObservableCollection<PlcInfo>>(ConfigPaths.PlcConfigurationPath);
  142. else
  143. {
  144. Plcs = new ObservableCollection<PlcInfo>();
  145. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  146. }
  147. if (File.Exists(ConfigPaths.BgTcpIpConfigurationPath))
  148. BgCommunicate = FileHelper.ReadJsonFile<BgTcpIP>(ConfigPaths.BgTcpIpConfigurationPath);
  149. else
  150. {
  151. BgCommunicate = new BgTcpIP();
  152. FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath);
  153. }
  154. if (File.Exists(ConfigPaths.BgModbusTcpConfigurationPath))
  155. BgModbusCommunicate = FileHelper.ReadJsonFile<BgModbusTcp>(ConfigPaths.BgModbusTcpConfigurationPath);
  156. else
  157. {
  158. BgModbusCommunicate = new BgModbusTcp();
  159. FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath);
  160. }
  161. if (!File.Exists(ConfigPaths.FeederClearanceTasksConfigurationPath))
  162. {
  163. FeederClearanceTasks = new ObservableCollection<FeederClearWork>();
  164. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  165. }
  166. else
  167. {
  168. // 锟斤拷取 Feeder锟斤拷锟斤拷锟斤拷锟斤拷 锟斤拷锟斤拷
  169. FeederClearanceTasks = FileHelper.ReadJsonFile<ObservableCollection<FeederClearWork>>(ConfigPaths.FeederClearanceTasksConfigurationPath);
  170. }
  171. // 锟斤拷取锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
  172. if (!File.Exists(ConfigPaths.LightControllersConfigurationPath))
  173. {
  174. LightControllers = new ObservableCollection<LightControllerConfig>();
  175. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  176. }
  177. else
  178. {
  179. LightControllers = FileHelper.ReadJsonFile<ObservableCollection<LightControllerConfig>>(ConfigPaths.LightControllersConfigurationPath);
  180. }
  181. // load plc addresses
  182. var plcAddressPath = "..//Config//PlcAddressConfiguration.cfg";
  183. if (File.Exists(plcAddressPath))
  184. PlcAddressConfig = FileHelper.ReadJsonFile<PlcAddressConfig>(plcAddressPath);
  185. else
  186. {
  187. PlcAddressConfig = new PlcAddressConfig();
  188. PlcAddressConfig.SetDefaultValue();
  189. FileHelper.WriteJsonFile(PlcAddressConfig, plcAddressPath);
  190. }
  191. // load screw driver config (single device)
  192. if (File.Exists(ConfigPaths.ScrewDriverConfigurationPath))
  193. _screwDriverConfig = FileHelper.ReadJsonFile<TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig>(ConfigPaths.ScrewDriverConfigurationPath);
  194. else
  195. {
  196. _screwDriverConfig = new TeamAAS_VP.Models.ScrewDriver.ScrewDriverConfig();
  197. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  198. }
  199. // load device info list (鏀�寔澶氳�澶?
  200. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  201. {
  202. try
  203. {
  204. // 灏濊瘯浣滀负鍒楄〃璇诲彇
  205. _deviceInfoList = FileHelper.ReadJsonFile<List<DeviceInfo>>(ConfigPaths.DeviceInfoConfigurationPath);
  206. }
  207. catch
  208. {
  209. // 鍏煎�鏃х増鍗曚釜 DeviceInfo锛屽皢鍏惰浆鎹�负鍒楄〃
  210. var singleDevice = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  211. if (singleDevice != null)
  212. {
  213. singleDevice.DeviceNo = 0;
  214. _deviceInfoList = new List<DeviceInfo> { singleDevice };
  215. }
  216. else
  217. {
  218. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  219. }
  220. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  221. }
  222. }
  223. else
  224. {
  225. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  226. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  227. }
  228. // load card reader configuration
  229. if (File.Exists(ConfigPaths.CardReaderConfigurationPath))
  230. _cardReaderConfig = FileHelper.ReadJsonFile<SerialPortConfig>(ConfigPaths.CardReaderConfigurationPath);
  231. else
  232. {
  233. _cardReaderConfig = new SerialPortConfig();
  234. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  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 list (鏀�寔澶氳�澶?
  271. if (_deviceInfoList != null)
  272. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  273. // save card reader config
  274. if (_cardReaderConfig != null)
  275. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  276. }
  277. }
  278. /// <summary>
  279. /// 锟届步执锟斤拷 <see cref="SaveAll"/> 锟斤拷锟斤拷锟斤拷
  280. /// </summary>
  281. /// <returns>锟斤拷示锟届步锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟?/returns>
  282. public Task SaveAllAsync()
  283. {
  284. return Task.Run(() => SaveAll());
  285. }
  286. #region Cameras
  287. /// <summary>
  288. /// 锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷玫锟街伙拷锟斤拷锟斤拷稀锟?
  289. /// 锟竭程帮拷全锟斤拷锟斤拷锟节诧拷锟斤拷锟斤拷锟皆憋拷证锟斤拷锟斤拷锟斤拷取锟斤拷一锟斤拷锟皆★拷
  290. /// </summary>
  291. /// <returns>锟斤拷锟斤拷锟斤拷玫锟街伙拷锟斤拷锟斤拷稀锟?/returns>
  292. public IReadOnlyCollection<CameraInfo> GetAllCameras()
  293. {
  294. lock (_sync) { return Cameras.ToList().AsReadOnly(); }
  295. }
  296. /// <summary>
  297. /// 锟斤拷锟捷憋拷识锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟较�拷锟?
  298. /// </summary>
  299. /// <param name="id">锟斤拷锟斤拷锟?Guid 锟斤拷识锟斤拷</param>
  300. /// <returns>锟揭碉拷锟津返回讹拷应锟斤拷 <see cref="CameraInfo"/>锟斤拷锟斤拷锟津返伙拷 <c>null</c>锟斤拷</returns>
  301. public CameraInfo GetCamera(Guid id)
  302. {
  303. lock (_sync) { return Cameras.FirstOrDefault(c => c.Id == id); }
  304. }
  305. /// <summary>
  306. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  307. /// - 锟斤拷锟斤拷锟斤拷 <paramref name="camera"/> 为 <c>null</c> 锟斤拷锟斤拷 <c>null</c>锟斤拷
  308. /// - 锟斤拷 Id 锟窖达拷锟斤拷锟斤拷锟芥换锟斤拷锟斤拷锟斤拷追锟接诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 CameraNo 锟斤拷拧锟?
  309. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷峤�拷锟斤拷锟斤拷锟较持久伙拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  310. /// </summary>
  311. /// <param name="camera">要锟斤拷锟接伙拷锟斤拷碌锟斤拷锟斤拷锟斤拷锟矫★拷</param>
  312. /// <returns>锟斤拷锟斤拷锟接伙拷锟斤拷碌锟?<see cref="CameraInfo"/>锟斤拷锟斤拷锟斤拷为 <c>null</c> 时锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  313. public CameraInfo AddOrUpdateCamera(CameraInfo camera)
  314. {
  315. if (camera == null) return null;
  316. lock (_sync)
  317. {
  318. var exist = Cameras.FirstOrDefault(c => c.Id == camera.Id);
  319. if (exist != null)
  320. {
  321. var idx = Cameras.IndexOf(exist);
  322. Cameras[idx] = camera;
  323. }
  324. else
  325. {
  326. camera.CameraNo = Cameras.Count + 1;
  327. Cameras.Add(camera);
  328. }
  329. }
  330. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  331. return camera;
  332. }
  333. /// <summary>
  334. /// 锟斤拷锟捷憋拷识锟狡筹拷锟斤拷锟斤拷锟斤拷貌锟斤拷锟斤拷卤锟斤拷剩锟斤拷锟斤拷锟斤拷锟?CameraNo锟斤拷
  335. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷峤�拷锟斤拷锟斤拷锟较持久伙拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  336. /// </summary>
  337. /// <param name="id">要锟狡筹拷锟斤拷锟斤拷锟?Guid锟斤拷</param>
  338. /// <returns>锟斤拷锟揭碉拷锟斤拷锟缴癸拷锟狡筹拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  339. public bool RemoveCamera(Guid id)
  340. {
  341. bool result = false;
  342. lock (_sync)
  343. {
  344. var exist = Cameras.FirstOrDefault(c => c.Id == id);
  345. if (exist != null) result = Cameras.Remove(exist);
  346. //锟斤拷锟铰憋拷锟?
  347. int no = 1;
  348. //锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟紺ameraNo锟斤拷锟斤拷
  349. var sortedCameras = Cameras.OrderBy(c => c.CameraNo).ToList();
  350. foreach (var cam in sortedCameras)
  351. {
  352. cam.CameraNo = no;
  353. no++;
  354. }
  355. Cameras.Clear();
  356. foreach (var cam in sortedCameras)
  357. {
  358. Cameras.Add(cam);
  359. }
  360. }
  361. FileHelper.WriteJsonFile(Cameras, ConfigPaths.CamerasConfigurationPath);
  362. return result;
  363. }
  364. /// <summary>
  365. /// 锟斤拷锟斤拷欠锟斤拷锟斤拷指锟斤拷 Id 锟斤拷锟斤拷锟斤拷锟斤拷谩锟?
  366. /// </summary>
  367. /// <param name="id">锟斤拷锟斤拷锟?Guid锟斤拷</param>
  368. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  369. public bool ContainsCamera(Guid id) { lock (_sync) { return Cameras.Any(c => c.Id == id); } }
  370. #endregion
  371. #region DeviceInfo
  372. /// <summary>
  373. /// 鑾峰彇鎵€鏈夎�澶囦俊鎭�厤缃�垪琛?
  374. /// </summary>
  375. /// <returns>璁惧�淇℃伅鍒楄〃鐨勫彧璇婚泦鍚?/returns>
  376. public IReadOnlyCollection<DeviceInfo> GetAllDeviceInfos()
  377. {
  378. lock (_sync)
  379. {
  380. if (_deviceInfoList == null)
  381. {
  382. if (File.Exists(ConfigPaths.DeviceInfoConfigurationPath))
  383. {
  384. try
  385. {
  386. _deviceInfoList = FileHelper.ReadJsonFile<List<DeviceInfo>>(ConfigPaths.DeviceInfoConfigurationPath);
  387. }
  388. catch
  389. {
  390. // 鍏煎�鏃х増鍗曚釜 DeviceInfo
  391. var singleDevice = FileHelper.ReadJsonFile<DeviceInfo>(ConfigPaths.DeviceInfoConfigurationPath);
  392. if (singleDevice != null)
  393. {
  394. singleDevice.DeviceNo = 0;
  395. _deviceInfoList = new List<DeviceInfo> { singleDevice };
  396. }
  397. else
  398. {
  399. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  400. }
  401. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  402. }
  403. }
  404. else
  405. {
  406. _deviceInfoList = new List<DeviceInfo> { new DeviceInfo { DeviceNo = 0 } };
  407. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  408. }
  409. }
  410. return _deviceInfoList.AsReadOnly();
  411. }
  412. }
  413. /// <summary>
  414. /// 鏍规嵁璁惧�缂栧彿鑾峰彇璁惧�淇℃伅锛堝吋瀹规棫API锛岃繑鍥炵�涓€涓��澶囷級
  415. /// </summary>
  416. /// <returns>璁惧�淇℃伅锛岃嫢涓嶅瓨鍦ㄥ垯鍒涘缓榛樿�璁惧�</returns>
  417. public DeviceInfo GetDeviceInfo()
  418. {
  419. return GetDeviceInfo(0);
  420. }
  421. /// <summary>
  422. /// 鏍规嵁璁惧�缂栧彿鑾峰彇璁惧�淇℃伅
  423. /// </summary>
  424. /// <param name="deviceNo">璁惧�缂栧彿</param>
  425. /// <returns>璁惧�淇℃伅锛岃嫢涓嶅瓨鍦ㄥ垯杩斿洖 null</returns>
  426. public DeviceInfo GetDeviceInfo(int deviceNo)
  427. {
  428. lock (_sync)
  429. {
  430. var allDevices = GetAllDeviceInfos();
  431. return allDevices.FirstOrDefault(d => d.DeviceNo == deviceNo);
  432. }
  433. }
  434. /// <summary>
  435. /// 娣诲姞鎴栨洿鏂拌�澶囦俊鎭?
  436. /// </summary>
  437. /// <param name="deviceInfo">璁惧�淇℃伅瀵硅薄</param>
  438. public void SaveDeviceInfo(DeviceInfo deviceInfo)
  439. {
  440. if (deviceInfo == null) return;
  441. lock (_sync)
  442. {
  443. // 纭�繚鍒楄〃宸插垵濮嬪寲
  444. if (_deviceInfoList == null)
  445. {
  446. _deviceInfoList = new List<DeviceInfo>();
  447. }
  448. // 鏌ユ壘鏄�惁宸插瓨鍦ㄧ浉鍚岃�澶囩紪鍙风殑璁惧�
  449. var existing = _deviceInfoList.FirstOrDefault(d => d.DeviceNo == deviceInfo.DeviceNo);
  450. if (existing != null)
  451. {
  452. // 鏇存柊鐜版湁璁惧�
  453. var index = _deviceInfoList.IndexOf(existing);
  454. _deviceInfoList[index] = deviceInfo;
  455. }
  456. else
  457. {
  458. // 娣诲姞鏂拌�澶?
  459. _deviceInfoList.Add(deviceInfo);
  460. }
  461. // 鎸夎�澶囩紪鍙锋帓搴?
  462. _deviceInfoList = _deviceInfoList.OrderBy(d => d.DeviceNo).ToList();
  463. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  464. }
  465. }
  466. /// <summary>
  467. /// 淇濆瓨鎵€鏈夎�澶囦俊鎭�垪琛?
  468. /// </summary>
  469. /// <param name="deviceInfoList">璁惧�淇℃伅鍒楄〃</param>
  470. public void SaveAllDeviceInfos(IEnumerable<DeviceInfo> deviceInfoList)
  471. {
  472. if (deviceInfoList == null) return;
  473. lock (_sync)
  474. {
  475. _deviceInfoList = deviceInfoList.OrderBy(d => d.DeviceNo).ToList();
  476. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  477. }
  478. }
  479. /// <summary>
  480. /// 娣诲姞鏂拌�澶?
  481. /// </summary>
  482. /// <returns>鏂版坊鍔犵殑璁惧�</returns>
  483. public DeviceInfo AddDeviceInfo()
  484. {
  485. lock (_sync)
  486. {
  487. if (_deviceInfoList == null)
  488. {
  489. _deviceInfoList = new List<DeviceInfo>();
  490. }
  491. // 璁$畻鏂拌�澶囩紪鍙?
  492. int newDeviceNo = _deviceInfoList.Count > 0 ? _deviceInfoList.Max(d => d.DeviceNo) + 1 : 0;
  493. var newDevice = new DeviceInfo { DeviceNo = newDeviceNo };
  494. _deviceInfoList.Add(newDevice);
  495. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  496. return newDevice;
  497. }
  498. }
  499. /// <summary>
  500. /// 鍒犻櫎璁惧�
  501. /// </summary>
  502. /// <param name="deviceNo">璁惧�缂栧彿</param>
  503. /// <returns>鏄�惁鍒犻櫎鎴愬姛</returns>
  504. public bool RemoveDeviceInfo(int deviceNo)
  505. {
  506. lock (_sync)
  507. {
  508. if (_deviceInfoList == null) return false;
  509. var device = _deviceInfoList.FirstOrDefault(d => d.DeviceNo == deviceNo);
  510. if (device != null)
  511. {
  512. _deviceInfoList.Remove(device);
  513. FileHelper.WriteJsonFile(_deviceInfoList, ConfigPaths.DeviceInfoConfigurationPath);
  514. return true;
  515. }
  516. return false;
  517. }
  518. }
  519. #endregion
  520. #region Robots
  521. /// <summary>
  522. /// 锟斤拷取锟斤拷锟叫伙拷锟斤拷锟斤拷锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷
  523. /// </summary>
  524. /// <returns>锟斤拷锟斤拷锟斤拷锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷</returns>
  525. public IReadOnlyCollection<RobotInfo> GetAllRobots() { lock (_sync) { return Robots.ToList().AsReadOnly(); } }
  526. /// <summary>
  527. /// 锟斤拷锟捷憋拷识锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  528. /// </summary>
  529. /// <param name="id">锟斤拷锟斤拷锟剿碉拷 Guid 锟斤拷识锟斤拷</param>
  530. /// <returns>锟揭碉拷锟津返回讹拷应锟斤拷 <see cref="RobotInfo"/>锟斤拷锟斤拷锟津返伙拷 <c>null</c>锟斤拷</returns>
  531. public RobotInfo GetRobot(Guid id) { lock (_sync) { return Robots.FirstOrDefault(r => r.Id == id); } }
  532. /// <summary>
  533. /// 锟斤拷锟斤拷锟斤拷锟斤拷禄锟斤拷锟斤拷锟斤拷锟斤拷茫锟斤拷锟斤拷锟斤拷锟街久伙拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  534. /// 锟斤拷锟斤拷时为锟斤拷锟斤拷锟剿凤拷锟斤拷锟斤拷锟斤拷锟斤拷 RobotNo 锟斤拷拧锟?
  535. /// </summary>
  536. /// <param name="robot">要锟斤拷锟接伙拷锟斤拷碌幕锟斤拷锟斤拷锟斤拷锟斤拷谩锟?/param>
  537. /// <returns>锟斤拷锟斤拷锟接伙拷锟斤拷碌锟?<see cref="RobotInfo"/>锟斤拷锟斤拷锟斤拷为 <c>null</c> 时锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  538. public RobotInfo AddOrUpdateRobot(RobotInfo robot)
  539. {
  540. if (robot == null) return null;
  541. lock (_sync)
  542. {
  543. EnsureRobotPlcAxisParameters(robot);
  544. var exist = Robots.FirstOrDefault(r => r.Id == robot.Id);
  545. if (exist != null)
  546. {
  547. var idx = Robots.IndexOf(exist);
  548. Robots[idx] = robot;
  549. }
  550. else
  551. {
  552. robot.RobotNo = Robots.Count + 1;
  553. Robots.Add(robot);
  554. }
  555. }
  556. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  557. return robot;
  558. }
  559. private static void EnsureRobotPlcAxisParameters(RobotInfo robot)
  560. {
  561. var axisNames = GetRobotAxisNames(robot.RobotBrand);
  562. if (axisNames == null) return;
  563. if (robot.PlcRobotParameter == null)
  564. robot.PlcRobotParameter = new PlcRobotParameter();
  565. var existingAxes = robot.PlcRobotParameter.AxixList ?? new List<Axis>();
  566. var axes = new List<Axis>();
  567. for (var i = 0; i < axisNames.Length; i++)
  568. {
  569. var axisName = axisNames[i];
  570. var defaultIndex = i + 1;
  571. var existingAxis = existingAxes.FirstOrDefault(a => string.Equals(a.Name, axisName, StringComparison.OrdinalIgnoreCase))
  572. ?? existingAxes.FirstOrDefault(a => a.Index == defaultIndex);
  573. var axisIndex = existingAxis != null && existingAxis.Index > 0 ? existingAxis.Index : defaultIndex;
  574. axes.Add(CreatePlcAxis(axisName, axisIndex));
  575. }
  576. robot.PlcRobotParameter.AxixList = axes;
  577. }
  578. private static string[] GetRobotAxisNames(RobotBrand robotBrand)
  579. {
  580. switch (robotBrand)
  581. {
  582. case RobotBrand.XYZ_Platform:
  583. return new[] { "X", "Y", "Z" };
  584. case RobotBrand.XYZU_Platform:
  585. return new[] { "X", "Y", "Z", "U" };
  586. case RobotBrand.XYZUR_Platform:
  587. return new[] { "X", "Y", "Z", "U", "R" };
  588. case RobotBrand.XYZURWV_Platform:
  589. return new[] { "X", "Y", "Z", "U", "R", "W", "V" };
  590. default:
  591. return null;
  592. }
  593. }
  594. private static Axis CreatePlcAxis(string name, int index)
  595. {
  596. var axisPath = $"ns=4;s=DB_DriveControl|AxisCtrl[{index}]";
  597. return new Axis
  598. {
  599. Name = name,
  600. Index = index,
  601. Command = new AxisCommand
  602. {
  603. PowerNode = $"{axisPath}.Cmd.Power",
  604. StopNode = $"{axisPath}.Cmd.Stop",
  605. ManuToHomeNode = $"{axisPath}.Cmd.ManuToHome",
  606. AutoToHomeNode = $"{axisPath}.Cmd.AutoToHome",
  607. ManuJogFowardNode = $"{axisPath}.Cmd.ManuJogFoward",
  608. ManuJogBackwardNode = $"{axisPath}.Cmd.ManuJogBackward",
  609. VelocityControlNode = $"{axisPath}.Cmd.VelocityControl",
  610. VelocityChangeNode = $"{axisPath}.Cmd.VelocityChange",
  611. AutoINCNode = $"{axisPath}.Cmd.AutoINC",
  612. AutoABSNode = $"{axisPath}.Cmd.AutoABS",
  613. TorqueNode = $"{axisPath}.Cmd.TeachOn",
  614. PointSelectNode = $"{axisPath}.Cmd.PointSelect",
  615. TeachOnNode = $"{axisPath}.Cmd.TeachOn",
  616. TeachNode = $"{axisPath}.Cmd.Teach",
  617. ManuPointNode = $"{axisPath}.Cmd.ManuPoint",
  618. ManuPositionNode = $"{axisPath}.Cmd.ManuPosition"
  619. },
  620. Parameter = new AxisParameter
  621. {
  622. ManuPositionNode = $"{axisPath}.Parm.ManuPosition",
  623. ManuVelocityNode = $"{axisPath}.Parm.ManuVelocity",
  624. VelModeVelocityNode = $"{axisPath}.Parm.VelModeVelocity",
  625. CommentNode = $"{axisPath}.Parm.Comment"
  626. },
  627. State = new AxisState
  628. {
  629. PowerOnNode = $"{axisPath}.Status.PowerON",
  630. BusyNode = $"{axisPath}.Status.Busy",
  631. PosOKNode = $"{axisPath}.Status.PosOK",
  632. InitialedNode = $"{axisPath}.Status.Intialed",
  633. PausedNode = $"{axisPath}.Status.Paused",
  634. PosiNode = $"{axisPath}.Status.Posi",
  635. NegaNode = $"{axisPath}.Status.Nega",
  636. ErrorNode = $"{axisPath}.Status.Error",
  637. ErrorIdNode = $"{axisPath}.Status.ErrorID",
  638. ActPositionNode = $"{axisPath}.Status.ActPosition",
  639. ActVelocityNode = $"{axisPath}.Status.ActVelocity",
  640. ActTorqueNode = $"{axisPath}.Status.ActTorque",
  641. StopPositionNode = $"{axisPath}.Status.StopPositon",
  642. HmiPositionNode = $"{axisPath}.Status.HmiPosition",
  643. SpTimeNode = $"{axisPath}.Status.SpTime",
  644. StateNode = $"{axisPath}.Status.State"
  645. }
  646. };
  647. }
  648. /// <summary>
  649. /// 锟斤拷锟捷憋拷识锟狡筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫诧拷锟斤拷锟铰憋拷锟绞o拷锟斤拷锟斤拷锟剿★拷
  650. /// 锟斤拷锟斤拷锟斤拷志没锟斤拷锟斤拷锟斤拷募锟斤拷锟?
  651. /// </summary>
  652. /// <param name="id">要锟狡筹拷锟侥伙拷锟斤拷锟斤拷 Guid锟斤拷</param>
  653. /// <returns>锟狡筹拷锟缴癸拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  654. public bool RemoveRobot(Guid id)
  655. {
  656. bool result = false;
  657. lock (_sync)
  658. {
  659. var e = Robots.FirstOrDefault(r => r.Id == id);
  660. if (e != null)
  661. result = Robots.Remove(e);
  662. //锟斤拷锟铰憋拷锟?
  663. int no = 1;
  664. //锟斤拷锟斤拷锟叫伙拷锟斤拷锟剿帮拷RobotNo锟斤拷锟斤拷
  665. var sortedRobots = Robots.OrderBy(r => r.RobotNo).ToList();
  666. foreach (var r in sortedRobots)
  667. {
  668. r.RobotNo = no;
  669. no++;
  670. }
  671. Robots.Clear();
  672. foreach (var r in sortedRobots)
  673. {
  674. Robots.Add(r);
  675. }
  676. }
  677. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  678. return result;
  679. }
  680. /// <summary>
  681. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟?Id 锟侥伙拷锟斤拷锟斤拷锟斤拷锟矫★拷
  682. /// </summary>
  683. /// <param name="id">锟斤拷锟斤拷锟剿碉拷 Guid锟斤拷</param>
  684. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  685. public bool ContainsRobot(Guid id) { lock (_sync) { return Robots.Any(r => r.Id == id); } }
  686. /// <summary>
  687. /// 锟睫革拷指锟斤拷锟斤拷锟斤拷锟斤拷 Id锟侥诧拷锟斤拷锟斤拷锟诫并锟街久伙拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  688. /// </summary>
  689. /// <param name="id">锟斤拷锟斤拷锟斤拷唯一锟斤拷识锟斤拷锟斤拷</param>
  690. /// <param name="stepDistance">锟斤拷锟斤拷锟斤拷锟诫。</param>
  691. /// <returns>锟斤拷锟铰成癸拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟揭诧拷锟斤拷锟斤拷锟斤拷锟剿凤拷锟斤拷 <c>false</c>锟斤拷</returns>
  692. public bool UpdateRobotStepDistance(Guid id, double stepDistance)
  693. {
  694. lock (_sync)
  695. {
  696. var robot = Robots.FirstOrDefault(r => r.Id == id);
  697. if (robot != null)
  698. {
  699. robot.StepDistance = stepDistance;
  700. FileHelper.WriteJsonFile(Robots, ConfigPaths.RobotsConfigurationPath);
  701. return true;
  702. }
  703. else
  704. {
  705. return false;
  706. }
  707. }
  708. }
  709. /// <summary>
  710. /// 锟斤拷取指锟斤拷锟斤拷锟斤拷锟斤拷 Id 锟侥诧拷锟斤拷锟斤拷锟诫。
  711. /// </summary>
  712. /// <param name="id">锟斤拷锟斤拷锟斤拷 Guid锟斤拷</param>
  713. /// <returns>锟斤拷锟揭碉拷锟津返回讹拷应锟侥诧拷锟斤拷锟斤拷锟诫,锟斤拷锟津返伙拷默锟斤拷值 1.0锟斤拷</returns>
  714. public double GetRobotStepDistance(Guid id)
  715. {
  716. lock (_sync)
  717. {
  718. var robot = Robots.FirstOrDefault(r => r.Id == id);
  719. if (robot != null)
  720. {
  721. return robot.StepDistance;
  722. }
  723. else
  724. {
  725. return 1.0;
  726. }
  727. }
  728. }
  729. #endregion
  730. #region Feeders
  731. /// <summary>
  732. /// 锟斤拷取锟斤拷锟叫癸拷锟斤拷锟斤拷锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷
  733. /// </summary>
  734. /// <returns>锟斤拷锟斤拷锟斤拷锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷</returns>
  735. public IReadOnlyCollection<FeederInfo> GetAllFeeders() { lock (_sync) { return Feeders.ToList().AsReadOnly(); } }
  736. /// <summary>
  737. /// 锟斤拷锟捷憋拷识锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  738. /// </summary>
  739. /// <param name="id">锟斤拷锟斤拷锟斤拷锟斤拷 Guid 锟斤拷识锟斤拷</param>
  740. /// <returns>锟揭碉拷锟津返回讹拷应锟斤拷 <see cref="FeederInfo"/>锟斤拷锟斤拷锟津返伙拷 <c>null</c>锟斤拷</returns>
  741. public FeederInfo GetFeeder(Guid id) { lock (_sync) { return Feeders.FirstOrDefault(f => f.Id == id); } }
  742. /// <summary>
  743. /// 锟斤拷锟斤拷锟斤拷锟斤拷鹿锟斤拷锟斤拷锟斤拷锟斤拷茫锟斤拷锟斤拷锟斤拷锟街久伙拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  744. /// 锟斤拷锟斤拷时为锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 FeederNo 锟斤拷拧锟?
  745. /// </summary>
  746. /// <param name="feeder">要锟斤拷锟接伙拷锟斤拷碌墓锟斤拷锟斤拷锟斤拷锟斤拷谩锟?/param>
  747. /// <returns>锟斤拷锟斤拷锟接伙拷锟斤拷碌锟?<see cref="FeederInfo"/>锟斤拷锟斤拷锟斤拷为 <c>null</c> 时锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  748. public FeederInfo AddOrUpdateFeeder(FeederInfo feeder)
  749. {
  750. if (feeder == null) return null;
  751. lock (_sync)
  752. {
  753. var exist = Feeders.FirstOrDefault(f => f.Id == feeder.Id);
  754. if (exist != null)
  755. {
  756. var idx = Feeders.IndexOf(exist);
  757. Feeders[idx] = feeder;
  758. }
  759. else
  760. {
  761. feeder.FeederNo = Feeders.Count + 1;
  762. Feeders.Add(feeder);
  763. }
  764. }
  765. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  766. return feeder;
  767. }
  768. /// <summary>
  769. /// 锟斤拷锟捷憋拷识锟狡筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟矫诧拷锟斤拷锟铰憋拷锟绞o拷喙╋拷锟斤拷锟斤拷锟?
  770. /// 锟斤拷锟斤拷锟斤拷志没锟斤拷锟斤拷锟斤拷募锟斤拷锟?
  771. /// </summary>
  772. /// <param name="id">要锟狡筹拷锟侥癸拷锟斤拷锟斤拷 Guid锟斤拷</param>
  773. /// <returns>锟狡筹拷锟缴癸拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  774. public bool RemoveFeeder(Guid id)
  775. {
  776. bool result = false;
  777. lock (_sync)
  778. {
  779. var e = Feeders.FirstOrDefault(f => f.Id == id);
  780. if (e != null) result = Feeders.Remove(e);
  781. //锟斤拷锟铰憋拷锟?
  782. int no = 1;
  783. //锟斤拷锟斤拷锟叫癸拷锟斤拷锟斤拷锟斤拷FeederNo锟斤拷锟斤拷
  784. var sortedFeeders = Feeders.OrderBy(f => f.FeederNo).ToList();
  785. foreach (var f in sortedFeeders)
  786. {
  787. f.FeederNo = no;
  788. no++;
  789. }
  790. Feeders.Clear();
  791. foreach (var f in sortedFeeders)
  792. {
  793. Feeders.Add(f);
  794. }
  795. }
  796. FileHelper.WriteJsonFile(Feeders, ConfigPaths.FeedersConfigurationPath);
  797. return result;
  798. }
  799. /// <summary>
  800. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟?Id 锟侥癸拷锟斤拷锟斤拷锟斤拷锟矫★拷
  801. /// </summary>
  802. /// <param name="id">锟斤拷锟斤拷锟斤拷 Guid锟斤拷</param>
  803. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  804. public bool ContainsFeeder(Guid id) { lock (_sync) { return Feeders.Any(f => f.Id == id); } }
  805. #endregion
  806. #region PLC
  807. /// <summary>
  808. /// 锟斤拷取锟斤拷锟斤拷 PLC 锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷
  809. /// </summary>
  810. /// <returns>PLC 锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷</returns>
  811. public IReadOnlyCollection<PlcInfo> GetAllPlcs() { lock (_sync) { return Plcs.ToList().AsReadOnly(); } }
  812. /// <summary>
  813. /// 锟斤拷锟捷憋拷识锟斤拷取锟斤拷锟斤拷 PLC 锟斤拷锟矫★拷
  814. /// </summary>
  815. /// <param name="id">PLC 锟斤拷 Guid 锟斤拷识锟斤拷</param>
  816. /// <returns>匹锟斤拷锟?<see cref="PlcInfo"/> 实锟斤拷锟斤拷锟揭诧拷锟斤拷锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  817. public PlcInfo GetPlc(Guid id) { lock (_sync) { return Plcs.FirstOrDefault(p => p.Id == id); } }
  818. /// <summary>
  819. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟?PLC 锟斤拷锟矫o拷锟斤拷锟斤拷锟斤拷志没锟斤拷锟斤拷锟斤拷锟斤拷募锟斤拷锟斤拷锟斤拷锟绞憋拷锟斤拷锟斤拷锟斤拷锟?PlcNo 锟斤拷拧锟?
  820. /// </summary>
  821. /// <param name="plc">要锟斤拷锟接伙拷锟斤拷碌锟?PLC 锟斤拷锟矫★拷</param>
  822. /// <returns>锟斤拷锟斤拷锟接伙拷锟斤拷碌锟?<see cref="PlcInfo"/>锟斤拷锟斤拷锟斤拷为 <c>null</c> 时锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  823. public PlcInfo AddOrUpdatePlc(PlcInfo plc)
  824. {
  825. if (plc == null) return null;
  826. lock (_sync)
  827. {
  828. var exist = Plcs.FirstOrDefault(p => p.Id == plc.Id);
  829. if (exist != null)
  830. {
  831. var idx = Plcs.IndexOf(exist);
  832. Plcs[idx] = plc;
  833. }
  834. else
  835. {
  836. plc.PlcNo = Plcs.Count + 1;
  837. Plcs.Add(plc);
  838. }
  839. }
  840. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  841. return plc;
  842. }
  843. /// <summary>
  844. /// 锟斤拷锟捷憋拷识锟狡筹拷 PLC 锟斤拷锟矫诧拷锟斤拷锟铰憋拷锟绞o拷锟?PLC锟斤拷
  845. /// 锟斤拷锟斤拷锟斤拷志没锟斤拷锟斤拷锟斤拷募锟斤拷锟?
  846. /// </summary>
  847. /// <param name="id">要锟狡筹拷锟斤拷 PLC Guid锟斤拷</param>
  848. /// <returns>锟狡筹拷锟缴癸拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  849. public bool RemovePlc(Guid id)
  850. {
  851. bool result = false;
  852. lock (_sync)
  853. {
  854. var e = Plcs.FirstOrDefault(p => p.Id == id);
  855. if (e != null) result = Plcs.Remove(e);
  856. //锟斤拷锟铰憋拷锟?
  857. int no = 1;
  858. //锟斤拷锟斤拷锟斤拷PLC锟斤拷PlcNo锟斤拷锟斤拷
  859. var sortedPlcs = Plcs.OrderBy(p => p.PlcNo).ToList();
  860. foreach (var p in sortedPlcs)
  861. {
  862. p.PlcNo = no;
  863. no++;
  864. }
  865. Plcs.Clear();
  866. foreach (var p in sortedPlcs)
  867. {
  868. Plcs.Add(p);
  869. }
  870. }
  871. FileHelper.WriteJsonFile(Plcs, ConfigPaths.PlcConfigurationPath);
  872. return result;
  873. }
  874. /// <summary>
  875. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟?Id 锟斤拷 PLC 锟斤拷锟矫★拷
  876. /// </summary>
  877. /// <param name="id">PLC 锟斤拷 Guid锟斤拷</param>
  878. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  879. public bool ContainsPlc(Guid id) { lock (_sync) { return Plcs.Any(p => p.Id == id); } }
  880. #endregion
  881. #region BgTcp
  882. /// <summary>
  883. /// 锟斤拷取 BG TCP/IP 通锟斤拷锟斤拷锟矫o拷锟节达拷锟斤拷螅�锟斤拷锟轿?null锟斤拷锟斤拷
  884. /// </summary>
  885. /// <returns>锟斤拷前锟斤拷 <see cref="BgTcpIP"/> 锟斤拷锟矫讹拷锟斤拷</returns>
  886. public BgTcpIP GetBgTcp() { lock (_sync) { return BgCommunicate; } }
  887. /// <summary>
  888. /// 锟斤拷锟斤拷 BG TCP/IP 通锟斤拷锟斤拷锟矫o拷锟斤拷锟斤拷锟斤拷锟节达拷锟斤拷螅�锟斤拷锟斤拷远锟斤拷志没锟斤拷锟斤拷锟?
  889. /// 锟斤拷锟斤拷志没锟斤拷锟斤拷锟斤拷 <see cref="SaveBgTcp"/>锟斤拷
  890. /// </summary>
  891. /// <param name="cfg">锟铰碉拷 <see cref="BgTcpIP"/> 锟斤拷锟矫讹拷锟斤拷</param>
  892. public void SetBgTcp(BgTcpIP cfg) { lock (_sync) { BgCommunicate = cfg; } }
  893. /// <summary>
  894. /// 锟斤拷锟斤拷前锟节达拷锟叫碉拷 BG TCP/IP 锟斤拷锟矫持久伙拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  895. /// </summary>
  896. public void SaveBgTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgCommunicate, ConfigPaths.BgTcpIpConfigurationPath); } }
  897. #endregion
  898. #region BgModbus
  899. /// <summary>
  900. /// 锟斤拷取 BG Modbus TCP 通锟斤拷锟斤拷锟矫o拷锟节达拷锟斤拷螅�锟?
  901. /// </summary>
  902. /// <returns>锟斤拷前锟斤拷 <see cref="BgModbusTcp"/> 锟斤拷锟矫讹拷锟斤拷</returns>
  903. public BgModbusTcp GetBgModbusTcp() { lock (_sync) { return BgModbusCommunicate; } }
  904. /// <summary>
  905. /// 锟斤拷锟斤拷 BG Modbus TCP 通锟斤拷锟斤拷锟矫o拷锟斤拷锟斤拷锟斤拷锟节达拷锟斤拷螅�锟斤拷锟斤拷远锟斤拷志没锟斤拷锟斤拷锟?
  906. /// </summary>
  907. /// <param name="cfg">锟铰碉拷 <see cref="BgModbusTcp"/> 锟斤拷锟矫讹拷锟斤拷</param>
  908. public void SetBgModbusTcp(BgModbusTcp cfg) { lock (_sync) { BgModbusCommunicate = cfg; } }
  909. /// <summary>
  910. /// 锟斤拷锟斤拷前锟节达拷锟叫碉拷 BG Modbus TCP 锟斤拷锟矫持久伙拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  911. /// </summary>
  912. public void SaveBgModbusTcp() { lock (_sync) { FileHelper.WriteJsonFile(BgModbusCommunicate, ConfigPaths.BgModbusTcpConfigurationPath); } }
  913. #endregion
  914. #region CTQData
  915. /// <summary>
  916. /// 鑾峰彇CTQ淇℃伅閰嶇疆
  917. /// </summary>
  918. public CTQ_Data GetCTQDataInfo()
  919. {
  920. lock (_sync)
  921. {
  922. if (CtqData == null)
  923. {
  924. if (File.Exists(ConfigPaths.DataConfigurationPath))
  925. CtqData = FileHelper.ReadJsonFile<CTQ_Data>(ConfigPaths.DataConfigurationPath);
  926. else
  927. {
  928. CtqData = new CTQ_Data();
  929. FileHelper.WriteJsonFile(CtqData, ConfigPaths.DataConfigurationPath);
  930. }
  931. }
  932. return CtqData;
  933. }
  934. }
  935. /// <summary>
  936. /// 淇濆瓨CTQ淇℃伅
  937. /// </summary>
  938. public void SaveCTQDataInfo(CTQ_Data cd)
  939. {
  940. if (cd == null) return;
  941. lock (_sync)
  942. {
  943. CtqData = cd;
  944. FileHelper.WriteJsonFile(CtqData, ConfigPaths.DataConfigurationPath);
  945. }
  946. }
  947. #endregion
  948. #region 系统锟斤拷锟斤拷
  949. /// <summary>
  950. /// 锟斤拷取系统锟斤拷锟矫o拷锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷取锟斤拷锟斤拷
  951. /// 锟竭程帮拷全锟斤拷锟斤拷锟斤拷锟节诧拷锟斤拷锟斤拷锟皆憋拷证锟斤拷取一锟斤拷锟皆★拷
  952. /// </summary>
  953. /// <returns>锟斤拷取锟斤拷锟斤拷 <see cref="SystemConfiguration"/> 锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟斤拷锟斤拷锟津返伙拷默锟较碉拷锟斤拷实锟斤拷锟斤拷</returns>
  954. public SystemConfiguration GetSystemConfiguration()
  955. {
  956. lock (_sync)
  957. {
  958. var config = new SystemConfiguration();
  959. if (File.Exists(ConfigPaths.SystemConfigurationPath))
  960. {
  961. config = FileHelper.ReadJsonFile<SystemConfiguration>(ConfigPaths.SystemConfigurationPath);
  962. }
  963. FileHelper.WriteJsonFile(config, ConfigPaths.SystemConfigurationPath);
  964. return config;
  965. }
  966. }
  967. /// <summary>
  968. /// 锟斤拷锟斤拷系统锟斤拷锟矫碉拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟结覆锟斤拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟斤拷
  969. /// </summary>
  970. /// <param name="systemConfiguration">要锟斤拷锟斤拷锟较低筹拷锟斤拷枚锟斤拷锟?/param>
  971. public void SaveSystemConfiguration(SystemConfiguration systemConfiguration)
  972. {
  973. lock (_sync)
  974. {
  975. FileHelper.WriteJsonFile(systemConfiguration, ConfigPaths.SystemConfigurationPath);
  976. }
  977. }
  978. /// <summary>
  979. /// 锟斤拷取锟斤拷前锟斤拷锟斤拷
  980. /// </summary>
  981. /// <returns></returns>
  982. public Language GetCurrentLanguage()
  983. {
  984. lock (_sync)
  985. {
  986. var config = GetSystemConfiguration();
  987. return config.CurrentLanguage;
  988. }
  989. }
  990. /// <summary>
  991. /// 锟斤拷锟矫碉拷前锟斤拷锟斤拷
  992. /// </summary>
  993. /// <param name="language"></param>
  994. public void SetCurrentLanguage(Language language)
  995. {
  996. lock (_sync)
  997. {
  998. var config = GetSystemConfiguration();
  999. config.CurrentLanguage = language;
  1000. if (language == Enums.Language.ChineseSimplified)
  1001. {
  1002. var culture = new CultureInfo("zh-CN");
  1003. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  1004. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  1005. LocalizeDictionary.Instance.Culture = culture;
  1006. Lang.Culture = culture;
  1007. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Microsoft YaHei");
  1008. }
  1009. else if (language == Enums.Language.ChineseTraditional)
  1010. {
  1011. var culture = new CultureInfo("zh-TW");
  1012. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  1013. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  1014. LocalizeDictionary.Instance.Culture = culture;
  1015. Lang.Culture = culture;
  1016. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Microsoft YaHei");
  1017. }
  1018. else if (language == Enums.Language.English)
  1019. {
  1020. var culture = new CultureInfo("en");
  1021. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  1022. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  1023. LocalizeDictionary.Instance.Culture = culture;
  1024. Lang.Culture = culture;
  1025. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Segoe UI");
  1026. }
  1027. else if (language == Enums.Language.Japanese)
  1028. {
  1029. var culture = new CultureInfo("ja-JP");
  1030. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  1031. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  1032. LocalizeDictionary.Instance.Culture = culture;
  1033. Lang.Culture = culture;
  1034. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Segoe UI");
  1035. }
  1036. else if (language == Enums.Language.Vietnamese)
  1037. {
  1038. var culture = new CultureInfo("vi");
  1039. App.Current.Dispatcher.Thread.CurrentCulture = culture;
  1040. App.Current.Dispatcher.Thread.CurrentUICulture = culture;
  1041. LocalizeDictionary.Instance.Culture = culture;
  1042. Lang.Culture = culture;
  1043. System.Windows.Application.Current.Resources["DefaultFont"] = new System.Windows.Media.FontFamily("Segoe UI");
  1044. }
  1045. SaveSystemConfiguration(config);
  1046. }
  1047. }
  1048. #endregion
  1049. #region Feeder锟斤拷锟斤拷锟斤拷锟斤拷
  1050. /// <summary>
  1051. /// 锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街伙拷锟斤拷锟斤拷稀锟?
  1052. /// </summary>
  1053. /// <returns>锟斤拷锟斤拷锟斤拷锟斤拷锟街伙拷锟斤拷锟斤拷稀锟?/returns>
  1054. public IReadOnlyCollection<FeederClearWork> GetAllClearanceTasks() { lock (_sync) { return FeederClearanceTasks.ToList().AsReadOnly(); } }
  1055. /// <summary>
  1056. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟绞蔽�拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟?TaskCode锟斤拷锟斤拷珊锟街久伙拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  1057. /// </summary>
  1058. /// <param name="task">要锟斤拷锟接伙拷锟斤拷碌锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷</param>
  1059. /// <returns>锟斤拷锟斤拷锟接伙拷锟斤拷碌锟?<see cref="FeederClearWork"/>锟斤拷锟斤拷锟斤拷为 <c>null</c> 时锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  1060. public FeederClearWork AddOrUpdateClearanceTask(FeederClearWork task)
  1061. {
  1062. if (task == null) return null;
  1063. lock (_sync)
  1064. {
  1065. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == task.Id);
  1066. if (exist != null)
  1067. {
  1068. var idx = FeederClearanceTasks.IndexOf(exist);
  1069. FeederClearanceTasks[idx] = task;
  1070. }
  1071. else
  1072. {
  1073. // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷为锟斤拷前锟斤拷锟斤拷偶锟?
  1074. task.TaskCode = FeederClearanceTasks.Count > 0 ? FeederClearanceTasks.Max(t => t.TaskCode) + 1 : 1;
  1075. FeederClearanceTasks.Add(task);
  1076. }
  1077. }
  1078. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  1079. return task;
  1080. }
  1081. /// <summary>
  1082. /// 锟斤拷锟捷憋拷识锟狡筹拷锟斤拷锟斤拷锟斤拷锟今并持久伙拷锟斤拷锟斤拷锟侥硷拷锟斤拷
  1083. /// </summary>
  1084. /// <param name="id">要锟狡筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷 Guid锟斤拷</param>
  1085. /// <returns>锟斤拷锟揭碉拷锟斤拷锟狡筹拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  1086. public bool RemoveClearanceTask(Guid id)
  1087. {
  1088. lock (_sync)
  1089. {
  1090. var exist = FeederClearanceTasks.FirstOrDefault(t => t.Id == id);
  1091. if (exist != null)
  1092. {
  1093. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  1094. return FeederClearanceTasks.Remove(exist);
  1095. }
  1096. else
  1097. return false;
  1098. }
  1099. }
  1100. /// <summary>
  1101. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷癫⒊志没锟斤拷占锟斤拷系锟斤拷锟斤拷锟斤拷募锟斤拷锟?
  1102. /// </summary>
  1103. public void ClearAllClearanceTasks()
  1104. {
  1105. lock (_sync)
  1106. {
  1107. FeederClearanceTasks.Clear();
  1108. }
  1109. FileHelper.WriteJsonFile(FeederClearanceTasks, ConfigPaths.FeederClearanceTasksConfigurationPath);
  1110. }
  1111. /// <summary>
  1112. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟?Id 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
  1113. /// </summary>
  1114. /// <param name="id">锟斤拷锟斤拷锟斤拷锟斤拷 Guid锟斤拷</param>
  1115. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  1116. public bool ContainsClearanceTask(Guid id)
  1117. {
  1118. lock (_sync) { return FeederClearanceTasks.Any(t => t.Id == id); }
  1119. }
  1120. /// <summary>
  1121. /// 锟斤拷锟捷憋拷识锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷息锟斤拷
  1122. /// </summary>
  1123. /// <param name="id">锟斤拷锟斤拷锟斤拷锟斤拷 Guid锟斤拷</param>
  1124. /// <returns>匹锟斤拷锟?<see cref="FeederClearWork"/>锟斤拷锟揭诧拷锟斤拷锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  1125. public FeederClearWork GetClearanceTask(Guid id)
  1126. {
  1127. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.Id == id); }
  1128. }
  1129. /// <summary>
  1130. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟斤拷锟斤拷锟斤拷诺锟斤拷锟斤拷锟斤拷锟斤拷锟?
  1131. /// </summary>
  1132. /// <param name="taskNumber">锟斤拷锟斤拷锟脚o拷TaskCode锟斤拷锟斤拷</param>
  1133. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  1134. public bool ContainsClearanceTaskByNumber(int taskNumber)
  1135. {
  1136. lock (_sync) { return FeederClearanceTasks.Any(t => t.TaskCode == taskNumber); }
  1137. }
  1138. /// <summary>
  1139. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟脚伙拷取锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷息锟斤拷
  1140. /// </summary>
  1141. /// <param name="taskNumber">锟斤拷锟斤拷锟脚o拷TaskCode锟斤拷锟斤拷</param>
  1142. /// <returns>匹锟斤拷锟?<see cref="FeederClearWork"/>锟斤拷锟揭诧拷锟斤拷锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  1143. public FeederClearWork GetClearanceTaskByNumber(int taskNumber)
  1144. {
  1145. lock (_sync) { return FeederClearanceTasks.FirstOrDefault(t => t.TaskCode == taskNumber); }
  1146. }
  1147. #endregion
  1148. #region Light controllers and channels
  1149. /// <summary>
  1150. /// 锟斤拷取锟斤拷锟叫癸拷源锟斤拷锟斤拷锟斤拷锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷
  1151. /// 锟竭程帮拷全锟斤拷锟斤拷锟节诧拷使锟斤拷 <see cref="_sync"/> 锟斤拷锟斤拷锟斤拷锟斤拷锟皆憋拷证锟斤拷锟斤拷锟斤拷锟绞帮拷全锟斤拷
  1152. /// </summary>
  1153. /// <returns>锟斤拷锟斤拷前锟节达拷锟叫存储顺锟津返回碉拷只锟斤拷 <see cref="LightControllerConfig"/> 锟斤拷锟较★拷</returns>
  1154. public IReadOnlyCollection<LightControllerConfig> GetAllLightControllers()
  1155. {
  1156. lock (_sync) { return LightControllers.ToList().AsReadOnly(); }
  1157. }
  1158. /// <summary>
  1159. /// 锟斤拷锟捷匡拷锟斤拷锟斤拷锟斤拷识锟斤拷取锟斤拷锟斤拷锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  1160. /// 锟竭程帮拷全锟斤拷锟矫凤拷锟斤拷锟斤拷锟节存集锟较斤拷锟斤拷只锟斤拷锟斤拷锟绞诧拷锟斤拷锟节诧拷锟斤拷锟斤拷锟斤拷
  1161. /// </summary>
  1162. /// <param name="id">锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷识锟斤拷Id锟斤拷锟斤拷</param>
  1163. /// <returns>匹锟斤拷锟?<see cref="LightControllerConfig"/> 实锟斤拷锟斤拷锟揭诧拷锟斤拷锟津返伙拷 <c>null</c>锟斤拷</returns>
  1164. public LightControllerConfig GetLightController(int id)
  1165. {
  1166. lock (_sync) { return LightControllers.FirstOrDefault(c => c.Id == id); }
  1167. }
  1168. /// <summary>
  1169. /// 锟斤拷锟斤拷锟斤拷锟斤拷鹿锟皆达拷锟斤拷锟斤拷锟斤拷锟斤拷谩锟?
  1170. /// - 锟斤拷 <paramref name="controller"/> 为 <c>null</c> 锟斤拷锟斤拷 <c>null</c>锟斤拷
  1171. /// - 锟斤拷锟斤拷时锟斤拷 Id 匹锟斤拷锟斤拷锟斤拷锟筋并锟芥换锟斤拷
  1172. /// - 锟斤拷锟斤拷时锟斤拷锟斤拷锟斤拷锟斤拷锟侥匡拷锟斤拷锟斤拷 Id锟斤拷锟斤拷为锟斤拷锟斤拷锟斤拷锟节碉拷每锟斤拷通锟斤拷锟斤拷锟斤拷全锟斤拷通锟斤拷锟斤拷牛锟紾lobalIndex锟斤拷锟斤拷
  1173. /// 锟竭程帮拷全锟斤拷锟斤拷锟节诧拷使锟斤拷 <see cref="_sync"/> 锟斤拷锟斤拷锟斤拷锟较★拷
  1174. /// </summary>
  1175. /// <param name="controller">要锟斤拷锟接伙拷锟斤拷碌锟?<see cref="LightControllerConfig"/> 实锟斤拷锟斤拷</param>
  1176. /// <returns>锟斤拷锟斤拷锟接伙拷锟斤拷碌锟?<see cref="LightControllerConfig"/> 实锟斤拷锟斤拷锟斤拷锟斤拷为 <c>null</c> 时锟斤拷锟斤拷 <c>null</c>锟斤拷</returns>
  1177. /// <exception cref="ArgumentException">锟斤拷要锟斤拷锟斤拷/锟斤拷锟铰的匡拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟截革拷时锟阶筹拷锟斤拷</exception>
  1178. public LightControllerConfig AddOrUpdateLightController(LightControllerConfig controller)
  1179. {
  1180. if (controller == null) return null;
  1181. lock (_sync)
  1182. {
  1183. // 锟斤拷锟狡诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟截革拷锟斤拷同锟斤拷锟斤拷锟斤拷同 Id 锟斤拷锟斤拷锟斤拷锟斤拷
  1184. if (LightControllers.Any(c => c.Name == controller.Name && c.Id != controller.Id))
  1185. throw new ArgumentException("Controller name must be unique");
  1186. var exist = LightControllers.FirstOrDefault(c => c.Id == controller.Id);
  1187. if (exist != null)
  1188. {
  1189. // 锟斤拷锟斤拷锟斤拷锟叫匡拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟芥换锟斤拷
  1190. var idx = LightControllers.IndexOf(exist);
  1191. LightControllers[idx] = controller;
  1192. }
  1193. else
  1194. {
  1195. // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
  1196. // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷为锟斤拷前锟斤拷锟?Id + 1锟斤拷锟斤拷锟斤拷锟斤拷为锟斤拷锟斤拷为 1锟斤拷
  1197. controller.Id = LightControllers.Count > 0 ? LightControllers.Max(c => c.Id) + 1 : 1;
  1198. // 锟斤拷锟斤拷锟斤拷一锟斤拷全锟斤拷通锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟窖达拷锟节匡拷锟斤拷锟斤拷锟斤拷通锟斤拷 GlobalIndex 锟斤拷取锟斤拷锟街碉拷锟斤拷锟?
  1199. int nextGlobal = 0;
  1200. if (LightControllers.SelectMany(c => c.ChannelConfigs).Any())
  1201. {
  1202. nextGlobal = LightControllers.SelectMany(c => c.ChannelConfigs).Max(ch => ch.GlobalIndex) + 1;
  1203. }
  1204. // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷 GlobalIndex 锟斤拷效锟斤拷<0锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷通锟斤拷锟斤拷突锟斤拷锟斤拷锟斤拷锟铰凤拷锟斤拷
  1205. for (int i = 0; i < controller.ChannelConfigs.Count; i++)
  1206. {
  1207. var ch = controller.ChannelConfigs[i];
  1208. if (ch.GlobalIndex < 0 || LightControllers.SelectMany(c => c.ChannelConfigs).Any(existingCh => existingCh.GlobalIndex == ch.GlobalIndex))
  1209. {
  1210. ch.GlobalIndex = nextGlobal;
  1211. nextGlobal++;
  1212. }
  1213. }
  1214. LightControllers.Add(controller);
  1215. }
  1216. }
  1217. // 锟街久伙拷锟斤拷锟铰猴拷墓锟皆达拷锟斤拷锟斤拷锟斤拷锟斤拷锟?
  1218. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1219. return controller;
  1220. }
  1221. /// <summary>
  1222. /// 锟斤拷锟斤拷 Id 锟狡筹拷锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟矫诧拷锟斤拷剩锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷卤锟脚o拷锟斤拷 1 锟斤拷始锟斤拷锟斤拷锟斤拷牛锟斤拷锟?
  1223. /// 锟斤拷锟斤拷锟斤拷志没锟斤拷锟斤拷锟斤拷募锟斤拷锟?
  1224. /// </summary>
  1225. /// <param name="id">要锟狡筹拷锟侥匡拷锟斤拷锟斤拷 Id锟斤拷</param>
  1226. /// <returns>锟斤拷锟斤拷晒锟斤拷瞥锟斤拷锟斤拷锟?<c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷锟斤拷锟斤拷未锟揭碉拷锟斤拷 Id锟斤拷锟斤拷</returns>
  1227. public bool RemoveLightController(int id)
  1228. {
  1229. bool result = false;
  1230. lock (_sync)
  1231. {
  1232. var e = LightControllers.FirstOrDefault(c => c.Id == id);
  1233. if (e != null)
  1234. result = LightControllers.Remove(e);
  1235. // 锟斤拷锟铰帮拷 Id 锟斤拷锟津并达拷 1 锟斤拷始锟斤拷锟铰憋拷牛锟斤拷员锟斤拷锟斤拷锟斤拷锟斤拷锟?
  1236. int no = 1;
  1237. var sorted = LightControllers.OrderBy(c => c.Id).ToList();
  1238. foreach (var c in sorted)
  1239. {
  1240. c.Id = no;
  1241. no++;
  1242. }
  1243. LightControllers.Clear();
  1244. foreach (var c in sorted)
  1245. {
  1246. LightControllers.Add(c);
  1247. }
  1248. }
  1249. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1250. return result;
  1251. }
  1252. /// <summary>
  1253. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟?Id 锟侥癸拷源锟斤拷锟斤拷锟斤拷锟斤拷
  1254. /// </summary>
  1255. /// <param name="id">锟斤拷锟斤拷锟斤拷 Id锟斤拷</param>
  1256. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  1257. public bool ContainsLightController(int id) { lock (_sync) { return LightControllers.Any(c => c.Id == id); } }
  1258. /// <summary>
  1259. /// 锟斤拷取锟斤拷锟叫癸拷源通锟斤拷锟斤拷只锟斤拷锟斤拷锟较o拷锟斤拷 GlobalIndex 锟斤拷锟津返回★拷
  1260. /// </summary>
  1261. /// <returns>锟斤拷 GlobalIndex 锟斤拷锟斤拷锟?<see cref="ChannelConfig"/> 只锟斤拷锟斤拷锟较★拷</returns>
  1262. public IReadOnlyCollection<ChannelConfig> GetAllLightChannels()
  1263. {
  1264. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).OrderBy(ch => ch.GlobalIndex).ToList().AsReadOnly(); }
  1265. }
  1266. /// <summary>
  1267. /// 锟斤拷锟斤拷全锟斤拷通锟斤拷锟斤拷锟斤拷锟斤拷取锟斤拷锟斤拷通锟斤拷锟斤拷锟矫★拷
  1268. /// </summary>
  1269. /// <param name="globalIndex">通锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷锟斤拷GlobalIndex锟斤拷锟斤拷</param>
  1270. /// <returns>匹锟斤拷锟?<see cref="ChannelConfig"/> 实锟斤拷锟斤拷锟揭诧拷锟斤拷锟津返伙拷 <c>null</c>锟斤拷</returns>
  1271. public ChannelConfig GetLightChannelByGlobalIndex(int globalIndex)
  1272. {
  1273. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(ch => ch.GlobalIndex == globalIndex); }
  1274. }
  1275. /// <summary>
  1276. /// 锟叫讹拷锟角凤拷锟斤拷锟街革拷锟饺�拷锟酵�拷锟斤拷锟斤拷锟斤拷锟酵�拷锟斤拷锟斤拷谩锟?
  1277. /// </summary>
  1278. /// <param name="globalIndex">全锟斤拷通锟斤拷锟斤拷锟斤拷锟斤拷</param>
  1279. /// <returns>锟斤拷锟节凤拷锟斤拷 <c>true</c>锟斤拷锟斤拷锟津返伙拷 <c>false</c>锟斤拷</returns>
  1280. public bool ContainsLightChannelByGlobalIndex(int globalIndex)
  1281. {
  1282. lock (_sync) { return LightControllers.SelectMany(c => c.ChannelConfigs).Any(ch => ch.GlobalIndex == globalIndex); }
  1283. }
  1284. /// <summary>
  1285. /// 锟斤拷锟斤拷指锟斤拷全锟斤拷通锟斤拷锟斤拷默锟斤拷锟斤拷锟饺o拷DefaultBrightness锟斤拷锟斤拷锟斤拷锟街久伙拷锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  1286. /// </summary>
  1287. /// <param name="globalIndex">目锟斤拷通锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷锟斤拷GlobalIndex锟斤拷锟斤拷</param>
  1288. /// <param name="brightness">要锟斤拷锟矫碉拷锟斤拷锟斤拷值锟斤拷</param>
  1289. /// <returns>锟斤拷锟铰成癸拷锟斤拷锟斤拷 <c>true</c>锟斤拷锟揭诧拷锟斤拷锟斤拷应通锟斤拷锟斤拷锟斤拷 <c>false</c>锟斤拷</returns>
  1290. public bool UpdateChannelDefaultBrightness(int globalIndex, int brightness)
  1291. {
  1292. lock (_sync)
  1293. {
  1294. var ch = LightControllers.SelectMany(c => c.ChannelConfigs).FirstOrDefault(x => x.GlobalIndex == globalIndex);
  1295. if (ch == null) return false;
  1296. ch.DefaultBrightness = brightness;
  1297. FileHelper.WriteJsonFile(LightControllers, ConfigPaths.LightControllersConfigurationPath);
  1298. return true;
  1299. }
  1300. }
  1301. #endregion
  1302. #region Plc Addresses
  1303. public PlcAddressConfig GetPlcAddresses() { lock (_sync) { return PlcAddressConfig; } }
  1304. #endregion
  1305. #region ScrewDriver config (single device)
  1306. /// <summary>
  1307. /// 锟斤拷取锟斤拷锟斤拷锟斤拷锟矫o拷锟斤拷锟借备锟斤拷锟斤拷
  1308. /// </summary>
  1309. /// <returns>锟斤拷前锟斤拷 <see cref="ScrewDriverConfig"/>锟斤拷锟斤拷未锟斤拷锟斤拷锟津返伙拷 null锟斤拷</returns>
  1310. public ScrewDriverConfig GetScrewDriverConfig()
  1311. {
  1312. lock (_sync) { return _screwDriverConfig; }
  1313. }
  1314. /// <summary>
  1315. /// 锟斤拷锟矫诧拷锟街久伙拷锟斤拷锟斤拷锟斤拷锟矫o拷锟斤拷锟借备锟斤拷锟斤拷
  1316. /// </summary>
  1317. /// <param name="cfg">锟铰碉拷锟斤拷锟矫讹拷锟襟,诧拷锟斤拷为锟秸★拷</param>
  1318. public void SetScrewDriverConfig(ScrewDriverConfig cfg)
  1319. {
  1320. if (cfg == null) throw new ArgumentNullException(nameof(cfg));
  1321. lock (_sync)
  1322. {
  1323. _screwDriverConfig = cfg;
  1324. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  1325. }
  1326. }
  1327. /// <summary>
  1328. /// 锟斤拷锟斤拷锟斤拷前锟节达拷锟叫的碉拷锟斤拷锟斤拷锟矫憋拷锟芥到锟侥硷拷锟斤拷
  1329. /// </summary>
  1330. public void SaveScrewDriverConfig()
  1331. {
  1332. lock (_sync)
  1333. {
  1334. if (_screwDriverConfig != null)
  1335. FileHelper.WriteJsonFile(_screwDriverConfig, ConfigPaths.ScrewDriverConfigurationPath);
  1336. }
  1337. }
  1338. #endregion
  1339. #region Screw Feeders (material)
  1340. /// <summary>
  1341. /// 锟斤拷取锟斤拷锟斤拷锟斤拷丝锟斤拷锟斤拷锟斤拷锟斤拷锟矫碉拷只锟斤拷锟斤拷锟较★拷
  1342. /// </summary>
  1343. public IReadOnlyCollection<ScrewFeederInfo> GetAllScrewFeeders() { lock (_sync) { return ScrewFeeders.ToList().AsReadOnly(); } }
  1344. /// <summary>
  1345. /// 锟斤拷锟斤拷 Id 锟斤拷取锟斤拷锟斤拷锟斤拷丝锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  1346. /// </summary>
  1347. public ScrewFeederInfo GetScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.FirstOrDefault(s => s.Id == id); } }
  1348. /// <summary>
  1349. /// 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟剿匡拷锟斤拷锟斤拷锟斤拷锟斤拷谩锟?
  1350. /// 锟斤拷锟斤拷时锟斤拷未指锟斤拷 FeederNumber 锟斤拷锟斤拷锟轿�拷锟角帮拷锟斤拷锟?1锟斤拷
  1351. /// </summary>
  1352. public ScrewFeederInfo AddOrUpdateScrewFeeder(ScrewFeederInfo feeder)
  1353. {
  1354. if (feeder == null) return null;
  1355. lock (_sync)
  1356. {
  1357. var exist = ScrewFeeders.FirstOrDefault(f => f.Id == feeder.Id);
  1358. if (exist != null)
  1359. {
  1360. var idx = ScrewFeeders.IndexOf(exist);
  1361. ScrewFeeders[idx] = feeder;
  1362. }
  1363. else
  1364. {
  1365. if (feeder.FeederNumber <= 0) feeder.FeederNumber = ScrewFeeders.Count + 1;
  1366. ScrewFeeders.Add(feeder);
  1367. }
  1368. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1369. }
  1370. return feeder;
  1371. }
  1372. /// <summary>
  1373. /// 锟狡筹拷锟斤拷丝锟斤拷锟斤拷锟斤拷锟斤拷锟矫★拷
  1374. /// </summary>
  1375. public bool RemoveScrewFeeder(Guid id)
  1376. {
  1377. bool result = false;
  1378. lock (_sync)
  1379. {
  1380. var e = ScrewFeeders.FirstOrDefault(s => s.Id == id);
  1381. if (e != null) result = ScrewFeeders.Remove(e);
  1382. }
  1383. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1384. return result;
  1385. }
  1386. public bool ContainsScrewFeeder(Guid id) { lock (_sync) { return ScrewFeeders.Any(s => s.Id == id); } }
  1387. // event for low level alarm
  1388. public event Action<ScrewFeederInfo> ScrewFeederLowLevelAlarmTriggered;
  1389. /// <summary>
  1390. /// 锟斤拷取指锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷诺锟绞o拷锟斤拷锟剿匡拷锟斤拷锟斤拷锟斤拷也锟斤拷锟斤拷锟斤拷锟?-1锟斤拷
  1391. /// </summary>
  1392. public int GetRemainingCountByFeederNumber(int feederNumber)
  1393. {
  1394. lock (_sync)
  1395. {
  1396. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1397. if (f == null) return -1;
  1398. return f.RemainingCount;
  1399. }
  1400. }
  1401. /// <summary>
  1402. /// 锟斤拷取指锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷诺牡锟斤拷锟斤拷锟斤拷锟阶刺�拷锟斤拷也锟斤拷锟斤拷锟斤拷锟?false锟斤拷
  1403. /// </summary>
  1404. public bool GetLowLevelAlarmStatusByFeederNumber(int feederNumber)
  1405. {
  1406. lock (_sync)
  1407. {
  1408. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1409. if (f == null) return false;
  1410. return f.IsLowLevelAlarmActive;
  1411. }
  1412. }
  1413. // helper: check and raise low level alarm when necessary
  1414. private void CheckAndTriggerLowLevelAlarm(ScrewFeederInfo f)
  1415. {
  1416. if (f == null) return;
  1417. if (f.LowLevelAlarmEnabled && f.RemainingCount <= f.LowLevelThreshold)
  1418. {
  1419. if (!f.IsLowLevelAlarmActive)
  1420. {
  1421. f.IsLowLevelAlarmActive = true;
  1422. try
  1423. {
  1424. ScrewFeederLowLevelAlarmTriggered?.Invoke(f.Clone());
  1425. }
  1426. catch { }
  1427. }
  1428. }
  1429. else
  1430. {
  1431. if (f.IsLowLevelAlarmActive)
  1432. {
  1433. f.IsLowLevelAlarmActive = false;
  1434. }
  1435. }
  1436. }
  1437. /// <summary>
  1438. /// 为指锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷诺菁锟街革拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷惴碉拷锟?-1
  1439. /// </summary>
  1440. public int DecrementScrewCountByFeederNumber(int feederNumber, int decrement = 1)
  1441. {
  1442. lock (_sync)
  1443. {
  1444. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1445. if (f == null) return -1;
  1446. if (decrement <= 0) decrement = 1;
  1447. if (f.RemainingCount < decrement) return -1;
  1448. f.RemainingCount -= decrement;
  1449. // check alarm
  1450. CheckAndTriggerLowLevelAlarm(f);
  1451. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1452. return f.RemainingCount;
  1453. }
  1454. }
  1455. /// <summary>
  1456. /// 锟斤拷锟街革拷锟斤拷锟斤拷锟斤拷锟斤拷锟脚碉拷锟斤拷丝锟斤拷息锟斤拷锟斤拷锟轿猴拷锟矫空o拷剩锟斤拷锟斤拷锟斤拷锟斤拷0锟斤拷
  1457. /// </summary>
  1458. public void ClearScrewFeederByNumber(int feederNumber)
  1459. {
  1460. lock (_sync)
  1461. {
  1462. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1463. if (f == null) return;
  1464. f.BatchNumber = string.Empty;
  1465. f.RemainingCount = 0;
  1466. // check alarm
  1467. CheckAndTriggerLowLevelAlarm(f);
  1468. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1469. }
  1470. }
  1471. /// <summary>
  1472. /// 为指锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷魏牛锟斤拷锟斤拷锟皆�拷锟绞o拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭伙拷锟斤拷锟絇ackSize锟斤拷
  1473. /// </summary>
  1474. public void SetBatchForFeederNumber(int feederNumber, string batchNumber)
  1475. {
  1476. if (string.IsNullOrWhiteSpace(batchNumber)) return;
  1477. //锟斤拷取锟斤拷前锟侥诧拷锟斤拷员锟矫伙拷锟斤拷
  1478. string operatorName = _systemDatabaseService.GetCurrentUser()?.UserName;
  1479. // capture values under lock, then record to DB outside lock
  1480. ScrewFeederInfo target = null;
  1481. int remainingAfter = 0;
  1482. int packSize = 0;
  1483. string feederName = null;
  1484. int previousCount = 0;
  1485. lock (_sync)
  1486. {
  1487. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1488. if (f == null) return;
  1489. f.BatchNumber = batchNumber;
  1490. previousCount = f.RemainingCount;
  1491. f.RemainingCount += Math.Max(0, f.PackSize);
  1492. // prepare capture values
  1493. target = f;
  1494. remainingAfter = f.RemainingCount;
  1495. packSize = f.PackSize;
  1496. feederName = f.Name;
  1497. // check alarm
  1498. CheckAndTriggerLowLevelAlarm(f);
  1499. FileHelper.WriteJsonFile(ScrewFeeders, ConfigPaths.ScrewFeedersConfigurationPath);
  1500. }
  1501. try
  1502. {
  1503. var record = new ScrewFeederBatchRecord
  1504. {
  1505. BatchNumber = batchNumber,
  1506. PackSize = packSize,
  1507. ChangeTime = DateTime.Now,
  1508. RemainingCount = remainingAfter,
  1509. FeederNumber = feederNumber,
  1510. FeederName = feederName,
  1511. PreviousCount = previousCount,
  1512. OperatorName = operatorName,
  1513. };
  1514. // try get operator name from system database service if available
  1515. try
  1516. {
  1517. var user = _systemDatabaseService?.GetCurrentUser();
  1518. if (user != null)
  1519. record.OperatorName = user.UserName;
  1520. }
  1521. catch
  1522. {
  1523. // ignore getting user failure
  1524. }
  1525. try
  1526. {
  1527. if (_systemDatabaseService != null)
  1528. {
  1529. _ = _systemDatabaseService.RecordScrewFeederBatchAsync(record);
  1530. }
  1531. }
  1532. catch
  1533. {
  1534. // 锟斤拷锟斤拷锟斤拷锟捷匡拷写锟斤拷锟斤拷螅�锟铰硷拷锟斤拷锟斤拷锟斤拷锟街?
  1535. }
  1536. }
  1537. catch
  1538. {
  1539. // ignore any error creating/recording the batch record
  1540. }
  1541. }
  1542. /// <summary>
  1543. /// 锟斤拷锟绞o拷锟斤拷锟剿匡拷欠癖ň锟?
  1544. /// </summary>
  1545. public bool CheckAlarm(int feederNumber)
  1546. {
  1547. lock (_sync)
  1548. {
  1549. var f = ScrewFeeders.FirstOrDefault(s => s.FeederNumber == feederNumber);
  1550. if (f == null) return false;
  1551. // check alarm
  1552. CheckAndTriggerLowLevelAlarm(f);
  1553. return f.IsLowLevelAlarmActive;
  1554. }
  1555. }
  1556. #endregion
  1557. #region 锟矫伙拷锟斤拷录刷锟斤拷锟斤拷
  1558. /// <summary>
  1559. /// 锟斤拷取刷锟斤拷锟斤拷锟斤拷锟斤拷
  1560. /// </summary>
  1561. /// <returns></returns>
  1562. public SerialPortConfig GetCardReaderConfig()
  1563. {
  1564. lock (_sync)
  1565. {
  1566. if (_cardReaderConfig != null)
  1567. return _cardReaderConfig;
  1568. if (File.Exists(ConfigPaths.CardReaderConfigurationPath))
  1569. {
  1570. try
  1571. {
  1572. _cardReaderConfig = FileHelper.ReadJsonFile<SerialPortConfig>(ConfigPaths.CardReaderConfigurationPath);
  1573. }
  1574. catch
  1575. {
  1576. // 锟斤拷锟斤拷取失锟杰o拷锟斤拷锟斤拷默锟斤拷锟斤拷锟矫诧拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟斤拷锟斤拷目锟斤拷锟斤拷锟斤拷锟斤拷锟矫诧拷锟斤拷一锟铰o拷
  1577. _cardReaderConfig = new SerialPortConfig();
  1578. try { FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath); } catch { }
  1579. }
  1580. }
  1581. else
  1582. {
  1583. _cardReaderConfig = new SerialPortConfig();
  1584. try { FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath); } catch { }
  1585. }
  1586. return _cardReaderConfig;
  1587. }
  1588. }
  1589. /// <summary>
  1590. /// 锟斤拷锟斤拷刷锟斤拷锟斤拷锟斤拷锟斤拷
  1591. /// </summary>
  1592. /// <param name="config"></param>
  1593. public void SaveCardReaderConfig(SerialPortConfig config)
  1594. {
  1595. if (config == null) return;
  1596. lock (_sync)
  1597. {
  1598. _cardReaderConfig = config;
  1599. try
  1600. {
  1601. FileHelper.WriteJsonFile(_cardReaderConfig, ConfigPaths.CardReaderConfigurationPath);
  1602. }
  1603. catch
  1604. {
  1605. // 锟斤拷锟皆持久伙拷锟斤拷锟斤拷锟斤拷锟斤拷目锟斤拷锟斤拷锟斤拷锟斤拷锟芥方锟斤拷一锟铰o拷锟斤拷锟斤拷锟斤拷锟斤拷要时锟斤拷锟斤拷锟斤拷志锟斤拷录
  1606. }
  1607. }
  1608. }
  1609. #endregion
  1610. #region 锟斤拷取锟斤拷锟斤拷锟斤拷锟斤拷
  1611. public void SaveTorqueReaderConfig(TorqueSerialPortConfig config)
  1612. {
  1613. if (config == null) return;
  1614. lock (_sync)
  1615. {
  1616. _torqueReaderConfig = config;
  1617. try
  1618. {
  1619. FileHelper.WriteJsonFile(_torqueReaderConfig, ConfigPaths.TorqueReaderConfigurationPath);
  1620. }
  1621. catch
  1622. {
  1623. // 锟斤拷锟皆持久伙拷锟斤拷锟斤拷锟斤拷锟斤拷目锟斤拷锟斤拷锟斤拷锟斤拷锟芥方锟斤拷一锟铰o拷锟斤拷锟斤拷锟斤拷锟斤拷要时锟斤拷锟斤拷锟斤拷志锟斤拷录
  1624. }
  1625. }
  1626. }
  1627. public TorqueSerialPortConfig GetTorqueReaderConfig()
  1628. {
  1629. lock (_sync)
  1630. {
  1631. if (_torqueReaderConfig != null)
  1632. return _torqueReaderConfig;
  1633. if (File.Exists(ConfigPaths.TorqueReaderConfigurationPath))
  1634. {
  1635. try
  1636. {
  1637. _torqueReaderConfig = FileHelper.ReadJsonFile<TorqueSerialPortConfig>(ConfigPaths.TorqueReaderConfigurationPath);
  1638. }
  1639. catch
  1640. {
  1641. // 锟斤拷锟斤拷取失锟杰o拷锟斤拷锟斤拷默锟斤拷锟斤拷锟矫诧拷锟斤拷锟斤拷锟侥硷拷锟斤拷锟斤拷锟斤拷目锟斤拷锟斤拷锟斤拷锟斤拷锟矫诧拷锟斤拷一锟铰o拷
  1642. _torqueReaderConfig = new TorqueSerialPortConfig();
  1643. try { FileHelper.WriteJsonFile(_torqueReaderConfig, ConfigPaths.TorqueReaderConfigurationPath); } catch { }
  1644. }
  1645. }
  1646. else
  1647. {
  1648. _torqueReaderConfig = new TorqueSerialPortConfig();
  1649. try { FileHelper.WriteJsonFile(_torqueReaderConfig, ConfigPaths.TorqueReaderConfigurationPath); } catch { }
  1650. }
  1651. return _torqueReaderConfig;
  1652. }
  1653. }
  1654. #endregion
  1655. /// <summary>
  1656. /// 锟酵凤拷锟斤拷源锟斤拷锟斤拷锟芥当前锟节达拷锟叫碉拷锟斤拷锟斤拷锟斤拷锟矫碉拷锟侥硷拷锟斤拷
  1657. /// </summary>
  1658. public void Dispose()
  1659. {
  1660. SaveAll();
  1661. GC.SuppressFinalize(this);
  1662. }
  1663. }
  1664. }