HouseDebugPageViewModel.cs 85 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840
  1. using CommunityToolkit.Mvvm.ComponentModel;
  2. using ivf_tl_Entity.CameraEntitys;
  3. using ivf_tl_Entity.ComEntitys;
  4. using ivf_tl_Entity.DebugEntitys;
  5. using ivf_tl_Entity.DTO;
  6. using ivf_tl_Entity.GlobalEnums;
  7. using ivf_tl_Operate.Converts;
  8. using ivf_tl_Operate.Debug;
  9. using ivf_tl_Operate.Helpers;
  10. using ivf_tl_Services;
  11. using IvfTl.Hardware;
  12. using IvfTl.Hardware.Impl;
  13. using IvfTl.AutoFocus.Layout;
  14. using Newtonsoft.Json;
  15. using Newtonsoft.Json.Linq;
  16. using System;
  17. using System.Collections.Generic;
  18. using System.Collections.ObjectModel;
  19. using System.Configuration;
  20. using System.DirectoryServices.ActiveDirectory;
  21. using System.IO;
  22. using System.Linq;
  23. using System.Reflection.Metadata;
  24. using System.Text;
  25. using System.Threading.Tasks;
  26. using System.Windows;
  27. using static ivf_tl_Operate.CustomUserControls.RecordBox;
  28. using System.Windows.Documents;
  29. namespace ivf_tl_Operate.ViewModel
  30. {
  31. public partial class HouseDebugPageViewModel : ObservableObject
  32. {
  33. public event Action<string> MessageEvent;
  34. public event Action<string, int, int> AddPicEvent;
  35. public event Action OpenVideoEvent;
  36. // M1-B2:调试页不再 new ComBin/new Camera 开第二个物理串口/相机。
  37. // 全部硬件动作走借用到的 HAL 句柄(_halLease.Serial / _halLease.Camera)——与采集端同一物理实例,
  38. // 配合 T1.3(前台借用时采集端暂停让出 ComBin),端口/相机占用根除(审计 B2)。
  39. /// <summary>借用到的串口句柄(与采集端同一实例);未持借用时为 null。</summary>
  40. private IvfTl.Hardware.ISerialChannel Serial => _halLease?.Serial;
  41. /// <summary>借用到的相机句柄(与采集端同一实例);未持借用时为 null。</summary>
  42. private IvfTl.Hardware.ICamera Cam => _halLease?.Camera;
  43. /// <summary>
  44. /// M1-03 HAL 前台借用凭证。打开调试页时向 HAL 申请该舱独占借用(HardwareUser.OperateDebug),
  45. /// HAL 自动暂停 control 对该舱的后台采集;关闭调试页 Dispose 归还,HAL 恢复采集。
  46. /// ⚠ 待验证 V-024:借用→暂停采集→归还恢复时序(调试取图 vs 后台采集切换不占用/不死锁,01 §3 M1 必过)。
  47. /// 说明(代码隔离 + 范围控制):调试页 ComBin/Camera 仍用 operate 侧 ivf_tl_Entity 具体类型——
  48. /// 因调试栈方法更全(Write*EEPROM / 电机正反向 / RawToRgb 等),control 侧 SerialHelper ComBin 未覆盖,
  49. /// 折叠进 HAL ISerialChannel 属 M2 统一。M1 通过 HAL 借用闸门保证"同舱同一时刻单一使用者",
  50. /// 杜绝与后台采集同时 Open 同 COM 口/Init 同相机。
  51. /// </summary>
  52. private IHardwareLease _halLease = null;
  53. // ── 自动对焦重构 D2-02-T3.4:调试页标定改"经 control 协作",不再 operate 本地自建 CalibrationEngine ──
  54. /// <summary>
  55. /// 调试会话客户端:经 control 本地 HTTP /debug/acquire 借该舱硬件,拿 sessionId(存 CurrentSessionId)。
  56. /// control 独立进程持有真硬件;operate 进程内 HAL 是空壳(从不 ScanDevices),故借硬件/预览/标定全走此 HTTP 协作。
  57. /// 借到后起心跳;ComHouseUnit 归还。会话失效回调提示重进调试。
  58. /// </summary>
  59. private DebugSessionClient _sessionClient;
  60. /// <summary>
  61. /// 16 孔标定协作客户端:复用同一 sessionId,封 control /debug/calibrate/{start,progress,recalibrate,stop}。
  62. /// acquire 成功后构造;ComHouseUnit 释放。
  63. /// </summary>
  64. private CalibrationClient _calibClient;
  65. /// <summary>标定进度轮询任务的取消源(IsRunning 转 false 或停止标定时取消)。</summary>
  66. private System.Threading.CancellationTokenSource _calibPollCts;
  67. /// <summary>
  68. /// 当前housesn
  69. /// </summary>
  70. public int CurrentHouseId { get; set; } = 1;
  71. /// <summary>当前借用会话 id(D2-02 第三阶段 acquire 时赋值;第二阶段预览用)。</summary>
  72. public string CurrentSessionId { get; set; }
  73. /// <summary>
  74. /// 当前ccdID
  75. /// </summary>
  76. public int CurrentCCDId { get; set; } = 0;
  77. /// <summary>
  78. /// 所有舱室
  79. /// </summary>
  80. public List<HouseInfo> HouseList { get; set; } = new List<HouseInfo>();
  81. /// <summary>
  82. /// 仪器设置
  83. /// </summary>
  84. public TLSetting tLSetting { get; set; } = new TLSetting();
  85. /// <summary>
  86. /// 自动对焦和拍照位置
  87. /// </summary>
  88. public List<HousePhotographLocation> ccdPhoto = new List<HousePhotographLocation>();
  89. /// <summary>
  90. /// 水平电机位置
  91. /// </summary>
  92. public List<HouseWellSetting> houseWellSettingList = new List<HouseWellSetting>();
  93. [ObservableProperty]
  94. private ObservableCollection<string> messageInfoList = new ObservableCollection<string>();
  95. [ObservableProperty]
  96. private decimal temperature = 0m;
  97. [ObservableProperty]
  98. private decimal pressure = 0m;
  99. [ObservableProperty]
  100. private string doorState = null;
  101. [ObservableProperty]
  102. private string ledState = null;
  103. [ObservableProperty]
  104. private int currentWell = 0;
  105. [ObservableProperty]
  106. private int currentFocal = 0;
  107. /// <summary>
  108. /// 结束抓图
  109. /// </summary>
  110. public bool IsStop { get; set; } = false;
  111. /// <summary>
  112. /// M2-05 一键标定中止标志(工程师可中止;每 well 间检查)。
  113. /// </summary>
  114. public bool IsStopCalibrate { get; set; } = false;
  115. /// <summary>
  116. /// M2-05 一键标定是否进行中(UI 据此禁用重复触发)。
  117. /// </summary>
  118. [ObservableProperty]
  119. private bool isCalibrating = false;
  120. /// <summary>
  121. /// M2-05 场景A 一键标定 16 well 实时结果(合格绿/伪峰红,含 FocusZ/峰比/偏移)。
  122. /// View 绑定此集合做 4x4 实时呈现(沿用调试页内呈现,不另开 CalibWindow)。
  123. /// </summary>
  124. public ObservableCollection<WellCalibUiItem> CalibResults { get; } = new ObservableCollection<WellCalibUiItem>();
  125. /// <summary>
  126. /// 垂直电机当前位置
  127. /// </summary>
  128. [ObservableProperty]
  129. private int currentVer = 0;
  130. /// <summary>
  131. /// 水平电机当前位置
  132. /// </summary>
  133. [ObservableProperty]
  134. private int currentHor = 0;
  135. [ObservableProperty]
  136. private HouseInfo currentHouse = null;
  137. [ObservableProperty]
  138. private int houseVentTimeE = 0;
  139. public HouseDebugPageViewModel()
  140. {
  141. //HouseList = AppData.Instance.HttpHelper.GetSettingHouseApi(AppData.Instance.TlSn);
  142. //CurrentHouse = HouseList.FirstOrDefault(x => x.houseSn == 1);
  143. }
  144. private void ExLog(Exception ex, string name)
  145. {
  146. AppData.Instance.LogHelper.ExceptionLog(ex, $"HouseDebugPageViewModel.{name}", LogEnum.RunException);
  147. }
  148. private void ErrorLog(string message, LogEnum logType)
  149. {
  150. AppData.Instance.LogHelper.TLLog($"HouseDebugPageViewModel.{message}", logType);
  151. }
  152. public void Start(ref string errora)
  153. {
  154. try
  155. {
  156. SerialBin serialBin = new SerialBin();
  157. serialBin.TLLogEvent += AppData.Instance.LogHelper.TLLog;
  158. serialBin.ExceptionLogEvent += AppData.Instance.LogHelper.ExceptionLog;
  159. serialBin.HouseLogEvent += AppData.Instance.LogHelper.HouseLog;
  160. var errorList = serialBin.UpdataCamera();
  161. AppData.Instance.LogHelper.TLLog($"ccdidsn:{JsonConvert.SerializeObject(serialBin.CCDidSn)}", LogEnum.RunRecord);
  162. if (errorList.Any())
  163. {
  164. errora = $"获取相机Id和CCDSN错误{JsonConvert.SerializeObject(errorList)}";
  165. AppData.Instance.LogHelper.TLLog(errora, LogEnum.RunRecord);
  166. return;
  167. }
  168. errorList = serialBin.Start(ConfigurationManager.AppSettings["autoFocus"].ToString());
  169. AppData.Instance.LogHelper.TLLog($"舱室信息:{JsonConvert.SerializeObject(serialBin.SerialModels)}", LogEnum.RunRecord);
  170. AppData.Instance.LogHelper.TLLog($"E方数据:{JsonConvert.SerializeObject(serialBin.HouseEEPROInfos)}", LogEnum.RunRecord);
  171. if (errorList.Any())
  172. {
  173. errora = $"获取串口信息错误{JsonConvert.SerializeObject(errorList)}";
  174. AppData.Instance.LogHelper.TLLog(errora, LogEnum.RunRecord);
  175. return;
  176. }
  177. var modelCount = serialBin.SerialModels.Count;
  178. if (modelCount != 11)
  179. {
  180. //string messageinfo = $"检测到{modelCount}个模块,是否继续运行?";
  181. string messageinfo = $" Detected {modelCount} cabin, are you sure to run?";
  182. MessageBoxResult aaa = MessageBox.Show(messageinfo, KeyToStringConvert.GetLanguageStringByKey("C0171"), MessageBoxButton.YesNo, MessageBoxImage.Question, MessageBoxResult.No, MessageBoxOptions.DefaultDesktopOnly);
  183. if (aaa != MessageBoxResult.Yes)
  184. {
  185. errora = "结束";
  186. return;
  187. }
  188. }
  189. List<int> listIntRunHoues = serialBin.SerialModels.Select(x => x.houseSn).ToList();
  190. TLInitData tLInitData = new TLInitData();
  191. tLInitData.tlSn = $"NEO-1-{serialBin.TLNum}";
  192. tLInitData.softwareVersion = "V2.0.0";
  193. tLInitData.verticalMotorPulseMax = 125000;
  194. tLInitData.houseLinkDataList = serialBin.SerialModels.OrderBy(x => x.houseSn).ToList();
  195. foreach (var item in serialBin.HouseEEPROInfos)
  196. {
  197. item.tlSn = tLInitData.tlSn;
  198. }
  199. tLInitData.houseEEPROInitDTOList = serialBin.HouseEEPROInfos.OrderBy(x => x.houseSn).ToList();
  200. AppData.Instance.LogHelper.TLLog($"舱室信息:{JsonConvert.SerializeObject(tLInitData)}", LogEnum.RunRecord);
  201. SettingDataApiData settingDataApiData = AppData.Instance.HttpHelper.GetSettingDataApi(tLInitData);
  202. if (settingDataApiData == null)
  203. {
  204. errora = $"{tLInitData.tlSn}获取仪器设置失败";
  205. return;
  206. }
  207. AppData.Instance.LogHelper.TLLog(JsonConvert.SerializeObject(settingDataApiData), LogEnum.RunRecord);
  208. tLSetting = AppData.Instance.ConvertHelper.ConvertToTLSetting(settingDataApiData.tlInfo, settingDataApiData.tlSetting);
  209. ccdPhoto = settingDataApiData.housePhotographLocation;
  210. houseWellSettingList = settingDataApiData.houseWellSettingList;
  211. HouseList = settingDataApiData.houseList;
  212. CurrentHouse = HouseList.FirstOrDefault(x => x.houseSn == 1);
  213. }
  214. catch (Exception ex)
  215. {
  216. AppData.Instance.LogHelper.ExceptionLog(ex, $"调试模式初始化", LogEnum.RunException);
  217. errora = $"调试模式初始化异常:{ex.Message}";
  218. }
  219. }
  220. public async Task ComHouseInit()
  221. {
  222. await Task.Run(async () =>
  223. {
  224. try
  225. {
  226. var currentHouse = HouseList.FirstOrDefault(x => x.houseSn == CurrentHouseId);
  227. if (currentHouse == null)
  228. {
  229. AddMessageInfo($"[{CurrentHouseId}]未获取到舱室信息,无法进入调试");
  230. return;
  231. }
  232. // D2-02-T3.4:先经 control HTTP 协作借该舱调试会话拿 sessionId(预览/标定/会话命令均依赖)。
  233. // control 独立进程持真硬件;operate 进程内 HAL 是空壳(从不 ScanDevices)、下面的本地 lease.Serial 取不到,
  234. // 故借硬件的"真正入口"是这里的 HTTP acquire。放在本地 HAL 借用之前,确保 sessionId 一定先建立。
  235. await AcquireDebugSessionAsync(currentHouse.houseSn);
  236. // M1-03/B2 HAL: 向 HAL 申请该舱前台借用——HAL 暂停 control 对本舱采集(T1.3)并让采集端让出串口/相机,
  237. // 调试页随后复用借用到的同一物理句柄(lease.Serial/lease.Camera),不再 new 第二个 ComBin/Camera 开同口/同相机。
  238. try
  239. {
  240. var gate = HardwareAccessLayer.Instance.GetHouseGate(currentHouse.houseSn);
  241. _halLease = gate.Acquire(HardwareUser.OperateDebug);
  242. if (_halLease == null)
  243. {
  244. AddMessageInfo($"[{currentHouse.houseSn}]该舱正被占用(采集/对焦),借用超时,稍后重试");
  245. return;
  246. }
  247. }
  248. catch (Exception le)
  249. {
  250. AddMessageInfo($"[{currentHouse.houseSn}]HAL 借用异常:{le.Message}");
  251. return;
  252. }
  253. if (Serial == null)
  254. {
  255. AddMessageInfo($"[{currentHouse.houseSn}]借用到的串口句柄为空(HAL 未 ScanDevices 到本舱?),无法进入调试");
  256. return;
  257. }
  258. if (!Serial.IsOpen)
  259. {
  260. // 物理口由采集端持有并保持打开;T1.3 暂停只停发不关口。此处兜底再开一次(幂等)。
  261. if (!Serial.Open())
  262. {
  263. AddMessageInfo($"[{currentHouse.houseSn}][{currentHouse.housePort}]借用串口未打开且兜底打开失败");
  264. return;
  265. }
  266. }
  267. AddMessageInfo($"[{currentHouse.houseSn}][{currentHouse.housePort}]调试已复用采集端串口句柄(同一物理口)");
  268. // 相机:复用借用到的同一相机句柄。采集端通常已 Init+SetOpMode;仅在未 Init 时兜底 Init,
  269. // 然后统一设单帧采集模式(mode=0)供调试抓图,避免重复 Init 扰动采集端相机。
  270. if (Cam == null)
  271. {
  272. AddMessageInfo($"[{currentHouse.houseSn}]本舱无相机句柄(buffer/无相机舱?),跳过相机初始化");
  273. }
  274. else
  275. {
  276. if (!Cam.IsInit)
  277. {
  278. int cameraInit = Cam.Init();
  279. AddMessageInfo($"[CCD模块初始化]CCDID={CurrentCCDId},SN={currentHouse.ccdSn} 初始化结果:{cameraInit}[0=成功]");
  280. if (cameraInit != 0) return;
  281. }
  282. int cameraSetMode = Cam.SetOpMode();
  283. AddMessageInfo($"[CCD模块初始化]开启图像捕捉结果:{cameraSetMode}[0=成功]");
  284. if (cameraSetMode != 0) return;
  285. }
  286. var currentHorSetting = houseWellSettingList.FirstOrDefault(x => x.houseSn == currentHouse.houseSn && x.wellSn == 1);
  287. if (currentHorSetting == null)
  288. {
  289. AddMessageInfo($"[{currentHouse.houseSn}][{currentHouse.housePort}][未获取到1号well的水平电机位置]");
  290. return;
  291. }
  292. //OpenVideoEvent?.Invoke();
  293. var verNewValue = currentHorSetting.eepromClearPosition;
  294. var cc = ccdPhoto.FirstOrDefault(x => x.houseSn == currentHouse.houseSn && x.wellSn == 1);
  295. if (cc != null)
  296. {
  297. verNewValue = cc.clearestPosition;
  298. }
  299. // Task3.4b:进入调试的握手/电机归位/读数序列同走 control(operate Serial 空壳)。
  300. await RunDebugCommandAsync("进入调试-握手", "ShakeHands", null, new { houseSn = currentHouse.houseSn });
  301. await OpenLed();
  302. await RunDebugCommandAsync("进入调试-水平复位", "HorizontalReset", new { motorDelay = tLSetting.motorDelay }, new { houseSn = currentHouse.houseSn });
  303. CurrentHor = 0;
  304. CurrentWell = 0;
  305. await RunDebugCommandAsync("进入调试-水平到位", "HorizontalMoveTo",
  306. new { pos = currentHorSetting.horizontalMotorPosition, motorDelay = tLSetting.motorDelay }, new { houseSn = currentHouse.houseSn });
  307. CurrentHor = currentHorSetting.horizontalMotorPosition;
  308. CurrentWell = 1;
  309. await RunDebugCommandAsync("进入调试-垂直复位", "VerticalReset", new { motorDelay = tLSetting.motorDelay }, new { houseSn = currentHouse.houseSn });
  310. CurrentVer = 0;
  311. CurrentFocal = 0;
  312. await RunDebugCommandAsync("进入调试-垂直到位", "VerticalMoveTo",
  313. new { pos = verNewValue, motorDelay = tLSetting.motorDelay }, new { houseSn = currentHouse.houseSn });
  314. CurrentVer = verNewValue;
  315. CurrentFocal = 1;
  316. await RedTem();
  317. await RedPre();
  318. await RedDoor();
  319. await RedVentTime();
  320. return;
  321. }
  322. catch (Exception ex)
  323. {
  324. AppData.Instance.LogHelper.ExceptionLog(ex, "调试模式初始化", LogEnum.RunException);
  325. AddMessageInfo($"初始化异常:{ex.Message}");
  326. return;
  327. }
  328. });
  329. }
  330. public bool ComHouseUnit()
  331. {
  332. try
  333. {
  334. // D2-02-T3.4:先停标定轮询、归还 control 协作会话(停心跳),再归还本地 HAL 借用。
  335. // (Critical 并发兜底)正常退出时先主动通知 control 停标定(bounded 等一下让停标请求到达),
  336. // 让 control 端尽早停 coordinator —— control 端 onSessionClosing→StopAndWait 已兜底超时回收路径,
  337. // 这里是双保险,使正常退出更快停标、缩短"标定后台线程仍在跑"的窗口。失败不阻断卸载。
  338. var calib = _calibClient;
  339. if (calib != null)
  340. {
  341. try { calib.StopAsync().Wait(3000); } catch (Exception ex) { ExLog(ex, "ComHouseUnit.StopAsync"); }
  342. }
  343. StopCalibPolling();
  344. ReleaseDebugSession();
  345. // M1-B2:物理串口/相机由采集端(control)持有,调试只归还借用,绝不 ClosePort/UnInit 关物理口——
  346. // 否则会把采集端的口/相机一并关掉。归还后 HAL 触发 ResumeCapture 恢复本舱采集(T1.3)。
  347. if (_halLease != null)
  348. {
  349. try { _halLease.Dispose(); } catch { }
  350. _halLease = null;
  351. AddMessageInfo($"[{CurrentHouseId}]已归还借用,恢复后台采集");
  352. }
  353. return true;
  354. }
  355. catch (Exception ex)
  356. {
  357. AppData.Instance.LogHelper.ExceptionLog(ex, "调试模式卸载", LogEnum.RunException);
  358. AddMessageInfo($"卸载异常:{ex.Message}");
  359. return false;
  360. }
  361. }
  362. #region D2-02-T3.4 调试会话协作(借硬件拿 sessionId / 归还)
  363. /// <summary>
  364. /// 向 control 借该舱调试会话:POST /debug/acquire {houseSn} → 拿 sessionId 存 CurrentSessionId,
  365. /// 并构造 16 孔标定协作客户端 CalibrationClient(复用同一 sessionId)。
  366. /// control 借用成功会起心跳;会话失效(SESSION_EXPIRED)回调提示工程师重进调试。
  367. /// 借不到(BUSY/会话异常)只提示不抛——预览/标定将因 CurrentSessionId 为空而拒绝执行。
  368. /// </summary>
  369. private async Task AcquireDebugSessionAsync(int houseSn)
  370. {
  371. try
  372. {
  373. // 关旧会话(重复初始化时)。
  374. ReleaseDebugSession();
  375. var client = new DebugSessionClient(ControlClient.BaseUrl);
  376. client.OnSessionExpired = () =>
  377. {
  378. CurrentSessionId = null;
  379. AddMessageInfo("⚠ 调试会话已失效(control 端超时回收),请退出后重新进入调试");
  380. };
  381. var r = await client.AcquireAsync(houseSn);
  382. if (!r.Ok || string.IsNullOrEmpty(r.SessionId))
  383. {
  384. try { client.Dispose(); } catch { }
  385. AddMessageInfo($"[{houseSn}]借调试会话失败:{r.Code}/{r.Error}(预览与标定不可用,请确认 control 已托管该舱)");
  386. return;
  387. }
  388. _sessionClient = client;
  389. CurrentSessionId = r.SessionId;
  390. // 标定协作客户端复用同一 baseUrl + sessionId。
  391. _calibClient = new CalibrationClient(ControlClient.BaseUrl, r.SessionId);
  392. string cultMsg = r.Cultivating ? $"(注意:该舱培养中,胚胎 {r.EmbryoCount} 枚)" : "";
  393. AddMessageInfo($"[{houseSn}]调试会话已建立 sessionId={r.SessionId}{cultMsg}");
  394. }
  395. catch (Exception ex)
  396. {
  397. ExLog(ex, "AcquireDebugSessionAsync");
  398. AddMessageInfo($"[{houseSn}]借调试会话异常:{ex.Message}");
  399. }
  400. }
  401. /// <summary>归还调试会话(停心跳、通知 control)并释放协作客户端。幂等。
  402. /// release 的 HTTP POST 放后台跑(避免 control 失联时 HttpClient 默认 100s 超时卡死 UI 线程);
  403. /// DebugSessionClient.ReleaseAsync 在 await POST 前已同步置闸+停心跳,故心跳即时停止、不必等 POST。</summary>
  404. private void ReleaseDebugSession()
  405. {
  406. var calib = _calibClient; _calibClient = null;
  407. if (calib != null) { try { calib.Dispose(); } catch { } }
  408. var sc = _sessionClient; _sessionClient = null;
  409. if (sc != null)
  410. {
  411. // 后台 best-effort 归还+释放;失败也无妨(control 端 TTL 看门狗会超时回收会话)。
  412. Task.Run(async () =>
  413. {
  414. try { await sc.ReleaseAsync(); } catch { }
  415. try { sc.Dispose(); } catch { }
  416. });
  417. }
  418. CurrentSessionId = null;
  419. }
  420. #endregion
  421. // ── 自动对焦重构 D2-02-T3.4b:调试页手动命令统一走 control 的 /debug/command ──
  422. // operate 进程内 HAL 是空壳(从不 ScanDevices)、Serial/Cam 在真机上取不到真硬件;
  423. // control 独立进程持真硬件,故手动电机/光源/阀/EEPROM/曝光全经 _sessionClient.CommandAsync 下发。
  424. // 埋点不丢:沿用 OperationScope(同 M8-G3-1),据 CommandAsync 返回 Ok 记成功/失败。
  425. /// <summary>
  426. /// 统一执行一个调试手动命令:经 control HTTP /debug/command 下发 + 操作日志埋点 + 失败/会话失效提示。
  427. /// 返回 control 的 AcquireResult(读命令的值从 r.Result 取);会话未建立或失败返回 null/!Ok。
  428. /// </summary>
  429. private async Task<AcquireResult> RunDebugCommandAsync(string operation, string op, object args, object input)
  430. {
  431. if (_sessionClient == null || string.IsNullOrEmpty(CurrentSessionId))
  432. {
  433. AddMessageInfo($"[{operation}]未持调试会话,请重新进入调试页");
  434. return null;
  435. }
  436. using var _op = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", operation, houseSn: CurrentHouseId);
  437. try { _op.Input(input); } catch { }
  438. AcquireResult r;
  439. try
  440. {
  441. r = await _sessionClient.CommandAsync(op, args);
  442. }
  443. catch (Exception ex)
  444. {
  445. _op.Fail(ex.GetType().Name + ": " + ex.Message);
  446. AddMessageInfo($"[{operation}]下发异常:{ex.Message}");
  447. return null;
  448. }
  449. if (r == null) { _op.Fail("空响应"); AddMessageInfo($"[{operation}]无响应"); return null; }
  450. if (r.Ok) { _op.Success(r.Result); }
  451. else
  452. {
  453. _op.Fail(r.Code + ": " + r.Error);
  454. if (r.Code == "SESSION_EXPIRED")
  455. AddMessageInfo($"[{operation}]调试会话已失效,请重新进入调试页");
  456. else
  457. AddMessageInfo($"[{operation}]失败:{r.Error}");
  458. }
  459. return r;
  460. }
  461. /// <summary>
  462. /// 读温度
  463. /// </summary>
  464. public async Task RedTem()
  465. {
  466. var r = await RunDebugCommandAsync("读温度", "ReadTemp", null, new { houseSn = CurrentHouseId });
  467. if (r != null && r.Ok && r.Result != null && decimal.TryParse(r.Result.ToString(), out var t)) Temperature = t;
  468. }
  469. /// <summary>
  470. /// 读压力
  471. /// </summary>
  472. public async Task RedPre()
  473. {
  474. var r = await RunDebugCommandAsync("读压力", "ReadPressure", null, new { houseSn = CurrentHouseId });
  475. if (r != null && r.Ok && r.Result != null && decimal.TryParse(r.Result.ToString(), out var p)) Pressure = p;
  476. }
  477. /// <summary>
  478. /// 读舱门
  479. /// </summary>
  480. public async Task RedDoor()
  481. {
  482. var r = await RunDebugCommandAsync("读舱门", "ReadDoor", null, new { houseSn = CurrentHouseId });
  483. if (r == null || !r.Ok) return;
  484. string DoorStateString = r.Result?.ToString();
  485. if(DoorStateString == "关闭")
  486. {
  487. DoorState = KeyToStringConvert.GetLanguageStringByKey("C0305");
  488. }
  489. if (DoorStateString == "打开")
  490. {
  491. DoorState = KeyToStringConvert.GetLanguageStringByKey("C0306");
  492. }
  493. }
  494. /// <summary>
  495. /// 打开Led灯
  496. /// </summary>
  497. public async Task OpenLed()
  498. {
  499. // M8-G3-1:LED 开关为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  500. await RunDebugCommandAsync("打开LED灯", "OpenLed", null, new { houseSn = CurrentHouseId });
  501. LedState = KeyToStringConvert.GetLanguageStringByKey("C0306");
  502. //LedState = "开启";
  503. }
  504. /// <summary>
  505. /// 关闭Led灯
  506. /// </summary>
  507. public async Task CloseLed()
  508. {
  509. // M8-G3-1:LED 开关为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  510. await RunDebugCommandAsync("关闭LED灯", "CloseLed", null, new { houseSn = CurrentHouseId });
  511. //LedState = "关闭";
  512. LedState = KeyToStringConvert.GetLanguageStringByKey("C0305");
  513. }
  514. /// <summary>
  515. /// 打开进气阀
  516. /// </summary>
  517. public async Task OpenIntake()
  518. {
  519. // M8-G3-1:进气阀开关为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  520. await RunDebugCommandAsync("打开进气阀", "OpenIntake", null, new { houseSn = CurrentHouseId });
  521. }
  522. /// <summary>
  523. /// 关闭进气阀
  524. /// </summary>
  525. public async Task CloseIntake()
  526. {
  527. // M8-G3-1:进气阀开关为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  528. await RunDebugCommandAsync("关闭进气阀", "CloseIntake", null, new { houseSn = CurrentHouseId });
  529. }
  530. /// <summary>
  531. /// 打开排气阀
  532. /// </summary>
  533. public async Task OpenExhaust()
  534. {
  535. // M8-G3-1:排气阀开关为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  536. await RunDebugCommandAsync("打开排气阀", "OpenExhaust", null, new { houseSn = CurrentHouseId });
  537. }
  538. /// <summary>
  539. /// 关闭排气阀
  540. /// </summary>
  541. public async Task CloseExhaust()
  542. {
  543. // M8-G3-1:排气阀开关为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  544. await RunDebugCommandAsync("关闭排气阀", "CloseExhaust", null, new { houseSn = CurrentHouseId });
  545. }
  546. /// <summary>
  547. /// 舱室补气
  548. /// </summary>
  549. public async Task HouseAeration()
  550. {
  551. // M8-G3-1:舱室补气为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  552. await RunDebugCommandAsync("舱室补气", "HouseAeration", null, new { houseSn = CurrentHouseId });
  553. }
  554. /// <summary>
  555. /// 舱室排气
  556. /// </summary>
  557. public async Task HouseVent()
  558. {
  559. // M8-G3-1:舱室排气为串口设备命令入口,补操作日志埋点(module=对焦调试)。
  560. await RunDebugCommandAsync("舱室排气", "HouseVent", null, new { houseSn = CurrentHouseId });
  561. }
  562. /// <summary>
  563. /// 写舱室进气阀时间
  564. /// </summary>
  565. /// <param name="newValue"></param>
  566. public async Task WriteOpenIntakeTime(int newValue)
  567. {
  568. // M8-G3-1:写舱室进气阀时间为写 EEPROM 设备命令入口,补操作日志埋点(module=对焦调试)。
  569. await RunDebugCommandAsync("写舱室进气阀时间", "WriteOpenIntakeTime", new { value = newValue },
  570. new { houseSn = CurrentHouseId, newValue });
  571. }
  572. /// <summary>
  573. /// 写舱室排气阀时间
  574. /// </summary>
  575. /// <param name="newValue"></param>
  576. public async Task WriteOpenVentTime(int newValue)
  577. {
  578. // M8-G3-1:写舱室排气阀时间为写 EEPROM 设备命令入口,补操作日志埋点(module=对焦调试)。
  579. var r = await RunDebugCommandAsync("写舱室排气阀时间", "WriteOpenVentTime", new { value = newValue },
  580. new { houseSn = CurrentHouseId, newValue });
  581. if (r == null || !r.Ok)
  582. {
  583. AddMessageInfo($"[排气阀时间]下发失败,仅本地暂存{newValue}");
  584. }
  585. HouseVentTimeE = newValue;
  586. }
  587. /// <summary>
  588. /// 读舱室排气阀打开时间
  589. /// </summary>
  590. public async Task RedVentTime()
  591. {
  592. var r = await RunDebugCommandAsync("读排气阀时间", "ReadVentTime", null, new { houseSn = CurrentHouseId });
  593. if (r != null && r.Ok && r.Result != null && int.TryParse(r.Result.ToString(), out var v) && v >= 0)
  594. HouseVentTimeE = v;
  595. }
  596. /// <summary>
  597. /// 写垂直电机间隔脉冲
  598. /// </summary>
  599. /// <param name="newValue"></param>
  600. public async Task WriteOVerSpace(int newValue)
  601. {
  602. // M8-G3-1:写垂直电机间隔脉冲为写 EEPROM 设备命令入口,补操作日志埋点(module=对焦调试)。
  603. await RunDebugCommandAsync("写垂直电机间隔脉冲", "WriteScanStep", new { value = newValue },
  604. new { houseSn = CurrentHouseId, newValue });
  605. }
  606. /// <summary>
  607. /// 保存水平电机位置
  608. /// </summary>
  609. /// <param name="newValue"></param>
  610. public async Task SaveWellHor()
  611. {
  612. // M8-P3b:手调保存水平电机位置(关键命令入口,module=对焦调试)。
  613. await RunDebugCommandAsync("手调保存水平电机位置", "WriteWellHorizontalPos",
  614. new { well = CurrentWell, hor = CurrentHor },
  615. new { houseSn = CurrentHouseId, well = CurrentWell, hor = CurrentHor });
  616. }
  617. #region 电机运动
  618. /// <summary>
  619. /// 水平电机复位
  620. /// </summary>
  621. public async Task HorizontalMotorReset()
  622. {
  623. // M8-P3b:电机控制命令埋点(module=对焦调试)。
  624. await RunDebugCommandAsync("水平电机复位", "HorizontalReset", new { motorDelay = tLSetting.motorDelay },
  625. new { houseSn = CurrentHouseId });
  626. CurrentHor = 0;
  627. CurrentWell = 0;
  628. }
  629. /// <summary>
  630. /// 水平电机正向
  631. /// </summary>
  632. public async Task HorizontalMotorForward(int value)
  633. {
  634. // M8-G3-1:电机控制命令入口,补操作日志埋点(module=对焦调试)。
  635. await RunDebugCommandAsync("水平电机正向", "HorizontalForward", new { value, motorDelay = tLSetting.motorDelay },
  636. new { houseSn = CurrentHouseId, value });
  637. CurrentHor += value;
  638. }
  639. /// <summary>
  640. /// 水平电机反向
  641. /// </summary>
  642. public async Task HorizontalMotorBackward(int value)
  643. {
  644. // M8-G3-1:电机控制命令入口,补操作日志埋点(module=对焦调试)。
  645. await RunDebugCommandAsync("水平电机反向", "HorizontalBackward", new { value, motorDelay = tLSetting.motorDelay },
  646. new { houseSn = CurrentHouseId, value });
  647. CurrentHor -= value;
  648. }
  649. /// <summary>
  650. /// 水平电机到目标well
  651. /// </summary>
  652. /// <param name="newWell"></param>
  653. public async Task HorizontalMotorToWell(int newWell)
  654. {
  655. var currentHorSetting = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == newWell);
  656. if (currentHorSetting == null)
  657. {
  658. AddMessageInfo($"[未获取到{newWell}号well的水平电机位置]");
  659. return;
  660. }
  661. // M8-G3-1:电机控制命令入口,补操作日志埋点(module=对焦调试)。
  662. await RunDebugCommandAsync("水平电机到well", "HorizontalMoveTo",
  663. new { pos = currentHorSetting.horizontalMotorPosition, motorDelay = tLSetting.motorDelay },
  664. new { houseSn = CurrentHouseId, well = newWell, hor = currentHorSetting.horizontalMotorPosition });
  665. CurrentHor = currentHorSetting.horizontalMotorPosition;
  666. CurrentWell = newWell;
  667. }
  668. /// <summary>
  669. /// 垂直电机复位
  670. /// </summary>
  671. public async Task VerticalMotorReset()
  672. {
  673. // M8-P3b:电机控制命令埋点(module=对焦调试)。
  674. await RunDebugCommandAsync("垂直电机复位", "VerticalReset", new { motorDelay = tLSetting.motorDelay },
  675. new { houseSn = CurrentHouseId });
  676. CurrentVer = 0;
  677. }
  678. /// <summary>
  679. /// 垂直电机正向运动
  680. /// </summary>
  681. public async Task VerticalMotorForward(int newValue)
  682. {
  683. // M8-G3-1:电机控制命令入口,补操作日志埋点(module=对焦调试)。
  684. await RunDebugCommandAsync("垂直电机正向", "VerticalForward", new { value = newValue, motorDelay = tLSetting.motorDelay },
  685. new { houseSn = CurrentHouseId, newValue });
  686. CurrentVer += newValue;
  687. }
  688. /// <summary>
  689. /// 垂直电机反向运动
  690. /// </summary>
  691. public async Task VerticalMotorBackward(int newValue)
  692. {
  693. // M8-G3-1:电机控制命令入口,补操作日志埋点(module=对焦调试)。
  694. await RunDebugCommandAsync("垂直电机反向", "VerticalBackward", new { value = newValue, motorDelay = tLSetting.motorDelay },
  695. new { houseSn = CurrentHouseId, newValue });
  696. CurrentVer -= newValue;
  697. }
  698. /// <summary>
  699. /// 垂直电机绝对运动
  700. /// </summary>
  701. public async Task VerticalMotorAbsolute(int newValue)
  702. {
  703. // M8-G3-1:电机控制命令入口,补操作日志埋点(module=对焦调试)。
  704. await RunDebugCommandAsync("垂直电机绝对运动", "VerticalMoveTo", new { pos = newValue, motorDelay = tLSetting.motorDelay },
  705. new { houseSn = CurrentHouseId, newValue });
  706. CurrentVer = newValue;
  707. }
  708. /// <summary>
  709. /// 一键电机准备
  710. /// </summary>
  711. public async Task MototReady()
  712. {
  713. var currentHorSetting = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == 1);
  714. if (currentHorSetting == null)
  715. {
  716. AddMessageInfo($"[未获取到1号well的水平电机位置]");
  717. return;
  718. }
  719. var verNewValue = currentHorSetting.eepromClearPosition;
  720. var cc = ccdPhoto.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == 1);
  721. if (cc != null)
  722. {
  723. verNewValue = cc.clearestPosition;
  724. }
  725. // M8-G3-1:一键电机准备为多步串口动作流程,各子动作经 control 顺序下发(module=对焦调试)。
  726. using var _op = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", "一键电机准备",
  727. houseSn: CurrentHouseId);
  728. try { _op.Input(new { houseSn = CurrentHouseId, targetHor = currentHorSetting.horizontalMotorPosition, targetVer = verNewValue }); } catch { }
  729. await RunDebugCommandAsync("一键电机准备-水平复位", "HorizontalReset", new { motorDelay = tLSetting.motorDelay }, new { houseSn = CurrentHouseId });
  730. CurrentHor = 0;
  731. CurrentWell = 0;
  732. await RunDebugCommandAsync("一键电机准备-水平到位", "HorizontalMoveTo",
  733. new { pos = currentHorSetting.horizontalMotorPosition, motorDelay = tLSetting.motorDelay }, new { houseSn = CurrentHouseId });
  734. CurrentHor = currentHorSetting.horizontalMotorPosition;
  735. CurrentWell = 1;
  736. await RunDebugCommandAsync("一键电机准备-垂直复位", "VerticalReset", new { motorDelay = tLSetting.motorDelay }, new { houseSn = CurrentHouseId });
  737. CurrentVer = 0;
  738. CurrentFocal = 0;
  739. await RunDebugCommandAsync("一键电机准备-垂直到位", "VerticalMoveTo",
  740. new { pos = verNewValue, motorDelay = tLSetting.motorDelay }, new { houseSn = CurrentHouseId });
  741. CurrentVer = verNewValue;
  742. CurrentFocal = 1;
  743. }
  744. /// <summary>
  745. /// 单张抓拍
  746. /// </summary>
  747. public bool SavePic(string fullName)
  748. {
  749. try
  750. {
  751. if (GetPicData() == 0)
  752. {
  753. if (Cam == null) return false;
  754. // M8-G3-1:单张抓拍落盘为相机采图+保存命令入口,补操作日志埋点(module=对焦调试)。
  755. // 批量抓图(水平抓图/清晰图层抓图)经 Begin scope 调用时,本埋点自动成为其子埋点(父子链)。
  756. return Aivfo.OperationLog.OperationLogger.Run("对焦调试", "单张抓拍",
  757. () => Cam.SavePic(fullName, CurrentHouse.ccdWidth, CurrentHouse.ccdHeight),
  758. input: new { houseSn = CurrentHouseId, well = CurrentWell, focal = CurrentFocal, hor = CurrentHor, ver = CurrentVer });
  759. }
  760. return false;
  761. }
  762. catch (Exception ex)
  763. {
  764. AppData.Instance.LogHelper.ExceptionLog(ex, $"单张抓拍", LogEnum.RunException);
  765. AddMessageInfo($"单张抓拍异常:{ex.Message}");
  766. return false;
  767. }
  768. }
  769. /// <summary>
  770. /// 水平抓图
  771. /// </summary>
  772. public void ShuiPingZhuaPai()
  773. {
  774. try
  775. {
  776. IsStop = false;
  777. if (Serial == null) return;
  778. if (IsStop) return;
  779. // M8-G3-1:水平抓图为多步循环采图流程,用 Begin scope 串联各 well 抓拍子埋点(module=对焦调试)。
  780. using var _op = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", "水平抓图",
  781. houseSn: CurrentHouseId);
  782. try { _op.Input(new { houseSn = CurrentHouseId }); } catch { }
  783. Serial.HorizontalResetWait(tLSetting.motorDelay);
  784. CurrentHor = 0;
  785. CurrentWell = 0;
  786. HouseWellSetting currentHorSetting = null;
  787. string dtnow = string.Format("{0:yyyy-MM-dd-HH-mm-ss}", DateTime.Now); //24小时制
  788. string path = AppData.Instance.LogHelper.GetDeBugShuiPingDirectory(CurrentHouse.houseSn, dtnow);
  789. if (!Directory.Exists(path))
  790. {
  791. Directory.CreateDirectory(path);
  792. }
  793. for (int i = 1; i <= 16; i++)
  794. {
  795. currentHorSetting = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == i);
  796. if (currentHorSetting == null)
  797. {
  798. AddMessageInfo($"[未获取到1号well的水平电机位置]");
  799. continue;
  800. }
  801. if (IsStop) return;
  802. if (Serial == null) return;
  803. Serial.HorizontalMoveToWait(currentHorSetting.horizontalMotorPosition, tLSetting.motorDelay);
  804. if (IsStop) return;
  805. CurrentHor = currentHorSetting.horizontalMotorPosition;
  806. CurrentWell = i;
  807. string filename = $"{dtnow}-house{CurrentHouse.houseSn}-well{CurrentWell}-{CurrentFocal}-{CurrentHor}-{CurrentVer}.jpg";
  808. string fullName = $"{path}{filename}";
  809. if (Cam == null) return;
  810. if (SavePic(fullName))
  811. {
  812. AddPic(fullName);
  813. }
  814. }
  815. }
  816. catch (Exception ex)
  817. {
  818. AppData.Instance.LogHelper.ExceptionLog(ex, $"水平抓拍", LogEnum.RunException);
  819. AddMessageInfo($"水平抓拍异常:{ex.Message}");
  820. }
  821. }
  822. /// <summary>
  823. /// 清晰图层抓图
  824. /// </summary>
  825. public async Task AutoFocusPic(int focalCount, int xun)
  826. {
  827. await Task.Run(async () =>
  828. {
  829. try
  830. {
  831. IsStop = false;
  832. var startAutoFocus = -1;
  833. var cc = ccdPhoto.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == CurrentWell);
  834. if (cc == null)
  835. {
  836. AddMessageInfo($"[未获取到{CurrentWell}号well的自动对焦起点]");
  837. return;
  838. }
  839. // M8-G3-1:清晰图层抓图为多步循环采图流程,用 Begin scope 串联各层抓拍子埋点(module=对焦调试)。
  840. using var _op = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", "清晰图层抓图",
  841. houseSn: CurrentHouseId);
  842. try { _op.Input(new { houseSn = CurrentHouseId, well = CurrentWell, focalCount, xun }); } catch { }
  843. startAutoFocus = cc.autoFocusPosition;
  844. string dtnow = string.Format("{0:yyyy-MM-dd-HH-mm-ss}", DateTime.Now); //24小时制
  845. string path = null;
  846. string fullName = null;
  847. for (int k = 0; k < xun; k++)
  848. {
  849. if (IsStop) return;
  850. if (Serial == null) return;
  851. Serial.VerticalResetWait(tLSetting.motorDelay);
  852. CurrentVer = 0;
  853. CurrentFocal = 0;
  854. var verSpacePulse = 128;
  855. if (CurrentHouse.verticalMotorSpacePulse.HasValue) verSpacePulse = CurrentHouse.verticalMotorSpacePulse.Value;
  856. path = $"{AppData.Instance.LogHelper.GetDeBugQingXiDirectory(CurrentHouse.houseSn, CurrentWell, dtnow)}{(k + 1)}_{CurrentHor}";
  857. if (!Directory.Exists(path)) Directory.CreateDirectory(path);
  858. for (int i = 0; i < focalCount; i++)
  859. {
  860. CurrentFocal = i + 1;
  861. var currentVerValue = startAutoFocus + (i * verSpacePulse);
  862. if (IsStop) return;
  863. if (Serial == null) return;
  864. if(currentVerValue > tLSetting.verticalMotorPulseMax)
  865. {
  866. AddMessageInfo($"清晰图层抓图超出垂直电机上限:{tLSetting.verticalMotorPulseMax}");
  867. return;
  868. }
  869. Serial.VerticalMoveToWait(currentVerValue, tLSetting.motorDelay);
  870. CurrentVer = currentVerValue;
  871. fullName = $"{path}\\{currentVerValue}.jpg";
  872. if (IsStop) return;
  873. if (Cam == null) return;
  874. if (SavePic(fullName)) AddPic(fullName);
  875. }
  876. }
  877. }
  878. catch (Exception ex)
  879. {
  880. AppData.Instance.LogHelper.ExceptionLog(ex, $"清晰图层抓图", LogEnum.RunException);
  881. AddMessageInfo($"清晰图层抓图异常:{ex.Message}");
  882. }
  883. });
  884. }
  885. /// <summary>
  886. /// 抓图
  887. /// </summary>
  888. public int GetPicData()
  889. {
  890. try
  891. {
  892. if (Cam == null) return -1;
  893. int GetRgbData = -1;
  894. bool isWuTu = false;
  895. if (isWuTu)
  896. {
  897. GetRgbData = Cam.GrabRaw();//获取字节流
  898. AddMessageInfo($"[抓拍结果:{GetRgbData}][注:0表示成功]");
  899. if (GetRgbData == 0)
  900. {
  901. GetRgbData = Cam.RawToRgb();
  902. AddMessageInfo($"[rawToRgb结果:{GetRgbData}][注:0表示成功]");
  903. }
  904. }
  905. else
  906. {
  907. GetRgbData = Cam.GrabRgb();//获取字节流
  908. AddMessageInfo($"[抓拍结果:{GetRgbData}][注:0表示成功]");
  909. }
  910. return GetRgbData;
  911. }
  912. catch (Exception ex)
  913. {
  914. AppData.Instance.LogHelper.ExceptionLog(ex, $"调试模式抓拍", LogEnum.RunException);
  915. AddMessageInfo($"相机抓拍异常:{ex.Message}");
  916. return -1;
  917. }
  918. }
  919. #endregion
  920. #region 相机操作
  921. /// <summary>
  922. /// 设置曝光值
  923. /// </summary>
  924. /// <param name="newExporuse"></param>
  925. public async Task SetExposure(int newExporuse)
  926. {
  927. // M8-G3-1:设置相机曝光为相机设备命令入口,补操作日志埋点(module=对焦调试)。
  928. // Task3.4b:operate 相机空壳,曝光改走 control 借用的真相机(control 端 Execute 新增 SetExposure op)。
  929. var r = await RunDebugCommandAsync("设置相机曝光值", "SetExposure", new { value = newExporuse },
  930. new { houseSn = CurrentHouseId, ccdId = CurrentCCDId, newExporuse });
  931. if (r != null && r.Ok) AddMessageInfo($"设置曝光结果:{r.Result}");
  932. }
  933. /// <summary>
  934. /// 打开实时预览(贴宿主窗口句柄)。M1-B2:走借用到的 lease.Camera(StartPreview),不再触碰具体 Camera。
  935. /// 返回 0 成功;相机句柄为空返回 -1。
  936. /// </summary>
  937. public int StartPreview(IntPtr hostControl, int left, int top, int width, int height)
  938. {
  939. if (Cam == null) return -1;
  940. return Cam.StartPreview(hostControl, left, top, width, height);
  941. }
  942. /// <summary>关闭实时预览。返回 0 成功;相机句柄为空返回 -1。</summary>
  943. public int StopPreview()
  944. {
  945. if (Cam == null) return -1;
  946. return Cam.StopPreview();
  947. }
  948. //public bool OpenVideo(IntPtr mControlPtr, int left, int top, int width, int height)
  949. //{
  950. // try
  951. // {
  952. // var a = camera.Usb2Start(mControlPtr, left, top, width, height);
  953. // AddMessageInfo($"图像打开结果[0表示成功]:{a}");
  954. // return a == 0;
  955. // }
  956. // catch (Exception ex)
  957. // {
  958. // ExLog(ex, "OpenVideo");
  959. // AddMessageInfo($"图像打开异常:{ex.Message}");
  960. // return false;
  961. // }
  962. //}
  963. //public bool CloseVideo()
  964. //{
  965. // try
  966. // {
  967. // var a = camera.Usb2Stop();
  968. // AddMessageInfo($"图像关闭结果[0表示成功]:{a}");
  969. // return a == 0;
  970. // }
  971. // catch (Exception ex)
  972. // {
  973. // ExLog(ex, "CloseVideo");
  974. // AddMessageInfo($"图像关闭异常:{ex.Message}");
  975. // return false;
  976. // }
  977. //}
  978. #endregion
  979. #region 参数保存
  980. /// <summary>
  981. /// 保存舱室参数
  982. /// </summary>
  983. /// <returns></returns>
  984. public bool SetHouseInfo()
  985. {
  986. try
  987. {
  988. if (CurrentHouse == null) return true;
  989. string body = JsonConvert.SerializeObject(new
  990. {
  991. tlSn = CurrentHouse.tlSn,
  992. houseSn = CurrentHouse.houseSn,
  993. ccdExposure = CurrentHouse.ccdExposure,
  994. inletValveOpeningTime = CurrentHouse.inletValveOpeningTime,
  995. verticalMotorSpacePulse = CurrentHouse.verticalMotorSpacePulse,
  996. });
  997. return AppData.Instance.HttpHelper.HouseDebuggingApi(body);
  998. }
  999. catch (Exception ex)
  1000. {
  1001. ExLog(ex, "SetHouseExposure");
  1002. return false;
  1003. }
  1004. }
  1005. /// <summary>
  1006. /// 保存当前well位置
  1007. /// </summary>
  1008. /// <returns></returns>
  1009. public bool SetWellMotorPosition()
  1010. {
  1011. try
  1012. {
  1013. if (CurrentHouse == null)
  1014. {
  1015. AddMessageInfo("获取舱室信息失败");
  1016. }
  1017. string body = JsonConvert.SerializeObject(new
  1018. {
  1019. horizontalMotorPosition = CurrentHor,
  1020. houseSn = CurrentHouse.houseSn,
  1021. tlSn = CurrentHouse.tlSn,
  1022. wellSn = CurrentWell,
  1023. });
  1024. return AppData.Instance.HttpHelper.WellUpdateApi(body);
  1025. }
  1026. catch (Exception ex)
  1027. {
  1028. ExLog(ex, "SetWellMotorPosition");
  1029. return false;
  1030. }
  1031. }
  1032. /// <summary>
  1033. /// 保存自动对焦起点
  1034. /// </summary>
  1035. /// <returns></returns>
  1036. public bool SetWellAutoFocus()
  1037. {
  1038. try
  1039. {
  1040. if (CurrentHouse == null)
  1041. {
  1042. AddMessageInfo("获取舱室信息失败");
  1043. }
  1044. string body = JsonConvert.SerializeObject(new
  1045. {
  1046. verticalMotorPosition = CurrentVer,
  1047. houseSn = CurrentHouse.houseSn,
  1048. tlSn = CurrentHouse.tlSn,
  1049. wellSn = CurrentWell,
  1050. });
  1051. return AppData.Instance.HttpHelper.WellUpdateApi(body);
  1052. }
  1053. catch (Exception ex)
  1054. {
  1055. ExLog(ex, "SetWellAutoFocus");
  1056. return false;
  1057. }
  1058. }
  1059. #endregion
  1060. private void ComBin_ExceptionLogEvent(Exception exception, string arg2, string arg3, LogEnum @enum)
  1061. {
  1062. AppData.Instance.LogHelper.ExceptionLog(exception, $"{arg2}{arg3}", @enum);
  1063. }
  1064. private void ComBin_ErrorLogEvent(string arg1, LogEnum @enum)
  1065. {
  1066. AppData.Instance.LogHelper.TLLog(arg1, @enum);
  1067. }
  1068. private void ComBin_CommandLogEvent(int arg1, DateTime time, string arg3, LogEnum @enum)
  1069. {
  1070. AppData.Instance.LogHelper.HouseLog(arg1, time, arg3, @enum);
  1071. }
  1072. public void AddMessageInfo(string mess)
  1073. {
  1074. MessageEvent?.Invoke(mess);
  1075. }
  1076. public void AddPic(string picFullName)
  1077. {
  1078. AddPicEvent?.Invoke(picFullName, CurrentWell, CurrentFocal);
  1079. }
  1080. #region 场景A 一键全自动标定(经 control 协作,D2-02-T3.4 重构)
  1081. /// <summary>
  1082. /// 一键全自动标定(D2-02-T3.4 重构为"经 control 协作")。
  1083. /// 旧实现:operate 本地 new CalibrationEngine 逐 well 跑 + CalibrationStore 写 JSON/scene0(已停用)。
  1084. /// 新实现:operate 仅发 /debug/calibrate/start(经 CalibrationClient,复用 acquire 的 sessionId) →
  1085. /// 起轮询 /debug/calibrate/progress(~800ms) 把每孔状态映射到 16 格 UI(合格绿/伪峰橙/失败红 + FocusZ/峰比/偏移)。
  1086. /// 标定由 control 协作端真正执行(持真硬件)、scene=0 基准由 control 端落库。
  1087. /// 前提:ComHouseInit 已成功 acquire(CurrentSessionId 非空、_calibClient 已构造)。
  1088. /// 中止:StopCalibrate → /debug/calibrate/stop + 停轮询。
  1089. ///
  1090. /// ⚠ 待验证(compile-pending,operate.exe 卡死未编译):start/progress/stop 协作往返、16 格映射、合格判定一致。
  1091. /// </summary>
  1092. /// <param name="wells">勾选的 well 列表(空/null 视为全 16 well)。</param>
  1093. public async Task OneClickCalibrate(IEnumerable<int> wells = null)
  1094. {
  1095. if (IsCalibrating)
  1096. {
  1097. AddMessageInfo("[一键标定]已在标定中,请勿重复触发");
  1098. return;
  1099. }
  1100. if (_calibClient == null || string.IsNullOrEmpty(CurrentSessionId))
  1101. {
  1102. AddMessageInfo("[一键标定]未建立调试会话(请先初始化舱室借硬件),无法发起协作标定");
  1103. return;
  1104. }
  1105. if (CurrentHouse == null)
  1106. {
  1107. AddMessageInfo("[一键标定]未获取到舱室信息");
  1108. return;
  1109. }
  1110. // 勾选 well:未传则默认 16 well;去重、按序、限定 1-16。
  1111. var wellList = (wells ?? Enumerable.Range(1, 16))
  1112. .Where(w => w >= 1 && w <= 16).Distinct().OrderBy(w => w).ToList();
  1113. if (wellList.Count == 0) wellList = Enumerable.Range(1, 16).ToList();
  1114. IsCalibrating = true;
  1115. IsStopCalibrate = false;
  1116. try
  1117. {
  1118. // M8-P3b:一键标定发起为关键命令入口,记一条操作日志(start 同步发起;异步轮询单独不再串 scope,
  1119. // 避免 using scope 在方法返回即 Dispose 后被后台轮询误用)。
  1120. using (var _opScope = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", "一键标定发起(协作)", houseSn: CurrentHouseId))
  1121. {
  1122. try { _opScope.Input(new { houseSn = CurrentHouseId, wells = wellList.ToArray() }); } catch { }
  1123. ResetCalibResults(wellList);
  1124. // D2-02-T3.4:标定由 control 协作端执行(scene=0 落库由 control 端处理)。
  1125. // operate 仅发 start + 轮询进度刷新 16 格 UI,不再 operate 本地 new CalibrationEngine/CalibrationStore。
  1126. var r = await _calibClient.StartAsync(wellList);
  1127. if (!r.Ok)
  1128. {
  1129. IsCalibrating = false;
  1130. AddMessageInfo($"[一键标定]发起失败:{r.Code}/{r.Error}");
  1131. try { _opScope.Fail($"start 失败:{r.Code}/{r.Error}"); } catch { }
  1132. return;
  1133. }
  1134. try { _opScope.Output(new { started = true }).Success(); } catch { }
  1135. }
  1136. AddMessageInfo($"[一键标定]已发起(control 协作):舱{CurrentHouse.houseSn} 共 {wellList.Count} well,开始轮询进度...");
  1137. // 起轮询任务,把 control 端进度映射到 16 格 UI;IsRunning 转 false 即停。
  1138. StartCalibPolling();
  1139. }
  1140. catch (Exception ex)
  1141. {
  1142. IsCalibrating = false;
  1143. ExLog(ex, "OneClickCalibrate");
  1144. AddMessageInfo($"[一键标定]整体异常:{ex.Message}");
  1145. }
  1146. }
  1147. /// <summary>
  1148. /// D2-02-T3.4 单孔重标:经 control 协作端对该 well 重新标定一次,并起轮询刷新该格。
  1149. /// </summary>
  1150. public async Task RecalibrateWell(int wellSn)
  1151. {
  1152. if (_calibClient == null || string.IsNullOrEmpty(CurrentSessionId))
  1153. {
  1154. AddMessageInfo("[重标]未建立调试会话,无法重标");
  1155. return;
  1156. }
  1157. if (IsCalibrating)
  1158. {
  1159. AddMessageInfo("[重标]批量标定进行中,请先中止或等待结束");
  1160. return;
  1161. }
  1162. if (wellSn < 1 || wellSn > 16)
  1163. {
  1164. AddMessageInfo("[重标]well 只能为 1-16");
  1165. return;
  1166. }
  1167. try
  1168. {
  1169. IsCalibrating = true;
  1170. IsStopCalibrate = false;
  1171. UpdateCalibResult(wellSn, item => { item.State = WellCalibState.Running; item.Note = "重标中..."; });
  1172. var r = await _calibClient.RecalibrateAsync(wellSn);
  1173. if (!r.Ok)
  1174. {
  1175. IsCalibrating = false;
  1176. AddMessageInfo($"[重标]well{wellSn} 发起失败:{r.Code}/{r.Error}");
  1177. return;
  1178. }
  1179. AddMessageInfo($"[重标]well{wellSn} 已发起,轮询进度...");
  1180. StartCalibPolling();
  1181. }
  1182. catch (Exception ex)
  1183. {
  1184. IsCalibrating = false;
  1185. ExLog(ex, "RecalibrateWell");
  1186. AddMessageInfo($"[重标]well{wellSn} 异常:{ex.Message}");
  1187. }
  1188. }
  1189. /// <summary>工程师中止一键标定:通知 control 停标,停本地轮询。</summary>
  1190. public void StopCalibrate()
  1191. {
  1192. IsStopCalibrate = true;
  1193. AddMessageInfo("[一键标定]收到中止请求,通知 control 停止...");
  1194. var calib = _calibClient;
  1195. if (calib != null)
  1196. {
  1197. Task.Run(async () =>
  1198. {
  1199. try { await calib.StopAsync(); } catch (Exception ex) { ExLog(ex, "StopCalibrate.StopAsync"); }
  1200. });
  1201. }
  1202. // 轮询任务读到 IsRunning=false 后会自停;此处也主动停一次兜底。
  1203. StopCalibPolling();
  1204. }
  1205. /// <summary>
  1206. /// 起标定进度轮询(~800ms 一次):调 control /debug/calibrate/progress,
  1207. /// 把每孔 WellCalibProgressDto(State 数字枚举)映射到 16 格 WellCalibUiItem。
  1208. /// IsRunning 转 false(或会话失效返回 null)即停轮询并复位 IsCalibrating。
  1209. /// 同一时刻只跑一个轮询任务(先停旧的)。
  1210. /// </summary>
  1211. private void StartCalibPolling()
  1212. {
  1213. StopCalibPolling();
  1214. var cts = new System.Threading.CancellationTokenSource();
  1215. _calibPollCts = cts;
  1216. var token = cts.Token;
  1217. var calib = _calibClient;
  1218. Task.Run(async () =>
  1219. {
  1220. try
  1221. {
  1222. while (!token.IsCancellationRequested)
  1223. {
  1224. var dto = await calib.PollProgressAsync();
  1225. if (token.IsCancellationRequested) break;
  1226. if (dto == null)
  1227. {
  1228. // 会话失效/无进度:停轮询(会话失效另由 DebugSessionClient.OnSessionExpired 提示)。
  1229. AddMessageInfo("[一键标定]进度查询无结果(会话可能已失效),停止轮询");
  1230. break;
  1231. }
  1232. MapProgressToUi(dto);
  1233. if (!dto.IsRunning)
  1234. {
  1235. int okCount = CalibResults.Count(x => x.State == WellCalibState.Qualified);
  1236. AddMessageInfo($"[一键标定]结束:合格 {okCount}/{dto.Total}(scene=0 基准由 control 协作端落库)");
  1237. break;
  1238. }
  1239. await Task.Delay(800, token);
  1240. }
  1241. }
  1242. catch (TaskCanceledException) { /* 主动停 */ }
  1243. catch (Exception ex)
  1244. {
  1245. ExLog(ex, "CalibPolling");
  1246. AddMessageInfo($"[一键标定]轮询异常:{ex.Message}");
  1247. }
  1248. finally
  1249. {
  1250. IsCalibrating = false;
  1251. }
  1252. }, token);
  1253. }
  1254. /// <summary>停标定进度轮询(取消轮询任务)。幂等。</summary>
  1255. private void StopCalibPolling()
  1256. {
  1257. var cts = _calibPollCts;
  1258. _calibPollCts = null;
  1259. if (cts != null) { try { cts.Cancel(); } catch { } try { cts.Dispose(); } catch { } }
  1260. }
  1261. /// <summary>把 control 进度 DTO 的每孔状态映射到 16 格 UI(State 为数字枚举:0待标/1标定中/2合格/3伪峰/4失败)。</summary>
  1262. private void MapProgressToUi(CalibProgressDto dto)
  1263. {
  1264. if (dto?.Wells == null) return;
  1265. foreach (var w in dto.Wells)
  1266. {
  1267. var well = w; // 闭包捕获
  1268. UpdateCalibResult(well.WellSn, item =>
  1269. {
  1270. item.State = (WellCalibState)well.State; // 0..4 与 operate 端枚举顺序一致
  1271. item.FocusZ = well.FocusZ;
  1272. item.Exposure = well.Exposure;
  1273. item.PeakRatio = well.PeakRatio;
  1274. item.CenterOffsetPct = well.CenterOffsetPct;
  1275. item.CircleFound = well.CircleFound;
  1276. item.Note = string.IsNullOrEmpty(well.Note)
  1277. ? StateNote((WellCalibState)well.State, well.FocusZ, well.PeakRatio)
  1278. : well.Note;
  1279. });
  1280. }
  1281. }
  1282. private static string StateNote(WellCalibState st, int focusZ, double peakRatio) => st switch
  1283. {
  1284. WellCalibState.Pending => "待标定",
  1285. WellCalibState.Running => "标定中...",
  1286. WellCalibState.Qualified => $"合格 Z={focusZ} 峰比={peakRatio:F2}",
  1287. WellCalibState.FakePeak => $"伪峰 Z={focusZ} 峰比={peakRatio:F2}",
  1288. WellCalibState.Failed => "失败",
  1289. _ => ""
  1290. };
  1291. private void ResetCalibResults(List<int> wells)
  1292. {
  1293. void build()
  1294. {
  1295. CalibResults.Clear();
  1296. foreach (var w in wells)
  1297. CalibResults.Add(new WellCalibUiItem { Well = w, State = WellCalibState.Pending, Note = "待标定" });
  1298. }
  1299. // 集合改动需在 UI 线程(ObservableCollection 绑定)。
  1300. var disp = System.Windows.Application.Current?.Dispatcher;
  1301. if (disp != null && !disp.CheckAccess()) disp.Invoke(build); else build();
  1302. }
  1303. private void UpdateCalibResult(int well, Action<WellCalibUiItem> mutate)
  1304. {
  1305. void apply()
  1306. {
  1307. var item = CalibResults.FirstOrDefault(x => x.Well == well);
  1308. if (item == null)
  1309. {
  1310. item = new WellCalibUiItem { Well = well };
  1311. CalibResults.Add(item);
  1312. }
  1313. mutate(item);
  1314. }
  1315. var disp = System.Windows.Application.Current?.Dispatcher;
  1316. if (disp != null && !disp.CheckAccess()) disp.Invoke(apply); else apply();
  1317. }
  1318. #endregion
  1319. #region M2-07 对焦后手动微调拍摄层(层数/层间距/下移)持久化 well 级
  1320. /// <summary>
  1321. /// M2-07 手调"实际拍摄层数"(well 级覆盖)。空字符串=留空继承设备级(保存写 null)。
  1322. /// View TextBox 双向绑定;校验在保存/预览时做(层数≥1)。
  1323. /// </summary>
  1324. [ObservableProperty] private string manualLayerCount = "";
  1325. /// <summary>
  1326. /// M2-07 手调"实际拍摄层间距脉冲"(well 级覆盖)。空=继承设备级(写 null)。校验:>0。
  1327. /// </summary>
  1328. [ObservableProperty] private string manualLayerSpacing = "";
  1329. /// <summary>
  1330. /// M2-07 手调"对焦起点下移层数"(复用 move_down_layer)。空=继承设备级。
  1331. /// 校验:≥0 且 &lt;层数(下移层须落在拍摄范围内,§2.4 清晰层=第 down 层)。
  1332. /// </summary>
  1333. [ObservableProperty] private string manualMoveDown = "";
  1334. /// <summary>
  1335. /// M2-07 实时预览各层绝对 Z 位置(调 M2-02 ComputeLayerPositions 生成,关联 V-045)。
  1336. /// View 绑定此集合显示 N 层位置列表,让工程师看到手调效果。
  1337. /// </summary>
  1338. public ObservableCollection<LayerPreviewItem> LayerPreview { get; } = new ObservableCollection<LayerPreviewItem>();
  1339. /// <summary>
  1340. /// M2-07 预览/手调锚点 well(默认随水平电机当前 well / 一键标定取 CurrentWell)。
  1341. /// </summary>
  1342. [ObservableProperty] private int manualTuneWell = 1;
  1343. /// <summary>
  1344. /// 取该 well 当前生效的"实际拍摄层"配置(well 级覆盖优先,空则回退设备级),
  1345. /// 回填三个手调输入框 + 触发一次预览。供"载入当前值"按钮调用。
  1346. /// </summary>
  1347. public void LoadManualLayerSetting(int well)
  1348. {
  1349. ManualTuneWell = well;
  1350. var ws = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == well);
  1351. // well 级覆盖非空显示 well 值,否则显示继承的设备级值作占位(§2.5 就近优先)。
  1352. int? wellCount = ws?.focusLayerCount;
  1353. int? wellSpacing = ws?.focusLayerSpacingPulse;
  1354. // 下移复用 moveDownLayer(well 级为非空 int 列;0 视为有效覆盖值)。
  1355. int? wellDown = ws != null ? (int?)ws.moveDownLayer : null;
  1356. ManualLayerCount = (wellCount ?? tLSetting?.focusLayerCount)?.ToString() ?? "";
  1357. ManualLayerSpacing = (wellSpacing ?? tLSetting?.focusLayerSpacingPulse)?.ToString() ?? "";
  1358. ManualMoveDown = (wellDown ?? tLSetting?.focusLayerDown)?.ToString() ?? "";
  1359. PreviewManualLayers();
  1360. }
  1361. /// <summary>
  1362. /// 取该 well 最近标定的 FocusZ 作预览锚点(M2-05 一键标定结果 CalibResults 优先;
  1363. /// 回退 ccdPhoto 的 clearestPosition 即 scene0/1 库下发的清晰位置)。
  1364. /// 返回 null 表示无标定可用(须提示先标定)。
  1365. /// </summary>
  1366. private int? GetPreviewFocusZ(int well)
  1367. {
  1368. var calib = CalibResults.FirstOrDefault(x => x.Well == well
  1369. && (x.State == WellCalibState.Qualified || x.State == WellCalibState.FakePeak));
  1370. if (calib != null && calib.FocusZ > 0) return calib.FocusZ;
  1371. // 回退:调试页加载的清晰位置(scene0/1 库值 clearestPosition)。
  1372. var cc = ccdPhoto.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == well);
  1373. if (cc != null && cc.clearestPosition > 0) return cc.clearestPosition;
  1374. return null;
  1375. }
  1376. /// <summary>
  1377. /// 解析三个手调输入框(空=继承设备级取回退值),返回有效 (count,spacing,down) 或 null(非法/缺失)。
  1378. /// validateMsg 携带校验失败原因。
  1379. /// </summary>
  1380. private (int count, int spacing, int down)? ResolveEffectiveTune(out string validateMsg)
  1381. {
  1382. validateMsg = null;
  1383. // 解析层数:空→设备级回退;非空→必须 int。
  1384. int? count;
  1385. if (string.IsNullOrWhiteSpace(ManualLayerCount)) count = tLSetting?.focusLayerCount;
  1386. else if (int.TryParse(ManualLayerCount.Trim(), out int c)) count = c;
  1387. else { validateMsg = "层数只能输入整数"; return null; }
  1388. int? spacing;
  1389. if (string.IsNullOrWhiteSpace(ManualLayerSpacing)) spacing = tLSetting?.focusLayerSpacingPulse;
  1390. else if (int.TryParse(ManualLayerSpacing.Trim(), out int s)) spacing = s;
  1391. else { validateMsg = "层间距只能输入整数"; return null; }
  1392. int? down;
  1393. if (string.IsNullOrWhiteSpace(ManualMoveDown)) down = tLSetting?.focusLayerDown;
  1394. else if (int.TryParse(ManualMoveDown.Trim(), out int d)) down = d;
  1395. else { validateMsg = "下移层数只能输入整数"; return null; }
  1396. if (!count.HasValue) { validateMsg = "层数未配置(设备级也为空),请填层数或先初始化设备级"; return null; }
  1397. if (!spacing.HasValue) { validateMsg = "层间距未配置(设备级也为空),请填层间距或先初始化设备级(§2.5 不兜底)"; return null; }
  1398. if (!down.HasValue) { validateMsg = "下移层数未配置(设备级也为空),请填下移层数"; return null; }
  1399. // 校验:层数≥1、间距>0、下移≥0 且 <层数(下移层须落在拍摄范围内)。
  1400. if (count.Value < 1) { validateMsg = "层数必须 ≥ 1"; return null; }
  1401. if (spacing.Value <= 0) { validateMsg = "层间距必须 > 0"; return null; }
  1402. if (down.Value < 0) { validateMsg = "下移层数必须 ≥ 0"; return null; }
  1403. if (down.Value >= count.Value) { validateMsg = $"下移层数必须 < 层数({count.Value}),否则清晰层落在拍摄范围外"; return null; }
  1404. return (count.Value, spacing.Value, down.Value);
  1405. }
  1406. /// <summary>
  1407. /// M2-07 实时预览:用该 well 标定 FocusZ + 当前手调值,调 M2-02
  1408. /// ComputeLayerPositions(focusZ, cfg, pulseMax) 生成各层绝对 Z,刷新 LayerPreview(关联 V-045)。
  1409. /// 无标定锚点 → 清空预览并提示先标定;校验非法 → 清空预览并提示。
  1410. /// </summary>
  1411. public void PreviewManualLayers()
  1412. {
  1413. try
  1414. {
  1415. var focusZ = GetPreviewFocusZ(ManualTuneWell);
  1416. if (!focusZ.HasValue)
  1417. {
  1418. SetLayerPreview(null);
  1419. AddMessageInfo($"[手调拍摄层]well{ManualTuneWell} 无标定结果,请先对该 well 标定(或确认已下发清晰位置)再预览");
  1420. return;
  1421. }
  1422. var eff = ResolveEffectiveTune(out string msg);
  1423. if (eff == null)
  1424. {
  1425. SetLayerPreview(null);
  1426. AddMessageInfo($"[手调拍摄层]预览失败:{msg}");
  1427. return;
  1428. }
  1429. var cfg = new FocusLayerConfig
  1430. {
  1431. LayerCount = eff.Value.count,
  1432. LayerSpacingPulse = eff.Value.spacing,
  1433. LayerDown = eff.Value.down,
  1434. };
  1435. int pulseMax = tLSetting != null ? tLSetting.verticalMotorPulseMax : 0;
  1436. int[] positions = PhotoLayerCalculator.ComputeLayerPositions(focusZ.Value, cfg, pulseMax);
  1437. var items = new List<LayerPreviewItem>();
  1438. for (int i = 0; i < positions.Length; i++)
  1439. {
  1440. items.Add(new LayerPreviewItem
  1441. {
  1442. LayerIndex = i,
  1443. ZPulse = positions[i],
  1444. IsFocusLayer = (i == eff.Value.down), // 第 down 层 = 清晰层(FocusZ 锚点)
  1445. });
  1446. }
  1447. SetLayerPreview(items);
  1448. AddMessageInfo($"[手调拍摄层]well{ManualTuneWell} 预览:锚点FocusZ={focusZ.Value} 层数={eff.Value.count} " +
  1449. $"间距={eff.Value.spacing} 下移={eff.Value.down} → 第0层Z={positions[0]} 第{positions.Length - 1}层Z={positions[positions.Length - 1]}");
  1450. }
  1451. catch (Exception ex)
  1452. {
  1453. SetLayerPreview(null);
  1454. ExLog(ex, "PreviewManualLayers");
  1455. AddMessageInfo($"[手调拍摄层]预览异常:{ex.Message}");
  1456. }
  1457. }
  1458. /// <summary>
  1459. /// M2-07 保存为该 well 默认:校验通过后,把手调值写 house_well_setting well 级覆盖
  1460. /// (focus_layer_spacing_pulse/focus_layer_count + 复用 move_down_layer)。
  1461. /// 复用现有 operate 端 well 设置保存通道 HttpHelper.WellUpdateApi(同 SetWellMotorPosition/SetWellAutoFocus),
  1462. /// 走 /api/tl/control/setting/house/well/update。留空字段=继承设备级(写 null)。
  1463. /// 下次该 well 经 §2.5 就近优先(PhotoLayerCalculator.Resolve)沿用 well 覆盖值。
  1464. /// 返回 true=保存成功。
  1465. /// </summary>
  1466. public bool SaveManualLayerTune()
  1467. {
  1468. try
  1469. {
  1470. if (CurrentHouse == null)
  1471. {
  1472. AddMessageInfo("[手调拍摄层]未获取到舱室信息");
  1473. return false;
  1474. }
  1475. // M8-G3-1:保存手调拍摄层为"本地校验/计算 + HTTP 持久化 + 内存同步"打包的关键业务操作,
  1476. // 用 Begin scope 给一个父操作名(统一 traceId 串联其内的 WellUpdateApi HTTP 埋点;module=对焦调试)。
  1477. using var _op = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", "保存手调拍摄层设置",
  1478. houseSn: CurrentHouseId);
  1479. // 校验:层数≥1、间距>0、下移≥0 且 <层数;非法不保存。
  1480. var eff = ResolveEffectiveTune(out string msg);
  1481. if (eff == null)
  1482. {
  1483. AddMessageInfo($"[手调拍摄层]保存被拦截(非法值):{msg}");
  1484. try { _op.Output(new { rejected = msg }).Fail("校验未通过:" + msg); } catch { }
  1485. return false;
  1486. }
  1487. // 留空字段=继承设备级 → 写 null(well 级覆盖留空,§2.5)。非空字段写实际值。
  1488. int? wellCount = string.IsNullOrWhiteSpace(ManualLayerCount) ? (int?)null : int.Parse(ManualLayerCount.Trim());
  1489. int? wellSpacing = string.IsNullOrWhiteSpace(ManualLayerSpacing) ? (int?)null : int.Parse(ManualLayerSpacing.Trim());
  1490. // 下移复用 move_down_layer(库列非空);留空时回退取生效值(eff.down)写回,不破坏旧列语义。
  1491. int wellMoveDown = string.IsNullOrWhiteSpace(ManualMoveDown) ? eff.Value.down : int.Parse(ManualMoveDown.Trim());
  1492. try { _op.Input(new { houseSn = CurrentHouseId, well = ManualTuneWell, wellCount, wellSpacing, wellMoveDown }); } catch { }
  1493. // 复用现有 well 设置保存通道:与 SetWellMotorPosition/SetWellAutoFocus 同一 WellUpdateApi。
  1494. // 后端按 tlSn/houseSn/wellSn 定位 house_well_setting 行做部分更新(仅本次携带的字段)。
  1495. string body = JsonConvert.SerializeObject(new
  1496. {
  1497. tlSn = CurrentHouse.tlSn,
  1498. houseSn = CurrentHouse.houseSn,
  1499. wellSn = ManualTuneWell,
  1500. focusLayerSpacingPulse = wellSpacing, // null=继承设备级
  1501. focusLayerCount = wellCount, // null=继承设备级
  1502. moveDownLayer = wellMoveDown, // 复用既有列(下移)
  1503. });
  1504. bool ok = AppData.Instance.HttpHelper.WellUpdateApi(body);
  1505. if (!ok)
  1506. {
  1507. AddMessageInfo("[手调拍摄层]保存失败(接口返回失败)");
  1508. try { _op.Fail("WellUpdateApi 返回失败"); } catch { }
  1509. return false;
  1510. }
  1511. // 本地内存同步,使"下次该 well 沿用"在不重载设置时也即时生效(预览/取数一致)。
  1512. var ws = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == ManualTuneWell);
  1513. if (ws != null)
  1514. {
  1515. ws.focusLayerCount = wellCount;
  1516. ws.focusLayerSpacingPulse = wellSpacing;
  1517. ws.moveDownLayer = wellMoveDown;
  1518. }
  1519. AddMessageInfo($"[手调拍摄层]well{ManualTuneWell} 已存为默认:层数={(wellCount?.ToString() ?? "继承")} " +
  1520. $"间距={(wellSpacing?.ToString() ?? "继承")} 下移={wellMoveDown}(写 house_well_setting well 级覆盖,留空继承设备级)");
  1521. try { _op.Output(new { ok = true }).Success(); } catch { }
  1522. return true;
  1523. }
  1524. catch (Exception ex)
  1525. {
  1526. ExLog(ex, "SaveManualLayerTune");
  1527. AddMessageInfo($"[手调拍摄层]保存异常:{ex.Message}");
  1528. return false;
  1529. }
  1530. }
  1531. private void SetLayerPreview(List<LayerPreviewItem> items)
  1532. {
  1533. void build()
  1534. {
  1535. LayerPreview.Clear();
  1536. if (items != null)
  1537. foreach (var it in items) LayerPreview.Add(it);
  1538. }
  1539. var disp = System.Windows.Application.Current?.Dispatcher;
  1540. if (disp != null && !disp.CheckAccess()) disp.Invoke(build); else build();
  1541. }
  1542. #endregion
  1543. #region D2-02-T3.5 保存 per-well 对焦搜索范围(半幅)
  1544. /// <summary>
  1545. /// 当前编辑的 well 级"水平搜索半幅"(围绕 horizontalMotorPosition)。空字符串=留空继承设备级(保存写 null)。
  1546. /// View TextBox 双向绑定;校验在保存时做(非空须为 ≥0 整数)。
  1547. /// </summary>
  1548. [ObservableProperty] private string currentHFocusRange = "";
  1549. /// <summary>
  1550. /// 当前编辑的 well 级"垂直搜索半幅"(围绕 eepromClearPosition/清晰位)。空=继承设备级(写 null)。校验:≥0。
  1551. /// </summary>
  1552. [ObservableProperty] private string currentVFocusRange = "";
  1553. /// <summary>
  1554. /// 取该 well 当前 well 级半幅覆盖值回填两个输入框(空=继承设备级,显示空占位)。供"载入半幅"按钮调用。
  1555. /// 复用 ManualTuneWell 作为锚点 well(与手调拍摄层同一选定 well)。
  1556. /// </summary>
  1557. public void LoadWellFocusRange(int well)
  1558. {
  1559. ManualTuneWell = well;
  1560. var ws = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == well);
  1561. CurrentHFocusRange = ws?.horizontalFocusRange?.ToString() ?? "";
  1562. CurrentVFocusRange = ws?.verticalFocusRange?.ToString() ?? "";
  1563. AddMessageInfo($"[对焦半幅]已载入 well{well} 当前覆盖:水平={(ws?.horizontalFocusRange?.ToString() ?? "继承")} 垂直={(ws?.verticalFocusRange?.ToString() ?? "继承")}");
  1564. }
  1565. /// <summary>
  1566. /// D2-02-T3.5 保存该 well 对焦搜索半幅:校验通过后写 house_well_setting well 级覆盖
  1567. /// (horizontal_focus_range/vertical_focus_range)。留空字段=继承设备级(写 null)。
  1568. /// 复用现有 well 设置保存通道 HttpHelper.WellUpdateApi(同 SetWellMotorPosition/SaveManualLayerTune),
  1569. /// 走 /well/update;后端 well/update 已支持这两列(Java HouseWellSettingUpdate.horizontalFocusRange/verticalFocusRange)。
  1570. /// 字段名与 Java DTO 完全一致:horizontalFocusRange / verticalFocusRange。
  1571. /// 返回 true=保存成功。
  1572. /// </summary>
  1573. public bool SaveWellFocusRange()
  1574. {
  1575. try
  1576. {
  1577. if (CurrentHouse == null)
  1578. {
  1579. AddMessageInfo("[对焦半幅]未获取到舱室信息");
  1580. return false;
  1581. }
  1582. if (ManualTuneWell < 1 || ManualTuneWell > 16)
  1583. {
  1584. AddMessageInfo("[对焦半幅]well 只能为 1-16");
  1585. return false;
  1586. }
  1587. // 校验:非空须为 ≥0 整数;留空=继承设备级(写 null)。
  1588. int? hRange;
  1589. if (string.IsNullOrWhiteSpace(CurrentHFocusRange)) hRange = null;
  1590. else if (int.TryParse(CurrentHFocusRange.Trim(), out int hv) && hv >= 0) hRange = hv;
  1591. else { AddMessageInfo("[对焦半幅]水平半幅只能输入 ≥0 整数(留空=继承设备级)"); return false; }
  1592. int? vRange;
  1593. if (string.IsNullOrWhiteSpace(CurrentVFocusRange)) vRange = null;
  1594. else if (int.TryParse(CurrentVFocusRange.Trim(), out int vv) && vv >= 0) vRange = vv;
  1595. else { AddMessageInfo("[对焦半幅]垂直半幅只能输入 ≥0 整数(留空=继承设备级)"); return false; }
  1596. // M8 埋点:保存对焦半幅为关键业务操作(统一 traceId 串其内 WellUpdateApi HTTP 埋点)。
  1597. using var _op = Aivfo.OperationLog.OperationLogger.Begin("对焦调试", "保存对焦搜索半幅",
  1598. houseSn: CurrentHouseId);
  1599. try { _op.Input(new { houseSn = CurrentHouseId, well = ManualTuneWell, horizontalFocusRange = hRange, verticalFocusRange = vRange }); } catch { }
  1600. // body 字段名与 Java HouseWellSettingUpdate 完全一致;留空=null 清空继承设备级(与 SaveManualLayerTune 一致)。
  1601. string body = JsonConvert.SerializeObject(new
  1602. {
  1603. tlSn = CurrentHouse.tlSn,
  1604. houseSn = CurrentHouse.houseSn,
  1605. wellSn = ManualTuneWell,
  1606. horizontalFocusRange = hRange, // null=继承设备级 focus_h_range_default
  1607. verticalFocusRange = vRange, // null=继承设备级 focus_v_range_default
  1608. });
  1609. bool ok = AppData.Instance.HttpHelper.WellUpdateApi(body);
  1610. if (!ok)
  1611. {
  1612. AddMessageInfo("[对焦半幅]保存失败(接口返回失败)");
  1613. try { _op.Fail("WellUpdateApi 返回失败"); } catch { }
  1614. return false;
  1615. }
  1616. // 本地内存同步,使取数一致(不重载设置即生效)。
  1617. var ws = houseWellSettingList.FirstOrDefault(x => x.houseSn == CurrentHouseId && x.wellSn == ManualTuneWell);
  1618. if (ws != null)
  1619. {
  1620. ws.horizontalFocusRange = hRange;
  1621. ws.verticalFocusRange = vRange;
  1622. }
  1623. AddMessageInfo($"[对焦半幅]well{ManualTuneWell} 已保存:水平={(hRange?.ToString() ?? "继承")} 垂直={(vRange?.ToString() ?? "继承")}(写 house_well_setting well 级覆盖,留空继承设备级)");
  1624. try { _op.Output(new { ok = true }).Success(); } catch { }
  1625. return true;
  1626. }
  1627. catch (Exception ex)
  1628. {
  1629. ExLog(ex, "SaveWellFocusRange");
  1630. AddMessageInfo($"[对焦半幅]保存异常:{ex.Message}");
  1631. return false;
  1632. }
  1633. }
  1634. #endregion
  1635. }
  1636. }