156 lines
4.7 KiB
Python
156 lines
4.7 KiB
Python
#!/usr/bin/env python3
|
||
# -*- encoding: utf-8 -*-
|
||
# enconding = utf8
|
||
import sys
|
||
import time
|
||
import grpc
|
||
|
||
from explore import Explore
|
||
|
||
sys.path.append('./')
|
||
sys.path.append('../')
|
||
|
||
import matplotlib.pyplot as plt
|
||
import numpy as np
|
||
from mpl_toolkits.axes_grid1 import make_axes_locatable
|
||
|
||
from robowaiter.proto import GrabSim_pb2
|
||
from robowaiter.proto import GrabSim_pb2_grpc
|
||
|
||
channel = grpc.insecure_channel('localhost:30001', options=[
|
||
('grpc.max_send_message_length', 1024 * 1024 * 1024),
|
||
('grpc.max_receive_message_length', 1024 * 1024 * 1024)
|
||
])
|
||
|
||
sim_client = GrabSim_pb2_grpc.GrabSimStub(channel)
|
||
|
||
'''
|
||
初始化，卸载已经加载的关卡，清除所有机器人
|
||
'''
|
||
|
||
|
||
def Init():
|
||
sim_client.Init(GrabSim_pb2.NUL())
|
||
|
||
|
||
'''
|
||
获取当前可加载的地图信息(地图名字、地图尺寸)
|
||
'''
|
||
|
||
|
||
def AcquireAvailableMaps():
|
||
AvailableMaps = sim_client.AcquireAvailableMaps(GrabSim_pb2.NUL())
|
||
print(AvailableMaps)
|
||
|
||
|
||
'''
|
||
1、根据mapID加载指定地图
|
||
2、如果scene_num>1,则根据地图尺寸偏移后加载多个相同地图
|
||
3、这样就可以在一个关卡中训练多个地图
|
||
'''
|
||
|
||
|
||
def SetWorld(map_id=0, scene_num=1):
|
||
print('------------------SetWorld----------------------')
|
||
world = sim_client.SetWorld(GrabSim_pb2.BatchMap(count=scene_num, mapID=map_id))
|
||
|
||
|
||
'''
|
||
返回场景的状态信息
|
||
1、返回机器人的位置和旋转
|
||
2、返回各个关节的名字和旋转
|
||
3、返回场景中标记的物品信息(名字、类型、位置、旋转)
|
||
4、返回场景中行人的信息(名字、位置、旋转、速度)
|
||
5、返回机器人手指和双臂的碰撞信息
|
||
'''
|
||
|
||
|
||
def Observe(scene_id=0):
|
||
print('------------------show_env_info----------------------')
|
||
scene = sim_client.Observe(GrabSim_pb2.SceneID(value=scene_id))
|
||
print(
|
||
f"location:{[scene.location]}, rotation:{scene.rotation}\n",
|
||
f"joints number:{len(scene.joints)}, fingers number:{len(scene.fingers)}\n",
|
||
f"objects number: {len(scene.objects)}, walkers number: {len(scene.walkers)}\n"
|
||
f"timestep:{scene.timestep}, timestamp:{scene.timestamp}\n"
|
||
f"collision:{scene.collision}, info:{scene.info}")
|
||
|
||
|
||
'''
|
||
重置场景
|
||
1、重置桌子的宽度和高度
|
||
2、清除生成的行人和物品
|
||
3、重置关节角度、位置旋转
|
||
4、清除碰撞信息
|
||
5、重置场景中标记的物品
|
||
'''
|
||
|
||
|
||
def Reset(scene_id=0):
|
||
print('------------------Reset----------------------')
|
||
scene = sim_client.Reset(GrabSim_pb2.ResetParams(scene=scene_id))
|
||
print(scene)
|
||
|
||
# 如果场景支持调整桌子
|
||
# sim_client.Reset(GrabSim_pb2.ResetParams(scene = scene_id, adjust = True, height = 100.0, width = 100.0))"
|
||
|
||
|
||
"""
|
||
导航移动
|
||
yaw:机器人朝向;
|
||
velocity:速度,>0代表移动,<0代表瞬移,=0代表只查询;
|
||
dis:最终达到的位置距离目标点最远距离,如果超过此距离则目标位置不可达
|
||
"""
|
||
|
||
|
||
def navigation_move(v_list, scene_id=0, map_id=11):
|
||
print('------------------navigation_move----------------------')
|
||
scene = sim_client.Observe(GrabSim_pb2.SceneID(value=scene_id))
|
||
walk_value = [scene.location.X, scene.location.Y, scene.rotation.Yaw]
|
||
print("position:", walk_value)
|
||
|
||
# if map_id == 11: # coffee
|
||
# v_list = [[0, 880], [250, 1200], [-55, 750], [70, -200]]
|
||
# else:
|
||
# v_list = [[0.0, 0.0]]
|
||
|
||
for walk_v in v_list:
|
||
walk_v = walk_v + [scene.rotation.Yaw - 90, 60, 0]
|
||
print("walk_v", walk_v)
|
||
action = GrabSim_pb2.Action(scene=scene_id, action=GrabSim_pb2.Action.ActionType.WalkTo, values=walk_v)
|
||
scene = sim_client.Do(action)
|
||
print(scene.info)
|
||
|
||
|
||
if __name__ == '__main__':
|
||
map_id = 11 # 地图编号
|
||
scene_num = 1 # 场景数量
|
||
node_list = [] # 探索点
|
||
explorer = Explore(_explore_range=100)
|
||
|
||
print('------------ 初始化加载场景 ------------')
|
||
Init()
|
||
AcquireAvailableMaps()
|
||
SetWorld(map_id, scene_num)
|
||
time.sleep(5.0)
|
||
|
||
for i in range(scene_num):
|
||
print('------------ 场景操作 ------------')
|
||
Observe(i)
|
||
Reset(i)
|
||
|
||
print('------------ 自主探索 ------------')
|
||
while True:
|
||
|
||
# scene = sim_client.Observe(GrabSim_pb2.SceneID(value=0))
|
||
# cur_pos =[int(scene.location.X), int(scene.location.Y), int(scene.rotation.Yaw)]
|
||
|
||
goal = explorer.explore(cur_pos) # cur_pos 指的是当前机器人的位置，场景中应该也有接口可以获取
|
||
if goal is None:
|
||
break
|
||
node_list.append(goal)
|
||
cur_pos = goal
|
||
navigation_move(i, map_id, node_list)
|
||
|
||
# TODO：node_list就是机器人拍照的点，目前没有设置拍照角度，需要机器人到达一个拍照点后，前后左右各拍一张照片然后获取语义信息
|