视频获取

epmet-plugins-module/pli-power-base/pli-power-base-server/pom.xml

@@ -207,7 +207,7 @@
                 <nacos.config.namespace></nacos.config.namespace>
                 <nacos.config.group></nacos.config.group>
                 <nacos.config-enabled>false</nacos.config-enabled>
-                <nacos.ip>192.168.43.132</nacos.ip>
+                <nacos.ip>192.168.43.43</nacos.ip>
                 <!--是否开启服务列表变更监听-->
                 <nacos.service-list-changed-listening.enable>false</nacos.service-list-changed-listening.enable>
 

epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/visit/controller/VisitVisitorController.java

@@ -91,6 +91,15 @@ public class VisitVisitorController {
         return new Result();
     }
 
+    @NoRepeatSubmit
+    @PostMapping("video")
+    public Result video(@RequestBody VisitVisitorDTO dto) {
+        //效验数据
+        ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class);
+        visitVisitorService.video(dto);
+        return new Result();
+    }
+
     @PostMapping("visitorlogout")
     public Result visitorLogout(@RequestBody VisitorLogoutFormDTO dto) {
         //效验数据

epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/visit/service/VisitVisitorService.java

@@ -90,6 +90,16 @@ public interface VisitVisitorService extends BaseService<VisitVisitorEntity> {
      */
     void visit(VisitVisitorFormDTO dto);
 
+    /**
+     * 视频获取
+     *
+     * @param dto
+     * @return void
+     * @author generator
+     * @date 2022-07-26
+     */
+    void video(VisitVisitorDTO dto);
+
     /**
      * 临时授权
      *

epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/visit/service/impl/VisitVisitorServiceImpl.java

@@ -138,6 +138,12 @@ public class VisitVisitorServiceImpl extends BaseServiceImpl<VisitVisitorDao, Vi
         insert(entity);
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void video(VisitVisitorDTO dto) {
+        dhDeviceUtil.getAllChannel();
+    }
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void doorAuthority(VisitVisitorFormDTO dto) {

epmet-plugins-module/pli-power-base/pli-power-base-server/src/main/java/com/epmet/plugin/power/modules/visit/utils/DhDeviceUtil.java

@@ -566,6 +566,60 @@ public class DhDeviceUtil {
         return list;
     }
 
+
+    /**
+     * 查询通道-从全部设备中获取(视频获取)
+     *
+     * @param
+     * @return java.lang.String
+     * @author zhy
+     * @date 2022/5/23 11:04
+     */
+    public List<DhChannelResultDTO> getAllChannel() {
+        String url = dhCloudProperties.getUrl().concat(GET_CHANNEL);
+        String urlParam = getDhUrlParams();
+        url = url + urlParam;
+
+        Map<String, String> paramsMap = new HashMap<>(4);
+        DhChannelFormDTO dto = new DhChannelFormDTO();
+        dto.setInterfaceId("admin_001_006");
+        dto.setJsonParam("{\"param\":{\"unitType\":1}}");
+
+        String data = HttpClientManager.getInstance().sendPostByJSONAndHeader(url, JSON.toJSONString(dto), paramsMap).getData();
+
+        if (null == data) {
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询通道列表失败");
+        }
+        JSONObject toResult = JSON.parseObject(data);
+        DhResult result = ConvertUtils.mapToEntity(toResult, DhResult.class);
+        if (null != toResult.get("success")) {
+            result.setCode(200);
+        }
+        if (!result.getSuccess()) {
+            logger.info(result.getErrMsg());
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询通道列表失败!" + result.getErrMsg());
+        }
+        Object registerResult = result.getData();
+
+        JSONArray jsonArray = JSON.parseArray(registerResult.toString());
+
+        List<DhChannelResultDTO> list = new ArrayList<>();
+        for (int i = 0; i < jsonArray.size(); i++) {
+            JSONObject jsonItem = jsonArray.getJSONObject(i);
+            DhChannelResultDTO channel = new DhChannelResultDTO();
+            channel.setPrivilegeType("1");
+            channel.setResouceCode(jsonItem.get("channelId").toString());
+            list.add(channel);
+            String channelId = jsonItem.get("channelId").toString();
+            String[] channelIds = channelId.split("\\$");
+            String videoUrl = "http://112.6.213.175:7086/live/cameraid/" + jsonItem.get("deviceId").toString() + "%24" + channelIds[channelIds.length - 1] + "/substream/1.m3u8";
+            System.out.println("INSERT INTO epv_monitor_details (url,customer_id,create_time) VALUES ('" + videoUrl + "','1550309684576591874',NOW());");
+        }
+
+        return list;
+    }
+
+
     /**
      * 新增人员
      *