dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TelRiskLevelLow     = 1
	TelRiskLevelMedium  = 2
	TelRiskLevelHigh    = 3
	TelRiskLevelUnknown = 4
)

tel level.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dao 

type Dao struct {
	// contains filtered or unexported fields
}

Dao event dao def.

func New 

func New(c *conf.Config) (d *Dao)

New create instance of dao and return.

func (*Dao) AddBlockCache 

func (d *Dao) AddBlockCache(c context.Context, mid int64, score int8, blockNo int64) (err error)

AddBlockCache add block cache.

func (*Dao) AddEvent 

func (d *Dao) AddEvent(c context.Context, event *model.Event) (id int64, err error)

AddEvent insert service to db.

func (*Dao) AddPunishmentQueue 

func (d *Dao) AddPunishmentQueue(c context.Context, mid int64, blockNo int64) (err error)

AddPunishmentQueue insert punishment queue.

func (*Dao) AddService 

func (d *Dao) AddService(c context.Context, service *model.Service) (id int64, err error)

AddService insert service to db.

func (*Dao) AddTelLevelInfo 

func (d *Dao) AddTelLevelInfo(c context.Context, t *model.TelRiskLevel) (id int64, err error)

AddTelLevelInfo add tel level info.

func (*Dao) AddUserInfoCache 

func (d *Dao) AddUserInfoCache(c context.Context, ui *model.UserInfo) (err error)

AddUserInfoCache add info to cache , return err if key is exist already.

func (*Dao) AllEvent 

func (d *Dao) AllEvent(c context.Context) (list []*model.Event, err error)

AllEvent all event.

func (*Dao) AuditInfo 

func (d *Dao) AuditInfo(c context.Context, mid int64, remoteIP string) (rs *model.AuditInfo, err error)

AuditInfo get user audit info

func (*Dao) BeginTran 

func (d *Dao) BeginTran(c context.Context) (*sql.Tx, error)

BeginTran begin transaction.

func (*Dao) BlockAccount 

func (d *Dao) BlockAccount(c context.Context, mid int64) (err error)

BlockAccount block account.

func (*Dao) BlockMidCache 

func (d *Dao) BlockMidCache(c context.Context, batchNo int64, num int64) (res []int64, err error)

BlockMidCache get wait block mids.

func (*Dao) Close 

func (d *Dao) Close()

Close close all db connections.

func (*Dao) Configs 

func (d *Dao) Configs(c context.Context) (res map[string]string, err error)

Configs spy system configs.

func (*Dao) DelInfoCache 

func (d *Dao) DelInfoCache(c context.Context, mid int64) (err error)

DelInfoCache delete info cache.

func (*Dao) Event 

func (d *Dao) Event(c context.Context, eventName string) (event *model.Event, err error)

Event get event from db.

func (*Dao) EventHistoryByMidAndEvent 

func (d *Dao) EventHistoryByMidAndEvent(c context.Context, mid int64, eventID int64) (res *model.UserEventHistory, err error)

EventHistoryByMidAndEvent get one event history with mid and eventID from db.

func (*Dao) Factor 

func (d *Dao) Factor(c context.Context, serviceID, eventID int64, riskLevel int8) (factor *model.Factor, err error)

Factor get factor from db.

func (*Dao) FactorGroup 

func (d *Dao) FactorGroup(c context.Context, groupName string) (factorGroup *model.FactorGroup, err error)

FactorGroup get factor group from db.

func (*Dao) HistoryList 

func (d *Dao) HistoryList(c context.Context, mid int64, size int) (res []*model.UserEventHistory, err error)

HistoryList query .

func (*Dao) Ping 

func (d *Dao) Ping(c context.Context) (err error)

Ping check db health.

func (*Dao) PingRedis 

func (d *Dao) PingRedis(c context.Context) (err error)

PingRedis check redis connection

func (*Dao) ProfileInfo 

func (d *Dao) ProfileInfo(c context.Context, mid int64, remoteIP string) (profile *model.ProfileInfo, err error)

ProfileInfo get user profile info from account service.

func (*Dao) PubScoreChange 

func (d *Dao) PubScoreChange(c context.Context, mid int64, msg interface{}) (err error)

PubScoreChange pub spy score change msg into databus.

func (*Dao) RegisterProtection 

func (d *Dao) RegisterProtection(c context.Context, args url.Values, ip string) (level int8, err error)

RegisterProtection register protection.

func (*Dao) SecurityLogin 

func (d *Dao) SecurityLogin(c context.Context, mid int64, reason string) (err error)

SecurityLogin security login

func (*Dao) Service 

func (d *Dao) Service(c context.Context, serviceName string) (service *model.Service, err error)

Service get service from db.

func (*Dao) SetNXLockCache 

func (d *Dao) SetNXLockCache(c context.Context, k int64) (res bool, err error)

SetNXLockCache redis lock.

func (*Dao) SetUserInfoCache 

func (d *Dao) SetUserInfoCache(c context.Context, ui *model.UserInfo) (err error)

SetUserInfoCache set info cache.

func (*Dao) StatListByID 

func (d *Dao) StatListByID(c context.Context, id int64) (list []*model.Statistics, err error)

StatListByID stat list by id.

func (*Dao) StatListByIDAndMid 

func (d *Dao) StatListByIDAndMid(c context.Context, mid, id int64) (list []*model.Statistics, err error)

StatListByIDAndMid stat list by id.

func (*Dao) StatListByMid 

func (d *Dao) StatListByMid(c context.Context, mid int64) (list []*model.Statistics, err error)

StatListByMid stat list by mid.

func (*Dao) TelInfo 

func (d *Dao) TelInfo(c context.Context, mid int64) (tel *model.TelInfo, err error)

TelInfo tel info.

func (*Dao) TelLevel 

func (d *Dao) TelLevel(c context.Context, mid int64) (res *model.TelRiskLevel, err error)

TelLevel tel level.

func (*Dao) TelRiskLevel 

func (d *Dao) TelRiskLevel(c context.Context, mid int64) (riskLevel int8, err error)

TelRiskLevel tel risk level.

func (*Dao) TxAddEventHistory 

func (d *Dao) TxAddEventHistory(c context.Context, tx *sql.Tx, ueh *model.UserEventHistory) (err error)

TxAddEventHistory insert user_event_history.

func (*Dao) TxAddInfo 

func (d *Dao) TxAddInfo(c context.Context, tx *sql.Tx, info *model.UserInfo) (id int64, err error)

TxAddInfo add user info.

func (*Dao) TxAddPunishment 

func (d *Dao) TxAddPunishment(c context.Context, tx *sql.Tx, mid int64, t int8, reason string) (err error)

TxAddPunishment insert punishment.

func (*Dao) TxAddPunishmentQueue 

func (d *Dao) TxAddPunishmentQueue(c context.Context, tx *sql.Tx, mid int64, blockNo int64) (err error)

TxAddPunishmentQueue insert punishment queue.

func (*Dao) TxClearReliveTimes 

func (d *Dao) TxClearReliveTimes(c context.Context, tx *sql.Tx, ui *model.UserInfo) (err error)

TxClearReliveTimes do clear user relivetimes.

func (*Dao) TxUpdateBaseScore 

func (d *Dao) TxUpdateBaseScore(c context.Context, tx *sql.Tx, ui *model.UserInfo) (err error)

TxUpdateBaseScore do update user base score.

func (*Dao) TxUpdateEventScore 

func (d *Dao) TxUpdateEventScore(c context.Context, tx *sql.Tx, mid int64, escore, score int8) (err error)

TxUpdateEventScore update user event score.

func (*Dao) TxUpdateEventScoreReLive 

func (d *Dao) TxUpdateEventScoreReLive(c context.Context, tx *sql.Tx, mid int64, escore, score int8) (err error)

TxUpdateEventScoreReLive update event score and times

func (*Dao) TxUpdateInfo 

func (d *Dao) TxUpdateInfo(c context.Context, tx *sql.Tx, info *model.UserInfo) (err error)

TxUpdateInfo insert or update user info by mid.

func (*Dao) UnicomGiftState 

func (d *Dao) UnicomGiftState(c context.Context, mid int64) (state int, err error)

UnicomGiftState get unicom gift state by mid from account service.

func (*Dao) UserInfo 

func (d *Dao) UserInfo(c context.Context, mid int64) (res *model.UserInfo, err error)

UserInfo get info by mid.

func (*Dao) UserInfoCache 

func (d *Dao) UserInfoCache(c context.Context, mid int64) (ui *model.UserInfo, err error)

UserInfoCache get user info to cache.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.