From 4ad77884d3666ff9bd59c49e2d2dc84b0cfc9feb Mon Sep 17 00:00:00 2001
From: Lei OT <lyt@hainatravel.com>
Date: Wed, 21 Aug 2024 16:00:59 +0800
Subject: [PATCH] =?UTF-8?q?perf:=20=E9=9D=99=E6=80=81=E4=BF=A1=E6=81=AF?=
 =?UTF-8?q?=E8=A7=A3=E6=9E=90:=20=E6=9C=89=E8=BF=94=E5=9B=9EID,=20?=
 =?UTF-8?q?=E5=AE=9E=E9=99=85=E6=97=A0=E6=95=B0=E6=8D=AE=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 server/helper/heytripDataHelper.js | 5 ++++-
 server/services/heytripService.js  | 2 +-
 2 files changed, 5 insertions(+), 2 deletions(-)

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) => {