php/app/controller/admin/user/UserExtract.php

<?php
/**
 * @package merchant
 *
 * @author Qinii
 * @day 2020-06-16
 *
 *
 */
namespace app\controller\admin\user;

use app\common\enum\CommonEnum;
use app\common\enum\user\UserWithdrawalLimitRecordEnum;
use app\common\repositories\user\UserRepository;
use app\common\repositories\user\UserWithdrawalLimitRecordRepository;
use crmeb\basic\BaseController;
use crmeb\services\SpreadsheetExcelService;
use think\App;
use app\validate\api\UserExtractValidate as validate;
use app\common\repositories\user\UserExtractRepository as repository;
use think\facade\Db;

class UserExtract extends BaseController
{
    /**
     * @var repository
     */
    public $repository;

    /**
     * UserExtract constructor.
     * @param App $app
     * @param repository $repository
     */
    public function __construct(App $app,repository $repository)
    {
        parent::__construct($app);
        $this->repository = $repository;
    }


    /**
     * TODO
     * @return mixed
     * @author Qinii
     * @day 2020-06-16
     */
    public function lst()
    {
        [$page,$limit] = $this->getPage();
        $where = $this->request->params(['status','keyword','date','extract_type','mer_id','mer_name',['identity', '']]);
        if($where['mer_id']==''){
            unset($where['mer_id']);
        }else if($where['mer_id']==0){
            $where['mer_id']='';
        }
        $res = $this->repository->serach($where,$page,$limit);
        foreach ($res['list'] as $k=>$v){
            $res['list'][$k]['certification']= Db::name('user_certification')->where('uid', $v['uid'])->find();
            $res['list'][$k]['list']=$this->repository->get_user_extract_item($v['extract_id']);
            $res['list'][$k]['bank_info_data']=[];
            if($v['bank_info']){
                $res['list'][$k]['bank_info_data']=json_decode($v['bank_info'],true);
            }

        }
        return app('json')->success($res);
    }

    public function excel()
    {
        $where = $this->request->params(['status','keyword','date','extract_type','mer_id','mer_name',['identity', '']]);
        if($where['mer_id']==''){
            unset($where['mer_id']);
        }else if($where['mer_id']==0){
            $where['mer_id']='';
        }
        $identity_desc = "用户提现";
        if ($where['identity'] == 'mer') {
            $identity_desc = "商户提现";
        }
        $res = $this->repository->serach($where,1, 10000000);
        $list = $res['list'];
        foreach ($list as $k => $v) {
            $temp = array(
                $v['extract_id'],
                $v['create_time'],
                $v['phone'],
                $v['real_name'],
                $v['extract_price'],
                $v['service_money'],
                $v['extract_price'] - $v['service_money'],
            );
            if ($v['extract_type'] == 1) {
                $temp[] = '微信';
            }
            if ($v['extract_type'] == 2) {
                $temp[] = '支付宝';
            }
            if ($v['extract_type'] == 3) {
                $temp[] = '银行卡';
            }
            $temp[] = $v['bank_address'] ?? '';
            $temp[] = $v['bank_code'] ?? '';
            if ($v['status'] == -1) {
                $temp[] = '未通过';
            }
            if ($v['status'] == 0) {
                $temp[] = '审核中';
            }
            if ($v['status'] == 1) {
                $temp[] = '已提现';
            }
            $temp[] = $v['status_time'] ?? '';
            $arr[] = $temp;
        }
        $header = [
            'ID', '申请时间', '手机号', '商户信息', '提现金额', '综合服务费', '实际到账', '提现方式', '所属银行', '账号', '审核状态', '处理时间'
        ];
        $filename = $identity_desc . date('YmdHis') . '_' . rand(10000, 99999);
        $title = $identity_desc;
        $name = $identity_desc;
        $info = '生成时间:' . date('Y-m-d H:i:s', time());
        $suffix = 'xlsx';
        $path = 'extract';
        unset($_instance);

        $_instance = SpreadsheetExcelService::instance_xin();

        $_path = $_instance
            ->createOrActive()
            ->setExcelHeader($header)
            ->setExcelTile($title, $name, $info)
            ->setExcelContent($arr)
            ->excelSave($filename, $suffix, $path);

        $data = [
            'name' => $filename . '.' . $suffix,
            'status' => 1,
            'path' => '/' . $_path
        ];

        return app('json')->success('ok', $data);
    }


    /**
     * TODO
     * @param $id
     * @return mixed
     * @author Qinii
     * @day 2020-06-16
     */
    public function switchStatus($id)
    {
        $data = $this->request->params(['status','fail_msg','mark']);
        if($data['status'] == '-1' && empty($data['fail_msg']))
            return app('json')->fail('请填写拒绝原因');
        if(!$this->repository->getWhereCount($id))
            return app('json')->fail('数据不存在或状态错误');
        $data['admin_id'] = $this->request->adminId();
        $data['status_time'] = date('Y-m-d H:i:s',time());
        $extract_data=Db::name('user_extract')->where('extract_id',$id)->find();
        if($data['status']!='-1'){

            /** @var UserRepository $userRepository */
            $userRepository = app()->make(UserRepository::class);
            $userEntity = $userRepository->getUserEntityByUid($extract_data['uid']);
            if ($userEntity->getWithdrawalLimit() < $extract_data['extract_price']) {
                return app('json')->fail('提现额度不足');
            } else {
                try {
                    /** @var UserWithdrawalLimitRecordRepository $userWithdrawalLimitRecordRepository */
                    $userWithdrawalLimitRecordRepository = app()->make(UserWithdrawalLimitRecordRepository::class);
                    // 添加扣减记录
                    $userWithdrawalLimitRecordEntity = $userWithdrawalLimitRecordRepository->addUserWithdrawalLimitRecord(
                        (int)$userEntity->getUid(),
                        UserWithdrawalLimitRecordEnum::PM['EXPEND']['code'],
                        (float)$extract_data['extract_price'],
                        -1,
                        '',
                        '提现扣减提现额度'
                    );
                    // 结算扣减记录
                    $userWithdrawalLimitRecordRepository->executeByIdList([$userWithdrawalLimitRecordEntity->getId()]);
                } catch (\Throwable $exception) {
                    return app('json')->fail($exception->getMessage());
                }
            }

            if($extract_data['extract_type']==1){
                $res=$this->repository->WechatTransfers($id);
                if($res['code']==201){
                    return app('json')->success('微信处理中，请稍后');
                }
            }elseif ($extract_data['extract_type']==2){
                $res=$this->repository->AliTransfers($id);
            }
//            if($res['code']!=200 && $extract_data['types']==1){
//                Db::name('user_rich')->where('uid',$extract_data['uid'])->inc('red', $extract_data['extract_price'])->update();
//                Db::name('user_rich_log')->insert([
//                    'uid'      => $extract_data['uid'],
//                    'red'      => $extract_data['extract_price'],
//                    'pm'       => 1,
//                    'time'     => time(),
//                    'order_id' => 0,
//                    'mark'     => '提现失败返还红积分'
//                ]);
//                return app('json')->fail(isset($res['msg'])?$res['msg']:'提现失败',$res);
//            }
        }else{
            if($extract_data['withdrawal_type']==2) {
                Db::name('entropy_barter_bill')->where('order_no', $extract_data['order_sn'])->where('pm', 2)->update(['status' => 3, 'remarks' => '审核已拒绝']);
                $eb_bill = Db::name('entropy_barter_bill')->where('order_no', $extract_data['order_sn'])->where('pm', 2)->find();
                Db::name('entropy_barter_user_' . $extract_data['mer_id'])->where('eb_id', $eb_bill['to_id'])->inc('wallet', $extract_data['extract_price'])->update();
            }
        }
        $this->repository->switchStatus($id,$data);
        Db::name('user_extract')->where('extract_id',$id)->update($data);
        return app('json')->success('审核成功');
    }

    public function new_lst()
    {
        [$page,$limit] = $this->getPage();
        $where = $this->request->params(['status','keyword','date','extract_type','uid']);
        $res = $this->repository->new_search($where,$page,$limit);
        foreach ($res['list'] as $k=>$v){
            $res['list'][$k]['certification']= Db::name('user_certification')->where('uid', $v['uid'])->find();;

            $res['list'][$k]['bank_info_data']=[];
            $pay_info='';
            if($v['bank_info']!=''){
                $res['list'][$k]['bank_info_data']=json_decode($v['bank_info'],true);
                $pay_info=$res['list'][$k]['certification']['user_name'].' ';
                $pay_info.=$res['list'][$k]['certification']['user_card']." ";
                $pay_info.=$res['list'][$k]['bank_info_data']['bank_name'].' ';
                $pay_info.=$res['list'][$k]['bank_info_data']['bank_open_name'].' ';
                $pay_info.=$res['list'][$k]['bank_code'];
            }
            $res['list'][$k]['status_name']='';
            if($v['status']=='0') $res['list'][$k]['status_name']='审核中';
            if($v['status']=='1') $res['list'][$k]['status_name']='已打款';
            if($v['status']=='-1') $res['list'][$k]['status_name']='已拒绝';
            if($v['extract_type']=='3') $res['list'][$k]['extract_type_name']='银行卡';
            if($v['status']=='0') $res['list'][$k]['status_time']='';


            $res['list'][$k]['extract_price']=set_price_rtrim($v['extract_price']);
            $res['list'][$k]['service_money']=set_price_rtrim( $v['service_money']);
            $res['list'][$k]['money']=set_price_rtrim($v['extract_price'] - $v['service_money']);


            $res['list'][$k]['pay_info']=$pay_info;
            if($v['extract_type']=='4'){
                $res['list'][$k]['status_name']='已完成';
                $res['list'][$k]['pay_info']='人工减少-'.$v['mark'];
            }
            if(!$v['fail_msg'] || $v['fail_msg']==''){
                $res['list'][$k]['fail_msg']='--';
            }
            if(!$v['status_time'] || $v['status_time']==''){
                $res['list'][$k]['status_time']='--';
            }
//            $res['list'][$k]['list']=$this->repository->get_user_extract_item($v['extract_id']);
        }
        //查询用户可提现金额
        $merid = $this->request->merId();
        $merchant= Db::name('merchant')->where('mer_id', $merid)->find();
        $user = Db::name('user')->where('uid', $merchant['uid'])->find();
        $res['brokerage_price'] = $user['brokerage_price'];
        return app('json')->success($res);
    }
}