唯品会

upstream/upstream.go

@@ -5,13 +5,14 @@ import (
 )
 
 const (
-	Jd    = 2
-	Ali   = 6
-	Tm    = 7
-	Cloud = 1
-	Sn    = 8
-	Gome  = 10
+	Cloud = 1  //云仓
+	Jd    = 2  //京东
+	Ali   = 6  //阿里
+	Tm    = 7  //天猫
+	Sn    = 8  //苏宁
+	Gome  = 10 //国美
 	Schl  = 11 //盛创汇联
+	Wpc   = 12 //唯品会
 )
 
 var (
@@ -60,6 +61,10 @@ func GetUpstreamList() (res interface{}, err error) {
 			"key":  Schl,
 			"name": GetUpstreamName(Schl),
 		},
+		g.Map{
+			"key":  Wpc,
+			"name": GetUpstreamName(Wpc),
+		},
 	}
 	return
 }
@@ -80,6 +85,8 @@ func GetUpstreamName(source int) string {
 		return "国美"
 	case Schl:
 		return "盛创汇联"
+	case Wpc:
+		return "特卖专场"
 	default:
 		return "未知来源"
 	}

upstream/wpc/wpc.go

+package wpc
+
+import (
+	"context"
+	"crypto/hmac"
+	"crypto/md5"
+	"encoding/hex"
+	"github.com/gogf/gf/container/garray"
+	"github.com/gogf/gf/encoding/gjson"
+	"github.com/gogf/gf/frame/g"
+	"github.com/gogf/gf/os/gtime"
+	"github.com/gogf/gf/text/gstr"
+	"github.com/gogf/gf/util/gconv"
+	"net/url"
+	"time"
+)
+
+type Config struct {
+	ApiUrl      string
+	AppKey      string
+	UserNumber  string
+	AppSecret   string
+	AccessToken string
+}
+
+type QueryParam struct {
+	AccessToken string `json:"accessToken"`
+	AppKey      string `json:"appKey"`
+	Format      string `json:"format"`
+	Method      string `json:"method"`
+	Service     string `json:"service"`
+	Timestamp   int64  `json:"timestamp"`
+	Version     string `json:"version"`
+}
+
+var server *Config
+
+const service = "com.vip.wpc.ospservice.vop.WpcVopOspService"
+const version = "1.0.0"
+const format = "json"
+
+const pkgName = "wpc"
+
+func New(config *Config) {
+	server = config
+	return
+}
+
+func getQueryParam(method string) (res *QueryParam) {
+	return &QueryParam{
+		Service:     service,
+		Method:      method,
+		Version:     version,
+		Timestamp:   gtime.Timestamp(),
+		Format:      format,
+		AppKey:      server.AppKey,
+		AccessToken: server.AccessToken,
+	}
+}
+
+func sign(param *QueryParam, req string) string {
+	Map := gjson.New(param).Map()
+
+	var keys = garray.NewStrArray()
+	for k := range Map {
+		keys.Append(k)
+	}
+	keys.Sort()
+	var signStr string
+	u := url.Values{}
+	for _, v := range keys.Slice() {
+		if val := gconv.String(Map[v]); val != "" {
+			signStr += v
+			signStr += val
+			u.Set(v, val)
+		}
+	}
+	signStr += req
+	g.Dump(signStr)
+	h := hmac.New(md5.New, []byte(server.AppSecret))
+	h.Write([]byte(signStr))
+	u.Set("sign", gstr.ToUpper(hex.EncodeToString(h.Sum([]byte("")))))
+	return u.Encode()
+}
+
+func post(ctx context.Context, method string, req interface{}) (res string, err error) {
+	Start := gtime.TimestampMilli()
+	var Query = getQueryParam(method)
+	paramStr := gjson.New(req).MustToJsonString()
+	Url := server.ApiUrl + "?" + sign(Query, paramStr)
+	Request := g.Client()
+	Request.SetHeader("Content-Type", "application/json")
+	resp, err := Request.Timeout(time.Second*5).Post(Url, gjson.New(req).MustToJsonString())
+	defer func() {
+		_ = resp.Close()
+		ctx = context.WithValue(ctx, "Method", "POST")
+		ctx = context.WithValue(ctx, "URI", method)
+		if err != nil {
+			g.Log().Ctx(ctx).Infof("参数【%v】错误【%v】响应时间【%v】", paramStr, err.Error(), gtime.TimestampMilli()-Start)
+		} else {
+			g.Log().Ctx(ctx).Cat(pkgName).Infof("参数【%v】响应【%v】响应时间【%v】", paramStr, res, gtime.TimestampMilli()-Start)
+		}
+	}()
+	res = resp.ReadAllString()
+	return
+}

upstream/wpc/wpc_address.go

+package wpc
+
+import (
+	"context"
+)
+
+type addressWpc struct {
+}
+
+var Address = addressWpc{}
+
+type ParseRes struct {
+	NationId   string `json:"nationId"`   //国家ID
+	Nation     string `json:"nation"`     //国家名称
+	ProvinceId int    `json:"provinceId"` //一级地址ID
+	Province   string `json:"province"`   //一级地址名称
+	CityId     int    `json:"cityId"`     //二级地址ID
+	City       string `json:"city"`       //二级地址名称
+	CountyId   int    `json:"countyId"`   //三级地址ID
+	County     string `json:"county"`     //三级地址名称
+	TownId     int    `json:"townId"`     //四级地址ID
+	Town       string `json:"town"`       //四级地址名称
+}
+
+//Parse  地址详情转换京东地址编码
+func (*addressWpc) Parse(ctx context.Context, address string) (res *ParseRes, err error) {
+	return
+}

upstream/wpc/wpc_brand.go

+package wpc
+
+import (
+	"context"
+	"github.com/gogf/gf/encoding/gjson"
+	"github.com/gogf/gf/frame/g"
+)
+
+type brandWpc struct {
+}
+
+var Brand = brandWpc{}
+
+type BrandListReq struct {
+	ChannelId  string `json:"vopChannelId"`
+	UserNumber string `json:"userNumber"`
+	Page       string `json:"page"`
+	PageSize   string `json:"pageSize"`
+	AreaId     string `json:"areaId,omitempty"`
+	AdIds      string `json:"adIds,omitempty"`
+}
+
+type BrandListRes struct {
+}
+
+//List 列表
+func (brandWpc) List(ctx context.Context, req BrandListReq) (res *BrandListRes, err error) {
+	method := "getBrandList"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}
+
+type BrandPreListReq struct {
+	ChannelId  string `json:"vopChannelId"`
+	UserNumber string `json:"userNumber"`
+	Page       string `json:"page"`
+	PageSize   string `json:"pageSize"`
+	AreaId     string `json:"areaId,omitempty"`
+	AdIds      string `json:"adIds,omitempty"`
+}
+
+type BrandPreListRes struct {
+	ReturnCode string `json:"returnCode"`
+	Result     struct {
+		PageTotal int `json:"pageTotal"`
+		PageIndex int `json:"pageIndex"`
+		TotalNum  int `json:"totalNum"`
+		PageSize  int `json:"pageSize"`
+		BrandList []struct {
+			AdId            string
+			BrandName       string
+			BrandImage      string
+			SellTimeFrom    string
+			SellTimeTo      string
+			BrandDesc       string
+			CommissionRatio string
+			PreTime         string
+			Ext1            string
+			Ext2            g.MapStrStr
+			Notice          string
+			Goods           []struct {
+				GoodId          string
+				GoodImage       string
+				BrandCnName     string
+				BrandEnName     string
+				Logo            string
+				Sn              string
+				Color           string
+				Material        string
+				CatNameOne      string
+				CatNameTwo      string
+				CatNameThree    string
+				GoodFullId      string
+				GoodOnline      int
+				VendorProductId int64
+				IsMp            bool
+				CatIdOne        string
+				CatIdTwo        string
+				CatIdThree      string
+				VendorSn        string
+				GoodsBrandId    string
+				SizeTableJson   []string
+				DcImageURLs     []string
+				Sizes           []struct {
+					SizeName        string
+					VipshopPrice    string
+					MarketPrice     string
+					Stock           bool
+					SizeId          int64
+					BuyMinNum       string
+					BuyMaxNum       string
+					Commission      string
+					SuggestAddPrice string
+					SuggestPrice    string
+					SkuId           int64
+					LimitBuyFlag    bool
+				}
+			}
+			StoreQualificationImgList []struct {
+				QualificationType string
+				ImgUrl            string
+				LicenseNumber     string
+			}
+			AdCategoryList []struct {
+				CateId   int64
+				CateName string
+			}
+			CouponList []struct {
+				CouponName        string
+				CouponDesc        string
+				ActivateBeginTime string
+				ActivateEndTime   string
+				SurplusSecond     int64
+				UseSurplusSecond  int64
+				Fav               string
+				CouponNo          string
+				UseBeginTime      string
+				UseEndTime        string
+				ShareFav          string
+				Buy               string
+				Status            int
+				ShareType         int
+				Type              int
+			}
+		} `json:"brandList"`
+	} `json:"result"`
+}
+
+//PreList 预告品牌列表
+func (brandWpc) PreList(ctx context.Context, req BrandPreListReq) (res *BrandPreListRes, err error) {
+	method := "getPreBrandList"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}

upstream/wpc/wpc_deliver.go

+package wpc
+
+import (
+	"context"
+	"github.com/gogf/gf/encoding/gjson"
+	"github.com/gogf/gf/frame/g"
+)
+
+type deliverWpc struct {
+}
+
+var Deliver = deliverWpc{}
+
+type DeliverListReq struct {
+	ChannelId  string `json:"vopChannelId"`
+	UserNumber string `json:"userNumber"`
+}
+
+type DeliverListRes struct {
+	ReturnCode string `json:"returnCode"`
+	Result     []struct {
+		CustNo   string `json:"custNo"`
+		CustName string `json:"custName"`
+		CustCode string `json:"custCode"`
+	} `json:"result"`
+}
+
+//List 列表
+func (deliverWpc) List(ctx context.Context) (res *DeliverListRes, err error) {
+	method := "getCarrierList"
+	req := DeliverListReq{}
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}

upstream/wpc/wpc_goods.go

+package wpc
+
+import (
+	"context"
+	"github.com/gogf/gf/encoding/gjson"
+	"github.com/gogf/gf/frame/g"
+)
+
+type goodsWpc struct {
+}
+
+var Goods = goodsWpc{}
+
+type GoodsListReq struct {
+	ChannelId  string `json:"vopChannelId"`
+	UserNumber string `json:"userNumber"`
+	Page       string `json:"page"`
+	PageSize   string `json:"pageSize"`
+	AreaId     string `json:"areaId,omitempty"`
+	AdId       string `json:"adId"`
+	GoodsIds   string `json:"goodsIds,omitempty"`
+}
+
+type GoodsListRes struct {
+	ReturnCode    string `json:"returnCode"`
+	ReturnMessage string `json:"returnMessage"`
+}
+
+//List 列表
+func (goodsWpc) List(ctx context.Context, req GoodsListReq) (res *GoodsListRes, err error) {
+	method := "getGoodsList"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}
+
+type GoodsStockReq struct {
+	ChannelId   string `json:"vopChannelId"`
+	UserNumber  string `json:"userNumber"`
+	GoodFullIds string `json:"goodFullIds,omitempty"`
+	AreaId      string `json:"areaId,omitempty"`
+}
+
+type GoodsStockRes struct {
+	ReturnCode    string `json:"returnCode"`
+	ReturnMessage string `json:"returnMessage"`
+	Result        struct {
+		GoodsStockList struct {
+			GoodFullId string `json:"goodFullId"`
+			sizes      []struct {
+				SizeId      string `json:"sizeId"`
+				SizeName    string `json:"sizeName"`
+				Stock       int    `json:"stock"`
+				Type        int    `json:"type"`
+				StockStatus int    `json:"stockStatus"`
+			}
+		}
+	} `json:"result"`
+}
+
+//Stock 库存
+func (goodsWpc) Stock(ctx context.Context, req GoodsStockReq) (res *GoodsStockRes, err error) {
+	method := "getGoodsStock"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}
+
+type GoodsDetailReq struct {
+	ChannelId   string `json:"vopChannelId"`
+	UserNumber  string `json:"userNumber"`
+	AreaId      string `json:"areaId,omitempty"`
+	GoodFullIds string `json:"goodFullIds"`
+}
+
+type GoodsDetailRes struct {
+	ReturnCode    string `json:"returnCode"`
+	ReturnMessage string `json:"returnMessage"`
+	Result        struct {
+	} `json:"result"`
+}
+
+//Detail 详情
+func (goodsWpc) Detail(ctx context.Context, req GoodsDetailReq) (res *GoodsDetailRes, err error) {
+	method := "getGoodsDetail"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}
+
+type GoodsStatusReq struct {
+	ChannelId   string `json:"vopChannelId"`
+	UserNumber  string `json:"userNumber"`
+	AreaId      string `json:"areaId,omitempty"`
+	GoodFullIds string `json:"goodFullIds"`
+}
+
+type GoodsStatusRes struct {
+	ReturnCode    string      `json:"returnCode"`
+	ReturnMessage string      `json:"returnMessage"`
+	Result        interface{} `json:"result"`
+}
+
+//Status 批量查询商品状态
+func (goodsWpc) Status(ctx context.Context, req GoodsStatusReq) (res *GoodsStatusRes, err error) {
+	method := "getGoodsStatus"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}
+
+type GoodsSizeStatusReq struct {
+	ChannelId  string `json:"vopChannelId"`
+	UserNumber string `json:"userNumber"`
+	AreaId     string `json:"areaId,omitempty"`
+	SizeIds    string `json:"sizeIds"`
+}
+
+type GoodsSizeStatusRes struct {
+	ReturnCode    string      `json:"returnCode"`
+	ReturnMessage string      `json:"returnMessage"`
+	Result        interface{} `json:"result"`
+}
+
+//SizeStatus 批量查询尺码状态
+func (goodsWpc) SizeStatus(ctx context.Context, req GoodsSizeStatusReq) (res *GoodsSizeStatusRes, err error) {
+	method := "getSizeStatus"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}
+
+type GoodsOnlineReq struct {
+	ChannelId   string `json:"vopChannelId"`
+	UserNumber  string `json:"userNumber"`
+	AreaId      string `json:"areaId,omitempty"`
+	GoodFullIds string `json:"goodFullIds"`
+}
+
+type GoodsOnlineRes struct {
+	ReturnCode    string      `json:"returnCode"`
+	ReturnMessage string      `json:"returnMessage"`
+	Result        interface{} `json:"result"`
+}
+
+//Online 批量查询商品上下架
+func (goodsWpc) Online(ctx context.Context, req GoodsOnlineReq) (res *GoodsOnlineRes, err error) {
+	method := "getGoodsOnline"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}

upstream/wpc/wpc_order.go

+package wpc
+
+import (
+	"context"
+	"github.com/gogf/gf/encoding/gjson"
+	"github.com/gogf/gf/frame/g"
+)
+
+type orderWpc struct {
+}
+
+var Order = orderWpc{}
+
+type OrderListReq struct {
+	ChannelId  string `json:"vopChannelId"`
+	UserNumber string `json:"userNumber"`
+	Page       string `json:"page"`
+	PageSize   string `json:"pageSize"`
+}
+type OrderListRes struct {
+}
+
+func (orderWpc) List(ctx context.Context, req OrderListReq) (res *OrderListRes, err error) {
+	method := "getSimpleOrderListV2"
+	req.ChannelId = server.AppKey
+	req.UserNumber = server.UserNumber
+	result, err := post(ctx, method, g.Map{
+		"request": req,
+	})
+	_ = gjson.New(result).Scan(&res)
+	return
+}

upstream/wpc/wpc_refund.go

+package wpc
+
+type refundWpc struct {
+}
+
+var Refund = refundWpc{}

upstream/wpc/wpc_token.go

+package wpc
+
+type tokenWpc struct {
+}
+
+var Token = tokenWpc{}