kiri-wchat/common/Multiprogramming.php

<?php
/**
 * Created by PhpStorm.
 * User: whwyy
 * Date: 2018/3/26 0026
 * Time: 10:23
 */

namespace wchat\common;

use Kiri\Client;

abstract class Multiprogramming implements Progaram
{

    /** @var Config */
    protected Config $config;

    protected static ?Multiprogramming $instance = null;

    protected int    $errorCode = 0;
    protected string $errorMsg  = '';


    protected string $host = 'api.weixin.qq.com';


    /**
     * @var AppConfig
     */
    protected AppConfig $payConfig;


    /**
     * @param $message
     * @param int $code
     * @return Result
     */
    protected function sendError($message, int $code = 500): Result
    {
        return new Result(code: $code, message: $message);
    }

    /**
     * @param $code
     */
    public function setErrorCode($code)
    {
        $this->errorCode = $code;
    }

    /**
     * @param $message
     */
    public function setErrorMessage($message)
    {
        $this->errorMsg = $message;
    }

    /**
     * @return int
     */
    public function getErrorCode(): int
    {
        return $this->errorCode;
    }

    /**
     * @return string
     */
    public function getErrorMessage(): string
    {
        return $this->errorMsg;
    }


    /**
     * @param Config $config
     * @return void
     */
    public function setConfig(Config $config): void
    {
        $this->config = $config;
    }

    /**
     * @return AppConfig
     */
    public function getPayConfig(): AppConfig
    {
        return $this->payConfig;
    }

    /**
     * @param AppConfig $payConfig
     */
    public function setPayConfig(AppConfig $payConfig): void
    {
        $this->payConfig = $payConfig;
    }


    /**
     * @return Config
     */
    public function getConfig(): Config
    {
        return $this->config;
    }

    /**
     * @param $result
     * @return array|bool
     * @throws \Exception
     */
    protected function checkSign($result): array|bool
    {
        $data = Help::toArray($result);

        if (!isset($data['sign'])) {
            return $data;
        }

        $sign = $data['sign'];

        unset($data['sign']);

        $key       = $this->config->getKey();
        $sign_type = $this->config->getSignType();

        $_sign = Help::sign($data, $key, $sign_type);
        if ($sign != $_sign) {
            return FALSE;
        }
        return $data;
    }


    /**
     * @param string $requestUrl
     * @param mixed $body
     * @param string $contentType
     * @return Result
     */
    protected function post(string $requestUrl, mixed $body, string $contentType = 'application/application'): Result
    {
        return $this->request('post', $requestUrl, $body, $contentType);
    }


    /**
     * @param string $requestUrl
     * @param mixed $body
     * @return Result
     */
    protected function get(string $requestUrl, mixed $body, string $contentType = 'application/application'): Result
    {
        return $this->request('get', $requestUrl, $body, $contentType);
    }


    /**
     * @param string $requestUrl
     * @param mixed $body
     * @return Result
     */
    protected function upload(string $requestUrl, mixed $body): Result
    {
        return $this->request('upload', $requestUrl, $body);
    }


    /**
     * @param string $method
     * @param string $requestUrl
     * @param $body
     * @param string $contentType
     * @return Result
     */
    private function request(string $method, string $requestUrl, $body, string $contentType = 'application/application'): Result
    {
        $client = new Client($this->host, 443, true);
        $proxyHost = $this->getConfig()->getProxyHost();
        $proxyPort = $this->getConfig()->getProxyPort();
        if (!empty($proxyHost) && $proxyPort > 0) {
            $client->withProxyHost($proxyHost)->withProxyPort($proxyPort);
        }
        if ($method == 'post') {
            $client->withHeader(['Content-Type' => $contentType]);
            $client->post($requestUrl, $body);
        } else if ($method == 'upload') {
            $client->upload($requestUrl, $body);
        } else {
            $client->withHeader(['Content-Type' => $contentType]);
            $client->get($requestUrl, $body);
        }
        $client->close();
        if (!in_array($client->getStatusCode(), [101, 200, 201])) {
            return new Result(code: 505, message: $client->getBody());
        }
        $body = json_decode($client->getBody(), true);
        if (!is_null($body)) {
            return new Result(code: $body['errcode'], message: $body['errmsg']);
        } else {
            return new Result(code: 0, data: $client->getBody());
        }
    }

}