消息优化

cloud-research-service/src/main/java/com/yizhi/research/application/util/ResearchEvenSendMessage.java

@@ -103,7 +103,7 @@ public class ResearchEvenSendMessage {
         if (null != remindVo && null != remindVo.getIsCopy() && remindVo.getIsCopy()) {
             vo.setIsCopy(remindVo.getIsCopy());
             vo.setOldRelationId(remindVo.getOldRelationId());
-            publicSendMessageClient.processBizEvent(  new EventWrapper<MessageRemindVo>(null, vo));
+            publicSendMessageClient.processBizEvent(vo);
             logger.error("发送复制消息成功=====================");
             return;
         }
@@ -116,7 +116,7 @@ public class ResearchEvenSendMessage {
         }
         if (null != remindVo.getHasDeleted() && remindVo.getHasDeleted()) {
             vo.setHasDeleted(remindVo.getHasDeleted());
-            publicSendMessageClient.processBizEvent(  new EventWrapper<MessageRemindVo>(null, vo));
+            publicSendMessageClient.processBizEvent(vo);
             logger.error("发送删除消息成功=====================");
         } else {
             //修改调研的状态
@@ -124,7 +124,7 @@ public class ResearchEvenSendMessage {
                 //1 为消息业务可发送状态  0 则不行
                 vo.setTaskStatusUpdate(true);
                 vo.setTaskStatus(research.getState() == ResearchState.RELEASED.getValue() ? 1 : 0);
-                publicSendMessageClient.processBizEvent(  new EventWrapper<MessageRemindVo>(null, vo));
+                publicSendMessageClient.processBizEvent(vo);
                 logger.info("发送修改业务状态消息成功=====================");
                 return;
             }
@@ -157,7 +157,7 @@ public class ResearchEvenSendMessage {
                             logger.info("相关参数缺失！！!!!");
                             return;
                         }
-                        publicSendMessageClient.processBizEvent(  new EventWrapper<MessageRemindVo>(null, vo));
+                        publicSendMessageClient.processBizEvent(vo);
                         logger.info("发送消息成功=====================");
                     } catch (Exception e) {
                         e.printStackTrace();