$search

human_sensing_states.py

Go to the documentation of this file.

import roslib
roslib.load_manifest('srs_states')
import rospy
import smach
import smach_ros

from math import *
import copy
from struct import *
import tf

from simple_script_server import *
sss = simple_script_server()


#from srs_grasping.srv import *
from geometry_msgs.msg import *
from cob_people_detection.srv import *
from cob_people_detection_msgs.msg import *
from srs_human_sensing.srv import *
from srs_human_sensing.msg import *

from srs_leg_detector.srv import *
from srs_body_detector.srv import *


from simple_script_server import *
sss = simple_script_server()

class leg_detection(smach.State):
    def __init__(self,object_name = ""):
        smach.State.__init__(
            self,
            outcomes=['succeeded','failed','preempted','retry'],
            input_keys=['sm_input'],
            output_keys=['pose_list','id','humans_pose','person_label'])
        
        self.srv_name_leg_detection = '/detect_legs'
        self.pose_list=[]

    def execute(self, userdata):
        rospy.loginfo("Leg detection ready.")

        if(userdata.sm_input.label==""):
                    rospy.loginfo("Searching for all peoples.")
        else:
                    rospy.loginfo("Searching for special person.")

        if self.preempt_requested():
           self.service_preempt()
           return 'preempted'
       
       
        try:
            rospy.wait_for_service(self.srv_name_leg_detection,10)
        except rospy.ROSException, e:
            print "Service not available: %s"%e
            return 'failed'

        # call leg detection service
        try:
            detector_service = rospy.ServiceProxy(self.srv_name_leg_detection, DetectLegs)
            req = DetectLegsRequest()
            res = detector_service(req)
            lenp=len(res.leg_list.points)
            if lenp > 3:
                lenp=3
            if lenp==0:
                return 'retry'   
            for i in range(0, lenp):    
                            
                 p=Pose2D()
                 p.x=res.leg_list.points[i].x
                 p.y=res.leg_list.points[i].y
                 p.theta=0
                 self.pose_list.append(p)
                 
            for i in range (0,len(userdata.sm_input.pose_furniture)):
                 p=Pose2D()
                 p.x=userdata.sm_input.pose_furniture[i].x
                 p.y=userdata.sm_input.pose_furniture[i].y
                 p.theta=userdata.sm_input.pose_furniture[i].theta
                 self.pose_list.append(p)

                 
            #print self.pose_list     
            if len(self.pose_list)==0:
                return 'failed'   
              
            userdata.pose_list=self.pose_list
            print len(self.pose_list)
            userdata.id=0
            userdata.humans_pose=detect_human_array()
            userdata.person_label=userdata.sm_input.label
            return 'succeeded'
        
        except rospy.ServiceException, e:
            print "Service call failed: %s"%e

            return 'failed'


class move_to_better_position(smach.State):
    def __init__(self):
        smach.State.__init__(self, 
                             outcomes=['succeeded', 'failed', 'preempted'],
                             input_keys = ['pose_list', 'id','humans_pose','person_label'],
                             output_keys=['pose_list_out','id_out','humans_pose_out','person_label_out'])
        
        self.target_object_name=''
        #self.object_list
        
        
        self.object_pose=Pose()
        self.bbpose=Pose()
        self.srv_name_people_detection='/cob_people_detection/detect_people'
        
    def execute(self, userdata):
        print userdata.id
        if self.preempt_requested():
           self.service_preempt()
           return 'preempted'
       
        
        #move to better position
        
        #get the robot's current pose from tf
        rb_pose = Pose2D()
        listener = tf.TransformListener()
        listener.waitForTransform("/map", "/base_link", rospy.Time(0), rospy.Duration(4.0)) #wait for 4secs for the coordinate to be transformed
        (trans,rot) = listener.lookupTransform("/map", "/base_link", rospy.Time(0))
        rb_pose.x = trans[0]
        rb_pose.y = trans[1]
        rb_pose_rpy = tf.transformations.euler_from_quaternion(rot)
        rb_pose.theta = rb_pose_rpy[2]
        rospy.sleep(0.5)
        
        x=rb_pose.x-userdata.pose_list[userdata.id].x
        y=rb_pose.y-userdata.pose_list[userdata.id].y
        
        
        #not sure about the direction
        theta=tan(x/y)       
         
        sss.move("base",[rb_pose.x,rb_pose.y,theta])
        
        userdata.id_out=userdata.id
        userdata.pose_list_out=userdata.pose_list
        userdata.humans_pose_out=userdata.humans_pose
        userdata.person_label_out=userdata.person_label
        
        return 'succeeded'
         
         
         
   
class face_detection(smach.State):
  def __init__(self):
      smach.State.__init__(self, 
                           outcomes=['succeeded', 'failed', 'preempted','retry'],
                           input_keys = ['pose_list', 'id','humans_pose','person_label'],
                           output_keys=['pose_list_output','id_out','face_list','humans_pose_out','person_label_out'])
      
      self.srv_name_face_detection='/cob_people_detection/detect_people'    
        
      self.object_pose=Pose()
      self.bbpose=Pose()
      
  def execute(self, userdata):
        

        if self.preempt_requested():
           self.service_preempt()
           return 'preempted'
         
        #searching for all people 
        if (userdata.person_label==''):
 
            try:
                rospy.wait_for_service(self.srv_name_face_detection,10)
            except rospy.ROSException, e:
                print "Service not available: %s"%e
                return 'next'
    
            # call object detection service
            try:
                detector_service = rospy.ServiceProxy(self.srv_name_face_detection, DetectPeople)
                req = DetectPeopleRequest()
                res = detector_service(req)
                if len(res.people_list.detections)==0:
                   userdata.id_out=userdata.id+1
                   userdata.pose_list_output=userdata.pose_list
                   return 'succeeded'    
                 
                userdata.face_list=res.people_list
                userdata.id_out=userdata.id
                userdata.pose_list_output=userdata.pose_list
                userdata.humans_pose_out=userdata.humans_pose
                userdata.person_label_out=userdata.person_label
    
                return 'succeeded'
                
    
            except rospy.ServiceException, e:
                print "Service call failed: %s"%e
    
                return 'failed'
            
        #searching for a special label    
        try:
            rospy.wait_for_service(self.srv_name_face_detection,10)
        except rospy.ROSException, e:
            print "Service not available: %s"%e
            return 'succeeded'

        # call object detection service
        try:
            detector_service = rospy.ServiceProxy(self.srv_name_face_detection, DetectPeople)
            req = DetectPeopleRequest()
            res = detector_service(req)
    
            for i in range (0,len(res.people_list.detections)):
                if(res.people_list.detections[i].label==userdata.person_label):

                    userdata.face_list=res.people_list.detections[i]
                    userdata.id_out=userdata.id
                    userdata.pose_list_output=userdata.pose_list
                    userdata.humans_pose_out=userdata.humans_pose
                    userdata.person_label_out=userdata.person_label
                    return 'succeeded'

            if userdata.id+1>len(userdata.pose_list)-1:
              print 'cant find special person'  
              return 'failed'  
            userdata.id_out=userdata.id+1
            userdata.pose_list_output=userdata.pose_list      
            return 'retry'

        except rospy.ServiceException, e:
            print "Service call failed: %s"%e

            return 'failed'
class body_detection(smach.State):
  def __init__(self):
      smach.State.__init__(self, 
                           outcomes=['succeeded', 'failed', 'preempted'],
                           input_keys = ['pose_list', 'id','humans_pose','person_label','face_list'],
                           output_keys=['pose_list_output','id_out','bodies_list','humans_pose_out','face_list_out','person_label_out'])
      
      self.srv_name_body_detection='/detect_bodies'    
        
      self.object_pose=Pose()
      self.bbpose=Pose()
      
  def execute(self, userdata):
        print userdata.id
        if self.preempt_requested():
           self.service_preempt()
           return 'preempted'
         
         
         
         
        try:
            rospy.wait_for_service(self.srv_name_body_detection,10)
        except rospy.ROSException, e:
            print "Service not available: %s"%e
            return 'failed'

        # call object detection service
        try:
            body_detector_service = rospy.ServiceProxy(self.srv_name_body_detection, getBodyDetections)
            req = getBodyDetectionsRequest()
            res = body_detector_service(req)
   
            userdata.bodies_list=res.bodies_list
            userdata.id_out=userdata.id
            userdata.pose_list_output=userdata.pose_list
            userdata.humans_pose_out=userdata.humans_pose
            
            userdata.face_list_out=userdata.face_list
            userdata.person_label_out=userdata.person_label

            return 'succeeded'
            

        except rospy.ServiceException, e:
            print "Service call failed: %s"%e

            return 'failed'
                
        
class compare_detections(smach.State):
  def __init__(self):
      smach.State.__init__(self, 
                           outcomes=['succeeded', 'retry',  'failed', 'preempted'],
                           input_keys = ['pose_list','face_list','bodies_list', 'id','humans_pose','person_label'],
                           output_keys=['pose_list_out','id_out','humans_pose_out','person_label'])
      
      self.srv_name_compare='compare_hs_detections'
      self.human=[]
      self.body_list=[]
      self.face_list=[]
  def execute(self, userdata):
      
      print userdata.id
      if self.preempt_requested():
           self.service_preempt()
           return 'preempted'
             
      if (userdata.person_label==''):

          self.human_array=userdata.humans_pose 

             
          try:
                rospy.wait_for_service(self.srv_name_compare,10)
          except rospy.ROSException, e:
                print "Service not available: %s"%e
                return 'failed'
        
        # call object detection service
          try:
                detector_service = rospy.ServiceProxy(self.srv_name_compare, Comp_HS_Detections)
                comp=Comp_HS_DetectionsRequest()
                for i in range(len(userdata.face_list.detections)):
                    pose=Pose()
                    pose.position.x=userdata.face_list.detections[i].pose.pose.position.x
                    pose.position.z=userdata.face_list.detections[i].pose.pose.position.z
                    pose.position.y=userdata.face_list.detections[i].pose.pose.position.y
                    pose.orientation.x=userdata.face_list.detections[i].pose.pose.orientation.x
                    pose.orientation.z=userdata.face_list.detections[i].pose.pose.orientation.z
                    pose.orientation.y=userdata.face_list.detections[i].pose.pose.orientation.y
                    self.face_list.append(pose)
                    
                comp.face_det=self.face_list
                comp.leg_det=userdata.pose_list[userdata.id]
                   
                       
                for i in range(len(userdata.bodies_list)):
                    pose=Pose()
                    pose.position.x=userdata.bodies_list[i].position.x
                    pose.position.z=userdata.bodies_list[i].position.z
                    pose.position.y=userdata.bodies_list[i].position.y
                    pose.orientation.x=userdata.bodies_list[i].orientation.x
                    pose.orientation.z=userdata.bodies_list[i].orientation.z
                    pose.orientation.y=userdata.bodies_list[i].orientation.y
                    self.body_list.append(pose)
                    
                comp.face_det=self.body_list
                comp.label=userdata.person_label
                res = detector_service(comp)
                for i in range(len(res.detect_human_array.detect_human)):
                    self.human_array.detect_human.append(res.detect_human_array.detect_human[i])
                                 
          
          except rospy.ServiceException, e:
                print "Service call failed: %s"%e
    
                return 'failed'
            
          userdata.humans_pose_out=self.human_array
          if userdata.id+1>len(userdata.pose_list)-1:
              print self.human_array
              return 'succeeded'
          userdata.id_out=userdata.id+1
          userdata.pose_list_out=userdata.pose_list
          userdata.person_label_out=userdata.person_label
      
          return 'retry'
      
      
      
      #compare label
      
      

      try:
            rospy.wait_for_service(self.srv_name_compare,10)
      except rospy.ROSException, e:
            print "Service not available: %s"%e
            return 'failed'
    
        # call object detection service
      try:
            compare_service = rospy.ServiceProxy(self.srv_name_compare, Comp_HS_Detections)
            comp=Comp_HS_DetectionsRequest()
           

                
            comp.leg_det=userdata.pose_list[userdata.id]
            
            
            pose=Pose()
            pose=userdata.face_list.pose.pose
            self.face_list.append(pose)
                    
            for i in range(len(userdata.bodies_list)):
                    pose=Pose()
                    pose.position.x=userdata.bodies_list[i].position.x
                    pose.position.z=userdata.bodies_list[i].position.z
                    pose.position.y=userdata.bodies_list[i].position.y
                    pose.orientation.x=userdata.bodies_list[i].orientation.x
                    pose.orientation.z=userdata.bodies_list[i].orientation.z
                    pose.orientation.y=userdata.bodies_list[i].orientation.y
                    self.body_list.append(pose)
            comp.label=userdata.person_label
            comp.face_det=self.face_list
            comp.body_det=self.body_list

            res = compare_service(comp)
            print res
            userdata.humans_pose_out=res

                    
            
                            
                    
      
      except rospy.ServiceException, e:
            print "Service call failed: %s"%e

            return 'failed'
        
      print self.human    
      return 'succeeded'

      

---

srs_human_sensing
Author(s): Alex
autogenerated on Wed Mar 6 00:24:38 2013