1

gx_api/GxPress/Model/GxPress.Result/User/UserResult.cs

@@ -52,6 +52,10 @@ namespace GxPress.Result.User
         /// 头像地址
         /// </summary>
         public string AvatarUrl { get; set; }
+        /// <summary>
+        /// 环信ID
+        /// </summary>
+        public string ImId { get; set; }
     }
     /// <summary>
     /// 用户通讯录  

gx_api/GxPress/Repository/GxPress.Repository.Implement/Analyze/AnalyzeRepository.cs

@@ -45,7 +45,10 @@ namespace GxPress.Repository.Implement.Analyze
         {
             return await _repository.CountAsync(query);
         }
-
+        public async Task<int> UpdateAsync(Query query)
+        {
+            return await _repository.UpdateAsync(query);
+        }
         public async Task<bool> DeleteAsync(SqlKata.Query query)
         {
             return await _repository.DeleteAsync(query) > 0;

gx_api/GxPress/Repository/GxPress.Repository.Interface/Analyze/IAnalyzeRepository.cs

@@ -17,7 +17,7 @@ namespace GxPress.Repository.Interface.Analyze
 
         Task<int> InsertAsync(Entity.Analyze.Analyze analyze);
         Task<IEnumerable<Entity.Analyze.Analyze>> GetAllAsync(Query query);
-
+        Task<int> UpdateAsync(Query query);
         Task<bool> ExistsAsync(Query query);
     }
 }

gx_api/GxPress/Service/GxPress.Service.Implement/Reply/ReplyService.Praise.cs

@@ -7,6 +7,8 @@ using GxPress.EnumConst;
 using GxPress.Request.Reply;
 using GxPress.Result.Reply;
 using System.Transactions;
+using System.Linq;
+
 namespace GxPress.Service.Implement.Reply
 {
     /// <summary>
@@ -347,10 +349,9 @@ namespace GxPress.Service.Implement.Reply
         {
             try
             {
-
-
                 using (var tran = new TransactionScope())
                 {
+                    var intList = new List<int>();
                     var sql = $@"SELECT 
                        a.Id
                     FROM
@@ -372,19 +373,7 @@ namespace GxPress.Service.Implement.Reply
                             AND a.IsRead = 0";
                     var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString"));
                     var connection = database.GetConnection();
-                    var intList = await connection.QueryAsync<int>(sql);
-                    var sqlAnalyzeStr = string.Empty;
-                    foreach (var item in intList)
-                        sqlAnalyzeStr += $"{item},";
-                    sqlAnalyzeStr = !string.IsNullOrEmpty(sqlAnalyzeStr) ? sqlAnalyzeStr.Remove(sqlAnalyzeStr.Length - 1, 1) : string.Empty;
-                    if (!string.IsNullOrEmpty(sqlAnalyzeStr))
-                    {
-                        sql = $@"UPDATE tede_analyze 
-                            SET 
-                                IsRead = 1
-                                    WHERE Id IN ({sqlAnalyzeStr}) and id>0";
-                        await connection.ExecuteScalarAsync<int>(sql);
-                    }
+                    intList.AddRange(await connection.QueryAsync<int>(sql));
                     sql = $@"
                     SELECT 
                         b.Id
@@ -401,20 +390,7 @@ namespace GxPress.Service.Implement.Reply
                                 AND a.UserId ={userId}
                                 AND b.AnalyzeType = 2
                                 AND b.IsRead = 0";
-                    intList = await connection.QueryAsync<int>(sql);
-                    sqlAnalyzeStr = string.Empty;
-                    foreach (var item in intList)
-                        sqlAnalyzeStr += $"{item},";
-                    sqlAnalyzeStr = !string.IsNullOrEmpty(sqlAnalyzeStr) ? sqlAnalyzeStr.Remove(sqlAnalyzeStr.Length - 1, 1) : string.Empty;
-                    if (!string.IsNullOrEmpty(sqlAnalyzeStr))
-                    {
-
-                        sql = $@"  UPDATE tede_analyze 
-                            SET 
-                                IsRead = 1 
-                                    WHERE Id IN ({sqlAnalyzeStr}) and id>0";
-                        await connection.ExecuteScalarAsync<int>(sql);
-                    }
+                    intList.AddRange(await connection.QueryAsync<int>(sql));
                     sql = $@"
                     SELECT 
                             a.Id
@@ -434,21 +410,7 @@ namespace GxPress.Service.Implement.Reply
                                 AND e.IsDelete = 0
                                 AND a.CommentId = 0
                                 AND a.AnalyzeType = 1";
-                    intList = await connection.QueryAsync<int>(sql);
-                    sqlAnalyzeStr = string.Empty;
-                    foreach (var item in intList)
-                        sqlAnalyzeStr += $"{item},";
-                    sqlAnalyzeStr = !string.IsNullOrEmpty(sqlAnalyzeStr) ? sqlAnalyzeStr.Remove(sqlAnalyzeStr.Length - 1, 1) : string.Empty;
-                    if (!string.IsNullOrEmpty(sqlAnalyzeStr))
-                    {
-                        sql = $@" 
-             UPDATE tede_analyze 
-                            SET 
-                                IsRead = 1
-                                    WHERE Id IN ({sqlAnalyzeStr}) and id>0";
-                        await connection.ExecuteScalarAsync<int>(sql);
-                    }
-
+                    intList.AddRange(await connection.QueryAsync<int>(sql));
                     sql = $@"
                            SELECT 
                                 a.Id
@@ -470,19 +432,13 @@ namespace GxPress.Service.Implement.Reply
                                         AND e.UserId = b.UserId
                                         AND a.AnalyzeType = 1
                                         AND b.UserId ={userId}";
-                    intList = await connection.QueryAsync<int>(sql);
-                    sqlAnalyzeStr = string.Empty;
-                    foreach (var item in intList)
-                        sqlAnalyzeStr += $"{item},";
-                    sqlAnalyzeStr = !string.IsNullOrEmpty(sqlAnalyzeStr) ? sqlAnalyzeStr.Remove(sqlAnalyzeStr.Length - 1, 1) : string.Empty;
-                    if (!string.IsNullOrEmpty(sqlAnalyzeStr))
+                    intList.AddRange(await connection.QueryAsync<int>(sql));
+                    if (intList.Count() > 0)
                     {
-                        sql = $@" 
-              UPDATE tede_analyze 
-                            SET 
-                                IsRead = 1
-                                    WHERE Id IN ({sqlAnalyzeStr}) and id>0";
-                        await connection.ExecuteScalarAsync<int>(sql);
+                        var query = Q.NewQuery();
+                        query.Set(nameof(Entity.Analyze.Analyze.IsRead), true);
+                        query.WhereIn(nameof(Entity.Analyze.Analyze.Id), intList);
+                        var result = await analyzeRepository.UpdateAsync(query);
                     }
                     tran.Complete();
                 }

gx_api/GxPress/Service/GxPress.Service.Implement/Reply/ReplyService.cs

@@ -4,6 +4,7 @@ using GxPress.Request.Reply;
 using GxPress.Result.Reply;
 using GxPress.Service.Interface.Reply;
 using System.Linq;
+using GxPress.Repository.Interface.Analyze;
 namespace GxPress.Service.Implement.Reply
 {
     /// <summary>
@@ -11,9 +12,10 @@ namespace GxPress.Service.Implement.Reply
     /// </summary>
     public partial class ReplyService : IReplyService
     {
-        public ReplyService()
+        private readonly IAnalyzeRepository analyzeRepository;
+        public ReplyService(IAnalyzeRepository analyzeRepository)
         {
-
+            this.analyzeRepository = analyzeRepository;
         }
         /// <summary>
         /// 获取我收到和我回复的评论