<?php

namespace app\operations\model\plus\agent;

use app\common\library\easywechat\AppWx;
use app\common\library\easywechat\AppMp;
use app\common\model\app\AppMp as AppMpModel;
use app\common\model\app\AppOpen as AppOpenModel;
use app\common\model\app\AppWx as AppWxModel;
use app\common\model\plus\agent\Setting;
use app\common\service\message\MessageService;
use app\common\service\order\OrderService;
use app\common\library\easywechat\WxPay;
use app\common\model\plus\agent\Cash as CashModel;
use app\operations\model\user\User as UserModel;
use app\operations\service\order\ExportService;
use app\common\library\fbpay\FbPay;
use app\operations\model\user\UserAuth;
use app\operations\model\shop\FbCashApply;

/**
 * 分销商提现明细模型
 */
class Cash extends CashModel
{
    /**
     * 获取器：申请时间
     */
    public function getAuditTimeAttr($value)
    {
        return $value > 0 ? date('Y-m-d H:i:s', $value) : 0;
    }

    /**
     * 获取器：打款方式
     */
    public function getPayTypeAttr($value)
    {
        return ['text' => $this->payType[$value], 'value' => $value];
    }

    /**
     * 获取分销商提现列表
     */
    public function getList($user_id = null, $apply_status = -1, $pay_type = -1, $search = '')
    {
        $model = $this;
        // 构建查询规则
        $model = $model->alias('cash')
            ->with(['user'])
            ->field('cash.*, agent.real_name, agent.mobile, user.nickName, user.avatarUrl')
            ->join('user', 'user.user_id = cash.user_id')
            ->join('agent_user agent', 'agent.user_id = cash.user_id')
            ->order(['cash.create_time' => 'desc']);
        // 查询条件
        if ($user_id > 0) {
            $model = $model->where('cash.user_id', '=', $user_id);
        }
        if (!empty($search)) {
            $model = $model->where('agent.real_name|agent.mobile', 'like', '%' . $search . '%');
        }
        if ($apply_status > 0) {
            $model = $model->where('cash.apply_status', '=', $apply_status);
        }
        if ($pay_type > 0) {
            $model = $model->where('cash.pay_type', '=', $pay_type);
        }
        // 获取列表数据
        return $model->paginate(15);
    }

    /**
     * 分销商提现审核
     */
    public function submit($param)
    {
        $data = ['apply_status' => $param['apply_status']];
        if ($param['apply_status'] == 30) {
            $data['reject_reason'] = $param['reject_reason'];
        }
        // 更新申请记录
        $data['audit_time'] = time();
        self::update($data, ['id' => $param['id']]);
        // 提现驳回：解冻分销商资金
        if ($param['apply_status'] == 30) {
            User::backFreezeMoney($param['user_id'], $param['money']);
        }

        // 发送模板消息
        (new MessageService)->cash($this);
        return true;
    }

    /**
     * 确认已打款
     */
    public function money()
    {
        $this->startTrans();
        try {
            // 更新申请状态
            $data = ['apply_status' => 40, 'audit_time' => time()];
            self::update($data, ['id' => $this['id']]);

            // 更新分销商累积提现佣金
            User::totalMoney($this['user_id'], $this['money']);

            // 记录分销商资金明细
            Capital::add([
                'user_id' => $this['user_id'],
                'flow_type' => 20,
                'money' => -$this['money'],
                'describe' => '申请提现',
            ]);
            // 发送模板消息
           //(new Message)->withdraw($this);
            // 事务提交
            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }

    /**
     * 分销商提现：微信支付企业付款
     */
    public function wechatPay()
    {
        $settlement = Setting::getItem('settlement');
        if($settlement['wechat_type'] == 0){
            return $this->wechatPay0();
        }else {
            return $this->wechatPay1();
        }
    }

    /**
     * 分销商提现：微信支付企业付款
     */
    public function wechatPay0()
    {
        // 微信用户信息
        $user = UserModel::detail($this['user_id']);
        // 生成付款订单号
        $orderNO = OrderService::createOrderNo();
        // 付款描述
        $desc = '分销商提现付款';
        // 微信支付api：企业付款到零钱
        $open_id = '';
        $app = [];
        if($user['reg_source'] == 'mp'){
            $app = AppMp::getWxPayApp($user['app_id']);
            $open_id = $user['mpopen_id'];
        }else if($user['reg_source'] == 'wx'){
            $app = AppWx::getWxPayApp($user['app_id']);
            $open_id = $user['open_id'];
        }

        if($open_id == ''){
            $this->error = '未找到用户open_id';
            return false;
        }

        $WxPay = new WxPay($app);
        // 请求付款api
        if ($WxPay->transfers($orderNO, $open_id, $this['money'], $desc)) {
            // 确认已打款
            $this->money();
            return true;
        }
        return false;
    }
    
     /**
     * 商家转账到零钱
     */
    public function wechatPay1()
    {
        // 微信用户信息
        $user = UserModel::detail($this['user_id']);
        // 生成付款订单号
        $orderNO = OrderService::createOrderNo();
        // 付款描述
        $desc = '余额提现付款';
        // 微信支付api：企业付款到零钱
        $open_id = '';
        $app_id = '';
        if ($user['reg_source'] == 'mp') {
            $open_id = $user['mpopen_id'];
            $wxConfig = AppMpModel::getAppMpCache($app_id);
            $app_id = $wxConfig['mpapp_id'];
        } else if ($user['reg_source'] == 'wx') {
            $open_id = $user['open_id'];
            $wxConfig = AppWxModel::getAppWxCache($app_id);
            $app_id = $wxConfig['wxapp_id'];
        } else if ($user['reg_source'] == 'app') {
            $open_id = $user['appopen_id'];
            $wxConfig = AppOpenModel::getAppOpenCache($app_id);
            $app_id = $wxConfig['openapp_id'];
        }

        if ($open_id == '') {
            $this->error = '未找到用户open_id';
            return false;
        }

        $pars = [];
        $pars['appid'] = $app_id;//直连商户的appid
        $pars['out_batch_no'] = 'sjzz'.date('Ymd').mt_rand(1000, 9999);//商户系统内部的商家批次单号，要求此参数只能由数字、大小写字母组成，在商户系统内部唯一
        $pars['batch_name']   = $desc;//该笔批量转账的名称
        $pars['batch_remark'] = $desc;//转账说明，UTF8编码，最多允许32个字符
        $pars['total_amount'] = intval($this['money'] * 100);//转账总金额 单位为“分”
        $pars['total_num']    = 1;//转账总笔数
        $pars['transfer_detail_list'][0]  = [
            'out_detail_no'=>'Dh'.$orderNO,
            'transfer_amount'=>$pars['total_amount'],
            'transfer_remark'=> $desc,
            'openid' => $open_id
        ];//转账明细列表
        //获取token
        $wxPay = new WxPay(null);
        $res = $wxPay->wechatTrans($pars, $user['app_id']);
        $resArr = json_decode($res,true);
        if(isset($resArr['batch_id'])){
            $this->save([
                'batch_id' => $resArr['batch_id']
            ]);
            // 确认打款
            $this->money();
            return true;
        }else{
            $this->error = $resArr['message'];
            return false;
        }
    }

    /**
     * 分销商提现：分账功能
     */
    public function fbPay()
    {
        // 用户认证的信息
        $userAuth = UserAuth::detail($this['user_id']);
        if(empty($userAuth)){
            $this->error = '该用户未实名认证';
            return false;
        }elseif(!empty($userAuth) && empty($userAuth["account_id"])){
            $this->error = '该用户实名认证还未审核通过';
            return false;
        }
        //获取向付呗申请的记录
        $where["cash_id"] = $this['id'];
        $apply = FbCashApply::detail($where);
        if(empty($apply)){
            //只生成一次订单 否则造成多次打同一笔款
            $merchant_order_sn = OrderService::createOrderNo();
            // 更新订单号：用于回调 更新打款状态
            $save_data = [
                'merchant_order_sn' => $merchant_order_sn,
                'cash_id' => $this['id'],
                'type' => 'agent',
                'user_id' => $this['user_id'],
            ];
            $model =new FbCashApply();
            $model->save($save_data);
        }else{
            $merchant_order_sn = $apply['merchant_order_sn'];
        }

        // 分账接收方ID
        $data["account_id"] = $userAuth["account_id"];
        // 生成付款订单号
        $data["merchant_order_sn"] = $merchant_order_sn;
        //打款金额
        $data["amount"]=$this['real_money'];

        //如果是付呗接口，配置参数 by yj
        $app = FbPay::getFbPayApp($userAuth["app_id"], 'wx');
        $FbPay = new FbPay($app);
        // 请求分账api
        if ($FbPay->withdraw($data)) {
            return true;
        }
        return false;
    }

    /*
     *统计提现总数量
     */
    public function getAgentOrderTotal()
    {
        return $this->count('id');
    }

    /*
    * 统计提现待审核总数量
    */
    public function getAgentApplyTotal($apply_status)
    {
        return $this->where('apply_status', '=', $apply_status)->count();
    }

    /**
     * 导出分销商提现
     */
    public function exportList($user_id = null, $apply_status = -1, $pay_type = -1, $search = '')
    {
        $model = $this;
        // 构建查询规则
        $model = $model->alias('cash')
            ->with(['user'])
            ->field('cash.*, agent.real_name, agent.mobile, user.nickName, user.avatarUrl')
            ->join('user', 'user.user_id = cash.user_id')
            ->join('agent_user agent', 'agent.user_id = cash.user_id')
            ->order(['cash.create_time' => 'desc']);
        // 查询条件
        if ($user_id > 0) {
            $model = $model->where('cash.user_id', '=', $user_id);
        }
        if (!empty($search)) {
            $model = $model->where('agent.real_name|agent.mobile', 'like', '%' . $search . '%');
        }
        if ($apply_status > 0) {
            $model = $model->where('cash.apply_status', '=', $apply_status);
        }
        if ($pay_type > 0) {
            $model = $model->where('cash.pay_type', '=', $pay_type);
        }
        // 获取列表数据
        $list = $model->select();
        // 导出excel文件
        (new Exportservice)->cashList($list);

    }

}