From aef74aff62bd9fc2d615f8b15a100432f2bca44f Mon Sep 17 00:00:00 2001 From: zhengyiming <540361168@qq.com> Date: 星期三, 19 三月 2025 14:46:10 +0800 Subject: [PATCH] Merge branch 'master' of http://120.26.58.240:8888/r/LifePaymentApi --- LifePayment/LifePayment.Application/User/AccountService.cs | 21 ++++++++++++++++++++- 1 files changed, 20 insertions(+), 1 deletions(-) diff --git a/LifePayment/LifePayment.Application/User/AccountService.cs b/LifePayment/LifePayment.Application/User/AccountService.cs index 96b3ae8..0837679 100644 --- a/LifePayment/LifePayment.Application/User/AccountService.cs +++ b/LifePayment/LifePayment.Application/User/AccountService.cs @@ -6,6 +6,7 @@ using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Configuration; using System; +using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Volo.Abp; @@ -27,6 +28,7 @@ private readonly IConfiguration _configuration; private readonly IIdentityModelAuthenticationService _authenticator; private readonly IRepository<User, Guid> _userRepository; + private readonly IRepository<UserChannle, Guid> _userChannleRep; private readonly IIdentityUserAppService _identityUserService; public AccountService( @@ -35,7 +37,8 @@ IIdentityModelAuthenticationService authenticator, IRepository<User, Guid> userRepository, IIdentityUserAppService identityUserService, - IRepository<LifePayUser, Guid> lifePayUserRepository) + IRepository<LifePayUser, Guid> lifePayUserRepository, + IRepository<UserChannle, Guid> userChannleRep) { _configuration = configuration; _wxManager = wxManager; @@ -43,6 +46,7 @@ _lifePayUserRepository = lifePayUserRepository; _authenticator = authenticator; _userRepository = userRepository; + _userChannleRep = userChannleRep; } #region 鏌ヨ @@ -92,6 +96,7 @@ lifeUser = new LifePayUser() { Id = GuidGenerator.Create(), + CreationChannleNum = input.CheckChannelId, PhoneNumber = input.PhoneNumber, LastLoginTime = DateTime.Now }; @@ -100,6 +105,7 @@ } else { + lifeUser.LastLoginChannleNum = input.CheckChannelId; lifeUser.LastLoginTime = DateTime.Now; await _lifePayUserRepository.UpdateAsync(lifeUser); } @@ -168,6 +174,19 @@ DepartmentOrgId = input.ClientId == LifePaymentConstant.ClientId.Back ? input.DepartmentOrgId : null, CompanyOrgId = input.ClientId == LifePaymentConstant.ClientId.Back ? input.CompanyOrgId : null }); + + List<UserChannle> userChannles = new List<UserChannle>(); + foreach (var item in input.ChannlesId) + { + userChannles.Add(new UserChannle() + { + Id = Guid.NewGuid(), + ChannleId = item, + UserId = user.Id + }); + } + + await _userChannleRep.InsertManyAsync(userChannles); //if (input.ClientId == Constant.ClientType.Back) //{ // await _distributedEventBus.PublishAsync(new SendPhoneMessageInput -- Gitblit v1.9.1