zhangsheng/WLG
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
WLG/localserver/web_cmd.cpp

445 lines
21 KiB
C++
Raw Normal View History

modify file name and separate files.
2024-10-22 19:04:25 +08:00
#include "local_server.hpp"
fix build bugs.
2024-10-24 16:01:21 +08:00
#include <unistd.h>
#include <boost/lexical_cast.hpp>
modify file name and separate files.
2024-10-22 19:04:25 +08:00
#include <json/json.h>
add log info
2024-10-23 19:51:01 +08:00
#include <zlog.h>
modify file name and separate files.
2024-10-22 19:04:25 +08:00
fix build bugs.
2024-10-24 16:01:21 +08:00
#include "mqttclient/mqtt_client.h"
#include "common/global.hpp"
#include "common/parameter_defination.hpp"
#include "dbaccess/sql_db.hpp"
#include "common/common_func.hpp"
#include "jsonparse/communication_cmd.hpp"
extern zlog_category_t *zct;
modify file name and separate files.
2024-10-22 19:04:25 +08:00
std::string LocalServer::HandleCgi_cmd(std::string &pData) {
try {
add log info
2024-10-23 19:51:01 +08:00
zlog_info(zct,"HandleCgi Data = %s ", pData.c_str());
modify file name and separate files.
2024-10-22 19:04:25 +08:00
Json::Features f = Json::Features::strictMode();
Json::Reader recvReader(f);
Json::Value recvValue;
Json::Value recvBody;
if (recvReader.parse(pData, recvValue)) {
int cmdType = atoi(recvValue["cmd"].asString().c_str());
std::string cmdBody = "";
if (!recvValue["cmdBody"].isNull()) {
recvBody = recvValue["cmdBody"];
Json::FastWriter fw;
cmdBody = fw.write(recvBody);
}
switch (cmdType) {
case kLoginUpdateAccount: {
Param_01 param;
std::string type = recvBody["type"].asString();
if (0 == type.compare("login")) {
param.mMode = 0;
param.mUserName = recvBody["userName"].asString();
param.mPassWord = recvBody["passWord"].asString();
} else if (0 == type.compare("upDate")) {
param.mMode = 1;
param.mUserName = recvBody["userName"].asString();
param.mPassWord = recvBody["passWord"].asString();
param.mPassWordNew = recvBody["passWordNew"].asString();
} else {
// TODO: add error log here
}
JsonData jd;
std::string data = jd.JsonCmd_Cgi_01(param);
return data;
} break;
添加任务调用流程
2024-10-31 19:30:10 +08:00
// case kWebTiming: {
// Param_02 param;
// std::string type = recvBody["type"].asString();
// if (0 == type.compare("SET")) {
// param.mMode = 0;
// param.mTimeStamp = recvBody["timeStamp"].asInt();
// param.mSetType = recvBody["setType"].asInt();
// } else if (0 == type.compare("GET")) {
// param.mMode = 1;
// }
// JsonData jd;
// std::string data = jd.JsonCmd_Cgi_02(param);
// return data;
// } break;
modify file name and separate files.
2024-10-22 19:04:25 +08:00
case kWebHWStatus: {
JsonData jd;
std::string data = jd.JsonCmd_Cgi_07();
return data;
} break;
case kWebRebootSystem: {
JsonData jd;
std::string data = jd.JsonCmd_Cgi_08();
system("sync");
sleep(3);
system("reboot");
return data;
} break;
case kGetFeatureData: {
JsonData jd;
Param_09 param;
param.mPackageFlag = recvBody["package"].asInt();
std::string data = jd.JsonCmd_Cgi_09(param);
return data;
} break;
case kGetHistoryFeatureData: {
JsonData jd;
Param_10 param;
param.strDataNode = recvBody["DataNode"].asString();
param.strStatic = recvBody["Static"].asString();
param.straxis = recvBody["Raxis"].asString();
param.mPackageFlag = recvBody["package"].asInt();
param.timeStart = recvBody["timeStart"].asString();
param.timeEnd = recvBody["timeEnd"].asString();
param.MeasurementID = recvBody["MeasurementID"].asString();
std::string data = jd.JsonCmd_Cgi_10(param);
return data;
} break;
case kWebModifyProperty: {
Param_20 param;
std::string type = recvBody["type"].asString();
if (0 == type.compare("SET")) {
param.mMode = 0;
param.mDataWatchName = recvBody["SystemInfo"]["dataNodeGatewayName"].asString();
param.mDataWatchAssetId = recvBody["SystemInfo"]["dataNodeGatewayAssetId"].asString();
param.mDataWatchAddedBy = recvBody["SystemInfo"]["dataNodeGatewayAddedBy"].asString();
} else {
param.mMode = 1;
}
JsonData jd;
std::string data = jd.JsonCmd_Cgi_20(param);
return data;
} break;
case kWebTimeZone: {
Param_22 param;
std::string type = recvBody["type"].asString();
param.mCmdSerial = recvValue["cmdSerial"].asString();
if (0 == type.compare("SET")) {
param.mMode = 0;
param.mTimeZone = recvBody["SystemSettings"]["timezone"].asString();
ZoneConfig(param.mTimeZone);
} else {
param.mMode = 1;
}
JsonData jd;
std::string data = jd.JsonCmd_Cgi_22(param);
return data;
} break;
case kWebMqttBrokerCfg: {
std::string type = recvBody["type"].asString();
Param_23 param;
param.mCmdSerial = recvValue["cmdSerial"].asString();
if (0 == type.compare("SET")) {
param.mMode = 0;
param.mServerIp = recvBody["SystemSettings"]["ServerIpAddress"].asString();
param.mPort = boost::lexical_cast<std::string>(recvBody["SystemSettings"]["ServerPort"].asInt());
param.mCommMode = recvBody["SystemSettings"]["CommMode"].asString();
param.mUserName = recvBody["SystemSettings"]["UserName"].asString();
param.mPassword = recvBody["SystemSettings"]["Password"].asString();
param.mAPN = recvBody["SystemSettings"]["APN"].asString();
} else {
param.mMode = 1;
}
JsonData jd;
std::string data = jd.JsonCmd_Cgi_23(param);
return data;
} break;
case kWebNetworkCfg: {
Param_25 param;
std::string type = recvBody["type"].asString();
if (0 == type.compare("SET")) {
param.mNet = recvBody["net"].asString();
param.mDnsName = recvBody["dnsName"].asString();
param.mGateway = recvBody["gateway"].asString();
param.mHostName = recvBody["hostName"].asString();
param.mIp = recvBody["dataWatchIpAddress"].asString();
param.mSubnetMask = recvBody["subnetMask"].asString();
param.mNetworkPortStatus = recvBody["networkPortStatus"].asString();
param.mMode = 0;
} else {
param.mMode = 1;
}
JsonData jd;
std::string data = jd.JsonCmd_Cgi_25(param);
return data;
} break;
case kWebGetTransducerInfo: {
JsonData jd;
Param_26 param;
param.mPackageFlag = recvBody["package"].asInt();
std::string data = jd.JsonCmd_Cgi_26(param);
return data;
} break;
case kWebDeleteTransducerInfo: {
Param_27 param;
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
param.mType = recvBody["type"].asString();
JsonData jd;
std::string data = jd.JsonCmd_Cgi_27(param);
return data;
} break;
case kUpdateTransducerName: {
Param_28 param;
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
param.mDataNodeName = recvBody["dataNodeName"].asString();
JsonData jd;
std::string data = jd.JsonCmd_Cgi_28(param);
return data;
} break;
case kGetTimeDomainWave: {
JsonData jd;
Param_29 param;
param.mChannelId = recvBody["channelId"].asString();
param.mPackageFlag = recvBody["package"].asInt();
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
std::string data = jd.JsonCmd_Cgi_29(param);
return data;
} break;
case kGetFreqDomainWave: {
JsonData jd;
Param_30 param;
param.mChannelId = recvBody["channelId"].asString();
param.mPackageFlag = recvBody["package"].asInt();
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
std::string data = jd.JsonCmd_Cgi_30(param);
return data;
} break;
case kConfigZigbee: {
JsonData jd;
Param_31 param;
std::string data;
std::string type = recvBody["type"].asString();
if (0 == type.compare("SET")) {
param.mMode = 0;
param.mChannelId = recvBody["channel"].asString();
param.mPanID = recvBody["PanID"].asString();
data = jd.JsonCmd_Cgi_31(param);
sleep(1);
system("reboot");
} else {
param.mMode = 1;
data = jd.JsonCmd_Cgi_31(param);
}
return data;
} break;
case kGetEnvolop: {
JsonData jd;
Param_40 param;
param.mChannelId = recvBody["channelId"].asString();
param.mPackageFlag = recvBody["package"].asInt();
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
param.StartFrequency = recvBody["StartFrequency"].asInt();
param.EndFrequency = recvBody["EndFrequency"].asInt();
std::string data = jd.JsonCmd_Cgi_40(param);
return data;
} break;
case kModifyTransducerConfig: {
JsonData jd;
Param_41 param;
std::vector<Param_41> param41;
fix build bugs.
2024-10-24 16:01:21 +08:00
for (size_t i = 0; i < recvBody.size(); i++) {
modify file name and separate files.
2024-10-22 19:04:25 +08:00
param.mdataNodeNo = recvBody[i]["dataNodeNo"].asString();
param.mfeatureInterVal = recvBody[i]["featureInterVal"].asInt();
param.mwaveInterVal = recvBody[i]["waveInterVal"].asInt();
param.msamplingRate = recvBody[i]["samplingRate"].asInt();
param.mrange = recvBody[i]["range"].asInt();
param.mAccSampleTime = recvBody[i]["ACCSampleTime"].asInt();
param.mstartBrands = recvBody[i]["startBrands"].asString();
param.mstopBrands = recvBody[i]["stopBrands"].asString();
param.menvelopeBandPass = recvBody[i]["envelopeBandPass"].asString();
param.mviff = recvBody[i]["viff"].asInt();
param.mfaultFrequency = recvBody[i]["faultFrequency"].asString();
param.mdataNodeName = recvBody[i]["dataNodeName"].asString();
param.ZigbeePower = recvBody[i]["ZigbeePower"].asInt();
param.ZigbeeRetry = recvBody[i]["ZigbeeRetry"].asInt();
param.mMeasurementID = recvBody[i]["MeasurementID"].asString();
param.nodeWaveSend = recvBody[i]["nodeWaveSend"].asString();
fix upgrade sensor bugs
2024-11-09 16:15:39 +08:00
param.mShortAddr = recvBody[i]["shortAddr"].asString();
modify file name and separate files.
2024-10-22 19:04:25 +08:00
param41.push_back(param);
}
std::string data = jd.JsonCmd_Cgi_41(param41);
char whereCon[64] = {0};
sprintf(whereCon, " UpdateFlag <> 1 ");
modify structure.
2024-10-22 20:56:21 +08:00
std::string strData = sqlite_db_ctrl::instance().GetNodeConfigureInfor(whereCon);
modify file name and separate files.
2024-10-22 19:04:25 +08:00
data_publish(strData.c_str(), GlobalConfig::Topic_G.mPubConfig.c_str());
return data;
} break;
case kWebUpgrade: {
JsonData jd;
Param_42 param;
param.fileName = recvBody["fileName"].asString();
std::string data = jd.JsonCmd_Cgi_42(param);
return data;
} break;
case kGetAllVersionInfo: {
JsonData jd;
std::string data = jd.JsonCmd_Cgi_50();
return data;
} break;
case kUpdateInstallPosition: {
JsonData jd;
Param_51 param;
std::string type = recvBody["type"].asString();
if (0 == type.compare("SET")) {
param.mMode = 0;
param.strGateWayMAC = recvBody["gateWayNo"].asString();
param.strGateWayLocation = recvBody["gateWayLocation"].asString();
} else {
param.mMode = 1;
}
std::string data = jd.JsonCmd_Cgi_51(param);
return data;
} break;
case kWifiOperation: {
Param_52 param;
param.mCmdSerial = recvValue["cmdSerial"].asString();
std::string type = recvBody["type"].asString();
if (0 == type.compare("SCAN")) {
param.mMode = 0;
} else if (0 == type.compare("SET")) {
param.mMode = 1;
param.mSsid = recvBody["ssid"].asString();
param.mPassWord = recvBody["password"].asString();
} else if (0 == type.compare("GET")) {
param.mMode = 2;
} else if (0 == type.compare("CLEAN")) {
param.mMode = 3;
} else {
// TODO: add error log
}
JsonData jd;
std::string data = jd.JsonCmd_Cgi_52(param);
return data;
} break;
case kUpdateFreqBandEnergyConfig: {
JsonData jd;
Param_53 param;
std::vector<Param_53> param53;
fix build bugs.
2024-10-24 16:01:21 +08:00
for (size_t i = 0; i < recvBody.size(); i++) {
modify file name and separate files.
2024-10-22 19:04:25 +08:00
param.mdataNodeNo = recvBody[i]["dataNodeNo"].asString();
param.mUpdateKey = recvBody[i]["updateKey"].asString();
param.mUpdateValue = recvBody[i]["updateValue"].asString();
param.mUpdateKey2 = recvBody[i]["updateKey2"].asString();
param.mUpdateValue2 = recvBody[i]["updateValue2"].asString();
param.mUpdateKey3 = recvBody[i]["updateKey3"].asString();
param.mUpdateValue3 = recvBody[i]["updateValue3"].asString();
param53.push_back(param);
}
std::string data = jd.JsonCmd_Cgi_53(param53);
char whereCon[64] = {0};
sprintf(whereCon, "UpdateFlag <> 0 ");
fix build bugs.
2024-10-24 16:01:21 +08:00
std::string strData = sqlite_db_ctrl::instance().GetNodeConfigureInfor(whereCon);
modify file name and separate files.
2024-10-22 19:04:25 +08:00
data_publish(strData.c_str(), GlobalConfig::Topic_G.mPubConfig.c_str());
return data;
} break;
case kBackupGatewayInfo: {
JsonData jd;
Param_54 param;
param.mPackageFlag = recvBody["package"].asInt();
std::string data = jd.JsonCmd_Cgi_54(param);
return data;
} break;
case kVelocityTimeDomain: {
JsonData jd;
Param_55 param;
param.mChannelId = recvBody["channelId"].asString();
param.mPackageFlag = recvBody["package"].asInt();
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
std::string data = jd.JsonCmd_Cgi_55(param);
return data;
} break;
case kVelocityFreqDomain: {
JsonData jd;
Param_56 param;
param.mChannelId = recvBody["channelId"].asString();
param.mPackageFlag = recvBody["package"].asInt();
param.mDataNodeNo = recvBody["dataNodeNo"].asString();
std::string data = jd.JsonCmd_Cgi_56(param);
return data;
}
case kEnableZigbeePower: {
JsonData jd;
Param_57 param;
param.mZigbeePowerEnable = recvBody["ZigbeePowerEnable"].asInt();
std::string type = recvBody["type"].asString();
if (0 == type.compare("SET")) {
param.mMode = 1;
}
if (0 == type.compare("GET")) {
param.mMode = 0;
}
std::string data = jd.JsonCmd_Cgi_57(param);
return data;
} break;
添加web接口，优化与传感器调用逻辑
2024-11-04 21:35:50 +08:00
case kSchedulingConfiguration:{
JsonData jd;
Param_58 param;
优化特征值时间戳
2024-11-06 10:59:22 +08:00
std::string type = recvBody["type"].asString();
if (0 == type.compare("SET")) {
param.mMode = 1;
}
if (0 == type.compare("GET")) {
param.mMode = 0;
}
添加web接口，优化与传感器调用逻辑
2024-11-04 21:35:50 +08:00
param.featureInterVal = recvBody["featureInterVal"].asInt();
param.featureInterTime = recvBody["featureInterTime"].asInt();
param.waveInterVal = recvBody["waveInterVal"].asInt();
param.waveInterTime = recvBody["waveInterTime"].asInt();
param.maxSensorNum = recvBody["maxSensorNum"].asInt();
std::string data = jd.JsonCmd_Cgi_58(param);
return data;
}break;
case kLostRecords:{
JsonData jd;
Param_59 param;
param.mMode = recvBody["type"].asInt();
param.DataNodeNo = recvBody["DataNodeNo"].asString();
优化特征值时间戳
2024-11-06 10:59:22 +08:00
param.straxis = recvBody["Raxis"].asString();
添加web接口，优化与传感器调用逻辑
2024-11-04 21:35:50 +08:00
std::string data = jd.JsonCmd_Cgi_59(param);
return data;
}break;
add web
2024-11-08 09:17:35 +08:00
case kTransducerUpgrade:{
JsonData jd;
Param_60 param;
param.fileName = recvBody["fileName"].asString();
param.product = recvBody["product"].asInt();
fix upgrade sensor bugs
2024-11-09 16:15:39 +08:00
param.mShortAddr = recvBody["shortAddr"].asString();
add web
2024-11-08 09:17:35 +08:00
Json::Value recvDataNodeNo = recvBody["DataNodeNo"];
if (recvDataNodeNo.size() > 0)
{
for (size_t i = 0; i < recvDataNodeNo.size(); i++) {
param.dataNodeNo.push_back(recvDataNodeNo[i].asString());
}
}
std::string data = jd.JsonCmd_Cgi_60(param);
return data;
}break;
fix upgrade sensor bugs
2024-11-09 16:15:39 +08:00
case kWaveRecords:{
JsonData jd;
Param_61 param;
param.straxis = recvBody["Raxis"].asString();
std::string data = jd.JsonCmd_Cgi_61(param);
return data;
}break;
modify file name and separate files.
2024-10-22 19:04:25 +08:00
default:
JsonData jd;
std::string data = jd.JsonCmd_Cgi_default();
return data;
break;
}
}
} catch (...) {
Json::Value jsVal;
jsVal["success"] = false;
jsVal["message"] = "未知错误";
Json::FastWriter fw;
return fw.write(jsVal);
}
fix build bugs.
2024-10-24 16:01:21 +08:00
zlog_error(zct, "invalid command");
return "";
modify file name and separate files.
2024-10-22 19:04:25 +08:00
}
Reference in New Issue Copy Permalink