修改Model
This commit is contained in:
@@ -50,6 +50,7 @@ type (
|
|||||||
Reviewers string `db:"reviewers"` // 审核者名单(多个用逗号分隔)
|
Reviewers string `db:"reviewers"` // 审核者名单(多个用逗号分隔)
|
||||||
PublishTime time.Time `db:"publish_time"` // 发布时间(默认插入时的当前时间)
|
PublishTime time.Time `db:"publish_time"` // 发布时间(默认插入时的当前时间)
|
||||||
UpdateTime time.Time `db:"update_time"` // 最后更改时间(自动更新)
|
UpdateTime time.Time `db:"update_time"` // 最后更改时间(自动更新)
|
||||||
|
IsDelete int64 `db:"is_delete"` // 逻辑删除标识:0-未删除,1-已删除
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -61,7 +62,8 @@ func newSocialServiceModel(conn sqlx.SqlConn) *defaultSocialServiceModel {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (m *defaultSocialServiceModel) Delete(ctx context.Context, id int64) error {
|
func (m *defaultSocialServiceModel) Delete(ctx context.Context, id int64) error {
|
||||||
query := fmt.Sprintf("delete from %s where `id` = ?", m.table)
|
// 逻辑删除:更新 is_delete 为 1,而非物理删除
|
||||||
|
query := fmt.Sprintf("UPDATE %s SET `is_delete` = 1, `update_time` = CURRENT_TIMESTAMP WHERE `id` = ? AND `is_delete` = 0", m.table)
|
||||||
_, err := m.conn.ExecCtx(ctx, query, id)
|
_, err := m.conn.ExecCtx(ctx, query, id)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -81,14 +83,14 @@ func (m *defaultSocialServiceModel) FindOne(ctx context.Context, id int64) (*Soc
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (m *defaultSocialServiceModel) Insert(ctx context.Context, data *SocialService) (sql.Result, error) {
|
func (m *defaultSocialServiceModel) Insert(ctx context.Context, data *SocialService) (sql.Result, error) {
|
||||||
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, socialServiceRowsExpectAutoSet)
|
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, socialServiceRowsExpectAutoSet)
|
||||||
ret, err := m.conn.ExecCtx(ctx, query, data.Title, data.Subtitle, data.CoverUrl, data.Intro, data.Content, data.ImageEditors, data.TextEditors, data.ChiefEditor, data.Proofreaders, data.Reviewers, data.PublishTime)
|
ret, err := m.conn.ExecCtx(ctx, query, data.Title, data.Subtitle, data.CoverUrl, data.Intro, data.Content, data.ImageEditors, data.TextEditors, data.ChiefEditor, data.Proofreaders, data.Reviewers, data.PublishTime, data.IsDelete)
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *defaultSocialServiceModel) Update(ctx context.Context, data *SocialService) error {
|
func (m *defaultSocialServiceModel) Update(ctx context.Context, data *SocialService) error {
|
||||||
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, socialServiceRowsWithPlaceHolder)
|
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, socialServiceRowsWithPlaceHolder)
|
||||||
_, err := m.conn.ExecCtx(ctx, query, data.Title, data.Subtitle, data.CoverUrl, data.Intro, data.Content, data.ImageEditors, data.TextEditors, data.ChiefEditor, data.Proofreaders, data.Reviewers, data.PublishTime, data.Id)
|
_, err := m.conn.ExecCtx(ctx, query, data.Title, data.Subtitle, data.CoverUrl, data.Intro, data.Content, data.ImageEditors, data.TextEditors, data.ChiefEditor, data.Proofreaders, data.Reviewers, data.PublishTime, data.IsDelete, data.Id)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user