diff --git a/server/helper/heytripDataHelper.js b/server/helper/heytripDataHelper.js index 9b3d395..f8dab4a 100644 --- a/server/helper/heytripDataHelper.js +++ b/server/helper/heytripDataHelper.js @@ -1,4 +1,4 @@ -const { objectMapper: _objectMapper, isNotEmpty } = require('../utils/commons'); +const { objectMapper: _objectMapper, isNotEmpty, isEmpty } = require('../utils/commons'); const { DEFAULT_LGC, LGC_MAPPED } = require('../config/constants'); const objectMapper = (input, keyMap) => _objectMapper(input || {}, keyMap, false); @@ -213,6 +213,9 @@ const scoresMapper = (sourceName, hotelId, scores, lgcObj) => scores.map((item) const resolveDetails = (res, lgcObj) => { return res.reduce( (rd, c) => { + if (isEmpty(c.HotelName)) { + return rd; + } rd.info.push(infoDataMapper(c)); rd.info2.push(info2DataMapper(c, lgcObj)); rd.rooms = rd.rooms.concat(roomsMapper(c, lgcObj)); diff --git a/server/services/heytripService.js b/server/services/heytripService.js index 12a839c..cef7ddb 100644 --- a/server/services/heytripService.js +++ b/server/services/heytripService.js @@ -319,10 +319,10 @@ class Heytrip { AccommodationIds: allIds, }); - const resIds = res.map((item) => item.HotelId); // hotel info const insertData = resolveDetails(res, lgcObj); // return insertData; // debug: 0 + const resIds = insertData.info.map((item) => item.hotel_id); /** 开始Database */ const result = await Sequelize.transaction(async (transaction) => {