integralconsumelogic.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. package logic
  2. import (
  3. "app.yhyue.com/moapp/jyPoints/rpc/integral"
  4. "context"
  5. "app.yhyue.com/moapp/jyPoints/api/internal/svc"
  6. "app.yhyue.com/moapp/jyPoints/api/internal/types"
  7. "github.com/zeromicro/go-zero/core/logx"
  8. )
  9. type IntegralConsumeLogic struct {
  10. logx.Logger
  11. ctx context.Context
  12. svcCtx *svc.ServiceContext
  13. }
  14. func NewIntegralConsumeLogic(ctx context.Context, svcCtx *svc.ServiceContext) IntegralConsumeLogic {
  15. return IntegralConsumeLogic{
  16. Logger: logx.WithContext(ctx),
  17. ctx: ctx,
  18. svcCtx: svcCtx,
  19. }
  20. }
  21. // 积分消耗
  22. func (l *IntegralConsumeLogic) IntegralConsume(req types.ConsumeReq) (*types.ConsumeResp, error) {
  23. // todo: add your logic here and delete this line
  24. result := &types.ConsumeResp{}
  25. lsi := l.svcCtx.Integral
  26. resp, err := lsi.IntegralConsume(l.ctx, &integral.Req{
  27. UserId: req.UserId,
  28. AppId: req.AppId,
  29. EndDate: req.EndDate,
  30. SourceType: req.SourceType,
  31. SourceId: req.SourceId,
  32. PointType: req.PointType,
  33. Point: req.Point,
  34. Abstract: req.Abstract,
  35. })
  36. if err != nil {
  37. return nil, err
  38. }
  39. result.Code = resp.Code
  40. result.Message = resp.Message
  41. result.SerialNumber = resp.SerialNumber
  42. return result, nil
  43. }