Commit 37936b9f authored by duanruiming's avatar duanruiming

[update] 通过路口周期数据修改路口事件交通指数异常优化

parent 9fb5d0e8
...@@ -160,9 +160,11 @@ public class DataProcessServiceImpl implements DataProcessService { ...@@ -160,9 +160,11 @@ public class DataProcessServiceImpl implements DataProcessService {
try { try {
String crossId = crossDataRealtimePO.getCrossId(); String crossId = crossDataRealtimePO.getCrossId();
EventInfoPO eventInfoPO = eventInfoMapper.selectLastEventInfo(crossId); EventInfoPO eventInfoPO = eventInfoMapper.selectLastEventInfo(crossId);
Double trafficIndex = crossDataRealtimePO.getTrafficIndex(); if (Objects.nonNull(eventInfoPO)) {
eventInfoPO.setTrafficIndex(trafficIndex); Double trafficIndex = crossDataRealtimePO.getTrafficIndex();
eventInfoMapper.updateOne(eventInfoPO); eventInfoPO.setTrafficIndex(trafficIndex);
eventInfoMapper.updateOne(eventInfoPO);
}
} catch (Exception e) { } catch (Exception e) {
log.error("路口周期数据插入时间交通指数失败:{}", e); log.error("路口周期数据插入时间交通指数失败:{}", e);
} }
......
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