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: 31 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 dao conf

func New 

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

New init mysql db

func (*Dao) AddBatch 

func (d *Dao) AddBatch(c context.Context, r *model.ResouceBatchBo) (a int64, err error)

AddBatch add batch

func (*Dao) AddBusiness 

func (d *Dao) AddBusiness(c context.Context, r *model.VipBusinessInfo) (a int64, err error)

AddBusiness add business info.

func (*Dao) AddJointly 

func (d *Dao) AddJointly(c context.Context, j *model.Jointly) (a int64, err error)

AddJointly add jointly.

func (*Dao) AddPayOrderLog 

func (d *Dao) AddPayOrderLog(c context.Context, arg *model.PayOrderLog) (err error)

AddPayOrderLog add order log.

func (*Dao) AddPool 

func (d *Dao) AddPool(c context.Context, r *model.ResoucePoolBo) (a int64, err error)

AddPool add pool

func (*Dao) AddPrivilege 

func (d *Dao) AddPrivilege(tx *gorm.DB, ps *model.Privilege) (id int64, err error)

AddPrivilege add privilege.

func (*Dao) AddPrivilegeResources 

func (d *Dao) AddPrivilegeResources(tx *gorm.DB, p *model.PrivilegeResources) (a int64, err error)

AddPrivilegeResources add privilege resources.

func (*Dao) AddPushData 

func (d *Dao) AddPushData(c context.Context, r *model.VipPushData) (id int64, err error)

AddPushData add push data

func (*Dao) AddTip 

func (d *Dao) AddTip(c context.Context, t *model.Tips) (lid int64, err error)

AddTip add tip.

func (*Dao) AddVipDPriceConfig 

func (d *Dao) AddVipDPriceConfig(c context.Context, v *model.VipDPriceConfig) (err error)

AddVipDPriceConfig insert vip discount price config .

func (*Dao) AddVipPriceConfig 

func (d *Dao) AddVipPriceConfig(c context.Context, v *model.VipPriceConfig) (err error)

AddVipPriceConfig insert vip price config .

func (*Dao) AllVersion 

func (d *Dao) AllVersion(c context.Context) (res []*model.VipAppVersion, err error)

AllVersion all version.

func (*Dao) BatchAddCode 

func (d *Dao) BatchAddCode(tx *sql.Tx, codes []*model.ResourceCode) (err error)

BatchAddCode .

func (*Dao) BeginGormTran 

func (d *Dao) BeginGormTran(c context.Context) (tx *gorm.DB)

BeginGormTran start gorm tx .

func (*Dao) BeginTran 

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

BeginTran start tx .

func (*Dao) BussinessCount 

func (d *Dao) BussinessCount(c context.Context, status int) (count int64, err error)

BussinessCount bussiness info count.

func (*Dao) BussinessList 

func (d *Dao) BussinessList(c context.Context, pn, ps, status int) (res []*model.VipBusinessInfo, err error)

BussinessList business infos.

func (*Dao) Close 

func (d *Dao) Close() (err error)

Close close the resource.

func (*Dao) CountDialogByPlatID 

func (d *Dao) CountDialogByPlatID(c context.Context, plat int64) (count int64, err error)

CountDialogByPlatID count dialog by platform id .

func (*Dao) CountVipPriceConfigByPlat 

func (d *Dao) CountVipPriceConfigByPlat(c context.Context, plat int64) (count int64, err error)

CountVipPriceConfigByPlat count vip price config by platform id.

func (*Dao) DelBcoinSalary 

func (d *Dao) DelBcoinSalary(tx *sql.Tx, mid int64, month time.Time) (err error)

DelBcoinSalary del bacoin salary

func (*Dao) DelPushData 

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

DelPushData .

func (*Dao) DelSelCode 

func (d *Dao) DelSelCode(c context.Context, username string) (err error)

DelSelCode .

func (*Dao) DelVipDPriceConfig 

func (d *Dao) DelVipDPriceConfig(c context.Context, arg *model.ArgVipDPriceID) (err error)

DelVipDPriceConfig delete vip discount price config .

func (*Dao) DelVipInfoCache 

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

DelVipInfoCache delete vipinfo cache.

func (*Dao) DelVipPriceConfig 

func (d *Dao) DelVipPriceConfig(c context.Context, arg *model.ArgVipPriceID) (err error)

DelVipPriceConfig delete vip price config .

func (*Dao) DeleteJointly 

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

DeleteJointly delete jointly.

func (*Dao) DeletePrivilege 

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

DeletePrivilege dekete privilege.

func (*Dao) DeleteTip 

func (d *Dao) DeleteTip(c context.Context, id int64, deleted int8, operator string) (eff int64, err error)

DeleteTip tip delete.

func (*Dao) DialogAll 

func (d *Dao) DialogAll(c context.Context, appID, platform int64, status string) (res []*model.ConfDialog, err error)

DialogAll .

func (*Dao) DialogBy 

func (d *Dao) DialogBy(c context.Context, appID, platform int64, id int64) (res []*model.ConfDialog, err error)

DialogBy vip price config by .

func (*Dao) DialogByID 

func (d *Dao) DialogByID(c context.Context, id int64) (dlg *model.ConfDialog, err error)

DialogByID vip price config by id.

func (*Dao) DialogDel 

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

DialogDel delete vip price config by id.

func (*Dao) DialogEnable 

func (d *Dao) DialogEnable(c context.Context, arg *model.ConfDialog) (eff int64, err error)

DialogEnable .

func (*Dao) DialogSave 

func (d *Dao) DialogSave(c context.Context, arg *model.ConfDialog) (eff int64, err error)

DialogSave .

func (*Dao) DisablePushData 

func (d *Dao) DisablePushData(c context.Context, res *model.VipPushData) (err error)

DisablePushData .

func (*Dao) ExpireTip 

func (d *Dao) ExpireTip(c context.Context, id int64, operator string, t int64) (eff int64, err error)

ExpireTip tip expire.

func (*Dao) GetMonth 

func (d *Dao) GetMonth(c context.Context, id int64) (m *model.VipMonth, err error)

GetMonth .

func (*Dao) GetPrice 

func (d *Dao) GetPrice(c context.Context, id int64) (r *model.VipMonthPrice, err error)

GetPrice .

func (*Dao) GetPushData 

func (d *Dao) GetPushData(c context.Context, id int64) (r *model.VipPushData, err error)

GetPushData get push data by id

func (*Dao) GetSelCode 

func (d *Dao) GetSelCode(c context.Context, username string) (linkmap map[int64]int64, err error)

GetSelCode .

func (*Dao) HistoryCount 

func (d *Dao) HistoryCount(c context.Context, u *model.UserChangeHistoryReq) (count int, err error)

HistoryCount user change history.

func (*Dao) HistoryList 

func (d *Dao) HistoryList(c context.Context, u *model.UserChangeHistoryReq) (res []*model.VipChangeHistory, err error)

HistoryList history list.

func (*Dao) InsertVipChangeHistory 

func (d *Dao) InsertVipChangeHistory(tx *sql.Tx, r *model.VipChangeHistory) (id int64, err error)

InsertVipChangeHistory insert vipChangeHistory

func (*Dao) JointlysByState 

func (d *Dao) JointlysByState(c context.Context, state int8, now int64) (res []*model.Jointly, err error)

JointlysByState jointly by state.

func (*Dao) MaxOrder 

func (d *Dao) MaxOrder(c context.Context) (order int64, err error)

MaxOrder max priivilege order.

func (*Dao) MonthEdit 

func (d *Dao) MonthEdit(c context.Context, id int64, status int8, op string) (eff int64, err error)

MonthEdit .

func (*Dao) MonthList 

func (d *Dao) MonthList(c context.Context) (res []*model.VipMonth, err error)

MonthList get all month.

func (*Dao) OrderCount 

func (d *Dao) OrderCount(c context.Context, arg *model.ArgPayOrder) (count int64, err error)

OrderCount order count.

func (*Dao) OrderList 

func (d *Dao) OrderList(c context.Context, arg *model.ArgPayOrder) (res []*model.PayOrder, err error)

OrderList order list.

func (*Dao) PayRefund 

func (d *Dao) PayRefund(c context.Context, arg *model.PayOrder, refundAmount float64, refundID string) (err error)

PayRefund .

func (*Dao) Ping 

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

Ping dao ping

func (*Dao) PingMC 

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

PingMC ping memcache.

func (*Dao) PlatformAll 

func (d *Dao) PlatformAll(c context.Context, order string) (res []*model.ConfPlatform, err error)

PlatformAll .

func (*Dao) PlatformByID 

func (d *Dao) PlatformByID(c context.Context, id int64) (re *model.ConfPlatform, err error)

PlatformByID vip platform config by id.

func (*Dao) PlatformDel 

func (d *Dao) PlatformDel(c context.Context, id int64, operator string) (eff int64, err error)

PlatformDel delete vip platform config by id.

func (*Dao) PlatformSave 

func (d *Dao) PlatformSave(c context.Context, arg *model.ConfPlatform) (eff int64, err error)

PlatformSave .

func (*Dao) PlatformTypes 

func (d *Dao) PlatformTypes(c context.Context) (res []*model.TypePlatform, err error)

PlatformTypes .

func (*Dao) PriceAdd 

func (d *Dao) PriceAdd(c context.Context, mp *model.VipMonthPrice) (eff int64, err error)

PriceAdd .

func (*Dao) PriceEdit 

func (d *Dao) PriceEdit(c context.Context, mp *model.VipMonthPrice) (eff int64, err error)

PriceEdit .

func (*Dao) PriceList 

func (d *Dao) PriceList(c context.Context, mID int64) (res []*model.VipMonthPrice, err error)

PriceList .

func (*Dao) PrivilegeList 

func (d *Dao) PrivilegeList(c context.Context, langType int8) (res []*model.Privilege, err error)

PrivilegeList query .

func (*Dao) PrivilegeResourcesList 

func (d *Dao) PrivilegeResourcesList(c context.Context) (res []*model.PrivilegeResources, err error)

PrivilegeResourcesList query privilege resources .

func (*Dao) PushDataCount 

func (d *Dao) PushDataCount(c context.Context, arg *model.ArgPushData) (count int64, err error)

PushDataCount sel push data count

func (*Dao) PushDatas 

func (d *Dao) PushDatas(c context.Context, arg *model.ArgPushData) (res []*model.VipPushData, err error)

PushDatas sel push datas

func (*Dao) ResetWelfareTid 

func (d *Dao) ResetWelfareTid(tx *gorm.DB, tid int) (err error)

ResetWelfareTid reset welfare tid to 0

func (*Dao) SelBatchCode 

func (d *Dao) SelBatchCode(c context.Context, arg *model.ArgBatchCode, pn, ps int) (res []*model.BatchCode, err error)

SelBatchCode .

func (*Dao) SelBatchCodeCount 

func (d *Dao) SelBatchCodeCount(c context.Context, arg *model.ArgBatchCode) (n int64, err error)

SelBatchCodeCount .

func (*Dao) SelBatchCodeID 

func (d *Dao) SelBatchCodeID(c context.Context, batchCodeID int64) (r *model.BatchCode, err error)

SelBatchCodeID .

func (*Dao) SelBatchCodeName 

func (d *Dao) SelBatchCodeName(c context.Context, name string) (r *model.BatchCode, err error)

SelBatchCodeName .

func (*Dao) SelBatchCodes 

func (d *Dao) SelBatchCodes(c context.Context, batchIds []int64) (res []*model.BatchCode, err error)

SelBatchCodes .

func (*Dao) SelBatchRow 

func (d *Dao) SelBatchRow(c context.Context, id int) (r *model.VipResourceBatch, err error)

SelBatchRow sel batch by id

func (*Dao) SelBatchRows 

func (d *Dao) SelBatchRows(c context.Context, poolID int) (res []*model.VipResourceBatch, err error)

SelBatchRows sel batch by poolID

func (*Dao) SelBusiness 

func (d *Dao) SelBusiness(c context.Context, id int) (r *model.VipBusinessInfo, err error)

SelBusiness select businessInfo by id

func (*Dao) SelBusinessByQuery 

func (d *Dao) SelBusinessByQuery(c context.Context, arg *model.QueryBusinessInfo) (r *model.VipBusinessInfo, err error)

SelBusinessByQuery .

func (*Dao) SelCode 

func (d *Dao) SelCode(c context.Context, arg *model.ArgCode, cursor int64, ps int) (res []*model.ResourceCode, err error)

SelCode .

func (*Dao) SelCodeID 

func (d *Dao) SelCodeID(c context.Context, codeID int64) (r *model.ResourceCode, err error)

SelCodeID .

func (*Dao) SelCountPool 

func (d *Dao) SelCountPool(c context.Context, r *model.ResoucePoolBo) (count int, err error)

SelCountPool sel count Pool

func (*Dao) SelOrder 

func (d *Dao) SelOrder(c context.Context, orderNo string) (r *model.PayOrder, err error)

SelOrder sel order by orderNo.

func (*Dao) SelPool 

func (d *Dao) SelPool(c context.Context, r *model.ResoucePoolBo, pn, ps int) (res []*model.VipResourcePool, err error)

SelPool sel pool by query condition

func (*Dao) SelPoolByName 

func (d *Dao) SelPoolByName(c context.Context, name string) (r *model.VipResourcePool, err error)

SelPoolByName sel pool by name

func (*Dao) SelPoolRow 

func (d *Dao) SelPoolRow(c context.Context, id int) (r *model.VipResourcePool, err error)

SelPoolRow sel pool by id

func (*Dao) SelVipUserInfo 

func (d *Dao) SelVipUserInfo(c context.Context, mid int64) (r *model.VipUserInfo, err error)

SelVipUserInfo select user info by mid

func (*Dao) SendMultipMsg 

func (d *Dao) SendMultipMsg(c context.Context, mids, content, title, mc, ip string, dataType int) (err error)

SendMultipMsg send multip msg

func (*Dao) SetSelCode 

func (d *Dao) SetSelCode(c context.Context, username string, linkmap map[int64]int64) (err error)

SetSelCode .

func (*Dao) TipByID 

func (d *Dao) TipByID(c context.Context, id int64) (r *model.Tips, err error)

TipByID by id .

func (*Dao) TipList 

func (d *Dao) TipList(c context.Context, platform int8, state int8, now int64, position int8) (rs []*model.Tips, err error)

TipList tips list.

func (*Dao) TipUpdate 

func (d *Dao) TipUpdate(c context.Context, t *model.Tips) (eff int64, err error)

TipUpdate tip update.

func (*Dao) TxAddBatchCode 

func (d *Dao) TxAddBatchCode(tx *sql.Tx, bc *model.BatchCode) (ID int64, err error)

TxAddBatchCode .

func (*Dao) UpVipDPriceConfig 

func (d *Dao) UpVipDPriceConfig(c context.Context, v *model.VipDPriceConfig) (err error)

UpVipDPriceConfig update vip discount price config .

func (*Dao) UpVipPriceConfig 

func (d *Dao) UpVipPriceConfig(c context.Context, v *model.VipPriceConfig) (err error)

UpVipPriceConfig update vip price config .

func (*Dao) UpdateBatch 

func (d *Dao) UpdateBatch(c context.Context, r *model.VipResourceBatch, ver int) (a int64, err error)

UpdateBatch update batch data

func (*Dao) UpdateBatchCode 

func (d *Dao) UpdateBatchCode(c context.Context, bc *model.BatchCode) (eff int64, err error)

UpdateBatchCode .

func (*Dao) UpdateBusiness 

func (d *Dao) UpdateBusiness(c context.Context, r *model.VipBusinessInfo) (a int64, err error)

UpdateBusiness update business info.

func (*Dao) UpdateCode 

func (d *Dao) UpdateCode(c context.Context, codeID int64, status int8) (eff int64, err error)

UpdateCode .

func (*Dao) UpdateJointly 

func (d *Dao) UpdateJointly(c context.Context, j *model.Jointly) (a int64, err error)

UpdateJointly update jointly.

func (*Dao) UpdateOrder 

func (d *Dao) UpdateOrder(c context.Context, aid, bid int64) (a int64, err error)

UpdateOrder update privilege order.

func (*Dao) UpdatePool 

func (d *Dao) UpdatePool(c context.Context, r *model.ResoucePoolBo) (a int64, err error)

UpdatePool update pool

func (*Dao) UpdatePrivilege 

func (d *Dao) UpdatePrivilege(tx *gorm.DB, ps *model.Privilege) (a int64, err error)

UpdatePrivilege update privilege .

func (*Dao) UpdatePrivilegeResources 

func (d *Dao) UpdatePrivilegeResources(tx *gorm.DB, ps *model.PrivilegeResources) (aff int64, err error)

UpdatePrivilegeResources update privilege resources .

func (*Dao) UpdatePushData 

func (d *Dao) UpdatePushData(c context.Context, r *model.VipPushData) (eff int64, err error)

UpdatePushData update push data

func (*Dao) UpdateStatePrivilege 

func (d *Dao) UpdateStatePrivilege(c context.Context, p *model.Privilege) (a int64, err error)

UpdateStatePrivilege update state privilege.

func (*Dao) UpdateVersion 

func (d *Dao) UpdateVersion(c context.Context, v *model.VipAppVersion) (ret int64, err error)

UpdateVersion update version.

func (*Dao) UpdateVipUserInfo 

func (d *Dao) UpdateVipUserInfo(tx *sql.Tx, r *model.VipUserInfo) (a int64, err error)

UpdateVipUserInfo update vip user info by id

func (*Dao) Upload 

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

Upload upload picture or log file to bfs

func (*Dao) UseBatch 

func (d *Dao) UseBatch(tx *sql.Tx, r *model.VipResourceBatch, ver int) (a int64, err error)

UseBatch use batch resouce

func (*Dao) VipDPriceConfigID 

func (d *Dao) VipDPriceConfigID(c context.Context, arg *model.ArgVipDPriceID) (res *model.VipDPriceConfig, err error)

VipDPriceConfigID vip discount price config by id

func (*Dao) VipDPriceConfigUQTime 

func (d *Dao) VipDPriceConfigUQTime(c context.Context, arg *model.ArgAddOrUpVipDPrice) (mvd map[int64]*model.VipDPriceConfig, err error)

VipDPriceConfigUQTime count vip discount price config unquie check time.

func (*Dao) VipDPriceConfigs 

func (d *Dao) VipDPriceConfigs(c context.Context, arg *model.ArgVipPriceID) (res []*model.VipDPriceConfig, err error)

VipDPriceConfigs vip discount price configs

func (*Dao) VipMaxPriceDiscount 

func (d *Dao) VipMaxPriceDiscount(c context.Context, arg *model.ArgAddOrUpVipPrice) (res float64, err error)

VipMaxPriceDiscount max price discount.

func (*Dao) VipPriceConfigID 

func (d *Dao) VipPriceConfigID(c context.Context, arg *model.ArgVipPriceID) (vpc *model.VipPriceConfig, err error)

VipPriceConfigID vip price config by id

func (*Dao) VipPriceConfigUQCheck 

func (d *Dao) VipPriceConfigUQCheck(c context.Context, arg *model.ArgAddOrUpVipPrice) (count int64, err error)

VipPriceConfigUQCheck count vip price config unquie check.

func (*Dao) VipPriceConfigs 

func (d *Dao) VipPriceConfigs(c context.Context) (vpcs []*model.VipPriceConfig, err error)

VipPriceConfigs vip price configs

func (*Dao) VipPriceDiscountConfigs 

func (d *Dao) VipPriceDiscountConfigs(c context.Context) (mvd map[int64]*model.VipDPriceConfig, err error)

VipPriceDiscountConfigs get vip price discount configs.

func (*Dao) WelfareAdd 

func (d *Dao) WelfareAdd(wt *model.Welfare) (err error)

WelfareAdd add welfare

func (*Dao) WelfareBatchList 

func (d *Dao) WelfareBatchList(wid int) (wbs []*model.WelfareBatchRes, err error)

WelfareBatchList get welfare list

func (*Dao) WelfareBatchSave 

func (d *Dao) WelfareBatchSave(wcb *model.WelfareCodeBatch) (err error)

WelfareBatchSave add welfare batch

func (*Dao) WelfareBatchState 

func (d *Dao) WelfareBatchState(tx *gorm.DB, id, state, operId int, operName string) (err error)

WelfareBatchState delete welfare batch

func (*Dao) WelfareCodeBatchInsert 

func (d *Dao) WelfareCodeBatchInsert(wcs []*model.WelfareCode) (err error)

WelfareCodeBatchInsert insert welfare batch code

func (*Dao) WelfareCodeStatus 

func (d *Dao) WelfareCodeStatus(tx *gorm.DB, bid, state int) (err error)

WelfareCodeStatus delete welfare batch code

func (*Dao) WelfareList 

func (d *Dao) WelfareList(tid int) (ws []*model.WelfareRes, err error)

WelfareList get welfare list

func (*Dao) WelfareState 

func (d *Dao) WelfareState(id, state, operId int, operName string) (err error)

WelfareState delete welfare

func (*Dao) WelfareTypeAdd 

func (d *Dao) WelfareTypeAdd(wt *model.WelfareType) (err error)

WelfareTypeAdd add welfare type

func (*Dao) WelfareTypeList 

func (d *Dao) WelfareTypeList() (wts []*model.WelfareTypeRes, err error)

WelfareTypeList get welfare type list

func (*Dao) WelfareTypeState 

func (d *Dao) WelfareTypeState(tx *gorm.DB, id, state, operId int, operName string) (err error)

WelfareTypeState delete welfare type

func (*Dao) WelfareTypeUpd 

func (d *Dao) WelfareTypeUpd(wt *model.WelfareType) (err error)

WelfareTypeUpd update welfare type

func (*Dao) WelfareUpd 

func (d *Dao) WelfareUpd(wt *model.WelfareReq) (err error)

WelfareUpd update welfare

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.