注册&实名赠送积分

app/common/repositories/user/UserRepository.php

@@ -933,6 +933,47 @@ class UserRepository extends BaseRepository
         return $user;
     }
 
+        /**
+     * @param int $uid 用户ID
+     * @param string $score 积分
+     * @param int $status 积分状态
+     * @param string $mark 备注
+     * @param string $has_qian 连续签到天数
+     * @param string $today_signintime 签到时间
+     * @param int $order_id 订单ID
+     * @param int $pm 1-收入。2-支出
+     * @param string $order_type
+     * @throws DbException
+     */
+    public function sign_add($uid, $score, $status, $mark, $has_qian = '', $today_signintime = '', $order_id = 0, $pm = 1, $order_type = '',$type='',$settlement_time = '')
+    {
+        if(!in_array($type,[1,2])){
+            // 其他情况都直接返回，因为目前只有365专区购买才可以获得
+            return false;
+        }
+
+        $ins_data['uid'] = $uid;
+        $ins_data['continuity_day'] = $has_qian;
+        $ins_data['reward_socre'] = $score;
+        $ins_data['signin_time'] = $today_signintime;
+        $ins_data['addtime'] = time();
+        $ins_data['status'] = $status;
+        $ins_data['mark'] = $mark;
+        $ins_data['type'] = $type;
+        $ins_data['settlement_time'] = $settlement_time;// 结算时间 真正到了结算时间会结算
+        $ins_data['order_id'] = $order_id;
+        $ins_data['pm'] = $pm;
+        $ins_data['order_type'] = $order_type;
+        Db::name('user_sign_score')->insertGetId($ins_data);
+
+        if($pm == 1 && $status == 1){
+            Db::name('user')->where('uid',$uid)->inc('score', $score)->update();
+        }
+        if($pm == 2){
+            Db::name('user')->where('uid', $uid)->dec('score', $score)->update();
+        }
+    }
+
     /**
      * @param string $type
      * @param array $userInfo
@@ -962,6 +1003,9 @@ class UserRepository extends BaseRepository
 //
 //            Queue::push(SendNewPeopleCouponJob::class, $user->uid);
 
+            //赠送积分 注册送10积分
+            $this->sign_add($user['uid'], 10,1,'注册送10积分','','');
+
             Db::commit();
             return $user;
         } catch (\Exception $e) {

app/controller/api/user/User.php

@@ -720,6 +720,14 @@ class User extends BaseController
             $params['status'] = 1;
             $res = $this->repository->add_cer($params, $member_id);
             if ($res) {
+                //赠送积分 完善实名送20个积分，同时送邀请人20个积
+                $this->sign_add($member_id, 20,1,'完善实名系统赠送20个积分','','');
+                $member_info = Db::name('user')->where( array('uid' => $member_id) )->find(); 
+                if($member_info['spread_uid']){
+                     //首次邀请好友奖励积分
+                    $spreadUid = $member_info['spread_uid'];
+                    $this->sign_add($spreadUid, 20,1,'好友完善实名系统赠送20个积分','','');
+                }
                 return app('json')->success($res);
             } else {
                 return app('json')->fail('认证失败');
@@ -730,6 +738,48 @@ class User extends BaseController
 
     }
 
+
+        /**
+     * @param int $uid 用户ID
+     * @param string $score 积分
+     * @param int $status 积分状态
+     * @param string $mark 备注
+     * @param string $has_qian 连续签到天数
+     * @param string $today_signintime 签到时间
+     * @param int $order_id 订单ID
+     * @param int $pm 1-收入。2-支出
+     * @param string $order_type
+     * @throws DbException
+     */
+    public function sign_add($uid, $score, $status, $mark, $has_qian = '', $today_signintime = '', $order_id = 0, $pm = 1, $order_type = '',$type='',$settlement_time = '')
+    {
+        if(!in_array($type,[1,2])){
+            // 其他情况都直接返回，因为目前只有365专区购买才可以获得
+            return false;
+        }
+
+        $ins_data['uid'] = $uid;
+        $ins_data['continuity_day'] = $has_qian;
+        $ins_data['reward_socre'] = $score;
+        $ins_data['signin_time'] = $today_signintime;
+        $ins_data['addtime'] = time();
+        $ins_data['status'] = $status;
+        $ins_data['mark'] = $mark;
+        $ins_data['type'] = $type;
+        $ins_data['settlement_time'] = $settlement_time;// 结算时间 真正到了结算时间会结算
+        $ins_data['order_id'] = $order_id;
+        $ins_data['pm'] = $pm;
+        $ins_data['order_type'] = $order_type;
+        Db::name('user_sign_score')->insertGetId($ins_data);
+
+        if($pm == 1 && $status == 1){
+            Db::name('user')->where('uid',$uid)->inc('score', $score)->update();
+        }
+        if($pm == 2){
+            Db::name('user')->where('uid', $uid)->dec('score', $score)->update();
+        }
+    }
+
     /**
      * 申请代理
      * name:公司名称