dao/src/main/java/com/sandu/ximon/dao/mapper/MonitorMapper.java
@@ -17,7 +17,7 @@ List<MonitorBo> listMonitorByIds(List<String> list, String keyword, int bindingState, int equipmentState, Long userid); List<String> listMonitorDeviceSerial(); List<String> listMonitorDeviceSerial(Long userid); } dao/src/main/resources/mapper/MonitorMapper.xml
@@ -80,7 +80,18 @@ </where> </select> <select id="listMonitorDeviceSerial" resultType="java.lang.String"> SELECT device_serial FROM monitor; SELECT device_serial FROM monitor t1 LEFT JOIN pole_binding t2 ON t1.device_serial = t2.device_code AND t2.device_type = 7 LEFT JOIN pole t3 ON t3.id = t2.pole_id <where> <if test="userid != null"> AND (t3.user_id = #{userid} OR t3.client_id = #{userid}) </if> </where> </select> </mapper> ximon-admin/src/main/java/com/sandu/ximon/admin/controller/MonitorController.java
@@ -37,26 +37,10 @@ */ @PostMapping("/listMonitor") public ResponseVO<Object> listMonitorByKeyword(BaseConditionVO baseConditionVO, @RequestBody(required = false) MonitorParam monitorParam) { // //查询数据库的摄像头信息列表 // if (monitorParam == null) { // list = monitorService.listMonitorByKeyword(baseConditionVO, new MonitorParam()); // } else { // list = monitorService.listMonitorByKeyword(baseConditionVO, monitorParam); // } if (!permissionConfig.check(MenuEnum.MONITOR_LIST.getCode())) { return ResponseUtil.fail("缺少对应用户权限"); } // List<String> list; // list = monitorMapper.listMonitorDeviceSerial(); // // MonitorParam monitorParam1; // for (String devices_serial : list) { // monitorParam1 = new MonitorParam(); // monitorParam1.setAccessToken(monitorService.getAccessToken()); // monitorParam1.setDeviceSerial(devices_serial); // getYSYMonitorInfoAndaddMonitorToTable(monitorParam1); // } //返回查询的摄像头信息列表 List<MonitorBo> listresult; if (monitorParam == null) { ximon-admin/src/main/java/com/sandu/ximon/admin/service/MonitorService.java
@@ -55,7 +55,11 @@ */ public List<MonitorBo> listMonitorByKeyword(BaseConditionVO baseConditionVO, MonitorParam monitorParam) { List<String> list; list = monitorMapper.listMonitorDeviceSerial(); if (SecurityUtils.getClientId() == null) { list = monitorMapper.listMonitorDeviceSerial(null); } else { list = monitorMapper.listMonitorDeviceSerial(SecurityUtils.getUserId()); } MonitorParam monitorParam1; for (String devices_serial : list) { @@ -90,7 +94,8 @@ YSY_MonitorDto getMonitorDto = getYSYMonitorInfo(getAccessToken(), monitorParam.getDeviceSerial()); if ("200".equals(getMonitorDto.getCode())) { Monitor monitor = new Monitor(); Monitor monitor = getOne(Wrappers.lambdaQuery(Monitor.class).eq(Monitor::getDeviceSerial, monitorParam.getDeviceSerial())); if (monitor != null) { monitor.setDeviceSerial(getMonitorDto.getData().getDeviceSerial()); if (monitorParam.getValidateCode() != null) { monitor.setDevicesCode(monitorParam.getValidateCode()); @@ -101,6 +106,23 @@ monitor.setIsEncrypt(getMonitorDto.getData().getIsEncrypt()); monitor.setAddTime(getMonitorDto.getData().getUpdateTime()); monitor.setNetAddress(getMonitorDto.getData().getNetAddress()); //更新摄像头状态 updateById(monitor); } else { monitor = new Monitor(); monitor.setDeviceSerial(getMonitorDto.getData().getDeviceSerial()); if (monitorParam.getValidateCode() != null) { monitor.setDevicesCode(monitorParam.getValidateCode()); } monitor.setDeviceName(getMonitorDto.getData().getDeviceName()); monitor.setDeviceType(getMonitorDto.getData().getModel()); monitor.setEquipmentState(getMonitorDto.getData().getStatus()); monitor.setIsEncrypt(getMonitorDto.getData().getIsEncrypt()); monitor.setAddTime(getMonitorDto.getData().getUpdateTime()); monitor.setNetAddress(getMonitorDto.getData().getNetAddress()); //更新摄像头状态 save(monitor); } return monitor; } else {