shenying/crmeb/services/WithdrawService.php

<?php
/**
 * @Created by PhpStorm
 * @author: Kirin
 * @day: 2023/12/19
 * @time: 16:09
 */

namespace crmeb\services;


use crmeb\exceptions\ApiException;
use think\Exception;

class WithdrawService
{
    static $url = 'https://testshuichou.zhuoyankeji.com';
    //    static $url = 'https://api.yeeshui.com';
    static $token;
    static $user_name = '星领测试';
    static $password = '123456';
    static $secret = '2a879ac637d65ced5ed5892e1bf82e4c';
    static $aeskey = '37d65ced5ed5892e';


    public function __construct($token)
    {
        self::$token = $token;
    }

    public static function init()
    {
        $token = CacheService::get('withdraw_token', '');
        if (!$token) {
            $token = self::login();
            CacheService::set('withdraw_token', $token, 500);
        }
        return new self($token);
    }


    /**
     * 新增人员
     * @param $name
     * @param $id_card
     * @param $bank_code
     * @param $mobile
     * @param $front_img
     * @param $back_img
     * @return false|string
     */
    public static function addEmployee($name, $id_card, $bank_code, $mobile, $front_img, $back_img)
    {
        $url = '/Enterprise/addEmployee';
        $data = [
            'name' => $name,//姓名
            'cer_code' => $id_card,//身份证号码
            'bank_code' => $bank_code,//银行卡号
            'mobile' => $mobile,//银行卡预留手机号
            'has_auth' => 1,
            'source' => 1,
            "sign_img" => "",
            "protocol_img" => "",
            "contract_img" => "",
            'auth' => "2",
            'cer_front_img' => $front_img,//身份证正面照
            'cer_reverse_img' => $back_img,//身份证反面照
        ];
        $token = self::$token;
        return self::postRequest(self::$url . $url, compact('data', 'token'));
    }


    public static function applySignUrl($id)
    {
        $url = '/Enterprise/applySignUrl';
        $data = [
            'professional_id' => $id,//姓名
            'back_url' => sys_config('site_url'),//返回网址
            'sign_type' => 'letsign',//银行卡号
        ];
        $token = self::$token;
        return self::postRequest(self::$url . $url, compact('data', 'token'));
    }


    public static function querySignResult($id)
    {
        $url = '/Enterprise/querySignResult';
        $data = [
            'transactionCode' => $id,//姓名
        ];
        $token = self::$token;
        return self::postRequest(self::$url . $url, compact('data', 'token'));
    }

    public static function contractDo($id)
    {

        $url = '/Enterprise/contractDo';
        $data = [
            'enterprise_professional_facilitator_id' => $id,//姓名
        ];
        $token = self::$token;
        return self::postRequest(self::$url . $url, compact('data', 'token'));
    }

    public static function postRequest($url, $data)
    {
        $res = json_decode(self::do_request($url, $data, ['content-type:application/json'], true, true), true);
        if ($res['code'] == 200) {
            try {
                return self::decode($res['data']);
            } catch (\Exception $exception) {
                throw new ApiException($exception->getMessage());
            }
        } else {
            throw new ApiException($res['msg'] ?? '处理失败');
        }
    }


    private static function login()
    {
        $data = [
            'user_name' => self::$user_name,
            'password' => self::$password,
            'timestamp' => time(),
        ];
        ksort($data);
        $signString = http_build_query($data) . '&secret=' . self::$secret;
        $sign = md5($signString);
        $data['sign'] = $sign;
        $res = json_decode(self::do_request(self::$url . '/sdk/v1/login', $data, ['content-type:application/json'], true, true), true);
        if ($res['code'] == 200) {
            return $res['token'];
        } else {
            throw new ApiException($res['msg'] ?? '企业登陆失败');
        }
    }

    private static function decode($businessBodyString)
    {
        //进行Aes解密
        include_once 'phpseclib/Crypt/AES.php';
        $aes = new \Crypt_AES(CRYPT_AES_MODE_ECB);
        $aes->setKey(self::$aeskey);
        $data = $aes->decrypt(base64_decode($businessBodyString));
        return json_decode(base64_decode($data), true);
    }


    private static function do_request($url, $data, $header = null, $post = true, $json = false, $format = 0, $form = false)
    {
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        if ($post) {
            curl_setopt($curl, CURLOPT_POST, 1);
            if (!$json && !$form) {
                curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data));
            } else if ($json && !$form) {
                curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data, $format));
            } else {
                curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
            }
        }
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        if ($header) {
            curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
            curl_setopt($curl, CURLOPT_HEADER, 0);
        }
        $result = curl_exec($curl);
        if (curl_errno($curl)) {
            return json_encode(['status' => curl_errno($curl), 'msg' => '请求失败']);
        }
        curl_close($curl);
        return $result;
    }
}