Merge remote-tracking branch 'origin'; commit 'FETCH_HEAD' into develop

service/auto_task.go

@@ -2,6 +2,9 @@ package service
 
 import (
 	"context"
+	"github.com/caixw/lib.go/conv"
+	"github.com/robfig/cron/v3"
+	"github.com/sirupsen/logrus"
 	"log"
 	"time"
 	"youngee_m_api/db"
@@ -14,9 +17,19 @@ import (
 func AutoTask() error {
 	// 新建一个定时任务对象
 	// 根据cron表达式进行时间调度，cron可以精确到秒，大部分表达式格式也是从秒开始。
-	//crontab := cron.New()  默认从分开始进行时间调度
+	// crontab := cron.New()  默认从分开始进行时间调度
 	crontab := cron.New(cron.WithSeconds()) //精确到秒
 	//定义定时器调用的任务函数
+	taskKDStatus := func() {
+		logisticNums := db.GetLogisticsNum()
+		for i := 0; i < len(logisticNums); i++ {
+			logisticNum := logisticNums[i]
+			status := GetKDStatus(consts.GetKD(logisticNum[0]), logisticNum[1])
+			if status == "1" {
+				db.SignLogistic(conv.MustInt64(logisticNum[2], 0))
+			}
+		}
+	}
 	//定时任务1 ，线下探店打卡的自动签收操作
 	task1 := func() {
 		DB := db.GetReadDB(context.Background())