...
|
...
|
@@ -194,16 +194,16 @@ class XzhIndexModel extends global.yoho.BaseModel { |
|
|
mipUrl: 'http://www.yohomars.com'
|
|
|
};
|
|
|
|
|
|
// init global:yoho:seo:xzh:marsReal 11972
|
|
|
// init global:yoho:seo:xzh:marsReal 12222
|
|
|
let marsRealId = yield redis.getAsync('global:yoho:seo:xzh:marsReal');
|
|
|
let marsReal = [];
|
|
|
|
|
|
marsRealId = parseInt(marsRealId, 10) || 11972;
|
|
|
marsRealId = parseInt(marsRealId, 10) || 12222;
|
|
|
|
|
|
for (let i = 0; i < 8; i++) {
|
|
|
marsReal.push(yield that._getRp(`http://www.yohomars.com/share/store/${marsRealId}`, false));
|
|
|
marsIds.push(marsRealId);
|
|
|
marsRealId = (marsRealId + 2);
|
|
|
marsRealId = (marsRealId + 1);
|
|
|
}
|
|
|
|
|
|
_.each(marsReal, (mars, index) => {
|
...
|
...
|
@@ -214,7 +214,7 @@ class XzhIndexModel extends global.yoho.BaseModel { |
|
|
});
|
|
|
|
|
|
// 记录最后一次404或者上次推送成功连接id
|
|
|
lastId = lastId ? (lastId + 2) : marsIds.shift();
|
|
|
lastId = lastId ? (lastId + 1) : marsIds.shift();
|
|
|
yield redis.setAsync('global:yoho:seo:xzh:marsReal', lastId);
|
|
|
|
|
|
return that._sendData(initData.mip, XZHKEY.mars, 'realtime');
|
...
|
...
|
|