44 lines
1.3 KiB
JavaScript
44 lines
1.3 KiB
JavaScript
const db = require('./db')
|
|
const uuid = require('uuid')
|
|
const _ = require('lodash/fp')
|
|
const BN = require('./bn')
|
|
const anonymous = require('../lib/constants').anonymousCustomer
|
|
const NUM_RESULTS = 20
|
|
|
|
function add (customer) {
|
|
const sql = 'insert into customers (id, phone, phone_at) values ($1, $2, now()) returning *'
|
|
return db.one(sql, [uuid.v4(), customer.phone])
|
|
}
|
|
|
|
function get (phone) {
|
|
const sql = 'select id, phone from customers where phone=$1'
|
|
return db.oneOrNone(sql, [phone])
|
|
.then(customer => {
|
|
if (!customer) return
|
|
return getDailyVolume(customer.id).then(dailyVolume => {
|
|
return _.set('dailyVolume', dailyVolume, customer)
|
|
})
|
|
})
|
|
}
|
|
|
|
function getDailyVolume (id) {
|
|
return Promise.all([
|
|
db.one(`select coalesce(sum(fiat), 0) as total from cash_in_txs
|
|
where customer_id=$1
|
|
and created > now() - interval '1 day'`, [id]),
|
|
db.one(`select coalesce(sum(fiat), 0) as total from cash_out_txs
|
|
where customer_id=$1
|
|
and created > now() - interval '1 day'`, [id])
|
|
]).then(([cashInTotal, cashOutTotal]) => {
|
|
return BN(cashInTotal.total).add(cashOutTotal.total)
|
|
})
|
|
}
|
|
|
|
function batch () {
|
|
const sql = `select * from customers
|
|
where id != $1
|
|
order by created desc limit $2`
|
|
return db.any(sql, [ anonymous.uuid, NUM_RESULTS ])
|
|
}
|
|
|
|
module.exports = { add, get, batch }
|