itemHistoryDataFirstLastByTimeLogic.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. package logic
  2. import (
  3. "GtDataStore/app/cmd/organization/internal/svc"
  4. "GtDataStore/app/cmd/organization/pb"
  5. "GtDataStore/common/xerr"
  6. "context"
  7. "github.com/pkg/errors"
  8. "github.com/zeromicro/go-zero/core/logx"
  9. )
  10. type ItemHistoryDataFirstLastByTimeLogic struct {
  11. ctx context.Context
  12. svcCtx *svc.ServiceContext
  13. logx.Logger
  14. }
  15. func NewItemHistoryDataFirstLastByTimeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ItemHistoryDataFirstLastByTimeLogic {
  16. return &ItemHistoryDataFirstLastByTimeLogic{
  17. ctx: ctx,
  18. svcCtx: svcCtx,
  19. Logger: logx.WithContext(ctx),
  20. }
  21. }
  22. func (l *ItemHistoryDataFirstLastByTimeLogic) ItemHistoryDataFirstLastByTime(in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataFirstLastResp, error) {
  23. FirstData, err := l.svcCtx.ItemHistoryData.QueryHistoryDataFirstByTime(l.ctx, in)
  24. if err != nil {
  25. return nil, errors.Wrapf(xerr.NewErrCode(xerr.DB_ERROR), "model QueryHistoryDataFirstByTime get data err:%v", err)
  26. }
  27. LastData, err := l.svcCtx.ItemHistoryData.QueryHistoryDataLastByTime(l.ctx, in)
  28. if err != nil {
  29. return nil, errors.Wrapf(xerr.NewErrCode(xerr.DB_ERROR), "model QueryHistoryDataLastByTime get data err:%v", err)
  30. }
  31. return &pb.ItemHistoryDataFirstLastResp{
  32. First: FirstData.Val,
  33. Last: LastData.Val,
  34. }, nil
  35. }