用Nodejs抓取阿里巴巴企业联系人数据并导入微信

要实现从阿里巴巴抓取企业联系人数据，并将其导入微信，我们可以分为两步：首先通过 Node.js 抓取数据，然后将数据导入微信。由于直接导入微信涉及隐私和安全性问题，通常需要使用微信的开放平台 API 来实现间接操作。

抓取数据

我们已经有一个基本的抓取逻辑，现在补充完整：

安装依赖

npm install nodegrass jquery jsdom

抓取数据的完整代码

const nodegrass = require('nodegrass');
const $ = require('jquery');
const jsdom = require('jsdom');
const { JSDOM } = jsdom;

// 假设数据库连接已定义
const connection = /* 你的数据库连接 */;

function getHtml(pageid, cid) {
    const url = `http://daili.1688.com/daili/ajax.json?action=list/list_action&event_submit_doQueryFromList=true&pageNum=${pageid}&pageSize=15&stdcategoryid1=${cid}&_=1388454529278`;

    nodegrass.get(url, (data, status, headers) => {
        alibabaToDb(JSON.parse(data));
    }, 'utf-8').on('error', (e) => {
        console.log("Got error: " + e.message);
    });
}

function alibabaToDb(data) {
    data.data.forEach((val) => {
        console.log(val.tel);
        const value = {
            companyname: val.companyname,
            companyintroduction: val.companyintroduction,
            stdcategoryid1: val.stdcategoryid1,
            tel: val.tel,
            winportdomain: val.winportdomain,
            brandlogourl: val.brandlogourl,
            createdTime: Date.now()
        };
        sqlInsert('enterprise', value);
    });
}

function sqlInsert(table, fields) {
    let field = '';
    let val = '';
    for (let key in fields) {
        field += `${key},`;
        val += `"${fields[key]}",`;
    }
    field = field.slice(0, -1);
    val = val.slice(0, -1);

    const sql = `INSERT INTO ${table}(${field}) VALUES(${val})`;
    connection.query(sql, (err, res, fields) => {
        if (err) {
            return null;
        }
        console.log(res);
        connection.end();
    });
}

// 执行抓取
getHtml(1, 7); // 抓取第一页的行业分类为7（数码、电脑）的数据

将数据导入微信

由于微信的 API 涉及复杂的认证和安全机制，我们不能直接通过 API 添加好友或通讯录。你可以考虑以下方案：

1. 使用企业微信 API：企业微信提供了更开放的 API 接口，可以通过这些接口进行批量导入或发送消息。
2. 手动操作：如果你的数据量不大，可以先将数据导出到 Excel 或 CSV 文件，然后手动导入到微信中。

示例：使用企业微信 API 导入数据

1. 注册企业微信：注册并获取企业 ID 和应用凭证。
2. API 调用：使用企业微信提供的 API 进行数据导入。

const axios = require('axios');
const crypto = require('crypto');

// 假设获取到的 access_token
const accessToken = 'your_access_token_here';

// 获取公司信息
async function getCompanyInfo(companyName) {
    const response = await axios.get(`https://qyapi.weixin.qq.com/cgi-bin/department/list?access_token=${accessToken}`);
    return response.data.department;
}

// 添加成员
async function addMember(memberData) {
    const response = await axios.post(`https://qyapi.weixin.qq.com/cgi-bin/user/create?access_token=${accessToken}`, memberData);
    return response.data;
}

// 使用示例
const memberData = {
    userid: 'unique_id',
    name: '公司名称',
    mobile: '电话号码',
    department: [1], // 部门ID
};

addMember(memberData).then(console.log).catch(console.error);

请确保遵循企业微信的 API 文档和规则，以避免违反其使用政策。