fix

Home/Lib/Action/V1Action.class.php

@@ -81,18 +81,18 @@ class V1Action extends Action {
 			$fileTimeInterval = 30;
 		}
 		// $x = 0;
-		// $sum = 0;
+		$sum = 0;
 		while (true) {
 			$message = $consumer->consume(30*1000);
 			// $_st  = microtime(TRUE);
 			switch ($message->err) {
 				case RD_KAFKA_RESP_ERR_NO_ERROR:
 				$locationPack = ($message->payload).'\n';
-				
-				$fileName = $localDir.'/HC_'.json_decode($message->payload)->mac.$createTime . '.dat';
+				$fileName = $localDir.'/HC_'.$createTime . '.dat';
 				$runTime = time() - $timeFram;
-		
 				if($runTime < $fileTimeInterval){
+					$sum++;
+					echo $sum;
 					$datRes = $this->writeRouteFile($fileName, $locationPack);
 				}else{
 					$md5Res = $this->createRouteMD5file($fileName);
@@ -106,7 +106,7 @@ class V1Action extends Action {
 				echo "No more messages; will wait for more".PHP_EOL;
 				break;
 				case RD_KAFKA_RESP_ERR__TIMED_OUT:
-				$fileName = $localDir.'/HC_'.json_decode($message->payload)->mac.$createTime . '.dat';
+				$fileName = $localDir.'/HC_'.$createTime . '.dat';
 				$md5Res = $this->createRouteMD5file($fileName);
 				$timeFram = time();
 				$createTime = date('Ymd_His', $timeFram);