no message

services/task.go

@@ -117,7 +117,7 @@ func Task() {
 		task.AddTask("getArticleListByApi", getArticleListByApi)
 	}
 
-	//go UserLabelLogReduce() // 处理用户标签的队列消息
+	go UserLabelLogReduce() // 处理用户标签的队列消息
 	//GetCygxActivityAttendanceDetail()
 	//CreateIndexNameArticleHistory()
 	//AddAllArticleHistory()

services/user_label.go

@@ -90,6 +90,12 @@ func ActivityUserLabelLogAdd(activityId int, mobileArr []string) (err error) {
 		return
 	}
 
+	industrialList, e := models.GetCygxIndustrialActivityGroupManagementList(condition+"  AND  source = 1 ", pars)
+	if e != nil {
+		err = errors.New("GetCygxIndustrialActivityGroupManagementList, Err: " + e.Error())
+		return
+	}
+
 	//如果有行产业归类就按照产业报告处理
 	var topCond string
 	var topPars []interface{}
@@ -139,16 +145,19 @@ func ActivityUserLabelLogAdd(activityId int, mobileArr []string) (err error) {
 				fmt.Println("CygxUserLabelLogRedis LPush Err:" + err.Error())
 			}
 		}
-		item := new(models.CygxUserLabelActivity)
-		item.UserId = user.UserId
-		item.CompanyId = user.CompanyId
-		item.RealName = user.RealName
-		item.Mobile = user.Mobile
-		item.Email = user.Email
-		item.ActivityId = activityId
-		item.CreateTime = time.Now()
-		item.ModifyTime = time.Now()
-		items = append(items, item)
+		for _, industr := range industrNamelist {
+			item := new(models.CygxUserLabelActivity)
+			item.UserId = user.UserId
+			item.CompanyId = user.CompanyId
+			item.RealName = user.RealName
+			item.Mobile = user.Mobile
+			item.Email = user.Email
+			item.ActivityId = activityId
+			item.Label = industr.IndustryName
+			item.CreateTime = time.Now()
+			item.ModifyTime = time.Now()
+			items = append(items, item)
+		}
 	}
 	if len(items) > 0 {
 		_, err = models.AddCygxUserLabelActivityList(items)