AGV/MPC/navigation_main.cpp

//
// Created by zx on 23-5-8.
//

#include "navigation_main.h"


NavigationMain::NavigationMain(){
  move_mode_=Monitor_emqx::eSingle;
  wheelBase_=0;
}
NavigationMain::~NavigationMain(){

}

void NavigationMain::ResetPose(const Pose2d& pose){
  if(move_mode_==Monitor_emqx::eMain) {
    Pose2d transform(-wheelBase_/2.0,0,0);
    Navigation::ResetPose(pose * transform);
  }
  else
    Navigation::ResetPose(pose);
}

void NavigationMain::publish_statu(NavMessage::NavStatu& statu)
{
  statu.set_main_agv(true);
  Navigation::publish_statu(statu);
}

void NavigationMain::HandleNavCmd(const NavMessage::NavCmd& cmd)
{
  if(cmd.action()==4)
  {
    if(cmd.wheelbase()<2.4 || cmd.wheelbase()>3.5)
    {
      printf("Failed to Switch MoveMode --> main,wheelbase invalid :%f\n",cmd.wheelbase());
      return;
    }
    printf(" Switch MoveMode --> main\n");
    SwitchMode(Monitor_emqx::eMain,cmd.wheelbase());
    return ;
  }
  if(cmd.action()==5)
  {
    printf(" Switch MoveMode --> single\n");
    SwitchMode(Monitor_emqx::eSingle,0);
    return ;
  }
  else
  {
    Navigation::HandleNavCmd(cmd);
  }
}

bool NavigationMain::Start(const NavMessage::NavCmd& cmd)
{
  /*if(move_mode_!=Monitor_emqx::eMain)
  {
    printf(" navigation mode must set main,parameter:Pose2d\n");
    return false;
  }*/

  return Navigation::Start(cmd);

}

void NavigationMain::SendMoveCmd(Monitor_emqx::ActionMode mode,Monitor_emqx::ActionType type,
                double v,double angular)
{
  if(monitor_)
  {
    monitor_->set_speed(mode,type,v,angular,wheelBase_);
  }

}

NavMessage::RobotStatu NavigationMain::CreateRobotStatuMsg()
{
  NavMessage::RobotStatu agvStatu=Navigation::CreateRobotStatuMsg();
  agvStatu.mutable_agvstatu()->set_clamp_other(timed_other_clamp_.Get());
  //std::cout<<agvStatu.DebugString()<<std::endl;
  return agvStatu;
}

void NavigationMain::ResetOtherClamp(ClampStatu statu)
{
  timed_other_clamp_.reset(statu,1);
}

void NavigationMain::HandleAgvStatu(const MqttMsg& msg)
{
  NavMessage::AgvStatu speed;
  if(msg.toProtoMessage(speed))
  {
    ResetStatu(speed.v(),speed.w());
    ResetClamp((ClampStatu)speed.clamp());
    ResetOtherClamp((ClampStatu)speed.clamp_other());
    //printf(" clamp:%d   other:%d\n",speed.clamp(),speed.clamp_other());
  }
}

bool NavigationMain::clamp_close()
{
  if(move_mode_==Monitor_emqx::eSingle)
    return Navigation::clamp_close();
  printf("双车夹持\n");
  if(monitor_) {
    monitor_->clamp_close(move_mode_);
    while (exit_ == false) {
      if (timed_clamp_.timeout() || timed_other_clamp_.timeout()) {
        printf("timed clamp is timeout\n");
        return false;
      }
      if (timed_clamp_.Get() == eClosed && timed_other_clamp_.Get()==eClosed) {
        printf("双车夹持completed!!!\n");
        return true;
      }
      std::this_thread::sleep_for(std::chrono::milliseconds(100));
      monitor_->clamp_close(move_mode_);
    }
    return false;
  }
  return false;
}
bool NavigationMain::clamp_open() {
  if(move_mode_==Monitor_emqx::eSingle)
    return Navigation::clamp_open();

  if(monitor_) {
    printf("双车松夹持\n");
    monitor_->clamp_open(move_mode_);
    while(exit_==false)
    {
      if(timed_clamp_.timeout()||timed_other_clamp_.timeout())
      {
        printf("timed clamp is timeout\n");
        return false;
      }
      if(timed_clamp_.Get()==eOpened&&timed_other_clamp_.Get()==eOpened) {
        printf("双车松夹持completed!!!\n");
        return true;
      }
      std::this_thread::sleep_for(std::chrono::milliseconds(100));
      monitor_->clamp_open(move_mode_);
    }
    return false;
  }
  return false;
}