|
|
@ -83,7 +83,7 @@ public class MaintenanceTaskRemindHandler { |
|
|
|
request.setCreateUser(taskEntity.getCreateUser()); |
|
|
|
request.setCreateUser(taskEntity.getCreateUser()); |
|
|
|
request.setTenantId(CommonConstant.TENANT_ID); |
|
|
|
request.setTenantId(CommonConstant.TENANT_ID); |
|
|
|
R<Boolean> sendFlag = messageClient.sendAppAndWsMsgByUsers(request); |
|
|
|
R<Boolean> sendFlag = messageClient.sendAppAndWsMsgByUsers(request); |
|
|
|
if(!sendFlag.isSuccess() || sendFlag.getData() == null) { |
|
|
|
if(!sendFlag.isSuccess()) { |
|
|
|
XxlJobLogger.log(taskEntity.getId() +"执行人消息推送失败!"); |
|
|
|
XxlJobLogger.log(taskEntity.getId() +"执行人消息推送失败!"); |
|
|
|
} |
|
|
|
} |
|
|
|
// 任务执行人发送短信
|
|
|
|
// 任务执行人发送短信
|
|
|
@ -92,7 +92,7 @@ public class MaintenanceTaskRemindHandler { |
|
|
|
request.setUserIds(listR.getData().stream().map(User::getId).map(String::valueOf).collect(Collectors.joining(","))); |
|
|
|
request.setUserIds(listR.getData().stream().map(User::getId).map(String::valueOf).collect(Collectors.joining(","))); |
|
|
|
request.setContent("有一条待执行的日常维护任务【"+taskEntity.getTitle()+"】即将于"+ DateUtil.format(taskEntity.getPlanEndTime(),DateUtil.PATTERN_DATETIME) +"过期,请确认。"); |
|
|
|
request.setContent("有一条待执行的日常维护任务【"+taskEntity.getTitle()+"】即将于"+ DateUtil.format(taskEntity.getPlanEndTime(),DateUtil.PATTERN_DATETIME) +"过期,请确认。"); |
|
|
|
R<Boolean> result = messageClient.sendAppAndWsMsgByUsers(request); |
|
|
|
R<Boolean> result = messageClient.sendAppAndWsMsgByUsers(request); |
|
|
|
if(!result.isSuccess() || result.getData() == null) { |
|
|
|
if(!result.isSuccess()) { |
|
|
|
XxlJobLogger.log(taskEntity.getId() +"执行人消息推送失败!"); |
|
|
|
XxlJobLogger.log(taskEntity.getId() +"执行人消息推送失败!"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|