wol/radar
1
0
Fork 0
mirror of https://gitee.com/freshday/radar.git synced 2025-12-26 07:16:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

buf fix.

Browse Source 
feihu.wang
This commit is contained in:
feihu.wang 2022-11-27 12:01:18 +08:00
parent ab0b2aae9a
commit 5e688da639
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
radar-service-impl/src/main/java/com/pgmmers/radar/service/impl/engine/AggregateCommandImpl.java
View File

@ -30,6 +30,7 @@ public class AggregateCommandImpl implements AggregateCommand {
return count(modelId, searchField, searchFieldValue, refDateName,"1", begin, end);
}
@Override
public long count(String modelId, String searchField, Object searchFieldValue, String refDateName, String status, Date begin,
Date end) {
String collectionName = "entity_" + modelId;

4
radar-service-impl/src/main/java/com/pgmmers/radar/service/impl/model/EntityServiceImpl.java
View File

@ -55,7 +55,7 @@ public class EntityServiceImpl implements EntityService {
Document filter = new Document();
filter.append(model.getEntryName(), eventId);
Document updateDoc = new Document();
updateDoc.append("status",status);
updateDoc.append("status", status);
String collectionName = buildCollectionName(modelId);
return mongoService.update(collectionName, filter, updateDoc);
}
@ -68,7 +68,7 @@ public class EntityServiceImpl implements EntityService {
Document attach = Document.parse(attachJson);
ModelVO model = modelService.getModelById(modelId);
attach.put("radar_ref_datetime", new Date(doc.getLong(model.getReferenceDate())));
attach.put("status", 1);
attach.put("status", "1");
doc.putAll(attach);
if (!isAllowDuplicate) {
//设置查询条件

2
radar-service-impl/src/main/java/com/pgmmers/radar/service/impl/model/ModelServiceImpl.java
View File

@ -208,7 +208,7 @@ public class ModelServiceImpl extends BaseLocalCacheService implements ModelServ
// add status.
Document statusKey = new Document();
statusKey.put("status", 1);
statusKey.put("status", "1");
IndexModel statusIndex = new IndexModel(statusKey);
indexes.add(statusIndex);