目录
一、设备数据库
二、添加设备
三、排序设备
四、重命名设备
五、删除设备
六、移动设备
本项目的交流QQ群:701889554
物联网实战--入门篇https://blog.csdn.net/ypp240124016/category_12609773.html
物联网实战--驱动篇https://blog.csdn.net/ypp240124016/category_12631333.html
一、设备数据库
上图是设备管理数据库,跟分组管理同一个数据库,库表为设备表device_tb,放在不同的应用下,内容主要是设备sn,父设备sn和设备名称,对于跟mqtt服务器直连的设备,父设备sn为0;对于节点设备,它所在的网关就是它的父设备,这在设备组网的时候经常会用到。下面是数据库的主要代码:
bool GroupSqlite::createDeviceTable(void)
{
QString str_query = QString::asprintf("CREATE TABLE If Not Exists device_tb ("
"devSn bigint NOT NULL,"
"devStr varchar(20) NOT NULL,"
"parentSn bigint DEFAULT 0,"
"parentStr varchar(20) DEFAULT 0,"
"devName varchar(10000) DEFAULT 0,"
"createTime timestamp DEFAULT (datetime(\'now\',\'localtime\')),"
"PRIMARY KEY (devSn)"
")"
);
// qDebug()<<"str_query= "<<str_query;
if(runSqlQuery(str_query)==false)
{
qDebug()<<"createDeviceTable error";
return false;
}
else
{
qDebug()<<"createDeviceTable ok: ";
}
return true;
}
bool GroupSqlite::insertDeviceNode(u32 devSn, u32 parentSn)
{
QString dev_str=QString::asprintf("%08X", devSn);
QString parent_str=QString::asprintf("%08X", parentSn);
QString str_query = QString::asprintf("INSERT INTO device_tb (devSn, parentSn, devStr, parentStr) VALUES ( %u, %u, \"%s\", \"%s\")",
devSn, parentSn, dev_str.toLatin1().data(), parent_str.toLatin1().data());
// qDebug()<<str_query;
if( runSqlQuery(str_query))
{
qDebug("insertDeviceNode ok 001!");
return true;
}
else
{
createDeviceTable();
if( runSqlQuery(str_query))
{
qDebug("insertDeviceNode ok 002!");
return true;
}
}
return false;
}
bool GroupSqlite::updateDeviceName(u32 devSn, QString devName)
{
QString str_query = QString::asprintf("UPDATE device_tb SET devName=\"%s\" WHERE devSn=%u",
devName.toUtf8().data(), devSn);
// qDebug()<<str_query;
if( runSqlQuery(str_query))
{
qDebug("updateDeviceName ok!");
return true;
}
return false;
}
bool GroupSqlite::updateDeviceParentSn(u32 devSn, u32 parentSn)
{
QString parent_str=QString::asprintf("%08X", parentSn);
QString str_query = QString::asprintf("UPDATE device_tb SET parentSn=%u, parentStr=\"%s\" WHERE devSn=%u",
parentSn, parent_str.toLatin1().data(),devSn);
// qDebug()<<str_query;
if( runSqlQuery(str_query))
{
qDebug("updateDeviceParentSn ok!");
return true;
}
return false;
}
bool GroupSqlite::selectDeviceNode(u32 devSn, DeviceNodeStruct &workNode)
{
QString str_query = QString::asprintf("SELECT devSn, parentSn, devName, createTime FROM device_tb WHERE devSn=%u" ,
devSn);
// qDebug()<<str_query;
if(runSqlQuery(str_query)==false)
{
qDebug("selectDeviceNode error_01!");
return false;
}
while(m_sqlQuery.next())
{
int ptr=0;
workNode.devSn=m_sqlQuery.value(ptr++).toUInt();
workNode.parentSn=m_sqlQuery.value(ptr++).toUInt();
workNode.devName=m_sqlQuery.value(ptr++).toString();
workNode.createTime=m_sqlQuery.value(ptr++).toString();
break;
}
m_sqlQuery.finish();
return true;
}
bool GroupSqlite::selectDeviceList(QList<DeviceNodeStruct> &workList)
{
QString str_query = QString::asprintf("SELECT devSn, parentSn, devName, createTime FROM device_tb");
// qDebug()<<str_query;
if(runSqlQuery(str_query)==false)
{
qDebug("selectDeviceList error_01!");
return false;
}
while(m_sqlQuery.next())
{
int ptr=0;
DeviceNodeStruct workNode;
workNode.devSn=m_sqlQuery.value(ptr++).toUInt();
workNode.parentSn=m_sqlQuery.value(ptr++).toUInt();
workNode.devName=m_sqlQuery.value(ptr++).toString();
workNode.createTime=m_sqlQuery.value(ptr++).toString();
workList.append(workNode);
}
m_sqlQuery.finish();
return true;
}
bool GroupSqlite::delDeviceNode(u32 devSn)
{
QString str_query = QString::asprintf("DELETE FROM device_tb WHERE devSn=%u", devSn);
// qDebug()<<str_query;
if( runSqlQuery(str_query))
{
qDebug("delDeviceNode ok!");
return true;
}
return false;
}
二、添加设备
添加设备一般是由用户发起的,主要通过扫码或者手动输入SN,跟设备联动完成添加,在这里因为扫码这块后续要单独讲解,而且还没有设备可以联动配合,所以我们先程序内部直接添加,其用户端APP添加函数如下:
void CenterMan::requestAddDevice(u32 dev_sn, u32 parent_sn)
{
QJsonObject root_obj;
QJsonDocument json_doc;
root_obj.insert("account", m_loginAccount);
root_obj.insert("rand_num", m_randNum);
root_obj.insert("mac", m_macStr);
root_obj.insert("cmd_type", "add_dev");
root_obj.insert("app_id", (qint64)m_currAppWork.appID);
root_obj.insert("dev_sn", (qint64)dev_sn);
root_obj.insert("parent_sn", (qint64)parent_sn);
json_doc.setObject(root_obj);
QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);
QString topic=makePubTopic("device");
emit sigMqttPushMessage(topic, msg_ba);
}
在定时器里每秒添加一个,添加10个为止,这里的序列号是0xA1010001~0xA101000A十个,其中A101代表型号,这是自定义,我这里就是定义为一种净化器设备,0001~000A就是地址码了,至于这个设备的具体定义,实际上是一个物模型,包含C++文件和QML文件,这个后面跟硬件结合起来要单独讲解,在这里也先保留,只展示一些文件信息,了解结构:
由上图可知,在手机APP项目里,我们对物模型进行了单独的定义和存放,modelCpp和modelQml分别存放后端程序和前端代码,这样,在手机APP的主体结构完成后,对于要增加新的硬件产品,只需要对应增加物模型的代码就行了,其它不变,这也是物联网 端到端开发的核心所在。
在服务器后台,接收到请求后会将设备添加到数据库,并返回反馈信息。
else if(cmd_type=="add_dev")
{
u32 dev_sn=0, parent_sn=0;
if(root_obj.contains("dev_sn"))
{
QJsonValue value = root_obj.value("dev_sn");
dev_sn=value.toDouble();
}
if(root_obj.contains("parent_sn"))
{
QJsonValue value = root_obj.value("parent_sn");
parent_sn=value.toDouble();
}
tag_groupSqlite.insertDeviceNode(dev_sn, parent_sn);//添加设备到数据库
ack_str=QString::asprintf("设备%08X 添加成功!", dev_sn);
ackAddDevice(account, mac_str, rand_num, app_id, dev_sn, parent_sn, result, ack_str);
}
用户端收到后将新设备添加到工作列表和"全部"分组,这样一个完整的添加流程就完成了。
else if(cmd_type=="add_dev")//新增设备
{
u32 dev_sn=root_obj.value("dev_sn").toDouble();
u32 parent_sn=root_obj.value("parent_sn").toDouble();
addWorkDevice(dev_sn, parent_sn, "");//添加到工作列表
emit siqAddDevice2Group("全部", dev_sn);//添加到全部分组
}
三、排序设备
用户在界面调整每个分组设备的顺序后,需要发送到后台服务器进行更新,以下的请求代码和后台更新代码:
void CenterMan::requestSortDevice(QString group_name, QList<qint64> dev_list)
{
QJsonArray dev_array;
QJsonObject root_obj;
QJsonDocument json_doc;
qDebug()<<"group_name="<<group_name;
qDebug()<<"dev_list="<<dev_list;
int nSize=dev_list.size();
for(int i=0; i<nSize; i++)
{
u32 dev_sn=dev_list.at(i);
if(dev_sn>0)
{
dev_array.append((qint64)dev_sn);
}
}
root_obj.insert("account", m_loginAccount);
root_obj.insert("rand_num", m_randNum);
root_obj.insert("mac", m_macStr);
root_obj.insert("app_id", (qint64)m_currAppWork.appID);
root_obj.insert("group_name", group_name);
root_obj.insert("dev_list", dev_array);
root_obj.insert("cmd_type", "sort_dev");
json_doc.setObject(root_obj);
QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);
QString topic=makePubTopic("device");
emit sigMqttPushMessage(topic, msg_ba);
}
if(cmd_type=="sort_dev")
{
QString group_name="";
if(root_obj.contains("group_name"))
{
QJsonValue value = root_obj.value("group_name");
group_name=value.toString();
}
QJsonArray dev_array;
QList<u32>dev_list;
if(root_obj.contains("dev_list"))
{
QJsonValue value = root_obj.value("dev_list");
dev_array=value.toArray();
}
int nSize=dev_array.size();
for(int i=0; i<nSize; i++)
{
u32 dev_sn=dev_array.at(i).toDouble();
dev_list.append((qint64)dev_sn);
}
tag_groupSqlite.updateDevList(group_name, dev_list);//更新数据库
ack_str="排序成功!";
ackSortDevice(account, mac_str, rand_num, app_id, group_name, dev_array, result, ack_str);
}
排序完成后会返回到用户端,以下是用户端代码,主要是更新该分组在前端显示的顺序,完成最终的排序任务。
else if(cmd_type=="sort_dev")//重新排序分组内的设备
{
QString group_name="";
if(root_obj.contains("group_name"))
{
QJsonValue value = root_obj.value("group_name");
group_name=value.toString();
}
GroupNodeStruct *pGroupNode=searchGroupNode(group_name);
if(pGroupNode)//更新分组内的设备
{
QJsonArray dev_array;
if(root_obj.contains("dev_list"))
{
QJsonValue value = root_obj.value("dev_list");
dev_array=value.toArray();
}
emit siqClearDevice(group_name);
pGroupNode->devList.clear();
int nSize=dev_array.size();
for(int i=0; i<nSize; i++)
{
u32 dev_sn=dev_array.at(i).toDouble();
pGroupNode->devList.append(dev_sn);
emit siqAddDevice2Group(group_name, dev_sn);//添加设备到分组
}
emit siqUpdateGroupTotalNum(group_name, pGroupNode->devList.size());//更新设备数量
}
}
四、重命名设备
设备重命名流程与分组重命名类似,首先是用户端请求,服务器更新返回,最后用户端更新显示,下面是请求代码,
void CenterMan::requestRenameDevice(u32 dev_sn, QString new_name)
{
QJsonObject root_obj;
QJsonDocument json_doc;
root_obj.insert("account", m_loginAccount);
root_obj.insert("rand_num", m_randNum);
root_obj.insert("mac", m_macStr);
root_obj.insert("cmd_type", "rename_dev");
root_obj.insert("app_id", (qint64)m_currAppWork.appID);
root_obj.insert("dev_sn", (qint64)dev_sn);
root_obj.insert("new_name", new_name);
json_doc.setObject(root_obj);
QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);
QString topic=makePubTopic("device");
emit sigMqttPushMessage(topic, msg_ba);
}
服务器更新数据库设备名称:
else if(cmd_type=="rename_dev")
{
u32 dev_sn=0;
if(root_obj.contains("dev_sn"))
{
QJsonValue value = root_obj.value("dev_sn");
dev_sn=value.toDouble();
}
QString new_name;
if(root_obj.contains("new_name"))
{
QJsonValue value = root_obj.value("new_name");
new_name=value.toString();
}
if(dev_sn>0 &&!new_name.isEmpty())
{
tag_groupSqlite.updateDeviceName(dev_sn, new_name);
ack_str="重命名成功!";
}
else
{
ack_str="重命名失败!";
result=1;
}
ackRenameDevice(account, mac_str, rand_num, app_id, dev_sn, new_name, result, ack_str);
}
用户端更新前端显示:
else if(cmd_type=="rename_dev")//重命名设备
{
u32 dev_sn=root_obj.value("dev_sn").toDouble();
QString new_name=root_obj.value("new_name").toString();
updateWorkName(dev_sn, new_name);//更新设备名称
}
五、删除设备
删除设备可以是多个的,所以参数是一个设备列表:
void CenterMan::requestDelDevice(QList<qint64> dev_list)
{
QJsonArray dev_array;
QJsonObject root_obj;
QJsonDocument json_doc;
qDebug()<<"del dev_list="<<dev_list;
int nSize=dev_list.size();
for(int i=0; i<nSize; i++)
{
u32 dev_sn=dev_list.at(i);
if(dev_sn>0)
{
dev_array.append((qint64)dev_sn);
}
}
root_obj.insert("account", m_loginAccount);
root_obj.insert("rand_num", m_randNum);
root_obj.insert("mac", m_macStr);
root_obj.insert("app_id", (qint64)m_currAppWork.appID);
root_obj.insert("dev_list", dev_array);
root_obj.insert("cmd_type", "del_dev");
json_doc.setObject(root_obj);
QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);
QString topic=makePubTopic("device");
emit sigMqttPushMessage(topic, msg_ba);
}
服务器解析后从数据库中一个个删除设备:
else if(cmd_type=="del_dev")
{
QJsonArray dev_array;
if(root_obj.contains("dev_list"))
{
QJsonValue value = root_obj.value("dev_list");
dev_array=value.toArray();
}
int nSize=dev_array.size();
for(int i=0; i<nSize; i++)
{
u32 dev_sn=dev_array.at(i).toDouble();
tag_groupSqlite.delDeviceNode(dev_sn);//删除设备
}
ack_str="删除成功!";
ackDelDevice(account, mac_str, rand_num, app_id, dev_array, result, ack_str);
}
用户端也要删除对应的前端显示,在删除最后一个后,需要重新排序设备,这样才能更新服务器内的分组信息。
else if(cmd_type=="del_dev")//移除设备
{
QJsonArray dev_array;
if(root_obj.contains("dev_list"))
{
QJsonValue value = root_obj.value("dev_list");
dev_array=value.toArray();
}
int nSize=dev_array.size();
for(int i=0; i<nSize; i++)
{
u32 dev_sn=dev_array.at(i).toDouble();
delWorkDevice(dev_sn);//删除工作设备
emit siqDelDevice(dev_sn, i==nSize-1);//删除显示设备
}
}
六、移动设备
移动设备相对来讲是比较复杂的,首先有两个分组,一个是源分组,就是设备要移出的分组;另一个是目标分组,就是设备要移到的分组,设备是多个的。所以,对于源分组,我们要删除要移出的设备,这里排除“全部”这个分组;对于目标分组,我们要新增移出来的设备,这里对于重复的设备要检查,各自任务完成后就是请求重新排序就可以了,具体代码如下:
void CenterMan::requestMoveDevice(QString src_group, QString dst_group, QList<qint64> dev_list)
{
GroupNodeStruct *pGroupNodeSrc=searchGroupNode(src_group);
GroupNodeStruct *pGroupNodeDst=searchGroupNode(dst_group);
int nSize=dev_list.size();
if(pGroupNodeSrc==nullptr || pGroupNodeDst==nullptr || nSize<=0)
return;
qDebug()<<"move src_group="<<src_group;
qDebug()<<"move dst_group="<<dst_group;
qDebug()<<"move dev_list="<<dev_list;
qDebug()<<"src dev list="<<pGroupNodeSrc->devList;
qDebug()<<"dst dev list="<<pGroupNodeDst->devList;
if(src_group!="全部")
{
for(auto iter : dev_list)//先移除源分组设备
{
qDebug()<<"will remove dev sn="<<iter<<", dev_list="<<pGroupNodeSrc->devList;
for(int i=0; i<pGroupNodeSrc->devList.size(); i++)
{
if(iter==pGroupNodeSrc->devList.at(i))
{
qDebug()<<"remove dev_sn="<<iter;
pGroupNodeSrc->devList.removeAt(i);
break;
}
}
}
requestSortDevice(src_group, pGroupNodeSrc->devList);//重新排序
}
if(dst_group!="全部")
{
for(auto iter : dev_list)//添加到目标分组
{
bool flag=false;
for(int i=0; i<pGroupNodeDst->devList.size(); i++)
{
if(iter==pGroupNodeDst->devList.at(i))//重复,不能添加
{
flag=true;
break;
}
}
if(flag==false)
{
pGroupNodeDst->devList.append(iter);
}
}
requestSortDevice(dst_group, pGroupNodeDst->devList);//重新排序
}
}
这里有几点需要提一下,首先,"全部"分组是比较特殊的,它是包含所有设备的,所以设备从"全部"分组移出后自身不会删除;反过来,如果其它分组的设备想移除,但不是删除,那么可以将设备 移动到"全部"分组即可。另外一点,米家APP的每一个设备只能存放在一个分组内,那我们这边对这个没做限制,用户可以根据自己的需求和习惯,将一个设备放在不同分组内。