|
|
@@ -7,6 +7,9 @@
|
|
|
#include <hiredis/hiredis.h>
|
|
|
#include <sqlite3.h>
|
|
|
|
|
|
+#include "DatabaseWorker.h"
|
|
|
+#include "../logger/Logger.h"
|
|
|
+
|
|
|
// 回调函数，用于处理查询结果
|
|
|
static int sql_callback(void *NotUsed, int argc, char **argv, char **azColName) {
|
|
|
for (int i = 0; i < argc; i++) {
|
|
|
@@ -50,9 +53,14 @@ static uint16_t calculate_crc16(uint8_t *data, size_t length) {
|
|
|
|
|
|
|
|
|
|
|
|
-
|
|
|
// 构造函数
|
|
|
-TcpServer::TcpServer(int port) : conn_num(0), running(true) {
|
|
|
+TcpServer::TcpServer(int port)
|
|
|
+ :
|
|
|
+ db_queue(), // 默认构造 db_queue
|
|
|
+ db_worker(db_queue), // 用 db_queue 初始化 db_worker
|
|
|
+ running(true),
|
|
|
+ conn_num(0)
|
|
|
+{
|
|
|
server_fd = socket(AF_INET, SOCK_STREAM, 0);
|
|
|
if (server_fd < 0) {
|
|
|
perror("Socket creation failed");
|
|
|
@@ -81,7 +89,7 @@ TcpServer::TcpServer(int port) : conn_num(0), running(true) {
|
|
|
}
|
|
|
|
|
|
// Listen for incoming connections
|
|
|
- if (listen(server_fd, 3) < 0) {
|
|
|
+ if (listen(server_fd, SOMAXCONN) < 0) {
|
|
|
perror("Listen failed");
|
|
|
close(server_fd);
|
|
|
throw std::runtime_error("Listen failed");
|
|
|
@@ -106,14 +114,13 @@ TcpServer::~TcpServer() {
|
|
|
close(server_fd);
|
|
|
}
|
|
|
|
|
|
+
|
|
|
// 启动服务器
|
|
|
void TcpServer::start_server() {
|
|
|
std::cout << "Starting server..." << std::endl;
|
|
|
// 初始化CRC16表格
|
|
|
init_crc16_table();
|
|
|
|
|
|
-
|
|
|
-
|
|
|
accept_thread = std::thread([this]() {
|
|
|
while (this->running) {
|
|
|
char client_ip[INET_ADDRSTRLEN];
|
|
|
@@ -121,6 +128,7 @@ void TcpServer::start_server() {
|
|
|
if (new_socket < 0) {
|
|
|
// 打印错误信息
|
|
|
std::cerr << "Accept failed with error: " << strerror(errno) << std::endl;
|
|
|
+ std::cout << "当前连接数量: " << this->conn_num << std::endl;
|
|
|
if (errno == EINTR) {
|
|
|
// 如果是信号中断，继续等待连接
|
|
|
continue;
|
|
|
@@ -136,20 +144,36 @@ void TcpServer::start_server() {
|
|
|
std::string ip_str(client_ip);
|
|
|
|
|
|
std::cout << "客户端已连接: " << ip_str << ":" << client_port << std::endl;
|
|
|
+
|
|
|
{
|
|
|
std::lock_guard<std::mutex> lock(mtx_client_addrs);
|
|
|
+
|
|
|
+ if (ip_str == "172.16.111.60" || ip_str == "172.16.111.61" || ip_str == "172.16.111.62") {
|
|
|
+ for (auto it = client_addrs.begin(); it != client_addrs.end();) {
|
|
|
+ if (it->ip == ip_str) {
|
|
|
+ it = client_addrs.erase(it); // 删除当前元素，返回下一个迭代器
|
|
|
+ } else {
|
|
|
+ ++it; // 不删，继续往后走
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
client_addrs.push_back({ip_str, client_port, new_socket});
|
|
|
+
|
|
|
}
|
|
|
|
|
|
{
|
|
|
std::lock_guard<std::mutex> lock(mtx);
|
|
|
this->conn_num++;
|
|
|
- std::cout << "Current connection count: " << this->conn_num << std::endl;
|
|
|
+ LOG_Debug("客户端已连接：%s %d 当前连接数量：%d", ip_str.c_str(), client_port, this->conn_num);
|
|
|
+ std::cout << "当前连接数量: " << this->conn_num << std::endl;
|
|
|
+
|
|
|
+// LOG_Debug("", this->conn_num); // 不会输出
|
|
|
}
|
|
|
|
|
|
- // Create a new thread to handle the client
|
|
|
-// threads.emplace_back(&TcpServer::handle_client, this, new_socket);
|
|
|
- std::thread(&TcpServer::handle_client, this, new_socket).detach();
|
|
|
+ threads.emplace_back([this, new_socket, ip_str]() {
|
|
|
+ handle_client(new_socket, ip_str);
|
|
|
+ });
|
|
|
+// std::thread(&TcpServer::handle_client, this, new_socket).detach();
|
|
|
}
|
|
|
});
|
|
|
accept_thread.detach(); // 让接受线程独立运行
|
|
|
@@ -160,406 +184,502 @@ std::vector<ClientAddr> TcpServer::get_connected_clients() {
|
|
|
std::lock_guard<std::mutex> lock(mtx_client_addrs);
|
|
|
return client_addrs;
|
|
|
}
|
|
|
+void TcpServer::remove_connected_clients(std::string ip) {
|
|
|
+ std::lock_guard<std::mutex> lock(mtx_client_addrs);
|
|
|
+ auto it = client_addrs.begin();
|
|
|
+ while (it != client_addrs.end()) {
|
|
|
+ if (it->ip == ip) {
|
|
|
+// close(it->sockfd); // 关闭 socket
|
|
|
+ it = client_addrs.erase(it); // 删除元素并更新迭代器
|
|
|
+ } else {
|
|
|
+ ++it;
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+nlohmann::json decode_modbus_msg(const uint8_t * buffer, std::string& device_name){
|
|
|
+ int dev_addr = buffer[0];
|
|
|
+ int fun_code = buffer[1];
|
|
|
+ int data_len = buffer[2];
|
|
|
+ int dev_type = buffer[6];
|
|
|
+
|
|
|
+ nlohmann::json json_save;
|
|
|
+
|
|
|
+ if(dev_type == 9) {
|
|
|
+ std::cout << "门锁" << std::endl;
|
|
|
+ }
|
|
|
+ if(dev_type == 10) {
|
|
|
+ std::cout << "噪声" << std::endl;
|
|
|
+ }
|
|
|
+ if(dev_type == 12) {
|
|
|
+ std::cout << "蓄电池" << std::endl;
|
|
|
+ }
|
|
|
+ std::string postfix = "NARI-";
|
|
|
+ // 公共字段
|
|
|
+ json_save["status"] = "run";
|
|
|
+ json_save["gateway_id"] = 0;
|
|
|
+ std::string dev_name = "device_" + std::to_string(dev_addr);
|
|
|
+ if (dev_type == 1) { // 温湿度
|
|
|
+ device_name = "温湿度-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "温湿度-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 温度对象
|
|
|
+ nlohmann::json temp_data;
|
|
|
+ temp_data["name"] = "温度";
|
|
|
+ temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
+ temp_data["format"] = "℃";
|
|
|
+ temp_data["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(temp_data);
|
|
|
+
|
|
|
+ // 湿度对象
|
|
|
+ nlohmann::json humidity_data;
|
|
|
+ humidity_data["name"] = "湿度";
|
|
|
+ humidity_data["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
+ humidity_data["format"] = "%RH";
|
|
|
+ humidity_data["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(humidity_data);
|
|
|
+ } else if (dev_type == 2) { // 水浸
|
|
|
+ device_name = "水浸-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "水浸-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 水浸对象
|
|
|
+ nlohmann::json water_data;
|
|
|
+ water_data["name"] = "水浸状态";
|
|
|
+ water_data["value"] = ((buffer[7] << 8) + buffer[8]); // 0 表示无水浸，1 表示有水浸
|
|
|
+ // if((buffer[7] << 8) + buffer[8] == 0)
|
|
|
+ // water_data["value"] = "正常";
|
|
|
+ // else
|
|
|
+ // water_data["value"] = "告警";
|
|
|
+ water_data["format"] = "";
|
|
|
+ water_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(water_data);
|
|
|
+
|
|
|
+ } else if (dev_type == 3) { // 烟感
|
|
|
+ device_name = "烟感-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "烟感-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 烟感对象
|
|
|
+ nlohmann::json smoke_data;
|
|
|
+ smoke_data["name"] = "报警状态";
|
|
|
+ smoke_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
+ // if((buffer[7] << 8) + buffer[8] == 0)
|
|
|
+ // smoke_data["value"] = "正常";
|
|
|
+ // else
|
|
|
+ // smoke_data["value"] = "告警";
|
|
|
+ smoke_data["format"] = "";
|
|
|
+ smoke_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(smoke_data);
|
|
|
+ }else if (dev_type == 7) {
|
|
|
+ device_name = "空调-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "空调-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 开关对象
|
|
|
+ nlohmann::json switch_data;
|
|
|
+ switch_data["name"] = "开关";
|
|
|
+ switch_data["value"] = ((buffer[7] << 8) + buffer[8]);
|
|
|
+ switch_data["format"] = "";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+ // 模式对象
|
|
|
+ nlohmann::json mode_data;
|
|
|
+ mode_data["name"] = "模式";
|
|
|
+ mode_data["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
+ mode_data["format"] = "";
|
|
|
+ mode_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(mode_data);
|
|
|
+ // 模式对象
|
|
|
+ nlohmann::json set_temperature_data;
|
|
|
+ set_temperature_data["name"] = "设定温度";
|
|
|
+ set_temperature_data["value"] = ((buffer[11] << 8) + buffer[12]);
|
|
|
+ set_temperature_data["format"] = "℃";
|
|
|
+ set_temperature_data["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(set_temperature_data);
|
|
|
+ // 模式对象
|
|
|
+ nlohmann::json wind_speed_data;
|
|
|
+ wind_speed_data["name"] = "风速";
|
|
|
+ wind_speed_data["value"] = ((buffer[13] << 8) + buffer[14]);
|
|
|
+ wind_speed_data["format"] = "";
|
|
|
+ wind_speed_data["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(wind_speed_data);
|
|
|
+ // 模式对象
|
|
|
+ nlohmann::json wind_direction_data;
|
|
|
+ wind_direction_data["name"] = "风向";
|
|
|
+ wind_direction_data["value"] = ((buffer[15] << 8) + buffer[16]);
|
|
|
+ wind_direction_data["format"] = "";
|
|
|
+ wind_direction_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(wind_direction_data);
|
|
|
+
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[17] << 8) + buffer[18]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else if (dev_type == 6) { // 照明
|
|
|
+ device_name = "照明-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "照明-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ //开关
|
|
|
+ nlohmann::json switch_data;
|
|
|
+ switch_data["name"] = "开关";
|
|
|
+ switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
+ switch_data["format"] = "";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else if (dev_type == 8) { // 门磁
|
|
|
+ device_name = "门磁-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "门磁-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ //开关
|
|
|
+ nlohmann::json switch_data;
|
|
|
+ switch_data["name"] = "开关";
|
|
|
+ switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
+ switch_data["format"] = "";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else if (dev_type == 5) { // 风机
|
|
|
+ device_name = "风机-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "风机-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ //开关
|
|
|
+ nlohmann::json switch_data;
|
|
|
+ switch_data["name"] = "开关";
|
|
|
+ switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
+ switch_data["format"] = "";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else if (dev_type == 9) { // 智能门锁
|
|
|
+ device_name = "智能门锁-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "智能门锁-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ //开关
|
|
|
+ nlohmann::json switch_data;
|
|
|
+ switch_data["name"] = "门状态";
|
|
|
+ switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
+ switch_data["format"] = "";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+
|
|
|
+ switch_data["name"] = "门控制";
|
|
|
+ switch_data["value"] = (buffer[9] << 8) + buffer[10];
|
|
|
+ switch_data["format"] = "";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+
|
|
|
+ switch_data["name"] = "上报周期";
|
|
|
+ switch_data["value"] = (buffer[11] << 8) + buffer[12];
|
|
|
+ switch_data["format"] = "s";
|
|
|
+ switch_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(switch_data);
|
|
|
+ }else if (dev_type == 4) { // 双气
|
|
|
+ device_name = "双气-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "双气-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 氧气浓度
|
|
|
+ nlohmann::json temp_data;
|
|
|
+ temp_data["name"] = "氧气浓度";
|
|
|
+ temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
+ temp_data["format"] = "%";
|
|
|
+ temp_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(temp_data);
|
|
|
+
|
|
|
+ // SF6浓度
|
|
|
+ nlohmann::json humidity_data;
|
|
|
+ humidity_data["name"] = "SF6浓度";
|
|
|
+ humidity_data["value"] = ((buffer[9] << 8) + buffer[10])/10.0;
|
|
|
+ humidity_data["format"] = "ppm";
|
|
|
+ humidity_data["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(humidity_data);
|
|
|
+
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[11] << 8) + buffer[12]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else if (dev_type == 10) { // 噪声
|
|
|
+ device_name = "噪声-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "噪声-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 噪声值
|
|
|
+ nlohmann::json temp_data;
|
|
|
+ temp_data["name"] = "噪声值";
|
|
|
+ temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
+ temp_data["format"] = "db";
|
|
|
+ temp_data["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(temp_data);
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else if (dev_type == 11) { // 噪声
|
|
|
+ device_name = "臭氧-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "臭氧-" + postfix + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 臭氧浓度
|
|
|
+ nlohmann::json temp_data;
|
|
|
+ temp_data["name"] = "臭氧浓度";
|
|
|
+ temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
+ temp_data["format"] = "0.1ppm";
|
|
|
+ temp_data["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(temp_data);
|
|
|
+
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[11] << 8) + buffer[12]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }
|
|
|
+ else if (dev_type == 12) { // 蓄电池
|
|
|
+ device_name = "蓄电池-" + std::to_string(dev_addr);
|
|
|
+ json_save["device_name"] = "蓄电池-" + std::to_string(dev_addr);
|
|
|
+ json_save["device_id"] = dev_addr;
|
|
|
+
|
|
|
+ // 开关对象
|
|
|
+ nlohmann::json group_voltage;
|
|
|
+ group_voltage["name"] = "组电压";
|
|
|
+ group_voltage["value"] = (((buffer[7] << 8) + buffer[8]))/10.0;
|
|
|
+ group_voltage["format"] = "V";
|
|
|
+ group_voltage["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(group_voltage);
|
|
|
+ // 模式对象
|
|
|
+ nlohmann::json group_current;
|
|
|
+ group_current["name"] = "组电流";
|
|
|
+ group_current["value"] = ((buffer[9] << 8) + buffer[10]) / 100.0;
|
|
|
+ group_current["format"] = "A";
|
|
|
+ group_current["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(group_current);
|
|
|
+
|
|
|
+ for(int i = 0; i <= 8; i++) {
|
|
|
+ nlohmann::json sigle_voltage;
|
|
|
+ sigle_voltage["name"] = "电池-" + std::to_string(i+1) + " 电压";
|
|
|
+ sigle_voltage["value"] = ((buffer[11 + i * 2] << 8) + buffer[12 + i * 2]) / 1000.0;
|
|
|
+ sigle_voltage["format"] = "V";
|
|
|
+ sigle_voltage["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(sigle_voltage);
|
|
|
+ }
|
|
|
+ // 模式对象
|
|
|
+ for(int i = 0; i <= 8; i++) {
|
|
|
+ nlohmann::json sigle_temp;
|
|
|
+ sigle_temp["name"] = "电池-" + std::to_string(i+1) + " 温度";
|
|
|
+ sigle_temp["value"] = ((buffer[29 + i * 2] << 8) + buffer[30 + i * 2]) / 100.0;
|
|
|
+ sigle_temp["format"] = "℃";
|
|
|
+ sigle_temp["format_id"] = 40;
|
|
|
+ json_save["data"].push_back(sigle_temp);
|
|
|
+ }
|
|
|
+ // 模式对象
|
|
|
+ for(int i = 0; i <= 8; i++) {
|
|
|
+ nlohmann::json sigle_resistance;
|
|
|
+ sigle_resistance["name"] = "电池-" + std::to_string(i+1) + " 内阻";
|
|
|
+ sigle_resistance["value"] = ((buffer[47 + i * 2] << 8) + buffer[48 + i * 2]) / 1000.0;
|
|
|
+ sigle_resistance["format"] = "mΩ";
|
|
|
+ sigle_resistance["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(sigle_resistance);
|
|
|
+ }
|
|
|
+
|
|
|
+ for(int i = 0; i <= 8; i++) {
|
|
|
+ nlohmann::json sigle_volumn;
|
|
|
+ sigle_volumn["name"] = "电池-" + std::to_string(i+1) + " 容量";
|
|
|
+ sigle_volumn["value"] = ((buffer[65 + i * 2] << 8) + buffer[66 + i * 2]) / 100.0;
|
|
|
+ sigle_volumn["format"] = "";
|
|
|
+ sigle_volumn["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(sigle_volumn);
|
|
|
+ }
|
|
|
+ // 上报周期
|
|
|
+ nlohmann::json report_period;
|
|
|
+ report_period["name"] = "上报周期";
|
|
|
+ report_period["value"] = ((buffer[83] << 8) + buffer[84]);
|
|
|
+ report_period["format"] = "s";
|
|
|
+ report_period["format_id"] = 0;
|
|
|
+ json_save["data"].push_back(report_period);
|
|
|
+ }else{
|
|
|
+ std::cout << "未知设备类型： " << dev_type << std::endl;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+// std::cout << "devaice_name: " << dev_name << std::endl;
|
|
|
+// std::cout << "json_save： "<< json_save.dump(1) << std::endl;
|
|
|
+ return json_save;
|
|
|
+}
|
|
|
+
|
|
|
|
|
|
// 处理客户端连接
|
|
|
-void TcpServer::handle_client(int client_socket) {
|
|
|
+void TcpServer::handle_client(int client_socket, const std::string& ip) {
|
|
|
uint8_t buffer[BUFFER_SIZE];
|
|
|
while (true) {
|
|
|
- memset(buffer, 0, BUFFER_SIZE);
|
|
|
- int bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0);
|
|
|
- if (bytes_received <= 0) {
|
|
|
- // Client disconnected or error
|
|
|
- std::cout << "Client disconnected or error occurred. bytes_received = " << bytes_received << std::endl;
|
|
|
+ // 检测连接状态
|
|
|
+ fd_set read_fds;
|
|
|
+ FD_ZERO(&read_fds);
|
|
|
+ FD_SET(client_socket, &read_fds);
|
|
|
+
|
|
|
+ struct timeval timeout = {1, 0}; // 1秒超时
|
|
|
+ int activity = select(client_socket + 1, &read_fds, nullptr, nullptr, &timeout);
|
|
|
+
|
|
|
+ if (activity < 0 && errno != EINTR) {
|
|
|
+ close(client_socket);
|
|
|
+ this->conn_num--;
|
|
|
+ std::cout << "连接已断开: " << this->conn_num << std::endl;
|
|
|
+ LOG_Debug("%s 连接已断开，当前连接数量：%d", ip.c_str(), this->conn_num);
|
|
|
+ break; // 出错退出
|
|
|
+ }
|
|
|
+
|
|
|
+ if (FD_ISSET(client_socket, &read_fds)) {
|
|
|
+ memset(buffer, 0, BUFFER_SIZE);
|
|
|
+ int bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0);
|
|
|
+ if (bytes_received <= 0) {
|
|
|
close(client_socket);
|
|
|
- this->conn_num --;
|
|
|
- std::cout << "Current connection count: " << this->conn_num << std::endl;
|
|
|
+ this->conn_num--;
|
|
|
+ std::cout << "连接已断开，当前连接数量是: " << this->conn_num << std::endl;
|
|
|
+ LOG_Debug("%s 连接已断开，当前连接数量：%d", ip.c_str(), this->conn_num);
|
|
|
break;
|
|
|
- }
|
|
|
- std::cout << "Received from client, size = " << bytes_received << " data = ";
|
|
|
- for(int i = 0;i < bytes_received; i++){
|
|
|
+ }
|
|
|
+ std::cout << "接收到对端消息, size = " << bytes_received << " data = ";
|
|
|
+ for (int i = 0; i < bytes_received; i++) {
|
|
|
printf("0x%02x ", buffer[i]);
|
|
|
- }
|
|
|
- printf("\n");
|
|
|
- if(bytes_received < 11){
|
|
|
- std::cout << "too short msg!" << std::endl;
|
|
|
+ }
|
|
|
+ printf("\n");
|
|
|
+ if (bytes_received < 11) {
|
|
|
+ std::cout << "消息太短，丢弃！" << std::endl;
|
|
|
continue;
|
|
|
- }
|
|
|
+ }
|
|
|
|
|
|
- // if(calculate_crc16(buffer, bytes_received - 2)){
|
|
|
- uint16_t CRC = calculate_crc16(buffer, bytes_received - 2);
|
|
|
- if(((buffer[bytes_received - 1]<<8) != (CRC&(0xff<<8))) || (buffer[bytes_received - 2] != (CRC&0xff))){
|
|
|
- std::cout << "error crc msg!" << std::endl;
|
|
|
+ // if(calculate_crc16(buffer, bytes_received - 2)){
|
|
|
+ uint16_t CRC = calculate_crc16(buffer, bytes_received - 2);
|
|
|
+ if (((buffer[bytes_received - 1] << 8) != (CRC & (0xff << 8))) || (buffer[bytes_received - 2] != (CRC & 0xff))) {
|
|
|
+ std::cout << "crc错误，丢弃！" << std::endl;
|
|
|
continue;
|
|
|
- }
|
|
|
- std::cout << "CRC = " << CRC <<std::endl;
|
|
|
+ }
|
|
|
+ // std::cout << "CRC = " << CRC <<std::endl;
|
|
|
|
|
|
- int dev_addr = buffer[0];
|
|
|
- int fun_code = buffer[1];
|
|
|
- int data_len = buffer[2];
|
|
|
- int dev_type = buffer[6];
|
|
|
- std::string device_name;
|
|
|
+ std::string deviceName;
|
|
|
+ int dev_addr = buffer[0];
|
|
|
|
|
|
- nlohmann::json json_save;
|
|
|
+ nlohmann::json json_save = decode_modbus_msg(buffer, deviceName);
|
|
|
|
|
|
- if(dev_type == 9) {
|
|
|
- std::cout << "门锁" << std::endl;
|
|
|
- }
|
|
|
- if(dev_type == 10) {
|
|
|
- std::cout << "噪声" << std::endl;
|
|
|
- }
|
|
|
- if(dev_type == 12) {
|
|
|
- std::cout << "蓄电池" << std::endl;
|
|
|
- }
|
|
|
- // 公共字段
|
|
|
- json_save["status"] = "run";
|
|
|
- json_save["gateway_id"] = 0;
|
|
|
- std::string dev_name = "device_" + std::to_string(dev_addr);
|
|
|
- if (dev_type == 1) { // 温湿度
|
|
|
- device_name = "温湿度-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "温湿度-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 温度对象
|
|
|
- nlohmann::json temp_data;
|
|
|
- temp_data["name"] = "温度";
|
|
|
- temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
- temp_data["format"] = "℃";
|
|
|
- temp_data["format_id"] = 40;
|
|
|
- json_save["data"].push_back(temp_data);
|
|
|
-
|
|
|
- // 湿度对象
|
|
|
- nlohmann::json humidity_data;
|
|
|
- humidity_data["name"] = "湿度";
|
|
|
- humidity_data["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
- humidity_data["format"] = "%RH";
|
|
|
- humidity_data["format_id"] = 40;
|
|
|
- json_save["data"].push_back(humidity_data);
|
|
|
- } else if (dev_type == 2) { // 水浸
|
|
|
- device_name = "水浸-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "水浸-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 水浸对象
|
|
|
- nlohmann::json water_data;
|
|
|
- water_data["name"] = "水浸状态";
|
|
|
- // water_data["value"] = ((buffer[7] << 8) + buffer[8]); // 0 表示无水浸，1 表示有水浸
|
|
|
- if((buffer[7] << 8) + buffer[8] == 0)
|
|
|
- water_data["value"] = "正常";
|
|
|
- else
|
|
|
- water_data["value"] = "告警";
|
|
|
- water_data["format"] = "";
|
|
|
- water_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(water_data);
|
|
|
-
|
|
|
- } else if (dev_type == 3) { // 烟感
|
|
|
- device_name = "烟感-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "烟感-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 烟感对象
|
|
|
- nlohmann::json smoke_data;
|
|
|
- smoke_data["name"] = "报警状态";
|
|
|
- if((buffer[7] << 8) + buffer[8] == 0)
|
|
|
- smoke_data["value"] = "正常";
|
|
|
- else
|
|
|
- smoke_data["value"] = "告警";
|
|
|
- smoke_data["format"] = "";
|
|
|
- smoke_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(smoke_data);
|
|
|
- }else if (dev_type == 7) {
|
|
|
- device_name = "空调-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "空调-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 开关对象
|
|
|
- nlohmann::json switch_data;
|
|
|
- switch_data["name"] = "开关";
|
|
|
- switch_data["value"] = ((buffer[7] << 8) + buffer[8]);
|
|
|
- switch_data["format"] = "";
|
|
|
- switch_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(switch_data);
|
|
|
- // 模式对象
|
|
|
- nlohmann::json mode_data;
|
|
|
- mode_data["name"] = "模式";
|
|
|
- mode_data["value"] = ((buffer[9] << 8) + buffer[10]);
|
|
|
- mode_data["format"] = "";
|
|
|
- mode_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(mode_data);
|
|
|
- // 模式对象
|
|
|
- nlohmann::json set_temperature_data;
|
|
|
- set_temperature_data["name"] = "设定温度";
|
|
|
- set_temperature_data["value"] = ((buffer[11] << 8) + buffer[12]);
|
|
|
- set_temperature_data["format"] = "℃";
|
|
|
- set_temperature_data["format_id"] = 40;
|
|
|
- json_save["data"].push_back(set_temperature_data);
|
|
|
- // 模式对象
|
|
|
- nlohmann::json wind_speed_data;
|
|
|
- wind_speed_data["name"] = "风速";
|
|
|
- wind_speed_data["value"] = ((buffer[13] << 8) + buffer[14]);
|
|
|
- wind_speed_data["format"] = "";
|
|
|
- wind_speed_data["format_id"] = 40;
|
|
|
- json_save["data"].push_back(wind_speed_data);
|
|
|
- // 模式对象
|
|
|
- nlohmann::json wind_direction_data;
|
|
|
- wind_direction_data["name"] = "风向";
|
|
|
- wind_direction_data["value"] = ((buffer[15] << 8) + buffer[16]);
|
|
|
- wind_direction_data["format"] = "";
|
|
|
- wind_direction_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(wind_direction_data);
|
|
|
- }else if (dev_type == 6) { // 照明
|
|
|
- device_name = "照明-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "照明-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- //开关
|
|
|
- nlohmann::json switch_data;
|
|
|
- switch_data["name"] = "开关";
|
|
|
- switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
- switch_data["format"] = "";
|
|
|
- switch_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(switch_data);
|
|
|
- }else if (dev_type == 8) { // 门磁
|
|
|
- device_name = "门磁-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "门磁-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- //开关
|
|
|
- nlohmann::json switch_data;
|
|
|
- switch_data["name"] = "开关";
|
|
|
- switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
- switch_data["format"] = "";
|
|
|
- switch_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(switch_data);
|
|
|
- }else if (dev_type == 5) { // 风机
|
|
|
- device_name = "风机-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "风机-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- //开关
|
|
|
- nlohmann::json switch_data;
|
|
|
- switch_data["name"] = "开关";
|
|
|
- switch_data["value"] = (buffer[7] << 8) + buffer[8];
|
|
|
- switch_data["format"] = "";
|
|
|
- switch_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(switch_data);
|
|
|
- }else if (dev_type == 9) { // 智能门锁
|
|
|
- device_name = "智能门锁-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "智能门锁-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- //开关
|
|
|
- nlohmann::json switch_data;
|
|
|
- switch_data["name"] = "门状态";
|
|
|
- switch_data["value"] = (buffer[9] << 8) + buffer[10];
|
|
|
- switch_data["format"] = "";
|
|
|
- switch_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(switch_data);
|
|
|
-
|
|
|
- switch_data["name"] = "门控制";
|
|
|
- switch_data["value"] = (buffer[9] << 8) + buffer[10];
|
|
|
- switch_data["format"] = "";
|
|
|
- switch_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(switch_data);
|
|
|
- }else if (dev_type == 4) { // 双气
|
|
|
- device_name = "双气-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "双气-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 氧气浓度
|
|
|
- nlohmann::json temp_data;
|
|
|
- temp_data["name"] = "氧气浓度";
|
|
|
- temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
- temp_data["format"] = "%";
|
|
|
- temp_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(temp_data);
|
|
|
-
|
|
|
- // SF6浓度
|
|
|
- nlohmann::json humidity_data;
|
|
|
- humidity_data["name"] = "SF6浓度";
|
|
|
- humidity_data["value"] = ((buffer[9] << 8) + buffer[10])/10.0;
|
|
|
- humidity_data["format"] = "ppm";
|
|
|
- humidity_data["format_id"] = 0;
|
|
|
- json_save["data"].push_back(humidity_data);
|
|
|
- }else if (dev_type == 10) { // 噪声
|
|
|
- device_name = "噪声-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "噪声-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 噪声值
|
|
|
- nlohmann::json temp_data;
|
|
|
- temp_data["name"] = "噪声值";
|
|
|
- temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
- temp_data["format"] = "db";
|
|
|
- temp_data["format_id"] = 40;
|
|
|
- json_save["data"].push_back(temp_data);
|
|
|
- }else if (dev_type == 11) { // 噪声
|
|
|
- device_name = "臭氧-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "臭氧-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 臭氧浓度
|
|
|
- nlohmann::json temp_data;
|
|
|
- temp_data["name"] = "臭氧浓度";
|
|
|
- temp_data["value"] = ((buffer[7] << 8) + buffer[8])/10.0;
|
|
|
- temp_data["format"] = "0.1ppm";
|
|
|
- temp_data["format_id"] = 40;
|
|
|
- json_save["data"].push_back(temp_data);
|
|
|
- }else if (dev_type == 12) { // 蓄电池
|
|
|
- device_name = "蓄电池-" + std::to_string(dev_addr);
|
|
|
- json_save["device_name"] = "蓄电池-" + std::to_string(dev_addr);
|
|
|
- json_save["device_id"] = dev_addr;
|
|
|
-
|
|
|
- // 开关对象
|
|
|
- nlohmann::json group_voltage;
|
|
|
- group_voltage["name"] = "组电压";
|
|
|
- group_voltage["value"] = (((buffer[7] << 8) + buffer[8]))/10.0;
|
|
|
- group_voltage["format"] = "V";
|
|
|
- group_voltage["format_id"] = 0;
|
|
|
- json_save["data"].push_back(group_voltage);
|
|
|
- // 模式对象
|
|
|
- nlohmann::json group_current;
|
|
|
- group_current["name"] = "组电流";
|
|
|
- group_current["value"] = ((buffer[9] << 8) + buffer[10]) / 100.0;
|
|
|
- group_current["format"] = "A";
|
|
|
- group_current["format_id"] = 0;
|
|
|
- json_save["data"].push_back(group_current);
|
|
|
-
|
|
|
- for(int i = 0; i <= 8; i++) {
|
|
|
- nlohmann::json sigle_voltage;
|
|
|
- sigle_voltage["name"] = "电池-" + std::to_string(i+1) + " 电压";
|
|
|
- sigle_voltage["value"] = ((buffer[11 + i * 2] << 8) + buffer[12 + i * 2]) / 1000.0;
|
|
|
- sigle_voltage["format"] = "V";
|
|
|
- sigle_voltage["format_id"] = 40;
|
|
|
- json_save["data"].push_back(sigle_voltage);
|
|
|
- }
|
|
|
- // 模式对象
|
|
|
- for(int i = 0; i <= 8; i++) {
|
|
|
- nlohmann::json sigle_temp;
|
|
|
- sigle_temp["name"] = "电池-" + std::to_string(i+1) + " 温度";
|
|
|
- sigle_temp["value"] = ((buffer[29 + i * 2] << 8) + buffer[30 + i * 2]) / 100.0;
|
|
|
- sigle_temp["format"] = "℃";
|
|
|
- sigle_temp["format_id"] = 40;
|
|
|
- json_save["data"].push_back(sigle_temp);
|
|
|
- }
|
|
|
- // 模式对象
|
|
|
- for(int i = 0; i <= 8; i++) {
|
|
|
- nlohmann::json sigle_resistance;
|
|
|
- sigle_resistance["name"] = "电池-" + std::to_string(i+1) + " 内阻";
|
|
|
- sigle_resistance["value"] = ((buffer[47 + i * 2] << 8) + buffer[48 + i * 2]) / 1000.0;
|
|
|
- sigle_resistance["format"] = "mΩ";
|
|
|
- sigle_resistance["format_id"] = 0;
|
|
|
- json_save["data"].push_back(sigle_resistance);
|
|
|
- }
|
|
|
|
|
|
- for(int i = 0; i <= 8; i++) {
|
|
|
- nlohmann::json sigle_volumn;
|
|
|
- sigle_volumn["name"] = "电池-" + std::to_string(i+1) + " 容量";
|
|
|
- sigle_volumn["value"] = ((buffer[65 + i * 2] << 8) + buffer[66 + i * 2]) / 100.0;
|
|
|
- sigle_volumn["format"] = "";
|
|
|
- sigle_volumn["format_id"] = 0;
|
|
|
- json_save["data"].push_back(sigle_volumn);
|
|
|
- }
|
|
|
- }else{
|
|
|
- std::cout << "未知设备类型： " << dev_type << std::endl;
|
|
|
- return;
|
|
|
- }
|
|
|
+ // 添加额外信息
|
|
|
+ json_save["dev_addr"] = dev_addr;
|
|
|
+ json_save["device_name"] = deviceName;
|
|
|
+ // 放入队列
|
|
|
+ db_queue.push(json_save);
|
|
|
|
|
|
- std::cout << "devaice_name " << dev_name << "json_save "<< json_save.dump(1) << std::endl;
|
|
|
|
|
|
- sqlite3 *db;
|
|
|
- char *zErrMsg = 0;
|
|
|
- int rc;
|
|
|
|
|
|
- // 打开数据库连接
|
|
|
- rc = sqlite3_open("/usr/local/bin/database/sqlite/history_data.db", &db);
|
|
|
- if (rc) {
|
|
|
- fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
|
|
|
+ sqlite3_stmt* stmt = nullptr;
|
|
|
+ sqlite3* db = nullptr;
|
|
|
+ const std::string dbPath = "/usr/local/bin/database/sqlite/device_position.db";
|
|
|
+
|
|
|
+ // 直接打开数据库（不会自动创建目录或建表）
|
|
|
+ if (sqlite3_open(dbPath.c_str(), &db) != SQLITE_OK) {
|
|
|
+ std::cerr << "无法打开数据库: " << sqlite3_errmsg(db) << std::endl;
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ // 检查设备是否已存在
|
|
|
+ std::string checkSQL = "SELECT COUNT(*) FROM device_position WHERE name = ?;";
|
|
|
+ if (sqlite3_prepare_v2(db, checkSQL.c_str(), -1, &stmt, nullptr) != SQLITE_OK) {
|
|
|
+ std::cerr << "Prepare failed: " << sqlite3_errmsg(db) << std::endl;
|
|
|
sqlite3_close(db);
|
|
|
- return;
|
|
|
- }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
|
|
|
- // 创建表
|
|
|
- const char *sql_create_table =
|
|
|
- "CREATE TABLE IF NOT EXISTS history_data ("
|
|
|
- "id INTEGER PRIMARY KEY AUTOINCREMENT,"
|
|
|
- "data TEXT NOT NULL,"
|
|
|
- "time TEXT NOT NULL,"
|
|
|
- "device_id INTEGER NOT NULL,"
|
|
|
- "device_name TEXT NOT NULL,"
|
|
|
- "gateway_id INTEGER NOT NULL,"
|
|
|
- "status TEXT NOT NULL);"
|
|
|
- "PRAGMA busy_timeout = 5000;";
|
|
|
-
|
|
|
- rc = sqlite3_exec(db, sql_create_table, sql_callback, 0, &zErrMsg);
|
|
|
- if (rc != SQLITE_OK) {
|
|
|
- fprintf(stderr, "SQL error: %s\n", zErrMsg);
|
|
|
- sqlite3_free(zErrMsg);
|
|
|
- } else {
|
|
|
- printf("Table created successfully\n");
|
|
|
- }
|
|
|
+ sqlite3_bind_text(stmt, 1, deviceName.c_str(), -1, SQLITE_STATIC);
|
|
|
|
|
|
- // 插入数据
|
|
|
- const char *sql_insert_data =
|
|
|
- "INSERT INTO history_data (data, time, device_id, device_name, gateway_id, status) VALUES (?, ?, ?, ?, ?, ?);";
|
|
|
+ bool exists = false;
|
|
|
+ if (sqlite3_step(stmt) == SQLITE_ROW) {
|
|
|
+ exists = (sqlite3_column_int(stmt, 0) > 0);
|
|
|
+ }
|
|
|
+ sqlite3_finalize(stmt);
|
|
|
|
|
|
- // 准备插入语句
|
|
|
- sqlite3_stmt *stmt;
|
|
|
- rc = sqlite3_prepare_v2(db, sql_insert_data, -1, &stmt, 0);
|
|
|
- if (rc != SQLITE_OK) {
|
|
|
- fprintf(stderr, "Failed to prepare statement: %s\n", sqlite3_errmsg(db));
|
|
|
- sqlite3_close(db);
|
|
|
- return;
|
|
|
- }
|
|
|
+ if (exists) {
|
|
|
+ std::cout << "设备 [" << deviceName << "] 已存在，跳过插入。 ip=" << ip << std::endl;
|
|
|
|
|
|
- // 定义要插入的数据
|
|
|
- std::string sql_data = json_save["data"].dump();
|
|
|
- rc = sqlite3_bind_text(stmt, 1, sql_data.c_str(), -1, SQLITE_STATIC);
|
|
|
-
|
|
|
- // 获取当前时间
|
|
|
- time_t rawtime;
|
|
|
- struct tm *timeinfo;
|
|
|
- // 获取当前时间的时间戳
|
|
|
- time(&rawtime);
|
|
|
- // 将时间戳转换为本地时间
|
|
|
- timeinfo = localtime(&rawtime);
|
|
|
- // 提取年、月、日、时、分、秒
|
|
|
- int year = 1900 + timeinfo->tm_year; // tm_year 是从 1900 年开始的年数
|
|
|
- int month = 1 + timeinfo->tm_mon; // tm_mon 是从 0 开始的月份（0-11）
|
|
|
- int day = timeinfo->tm_mday; // tm_mday 是一个月中的第几天（1-31）
|
|
|
- int hour = timeinfo->tm_hour; // tm_hour 是小时（0-23）
|
|
|
- int minute = timeinfo->tm_min; // tm_min 是分钟（0-59）
|
|
|
- int second = timeinfo->tm_sec; // tm_sec 是秒（0-59）
|
|
|
-
|
|
|
- // 打印时间信息
|
|
|
- char time[30] = {};
|
|
|
- sprintf(time,"%d-%02d-%02d %02d:%02d:%02d",
|
|
|
- year, month, day, hour, minute, second);
|
|
|
- rc = sqlite3_bind_text(stmt, 2, time, -1, SQLITE_STATIC);
|
|
|
-
|
|
|
- rc = sqlite3_bind_int(stmt, 3, dev_addr);
|
|
|
- rc = sqlite3_bind_text(stmt, 4, device_name.c_str(), -1, SQLITE_STATIC);
|
|
|
- rc = sqlite3_bind_int(stmt, 5, 0);
|
|
|
- rc = sqlite3_bind_text(stmt, 6, "run", -1, SQLITE_STATIC);
|
|
|
- if (rc != SQLITE_OK) {
|
|
|
- fprintf(stderr, "Failed to bind parameters: %s\n", sqlite3_errmsg(db));
|
|
|
- sqlite3_finalize(stmt);
|
|
|
+ if(ip == "172.16.111.60" || ip == "172.16.111.61" || ip == "172.16.111.62"
|
|
|
+ || ip == "172.16.111.64" || ip == "172.16.111.63" || ip == "172.16.111.65" || ip == "172.16.111.68" || ip == "172.16.111.70") {
|
|
|
sqlite3_close(db);
|
|
|
- return;
|
|
|
+ close(client_socket);
|
|
|
+ this->conn_num--;
|
|
|
+ std::cout << "连接已经断开: " << ip << "当前连接数量：" << this->conn_num << std::endl;
|
|
|
+ LOG_Debug("%s 连接已断开，当前连接数量：%d", ip.c_str(), this->conn_num);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ sqlite3_close(db);
|
|
|
+ continue;
|
|
|
}
|
|
|
- rc = sqlite3_step(stmt);
|
|
|
- if (rc != SQLITE_DONE) {
|
|
|
- fprintf(stderr, "Failed to execute insert: %s\n", sqlite3_errmsg(db));
|
|
|
+
|
|
|
+ // 插入新设备
|
|
|
+ std::string insertSQL = "INSERT INTO device_position (name, x, y) VALUES (?, 0.5, 0.25);";
|
|
|
+ if (sqlite3_prepare_v2(db, insertSQL.c_str(), -1, &stmt, nullptr) != SQLITE_OK) {
|
|
|
+ std::cerr << "Insert prepare failed: " << sqlite3_errmsg(db) << std::endl;
|
|
|
+ sqlite3_close(db);
|
|
|
+ continue;
|
|
|
}
|
|
|
- // 清理语句
|
|
|
- sqlite3_finalize(stmt);
|
|
|
|
|
|
+ sqlite3_bind_text(stmt, 1, deviceName.c_str(), -1, SQLITE_STATIC);
|
|
|
|
|
|
- // 关闭数据库连接
|
|
|
- sqlite3_close(db);
|
|
|
+ if (sqlite3_step(stmt) != SQLITE_DONE) {
|
|
|
+ std::cerr << "插入失败: " << sqlite3_errmsg(db) << std::endl;
|
|
|
+ sqlite3_finalize(stmt);
|
|
|
+ sqlite3_close(db);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ sqlite3_finalize(stmt);
|
|
|
+ sqlite3_close(db);
|
|
|
+ std::cout << "设备 [" << deviceName << "] 插入成功。" << std::endl;
|
|
|
|
|
|
+ if(ip == "172.16.111.60" || ip == "172.16.111.61" || ip == "172.16.111.62" || ip == "172.16.111.64"
|
|
|
+ || ip == "172.16.111.64" || ip == "172.16.111.63" || ip == "172.16.111.65" || ip == "172.16.111.68" || ip == "172.16.111.70") {
|
|
|
+ close(client_socket);
|
|
|
+ this->conn_num--;
|
|
|
+ std::cout << "连接已经断开: " << ip << "当前连接数量：" << this->conn_num << std::endl;
|
|
|
+ LOG_Debug("%s 连接已经断开 当前连接数量：%d", ip.c_str(), this->conn_num);
|
|
|
+ break;
|
|
|
+ }
|
|
|
|
|
|
- this->conn_num--;
|
|
|
- break;
|
|
|
+ }
|
|
|
|
|
|
}
|
|
|
-}
|
|
|
+}
|
