Joburgess 5 years ago
parent
commit
385b745b11

+ 14 - 0
edu-auth/edu-auth-api/src/main/java/com/keao/edu/auth/api/entity/SysMessageParams.java

@@ -29,6 +29,20 @@ public class SysMessageParams {
 
     private Object[] args;
 
+    public SysMessageParams() {
+    }
+
+    public SysMessageParams(MessageSenderPluginContext.MessageSender messageSender, MessageTypeEnum messageType, Map<Integer, String> receivers, Date triggerTime, Integer readStatus, String url, String jpushType, Object... args) {
+        this.messageSender = messageSender;
+        this.messageType = messageType;
+        this.receivers = receivers;
+        this.triggerTime = triggerTime;
+        this.readStatus = readStatus;
+        this.url = url;
+        this.jpushType = jpushType;
+        this.args = args;
+    }
+
     public MessageSenderPluginContext.MessageSender getMessageSender() {
         return messageSender;
     }

+ 2 - 2
edu-auth/edu-auth-server/src/main/java/com/keao/edu/auth/service/SysMessageService.java

@@ -70,7 +70,7 @@ public interface SysMessageService extends BaseService<Long, SysMessage> {
 	 * @return
 	 */
 	public void batchSendMessage(MessageSender messageSender, MessageTypeEnum messageType, Map<Integer, String> receivers, Date triggerTime,
-                                 Integer readStatus, String url, String jpushType, Object... args);
+                                 Integer readStatus, String url, String jpushType, Object[] args);
 
 	/**
 	 * 发送消息
@@ -150,4 +150,4 @@ public interface SysMessageService extends BaseService<Long, SysMessage> {
 	 * @param content
 	 */
 	void sendNoAuthPrivateMessage(String sender, String receiver, String content);
-}
+}

+ 2 - 2
edu-auth/edu-auth-server/src/main/java/com/keao/edu/auth/service/impl/SysMessageServiceImpl.java

@@ -272,7 +272,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 	@Override
 	@Async
 	public void batchSendMessage(MessageSender messageSender, MessageTypeEnum type, Map<Integer, String> receivers, Date triggerTime, Integer readStatus,
-								 String url, String jpushType, Object... args) {
+								 String url, String jpushType, Object[] args) {
 
 		if (receivers == null || receivers.size() == 0) {
 			throw new BizException("接收地址不能为空");
@@ -364,7 +364,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 		}
 		Map<Integer, String> receivers = new HashMap<>(1);
 		receivers.put(userId, receiver);
-		batchSendMessage(messageSender, messageType, receivers, null, 1, "","", code);
+		batchSendMessage(messageSender, messageType, receivers, null, 1, "","", new Object[]{code});
 		redisCache.put(key, code + "", CODE_EXPIRE);
 		redisCache.put(key1, code + "", CODE_INTERVAL_TIME);
 		return true;

+ 2 - 1
edu-auth/edu-auth-server/src/main/java/com/keao/edu/auth/web/controller/SysMessageController.java

@@ -30,7 +30,8 @@ public class SysMessageController extends BaseController {
     @PostMapping(value = "/batchSendMessage")
     public void batchSendMessage(@RequestBody SysMessageParams sysMessageParams){
         sysMessageService.batchSendMessage(sysMessageParams.getMessageSender(), sysMessageParams.getMessageType(), sysMessageParams.getReceivers(),
-                sysMessageParams.getTriggerTime(), sysMessageParams.getReadStatus(), sysMessageParams.getUrl(), sysMessageParams.getJpushType(), sysMessageParams.getArgs());
+                sysMessageParams.getTriggerTime(), sysMessageParams.getReadStatus(), sysMessageParams.getUrl(), sysMessageParams.getJpushType(),
+                sysMessageParams.getArgs());
     }
 
 }

+ 2 - 6
edu-user/edu-user-server/src/main/java/com/keao/edu/user/service/impl/ExamOrganizationRelationServiceImpl.java

@@ -163,12 +163,8 @@ public class ExamOrganizationRelationServiceImpl extends BaseServiceImpl<Long, E
 			Map<Integer, String> userPhoneMap = new HashMap<>();
 			userPhoneMap.put(examOrgan.getOrganId(), student.getPhone());
 
-			SysMessageParams sysMessageParams=new SysMessageParams();
-			sysMessageParams.setMessageSender(MessageSenderPluginContext.MessageSender.YIMEI);
-			sysMessageParams.setMessageType(MessageTypeEnum.EXAM_REGISTRATION_URL_PUSH);
-			sysMessageParams.setReceivers(userPhoneMap);
-			sysMessageParams.setReadStatus(0);
-			sysMessageParams.setArgs(new Object[]{registShortUrl});
+			SysMessageParams sysMessageParams=new SysMessageParams(MessageSenderPluginContext.MessageSender.YIMEI, MessageTypeEnum.EXAM_REGISTRATION_URL_PUSH,
+					userPhoneMap, null, 0, null, null, registShortUrl);
 			sysMessageFeignService.batchSendMessage(sysMessageParams);
 		}
 

+ 1 - 1
edu-util/src/main/java/com/keao/edu/util/string/MessageFormatter.java

@@ -15,7 +15,7 @@ final public class MessageFormatter {
 	 * @param argArray
 	 * @return String
 	 */
-	final public static String arrayFormat(String messagePattern, Object... argArray) {
+	final public static String arrayFormat(String messagePattern, Object[] argArray) {
 		if (messagePattern == null) {
 			return "";
 		}