Commit fa696aab by xiezhongtao

上课提醒

parent b6bc4f6b
......@@ -67,21 +67,7 @@
<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 ======================= -->
......
......@@ -56,18 +56,6 @@
<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>
</dependency>
......
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);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment