|
|
@@ -113,11 +113,11 @@ public class MiniProgramSubTask {
|
|
|
*/
|
|
|
@QuartzRunnable(name="小程序直播订阅通知")
|
|
|
public void notifyMiniLiveAppSub(){
|
|
|
- log.info("小程序订阅通知定时任务");
|
|
|
+ log.info("小程序直播订阅通知定时任务");
|
|
|
// 先获取所有可用待处理任务
|
|
|
List<FsMiniprogramSubNotifyTask> pendingData = notifyTaskMapper.selectLivePendingData();
|
|
|
if(CollectionUtils.isEmpty(pendingData)){
|
|
|
- log.info("小程序订阅通知定时任务, 无待处理数据");
|
|
|
+ log.info("小程序直播阅通知定时任务, 无待处理数据");
|
|
|
return;
|
|
|
}
|
|
|
LocalDateTime now = LocalDateTime.now();
|
|
|
@@ -164,7 +164,7 @@ public class MiniProgramSubTask {
|
|
|
pendingDatum.setStatus(MiniAppNotifyTaskStatusEnum.FAILED.getValue());
|
|
|
pendingDatum.setErrorMessage(ExceptionUtils.getStackTrace(e));
|
|
|
pendingDatum.setRetryCount(pendingDatum.getRetryCount() +1);
|
|
|
- log.error("小程序订阅通知定时任务异常: {}", ExceptionUtils.getStackTrace(e));
|
|
|
+ log.error("小程序直播订阅通知定时任务异常: {}", ExceptionUtils.getStackTrace(e));
|
|
|
}
|
|
|
}
|
|
|
|