74 lines
2.2 KiB
Go
74 lines
2.2 KiB
Go
package dao
|
|
|
|
import (
|
|
"context"
|
|
"go-common/app/service/bbq/video/model"
|
|
"go-common/library/ecode"
|
|
"go-common/library/log"
|
|
)
|
|
|
|
const (
|
|
insertVR = "insert into video_repository (`cid`,`svid`,`mid`,`title`,`from`,`sync_status`) values (?,?,?,?,?,?)"
|
|
updateVRSyncStatus = "update video_repository set sync_status = ?"
|
|
queryVRBySvid = "select `title`,`mid`,`home_img_url`,`home_img_width`,`home_img_height` from video_repository where svid = ?"
|
|
)
|
|
|
|
//InsertVR ..
|
|
func (d *Dao) InsertVR(c context.Context, vr *model.VideoRepository) (err error) {
|
|
if vr == nil {
|
|
err = ecode.BBQSystemErr
|
|
log.Errorw(c, "event", "InsertVR req nil")
|
|
return
|
|
}
|
|
if _, err = d.cmsdb.Exec(c, insertVR, vr.SVID, vr.SVID, vr.MID, vr.Title, vr.From,
|
|
vr.SyncStatus); err != nil {
|
|
log.Errorw(c, "event", "InsertVR err", "err", err, "param", vr)
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
//UpdateVR ..
|
|
func (d *Dao) UpdateVR(c context.Context, vr *model.VideoRepository) (err error) {
|
|
if vr == nil {
|
|
err = ecode.BBQSystemErr
|
|
log.Errorw(c, "event", "InsertVR req nil")
|
|
return
|
|
}
|
|
if _, err = d.cmsdb.Exec(c, updateVRSyncStatus, vr.SyncStatus); err != nil {
|
|
log.Errorw(c, "event", "UpdateVR err", "err", err, "param", vr)
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
//QueryVR ..
|
|
func (d *Dao) QueryVR(c context.Context, vr *model.VideoRepository) (res *model.VideoRepository, err error) {
|
|
if vr == nil {
|
|
err = ecode.BBQSystemErr
|
|
log.Errorw(c, "event", "InsertVR req nil")
|
|
return
|
|
}
|
|
res = new(model.VideoRepository)
|
|
if err = d.cmsdb.QueryRow(c, queryVRBySvid, vr.SVID).Scan(&res.Title, &res.MID, &res.HomeImgURL, &res.HomeImgWidth, &res.HomeImgHeight); err != nil {
|
|
log.Errorw(c, "event", "queryVR scan err", "err", err, "param", vr)
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
//HomeImgCreate ..
|
|
func (d *Dao) HomeImgCreate(c context.Context, vr *model.VideoRepository) (err error) {
|
|
if vr == nil {
|
|
err = ecode.BBQSystemErr
|
|
log.Errorw(c, "event", "HomeImgCreate req nil")
|
|
return
|
|
}
|
|
if _, err = d.cmsdb.Exec(c, "update video_repository set home_img_url = ?,home_img_width = ? ,home_img_height = ? where svid = ? and mid = ?",
|
|
vr.HomeImgURL, vr.HomeImgWidth, vr.HomeImgHeight, vr.SVID, vr.MID); err != nil {
|
|
log.Errorw(c, "update home_img err", "err", err, "param", vr)
|
|
return
|
|
}
|
|
return
|
|
}
|