智能家居系统数据库设计与实现

1. 数据库表创建

1.1 用户表 (users)

CREATE TABLE IF NOT EXISTS users (
    uid INTEGER PRIMARY KEY AUTOINCREMENT,
    username varchar(10), 
    passwd varchar(10)
);

1.2 智能家居状态表 (Status)

CREATE TABLE IF NOT EXISTS Status (
    sid INTEGER PRIMARY KEY AUTOINCREMENT,
    uid INTEGER ,
    device_name varchar(10),
    device_state varchar(10),
    value varchar(10),
    mode varchar(20),
    FOREIGN KEY (uid) REFERENCES users (uid)
);

2. SQLite 数据库操作代码

#include <QSqlDatabase>
#include <QSqlQuery>
#include <QMessageBox>
#include <QDebug>
#include <QSqlError>
#include "sqlite.h"

Sqlite::Sqlite()
{

}


void Sqlite::sqlite_init()
{
    // 先关闭重复的数据库连接
    if (QSqlDatabase::contains("qt_sql_default_connection")) {
        QSqlDatabase::removeDatabase("qt_sql_default_connection");
    }
    QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
    db.setDatabaseName("../Smarthome_Client/database/database.db");
    if(!db.open())
    {
        qDebug() << "无法打开数据库！";
    }
    else{
        qDebug() << "数据库打开成功！";
    }
}


// 更新智能家居状态表中的数据
void updateSmartHomeStatus(int userId, QString deviceName, QString devicestate,QString newValue)
{
    Sqlite::sqlite_init();
    // 执行更新操作
    QSqlQuery query;
    query.prepare("SELECT * FROM Status WHERE uid = :userId");
     query.bindValue(":userId", userId);
     if (!query.exec()) {
         qDebug() << "查询id失败：" << query.lastError().text();
     }
         QString sql = QString("INSERT INTO Status (uid, device_name, device_state, value) VALUES (%1, \'%2\', \'%3\', \'%4\')")
                 .arg(userId).arg(deviceName).arg(devicestate).arg(newValue);
         query.prepare(sql);
         if (!query.exec()) {
             qDebug() << "插入数据失败：" << query.lastError().text();
             return;
     }
}

bool statusUid(int userId)
{
    Sqlite::sqlite_init();
    QSqlQuery query;
    // 查询智能家居状态表，获取用户对应的状态
    query.prepare("SELECT * FROM status WHERE user_id = :userId");
    query.bindValue(":userId", userId);
    qDebug()<<query.exec();
    if (!query.next()) {
        qDebug() << "Failed to execute query!"<<query.lastError().text();
        return false;
    }else{
        qDebug() << "Successed to execute query!";
        return true;
    }
}

#ifndef USERSWIDGET_H
#define USERSWIDGET_H

#include <QWidget>

namespace Ui {
class UsersWidget;
}

class UsersWidget : public QWidget
{
    Q_OBJECT

public:
    explicit UsersWidget(int userid,QWidget *parent = nullptr);
    ~UsersWidget();
    void displayUsersWidget();
    void loadLastStatus();//加载上一次的状态
    void saveLastStatus(); // 保存当前更改的状态
    QString getLastState(int userid);//得到上一次的状态信息
    void updateLastMode(int userid,QString mode);//更新模式信息

protected:
    void closeEvent(QCloseEvent *);

signals:
    void modeChanged(const QString &mode); // 添加信号

private slots:
    void on_mode_currentIndexChanged(int index);

private:
    Ui::UsersWidget *ui;
    int userid;
    void updateLastDeviceMode(int userId, const QString& deviceName, const QString& mode);
};

#endif // USERSWIDGET_H


#include "userswidget.h"
#include "ui_userswidget.h"
#include "sqlite.h"
#include "lights.h"
#include "aircondition.h"
#include "curtains.h"
#include "humidiffer.h"
#include "information.h"
#include "procession.h"
#include <QSqlQuery>
#include <QCloseEvent>
#include <QComboBox>
#include <QMessageBox>
#include <QSqlError>

UsersWidget::UsersWidget(int userid,QWidget *parent) : 
    QWidget(parent),
    ui(new Ui::UsersWidget),
    userid(userid)
{
    ui->setupUi(this);
    displayUsersWidget();
    connect(ui->lights,&QToolButton::clicked,this,[=]{
        Lights *w = new Lights(userid);
        w->show();});
    connect(ui->air_condition,&QToolButton::clicked,this,[=]{
        AirCondition *w = new AirCondition(userid);
        w->show();});
    connect(ui->curtains,&QToolButton::clicked,this,[=]{
        Curtains *w = new Curtains(userid);
        w->show();});
    connect(ui->humidifiers,&QToolButton::clicked,this,[=]{
        Humidiffer *w = new Humidiffer(userid);
        w->show();});
    connect(ui->tables,&QToolButton::clicked,this,[=]{
        Information *w = new Information;
        w->show();});
    connect(ui->wifi,&QToolButton::clicked,this,[=]{
        Procession *w = new Procession(userid);
        w->show();});
    //模式信号和槽连接
    connect(ui->mode, QOverload<int>::of(&QComboBox::currentIndexChanged),
            this, &UsersWidget::on_mode_currentIndexChanged);
    loadLastStatus();




}

UsersWidget::~UsersWidget()
{
    delete ui;
}

void UsersWidget::displayUsersWidget()
{
    setWindowTitle("智能家居总览图");
    setFixedSize(900,600);

}

void UsersWidget::loadLastStatus()
{
    qDebug()<<this->userid;
    QString state = getLastState(this->userid);
    qDebug()<<state;
    if (state.compare("日常模式") == 0) {
        ui->mode->setCurrentIndex(1);
    } else if (state.compare("睡眠模式") == 0) {
        ui->mode->setCurrentIndex(2);
    } else if (state.compare("节能模式") == 0) {
        ui->mode->setCurrentIndex(3);
    } else {
        ui->mode->setCurrentIndex(0);
    }

}

void UsersWidget::saveLastStatus()
{
    qDebug()<<this->userid;
    QString Mode = ui->mode->currentData().toString();
    updateLastMode(this->userid, Mode);

}

void UsersWidget::on_mode_currentIndexChanged(int mode)
{
    QString modeText;
    switch (mode) {
        case 1:
            modeText = "日常模式";
            break;
        case 2:
            modeText = "睡眠模式";
            break;
        case 3:
            modeText = "节能模式";
            break;
        default:
            return;
    }

    updateLastDeviceMode(userid, "智能灯", modeText);
    updateLastDeviceMode(userid, "空调", modeText);
    updateLastDeviceMode(userid, "窗帘", modeText);
    updateLastDeviceMode(userid, "加湿器", modeText);

    saveLastStatus();
}

QString UsersWidget::getLastState(int userid)
{
    Sqlite::sqlite_init();
    QString queryStr = QString("SELECT mode FROM Status WHERE uid = %1  ORDER BY sid DESC LIMIT 1").arg(userid);
    qDebug()<<queryStr<<userid;
    QSqlQuery query;
    qDebug ()<<query.exec(queryStr);
    if (query.exec(queryStr) && query.next())
    {
        return query.value(0).toString();
    }
    else
    {
        qDebug() << "得到上一次状态错误: " << query.lastError().text();
        return "";
    }
}

void UsersWidget::updateLastMode(int userid,QString mode)
{
    Sqlite::sqlite_init();
    QString queryStr = QString("UPDATE Status SET mode = %1  WHERE uid = %2 ").arg(mode).arg(userid);
    QSqlQuery query;
    if (!query.exec(queryStr))
    {
        qDebug() << "更新模式失败: " << query.lastError().text();
    }
}
void UsersWidget::closeEvent(QCloseEvent *e)
{
    if(e->spontaneous())
    {
    //窗口关闭时弹出的提示窗口
        QMessageBox::StandardButton reply;

        reply = QMessageBox::information(this,"提示","确认退出智能管家系统？",QMessageBox::Yes|QMessageBox::No);
        if(reply == QMessageBox::Yes){
            //若用户点击确认，则接收这个事件,当前窗口会关闭
            e->accept();
         }else{
            //若用户点击取消，则忽略这个事件，当前窗口不会关闭
            e->ignore();
        }
    }
}

void UsersWidget::updateLastDeviceMode(int userId, const QString& deviceName, const QString& mode)
{
    // 执行更新操作
    QSqlQuery query;
    query.prepare("UPDATE Status SET mode = :mode WHERE uid = :userId AND device_name = :deviceName");
    query.bindValue(":mode", mode);
    query.bindValue(":userId", userId);
    query.bindValue(":deviceName", deviceName);
    if (!query.exec()) {
        qDebug() << "更新设备模式失败：" << query.lastError().text();
    }
}

3. 使用说明

用户表存储用户账号信息，包括用户名和密码。
状态表存储智能家居设备的状态信息，包括设备名称、状态、值、模式和用户 ID。
SQLite 数据库操作代码示例展示了如何使用 SQLite 数据库进行数据操作，包括创建数据库连接、执行 SQL 语句、更新数据等。
UsersWidget 类展示了如何使用数据库信息来更新智能家居设备的模式。

4. 总结

本文介绍了智能家居系统数据库设计与实现，包括用户表和状态表的创建，以及使用 SQLite 数据库进行数据操作的代码示例。希望这篇文章能帮助你理解智能家居系统数据库设计的基本原理和实现方法。