go_rely_warehouse
/
zyos_go_third_party_api
4
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 30 Wiki Activity
第三方api接口
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
242 Commits
1 Branch
14 MiB
 
Tree: 4b811ded37
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '4b811ded37'
${ noResults }
zyos_go_third_party_api/taobao/convert_url.go

346 lines
11 KiB
Raw Blame History 

  1. package taobao

  2. 

  3. import (

  4. 	"code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/md"

  5. 	"encoding/json"

  6. 	"github.com/syyongx/php2go"

  7. 	"strconv"

  8. 	"strings"

  9. )

  10. 

  11. type UrlInfo struct {

  12. 	CategoryID        int    `json:"category_id"`

  13. 	CouponClickURL    string `json:"coupon_click_url"`

  14. 	CouponEndTime     string `json:"coupon_end_time"`

  15. 	CouponInfo        string `json:"coupon_info"`

  16. 	CouponRemainCount int    `json:"coupon_remain_count"`

  17. 	CouponStartTime   string `json:"coupon_start_time"`

  18. 	CouponTotalCount  int    `json:"coupon_total_count"`

  19. 	ItemID            string `json:"item_id"`

  20. 	ItemURL           string `json:"item_url"`

  21. 	MaxCommissionRate string `json:"max_commission_rate"`

  22. 	MinCommissionRate string `json:"min_commission_rate"`

  23. 	RewardInfo        int    `json:"reward_info"`

  24. }

  25. 

  26. // 淘宝转链

  27. func (t *TB) ConvertUrlSC(itemId, pid, externalId string) (*md.ConvertedUrls, error) {

  28. 	method := "taobao.tbk.privilege.get"

  29. 	_, siteId, adZoneId := SplitPid(pid)

  30. 	args := map[string]string{

  31. 		"item_id":   itemId,

  32. 		"session":   t.UserSID, // 一般用站长就可以转链

  33. 		"adzone_id": adZoneId,

  34. 		"platform":  "2",

  35. 		"site_id":   siteId,

  36. 	}

  37. 

  38. 	if php2go.IsNumeric(itemId) {

  39. 		args["biz_scene_id"] = "2"

  40. 	}

  41. 	if externalId != "" {

  42. 		args["external_id"] = externalId

  43. 	}

  44. 	resp, err := send(args, method, t.Svc_AK, t.Svc_SK)

  45. 	if err != nil {

  46. 		return nil, err

  47. 	}

  48. 	var tmp struct {

  49. 		TbkPrivilegeGetResponse struct {

  50. 			Result struct {

  51. 				Data UrlInfo `json:"data"`

  52. 			} `json:"result"`

  53. 			RequestID string `json:"request_id"`

  54. 		} `json:"tbk_privilege_get_response"`

  55. 	}

  56. 	if err = json.Unmarshal(resp, &tmp); err != nil {

  57. 		return nil, err

  58. 	}

  59. 	url := tmp.TbkPrivilegeGetResponse.Result.Data.ItemURL

  60. 	hasCoupon := false

  61. 	itemUrl := tmp.TbkPrivilegeGetResponse.Result.Data.ItemURL

  62. 	maxCommissionRate := tmp.TbkPrivilegeGetResponse.Result.Data.MaxCommissionRate

  63. 	if tmp.TbkPrivilegeGetResponse.Result.Data.CouponClickURL != "" {

  64. 		hasCoupon = true

  65. 		url = tmp.TbkPrivilegeGetResponse.Result.Data.CouponClickURL

  66. 	}

  67. 	return &md.ConvertedUrls{

  68. 		ItemId:         itemId,

  69. 		URL:            url,

  70. 		ItemUrl:        itemUrl,

  71. 		ShortenURL:     url,

  72. 		NoOpenAppURL:   url,

  73. 		AppURL:         url,

  74. 		HasCoupon:      hasCoupon,

  75. 		CommissionRate: maxCommissionRate,

  76. 	}, nil

  77. }

  78. 

  79. func (t *TB) WnConvertUrlSC(itemId, types, pid, externalId string) (*md.ConvertedUrls, error) {

  80. 	method := "taobao.tbk.sc.general.link.convert"

  81. 	_, siteId, adZoneId := SplitPid(pid)

  82. 	args := map[string]string{

  83. 		"session":   t.UserSID, // 一般用站长就可以转链

  84. 		"adzone_id": adZoneId,

  85. 		"platform":  "2",

  86. 		"site_id":   siteId,

  87. 	}

  88. 	if types == "1" || types == "4" { //	商品ID列表

  89. 		args["item_id_list"] = itemId

  90. 		args["biz_scene_id"] = "1"

  91. 		if externalId != "0" && externalId != "" {

  92. 			args["relation_id"] = externalId

  93. 		}

  94. 	}

  95. 	if types == "2" { //物料列表，可以为url或淘口令

  96. 		args["material_list"] = itemId

  97. 		if externalId != "0" && externalId != "" {

  98. 			args["relation_id"] = externalId

  99. 		}

  100. 	}

  101. 

  102. 	if types == "3" { //	会场ID列表

  103. 		args["page_id_list"] = itemId

  104. 		if externalId != "" {

  105. 			args["relation_id"] = externalId

  106. 		}

  107. 	}

  108. 

  109. 	resp, err := send(args, method, t.Svc_AK, t.Svc_SK)

  110. 	if err != nil {

  111. 		return nil, err

  112. 	}

  113. 	var tmp struct {

  114. 		TbkScGeneralLinkConvertResponse struct {

  115. 			Data struct {

  116. 				MaterialUrlList struct {

  117. 					MaterialUrlList []struct {

  118. 						Msg              string `json:"msg"`

  119. 						Code             int    `json:"code"`

  120. 						PromotionInfoDto struct {

  121. 							CommissionRate string `json:"commission_rate"`

  122. 						} `json:"promotion_info_dto"`

  123. 						CouponInfoDto struct {

  124. 							CouponEndTime     string `json:"coupon_end_time"`

  125. 							ActivityId        string `json:"activity_id"`

  126. 							CouponRemainCount int    `json:"coupon_remain_count"`

  127. 							CouponAmount      string `json:"coupon_amount"`

  128. 							CouponStartTime   string `json:"coupon_start_time"`

  129. 							CouponDesc        string `json:"coupon_desc"`

  130. 							CouponType        int    `json:"coupon_type"`

  131. 						} `json:"coupon_info_dto"`

  132. 						LinkInfoDto struct {

  133. 							CouponLongUrl   string `json:"coupon_long_url"`

  134. 							MaterialType    int    `json:"material_type"`

  135. 							TpwdOriginUrl   string `json:"tpwd_origin_url"`

  136. 							MaterialId      string `json:"material_id"`

  137. 							CpsLongUrl      string `json:"cps_long_url"`

  138. 							CpsShortTpwd    string `json:"cps_short_tpwd"`

  139. 							TkBizType       int    `json:"tk_biz_type"`

  140. 							CouponShortTpwd string `json:"coupon_short_tpwd"`

  141. 							CpsShortUrl     string `json:"cps_short_url"`

  142. 							CouponShortUrl  string `json:"coupon_short_url"`

  143. 							CouponFullTpwd  string `json:"coupon_full_tpwd"`

  144. 							CpsFullTpwd     string `json:"cps_full_tpwd"`

  145. 						} `json:"link_info_dto"`

  146. 					} `json:"material_url_list"`

  147. 				} `json:"material_url_list"`

  148. 				ShopUrlList struct {

  149. 					ShopUrlList []struct {

  150. 						Msg         string `json:"msg"`

  151. 						Code        int    `json:"code"`

  152. 						LinkInfoDto struct {

  153. 							MaterialType int    `json:"material_type"`

  154. 							SellerId     string `json:"seller_id"`

  155. 							CpsLongUrl   string `json:"cps_long_url"`

  156. 							CpsShortTpwd string `json:"cps_short_tpwd"`

  157. 							CpsShortUrl  string `json:"cps_short_url"`

  158. 							CpsFullTpwd  string `json:"cps_full_tpwd"`

  159. 						} `json:"link_info_dto"`

  160. 					} `json:"shop_url_list"`

  161. 				} `json:"shop_url_list"`

  162. 				EventUrlList struct {

  163. 					EventUrlList []struct {

  164. 						Msg         string `json:"msg"`

  165. 						Code        int    `json:"code"`

  166. 						LinkInfoDto struct {

  167. 							MaterialType int    `json:"material_type"`

  168. 							PageId       string `json:"page_id"`

  169. 							CpsLongUrl   string `json:"cps_long_url"`

  170. 							CpsShortTpwd string `json:"cps_short_tpwd"`

  171. 							CpsShortUrl  string `json:"cps_short_url"`

  172. 							CpsFullTpwd  string `json:"cps_full_tpwd"`

  173. 						} `json:"link_info_dto"`

  174. 					} `json:"event_url_list"`

  175. 				} `json:"event_url_list"`

  176. 				ItemUrlList struct {

  177. 					ItemUrlList []struct {

  178. 						Msg              string `json:"msg"`

  179. 						Code             int    `json:"code"`

  180. 						PromotionInfoDto struct {

  181. 							CommissionRate string `json:"commission_rate"`

  182. 						} `json:"promotion_info_dto"`

  183. 						CouponInfoDto struct {

  184. 							CouponEndTime     string `json:"coupon_end_time"`

  185. 							ActivityId        string `json:"activity_id"`

  186. 							CouponRemainCount int    `json:"coupon_remain_count"`

  187. 							CouponAmount      string `json:"coupon_amount"`

  188. 							CouponStartTime   string `json:"coupon_start_time"`

  189. 							CouponDesc        string `json:"coupon_desc"`

  190. 						} `json:"coupon_info_dto"`

  191. 						LinkInfoDto struct {

  192. 							CouponLongUrl   string `json:"coupon_long_url"`

  193. 							MaterialType    int    `json:"material_type"`

  194. 							ItemId          string `json:"item_id"`

  195. 							CpsLongUrl      string `json:"cps_long_url"`

  196. 							CpsShortTpwd    string `json:"cps_short_tpwd"`

  197. 							CouponShortTpwd string `json:"coupon_short_tpwd"`

  198. 							CpsShortUrl     string `json:"cps_short_url"`

  199. 							CouponShortUrl  string `json:"coupon_short_url"`

  200. 							CouponFullTpwd  string `json:"coupon_full_tpwd"`

  201. 							CpsFullTpwd     string `json:"cps_full_tpwd"`

  202. 						} `json:"link_info_dto"`

  203. 					} `json:"item_url_list"`

  204. 				} `json:"item_url_list"`

  205. 			} `json:"data"`

  206. 			BizErrorDesc int    `json:"biz_error_desc"`

  207. 			ResultMsg    string `json:"result_msg"`

  208. 		} `json:"tbk_sc_general_link_convert_response"`

  209. 	}

  210. 	if err = json.Unmarshal(resp, &tmp); err != nil {

  211. 		return nil, err

  212. 	}

  213. 	url := ""

  214. 	hasCoupon := false

  215. 	itemUrl := ""

  216. 	maxCommissionRate := ""

  217. 	tkl := ""

  218. 	shortTkl := ""

  219. 	isitem := 0

  220. 	for _, v := range tmp.TbkScGeneralLinkConvertResponse.Data.ItemUrlList.ItemUrlList {

  221. 		url = v.LinkInfoDto.CouponLongUrl

  222. 		tkl = v.LinkInfoDto.CouponFullTpwd

  223. 		shortTkl = v.LinkInfoDto.CouponShortTpwd

  224. 		if url == "" {

  225. 			url = v.LinkInfoDto.CpsLongUrl

  226. 			tkl = v.LinkInfoDto.CpsFullTpwd

  227. 			shortTkl = v.LinkInfoDto.CpsShortTpwd

  228. 		}

  229. 		if v.LinkInfoDto.CouponLongUrl != "" {

  230. 			hasCoupon = true

  231. 		}

  232. 		itemId = v.LinkInfoDto.ItemId

  233. 		itemUrl = url

  234. 		isitem = 1

  235. 		maxCommissionRate = v.PromotionInfoDto.CommissionRate

  236. 	}

  237. 

  238. 	for _, v := range tmp.TbkScGeneralLinkConvertResponse.Data.MaterialUrlList.MaterialUrlList {

  239. 		if v.LinkInfoDto.CouponLongUrl == "" && v.LinkInfoDto.CpsLongUrl == "" {

  240. 			continue

  241. 		}

  242. 		url = v.LinkInfoDto.CouponLongUrl

  243. 		tkl = v.LinkInfoDto.CouponFullTpwd

  244. 		shortTkl = v.LinkInfoDto.CouponShortTpwd

  245. 		if url == "" {

  246. 			url = v.LinkInfoDto.CpsLongUrl

  247. 			tkl = v.LinkInfoDto.CpsFullTpwd

  248. 			shortTkl = v.LinkInfoDto.CpsShortTpwd

  249. 		}

  250. 		if v.LinkInfoDto.CouponLongUrl != "" {

  251. 			hasCoupon = true

  252. 		}

  253. 		//1—单品 2—店铺 3—会场 4-承接开放 5-优惠券

  254. 		if v.Code == 0 && (v.LinkInfoDto.MaterialType == 1 || v.LinkInfoDto.MaterialType == 0) {

  255. 			itemId = v.LinkInfoDto.MaterialId

  256. 			isitem = 1

  257. 		}

  258. 		itemUrl = url

  259. 		maxCommissionRate = v.PromotionInfoDto.CommissionRate

  260. 	}

  261. 	if isitem == 0 && len(tmp.TbkScGeneralLinkConvertResponse.Data.MaterialUrlList.MaterialUrlList) > 0 {

  262. 		itemId = ""

  263. 	}

  264. 	for _, v := range tmp.TbkScGeneralLinkConvertResponse.Data.EventUrlList.EventUrlList {

  265. 		url = v.LinkInfoDto.CpsLongUrl

  266. 		tkl = v.LinkInfoDto.CpsFullTpwd

  267. 		shortTkl = v.LinkInfoDto.CpsShortTpwd

  268. 		itemUrl = url

  269. 	}

  270. 	isDown := "0"

  271. 	if tkl == "" {

  272. 		isDown = "2"

  273. 	}

  274. 	if strings.Contains(string(resp), "该商品已下架") {

  275. 		isDown = "1"

  276. 	}

  277. 	return &md.ConvertedUrls{

  278. 		IsDown:         isDown,

  279. 		Tkl:            tkl,

  280. 		ShortTkl:       shortTkl,

  281. 		ItemId:         itemId,

  282. 		URL:            url,

  283. 		ItemUrl:        itemUrl,

  284. 		ShortenURL:     url,

  285. 		NoOpenAppURL:   url,

  286. 		AppURL:         url,

  287. 		HasCoupon:      hasCoupon,

  288. 		CommissionRate: maxCommissionRate,

  289. 	}, nil

  290. }

  291. 

  292. type T struct {

  293. 	TbkScActivityInfoGetResponse struct {

  294. 		Data struct {

  295. 			ClickUrl      string `json:"click_url"`

  296. 			PageEndTime   string `json:"page_end_time"`

  297. 			PageName      string `json:"page_name"`

  298. 			PageStartTime string `json:"page_start_time"`

  299. 			TerminalType  string `json:"terminal_type"`

  300. 		} `json:"data"`

  301. 		RequestId string `json:"request_id"`

  302. 	} `json:"tbk_sc_activity_info_get_response"`

  303. }

  304. 

  305. func (t *TB) ActivityConvertUrlSC(activityMaterialId, pid string, relationId int64) (*md.OfficialRecommendUrl, error) {

  306. 	method := "taobao.tbk.sc.activity.info.get"

  307. 	_, siteId, adZoneId := SplitPid(pid)

  308. 	args := map[string]string{

  309. 		"activity_material_id": activityMaterialId,

  310. 		"session":              t.UserSID, // 一般用站长就可以转链

  311. 		"adzone_id":            adZoneId,

  312. 		"platform":             "2",

  313. 		"site_id":              siteId,

  314. 	}

  315. 	if relationId > 0 {

  316. 		args["relation_id"] = strconv.FormatInt(relationId, 10)

  317. 	}

  318. 	resp, err := send(args, method, t.Svc_AK, t.Svc_SK)

  319. 	if err != nil {

  320. 		return nil, err

  321. 	}

  322. 	var tmp struct {

  323. 		TbkScActivityInfoGetResponse struct {

  324. 			Data struct {

  325. 				WxQrcodeUrl       string `json:"wx_qrcode_url"`

  326. 				WxMiniprogramPath string `json:"wx_miniprogram_path"`

  327. 				Url               string `json:"click_url"`

  328. 				ShortClickurl     string `json:"short_click_url"`

  329. 			} `json:"data"`

  330. 		} `json:"tbk_sc_activity_info_get_response"`

  331. 	}

  332. 	if err = json.Unmarshal(resp, &tmp); err != nil {

  333. 		return nil, err

  334. 	}

  335. 

  336. 	url := tmp.TbkScActivityInfoGetResponse.Data.Url

  337. 	if tmp.TbkScActivityInfoGetResponse.Data.ShortClickurl != "" {

  338. 		url = tmp.TbkScActivityInfoGetResponse.Data.ShortClickurl

  339. 	}

  340. 	return &md.OfficialRecommendUrl{

  341. 		WxQrcodeUrl:       tmp.TbkScActivityInfoGetResponse.Data.WxQrcodeUrl,

  342. 		WxMiniprogramPath: tmp.TbkScActivityInfoGetResponse.Data.WxMiniprogramPath,

  343. 		Url:               url,

  344. 	}, nil

  345. }