消息优化

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

@@ -5,11 +5,12 @@ import com.yizhi.assignment.application.vo.MessageTaskRemindVo;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.context.RequestContext;
 import com.yizhi.core.application.event.EventWrapper;
 import com.yizhi.core.application.event.EventWrapper;
 import com.yizhi.core.application.publish.CloudEventPublisher;
 import com.yizhi.core.application.publish.CloudEventPublisher;
+import com.yizhi.core.application.publish.PublicSendMessageClient;
 import com.yizhi.message.application.constans.Constans;
 import com.yizhi.message.application.constans.Constans;
 import com.yizhi.assignment.application.vo.enums.EvenType;
 import com.yizhi.assignment.application.vo.enums.EvenType;
 import com.yizhi.message.application.enums.RelationType;
 import com.yizhi.message.application.enums.RelationType;
-import com.yizhi.message.application.vo.MessageRemindVo;
-import com.yizhi.message.application.vo.TaskVo;
+import com.yizhi.core.application.vo.MessageRemindVo;
+import com.yizhi.core.application.vo.TaskVo;
 import org.apache.commons.lang3.time.DateUtils;
 import org.apache.commons.lang3.time.DateUtils;
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.LoggerFactory;
@@ -27,7 +28,7 @@ public class AssignmentEvenSendMessage {
 
 
 
 
     @Autowired
     @Autowired
-    private CloudEventPublisher cloudEventPublisher;
+    private PublicSendMessageClient publicSendMessageClient;
 
 
     private Logger logger = LoggerFactory.getLogger(AssignmentEvenSendMessage.class);
     private Logger logger = LoggerFactory.getLogger(AssignmentEvenSendMessage.class);
 
 
@@ -69,7 +70,7 @@ public class AssignmentEvenSendMessage {
             vo.setRequestContext(requestContext);
             vo.setRequestContext(requestContext);
             try {
             try {
                 //临时取消触发功能
                 //临时取消触发功能
-//                cloudEventPublisher.publish(Constans.MESSAGE_QUEUE, new EventWrapper<MessageRemindVo>(null, vo));
+//                publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
             } catch (Exception e) {
             } catch (Exception e) {
                 e.printStackTrace();
                 e.printStackTrace();
                 logger.error("发送消息失败=====================", e);
                 logger.error("发送消息失败=====================", e);
@@ -109,12 +110,12 @@ public class AssignmentEvenSendMessage {
 
 
         if (remindVo.getHasDeleted()) {
         if (remindVo.getHasDeleted()) {
             vo.setHasDeleted(remindVo.getHasDeleted());
             vo.setHasDeleted(remindVo.getHasDeleted());
-            cloudEventPublisher.publish(Constans.MESSAGE_QUEUE, new EventWrapper<MessageRemindVo>(null, vo));
+            publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
         } else {
         } else {
             if (remindVo.getTaskStatusUpdate()) {
             if (remindVo.getTaskStatusUpdate()) {
                 //1 为消息业务可发送状态  0 则不行
                 //1 为消息业务可发送状态  0 则不行
                 vo.setTaskStatusUpdate(remindVo.getTaskStatusUpdate());
                 vo.setTaskStatusUpdate(remindVo.getTaskStatusUpdate());
-                cloudEventPublisher.publish(Constans.MESSAGE_QUEUE, new EventWrapper<MessageRemindVo>(null, vo));
+                publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
                 logger.info("发送修改业务状态消息成功=====================");
                 logger.info("发送修改业务状态消息成功=====================");
                 return;
                 return;
             }
             }
@@ -127,10 +128,10 @@ public class AssignmentEvenSendMessage {
                     vo.setMessageId(remindVo.getMessageId());
                     vo.setMessageId(remindVo.getMessageId());
                     vo.setIsChangge(remindVo.getIsChangge());
                     vo.setIsChangge(remindVo.getIsChangge());
                     List<MessageTaskRemindVo> m=  remindVo.getMessageTaskRemindVos();
                     List<MessageTaskRemindVo> m=  remindVo.getMessageTaskRemindVos();
-                    List<com.yizhi.message.application.vo.MessageTaskRemindVo> m2=new ArrayList<>();
+                    List<com.yizhi.core.application.vo.MessageTaskRemindVo> m2=new ArrayList<>();
                     for (MessageTaskRemindVo m1:m
                     for (MessageTaskRemindVo m1:m
                     ) {
                     ) {
-                        com.yizhi.message.application.vo.MessageTaskRemindVo mx=new com.yizhi.message.application.vo.MessageTaskRemindVo();
+                        com.yizhi.core.application.vo.MessageTaskRemindVo mx=new com.yizhi.core.application.vo.MessageTaskRemindVo();
                         BeanUtils.copyProperties(m1,mx);
                         BeanUtils.copyProperties(m1,mx);
                         m2.add(mx);
                         m2.add(mx);
                     }
                     }
@@ -145,7 +146,7 @@ public class AssignmentEvenSendMessage {
                         return;
                         return;
                     }
                     }
                     try {
                     try {
-                        cloudEventPublisher.publish(Constans.MESSAGE_QUEUE, new EventWrapper<MessageRemindVo>(null, vo));
+                        publicSendMessageClient.processBizEvent(new EventWrapper<MessageRemindVo>(null, vo));
                         logger.info("发送消息成功=====================");
                         logger.info("发送消息成功=====================");
                     } catch (Exception e) {
                     } catch (Exception e) {
                         e.printStackTrace();
                         e.printStackTrace();