init

brain.js

@@ -5,9 +5,11 @@ let prefix = 'work'
 let cores = 15
 
 
-init()
+//init()
 
 
+copyAllFiles()
+
 async function init() {
 
 
@@ -37,19 +39,19 @@ function makeStatus(directory) {
 
 
 async function check() {
-    let files = await fs.readdirSync('files')
+    let files = await fs.readdirSync('allFiles')
     let size = await fs.read
     for (let i = 0; i < files.length; i++) {
 
         if (!files[i].includes('csv')) {
-            await fs.unlinkSync('files/' + files[i])
+            await fs.unlinkSync('allFiles/' + files[i])
             continue
         }
 
-        let stats = await fs.statSync('files/' + files[i])
+        let stats = await fs.statSync('allFiles/' + files[i])
         if (stats.size < 500) {
 
-            await fs.unlinkSync('files/' + files[i])
+            await fs.unlinkSync('allFiles/' + files[i])
             continue
         }
         //  console.log(stats.size)
@@ -57,11 +59,12 @@ async function check() {
 
         let worker = await findOffWorker()
         //  console.log(worker)
+        let configFileName=files[i].split('-')[0]
 
         if (worker !== null) {
-            await fs.renameSync('files/' + files[i], worker + '/' + files[i])
+            await fs.renameSync('allFiles/' + files[i], worker + '/' + files[i])
             await makeStatusNew(worker, '1')
-            shell.exec('node run.js ' + worker, {async: true});
+            shell.exec('node run.js ' + worker +' '+configFileName, {async: true});
         }
 
 
@@ -74,6 +77,52 @@ async function check() {
     //  console.log(files)
 }
 
+
+async function copyAllFiles()
+{
+    let configs = await fs.readdirSync('configs')
+    for (let z=0;z<configs.length;z++)
+    {
+        try {
+            await fs.mkdirSync('result/' + configs[z])
+        }
+        catch (e)
+        {
+
+        }
+
+        let files = await fs.readdirSync('files')
+        let size = await fs.read
+        for (let i = 0; i < files.length; i++) {
+
+            if (!files[i].includes('csv')) {
+                await fs.unlinkSync('files/' + files[i])
+                continue
+            }
+
+            let stats = await fs.statSync('files/' + files[i])
+            if (stats.size < 500) {
+
+                await fs.unlinkSync('files/' + files[i])
+                continue
+            }
+
+
+
+
+
+
+                await fs.copyFileSync('files/' + files[i], 'allFiles' + '/' + configs[z]+'-'+files[i])
+
+
+
+
+        }
+    }
+
+    init()
+}
+
 function sleep(millis) {
     return new Promise(resolve => setTimeout(resolve, millis));
 }

run.js

@@ -2,6 +2,7 @@ let fs = require('fs')
 let csv = require('./csv')
 let _ = require('lodash')
 let directory
+let configFileName
 let csvFile
 let drawDown=[30,40,50]
 //const perf = require('execution-time')();
@@ -10,9 +11,10 @@ run()
 async function run() {
     var args = process.argv.slice(2);
     directory = args[0]
+    configFileName=args[1]
     await makeStatus(directory, '1')
     //  perf.start()
-    let configs = await fs.readFileSync('./configs.json', 'utf8')
+    let configs = await fs.readFileSync('./configs/'+configFileName, 'utf8')
     configs = JSON.parse(configs)
     let arr = []
     let files = await fs.readdirSync('./' + directory)
@@ -73,8 +75,8 @@ async function run() {
     let timestamp = Date.now()
     try {
 
-        await fs.mkdirSync('result/' + csvFile)
-        await fs.mkdirSync('result/' + csvFile+'/default')
+        await fs.mkdirSync('result/'+configFileName+'/' + csvFile)
+        await fs.mkdirSync('result/'+configFileName+'/' + csvFile+'/default')
         // await fs.mkdirSync('result/' + csvFile+'/drawDown30')
         // await fs.mkdirSync('result/' + csvFile+'/drawdown40')
         // await fs.mkdirSync('result/' + csvFile+'/drawdown50')
@@ -324,7 +326,7 @@ function createfile(data) {
 
 function createfileADV(type,filename, data) {
     return new Promise(function (resolve, reject) {
-        fs.writeFile('result/' + csvFile + '/'+type+ '/' + filename + '.json', data, 'utf8', function (err) {
+        fs.writeFile('result/'+configFileName+'/' + csvFile + '/'+type+ '/' + filename + '.json', data, 'utf8', function (err) {
             if (err) reject(err);
             else resolve(data);
         });