From 3a6fe58a2a71d7427d7017586adf6eb294989dbe Mon Sep 17 00:00:00 2001
From: qidaijie <qidaijie@mesalab.cn>
Date: Tue, 17 Sep 2019 09:57:41 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=BA=93=E8=A1=A8=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 properties/service_flow_config.properties     |  4 ++--
 .../java/cn/ac/iie/bean/SessionRecordLog.java | 19 +++++++++++++++++++
 .../ac/iie/utils/influxdb/InfluxDbUtils.java  |  2 +-
 3 files changed, 22 insertions(+), 3 deletions(-)

diff --git a/properties/service_flow_config.properties b/properties/service_flow_config.properties
index 06c7f56..3077812 100644
--- a/properties/service_flow_config.properties
+++ b/properties/service_flow_config.properties
@@ -60,10 +60,10 @@ check.ip.scope=10,100,192
 max.failure.num=20
 
 #influx地址
-influx.ip=http://192.168.40.207:8086
+influx.ip=http://192.168.40.151:8086
 
 #influx用户名
 influx.username=admin
 
 #influx密码
-influx.password=123456
\ No newline at end of file
+influx.password=admin
\ No newline at end of file
diff --git a/src/main/java/cn/ac/iie/bean/SessionRecordLog.java b/src/main/java/cn/ac/iie/bean/SessionRecordLog.java
index 5385883..baa3f81 100644
--- a/src/main/java/cn/ac/iie/bean/SessionRecordLog.java
+++ b/src/main/java/cn/ac/iie/bean/SessionRecordLog.java
@@ -78,6 +78,9 @@ public class SessionRecordLog {
     private String framed_ip;
     private String account;
     private int packet_type;
+    private int has_dup_traffic;
+    private String stream_error;
+
 
     public SessionRecordLog() {
     }
@@ -650,4 +653,20 @@ public class SessionRecordLog {
     public void setPacket_type(int packet_type) {
         this.packet_type = packet_type;
     }
+
+    public int getHas_dup_traffic() {
+        return has_dup_traffic;
+    }
+
+    public void setHas_dup_traffic(int has_dup_traffic) {
+        this.has_dup_traffic = has_dup_traffic;
+    }
+
+    public String getStream_error() {
+        return stream_error;
+    }
+
+    public void setStream_error(String stream_error) {
+        this.stream_error = stream_error;
+    }
 }
diff --git a/src/main/java/cn/ac/iie/utils/influxdb/InfluxDbUtils.java b/src/main/java/cn/ac/iie/utils/influxdb/InfluxDbUtils.java
index f0dfffd..124344f 100644
--- a/src/main/java/cn/ac/iie/utils/influxdb/InfluxDbUtils.java
+++ b/src/main/java/cn/ac/iie/utils/influxdb/InfluxDbUtils.java
@@ -63,7 +63,7 @@ public class InfluxDbUtils {
 
     public static void main(String[] args) {
         sendKafkaFail(100);
-        sendKafkaSuccess(100L);
+//        sendKafkaSuccess(100L);
     }
 
 }