Merge branch 'dev' of http://120.76.84.145:10101/gitblit/r/java/mx_charging...

liujie

17 小时以前 0f4459e4201fdc19185b7dd03215871f036acd70

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

@@ -26,6 +26,7 @@
    private RocketMQEnhanceTemplate rocketMQEnhanceTemplate;

    private static final String TOPIC = "charge_";
    private static final String TOPIC_JIANGUAN = "jianguan_";

    /**
     * 充电桩登录认证
@@ -351,7 +352,41 @@
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.CHARGING_MESSAGE);

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

        return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN+SendTagConstant.GUN_STATUS, SendTagConstant.GUN_STATUS, message);
    }
    /**
     * 监管平台推送充电订单信息
     */
    public SendResult orderInfoMessage(ChargingMessage message) {
        // 设置业务key
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.ORDER_INFO);

        return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN+SendTagConstant.ORDER_INFO, SendTagConstant.ORDER_INFO, message);
    }
    /**
     * 监管平台推送充电订单状态
     */
    public SendResult orderStatusMessage(ChargingMessage message) {
        // 设置业务key
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.ORDER_STATUS);

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

}