实战:如果让你用SpringBoot实现签到奖励的功能,你会怎么做?
程序员的成长之路
共 11813字,需浏览 24分钟
·
2020-11-03 17:53
阅读本文大概需要 6 分钟。
来自:网络
前言
快速实现(不需要做太重,满足初期推广运营即可)
快速投入市场去运营
用户在每次启动时查询签到记录(规则:连续7日签到从0开始,签到过程中有断签从0开始)
如果今日未签到则提示用户可以进行签到
用户签到获取相应的奖励
需要记录每位用户每天的签到情况
查询时根据规则进行签到记录情况
需求&流程设计&技术实现方案
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='用户签到历史表';
代码实现
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);
}
}
/*
* 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.*;
public class SignInServiceImpl implements SignInService {
private XZhSignInMapper xZhSignInMapper;
private XZhSignInHistMapper xZhSignInHistMapper;
//校验连续天数是否为7
"#{T(java.lang.Integer).parseInt('${zh.sign.in.continuite.day.threshold:7}')}") (
public Integer continuiteDayThreshold;
//签到奖励金币集合配置
public SignInRewardMoneyListConfig signInRewardMoneyListConfig;
/**
* 查询用户签到记录
*/
public Object listSignInDetail(ListSignInDetailRequest listSignInDetailRequest) {
//若配置文件中未配置签到奖励则不展示签到记录
List
signInRewardMoneyListConfigList = signInRewardMoneyListConfig.getList(); if (CollectionUtils.isEmpty(signInRewardMoneyListConfigList)) {
return WrapMapper.ok(new ListSignInDetailResponse(false));
}
String customerId = listSignInDetailRequest.getCustomerId();
XZhSignInEntity xZhSignInEntity = xZhSignInMapper.findByCustomerId(customerId);
List
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
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));
}
/**
* 进行签到
*/
public Object postSignIn(PostSignInRequest postSignInRequest) {
//若配置文件中未配置签到奖励则不展示签到记录
List
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);
}
}
测试
模拟用户进行签到
进行请求
查看数据库结果
模拟用户查询签到记录
进行请求
总结
亮点:实现业务连续签到,断签以及奖励的业务
注意点:基于数据库查询做的,在进行签到接口需要用redis锁防止并发操作
后续会持续分享更多业务中的亮点
别忘记点个在看,咱们下篇见!
慢一点才能更快
StackOverflow热帖:Java整数相加溢出怎么办?Java8一步搞定~
微信扫描二维码,关注我的公众号
朕已阅
评论