修改代码

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/OrderApplication.java

@@ -12,9 +12,8 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication(scanBasePackages = {
         "com.xxfc.platform",
-        "com.github.wxiaoqi.security.common.handler"
-//        ,
-//        "com.github.wxiaoqi.security.common.log"
+        "com.github.wxiaoqi.security.common.handler",
+        "com.github.wxiaoqi.security.common.log"
 })
 @EnableDiscoveryClient
 @EnableScheduling

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/BaseOrderBiz.java

@@ -435,24 +435,27 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper, BaseOrder> {
     private void sendQueue(OrderMQDTO orderMQDTO, Integer sign) {
         try {
             orderMQDTO.setSign(sign);
-            SendMsgDTO sendMsgDTO = new SendMsgDTO(){{
-                setExchange(ORDER_TOPIC);
-            }};
-            //sendMsgDTO.setJson(JSONUtil.toJsonStr(orderMQDTO));
+//            SendMsgDTO sendMsgDTO = new SendMsgDTO(){{
+//                setExchange(ORDER_TOPIC);
+//            }};
+//            sendMsgDTO.setJson(JSONUtil.toJsonStr(orderMQDTO));
             switch (sign) {
                 case 2:
-                    sendMsgDTO.setRoutKey(KEY_ORDER_CANCEL);
+//                    sendMsgDTO.setRoutKey(KEY_ORDER_CANCEL);
+                    mqSenderFeign.sendMessage(ORDER_TOPIC, KEY_ORDER_CANCEL, JSONUtil.toJsonStr(orderMQDTO));
                     break;
                 case 4:
-                    sendMsgDTO.setRoutKey(KEY_ORDER_PAY);
+//                    sendMsgDTO.setRoutKey(KEY_ORDER_PAY);
+                    mqSenderFeign.sendMessage(ORDER_TOPIC, KEY_ORDER_PAY, JSONUtil.toJsonStr(orderMQDTO));
                     break;
                 case 6:
-                    sendMsgDTO.setRoutKey(KEY_ORDER_FINLISH);
+//                    sendMsgDTO.setRoutKey(KEY_ORDER_FINLISH);
+                    mqSenderFeign.sendMessage(ORDER_TOPIC, KEY_ORDER_FINLISH, JSONUtil.toJsonStr(orderMQDTO));
                     break;
                 default:
                     break;
             }
-            mqSenderFeign.postSendMessage(BeanUtil.beanToMap(sendMsgDTO, Boolean.FALSE, Boolean.TRUE));
+//            mqSenderFeign.postSendMessage(BeanUtil.beanToMap(sendMsgDTO, Boolean.FALSE, Boolean.TRUE));
         } catch (Exception e) {
             log.error(e.getMessage(), e);
         }