过滤下架产品

domian/user/user_source_click_flow_service.go

@@ -43,8 +43,6 @@ func generateTraceId(productType string) string {
 func CountReport(record RecordCountDTO) (traceId string, err error) {
 	dao := convertUserToReportFlow(record)
 	if dao.TraceId == "" {
-		logger.Info("插入用户研报点击记录")
-		_ = GetUserAndCountReadTimes(record.UserId)
 		traceId = generateTraceId(string(dao.SourceType))
 		dao.TraceId = traceId
 		err = userDao.CountSourceClicks(dao)
@@ -59,6 +57,8 @@ func CountReport(record RecordCountDTO) (traceId string, err error) {
 		currTime := time.Now()
 		dbRecord.ReadDurationSeconds = int64(currTime.Sub(dbRecord.ClickTime).Seconds())
 		err = userDao.UpdateSourceClicks(dbRecord)
+		logger.Info("插入用户研报点击记录")
+		_ = GetUserAndCountReadTimes(record.UserId)
 	}
 	if err != nil {
 		logger.Error("插入用户研报点击记录失败:%v", err)
@@ -78,8 +78,7 @@ func CountMedia(record RecordCountDTO, mediaType string) (traceId string, err er
 	record.SourceType = sourceType
 	dao := convertUserToMediaFlow(record)
 	if dao.TraceId == "" {
-		logger.Info("插入用户媒体点击记录")
-		_ = GetUserAndCountReadTimes(record.UserId)
+
 		traceId = generateTraceId(string(dao.SourceType))
 		dao.TraceId = traceId
 		err = userDao.CountSourceClicks(dao)
@@ -94,6 +93,8 @@ func CountMedia(record RecordCountDTO, mediaType string) (traceId string, err er
 		currTime := time.Now()
 		dbRecord.ReadDurationSeconds = int64(currTime.Sub(dbRecord.ClickTime).Seconds())
 		err = userDao.UpdateSourceClicks(dbRecord)
+		logger.Info("插入用户媒体点击记录")
+		_ = GetUserAndCountReadTimes(record.UserId)
 	}
 	if err != nil {
 		logger.Error("插入用户媒体点击记录失败:%v", err)