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.
90 lines
2.8 KiB
90 lines
2.8 KiB
package archive |
|
|
|
import ( |
|
"context" |
|
"go-common/app/service/main/videoup/model/archive" |
|
"go-common/library/database/sql" |
|
"go-common/library/log" |
|
) |
|
|
|
const ( |
|
_upStateStaffSQL = "UPDATE archive_staff SET state =? where id=?" |
|
_inStaffSQL = "INSERT into archive_staff(aid,mid,staff_mid,staff_title,staff_title_id,state) VALUES (?,?,?,?,?,?) ON DUPLICATE KEY UPDATE staff_title=?,staff_title_id=?,state=?" |
|
_staffsSQL = "SELECT id,aid,mid,staff_mid,staff_title,staff_title_id,state FROM archive_staff WHERE aid=? AND state=?" |
|
|
|
_staffByIDSQL = "SELECT id,aid,mid,staff_mid,staff_title,staff_title_id,state FROM archive_staff WHERE id=?" |
|
_staffByAIdMIDSQL = "SELECT id,aid,mid,staff_mid,staff_title,staff_title_id,state FROM archive_staff WHERE aid=? AND staff_mid=? limit 1" |
|
) |
|
|
|
// TxAddStaff tx. |
|
func (d *Dao) TxAddStaff(tx *sql.Tx, param *archive.Staff) (id int64, err error) { |
|
res, err := tx.Exec(_inStaffSQL, param.AID, param.MID, param.StaffMID, param.StaffTitle, param.StaffTitleID, param.State, param.StaffTitle, param.StaffTitleID, param.State) |
|
if err != nil { |
|
log.Error("d.TxAddStaff.Exec() error(%v)", err) |
|
return |
|
} |
|
id, err = res.LastInsertId() |
|
return |
|
} |
|
|
|
// TxUpStaffState tx . |
|
func (d *Dao) TxUpStaffState(tx *sql.Tx, state int8, id int64) (rows int64, err error) { |
|
res, err := tx.Exec(_upStateStaffSQL, state, id) |
|
if err != nil { |
|
log.Error("d.TxUpStaffState.Exec() error(%v)", err) |
|
return |
|
} |
|
rows, err = res.RowsAffected() |
|
return |
|
} |
|
|
|
// Staffs get . |
|
func (d *Dao) Staffs(c context.Context, AID int64) (fs []*archive.Staff, err error) { |
|
rows, err := d.db.Query(c, _staffsSQL, AID, archive.STATEON) |
|
if err != nil { |
|
log.Error("d.db.Staffs aid(%d) error(%v)", AID, err) |
|
return |
|
} |
|
defer rows.Close() |
|
for rows.Next() { |
|
f := &archive.Staff{} |
|
if err = rows.Scan(&f.ID, &f.AID, &f.MID, &f.StaffMID, &f.StaffTitle, &f.StaffTitleID, &f.State); err != nil { |
|
log.Error("rows.Scan error(%v)", err) |
|
return |
|
} |
|
fs = append(fs, f) |
|
} |
|
return |
|
} |
|
|
|
// Staff get . |
|
func (d *Dao) Staff(c context.Context, ID int64) (s *archive.Staff, err error) { |
|
row := d.db.QueryRow(c, _staffByIDSQL, ID) |
|
s = &archive.Staff{} |
|
if err = row.Scan(&s.ID, &s.AID, &s.MID, &s.StaffMID, &s.StaffTitle, &s.StaffTitleID, &s.State); err != nil { |
|
if err == sql.ErrNoRows { |
|
s = nil |
|
err = nil |
|
} else { |
|
log.Error("row.Scan error(%v)", err) |
|
} |
|
return |
|
} |
|
return |
|
} |
|
|
|
// StaffByAidAndMid get . |
|
func (d *Dao) StaffByAidAndMid(c context.Context, AID, StaffMid int64) (s *archive.Staff, err error) { |
|
row := d.db.QueryRow(c, _staffByAIdMIDSQL, AID, StaffMid) |
|
s = &archive.Staff{} |
|
if err = row.Scan(&s.ID, &s.AID, &s.MID, &s.StaffMID, &s.StaffTitle, &s.StaffTitleID, &s.State); err != nil { |
|
if err == sql.ErrNoRows { |
|
s = nil |
|
err = nil |
|
} else { |
|
log.Error("row.Scan error(%v)", err) |
|
} |
|
return |
|
} |
|
return |
|
}
|
|
|