Răsfoiți Sursa

定时任务修改

WH01243 5 luni în urmă
părinte
comite
15fd3a5258
2 a modificat fișierele cu 10 adăugiri și 10 ștergeri
  1. 8 9
      config/config.go
  2. 2 1
      timetask/timetask.go

+ 8 - 9
config/config.go

@@ -35,15 +35,14 @@ type config struct {
 		Qfw     *mongo `json:"qfw"`
 		Qyfw    *mongo `json:"jyqyfw"`
 	} `json:"mongodb"`
-	TaskRule          string                 `json:"taskRule"`
-	RuleTime          int                    `json:"ruleTime"`
-	Tidb              *mysqlConf             `json:"tidb"`
-	EntId             int64                  `json:"entId"`
-	Appid             string                 `json:"appid"`
-	TaskTimeout       string                 `json:"taskTimeout"` // 超时未处理标签任务
-	TimeoutMode       int                    `json:"timeoutMode"` // 0: 自然日, 1: 工作日
-	AppUser           map[string]interface{} `json:"appUser"`
-	EmployTaskTimeout string                 `json:"appid"`
+	TaskRule    string                 `json:"taskRule"`
+	RuleTime    int                    `json:"ruleTime"`
+	Tidb        *mysqlConf             `json:"tidb"`
+	EntId       int64                  `json:"entId"`
+	Appid       string                 `json:"appid"`
+	TaskTimeout string                 `json:"taskTimeout"` // 超时未处理标签任务
+	TimeoutMode int                    `json:"timeoutMode"` // 0: 自然日, 1: 工作日
+	AppUser     map[string]interface{} `json:"appUser"`
 }
 
 type mysqlConf struct {

+ 2 - 1
timetask/timetask.go

@@ -3,6 +3,7 @@ package timetask
 import (
 	. "digitalMarketing/config"
 	"digitalMarketing/top"
+	"github.com/gogf/gf/v2/util/gconv"
 	"log"
 
 	"github.com/robfig/cron"
@@ -17,7 +18,7 @@ func Run() {
 	top.ExcTopInfo()
 	c.AddFunc(Config.TaskTimeout, top.ExcTopInfo)
 
-	c.AddFunc(Config.EmployTaskTimeout, top.UsermailInsertEmploy)
+	c.AddFunc(gconv.String(Config.AppUser["employTaskTimeout"]), top.UsermailInsertEmploy)
 	c.Start()
 	defer c.Stop()