git pu

change.js

@@ -35,7 +35,7 @@ run()
 async function run() {
     let files = await fs.readdirSync(path)
     for (let i = 0; i < files.length; i++) {
-        if (!files[i].includes('Lp') )
+        if (!files[i].includes('id') )
             continue
 
 
@@ -48,12 +48,16 @@ async function run() {
 
 
         let vars = ai.run(data)
-console.log(vars.VarProfitDrawDownZeroProfit)
-        datas.push({name: files[i], size: stats.size, vars: vars})
+        let sp=files[i].split('_')
+        let  id=sp[4]
+        let usage=sp[5]
+        let value=parseFloat(sp[6])
+//console.log(vars.VarProfitDrawDownZeroProfit)
+        datas.push({name: files[i], size: stats.size, vars: vars,id:id,usage:usage,value:value})
     }
 
-    // console.log(datas)
-    checker()
+     console.log(datas)
+  //  checker()
 
 }
 
@@ -88,7 +92,7 @@ function grabData(data) {
 //         name=name.split('\\')
 //         name=name[name.length-1]
 //         console.log('%s changed.', name);
-//         if (name.includes('220518212916_O1_ETHUSDT_Lp1_ETH'))
+//         if (name.includes('220518212916_O1_ETHUSDT_id1_ETH'))
 //             updateVars(name)
 //
 //     });
@@ -100,7 +104,7 @@ async function checker() {
     let files = await fs.readdirSync(path)
     for (let i = 0; i < files.length; i++) {
 
-        if (!files[i].includes('Lp'))
+        if (!files[i].includes('id'))
             continue
 
 
@@ -131,21 +135,21 @@ async function updateVars(name) {
     lastFile = lastFile.split('\n')
     // console.log([lastFile[lastFile.length-2]])
     let lastData = lastFile[lastFile.length - 2]
-    let lp=name.split('_')[3].replace('Lp','')
-    lp=parseInt(lp)/100
+    let id=name.split('_')[3].replace('id','')
+    id=parseInt(id)/100
     let qty=0.01
-    // if (name.includes('Lp1'))
+    // if (name.includes('id1'))
     //     qty=0.01
-    // else if (name.includes('Lp2'))
+    // else if (name.includes('id2'))
     //     qty=0.02
-    // else if (name.includes('Lp3'))
+    // else if (name.includes('id3'))
     //     qty=0.03
-    // else if (name.includes('Lp4'))
+    // else if (name.includes('id4'))
     //     qty=0.04
 
-    // else if (name.includes('Lp5'))
+    // else if (name.includes('id5'))
     //     qty=0.05
-    // else if (name.includes('Lp6'))
+    // else if (name.includes('id6'))
     //     qty=0.05
     if (lastData.includes('Buy')) {
     //   bybit.reduceOrder('Buy',qty)

package.json

@@ -24,6 +24,7 @@
     "node-stream-zip": "^1.15.0",
     "node-watch": "^0.7.3",
     "nodejs-file-downloader": "^4.9.3",
+    "redis": "^4.1.0",
     "request": "^2.88.2",
     "shelljs": "^0.8.4",
     "stringify-object": "^4.0.1",

test_json.js

@@ -11,6 +11,16 @@
 // p=parseFloat(p[0])
 // console.log(p)
 
-let t='220522181407_O1_ETHUSDT_Lp1_ETH.csv'
-let lp=t.split('_')[3].replace('Lp','')
-console.log(parseInt(lp)/100)
+// let t='220522181407_O1_ETHUSDT_Lp1_ETH.csv'
+// let lp=t.split('_')[3].replace('Lp','')
+// console.log(parseInt(lp)/100)
+//
+//
+// let header=''
+
+let t='220524120420_O1_ETHUSDT_Lp3_id3_ProfitZeroProfit_0.3_ETH.csv'
+let sp=t.split('_')
+let  id=sp[4]
+let usage=sp[5]
+let value=parseFloat(sp[6])
+console.log(id,usage,value)

test_redis.js

+let   redis  =require('redis')
+
+
+const client = redis.createClient(
+    {url: 'redis://default:p@db.zignaly.xyz:7001'}
+);
+
+run()
+async function run()
+{
+    client.on('error', (err) => console.log('Redis Client Error', err));
+
+    await client.connect();
+
+ //   await client.set('key', 'value');
+ //    const value = await client.get('key');
+ //    console.log(value)
+    const [set, get,dell] = await client
+        .multi()
+        .set('key2', JSON.stringify({qty:2}))
+        .get('key2')
+
+        .exec();
+    console.log(set,get,dell)
+
+}
+