|
@@ -476,6 +476,12 @@ async function crawlData(from, to, compilationID) {
|
|
|
} else { // 需求变更,需要排序
|
|
|
await priceInfoAreaModel.update({ ID: areaItem.ID }, { $set: { serialNo } });
|
|
|
}
|
|
|
+
|
|
|
+ const existCount = await priceInfoItemModel.count({ compilationID, period, areaID: areaItem.ID });
|
|
|
+ if (existCount) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
// 存入信息价相关数据
|
|
|
const sourceData = await getPriceInfoSource(token, sourcePeriod, city, county);
|
|
|
if (typeof sourceData === 'string') {
|