|
@ -32,7 +32,7 @@ func (s *sHomework) GetHomeworkList(ctx context.Context, pageNo int, pageSize in |
|
|
if value.String() != "" { |
|
|
if value.String() != "" { |
|
|
// 如果Redis中有数据,尝试解析为ActivityInteractiveGroup列表
|
|
|
// 如果Redis中有数据,尝试解析为ActivityInteractiveGroup列表
|
|
|
err = json.Unmarshal(value.Bytes(), &homeworkList) //反序列化
|
|
|
err = json.Unmarshal(value.Bytes(), &homeworkList) //反序列化
|
|
|
homeworkList = UpdateHomework(ctx, homeworkList) |
|
|
|
|
|
|
|
|
//homeworkList = UpdateHomework(ctx, homeworkList)
|
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return nil, err |
|
|
return nil, err |
|
|
} |
|
|
} |
|
@ -45,11 +45,16 @@ func (s *sHomework) GetHomeworkList(ctx context.Context, pageNo int, pageSize in |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return nil, err |
|
|
return nil, err |
|
|
} |
|
|
} |
|
|
|
|
|
homeworkList = UpdateHomework(ctx, homeworkList) |
|
|
|
|
|
|
|
|
// 将查询到的作业列表序列化并存储到Redis,更新频繁变更的数据
|
|
|
// 将查询到的作业列表序列化并存储到Redis,更新频繁变更的数据
|
|
|
homeworkListJson, _ := json.Marshal(homeworkList) |
|
|
homeworkListJson, _ := json.Marshal(homeworkList) |
|
|
_, _ = g.Redis().Set(ctx, fmt.Sprintf("%d-%d homeworklist", pageNo, pageSize), homeworkListJson) |
|
|
|
|
|
homeworkList = UpdateHomework(ctx, homeworkList) |
|
|
|
|
|
|
|
|
_, err = g.Redis().Set(ctx, fmt.Sprintf("%d-%d homeworklist", pageNo, pageSize), homeworkListJson) |
|
|
|
|
|
if err != nil { |
|
|
|
|
|
fmt.Println("redis set error", err) |
|
|
|
|
|
return nil, err |
|
|
|
|
|
} |
|
|
|
|
|
//homeworkList = UpdateHomework(ctx, homeworkList)
|
|
|
|
|
|
|
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
@ -76,6 +81,12 @@ func (s *sHomework) GetHomeworkListTotal(ctx context.Context) (total int, err er |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (s *sHomework) GetHomework(ctx context.Context, id int) (homework *entity.ActivityInteractiveGroup, err error) { |
|
|
|
|
|
err = dao.ActivityInteractiveGroup.Ctx(ctx).Where("id", id).With(entity.Live{}, entity.ActivityInteractiveForm{}).Scan(&homework) |
|
|
|
|
|
err = g.DB("cms").Model("fx_article").Where("id", homework.ArticleId).Scan(&homework.Article) |
|
|
|
|
|
return |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
func (s *sHomework) AddHomework(ctx context.Context, req *homework.AddHomeworkReq) (err error) { |
|
|
func (s *sHomework) AddHomework(ctx context.Context, req *homework.AddHomeworkReq) (err error) { |
|
|
// 判断作业是否已结束
|
|
|
// 判断作业是否已结束
|
|
|
status := 0 |
|
|
status := 0 |
|
|