背景:积分项目,每次添加的积分都有一个有效期,有效期为一年,如2017-01-02添加了一条积分记录,到2018-01-02这条记录应该是过时的。当前项目设计有两张表:积分明细表(存放积分添加、使用明细)、积分总额表(用户当前的积分额度)。因为每条积分的过时时间各不相同,如何正确地将过时的积分做废?消费时,如何优先使用即将过时的积分?java
刚开始系统有两张表:积分明细表、积分总额表,积分总额直接由积分明细表统计。app
如下是积分明细表,须要将内容展现给用户,让用户知道本身积分的添加、消耗状况:性能
记录id | 会员id | 积分值 | 添加时间 | 过时时间 | 备注 |
---|---|---|---|---|---|
1 | 1 | 10 | 2017-01-02 | 2018-01-02 | 新增积分 |
2 | 1 | 20 | 2017-01-04 | 2018-01-04 | 新增积分 |
3 | 1 | -30 | 2017-01-08 | 2018-01-08 | 使用积分 |
假设id为1的会在2017-01-08后,再无积分添加与消耗的状况。设计
如今有一张积分总额表,记录的了会员的积分额度,因为积分是过时的,那么按不一样时间来统计,就会出现如下状况:code
在2018-01-01统计时,id为1的会员积分额度是0,这没问题。排序
会员id | 积分总值 | 更新时间 |
---|---|---|
1 | 0 | 2018-01-01 |
那在2018-01-02统计时呢,记录id为1的记录已通过期了,只统计记录id为2与3的记录,会出现如下状况:get
会员id | 积分总值 | 更新时间 |
---|---|---|
1 | -10 | 2018-01-02 |
在2018-01-04统计时,记录id为1与3的记录已通过期了,只统计记录id为3的记录,差额就更大了:it
会员id | 积分总值 | 更新时间 |
---|---|---|
1 | -30 | 2018-01-04 |
只有在2018-01-08统计时,记录id为一、二、3的记录已通过期了,积分值才会正常:io
会员id | 积分总值 | 更新时间 |
---|---|---|
1 | 0 | 2018-01-08 |
从上面的状况来看,单纯从积分明细表来统计,会出现积分值为负数的状况。table
项目当前的方案中,积分明细表记录了用户使用添加与使用状况,须要展示给用户,因此没法在这上面下手,为此新添加了一张表来记录当前可用积分明细。该表的关键字段以下:
字段 | 含义 |
---|---|
积分值 | 该记录的积分值 |
添加时间 | 该记录的添加时间 |
过时时间 | 该记录的过时时间 |
如,在2017-01-02该会员的可用积分记录为
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
100 | 1 | 10 | 2017-01-02 | 2018-01-02 |
在2017-01-04该会员的可用积分记录为
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
100 | 1 | 10 | 2017-01-02 | 2018-01-02 |
101 | 1 | 20 | 2017-01-04 | 2018-01-04 |
在2018-01-08该会员的可用积分记录为
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
因为当前会员无可用积分,因此表中记录为空。 |
新加了可用积分表后,后续用户的积分总额就能够直接从该表中统计了。
明白了大体原理后,接下来解决如下几个问题。
以会员id为2的用户为例
可用积分表以下:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
103 | 2 | 10 | 2017-01-02 | 2018-01-02 |
104 | 2 | 20 | 2017-01-04 | 2018-01-04 |
105 | 2 | 20 | 2017-01-06 | 2018-01-06 |
积分明细表以下:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 | 备注 |
---|---|---|---|---|---|
4 | 2 | 10 | 2017-01-02 | 2018-01-02 | 新增积分 |
5 | 2 | 20 | 2017-01-04 | 2018-01-04 | 新增积分 |
6 | 2 | 20 | 2017-01-06 | 2018-01-06 | 新增积分 |
积分总额表以下:
会员id | 积分总值 | 更新时间 |
---|---|---|
2 | 50 | 2018-01-01 |
在2018-01-02统计该用户的可用积分时,发现有一条记录id为103的记录已过时,那么统计完以后,各表变化以下:
可用积分表及时删除过时记录:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
104 | 2 | 20 | 2017-01-04 | 2018-01-04 |
105 | 2 | 20 | 2017-01-06 | 2018-01-06 |
积分明细表添加一条过时明细:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 | 备注 |
---|---|---|---|---|---|
4 | 2 | 10 | 2017-01-02 | 2018-01-02 | 新增积分 |
5 | 2 | 20 | 2017-01-04 | 2018-01-04 | 新增积分 |
6 | 2 | 20 | 2017-01-06 | 2018-01-06 | 新增积分 |
7 | 2 | -10 | 2018-01-02 | - | 积分过时 |
积分总额表更新为正确的积分总额:
会员id | 积分总值 | 更新时间 |
---|---|---|
2 | 40 | 2018-01-04 |
小结:积分过时时,可用积分表删除过时记录,积分明细表添加一条过时明细,积分总额表更新为当前积分总额。
那么积分过时在何时触发呢?能够有如下方案:
第一种方案须要所有遍历会员表,若是会员表太大,效率低下,并且若是会员并无过时积分,会作许多无效的统计。第二种方案采用被动触发的形式,虽然也会有无效的积分统计,未能及时清理过时积分,但避免了积分的会员表的全表扫描,性能略高。第三种方案从过时积分入手,主动触发,能及时清理过时积分,只针对过时积分,没有无效的统计,性能优于前两种。
积分使用策略以下:
可用积分表
的可用积分记录按过时时间升序排列,依次累加积分额度sumPoint直到sumPoint>=point
或记录所有遍历完,用recordIds记录符合要求的积分id,用targetRecord记录最后一条积分记录。(sumPoint-point)
),另外一条记录积分剩余(额度为最后一条记录的额度-(sumPoint-point)
,过时时间为最后一条记录的过时时间)。仍是以会员id为2的用户为例,用户各表以下:
可用积分表以下:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
103 | 2 | 10 | 2017-01-02 | 2018-01-02 |
104 | 2 | 20 | 2017-01-04 | 2018-01-04 |
105 | 2 | 20 | 2017-01-06 | 2018-01-06 |
积分明细表以下:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 | 备注 |
---|---|---|---|---|---|
4 | 2 | 10 | 2017-01-02 | 2018-01-02 | 新增积分 |
5 | 2 | 20 | 2017-01-04 | 2018-01-04 | 新增积分 |
6 | 2 | 20 | 2017-01-06 | 2018-01-06 | 新增积分 |
积分总额表以下:
会员id | 积分总值 | 更新时间 |
---|---|---|
2 | 50 | 2017-12-01 |
假设该用户在2017-12-01须要使用40积分,使用过程以下:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
103 | 2 | 10 | 2017-01-02 | 2018-01-02 |
104 | 2 | 20 | 2017-01-04 | 2018-01-04 |
105 | 2 | 10 | 2017-01-06 | 2018-01-06 |
106 | 2 | 10 | 2017-01-06 | 2018-01-06 |
id为106的记录由105拆出来的,过时时间与105相同,如今105的积分值(10)+如今的106的积分值(10)=原来的105的积分值(20)
记录id | 会员id | 积分值 | 添加时间 | 过时时间 |
---|---|---|---|---|
106 | 2 | 10 | 2017-01-06 | 2018-01-06 |
积分明细表以下:
记录id | 会员id | 积分值 | 添加时间 | 过时时间 | 备注 |
---|---|---|---|---|---|
4 | 2 | 10 | 2017-01-02 | 2018-01-02 | 新增积分 |
5 | 2 | 20 | 2017-01-04 | 2018-01-04 | 新增积分 |
6 | 2 | 20 | 2017-01-06 | 2018-01-06 | 新增积分 |
7 | 2 | -40 | 2017-12-01 | - | 使用积分 |
积分总额表以下:
会员id | 积分总值 | 更新时间 |
---|---|---|
2 | 10 | 2017-12-01 |
相关的java代码以下:
int pageNo = 0; int pageSize = 10; int sumPoint = 0; //目标记录 PointRecord targetRecord = null; //保存要更新的recordId List<Long> recordIds = new ArrayList<>(); //查询可用积分记录 PointRecordSearch search = new PointRecordSearch(); search.setMemberId(memberId); search.setOrderFields(" expire_time ASC "); while(sumPoint < point) { search.setStart(pageNo * pageSize); search.setLimit(pageSize); List<PointRecord> pointRecords = pointRecordMapper.queryForPages(search); if(CollectionUtils.isEmpty(pointRecords)) { break; } for(PointRecord pointRecord : pointRecords) { //累加,直到值大于等于point sumPoint += pointRecord.getPoint(); if(sumPoint >= point) { targetRecord = pointRecord; break; } //记录相应的id值 recordIds.add(pointRecord.getRecordId()); } pageNo++; } if(sumPoint < point) { //当前积分不足以消耗 return false; } else if(sumPoint == point) { //加上最后一条记录的值后,总额恰好等于使用额度 recordIds.add(targetRecord.getRecordId()); } else { // 加上最后一条记录的值后,总额恰好大于使用额度,此时须要将最后一条记录拆成两条记录 int leftPoint = sumPoint - point; int usePoint = targetRecord.getPoint() - leftPoint; //添加一条记录 PointRecord newPointRecord = new PointRecord(); newPointRecord.setCreateTime(targetRecord.getCreateTime()); newPointRecord.setExpireTime(targetRecord.getExpireTime()); newPointRecord.setMemberId(targetRecord.getMemberId()); newPointRecord.setPoint(leftPoint); newPointRecord.setUpdateTime(new Date()); pointRecordMapper.insertValues(newPointRecord); //修改最后一条记录的积分值 PointRecord updateModel = new PointRecord(); updateModel.setRecordId(targetRecord.getRecordId()); updateModel.setPoint(usePoint); pointRecordMapper.updateById(updateModel); } //按id删除记录 pointRecordMapper.deleteByIds(recordIds); //处理积分明细 PointDetail detail = new PointDetail(); detail.setCreateTime(new Date()); detail.setMemberId(memberId); detail.setPoint(-point); detail.setDesc("使用积分"); pointDetailMapper.add(detail); //处理积分总额 PointTotal pointTotal = new PointTotal(); pointTotal.setId(memberId); pointTotal.setPoint(pointRecordMapper.sumByMemberId(memberId)); pointTotalMapper.updateById();
总结:积分过时问题的难点在于每条积分都有过时时间,很差把控。引入了一张新表后,使积分明细与可用积分得以分离,明细表仅展现用户的积分添加与使用记录,用户的可用积分额度由该表进行统计,这样积分的过时问题就完美获得了解决。