Macbook
94 lines
3.4 KiB
Java
94 lines
3.4 KiB
Java
package com.goldenchart.service;
|
|
|
|
import com.goldenchart.dto.VerificationIssueDto;
|
|
import com.goldenchart.entity.GcVerificationIssue;
|
|
import com.goldenchart.entity.VerificationIssueStage;
|
|
import com.goldenchart.repository.GcVerificationIssueRepository;
|
|
import com.goldenchart.websocket.VerificationIssueEventBroker;
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
import java.io.IOException;
|
|
import java.util.List;
|
|
import java.util.Optional;
|
|
|
|
@Service
|
|
@RequiredArgsConstructor
|
|
@Slf4j
|
|
public class VerificationIssueService {
|
|
|
|
private final GcVerificationIssueRepository repository;
|
|
private final VerificationIssueImageService imageService;
|
|
private final VerificationIssueEventBroker eventBroker;
|
|
|
|
public List<VerificationIssueDto> list(VerificationIssueStage stage) {
|
|
List<GcVerificationIssue> entities = stage != null
|
|
? repository.findByStageOrderByUpdatedAtDesc(stage)
|
|
: repository.findAllByOrderByUpdatedAtDesc();
|
|
return entities.stream().map(this::toDto).toList();
|
|
}
|
|
|
|
public Optional<VerificationIssueDto> findById(Long id) {
|
|
return repository.findById(id).map(this::toDto);
|
|
}
|
|
|
|
@Transactional
|
|
public VerificationIssueDto save(VerificationIssueDto dto, Long userId, String deviceId) {
|
|
GcVerificationIssue entity;
|
|
boolean isNew = dto.getId() == null;
|
|
VerificationIssueStage previousStage = null;
|
|
|
|
if (dto.getId() != null) {
|
|
entity = repository.findById(dto.getId()).orElseGet(GcVerificationIssue::new);
|
|
if (entity.getId() != null) {
|
|
previousStage = entity.getStage();
|
|
}
|
|
} else {
|
|
entity = new GcVerificationIssue();
|
|
entity.setUserId(userId);
|
|
entity.setDeviceId(deviceId);
|
|
}
|
|
|
|
entity.setTitle(dto.getTitle() != null ? dto.getTitle().trim() : "제목 없음");
|
|
entity.setContent(dto.getContent() != null ? dto.getContent() : "");
|
|
String path = dto.getReproductionPath();
|
|
entity.setReproductionPath(path != null && !path.isBlank() ? path.trim() : null);
|
|
entity.setStage(dto.getStage() != null ? dto.getStage() : VerificationIssueStage.REGISTERED);
|
|
|
|
GcVerificationIssue saved = repository.save(entity);
|
|
VerificationIssueDto result = toDto(saved);
|
|
|
|
if (isNew) {
|
|
eventBroker.publishCreated(result, deviceId);
|
|
} else if (previousStage != null && previousStage != saved.getStage()) {
|
|
eventBroker.publishStageChanged(result, previousStage, deviceId);
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
@Transactional
|
|
public void delete(Long id) {
|
|
try {
|
|
imageService.deleteAllForIssue(id);
|
|
} catch (IOException e) {
|
|
log.warn("issue image cleanup failed id={}: {}", id, e.getMessage());
|
|
}
|
|
repository.deleteById(id);
|
|
}
|
|
|
|
private VerificationIssueDto toDto(GcVerificationIssue e) {
|
|
return VerificationIssueDto.builder()
|
|
.id(e.getId())
|
|
.title(e.getTitle())
|
|
.content(e.getContent())
|
|
.reproductionPath(e.getReproductionPath())
|
|
.stage(e.getStage())
|
|
.createdAt(e.getCreatedAt())
|
|
.updatedAt(e.getUpdatedAt())
|
|
.build();
|
|
}
|
|
}
|