lihongjie/coal
1
0
Fork 0
mirror of https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git synced 2026-01-25 07:46:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

磅房数据归档之后不再同步

Browse Source
This commit is contained in:
lihongjie0209
2024-05-01 20:43:57 +08:00
parent 7f441b2a76
commit 47383a6030
1 changed files with 20 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/cn/lihongjie/coal/dataCollector/listener/WeightListener.java
View File

@@ -204,6 +204,16 @@ public class WeightListener {
flowNumber,
device.getId());
deviceData = flowNumberMap.get(flowNumber);
if (StringUtils.equals(deviceData.getArchiveStatus(), "1")) {
log.info(
"data already archived: {} {} {}",
seqNumber,
flowNumber,
device.getId());
return;
}
deviceData.setInvalid(true);
} else {
@@ -422,6 +432,16 @@ public class WeightListener {
flowNumber,
device.getId());
deviceData = seqNumberMap.get(seqNumber);
if (StringUtils.equals(deviceData.getArchiveStatus(), "1")) {
log.info(
"data already archived: {} {} {}",
seqNumber,
flowNumber,
device.getId());
return;
}
}
// log.info(x.toPrettyString());