where('id', $params['user_id'])->setInc('score', $params['price']); // 记录日志 $this->addScore($params['user_id'], $params['price'], '订单奖励'); } /** * 发帖增加积分 * * @param [type] $params * @return void */ public function messageAdd($params) { $this->addScore($params['user_id'], 5, '发起话题'); } /** * 评论增加积分 * * @param [type] $params * @return void */ public function commentAdd($params) { $this->addScore($params['user_id'], 1, '话题被评论'); } /** * 增加积分 * * @param [type] $user_id * @param [type] $score * @return void */ public function addScore($user_id, $score, $memo) { // 查询修改前积分 $before = Db::name('user')->where('id', $user_id)->value('score'); $log = [ 'user_id' => $user_id, 'score' => $score, 'before' => $before, 'after' => $before + $score, 'memo' => $memo, 'createtime' => time(), ]; Db::name('user')->where('id', $user_id)->setInc('score', $score); Db::name('user_score_log')->insert($log); } }