修改

Home/Lib/Action/RouteRfidKafkaAction.class.php

@@ -14,7 +14,6 @@ class RouteRfidKafkaAction extends Action {
 		if($data['methond']=='login'){
 			return array('success'=>true,'message'=>'addRfidDataToNingbo failed,methond  login!');
 		}
-		
 		$RF_ID=strtoupper($data['mac']);
 		
 		$station_cond=array('mac'=>$RF_ID);
@@ -52,6 +51,7 @@ class RouteRfidKafkaAction extends Action {
 		foreach($data['labels'] as $val){
 			if( ($val['time']<(time()-3600*24*10) ) || ($val['time']>(time()+3600*24*10) ) ){
 				$updateStationTime=false;
+				$val['mac']=$RF_ID;
 				$this->debug_log( 'abnormal_labels', $val );
 				continue;
 			}
@@ -64,7 +64,8 @@ class RouteRfidKafkaAction extends Action {
 			}
 			$RF_FLAGID=strtoupper($val['id']);
 			if($RF_FLAGID=='00000000'){
-				$this->debug_log( 'abnormal_labels', $val );
+				$val['mac']=$RF_ID;
+				$this->debug_log( 'abnormal_labels', $val);
 				continue;
 			}
 			$RF_DATE=date('Y-m-d H:i:s',$val['time']);
@@ -586,5 +587,28 @@ class RouteRfidKafkaAction extends Action {
 		
 	}
 	
+ 
+	public  function test3(  ){
+		//统计表数据添加
+		for($i=0;$i<5000;$i++){
+			$to_cond=array(
+				'mac'=>'AABBCCDD',
+				'date'=>date('Y-m-d',time())
+			);
+			if(!M('station_passing')->where($to_cond)->count()){
+				$total_data=array(
+					'address'=>'测试AAAAA',
+					'mac'=>'AABBCCDD',
+					'date'=>date('Y-m-d',time()),
+					'num'=>1,
+				);
+				$res=M('station_passing')->createAdd($total_data);
+			}else{
+				$res=M('station_passing')->where($to_cond)->setInc('num');
+			}
+		}
+		
+	}
+	
 
 }