package Wx import ( "context" "wechat-api/ent/wx" "wechat-api/ent/predicate" "wechat-api/internal/svc" "wechat-api/internal/types" "wechat-api/internal/utils/dberrorhandler" "github.com/suyuan32/simple-admin-common/msg/errormsg" "github.com/suyuan32/simple-admin-common/utils/pointy" "github.com/zeromicro/go-zero/core/logx" ) type GetWxListLogic struct { ctx context.Context svcCtx *svc.ServiceContext logx.Logger } func NewGetWxListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetWxListLogic { return &GetWxListLogic{ ctx: ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } } func (l *GetWxListLogic) GetWxList(req *types.WxListReq) (*types.WxListResp, error) { var predicates []predicate.Wx if req.Port != nil { predicates = append(predicates, wx.PortContains(*req.Port)) } if req.ProcessId != nil { predicates = append(predicates, wx.ProcessIDContains(*req.ProcessId)) } if req.Callback != nil { predicates = append(predicates, wx.CallbackContains(*req.Callback)) } data, err := l.svcCtx.DB.Wx.Query().Where(predicates...).Page(l.ctx, req.Page, req.PageSize) if err != nil { return nil, dberrorhandler.DefaultEntError(l.Logger, err, req) } resp := &types.WxListResp{} resp.Msg = errormsg.Success resp.Data.Total = data.PageDetails.Total for _, v := range data.List { resp.Data.Data = append(resp.Data.Data, types.WxInfo{ BaseIDInfo: types.BaseIDInfo{ Id: &v.ID, CreatedAt: pointy.GetPointer(v.CreatedAt.UnixMilli()), UpdatedAt: pointy.GetPointer(v.UpdatedAt.UnixMilli()), }, Status: &v.Status, ServerId: &v.ServerID, Port: &v.Port, ProcessId: &v.ProcessID, Callback: &v.Callback, Wxid: &v.Wxid, Account: &v.Account, Nickname: &v.Nickname, Tel: &v.Tel, HeadBig: &v.HeadBig, }) } return resp, nil }