kpyk/app/models/trade/CashTradeOrder.php

<?php


namespace app\models\trade;

use app\models\user\User;
use app\models\user\UserBill;
use app\models\user\UserMoney;
use app\models\user\UserMoneyOrder;
use crmeb\traits\ModelTrait;
use crmeb\basic\BaseModel;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\Exception;
use think\Model;

class CashTradeOrder extends BaseModel
{
    /**
     * 数据表主键
     * @var string
     */
    protected $pk = 'id';
    /**
     * 模型名称
     * @var string
     */
    protected $name = 'cash_trade_order';
    use ModelTrait;

    /**
     * @param $money_type
     * @return int|string|null
     */
    public static function averagePrice($money_type)
    {
        $all_money = self::whereTime('trade_time', 'yesterday')->where('status', 2)->where('money_type', $money_type)->sum('money_num');
        $all_cash = self::whereTime('trade_time', 'yesterday')->where('status', 2)->where('money_type', $money_type)->sum('all_price');
        if ($all_money > 0)
            return bcdiv($all_cash, $all_money, 8);
        else
            return "0";
    }

    /**
     * @param $where
     * @return self
     */
    public static function setStatus($where)
    {
        if (is_array($where)) {
            if (isset($where['status'])) {
                $status = $where['status'];
            } else {
                return new self();
            }
        } else {
            $status = $where;
        }

        switch ($status) {
            case 1://挂出中
                return self::where('status', 'in', [0, -1])->where('end_time', '>', time())->where('trade_uid', null);
            case 2://已完成
                return self::where('status', 1);
            case 3://挂出时间结束
                return self::where('status', 'in', [0, -1, 2])->where('end_time', '<', time());
            case 4://挂出时间结束，未领回
                return self::where('status', 'in', [0, -1])->where('end_time', '<', time())->where('close_time', '<', time());
            case 5://已领回
                return self::where('status', 2);
            case 6://交易中，已上传凭证
                return self::where('status', 3);
            case 7://未结束 但是关闭
                return self::where('status', 'in', [0, -1])->where('end_time', '>', time())->where('close_time', '<', time());
            default:
                return new self();
        }
    }


    /**
     * @param $where
     * @return array
     */
    public static function getList($where)
    {
        $model = self::setStatus($where);
//        if (isset($where['uid']) && $where['uid']) {
//            $model = $model->where('uid|trade_uid', $where['uid']);
//        }
        if (isset($where['trade_type']) && $where['trade_type'] != '') {
            if (isset($where['uid']) && $where['uid']) {
                $model = $model->where(function ($query) use ($where) {
                    $query->where('trade_uid', $where['uid'])
                        ->where('trade_type', $where['trade_type']);
                })->whereOr(function ($query) use ($where) {
                    $query->where('uid', $where['uid'])
                        ->where('trade_type', '<>', $where['trade_type']);
                });
            } else {
                $model = $model->where('trade_type', $where['trade_type']);
            }
        }
        if (isset($where['money_type']) && $where['money_type'] != '') {
            $model = $model->where('money_type', $where['money_type']);
        }
        $count = $model->count();
        $list = $model->page((int)$where['page'], (int)$where['limit'])->select()
//        var_dump(self::getLastSql());
            ->each(function ($item) {
                $item['user'] = User::getUserInfo($item['uid']);
                $item['trade_user'] = User::getUserInfo($item['trade_uid']);
                $item['_add_time'] = time_format($item['add_time']);
                $item['_end_time'] = time_format($item['end_time']);
                $item['_trade_time'] = time_format($item['trade_time']);
            });

        return compact('count', 'list');
    }


    public static function hangSale($uid, $money_type, $money_num, $price, $hang_time)
    {
        $money = UserMoney::initialUserMoney($uid, $money_type);
        if ($money['money'] < $money_num) return self::setErrorInfo('账户不足！');
        $sum = bcmul($money_num, $price, 2);
        BaseModel::beginTrans();
        try {
            $res = UserMoney::expendMoney($uid, $money_type, $money_num, 'hang_sale', '挂卖', '挂卖' . $money_num);
            if (!$res) {
                return self::setErrorInfo(UserMoney::getErrorInfo('支付失败'), true);
            }
            $res = self::create([
                'order_id' => self::getOrderId(),
                'uid' => $uid,
                'money_type' => $money_type,
                'money_num' => $money_num,
                'price' => $price,
                'all_price' => $sum,
                'trade_type' => 1,
                'add_time' => time(),
                'hang_time' => $hang_time,
                'end_time' => bcadd(time(), bcmul($hang_time, 3600)),
            ]);
            if ($res) {
                BaseModel::commitTrans();
                return $res;
            } else {
                return self::setErrorInfo('挂卖失败', true);
            }
        } catch (Exception $e) {
            return self::setErrorInfo($e->getMessage(), true);
        }
    }

    public static function hangBuy2($uid, $money_type, $money_num, $price, $hang_time)
    {
        $sum = bcmul($money_num, $price, 2);
        BaseModel::beginTrans();
        try {
//            $res = UserMoney::expendMoney($uid, $money_type, $money_num, 'hang_sale', '挂卖', '挂卖' . $money_num);
//            if (!$res) {
//                return self::setErrorInfo(UserMoney::getErrorInfo('支付失败'), true);
//            }
            $res = self::create([
                'order_id' => self::getOrderId(),
                'uid' => $uid,
                'money_type' => $money_type,
                'money_num' => $money_num,
                'price' => $price,
                'all_price' => $sum,
                'trade_type' => 2,
                'add_time' => time(),
                'hang_time' => $hang_time,
                'status' => -1,//未支付虚拟货币
                'end_time' => bcadd(time(), bcmul($hang_time, 3600)),
            ]);
            if ($res) {
                BaseModel::commitTrans();
                return $res;
            } else {
                return self::setErrorInfo('挂买失败', true);
            }
        } catch (Exception $e) {
            return self::setErrorInfo($e->getMessage(), true);
        }
    }


    public static function hangBuy($uid, $money_type, $money_num, $price, $hang_time)
    {
        $sum = bcmul($money_num, $price, 2);
        BaseModel::beginTrans();
        try {
            $res = CashTradeOrderPayment::create([
                'uid' => $uid,
                'order_id' => CashTradeOrderPayment::getOrderId(),
                'order_type' => 1,
                'pay_money' => $sum,
                'add_time' => time(),
                'order_info' => json_encode([
                    'uid' => $uid,
                    'money_type' => $money_type,
                    'money_num' => $money_num,
                    'price' => $price,
                    'all_price' => $sum,
                    'trade_type' => 2,
                    'hang_time' => $hang_time,]),
            ]);
            if ($res) {
                BaseModel::commitTrans();
                return $res;
            } else {
                return self::setErrorInfo('订单生成失败', true);
            }
        } catch (Exception $e) {
            return self::setErrorInfo($e->getMessage(), true);
        }
    }

    public static function getOrderId()
    {
        list($msec, $sec) = explode(' ', microtime());
        $msectime = number_format((floatval($msec) + floatval($sec)) * 1000, 0, '', '');
        do {
            $str = 'ct' . $msectime . mt_rand(10000, 99999);
        } while (self::be(['order_id' => $str]));
        return $str;
    }


    public static function sale($uid, $id)
    {
        $order = self::setStatus(1)->where('id', $id)->find();
        if (!$order) {
            return self::setErrorInfo('订单不存在或已结束挂出');
        }
        $money = UserMoney::initialUserMoney($uid, $order['money_type']);
        if ($money['money'] < $order['money_num']) return self::setErrorInfo('账户不足！');
        BaseModel::beginTrans();
        try {
            $res = UserMoney::expendMoney($uid, $order['money_type'], $order['money_num'], 'sale', '售币成功', '售币成功，购买方：' . $order['uid']);
            if (!$res) {
                return self::setErrorInfo(UserMoney::getErrorInfo('支付失败'), true);
            }
            $res = self::where('id', $id)->update([
                'status' => 0,
                'trade_uid' => $uid,
                //'trade_way' => $order['pay_type'],
//                'trade_time' => time(),
            ]);
//            $userInfo = User::getUserInfo($uid);
//            $res = $res && UserMoney::incomeMoney($order['uid'], $order['money_type'], $order['money_num'], 'buy_success', '购币成功', '购币成功，出售方：' . $uid);
//            $res = $res && (false !== User::bcInc($userInfo['uid'], 'now_money', $order['all_price'], 'uid'));
//            $res = $res && UserBill::income('售币成功', $userInfo['uid'], 'now_money', 'sale_success', $order['all_price'], $order['id'], $userInfo['now_money'] + $order['all_price'], '售币成功，购买方：' . $order['uid']);
            if ($res) {
                BaseModel::commitTrans();
                return $res;
            } else {
                return self::setErrorInfo('出售失败', true);
            }
        } catch (Exception $e) {
            return self::setErrorInfo($e->getMessage(), true);
        }
    }


    public static function buy($uid, $id)
    {
        $order = self::setStatus(1)->where('id', $id)->find();
        if (!$order) {
            return self::setErrorInfo('订单不存在或已结束挂出');
        }
        BaseModel::beginTrans();
        try {
            $res = CashTradeOrderPayment::create([
                'uid' => $uid,
                'order_id' => CashTradeOrderPayment::getOrderId(),
                'bind_order' => $id,
                'order_type' => 2,
                'pay_money' => $order['all_price'],
                'add_time' => time()
            ]);
            if ($res) {
                BaseModel::commitTrans();
                return $res;
            } else {
                return self::setErrorInfo('订单生成失败', true);
            }
        } catch (Exception $e) {
            return self::setErrorInfo($e->getMessage(), true);
        }
    }

    public static function buy2($uid, $id)
    {
        $order = self::setStatus(1)->where('id', $id)->find();
        if (!$order) {
            return self::setErrorInfo('订单不存在或已结束挂出');
        }
        $money = UserMoney::initialUserMoney($uid, $order['money_type']);
        if ($money['money'] < $order['money_num']) return self::setErrorInfo('账户不足！');
        BaseModel::beginTrans();
        try {
            $res = UserMoney::expendMoney($uid, $order['money_type'], $order['money_num'], 'sale', '售币成功', '售币成功，购买方：' . $order['uid']);
            if (!$res) {
                return self::setErrorInfo(UserMoney::getErrorInfo('支付失败'), true);
            }
            $res = self::where('id', $id)->update([
                'status' => -1,
                'trade_uid' => $uid,
//                'trade_time' => time(),
            ]);
            if ($res) {
                BaseModel::commitTrans();
                return $res;
            } else {
                return self::setErrorInfo('申请购买失败', true);
            }
        } catch (Exception $e) {
            return self::setErrorInfo($e->getMessage(), true);
        }
    }

    public static function getBack()
    {
        $list = self::setStatus(4)->select();
        BaseModel::beginTrans();
        $res = true;
        foreach ($list as $v) {
            switch ($v['trade_type']) {
                case 1:
                    //退回币
                    $res = $res && UserMoney::incomeMoney($v['uid'], $v['money_type'], $v['money_num'], 'hang_sale_send_back', '挂卖退回', '挂卖时间结束，退回钱包');
                    $res = $res && self::where('id', $v['id'])->update(['status' => 2]);
                    break;
                case 2:
//                    $userInfo = User::getUserInfo($v['uid']);
//                    $res = $res && (false !== User::bcInc($v['uid'], 'now_money', $v['all_price'], 'uid'));
//                    $res = $res && UserBill::income('售币成功', $v['uid'], 'now_money', 'hang_buy_send_back', $v['all_price'], $v['id'], $userInfo['now_money'] + $v['all_price'], '挂买时间结束，退回余额');
//                    $res = $res && self::where('id', $v['id'])->update(['status' => 2]);
                    if ($v['trade_uid'])
                        $res = $res && UserMoney::incomeMoney($v['trade_uid'], $v['money_type'], $v['money_num'], 'hang_buy_send_back', '挂买退回', '挂买时间结束，退回钱包');
                    $res = $res && self::where('id', $v['id'])->update(['status' => 2]);
                    break;
                default:
                    break;
            }
        }
        BaseModel::checkTrans($res);
        return $res;
    }

    public static function orderClose()
    {
        $list = self::setStatus(7)->select();
        BaseModel::beginTrans();
        $res = true;
        foreach ($list as $v) {
            switch ($v['trade_type']) {
                case 1:
                    //退回币
//                    $res = $res && UserMoney::incomeMoney($v['uid'], $v['money_type'], $v['money_num'], 'hang_sale_send_back', '挂卖退回', '挂卖时间结束，退回钱包');
                    $res = $res && self::where('id', $v['id'])->update(['trade_uid' => null, 'status' => 0, 'close_time' => null]);
                    break;
                case 2:
//                    $userInfo = User::getUserInfo($v['uid']);
//                    $res = $res && (false !== User::bcInc($v['uid'], 'now_money', $v['all_price'], 'uid'));
//                    $res = $res && UserBill::income('售币成功', $v['uid'], 'now_money', 'hang_buy_send_back', $v['all_price'], $v['id'], $userInfo['now_money'] + $v['all_price'], '挂买时间结束，退回余额');
//                    $res = $res && self::where('id', $v['id'])->update(['status' => 2]);
                    if ($v['trade_uid'])
                        $res = $res && UserMoney::incomeMoney($v['trade_uid'], $v['money_type'], $v['money_num'], 'hang_sale_send_back', '挂卖退回', '挂卖时间结束，退回钱包');
                    $res = $res && self::where('id', $v['id'])->update(['trade_uid' => null, 'status' => -1, 'close_time' => null]);
                    break;
                default:
                    break;
            }
        }
        BaseModel::checkTrans($res);
        return $res;
    }
}