import { acquireConnection } from './pool.js'; export async function addOrUpdateLotField(lotFieldForm, requestSession, connectedDatabase) { const database = connectedDatabase ?? (await acquireConnection()); const rightNowMillis = Date.now(); let result = database .prepare(`update LotFields set lotFieldValue = ?, recordUpdate_userName = ?, recordUpdate_timeMillis = ?, recordDelete_userName = null, recordDelete_timeMillis = null where lotId = ? and lotTypeFieldId = ?`) .run(lotFieldForm.lotFieldValue, requestSession.user.userName, rightNowMillis, lotFieldForm.lotId, lotFieldForm.lotTypeFieldId); if (result.changes === 0) { result = database .prepare(`insert into LotFields ( lotId, lotTypeFieldId, lotFieldValue, recordCreate_userName, recordCreate_timeMillis, recordUpdate_userName, recordUpdate_timeMillis) values (?, ?, ?, ?, ?, ?, ?)`) .run(lotFieldForm.lotId, lotFieldForm.lotTypeFieldId, lotFieldForm.lotFieldValue, requestSession.user.userName, rightNowMillis, requestSession.user.userName, rightNowMillis); } if (connectedDatabase === undefined) { database.release(); } return result.changes > 0; } export default addOrUpdateLotField;