修改

task_script/LIVESTOCK_REPEAT_BRAZIL.php

@@ -3,16 +3,12 @@ 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("America/Bahia");
-// define('HOST', 'r-bp1eebab79320044pd.redis.rds.aliyuncs.com');
-// define('PORT', '6379');
-// define('PASSWORD', '7e2b5c91e438be3c!');
-// define('DATABASE', 4);
+
+date_default_timezone_set("America/Bahia");
 define('HOST', '127.0.0.1');
 define('PORT', '6379');
 define('PASSWORD', '123456');
-define('DATABASE', 2);
+define('DATABASE', 0);
 
 
 function rlog(...$args)
@@ -93,9 +89,9 @@ function rlog(...$args)
 
 function loop()
 {
-    $server   = '116.62.220.88';
+    $server   = '43.157.183.167';
     $port     = 1883;
-    $clientId = 'repeat_mqtt_livestock_develop_paigou';
+    $clientId = 'mqtt_bx_repart_livestock_cli';
     $username = 'rl517';
     $password = "rlian2022";
     $clean_session = false;
@@ -135,8 +131,35 @@ function loop()
         rlog("reportData", 'recv', $topic, $message);
         $topicArr=explode('/',$topic);
         $deviceId=$topicArr[1];
-
-        mqttRepeat($topic, $message);
+        $device_arr=[
+                '869761079960164-999274877903265',
+                '869761079959216-999274877904165',
+                '869761079718869-999274877904300',
+                '869761079720154-999274877903457',
+                '869761079714413-999274877902831',
+                '869761079979404-999274877904081',
+                '866216066888053-999274877905803',
+                '869761079982671-999274877904303',
+                '869761079957889-999274877904193',
+                '869761079711112-999274877904283',
+                '869761079959604-999274877904128',
+                '869761079694268-999274877903963',
+                '869761079959026-999274877904093',
+                '869761079962137-999274877903395',
+                '869761079721764-999274877904203',
+                '869761079979529-999274877904129',
+                '869761079695976-999274877904164',
+                '869761079709769-999274877902136',
+                '869761079984131-999274877903943',
+                '869761079695968-999274877903109',
+                '869761079960693-999274877903377',
+               
+        ];
+        if(in_array($deviceId,$device_arr)){
+           mqttRepeat($topic, $message);
+        }else{
+            rlog($deviceId.'not in array');
+        }
     }, 1);
     // $mqtt->subscribe('earings/+/cloudResp', function ($topic, $message) use($mqtt) {
     //     rlog("cloudResp", 'recv', $topic, $message);
@@ -189,15 +212,15 @@ function mqttRepeat($topic,$message){
     $mqtt2 = new MqttClient($server, $port, $clientId);
 
     $mqtt2->connect($connectionSettings, $clean_session);
-    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;
+    rlog('connect OK');
+    rlog('topic:'.$topic);
+    rlog('message:'.$message);
     $res=$mqtt2->publish(
         $topic,
         $message,
-        1
+        0
     );
-    echo '['.date('Y-m-d H:i:s').']publish end'.PHP_EOL;
+    rlog('publish end');
     $mqtt2->loop(true,true);
     $mqtt2->disconnect();
     return $res;