PosController.cs 77 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data.Entity;
  4. using System.Data.SqlClient;
  5. using System.Data.SQLite;
  6. using System.Linq;
  7. using System.Net.Http;
  8. using System.Text;
  9. using System.Threading.Tasks;
  10. using System.Web.Http;
  11. using Newtonsoft.Json;
  12. using Serilog;
  13. using Swashbuckle.Swagger;
  14. using XdCxRhDw.Dto;
  15. using XdCxRhDW.App.Api;
  16. using XdCxRhDW.Core.Api;
  17. using XdCxRhDW.Core.ObServer;
  18. using XdCxRhDW.Core;
  19. using XdCxRhDW.Dto;
  20. using XdCxRhDW.Repostory.EFContext;
  21. using XdCxRhDW.Repostory.Model;
  22. using XdCxRhDW.WebApi.Controllers;
  23. using System.ComponentModel.DataAnnotations;
  24. using System.Web.Caching;
  25. using XdCxRhDW.Repostory;
  26. using System.IO;
  27. namespace XdCxRhDW.App.WebAPI
  28. {
  29. /// <summary>
  30. /// 定位功能相关接口
  31. /// </summary>
  32. public class PosController : BaseController
  33. {
  34. #region 一星一地测向定位
  35. /// <summary>
  36. /// 一星一地测向带参定位(含星历)
  37. /// </summary>
  38. /// <param name="dto">定位参数</param>
  39. /// <returns></returns>
  40. [HttpPost]
  41. public async Task<AjaxResult<PosResDto>> PosX1D1Async(X1D1PosDto dto)
  42. {
  43. TaskInfo runTask;
  44. using (RHDWContext db = new RHDWContext())
  45. {
  46. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X1D1CX && p.TaskState == EnumTaskState.Running);
  47. if (runTask == null)
  48. {
  49. Serilog.Log.Warning($"接收到一星一地测向带参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  50. return Error<PosResDto>($"多模式融合定位平台没有启动一星一地测向定位任务");
  51. }
  52. }
  53. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  54. {
  55. var StationRes = db.StationRes.Add(new StationRes()
  56. {
  57. SatTxLon = dto.SatTxLon,
  58. SatTxLat = dto.SatTxLat,
  59. CdbTxLon = dto.CdbTxLon,
  60. CdbTxLat = dto.CdbTxLat,
  61. CxLon = dto.CxLon,
  62. CxLat = dto.CxLat,
  63. RefLon = dto.RefLon,
  64. RefLat = dto.RefLat,
  65. });
  66. var cgRes = db.CgRes.Add(new CgRes()
  67. {
  68. SigTime = dto.SigTime,
  69. DtoCdb = dto.XdDto,
  70. DfoCdb = dto.XdDfo,
  71. SnrCdb = dto.XdSnr,
  72. YbMainDto = dto.MainYbDto,
  73. StationResID = StationRes.ID,
  74. MainCode = dto.MainCode,
  75. MainX = dto.MainX,
  76. MainY = dto.MainY,
  77. MainZ = dto.MainZ,
  78. });
  79. var cxRes = db.CxRes.Add(new CxRes()
  80. {
  81. SigTime = dto.SigTime,
  82. Fx = dto.CxRes,
  83. });
  84. var res = PosApi.X1D1_Pos(cgRes, StationRes, cxRes);
  85. PosRes posRes = new PosRes()
  86. {
  87. SigTime = cgRes.SigTime,
  88. TaskInfoID = runTask.ID,
  89. CxResID = cxRes.ID,
  90. CgResID = cgRes.ID,
  91. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  92. TsName = dto.TsName,
  93. PosLon = res[0],
  94. PosLat = res[1],
  95. MirrLon = res[3],
  96. MirrLat = res[4],
  97. PosResType = EnumPosResType.X1D1CX,
  98. };
  99. posRes = db.PosRes.Add(posRes);
  100. await db.SaveChangesAsync();
  101. PosObServer.Instance.Pub(posRes);
  102. return Success(Map(posRes));
  103. }
  104. }
  105. /// <summary>
  106. /// 一星一地测向带参定位(无星历)
  107. /// </summary>
  108. /// <returns>返回定位结果ID</returns>
  109. [HttpPost]
  110. public async Task<AjaxResult<PosResDto>> PosX1D1NoXlAsync(X1D1NoXlPosDto dto)
  111. {
  112. TaskInfo runTask;
  113. SysSetings settings;
  114. using (RHDWContext db = new RHDWContext())
  115. {
  116. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X1D1CX).FirstOrDefaultAsync();
  117. if (runTask == null)
  118. {
  119. Serilog.Log.Warning($"接收到一星一地带参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  120. return Error<PosResDto>($"多模式融合定位平台没有启动一星一地定位任务");
  121. }
  122. settings = await db.SysSetings.FirstOrDefaultAsync();
  123. }
  124. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  125. {
  126. var xlInfoList = await XlCache.GetAllAsync();
  127. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  128. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  129. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  130. //var parameter1 = new SQLiteParameter("@sigTime", dto.SigTime);
  131. //var parameter2 = new SQLiteParameter("@satcode", dto.MainCode);
  132. //var xlInfo1 = await db.XlInfos.SqlQuery("select * from XlInfo where ABS(JULIANDAY(TimeBJ)-JULIANDAY(@sigTime))=(select min(ABS(JULIANDAY(TimeBJ)-JULIANDAY(@sigTime))) from XlInfo where satcode=@satcode)", parameter1, parameter2).FirstOrDefaultAsync();
  133. if (xlInfo1 == null)
  134. {
  135. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  136. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  137. }
  138. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  139. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  140. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  141. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  142. if (ephMain.code != 200)
  143. {
  144. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  145. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  146. }
  147. var StationRes = db.StationRes.Add(new StationRes()
  148. {
  149. SatTxLon = dto.SatTxLon,
  150. SatTxLat = dto.SatTxLat,
  151. CdbTxLon = dto.CdbTxLon,
  152. CdbTxLat = dto.CdbTxLat,
  153. CxLon = dto.CxLon,
  154. CxLat = dto.CxLat,
  155. RefLon = dto.RefLon,
  156. RefLat = dto.RefLat,
  157. });
  158. var cgRes = db.CgRes.Add(new CgRes()
  159. {
  160. SigTime = dto.SigTime,
  161. DtoCdb = dto.XdDto,
  162. DfoCdb = dto.XdDfo,
  163. SnrCdb = dto.XdSnr,
  164. YbMainDto = dto.MainYbDto,
  165. StationResID = StationRes.ID,
  166. MainCode = dto.MainCode,
  167. MainX = ephMain.data.X,
  168. MainY = ephMain.data.Y,
  169. MainZ = ephMain.data.Z,
  170. });
  171. var cxRes = db.CxRes.Add(new CxRes()
  172. {
  173. SigTime = dto.SigTime,
  174. Fx = dto.CxRes,
  175. });
  176. var res = PosApi.X1D1_Pos(cgRes, StationRes, cxRes);
  177. PosRes posRes = new PosRes()
  178. {
  179. SigTime = dto.SigTime,
  180. TaskInfoID = runTask.ID,
  181. CgResID = cgRes.ID,
  182. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  183. TsName = dto.TsName,
  184. PosLon = res[0],
  185. PosLat = res[1],
  186. MirrLon = res[3],
  187. MirrLat = res[4],
  188. PosResType = EnumPosResType.X1D1CX,
  189. };
  190. posRes = db.PosRes.Add(posRes);
  191. await db.SaveChangesAsync();
  192. PosObServer.Instance.Pub(posRes);
  193. return Success(Map(posRes));
  194. }
  195. }
  196. #endregion
  197. #region 两星一地定位
  198. /// <summary>
  199. /// 两星一地带参定位(含星历)
  200. /// </summary>
  201. /// <param name="dto">定位参数</param>
  202. /// <returns></returns>
  203. [HttpPost]
  204. public async Task<AjaxResult<PosResDto>> PosX2D1Async(X2D1PosDto dto)
  205. {
  206. TaskInfo runTask;
  207. using (RHDWContext db = new RHDWContext())
  208. {
  209. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  210. if (runTask == null)
  211. {
  212. Serilog.Log.Warning($"接收到两星一地带参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  213. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  214. }
  215. }
  216. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  217. {
  218. var StationRes = db.StationRes.Add(new StationRes()
  219. {
  220. SatTxLon = dto.SatTxLon,
  221. SatTxLat = dto.SatTxLat,
  222. CdbTxLon = dto.CdbTxLon,
  223. CdbTxLat = dto.CdbTxLat,
  224. RefLon = dto.RefLon,
  225. RefLat = dto.RefLat,
  226. });
  227. var cgRes = db.CgRes.Add(new CgRes()
  228. {
  229. SigTime = dto.SigTime,
  230. Dto1 = dto.SxDto,
  231. Dfo1 = dto.SxDfo,
  232. Snr1 = dto.SxSnr,
  233. DtoCdb = dto.XdDto,
  234. DfoCdb = dto.XdDfo,
  235. SnrCdb = dto.XdSnr,
  236. YbMainDto = dto.MainYbDto,
  237. YbAdja1Dto = dto.AdjaYbDto,
  238. StationResID = StationRes.ID,
  239. MainCode = dto.MainCode,
  240. Adja1Code = dto.AdjaCode,
  241. MainX = dto.MainX,
  242. MainY = dto.MainY,
  243. MainZ = dto.MainZ,
  244. Adja1X = dto.AdjaX,
  245. Adja1Y = dto.AdjaY,
  246. Adja1Z = dto.AdjaZ,
  247. });
  248. var res = PosApi.X2D1_Pos(cgRes, StationRes);
  249. PosRes posRes = new PosRes()
  250. {
  251. SigTime = cgRes.SigTime,
  252. TaskInfoID = runTask.ID,
  253. CgResID = cgRes.ID,
  254. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  255. TsName = dto.TsName,
  256. PosLon = res[0],
  257. PosLat = res[1],
  258. MirrLon = res[3],
  259. MirrLat = res[4],
  260. PosResType = EnumPosResType.X2D1,
  261. };
  262. posRes = db.PosRes.Add(posRes);
  263. await db.SaveChangesAsync();
  264. PosObServer.Instance.Pub(posRes);
  265. return Success(Map(posRes));
  266. }
  267. }
  268. /// <summary>
  269. /// 两星一地带参定位(无星历)
  270. /// </summary>
  271. /// <returns>返回定位结果ID</returns>
  272. [HttpPost]
  273. public async Task<AjaxResult<PosResDto>> PosX2D1NoXlAsync(X2D1NoXlPosDto dto)
  274. {
  275. TaskInfo runTask;
  276. SysSetings settings;
  277. using (RHDWContext db = new RHDWContext())
  278. {
  279. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X2D1).FirstOrDefaultAsync();
  280. if (runTask == null)
  281. {
  282. Serilog.Log.Warning($"接收到两星一地带参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  283. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  284. }
  285. settings = await db.SysSetings.FirstOrDefaultAsync();
  286. }
  287. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  288. {
  289. var xlInfoList = await XlCache.GetAllAsync();
  290. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  291. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  292. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  293. if (xlInfo1 == null)
  294. {
  295. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  296. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  297. }
  298. var adjaXl = xlInfoList.Where(w => w.SatCode == dto.AdjaCode);
  299. var minTime2 = adjaXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  300. var xlInfo2 = adjaXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  301. if (xlInfo2 == null)
  302. {
  303. Serilog.Log.Error($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  304. return Error<PosResDto>($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  305. }
  306. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  307. Serilog.Log.Information($"卫星{dto.AdjaCode}使用{xlInfo2.TwoLine}进行星历推算");
  308. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  309. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  310. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  311. if (ephMain.code != 200)
  312. {
  313. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  314. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  315. }
  316. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  317. var ephAdja = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  318. if (ephAdja.code != 200)
  319. {
  320. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  321. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  322. }
  323. var StationRes = db.StationRes.Add(new StationRes()
  324. {
  325. SatTxLon = dto.SatTxLon,
  326. SatTxLat = dto.SatTxLat,
  327. CdbTxLon = dto.CdbTxLon,
  328. CdbTxLat = dto.CdbTxLat,
  329. RefLon = dto.RefLon,
  330. RefLat = dto.RefLat,
  331. });
  332. var cgRes = db.CgRes.Add(new CgRes()
  333. {
  334. SigTime = dto.SigTime,
  335. Dto1 = dto.SxDto,
  336. Dfo1 = dto.SxDfo,
  337. Snr1 = dto.SxSnr,
  338. DtoCdb = dto.XdDto,
  339. DfoCdb = dto.XdDfo,
  340. SnrCdb = dto.XdSnr,
  341. YbMainDto = dto.MainYbDto,
  342. YbAdja1Dto = dto.AdjaYbDto,
  343. StationResID = StationRes.ID,
  344. MainCode = dto.MainCode,
  345. Adja1Code = dto.AdjaCode,
  346. MainX = ephMain.data.X,
  347. MainY = ephMain.data.Y,
  348. MainZ = ephMain.data.Z,
  349. Adja1X = ephAdja.data.X,
  350. Adja1Y = ephAdja.data.Y,
  351. Adja1Z = ephAdja.data.Z,
  352. });
  353. var res = PosApi.X2D1_Pos(cgRes, StationRes);
  354. PosRes posRes = new PosRes()
  355. {
  356. SigTime = dto.SigTime,
  357. TaskInfoID = runTask.ID,
  358. CgResID = cgRes.ID,
  359. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  360. TsName = dto.TsName,
  361. PosLon = res[0],
  362. PosLat = res[1],
  363. MirrLon = res[3],
  364. MirrLat = res[4],
  365. PosResType = EnumPosResType.X2D1,
  366. };
  367. posRes = db.PosRes.Add(posRes);
  368. await db.SaveChangesAsync();
  369. PosObServer.Instance.Pub(posRes);
  370. return Success(Map(posRes));
  371. }
  372. }
  373. /// <summary>
  374. /// 两星一地无参定位(含星历)
  375. /// </summary>
  376. /// <param name="dto">定位参数</param>
  377. /// <returns></returns>
  378. [HttpPost]
  379. public async Task<AjaxResult<PosResDto>> PosX2D1NoParAsync(X2D1NoParPosDto dto)
  380. {
  381. TaskInfo runTask;
  382. using (RHDWContext db = new RHDWContext())
  383. {
  384. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  385. if (runTask == null)
  386. {
  387. Serilog.Log.Warning($"接收到两星一地无参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  388. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  389. }
  390. }
  391. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  392. {
  393. var StationRes = db.StationRes.Add(new StationRes()
  394. {
  395. SatTxLon = dto.SatTxLon,
  396. SatTxLat = dto.SatTxLat,
  397. CdbTxLon = dto.CdbTxLon,
  398. CdbTxLat = dto.CdbTxLat,
  399. });
  400. var cgRes = db.CgRes.Add(new CgRes()
  401. {
  402. SigTime = dto.SigTime,
  403. Dto1 = dto.SxDto,
  404. Dfo1 = dto.SxDfo,
  405. Snr1 = dto.SxSnr,
  406. DtoCdb = dto.XdDto,
  407. DfoCdb = dto.XdDfo,
  408. SnrCdb = dto.XdSnr,
  409. StationResID = StationRes.ID,
  410. MainCode = dto.MainCode,
  411. Adja1Code = dto.AdjaCode,
  412. MainX = dto.MainX,
  413. MainY = dto.MainY,
  414. MainZ = dto.MainZ,
  415. Adja1X = dto.AdjaX,
  416. Adja1Y = dto.AdjaY,
  417. Adja1Z = dto.AdjaZ,
  418. });
  419. var res = PosApi.X2D1_PosNoRef(cgRes, StationRes);
  420. PosRes posRes = new PosRes()
  421. {
  422. SigTime = cgRes.SigTime,
  423. TaskInfoID = runTask.ID,
  424. CgResID = cgRes.ID,
  425. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  426. TsName = dto.TsName,
  427. PosLon = res[0],
  428. PosLat = res[1],
  429. MirrLon = res[3],
  430. MirrLat = res[4],
  431. PosResType = EnumPosResType.X2D1NoRef,
  432. };
  433. posRes = db.PosRes.Add(posRes);
  434. await db.SaveChangesAsync();
  435. PosObServer.Instance.Pub(posRes);
  436. return Success(Map(posRes));
  437. }
  438. }
  439. /// <summary>
  440. /// 两星一地无参定位(无星历)
  441. /// </summary>
  442. /// <returns>返回定位结果ID</returns>
  443. [HttpPost]
  444. public async Task<AjaxResult<PosResDto>> PosX2D1NoXlNoParAsync(X2D1NoXlNoParlPosDto dto)
  445. {
  446. TaskInfo runTask;
  447. SysSetings settings;
  448. using (RHDWContext db = new RHDWContext())
  449. {
  450. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X2D1).FirstOrDefaultAsync();
  451. if (runTask == null)
  452. {
  453. Serilog.Log.Warning($"接收到两星一地无参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  454. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  455. }
  456. settings = await db.SysSetings.FirstOrDefaultAsync();
  457. }
  458. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  459. {
  460. var xlInfoList = await XlCache.GetAllAsync();
  461. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  462. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  463. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  464. if (xlInfo1 == null)
  465. {
  466. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  467. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  468. }
  469. var adjaXl = xlInfoList.Where(w => w.SatCode == dto.AdjaCode);
  470. var minTime2 = adjaXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  471. var xlInfo2 = adjaXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  472. if (xlInfo2 == null)
  473. {
  474. Serilog.Log.Error($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  475. return Error<PosResDto>($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  476. }
  477. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  478. Serilog.Log.Information($"卫星{dto.AdjaCode}使用{xlInfo2.TwoLine}进行星历推算");
  479. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  480. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  481. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  482. if (ephMain.code != 200)
  483. {
  484. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  485. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  486. }
  487. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  488. var ephAdja = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  489. if (ephAdja.code != 200)
  490. {
  491. Serilog.Log.Error($"推算[{dto.AdjaCode}]的星历出错");
  492. return Error<PosResDto>($"推算[{dto.AdjaCode}]的星历出错");
  493. }
  494. var StationRes = db.StationRes.Add(new StationRes()
  495. {
  496. SatTxLon = dto.SatTxLon,
  497. SatTxLat = dto.SatTxLat,
  498. CdbTxLon = dto.CdbTxLon,
  499. CdbTxLat = dto.CdbTxLat,
  500. });
  501. var cgRes = db.CgRes.Add(new CgRes()
  502. {
  503. SigTime = dto.SigTime,
  504. Dto1 = dto.SxDto,
  505. Dfo1 = dto.SxDfo,
  506. Snr1 = dto.SxSnr,
  507. DtoCdb = dto.XdDto,
  508. DfoCdb = dto.XdDfo,
  509. SnrCdb = dto.XdSnr,
  510. StationResID = StationRes.ID,
  511. MainCode = dto.MainCode,
  512. Adja1Code = dto.AdjaCode,
  513. MainX = ephMain.data.X,
  514. MainY = ephMain.data.Y,
  515. MainZ = ephMain.data.Z,
  516. Adja1X = ephAdja.data.X,
  517. Adja1Y = ephAdja.data.Y,
  518. Adja1Z = ephAdja.data.Z,
  519. });
  520. var res = PosApi.X2D1_PosNoRef(cgRes, StationRes);
  521. PosRes posRes = new PosRes()
  522. {
  523. SigTime = dto.SigTime,
  524. TaskInfoID = runTask.ID,
  525. CgResID = cgRes.ID,
  526. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  527. TsName = dto.TsName,
  528. PosLon = res[0],
  529. PosLat = res[1],
  530. MirrLon = res[3],
  531. MirrLat = res[4],
  532. PosResType = EnumPosResType.X2D1NoRef,
  533. };
  534. posRes = db.PosRes.Add(posRes);
  535. await db.SaveChangesAsync();
  536. PosObServer.Instance.Pub(posRes);
  537. return Success(Map(posRes));
  538. }
  539. }
  540. #endregion
  541. #region 融合定位
  542. /// <summary>
  543. /// 融合带参定位(含星历)
  544. /// </summary>
  545. /// <param name="dto">定位参数</param>
  546. /// <returns></returns>
  547. [HttpPost]
  548. public async Task<AjaxResult<PosResDto>> PosRhAsync(RHPosDto dto)
  549. {
  550. TaskInfo runTask;
  551. using (RHDWContext db = new RHDWContext())
  552. {
  553. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.RH && p.TaskState == EnumTaskState.Running);
  554. if (runTask == null)
  555. {
  556. Serilog.Log.Warning($"接收到融合带参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  557. return Error<PosResDto>($"多模式融合定位平台没有启动融合定位任务");
  558. }
  559. }
  560. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  561. {
  562. var StationRes = db.StationRes.Add(new StationRes()
  563. {
  564. SatTxLon = dto.SatTxLon,
  565. SatTxLat = dto.SatTxLat,
  566. CdbTxLon = dto.CdbTxLon,
  567. CdbTxLat = dto.CdbTxLat,
  568. CxLon = dto.CxLon,
  569. CxLat = dto.CxLat,
  570. RefLon = dto.RefLon,
  571. RefLat = dto.RefLat,
  572. });
  573. var cgRes = db.CgRes.Add(new CgRes()
  574. {
  575. SigTime = dto.SigTime,
  576. Dto1 = dto.SxDto,
  577. Dfo1 = dto.SxDfo,
  578. Snr1 = dto.SxSnr,
  579. DtoCdb = dto.XdDto,
  580. DfoCdb = dto.XdDfo,
  581. SnrCdb = dto.XdSnr,
  582. YbMainDto = dto.MainYbDto,
  583. YbAdja1Dto = dto.AdjaYbDto,
  584. StationResID = StationRes.ID,
  585. MainCode = dto.MainCode,
  586. Adja1Code = dto.AdjaCode,
  587. MainX = dto.MainX,
  588. MainY = dto.MainY,
  589. MainZ = dto.MainZ,
  590. Adja1X = dto.AdjaX,
  591. Adja1Y = dto.AdjaY,
  592. Adja1Z = dto.AdjaZ,
  593. });
  594. var cxRes = db.CxRes.Add(new CxRes()
  595. {
  596. SigTime = dto.SigTime,
  597. Fx = dto.CxRes,
  598. });
  599. var res = PosApi.RH_Pos(cgRes, StationRes, cxRes);
  600. PosRes posRes = new PosRes()
  601. {
  602. SigTime = cgRes.SigTime,
  603. TaskInfoID = runTask.ID,
  604. CxResID = cxRes.ID,
  605. CgResID = cgRes.ID,
  606. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  607. TsName = dto.TsName,
  608. PosLon = res[0],
  609. PosLat = res[1],
  610. MirrLon = res[3],
  611. MirrLat = res[4],
  612. PosResType = EnumPosResType.RH,
  613. };
  614. posRes = db.PosRes.Add(posRes);
  615. await db.SaveChangesAsync();
  616. PosObServer.Instance.Pub(posRes);
  617. return Success(Map(posRes));
  618. }
  619. }
  620. /// <summary>
  621. /// 融合带参定位(无星历)
  622. /// </summary>
  623. /// <returns>返回定位结果ID</returns>
  624. [HttpPost]
  625. public async Task<AjaxResult<PosResDto>> PosRhNoXlAsync(RHNoXlPosDto dto)
  626. {
  627. TaskInfo runTask;
  628. SysSetings settings;
  629. using (RHDWContext db = new RHDWContext())
  630. {
  631. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.RH).FirstOrDefaultAsync();
  632. if (runTask == null)
  633. {
  634. Serilog.Log.Warning($"接收到融合带参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  635. return Error<PosResDto>($"多模式融合定位平台没有启动融合定位任务");
  636. }
  637. settings = await db.SysSetings.FirstOrDefaultAsync();
  638. }
  639. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  640. {
  641. var xlInfoList = await XlCache.GetAllAsync();
  642. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  643. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  644. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  645. if (xlInfo1 == null)
  646. {
  647. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  648. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  649. }
  650. var adjaXl = xlInfoList.Where(w => w.SatCode == dto.AdjaCode);
  651. var minTime2 = adjaXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  652. var xlInfo2 = adjaXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  653. if (xlInfo2 == null)
  654. {
  655. Serilog.Log.Error($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  656. return Error<PosResDto>($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  657. }
  658. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  659. Serilog.Log.Information($"卫星{dto.AdjaCode}使用{xlInfo2.TwoLine}进行星历推算");
  660. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  661. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  662. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  663. if (ephMain.code != 200)
  664. {
  665. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  666. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  667. }
  668. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  669. var ephAdja = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  670. if (ephAdja.code != 200)
  671. {
  672. Serilog.Log.Error($"推算[{dto.AdjaCode}]的星历出错");
  673. return Error<PosResDto>($"推算[{dto.AdjaCode}]的星历出错");
  674. }
  675. var StationRes = db.StationRes.Add(new StationRes()
  676. {
  677. SatTxLon = dto.SatTxLon,
  678. SatTxLat = dto.SatTxLat,
  679. CdbTxLon = dto.CdbTxLon,
  680. CdbTxLat = dto.CdbTxLat,
  681. CxLon = dto.CxLon,
  682. CxLat = dto.CxLat,
  683. RefLon = dto.RefLon,
  684. RefLat = dto.RefLat,
  685. });
  686. var cgRes = db.CgRes.Add(new CgRes()
  687. {
  688. SigTime = dto.SigTime,
  689. Dto1 = dto.SxDto,
  690. Dfo1 = dto.SxDfo,
  691. Snr1 = dto.SxSnr,
  692. DtoCdb = dto.XdDto,
  693. DfoCdb = dto.XdDfo,
  694. SnrCdb = dto.XdSnr,
  695. YbMainDto = dto.MainYbDto,
  696. YbAdja1Dto = dto.AdjaYbDto,
  697. StationResID = StationRes.ID,
  698. MainCode = dto.MainCode,
  699. Adja1Code = dto.AdjaCode,
  700. MainX = ephMain.data.X,
  701. MainY = ephMain.data.Y,
  702. MainZ = ephMain.data.Z,
  703. Adja1X = ephAdja.data.X,
  704. Adja1Y = ephAdja.data.Y,
  705. Adja1Z = ephAdja.data.Z,
  706. });
  707. var cxRes = db.CxRes.Add(new CxRes()
  708. {
  709. SigTime = dto.SigTime,
  710. Fx = dto.CxRes,
  711. });
  712. var res = PosApi.RH_Pos(cgRes, StationRes, cxRes);
  713. PosRes posRes = new PosRes()
  714. {
  715. SigTime = cgRes.SigTime,
  716. TaskInfoID = runTask.ID,
  717. CxResID = cxRes.ID,
  718. CgResID = cgRes.ID,
  719. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  720. TsName = dto.TsName,
  721. PosLon = res[0],
  722. PosLat = res[1],
  723. MirrLon = res[3],
  724. MirrLat = res[4],
  725. PosResType = EnumPosResType.RH,
  726. };
  727. posRes = db.PosRes.Add(posRes);
  728. await db.SaveChangesAsync();
  729. PosObServer.Instance.Pub(posRes);
  730. return Success(Map(posRes));
  731. }
  732. }
  733. #endregion
  734. #region 三星双时差定位
  735. /// <summary>
  736. /// 三星双时差带参定位(含星历)
  737. /// </summary>
  738. /// <param name="dto">定位参数</param>
  739. /// <returns></returns>
  740. [HttpPost]
  741. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoAsync(X3TwoDtoPosDto dto)
  742. {
  743. TaskInfo runTask;
  744. using (RHDWContext db = new RHDWContext())
  745. {
  746. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  747. if (runTask == null)
  748. {
  749. Serilog.Log.Warning($"接收到三星双时差带参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  750. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  751. }
  752. }
  753. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  754. {
  755. var StationRes = db.StationRes.Add(new StationRes()
  756. {
  757. SatTxLon = dto.SatTxLon,
  758. SatTxLat = dto.SatTxLat,
  759. RefLon = dto.RefLon,
  760. RefLat = dto.RefLat,
  761. });
  762. var cgRes = db.CgRes.Add(new CgRes()
  763. {
  764. SigTime = dto.SigTime,
  765. Dto1 = dto.Dto1,
  766. Dfo1 = dto.Dfo1,
  767. Snr1 = dto.Snr1,
  768. Dto2 = dto.Dto2,
  769. Dfo2 = dto.Dfo2,
  770. Snr2 = dto.Snr2,
  771. YbMainDto = dto.YbMainDto,
  772. YbAdja1Dto = dto.YbAdja1Dto,
  773. YbAdja2Dto = dto.YbAdja2Dto,
  774. StationResID = StationRes.ID,
  775. MainCode = dto.MainCode,
  776. Adja1Code = dto.Adja1Code,
  777. Adja2Code = dto.Adja2Code,
  778. MainX = dto.MainX,
  779. MainY = dto.MainY,
  780. MainZ = dto.MainZ,
  781. Adja1X = dto.Adja1X,
  782. Adja1Y = dto.Adja1Y,
  783. Adja1Z = dto.Adja1Z,
  784. Adja2X = dto.Adja2X,
  785. Adja2Y = dto.Adja2Y,
  786. Adja2Z = dto.Adja2Z,
  787. });
  788. var res = PosApi.X3_Pos(cgRes, StationRes);
  789. PosRes posRes = new PosRes()
  790. {
  791. SigTime = cgRes.SigTime,
  792. TaskInfoID = runTask.ID,
  793. CgResID = cgRes.ID,
  794. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  795. TsName = dto.TsName,
  796. PosLon = res[0],
  797. PosLat = res[1],
  798. MirrLon = res[3],
  799. MirrLat = res[4],
  800. PosResType = EnumPosResType.X3,
  801. };
  802. posRes = db.PosRes.Add(posRes);
  803. await db.SaveChangesAsync();
  804. PosObServer.Instance.Pub(posRes);
  805. return Success(Map(posRes));
  806. }
  807. }
  808. /// <summary>
  809. /// 三星双时差带参定位(无星历)
  810. /// </summary>
  811. /// <returns>返回定位结果ID</returns>
  812. [HttpPost]
  813. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoXlAsync(X3TwoDtoNoXlPosDto dto)
  814. {
  815. TaskInfo runTask;
  816. SysSetings settings;
  817. using (RHDWContext db = new RHDWContext())
  818. {
  819. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X3TwoDto).FirstOrDefaultAsync();
  820. if (runTask == null)
  821. {
  822. Serilog.Log.Warning($"接收到三星双时差带参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  823. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  824. }
  825. settings = await db.SysSetings.FirstOrDefaultAsync();
  826. }
  827. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  828. {
  829. var xlInfoList = await XlCache.GetAllAsync();
  830. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  831. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  832. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  833. if (xlInfo1 == null)
  834. {
  835. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  836. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  837. }
  838. var adja1Xl = xlInfoList.Where(w => w.SatCode == dto.Adja1Code);
  839. var minTime2 = adja1Xl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  840. var xlInfo2 = adja1Xl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  841. if (xlInfo2 == null)
  842. {
  843. Serilog.Log.Error($"未找到卫星[{dto.Adja1Code}]的双行根数星历");
  844. return Error<PosResDto>($"未找到卫星[{dto.Adja1Code}]的双行根数星历");
  845. }
  846. var adja2Xl = xlInfoList.Where(w => w.SatCode == dto.Adja2Code);
  847. var minTime3 = adja2Xl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  848. var xlInfo3 = adja2Xl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime3).FirstOrDefault();
  849. if (xlInfo3 == null)
  850. {
  851. Serilog.Log.Error($"未找到卫星[{dto.Adja2Code}]的双行根数星历");
  852. return Error<PosResDto>($"未找到卫星[{dto.Adja2Code}]的双行根数星历");
  853. }
  854. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  855. Serilog.Log.Information($"卫星{dto.Adja1Code}使用{xlInfo2.TwoLine}进行星历推算");
  856. Serilog.Log.Information($"卫星{dto.Adja2Code}使用{xlInfo3.TwoLine}进行星历推算");
  857. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  858. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  859. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  860. if (ephMain.code != 200)
  861. {
  862. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  863. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  864. }
  865. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  866. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  867. if (ephAdja1.code != 200)
  868. {
  869. Serilog.Log.Error($"推算[{dto.Adja1Code}]的星历出错");
  870. return Error<PosResDto>($"推算[{dto.Adja1Code}]的星历出错");
  871. }
  872. var XlCalcDto3 = new XlCalcDto() { tleStr = xlInfo3.TwoLine, dt = dto.SigTime };
  873. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto3);
  874. if (ephAdja2.code != 200)
  875. {
  876. Serilog.Log.Error($"推算[{dto.Adja2Code}]的星历出错");
  877. return Error<PosResDto>($"推算[{dto.Adja2Code}]的星历出错");
  878. }
  879. var StationRes = db.StationRes.Add(new StationRes()
  880. {
  881. SatTxLon = dto.SatTxLon,
  882. SatTxLat = dto.SatTxLat,
  883. RefLon = dto.RefLon,
  884. RefLat = dto.RefLat,
  885. });
  886. var cgRes = db.CgRes.Add(new CgRes()
  887. {
  888. SigTime = dto.SigTime,
  889. Dto1 = dto.Dto1,
  890. Dfo1 = dto.Dfo1,
  891. Snr1 = dto.Snr1,
  892. Dto2 = dto.Dto2,
  893. Dfo2 = dto.Dfo2,
  894. Snr2 = dto.Snr2,
  895. YbMainDto = dto.YbMainDto,
  896. YbAdja1Dto = dto.YbAdja1Dto,
  897. YbAdja2Dto = dto.YbAdja2Dto,
  898. StationResID = StationRes.ID,
  899. MainCode = dto.MainCode,
  900. Adja1Code = dto.Adja1Code,
  901. Adja2Code = dto.Adja2Code,
  902. MainX = ephMain.data.X,
  903. MainY = ephMain.data.Y,
  904. MainZ = ephMain.data.Z,
  905. Adja1X = ephAdja1.data.X,
  906. Adja1Y = ephAdja1.data.Y,
  907. Adja1Z = ephAdja1.data.Z,
  908. Adja2X = ephAdja2.data.X,
  909. Adja2Y = ephAdja2.data.Y,
  910. Adja2Z = ephAdja2.data.Z,
  911. });
  912. var res = PosApi.X3_Pos(cgRes, StationRes);
  913. PosRes posRes = new PosRes()
  914. {
  915. SigTime = dto.SigTime,
  916. TaskInfoID = runTask.ID,
  917. CgResID = cgRes.ID,
  918. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  919. TsName = dto.TsName,
  920. PosLon = res[0],
  921. PosLat = res[1],
  922. MirrLon = res[3],
  923. MirrLat = res[4],
  924. PosResType = EnumPosResType.X3,
  925. };
  926. posRes = db.PosRes.Add(posRes);
  927. await db.SaveChangesAsync();
  928. PosObServer.Instance.Pub(posRes);
  929. return Success(Map(posRes));
  930. }
  931. }
  932. /// <summary>
  933. /// 三星双时差无参定位(含星历)
  934. /// </summary>
  935. /// <param name="dto">定位参数</param>
  936. /// <returns></returns>
  937. [HttpPost]
  938. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoParAsync(X3TwoDtoNoParPosDto dto)
  939. {
  940. TaskInfo runTask;
  941. using (RHDWContext db = new RHDWContext())
  942. {
  943. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  944. if (runTask == null)
  945. {
  946. Serilog.Log.Warning($"接收到三星双时差无参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  947. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  948. }
  949. }
  950. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  951. {
  952. var StationRes = db.StationRes.Add(new StationRes()
  953. {
  954. SatTxLon = dto.SatTxLon,
  955. SatTxLat = dto.SatTxLat,
  956. });
  957. var cgRes = db.CgRes.Add(new CgRes()
  958. {
  959. SigTime = dto.SigTime,
  960. Dto1 = dto.Dto1,
  961. Dfo1 = dto.Dfo1,
  962. Snr1 = dto.Snr1,
  963. Dto2 = dto.Dto2,
  964. Dfo2 = dto.Dfo2,
  965. Snr2 = dto.Snr2,
  966. StationResID = StationRes.ID,
  967. MainCode = dto.MainCode,
  968. Adja1Code = dto.Adja1Code,
  969. Adja2Code = dto.Adja2Code,
  970. MainX = dto.MainX,
  971. MainY = dto.MainY,
  972. MainZ = dto.MainZ,
  973. Adja1X = dto.Adja1X,
  974. Adja1Y = dto.Adja1Y,
  975. Adja1Z = dto.Adja1Z,
  976. Adja2X = dto.Adja2X,
  977. Adja2Y = dto.Adja2Y,
  978. Adja2Z = dto.Adja2Z,
  979. });
  980. var res = PosApi.X3_PosNoRef(cgRes, StationRes);
  981. PosRes posRes = new PosRes()
  982. {
  983. SigTime = cgRes.SigTime,
  984. TaskInfoID = runTask.ID,
  985. CgResID = cgRes.ID,
  986. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  987. TsName = dto.TsName,
  988. PosLon = res[0],
  989. PosLat = res[1],
  990. MirrLon = res[3],
  991. MirrLat = res[4],
  992. PosResType = EnumPosResType.X3NoRef,
  993. };
  994. posRes = db.PosRes.Add(posRes);
  995. await db.SaveChangesAsync();
  996. PosObServer.Instance.Pub(posRes);
  997. return Success(Map(posRes));
  998. }
  999. }
  1000. /// <summary>
  1001. /// 三星双时差无参定位(无星历)
  1002. /// </summary>
  1003. /// <returns>返回定位结果ID</returns>
  1004. [HttpPost]
  1005. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoXlNoParAsync(X3TwoDtoNoXlNoParPosDto dto)
  1006. {
  1007. TaskInfo runTask;
  1008. SysSetings settings;
  1009. using (RHDWContext db = new RHDWContext())
  1010. {
  1011. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X3TwoDto).FirstOrDefaultAsync();
  1012. if (runTask == null)
  1013. {
  1014. Serilog.Log.Warning($"接收到三星双时差无参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  1015. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1016. }
  1017. settings = await db.SysSetings.FirstOrDefaultAsync();
  1018. }
  1019. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  1020. {
  1021. var xlInfoList = await XlCache.GetAllAsync();
  1022. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  1023. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1024. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  1025. if (xlInfo1 == null)
  1026. {
  1027. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  1028. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  1029. }
  1030. var adja1Xl = xlInfoList.Where(w => w.SatCode == dto.Adja1Code);
  1031. var minTime2 = adja1Xl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1032. var xlInfo2 = adja1Xl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  1033. if (xlInfo2 == null)
  1034. {
  1035. Serilog.Log.Error($"未找到卫星[{dto.Adja1Code}]的双行根数星历");
  1036. return Error<PosResDto>($"未找到卫星[{dto.Adja1Code}]的双行根数星历");
  1037. }
  1038. var adja2Xl = xlInfoList.Where(w => w.SatCode == dto.Adja2Code);
  1039. var minTime3 = adja2Xl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1040. var xlInfo3 = adja2Xl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime3).FirstOrDefault();
  1041. if (xlInfo3 == null)
  1042. {
  1043. Serilog.Log.Error($"未找到卫星[{dto.Adja2Code}]的双行根数星历");
  1044. return Error<PosResDto>($"未找到卫星[{dto.Adja2Code}]的双行根数星历");
  1045. }
  1046. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  1047. Serilog.Log.Information($"卫星{dto.Adja1Code}使用{xlInfo2.TwoLine}进行星历推算");
  1048. Serilog.Log.Information($"卫星{dto.Adja2Code}使用{xlInfo3.TwoLine}进行星历推算");
  1049. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  1050. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  1051. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  1052. if (ephMain.code != 200)
  1053. {
  1054. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  1055. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  1056. }
  1057. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  1058. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  1059. if (ephAdja1.code != 200)
  1060. {
  1061. Serilog.Log.Error($"推算[{dto.Adja1Code}]的星历出错");
  1062. return Error<PosResDto>($"推算[{dto.Adja1Code}]的星历出错");
  1063. }
  1064. var XlCalcDto3 = new XlCalcDto() { tleStr = xlInfo3.TwoLine, dt = dto.SigTime };
  1065. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto3);
  1066. if (ephAdja2.code != 200)
  1067. {
  1068. Serilog.Log.Error($"推算[{dto.Adja2Code}]的星历出错");
  1069. return Error<PosResDto>($"推算[{dto.Adja2Code}]的星历出错");
  1070. }
  1071. var StationRes = db.StationRes.Add(new StationRes()
  1072. {
  1073. SatTxLon = dto.SatTxLon,
  1074. SatTxLat = dto.SatTxLat,
  1075. });
  1076. var cgRes = db.CgRes.Add(new CgRes()
  1077. {
  1078. SigTime = dto.SigTime,
  1079. Dto1 = dto.Dto1,
  1080. Dfo1 = dto.Dfo1,
  1081. Snr1 = dto.Snr1,
  1082. Dto2 = dto.Dto2,
  1083. Dfo2 = dto.Dfo2,
  1084. Snr2 = dto.Snr2,
  1085. StationResID = StationRes.ID,
  1086. MainCode = dto.MainCode,
  1087. Adja1Code = dto.Adja1Code,
  1088. Adja2Code = dto.Adja2Code,
  1089. MainX = ephMain.data.X,
  1090. MainY = ephMain.data.Y,
  1091. MainZ = ephMain.data.Z,
  1092. Adja1X = ephAdja1.data.X,
  1093. Adja1Y = ephAdja1.data.Y,
  1094. Adja1Z = ephAdja1.data.Z,
  1095. Adja2X = ephAdja2.data.X,
  1096. Adja2Y = ephAdja2.data.Y,
  1097. Adja2Z = ephAdja2.data.Z,
  1098. });
  1099. var res = PosApi.X3_PosNoRef(cgRes, StationRes);
  1100. PosRes posRes = new PosRes()
  1101. {
  1102. SigTime = dto.SigTime,
  1103. TaskInfoID = runTask.ID,
  1104. CgResID = cgRes.ID,
  1105. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  1106. TsName = dto.TsName,
  1107. PosLon = res[0],
  1108. PosLat = res[1],
  1109. MirrLon = res[3],
  1110. MirrLat = res[4],
  1111. PosResType = EnumPosResType.X3NoRef,
  1112. };
  1113. posRes = db.PosRes.Add(posRes);
  1114. await db.SaveChangesAsync();
  1115. PosObServer.Instance.Pub(posRes);
  1116. return Success(Map(posRes));
  1117. }
  1118. }
  1119. #endregion
  1120. #region 三星双频差定位
  1121. /// <summary>
  1122. /// 三星双频差带参定位(含星历)
  1123. /// </summary>
  1124. /// <param name="dto">定位参数</param>
  1125. /// <returns></returns>
  1126. [HttpPost]
  1127. public async Task<AjaxResult<PosResDto>> PosX3TwoDfoAsync(X3TwoDfoPosDto dto)
  1128. {
  1129. TaskInfo runTask;
  1130. using (RHDWContext db = new RHDWContext())
  1131. {
  1132. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X3TwoDfo && p.TaskState == EnumTaskState.Running);
  1133. if (runTask == null)
  1134. {
  1135. Serilog.Log.Warning($"接收到三星双频差带参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  1136. return Error<PosResDto>($"多模式融合定位平台没有启动三星双频差定位任务");
  1137. }
  1138. }
  1139. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  1140. {
  1141. var StationRes = db.StationRes.Add(new StationRes()
  1142. {
  1143. SatTxLon = dto.SatTxLon,
  1144. SatTxLat = dto.SatTxLat,
  1145. RefLon = dto.RefLon,
  1146. RefLat = dto.RefLat,
  1147. });
  1148. var cgRes = db.CgRes.Add(new CgRes()
  1149. {
  1150. SigTime = dto.SigTime,
  1151. Dto1 = dto.Dto1,
  1152. Dfo1 = dto.Dfo1,
  1153. Snr1 = dto.Snr1,
  1154. Dto2 = dto.Dto2,
  1155. Dfo2 = dto.Dfo2,
  1156. Snr2 = dto.Snr2,
  1157. YbMainDfo = dto.YbMainDfo,
  1158. YbAdja1Dfo = dto.YbAdja1Dfo,
  1159. YbAdja2Dfo = dto.YbAdja2Dfo,
  1160. TarFreqUp = dto.TarFreqUp,
  1161. TarFreqDown = dto.TarFreqDown,
  1162. RefFreqUp = dto.RefFreqUp,
  1163. RefFreqDown = dto.RefFreqDown,
  1164. StationResID = StationRes.ID,
  1165. MainCode = dto.MainCode,
  1166. Adja1Code = dto.Adja1Code,
  1167. Adja2Code = dto.Adja2Code,
  1168. MainX = dto.MainX,
  1169. MainY = dto.MainY,
  1170. MainZ = dto.MainZ,
  1171. MainVx = dto.MainVx,
  1172. MainVy = dto.MainVy,
  1173. MainVz = dto.MainVz,
  1174. Adja1X = dto.Adja1X,
  1175. Adja1Y = dto.Adja1Y,
  1176. Adja1Z = dto.Adja1Z,
  1177. Adja1Vx = dto.Adja1Vx,
  1178. Adja1Vy = dto.Adja1Vy,
  1179. Adja1Vz = dto.Adja1Vz,
  1180. Adja2X = dto.Adja2X,
  1181. Adja2Y = dto.Adja2Y,
  1182. Adja2Z = dto.Adja2Z,
  1183. Adja2Vx = dto.Adja2Vx,
  1184. Adja2Vy = dto.Adja2Vy,
  1185. Adja2Vz = dto.Adja2Vz,
  1186. });
  1187. var res = PosApi.X3_PosTwoDfo(cgRes, StationRes);
  1188. PosRes posRes = new PosRes()
  1189. {
  1190. SigTime = cgRes.SigTime,
  1191. TaskInfoID = runTask.ID,
  1192. CgResID = cgRes.ID,
  1193. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  1194. TsName = dto.TsName,
  1195. PosLon = res[0],
  1196. PosLat = res[1],
  1197. MirrLon = res[3],
  1198. MirrLat = res[4],
  1199. PosResType = EnumPosResType.X3TwoDfo,
  1200. };
  1201. posRes = db.PosRes.Add(posRes);
  1202. await db.SaveChangesAsync();
  1203. PosObServer.Instance.Pub(posRes);
  1204. return Success(Map(posRes));
  1205. }
  1206. }
  1207. /// <summary>
  1208. /// 三星双频差带参定位(无星历)
  1209. /// </summary>
  1210. /// <returns>返回定位结果ID</returns>
  1211. [HttpPost]
  1212. public async Task<AjaxResult<PosResDto>> PosX3TwoDfoNoXlAsync(X3TwoDfoNoXlPosDto dto)
  1213. {
  1214. TaskInfo runTask;
  1215. SysSetings settings;
  1216. using (RHDWContext db = new RHDWContext())
  1217. {
  1218. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X3TwoDfo).FirstOrDefaultAsync();
  1219. if (runTask == null)
  1220. {
  1221. Serilog.Log.Warning($"接收到三星双频差带参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  1222. return Error<PosResDto>($"多模式融合定位平台没有启动三星双频差定位任务");
  1223. }
  1224. settings = await db.SysSetings.FirstOrDefaultAsync();
  1225. }
  1226. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  1227. {
  1228. var xlInfoList = await XlCache.GetAllAsync();
  1229. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  1230. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1231. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  1232. if (xlInfo1 == null)
  1233. {
  1234. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  1235. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  1236. }
  1237. var adja1Xl = xlInfoList.Where(w => w.SatCode == dto.Adja1Code);
  1238. var minTime2 = adja1Xl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1239. var xlInfo2 = adja1Xl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  1240. if (xlInfo2 == null)
  1241. {
  1242. Serilog.Log.Error($"未找到卫星[{dto.Adja1Code}]的双行根数星历");
  1243. return Error<PosResDto>($"未找到卫星[{dto.Adja1Code}]的双行根数星历");
  1244. }
  1245. var adja2Xl = xlInfoList.Where(w => w.SatCode == dto.Adja2Code);
  1246. var minTime3 = adja2Xl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1247. var xlInfo3 = adja2Xl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime3).FirstOrDefault();
  1248. if (xlInfo3 == null)
  1249. {
  1250. Serilog.Log.Error($"未找到卫星[{dto.Adja2Code}]的双行根数星历");
  1251. return Error<PosResDto>($"未找到卫星[{dto.Adja2Code}]的双行根数星历");
  1252. }
  1253. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  1254. Serilog.Log.Information($"卫星{dto.Adja1Code}使用{xlInfo2.TwoLine}进行星历推算");
  1255. Serilog.Log.Information($"卫星{dto.Adja2Code}使用{xlInfo3.TwoLine}进行星历推算");
  1256. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  1257. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  1258. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  1259. if (ephMain.code != 200)
  1260. {
  1261. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  1262. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  1263. }
  1264. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  1265. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  1266. if (ephAdja1.code != 200)
  1267. {
  1268. Serilog.Log.Error($"推算[{dto.Adja1Code}]的星历出错");
  1269. return Error<PosResDto>($"推算[{dto.Adja1Code}]的星历出错");
  1270. }
  1271. var XlCalcDto3 = new XlCalcDto() { tleStr = xlInfo3.TwoLine, dt = dto.SigTime };
  1272. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto3);
  1273. if (ephAdja2.code != 200)
  1274. {
  1275. Serilog.Log.Error($"推算[{dto.Adja2Code}]的星历出错");
  1276. return Error<PosResDto>($"推算[{dto.Adja2Code}]的星历出错");
  1277. }
  1278. var StationRes = db.StationRes.Add(new StationRes()
  1279. {
  1280. SatTxLon = dto.SatTxLon,
  1281. SatTxLat = dto.SatTxLat,
  1282. RefLon = dto.RefLon,
  1283. RefLat = dto.RefLat,
  1284. });
  1285. var cgRes = db.CgRes.Add(new CgRes()
  1286. {
  1287. SigTime = dto.SigTime,
  1288. Dto1 = dto.Dto1,
  1289. Dfo1 = dto.Dfo1,
  1290. Snr1 = dto.Snr1,
  1291. Dto2 = dto.Dto2,
  1292. Dfo2 = dto.Dfo2,
  1293. Snr2 = dto.Snr2,
  1294. YbMainDfo = dto.YbMainDfo,
  1295. YbAdja1Dfo = dto.YbAdja1Dfo,
  1296. YbAdja2Dfo = dto.YbAdja2Dfo,
  1297. TarFreqUp = dto.TarFreqUp,
  1298. TarFreqDown = dto.TarFreqDown,
  1299. RefFreqUp = dto.RefFreqUp,
  1300. RefFreqDown = dto.RefFreqDown,
  1301. StationResID = StationRes.ID,
  1302. MainCode = dto.MainCode,
  1303. Adja1Code = dto.Adja1Code,
  1304. Adja2Code = dto.Adja2Code,
  1305. MainX = ephMain.data.X,
  1306. MainY = ephMain.data.Y,
  1307. MainZ = ephMain.data.Z,
  1308. MainVx = ephMain.data.VX,
  1309. MainVy = ephMain.data.VY,
  1310. MainVz = ephMain.data.VZ,
  1311. Adja1X = ephAdja1.data.X,
  1312. Adja1Y = ephAdja1.data.Y,
  1313. Adja1Z = ephAdja1.data.Z,
  1314. Adja1Vx = ephAdja1.data.VX,
  1315. Adja1Vy = ephAdja1.data.VY,
  1316. Adja1Vz = ephAdja1.data.VZ,
  1317. Adja2X = ephAdja2.data.X,
  1318. Adja2Y = ephAdja2.data.Y,
  1319. Adja2Z = ephAdja2.data.Z,
  1320. Adja2Vx = ephAdja2.data.VX,
  1321. Adja2Vy = ephAdja2.data.VY,
  1322. Adja2Vz = ephAdja2.data.VZ,
  1323. });
  1324. var res = PosApi.X3_PosTwoDfo(cgRes, StationRes);
  1325. PosRes posRes = new PosRes()
  1326. {
  1327. SigTime = dto.SigTime,
  1328. TaskInfoID = runTask.ID,
  1329. CgResID = cgRes.ID,
  1330. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  1331. TsName = dto.TsName,
  1332. PosLon = res[0],
  1333. PosLat = res[1],
  1334. MirrLon = res[3],
  1335. MirrLat = res[4],
  1336. PosResType = EnumPosResType.X3TwoDfo,
  1337. };
  1338. posRes = db.PosRes.Add(posRes);
  1339. await db.SaveChangesAsync();
  1340. PosObServer.Instance.Pub(posRes);
  1341. return Success(Map(posRes));
  1342. }
  1343. }
  1344. #endregion
  1345. #region 双星时频差定位
  1346. /// <summary>
  1347. /// 双星时频差带参定位(含星历)
  1348. /// </summary>
  1349. /// <param name="dto">定位参数</param>
  1350. /// <returns></returns>
  1351. [HttpPost]
  1352. public async Task<AjaxResult<PosResDto>> PosX2DtoDfoAsync(X2DtoDfoPosDto dto)
  1353. {
  1354. TaskInfo runTask;
  1355. using (RHDWContext db = new RHDWContext())
  1356. {
  1357. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.PosType == EnumPosType.X2Dfo && p.TaskState == EnumTaskState.Running);
  1358. if (runTask == null)
  1359. {
  1360. Serilog.Log.Warning($"接收到双星时频差带参定位(含星历)参数,由于任务没有运行中忽略本次定位!");
  1361. return Error<PosResDto>($"多模式融合定位平台没有启动双星时频差定位任务");
  1362. }
  1363. }
  1364. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  1365. {
  1366. var StationRes = db.StationRes.Add(new StationRes()
  1367. {
  1368. SatTxLon = dto.SatTxLon,
  1369. SatTxLat = dto.SatTxLat,
  1370. RefLon = dto.RefLon,
  1371. RefLat = dto.RefLat,
  1372. });
  1373. var cgRes = db.CgRes.Add(new CgRes()
  1374. {
  1375. SigTime = dto.SigTime,
  1376. Dto1 = dto.Dto,
  1377. Dfo1 = dto.Dfo,
  1378. Snr1 = dto.Snr,
  1379. YbMainDto = dto.YbMainDto,
  1380. YbAdja1Dto = dto.YbAdjaDto,
  1381. YbMainDfo = dto.YbMainDfo,
  1382. YbAdja1Dfo = dto.YbAdjaDfo,
  1383. TarFreqUp = dto.TarFreqUp,
  1384. TarFreqDown = dto.TarFreqDown,
  1385. RefFreqUp = dto.RefFreqUp,
  1386. RefFreqDown = dto.RefFreqDown,
  1387. StationResID = StationRes.ID,
  1388. MainCode = dto.MainCode,
  1389. Adja1Code = dto.AdjaCode,
  1390. MainX = dto.MainX,
  1391. MainY = dto.MainY,
  1392. MainZ = dto.MainZ,
  1393. MainVx = dto.MainVx,
  1394. MainVy = dto.MainVy,
  1395. MainVz = dto.MainVz,
  1396. Adja1X = dto.AdjaX,
  1397. Adja1Y = dto.AdjaY,
  1398. Adja1Z = dto.AdjaZ,
  1399. Adja1Vx = dto.AdjaVx,
  1400. Adja1Vy = dto.AdjaVy,
  1401. Adja1Vz = dto.AdjaVz,
  1402. });
  1403. var res = PosApi.X2_PosDtoDfo(cgRes, StationRes);
  1404. PosRes posRes = new PosRes()
  1405. {
  1406. SigTime = cgRes.SigTime,
  1407. TaskInfoID = runTask.ID,
  1408. CgResID = cgRes.ID,
  1409. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  1410. TsName = dto.TsName,
  1411. PosLon = res[0],
  1412. PosLat = res[1],
  1413. MirrLon = res[3],
  1414. MirrLat = res[4],
  1415. PosResType = EnumPosResType.X2Dfo,
  1416. };
  1417. posRes = db.PosRes.Add(posRes);
  1418. await db.SaveChangesAsync();
  1419. PosObServer.Instance.Pub(posRes);
  1420. return Success(Map(posRes));
  1421. }
  1422. }
  1423. /// <summary>
  1424. /// 双星时频差带参定位(无星历)
  1425. /// </summary>
  1426. /// <returns>返回定位结果ID</returns>
  1427. [HttpPost]
  1428. public async Task<AjaxResult<PosResDto>> PosX2DtoDfoNoXlAsync(X2DtoDfoNoXlPosDto dto)
  1429. {
  1430. TaskInfo runTask;
  1431. SysSetings settings;
  1432. using (RHDWContext db = new RHDWContext())
  1433. {
  1434. runTask = await db.TaskInfos.Where(p => p.TaskState == EnumTaskState.Running && p.PosType == EnumPosType.X2Dfo).FirstOrDefaultAsync();
  1435. if (runTask == null)
  1436. {
  1437. Serilog.Log.Warning($"接收到双星时频差带参定位(无星历)参数,由于任务没有运行中忽略本次定位!");
  1438. return Error<PosResDto>($"多模式融合定位平台没有启动双星时频差定位任务");
  1439. }
  1440. settings = await db.SysSetings.FirstOrDefaultAsync();
  1441. }
  1442. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime))
  1443. {
  1444. var xlInfoList = await XlCache.GetAllAsync();
  1445. var mainXl = xlInfoList.Where(w => w.SatCode == dto.MainCode);
  1446. var minTime = mainXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1447. var xlInfo1 = mainXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime).FirstOrDefault();
  1448. if (xlInfo1 == null)
  1449. {
  1450. Serilog.Log.Error($"未找到卫星[{dto.MainCode}]的双行根数星历");
  1451. return Error<PosResDto>($"未找到卫星[{dto.MainCode}]的双行根数星历");
  1452. }
  1453. var adjaXl = xlInfoList.Where(w => w.SatCode == dto.AdjaCode);
  1454. var minTime2 = adjaXl.Min(m => Math.Abs((m.TimeBJ - dto.SigTime).TotalSeconds));
  1455. var xlInfo2 = adjaXl.Where(w => Math.Abs((w.TimeBJ - dto.SigTime).TotalSeconds) == minTime2).FirstOrDefault();
  1456. if (xlInfo2 == null)
  1457. {
  1458. Serilog.Log.Error($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  1459. return Error<PosResDto>($"未找到卫星[{dto.AdjaCode}]的双行根数星历");
  1460. }
  1461. Serilog.Log.Information($"卫星{dto.MainCode}使用{xlInfo1.TwoLine}进行星历推算");
  1462. Serilog.Log.Information($"卫星{dto.AdjaCode}使用{xlInfo2.TwoLine}进行星历推算");
  1463. string url = string.Format("http://{0}:{1}/Api/Xl/Calc", IpHelper.GetLocalIp(), settings.HttpPort);
  1464. var XlCalcDto = new XlCalcDto() { tleStr = xlInfo1.TwoLine, dt = dto.SigTime };
  1465. var ephMain = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto);
  1466. if (ephMain.code != 200)
  1467. {
  1468. Serilog.Log.Error($"推算[{dto.MainCode}]的星历出错");
  1469. return Error<PosResDto>($"推算[{dto.MainCode}]的星历出错");
  1470. }
  1471. var XlCalcDto2 = new XlCalcDto() { tleStr = xlInfo2.TwoLine, dt = dto.SigTime };
  1472. var ephAdja = await HttpHelper.PostRequestAsync<SatEphDto>(url, XlCalcDto2);
  1473. if (ephAdja.code != 200)
  1474. {
  1475. Serilog.Log.Error($"推算[{dto.AdjaCode}]的星历出错");
  1476. return Error<PosResDto>($"推算[{dto.AdjaCode}]的星历出错");
  1477. }
  1478. var StationRes = db.StationRes.Add(new StationRes()
  1479. {
  1480. SatTxLon = dto.SatTxLon,
  1481. SatTxLat = dto.SatTxLat,
  1482. RefLon = dto.RefLon,
  1483. RefLat = dto.RefLat,
  1484. });
  1485. var cgRes = db.CgRes.Add(new CgRes()
  1486. {
  1487. SigTime = dto.SigTime,
  1488. Dto1 = dto.Dto,
  1489. Dfo1 = dto.Dfo,
  1490. Snr1 = dto.Snr,
  1491. YbMainDto = dto.YbMainDto,
  1492. YbAdja1Dto = dto.YbAdjaDto,
  1493. YbMainDfo = dto.YbMainDfo,
  1494. YbAdja1Dfo = dto.YbAdjaDfo,
  1495. TarFreqUp = dto.TarFreqUp,
  1496. TarFreqDown = dto.TarFreqDown,
  1497. RefFreqUp = dto.RefFreqUp,
  1498. RefFreqDown = dto.RefFreqDown,
  1499. StationResID = StationRes.ID,
  1500. MainCode = dto.MainCode,
  1501. Adja1Code = dto.AdjaCode,
  1502. MainX = ephMain.data.X,
  1503. MainY = ephMain.data.Y,
  1504. MainZ = ephMain.data.Z,
  1505. MainVx = ephMain.data.VX,
  1506. MainVy = ephMain.data.VY,
  1507. MainVz = ephMain.data.VZ,
  1508. Adja1X = ephAdja.data.X,
  1509. Adja1Y = ephAdja.data.Y,
  1510. Adja1Z = ephAdja.data.Z,
  1511. Adja1Vx = ephAdja.data.VX,
  1512. Adja1Vy = ephAdja.data.VY,
  1513. Adja1Vz = ephAdja.data.VZ,
  1514. });
  1515. var res = PosApi.X2_PosDtoDfo(cgRes, StationRes);
  1516. PosRes posRes = new PosRes()
  1517. {
  1518. SigTime = dto.SigTime,
  1519. TaskInfoID = runTask.ID,
  1520. CgResID = cgRes.ID,
  1521. TarName = string.IsNullOrWhiteSpace(dto.TarName) ? "未知目标" : dto.TarName,
  1522. TsName = dto.TsName,
  1523. PosLon = res[0],
  1524. PosLat = res[1],
  1525. MirrLon = res[3],
  1526. MirrLat = res[4],
  1527. PosResType = EnumPosResType.X2Dfo,
  1528. };
  1529. posRes = db.PosRes.Add(posRes);
  1530. await db.SaveChangesAsync();
  1531. PosObServer.Instance.Pub(posRes);
  1532. return Success(Map(posRes));
  1533. }
  1534. }
  1535. #endregion
  1536. private PosResDto Map(PosRes res)
  1537. {
  1538. return new PosResDto()
  1539. {
  1540. ID = res.ID,
  1541. SigTime = res.SigTime,
  1542. TaskInfoID = res.TaskInfoID,
  1543. TarName = string.IsNullOrWhiteSpace(res.TarName) ? "未知目标" : res.TarName,
  1544. PosLon = res.PosLon,
  1545. PosLat = res.PosLat,
  1546. MirrLon = res.MirrLon,
  1547. MirrLat = res.MirrLat,
  1548. PosResType = (EnumPosResTypeDto)((int)res.PosResType)
  1549. };
  1550. }
  1551. /// <summary>
  1552. /// 查询定位结果
  1553. /// </summary>
  1554. /// <param name="dto"></param>
  1555. /// <returns></returns>
  1556. /// <exception cref="Exception"></exception>
  1557. [HttpPost]
  1558. public async Task<AjaxResult<List<PosResDto>>> GetPosRes([FromBody] PosResQueryDto dto)
  1559. {
  1560. List<PosResDto> posList = new List<PosResDto>();
  1561. try
  1562. {
  1563. DateTime start = dto.BeginTime;
  1564. DateTime end = dto.EndTime;
  1565. if (!Directory.Exists("DbPart")) return Success(posList);
  1566. var yearDirs = Directory.EnumerateDirectories(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart")).OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name));//年目录,倒叙排列
  1567. foreach (var yearDir in yearDirs)
  1568. {
  1569. //每一天的db文件,倒序排列
  1570. var dayFiles = Directory.EnumerateFiles(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, yearDir), "*.db").OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name.Substring(0, 4)));
  1571. foreach (var dayFile in dayFiles)
  1572. {
  1573. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  1574. {
  1575. if (db.PosRes.Any(p => p.TaskInfoID == dto.TaskInfoID))
  1576. end = await db.PosRes.Where(p => p.TaskInfoID == dto.TaskInfoID).MaxAsync(p => p.SigTime);
  1577. }
  1578. if (end != DateTime.MinValue)
  1579. {
  1580. goto skip;
  1581. }
  1582. }
  1583. }
  1584. skip:
  1585. if (end == DateTime.MinValue)
  1586. {
  1587. return Success(posList);//没有数据不查询
  1588. }
  1589. if (end >= dto.EndTime)
  1590. {
  1591. end = dto.EndTime;
  1592. }
  1593. start = dto.BeginTime;
  1594. DateTime endDay = new DateTime(end.Year, end.Month, end.Day);
  1595. DateTime startDay = new DateTime(start.Year, start.Month, start.Day);
  1596. while (endDay >= startDay)
  1597. {
  1598. using (RHDWPartContext db = RHDWPartContext.GetContext(endDay))
  1599. {
  1600. var posRes = await db.PosRes
  1601. .Where(w => w.SigTime >= start && w.SigTime <= end && w.TaskInfoID == dto.TaskInfoID)
  1602. .OrderByDescending(o => o.SigTime).ToListAsync();
  1603. posList.AddRange(posRes.Select(m => Map(m)));
  1604. }
  1605. endDay = endDay.AddDays(-1);
  1606. }
  1607. return Success(posList);
  1608. }
  1609. catch (Exception ex)
  1610. {
  1611. string err = $"定位查询任务编号:{dto.TaskInfoID},{dto.BeginTime:yyyy-MM-dd HH:mm:ss}-{dto.EndTime:yyyy-MM-dd HH:mm:ss}异常:{ex.Message}";
  1612. Serilog.Log.Error(err);
  1613. return Error<List<PosResDto>>(err);
  1614. }
  1615. }
  1616. }
  1617. }