From f5bd2dbe3d4047dad9ba8f2516b307398cf5d9e1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com>
Date: Mon, 18 Aug 2025 15:34:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E9=A2=91=E7=B9=81500?=
 =?UTF-8?q?=E6=95=85=E9=9A=9C=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.App/ServiceApp/ManageApp.cs                   |  3 ++-
 .../ServiceControllers/DaHuaAiController.cs            | 10 ++--------
 .../Model/RabbitMQService/RabbitMqListenerService.cs   |  5 ++---
 OpenAuth.WebApi/OpenAuth.WebApi.csproj                 |  3 +++
 4 files changed, 9 insertions(+), 12 deletions(-)

diff --git a/OpenAuth.App/ServiceApp/ManageApp.cs b/OpenAuth.App/ServiceApp/ManageApp.cs
index 58adede..bd5062c 100644
--- a/OpenAuth.App/ServiceApp/ManageApp.cs
+++ b/OpenAuth.App/ServiceApp/ManageApp.cs
@@ -1599,9 +1599,10 @@ namespace OpenAuth.App.ServiceApp
                         .AsQueryable()
                         .Where(r => r.Topic == topic)
                         .Where(r => r.CreateTime > time)
-                        .Where(r => SqlFunc.JsonLike(r.Data, "wind_speed"))
+                        .Where(r => SqlFunc.JsonContainsFieldName(r.Data, "wind_speed"))
                         .OrderByDescending(r => r.CreateTime)
                         .FirstAsync();
+                    //SqlFunc.JsonContainsFieldName(log.Data, "wind_speed")
                     x.Stop();
                     Console.WriteLine("耗时：" + x.ElapsedMilliseconds / 1000);
                     //不太可能为空
diff --git a/OpenAuth.WebApi/Controllers/ServiceControllers/DaHuaAiController.cs b/OpenAuth.WebApi/Controllers/ServiceControllers/DaHuaAiController.cs
index b52b8e9..19c51e5 100644
--- a/OpenAuth.WebApi/Controllers/ServiceControllers/DaHuaAiController.cs
+++ b/OpenAuth.WebApi/Controllers/ServiceControllers/DaHuaAiController.cs
@@ -1,17 +1,11 @@
-using DocumentFormat.OpenXml.Math;
+using System.Text;
 using Infrastructure;
 using Infrastructure.Helpers;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
-using Microsoft.CodeAnalysis.Text;
 using Newtonsoft.Json;
 using OpenAuth.App.ServiceApp.Request;
-using OpenAuth.Repository.Domain;
 using OpenAuth.WebApi.Model.RabbitMQService;
-using RabbitMQ.Client;
-using System.Globalization;
-using System.Security.Cryptography;
-using System.Text;
 
 namespace OpenAuth.WebApi.Controllers.ServiceControllers
 {
@@ -101,7 +95,7 @@ namespace OpenAuth.WebApi.Controllers.ServiceControllers
                     "sdhc"
                 }
             };
-            var jsonBody = Newtonsoft.Json.JsonConvert.SerializeObject(data);
+            var jsonBody = JsonConvert.SerializeObject(data);
             using var httpClient = new HttpClient(handler);
             // 添加请求头
             // 只把非 Content-Type 的头加到 request
diff --git a/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs b/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs
index f88707d..fecfeb3 100644
--- a/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs
+++ b/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs
@@ -1,7 +1,6 @@
-using Microsoft.AspNetCore.Connections;
-using RabbitMQ.Client.Events;
+using System.Text;
 using RabbitMQ.Client;
-using System.Text;
+using RabbitMQ.Client.Events;
 
 namespace OpenAuth.WebApi.Model.RabbitMQService
 {
diff --git a/OpenAuth.WebApi/OpenAuth.WebApi.csproj b/OpenAuth.WebApi/OpenAuth.WebApi.csproj
index b66ef05..1579c22 100644
--- a/OpenAuth.WebApi/OpenAuth.WebApi.csproj
+++ b/OpenAuth.WebApi/OpenAuth.WebApi.csproj
@@ -60,6 +60,9 @@
 		<Reference Include="Autofac.Extensions.DependencyInjection">
 			<HintPath>..\..\..\Users\Administrator\.nuget\packages\autofac.extensions.dependencyinjection\4.0.0\lib\netstandard1.1\Autofac.Extensions.DependencyInjection.dll</HintPath>
 		</Reference>
+		<Reference Include="RabbitMQ.Client">
+		  <HintPath>bin\Debug\net6.0\RabbitMQ.Client.dll</HintPath>
+		</Reference>
 	</ItemGroup>
 
 	<ItemGroup>