@@ -428,6 +428,11 @@ func syncESAndSendMessage(reports []reportDao.Report) (err error) {
if err != nil {
logger.Error("隐藏热度搜索失败,reportId::%d,err:%v", report.ID, err)
}
+ } else {
+ err = userDao.ShowFlows(report.ID, userDao.ReportSourceType)
+ if err != nil {
+ logger.Error("重置热度搜索失败,reportId::%d,err:%v", report.ID, err)
+ }
} else {
insert := ESReport{
@@ -52,3 +52,9 @@ func HiddenFlows(id int, sourceType SourceType) (err error) {
err = db.Table(userSourceClickFlows).Where("source_type=? and source_id =?", sourceType, id).Update("hidden", 1).Error
return
+
+func ShowFlows(id int, sourceType SourceType) (err error) {
+ db := models.Main()
+ err = db.Table(userSourceClickFlows).Where("source_type=? and source_id =?", sourceType, id).Update("hidden", 0).Error
+ return
+}