PosController.cs 115 KB

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