[update] 实时监控-代码优化

signal-optimize-service/src/main/java/net/wanji/opt/service/impl/CrossOptimizeServiceImpl.java

@@ -7,6 +7,7 @@ import net.wanji.common.enums.CrossStatusEnum;
 import net.wanji.common.framework.Constants;
 import net.wanji.common.framework.rest.JsonViewObject;
 import net.wanji.common.utils.tool.BeanListUtils;
+import net.wanji.common.utils.tool.BeanMapUtils;
 import net.wanji.databus.dao.entity.RidInfoEntity;
 import net.wanji.databus.dao.mapper.CrossDirDataRealtimeMapper;
 import net.wanji.databus.dao.mapper.CrossTurnDataRealtimeMapper;
@@ -732,7 +733,8 @@ public class CrossOptimizeServiceImpl implements CrossOptimizeService {
             log.error("路口优化获取当前路口控制模式异常！");
             throw new OptServiceException("路口优化获取当前路口控制模式异常！");
         }
-        List<SignalStatusVO> signalStatusVOS = (List<SignalStatusVO>) jsonViewObject.getContent();
+        List<Map<String, Object>> source = (List<Map<String, Object>>) jsonViewObject.getContent();
+        List<SignalStatusVO> signalStatusVOS = BeanMapUtils.mapsToObjects(source, SignalStatusVO.class);
         List<SignalStatusVO> resultList = signalStatusVOS.stream().filter(signalStatusVO -> Objects.equals(crossId, signalStatusVO.getCrossId())).collect(Collectors.toList());
         if (!CollectionUtils.isEmpty(resultList)) {
             SignalStatusVO signalStatusVO = resultList.get(0);