Commit e04a074a authored by duanruiming's avatar duanruiming

[update] 绿波实时数据优化

parent 0fbdb081
......@@ -340,6 +340,14 @@ public class GreenBeltInfoServiceImpl implements GreenBeltInfoService {
ObjectMapper instance = JacksonUtils.getInstance();
GreenWavePeriodDTO greenWavePeriodDTO = instance.readValue(message, GreenWavePeriodDTO.class);
List<GreenwaveRealtimePO> greenwaveRealtimePOS = greenWavePeriodDTO.getEventList();
greenwaveRealtimePOS.forEach(item -> {
Integer batchTime = item.getBatchTime();
item.setBatchTime(batchTime);
item.setGmtCreate(new Date());
item.setGmtModified(new Date());
item.setStartTime(new Date(batchTime * 1000L));
}
);
if (!CollectionUtils.isEmpty(greenwaveRealtimePOS)) {
List<Integer> collect = greenwaveRealtimePOS.stream().map(GreenwaveRealtimePO::getGreenId).collect(Collectors.toList());
greenwaveRealtimeMapper.deleteBatch(collect);
......
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