...
|
...
|
@@ -129,7 +129,7 @@ const task = async({product, now, sizeRelation, isSpecialSize}) => { |
|
|
skus,
|
|
|
}, now);
|
|
|
} catch (error) {
|
|
|
logger.error(`[price-day-task] dayTask, ${error}`);
|
|
|
logger.error(`[price-day-task] dayTask, ${product.productId}, ${error}`);
|
|
|
}
|
|
|
};
|
|
|
|
...
|
...
|
@@ -164,7 +164,7 @@ module.exports = async() => { |
|
|
const isSpecialSize = Boolean(specialSizeProducts[product.productId]);
|
|
|
const inserted = await lockTask({product, now, sizeRelation, isSpecialSize});
|
|
|
|
|
|
insertTotal += inserted;
|
|
|
insertTotal += inserted || 0;
|
|
|
if (inx >= products.length - 1) {
|
|
|
sendMessage(insertTotal, new Date().getTime() * 1000000, 'price-day-task-inserted');
|
|
|
}
|
...
|
...
|
|