94 lines
2.4 KiB
JavaScript
94 lines
2.4 KiB
JavaScript
import { GET_JOB_LINES_BY_PK } from "../../graphql/jobs-lines.queries";
|
|
import gql from "graphql-tag";
|
|
import _ from "lodash";
|
|
|
|
export const GetSupplementDelta = async (client, jobId, newLines) => {
|
|
console.log("-----Begin Supplement-----");
|
|
|
|
const {
|
|
data: { joblines: existingLinesFromDb },
|
|
} = await client.query({
|
|
query: GET_JOB_LINES_BY_PK,
|
|
variables: { id: jobId },
|
|
});
|
|
const existingLines = _.cloneDeep(existingLinesFromDb);
|
|
const linesToInsert = [];
|
|
const linesToUpdate = [];
|
|
|
|
newLines.forEach((newLine) => {
|
|
const matchingIndex = existingLines.findIndex(
|
|
(eL) => eL.unq_seq === newLine.unq_seq
|
|
);
|
|
if (matchingIndex >= 0) {
|
|
//Found a relevant matching line. Add it to lines to update.
|
|
linesToUpdate.push({
|
|
id: existingLines[matchingIndex].id,
|
|
newData: newLine,
|
|
});
|
|
|
|
//Splice out item we found for performance.
|
|
existingLines.splice(matchingIndex, 1);
|
|
} else {
|
|
//Didn't find a match. Must be a new line.
|
|
linesToInsert.push(newLine);
|
|
}
|
|
});
|
|
|
|
//Wahtever is left in the existing lines, are lines that should be removed.
|
|
|
|
const insertQueries = linesToInsert.reduce((acc, value, idx) => {
|
|
return acc + generateInsertQuery(value, idx, jobId);
|
|
}, "");
|
|
|
|
const updateQueries = linesToUpdate.reduce((acc, value, idx) => {
|
|
return acc + generateUpdateQuery(value, idx);
|
|
}, "");
|
|
|
|
const removeQueries = existingLines.reduce((acc, value, idx) => {
|
|
return acc + generateRemoveQuery(value, idx);
|
|
}, "");
|
|
|
|
return new Promise((resolve, reject) => {
|
|
resolve(gql`
|
|
mutation SUPPLEMENT_EST_LINES{
|
|
${insertQueries + updateQueries + removeQueries}
|
|
}
|
|
`);
|
|
});
|
|
};
|
|
|
|
const generateInsertQuery = (lineToInsert, index, jobId) => {
|
|
return `
|
|
insert_joblines${index}: insert_joblines(objects: ${JSON.stringify({
|
|
...lineToInsert,
|
|
jobid: jobId,
|
|
}).replace(/"(\w+)"\s*:/g, "$1:")}) {
|
|
returning {
|
|
id
|
|
}
|
|
}`;
|
|
};
|
|
|
|
const generateUpdateQuery = (lineToUpdate, index) => {
|
|
return `
|
|
update_joblines${index}: update_joblines(where: { id: { _eq: "${
|
|
lineToUpdate.id
|
|
}" } }, _set: ${JSON.stringify(lineToUpdate.newData).replace(
|
|
/"(\w+)"\s*:/g,
|
|
"$1:"
|
|
)}) {
|
|
returning {
|
|
id
|
|
}
|
|
}`;
|
|
};
|
|
|
|
const generateRemoveQuery = (lineToRemove, index) => {
|
|
return `
|
|
update_joblines_r${index}: update_joblines(where: {id: {_eq: "${lineToRemove.id}"}}, _set: {removed: true}) {
|
|
returning{
|
|
id
|
|
}
|
|
}`;
|
|
};
|