通用钱包操作方法

application/common/model/Wallet.php

@@ -0,0 +1,171 @@
+<?php
+namespace app\common\model;
+use think\Model;
+use think\Db;
+/**
+ * 货币模型
+ */
+class Wallet extends Model
+{
+    /**
+     * 获取交易类型配置
+     * @return mixed
+     */
+    public function getlogtype($type = '')
+    {
+        $conf = config('wallet.logtype');
+        if($type){
+            return $conf[$type] ?: $type;
+        }
+        return $conf;
+    }
+
+    //获取钱包名称
+    public function getwalletname($name = ''){
+        $conf = config('wallet.moneyname');
+        if($name){
+            return $conf[$name] ?: $name;
+        }
+        return $conf;
+    }
+
+    /**
+     * 获取钱包余额
+     * @param string $username 用户编号
+     * @param string $wallet_name 指定钱包名
+     * @return array|float
+     */
+    public function getWallet($user_id = '', $wallet_name = '')
+    {
+        //所有钱包余额
+        $wallet = Db::name('user')->lock(true)->where(['id' => $user_id])->find();
+        if(!$wallet) {
+            abort(500,'钱包余额获取失败');
+        }
+
+        if($wallet_name) { //返回指定钱包
+            return isset($wallet[$wallet_name]) ? $wallet[$wallet_name] : 0;
+        } else { //返回所有钱包
+            return $wallet;
+        }
+    }
+
+
+    /**
+     *
+     * @param floatval $number 金额（正数进账，负数出账）
+     * @param $accountType 货币类型，money,score
+     * @param $logtype 日志的类型
+     * @param $remark  备注
+     * @param $user_id  用户id
+     * @param $table  来源表
+     * @param $data_id  表id
+     * @param $isAdmin 是否是管理员处理
+     * @return array
+     * @return array[status]
+     * @return array[msg]
+     * @return array[log_table]
+     * @return array[log_id]
+     */
+    public function lockChangeAccountRemain($user_id,$number,$mode,$before,$remark='',$logtype='',$accountType='money')
+    {
+        //初始化
+        $result = array(
+            'status'=>false,
+            'code' => 0, //报错时候采用
+            'msg'=>'',
+            'log_table' => '',
+            'log_id' => '',
+        );
+
+        //获取小数点
+        $point = $accountType == 'money' ? 2 : 0;
+        bcscale($point);
+
+        //钱包名称
+        $wallet_name = $this->getwalletname($accountType);
+
+        //正负数
+        if($mode == '-'){
+            $number = -$number;
+        }
+
+        //检测
+        $number = floatval( $number );
+        if( $number == 0 )
+        {
+            $result['msg'] = '交易金额:0';
+            return $result;
+        }
+        if(0 === bccomp($number, 0)){
+            $result['msg'] = '交易金额:0';
+            return $result;
+        }
+
+
+        //检测
+        $wallet = Db::name('user')->lock(true)->where(['id'=>$user_id])->find();
+        if(!$wallet)
+        {
+            $result['msg'] = '不存在的用户';
+            return $result;
+        }
+
+        if(bccomp(bcadd($wallet[$accountType], $number), 0) === -1)
+        {
+            $result['code'] = 10;
+            $result['msg'] = $wallet_name.'余额不足!';
+            return $result;
+        }
+
+        if(0 !== bccomp($number, 0))
+        {
+
+            //钱币记录
+            $data = array();
+            $data['user_id'] = $user_id;
+            $data['value'] = $number;
+            $data['mode'] = $mode;
+            $data['before'] = $wallet[$accountType];
+            $data['balance'] = bcadd($wallet[$accountType], $number);
+            $data['detail'] = $remark;
+            $data['createtime'] = time();
+            $data['log_type'] = $logtype;
+
+            //新的方式
+            $rs1 = Db::name('user')->where(['id'=>$user_id])->update([$accountType => $data['balance']]);
+
+            /////////////
+            $log_table = 'user_'.$accountType.'_log';
+
+            $rs2_id = Db::name($log_table)->insertGetId($data);
+
+            if($rs1 === false || $rs2_id === false){
+                $result['msg'] = '更新财务记录失败!';
+                return $result;
+            }
+
+            if( $rs1 !== false && $rs2_id !== false )
+            {
+                $result['status'] = true;
+                $result['msg'] = '账户余额已更新!';
+                $result['log_table'] = $accountType.'_log';
+                $result['log_id'] = $rs2_id;
+
+                return $result;
+            }
+            else
+            {
+                $result['msg'] = '更新财务记录失败!';
+                return $result;
+            }
+        } else {
+            $result['msg'] = '金额不足0.01';
+            return $result;
+        }
+
+    }
+
+
+
+}

application/extra/wallet.php

@@ -0,0 +1,22 @@
+<?php
+/**
+ * 钱包类型数组
+ */
+return [
+    'logtype' => [
+        //jewel, 从原有代码里找出来的
+        0  => '下单',   //减少
+        1  => '充值',  //增加
+        2  => '购买锤子',  //减少
+        3  => '赠送礼物',   //减少
+        4  => '声币兑换钻石',  //增加
+        5  => '开通贵族',    //先减少100，接着增加100，没看明白，可能是bug
+        6  => '购买装扮',    //减少
+        7  => '拒绝订单返还',    //增加
+        8  => '完成用户订单获得收益',    //增加
+    ],
+    'moneyname' => [
+        'jewel'    => '钻石',
+    ],
+
+];