PosController.cs 98 KB

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