diff --git a/CounterAcq/CounterDevice.cpp b/CounterAcq/CounterDevice.cpp index 318dff7..84b0a7a 100644 --- a/CounterAcq/CounterDevice.cpp +++ b/CounterAcq/CounterDevice.cpp @@ -123,17 +123,20 @@ QString delay = SettingConfig::getInstance().DELAY_ARR.at(0).at(i - 1); // 3. 通过UDP发送到本地的Java后端进行存库处理 - QJsonObject jsonObj = counterData->toJSON(i - 1); - jsonObj.insert("deviceId", deviceId); - jsonObj.insert("devCode", devCode); - QJsonObject data = jsonObj.take("data").toObject(); - data.insert("openClock", openClock); - data.insert("closeClock", closeClock); - double value = data.find("dataValue")->toString().toDouble(); - value += delay.toDouble() * 1E-9; - data.insert("dataValue", QString::number(value, 'f', 12)); - jsonObj.insert("data", data); - udpClient->writeDatagram(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)).toLocal8Bit(), QHostAddress(SettingConfig::getInstance().RECV_HOST), SettingConfig::getInstance().RECV_PORT); + if ((counterData->milisecond / 1000) % 60 == 0) + { + QJsonObject jsonObj = counterData->toJSON(i - 1); + jsonObj.insert("deviceId", deviceId); + jsonObj.insert("devCode", devCode); + QJsonObject data = jsonObj.take("data").toObject(); + data.insert("openClock", openClock); + data.insert("closeClock", closeClock); + double value = data.find("dataValue")->toString().toDouble(); + value += delay.toDouble() * 1E-9; + data.insert("dataValue", QString::number(value, 'f', 12)); + jsonObj.insert("data", data); + udpClient->writeDatagram(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)).toLocal8Bit(), QHostAddress(SettingConfig::getInstance().RECV_HOST), SettingConfig::getInstance().RECV_PORT); + } } }