修改提取 请求sensordata 的url

src/model/akm_init.go

@@ -27,7 +27,7 @@ type AkmClient struct {
 	ua        string
 }
 
-func (akm *AkmClient) init() error {
+func (akm *AkmClient) Init() error {
 	startTime := time.Now()
 	req, err := http.NewRequest(http.MethodGet, akm.initUrl, nil)
 	//req, err := http.NewRequest(http.MethodGet, "https://www.easyjet.com/ejavailability/api/v66/availability/query?AdditionalSeats=0&AdultSeats=1&ArrivalIata=LGW&ChildSeats=0&DepartureIata=BFS&IncludeAdminFees=true&IncludeFlexiFares=false&IncludeLowestFareSeats=true&IncludePrices=true&Infants=0&IsTransfer=false&LanguageCode=EN&MaxDepartureDate=2023-03-20&MinDepartureDate=2023-03-18", nil)
@@ -64,16 +64,15 @@ func (akm *AkmClient) init() error {
 	scripts := doc.Find("script")
 	lastScript := scripts.Last()
 	for {
-		src, ok := scripts.Last().Attr("src")
-		types, ok2 := scripts.Last().Attr("type")
+		src, ok := lastScript.Attr("src")
+		types, ok2 := lastScript.Attr("type")
 
-		if ok == false {
-			lastScript = lastScript.Prev()
-		}
-		if ok2 && types == "text/javascript" {
+		if ok2 && ok && types == "text/javascript" && !strings.Contains(src, ".") {
 			akm.SensorUrl = fmt.Sprintf("%s://%s%s", uri.Scheme, uri.Host, src)
 			break
 		}
+		lastScript = lastScript.Prev()
+
 	}
 	//	akm.SensorUrl = fmt.Sprintf("%s://%s%s", uri.Scheme, uri.Host, matchs[1])
 	if akm.SensorUrl == "" {
@@ -90,10 +89,8 @@ func NewAkmClient(initUrl, postUrl, proxyUrl string, logger *logrus.Entry) *AkmC
 	options := []tls_client.HttpClientOption{
 		tls_client.WithTimeoutSeconds(30),
 		tls_client.WithClientProfile(tls_client.Chrome_110),
-		tls_client.WithNotFollowRedirects(),
 		tls_client.WithCookieJar(jar), // create cookieJar instance and pass it as argument
 		//tls_client.WithProxyUrl("http://user:pass@host:port"),
-		//tls_client.WithInsecureSkipVerify(),
 	}
 
 	client, err := tls_client.NewHttpClient(tls_client.NewNoopLogger(), options...)

src/model/common.go

@@ -7,7 +7,7 @@ func Common(carrierType, proxyUrl string) (*Akm, error) {
 	logger.Info("使用代理", proxyUrl)
 	akmClient := NewAkmClient(NKURL, NKPostUrl, proxyUrl, logger)
 
-	err := akmClient.init()
+	err := akmClient.Init()
 	if err != nil {
 		return nil, err
 	}

src/model/easyjet.go

@@ -10,7 +10,7 @@ func EasyJet(carrierType, proxyUrl string) (*Akm, error) {
 	akmClient := NewAkmClient(U2Url, U2PostUrl, proxyUrl, logger)
 	akmClient.ua = "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/110.0.0.0 Safari/537.36 Edg/110.0.1587.50"
 
-	err := akmClient.init()
+	err := akmClient.Init()
 	if err != nil {
 		return nil, err
 	}

src/model/ew.go

@@ -10,7 +10,7 @@ func EW(carrierType, proxyUrl string) (*Akm, error) {
 	logger.Info("使用代理", proxyUrl)
 	akmClient := NewAkmClient(EWUrl, EWPostUrl, proxyUrl, logger)
 
-	err := akmClient.init()
+	err := akmClient.Init()
 	if err != nil {
 		return nil, err
 	}

src/model/nk.go

@@ -7,7 +7,7 @@ func NK(carrierType, proxyUrl string) (*Akm, error) {
 	logger.Info("使用代理", proxyUrl)
 	akmClient := NewAkmClient(NKURL, NKPostUrl, proxyUrl, logger)
 
-	err := akmClient.init()
+	err := akmClient.Init()
 	if err != nil {
 		return nil, err
 	}

src/model/vueling.go

@@ -7,7 +7,7 @@ func VueLing(carrierType, proxyUrl string) (*Akm, error) {
 	logger.Info("使用代理", proxyUrl)
 	akmClient := NewAkmClient(VYUrl, VYPostUrl, proxyUrl, logger)
 	akmClient.ua = "Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1"
-	err := akmClient.init()
+	err := akmClient.Init()
 	if err != nil {
 		return nil, err
 	}

src/test/test_akm_init.go

+package main
+
+import "test/model"
+
+func main() {
+
+	akmClient := model.NewAkmClient(model.EWUrl, model.EWPostUrl, "http://127.0.0.1:8890", nil)
+	akmClient.Init()
+}