RWACha-API/application/common/model/OfflineRechargeRecordModel.php

<?php

namespace app\common\model;

use Exception;
use fast\Action;
use fast\Asset;
use fast\RechargeOrderType;
use fast\RechargeStatus;
use think\Db;
use think\Model;

class OfflineRechargeRecordModel extends Model
{

    protected $name = "offline_recharge_record";

    const StatusDefault     = 0;
    const StatusConfirm     = 100;
    const StatusSuccess     = 200;
    const StatusFail        = 400;
    const StatusCancel      = 500;

    /*
     * 客户端订单状态筛选
     */
    public $order_status = [
        '-1'                  => '全部',
        self::StatusDefault   => '待支付',
        self::StatusConfirm   => '待确认',
        self::StatusSuccess   => '成功',
        self::StatusFail      => '失败',
        self::StatusCancel    => '取消'
    ];

    public function userInfo()
    {
        return $this->hasOne(UserModel::class, 'id', 'user_id');
    }

    /**
     * 创建购买(充值)记录
     * @param string $txHash
     * @param int $uid
     * @param string $fee
     * @param int $status
     * @return int|string
     * @throws Exception
     */
    public function createRecord(int $cashFrom, string $txHash, int $uid, string $fee, int $status, int $order_type = RechargeOrderType::RentalPower, int $block_number = 0, string $note = '')
    {
        $orderExist = $this->where('tx_hash', $txHash)->count();
        if ($orderExist > 0) {
            throw new Exception('Hash已存在');
        }

        $now    = time();
        $result = $this->insertGetId([
            'order_type'   => $order_type,
            'type'         => $cashFrom,
            'tx_hash'      => $txHash,
            'user_id'      => $uid,
            'symbol'       => Asset::USDT,
            'amount'       => $fee,
            'status'       => $status,
            'create_time'  => $now,
            'note'         => $note,
            'block_number' => $block_number,
        ]);
        if (empty($result)) {
            throw new Exception('创建购买记录失败');
        }
        return $result;
    }


    /**
     * 服务器算力和后续处理
     * @param int $uid
     * @param string $fee
     * @throws Exception
     */
    public function updateOrderStatus(int $orderID, int $status, int $block_number = 0, float $power = 0)
    {
        $update = [
            'status'       => $status,
            'update_time'  => time(),
            'block_number' => $block_number,
        ];
        if($power > 0){
            $update['power'] = $power;
        }
        $affect = (new OfflineRechargeRecordModel())
            ->where('status', RechargeStatus::StatusUnAuth)
            ->where('id', $orderID)
            ->update($update);
        if (empty($affect)) {
            throw new Exception("处理充值订单状态的影响行数为0,orderID:$orderID,status:$status");
        }
    }
}