services/reward/period_task.go

@@ -66,7 +66,10 @@ func RunRewardTask(t models.RewardPeriodicTask, now time.Time) error {
 		return nil
 	}
 	task, err := models.GetCloudbrainByID(record.SourceId)
-
+	if task == nil {
+		log.Info("RunRewardTask task is not exists.taskID = %d", record.SourceId)
+		return nil
+	}
 	log.Info("RunRewardTask. operate record=%+v", record)
 	n, _ := countExecuteTimes(t, now)
 	if n == 0 {