Bläddra i källkod

fix:最近一次更新订单记录

duxin 1 månad sedan
förälder
incheckning
c2a8feabef
2 ändrade filer med 11 tillägg och 2 borttagningar
  1. 8 0
      internal/logic/timedTask/automaticPayment.go
  2. 3 2
      internal/logic/timedTask/init.go

+ 8 - 0
internal/logic/timedTask/automaticPayment.go

@@ -30,6 +30,14 @@ type FilterStr struct {
 	paybackListArr []map[string]interface{}
 }
 
+func AutomaticPaymentCollection() {
+	autoReturnTaskTime := g.Cfg().MustGet(context.Background(), "autoReturnTaskTime", 3).Int()
+	for {
+		AutomaticPayment()
+		time.Sleep(gconv.Duration(autoReturnTaskTime) * time.Minute)
+	}
+}
+
 func AutomaticPayment() {
 	var ctx = context.Background()
 	log.Println("自动回款匹配。。。开始")

+ 3 - 2
internal/logic/timedTask/init.go

@@ -8,9 +8,10 @@ import (
 
 func AutoReturnTask() {
 	cr := cron.New()
-	go AutomaticPayment()  //首次执行
+	//go AutomaticPayment()  //首次执行
 	go OnlineReturnMoney() //首次执行
-	cr.AddFunc(g.Cfg().MustGet(context.Background(), "autoReturnTaskTime", "0 */3 * * * ?").String(), AutomaticPayment)
+	go AutomaticPaymentCollection()
+	//cr.AddFunc(g.Cfg().MustGet(context.Background(), "autoReturnTaskTime", "0 */3 * * * ?").String(), AutomaticPayment)
 	cr.AddFunc(g.Cfg().MustGet(context.Background(), "onlineReturnMoney", "0 */2 * * * ?").String(), OnlineReturnMoney)
 	cr.AddFunc(g.Cfg().MustGet(context.Background(), "protocolNotice.cron", "# 0 2 * * *").String(), OrderProtocolNotice)
 	cr.Start()