PosController.cs 110 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data.Entity;
  4. using System.Linq;
  5. using System.Net.Http;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8. using System.Web.Http;
  9. using Serilog;
  10. using XdCxRhDW.Dto;
  11. using XdCxRhDW.Repostory;
  12. using System.IO;
  13. using XdCxRhDW.Entity;
  14. using XdCxRhDW.Api;
  15. using XdCxRhDW.WebApi;
  16. using DPP_YH_Core.Extensions;
  17. using XdCxRhDW.App.Model;
  18. using System.Diagnostics;
  19. namespace XdCxRhDW.App.Controllers
  20. {
  21. /// <summary>
  22. /// 定位功能相关接口
  23. /// </summary>
  24. public class PosController : BaseController
  25. {
  26. #region 一星一地测向定位
  27. /// <summary>
  28. /// 一星一地测向带参定位(含星历)
  29. /// </summary>
  30. /// <param name="dto">定位参数</param>
  31. /// <returns></returns>
  32. [HttpPost]
  33. public async Task<AjaxResult<PosResDto>> PosX1D1Async(X1D1PosDto dto)
  34. {
  35. TaskInfo runTask;
  36. using (RHDWContext db = new RHDWContext())
  37. {
  38. if (dto.TaskID == null)
  39. {
  40. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  41. && p.PosType == EnumPosType.X1D1CX && p.TaskState == EnumTaskState.Running);
  42. if (runTask == null)
  43. {
  44. Serilog.Log.Warning($"接收到一星一地测向带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  45. return Error<PosResDto>($"多模式融合定位平台没有启动一星一地测向定位任务");
  46. }
  47. }
  48. else
  49. {
  50. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  51. if (runTask == null)
  52. {
  53. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  54. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  55. }
  56. }
  57. }
  58. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  59. {
  60. var StationRes = db.StationRes.Add(new StationRes()
  61. {
  62. SatTxLon = dto.SatTxLon,
  63. SatTxLat = dto.SatTxLat,
  64. CdbTxLon = dto.CdbTxLon,
  65. CdbTxLat = dto.CdbTxLat,
  66. CxLon = dto.CxLon,
  67. CxLat = dto.CxLat,
  68. RefLon = dto.RefLon,
  69. RefLat = dto.RefLat,
  70. });
  71. var ckRes = new CheckRes()
  72. {
  73. FileName = dto.CheckRes?.FileName,
  74. SmpStart = dto.CheckRes?.SmpStart,
  75. SmpCount = dto.CheckRes?.SmpCount,
  76. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  77. ModRate = dto.CheckRes?.ModRate,
  78. ModType = dto.CheckRes?.ModType,
  79. UserName = dto.CheckRes?.UserName,
  80. FfcHz = dto.CheckRes?.FfcHz,
  81. };
  82. db.CheckRes.Add(ckRes);
  83. var cgRes = db.CgRes.Add(new CgRes()
  84. {
  85. SigTime = dto.SigTime,
  86. DtoCdb = Math.Round(dto.XdDto, 10),
  87. DfoCdb = Math.Round(dto.XdDfo, 10),
  88. SnrCdb = Math.Round(dto.XdSnr, 1),
  89. YbMainDto = Math.Round(dto.MainYbDto, 10),
  90. StationResID = StationRes.ID,
  91. MainCode = dto.MainCode,
  92. TaskID = runTask.ID,
  93. MainX = dto.MainX,
  94. MainY = dto.MainY,
  95. MainZ = dto.MainZ,
  96. TarFreqUp = dto.FreqUp,
  97. TarFreqDown = dto.FreqDown,
  98. });
  99. var cxRes = db.CxRes.Add(new CxRes()
  100. {
  101. SigTime = dto.SigTime,
  102. Fx = dto.CxRes,
  103. });
  104. var res = PosApi.X1D1_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  105. PosRes posRes = new PosRes()
  106. {
  107. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  108. SigTime = cgRes.SigTime,
  109. TaskInfoID = runTask.ID,
  110. CxResID = cxRes.ID,
  111. CgResID = cgRes.ID,
  112. CheckResID = ckRes.ID,
  113. PosLon = res[0],
  114. PosLat = res[1],
  115. MirrLon = res[3],
  116. MirrLat = res[4],
  117. Confidence = (int)res[6],
  118. PosResType = EnumPosResType.X1D1CX,
  119. };
  120. posRes = db.PosRes.Add(posRes);
  121. await db.SaveChangesAsync();
  122. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  123. return Success(MapDto(posRes));
  124. }
  125. }
  126. /// <summary>
  127. /// 一星一地测向带参定位(无星历)
  128. /// </summary>
  129. /// <returns>返回定位结果ID</returns>
  130. [HttpPost]
  131. public async Task<AjaxResult<PosResDto>> PosX1D1NoXlAsync(X1D1NoXlPosDto dto)
  132. {
  133. TaskInfo runTask;
  134. using (RHDWContext db = new RHDWContext())
  135. {
  136. if (dto.TaskID == null)
  137. {
  138. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  139. && p.PosType == EnumPosType.X1D1CX && p.TaskState == EnumTaskState.Running);
  140. if (runTask == null)
  141. {
  142. Serilog.Log.Warning($"接收到一星一地测向带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  143. return Error<PosResDto>($"多模式融合定位平台没有启动一星一地测向定位任务");
  144. }
  145. }
  146. else
  147. {
  148. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  149. if (runTask == null)
  150. {
  151. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  152. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  153. }
  154. }
  155. }
  156. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  157. if (xl1 == null)
  158. {
  159. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  160. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  161. }
  162. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  163. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  164. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  165. if (ephMain.code != 200)
  166. {
  167. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  168. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  169. }
  170. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  171. {
  172. var StationRes = db.StationRes.Add(new StationRes()
  173. {
  174. SatTxLon = dto.SatTxLon,
  175. SatTxLat = dto.SatTxLat,
  176. CdbTxLon = dto.CdbTxLon,
  177. CdbTxLat = dto.CdbTxLat,
  178. CxLon = dto.CxLon,
  179. CxLat = dto.CxLat,
  180. RefLon = dto.RefLon,
  181. RefLat = dto.RefLat,
  182. });
  183. var ckRes = new CheckRes()
  184. {
  185. FileName = dto.CheckRes?.FileName,
  186. SmpStart = dto.CheckRes?.SmpStart,
  187. SmpCount = dto.CheckRes?.SmpCount,
  188. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  189. ModRate = dto.CheckRes?.ModRate,
  190. ModType = dto.CheckRes?.ModType,
  191. UserName = dto.CheckRes?.UserName,
  192. FfcHz = dto.CheckRes?.FfcHz,
  193. };
  194. db.CheckRes.Add(ckRes);
  195. var cgRes = db.CgRes.Add(new CgRes()
  196. {
  197. SigTime = dto.SigTime,
  198. DtoCdb = Math.Round(dto.XdDto, 10),
  199. DfoCdb = Math.Round(dto.XdDfo, 10),
  200. SnrCdb = Math.Round(dto.XdSnr, 1),
  201. YbMainDto = Math.Round(dto.MainYbDto, 10),
  202. StationResID = StationRes.ID,
  203. MainCode = dto.MainCode,
  204. MainXlTime = ephMain.data.TleTime,
  205. TaskID = runTask.ID,
  206. MainX = ephMain.data.X,
  207. MainY = ephMain.data.Y,
  208. MainZ = ephMain.data.Z,
  209. MainVx = ephMain.data.VX,
  210. MainVy = ephMain.data.VY,
  211. MainVz = ephMain.data.VZ,
  212. TarFreqUp = dto.FreqUp,
  213. TarFreqDown = dto.FreqDown,
  214. });
  215. var cxRes = db.CxRes.Add(new CxRes()
  216. {
  217. SigTime = dto.SigTime,
  218. Fx = dto.CxRes,
  219. });
  220. var res = PosApi.X1D1_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  221. PosRes posRes = new PosRes()
  222. {
  223. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  224. SigTime = dto.SigTime,
  225. TaskInfoID = runTask.ID,
  226. CgResID = cgRes.ID,
  227. CxResID = cxRes.ID,
  228. CheckResID = ckRes.ID,
  229. PosLon = res[0],
  230. PosLat = res[1],
  231. MirrLon = res[3],
  232. MirrLat = res[4],
  233. Confidence = (int)res[6],
  234. PosResType = EnumPosResType.X1D1CX,
  235. };
  236. posRes = db.PosRes.Add(posRes);
  237. await db.SaveChangesAsync();
  238. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  239. return Success(MapDto(posRes));
  240. }
  241. }
  242. #endregion
  243. #region 两星一地定位
  244. /// <summary>
  245. /// 两星一地带参定位(含星历)
  246. /// </summary>
  247. /// <param name="dto">定位参数</param>
  248. /// <returns></returns>
  249. [HttpPost]
  250. public async Task<AjaxResult<PosResDto>> PosX2D1Async(X2D1PosDto dto)
  251. {
  252. TaskInfo runTask;
  253. using (RHDWContext db = new RHDWContext())
  254. {
  255. if (dto.TaskID == null)
  256. {
  257. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  258. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  259. if (runTask == null)
  260. {
  261. Serilog.Log.Warning($"接收到两星一地带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  262. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  263. }
  264. }
  265. else
  266. {
  267. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  268. if (runTask == null)
  269. {
  270. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  271. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  272. }
  273. }
  274. }
  275. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  276. {
  277. var StationRes = db.StationRes.Add(new StationRes()
  278. {
  279. SatTxLon = dto.SatTxLon,
  280. SatTxLat = dto.SatTxLat,
  281. CdbTxLon = dto.CdbTxLon,
  282. CdbTxLat = dto.CdbTxLat,
  283. RefLon = dto.RefLon,
  284. RefLat = dto.RefLat,
  285. });
  286. var ckRes = new CheckRes()
  287. {
  288. FileName = dto.CheckRes?.FileName,
  289. SmpStart = dto.CheckRes?.SmpStart,
  290. SmpCount = dto.CheckRes?.SmpCount,
  291. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  292. ModRate = dto.CheckRes?.ModRate,
  293. ModType = dto.CheckRes?.ModType,
  294. UserName = dto.CheckRes?.UserName,
  295. FfcHz = dto.CheckRes?.FfcHz,
  296. };
  297. ckRes = db.CheckRes.Add(ckRes);
  298. var cgRes = db.CgRes.Add(new CgRes()
  299. {
  300. SigTime = dto.SigTime,
  301. Dto1 = Math.Round(dto.SxDto, 10),
  302. Dfo1 = Math.Round(dto.SxDfo, 10),
  303. Snr1 = Math.Round(dto.SxSnr, 1),
  304. DtoCdb = Math.Round(dto.XdDto, 10),
  305. DfoCdb = Math.Round(dto.XdDfo, 10),
  306. SnrCdb = Math.Round(dto.XdSnr, 1),
  307. YbMainDto = Math.Round(dto.MainYbDto, 10),
  308. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  309. StationResID = StationRes.ID,
  310. MainCode = dto.MainCode,
  311. Adja1Code = dto.AdjaCode,
  312. TaskID = runTask.ID,
  313. MainX = dto.MainX,
  314. MainY = dto.MainY,
  315. MainZ = dto.MainZ,
  316. Adja1X = dto.AdjaX,
  317. Adja1Y = dto.AdjaY,
  318. Adja1Z = dto.AdjaZ,
  319. MainVx = dto.MainVX,
  320. MainVy = dto.MainVY,
  321. MainVz = dto.MainVZ,
  322. Adja1Vx = dto.AdjaVX,
  323. Adja1Vy = dto.AdjaVY,
  324. Adja1Vz = dto.AdjaVZ,
  325. TarFreqUp = dto.FreqUp,
  326. TarFreqDown = dto.FreqDown,
  327. });
  328. var res = PosApi.X2D1_Pos(cgRes, StationRes, dto.CalcConfidence);
  329. PosRes posRes = new PosRes()
  330. {
  331. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  332. SigTime = cgRes.SigTime,
  333. TaskInfoID = runTask.ID,
  334. CgResID = cgRes.ID,
  335. CheckResID = ckRes.ID,
  336. PosLon = res[0],
  337. PosLat = res[1],
  338. MirrLon = res[3],
  339. MirrLat = res[4],
  340. Confidence = (int)res[6],
  341. PosResType = EnumPosResType.X2D1,
  342. };
  343. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  344. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  345. if (dto.CalcConfidence)
  346. {
  347. }
  348. posRes = db.PosRes.Add(posRes);
  349. await db.SaveChangesAsync();
  350. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  351. return Success(MapDto(posRes));
  352. }
  353. }
  354. /// <summary>
  355. /// 两星一地带参定位(无星历)
  356. /// </summary>
  357. /// <returns>返回定位结果ID</returns>
  358. [HttpPost]
  359. public async Task<AjaxResult<PosResDto>> PosX2D1NoXlAsync(X2D1NoXlPosDto dto)
  360. {
  361. TaskInfo runTask;
  362. using (RHDWContext db = new RHDWContext())
  363. {
  364. if (dto.TaskID == null)
  365. {
  366. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  367. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  368. if (runTask == null)
  369. {
  370. Serilog.Log.Warning($"接收到两星一地带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  371. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  372. }
  373. }
  374. else
  375. {
  376. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  377. if (runTask == null)
  378. {
  379. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  380. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  381. }
  382. }
  383. }
  384. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  385. if (xl1 == null)
  386. {
  387. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  388. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  389. }
  390. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  391. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  392. if (xl2 == null)
  393. {
  394. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  395. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  396. }
  397. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  398. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  399. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  400. if (ephMain.code != 200)
  401. {
  402. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  403. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  404. }
  405. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  406. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  407. if (ephAdja.code != 200)
  408. {
  409. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  410. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  411. }
  412. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  413. {
  414. var StationRes = db.StationRes.Add(new StationRes()
  415. {
  416. SatTxLon = dto.SatTxLon,
  417. SatTxLat = dto.SatTxLat,
  418. CdbTxLon = dto.CdbTxLon,
  419. CdbTxLat = dto.CdbTxLat,
  420. RefLon = dto.RefLon,
  421. RefLat = dto.RefLat,
  422. });
  423. var ckRes = new CheckRes()
  424. {
  425. FileName = dto.CheckRes?.FileName,
  426. SmpStart = dto.CheckRes?.SmpStart,
  427. SmpCount = dto.CheckRes?.SmpCount,
  428. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  429. ModRate = dto.CheckRes?.ModRate,
  430. ModType = dto.CheckRes?.ModType,
  431. UserName = dto.CheckRes?.UserName,
  432. FfcHz = dto.CheckRes?.FfcHz,
  433. };
  434. db.CheckRes.Add(ckRes);
  435. var cgRes = db.CgRes.Add(new CgRes()
  436. {
  437. SigTime = dto.SigTime,
  438. Dto1 = Math.Round(dto.SxDto, 10),
  439. Dfo1 = Math.Round(dto.SxDfo, 10),
  440. Snr1 = Math.Round(dto.SxSnr, 1),
  441. DtoCdb = Math.Round(dto.XdDto, 10),
  442. DfoCdb = Math.Round(dto.XdDfo, 10),
  443. SnrCdb = Math.Round(dto.XdSnr, 1),
  444. YbMainDto = Math.Round(dto.MainYbDto, 10),
  445. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  446. StationResID = StationRes.ID,
  447. MainCode = dto.MainCode,
  448. MainXlTime = ephMain.data.TleTime,
  449. Adja1Code = dto.AdjaCode,
  450. Adja1XlTime = ephAdja.data.TleTime,
  451. TaskID = runTask.ID,
  452. MainX = ephMain.data.X,
  453. MainY = ephMain.data.Y,
  454. MainZ = ephMain.data.Z,
  455. MainVx = ephMain.data.VX,
  456. MainVy = ephMain.data.VY,
  457. MainVz = ephMain.data.VZ,
  458. Adja1Vx = ephAdja.data.VX,
  459. Adja1Vy = ephAdja.data.VY,
  460. Adja1Vz = ephAdja.data.VZ,
  461. Adja1X = ephAdja.data.X,
  462. Adja1Y = ephAdja.data.Y,
  463. Adja1Z = ephAdja.data.Z,
  464. TarFreqUp = dto.FreqUp,
  465. TarFreqDown = dto.FreqDown,
  466. });
  467. var res = PosApi.X2D1_Pos(cgRes, StationRes, dto.CalcConfidence);
  468. PosRes posRes = new PosRes()
  469. {
  470. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  471. SigTime = dto.SigTime,
  472. TaskInfoID = runTask.ID,
  473. CgResID = cgRes.ID,
  474. CheckResID = ckRes.ID,
  475. PosLon = res[0],
  476. PosLat = res[1],
  477. MirrLon = res[3],
  478. MirrLat = res[4],
  479. Confidence = (int)res[6],
  480. PosResType = EnumPosResType.X2D1,
  481. };
  482. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  483. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  484. posRes = db.PosRes.Add(posRes);
  485. await db.SaveChangesAsync();
  486. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  487. return Success(MapDto(posRes));
  488. }
  489. }
  490. /// <summary>
  491. /// 两星一地无参定位(含星历)
  492. /// </summary>
  493. /// <param name="dto">定位参数</param>
  494. /// <returns></returns>
  495. [HttpPost]
  496. public async Task<AjaxResult<PosResDto>> PosX2D1NoParAsync(X2D1NoParPosDto dto)
  497. {
  498. TaskInfo runTask;
  499. using (RHDWContext db = new RHDWContext())
  500. {
  501. if (dto.TaskID == null)
  502. {
  503. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  504. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  505. if (runTask == null)
  506. {
  507. Serilog.Log.Warning($"接收到两星一地无参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  508. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  509. }
  510. }
  511. else
  512. {
  513. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  514. if (runTask == null)
  515. {
  516. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  517. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  518. }
  519. }
  520. }
  521. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  522. {
  523. var StationRes = db.StationRes.Add(new StationRes()
  524. {
  525. SatTxLon = dto.SatTxLon,
  526. SatTxLat = dto.SatTxLat,
  527. CdbTxLon = dto.CdbTxLon,
  528. CdbTxLat = dto.CdbTxLat,
  529. });
  530. var ckRes = new CheckRes()
  531. {
  532. FileName = dto.CheckRes?.FileName,
  533. SmpStart = dto.CheckRes?.SmpStart,
  534. SmpCount = dto.CheckRes?.SmpCount,
  535. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  536. ModRate = dto.CheckRes?.ModRate,
  537. ModType = dto.CheckRes?.ModType,
  538. UserName = dto.CheckRes?.UserName,
  539. FfcHz = dto.CheckRes?.FfcHz,
  540. };
  541. db.CheckRes.Add(ckRes);
  542. var cgRes = db.CgRes.Add(new CgRes()
  543. {
  544. SigTime = dto.SigTime,
  545. Dto1 = Math.Round(dto.SxDto, 10),
  546. Dfo1 = Math.Round(dto.SxDfo, 10),
  547. Snr1 = Math.Round(dto.SxSnr, 1),
  548. DtoCdb = Math.Round(dto.XdDto, 10),
  549. DfoCdb = Math.Round(dto.XdDfo, 10),
  550. SnrCdb = Math.Round(dto.XdSnr, 1),
  551. StationResID = StationRes.ID,
  552. MainCode = dto.MainCode,
  553. Adja1Code = dto.AdjaCode,
  554. TaskID = runTask.ID,
  555. MainX = dto.MainX,
  556. MainY = dto.MainY,
  557. MainZ = dto.MainZ,
  558. Adja1X = dto.AdjaX,
  559. Adja1Y = dto.AdjaY,
  560. Adja1Z = dto.AdjaZ,
  561. MainVx = dto.MainVX,
  562. MainVy = dto.MainVY,
  563. MainVz = dto.MainVZ,
  564. Adja1Vx = dto.AdjaVX,
  565. Adja1Vy = dto.AdjaVY,
  566. Adja1Vz = dto.AdjaVZ,
  567. TarFreqUp = dto.FreqUp,
  568. TarFreqDown = dto.FreqDown,
  569. });
  570. var res = PosApi.X2D1_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  571. PosRes posRes = new PosRes()
  572. {
  573. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  574. SigTime = cgRes.SigTime,
  575. TaskInfoID = runTask.ID,
  576. CgResID = cgRes.ID,
  577. CheckResID = ckRes.ID,
  578. PosLon = res[0],
  579. PosLat = res[1],
  580. MirrLon = res[3],
  581. MirrLat = res[4],
  582. Confidence = (int)res[6],
  583. PosResType = EnumPosResType.X2D1NoRef,
  584. };
  585. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  586. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  587. posRes = db.PosRes.Add(posRes);
  588. await db.SaveChangesAsync();
  589. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  590. return Success(MapDto(posRes));
  591. }
  592. }
  593. /// <summary>
  594. /// 两星一地无参定位(无星历)
  595. /// </summary>
  596. /// <returns>返回定位结果ID</returns>
  597. [HttpPost]
  598. public async Task<AjaxResult<PosResDto>> PosX2D1NoXlNoParAsync(X2D1NoXlNoParlPosDto dto)
  599. {
  600. TaskInfo runTask;
  601. using (RHDWContext db = new RHDWContext())
  602. {
  603. if (dto.TaskID == null)
  604. {
  605. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  606. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  607. if (runTask == null)
  608. {
  609. Serilog.Log.Warning($"接收到两星一地无参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  610. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  611. }
  612. }
  613. else
  614. {
  615. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  616. if (runTask == null)
  617. {
  618. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  619. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  620. }
  621. }
  622. }
  623. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  624. if (xl1 == null)
  625. {
  626. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  627. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  628. }
  629. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  630. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  631. if (xl2 == null)
  632. {
  633. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  634. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  635. }
  636. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  637. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  638. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  639. if (ephMain.code != 200)
  640. {
  641. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  642. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  643. }
  644. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  645. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  646. if (ephAdja.code != 200)
  647. {
  648. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  649. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  650. }
  651. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  652. {
  653. var StationRes = db.StationRes.Add(new StationRes()
  654. {
  655. SatTxLon = dto.SatTxLon,
  656. SatTxLat = dto.SatTxLat,
  657. CdbTxLon = dto.CdbTxLon,
  658. CdbTxLat = dto.CdbTxLat,
  659. });
  660. var ckRes = new CheckRes()
  661. {
  662. FileName = dto.CheckRes?.FileName,
  663. SmpStart = dto.CheckRes?.SmpStart,
  664. SmpCount = dto.CheckRes?.SmpCount,
  665. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  666. ModRate = dto.CheckRes?.ModRate,
  667. ModType = dto.CheckRes?.ModType,
  668. UserName = dto.CheckRes?.UserName,
  669. FfcHz = dto.CheckRes?.FfcHz,
  670. };
  671. db.CheckRes.Add(ckRes);
  672. var cgRes = db.CgRes.Add(new CgRes()
  673. {
  674. SigTime = dto.SigTime,
  675. Dto1 = Math.Round(dto.SxDto, 10),
  676. Dfo1 = Math.Round(dto.SxDfo, 10),
  677. Snr1 = Math.Round(dto.SxSnr, 1),
  678. DtoCdb = Math.Round(dto.XdDto, 10),
  679. DfoCdb = Math.Round(dto.XdDfo, 10),
  680. SnrCdb = Math.Round(dto.XdSnr, 1),
  681. StationResID = StationRes.ID,
  682. MainCode = dto.MainCode,
  683. Adja1Code = dto.AdjaCode,
  684. MainXlTime = ephMain.data.TleTime,
  685. Adja1XlTime = ephAdja.data.TleTime,
  686. TaskID = runTask.ID,
  687. MainX = ephMain.data.X,
  688. MainY = ephMain.data.Y,
  689. MainZ = ephMain.data.Z,
  690. Adja1X = ephAdja.data.X,
  691. Adja1Y = ephAdja.data.Y,
  692. Adja1Z = ephAdja.data.Z,
  693. MainVx = ephMain.data.VX,
  694. MainVy = ephMain.data.VY,
  695. MainVz = ephMain.data.VZ,
  696. Adja1Vx = ephAdja.data.VX,
  697. Adja1Vy = ephAdja.data.VY,
  698. Adja1Vz = ephAdja.data.VZ,
  699. TarFreqUp = dto.FreqUp,
  700. TarFreqDown = dto.FreqDown,
  701. });
  702. var res = PosApi.X2D1_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  703. PosRes posRes = new PosRes()
  704. {
  705. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  706. SigTime = dto.SigTime,
  707. TaskInfoID = runTask.ID,
  708. CgResID = cgRes.ID,
  709. CheckResID = ckRes.ID,
  710. PosLon = res[0],
  711. PosLat = res[1],
  712. MirrLon = res[3],
  713. MirrLat = res[4],
  714. Confidence = (int)res[6],
  715. PosResType = EnumPosResType.X2D1NoRef,
  716. };
  717. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  718. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  719. posRes = db.PosRes.Add(posRes);
  720. await db.SaveChangesAsync();
  721. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  722. return Success(MapDto(posRes));
  723. }
  724. }
  725. #endregion
  726. #region 融合定位
  727. /// <summary>
  728. /// 融合带参定位(含星历)
  729. /// </summary>
  730. /// <param name="dto">定位参数</param>
  731. /// <returns></returns>
  732. [HttpPost]
  733. public async Task<AjaxResult<PosResDto>> PosRhAsync(RHPosDto dto)
  734. {
  735. TaskInfo runTask;
  736. using (RHDWContext db = new RHDWContext())
  737. {
  738. if (dto.TaskID == null)
  739. {
  740. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  741. && p.PosType == EnumPosType.RH && p.TaskState == EnumTaskState.Running);
  742. if (runTask == null)
  743. {
  744. Serilog.Log.Warning($"接收到融合带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  745. return Error<PosResDto>($"多模式融合定位平台没有启动融合定位任务");
  746. }
  747. }
  748. else
  749. {
  750. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  751. if (runTask == null)
  752. {
  753. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  754. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  755. }
  756. }
  757. }
  758. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  759. {
  760. var StationRes = db.StationRes.Add(new StationRes()
  761. {
  762. SatTxLon = dto.SatTxLon,
  763. SatTxLat = dto.SatTxLat,
  764. CdbTxLon = dto.CdbTxLon,
  765. CdbTxLat = dto.CdbTxLat,
  766. CxLon = dto.CxLon,
  767. CxLat = dto.CxLat,
  768. RefLon = dto.RefLon,
  769. RefLat = dto.RefLat,
  770. });
  771. var ckRes = new CheckRes()
  772. {
  773. FileName = dto.CheckRes?.FileName,
  774. SmpStart = dto.CheckRes?.SmpStart,
  775. SmpCount = dto.CheckRes?.SmpCount,
  776. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  777. ModRate = dto.CheckRes?.ModRate,
  778. ModType = dto.CheckRes?.ModType,
  779. UserName = dto.CheckRes?.UserName,
  780. FfcHz = dto.CheckRes?.FfcHz,
  781. };
  782. db.CheckRes.Add(ckRes);
  783. var cgRes = db.CgRes.Add(new CgRes()
  784. {
  785. SigTime = dto.SigTime,
  786. Dto1 = Math.Round(dto.SxDto, 10),
  787. Dfo1 = Math.Round(dto.SxDfo, 10),
  788. Snr1 = Math.Round(dto.SxSnr, 1),
  789. DtoCdb = Math.Round(dto.XdDto, 10),
  790. DfoCdb = Math.Round(dto.XdDfo, 10),
  791. SnrCdb = Math.Round(dto.XdSnr, 1),
  792. YbMainDto = Math.Round(dto.MainYbDto, 10),
  793. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  794. StationResID = StationRes.ID,
  795. MainCode = dto.MainCode,
  796. Adja1Code = dto.AdjaCode,
  797. TaskID = runTask.ID,
  798. MainX = dto.MainX,
  799. MainY = dto.MainY,
  800. MainZ = dto.MainZ,
  801. Adja1X = dto.AdjaX,
  802. Adja1Y = dto.AdjaY,
  803. Adja1Z = dto.AdjaZ,
  804. TarFreqUp = dto.FreqUp,
  805. TarFreqDown = dto.FreqDown,
  806. });
  807. var cxRes = db.CxRes.Add(new CxRes()
  808. {
  809. SigTime = dto.SigTime,
  810. Fx = dto.CxRes,
  811. });
  812. var res = PosApi.RH_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  813. PosRes posRes = new PosRes()
  814. {
  815. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  816. SigTime = cgRes.SigTime,
  817. TaskInfoID = runTask.ID,
  818. CxResID = cxRes.ID,
  819. CgResID = cgRes.ID,
  820. CheckResID = ckRes.ID,
  821. PosLon = res[0],
  822. PosLat = res[1],
  823. MirrLon = res[3],
  824. MirrLat = res[4],
  825. Confidence = (int)res[6],
  826. PosResType = EnumPosResType.RH,
  827. };
  828. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  829. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  830. posRes = db.PosRes.Add(posRes);
  831. await db.SaveChangesAsync();
  832. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  833. return Success(MapDto(posRes));
  834. }
  835. }
  836. /// <summary>
  837. /// 融合带参定位(无星历)
  838. /// </summary>
  839. /// <returns>返回定位结果ID</returns>
  840. [HttpPost]
  841. public async Task<AjaxResult<PosResDto>> PosRhNoXlAsync(RHNoXlPosDto dto)
  842. {
  843. TaskInfo runTask;
  844. using (RHDWContext db = new RHDWContext())
  845. {
  846. if (dto.TaskID == null)
  847. {
  848. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  849. && p.PosType == EnumPosType.RH && p.TaskState == EnumTaskState.Running);
  850. if (runTask == null)
  851. {
  852. Serilog.Log.Warning($"接收到融合带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  853. return Error<PosResDto>($"多模式融合定位平台没有启动融合定位任务");
  854. }
  855. }
  856. else
  857. {
  858. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  859. if (runTask == null)
  860. {
  861. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  862. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  863. }
  864. }
  865. }
  866. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  867. if (xl1 == null)
  868. {
  869. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  870. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  871. }
  872. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  873. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  874. if (xl2 == null)
  875. {
  876. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  877. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  878. }
  879. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  880. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  881. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  882. if (ephMain.code != 200)
  883. {
  884. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  885. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  886. }
  887. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  888. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  889. if (ephAdja.code != 200)
  890. {
  891. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  892. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  893. }
  894. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  895. {
  896. var StationRes = db.StationRes.Add(new StationRes()
  897. {
  898. SatTxLon = dto.SatTxLon,
  899. SatTxLat = dto.SatTxLat,
  900. CdbTxLon = dto.CdbTxLon,
  901. CdbTxLat = dto.CdbTxLat,
  902. CxLon = dto.CxLon,
  903. CxLat = dto.CxLat,
  904. RefLon = dto.RefLon,
  905. RefLat = dto.RefLat,
  906. });
  907. var ckRes = new CheckRes()
  908. {
  909. FileName = dto.CheckRes?.FileName,
  910. SmpStart = dto.CheckRes?.SmpStart,
  911. SmpCount = dto.CheckRes?.SmpCount,
  912. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  913. ModRate = dto.CheckRes?.ModRate,
  914. ModType = dto.CheckRes?.ModType,
  915. UserName = dto.CheckRes?.UserName,
  916. FfcHz = dto.CheckRes?.FfcHz,
  917. };
  918. db.CheckRes.Add(ckRes);
  919. var cgRes = db.CgRes.Add(new CgRes()
  920. {
  921. SigTime = dto.SigTime,
  922. Dto1 = Math.Round(dto.SxDto, 10),
  923. Dfo1 = Math.Round(dto.SxDfo, 10),
  924. Snr1 = Math.Round(dto.SxSnr, 1),
  925. DtoCdb = Math.Round(dto.XdDto, 10),
  926. DfoCdb = Math.Round(dto.XdDfo, 10),
  927. SnrCdb = Math.Round(dto.XdSnr, 1),
  928. YbMainDto = Math.Round(dto.MainYbDto, 10),
  929. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  930. StationResID = StationRes.ID,
  931. MainCode = dto.MainCode,
  932. Adja1Code = dto.AdjaCode,
  933. MainXlTime = ephMain.data.TleTime,
  934. Adja1XlTime = ephAdja.data.TleTime,
  935. TaskID = runTask.ID,
  936. MainX = ephMain.data.X,
  937. MainY = ephMain.data.Y,
  938. MainZ = ephMain.data.Z,
  939. MainVx = ephMain.data.VX,
  940. MainVy = ephMain.data.VY,
  941. MainVz = ephMain.data.VZ,
  942. Adja1X = ephAdja.data.X,
  943. Adja1Y = ephAdja.data.Y,
  944. Adja1Z = ephAdja.data.Z,
  945. Adja1Vx = ephAdja.data.VX,
  946. Adja1Vy = ephAdja.data.VY,
  947. Adja1Vz = ephAdja.data.VZ,
  948. TarFreqUp = dto.FreqUp,
  949. TarFreqDown = dto.FreqDown,
  950. });
  951. var cxRes = db.CxRes.Add(new CxRes()
  952. {
  953. SigTime = dto.SigTime,
  954. Fx = dto.CxRes,
  955. });
  956. var res = PosApi.RH_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  957. PosRes posRes = new PosRes()
  958. {
  959. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  960. SigTime = cgRes.SigTime,
  961. TaskInfoID = runTask.ID,
  962. CxResID = cxRes.ID,
  963. CgResID = cgRes.ID,
  964. CheckResID = ckRes.ID,
  965. PosLon = res[0],
  966. PosLat = res[1],
  967. MirrLon = res[3],
  968. MirrLat = res[4],
  969. Confidence = (int)res[6],
  970. PosResType = EnumPosResType.RH,
  971. };
  972. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  973. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  974. posRes = db.PosRes.Add(posRes);
  975. await db.SaveChangesAsync();
  976. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  977. return Success(MapDto(posRes));
  978. }
  979. }
  980. #endregion
  981. #region 三星双时差定位
  982. /// <summary>
  983. /// 三星双时差带参定位(含星历)
  984. /// </summary>
  985. /// <param name="dto">定位参数</param>
  986. /// <returns></returns>
  987. [HttpPost]
  988. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoAsync(X3TwoDtoPosDto dto)
  989. {
  990. TaskInfo runTask;
  991. using (RHDWContext db = new RHDWContext())
  992. {
  993. if (dto.TaskID == null)
  994. {
  995. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  996. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  997. if (runTask == null)
  998. {
  999. Serilog.Log.Warning($"接收到三星双时差带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1000. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1001. }
  1002. }
  1003. else
  1004. {
  1005. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1006. if (runTask == null)
  1007. {
  1008. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1009. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1010. }
  1011. }
  1012. }
  1013. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1014. {
  1015. var StationRes = db.StationRes.Add(new StationRes()
  1016. {
  1017. SatTxLon = dto.SatTxLon,
  1018. SatTxLat = dto.SatTxLat,
  1019. RefLon = dto.RefLon,
  1020. RefLat = dto.RefLat,
  1021. });
  1022. var ckRes = new CheckRes()
  1023. {
  1024. FileName = dto.CheckRes?.FileName,
  1025. SmpStart = dto.CheckRes?.SmpStart,
  1026. SmpCount = dto.CheckRes?.SmpCount,
  1027. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1028. ModRate = dto.CheckRes?.ModRate,
  1029. ModType = dto.CheckRes?.ModType,
  1030. UserName = dto.CheckRes?.UserName,
  1031. FfcHz = dto.CheckRes?.FfcHz,
  1032. };
  1033. db.CheckRes.Add(ckRes);
  1034. var cgRes = db.CgRes.Add(new CgRes()
  1035. {
  1036. SigTime = dto.SigTime,
  1037. Dto1 = Math.Round(dto.Dto1, 10),
  1038. Dfo1 = Math.Round(dto.Dfo1, 10),
  1039. Snr1 = Math.Round(dto.Snr1, 1),
  1040. Dto2 = Math.Round(dto.Dto2, 10),
  1041. Dfo2 = Math.Round(dto.Dfo2, 10),
  1042. Snr2 = Math.Round(dto.Snr2, 1),
  1043. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1044. YbAdja1Dto = Math.Round(dto.YbAdja1Dto, 10),
  1045. YbAdja2Dto = Math.Round(dto.YbAdja2Dto, 10),
  1046. StationResID = StationRes.ID,
  1047. MainCode = dto.MainCode,
  1048. Adja1Code = dto.Adja1Code,
  1049. Adja2Code = dto.Adja2Code,
  1050. TaskID = runTask.ID,
  1051. MainX = dto.MainX,
  1052. MainY = dto.MainY,
  1053. MainZ = dto.MainZ,
  1054. MainVx = dto.MainVX,
  1055. MainVy = dto.MainVY,
  1056. MainVz = dto.MainVZ,
  1057. Adja1X = dto.Adja1X,
  1058. Adja1Y = dto.Adja1Y,
  1059. Adja1Z = dto.Adja1Z,
  1060. Adja1Vx = dto.Adja1VX,
  1061. Adja1Vy = dto.Adja1VY,
  1062. Adja1Vz = dto.Adja1VZ,
  1063. Adja2X = dto.Adja2X,
  1064. Adja2Y = dto.Adja2Y,
  1065. Adja2Z = dto.Adja2Z,
  1066. Adja2Vx = dto.Adja2VX,
  1067. Adja2Vy = dto.Adja2VY,
  1068. Adja2Vz = dto.Adja2VZ,
  1069. TarFreqUp = dto.FreqUp,
  1070. TarFreqDown = dto.FreqDown,
  1071. });
  1072. var res = PosApi.X3_Pos(cgRes, StationRes, dto.CalcConfidence);
  1073. PosRes posRes = new PosRes()
  1074. {
  1075. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1076. SigTime = cgRes.SigTime,
  1077. TaskInfoID = runTask.ID,
  1078. CgResID = cgRes.ID,
  1079. CheckResID = ckRes.ID,
  1080. PosLon = res[0],
  1081. PosLat = res[1],
  1082. MirrLon = res[3],
  1083. MirrLat = res[4],
  1084. Confidence = (int)res[6],
  1085. PosResType = EnumPosResType.X3,
  1086. };
  1087. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1088. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1089. posRes = db.PosRes.Add(posRes);
  1090. await db.SaveChangesAsync();
  1091. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1092. return Success(MapDto(posRes));
  1093. }
  1094. }
  1095. /// <summary>
  1096. /// 三星双时差带参定位(无星历)
  1097. /// </summary>
  1098. /// <returns>返回定位结果ID</returns>
  1099. [HttpPost]
  1100. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoXlAsync(X3TwoDtoNoXlPosDto dto)
  1101. {
  1102. TaskInfo runTask;
  1103. using (RHDWContext db = new RHDWContext())
  1104. {
  1105. if (dto.TaskID == null)
  1106. {
  1107. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1108. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1109. if (runTask == null)
  1110. {
  1111. Serilog.Log.Warning($"接收到三星双时差带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1112. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1113. }
  1114. }
  1115. else
  1116. {
  1117. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1118. if (runTask == null)
  1119. {
  1120. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1121. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1122. }
  1123. }
  1124. }
  1125. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1126. if (xl1 == null)
  1127. {
  1128. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1129. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1130. }
  1131. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1132. var xl2 = await XlRepository.GetLatestAsync(dto.Adja1Code, dto.SigTime);
  1133. if (xl2 == null)
  1134. {
  1135. Serilog.Log.Error($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1136. return Error<PosResDto>($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1137. }
  1138. Serilog.Log.Information($"卫星{dto.Adja1Code}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1139. var xl3 = await XlRepository.GetLatestAsync(dto.Adja2Code, dto.SigTime);
  1140. if (xl3 == null)
  1141. {
  1142. Serilog.Log.Error($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1143. return Error<PosResDto>($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1144. }
  1145. Serilog.Log.Information($"卫星{dto.Adja2Code}使用发布时刻为{xl3.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1146. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1147. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1148. if (ephMain.code != 200)
  1149. {
  1150. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1151. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1152. }
  1153. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1154. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1155. if (ephAdja1.code != 200)
  1156. {
  1157. Serilog.Log.Error($"推算卫星{dto.Adja1Code}的ECEF星历出错.{ephAdja1.msg}");
  1158. return Error<PosResDto>($"推算卫星{dto.Adja1Code}的ECEF星历出错");
  1159. }
  1160. var XlCalcDto3 = new XlCalcDto() { tleStr = xl3.TwoLine, SigTime = dto.SigTime };
  1161. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto3);
  1162. if (ephAdja2.code != 200)
  1163. {
  1164. Serilog.Log.Error($"推算卫星{dto.Adja2Code}的ECEF星历出错.{ephAdja2.msg}");
  1165. return Error<PosResDto>($"推算卫星{dto.Adja2Code}的ECEF星历出错");
  1166. }
  1167. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1168. {
  1169. var StationRes = db.StationRes.Add(new StationRes()
  1170. {
  1171. SatTxLon = dto.SatTxLon,
  1172. SatTxLat = dto.SatTxLat,
  1173. RefLon = dto.RefLon,
  1174. RefLat = dto.RefLat,
  1175. });
  1176. var ckRes = new CheckRes()
  1177. {
  1178. FileName = dto.CheckRes?.FileName,
  1179. SmpStart = dto.CheckRes?.SmpStart,
  1180. SmpCount = dto.CheckRes?.SmpCount,
  1181. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1182. ModRate = dto.CheckRes?.ModRate,
  1183. ModType = dto.CheckRes?.ModType,
  1184. UserName = dto.CheckRes?.UserName,
  1185. FfcHz = dto.CheckRes?.FfcHz,
  1186. };
  1187. db.CheckRes.Add(ckRes);
  1188. var cgRes = db.CgRes.Add(new CgRes()
  1189. {
  1190. SigTime = dto.SigTime,
  1191. Dto1 = Math.Round(dto.Dto1, 10),
  1192. Dfo1 = Math.Round(dto.Dfo1, 10),
  1193. Snr1 = Math.Round(dto.Snr1, 1),
  1194. Dto2 = Math.Round(dto.Dto2, 10),
  1195. Dfo2 = Math.Round(dto.Dfo2, 10),
  1196. Snr2 = Math.Round(dto.Snr2, 1),
  1197. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1198. YbAdja1Dto = Math.Round(dto.YbAdja1Dto, 10),
  1199. YbAdja2Dto = Math.Round(dto.YbAdja2Dto, 10),
  1200. StationResID = StationRes.ID,
  1201. MainCode = dto.MainCode,
  1202. Adja1Code = dto.Adja1Code,
  1203. Adja2Code = dto.Adja2Code,
  1204. MainXlTime = ephMain.data.TleTime,
  1205. Adja1XlTime = ephAdja1.data.TleTime,
  1206. Adja2XlTime = ephAdja2.data.TleTime,
  1207. TaskID = runTask.ID,
  1208. MainX = ephMain.data.X,
  1209. MainY = ephMain.data.Y,
  1210. MainZ = ephMain.data.Z,
  1211. MainVx = ephMain.data.VX,
  1212. MainVy = ephMain.data.VY,
  1213. MainVz = ephMain.data.VZ,
  1214. Adja1X = ephAdja1.data.X,
  1215. Adja1Y = ephAdja1.data.Y,
  1216. Adja1Z = ephAdja1.data.Z,
  1217. Adja1Vx = ephAdja1.data.VX,
  1218. Adja1Vy = ephAdja1.data.VY,
  1219. Adja1Vz = ephAdja1.data.VZ,
  1220. Adja2X = ephAdja2.data.X,
  1221. Adja2Y = ephAdja2.data.Y,
  1222. Adja2Z = ephAdja2.data.Z,
  1223. Adja2Vx = ephAdja2.data.VX,
  1224. Adja2Vy = ephAdja2.data.VY,
  1225. Adja2Vz = ephAdja2.data.VZ,
  1226. TarFreqUp = dto.FreqUp,
  1227. TarFreqDown = dto.FreqDown,
  1228. });
  1229. var res = PosApi.X3_Pos(cgRes, StationRes, dto.CalcConfidence);
  1230. PosRes posRes = new PosRes()
  1231. {
  1232. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1233. SigTime = dto.SigTime,
  1234. TaskInfoID = runTask.ID,
  1235. CgResID = cgRes.ID,
  1236. CheckResID = ckRes.ID,
  1237. PosLon = res[0],
  1238. PosLat = res[1],
  1239. MirrLon = res[3],
  1240. MirrLat = res[4],
  1241. Confidence = (int)res[6],
  1242. PosResType = EnumPosResType.X3,
  1243. };
  1244. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1245. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1246. posRes = db.PosRes.Add(posRes);
  1247. await db.SaveChangesAsync();
  1248. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1249. return Success(MapDto(posRes));
  1250. }
  1251. }
  1252. /// <summary>
  1253. /// 三星双时差无参定位(含星历)
  1254. /// </summary>
  1255. /// <param name="dto">定位参数</param>
  1256. /// <returns></returns>
  1257. [HttpPost]
  1258. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoParAsync(X3TwoDtoNoParPosDto dto)
  1259. {
  1260. TaskInfo runTask;
  1261. using (RHDWContext db = new RHDWContext())
  1262. {
  1263. if (dto.TaskID == null)
  1264. {
  1265. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1266. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1267. if (runTask == null)
  1268. {
  1269. Serilog.Log.Warning($"接收到三星双时差无参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1270. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1271. }
  1272. }
  1273. else
  1274. {
  1275. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1276. if (runTask == null)
  1277. {
  1278. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1279. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1280. }
  1281. }
  1282. }
  1283. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1284. {
  1285. var StationRes = db.StationRes.Add(new StationRes()
  1286. {
  1287. SatTxLon = dto.SatTxLon,
  1288. SatTxLat = dto.SatTxLat,
  1289. });
  1290. var ckRes = new CheckRes()
  1291. {
  1292. FileName = dto.CheckRes?.FileName,
  1293. SmpStart = dto.CheckRes?.SmpStart,
  1294. SmpCount = dto.CheckRes?.SmpCount,
  1295. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1296. ModRate = dto.CheckRes?.ModRate,
  1297. ModType = dto.CheckRes?.ModType,
  1298. UserName = dto.CheckRes?.UserName,
  1299. FfcHz = dto.CheckRes?.FfcHz,
  1300. };
  1301. db.CheckRes.Add(ckRes);
  1302. var cgRes = db.CgRes.Add(new CgRes()
  1303. {
  1304. SigTime = dto.SigTime,
  1305. Dto1 = Math.Round(dto.Dto1, 10),
  1306. Dfo1 = Math.Round(dto.Dfo1, 10),
  1307. Snr1 = Math.Round(dto.Snr1, 1),
  1308. Dto2 = Math.Round(dto.Dto2, 10),
  1309. Dfo2 = Math.Round(dto.Dfo2, 10),
  1310. Snr2 = Math.Round(dto.Snr2, 1),
  1311. StationResID = StationRes.ID,
  1312. MainCode = dto.MainCode,
  1313. Adja1Code = dto.Adja1Code,
  1314. Adja2Code = dto.Adja2Code,
  1315. TaskID = runTask.ID,
  1316. MainX = dto.MainX,
  1317. MainY = dto.MainY,
  1318. MainZ = dto.MainZ,
  1319. MainVx = dto.MainVX,
  1320. MainVy = dto.MainVY,
  1321. MainVz = dto.MainVZ,
  1322. Adja1X = dto.Adja1X,
  1323. Adja1Y = dto.Adja1Y,
  1324. Adja1Z = dto.Adja1Z,
  1325. Adja1Vx = dto.Adja1VX,
  1326. Adja1Vy = dto.Adja1VY,
  1327. Adja1Vz = dto.Adja1VZ,
  1328. Adja2X = dto.Adja2X,
  1329. Adja2Y = dto.Adja2Y,
  1330. Adja2Z = dto.Adja2Z,
  1331. Adja2Vx = dto.Adja2VX,
  1332. Adja2Vy = dto.Adja2VY,
  1333. Adja2Vz = dto.Adja2VZ,
  1334. TarFreqUp = dto.FreqUp,
  1335. TarFreqDown = dto.FreqDown,
  1336. });
  1337. var res = PosApi.X3_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  1338. PosRes posRes = new PosRes()
  1339. {
  1340. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1341. SigTime = cgRes.SigTime,
  1342. TaskInfoID = runTask.ID,
  1343. CgResID = cgRes.ID,
  1344. CheckResID = ckRes.ID,
  1345. PosLon = res[0],
  1346. PosLat = res[1],
  1347. MirrLon = res[3],
  1348. MirrLat = res[4],
  1349. Confidence = (int)res[6],
  1350. PosResType = EnumPosResType.X3NoRef,
  1351. };
  1352. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1353. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1354. posRes = db.PosRes.Add(posRes);
  1355. await db.SaveChangesAsync();
  1356. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1357. return Success(MapDto(posRes));
  1358. }
  1359. }
  1360. /// <summary>
  1361. /// 三星双时差无参定位(无星历)
  1362. /// </summary>
  1363. /// <returns>返回定位结果ID</returns>
  1364. [HttpPost]
  1365. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoXlNoParAsync(X3TwoDtoNoXlNoParPosDto dto)
  1366. {
  1367. TaskInfo runTask;
  1368. using (RHDWContext db = new RHDWContext())
  1369. {
  1370. if (dto.TaskID == null)
  1371. {
  1372. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1373. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1374. if (runTask == null)
  1375. {
  1376. Serilog.Log.Warning($"接收到三星双时差无参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1377. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1378. }
  1379. }
  1380. else
  1381. {
  1382. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1383. if (runTask == null)
  1384. {
  1385. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1386. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1387. }
  1388. }
  1389. }
  1390. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1391. if (xl1 == null)
  1392. {
  1393. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1394. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1395. }
  1396. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1397. var xl2 = await XlRepository.GetLatestAsync(dto.Adja1Code, dto.SigTime);
  1398. if (xl2 == null)
  1399. {
  1400. Serilog.Log.Error($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1401. return Error<PosResDto>($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1402. }
  1403. Serilog.Log.Information($"卫星{dto.Adja1Code}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1404. var xl3 = await XlRepository.GetLatestAsync(dto.Adja2Code, dto.SigTime);
  1405. if (xl3 == null)
  1406. {
  1407. Serilog.Log.Error($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1408. return Error<PosResDto>($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1409. }
  1410. Serilog.Log.Information($"卫星{dto.Adja2Code}使用发布时刻为{xl3.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1411. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1412. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1413. if (ephMain.code != 200)
  1414. {
  1415. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1416. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1417. }
  1418. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1419. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1420. if (ephAdja1.code != 200)
  1421. {
  1422. Serilog.Log.Error($"推算卫星{dto.Adja1Code}的ECEF星历出错.{ephAdja1.msg}");
  1423. return Error<PosResDto>($"推算卫星{dto.Adja1Code}的ECEF星历出错");
  1424. }
  1425. var XlCalcDto3 = new XlCalcDto() { tleStr = xl3.TwoLine, SigTime = dto.SigTime };
  1426. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto3);
  1427. if (ephAdja2.code != 200)
  1428. {
  1429. Serilog.Log.Error($"推算卫星{dto.Adja2Code}的ECEF星历出错.{ephAdja2.msg}");
  1430. return Error<PosResDto>($"推算卫星{dto.Adja2Code}的ECEF星历出错");
  1431. }
  1432. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1433. {
  1434. var StationRes = db.StationRes.Add(new StationRes()
  1435. {
  1436. SatTxLon = dto.SatTxLon,
  1437. SatTxLat = dto.SatTxLat,
  1438. });
  1439. var ckRes = new CheckRes()
  1440. {
  1441. FileName = dto.CheckRes?.FileName,
  1442. SmpStart = dto.CheckRes?.SmpStart,
  1443. SmpCount = dto.CheckRes?.SmpCount,
  1444. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1445. ModRate = dto.CheckRes?.ModRate,
  1446. ModType = dto.CheckRes?.ModType,
  1447. UserName = dto.CheckRes?.UserName,
  1448. FfcHz = dto.CheckRes?.FfcHz,
  1449. };
  1450. db.CheckRes.Add(ckRes);
  1451. var cgRes = db.CgRes.Add(new CgRes()
  1452. {
  1453. SigTime = dto.SigTime,
  1454. Dto1 = Math.Round(dto.Dto1, 10),
  1455. Dfo1 = Math.Round(dto.Dfo1, 10),
  1456. Snr1 = Math.Round(dto.Snr1, 1),
  1457. Dto2 = Math.Round(dto.Dto2, 10),
  1458. Dfo2 = Math.Round(dto.Dfo2, 10),
  1459. Snr2 = Math.Round(dto.Snr2, 1),
  1460. StationResID = StationRes.ID,
  1461. MainCode = dto.MainCode,
  1462. Adja1Code = dto.Adja1Code,
  1463. Adja2Code = dto.Adja2Code,
  1464. MainXlTime = ephMain.data.TleTime,
  1465. Adja1XlTime = ephAdja1.data.TleTime,
  1466. Adja2XlTime = ephAdja2.data.TleTime,
  1467. TaskID = runTask.ID,
  1468. MainX = ephMain.data.X,
  1469. MainY = ephMain.data.Y,
  1470. MainZ = ephMain.data.Z,
  1471. MainVx = ephMain.data.VX,
  1472. MainVy = ephMain.data.VY,
  1473. MainVz = ephMain.data.VZ,
  1474. Adja1X = ephAdja1.data.X,
  1475. Adja1Y = ephAdja1.data.Y,
  1476. Adja1Z = ephAdja1.data.Z,
  1477. Adja1Vx = ephAdja1.data.VX,
  1478. Adja1Vy = ephAdja1.data.VY,
  1479. Adja1Vz = ephAdja1.data.VZ,
  1480. Adja2X = ephAdja2.data.X,
  1481. Adja2Y = ephAdja2.data.Y,
  1482. Adja2Z = ephAdja2.data.Z,
  1483. Adja2Vx = ephAdja2.data.VX,
  1484. Adja2Vy = ephAdja2.data.VY,
  1485. Adja2Vz = ephAdja2.data.VZ,
  1486. TarFreqUp = dto.FreqUp,
  1487. TarFreqDown = dto.FreqDown,
  1488. });
  1489. var res = PosApi.X3_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  1490. PosRes posRes = new PosRes()
  1491. {
  1492. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1493. SigTime = dto.SigTime,
  1494. TaskInfoID = runTask.ID,
  1495. CgResID = cgRes.ID,
  1496. CheckResID = ckRes.ID,
  1497. PosLon = res[0],
  1498. PosLat = res[1],
  1499. MirrLon = res[3],
  1500. MirrLat = res[4],
  1501. Confidence = (int)res[6],
  1502. PosResType = EnumPosResType.X3NoRef,
  1503. };
  1504. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1505. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1506. posRes = db.PosRes.Add(posRes);
  1507. await db.SaveChangesAsync();
  1508. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1509. return Success(MapDto(posRes));
  1510. }
  1511. }
  1512. #endregion
  1513. #region 三星双频差定位
  1514. /// <summary>
  1515. /// 三星双频差带参定位(含星历)
  1516. /// </summary>
  1517. /// <param name="dto">定位参数</param>
  1518. /// <returns></returns>
  1519. [HttpPost]
  1520. public async Task<AjaxResult<PosResDto>> PosX3TwoDfoAsync(X3TwoDfoPosDto dto)
  1521. {
  1522. TaskInfo runTask;
  1523. using (RHDWContext db = new RHDWContext())
  1524. {
  1525. if (dto.TaskID == null)
  1526. {
  1527. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1528. && p.PosType == EnumPosType.X3TwoDfo && p.TaskState == EnumTaskState.Running);
  1529. if (runTask == null)
  1530. {
  1531. Serilog.Log.Warning($"接收到三星双频差带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1532. return Error<PosResDto>($"多模式融合定位平台没有启动三星双频差定位任务");
  1533. }
  1534. }
  1535. else
  1536. {
  1537. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1538. if (runTask == null)
  1539. {
  1540. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1541. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1542. }
  1543. }
  1544. }
  1545. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1546. {
  1547. var StationRes = db.StationRes.Add(new StationRes()
  1548. {
  1549. SatTxLon = dto.SatTxLon,
  1550. SatTxLat = dto.SatTxLat,
  1551. RefLon = dto.RefLon,
  1552. RefLat = dto.RefLat,
  1553. });
  1554. var ckRes = new CheckRes()
  1555. {
  1556. FileName = dto.CheckRes?.FileName,
  1557. SmpStart = dto.CheckRes?.SmpStart,
  1558. SmpCount = dto.CheckRes?.SmpCount,
  1559. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1560. ModRate = dto.CheckRes?.ModRate,
  1561. ModType = dto.CheckRes?.ModType,
  1562. UserName = dto.CheckRes?.UserName,
  1563. FfcHz = dto.CheckRes?.FfcHz,
  1564. };
  1565. db.CheckRes.Add(ckRes);
  1566. var cgRes = db.CgRes.Add(new CgRes()
  1567. {
  1568. SigTime = dto.SigTime,
  1569. Dto1 = Math.Round(dto.Dto1, 10),
  1570. Dfo1 = Math.Round(dto.Dfo1, 10),
  1571. Snr1 = Math.Round(dto.Snr1, 1),
  1572. Dto2 = Math.Round(dto.Dto2, 10),
  1573. Dfo2 = Math.Round(dto.Dfo2, 10),
  1574. Snr2 = Math.Round(dto.Snr2, 1),
  1575. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1576. YbAdja1Dfo = Math.Round(dto.YbAdja1Dfo, 10),
  1577. YbAdja2Dfo = Math.Round(dto.YbAdja2Dfo, 10),
  1578. TarFreqUp = dto.TarFreqUp,
  1579. TarFreqDown = dto.TarFreqDown,
  1580. RefFreqUp = dto.RefFreqUp,
  1581. RefFreqDown = dto.RefFreqDown,
  1582. StationResID = StationRes.ID,
  1583. MainCode = dto.MainCode,
  1584. Adja1Code = dto.Adja1Code,
  1585. Adja2Code = dto.Adja2Code,
  1586. TaskID = runTask.ID,
  1587. MainX = dto.MainX,
  1588. MainY = dto.MainY,
  1589. MainZ = dto.MainZ,
  1590. MainVx = dto.MainVx,
  1591. MainVy = dto.MainVy,
  1592. MainVz = dto.MainVz,
  1593. Adja1X = dto.Adja1X,
  1594. Adja1Y = dto.Adja1Y,
  1595. Adja1Z = dto.Adja1Z,
  1596. Adja1Vx = dto.Adja1Vx,
  1597. Adja1Vy = dto.Adja1Vy,
  1598. Adja1Vz = dto.Adja1Vz,
  1599. Adja2X = dto.Adja2X,
  1600. Adja2Y = dto.Adja2Y,
  1601. Adja2Z = dto.Adja2Z,
  1602. Adja2Vx = dto.Adja2Vx,
  1603. Adja2Vy = dto.Adja2Vy,
  1604. Adja2Vz = dto.Adja2Vz,
  1605. });
  1606. var res = PosApi.X3_PosTwoDfo(cgRes, StationRes, dto.CalcConfidence);
  1607. PosRes posRes = new PosRes()
  1608. {
  1609. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1610. SigTime = cgRes.SigTime,
  1611. TaskInfoID = runTask.ID,
  1612. CgResID = cgRes.ID,
  1613. CheckResID = ckRes.ID,
  1614. PosLon = res[0],
  1615. PosLat = res[1],
  1616. MirrLon = res[3],
  1617. MirrLat = res[4],
  1618. Confidence = (int)res[6],
  1619. PosResType = EnumPosResType.X3TwoDfo,
  1620. };
  1621. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1622. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1623. posRes = db.PosRes.Add(posRes);
  1624. await db.SaveChangesAsync();
  1625. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1626. return Success(MapDto(posRes));
  1627. }
  1628. }
  1629. /// <summary>
  1630. /// 三星双频差带参定位(无星历)
  1631. /// </summary>
  1632. /// <returns>返回定位结果ID</returns>
  1633. [HttpPost]
  1634. public async Task<AjaxResult<PosResDto>> PosX3TwoDfoNoXlAsync(X3TwoDfoNoXlPosDto dto)
  1635. {
  1636. TaskInfo runTask;
  1637. using (RHDWContext db = new RHDWContext())
  1638. {
  1639. if (dto.TaskID == null)
  1640. {
  1641. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1642. && p.PosType == EnumPosType.X3TwoDfo && p.TaskState == EnumTaskState.Running);
  1643. if (runTask == null)
  1644. {
  1645. Serilog.Log.Warning($"接收到三星双频差带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1646. return Error<PosResDto>($"多模式融合定位平台没有启动三星双频差定位任务");
  1647. }
  1648. }
  1649. else
  1650. {
  1651. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1652. if (runTask == null)
  1653. {
  1654. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1655. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1656. }
  1657. }
  1658. }
  1659. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1660. if (xl1 == null)
  1661. {
  1662. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1663. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1664. }
  1665. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1666. var xl2 = await XlRepository.GetLatestAsync(dto.Adja1Code, dto.SigTime);
  1667. if (xl2 == null)
  1668. {
  1669. Serilog.Log.Error($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1670. return Error<PosResDto>($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1671. }
  1672. Serilog.Log.Information($"卫星{dto.Adja1Code}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1673. var xl3 = await XlRepository.GetLatestAsync(dto.Adja2Code, dto.SigTime);
  1674. if (xl3 == null)
  1675. {
  1676. Serilog.Log.Error($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1677. return Error<PosResDto>($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1678. }
  1679. Serilog.Log.Information($"卫星{dto.Adja2Code}使用发布时刻为{xl3.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1680. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1681. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1682. if (ephMain.code != 200)
  1683. {
  1684. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1685. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1686. }
  1687. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1688. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1689. if (ephAdja1.code != 200)
  1690. {
  1691. Serilog.Log.Error($"推算卫星{dto.Adja1Code}的ECEF星历出错.{ephAdja1.msg}");
  1692. return Error<PosResDto>($"推算卫星{dto.Adja1Code}的ECEF星历出错");
  1693. }
  1694. var XlCalcDto3 = new XlCalcDto() { tleStr = xl3.TwoLine, SigTime = dto.SigTime };
  1695. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto3);
  1696. if (ephAdja2.code != 200)
  1697. {
  1698. Serilog.Log.Error($"推算卫星{dto.Adja2Code}的ECEF星历出错.{ephAdja2.msg}");
  1699. return Error<PosResDto>($"推算卫星{dto.Adja2Code}的ECEF星历出错");
  1700. }
  1701. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1702. {
  1703. var StationRes = db.StationRes.Add(new StationRes()
  1704. {
  1705. SatTxLon = dto.SatTxLon,
  1706. SatTxLat = dto.SatTxLat,
  1707. RefLon = dto.RefLon,
  1708. RefLat = dto.RefLat,
  1709. });
  1710. var ckRes = new CheckRes()
  1711. {
  1712. FileName = dto.CheckRes?.FileName,
  1713. SmpStart = dto.CheckRes?.SmpStart,
  1714. SmpCount = dto.CheckRes?.SmpCount,
  1715. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1716. ModRate = dto.CheckRes?.ModRate,
  1717. ModType = dto.CheckRes?.ModType,
  1718. UserName = dto.CheckRes?.UserName,
  1719. FfcHz = dto.CheckRes?.FfcHz,
  1720. };
  1721. db.CheckRes.Add(ckRes);
  1722. var cgRes = db.CgRes.Add(new CgRes()
  1723. {
  1724. SigTime = dto.SigTime,
  1725. Dto1 = Math.Round(dto.Dto1, 10),
  1726. Dfo1 = Math.Round(dto.Dfo1, 10),
  1727. Snr1 = Math.Round(dto.Snr1, 1),
  1728. Dto2 = Math.Round(dto.Dto2, 10),
  1729. Dfo2 = Math.Round(dto.Dfo2, 10),
  1730. Snr2 = Math.Round(dto.Snr2, 1),
  1731. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1732. YbAdja1Dfo = Math.Round(dto.YbAdja1Dfo, 10),
  1733. YbAdja2Dfo = Math.Round(dto.YbAdja2Dfo, 10),
  1734. TarFreqUp = dto.TarFreqUp,
  1735. TarFreqDown = dto.TarFreqDown,
  1736. RefFreqUp = dto.RefFreqUp,
  1737. RefFreqDown = dto.RefFreqDown,
  1738. StationResID = StationRes.ID,
  1739. MainCode = dto.MainCode,
  1740. Adja1Code = dto.Adja1Code,
  1741. Adja2Code = dto.Adja2Code,
  1742. MainXlTime = ephMain.data.TleTime,
  1743. Adja1XlTime = ephAdja1.data.TleTime,
  1744. Adja2XlTime = ephAdja2.data.TleTime,
  1745. TaskID = runTask.ID,
  1746. MainX = ephMain.data.X,
  1747. MainY = ephMain.data.Y,
  1748. MainZ = ephMain.data.Z,
  1749. MainVx = ephMain.data.VX,
  1750. MainVy = ephMain.data.VY,
  1751. MainVz = ephMain.data.VZ,
  1752. Adja1X = ephAdja1.data.X,
  1753. Adja1Y = ephAdja1.data.Y,
  1754. Adja1Z = ephAdja1.data.Z,
  1755. Adja1Vx = ephAdja1.data.VX,
  1756. Adja1Vy = ephAdja1.data.VY,
  1757. Adja1Vz = ephAdja1.data.VZ,
  1758. Adja2X = ephAdja2.data.X,
  1759. Adja2Y = ephAdja2.data.Y,
  1760. Adja2Z = ephAdja2.data.Z,
  1761. Adja2Vx = ephAdja2.data.VX,
  1762. Adja2Vy = ephAdja2.data.VY,
  1763. Adja2Vz = ephAdja2.data.VZ,
  1764. });
  1765. var res = PosApi.X3_PosTwoDfo(cgRes, StationRes, dto.CalcConfidence);
  1766. PosRes posRes = new PosRes()
  1767. {
  1768. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1769. SigTime = dto.SigTime,
  1770. TaskInfoID = runTask.ID,
  1771. CgResID = cgRes.ID,
  1772. CheckResID = ckRes.ID,
  1773. PosLon = res[0],
  1774. PosLat = res[1],
  1775. MirrLon = res[3],
  1776. MirrLat = res[4],
  1777. Confidence = (int)res[6],
  1778. PosResType = EnumPosResType.X3TwoDfo,
  1779. };
  1780. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1781. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1782. posRes = db.PosRes.Add(posRes);
  1783. await db.SaveChangesAsync();
  1784. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1785. return Success(MapDto(posRes));
  1786. }
  1787. }
  1788. #endregion
  1789. #region 双星时频差定位
  1790. /// <summary>
  1791. /// 双星时频差带参定位(含星历)
  1792. /// </summary>
  1793. /// <param name="dto">定位参数</param>
  1794. /// <returns></returns>
  1795. [HttpPost]
  1796. public async Task<AjaxResult<PosResDto>> PosX2DtoDfoAsync(X2DtoDfoPosDto dto)
  1797. {
  1798. TaskInfo runTask;
  1799. using (RHDWContext db = new RHDWContext())
  1800. {
  1801. if (dto.TaskID == null)
  1802. {
  1803. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1804. && p.PosType == EnumPosType.X2Dfo && p.TaskState == EnumTaskState.Running);
  1805. if (runTask == null)
  1806. {
  1807. Serilog.Log.Warning($"接收到双星时频差带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1808. return Error<PosResDto>($"多模式融合定位平台没有启动双星时频差定位任务");
  1809. }
  1810. }
  1811. else
  1812. {
  1813. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1814. if (runTask == null)
  1815. {
  1816. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1817. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1818. }
  1819. }
  1820. }
  1821. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1822. {
  1823. var StationRes = db.StationRes.Add(new StationRes()
  1824. {
  1825. SatTxLon = dto.SatTxLon,
  1826. SatTxLat = dto.SatTxLat,
  1827. RefLon = dto.RefLon,
  1828. RefLat = dto.RefLat,
  1829. });
  1830. var ckRes = new CheckRes()
  1831. {
  1832. FileName = dto.CheckRes?.FileName,
  1833. SmpStart = dto.CheckRes?.SmpStart,
  1834. SmpCount = dto.CheckRes?.SmpCount,
  1835. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1836. ModRate = dto.CheckRes?.ModRate,
  1837. ModType = dto.CheckRes?.ModType,
  1838. UserName = dto.CheckRes?.UserName,
  1839. FfcHz = dto.CheckRes?.FfcHz,
  1840. };
  1841. db.CheckRes.Add(ckRes);
  1842. var cgRes = db.CgRes.Add(new CgRes()
  1843. {
  1844. SigTime = dto.SigTime,
  1845. Dto1 = Math.Round(dto.Dto, 10),
  1846. Dfo1 = Math.Round(dto.Dfo, 10),
  1847. Snr1 = Math.Round(dto.Snr, 1),
  1848. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1849. YbAdja1Dto = Math.Round(dto.YbAdjaDto, 10),
  1850. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1851. YbAdja1Dfo = Math.Round(dto.YbAdjaDfo, 10),
  1852. TarFreqUp = dto.TarFreqUp,
  1853. TarFreqDown = dto.TarFreqDown,
  1854. RefFreqUp = dto.RefFreqUp,
  1855. RefFreqDown = dto.RefFreqDown,
  1856. StationResID = StationRes.ID,
  1857. MainCode = dto.MainCode,
  1858. Adja1Code = dto.AdjaCode,
  1859. TaskID = runTask.ID,
  1860. MainX = dto.MainX,
  1861. MainY = dto.MainY,
  1862. MainZ = dto.MainZ,
  1863. MainVx = dto.MainVx,
  1864. MainVy = dto.MainVy,
  1865. MainVz = dto.MainVz,
  1866. Adja1X = dto.AdjaX,
  1867. Adja1Y = dto.AdjaY,
  1868. Adja1Z = dto.AdjaZ,
  1869. Adja1Vx = dto.AdjaVx,
  1870. Adja1Vy = dto.AdjaVy,
  1871. Adja1Vz = dto.AdjaVz,
  1872. });
  1873. var res = PosApi.X2_PosDtoDfo(cgRes, StationRes, dto.CalcConfidence);
  1874. PosRes posRes = new PosRes()
  1875. {
  1876. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1877. SigTime = cgRes.SigTime,
  1878. TaskInfoID = runTask.ID,
  1879. CgResID = cgRes.ID,
  1880. CheckResID = ckRes.ID,
  1881. PosLon = res[0],
  1882. PosLat = res[1],
  1883. MirrLon = res[3],
  1884. MirrLat = res[4],
  1885. Confidence = (int)res[6],
  1886. PosResType = EnumPosResType.X2Dfo,
  1887. };
  1888. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1889. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1890. posRes = db.PosRes.Add(posRes);
  1891. await db.SaveChangesAsync();
  1892. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1893. return Success(MapDto(posRes));
  1894. }
  1895. }
  1896. /// <summary>
  1897. /// 双星时频差带参定位(无星历)
  1898. /// </summary>
  1899. /// <returns>返回定位结果ID</returns>
  1900. [HttpPost]
  1901. public async Task<AjaxResult<PosResDto>> PosX2DtoDfoNoXlAsync(X2DtoDfoNoXlPosDto dto)
  1902. {
  1903. TaskInfo runTask;
  1904. using (RHDWContext db = new RHDWContext())
  1905. {
  1906. if (dto.TaskID == null)
  1907. {
  1908. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1909. && p.PosType == EnumPosType.X2Dfo && p.TaskState == EnumTaskState.Running);
  1910. if (runTask == null)
  1911. {
  1912. Serilog.Log.Warning($"接收到双星时频差带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1913. return Error<PosResDto>($"多模式融合定位平台没有启动双星时频差定位任务");
  1914. }
  1915. }
  1916. else
  1917. {
  1918. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1919. if (runTask == null)
  1920. {
  1921. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1922. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1923. }
  1924. }
  1925. }
  1926. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1927. if (xl1 == null)
  1928. {
  1929. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1930. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1931. }
  1932. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1933. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  1934. if (xl2 == null)
  1935. {
  1936. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  1937. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  1938. }
  1939. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1940. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1941. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1942. if (ephMain.code != 200)
  1943. {
  1944. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1945. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1946. }
  1947. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1948. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1949. if (ephAdja.code != 200)
  1950. {
  1951. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  1952. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  1953. }
  1954. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1955. {
  1956. var StationRes = db.StationRes.Add(new StationRes()
  1957. {
  1958. SatTxLon = dto.SatTxLon,
  1959. SatTxLat = dto.SatTxLat,
  1960. RefLon = dto.RefLon,
  1961. RefLat = dto.RefLat,
  1962. });
  1963. var ckRes = new CheckRes()
  1964. {
  1965. FileName = dto.CheckRes?.FileName,
  1966. SmpStart = dto.CheckRes?.SmpStart,
  1967. SmpCount = dto.CheckRes?.SmpCount,
  1968. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1969. ModRate = dto.CheckRes?.ModRate,
  1970. ModType = dto.CheckRes?.ModType,
  1971. UserName = dto.CheckRes?.UserName,
  1972. FfcHz = dto.CheckRes?.FfcHz,
  1973. };
  1974. db.CheckRes.Add(ckRes);
  1975. var cgRes = db.CgRes.Add(new CgRes()
  1976. {
  1977. SigTime = dto.SigTime,
  1978. Dto1 = Math.Round(dto.Dto, 10),
  1979. Dfo1 = Math.Round(dto.Dfo, 10),
  1980. Snr1 = Math.Round(dto.Snr, 1),
  1981. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1982. YbAdja1Dto = Math.Round(dto.YbAdjaDto, 10),
  1983. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1984. YbAdja1Dfo = Math.Round(dto.YbAdjaDfo, 10),
  1985. TarFreqUp = dto.TarFreqUp,
  1986. TarFreqDown = dto.TarFreqDown,
  1987. RefFreqUp = dto.RefFreqUp,
  1988. RefFreqDown = dto.RefFreqDown,
  1989. StationResID = StationRes.ID,
  1990. MainCode = dto.MainCode,
  1991. Adja1Code = dto.AdjaCode,
  1992. MainXlTime = ephMain.data.TleTime,
  1993. Adja1XlTime = ephAdja.data.TleTime,
  1994. TaskID = runTask.ID,
  1995. MainX = ephMain.data.X,
  1996. MainY = ephMain.data.Y,
  1997. MainZ = ephMain.data.Z,
  1998. MainVx = ephMain.data.VX,
  1999. MainVy = ephMain.data.VY,
  2000. MainVz = ephMain.data.VZ,
  2001. Adja1X = ephAdja.data.X,
  2002. Adja1Y = ephAdja.data.Y,
  2003. Adja1Z = ephAdja.data.Z,
  2004. Adja1Vx = ephAdja.data.VX,
  2005. Adja1Vy = ephAdja.data.VY,
  2006. Adja1Vz = ephAdja.data.VZ,
  2007. });
  2008. var res = PosApi.X2_PosDtoDfo(cgRes, StationRes, dto.CalcConfidence);
  2009. PosRes posRes = new PosRes()
  2010. {
  2011. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  2012. SigTime = dto.SigTime,
  2013. TaskInfoID = runTask.ID,
  2014. CgResID = cgRes.ID,
  2015. CheckResID = ckRes.ID,
  2016. PosLon = res[0],
  2017. PosLat = res[1],
  2018. MirrLon = res[3],
  2019. MirrLat = res[4],
  2020. Confidence = (int)res[6],
  2021. PosResType = EnumPosResType.X2Dfo,
  2022. };
  2023. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  2024. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  2025. posRes = db.PosRes.Add(posRes);
  2026. await db.SaveChangesAsync();
  2027. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  2028. return Success(MapDto(posRes));
  2029. }
  2030. }
  2031. #endregion
  2032. #region 定位结果查询接口
  2033. /// <summary>
  2034. /// 根据时间范围查询定位结果
  2035. /// </summary>
  2036. /// <param name="dto"><see cref="PosRequestByTimeRangeDto"/>查询参数</param>
  2037. /// <returns></returns>
  2038. /// <exception cref="Exception"></exception>
  2039. [HttpPost]
  2040. public async Task<AjaxResult<List<PosResDto>>> GetPosResByTimeRange(PosRequestByTimeRangeDto dto)
  2041. {
  2042. #pragma warning disable CS0612 // 类型或成员已过时
  2043. var response = (await GetPosResByTimeRangeObsolete(dto));
  2044. #pragma warning restore CS0612 // 类型或成员已过时
  2045. if (response.code == 200)
  2046. {
  2047. var listDto = response.data?.Select(p => MapDto(p)).ToList();
  2048. return Success(listDto);
  2049. }
  2050. else
  2051. {
  2052. return Error<List<PosResDto>>(response.msg);
  2053. }
  2054. }
  2055. /// <summary>
  2056. /// 查询最后X小时的的定位结果
  2057. /// </summary>
  2058. /// <param name="dto"><see cref="PosRequestByLastRangeDto"/>查询参数</param>
  2059. /// <returns></returns>
  2060. /// <exception cref="Exception"></exception>
  2061. [HttpPost]
  2062. public async Task<AjaxResult<List<PosResDto>>> GetPosResByLastHours(PosRequestByLastRangeDto dto)
  2063. {
  2064. #pragma warning disable CS0612 // 类型或成员已过时
  2065. var response = (await GetPosResByLastHoursObsolete(dto));
  2066. #pragma warning restore CS0612 // 类型或成员已过时
  2067. if (response.code == 200)
  2068. {
  2069. var listDto = response.data?.Select(p => MapDto(p)).ToList();
  2070. return Success(listDto);
  2071. }
  2072. else
  2073. {
  2074. return Error<List<PosResDto>>(response.msg);
  2075. }
  2076. }
  2077. /// <summary>
  2078. /// 根据时间范围查询定位结果(此方法内部调用)
  2079. /// </summary>
  2080. /// <param name="dto"><see cref="PosRequestByTimeRangeDto"/>查询参数</param>
  2081. /// <returns></returns>
  2082. /// <exception cref="Exception"></exception>
  2083. [HttpPost]
  2084. [Obsolete]
  2085. public async Task<AjaxResult<List<PosRes>>> GetPosResByTimeRangeObsolete(PosRequestByTimeRangeDto dto)
  2086. {
  2087. List<PosRes> posList = new List<PosRes>();
  2088. try
  2089. {
  2090. DateTime start = dto.BeginTime;
  2091. DateTime end = dto.EndTime;
  2092. var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
  2093. if (!Directory.Exists(dir)) return Success(posList);
  2094. List<string> list = new List<string>();
  2095. DateTime tempStart = new DateTime(start.Year, start.Month, start.Day);
  2096. while (end >= tempStart)
  2097. {
  2098. list.Add(end.ToString("yyyy") + "\\" + end.ToString("MMdd") + ".db");
  2099. end = end.AddDays(-1);
  2100. }
  2101. end = dto.EndTime;
  2102. List<TargetInfo> targets;
  2103. using (RHDWContext dbBasic = new RHDWContext())
  2104. {
  2105. targets = await dbBasic.TargetInfos.ToListAsync();
  2106. }
  2107. foreach (var item in list)
  2108. {
  2109. var dayFile = Path.Combine(dir, item);
  2110. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  2111. {
  2112. if (db == null) continue;
  2113. var query = db.PosRes.Where(p => p.SigTime >= start && p.SigTime <= end && p.TaskInfoID == dto.TaskInfoID);
  2114. if (!dto.IncludeInvalidate)
  2115. query = query.Where(p => p.PosLon != 999);
  2116. if (dto.TarFrequpHz != null)
  2117. query = query.Where(p => p.FreqUpHz == dto.TarFrequpHz.Value);
  2118. var posRes = await query.Include(p => p.CheckRes).OrderByDescending(p => p.SigTime).ToListAsync();
  2119. foreach (var itemPos in posRes)
  2120. {
  2121. if (itemPos.TargetInfoID > 0)
  2122. {
  2123. itemPos.TargetInfo = targets.FirstOrDefault(p => p.ID == itemPos.TargetInfoID);
  2124. if (itemPos.TargetInfo != null && !string.IsNullOrWhiteSpace(itemPos.TargetInfo.TargeColor))
  2125. itemPos.ColorKey = itemPos.TargetInfo.TargeColor;
  2126. }
  2127. }
  2128. posList.AddRange(posRes);
  2129. }
  2130. }
  2131. return Success(posList);
  2132. }
  2133. catch (Exception ex)
  2134. {
  2135. string msg = $"定位结果时间范围查询异常.任务ID={dto.TaskInfoID},{dto.BeginTime:yyyyMMddHHmmss}-{dto.EndTime:yyyyMMddHHmmss}";
  2136. Serilog.Log.Error(ex, msg);
  2137. return Error<List<PosRes>>("定位结果时间范围查询异常");
  2138. }
  2139. }
  2140. /// <summary>
  2141. /// 根据时间范围查询定位结果(此方法内部调用)
  2142. /// </summary>
  2143. /// <param name="dto"><see cref="PosRequestByTimeRangeDto"/>查询参数</param>
  2144. /// <returns></returns>
  2145. /// <exception cref="Exception"></exception>
  2146. [HttpPost]
  2147. [Obsolete]
  2148. public async Task<AjaxResult<List<RePosRes>>> GetPosCgResByTimeRangeObsolete(PosRequestByTimeRangeDto dto)
  2149. {
  2150. List<RePosRes> posList = new List<RePosRes>();
  2151. try
  2152. {
  2153. DateTime start = dto.BeginTime;
  2154. DateTime end = dto.EndTime;
  2155. var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
  2156. if (!Directory.Exists(dir)) return Success(posList);
  2157. List<string> list = new List<string>();
  2158. DateTime tempStart = new DateTime(start.Year, start.Month, start.Day);
  2159. while (end >= tempStart)
  2160. {
  2161. list.Add(end.ToString("yyyy") + "\\" + end.ToString("MMdd") + ".db");
  2162. end = end.AddDays(-1);
  2163. }
  2164. end = dto.EndTime;
  2165. List<TargetInfo> targets;
  2166. using (RHDWContext dbBasic = new RHDWContext())
  2167. {
  2168. targets = await dbBasic.TargetInfos.ToListAsync();
  2169. }
  2170. foreach (var item in list)
  2171. {
  2172. var dayFile = Path.Combine(dir, item);
  2173. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  2174. {
  2175. if (db == null) continue;
  2176. var query = db.PosRes.Where(p => p.SigTime >= start && p.SigTime <= end && p.TaskInfoID == dto.TaskInfoID);
  2177. if (!dto.IncludeInvalidate)
  2178. query = query.Where(p => p.PosLon != 999);
  2179. if (dto.TarFrequpHz != null)
  2180. query = query.Where(p => p.FreqUpHz == dto.TarFrequpHz.Value);
  2181. var posRes = await query.OrderByDescending(p => p.SigTime).ToListAsync();
  2182. foreach (var itemPos in posRes)
  2183. {
  2184. var repos = new RePosRes();
  2185. repos.ID = itemPos.ID;
  2186. repos.SigTime = itemPos.SigTime;
  2187. repos.PosLon = itemPos.PosLon;
  2188. repos.PosLat = itemPos.PosLat;
  2189. repos.MirrLon = itemPos.MirrLon;
  2190. repos.MirrLat = itemPos.MirrLat;
  2191. repos.TaskInfoID = itemPos.TaskInfoID;
  2192. repos.FreqUpHz = itemPos.FreqUpHz;
  2193. repos.StationResID = itemPos.StationResID;
  2194. repos.CxResID = itemPos.CxResID;
  2195. repos.CgResID = itemPos.CgResID;
  2196. repos.CheckResID = itemPos.CheckResID;
  2197. repos.PosResType = itemPos.PosResType;
  2198. repos.TargetState = itemPos.TargetState;
  2199. repos.TargetInfo = targets?.FirstOrDefault(p => p.ID == itemPos.TargetInfoID);
  2200. if (itemPos.TargetInfo != null && !string.IsNullOrWhiteSpace(itemPos.TargetInfo.TargeColor))
  2201. {
  2202. repos.ColorKey = itemPos.TargetInfo.TargeColor;
  2203. }
  2204. repos.BaseTargetName = itemPos.TargetInfo?.TargetName;
  2205. repos.CheckRes = await db.CheckRes.FirstOrDefaultAsync(p => p.ID == itemPos.CheckResID);
  2206. repos.BaseCheckType = itemPos.CheckRes?.PosCheckType?.GetEnumDisplayName();
  2207. repos.CgRes = await db.CgRes.FirstOrDefaultAsync(p => p.ID == itemPos.CgResID);
  2208. repos.CxRes = await db.CxRes.FirstOrDefaultAsync(p => p.ID == itemPos.CxResID);
  2209. repos.StationRes = await db.StationRes.FirstOrDefaultAsync(p => p.ID == itemPos.StationResID);
  2210. posList.Add(repos);
  2211. }
  2212. }
  2213. }
  2214. return Success(posList);
  2215. }
  2216. catch (Exception ex)
  2217. {
  2218. string msg = $"定位结果时间范围查询异常.任务ID={dto.TaskInfoID},{dto.BeginTime:yyyyMMddHHmmss}-{dto.EndTime:yyyyMMddHHmmss}";
  2219. Serilog.Log.Error(ex, msg);
  2220. return Error<List<RePosRes>>("定位结果时间范围查询异常");
  2221. }
  2222. }
  2223. /// <summary>
  2224. /// 查询最后X小时的的定位结果(此方法内部调用)
  2225. /// </summary>
  2226. /// <param name="dto"><see cref="PosRequestByLastRangeDto"/>查询参数</param>
  2227. /// <returns></returns>
  2228. /// <exception cref="Exception"></exception>
  2229. [HttpPost]
  2230. [Obsolete]
  2231. public async Task<AjaxResult<List<PosRes>>> GetPosResByLastHoursObsolete(PosRequestByLastRangeDto dto)
  2232. {
  2233. List<PosRes> posList = new List<PosRes>();
  2234. try
  2235. {
  2236. var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
  2237. if (!Directory.Exists(dir)) return Success(posList);
  2238. var yearDirs = Directory.EnumerateDirectories(dir).OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name));//年目录,倒叙排列
  2239. DateTime max = DateTime.MinValue;
  2240. foreach (var yearDir in yearDirs)
  2241. {
  2242. if (max != DateTime.MinValue) break;
  2243. //每一天的db文件,倒序排列
  2244. var dayFiles = Directory.EnumerateFiles(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, yearDir), "*.db").OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name.Substring(0, 4)));
  2245. foreach (var dayFile in dayFiles)
  2246. {
  2247. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  2248. {
  2249. if (db == null) continue;
  2250. var query = db.PosRes.Where(p => p.TaskInfoID == dto.TaskInfoID);
  2251. if (!dto.IncludeInvalidate)
  2252. {
  2253. query = query.Where(p => p.PosLon != 999);
  2254. }
  2255. if (dto.TarFrequpHz != null)
  2256. {
  2257. query = query.Where(p => p.FreqUpHz == dto.TarFrequpHz);
  2258. }
  2259. bool any = await query.AnyAsync();
  2260. if (any)
  2261. max = await query.MaxAsync(p => p.SigTime);
  2262. }
  2263. if (max != DateTime.MinValue)
  2264. {
  2265. break;
  2266. }
  2267. }
  2268. }
  2269. if (max == DateTime.MinValue) return Success(posList);
  2270. DateTime min = max.AddHours(-dto.Hours);
  2271. var res = await GetPosResByTimeRangeObsolete(new PosRequestByTimeRangeDto()
  2272. {
  2273. TaskInfoID = dto.TaskInfoID,
  2274. BeginTime = min,
  2275. EndTime = max,
  2276. IncludeInvalidate = dto.IncludeInvalidate,
  2277. TarFrequpHz = dto.TarFrequpHz,
  2278. });
  2279. return res;
  2280. }
  2281. catch (Exception ex)
  2282. {
  2283. string msg = $"定位结果查询最新数据异常-任务编号:{dto.TaskInfoID},Hours:{dto.Hours}";
  2284. Serilog.Log.Error(ex, msg);
  2285. return Error<List<PosRes>>("定位结果查询最新数据异常");
  2286. }
  2287. }
  2288. #endregion
  2289. private PosResDto MapDto(PosRes res)
  2290. {
  2291. return new PosResDto()
  2292. {
  2293. ID = res.ID,
  2294. FreqUpHz = res.FreqUpHz,
  2295. SigTime = res.SigTime,
  2296. TaskInfoID = res.TaskInfoID,
  2297. TarName = res.TargetInfo?.TargetName,
  2298. PosLon = res.PosLon,
  2299. PosLat = res.PosLat,
  2300. MirrLon = res.MirrLon,
  2301. MirrLat = res.MirrLat,
  2302. CheckType = res.CheckRes?.PosCheckType == null ? "" : res.CheckRes?.PosCheckType?.GetEnumDisplayName(),
  2303. TargetState = (EnumTargetStateDto)res.TargetState,
  2304. PosResType = (EnumPosResTypeDto)res.PosResType,
  2305. Confidence = res.Confidence,
  2306. };
  2307. }
  2308. private ModelPosRes MapModel(PosRes res)
  2309. {
  2310. return new ModelPosRes()
  2311. {
  2312. ID = res.ID,
  2313. FreqUpHz = res.FreqUpHz,
  2314. SigTime = res.SigTime,
  2315. TaskInfoID = res.TaskInfoID,
  2316. PosLon = res.PosLon,
  2317. PosLat = res.PosLat,
  2318. MirrLon = res.MirrLon,
  2319. MirrLat = res.MirrLat,
  2320. TargetState = res.TargetState,
  2321. PosResType = res.PosResType,
  2322. CgResID = res.CgResID,
  2323. CheckRes = res.CheckRes,
  2324. CheckResID = res.CheckResID,
  2325. ColorKey = res.ColorKey,
  2326. CreateTime = res.CreateTime,
  2327. CxResID = res.CxResID,
  2328. StationResID = res.StationResID,
  2329. TargetInfo = res.TargetInfo,
  2330. TargetInfoID = res.TargetInfoID,
  2331. UpdateTime = res.UpdateTime,
  2332. Confidence = res.Confidence,
  2333. };
  2334. }
  2335. }
  2336. }