PosController.cs 75 KB

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