84 lines
2.5 KiB
C++
84 lines
2.5 KiB
C++
#include "SimMsg.h"
|
|
#include "MagS.h"
|
|
|
|
#include <iostream>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
|
|
using namespace std;
|
|
|
|
void MagSWriteLog(const std::string &msg)
|
|
{
|
|
std::cout << msg<<std::endl;
|
|
}
|
|
|
|
string topic_name_cmd = "Command";
|
|
string topic_name_tlm = "Telemetry";
|
|
|
|
SimMsg* MagS_part = nullptr;
|
|
string servername = "Mag_Service";
|
|
|
|
//初始化
|
|
void MagS_init(uint8_t domainid, std::string appname)
|
|
{
|
|
std::vector<std::string> parameters;
|
|
string expression = "dest = '"+ servername + "'";
|
|
if (nullptr == MagS_part)
|
|
{
|
|
MagS_part=new SimMsg(domainid, 3000, appname, MagSWriteLog);
|
|
MagS_part->create_pub(topic_name_cmd);
|
|
MagS_part->create_pub(topic_name_tlm);
|
|
|
|
MagS_part->create_sub(topic_name_cmd, command_callback, expression, parameters);
|
|
MagS_part->create_sub(topic_name_tlm, telemetry_callback, expression, parameters);
|
|
}
|
|
}
|
|
|
|
// 遥控接收回调函数
|
|
void command_callback(std::string src, std::string dest, std::string type,
|
|
std::string reserve1, std::string reserve2,
|
|
std::vector<uint8_t>& data) {
|
|
// 打印接收到的数据
|
|
std::cout << "Command received from " << src << " to " << dest << std::endl;
|
|
std::cout << "Type: " << type << std::endl;
|
|
std::cout << "Data (" << data.size() << " bytes): ";
|
|
for (size_t i = 0; i < data.size(); ++i) {
|
|
std::cout << std::hex << std::uppercase << (int)data[i];
|
|
if (i < data.size() - 1) {
|
|
std::cout << ", ";
|
|
}
|
|
}
|
|
std::cout << std::dec << std::endl;
|
|
}
|
|
|
|
// 遥测接收回调函数
|
|
void telemetry_callback(std::string src, std::string dest, std::string type,
|
|
std::string reserve1, std::string reserve2,
|
|
std::vector<uint8_t>& data) {
|
|
// 打印接收到的数据
|
|
std::cout << "Telemetry received from " << src << " to " << dest << std::endl;
|
|
std::cout << "Type: " << type << std::endl;
|
|
std::cout << "Data (" << data.size() << " bytes): ";
|
|
for (size_t i = 0; i < data.size(); ++i) {
|
|
std::cout << std::hex << std::uppercase << (int)data[i];
|
|
if (i < data.size() - 1) {
|
|
std::cout << ", ";
|
|
}
|
|
}
|
|
std::cout << std::dec << std::endl;
|
|
}
|
|
|
|
|
|
// 能源管理服务遥控发布
|
|
void MagS_command_Pub(uint8_t* data, string dest, uint16_t len)
|
|
{
|
|
MagS_part->publish(topic_name_cmd, "Mag_Service", dest, "command", data, len);
|
|
}
|
|
|
|
// 能源管理服务遥测发布
|
|
void MagS_telemetry_Pub(uint8_t* data, string dest, uint16_t len)
|
|
{
|
|
MagS_part->publish(topic_name_tlm, "Mag_Service", dest, "telemetry", data, len);
|
|
}
|