| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.ruoyi.integration.api.model.ErrorMessage; |
|---|
| | | import com.ruoyi.integration.api.model.ParameterSetting; |
|---|
| | | import com.ruoyi.integration.iotda.constant.SendTagConstant; |
|---|
| | | import com.ruoyi.integration.rocket.model.*; |
|---|
| | |
|---|
| | | message.setSource(SendTagConstant.END_CHARGE); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.END_CHARGE, SendTagConstant.END_CHARGE, message); |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 错误报文 |
|---|
| | | */ |
|---|
| | | public SendResult errorMessageMessage(ErrorMessageMessage message) { |
|---|
| | | // 设置业务key |
|---|
| | | message.setKey(UUID.randomUUID().toString()); |
|---|
| | | // 设置消息来源，便于查询 |
|---|
| | | message.setSource(SendTagConstant.ERROR_MESSAGE); |
|---|
| | | return rocketMQEnhanceTemplate.send(TOPIC+SendTagConstant.ERROR_MESSAGE, SendTagConstant.ERROR_MESSAGE, message); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 计费模型验证请求 |
|---|
