提交

jyBXCore/api/internal/handler/operatorSearchCriteriaHandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/logic"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/svc"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func operatorSearchCriteriaHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.OperatorSearchCriteriaReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewOperatorSearchCriteriaLogic(r.Context(), svcCtx)
+		resp, err := l.OperatorSearchCriteria(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

jyBXCore/api/internal/handler/operatorSearchHandler.go

@@ -0,0 +1,28 @@
+package handler
+
+import (
+	"net/http"
+
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/logic"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/svc"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/types"
+	"github.com/zeromicro/go-zero/rest/httpx"
+)
+
+func operatorSearchHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.OperatorSearchReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := logic.NewOperatorSearchLogic(r.Context(), svcCtx)
+		resp, err := l.OperatorSearch(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

jyBXCore/api/internal/logic/operatorSearchCriteriaLogic.go

@@ -0,0 +1,41 @@
+package logic
+
+import (
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/rpc/bxcore"
+	"context"
+	"github.com/gogf/gf/v2/util/gconv"
+
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/svc"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type OperatorSearchCriteriaLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewOperatorSearchCriteriaLogic(ctx context.Context, svcCtx *svc.ServiceContext) *OperatorSearchCriteriaLogic {
+	return &OperatorSearchCriteriaLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *OperatorSearchCriteriaLogic) OperatorSearchCriteria(req *types.OperatorSearchCriteriaReq) (resp *types.CommonResp, err error) {
+	// todo: add your logic here and delete this line
+	res, err := l.svcCtx.BxCore.OperatorSearchCriteria(l.ctx, &bxcore.OperatorSearchCriteriaReq{
+		EntId:      req.EntId,
+		Tag:        req.Tag,
+		PositionId: req.PositionId,
+	})
+	data := gconv.Map(gconv.UnsafeBytesToStr(res.Data))
+	return &types.CommonResp{
+		Err_code: 0,
+		Err_msg:  "",
+		Data:     data,
+	}, nil
+}

jyBXCore/api/internal/logic/operatorSearchLogic.go

@@ -0,0 +1,55 @@
+package logic
+
+import (
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/svc"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/api/internal/types"
+	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/rpc/bxcore"
+	"context"
+	"github.com/gogf/gf/v2/util/gconv"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type OperatorSearchLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewOperatorSearchLogic(ctx context.Context, svcCtx *svc.ServiceContext) *OperatorSearchLogic {
+	return &OperatorSearchLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *OperatorSearchLogic) OperatorSearch(req *types.OperatorSearchReq) (resp *types.CommonResp, err error) {
+	// todo: add your logic here and delete this line
+	res, err := l.svcCtx.BxCore.OperatorSearch(l.ctx, &bxcore.OperatorSearchReq{
+		EntId:        req.EntId,
+		Tag:          req.Tag,
+		PageNum:      req.PageNum,
+		PageSize:     req.PageSize,
+		Province:     req.Province,
+		TopType:      req.TopType,
+		PublishTime:  req.PublishTime,
+		SelectType:   req.SelectType,
+		Price:        req.Price,
+		Tagname:      req.Tagname,
+		Tagname1:     req.Tagname1,
+		Tagname2:     req.Tagname2,
+		WordsMode:    req.WordsMode,
+		KeyWords:     req.KeyWords,
+		PurchaseTime: req.PurchaseTime,
+		OpeningTime:  req.OpeningTime,
+		WinnerTag:    req.WinnerTag,
+		PositionId:   req.PositionId,
+	})
+	data := gconv.Map(gconv.UnsafeBytesToStr(res.Data))
+	return &types.CommonResp{
+		Err_code: 0,
+		Err_msg:  "",
+		Data:     data,
+	}, nil
+}