From 24925c9d9243358a3a1c7fdcfb6eb67c867fc80f Mon Sep 17 00:00:00 2001
From: zhengyuxuan <zhengyuxuan1995>
Date: 星期三, 19 三月 2025 13:59:28 +0800
Subject: [PATCH] fix:新增用户接口加入渠道
---
LifePayment/LifePayment.Application.Contracts/User/QrCodeLogin.cs | 5 +++++
LifePayment/LifePayment.Application/User/AccountService.cs | 19 ++++++++++++++++++-
2 files changed, 23 insertions(+), 1 deletions(-)
diff --git a/LifePayment/LifePayment.Application.Contracts/User/QrCodeLogin.cs b/LifePayment/LifePayment.Application.Contracts/User/QrCodeLogin.cs
index de67ea7..2a96375 100644
--- a/LifePayment/LifePayment.Application.Contracts/User/QrCodeLogin.cs
+++ b/LifePayment/LifePayment.Application.Contracts/User/QrCodeLogin.cs
@@ -75,6 +75,11 @@
public string[] RoleNames { get; set; }
/// <summary>
+ /// 娓犻亾鍒楄〃
+ /// </summary>
+ public Guid[] ChannlesId { get; set; }
+
+ /// <summary>
/// 灏忕▼搴廜penId
/// </summary>
public string OpenId { get; set; }
diff --git a/LifePayment/LifePayment.Application/User/AccountService.cs b/LifePayment/LifePayment.Application/User/AccountService.cs
index bf2d4e3..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 鏌ヨ
@@ -170,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