|
|
@ -76,7 +76,7 @@ public class EventreportPingyinServiceImpl extends BaseServiceImpl<EventreportPi |
|
|
|
log.warn("no event data to save table base_conflicts_resolve"); |
|
|
|
return; |
|
|
|
} |
|
|
|
log.debug("sql结果" + list); |
|
|
|
log.debug("sql结果" + list.size()); |
|
|
|
List<EventreportPingyinEntity> entityList = list.stream().map(item -> { |
|
|
|
EventreportPingyinEntity entity = new EventreportPingyinEntity(); |
|
|
|
entity.setQxBm("370124"); |
|
|
@ -149,6 +149,7 @@ public class EventreportPingyinServiceImpl extends BaseServiceImpl<EventreportPi |
|
|
|
StringUtils.isNotBlank(item.getGridUserCardid()) && StringUtils.isNotBlank(item.getEventDescription()) && |
|
|
|
StringUtils.isNotBlank(item.getWaysOfResolving()) && null != item.getLng() && null != item.getLat() |
|
|
|
).collect(Collectors.toList()); |
|
|
|
log.debug("数据过滤结果" + entityList.size()); |
|
|
|
if (NumConstant.ZERO_STR.equals(initFlag)) { |
|
|
|
entityList.forEach(entity -> { |
|
|
|
LambdaQueryWrapper<EventreportPingyinEntity> wrapper = new LambdaQueryWrapper<>(); |
|
|
|