feat: fix issues

templates/project/app/jobs/demo_cron.go.tpl

@@ -0,0 +1,48 @@
+package jobs
+
+import (
+	"time"
+
+	_ "git.ipao.vip/rogeecn/atom"
+	"git.ipao.vip/rogeecn/atom/contracts"
+	"github.com/riverqueue/river"
+	"github.com/sirupsen/logrus"
+)
+
+var _ contracts.CronJob = (*CronJob)(nil)
+
+// @provider contracts.CronJob atom.GroupCronJob
+type CronJob struct {
+	log *logrus.Entry `inject:"false"`
+}
+
+func (cron *CronJob) Prepare() error {
+	cron.log = logrus.WithField("module", "cron")
+	return nil
+}
+
+func (cron *CronJob) Description() string {
+	return "hello world cron job"
+}
+
+// InsertOpts implements contracts.CronJob.
+func (cron *CronJob) InsertOpts() *river.InsertOpts {
+	return nil
+}
+
+// JobArgs implements contracts.CronJob.
+func (cron *CronJob) JobArgs() river.JobArgs {
+	return SortArgs{
+		Strings: []string{"a", "c", "b", "d"},
+	}
+}
+
+// Periodic implements contracts.CronJob.
+func (cron *CronJob) Periodic() time.Duration {
+	return time.Second * 10
+}
+
+// RunOnStart implements contracts.CronJob.
+func (cron *CronJob) RunOnStart() bool {
+	return true
+}

templates/project/app/jobs/demo_job.go.tpl

@@ -25,7 +25,7 @@ type SortArgs struct {
 // InsertOpts implements JobArgsWithInsertOpts.
 func (s SortArgs) InsertOpts() InsertOpts {
 	return InsertOpts{
-		Queue:    "high_priority",
+		Queue:    QueueDefault,
 		Priority: PriorityDefault,
 	}
 }