go-policy-service/services/validate.go

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
}