|
@@ -89,7 +89,7 @@ async def roughTimeStatus(
|
|
"nest_url": n['nestOutMediaPullStreamAddress'] if n['nestOutMediaPullStreamAddress'] is not None else "", # 机巢视频流
|
|
"nest_url": n['nestOutMediaPullStreamAddress'] if n['nestOutMediaPullStreamAddress'] is not None else "", # 机巢视频流
|
|
|
|
|
|
"addressLongitude": n['addressLongitude'],
|
|
"addressLongitude": n['addressLongitude'],
|
|
- "addressLatitude": n ['addressLatitude'],
|
|
|
|
|
|
+ "addressLatitude": n['addressLatitude'],
|
|
}
|
|
}
|
|
|
|
|
|
# 测试数据
|
|
# 测试数据
|
|
@@ -117,7 +117,20 @@ async def roughTimeStatus(
|
|
item['fly_info'] = fly_info
|
|
item['fly_info'] = fly_info
|
|
wrj_list.append(item)
|
|
wrj_list.append(item)
|
|
|
|
|
|
-
|
|
|
|
|
|
+ '''
|
|
|
|
+ sql = "insert into tp_wrj_info (id, name, area, longitude, latitude, address, type) value (:id, :name, :area, :longitude, :latitude, :address, :type)"
|
|
|
|
+ db.execute(text(sql), {
|
|
|
|
+ "id": n['id'],
|
|
|
|
+ "name": n['uavName'],
|
|
|
|
+ "area": n['addressAreaId'],
|
|
|
|
+ "longitude": n['addressLongitude'],
|
|
|
|
+ "latitude": n['addressLatitude'],
|
|
|
|
+ "address": n["residentAddress"],
|
|
|
|
+ "type": n['status_text']
|
|
|
|
+ })
|
|
|
|
+ db.commit()
|
|
|
|
+ '''
|
|
|
|
+
|
|
return {
|
|
return {
|
|
"code": 200,
|
|
"code": 200,
|
|
"msg": "操作成功",
|
|
"msg": "操作成功",
|