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