通道查询

src/main/java/com/genersoft/iot/vmp/extend/controller/ExtendDeviceController.java

@@ -15,6 +15,7 @@ import org.springframework.web.context.request.async.DeferredResult;
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import java.util.List;
+import java.util.Map;
 
 @RestController
 @RequestMapping(value = "/internal/device")
@@ -40,11 +41,17 @@ public class ExtendDeviceController {
         return deviceService.page(dto);
     }
 
+    @RequestMapping("/getDevices")
+    public Map<String,ExtendDevice> getDevices(@RequestParam List<String> deviceIds) {
+        return deviceService.getDevices(deviceIds);
+    }
+
     @RequestMapping("/deviceChannel")
     public List<ExtendDeviceChannel> deviceChannel(@RequestParam String deviceId) {
         return deviceChannelService.deviceChannel(deviceId);
     }
 
+
     @RequestMapping("/start")
     public DeferredResult<WVPResult<StreamContent>> start(HttpServletRequest request, @RequestParam String deviceId,
                                                           @RequestParam String channelId) {

src/main/java/com/genersoft/iot/vmp/extend/service/ExtendDeviceService.java

@@ -9,8 +9,11 @@ import com.genersoft.iot.vmp.extend.mapper.ExtendDeviceMapper;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestParam;
 
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 @Service
 public class ExtendDeviceService extends ServiceImpl<ExtendDeviceMapper, ExtendDevice> {
@@ -30,4 +33,16 @@ public class ExtendDeviceService extends ServiceImpl<ExtendDeviceMapper, ExtendD
         return new PageInfo<>(rsList);
     }
 
+    public Map<String,ExtendDevice> getDevices(List<String> deviceIds) {
+        LambdaQueryWrapper<ExtendDevice> lqw = new LambdaQueryWrapper<>();
+        lqw.in(ExtendDevice :: getDeviceId,deviceIds);
+        List<ExtendDevice> list = list(lqw);
+        Map<String,ExtendDevice> result = new HashMap<>();
+        for(ExtendDevice temp : list) {
+            result.put(temp.getDeviceId(),temp);
+        }
+        return result;
+
+    }
+
 }