no message

services/user_label.go

@@ -54,6 +54,7 @@ func IndustryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 	isFllow := log.IsFllow
 	industrialManagementId := log.SourceId
 	userId := log.UserId
+	source := 1
 	detailIndustrial, e := models.GetIndustrialManagementDetail(industrialManagementId)
 	if e != nil {
 		err = errors.New("GetIndustrialManagementDetail" + e.Error())
@@ -61,7 +62,7 @@ func IndustryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 	}
 	label := detailIndustrial.IndustryName
 	if isFllow == 0 {
-		e = models.UpdateCygxUserLabelIsFollow(isFllow, industrialManagementId, 1, label)
+		e = models.UpdateCygxUserLabelIsFollow(isFllow, industrialManagementId, source, label)
 		if e != nil {
 			err = errors.New("UpdateCygxUserLabelIsFollow" + e.Error())
 			return
@@ -69,7 +70,8 @@ func IndustryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 	} else {
 		var condition string
 		var pars []interface{}
-		condition += ` AND art.status = 1 `
+		condition += ` WHERE source_id=? AND source = ?  `
+		pars = append(pars, industrialManagementId, source)
 		total, e := models.GetCygxUserLabelCount(condition, pars)
 		if e != nil {
 			err = errors.New("GetCygxProductInteriorCount" + e.Error())
@@ -89,8 +91,8 @@ func IndustryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 			item.Email = user.Email
 			item.Label = label
 			item.SourceId = industrialManagementId
-			item.Source = 1
-			item.IsFollow = 1
+			item.Source = source
+			item.IsFollow = isFllow
 			item.CreateTime = time.Now()
 			item.CreateTime = time.Now()
 			_, e = models.AddCygxUserLabel(item)
@@ -100,7 +102,7 @@ func IndustryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 			}
 		} else {
 			//source 来源1:产业、2：系列
-			e = models.UpdateCygxUserLabelIsFollow(isFllow, industrialManagementId, 1, label)
+			e = models.UpdateCygxUserLabelIsFollow(isFllow, industrialManagementId, source, label)
 			if e != nil {
 				err = errors.New("UpdateCygxUserLabelIsFollow" + e.Error())
 				return