基于SqlSugar的开发框架循序渐进介绍（17）-- 基于CSRedis实现缓存的处理

var csredis = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=13,prefix=my_");

//初始化Redis及分布式缓存
var redisConnectionString = builder.Configuration["CSRedis:ConnectString"];
RedisHelper.Initialization(new CSRedisClient(redisConnectionString));
builder.Services.AddSingleton<IDistributedCache>(new CSRedisCache(RedisHelper.Instance));

RedisHelper.Set("test1", "123123", 60);
RedisHelper.Get("test1");

/// <summary>
/// 清空Redis缓存
/// </summary>
protected void ClearRedisCache()
{
    //查找所有分区节点中符合给定模式(pattern)的 key
    var cacheKeys = RedisHelper.Keys("*");
    RedisHelper.Del(cacheKeys);
}

//程序1：使用代码实现订阅端
var sub = RedisHelper.Subscribe(("chan1", msg => Console.WriteLine(msg.Body)));
//sub.Disponse(); //停止订阅
//程序2：使用代码实现发布端
RedisHelper.Publish("chan1", "111");

// 获取验证码
getCode() {
    if (this.model.mobile.length < 11 && !uni.$u.test.mobile(this.model.mobile)) {
        uni.$u.toast('手机号码不正确')
        return;
    }
    //发送短信验证码
    var params = {
        PhoneNumber: this.model.mobile
    }
    user.SendPhoneLoginSmsCode(params).then(res => {
        if (res.success) {
            this.show = false;
            uni.$u.toast(`验证码已发送至手机 ${this.model.mobile}，请注意查收！`)
            let interval = setInterval(() => {
                this.second--;
                if (this.second <= 0) {
                    this.show = true;
                    clearInterval(interval);
                }
            }, 1000);
        } else {
            uni.$u.toast('发送出现错误：' + res.errorMessage)
        }
    })
}

/// <summary>
/// 发送登录动态码
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
[AllowAnonymous]
[HttpPost]
[Route("send-login-smscode")]
public async Task<CommonResult> SendPhoneLoginSmsCode(PhoneCaptchaModel model)
{
    //获取随机6位数字动态验证码
    var code = RandomChinese.GetRandomNumber(6);
    //使用自定义模板处理短信发送
    string message = string.Format(ConfigData.MySmsCodeTemplate, code);
    var result = await _smsSender.SendAsync(model.PhoneNumber, message);
    if (result.Success)
    {
        var cacheKey = model.PhoneNumber;//以手机号码作为键存储验证码缓存
        var cacheItem = new SmsLoginCodeCacheItem { Code = code, PhoneNumber = model.PhoneNumber };
        RedisHelper.Set(cacheKey, cacheItem, TimeSpan.FromMinutes(ConfigData.SmsCodeExpiredMinutes));
        //获取的时候
        //var tmp = RedisHelper.Get<SmsLoginCodeCacheItem>(cacheKey);
    }
    return result;
}

//短信验证码登录
loginByCode() {
    var params = {
        mobile: this.model.mobile,
        smscode: this.model.code
    };
    console.log(params);
    user.dynamiclogin(params)
        .then(res => {
            uni.$u.toast('验证成功');
            this.gotoPage();
        })
        .catch(error => {
            console.log('验证失败' + error);
            uni.$u.toast(error);
        });
},

/// <summary>
/// 登录授权处理
/// </summary>
/// <returns></returns>
[AllowAnonymous]
[HttpPost]
[Route("authenticate-byphone")]
public async Task<AuthenticateResultDto> AuthenticateByPhoneCaptcha(PhoneCaptchaModel model)
{
    var authResult = new AuthenticateResultDto();
    #region 条件检查
    if (string.IsNullOrEmpty(model.PhoneNumber))
    {
        throw new MyApiException("手机号不能为空");
    }
    if (string.IsNullOrEmpty(model.SmsCode))
    {
        throw new MyApiException("验证码不能为空");
    }
    var userInfo = await _userService.GetFirstAsync(s => s.MobilePhone == model.PhoneNumber);
    if (userInfo == null)
    {
        throw new MyApiException("用户手机不存在");
    }
    #endregion
    var cacheKey = model.PhoneNumber;//以手机号码作为键存储验证码缓存
    var item = RedisHelper.Get<SmsLoginCodeCacheItem>(cacheKey);
    if (item != null && item.Code == model.SmsCode)
    {
        //根据用户身份生成tokenresult
        authResult.AccessToken = GenerateToken(userInfo); //令牌
        authResult.Expires = expiredDays * 24 * 3600; //失效秒数
        authResult.Success = true;//成功
        authResult.UserId = userInfo.Id;//当前用户Id
        //移除缓存短信键值
        RedisHelper.Del(cacheKey);
    }
    else
    {
        authResult.Error = "登录失败，无法生成令牌";
    }
    return authResult;
}