Merge branch 'yhg_240730'

desc/wechat/sop_task.api

@@ -137,6 +137,11 @@ type (
         BaseDataInfo
         Data []string `json:"data"`
     }
+
+	SopApiListReq {
+		Page   uint64    `json:"page" validate:"required,number,gt=0"`
+		PageSize  uint64    `json:"pageSize" validate:"required,number,lt=2000"`
+	}
 )
 
 @server(
@@ -144,9 +149,8 @@ type (
 )
 
 service Wechat {
-	// Get sop task list | 获取SopTask列表
 	@handler getApiSopTaskList
-	post /api/sop_task/list () returns (SopTaskListResp)
+	post /api/sop_task/list (SopApiListReq) returns (SopTaskListResp)
 }
 
 @server(

internal/handler/sop_task/get_api_sop_task_list_handler.go

@@ -7,21 +7,34 @@ import (
 
 	"wechat-api/internal/logic/sop_task"
 	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
 )
 
 // swagger:route post /api/sop_task/list sop_task GetApiSopTaskList
 //
-// Get sop task list | 获取SopTask列表
+
+//
+
 //
-// Get sop task list | 获取SopTask列表
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: SopApiListReq
 //
 // Responses:
 //  200: SopTaskListResp
 
 func GetApiSopTaskListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.SopApiListReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
 		l := sop_task.NewGetApiSopTaskListLogic(r.Context(), svcCtx)
-		resp, err := l.GetApiSopTaskList(r)
+		resp, err := l.GetApiSopTaskList(&req, r)
 		if err != nil {
 			httpx.ErrorCtx(r.Context(), w, err)
 		} else {

internal/logic/sop_task/get_api_sop_task_list_logic.go

@@ -28,11 +28,10 @@ func NewGetApiSopTaskListLogic(ctx context.Context, svcCtx *svc.ServiceContext)
 	return &GetApiSopTaskListLogic{
 		Logger: logx.WithContext(ctx),
 		ctx:    ctx,
-		svcCtx: svcCtx,
-	}
+		svcCtx: svcCtx}
 }
 
-func (l *GetApiSopTaskListLogic) GetApiSopTaskList(r *http.Request) (*types.SopTaskListResp, error) {
+func (l *GetApiSopTaskListLogic) GetApiSopTaskList(req *types.SopApiListReq, r *http.Request) (*types.SopTaskListResp, error) {
 	tokenStr := r.Header.Get("Authorization")
 	token, err := hook.CheckDesktopAuth(tokenStr, l.svcCtx.DB)
 	if err != nil {
@@ -42,7 +41,7 @@ func (l *GetApiSopTaskListLogic) GetApiSopTaskList(r *http.Request) (*types.SopT
 	var predicates []predicate.SopTask
 	predicates = append(predicates, soptask.OrganizationIDEQ(token.OrganizationID))
 	predicates = append(predicates, soptask.StatusEQ(uint8(3)))
-	data, err := l.svcCtx.DB.SopTask.Query().Where(predicates...).Page(l.ctx, 1, 1000)
+	data, err := l.svcCtx.DB.SopTask.Query().Where(predicates...).Page(l.ctx, req.Page, req.PageSize)
 
 	if err != nil {
 		return nil, dberrorhandler.DefaultEntError(l.Logger, err, nil)

internal/types/types.go

@@ -1208,6 +1208,16 @@ type TestNodeResp struct {
 	Data []string `json:"data"`
 }
 
+// swagger:model SopApiListReq
+type SopApiListReq struct {
+	// required : true
+	// min : 0
+	Page uint64 `json:"page" validate:"required,number,gt=0"`
+	// required : true
+	// max : 2000
+	PageSize uint64 `json:"pageSize" validate:"required,number,lt=2000"`
+}
+
 // The response data of sop stage information | SopStage信息
 // swagger:model SopStageInfo
 type SopStageInfo struct {