Develop

.gitignore

@@ -13,4 +13,4 @@
 
 # Dependency directories (remove the comment below to include it)
 # vendor/
-go.sum
+.idea/

auth.go

@@ -0,0 +1,120 @@
+package xxl
+
+import (
+	"encoding/json"
+	"errors"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"sync"
+	"time"
+)
+
+type Auth interface {
+	Login() ([]*http.Cookie, error)
+}
+
+type AuthImpl struct {
+	Addr     string
+	UserName string
+	Password string
+
+	mu        sync.Mutex
+	closeChan chan struct{}
+	cookies   []*http.Cookie
+}
+
+func NewAuth(userName, password, addr string, interval time.Duration) (Auth, func(), error) {
+	auth := &AuthImpl{
+		UserName:  userName,
+		Password:  password,
+		Addr:      addr,
+		closeChan: make(chan struct{}),
+	}
+
+	auth.CronReplaceCookie(interval)
+
+	return auth, func() {
+		auth.closeChan <- struct{}{}
+	}, nil
+}
+
+const loginUrl = "/login"
+
+var LoginErr = errors.New("login failed")
+
+// Login 登录
+func (a *AuthImpl) Login() ([]*http.Cookie, error) {
+	if len(a.cookies) == 0 {
+
+		a.mu.Lock()
+		defer a.mu.Unlock()
+
+		if len(a.cookies) > 0 {
+			return a.cookies, nil
+		}
+
+		cookies, err := a.login()
+
+		if err != nil {
+			return nil, err
+		}
+
+		a.cookies = cookies
+	}
+
+	return a.cookies, nil
+}
+
+func (a *AuthImpl) CronReplaceCookie(interval time.Duration) {
+
+	go func(t time.Duration) {
+		ticker := time.NewTicker(t)
+
+	ReplaceXxlJonCookieLoop:
+		for {
+			select {
+			case <-ticker.C:
+				cookies, err := a.login()
+				if err != nil {
+					continue
+				}
+
+				a.cookies = cookies
+			case <-a.closeChan:
+				break ReplaceXxlJonCookieLoop
+			}
+		}
+	}(interval)
+}
+
+func (a *AuthImpl) login() ([]*http.Cookie, error) {
+	values := url.Values{}
+	values.Add("userName", a.UserName)
+	values.Add("password", a.Password)
+
+	resp, err := http.PostForm(a.Addr+loginUrl, values)
+	if err != nil {
+		return nil, err
+	}
+
+	defer resp.Body.Close()
+
+	all, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	response := &res{}
+	if err = json.Unmarshal(all, response); err != nil {
+		return nil, err
+	}
+
+	if response.Code == FailureCode {
+		return nil, LoginErr
+	}
+
+	cookies := resp.Cookies()
+
+	return cookies, nil
+}

constants.go

@@ -5,3 +5,42 @@ const (
 	SuccessCode = 200
 	FailureCode = 500
 )
+
+type ScheduleType string
+
+const (
+	FixRate ScheduleType = "FIX_RATE"
+	Cron    ScheduleType = "CRON"
+)
+
+type MisfireStrategy string
+
+const (
+	DoNothing   MisfireStrategy = "DO_NOTHING"    //  什么都不做
+	FireOnceNow MisfireStrategy = "FIRE_ONCE_NOW" // 立即执行
+)
+
+type ExecutorBlockStrategy string
+
+const (
+	SerialExecution ExecutorBlockStrategy = "SERIAL_EXECUTION" // 串行
+	DiscardLater    ExecutorBlockStrategy = "DISCARD_LATER"    // 丢弃后续调度
+	CoverEarly      ExecutorBlockStrategy = "COVER_EARLY"      // 覆盖之前调度
+)
+
+type TriggerStatus int32
+
+const (
+	Total   TriggerStatus = -1 // 全部
+	Stop    TriggerStatus = 0  // 停止
+	Running TriggerStatus = 1  // 运行
+)
+
+type ExecutorRouteStrategy string
+
+const (
+	First  ExecutorRouteStrategy = "FIRST"  // 第一个
+	Last   ExecutorBlockStrategy = "LAST"   // 最后一个
+	Round  ExecutorBlockStrategy = "ROUND"  // 轮询
+	Random ExecutorRouteStrategy = "RANDOM" // 随机
+)

dto.go

@@ -1,5 +1,7 @@
 package xxl
 
+import "time"
+
 //通用响应
 type res struct {
 	Code int64       `json:"code"` // 200 表示正常、其他失败
@@ -89,3 +91,99 @@ type LogResContent struct {
 	LogContent  string `json:"logContent"`  // 本次请求日志内容
 	IsEnd       bool   `json:"isEnd"`       // 日志是否全部加载完
 }
+
+/********************任务参数*******************/
+
+type AddJob struct {
+	JobGroup               int64  `json:"jobGroup"`                // 执行器ID
+	JobDesc                string `json:"jobDesc"`                 // 任务描述
+	Author                 string `json:"author"`                  // 作者
+	TriggerStatus          int32  `json:"triggerStatus"`           // 任务状态
+	AlarmEmail             string `json:"alarmEmail"`              // 多个邮件使用逗号分隔
+	ScheduleType           string `json:"scheduleType"`            // 调度类型, CRON 定时, FIX_RATE 固定速率
+	ScheduleConf           string `json:"scheduleConf"`            // 必传
+	ScheduleConfCron       string `json:"schedule_conf_CRON"`      // 不清楚该字段功能
+	CronGenDisplay         string `json:"cronGen_display"`         // CRON类型, 与scheduleConf一致, 否则不传
+	ScheduleConfFixDelay   string `json:"schedule_conf_FIX_DELAY"` // 不清楚该字段功能
+	ScheduleConfFixRate    string `json:"schedule_conf_FIX_RATE"`  // FIX_RATE类型, 与scheduleConf一致, 否则不传
+	GlueType               string `json:"glueType"`                // 运行模式, BEAN
+	ExecutorHandler        string `json:"executorHandler"`         // JobHandler, 任务名
+	ExecutorParam          string `json:"executorParam"`           // 执行参数
+	ExecutorRouteStrategy  string `json:"executorRouteStrategy"`   // 路由策略, ROUND 轮询, FIRST 第一个, LAST 最后一个
+	ChildJobId             string `json:"childJobId"`              // 子任务ID, 做个任务使用逗号隔开
+	MisfireStrategy        string `json:"misfireStrategy"`         // 调度过期策略, DO_NOTHING 忽略, FIRE_ONCE_NOW 立即执行一次
+	ExecutorBlockStrategy  string `json:"executorBlockStrategy"`   // 阻塞处理策略, SERIAL_EXECUTION 串行, DISCARD_LATER 丢弃后续调度, COVER_EARLY 覆盖之前调度
+	ExecutorTimeout        int64  `json:"executorTimeout"`         // 执行超时时间, 单位: s
+	ExecutorFailRetryCount int32  `json:"executorFailRetryCount"`  // 失败重试次数
+	GlueRemark             string `json:"glueRemark"`              // 值为: GLUE代码初始化
+	GlueSource             string `json:"glueSource"`              // 源码
+}
+
+/********************添加任务响应*******************/
+
+type AddJobResp struct {
+	Code    int         `json:"code"`
+	Msg     interface{} `json:"msg"`
+	Content string      `json:"content"`
+}
+
+/********************添加任务参数*******************/
+
+type JobInfo struct {
+	Id                     int       `json:"id"`
+	JobGroup               int       `json:"jobGroup"`
+	JobDesc                string    `json:"jobDesc"`
+	AddTime                time.Time `json:"addTime"`
+	UpdateTime             time.Time `json:"updateTime"`
+	Author                 string    `json:"author"`
+	AlarmEmail             string    `json:"alarmEmail"`
+	ScheduleType           string    `json:"scheduleType"`
+	ScheduleConf           string    `json:"scheduleConf"`
+	MisfireStrategy        string    `json:"misfireStrategy"`
+	ExecutorRouteStrategy  string    `json:"executorRouteStrategy"`
+	ExecutorHandler        string    `json:"executorHandler"`
+	ExecutorParam          string    `json:"executorParam"`
+	ExecutorBlockStrategy  string    `json:"executorBlockStrategy"`
+	ExecutorTimeout        int       `json:"executorTimeout"`
+	ExecutorFailRetryCount int       `json:"executorFailRetryCount"`
+	GlueType               string    `json:"glueType"`
+	GlueSource             string    `json:"glueSource"`
+	GlueRemark             string    `json:"glueRemark"`
+	GlueUpdatetime         time.Time `json:"glueUpdatetime"`
+	ChildJobId             string    `json:"childJobId"`
+	TriggerStatus          int       `json:"triggerStatus"`
+	TriggerLastTime        int       `json:"triggerLastTime"`
+	TriggerNextTime        int       `json:"triggerNextTime"`
+}
+
+/********************查询任务参数*******************/
+
+type QueryJob struct {
+	JobGroup        int64  `json:"jobGroup"`        // 执行器ID
+	TriggerStatus   int32  `json:"triggerStatus"`   // 直接使用-1
+	JobDesc         string `json:"jobDesc"`         // 任务描述
+	ExecutorHandler string `json:"executorHandler"` // 任务名
+	Author          string `json:"author"`          // 作者
+	Start           int32  `json:"start"`           // 偏移量, 默认是0
+	Length          int32  `json:"length"`          // 每页数量
+}
+
+/********************运行任务参数*******************/
+
+type RunJob struct {
+	Id int64 `json:"id"`
+}
+
+/********************查询任务响应*******************/
+
+type JobList struct {
+	RecordsFiltered int       `json:"recordsFiltered"`
+	Data            []JobInfo `json:"data"`
+	RecordsTotal    int       `json:"recordsTotal"`
+}
+
+/********************删除任务参数*******************/
+
+type DeleteJob struct {
+	Id int64 `json:"id"`
+}