|
@@ -4,25 +4,31 @@
|
|
|
|
|
|
let billsData = require('../../main/models/bills');
|
|
let billsData = require('../../main/models/bills');
|
|
let rationData = require('../../main/models/ration');
|
|
let rationData = require('../../main/models/ration');
|
|
|
|
+let projCounter = require('../../main/models/proj_counter');
|
|
let async = require('async');
|
|
let async = require('async');
|
|
|
|
|
|
module.exports = {
|
|
module.exports = {
|
|
copyProjectData: function (srcProjID, newProjID, callback) {
|
|
copyProjectData: function (srcProjID, newProjID, callback) {
|
|
var fun = [];
|
|
var fun = [];
|
|
var copyData = function (model) {
|
|
var copyData = function (model) {
|
|
- return () => {
|
|
|
|
- model.getProjectData(srcProjID).then(function (results) {
|
|
|
|
- let datas = [];
|
|
|
|
- results.forEach(function (result) {
|
|
|
|
- result._doc.projectID = newProjID;
|
|
|
|
- datas.push(result._doc);
|
|
|
|
- });
|
|
|
|
- return model.insertData(datas, callback);
|
|
|
|
- }).catch((err) => callback(err));
|
|
|
|
|
|
+ return (cb) => {
|
|
|
|
+ model.getQueryData({"projectID": srcProjID}, '-_id').then(function (results, err) {
|
|
|
|
+ if (results.length > 0) {
|
|
|
|
+ let datas = [];
|
|
|
|
+ results.forEach(function (result) {
|
|
|
|
+ result._doc.projectID = newProjID;
|
|
|
|
+ datas.push(result._doc);
|
|
|
|
+ });
|
|
|
|
+ return model.insertData(datas, cb);
|
|
|
|
+ } else {
|
|
|
|
+ cb(err);
|
|
|
|
+ }
|
|
|
|
+ }).catch(cb);
|
|
};
|
|
};
|
|
};
|
|
};
|
|
fun.push(copyData(billsData));
|
|
fun.push(copyData(billsData));
|
|
fun.push(copyData(rationData));
|
|
fun.push(copyData(rationData));
|
|
|
|
+ fun.push(copyData(projCounter));
|
|
async.parallel(fun, (err) => callback(err));
|
|
async.parallel(fun, (err) => callback(err));
|
|
}
|
|
}
|
|
};
|
|
};
|