123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259 |
- /*
- * 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);
- }
|