Commit 114e6fd7 by 陈健智

舆情库聚合修复,用户行为修复

parent dcf29a94
...@@ -61,12 +61,12 @@ public class MarkFlowEntity implements Serializable { ...@@ -61,12 +61,12 @@ public class MarkFlowEntity implements Serializable {
return entity; return entity;
} }
public static MarkFlowEntity getAggreeInstance(List<MarkFlowEntity> entities,int size) { public static MarkFlowEntity getAggreeInstance(List<MarkFlowEntity> entities, Integer size) {
// 首条数据为主 // 首条数据为主
MarkFlowEntity entity = Tools.copyByJson(entities.get(0), MarkFlowEntity.class); MarkFlowEntity entity = Tools.copyByJson(entities.get(0), MarkFlowEntity.class);
if (size > 1) { if (null != size && size > 1) {
entity.getType().put("fold", true); entity.getType().put("fold", true);
entity.getType().put("size",size); entity.getType().put("size", size);
} }
return entity; return entity;
} }
......
...@@ -76,7 +76,7 @@ public class BehaviorServiceImpl implements BehaviorService { ...@@ -76,7 +76,7 @@ public class BehaviorServiceImpl implements BehaviorService {
Date end = new Date(endTime); Date end = new Date(endTime);
String[] collectionNames = behaviorDao.generateCollectionNames(start, end); String[] collectionNames = behaviorDao.generateCollectionNames(start, end);
Query query = new Query(); Query query = new Query();
query.addCriteria(Criteria.where("cTime").gte(start).lt(end).and("backstage").is(backstage)); query.addCriteria(Criteria.where("cTime").gte(startTime).lt(endTime).and("backstage").is(backstage));
if (StringUtils.isNotEmpty(nickname)) { if (StringUtils.isNotEmpty(nickname)) {
List<User> userList = userDao.findList(Query.query(Criteria.where("nickname").regex(Pattern.compile("^.*" + nickname + ".*$", Pattern.CASE_INSENSITIVE)))); List<User> userList = userDao.findList(Query.query(Criteria.where("nickname").regex(Pattern.compile("^.*" + nickname + ".*$", Pattern.CASE_INSENSITIVE))));
// 根据nickname未查询 // 根据nickname未查询
...@@ -102,7 +102,7 @@ public class BehaviorServiceImpl implements BehaviorService { ...@@ -102,7 +102,7 @@ public class BehaviorServiceImpl implements BehaviorService {
Date start = new Date(startTime); Date start = new Date(startTime);
Date end = new Date(endTime); Date end = new Date(endTime);
Query query = new Query(); Query query = new Query();
query.addCriteria(Criteria.where("cTime").gte(start).lt(end).and("backstage").is(backstage)); query.addCriteria(Criteria.where("cTime").gte(startTime).lt(endTime).and("backstage").is(backstage));
List<Behavior> behaviorList = behaviorDao.findList(query, behaviorDao.generateCollectionNames(start, end)); List<Behavior> behaviorList = behaviorDao.findList(query, behaviorDao.generateCollectionNames(start, end));
List<ExportBehaviorDTO> resList = new ArrayList<>(behaviorList.size()); List<ExportBehaviorDTO> resList = new ArrayList<>(behaviorList.size());
behaviorList.forEach(behavior -> { behaviorList.forEach(behavior -> {
......
...@@ -531,6 +531,7 @@ public class MarkDataServiceImpl implements MarkDataService { ...@@ -531,6 +531,7 @@ public class MarkDataServiceImpl implements MarkDataService {
linkedGroupId = projectService.getProjectVOById(projectId).getBrandLinkedGroupId(); linkedGroupId = projectService.getProjectVOById(projectId).getBrandLinkedGroupId();
markSearchDTO.setLinkedGroupId(linkedGroupId); markSearchDTO.setLinkedGroupId(linkedGroupId);
} }
markSearchDTO.setPage(1);
markSearchDTO.setPageSize(10000); markSearchDTO.setPageSize(10000);
return markSearchDTO; return markSearchDTO;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment