RWACha-API/application/api/controller/Ledger.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\model\LedgerQubicChangeModel;
use app\common\model\UserModel;
use app\common\model\LedgerSmhChangeModel;
use app\common\model\LedgerTeacChangeModel;
use app\common\model\LedgerTokenChangeModel;
use app\common\model\LedgerUsdtChangeModel;
use app\common\model\LedgerWalletModel;
use app\common\model\OfflineWithdrawRecordModel;
use fast\Action;
use think\Log;
use think\Env;
use think\Db;
use fast\Asset;
use think\Loader ;
use think\Exception;

/**
 * 首页接口
 */
class Ledger extends Api
{
    protected array $noNeedLogin = ['withdrawCallback'];

    /**
     * 资产首页
     */
    public function assets()
    {
        $config = getAllConfig();
        $wallet = LedgerWalletModel::getWallet($this->auth->id);
        $res['assets']        = $wallet->token;
        $res['transfes_fee']  = $config['transfer_fee'];  //转让手续费比例
        $res['transfes_txt']  = $config['transfes_txt'];   //转让文字表述
        $res['chabao_rate']  = $config['chabao_rate'];    //茶宝汇率
        $res['withdrawal_next_fee']  = $config['withdrawal_next_fee'];  //600以下提现收费
        $res['withdrawal_up_fee']    = $config['withdrawal_up_fee'];    //600以上提现收费
        $res['coin_list'] = [
            [
                'coin_name' => '茶宝',
                'coin_key'  => 'token', 
                'amount'    => $wallet->token,
                'frozen_amount'=> $wallet->frozen //冻结金额
            ],
            [
                'coin_name' => 'Teac',
                'coin_key'  => 'teac', 
                'amount'    => $wallet->teac,
                'frozen_amount'=> 0 //冻结金额
            ]
        ];
        $this->success('', $res);
    }

    /**
     * 资产变动明细
     * @return void
     */
    public function coinList(LedgerWalletModel $ledgerWalletModel)
    {
        $type_id  = $this->request->post('query.action'); // 账变类型
        $coin_type  = $this->request->post('query.coin_type'); // 資金类型
        $where = ['user_id' => $this->auth->getTokenUserID()];
        if ($type_id > 0) $where['action'] = $type_id;
        switch ($coin_type){
            case 'usdt':
                $paginator = (new LedgerUsdtChangeModel());
                break;
            case 'teac':
                $paginator = Loader::model('LedgerTeacChangeModel');
                $res['data'] = $paginator->where($where)->order('id DESC')->paginate($this->pageSize);
                $res['statusList'] = $paginator::getStatusList();
                break;
            case 'token':
                $res['data'] = Loader::model('LedgerTokenChangeModel')->alias('a')
                    ->join('user u', 'a.from_id = u.id and a.action > 9 and a.action < 12', 'LEFT')
                    ->field('a.*, u.address')
                    ->where($where)
                    ->order('a.id DESC')->paginate($this->pageSize);
                $res['statusList'] = LedgerWalletModel::getStatusList();
                break;
            case 'smh':
                $paginator = (new LedgerSmhChangeModel());
                break;
            case 'qubic':
                $paginator = (new LedgerQubicChangeModel());
                break;
            default:
                $this->error(__('Invalid parameters'));
                break;
        }
        $this->success('',$res);
    }

    /**
     * 资产变动类型
     * @return void
     */
    public function coinAction()
    {
        $coin_type  = $this->request->post('coin_type'); // 資金类型
        switch ($coin_type){
            case 'smh':
                $res = (new LedgerSmhChangeModel())->pay_status;//资金变动类型列表
                break;
            case 'qubic':
                $res = (new LedgerQubicChangeModel())->aciton_name;//资金变动类型列表
                break;
            case 'aleo':
                $res = (new LedgerTokenChangeModel())->aciton_name;//资金变动类型列表
                break;
            default:
                $res = Action::getAll($coin_type);//资金变动类型列表
                break;
        }
        $this->success('',$res);
    }


    /**
     * 茶宝赠送明细 
     * @return void
     */
    public function chabao()
    {
        $this->success('', ['value' => getConfig('chabao_giveaway'), 'text' => getConfig('chabao_giveaway_txt')]);
    }

    /**
     * 茶宝赠送
     * @return void
     */
    public function chabaoGift(UserModel $userModel,  LedgerWalletModel $ledgerWalletModel)
    {
   
        $amount = $this->request->post('amount'); // 茶宝
        $address = $this->request->post('address'); // 地址
        if(empty($amount) || empty($address)){
            $this->error(__('Parameter error'));
        }
        $real   = bcsub($amount, bcmul(getConfig('chabao_giveaway'), $amount, 2), 2) ; // 手续费

        // 启动事务
        Db::startTrans();
        try {

            $user = $userModel->getByAddress($address);
            if(empty($user)) throw new Exception(__("赠送用户不存在"));    
            if($user['id'] == $this->auth->id) throw new Exception(__("赠送用户不能是自己"));  
            $chabao = $ledgerWalletModel::getWalletChaBao($this->auth->id);
            if(bccomp($amount, $chabao, 2) > 0) throw new Exception(__("余额不足请前往充值"), 15001);
        
            // 更新USDT和账变
            $ledgerWalletModel->changeWalletAccount($this->auth->id, Asset::TOKEN, -$amount, $ledgerWalletModel::GiftPay, $user['id']);

            $ledgerWalletModel->changeWalletAccount($user['id'], Asset::TOKEN, $real, $ledgerWalletModel::GiftReceipt, $this->auth->id);
            // 提交事务
            Db::commit();
        } catch (Exception $e) {
            // 回滚事务
            Db::rollback();
            $this->error($e->getMessage(), null, $e->getCode());
        }
        $this->success('ok');
    }

    /**
     * 虚拟币明细
     * @return void
     */
    public function tokenList()
    {
        $type  = $this->request->post('query.action'); // 账变类型
        $where = ['user_id' => $this->auth->getTokenUserID()];
        if ($type != Action::All) {
            $where['action'] = $type;
        }
        $paginator = (new LedgerTokenChangeModel())->where($where)->order('id DESC')->paginate($this->pageSize);
        $this->success('', $this->buildResp($paginator->total(), $paginator->currentPage(), $paginator->items()));
    }

    /**
     * 提现自动打款回调
     * 接口回调信息格式:
     *
     * @return void
     */
    public function withdrawCallback_my()
    {
        //post 获取过来的数据格式为：{"code":"1","data":{"orderNo":"1768","tx_hash":"xx4545"}}
        $parems = $this->request->post();
        Log::write('提现自动打款回调参数:','info');
        Log::info(json_encode($parems));

        if(empty($parems)){
            $this->error("回调参数为空");
        }

        if($parems['code'] != 1){
            $this->error("本次提现失败");
        }
        $rs_data = $parems['data'];
        $info = (new OfflineWithdrawRecordModel())
            ->where('id', $rs_data['orderNo'])
            ->find();
        if(empty($info)){
            $this->error("当前提现信息不存在");
        }
        if($info['status'] == 2){
            $this->success("更新成功");
        }
        if($info['status'] == 5){
            $is_update = (new OfflineWithdrawRecordModel())
                ->where('id', $info['id'])
                ->update([
                    'tx_hash'       => $rs_data['tx_hash'],
                    'status'        => 2,
                    'update_time'   => time(),
                ]);
            if($is_update){
                $this->success("更新成功");
            }else{
                $this->error("更新失败");
            }
        }
    }
   
    // 获取充值地址
    public function getAddress()
    {   
        return $this->success('', ['value'=> Env::get('rental.pay_address'), 'name'=>getConfig('recharge_txt')]);
    }
}