修改bug和将roacktmq连接方式切换为直连方式

Pu Zhibing

7 天以前 b4bfd886af0460ae84b2d70233c2a77866930a46

 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/produce/EnhanceProduce.java

@@ -344,17 +344,17 @@
        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.SECURITY_DETECTION, SendTagConstant.SECURITY_DETECTION, message);
    }

    /**
     * 充电桩登录认证
     */
    public SendResult chargingMessage(ChargingMessage message) {
        // 设置业务key
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.CHARGING_MESSAGE);

        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CHARGING_MESSAGE, SendTagConstant.CHARGING_MESSAGE, message);
    }
//    /**
//     * 充电桩登录认证
//     */
//    public SendResult chargingMessage(ChargingMessage message) {
//        // 设置业务key
//        message.setKey(UUID.randomUUID().toString());
//        // 设置消息来源，便于查询
//        message.setSource(SendTagConstant.CHARGING_MESSAGE);
//
//        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CHARGING_MESSAGE, SendTagConstant.CHARGING_MESSAGE, message);
//    }
    /**
     * 监管平台推送充电设备接口状态
     */
@@ -363,8 +363,8 @@
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.GUN_STATUS);

        return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN+SendTagConstant.GUN_STATUS, SendTagConstant.GUN_STATUS, message);
        rocketMQEnhanceTemplate.sendAsynchronous(TOPIC_JIANGUAN+SendTagConstant.GUN_STATUS, SendTagConstant.GUN_STATUS, message);
        return null;
    }
    /**
     * 监管平台推送充电订单信息
@@ -374,8 +374,8 @@
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.ORDER_INFO);

        return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN+SendTagConstant.ORDER_INFO, SendTagConstant.ORDER_INFO, message);
        rocketMQEnhanceTemplate.sendAsynchronous(TOPIC_JIANGUAN+SendTagConstant.ORDER_INFO, SendTagConstant.ORDER_INFO, message);
        return null;
    }
    /**
     * 监管平台推送充电订单状态
@@ -385,8 +385,8 @@
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.ORDER_STATUS);

        return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN+SendTagConstant.ORDER_STATUS, SendTagConstant.ORDER_STATUS, message);
        rocketMQEnhanceTemplate.sendAsynchronous(TOPIC_JIANGUAN+SendTagConstant.ORDER_STATUS, SendTagConstant.ORDER_STATUS, message);
        return null;
    }

}