gorm

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Available 

func Available(db *gorm.DB) *gorm.DB

Available .

func Disable 

func Disable(db *gorm.DB) *gorm.DB

Disable .

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 orm

func (*Dao) ActiveConfigs 

func (d *Dao) ActiveConfigs(c context.Context) (configs []*business.BizCFG, err error)

ActiveConfigs 所有任务配置

func (*Dao) AddBizConfig 

func (d *Dao) AddBizConfig(c context.Context, cfg *business.BizCFG) (lastid int64, err error)

AddBizConfig 每个业务每种配置只有一条

func (*Dao) AddBusiness 

func (d *Dao) AddBusiness(c context.Context, e *business.Business) (id int64, err error)

AddBusiness .

func (*Dao) AddConfig 

func (d *Dao) AddConfig(c context.Context, config *taskmod.Config, confJSON interface{}) (err error)

AddConfig add config

func (*Dao) AddItem 

func (d *Dao) AddItem(c context.Context, db *gorm.DB, n interface{}) (err error)

AddItem .

func (*Dao) BeginTx 

func (d *Dao) BeginTx(c context.Context) (tx *gorm.DB, err error)

BeginTx .

func (*Dao) Business 

func (d *Dao) Business(c context.Context, id int64) (res *business.Business, err error)

Business .

func (*Dao) BusinessList 

func (d *Dao) BusinessList(c context.Context, tp int8, ids []int64, onlyEnable bool) (res []*business.Business, err error)

BusinessList .

func (*Dao) CancelFlowResource 

func (d *Dao) CancelFlowResource(c context.Context, tx *gorm.DB, rids []int64) (err error)

CancelFlowResource .

func (*Dao) Close 

func (d *Dao) Close()

Close close the resource.

func (*Dao) CloseTask 

func (d *Dao) CloseTask(c context.Context, id int64) (err error)

CloseTask .

func (*Dao) ColumnMapString 

func (d *Dao) ColumnMapString(c context.Context, table string, column string, ids []int64, where string) (result map[int64]string, err error)

ColumnMapString .

func (*Dao) DeleteConfig 

func (d *Dao) DeleteConfig(c context.Context, id int64) (err error)

DeleteConfig delete config

func (*Dao) DirectionByFlowID 

func (d *Dao) DirectionByFlowID(c context.Context, flowID []int64, direction int8) (dirs []*net.Direction, err error)

DirectionByFlowID .

func (*Dao) DirectionByID 

func (d *Dao) DirectionByID(c context.Context, id int64) (n *net.Direction, err error)

DirectionByID .

func (*Dao) DirectionByNet 

func (d *Dao) DirectionByNet(c context.Context, netID int64) (n []*net.Direction, err error)

DirectionByNet .

func (*Dao) DirectionByTransitionID 

func (d *Dao) DirectionByTransitionID(c context.Context, transitionID []int64, direction int8, onlyAvailable bool) (dirs []*net.Direction, err error)

DirectionByTransitionID .

func (*Dao) DirectionByUnique 

func (d *Dao) DirectionByUnique(c context.Context, netID int64, flowID int64, transitionID int64, direction int8) (t *net.Direction, err error)

DirectionByUnique .

func (*Dao) DirectionList 

func (d *Dao) DirectionList(c context.Context, pm *net.ListDirectionParam) (result *net.ListDirectionRes, err error)

DirectionList .

func (*Dao) Directions 

func (d *Dao) Directions(c context.Context, ids []int64) (n []*net.Direction, err error)

func (*Dao) DisableBusiness 

func (d *Dao) DisableBusiness(c context.Context, id int64) (err error)

DisableBusiness .

func (*Dao) DisableNet 

func (d *Dao) DisableNet(c context.Context, tx *gorm.DB, id int64) (err error)

DisableNet .

func (*Dao) EditBizConfig 

func (d *Dao) EditBizConfig(c context.Context, cfg *business.BizCFG) (err error)

EditBizConfig .

func (*Dao) EnableBusiness 

func (d *Dao) EnableBusiness(c context.Context, id int64) (err error)

EnableBusiness .

func (*Dao) FRByFlow 

func (d *Dao) FRByFlow(c context.Context, flowID []int64) (fr *net.FlowResource, err error)

FRByFlow .

func (*Dao) FRByNetRID 

func (d *Dao) FRByNetRID(c context.Context, netID []int64, rids []int64, onlyRunning bool) (frs []*net.FlowResource, err error)

FRByNetRID .

func (*Dao) FRByUniques 

func (d *Dao) FRByUniques(c context.Context, rids []int64, flowID []int64, onlyRunning bool) (frs []*net.FlowResource, err error)

FRByUniques .

func (*Dao) FlowByID 

func (d *Dao) FlowByID(c context.Context, id int64) (f *net.Flow, err error)

FlowByID .

func (*Dao) FlowByUnique 

func (d *Dao) FlowByUnique(c context.Context, netID int64, name string) (f *net.Flow, err error)

FlowByUnique .

func (*Dao) FlowIDByNet 

func (d *Dao) FlowIDByNet(c context.Context, nid []int64) (res map[int64][]int64, err error)

func (*Dao) FlowList 

func (d *Dao) FlowList(c context.Context, pm *net.ListNetElementParam) (result *net.ListFlowRes, err error)

FlowList .

func (*Dao) Flows 

func (d *Dao) Flows(c context.Context, ids []int64) (fs []*net.Flow, err error)

Flows .

func (*Dao) FlowsByNet 

func (d *Dao) FlowsByNet(c context.Context, netID []int64) (fs []*net.Flow, err error)

FlowsByNet .

func (*Dao) GetConfig 

func (d *Dao) GetConfig(c context.Context, bizid int64, tp int8) (config string, err error)

GetConfig .

func (*Dao) GetConfigs 

func (d *Dao) GetConfigs(c context.Context, bizid int64) (cfgs []*business.BizCFG, err error)

GetConfigs .

func (*Dao) ListHelperForTask 

func (d *Dao) ListHelperForTask(c context.Context, rids []int64) (res map[int64][]interface{}, err error)

ListHelperForTask 补充任务列表里面的oid和content

func (*Dao) MaxWeight 

func (d *Dao) MaxWeight(c context.Context, bizID, flowID int64) (max int64, err error)

MaxWeight max weight

func (*Dao) MetaByRID 

func (d *Dao) MetaByRID(c context.Context, rids []int64) (metas map[int64]string, err error)

MetaByRID .

func (*Dao) NetBindStartFlow 

func (d *Dao) NetBindStartFlow(c context.Context, tx *gorm.DB, id int64, flowID int64) (err error)

NetBindStartFlow .

func (*Dao) NetByID 

func (d *Dao) NetByID(c context.Context, id int64) (n *net.Net, err error)

NetByID .

func (*Dao) NetByUnique 

func (d *Dao) NetByUnique(c context.Context, name string) (n *net.Net, err error)

NetByUnique .

func (*Dao) NetIDByBusiness 

func (d *Dao) NetIDByBusiness(c context.Context, businessID []int64) (bizmap map[int64][]int64, err error)

NetIDByBusiness .

func (*Dao) NetList 

func (d *Dao) NetList(c context.Context, pm *net.ListNetParam) (result *net.ListNetRes, err error)

NetList .

func (*Dao) Nets 

func (d *Dao) Nets(c context.Context, ids []int64) (n []*net.Net, err error)

func (*Dao) NetsByBusiness 

func (d *Dao) NetsByBusiness(c context.Context, businessID []int64, onlyAvailable bool) (list []*net.Net, err error)

NetsByBusiness .

func (*Dao) OidByRID 

func (d *Dao) OidByRID(c context.Context, rid int64) (oid string, err error)

OidByRID 通过rid查到oid

func (*Dao) Ping 

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

Ping dao ping

func (*Dao) QueryConfigs 

func (d *Dao) QueryConfigs(c context.Context, queryParams *taskmod.QueryParams) (configs []*taskmod.Config, count int64, err error)

QueryConfigs list config

func (*Dao) ReportTaskMetas 

func (d *Dao) ReportTaskMetas(c context.Context, bt string, et string, bizid, flowid int64, uids []int64, mnames map[int64]string, tp int8) (metas []*model.ReportMeta, missuid []int64, err error)

ReportTaskMetas 任务数据统计

func (*Dao) ResByOID 

func (d *Dao) ResByOID(c context.Context, bizID int64, OID string) (res *resource.Res, err error)

ResByOID .

func (*Dao) ResIDByOID 

func (d *Dao) ResIDByOID(C context.Context, bizID int64, oids []string) (res map[string]int64, err error)

ResIDByOID 根据oid获取rid

func (*Dao) ResOIDByID 

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

ResOIDByID 根据id获取资源oid

func (*Dao) ResourceByOID 

func (d *Dao) ResourceByOID(c context.Context, OID string, bizID int64) (res *resource.Resource, err error)

ResourceByOID .

func (*Dao) ResourceHit 

func (d *Dao) ResourceHit(c context.Context, rids []int64) (hitids map[int64]int64, err error)

ResourceHit 根据状态筛选资源

func (*Dao) ResourceRes 

func (d *Dao) ResourceRes(c context.Context, rid int64) (res *resource.Res, err error)

ResourceRes .

func (*Dao) ResultByRID 

func (d *Dao) ResultByRID(c context.Context, rid int64) (res *resource.Result, err error)

ResultByRID result by rid

func (*Dao) RidsByOids 

func (d *Dao) RidsByOids(c context.Context, bizID int64, oids []string) (rids string, err error)

RidsByOids .

func (*Dao) SetStateConfig 

func (d *Dao) SetStateConfig(c context.Context, id int64, state int8) (err error)

SetStateConfig update config

func (*Dao) TaskByRID 

func (d *Dao) TaskByRID(c context.Context, rid, flowid int64) (t *task.Task, err error)

TaskByRID task by rid

func (*Dao) TaskHitAuditing 

func (d *Dao) TaskHitAuditing(c context.Context, rids []int64) (map[int64]struct{}, error)

TaskHitAuditing 检查资源是否正在审核

func (*Dao) TaskListAssignd 

func (d *Dao) TaskListAssignd(c context.Context, opt *task.ListOptions) (ids []int64, count int64, err error)

TaskListAssignd 指派停滞任务

func (*Dao) TaskListDelayd 

func (d *Dao) TaskListDelayd(c context.Context, opt *task.ListOptions) (ids []int64, count int64, err error)

TaskListDelayd 延迟任务

func (*Dao) TaskListSeized 

func (d *Dao) TaskListSeized(c context.Context, opt *task.ListOptions) (ids []int64, count int64, err error)

TaskListSeized 停滞任务

func (*Dao) TaskReports 

func (d *Dao) TaskReports(c context.Context, biz int64, flowID int64, tp []int8, statdateFrom string, statdateTo string) (res []*model.TaskReport, err error)

TaskReports 任务报表记录

func (*Dao) TaskStat 

func (d *Dao) TaskStat(c context.Context, bizID, flowID, UID int64) (stat *task.Stat, err error)

TaskStat 任务详情统计

func (*Dao) TokenBindByElement 

func (d *Dao) TokenBindByElement(c context.Context, elementID []int64, tp []int8, onlyAvailable bool) (binds map[int64][]*net.TokenBind, err error)

TokenBindByElement .

func (*Dao) TokenBinds 

func (d *Dao) TokenBinds(c context.Context, id []int64) (t []*net.TokenBind, err error)

TokenBinds .

func (*Dao) TokenByID 

func (d *Dao) TokenByID(c context.Context, id int64) (t *net.Token, err error)

TokenByID .

func (*Dao) TokenByUnique 

func (d *Dao) TokenByUnique(c context.Context, netID int64, name string, compare int8, value string) (t *net.Token, err error)

TokenByUnique .

func (*Dao) TokenList 

func (d *Dao) TokenList(c context.Context, netID []int64, id []int64, name string, onlyAssign bool) (list []*net.Token, err error)

TokenList .

func (*Dao) TokenListWithPager 

func (d *Dao) TokenListWithPager(c context.Context, pm *net.ListTokenParam) (result *net.ListTokenRes, err error)

TokenListWithPager .

func (*Dao) Tokens 

func (d *Dao) Tokens(c context.Context, ids []int64) (list []*net.Token, err error)

Tokens .

func (*Dao) TranByNet 

func (d *Dao) TranByNet(c context.Context, netID int64, onlyAvailable bool) (list []*net.Transition, err error)

TranByNet .

func (*Dao) TransitionByID 

func (d *Dao) TransitionByID(c context.Context, id int64) (n *net.Transition, err error)

TransitionByID .

func (*Dao) TransitionByUnique 

func (d *Dao) TransitionByUnique(c context.Context, netID int64, name string) (t *net.Transition, err error)

TransitionByUnique .

func (*Dao) TransitionIDByNet 

func (d *Dao) TransitionIDByNet(c context.Context, netID []int64, onlyDispatch bool, onlyAvailable bool) (ids map[int64][]int64, err error)

TransitionIDByNet .

func (*Dao) TransitionList 

func (d *Dao) TransitionList(c context.Context, pm *net.ListNetElementParam) (result *net.ListTransitionRes, err error)

TransitionList .

func (*Dao) Transitions 

func (d *Dao) Transitions(c context.Context, id []int64) (n []*net.Transition, err error)

Transitions .

func (*Dao) TxAddResource 

func (d *Dao) TxAddResource(tx *gorm.DB, r *resource.Resource, rr *resource.Result) (rid int64, err error)

TxAddResource .

func (*Dao) TxCloseTasks 

func (d *Dao) TxCloseTasks(tx *gorm.DB, rids []int64, uid int64) (err error)

TxCloseTasks close

func (*Dao) TxSubmit 

func (d *Dao) TxSubmit(tx *gorm.DB, opt *task.SubmitOptions, state int8) (rows int64, err error)

TxSubmit 提交任务

func (*Dao) TxUpdateResource 

func (d *Dao) TxUpdateResource(ormTx *gorm.DB, rid int64, res map[string]interface{}) (err error)

TxUpdateResource . TODO Resource表的字段要不要直接审核提交变更 还是等待业务方同步更新？(例如单话的上线下线)

func (*Dao) TxUpdateResult 

func (d *Dao) TxUpdateResult(ormTx *gorm.DB, rid int64, res map[string]interface{}, rscRes *resource.Result) (err error)

TxUpdateResult .

func (*Dao) TxUpdateState 

func (d *Dao) TxUpdateState(tx *gorm.DB, rids []int64, state int) (err error)

TxUpdateState 更新状态

func (*Dao) UndoStat 

func (d *Dao) UndoStat(c context.Context, bizID, flowID, UID int64) (stat *task.UnDOStat, err error)

UndoStat 未完成

func (*Dao) UpdateBusiness 

func (d *Dao) UpdateBusiness(c context.Context, e *business.Business) (err error)

UpdateBusiness .

func (*Dao) UpdateConfig 

func (d *Dao) UpdateConfig(c context.Context, config *taskmod.Config) (err error)

UpdateConfig update config

func (*Dao) UpdateFields 

func (d *Dao) UpdateFields(c context.Context, db *gorm.DB, table string, id int64, fields map[string]interface{}) (err error)

UpdateFields .

func (*Dao) UpdateResource 

func (d *Dao) UpdateResource(c context.Context, bizid int64, oid string, update map[string]interface{}) (rows int64, err error)

UpdateResource 更新资源

func (*Dao) UpsertByOIDs 

func (d *Dao) UpsertByOIDs(c context.Context, businessID int64, oids []string) (res []*model.UpsertItem, err error)

UpsertByOIDs 获取需要更新到搜索部分

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.