| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.ruoyi.integration.api.model.ParameterSetting; |
|---|
| | | import com.ruoyi.integration.iotda.constant.SendTagConstant; |
|---|
| | | import com.ruoyi.integration.rocket.model.*; |
|---|
| | | import com.ruoyi.integration.rocket.util.RocketMQEnhanceTemplate; |
|---|
| | |
|---|
| | | message.setSource(SendTagConstant.CHARGING_HANDSHAKE); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.CHARGING_HANDSHAKE, SendTagConstant.CHARGING_HANDSHAKE, message); |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 参数设置 |
|---|
| | | */ |
|---|
| | | public SendResult parameterSettingMessage(ParameterSettingMessage message) { |
|---|
| | | // 设置业务key |
|---|
| | | message.setKey(UUID.randomUUID().toString()); |
|---|
| | | // 设置消息来源，便于查询 |
|---|
| | | message.setSource(SendTagConstant.PARAMETER_SETTING); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.PARAMETER_SETTING, SendTagConstant.PARAMETER_SETTING, message); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 充电阶段BMS中止 |
|---|
