绝味门店

var request = require("request");
var mysql = require('mysql');

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: 'mysql',
    port: 3307
});
connection.connect();

request("http://www.juewei.cn/js/data/city-pinyin.json", function (error, response) {
    var newArr = [];
    var arr = JSON.parse(response.body);
    var dic = ["a", "b", "c", "d", "e", "f", "g", "h", "j", "k", "l", "m", "n", "p", "q", "r", "s", "t", "w", "x", "y", "z"];
    for (var i = 0; i < dic.length; i++) {
        var zm = dic[i];
        for (var j = 0; j < arr[zm].length; j++) {
            var Addrid = arr[zm][j].addrid;
            var Name = arr[zm][j].name;
            var ParentName = arr[zm][j].parentName;
            newArr.push(Addrid);

            //--------机构入库-----------
            var addSql = 'INSERT INTO jueweiPosCode(id,addrid,name,parentName) VALUES(0,?,?,?)';
            var addSqlParams = [Addrid, Name, ParentName];
            connection.query(addSql, addSqlParams, function (err, result) {
                if (err) {
                    console.log('[INSERT ERROR] - ', err.message);
                    return;
                }
                console.log('----INSERT----');
            }); 
        }
    }

    for (var i = 0; i < newArr.length; i++) {
        request("http://www.juewei.cn/js/data/jw-shop/"+newArr[i]+".json", function (error, response) {
            if (response.body) {
                if (response.body != undefined && response.body != null & response.body != "") {
                    var dataArr = JSON.parse(response.body);
                    if (dataArr.length > 0) {
                        for (var j = 0; j < dataArr.length; j++) {
                            var addSql = 'INSERT INTO juewei(id,city_id,name,address,longitude,latitude,phone,province,city,town) VALUES(0,?,?,?,?,?,?,?,?,?)';
                            var addSqlParams = [dataArr[j].city_id, dataArr[j].name, dataArr[j].address, dataArr[j].longitude, dataArr[j].latitude, dataArr[j].phone, dataArr[j].province, dataArr[j].city, dataArr[j].town];
                            connection.query(addSql, addSqlParams, function (err, result) {
                                if (err) {
                                    console.log('[INSERT ERROR] - ', err.message);
                                    return;
                                }
                                console.log('----INSERT----');
                            });
                        }
                    }
                }
            }
        })
    }
})