zhangsiye/server/app/Helper/ByteDance.php

<?php

namespace App\Helper;

use App\Helper\UniPlatform\BaseAPI;
use App\Helper\UniPlatform\BaseUniPlatform;
use Carbon\Carbon;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;

/**
 * Class ByteDance
 *
 * @package App\Helper
 * @property-read  string $appId
 * @property-read  string $slat
 * @property-read  string $secret
 * @property-read  string $token
 * @property-read  string $accessTokenFile
 * @property-read  string $accessToken
 * @property-read  string $noticeUrl
 * @property-read  string $validTimestamp
 */
class ByteDance extends BaseUniPlatform
{

    public function __construct(BaseAPI $api)
    {
        $this->API  = $api;
    }

    /**
     * 获取 access token
     * @throws \Exception
     */
    protected function getAccessToken() : string
    {
        $res = $this->post($this->API::ACCESS_TOKEN, [
            'grant_type' => 'client_credential',
            'appid'      => $this->appId,
            'secret'     => $this->secret,
        ]);
        if (!empty($res['err_no'])) {
            throw new \Exception('获取access token 错误');
        }

        file_put_contents($this->accessTokenFile, json_encode([
            'access_token' => $res['access_token'],
            'expires_at'   => $res['expiresAt']
        ]));

        return $res['access_token'];
    }

    /**
     * @param $outOrderNo
     * @param $totalAmount
     * @param $openId
     * @return array|mixed
     * @throws \Exception
     */
    public function createOrder($outOrderNo, $totalAmount, $openId): array
    {
        $data = [
            'app_id'       => $this->appId,
            'out_order_no' => $outOrderNo,
            'total_amount' => intval($totalAmount * 100),
            'subject'      => "订单号：".$outOrderNo,
            'body'         => '抖音担保支付',
            'valid_time'   => $this->validTimestamp,
            'sign'         => $this->secret
            //'notify_url'   => $notifyUrl, // 可以不设置 使用小程序后台设置的回调
        ];
        $data = array_filter($data);
        $data['sign'] = $this->getSign($data);

        return $this->post(
            $this->API::CREATE_ORDER,
            $data
        );
    }

    /**
     * 结算
     * @param $outOrderNo
     * @return array|mixed|string[]
     * @throws \Exception
     */
    public function settle($outOrderNo)
    {
        $data = [
            'app_id'        => $this->appId,
            'out_settle_no' => $outOrderNo,
            'out_order_no'  => $outOrderNo,
            'settle_desc'   => '主动结算',
        ];
        $data = array_filter($data);
        $data['sign'] = $this->getSign($data);

        return $this->post(
            $this->API::SETTLE,
            $data
        );
    }

    /**
     * @param array  $data
     * @return string
     */
    public function getSign(array $data)
    {
        $rList = [];
        foreach ($data as $k => $v) {
            if ($k == "other_settle_params" || $k == "app_id" || $k == "sign" || $k == "thirdparty_id")
                continue;
            $value = trim(strval($v));
            $len = strlen($value);
            if ($len > 1 && substr($value, 0, 1) == "\"" && substr($value, $len, $len - 1) == "\"")
                $value = substr($value, 1, $len - 1);
            $value = trim($value);
            if ($value == "" || $value == "null")
                continue;
            array_push($rList, $value);
        }
        array_push($rList, $this->slat);
        sort($rList, SORT_STRING);
        return md5(implode('&', $rList));
    }

    /**
     * @param array  $data
     * @return string
     */
    public function getNotifySign(array $data)
    {
        $filtered = [];
        foreach ($data as $key => $value) {
            if (in_array($key, ['msg_signature', 'type'])) {
                continue;
            }
            $value = trim(strval($value));
            $len = strlen($value);
            if ($len > 1 && substr($value, 0, 1) == "\"" && substr($value, $len, $len - 1) == "\"")
                $value = substr($value, 1, $len - 1);
            $filtered[] =
                is_string($value)
                    ? trim($value)
                    : $value;
        }
        $filtered[] = trim($this->token);
        sort($filtered, SORT_STRING);
        return sha1(trim(implode('', $filtered)));
    }

    public function pushOrder($openid, $orderId, $goods, $status)
    {
        $data = [
            'access_token' => $this->accessToken,
            'open_id'      => $openid,
            'order_type'   => 0, // 0：普通小程序订单（非 POI 订单）,
            'order_status' => 1,
            'app_name'     => 'douyin',
            'update_time'  => (int)Carbon::now()->getPreciseTimestamp(3),
            'order_detail' => json_encode([
                'order_id'    => $orderId,
                'create_time' => (int)Carbon::now()->getPreciseTimestamp(3),
                'status'      => $status, // 已支付 待支付
                'amount'      => 1,
                'total_price' => $goods['price'] * 100,
                'detail_url'  => 'pages/my/consume',
                'item_list'   => [
                    [
                        'item_code' => (string)$goods['id'], // 商品ID，
                        'img'       => 'https://zhengda.oss-cn-chengdu.aliyuncs.com/zhangsiye/images/26474488be1b83e2fcb0b9475508a9bb.png',
                        'title'     => $goods['title'],
                        'price'     => $goods['price'] * 100,
                    ]
                ]
            ],JSON_UNESCAPED_UNICODE),
        ];
        return $this->post($this->API::ORDER_PUSH, $data);
    }


    /**
     * @param string $code
     * @return array|mixed
     * @throws \Exception
     */
    public function login($code = ''): array
    {
        return $this->post($this->API::LOGIN, [
            'appid'      => $this->appId,
            'secret'     => $this->secret,
            'code'       => $code,
        ]);
    }

    /**
     * @return array|mixed
     * @throws \Exception
     */
    public function generateQrcode()
    {
        $userId = \user()->id;
        return $this->post($this->API::CREATE_QRCODE, [
            'appname'      => 'douyin',
            'access_token' => $this->accessToken,
            'path'         =>urlencode('pages/index/index?'."user_id=$userId"),
            'width'        => 600,
        ]);
    }

    /**
     * 接口请求
     *
     * @param string $uri
     * @param array  $data
     * @return array|mixed
     * @throws \Exception
     */
    protected function post($uri = '', $data = []) : array
    {
        try {
            $client = new Client();
            $res = $client->post($uri, [
                'verify'  => false,
                'headers' => ['Content-Type' => 'application/json'],
                'body'    => json_encode($data)
            ]);

            $stringBody = (string)$res->getBody();
            $res = json_decode($stringBody, true);
            // 生成二维码接口是直接放回 buffer的
            if(empty($res) && $uri == $this->API::CREATE_QRCODE){
                return [$stringBody];
            }

            if(isset($res['err_no']) && !empty($res['err_no'])){
                throw new \Exception("请求字节跳动API接口错误，错误码:{$res['err_no']},错误信息:{$res['err_tips']}");
            }

            if(isset($res['err_code']) && !empty($res['err_code'])){
                throw new \Exception("请求字节跳动API接口错误，错误码:{$res['err_msg']},错误信息:{$res['err_msg']}");
            }
            return $res['data']?? $res;
        } catch (GuzzleException $e) {
            \Log::error($e->getMessage());
            throw new \Exception($e->getMessage());
        }
    }

    protected function setAccessFileDir(): void
    {
        $this->accessTokenDir = storage_path('app/bytedance');
    }

    protected function setAccessFilePath(): void
    {
        $this->accessTokenFile = storage_path('app/bytedance/bytedance_access_token.json');
    }

    protected function setNoticeUrl(): void
    {
        $this->noticeUrl = env('APP_URL').'/api/pay/bytedance/notify';
    }
}