签到业务流程

1.技术选型

Redis主写入查询,Mysql辅助查询,传统签到多数都是直接采用mysql为存储DB,在大数据的情况下数据库的压力较大.查询速率也会随着数据量增大而增加.所以在需求定稿以后查阅了很多签到实现方式,发现用redis做签到会有很大的优势.本功能主要用到redis位图

2.功能实现

1 签到流程(签到,补签,连续,签到记录)
2 签到任务(每日任务,固定任务)
在这里插入图片描述

3.表设计

## 用户积分总表
CREATE TABLE `t_user_integral` (`id` varchar(50) NOT NULL COMMENT 'id',`user_id` int(11) NOT NULL COMMENT '用户id',`integral` int(16) DEFAULT '0' COMMENT '当前积分',`integral_total` int(16) DEFAULT '0' COMMENT '累计积分',`create_time` datetime DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',`update_time` datetime DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='用户积分总表'## 积分流水表
CREATE TABLE `t_user_integral_log` (`id` varchar(50) NOT NULL COMMENT 'id',`user_id` int(11) NOT NULL COMMENT '用户id',`integral_type` int(3) DEFAULT NULL COMMENT '积分类型 1.签到 2.连续签到 3.福利任务 4.每日任务 5.补签',`integral` int(16) DEFAULT '0' COMMENT '积分',`bak` varchar(100) DEFAULT NULL COMMENT '积分补充文案',`operation_time` date DEFAULT NULL COMMENT '操作时间(签到和补签的具体日期)',`create_time` datetime DEFAULT NULL COMMENT '创建时间',PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='用户积分流水表'

4.Redis位图Key的设计

//人员签到位图key,一个位图存一个用户一年的签到状态,以userSign为标识,后面的两个参数是今年的年份和用户的idpublic final static String USER_SIGN_IN = "userSign:%d:%d";//人员补签key,一个Hash列表存用户一个月的补签状态,以userSign:retroactive为标识,后面的两个参数是当月的月份和用户的idpublic final static String USER_RETROACTIVE_SIGN_IN = "userSign:retroactive:%d:%d";//人员签到总天数key,以userSign:count为标识,后面的参数是用户的idpublic final static String USER_SIGN_IN_COUNT = "userSign:count:%d";

5.实现签到

5.1controller

@ApiOperation("用户签到")@PostMapping("/signIn")@LoginValidatepublic ResponseResult saveSignIn(@RequestHeader Integer userId) {return userIntegralLogService.saveSignIn(userId);}

5.2service

1创建一个 ResponseResult 对象,用于统一返回结果。

2使用 String.format 方法拼接出该用户的签到位图在 Redis 中的 Key,格式为 USER_SIGN_IN:年份:用户ID。

3获取当前日期的月份和日期,转换为格式为 MMdd 的长整型数字,作为位图的偏移点。

4设置默认的响应结果信息为 “今日已签到”,并将 code 设置为 -1。

5使用 cacheClient.getBit 方法检查用户今日是否已经签到过。如果返回值为 false,表示用户今日尚未签到。

6执行 cacheClient.setbit 方法设置位图中对应位置为 1,表示用户今日已签到。该方法会返回设置前的位图值。

7如果之前没有签到过(即 oldResult 为 false),则计算该用户本月至今天的连续签到天数,调用 getContinuousSignCount 方法。

8执行 doSaveUserIntegral 方法,记录用户的签到积分类型以及连续签到积分。具体实现不在代码段中。

将响应结果的 code 设置为 0,表示签到成功。

9返回最终的响应结果。

public ResponseResult saveSignIn(Integer userId) {//这里是我们的公司统一返回类ResponseResult responseResult = ResponseResult.newSingleData();//用String.format拼装好单个用户的位图keyString signKey = String.format(RedisKeyConstant.USER_SIGN_IN, LocalDate.now().getYear(), userId);//位图的偏移点为当天的日期,如今天,偏移值就是1010long monthAndDay = Long.parseLong(LocalDate.now().format(DateTimeFormatter.ofPattern("MMdd")));responseResult.setMessage("今日已签到");responseResult.setCode((byte) -1);//检测是否用户今日签到过,用getBit可以取出该用户具体日期的签到状态(位图的值只有两个,1或者0,这里1代表true)if (!cacheClient.getBit(signKey, monthAndDay)) {//位图的set方法会返回该位图未改变前的数值,这里如果之前没有签到过默认是0,也就是falseboolean oldResult = cacheClient.setbit(signKey, monthAndDay);if (!oldResult) {//计算出这个月该用户的到今天的连续签到天数,此方法参照下方计算连续签到天数的代码块int signContinuousCount = getContinuousSignCount(userId);//此方法参照下方记录签到积分类型以及连续签到积分代码块doSaveUserIntegral(userId, signContinuousCount);responseResult.setCode((byte) 0);}}return responseResult;}

5.3连续签到
流程: 1.本质就是取出位图一个偏移值区间内的值,区间起始值为当月的第一天,范围为当月的总天数(BITFIELD命令)——>2.如果没有签到呢默认0,若是连续签到则将得到的long值右移一位再左移一位,若是不相等signCount+1;
1首先,根据传入的用户 ID 和当前时间,生成用户在 Redis 中保存签到信息的 Key,然后从 Redis 中获取该用户在本月内的签到信息的位图。

2接着,遍历该位图,从第一天到当前日期,判断该用户在每一天是否进行了签到。位图中每一个值都表示一天是否签到,如果为 1 表示签到,为 0 则表示没有签到。

3在遍历位图的过程中,如果某一天没有签到,则返回当前的连续签到天数。如果该用户从本月的第一天开始一直到当前日期都进行了签到,则返回当前日期所在的连续签到天数。

如果该用户在本月尚未进行过签到,则返回连续签到天数为 0。
如何判断连续签到?

1通过遍历位图的方式,从第一天到当前日期(date.getDayOfMonth()),依次检查每一天的签到情况。

2对于每一天的检查,首先从位图中获取对应的值,即 list.get(i)。如果该值为 null,则默认设置为 0,表示该天没有进行签到。

3判断获取到的值 v 是否满足连续签到的条件:右移一位再左移一位后与原始值不相等。如果相等,说明当前位为 0,表示当天没有签到,返回当前的连续签到天数。

4如果满足连续签到的条件,将连续签到天数 signCount 加一。

5将值 v 右移一位,用于下一天的判断。

遍历完所有的天数后,返回连续签到天数 signCount。

 private int getContinuousSignCount(Integer userId) {int signCount = 0;LocalDate date = LocalDate.now();String signKey = String.format(RedisKeyConstant.USER_SIGN_IN, date.getYear(), userId);//这里取出的是位图一个偏移值区间的值,区间起始值为当月的第一天,范围值为当月的总天数(参考命令bitfield)List<Long> list = cacheClient.getBit(signKey, date.getMonthValue() * 100 + 1, date.getDayOfMonth());if (list != null && list.size() > 0) {//可能该用户这个月就没有签到过,需要判断一下,如果是空就给一个默认值0long v = list.get(0) == null ? 0 : list.get(0);for (int i = 0; i < date.getDayOfMonth(); i++) {//如果是连续签到得到的long值右移一位再左移一位后与原始值不相等,连续天数加一(相等说明当前位为0没有签到过了)if (v >> 1 << 1 == v) return signCount;signCount += 1;v >>= 1;}}return signCount;}

5.4记录积分类型和连续签到的积分

public Boolean doSaveUserIntegral(int userId, int signContinuousCount) {int count = 0;//叠加签到次数cacheClient.incrValue(String.format(RedisKeyConstant.USER_SIGN_IN_COUNT, userId));List<UserIntegralLog> userIntegralLogList = new LinkedList<>();userIntegralLogList.add(UserIntegralLog.builder().createTime(LocalDateTime.now()).operationTime(LocalDate.now()).bak(BusinessConstant.Integral.NORMAL_SIGN_COPY).integral(BusinessConstant.Integral.SIGN_TYPE_NORMAL_INTEGRAL).integralType(BusinessConstant.Integral.SIGN_TYPE_NORMAL).userId(userId).build());count += BusinessConstant.Integral.SIGN_TYPE_NORMAL_INTEGRAL;//连续签到处理,获取缓存配置连续签到奖励//因为每个月的天数都不是固定的,连续签到奖励是用的redis hash写入的.所以这个地方用32代替一个月的连续签到天数,具体配置在下方图中if (signContinuousCount == LocalDate.now().lengthOfMonth()) {signContinuousCount = 32;}Map<String, String> configurationHashMap = cacheClient.hgetAll("userSign:configuration");String configuration = configurationHashMap.get(signContinuousCount);if (null != configuration) {int giveIntegral = 0;JSONObject item = JSONObject.parseObject(configuration);giveIntegral = item.getInteger("integral");if (giveIntegral != 0) {if (signContinuousCount == 32) {signContinuousCount = LocalDate.now().lengthOfMonth();}userIntegralLogList.add(UserIntegralLog.builder().createTime(LocalDateTime.now()).bak(String.format(BusinessConstant.Integral.CONTINUOUS_SIGN_COPY, signContinuousCount)).integral(giveIntegral).integralType(BusinessConstant.Integral.SIGN_TYPE_CONTINUOUS).userId(userId).build());count += giveIntegral;}}//改变总积分和批量写入积分记录return updateUserIntegralCount(userId, count) && userIntegralLogService.saveBatch(userIntegralLogList);}

6.补签

补签功能是一个签到补充功能,主要就是方便用户在忘了签到的情况下也能通过补签功能达到相应的连续签到条件,从而得到奖励.
这段代码是一个补签功能的后端实现,主要用于用户在签到平台上进行补签操作。我来详细解释一下它的业务流程:

1首先,根据传入的用户ID和需要补签的日期信息,判断今日是否需要进行补签。如果不需要补签,则返回相应的提示信息并结束流程。

2接着,从 Redis 中获取用户当月已经补签的次数,如果已经达到三次补签上限,则返回相应的提示信息,并将结果设置为失败。

3然后,检查用户的积分情况,确保用户的积分足够进行本次补签所需的积分消耗。如果积分不足,则返回相应的提示信息,并将结果设置为失败。

4如果前面的步骤都通过了,那么表示用户可以进行补签操作。在这里会先构建补签日期的 LocalDate 对象,并生成相应的 Redis Key 来存储用户的签到信息。

5在进行补签前,会对用户今日是否已经签到过进行检测,同时也会检测补签的日期是否大于今天的日期。如果通过检测,则将用户的签到信息在 Redis 中进行设置。

6如果补签成功,将补签的记录存入 Redis,同时更新用户的积分信息,并返回补签成功的提示信息。

整体来说,这段代码主要是通过 Redis 存储用户的签到信息及补签记录,并结合用户的积分情况来进行补签操作的逻辑。

//day表示需要补签的日期,因为我们平台的签到周期是一个月所以只需要传日的信息就可以,入 7号传入7
public ResponseResult saveSignInRetroactive(Integer userId, Integer day) {Boolean result = Boolean.TRUE;ResponseResult responseResult = ResponseResult.newSingleData();responseResult.setMessage("今日无需补签哟");responseResult.setCode((byte) -1);LocalDate timeNow = LocalDate.now();//检测是否补签达上限String retroactiveKey = String.format(RedisKeyConstant.USER_RETROACTIVE_SIGN_IN, timeNow.getMonthValue(), userId);//从redis中取出用户的当月补签的集合set.我们平台的限制是三次补签Set<String> keys = cacheClient.hkeys(retroactiveKey);if (CollUtil.isNotEmpty(keys) && keys.size() == 3) {responseResult.setMessage("本月补签次数已达上限");result = Boolean.FALSE;}//检查补签积分是否足够,这里就是一个简单的单表查询,用于查询积分是否足够本次消耗UserIntegral userIntegral = userIntegralService.getOne(new LambdaQueryWrapper<UserIntegral>().eq(UserIntegral::getUserId, userId));//这里只是简单的做了一个map放置三次补签分别消耗的积分(key:次数 value:消耗积分),也可参照之前连续签到配置放入redis缓存中便于后台管理系统可配置Integer reduceIntegral = getReduceIntegral().get(keys.size() + 1);if (reduceIntegral > userIntegral.getIntegral()) {responseResult.setMessage("您的橙汁值不足");result = Boolean.FALSE;}if (result) {LocalDate retroactiveDate = LocalDate.of(timeNow.getYear(), timeNow.getMonthValue(), day);String signKey = String.format(RedisKeyConstant.USER_SIGN_IN, timeNow.getYear(), userId);long monthAndDay = Long.parseLong(retroactiveDate.format(DateTimeFormatter.ofPattern("MMdd")));//后端检测是否用户今日签到过同时补签日期不可大于今天的日期if (!cacheClient.getBit(signKey, monthAndDay) && timeNow.getDayOfMonth() > day) {boolean oldResult = cacheClient.setbit(signKey, monthAndDay);if (!oldResult) {//补签记录(:月份) 过月清零,过期时间是计算出当前时间的差值,补签次数是一个月一刷新的cacheClient.hset(retroactiveKey, retroactiveDate.getDayOfMonth() + "", "1",(Math.max(retroactiveDate.lengthOfMonth() - retroactiveDate.getDayOfMonth(), 1)) * 60 * 60 * 24);//这里就是对积分总表减少.以及对积分记录进行记录.参照下方代码块doRemoveUserIntegral(userId, reduceIntegral, RETROACTIVE_SIGN_COPY);responseResult.setCode((byte) 0);responseResult.setMessage("补签成功");}}}return responseResult;}

积分总表和积分流水表的变动

  public Boolean doRemoveUserIntegral(int userId, int reduceIntegral, String bak) {return updateUserIntegralCount(userId, -reduceIntegral)&& userIntegralLogService.save(UserIntegralLog.builder().createTime(LocalDateTime.now()).operationTime(LocalDate.now()).bak(bak).integral(-reduceIntegral).integralType(BusinessConstant.Integral.RETROACTIVE_SIGN_COPY.equals(bak) ?BusinessConstant.Integral.SIGN_TYPE_RETROACTIVE : BusinessConstant.Integral.SIGN_TYPE_WELFARE).userId(userId).build());}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/433872.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

字节8年经验之谈 —— 如何编写出色的接口测试用例?

简介&#xff1a;在所有的开发测试中&#xff0c;接口测试是必不可少的一项。有效且覆盖完整的接口测试&#xff0c;不仅能保障新功能的开发质量&#xff0c;还能让开发在修改功能逻辑的时候有回归的能力&#xff0c;同时也是能优雅地进行重构的前提。编写接口测试要遵守哪些原…

项目中日历管理学习使用

一些项目中会有日历或日期设置&#xff0c;最基本的会显示工作日&#xff0c;休息日&#xff0c;节假日等等&#xff0c;下面就是基于项目中的日历管理功能&#xff0c;要显示工作日&#xff0c;休息日&#xff0c;节假日 效果图 获取国家法定节假日工具类 public class Holi…

Go语言grpc服务开发——Protocol Buffer

文章目录 一、Protocol Buffer简介二、Protocol Buffer编译器安装三、proto3语言指南四、序列化与反序列化五、引入grpc-gateway1、插件安装2、定义proto文件3、生成go文件4、实现Service服务5、gRPC服务启动方法6、gateway服务启动方法7、main函数启动8、验证 相关参考链接&am…

msvcp140.dll丢失的解决方法

当你在尝试打开一个需要msvcp140.dll文件支持的程序或游戏时&#xff0c;如果系统提示该文件丢失&#xff0c;那么意味着在执行过程中缺少了这个关键的DLL文件。当系统无法找到或加载msvcp140.dll文件时&#xff0c;相应的程序将无法正常启动&#xff0c;这对于用户来说可能会非…

上位机图像处理和嵌入式模块部署(python opencv)

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 前面我们谈到了qt&#xff0c;谈到了opencv&#xff0c;也谈到了嵌入式&#xff0c;但是没有说明python在这个过程当中应该扮演什么样的角色。open…

mac滚动截图

参考博客 https://www.zhihu.com/question/313673726/answer/2938671835 首先去AppStore搜索 iShot 这个也是要钱的&#xff0c;不过我输入appleID后&#xff0c;并没有扣我钱&#xff0c;不知道设么回事 然后打开iShot 点击观看视频&#xff0c;然后mac会自动打开一个新的…

JVM-字节码应用

一、字节码的应用远超你的想象 二、ASM介绍与读取字节码实战 用CoreAPI解析和TreeAPI都能做字节码解析&#xff0c;区别&#xff0c;TreeAPI必须读取完整字节码信息&#xff0c;才能做解析。 下面代码&#xff0c;使用CoreAPI做解析&#xff1a; package asm;public class MyM…

拦截器的简单使用

拦截器的简单使用 拦截器的使用创建拦截器preHandle 目标方法执行前执行postHandle 目标方法执行后执行afterCompletion 视图渲染后执行 拦截器使用场景返回值注册拦截器运用拦截器 拦截器的使用 创建拦截器 首先,我们需要创建一个拦截器器的类,并且需要继承自HandlerIntercep…

DEM高程地形瓦片数据Cesium使用教程

一、简介 从开始写文章到现在&#xff0c;陆续发布了全球90m、30m(包括哥白尼及ALOS)、12.5m全球级瓦片数据&#xff0c;以及中国12.5、日本10m、新西兰8m、等国家级瓦片数据&#xff0c;同时也发布了台湾20m、中国34省区12.5m等地区级瓦片数据。在数据发布的文章中对数据如何…

docker之部署青龙面板

青龙面板是一个用于管理和监控 Linux 服务器的工具&#xff0c;具有定时运行脚本任务的功能。在实际情况下也可以用于一些定期自动签到等任务脚本的运行。 本次记录下简单的安装与使用&#xff0c;请提前安装好docker&#xff0c;参考之前的文章。 一、安装部署 1、拉取镜像 # …

力扣每日一题 ---- 1039. 多边形三角剖分的最低得分

这题的难点在哪部分呢&#xff0c;其实是怎么思考。这道题如果之前没做过类似的话&#xff0c;还是很难看出一些性质的&#xff0c;这题原本的话是没有图片把用例显示的这么详细的。这题中有个很隐晦的点没有说出来 剖出来的三角形是否有交叉&#xff0c;这题中如果加一个三角…

Autodesk AutoCAD 2024:开启无限创意,塑造未来设计

随着科技的飞速发展&#xff0c;设计行业正在经历前所未有的变革。作为设计领域的核心软件&#xff0c;Autodesk AutoCAD 2024以其强大的功能和卓越的性能&#xff0c;引领着设计行业的创新潮流。 AutoCAD 2024不仅继承了前代版本的优点&#xff0c;更在功能和性能上进行了全面…