빌드/배포 환경 설정 및 kjb-safedb 의존성 분리
- build.gradle: nexusUrl 활성화, kjb-safedb 의존성 주석 처리 - settings.gradle: kjb-safedb include 주석 처리, eapim-admin-kjb 경로 수정 - weblogic.xml: WebLogic 배포 설정 반영 - logback-dev.xml: 개발 로그 설정 조정
This commit is contained in:
+17
-16
@@ -10,7 +10,7 @@ import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import com.eactive.ext.kjb.safedb.KjbSafedbWrapper;
|
||||
//import com.eactive.ext.kjb.safedb.KjbSafedbWrapper;
|
||||
|
||||
/**
|
||||
* DB Console 복호화 서비스
|
||||
@@ -31,21 +31,22 @@ public class DbConsoleDecryptService {
|
||||
* 단일 값 복호화
|
||||
*/
|
||||
public String decryptValue(String encryptedValue) {
|
||||
if (encryptedValue == null || encryptedValue.isEmpty()) {
|
||||
return encryptedValue;
|
||||
}
|
||||
|
||||
try {
|
||||
KjbSafedbWrapper safedb = KjbSafedbWrapper.getInstance();
|
||||
String decrypted = safedb.decryptNotRnno(encryptedValue);
|
||||
log.debug("복호화 성공: {} -> {}",
|
||||
encryptedValue.length() > 20 ? encryptedValue.substring(0, 20) + "..." : encryptedValue,
|
||||
decrypted);
|
||||
return decrypted;
|
||||
} catch (Exception e) {
|
||||
log.warn("복호화 실패: {}", e.getMessage());
|
||||
return "[복호화 실패: " + e.getMessage() + "]";
|
||||
}
|
||||
return encryptedValue;
|
||||
// if (encryptedValue == null || encryptedValue.isEmpty()) {
|
||||
// return encryptedValue;
|
||||
// }
|
||||
//
|
||||
// try {
|
||||
// KjbSafedbWrapper safedb = KjbSafedbWrapper.getInstance();
|
||||
// String decrypted = safedb.decryptNotRnno(encryptedValue);
|
||||
// log.debug("복호화 성공: {} -> {}",
|
||||
// encryptedValue.length() > 20 ? encryptedValue.substring(0, 20) + "..." : encryptedValue,
|
||||
// decrypted);
|
||||
// return decrypted;
|
||||
// } catch (Exception e) {
|
||||
// log.warn("복호화 실패: {}", e.getMessage());
|
||||
// return "[복호화 실패: " + e.getMessage() + "]";
|
||||
// }
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -64,18 +64,18 @@ public class UmsDispatchService {
|
||||
@PostConstruct
|
||||
public void init() {
|
||||
// KjbEmailSendModule에 repository 설정
|
||||
KjbEmailSendModule.getInstance().setRepository(messageRequestRepository);
|
||||
// KjbEmailSendModule.getInstance().setRepository(messageRequestRepository);
|
||||
log.info("UmsDispatchService initialized - KjbUmsService and KjbEmailSendModule ready via singleton");
|
||||
}
|
||||
|
||||
private KjbUmsService getUmsService() {
|
||||
return KjbUmsService.getInstance();
|
||||
}
|
||||
|
||||
private KjbEmailSendModule getEmailModule() {
|
||||
return KjbEmailSendModule.getInstance();
|
||||
}
|
||||
|
||||
// private KjbUmsService getUmsService() {
|
||||
// return KjbUmsService.getInstance();
|
||||
// }
|
||||
//
|
||||
// private KjbEmailSendModule getEmailModule() {
|
||||
// return KjbEmailSendModule.getInstance();
|
||||
// }
|
||||
//
|
||||
@SuppressWarnings("unchecked")
|
||||
@Transactional(transactionManager = "transactionManagerForEMS")
|
||||
public void processMessages() {
|
||||
@@ -112,7 +112,7 @@ public class UmsDispatchService {
|
||||
|
||||
log.info("Starting to submit {} messages for processing", messagesToProcess.size());
|
||||
for (MessageRequest message : messagesToProcess) {
|
||||
submitMessageTask(message);
|
||||
//submitMessageTask(message);
|
||||
}
|
||||
} else {
|
||||
log.info("No pending messages found");
|
||||
@@ -123,40 +123,40 @@ public class UmsDispatchService {
|
||||
}
|
||||
|
||||
|
||||
private void submitMessageTask(MessageRequest message) {
|
||||
int queueSize = executorService.getQueue().size();
|
||||
log.debug("Current queue size before submission: {}", queueSize);
|
||||
|
||||
executorService.submit(() -> {
|
||||
try {
|
||||
transactionTemplate.execute(status -> {
|
||||
try {
|
||||
// 광주은행에서는 사용하지 않는 메소드
|
||||
// processMessage(message);
|
||||
|
||||
if (KjbUmsService.isAllowChannel(message)) {
|
||||
getUmsService().send(message);
|
||||
}
|
||||
|
||||
if (KjbEmailSendModule.isAllowChannel(message)) {
|
||||
getEmailModule().sendEmail(message);
|
||||
}
|
||||
|
||||
return null;
|
||||
} catch (Exception e) {
|
||||
log.error("Failed to process message: {} - Error: {}",
|
||||
message.getId(), e.getMessage(), e);
|
||||
updateMessageStatus(message, "FAILED");
|
||||
status.setRollbackOnly();
|
||||
return null;
|
||||
}
|
||||
});
|
||||
} catch (Exception e) {
|
||||
log.error("Transaction execution failed for message: {} - Error: {}",
|
||||
message.getId(), e.getMessage(), e);
|
||||
}
|
||||
});
|
||||
}
|
||||
// private void submitMessageTask(MessageRequest message) {
|
||||
// int queueSize = executorService.getQueue().size();
|
||||
// log.debug("Current queue size before submission: {}", queueSize);
|
||||
//
|
||||
// executorService.submit(() -> {
|
||||
// try {
|
||||
// transactionTemplate.execute(status -> {
|
||||
// try {
|
||||
// // 광주은행에서는 사용하지 않는 메소드
|
||||
//// processMessage(message);
|
||||
//
|
||||
// if (KjbUmsService.isAllowChannel(message)) {
|
||||
// getUmsService().send(message);
|
||||
// }
|
||||
//
|
||||
// if (KjbEmailSendModule.isAllowChannel(message)) {
|
||||
// getEmailModule().sendEmail(message);
|
||||
// }
|
||||
//
|
||||
// return null;
|
||||
// } catch (Exception e) {
|
||||
// log.error("Failed to process message: {} - Error: {}",
|
||||
// message.getId(), e.getMessage(), e);
|
||||
// updateMessageStatus(message, "FAILED");
|
||||
// status.setRollbackOnly();
|
||||
// return null;
|
||||
// }
|
||||
// });
|
||||
// } catch (Exception e) {
|
||||
// log.error("Transaction execution failed for message: {} - Error: {}",
|
||||
// message.getId(), e.getMessage(), e);
|
||||
// }
|
||||
// });
|
||||
// }
|
||||
|
||||
/**
|
||||
* kbank 방식으로 광주은행에서는 사용하지 않음
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package com.eactive.ext.kjb.spring;
|
||||
|
||||
import com.eactive.ext.kjb.safedb.KjbSafedbWrapper;
|
||||
//import com.eactive.ext.kjb.safedb.KjbSafedbWrapper;
|
||||
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
|
||||
import org.springframework.security.crypto.password.PasswordEncoder;
|
||||
|
||||
@@ -10,14 +10,16 @@ public class KjbSafedbPasswordEncoder implements PasswordEncoder {
|
||||
@Override
|
||||
public String encode(CharSequence rawPassword) {
|
||||
String bcryptHash = bcryptEncoder.encode(rawPassword);
|
||||
KjbSafedbWrapper safedb = KjbSafedbWrapper.getInstance();
|
||||
return safedb.encryptNotRnnoString(bcryptHash);
|
||||
return bcryptHash;
|
||||
// KjbSafedbWrapper safedb = KjbSafedbWrapper.getInstance();
|
||||
// return safedb.encryptNotRnnoString(bcryptHash);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean matches(CharSequence rawPassword, String encodedPassword) {
|
||||
KjbSafedbWrapper safedb = KjbSafedbWrapper.getInstance();
|
||||
String bcryptHash = safedb.decryptNotRnno(encodedPassword);
|
||||
return bcryptEncoder.matches(rawPassword, bcryptHash);
|
||||
// KjbSafedbWrapper safedb = KjbSafedbWrapper.getInstance();
|
||||
// String bcryptHash = safedb.decryptNotRnno(encodedPassword);
|
||||
// return bcryptEncoder.matches(rawPassword, bcryptHash);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -182,5 +182,6 @@
|
||||
<root>
|
||||
<level value="DEBUG" />
|
||||
<appender-ref ref="STDOUT" />
|
||||
<appender-ref ref="CONSOLE" />
|
||||
</root>
|
||||
</configuration>
|
||||
Reference in New Issue
Block a user