sheying/application/store/controller/Finance.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\store\controller;

use app\api\controller\Alipay;
use EasyWeChat\Factory;
use library\Controller;
use think\Db;
use app\api\controller\Area;
use app\api\controller\Crontab;
use function GuzzleHttp\Psr7\_caseless_remove;

/**
 * 财务管理
 * Class Finance
 * @package app\store\controller
 */
class Finance extends Controller
{
    /**
     * 绑定数据表
     * @var string
     */
    protected $table = 'release_detailed';

    /**
     * 财务管理
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function index()
    {
        $this->title = '财务管理';
        $query = $this->byWhere();
        $query->order('id desc')->page();
    }

    /**
     * 搜索条件
     * @return \library\helper\QueryHelper
     */
    protected function byWhere()
    {
        $query = $this->_query($this->table)->where('detailed', '提现');
        if (!empty($_GET['transaction_number'])) {
            $query->where('transaction_number', $_GET['transaction_number']);
        }
        if (!empty($_GET['withdrawa_status'])) {
            $query->where('withdrawa_status', $_GET['withdrawa_status']);
        }

        return $query;
    }

    /**
     * 财务列表处理
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    protected function _index_page_filter(array &$data)
    {
        $status_arr = array(0=>'提现中',1=>'提现成功',2=>'提现失败');
        foreach ($data as $k => &$v) {
            $v['extract_status_name'] = $status_arr[$v['extract_status']];
            $v['transaction_amount'] = str_replace("-", "", $v['transaction_amount']);
            $v['user'] = Db::name('release_user')->find($v['user_id']);
        }
    }
    /**
     * 申请提现
     * @auth true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function edit()
    {
        $this->title = '审核提现申请';
        $this->_form($this->table, 'form');
    }
    /**
     * 表单数据处理
     * @param array $data
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    protected function _form_filter(&$data)
    {
        if ($this->request->isGet()) {
            $data['transaction_amount'] = abs($data['transaction_amount']);
        } elseif ($this->request->isPost()) {
            //处理提现
            $store_withdrawal = Db::name('release_detailed')->where('id',$data['id'])->find();
            if($data['extract_status'] == 1){    //提现成功
                $rufund_success = 1;
                if(1 != 1){    //提现到微信
                    $app = Factory::payment(config('app.wx_pay'));
                    $res = $app->transfer->toBalance([
                        'partner_trade_no' => $store_withdrawal['trade_no'], // 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号)
                        'openid' => $store_withdrawal['wechat'],
                        'check_name' => 'NO_CHECK', // NO_CHECK：不校验真实姓名
                        're_user_name' => '', // 如果 check_name 设置为FORCE_CHECK，则必填用户真实姓名
                        'amount' =>$store_withdrawal['transaction_amount']*100,// 企业付款金额，单位为分
                        'desc' =>'会员提现'//企业付款操作说明信息。必填
                    ]);
                    if(isset($res['err_code_des'])){
                        $this->error($res['err_code_des']);
                    }else{
                        $rufund_success = 1;
                    }
                }
            }elseif($data['extract_status'] == 2){    //提现失败
                //退回余额
                $balance = Db::name('release_user')->where('id',$store_withdrawal['user_id'])->value('balance');
                $remainingBalance = $balance + $data['transaction_amount'];
                Db::startTrans();
                $error = 0;
                $detailed_data = array(
                    'transaction_amount' => '+'.$data['transaction_amount'],
                    'user_id' => $store_withdrawal['user_id'],
                    'detailed' => '提现失败退回',
                    'transaction_number' => get_order_sn(),
                    'create_time' => date('Y-m-d'),
                    'remaining_balance' => $remainingBalance,
                    'withdrawa_status' => 2
                );
                $release_detailed = Db::name('release_detailed')->insert($detailed_data);
                if(!$release_detailed){
                    $error = 1;
                    Db::rollback();
                }
                $user_balance = Db::name('release_user')->where('id', $store_withdrawal['user_id'])->update([
                    'balance' => $remainingBalance
                ]);
                if(!$user_balance){
                    $error = 2;
                    Db::rollback();
                }
                Db::name('release_detailed')->where('id',$data['id'])->update(array('extract_status'=>2));
                if($error == 0){
                    Db::commit();
                }
                $this->success('保存成功');
            }
            if($data['extract_status'] == 1 && $rufund_success == 1){
                Db::name('release_detailed')->where('id',$data['id'])->update(array('extract_status'=>1));
                $this->success('提现成功');
            }else{
                $this->error('提现失败');
            }
        }
    }

    /**
     * 表单结果处理
     * @param boolean $result
     */
    protected function _form_result($result)
    {
        if ($result && $this->request->isPost()) {
            $this->success('操作成功！', 'javascript:history.back()');
        }
    }

    /**
     * 订单详情
     * @auth true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function order_detail()
    {
        $this->_form($this->table);
    }


    /**
     * 删除
     * @auth true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function remove()
    {
        $this->_delete($this->table);
    }
}