http

Documentation

Index

• Constants
• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) Close()
  • func (d *Dao) FilterMulti(c context.Context, area string, msg string) (hits []string, err error)
  • func (d *Dao) GetRole(c context.Context, bid, uid int64) (roles []*task.Role, err error)
  • func (d *Dao) GetUIDs(c context.Context, unames string) (uids map[string]int64, err error)
  • func (d *Dao) GetUdepartment(c context.Context, uids []int64) (udepartment map[int64]string, err error)
  • func (d *Dao) GetUnames(c context.Context, uids []int64) (unames map[int64]string, err error)
  • func (d *Dao) GetUserRoles(c context.Context, uid int64) (roles []*task.Role, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) QueryLogSearch(c context.Context, args *model.ParamsQueryLog, cm model.EsCommon) (resp *model.SearchLogResult, err error)
  • func (d *Dao) ResourceES(c context.Context, arg *model.SearchParams) (sres *model.SearchRes, err error)
  • func (d *Dao) SyncResource(c context.Context, act *model.Action, ropt map[string]interface{}) (code int, err error)
  • func (d *Dao) Upload(c context.Context, fileName string, fileType string, timing int64, data []byte) (location string, err error)
  • func (d *Dao) UpsertES(c context.Context, rsc []*model.UpsertItem) (err error)
• type Res

Constants

const (
	LogMinYear = 2018
	LogMinTime = "2018-11-01 10:00:00"
)

const

Types

type Dao

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

Dao dao

func New

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

New init mysql db

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) FilterMulti

func (d *Dao) FilterMulti(c context.Context, area string, msg string) (hits []string, err error)

FilterMulti .批量过滤

func (*Dao) GetRole

func (d *Dao) GetRole(c context.Context, bid, uid int64) (roles []*task.Role, err error)

GetRole 获取用户对应业务下的角色

func (*Dao) GetUIDs

func (d *Dao) GetUIDs(c context.Context, unames string) (uids map[string]int64, err error)

GetUIDs .

func (*Dao) GetUdepartment

func (d *Dao) GetUdepartment(c context.Context, uids []int64) (udepartment map[int64]string, err error)

GetUdepartment .

func (*Dao) GetUnames

func (d *Dao) GetUnames(c context.Context, uids []int64) (unames map[int64]string, err error)

GetUnames .

func (*Dao) GetUserRoles

func (d *Dao) GetUserRoles(c context.Context, uid int64) (roles []*task.Role, err error)

GetUserRoles 获取用户在所有业务下的角色

func (*Dao) Ping

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

Ping dao ping

func (*Dao) QueryLogSearch

func (d *Dao) QueryLogSearch(c context.Context, args *model.ParamsQueryLog, cm model.EsCommon) (resp *model.SearchLogResult, err error)

QueryLogSearch .

func (*Dao) ResourceES

func (d *Dao) ResourceES(c context.Context, arg *model.SearchParams) (sres *model.SearchRes, err error)

ResourceES search archives by es.

func (*Dao) SyncResource

func (d *Dao) SyncResource(c context.Context, act *model.Action, ropt map[string]interface{}) (code int, err error)

SyncResource 同步到业务方

func (*Dao) Upload

func (d *Dao) Upload(c context.Context, fileName string, fileType string, timing int64, data []byte) (location string, err error)

Upload upload picture or log file to bfs

func (*Dao) UpsertES

func (d *Dao) UpsertES(c context.Context, rsc []*model.UpsertItem) (err error)

UpsertES 更新搜索

type Res

type Res struct {
	Code int64 `json:"code"`
	Data []struct {
		Level int64  `json:"level"`
		Msg   string `json:"msg"`
	} `json:"data"`
}

Res 筛选结果