PosController.cs 111 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data.Entity;
  4. using System.Linq;
  5. using System.Net.Http;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8. using System.Web.Http;
  9. using Serilog;
  10. using XdCxRhDW.Dto;
  11. using XdCxRhDW.Repostory;
  12. using System.IO;
  13. using XdCxRhDW.Entity;
  14. using XdCxRhDW.Api;
  15. using XdCxRhDW.WebApi;
  16. using DPP_YH_Core.Extensions;
  17. using XdCxRhDW.App.Model;
  18. using System.Diagnostics;
  19. using System.Configuration;
  20. namespace XdCxRhDW.App.Controllers
  21. {
  22. /// <summary>
  23. /// 定位功能相关接口
  24. /// </summary>
  25. public class PosController : BaseController
  26. {
  27. #region 一星一地测向定位
  28. /// <summary>
  29. /// 一星一地测向带参定位(含星历)
  30. /// </summary>
  31. /// <param name="dto">定位参数</param>
  32. /// <returns></returns>
  33. [HttpPost]
  34. public async Task<AjaxResult<PosResDto>> PosX1D1Async(X1D1PosDto dto)
  35. {
  36. TaskInfo runTask;
  37. using (RHDWContext db = new RHDWContext())
  38. {
  39. if (dto.TaskID == null)
  40. {
  41. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  42. && p.PosType == EnumPosType.X1D1CX && p.TaskState == EnumTaskState.Running);
  43. if (runTask == null)
  44. {
  45. Serilog.Log.Warning($"接收到一星一地测向带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  46. return Error<PosResDto>($"多模式融合定位平台没有启动一星一地测向定位任务");
  47. }
  48. }
  49. else
  50. {
  51. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  52. if (runTask == null)
  53. {
  54. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  55. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  56. }
  57. }
  58. }
  59. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  60. {
  61. var StationRes = db.StationRes.Add(new StationRes()
  62. {
  63. SatTxLon = dto.SatTxLon,
  64. SatTxLat = dto.SatTxLat,
  65. CdbTxLon = dto.CdbTxLon,
  66. CdbTxLat = dto.CdbTxLat,
  67. CxLon = dto.CxLon,
  68. CxLat = dto.CxLat,
  69. RefLon = dto.RefLon,
  70. RefLat = dto.RefLat,
  71. });
  72. var ckRes = new CheckRes()
  73. {
  74. FileName = dto.CheckRes?.FileName,
  75. SmpStart = dto.CheckRes?.SmpStart,
  76. SmpCount = dto.CheckRes?.SmpCount,
  77. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  78. ModRate = dto.CheckRes?.ModRate,
  79. ModType = dto.CheckRes?.ModType,
  80. UserName = dto.CheckRes?.UserName,
  81. FfcHz = dto.CheckRes?.FfcHz,
  82. };
  83. db.CheckRes.Add(ckRes);
  84. var cgRes = db.CgRes.Add(new CgRes()
  85. {
  86. SigTime = dto.SigTime,
  87. DtoCdb = Math.Round(dto.XdDto, 10),
  88. DfoCdb = Math.Round(dto.XdDfo, 10),
  89. SnrCdb = Math.Round(dto.XdSnr, 1),
  90. YbMainDto = Math.Round(dto.MainYbDto, 10),
  91. StationResID = StationRes.ID,
  92. MainCode = dto.MainCode,
  93. TaskID = runTask.ID,
  94. MainX = dto.MainX,
  95. MainY = dto.MainY,
  96. MainZ = dto.MainZ,
  97. TarFreqUp = dto.FreqUp,
  98. TarFreqDown = dto.FreqDown,
  99. });
  100. var cxRes = db.CxRes.Add(new CxRes()
  101. {
  102. SigTime = dto.SigTime,
  103. Fx = dto.CxRes,
  104. });
  105. var res = PosApi.X1D1_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  106. PosRes posRes = new PosRes()
  107. {
  108. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  109. SigTime = cgRes.SigTime,
  110. TaskInfoID = runTask.ID,
  111. CxResID = cxRes.ID,
  112. CgResID = cgRes.ID,
  113. CheckResID = ckRes.ID,
  114. PosLon = res[0],
  115. PosLat = res[1],
  116. MirrLon = res[3],
  117. MirrLat = res[4],
  118. Confidence = (int)res[6],
  119. PosResType = EnumPosResType.X1D1CX,
  120. };
  121. posRes = db.PosRes.Add(posRes);
  122. await db.SaveChangesAsync();
  123. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  124. return Success(MapDto(posRes));
  125. }
  126. }
  127. /// <summary>
  128. /// 一星一地测向带参定位(无星历)
  129. /// </summary>
  130. /// <returns>返回定位结果ID</returns>
  131. [HttpPost]
  132. public async Task<AjaxResult<PosResDto>> PosX1D1NoXlAsync(X1D1NoXlPosDto dto)
  133. {
  134. TaskInfo runTask;
  135. using (RHDWContext db = new RHDWContext())
  136. {
  137. if (dto.TaskID == null)
  138. {
  139. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  140. && p.PosType == EnumPosType.X1D1CX && p.TaskState == EnumTaskState.Running);
  141. if (runTask == null)
  142. {
  143. Serilog.Log.Warning($"接收到一星一地测向带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  144. return Error<PosResDto>($"多模式融合定位平台没有启动一星一地测向定位任务");
  145. }
  146. }
  147. else
  148. {
  149. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  150. if (runTask == null)
  151. {
  152. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  153. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  154. }
  155. }
  156. }
  157. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  158. if (xl1 == null)
  159. {
  160. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  161. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  162. }
  163. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  164. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  165. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  166. if (ephMain.code != 200)
  167. {
  168. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  169. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  170. }
  171. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  172. {
  173. var StationRes = db.StationRes.Add(new StationRes()
  174. {
  175. SatTxLon = dto.SatTxLon,
  176. SatTxLat = dto.SatTxLat,
  177. CdbTxLon = dto.CdbTxLon,
  178. CdbTxLat = dto.CdbTxLat,
  179. CxLon = dto.CxLon,
  180. CxLat = dto.CxLat,
  181. RefLon = dto.RefLon,
  182. RefLat = dto.RefLat,
  183. });
  184. var ckRes = new CheckRes()
  185. {
  186. FileName = dto.CheckRes?.FileName,
  187. SmpStart = dto.CheckRes?.SmpStart,
  188. SmpCount = dto.CheckRes?.SmpCount,
  189. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  190. ModRate = dto.CheckRes?.ModRate,
  191. ModType = dto.CheckRes?.ModType,
  192. UserName = dto.CheckRes?.UserName,
  193. FfcHz = dto.CheckRes?.FfcHz,
  194. };
  195. db.CheckRes.Add(ckRes);
  196. var cgRes = db.CgRes.Add(new CgRes()
  197. {
  198. SigTime = dto.SigTime,
  199. DtoCdb = Math.Round(dto.XdDto, 10),
  200. DfoCdb = Math.Round(dto.XdDfo, 10),
  201. SnrCdb = Math.Round(dto.XdSnr, 1),
  202. YbMainDto = Math.Round(dto.MainYbDto, 10),
  203. StationResID = StationRes.ID,
  204. MainCode = dto.MainCode,
  205. MainXlTime = ephMain.data.TleTime,
  206. TaskID = runTask.ID,
  207. MainX = ephMain.data.X,
  208. MainY = ephMain.data.Y,
  209. MainZ = ephMain.data.Z,
  210. MainVx = ephMain.data.VX,
  211. MainVy = ephMain.data.VY,
  212. MainVz = ephMain.data.VZ,
  213. TarFreqUp = dto.FreqUp,
  214. TarFreqDown = dto.FreqDown,
  215. });
  216. var cxRes = db.CxRes.Add(new CxRes()
  217. {
  218. SigTime = dto.SigTime,
  219. Fx = dto.CxRes,
  220. });
  221. var res = PosApi.X1D1_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  222. PosRes posRes = new PosRes()
  223. {
  224. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  225. SigTime = dto.SigTime,
  226. TaskInfoID = runTask.ID,
  227. CgResID = cgRes.ID,
  228. CxResID = cxRes.ID,
  229. CheckResID = ckRes.ID,
  230. PosLon = res[0],
  231. PosLat = res[1],
  232. MirrLon = res[3],
  233. MirrLat = res[4],
  234. Confidence = (int)res[6],
  235. PosResType = EnumPosResType.X1D1CX,
  236. };
  237. posRes = db.PosRes.Add(posRes);
  238. await db.SaveChangesAsync();
  239. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  240. return Success(MapDto(posRes));
  241. }
  242. }
  243. #endregion
  244. #region 两星一地定位
  245. /// <summary>
  246. /// 两星一地带参定位(含星历)
  247. /// </summary>
  248. /// <param name="dto">定位参数</param>
  249. /// <returns></returns>
  250. [HttpPost]
  251. public async Task<AjaxResult<PosResDto>> PosX2D1Async(X2D1PosDto dto)
  252. {
  253. TaskInfo runTask;
  254. using (RHDWContext db = new RHDWContext())
  255. {
  256. if (dto.TaskID == null)
  257. {
  258. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  259. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  260. if (runTask == null)
  261. {
  262. Serilog.Log.Warning($"接收到两星一地带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  263. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  264. }
  265. }
  266. else
  267. {
  268. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  269. if (runTask == null)
  270. {
  271. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  272. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  273. }
  274. }
  275. }
  276. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  277. {
  278. var StationRes = db.StationRes.Add(new StationRes()
  279. {
  280. SatTxLon = dto.SatTxLon,
  281. SatTxLat = dto.SatTxLat,
  282. CdbTxLon = dto.CdbTxLon,
  283. CdbTxLat = dto.CdbTxLat,
  284. RefLon = dto.RefLon,
  285. RefLat = dto.RefLat,
  286. });
  287. var ckRes = new CheckRes()
  288. {
  289. FileName = dto.CheckRes?.FileName,
  290. SmpStart = dto.CheckRes?.SmpStart,
  291. SmpCount = dto.CheckRes?.SmpCount,
  292. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  293. ModRate = dto.CheckRes?.ModRate,
  294. ModType = dto.CheckRes?.ModType,
  295. UserName = dto.CheckRes?.UserName,
  296. FfcHz = dto.CheckRes?.FfcHz,
  297. };
  298. ckRes = db.CheckRes.Add(ckRes);
  299. var cgRes = db.CgRes.Add(new CgRes()
  300. {
  301. SigTime = dto.SigTime,
  302. Dto1 = Math.Round(dto.SxDto, 10),
  303. Dfo1 = Math.Round(dto.SxDfo, 10),
  304. Snr1 = Math.Round(dto.SxSnr, 1),
  305. DtoCdb = Math.Round(dto.XdDto, 10),
  306. DfoCdb = Math.Round(dto.XdDfo, 10),
  307. SnrCdb = Math.Round(dto.XdSnr, 1),
  308. YbMainDto = Math.Round(dto.MainYbDto, 10),
  309. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  310. StationResID = StationRes.ID,
  311. MainCode = dto.MainCode,
  312. Adja1Code = dto.AdjaCode,
  313. TaskID = runTask.ID,
  314. MainX = dto.MainX,
  315. MainY = dto.MainY,
  316. MainZ = dto.MainZ,
  317. Adja1X = dto.AdjaX,
  318. Adja1Y = dto.AdjaY,
  319. Adja1Z = dto.AdjaZ,
  320. MainVx = dto.MainVX,
  321. MainVy = dto.MainVY,
  322. MainVz = dto.MainVZ,
  323. Adja1Vx = dto.AdjaVX,
  324. Adja1Vy = dto.AdjaVY,
  325. Adja1Vz = dto.AdjaVZ,
  326. TarFreqUp = dto.FreqUp,
  327. TarFreqDown = dto.FreqDown,
  328. });
  329. var res = PosApi.X2D1_Pos(cgRes, StationRes, dto.CalcConfidence);
  330. PosRes posRes = new PosRes()
  331. {
  332. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  333. SigTime = cgRes.SigTime,
  334. TaskInfoID = runTask.ID,
  335. CgResID = cgRes.ID,
  336. CheckResID = ckRes.ID,
  337. PosLon = res[0],
  338. PosLat = res[1],
  339. MirrLon = res[3],
  340. MirrLat = res[4],
  341. Confidence = (int)res[6],
  342. PosResType = EnumPosResType.X2D1,
  343. };
  344. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  345. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  346. if (dto.CalcConfidence)
  347. {
  348. }
  349. posRes = db.PosRes.Add(posRes);
  350. await db.SaveChangesAsync();
  351. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  352. return Success(MapDto(posRes));
  353. }
  354. }
  355. /// <summary>
  356. /// 两星一地带参定位(无星历)
  357. /// </summary>
  358. /// <returns>返回定位结果ID</returns>
  359. [HttpPost]
  360. public async Task<AjaxResult<PosResDto>> PosX2D1NoXlAsync(X2D1NoXlPosDto dto)
  361. {
  362. TaskInfo runTask;
  363. using (RHDWContext db = new RHDWContext())
  364. {
  365. if (dto.TaskID == null)
  366. {
  367. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  368. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  369. if (runTask == null)
  370. {
  371. Serilog.Log.Warning($"接收到两星一地带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  372. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  373. }
  374. }
  375. else
  376. {
  377. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  378. if (runTask == null)
  379. {
  380. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  381. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  382. }
  383. }
  384. }
  385. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  386. if (xl1 == null)
  387. {
  388. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  389. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  390. }
  391. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  392. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  393. if (xl2 == null)
  394. {
  395. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  396. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  397. }
  398. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  399. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  400. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  401. if (ephMain.code != 200)
  402. {
  403. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  404. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  405. }
  406. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  407. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  408. if (ephAdja.code != 200)
  409. {
  410. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  411. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  412. }
  413. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  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. RefLon = dto.RefLon,
  422. RefLat = dto.RefLat,
  423. });
  424. var ckRes = new CheckRes()
  425. {
  426. FileName = dto.CheckRes?.FileName,
  427. SmpStart = dto.CheckRes?.SmpStart,
  428. SmpCount = dto.CheckRes?.SmpCount,
  429. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  430. ModRate = dto.CheckRes?.ModRate,
  431. ModType = dto.CheckRes?.ModType,
  432. UserName = dto.CheckRes?.UserName,
  433. FfcHz = dto.CheckRes?.FfcHz,
  434. };
  435. db.CheckRes.Add(ckRes);
  436. var cgRes = db.CgRes.Add(new CgRes()
  437. {
  438. SigTime = dto.SigTime,
  439. Dto1 = Math.Round(dto.SxDto, 10),
  440. Dfo1 = Math.Round(dto.SxDfo, 10),
  441. Snr1 = Math.Round(dto.SxSnr, 1),
  442. DtoCdb = Math.Round(dto.XdDto, 10),
  443. DfoCdb = Math.Round(dto.XdDfo, 10),
  444. SnrCdb = Math.Round(dto.XdSnr, 1),
  445. YbMainDto = Math.Round(dto.MainYbDto, 10),
  446. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  447. StationResID = StationRes.ID,
  448. MainCode = dto.MainCode,
  449. MainXlTime = ephMain.data.TleTime,
  450. Adja1Code = dto.AdjaCode,
  451. Adja1XlTime = ephAdja.data.TleTime,
  452. TaskID = runTask.ID,
  453. MainX = ephMain.data.X,
  454. MainY = ephMain.data.Y,
  455. MainZ = ephMain.data.Z,
  456. MainVx = ephMain.data.VX,
  457. MainVy = ephMain.data.VY,
  458. MainVz = ephMain.data.VZ,
  459. Adja1Vx = ephAdja.data.VX,
  460. Adja1Vy = ephAdja.data.VY,
  461. Adja1Vz = ephAdja.data.VZ,
  462. Adja1X = ephAdja.data.X,
  463. Adja1Y = ephAdja.data.Y,
  464. Adja1Z = ephAdja.data.Z,
  465. TarFreqUp = dto.FreqUp,
  466. TarFreqDown = dto.FreqDown,
  467. });
  468. var res = PosApi.X2D1_Pos(cgRes, StationRes, dto.CalcConfidence);
  469. PosRes posRes = new PosRes()
  470. {
  471. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  472. SigTime = dto.SigTime,
  473. TaskInfoID = runTask.ID,
  474. CgResID = cgRes.ID,
  475. CheckResID = ckRes.ID,
  476. PosLon = res[0],
  477. PosLat = res[1],
  478. MirrLon = res[3],
  479. MirrLat = res[4],
  480. Confidence = (int)res[6],
  481. PosResType = EnumPosResType.X2D1,
  482. };
  483. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  484. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  485. posRes = db.PosRes.Add(posRes);
  486. await db.SaveChangesAsync();
  487. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  488. return Success(MapDto(posRes));
  489. }
  490. }
  491. /// <summary>
  492. /// 两星一地无参定位(含星历)
  493. /// </summary>
  494. /// <param name="dto">定位参数</param>
  495. /// <returns></returns>
  496. [HttpPost]
  497. public async Task<AjaxResult<PosResDto>> PosX2D1NoParAsync(X2D1NoParPosDto dto)
  498. {
  499. TaskInfo runTask;
  500. using (RHDWContext db = new RHDWContext())
  501. {
  502. if (dto.TaskID == null)
  503. {
  504. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  505. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  506. if (runTask == null)
  507. {
  508. Serilog.Log.Warning($"接收到两星一地无参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  509. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  510. }
  511. }
  512. else
  513. {
  514. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  515. if (runTask == null)
  516. {
  517. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  518. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  519. }
  520. }
  521. }
  522. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  523. {
  524. var StationRes = db.StationRes.Add(new StationRes()
  525. {
  526. SatTxLon = dto.SatTxLon,
  527. SatTxLat = dto.SatTxLat,
  528. CdbTxLon = dto.CdbTxLon,
  529. CdbTxLat = dto.CdbTxLat,
  530. });
  531. var ckRes = new CheckRes()
  532. {
  533. FileName = dto.CheckRes?.FileName,
  534. SmpStart = dto.CheckRes?.SmpStart,
  535. SmpCount = dto.CheckRes?.SmpCount,
  536. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  537. ModRate = dto.CheckRes?.ModRate,
  538. ModType = dto.CheckRes?.ModType,
  539. UserName = dto.CheckRes?.UserName,
  540. FfcHz = dto.CheckRes?.FfcHz,
  541. };
  542. db.CheckRes.Add(ckRes);
  543. var cgRes = db.CgRes.Add(new CgRes()
  544. {
  545. SigTime = dto.SigTime,
  546. Dto1 = Math.Round(dto.SxDto, 10),
  547. Dfo1 = Math.Round(dto.SxDfo, 10),
  548. Snr1 = Math.Round(dto.SxSnr, 1),
  549. DtoCdb = Math.Round(dto.XdDto, 10),
  550. DfoCdb = Math.Round(dto.XdDfo, 10),
  551. SnrCdb = Math.Round(dto.XdSnr, 1),
  552. StationResID = StationRes.ID,
  553. MainCode = dto.MainCode,
  554. Adja1Code = dto.AdjaCode,
  555. TaskID = runTask.ID,
  556. MainX = dto.MainX,
  557. MainY = dto.MainY,
  558. MainZ = dto.MainZ,
  559. Adja1X = dto.AdjaX,
  560. Adja1Y = dto.AdjaY,
  561. Adja1Z = dto.AdjaZ,
  562. MainVx = dto.MainVX,
  563. MainVy = dto.MainVY,
  564. MainVz = dto.MainVZ,
  565. Adja1Vx = dto.AdjaVX,
  566. Adja1Vy = dto.AdjaVY,
  567. Adja1Vz = dto.AdjaVZ,
  568. TarFreqUp = dto.FreqUp,
  569. TarFreqDown = dto.FreqDown,
  570. });
  571. double[] res;
  572. if (ConfigurationManager.AppSettings["UseNewPosX2D1"] != null
  573. && ConfigurationManager.AppSettings["UseNewPosX2D1"].ToLower() != "false"
  574. && ConfigurationManager.AppSettings["UseNewPosX2D1"].ToLower() != "0")
  575. {
  576. res = PosApi.X2D1_PosNoRef_ZL(cgRes, StationRes);
  577. }
  578. else
  579. {
  580. res = PosApi.X2D1_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  581. }
  582. PosRes posRes = new PosRes()
  583. {
  584. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  585. SigTime = cgRes.SigTime,
  586. TaskInfoID = runTask.ID,
  587. CgResID = cgRes.ID,
  588. CheckResID = ckRes.ID,
  589. PosLon = res[0],
  590. PosLat = res[1],
  591. MirrLon = res[3],
  592. MirrLat = res[4],
  593. Confidence = (int)res[6],
  594. PosResType = EnumPosResType.X2D1NoRef,
  595. };
  596. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  597. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  598. posRes = db.PosRes.Add(posRes);
  599. await db.SaveChangesAsync();
  600. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  601. return Success(MapDto(posRes));
  602. }
  603. }
  604. /// <summary>
  605. /// 两星一地无参定位(无星历)
  606. /// </summary>
  607. /// <returns>返回定位结果ID</returns>
  608. [HttpPost]
  609. public async Task<AjaxResult<PosResDto>> PosX2D1NoXlNoParAsync(X2D1NoXlNoParlPosDto dto)
  610. {
  611. TaskInfo runTask;
  612. using (RHDWContext db = new RHDWContext())
  613. {
  614. if (dto.TaskID == null)
  615. {
  616. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  617. && p.PosType == EnumPosType.X2D1 && p.TaskState == EnumTaskState.Running);
  618. if (runTask == null)
  619. {
  620. Serilog.Log.Warning($"接收到两星一地无参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  621. return Error<PosResDto>($"多模式融合定位平台没有启动两星一地定位任务");
  622. }
  623. }
  624. else
  625. {
  626. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  627. if (runTask == null)
  628. {
  629. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  630. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  631. }
  632. }
  633. }
  634. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  635. if (xl1 == null)
  636. {
  637. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  638. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  639. }
  640. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  641. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  642. if (xl2 == null)
  643. {
  644. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  645. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  646. }
  647. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  648. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  649. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  650. if (ephMain.code != 200)
  651. {
  652. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  653. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  654. }
  655. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  656. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  657. if (ephAdja.code != 200)
  658. {
  659. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  660. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  661. }
  662. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  663. {
  664. var StationRes = db.StationRes.Add(new StationRes()
  665. {
  666. SatTxLon = dto.SatTxLon,
  667. SatTxLat = dto.SatTxLat,
  668. CdbTxLon = dto.CdbTxLon,
  669. CdbTxLat = dto.CdbTxLat,
  670. });
  671. var ckRes = new CheckRes()
  672. {
  673. FileName = dto.CheckRes?.FileName,
  674. SmpStart = dto.CheckRes?.SmpStart,
  675. SmpCount = dto.CheckRes?.SmpCount,
  676. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  677. ModRate = dto.CheckRes?.ModRate,
  678. ModType = dto.CheckRes?.ModType,
  679. UserName = dto.CheckRes?.UserName,
  680. FfcHz = dto.CheckRes?.FfcHz,
  681. };
  682. db.CheckRes.Add(ckRes);
  683. var cgRes = db.CgRes.Add(new CgRes()
  684. {
  685. SigTime = dto.SigTime,
  686. Dto1 = Math.Round(dto.SxDto, 10),
  687. Dfo1 = Math.Round(dto.SxDfo, 10),
  688. Snr1 = Math.Round(dto.SxSnr, 1),
  689. DtoCdb = Math.Round(dto.XdDto, 10),
  690. DfoCdb = Math.Round(dto.XdDfo, 10),
  691. SnrCdb = Math.Round(dto.XdSnr, 1),
  692. StationResID = StationRes.ID,
  693. MainCode = dto.MainCode,
  694. Adja1Code = dto.AdjaCode,
  695. MainXlTime = ephMain.data.TleTime,
  696. Adja1XlTime = ephAdja.data.TleTime,
  697. TaskID = runTask.ID,
  698. MainX = ephMain.data.X,
  699. MainY = ephMain.data.Y,
  700. MainZ = ephMain.data.Z,
  701. Adja1X = ephAdja.data.X,
  702. Adja1Y = ephAdja.data.Y,
  703. Adja1Z = ephAdja.data.Z,
  704. MainVx = ephMain.data.VX,
  705. MainVy = ephMain.data.VY,
  706. MainVz = ephMain.data.VZ,
  707. Adja1Vx = ephAdja.data.VX,
  708. Adja1Vy = ephAdja.data.VY,
  709. Adja1Vz = ephAdja.data.VZ,
  710. TarFreqUp = dto.FreqUp,
  711. TarFreqDown = dto.FreqDown,
  712. });
  713. double[] res;
  714. if (ConfigurationManager.AppSettings["UseNewPosX2D1"] != null
  715. && ConfigurationManager.AppSettings["UseNewPosX2D1"].ToLower() != "false"
  716. && ConfigurationManager.AppSettings["UseNewPosX2D1"].ToLower() != "0")
  717. {
  718. res = PosApi.X2D1_PosNoRef_ZL(cgRes, StationRes);
  719. }
  720. else
  721. {
  722. res = PosApi.X2D1_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  723. }
  724. PosRes posRes = new PosRes()
  725. {
  726. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  727. SigTime = dto.SigTime,
  728. TaskInfoID = runTask.ID,
  729. CgResID = cgRes.ID,
  730. CheckResID = ckRes.ID,
  731. PosLon = res[0],
  732. PosLat = res[1],
  733. MirrLon = res[3],
  734. MirrLat = res[4],
  735. Confidence = (int)res[6],
  736. PosResType = EnumPosResType.X2D1NoRef,
  737. };
  738. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  739. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  740. posRes = db.PosRes.Add(posRes);
  741. await db.SaveChangesAsync();
  742. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  743. return Success(MapDto(posRes));
  744. }
  745. }
  746. #endregion
  747. #region 融合定位
  748. /// <summary>
  749. /// 融合带参定位(含星历)
  750. /// </summary>
  751. /// <param name="dto">定位参数</param>
  752. /// <returns></returns>
  753. [HttpPost]
  754. public async Task<AjaxResult<PosResDto>> PosRhAsync(RHPosDto dto)
  755. {
  756. TaskInfo runTask;
  757. using (RHDWContext db = new RHDWContext())
  758. {
  759. if (dto.TaskID == null)
  760. {
  761. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  762. && p.PosType == EnumPosType.RH && p.TaskState == EnumTaskState.Running);
  763. if (runTask == null)
  764. {
  765. Serilog.Log.Warning($"接收到融合带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  766. return Error<PosResDto>($"多模式融合定位平台没有启动融合定位任务");
  767. }
  768. }
  769. else
  770. {
  771. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  772. if (runTask == null)
  773. {
  774. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  775. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  776. }
  777. }
  778. }
  779. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  780. {
  781. var StationRes = db.StationRes.Add(new StationRes()
  782. {
  783. SatTxLon = dto.SatTxLon,
  784. SatTxLat = dto.SatTxLat,
  785. CdbTxLon = dto.CdbTxLon,
  786. CdbTxLat = dto.CdbTxLat,
  787. CxLon = dto.CxLon,
  788. CxLat = dto.CxLat,
  789. RefLon = dto.RefLon,
  790. RefLat = dto.RefLat,
  791. });
  792. var ckRes = new CheckRes()
  793. {
  794. FileName = dto.CheckRes?.FileName,
  795. SmpStart = dto.CheckRes?.SmpStart,
  796. SmpCount = dto.CheckRes?.SmpCount,
  797. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  798. ModRate = dto.CheckRes?.ModRate,
  799. ModType = dto.CheckRes?.ModType,
  800. UserName = dto.CheckRes?.UserName,
  801. FfcHz = dto.CheckRes?.FfcHz,
  802. };
  803. db.CheckRes.Add(ckRes);
  804. var cgRes = db.CgRes.Add(new CgRes()
  805. {
  806. SigTime = dto.SigTime,
  807. Dto1 = Math.Round(dto.SxDto, 10),
  808. Dfo1 = Math.Round(dto.SxDfo, 10),
  809. Snr1 = Math.Round(dto.SxSnr, 1),
  810. DtoCdb = Math.Round(dto.XdDto, 10),
  811. DfoCdb = Math.Round(dto.XdDfo, 10),
  812. SnrCdb = Math.Round(dto.XdSnr, 1),
  813. YbMainDto = Math.Round(dto.MainYbDto, 10),
  814. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  815. StationResID = StationRes.ID,
  816. MainCode = dto.MainCode,
  817. Adja1Code = dto.AdjaCode,
  818. TaskID = runTask.ID,
  819. MainX = dto.MainX,
  820. MainY = dto.MainY,
  821. MainZ = dto.MainZ,
  822. Adja1X = dto.AdjaX,
  823. Adja1Y = dto.AdjaY,
  824. Adja1Z = dto.AdjaZ,
  825. TarFreqUp = dto.FreqUp,
  826. TarFreqDown = dto.FreqDown,
  827. });
  828. var cxRes = db.CxRes.Add(new CxRes()
  829. {
  830. SigTime = dto.SigTime,
  831. Fx = dto.CxRes,
  832. });
  833. var res = PosApi.RH_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  834. PosRes posRes = new PosRes()
  835. {
  836. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  837. SigTime = cgRes.SigTime,
  838. TaskInfoID = runTask.ID,
  839. CxResID = cxRes.ID,
  840. CgResID = cgRes.ID,
  841. CheckResID = ckRes.ID,
  842. PosLon = res[0],
  843. PosLat = res[1],
  844. MirrLon = res[3],
  845. MirrLat = res[4],
  846. Confidence = (int)res[6],
  847. PosResType = EnumPosResType.RH,
  848. };
  849. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  850. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  851. posRes = db.PosRes.Add(posRes);
  852. await db.SaveChangesAsync();
  853. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  854. return Success(MapDto(posRes));
  855. }
  856. }
  857. /// <summary>
  858. /// 融合带参定位(无星历)
  859. /// </summary>
  860. /// <returns>返回定位结果ID</returns>
  861. [HttpPost]
  862. public async Task<AjaxResult<PosResDto>> PosRhNoXlAsync(RHNoXlPosDto dto)
  863. {
  864. TaskInfo runTask;
  865. using (RHDWContext db = new RHDWContext())
  866. {
  867. if (dto.TaskID == null)
  868. {
  869. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  870. && p.PosType == EnumPosType.RH && p.TaskState == EnumTaskState.Running);
  871. if (runTask == null)
  872. {
  873. Serilog.Log.Warning($"接收到融合带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  874. return Error<PosResDto>($"多模式融合定位平台没有启动融合定位任务");
  875. }
  876. }
  877. else
  878. {
  879. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  880. if (runTask == null)
  881. {
  882. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  883. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  884. }
  885. }
  886. }
  887. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  888. if (xl1 == null)
  889. {
  890. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  891. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  892. }
  893. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  894. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  895. if (xl2 == null)
  896. {
  897. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  898. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  899. }
  900. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  901. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  902. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  903. if (ephMain.code != 200)
  904. {
  905. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  906. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  907. }
  908. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  909. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  910. if (ephAdja.code != 200)
  911. {
  912. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  913. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  914. }
  915. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  916. {
  917. var StationRes = db.StationRes.Add(new StationRes()
  918. {
  919. SatTxLon = dto.SatTxLon,
  920. SatTxLat = dto.SatTxLat,
  921. CdbTxLon = dto.CdbTxLon,
  922. CdbTxLat = dto.CdbTxLat,
  923. CxLon = dto.CxLon,
  924. CxLat = dto.CxLat,
  925. RefLon = dto.RefLon,
  926. RefLat = dto.RefLat,
  927. });
  928. var ckRes = new CheckRes()
  929. {
  930. FileName = dto.CheckRes?.FileName,
  931. SmpStart = dto.CheckRes?.SmpStart,
  932. SmpCount = dto.CheckRes?.SmpCount,
  933. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  934. ModRate = dto.CheckRes?.ModRate,
  935. ModType = dto.CheckRes?.ModType,
  936. UserName = dto.CheckRes?.UserName,
  937. FfcHz = dto.CheckRes?.FfcHz,
  938. };
  939. db.CheckRes.Add(ckRes);
  940. var cgRes = db.CgRes.Add(new CgRes()
  941. {
  942. SigTime = dto.SigTime,
  943. Dto1 = Math.Round(dto.SxDto, 10),
  944. Dfo1 = Math.Round(dto.SxDfo, 10),
  945. Snr1 = Math.Round(dto.SxSnr, 1),
  946. DtoCdb = Math.Round(dto.XdDto, 10),
  947. DfoCdb = Math.Round(dto.XdDfo, 10),
  948. SnrCdb = Math.Round(dto.XdSnr, 1),
  949. YbMainDto = Math.Round(dto.MainYbDto, 10),
  950. YbAdja1Dto = Math.Round(dto.AdjaYbDto, 10),
  951. StationResID = StationRes.ID,
  952. MainCode = dto.MainCode,
  953. Adja1Code = dto.AdjaCode,
  954. MainXlTime = ephMain.data.TleTime,
  955. Adja1XlTime = ephAdja.data.TleTime,
  956. TaskID = runTask.ID,
  957. MainX = ephMain.data.X,
  958. MainY = ephMain.data.Y,
  959. MainZ = ephMain.data.Z,
  960. MainVx = ephMain.data.VX,
  961. MainVy = ephMain.data.VY,
  962. MainVz = ephMain.data.VZ,
  963. Adja1X = ephAdja.data.X,
  964. Adja1Y = ephAdja.data.Y,
  965. Adja1Z = ephAdja.data.Z,
  966. Adja1Vx = ephAdja.data.VX,
  967. Adja1Vy = ephAdja.data.VY,
  968. Adja1Vz = ephAdja.data.VZ,
  969. TarFreqUp = dto.FreqUp,
  970. TarFreqDown = dto.FreqDown,
  971. });
  972. var cxRes = db.CxRes.Add(new CxRes()
  973. {
  974. SigTime = dto.SigTime,
  975. Fx = dto.CxRes,
  976. });
  977. var res = PosApi.RH_Pos(cgRes, StationRes, cxRes, dto.CalcConfidence);
  978. PosRes posRes = new PosRes()
  979. {
  980. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  981. SigTime = cgRes.SigTime,
  982. TaskInfoID = runTask.ID,
  983. CxResID = cxRes.ID,
  984. CgResID = cgRes.ID,
  985. CheckResID = ckRes.ID,
  986. PosLon = res[0],
  987. PosLat = res[1],
  988. MirrLon = res[3],
  989. MirrLat = res[4],
  990. Confidence = (int)res[6],
  991. PosResType = EnumPosResType.RH,
  992. };
  993. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  994. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  995. posRes = db.PosRes.Add(posRes);
  996. await db.SaveChangesAsync();
  997. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  998. return Success(MapDto(posRes));
  999. }
  1000. }
  1001. #endregion
  1002. #region 三星双时差定位
  1003. /// <summary>
  1004. /// 三星双时差带参定位(含星历)
  1005. /// </summary>
  1006. /// <param name="dto">定位参数</param>
  1007. /// <returns></returns>
  1008. [HttpPost]
  1009. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoAsync(X3TwoDtoPosDto dto)
  1010. {
  1011. TaskInfo runTask;
  1012. using (RHDWContext db = new RHDWContext())
  1013. {
  1014. if (dto.TaskID == null)
  1015. {
  1016. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1017. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1018. if (runTask == null)
  1019. {
  1020. Serilog.Log.Warning($"接收到三星双时差带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1021. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1022. }
  1023. }
  1024. else
  1025. {
  1026. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1027. if (runTask == null)
  1028. {
  1029. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1030. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1031. }
  1032. }
  1033. }
  1034. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1035. {
  1036. var StationRes = db.StationRes.Add(new StationRes()
  1037. {
  1038. SatTxLon = dto.SatTxLon,
  1039. SatTxLat = dto.SatTxLat,
  1040. RefLon = dto.RefLon,
  1041. RefLat = dto.RefLat,
  1042. });
  1043. var ckRes = new CheckRes()
  1044. {
  1045. FileName = dto.CheckRes?.FileName,
  1046. SmpStart = dto.CheckRes?.SmpStart,
  1047. SmpCount = dto.CheckRes?.SmpCount,
  1048. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1049. ModRate = dto.CheckRes?.ModRate,
  1050. ModType = dto.CheckRes?.ModType,
  1051. UserName = dto.CheckRes?.UserName,
  1052. FfcHz = dto.CheckRes?.FfcHz,
  1053. };
  1054. db.CheckRes.Add(ckRes);
  1055. var cgRes = db.CgRes.Add(new CgRes()
  1056. {
  1057. SigTime = dto.SigTime,
  1058. Dto1 = Math.Round(dto.Dto1, 10),
  1059. Dfo1 = Math.Round(dto.Dfo1, 10),
  1060. Snr1 = Math.Round(dto.Snr1, 1),
  1061. Dto2 = Math.Round(dto.Dto2, 10),
  1062. Dfo2 = Math.Round(dto.Dfo2, 10),
  1063. Snr2 = Math.Round(dto.Snr2, 1),
  1064. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1065. YbAdja1Dto = Math.Round(dto.YbAdja1Dto, 10),
  1066. YbAdja2Dto = Math.Round(dto.YbAdja2Dto, 10),
  1067. StationResID = StationRes.ID,
  1068. MainCode = dto.MainCode,
  1069. Adja1Code = dto.Adja1Code,
  1070. Adja2Code = dto.Adja2Code,
  1071. TaskID = runTask.ID,
  1072. MainX = dto.MainX,
  1073. MainY = dto.MainY,
  1074. MainZ = dto.MainZ,
  1075. MainVx = dto.MainVX,
  1076. MainVy = dto.MainVY,
  1077. MainVz = dto.MainVZ,
  1078. Adja1X = dto.Adja1X,
  1079. Adja1Y = dto.Adja1Y,
  1080. Adja1Z = dto.Adja1Z,
  1081. Adja1Vx = dto.Adja1VX,
  1082. Adja1Vy = dto.Adja1VY,
  1083. Adja1Vz = dto.Adja1VZ,
  1084. Adja2X = dto.Adja2X,
  1085. Adja2Y = dto.Adja2Y,
  1086. Adja2Z = dto.Adja2Z,
  1087. Adja2Vx = dto.Adja2VX,
  1088. Adja2Vy = dto.Adja2VY,
  1089. Adja2Vz = dto.Adja2VZ,
  1090. TarFreqUp = dto.FreqUp,
  1091. TarFreqDown = dto.FreqDown,
  1092. });
  1093. var res = PosApi.X3_Pos(cgRes, StationRes, dto.CalcConfidence);
  1094. PosRes posRes = new PosRes()
  1095. {
  1096. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1097. SigTime = cgRes.SigTime,
  1098. TaskInfoID = runTask.ID,
  1099. CgResID = cgRes.ID,
  1100. CheckResID = ckRes.ID,
  1101. PosLon = res[0],
  1102. PosLat = res[1],
  1103. MirrLon = res[3],
  1104. MirrLat = res[4],
  1105. Confidence = (int)res[6],
  1106. PosResType = EnumPosResType.X3,
  1107. };
  1108. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1109. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1110. posRes = db.PosRes.Add(posRes);
  1111. await db.SaveChangesAsync();
  1112. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1113. return Success(MapDto(posRes));
  1114. }
  1115. }
  1116. /// <summary>
  1117. /// 三星双时差带参定位(无星历)
  1118. /// </summary>
  1119. /// <returns>返回定位结果ID</returns>
  1120. [HttpPost]
  1121. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoXlAsync(X3TwoDtoNoXlPosDto dto)
  1122. {
  1123. TaskInfo runTask;
  1124. using (RHDWContext db = new RHDWContext())
  1125. {
  1126. if (dto.TaskID == null)
  1127. {
  1128. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1129. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1130. if (runTask == null)
  1131. {
  1132. Serilog.Log.Warning($"接收到三星双时差带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1133. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1134. }
  1135. }
  1136. else
  1137. {
  1138. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1139. if (runTask == null)
  1140. {
  1141. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1142. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1143. }
  1144. }
  1145. }
  1146. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1147. if (xl1 == null)
  1148. {
  1149. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1150. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1151. }
  1152. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1153. var xl2 = await XlRepository.GetLatestAsync(dto.Adja1Code, dto.SigTime);
  1154. if (xl2 == null)
  1155. {
  1156. Serilog.Log.Error($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1157. return Error<PosResDto>($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1158. }
  1159. Serilog.Log.Information($"卫星{dto.Adja1Code}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1160. var xl3 = await XlRepository.GetLatestAsync(dto.Adja2Code, dto.SigTime);
  1161. if (xl3 == null)
  1162. {
  1163. Serilog.Log.Error($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1164. return Error<PosResDto>($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1165. }
  1166. Serilog.Log.Information($"卫星{dto.Adja2Code}使用发布时刻为{xl3.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1167. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1168. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1169. if (ephMain.code != 200)
  1170. {
  1171. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1172. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1173. }
  1174. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1175. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1176. if (ephAdja1.code != 200)
  1177. {
  1178. Serilog.Log.Error($"推算卫星{dto.Adja1Code}的ECEF星历出错.{ephAdja1.msg}");
  1179. return Error<PosResDto>($"推算卫星{dto.Adja1Code}的ECEF星历出错");
  1180. }
  1181. var XlCalcDto3 = new XlCalcDto() { tleStr = xl3.TwoLine, SigTime = dto.SigTime };
  1182. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto3);
  1183. if (ephAdja2.code != 200)
  1184. {
  1185. Serilog.Log.Error($"推算卫星{dto.Adja2Code}的ECEF星历出错.{ephAdja2.msg}");
  1186. return Error<PosResDto>($"推算卫星{dto.Adja2Code}的ECEF星历出错");
  1187. }
  1188. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1189. {
  1190. var StationRes = db.StationRes.Add(new StationRes()
  1191. {
  1192. SatTxLon = dto.SatTxLon,
  1193. SatTxLat = dto.SatTxLat,
  1194. RefLon = dto.RefLon,
  1195. RefLat = dto.RefLat,
  1196. });
  1197. var ckRes = new CheckRes()
  1198. {
  1199. FileName = dto.CheckRes?.FileName,
  1200. SmpStart = dto.CheckRes?.SmpStart,
  1201. SmpCount = dto.CheckRes?.SmpCount,
  1202. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1203. ModRate = dto.CheckRes?.ModRate,
  1204. ModType = dto.CheckRes?.ModType,
  1205. UserName = dto.CheckRes?.UserName,
  1206. FfcHz = dto.CheckRes?.FfcHz,
  1207. };
  1208. db.CheckRes.Add(ckRes);
  1209. var cgRes = db.CgRes.Add(new CgRes()
  1210. {
  1211. SigTime = dto.SigTime,
  1212. Dto1 = Math.Round(dto.Dto1, 10),
  1213. Dfo1 = Math.Round(dto.Dfo1, 10),
  1214. Snr1 = Math.Round(dto.Snr1, 1),
  1215. Dto2 = Math.Round(dto.Dto2, 10),
  1216. Dfo2 = Math.Round(dto.Dfo2, 10),
  1217. Snr2 = Math.Round(dto.Snr2, 1),
  1218. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1219. YbAdja1Dto = Math.Round(dto.YbAdja1Dto, 10),
  1220. YbAdja2Dto = Math.Round(dto.YbAdja2Dto, 10),
  1221. StationResID = StationRes.ID,
  1222. MainCode = dto.MainCode,
  1223. Adja1Code = dto.Adja1Code,
  1224. Adja2Code = dto.Adja2Code,
  1225. MainXlTime = ephMain.data.TleTime,
  1226. Adja1XlTime = ephAdja1.data.TleTime,
  1227. Adja2XlTime = ephAdja2.data.TleTime,
  1228. TaskID = runTask.ID,
  1229. MainX = ephMain.data.X,
  1230. MainY = ephMain.data.Y,
  1231. MainZ = ephMain.data.Z,
  1232. MainVx = ephMain.data.VX,
  1233. MainVy = ephMain.data.VY,
  1234. MainVz = ephMain.data.VZ,
  1235. Adja1X = ephAdja1.data.X,
  1236. Adja1Y = ephAdja1.data.Y,
  1237. Adja1Z = ephAdja1.data.Z,
  1238. Adja1Vx = ephAdja1.data.VX,
  1239. Adja1Vy = ephAdja1.data.VY,
  1240. Adja1Vz = ephAdja1.data.VZ,
  1241. Adja2X = ephAdja2.data.X,
  1242. Adja2Y = ephAdja2.data.Y,
  1243. Adja2Z = ephAdja2.data.Z,
  1244. Adja2Vx = ephAdja2.data.VX,
  1245. Adja2Vy = ephAdja2.data.VY,
  1246. Adja2Vz = ephAdja2.data.VZ,
  1247. TarFreqUp = dto.FreqUp,
  1248. TarFreqDown = dto.FreqDown,
  1249. });
  1250. var res = PosApi.X3_Pos(cgRes, StationRes, dto.CalcConfidence);
  1251. PosRes posRes = new PosRes()
  1252. {
  1253. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1254. SigTime = dto.SigTime,
  1255. TaskInfoID = runTask.ID,
  1256. CgResID = cgRes.ID,
  1257. CheckResID = ckRes.ID,
  1258. PosLon = res[0],
  1259. PosLat = res[1],
  1260. MirrLon = res[3],
  1261. MirrLat = res[4],
  1262. Confidence = (int)res[6],
  1263. PosResType = EnumPosResType.X3,
  1264. };
  1265. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1266. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1267. posRes = db.PosRes.Add(posRes);
  1268. await db.SaveChangesAsync();
  1269. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1270. return Success(MapDto(posRes));
  1271. }
  1272. }
  1273. /// <summary>
  1274. /// 三星双时差无参定位(含星历)
  1275. /// </summary>
  1276. /// <param name="dto">定位参数</param>
  1277. /// <returns></returns>
  1278. [HttpPost]
  1279. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoParAsync(X3TwoDtoNoParPosDto dto)
  1280. {
  1281. TaskInfo runTask;
  1282. using (RHDWContext db = new RHDWContext())
  1283. {
  1284. if (dto.TaskID == null)
  1285. {
  1286. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1287. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1288. if (runTask == null)
  1289. {
  1290. Serilog.Log.Warning($"接收到三星双时差无参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1291. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1292. }
  1293. }
  1294. else
  1295. {
  1296. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1297. if (runTask == null)
  1298. {
  1299. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1300. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1301. }
  1302. }
  1303. }
  1304. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1305. {
  1306. var StationRes = db.StationRes.Add(new StationRes()
  1307. {
  1308. SatTxLon = dto.SatTxLon,
  1309. SatTxLat = dto.SatTxLat,
  1310. });
  1311. var ckRes = new CheckRes()
  1312. {
  1313. FileName = dto.CheckRes?.FileName,
  1314. SmpStart = dto.CheckRes?.SmpStart,
  1315. SmpCount = dto.CheckRes?.SmpCount,
  1316. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1317. ModRate = dto.CheckRes?.ModRate,
  1318. ModType = dto.CheckRes?.ModType,
  1319. UserName = dto.CheckRes?.UserName,
  1320. FfcHz = dto.CheckRes?.FfcHz,
  1321. };
  1322. db.CheckRes.Add(ckRes);
  1323. var cgRes = db.CgRes.Add(new CgRes()
  1324. {
  1325. SigTime = dto.SigTime,
  1326. Dto1 = Math.Round(dto.Dto1, 10),
  1327. Dfo1 = Math.Round(dto.Dfo1, 10),
  1328. Snr1 = Math.Round(dto.Snr1, 1),
  1329. Dto2 = Math.Round(dto.Dto2, 10),
  1330. Dfo2 = Math.Round(dto.Dfo2, 10),
  1331. Snr2 = Math.Round(dto.Snr2, 1),
  1332. StationResID = StationRes.ID,
  1333. MainCode = dto.MainCode,
  1334. Adja1Code = dto.Adja1Code,
  1335. Adja2Code = dto.Adja2Code,
  1336. TaskID = runTask.ID,
  1337. MainX = dto.MainX,
  1338. MainY = dto.MainY,
  1339. MainZ = dto.MainZ,
  1340. MainVx = dto.MainVX,
  1341. MainVy = dto.MainVY,
  1342. MainVz = dto.MainVZ,
  1343. Adja1X = dto.Adja1X,
  1344. Adja1Y = dto.Adja1Y,
  1345. Adja1Z = dto.Adja1Z,
  1346. Adja1Vx = dto.Adja1VX,
  1347. Adja1Vy = dto.Adja1VY,
  1348. Adja1Vz = dto.Adja1VZ,
  1349. Adja2X = dto.Adja2X,
  1350. Adja2Y = dto.Adja2Y,
  1351. Adja2Z = dto.Adja2Z,
  1352. Adja2Vx = dto.Adja2VX,
  1353. Adja2Vy = dto.Adja2VY,
  1354. Adja2Vz = dto.Adja2VZ,
  1355. TarFreqUp = dto.FreqUp,
  1356. TarFreqDown = dto.FreqDown,
  1357. });
  1358. var res = PosApi.X3_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  1359. PosRes posRes = new PosRes()
  1360. {
  1361. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1362. SigTime = cgRes.SigTime,
  1363. TaskInfoID = runTask.ID,
  1364. CgResID = cgRes.ID,
  1365. CheckResID = ckRes.ID,
  1366. PosLon = res[0],
  1367. PosLat = res[1],
  1368. MirrLon = res[3],
  1369. MirrLat = res[4],
  1370. Confidence = (int)res[6],
  1371. PosResType = EnumPosResType.X3NoRef,
  1372. };
  1373. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1374. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1375. posRes = db.PosRes.Add(posRes);
  1376. await db.SaveChangesAsync();
  1377. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1378. return Success(MapDto(posRes));
  1379. }
  1380. }
  1381. /// <summary>
  1382. /// 三星双时差无参定位(无星历)
  1383. /// </summary>
  1384. /// <returns>返回定位结果ID</returns>
  1385. [HttpPost]
  1386. public async Task<AjaxResult<PosResDto>> PosX3TwoDtoNoXlNoParAsync(X3TwoDtoNoXlNoParPosDto dto)
  1387. {
  1388. TaskInfo runTask;
  1389. using (RHDWContext db = new RHDWContext())
  1390. {
  1391. if (dto.TaskID == null)
  1392. {
  1393. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1394. && p.PosType == EnumPosType.X3TwoDto && p.TaskState == EnumTaskState.Running);
  1395. if (runTask == null)
  1396. {
  1397. Serilog.Log.Warning($"接收到三星双时差无参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1398. return Error<PosResDto>($"多模式融合定位平台没有启动三星双时差定位任务");
  1399. }
  1400. }
  1401. else
  1402. {
  1403. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1404. if (runTask == null)
  1405. {
  1406. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1407. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1408. }
  1409. }
  1410. }
  1411. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1412. if (xl1 == null)
  1413. {
  1414. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1415. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1416. }
  1417. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1418. var xl2 = await XlRepository.GetLatestAsync(dto.Adja1Code, dto.SigTime);
  1419. if (xl2 == null)
  1420. {
  1421. Serilog.Log.Error($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1422. return Error<PosResDto>($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1423. }
  1424. Serilog.Log.Information($"卫星{dto.Adja1Code}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1425. var xl3 = await XlRepository.GetLatestAsync(dto.Adja2Code, dto.SigTime);
  1426. if (xl3 == null)
  1427. {
  1428. Serilog.Log.Error($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1429. return Error<PosResDto>($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1430. }
  1431. Serilog.Log.Information($"卫星{dto.Adja2Code}使用发布时刻为{xl3.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1432. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1433. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1434. if (ephMain.code != 200)
  1435. {
  1436. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1437. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1438. }
  1439. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1440. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1441. if (ephAdja1.code != 200)
  1442. {
  1443. Serilog.Log.Error($"推算卫星{dto.Adja1Code}的ECEF星历出错.{ephAdja1.msg}");
  1444. return Error<PosResDto>($"推算卫星{dto.Adja1Code}的ECEF星历出错");
  1445. }
  1446. var XlCalcDto3 = new XlCalcDto() { tleStr = xl3.TwoLine, SigTime = dto.SigTime };
  1447. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto3);
  1448. if (ephAdja2.code != 200)
  1449. {
  1450. Serilog.Log.Error($"推算卫星{dto.Adja2Code}的ECEF星历出错.{ephAdja2.msg}");
  1451. return Error<PosResDto>($"推算卫星{dto.Adja2Code}的ECEF星历出错");
  1452. }
  1453. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1454. {
  1455. var StationRes = db.StationRes.Add(new StationRes()
  1456. {
  1457. SatTxLon = dto.SatTxLon,
  1458. SatTxLat = dto.SatTxLat,
  1459. });
  1460. var ckRes = new CheckRes()
  1461. {
  1462. FileName = dto.CheckRes?.FileName,
  1463. SmpStart = dto.CheckRes?.SmpStart,
  1464. SmpCount = dto.CheckRes?.SmpCount,
  1465. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1466. ModRate = dto.CheckRes?.ModRate,
  1467. ModType = dto.CheckRes?.ModType,
  1468. UserName = dto.CheckRes?.UserName,
  1469. FfcHz = dto.CheckRes?.FfcHz,
  1470. };
  1471. db.CheckRes.Add(ckRes);
  1472. var cgRes = db.CgRes.Add(new CgRes()
  1473. {
  1474. SigTime = dto.SigTime,
  1475. Dto1 = Math.Round(dto.Dto1, 10),
  1476. Dfo1 = Math.Round(dto.Dfo1, 10),
  1477. Snr1 = Math.Round(dto.Snr1, 1),
  1478. Dto2 = Math.Round(dto.Dto2, 10),
  1479. Dfo2 = Math.Round(dto.Dfo2, 10),
  1480. Snr2 = Math.Round(dto.Snr2, 1),
  1481. StationResID = StationRes.ID,
  1482. MainCode = dto.MainCode,
  1483. Adja1Code = dto.Adja1Code,
  1484. Adja2Code = dto.Adja2Code,
  1485. MainXlTime = ephMain.data.TleTime,
  1486. Adja1XlTime = ephAdja1.data.TleTime,
  1487. Adja2XlTime = ephAdja2.data.TleTime,
  1488. TaskID = runTask.ID,
  1489. MainX = ephMain.data.X,
  1490. MainY = ephMain.data.Y,
  1491. MainZ = ephMain.data.Z,
  1492. MainVx = ephMain.data.VX,
  1493. MainVy = ephMain.data.VY,
  1494. MainVz = ephMain.data.VZ,
  1495. Adja1X = ephAdja1.data.X,
  1496. Adja1Y = ephAdja1.data.Y,
  1497. Adja1Z = ephAdja1.data.Z,
  1498. Adja1Vx = ephAdja1.data.VX,
  1499. Adja1Vy = ephAdja1.data.VY,
  1500. Adja1Vz = ephAdja1.data.VZ,
  1501. Adja2X = ephAdja2.data.X,
  1502. Adja2Y = ephAdja2.data.Y,
  1503. Adja2Z = ephAdja2.data.Z,
  1504. Adja2Vx = ephAdja2.data.VX,
  1505. Adja2Vy = ephAdja2.data.VY,
  1506. Adja2Vz = ephAdja2.data.VZ,
  1507. TarFreqUp = dto.FreqUp,
  1508. TarFreqDown = dto.FreqDown,
  1509. });
  1510. var res = PosApi.X3_PosNoRef(cgRes, StationRes, dto.CalcConfidence);
  1511. PosRes posRes = new PosRes()
  1512. {
  1513. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1514. SigTime = dto.SigTime,
  1515. TaskInfoID = runTask.ID,
  1516. CgResID = cgRes.ID,
  1517. CheckResID = ckRes.ID,
  1518. PosLon = res[0],
  1519. PosLat = res[1],
  1520. MirrLon = res[3],
  1521. MirrLat = res[4],
  1522. Confidence = (int)res[6],
  1523. PosResType = EnumPosResType.X3NoRef,
  1524. };
  1525. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1526. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1527. posRes = db.PosRes.Add(posRes);
  1528. await db.SaveChangesAsync();
  1529. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1530. return Success(MapDto(posRes));
  1531. }
  1532. }
  1533. #endregion
  1534. #region 三星双频差定位
  1535. /// <summary>
  1536. /// 三星双频差带参定位(含星历)
  1537. /// </summary>
  1538. /// <param name="dto">定位参数</param>
  1539. /// <returns></returns>
  1540. [HttpPost]
  1541. public async Task<AjaxResult<PosResDto>> PosX3TwoDfoAsync(X3TwoDfoPosDto dto)
  1542. {
  1543. TaskInfo runTask;
  1544. using (RHDWContext db = new RHDWContext())
  1545. {
  1546. if (dto.TaskID == null)
  1547. {
  1548. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1549. && p.PosType == EnumPosType.X3TwoDfo && p.TaskState == EnumTaskState.Running);
  1550. if (runTask == null)
  1551. {
  1552. Serilog.Log.Warning($"接收到三星双频差带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1553. return Error<PosResDto>($"多模式融合定位平台没有启动三星双频差定位任务");
  1554. }
  1555. }
  1556. else
  1557. {
  1558. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1559. if (runTask == null)
  1560. {
  1561. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1562. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1563. }
  1564. }
  1565. }
  1566. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1567. {
  1568. var StationRes = db.StationRes.Add(new StationRes()
  1569. {
  1570. SatTxLon = dto.SatTxLon,
  1571. SatTxLat = dto.SatTxLat,
  1572. RefLon = dto.RefLon,
  1573. RefLat = dto.RefLat,
  1574. });
  1575. var ckRes = new CheckRes()
  1576. {
  1577. FileName = dto.CheckRes?.FileName,
  1578. SmpStart = dto.CheckRes?.SmpStart,
  1579. SmpCount = dto.CheckRes?.SmpCount,
  1580. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1581. ModRate = dto.CheckRes?.ModRate,
  1582. ModType = dto.CheckRes?.ModType,
  1583. UserName = dto.CheckRes?.UserName,
  1584. FfcHz = dto.CheckRes?.FfcHz,
  1585. };
  1586. db.CheckRes.Add(ckRes);
  1587. var cgRes = db.CgRes.Add(new CgRes()
  1588. {
  1589. SigTime = dto.SigTime,
  1590. Dto1 = Math.Round(dto.Dto1, 10),
  1591. Dfo1 = Math.Round(dto.Dfo1, 10),
  1592. Snr1 = Math.Round(dto.Snr1, 1),
  1593. Dto2 = Math.Round(dto.Dto2, 10),
  1594. Dfo2 = Math.Round(dto.Dfo2, 10),
  1595. Snr2 = Math.Round(dto.Snr2, 1),
  1596. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1597. YbAdja1Dfo = Math.Round(dto.YbAdja1Dfo, 10),
  1598. YbAdja2Dfo = Math.Round(dto.YbAdja2Dfo, 10),
  1599. TarFreqUp = dto.TarFreqUp,
  1600. TarFreqDown = dto.TarFreqDown,
  1601. RefFreqUp = dto.RefFreqUp,
  1602. RefFreqDown = dto.RefFreqDown,
  1603. StationResID = StationRes.ID,
  1604. MainCode = dto.MainCode,
  1605. Adja1Code = dto.Adja1Code,
  1606. Adja2Code = dto.Adja2Code,
  1607. TaskID = runTask.ID,
  1608. MainX = dto.MainX,
  1609. MainY = dto.MainY,
  1610. MainZ = dto.MainZ,
  1611. MainVx = dto.MainVx,
  1612. MainVy = dto.MainVy,
  1613. MainVz = dto.MainVz,
  1614. Adja1X = dto.Adja1X,
  1615. Adja1Y = dto.Adja1Y,
  1616. Adja1Z = dto.Adja1Z,
  1617. Adja1Vx = dto.Adja1Vx,
  1618. Adja1Vy = dto.Adja1Vy,
  1619. Adja1Vz = dto.Adja1Vz,
  1620. Adja2X = dto.Adja2X,
  1621. Adja2Y = dto.Adja2Y,
  1622. Adja2Z = dto.Adja2Z,
  1623. Adja2Vx = dto.Adja2Vx,
  1624. Adja2Vy = dto.Adja2Vy,
  1625. Adja2Vz = dto.Adja2Vz,
  1626. });
  1627. var res = PosApi.X3_PosTwoDfo(cgRes, StationRes, dto.CalcConfidence);
  1628. PosRes posRes = new PosRes()
  1629. {
  1630. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1631. SigTime = cgRes.SigTime,
  1632. TaskInfoID = runTask.ID,
  1633. CgResID = cgRes.ID,
  1634. CheckResID = ckRes.ID,
  1635. PosLon = res[0],
  1636. PosLat = res[1],
  1637. MirrLon = res[3],
  1638. MirrLat = res[4],
  1639. Confidence = (int)res[6],
  1640. PosResType = EnumPosResType.X3TwoDfo,
  1641. };
  1642. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1643. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1644. posRes = db.PosRes.Add(posRes);
  1645. await db.SaveChangesAsync();
  1646. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1647. return Success(MapDto(posRes));
  1648. }
  1649. }
  1650. /// <summary>
  1651. /// 三星双频差带参定位(无星历)
  1652. /// </summary>
  1653. /// <returns>返回定位结果ID</returns>
  1654. [HttpPost]
  1655. public async Task<AjaxResult<PosResDto>> PosX3TwoDfoNoXlAsync(X3TwoDfoNoXlPosDto dto)
  1656. {
  1657. TaskInfo runTask;
  1658. using (RHDWContext db = new RHDWContext())
  1659. {
  1660. if (dto.TaskID == null)
  1661. {
  1662. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1663. && p.PosType == EnumPosType.X3TwoDfo && p.TaskState == EnumTaskState.Running);
  1664. if (runTask == null)
  1665. {
  1666. Serilog.Log.Warning($"接收到三星双频差带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1667. return Error<PosResDto>($"多模式融合定位平台没有启动三星双频差定位任务");
  1668. }
  1669. }
  1670. else
  1671. {
  1672. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1673. if (runTask == null)
  1674. {
  1675. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1676. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1677. }
  1678. }
  1679. }
  1680. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1681. if (xl1 == null)
  1682. {
  1683. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1684. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1685. }
  1686. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1687. var xl2 = await XlRepository.GetLatestAsync(dto.Adja1Code, dto.SigTime);
  1688. if (xl2 == null)
  1689. {
  1690. Serilog.Log.Error($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1691. return Error<PosResDto>($"系统缺少编号{dto.Adja1Code}卫星的星历!");
  1692. }
  1693. Serilog.Log.Information($"卫星{dto.Adja1Code}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1694. var xl3 = await XlRepository.GetLatestAsync(dto.Adja2Code, dto.SigTime);
  1695. if (xl3 == null)
  1696. {
  1697. Serilog.Log.Error($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1698. return Error<PosResDto>($"系统缺少编号{dto.Adja2Code}卫星的星历!");
  1699. }
  1700. Serilog.Log.Information($"卫星{dto.Adja2Code}使用发布时刻为{xl3.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1701. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1702. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1703. if (ephMain.code != 200)
  1704. {
  1705. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1706. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1707. }
  1708. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1709. var ephAdja1 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1710. if (ephAdja1.code != 200)
  1711. {
  1712. Serilog.Log.Error($"推算卫星{dto.Adja1Code}的ECEF星历出错.{ephAdja1.msg}");
  1713. return Error<PosResDto>($"推算卫星{dto.Adja1Code}的ECEF星历出错");
  1714. }
  1715. var XlCalcDto3 = new XlCalcDto() { tleStr = xl3.TwoLine, SigTime = dto.SigTime };
  1716. var ephAdja2 = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto3);
  1717. if (ephAdja2.code != 200)
  1718. {
  1719. Serilog.Log.Error($"推算卫星{dto.Adja2Code}的ECEF星历出错.{ephAdja2.msg}");
  1720. return Error<PosResDto>($"推算卫星{dto.Adja2Code}的ECEF星历出错");
  1721. }
  1722. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1723. {
  1724. var StationRes = db.StationRes.Add(new StationRes()
  1725. {
  1726. SatTxLon = dto.SatTxLon,
  1727. SatTxLat = dto.SatTxLat,
  1728. RefLon = dto.RefLon,
  1729. RefLat = dto.RefLat,
  1730. });
  1731. var ckRes = new CheckRes()
  1732. {
  1733. FileName = dto.CheckRes?.FileName,
  1734. SmpStart = dto.CheckRes?.SmpStart,
  1735. SmpCount = dto.CheckRes?.SmpCount,
  1736. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1737. ModRate = dto.CheckRes?.ModRate,
  1738. ModType = dto.CheckRes?.ModType,
  1739. UserName = dto.CheckRes?.UserName,
  1740. FfcHz = dto.CheckRes?.FfcHz,
  1741. };
  1742. db.CheckRes.Add(ckRes);
  1743. var cgRes = db.CgRes.Add(new CgRes()
  1744. {
  1745. SigTime = dto.SigTime,
  1746. Dto1 = Math.Round(dto.Dto1, 10),
  1747. Dfo1 = Math.Round(dto.Dfo1, 10),
  1748. Snr1 = Math.Round(dto.Snr1, 1),
  1749. Dto2 = Math.Round(dto.Dto2, 10),
  1750. Dfo2 = Math.Round(dto.Dfo2, 10),
  1751. Snr2 = Math.Round(dto.Snr2, 1),
  1752. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1753. YbAdja1Dfo = Math.Round(dto.YbAdja1Dfo, 10),
  1754. YbAdja2Dfo = Math.Round(dto.YbAdja2Dfo, 10),
  1755. TarFreqUp = dto.TarFreqUp,
  1756. TarFreqDown = dto.TarFreqDown,
  1757. RefFreqUp = dto.RefFreqUp,
  1758. RefFreqDown = dto.RefFreqDown,
  1759. StationResID = StationRes.ID,
  1760. MainCode = dto.MainCode,
  1761. Adja1Code = dto.Adja1Code,
  1762. Adja2Code = dto.Adja2Code,
  1763. MainXlTime = ephMain.data.TleTime,
  1764. Adja1XlTime = ephAdja1.data.TleTime,
  1765. Adja2XlTime = ephAdja2.data.TleTime,
  1766. TaskID = runTask.ID,
  1767. MainX = ephMain.data.X,
  1768. MainY = ephMain.data.Y,
  1769. MainZ = ephMain.data.Z,
  1770. MainVx = ephMain.data.VX,
  1771. MainVy = ephMain.data.VY,
  1772. MainVz = ephMain.data.VZ,
  1773. Adja1X = ephAdja1.data.X,
  1774. Adja1Y = ephAdja1.data.Y,
  1775. Adja1Z = ephAdja1.data.Z,
  1776. Adja1Vx = ephAdja1.data.VX,
  1777. Adja1Vy = ephAdja1.data.VY,
  1778. Adja1Vz = ephAdja1.data.VZ,
  1779. Adja2X = ephAdja2.data.X,
  1780. Adja2Y = ephAdja2.data.Y,
  1781. Adja2Z = ephAdja2.data.Z,
  1782. Adja2Vx = ephAdja2.data.VX,
  1783. Adja2Vy = ephAdja2.data.VY,
  1784. Adja2Vz = ephAdja2.data.VZ,
  1785. });
  1786. var res = PosApi.X3_PosTwoDfo(cgRes, StationRes, dto.CalcConfidence);
  1787. PosRes posRes = new PosRes()
  1788. {
  1789. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1790. SigTime = dto.SigTime,
  1791. TaskInfoID = runTask.ID,
  1792. CgResID = cgRes.ID,
  1793. CheckResID = ckRes.ID,
  1794. PosLon = res[0],
  1795. PosLat = res[1],
  1796. MirrLon = res[3],
  1797. MirrLat = res[4],
  1798. Confidence = (int)res[6],
  1799. PosResType = EnumPosResType.X3TwoDfo,
  1800. };
  1801. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1802. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1803. posRes = db.PosRes.Add(posRes);
  1804. await db.SaveChangesAsync();
  1805. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1806. return Success(MapDto(posRes));
  1807. }
  1808. }
  1809. #endregion
  1810. #region 双星时频差定位
  1811. /// <summary>
  1812. /// 双星时频差带参定位(含星历)
  1813. /// </summary>
  1814. /// <param name="dto">定位参数</param>
  1815. /// <returns></returns>
  1816. [HttpPost]
  1817. public async Task<AjaxResult<PosResDto>> PosX2DtoDfoAsync(X2DtoDfoPosDto dto)
  1818. {
  1819. TaskInfo runTask;
  1820. using (RHDWContext db = new RHDWContext())
  1821. {
  1822. if (dto.TaskID == null)
  1823. {
  1824. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1825. && p.PosType == EnumPosType.X2Dfo && p.TaskState == EnumTaskState.Running);
  1826. if (runTask == null)
  1827. {
  1828. Serilog.Log.Warning($"接收到双星时频差带参定位(含星历)参数,由于找不到执行中的任务忽略本次定位");
  1829. return Error<PosResDto>($"多模式融合定位平台没有启动双星时频差定位任务");
  1830. }
  1831. }
  1832. else
  1833. {
  1834. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1835. if (runTask == null)
  1836. {
  1837. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1838. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1839. }
  1840. }
  1841. }
  1842. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1843. {
  1844. var StationRes = db.StationRes.Add(new StationRes()
  1845. {
  1846. SatTxLon = dto.SatTxLon,
  1847. SatTxLat = dto.SatTxLat,
  1848. RefLon = dto.RefLon,
  1849. RefLat = dto.RefLat,
  1850. });
  1851. var ckRes = new CheckRes()
  1852. {
  1853. FileName = dto.CheckRes?.FileName,
  1854. SmpStart = dto.CheckRes?.SmpStart,
  1855. SmpCount = dto.CheckRes?.SmpCount,
  1856. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1857. ModRate = dto.CheckRes?.ModRate,
  1858. ModType = dto.CheckRes?.ModType,
  1859. UserName = dto.CheckRes?.UserName,
  1860. FfcHz = dto.CheckRes?.FfcHz,
  1861. };
  1862. db.CheckRes.Add(ckRes);
  1863. var cgRes = db.CgRes.Add(new CgRes()
  1864. {
  1865. SigTime = dto.SigTime,
  1866. Dto1 = Math.Round(dto.Dto, 10),
  1867. Dfo1 = Math.Round(dto.Dfo, 10),
  1868. Snr1 = Math.Round(dto.Snr, 1),
  1869. YbMainDto = Math.Round(dto.YbMainDto, 10),
  1870. YbAdja1Dto = Math.Round(dto.YbAdjaDto, 10),
  1871. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  1872. YbAdja1Dfo = Math.Round(dto.YbAdjaDfo, 10),
  1873. TarFreqUp = dto.TarFreqUp,
  1874. TarFreqDown = dto.TarFreqDown,
  1875. RefFreqUp = dto.RefFreqUp,
  1876. RefFreqDown = dto.RefFreqDown,
  1877. StationResID = StationRes.ID,
  1878. MainCode = dto.MainCode,
  1879. Adja1Code = dto.AdjaCode,
  1880. TaskID = runTask.ID,
  1881. MainX = dto.MainX,
  1882. MainY = dto.MainY,
  1883. MainZ = dto.MainZ,
  1884. MainVx = dto.MainVx,
  1885. MainVy = dto.MainVy,
  1886. MainVz = dto.MainVz,
  1887. Adja1X = dto.AdjaX,
  1888. Adja1Y = dto.AdjaY,
  1889. Adja1Z = dto.AdjaZ,
  1890. Adja1Vx = dto.AdjaVx,
  1891. Adja1Vy = dto.AdjaVy,
  1892. Adja1Vz = dto.AdjaVz,
  1893. });
  1894. var res = PosApi.X2_PosDtoDfo(cgRes, StationRes, dto.CalcConfidence);
  1895. PosRes posRes = new PosRes()
  1896. {
  1897. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  1898. SigTime = cgRes.SigTime,
  1899. TaskInfoID = runTask.ID,
  1900. CgResID = cgRes.ID,
  1901. CheckResID = ckRes.ID,
  1902. PosLon = res[0],
  1903. PosLat = res[1],
  1904. MirrLon = res[3],
  1905. MirrLat = res[4],
  1906. Confidence = (int)res[6],
  1907. PosResType = EnumPosResType.X2Dfo,
  1908. };
  1909. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  1910. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  1911. posRes = db.PosRes.Add(posRes);
  1912. await db.SaveChangesAsync();
  1913. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  1914. return Success(MapDto(posRes));
  1915. }
  1916. }
  1917. /// <summary>
  1918. /// 双星时频差带参定位(无星历)
  1919. /// </summary>
  1920. /// <returns>返回定位结果ID</returns>
  1921. [HttpPost]
  1922. public async Task<AjaxResult<PosResDto>> PosX2DtoDfoNoXlAsync(X2DtoDfoNoXlPosDto dto)
  1923. {
  1924. TaskInfo runTask;
  1925. using (RHDWContext db = new RHDWContext())
  1926. {
  1927. if (dto.TaskID == null)
  1928. {
  1929. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.TaskType == EnumTaskType.Group
  1930. && p.PosType == EnumPosType.X2Dfo && p.TaskState == EnumTaskState.Running);
  1931. if (runTask == null)
  1932. {
  1933. Serilog.Log.Warning($"接收到双星时频差带参定位(无星历)参数,由于找不到执行中的任务忽略本次定位");
  1934. return Error<PosResDto>($"多模式融合定位平台没有启动双星时频差定位任务");
  1935. }
  1936. }
  1937. else
  1938. {
  1939. runTask = await db.TaskInfos.FirstOrDefaultAsync(p => p.ID == dto.TaskID);
  1940. if (runTask == null)
  1941. {
  1942. Serilog.Log.Warning($"找不到任务,ID={dto.TaskID}");
  1943. return Error<PosResDto>($"找不到ID={dto.TaskID}的任务");
  1944. }
  1945. }
  1946. }
  1947. var xl1 = await XlRepository.GetLatestAsync(dto.MainCode, dto.SigTime);
  1948. if (xl1 == null)
  1949. {
  1950. Serilog.Log.Error($"系统缺少编号{dto.MainCode}卫星的星历!");
  1951. return Error<PosResDto>($"系统缺少编号{dto.MainCode}卫星的星历!");
  1952. }
  1953. Serilog.Log.Information($"卫星{dto.MainCode}使用发布时刻为{xl1.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1954. var xl2 = await XlRepository.GetLatestAsync(dto.AdjaCode, dto.SigTime);
  1955. if (xl2 == null)
  1956. {
  1957. Serilog.Log.Error($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  1958. return Error<PosResDto>($"系统缺少编号{dto.AdjaCode}卫星的星历!");
  1959. }
  1960. Serilog.Log.Information($"卫星{dto.AdjaCode}使用发布时刻为{xl2.TimeUTC:yyyyMMddHHmmss}的星历进行推算");
  1961. var XlCalcDto = new XlCalcDto() { tleStr = xl1.TwoLine, SigTime = dto.SigTime };
  1962. var ephMain = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto);
  1963. if (ephMain.code != 200)
  1964. {
  1965. Serilog.Log.Error($"推算卫星{dto.MainCode}的ECEF星历出错.{ephMain.msg}");
  1966. return Error<PosResDto>($"推算卫星{dto.MainCode}的ECEF星历出错");
  1967. }
  1968. var XlCalcDto2 = new XlCalcDto() { tleStr = xl2.TwoLine, SigTime = dto.SigTime };
  1969. var ephAdja = await HttpHelper.PostRequestAsync<SatEphResDto>(SysConfig.GetUrl("Xl/Calc"), XlCalcDto2);
  1970. if (ephAdja.code != 200)
  1971. {
  1972. Serilog.Log.Error($"推算卫星{dto.AdjaCode}的ECEF星历出错.{ephAdja.msg}");
  1973. return Error<PosResDto>($"推算卫星{dto.AdjaCode}的ECEF星历出错");
  1974. }
  1975. using (RHDWPartContext db = RHDWPartContext.GetContext(dto.SigTime, true))
  1976. {
  1977. var StationRes = db.StationRes.Add(new StationRes()
  1978. {
  1979. SatTxLon = dto.SatTxLon,
  1980. SatTxLat = dto.SatTxLat,
  1981. RefLon = dto.RefLon,
  1982. RefLat = dto.RefLat,
  1983. });
  1984. var ckRes = new CheckRes()
  1985. {
  1986. FileName = dto.CheckRes?.FileName,
  1987. SmpStart = dto.CheckRes?.SmpStart,
  1988. SmpCount = dto.CheckRes?.SmpCount,
  1989. PosCheckType = (EnumPosCheckType?)dto.CheckRes?.PosCheckType,
  1990. ModRate = dto.CheckRes?.ModRate,
  1991. ModType = dto.CheckRes?.ModType,
  1992. UserName = dto.CheckRes?.UserName,
  1993. FfcHz = dto.CheckRes?.FfcHz,
  1994. };
  1995. db.CheckRes.Add(ckRes);
  1996. var cgRes = db.CgRes.Add(new CgRes()
  1997. {
  1998. SigTime = dto.SigTime,
  1999. Dto1 = Math.Round(dto.Dto, 10),
  2000. Dfo1 = Math.Round(dto.Dfo, 10),
  2001. Snr1 = Math.Round(dto.Snr, 1),
  2002. YbMainDto = Math.Round(dto.YbMainDto, 10),
  2003. YbAdja1Dto = Math.Round(dto.YbAdjaDto, 10),
  2004. YbMainDfo = Math.Round(dto.YbMainDfo, 10),
  2005. YbAdja1Dfo = Math.Round(dto.YbAdjaDfo, 10),
  2006. TarFreqUp = dto.TarFreqUp,
  2007. TarFreqDown = dto.TarFreqDown,
  2008. RefFreqUp = dto.RefFreqUp,
  2009. RefFreqDown = dto.RefFreqDown,
  2010. StationResID = StationRes.ID,
  2011. MainCode = dto.MainCode,
  2012. Adja1Code = dto.AdjaCode,
  2013. MainXlTime = ephMain.data.TleTime,
  2014. Adja1XlTime = ephAdja.data.TleTime,
  2015. TaskID = runTask.ID,
  2016. MainX = ephMain.data.X,
  2017. MainY = ephMain.data.Y,
  2018. MainZ = ephMain.data.Z,
  2019. MainVx = ephMain.data.VX,
  2020. MainVy = ephMain.data.VY,
  2021. MainVz = ephMain.data.VZ,
  2022. Adja1X = ephAdja.data.X,
  2023. Adja1Y = ephAdja.data.Y,
  2024. Adja1Z = ephAdja.data.Z,
  2025. Adja1Vx = ephAdja.data.VX,
  2026. Adja1Vy = ephAdja.data.VY,
  2027. Adja1Vz = ephAdja.data.VZ,
  2028. });
  2029. var res = PosApi.X2_PosDtoDfo(cgRes, StationRes, dto.CalcConfidence);
  2030. PosRes posRes = new PosRes()
  2031. {
  2032. FreqUpHz = (long)cgRes.TarFreqUp.Value,
  2033. SigTime = dto.SigTime,
  2034. TaskInfoID = runTask.ID,
  2035. CgResID = cgRes.ID,
  2036. CheckResID = ckRes.ID,
  2037. PosLon = res[0],
  2038. PosLat = res[1],
  2039. MirrLon = res[3],
  2040. MirrLat = res[4],
  2041. Confidence = (int)res[6],
  2042. PosResType = EnumPosResType.X2Dfo,
  2043. };
  2044. if (dto.TheoryDfoCalc && posRes.PosLon != 999)
  2045. posRes.TargetState = TheoryDtoDfoApi.TheoryDfo(cgRes, StationRes, posRes, SysConfig.Config.YDPZThreshold);
  2046. posRes = db.PosRes.Add(posRes);
  2047. await db.SaveChangesAsync();
  2048. Messenger.Defalut.Pub("新增定位点", MapModel(posRes));
  2049. return Success(MapDto(posRes));
  2050. }
  2051. }
  2052. #endregion
  2053. #region 定位结果查询接口
  2054. /// <summary>
  2055. /// 根据时间范围查询定位结果
  2056. /// </summary>
  2057. /// <param name="dto"><see cref="PosRequestByTimeRangeDto"/>查询参数</param>
  2058. /// <returns></returns>
  2059. /// <exception cref="Exception"></exception>
  2060. [HttpPost]
  2061. public async Task<AjaxResult<List<PosResDto>>> GetPosResByTimeRange(PosRequestByTimeRangeDto dto)
  2062. {
  2063. #pragma warning disable CS0612 // 类型或成员已过时
  2064. var response = (await GetPosResByTimeRangeObsolete(dto));
  2065. #pragma warning restore CS0612 // 类型或成员已过时
  2066. if (response.code == 200)
  2067. {
  2068. var listDto = response.data?.Select(p => MapDto(p)).ToList();
  2069. return Success(listDto);
  2070. }
  2071. else
  2072. {
  2073. return Error<List<PosResDto>>(response.msg);
  2074. }
  2075. }
  2076. /// <summary>
  2077. /// 查询最后X小时的的定位结果
  2078. /// </summary>
  2079. /// <param name="dto"><see cref="PosRequestByLastRangeDto"/>查询参数</param>
  2080. /// <returns></returns>
  2081. /// <exception cref="Exception"></exception>
  2082. [HttpPost]
  2083. public async Task<AjaxResult<List<PosResDto>>> GetPosResByLastHours(PosRequestByLastRangeDto dto)
  2084. {
  2085. #pragma warning disable CS0612 // 类型或成员已过时
  2086. var response = (await GetPosResByLastHoursObsolete(dto));
  2087. #pragma warning restore CS0612 // 类型或成员已过时
  2088. if (response.code == 200)
  2089. {
  2090. var listDto = response.data?.Select(p => MapDto(p)).ToList();
  2091. return Success(listDto);
  2092. }
  2093. else
  2094. {
  2095. return Error<List<PosResDto>>(response.msg);
  2096. }
  2097. }
  2098. /// <summary>
  2099. /// 根据时间范围查询定位结果(此方法内部调用)
  2100. /// </summary>
  2101. /// <param name="dto"><see cref="PosRequestByTimeRangeDto"/>查询参数</param>
  2102. /// <returns></returns>
  2103. /// <exception cref="Exception"></exception>
  2104. [HttpPost]
  2105. [Obsolete]
  2106. public async Task<AjaxResult<List<PosRes>>> GetPosResByTimeRangeObsolete(PosRequestByTimeRangeDto dto)
  2107. {
  2108. List<PosRes> posList = new List<PosRes>();
  2109. try
  2110. {
  2111. DateTime start = dto.BeginTime;
  2112. DateTime end = dto.EndTime;
  2113. var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
  2114. if (!Directory.Exists(dir)) return Success(posList);
  2115. List<string> list = new List<string>();
  2116. DateTime tempStart = new DateTime(start.Year, start.Month, start.Day);
  2117. while (end >= tempStart)
  2118. {
  2119. list.Add(end.ToString("yyyy") + "\\" + end.ToString("MMdd") + ".db");
  2120. end = end.AddDays(-1);
  2121. }
  2122. end = dto.EndTime;
  2123. List<TargetInfo> targets;
  2124. using (RHDWContext dbBasic = new RHDWContext())
  2125. {
  2126. targets = await dbBasic.TargetInfos.ToListAsync();
  2127. }
  2128. foreach (var item in list)
  2129. {
  2130. var dayFile = Path.Combine(dir, item);
  2131. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  2132. {
  2133. if (db == null) continue;
  2134. var query = db.PosRes.Where(p => p.SigTime >= start && p.SigTime <= end && p.TaskInfoID == dto.TaskInfoID);
  2135. if (!dto.IncludeInvalidate)
  2136. query = query.Where(p => p.PosLon != 999);
  2137. if (dto.TarFrequpHz != null)
  2138. query = query.Where(p => p.FreqUpHz == dto.TarFrequpHz.Value);
  2139. var posRes = await query.Include(p => p.CheckRes).OrderByDescending(p => p.SigTime).ToListAsync();
  2140. foreach (var itemPos in posRes)
  2141. {
  2142. if (itemPos.TargetInfoID > 0)
  2143. {
  2144. itemPos.TargetInfo = targets.FirstOrDefault(p => p.ID == itemPos.TargetInfoID);
  2145. if (itemPos.TargetInfo != null && !string.IsNullOrWhiteSpace(itemPos.TargetInfo.TargeColor))
  2146. itemPos.ColorKey = itemPos.TargetInfo.TargeColor;
  2147. }
  2148. }
  2149. posList.AddRange(posRes);
  2150. }
  2151. }
  2152. return Success(posList);
  2153. }
  2154. catch (Exception ex)
  2155. {
  2156. string msg = $"定位结果时间范围查询异常.任务ID={dto.TaskInfoID},{dto.BeginTime:yyyyMMddHHmmss}-{dto.EndTime:yyyyMMddHHmmss}";
  2157. Serilog.Log.Error(ex, msg);
  2158. return Error<List<PosRes>>("定位结果时间范围查询异常");
  2159. }
  2160. }
  2161. /// <summary>
  2162. /// 根据时间范围查询定位结果(此方法内部调用)
  2163. /// </summary>
  2164. /// <param name="dto"><see cref="PosRequestByTimeRangeDto"/>查询参数</param>
  2165. /// <returns></returns>
  2166. /// <exception cref="Exception"></exception>
  2167. [HttpPost]
  2168. [Obsolete]
  2169. public async Task<AjaxResult<List<RePosRes>>> GetPosCgResByTimeRangeObsolete(PosRequestByTimeRangeDto dto)
  2170. {
  2171. List<RePosRes> posList = new List<RePosRes>();
  2172. try
  2173. {
  2174. DateTime start = dto.BeginTime;
  2175. DateTime end = dto.EndTime;
  2176. var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
  2177. if (!Directory.Exists(dir)) return Success(posList);
  2178. List<string> list = new List<string>();
  2179. DateTime tempStart = new DateTime(start.Year, start.Month, start.Day);
  2180. while (end >= tempStart)
  2181. {
  2182. list.Add(end.ToString("yyyy") + "\\" + end.ToString("MMdd") + ".db");
  2183. end = end.AddDays(-1);
  2184. }
  2185. end = dto.EndTime;
  2186. List<TargetInfo> targets;
  2187. using (RHDWContext dbBasic = new RHDWContext())
  2188. {
  2189. targets = await dbBasic.TargetInfos.ToListAsync();
  2190. }
  2191. foreach (var item in list)
  2192. {
  2193. var dayFile = Path.Combine(dir, item);
  2194. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  2195. {
  2196. if (db == null) continue;
  2197. var query = db.PosRes.Where(p => p.SigTime >= start && p.SigTime <= end && p.TaskInfoID == dto.TaskInfoID);
  2198. if (!dto.IncludeInvalidate)
  2199. query = query.Where(p => p.PosLon != 999);
  2200. if (dto.TarFrequpHz != null)
  2201. query = query.Where(p => p.FreqUpHz == dto.TarFrequpHz.Value);
  2202. var posRes = await query.OrderByDescending(p => p.SigTime).ToListAsync();
  2203. foreach (var itemPos in posRes)
  2204. {
  2205. var repos = new RePosRes();
  2206. repos.ID = itemPos.ID;
  2207. repos.SigTime = itemPos.SigTime;
  2208. repos.PosLon = itemPos.PosLon;
  2209. repos.PosLat = itemPos.PosLat;
  2210. repos.MirrLon = itemPos.MirrLon;
  2211. repos.MirrLat = itemPos.MirrLat;
  2212. repos.TaskInfoID = itemPos.TaskInfoID;
  2213. repos.FreqUpHz = itemPos.FreqUpHz;
  2214. repos.StationResID = itemPos.StationResID;
  2215. repos.CxResID = itemPos.CxResID;
  2216. repos.CgResID = itemPos.CgResID;
  2217. repos.CheckResID = itemPos.CheckResID;
  2218. repos.PosResType = itemPos.PosResType;
  2219. repos.TargetState = itemPos.TargetState;
  2220. repos.TargetInfo = targets?.FirstOrDefault(p => p.ID == itemPos.TargetInfoID);
  2221. if (itemPos.TargetInfo != null && !string.IsNullOrWhiteSpace(itemPos.TargetInfo.TargeColor))
  2222. {
  2223. repos.ColorKey = itemPos.TargetInfo.TargeColor;
  2224. }
  2225. repos.BaseTargetName = itemPos.TargetInfo?.TargetName;
  2226. repos.CheckRes = await db.CheckRes.FirstOrDefaultAsync(p => p.ID == itemPos.CheckResID);
  2227. repos.BaseCheckType = itemPos.CheckRes?.PosCheckType?.GetEnumDisplayName();
  2228. repos.CgRes = await db.CgRes.FirstOrDefaultAsync(p => p.ID == itemPos.CgResID);
  2229. repos.CxRes = await db.CxRes.FirstOrDefaultAsync(p => p.ID == itemPos.CxResID);
  2230. repos.StationRes = await db.StationRes.FirstOrDefaultAsync(p => p.ID == itemPos.StationResID);
  2231. posList.Add(repos);
  2232. }
  2233. }
  2234. }
  2235. return Success(posList);
  2236. }
  2237. catch (Exception ex)
  2238. {
  2239. string msg = $"定位结果时间范围查询异常.任务ID={dto.TaskInfoID},{dto.BeginTime:yyyyMMddHHmmss}-{dto.EndTime:yyyyMMddHHmmss}";
  2240. Serilog.Log.Error(ex, msg);
  2241. return Error<List<RePosRes>>("定位结果时间范围查询异常");
  2242. }
  2243. }
  2244. /// <summary>
  2245. /// 查询最后X小时的的定位结果(此方法内部调用)
  2246. /// </summary>
  2247. /// <param name="dto"><see cref="PosRequestByLastRangeDto"/>查询参数</param>
  2248. /// <returns></returns>
  2249. /// <exception cref="Exception"></exception>
  2250. [HttpPost]
  2251. [Obsolete]
  2252. public async Task<AjaxResult<List<PosRes>>> GetPosResByLastHoursObsolete(PosRequestByLastRangeDto dto)
  2253. {
  2254. List<PosRes> posList = new List<PosRes>();
  2255. try
  2256. {
  2257. var dir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DbPart");
  2258. if (!Directory.Exists(dir)) return Success(posList);
  2259. var yearDirs = Directory.EnumerateDirectories(dir).OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name));//年目录,倒叙排列
  2260. DateTime max = DateTime.MinValue;
  2261. foreach (var yearDir in yearDirs)
  2262. {
  2263. if (max != DateTime.MinValue) break;
  2264. //每一天的db文件,倒序排列
  2265. var dayFiles = Directory.EnumerateFiles(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, yearDir), "*.db").OrderByDescending(p => Convert.ToInt32(new DirectoryInfo(p).Name.Substring(0, 4)));
  2266. foreach (var dayFile in dayFiles)
  2267. {
  2268. using (RHDWPartContext db = RHDWPartContext.GetContext(dayFile))
  2269. {
  2270. if (db == null) continue;
  2271. var query = db.PosRes.Where(p => p.TaskInfoID == dto.TaskInfoID);
  2272. if (!dto.IncludeInvalidate)
  2273. {
  2274. query = query.Where(p => p.PosLon != 999);
  2275. }
  2276. if (dto.TarFrequpHz != null)
  2277. {
  2278. query = query.Where(p => p.FreqUpHz == dto.TarFrequpHz);
  2279. }
  2280. bool any = await query.AnyAsync();
  2281. if (any)
  2282. max = await query.MaxAsync(p => p.SigTime);
  2283. }
  2284. if (max != DateTime.MinValue)
  2285. {
  2286. break;
  2287. }
  2288. }
  2289. }
  2290. if (max == DateTime.MinValue) return Success(posList);
  2291. DateTime min = max.AddHours(-dto.Hours);
  2292. var res = await GetPosResByTimeRangeObsolete(new PosRequestByTimeRangeDto()
  2293. {
  2294. TaskInfoID = dto.TaskInfoID,
  2295. BeginTime = min,
  2296. EndTime = max,
  2297. IncludeInvalidate = dto.IncludeInvalidate,
  2298. TarFrequpHz = dto.TarFrequpHz,
  2299. });
  2300. return res;
  2301. }
  2302. catch (Exception ex)
  2303. {
  2304. string msg = $"定位结果查询最新数据异常-任务编号:{dto.TaskInfoID},Hours:{dto.Hours}";
  2305. Serilog.Log.Error(ex, msg);
  2306. return Error<List<PosRes>>("定位结果查询最新数据异常");
  2307. }
  2308. }
  2309. #endregion
  2310. private PosResDto MapDto(PosRes res)
  2311. {
  2312. return new PosResDto()
  2313. {
  2314. ID = res.ID,
  2315. FreqUpHz = res.FreqUpHz,
  2316. SigTime = res.SigTime,
  2317. TaskInfoID = res.TaskInfoID,
  2318. TarName = res.TargetInfo?.TargetName,
  2319. PosLon = res.PosLon,
  2320. PosLat = res.PosLat,
  2321. MirrLon = res.MirrLon,
  2322. MirrLat = res.MirrLat,
  2323. CheckType = res.CheckRes?.PosCheckType == null ? "" : res.CheckRes?.PosCheckType?.GetEnumDisplayName(),
  2324. TargetState = (EnumTargetStateDto)res.TargetState,
  2325. PosResType = (EnumPosResTypeDto)res.PosResType,
  2326. Confidence = res.Confidence,
  2327. };
  2328. }
  2329. private ModelPosRes MapModel(PosRes res)
  2330. {
  2331. return new ModelPosRes()
  2332. {
  2333. ID = res.ID,
  2334. FreqUpHz = res.FreqUpHz,
  2335. SigTime = res.SigTime,
  2336. TaskInfoID = res.TaskInfoID,
  2337. PosLon = res.PosLon,
  2338. PosLat = res.PosLat,
  2339. MirrLon = res.MirrLon,
  2340. MirrLat = res.MirrLat,
  2341. TargetState = res.TargetState,
  2342. PosResType = res.PosResType,
  2343. CgResID = res.CgResID,
  2344. CheckRes = res.CheckRes,
  2345. CheckResID = res.CheckResID,
  2346. ColorKey = res.ColorKey,
  2347. CreateTime = res.CreateTime,
  2348. CxResID = res.CxResID,
  2349. StationResID = res.StationResID,
  2350. TargetInfo = res.TargetInfo,
  2351. TargetInfoID = res.TargetInfoID,
  2352. UpdateTime = res.UpdateTime,
  2353. Confidence = res.Confidence,
  2354. };
  2355. }
  2356. }
  2357. }