wip:员工订阅查询代码提交

jyBXSubscribe/api/internal/logic/getstaffsubscribedetaillogic.go

@@ -0,0 +1,57 @@
+package logic
+
+import (
+	"context"
+	"encoding/json"
+	"jyBXSubscribe/rpc/type/bxsubscribe"
+
+	"jyBXSubscribe/api/internal/svc"
+	"jyBXSubscribe/api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GetStaffSubscribeDetailLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGetStaffSubscribeDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetStaffSubscribeDetailLogic {
+	return &GetStaffSubscribeDetailLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GetStaffSubscribeDetailLogic) GetStaffSubscribeDetail(req *types.GetStaffSubscribeDetailReq) (resp *types.StaffSubscribeCommonResp, err error) {
+	res, err := l.svcCtx.Suscribe.GetStaffSubscribeDetail(l.ctx, &bxsubscribe.StaffSubscribeDetailReq{
+		EntId:     req.EntId,
+		EntUserId: req.EntUserId,
+		StaffId:   req.StaffId,
+	})
+	if err != nil {
+		return nil, err
+	}
+	if res.ErrCode != 0 {
+		return &types.StaffSubscribeCommonResp{
+			Err_code: res.ErrCode,
+			Err_msg:  res.ErrMsg,
+			Data:     nil,
+		}, nil
+	}
+	subscribeDetail := map[string]interface{}{}
+	if err := json.Unmarshal(res.Data, &subscribeDetail); err != nil {
+		return &types.StaffSubscribeCommonResp{
+			Err_code: res.ErrCode,
+			Err_msg:  "返回异常",
+			Data:     nil,
+		}, nil
+	}
+	return &types.StaffSubscribeCommonResp{
+		Err_code: res.ErrCode,
+		Err_msg:  res.ErrMsg,
+		Data:     subscribeDetail,
+	}, nil
+}

jyBXSubscribe/api/internal/logic/getstaffsubscribelistlogic.go

@@ -0,0 +1,56 @@
+package logic
+
+import (
+	"context"
+	"jyBXSubscribe/rpc/type/bxsubscribe"
+
+	"jyBXSubscribe/api/internal/svc"
+	"jyBXSubscribe/api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GetStaffSubscribeListLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGetStaffSubscribeListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetStaffSubscribeListLogic {
+	return &GetStaffSubscribeListLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GetStaffSubscribeListLogic) GetStaffSubscribeList(req *types.GetStaffSubscribeListReq) (resp *types.StaffSubscribeCommonResp, err error) {
+	res, err := l.svcCtx.Suscribe.GetStaffSubscribeList(l.ctx, &bxsubscribe.StaffSubscribeReq{
+		AppId:     req.AppId,
+		EntId:     req.EntId,
+		EntUserId: req.EntUserId,
+		Query:     req.Search,
+		EStatus:   req.EStatus,
+		PStatus:   req.PStatus,
+		PageNum:   req.PageNum,
+		PageSize:  req.PageSize,
+	})
+	if err != nil {
+		return nil, err
+	}
+	if res.ErrCode != 0 {
+		return &types.StaffSubscribeCommonResp{
+			Err_code: res.ErrCode,
+			Err_msg:  res.ErrMsg,
+			Data:     nil,
+		}, nil
+	}
+	return &types.StaffSubscribeCommonResp{
+		Err_code: res.ErrCode,
+		Err_msg:  res.ErrMsg,
+		Data: map[string]interface{}{
+			"total": res.Total,
+			"list":  res.Items,
+		},
+	}, nil
+}

jyBXSubscribe/rpc/internal/logic/getstaffsubscribedetaillogic.go

@@ -0,0 +1,43 @@
+package logic
+
+import (
+	"context"
+	"github.com/gogf/gf/v2/util/gconv"
+	"jyBXSubscribe/rpc/model"
+
+	"jyBXSubscribe/rpc/internal/svc"
+	"jyBXSubscribe/rpc/type/bxsubscribe"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GetStaffSubscribeDetailLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGetStaffSubscribeDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetStaffSubscribeDetailLogic {
+	return &GetStaffSubscribeDetailLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// GetStaffSubscribeDetail 查看企业员工用户订阅详情
+func (l *GetStaffSubscribeDetailLogic) GetStaffSubscribeDetail(in *bxsubscribe.StaffSubscribeDetailReq) (*bxsubscribe.StaffSubscribeDetail, error) {
+	rData, err := model.GetStaffSubscribeDetail(in.EntId, in.EntUserId, in.StaffId)
+	if err != nil {
+		return &bxsubscribe.StaffSubscribeDetail{
+			ErrCode: -1,
+			ErrMsg:  err.Error(),
+			Data:    nil,
+		}, nil
+	}
+	return &bxsubscribe.StaffSubscribeDetail{
+		ErrCode: 0,
+		ErrMsg:  "",
+		Data:    gconv.Bytes(rData),
+	}, nil
+}

jyBXSubscribe/rpc/internal/logic/getstaffsubscribelistlogic.go

@@ -0,0 +1,38 @@
+package logic
+
+import (
+	"app.yhyue.com/moapp/jybase/common"
+	"context"
+	"github.com/gogf/gf/v2/util/gconv"
+	"jyBXSubscribe/rpc/model"
+
+	"jyBXSubscribe/rpc/internal/svc"
+	"jyBXSubscribe/rpc/type/bxsubscribe"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GetStaffSubscribeListLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGetStaffSubscribeListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetStaffSubscribeListLogic {
+	return &GetStaffSubscribeListLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+// GetStaffSubscribeList 查看企业员工用户订阅
+func (l *GetStaffSubscribeListLogic) GetStaffSubscribeList(in *bxsubscribe.StaffSubscribeReq) (*bxsubscribe.StaffSubscribeListResp, error) {
+	pNum := common.Int64All(common.If(in.PageNum < 0, 0, in.PageNum))
+	pSize := common.Int64All(common.If(in.PageSize != 0, in.PageSize, 5))
+	total, list := model.GetStaffSubscribeList(gconv.Int(in.EntId), gconv.Int(in.EntUserId), in.Query, in.EStatus, in.PStatus, pNum, pSize)
+	return &bxsubscribe.StaffSubscribeListResp{
+		Total: total,
+		Items: list,
+	}, nil
+}