From 35a4ede2b56b63628f170d1e2b6e543929b787e9 Mon Sep 17 00:00:00 2001
From: tk <szdot@live.com>
Date: Wed, 5 Jun 2024 19:59:17 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90=E7=B1=BB=09=E5=9E=8B=E3=80=91?=
 =?UTF-8?q?=EF=BC=9Atest=20=E3=80=90=E4=B8=BB=09=E9=A2=98=E3=80=91?=
 =?UTF-8?q?=EF=BC=9A=E6=94=AF=E4=BB=98=E5=9B=9E=E8=B0=83=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=20=E3=80=90=E6=8F=8F=09=E8=BF=B0=E3=80=91=EF=BC=9A=20=09[?=
 =?UTF-8?q?=E5=8E=9F=E5=9B=A0]=EF=BC=9A=20=09[=E8=BF=87=E7=A8=8B]=EF=BC=9A?=
 =?UTF-8?q?=20=09[=E5=BD=B1=E5=93=8D]=EF=BC=9A=20=E3=80=90=E7=BB=93=09?=
 =?UTF-8?q?=E6=9D=9F=E3=80=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

# 类型 包含:
# feat：新功能（feature）
# fix：修补bug
# docs：文档（documentation）
# style： 格式（不影响代码运行的变动）
# refactor：重构（即不是新增功能，也不是修改bug的代码变动）
# test：增加测试
# chore：构建过程或辅助工具的变动
---
 .../Api/Controller/PayController.class.php    | 44 ++++++++++++++++---
 1 file changed, 38 insertions(+), 6 deletions(-)

diff --git a/FlyCube/Api/Controller/PayController.class.php b/FlyCube/Api/Controller/PayController.class.php
index 9e0bb4a..fafc12a 100644
--- a/FlyCube/Api/Controller/PayController.class.php
+++ b/FlyCube/Api/Controller/PayController.class.php
@@ -3,6 +3,10 @@
 namespace Api\Controller;
 
 use Yansongda\Pay\Pay;
+use PhpMqtt\Client\MqttClient;
+use PhpMqtt\Client\Exceptions\MqttClientException;
+use PhpMqtt\Client\ConnectionSettings;
+use PhpMqtt\Client\Message;
 
 class PayController extends PublicController
 {
@@ -58,7 +62,7 @@ class PayController extends PublicController
         //设置获取签名的订单参数
         $orderParameter = [
             'out_trade_no' => $order['order_sn'],
-            'description' => $order['shop_id'],
+            'description' => $order['shop_id'], //商品名称
             'amount' => [
                 'total' => $order['total_price'] * 100, //单位:分
                 'currency' => 'CNY',
@@ -78,14 +82,42 @@ class PayController extends PublicController
 
     public function notifyCallback()
     {
-        $pay = Pay::wechat($this->config);
+        $server   = 'www.szdot.top';         // MQTT 代理地址
+        $port     = 1883;                    // MQTT 代理端口
+        $clientId = 'php-mqtt-client';       // 客户端 ID
+        $username = 'admin';                 // 用户名（如果需要）
+        $password = '123456';                // 密码（如果需要）
 
         try {
-            $data = $pay->callback(); // 是的，验签就这么简单！
-        } catch (\Exception $e) {
-            // $e->getMessage();
+            // 创建连接设置对象
+            $settings = (new ConnectionSettings)->setUsername($username)->setPassword($password);
+            // 实例化 MQTT 客户端
+            $mqtt = new MqttClient($server, $port, $clientId);
+            // 连接到 MQTT 代理
+            $mqtt->connect($settings);
+            // 检查是否连接成功
+            if ($mqtt->isConnected()) {
+                echo "连接成功";
+                // 发布消息到指定的主题 ps:主题  信息  qos
+                $mqtt->publish('demo', 'Hello MQTT', 0);
+                // 断开连接
+                $mqtt->disconnect();
+                echo "断开连接";
+            } else {
+                echo "连接失败";
+            }
+        } catch (MqttClientException $e) { //连接失败
+            echo "Could not connect to MQTT broker: " . $e->getMessage();
         }
+        // $pay = Pay::wechat($this->config);
+
+        // try {
+        //     $data = $pay->callback(); // 是的，验签就这么简单！
+        // } catch (\Exception $e) {
+        //     // $e->getMessage();
+        // }
+
+        // return $pay->success();
 
-        return $pay->success();
     }
 }