改 bug

services/hangguan.go

@@ -40,6 +40,7 @@ func (s *HangguanService) requestSFDataConvert(task models.HgFlightSearchTask, s
 		ArrCode: task.Arr,
 		Date:    startDate,
 		FlyNo:   task.FlightNo,
+		AcCode:  task.Flight,
 	}
 
 	// 将结构体转换为 JSON
@@ -70,8 +71,8 @@ func (h *HangguanService) RequestSFlightData(ctx context.Context, task models.Hg
 		// 记录请求数据
 		//utils.Logger.WithField("task_id", task.ID).Info("请求数据: ", string(reqData))
 		// 调用第三方接口
-		//resp, err := h.httpClient.RequestWithProxy(ctx, "POST", url, reqData, h.cfg.ProxyUrl) //测试使用
-		resp, err := h.httpClient.RequestJSON(ctx, "POST", url, reqData)
+		resp, err := h.httpClient.RequestWithProxy(ctx, "POST", url, reqData, h.cfg.ProxyUrl) //测试使用
+		//resp, err := h.httpClient.RequestJSON(ctx, "POST", url, reqData)
 		// 记录响应数据
 		//utils.Logger.WithField("task_id", task.ID).Info("响应数据: ", string(resp))
 		if err != nil {
@@ -108,7 +109,8 @@ func (h *HangguanService) processResponse(ctx context.Context, task *models.HgFl
 	pushDataList := make([]structs.Datum, 0)
 	for _, fltData := range response.Datas {
 		if fltData.FlightInfo.IsCancel == 1 ||
-			len(fltData.CabinInfos) == 0 { //航班取消 或者 无舱位信息 或者 无实际承运航司
+			len(fltData.CabinInfos) == 0 ||
+			fltData.FlightInfo.AcCode != task.Flight { //航班取消 或者 无舱位信息 或者 无实际承运航司
 			continue
 		}
 		var minPrice float64 = 0

structs/search_flight_api.go

@@ -5,6 +5,7 @@ type ReqSearchFlightData struct {
 	ArrCode string `json:"arrCode"`
 	Date    string `json:"date"`
 	FlyNo   string `json:"flyNo"`
+	AcCode  string `json:"acCode"`
 }
 
 type ResSearchFlight struct {