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='用户积分流水表'

    //人员签到位图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";

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

    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;}

    /*** @description: 获取连续签到天数* @author: chenyunxuan* @updateTime: 2020/8/25 4:43 下午*/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值右移一位再左移一位后与原始值不相等,连续天数加一if (v >> 1 << 1 == v) return signCount;signCount += 1;v >>= 1;}}return signCount;}

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

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