|
|
@@ -78,7 +78,7 @@ public class IotAlarmRuleServiceImpl extends ServiceImpl<IotAlarmRuleMapper, Iot
|
|
|
jsb.put("ruleExpresses", ruleExpresses);
|
|
|
|
|
|
final String topic = TopicTypeEnums.formatUrl(TopicTypeEnums.PRODUCT_SERVICE_INVOKE.getUrl(), ProductEnums.DETECTION_HOST.getProductName().get(0), ProductEnums.DETECTION_HOST.getProductName().get(1));
|
|
|
- final WebsocketResult result = WebsocketResult.invokeHostServer(topic, new com.alibaba.fastjson.JSONObject(), WebSocketConstants.ALARM_RULE, jsb);
|
|
|
+ final WebsocketResult result = WebsocketResult.invokeHostServer(topic, new com.alibaba.fastjson.JSONObject(), WebSocketConstants.ALARM_RULE_TO_HOST, jsb);
|
|
|
|
|
|
|
|
|
final IotWebsocketMsg saveMsg = websocketMsgService.sendAndSaveMsg(iotAlarmRule.getIotCode(), result);
|