thinkphp6.x积分系统通过user、point_log、point_goods三表实现签到、消费、兑换全流程管理,依托事务与状态机保障数据一致性,并提供对账修复机制。

在ThinkPHP6.x框架中构建积分系统时,用户签到、消费及积分兑换需围绕统一的积分账户模型展开,确保数据一致性与事务安全性。以下是实现该逻辑的具体设计步骤:
一、数据库表结构设计
积分系统依赖三张核心数据表:用户基础表(user)、积分流水表(point_log)和积分商品表(point_goods)。其中积分流水表必须记录操作类型、变动值、关联ID及事务状态,用于追溯与对账。
1、在数据库中创建point_log表,字段包括id(主键)、user_id(用户ID)、type(操作类型:1=签到、2=消费、3=兑换)、amount(变动积分,正为增加、负为扣除)、related_id(关联订单或商品ID)、status(0=待处理、1=成功、-1=失败)、created_at(时间戳)。
2、创建point_goods表,字段包括id、title(商品名称)、point_price(所需积分)、stock(库存)、is_enabled(是否启用),并为point_price和stock添加索引以提升查询效率。
3、确保user表中存在point字段(INT类型,默认0),用于实时反映用户当前可用积分,该字段仅作展示用途,所有变更必须通过流水驱动。
二、签到积分逻辑实现
每日签到需限制同一用户当天仅可成功签到一次,并支持连续签到奖励叠加。逻辑需在应用层校验时间范围与历史记录,避免数据库重复插入。
1、调用Db::table('point_log')->where(['user_id' => $uid, 'type' => 1])->where('created_at', '>=', date('Y-m-d 00:00:00'))->find()查询当日是否存在签到记录。
2、若无记录,则使用Db::transaction()开启事务,先向point_log插入一条type=1、amount=+10的记录,再执行Db::name('user')->where('id', $uid)->setInc('point', 10)更新用户积分。
3、若存在连续签到天数字段(如user表中sign_days),则在插入前查询最近连续签到日期,若昨日已签到则递增sign_days,否则重置为1;当sign_days达到7时,额外追加50点奖励积分并写入第二条流水。
三、消费扣减积分逻辑
用户在下单时选择使用积分抵扣,需同步校验积分余额、冻结未支付订单的积分占用,并在支付成功后完成实际扣除。该过程必须防止超扣与并发冲突。
1、在订单提交接口中,读取用户当前point值,判断是否≥请求抵扣值,若不满足则返回错误:“积分余额不足”。
2、调用Db::name('point_log')->insert(['user_id'=>$uid, 'type'=>2, 'amount'=>-$deduct, 'related_id'=>$order_id, 'status'=>0, 'created_at'=>date('Y-m-d H:i:s')])生成预占流水,status设为0表示待确认。
3、在支付成功回调中,使用where条件[‘user_id’=>$uid, ‘related_id’=>$order_id, ‘type’=>2, ‘status’=>0]锁定该流水,更新其status为1,并同步执行Db::name('user')->where('id',$uid)->setDec('point',$deduct)。
四、积分兑换商品逻辑
兑换操作需校验商品库存、用户积分、商品启用状态,并确保兑换与库存扣减原子性。失败时须回滚已生成的流水记录。
1、查询point_goods表中id=$goods_id的记录,检查is_enabled是否为1且stock > 0,任一不满足则终止流程并提示:“商品不可用或库存不足”。
2、使用Db::transaction()包裹以下操作:插入type=3的point_log记录(amount为负值)、执行Db::name('user')->setDec('point',$goods['point_price'])、Db::name('point_goods')->where('id',$goods_id)->setDec('stock',1)。
3、若任意一步抛出异常,则整个事务回滚,已插入的point_log记录将被撤销,保证积分与库存状态始终一致。
五、积分流水对账与修复机制
因网络超时或程序中断可能导致point_log与user.point值不一致,需提供独立对账脚本定期比对,并支持人工触发修复。
1、执行SQL语句SELECT user_id, SUM(amount) AS total FROM point_log WHERE status = 1 GROUP BY user_id,获取各用户理论积分总和。
2、对比结果集与user表中对应user_id的point字段值,筛选出差异记录,输出格式为:user_id=123,log_sum=850,user_point=820,差额=+30。
3、对差额非零的用户,提供修复命令行指令php think repair:point --uid=123,该指令将自动更新user.point为log_sum值,并记录修复日志到repair_log表。
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











