diff --git a/worker/checkin.go b/worker/checkin.go index 2878d45..017867c 100644 --- a/worker/checkin.go +++ b/worker/checkin.go @@ -7,6 +7,7 @@ import ( "enterprise/common/weixin" log "github.com/sirupsen/logrus" "strings" + "time" ) func SyncCheckin(day string) error { @@ -69,6 +70,7 @@ func SyncCheckin(day string) error { if isUpdate { go NotifyCheckinOffDuty(checkin) } + time.Sleep(60 * time.Second) } return nil diff --git a/worker/worker.go b/worker/worker.go index c8a905a..1317c24 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -1,7 +1,6 @@ package worker import ( - "fmt" "github.com/go-co-op/gocron" "time" ) @@ -21,17 +20,6 @@ func Init() error { go SyncCheckin(time.Now().Format("2006-01-02")) }) - // 早晚高频拉取 - sch := cron.Every(1).Day() - for i := 0; i < 12; i++ { - sch.At(fmt.Sprintf("08:%02d", i*5)) - sch.At(fmt.Sprintf("09:%02d", i*5)) - sch.At(fmt.Sprintf("18:%02d", i*5)) - } - sch.Do(func() { - go SyncCheckin(time.Now().Format("2006-01-02")) - }) - // 每天同步企业人事信息 cron.Every(1).Day().At("01:00").Do(func() { go SyncStaffInfo()