| | |
|---|
| | | Integer finalIndex = index; |
|---|
| | | String catalogXmlContent = getCatalogXmlContentForCatalogAddOrUpdate(parentPlatform, channels, |
|---|
| | | deviceChannels.size(), type, subscribeInfo); |
|---|
| | | System.out.println(catalogXmlContent); |
|---|
| | | logger.info("[发送NOTIFY通知]类型： {}，发送数量： {}", type, channels.size()); |
|---|
| | | sendNotify(parentPlatform, catalogXmlContent, subscribeInfo, eventResult -> { |
|---|
| | | logger.error("发送NOTIFY通知消息失败。错误：{} {}", eventResult.statusCode, eventResult.msg); |
|---|
| | |
|---|
| | | |
|---|
| | | private String getCatalogXmlContentForCatalogAddOrUpdate(ParentPlatform parentPlatform, List<DeviceChannel> channels, int sumNum, String type, SubscribeInfo subscribeInfo) { |
|---|
| | | StringBuffer catalogXml = new StringBuffer(600); |
|---|
| | | |
|---|
| | | String characterSet = parentPlatform.getCharacterSet(); |
|---|
| | | catalogXml.append("<?xml version=\"1.0\" encoding=\"" + characterSet + "\"?>\r\n") |
|---|
| | | .append("<Notify>\r\n") |
|---|
