Ethan преди 6 месеца
родител
ревизия
8beab5665c
променени са 3 файла, в които са добавени 16 реда и са изтрити 7 реда
  1. 1 1
      app/schedule/auto_task1.go
  2. 14 5
      main.go
  3. 1 1
      service/autoTask.go

+ 1 - 1
app/schedule/auto_task1.go

@@ -13,7 +13,7 @@ import (
 func AutoTask1() error {
 	// 新建一个定时任务对象
 	crontab := cron.New(cron.WithSeconds()) // 精确到秒
-	spec := "0 */5 * * * ?"                 //cron表达式,每5h一次
+	spec := "0 */5 * * * ?"                 //cron表达式,每5分钟一次
 	// "0 0 12 * * ?" 每天中午12点执行
 
 	// 添加定时任务

+ 14 - 5
main.go

@@ -3,6 +3,8 @@ package main
 import (
 	"fmt"
 	"github.com/gin-gonic/gin"
+	log "github.com/sirupsen/logrus"
+	"youngee_b_api/app/schedule"
 	"youngee_b_api/config"
 	_ "youngee_b_api/docs"
 	"youngee_b_api/route"
@@ -18,10 +20,17 @@ func main() {
 	service.SMTPMailServiceIstance.Init(mailConfig)
 
 	addr := fmt.Sprintf("%v:%v", config.Host, config.Port)
-	//err := service.AutoTask()
-	//err := schedule.AutoTask()
-	//if err != nil {
-	//	log.Println("service AutoTask error:", err)
-	//}
+	err := service.AutoTask()
+	if err != nil {
+		log.Println("service AutoTask error:", err)
+	}
+	err1 := schedule.AutoTask1()
+	if err1 != nil {
+		log.Println("schedule AutoTask1 error:", err1)
+	}
+	err2 := schedule.AutoTask2()
+	if err2 != nil {
+		log.Println("schedule AutoTask2 error:", err2)
+	}
 	r.Run(addr) // listen and serve on 0.0.0.0:8080 (for windows "localhost:8080")
 }

+ 1 - 1
service/autoTask.go

@@ -11,7 +11,7 @@ import (
 func AutoTask() error {
 	c := cron.New(cron.WithSeconds())
 	//spec := "0 */30 * * * ?" //cron表达式,每半小时执行一次
-	spec := "0 */1 * * * ?" //cron表达式,每1分钟一次
+	spec := "0 */2 * * * ?" //cron表达式,每1分钟一次
 	//spec := "*/10 * * * * ?" //cron表达式,每10秒一次
 
 	/*