Merge remote-tracking branch 'origin/feat/infer_dev_260107' into feat/infer_dev_260107

2026-01-22 13:42:53 +09:00
parent d92b38b9d5 e0822347c9
commit 186c20d6e3
6 changed files with 138 additions and 133 deletions
--- a/src/main/java/com/kamco/cd/kamcoback/Innopam/InnopamApiController.java
+++ b/src/main/java/com/kamco/cd/kamcoback/Innopam/InnopamApiController.java
@@ -1,11 +1,17 @@
 package com.kamco.cd.kamcoback.Innopam;

+import com.kamco.cd.kamcoback.Innopam.dto.ChngDetectMastDto;
+import com.kamco.cd.kamcoback.Innopam.dto.ChngDetectMastDto.ChnDetectMastReqDto;
+import com.kamco.cd.kamcoback.Innopam.dto.ChngDetectMastDto.ChngDetectMastSearchDto;
+import com.kamco.cd.kamcoback.Innopam.dto.ChngDetectMastDto.ResReturn;
 import com.kamco.cd.kamcoback.Innopam.dto.DetectMastDto;
 import com.kamco.cd.kamcoback.Innopam.dto.DetectMastDto.Basic;
 import com.kamco.cd.kamcoback.Innopam.dto.DetectMastDto.DetectMastReq;
 import com.kamco.cd.kamcoback.Innopam.dto.DetectMastDto.DetectMastSearch;
 import com.kamco.cd.kamcoback.Innopam.dto.DetectMastDto.FeaturePnuDto;
 import com.kamco.cd.kamcoback.Innopam.service.DetectMastService;
+import com.kamco.cd.kamcoback.Innopam.service.InnopamApiService;
+import com.kamco.cd.kamcoback.config.api.ApiResponseDto;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.media.Content;
@@ -26,13 +32,13 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;

-@Tag(name = "이노펨 mockup API", description = "이노펨 mockup API")
+@Tag(name = "이노펨 연동 API", description = "이노펨 연동 API")
@RestController
@RequiredArgsConstructor
-@RequestMapping("/api/kcd/cdi/detect")
+@RequestMapping("/api/innopam/")
 public class InnopamApiController {

-  private final DetectMastService detectMastService;
+  private final InnopamApiService innopamApiService;

  /** 탐지결과 등록 */
  @Operation(summary = "탐지결과 등록", description = "탐지결과 등록")
@@ -49,142 +55,57 @@ public class InnopamApiController {
        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
      })
  @PostMapping("/mast/regist")
-  public DetectMastReq setChangeDetection(
-      @RequestBody @Valid DetectMastDto.DetectMastReq detectMast) {
-    detectMastService.saveDetectMast(detectMast);
-    return detectMast;
+  public ChngDetectMastDto.Basic regist(
+      @RequestBody @Valid ChngDetectMastDto.ChnDetectMastReqDto chnDetectMastReq) {
+      //innopamApiService.saveDetectMast(chnDetectMastReq);
+    return innopamApiService.regist(chnDetectMastReq);
  }

+
  @Operation(summary = "탐지결과 삭제", description = "탐지결과 삭제")
  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "201",
-            description = "등록 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = DetectMastReq.class))),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
+    value = {
+      @ApiResponse(
+        responseCode = "201",
+        description = "등록 성공",
+        content =
+        @Content(
+          mediaType = "application/json",
+          schema = @Schema(implementation = ChnDetectMastReqDto.class))),
+      @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
+      @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
+    })
  @PostMapping("/mast/remove")
-  public String deleteChangeDetection(@RequestBody DetectMastReq detectMast) {
-    return "OK";
+  public ResReturn remove(
+    @RequestBody @Valid ChngDetectMastDto.ChnDetectMastReqDto chnDetectMastReq) {
+    return innopamApiService.remove(chnDetectMastReq);
  }

  @Operation(summary = "탐지결과 등록목록 조회", description = "탐지결과 등록목록 조회")
  @GetMapping("/mast/list")
  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "200",
-            description = "목록 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = Basic.class))),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  public List<Basic> selectChangeDetectionList(
-      @RequestParam(required = false) String cprsBfYr,
-      @RequestParam(required = false) String cprsAdYr,
-      @RequestParam(required = false) Integer dtctSno) {
-    DetectMastSearch detectMastSearch = new DetectMastSearch();
-    detectMastSearch.setCprsAdYr(cprsAdYr);
-    detectMastSearch.setCprsBfYr(cprsBfYr);
-    detectMastSearch.setDtctSno(dtctSno);
-    return detectMastService.selectDetectMast(detectMastSearch);
+    value = {
+      @ApiResponse(
+        responseCode = "200",
+        description = "목록 성공",
+        content =
+        @Content(
+          mediaType = "application/json",
+          schema = @Schema(implementation = Basic.class))),
+      @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
+      @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
+    })
+  public List<ChngDetectMastDto.Basic> selectChangeDetectionList(
+    @RequestParam(required = false) String chnDtctId,
+    @RequestParam(required = false) String cprsYr,
+    @RequestParam(required = false) String crtrYr,
+    @RequestParam(required = false) String chnDtctSno) {
+      ChngDetectMastSearchDto searchDto = new ChngDetectMastSearchDto();
+      searchDto.setChnDtctId(chnDtctId);
+      searchDto.setCprsYr(cprsYr);
+      searchDto.setCrtrYr(crtrYr);
+      searchDto.setChnDtctSno(chnDtctSno);
+    return innopamApiService.list(searchDto);
  }

-  @Operation(summary = "탐지결과 등록목록 상세 조회", description = "탐지결과 등록목록 상세 조회")
-  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "200",
-            description = "목록 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = Basic.class))),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  @GetMapping("/mast/list/{dtctMstId}")
-  public Basic selectChangeDetectionDetail(@PathVariable Long dtctMstId) {
-    return detectMastService.selectDetectMast(dtctMstId);
-  }
-
-  @Operation(summary = "탐지객체 랜덤 PNU 리스트 조회", description = "탐지객체 PNU 랜덤값을 생성해서 보여준다")
-  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "200",
-            description = "목록 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = FeaturePnuDto.class))),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  @GetMapping("/pnu/{cprsBfYr}/{cprsAfYr}/{dtctSno}")
-  public List<FeaturePnuDto> selectPnuList(
-      @PathVariable String cprsBfYr, @PathVariable String cprsAfYr, @PathVariable Integer dtctSno) {
-    DetectMastSearch detectMastSearch = new DetectMastSearch();
-    detectMastSearch.setCprsAdYr(cprsAfYr);
-    detectMastSearch.setCprsBfYr(cprsBfYr);
-    detectMastSearch.setDtctSno(dtctSno);
-    return detectMastService.findPnuData(detectMastSearch);
-  }
-
-  @Operation(summary = "탐지객체 랜덤 PNU 상세 조회", description = "탐지객체 PNU 랜덤값을 생성해서 보여준다")
-  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "200",
-            description = "목록 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = FeaturePnuDto.class))),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  @GetMapping("/pnu/{cprsBfYr}/{cprsAfYr}/{dtctSno}/{featureId}")
-  public FeaturePnuDto selectPnuDetail(
-      @Parameter(description = "이전년도", example = "2022") @PathVariable String cprsBfYr,
-      @Parameter(description = "기준년도", example = "2024") @PathVariable String cprsAfYr,
-      @Parameter(description = "회차", example = "4") @PathVariable Integer dtctSno,
-      @Parameter(description = "featureId", example = "000e161b-1955-4c89-ad87-0b3b4a91d00f")
-          @PathVariable
-          UUID featureId) {
-    return detectMastService.selectPnuDetail(featureId);
-  }
-
-  @Operation(
-      summary = "탐지객체 랜덤 PNU GEOM 업데이트(이노펨에 없는 API)",
-      description = "탐지객체 랜덤 PNU GEOM 업데이트(이노펨에 없는 API)")
-  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "201",
-            description = "pnu 업데이트 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = Integer.class))),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  @PutMapping("/pnu/{cprsBfYr}/{cprsAfYr}/{dtctSno}")
-  public Integer updatePnuList(
-      @PathVariable String cprsBfYr, @PathVariable String cprsAfYr, @PathVariable Integer dtctSno) {
-    DetectMastSearch detectMastSearch = new DetectMastSearch();
-    detectMastSearch.setCprsAdYr(cprsAfYr);
-    detectMastSearch.setCprsBfYr(cprsBfYr);
-    detectMastSearch.setDtctSno(dtctSno);
-    return detectMastService.updatePnuData(detectMastSearch);
-  }
 }
--- a/src/main/java/com/kamco/cd/kamcoback/common/utils/FIleChecker.java
+++ b/src/main/java/com/kamco/cd/kamcoback/common/utils/FIleChecker.java
@@ -439,6 +439,7 @@ public class FIleChecker {
                    String parentPath = path.getParent().toString();
                    String fullPath = path.toAbsolutePath().toString();

+
                    File file = new File(fullPath);
                    long fileSize = file.length();
                    String lastModified = dttmFormat.format(new Date(file.lastModified()));
--- a/src/main/java/com/kamco/cd/kamcoback/config/resttemplate/ExternalHttpClient.java
+++ b/src/main/java/com/kamco/cd/kamcoback/config/resttemplate/ExternalHttpClient.java
@@ -1,5 +1,7 @@
 package com.kamco.cd.kamcoback.config.resttemplate;

+import java.net.InetAddress;
+import java.net.UnknownHostException;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.http.HttpEntity;
@@ -69,4 +71,6 @@ public class ExternalHttpClient {
  }

  public record ExternalCallResult<T>(int statusCode, boolean success, T body) {}
+
+
 }
--- a/src/main/java/com/kamco/cd/kamcoback/inference/dto/InferenceResultDto.java
+++ b/src/main/java/com/kamco/cd/kamcoback/inference/dto/InferenceResultDto.java
@@ -538,14 +538,15 @@ public class InferenceResultDto {

    public String getServerStatus() {
      String enumId = "SAFETY";
+      if( this.cpu_user+this.cpu_system+this.gpuUtil+this.kbmemused == 0 )enumId = "FAILUR";
      // if( this.cpu_user+this.cpu_system >= 80 )enumId = "CAUTION";
      return enumId;
    }

    public String getServerStatusName() {
-      // String enumId = "SAFETY";
-      // if( this.cpu_user+this.cpu_system >= 80 )enumId = "CAUTION";
-      return ServerStatus.SAFETY.getText();
+      String enumStr = ServerStatus.SAFETY.getText();
+      if( this.cpu_user+this.cpu_system+this.gpuUtil+this.kbmemused == 0 )enumStr = ServerStatus.FAILUR.getText();
+      return enumStr;
    }

    public String getCpuStatus() {
@@ -553,6 +554,9 @@ public class InferenceResultDto {
      if (this.cpu_user + this.cpu_system >= 80) {
        enumId = "CAUTION";
      }
+      else if (this.cpu_user + this.cpu_system + this.memused == 0) {
+        enumId = "FAILUR";
+      }
      return enumId;
    }

@@ -561,6 +565,9 @@ public class InferenceResultDto {
      if (this.gpuUtil >= 80) {
        enumId = "CAUTION";
      }
+      else if (this.cpu_user + this.cpu_system == 0) {
+        enumId = "FAILUR";
+      }
      return enumId;
    }

@@ -569,6 +576,9 @@ public class InferenceResultDto {
      if (this.memused >= 80) {
        enumId = "CAUTION";
      }
+      else if (this.cpu_user + this.cpu_system + this.memused == 0) {
+        enumId = "FAILUR";
+      }
      return enumId;
    }

@@ -576,6 +586,9 @@ public class InferenceResultDto {
      if (this.cpu_user + this.cpu_system >= 80) {
        return ServerStatus.CAUTION.getText();
      }
+      else if (this.cpu_user + this.cpu_system + this.memused == 0) {
+        return ServerStatus.FAILUR.getText();
+      }
      return ServerStatus.SAFETY.getText();
    }

@@ -583,6 +596,9 @@ public class InferenceResultDto {
      if (this.gpuUtil >= 80) {
        return ServerStatus.CAUTION.getText();
      }
+      else if (this.cpu_user + this.cpu_system + this.memused == 0) {
+        return ServerStatus.FAILUR.getText();
+      }
      return ServerStatus.SAFETY.getText();
    }

@@ -590,6 +606,9 @@ public class InferenceResultDto {
      if (this.memused >= 80) {
        return ServerStatus.CAUTION.getText();
      }
+      else if (this.cpu_user + this.cpu_system + this.memused == 0) {
+        return ServerStatus.FAILUR.getText();
+      }
      return ServerStatus.SAFETY.getText();
    }
  }
--- a/src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java
+++ b/src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java
@@ -1,5 +1,8 @@
 package com.kamco.cd.kamcoback.inference.service;

+import static com.kamco.cd.kamcoback.postgres.entity.QGpuMetricEntity.gpuMetricEntity;
+import static com.kamco.cd.kamcoback.postgres.entity.QSystemMetricEntity.systemMetricEntity;
+
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -41,6 +44,7 @@ import jakarta.validation.constraints.NotNull;
 import java.nio.file.Path;
 import java.time.ZonedDateTime;
 import java.util.ArrayList;
+import java.util.Comparator;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -514,7 +518,59 @@ public class InferenceResultService {
  }

  public List<InferenceServerStatusDto> getInferenceServerStatusList() {
-    return inferenceResultCoreService.getInferenceServerStatusList();
+
+    List<InferenceServerStatusDto> dtoList = inferenceResultCoreService.getInferenceServerStatusList();
+    int size = dtoList.size();
+
+    System.out.println("size ="+size);
+
+    if( size == 0 )
+    {
+      for(int k=1; k<=4; k++)
+      {
+        InferenceServerStatusDto dto = new InferenceServerStatusDto();
+        dto.setServerName("server0"+k);
+        dto.setCpu_user(0);
+        dto.setCpu_system(0);
+        dto.setMemused(0);
+        dto.setKbmemused(0L);
+        dto.setGpuUtil(0);
+
+        dtoList.add(dto);
+      }
+    }
+    else
+    {
+      for(int k=1; k<=4; k++)
+      {
+        String srvNm = "server"+k;
+        String srvNmChk = "N";
+        for (InferenceServerStatusDto dto : dtoList) {
+          if( srvNm.equals(dto.getServerName()) ){
+            srvNmChk = "Y";
+            break;
+          }
+        }
+
+        if( srvNmChk.equals("N") )
+        {
+          InferenceServerStatusDto dto = new InferenceServerStatusDto();
+          dto.setServerName(srvNm);
+          dto.setCpu_user(0);
+          dto.setCpu_system(0);
+          dto.setMemused(0);
+          dto.setKbmemused(0L);
+          dto.setGpuUtil(0);
+          dtoList.add(dto);
+        }
+
+      }
+
+    }
+
+    dtoList.sort(Comparator.comparing(InferenceServerStatusDto::getServerName));
+
+    return dtoList;
  }

  /**
--- a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java
+++ b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java
@@ -121,6 +121,8 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto
        queryFactory
            .select(systemMetricEntity.timestamp.max())
            .from(systemMetricEntity)
+             .where(systemMetricEntity.timestamp.goe(OffsetDateTime.now().minusMinutes(5)))
+             //.where(systemMetricEntity.timestamp.goe(OffsetDateTime.now().minusSeconds(30)))
            .groupBy(systemMetricEntity.serverName)
            .fetch();

@@ -128,6 +130,8 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto
        queryFactory
            .select(gpuMetricEntity.timestamp.max())
            .from(gpuMetricEntity)
+            .where(gpuMetricEntity.timestamp.goe(OffsetDateTime.now().minusMinutes(5)))
+            //.where(gpuMetricEntity.timestamp.goe(OffsetDateTime.now().minusSeconds(30)))
            .groupBy(gpuMetricEntity.serverName)
            .fetch();