机构类型

FullCardServer/src/main/java/com/zhongshu/card/server/core/controller/org/PingController.java

@@ -0,0 +1,34 @@
+package com.zhongshu.card.server.core.controller.org;
+
+import com.zhongshu.card.client.model.mqtt.SendMessageModel;
+import com.zhongshu.card.client.ret.ResultContent;
+import com.zhongshu.card.server.core.service.mqtt.MqttServiceImpl;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ *
+ */
+@RequestMapping("/ping")
+@RestController
+@Validated
+@Tag(name = "ping接口")
+public class PingController {
+
+    @Autowired
+    MqttServiceImpl mqttService;
+
+    @Operation(summary = "ping")
+    @RequestMapping(value = "ping", method = {RequestMethod.GET})
+    public ResultContent ping() {
+        return ResultContent.buildSuccess(System.currentTimeMillis());
+    }
+
+}
+

FullCardServer/src/main/java/com/zhongshu/card/server/core/httpRequest/ApiRequestService.java

@@ -1,6 +1,7 @@
 package com.zhongshu.card.server.core.httpRequest;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.date.StopWatch;
 import cn.hutool.json.JSONUtil;
 import com.github.microservice.core.util.net.apache.HttpClientUtil;
 import com.github.microservice.core.util.net.apache.HttpModel;
@@ -46,6 +47,8 @@ public class ApiRequestService extends SuperService {
                 responseModel.setIsFailed("未找到API配置");
                 return responseModel;
             }
+            StopWatch stopWatch = new StopWatch();
+            stopWatch.start();
             String json = JSONUtil.toJsonStr(data);
             String url = iotCenterConf.getUrl() + apiConfParam.getApiName();
             ResponseModel request = HttpClientUtil.request(HttpModel.builder()
@@ -56,6 +59,8 @@ public class ApiRequestService extends SuperService {
                 responseModel = BeanUtil.copyProperties(request.getBody(), APIResponseModel.class);
             }
             responseModel.setParam(apiConfParam);
+            stopWatch.stop();
+            responseModel.setMillis(stopWatch.getTotalTimeMillis());
         } catch (Exception e) {
             e.printStackTrace();
             responseModel.setIsFailed(String.format("请求出错：%s", e.getMessage()));

FullCardServer/src/main/java/com/zhongshu/card/server/core/httpRequest/apiConf/APIResponseModel.java

@@ -2,6 +2,7 @@ package com.zhongshu.card.server.core.httpRequest.apiConf;
 
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
+import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
@@ -19,8 +20,12 @@ public class APIResponseModel {
     private String msg;
     private String state;
     private String content;
+
     private ApiConfParam param;
 
+    @Schema(description = "请求耗时：毫秒")
+    private Long millis;
+
     public <T> T toBean(Class<T> tClass) {
         if (content != null) {
             return JSONUtil.toBean(content, tClass);