|
@@ -106,21 +106,28 @@ namespace GxPress.Repository.Implement
|
|
|
var addressBookGroup = await _addressBookGroupRepository.GetAsync(request.AddressBookGroupId);
|
|
|
if (addressBookGroup == null)
|
|
|
throw new BusinessException("通讯录组不存在!");
|
|
|
- var user = await _userRepository.GetAsync(request.UserId);
|
|
|
- if (user == null)
|
|
|
- throw new BusinessException("用户不存在!");
|
|
|
- var addressBookGroupUserEntity = await _repository.GetAsync(Q
|
|
|
- .Where(nameof(AddressBookGroupUser.UserId), request.UserId)
|
|
|
- .Where(nameof(AddressBookGroupUser.AddressBookGroupId), request.AddressBookGroupId));
|
|
|
- if (addressBookGroupUserEntity != null)
|
|
|
- throw new BusinessException("用户已经存在!");
|
|
|
- var addressBookGroupUser = new AddressBookGroupUser
|
|
|
+ try
|
|
|
+ {
|
|
|
+ using (var trans = new TransactionScope())
|
|
|
+ {
|
|
|
+ foreach (var item in request.UserId)
|
|
|
+ {
|
|
|
+ var addressBookGroupUser = new AddressBookGroupUser
|
|
|
+ {
|
|
|
+ AddressBookGroupId = request.AddressBookGroupId,
|
|
|
+ UserId = item
|
|
|
+ };
|
|
|
+ //查询用户是否是好友
|
|
|
+ await _repository.InsertAsync(addressBookGroupUser);
|
|
|
+ }
|
|
|
+ trans.Complete();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ catch
|
|
|
{
|
|
|
- AddressBookGroupId = request.AddressBookGroupId,
|
|
|
- UserId = request.UserId
|
|
|
- };
|
|
|
- //查询用户是否是好友
|
|
|
- return await _repository.InsertAsync(addressBookGroupUser) > 0;
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ return true;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 移动分组成员到分组下面
|