[update] 停车次数改为double类型

signal-datacenter-service/src/main/java/net/wanji/datacenter/pojo/convert/LanePeriodicDataEventListConvert.java

@@ -36,13 +36,13 @@ public class LanePeriodicDataEventListConvert {
         crossDataRealTimePO.setStartTime(now);
         crossDataRealTimePO.setDuration(5); // todo 通过第二批次判断
 
-        crossDataRealTimePO.setUnbalanceStatus(0);
+        crossDataRealTimePO.setIsUnbalance(0);
         crossDataRealTimePO.setUnbalanceIndex(1.0);
         crossDataRealTimePO.setUnbalanceDirs(dir);
-        crossDataRealTimePO.setCongestionStatus(0);
+        crossDataRealTimePO.setIsCongestion(0);
         crossDataRealTimePO.setCongestionIndex(1.0);
         crossDataRealTimePO.setCongestionDirs(dir);
-        crossDataRealTimePO.setSpilloverStatus(0);
+        crossDataRealTimePO.setIsSpillover(0);
         crossDataRealTimePO.setSpilloverIndex(1.0);
         crossDataRealTimePO.setSpilloverDirs(dir);
 
@@ -51,7 +51,7 @@ public class LanePeriodicDataEventListConvert {
         crossDataRealTimePO.setFlowRate(Double.valueOf(trafficFlow / 5 * 60));
         crossDataRealTimePO.setSpeed(meanV);
         crossDataRealTimePO.setQueueLength(staticQueueLengthMax);
-        crossDataRealTimePO.setStopTimes(stopTimes);
+        crossDataRealTimePO.setStopTimes((double)stopTimes);
         crossDataRealTimePO.setDelayTime(meanDelayInt);
         crossDataRealTimePO.setSturation(laneSaturation);
         crossDataRealTimePO.setBatchTime(batchTime);
@@ -90,7 +90,7 @@ public class LanePeriodicDataEventListConvert {
         crossDirDataRealTimePO.setFlow(trafficFlow);
         crossDirDataRealTimePO.setSpeed(meanV);
         crossDirDataRealTimePO.setQueueLength(staticQueueLengthMax);
-        crossDirDataRealTimePO.setStopTimes(stopTimes);
+        crossDirDataRealTimePO.setStopTimes((double)stopTimes);
         crossDirDataRealTimePO.setDelayTime(meanDelayInt);
         crossDirDataRealTimePO.setSturation(laneSaturation);
         crossDirDataRealTimePO.setBatchTime(batchTime);
@@ -129,7 +129,7 @@ public class LanePeriodicDataEventListConvert {
         crossTurnDataRealtimePO.setInSpeed(0000.0);
         crossTurnDataRealtimePO.setOutSpeed(0000.0);
         crossTurnDataRealtimePO.setQueueLength(staticQueueLengthMax);
-        crossTurnDataRealtimePO.setStopTimes(stopTimes);
+        crossTurnDataRealtimePO.setStopTimes((double)stopTimes);
         crossTurnDataRealtimePO.setDelayTime(meanDelayInt);
         crossTurnDataRealtimePO.setSturation(laneSaturation);
         crossTurnDataRealtimePO.setVehheadDist(0000.0);

signal-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/LanePeriodicDataProcessServiceImpl.java

@@ -127,7 +127,7 @@ public class LanePeriodicDataProcessServiceImpl implements DataProcessService {
             Double flowRate = 0.0;
             Double speed = 0.0;
             Double queueLength = 0.0;
-            Integer stopTimes = 0;
+            Double stopTimes = 0.0;
             Integer delayTime = 0;
             for (CrossDataRealtimePO crossDataRealTimePO : value) {
                 // 每个路口计算交通流量累加，筛选最大停车长度