1

GxPress/Api/GxPress.Api/AppControllers/ArticleGroupUserController.cs

@@ -58,5 +58,16 @@ namespace GxPress.Api.AppControllers
             request.UserId = _loginContext.AccountId;
             return await _articleGroupUserRepository.GetListAsync(request);
         }
+         /// <summary>
+        /// 添加
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<bool> InsertAsync(ArticleGroupUserInNewRequest request)
+        {
+            request.UserId = _loginContext.AccountId;
+            return await _articleGroupUserRepository.InsertAsync(request);
+        }
     }
 }

GxPress/Model/GxPress.Request/ArticleGroupUser/ArticleGroupUserInRequest.cs

@@ -19,4 +19,19 @@ namespace GxPress.Request.ArticleGroupUser
         /// </summary>
         public int ArticleGroupId { get; set; }
     }
+     /// <summary>
+    /// 新版添加
+    /// </summary>
+    public class ArticleGroupUserInNewRequest
+    {
+        /// <summary>
+        /// 用户ID
+        /// </summary>
+        public int UserId { get; set; }
+
+        /// <summary>
+        /// 文章组ID
+        /// </summary>
+        public List<int> ArticleGroupId { get; set; }
+    }
 }

GxPress/Repository/GxPress.Repository.Implement/ArticleGroupUserRepository.cs

@@ -11,6 +11,7 @@ using GxPress.Request.ArticleGroupUser;
 using GxPress.Result.ArticleGroupUser;
 using Microsoft.Extensions.Options;
 using Datory;
+using System.Transactions;
 
 namespace GxPress.Repository.Implement
 {
@@ -59,7 +60,40 @@ namespace GxPress.Repository.Implement
             };
             return await _repository.InsertAsync(articleGroupUserEntity);
         }
-
+        /// <summary>
+        /// 添加
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public async Task<bool> InsertAsync(ArticleGroupUserInNewRequest request)
+        {
+            var user = await _userRepository.GetAsync(request.UserId);
+            if (user == null)
+                throw new BusinessException("用户不存在");
+            try
+            {
+                using (var transactionScope = new TransactionScope())
+                {
+                    //删除
+                    await _repository.DeleteAsync(Q.Where(nameof(ArticleGroupUser.UserId), request.UserId));
+                    foreach (var item in request.ArticleGroupId)
+                    {
+                        var articleGroupUserEntity = new ArticleGroupUser
+                        {
+                            ArticleGroupId = item,
+                            UserId = request.UserId
+                        };
+                        await _repository.InsertAsync(articleGroupUserEntity);
+                    }
+                    transactionScope.Complete();
+                }
+            }
+            catch
+            {
+                return false;
+            }
+            return true;
+        }
         /// <summary>
         /// 删除用户频道
         /// </summary>

GxPress/Repository/GxPress.Repository.Interface/IArticleGroupUserRepository.cs

@@ -16,5 +16,11 @@ namespace GxPress.Repository.Interface
         Task<bool> DeleteAsync(int id);
 
         Task<IEnumerable<ArticleGroupUserListResult>> GetListAsync(ArticleGroupUserSearchRequest request);
+        /// <summary>
+        /// 添加
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        Task<bool> InsertAsync(ArticleGroupUserInNewRequest request);
     }
 }