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锁防止并发操作
  • 后续会持续分享更多业务中的亮点

相关文章
|
1天前
|
缓存 NoSQL Java
SpringBoot实现缓存预热的几种常用方案
SpringBoot实现缓存预热的几种常用方案
|
1天前
|
Java 应用服务中间件 测试技术
深入探索Spring Boot Web应用源码及实战应用
【5月更文挑战第11天】本文将详细解析Spring Boot Web应用的源码架构,并通过一个实际案例,展示如何构建一个基于Spring Boot的Web应用。本文旨在帮助读者更好地理解Spring Boot的内部工作机制,以及如何利用这些机制优化自己的Web应用开发。
25 3
|
1天前
|
安全 Java 开发者
深入理解Spring Boot配置绑定及其实战应用
【4月更文挑战第10天】本文详细探讨了Spring Boot中配置绑定的核心概念,并结合实战示例,展示了如何在项目中有效地使用这些技术来管理和绑定配置属性。
13 1
|
1天前
|
安全 Java 测试技术
Spring Boot集成支付宝支付:概念与实战
【4月更文挑战第29天】在电子商务和在线业务应用中,集成有效且安全的支付解决方案是至关重要的。支付宝作为中国领先的支付服务提供商,其支付功能的集成可以显著提升用户体验。本篇博客将详细介绍如何在Spring Boot应用中集成支付宝支付功能,并提供一个实战示例。
37 2
|
1天前
|
Java 关系型数据库 数据库
Spring Boot多数据源及事务管理:概念与实战
【4月更文挑战第29天】在复杂的企业级应用中,经常需要访问和管理多个数据源。Spring Boot通过灵活的配置和强大的框架支持,可以轻松实现多数据源的整合及事务管理。本篇博客将探讨如何在Spring Boot中配置多数据源,并详细介绍事务管理的策略和实践。
38 3
|
1天前
|
Java 开发者 Spring
springboot DDD的概念以及实战
【5月更文挑战第15天】领域驱动设计(Domain-Driven Design,简称DDD)是一种软件设计方法论,它强调基于业务领域的复杂性来构建软件
9 2
|
1天前
|
开发框架 监控 Java
深入探索Spring Boot的监控、管理和测试功能及实战应用
【5月更文挑战第14天】Spring Boot是一个快速开发框架,提供了一系列的功能模块,包括监控、管理和测试等。本文将深入探讨Spring Boot中监控、管理和测试功能的原理与应用,并提供实际应用场景的示例。
14 2
|
1天前
|
Java Spring 容器
深入理解Spring Boot启动流程及其实战应用
【5月更文挑战第9天】本文详细解析了Spring Boot启动流程的概念和关键步骤,并结合实战示例,展示了如何在实际开发中运用这些知识。
18 2
|
1天前
|
JavaScript Java 开发者
Spring Boot中的@Lazy注解:概念及实战应用
【4月更文挑战第7天】在Spring Framework中,@Lazy注解是一个非常有用的特性,它允许开发者控制Spring容器的bean初始化时机。本文将详细介绍@Lazy注解的概念,并通过一个实际的例子展示如何在Spring Boot应用中使用它。
21 2
|
1天前
|
Java 调度 Maven
Springboot实战篇--Springboot框架通过@Scheduled实现定时任务
Spring Boot的Scheduled定时任务无需额外Maven依赖,通过`@EnableScheduling`开启。任务调度有两种方式:fixedRate和fixedDelay,前者任务结束后立即按设定间隔执行,后者在任务完成后等待设定时间再执行。更灵活的是cron表达式,例如`0 0 3 * * ?`表示每天3点执行。实现定时任务时,需注意默认单线程执行可能导致的任务交错,可通过自定义线程池解决。
http://www.vxiaotou.com