houweichen 2 månader sedan
förälder
incheckning
999bbb4ecc

+ 2 - 1
JiaZhiQuan.Common/JiaZhiQuan.Common.csproj

@@ -11,9 +11,10 @@
     <PackageReference Include="Aliyun.OSS.SDK.NetCore" Version="2.13.0" />
     <PackageReference Include="Autofac" Version="8.2.0" />
     <PackageReference Include="Confluent.Kafka" Version="2.0.2" />
-    <PackageReference Include="CSRedisCore" Version="3.2.0" />
+    <PackageReference Include="CSRedisCore" Version="3.8.804" />
     <PackageReference Include="Dapper" Version="2.1.66" />
     <PackageReference Include="Elasticsearch.Net" Version="7.17.0" />
+    <PackageReference Include="Google.Protobuf" Version="3.29.3" />
     <PackageReference Include="MailKit" Version="3.1.1" />
     <PackageReference Include="Mapster" Version="7.3.0" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="6.0.0" />

+ 2 - 2
JiaZhiQuan.Common/Repository/RepositoryExtension.Post.cs

@@ -120,7 +120,7 @@ namespace JiaZhiQuan.Common
                 // 过滤已看过的,如果未看的内容不足最大推荐数量,则将已看内容添加至未看列表末尾
                 var filterRst = (await rpcClient.InvokeRpcAsync(repository.Context, "UserVisitService", "FilterNotExist", string.Join(',', list1.Select(e => $"{userId}_{e.id}")))).Data;
                 var filteredList = (JsonConvert.DeserializeObject<string>(filterRst) ?? string.Empty).Split(',', StringSplitOptions.RemoveEmptyEntries).Select(e => long.Parse(e.Split('_')[1])).ToHashSet();
-                if (filteredList.Count > 0)
+                if (filteredList.Count() > 0)
                 {
                     var validList = new List<PostScore>();
                     var readList = new List<PostScore>();
@@ -546,7 +546,7 @@ namespace JiaZhiQuan.Common
                 mustConditions.Add(new { term = new { type = 1 } });
             }
 
-            var postList = new List<(double, object)>();
+            var postList = new List<(decimal, object)>();
             var query = new
             {
                 _source = new string[] { "id", "subjectiveScore" },