Browse Source

Merge pull request 'master' (#16) from master into V3

Reviewed-on: http://git.lrdaiot.cn:9000/thing/thing_api/pulls/16
qingyuan_dev_new
李帅 2 years ago
parent
commit
d3bb1cc695
  1. 2
      help/sql/ddl_1.0.0.sql
  2. 9
      modules/filter-rule/src/main/java/com/thing/filter/rule/listener/FilterLogSaveEventListener.java
  3. 1
      modules/thing/src/main/java/com/thing/thing/api/service/impl/IotThingApiServiceImpl.java

2
help/sql/ddl_1.0.0.sql

@ -1983,6 +1983,8 @@ COMMENT ON COLUMN "public"."filter_log"."updater" IS '更新人';
COMMENT ON COLUMN "public"."filter_log"."update_date" IS '更新时间'; COMMENT ON COLUMN "public"."filter_log"."update_date" IS '更新时间';
COMMENT ON TABLE "public"."filter_log" IS '过滤日志表'; COMMENT ON TABLE "public"."filter_log" IS '过滤日志表';
alter table public.filter_log add constraint filter_log_uk unique (filter_rule_id, time);
-- ---------------------------- -- ----------------------------
-- Table structure for filter_rule -- Table structure for filter_rule
-- ---------------------------- -- ----------------------------

9
modules/filter-rule/src/main/java/com/thing/filter/rule/listener/FilterLogSaveEventListener.java

@ -241,12 +241,13 @@ public class FilterLogSaveEventListener {
Set<FilterLogEntity> unMergedLogs = new HashSet<>(); Set<FilterLogEntity> unMergedLogs = new HashSet<>();
for (FilterLogEntity currentLog : logs) { for (FilterLogEntity currentLog : logs) {
Set<String> thingAttrs; Set<String> thingAttrs;
if(onlyMergeMissThingAttr){
if (onlyMergeMissThingAttr) {
thingAttrs = currentLog.getMissingThingAttrs(); thingAttrs = currentLog.getMissingThingAttrs();
if (CollectionUtils.isEmpty(thingAttrs)) { if (CollectionUtils.isEmpty(thingAttrs)) {
mergedLogs.add(currentLog);
continue; continue;
} }
}else {
} else {
thingAttrs = currentLog.getDefThingAttrs(); thingAttrs = currentLog.getDefThingAttrs();
} }
thingAttrs.forEach( thingAttrs.forEach(
@ -271,7 +272,9 @@ public class FilterLogSaveEventListener {
} }
}); });
} }
mergedLogs.addAll(unMergedLogs);
if (!unMergedLogs.isEmpty()) {
mergedLogs.addAll(unMergedLogs);
}
return mergedLogs.stream().filter(Objects::nonNull).collect(Collectors.toSet()); return mergedLogs.stream().filter(Objects::nonNull).collect(Collectors.toSet());
} }

1
modules/thing/src/main/java/com/thing/thing/api/service/impl/IotThingApiServiceImpl.java

@ -610,6 +610,7 @@ public class IotThingApiServiceImpl extends BaseServiceImpl<IotThingApiMapper, I
} }
} }
resultMap.put("result", entityResultMap); resultMap.put("result", entityResultMap);
log.info("IotThingApiServiceImpl.encapsulationQuery1:{}", JSON.toJSONString(resultMap));
return resultMap; return resultMap;
} }

Loading…
Cancel
Save