Merge branch 'price-history-log' into 'master'
Price history log See merge request saburly/marketalarm/web!87
This commit was merged in pull request #87.
This commit is contained in:
@@ -1,6 +1,7 @@
|
||||
const moment = require("moment");
|
||||
|
||||
const { bulkUpsertRealEstates } = require("../../helpers/db/realEstate");
|
||||
const { bulkUpsertPriceHistory } = require("../../helpers/db/priceHistory");
|
||||
|
||||
class PostgresSaver {
|
||||
connect() {
|
||||
@@ -11,6 +12,21 @@ class PostgresSaver {
|
||||
|
||||
async save(results) {
|
||||
const savedRecords = await bulkUpsertRealEstates(results);
|
||||
//Extruding data for price history table
|
||||
const resultPrices = savedRecords.map(realEstate => {
|
||||
//Null values canot be recognized by ignore duplicates in sequalize
|
||||
//Value price = 0 indicates 'cijena na upit'
|
||||
const priceTmp =
|
||||
realEstate.dataValues.price === null ? 0 : realEstate.dataValues.price;
|
||||
|
||||
return {
|
||||
realEstateId: realEstate.dataValues.id,
|
||||
price: priceTmp,
|
||||
createdAt: realEstate.dataValues.createdAt,
|
||||
updatedAt: realEstate.dataValues.updatedAt
|
||||
};
|
||||
});
|
||||
const savedPrices = await bulkUpsertPriceHistory(resultPrices);
|
||||
|
||||
if (Array.isArray(savedRecords)) {
|
||||
const newRealEstates = [];
|
||||
|
||||
Reference in New Issue
Block a user