/*
 * tcp_util.cpp
 *
 *  Created on: 2024年7月18日
 *      Author: m
 */

#include "tcp_model.h"
#include "tcp_util.h"
#include "json/json.h"
#include <utils/TimeHelper.h>
#include "base/strings.hpp"
#include "service/BusinessConfig.h"



void sendNursing() {
	// 发送tcp, tcp_type = SIDE, tcp_action = NURSING
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d",TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::SIDE;
	tcpModel.action = SideAction::NURSING;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;

	sendTcpModel(tcpModel);
}


void sendNursingEnd() {
	// 发送tcp, tcp_type = SIDE, tcp_action = NURSING_END
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::SIDE;
	tcpModel.action = SideAction::NURSING_END;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.data = StoragePreferences::getString(STORE_NURSING_INTERACTION_ID, "");	// 获取nursingTcpModel里，id字段的数据

	sendTcpModel(tcpModel);
}

void sendReinforceCall() {
	TcpModel tcpModel;
	tcpModel.type = TcpType::REINFORCE;
	tcpModel.action = ReinforceAction::CALL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	sendTcpModel(tcpModel);
}

std::string sendVoiceCall(Json::Value json, std::string tid) {
	TcpModel tcpModel;
	if (tid != "") {
		tcpModel.tid = tid;
	}
	else {
		tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	}
	tcpModel.type = TcpType::VOICE;
	tcpModel.action = VoiceAction::CALL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.json = json;

	sendTcpModel(tcpModel);
	return tcpModel.tid;
}

std::string sendVoiceCall(Json::Value json) {
	return sendVoiceCall(json, "");
}

std::string sendVoiceCall(int toId) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::VOICE;
	tcpModel.action = VoiceAction::CALL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = toId;

	sendTcpModel(tcpModel);
	return tcpModel.tid;
}


void sendVoiceTcp(std::string action, TcpModel model, int toId){
	//发出TCP
	TcpModel tcpModel;
	tcpModel.tid = model.tid;
	tcpModel.type = TcpType::VOICE;
	tcpModel.action = action;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = toId;
	if (model.data != ""){
		tcpModel.data = model.data;
	} else if (model.json > 0){
		tcpModel.json = model.json;
	}

	sendTcpModel(tcpModel);
}


void sendVoiceCancel(int toId) {
	TcpModel tcpModel;
	tcpModel.type = TcpType::VOICE;
	tcpModel.action = VoiceAction::CANCEL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = toId;
	sendTcpModel(tcpModel);
}

void sendVoiceCancelByDoor() {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d",TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::VOICE;
	tcpModel.action = VoiceAction::CANCEL_BY_DOOR;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	std::string req = getTcpModelString(tcpModel);
	sendTcpModel(tcpModel);
}


void sendSosCall(std::string sosMsg) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::SOS;
	tcpModel.action = SosAction::CALL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID, 0);
	tcpModel.to_id = 0;
	if (sosMsg != "") {
		Json::Value data;
		data["title"] = sosMsg;
		tcpModel.json = data;
	}

	sendTcpModel(tcpModel);

}


void sendSosCancel(std::string sosId) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::SOS;
	tcpModel.action = SosAction::CANCEL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID, 0);
	tcpModel.to_id = 0;
	tcpModel.data = sosId;

	sendTcpModel(tcpModel);
}


void sendSosRoomCall() {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::SOS;
	tcpModel.action = SosAction::ROOM_CALL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID, 0);
	tcpModel.to_id = 0;

	sendTcpModel(tcpModel);
}

void sendPowerReset() {
	TcpModel tcpModel;
	tcpModel.type = TcpType::DEVICE;
	tcpModel.action = DeviceAction::POWER_RESET;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;

	sendTcpModel(tcpModel);
}


void sendEventClick(Json::Value json) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d",TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::EVENT;
	tcpModel.action = EventAction::KEY_CLICK;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.json = json;
	sendTcpModel(tcpModel);
}

void sendEventCompleted(std::string event) {
	TcpModel tcpModel;
	tcpModel.type = TcpType::EVENT;
	tcpModel.action = EventAction::COMPLETED;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.data = event;
	tcpModel.tid = base::format("t%d",TimeHelper::getCurrentTime());

	sendTcpModel(tcpModel);
}


void sendEventCancel(std::string event) {
	TcpModel tcpModel;
	tcpModel.type = TcpType::EVENT;
	tcpModel.action = EventAction::CANCEL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.data = event;
	tcpModel.tid = base::format("t%d",TimeHelper::getCurrentTime());

	sendTcpModel(tcpModel);
}


void sendConutdownStart(Json::Value json) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::COUNTDOWN;
	tcpModel.action = CountdownAction::START;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.json = json;
	sendTcpModel(tcpModel);
}

void sendCountdownEnd(std::string id) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::COUNTDOWN;
	tcpModel.action = CountdownAction::END;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.data = id;
	sendTcpModel(tcpModel);
}

void sendCountdownCancel(std::string id) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::COUNTDOWN;
	tcpModel.action = CountdownAction::CANCEL;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
	tcpModel.to_id = 0;
	tcpModel.data = id;
	sendTcpModel(tcpModel);
}

void sendDataRemindOhter(std::string msg) {
	TcpModel tcpModel;
	tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
	tcpModel.type = TcpType::DATA;
	tcpModel.action = DataAction::REMIND_OTHER;
	tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID, 0);
    tcpModel.to_id = 0;
	tcpModel.data = msg;

	sendTcpModel(tcpModel);
}