人体检测-task

liquidnet-bus-feign/liquidnet-api-feign-platform/src/main/java/com/liquidnet/service/feign/platform/api/FeignPlatformApiClient.java

@@ -19,4 +19,7 @@ public interface FeignPlatformApiClient {
     @GetMapping("refund/overtimeRefund")
     ResponseDto<String> overtimeRefund();
 
+    @GetMapping("detectPedestrian")
+    ResponseDto<String> detectPedestrian();
+
 }

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/PlatformTaskHandler.java

@@ -30,6 +30,22 @@ public class PlatformTaskHandler {
     @Autowired
     FeignPlatformApiClient feignPlatformApiClient;
 
+    @XxlJob(value = "sev-platform:detectPedestrian")
+    public ReturnT<String> detectPedestrian() {
+        try {
+            String result = feignPlatformApiClient.detectPedestrian().getData();
+            log.info("detectPedestrian：结果："+result);
+            ReturnT<String> success = ReturnT.SUCCESS;
+            success.setMsg(result);
+            return success;
+        } catch (Exception e) {
+            log.error("exception of handler:{}", e.getMessage(), e);
+            ReturnT<String> fail = ReturnT.FAIL;
+            fail.setMsg(e.getLocalizedMessage());
+            return fail;
+        }
+    }
+
     @XxlJob(value = "sev-platform:overtimeRefund")
     public ReturnT<String> overtimeRefund() {
         try {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/KylinCameraController.java

@@ -17,9 +17,9 @@ import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.MapperFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.google.gson.Gson;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
+import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.dto.vo.KylinCameraDevicesVo;
 import com.liquidnet.service.kylin.entity.KylinCamera;
 import com.liquidnet.service.kylin.entity.KylinCameraRecord;
@@ -38,7 +38,6 @@ import org.springframework.web.bind.annotation.*;
 import java.io.InputStream;
 import java.time.LocalDateTime;
 import java.util.List;
-import java.util.Optional;
 
 /**
  * <p>
@@ -82,13 +81,13 @@ public class KylinCameraController {
         }
     }
 
-    @GetMapping(value = "describeDevices")
+    @GetMapping("describeDevices")
     @ApiOperation("获取设备列表")
     @ApiImplicitParams({
             @ApiImplicitParam(type = "query", dataType = "Integer", name = "pageNum", value = "页码"),
             @ApiImplicitParam(type = "query", dataType = "Integer", name = "pageSize", value = "数量")
     })
-    public String describeDevices(
+    public ResponseDto describeDevices(
             @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
             @RequestParam(value = "pageSize", defaultValue = "20") Integer pageSize
     ) {
@@ -138,16 +137,16 @@ public class KylinCameraController {
 
             }
 
-            return "success";
+            return ResponseDto.success();
         } catch (ClientException | JsonProcessingException e) {
             log.error("获取设备列表Exception：[msg={}, e={}]", e.getMessage(), e);
-            return "error";
+            return ResponseDto.failure();
         }
     }
 
     @GetMapping(value = "detectPedestrian")
     @ApiOperation("人体识别")
-    public String detectPedestrian() {
+    public ResponseDto detectPedestrian() {
         long startTime1 = System.currentTimeMillis();
         List<KylinCamera> cameraList = cameraMapper.selectList(
                 Wrappers.lambdaQuery(KylinCamera.class)
@@ -188,7 +187,7 @@ public class KylinCameraController {
                 }
             }
         }
-        return "success";
+        return ResponseDto.success();
     }
 
 }