@@ -2,7 +2,6 @@ package main
import (
"fmt"
- "strconv"
"testing"
)
@@ -11,23 +10,14 @@ func TestTagBidding(t *testing.T) {
"toptype": "招标",
"subtype": "招标",
"buyerclass": "能源化工",
+ "spidercode": "a_jyxxfbpt_gg",
}
rea := TagBidding(data)
fmt.Println(rea)
reb := calculateFlag(rea, columns)
- fmt.Println(reb)
+ fmt.Println("reb", reb)
+ //1000 0100 0001
- fmt.Println("len data", len(data))
-
- dab := make(map[string]interface{})
- fmt.Println("len dab ", len(dab))
- code := "04"
- stage_code, _ := strconv.Atoi(code)
- if stage_code > 0 {
- fmt.Println("aaaa")
- }
- fmt.Println(stage_code)
@@ -37,9 +37,7 @@
columns = ["招标公告","招标预告","招标结果","招标信用","采购意向","项目分包","企业直采",
"政府采购","拟在建项目","审批项目","推荐项目","业主委托项目","热门项目","新兴项目",
"国家级项目","省级项目"]
- hotnum = 100 ## 每天搜索次数
- hotUrl = "http://192.168.3.207:4223/jyartvisit/"
-# hotUrl = "http://172.17.145.164:18880/jyartvisit/" ## 正式环境
+ hotnum = 25 ## 每天搜索次数
@@ -195,9 +195,15 @@ func getHot() {
if err != nil {
log.Error("getHot", zap.Error(err))
- insert["hot_data"] = 1
- rea := TagBidding(insert)
+ bidding, _ := MgoB.FindById("bidding", vs[0], nil)
+ biddingData := *bidding
+ if biddingData == nil {
+ continue
+ }
+ biddingData["hot_data"] = 1
+ rea := TagBidding(biddingData)
reb := calculateFlag(rea, columns) //拿到十进制数字,标签栏目结果
+ log.Info("getHot", zap.Any("reb", reb), zap.String("id", vs[0]))
updatePool <- []map[string]interface{}{
{"_id": insert["_id"]},
{"$set": bson.M{
@@ -0,0 +1,15 @@
+package main
+
+import (
+ "fmt"
+ "go.mongodb.org/mongo-driver/bson/primitive"
+ "testing"
+)
+func TestIdTime(T *testing.T) {
+ id := "65713fc86977356f555aded5"
+ objectID, _ := primitive.ObjectIDFromHex(id)
+ timestamp := objectID.Timestamp()
+ fmt.Println(timestamp.Format("2006-01-02"))
+}