xiaoshan/application/common/model/Wallet.php

<?php

namespace app\common\model;

use think\Model;
use think\Db;

/**
 * 货币模型
 */
class Wallet extends BaseModel
{
    // 日志变动类型
    const log_type = [
        1  => '系统调节',//money + -
        10  => '用户充值',//money +
        31 => '商城订单支付', //money -
        32 => '商城订单退款', //money +
        40 => '酒店预定',//money + -
        50 => '餐厅预定',//money + -
        60 => '老年大学活动报名',//money + -
        70 => '线下消费',//money + -

        //善豆
        101 => '签到', //bean +
        102 => '完成任务', //bean +
        131 => '商城订单支付抵扣', //bean -
        132 => '商城订单退款', //bean +
    ];
    // 操作钱包余额类型
    const money_type = [
        'money' => '余额',
        'bean' => '善豆',
    ];

    // Bill订单所属日志 type id
    const BILL_LOG_TYPE = [
        'hotel_order'            => 40,
        'hotel_canteen_order'    => 50,
        'university_event_apply' => 60,
        'offline_shop_order'     => 70,
    ];

    protected $message = '';
    protected $data    = [];

    /**
     * 获取交易类型配置
     * @return mixed
     */
    public function getLogType($type = '')
    {
        $conf = self::log_type;
        if ($type) {
            return $conf[$type] ?: $type;
        }
        return $conf;
    }

    //获取钱包名称
    public function getWalletName($name = '')
    {
        $conf = self::money_type;
        if ($name) {
            return $conf[$name] ?: $name;
        }
        return $conf;
    }

    /**
     * 获取钱包余额
     * @param int $user_id 用户编号
     * @param string $wallet_name 指定钱包名
     * @return array|float
     */
    public function getWalletBak($user_id = 0, $wallet_name = '')
    {
        //所有钱包余额
        if (!$wallet = Db::name('user_wallet')->where(['user_id' => $user_id])->find()) {
            abort(500, '钱包余额获取失败');
        }

        if ($wallet_name) { //返回指定钱包
            return isset($wallet[$wallet_name]) ? $wallet[$wallet_name] : 0;
        } else { //返回所有钱包
            return $wallet;
        }
    }

    public function getWallet($user_id = 0, $wallet_name = '')
    {
        //所有钱包余额
        if (!$wallet = Db::name('user_wallet')->where(['user_id' => $user_id])->find()) {
            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 $log_type 日志的类型
     * @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, $accountType = 'money',  $log_type = '', $remark = '', $table = '', $table_id = 0)
    {
        //初始化
        $result = array(
            'status'    => false,
            'msg'       => '',
            'log_table' => '',
            'log_id'    => '',
        );

        //获取小数点
        $point = 0;
        if(in_array($accountType,['money','bean'])){
            $point = 2;
        }
        bcscale($point);

        //钱包名称
        $wallet_name = $this->getWalletName($accountType);

        //检测
        $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_wallet')->lock(true)->where(['user_id' => $user_id])->find();
        if (!$wallet) {
            $result['msg'] = '不存在的用户';
            return $result;
        }

        if (bccomp(bcadd($wallet[$accountType], $number), 0) === -1) {
            $result['msg'] = $wallet_name . '余额不足!';
            return $result;
        } else {
            if (0 !== bccomp($number, 0)) {

                //钱币记录
                $data             = array();
                $data['user_id']  = $user_id;
                $data['log_type'] = $log_type;
//                $data['money_type'] = $accountType;
                $data['before']       = $wallet[$accountType];
                $data['change_value'] = $number;
                $data['remain']       = bcadd($wallet[$accountType], $number);
                $data['table']        = $table;
                $data['table_id']     = $table_id;
                $data['remark']       = $remark;
                $data['createtime']   = time();
                $data['updatetime']   = time();

                //新的方式
                $rs1 = Db::name('user_wallet')->where(['user_id' => $user_id])->update([$accountType => $data['remain']]);


                /////////////
                $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'] = $log_table;
                    $result['log_id']    = $rs2_id;

                    return $result;
                } else {
                    $result['msg'] = '更新财务记录失败!';
                    return $result;
                }
            } else {
                $result['msg'] = '金额不足0.01';
                return $result;
            }
        }
    }

    /**
     * 余额变更
     * @param int $user_id 用户id
     * @param float $number 金额（正数进账，负数出账）
     * @param string $accountType 货币类型 self::money_type
     * @param int $log_type 日志的类型 self::log_type
     * @param string $remark 备注
     * @param string $table 来源表
     * @param int $table_id 表id
     * @return bool
     */
    public function change(int $user_id, float $number, string $accountType = 'money', int $log_type = 0, string $remark = '', string $table = '', int $table_id = 0)
    {
        //获取小数点
        $point = 0;
        if(in_array($accountType,['money','bean'])){
            $point = 2;
        }
        bcscale($point);

        //钱包名称
        $wallet_name = $this->getWalletName($accountType);

        //检测
        if ($number == 0 || 0 === bccomp($number, 0)) {
            return $this->error('交易金额:0');
        }

        //检测
        if (!$wallet = Db::name('user_wallet')->lock(true)->where(['user_id' => $user_id])->find()) {
            return $this->error('不存在的用户');
        }

        if (bccomp(bcadd($wallet[$accountType], $number), 0) === -1) {
            return $this->error("{$wallet_name}余额不足!");
        }

        //钱币记录
        $data = [
            'user_id'      => $user_id,
            'log_type'     => $log_type,
            'before'       => $wallet[$accountType],
            'change_value' => $number,
            'remain'       => bcadd($wallet[$accountType], $number),
            'table'        => $table,
            'table_id'     => $table_id,
            'remark'       => $remark,
            'createtime'   => time(),
            'updatetime'   => time(),
        ];
        //新的方式
        $upWallet = Db::name('user_wallet')->where(['user_id' => $user_id])->update([$accountType => $data['remain']]);
        if ($upWallet === false) {
            return $this->error("更新账户余额失败!");
        }
        if (!Db::name("user_{$accountType}_log")->insertGetId($data)) {
            return $this->error("更新财务记录失败!");
        }

        return $this->success("账户余额已更新!");
    }
}