server-l-zmg/websocket/wsTimerThread.cpp

#include "wsTimerThread.h"
#include <iostream>
#include "wsClientMgr.h"
#include "constdef.h"
#include "log.h"
#include "ya_setting.h"

namespace YA
{
	wsTimerThread::wsTimerThread()
	{
		__Reset();
	}

	wsTimerThread::~wsTimerThread()
	{
		Stop();
	}

	void wsTimerThread::Start()
	{
		__Running = true;
		__Thread.reset( new boost::thread( boost::bind( &wsTimerThread::_ThreadFunc, this, this ) ) );
        //__Thread->detach();
	}

	void wsTimerThread::Stop()
	{
        if(__Thread==nullptr)
        {
            return;
        }
        __Thread->interrupt();
        __Running = false;
		std::cout << "wsTimerThread::Stop() begin" << std::endl;

		__Enable = false;

		if ( __Running )
		{
			boost::unique_lock<boost::mutex> lock( __ExitMutex );
			__ExitCond.wait( lock );
		}

		__Reset();
        __Thread=nullptr;

		std::cout << "wsTimerThread::Stop() end" << std::endl;
	}

	void wsTimerThread::__Reset()
	{
		__Enable  = true;
		__Running = false;
	}

	void wsTimerThread::__ChkConfig()
	{
		if ( __Config.SendInterval < MIN_SEND_INTERVAL )
		{
			__Config.SendInterval = MIN_SEND_INTERVAL;
		}
	}

	void wsTimerThread::__SendCardPos()
	{
		std::map<uint64_t, _CARD_POS_> CardPosList;
		if(__CardPosList.empty())
		    return;
		__CardPosList.copy( CardPosList );
		std::string jsCardPos = __jsBuilder.BuildCardPos( CardPosList );
		swsClientMgr.send( JSON_CMD_VALUE_PUSH, jsCardPos );
	}

    void wsTimerThread::send_card_pos()
    {
        if(__CardPosList.empty()){
            //std::cout<<"send_card_pos: card's list is empty.";
            return;
        } 

        std::map<uint64_t, _CARD_POS_> cards;
        __CardPosList.copy(cards);
        //log_info("[service-position] size=%d", cards.size());
        //service_position send
        for(auto it = cards.begin(); it != cards.end(); ++it)
        {
            std::string json_pos = __jsBuilder.build_ios_card_pos(it->second);
            //log_info("[service-position] json_pos: card_id=%d, freq=%.2f, json=%s", it->second.ID, it->second.m_freq, json_pos.c_str());
            ios_service::m_ios_service->notify(json_pos, std::to_string(it->second.ID), it->second.m_freq);
        }
    }

    void wsTimerThread::temp_send_card_pos()
    {
        if(__CardPosList.empty()){
            return;
        }
        std::map<uint64_t, _CARD_POS_> cards;
        __CardPosList.copy(cards);
        std::string json_pos = __jsBuilder.build_tmp_card_pos(cards);
        swsClientMgr.send(JSON_CMD_VALUE_PUSH, json_pos);
    }

    /*
     * 定时器线程发送定位数据
     *
     * */
	void wsTimerThread::_ThreadFunc( wsTimerThread * pOwner )
	{	
        log_info("The timer thread is running");
        while ( pOwner->__Enable )
		{
			std::time_t t = time( 0 );
			int seconds = (int)std::difftime( t, __LastSendTime );

			if ( seconds >= pOwner->__Config.SendInterval )
			{
				pOwner->__SendCardPos();
                //service_position send
                //pOwner->send_card_pos();
                //pOwner->temp_send_card_pos();
				__LastSendTime = t;
			}
          	boost::this_thread::sleep( boost::posix_time::millisec( 1 ) );
		}

		pOwner->__ExitCond.notify_one();
	}

	void wsTimerThread::Init( const _THREAD_CONFIG_ & Config )
	{
		__Config = Config;
		__ChkConfig();
	}

	void wsTimerThread::upt_card_pos( const _CARD_POS_ & pos )
	{
		//如果已存在就更新，否则插入
		uint64_t type = pos.Type;
		uint64_t id=type<<32|pos.ID;
		if ( __CardPosList.seek( id  ) )
		{
			__CardPosList.update( id, pos );
		}
		else
		{
			__CardPosList.insert( id, pos );
		}
	}

    void wsTimerThread::real_upt_card_pos(const _CARD_POS_& pos)
    {
        std::string pos_json = __jsBuilder.build_ios_card_pos(pos);
        ios_service::m_ios_service->notify(pos_json, std::to_string(pos.ID), 10);
        log_info("[service-position] json: %s", pos_json.c_str());
    }

	void wsTimerThread::del_card_pos( const _CARD_POS_ & pos )
	{
		uint64_t type = pos.Type;
		uint64_t id=type<<32|pos.ID;
		__CardPosList.erase( id );
	}
}