搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiaoQQya
2023-03-20 713aa00acc398e44cb2a59e4f5c3f55b4e0784d8 
 src/main/java/com/genersoft/iot/vmp/web/gb28181/ApiDeviceController.java


@@ -1,23 +1,28 @@


package com.genersoft.iot.vmp.web.gb28181;




import com.alibaba.fastjson.JSONArray;


import com.alibaba.fastjson.JSONObject;


import com.alibaba.fastjson2.JSONArray;


import com.alibaba.fastjson2.JSONObject;


import com.genersoft.iot.vmp.gb28181.bean.Device;


import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;


import com.genersoft.iot.vmp.storager.IVideoManagerStorager;


import com.genersoft.iot.vmp.service.IDeviceService;


import com.genersoft.iot.vmp.storager.IVideoManagerStorage;


import com.genersoft.iot.vmp.web.gb28181.dto.DeviceChannelExtend;


import com.github.pagehelper.PageInfo;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.web.bind.annotation.*;


import org.springframework.util.StringUtils;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.RequestParam;


import org.springframework.web.bind.annotation.RestController;




import java.util.Arrays;


import java.util.List;




/**


 * API兼容：设备信息


 */


@SuppressWarnings("unchecked")


@CrossOrigin




@RestController


@RequestMapping(value = "/api/v1/device")


public class ApiDeviceController {


@@ -25,7 +30,9 @@


    private final static Logger logger = LoggerFactory.getLogger(ApiDeviceController.class);




    @Autowired


    private IVideoManagerStorager storager;


    private IVideoManagerStorage storager;


    @Autowired


    private IDeviceService deviceService;




    // @Autowired


    // private SIPCommander cmder;


@@ -37,7 +44,7 @@


    // private DeviceOffLineDetector offLineDetector;




    /**


     * 分页获取设备列表 TODO 现在直接返回，尚未实现分页


     * 分页获取设备列表 现在直接返回，尚未实现分页


     * @param start


     * @param limit


     * @param q


@@ -56,10 +63,10 @@


        JSONObject result = new JSONObject();


        List<Device> devices;


        if (start == null || limit ==null) {


            devices = storager.queryVideoDeviceList();


            devices = storager.queryVideoDeviceList(online);


            result.put("DeviceCount", devices.size());


        }else {


            PageInfo<Device> deviceList = storager.queryVideoDeviceList(start/limit, limit);


            PageInfo<Device> deviceList = storager.queryVideoDeviceList(start/limit, limit,online);


            result.put("DeviceCount", deviceList.getTotal());


            devices = deviceList.getList();


        }


@@ -73,7 +80,7 @@


            deviceJsonObject.put("ChannelCount", device.getChannelCount());


            deviceJsonObject.put("RecvStreamIP", "");


            deviceJsonObject.put("CatalogInterval", 3600); // 通道目录抓取周期


            deviceJsonObject.put("SubscribeInterval", 0); // 订阅周期(秒), 0 表示后台不周期订阅


            deviceJsonObject.put("SubscribeInterval", device.getSubscribeCycleForCatalog()); // 订阅周期(秒), 0 表示后台不周期订阅


            deviceJsonObject.put("Online", device.getOnline() == 1);


            deviceJsonObject.put("Password", "");


            deviceJsonObject.put("MediaTransport", device.getTransport());


@@ -92,6 +99,7 @@


    @RequestMapping(value = "/channellist")


    public JSONObject channellist( String serial,


                                   @RequestParam(required = false)String channel_type,


                                   @RequestParam(required = false)String code ,


                                   @RequestParam(required = false)String dir_serial ,


                                   @RequestParam(required = false)Integer start,


                                   @RequestParam(required = false)Integer limit,


@@ -103,54 +111,60 @@


//        }


        JSONObject result = new JSONObject();


        // 查询设备是否存在


        Device device = storager.queryVideoDevice(serial);


        if (device == null) {


            result.put("ChannelCount", 0);


            result.put("ChannelList", "[]");


            return result;


//        Device device = storager.queryVideoDevice(serial);


//        if (device == null) {


//            result.put("ChannelCount", 0);


//            result.put("ChannelList", "[]");


//            return result;


//        }


        List<DeviceChannelExtend> deviceChannels;


        List<String> channelIds = null;


        if (!StringUtils.isEmpty(code)) {


            String[] split = code.trim().split(",");


            channelIds = Arrays.asList(split);


        }


        List<DeviceChannel> deviceChannels;


        List<DeviceChannelExtend> allDeviceChannelList = storager.queryChannelsByDeviceId(serial,channelIds,online);


        if (start == null || limit ==null) {


            deviceChannels = storager.queryChannelsByDeviceId(serial);


            deviceChannels = allDeviceChannelList;


            result.put("ChannelCount", deviceChannels.size());


        }else {


            PageInfo<DeviceChannel> pageResult = storager.queryChannelsByDeviceId(serial, null, null, null,start/limit, limit);


            result.put("ChannelCount", pageResult.getTotal());


            deviceChannels = pageResult.getList();


            deviceChannels = storager.queryChannelsByDeviceIdWithStartAndLimit(serial,channelIds, null, null, online,start, limit);


            int total = allDeviceChannelList.size();


            result.put("ChannelCount", total);


        }




        JSONArray channleJSONList = new JSONArray();


        for (DeviceChannel deviceChannel : deviceChannels) {


        for (DeviceChannelExtend deviceChannelExtend : deviceChannels) {


            JSONObject deviceJOSNChannel = new JSONObject();


            deviceJOSNChannel.put("ID", deviceChannel.getChannelId());


            deviceJOSNChannel.put("DeviceID", device.getDeviceId());


            deviceJOSNChannel.put("DeviceName", device.getName());


            deviceJOSNChannel.put("DeviceOnline", device.getOnline() == 1);


            deviceJOSNChannel.put("ID", deviceChannelExtend.getChannelId());


            deviceJOSNChannel.put("DeviceID", deviceChannelExtend.getDeviceId());


            deviceJOSNChannel.put("DeviceName", deviceChannelExtend.getDeviceName());


            deviceJOSNChannel.put("DeviceOnline", deviceChannelExtend.getDeviceOnline() == 1);


            deviceJOSNChannel.put("Channel", 0); // TODO 自定义序号


            deviceJOSNChannel.put("Name", deviceChannel.getName());


            deviceJOSNChannel.put("Name", deviceChannelExtend.getName());


            deviceJOSNChannel.put("Custom", false);


            deviceJOSNChannel.put("CustomName", "");


            deviceJOSNChannel.put("SubCount", deviceChannel.getSubCount()); // TODO ? 子节点数, SubCount > 0 表示该通道为子目录


            deviceJOSNChannel.put("SubCount", deviceChannelExtend.getSubCount()); // TODO ? 子节点数, SubCount > 0 表示该通道为子目录


            deviceJOSNChannel.put("SnapURL", "");


            deviceJOSNChannel.put("Manufacturer ", deviceChannel.getManufacture());


            deviceJOSNChannel.put("Model", deviceChannel.getModel());


            deviceJOSNChannel.put("Owner", deviceChannel.getOwner());


            deviceJOSNChannel.put("CivilCode", deviceChannel.getCivilCode());


            deviceJOSNChannel.put("Address", deviceChannel.getAddress());


            deviceJOSNChannel.put("Parental", deviceChannel.getParental()); // 当为通道设备时, 是否有通道子设备, 1-有,0-没有


            deviceJOSNChannel.put("ParentID", deviceChannel.getParentId()); // 直接上级编号


            deviceJOSNChannel.put("Secrecy", deviceChannel.getSecrecy());


            deviceJOSNChannel.put("Manufacturer ", deviceChannelExtend.getManufacture());


            deviceJOSNChannel.put("Model", deviceChannelExtend.getModel());


            deviceJOSNChannel.put("Owner", deviceChannelExtend.getOwner());


            deviceJOSNChannel.put("CivilCode", deviceChannelExtend.getCivilCode());


            deviceJOSNChannel.put("Address", deviceChannelExtend.getAddress());


            deviceJOSNChannel.put("Parental", deviceChannelExtend.getParental()); // 当为通道设备时, 是否有通道子设备, 1-有,0-没有


            deviceJOSNChannel.put("ParentID", deviceChannelExtend.getParentId()); // 直接上级编号


            deviceJOSNChannel.put("Secrecy", deviceChannelExtend.getSecrecy());


            deviceJOSNChannel.put("RegisterWay", 1); // 注册方式, 缺省为1, 允许值: 1, 2, 3


                                                     // 1-IETF RFC3261,


                                                     // 2-基于口令的双向认证,


                                                     // 3-基于数字证书的双向认证


            deviceJOSNChannel.put("Status", deviceChannel.getStatus());


            deviceJOSNChannel.put("Longitude", deviceChannel.getLongitude());


            deviceJOSNChannel.put("Latitude", deviceChannel.getLatitude());


            deviceJOSNChannel.put("PTZType ", deviceChannel.getPTZType()); // 云台类型, 0 - 未知, 1 - 球机, 2 - 半球,


                                                                            //   3 - 固定枪机, 4 - 遥控枪机


            // 1-IETF RFC3261,


            // 2-基于口令的双向认证,


            // 3-基于数字证书的双向认证


            deviceJOSNChannel.put("Status", deviceChannelExtend.getStatus() == 1 ? "ON":"OFF");


            deviceJOSNChannel.put("Longitude", deviceChannelExtend.getLongitude());


            deviceJOSNChannel.put("Latitude", deviceChannelExtend.getLatitude());


            deviceJOSNChannel.put("PTZType ", deviceChannelExtend.getPTZType()); // 云台类型, 0 - 未知, 1 - 球机, 2 - 半球,


            //   3 - 固定枪机, 4 - 遥控枪机


            deviceJOSNChannel.put("CustomPTZType", "");


            deviceJOSNChannel.put("StreamID", deviceChannel.getStreamId()); // StreamID 直播流ID, 有值表示正在直播


            deviceJOSNChannel.put("StreamID", deviceChannelExtend.getStreamId()); // StreamID 直播流ID, 有值表示正在直播


            deviceJOSNChannel.put("NumOutputs ", -1); // 直播在线人数


            channleJSONList.add(deviceJOSNChannel);


        }