API 통계 화면 구현

This commit is contained in:
daekuk1
2026-01-26 14:07:50 +09:00
parent ef50801594
commit 75fb8234f6
30 changed files with 4708 additions and 103 deletions
@@ -0,0 +1,93 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDate;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.IdClass;
import javax.persistence.Table;
import lombok.Getter;
import lombok.Setter;
/**
* API Gateway 일별 처리 통계
*/
@Getter
@Setter
@Entity
@Table(name = "API_STATS_DAY")
@IdClass(ApiStatsDayId.class)
public class ApiStatsDay implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@Column(name = "STAT_TIME", nullable = false)
private LocalDate statTime;
@Id
@Column(name = "API_NAME", nullable = false, length = 100)
private String apiName;
@Id
@Column(name = "GW_INSTANCE_ID", nullable = false, length = 50)
private String gwInstanceId;
@Id
@Column(name = "BIZ_DIV_CODE", nullable = false, length = 50)
private String bizDivCode = "NONE";
@Id
@Column(name = "CLIENT_ID", nullable = false, length = 100)
private String clientId = "NONE";
@Id
@Column(name = "INBOUND_ADAPTER", nullable = false, length = 100)
private String inboundAdapter = "NONE";
@Id
@Column(name = "OUTBOUND_ADAPTER", nullable = false, length = 100)
private String outboundAdapter = "NONE";
@Column(name = "TOTAL_CNT", nullable = false)
private Long totalCnt = 0L;
@Column(name = "SUCCESS_CNT", nullable = false)
private Long successCnt = 0L;
@Column(name = "TIMEOUT_CNT", nullable = false)
private Long timeoutCnt = 0L;
@Column(name = "SYSTEM_ERR_CNT", nullable = false)
private Long systemErrCnt = 0L;
@Column(name = "BIZ_ERR_CNT", nullable = false)
private Long bizErrCnt = 0L;
@Column(name = "SEQ900_TIMEOUT_CNT", nullable = false)
private Long seq900TimeoutCnt = 0L;
@Column(name = "SEQ900_SYSTEM_ERR_CNT", nullable = false)
private Long seq900SystemErrCnt = 0L;
@Column(name = "SEQ900_BIZ_ERR_CNT", nullable = false)
private Long seq900BizErrCnt = 0L;
@Column(name = "AVG_RESP_TIME", precision = 10, scale = 3)
private BigDecimal avgRespTime = BigDecimal.ZERO;
@Column(name = "MIN_RESP_TIME", precision = 10, scale = 3)
private BigDecimal minRespTime = BigDecimal.ZERO;
@Column(name = "MAX_RESP_TIME", precision = 10, scale = 3)
private BigDecimal maxRespTime = BigDecimal.ZERO;
@Column(name = "P50_RESP_TIME", precision = 10, scale = 3)
private BigDecimal p50RespTime = BigDecimal.ZERO;
@Column(name = "P95_RESP_TIME", precision = 10, scale = 3)
private BigDecimal p95RespTime = BigDecimal.ZERO;
}
@@ -0,0 +1,26 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.io.Serializable;
import java.time.LocalDate;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* API 통계 일별 복합키
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class ApiStatsDayId implements Serializable {
private static final long serialVersionUID = 1L;
private LocalDate statTime;
private String apiName;
private String gwInstanceId;
private String bizDivCode;
private String clientId;
private String inboundAdapter;
private String outboundAdapter;
}
@@ -0,0 +1,10 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import com.eactive.eai.data.jpa.BaseRepository;
/**
* API 통계 일별 Repository
*/
interface ApiStatsDayRepository extends BaseRepository<ApiStatsDay, ApiStatsDayId> {
}
@@ -0,0 +1,152 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.List;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.jpa.AbstractDataService;
import com.eactive.ext.kjb.statistics.ui.ApiStatsChartUI;
import com.eactive.ext.kjb.statistics.ui.ApiStatsSearch;
import com.querydsl.core.BooleanBuilder;
import com.querydsl.core.types.Projections;
@Service
@Transactional
public class ApiStatsDayService
extends AbstractDataService<ApiStatsDay, ApiStatsDayId, ApiStatsDayRepository> {
private static final int MAX_DAYS = 31;
public Page<ApiStatsDay> selectList(ApiStatsSearch search, Pageable pageable) {
QApiStatsDay q = QApiStatsDay.apiStatsDay;
BooleanBuilder builder = buildSearchConditions(q, search);
return repository.findAll(builder, pageable);
}
public List<ApiStatsDay> selectListForExcel(ApiStatsSearch search) {
QApiStatsDay q = QApiStatsDay.apiStatsDay;
BooleanBuilder builder = buildSearchConditions(q, search);
return getJPAQueryFactory()
.selectFrom(q)
.where(builder)
.orderBy(q.statTime.desc())
.fetch();
}
public List<ApiStatsChartUI> selectChartData(ApiStatsSearch search) {
QApiStatsDay q = QApiStatsDay.apiStatsDay;
BooleanBuilder builder = new BooleanBuilder();
calculateDateRange(search);
if (search.getParsedStartDate() != null) {
builder.and(q.statTime.goe(search.getParsedStartDate()));
builder.and(q.statTime.loe(search.getParsedEndDate()));
}
if (StringUtils.isNotBlank(search.getSearchApiName())) {
builder.and(q.apiName.containsIgnoreCase(search.getSearchApiName()));
}
if (StringUtils.isNotBlank(search.getSearchGwInstanceId())) {
builder.and(q.gwInstanceId.containsIgnoreCase(search.getSearchGwInstanceId()));
}
if (StringUtils.isNotBlank(search.getSearchBizDivCode())) {
builder.and(q.bizDivCode.containsIgnoreCase(search.getSearchBizDivCode()));
}
if (StringUtils.isNotBlank(search.getSearchClientId())) {
builder.and(q.clientId.containsIgnoreCase(search.getSearchClientId()));
}
return getJPAQueryFactory()
.select(Projections.constructor(ApiStatsChartUI.class,
q.statTime,
q.totalCnt.sum(),
q.successCnt.sum(),
q.timeoutCnt.sum(),
q.systemErrCnt.sum(),
q.bizErrCnt.sum(),
q.seq900TimeoutCnt.sum(),
q.seq900SystemErrCnt.sum(),
q.seq900BizErrCnt.sum(),
q.avgRespTime.avg(),
q.p50RespTime.avg(),
q.p95RespTime.avg()))
.from(q)
.where(builder)
.groupBy(q.statTime)
.orderBy(q.statTime.asc())
.fetch();
}
private BooleanBuilder buildSearchConditions(QApiStatsDay q, ApiStatsSearch search) {
BooleanBuilder builder = new BooleanBuilder();
calculateDateRange(search);
if (search.getParsedStartDate() != null) {
builder.and(q.statTime.goe(search.getParsedStartDate()));
builder.and(q.statTime.loe(search.getParsedEndDate()));
}
if (StringUtils.isNotBlank(search.getSearchApiName())) {
builder.and(q.apiName.containsIgnoreCase(search.getSearchApiName()));
}
if (StringUtils.isNotBlank(search.getSearchGwInstanceId())) {
builder.and(q.gwInstanceId.containsIgnoreCase(search.getSearchGwInstanceId()));
}
if (StringUtils.isNotBlank(search.getSearchBizDivCode())) {
builder.and(q.bizDivCode.containsIgnoreCase(search.getSearchBizDivCode()));
}
if (StringUtils.isNotBlank(search.getSearchClientId())) {
builder.and(q.clientId.containsIgnoreCase(search.getSearchClientId()));
}
if (StringUtils.isNotBlank(search.getSearchInboundAdapter())) {
builder.and(q.inboundAdapter.containsIgnoreCase(search.getSearchInboundAdapter()));
}
if (StringUtils.isNotBlank(search.getSearchOutboundAdapter())) {
builder.and(q.outboundAdapter.containsIgnoreCase(search.getSearchOutboundAdapter()));
}
return builder;
}
/**
* 조회 기간 계산 (최대 31일 제한)
*/
private void calculateDateRange(ApiStatsSearch search) {
if (StringUtils.isBlank(search.getSearchStartDateTime())) {
return;
}
LocalDate startDate = LocalDate.parse(search.getSearchStartDateTime(),
DateTimeFormatter.ofPattern("yyyyMMdd"));
LocalDate endDate;
if (StringUtils.isNotBlank(search.getSearchEndDateTime())) {
endDate = LocalDate.parse(search.getSearchEndDateTime(),
DateTimeFormatter.ofPattern("yyyyMMdd"));
// 31일 초과 시 시작날짜 기준 31일 후로 강제 설정
if (java.time.Period.between(startDate, endDate).getDays() > MAX_DAYS) {
endDate = startDate.plusDays(MAX_DAYS);
}
} else {
endDate = startDate.plusDays(MAX_DAYS);
}
search.setParsedStartDate(startDate);
search.setParsedEndDate(endDate);
}
}
@@ -0,0 +1,92 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.io.Serializable;
import java.math.BigDecimal;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.IdClass;
import javax.persistence.Table;
import lombok.Getter;
import lombok.Setter;
/**
* API Gateway 월별 처리 통계
*/
@Getter
@Setter
@Entity
@Table(name = "API_STATS_MONTH")
@IdClass(ApiStatsMonthId.class)
public class ApiStatsMonth implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@Column(name = "STAT_TIME", nullable = false, length = 6)
private String statTime; // YYYYMM format
@Id
@Column(name = "API_NAME", nullable = false, length = 100)
private String apiName;
@Id
@Column(name = "GW_INSTANCE_ID", nullable = false, length = 50)
private String gwInstanceId;
@Id
@Column(name = "BIZ_DIV_CODE", nullable = false, length = 50)
private String bizDivCode = "NONE";
@Id
@Column(name = "CLIENT_ID", nullable = false, length = 100)
private String clientId = "NONE";
@Id
@Column(name = "INBOUND_ADAPTER", nullable = false, length = 100)
private String inboundAdapter = "NONE";
@Id
@Column(name = "OUTBOUND_ADAPTER", nullable = false, length = 100)
private String outboundAdapter = "NONE";
@Column(name = "TOTAL_CNT", nullable = false)
private Long totalCnt = 0L;
@Column(name = "SUCCESS_CNT", nullable = false)
private Long successCnt = 0L;
@Column(name = "TIMEOUT_CNT", nullable = false)
private Long timeoutCnt = 0L;
@Column(name = "SYSTEM_ERR_CNT", nullable = false)
private Long systemErrCnt = 0L;
@Column(name = "BIZ_ERR_CNT", nullable = false)
private Long bizErrCnt = 0L;
@Column(name = "SEQ900_TIMEOUT_CNT", nullable = false)
private Long seq900TimeoutCnt = 0L;
@Column(name = "SEQ900_SYSTEM_ERR_CNT", nullable = false)
private Long seq900SystemErrCnt = 0L;
@Column(name = "SEQ900_BIZ_ERR_CNT", nullable = false)
private Long seq900BizErrCnt = 0L;
@Column(name = "AVG_RESP_TIME", precision = 10, scale = 3)
private BigDecimal avgRespTime = BigDecimal.ZERO;
@Column(name = "MIN_RESP_TIME", precision = 10, scale = 3)
private BigDecimal minRespTime = BigDecimal.ZERO;
@Column(name = "MAX_RESP_TIME", precision = 10, scale = 3)
private BigDecimal maxRespTime = BigDecimal.ZERO;
@Column(name = "P50_RESP_TIME", precision = 10, scale = 3)
private BigDecimal p50RespTime = BigDecimal.ZERO;
@Column(name = "P95_RESP_TIME", precision = 10, scale = 3)
private BigDecimal p95RespTime = BigDecimal.ZERO;
}
@@ -0,0 +1,25 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.io.Serializable;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* API 통계 월별 복합키
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class ApiStatsMonthId implements Serializable {
private static final long serialVersionUID = 1L;
private String statTime; // YYYYMM format
private String apiName;
private String gwInstanceId;
private String bizDivCode;
private String clientId;
private String inboundAdapter;
private String outboundAdapter;
}
@@ -0,0 +1,10 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import com.eactive.eai.data.jpa.BaseRepository;
/**
* API 통계 월별 Repository
*/
interface ApiStatsMonthRepository extends BaseRepository<ApiStatsMonth, ApiStatsMonthId> {
}
@@ -0,0 +1,153 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.time.YearMonth;
import java.time.format.DateTimeFormatter;
import java.util.List;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.jpa.AbstractDataService;
import com.eactive.ext.kjb.statistics.ui.ApiStatsChartUI;
import com.eactive.ext.kjb.statistics.ui.ApiStatsSearch;
import com.querydsl.core.BooleanBuilder;
import com.querydsl.core.types.Projections;
@Service
@Transactional
public class ApiStatsMonthService
extends AbstractDataService<ApiStatsMonth, ApiStatsMonthId, ApiStatsMonthRepository> {
private static final int MAX_MONTHS = 24;
public Page<ApiStatsMonth> selectList(ApiStatsSearch search, Pageable pageable) {
QApiStatsMonth q = QApiStatsMonth.apiStatsMonth;
BooleanBuilder builder = buildSearchConditions(q, search);
return repository.findAll(builder, pageable);
}
public List<ApiStatsMonth> selectListForExcel(ApiStatsSearch search) {
QApiStatsMonth q = QApiStatsMonth.apiStatsMonth;
BooleanBuilder builder = buildSearchConditions(q, search);
return getJPAQueryFactory()
.selectFrom(q)
.where(builder)
.orderBy(q.statTime.desc())
.fetch();
}
public List<ApiStatsChartUI> selectChartData(ApiStatsSearch search) {
QApiStatsMonth q = QApiStatsMonth.apiStatsMonth;
BooleanBuilder builder = new BooleanBuilder();
calculateDateRange(search);
if (search.getParsedStartMonth() != null) {
builder.and(q.statTime.goe(search.getParsedStartMonth()));
builder.and(q.statTime.loe(search.getParsedEndMonth()));
}
if (StringUtils.isNotBlank(search.getSearchApiName())) {
builder.and(q.apiName.containsIgnoreCase(search.getSearchApiName()));
}
if (StringUtils.isNotBlank(search.getSearchGwInstanceId())) {
builder.and(q.gwInstanceId.containsIgnoreCase(search.getSearchGwInstanceId()));
}
if (StringUtils.isNotBlank(search.getSearchBizDivCode())) {
builder.and(q.bizDivCode.containsIgnoreCase(search.getSearchBizDivCode()));
}
if (StringUtils.isNotBlank(search.getSearchClientId())) {
builder.and(q.clientId.containsIgnoreCase(search.getSearchClientId()));
}
return getJPAQueryFactory()
.select(Projections.constructor(ApiStatsChartUI.class,
q.statTime,
q.totalCnt.sum(),
q.successCnt.sum(),
q.timeoutCnt.sum(),
q.systemErrCnt.sum(),
q.bizErrCnt.sum(),
q.seq900TimeoutCnt.sum(),
q.seq900SystemErrCnt.sum(),
q.seq900BizErrCnt.sum(),
q.avgRespTime.avg(),
q.p50RespTime.avg(),
q.p95RespTime.avg()))
.from(q)
.where(builder)
.groupBy(q.statTime)
.orderBy(q.statTime.asc())
.fetch();
}
private BooleanBuilder buildSearchConditions(QApiStatsMonth q, ApiStatsSearch search) {
BooleanBuilder builder = new BooleanBuilder();
calculateDateRange(search);
if (search.getParsedStartMonth() != null) {
builder.and(q.statTime.goe(search.getParsedStartMonth()));
builder.and(q.statTime.loe(search.getParsedEndMonth()));
}
if (StringUtils.isNotBlank(search.getSearchApiName())) {
builder.and(q.apiName.containsIgnoreCase(search.getSearchApiName()));
}
if (StringUtils.isNotBlank(search.getSearchGwInstanceId())) {
builder.and(q.gwInstanceId.containsIgnoreCase(search.getSearchGwInstanceId()));
}
if (StringUtils.isNotBlank(search.getSearchBizDivCode())) {
builder.and(q.bizDivCode.containsIgnoreCase(search.getSearchBizDivCode()));
}
if (StringUtils.isNotBlank(search.getSearchClientId())) {
builder.and(q.clientId.containsIgnoreCase(search.getSearchClientId()));
}
if (StringUtils.isNotBlank(search.getSearchInboundAdapter())) {
builder.and(q.inboundAdapter.containsIgnoreCase(search.getSearchInboundAdapter()));
}
if (StringUtils.isNotBlank(search.getSearchOutboundAdapter())) {
builder.and(q.outboundAdapter.containsIgnoreCase(search.getSearchOutboundAdapter()));
}
return builder;
}
/**
* 조회 기간 계산 (최대 24개월 제한)
*/
private void calculateDateRange(ApiStatsSearch search) {
if (StringUtils.isBlank(search.getSearchStartDateTime())) {
return;
}
YearMonth startMonth = YearMonth.parse(search.getSearchStartDateTime(),
DateTimeFormatter.ofPattern("yyyyMM"));
YearMonth endMonth;
if (StringUtils.isNotBlank(search.getSearchEndDateTime())) {
endMonth = YearMonth.parse(search.getSearchEndDateTime(),
DateTimeFormatter.ofPattern("yyyyMM"));
// 12개월 초과 시 시작월 기준 12개월 후로 강제 설정
long monthsBetween = java.time.temporal.ChronoUnit.MONTHS.between(startMonth, endMonth);
if (monthsBetween > MAX_MONTHS) {
endMonth = startMonth.plusMonths(MAX_MONTHS);
}
} else {
endMonth = startMonth.plusMonths(MAX_MONTHS);
}
search.setParsedStartMonth(startMonth.format(DateTimeFormatter.ofPattern("yyyyMM")));
search.setParsedEndMonth(endMonth.format(DateTimeFormatter.ofPattern("yyyyMM")));
}
}
@@ -0,0 +1,92 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.io.Serializable;
import java.math.BigDecimal;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.IdClass;
import javax.persistence.Table;
import lombok.Getter;
import lombok.Setter;
/**
* API Gateway 연간 처리 통계
*/
@Getter
@Setter
@Entity
@Table(name = "API_STATS_YEAR")
@IdClass(ApiStatsYearId.class)
public class ApiStatsYear implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@Column(name = "STAT_TIME", nullable = false, length = 4)
private String statTime; // YYYY format
@Id
@Column(name = "API_NAME", nullable = false, length = 100)
private String apiName;
@Id
@Column(name = "GW_INSTANCE_ID", nullable = false, length = 50)
private String gwInstanceId;
@Id
@Column(name = "BIZ_DIV_CODE", nullable = false, length = 50)
private String bizDivCode = "NONE";
@Id
@Column(name = "CLIENT_ID", nullable = false, length = 100)
private String clientId = "NONE";
@Id
@Column(name = "INBOUND_ADAPTER", nullable = false, length = 100)
private String inboundAdapter = "NONE";
@Id
@Column(name = "OUTBOUND_ADAPTER", nullable = false, length = 100)
private String outboundAdapter = "NONE";
@Column(name = "TOTAL_CNT", nullable = false)
private Long totalCnt = 0L;
@Column(name = "SUCCESS_CNT", nullable = false)
private Long successCnt = 0L;
@Column(name = "TIMEOUT_CNT", nullable = false)
private Long timeoutCnt = 0L;
@Column(name = "SYSTEM_ERR_CNT", nullable = false)
private Long systemErrCnt = 0L;
@Column(name = "BIZ_ERR_CNT", nullable = false)
private Long bizErrCnt = 0L;
@Column(name = "SEQ900_TIMEOUT_CNT", nullable = false)
private Long seq900TimeoutCnt = 0L;
@Column(name = "SEQ900_SYSTEM_ERR_CNT", nullable = false)
private Long seq900SystemErrCnt = 0L;
@Column(name = "SEQ900_BIZ_ERR_CNT", nullable = false)
private Long seq900BizErrCnt = 0L;
@Column(name = "AVG_RESP_TIME", precision = 10, scale = 3)
private BigDecimal avgRespTime = BigDecimal.ZERO;
@Column(name = "MIN_RESP_TIME", precision = 10, scale = 3)
private BigDecimal minRespTime = BigDecimal.ZERO;
@Column(name = "MAX_RESP_TIME", precision = 10, scale = 3)
private BigDecimal maxRespTime = BigDecimal.ZERO;
@Column(name = "P50_RESP_TIME", precision = 10, scale = 3)
private BigDecimal p50RespTime = BigDecimal.ZERO;
@Column(name = "P95_RESP_TIME", precision = 10, scale = 3)
private BigDecimal p95RespTime = BigDecimal.ZERO;
}
@@ -0,0 +1,25 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.io.Serializable;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* API 통계 연간 복합키
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class ApiStatsYearId implements Serializable {
private static final long serialVersionUID = 1L;
private String statTime; // YYYY format
private String apiName;
private String gwInstanceId;
private String bizDivCode;
private String clientId;
private String inboundAdapter;
private String outboundAdapter;
}
@@ -0,0 +1,10 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import com.eactive.eai.data.jpa.BaseRepository;
/**
* API 통계 연간 Repository
*/
interface ApiStatsYearRepository extends BaseRepository<ApiStatsYear, ApiStatsYearId> {
}
@@ -0,0 +1,143 @@
package com.eactive.eai.rms.data.entity.onl.kjb.statistics;
import java.time.Year;
import java.util.List;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.jpa.AbstractDataService;
import com.eactive.ext.kjb.statistics.ui.ApiStatsChartUI;
import com.eactive.ext.kjb.statistics.ui.ApiStatsSearch;
import com.querydsl.core.BooleanBuilder;
import com.querydsl.core.types.Projections;
@Service
@Transactional
public class ApiStatsYearService
extends AbstractDataService<ApiStatsYear, ApiStatsYearId, ApiStatsYearRepository> {
public Page<ApiStatsYear> selectList(ApiStatsSearch search, Pageable pageable) {
QApiStatsYear q = QApiStatsYear.apiStatsYear;
BooleanBuilder builder = buildSearchConditions(q, search);
return repository.findAll(builder, pageable);
}
public List<ApiStatsYear> selectListForExcel(ApiStatsSearch search) {
QApiStatsYear q = QApiStatsYear.apiStatsYear;
BooleanBuilder builder = buildSearchConditions(q, search);
return getJPAQueryFactory()
.selectFrom(q)
.where(builder)
.orderBy(q.statTime.desc())
.fetch();
}
public List<ApiStatsChartUI> selectChartData(ApiStatsSearch search) {
QApiStatsYear q = QApiStatsYear.apiStatsYear;
BooleanBuilder builder = new BooleanBuilder();
calculateDateRange(search);
if (search.getParsedStartYear() != null) {
builder.and(q.statTime.goe(search.getParsedStartYear()));
builder.and(q.statTime.loe(search.getParsedEndYear()));
}
if (StringUtils.isNotBlank(search.getSearchApiName())) {
builder.and(q.apiName.containsIgnoreCase(search.getSearchApiName()));
}
if (StringUtils.isNotBlank(search.getSearchGwInstanceId())) {
builder.and(q.gwInstanceId.containsIgnoreCase(search.getSearchGwInstanceId()));
}
if (StringUtils.isNotBlank(search.getSearchBizDivCode())) {
builder.and(q.bizDivCode.containsIgnoreCase(search.getSearchBizDivCode()));
}
if (StringUtils.isNotBlank(search.getSearchClientId())) {
builder.and(q.clientId.containsIgnoreCase(search.getSearchClientId()));
}
return getJPAQueryFactory()
.select(Projections.constructor(ApiStatsChartUI.class,
q.statTime,
q.totalCnt.sum(),
q.successCnt.sum(),
q.timeoutCnt.sum(),
q.systemErrCnt.sum(),
q.bizErrCnt.sum(),
q.seq900TimeoutCnt.sum(),
q.seq900SystemErrCnt.sum(),
q.seq900BizErrCnt.sum(),
q.avgRespTime.avg(),
q.p50RespTime.avg(),
q.p95RespTime.avg()))
.from(q)
.where(builder)
.groupBy(q.statTime)
.orderBy(q.statTime.asc())
.fetch();
}
private BooleanBuilder buildSearchConditions(QApiStatsYear q, ApiStatsSearch search) {
BooleanBuilder builder = new BooleanBuilder();
calculateDateRange(search);
if (search.getParsedStartYear() != null) {
builder.and(q.statTime.goe(search.getParsedStartYear()));
builder.and(q.statTime.loe(search.getParsedEndYear()));
}
if (StringUtils.isNotBlank(search.getSearchApiName())) {
builder.and(q.apiName.containsIgnoreCase(search.getSearchApiName()));
}
if (StringUtils.isNotBlank(search.getSearchGwInstanceId())) {
builder.and(q.gwInstanceId.containsIgnoreCase(search.getSearchGwInstanceId()));
}
if (StringUtils.isNotBlank(search.getSearchBizDivCode())) {
builder.and(q.bizDivCode.containsIgnoreCase(search.getSearchBizDivCode()));
}
if (StringUtils.isNotBlank(search.getSearchClientId())) {
builder.and(q.clientId.containsIgnoreCase(search.getSearchClientId()));
}
if (StringUtils.isNotBlank(search.getSearchInboundAdapter())) {
builder.and(q.inboundAdapter.containsIgnoreCase(search.getSearchInboundAdapter()));
}
if (StringUtils.isNotBlank(search.getSearchOutboundAdapter())) {
builder.and(q.outboundAdapter.containsIgnoreCase(search.getSearchOutboundAdapter()));
}
return builder;
}
/**
* 조회 기간 계산
*/
private void calculateDateRange(ApiStatsSearch search) {
if (StringUtils.isBlank(search.getSearchStartDateTime())) {
return;
}
Year startYear = Year.parse(search.getSearchStartDateTime());
Year endYear;
if (StringUtils.isNotBlank(search.getSearchEndDateTime())) {
endYear = Year.parse(search.getSearchEndDateTime());
} else {
endYear = Year.now();
}
search.setParsedStartYear(String.valueOf(startYear.getValue()));
search.setParsedEndYear(String.valueOf(endYear.getValue()));
}
}