diff --git a/app/common.php b/app/common.php
index c4a426e..1534f9e 100644
--- a/app/common.php
+++ b/app/common.php
@@ -550,3 +550,62 @@ function doCurl(string $url, array $params = [])
         throw new \Exception(lang('system_busy'));
     }
 }
+
+/**
+ * 使用 multipart/form-data 请求第三方 API。
+ * 普通值作为文本字段发送，资源或 StreamInterface 可直接作为文件字段发送。
+ * 不要手动设置 Content-Type，Guzzle 会自动生成带 boundary 的请求头。
+ *
+ * @param string $url
+ * @param array $params
+ * @param array $headers
+ * @param array $options Guzzle 请求选项，例如 timeout、verify、proxy 等
+ * @return mixed JSON 响应返回数组，非 JSON 响应返回原始字符串
+ * @throws \Exception
+ */
+function third_party_form_request(
+    string $url,
+    array $params = [],
+    array $headers = [],
+    array $options = []
+): mixed {
+    $multipart = [];
+    foreach ($params as $name => $value) {
+        $isList = is_array($value) && (
+            function_exists('array_is_list')
+                ? array_is_list($value)
+                : $value === [] || array_keys($value) === range(0, count($value) - 1)
+        );
+        $values = $isList ? $value : [$value];
+        foreach ($values as $item) {
+            $multipart[] = [
+                'name'     => (string) $name,
+                'contents' => is_null($item) ? '' : $item,
+            ];
+        }
+    }
+
+    $requestOptions = array_merge([
+        'timeout'         => 7,
+        'connect_timeout' => 7,
+        'verify'          => true,
+        'http_errors'     => false,
+    ], $options);
+    $requestOptions['multipart'] = $multipart;
+    $requestOptions['headers'] = array_merge(['Accept' => 'application/json'], $headers);
+
+    try {
+        $response = (new Client())->request('POST', $url, $requestOptions);
+        $statusCode = $response->getStatusCode();
+        $contents = $response->getBody()->getContents();
+
+        if ($statusCode < 200 || $statusCode >= 300) {
+            throw new \Exception(lang('system_busy'));
+        }
+
+        $data = json_decode($contents, true);
+        return json_last_error() === JSON_ERROR_NONE ? $data : $contents;
+    } catch (GuzzleException $e) {
+        throw new \Exception(lang('system_busy'), 0, $e);
+    }
+}
diff --git a/app/common/service/JK8Services.php b/app/common/service/JK8Services.php
index 75f6514..234a2b6 100644
--- a/app/common/service/JK8Services.php
+++ b/app/common/service/JK8Services.php
@@ -51,7 +51,7 @@ class JK8Services
             // 'name'     => $nickname,
             'referrerCode'     => $referrerCode,
         ]);
-        $result = doCurl($this->domain, $params);
+        $result = third_party_form_request($this->domain, $params);
         if (($result['status'] ?? '') === 'ERROR') {
             throw new Exception($result['data']['message'] ?? 'Remote API Error');
         }
@@ -69,7 +69,7 @@ class JK8Services
         $params = $this->createParam('/users/getAllUsers', [
             'id' => $userId,
         ]);
-        $result = doCurl($this->domain, $params);
+        $result = third_party_form_request($this->domain, $params);
         if (($result['status'] ?? '') === 'ERROR') {
             throw new Exception($result['data']['message'] ?? 'Remote API Error');
         }
@@ -86,7 +86,7 @@ class JK8Services
         $params = $this->createParam('/users/getPromotionList', [
             'userId' => $userId,
         ]);
-        $result = doCurl($this->domain, $params);
+        $result = third_party_form_request($this->domain, $params);
         if (($result['status'] ?? '') === 'ERROR') {
             throw new Exception($result['data']['message'] ?? 'Remote API Error');
         }
@@ -106,7 +106,28 @@ class JK8Services
             'username' => $username,
             'amount' => $amount
         ]);
-        $result = doCurl($this->domain, $params);
+        $result = third_party_form_request($this->domain, $params);
+        if (($result['status'] ?? '') === 'ERROR') {
+            throw new Exception($result['data']['message'] ?? 'Remote API Error');
+        }
+        return $result['data']['transactionId'];
+    }
+
+    /**
+     * 手动发红包
+     * @param string $username
+     * @param float $amount
+     * @return array|mixed|null
+     * @throws Exception
+     */
+    public function manualAngPao(string $username, float $amount): mixed
+    {
+        $params = $this->createParam('/users/manualAngPao', [
+            'userId' => $username,
+            'amount' => $amount,
+            'promotionId' => 254385
+        ]);
+        $result = third_party_form_request($this->domain, $params);
         if (($result['status'] ?? '') === 'ERROR') {
             throw new Exception($result['data']['message'] ?? 'Remote API Error');
         }
@@ -121,7 +142,7 @@ class JK8Services
     public function getGameCategory(): mixed
     {
         $params = $this->createParam('/games/getGameCategory', []);
-        $result = doCurl($this->domain, $params);
+        $result = third_party_form_request($this->domain, $params);
         if (($result['status'] ?? '') === 'ERROR') {
             throw new Exception($result['data']['message'] ?? 'Remote API Error');
         }
@@ -161,7 +182,7 @@ class JK8Services
         foreach ($sites as $site) {
             $post['site'] = $site;
             $params = $this->createParam('/games/getGameList', $post);
-            $result = doCurl($this->domain, $params);
+            $result = third_party_form_request($this->domain, $params);
             if (($result['status'] ?? '') === 'ERROR') {
                 throw new Exception($result['data']['message'] ?? 'Remote API Error');
             }