三级页汇总调整

userBehaviorTask/entity/task.go

@@ -29,7 +29,7 @@ var ContentInfo = make(map[string][]map[string]interface{})
 var positionUser = map[string]string{}
 
 // 三级页详情获取
-var biddingInfo map[string]string
+var biddingInfo map[string]map[string]interface{}
 
 // 数据库中数据初始化
 var subInItInfo map[string]map[string]string
@@ -58,7 +58,7 @@ func (t *Task) ShuaKu(start, end int64) {
 	ContentInfo = make(map[string][]map[string]interface{})
 	subInfo = make(map[string]map[string]string)
 	searchHandle(start, end)
-	biddingInfo = map[string]string{}
+	biddingInfo = map[string]map[string]interface{}{}
 	ContentHandle(start, end)
 	//批量处理入库
 	for userId, v := range SearchInfo {
@@ -118,6 +118,12 @@ func (t *Task) ShuaKu(start, end int64) {
 			}
 		}
 	}
+	SearchInfo = make(map[string][]map[string]interface{})
+	ContentInfo = make(map[string][]map[string]interface{})
+	subInfo = make(map[string]map[string]string)
+	biddingInfo = map[string]map[string]interface{}{}
+	positionUser = map[string]string{}
+	subInItInfo = map[string]map[string]string{}
 }
 
 func UserHandle() {
@@ -314,13 +320,15 @@ func InformationHandle(m map[string]interface{}, data map[string][]map[string]in
 	}
 	//分类标签，bidding表gov_classify.root，过滤掉只有一级的，取最后一级
 	rootStr := ""
+	area := ""
 	if _, ok := biddingInfo[infoId]; !ok {
-		bidding, _ := MgoBidding.FindById("bidding", infoId, `{"gov_classify":1}`)
-		biddingInfo[infoId] = ""
+		bidding, _ := MgoBidding.FindById("bidding", infoId, `{"gov_classify":1,"area":1}`)
+		biddingInfo[infoId] = map[string]interface{}{}
 		if bidding == nil {
 			return
 		}
 		gov_classify := gconv.Map((*bidding)["gov_classify"])
+		area = gconv.String((*bidding)["area"])
 		if gov_classify != nil {
 			root := strings.Split(gconv.String(gov_classify["root"]), "/")
 			if len(root) == 0 {
@@ -329,14 +337,18 @@ func InformationHandle(m map[string]interface{}, data map[string][]map[string]in
 				for i := len(root) - 1; i >= 1; i-- {
 					if root[i] != "" {
 						rootStr = root[i]
-						biddingInfo[infoId] = rootStr
+						biddingInfo[infoId] = map[string]interface{}{
+							"area":    area,
+							"rootStr": rootStr,
+						}
 						break
 					}
 				}
 			}
 		}
 	} else {
-		rootStr = biddingInfo[infoId]
+		rootStr = gconv.String(biddingInfo[infoId]["rootStr"])
+		area = gconv.String(biddingInfo[infoId]["area"])
 	}
 	if rootStr == "" {
 		return
@@ -346,8 +358,8 @@ func InformationHandle(m map[string]interface{}, data map[string][]map[string]in
 		"classify":    rootStr,                                                            //分类标签，bidding表gov_classify.root，过滤掉只有一级的，取最后一级
 		"datetimeInt": gconv.Int64(m["date"]),                                             //访问时间
 		"datetime":    time.Unix(gconv.Int64(m["date"]), 0).Format("2006-01-02 15:04:05"), //搜索时间
+		"area":        area,
 	}
-	logx.Info("1111", gconv.String(m["url"]))
 	if _, ok := data[userId]; ok {
 		data[userId] = append(data[userId], searchMap)
 	} else {

userBehaviorTask/main.go

@@ -10,8 +10,8 @@ func main() {
 	s := flag.Int64("s", 0, "开始时间")
 	e := flag.Int64("e", 0, "结束时间")
 	/*	m := flag.Int("m", 1, " 1-指定时间段统计")
-		s := flag.Int64("s", 1710234232, "开始时间")
-		e := flag.Int64("e", 1710408045, "结束时间")*/
+		s := flag.Int64("s", 1710729220, "开始时间")
+		e := flag.Int64("e", 1710815620, "结束时间")*/
 	flag.Parse()
 	if *m == 1 {
 		(&entity.Task{}).ShuaKu(*s, *e)