feat(task): 添加任务更新功能

This commit is contained in:
2026-06-10 16:47:21 +08:00
parent 2dc88ae587
commit 7596cbde09

View File

@@ -30,6 +30,19 @@ func (d *taskDao) Insert(ctx context.Context, req *entity.AsynchTask) (id int64,
return r.LastInsertId()
}
// Update 更新
func (d *taskDao) Update(ctx context.Context, req *entity.AsynchTask) (rows int64, err error) {
r, err := gfdb.DB(ctx, public.DbNameModelGateway).Model(ctx, public.TableNameTask).
OmitEmpty().
Data(&req).
Where(entity.AsynchTaskCol.Id, req.Id).
Update()
if err != nil {
return
}
return r.RowsAffected()
}
// Get 获取
func (d *taskDao) Get(ctx context.Context, req *entity.AsynchTask, fields ...string) (m *entity.AsynchTask, err error) {
r, err := gfdb.DB(ctx, public.DbNameModelGateway).Model(ctx, public.TableNameTask).