消息优化

cloud-assignment/src/main/java/com/yizhi/application/util/AssignmentEvenSendMessage.java

@@ -110,12 +110,12 @@ public class AssignmentEvenSendMessage {
 
         if (remindVo.getHasDeleted()) {
             vo.setHasDeleted(remindVo.getHasDeleted());
-            publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
+            publicSendMessageClient.processBizEvent(vo);
         } else {
             if (remindVo.getTaskStatusUpdate()) {
                 //1 为消息业务可发送状态  0 则不行
                 vo.setTaskStatusUpdate(remindVo.getTaskStatusUpdate());
-                publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
+                publicSendMessageClient.processBizEvent(vo);
                 logger.info("发送修改业务状态消息成功=====================");
                 return;
             }
@@ -146,7 +146,7 @@ public class AssignmentEvenSendMessage {
                         return;
                     }
                     try {
-                        publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
+                        publicSendMessageClient.processBizEvent(vo);
                         logger.info("发送消息成功=====================");
                     } catch (Exception e) {
                         e.printStackTrace();