xiugai

src/config.json

@@ -85,5 +85,10 @@
 		"111",
 		"222",
 		"jyPB1XQgsGBQNbQElICQNW"
+	],
+	"checkbidopen_appid": [
+		"111",
+		"222",
+		"jyPB1XQgsGBQNbQElICQNW"
 	]
 }

src/history/datamodel.go

@@ -69,14 +69,15 @@ import (
 // 	"tagname":          "标签名称",
 // }
 var (
-	MgoSaveCache     = make(chan map[string]interface{}, 1000)
-	xlsxArr          = []map[string]interface{}{}
-	SP               = make(chan bool, 5)
-	xlsxCount        = 0
-	SE               = util.SimpleEncrypt{Key: "topJYBX2019"}
-	ProjectAppidMap  = map[string]bool{}
-	projectIdMap     = sync.Map{}
-	FileTextAppidMap = map[string]bool{}
+	MgoSaveCache         = make(chan map[string]interface{}, 1000)
+	xlsxArr              = []map[string]interface{}{}
+	SP                   = make(chan bool, 5)
+	xlsxCount            = 0
+	SE                   = util.SimpleEncrypt{Key: "topJYBX2019"}
+	ProjectAppidMap      = map[string]bool{}
+	projectIdMap         = sync.Map{}
+	FileTextAppidMap     = map[string]bool{}
+	CheckBidOpenAppidMap = map[string]bool{}
 )
 
 //客户模型

src/history/task.go

@@ -154,6 +154,17 @@ func (c *Customer) GetData(stype string) {
 									}
 								}
 								id := qu.ObjToString(tmp["_id"])
+								//亚信
+								if CheckBidOpenAppidMap[c.AppId] {
+									if tmp["bidopentime"] != nil {
+										bidopentime := qu.Int64All(tmp["bidopentime"])
+										comeintime := qu.Int64All(tmp["comeintime"])
+										if bidopentime-comeintime <= 7*24*60*60 {
+											qu.Debug("跳过该条数据，开标时间-入库时间<=7天，", id)
+											return
+										}
+									}
+								}
 								//
 								tmp["id"] = id //记录数据原有id
 								delete(tmp, "_id")

src/main.go

@@ -60,6 +60,9 @@ func init() {
 	for _, s := range util.Sysconfig["filetext_appid"].([]interface{}) {
 		history.FileTextAppidMap[s.(string)] = true
 	}
+	for _, s := range util.Sysconfig["checkbidopen_appid"].([]interface{}) {
+		history.CheckBidOpenAppidMap[s.(string)] = true
+	}
 }
 
 func main() {