diff --git a/src/main/java/com/zdjizhi/etl/DosDetection.java b/src/main/java/com/zdjizhi/etl/DosDetection.java index 74c4bdf..c8d68d1 100644 --- a/src/main/java/com/zdjizhi/etl/DosDetection.java +++ b/src/main/java/com/zdjizhi/etl/DosDetection.java @@ -131,9 +131,22 @@ public class DosDetection extends BroadcastProcessFunction 0){ + diffSessionPercent = getDiffPercent(diffSession, sessionBase)*100; + } + else if (pktBase != 0 && pktBase > 0){ + diffPktPercent = getDiffPercent(diffPkt, pktBase)*100; + } + else if (bitBase != 0 && bitBase > 0){ + diffBitPercent = getDiffPercent(diffByte, bitBase)*100; + } long profileId = 0; DosEventLog result =null; @@ -148,22 +161,6 @@ public class DosDetection extends BroadcastProcessFunction dosEventLogs = new ArrayList<>(); - if (result != null){ - dosEventLogs.add(result); - Integer[] superiorIds = threshold.getSuperiorIds(); - if (superiorIds != null && superiorIds.length > 0){ - for (Integer integer:superiorIds){ - DosEventLog clone = (DosEventLog) result.clone(); - clone.setVsys_id(integer); - clone.setLog_id(SnowflakeId.generateId()); - dosEventLogs.add(clone); - } - } - } - */ return result; } @@ -316,7 +313,13 @@ public class DosDetection extends BroadcastProcessFunction