修改

task_script/LIVESTOCK_MQTT_PUBLISH.php

@@ -60,7 +60,25 @@ function app_redis()
 
 function sendConfig($topic,$config)
 {
-    $server   = '116.62.220.88';
+    
+}
+function updateSendResult($msgid){
+    $conn = new mysqli('rm-bp1h3uqkzy66ckt8yro.mysql.rds.aliyuncs.com', 'dev', '711e7D69f9d0c3f1', 'smart_livestock');
+    // $conn = new mysqli('127.0.0.1', 'root', 'root', 'smart_livestock');
+    if ($conn -> connect_errno) {
+        printf("Connect failed: %s\n", $conn->connect_error);
+        exit();
+    }
+    $sql = "UPDATE send_config_log SET result='1' WHERE id=".$msgid;
+    if ($conn->query($sql) === TRUE) {
+        echo "send_config_log update success";
+    } else {
+        echo "更新失败: " . $conn->error;
+    }
+
+}
+
+$server   = '116.62.220.88';
     $port     = 1883;
     $clientId = 'mqtt_livestock_config_cli';
     $username = 'rl517';
@@ -82,30 +100,9 @@ function sendConfig($topic,$config)
 
     $mqtt->connect($connectionSettings, $clean_session);
     echo 'connect OK'.PHP_EOL;
-    $res=$mqtt->publish(
-        $topic,
-        $config,
-        1
-    );
-    $mqtt->disconnect();
-    return $res;
-}
-function updateSendResult($msgid){
-    $conn = new mysqli('rm-bp1h3uqkzy66ckt8yro.mysql.rds.aliyuncs.com', 'dev', '711e7D69f9d0c3f1', 'smart_livestock');
-    // $conn = new mysqli('127.0.0.1', 'root', 'root', 'smart_livestock');
-    if ($conn -> connect_errno) {
-        printf("Connect failed: %s\n", $conn->connect_error);
-        exit();
-    }
-    $sql = "UPDATE send_config_log SET result='1' WHERE id=".$msgid;
-    if ($conn->query($sql) === TRUE) {
-        echo "send_config_log update success";
-    } else {
-        echo "更新失败: " . $conn->error;
-    }
-
-}
+  
 
+    return $res;
 $redis=app_redis();
 while (1) {
     $jsonData= $redis->rpop("device_mqtt_config_list");
@@ -130,7 +127,12 @@ while (1) {
    
     $config_json=json_encode($config);
     var_dump($config_json);
-    $res=sendConfig($topic,$config_json);
+    // $res=sendConfig($topic,$config_json);
+    $res=$mqtt->publish(
+        $topic,
+        $config_json,
+        1
+    );
     updateSendResult($data['msgid']);
     // if($res){
         // Db::table('send_config_log')->where('id',$data['msgid'])->update(['result'=>'1']);