|
@@ -32,6 +32,7 @@ func AddSearchKeyWord(user *models.WxUserItem, keyWord string, source int) (err
|
|
|
keyWordItem.RealName = user.RealName
|
|
|
_, err = models.AddSearchKeyWord(keyWordItem)
|
|
|
go AddUserSearchLog(user, keyWord, source)
|
|
|
+ go SearchKeywordUserRmind(user, keyWord)
|
|
|
////一分钟之内的相同搜索词不重复记录
|
|
|
//setNX := utils.Rc.SetNX(cacheKey, keyWord, time.Minute*1)
|
|
|
//if !setNX {
|
|
@@ -60,7 +61,6 @@ func AddUserSearchLog(user *models.WxUserItem, keyWord string, source int) (err
|
|
|
item.RealName = user.RealName
|
|
|
item.Source = source
|
|
|
_, err = models.AddSearchKeyWordLog(item)
|
|
|
- go SearchKeywordUserRmind(user, keyWord)
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -96,9 +96,9 @@ func SearchKeywordUserRmind(user *models.WxUserItem, keyWord string) (err error)
|
|
|
err = errors.New("GetSellerByAdminId, Err: " + e.Error())
|
|
|
return
|
|
|
}
|
|
|
- first = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动:搜索")
|
|
|
- keyword1 = first
|
|
|
- keyword2 = "搜索关键词:" + keyWord
|
|
|
+ first = fmt.Sprint("互动:搜索,", user.RealName, "--", user.CompanyName)
|
|
|
+ keyword1 = "搜索关键词:" + keyWord
|
|
|
+ keyword2 = first
|
|
|
openIdArr := make([]string, 0)
|
|
|
for _, v := range openIdList {
|
|
|
openIdArr = append(openIdArr, v.OpenId)
|