//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();
//            }
//        }
//    }


//}