no message

services/user_label.go

@@ -19,7 +19,7 @@ func init() {
 	//mobileArr = append(mobileArr, "15557270714")
 	//ActivityUserLabelLogAdd(2239, mobileArr)
 
-	UserLabelLogReduce()
+	//UserLabelLogReduce()
 }
 
 // 添加用户阅读标签到Redis
@@ -89,6 +89,28 @@ func ActivityUserLabelLogAdd(activityId int, mobileArr []string) (err error) {
 		//没有关联产业的活动不做标签处理
 		return
 	}
+
+	//如果有行产业归类就按照产业报告处理
+	var topCond string
+	var topPars []interface{}
+	var industrialManagementIds []int
+
+	for _, v := range industrialList {
+		industrialManagementIds = append(industrialManagementIds, v.IndustrialManagementId)
+	}
+	idsLen := len(industrialManagementIds)
+	if idsLen > 0 {
+		topCond = ` AND industrial_management_id IN (` + utils.GetOrmInReplace(idsLen) + `)`
+		topPars = append(topPars, industrialManagementIds)
+	} else {
+		return
+	}
+	industrNamelist, e := models.GetTopOneMonthArtReadNumIndustryAll(topCond, topPars)
+	if e != nil {
+		err = errors.New("GetTopOneMonthArtReadNumIndustryAll, Err: " + e.Error())
+		return
+	}
+
 	userList, e := models.GetWxUserByOutboundMobiles(mobileArr)
 	if e != nil {
 		err = errors.New("GetWxUserByOutboundMobiles" + e.Error())