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.
361 Commits
1 Branch
2.0 MiB
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
zyos_go_third_party_api/taobao/convert_url.go

352 lines
12 KiB
Raw Permalink 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. 	isActivity := 0

  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. 		if v.LinkInfoDto.MaterialType == 3 {

  259. 			isActivity = 1

  260. 		}

  261. 		itemUrl = url

  262. 		maxCommissionRate = v.PromotionInfoDto.CommissionRate

  263. 	}

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

  265. 		itemId = ""

  266. 	}

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

  268. 		url = v.LinkInfoDto.CpsLongUrl

  269. 		tkl = v.LinkInfoDto.CpsFullTpwd

  270. 		shortTkl = v.LinkInfoDto.CpsShortTpwd

  271. 		itemUrl = url

  272. 	}

  273. 	isDown := "0"

  274. 	if isActivity == 1 {

  275. 		isDown = "10"

  276. 	}

  277. 	if tkl == "" {

  278. 		isDown = "2"

  279. 	}

  280. 	if strings.Contains(string(resp), "该商品已下架") || strings.Contains(string(resp), "URL解析失败") || strings.Contains(string(resp), "当前APPKEY无淘口令解析权限") {

  281. 		isDown = "1"

  282. 	}

  283. 	return &md.ConvertedUrls{

  284. 		IsDown:         isDown,

  285. 		Tkl:            tkl,

  286. 		ShortTkl:       shortTkl,

  287. 		ItemId:         itemId,

  288. 		URL:            url,

  289. 		ItemUrl:        itemUrl,

  290. 		ShortenURL:     url,

  291. 		NoOpenAppURL:   url,

  292. 		AppURL:         url,

  293. 		HasCoupon:      hasCoupon,

  294. 		CommissionRate: maxCommissionRate,

  295. 	}, nil

  296. }

  297. 

  298. type T struct {

  299. 	TbkScActivityInfoGetResponse struct {

  300. 		Data struct {

  301. 			ClickUrl      string `json:"click_url"`

  302. 			PageEndTime   string `json:"page_end_time"`

  303. 			PageName      string `json:"page_name"`

  304. 			PageStartTime string `json:"page_start_time"`

  305. 			TerminalType  string `json:"terminal_type"`

  306. 		} `json:"data"`

  307. 		RequestId string `json:"request_id"`

  308. 	} `json:"tbk_sc_activity_info_get_response"`

  309. }

  310. 

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

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

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

  314. 	args := map[string]string{

  315. 		"activity_material_id": activityMaterialId,

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

  317. 		"adzone_id":            adZoneId,

  318. 		"platform":             "2",

  319. 		"site_id":              siteId,

  320. 	}

  321. 	if relationId > 0 {

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

  323. 	}

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

  325. 	if err != nil {

  326. 		return nil, err

  327. 	}

  328. 	var tmp struct {

  329. 		TbkScActivityInfoGetResponse struct {

  330. 			Data struct {

  331. 				WxQrcodeUrl       string `json:"wx_qrcode_url"`

  332. 				WxMiniprogramPath string `json:"wx_miniprogram_path"`

  333. 				Url               string `json:"click_url"`

  334. 				ShortClickurl     string `json:"short_click_url"`

  335. 			} `json:"data"`

  336. 		} `json:"tbk_sc_activity_info_get_response"`

  337. 	}

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

  339. 		return nil, err

  340. 	}

  341. 

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

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

  344. 		url = tmp.TbkScActivityInfoGetResponse.Data.ShortClickurl

  345. 	}

  346. 	return &md.OfficialRecommendUrl{

  347. 		WxQrcodeUrl:       tmp.TbkScActivityInfoGetResponse.Data.WxQrcodeUrl,

  348. 		WxMiniprogramPath: tmp.TbkScActivityInfoGetResponse.Data.WxMiniprogramPath,

  349. 		Url:               url,

  350. 	}, nil

  351. }