|
|
@ -168,7 +168,7 @@ class Heytrip {
|
|
|
|
// await HeytripIds.update({ update_flag: 99, priority: 99 }, { where: { pageIndex: [Op.gt]: pageIndex } });
|
|
|
|
// await HeytripIds.update({ update_flag: 99, priority: 99 }, { where: { pageIndex: [Op.gt]: pageIndex } });
|
|
|
|
// 同步结束; 本次没有的ID: 更新: 99=失效
|
|
|
|
// 同步结束; 本次没有的ID: 更新: 99=失效
|
|
|
|
const stateOff = await HeytripIds.findAll({
|
|
|
|
const stateOff = await HeytripIds.findAll({
|
|
|
|
raw: true,
|
|
|
|
raw: true, logging: false,
|
|
|
|
where: {
|
|
|
|
where: {
|
|
|
|
update_flag: { [Op.notIn]: [0, 1] },
|
|
|
|
update_flag: { [Op.notIn]: [0, 1] },
|
|
|
|
last_modify_time: { [Op.gt]: today },
|
|
|
|
last_modify_time: { [Op.gt]: today },
|
|
|
@ -186,22 +186,20 @@ class Heytrip {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const savedIds = await HeytripIds.findAll({
|
|
|
|
const savedIds = await HeytripIds.findAll({
|
|
|
|
raw: true,
|
|
|
|
raw: true, logging: false,
|
|
|
|
where: { hotel_id: validIds },
|
|
|
|
where: { hotel_id: validIds },
|
|
|
|
attributes: ['hotel_id'],
|
|
|
|
attributes: ['hotel_id'],
|
|
|
|
logging: false,
|
|
|
|
|
|
|
|
}); // savedIds <= validIds
|
|
|
|
}); // savedIds <= validIds
|
|
|
|
const savedPageIds = await HeytripIds.findAll({
|
|
|
|
const savedPageIds = await HeytripIds.findAll({
|
|
|
|
raw: true,
|
|
|
|
raw: true, logging: false,
|
|
|
|
where: { page_index: pageIndex, },
|
|
|
|
where: { page_index: pageIndex, },
|
|
|
|
attributes: ['hotel_id'],
|
|
|
|
attributes: ['hotel_id'],
|
|
|
|
// logging: false,
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
// 已存在ID: 更新: 状态, 页码, 时间
|
|
|
|
// 已存在ID: 更新: 状态, 页码, 时间
|
|
|
|
const stateNormal = savedIds.filter((item) => validIds.includes((item.hotel_id))).map((item) => item.hotel_id);
|
|
|
|
const stateNormal = savedIds.filter((item) => validIds.includes((item.hotel_id))).map((item) => item.hotel_id);
|
|
|
|
if (!isEmpty(stateNormal)) {
|
|
|
|
if (!isEmpty(stateNormal)) {
|
|
|
|
await HeytripIds.update({ update_flag: 0, priority: 0, page_index: pageIndex, last_modify_time: Sequelize.fn('NOW') }, { where: { hotel_id: stateNormal } });
|
|
|
|
await HeytripIds.update({ update_flag: 0, priority: 0, page_index: pageIndex, last_modify_time: Sequelize.fn('NOW') }, { where: { hotel_id: stateNormal } ,logging: false, });
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// 新增ID
|
|
|
|
// 新增ID
|
|
|
|
const newIds = validIds.filter((id) => !savedIds.map((item) => item.hotel_id).includes(id));
|
|
|
|
const newIds = validIds.filter((id) => !savedIds.map((item) => item.hotel_id).includes(id));
|
|
|
@ -212,7 +210,7 @@ class Heytrip {
|
|
|
|
// 页码滚动
|
|
|
|
// 页码滚动
|
|
|
|
const oldToNext = savedPageIds.filter((item) => !validIds.includes((item.hotel_id))).map((item) => item.hotel_id);
|
|
|
|
const oldToNext = savedPageIds.filter((item) => !validIds.includes((item.hotel_id))).map((item) => item.hotel_id);
|
|
|
|
if (!isEmpty(oldToNext)) {
|
|
|
|
if (!isEmpty(oldToNext)) {
|
|
|
|
await HeytripIds.update({ page_index: Number(pageIndex)+9999, update_flag: 99 }, { where: { hotel_id: oldToNext } });
|
|
|
|
await HeytripIds.update({ page_index: Number(pageIndex)+9999, update_flag: 99 }, { where: { hotel_id: oldToNext },logging: false, });
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
return {
|
|
|
|