监管平台bug修改

无关风月

昨天 562fac9ce09621e86ab8707ff270b706576e9821

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

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

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

    /**
     * 充电桩登录认证
@@ -59,6 +59,13 @@
        message.setSource(SendTagConstant.END_CHARGE);
        return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.END_CHARGE, SendTagConstant.END_CHARGE, message);
    }
    public SendResult endChargeMessageJianGuan(EndChargeMessage message) {
        // 设置业务key
        message.setKey(UUID.randomUUID().toString());
        // 设置消息来源，便于查询
        message.setSource(SendTagConstant.END_CHARGE);
        return rocketMQEnhanceTemplate.send(TOPIC_JIANGUAN, SendTagConstant.END_CHARGE, message);
    }
    /**
     * 错误报文
     */