no message

udpcreateindex/main.go

@@ -12,6 +12,7 @@ import (
 	"time"
 	util "utils"
 	"utils/nsq"
+	"utils/redis"
 	"utils/udp"
 )
 
@@ -21,13 +22,13 @@ var (
 
 func main() {
 	// company_id
-	//redis.InitRedis1("qyxy_id=172.17.4.189:8379", 4)
-	//inits()
+	redis.InitRedis1("qyxy_id=172.17.4.189:8379", 4)
+	inits()
 
 	//go inspectQuery()
-	//go checkMapJob()
-	//go task_index()
-	//go nsqMethod()
+	go checkMapJob()
+	go task_index()
+	go nsqMethod()
 
 	go UpdateBidding()
 	go UpdateExtract()

udpcreateindex/projectindex.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"go.mongodb.org/mongo-driver/bson/primitive"
 	"math"
 	"strconv"
 	util "utils"
@@ -114,7 +115,7 @@ func projectTask(data []byte, project, mapInfo map[string]interface{}) {
 		bidopentime := util.Int64All(tmp["bidopentime"]) //开标日期
 		fzb_publishtime := int64(0)                      //记录第一个招标信息的publishtime
 		bidcycle_flag := false                           //判断是否已计算出标书表编制周期
-		list := tmp["list"].([]interface{})
+		list := []interface{}(tmp["list"].(primitive.A))
 		for _, m := range list {
 			tmpM := m.(map[string]interface{})
 			//删除purchasing,review_experts