diff --git a/hzims-service/inspect/src/main/java/com/hnac/hzinfo/inspect/task/schedule/TaskSchedule.java b/hzims-service/inspect/src/main/java/com/hnac/hzinfo/inspect/task/schedule/TaskSchedule.java index f9dcd76..8758e16 100644 --- a/hzims-service/inspect/src/main/java/com/hnac/hzinfo/inspect/task/schedule/TaskSchedule.java +++ b/hzims-service/inspect/src/main/java/com/hnac/hzinfo/inspect/task/schedule/TaskSchedule.java @@ -94,7 +94,7 @@ public class TaskSchedule { .taskId(taskEntity.getId()) .businessKey("巡检任务结束提醒") .businessClassify(MessageConstants.BusinessClassifyEnum.INSPECT.getKey()) - .content("您有一条未执行的任务【"+taskEntity.getPlanName()+"】将于"+ DateUtil.format(taskEntity.getPlanEndTime(),DateUtil.PATTERN_DATETIME)+"截止,请及时处理!") + .content("您有巡检工作任务("+taskEntity.getPlanName()+")即将在"+DateUtil.format(taskEntity.getPlanEndTime(),DateUtil.PATTERN_DATETIME)+"结束,请及时处理。") .subject("巡检任务结束提醒") .pusher(taskEntity.getUserId().toString()) .createUser(taskEntity.getCreateUser()) @@ -111,7 +111,7 @@ public class TaskSchedule { appMessage.setDeptId(taskEntity.getCreateDept()); appMessage.setBusinessKey("巡检任务结束提醒"); appMessage.setBusinessClassify(MessageConstants.BusinessClassifyEnum.INSPECT.getKey()); - appMessage.setContent("您有一条未执行的任务【"+taskEntity.getPlanName()+"】将于"+ DateUtil.format(taskEntity.getPlanEndTime(),DateUtil.PATTERN_DATETIME)+"截止,请及时处理!"); + appMessage.setContent("您有巡检工作任务("+taskEntity.getPlanName()+")即将在"+DateUtil.format(taskEntity.getPlanEndTime(),DateUtil.PATTERN_DATETIME)+"结束,请及时处理。"); appMessage.setTaskId(taskEntity.getId()); appMessage.setSubject("巡检任务结束提醒"); appMessage.setUserIds(taskEntity.getUserId().toString()); diff --git a/hzims-service/message/src/main/java/com/hnac/hzims/message/fegin/MessageClient.java b/hzims-service/message/src/main/java/com/hnac/hzims/message/fegin/MessageClient.java index cec9f41..c718ab3 100644 --- a/hzims-service/message/src/main/java/com/hnac/hzims/message/fegin/MessageClient.java +++ b/hzims-service/message/src/main/java/com/hnac/hzims/message/fegin/MessageClient.java @@ -116,13 +116,13 @@ public class MessageClient extends BladeController implements IMessageClient{ if(Func.isNotEmpty(template.getType())) { Func.toStrList(",",template.getType()).forEach(type -> { MessagePushRecordEntity entity = BeanUtil.copy(template,MessagePushRecordEntity.class); - entity.setDeptName(Func.isNotEmpty(entity.getDeptName()) ? entity.getDeptName() : this.getDeptNameById(entity.getDeptId())); entity.setId(null); entity.setType(type); entity.setTaskId(request.getTaskId()); entity.setMessageId(messageId); entity.setTemplateId(request.getTemplateId()); entity.setDeptId(request.getDeptId()); + entity.setDeptName(Func.isNotEmpty(entity.getDeptName()) ? entity.getDeptName() : this.getDeptNameById(entity.getDeptId())); entity.setCreateUser(request.getCreateUser()); entity.setResourceCode(request.getResourceCode()); entity.setCreateDept(request.getDeptId()); diff --git a/hzims-service/message/src/main/java/com/hnac/hzims/message/schedule/MessagePushSchedule.java b/hzims-service/message/src/main/java/com/hnac/hzims/message/schedule/MessagePushSchedule.java index f1024a3..fcf8d24 100644 --- a/hzims-service/message/src/main/java/com/hnac/hzims/message/schedule/MessagePushSchedule.java +++ b/hzims-service/message/src/main/java/com/hnac/hzims/message/schedule/MessagePushSchedule.java @@ -133,6 +133,7 @@ public class MessagePushSchedule { MessagePushRecordEntity request = records.get(0); // 完善推送内容 request.setContent(this.getPushContent(type,records)); + XxlJobLogger.log("推送类型为:"+type+",消息推送内容为:"+request.getContent()); if(MessageConstants.SMS_PUSH.equals(type)) { request.setSmsParam(request.getContent()); } @@ -159,7 +160,7 @@ public class MessagePushSchedule { * @return java.lang.String **/ private String getPushContent(String type,List list) { - if(MessageConstants.APP_PUSH.equals(type)) { + if(MessageConstants.APP_PUSH.equals(type) || MessageConstants.WS_PUSH.equals(type)) { return list.stream().map(MessagePushRecordEntity::getContent).collect(Collectors.joining("\r\n")); } else if(MessageConstants.SMS_PUSH.equals(type)) { diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/StationServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/StationServiceImpl.java index 2f778c7..df67928 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/StationServiceImpl.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/StationServiceImpl.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.google.common.collect.Lists; import com.hnac.hzims.common.service.UserAuthDataService; import com.hnac.hzims.fdp.feign.IQuestionClient; import com.hnac.hzims.hzimsweather.response.air.Station; @@ -152,8 +153,8 @@ public class StationServiceImpl extends BaseServiceImpl 5.0.1.RELEASE - 5.0.1-SNAPSHOT + 5.0.2-SNAPSHOT UTF-8 1.8