| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.io.File; |
| | | import java.io.FileOutputStream; |
| | | import java.io.FileWriter; |
| | | import java.io.IOException; |
| | | import java.math.BigDecimal; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Objects; |
| | | import java.util.*; |
| | | |
| | | /** |
| | | * iotda消息监听 |
| | |
| | | String productId = header.getString("product_id"); // 产品id |
| | | String service_id = content.getString("service_id"); |
| | | log.info("服务id:{}",service_id); |
| | | // 写入文件 |
| | | FileWriter writer = new FileWriter("D:/sample.txt",true); |
| | | writer.write("接收到消息中转:"+jsonObject+"\n"); |
| | | writer.write("服务id:"+service_id+"\n"); |
| | | writer.close(); |
| | | SendResult sendResult; |
| | | // 设备消息下发 |
| | | String result; |