135 lines
3.8 KiB
Go
135 lines
3.8 KiB
Go
package dao
|
|
|
|
import (
|
|
"context"
|
|
"strings"
|
|
"time"
|
|
|
|
"go-common/app/admin/main/reply/model"
|
|
xsql "go-common/library/database/sql"
|
|
)
|
|
|
|
const (
|
|
//state 0-上线 1-下线
|
|
_selEmojiSQL = "SELECT id,package_id,name,url,sort,state,remark from emoji order by package_id,sort"
|
|
_selEmojiByPidSQL = "SELECT id,package_id,name,url,sort,state,remark from emoji where package_id=? order by sort"
|
|
_selEmojiByNameSQL = "SELECT id from emoji where name=? "
|
|
_insertEmojiSQL = "INSERT INTO emoji (package_id, name, url, sort, state, remark, ctime, mtime ) VALUES (?, ?, ?, ?, ?, ?, ?, ?)"
|
|
_upEmojiSortSQL = "UPDATE emoji SET sort=?, mtime=? where id=?"
|
|
_upEmojiStateSQL = "UPDATE emoji SET state=?, mtime=? WHERE id=?"
|
|
_upEmojiSQL = "UPDATE emoji SET name=?, remark=?, url=?, mtime=? WHERE id=?"
|
|
_delEmojiByIDSQL = "DELETE from emoji where id=?"
|
|
_delEmojiByPidSQL = "DELETE from emoji where package_id=?"
|
|
)
|
|
|
|
// EmojiList get all emoji
|
|
func (d *Dao) EmojiList(c context.Context) (emojis []*model.Emoji, err error) {
|
|
rows, err := d.db.Query(c, _selEmojiSQL)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer rows.Close()
|
|
for rows.Next() {
|
|
emo := &model.Emoji{}
|
|
if err = rows.Scan(&emo.ID, &emo.PackageID, &emo.Name, &emo.URL, &emo.Sort, &emo.State, &emo.Remark); err != nil {
|
|
return
|
|
}
|
|
emojis = append(emojis, emo)
|
|
}
|
|
err = rows.Err()
|
|
return
|
|
}
|
|
|
|
// EmojiListByPid get emoji by package_id
|
|
func (d *Dao) EmojiListByPid(c context.Context, pid int64) (emojis []*model.Emoji, err error) {
|
|
rows, err := d.db.Query(c, _selEmojiByPidSQL, pid)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer rows.Close()
|
|
for rows.Next() {
|
|
emo := &model.Emoji{}
|
|
if err = rows.Scan(&emo.ID, &emo.PackageID, &emo.Name, &emo.URL, &emo.Sort, &emo.State, &emo.Remark); err != nil {
|
|
return
|
|
}
|
|
emojis = append(emojis, emo)
|
|
}
|
|
err = rows.Err()
|
|
return
|
|
}
|
|
|
|
// EmojiByName get emoji by name
|
|
func (d *Dao) EmojiByName(c context.Context, name string) (emojis []*model.Emoji, err error) {
|
|
rows, err := d.db.Query(c, _selEmojiByNameSQL, name)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer rows.Close()
|
|
for rows.Next() {
|
|
emo := &model.Emoji{}
|
|
if err = rows.Scan(&emo.ID); err != nil {
|
|
return
|
|
}
|
|
emojis = append(emojis, emo)
|
|
}
|
|
err = rows.Err()
|
|
return
|
|
}
|
|
|
|
// CreateEmoji insert a emoji into db
|
|
func (d *Dao) CreateEmoji(c context.Context, pid int64, name string, url string, sort int32, state int32, remark string) (id int64, err error) {
|
|
result, err := d.db.Exec(c, _insertEmojiSQL, pid, name, url, sort, state, remark, time.Now(), time.Now())
|
|
if err != nil {
|
|
return
|
|
}
|
|
return result.LastInsertId()
|
|
}
|
|
|
|
// UpEmojiSort udpate emoji sort
|
|
func (d *Dao) UpEmojiSort(tx *xsql.Tx, ids string) (err error) {
|
|
idx := strings.Split(ids, ",")
|
|
for sort, id := range idx {
|
|
_, err = tx.Exec(_upEmojiSortSQL, sort, time.Now(), id)
|
|
if err != nil {
|
|
return
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// UpEmojiStateByID update emoji state
|
|
func (d *Dao) UpEmojiStateByID(c context.Context, state int32, id int64) (idx int64, err error) {
|
|
result, err := d.db.Exec(c, _upEmojiStateSQL, state, time.Now(), id)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return result.RowsAffected()
|
|
}
|
|
|
|
// UpEmoji update emoji name and remark by id
|
|
func (d *Dao) UpEmoji(c context.Context, name string, remark string, url string, id int64) (idx int64, err error) {
|
|
result, err := d.db.Exec(c, _upEmojiSQL, name, remark, url, time.Now(), id)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return result.RowsAffected()
|
|
}
|
|
|
|
// DelEmojiByID delete emoji by id
|
|
func (d *Dao) DelEmojiByID(c context.Context, id int64) (idx int64, err error) {
|
|
result, err := d.db.Exec(c, _delEmojiByIDSQL, id)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return result.RowsAffected()
|
|
}
|
|
|
|
// DelEmojiByPid delete emoji by package_id
|
|
func (d *Dao) DelEmojiByPid(c context.Context, pid int64) (idx int64, err error) {
|
|
result, err := d.db.Exec(c, _delEmojiByPidSQL, pid)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return result.RowsAffected()
|
|
}
|