PosController.cs 77 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749
  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. if (!Directory.Exists("DbPart")) return Success(posList);
  1583. var yearDirs = Directory.EnumerateDirectories(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart")).OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name));//年目录,倒叙排列
  1584. foreach (var yearDir in yearDirs)
  1585. {
  1586. //每一天的db文件,倒序排列
  1587. var dayFiles = Directory.EnumerateFiles(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, yearDir), "*.db").OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name.Substring(0, 4)));
  1588. foreach (var dayFile in dayFiles)
  1589. {
  1590. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  1591. {
  1592. if (db.PosRes.Any(p => p.TaskInfoID == dto.TaskInfoID))
  1593. end = await db.PosRes.Where(p => p.TaskInfoID == dto.TaskInfoID).MaxAsync(p => p.SigTime);
  1594. }
  1595. if (end != DateTime.MinValue)
  1596. {
  1597. goto skip;
  1598. }
  1599. }
  1600. }
  1601. skip:
  1602. if (end == DateTime.MinValue)
  1603. {
  1604. return Success(posList);//没有数据不查询
  1605. }
  1606. if (end >= dto.EndTime)
  1607. {
  1608. end = dto.EndTime;
  1609. }
  1610. start = dto.BeginTime;
  1611. DateTime endDay = new DateTime(end.Year, end.Month, end.Day);
  1612. DateTime startDay = new DateTime(start.Year, start.Month, start.Day);
  1613. while (endDay >= startDay)
  1614. {
  1615. using (RHDWPartContext db = RHDWPartContext.GetContext(endDay))
  1616. {
  1617. var posRes = await db.PosRes
  1618. .Where(w => w.SigTime >= start && w.SigTime <= end && w.TaskInfoID == dto.TaskInfoID)
  1619. .OrderByDescending(o => o.SigTime).ToListAsync();
  1620. posList.AddRange(posRes.Select(m => Map(m)));
  1621. }
  1622. endDay = endDay.AddDays(-1);
  1623. }
  1624. return Success(posList);
  1625. }
  1626. catch (Exception ex)
  1627. {
  1628. string err = $"定位查询任务编号:{dto.TaskInfoID},{dto.BeginTime:yyyy-MM-dd HH:mm:ss}-{dto.EndTime:yyyy-MM-dd HH:mm:ss}异常:{ex.Message}";
  1629. Serilog.Log.Error(err);
  1630. return Error<List<PosResDto>>(err);
  1631. }
  1632. }
  1633. }
  1634. }