aa
This commit is contained in:
@@ -211,8 +211,8 @@ func GetJobs(ctx *jxcontext.Context, userIDs []string, categoryIDs, statuss, ven
|
|||||||
dao.UpdateEntity(db, userSearchs[0], "Count", "UpdatedAt")
|
dao.UpdateEntity(db, userSearchs[0], "Count", "UpdatedAt")
|
||||||
} else {
|
} else {
|
||||||
userSearch := &model.UserSearch{
|
userSearch := &model.UserSearch{
|
||||||
UserID: userID,
|
UserID: userID,
|
||||||
Key: keyword,
|
Keyword: keyword,
|
||||||
}
|
}
|
||||||
dao.WrapAddIDCULEntity(userSearch, ctx.GetUserName())
|
dao.WrapAddIDCULEntity(userSearch, ctx.GetUserName())
|
||||||
dao.CreateEntity(db, userSearch)
|
dao.CreateEntity(db, userSearch)
|
||||||
|
|||||||
@@ -741,13 +741,24 @@ type GetUserSerachKeywordResult struct {
|
|||||||
UserSpan []*model.UserSearch `json:"userSpan"`
|
UserSpan []*model.UserSearch `json:"userSpan"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetUserSerachKeyword(ctx *jxcontext.Context) (err error) {
|
func GetUserSerachKeyword(ctx *jxcontext.Context) (getUserSerachKeywordResult *GetUserSerachKeywordResult, err error) {
|
||||||
// var (
|
var (
|
||||||
// db = dao.GetDB()
|
db = dao.GetDB()
|
||||||
// userID = ctx.GetUserID()
|
userID = ctx.GetUserID()
|
||||||
// )
|
userSearchAll []*model.UserSearch
|
||||||
// sql := `
|
userSearch []*model.UserSearch
|
||||||
// SELECT SUM(count) count FROM user_search WHERE
|
)
|
||||||
// `
|
sql := `
|
||||||
return err
|
SELECT keyword, SUM(count) count FROM user_search WHERE created_at > ? GROUP 1 ORDER BY SUM(count) DESC LIMIT 20
|
||||||
|
`
|
||||||
|
sqlParams := []interface{}{time.Now().AddDate(0, -1, 0)}
|
||||||
|
err = dao.GetRows(db, &userSearchAll, sql, sqlParams)
|
||||||
|
getUserSerachKeywordResult.AllSpan = userSearchAll
|
||||||
|
sql2 := `
|
||||||
|
SELECT keyword, SUM(count) count FROM user_search WHERE created_at > ? AND user_id = ? GROUP 1 ORDER BY SUM(count) DESC LIMIT 20
|
||||||
|
`
|
||||||
|
sqlParams2 := []interface{}{time.Now().AddDate(0, -1, 0), userID}
|
||||||
|
err = dao.GetRows(db, &userSearch, sql2, sqlParams2)
|
||||||
|
getUserSerachKeywordResult.UserSpan = userSearch
|
||||||
|
return getUserSerachKeywordResult, err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -402,15 +402,13 @@ func GetUserSearch(db *DaoDB, userID, keyword string) (userSearchs []*model.User
|
|||||||
`
|
`
|
||||||
sqlParams := []interface{}{}
|
sqlParams := []interface{}{}
|
||||||
if userID != "" {
|
if userID != "" {
|
||||||
sql += ` AND user_id = ?`
|
sql += " AND user_id = ?"
|
||||||
sqlParams = append(sqlParams, userID)
|
sqlParams = append(sqlParams, userID)
|
||||||
}
|
}
|
||||||
if keyword != "" {
|
if keyword != "" {
|
||||||
sql += ` AND key = ?`
|
sql += " AND keyword = ?"
|
||||||
sqlParams = append(sqlParams, keyword)
|
sqlParams = append(sqlParams, keyword)
|
||||||
}
|
}
|
||||||
fmt.Println(sql)
|
|
||||||
fmt.Println(sqlParams)
|
|
||||||
err = GetRows(db, &userSearchs, sql, sqlParams)
|
err = GetRows(db, &userSearchs, sql, sqlParams)
|
||||||
return userSearchs, err
|
return userSearchs, err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -264,14 +264,14 @@ type GetUserResult struct {
|
|||||||
type UserSearch struct {
|
type UserSearch struct {
|
||||||
ModelIDCUL
|
ModelIDCUL
|
||||||
|
|
||||||
UserID string `orm:"column(user_id)" json:"userID"` //用户ID
|
UserID string `orm:"column(user_id)" json:"userID"` //用户ID
|
||||||
Key string `json:"key"` //搜索关键字
|
Keyword string `json:"keyword"` //搜索关键字
|
||||||
Count int `json:"count"` //搜索次数
|
Count int `json:"count"` //搜索次数
|
||||||
}
|
}
|
||||||
|
|
||||||
func (v *UserSearch) TableIndex() [][]string {
|
func (v *UserSearch) TableIndex() [][]string {
|
||||||
return [][]string{
|
return [][]string{
|
||||||
[]string{"UserID"},
|
[]string{"UserID"},
|
||||||
[]string{"Key"},
|
[]string{"Keyword"},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user