浏览代码

定时任务

wangfei 6 年前
父节点
当前提交
5e75acb551
共有 3 个文件被更改,包括 26 次插入12 次删除
  1. 3
    0
      bootstrap/bootstrap.go
  2. 0
    12
      controllers/book/book.go
  3. 23
    0
      models/task.go

+ 3
- 0
bootstrap/bootstrap.go 查看文件

24
 	// 事件系统
24
 	// 事件系统
25
 	events.EventInit()
25
 	events.EventInit()
26
 
26
 
27
+	// 定时任务
28
+	models.InitTask()
29
+
27
 	// 路由系统
30
 	// 路由系统
28
 	routers.RouteInit()
31
 	routers.RouteInit()
29
 }
32
 }

+ 0
- 12
controllers/book/book.go 查看文件

6
 	"spaceofcheng/services/models/model"
6
 	"spaceofcheng/services/models/model"
7
 	"spaceofcheng/services/service/book"
7
 	"spaceofcheng/services/service/book"
8
 	"strings"
8
 	"strings"
9
-	"time"
10
 
9
 
11
 	"github.com/tealeg/xlsx"
10
 	"github.com/tealeg/xlsx"
12
 )
11
 )
289
 	}
288
 	}
290
 	c.ResponseJSON(list)
289
 	c.ResponseJSON(list)
291
 }
290
 }
292
-
293
-func (c *BookController) SendMessageToCustomer() time.Duration {
294
-	var timeNext time.Duration
295
-	return timeNext
296
-}
297
-
298
-// func (c *BookController) ScheduleTask() {
299
-// 	kernel := utils.NewKernel()
300
-// 	kernel.SetTask("refresh-token", SendMessageToCustomer)
301
-// 	kernel.StartTask("refresh-token")
302
-// }

+ 23
- 0
models/task.go 查看文件

1
+package models
2
+
3
+import (
4
+	"spaceofcheng/services/models/model"
5
+	"spaceofcheng/services/utils"
6
+	"time"
7
+)
8
+
9
+func InitTask() {
10
+	kernel := utils.NewKernel()
11
+	kernel.SetTask("sendmessage", SendMessageToCustomer)
12
+	kernel.StartTask("sendmessage")
13
+}
14
+
15
+func SendMessageToCustomer() time.Duration {
16
+	// do something
17
+	sql := ``
18
+	var records []model.TaBookBorrowRecord
19
+	DBEngine.Sql(sql).Find(&records)
20
+	// 发消息
21
+	var timeNext time.Duration
22
+	return timeNext
23
+}