url_jx.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  1. package dyjx
  2. import (
  3. "dysy/apis"
  4. "dysy/models"
  5. "encoding/json"
  6. "errors"
  7. "fmt"
  8. "github.com/asmcos/requests"
  9. "github.com/gin-gonic/gin"
  10. "net/http"
  11. "strings"
  12. )
  13. func DouYinUrlJieXi(c *gin.Context) {
  14. //前端给端视频连接
  15. var inData models.DyJieXiInput
  16. var outData models.DyJieXiOutput
  17. err := c.ShouldBindJSON(&inData)
  18. if err != nil {
  19. outData.Code = apis.Code400
  20. outData.Message = apis.InputFail
  21. c.JSON(http.StatusOK, outData)
  22. return
  23. }
  24. err, outData = DeWater(inData)
  25. if err != nil {
  26. outData.Code = apis.Code500
  27. outData.Message = err.Error()
  28. c.JSON(http.StatusOK, outData)
  29. return
  30. }
  31. outData.Code = apis.Code200
  32. outData.Message = apis.Success
  33. c.JSON(http.StatusOK, outData)
  34. }
  35. func DeWater(in models.DyJieXiInput) (error, models.DyJieXiOutput) {
  36. var out models.DyJieXiOutput
  37. fmt.Println("test")
  38. str := ""
  39. baseHost := in.Url
  40. client := &http.Client{
  41. CheckRedirect: func(req *http.Request, via []*http.Request) error {
  42. return http.ErrUseLastResponse
  43. },
  44. }
  45. res, err := client.Get(baseHost)
  46. if err != nil {
  47. return errors.New(apis.ClientGetFail), out
  48. }
  49. //if res.StatusCode != 301 {
  50. // fmt.Println(baseHost)
  51. // //return baseHost
  52. //}
  53. //fmt.Println(res.Header.Get("Location"))
  54. str = res.Header.Get("Location")
  55. comma := strings.Index(str, "/video/")
  56. pos := strings.Index(str, "/?")
  57. fmt.Println(comma, pos, str[comma+7:pos])
  58. var inData models.DyJieXi
  59. baseHost = "https://www.iesdouyin.com/web/api/v2/aweme/iteminfo/?item_ids=" + str[comma+7:pos]
  60. req := requests.Requests()
  61. resp, err := req.Get(baseHost)
  62. if err != nil {
  63. return errors.New(apis.RedirectUrlFail), out
  64. }
  65. err = json.Unmarshal([]byte(resp.Text()), &inData)
  66. if err != nil {
  67. return errors.New(apis.JsonUnmarshalFail), out
  68. //fmt.Println()
  69. }
  70. fmt.Println(inData)
  71. //视频url
  72. var videoUrl = inData.ItemList[0].Video.PlayAddr.URLList[0]
  73. fmt.Println(inData.ItemList[0].Video.PlayAddr.URLList[0])
  74. fmt.Println(inData.ItemList[0].Video.PlayAddr.URI)
  75. fmt.Println(strings.Replace(videoUrl, "playwm", "play", 1))
  76. out.Data.VideoUrl = strings.Replace(videoUrl, "playwm", "play", 1)
  77. //音频url
  78. //musicUrl = dyResult.getItem_list().get(0).getMusic().getPlay_url().getUri();
  79. //dyDto.setMusicUrl(musicUrl);
  80. fmt.Println(inData.ItemList[0].Music.PlayURL.URI)
  81. //fmt.Println(inData.ItemList[0].Music.PlayURL.URLList[0])
  82. out.Data.AudioUrl = inData.ItemList[0].Music.PlayURL.URI
  83. //videoPic = dyResult.getItem_list().get(0).getVideo().getDynamic_cover().getUrl_list().get(0);
  84. //dyDto.setVideoPic(videoPic);
  85. //封面
  86. fmt.Println(inData.ItemList[0].Video.DynamicCover.URLList[0])
  87. out.Data.VideoPic = inData.ItemList[0].Video.DynamicCover.URLList[0]
  88. //文案
  89. //desc = dyResult.getItem_list().get(0).getDesc();
  90. // dyDto.setDesc(desc);
  91. fmt.Println(inData.ItemList[0].Desc)
  92. out.Data.Desc = inData.ItemList[0].Desc
  93. return nil, out
  94. }