Skip to content
This repository was archived by the owner on Mar 13, 2025. It is now read-only.

Commit 1051366

Browse files
topcoder-archive/topcoder-platform-u-bahn-app#638 - Store failed records details back into the Upload model
1 parent bb7f3b8 commit 1051366

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

src/common/helper.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,8 @@ async function uploadFailedRecord (records, objectKey) {
103103
originalname: objectKey
104104
}
105105
}).promise()
106+
107+
return errFileName
106108
}
107109

108110
/**

src/services/ProcessorService.js

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,13 +248,14 @@ async function processCreate (message) {
248248
const file = await helper.downloadFile(message.payload.objectKey)
249249
const records = helper.parseExcel(file)
250250
const failedRecord = []
251+
let failedRecordsObjectKey
251252

252253
await Promise.map(records, record => processCreateRecord(record, failedRecord, message.payload.organizationId), { concurrency: config.PROCESS_CONCURRENCY_COUNT })
253254

254255
if (failedRecord.length > 0) {
255-
await helper.uploadFailedRecord(failedRecord, message.payload.objectKey)
256+
failedRecordsObjectKey = await helper.uploadFailedRecord(failedRecord, message.payload.objectKey)
256257
}
257-
await helper.updateProcessStatus(message.payload.id, { status: 'completed' })
258+
await helper.updateProcessStatus(message.payload.id, { status: 'completed', failedRecordsObjectKey })
258259
logger.info(`processing of the record(s) completed, id: ${message.payload.id}, success count: ${records.length - failedRecord.length}, fail count: ${failedRecord.length}`)
259260
} catch (err) {
260261
await helper.updateProcessStatus(message.payload.id, { status: 'failed', info: err.message })

0 commit comments

Comments
 (0)