<?php

namespace app\common\library\fbpay;

use app\api\service\order\paysuccess\type\PayTypeSuccessFactory;
use app\common\enum\order\OrderTypeEnum;
use app\common\enum\order\OrderPayTypeEnum;
use app\common\exception\BaseException;
use app\common\model\app\AppWx as AppWxModel;
use think\helper\Str;
use EasyWeChat\Factory;
use app\common\model\user\UserAuth as UserAuthModel;
use app\shop\model\shop\FbCashApply;
use app\shop\service\FbCashApply as FbCashApplyService;
use app\common\model\app\App as AppModel;
use app\common\model\app\AppPay as AppPayModel;
use app\api\model\settings\Setting as SettingModel;
use app\common\model\supplier\Supplier as SupplierModel;

/**
 * 付呗支付
 */
class FbPay
{
    // 付呗支付配置
    private $app;

    private $gateway = 'https://shq-api.51fubei.com/gateway/agent';

    /**
     * 构造函数
     */
    public function __construct($app)
    {
        $this->app = $app;
    }

    /**
     * 统一下单API
     */
    public function unifiedorder($order_no, $openid, $totalFee, $orderType = OrderTypeEnum::MASTER, $pay_source, $multiple)
    {
        //判断是否使用付呗插件，兼容其他商户的付呗支付 by yj 2023.12.16
        if(!empty($this->app['config']["is_use_plus"])){
            $sub_appid = $this->app['config']["cashier_app_id"];
        }else{
            $sub_appid = $this->app['config']["app_id"];
        }

        $requestConfigs = array(
            'merchant_id' => $this->app['config']["merchant_id"],
            'store_id' => $this->app['config']["store_id"],
            //'sub_appid' => $this->app['config']["app_id"],
            'sub_appid'=> $sub_appid,
            'merchant_order_sn' => $order_no,
            'total_amount' => $totalFee,
            'user_id' => $openid,
            'pay_type' => "wxpay",
            'body' =>$order_no,
            'attach' => ['order_type' => $orderType, 'pay_source' => $pay_source, 'multiple' => $multiple],
            'notify_url' => base_url() . 'index.php/job/notify/fbpay',
        );
        //使用插件才能传该字段 by yj 2023.12.22
        if(!empty($this->app['config']["is_use_plus"])){
            $requestConfigs["pay_scene"] = "OPENAPI_PAYMENT_APPLET_PLUGIN";
            $requestConfigs["timeout_express"] = date('YmdHis',time() + 60 * 15);
        }
        $commonConfigs = array(
            //公共参数
            'method' => 'fbpay.order.create',
            'format' => 'json',
            'sign_method' => 'md5',
            'nonce' => Str::random(32),
            'version' => '2.0',
            'biz_content' => json_encode($requestConfigs),
        );
        if($this->app['config']["vendor_sn"]) {
            $commonConfigs['vendor_sn'] = $this->app['config']["vendor_sn"];
        } else {
            $commonConfigs['app_id'] = $this->app['config']["fbapp_id"];
        }
        $commonConfigs["sign"] = $this->makeSign($commonConfigs);
        $result = $this->curlPostContents($this->gateway,$commonConfigs);
        $result = json_decode($result);

        if($result->result_code != 200){
            throw new BaseException(['msg' => '付呗支付api: ' . $result->result_message]);
        }
        $sign_package = (array)($result->data->sign_package);
        // log_write($result);
        //如果是微信小程序
        $time = time();
        if($pay_source == 'wx') {
            // 二次签名的参数必须与下面相同
            $params = [
                'appId' => $sign_package['appId'],//有所修改
                'timeStamp' => $time,
                'nonceStr' => $sign_package['nonceStr'],
                'package' => $sign_package['package'],
                'signType' => 'MD5',
            ];
            //$sign_package['paySign'] = $this->makeSign($params);
            //$sign_package['paySign'] = $sign_package['paySign'];
            $sign_package['prepay_id'] = str_replace('prepay_id=', '', $sign_package['package']);
            $result_data =[
                'prepay_id' => $sign_package['prepay_id'],
                'nonceStr' => $sign_package['nonceStr'],
                'timeStamp' => $sign_package['timeStamp'],
                'paySign' => $sign_package['paySign'],
                'signType' => $sign_package['signType'],
              //  'orderSn'=>$result->data->order_sn,// 付呗新增参数 by yj 2023.12.16
                'apiType'=>1,//返回付呗支付标识 0微信原生 1付呗支付  by yj 2023.12.16
            ];
            if(!empty($this->app['config']["is_use_plus"])){
                $result_data["orderSn"] = $result->data->order_sn;
            }
            return $result_data;
        }
        return $sign_package;
    }

    /**
     * 支付成功异步通知
     */
    public function notify()
    {
        log_write('付呗回调');
        $data = json_decode($_POST['data'], true);
        $attach = json_decode($data['attach'], true);
        // 实例化订单模型
        $PaySuccess = PayTypeSuccessFactory::getFactory($data['merchant_order_sn'], $attach);
        $app_id = $PaySuccess->isExist();
        $app_id == 0 && $this->returnCode(false, '订单不存在1');
        $shop_supplier_id = $PaySuccess->isExistSupplier();
        // $shop_supplier_id == 0 && $this->returnCode(false, '订单商户不存在2'); // 暂时屏蔽 by lyzflash 20251029
        // 支付配置信息
        $this->app = $this->getFbPayApp($app_id,$shop_supplier_id);
        // 保存微信服务器返回的签名sign
        $dataSign = $_POST['sign'];
        // sign不参与签名算法
        unset($_POST['sign']);
        // 生成签名
        $sign = $this->makeSign($_POST);
        // 判断签名是否正确 判断支付状态
        if (
            ($sign !== $dataSign)
            || ($data['order_status'] !== 'SUCCESS')
        ) {
            $this->returnCode(false, '签名失败');
        }
        // 订单支付成功业务处理
        $data['transaction_id'] = $data['channel_order_sn'];
        $status = $PaySuccess->onPaySuccess(OrderPayTypeEnum::WECHAT, $data);
        if ($status == false) {
            echo 'error';
            exit();
        }
        // 返回状态
        echo 'success';
        exit();
    }

    /**
     * 申请退款API
     */
    public function refund($transaction_id, $order_no, $refund_fee)
    {
        //请求参数
        $requestConfigs = array(
            'merchant_order_sn' => $order_no,
            'merchant_refund_sn' => $transaction_id,
            'refund_amount' => $refund_fee,
        );
        if($this->app['config']["vendor_sn"]) {
            $requestConfigs['merchant_id'] = $this->app['config']["merchant_id"];
        }
        $commonConfigs = array(
            //公共参数
            'method' => 'fbpay.order.refund',
            'format' => 'json',
            'sign_method' => 'md5',
            'nonce' => Str::random(32),
            'version' => '2.0',
            'biz_content' => json_encode($requestConfigs),
        );
        if($this->app['config']["vendor_sn"]) {
            $commonConfigs['vendor_sn'] = $this->app['config']["vendor_sn"];
        } else {
            $commonConfigs['app_id'] = $this->app['config']["fbapp_id"];
        }
        $commonConfigs["sign"] = $this->makeSign($commonConfigs);
        $result = $this->curlPostContents($this->gateway,$commonConfigs);
        $result = json_decode($result);
        if($result->result_code && $result->result_code == 200){
            return true;
        }else{
            throw new BaseException(['msg' => 'return_msg: ' . $result->result_message]);
        }
    }

    /**
     * 企业付款到零钱API
     */
    public function transfers($order_no, $openid, $amount, $desc)
    {
        $result = $this->app->transfer->toBalance([
            'partner_trade_no' => $order_no, // 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号)
            'openid' => $openid,
            'check_name' => 'NO_CHECK', // NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名
            'amount' => $amount * 100, // 企业付款金额，单位为分
            'desc' => $desc, // 企业付款操作说明信息。必填
        ]);
        // 请求失败
        if (empty($result)) {
            throw new BaseException(['msg' => '微信提现到零钱api请求失败']);
        }
        // 请求失败
        if ($result['return_code'] === 'FAIL') {
            throw new BaseException(['msg' => 'return_msg: ' . $result['return_msg']]);
        }
        if ($result['result_code'] === 'FAIL') {
            throw new BaseException(['msg' => 'err_code_des: ' . $result['err_code_des']]);
        }
        return true;
    }

    /**
     * 上传加密图片
     */
    public function imgupload($file_data, $bus_type='bankCard')
    {
        //请求参数
        $requestConfigs = array(
            'bus_type' => $bus_type,
            'file_data' => $file_data,
        );
        $commonConfigs = array(
            //公共参数
            'method' => 'openapi.agent.base.imgupload.security',
            'format' => 'json',
            'sign_method' => 'md5',
            'nonce' => Str::random(32),
            'version' => '2.0',
            'biz_content' => json_encode($requestConfigs),
        );
        if($this->app['config']["vendor_sn"]) {
            $commonConfigs['vendor_sn'] = $this->app['config']["vendor_sn"];
        } else {
            $commonConfigs['app_id'] = $this->app['config']["fbapp_id"];
        }
        $commonConfigs["sign"] = $this->makeSign($commonConfigs);
        $result = $this->curlPostContents($this->gateway,$commonConfigs);
        $result = json_decode($result);
        if($result->result_code && $result->result_code == 200){
            $resource_id = (array)($result->data->resource_id);
            return $resource_id;
        }else{
            throw new BaseException(['msg' => 'return_msg: ' . $result->result_message]);
        }
    }

    /**
     * 分账接收方入驻
     */
    public function subaccount($data)
    {
        //请求参数
        $requestConfigs = $data;
        $commonConfigs = array(
            //公共参数
            'method' => 'openapi.agent.account.subaccount.income',
            'format' => 'json',
            'sign_method' => 'md5',
            'nonce' => Str::random(32),
            'version' => '2.0',
            'biz_content' => json_encode($requestConfigs),
        );
        if($this->app['config']["vendor_sn"]) {
            $commonConfigs['vendor_sn'] = $this->app['config']["vendor_sn"];
        } else {
            $commonConfigs['app_id'] = $this->app['config']["fbapp_id"];
        }
        $commonConfigs["sign"] = $this->makeSign($commonConfigs);
        $result = $this->curlPostContents($this->gateway,$commonConfigs);
        $result = json_decode($result);
       // print_r($result);exit;
        if($result->result_code && $result->result_code == 200){
            $resutl_data = (array)($result->data);
            return $resutl_data["account_id"];
        }else{
            throw new BaseException(['msg' => '请把信息填写完整再提交: ' . $result->result_message]);
        }
    }

    /**
     * 分账接收方入驻回调
     */
    public function subaccountResult()
    {
        log_write('入驻回调');
        $data = json_decode($_POST['data'], true);

        $where["merchant_order_sn"]=$data["merchant_order_sn"];
        $model = UserAuthModel::detailById($where);
        if(empty($model)){
            $this->returnCode(false, '数据不存在');
        }

        // 数据处理
        $save_data['account_id'] = $data['account_id'];
        $save_data['auth_status'] = $data['status'];
        $save_data['fail_message'] = $data['fail_message'];
        $status = $model->save($save_data);
        if ($status == false) {
            echo 'error';
            exit();
        }
        // 返回状态
        echo 'success';
        exit();
    }

    /**
     * 分账提现API
     */
    public function withdraw($data)
    {
        //请求参数
        $requestConfigs = array(
            'merchant_order_sn' => $data["merchant_order_sn"],
            'account_id' => $data["account_id"],
            'amount' => $data["amount"],
            'type' => 1,//提现方式 1慢  2快（每日十次）
            'notify_url' => base_url() . 'index.php/job/notify/withdraw_result'
        );
        if($this->app['config']["vendor_sn"]) {
            $requestConfigs['merchant_id'] = $this->app['config']["merchant_id"];
        }
        $commonConfigs = array(
            //公共参数
            'method' => 'openapi.agent.account.withdraw',
            'format' => 'json',
            'sign_method' => 'md5',
            'nonce' => Str::random(32),
            'version' => '2.0',
            'biz_content' => json_encode($requestConfigs),
        );
        if($this->app['config']["vendor_sn"]) {
            $commonConfigs['vendor_sn'] = $this->app['config']["vendor_sn"];
        } else {
            $commonConfigs['app_id'] = $this->app['config']["fbapp_id"];
        }
        $commonConfigs["sign"] = $this->makeSign($commonConfigs);
        $result = $this->curlPostContents($this->gateway,$commonConfigs);
        $result = json_decode($result);
        if($result->result_code && $result->result_code == 200){
            $resutl_data = (array)($result->data);
            $save_data = [
                "bank_name"=>$resutl_data["bank_name"],//银行名称
                "bank_card_no"=>$resutl_data["bank_card_no"],//银行卡号
                "create_time"=>$resutl_data["create_time"],//申请付呗打款的时间
                "finish_time"=>$resutl_data["finish_time"],//预计到账的时间
                "status"=>$resutl_data["status"],//提现中
                "amount"=>$resutl_data["amount"],//提现金额
            ];
            FbCashApply::update($save_data, ['merchant_order_sn' => $resutl_data["merchant_order_sn"]]);
            return true;
        }else{
            throw new BaseException(['msg' => 'return_msg: ' . $result->result_message]);
        }
    }

    /**
     * 分账结果回调
     */
    public function withdrawResult()
    {
        log_write('分账结果回调');
        $data = json_decode($_POST['data_list'], true);
        $status = FbCashApplyService::applySuccess($_POST['merchant_order_sn'],$data);
        if ($status == false) {
            echo 'error';
            exit();
        }
        // 返回状态
        echo 'success';
        exit();
    }

    /**
     * 微信参数配置
     */
    public function wxconfig()
    {
        //请求参数
        $requestConfigs = array(
            'store_id' => $this->app['config']["store_id"],
            'merchant_id' => $this->app['config']["merchant_id"],
            'sub_appid' => $this->app['config']['is_embed'] ? $this->app['config']["embed_app_id"] : $this->app['config']["app_id"],
            'account_type' => '01',
            'jsapi_path' => base_url() . 'h5/pages/order/',
        );
        $commonConfigs = array(
            //公共参数
            'method' => 'fbpay.order.wxconfig',
            'format' => 'json',
            'sign_method' => 'md5',
            'nonce' => Str::random(32),
            'version' => '2.0',
            'biz_content' => json_encode($requestConfigs),
        );
        if($this->app['config']["vendor_sn"]) {
            $commonConfigs['vendor_sn'] = $this->app['config']["vendor_sn"];
        } else {
            $commonConfigs['app_id'] = $this->app['config']["fbapp_id"];
        }
        $commonConfigs["sign"] = $this->makeSign($commonConfigs);
        $result = $this->curlPostContents($this->gateway,$commonConfigs);
        $result = json_decode($result);
       /* if($result->result_code && $result->result_code == 200){
            return true;
        }else{
            throw new BaseException(['msg' => '付呗微信配置返回: ' . $result->result_message]);
        }*/
        if($result->result_code && $result->result_code == 200 && ($result->data->sub_appid_code == 1 || $result->data->jsapi_code == 1)){
            return true;
        }else{
            if ($result->data->sub_appid_code != 1) {
                throw new BaseException(['msg' => '付呗微信配置返回: ' . $result->data->sub_appid_msg]);
                return false;
            }
            if ($result->data->jsapi_code != 1) {
                throw new BaseException(['msg' => '付呗微信配置返回: ' . $result->data->jsapi_msg]);
                return false;
            }
            throw new BaseException(['msg' => '付呗微信配置返回: ' . $result->result_message]);
        }
    }

    /**
     * 返回状态给微信服务器
     */
    private function returnCode($returnCode = true, $msg = null)
    {
        // 返回状态
        $return = [
            'return_code' => $returnCode ? 'SUCCESS' : 'FAIL',
            'return_msg' => $msg ?: 'OK',
        ];
        // 记录日志
        log_write([
            'describe' => '返回微信支付状态',
            'data' => $return
        ]);
        die($this->toXml($return));
    }

    /**
     * 输出xml字符
     * @param $values
     * @return bool|string
     */
    private function toXml($values)
    {
        if (!is_array($values)
            || count($values) <= 0
        ) {
            return false;
        }

        $xml = "<xml>";
        foreach ($values as $key => $val) {
            if (is_numeric($val)) {
                $xml .= "<" . $key . ">" . $val . "</" . $key . ">";
            } else {
                $xml .= "<" . $key . "><![CDATA[" . $val . "]]></" . $key . ">";
            }
        }
        $xml .= "</xml>";
        return $xml;
    }

    /**
     * 生成签名
     */
    private function makeSign($values)
    {
        //签名步骤一：按字典序排序参数
        ksort($values);
        $string = $this->toUrlParams($values);
        //签名步骤二：在string后加入KEY
        $string = trim($string, '&') . $this->app['config']['secret'];
        //签名步骤三：MD5加密
        $string = md5($string);
        //签名步骤四：所有字符转为大写
        $result = strtoupper($string);
        return $result;
    }

    /**
     * 格式化参数格式化成url参数
     */
    private function toUrlParams($values)
    {
        $buff = '';
        foreach ($values as $k => $v) {
            if ($k != 'sign' && $v != '' && !is_array($v)) {
                $buff .= $k . '=' . $v . '&';
            }
        }
        return trim($buff, '&');
    }

    public static function getFbPayApp($app_id,$shop_supplier_id =0){
        // 获取当前小程序信息
        $wxConfig = AppWxModel::getAppWxCache($app_id);
        //获取后台是否设置了商户独立收款 by yj 2024.3.12
        //$is_independent = SettingModel::getIndependentOpen();
        $is_independent = SupplierModel::getIndependentOpen($shop_supplier_id);
        if(!empty($is_independent)){
            //分每个商户有单独的付呗支付信息
            $app = AppPayModel::detail($shop_supplier_id);
        }else{
            $app = AppModel::detail($app_id);
        }
        // 验证fbpay_vendor_sn或fbpay_app_id是否填写，不能全为空
        if (empty($app['fbpay_vendor_sn']) && empty($app['fbpay_app_id'])) {
            throw new BaseException(['msg' => '请到 [后台-应用-小程序设置] 服务商开放平台vendor-sn和商户开放平台app_id不能全为空']);
        }
        if (empty($app['fbpay_secret']) || empty($app['fbpay_merchant_id']) || empty($app['fbpay_store_id'])) {
            throw new BaseException(['msg' => '请到 [后台-应用-小程序设置] 填写相关参数']);
        }

        $config = [
            'app_id'        => $wxConfig['wxapp_id'],
            'vendor_sn'     => $app['fbpay_vendor_sn'],
            'secret'        => $app['fbpay_secret'],
            'merchant_id'   => $app['fbpay_merchant_id'],
            'store_id'      => $app['fbpay_store_id'],
            'fbapp_id'      => $app['fbpay_app_id'],
            'is_use_plus'   => $app['is_use_plus'],// 用于判断是否用付呗收银台插件
            'cashier_app_id'=> $app['fbpay_cashier_app_id'],// 付呗收银台插件使用
            'is_embed'    => $app['is_embed'], // 是否开启半屏小程序支付
            'embed_app_id'=> $app['embed_app_id'], // 半屏小程序的appId
            'embed_key' => $app['embed_key'], // 半屏小程序安全密钥
            'embed_path' => $app['embed_path'], // 半屏小程序支付路径
        ];
        return Factory::payment($config);
    }
    /**
     * 提交提交结果
     * @param $url 网关地址
     * @param array $data 请求参数
     * @param int $timeout 超时时间
     * @return bool|string
     * @throws Exception
     */
    public static function curlPostContents($url, $data = array(), $timeout=10){
        $data_string = json_encode($data);
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL,$url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER,1);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
        curl_setopt($ch, CURLOPT_POSTFIELDS,$data_string);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER,true);
        curl_setopt($ch, CURLOPT_TIMEOUT,$timeout);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                'Content-Type: application/json',
                'Content-Length: ' . strlen($data_string))
        );
        $result = curl_exec($ch);
        if ($no = curl_errno($ch)) {
            $error = curl_error($ch);
            curl_close($ch);
            if(in_array(intval($no), [7, 28], true)) {
                throw new BaseException(['msg' => '连接或请求超时' . $error]);
            }
        }
        curl_close($ch);
        return $result;
    }
}