122 lines
4.7 KiB
C#
122 lines
4.7 KiB
C#
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Sys.Entities;
|
|
using Kurisu.AspNetCore.Authentication.Options;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Kurisu.Core.DataAccess.Entity;
|
|
using Kurisu.SqlSugar.Services;
|
|
using Microsoft.AspNetCore.Identity;
|
|
using Microsoft.Extensions.Options;
|
|
|
|
namespace Dlhis.ScheduledTask.CommonJobs
|
|
{
|
|
public class TempCreateUserJob
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
private readonly ILogger<TempCreateUserJob> _logger;
|
|
private readonly IdentityServerOptions _identityServerOptions;
|
|
private readonly IHttpClientFactory _httpClientFactory;
|
|
|
|
public TempCreateUserJob(
|
|
IDbContext dbContext,
|
|
ILogger<TempCreateUserJob> logger,
|
|
IOptions<IdentityServerOptions> options,
|
|
IHttpClientFactory httpClientFactory)
|
|
{
|
|
_dbContext = dbContext;
|
|
_logger = logger;
|
|
_httpClientFactory = httpClientFactory;
|
|
_identityServerOptions = options.Value;
|
|
}
|
|
|
|
public async Task RunAsync()
|
|
{
|
|
_dbContext.Client.QueryFilter.ClearAndBackup<ITenantId>();
|
|
try
|
|
{
|
|
|
|
var identityDbContext = _dbContext.ChangeDb("identity");
|
|
|
|
//HST0001
|
|
var users = await identityDbContext.Queryable<UserEntity>().Where(x => x.UserName != "HST0001")
|
|
.Where(x => x.Id > 21)
|
|
.ToListAsync();
|
|
|
|
var gainfos = await _dbContext.Queryable<GainfoEntity>().ToListAsync();
|
|
|
|
var hasher = new PasswordHasher<UserEntity>();
|
|
foreach (var user in users)
|
|
{
|
|
var gainfo = gainfos.FirstOrDefault(x => x.Code == user.UserName);
|
|
if (gainfo != null && gainfo.IdNo.IsPresent())
|
|
{
|
|
var password = gainfo.IdNo.TakeLast(6).Join("");
|
|
password = hasher.HashPassword(user, password);
|
|
user.PasswordHash = password;
|
|
await identityDbContext.UpdateAsync(user);
|
|
}
|
|
}
|
|
|
|
//var userNames = await identityDbContext.Queryable<UserEntity>().Select(x => x.UserName).ToListAsync();
|
|
//var newUser = await _dbContext.Queryable<GainfoEntity>()
|
|
// .Where(x => !string.IsNullOrEmpty(x.Code))
|
|
// .Where(x => !userNames.Contains(x.Code))
|
|
// .Select(x => new
|
|
// {
|
|
// x.Code,
|
|
// x.Factory,
|
|
// x.Name,
|
|
// })
|
|
// .ToListAsync();
|
|
|
|
//var httpClient = _httpClientFactory.CreateClient();
|
|
//httpClient.BaseAddress = new Uri(_identityServerOptions.Authority);
|
|
|
|
//var hasher = new PasswordHasher<UserEntity>();
|
|
//foreach (var item in newUser)
|
|
//{
|
|
// var userName = item.Code;
|
|
// var password = item.Code;
|
|
// var factory = item.Factory;
|
|
|
|
// if (password.Length > 6)
|
|
// {
|
|
// password = string.Join("", password.TakeLast(6));
|
|
// }
|
|
// else
|
|
// {
|
|
// password = password.PadLeft(6, '0');
|
|
// }
|
|
// var user = new UserEntity
|
|
// {
|
|
// UserName = userName,
|
|
// NormalizedUserName = userName.ToUpper(),
|
|
// ConcurrencyStamp = Guid.NewGuid().ToString(),
|
|
// SecurityStamp = Guid.NewGuid().ToString(),
|
|
// };
|
|
|
|
// password = hasher.HashPassword(user, password);
|
|
// user.PasswordHash = password;
|
|
// var id = (int)await identityDbContext.InsertReturnIdentityAsync(user);
|
|
|
|
// await identityDbContext.InsertAsync(new UserTenantEntity() { UserId = id, TenantCode = factory });
|
|
// await identityDbContext.InsertAsync(new List<UserClaimEntity>
|
|
// {
|
|
// new UserClaimEntity{ UserId = id , ClaimType ="preferred_username", ClaimValue = item.Name},
|
|
// new UserClaimEntity{ UserId = id , ClaimType ="jinko-code", ClaimValue = item.Code},
|
|
// });
|
|
//}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex, "创建用户失败:{message}", ex.Message);
|
|
}
|
|
finally
|
|
{
|
|
_dbContext.Client.QueryFilter.Restore();
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
}
|