zhipuzi_pos_windows/lewaimai_dispatch/network/CMessagePush.cpp

#include "../pch/pch.h"
#include "CMessagePush.h"

#include "../tool/CPosPrinter.h"
#include "../order/CWaimaiOrder.h"

#include "mmsystem.h" 

CMessagePush::~CMessagePush()
{
	
}

void CMessagePush::Start()
{
	std::thread t(&CMessagePush::Run, this);
	t.detach();
}

void CMessagePush::Run()
{
	try
	{
		char host[] = "127.0.0.1";
		char port[] = "9001";

		tcp::resolver resolver(m_io_context);
		tcp::resolver::results_type endpoints =
			resolver.resolve(tcp::v4(), host, port);

		boost::asio::connect(socket_, endpoints);

		//发送身份信息
		rapidjson::Document doc;
		doc.SetObject();
		rapidjson::Document::AllocatorType &allocator = doc.GetAllocator(); //获取分配器

		doc.AddMember("username", "zhangyang", allocator);

		rapidjson::StringBuffer buffer;
		rapidjson::Writer<StringBuffer> writer(buffer);
		doc.Accept(writer);

		//返回给接入层的消息
		std::string m_login_msg = buffer.GetString();

		//异步发送消息
		PushMessage(m_login_msg);

		//同时启动一个异步接受消息
		socket_.async_read_some(boost::asio::buffer(data_, max_length),
			boost::bind(&CMessagePush::handle_read, this,
				boost::asio::placeholders::error,
				boost::asio::placeholders::bytes_transferred));

		m_io_context.run();
	}
	catch (std::exception& e)
	{
		std::cerr << "Exception: " << e.what() << "\n";
	}
}

void CMessagePush::PushMessage(std::string msg)
{
	boost::asio::async_write(socket_,
		boost::asio::buffer(msg.c_str(), msg.length()),
		boost::bind(&CMessagePush::handle_write, this,
			boost::asio::placeholders::error));
}

void CMessagePush::HandleMessage(std::string msg)
{
	try
	{
		//收到服务器的消息，对服务器的消息进行处理
		rapidjson::Document document;
		document.Parse(msg.c_str());
		if (!document.IsObject())
		{
			LOG_INFO("message 非法！");
			return;
		}

		int type = document["type"].GetInt();

		if (type == 0)
		{
			std::string status = document["status"].GetString();

			if (status == "ok")
			{
				//表示连接服务器成功了
			}
		}
		else if (type == 1)
		{
			std::string username = document["username"].GetString();
			std::string order_id = document["order_id"].GetString();
			std::string order_no = document["order_no"].GetString();

			//新订单来了，首先判断是否要语音提醒
			if (CSetting::GetParam("setting_is_new_waimai_voice") == "1")
			{
				//需要语音提醒
				std::wstring filepath = L"music/new_wamai_order.mp3";
				std::wstring Open = L"OPEN " + filepath + L" ALIAS MUSIC";
				mciSendString(Open.c_str(), NULL, 0, 0);

				std::wstring Play = L"PLAY MUSIC FROM 0";
				mciSendString(Play.c_str(), NULL, 0, 0);

				std::wstring Close = L"CLOSE MUSIC";
				mciSendString(Close.c_str(), NULL, 0, 0);
			}

			//判断是否要自动确认
			if (CSetting::GetParam("setting_is_new_waimai_autoconfirm") == "1")
			{
				CWaimaiOrder newOrder;
				newOrder.ConfirmeOrder(order_id);
			}

			//判断是否右下角弹框提醒
			if (CSetting::GetParam("setting_is_new_waimai_dialog") == "1")
			{
				
			}

			//判断是否自动打印
			if (CSetting::GetParam("setting_is_new_waimai_printer") == "1")
			{
				CPosPrinter printer;

				//判断打印规格和联数
				std::string guige = CSetting::GetParam("setting_printer_guige");
				std::string lianshu = CSetting::GetParam("setting_printer_lianshu");

				int n_lianshu = atoi(lianshu.c_str());
				for (int i = 0; i < n_lianshu; i++)
				{
					if (guige == "58")
					{
						printer.PrintWaimaiOrder(order_id, order_no, 1);
					}
					else
					{
						printer.PrintWaimaiOrder(order_id, order_no, 2);
					}
				}
			}
		}
	}
	catch (std::exception& e)
	{
		std::cerr << "Exception: " << e.what() << "\n";
	}
}

void CMessagePush::handle_read(const boost::system::error_code& error,
	size_t bytes_transferred)
{
	if (!error)
	{
		string s_reply = data_;
		HandleMessage(s_reply);

		memset(data_, 0, max_length);
		socket_.async_read_some(boost::asio::buffer(data_, max_length),
			boost::bind(&CMessagePush::handle_read, this,
				boost::asio::placeholders::error,
				boost::asio::placeholders::bytes_transferred));
	}
	else
	{
		delete this;
	}
}

void CMessagePush::handle_write(const boost::system::error_code& error)
{
	if (!error)
	{
		LOG_INFO("send success!");
	}
	else
	{
		delete this;
	}
}