注册发放钻石

application/api/controller/User.php

@@ -381,6 +381,24 @@ class User extends Api
                         $user->save($fields);
 
                         Db::commit();
+                        //增加钻石
+                        //开启事务
+                        Db::startTrans();
+                        //修改用户钻石余额
+                        $res1 = Db::name('user')->where(['id' => $user->id])->setField('diamond', 100);
+                        // 添加钻石明细
+                        $_data['user_id'] = $user->id;
+                        $_data['diamond'] = 100;
+                        $_data['before'] = 0;
+                        $_data['after'] = 100;
+                        $_data['memo'] = '注册';
+                        $_data['createtime'] = time();
+                        $res2 = Db::name('user_diamond_log')->insertGetId($_data);
+                        if ($res1 && $res2) {
+                            Db::commit();
+                        } else {
+                            Db::rollback();
+                        }
                     } catch (PDOException $e) {
                         Db::rollback();
                         $auth->logout();

application/common/library/Auth.php

@@ -215,6 +215,25 @@ class Auth
             //注册成功的事件
             Hook::listen("user_register_successed", $this->_user, $data);
             Db::commit();
+
+            //增加钻石
+            //开启事务
+            Db::startTrans();
+            //修改用户钻石余额
+            $res1 = Db::name('user')->where(['id' => $user->id])->setField('diamond', 100);
+            // 添加钻石明细
+            $_data['user_id'] = $user->id;
+            $_data['diamond'] = 100;
+            $_data['before'] = 0;
+            $_data['after'] = 100;
+            $_data['memo'] = '注册';
+            $_data['createtime'] = time();
+            $res2 = Db::name('user_diamond_log')->insertGetId($_data);
+            if ($res1 && $res2) {
+                Db::commit();
+            } else {
+                Db::rollback();
+            }
         } catch (Exception $e) {
             $this->setError($e->getMessage());
             Db::rollback();