server/mine_module/MineCardManager.cpp

#include "MineCardManager.h"
#include "ya_setting.h"
#include "common_tool.h"
#include "mine.h"

CMineCardManager::CMineCardManager()
{
    m_minecards = std::make_shared<mine_card_info>();
}

std::shared_ptr<mine_card_info> CMineCardManager::GetMineCards() 
{
    return m_minecards;
}

 /**
     * @brief 获取事件ID
     **/
bool CMineCardManager::Exist(SET_CARDID &list,uint64_t id)
{
    if (list.find(id) == list.end())
    {
        return false;
    }
    return true;
}

bool CMineCardManager::Exist(SET_CARDID &list,int card_id,int card_type)
{
    return Exist(list,tool_other::type_id_to_u64(card_type,card_id));
}
/**
 * @brief 人员下井
 * @param card 卡
 **/
void CMineCardManager::OnPersonDown(std::shared_ptr<card> card,bool bInit/* = false*/)
{
    if (nullptr == card)
    {
        return ;
    }
     //设置卡的状态
    card->m_is_attendance = EAttendanceState::MineDown;
   
    uint64_t key = tool_other::type_id_to_u64(card->m_id,card->m_type);
    if (this->Exist(m_minecards->m_down_person,key))
    {
        return ;
    }   
     //移除升井中的状态
    m_minecards->m_up_person.erase(key);
    //加入到井下列表中
    m_minecards->m_down_person.insert(key);
    if(!bInit)
    {
        //井下超员判断
        this->OnPersonOvercrowdingWarning();
    }
}
    /**
 * @brief 人员升井
 * @param card 卡
 **/
void CMineCardManager::OnPersonUp(std::shared_ptr<card> card)
{
    if (nullptr == card)
    {
        return ;
    }
    card->m_is_attendance = EAttendanceState::MineUp;
    uint64_t key = tool_other::type_id_to_u64(card->m_id,card->m_type);
    if (this->Exist(m_minecards->m_up_person,key))
    {
        return ;
    }   
     //移除井下列表
    m_minecards->m_down_person.erase(key);
    //加入到升井列表中
    m_minecards->m_up_person.insert(key);
    
    int max_person = CYaSetting::m_sys_setting.over_count_person;
    //井下超员判断--取消
    if (max_person != 0 && (int)m_minecards->m_down_person.size() < max_person )
    {
        //this->CancelEvent(EVENT_TYPE::ET_OVER_COUNT_PERSON,(int)m_minecards->m_down_person.size());
    }
    
}

/**
 * @brief 人员超员警告
**/
void CMineCardManager::OnPersonOvercrowdingWarning()
{
  //  int max_person = CYaSetting::m_sys_setting.over_count_person;
  //  //井下超员判断
  //  if (max_person != 0 && (int)m_minecards->m_down_person.size() > max_person )
  //  {
  //      std::string log = "";
  //      for (uint64_t id : m_minecards->m_down_person)
  //      {
  //          std::shared_ptr<card_location_base> pitcard = card_list::instance()->get(id);
  //          if (nullptr != pitcard)
  //          {
  //              log += tool_other::type_id_to_str(pitcard->m_type,pitcard->m_id);
  //              log += "&";
  //          }
  //      }
  //      //打印日志
  //      log_info("[lemon mp_card_list_down_person:]:%s",log.c_str());

  //      this->StartEvent(EVENT_TYPE::ET_OVER_COUNT_PERSON,max_person,(int)m_minecards->m_down_person.size());
  //  }
}

/**
* @brief 人员井下超时
**/
void CMineCardManager::OnPersonInMineOverTime(int card_id,int card_type)
{
  //  std::shared_ptr<card_location_base> card = card_list::instance()->get(tool_other::type_id_to_u64(card_type, card_id));
  //  if (nullptr == card)
  //  {
  //      return ;
  //  }

  //  std::shared_ptr<mine_tool> mine = card->get_mine_tool();
  //  if(nullptr == mine )
  //  {
  //      return ;
  //  }

  //  int sec= tool_time::to_ms(std::chrono::system_clock::now()) - mine->get_work_time();
  //  if (!mine->m_is_overtime && sec > (int)CYaSetting::m_sys_setting.over_time_person)
  //  {
  //      //人员超时
  //      mine->m_is_overtime = true;
  //      mine->m_overtime = std::chrono::system_clock::now();
  //  }
  //  else if (mine->m_is_overtime && sec < (int)CYaSetting::m_sys_setting.over_time_person)
  //  {
  //      mine->m_is_overtime = false;
  //      mine->m_overtime = std::chrono::system_clock::now();
  //  }
  //  else
  //  {
  //      return ;
  //  }

  //  // 发送警告
  //  event_ptr evPtr = event_list::instance()->get_event_card(card->m_id,card->m_type,ET_CARD_OVER_TIME_PERSON);
  //  if (nullptr == evPtr)
  //  {
  //      event_ptr evPtr = event_list::create_event_card(card->m_id, card->m_type, ET_CARD_OVER_TIME_PERSON);
  //      event_list::instance()->copy_event(card, evPtr);
  //      event_list::instance()->add(evPtr->get_list_id(), evPtr);
  //  }
  //  evPtr->m_limit_value = 0;
  //  evPtr->m_cur_value = 0;
  //  evPtr->m_is_display = false;
  //  evPtr->m_status = mine->m_is_overtime ? ES_START : ES_END;
  //  evPtr->m_cur_time = std::chrono::system_clock::now();

  //  event_list::save_event(evPtr);

  //  log_info("OnPersonInMineOverTime: send Event=ET_CARD_OVER_TIME_PERSON card=id,eventState=%d",card->m_id,evPtr->m_status);
}
    /**
 * @brief 车下井
 * @param card 卡
 **/
void CMineCardManager::OnVehicleDown(std::shared_ptr<card> card,bool bInit/* = false*/)
{
    if (nullptr == card)
    {
        return ;
    }
}
    /**
 * @brief 车升井
 * @param card 卡
 **/
void CMineCardManager::OnVehicleUp(std::shared_ptr<card> card)
{
    if (nullptr == card)
    {
        return ;
    }
}

 /**
 * @brief 车辆超员警告
 **/
void CMineCardManager::OnVehicleOvercrowdingWarning()
{

}