summaryrefslogtreecommitdiff
path: root/lib/sedp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/sedp')
-rw-r--r--lib/sedp/get-form-tags.ts41
-rw-r--r--lib/sedp/get-tags.ts55
-rw-r--r--lib/sedp/sync-form.ts61
3 files changed, 110 insertions, 47 deletions
diff --git a/lib/sedp/get-form-tags.ts b/lib/sedp/get-form-tags.ts
index 5b1c500d..821fa372 100644
--- a/lib/sedp/get-form-tags.ts
+++ b/lib/sedp/get-form-tags.ts
@@ -26,7 +26,9 @@ interface Attribute {
}
interface TagEntry {
+ TAG_IDX: string;
TAG_NO: string;
+ BF_TAG_NO: string;
TAG_DESC: string;
EP_ID: string;
TAG_TYPE_ID: string;
@@ -389,8 +391,8 @@ export async function importTagsFromSEDP(
existingEntries.forEach(entry => {
const data = entry.data as any[];
data.forEach(item => {
- if (item.TAG_NO) {
- existingTagMap.set(item.TAG_NO, {
+ if (item.TAG_IDX) {
+ existingTagMap.set(item.TAG_IDX, {
entryId: entry.id,
data: item
});
@@ -399,7 +401,7 @@ export async function importTagsFromSEDP(
});
existingTags.forEach(tag => {
- existingTagsMap.set(tag.tagNo, tag);
+ existingTagsMap.set(tag.tagIdx, tag);
});
// 진행 상황 보고
@@ -417,7 +419,7 @@ export async function importTagsFromSEDP(
// SEDP 태그 데이터 처리
for (const tagEntry of tagEntries) {
try {
- if (!tagEntry.TAG_NO) {
+ if (!tagEntry.TAG_IDX) {
excludedCount++;
errors.push(`Missing TAG_NO in tag entry`);
continue;
@@ -459,6 +461,7 @@ export async function importTagsFromSEDP(
// 기본 태그 데이터 객체 생성 (formEntries용)
const tagObject: any = {
+ TAG_IDX: tagEntry.TAG_IDX, // SEDP 고유 식별자
TAG_NO: tagEntry.TAG_NO,
TAG_DESC: tagEntry.TAG_DESC || "",
VNDRCD:vendorRecord[0].vendorCode,
@@ -470,6 +473,7 @@ export async function importTagsFromSEDP(
const tagRecord = {
contractItemId: packageId,
formId: formId,
+ tagIdx: tagEntry.TAG_IDX, // SEDP 고유 식별자
tagNo: tagEntry.TAG_NO,
tagType: tagTypeDescription || "",
class: tagClassLabel,
@@ -508,7 +512,7 @@ export async function importTagsFromSEDP(
}
// 기존 태그가 있는지 확인하고 처리
- const existingTag = existingTagMap.get(tagEntry.TAG_NO);
+ const existingTag = existingTagMap.get(tagEntry.TAG_IDX);
if (existingTag) {
// 기존 태그가 있으면 formEntries 업데이트 데이터 준비
@@ -516,7 +520,14 @@ export async function importTagsFromSEDP(
let hasUpdates = false;
for (const key of Object.keys(tagObject)) {
- if (key === "TAG_NO") continue;
+ if (key === "TAG_IDX") continue;
+
+ if (key === "TAG_NO" && tagObject[key] !== existingTag.data[key]) {
+ updates[key] = tagObject[key];
+ hasUpdates = true;
+ continue;
+ }
+
if (key === "TAG_DESC" && tagObject[key] !== existingTag.data[key]) {
updates[key] = tagObject[key];
@@ -542,7 +553,7 @@ export async function importTagsFromSEDP(
if (hasUpdates) {
updateData.push({
entryId: existingTag.entryId,
- tagNo: tagEntry.TAG_NO,
+ tagIdx: tagEntry.TAG_IDX, // TAG_IDX로 변경
updates
});
}
@@ -557,7 +568,7 @@ export async function importTagsFromSEDP(
processedCount++;
} catch (error) {
excludedCount++;
- errors.push(`Error processing tag ${tagEntry.TAG_NO || 'unknown'}: ${error}`);
+ errors.push(`Error processing tag ${tagEntry.TAG_IDX || 'unknown'}: ${error}`);
}
}
@@ -572,7 +583,7 @@ export async function importTagsFromSEDP(
const data = entry.data as any[];
const updatedData = data.map(item => {
- if (item.TAG_NO === update.tagNo) {
+ if (item.TAG_IDX === update.tagIdx) {
return { ...item, ...update.updates };
}
return item;
@@ -627,6 +638,12 @@ export async function importTagsFromSEDP(
// 기존 태그가 있으면 업데이트 준비
const tagUpdates: any = {};
let hasTagUpdates = false;
+
+ // tagNo도 업데이트 가능 (편집된 경우)
+ if (existingTagRecord.tagNo !== tagRecord.tagNo) {
+ tagUpdates.tagNo = tagRecord.tagNo;
+ hasTagUpdates = true;
+ }
if (existingTagRecord.tagType !== tagRecord.tagType) {
tagUpdates.tagType = tagRecord.tagType;
@@ -663,7 +680,7 @@ export async function importTagsFromSEDP(
await tx.insert(tags)
.values(newTagRecords)
.onConflictDoNothing({
- target: [tags.contractItemId, tags.tagNo]
+ target: [tags.contractItemId, tags.tagIdx]
});
} catch (error) {
// 개별 삽입으로 재시도
@@ -672,10 +689,10 @@ export async function importTagsFromSEDP(
await tx.insert(tags)
.values(tagRecord)
.onConflictDoNothing({
- target: [tags.contractItemId, tags.tagNo]
+ target: [tags.contractItemId, tags.tagIdx]
});
} catch (individualError) {
- errors.push(`Error inserting tag ${tagRecord.tagNo}: ${individualError}`);
+ errors.push(`Error inserting tag ${tagRecord.tagIdx}: ${individualError}`);
}
}
}
diff --git a/lib/sedp/get-tags.ts b/lib/sedp/get-tags.ts
index cb549d8c..ff742299 100644
--- a/lib/sedp/get-tags.ts
+++ b/lib/sedp/get-tags.ts
@@ -18,6 +18,7 @@ import { getSEDPToken } from "./sedp-token";
/**
* 태그 가져오기 서비스 함수
* contractItemId(packageId)를 기반으로 외부 시스템에서 태그 데이터를 가져와 DB에 저장
+ * TAG_IDX를 기준으로 태그를 식별합니다.
*
* @param packageId 계약 아이템 ID (contractItemId)
* @param progressCallback 진행 상황을 보고하기 위한 콜백 함수
@@ -321,7 +322,8 @@ export async function importTagsFromSEDP(
// formEntries를 위한 데이터 수집
const newTagsForFormEntry: Array<{
- TAG_NO: string;
+ TAG_IDX: string; // 변경: TAG_NO → TAG_IDX
+ TAG_NO?: string; // TAG_NO도 함께 저장 (편집 가능한 필드)
TAG_DESC: string | null;
status: string;
[key: string]: any;
@@ -332,6 +334,21 @@ export async function importTagsFromSEDP(
try {
const entry = tagEntries[i];
+ // TAG_IDX가 없는 경우 제외 (변경: TAG_NO → TAG_IDX 체크)
+ if (!entry.TAG_IDX) {
+ excludedCount++;
+ totalExcludedCount++;
+
+ // 주기적으로 진행 상황 보고 (건너뛰어도 진행률은 업데이트)
+ if (progressCallback && (i % 10 === 0 || i === tagEntries.length - 1)) {
+ const baseProgress = 60;
+ const entryProgress = Math.floor(30 * ((mappingIndex * entriesCount + i) / (mappings.length * entriesCount)));
+ progressCallback(baseProgress + entryProgress);
+ }
+
+ continue; // 이 항목은 건너뜀
+ }
+
// TAG_TYPE_ID가 null이거나 빈 문자열인 경우 제외
if (entry.TAG_TYPE_ID === null || entry.TAG_TYPE_ID === "") {
excludedCount++;
@@ -363,19 +380,21 @@ export async function importTagsFromSEDP(
)
});
- // Insert or update the tag
+ // Insert or update the tag - tagIdx 필드 추가
await db.insert(tags).values({
contractItemId: packageId,
formId: formId,
- tagNo: entry.TAG_NO,
+ tagIdx: entry.TAG_IDX, // 추가: SEDP 고유 식별자
+ tagNo: entry.TAG_NO || entry.TAG_IDX, // TAG_NO가 없으면 TAG_IDX 사용
tagType: tagType?.description || entry.TAG_TYPE_ID,
tagClassId: tagClass?.id,
class: tagClass?.label || entry.CLS_ID,
description: entry.TAG_DESC
}).onConflictDoUpdate({
- target: [tags.contractItemId, tags.tagNo],
+ target: [tags.contractItemId, tags.tagIdx], // 변경: tagNo → tagIdx
set: {
formId: formId,
+ tagNo: entry.TAG_NO || entry.TAG_IDX, // tagNo도 업데이트 가능
tagType: tagType?.description || entry.TAG_TYPE_ID,
class: tagClass?.label || entry.CLS_ID,
description: entry.TAG_DESC,
@@ -385,9 +404,10 @@ export async function importTagsFromSEDP(
// formEntries용 데이터 수집
const tagDataForFormEntry = {
- TAG_NO: entry.TAG_NO,
+ TAG_IDX: entry.TAG_IDX, // 변경: TAG_NO → TAG_IDX
+ TAG_NO: entry.TAG_NO || entry.TAG_IDX, // TAG_NO도 함께 저장
TAG_DESC: entry.TAG_DESC || null,
- status:"From S-EDP" // SEDP에서 가져온 데이터임을 표시
+ status: "From S-EDP" // SEDP에서 가져온 데이터임을 표시
};
// ATTRIBUTES가 있으면 추가 (SHI 필드들)
@@ -416,7 +436,7 @@ export async function importTagsFromSEDP(
}
}
- // Step 7: formEntries 업데이트
+ // Step 7: formEntries 업데이트 - TAG_IDX 기준으로 변경
if (newTagsForFormEntry.length > 0) {
try {
// 기존 formEntry 가져오기
@@ -430,7 +450,8 @@ export async function importTagsFromSEDP(
if (existingEntry && existingEntry.id) {
// 기존 formEntry가 있는 경우
let existingData: Array<{
- TAG_NO: string;
+ TAG_IDX?: string; // 추가: TAG_IDX 필드
+ TAG_NO?: string;
TAG_DESC?: string;
status?: string;
[key: string]: any;
@@ -440,18 +461,22 @@ export async function importTagsFromSEDP(
existingData = existingEntry.data;
}
- // 기존 TAG_NO들 추출
- const existingTagNos = new Set(existingData.map(item => item.TAG_NO));
+ // 기존 TAG_IDX들 추출 (변경: TAG_NO → TAG_IDX)
+ const existingTagIdxs = new Set(
+ existingData
+ .map(item => item.TAG_IDX)
+ .filter(tagIdx => tagIdx !== undefined && tagIdx !== null)
+ );
- // 중복되지 않은 새 태그들만 필터링
+ // 중복되지 않은 새 태그들만 필터링 (변경: TAG_NO → TAG_IDX)
const newUniqueTagsData = newTagsForFormEntry.filter(
- tagData => !existingTagNos.has(tagData.TAG_NO)
+ tagData => !existingTagIdxs.has(tagData.TAG_IDX)
);
- // 기존 태그들의 status와 ATTRIBUTES 업데이트
+ // 기존 태그들의 status와 ATTRIBUTES 업데이트 (변경: TAG_NO → TAG_IDX)
const updatedExistingData = existingData.map(existingItem => {
const newTagData = newTagsForFormEntry.find(
- newItem => newItem.TAG_NO === existingItem.TAG_NO
+ newItem => newItem.TAG_IDX === existingItem.TAG_IDX
);
if (newTagData) {
@@ -459,7 +484,7 @@ export async function importTagsFromSEDP(
return {
...existingItem,
...newTagData,
- TAG_NO: existingItem.TAG_NO // TAG_NO는 유지
+ TAG_IDX: existingItem.TAG_IDX // TAG_IDX는 유지
};
}
diff --git a/lib/sedp/sync-form.ts b/lib/sedp/sync-form.ts
index 559c09a2..6ae2e675 100644
--- a/lib/sedp/sync-form.ts
+++ b/lib/sedp/sync-form.ts
@@ -129,6 +129,7 @@ interface newRegister {
REG_TYPE_ID: string;
TOOL_ID: string;
TOOL_TYPE: string;
+ SCOPES: string[];
MAP_CLS: {
TOOL_ATT_NAME: string;
ITEMS: ClassItmes[];
@@ -933,10 +934,15 @@ export async function saveFormMappingsAndMetas(
const defaultAttributes = await getDefaulTAttributes();
/* ------------------------------------------------------------------ */
- /* 2. Contract‑item look‑up (TOOL_TYPE) - 수정된 부분 */
+ /* 2. Contract‑item look‑up (SCOPES) - 수정된 부분 */
/* ------------------------------------------------------------------ */
- const uniqueItemCodes = [...new Set(newRegisters.filter(nr => nr.TOOL_TYPE).map(nr => nr.TOOL_TYPE as string))];
- const itemCodeToContractItemIds = await getContractItemsByItemCodes(uniqueItemCodes, projectId, projectCode);
+ // SCOPES 배열에서 모든 unique한 itemCode들을 추출
+ const uniqueItemCodes = [...new Set(
+ newRegisters
+ .filter(nr => nr.SCOPES && nr.SCOPES.length > 0)
+ .flatMap(nr => nr.SCOPES as string[])
+ )];
+ const itemCodeToContractItemIds = await getContractItemsByItemCodes(uniqueItemCodes, projectId);
/* ------------------------------------------------------------------ */
/* 3. Buffers for bulk insert */
@@ -1019,27 +1025,42 @@ export async function saveFormMappingsAndMetas(
if (!cls) { console.warn(`클래스 ${classId} 없음`); return; }
const tp = tagTypeMap.get(cls.tagTypeCode);
if (!tp) { console.warn(`태그 타입 ${cls.tagTypeCode} 없음`); return; }
- mappingsToSave.push({ projectId, tagTypeLabel: tp.description, classLabel: cls.label, formCode, formName: legacy?.DESC || formCode, remark: newReg.TOOL_TYPE || null, ep: newReg.EP_ID || legacy?.EP_ID || "", createdAt: new Date(), updatedAt: new Date() });
+ // SCOPES 배열을 문자열로 변환하여 remark에 저장
+ const scopesRemark = newReg.SCOPES && newReg.SCOPES.length > 0 ? newReg.SCOPES.join(', ') : null;
+ mappingsToSave.push({
+ projectId,
+ tagTypeLabel: tp.description,
+ classLabel: cls.label,
+ formCode,
+ formName: legacy?.DESC || formCode,
+ remark: scopesRemark,
+ ep: newReg.EP_ID || legacy?.EP_ID || "",
+ createdAt: new Date(),
+ updatedAt: new Date()
+ });
});
/* ---------- 4‑d. contractItem ↔ form - 수정된 부분 -------------- */
- if (newReg.TOOL_TYPE) {
- const contractItemIds = itemCodeToContractItemIds.get(newReg.TOOL_TYPE);
- if (contractItemIds && contractItemIds.length > 0) {
- // 모든 contractItemId에 대해 form 생성
- contractItemIds.forEach(cId => {
- contractItemIdsWithForms.add(cId);
- formsToSave.push({
- contractItemId: cId,
- formCode,
- formName: legacy?.DESC || formCode,
- eng: true,
- createdAt: new Date(),
- updatedAt: new Date()
+ if (newReg.SCOPES && newReg.SCOPES.length > 0) {
+ // SCOPES 배열의 각 itemCode에 대해 처리
+ for (const itemCode of newReg.SCOPES) {
+ const contractItemIds = itemCodeToContractItemIds.get(itemCode);
+ if (contractItemIds && contractItemIds.length > 0) {
+ // 모든 contractItemId에 대해 form 생성
+ contractItemIds.forEach(cId => {
+ contractItemIdsWithForms.add(cId);
+ formsToSave.push({
+ contractItemId: cId,
+ formCode,
+ formName: legacy?.DESC || formCode,
+ eng: true,
+ createdAt: new Date(),
+ updatedAt: new Date()
+ });
});
- });
- } else {
- console.warn(`itemCode ${newReg.TOOL_TYPE} 의 contractItemId 없음`);
+ } else {
+ console.warn(`itemCode ${itemCode} 의 contractItemId 없음`);
+ }
}
}
}
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-07 06:22:34 +0000