修改

task_script/LIVESTOCK_MQTT_CLIENT.php

@@ -206,19 +206,20 @@ function decodeUnicode($str)
 }
 function loop()
 {
-    $server   = '43.157.183.167';
+    // $server   = '43.157.183.167';
+    // $port     = 1883;
+    // $clientId = 'local1_mqtt_livestock_cli_202406271';
+    // $username = 'rl517';
+    // $password = "rlian2022";
+
+    $server   = '116.62.220.88';
     $port     = 1883;
-    $clientId = 'local_mqtt_livestock_cli';
+    $clientId = 'local_mqtt_livestock_cli_202409271';
     $username = 'rl517';
     $password = "rlian2022";
-    $clean_session = false;
 
-    // $server   = '61.175.203.188';
-    // $port     = 10002;
-    // $clientId = 'local_mqtt_livestock_cli';
-    // $username = 'rltest';
-    // $password = "rlian@24329";
     $clean_session = false;
+
     $connectionSettings  = new ConnectionSettings();
     $connectionSettings = $connectionSettings
         ->setUsername($username)

task_script/LIVESTOCK_MQTT_PUBLISH.php

@@ -138,11 +138,12 @@ while (1) {
     }
    
     $config_json=json_encode($config);
-    // var_dump($config_json);
-    $res=sendConfig($topic,$config_json);
     if(isset($data['msgid'])){
         updateSendResult($data['msgid']);
     }
+    // var_dump($config_json);
+    $res=sendConfig($topic,$config_json);
+    
     
     // if($res){
         // Db::table('send_config_log')->where('id',$data['msgid'])->update(['result'=>'1']);

task_script/LIVESTOCK_MQTT_REPEAT.php

@@ -3,7 +3,7 @@ require('../vendor/autoload.php');
 use \PhpMqtt\Client\MqttClient;
 use \PhpMqtt\Client\ConnectionSettings;
 use think\facade\Cache;
-// date_default_timezone_set("PRC");
+date_default_timezone_set("PRC");
 // date_default_timezone_set("America/Bahia");
 // define('HOST', 'r-bp1eebab79320044pd.redis.rds.aliyuncs.com');
 // define('PORT', '6379');
@@ -95,7 +95,7 @@ function loop()
 {
     $server   = '116.62.220.88';
     $port     = 1883;
-    $clientId = 'repeat_mqtt_livestock_develop';
+    $clientId = 'repeat_mqtt_livestock_develop_paigou';
     $username = 'rl517';
     $password = "rlian2022";
     $clean_session = false;
@@ -169,7 +169,7 @@ function mqttRepeat($topic,$message){
 
     $server   = '61.175.203.188';
     $port     = 10002;
-    $clientId = 'repeat_mqtt_livestock_ningbo';
+    $clientId = 'repeat_mqtt_livestock_ningbo_paigou';
     $username = 'rltest';
     $password = "rlian@24329";
     $clean_session = false;
@@ -188,15 +188,15 @@ function mqttRepeat($topic,$message){
     $mqtt2 = new MqttClient($server, $port, $clientId);
 
     $mqtt2->connect($connectionSettings, $clean_session);
-    echo 'connect OK'.PHP_EOL;
-    echo 'topic:'.$topic.PHP_EOL;
-    echo 'message:'.$message.PHP_EOL;
+    echo '['.date('Y-m-d H:i:s').']connect OK'.PHP_EOL;
+    echo '['.date('Y-m-d H:i:s').']topic:'.$topic.PHP_EOL;
+    echo '['.date('Y-m-d H:i:s').']message:'.$message.PHP_EOL;
     $res=$mqtt2->publish(
         $topic,
         $message,
         1
     );
-    echo 'publish end'.PHP_EOL;
+    echo '['.date('Y-m-d H:i:s').']publish end'.PHP_EOL;
     $mqtt2->loop(true,true);
     $mqtt2->disconnect();
     return $res;

task_script/RLSTA_DOOR_MQTT_CLI.php

@@ -209,7 +209,7 @@ function loop()
 
     $server   = '61.175.203.188';
     $port     = 10002;
-    $clientId = 'local_mqtt_rlsta_door';
+    $clientId = 'local_mqtt_rlsta_door_13145';
     $username = 'rl0606';
     $password = "rlian2023";
 

task_script/RLSTA_DOOR_MQTT_PUBLISH.php

@@ -62,7 +62,7 @@ function sendConfig($topic,$config)
 {
     $server   = '61.175.203.188';
     $port     = 10002;
-    $clientId = 'mqtt_rlsta_door_config';
+    $clientId = 'mqtt_rlsta_door_config_3213';
     $username = 'rl0606';
     $password = "rlian2023";
     $clean_session = false;
@@ -129,13 +129,17 @@ while (1) {
     //     "time": 1724145895
     // }
     $config=$data['config'];
+    var_dump($config);
     
-   
+    foreach($config['bkList']['list'] as &$val){
+        $val = str_pad($val, 8, "0", STR_PAD_LEFT);
+    }
     $config_json=json_encode($config);
+    
     // if(isset($data['msgid'])){
     //     updateSendResult($data['msgid']);
     // }
-    // var_dump($config_json);
+    var_dump($config_json);
     sendConfig($topic,$config_json);
  
 }