Feature/frb 156

src/main/java/com/factoreal/backend/controller/SystemLogController.java

@@ -0,0 +1,31 @@
+package com.factoreal.backend.controller;
+
+import com.factoreal.backend.dto.abnormalLog.AbnormalPagingDto;
+import com.factoreal.backend.dto.abnormalLog.SystemLogResponseDto;
+import com.factoreal.backend.service.AbnormalLogService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@Tag(name = "시스템 로그 API", description = "공간별 시스템 로그 조회 API")
+@RestController
+@RequestMapping("/api/system-logs")
+@RequiredArgsConstructor
+public class SystemLogController {
+    private final AbnormalLogService abnormalLogService;
+
+    @Operation(summary = "공간별 시스템 로그 조회", description = "특정 공간(zone)의 시스템 로그를 페이징 처리하여 조회합니다.")
+    @GetMapping("/zone/{zoneId}")
+    public ResponseEntity<Page<SystemLogResponseDto>> getSystemLogsByZone(
+            @Parameter(description = "조회할 공간 ID", required = true) 
+            @PathVariable String zoneId,
+            @Parameter(description = "페이징 정보 (page: 페이지 번호, size: 페이지 크기)") 
+            @ModelAttribute AbnormalPagingDto pagingDto) {
+        Page<SystemLogResponseDto> logs = abnormalLogService.findSystemLogsByZoneId(zoneId, pagingDto);
+        return ResponseEntity.ok(logs);
+    }
+} 

src/main/java/com/factoreal/backend/controller/WorkerController.java

@@ -0,0 +1,48 @@
+package com.factoreal.backend.controller;
+
+import com.factoreal.backend.dto.WorkerDto;
+import com.factoreal.backend.dto.ZoneManagerResponseDto;
+import com.factoreal.backend.service.WorkerService;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/workers")
+@RequiredArgsConstructor
+@Slf4j
+@Tag(name = "작업자 API", description = "작업자 조회 API")
+public class WorkerController {
+    private final WorkerService workerService;
+
+    @Operation(summary = "전체 작업자 목록 조회", description = "전체 작업자 목록을 조회합니다.")
+    @GetMapping
+    public ResponseEntity<List<WorkerDto>> getAllWorkers() {
+        log.info("전체 작업자 목록 조회 요청");
+        List<WorkerDto> workers = workerService.getAllWorkers();
+        return ResponseEntity.ok(workers);
+    }
+
+    @Operation(summary = "공간별 작업자 목록 조회", description = "공간 ID를 기반으로 현재 해당 공간에 들어가있는 작업자 리스트를 조회합니다.")
+    @GetMapping("/zone/{zoneId}")
+    public ResponseEntity<List<WorkerDto>> getWorkersByZoneId(@PathVariable String zoneId) {
+        log.info("공간 ID: {}의 작업자 목록 조회 요청", zoneId);
+        List<WorkerDto> zoneWorkers = workerService.getWorkersByZoneId(zoneId);
+        return ResponseEntity.ok(zoneWorkers);
+    }
+
+    @Operation(summary = "공간 담당자 정보 조회", 
+              description = "공간 ID를 기반으로 해당 공간의 담당자와 현재 위치 정보를 조회합니다.")
+    @GetMapping("/zone/{zoneId}/manager")
+    public ResponseEntity<ZoneManagerResponseDto> getZoneManager(@PathVariable String zoneId) {
+        log.info("공간 ID: {}의 담당자 정보 조회 요청", zoneId);
+        ZoneManagerResponseDto manager = workerService.getZoneManagerWithLocation(zoneId);
+        return ResponseEntity.ok(manager);
+    }
+} 

src/main/java/com/factoreal/backend/controller/WorkerLocationController.java

@@ -0,0 +1,36 @@
+package com.factoreal.backend.controller;
+
+import com.factoreal.backend.dto.WorkerLocationRequest;
+import com.factoreal.backend.service.WorkerLocationService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import java.time.LocalDateTime;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@Slf4j
+@Tag(name = "작업자 위치 API", description = "작업자의 실시간 위치 정보를 관리하는 API")
+@RestController
+@RequestMapping("/api/worker-locations")
+@RequiredArgsConstructor
+// 웨어러블 디바이스에서 받아오는 데이터를 업데이트하는 컨트롤러
+public class WorkerLocationController {
+
+    private final WorkerLocationService workerLocationService;
+
+    @Operation(summary = "작업자 위치 업데이트", description = "웨어러블 디바이스로부터 받은 작업자의 위치 정보를 업데이트합니다.")
+    @PostMapping("/update")
+    public ResponseEntity<Void> updateWorkerLocation(@RequestBody WorkerLocationRequest request) {
+        log.info("작업자 위치 업데이트 요청: {}", request);
+        workerLocationService.updateWorkerLocation(
+                request.getWorkerId(),
+                request.getZoneId(),
+                request.getTimestamp() != null ? request.getTimestamp() : LocalDateTime.now()
+        );
+        return ResponseEntity.ok().build(); // 200 OK 응답
+    }
+}

src/main/java/com/factoreal/backend/dto/WorkerDto.java

@@ -0,0 +1,30 @@
+package com.factoreal.backend.dto;
+
+import com.factoreal.backend.entity.Worker;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class WorkerDto {
+    private String workerId;
+    private String name;
+    private String phoneNumber;
+    private String email;
+    private Boolean isManager; // 관리자 여부
+
+    // Entity -> DTO 변환
+    public static WorkerDto fromEntity(Worker worker, Boolean isManager) {
+        return WorkerDto.builder()
+                .workerId(worker.getWorkerId())
+                .name(worker.getName())
+                .phoneNumber(worker.getPhoneNumber())
+                .email(worker.getEmail())
+                .isManager(isManager)
+                .build();
+    }
+} 

src/main/java/com/factoreal/backend/dto/WorkerLocationRequest.java

@@ -0,0 +1,17 @@
+package com.factoreal.backend.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Setter
+@ToString
+// Wearable 장치에서 받아오는 데이터 by 우영. 추후 논의 예정
+public class WorkerLocationRequest {
+    private String workerId;
+    private String zoneId;
+    private LocalDateTime timestamp; // 장치에서 받아오는 데이터
+}

src/main/java/com/factoreal/backend/dto/ZoneManagerResponseDto.java

@@ -0,0 +1,33 @@
+package com.factoreal.backend.dto;
+
+import com.factoreal.backend.entity.Worker;
+import com.factoreal.backend.entity.Zone;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+// 공간 담당자 정보 조회 시 사용되는 DTO (BE -> FE)
+public class ZoneManagerResponseDto {
+    private String workerId;          // 작업자 ID
+    private String name;              // 작업자 이름
+    private String phoneNumber;       // 연락처
+    private String email;             // 이메일
+    private String currentZoneId;     // 현재 위치한 공간 ID
+    private String currentZoneName;   // 현재 위치한 공간 이름
+
+    public static ZoneManagerResponseDto fromEntity(Worker worker, Zone currentZone) {
+        return ZoneManagerResponseDto.builder()
+                .workerId(worker.getWorkerId())
+                .name(worker.getName())
+                .phoneNumber(worker.getPhoneNumber())
+                .email(worker.getEmail())
+                .currentZoneId(currentZone != null ? currentZone.getZoneId() : null)
+                .currentZoneName(currentZone != null ? currentZone.getZoneName() : null)
+                .build();
+    }
+} 

src/main/java/com/factoreal/backend/dto/abnormalLog/AbnormalPagingDto.java

@@ -1,9 +1,14 @@
 package com.factoreal.backend.dto.abnormalLog;
 
+import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 
 @Data
+@Schema(description = "페이징 정보 DTO")
 public class AbnormalPagingDto {
+    @Schema(description = "페이지 번호 (0부터 시작)", example = "0")
     private int page;
+
+    @Schema(description = "페이지 크기", example = "10")
     private int size;
 }

src/main/java/com/factoreal/backend/dto/abnormalLog/SystemLogResponseDto.java

@@ -0,0 +1,75 @@
+package com.factoreal.backend.dto.abnormalLog;
+
+import com.factoreal.backend.entity.AbnormalLog;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class SystemLogResponseDto {
+    private String zoneId;
+    private String targetType;
+    private String sensorType;
+    private int dangerLevel;
+    private double value;
+    private LocalDateTime timestamp;
+    private String abnormalType;
+    private String targetId;
+
+    public static SystemLogResponseDto fromEntity(AbnormalLog abnormalLog) {
+        return SystemLogResponseDto.builder()
+                .zoneId(abnormalLog.getZone().getZoneId())
+                .targetType(convertLogTypeToKorean(abnormalLog.getTargetType()))
+                .sensorType(abnormalLog.getTargetType().toString())
+                .dangerLevel(calculateDangerLevel(abnormalLog.getAbnormalType()))
+                .value(abnormalLog.getAbnVal())
+                .timestamp(abnormalLog.getDetectedAt())
+                .abnormalType(abnormalLog.getAbnormalType())
+                .targetId(abnormalLog.getTargetId())
+                .build();
+    }
+
+    private static String convertLogTypeToKorean(LogType logType) {
+        return switch (logType) {
+            case Sensor -> "환경";
+            case Worker -> "작업자";
+            case Equip -> "설비";
+        };
+    }
+
+    private static int calculateDangerLevel(String abnormalType) {
+        if (abnormalType.contains("위험")) return 2;
+        if (abnormalType.contains("주의")) return 1;
+        return 0;
+    }
+} 
+
+/**
+ * {
+  "content": [
+    {
+      "zoneId": "zone123",
+      "targetType": "환경",  // 또는 "작업자", "설비"
+       "sensorType": "TEMPERATURE",
+       "dangerLevel": 2,
+       "value": 35.5,
+       "timestamp": "2024-03-20T14:30:00",
+       "abnormalType": "온도 위험",
+       "targetId": "sensor456"
+    }
+    // ... 더 많은 로그
+  ],
+  "pageable": {
+    "pageNumber": 0,
+    "pageSize": 10
+  },
+  "totalElements": 50,
+  "totalPages": 5
+}
+ */

src/main/java/com/factoreal/backend/entity/AbnormalLog.java

@@ -30,7 +30,8 @@ public class AbnormalLog {
     private String targetId; // 고유 ID : 센서ID, WorkerID, EquipID
 
     @Column(name = "abnormal_type", length = 100)
-    private String abnormalType; // 이상 유형 : (예: 심박수 이상, 온도 초과, 진동 이상 등)
+    private String abnormalType; // 이상 유형 : (예: 심박수 위험, 온도 초과 위험, 진동 주의 등)
+                                 // 이상은 위험과 주의로 구분이 애매하므로 명확한 표현 필요
 
     @Column(name = "abn_val")
     private Double abnVal; // 이상치 값

src/main/java/com/factoreal/backend/kafka/KafkaConsumerD.java

@@ -71,7 +71,7 @@ public void consume(String message) {
             SensorKafkaDto dto = objectMapper.readValue(message, SensorKafkaDto.class);
 
             // 시스템 로그 (위험도 변화 감지 -> 비동기 전송)
-            sendSystemLog(dto);
+            // sendSystemLog(dto);
 
             // 공간 센서일 때만 히트맵용 웹소켓 전송
             if (dto.getEquipId() != null && dto.getZoneId() != null && dto.getEquipId().equals(dto.getZoneId())) {
@@ -164,6 +164,7 @@ public void startAlarm(SensorKafkaDto sensorData, AbnormalLog abnormalLog, RiskL
 
     // 공간(zone)별 위험도 변경 시 시스템 로그 전송
     @Async
+    @Deprecated
     public void sendSystemLog(SensorKafkaDto dto) {
         String zoneId = dto.getZoneId();
         int newLevel = getDangerLevel(dto.getSensorType(), dto.getVal());

src/main/java/com/factoreal/backend/repository/AbnLogRepository.java

@@ -12,4 +12,7 @@ public interface AbnLogRepository extends JpaRepository<AbnormalLog,Long> {
     long countByIsReadFalse(); // 읽지 않은 로그의 개수 반환
 
     Page<AbnormalLog> findAllByIsReadIsFalse(Pageable pageable);
+
+    // zoneId로 페이징 처리된 로그 조회
+    Page<AbnormalLog> findByZone_ZoneIdOrderByDetectedAtDesc(String zoneId, Pageable pageable);
 }

src/main/java/com/factoreal/backend/repository/WorkerZoneRepository.java

@@ -0,0 +1,17 @@
+package com.factoreal.backend.repository;
+
+import com.factoreal.backend.entity.WorkerZone;
+import com.factoreal.backend.entity.WorkerZoneId;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface WorkerZoneRepository extends JpaRepository<WorkerZone, WorkerZoneId> {
+
+    // 특정 zone_id에 속한 작업자 목록 조회
+    List<WorkerZone> findByZoneZoneId(String zoneId);
+
+    // 특정 zone_id의 담당자 조회 (manageYn = true)
+    Optional<WorkerZone> findByZoneZoneIdAndManageYnIsTrue(String zoneId);
+} 

src/main/java/com/factoreal/backend/repository/ZoneHistRepository.java

@@ -0,0 +1,14 @@
+package com.factoreal.backend.repository;
+
+import com.factoreal.backend.entity.ZoneHist;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface ZoneHistRepository extends JpaRepository<ZoneHist, Long> {
+    // 특정 공간에 현재 있는 작업자들 조회 (existFlag = 1)
+    List<ZoneHist> findByZone_ZoneIdAndExistFlag(String zoneId, Integer existFlag);
+
+    // 특정 작업자의 현재 위치 조회 (existFlag = 1)
+    ZoneHist findByWorker_WorkerIdAndExistFlag(String workerId, Integer existFlag);
+}