目录
一、设备数据库
二、添加设备
三、排序设备
四、重命名设备
五、删除设备
六、移动设备
本项目的交流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的每一个设备只能存放在一个分组内,那我们这边对这个没做限制,用户可以根据自己的需求和习惯,将一个设备放在不同分组内。