package services import ( "fmt" "go-policy-service/config" "go-policy-service/models" "go-policy-service/utils" ) func validateTask(task models.HgFlightSearchTask, cfg *config.Config) error { // 服务标签 serviceTag := []string{"3uSpecial", "lowPriceFlashSale", "carrieFlight", "muCarrieFlight", "discountPriceC1", "discountPriceB1"} // 验证参数 if task.Dep == "" || task.Arr == "" || task.Date == 0 || task.ServiceTag == "" { return fmt.Errorf("dep, arr, date, service_tag参数不能为空: %v", task) } // 验证服务标签 if !utils.Contains(serviceTag, task.ServiceTag) { return fmt.Errorf("service_tag参数不在serviceTag中: %v", serviceTag) } return nil }