|
@@ -28,7 +28,7 @@ class RouteRfidKafkaAction extends Action {
|
|
|
return array('success'=>true,'message'=>'heartbeat time abnormal !');
|
|
|
}
|
|
|
$save_data=array(
|
|
|
- 'online_time'=>date('Y-m-d H:i:s',$onlinetime)
|
|
|
+ 'online_time'=>date('Y-m-d H:i:s',$data['time'])
|
|
|
);
|
|
|
M('stations')->createSave($station_cond,$save_data);
|
|
|
}
|
|
@@ -39,7 +39,10 @@ class RouteRfidKafkaAction extends Action {
|
|
|
if(!$data['labels']){
|
|
|
return array('success'=>true,'message'=>'addRfidDataToNingbo failed,labels not existed!');
|
|
|
}
|
|
|
-
|
|
|
+ $save_data=array(
|
|
|
+ 'online_time'=>date('Y-m-d H:i:s',time())
|
|
|
+ );
|
|
|
+ M('stations')->createSave($station_cond,$save_data);
|
|
|
|
|
|
//$station_sql='SELECT DEVICE_NAME FROM DSSC2.ADM_DEV WHERE LOGIN_NAME=\''.$RF_ID.'\'';
|
|
|
//$stid = oci_parse($conn, $station_sql);
|
|
@@ -47,11 +50,9 @@ class RouteRfidKafkaAction extends Action {
|
|
|
//oci_execute($stid);
|
|
|
//oci_fetch($stid);
|
|
|
|
|
|
- $updateStationTime=true;
|
|
|
|
|
|
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;
|
|
@@ -109,12 +110,7 @@ class RouteRfidKafkaAction extends Action {
|
|
|
$this->checkIllegalDriving($handle_data);
|
|
|
|
|
|
}
|
|
|
- if($updateStationTime){
|
|
|
- $save_data=array(
|
|
|
- 'online_time'=>date('Y-m-d H:i:s',time())
|
|
|
- );
|
|
|
- M('stations')->createSave($station_cond,$save_data);
|
|
|
- }
|
|
|
+
|
|
|
|
|
|
oci_free_statement($stid);
|
|
|
//oci_close($conn);
|