潘志宝
2 天以前 f280764caf198728677a5b8fa62175e1b3ccd209
tag分页异常捕获
已修改1个文件
11 ■■■■■ 文件已修改
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/http/controller/admin/HttpTagController.java 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/http/controller/admin/HttpTagController.java
@@ -30,6 +30,10 @@
import javax.validation.Valid;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import static com.iailab.framework.apilog.core.enums.OperateTypeEnum.EXPORT;
import static com.iailab.framework.common.pojo.CommonResult.success;
@@ -49,16 +53,23 @@
    @Resource
    private HttpCollector httpCollector;
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(18, 36, 30, TimeUnit.SECONDS,
            new ArrayBlockingQueue<Runnable>(36), new ThreadPoolExecutor.AbortPolicy());
    @PreAuthorize("@ss.hasPermission('data:channel-http:query')")
    @GetMapping("page")
    public CommonResult<PageResult<HttpTagRespVO>> page(@Valid HttpTagPageReqVO reqVO) {
        PageResult<HttpTagEntity> page = tagService.queryPage(reqVO);
        PageResult<HttpTagRespVO> pageResult = BeanUtils.toBean(page, HttpTagRespVO.class);
        try {
        pageResult.getList().forEach(item -> {
            item.setDataValue(httpCollector.getTagValue(item.getApiId(), item.getTagName()));
            item.setDataTime(new Date());
            item.setDataQuality(DataQualityEnum.getEumByValue(item.getDataValue()).getDesc());
        });
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return success(pageResult);
    }