#include <stdio.h>
#include <unistd.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include 'handle.h'

int receiveUserId(int sockfd) {
    int userid;
    ssize_t recvSize = recv(sockfd, &userid, sizeof(int), 0);
    if (recvSize == -1 || recvSize == 0 || recvSize != sizeof(int)) {
        perror('接收userid失败');
        return -1;
    }
    return ntohl(userid);
}

sqlite3_stmt* prepareStatement(sqlite3 *db, int userid) {
    char sql[100];
    snprintf(sql, sizeof(sql), 'SELECT * FROM Status WHERE uid = %d', userid);
    sqlite3_stmt *stmt = NULL;
    int rc = sqlite3_prepare_v2(db, sql, -1, &stmt, NULL);
    if (rc != SQLITE_OK) {
        fprintf(stderr, '无法执行的语句: %s\n', sqlite3_errmsg(db));
        return NULL;
    }
    return stmt;
}

void initializeStatus(Status *status) {
    memset(status, 0, sizeof(Status));
    status->uid = 0;
    status->device_name[0] = '\0';
}

void updateAcStatus(Status *acStatus, int uid, const unsigned char *device_state, const unsigned char *value) {
    acStatus->uid = uid;
    strncpy(acStatus->device_state, device_state, sizeof(acStatus->device_state) - 1);
    acStatus->device_state[sizeof(acStatus->device_state) - 1] = '\0';
    strncpy(acStatus->value, value, sizeof(acStatus->value) - 1);
    acStatus->value[sizeof(acStatus->value) - 1] = '\0';

}

void generateAcSuggestion(const Status *acStatus, char *suggestion) {
    int temperature = atoi(acStatus->value);
 
    if (temperature < 24) {
        snprintf(suggestion, MAX_BUFFER_SIZE, '空调温度过低,建议提高温度至26℃');
    } else if(temperature>35){
        snprintf(suggestion, MAX_BUFFER_SIZE, '空调温度过高,建议降低温度至26℃');
    }
    else{
        snprintf(suggestion, MAX_BUFFER_SIZE, '空调温度适宜');
    }
}

void generateHumidifierSuggestion(const Status *humidifierStatus, char *suggestion) {
    int humidity = atoi(humidifierStatus->value);
    if (humidity < 40) {
        snprintf(suggestion, MAX_BUFFER_SIZE, '加湿器湿度过低,建议调整加湿器湿度');
    } else if (humidity > 70) {
        snprintf(suggestion, MAX_BUFFER_SIZE, '加湿器湿度过高,建议调整加湿器湿度');
    } else {
        snprintf(suggestion, MAX_BUFFER_SIZE, '加湿器湿度适宜');
    }
}

char* combineSuggestions(const char *suggestion, const char *humidifierSuggestion) {
    int combinedSuggestionSize = strlen(suggestion) + strlen(humidifierSuggestion) + 2;
    char *combinedSuggestion = malloc(combinedSuggestionSize);
    snprintf(combinedSuggestion, combinedSuggestionSize, '%s\n%s', suggestion, humidifierSuggestion);
    return combinedSuggestion;
}

void sendSuggestion(int sockfd, char *suggestion) {
    ssize_t sendSize = send(sockfd, suggestion, strlen(suggestion)+1, 0);
    if (sendSize == -1) {
        perror('发送失败\nsend');
        free(suggestion);
        return;
    } else {
        printf('建议已发送\n');
    }
}

// ... 其他代码 ...

代码功能:

  • 该代码实现了一个简单的智能家居环境建议系统。
  • 服务器端监听客户端连接请求,接收用户ID。
  • 根据用户ID查询数据库获取设备状态信息。
  • 根据空调和加湿器的状态生成相应的建议。
  • 将建议发送给客户端。

代码亮点:

  • 使用Socket编程实现网络通信,支持多客户端连接。
  • 使用SQLite数据库存储设备状态信息,方便数据管理。
  • 根据实际环境状态生成个性化建议,提升用户体验。

未来改进:

  • 可以扩展支持更多类型的设备,例如空气净化器、电灯等。
  • 可以根据用户历史数据和偏好,提供更加精准的建议。
  • 可以开发配套的客户端应用程序,实现更友好的用户界面。
C语言实现基于Socket的智能家居环境建议系统

原文地址: http://www.cveoy.top/t/topic/fDQt 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录