Tou-Biao-API/application/api/controller/Money.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\model\Config;
use app\common\model\MoneyIn;
use app\common\model\MoneyLog;
use app\common\model\MoneyOut;
use app\common\model\Users AS UserModel;
use think\Db;
use think\Exception;

/**
 * 首页接口
 */
class Money extends Api
{
    protected $noNeedLogin = ['getMongyOut'];
    protected $noNeedRight = ['*'];

    /**
     * 充值信息
     * @return void
     * @throws \think\exception\DbException
     */
    public function recharge()
    {
        $user = $this->auth->getUser();

        $data['amount_list'] = [100,200,500,1000,5000,10000];//快捷输入额度
        $data['usdt'] = $data['bank'] = 1;
        $recharge_info = UserModel::getAgentRechargeInfoByAgentId($user);
        if(empty($recharge_info)){
            $this->error(__('无充值信息'));
        }
        if(empty($recharge_info['usdt'])){
            $data['usdt'] = 0;
        }
        if(empty($recharge_info['bank'])){
            $data['bank'] = 0;
        }

        $this->success('', $data);
    }

    /**
     * 创建充值订单
     * @return void
     */
    public function recharge_create()
    {
        $recharge_type = $this->request->post('type');
        $amount        = $this->request->post('amount');
        if(!in_array($recharge_type, [1,2])){
            $this->error(__('参数有误'));
        }
        if(!($amount > 0)){
            $this->error(__('参数有误'));
        }

        $user = $this->auth->getUser();
        $recharge_info = UserModel::getAgentRechargeInfoByAgentId($user);
        if(empty($recharge_info)){
            $this->error(__('无充值信息'));
        }

        $insert_data = [
            'order_type' => $recharge_type,
            'user_id'   => $user['id'],
            'amount'    => $amount,
            'status'    => MoneyIn::Default,
            'user_type' => $user['user_type'],
            'agent_id'  => $recharge_info['agent_id']
        ];

        //USDT充值
        if($recharge_type == 1){
            if(empty($recharge_info['usdt'])){
                $this->error(__('参数有误'));
            }
            $insert_data['order_no'] = 'U' . time() . $user['id'];
            $insert_data['usdt_address']  = $recharge_info['usdt'];
        }else{
            if(empty($recharge_info['bank'])){
                $this->error(__('参数有误'));
            }
            $insert_data['order_no']    = 'B' . time() . $user['id'];
            $insert_data['bank_name']   = $recharge_info['bank']['bank_name'];
            $insert_data['bank_card']   = $recharge_info['bank']['bank_card'];
            $insert_data['account_name']= $recharge_info['bank']['account_name'];
        }

        //写入
        Db::startTrans();
        try {
            (new MoneyIn())->save($insert_data);
            Db::commit();
        } catch (Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('', $insert_data);
    }

    /**
     * 上传图片
     * @return void
     * @throws \think\exception\DbException
     */
    public function recharge_upload()
    {
        $user = $this->auth->getUser();

        $order_no = $this->request->post('order_no');
        if (empty($order_no)) {
            $this->error(__('参数有误'));
        }

        $order_info = (new MoneyIn())
            ->where('user_id', $user['id'])
            ->where('order_no', $order_no)
            ->find();
        if (empty($order_no)) {
            $this->error(__('参数有误'));
        }

        $file_info = ali_oss_upload($this->request, 'recharge', $order_no);
        if($file_info['code'] == 0){
            $this->error($file_info['msg']);
        }

        $this->success('', $file_info['data']);
    }
    /**
     * 提交充值信息
     * @return void
     * @throws \think\exception\DbException
     */
    public function recharge_submit()
    {
        $user = $this->auth->getUser();

        $order_no = $this->request->post('order_no');

        if (empty($order_no)) {
            $this->error(__('参数有误'));
        }

        $order_info = (new MoneyIn())
            ->where('user_id', $user['id'])
            ->where('order_no', $order_no)
            ->find();
        if (empty($order_info)) {
            $this->error(__('参数有误'));
        }

        //上传图片
        $file_info = ali_oss_upload($this->request, 'recharge', $order_no);
        if($file_info['code'] == 0){
            $this->error($file_info['msg']);
        }
        $img_url = $file_info['data']['full_url'];

        if ($order_info['status'] != MoneyIn::Default) {
            if (empty($order_info['img_url'])) {
                (new MoneyIn())
                    ->where('order_no', $order_no)
                    ->update([
                        'img_url' => $img_url
                    ]);
            }
            $this->success(__('提交成功'));
        }

        (new MoneyIn())
            ->where('order_no', $order_no)
            ->update([
                'img_url' => $img_url,
                'status'  => MoneyIn::Pending,
            ]);
        $this->success(__('提交成功'));
    }

    /**
     * 提现
     * @return void
     */
    public function withdraw()
    {
        $user = $this->auth->getUser();
        if(empty($user['fund_pwd'])){
            $this->error(__('资金密码未设置'), '', 4001);
        }

        $data['balance']        = $user['freeze'] < 0 ? $user['freeze']: $user['balance'];
        $data['money_out_sum']  = MoneyOut::where('user_id', $user['id'])->where('status', MoneyOut::Success)->sum('amount');

        $withdraw_info = UserModel::getAgentWithdrawInfoByAgentId($user['agent_id']);
        if(empty($withdraw_info)){
            $this->error(__('无提现信息'));
        }

        $data['usdt']['is_open'] = $withdraw_info['usdt'];
        $data['bank']['is_open'] = $withdraw_info['bank'];

        if($withdraw_info['usdt']){
            if(empty($user['usdt_address'])){
                $this->error(__('出款信息未配置'), '', 4002);
            }

            $data['usdt']['address'] = $user['usdt_address'];
        }

        if($withdraw_info['bank']){
            if(empty($user['bank_info'])){
                $this->error(__('出款信息未配置'), '', 4002);
            }
            $data['bank']['account_name'] = $data['bank']['bank_name'] = $data['bank']['bank_card'] = '';
            $bank_info = json_decode($user['bank_info'], true);
            if(!empty($bank_info)){
                $data['bank']['account_name'] = $bank_info['account_name'];
                $data['bank']['bank_name'] = $bank_info['bank_name'];
                $data['bank']['bank_card'] = $bank_info['bank_card'];
            }
        }

        $this->success('', $data);
    }

    /**
     * 提交提现信息
     * @return void
     * @throws \think\exception\DbException
     */
    public function withdraw_submit()
    {
        $type          = $this->request->post('type');
        $amount        = $this->request->post('amount');
        if(!in_array($type, [1,2])){
            $this->error(__('参数有误'));
        }
        if(!($amount > 0)){
            $this->error(__('参数有误'));
        }

        $user = $this->auth->getUser();
        if($amount > $user['balance']){
            $this->error(__('余额不足'));
        }
        if($user['task_num'] != (new Config())->getValue('day_tasks_num')){
            $this->error(__('任务不足'));
        }

        $withdraw_info = UserModel::getAgentWithdrawInfoByAgentId($user['agent_id']);
        if(empty($withdraw_info)){
            $this->error(__('无提现信息'));
        }

        $withdraw_fee = (new Config())->getValue('withdrawal_fee');
        if(empty($withdraw_fee)){
            $withdraw_fee = 0;
        }elseif($withdraw_fee > 1){
            $this->error(__('提现手续费有误'));
        }

        $insert_data = [
            'order_type' => $type,
            'user_id'   => $user['id'],
            'amount'    => $amount,
            'fee'       => $amount * $withdraw_fee,
            'real_amount'   => $amount * (1 - $withdraw_fee),
            'status'    => MoneyOut::Pending,
            'agent_id'  => $withdraw_info['agent_id'],
            'user_type' => $user['user_type'],
        ];

        //USDT充值
        if($type == 1){
            if(empty($withdraw_info['usdt'])){
                $this->error(__('参数有误'));
            }
//            $usdt_address = $this->request->post('usdt');
            if(empty($user['usdt_address'])){
                $this->error(__('参数有误'));
            }

            $insert_data['order_no']      = 'U' . time() . $user['id'];
            $insert_data['usdt_address']  = $user['usdt_address'];
        }else{
            if(empty($withdraw_info['bank'])){
                $this->error(__('参数有误'));
            }

            if(empty($user['bank_info'])){
                $this->error(__('参数有误'));
            }
            $bank_info = json_decode($user['bank_info'], true);

            $insert_data['bank_name']   = $bank_info['bank_name'];
            $insert_data['bank_card']   = $bank_info['bank_card'];
            $insert_data['account_name']= $bank_info['account_name'];

            $insert_data['order_no']    = 'B' . time() . $user['id'];
        }

        $fund_pwd = $this->request->post('fund_pwd');
        if(empty($fund_pwd)){
            $this->error(__('参数有误'));
        }
        if($user['fund_pwd'] != md5($fund_pwd)){
            $this->error(__('资金密码有误'));
        }

        //写入
        Db::startTrans();
        try {
            (new MoneyOut())->save($insert_data);
            //扣款
            (new MoneyLog())->change($user['id'], -$amount, MoneyLog::Withdraw, '', '');
            Db::commit();
        } catch (Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('');
    }

    /**
     * 充值提现列表
     * @return void
     * @throws \think\exception\DbException
     */
    public function money_list()
    {
        $type          = $this->request->post('type');
        if(empty($type)){
            $type = 1;
        }
        if(!in_array($type, [1,2])){
            $this->error(__('参数有误'));
        }

        $user = $this->auth->getUser();
        $res_data = [];

        if($type == 1){
            //充值列表

            $info_list = MoneyIn::where('user_id', $user['id'])
                ->field('order_no,order_type,usdt_address,bank_name,bank_card,account_name,amount,status,create_time')
                ->order('id DESC')
                ->paginate($this->pageSize);
            foreach ($info_list as $k => $v) {
                $info_list[$k]['status_name'] = (new MoneyIn())->getStatusNames($v['status']);
            }
            $res_data = $this->buildResp($info_list->total(), $info_list->currentPage(), $info_list->items());
        }else{
            //提现列表
            $info_list = MoneyOut::where('user_id', $user['id'])
                ->field('order_no,order_type,amount,status,create_time')
                ->order('id DESC')
                ->paginate($this->pageSize);
            foreach ($info_list as $k => $v) {
                $info_list[$k]['status_name'] = (new MoneyOut())->getStatusNames($v['status']);
            }
            $res_data = $this->buildResp($info_list->total(), $info_list->currentPage(), $info_list->items());
        }


        $res_data['money_in_sum']   = MoneyIn::where('user_id', $user['id'])->where('status', MoneyIn::Success)->sum('amount');
        $res_data['money_out_sum']  = MoneyOut::where('user_id', $user['id'])->where('status', MoneyOut::Success)->sum('amount');
        $this->success('', $res_data);
    }


    /**
     * 获取待处理提现订单
     * @return void
     * @throws \think\exception\DbException
     */
    public function getMongyOut()
    {
        $count = MoneyOut::where('status', MoneyOut::Pending)->count();
        $this->success('', $count);
    }
}