fengweiqiang 5 gadi atpakaļ
vecāks
revīzija
be1aadfcc9

+ 1 - 1
udp_winner/main.go

@@ -7,7 +7,7 @@ import (
 	mu "mfw/util"
 	"net"
 	"qfw/util"
-	"qfw/util/mongodb"
+	"qfw/common/src/qfw/util/mongodb"
 	"regexp"
 	"strconv"
 	"strings"

+ 2 - 1
udp_winner/timedTaskAgency.go

@@ -29,6 +29,7 @@ func TaskAgency(mapinfo *map[string]interface{}) {
 		log.Println(gtid, lteid, "不是Objectid,转换_id错误", gtid, lteid)
 		return
 	}
+	timenow := time.Now().Unix()
 	//udp的id区间查询bidding  中标人 中标联系人 中标联系电话
 	// topscopeclass项目类型-industry行业类型&&topscopeclass联系人项目类型
 	// (area地区-province省份 city城市-city城市 district区县-district区县)
@@ -205,7 +206,7 @@ func TaskAgency(mapinfo *map[string]interface{}) {
 		SourceClient.DestoryMongoConn(SourceClientcc)
 		log.Println("增量合并执行完成 ok", gtid, lteid, overid)
 		//发送udp 更新es段
-
+		nextNode("agencyent",timenow)
 	}
 
 }

+ 2 - 0
udp_winner/timedTaskBuyer.go

@@ -29,6 +29,7 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
 		log.Println(gtid, lteid, "不是Objectid,转换_id错误", gtid, lteid)
 		return
 	}
+	timenow:=time.Now().Unix()
 	//udp的id区间查询bidding  中标人 中标联系人 中标联系电话
 	// topscopeclass项目类型-industry行业类型&&topscopeclass联系人项目类型
 	// (area地区-province省份 city城市-city城市 district区县-district区县)
@@ -223,6 +224,7 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
 		SourceClient.DestoryMongoConn(SourceClientcc)
 		log.Println("增量合并执行完成 ok", gtid, lteid, overid)
 		//发送udp 更新es段
+		nextNode("buyerent",timenow)
 	}
 
 }

+ 2 - 0
udp_winner/timedTaskWinner.go

@@ -29,6 +29,7 @@ func TaskWinner(mapinfo *map[string]interface{}) {
 		log.Println(gtid, lteid, "不是Objectid,转换_id错误", gtid, lteid)
 		return
 	}
+	timenow := time.Now().Unix()
 	//udp的id区间查询bidding  中标人 中标联系人 中标联系电话
 	// topscopeclass项目类型-industry行业类型&&topscopeclass联系人项目类型
 	// (area地区-province省份 city城市-city城市 district区县-district区县)
@@ -212,6 +213,7 @@ func TaskWinner(mapinfo *map[string]interface{}) {
 		SourceClient.DestoryMongoConn(SourceClientcc)
 		log.Println("增量合并执行完成 ok", gtid, lteid, overid)
 		//发送udp 更新es段
+		nextNode("winnerent",timenow)
 	}
 
 }