Browse Source

12月18日合并调整后的lijikun分支

dev_ljk
lijikun 5 months ago
parent
commit
857a110da7
  1. 6
      link_homework/internal/controller/clientPage/clientPage.go
  2. 16
      link_homework/internal/controller/record/manageRecord.go
  3. 18
      link_homework/internal/logic/client/client.go
  4. 0
      link_homework/internal/logic/homework/.gitkeep
  5. 14
      link_homework/internal/logic/record/record.go
  6. 37
      link_homework/internal/service/homework.go
  7. 2
      link_homework/manifest/config/config.yaml

6
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: "提交作业成功",
})
}

16
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,

18
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

0
link_homework/internal/logic/homework/.gitkeep

14
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 {

37
link_homework/internal/service/homework.go

@ -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
}

2
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"

Loading…
Cancel
Save