station-test-api/task_script/OSD_DRONE_CLIENT.php

<?php
require('../vendor/autoload.php');
use \PhpMqtt\Client\MqttClient;
use \PhpMqtt\Client\ConnectionSettings;
use think\facade\Cache;
use think\facade\Db;
date_default_timezone_set("PRC");
// define('HOST', '127.0.0.1');
// define('PORT', '6379');
// define('PASSWORD', '123456');
// define('DATABASE', 2);
define('HOST', '172.16.222.97');
define('PORT', '6379');
define('PASSWORD', 'jrtk.net');
define('DATABASE', 4);
(new think\App())->initialize();

function app_redis()
{
    static $redis = null;
    static $conn = false;
    if (!$conn) {
        connect: //定义标签
        $redis = new Redis();
        try {
            //建立的Redis短连接,在请求结束后不会自动关闭,相当于持久连接.
            $conn = $redis->connect(HOST, PORT);
            $conn = $redis->auth(PASSWORD);
            $conn = $redis->select(DATABASE);
            // 连接成功,返回$redis对象,连接失败,返回false.
            return ($conn === true) ? $redis : false;
        } catch (Exception $e) {
            return false;
        }
    } else {
        // 这里假设PHP-FPM在处理一个请求的时间内,Redis连接都是可用的.
        // 所以只在PHP-CLI下检查Redis连接的状态,进行断线重连.
        if (php_sapi_name() === 'cli') {
            try {
                // ping用于检查当前连接的状态,成功时返回+PONG,失败时抛出一个RedisException对象.
                // ping失败时警告:
                // Warning: Redis::ping(): connect() failed: Connection refused
                // var_dump('AAAAAAAAA', $redis);
                // echo 'Redis 连接状态' . $redis->ping() . PHP_EOL;
                @$redis->ping();
                if (!$redis->ping()) {
                    goto connect; //跳转到标签出继续执行连接操作
                }
            } catch (Exception  $e) {
                // 信息如 Connection lost 或 Redis server went away
                echo $e->getMessage();
                echo 'Redis 连接失败 重新连接：' . PHP_EOL;
                // 断线重连
                goto connect;
            }
        }
        return $redis;
    }
}

while (1) {
    $jsonData= app_redis()->rpop("OSD_DRONE_LIST");
    if(!$jsonData){
        sleep(3);
        continue;
    }
    $redis_data=json_decode($jsonData,true);

    $device_sn=$redis_data['from'];
    $gateway=$redis_data['gateway'];
    $data=$redis_data['val'];

    if(!isset($data['longitude']) || !isset($data['latitude']) || !isset($data['height'])){
        continue;
    }
    $save_data=[
        'longitude'=>$data['longitude'],
        'latitude'=>$data['latitude'],
        'height'=>$data['height'],
        // 'time'=>$data['timestamp'],
        'time'=>time(),
        'gateway'=>$gateway,
        'device_sn'=>$device_sn ,
    ];
    var_dump($save_data);
    try {
        $res = Db::connect('uav')->name('uav_route')->insertGetId($save_data);
        var_dump($res);
    } catch (\Exception $e) {
        // 错误日志或重新连接逻辑
        echo "错误: " . $e->getMessage().PHP_EOL;   
        // 重新连接逻辑（示例）:
         Db::connect('uav')->close(); // 关闭现有连接
        Db::connect('uav')->connect(); // 重新连接
        $res = Db::connect('uav')->name('uav_route')->insertGetId($save_data);
        var_dump($res);
    }
}