1.消息体修改回退

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/SysMessageService.java

@@ -32,9 +32,6 @@ public interface SysMessageService extends BaseService<Long, SysMessage> {
 			Integer readStatus, String url,String jpushType, Object... args);
 
 
-	void batchSendMessage(MessageSender messageSender, MessageTypeEnum type, Map<Long, String> receivers, Date triggerTime, Integer readStatus,
-						  String url, String jpushType, String title, Object... args);
-
 	public void batchSendMessage(MessageSender messageSender, String title, String content, Map<Long, String> receivers, Date triggerTime,
 								 Integer readStatus, String url, String jpushType, Object... args);
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/SysMessageServiceImpl.java

@@ -132,12 +132,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 
 	@Override
 	public void batchSendMessage(MessageSender messageSender, MessageTypeEnum type, Map<Long, String> receivers, Date triggerTime, Integer readStatus,
-								 String url, String jpushType, Object... args) {
-		batchSendMessage(messageSender, type, receivers, triggerTime, readStatus, url, jpushType, null, args);
-	}
-	@Override
-	public void batchSendMessage(MessageSender messageSender, MessageTypeEnum type, Map<Long, String> receivers, Date triggerTime, Integer readStatus,
-			String url,String jpushType,String title, Object... args) {
+								 String url,String jpushType, Object... args) {
 		LOGGER.info("batchSendMessage msgSender {}, type {}, receivers {} ", messageSender, type, receivers);
 		if (receivers == null || receivers.size() == 0) {
 			LOGGER.error("接收地址不能为空");
@@ -151,10 +146,10 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 		if(messageSender.getSendMode().equals(MessageSender.JIGUANG.getSendMode())) {
 			tos= new String[receivers.size()];
 			tos = receivers.entrySet()
-						   .stream()
-						   .map(longStringEntry -> String.valueOf(longStringEntry.getKey()))
-						   .collect(Collectors.toList())
-						   .toArray(tos);
+					.stream()
+					.map(longStringEntry -> String.valueOf(longStringEntry.getKey()))
+					.collect(Collectors.toList())
+					.toArray(tos);
 		} else {
 			tos = receivers.values().toArray(new String[receivers.size()]);
 		}
@@ -168,17 +163,13 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 		Date date = new Date();
 		SendStatusEnum status = SendStatusEnum.WAIT;
 		String errorMsg = null;
-		String msgTitle = title;
-		if(StringUtils.isEmpty(msgTitle)){
-			msgTitle = messageConfig.getDescription();
-		}
 		// 立即发送
 		if (triggerTime == null || date.after(triggerTime)) {
 			status = SendStatusEnum.SENDING;
 			try {
 				if (isSendRemoteMessage(messageSender)) {
-					errorMsg = messageSenderPluginContext.batchSend(messageSender, msgTitle,
-														 MessageFormatter.arrayFormat(messageConfig.getContent(), args), tos, url,jpushType,"default",null);
+					errorMsg = messageSenderPluginContext.batchSend(messageSender, messageConfig.getDescription(),
+							MessageFormatter.arrayFormat(messageConfig.getContent(), args), tos, url,jpushType,"default",null);
 					if (StringUtils.isEmpty(errorMsg)) {
 						status = SendStatusEnum.SUCCESSED;
 					}  else {
@@ -198,10 +189,10 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 		} else if (messageSender.getSendMode().equals("EMAIL")) {
 			mode = MessageSendMode.EMAIL;
 		}
-        if (ClientEnum.TENANT_STUDENT.getCode().equals(jpushType)) {
-            jpushType = ClientEnum.STUDENT.getCode();
-        }
-		addMessage(receivers, title, MessageFormatter.arrayFormat(messageConfig.getContent(), args), triggerTime, mode, status, errorMsg, readStatus,
+		if (ClientEnum.TENANT_STUDENT.getCode().equals(jpushType)) {
+			jpushType = ClientEnum.STUDENT.getCode();
+		}
+		addMessage(receivers, messageConfig.getDescription(), MessageFormatter.arrayFormat(messageConfig.getContent(), args), triggerTime, mode, status, errorMsg, readStatus,
 				url, messageConfig.getGroup(),jpushType,messageConfig.getId());
 	}