This commit is contained in:
2024-04-18 09:32:06 +08:00
parent 3334705c1c
commit 3c0ada304d

View File

@@ -160,17 +160,17 @@ public class WeightListener {
nodes.forEach(
x -> {
WeightDeviceDataEntity deviceData = new WeightDeviceDataEntity();
var flowNumber = x.get("流水号").asText();
if (flowNumberMap.containsKey(flowNumber)) {
log.info("data already exists: {} {}", flowNumber, device.getId());
return;
deviceData = flowNumberMap.get(flowNumber);
}
// log.info(x.toPrettyString());
// log.info(x.toPrettyString());
WeightDeviceDataEntity deviceData = new WeightDeviceDataEntity();
deviceData.setDevice(device);
deviceData.setOrganizationId(device.getOrganizationId());
deviceData.setSequenceNumber(toInteger(x.get("序号")));
deviceData.setFlowNumber(toString(x.get("流水号")));
deviceData.setPlateNo(toString(x.get("车号")));