96 lines
3.6 KiB
Go
96 lines
3.6 KiB
Go
package logic
|
|
|
|
import (
|
|
"github.com/fonchain/fonchain-artistinfo/cmd/internal/dao"
|
|
"github.com/fonchain/fonchain-artistinfo/pb/artistinfoStatement"
|
|
"github.com/fonchain/fonchain-artistinfo/pkg/util/stime"
|
|
"google.golang.org/protobuf/types/known/emptypb"
|
|
)
|
|
|
|
type StatementServerLogic struct{}
|
|
|
|
func (s *StatementServerLogic) CreateStatementBatch(in *artistinfoStatement.StatementBatchRequest) (res *artistinfoStatement.CreateStatementBatchResponse, err error) {
|
|
res = &artistinfoStatement.CreateStatementBatchResponse{}
|
|
data, err := dao.CreateStatementBatch(in)
|
|
res.Id = data.ID
|
|
return
|
|
}
|
|
|
|
func (s *StatementServerLogic) BatchCreateStatementBatch(in *artistinfoStatement.BatchCreateStatementBatchRequest) (*emptypb.Empty, error) {
|
|
return nil, dao.BatchCreateStatementBatch(in)
|
|
}
|
|
|
|
func (s *StatementServerLogic) GetStatementBatchList(in *artistinfoStatement.GetStatementBatchListRequest) (res *artistinfoStatement.GetStatementBatchListResponse, err error) {
|
|
datas, total, err := dao.GetStatementBatchList(in)
|
|
|
|
res = &artistinfoStatement.GetStatementBatchListResponse{
|
|
Page: &artistinfoStatement.StatementPageInfo{
|
|
Page: in.Page,
|
|
PageSize: in.PageSize,
|
|
Total: total,
|
|
},
|
|
Data: []*artistinfoStatement.StatementBatchRequest{},
|
|
}
|
|
for _, v := range datas {
|
|
res.Data = append(res.Data, &artistinfoStatement.StatementBatchRequest{
|
|
StType: v.StType,
|
|
ArtistUid: v.ArtistUid,
|
|
ArtistRealName: v.ArtistRealName,
|
|
FlowStatus: v.FlowStatus,
|
|
BatchTime: v.BatchTime,
|
|
MinPrice: v.MinPrice,
|
|
GuaranteePrice: v.GuaranteePrice,
|
|
Id: v.ID,
|
|
CreatedAt: stime.TimeToString(v.CreatedAt, stime.Format_Normal_YMDhms),
|
|
UpdatedAt: stime.TimeToString(v.UpdatedAt, stime.Format_Normal_YMDhms),
|
|
DeletedAt: int64(v.DeletedAt),
|
|
FileUrl: v.FileUrl,
|
|
})
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *StatementServerLogic) CreateStatementDetail(in *artistinfoStatement.StatementDetailRequest) (res *artistinfoStatement.CreateStatementDetailResponse, err error) {
|
|
res = &artistinfoStatement.CreateStatementDetailResponse{}
|
|
data, err := dao.CreateStatementDetail(in)
|
|
res.Id = data.ID
|
|
return
|
|
}
|
|
|
|
func (s *StatementServerLogic) BatchCreateStatementDetail(in *artistinfoStatement.BatchCreateStatementDetailRequest) (*emptypb.Empty, error) {
|
|
return nil, dao.BatchCreateStatementDetail(in)
|
|
}
|
|
|
|
func (s *StatementServerLogic) GetStatementDetailList(in *artistinfoStatement.GetStatementDetailListRequest) (res *artistinfoStatement.GetStatementDetailListResponse, err error) {
|
|
datas, total, err := dao.GetStatementDetailList(in)
|
|
res = &artistinfoStatement.GetStatementDetailListResponse{
|
|
Data: []*artistinfoStatement.StatementDetailRequest{},
|
|
Page: &artistinfoStatement.StatementPageInfo{
|
|
Page: in.Page,
|
|
PageSize: in.PageSize,
|
|
Total: total,
|
|
},
|
|
}
|
|
for _, v := range datas {
|
|
res.Data = append(res.Data, &artistinfoStatement.StatementDetailRequest{
|
|
BatchId: v.BatchId,
|
|
TfNum: v.TfNum,
|
|
ArtworkName: v.ArtworkName,
|
|
Ruler: v.Ruler,
|
|
SaleNo: v.SaleNo,
|
|
CompleteDate: v.CompleteDate,
|
|
Id: v.ID,
|
|
CreatedAt: stime.TimeToString(v.CreatedAt, stime.Format_Normal_YMDhms),
|
|
UpdatedAt: stime.TimeToString(v.UpdatedAt, stime.Format_Normal_YMDhms),
|
|
DeletedAt: int64(v.DeletedAt),
|
|
})
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *StatementServerLogic) GetStatementBatchTimeMenus(in *artistinfoStatement.GetStatementBatchListRequest) (res *artistinfoStatement.GetStatementBatchTimeMenusResponse, err error) {
|
|
res = &artistinfoStatement.GetStatementBatchTimeMenusResponse{}
|
|
res.Data, err = dao.GetStatementBatchTimeMenus(in)
|
|
return
|
|
}
|