PosController.cs 83 KB

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