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: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dao 

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

Dao def

func New 

func New() (d *Dao)

New create instance of Dao

func (*Dao) AccessTokenRedis 

func (d *Dao) AccessTokenRedis(c context.Context, key string) (token string, err error)

AccessTokenRedis get access token from redis

func (*Dao) AddFavorite 

func (d *Dao) AddFavorite(userName string, projID int) (err error)

AddFavorite add favorite project for user

func (*Dao) AddProjectInfo 

func (d *Dao) AddProjectInfo(projectInfo *model.ProjectInfo) (err error)

AddProjectInfo add ProjectInfo

func (*Dao) AddWechatCreateLog 

func (d *Dao) AddWechatCreateLog(req *model.WechatCreateLog) (err error)

AddWechatCreateLog ...

func (*Dao) AwardEmojiByMRIID 

func (d *Dao) AwardEmojiByMRIID(c context.Context, projectID, mrIID int) (AwardEmojis []*model.StatisticsMRAwardEmojis, err error)

AwardEmojiByMRIID ...

func (*Dao) Close 

func (d *Dao) Close()

Close dao.

func (*Dao) ContactInfos 

func (d *Dao) ContactInfos() (contactInfos []*model.ContactInfo, err error)

ContactInfos query all the records in contact_infos

func (*Dao) CountCommitByTime 

func (d *Dao) CountCommitByTime(projID int, since, until string) (total int, err error)

CountCommitByTime ...

func (*Dao) CountMRByTime 

func (d *Dao) CountMRByTime(projID int, since, until string) (total int, err error)

CountMRByTime ...

func (*Dao) CreateAggregateBranch 

func (d *Dao) CreateAggregateBranch(c context.Context, aggregateBranch *model.AggregateBranches) error

CreateAggregateBranch ...

func (*Dao) CreateAggregateReviewer 

func (d *Dao) CreateAggregateReviewer(c context.Context, req *model.AggregateMrReviewer) (err error)

CreateAggregateReviewer ...

func (*Dao) CreateBranch 

func (d *Dao) CreateBranch(c context.Context, branch *model.StatisticsBranches) error

CreateBranch query all the records in contact_infos

func (*Dao) CreateChatLog 

func (d *Dao) CreateChatLog(req *model.WechatChatLog) (err error)

CreateChatLog ...

func (*Dao) CreateCommit 

func (d *Dao) CreateCommit(req *model.StatisticsCommits) (err error)

CreateCommit ...

func (*Dao) CreateContact 

func (d *Dao) CreateContact(contact *model.ContactInfo) (err error)

CreateContact create contact info record

func (*Dao) CreateDiscussion 

func (d *Dao) CreateDiscussion(c context.Context, discussion *model.StatisticsDiscussions) (err error)

CreateDiscussion ...

func (*Dao) CreateIssue 

func (d *Dao) CreateIssue(req *model.StatisticsIssues) (err error)

CreateIssue ...

func (*Dao) CreateJob 

func (d *Dao) CreateJob(req *model.StatisticsJobs) (err error)

CreateJob ...

func (*Dao) CreateMR 

func (d *Dao) CreateMR(c context.Context, req *model.StatisticsMrs) (err error)

CreateMR ...

func (*Dao) CreateMRAwardEmoji 

func (d *Dao) CreateMRAwardEmoji(c context.Context, awardEmoji *model.StatisticsMRAwardEmojis) (err error)

CreateMRAwardEmoji ...

func (*Dao) CreateMember 

func (d *Dao) CreateMember(c context.Context, member *model.StatisticsMembers) (err error)

CreateMember ...

func (*Dao) CreateMessageLog 

func (d *Dao) CreateMessageLog(req *model.WechatMessageLog) (err error)

CreateMessageLog ...

func (*Dao) CreateNote 

func (d *Dao) CreateNote(c context.Context, note *model.StatisticsNotes) (err error)

CreateNote ...

func (*Dao) CreatePipeline 

func (d *Dao) CreatePipeline(req *model.StatisticsPipeline) (err error)

CreatePipeline ...

func (*Dao) CreateRunner 

func (d *Dao) CreateRunner(req *model.StatisticsRunners) (err error)

CreateRunner ...

func (*Dao) DelCommit 

func (d *Dao) DelCommit(projID int, commitID string) (err error)

DelCommit ...

func (*Dao) DelContact 

func (d *Dao) DelContact(contact *model.ContactInfo) (err error)

DelContact delete the contact info with the specified UserID

func (*Dao) DelFavorite 

func (d *Dao) DelFavorite(userName string, projID int) (err error)

DelFavorite delete favorite project for user

func (*Dao) DeleteAggregateBranch 

func (d *Dao) DeleteAggregateBranch(c context.Context, projectID int) error

DeleteAggregateBranch ...

func (*Dao) DeleteData 

func (d *Dao) DeleteData(c context.Context, key string) (err error)

DeleteData delete data info in memcache

func (*Dao) DeleteProjectBranch 

func (d *Dao) DeleteProjectBranch(c context.Context, projectID int) error

DeleteProjectBranch ...

func (*Dao) DeleteRequireVisibleUsersRedis 

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

DeleteRequireVisibleUsersRedis delete the wechat require visible key in redis

func (*Dao) DiscussionsByMRIID 

func (d *Dao) DiscussionsByMRIID(c context.Context, projectID, mrIID int) (discussions []*model.StatisticsDiscussions, err error)

DiscussionsByMRIID ...

func (*Dao) FavoriteProjects 

func (d *Dao) FavoriteProjects(userName string) (favorites []*model.ProjectFavorite, err error)

FavoriteProjects get user's favorite projects

func (*Dao) FindContacts 

func (d *Dao) FindContacts(pn, ps int) (total int64, ars []*model.ContactInfo, err error)

FindContacts find application record by auditor.

func (*Dao) FindMachineLogs 

func (d *Dao) FindMachineLogs(queryRequest *model.QueryContactLogRequest) (total int64, machineLogs []*model.AboundContactLog, err error)

FindMachineLogs Find Machine Logs.

func (*Dao) GetData 

func (d *Dao) GetData(c context.Context, key string, dataMap *map[string]*model.TeamDataResp) (err error)

GetData get data info from memcache

func (*Dao) GetPipeline 

func (d *Dao) GetPipeline(c context.Context, key string) (pipeline *model.PipelineDataResp, err error)

GetPipeline get pipeline info from memcache

func (*Dao) HasAggregateBranch 

func (d *Dao) HasAggregateBranch(c context.Context, projectID int, branchName string) (total int, err error)

HasAggregateBranch ...

func (*Dao) HasAggregateReviewer 

func (d *Dao) HasAggregateReviewer(c context.Context, projectID, mrIID, reviewerID, reviewID int) (total int, err error)

HasAggregateReviewer ...

func (*Dao) HasBranch 

func (d *Dao) HasBranch(c context.Context, projectID int, branchName string) (total int, err error)

HasBranch is exist project branch info in database.

func (*Dao) HasCommit 

func (d *Dao) HasCommit(projID int, commitID string) (total int, err error)

HasCommit ...

func (*Dao) HasDiscussion 

func (d *Dao) HasDiscussion(c context.Context, projectID, mrIID int, discussionID string) (total int, err error)

HasDiscussion ...

func (*Dao) HasIssue 

func (d *Dao) HasIssue(projID, issueID int) (total int, err error)

HasIssue ...

func (*Dao) HasJob 

func (d *Dao) HasJob(projID, jobID int) (total int, err error)

HasJob ...

func (*Dao) HasMR 

func (d *Dao) HasMR(c context.Context, projectID, mrIID int) (total int, err error)

HasMR ...

func (*Dao) HasMRAwardEmoji 

func (d *Dao) HasMRAwardEmoji(c context.Context, projectID, mrIID, awardEmojiID int) (total int, err error)

HasMRAwardEmoji ...

func (*Dao) HasMember 

func (d *Dao) HasMember(c context.Context, projectID, memberID int) (total int, err error)

HasMember ...

func (*Dao) HasNote 

func (d *Dao) HasNote(c context.Context, projectID, noteID int) (total int, err error)

HasNote ...

func (*Dao) HasPipeline 

func (d *Dao) HasPipeline(projID int, pipelineID int) (total int, err error)

HasPipeline ...

func (*Dao) HasProjectInfo 

func (d *Dao) HasProjectInfo(projectID int) (b bool, err error)

HasProjectInfo is exist project info in database.

func (*Dao) HasRunner 

func (d *Dao) HasRunner(projID, runnerID int) (total int, err error)

HasRunner ...

func (*Dao) InsertContactLog 

func (d *Dao) InsertContactLog(contactlog *model.ContactLog) (err error)

InsertContactLog insert machine log.

func (*Dao) ItemRedis 

func (d *Dao) ItemRedis(c context.Context, key string, value interface{}) (err error)

ItemRedis ...

func (*Dao) MRByProjectID 

func (d *Dao) MRByProjectID(c context.Context, projectID int, since *time.Time, until *time.Time) (mrs []*model.StatisticsMrs, err error)

MRByProjectID query mr by projectID

func (*Dao) NewRequest 

func (d *Dao) NewRequest(method, url string, v interface{}) (req *http.Request, err error)

NewRequest ...

func (*Dao) NoteByID 

func (d *Dao) NoteByID(c context.Context, projectID, mrIID, noteID int) (note *model.StatisticsNotes, err error)

NoteByID ...

func (*Dao) NoteByMRIID 

func (d *Dao) NoteByMRIID(c context.Context, projectID, mrIID int) (notes []*model.StatisticsNotes, err error)

NoteByMRIID ...

func (*Dao) Ping 

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

Ping dao.

func (*Dao) PostJSON 

func (d *Dao) PostJSON(c context.Context, uri, ip string, params url.Values, res interface{}, v interface{}) (err error)

PostJSON post http request with json params.

func (*Dao) ProjectExist 

func (d *Dao) ProjectExist(projID int) (exist bool, err error)

ProjectExist check the project exist or not

func (*Dao) ProjectInfoByID 

func (d *Dao) ProjectInfoByID(projectID int) (projectInfo *model.ProjectInfo, err error)

ProjectInfoByID query ProjectInfo by ID

func (*Dao) ProjectsInfo 

func (d *Dao) ProjectsInfo() (projects []*model.ProjectInfo, err error)

ProjectsInfo all the projects in saga

func (*Dao) QueryAllConfigFile 

func (d *Dao) QueryAllConfigFile(c context.Context, sessionID, url string) (resp *model.ConfigData, err error)

QueryAllConfigFile ...

func (*Dao) QueryCommitByID 

func (d *Dao) QueryCommitByID(projID int, commitID string) (commit *model.StatisticsCommits, err error)

QueryCommitByID query commit info by ID

func (*Dao) QueryConfigFileContent 

func (d *Dao) QueryConfigFileContent(c context.Context, sessionID, url string) (content string, err error)

QueryConfigFileContent ...

func (*Dao) QueryConfigInfo 

func (d *Dao) QueryConfigInfo(name, department, business, queryObject string) (total int, err error)

QueryConfigInfo query saga and runner Info.

func (*Dao) QueryFirstAggregateBranch 

func (d *Dao) QueryFirstAggregateBranch(c context.Context, projectID int, branchName string) (branch *model.AggregateBranches, err error)

QueryFirstAggregateBranch ...

func (*Dao) QueryFirstBranch 

func (d *Dao) QueryFirstBranch(c context.Context, projectID int, branchName string) (branch *model.StatisticsBranches, err error)

QueryFirstBranch ...

func (*Dao) QueryJobsByTime 

func (d *Dao) QueryJobsByTime(projID int, req *model.ProjectJobRequest, since, until string) (total int, jobs []*model.StatisticsJobs, err error)

QueryJobsByTime ...

func (*Dao) QueryMemberByID 

func (d *Dao) QueryMemberByID(c context.Context, projectID, memberID int) (member *model.StatisticsMembers, err error)

QueryMemberByID ...

func (*Dao) QueryPipelinesByTime 

func (d *Dao) QueryPipelinesByTime(projID int, req *model.PipelineDataReq, since, until string) (total, statNum int, pipelines []*model.StatisticsPipeline, err error)

QueryPipelinesByTime ...

func (*Dao) QueryProjectBranch 

func (d *Dao) QueryProjectBranch(c context.Context, projectID int) (b []*model.StatisticsBranches, err error)

QueryProjectBranch ...

func (*Dao) QueryProjectCommits 

func (d *Dao) QueryProjectCommits(c context.Context, projectID int) (commits []*model.StatisticsCommits, err error)

QueryProjectCommits ...

func (*Dao) QueryProjectInfo 

func (d *Dao) QueryProjectInfo(ifPage bool, req *model.ProjectInfoRequest) (total int, projectInfo []*model.ProjectInfo, err error)

QueryProjectInfo query Project Info.

func (*Dao) QueryUserByID 

func (d *Dao) QueryUserByID(userID string) (contactInfo *model.ContactInfo, err error)

QueryUserByID query user by user ID

func (*Dao) QueryUserByUserName 

func (d *Dao) QueryUserByUserName(userName string) (contactInfo *model.ContactInfo, err error)

QueryUserByUserName query user by user name

func (*Dao) QueryWechatCreateLog 

func (d *Dao) QueryWechatCreateLog(ifpage bool, req *model.Pagination, wechatCreateInfo *model.WechatCreateLog) (wechatCreateInfos []*model.WechatCreateLog, total int, err error)

QueryWechatCreateLog ...

func (*Dao) RequestConfig 

func (d *Dao) RequestConfig(c context.Context, sessionID, reqUrl string, params url.Values) (resp *model.CommonResp, err error)

RequestConfig ...

func (*Dao) RequireVisibleUsersRedis 

func (d *Dao) RequireVisibleUsersRedis(c context.Context, userMap *map[string]model.RequireVisibleUser) (err error)

RequireVisibleUsersRedis get wechat require visible users from redis

func (*Dao) SetAccessTokenRedis 

func (d *Dao) SetAccessTokenRedis(c context.Context, key, token string, expire int32) (err error)

SetAccessTokenRedis set the access token to redis

func (*Dao) SetData 

func (d *Dao) SetData(c context.Context, key string, dataMap map[string]*model.TeamDataResp) (err error)

SetData set data info to memcache

func (*Dao) SetItemRedis 

func (d *Dao) SetItemRedis(c context.Context, key string, value interface{}, ttl int) (err error)

SetItemRedis ...

func (*Dao) SetPipeline 

func (d *Dao) SetPipeline(c context.Context, key string, pipeline *model.PipelineDataResp) (err error)

SetPipeline set pipeline info info to memcache

func (*Dao) SetRequireVisibleUsersRedis 

func (d *Dao) SetRequireVisibleUsersRedis(c context.Context, contactInfo *model.ContactInfo) (err error)

SetRequireVisibleUsersRedis set wechat require visible users to redis

func (*Dao) Tasks 

func (d *Dao) Tasks(projID, status int) (tasks []*model.Task, err error)

Tasks get all the tasks for the specified project

func (*Dao) UpdateAggregateBranch 

func (d *Dao) UpdateAggregateBranch(c context.Context, projectID int, branchName string, aggregateBranch *model.AggregateBranches) error

UpdateAggregateBranch ...

func (*Dao) UpdateAggregateReviewer 

func (d *Dao) UpdateAggregateReviewer(c context.Context, projectID, mrIID, reviewerID, reviewID int, aggregateReviewer *model.AggregateMrReviewer) (err error)

UpdateAggregateReviewer ...

func (*Dao) UpdateBranch 

func (d *Dao) UpdateBranch(c context.Context, projectID int, branchName string, branch *model.StatisticsBranches) error

UpdateBranch update

func (*Dao) UpdateCommit 

func (d *Dao) UpdateCommit(projID int, commitID string, commit *model.StatisticsCommits) (err error)

UpdateCommit ...

func (*Dao) UpdateDiscussion 

func (d *Dao) UpdateDiscussion(c context.Context, projectID, mrIID int, discussionID string, discussion *model.StatisticsDiscussions) (err error)

UpdateDiscussion ...

func (*Dao) UpdateIssue 

func (d *Dao) UpdateIssue(projID, issueID int, issue *model.StatisticsIssues) (err error)

UpdateIssue ...

func (*Dao) UpdateJob 

func (d *Dao) UpdateJob(projID, jobID int, runner *model.StatisticsJobs) (err error)

UpdateJob ...

func (*Dao) UpdateMR 

func (d *Dao) UpdateMR(c context.Context, projectID, mrIID int, mr *model.StatisticsMrs) (err error)

UpdateMR update

func (*Dao) UpdateMRAwardEmoji 

func (d *Dao) UpdateMRAwardEmoji(c context.Context, projectID, mrIID, awardEmojiID int, awardEmoji *model.StatisticsMRAwardEmojis) (err error)

UpdateMRAwardEmoji update

func (*Dao) UpdateMember 

func (d *Dao) UpdateMember(c context.Context, projectID, memberID int, member *model.StatisticsMembers) (err error)

UpdateMember ...

func (*Dao) UpdateNote 

func (d *Dao) UpdateNote(c context.Context, projectID, noteID int, note *model.StatisticsNotes) (err error)

UpdateNote ...

func (*Dao) UpdatePipeline 

func (d *Dao) UpdatePipeline(projID int, pipelineID int, pipeline *model.StatisticsPipeline) (err error)

UpdatePipeline ...

func (*Dao) UpdateProjectInfo 

func (d *Dao) UpdateProjectInfo(projectID int, projectInfo *model.ProjectInfo) (err error)

UpdateProjectInfo update

func (*Dao) UpdateRunner 

func (d *Dao) UpdateRunner(projID, runnerID int, runner *model.StatisticsRunners) (err error)

UpdateRunner ...

func (*Dao) UptContact 

func (d *Dao) UptContact(contact *model.ContactInfo) (err error)

UptContact update the contact information

func (*Dao) UserIds 

func (d *Dao) UserIds(userNames []string) (userIds string, err error)

UserIds query user ids for the user names 从数据库表ContactInfo查询员工编号

func (*Dao) WechatAccessToken 

func (d *Dao) WechatAccessToken(c context.Context, secret string) (token string, expire int32, err error)

WechatAccessToken query access token with the specified secret 企业微信api获取公司token

func (*Dao) WechatContacts 

func (d *Dao) WechatContacts(c context.Context, accessToken string) (contacts []*model.ContactInfo, err error)

WechatContacts query all the contacts

func (*Dao) WechatParams 

func (d *Dao) WechatParams(c context.Context, u string, params url.Values, resp interface{}) (err error)

WechatParams ...

func (*Dao) WechatPushMsg 

func (d *Dao) WechatPushMsg(c context.Context, token string, txtMsg *model.TxtNotification) (invalidUser string, err error)

WechatPushMsg wechat push text message to specified user 发送企业微信信息

func (*Dao) WechatSagaVisible 

func (d *Dao) WechatSagaVisible(c context.Context, accessToken string, agentID int) (users []*model.UserInfo, err error)

WechatSagaVisible get all the user ids who can visiable saga 获取用户ID列表

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.