过滤下架产品

domian/user/user_source_click_flow_service.go

@@ -54,6 +54,10 @@ func CountReport(record RecordCountDTO) (traceId string, err error) {
 			logger.Error("更新用户研报点击记录失败:%v", err)
 			return
 		}
+		if dbRecord.ReadDurationSeconds > 0 {
+			logger.Warn("重复用户研报点击记录，不做处理，traceId:%s", traceId)
+			return
+		}
 		currTime := time.Now()
 		dbRecord.ReadDurationSeconds = int64(currTime.Sub(dbRecord.ClickTime).Seconds())
 		err = userDao.UpdateSourceClicks(dbRecord)
@@ -89,6 +93,10 @@ func CountMedia(record RecordCountDTO, mediaType string) (traceId string, err er
 			logger.Error("更新用户研报点击记录失败:%v", err)
 			return
 		}
+		if dbRecord.ReadDurationSeconds > 0 {
+			logger.Warn("重复用户媒体点击记录，不做处理，traceId:%s", traceId)
+			return
+		}
 		currTime := time.Now()
 		dbRecord.ReadDurationSeconds = int64(currTime.Sub(dbRecord.ClickTime).Seconds())
 		err = userDao.UpdateSourceClicks(dbRecord)