itemHistoryDataByTimeLogic.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  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/jinzhu/copier"
  8. "github.com/pkg/errors"
  9. "github.com/zeromicro/go-zero/core/logx"
  10. )
  11. type ItemHistoryDataByTimeLogic struct {
  12. ctx context.Context
  13. svcCtx *svc.ServiceContext
  14. logx.Logger
  15. }
  16. func NewItemHistoryDataByTimeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ItemHistoryDataByTimeLogic {
  17. return &ItemHistoryDataByTimeLogic{
  18. ctx: ctx,
  19. svcCtx: svcCtx,
  20. Logger: logx.WithContext(ctx),
  21. }
  22. }
  23. func (l *ItemHistoryDataByTimeLogic) ItemHistoryDataByTime(in *pb.ItemHistoryDataByTimeReq) (*pb.MultiAddItemHistoryDataReq, error) {
  24. modeList, err := l.svcCtx.ItemHistoryData.QueryHistoryDataByTime(l.ctx, in)
  25. if err != nil {
  26. return nil, errors.Wrapf(xerr.NewErrCode(xerr.DB_ERROR), "model QueryHistoryDataByTime get data err:%v", err)
  27. }
  28. dataList := make([]*pb.ItemHistoryData, 0)
  29. for _, line := range modeList {
  30. tmp := &pb.ItemHistoryData{}
  31. _ = copier.Copy(tmp, line)
  32. tmp.CTime = line.CTime.Format("2006-01-02 15:04:05")
  33. dataList = append(dataList, tmp)
  34. }
  35. return &pb.MultiAddItemHistoryDataReq{List: dataList}, nil
  36. }