seo.js
3.86 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
'use strict';
const api = global.yoho.API;
const rp = require('request-promise');
const serviceApi = global.yoho.ServiceAPI;
const Promise = require('bluebird');
const co = Promise.coroutine;
const _ = require('lodash');
const logger = global.yoho.logger;
const helper = global.yoho.helpers;
const config = require('../config/config');
const schedule = require('node-schedule');
const qs = require('querystring');
const seoModel = require('./seoModel');
const baiduUrls = {
urls: 'http://data.zz.baidu.com/urls',
update: 'http://data.zz.baidu.com/update',
del: 'http://data.zz.baidu.com/del'
};
const siteUrls = {
pcProduct: {
site: 'https://item.yohobuy.com',
url: []
},
pcGuang: {
site: 'https://guang.yohobuy.com',
url: []
},
mProduct: {
site: 'https://m.yohobuy.com',
url: []
},
mGuang: {
site: 'https://guang.m.yohobuy.com',
url: [],
type: 'mip'
}
};
/**
* 获取最新1000条商品详情链接和逛详情链接
*/
const getUrls = () => {
let apiArr = [api.get('', {method: 'web.product.bdPromotion'}),
serviceApi.get('/guang/api/v2/article/getLastArticleList', {limit: 100})];
return api.all(apiArr).spread((productData, articleData) => {
_.forEach(_.get(productData, 'data', {}), value => {
siteUrls.pcProduct.url.push('https:' + helper.urlFormat(`/${value.id}.html`, null, 'item'));
siteUrls.mProduct.url.push('https:' + helper.urlFormat(`/product/${value.id}.html`, null, 'm'));
});
_.forEach(_.get(articleData, 'data.artList', {}), value => {
siteUrls.pcGuang.url.push('https:' + helper.urlFormat(`/${value.articleId}.html`, null, 'guang'));
siteUrls.mGuang.url.push('https:' + helper.urlFormat(`/mip/guang/info/${value.articleId}.html`
, null, 'guang.m'));
});
return siteUrls;
});
};
/**
* 将链接推送到百度站长
* @param params object {site: 'https://www.yohobuy.com', type: 'mip'} 默认不需要type
* @param urls
*/
const sendUrlsToBaidu = (params, urls) => {
let paramsDef = {
token: config.baiduToken
};
// 过滤无效的参数
_.forEach(params, (val, key) => {
if (!val) {
delete params[key];
}
});
qs.escape = (str) => {
return str;
};
let options = {
url: `${baiduUrls.urls}?${qs.stringify(Object.assign(paramsDef, params), null, null, {})}`,
headers: {
'Content-Type': 'text/plain'
},
method: 'post',
form: urls.join('\n'),
json: true,
timeout: 10000,
gzip: true
};
return rp(options).then(result => {
logger.info(Object.assign(params, result, {length: urls.length}));
});
};
/**
* 获取最新商品详情1000条和逛详情100条推送到相应的站点域名（pc和wap）
*/
const sendUrls = () => {
co(function*() {
// 获取pc/wap的商品详情和逛的链接
let sendArr = [],
urls = yield getUrls();
_.forEach(urls, value => {
sendArr.push(sendUrlsToBaidu({site: value.site, type: value.type}, value.url));
});
// 推送url
api.all(sendArr);
})();
};
// 同步建议词（把接口拓展的建议词同步到灰度redis）
const synchronousKeywords = (req, res) => {
seoModel.synchronousKeywords();
res.end();
};
// 定时缓慢爬取关键词页面生成缓存，防止蜘蛛爬取
// 向百度推送页面新的页面
const sendKeywordsUrls = (req, res) => {
seoModel.sendKeywordsUrls();
res.end();
};
/**
* 定时每天1点推送最新商品和文章，更新站点sitemap
*/
const start = () => {
schedule.scheduleJob('0 0 1 * * *', function() {
sendUrls();
});
};
module.exports = {
start,
sendUrls,
synchronousKeywords,
sendKeywordsUrls
};