-------需求说明

---- 需求分析

积分签到处于app页面“我的”，用户会频繁的来回切换，如果将数据全部存储到数据库中然后去数据库中做查询，所以这里我才用的Redis缓存的方式将签到数据缓存起来；

在表结构设计的时候，由于需求还没有完全确定下来，所以签到规则等信息还不是很明确，这里配置了两个表，一个积分签到表，一个积分配置表；

CREATE TABLE `np_customer_sign_info` (

`sign_info_id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '主键',

`rule_name` varchar(50) DEFAULT NULL COMMENT '规则名称、说明',

`sign_info_type` varchar(30) DEFAULT NULL COMMENT ' 积分类型名称',

`rule_key` varchar(20) DEFAULT NULL COMMENT '规则Key值(redis缓存或者mysql查询) ',

`rule_grade` int(10) DEFAULT NULL COMMENT '规则对应积分值',

`rule_type` enum('1','2','3') DEFAULT NULL COMMENT '规则类型 1 累加 2 翻倍 3 其他',

`create_time` timestamp NULL DEFAULT NULL COMMENT '创建时间',

`del_flag` enum('0','1') DEFAULT '0' COMMENT '删除标志 0正常 1删除',

PRIMARY KEY (`sign_info_id`),

KEY `redis_key` (`rule_key`) USING BTREE

) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8 COMMENT='会员签到积分配置表';

积分签到表

CREATE TABLE `np_customer_sign_grade` (

`grade_id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '签到id',

`customer_id` bigint(20) NOT NULL COMMENT '会员id',

`grade__flow_id` bigint(30) DEFAULT NULL COMMENT '积分流水号',

`grade_detail` varchar(75) DEFAULT NULL COMMENT '积分说明',

`grade_type` enum('0','1') NOT NULL COMMENT '积分类型 0获取积分 1消费积分',

`grade` int(20) NOT NULL COMMENT '积分',

`succ_record` int(2) DEFAULT NULL COMMENT '连续签到记录数',

`create_time` timestamp NOT NULL COMMENT '创建时间',

`create_date` varchar(50) NOT NULL COMMENT '创建日期',

`del_flag` enum('0','1') NOT NULL COMMENT '删除标志 0未删除 1已删除',

PRIMARY KEY (`grade_id`)

) ENGINE=InnoDB AUTO_INCREMENT=223 DEFAULT CHARSET=utf8 COMMENT='会员签到积分表';

为了避免页面刷新频繁查询数据库，所以我才用了将签到信息存储到Redis中的方式进行存储，这样每次刷新页面的时候，可以直接在Redis中查询数据，从而避免频繁查询数据库；

由于每次签到都需要先校验昨天是否有签到记录，然后之后就不再查询两天前的数据，所以这里为每一个签到数据设置了一个过期时间，避免签到无用的签到数据占用服务器内存空间，以提高Redis效率；redis设置的过期时间为2天；

在最初写代码的时候，我想的是将用户的签到信息用Hash结构存储到Redis中，因为Hash可以直接存储对象，但是在设置过期时间的时候遇到了坎，Redis不支持对Hash设置过期时间，网上查询了一下，网友有提到过给Hash顶级K设置过期时间，亲测后，发现数据并不会失效。所以后来将签到数据序列化后储存到Redis中；

签到实体类实现序列化Serializable接口；

(关于Hash顶级K，在操作Hash结构时，put是三个参数，H、HK、HV)

----- 代码实现部分(签到接口)

@Service

public class Test {

private static String ZERO = "0";

private static String SUCC = "200";

/*** Redis初始积分配置 如: 第一天签到奖励积分值为*/

private String STASIGNGRADEDISPOSE = "STASIGNGRADEDISPOSE";

/*** Redis累加积分配置 如: 第一天签到奖励2分，第二天签到在前一天基础上加2分或者倍数*/

private String ADDSIGNGRADEDISPOSE = "ADDSIGNGRADEDISPOSE";

/*** Redis单周最高奖励积分配置 如: 第一天连续签到到第七天，第七天奖励积分为：20*/

private String MAXSIGNGRADEDISPOSE = "MAXSIGNGRADEDISPOSE";

Logger LOGGER = LoggerFactory.getLogger(NpCustomerSignGradeService.class);

@Autowired

private NpCustomerSignGradeRepository signGradeRepository;

@Autowired

private RedisTemplate redisTemplate;

@Autowired

private NpCustomerSignInfoRepository signInfoRepository;

/*** @author: JiaYao* @demand: 用户签到接口* @parameters:* @creationDate： 2018/8/16 0017 13:32*/

public Response sign(Long customerId) {

Response response = new Response();

Date date = new Date();

// 获取今天的日期 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");

String dateString = sdf.format(date);

LOGGER.info("-----今天是:" + dateString + "日-----");

// 获取昨天的日期 Calendar calendar = Calendar.getInstance();

calendar.setTime(date);

calendar.add(Calendar.DATE, -1);

Date date1 = calendar.getTime();

String yesterday = sdf.format(date1);

// 获取今天的签到信息 NpCustomerSignGrade todaySing = (NpCustomerSignGrade) redisTemplate.opsForValue().get(customerId + dateString);

// 获取昨天的签到信息 NpCustomerSignGrade yesterdaySing = (NpCustomerSignGrade) redisTemplate.opsForValue().get(customerId + yesterday);

// 第一次签到签到规则 NpCustomerSignInfo sta = (NpCustomerSignInfo) redisTemplate.opsForValue().get(STASIGNGRADEDISPOSE);

if (sta == null) {

sta = signInfoRepository.findGradeByRuleKey(STASIGNGRADEDISPOSE);

redisTemplate.opsForValue().set(STASIGNGRADEDISPOSE, sta);

}

// 获取续签规则 NpCustomerSignInfo add = (NpCustomerSignInfo) redisTemplate.opsForValue().get(ADDSIGNGRADEDISPOSE);

// 获取续签规则 if (add == null) {

add = signInfoRepository.findGradeByRuleKey(ADDSIGNGRADEDISPOSE);

redisTemplate.opsForValue().set(ADDSIGNGRADEDISPOSE, add);

}

// 获取满签规则 NpCustomerSignInfo max = (NpCustomerSignInfo) redisTemplate.opsForValue().get(MAXSIGNGRADEDISPOSE);

if (max == null) {

max = signInfoRepository.findGradeByRuleKey(MAXSIGNGRADEDISPOSE);

redisTemplate.opsForValue().set(MAXSIGNGRADEDISPOSE, max);

}

NpCustomerSignGrade customerSignGrade = new NpCustomerSignGrade();

int grade ;

// 当今天还没有签到 if (todaySing == null) {

LOGGER.info("今天还没有签到过，可以进行签到操作~--" + customerId);

if (yesterdaySing == null) {

LOGGER.info("昨天还没有签到，今天是第一天签到哦~--" + customerId);

grade = sta.getRuleGrade();

customerSignGrade.setGradeDetail(sta.getSignInfoType());

customerSignGrade.setCreateDate(dateString);

customerSignGrade.setCreateTime(date);

customerSignGrade.setCustomerId(customerId);

customerSignGrade.setDelFlag(ZERO);

customerSignGrade.setGrade(grade);

customerSignGrade.setGradeFlowId(Long.parseLong(genOrderCode()));

customerSignGrade.setGradeType(ZERO);

customerSignGrade.setSuccRecord(1);

signGradeRepository.save(customerSignGrade);

LOGGER.info("今天是用户" + customerId + "第1天签到,获得积分" + grade + "分~");

/*** 将签到信息以Hash形式存储到Redis中，并设定过期时间为2天*/

redisTemplate.opsForValue().set(customerId + dateString, customerSignGrade, 2, TimeUnit.DAYS);

response.setCode(SUCC);

response.setFlag(true);

response.setMessage(grade + "");

response.setStandby(grade + add.getRuleGrade() + "");

return response;

} else {

LOGGER.info("昨天有签到记录~--" + customerId);

if (yesterdaySing.getSuccRecord() < 6) {

grade = yesterdaySing.getGrade();

// 获取昨天签到获取的积分数 customerSignGrade.setGradeDetail(add.getSignInfoType());

customerSignGrade.setCreateDate(dateString);

customerSignGrade.setCreateTime(date);

customerSignGrade.setCustomerId(customerId);

customerSignGrade.setDelFlag(ZERO);

if ("1".equals(add.getRuleType())) {

// 累加规则 grade = grade + add.getRuleGrade();

}

if ("2".equals(add.getRuleType())) {

// 倍增规则 grade = grade * (add.getRuleGrade());

}

customerSignGrade.setGrade(grade);

customerSignGrade.setGradeFlowId(Long.parseLong(genOrderCode()));

customerSignGrade.setGradeType(ZERO);

customerSignGrade.setSuccRecord(yesterdaySing.getSuccRecord() + 1);

signGradeRepository.save(customerSignGrade);

LOGGER.info("今天是用户" + customerId + "持续第" + (yesterdaySing.getSuccRecord() + 1) + "天签到,获得积分" + grade + "分~");

redisTemplate.opsForValue().set(customerId + dateString, customerSignGrade, 2, TimeUnit.DAYS);

response.setCode(SUCC);

response.setFlag(true);

response.setMessage(grade + "");

if (yesterdaySing.getSuccRecord() == 5) {

response.setStandby(max.getRuleGrade() + "");

} else {

response.setStandby(grade + add.getRuleGrade() + "");

}

return response;

} else if (yesterdaySing.getSuccRecord() == 6) {

// 本周满签 customerSignGrade.setGradeDetail(max.getSignInfoType());

customerSignGrade.setCreateDate(dateString);

customerSignGrade.setCreateTime(date);

customerSignGrade.setCustomerId(customerId);

customerSignGrade.setDelFlag(ZERO);

grade = max.getRuleGrade();

customerSignGrade.setGrade(grade);

customerSignGrade.setGradeFlowId(Long.parseLong(genOrderCode()));

customerSignGrade.setGradeType(ZERO);

customerSignGrade.setSuccRecord(yesterdaySing.getSuccRecord() + 1);

signGradeRepository.save(customerSignGrade);

LOGGER.info("今天是用户" + customerId + "持续第" + (yesterdaySing.getSuccRecord() + 1) + "天签到,获得积分" + grade + "分~");

redisTemplate.opsForValue().set(customerId + dateString, customerSignGrade, 2, TimeUnit.DAYS);

response.setCode(SUCC);

response.setFlag(true);

response.setMessage(grade + "");

return response;

} else if (yesterdaySing.getSuccRecord() == 7) {

// 满签一周，续第二周第一签 grade = sta.getRuleGrade();

customerSignGrade.setGradeDetail(sta.getSignInfoType());

customerSignGrade.setCreateDate(dateString);

customerSignGrade.setCreateTime(date);

customerSignGrade.setCustomerId(customerId);

customerSignGrade.setDelFlag(ZERO);

customerSignGrade.setGrade(grade);

customerSignGrade.setGradeFlowId(Long.parseLong(genOrderCode()));

customerSignGrade.setGradeType(ZERO);

customerSignGrade.setSuccRecord(1);

signGradeRepository.save(customerSignGrade);

LOGGER.info("今天是用户" + customerId + "第1天签到,获得积分" + grade + "分~");

redisTemplate.opsForValue().set(customerId + dateString, customerSignGrade, 2, TimeUnit.DAYS);

response.setCode(SUCC);

response.setFlag(true);

response.setMessage(grade + "");

response.setStandby(grade + add.getRuleGrade() + "");

return response;

}

}

}

response.setCode(SUCC);

response.setFlag(false);

response.setMessage("今天已经签到过了哦~");

return response;

}

---- 查询用户总积分数

/**

* @author: JiaYao

* @demand: 查询用户总积分数

* @parameters:

* @creationDate： 2018/8/16 16:23

*/

public WelfareResponse findCustomerSignGrade(Long customerId) {

WelfareResponse response = new WelfareResponse();

Long signGrade = signGradeRepository.findCustomerSignGrade(customerId);

response.setCode(SUCC);

response.setFlag(true);

response.setMessage(signGrade == null ? "0" : signGrade + "");

LOGGER.info("用户" + customerId + "目前累计积分数为：" + (signGrade == null ? "0" : signGrade + ""));

return response;

}

--- 查询今天是否已经签到

/**

* @author: JiaYao

* @demand: 查询用户今天是否已经签到

* @parameters:

* @creationDate： 2018/8/16 16:18

*/

public Response isSign(Long customerId) {

Response response = new Response();

SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");

String dateString = sdf.format(new Date());

// 先从redis中获取当天用户有签到记录没

NpCustomerSignGrade todaySing = (NpCustomerSignGrade) redisTemplate.opsForValue().get(customerId + dateString);

if (todaySing == null) {

// 没有签到

response.setFlag(false);

response.setMessage("今天还没有签到哦~");

LOGGER.info("用户" + customerId + "今天还没有签到了~");

} else {

// 已经签到

response.setFlag(true);

response.setMessage("今天已经签到过了哦~");

// 将成功签到次数进行返回

response.setStandby(todaySing.getSuccRecord() + "");

LOGGER.info("用户" + customerId + "今天已经签到过了~");

}

response.setCode(SUCC);

return response;

}签到效果图