使用workman

2025-05-13 15:49:27 +08:00
parent c1547e191c
commit 2ff864b8c8
9 changed files with 446 additions and 13 deletions
--- a/src/AuthorServerClient.php
+++ b/src/AuthorServerClient.php
@@ -0,0 +1,178 @@
+<?php
+
+namespace cn\com\maiyoule\mqttclient;
+
+use cn\com\maiyoule\mqttclient\exception\ApiException;
+use cn\com\maiyoule\mqttclient\response\BizResponse;
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\ClientException;
+use phpseclib3\Crypt\RSA;
+
+/**
+ * MQTT服务端接口
+ */
+class AuthorServerClient
+{
+    /**
+     * 私钥
+     * @var string
+     */
+    protected string $privateKey = '';
+    /**
+     * 签名类型
+     * @var string
+     */
+    protected string $type = 'rsa';
+    /**
+     * 应用ID
+     * @var string
+     */
+    protected string $appId = '';
+
+    /**
+     * 接口地址
+     * @var string
+     */
+    protected string $api = 'https://mqttauthor.maiyoule.com.cn';
+    /**
+     * 版本号
+     */
+    public const VERSION = "1.0";
+    /**
+     * 是否为调试模式
+     * @var bool
+     */
+    protected bool $debug = false;
+
+    public function getPrivateKey(): string
+    {
+        return $this->privateKey;
+    }
+
+    public function setPrivateKey(string $privateKey): void
+    {
+        $this->privateKey = $privateKey;
+    }
+
+    public function getType(): string
+    {
+        return $this->type;
+    }
+
+    public function setType(string $type): void
+    {
+        $this->type = $type;
+    }
+
+    public function getAppId(): string
+    {
+        return $this->appId;
+    }
+
+    public function setAppId(string $appId): void
+    {
+        $this->appId = $appId;
+    }
+
+    public function getApi(): string
+    {
+        return $this->api;
+    }
+
+    public function setApi(string $api): void
+    {
+        $this->api = $api;
+    }
+
+    public function isDebug(): bool
+    {
+        return $this->debug;
+    }
+
+    public function setDebug(bool $debug): void
+    {
+        $this->debug = $debug;
+    }
+
+    private ?Client $client = null;
+
+    private function getHttpClient(): Client
+    {
+        if ($this->client == null) {
+            $this->client = new Client([
+                'base_uri' => $this->api,
+                'allow_redirects' => [
+                    'max' => 2
+                ],
+                'debug' => $this->debug,
+                'headers' => [
+                    'user-agent' => 'MaiYouLeMQTTClientAuthor/' . self::VERSION,
+                    'Accept' => 'application/json'
+                ]
+            ]);
+        }
+        return $this->client;
+    }
+
+
+    private function sign(string $str)
+    {
+        $prikey = RSA::loadPrivateKey($this->privateKey);
+        $result = $prikey->sign($str);
+        return base64_encode($result);
+    }
+
+    /**
+     * @param IRequest $request
+     * @return BizResponse
+     * @throws ApiException
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function exec(IRequest $request): BizResponse
+    {
+        //生成签名
+        $url = sprintf('%s%s', $this->api, $request->path());
+        $urls = parse_url($url);
+
+        $path = $urls['path'];
+        $body = $request->body();
+
+        $body['appid'] = $this->getAppId();
+        $body['type'] = $this->getType();
+
+        ksort($body, SORT_NATURAL);
+
+        $waitItem = [];
+        foreach ($body as $key => $value) {
+            $waitItem[] = $key . '=' . urlencode($value);
+        }
+        $waitItem[] = urlencode($path);
+        $str = join('&', $waitItem);
+        $sign = $this->sign($str);
+        $body['sign'] = $sign;
+        $http = $this->getHttpClient();
+
+        try {
+            $result = $http->request('POST', $path, [
+                'form_params' => $body
+            ]);
+            $content = $result->getBody()->getContents();
+            if (empty($content)) {
+                //没有反馈内容
+                return new BizResponse();
+            }
+            $data = json_decode($content, true);
+            return new BizResponse($data['code'] ?? 0, $data['message'] ?? '', $data['data'] ?? []);
+
+        } catch (ClientException $e) {
+            $body = $e->getResponse()->getBody()->getContents();
+            $message = '';
+            if (!empty($body)) {
+                $data = json_decode($body, true);
+                $message = $data['message'] ?? '';
+            }
+            throw new ApiException($message, $e->getResponse()->getStatusCode());
+        }
+
+    }
+}