SpringBoot实战(十八):签到奖励实现方案

简介: SpringBoot实战(十八):签到奖励实现方案

强烈推荐一个大神的人工智能的教程:http://www.captainai.net/zhanghan


前言


最近在做社交业务,用户进入APP后有签到功能,签到成功后获取相应的奖励:

项目状况:前期尝试业务阶段;

特点:

  • 快速实现(不需要做太重,满足初期推广运营即可)
  • 快速投入市场去运营

用户签到:

  • 用户在每次启动时查询签到记录(规则:连续7日签到从0开始,签到过程中有断签从0开始)
  • 如果今日未签到则提示用户可以进行签到
  • 用户签到获取相应的奖励

提到签到,脑海中首先浮现特点:

  • 需要记录每位用户每天的签到情况
  • 查询时根据规则进行签到记录情况


需求&流程设计&技术实现方案


  • 需求原型图

115d5e7557fe3bcde38f22642153c9af_watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI4MjkxMjQ=,size_16,color_FFFFFF,t_70#pic_center.png


  • 查询签到记录

c946fbc7e1b7b9d245ce59b77dfe3b03_watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI4MjkxMjQ=,size_16,color_FFFFFF,t_70#pic_center.png


  • 进行签到

75065aca3e10f811c7f4a32d9286c25a_watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI4MjkxMjQ=,size_16,color_FFFFFF,t_70#pic_center.png


  • 技术实现方案
  • SpringBoot
  • MySQL


数据库表结构


  • 签到记录最新表


CREATE TABLE `zh_sign_in` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `bu_no` varchar(32) DEFAULT NULL COMMENT '业务编码',
  `customer_id` varchar(32) DEFAULT NULL COMMENT '签到用户编码',
  `sign_in_date` datetime DEFAULT NULL COMMENT '签到日期(单位精确到日)',
  `reward_money` int(11) DEFAULT NULL COMMENT '本次签到奖励金币个数',
  `continuite_day` int(2) DEFAULT '1' COMMENT '连续签到天数(A:7天内如果有断签从0开始 B:7天签满从0开始)',
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  `update_time` datetime  DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
  `param1` int(2) DEFAULT NULL COMMENT '预留字段1',
  `param2` int(4) DEFAULT NULL COMMENT '预留字段2',
  `param3` int(11) DEFAULT NULL COMMENT '预留字段3',
  `param4` varchar(20) DEFAULT NULL COMMENT '预留字段4',
  `param5` varchar(32) DEFAULT NULL COMMENT '预留字段5',
  `param6` varchar(64) DEFAULT NULL COMMENT '预留字段6',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE KEY `uk_zh_sign_in_buno` (`bu_no`),
  UNIQUE KEY `uk_zh_sign_in_cid_signindate` (`customer_id`,`sign_in_date`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户签到表';
  • 签到记录历史表


CREATE TABLE `zh_sign_in_hist` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `bu_no` varchar(32) DEFAULT NULL COMMENT '业务编码',
  `customer_id` varchar(32) DEFAULT NULL COMMENT '签到用户编码',
  `sign_in_date` datetime NULL DEFAULT NULL COMMENT '签到日期(单位精确到日)',
  `reward_money` int(11) DEFAULT NULL COMMENT '本次签到奖励金币个数',
  `continuite_day` int(2) DEFAULT '1' COMMENT '连续签到天数(A:7天内如果有断签从0开始 B:7天签满从0开始)',
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  `update_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
  `param1` int(2) DEFAULT NULL COMMENT '预留字段1',
  `param2` int(4) DEFAULT NULL COMMENT '预留字段2',
  `param3` int(11) DEFAULT NULL COMMENT '预留字段3',
  `param4` varchar(20) DEFAULT NULL COMMENT '预留字段4',
  `param5` varchar(32) DEFAULT NULL COMMENT '预留字段5',
  `param6` varchar(64) DEFAULT NULL COMMENT '预留字段6',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE KEY `uk_zh_sign_in_hist_cid_signindate` (`customer_id`,`sign_in_date`) USING BTREE,
  KEY `key_zh_sign_in_hist_buno` (`bu_no`) USING BTREE
) ENGINE=InnoDB  DEFAULT CHARSET=utf8mb4 COMMENT='用户签到历史表';


代码实现


  • 完整代码(GitHub,欢迎大家Star,Fork,Watch)


https://github.com/dangnianchuntian/springboot


  • 主要代码展示


  • Controller
/*
 * Copyright (c) 2020. zhanghan_java@163.com All Rights Reserved.
 * 项目名称:Spring Boot实战:签到奖励实现方案
 * 类名称:SignInController.java
 * 创建人:张晗
 * 联系方式:zhanghan_java@163.com
 * 开源地址: https://github.com/dangnianchuntian/springboot
 * 博客地址: https://zhanghan.blog.csdn.net
 */
package com.zhanghan.zhsignin.controller;
import com.zhanghan.zhsignin.controller.request.PostSignInRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import com.zhanghan.zhsignin.controller.request.ListSignInDetailRequest;
import com.zhanghan.zhsignin.service.SignInService;
@RestController
public class SignInController {
    @Autowired
    private SignInService signInService;
    /**
     * 查询签到记录
     */
    @RequestMapping(value = "/list/sign/in/detail", method = RequestMethod.POST)
    public Object listSignInDetail(@RequestBody @Validated ListSignInDetailRequest listSignInDetailRequest) {
        return signInService.listSignInDetail(listSignInDetailRequest);
    }
    /**
     * 用户进行签到
     */
    @RequestMapping(value = "/post/sign/in", method = RequestMethod.POST)
    public Object postSignIn(@RequestBody @Validated PostSignInRequest postSignInRequest) {
        return signInService.postSignIn(postSignInRequest);
    }
}


  • service


/*
 * Copyright (c) 2020. zhanghan_java@163.com All Rights Reserved.
 * 项目名称:Spring Boot实战:签到奖励实现方案
 * 类名称:SignInServiceImpl.java
 * 创建人:张晗
 * 联系方式:zhanghan_java@163.com
 * 开源地址: https://github.com/dangnianchuntian/springboot
 * 博客地址: https://zhanghan.blog.csdn.net
 */
package com.zhanghan.zhsignin.service.impl;
import cn.hutool.core.util.IdUtil;
import com.zhanghan.zhsignin.config.SignInRewardMoneyListConfig;
import com.zhanghan.zhsignin.constant.SignInConstant;
import com.zhanghan.zhsignin.controller.request.ListSignInDetailRequest;
import com.zhanghan.zhsignin.controller.request.PostSignInRequest;
import com.zhanghan.zhsignin.controller.response.ListSignInDetailResponse;
import com.zhanghan.zhsignin.mybatis.entity.XZhSignInEntity;
import com.zhanghan.zhsignin.mybatis.entity.XZhSignInHistEntity;
import com.zhanghan.zhsignin.mybatis.mapper.XZhSignInHistMapper;
import com.zhanghan.zhsignin.mybatis.mapper.XZhSignInMapper;
import com.zhanghan.zhsignin.service.SignInService;
import com.zhanghan.zhsignin.util.DateUtils;
import com.zhanghan.zhsignin.util.wrapper.WrapMapper;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
import static com.zhanghan.zhsignin.constant.SignInConstant.*;
@Service
public class SignInServiceImpl implements SignInService {
    @Autowired
    private XZhSignInMapper xZhSignInMapper;
    @Autowired
    private XZhSignInHistMapper xZhSignInHistMapper;
    //校验连续天数是否为7
    @Value("#{T(java.lang.Integer).parseInt('${zh.sign.in.continuite.day.threshold:7}')}")
    public Integer continuiteDayThreshold;
    //签到奖励金币集合配置
    @Autowired
    public SignInRewardMoneyListConfig signInRewardMoneyListConfig;
    /**
     * 查询用户签到记录
     */
    @Override
    public Object listSignInDetail(ListSignInDetailRequest listSignInDetailRequest) {
        //若配置文件中未配置签到奖励则不展示签到记录
        List<Integer> signInRewardMoneyListConfigList = signInRewardMoneyListConfig.getList();
        if (CollectionUtils.isEmpty(signInRewardMoneyListConfigList)) {
            return WrapMapper.ok(new ListSignInDetailResponse(false));
        }
        String customerId = listSignInDetailRequest.getCustomerId();
        XZhSignInEntity xZhSignInEntity = xZhSignInMapper.findByCustomerId(customerId);
        List<ListSignInDetailResponse.SignInDetail> signInDetailList = signInRewardMoneyListConfigList.stream().map(aa -> new ListSignInDetailResponse.SignInDetail(0, aa)).collect(Collectors.toList());
        //该用户之前未签到过
        if (null == xZhSignInEntity) {
            return WrapMapper.ok(new ListSignInDetailResponse(TODAY_NOT_SIGN_IN, SignInConstant.CONTINUITE_DAY_ZERO, signInDetailList));
        }
        long signInDateTime = xZhSignInEntity.getSignInDate().getTime();
        //最近一次签到是否为昨日之前
        if (signInDateTime < DateUtils.getYesterdayDateTime()) {
            return WrapMapper.ok(new ListSignInDetailResponse(TODAY_NOT_SIGN_IN, SignInConstant.CONTINUITE_DAY_ZERO, signInDetailList));
        }
        //最近一次签到是否为昨日
        Integer todaySignStatus = TODAY_YES_SIGN_IN;
        Integer continuiteDay = xZhSignInEntity.getContinuiteDay();
        if (signInDateTime < DateUtils.getTodayDateTime()) {
            //最近一次签到是昨日且之前已连续签到7日
            if (continuiteDay >= continuiteDayThreshold) {
                return WrapMapper.ok(new ListSignInDetailResponse(TODAY_NOT_SIGN_IN, SignInConstant.CONTINUITE_DAY_ZERO, signInDetailList));
            }
            //最近一次签到是昨日且之前连续未超7日
            todaySignStatus = TODAY_NOT_SIGN_IN;
        }
        //查询用户签到历史记录
        List<XZhSignInHistEntity> xZhSignInHistEntitieList = xZhSignInHistMapper.listByCustomerIdAndLimit(customerId, continuiteDay);
        for (XZhSignInHistEntity xZhSignInHistEntity : xZhSignInHistEntitieList) {
            ListSignInDetailResponse.SignInDetail signInDetail = new ListSignInDetailResponse.SignInDetail(TODAY_YES_SIGN_IN, xZhSignInHistEntity.getRewardMoney());
            signInDetailList.remove(xZhSignInHistEntity.getContinuiteDay() - 1);
            signInDetailList.add(xZhSignInHistEntity.getContinuiteDay() - 1, signInDetail);
        }
        return WrapMapper.ok(new ListSignInDetailResponse(todaySignStatus, continuiteDay, signInDetailList));
    }
    /**
     * 进行签到
     */
    @Override
    public Object postSignIn(PostSignInRequest postSignInRequest) {
        //若配置文件中未配置签到奖励则不展示签到记录
        List<Integer> signInRewardMoneyListConfigList = signInRewardMoneyListConfig.getList();
        if (CollectionUtils.isEmpty(signInRewardMoneyListConfigList)) {
            return WrapMapper.ok();
        }
        //获取session用户对象
        String customerId = postSignInRequest.getCustomerId();
        //根据customerId查询用户签到记录
        XZhSignInEntity xZhSignInEntityByCustomerId = xZhSignInMapper.findByCustomerId(customerId);
        //签到记录是否为空
        if (null == xZhSignInEntityByCustomerId) {
            XZhSignInEntity xZhSignInEntity = new XZhSignInEntity();
            xZhSignInEntity.setBuNo(IdUtil.simpleUUID());
            xZhSignInEntity.setCustomerId(customerId);
            xZhSignInEntity.setContinuiteDay(CONTINUITE_DAY_ONE);
            xZhSignInEntity.setRewardMoney(signInRewardMoneyListConfigList.get(0));
            xZhSignInEntity.setSignInDate(DateUtils.getTodayDate());
            insertSigninAndHist(xZhSignInEntity);
            return WrapMapper.ok();
        }
        long signInDateTime = xZhSignInEntityByCustomerId.getSignInDate().getTime();
        if (signInDateTime == DateUtils.getTodayDateTime()) {
            return WrapMapper.error("今天已经签到");
        }
        //获取连续签到天数
        Integer continuiteDay = continuiteDay(xZhSignInEntityByCustomerId.getContinuiteDay(), signInDateTime);
        xZhSignInEntityByCustomerId.setSignInDate(DateUtils.getTodayDate());
        xZhSignInEntityByCustomerId.setContinuiteDay(continuiteDay);
        xZhSignInEntityByCustomerId.setRewardMoney(signInRewardMoneyListConfigList.get(continuiteDay - 1));
        xZhSignInEntityByCustomerId.setUpdateTime(new Date());
        xZhSignInEntityByCustomerId.setBuNo(IdUtil.simpleUUID());
        updateSignInAndInsertHist(xZhSignInEntityByCustomerId);
        return WrapMapper.ok();
    }
    private Integer continuiteDay(Integer continuiteDay, Long signInDateTime) {
        if (signInDateTime < DateUtils.getYesterdayDateTime()) {
            return CONTINUITE_DAY_ONE;
        }
        if (continuiteDay >= continuiteDayThreshold) {
            return CONTINUITE_DAY_ONE;
        }
        return continuiteDay + 1;
    }
    private void insertSigninAndHist(XZhSignInEntity xZhSignInEntity) {
        xZhSignInMapper.insertSelective(xZhSignInEntity);
        XZhSignInHistEntity xZhSignInHistEntity = new XZhSignInHistEntity();
        BeanUtils.copyProperties(xZhSignInEntity, xZhSignInHistEntity);
        xZhSignInHistEntity.setId(null);
        xZhSignInHistMapper.insertSelective(xZhSignInHistEntity);
    }
    private void updateSignInAndInsertHist(XZhSignInEntity xZhSignInEntity) {
        xZhSignInMapper.updateByPrimaryKeySelective(xZhSignInEntity);
        XZhSignInHistEntity xZhSignInHistEntity = new XZhSignInHistEntity();
        BeanUtils.copyProperties(xZhSignInEntity, xZhSignInHistEntity);
        xZhSignInHistEntity.setId(null);
        xZhSignInHistMapper.insertSelective(xZhSignInHistEntity);
    }
}


测试


  • 模拟用户进行签到
  • 进行请求

fde3f1b51ba21b3a24e2bd45892eb527_watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI4MjkxMjQ=,size_16,color_FFFFFF,t_70#pic_center.png

  • 查看数据库结果

20200830150006394.png

  • 模拟用户查询签到记录
  • 进行请求

d0c8ef84b15d4389cac2551584b71c3e_watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTI4MjkxMjQ=,size_16,color_FFFFFF,t_70#pic_center.png


总结


  • 亮点:实现业务连续签到,断签以及奖励的业务
  • 注意点:基于数据库查询做的,在进行签到接口需要用redis锁防止并发操作
  • 后续会持续分享更多业务中的亮点

相关文章
|
7天前
|
缓存 NoSQL Java
SpringBoot实现缓存预热的几种常用方案
SpringBoot实现缓存预热的几种常用方案
|
2月前
|
XML Java 数据库连接
spring boot 参数的过滤注解与实战
在Spring Boot应用中,对于入参的过滤,通常会涉及到对Web层的数据验证和处理。Spring Boot借助Spring框架提供了强大的验证框架支持,主要基于JSR-303/JSR-380(Bean Validation API)规范,以及Spring自身的@Valid或@Validated注解来实现请求参数的验证。以下是一些常见的使用案例来展示如何对参数进行过滤和验证。
30 1
|
2月前
|
Java Spring 容器
【二十二】springboot整合拦截器实战并对比过滤器
【二十二】springboot整合拦截器实战并对比过滤器
36 0
|
2月前
|
人工智能 JSON 前端开发
【Spring boot实战】Springboot+对话ai模型整体框架+高并发线程机制处理优化+提示词工程效果展示(按照框架自己修改可对接市面上百分之99的模型)
【Spring boot实战】Springboot+对话ai模型整体框架+高并发线程机制处理优化+提示词工程效果展示(按照框架自己修改可对接市面上百分之99的模型)
|
3天前
|
安全 Java 测试技术
Spring Boot集成支付宝支付:概念与实战
【4月更文挑战第29天】在电子商务和在线业务应用中,集成有效且安全的支付解决方案是至关重要的。支付宝作为中国领先的支付服务提供商,其支付功能的集成可以显著提升用户体验。本篇博客将详细介绍如何在Spring Boot应用中集成支付宝支付功能,并提供一个实战示例。
19 2
|
3天前
|
Java 关系型数据库 数据库
Spring Boot多数据源及事务管理:概念与实战
【4月更文挑战第29天】在复杂的企业级应用中,经常需要访问和管理多个数据源。Spring Boot通过灵活的配置和强大的框架支持,可以轻松实现多数据源的整合及事务管理。本篇博客将探讨如何在Spring Boot中配置多数据源,并详细介绍事务管理的策略和实践。
21 3
|
2天前
|
Java 调度 Maven
Springboot实战篇--Springboot框架通过@Scheduled实现定时任务
Spring Boot的Scheduled定时任务无需额外Maven依赖,通过`@EnableScheduling`开启。任务调度有两种方式:fixedRate和fixedDelay,前者任务结束后立即按设定间隔执行,后者在任务完成后等待设定时间再执行。更灵活的是cron表达式,例如`0 0 3 * * ?`表示每天3点执行。实现定时任务时,需注意默认单线程执行可能导致的任务交错,可通过自定义线程池解决。
|
3天前
|
XML Java API
Spring Boot 整合 LiteFlow 规则引擎:概念与实战
【4月更文挑战第30天】在现代软件开发中,规则引擎允许我们以声明式的方式定义业务逻辑和决策路径。LiteFlow 是一个轻量级、易于使用的组件式规则引擎,它可以与 Spring Boot 应用无缝整合。本文将介绍如何在 Spring Boot 项目中引入 LiteFlow,实现灵活的业务流程管理。
15 0
|
3天前
|
开发框架 Java Maven
SpringBoot-Starter 概念与实战
【4月更文挑战第30天】Spring Boot 是一个基于 Spring Framework 的开发框架,旨在简化 Spring 应用程序的搭建和开发。Spring Boot 提供了大量的 Starter(启动器)来简化项目的依赖管理和配置,其中最为常见的是 SpringBoot-Starter。
15 1
|
3天前
|
安全 Java 测试技术
利用Java反射机制提高Spring Boot的代码质量:概念与实战
【4月更文挑战第29天】Java反射机制提供了一种强大的方法来在运行时检查或修改类和对象的行为。在Spring Boot应用中,合理利用反射可以提高代码的灵活性和可维护性。本篇博客将探讨Java反射的核心概念,并展示如何通过反射提高Spring Boot项目的代码质量。
19 0