| | |
|---|
| | | package com.ruoyi.integration.iotda.utils.produce; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.huaweicloud.sdk.core.exception.ConnectionException; |
|---|
| | | import com.huaweicloud.sdk.core.exception.RequestTimeoutException; |
|---|
| | | import com.huaweicloud.sdk.core.exception.ServiceResponseException; |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IotBuilder iotBuilder; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IotDAConfig config; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 设备消息下发 |
|---|
| | | * @param deviceId 设备id |
|---|
| | | * @param name 消息名称 |
|---|
| | | * @param message 消息内容 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @PostMapping("/sendMessage") |
|---|
| | | public String sendMessage(String deviceId,String name,String message){ |
|---|
| | | public String sendMessage(String code, String name, JSONObject message){ |
|---|
| | | CreateMessageRequest request = new CreateMessageRequest(); |
|---|
| | | request.withDeviceId(deviceId); |
|---|
| | | System.err.println(code); |
|---|
| | | System.err.println(JSONObject.toJSONString(config)); |
|---|
| | | if(config.getTest() && code.equals(config.getTestDriverCode())){ |
|---|
| | | request.withDeviceId(config.getTestDeviceId()); |
|---|
| | | }else{ |
|---|
| | | request.withDeviceId(config.getDeviceId()); |
|---|
| | | } |
|---|
| | | DeviceMessageRequest body = new DeviceMessageRequest(); |
|---|
| | | body.withMessageId(UUID.randomUUID().toString()); |
|---|
| | | body.withName(name); |
|---|
