Fixed bug, for duplicate results for 2 similar re reqests of one user
This commit is contained in:
@@ -109,10 +109,10 @@ const sendBulkEmail = async (marketAlerts) => {
|
|||||||
return { uniqueId: marketAlert }
|
return { uniqueId: marketAlert }
|
||||||
});
|
});
|
||||||
|
|
||||||
const RERequest = await allRERequestByUiid(RERequestUuids);
|
const RERequests = await allRERequestByUiid(RERequestUuids);
|
||||||
const requestDataValues = [];
|
const requestDataValues = [];
|
||||||
|
|
||||||
RERequest.forEach(RERequest => {
|
RERequests.forEach(RERequest => {
|
||||||
var formatedRequest = {};
|
var formatedRequest = {};
|
||||||
formatedRequest[RERequest.uniqueId] =
|
formatedRequest[RERequest.uniqueId] =
|
||||||
requestDataValues[RERequest.uniqueId] = {
|
requestDataValues[RERequest.uniqueId] = {
|
||||||
@@ -211,7 +211,7 @@ const getNotificationEmailHtml = () => {
|
|||||||
<div>
|
<div>
|
||||||
<div>{{#each marketAlertUrl}}<li><a href="{{url}}">{{title}}</a></li><br />{{/each}}<div/>
|
<div>{{#each marketAlertUrl}}<li><a href="{{url}}">{{title}}</a></li><br />{{/each}}<div/>
|
||||||
<div/>
|
<div/>
|
||||||
<div>Kompletan spisan nekretnina mozete pegledati ovdije: <a href="{{requestUrl}}">Nekretnine</a> <div>
|
<div>Kompletan spisak nekretnina možete pegledati ovdije: <a href="{{requestUrl}}">Nekretnine</a> <div>
|
||||||
</div>`
|
</div>`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -43,7 +43,7 @@ module.exports = class OlxCrawler {
|
|||||||
|
|
||||||
if (null !== finalResult) {
|
if (null !== finalResult) {
|
||||||
if (finalResult.lat !== undefined && finalResult.lat !== null && finalResult.lat !== "") {
|
if (finalResult.lat !== undefined && finalResult.lat !== null && finalResult.lat !== "") {
|
||||||
const pointInsideBoundingBox = await findPointInsideBoundingBox([finalResult.lng, finalResult.lat], finalResult.email);
|
const pointInsideBoundingBox = await findPointInsideBoundingBox([finalResult.lng, finalResult.lat], finalResult.email, finalResult.uuid);
|
||||||
|
|
||||||
|
|
||||||
if (pointInsideBoundingBox[0].length !== 0) {
|
if (pointInsideBoundingBox[0].length !== 0) {
|
||||||
|
|||||||
@@ -77,8 +77,8 @@ const allMarketAlertsByRequest = async (request) => {
|
|||||||
*
|
*
|
||||||
* @returns array of MarketAlerts
|
* @returns array of MarketAlerts
|
||||||
*/
|
*/
|
||||||
const findPointInsideBoundingBox = async (latLng, email) => {
|
const findPointInsideBoundingBox = async (latLng, email, uniqueId) => {
|
||||||
return await db.sequelize.query(`SELECT * FROM "RealEstateRequests" WHERE email = '${email}' AND subscribed = true AND ST_Contains("RealEstateRequests".bounding_box, ST_GEOMFROMTEXT('POINT (${latLng[0]} ${latLng[1]})'))`);
|
return await db.sequelize.query(`SELECT * FROM "RealEstateRequests" WHERE email = '${email}' AND "uniqueId" = '${uniqueId}' AND subscribed = true AND ST_Contains("RealEstateRequests".bounding_box, ST_GEOMFROMTEXT('POINT (${latLng[0]} ${latLng[1]})'))`);
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = {
|
module.exports = {
|
||||||
|
|||||||
Reference in New Issue
Block a user