From 683778cb7bf48d7c3f39649be0c3a665e6bd2af6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Andr=C3=A9=20S=C3=A1?= <github-siiky@net-c.cat>
Date: Fri, 12 Nov 2021 14:50:47 +0000
Subject: [PATCH] feat: cashbox batch table and update bills

---
 lib/cashbox-batches.js                        | 37 +++++++++++++++++++
 .../1616528363530-add_cashbox_batches.js      | 26 +++++++++++++
 2 files changed, 63 insertions(+)
 create mode 100644 lib/cashbox-batches.js
 create mode 100644 migrations/1616528363530-add_cashbox_batches.js

diff --git a/lib/cashbox-batches.js b/lib/cashbox-batches.js
new file mode 100644
index 00000000..18e7e3c1
--- /dev/null
+++ b/lib/cashbox-batches.js
@@ -0,0 +1,37 @@
+const db = require('./db')
+const _ = require('lodash/fp')
+const uuid = require('uuid')
+
+function createCashboxBatch (deviceId, cashboxCount) {
+  if (_.isEqual(0, cashboxCount)) throw new Error('Cashbox is empty. Cashbox batch could not be created.')
+  const sql = `INSERT INTO cashbox_batches (id, device_id, created, operation_type) VALUES ($1, $2, now(), 'cash-in-empty') RETURNING *`
+  const sql2 = `
+    UPDATE bills SET cashbox_batch_id=$1
+    FROM cash_in_txs
+    WHERE bills.cash_in_txs_id = cash_in_txs.id AND
+          cash_in_txs.device_id = $2 AND
+          bills.cashbox_batch_id IS NULL
+  `
+  return db.tx(async t => {
+    const newBatch = await t.oneOrNone(sql, [uuid.v4(), deviceId])
+    return t.oneOrNone(sql2, [newBatch.id, newBatch.device_id])
+  })
+}
+
+function getBatches () {
+  const sql = `SELECT cb.id, cb.device_id, cb.created, cb.operation_type, cb.bill_count_override, cb.performed_by,
+  json_agg(b.*) AS bills FROM cashbox_batches cb LEFT JOIN bills b ON cb.id=b.cashbox_batch_id GROUP BY cb.id`
+  return db.any(sql).then(res => _.map(it => _.mapKeys(ite => _.camelCase(ite), it), res))
+}
+
+function editBatchById (id, performedBy) {
+  const sql = `UPDATE cashbox_batches SET performed_by=$1 WHERE id=$2`
+  return db.none(sql, [performedBy, id])
+}
+
+function getBillsByBatchId (id) {
+  const sql = `SELECT * FROM bills WHERE cashbox_batch_id=$1`
+  return db.any(sql, [id])
+}
+
+module.exports = { createCashboxBatch, getBatches, getBillsByBatchId, editBatchById }
diff --git a/migrations/1616528363530-add_cashbox_batches.js b/migrations/1616528363530-add_cashbox_batches.js
new file mode 100644
index 00000000..bfb88db3
--- /dev/null
+++ b/migrations/1616528363530-add_cashbox_batches.js
@@ -0,0 +1,26 @@
+var db = require('./db')
+
+exports.up = function (next) {
+  var sqls = [
+    `create table cashbox_batches (
+      id uuid PRIMARY KEY,
+      device_id text REFERENCES devices (device_id),
+      created timestamptz NOT NULL default now()
+    )`,
+
+    `ALTER TABLE bills ADD COLUMN legacy boolean DEFAULT false`,
+
+    `ALTER TABLE bills ADD COLUMN cashbox_batch_id uuid`,
+
+    `ALTER TABLE bills ADD CONSTRAINT cashbox_batch_id
+    FOREIGN KEY (cashbox_batch_id)
+    REFERENCES cashbox_batches (id)`,
+
+    `UPDATE bills SET legacy = 'true'`
+  ]
+  db.multi(sqls, next)
+}
+
+exports.down = function (next) {
+  next()
+}