PosController.cs 77 KB

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