dp change history

routes/api.js

@@ -99,22 +99,37 @@ var schedule = require('node-schedule');
 var j = schedule.scheduleJob('30 30 0 1 * *', function () {
     console.log('The scheduleJob run on first day of every month!', moment().format('YYYY-MM-DD HH:mm'));
 
+    /*
     pool.connect(function (err, client, done) {
         if (err) {
             return console.error('error fetching client from pool', err);
         }
 
-        var sql = `update user_info set pt = (pt - (pt - 1000) * 0.4 )
-                    where pt > 1000`
+        let sql = `update user_info set pt = (pt - (pt - 1000) * 0.4 )
+                    where pt > 1000`;
 
         client.query(sql, function (err, result) {
-            done()
+            done();
             if (err) {
                 return console.error('error running monthly scheduleJob', err);
             }
             console.log(result)
         });
     })
+    */
+    let time = moment().subtract(1, 'month');
+    let season = time.format('YYYY-MM');
+    let higher_limit = time.format('YYYY-MM-01 00:00:01');
+    let lower_limit = moment().subtract(1, 'day').format('YYYY-MM-DD 23:59:59');
+    let base = 1000;
+    pool.query('select monthly_user_historical_record($1::text, $2, $3::boolean, true)', [season, base, false], (err, result) => {
+        if (err)
+            return console.error('error running monthly scheduleJob', err);
+        else
+            pool.query('select collect_win_lose_rate($1, $2)', [lower_limit, higher_limit], (err, result) => {
+                if (err) console.error('error running monthly scheduleJob', err);
+            });
+    });
 });
 
 var Filter = require('bad-words-chinese');