You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
73 lines
2.2 KiB
73 lines
2.2 KiB
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 |
|
}
|
|
|