用户搜索记录统计

controllers/activity.go

@@ -370,16 +370,6 @@ func (this *ActivityCoAntroller) ActivityList() {
 		keyWordItem.PageType = "ActivitSearch"
 		keyWordItem.CreateTime = time.Now()
 		go models.AddUserSearchKeyWord(keyWordItem)
-
-		cacheKey := fmt.Sprint("Search_uid:", user.UserId, "_KeyWord:", keyWordSearch, "_Source:", 6)
-		isExist := utils.Rc.IsExist(cacheKey)
-		if !isExist {
-			setNX := utils.Rc.SetNX(cacheKey, keyWordSearch, time.Minute*1)
-			if !setNX {
-				go utils.SendAlarmMsg("记录用户搜索活动关键词失败，设置Redis Key 过期时间失败：key"+cacheKey, 3)
-			}
-			go services.AddUserSearchLog(user, keyWordSearch, 6)
-		}
 	}
 	resp := new(models.GetCygxActivityListRep)
 	//处理音频回放
@@ -3063,7 +3053,7 @@ func (this *ActivityCoAntroller) LabelTypeListV5() {
 		return
 	}
 	var startSize int
-	pageSize = 8
+	pageSize = 20
 	var sortTime string
 	var pars []interface{}
 	//活动可见限制

controllers/config.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_cygx/models"
+	"hongze/hongze_cygx/services"
 	"time"
 )
 
@@ -176,3 +177,41 @@ func (this *BaseConfigController) HotDetail() {
 	br.Success = true
 	br.Data = resp
 }
+
+// @Title 用户搜索记录统计
+// @Description 用户搜索记录统计
+// @Param   KeyWord   query   string  false       "搜索关键词"
+// @Success Ret=200 新增成功
+// @router /user/search/keyWordLog [post]
+func (this *ConfigController) KeyWordLog() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	var req models.CygxSearchKeyWordLogRep
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
+	if err != nil {
+		br.Msg = "参数解析异常！"
+		br.ErrMsg = "参数解析失败，Err:" + err.Error()
+		return
+	}
+	keyWord := req.KeyWord
+	if keyWord == "" {
+		br.Msg = "搜索内容不能为空"
+		return
+	}
+	user := this.User
+	if user == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，SysUser Is Empty"
+		br.Ret = 408
+		return
+	}
+	if keyWord != "" {
+		go services.AddUserSearchLog(user, keyWord, 1)
+	}
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "新增成功"
+}

controllers/report.go

@@ -2476,7 +2476,7 @@ func (this *ReportController) SearchReport() {
 		keyWordItem.PageType = "ReortSearch"
 		keyWordItem.CreateTime = time.Now()
 		go models.AddUserSearchKeyWord(keyWordItem)
-		go services.AddUserSearchLog(user, keyWord, 5)
+		//go services.AddUserSearchLog(user, keyWord, 5)
 	}
 	if len(listYx) == 0 {
 		listYx = make([]*models.ArticleCollectionResp, 0)
@@ -2602,8 +2602,6 @@ func (this *ReportController) SearchResource() {
 		keyWordItem.PageType = "ReortSearch"
 		keyWordItem.CreateTime = time.Now()
 		go models.AddUserSearchKeyWord(keyWordItem)
-
-		go services.AddUserSearchLog(user, keyWord, 4)
 	}
 
 	resp := new(models.SearchResourceResp)
@@ -2914,7 +2912,7 @@ func (this *ReportController) SearchReportAndResource() {
 		keyWordItem.PageType = "ReortSearch"
 		keyWordItem.CreateTime = time.Now()
 		go models.AddUserSearchKeyWord(keyWordItem)
-		go services.AddUserSearchLog(user, keyWord, 5)
+		//go services.AddUserSearchLog(user, keyWord, 5)
 	}
 
 	resp.ListHzResource = listHzResource

models/search_key_word_log.go

@@ -18,6 +18,10 @@ type CygxSearchKeyWordLog struct {
 	Source      int       `description:"来源；1:纪要、2：图表、3：纪要/图表、4：产业资源包、5：报告、6：活动"`
 }
 
+type CygxSearchKeyWordLogRep struct {
+	KeyWord string `description:"搜索关键词"`
+}
+
 //新增搜索
 func AddSearchKeyWordLog(item *CygxSearchKeyWordLog) (lastId int64, err error) {
 	o := orm.NewOrm()

routers/commentsRouter.go

@@ -664,6 +664,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:ConfigController"] = append(beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:ConfigController"],
+        beego.ControllerComments{
+            Method: "KeyWordLog",
+            Router: `/user/search/keyWordLog`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:HomeController"] = append(beego.GlobalControllerRouter["hongze/hongze_cygx/controllers:HomeController"],
         beego.ControllerComments{
             Method: "ListHomeArtAndChart",

services/activity.go

@@ -160,6 +160,7 @@ func SendEmailFileToExpert(cont context.Context) (err error) {
 	}
 
 	for _, v := range listActivity {
+		time.Sleep(5 * time.Second) //延时五秒，避免邮件发送不成功
 		activityInfo, _ := models.GetAddActivityInfoById(v.ActivityId)
 		if activityInfo == nil {
 			msg = "活动不存在，Err:activityId：" + strconv.Itoa(v.ActivityId)
@@ -1652,16 +1653,6 @@ func AddActivitykeyWordSearch(keyWordSearch string, user *models.WxUserItem) {
 		keyWordItem.PageType = "ActivitSearch"
 		keyWordItem.CreateTime = time.Now()
 		go models.AddUserSearchKeyWord(keyWordItem)
-
-		cacheKey := fmt.Sprint("Search_uid:", user.UserId, "_KeyWord:", keyWordSearch, "_Source:", 6)
-		isExist := utils.Rc.IsExist(cacheKey)
-		if !isExist {
-			setNX := utils.Rc.SetNX(cacheKey, keyWordSearch, time.Minute*1)
-			if !setNX {
-				go utils.SendAlarmMsg("记录用户搜索活动关键词失败，设置Redis Key 过期时间失败：key"+cacheKey, 3)
-			}
-			go AddUserSearchLog(user, keyWordSearch, 6)
-		}
 	}
 }
 

services/keyword.go

@@ -9,11 +9,11 @@ import (
 
 //AddSearchKeyWord 记录用户搜索关键词
 func AddSearchKeyWord(user *models.WxUserItem, keyWord string, source int) (err error) {
-	cacheKey := fmt.Sprint("Search_uid:", user.UserId, "_KeyWord:", keyWord, "_Source:", source)
-	isExist := utils.Rc.IsExist(cacheKey)
-	if isExist {
-		return err
-	}
+	//cacheKey := fmt.Sprint("Search_uid:", user.UserId, "_KeyWord:", keyWord, "_Source:", source)
+	//isExist := utils.Rc.IsExist(cacheKey)
+	//if isExist {
+	//	return err
+	//}
 	defer func() {
 		if err != nil {
 			go utils.SendAlarmMsg(" 记录用户搜索关键词失败"+err.Error(), 2)
@@ -30,12 +30,12 @@ func AddSearchKeyWord(user *models.WxUserItem, keyWord string, source int) (err
 	keyWordItem.CompanyName = user.CompanyName
 	keyWordItem.RealName = user.RealName
 	_, err = models.AddSearchKeyWord(keyWordItem)
-	go AddUserSearchLog(user, keyWord, source)
-	//一分钟之内的相同搜索词不重复记录
-	setNX := utils.Rc.SetNX(cacheKey, keyWord, time.Minute*1)
-	if !setNX {
-		go utils.SendAlarmMsg("记录用户搜索关键词失败，设置Redis Key 过期时间失败：key"+cacheKey, 3)
-	}
+	//go AddUserSearchLog(user, keyWord, source)
+	////一分钟之内的相同搜索词不重复记录
+	//setNX := utils.Rc.SetNX(cacheKey, keyWord, time.Minute*1)
+	//if !setNX {
+	//	go utils.SendAlarmMsg("记录用户搜索关键词失败，设置Redis Key 过期时间失败：key"+cacheKey, 3)
+	//}
 	return
 }