TargetDataService/app.js

var restify = require('restify');
var Buffer  = require('bufferhelper');
global.config = require('./config');
var db = require('./db'),
    usersProvider = db.usersProvider,
    branchsProvider = db.branchsProvider;
 
var server = restify.createServer({
  name: 'target-data',
  version: '1.0.0'
});
server.use(restify.acceptParser(server.acceptable));
server.use(restify.queryParser());
server.use(restify.bodyParser());

server.post('/api/branchs', function(req, res)
{
      if (Array.isArray(req.body)){
        var promises = [];
        req.body.forEach(function(element) {
            promises.push(branchsProvider.insert(element))
        }, this);
        Promise.all(promises).then(function(){
                // res.send('{success:true}');
            }).catch(function(err){
                // res.send('{success:false}');
                 console.log('error:'+err);
            });
    }else{
                branchsProvider.insert(req.body).then(function(){
                // res.send('{success:true}');
            }).catch(function(err){
                // res.send('{success:false}');
                 console.log('error:'+err);
            });
    }    
    res.send('ok');
});
 
server.del('/api/branchs/:serverId', function(req, res)
{
    branchsProvider.delete(req.params.serverId).then(function(){
                res.send('{success:true}');
            }).catch(function(err){
                res.send('{success:false}');
                 console.log('error:'+err);
            });
});

server.post('/api/users', function(req, res){
    if (Array.isArray(req.body)){
        var promises = [];
        req.body.forEach(function(element) {
            promises.push(usersProvider.insert(element))
        }, this);
        Promise.all(promises).then(function(){
                // res.send('{success:true}');
            }).catch(function(err){
                // res.send('{success:false}');
                 console.log('error:'+err);
            });
    }else{
                usersProvider.insert(req.body).then(function(){
                // res.send('{success:true}');
            }).catch(function(err){
                // res.send('{success:false}');
                 console.log('error:'+err);
            });
    }
    res.send('ok');
});
 
server.del('/api/users/:serverId', function(req, res)
{
    usersProvider.delete(req.params.serverId).then(function(){
                res.send('{success:true}');
            }).catch(function(err){
                res.send('{success:false}');
                 console.log('error:'+err);
            });
});

server.listen(8080, function () {
  console.log('%s listening at %s', server.name, server.url);
});