补充提交

src/main/java/com/yunfeiyun/agmp/iotm/mq/service/AgmpTosMsgService.java

@@ -0,0 +1,63 @@
+package com.yunfeiyun.agmp.iotm.mq.service;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.yunfeiyun.agmp.common.framework.mq.rabbitmq.enums.TosActionEnums;
+import com.yunfeiyun.agmp.iot.common.domain.IotDevice;
+import com.yunfeiyun.agmp.iotm.mq.provider.TosMqProviderService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.stereotype.Service;
+
+
+/**
+ * 往Tos发送：单个租户
+ * 覆盖面
+ * 1. 门户修改菜单，同步到tos
+ * 2. 门户修改平台信息，同步到tos
+ * 3. 门户修改账号中心信息，同步tos
+ *
+ * @author zhangn
+ */
+@Service
+@ConditionalOnBean(name = "tosMqConfig")
+public class AgmpTosMsgService {
+
+    @Autowired
+    private TosMqProviderService mqService;
+
+    /**
+     * 门户修改菜单，同步到tos ok
+     *
+     * @param tid
+     * @param data
+     */
+    public void sendIotDeviceInsertMsg(IotDevice iotDevice) {
+        mqService.sendToTos( TosActionEnums.IOT_DEVICE_CREATE, iotDevice, "【AGMP】to【Tos】物联网新增设备，同步到tos");
+
+    }
+
+    /**
+     * 门户修改平台信息，同步到tos  ok
+     *
+     * @param tid
+     * @param data
+     */
+    public void sendIotDeviceUpdateMsg(IotDevice iotDevice) {
+        mqService.sendToTos( TosActionEnums.IOT_DEVICE_UPDATE, iotDevice, "【AGMP】to【Tos】物联网编辑设备，同步到tos");
+
+    }
+
+    /**
+     * 门户修改账号中心信息，同步tos  ok
+     *
+     * @param tid
+     * @param data
+     */
+    public void sendIotDeviceDeleteMsg(IotDevice iotDevice) {
+        mqService.sendToTos( TosActionEnums.IOT_DEVICE_DELETE, iotDevice, "【AGMP】to【Tos】物联网删除设备，同步到tos");
+    }
+
+
+}
+
+