runner

type CacheableENJob struct {
	Task []DeepSearchTask          `json:"task"`
	Data map[string][]gjson.Result `json:"data"` // 将 gjson.Result 转换为字符串存储
}

type DeepSearchTask struct {
	common.DPS
	SearchList []string `json:"search_list"`
}

type ENJob struct {
	Task      []DeepSearchTask
	Data      map[string][]gjson.Result
	TaskCh    chan DeepSearchTask
	DataCh    chan map[string][]gjson.Result
	Total     int
	Processed int
}

type ENJobTask struct {
	Keyword string `json:"keyword"`
	Typ     string `json:"type"`
	Ref     string `json:"ref"`
}

type ENSCacheDTO struct {
	JobName string
	Date    string
	Tasks   []ENJobTask
	Data    map[string][]map[string]string
	Jobs    map[string]CacheableENJob
}

type ENSOp struct {
	OrgName  string  `form:"name" json:"name"`
	ScanType string  `form:"type" json:"type"`
	Filed    string  `form:"filed" json:"filed"`
	Depth    int     `form:"depth" json:"depth"`
	Invest   float64 `form:"invest" json:"invest"`
	Holds    bool    `form:"hold" json:"hold"`
	Supplier bool    `form:"supplier" json:"supplier"`
	Branch   bool    `form:"branch" json:"branch"`
}

type ENStatus struct {
	JobProcessed int         `json:"processed"`
	JobTotal     int         `json:"total"`
	JobItems     []ENJobTask `json:"items"`
	Tasks        []ENTask    `json:"tasks"`
}

type ENTask struct {
	TaskName      string           `json:"name"`
	TaskProcessed int              `json:"processed"`
	TaskTotal     int              `json:"total"`
	Items         []DeepSearchTask `json:"items"`
}

type ESJob struct {
	JobName string
	Jobs    chan ENJobTask

	Done chan struct{}
	// contains filtered or unexported fields
}

type EnJob struct {
	Done chan struct{}
	// contains filtered or unexported fields
}

type InfoPage struct {
	Total   int64               `json:"total"`
	Page    int64               `json:"page"`
	Size    int64               `json:"size"`
	HasNext bool                `json:"has_next"`
	List    []map[string]string `json:"list"`
}