no message

services/cygx_activity_video_history.go

@@ -55,7 +55,10 @@ func AddActivityVideoHistory(user *models.WxUserItem, activityId, playSeconds in
 		return
 	}
 	key := utils.CYGX_VIDEO_HISTORY_KEY + utils.CYGX_OBJ_ACTIVITYVIDEO + strconv.Itoa(activityId) + "_" + strconv.Itoa(user.UserId)
-
+	if utils.Rc.IsExist(key) {
+		return
+	}
+	utils.Rc.Put(key, 1, 10*time.Minute)
 	var err error
 	defer func() {
 		if err != nil {
@@ -88,37 +91,51 @@ func AddActivityVideoHistory(user *models.WxUserItem, activityId, playSeconds in
 	if sellerItem != nil {
 		item.SellerName = sellerItem.RealName
 	}
-
-	if !utils.Rc.IsExist(key) {
-		//添加记录
-		e = models.AddCygxActivityVideoHistory(item)
-		if e != nil {
-			err = errors.New("AddCygxActivityVideoHistory, Err: " + e.Error())
-			return
-		}
-		//播放记录加1
-		e = models.UpdateActivityVideoCounts(activityId)
-		if e != nil {
-			err = errors.New("UpdateActivityVideoCounts, Err: " + e.Error())
-			return
-		}
-		//设置消息提醒
-		go ActivityVideoUserRmind(user, activityId, 1)
-
-		utils.Rc.Put(key, 1, 10*time.Minute)
-	} else {
-		lastItem, e := models.GetLastCygxActivityVideoHistory(activityId, user.UserId)
-		if e != nil {
-			err = errors.New("GetLastCygxActivityVideoHistory, Err: " + e.Error())
-			return
-		}
-		//更新播放时长
-		e = models.UpdateLastCygxActivityVideoHistory(strconv.Itoa(playSeconds), lastItem.Id)
-		if e != nil {
-			err = errors.New("UpdateLastCygxActivityVideoHistory, Err: " + e.Error())
-			return
-		}
+	//添加记录
+	e = models.AddCygxActivityVideoHistory(item)
+	if e != nil {
+		err = errors.New("AddCygxActivityVideoHistory, Err: " + e.Error())
+		return
 	}
+	//播放记录加1
+	e = models.UpdateActivityVideoCounts(activityId)
+	if e != nil {
+		err = errors.New("UpdateActivityVideoCounts, Err: " + e.Error())
+		return
+	}
+	//设置消息提醒
+	go ActivityVideoUserRmind(user, activityId, 1)
+
+	//if !utils.Rc.IsExist(key) {
+	//	//添加记录
+	//	e = models.AddCygxActivityVideoHistory(item)
+	//	if e != nil {
+	//		err = errors.New("AddCygxActivityVideoHistory, Err: " + e.Error())
+	//		return
+	//	}
+	//	//播放记录加1
+	//	e = models.UpdateActivityVideoCounts(activityId)
+	//	if e != nil {
+	//		err = errors.New("UpdateActivityVideoCounts, Err: " + e.Error())
+	//		return
+	//	}
+	//	//设置消息提醒
+	//	go ActivityVideoUserRmind(user, activityId, 1)
+	//
+	//	utils.Rc.Put(key, 1, 10*time.Minute)
+	//} else {
+	//	lastItem, e := models.GetLastCygxActivityVideoHistory(activityId, user.UserId)
+	//	if e != nil {
+	//		err = errors.New("GetLastCygxActivityVideoHistory, Err: " + e.Error())
+	//		return
+	//	}
+	//	//更新播放时长
+	//	e = models.UpdateLastCygxActivityVideoHistory(strconv.Itoa(playSeconds), lastItem.Id)
+	//	if e != nil {
+	//		err = errors.New("UpdateLastCygxActivityVideoHistory, Err: " + e.Error())
+	//		return
+	//	}
+	//}
 
 	////小程序端的回传两次，第一次没有播放时长，第二次有播放时长
 	//if playSeconds != 0 {