spotless 적용
This commit is contained in:
@@ -34,8 +34,7 @@ public class ApiResponseAdvice implements ResponseBodyAdvice<Object> {
|
|||||||
private final AuditLogRepository auditLogRepository;
|
private final AuditLogRepository auditLogRepository;
|
||||||
private final MenuService menuService;
|
private final MenuService menuService;
|
||||||
|
|
||||||
@Autowired
|
@Autowired private ObjectMapper objectMapper;
|
||||||
private ObjectMapper objectMapper;
|
|
||||||
|
|
||||||
public ApiResponseAdvice(AuditLogRepository auditLogRepository, MenuService menuService) {
|
public ApiResponseAdvice(AuditLogRepository auditLogRepository, MenuService menuService) {
|
||||||
this.auditLogRepository = auditLogRepository;
|
this.auditLogRepository = auditLogRepository;
|
||||||
@@ -44,19 +43,19 @@ public class ApiResponseAdvice implements ResponseBodyAdvice<Object> {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean supports(
|
public boolean supports(
|
||||||
MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType) {
|
MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType) {
|
||||||
// ApiResponseDto를 반환하는 경우에만 적용
|
// ApiResponseDto를 반환하는 경우에만 적용
|
||||||
return returnType.getParameterType().equals(ApiResponseDto.class);
|
return returnType.getParameterType().equals(ApiResponseDto.class);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Object beforeBodyWrite(
|
public Object beforeBodyWrite(
|
||||||
Object body,
|
Object body,
|
||||||
MethodParameter returnType,
|
MethodParameter returnType,
|
||||||
MediaType selectedContentType,
|
MediaType selectedContentType,
|
||||||
Class<? extends HttpMessageConverter<?>> selectedConverterType,
|
Class<? extends HttpMessageConverter<?>> selectedConverterType,
|
||||||
ServerHttpRequest request,
|
ServerHttpRequest request,
|
||||||
ServerHttpResponse response) {
|
ServerHttpResponse response) {
|
||||||
|
|
||||||
HttpServletRequest servletRequest = ((ServletServerHttpRequest) request).getServletRequest();
|
HttpServletRequest servletRequest = ((ServletServerHttpRequest) request).getServletRequest();
|
||||||
ContentCachingRequestWrapper contentWrapper = null;
|
ContentCachingRequestWrapper contentWrapper = null;
|
||||||
@@ -71,7 +70,7 @@ public class ApiResponseAdvice implements ResponseBodyAdvice<Object> {
|
|||||||
Long userid = null;
|
Long userid = null;
|
||||||
|
|
||||||
if (servletRequest.getUserPrincipal() instanceof UsernamePasswordAuthenticationToken auth
|
if (servletRequest.getUserPrincipal() instanceof UsernamePasswordAuthenticationToken auth
|
||||||
&& auth.getPrincipal() instanceof CustomUserDetails customUserDetails) {
|
&& auth.getPrincipal() instanceof CustomUserDetails customUserDetails) {
|
||||||
userid = customUserDetails.getMember().getId();
|
userid = customUserDetails.getMember().getId();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -92,29 +91,29 @@ public class ApiResponseAdvice implements ResponseBodyAdvice<Object> {
|
|||||||
|
|
||||||
List<?> list = menuService.getFindAll();
|
List<?> list = menuService.getFindAll();
|
||||||
List<MenuDto.Basic> result =
|
List<MenuDto.Basic> result =
|
||||||
list.stream()
|
list.stream()
|
||||||
.map(
|
.map(
|
||||||
item -> {
|
item -> {
|
||||||
if (item instanceof LinkedHashMap<?, ?> map) {
|
if (item instanceof LinkedHashMap<?, ?> map) {
|
||||||
return objectMapper.convertValue(map, MenuDto.Basic.class);
|
return objectMapper.convertValue(map, MenuDto.Basic.class);
|
||||||
} else if (item instanceof MenuDto.Basic dto) {
|
} else if (item instanceof MenuDto.Basic dto) {
|
||||||
return dto;
|
return dto;
|
||||||
} else {
|
} else {
|
||||||
throw new IllegalStateException("Unsupported cache type: " + item.getClass());
|
throw new IllegalStateException("Unsupported cache type: " + item.getClass());
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
.toList();
|
.toList();
|
||||||
|
|
||||||
AuditLogEntity log =
|
AuditLogEntity log =
|
||||||
new AuditLogEntity(
|
new AuditLogEntity(
|
||||||
userid,
|
userid,
|
||||||
ApiLogFunction.getEventType(servletRequest),
|
ApiLogFunction.getEventType(servletRequest),
|
||||||
ApiLogFunction.isSuccessFail(apiResponse),
|
ApiLogFunction.isSuccessFail(apiResponse),
|
||||||
ApiLogFunction.getUriMenuInfo(result, servletRequest.getRequestURI()),
|
ApiLogFunction.getUriMenuInfo(result, servletRequest.getRequestURI()),
|
||||||
ip,
|
ip,
|
||||||
servletRequest.getRequestURI(),
|
servletRequest.getRequestURI(),
|
||||||
ApiLogFunction.cutRequestBody(requestBody),
|
ApiLogFunction.cutRequestBody(requestBody),
|
||||||
apiResponse.getErrorLogUid());
|
apiResponse.getErrorLogUid());
|
||||||
auditLogRepository.save(log);
|
auditLogRepository.save(log);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -52,18 +52,15 @@ public class MapSheetMngFileJobCoreService {
|
|||||||
return new MapSheetMngDto.DmlReturn("success", saved.getFileUid().toString());
|
return new MapSheetMngDto.DmlReturn("success", saved.getFileUid().toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
public Long findByMngYyyyTargetMapSheetNotYetCount(int mngYyyy){
|
public Long findByMngYyyyTargetMapSheetNotYetCount(int mngYyyy) {
|
||||||
return mapSheetMngFileJobRepository.findByMngYyyyTargetMapSheetNotYetCount(mngYyyy);
|
return mapSheetMngFileJobRepository.findByMngYyyyTargetMapSheetNotYetCount(mngYyyy);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void mngDataState(int mngYyyy, String mngState)
|
public void mngDataState(int mngYyyy, String mngState) {
|
||||||
{
|
|
||||||
mapSheetMngFileJobRepository.mngDataState(mngYyyy, mngState);
|
mapSheetMngFileJobRepository.mngDataState(mngYyyy, mngState);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Integer findNotYetMapSheetMng()
|
public Integer findNotYetMapSheetMng() {
|
||||||
{
|
|
||||||
return mapSheetMngFileJobRepository.findNotYetMapSheetMng();
|
return mapSheetMngFileJobRepository.findNotYetMapSheetMng();
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -35,15 +35,18 @@ public class MapSheetMngFileJobRepositoryImpl extends QuerydslRepositorySupport
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Integer findNotYetMapSheetMng(){
|
public Integer findNotYetMapSheetMng() {
|
||||||
Integer countQuery =
|
Integer countQuery =
|
||||||
queryFactory
|
queryFactory
|
||||||
.select(mapSheetMngEntity.mngYyyy)
|
.select(mapSheetMngEntity.mngYyyy)
|
||||||
.from(mapSheetMngEntity)
|
.from(mapSheetMngEntity)
|
||||||
.where(mapSheetMngEntity.mngState.eq("NOTYET")
|
.where(
|
||||||
.or(mapSheetMngEntity.mngState.eq("PROCESSING")))
|
mapSheetMngEntity
|
||||||
.limit(1)
|
.mngState
|
||||||
.fetchOne();
|
.eq("NOTYET")
|
||||||
|
.or(mapSheetMngEntity.mngState.eq("PROCESSING")))
|
||||||
|
.limit(1)
|
||||||
|
.fetchOne();
|
||||||
|
|
||||||
return countQuery;
|
return countQuery;
|
||||||
}
|
}
|
||||||
@@ -121,27 +124,30 @@ public class MapSheetMngFileJobRepositoryImpl extends QuerydslRepositorySupport
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Long findByMngYyyyTargetMapSheetNotYetCount(int mngYyyy){
|
public Long findByMngYyyyTargetMapSheetNotYetCount(int mngYyyy) {
|
||||||
Long countQuery =
|
Long countQuery =
|
||||||
queryFactory
|
queryFactory
|
||||||
.select(mapSheetMngHstEntity.mngYyyy.count())
|
.select(mapSheetMngHstEntity.mngYyyy.count())
|
||||||
.from(mapSheetMngHstEntity)
|
.from(mapSheetMngHstEntity)
|
||||||
.where(mapSheetMngHstEntity.mngYyyy.eq(mngYyyy)
|
.where(
|
||||||
.and(mapSheetMngHstEntity.syncState.eq("NOTYET")))
|
mapSheetMngHstEntity
|
||||||
.fetchOne();
|
.mngYyyy
|
||||||
|
.eq(mngYyyy)
|
||||||
|
.and(mapSheetMngHstEntity.syncState.eq("NOTYET")))
|
||||||
|
.fetchOne();
|
||||||
|
|
||||||
return countQuery;
|
return countQuery;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void mngDataState(int mngYyyy, String mngState){
|
public void mngDataState(int mngYyyy, String mngState) {
|
||||||
long updateCount =
|
long updateCount =
|
||||||
queryFactory
|
queryFactory
|
||||||
.update(mapSheetMngEntity)
|
.update(mapSheetMngEntity)
|
||||||
.set(mapSheetMngEntity.mngState, mngState)
|
.set(mapSheetMngEntity.mngState, mngState)
|
||||||
.set(mapSheetMngEntity.syncState, mngState)
|
.set(mapSheetMngEntity.syncState, mngState)
|
||||||
.set(mapSheetMngEntity.syncCheckState, mngState)
|
.set(mapSheetMngEntity.syncCheckState, mngState)
|
||||||
.where(mapSheetMngEntity.mngYyyy.eq(mngYyyy))
|
.where(mapSheetMngEntity.mngYyyy.eq(mngYyyy))
|
||||||
.execute();
|
.execute();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void mngHstDataSyncStateUpdate(MapSheetMngDto.MngHstDto updateReq) {
|
public void mngHstDataSyncStateUpdate(MapSheetMngDto.MngHstDto updateReq) {
|
||||||
|
|||||||
@@ -23,21 +23,25 @@ public class MapSheetMngFileJobController {
|
|||||||
if (!isSchedulerEnabled) return;
|
if (!isSchedulerEnabled) return;
|
||||||
|
|
||||||
Integer mng = 0;
|
Integer mng = 0;
|
||||||
// isFileSyncSchedulerEnabled = false;
|
// isFileSyncSchedulerEnabled = false;
|
||||||
if(mapSheetMngFileJobService.checkMngFileSync() != null)
|
if (mapSheetMngFileJobService.checkMngFileSync() != null) {
|
||||||
{
|
|
||||||
mng = mapSheetMngFileJobService.checkMngFileSync();
|
mng = mapSheetMngFileJobService.checkMngFileSync();
|
||||||
this.isFileSyncSchedulerEnabled = true;
|
this.isFileSyncSchedulerEnabled = true;
|
||||||
System.out.println("MngFileSyncJob ON --> mngYyyy : "+ mng + ", currentTime : " + System.currentTimeMillis());
|
System.out.println(
|
||||||
}
|
"MngFileSyncJob ON --> mngYyyy : "
|
||||||
else{
|
+ mng
|
||||||
|
+ ", currentTime : "
|
||||||
|
+ System.currentTimeMillis());
|
||||||
|
} else {
|
||||||
this.isFileSyncSchedulerEnabled = false;
|
this.isFileSyncSchedulerEnabled = false;
|
||||||
System.out.println("MngFileSyncJob OFF --> mngYyyy : "+ mng + ", currentTime : " + System.currentTimeMillis());
|
System.out.println(
|
||||||
|
"MngFileSyncJob OFF --> mngYyyy : "
|
||||||
|
+ mng
|
||||||
|
+ ", currentTime : "
|
||||||
|
+ System.currentTimeMillis());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Scheduled(fixedDelay = 1000 * 5)
|
@Scheduled(fixedDelay = 1000 * 5)
|
||||||
public void mngFileSyncJob00() {
|
public void mngFileSyncJob00() {
|
||||||
if (!isSchedulerEnabled || !isFileSyncSchedulerEnabled) return;
|
if (!isSchedulerEnabled || !isFileSyncSchedulerEnabled) return;
|
||||||
@@ -54,7 +58,6 @@ public class MapSheetMngFileJobController {
|
|||||||
mapSheetMngFileJobService.checkMapSheetFileProcess(1, mngSyncPageSize);
|
mapSheetMngFileJobService.checkMapSheetFileProcess(1, mngSyncPageSize);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Scheduled(fixedDelay = 1000 * 5)
|
@Scheduled(fixedDelay = 1000 * 5)
|
||||||
public void mngFileSyncJob02() {
|
public void mngFileSyncJob02() {
|
||||||
if (!isSchedulerEnabled || !isFileSyncSchedulerEnabled) return;
|
if (!isSchedulerEnabled || !isFileSyncSchedulerEnabled) return;
|
||||||
@@ -119,8 +122,6 @@ public class MapSheetMngFileJobController {
|
|||||||
mapSheetMngFileJobService.checkMapSheetFileProcess(9, mngSyncPageSize);
|
mapSheetMngFileJobService.checkMapSheetFileProcess(9, mngSyncPageSize);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// 3. 외부에서 플래그를 변경할 수 있는 Setter 메서드
|
// 3. 외부에서 플래그를 변경할 수 있는 Setter 메서드
|
||||||
public void setSchedulerEnabled(boolean enabled) {
|
public void setSchedulerEnabled(boolean enabled) {
|
||||||
this.isSchedulerEnabled = enabled;
|
this.isSchedulerEnabled = enabled;
|
||||||
|
|||||||
@@ -45,9 +45,7 @@ public class MapSheetMngFileJobService {
|
|||||||
@Value("${file.sync-file-extention}")
|
@Value("${file.sync-file-extention}")
|
||||||
private String syncFileExtention;
|
private String syncFileExtention;
|
||||||
|
|
||||||
|
public Integer checkMngFileSync() {
|
||||||
public Integer checkMngFileSync()
|
|
||||||
{
|
|
||||||
return mapSheetMngFileJobCoreService.findNotYetMapSheetMng();
|
return mapSheetMngFileJobCoreService.findNotYetMapSheetMng();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -66,7 +64,7 @@ public class MapSheetMngFileJobService {
|
|||||||
SrchFilesDepthDto srchDto = new SrchFilesDepthDto();
|
SrchFilesDepthDto srchDto = new SrchFilesDepthDto();
|
||||||
List<FIleChecker.Basic> basicList = new ArrayList<>();
|
List<FIleChecker.Basic> basicList = new ArrayList<>();
|
||||||
|
|
||||||
if( mapSheetFileNotYetList.size() >= 1 ){
|
if (mapSheetFileNotYetList.size() >= 1) {
|
||||||
mngYyyy = mapSheetFileNotYetList.get(0).getMngYyyy();
|
mngYyyy = mapSheetFileNotYetList.get(0).getMngYyyy();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -124,9 +122,9 @@ public class MapSheetMngFileJobService {
|
|||||||
if (tfwCnt == 0 && tifCnt == 0) syncState = "NOFILE";
|
if (tfwCnt == 0 && tifCnt == 0) syncState = "NOFILE";
|
||||||
|
|
||||||
for (FIleChecker.Basic item2 : basicList) {
|
for (FIleChecker.Basic item2 : basicList) {
|
||||||
//System.out.println("path: " + item2.getParentPath());
|
// System.out.println("path: " + item2.getParentPath());
|
||||||
//System.out.println("path: " + item2.getFileNm());
|
// System.out.println("path: " + item2.getFileNm());
|
||||||
//System.out.println("path: " + item2.getFullPath());
|
// System.out.println("path: " + item2.getFullPath());
|
||||||
|
|
||||||
MapSheetMngDto.MngFileAddReq addReq = new MapSheetMngDto.MngFileAddReq();
|
MapSheetMngDto.MngFileAddReq addReq = new MapSheetMngDto.MngFileAddReq();
|
||||||
addReq.setMngYyyy(item.getMngYyyy());
|
addReq.setMngYyyy(item.getMngYyyy());
|
||||||
@@ -178,11 +176,9 @@ public class MapSheetMngFileJobService {
|
|||||||
if (syncState.isEmpty()) syncState = "DONE";
|
if (syncState.isEmpty()) syncState = "DONE";
|
||||||
item.setSyncState(syncState);
|
item.setSyncState(syncState);
|
||||||
mngHstDataSyncStateUpdate(item);
|
mngHstDataSyncStateUpdate(item);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Long notyetCnt = this.mngDataStateDoneUpdate(mngYyyy);
|
Long notyetCnt = this.mngDataStateDoneUpdate(mngYyyy);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public int checkIsNoFile(List<FileDto.Basic> basicList) {
|
public int checkIsNoFile(List<FileDto.Basic> basicList) {
|
||||||
@@ -196,16 +192,12 @@ public class MapSheetMngFileJobService {
|
|||||||
public Long mngDataStateDoneUpdate(int mngYyyy) {
|
public Long mngDataStateDoneUpdate(int mngYyyy) {
|
||||||
|
|
||||||
Long notyetCnt = 0L;
|
Long notyetCnt = 0L;
|
||||||
if( mngYyyy > 0 )
|
if (mngYyyy > 0) {
|
||||||
{
|
|
||||||
notyetCnt = findByMngYyyyTargetMapSheetNotYetCount(mngYyyy);
|
notyetCnt = findByMngYyyyTargetMapSheetNotYetCount(mngYyyy);
|
||||||
if( notyetCnt == 0 )
|
if (notyetCnt == 0) {
|
||||||
{
|
mapSheetMngFileJobCoreService.mngDataState(mngYyyy, "DONE");
|
||||||
mapSheetMngFileJobCoreService.mngDataState(mngYyyy,"DONE");
|
} else {
|
||||||
}
|
mapSheetMngFileJobCoreService.mngDataState(mngYyyy, "PROCESSING");
|
||||||
else
|
|
||||||
{
|
|
||||||
mapSheetMngFileJobCoreService.mngDataState(mngYyyy,"PROCESSING");
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -216,7 +208,6 @@ public class MapSheetMngFileJobService {
|
|||||||
return mapSheetMngFileJobCoreService.findTargetMapSheetFileList(targetNum, pageSize);
|
return mapSheetMngFileJobCoreService.findTargetMapSheetFileList(targetNum, pageSize);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public Long findByMngYyyyTargetMapSheetNotYetCount(int mngYyyy) {
|
public Long findByMngYyyyTargetMapSheetNotYetCount(int mngYyyy) {
|
||||||
return mapSheetMngFileJobCoreService.findByMngYyyyTargetMapSheetNotYetCount(mngYyyy);
|
return mapSheetMngFileJobCoreService.findByMngYyyyTargetMapSheetNotYetCount(mngYyyy);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user