1

src/main/java/com/yunfeiyun/agmp/iots/mq/listener/IotmBaseDataChannelAwareMessageListener.java

@@ -82,15 +82,15 @@ public class IotmBaseDataChannelAwareMessageListener implements ChannelAwareMess
                         connectionManager.deleteDeviceHandle(synGlobalTenantInfoDto.getData().to(IotDevice.class));
                         break;
                     //设备连接信息创建
-                    case DEVICE_COON_CREATE:
+                    case DEVICE_CONN_CREATE:
                         connectionManager.createIotDeviceconnHandle(synGlobalTenantInfoDto.getData().to(IotDeviceconn.class));
                         break;
                     //设备连接信息更新
-                    case DEVICE_COON_UPDATE:
+                    case DEVICE_CONN_UPDATE:
                         connectionManager.editIotDeviceconnHandle(synGlobalTenantInfoDto.getData().to(IotDeviceconn.class));
                         break;
                     //设备连接信息删除
-                    case DEVICE_COON_DELETE:
+                    case DEVICE_CONN_DELETE:
                         connectionManager.deleteIotDeviceconnHandle(synGlobalTenantInfoDto.getData().to(IotDeviceconn.class));
                         break;
                     //更新所有设备信息

src/main/java/com/yunfeiyun/agmp/iots/service/BusinessCoreService.java

@@ -1,7 +1,6 @@
 package com.yunfeiyun.agmp.iots.service;
 
 import com.yunfeiyun.agmp.iots.common.modal.IotDeviceconnResVo;
-import com.yunfeiyun.agmp.iots.common.modal.TosDevicetypeResVo;
 import com.yunfeiyun.agmp.iots.device.mapper.BusinessCoreMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

src/main/resources/mapper/IotDeviceMapper.xml

@@ -528,6 +528,12 @@
             </foreach>
         </where>
     </select>
+    <select id="getDevicesByConectionId" resultType="com.yunfeiyun.agmp.iot.common.domain.IotDevice">
+                select  * from IotDevice where devconnBid=#{connectionId} and devDelstatus='0'
+    </select>
+    <select id="getDeviceCodesByConectionId" resultType="java.lang.String">
+        select  devCode from IotDevice where devconnBid=#{connectionId} and devDelstatus='0'
+    </select>
 </mapper>