291 lines
10 KiB
Go
291 lines
10 KiB
Go
package biz
|
||
|
||
import (
|
||
"encoding/json"
|
||
"fmt"
|
||
|
||
openapi "github.com/alibabacloud-go/darabonba-openapi/v2/client"
|
||
"github.com/alibabacloud-go/tea/v2"
|
||
|
||
"server_tb_LinkedMall/internal/config"
|
||
"server_tb_LinkedMall/internal/entities"
|
||
)
|
||
|
||
// LinkedMallBiz 业务逻辑层 - 封装对LinkedMall OpenAPI的调用
|
||
type LinkedMallBiz struct {
|
||
client *openapi.Client
|
||
cfg *config.Config
|
||
basePath string
|
||
}
|
||
|
||
// NewLinkedMallBiz 创建业务逻辑实例
|
||
func NewLinkedMallBiz(cfg *config.Config) (*LinkedMallBiz, error) {
|
||
cli, err := newLinkedMallClient(cfg.AccessKeyId, cfg.AccessKeySecret, cfg.RegionId, cfg.Endpoint)
|
||
if err != nil {
|
||
return nil, fmt.Errorf("初始化LinkedMall客户端失败: %w", err)
|
||
}
|
||
return &LinkedMallBiz{
|
||
client: cli,
|
||
cfg: cfg,
|
||
basePath: cfg.BasePath,
|
||
}, nil
|
||
}
|
||
|
||
// newLinkedMallClient 创建Darabonba OpenAPI客户端
|
||
func newLinkedMallClient(ak, sk, regionId, endpoint string) (*openapi.Client, error) {
|
||
config := &openapi.Config{
|
||
AccessKeyId: tea.String(ak),
|
||
AccessKeySecret: tea.String(sk),
|
||
RegionId: tea.String(regionId),
|
||
Endpoint: tea.String(endpoint),
|
||
ReadTimeout: tea.Int(30000),
|
||
ConnectTimeout: tea.Int(10000),
|
||
}
|
||
return openapi.NewClient(config)
|
||
}
|
||
|
||
// doRoaGet 发起ROA GET请求
|
||
func (b *LinkedMallBiz) doRoaGet(path string, query map[string]*string) (*entities.CommonResponse, error) {
|
||
resp, err := b.client.RoaRequest(
|
||
tea.String("GET"),
|
||
tea.String(b.basePath+path),
|
||
query,
|
||
nil, // body
|
||
nil, // header
|
||
)
|
||
if err != nil {
|
||
return nil, fmt.Errorf("ROA GET请求失败 [%s]: %w", path, err)
|
||
}
|
||
return b.parseResponse(resp)
|
||
}
|
||
|
||
// doRoaPost 发起ROA POST请求
|
||
func (b *LinkedMallBiz) doRoaPost(path string, body interface{}, query map[string]*string) (*entities.CommonResponse, error) {
|
||
jsonBytes, err := json.Marshal(body)
|
||
if err != nil {
|
||
return nil, fmt.Errorf("序列化请求Body失败: %w", err)
|
||
}
|
||
var bodyObj interface{}
|
||
if err := json.Unmarshal(jsonBytes, &bodyObj); err != nil {
|
||
return nil, fmt.Errorf("反序列化请求Body失败: %w", err)
|
||
}
|
||
resp, err := b.client.RoaRequest(
|
||
tea.String("POST"),
|
||
tea.String(b.basePath+path),
|
||
query,
|
||
bodyObj,
|
||
nil,
|
||
)
|
||
if err != nil {
|
||
return nil, fmt.Errorf("ROA POST请求失败 [%s]: %w", path, err)
|
||
}
|
||
return b.parseResponse(resp)
|
||
}
|
||
|
||
// parseResponse 解析公共响应
|
||
func (b *LinkedMallBiz) parseResponse(resp interface{}) (*entities.CommonResponse, error) {
|
||
respBytes, err := json.Marshal(resp)
|
||
if err != nil {
|
||
return nil, fmt.Errorf("序列化响应失败: %w", err)
|
||
}
|
||
var commonResp entities.CommonResponse
|
||
if err := json.Unmarshal(respBytes, &commonResp); err != nil {
|
||
return nil, fmt.Errorf("解析公共响应失败: %w", err)
|
||
}
|
||
return &commonResp, nil
|
||
}
|
||
|
||
// ============================================================
|
||
// 接口实现：调用阿里云LinkedMall OpenAPI
|
||
// ============================================================
|
||
|
||
// 接口 1: ListPurchaserShops
|
||
func (b *LinkedMallBiz) ListPurchaserShops(req *entities.ListPurchaserShopsReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
if req.PageNum > 0 {
|
||
query["PageNum"] = tea.String(fmt.Sprintf("%d", req.PageNum))
|
||
}
|
||
if req.PageSize > 0 {
|
||
query["PageSize"] = tea.String(fmt.Sprintf("%d", req.PageSize))
|
||
}
|
||
return b.doRoaGet("/purchaser-shops", query)
|
||
}
|
||
|
||
// 接口 2: GetPurchaserShop
|
||
func (b *LinkedMallBiz) GetPurchaserShop(req *entities.GetPurchaserShopReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaGet(fmt.Sprintf("/purchaser-shops/%s", req.ShopId), nil)
|
||
}
|
||
|
||
// 接口 3: ListSelectionProducts
|
||
func (b *LinkedMallBiz) ListSelectionProducts(req *entities.ListSelectionProductsReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
if req.PageNum > 0 {
|
||
query["PageNum"] = tea.String(fmt.Sprintf("%d", req.PageNum))
|
||
}
|
||
if req.PageSize > 0 {
|
||
query["PageSize"] = tea.String(fmt.Sprintf("%d", req.PageSize))
|
||
}
|
||
return b.doRoaGet("/selection-products", query)
|
||
}
|
||
|
||
// 接口 4: GetSelectionProduct
|
||
func (b *LinkedMallBiz) GetSelectionProduct(req *entities.GetSelectionProductReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
if req.DivisionCode != "" {
|
||
query["DivisionCode"] = tea.String(req.DivisionCode)
|
||
}
|
||
return b.doRoaGet(fmt.Sprintf("/selection-products/%s", req.ProductId), query)
|
||
}
|
||
|
||
// 接口 5: GetSelectionProductSaleInfo
|
||
func (b *LinkedMallBiz) GetSelectionProductSaleInfo(req *entities.GetSelectionProductSaleInfoReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
if req.DivisionCode != "" {
|
||
query["DivisionCode"] = tea.String(req.DivisionCode)
|
||
}
|
||
return b.doRoaGet(fmt.Sprintf("/selection-products/%s/sale-info", req.ProductId), query)
|
||
}
|
||
|
||
// 接口 6: ListSelectionProductSaleInfos
|
||
func (b *LinkedMallBiz) ListSelectionProductSaleInfos(req *entities.ListSelectionProductSaleInfosReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/selection-products:batch-sale-info", req, nil)
|
||
}
|
||
|
||
// 接口 7: ListSelectionSkuSaleInfos
|
||
func (b *LinkedMallBiz) ListSelectionSkuSaleInfos(req *entities.ListSelectionSkuSaleInfosReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/selection-skus:batch-sale-info", req, nil)
|
||
}
|
||
|
||
// 接口 8: ListCategories
|
||
func (b *LinkedMallBiz) ListCategories(req *entities.ListCategoriesReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
if req.ParentCategoryId != "" {
|
||
query["ParentCategoryId"] = tea.String(req.ParentCategoryId)
|
||
}
|
||
return b.doRoaGet("/categories", query)
|
||
}
|
||
|
||
// 接口 9: SearchProducts
|
||
func (b *LinkedMallBiz) SearchProducts(req *entities.SearchProductsReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/selection-products:search", req, nil)
|
||
}
|
||
|
||
// 接口 10: SelectionGroupAddProduct
|
||
func (b *LinkedMallBiz) SelectionGroupAddProduct(req *entities.SelectionGroupAddProductReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/selection-group/products:add", req, nil)
|
||
}
|
||
|
||
// 接口 11: SelectionGroupRemoveProduct
|
||
func (b *LinkedMallBiz) SelectionGroupRemoveProduct(req *entities.SelectionGroupRemoveProductReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/selection-group/products:remove", req, nil)
|
||
}
|
||
|
||
// 接口 12: RenderPurchaseOrder
|
||
func (b *LinkedMallBiz) RenderPurchaseOrder(req *entities.RenderPurchaseOrderReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/purchase-orders:render", req, nil)
|
||
}
|
||
|
||
// 接口 13: SplitPurchaseOrder
|
||
func (b *LinkedMallBiz) SplitPurchaseOrder(req *entities.SplitPurchaseOrderReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/purchase-orders:split-render", req, nil)
|
||
}
|
||
|
||
// 接口 14: CreatePurchaseOrder
|
||
func (b *LinkedMallBiz) CreatePurchaseOrder(req *entities.CreatePurchaseOrderReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/purchase-orders", req, nil)
|
||
}
|
||
|
||
// 接口 15: GetPurchaseOrderStatus
|
||
func (b *LinkedMallBiz) GetPurchaseOrderStatus(req *entities.GetPurchaseOrderStatusReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
return b.doRoaGet(fmt.Sprintf("/purchase-orders/%s/status", req.PurchaseOrderId), query)
|
||
}
|
||
|
||
// 接口 16: GetOrder
|
||
func (b *LinkedMallBiz) GetOrder(req *entities.GetOrderReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
return b.doRoaGet(fmt.Sprintf("/orders/%s", req.OrderId), query)
|
||
}
|
||
|
||
// 接口 17: QueryOrders
|
||
func (b *LinkedMallBiz) QueryOrders(req *entities.QueryOrdersReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
if req.PurchaseOrderId != "" {
|
||
query["PurchaseOrderId"] = tea.String(req.PurchaseOrderId)
|
||
}
|
||
if req.PageNum > 0 {
|
||
query["PageNum"] = tea.String(fmt.Sprintf("%d", req.PageNum))
|
||
}
|
||
if req.PageSize > 0 {
|
||
query["PageSize"] = tea.String(fmt.Sprintf("%d", req.PageSize))
|
||
}
|
||
if req.StartTime != "" {
|
||
query["StartTime"] = tea.String(req.StartTime)
|
||
}
|
||
if req.EndTime != "" {
|
||
query["EndTime"] = tea.String(req.EndTime)
|
||
}
|
||
return b.doRoaGet("/orders", query)
|
||
}
|
||
|
||
// 接口 18: ListLogisticsOrders
|
||
func (b *LinkedMallBiz) ListLogisticsOrders(req *entities.ListLogisticsOrdersReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
return b.doRoaGet(fmt.Sprintf("/orders/%s/logistics", req.OrderId), query)
|
||
}
|
||
|
||
// 接口 19: ConfirmDisburse
|
||
func (b *LinkedMallBiz) ConfirmDisburse(req *entities.ConfirmDisburseReq) (*entities.CommonResponse, error) {
|
||
body := map[string]string{"PurchaserId": req.PurchaserId}
|
||
return b.doRoaPost(fmt.Sprintf("/orders/%s:confirm-disburse", req.OrderId), body, nil)
|
||
}
|
||
|
||
// 接口 20: RenderRefundOrder
|
||
func (b *LinkedMallBiz) RenderRefundOrder(req *entities.RenderRefundOrderReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/refund-orders:render", req, nil)
|
||
}
|
||
|
||
// 接口 21: CreateRefundOrder
|
||
func (b *LinkedMallBiz) CreateRefundOrder(req *entities.CreateRefundOrderReq) (*entities.CommonResponse, error) {
|
||
return b.doRoaPost("/refund-orders", req, nil)
|
||
}
|
||
|
||
// 接口 22: CancelRefundOrder
|
||
func (b *LinkedMallBiz) CancelRefundOrder(req *entities.CancelRefundOrderReq) (*entities.CommonResponse, error) {
|
||
body := map[string]string{"PurchaserId": req.PurchaserId}
|
||
return b.doRoaPost(fmt.Sprintf("/refund-orders/%s:cancel", req.RefundOrderId), body, nil)
|
||
}
|
||
|
||
// 接口 23: GetRefundOrder
|
||
func (b *LinkedMallBiz) GetRefundOrder(req *entities.GetRefundOrderReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
query["PurchaserId"] = tea.String(req.PurchaserId)
|
||
return b.doRoaGet(fmt.Sprintf("/refund-orders/%s", req.RefundOrderId), query)
|
||
}
|
||
|
||
// 接口 24: CreateGoodsShippingNotice
|
||
func (b *LinkedMallBiz) CreateGoodsShippingNotice(req *entities.CreateGoodsShippingNoticeReq) (*entities.CommonResponse, error) {
|
||
body := map[string]string{
|
||
"PurchaserId": req.PurchaserId,
|
||
"LogisticsCompany": req.LogisticsCompany,
|
||
"TrackingNumber": req.TrackingNumber,
|
||
}
|
||
return b.doRoaPost(fmt.Sprintf("/refund-orders/%s:fill-logistics", req.RefundOrderId), body, nil)
|
||
}
|
||
|
||
// 接口 25: QueryChildDivisionCode
|
||
func (b *LinkedMallBiz) QueryChildDivisionCode(req *entities.QueryChildDivisionCodeReq) (*entities.CommonResponse, error) {
|
||
query := make(map[string]*string)
|
||
if req.ParentDivisionCode != "" {
|
||
query["ParentDivisionCode"] = tea.String(req.ParentDivisionCode)
|
||
}
|
||
return b.doRoaGet("/divisions:children", query)
|
||
} |