zhipuzi_pos_windows/lewaimai_dispatch/network/CMessagePush.h

#pragma once

#include "../pch/pch.h"
#include "../order/CWaimaiOrder.h"

using boost::asio::ip::tcp;

class CClientMessage
{
public:
	int m_type; //消息类型 0：新的外卖订单

	std::string m_username;
	std::string m_order_id;
	std::string m_order_no;
};

class WaimaiPinterInfo
{
public:
	std::string order_id;
	std::string order_no;
};

class CMessagePush
{
public:
	CMessagePush()
		: socket_(m_io_context)
	{

	}

	~CMessagePush();

	//开始工作
	void Start();

	//停止工作
	void Stop();

	//发送心跳包
	void KeepAlive();

	//专门处理推送消息
	void ReceiveMessage();

	//队列处理
	void HandleVoice();
	void HandleConfirm();
	void HandlePrinter();
	void HandleShouyinPrinter();
	void HandleChufangPrinter();


	void AddVoice(std::string order_id);
	void AddConfirm(std::string order_id);
	void AddPinter(std::string order_id, std::string order_no);
	void AddShouyinPrinter(CWaimaiOrder order);
	void AddChufangPrinter(CWaimaiOrder order);

private:
	void AddStopNum();

private:
	bool m_is_work;

	int m_nStopNum = 0;
	std::mutex m_nStopNumMutex;

	boost::asio::io_context m_io_context;
	tcp::socket socket_;

	enum { max_length = 1024 };
	char data_[max_length];

	std::queue<std::string> m_voice_queue;
	std::queue<std::string> m_confirm_queue;
	std::queue<WaimaiPinterInfo> m_printer_queue;
	std::queue<CWaimaiOrder> m_shouyin_printer_queue;
	std::queue<CWaimaiOrder> m_chufang_printer_queue;

	std::mutex m_voice_mutex;
	std::mutex m_confirm_mutex;
	std::mutex m_printer_mutex;
	std::mutex m_shouyin_printer_mutex;
	std::mutex m_chufang_printer_mutex;
};