2021与蓝度共同重构项目,服务端
zhanzhiqin
2022-05-20 d35545d88b9123b92b50aaf1b0fa4e3f20fd2209
ximon-admin/src/main/java/com/sandu/ximon/admin/service/MonitorService.java
@@ -268,6 +268,11 @@
     *                     //     * @param validateCode 设备验证码,设备机身上的六位大写字母
     */
    public boolean addYSYMonitor(String deviceSerial, String validateCode) {
        List<Monitor> list = list(Wrappers.lambdaQuery(Monitor.class).eq(Monitor::getDeviceSerial, deviceSerial));
        if (list.size() != 0) {
            throw new BusinessException("该摄像头已存在,无法重复添加!");
        }
        Map<String, Object> paramMap = new HashMap<>();
        paramMap.put("accessToken", getAccessToken());
        paramMap.put("deviceSerial", deviceSerial);
@@ -275,34 +280,45 @@
            paramMap.put("validateCode", validateCode);
        }
        String s = HttpUtil.post(YSY_URL + ADD_DEVICE_URL, paramMap);
        if (!s.startsWith("{") && !s.endsWith("}")) {
            throw new BusinessException("萤石云数据异常");
        }
        YSY_MonitorDto monitorDto = JSON.parseObject(s, YSY_MonitorDto.class);
        boolean result;
        if ("200".equals(monitorDto.getCode()) || "20017".equals(monitorDto.getCode())) {
            Monitor monitor = new Monitor();
            monitor.setDeviceSerial(monitorDto.getData().getDeviceSerial());
            monitor.setDevicesCode(validateCode);
            monitor.setDeviceName(monitorDto.getData().getDeviceName());
            monitor.setEquipmentState(monitorDto.getData().getStatus());
            monitor.setIsEncrypt(monitorDto.getData().getIsEncrypt());
            monitor.setDeviceType(monitorDto.getData().getModel());
            monitor.setNetAddress(monitorDto.getData().getNetAddress());
            result = addMonitorInfoToTable(monitor);
        if ("20017".equals(monitorDto.getCode())) {
            //当前摄像头已经被萤石云官网添加过,Code:20017
            monitorDto = getYSYMonitorInfo(getAccessToken(), deviceSerial);
            /**
             * 新增摄像头开始
             */
            String content = "{摄像头Code:" + monitor.getDeviceSerial() + ", 摄像头名称:" + monitor.getDeviceName() + " }";
            List<String> listCode = new ArrayList<>();
            listCode.add(monitor.getDeviceSerial());
            StoreOperationRecordsUtils.storeOperationData(listCode, null, "新增摄像头", content);
            /**
             * 新增摄像头结束
             */
        } else {
            result = false;
        } else if (!"200".equals(monitorDto.getCode())) {
            //当前摄像头成功被萤石云官网添加,Code:200
            throw new BusinessException(monitorDto.getMsg());
        }
        if (monitorDto.getData() == null) {
            throw new BusinessException("萤石云数据异常!");
        }
        Monitor monitor = new Monitor();
        monitor.setDeviceSerial(monitorDto.getData().getDeviceSerial());
        monitor.setDevicesCode(validateCode);
        monitor.setDeviceName(monitorDto.getData().getDeviceName());
        monitor.setEquipmentState(monitorDto.getData().getStatus());
        monitor.setIsEncrypt(monitorDto.getData().getIsEncrypt());
        monitor.setDeviceType(monitorDto.getData().getModel());
        monitor.setNetAddress(monitorDto.getData().getNetAddress());
        result = addMonitorInfoToTable(monitor);
        /**
         * 新增摄像头开始
         */
        String content = "{摄像头Code:" + monitor.getDeviceSerial() + ", 摄像头名称:" + monitor.getDeviceName() + " }";
        List<String> listCode = new ArrayList<>();
        listCode.add(monitor.getDeviceSerial());
        StoreOperationRecordsUtils.storeOperationData(listCode, null, "新增摄像头", content);
        /**
         * 新增摄像头结束
         */
        return result;
    }
@@ -435,8 +451,8 @@
            /**
             * 添加摄像头备注日志记录开始
             */
            String content = "编辑摄像头:" +deviceSerial+"编辑内容:"+notes;
            List<String> list  = new ArrayList<>();
            String content = "编辑摄像头:" + deviceSerial + "编辑内容:" + notes;
            List<String> list = new ArrayList<>();
            list.add(deviceSerial);
            StoreOperationRecordsUtils.storeOperationData(list, null, "编辑摄像头", content);
            /**