|
|
@@ -80,29 +80,26 @@ class RouteRfidKafkaAction extends Action {
|
|
|
$this->debug_log( 'insert_oracle_error', $val );
|
|
|
return array('success'=>false,'message'=>'addRfidDataToNingbo failed,insert_oracle_error!');
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
- $vehicle_sql='SELECT o.PLATE_NO FROM DSSC3.W_DW_NON_MOTOR o,DSSC3.W_DW_RFID_TAGS s WHERE s.RFID_SN =\''.$RF_FLAGID.'\' AND o.rfid_id = s.id ';
|
|
|
- $stid = oci_parse($conn, $vehicle_sql);
|
|
|
- oci_define_by_name($stid, 'PLATE_NO', $plate_no);
|
|
|
- oci_execute($stid);
|
|
|
- oci_fetch($stid);
|
|
|
-
|
|
|
-
|
|
|
+ //插入成功就执行统计
|
|
|
$handle_data=array(
|
|
|
'RF_STAT'=>$RF_STAT,
|
|
|
'RF_FLAGID'=>$RF_FLAGID,
|
|
|
'RF_ID'=>$RF_ID,
|
|
|
'time'=>$val['time'],
|
|
|
'address'=>$device_name,
|
|
|
- 'plate_no'=>$plate_no
|
|
|
);
|
|
|
-
|
|
|
-
|
|
|
$this->handleTotalData($handle_data);
|
|
|
+
|
|
|
+ $vehicle_sql='SELECT o.PLATE_NO FROM DSSC3.W_DW_NON_MOTOR o,DSSC3.W_DW_RFID_TAGS s WHERE s.RFID_SN =\''.$RF_FLAGID.'\' AND o.rfid_id = s.id ';
|
|
|
+ $stid = oci_parse($conn, $vehicle_sql);
|
|
|
+ oci_define_by_name($stid, 'PLATE_NO', $plate_no);
|
|
|
+ oci_execute($stid);
|
|
|
+ oci_fetch($stid);
|
|
|
+
|
|
|
if(!$plate_no){
|
|
|
continue;
|
|
|
}
|
|
|
+ $handle_data['plate_no']=$plate_no;
|
|
|
//检测布控
|
|
|
$this->checkControlAlarm($handle_data);
|
|
|
//违规行驶检测 超速逆行检测
|
git