录像索引主动获取代码提交

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteHostService.java

@@ -0,0 +1,20 @@
+package com.xunmei.system.api;
+
+import com.xunmei.common.core.constant.SecurityConstants;
+import com.xunmei.common.core.constant.ServiceNameConstants;
+import com.xunmei.common.core.domain.R;
+import com.xunmei.common.core.domain.host.remote.VideoIntegrityGetReq;
+import com.xunmei.common.core.web.domain.AjaxResult;
+import com.xunmei.system.api.domain.SysConfig;
+import com.xunmei.system.api.dto.SysJobDTO;
+import com.xunmei.system.api.factory.RemoteConfigFallbackFactory;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@FeignClient(contextId = "remoteHostService", value = ServiceNameConstants.HOST, fallbackFactory = RemoteConfigFallbackFactory.class)
+public interface RemoteHostService {
+    @PostMapping("/getRecordInfo")
+     AjaxResult getRecordInfo(@RequestBody VideoIntegrityGetReq req);
+}

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteHostFallbackFactory.java

@@ -0,0 +1,30 @@
+package com.xunmei.system.api.factory;
+
+import com.xunmei.common.core.domain.R;
+import com.xunmei.common.core.domain.host.remote.VideoIntegrityGetReq;
+import com.xunmei.common.core.web.domain.AjaxResult;
+import com.xunmei.system.api.RemoteConfigService;
+import com.xunmei.system.api.RemoteHostService;
+import com.xunmei.system.api.domain.SysConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.openfeign.FallbackFactory;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+public class RemoteHostFallbackFactory implements FallbackFactory<RemoteHostService> {
+    private static final Logger log = LoggerFactory.getLogger(RemoteHostFallbackFactory.class);
+    @Override
+    public RemoteHostService create(Throwable throwable) {
+        log.error("HOST服务调用失败:{}", throwable.getMessage());
+        return new RemoteHostService() {
+            @Override
+            public AjaxResult getRecordInfo(VideoIntegrityGetReq req) {
+                return null;
+            }
+        };
+    }
+}

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/constant/ServiceNameConstants.java

@@ -28,4 +28,5 @@ public class ServiceNameConstants
     public static final String MEDIATOR_SERVICE="soc-mediator";
     public static final String SMS="soc-sms";
     public static final String IOT="soc-iot";
+    public static final String HOST="soc-host";
 }

soc-modules/soc-modules-host/src/main/java/com/xunmei/host/north/controller/HostController.java

@@ -42,7 +42,7 @@ public class HostController {
 
 
     @ApiOperation("获取指定通道的录像完整性数据")
-    @GetMapping({"/host/videoIntegrityCheck"})
+    @GetMapping({"/getRecordInfo"})
     public AjaxResult videoIntegrityCheck(@RequestBody VideoIntegrityGetReq req ) {
         this.videoIntegrityCheckService.getRecordInfo(req);
         return AjaxResult.success();