SourceDataClient/app.js

global.config = require('./config');
process.setMaxListeners(0)
var db = require('./db'),
    usersProvider = db.usersProvider,
    branchsProvider = db.branchsProvider,
    addrGroupProvider = db.addrGroupProvider,
    addrGroupMemberProvider = db.addrGroupMemberProvider;
var client = require('./client');
var log4jsconfig = require('./log4js.json');
var log4js = require('log4js');
log4js.configure(log4jsconfig);
global.logger = log4js.getLogger();

var syncData = function() {
    var i = 0;
    for (i = 0; i <= config.dbs.length - 1; i++) {
        client.deleteUsers(config.dbs[i].serverId).then(function(serverid) {
            return usersProvider.getAll(serverid);
        }).then(function(users) {
            client.addUsers(users);
        }).catch(function(err) { logger.error(err) });
        client.deleteBranchs(config.dbs[i].serverId).then(function(serverId) {
            return branchsProvider.getAll(serverId);
        }).then(function(branchs) {
            return client.addBranchs(branchs);
        }).catch(function(err) { logger.error(err) });

        // add by thm 20170908 增加同步通讯录 start
        client.deleteAddrGroup(config.dbs[i].serverId).then(function(serverId) {
            return addrGroupProvider.getAll(serverId);
        }).then(function(addrGroups) {
            return client.addAddrGroup(addrGroups);
        }).catch(function(err) { logger.error(err) });

        let serverID = config.dbs[i].serverId;
        client.deleteAddrGroupMember(config.dbs[i].serverId).then(function(serverId) {
            return addrGroupMemberProvider.getAll(serverId);
        }).then(function(addrGroupMembers) {
            return client.addAddrGroupMember(addrGroupMembers, serverID);
        }).catch(function(err) { logger.error(err) });
        // add by thm 20170908 增加同步通讯录 end
    }
}

var schedule = require('node-schedule');
var rule = new schedule.RecurrenceRule();
rule.hour = [0, 12];
rule.minute = 0;
var jop;

jop = schedule.scheduleJob(rule, function() {
    logger.info('start asyn data!');
    syncData();
});

syncData()