11

gx_api/GxPress/Api/GxPress.Api/AdminControllers/AdminOrganizationController.cs

@@ -46,6 +46,26 @@ namespace GxPress.Api.AdminControllers
             return await service.InsertAsync(model);
         }
         /// <summary>
+        /// 机构用户启用停用
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        [HttpPut("user-updat-disable")]
+        public async Task<bool> UpdateDisableAsync(OrganizationUserDisableUpdateRequest request)
+        {
+            return await organizationUserRepository.UpdateDisableAsync(request);
+        }
+        /// <summary>
+        /// 机构用户删除
+        /// </summary>
+        /// <param name="ids"></param>
+        /// <returns></returns>
+        [HttpDelete("user-delete")]
+        public async Task<bool> UserDeleteAsync(List<int> ids)
+        {
+            return await service.DeleteAsync(ids);
+        }
+        /// <summary>
         /// 机构用户列表
         /// </summary>
         /// <param name="request"></param>

gx_api/GxPress/Model/GxPress.Request/OrganizationUser/OrganizationUserRequest.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 
 namespace GxPress.Request.OrganizationUser
 {
@@ -7,6 +8,22 @@ namespace GxPress.Request.OrganizationUser
 
     }
     /// <summary>
+    /// 修改
+    /// </summary>
+    public class OrganizationUserDisableUpdateRequest
+    {
+        /// <summary>
+        /// id集合
+        /// </summary>
+        /// <value></value>
+        public List<int> Ids { get; set; }
+        /// <summary>
+        /// 是否停用
+        /// </summary>
+        /// <value></value>
+        public bool IsDisable { get; set; }
+    }
+    /// <summary>
     /// 搜索
     /// </summary>
     public class OrganizationUserSearchRequest : Common.Page.PageParameter

gx_api/GxPress/Repository/GxPress.Repository.Implement/Organization/OrganizationUserRepository.cs

@@ -85,5 +85,20 @@ namespace GxPress.Repository.Implement.Organization
         {
             return await _repository.InsertAsync(model) > 0;
         }
+
+        public async Task<IEnumerable<Entity.tede2.Organization.OrganizationUser>> GetAllAsync(List<int> ids)
+        {
+            var list = await _repository.GetAllAsync(Q.WhereIn(nameof(Entity.tede2.Organization.OrganizationUser.Id), ids));
+            return list;
+        }
+        public async Task<bool> DeleteAsync(List<int> ids)
+        {
+            return await _repository.DeleteAsync(Q.WhereIn(nameof(Entity.tede2.Organization.OrganizationUser.Id), ids)) > 0;
+        }
+
+        public async Task<bool> UpdateDisableAsync(OrganizationUserDisableUpdateRequest request)
+        {
+            return await _repository.UpdateAsync(Q.WhereIn(nameof(Entity.tede2.Organization.OrganizationUser.Id), request.Ids).Set(nameof(Entity.tede2.Organization.OrganizationUser.IsDisable), request.IsDisable)) > 0;
+        }
     }
 }

gx_api/GxPress/Repository/GxPress.Repository.Implement/UserRepository.cs

@@ -355,7 +355,15 @@ namespace GxPress.Repository.Implement
             if (user == null) throw new BusinessException("该用户不存在");
             return await DeleteAsync(id);
         }
-
+        /// <summary>
+        /// 删除用户
+        /// </summary>
+        /// <param name="ids"></param>
+        /// <returns></returns>
+        public async Task<bool> DeleteAsync(List<int> ids)
+        {
+            return await _repository.DeleteAsync(Q.WhereIn(nameof(User.Id), ids)) > 0;
+        }
         /// <summary>
         /// 更新用户信息
         /// </summary>

gx_api/GxPress/Repository/GxPress.Repository.Interface/IUserRepository.cs

@@ -16,7 +16,12 @@ namespace GxPress.Repository.Interface
         Task<User> GetAsync(SqlKata.Query query);
         Task<UserDetail> GetDetailAsync(int id);
         Task<string> GetNameAsync(int id);
-
+        /// <summary>
+        /// 删除用户
+        /// </summary>
+        /// <param name="ids"></param>
+        /// <returns></returns>
+        Task<bool> DeleteAsync(List<int> ids);
         Task<string> GetAvatarUrlAsync(int id);
 
         string GetAvatarUrl(User user);

gx_api/GxPress/Repository/GxPress.Repository.Interface/Organization/IOrganizationUserRepository.cs

@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 using Datory;
 using GxPress.Common.Page;
@@ -11,5 +12,8 @@ namespace GxPress.Repository.Interface.Organization
         Task<bool> UpdateAsync(OrganizationUserUpdateRequest request);
 
         Task<bool> InsertAsync(Entity.tede2.Organization.OrganizationUser model);
+        Task<IEnumerable<Entity.tede2.Organization.OrganizationUser>> GetAllAsync(List<int> ids);
+        Task<bool> DeleteAsync(List<int> ids);
+        Task<bool> UpdateDisableAsync(OrganizationUserDisableUpdateRequest request);
     }
 }

gx_api/GxPress/Service/GxPress.Service.Implement/OrganizationUser/OrganizationUserService.cs

@@ -1,8 +1,9 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 using GxPress.Repository.Interface;
 using GxPress.Repository.Interface.Organization;
 using GxPress.Service.Interface.OrganizationUser;
-
+using System.Transactions;
 namespace GxPress.Service.Implement.OrganizationUser
 {
     public class OrganizationUserService : IOrganizationUserService
@@ -30,5 +31,26 @@ namespace GxPress.Service.Implement.OrganizationUser
             model.UserId = userId;
             return await organizationUserRepository.InsertAsync(model);
         }
+        public async Task<bool> DeleteAsync(List<int> ids)
+        {
+            try
+            {
+                using (var transactionScope = new TransactionScope())
+                {
+                    //查询用户
+                    var list = await organizationUserRepository.GetAllAsync(ids);
+                    //删除用户
+                    await userRepository.DeleteAsync(ids);
+                    await organizationUserRepository.DeleteAsync(ids);
+                    transactionScope.Complete();
+                }
+
+            }
+            catch (System.Exception ex)
+            {
+                throw new Common.Exceptions.BusinessException(ex.Message);
+            }
+            return true;
+        }
     }
 }

gx_api/GxPress/Service/GxPress.Service.Interface/OrganizationUser/IOrganizationUserService.cs

@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 
 namespace GxPress.Service.Interface.OrganizationUser
@@ -10,5 +11,6 @@ namespace GxPress.Service.Interface.OrganizationUser
         /// <param name="model"></param>
         /// <returns></returns>
         Task<bool> InsertAsync(Entity.tede2.Organization.OrganizationUser model);
+        Task<bool> DeleteAsync(List<int> ids);
     }
 }