This commit is contained in:
cdle 2021-08-22 21:10:37 +08:00
parent fe9d0fa3df
commit 957bb45afc
4 changed files with 14 additions and 15 deletions

View File

@ -176,9 +176,7 @@ var handleMessage = func(msgs ...interface{}) interface{} {
if Cdle {
return "推毛线啊"
}
runTask(&Task{Path: "jd_tyt.js", Envs: []Env{
{Name: "tytpacketId", Value: ss[1]},
}}, msgs...)
runTask(&Task{Path: "jd_tyt.js"}, msgs...)
return nil
}
}

View File

@ -114,9 +114,9 @@ func (rp *Repo) addTask() {
for i := range rp.Task {
task := &rp.Task[i]
eid, err := c.AddFunc(task.Cron, func() {
if Cdle {
return
}
// if Cdle {
// return
// }
logs.Info("执行任务 %s %s ", task.Title, task.Cron)
runTask(task)
})

View File

@ -15,19 +15,19 @@ import (
type Task struct {
ID int
EntryID int
Cron string
Path string
Enable bool
Enable string
Mode string
Word string
Name string
Timeout int
Envs []Env
Args string
Hack bool
Hack string
Git string
Title string
Running bool
Running string
}
type Env struct {
@ -56,7 +56,7 @@ func createTask(task *Task) {
}
func runTask(task *Task, msgs ...interface{}) string {
task.Running = true
task.Running = True
path := ""
if task.Git != "" {
path = task.Git + "/" + task.Name
@ -109,9 +109,9 @@ func runTask(task *Task, msgs ...interface{}) string {
lan = Config.Python
}
envs := ""
for _, env := range task.Envs {
envs += fmt.Sprintf("export %s=\"%s\"", env.Name, env.Value)
}
// for _, env := range task.Envs {
// envs += fmt.Sprintf("export %s=\"%s\"", env.Name, env.Value)
// }
sh := fmt.Sprintf(`
%s
%s %s
@ -167,6 +167,6 @@ func runTask(task *Task, msgs ...interface{}) string {
if msg != "" {
sendMessagee(msg, msgs...)
}
task.Running = false
task.Running = False
return msg
}

1
readme.txt Normal file
View File

@ -0,0 +1 @@
自用 学习 不求用。我就是上传数据也不叫偷,我自己脚本还不是想咋写就咋写,管得着吗,神经病整天头偷偷偷的毛病。