Commit 7b71937e8c9cdb016fd398273594fb4c175e3313

Authored by lijianfa_14810364212
1 parent 458462df

feat:OpenApi调用统计添加自定义查询

@@ -83,6 +83,21 @@ public class TkOpenApiRecordController extends BaseController { @@ -83,6 +83,21 @@ public class TkOpenApiRecordController extends BaseController {
83 return ResponseEntity.ok(openApiRecordService.getClassify(getCurrentUser().getTenantId().toString(), type)); 83 return ResponseEntity.ok(openApiRecordService.getClassify(getCurrentUser().getTenantId().toString(), type));
84 } 84 }
85 85
  86 + @GetMapping("/getCustomClassify")
  87 + @PreAuthorize("@check.checkPermissions({'TENANT_ADMIN'},{})")
  88 + @ApiImplicitParams(value = {
  89 + @ApiImplicitParam(name = "startTime", value = "开始时间" ,required = true),
  90 + @ApiImplicitParam(name = "endTime", value = "结束时间" ,required = true),
  91 + @ApiImplicitParam(name = "type", value = "统计类型 day以两小时为分组,month以一天为分组" ,required = true)
  92 + })
  93 + public ResponseEntity<List<OpenApiRecordClassifyAllDTO>> getCustomClassify(
  94 + @RequestParam(value = "startTime", required = true) Long startTime,
  95 + @RequestParam(value = "endTime", required = true) Long endTime,
  96 + @RequestParam(value = "type" ) String type
  97 + ) throws ThingsboardException {
  98 + return ResponseEntity.ok(openApiRecordService.getClassify(getCurrentUser().getTenantId().toString(), type,new java.util.Date(startTime),new java.util.Date(endTime)));
  99 + }
  100 +
86 101
87 @GetMapping("/getPage") 102 @GetMapping("/getPage")
88 public TkPageData<OpenApiRecordTopDTO> getPage( 103 public TkPageData<OpenApiRecordTopDTO> getPage(
@@ -19,6 +19,7 @@ import org.thingsboard.server.dao.yunteng.service.OpenApiRecordService; @@ -19,6 +19,7 @@ import org.thingsboard.server.dao.yunteng.service.OpenApiRecordService;
19 19
20 import java.sql.Time; 20 import java.sql.Time;
21 import java.util.ArrayList; 21 import java.util.ArrayList;
  22 +import java.util.Date;
22 import java.util.List; 23 import java.util.List;
23 import java.util.Map; 24 import java.util.Map;
24 import java.util.concurrent.atomic.AtomicInteger; 25 import java.util.concurrent.atomic.AtomicInteger;
@@ -126,7 +127,11 @@ public class OpenApiRecordImpl extends AbstractBaseService<OpenApiRecordMapper, @@ -126,7 +127,11 @@ public class OpenApiRecordImpl extends AbstractBaseService<OpenApiRecordMapper,
126 case "week":startTime=new java.util.Date(endTime.getTime()- HOUR_TIMESTAMP*24L*7L);break; 127 case "week":startTime=new java.util.Date(endTime.getTime()- HOUR_TIMESTAMP*24L*7L);break;
127 case "month":startTime=new java.util.Date(endTime.getTime()- HOUR_TIMESTAMP*24L*30L);break; 128 case "month":startTime=new java.util.Date(endTime.getTime()- HOUR_TIMESTAMP*24L*30L);break;
128 } 129 }
  130 + return getClassify(tenantId,type,startTime,endTime);
  131 + }
129 132
  133 + @Override
  134 + public List<OpenApiRecordClassifyAllDTO> getClassify(String tenantId, String type, Date startTime, Date endTime) {
130 List<OpenApiRecordClassifyDTO> tops = baseMapper.getClassify(tenantId,type,startTime,endTime); 135 List<OpenApiRecordClassifyDTO> tops = baseMapper.getClassify(tenantId,type,startTime,endTime);
131 List<OpenApiRecordClassifyAllDTO> allList =new ArrayList<>(); 136 List<OpenApiRecordClassifyAllDTO> allList =new ArrayList<>();
132 if(!tops.isEmpty()){ 137 if(!tops.isEmpty()){
@@ -21,4 +21,5 @@ public interface OpenApiRecordService extends BaseService<TkOpenApiRecordEntity> @@ -21,4 +21,5 @@ public interface OpenApiRecordService extends BaseService<TkOpenApiRecordEntity>
21 TkPageData<OpenApiRecordTopDTO> getPage(String tenantId,Integer page,Integer pageSize); 21 TkPageData<OpenApiRecordTopDTO> getPage(String tenantId,Integer page,Integer pageSize);
22 22
23 List<OpenApiRecordClassifyAllDTO> getClassify(String tenantId,String type); 23 List<OpenApiRecordClassifyAllDTO> getClassify(String tenantId,String type);
  24 + public List<OpenApiRecordClassifyAllDTO> getClassify(String tenantId,String type,java.util.Date startTime,java.util.Date endTime);
24 } 25 }