refactor: cleanup

Author: rayriffy

app.ts

@@ -13,6 +13,7 @@ import type { Order, ProcessedData } from "./types";
 import dayjs from "dayjs";
 import {creditCardCutOffDate} from "./config";
 import * as process from "node:process";
+import {logger} from "./logger";
 
 /**
  * Execute
@@ -40,11 +41,9 @@ const orderWithEmail: Record<string, string> = parse(fs.readFileSync("input/even
 const processedData: ProcessedData[] = (orders as Order[])
     // filter subtotal 0 away
     .filter(o => Number(o['Subtotal']) > 0)
-    .filter(o => o["Order #"] === '#38704-3215128')
     // beautify data
     .map(item => {
         const taxInfo = ordersWithTaxMap[item["Order #"]]
-        console.log(taxInfo)
 
         return {
             eventpopId: item['Order #'],
@@ -58,7 +57,7 @@ const processedData: ProcessedData[] = (orders as Order[])
             ticket: {
                 type: item["Ticket Type"],
                 amount: Number(item["Amount"]),
-                price: Number(item["Subtotal"])
+                price: Number(item["Unit Price"])
             },
             payment: {
                 method: item["Payment Method"] === "Bank transfer" ? 'bank' : 'credit',
@@ -77,23 +76,23 @@ const processedData: ProcessedData[] = (orders as Order[])
 
 fs.writeFileSync("output/processedData.json", JSON.stringify(processedData, null, 2))
 
-// const pickedData = [processedData[0]]
-// const pickedData = processedData
 const pickedData = processedData
-// .filter(o =>
-//     [
-//         "#38704-3216014", // credit, tax, withholding
-//         "#38704-3215164", // bank, tax, withholding
-//         "#38704-3215100", // credit, tax
-//         "#38704-3267295", // bank, tax
-//         "#38704-3225968", // credit
-//         "#38704-3215101", // bank,
-//         "#38704-3288940", // out of scope,
-//         "#38704-3251019", // company
-//         "#38704-3215560"   // company
-//
-//     ].includes(o.eventpopId)
-// )
+    // .filter(o =>
+    //     [
+    //         // "#38704-3216014", // credit, tax, withholding
+    //         // "#38704-3215164", // bank, tax, withholding
+    //         // "#38704-3215100", // credit, tax
+    //         // "#38704-3267295", // bank, tax
+    //         // "#38704-3225968", // credit
+    //         // "#38704-3215101", // bank,
+    //         // "#38704-3288940", // out of scope,
+    //         // "#38704-3251019", // company
+    //         // "#38704-3215560"   // company
+    //         "#38704-3244162"
+    //
+    //     ].includes(o.eventpopId)
+    // )
+
 
 ;(async () => {
     let index = 1
@@ -110,7 +109,7 @@ const pickedData = processedData
             if (item.payment.method === 'bank' || dayjs(item.payment.when).isBefore(dayjs(creditCardCutOffDate)))
                 await createPayment(item, invoice.recordId)
             else
-                console.log('payment:igno: ', item.eventpopId)
+                logger('payment', 'igno', item.eventpopId)
         } catch (e) {
             console.error('fail: ', item.eventpopId)
             console.error(e)

createInvoice.ts

@@ -2,10 +2,10 @@ import dayjs from 'dayjs'
 
 import { type ProcessedData } from "./types";
 import { headers } from './constants';
-import {creditCardBilledDate} from "./config";
 import {isExecuted} from "./isExecuted";
 import {execSync} from "child_process";
 import process from "node:process";
+import {logger} from "./logger";
 
 interface InvoiceResponse {
     recordId: number
@@ -19,7 +19,7 @@ interface PartialResponse {
 export const createInvoice = async (data: ProcessedData, index: number): Promise<InvoiceResponse> => {
     const cachedRecord = isExecuted('invoice', data.eventpopId)
     if (cachedRecord) {
-        console.log('invoice:skip: ', data.eventpopId)
+        logger('invoice', 'skip', data.eventpopId)
         return {
             recordId: Number(cachedRecord[1]),
             documentSerial: cachedRecord[2],
@@ -34,8 +34,6 @@ export const createInvoice = async (data: ProcessedData, index: number): Promise
     // const vat = Number((total * 0.07).toFixed(2));
     // const grandTotal = Number((total + vat).toFixed(2));
 
-    console.log(data)
-
     const raw = JSON.stringify({
         "isComplieAccountingRule": false,
         "documentContactCompanyChangeType": 7,
@@ -88,8 +86,8 @@ export const createInvoice = async (data: ProcessedData, index: number): Promise
             "discountPerItemValue": 0,
             "total": total,
             "pricePerUnit": data.ticket.price,
-            "originalPrice": data.ticket.price,
-            "originalPriceWithVat": data.ticket.price * 1.07,
+            "originalPrice": total,
+            "originalPriceWithVat": total * 1.07,
             "productMasterId": 6291394,
             "type": 1,
             "multipleUnits": [],
@@ -191,9 +189,7 @@ export const createInvoice = async (data: ProcessedData, index: number): Promise
             return result as PartialResponse
         })
 
-    console.log(invoice)
-
-    console.log('invoice:done: ', data.eventpopId)
+    logger('invoice', 'done', data.eventpopId)
     execSync(`echo "${data.eventpopId} ${invoice.data.recordId} ${invoice.data.documentSerial}" >> output/invoice.txt`, {
         cwd: process.cwd()
     })

createPayment.ts

@@ -5,10 +5,11 @@ import {creditCardBilledDate} from "./config";
 import {isExecuted} from "./isExecuted";
 import {execSync} from "child_process";
 import process from "node:process";
+import {logger} from "./logger";
 
 export const createPayment = (data: ProcessedData, recordId: number) => {
     if (isExecuted('payment', data.eventpopId)) {
-        console.log('payment:skip: ', data.eventpopId)
+        logger('payment', 'skip', data.eventpopId)
         return
     }
 
@@ -54,7 +55,7 @@ export const createPayment = (data: ProcessedData, recordId: number) => {
     body: JSON.stringify(payload),
     };
 
-    console.log('payment:done: ', data.eventpopId)
+    logger('payment', 'done', data.eventpopId)
     execSync(`echo "${data.eventpopId}" >> output/payment.txt`, {
         cwd: process.cwd()
     })

logger.ts

@@ -0,0 +1,19 @@
+import chalk from 'chalk'
+
+export const logger = (type: 'invoice' | 'payment', status: 'done' | 'skip' | 'igno' | 'fail', ...data: any[]) => {
+    const title = `${type}:${status}: `
+    switch (status) {
+        case "done":
+            console.log(chalk.green(title), ...data)
+            break
+        case "fail":
+            console.error(chalk.red(title), ...data)
+            break
+        case "skip":
+            console.log(chalk.yellow(title), ...data)
+            break
+        case "igno":
+            console.log(chalk.blue(title), ...data)
+            break
+    }
+}

package.json

@@ -11,6 +11,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
+    "chalk": "^5.3.0",
     "csv-parse": "5.5.6",
     "dayjs": "1.11.13",
     "dotenv": "16.4.5",

pnpm-lock.yaml

@@ -25,16 +25,25 @@ const invoices = fs.readFileSync("output/invoice.txt", "utf8").trim().split("\n"
         await fetch(`https://api-core-canary.flowaccount.com/api/th/tax-invoices/${invoice.recordId}/status-key/void`, {
             method: 'POST',
             headers
+        }).then(o => {
+            console.log(o.status)
+            return o
         })
         // reset it
         await fetch(`https://api-core-canary.flowaccount.com/api/th/tax-invoices/${invoice.recordId}/status-key/awaiting`, {
             method: 'POST',
             headers
+        }).then(o => {
+            console.log(o.status)
+            return o
         })
         // delete it
         await fetch(`https://api-core-canary.flowaccount.com/api/th/tax-invoices/${invoice.recordId}`, {
             method: 'DELETE',
             headers
+        }).then(o => {
+            console.log(o.status)
+            return o
         })
     }
 })()