|
@@ -66,8 +66,6 @@ while (1) {
|
|
|
}
|
|
|
$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'])){
|
|
@@ -77,10 +75,9 @@ while (1) {
|
|
|
'longitude'=>$data['longitude'],
|
|
|
'latitude'=>$data['latitude'],
|
|
|
'height'=>$data['height'],
|
|
|
- // 'time'=>$data['timestamp'],
|
|
|
- 'time'=>time(),
|
|
|
- 'gateway'=>$gateway,
|
|
|
- 'device_sn'=>$device_sn ,
|
|
|
+ 'time'=>$redis_data['ts']?:time(),
|
|
|
+ 'gateway'=>$redis_data['gateway'],
|
|
|
+ 'device_sn'=>$redis_data['from'] ,
|
|
|
];
|
|
|
var_dump($save_data);
|
|
|
try {
|
|
@@ -90,7 +87,7 @@ while (1) {
|
|
|
// 错误日志或重新连接逻辑
|
|
|
echo "错误: " . $e->getMessage().PHP_EOL;
|
|
|
// 重新连接逻辑(示例):
|
|
|
- Db::connect('uav')->close(); // 关闭现有连接
|
|
|
+ Db::connect('uav')->close(); // 关闭现有连接
|
|
|
Db::connect('uav')->connect(); // 重新连接
|
|
|
$res = Db::connect('uav')->name('uav_route')->insertGetId($save_data);
|
|
|
var_dump($res);
|