From e4260517fc5d434b0211cf869e64ab43c6e0e999 Mon Sep 17 00:00:00 2001 From: zhanghongqing Date: Tue, 20 Sep 2022 16:36:44 +0800 Subject: [PATCH] =?UTF-8?q?SUBSCRIBER=20from=20to=20=E5=A2=9E=E5=8A=A0vsys?= =?UTF-8?q?=5Fid?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scala/cn/ac/iie/service/update/UpdateDocument.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala index d767ca2..16a77d3 100644 --- a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala +++ b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala @@ -149,8 +149,8 @@ object UpdateDocument { } else { subidLocIpDoc = new BaseEdgeDocument() subidLocIpDoc.setKey(key) - subidLocIpDoc.setFrom("SUBSCRIBER/" + subId) - subidLocIpDoc.setTo("IP/" + ip) + subidLocIpDoc.setFrom("SUBSCRIBER/" + subId + "-" + vsysId) + subidLocIpDoc.setTo("IP/" + ip+ "-" + vsysId) subidLocIpDoc.addAttribute("SUBSCRIBER", subId) subidLocIpDoc.addAttribute("IP", ip) subidLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime) @@ -293,8 +293,8 @@ object UpdateDocument { } else { fqdnLocIpDoc = new BaseEdgeDocument() fqdnLocIpDoc.setKey(key) - fqdnLocIpDoc.setFrom("FQDN/" + fqdn) - fqdnLocIpDoc.setTo("IP/" + serverIp) + fqdnLocIpDoc.setFrom("FQDN/" + fqdn+ "-" + vsysId) + fqdnLocIpDoc.setTo("IP/" + serverIp+ "-" + vsysId) fqdnLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime) fqdnLocIpDoc.addAttribute("LAST_FOUND_TIME", lastFoundTime) fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId)