package taobao import ( "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/md" zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" "encoding/json" "errors" "fmt" "github.com/syyongx/php2go" "strings" "time" "xorm.io/xorm" ) //TaoBaoArgs is args type TaoBaoArgs struct { Keyword string PageIndex string PageSize string Sort string StartPrice string EndPrice string IsTmall string IsCoupon string StartCommissionRate string EndCommissionRate string } func TaoBaoFeaturedList(eg *xorm.Engine, dbName, Platform string, AccTaobaoShareId int, postData map[string]string) []map[string]string { var goods = make([]map[string]string, 0) sdk, err := NewTaobaoSDK(eg, dbName, Platform, AccTaobaoShareId, "") if err != nil { return goods } list, err := sdk.TaoBaoFeaturedList(postData) if list != nil { for _, v := range *list { var tmp = map[string]string{ "gid": zhios_third_party_utils.AnyToString(v.ItemID), "title": v.Title, "img": v.PictURL, "sales": zhios_third_party_utils.IntToStr(v.Volume), "price": zhios_third_party_utils.Float64ToStr(zhios_third_party_utils.StrToFloat64(v.ZkFinalPrice) - float64(v.CouponAmount)), "cost_price": v.ZkFinalPrice, "coupon": zhios_third_party_utils.IntToStr(v.CouponAmount), "commission_rate": zhios_third_party_utils.AnyToString(zhios_third_party_utils.StrToFloat64(v.CommissionRate) / 100), "commission": zhios_third_party_utils.Float64ToStr((zhios_third_party_utils.StrToFloat64(v.ZkFinalPrice) - float64(v.CouponAmount)) * (zhios_third_party_utils.StrToFloat64(v.CommissionRate) / 100 / 100)), "pvd": md.PVD_TB, "share_content": "", } goods = append(goods, tmp) } } return goods } func TaoBaoSearchList(eg *xorm.Engine, dbName, Platform string, AccTaobaoShareId int, postData map[string]string) []map[string]string { var goods = make([]map[string]string, 0) sdk, err := NewTaobaoSDK(eg, dbName, Platform, AccTaobaoShareId, "") if err != nil { return goods } list, err := sdk.TaoBaoSearchList(postData) if list != nil { for _, v := range *list { imgList := make([]string, 0) if len(v.SmallImages.String) == 0 { imgList = append(imgList, v.PictURL) } else { for _, v1 := range v.SmallImages.String { imgList = append(imgList, v1) } } var tmp = map[string]string{ "img_list": zhios_third_party_utils.SerializeStr(imgList), "gid": zhios_third_party_utils.AnyToString(v.ItemID), "title": v.Title, "img": v.PictURL, "sales": zhios_third_party_utils.IntToStr(v.Volume), "price": zhios_third_party_utils.Float64ToStr(zhios_third_party_utils.StrToFloat64(v.ZkFinalPrice) - zhios_third_party_utils.StrToFloat64(v.CouponAmount)), "cost_price": v.ZkFinalPrice, "coupon": v.CouponAmount, "commission_rate": zhios_third_party_utils.AnyToString(zhios_third_party_utils.StrToFloat64(v.CommissionRate) / 100), "commission": zhios_third_party_utils.Float64ToStr((zhios_third_party_utils.StrToFloat64(v.ZkFinalPrice) - zhios_third_party_utils.StrToFloat64(v.CouponAmount)) * (zhios_third_party_utils.StrToFloat64(v.CommissionRate) / 100 / 100)), "pvd": md.PVD_TB, "share_content": "", } goods = append(goods, tmp) } } return goods } // TaoBaoSearchList is return taobao search list func (t *TB) TaoBaoFeaturedList(args map[string]string) (*[]md.TBFeatureStruct, error) { list, err := t.FeaturedList( args, ) if err != nil { return nil, err } return list, nil } func (t *TB) TaoBaoSearchList(args map[string]string) (*[]Material, error) { list, err := t.SearchList( args, ) if err != nil { return nil, err } return list, nil } // 商品详情 func (t *TB) ItemDetailById(id, bizSceneId string) (*Material, error) { if php2go.IsNumeric(id) { return t.ItemDetailByLink("https://item.taobao.com/item.htm?id="+id, "2") } return t.ItemDetailByLink("https://uland.taobao.com/item/edetail?id="+id, "") } func (t *TB) ItemDetailByLink(l, bizSceneId string) (*Material, error) { args := map[string]string{ "q": l, "adzone_id": AdZoneId(t.SelfPromoIdWeb), // 默认使用安卓, 转链时候才要针对不同的渠道 "session": t.SID, "page_size": "1", "page_no": "1", } if bizSceneId == "2" { args["biz_scene_id"] = "2" } method := TBK_DG_MTL_OPT //判断是否跟随官方 需要换接口 if t.AuthType == 1 { method = TBK_SC_MTL_OPT Sid := t.UserSID args["session"] = Sid _, args["site_id"], args["adzone_id"] = SplitPid(t.SelfPromoIdWeb) } resp, err := send(args, method, t.Web_AK, t.Web_SK) if err != nil { return nil, err } fmt.Println("淘宝", args) fmt.Println("淘宝", string(resp)) // todo 可能还需返回的说明, 里面包含详细介绍的图片 // "https://mdetail.tmall.com/templates/pages/desc?id=" + id // "https://h5.m.taobao.com/app/detail/desc.html?type=1&f=&sellerType=B&_isH5Des=true#!id=" + id // 如果是跟随官方 结构不一样 if t.AuthType == 1 { var tmp scTbkScMaterialOptionalUpgradeResponse if err = json.Unmarshal(resp, &tmp); err != nil { return nil, err } if len(tmp.TbkScMaterialOptionalUpgradeResponse.ResultList.MapData) == 0 { return nil, err } data := tmp.TbkScMaterialOptionalUpgradeResponse.ResultList.MapData[0] tmp1 := Material{ CategoryID: data.ItemBasicInfo.CategoryId, CategoryName: data.ItemBasicInfo.CategoryName, CommissionRate: zhios_third_party_utils.Float64ToStr(zhios_third_party_utils.StrToFloat64(data.PublishInfo.IncomeRate) * 100), ItemID: data.ItemId, Nick: data.ItemBasicInfo.ShopTitle, PictURL: data.ItemBasicInfo.PictUrl, SellerID: int(data.ItemBasicInfo.SellerId), ShopTitle: data.ItemBasicInfo.ShopTitle, ShortTitle: data.ItemBasicInfo.ShortTitle, Title: data.ItemBasicInfo.Title, ZkFinalPrice: data.PricePromotionInfo.ZkFinalPrice, ReservePrice: data.PricePromotionInfo.ReservePrice, Volume: data.ItemBasicInfo.Volume, UserType: data.ItemBasicInfo.UserType, TkTotalSales: zhios_third_party_utils.IntToStr(data.ItemBasicInfo.Volume), } tmp1.SmallImages = data.ItemBasicInfo.SmallImages if len(data.ItemBasicInfo.SmallImages.String) == 0 { tmp1.SmallImages.String = []string{tmp1.PictURL} } if zhios_third_party_utils.StrToFloat64(data.PricePromotionInfo.FinalPromotionPrice) > 0 { for _, v1 := range data.PricePromotionInfo.FinalPromotionPathList.FinalPromotionPathMapData { tmp1.CouponAmount = zhios_third_party_utils.Float64ToStrByPrec(zhios_third_party_utils.StrToFloat64(v1.PromotionFee)+zhios_third_party_utils.StrToFloat64(tmp1.CouponAmount), 2) tmp1.CouponStartTime = zhios_third_party_utils.IntToStr(zhios_third_party_utils.StrToInt(v1.PromotionStartTime) / 1000) tmp1.CouponEndTime = zhios_third_party_utils.IntToStr(zhios_third_party_utils.StrToInt(v1.PromotionEndTime) / 1000) tmp1.CouponID = v1.PromotionId if v1.PromotionTitle == "商品券" || v1.PromotionTitle == "店铺券" { if zhios_third_party_utils.StrToInt64(v1.PromotionEndTime)/1000 > time.Now().Unix() { tmp1.GoodsCoupon = "1" } } } } return &tmp1, nil } else { var tmp wrapperStruct if err = json.Unmarshal(resp, &tmp); err != nil { return nil, err } if len(tmp.TbkDgMaterialOptionalResponse.ResultList.MapData) == 0 { return nil, err } data := tmp.TbkDgMaterialOptionalResponse.ResultList.MapData[0] itemID, ok := data.ItemID.(float64) if ok { data.ItemID = int64(itemID) } return &data, nil } } func (t *TB) ItemDetailByIdKey(l, bizSceneId string) (*Material, error) { l += "&" l = strings.ReplaceAll(l, "?", "&") ex := php2go.Explode("&id=", l) id := "" if len(ex) > 1 { ex1 := php2go.Explode("&", ex[1]) if len(ex1) > 0 { id = ex1[0] } } if id == "" || id == "622130940777" { return nil, errors.New("找不到商品") } args := map[string]string{ "num_iids": id, "session": t.SID, "platform": "2", } if bizSceneId == "2" { //args["biz_scene_id"] = "2" } method := "taobao.tbk.item.info.get" //判断是否跟随官方 需要换接口 if t.AuthType == 1 { Sid := t.UserSID args["session"] = Sid } resp, err := send(args, method, t.Web_AK, t.Web_SK) if err != nil { return nil, err } var tmp tbDetailStruct if err = json.Unmarshal(resp, &tmp); err != nil { return nil, err } if len(tmp.TbkItemInfoGetResponse.Results.NBbkItem) == 0 { return nil, err } data := tmp.TbkItemInfoGetResponse.Results.NBbkItem[0] data.ItemID = data.InputNumIid itemID, ok := data.ItemID.(float64) if ok { data.ItemID = int64(itemID) } return &data, nil }