gfwleak/wanglihui-ip-learning-graph
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SUBSCRIBER from to 增加vsys_id

Browse Source
This commit is contained in:
zhanghongqing
2022-09-20 16:36:44 +08:00
parent 1bf1045223
commit e4260517fc
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
View File

@@ -149,8 +149,8 @@ object UpdateDocument {
} else { } else {
subidLocIpDoc = new BaseEdgeDocument() subidLocIpDoc = new BaseEdgeDocument()
subidLocIpDoc.setKey(key) subidLocIpDoc.setKey(key)
subidLocIpDoc.setFrom("SUBSCRIBER/" + subId) subidLocIpDoc.setFrom("SUBSCRIBER/" + subId + "-" + vsysId)
subidLocIpDoc.setTo("IP/" + ip) subidLocIpDoc.setTo("IP/" + ip+ "-" + vsysId)
subidLocIpDoc.addAttribute("SUBSCRIBER", subId) subidLocIpDoc.addAttribute("SUBSCRIBER", subId)
subidLocIpDoc.addAttribute("IP", ip) subidLocIpDoc.addAttribute("IP", ip)
subidLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime) subidLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime)
@@ -293,8 +293,8 @@ object UpdateDocument {
} else { } else {
fqdnLocIpDoc = new BaseEdgeDocument() fqdnLocIpDoc = new BaseEdgeDocument()
fqdnLocIpDoc.setKey(key) fqdnLocIpDoc.setKey(key)
fqdnLocIpDoc.setFrom("FQDN/" + fqdn) fqdnLocIpDoc.setFrom("FQDN/" + fqdn+ "-" + vsysId)
fqdnLocIpDoc.setTo("IP/" + serverIp) fqdnLocIpDoc.setTo("IP/" + serverIp+ "-" + vsysId)
fqdnLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime) fqdnLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime)
fqdnLocIpDoc.addAttribute("LAST_FOUND_TIME", lastFoundTime) fqdnLocIpDoc.addAttribute("LAST_FOUND_TIME", lastFoundTime)
fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId) fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId)