RabbitMQService.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576
  1. using System.Linq;
  2. using System.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. using Newtonsoft.Json;
  5. using Ropin.Inspection.Model.Entities;
  6. using Ropin.Inspection.Model.ViewModel.DEV;
  7. using Ropin.Inspection.Model;
  8. using Ropin.Inspection.Repository.DEV.Interface;
  9. using Ropin.Inspection.Repository;
  10. using Ropin.Inspection.Common.Helper;
  11. using InitQ.Cache;
  12. using InfluxData.Net.InfluxDb;
  13. using InfluxData.Net.Common.Enums;
  14. using RabbitMQ.Client;
  15. using Microsoft.Extensions.Hosting;
  16. using System;
  17. using Microsoft.Extensions.Logging;
  18. using System.Threading.Tasks;
  19. using System.Threading;
  20. using Microsoft.Extensions.DependencyInjection;
  21. using System.Collections.Generic;
  22. using log4net;
  23. using RabbitMQ.Client.Events;
  24. using System.Text;
  25. using System.Threading.Channels;
  26. using FBoxClientDriver.Contract.Entity;
  27. namespace Ropin.Environmentally.LedgeService1
  28. {
  29. public class RabbitMQService : IHostedService, IDisposable
  30. {
  31. private readonly IServiceProvider _provider;
  32. private InfluxDbClient clientDb;
  33. private static readonly ILog log = LogManager.GetLogger(typeof(RabbitMQService));
  34. private readonly RabbitMQModel _rabbitMQModel;
  35. private readonly IniInfluxData _IniInfluxData;
  36. public RabbitMQService(IServiceProvider provider, RabbitMQModel rabbitMQModel, IniInfluxData IniInfluxData)
  37. {
  38. this._provider = provider;
  39. _rabbitMQModel = rabbitMQModel;
  40. _IniInfluxData = IniInfluxData;
  41. IniInflux();
  42. }
  43. private IConnection con;
  44. private IModel channel;
  45. public Task StartAsync(CancellationToken cancellationToken)
  46. {
  47. Task.Run(async () =>
  48. {
  49. await AddRabbitMQ();
  50. //while (true)
  51. //{
  52. // //await DevStatusChange("0", "8453d5ed-8a21-4880-88e7-f872e93551bf", "295458455312930168", DateTime.Now);
  53. // await Task.Delay(5000);//10000:10s
  54. //}
  55. });
  56. return Task.CompletedTask;
  57. }
  58. public Task StopAsync(CancellationToken cancellationToken)
  59. {
  60. Dispose();
  61. return Task.CompletedTask;
  62. }
  63. public void Dispose()
  64. {
  65. channel.Close();
  66. con.Close();
  67. }
  68. public async Task AddRabbitMQ()
  69. {
  70. try
  71. {
  72. var factory = new ConnectionFactory()
  73. {
  74. HostName = _rabbitMQModel.HostName,//"60.204.212.71",//IP地址
  75. Port = _rabbitMQModel.Port,//5672,//端口号
  76. UserName = _rabbitMQModel.UserName,//"guest",//用户账号
  77. VirtualHost = _rabbitMQModel.VirtualHost,//"/",
  78. Password = _rabbitMQModel.Password,// "guest"//用户密码
  79. };
  80. if (con == null || con.IsOpen == false)
  81. {
  82. con = factory.CreateConnection();//创建连接对象
  83. }
  84. if (channel == null || channel.IsOpen == false)
  85. {
  86. channel = con.CreateModel();//创建连接会话对象
  87. }
  88. channel.ExchangeDeclare(_rabbitMQModel.ExchangeName, type: ExchangeType.Direct); // Direct 交换机示例
  89. //声明队列
  90. var queueName = channel.QueueDeclare(
  91. queue: _rabbitMQModel.QueueName, //消息队列名称
  92. durable: false, //是否缓存
  93. exclusive: false,
  94. autoDelete: false,
  95. arguments: null
  96. ).QueueName;
  97. channel.QueueBind(queueName, _rabbitMQModel.ExchangeName, _rabbitMQModel.RoutingKey);
  98. //告诉Rabbit每次只能向消费者发送一条信息,再消费者未确认之前,不再向他发送信息
  99. channel.BasicQos(0, 1, false);
  100. channel.ConfirmSelect(); // 开启消息确认模式
  101. //创建消费者对象
  102. var consumer = new EventingBasicConsumer(channel);
  103. consumer.Received += async (model, ea) =>
  104. {
  105. try
  106. {
  107. var body = ea.Body.ToArray();
  108. var message = Encoding.UTF8.GetString(body);
  109. log.Info("【RabbitMQ】" + message);
  110. var ReceiveData = JsonConvert.DeserializeObject<ReceiveRabbitMQData>(message);
  111. bool result =await DevStatusChange("0", ReceiveData.devStoreCode, ReceiveData.devRunSpot, ReceiveData.time);
  112. if (result)
  113. {
  114. channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
  115. }
  116. else
  117. {
  118. channel.BasicNack(ea.DeliveryTag, false, true); // 重新入队或发送到死信队列的逻辑需要自定义实现
  119. }
  120. }
  121. catch (Exception ex)
  122. {
  123. channel.BasicNack(ea.DeliveryTag, false, true); // 重新入队或发送到死信队列的逻辑需要自定义实现
  124. log.Info("【RabbitMQ-接收消息处理异常了】" + ex.Message);
  125. }
  126. };
  127. //消费者开启监听 将autoAck设置false 手动确认关闭;true:自动关闭;
  128. channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer);
  129. }
  130. catch (Exception ex)
  131. {
  132. log.Info("【异常-RabbitMQ】" + ex.Message);
  133. }
  134. }
  135. #region
  136. /// <summary>
  137. /// 运行台账-【动态】
  138. /// </summary>
  139. /// <param name="devStatus"></param>
  140. /// <param name="devStoreCode"></param>
  141. /// <param name="devRunSpot"></param>
  142. /// <returns></returns>
  143. private async Task<bool> DevStatusChange(string devStatus, string devStoreCode, string devRunSpot, DateTime? time)
  144. {
  145. bool result = false;
  146. try
  147. {
  148. using (var scope = _provider.GetRequiredService<IServiceScopeFactory>().CreateScope())
  149. {
  150. var _redisService = scope.ServiceProvider.GetService<ICacheService>();
  151. DateTime startTime = await _redisService.GetAsync<DateTime>("fanyibox_devStartRun_" + devRunSpot);
  152. DateTime endTime = await _redisService.GetAsync<DateTime>("fanyibox_devEndRun_" + devRunSpot);
  153. var _tmtnDevOpsRecordRepository = scope.ServiceProvider.GetService<ITmtnDevOpsRecordRepository>();
  154. var _devDevOpeAccountConfigService = scope.ServiceProvider.GetService<Idev_DevOpeAccountConfigRepository>();
  155. var _mtnPushMsgResultRepository = scope.ServiceProvider.GetService<ITmtnPushMsgResultRepository>();
  156. var solidWasteRecordItems = await _tmtnDevOpsRecordRepository.GetRecordsConditionAsync(new TmtnDevOpsRecordDetailSearchModel { bSolidWaste = true, C_DevStoreCode = devStoreCode, IsPagination = false, Start = startTime, End = endTime });
  157. var devAccountConfig = await _devDevOpeAccountConfigService.GetByConditionAsync(t => t.C_DevStoreCode == devStoreCode);
  158. using (var dbContext = scope.ServiceProvider.GetService<InspectionDbContext>())//
  159. {
  160. var devStore = dbContext.TDEV_DevStore.Where(x => x.C_ID == devStoreCode).FirstOrDefault();
  161. //运行台账
  162. if (devStatus == "0")
  163. {
  164. bool isAlarm = false;
  165. var devOpeAccountS = dbContext.GetDbSet<TDEV_DevOpeAccount>();
  166. var devAccountConfigModel = devAccountConfig.OrderByDescending(t => t.D_CreateOn).FirstOrDefault();
  167. if (devAccountConfigModel != null)
  168. {
  169. if (!string.IsNullOrEmpty(devAccountConfigModel.C_Config))
  170. {
  171. TdevDevOpeAccountConfigViewModel configList = JsonConvert.DeserializeObject<TdevDevOpeAccountConfigViewModel>(devAccountConfigModel.C_Config);
  172. if (configList != null)
  173. {
  174. IEnumerable<TDEV_WebScadaDevSpot> items = _redisService.Get<IEnumerable<TDEV_WebScadaDevSpot>>("fanyibox_devStore_" + devStoreCode + "_spot");
  175. if (startTime.IsNotEmptyOrNull() && endTime.IsNotEmptyOrNull() && startTime != DateTime.MinValue && endTime != DateTime.MinValue)
  176. {
  177. isAlarm = await GetDevAlarmData(devStoreCode, startTime, endTime) >= 1;
  178. }
  179. List<SolidWaste> DevOpsRecordSolidWaste = new List<SolidWaste>();
  180. if (solidWasteRecordItems.Any() && solidWasteRecordItems.FirstOrDefault() != null)
  181. foreach (var item in solidWasteRecordItems.ToList())
  182. {
  183. if (item.C_Status == "4")
  184. {
  185. if (!string.IsNullOrWhiteSpace(item.C_SolidWaste))
  186. DevOpsRecordSolidWaste.Add(JsonConvert.DeserializeObject<SolidWaste>(item.C_SolidWaste));
  187. }
  188. }
  189. Dictionary<string, object> datas = new Dictionary<string, object>();
  190. #region
  191. datas.Add("Date", time);
  192. foreach (Inspection.Model.ViewModel.DEV.RunSpotConfig item in configList.RunSpotConfigList)
  193. {
  194. if (item.Name == "DevStoreName")
  195. {
  196. datas.Add(item.Name, devStore.C_Name);
  197. }
  198. else if (item.Name == "RunStartTime")
  199. {
  200. datas.Add(item.Name, startTime);
  201. }
  202. else if (item.Name == "RunEndTime")
  203. {
  204. datas.Add(item.Name, DateTime.Now);
  205. }
  206. else if (item.Name == "RunWhetherNormal")
  207. {
  208. datas.Add(item.Name, isAlarm);
  209. }
  210. else if (item.Name == "DischargeTime")
  211. { datas.Add(item.Name, (DateTime.Now - startTime).TotalHours.ToString("F2")); }
  212. else if (item.Name == "ConsumableName" || item.Name == "WasteName")
  213. {
  214. datas.Add(item.Name, DevOpsRecordSolidWaste.Any() ? string.Join(",", DevOpsRecordSolidWaste.Select(x => x.NameSpecification).ToList().ToArray()) : "/");
  215. }
  216. else if (item.Name == "ConsumableReplacementQuantity")
  217. {
  218. int number = DevOpsRecordSolidWaste.Any() ? DevOpsRecordSolidWaste.Sum(x => (string.IsNullOrEmpty(x.SolidWasteNumber) ? 0 : Convert.ToInt32(x.SolidWasteNumber))) : 0;
  219. datas.Add(item.Name, number);
  220. }
  221. else if (item.Name == "WasteProduction")
  222. {
  223. int number = DevOpsRecordSolidWaste.Any() ? DevOpsRecordSolidWaste.Sum(x => (string.IsNullOrEmpty(x.DropNumber) ? 0 : Convert.ToInt32(x.DropNumber))) : 0;
  224. datas.Add(item.Name, number);
  225. }
  226. else
  227. {
  228. if (item.BReadDevSpot)
  229. {
  230. string vals = "0"; string valsMax = "0"; string valsMin = "0";
  231. TDEV_WebScadaDevSpot webScadaDevSpot = items?.Where(x => x.C_Name == item.DevSpotName).FirstOrDefault();
  232. if (webScadaDevSpot == null)
  233. {
  234. datas.Add(item.Name, vals);
  235. datas.Add(item.Name + "_Max", valsMax);
  236. datas.Add(item.Name + "_Min", valsMin);
  237. continue;
  238. }
  239. string SpotId = webScadaDevSpot.C_DevSpotCode.ToString();
  240. if (!string.IsNullOrEmpty(SpotId) && startTime.IsNotEmptyOrNull() && endTime.IsNotEmptyOrNull() && startTime != DateTime.MinValue && endTime != DateTime.MinValue)
  241. {
  242. endTime = DateTime.Now;
  243. vals = await GetMeanData(SpotId, startTime, endTime);
  244. valsMax = await GetDataMax(SpotId, startTime, endTime);
  245. valsMin = await GetDataMin(SpotId, startTime, endTime);
  246. if (vals == null)
  247. {
  248. SpotId = webScadaDevSpot.C_ID.ToString();
  249. vals = await GetMeanData(SpotId, startTime, endTime);
  250. valsMax = await GetDataMax(SpotId, startTime, endTime);
  251. valsMin = await GetDataMin(SpotId, startTime, endTime);
  252. }
  253. }
  254. vals = string.IsNullOrEmpty(vals) ? "0" : Convert.ToDouble(vals).ToString("0.0");
  255. valsMax = string.IsNullOrEmpty(valsMax) ? "0" : Convert.ToDouble(valsMax).ToString("0.0");
  256. valsMin = string.IsNullOrEmpty(valsMin) ? "0" : Convert.ToDouble(valsMin).ToString("0.0");
  257. datas.Add(item.Name, vals);
  258. datas.Add(item.Name + "_Max", valsMax);
  259. datas.Add(item.Name + "_Min", valsMin);
  260. }
  261. else
  262. {
  263. var itemData = configList.RunSpotConfigList?.Where(x => x.Name == item.Name).FirstOrDefault();
  264. datas.Add(item.Name, itemData?.Value);
  265. }
  266. }
  267. }
  268. #endregion
  269. await devOpeAccountS.AddRangeAsync(new TDEV_DevOpeAccount
  270. {
  271. C_ID = Guid.NewGuid().ToString(),
  272. C_DevStoreCode = devStoreCode,
  273. C_Content = JsonConvert.SerializeObject(datas),
  274. C_Remark = "",
  275. C_DevOpeAccountConfigCode = devAccountConfigModel.C_ID,
  276. C_CreateBy = Guid.Parse("6e864cbc-5252-11ec-8681-fa163e02b3e4"),
  277. D_CreateOn = DateTime.Now
  278. });
  279. var qty = await dbContext.SaveChangesAsync();
  280. result = qty > 0 ? true : false;
  281. if (!result)
  282. {
  283. log.Info($"台账保存失败:【{JsonConvert.SerializeObject(datas)}】");
  284. }
  285. }
  286. }
  287. }
  288. }
  289. var devStoreLog = dbContext.GetDbSet<TDEV_DevStoreLog>();
  290. await devStoreLog.AddAsync(new TDEV_DevStoreLog
  291. {
  292. C_ID = Guid.NewGuid().ToString(),
  293. C_DeviceCode = devStoreCode,
  294. C_Type = devStatus == "1" ? "2" : "3",
  295. C_LogMsg = devStatus == "1" ? "开启" : "关闭",
  296. C_CreateBy = Guid.Parse("6e864cbc-5252-11ec-8681-fa163e02b3e4"),
  297. D_CreateOn = DateTime.Now
  298. });
  299. int sumbitLog= await dbContext.SaveChangesAsync();
  300. if (sumbitLog<=0)
  301. {
  302. log.Info($"[TDEV_DevStoreLog]保存失败:【devStoreCode={devStoreCode}】");
  303. }
  304. #region 业主设备运行记录
  305. try
  306. {
  307. DevStoreRunRecord runRecord = new DevStoreRunRecord();
  308. if (!string.IsNullOrEmpty(devStore.C_RunRecord))
  309. {
  310. runRecord = JsonConvert.DeserializeObject<DevStoreRunRecord>(devStore.C_RunRecord);
  311. TmtnPushMsgResultSearchModel ResultSearchMode = new TmtnPushMsgResultSearchModel();
  312. ResultSearchMode.C_DevStoreCode = devStoreCode;
  313. ResultSearchMode.D_Start = Convert.ToDateTime(runRecord.LastOffDate);
  314. DevAlarmCount alarmCount = await _mtnPushMsgResultRepository.GetPushMsgResultContentAsync(ResultSearchMode);
  315. if (alarmCount.TotalTime!="0.0.0")
  316. {
  317. runRecord.LastOffDate = alarmCount.LastOffDate;
  318. runRecord.RunDuration = alarmCount.nowTime;
  319. var arrayRun = runRecord.TotalRunDuration.Split('.');
  320. var runData = alarmCount.TotalTime.Split(".");
  321. int m = Convert.ToInt32(arrayRun[2]) + Convert.ToInt32(runData[2]);
  322. int h = 0;
  323. if (m >= 60)
  324. {
  325. m = m - 60;
  326. h++;
  327. }
  328. h = h + Convert.ToInt32(arrayRun[1]) + Convert.ToInt32(runData[1]);
  329. int d = 0;
  330. if (h >= 24)
  331. {
  332. h = h - 24;
  333. d++;
  334. }
  335. d = d + Convert.ToInt32(arrayRun[0]) + Convert.ToInt32(runData[0]);
  336. runRecord.TotalRunDuration = d + "." + h + "." + m;
  337. if (!string.IsNullOrEmpty(runRecord.FiratOnDate) && !string.IsNullOrEmpty(runRecord.LastOffDate))
  338. {
  339. DateTime time1 = Convert.ToDateTime(runRecord.FiratOnDate);
  340. DateTime time2 = Convert.ToDateTime(runRecord.LastOffDate);
  341. TimeSpan diff = time2.Subtract(time1);
  342. int day = d - diff.Days;
  343. if (diff.Hours > h)
  344. {
  345. d--; h = h + 24;
  346. }
  347. int hours = h - diff.Hours;
  348. if (diff.Minutes > m)
  349. {
  350. h--; m = m + 60;
  351. }
  352. int minutes = m - diff.Minutes;
  353. runRecord.TotalSpotDuration = day + "." + hours + "." + minutes;
  354. }
  355. devStore.C_RunRecord = JsonConvert.SerializeObject(runRecord);
  356. dbContext.TDEV_DevStore.Update(devStore);
  357. int saveresult = await dbContext.SaveChangesAsync();
  358. }
  359. }
  360. else
  361. {
  362. TmtnPushMsgResultSearchModel ResultSearchMode = new TmtnPushMsgResultSearchModel();
  363. ResultSearchMode.C_DevStoreCode = devStoreCode;
  364. DevAlarmCount alarmCount = await _mtnPushMsgResultRepository.GetPushMsgResultContentAsync(ResultSearchMode);
  365. runRecord.LastOffDate = alarmCount.LastOffDate;
  366. runRecord.FiratOnDate = alarmCount.FiratOnDate;
  367. runRecord.TotalRunDuration = alarmCount.TotalTime;
  368. runRecord.TotalSpotDuration = alarmCount.TotalSpotTime;
  369. runRecord.RunDuration = alarmCount.nowTime;
  370. int RepairOrder = dbContext.TMTN_RepairOrder.Where(x => x.C_DevStoreCode == devStoreCode && x.C_Status == "7").Count();
  371. TmtnDevOpsDetailSearchModel tmtnDevOps = new TmtnDevOpsDetailSearchModel();
  372. tmtnDevOps.C_Status = "7";
  373. tmtnDevOps.C_DevStoreCode = devStoreCode;
  374. var DevOps = _tmtnDevOpsRecordRepository.GetDevOpsList(tmtnDevOps);
  375. runRecord.MTNRepairOrder = RepairOrder;
  376. runRecord.MTNDevOps = DevOps.Result.Count();
  377. devStore.C_RunRecord = JsonConvert.SerializeObject(runRecord);
  378. dbContext.TDEV_DevStore.Update(devStore);
  379. int saveresult = await dbContext.SaveChangesAsync();
  380. }
  381. }
  382. catch (Exception ex)
  383. {
  384. log.Info($"【业主设备运行记录】【异常信息:{ex.Message}】【devStoreCode={devStoreCode}】");
  385. }
  386. #endregion
  387. }
  388. }
  389. }
  390. catch (Exception ex)
  391. {
  392. log.Info($"【台账异常】【异常信息:{ex.Message}】【devStoreCode={devStoreCode};devRunSpot={devRunSpot};time={time}】");
  393. }
  394. return result;
  395. }
  396. private void IniInflux()
  397. {
  398. //连接InfluxDb的API地址、账号、密码
  399. var infuxUrl = _IniInfluxData.infuxUrl;// "http://60.204.212.71:8085/";
  400. var infuxUser = _IniInfluxData.infuxUser;// "admin";
  401. var infuxPwd = _IniInfluxData.infuxPwd;//"123456";
  402. //创建InfluxDbClient实例
  403. clientDb = new InfluxDbClient(infuxUrl, infuxUser, infuxPwd, InfluxDbVersion.Latest);
  404. }
  405. public async Task<string> GetMeanData(string id, DateTime start, DateTime end)
  406. {
  407. //传入查询命令,支持多条
  408. var queries = new[]
  409. {
  410. //"SELECT mean(Val) FROM fanyidev where (Id ='"+id+"') and time > '"+ start.ToUniversalTime().ToString("yyyy-MM-dd hh:mm:ss") +"' and time < '" + end.ToUniversalTime().ToString("yyyy-MM-dd hh:mm:ss") + "'"
  411. "SELECT mean(Val) FROM fanyidev where (Id ='"+id+"') and time > '"+ start.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") +"' and time < '" + end.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") + "' TZ('Asia/Shanghai')"
  412. //"SELECT mean(Val) FROM fanyidev where (Id ='224873679711261516') and time > now() - 5m and time < now()"
  413. };
  414. var dbName = "fanyidb";
  415. //从指定库中查询数据
  416. var response = await clientDb.Client.QueryAsync(queries, dbName);
  417. if (!response.Any())
  418. return "0";
  419. //得到Serie集合对象(返回执行多个查询的结果)
  420. var series = response.ToList();
  421. //取出第一条命令的查询结果,是一个集合
  422. var list = series[0].Values;
  423. //从集合中取出第一条数据
  424. var info_model = list.FirstOrDefault();
  425. Console.WriteLine($"GetMeanData from DevEvent: ${info_model[1]}");
  426. using (var scope = _provider.GetRequiredService<IServiceScopeFactory>().CreateScope())
  427. {
  428. var _redisService = scope.ServiceProvider.GetService<ICacheService>();
  429. await _redisService.SetAsync("fanyibox_devspot_mean_" + id, info_model[1]);
  430. }
  431. return info_model[1]?.ToString();
  432. }
  433. public async Task<string> GetDataMax(string id, DateTime start, DateTime end)
  434. {
  435. //传入查询命令,支持多条
  436. var queries = new[]
  437. {
  438. "SELECT Max(Val) FROM fanyidev where (Id ='"+id+"') and time > '"+ start.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") +"' and time < '" + end.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") + "' TZ('Asia/Shanghai')"
  439. };
  440. var dbName = "fanyidb";
  441. //从指定库中查询数据
  442. var response = await clientDb.Client.QueryAsync(queries, dbName);
  443. if (!response.Any())
  444. return "0";
  445. //得到Serie集合对象(返回执行多个查询的结果)
  446. var series = response.ToList();
  447. //取出第一条命令的查询结果,是一个集合
  448. var list = series[0].Values;
  449. //从集合中取出第一条数据
  450. var info_model = list.FirstOrDefault();
  451. Console.WriteLine($"GetMeanData from DevEvent: ${info_model[1]}");
  452. using (var scope = _provider.GetRequiredService<IServiceScopeFactory>().CreateScope())
  453. {
  454. var _redisService = scope.ServiceProvider.GetService<ICacheService>();
  455. await _redisService.SetAsync("fanyibox_devspot_max_" + id, info_model[1]);
  456. }
  457. return info_model[1]?.ToString();
  458. }
  459. public async Task<string> GetDataMin(string id, DateTime start, DateTime end)
  460. {
  461. //传入查询命令,支持多条
  462. var queries = new[]
  463. {
  464. "SELECT MIN(Val) FROM fanyidev where (Id ='"+id+"') and time > '"+ start.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") +"' and time < '" + end.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") + "' TZ('Asia/Shanghai')"
  465. };
  466. var dbName = "fanyidb";
  467. //从指定库中查询数据
  468. var response = await clientDb.Client.QueryAsync(queries, dbName);
  469. if (!response.Any())
  470. return "0";
  471. //得到Serie集合对象(返回执行多个查询的结果)
  472. var series = response.ToList();
  473. //取出第一条命令的查询结果,是一个集合
  474. var list = series[0].Values;
  475. //从集合中取出第一条数据
  476. var info_model = list.FirstOrDefault();
  477. Console.WriteLine($"GetMeanData from DevEvent: ${info_model[1]}");
  478. using (var scope = _provider.GetRequiredService<IServiceScopeFactory>().CreateScope())
  479. {
  480. var _redisService = scope.ServiceProvider.GetService<ICacheService>();
  481. await _redisService.SetAsync("fanyibox_devspot_min_" + id, info_model[1]);
  482. }
  483. return info_model[1]?.ToString();
  484. }
  485. public async Task<int> GetDevAlarmData(string id, DateTime start, DateTime end)
  486. {
  487. //传入查询命令,支持多条
  488. var queries = new[]
  489. {
  490. //"SELECT Max(Val) FROM fanyidevalarm where (Id ='"+id+"') and time > '"+ start.ToUniversalTime().ToString("yyyy-MM-dd hh:mm:ss") +"' and time < '" + end.ToUniversalTime().ToString("yyyy-MM-dd hh:mm:ss") + "'"
  491. "SELECT Max(Val) FROM fanyidevalarm where (Id ='"+id+"') and time > '"+ start.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") +"' and time < '" + end.AddHours(-8).ToString("yyyy-MM-ddTHH:mm:ssZ") + "' TZ('Asia/Shanghai')"
  492. //"SELECT mean(Val) FROM fanyidev where (Id ='224873679711261516') and time > now() - 5m and time < now()"
  493. };
  494. var dbName = "fanyidb";
  495. //从指定库中查询数据
  496. var response = await clientDb.Client.QueryAsync(queries, dbName);
  497. if (!response.Any())
  498. return 0;
  499. //得到Serie集合对象(返回执行多个查询的结果)
  500. var series = response.ToList();
  501. //取出第一条命令的查询结果,是一个集合
  502. var list = series[0].Values;
  503. //从集合中取出第一条数据
  504. var info_model = list.FirstOrDefault();
  505. if (!info_model.Any())
  506. return 0;
  507. Console.WriteLine($"GetMeanData from DevEvent: ${info_model[1]}");
  508. return await Task.FromResult<int>(Convert.ToInt32(info_model[1]));
  509. }
  510. #endregion
  511. }
  512. }