Commit 1c81bd92 authored by 黄福新's avatar 黄福新

[add] 1、crossMonitorTask bug修复

parent a8673e53
......@@ -2,7 +2,7 @@ package net.wanji.opt.task;
import lombok.extern.slf4j.Slf4j;
import net.wanji.common.enums.CrossStatusEnum;
import net.wanji.opt.common.Constants;
import net.wanji.common.framework.Constants;
import net.wanji.opt.dto.CrossDataRealtimeDTO;
import net.wanji.opt.po.CrossDataRealtimePO;
import net.wanji.opt.service.CrossOptimizeService;
......@@ -65,15 +65,15 @@ public class CrossMonitorTask {
for (CrossDataRealtimePO po: crossDataRealtimePOList) {
// 获取失衡、拥堵、溢出路口数据
if(Constants.NO.equals(po.getIsSpillover()) || Constants.NO.equals(po.getIsCongestion()) || Constants.NO.equals(po.getIsUnbalance())) {
if(Constants.SystemParam.NO.equals(po.getIsSpillover()) || Constants.SystemParam.NO.equals(po.getIsCongestion()) || Constants.SystemParam.NO.equals(po.getIsUnbalance())) {
continue;
}
if(Constants.YES.equals(po.getIsSpillover())) { // 溢出
if(Constants.SystemParam.YES.equals(po.getIsSpillover())) { // 溢出
status = CrossStatusEnum.SPILLOVER.getCode();
} else if(Constants.YES.equals(po.getIsCongestion())) { // 拥堵
} else if(Constants.SystemParam.YES.equals(po.getIsCongestion())) { // 拥堵
status = CrossStatusEnum.CONGESTION.getCode();
} else if(Constants.YES.equals(po.getIsUnbalance())) { // 失衡
} else if(Constants.SystemParam.YES.equals(po.getIsUnbalance())) { // 失衡
status = CrossStatusEnum.UNBALANCE.getCode();
}
dto = new CrossDataRealtimeDTO();
......
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