|
|
@@ -158,6 +158,9 @@ func sendStopExtractNode(splitArr []map[string]interface{}) {
|
|
|
|
|
|
//发送下阶段节点~
|
|
|
func sendNextNode(sid string, eid string) {
|
|
|
+ //更新记录状态
|
|
|
+ updateProcessUdpIdsInfo(sid, eid)
|
|
|
+
|
|
|
for _, node := range nextNode {
|
|
|
by, _ := json.Marshal(map[string]interface{}{
|
|
|
"gtid": sid,
|
|
|
@@ -178,9 +181,9 @@ func sendNextNode(sid string, eid string) {
|
|
|
}
|
|
|
log.Debug("udp通知抽取完成...通知下阶段udp-敏感词,补城市", sid, "~", eid)
|
|
|
|
|
|
- //更新记录状态
|
|
|
+ //此段落彻底完毕~继续获取任务
|
|
|
isGetask = false
|
|
|
- updateProcessUdpIdsInfo(sid, eid)
|
|
|
+
|
|
|
}
|
|
|
|
|
|
//发送单节点~
|
zhengkun