unicom

package

v0.0.0-...-83adff0 Latest Latest Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tsrmtrue/asiotestrobot

Links

Open Source Insights

Documentation ¶

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
}

func New ¶

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

func (*Dao) AddUnicomCache ¶

func (d *Dao) AddUnicomCache(c context.Context, usermob string, u []*unicom.Unicom) (err error)

AddUnicomCache

func (*Dao) AddUserBindCache ¶

func (d *Dao) AddUserBindCache(c context.Context, mid int64, ub *unicom.UserBind) (err error)

AddUserBindCache add user user bind cache

func (*Dao) AddUserFlowCache ¶

func (d *Dao) AddUserFlowCache(c context.Context, keyStr string) (err error)

AddUserFlowCache add user pack cache

func (*Dao) AddUserFlowListCache ¶

func (d *Dao) AddUserFlowListCache(c context.Context, list map[string]*unicom.UnicomUserFlow) (err error)

AddUserFlowListCache add user pack cache

func (*Dao) AddUserFlowWaitCache ¶

func (d *Dao) AddUserFlowWaitCache(c context.Context, phone int) (err error)

AddUserFlowWaitCache add user flow wait

func (*Dao) AddUserPackCache ¶

func (d *Dao) AddUserPackCache(c context.Context, id int64, u *unicom.UserPack) (err error)

AddUserPackCache add user pack cache

func (*Dao) BeginTran ¶

func (d *Dao) BeginTran(ctx context.Context) (tx *xsql.Tx, err error)

BeginTran begin a transacition

func (*Dao) CancelOrder ¶

func (d *Dao) CancelOrder(c context.Context, usermob string) (data *unicom.BroadbandOrder, msg string, err error)

CancelOrder unicom cancel order

func (*Dao) DeleteUnicomCache ¶

func (d *Dao) DeleteUnicomCache(c context.Context, usermob string) (err error)

DeleteUnicomCache

func (*Dao) DeleteUserBindCache ¶

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

DeleteUserBindCache delete user bind cache

func (*Dao) DeleteUserFlowCache ¶

func (d *Dao) DeleteUserFlowCache(c context.Context, keyStr string) (err error)

DeleteUserPackCache delete user pack cache

func (*Dao) DeleteUserPackCache ¶

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

DeleteUserPackCache delete user pack cache

func (*Dao) FlowExchange ¶

func (d *Dao) FlowExchange(c context.Context, phone int, flowcode string, requestNo int64, ts time.Time) (orderID, outorderID, msg string, err error)

FlowExchange flow exchange

func (*Dao) FlowPre ¶

func (d *Dao) FlowPre(c context.Context, phone int, requestNo int64, ts time.Time) (msg string, err error)

FlowPre unicom phone flow pre

func (*Dao) FlowQry ¶

func (d *Dao) FlowQry(c context.Context, phone int, requestNo int64, outorderid, orderid string, ts time.Time) (orderstatus, msg string, err error)

FlowQry unicom phone qryflowchange

func (*Dao) FlowSync ¶

func (d *Dao) FlowSync(ctx context.Context, flowbyte int, usermob, time string, now time.Time) (row int64, err error)

FlowSync update OrdersSync

func (*Dao) IPSync ¶

func (d *Dao) IPSync(ctx context.Context) (res []*unicom.UnicomIP, err error)

IPSync select all ipSync

func (*Dao) InAdvanceSync ¶

func (d *Dao) InAdvanceSync(ctx context.Context, usermob string, u *unicom.UnicomJson, now time.Time) (row int64, err error)

InAdvanceSync insert AdvanceSync

func (*Dao) InIPSync ¶

func (d *Dao) InIPSync(ctx context.Context, u *unicom.UnicomIpJson, now time.Time) (row int64, err error)

InIPSync insert IpSync

func (*Dao) InOrdersSync ¶

func (d *Dao) InOrdersSync(ctx context.Context, usermob string, u *unicom.UnicomJson, now time.Time) (row int64, err error)

InOrdersSync insert OrdersSync

func (*Dao) InPack ¶

func (d *Dao) InPack(ctx context.Context, usermob string, mid int64) (row int64, err error)

InPack insert Privilege pack

func (*Dao) InUnicomIPSync ¶

func (d *Dao) InUnicomIPSync(tx *xsql.Tx, u *unicom.UnicomIP, now time.Time) (row int64, err error)

InUnicomIPSync insert or update unicom_ip

func (*Dao) InUserBind ¶

func (d *Dao) InUserBind(ctx context.Context, ub *unicom.UserBind) (row int64, err error)

InUserBind unicom insert user bind

func (*Dao) InUserPackLog ¶

func (d *Dao) InUserPackLog(ctx context.Context, u *unicom.UserPackLog) (row int64, err error)

InUserPackLog insert unicom user pack log

func (*Dao) Order ¶

func (d *Dao) Order(c context.Context, usermob, channel string, ordertype int) (data *unicom.BroadbandOrder, msg string, err error)

Order unicom order

func (*Dao) OrdersUserFlow ¶

func (d *Dao) OrdersUserFlow(ctx context.Context, usermob string) (res []*unicom.Unicom, err error)

OrdersUserFlow select user OrdersSync

func (*Dao) Pack ¶

func (d *Dao) Pack(ctx context.Context, usermobStr string) (res map[string]map[int64]struct{}, err error)

Pack select Privilege pack

func (*Dao) PhoneVerification ¶

func (d *Dao) PhoneVerification(c context.Context, phone string, requestNo int64, ts time.Time) (msg string, err error)

PhoneVerification unicom phone verification

func (*Dao) SearchUserBindLog ¶

func (d *Dao) SearchUserBindLog(ctx context.Context, mid int64, now time.Time) (ulogs []*unicom.UserLog, err error)

SearchUserBindLog unicom user bind log

func (*Dao) SendSmsCode ¶

func (d *Dao) SendSmsCode(c context.Context, phone string) (msg string, err error)

SendSmsCode unicom sms code

func (*Dao) SmsNumber ¶

func (d *Dao) SmsNumber(c context.Context, phone string, code int) (usermob string, msg string, err error)

SmsNumber unicom sms usermob

func (*Dao) UnicomCache ¶

func (d *Dao) UnicomCache(c context.Context, usermob string) (u []*unicom.Unicom, err error)

UnicomCache

func (*Dao) UnicomIP ¶

func (d *Dao) UnicomIP(c context.Context, now time.Time) (unicomIPs []*unicom.UnicomIP, err error)

UnicomIP unicom ip orders

func (*Dao) UpUnicomIP ¶

func (d *Dao) UpUnicomIP(tx *xsql.Tx, ipstart, ipend, state int, now time.Time) (row int64, err error)

UpUnicomIP update unicom_ip state

func (*Dao) UpUserIntegral ¶

func (d *Dao) UpUserIntegral(ctx context.Context, ub *unicom.UserBind) (row int64, err error)

UpUserIntegral update unicom user integral

func (*Dao) UpUserPacks ¶

func (d *Dao) UpUserPacks(ctx context.Context, u *unicom.UserPack, id int64) (row int64, err error)

UpUserPacks update user packs

func (*Dao) UpdateUnicomCache ¶

func (d *Dao) UpdateUnicomCache(c context.Context, usermob string, u *unicom.Unicom) (err error)

UpdateUnicomCache

func (*Dao) UserBind ¶

func (d *Dao) UserBind(ctx context.Context, mid int64) (res *unicom.UserBind, err error)

UserBind unicom select user bind

func (*Dao) UserBindCache ¶

func (d *Dao) UserBindCache(c context.Context, mid int64) (ub *unicom.UserBind, err error)

UserBindCache user bind cache

func (*Dao) UserBindOld ¶

func (d *Dao) UserBindOld(ctx context.Context, phone string) (res *unicom.UserBind, err error)

UserBindOld user by phone

func (*Dao) UserBindPhoneMid ¶

func (d *Dao) UserBindPhoneMid(ctx context.Context, phone string) (mid int64, err error)

UserBindPhoneMid mid by phone

func (*Dao) UserFlowCache ¶

func (d *Dao) UserFlowCache(c context.Context, keyStr string) (err error)

UserFlowCache unicom flow cache

func (*Dao) UserFlowListCache ¶

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

UserFlowListCache unicom flow cache

func (*Dao) UserFlowWaitCache ¶

func (d *Dao) UserFlowWaitCache(c context.Context, phone int) (err error)

UserFlowWaitCache unicom flow wait

func (*Dao) UserPackByID ¶

func (d *Dao) UserPackByID(ctx context.Context, id int64) (res map[int64]*unicom.UserPack, err error)

UserPackByID user pack by id

func (*Dao) UserPackCache ¶

func (d *Dao) UserPackCache(c context.Context, id int64) (res *unicom.UserPack, err error)

UserPackCache user packs

func (*Dao) UserPacks ¶

func (d *Dao) UserPacks(ctx context.Context) (res []*unicom.UserPack, err error)

UserPacks user pack list

func (*Dao) UserPacksLog ¶

func (d *Dao) UserPacksLog(ctx context.Context, start, end time.Time) (res []*unicom.UserPackLog, err error)

UserPacksLog user pack logs

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL