feat:完善项目信息
This commit is contained in:
@ -1,21 +1,48 @@
|
|||||||
package event
|
package event
|
||||||
|
|
||||||
|
import (
|
||||||
|
"SciencesServer/app/common/model"
|
||||||
|
"SciencesServer/serve/logger"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
// Visit 浏览事件数据处理
|
// Visit 浏览事件数据处理
|
||||||
type Visit struct{}
|
type Visit struct{}
|
||||||
|
|
||||||
// Handle 操作处理
|
// Handle 操作处理
|
||||||
// @
|
// @params: uid,kind,object
|
||||||
func (this *Visit) Handle(arg ...interface{}) {
|
func (this *Visit) Handle(arg ...interface{}) {
|
||||||
//&model.UserVisit{
|
uid := arg[0].(uint64)
|
||||||
// Model: model.Model{},
|
kind := arg[1].(model.UserVisitKind)
|
||||||
// UID: 0,
|
objectID := arg[2].(uint64)
|
||||||
// Kind: 0,
|
|
||||||
// ObjectID: 0,
|
mUserVisit := model.NewUserVisit()
|
||||||
// Count: 0,
|
|
||||||
// Date: time.Time{},
|
isExist, err := model.FirstField(mUserVisit, []string{"id", "uid", "created_at"}, model.NewWhere("uid", uid),
|
||||||
// ModelDeleted: model.ModelDeleted{},
|
model.NewWhere("kind", kind), model.NewWhere("object_id", objectID))
|
||||||
// ModelAt: model.ModelAt{},
|
|
||||||
//}
|
if err != nil {
|
||||||
|
logger.ErrorF("Event 查询用户访问记录【%d - %d - %d】错误:%v", err, uid, kind, objectID)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if isExist {
|
||||||
|
if err = model.Updates(mUserVisit, map[string]interface{}{
|
||||||
|
"count": gorm.Expr("visits + ?", 1), "date": time.Now(),
|
||||||
|
}); err != nil {
|
||||||
|
logger.ErrorF("Event 更新用户访问记录【%d - %d - %d】错误:%v", err, uid, kind, objectID)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
mUserVisit.UID = uid
|
||||||
|
mUserVisit.Kind = kind
|
||||||
|
mUserVisit.ObjectID = objectID
|
||||||
|
mUserVisit.Count = 1
|
||||||
|
mUserVisit.Date = time.Now()
|
||||||
|
if err = model.Create(mUserVisit); err != nil {
|
||||||
|
logger.ErrorF("Event 保存用户访问记录【%d - %d - %d】错误:%v", err, uid, kind, objectID)
|
||||||
|
}
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewVisit() *Visit {
|
func NewVisit() *Visit {
|
||||||
|
@ -23,6 +23,8 @@ func Init() {
|
|||||||
service.Subscribe(config.EventForConsumeProduce, event.NewConsume())
|
service.Subscribe(config.EventForConsumeProduce, event.NewConsume())
|
||||||
// 活动加入监听
|
// 活动加入监听
|
||||||
service.Subscribe(config.EventForActivityJoinProduce, event.NewActivityJoin())
|
service.Subscribe(config.EventForActivityJoinProduce, event.NewActivityJoin())
|
||||||
|
// 浏览录入监听
|
||||||
|
service.Subscribe(config.EventForVisitProduce, event.NewVisit())
|
||||||
// 开启权限
|
// 开启权限
|
||||||
service.NewAuth().Register()(config.EngineInfo.Mode, orm.GetDB(), model.NewSysAuthRule().TableName())
|
service.NewAuth().Register()(config.EngineInfo.Mode, orm.GetDB(), model.NewSysAuthRule().TableName())
|
||||||
// 开启缓存存储
|
// 开启缓存存储
|
||||||
|
@ -36,6 +36,7 @@ const (
|
|||||||
EventForSysLogProduce string = "sys_log_produce"
|
EventForSysLogProduce string = "sys_log_produce"
|
||||||
EventForConsumeProduce string = "consume_produce"
|
EventForConsumeProduce string = "consume_produce"
|
||||||
EventForActivityJoinProduce string = "activity_join_produce"
|
EventForActivityJoinProduce string = "activity_join_produce"
|
||||||
|
EventForVisitProduce string = "visit_produce"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
Reference in New Issue
Block a user