1234567891011121314151617181920212223242526272829303132333435363738 |
- package archive
- import (
- "context"
- "go-common/library/database/sql"
- "go-common/library/log"
- "time"
- )
- const (
- _slByAID = "SELECT `id` FROM `archive_first_pass` WHERE `aid`=? LIMIT 1;"
- _inFirstPass = "INSERT INTO `archive_first_pass`(`aid`, `ctime`, `mtime`) VALUES(?,?,?);"
- )
- //GetFirstPassByAID 根据aid获取第一次过审的记录
- func (d *Dao) GetFirstPassByAID(c context.Context, aid int64) (id int64, err error) {
- row := d.db.QueryRow(c, _slByAID, aid)
- if err = row.Scan(&id); err != nil {
- if err == sql.ErrNoRows {
- err = nil
- } else {
- log.Error("GetFirstPassByAID error(%v) aid(%d)", err, aid)
- }
- return
- }
- return
- }
- //AddFirstPass 添加一条 第一次过审的记录
- func (d *Dao) AddFirstPass(tx *sql.Tx, aid int64) (err error) {
- now := time.Now()
- if _, err = tx.Exec(_inFirstPass, aid, now, now); err != nil {
- log.Error("AddFirstPass error(%v) aid(%d)", err)
- }
- return
- }
|