fix

Home/Lib/Action/V1Action.class.php

@@ -87,19 +87,19 @@ class V1Action extends Action {
 			// $_st  = microtime(TRUE);
 			switch ($message->err) {
 				case RD_KAFKA_RESP_ERR_NO_ERROR:
-				$locationPack = ($message->payload).'\n';
+				$locationPack = ($message->payload);
 				$fileName = $localDir.'/HC_'.$createTime . '.dat';
 				$runTime = time() - $timeFram;
+				$sum++;
+				echo $sum.PHP_EOL;
 				if($runTime < $fileTimeInterval){
-					$sum++;
-					echo $sum;
 					$datRes = $this->writeRouteFile($fileName, $locationPack);
 				}else{
+					$datRes = $this->writeRouteFile($fileName,$locationPack);
 					$md5Res = $this->createRouteMD5file($fileName);
-		
 					$timeFram = time();
 					$createTime = date('Ymd_His', $timeFram);
-					$datRes = $this->writeRouteFile($fileName);
+		
 				}
 				break;
 				case RD_KAFKA_RESP_ERR__PARTITION_EOF:
@@ -131,7 +131,7 @@ class V1Action extends Action {
 		}
 		debug_log('route_info',$writeData);
 		
-		$writeData = utf8_encode($writeData);
+		$writeData = utf8_encode($writeData).'\n';
 		
 		$res = Zmcoding\FtpFile::getInstance($config)->writeFile($fileName, $writeData.PHP_EOL);