diff --git a/link_homework/internal/controller/clientPage/clientPage.go b/link_homework/internal/controller/clientPage/clientPage.go index 9c7b91b..9329225 100644 --- a/link_homework/internal/controller/clientPage/clientPage.go +++ b/link_homework/internal/controller/clientPage/clientPage.go @@ -39,8 +39,7 @@ func (c *ClientPage) GetHomeworkQuestion(r *ghttp.Request) { Message: err.Error(), }) } - groupId := req.Id - result, err := service.Client().GetHomeworkQuestion(r.Context(), groupId) + result, err := service.Client().GetHomeworkQuestion(r.Context(), req.Id) if err != nil { r.Response.WriteJsonExit(dto.Result{ Code: 400, @@ -73,7 +72,6 @@ func (c *ClientPage) CommitHomework(r *ghttp.Request) { } r.Response.WriteJsonExit(dto.Result{ Code: 200, - Message: "success", + Message: "提交作业成功", }) - } diff --git a/link_homework/internal/controller/record/manageRecord.go b/link_homework/internal/controller/record/manageRecord.go index cb7dd08..528512e 100644 --- a/link_homework/internal/controller/record/manageRecord.go +++ b/link_homework/internal/controller/record/manageRecord.go @@ -22,10 +22,7 @@ func (m *ManageRecord) GetRecordList(r *ghttp.Request) { Message: err.Error(), }) } - groupId := req.Id - pageNo := req.PageNo - pageSize := req.PageSize - result, err := service.Record().GetRecordList(r.Context(), groupId, pageNo, pageSize) + result, err := service.Record().GetRecordList(r.Context(), req.Id, req.PageNo, req.PageSize) if err != nil { r.Response.WriteJsonExit(dto.Result{ Code: 400, @@ -48,13 +45,7 @@ func (m *ManageRecord) GetRecordByCondition(r *ghttp.Request) { Message: err.Error(), }) } - groupId := req.Id - jwcode := req.Jwcode - deptId := req.DeptId - shopId := req.ShopId - pageNo := req.PageNo - pageSize := req.PageSize - result, err := service.Record().GetRecordByCondition(r.Context(), groupId, jwcode, deptId, shopId, pageNo, pageSize) + result, err := service.Record().GetRecordByCondition(r.Context(), req.Id, req.Jwcode, req.DeptId, req.ShopId, req.PageNo, req.PageSize) if err != nil { r.Response.WriteJsonExit(dto.Result{ Code: 400, @@ -93,8 +84,7 @@ func (m *ManageRecord) GetShopInfo(r *ghttp.Request) { Message: err.Error(), }) } - deptId := req.DeptId - result, err := service.Record().GetShopInfoByDeptId(r.Context(), deptId) + result, err := service.Record().GetShopInfoByDeptId(r.Context(), req.DeptId) if err != nil { r.Response.WriteJsonExit(dto.Result{ Code: 400, diff --git a/link_homework/internal/logic/client/client.go b/link_homework/internal/logic/client/client.go index 7f6be94..378d3a0 100644 --- a/link_homework/internal/logic/client/client.go +++ b/link_homework/internal/logic/client/client.go @@ -51,30 +51,36 @@ func (s *sClient) CommitHomework(ctx context.Context, req ClientPage.CommitHomew //req中需要有:作业id,提交的每一个题的答案,每一个提的类型 for _, answer := range req.CommitedAnswer { if answer.Type == 1 { //单选或者多选 - num, err := dao.ActivityInteractiveRecord.Ctx(ctx).Data(g.Map{ + _, err := dao.ActivityInteractiveRecord.Ctx(ctx).Data(g.Map{ "jwcode": jwcode, "form_id": answer.Id, "group_id": req.GroupId, "content": answer.Answer[0], }).Insert() - fmt.Println(num, err) + if err != nil { + return err + } } else if answer.Type == 2 { //多选 - num, err := dao.ActivityInteractiveRecord.Ctx(ctx).Data(g.Map{ + _, err := dao.ActivityInteractiveRecord.Ctx(ctx).Data(g.Map{ "jwcode": jwcode, "form_id": answer.Id, "group_id": req.GroupId, "content": answer.Answer, }).Insert() - fmt.Println(num, err) + if err != nil { + return err + } } else if answer.Type == 3 { //简答 - num, err := dao.ActivityInteractiveRecord.Ctx(ctx).Data(g.Map{ + _, err := dao.ActivityInteractiveRecord.Ctx(ctx).Data(g.Map{ "jwcode": jwcode, "form_id": answer.Id, "group_id": req.GroupId, "content_title": answer.Answer[0], "content": answer.Answer[1], }).Insert() - fmt.Println(num, err) + if err != nil { + return err + } } } return diff --git a/link_homework/internal/logic/homework/.gitkeep b/link_homework/internal/logic/homework/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/link_homework/internal/logic/record/record.go b/link_homework/internal/logic/record/record.go index 1783d51..0900281 100644 --- a/link_homework/internal/logic/record/record.go +++ b/link_homework/internal/logic/record/record.go @@ -27,7 +27,7 @@ func (s *sRecord) GetRecordList(ctx context.Context, groupId, pageNo, pageSize i err = dao.ActivityInteractiveRecord.Ctx(ctx).Fields("jwcode").Where("group_id", groupId).Group("jwcode"). Page(pageNo, pageSize).Scan(&record) if err != nil { - panic("无条件查jwcode失败") + return nil, errors.New("无条件查jwcode失败") } fmt.Println(record) @@ -36,7 +36,7 @@ func (s *sRecord) GetRecordList(ctx context.Context, groupId, pageNo, pageSize i err = g.DB("cms").Model("member_info").Fields("jwcode", "name", "deptId", "deptName", "shopId", "shopName"). Where("jwcode", info.Jwcode).Scan(&record[i]) if err != nil { - panic("无条件根据jwcode查member_info表失败") + return nil, errors.New("无条件根据jwcode查member_info表失败") } total, err1 := dao.ActivityInteractiveRecord.Ctx(ctx).Fields("jwcode").Where("group_id", groupId).Group("jwcode").Count() if err1 != nil { @@ -47,8 +47,14 @@ func (s *sRecord) GetRecordList(ctx context.Context, groupId, pageNo, pageSize i var recordInfo []dto.RecordInfo err = dao.ActivityInteractiveRecord.Ctx(ctx).Fields("content", "content_title", "updated_at", "form_id"). Where("jwcode", info.Jwcode).Where("group_id", groupId).Group("form_id").Order("updated_at desc").Scan(&recordInfo) //不是最新的,需要再改 + if err != nil { + return nil, err + } for i, title := range recordInfo { err = dao.ActivityInteractiveForm.Ctx(ctx).Fields("description", "type").Where("id", title.FormId).Scan(&recordInfo[i]) + if err != nil { + return nil, err + } } record[i].Reply = recordInfo fmt.Println(record) @@ -61,12 +67,12 @@ func (s *sRecord) GetRecordByCondition(ctx context.Context, groupId, jwcode int, //全查 recordList, err := s.GetRecordList(ctx, groupId, pageNo, pageSize) if err != nil { - return nil, err + return recordList, err } //判断传来的jwcode, deptId, shopId是否为空,根据情况进行不同的筛选 if jwcode == 0 { //没有传jwcode if deptId == "" && shopId == "" { //000 - return recordList, nil + return recordList, err } else if deptId != "" && shopId == "" { //010 for _, info := range recordList { if info.DeptId == deptId { diff --git a/link_homework/internal/service/homework.go b/link_homework/internal/service/homework.go deleted file mode 100644 index 7c0b2d2..0000000 --- a/link_homework/internal/service/homework.go +++ /dev/null @@ -1,37 +0,0 @@ -// ================================================================================ -// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. -// You can delete these comments if you wish manually maintain this interface file. -// ================================================================================ - -package service - -import ( - "context" - "link_homework/api/v1/homework" - "link_homework/internal/model/entity" -) - -type ( - IHomework interface { - GetHomeworkList(ctx context.Context, pageNo int, pageSize int) (homeworkList []*entity.ActivityInteractiveGroup, err error) - GetHomeworkListTotal(ctx context.Context) (total int, err error) - GetHomework(ctx context.Context, id int) (homework *entity.ActivityInteractiveGroup, err error) - AddHomework(ctx context.Context, req *homework.AddHomeworkReq) (err error) - EditHomework(ctx context.Context, req *homework.EditHomeworkReq) (err error) - } -) - -var ( - localHomework IHomework -) - -func Homework() IHomework { - if localHomework == nil { - panic("implement not found for interface IHomework, forgot register?") - } - return localHomework -} - -func RegisterHomework(i IHomework) { - localHomework = i -} diff --git a/link_homework/manifest/config/config.yaml b/link_homework/manifest/config/config.yaml index 90f42d2..14013af 100644 --- a/link_homework/manifest/config/config.yaml +++ b/link_homework/manifest/config/config.yaml @@ -18,7 +18,7 @@ database: link: "mysql:cms:AF42R3ib6YkFaemm@tcp(39.101.133.168:3306)/cms?charset=utf8mb4&parseTime=True&loc=Local" debug: true -# redis暂不配置,记得加 +# redis配置 redis: default: address: "127.0.0.1:6379"