上课提醒

pom.xml

@@ -67,6 +67,21 @@
         <artifactId>studio-api</artifactId>
         <version>0.0.1-SNAPSHOT</version>
       </dependency>
+      <dependency>
+        <groupId>com.jiejing.base</groupId>
+        <artifactId>cronjob-sdk</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+      </dependency>
+      <dependency>
+        <groupId>com.jiejing.event</groupId>
+        <artifactId>scs-event</artifactId>
+        <version>0.0.6-SNAPSHOT</version>
+      </dependency>
+      <dependency>
+        <groupId>com.jiejing.app</groupId>
+        <artifactId>notify-api</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+      </dependency>
       <!-- ======================= jiejing api end ======================= -->
 
 

server/pom.xml

@@ -55,7 +55,18 @@
       <groupId>com.alibaba</groupId>
       <artifactId>fastjson</artifactId>
     </dependency>
-
+    <dependency>
+      <groupId>com.jiejing.base</groupId>
+      <artifactId>cronjob-sdk</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.jiejing.event</groupId>
+      <artifactId>scs-event</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.jiejing.app</groupId>
+      <artifactId>notify-api</artifactId>
+    </dependency>
     <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-actuator</artifactId>

server/src/main/java/com/jiejing/bff/crontab/server/CrontabBffApplication.java

 package com.jiejing.bff.crontab.server;
 
+import com.jiejing.cronjob.annotation.EnableCronJobWorker;
+import com.xiaomai.event.annotation.EnableEventBinding;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -19,9 +21,13 @@ import org.springframework.scheduling.annotation.EnableScheduling;
     "com.jiejing.member.api",
     "com.jiejing.paycenter.api",
     "com.jiejing.fitness.finance.api",
-    "com.jiejing.studio.api"
+    "com.jiejing.studio.api",
+    "com.jiejing.notify.api"
 })
 @SpringBootApplication(scanBasePackages = "com.jiejing")
+@EnableCronJobWorker
+@EnableEventBinding(configs = {
+})
 public class CrontabBffApplication {
 
   public static void main(String[] args) {

server/src/main/java/com/jiejing/bff/crontab/server/notify/CreateScheduleNotifyTaskCronHandler.java

+package com.jiejing.bff.crontab.server.notify;
+
+import com.alibaba.fastjson.JSONObject;
+import com.google.common.collect.Lists;
+import com.jiejing.cronjob.handler.ICronJobHandler;
+import com.jiejing.cronjob.model.CronJobContext;
+import com.jiejing.fitness.enums.message.ReceiveTypeEnum;
+import com.jiejing.notify.api.ClassStartReminderDayTaskApi;
+import com.jiejing.notify.common.request.task.ClassStartReminderRequest;
+import javax.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiezhongtao
+ * @date 2024/6/4 10:25
+ */
+@Component
+@Slf4j
+public class CreateScheduleNotifyTaskCronHandler implements ICronJobHandler {
+
+  @Resource
+  private ClassStartReminderDayTaskApi classStartReminderDayTaskApi;
+
+  @Override
+  public String jobCode() {
+    return "create_schedule_notify_task";
+  }
+
+  @Override
+  public Object execute(CronJobContext context, String jobParams) {
+    log.info("创建课次通知任务  context:{}   jobParams:{}", context, jobParams);
+    Integer retryIndex = context.getRetryIndex();
+    if (null == retryIndex) {
+      retryIndex = 0;
+    }
+    if (retryIndex > 3) {
+      throw new RuntimeException("error on retry #" + retryIndex);
+    }
+    ClassStartReminderRequest request = ClassStartReminderRequest.builder()
+        .targets(Lists.newArrayList(ReceiveTypeEnum.ADMIN.name(), ReceiveTypeEnum.MEMBER.name()))
+        .build();
+    classStartReminderDayTaskApi.createClassStartReminderDayTask(request);
+    return new JSONObject().fluentPut("result", "Succeeded on retry #" + retryIndex);
+  }
+}

server/src/main/resources/application-local.yml

@@ -6,4 +6,5 @@ rpc:
     promotion: http://dev-fit-app.xiaomai5.com/promotion
     cam: http://dev-fit-app.xiaomai5.com/fit-cam
     permcenter: http://dev-fit-app.xiaomai5.com/permcenter
-    schedulecenter: http://dev-fit-app.xiaomai5.com/schedulecenter
\ No newline at end of file
+    schedulecenter: http://dev-fit-app.xiaomai5.com/schedulecenter
+    notify: http://dev-fit-app.xiaomai5.com/fit-notify
\ No newline at end of file