Browse Source

10点执行

胡轶钦 6 years ago
parent
commit
c3ae2ea975
2 changed files with 10 additions and 1 deletions
  1. 3
    0
      conf/app.conf
  2. 7
    1
      models/task.go

+ 3
- 0
conf/app.conf View File

29
 common = "/common/:org"
29
 common = "/common/:org"
30
 wechat = "/wechat/:org"
30
 wechat = "/wechat/:org"
31
 
31
 
32
+
33
+[job]
34
+sendmessagetime = 10:00:00

+ 7
- 1
models/task.go View File

13
 func InitTask() {
13
 func InitTask() {
14
 	kernel := utils.NewKernel()
14
 	kernel := utils.NewKernel()
15
 	kernel.SetTask("sendmessage", SendMessageToCustomer)
15
 	kernel.SetTask("sendmessage", SendMessageToCustomer)
16
-	kernel.StartTask("sendmessage")
16
+	timeStr := time.Now().Format("2006-01-02") + beego.AppConfig.String("job::sendmessagetime")
17
+	ten, _ := time.Parse(timeStr, "2006-01-02 15:04:05")
18
+	tomorrow := ten.AddDate(0, 0, 1)
19
+
20
+	dur := tomorrow.Sub(time.Now())
21
+
22
+	kernel.StartTask("sendmessage", dur)
17
 }
23
 }
18
 
24
 
19
 func SendMessageToCustomer() time.Duration {
25
 func SendMessageToCustomer() time.Duration {