summaryrefslogtreecommitdiff
path: root/lib/nonsap-sync/procurement-sync-service.ts
diff options
context:
space:
mode:
Diffstat (limited to 'lib/nonsap-sync/procurement-sync-service.ts')
-rw-r--r--lib/nonsap-sync/procurement-sync-service.ts14
1 files changed, 7 insertions, 7 deletions
diff --git a/lib/nonsap-sync/procurement-sync-service.ts b/lib/nonsap-sync/procurement-sync-service.ts
index 1f719526..c8365a1c 100644
--- a/lib/nonsap-sync/procurement-sync-service.ts
+++ b/lib/nonsap-sync/procurement-sync-service.ts
@@ -25,7 +25,7 @@ const logger = {
async function testOracleConnection(): Promise<boolean> {
try {
const result = await oracleKnex.raw('SELECT 1 FROM DUAL');
- return result.rows && result.rows.length > 0;
+ return result && result.length > 0;
} catch (error) {
logger.error('Oracle DB 연결 테스트 실패:', error);
return false;
@@ -46,7 +46,7 @@ async function syncPaymentTerms(): Promise<void> {
WHERE stc.cd = 'PAYT'
`);
- const paymentTermsData = oracleData.rows || [];
+ const paymentTermsData = oracleData || [];
logger.info(`Oracle에서 ${paymentTermsData.length}개의 지불조건 데이터 조회`);
if (paymentTermsData.length === 0) {
@@ -64,7 +64,7 @@ async function syncPaymentTerms(): Promise<void> {
// 업데이트할 데이터 준비
const upsertData = paymentTermsData.map((item: { CODE: string; DESCRIPTION: string }) => ({
code: item.CODE,
- description: item.DESCRIPTION,
+ description: item.DESCRIPTION || 'NONSAP에서 설명 기입 요망',
isActive: true // 기본값 true
}));
@@ -112,7 +112,7 @@ async function syncIncoterms(): Promise<void> {
WHERE stc.cd = 'INCO'
`);
- const incotermsData = oracleData.rows || [];
+ const incotermsData = oracleData || [];
logger.info(`Oracle에서 ${incotermsData.length}개의 인코텀즈 데이터 조회`);
if (incotermsData.length === 0) {
@@ -130,7 +130,7 @@ async function syncIncoterms(): Promise<void> {
// 업데이트할 데이터 준비
const upsertData = incotermsData.map((item: { CODE: string; DESCRIPTION: string }) => ({
code: item.CODE,
- description: item.DESCRIPTION,
+ description: item.DESCRIPTION || 'NONSAP에서 설명 기입 요망',
isActive: true // 기본값 true
}));
@@ -181,7 +181,7 @@ async function syncPlaceOfShipping(): Promise<void> {
ORDER BY cd.CD asc, cdnm.CDNM asc
`);
- const placeOfShippingData = oracleData.rows || [];
+ const placeOfShippingData = oracleData || [];
logger.info(`Oracle에서 ${placeOfShippingData.length}개의 선적/하역지 데이터 조회`);
if (placeOfShippingData.length === 0) {
@@ -199,7 +199,7 @@ async function syncPlaceOfShipping(): Promise<void> {
// 업데이트할 데이터 준비 (isActive = "Y"인 경우 true, 그 외는 기본값 true)
const upsertData = placeOfShippingData.map((item: { CODE: string; DESCRIPTION: string; ISACTIVE: string }) => ({
code: item.CODE,
- description: item.DESCRIPTION,
+ description: item.DESCRIPTION || 'NONSAP에서 설명 기입 요망',
isActive: item.ISACTIVE === 'Y' ? true : true // 기본값 true
}));