Merge remote-tracking branch 'origin/master'
| | |
| | | |
| | | @Override |
| | | public void update(ArcSettingEntity arcSettingEntity) { |
| | | arcSettingEntity.setUpdateTime(new Date()); |
| | | arcPointSettingDao.updateById(arcSettingEntity); |
| | | } |
| | | |
| | |
| | | |
| | | @Override |
| | | public void add(ArcSettingEntity arcSettingEntity) { |
| | | arcSettingEntity.setCreateTime(new Date()); |
| | | arcPointSettingDao.insert(arcSettingEntity); |
| | | } |
| | | |
| | |
| | | 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; |
| | | |
| | |
| | | @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); |
| | | } |
| | | |
| | |
| | | YESTERDAY("YESTERDAY", "昨天"), |
| | | LAST_DAY_7("LAST_DAY_7", "最近7天"), |
| | | LAST_DAY_30("LAST_DAY_30", "最近30天"), |
| | | LAST_DAY_90("LAST_DAY_90", "最近90天"), |
| | | THIS_MONTH("THIS_MONTH", "当前月"), |
| | | LAST_MONTH("LAST_MONTH", "上月"), |
| | | LAST_MONTH_12("LAST_MONTH_12", "最近12个月"), |
| | |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.YearMonth; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.Calendar; |
| | | import java.util.Date; |
| | | |
| | |
| | | whereSql.append(DateUtils.format(calendar.getTime(), datePattern)); |
| | | whereSql.append("'"); |
| | | break; |
| | | case LAST_DAY_90: |
| | | whereSql.append(indItem.getTimeLabel()); |
| | | whereSql.append(" <= '"); |
| | | whereSql.append(DateUtils.format(calendar.getTime(), datePattern)); |
| | | whereSql.append("' AND "); |
| | | whereSql.append(indItem.getTimeLabel()); |
| | | whereSql.append(" >= '"); |
| | | calendar.add(Calendar.DAY_OF_YEAR, -90); |
| | | whereSql.append(DateUtils.format(calendar.getTime(), datePattern)); |
| | | whereSql.append("'"); |
| | | break; |
| | | case THIS_MONTH: |
| | | whereSql.append(indItem.getTimeLabel()); |
| | | whereSql.append("='"); |