过滤下架产品

domian/user/user_source_click_flow_service.go

@@ -59,6 +59,9 @@ func CountReport(record RecordCountDTO) (traceId string, err error) {
 			return
 		}
 		currTime := time.Now()
+		fmt.Printf("更新用户研报点击记录,traceId:%s", traceId)
+		fmt.Printf("当前时间%v:", currTime)
+		fmt.Printf("点击时间%v:", dbRecord.ClickTime)
 		dbRecord.ReadDurationSeconds = currTime.Sub(dbRecord.ClickTime).Milliseconds()
 		err = userDao.UpdateSourceClicks(dbRecord)
 		logger.Info("插入用户研报点击记录")
@@ -97,6 +100,9 @@ func CountMedia(record RecordCountDTO, mediaType string) (traceId string, err er
 			_ = GetUserAndCountReadTimes(record.UserId)
 		}
 		currTime := time.Now()
+		fmt.Printf("更新用户研报点击记录,traceId:%s", traceId)
+		fmt.Printf("当前时间%v:", currTime)
+		fmt.Printf("点击时间%v:", dbRecord.ClickTime)
 		dbRecord.ReadDurationSeconds = currTime.Sub(dbRecord.ClickTime).Milliseconds()
 		err = userDao.UpdateSourceClicks(dbRecord)
 		logger.Info("插入用户媒体点击记录")

models/report/report.go

@@ -391,7 +391,7 @@ func GetReportClassifyById(id int) (classifyId int, err error) {
 	db := models.Main()
 	err = db.Model(&Report{}).
 		Select("classify_id").
-		Where("orgId =? and source ='ETA' ", id).Scan(&classifyId).Error
+		Where("org_id=? and source ='ETA' ", id).Scan(&classifyId).Error
 	return
 }