Compare commits

..

109 Commits

Author SHA1 Message Date
Dan Gowans 118fc1959b fix undefined transaction time 2025-05-02 08:52:35 -04:00
Dan Gowans 9830bede34 linting 2025-05-01 14:53:07 -04:00
Dan Gowans 302a9a4c48 include "cms" in title 2025-05-01 12:45:59 -04:00
Dan Gowans fe9188d1fb version bump 2025-05-01 12:36:08 -04:00
Dan Gowans 4664366e12 linting 2025-05-01 12:32:36 -04:00
Dan Gowans afcdca959b use built in database backup function 2025-05-01 12:19:48 -04:00
Dan Gowans 434e15ba1d highlight today's funerals 2025-05-01 11:34:47 -04:00
Dan Gowans 39dc10369f show funeral home upcoming contracts 2025-05-01 11:20:33 -04:00
Dan Gowans 7371be711a restore deleted burial sites 2025-05-01 10:38:13 -04:00
Dan Gowans 9048235ef2 more deleted item loading 2025-05-01 09:26:40 -04:00
Dan Gowans 59b0fb7e5f ensure deleted items are loaded for import 2025-05-01 09:16:02 -04:00
Dan Gowans 57b6dbf35e use common "cremation" cemetery list 2025-05-01 08:55:34 -04:00
Dan Gowans c460d073e7 linting 2025-04-30 15:14:56 -04:00
Dan Gowans a7ce5a99cb add default city to interment modals 2025-04-30 15:11:12 -04:00
Dan Gowans db05999c72 track burial site capacities
alter table BurialSiteTypes
add bodyCapacityMax smallint

alter table BurialSiteTypes
add crematedCapacityMax smallint

alter table BurialSites
add bodyCapacity smallint

alter table BurialSites
add crematedCapacity smallint
2025-04-30 14:40:47 -04:00
Dan Gowans 9c47b48abc linting 2025-04-30 10:42:16 -04:00
Dan Gowans 2ed7902320 rename "switch to edit mode" buttons 2025-04-30 10:19:16 -04:00
Dan Gowans 7887230c86 linting 2025-04-30 10:00:59 -04:00
Dan Gowans 18edc57f70 update linter 2025-04-30 10:00:27 -04:00
Dan Gowans 656f1b052e linting 2025-04-30 08:45:39 -04:00
Dan Gowans 3c1d023ccd linting 2025-04-29 15:22:01 -04:00
Dan Gowans 2c506711fb add id to pdf file name 2025-04-29 14:57:07 -04:00
Dan Gowans 0dcdfaaa8a fix small screen alignment 2025-04-29 13:44:33 -04:00
Dan Gowans ba0c9f3287 version bump 2025-04-29 13:23:22 -04:00
Dan Gowans ab61a3e340 fix initializing database 2025-04-29 13:17:31 -04:00
Dan Gowans 111663a274 interment container type maint
closes #8
2025-04-29 13:14:43 -04:00
Dan Gowans 1c7bc96392 committal type table maint #8 2025-04-29 11:54:17 -04:00
Dan Gowans b26e8b17b2 restructure config table management
preparing for #8
- switch tabs for collapsed panels
- split the javascript into a file per table
2025-04-29 11:01:50 -04:00
Dan Gowans c9b10f3696 fix toggle panel-block 2025-04-29 10:03:30 -04:00
Dan Gowans 34c00b856b fix viewing work orders 2025-04-29 09:25:57 -04:00
Dan Gowans 0474631bf5 fix create cemeteries 2025-04-29 09:25:46 -04:00
Dan Gowans 927334d954 allow testUpdate user to update work orders 2025-04-28 15:46:54 -04:00
Dan Gowans 50551582c1 identify 'HO' funeral home 2025-04-28 15:40:39 -04:00
Dan Gowans 19a7c81766 linting 2025-04-28 15:30:48 -04:00
Dan Gowans f96d975aa0 avoid order number updates
when deleted records are loaded
2025-04-28 15:10:19 -04:00
Dan Gowans 3c4c85df19 import cleanup 2025-04-28 14:50:34 -04:00
Dan Gowans 0d2f6f78ce missed include deleted 2025-04-28 14:16:08 -04:00
Dan Gowans 007b47a1f0 linting 2025-04-28 14:08:46 -04:00
Dan Gowans 62efb70542 include deleted list items
for import purposes
2025-04-28 14:05:45 -04:00
Dan Gowans f440a35df7 linting 2025-04-28 14:05:18 -04:00
Dan Gowans 78cae2f964 disable map scroll wheel zoom 2025-04-28 13:11:39 -04:00
Dan Gowans afa0286a2a show funeral details on work order view 2025-04-28 13:08:31 -04:00
Dan Gowans 556a6a71b6 add "direction of arrival"
database update:

create table if not exists CemeteryDirectionsOfArrival (
cemeteryId integer not null,
directionOfArrival varchar(2) not null,
directionOfArrivalDescription varchar(100) not null,
primary key (cemeteryId, directionOfArrival),
foreign key (cemeteryId) references Cemeteries (cemeteryId)) without rowid

alter table Contracts
add directionOfArrival varchar(2)
2025-04-28 11:59:09 -04:00
Dan Gowans 96a41862bf heading icons on contract view 2025-04-25 15:36:45 -04:00
Dan Gowans f35946d0a5 readd missing is-nowrap class 2025-04-25 15:28:19 -04:00
Dan Gowans d4670603b7 clean up awaits 2025-04-25 15:23:38 -04:00
Dan Gowans 09b3de1086 required indicators 2025-04-25 14:27:35 -04:00
Dan Gowans c7640f6dfd death age calculator
closes #9
2025-04-25 14:18:24 -04:00
Dan Gowans 14bd8e0ea4 internal data lists
move deathAgePeriods and purchaserRelationships out of config
2025-04-25 13:41:31 -04:00
Dan Gowans b356d771ab rename config files 2025-04-25 13:27:24 -04:00
Dan Gowans b359aaf564 type issue 2025-04-25 13:26:39 -04:00
Dan Gowans c330dff849 adjustable results limit 2025-04-25 13:03:05 -04:00
Dan Gowans a4522ec4d0 updated selling points 2025-04-25 12:38:28 -04:00
Dan Gowans 3babad95c4 version bump 2025-04-25 11:53:42 -04:00
Dan Gowans 5767b14f76 try removing legacy puppeteer in testing 2025-04-25 11:50:46 -04:00
Dan Gowans eada41aaaa linting 2025-04-25 11:42:02 -04:00
Dan Gowans e09d1ddb5d debug logging alignment 2025-04-25 11:19:19 -04:00
Dan Gowans f6eb3bf550 create burial site from contract
closes #7
2025-04-25 10:52:55 -04:00
Dan Gowans dc9a9b2bcc show "no cemetery" when none selected 2025-04-25 10:12:50 -04:00
Dan Gowans e7f79cbc4f fix burial site images 2025-04-25 10:03:38 -04:00
Dan Gowans 9bfed5aa4d date field restrictions 2025-04-24 14:48:13 -04:00
Dan Gowans 9a153bb238 linting 2025-04-24 14:15:25 -04:00
Dan Gowans 41761dcc8c remove node 18 testing 2025-04-24 13:49:32 -04:00
Dan Gowans 36e2b0f9cc linting 2025-04-24 13:48:19 -04:00
Dan Gowans d4087caa74 switch work order create button permission 2025-04-24 13:07:52 -04:00
Dan Gowans 9c9b94199b highlight overpayment 2025-04-24 13:00:43 -04:00
Dan Gowans 96eb7f36dc gp connection error catch 2025-04-24 12:55:40 -04:00
Dan Gowans 4f6fc87e05 remove better-sqlite-pool 2025-04-24 11:59:27 -04:00
Dan Gowans 38c1288856 separate `canUpdateWorkOrders` permission 2025-04-24 09:36:44 -04:00
Dan Gowans a167ef4a16 rename types files 2025-04-24 09:24:25 -04:00
Dan Gowans 3da2aad21b fix add grouped fee 2025-04-24 09:15:20 -04:00
Dan Gowans dcbaad753b linting 2025-04-23 14:13:45 -04:00
Dan Gowans d46a94db07 link funeral home name 2025-04-23 14:13:36 -04:00
Dan Gowans bb3100c0b0 version bump 2025-04-23 13:03:14 -04:00
Dan Gowans 3f28571dc2 fix contract status filter 2025-04-23 12:55:55 -04:00
Dan Gowans 8f201e05b3 linting 2025-04-23 12:06:29 -04:00
Dan Gowans d5915db9bd contract finalized indicator 2025-04-23 11:58:28 -04:00
Dan Gowans 8e22ee1026 contract paging 2025-04-23 10:31:04 -04:00
Dan Gowans 9e6da86d80 linting import 2025-04-23 10:30:44 -04:00
Dan Gowans 31837d4370 dev dependencies 2025-04-23 10:30:27 -04:00
Dan Gowans 880a6fd23a add import latitude and longitude 2025-04-22 15:38:55 -04:00
Dan Gowans 125f1e0949 version bump 2025-04-22 15:22:51 -04:00
Dan Gowans d4280a3796 import updates 2025-04-22 15:21:21 -04:00
Dan Gowans b3e5d8e5ad fix missing labels 2025-04-22 15:21:10 -04:00
Dan Gowans df3f7725d3 linting and development 2025-04-22 13:51:02 -04:00
Dan Gowans b8c9fd723d darken domain label
trying to fix cypress accessibility issue
2025-04-22 11:39:27 -04:00
Dan Gowans 3b98ac6f15 menu titles 2025-04-22 10:57:28 -04:00
Dan Gowans 6d964eb93a link together sections 2025-04-22 10:44:14 -04:00
Dan Gowans 688e55857d cypress update 2025-04-22 10:43:48 -04:00
Dan Gowans 59ab59bb1f enforce light theme 2025-04-17 14:20:12 -04:00
Dan Gowans f7ae72d40a linting and polish 2025-04-16 15:43:35 -04:00
Dan Gowans 43d70d8967 restrict parent cemeteries
when the cemetery has child cemeteries
2025-04-16 15:33:15 -04:00
Dan Gowans cd47832247 show child cemeteries 2025-04-16 15:14:33 -04:00
Dan Gowans 966a2fc869 polish 2025-04-16 14:20:26 -04:00
Dan Gowans 0b767d6b88 documentation 2025-04-16 14:06:56 -04:00
Dan Gowans 5e2b90f2a2 version bump 2025-04-16 13:01:28 -04:00
Dan Gowans fb5c960bc7 linting 2025-04-16 12:51:12 -04:00
Dan Gowans 4a17f0ecfa fix broken cemetery create 2025-04-16 12:50:51 -04:00
Dan Gowans 86cc71d235 ssm cemetery details 2025-04-16 11:21:02 -04:00
Dan Gowans a4e4a11a59 polish 2025-04-16 11:20:44 -04:00
Dan Gowans 20702c598a increase max process cutoff 2025-04-15 14:48:42 -04:00
Dan Gowans 6cb36c4548 linting 2025-04-15 14:48:26 -04:00
Dan Gowans 2176158847 fix url 2025-04-15 13:57:07 -04:00
Dan Gowans ebc74816c2 polish 2025-04-15 13:56:50 -04:00
Dan Gowans 9f661f478f fix urls 2025-04-15 13:56:39 -04:00
Dan Gowans f652f27c5e documentation 2025-04-15 13:36:18 -04:00
Dan Gowans 3312f70967 framing up documentation 2025-04-15 13:20:26 -04:00
Dan Gowans ab6ee7a9e2 linting 2025-04-15 13:20:06 -04:00
Dan Gowans cc79209eb9 update contract icon 2025-04-15 11:52:03 -04:00
1025 changed files with 15216 additions and 9028 deletions

View File

@ -10,7 +10,7 @@ jobs:
strategy: strategy:
fail-fast: false fail-fast: false
matrix: matrix:
node: [ 18, 20, 22, 23 ] node: [ 20, 22, 23 ]
env: env:
CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }} CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
CYPRESS_RECORD_KEY: ${{ secrets.CYPRESS_RECORD_KEY }} CYPRESS_RECORD_KEY: ${{ secrets.CYPRESS_RECORD_KEY }}
@ -25,11 +25,12 @@ jobs:
- name: Install Application - name: Install Application
run: | run: |
npm uninstall puppeteer
npm ci npm ci
npm install -g mocha c8 cypress@14 npm install -g mocha c8 cypress@14
- name: Copy Test Config - name: Copy Test Config
run: cp ./data/config.testing.js ./data/config.js run: cp ./data/testing.config.js ./data/config.js
- name: Test Application Startup - name: Test Application Startup
run: npm run test:startup run: npm run test:startup

View File

@ -5,25 +5,28 @@
[![sunrise-cms](https://img.shields.io/endpoint?url=https://cloud.cypress.io/badge/simple/26a4bi&style=flat&logo=cypress)](https://cloud.cypress.io/projects/26a4bi/runs) [![sunrise-cms](https://img.shields.io/endpoint?url=https://cloud.cypress.io/badge/simple/26a4bi&style=flat&logo=cypress)](https://cloud.cypress.io/projects/26a4bi/runs)
[![Coverage Testing](https://github.com/cityssm/sunrise-cms/actions/workflows/coverage.yml/badge.svg)](https://github.com/cityssm/sunrise-cms/actions/workflows/coverage.yml) [![Coverage Testing](https://github.com/cityssm/sunrise-cms/actions/workflows/coverage.yml/badge.svg)](https://github.com/cityssm/sunrise-cms/actions/workflows/coverage.yml)
![Sunrise CMS](./docs/socialPreview.png) ![Sunrise CMS](./docs/images/socialPreview.png)
🚧 **In development** 🚧 🚧 **In development** 🚧
**A web-based application to assist cemetery managers with managing their cemetery records.** **A web-based application to assist cemetery managers with managing their cemetery records.**
![Burial Site View](./docs/burialSite-view.png) ![Burial Site View](./docs/images/burialSite-view.png)
This is a major refactoring of the now archived This is a major refactoring of the now archived
[Lot Occupancy System](https://github.com/cityssm/lot-occupancy-system), [Lot Occupancy System](https://github.com/cityssm/lot-occupancy-system),
originally built with multiple focuses in mind. This fork completely reworks the project originally built with multiple focuses in mind. This fork completely reworks the project
to focus exculsively on cemetery management. to focus exculsively on cemetery management.
[**User Documentation (In the Works)**](./docs/README.md)
## Why Sunrise CMS? ## Why Sunrise CMS?
### ✔️ Cemetery Maps are NOT Required ### ✔️ Cemetery Maps are NOT Required
Many cemetery applications rely on maps to drill down into burial sites. Many cemetery applications rely on maps to drill down into burial sites.
In Sunrise CMS, maps are completely optional, greatly reducing the effort needed to get started. In Sunrise CMS, maps are completely optional, greatly reducing the effort needed to get started,
and reducing the maintenance work when new blocks of burial sites are introduced.
### ✔️ The System Requirements are Very Low ### ✔️ The System Requirements are Very Low
@ -31,14 +34,14 @@ Sunrise CMS does not need an expensive server to run.
No separate database server is required either. No separate database server is required either.
The whole application could run on a current, modest workstation. The whole application could run on a current, modest workstation.
### ✔️ Track Unlimited Cemeteries and Burial Sites ### ✔️ Track Unlimited Cemeteries, Unlimited Burial Sites, Unlimited Contracts...
There are no limits to the number of records that can be tracked in Sunrise CMS. There are no limits to the number of records that can be tracked in Sunrise CMS.
### ✔️ Includes a Built-In Work Order System ### ✔️ Includes a Simple Built-In Work Order System
In addition to tracking data related to cemetery plots, In addition to tracking data related to cemetery plots,
Sunrise CMS can also track work order activities, like grave maintenance. Sunrise CMS can also track work order activities, like interments and grave maintenance.
### ✔️ Sunrise CMS is Free and Open Source ### ✔️ Sunrise CMS is Free and Open Source
@ -46,6 +49,7 @@ There's no cost to use it.
## About this Project ## About this Project
- 📘 [Documentation](./docs/README.md)
- 🤗 [Code of Conduct](CODE_OF_CONDUCT.md) - 🤗 [Code of Conduct](CODE_OF_CONDUCT.md)
- 🥰 [Contributing Guidelines](CONTRIBUTING.md) - 🥰 [Contributing Guidelines](CONTRIBUTING.md)
- 🛡️ [Security Policy](SECURITY.md) - 🛡️ [Security Policy](SECURITY.md)
@ -54,3 +58,13 @@ There's no cost to use it.
Although the system is quite niche, it's being released in an open source environment in hopes to pool developer resources from other municipalities looking to move away from older, legacy systems. Although the system is quite niche, it's being released in an open source environment in hopes to pool developer resources from other municipalities looking to move away from older, legacy systems.
It is being shared to start the dialog among other municipalities and present an option to those who may be looking to refresh their own cemetery systems. It is being shared to start the dialog among other municipalities and present an option to those who may be looking to refresh their own cemetery systems.
## More City Management Applications from the City of Sault Ste. Marie
[**General Licence Manager**](https://cityssm.github.io/general-licence-manager/)<br />
An application built to manage the general licences issued by municipalities.
[**Attendance Tracking**](https://cityssm.github.io/attendance-tracking/)<br />
Track employee absences, call outs, and more.
💡 Discover even more on [the City of Sault Ste. Marie's GitHub page](https://cityssm.github.io/).

View File

@ -1,2 +1,2 @@
theme: jekyll-theme-cayman theme: jekyll-theme-cayman
title: Sunrise Cemetery Management System title: Sunrise Cemetery Management System (CMS)

8
app.js
View File

@ -10,11 +10,12 @@ import rateLimit from 'express-rate-limit';
import session from 'express-session'; import session from 'express-session';
import createError from 'http-errors'; import createError from 'http-errors';
import FileStore from 'session-file-store'; import FileStore from 'session-file-store';
import dataLists from './data/dataLists.js';
import { DEBUG_NAMESPACE } from './debug.config.js'; import { DEBUG_NAMESPACE } from './debug.config.js';
import * as permissionHandlers from './handlers/permissions.js'; import * as permissionHandlers from './handlers/permissions.js';
import { getSafeRedirectURL } from './helpers/authentication.helpers.js';
import * as configFunctions from './helpers/config.helpers.js'; import * as configFunctions from './helpers/config.helpers.js';
import { useTestDatabases } from './helpers/database.helpers.js'; import { useTestDatabases } from './helpers/database.helpers.js';
import { getSafeRedirectURL } from './helpers/functions.authentication.js';
import * as printFunctions from './helpers/functions.print.js'; import * as printFunctions from './helpers/functions.print.js';
import routerAdmin from './routes/admin.js'; import routerAdmin from './routes/admin.js';
import routerApi from './routes/api.js'; import routerApi from './routes/api.js';
@ -28,7 +29,7 @@ import routerPrint from './routes/print.js';
import routerReports from './routes/reports.js'; import routerReports from './routes/reports.js';
import routerWorkOrders from './routes/workOrders.js'; import routerWorkOrders from './routes/workOrders.js';
import { version } from './version.js'; import { version } from './version.js';
const debug = Debug(`${DEBUG_NAMESPACE}:app:${process.pid}`); const debug = Debug(`${DEBUG_NAMESPACE}:app:${process.pid.toString().padEnd(5)}`);
/* /*
* INITIALIZE APP * INITIALIZE APP
*/ */
@ -79,7 +80,7 @@ app.use(session({
}, },
secret: configFunctions.getConfigProperty('session.secret'), secret: configFunctions.getConfigProperty('session.secret'),
store: new FileStoreSession({ store: new FileStoreSession({
logFn: Debug(`${DEBUG_NAMESPACE}:session:${process.pid}`), logFn: Debug(`${DEBUG_NAMESPACE}:session:${process.pid.toString().padEnd(5)}`),
path: './data/sessions', path: './data/sessions',
retries: 20 retries: 20
}), }),
@ -141,6 +142,7 @@ app.use((request, response, next) => {
response.locals.configFunctions = configFunctions; response.locals.configFunctions = configFunctions;
response.locals.printFunctions = printFunctions; response.locals.printFunctions = printFunctions;
response.locals.dateTimeFunctions = dateTimeFunctions; response.locals.dateTimeFunctions = dateTimeFunctions;
response.locals.dataLists = dataLists;
response.locals.urlPrefix = configFunctions.getConfigProperty('reverseProxy.urlPrefix'); response.locals.urlPrefix = configFunctions.getConfigProperty('reverseProxy.urlPrefix');
next(); next();
}); });

9
app.ts
View File

@ -12,11 +12,12 @@ import session from 'express-session'
import createError from 'http-errors' import createError from 'http-errors'
import FileStore from 'session-file-store' import FileStore from 'session-file-store'
import dataLists from './data/dataLists.js'
import { DEBUG_NAMESPACE } from './debug.config.js' import { DEBUG_NAMESPACE } from './debug.config.js'
import * as permissionHandlers from './handlers/permissions.js' import * as permissionHandlers from './handlers/permissions.js'
import { getSafeRedirectURL } from './helpers/authentication.helpers.js'
import * as configFunctions from './helpers/config.helpers.js' import * as configFunctions from './helpers/config.helpers.js'
import { useTestDatabases } from './helpers/database.helpers.js' import { useTestDatabases } from './helpers/database.helpers.js'
import { getSafeRedirectURL } from './helpers/functions.authentication.js'
import * as printFunctions from './helpers/functions.print.js' import * as printFunctions from './helpers/functions.print.js'
import routerAdmin from './routes/admin.js' import routerAdmin from './routes/admin.js'
import routerApi from './routes/api.js' import routerApi from './routes/api.js'
@ -31,7 +32,7 @@ import routerReports from './routes/reports.js'
import routerWorkOrders from './routes/workOrders.js' import routerWorkOrders from './routes/workOrders.js'
import { version } from './version.js' import { version } from './version.js'
const debug = Debug(`${DEBUG_NAMESPACE}:app:${process.pid}`) const debug = Debug(`${DEBUG_NAMESPACE}:app:${process.pid.toString().padEnd(5)}`)
/* /*
* INITIALIZE APP * INITIALIZE APP
@ -107,7 +108,7 @@ app.use(
}, },
secret: configFunctions.getConfigProperty('session.secret'), secret: configFunctions.getConfigProperty('session.secret'),
store: new FileStoreSession({ store: new FileStoreSession({
logFn: Debug(`${DEBUG_NAMESPACE}:session:${process.pid}`), logFn: Debug(`${DEBUG_NAMESPACE}:session:${process.pid.toString().padEnd(5)}`),
path: './data/sessions', path: './data/sessions',
retries: 20 retries: 20
}), }),
@ -244,6 +245,8 @@ app.use((request, response, next) => {
response.locals.printFunctions = printFunctions response.locals.printFunctions = printFunctions
response.locals.dateTimeFunctions = dateTimeFunctions response.locals.dateTimeFunctions = dateTimeFunctions
response.locals.dataLists = dataLists
response.locals.urlPrefix = configFunctions.getConfigProperty( response.locals.urlPrefix = configFunctions.getConfigProperty(
'reverseProxy.urlPrefix' 'reverseProxy.urlPrefix'
) )

View File

@ -9,15 +9,17 @@ import exitHook from 'exit-hook';
import { initializeDatabase } from '../database/initializeDatabase.js'; import { initializeDatabase } from '../database/initializeDatabase.js';
import { DEBUG_NAMESPACE } from '../debug.config.js'; import { DEBUG_NAMESPACE } from '../debug.config.js';
import { getConfigProperty } from '../helpers/config.helpers.js'; import { getConfigProperty } from '../helpers/config.helpers.js';
import version from '../version.js';
const debug = Debug(`${DEBUG_NAMESPACE}:www:${process.pid}`); const debug = Debug(`${DEBUG_NAMESPACE}:www:${process.pid}`);
// INITIALIZE THE DATABASE // INITIALIZE THE DATABASE
await initializeDatabase(); initializeDatabase();
const directoryName = path.dirname(fileURLToPath(import.meta.url)); const directoryName = path.dirname(fileURLToPath(import.meta.url));
const processCount = Math.min(getConfigProperty('application.maximumProcesses'), os.cpus().length); const processCount = Math.min(getConfigProperty('application.maximumProcesses'), os.cpus().length * 2);
const applicationName = getConfigProperty('application.applicationName'); const applicationName = getConfigProperty('application.applicationName');
process.title = `${applicationName} (Primary)`; process.title = `${applicationName} (Primary)`;
debug(`Primary pid: ${process.pid}`); debug(`Primary pid: ${process.pid}`);
debug(`Primary title: ${process.title}`); debug(`Primary title: ${process.title}`);
debug(`Version: ${version}`);
debug(`Launching ${processCount} processes`); debug(`Launching ${processCount} processes`);
const clusterSettings = { const clusterSettings = {
exec: `${directoryName}/wwwProcess.js` exec: `${directoryName}/wwwProcess.js`

View File

@ -11,18 +11,19 @@ import exitHook from 'exit-hook'
import { initializeDatabase } from '../database/initializeDatabase.js' import { initializeDatabase } from '../database/initializeDatabase.js'
import { DEBUG_NAMESPACE } from '../debug.config.js' import { DEBUG_NAMESPACE } from '../debug.config.js'
import { getConfigProperty } from '../helpers/config.helpers.js' import { getConfigProperty } from '../helpers/config.helpers.js'
import type { WorkerMessage } from '../types/applicationTypes.js' import type { WorkerMessage } from '../types/application.types.js'
import version from '../version.js'
const debug = Debug(`${DEBUG_NAMESPACE}:www:${process.pid}`) const debug = Debug(`${DEBUG_NAMESPACE}:www:${process.pid}`)
// INITIALIZE THE DATABASE // INITIALIZE THE DATABASE
await initializeDatabase() initializeDatabase()
const directoryName = path.dirname(fileURLToPath(import.meta.url)) const directoryName = path.dirname(fileURLToPath(import.meta.url))
const processCount = Math.min( const processCount = Math.min(
getConfigProperty('application.maximumProcesses'), getConfigProperty('application.maximumProcesses'),
os.cpus().length os.cpus().length * 2
) )
const applicationName = getConfigProperty('application.applicationName') const applicationName = getConfigProperty('application.applicationName')
@ -31,6 +32,7 @@ process.title = `${applicationName} (Primary)`
debug(`Primary pid: ${process.pid}`) debug(`Primary pid: ${process.pid}`)
debug(`Primary title: ${process.title}`) debug(`Primary title: ${process.title}`)
debug(`Version: ${version}`)
debug(`Launching ${processCount} processes`) debug(`Launching ${processCount} processes`)
const clusterSettings = { const clusterSettings = {

View File

@ -7,10 +7,10 @@ import { app } from '../app.js';
import { initializeDatabase } from '../database/initializeDatabase.js'; import { initializeDatabase } from '../database/initializeDatabase.js';
import { DEBUG_NAMESPACE } from '../debug.config.js'; import { DEBUG_NAMESPACE } from '../debug.config.js';
import { getConfigProperty } from '../helpers/config.helpers.js'; import { getConfigProperty } from '../helpers/config.helpers.js';
const debug = Debug(`${DEBUG_NAMESPACE}:wwwProcess:${process.pid}`); const debug = Debug(`${DEBUG_NAMESPACE}:wwwProcess:${process.pid.toString().padEnd(5)}`);
if (process.send === undefined) { if (process.send === undefined) {
// INITIALIZE THE DATABASE // INITIALIZE THE DATABASE
await initializeDatabase(); initializeDatabase();
} }
function onError(error) { function onError(error) {
if (error.syscall !== 'listen') { if (error.syscall !== 'listen') {

View File

@ -11,11 +11,11 @@ import { initializeDatabase } from '../database/initializeDatabase.js'
import { DEBUG_NAMESPACE } from '../debug.config.js' import { DEBUG_NAMESPACE } from '../debug.config.js'
import { getConfigProperty } from '../helpers/config.helpers.js' import { getConfigProperty } from '../helpers/config.helpers.js'
const debug = Debug(`${DEBUG_NAMESPACE}:wwwProcess:${process.pid}`) const debug = Debug(`${DEBUG_NAMESPACE}:wwwProcess:${process.pid.toString().padEnd(5)}`)
if (process.send === undefined) { if (process.send === undefined) {
// INITIALIZE THE DATABASE // INITIALIZE THE DATABASE
await initializeDatabase() initializeDatabase()
} }
interface ServerError extends Error { interface ServerError extends Error {

View File

@ -1,6 +1,6 @@
import { getConfigProperty } from '../../../helpers/config.helpers.js' import { getConfigProperty } from '../../../helpers/config.helpers.js'
import { testAdmin } from '../../../test/_globals.js' import { testAdmin } from '../../../test/_globals.js'
import type { Fee } from '../../../types/recordTypes.js' import type { Fee } from '../../../types/record.types.js'
import { ajaxDelayMillis, login, logout } from '../../support/index.js' import { ajaxDelayMillis, login, logout } from '../../support/index.js'
describe('Admin - Fee Management', () => { describe('Admin - Fee Management', () => {

View File

@ -1,6 +1,6 @@
import { getConfigProperty } from '../../../helpers/config.helpers.js' import { getConfigProperty } from '../../../helpers/config.helpers.js'
import { testUpdate } from '../../../test/_globals.js' import { testUpdate } from '../../../test/_globals.js'
import type { Cemetery } from '../../../types/recordTypes.js' import type { Cemetery } from '../../../types/record.types.js'
import { login, logout } from '../../support/index.js' import { login, logout } from '../../support/index.js'
describe('Update - Cemeteries', () => { describe('Update - Cemeteries', () => {

View File

@ -1,3 +1,3 @@
import type { Config } from '../types/configTypes.js'; import type { Config } from '../types/config.types.js';
export declare const config: Config; export declare const config: Config;
export default config; export default config;

View File

@ -6,6 +6,7 @@ export const config = {
settings: { settings: {
adminCleanup: {}, adminCleanup: {},
burialSites: {}, burialSites: {},
burialSiteTypes: {},
cemeteries: {}, cemeteries: {},
contracts: {}, contracts: {},
dynamicsGP: { dynamicsGP: {

View File

@ -1,4 +1,4 @@
import type { Config } from '../types/configTypes.js' import type { Config } from '../types/config.types.js'
export const config: Config = { export const config: Config = {
aliases: {}, aliases: {},
@ -8,6 +8,7 @@ export const config: Config = {
settings: { settings: {
adminCleanup: {}, adminCleanup: {},
burialSites: {}, burialSites: {},
burialSiteTypes: {},
cemeteries: {}, cemeteries: {},
contracts: {}, contracts: {},
dynamicsGP: { dynamicsGP: {

View File

@ -1,2 +0,0 @@
export declare const config: import("../types/configTypes.js").Config;
export default config;

View File

@ -1,5 +1,5 @@
import type { config as MSSQLConfig } from 'mssql'; import type { config as MSSQLConfig } from 'mssql';
import type { ConfigActiveDirectory, ConfigBurialSiteNameSegments, ConfigNtfyStartup, DynamicsGPLookup } from '../types/configTypes.js'; import type { ConfigActiveDirectory, ConfigBurialSiteNameSegments, ConfigNtfyStartup, DynamicsGPLookup } from '../types/config.types.js';
export declare const configDefaultValues: { export declare const configDefaultValues: {
activeDirectory: ConfigActiveDirectory; activeDirectory: ConfigActiveDirectory;
'application.applicationName': string; 'application.applicationName': string;
@ -19,6 +19,7 @@ export declare const configDefaultValues: {
'session.secret': string; 'session.secret': string;
'users.canLogin': string[]; 'users.canLogin': string[];
'users.canUpdate': string[]; 'users.canUpdate': string[];
'users.canUpdateWorkOrders': string[];
'users.isAdmin': string[]; 'users.isAdmin': string[];
'users.testing': string[]; 'users.testing': string[];
'aliases.externalReceiptNumber': string; 'aliases.externalReceiptNumber': string;
@ -32,14 +33,14 @@ export declare const configDefaultValues: {
'settings.longitudeMax': number; 'settings.longitudeMax': number;
'settings.longitudeMin': number; 'settings.longitudeMin': number;
'settings.cemeteries.refreshImageChanges': boolean; 'settings.cemeteries.refreshImageChanges': boolean;
'settings.burialSiteTypes.bodyCapacityMaxDefault': number;
'settings.burialSiteTypes.crematedCapacityMaxDefault': number;
'settings.burialSites.burialSiteNameSegments': ConfigBurialSiteNameSegments; 'settings.burialSites.burialSiteNameSegments': ConfigBurialSiteNameSegments;
'settings.burialSites.burialSiteNameSegments.includeCemeteryKey': boolean; 'settings.burialSites.burialSiteNameSegments.includeCemeteryKey': boolean;
'settings.burialSites.refreshImageChanges': boolean; 'settings.burialSites.refreshImageChanges': boolean;
'settings.contracts.burialSiteIdIsRequired': boolean; 'settings.contracts.burialSiteIdIsRequired': boolean;
'settings.contracts.contractEndDateIsRequired': boolean; 'settings.contracts.contractEndDateIsRequired': boolean;
'settings.contracts.deathAgePeriods': string[];
'settings.contracts.prints': string[]; 'settings.contracts.prints': string[];
'settings.contracts.purchaserRelationships': string[];
'settings.fees.taxPercentageDefault': number; 'settings.fees.taxPercentageDefault': number;
'settings.workOrders.workOrderNumberLength': number; 'settings.workOrders.workOrderNumberLength': number;
'settings.workOrders.calendarEmailAddress': string; 'settings.workOrders.calendarEmailAddress': string;
@ -56,3 +57,4 @@ export declare const configDefaultValues: {
'settings.dynamicsGP.itemNumbers': string[]; 'settings.dynamicsGP.itemNumbers': string[];
'settings.dynamicsGP.trialBalanceCodes': string[]; 'settings.dynamicsGP.trialBalanceCodes': string[];
}; };
export default configDefaultValues;

View File

@ -18,6 +18,7 @@ export const configDefaultValues = {
'session.secret': 'cityssm/sunrise', 'session.secret': 'cityssm/sunrise',
'users.canLogin': ['administrator'], 'users.canLogin': ['administrator'],
'users.canUpdate': [], 'users.canUpdate': [],
'users.canUpdateWorkOrders': [],
'users.isAdmin': ['administrator'], 'users.isAdmin': ['administrator'],
'users.testing': [], 'users.testing': [],
'aliases.externalReceiptNumber': 'External Receipt Number', 'aliases.externalReceiptNumber': 'External Receipt Number',
@ -31,6 +32,10 @@ export const configDefaultValues = {
'settings.longitudeMax': 180, 'settings.longitudeMax': 180,
'settings.longitudeMin': -180, 'settings.longitudeMin': -180,
'settings.cemeteries.refreshImageChanges': false, 'settings.cemeteries.refreshImageChanges': false,
// eslint-disable-next-line no-secrets/no-secrets
'settings.burialSiteTypes.bodyCapacityMaxDefault': 2,
// eslint-disable-next-line no-secrets/no-secrets
'settings.burialSiteTypes.crematedCapacityMaxDefault': 6,
'settings.burialSites.burialSiteNameSegments': { 'settings.burialSites.burialSiteNameSegments': {
includeCemeteryKey: false, includeCemeteryKey: false,
separator: '-', separator: '-',
@ -48,21 +53,7 @@ export const configDefaultValues = {
'settings.burialSites.refreshImageChanges': false, 'settings.burialSites.refreshImageChanges': false,
'settings.contracts.burialSiteIdIsRequired': true, 'settings.contracts.burialSiteIdIsRequired': true,
'settings.contracts.contractEndDateIsRequired': false, 'settings.contracts.contractEndDateIsRequired': false,
'settings.contracts.deathAgePeriods': [
'Years',
'Months',
'Days',
'Stillborn'
],
'settings.contracts.prints': ['screen/contract'], 'settings.contracts.prints': ['screen/contract'],
'settings.contracts.purchaserRelationships': [
'Spouse',
'Child',
'Parent',
'Sibling',
'Friend',
'Self'
],
'settings.fees.taxPercentageDefault': 0, 'settings.fees.taxPercentageDefault': 0,
'settings.workOrders.workOrderNumberLength': 6, 'settings.workOrders.workOrderNumberLength': 6,
'settings.workOrders.calendarEmailAddress': 'no-reply@127.0.0.1', 'settings.workOrders.calendarEmailAddress': 'no-reply@127.0.0.1',
@ -80,3 +71,4 @@ export const configDefaultValues = {
'settings.dynamicsGP.itemNumbers': [], 'settings.dynamicsGP.itemNumbers': [],
'settings.dynamicsGP.trialBalanceCodes': [] 'settings.dynamicsGP.trialBalanceCodes': []
}; };
export default configDefaultValues;

View File

@ -1,13 +1,12 @@
import type { config as MSSQLConfig } from 'mssql'
import { hoursToMillis } from '@cityssm/to-millis' import { hoursToMillis } from '@cityssm/to-millis'
import type { config as MSSQLConfig } from 'mssql'
import type { import type {
ConfigActiveDirectory, ConfigActiveDirectory,
ConfigBurialSiteNameSegments, ConfigBurialSiteNameSegments,
ConfigNtfyStartup, ConfigNtfyStartup,
DynamicsGPLookup DynamicsGPLookup
} from '../types/configTypes.js' } from '../types/config.types.js'
export const configDefaultValues = { export const configDefaultValues = {
activeDirectory: undefined as unknown as ConfigActiveDirectory, activeDirectory: undefined as unknown as ConfigActiveDirectory,
@ -32,6 +31,7 @@ export const configDefaultValues = {
'users.canLogin': ['administrator'], 'users.canLogin': ['administrator'],
'users.canUpdate': [] as string[], 'users.canUpdate': [] as string[],
'users.canUpdateWorkOrders': [] as string[],
'users.isAdmin': ['administrator'], 'users.isAdmin': ['administrator'],
'users.testing': [] as string[], 'users.testing': [] as string[],
@ -51,6 +51,12 @@ export const configDefaultValues = {
'settings.cemeteries.refreshImageChanges': false, 'settings.cemeteries.refreshImageChanges': false,
// eslint-disable-next-line no-secrets/no-secrets
'settings.burialSiteTypes.bodyCapacityMaxDefault': 2,
// eslint-disable-next-line no-secrets/no-secrets
'settings.burialSiteTypes.crematedCapacityMaxDefault': 6,
'settings.burialSites.burialSiteNameSegments': { 'settings.burialSites.burialSiteNameSegments': {
includeCemeteryKey: false, includeCemeteryKey: false,
separator: '-', separator: '-',
@ -72,21 +78,8 @@ export const configDefaultValues = {
'settings.contracts.burialSiteIdIsRequired': true, 'settings.contracts.burialSiteIdIsRequired': true,
'settings.contracts.contractEndDateIsRequired': false, 'settings.contracts.contractEndDateIsRequired': false,
'settings.contracts.deathAgePeriods': [
'Years',
'Months',
'Days',
'Stillborn'
],
'settings.contracts.prints': ['screen/contract'], 'settings.contracts.prints': ['screen/contract'],
'settings.contracts.purchaserRelationships': [
'Spouse',
'Child',
'Parent',
'Sibling',
'Friend',
'Self'
],
'settings.fees.taxPercentageDefault': 0, 'settings.fees.taxPercentageDefault': 0,
@ -114,3 +107,5 @@ export const configDefaultValues = {
'settings.dynamicsGP.itemNumbers': [] as string[], 'settings.dynamicsGP.itemNumbers': [] as string[],
'settings.dynamicsGP.trialBalanceCodes': [] as string[] 'settings.dynamicsGP.trialBalanceCodes': [] as string[]
} }
export default configDefaultValues

9
data/dataLists.d.ts vendored 100644
View File

@ -0,0 +1,9 @@
export declare const deathAgePeriods: readonly ["Years", "Months", "Days", "Stillborn"];
export declare const purchaserRelationships: readonly ["Spouse", "Husband", "Wife", "Child", "Parent", "Sibling", "Friend", "Self"];
export declare const directionsOfArrival: readonly ["N", "NE", "E", "SE", "S", "SW", "W", "NW"];
declare const _default: {
deathAgePeriods: readonly ["Years", "Months", "Days", "Stillborn"];
directionsOfArrival: readonly ["N", "NE", "E", "SE", "S", "SW", "W", "NW"];
purchaserRelationships: readonly ["Spouse", "Husband", "Wife", "Child", "Parent", "Sibling", "Friend", "Self"];
};
export default _default;

26
data/dataLists.js 100644
View File

@ -0,0 +1,26 @@
export const deathAgePeriods = ['Years', 'Months', 'Days', 'Stillborn'];
export const purchaserRelationships = [
'Spouse',
'Husband',
'Wife',
'Child',
'Parent',
'Sibling',
'Friend',
'Self'
];
export const directionsOfArrival = [
'N',
'NE',
'E',
'SE',
'S',
'SW',
'W',
'NW'
];
export default {
deathAgePeriods,
directionsOfArrival,
purchaserRelationships
};

29
data/dataLists.ts 100644
View File

@ -0,0 +1,29 @@
export const deathAgePeriods = ['Years', 'Months', 'Days', 'Stillborn'] as const
export const purchaserRelationships = [
'Spouse',
'Husband',
'Wife',
'Child',
'Parent',
'Sibling',
'Friend',
'Self'
] as const
export const directionsOfArrival = [
'N',
'NE',
'E',
'SE',
'S',
'SW',
'W',
'NW'
] as const
export default {
deathAgePeriods,
directionsOfArrival,
purchaserRelationships
}

2
data/ontario.config.d.ts vendored 100644
View File

@ -0,0 +1,2 @@
export declare const config: import("../types/config.types.js").Config;
export default config;

View File

@ -1,4 +1,4 @@
import { config as baseConfig } from './config.base.js'; import { config as baseConfig } from './base.config.js';
export const config = Object.assign({}, baseConfig); export const config = Object.assign({}, baseConfig);
config.settings.provinceDefault = 'ON'; config.settings.provinceDefault = 'ON';
config.settings.latitudeMax = 56.85; config.settings.latitudeMax = 56.85;

View File

@ -1,4 +1,4 @@
import { config as baseConfig } from './config.base.js' import { config as baseConfig } from './base.config.js'
export const config = Object.assign({}, baseConfig) export const config = Object.assign({}, baseConfig)

View File

@ -1,3 +1,3 @@
import type { Config } from '../types/configTypes.js'; import type { Config } from '../types/config.types.js';
export declare const config: Config; export declare const config: Config;
export default config; export default config;

View File

@ -1,4 +1,4 @@
import { config as cemeteryConfig } from './config.baseOntario.js'; import { config as cemeteryConfig } from './ontario.config.js';
export const config = { ...cemeteryConfig }; export const config = { ...cemeteryConfig };
config.aliases.externalReceiptNumber = 'GP Receipt Number'; config.aliases.externalReceiptNumber = 'GP Receipt Number';
config.settings.publicInternalPath = config.settings.publicInternalPath =

View File

@ -1,6 +1,6 @@
import type { Config } from '../types/configTypes.js' import type { Config } from '../types/config.types.js'
import { config as cemeteryConfig } from './config.baseOntario.js' import { config as cemeteryConfig } from './ontario.config.js'
export const config: Config = { ...cemeteryConfig } export const config: Config = { ...cemeteryConfig }

View File

@ -1,3 +1,3 @@
import type { Config } from '../types/configTypes.js'; import type { Config } from '../types/config.types.js';
export declare const config: Config; export declare const config: Config;
export default config; export default config;

View File

@ -1,10 +1,11 @@
import { config as cemeteryConfig } from './config.baseSsm.js'; import { config as cemeteryConfig } from './ssm.ontario.config.js';
export const config = { ...cemeteryConfig }; export const config = { ...cemeteryConfig };
config.application.useTestDatabases = true; config.application.useTestDatabases = true;
config.session.doKeepAlive = true; config.session.doKeepAlive = true;
config.users = { config.users = {
canLogin: ['*testView', '*testUpdate', '*testAdmin'], canLogin: ['*testView', '*testUpdate', '*testAdmin'],
canUpdate: ['*testUpdate'], canUpdate: ['*testUpdate'],
canUpdateWorkOrders: ['*testUpdate'],
isAdmin: ['*testAdmin'], isAdmin: ['*testAdmin'],
testing: ['*testView', '*testUpdate', '*testAdmin'] testing: ['*testView', '*testUpdate', '*testAdmin']
}; };

View File

@ -1,6 +1,6 @@
import type { Config } from '../types/configTypes.js' import type { Config } from '../types/config.types.js'
import { config as cemeteryConfig } from './config.baseSsm.js' import { config as cemeteryConfig } from './ssm.ontario.config.js'
export const config: Config = { ...cemeteryConfig } export const config: Config = { ...cemeteryConfig }
@ -11,6 +11,7 @@ config.session.doKeepAlive = true
config.users = { config.users = {
canLogin: ['*testView', '*testUpdate', '*testAdmin'], canLogin: ['*testView', '*testUpdate', '*testAdmin'],
canUpdate: ['*testUpdate'], canUpdate: ['*testUpdate'],
canUpdateWorkOrders: ['*testUpdate'],
isAdmin: ['*testAdmin'], isAdmin: ['*testAdmin'],
testing: ['*testView', '*testUpdate', '*testAdmin'] testing: ['*testView', '*testUpdate', '*testAdmin']
} }

View File

@ -6,11 +6,13 @@ export interface AddBurialSiteForm {
burialSiteNameSegment5?: string; burialSiteNameSegment5?: string;
burialSiteStatusId: number | string; burialSiteStatusId: number | string;
burialSiteTypeId: number | string; burialSiteTypeId: number | string;
burialSiteImage: string; bodyCapacity?: number | string;
crematedCapacity?: number | string;
burialSiteImage?: string;
cemeteryId: number | string; cemeteryId: number | string;
cemeterySvgId: string; cemeterySvgId?: string;
burialSiteLatitude: string; burialSiteLatitude?: string;
burialSiteLongitude: string; burialSiteLongitude?: string;
burialSiteTypeFieldIds?: string; burialSiteTypeFieldIds?: string;
[fieldValue_burialSiteTypeFieldId: string]: unknown; [fieldValue_burialSiteTypeFieldId: string]: unknown;
} }
@ -21,4 +23,7 @@ export interface AddBurialSiteForm {
* @returns The new burial site's id. * @returns The new burial site's id.
* @throws If an active burial site with the same name already exists. * @throws If an active burial site with the same name already exists.
*/ */
export default function addBurialSite(burialSiteForm: AddBurialSiteForm, user: User): Promise<number>; export default function addBurialSite(burialSiteForm: AddBurialSiteForm, user: User): {
burialSiteId: number;
burialSiteName: string;
};

View File

@ -1,7 +1,8 @@
import sqlite from 'better-sqlite3';
import { buildBurialSiteName } from '../helpers/burialSites.helpers.js'; import { buildBurialSiteName } from '../helpers/burialSites.helpers.js';
import { sunriseDB } from '../helpers/database.helpers.js';
import addOrUpdateBurialSiteField from './addOrUpdateBurialSiteField.js'; import addOrUpdateBurialSiteField from './addOrUpdateBurialSiteField.js';
import getCemetery from './getCemetery.js'; import getCemetery from './getCemetery.js';
import { acquireConnection } from './pool.js';
/** /**
* Creates a new burial site. * Creates a new burial site.
* @param burialSiteForm - The new burial site's information * @param burialSiteForm - The new burial site's information
@ -9,12 +10,13 @@ import { acquireConnection } from './pool.js';
* @returns The new burial site's id. * @returns The new burial site's id.
* @throws If an active burial site with the same name already exists. * @throws If an active burial site with the same name already exists.
*/ */
export default async function addBurialSite(burialSiteForm, user) { // eslint-disable-next-line complexity
const database = await acquireConnection(); export default function addBurialSite(burialSiteForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const cemetery = burialSiteForm.cemeteryId === '' const cemetery = burialSiteForm.cemeteryId === ''
? undefined ? undefined
: await getCemetery(burialSiteForm.cemeteryId, database); : getCemetery(burialSiteForm.cemeteryId, database);
const burialSiteName = buildBurialSiteName(cemetery?.cemeteryKey, burialSiteForm); const burialSiteName = buildBurialSiteName(cemetery?.cemeteryKey, burialSiteForm);
// Ensure no active burial sites share the same name // Ensure no active burial sites share the same name
const existingBurialSite = database const existingBurialSite = database
@ -25,7 +27,7 @@ export default async function addBurialSite(burialSiteForm, user) {
.pluck() .pluck()
.get(burialSiteName); .get(burialSiteName);
if (existingBurialSite !== undefined) { if (existingBurialSite !== undefined) {
database.release(); database.close();
throw new Error('An active burial site with that name already exists.'); throw new Error('An active burial site with that name already exists.');
} }
const result = database const result = database
@ -37,17 +39,22 @@ export default async function addBurialSite(burialSiteForm, user) {
burialSiteNameSegment5, burialSiteNameSegment5,
burialSiteName, burialSiteName,
burialSiteTypeId, burialSiteStatusId, burialSiteTypeId, burialSiteStatusId,
bodyCapacity, crematedCapacity,
cemeteryId, cemeterySvgId, burialSiteImage, cemeteryId, cemeterySvgId, burialSiteImage,
burialSiteLatitude, burialSiteLongitude, burialSiteLatitude, burialSiteLongitude,
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, values (?, ?, ?, ?, ?,
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
?, ?, ?, ?)`) ?, ?, ?, ?)`)
.run(burialSiteForm.burialSiteNameSegment1 ?? '', burialSiteForm.burialSiteNameSegment2 ?? '', burialSiteForm.burialSiteNameSegment3 ?? '', burialSiteForm.burialSiteNameSegment4 ?? '', burialSiteForm.burialSiteNameSegment5 ?? '', burialSiteName, burialSiteForm.burialSiteTypeId, burialSiteForm.burialSiteStatusId === '' .run(burialSiteForm.burialSiteNameSegment1 ?? '', burialSiteForm.burialSiteNameSegment2 ?? '', burialSiteForm.burialSiteNameSegment3 ?? '', burialSiteForm.burialSiteNameSegment4 ?? '', burialSiteForm.burialSiteNameSegment5 ?? '', burialSiteName, burialSiteForm.burialSiteTypeId, burialSiteForm.burialSiteStatusId === ''
? undefined ? undefined
: burialSiteForm.burialSiteStatusId, burialSiteForm.cemeteryId === '' ? undefined : burialSiteForm.cemeteryId, burialSiteForm.cemeterySvgId, burialSiteForm.burialSiteImage, burialSiteForm.burialSiteLatitude === '' : burialSiteForm.burialSiteStatusId, burialSiteForm.bodyCapacity === ''
? undefined
: burialSiteForm.bodyCapacity, burialSiteForm.crematedCapacity === ''
? undefined
: burialSiteForm.crematedCapacity, burialSiteForm.cemeteryId === '' ? undefined : burialSiteForm.cemeteryId, burialSiteForm.cemeterySvgId, burialSiteForm.burialSiteImage ?? '', burialSiteForm.burialSiteLatitude === ''
? undefined ? undefined
: burialSiteForm.burialSiteLatitude, burialSiteForm.burialSiteLongitude === '' : burialSiteForm.burialSiteLatitude, burialSiteForm.burialSiteLongitude === ''
? undefined ? undefined
@ -57,13 +64,16 @@ export default async function addBurialSite(burialSiteForm, user) {
for (const burialSiteTypeFieldId of burialSiteTypeFieldIds) { for (const burialSiteTypeFieldId of burialSiteTypeFieldIds) {
const fieldValue = burialSiteForm[`burialSiteFieldValue_${burialSiteTypeFieldId}`]; const fieldValue = burialSiteForm[`burialSiteFieldValue_${burialSiteTypeFieldId}`];
if ((fieldValue ?? '') !== '') { if ((fieldValue ?? '') !== '') {
await addOrUpdateBurialSiteField({ addOrUpdateBurialSiteField({
burialSiteId, burialSiteId,
burialSiteTypeFieldId, burialSiteTypeFieldId,
fieldValue: fieldValue ?? '' fieldValue: fieldValue ?? ''
}, user, database); }, user, database);
} }
} }
database.release(); database.close();
return burialSiteId; return {
burialSiteId,
burialSiteName
};
} }

View File

@ -1,8 +1,10 @@
import sqlite from 'better-sqlite3'
import { buildBurialSiteName } from '../helpers/burialSites.helpers.js' import { buildBurialSiteName } from '../helpers/burialSites.helpers.js'
import { sunriseDB } from '../helpers/database.helpers.js'
import addOrUpdateBurialSiteField from './addOrUpdateBurialSiteField.js' import addOrUpdateBurialSiteField from './addOrUpdateBurialSiteField.js'
import getCemetery from './getCemetery.js' import getCemetery from './getCemetery.js'
import { acquireConnection } from './pool.js'
export interface AddBurialSiteForm { export interface AddBurialSiteForm {
burialSiteNameSegment1?: string burialSiteNameSegment1?: string
@ -14,12 +16,15 @@ export interface AddBurialSiteForm {
burialSiteStatusId: number | string burialSiteStatusId: number | string
burialSiteTypeId: number | string burialSiteTypeId: number | string
burialSiteImage: string bodyCapacity?: number | string
cemeteryId: number | string crematedCapacity?: number | string
cemeterySvgId: string
burialSiteLatitude: string burialSiteImage?: string
burialSiteLongitude: string cemeteryId: number | string
cemeterySvgId?: string
burialSiteLatitude?: string
burialSiteLongitude?: string
burialSiteTypeFieldIds?: string burialSiteTypeFieldIds?: string
@ -33,18 +38,19 @@ export interface AddBurialSiteForm {
* @returns The new burial site's id. * @returns The new burial site's id.
* @throws If an active burial site with the same name already exists. * @throws If an active burial site with the same name already exists.
*/ */
export default async function addBurialSite( // eslint-disable-next-line complexity
export default function addBurialSite(
burialSiteForm: AddBurialSiteForm, burialSiteForm: AddBurialSiteForm,
user: User user: User
): Promise<number> { ): { burialSiteId: number; burialSiteName: string } {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
const cemetery = const cemetery =
burialSiteForm.cemeteryId === '' burialSiteForm.cemeteryId === ''
? undefined ? undefined
: await getCemetery(burialSiteForm.cemeteryId, database) : getCemetery(burialSiteForm.cemeteryId, database)
const burialSiteName = buildBurialSiteName( const burialSiteName = buildBurialSiteName(
cemetery?.cemeteryKey, cemetery?.cemeteryKey,
@ -64,7 +70,7 @@ export default async function addBurialSite(
.get(burialSiteName) as number | undefined .get(burialSiteName) as number | undefined
if (existingBurialSite !== undefined) { if (existingBurialSite !== undefined) {
database.release() database.close()
throw new Error('An active burial site with that name already exists.') throw new Error('An active burial site with that name already exists.')
} }
@ -78,12 +84,13 @@ export default async function addBurialSite(
burialSiteNameSegment5, burialSiteNameSegment5,
burialSiteName, burialSiteName,
burialSiteTypeId, burialSiteStatusId, burialSiteTypeId, burialSiteStatusId,
bodyCapacity, crematedCapacity,
cemeteryId, cemeterySvgId, burialSiteImage, cemeteryId, cemeterySvgId, burialSiteImage,
burialSiteLatitude, burialSiteLongitude, burialSiteLatitude, burialSiteLongitude,
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, values (?, ?, ?, ?, ?,
?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,
?, ?, ?, ?)` ?, ?, ?, ?)`
) )
@ -98,9 +105,18 @@ export default async function addBurialSite(
burialSiteForm.burialSiteStatusId === '' burialSiteForm.burialSiteStatusId === ''
? undefined ? undefined
: burialSiteForm.burialSiteStatusId, : burialSiteForm.burialSiteStatusId,
burialSiteForm.bodyCapacity === ''
? undefined
: burialSiteForm.bodyCapacity,
burialSiteForm.crematedCapacity === ''
? undefined
: burialSiteForm.crematedCapacity,
burialSiteForm.cemeteryId === '' ? undefined : burialSiteForm.cemeteryId, burialSiteForm.cemeteryId === '' ? undefined : burialSiteForm.cemeteryId,
burialSiteForm.cemeterySvgId, burialSiteForm.cemeterySvgId,
burialSiteForm.burialSiteImage, burialSiteForm.burialSiteImage ?? '',
burialSiteForm.burialSiteLatitude === '' burialSiteForm.burialSiteLatitude === ''
? undefined ? undefined
: burialSiteForm.burialSiteLatitude, : burialSiteForm.burialSiteLatitude,
@ -125,7 +141,7 @@ export default async function addBurialSite(
] as string | undefined ] as string | undefined
if ((fieldValue ?? '') !== '') { if ((fieldValue ?? '') !== '') {
await addOrUpdateBurialSiteField( addOrUpdateBurialSiteField(
{ {
burialSiteId, burialSiteId,
burialSiteTypeFieldId, burialSiteTypeFieldId,
@ -137,7 +153,10 @@ export default async function addBurialSite(
} }
} }
database.release() database.close()
return burialSiteId return {
burialSiteId,
burialSiteName
}
} }

View File

@ -2,4 +2,4 @@ export interface AddBurialSiteCommentForm {
burialSiteId: string; burialSiteId: string;
comment: string; comment: string;
} }
export default function addBurialSiteComment(commentForm: AddBurialSiteCommentForm, user: User): Promise<number>; export default function addBurialSiteComment(commentForm: AddBurialSiteCommentForm, user: User): number;

View File

@ -1,7 +1,8 @@
import { dateToInteger, dateToTimeInteger } from '@cityssm/utils-datetime'; import { dateToInteger, dateToTimeInteger } from '@cityssm/utils-datetime';
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addBurialSiteComment(commentForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); export default function addBurialSiteComment(commentForm, user) {
const database = sqlite(sunriseDB);
const rightNow = new Date(); const rightNow = new Date();
const result = database const result = database
.prepare(`insert into BurialSiteComments ( .prepare(`insert into BurialSiteComments (
@ -11,6 +12,6 @@ export default async function addBurialSiteComment(commentForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?)`)
.run(commentForm.burialSiteId, dateToInteger(rightNow), dateToTimeInteger(rightNow), commentForm.comment, user.userName, rightNow.getTime(), user.userName, rightNow.getTime()); .run(commentForm.burialSiteId, dateToInteger(rightNow), dateToTimeInteger(rightNow), commentForm.comment, user.userName, rightNow.getTime(), user.userName, rightNow.getTime());
database.release(); database.close();
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,17 +1,18 @@
import { dateToInteger, dateToTimeInteger } from '@cityssm/utils-datetime' import { dateToInteger, dateToTimeInteger } from '@cityssm/utils-datetime'
import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddBurialSiteCommentForm { export interface AddBurialSiteCommentForm {
burialSiteId: string burialSiteId: string
comment: string comment: string
} }
export default async function addBurialSiteComment( export default function addBurialSiteComment(
commentForm: AddBurialSiteCommentForm, commentForm: AddBurialSiteCommentForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNow = new Date() const rightNow = new Date()
@ -35,7 +36,7 @@ export default async function addBurialSiteComment(
rightNow.getTime() rightNow.getTime()
) )
database.release() database.close()
return result.lastInsertRowid as number return result.lastInsertRowid as number
} }

View File

@ -0,0 +1,7 @@
export interface AddBurialSiteTypeForm {
burialSiteType: string;
bodyCapacityMax: number | string;
crematedCapacityMax: number | string;
orderNumber?: number | string;
}
export default function addBurialSiteType(addForm: AddBurialSiteTypeForm, user: User): number;

View File

@ -0,0 +1,20 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js';
export default function addBurialSiteType(addForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now();
const result = database
.prepare(`insert into BurialSiteTypes (
burialSiteType, bodyCapacityMax, crematedCapacityMax,
orderNumber,
recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.burialSiteType, addForm.bodyCapacityMax === '' ? undefined : addForm.bodyCapacityMax, addForm.crematedCapacityMax === ''
? undefined
: addForm.crematedCapacityMax, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.close();
clearCacheByTableName('BurialSiteTypes');
return result.lastInsertRowid;
}

View File

@ -0,0 +1,50 @@
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js'
export interface AddBurialSiteTypeForm {
burialSiteType: string
bodyCapacityMax: number | string
crematedCapacityMax: number | string
orderNumber?: number | string
}
export default function addBurialSiteType(
addForm: AddBurialSiteTypeForm,
user: User
): number {
const database = sqlite(sunriseDB)
const rightNowMillis = Date.now()
const result = database
.prepare(
`insert into BurialSiteTypes (
burialSiteType, bodyCapacityMax, crematedCapacityMax,
orderNumber,
recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?)`
)
.run(
addForm.burialSiteType,
addForm.bodyCapacityMax === '' ? undefined : addForm.bodyCapacityMax,
addForm.crematedCapacityMax === ''
? undefined
: addForm.crematedCapacityMax,
addForm.orderNumber ?? -1,
user.userName,
rightNowMillis,
user.userName,
rightNowMillis
)
database.close()
clearCacheByTableName('BurialSiteTypes')
return result.lastInsertRowid as number
}

View File

@ -1,12 +1,12 @@
export interface AddBurialSiteTypeFieldForm { export interface AddBurialSiteTypeFieldForm {
burialSiteTypeId: string | number; burialSiteTypeId: number | string;
burialSiteTypeField: string; burialSiteTypeField: string;
fieldType?: string; fieldType?: string;
fieldValues?: string; fieldValues?: string;
isRequired?: string; isRequired?: string;
maxLength?: number | string;
minLength?: number | string;
pattern?: string; pattern?: string;
minLength?: string | number;
maxLength?: string | number;
orderNumber?: number; orderNumber?: number;
} }
export default function addBurialSiteTypeField(addForm: AddBurialSiteTypeFieldForm, user: User): Promise<number>; export default function addBurialSiteTypeField(addForm: AddBurialSiteTypeFieldForm, user: User): number;

View File

@ -1,7 +1,8 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js'; export default function addBurialSiteTypeField(addForm, user) {
export default async function addBurialSiteTypeField(addForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into BurialSiteTypeFields ( .prepare(`insert into BurialSiteTypeFields (
@ -13,8 +14,10 @@ export default async function addBurialSiteTypeField(addForm, user) {
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.burialSiteTypeId, addForm.burialSiteTypeField, addForm.fieldType ?? 'text', addForm.fieldValues ?? '', addForm.isRequired === '' ? 0 : 1, addForm.pattern ?? '', addForm.minLength ?? 0, addForm.maxLength ?? 100, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.burialSiteTypeId, addForm.burialSiteTypeField, addForm.fieldType ?? 'text', addForm.fieldValues ?? '', addForm.isRequired === '' ? 0 : 1, addForm.pattern ?? '', addForm.minLength ?? 0,
database.release(); // eslint-disable-next-line @typescript-eslint/no-magic-numbers
addForm.maxLength ?? 100, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.close();
clearCacheByTableName('BurialSiteTypeFields'); clearCacheByTableName('BurialSiteTypeFields');
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,24 +1,29 @@
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js' import { clearCacheByTableName } from '../helpers/functions.cache.js'
import { acquireConnection } from './pool.js'
export interface AddBurialSiteTypeFieldForm { export interface AddBurialSiteTypeFieldForm {
burialSiteTypeId: string | number burialSiteTypeId: number | string
burialSiteTypeField: string burialSiteTypeField: string
fieldType?: string fieldType?: string
fieldValues?: string fieldValues?: string
isRequired?: string isRequired?: string
maxLength?: number | string
minLength?: number | string
pattern?: string pattern?: string
minLength?: string | number
maxLength?: string | number
orderNumber?: number orderNumber?: number
} }
export default async function addBurialSiteTypeField( export default function addBurialSiteTypeField(
addForm: AddBurialSiteTypeFieldForm, addForm: AddBurialSiteTypeFieldForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -42,6 +47,7 @@ export default async function addBurialSiteTypeField(
addForm.isRequired === '' ? 0 : 1, addForm.isRequired === '' ? 0 : 1,
addForm.pattern ?? '', addForm.pattern ?? '',
addForm.minLength ?? 0, addForm.minLength ?? 0,
// eslint-disable-next-line @typescript-eslint/no-magic-numbers
addForm.maxLength ?? 100, addForm.maxLength ?? 100,
addForm.orderNumber ?? -1, addForm.orderNumber ?? -1,
user.userName, user.userName,
@ -50,7 +56,7 @@ export default async function addBurialSiteTypeField(
rightNowMillis rightNowMillis
) )
database.release() database.close()
clearCacheByTableName('BurialSiteTypeFields') clearCacheByTableName('BurialSiteTypeFields')

View File

@ -1,4 +1,5 @@
export interface AddCemeteryForm { import { type UpdateCemeteryDirectionsOfArrivalForm } from './updateCemeteryDirectionsOfArrival.js';
export type AddCemeteryForm = UpdateCemeteryDirectionsOfArrivalForm & {
cemeteryDescription: string; cemeteryDescription: string;
cemeteryKey: string; cemeteryKey: string;
cemeteryName: string; cemeteryName: string;
@ -12,5 +13,5 @@ export interface AddCemeteryForm {
cemeteryPostalCode: string; cemeteryPostalCode: string;
cemeteryProvince: string; cemeteryProvince: string;
cemeteryPhoneNumber: string; cemeteryPhoneNumber: string;
} };
export default function addCemetery(addForm: AddCemeteryForm, user: User): Promise<number>; export default function addCemetery(addForm: AddCemeteryForm, user: User): number;

View File

@ -1,6 +1,8 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addCemetery(addForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); import updateCemeteryDirectionsOfArrival from './updateCemeteryDirectionsOfArrival.js';
export default function addCemetery(addForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into Cemeteries ( .prepare(`insert into Cemeteries (
@ -14,6 +16,8 @@ export default async function addCemetery(addForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.cemeteryName, addForm.cemeteryKey, addForm.cemeteryDescription, addForm.cemeterySvg, addForm.cemeteryLatitude === '' ? undefined : addForm.cemeteryLatitude, addForm.cemeteryLongitude === '' ? undefined : addForm.cemeteryLongitude, addForm.cemeteryAddress1, addForm.cemeteryAddress2, addForm.cemeteryCity, addForm.cemeteryProvince, addForm.cemeteryPostalCode, addForm.cemeteryPhoneNumber, addForm.parentCemeteryId === '' ? undefined : addForm.parentCemeteryId, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.cemeteryName, addForm.cemeteryKey, addForm.cemeteryDescription, addForm.cemeterySvg, addForm.cemeteryLatitude === '' ? undefined : addForm.cemeteryLatitude, addForm.cemeteryLongitude === '' ? undefined : addForm.cemeteryLongitude, addForm.cemeteryAddress1, addForm.cemeteryAddress2, addForm.cemeteryCity, addForm.cemeteryProvince, addForm.cemeteryPostalCode, addForm.cemeteryPhoneNumber, addForm.parentCemeteryId === '' ? undefined : addForm.parentCemeteryId, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); const cemeteryId = result.lastInsertRowid;
return result.lastInsertRowid; updateCemeteryDirectionsOfArrival(cemeteryId, addForm, database);
database.close();
return cemeteryId;
} }

View File

@ -1,6 +1,12 @@
import { acquireConnection } from './pool.js' import sqlite from 'better-sqlite3'
export interface AddCemeteryForm { import { sunriseDB } from '../helpers/database.helpers.js'
import updateCemeteryDirectionsOfArrival, {
type UpdateCemeteryDirectionsOfArrivalForm
} from './updateCemeteryDirectionsOfArrival.js'
export type AddCemeteryForm = UpdateCemeteryDirectionsOfArrivalForm & {
cemeteryDescription: string cemeteryDescription: string
cemeteryKey: string cemeteryKey: string
cemeteryName: string cemeteryName: string
@ -19,11 +25,11 @@ export interface AddCemeteryForm {
cemeteryPhoneNumber: string cemeteryPhoneNumber: string
} }
export default async function addCemetery( export default function addCemetery(
addForm: AddCemeteryForm, addForm: AddCemeteryForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -60,7 +66,11 @@ export default async function addCemetery(
rightNowMillis rightNowMillis
) )
database.release() const cemeteryId = result.lastInsertRowid as number
return result.lastInsertRowid as number updateCemeteryDirectionsOfArrival(cemeteryId, addForm, database)
database.close()
return cemeteryId
} }

View File

@ -1,6 +1,6 @@
export interface AddForm { export interface AddForm {
committalType: string; committalType: string;
committalTypeKey?: string; committalTypeKey?: string;
orderNumber?: number; orderNumber?: number | string;
} }
export default function addCommittalType(addForm: AddForm, user: User): Promise<number>; export default function addCommittalType(addForm: AddForm, user: User): number;

View File

@ -1,7 +1,8 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js'; export default function addCommittalType(addForm, user) {
export default async function addCommittalType(addForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into CommittalTypes ( .prepare(`insert into CommittalTypes (
@ -10,7 +11,7 @@ export default async function addCommittalType(addForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.committalType, addForm.committalTypeKey ?? '', addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.committalType, addForm.committalTypeKey ?? '', addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
clearCacheByTableName('CommittalTypes'); clearCacheByTableName('CommittalTypes');
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,18 +1,16 @@
import { clearCacheByTableName } from '../helpers/functions.cache.js' import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js'
export interface AddForm { export interface AddForm {
committalType: string committalType: string
committalTypeKey?: string committalTypeKey?: string
orderNumber?: number orderNumber?: number | string
} }
export default async function addCommittalType( export default function addCommittalType(addForm: AddForm, user: User): number {
addForm: AddForm, const database = sqlite(sunriseDB)
user: User
): Promise<number> {
const database = await acquireConnection()
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -34,7 +32,7 @@ export default async function addCommittalType(
rightNowMillis rightNowMillis
) )
database.release() database.close()
clearCacheByTableName('CommittalTypes') clearCacheByTableName('CommittalTypes')

View File

@ -1,5 +1,5 @@
import type { PoolConnection } from 'better-sqlite-pool';
import { type DateString, type TimeString } from '@cityssm/utils-datetime'; import { type DateString, type TimeString } from '@cityssm/utils-datetime';
import sqlite from 'better-sqlite3';
export interface AddContractForm { export interface AddContractForm {
burialSiteId: number | string; burialSiteId: number | string;
contractEndDateString: '' | DateString; contractEndDateString: '' | DateString;
@ -8,6 +8,7 @@ export interface AddContractForm {
[fieldValue_contractTypeFieldId: `fieldValue_${string}`]: unknown; [fieldValue_contractTypeFieldId: `fieldValue_${string}`]: unknown;
contractTypeFieldIds?: string; contractTypeFieldIds?: string;
committalTypeId?: number | string; committalTypeId?: number | string;
directionOfArrival?: string;
funeralDateString?: '' | DateString; funeralDateString?: '' | DateString;
funeralDirectorName?: string; funeralDirectorName?: string;
funeralHomeId?: number | string; funeralHomeId?: number | string;
@ -35,4 +36,4 @@ export interface AddContractForm {
deceasedProvince?: string; deceasedProvince?: string;
intermentContainerTypeId?: number | string; intermentContainerTypeId?: number | string;
} }
export default function addContract(addForm: AddContractForm, user: User, connectedDatabase?: PoolConnection): Promise<number>; export default function addContract(addForm: AddContractForm, user: User, connectedDatabase?: sqlite.Database): number;

View File

@ -1,9 +1,10 @@
import { dateStringToInteger, timeStringToInteger } from '@cityssm/utils-datetime'; import { dateStringToInteger, timeStringToInteger } from '@cityssm/utils-datetime';
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import addOrUpdateContractField from './addOrUpdateContractField.js'; import addOrUpdateContractField from './addOrUpdateContractField.js';
import { acquireConnection } from './pool.js';
// eslint-disable-next-line complexity // eslint-disable-next-line complexity
export default async function addContract(addForm, user, connectedDatabase) { export default function addContract(addForm, user, connectedDatabase) {
const database = connectedDatabase ?? (await acquireConnection()); const database = connectedDatabase ?? sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const contractStartDate = dateStringToInteger(addForm.contractStartDateString); const contractStartDate = dateStringToInteger(addForm.contractStartDateString);
const result = database const result = database
@ -15,17 +16,17 @@ export default async function addContract(addForm, user, connectedDatabase) {
purchaserPhoneNumber, purchaserEmail, purchaserRelationship, purchaserPhoneNumber, purchaserEmail, purchaserRelationship,
funeralHomeId, funeralDirectorName, funeralHomeId, funeralDirectorName,
funeralDate, funeralTime, funeralDate, funeralTime,
committalTypeId, directionOfArrival, committalTypeId,
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.contractTypeId, addForm.burialSiteId === '' ? undefined : addForm.burialSiteId, contractStartDate, addForm.contractEndDateString === '' .run(addForm.contractTypeId, addForm.burialSiteId === '' ? undefined : addForm.burialSiteId, contractStartDate, addForm.contractEndDateString === ''
? undefined ? undefined
: dateStringToInteger(addForm.contractEndDateString), addForm.purchaserName ?? '', addForm.purchaserAddress1 ?? '', addForm.purchaserAddress2 ?? '', addForm.purchaserCity ?? '', addForm.purchaserProvince ?? '', addForm.purchaserPostalCode ?? '', addForm.purchaserPhoneNumber ?? '', addForm.purchaserEmail ?? '', addForm.purchaserRelationship ?? '', addForm.funeralHomeId === '' ? undefined : addForm.funeralHomeId, addForm.funeralDirectorName ?? '', addForm.funeralDateString === '' : dateStringToInteger(addForm.contractEndDateString), addForm.purchaserName ?? '', addForm.purchaserAddress1 ?? '', addForm.purchaserAddress2 ?? '', addForm.purchaserCity ?? '', addForm.purchaserProvince ?? '', addForm.purchaserPostalCode ?? '', addForm.purchaserPhoneNumber ?? '', addForm.purchaserEmail ?? '', addForm.purchaserRelationship ?? '', addForm.funeralHomeId === '' ? undefined : addForm.funeralHomeId, addForm.funeralDirectorName ?? '', addForm.funeralDateString === ''
? undefined ? undefined
: dateStringToInteger(addForm.funeralDateString), addForm.funeralTimeString === '' : dateStringToInteger(addForm.funeralDateString), addForm.funeralTimeString === ''
? undefined ? undefined
: timeStringToInteger(addForm.funeralTimeString), addForm.committalTypeId === '' ? undefined : addForm.committalTypeId, user.userName, rightNowMillis, user.userName, rightNowMillis); : timeStringToInteger(addForm.funeralTimeString), addForm.directionOfArrival ?? '', addForm.committalTypeId === '' ? undefined : addForm.committalTypeId, user.userName, rightNowMillis, user.userName, rightNowMillis);
const contractId = result.lastInsertRowid; const contractId = result.lastInsertRowid;
/* /*
* Add contract fields * Add contract fields
@ -34,7 +35,7 @@ export default async function addContract(addForm, user, connectedDatabase) {
for (const contractTypeFieldId of contractTypeFieldIds) { for (const contractTypeFieldId of contractTypeFieldIds) {
const fieldValue = addForm[`fieldValue_${contractTypeFieldId}`]; const fieldValue = addForm[`fieldValue_${contractTypeFieldId}`];
if ((fieldValue ?? '') !== '') { if ((fieldValue ?? '') !== '') {
await addOrUpdateContractField({ addOrUpdateContractField({
contractId, contractId,
contractTypeFieldId, contractTypeFieldId,
fieldValue: fieldValue ?? '' fieldValue: fieldValue ?? ''
@ -66,7 +67,7 @@ export default async function addContract(addForm, user, connectedDatabase) {
: addForm.intermentContainerTypeId, user.userName, rightNowMillis, user.userName, rightNowMillis); : addForm.intermentContainerTypeId, user.userName, rightNowMillis, user.userName, rightNowMillis);
} }
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release(); database.close();
} }
return contractId; return contractId;
} }

View File

@ -1,14 +1,14 @@
import type { PoolConnection } from 'better-sqlite-pool'
import { import {
type DateString, type DateString,
type TimeString, type TimeString,
dateStringToInteger, dateStringToInteger,
timeStringToInteger timeStringToInteger
} from '@cityssm/utils-datetime' } from '@cityssm/utils-datetime'
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import addOrUpdateContractField from './addOrUpdateContractField.js' import addOrUpdateContractField from './addOrUpdateContractField.js'
import { acquireConnection } from './pool.js'
export interface AddContractForm { export interface AddContractForm {
burialSiteId: number | string burialSiteId: number | string
@ -20,6 +20,7 @@ export interface AddContractForm {
contractTypeFieldIds?: string contractTypeFieldIds?: string
committalTypeId?: number | string committalTypeId?: number | string
directionOfArrival?: string
funeralDateString?: '' | DateString funeralDateString?: '' | DateString
funeralDirectorName?: string funeralDirectorName?: string
funeralHomeId?: number | string funeralHomeId?: number | string
@ -51,12 +52,12 @@ export interface AddContractForm {
} }
// eslint-disable-next-line complexity // eslint-disable-next-line complexity
export default async function addContract( export default function addContract(
addForm: AddContractForm, addForm: AddContractForm,
user: User, user: User,
connectedDatabase?: PoolConnection connectedDatabase?: sqlite.Database
): Promise<number> { ): number {
const database = connectedDatabase ?? (await acquireConnection()) const database = connectedDatabase ?? sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -74,10 +75,10 @@ export default async function addContract(
purchaserPhoneNumber, purchaserEmail, purchaserRelationship, purchaserPhoneNumber, purchaserEmail, purchaserRelationship,
funeralHomeId, funeralDirectorName, funeralHomeId, funeralDirectorName,
funeralDate, funeralTime, funeralDate, funeralTime,
committalTypeId, directionOfArrival, committalTypeId,
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)` values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
) )
.run( .run(
addForm.contractTypeId, addForm.contractTypeId,
@ -103,6 +104,7 @@ export default async function addContract(
addForm.funeralTimeString === '' addForm.funeralTimeString === ''
? undefined ? undefined
: timeStringToInteger(addForm.funeralTimeString as TimeString), : timeStringToInteger(addForm.funeralTimeString as TimeString),
addForm.directionOfArrival ?? '',
addForm.committalTypeId === '' ? undefined : addForm.committalTypeId, addForm.committalTypeId === '' ? undefined : addForm.committalTypeId,
user.userName, user.userName,
rightNowMillis, rightNowMillis,
@ -124,7 +126,7 @@ export default async function addContract(
| undefined | undefined
if ((fieldValue ?? '') !== '') { if ((fieldValue ?? '') !== '') {
await addOrUpdateContractField( addOrUpdateContractField(
{ {
contractId, contractId,
contractTypeFieldId, contractTypeFieldId,
@ -186,7 +188,7 @@ export default async function addContract(
} }
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release() database.close()
} }
return contractId return contractId

View File

@ -1,8 +1,8 @@
import { type DateString, type TimeString } from '@cityssm/utils-datetime'; import { type DateString, type TimeString } from '@cityssm/utils-datetime';
export interface AddContractCommentForm { export interface AddContractCommentForm {
contractId: number | string;
comment: string; comment: string;
commentDateString?: DateString; commentDateString?: DateString;
commentTimeString?: TimeString; commentTimeString?: TimeString;
contractId: number | string;
} }
export default function addContractComment(commentForm: AddContractCommentForm, user: User): Promise<number>; export default function addContractComment(commentForm: AddContractCommentForm, user: User): number;

View File

@ -1,6 +1,7 @@
import { dateStringToInteger, dateToInteger, dateToTimeInteger, timeStringToInteger } from '@cityssm/utils-datetime'; import { dateStringToInteger, dateToInteger, dateToTimeInteger, timeStringToInteger } from '@cityssm/utils-datetime';
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addContractComment(commentForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
export default function addContractComment(commentForm, user) {
const rightNow = new Date(); const rightNow = new Date();
let commentDate = 0; let commentDate = 0;
let commentTime = 0; let commentTime = 0;
@ -12,7 +13,7 @@ export default async function addContractComment(commentForm, user) {
commentDate = dateStringToInteger(commentForm.commentDateString); commentDate = dateStringToInteger(commentForm.commentDateString);
commentTime = timeStringToInteger(commentForm.commentTimeString); commentTime = timeStringToInteger(commentForm.commentTimeString);
} }
const database = await acquireConnection(); const database = sqlite(sunriseDB);
const result = database const result = database
.prepare(`insert into ContractComments ( .prepare(`insert into ContractComments (
contractId, contractId,
@ -22,6 +23,6 @@ export default async function addContractComment(commentForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?)`)
.run(commentForm.contractId, commentDate, commentTime ?? 0, commentForm.comment, user.userName, rightNow.getTime(), user.userName, rightNow.getTime()); .run(commentForm.contractId, commentDate, commentTime ?? 0, commentForm.comment, user.userName, rightNow.getTime(), user.userName, rightNow.getTime());
database.release(); database.close();
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -6,20 +6,22 @@ import {
dateToTimeInteger, dateToTimeInteger,
timeStringToInteger timeStringToInteger
} from '@cityssm/utils-datetime' } from '@cityssm/utils-datetime'
import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddContractCommentForm { export interface AddContractCommentForm {
contractId: number | string
comment: string comment: string
commentDateString?: DateString commentDateString?: DateString
commentTimeString?: TimeString commentTimeString?: TimeString
contractId: number | string
} }
export default async function addContractComment( export default function addContractComment(
commentForm: AddContractCommentForm, commentForm: AddContractCommentForm,
user: User user: User
): Promise<number> { ): number {
const rightNow = new Date() const rightNow = new Date()
let commentDate = 0 let commentDate = 0
@ -37,7 +39,7 @@ export default async function addContractComment(
) )
} }
const database = await acquireConnection() const database = sqlite(sunriseDB)
const result = database const result = database
.prepare( .prepare(
@ -60,7 +62,7 @@ export default async function addContractComment(
rightNow.getTime() rightNow.getTime()
) )
database.release() database.close()
return result.lastInsertRowid as number return result.lastInsertRowid as number
} }

View File

@ -1,4 +1,4 @@
import type { PoolConnection } from 'better-sqlite-pool'; import sqlite from 'better-sqlite3';
export interface AddContractFeeForm { export interface AddContractFeeForm {
contractId: number | string; contractId: number | string;
feeId: number | string; feeId: number | string;
@ -6,4 +6,4 @@ export interface AddContractFeeForm {
quantity: number | string; quantity: number | string;
taxAmount?: number | string; taxAmount?: number | string;
} }
export default function addContractFee(addFeeForm: AddContractFeeForm, user: User, connectedDatabase?: PoolConnection): Promise<boolean>; export default function addContractFee(addFeeForm: AddContractFeeForm, user: User, connectedDatabase?: sqlite.Database): Promise<boolean>;

View File

@ -1,16 +1,17 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { calculateFeeAmount, calculateTaxAmount } from '../helpers/functions.fee.js'; import { calculateFeeAmount, calculateTaxAmount } from '../helpers/functions.fee.js';
import getContract from './getContract.js'; import getContract from './getContract.js';
import getFee from './getFee.js'; import getFee from './getFee.js';
import { acquireConnection } from './pool.js';
export default async function addContractFee(addFeeForm, user, connectedDatabase) { export default async function addContractFee(addFeeForm, user, connectedDatabase) {
const database = connectedDatabase ?? (await acquireConnection()); const database = connectedDatabase ?? sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
// Calculate fee and tax (if not set) // Calculate fee and tax (if not set)
let feeAmount; let feeAmount;
let taxAmount; let taxAmount;
if ((addFeeForm.feeAmount ?? '') === '') { if ((addFeeForm.feeAmount ?? '') === '') {
const contract = (await getContract(addFeeForm.contractId)); const contract = (await getContract(addFeeForm.contractId));
const fee = (await getFee(addFeeForm.feeId)); const fee = getFee(addFeeForm.feeId);
feeAmount = calculateFeeAmount(fee, contract); feeAmount = calculateFeeAmount(fee, contract);
taxAmount = calculateTaxAmount(fee, feeAmount); taxAmount = calculateTaxAmount(fee, feeAmount);
} }
@ -83,7 +84,7 @@ export default async function addContractFee(addFeeForm, user, connectedDatabase
} }
finally { finally {
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release(); database.close();
} }
} }
} }

View File

@ -1,14 +1,14 @@
import type { PoolConnection } from 'better-sqlite-pool' import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import { import {
calculateFeeAmount, calculateFeeAmount,
calculateTaxAmount calculateTaxAmount
} from '../helpers/functions.fee.js' } from '../helpers/functions.fee.js'
import type { Contract, Fee } from '../types/recordTypes.js' import type { Contract, Fee } from '../types/record.types.js'
import getContract from './getContract.js' import getContract from './getContract.js'
import getFee from './getFee.js' import getFee from './getFee.js'
import { acquireConnection } from './pool.js'
export interface AddContractFeeForm { export interface AddContractFeeForm {
contractId: number | string contractId: number | string
@ -22,9 +22,9 @@ export interface AddContractFeeForm {
export default async function addContractFee( export default async function addContractFee(
addFeeForm: AddContractFeeForm, addFeeForm: AddContractFeeForm,
user: User, user: User,
connectedDatabase?: PoolConnection connectedDatabase?: sqlite.Database
): Promise<boolean> { ): Promise<boolean> {
const database = connectedDatabase ?? (await acquireConnection()) const database = connectedDatabase ?? sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -33,11 +33,9 @@ export default async function addContractFee(
let taxAmount: number let taxAmount: number
if ((addFeeForm.feeAmount ?? '') === '') { if ((addFeeForm.feeAmount ?? '') === '') {
const contract = (await getContract( const contract = (await getContract(addFeeForm.contractId)) as Contract
addFeeForm.contractId
)) as Contract
const fee = (await getFee(addFeeForm.feeId)) as Fee const fee = getFee(addFeeForm.feeId) as Fee
feeAmount = calculateFeeAmount(fee, contract) feeAmount = calculateFeeAmount(fee, contract)
taxAmount = calculateTaxAmount(fee, feeAmount) taxAmount = calculateTaxAmount(fee, feeAmount)
@ -65,6 +63,7 @@ export default async function addContractFee(
| { | {
feeAmount: number | null feeAmount: number | null
taxAmount: number | null taxAmount: number | null
recordDelete_timeMillis: number | null recordDelete_timeMillis: number | null
} }
| undefined | undefined
@ -156,7 +155,7 @@ export default async function addContractFee(
return result.changes > 0 return result.changes > 0
} finally { } finally {
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release() database.close()
} }
} }
} }

View File

@ -1,9 +1,10 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import addContractFee from './addContractFee.js'; import addContractFee from './addContractFee.js';
import { getFeeCategory } from './getFeeCategories.js'; import { getFeeCategory } from './getFeeCategories.js';
import { acquireConnection } from './pool.js';
export default async function addContractFeeCategory(addFeeCategoryForm, user) { export default async function addContractFeeCategory(addFeeCategoryForm, user) {
const database = await acquireConnection(); const database = sqlite(sunriseDB);
const feeCategory = await getFeeCategory(addFeeCategoryForm.feeCategoryId, database); const feeCategory = getFeeCategory(addFeeCategoryForm.feeCategoryId, database);
let addedFeeCount = 0; let addedFeeCount = 0;
for (const fee of feeCategory?.fees ?? []) { for (const fee of feeCategory?.fees ?? []) {
const success = await addContractFee({ const success = await addContractFee({
@ -15,6 +16,6 @@ export default async function addContractFeeCategory(addFeeCategoryForm, user) {
addedFeeCount += 1; addedFeeCount += 1;
} }
} }
database.release(); database.close();
return addedFeeCount; return addedFeeCount;
} }

View File

@ -1,6 +1,9 @@
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import addContractFee from './addContractFee.js' import addContractFee from './addContractFee.js'
import { getFeeCategory } from './getFeeCategories.js' import { getFeeCategory } from './getFeeCategories.js'
import { acquireConnection } from './pool.js'
export interface AddContractCategoryForm { export interface AddContractCategoryForm {
contractId: number | string contractId: number | string
@ -11,12 +14,9 @@ export default async function addContractFeeCategory(
addFeeCategoryForm: AddContractCategoryForm, addFeeCategoryForm: AddContractCategoryForm,
user: User user: User
): Promise<number> { ): Promise<number> {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const feeCategory = await getFeeCategory( const feeCategory = getFeeCategory(addFeeCategoryForm.feeCategoryId, database)
addFeeCategoryForm.feeCategoryId,
database
)
let addedFeeCount = 0 let addedFeeCount = 0
@ -36,7 +36,7 @@ export default async function addContractFeeCategory(
} }
} }
database.release() database.close()
return addedFeeCount return addedFeeCount
} }

View File

@ -1,19 +1,19 @@
import { type DateString } from '@cityssm/utils-datetime'; import { type DateString } from '@cityssm/utils-datetime';
import type { PoolConnection } from 'better-sqlite-pool'; import sqlite from 'better-sqlite3';
export interface AddForm { export interface AddForm {
contractId: string | number; contractId: number | string;
deceasedName: string; deceasedName: string;
deceasedAddress1: string; deceasedAddress1: string;
deceasedAddress2: string; deceasedAddress2: string;
deceasedCity: string; deceasedCity: string;
deceasedProvince: string;
deceasedPostalCode: string; deceasedPostalCode: string;
birthDateString: DateString | ''; deceasedProvince: string;
birthDateString: '' | DateString;
birthPlace: string; birthPlace: string;
deathDateString: DateString | ''; deathDateString: '' | DateString;
deathPlace: string; deathPlace: string;
deathAge: string | number; deathAge: number | string;
deathAgePeriod: string; deathAgePeriod: string;
intermentContainerTypeId: string | number; intermentContainerTypeId: number | string;
} }
export default function addContractInterment(contractForm: AddForm, user: User, connectedDatabase?: PoolConnection): Promise<number>; export default function addContractInterment(contractForm: AddForm, user: User, connectedDatabase?: sqlite.Database): number;

View File

@ -1,11 +1,12 @@
import { dateStringToInteger } from '@cityssm/utils-datetime'; import { dateStringToInteger } from '@cityssm/utils-datetime';
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addContractInterment(contractForm, user, connectedDatabase) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = connectedDatabase ?? (await acquireConnection()); export default function addContractInterment(contractForm, user, connectedDatabase) {
const database = connectedDatabase ?? sqlite(sunriseDB);
const maxIntermentNumber = (database const maxIntermentNumber = (database
.prepare(`select max(intermentNumber) as maxIntermentNumber .prepare(`select max(intermentNumber) as maxIntermentNumber
from ContractInterments from ContractInterments
where contractId = ?`) where contractId = ?`)
.pluck() .pluck()
.get(contractForm.contractId) ?? 0); .get(contractForm.contractId) ?? 0);
const newIntermentNumber = maxIntermentNumber + 1; const newIntermentNumber = maxIntermentNumber + 1;
@ -26,7 +27,7 @@ export default async function addContractInterment(contractForm, user, connected
? undefined ? undefined
: contractForm.intermentContainerTypeId, user.userName, rightNowMillis, user.userName, rightNowMillis); : contractForm.intermentContainerTypeId, user.userName, rightNowMillis, user.userName, rightNowMillis);
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release(); database.close();
} }
return newIntermentNumber; return newIntermentNumber;
} }

View File

@ -1,37 +1,42 @@
import { type DateString, dateStringToInteger } from '@cityssm/utils-datetime' import { type DateString, dateStringToInteger } from '@cityssm/utils-datetime'
import type { PoolConnection } from 'better-sqlite-pool' import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddForm { export interface AddForm {
contractId: string | number contractId: number | string
deceasedName: string deceasedName: string
deceasedAddress1: string deceasedAddress1: string
deceasedAddress2: string deceasedAddress2: string
deceasedCity: string deceasedCity: string
deceasedProvince: string
deceasedPostalCode: string deceasedPostalCode: string
birthDateString: DateString | '' deceasedProvince: string
birthDateString: '' | DateString
birthPlace: string birthPlace: string
deathDateString: DateString | '' deathDateString: '' | DateString
deathPlace: string deathPlace: string
deathAge: string | number
deathAge: number | string
deathAgePeriod: string deathAgePeriod: string
intermentContainerTypeId: string | number
intermentContainerTypeId: number | string
} }
export default async function addContractInterment( export default function addContractInterment(
contractForm: AddForm, contractForm: AddForm,
user: User, user: User,
connectedDatabase?: PoolConnection connectedDatabase?: sqlite.Database
): Promise<number> { ): number {
const database = connectedDatabase ?? (await acquireConnection()) const database = connectedDatabase ?? sqlite(sunriseDB)
const maxIntermentNumber = (database const maxIntermentNumber = (database
.prepare( .prepare(
`select max(intermentNumber) as maxIntermentNumber `select max(intermentNumber) as maxIntermentNumber
from ContractInterments from ContractInterments
where contractId = ?` where contractId = ?`
) )
.pluck() .pluck()
.get(contractForm.contractId) ?? 0) as number .get(contractForm.contractId) ?? 0) as number
@ -76,7 +81,7 @@ export default async function addContractInterment(
) )
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release() database.close()
} }
return newIntermentNumber return newIntermentNumber

View File

@ -1,9 +1,10 @@
import { type DateString, type TimeString } from '@cityssm/utils-datetime';
export interface AddTransactionForm { export interface AddTransactionForm {
contractId: string | number; contractId: number | string;
transactionDateString?: string; transactionDateString?: '' | DateString;
transactionTimeString?: string; transactionTimeString?: '' | TimeString;
transactionAmount: string | number;
externalReceiptNumber: string; externalReceiptNumber: string;
transactionAmount: number | string;
transactionNote: string; transactionNote: string;
} }
export default function addContractTransaction(contractTransactionForm: AddTransactionForm, user: User): Promise<number>; export default function addContractTransaction(contractTransactionForm: AddTransactionForm, user: User): number;

View File

@ -1,7 +1,8 @@
import { dateStringToInteger, dateToInteger, dateToTimeInteger, timeStringToInteger } from '@cityssm/utils-datetime'; import { dateStringToInteger, dateToInteger, dateToTimeInteger, timeStringToInteger } from '@cityssm/utils-datetime';
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addContractTransaction(contractTransactionForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); export default function addContractTransaction(contractTransactionForm, user) {
const database = sqlite(sunriseDB);
let transactionIndex = 0; let transactionIndex = 0;
const maxIndexResult = database const maxIndexResult = database
.prepare(`select transactionIndex .prepare(`select transactionIndex
@ -14,12 +15,12 @@ export default async function addContractTransaction(contractTransactionForm, us
transactionIndex = maxIndexResult.transactionIndex + 1; transactionIndex = maxIndexResult.transactionIndex + 1;
} }
const rightNow = new Date(); const rightNow = new Date();
const transactionDate = contractTransactionForm.transactionDateString const transactionDate = (contractTransactionForm.transactionDateString ?? '') === ''
? dateStringToInteger(contractTransactionForm.transactionDateString) ? dateToInteger(rightNow)
: dateToInteger(rightNow); : dateStringToInteger(contractTransactionForm.transactionDateString);
const transactionTime = contractTransactionForm.transactionTimeString const transactionTime = (contractTransactionForm.transactionTimeString ?? '') === ''
? timeStringToInteger(contractTransactionForm.transactionTimeString) ? dateToTimeInteger(rightNow)
: dateToTimeInteger(rightNow); : timeStringToInteger(contractTransactionForm.transactionTimeString);
database database
.prepare(`insert into ContractTransactions ( .prepare(`insert into ContractTransactions (
contractId, transactionIndex, contractId, transactionIndex,
@ -29,6 +30,6 @@ export default async function addContractTransaction(contractTransactionForm, us
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(contractTransactionForm.contractId, transactionIndex, transactionDate, transactionTime, contractTransactionForm.transactionAmount, contractTransactionForm.externalReceiptNumber, contractTransactionForm.transactionNote, user.userName, rightNow.getTime(), user.userName, rightNow.getTime()); .run(contractTransactionForm.contractId, transactionIndex, transactionDate, transactionTime, contractTransactionForm.transactionAmount, contractTransactionForm.externalReceiptNumber, contractTransactionForm.transactionNote, user.userName, rightNow.getTime(), user.userName, rightNow.getTime());
database.release(); database.close();
return transactionIndex; return transactionIndex;
} }

View File

@ -1,26 +1,31 @@
import { import {
type DateString,
type TimeString,
dateStringToInteger, dateStringToInteger,
dateToInteger, dateToInteger,
dateToTimeInteger, dateToTimeInteger,
timeStringToInteger timeStringToInteger
} from '@cityssm/utils-datetime' } from '@cityssm/utils-datetime'
import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddTransactionForm { export interface AddTransactionForm {
contractId: string | number contractId: number | string
transactionDateString?: string
transactionTimeString?: string transactionDateString?: '' | DateString
transactionAmount: string | number transactionTimeString?: '' | TimeString
externalReceiptNumber: string externalReceiptNumber: string
transactionAmount: number | string
transactionNote: string transactionNote: string
} }
export default async function addContractTransaction( export default function addContractTransaction(
contractTransactionForm: AddTransactionForm, contractTransactionForm: AddTransactionForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
let transactionIndex = 0 let transactionIndex = 0
@ -42,13 +47,19 @@ export default async function addContractTransaction(
const rightNow = new Date() const rightNow = new Date()
const transactionDate = contractTransactionForm.transactionDateString const transactionDate =
? dateStringToInteger(contractTransactionForm.transactionDateString) (contractTransactionForm.transactionDateString ?? '') === ''
: dateToInteger(rightNow) ? dateToInteger(rightNow)
: dateStringToInteger(
contractTransactionForm.transactionDateString as DateString
)
const transactionTime = contractTransactionForm.transactionTimeString const transactionTime =
? timeStringToInteger(contractTransactionForm.transactionTimeString) (contractTransactionForm.transactionTimeString ?? '') === ''
: dateToTimeInteger(rightNow) ? dateToTimeInteger(rightNow)
: timeStringToInteger(
contractTransactionForm.transactionTimeString as TimeString
)
database database
.prepare( .prepare(
@ -74,7 +85,7 @@ export default async function addContractTransaction(
rightNow.getTime() rightNow.getTime()
) )
database.release() database.close()
return transactionIndex return transactionIndex
} }

View File

@ -3,4 +3,4 @@ export interface AddForm {
isPreneed?: string; isPreneed?: string;
orderNumber?: number; orderNumber?: number;
} }
export default function addContractType(addForm: AddForm, user: User): Promise<number>; export default function addContractType(addForm: AddForm, user: User): number;

View File

@ -1,7 +1,8 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js'; export default function addContractType(addForm, user) {
export default async function addContractType(addForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into ContractTypes ( .prepare(`insert into ContractTypes (
@ -10,7 +11,7 @@ export default async function addContractType(addForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.contractType, addForm.isPreneed === undefined ? 0 : 1, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.contractType, addForm.isPreneed === undefined ? 0 : 1, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
clearCacheByTableName('ContractTypes'); clearCacheByTableName('ContractTypes');
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,6 +1,7 @@
import { clearCacheByTableName } from '../helpers/functions.cache.js' import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js'
export interface AddForm { export interface AddForm {
contractType: string contractType: string
@ -8,11 +9,8 @@ export interface AddForm {
orderNumber?: number orderNumber?: number
} }
export default async function addContractType( export default function addContractType(addForm: AddForm, user: User): number {
addForm: AddForm, const database = sqlite(sunriseDB)
user: User
): Promise<number> {
const database = await acquireConnection()
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -34,7 +32,7 @@ export default async function addContractType(
rightNowMillis rightNowMillis
) )
database.release() database.close()
clearCacheByTableName('ContractTypes') clearCacheByTableName('ContractTypes')

View File

@ -1,12 +1,12 @@
export interface AddContractTypeFieldForm { export interface AddContractTypeFieldForm {
contractTypeId?: string | number; contractTypeId?: number | string;
contractTypeField: string; contractTypeField: string;
fieldValues?: string;
fieldType?: string; fieldType?: string;
fieldValues?: string;
isRequired?: string; isRequired?: string;
maxLength?: number | string;
minLength?: number | string;
pattern?: string; pattern?: string;
minLength?: string | number;
maxLength?: string | number;
orderNumber?: number; orderNumber?: number;
} }
export default function addContractTypeField(addForm: AddContractTypeFieldForm, user: User): Promise<number>; export default function addContractTypeField(addForm: AddContractTypeFieldForm, user: User): number;

View File

@ -1,7 +1,8 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js'; export default function addContractTypeField(addForm, user) {
export default async function addContractTypeField(addForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into ContractTypeFields ( .prepare(`insert into ContractTypeFields (
@ -12,8 +13,10 @@ export default async function addContractTypeField(addForm, user) {
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.contractTypeId ?? undefined, addForm.contractTypeField, addForm.fieldType ?? 'text', addForm.fieldValues ?? '', addForm.isRequired === '' ? 0 : 1, addForm.pattern ?? '', addForm.minLength ?? 0, addForm.maxLength ?? 100, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.contractTypeId ?? undefined, addForm.contractTypeField, addForm.fieldType ?? 'text', addForm.fieldValues ?? '', addForm.isRequired === '' ? 0 : 1, addForm.pattern ?? '', addForm.minLength ?? 0,
database.release(); // eslint-disable-next-line @typescript-eslint/no-magic-numbers
addForm.maxLength ?? 100, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.close();
clearCacheByTableName('ContractTypeFields'); clearCacheByTableName('ContractTypeFields');
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,24 +1,28 @@
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js' import { clearCacheByTableName } from '../helpers/functions.cache.js'
import { acquireConnection } from './pool.js'
export interface AddContractTypeFieldForm { export interface AddContractTypeFieldForm {
contractTypeId?: string | number contractTypeId?: number | string
contractTypeField: string contractTypeField: string
fieldValues?: string
fieldType?: string fieldType?: string
fieldValues?: string
isRequired?: string isRequired?: string
maxLength?: number | string
minLength?: number | string
pattern?: string pattern?: string
minLength?: string | number
maxLength?: string | number
orderNumber?: number orderNumber?: number
} }
export default async function addContractTypeField( export default function addContractTypeField(
addForm: AddContractTypeFieldForm, addForm: AddContractTypeFieldForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -41,6 +45,7 @@ export default async function addContractTypeField(
addForm.isRequired === '' ? 0 : 1, addForm.isRequired === '' ? 0 : 1,
addForm.pattern ?? '', addForm.pattern ?? '',
addForm.minLength ?? 0, addForm.minLength ?? 0,
// eslint-disable-next-line @typescript-eslint/no-magic-numbers
addForm.maxLength ?? 100, addForm.maxLength ?? 100,
addForm.orderNumber ?? -1, addForm.orderNumber ?? -1,
user.userName, user.userName,
@ -49,7 +54,7 @@ export default async function addContractTypeField(
rightNowMillis rightNowMillis
) )
database.release() database.close()
clearCacheByTableName('ContractTypeFields') clearCacheByTableName('ContractTypeFields')

View File

@ -1,6 +1,6 @@
export interface AddContractTypePrintForm { export interface AddContractTypePrintForm {
contractTypeId: string | number; contractTypeId: number | string;
printEJS: string; printEJS: string;
orderNumber?: number; orderNumber?: number;
} }
export default function addContractTypePrint(addForm: AddContractTypePrintForm, user: User): Promise<boolean>; export default function addContractTypePrint(addForm: AddContractTypePrintForm, user: User): boolean;

View File

@ -1,16 +1,17 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js'; export default function addContractTypePrint(addForm, user) {
export default async function addContractTypePrint(addForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
let result = database let result = database
.prepare(`update ContractTypePrints .prepare(`update ContractTypePrints
set recordUpdate_userName = ?, set recordUpdate_userName = ?,
recordUpdate_timeMillis = ?, recordUpdate_timeMillis = ?,
recordDelete_userName = null, recordDelete_userName = null,
recordDelete_timeMillis = null recordDelete_timeMillis = null
where contractTypeId = ? where contractTypeId = ?
and printEJS = ?`) and printEJS = ?`)
.run(user.userName, rightNowMillis, addForm.contractTypeId, addForm.printEJS); .run(user.userName, rightNowMillis, addForm.contractTypeId, addForm.printEJS);
if (result.changes === 0) { if (result.changes === 0) {
result = database result = database
@ -21,7 +22,7 @@ export default async function addContractTypePrint(addForm, user) {
values (?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.contractTypeId, addForm.printEJS, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.contractTypeId, addForm.printEJS, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
} }
database.release(); database.close();
clearCacheByTableName('ContractTypePrints'); clearCacheByTableName('ContractTypePrints');
return result.changes > 0; return result.changes > 0;
} }

View File

@ -1,18 +1,20 @@
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js' import { clearCacheByTableName } from '../helpers/functions.cache.js'
import { acquireConnection } from './pool.js'
export interface AddContractTypePrintForm { export interface AddContractTypePrintForm {
contractTypeId: string | number contractTypeId: number | string
printEJS: string printEJS: string
orderNumber?: number orderNumber?: number
} }
export default async function addContractTypePrint( export default function addContractTypePrint(
addForm: AddContractTypePrintForm, addForm: AddContractTypePrintForm,
user: User user: User
): Promise<boolean> { ): boolean {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -20,11 +22,11 @@ export default async function addContractTypePrint(
.prepare( .prepare(
`update ContractTypePrints `update ContractTypePrints
set recordUpdate_userName = ?, set recordUpdate_userName = ?,
recordUpdate_timeMillis = ?, recordUpdate_timeMillis = ?,
recordDelete_userName = null, recordDelete_userName = null,
recordDelete_timeMillis = null recordDelete_timeMillis = null
where contractTypeId = ? where contractTypeId = ?
and printEJS = ?` and printEJS = ?`
) )
.run( .run(
user.userName, user.userName,
@ -53,7 +55,7 @@ export default async function addContractTypePrint(
) )
} }
database.release() database.close()
clearCacheByTableName('ContractTypePrints') clearCacheByTableName('ContractTypePrints')

View File

@ -1,10 +1,10 @@
export interface AddFeeForm { export interface AddFeeForm {
feeCategoryId: string | number; feeCategoryId: number | string;
feeName: string; feeName: string;
feeDescription: string; feeDescription: string;
feeAccount: string; feeAccount: string;
contractTypeId: string | number; contractTypeId: number | string;
burialSiteTypeId: string | number; burialSiteTypeId: number | string;
feeAmount?: string; feeAmount?: string;
feeFunction?: string; feeFunction?: string;
taxAmount?: string; taxAmount?: string;
@ -14,4 +14,4 @@ export interface AddFeeForm {
isRequired?: '' | '1'; isRequired?: '' | '1';
orderNumber?: number; orderNumber?: number;
} }
export default function addFee(feeForm: AddFeeForm, user: User): Promise<number>; export default function addFee(feeForm: AddFeeForm, user: User): number;

View File

@ -1,6 +1,7 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addFee(feeForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); export default function addFee(feeForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into Fees ( .prepare(`insert into Fees (
@ -15,6 +16,6 @@ export default async function addFee(feeForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(feeForm.feeCategoryId, feeForm.feeName, feeForm.feeDescription, feeForm.feeAccount, feeForm.contractTypeId === '' ? undefined : feeForm.contractTypeId, feeForm.burialSiteTypeId === '' ? undefined : feeForm.burialSiteTypeId, feeForm.feeAmount === '' ? undefined : feeForm.feeAmount, feeForm.feeFunction ?? undefined, feeForm.taxAmount === '' ? undefined : feeForm.taxAmount, feeForm.taxPercentage === '' ? undefined : feeForm.taxPercentage, (feeForm.includeQuantity ?? '') === '' ? 0 : 1, feeForm.quantityUnit, (feeForm.isRequired ?? '') === '' ? 0 : 1, feeForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(feeForm.feeCategoryId, feeForm.feeName, feeForm.feeDescription, feeForm.feeAccount, feeForm.contractTypeId === '' ? undefined : feeForm.contractTypeId, feeForm.burialSiteTypeId === '' ? undefined : feeForm.burialSiteTypeId, feeForm.feeAmount === '' ? undefined : feeForm.feeAmount, feeForm.feeFunction ?? undefined, feeForm.taxAmount === '' ? undefined : feeForm.taxAmount, feeForm.taxPercentage === '' ? undefined : feeForm.taxPercentage, (feeForm.includeQuantity ?? '') === '' ? 0 : 1, feeForm.quantityUnit, (feeForm.isRequired ?? '') === '' ? 0 : 1, feeForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,12 +1,14 @@
import { acquireConnection } from './pool.js' import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddFeeForm { export interface AddFeeForm {
feeCategoryId: string | number feeCategoryId: number | string
feeName: string feeName: string
feeDescription: string feeDescription: string
feeAccount: string feeAccount: string
contractTypeId: string | number contractTypeId: number | string
burialSiteTypeId: string | number burialSiteTypeId: number | string
feeAmount?: string feeAmount?: string
feeFunction?: string feeFunction?: string
taxAmount?: string taxAmount?: string
@ -17,11 +19,8 @@ export interface AddFeeForm {
orderNumber?: number orderNumber?: number
} }
export default async function addFee( export default function addFee(feeForm: AddFeeForm, user: User): number {
feeForm: AddFeeForm, const database = sqlite(sunriseDB)
user: User
): Promise<number> {
const database = await acquireConnection()
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -60,7 +59,7 @@ export default async function addFee(
rightNowMillis rightNowMillis
) )
database.release() database.close()
return result.lastInsertRowid as number return result.lastInsertRowid as number
} }

View File

@ -3,4 +3,4 @@ export interface AddFeeCategoryForm {
isGroupedFee?: '1'; isGroupedFee?: '1';
orderNumber?: number; orderNumber?: number;
} }
export default function addFeeCategory(feeCategoryForm: AddFeeCategoryForm, user: User): Promise<number>; export default function addFeeCategory(feeCategoryForm: AddFeeCategoryForm, user: User): number;

View File

@ -1,6 +1,7 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addFeeCategory(feeCategoryForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); export default function addFeeCategory(feeCategoryForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into FeeCategories ( .prepare(`insert into FeeCategories (
@ -10,6 +11,6 @@ export default async function addFeeCategory(feeCategoryForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?)`)
.run(feeCategoryForm.feeCategory, (feeCategoryForm.isGroupedFee ?? '') === '1' ? 1 : 0, feeCategoryForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(feeCategoryForm.feeCategory, (feeCategoryForm.isGroupedFee ?? '') === '1' ? 1 : 0, feeCategoryForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,4 +1,6 @@
import { acquireConnection } from './pool.js' import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddFeeCategoryForm { export interface AddFeeCategoryForm {
feeCategory: string feeCategory: string
@ -6,11 +8,11 @@ export interface AddFeeCategoryForm {
orderNumber?: number orderNumber?: number
} }
export default async function addFeeCategory( export default function addFeeCategory(
feeCategoryForm: AddFeeCategoryForm, feeCategoryForm: AddFeeCategoryForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -33,7 +35,7 @@ export default async function addFeeCategory(
rightNowMillis rightNowMillis
) )
database.release() database.close()
return result.lastInsertRowid as number return result.lastInsertRowid as number
} }

View File

@ -1,11 +1,11 @@
export interface AddForm { export interface AddForm {
funeralHomeName: string;
funeralHomeKey: string; funeralHomeKey: string;
funeralHomeName: string;
funeralHomeAddress1: string; funeralHomeAddress1: string;
funeralHomeAddress2: string; funeralHomeAddress2: string;
funeralHomeCity: string; funeralHomeCity: string;
funeralHomeProvince: string;
funeralHomePostalCode: string; funeralHomePostalCode: string;
funeralHomeProvince: string;
funeralHomePhoneNumber: string; funeralHomePhoneNumber: string;
} }
export default function addFuneralHome(addForm: AddForm, user: User): Promise<number>; export default function addFuneralHome(addForm: AddForm, user: User): number;

View File

@ -1,6 +1,7 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addFuneralHome(addForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); export default function addFuneralHome(addForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into FuneralHomes ( .prepare(`insert into FuneralHomes (
@ -10,6 +11,6 @@ export default async function addFuneralHome(addForm, user) {
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.funeralHomeName, addForm.funeralHomeKey, addForm.funeralHomeAddress1, addForm.funeralHomeAddress2, addForm.funeralHomeCity, addForm.funeralHomeProvince, addForm.funeralHomePostalCode, addForm.funeralHomePhoneNumber, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.funeralHomeName, addForm.funeralHomeKey, addForm.funeralHomeAddress1, addForm.funeralHomeAddress2, addForm.funeralHomeCity, addForm.funeralHomeProvince, addForm.funeralHomePostalCode, addForm.funeralHomePhoneNumber, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,21 +1,22 @@
import { acquireConnection } from './pool.js' import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
export interface AddForm { export interface AddForm {
funeralHomeName: string
funeralHomeKey: string funeralHomeKey: string
funeralHomeName: string
funeralHomeAddress1: string funeralHomeAddress1: string
funeralHomeAddress2: string funeralHomeAddress2: string
funeralHomeCity: string funeralHomeCity: string
funeralHomeProvince: string
funeralHomePostalCode: string funeralHomePostalCode: string
funeralHomeProvince: string
funeralHomePhoneNumber: string funeralHomePhoneNumber: string
} }
export default async function addFuneralHome( export default function addFuneralHome(addForm: AddForm, user: User): number {
addForm: AddForm, const database = sqlite(sunriseDB)
user: User
): Promise<number> {
const database = await acquireConnection()
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -43,7 +44,7 @@ export default async function addFuneralHome(
rightNowMillis rightNowMillis
) )
database.release() database.close()
return result.lastInsertRowid as number return result.lastInsertRowid as number
} }

View File

@ -1,7 +1,7 @@
export interface AddForm { export interface AddIntermentContainerTypeForm {
intermentContainerType: string; intermentContainerType: string;
intermentContainerTypeKey?: string; intermentContainerTypeKey?: string;
isCremationType?: string; isCremationType?: '0' | '1';
orderNumber?: number; orderNumber?: number | string;
} }
export default function addIntermentContainerType(addForm: AddForm, user: User): Promise<number>; export default function addIntermentContainerType(addForm: AddIntermentContainerTypeForm, user: User): number;

View File

@ -1,7 +1,8 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js'; export default function addIntermentContainerType(addForm, user) {
export default async function addIntermentContainerType(addForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into IntermentContainerTypes ( .prepare(`insert into IntermentContainerTypes (
@ -9,8 +10,8 @@ export default async function addIntermentContainerType(addForm, user) {
recordCreate_userName, recordCreate_timeMillis, recordCreate_userName, recordCreate_timeMillis,
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?, ?, ?)`)
.run(addForm.intermentContainerType, addForm.intermentContainerTypeKey ?? '', addForm.isCremationType === undefined ? 0 : 1, addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(addForm.intermentContainerType, addForm.intermentContainerTypeKey ?? '', addForm.isCremationType ?? '0', addForm.orderNumber ?? -1, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
clearCacheByTableName('IntermentContainerTypes'); clearCacheByTableName('IntermentContainerTypes');
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,19 +1,20 @@
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js' import { clearCacheByTableName } from '../helpers/functions.cache.js'
import { acquireConnection } from './pool.js' export interface AddIntermentContainerTypeForm {
export interface AddForm {
intermentContainerType: string intermentContainerType: string
intermentContainerTypeKey?: string intermentContainerTypeKey?: string
isCremationType?: string isCremationType?: '0' | '1'
orderNumber?: number orderNumber?: number | string
} }
export default async function addIntermentContainerType( export default function addIntermentContainerType(
addForm: AddForm, addForm: AddIntermentContainerTypeForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -28,7 +29,7 @@ export default async function addIntermentContainerType(
.run( .run(
addForm.intermentContainerType, addForm.intermentContainerType,
addForm.intermentContainerTypeKey ?? '', addForm.intermentContainerTypeKey ?? '',
addForm.isCremationType === undefined ? 0 : 1, addForm.isCremationType ?? '0',
addForm.orderNumber ?? -1, addForm.orderNumber ?? -1,
user.userName, user.userName,
rightNowMillis, rightNowMillis,
@ -36,7 +37,7 @@ export default async function addIntermentContainerType(
rightNowMillis rightNowMillis
) )
database.release() database.close()
clearCacheByTableName('IntermentContainerTypes') clearCacheByTableName('IntermentContainerTypes')

View File

@ -1,7 +1,7 @@
import type { PoolConnection } from 'better-sqlite-pool'; import sqlite from 'better-sqlite3';
export interface BurialSiteFieldForm { export interface BurialSiteFieldForm {
burialSiteId: string | number; burialSiteId: number | string;
burialSiteTypeFieldId: string | number; burialSiteTypeFieldId: number | string;
fieldValue: string; fieldValue: string;
} }
export default function addOrUpdateBurialSiteField(fieldForm: BurialSiteFieldForm, user: User, connectedDatabase?: PoolConnection): Promise<boolean>; export default function addOrUpdateBurialSiteField(fieldForm: BurialSiteFieldForm, user: User, connectedDatabase?: sqlite.Database): boolean;

View File

@ -1,16 +1,17 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addOrUpdateBurialSiteField(fieldForm, user, connectedDatabase) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = connectedDatabase ?? (await acquireConnection()); export default function addOrUpdateBurialSiteField(fieldForm, user, connectedDatabase) {
const database = connectedDatabase ?? sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
let result = database let result = database
.prepare(`update BurialSiteFields .prepare(`update BurialSiteFields
set fieldValue = ?, set fieldValue = ?,
recordUpdate_userName = ?, recordUpdate_userName = ?,
recordUpdate_timeMillis = ?, recordUpdate_timeMillis = ?,
recordDelete_userName = null, recordDelete_userName = null,
recordDelete_timeMillis = null recordDelete_timeMillis = null
where burialSiteId = ? where burialSiteId = ?
and burialSiteTypeFieldId = ?`) and burialSiteTypeFieldId = ?`)
.run(fieldForm.fieldValue, user.userName, rightNowMillis, fieldForm.burialSiteId, fieldForm.burialSiteTypeFieldId); .run(fieldForm.fieldValue, user.userName, rightNowMillis, fieldForm.burialSiteId, fieldForm.burialSiteTypeFieldId);
if (result.changes === 0) { if (result.changes === 0) {
result = database result = database
@ -22,7 +23,7 @@ export default async function addOrUpdateBurialSiteField(fieldForm, user, connec
.run(fieldForm.burialSiteId, fieldForm.burialSiteTypeFieldId, fieldForm.fieldValue, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(fieldForm.burialSiteId, fieldForm.burialSiteTypeFieldId, fieldForm.fieldValue, user.userName, rightNowMillis, user.userName, rightNowMillis);
} }
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release(); database.close();
} }
return result.changes > 0; return result.changes > 0;
} }

View File

@ -1,19 +1,19 @@
import type { PoolConnection } from 'better-sqlite-pool' import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
export interface BurialSiteFieldForm { export interface BurialSiteFieldForm {
burialSiteId: string | number burialSiteId: number | string
burialSiteTypeFieldId: string | number burialSiteTypeFieldId: number | string
fieldValue: string fieldValue: string
} }
export default async function addOrUpdateBurialSiteField( export default function addOrUpdateBurialSiteField(
fieldForm: BurialSiteFieldForm, fieldForm: BurialSiteFieldForm,
user: User, user: User,
connectedDatabase?: PoolConnection connectedDatabase?: sqlite.Database
): Promise<boolean> { ): boolean {
const database = connectedDatabase ?? (await acquireConnection()) const database = connectedDatabase ?? sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -21,12 +21,12 @@ export default async function addOrUpdateBurialSiteField(
.prepare( .prepare(
`update BurialSiteFields `update BurialSiteFields
set fieldValue = ?, set fieldValue = ?,
recordUpdate_userName = ?, recordUpdate_userName = ?,
recordUpdate_timeMillis = ?, recordUpdate_timeMillis = ?,
recordDelete_userName = null, recordDelete_userName = null,
recordDelete_timeMillis = null recordDelete_timeMillis = null
where burialSiteId = ? where burialSiteId = ?
and burialSiteTypeFieldId = ?` and burialSiteTypeFieldId = ?`
) )
.run( .run(
fieldForm.fieldValue, fieldForm.fieldValue,
@ -57,7 +57,7 @@ export default async function addOrUpdateBurialSiteField(
} }
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release() database.close()
} }
return result.changes > 0 return result.changes > 0

View File

@ -1,7 +1,7 @@
import type { PoolConnection } from 'better-sqlite-pool'; import sqlite from 'better-sqlite3';
export interface ContractFieldForm { export interface ContractFieldForm {
contractId: string | number; contractId: number | string;
contractTypeFieldId: string | number; contractTypeFieldId: number | string;
fieldValue: string; fieldValue: string;
} }
export default function addOrUpdateContractField(fieldForm: ContractFieldForm, user: User, connectedDatabase?: PoolConnection): Promise<boolean>; export default function addOrUpdateContractField(fieldForm: ContractFieldForm, user: User, connectedDatabase?: sqlite.Database): boolean;

View File

@ -1,16 +1,17 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addOrUpdateContractField(fieldForm, user, connectedDatabase) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = connectedDatabase ?? (await acquireConnection()); export default function addOrUpdateContractField(fieldForm, user, connectedDatabase) {
const database = connectedDatabase ?? sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
let result = database let result = database
.prepare(`update ContractFields .prepare(`update ContractFields
set fieldValue = ?, set fieldValue = ?,
recordUpdate_userName = ?, recordUpdate_userName = ?,
recordUpdate_timeMillis = ?, recordUpdate_timeMillis = ?,
recordDelete_userName = null, recordDelete_userName = null,
recordDelete_timeMillis = null recordDelete_timeMillis = null
where contractId = ? where contractId = ?
and contractTypeFieldId = ?`) and contractTypeFieldId = ?`)
.run(fieldForm.fieldValue, user.userName, rightNowMillis, fieldForm.contractId, fieldForm.contractTypeFieldId); .run(fieldForm.fieldValue, user.userName, rightNowMillis, fieldForm.contractId, fieldForm.contractTypeFieldId);
if (result.changes === 0) { if (result.changes === 0) {
result = database result = database
@ -22,7 +23,7 @@ export default async function addOrUpdateContractField(fieldForm, user, connecte
.run(fieldForm.contractId, fieldForm.contractTypeFieldId, fieldForm.fieldValue, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(fieldForm.contractId, fieldForm.contractTypeFieldId, fieldForm.fieldValue, user.userName, rightNowMillis, user.userName, rightNowMillis);
} }
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release(); database.close();
} }
return result.changes > 0; return result.changes > 0;
} }

View File

@ -1,19 +1,19 @@
import type { PoolConnection } from 'better-sqlite-pool' import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
export interface ContractFieldForm { export interface ContractFieldForm {
contractId: string | number contractId: number | string
contractTypeFieldId: string | number contractTypeFieldId: number | string
fieldValue: string fieldValue: string
} }
export default async function addOrUpdateContractField( export default function addOrUpdateContractField(
fieldForm: ContractFieldForm, fieldForm: ContractFieldForm,
user: User, user: User,
connectedDatabase?: PoolConnection connectedDatabase?: sqlite.Database
): Promise<boolean> { ): boolean {
const database = connectedDatabase ?? (await acquireConnection()) const database = connectedDatabase ?? sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -21,12 +21,12 @@ export default async function addOrUpdateContractField(
.prepare( .prepare(
`update ContractFields `update ContractFields
set fieldValue = ?, set fieldValue = ?,
recordUpdate_userName = ?, recordUpdate_userName = ?,
recordUpdate_timeMillis = ?, recordUpdate_timeMillis = ?,
recordDelete_userName = null, recordDelete_userName = null,
recordDelete_timeMillis = null recordDelete_timeMillis = null
where contractId = ? where contractId = ?
and contractTypeFieldId = ?` and contractTypeFieldId = ?`
) )
.run( .run(
fieldForm.fieldValue, fieldForm.fieldValue,
@ -57,7 +57,7 @@ export default async function addOrUpdateContractField(
} }
if (connectedDatabase === undefined) { if (connectedDatabase === undefined) {
database.release() database.close()
} }
return result.changes > 0 return result.changes > 0

View File

@ -1,3 +1,3 @@
type RecordTable = 'BurialSiteStatuses' | 'BurialSiteTypes' | 'WorkOrderMilestoneTypes' | 'WorkOrderTypes'; type RecordTable = 'BurialSiteStatuses' | 'WorkOrderMilestoneTypes' | 'WorkOrderTypes';
export default function addRecord(recordTable: RecordTable, recordName: string, orderNumber: number | string, user: User): Promise<number>; export default function addRecord(recordTable: RecordTable, recordName: string, orderNumber: number | string, user: User): number;
export {}; export {};

View File

@ -1,13 +1,13 @@
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import { clearCacheByTableName } from '../helpers/functions.cache.js'; import { clearCacheByTableName } from '../helpers/functions.cache.js';
import { acquireConnection } from './pool.js';
const recordNameColumns = new Map([ const recordNameColumns = new Map([
['BurialSiteStatuses', 'burialSiteStatus'], ['BurialSiteStatuses', 'burialSiteStatus'],
['BurialSiteTypes', 'burialSiteType'],
['WorkOrderMilestoneTypes', 'workOrderMilestoneType'], ['WorkOrderMilestoneTypes', 'workOrderMilestoneType'],
['WorkOrderTypes', 'workOrderType'] ['WorkOrderTypes', 'workOrderType']
]); ]);
export default async function addRecord(recordTable, recordName, orderNumber, user) { export default function addRecord(recordTable, recordName, orderNumber, user) {
const database = await acquireConnection(); const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const result = database const result = database
.prepare(`insert into ${recordTable} ( .prepare(`insert into ${recordTable} (
@ -17,7 +17,7 @@ export default async function addRecord(recordTable, recordName, orderNumber, us
recordUpdate_userName, recordUpdate_timeMillis) recordUpdate_userName, recordUpdate_timeMillis)
values (?, ?, ?, ?, ?, ?)`) values (?, ?, ?, ?, ?, ?)`)
.run(recordName, orderNumber === '' ? -1 : orderNumber, user.userName, rightNowMillis, user.userName, rightNowMillis); .run(recordName, orderNumber === '' ? -1 : orderNumber, user.userName, rightNowMillis, user.userName, rightNowMillis);
database.release(); database.close();
clearCacheByTableName(recordTable); clearCacheByTableName(recordTable);
return result.lastInsertRowid; return result.lastInsertRowid;
} }

View File

@ -1,27 +1,26 @@
import { clearCacheByTableName } from '../helpers/functions.cache.js' import sqlite from 'better-sqlite3'
import { acquireConnection } from './pool.js' import { sunriseDB } from '../helpers/database.helpers.js'
import { clearCacheByTableName } from '../helpers/functions.cache.js'
type RecordTable = type RecordTable =
| 'BurialSiteStatuses' | 'BurialSiteStatuses'
| 'BurialSiteTypes'
| 'WorkOrderMilestoneTypes' | 'WorkOrderMilestoneTypes'
| 'WorkOrderTypes' | 'WorkOrderTypes'
const recordNameColumns = new Map<RecordTable, string>([ const recordNameColumns = new Map<RecordTable, string>([
['BurialSiteStatuses', 'burialSiteStatus'], ['BurialSiteStatuses', 'burialSiteStatus'],
['BurialSiteTypes', 'burialSiteType'],
['WorkOrderMilestoneTypes', 'workOrderMilestoneType'], ['WorkOrderMilestoneTypes', 'workOrderMilestoneType'],
['WorkOrderTypes', 'workOrderType'] ['WorkOrderTypes', 'workOrderType']
]) ])
export default async function addRecord( export default function addRecord(
recordTable: RecordTable, recordTable: RecordTable,
recordName: string, recordName: string,
orderNumber: number | string, orderNumber: number | string,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNowMillis = Date.now() const rightNowMillis = Date.now()
@ -43,7 +42,7 @@ export default async function addRecord(
rightNowMillis rightNowMillis
) )
database.release() database.close()
clearCacheByTableName(recordTable) clearCacheByTableName(recordTable)

View File

@ -1,9 +1,9 @@
export interface AddWorkOrderForm { export interface AddWorkOrderForm {
workOrderTypeId: number | string;
workOrderNumber?: string;
workOrderDescription: string; workOrderDescription: string;
workOrderOpenDateString?: string; workOrderNumber?: string;
workOrderTypeId: number | string;
workOrderCloseDateString?: string; workOrderCloseDateString?: string;
workOrderOpenDateString?: string;
contractId?: string; contractId?: string;
} }
export default function addWorkOrder(workOrderForm: AddWorkOrderForm, user: User): Promise<number>; export default function addWorkOrder(workOrderForm: AddWorkOrderForm, user: User): number;

View File

@ -1,13 +1,14 @@
import { dateStringToInteger, dateToInteger } from '@cityssm/utils-datetime'; import { dateStringToInteger, dateToInteger } from '@cityssm/utils-datetime';
import sqlite from 'better-sqlite3';
import { sunriseDB } from '../helpers/database.helpers.js';
import addWorkOrderContract from './addWorkOrderContract.js'; import addWorkOrderContract from './addWorkOrderContract.js';
import getNextWorkOrderNumber from './getNextWorkOrderNumber.js'; import getNextWorkOrderNumber from './getNextWorkOrderNumber.js';
import { acquireConnection } from './pool.js'; export default function addWorkOrder(workOrderForm, user) {
export default async function addWorkOrder(workOrderForm, user) { const database = sqlite(sunriseDB);
const database = await acquireConnection();
const rightNow = new Date(); const rightNow = new Date();
let workOrderNumber = workOrderForm.workOrderNumber; let workOrderNumber = workOrderForm.workOrderNumber;
if ((workOrderNumber ?? '') === '') { if ((workOrderNumber ?? '') === '') {
workOrderNumber = await getNextWorkOrderNumber(database); workOrderNumber = getNextWorkOrderNumber(database);
} }
const result = database const result = database
.prepare(`insert into WorkOrders ( .prepare(`insert into WorkOrders (
@ -23,11 +24,11 @@ export default async function addWorkOrder(workOrderForm, user) {
: dateStringToInteger(workOrderForm.workOrderCloseDateString), user.userName, rightNow.getTime(), user.userName, rightNow.getTime()); : dateStringToInteger(workOrderForm.workOrderCloseDateString), user.userName, rightNow.getTime(), user.userName, rightNow.getTime());
const workOrderId = result.lastInsertRowid; const workOrderId = result.lastInsertRowid;
if ((workOrderForm.contractId ?? '') !== '') { if ((workOrderForm.contractId ?? '') !== '') {
await addWorkOrderContract({ addWorkOrderContract({
contractId: workOrderForm.contractId,
workOrderId, workOrderId,
contractId: workOrderForm.contractId
}, user, database); }, user, database);
} }
database.release(); database.close();
return workOrderId; return workOrderId;
} }

View File

@ -3,32 +3,37 @@ import {
dateStringToInteger, dateStringToInteger,
dateToInteger dateToInteger
} from '@cityssm/utils-datetime' } from '@cityssm/utils-datetime'
import sqlite from 'better-sqlite3'
import { sunriseDB } from '../helpers/database.helpers.js'
import addWorkOrderContract from './addWorkOrderContract.js' import addWorkOrderContract from './addWorkOrderContract.js'
import getNextWorkOrderNumber from './getNextWorkOrderNumber.js' import getNextWorkOrderNumber from './getNextWorkOrderNumber.js'
import { acquireConnection } from './pool.js'
export interface AddWorkOrderForm { export interface AddWorkOrderForm {
workOrderTypeId: number | string
workOrderNumber?: string
workOrderDescription: string workOrderDescription: string
workOrderOpenDateString?: string workOrderNumber?: string
workOrderTypeId: number | string
workOrderCloseDateString?: string workOrderCloseDateString?: string
workOrderOpenDateString?: string
contractId?: string contractId?: string
} }
export default async function addWorkOrder( export default function addWorkOrder(
workOrderForm: AddWorkOrderForm, workOrderForm: AddWorkOrderForm,
user: User user: User
): Promise<number> { ): number {
const database = await acquireConnection() const database = sqlite(sunriseDB)
const rightNow = new Date() const rightNow = new Date()
let workOrderNumber = workOrderForm.workOrderNumber let workOrderNumber = workOrderForm.workOrderNumber
if ((workOrderNumber ?? '') === '') { if ((workOrderNumber ?? '') === '') {
workOrderNumber = await getNextWorkOrderNumber(database) workOrderNumber = getNextWorkOrderNumber(database)
} }
const result = database const result = database
@ -63,17 +68,17 @@ export default async function addWorkOrder(
const workOrderId = result.lastInsertRowid as number const workOrderId = result.lastInsertRowid as number
if ((workOrderForm.contractId ?? '') !== '') { if ((workOrderForm.contractId ?? '') !== '') {
await addWorkOrderContract( addWorkOrderContract(
{ {
contractId: workOrderForm.contractId as string,
workOrderId, workOrderId,
contractId: workOrderForm.contractId as string
}, },
user, user,
database database
) )
} }
database.release() database.close()
return workOrderId return workOrderId
} }

View File

@ -1,5 +1,5 @@
export interface AddForm { export interface AddForm {
workOrderId: number | string;
burialSiteId: number | string; burialSiteId: number | string;
workOrderId: number | string;
} }
export default function addWorkOrderBurialSite(workOrderLotForm: AddForm, user: User): Promise<boolean>; export default function addWorkOrderBurialSite(workOrderLotForm: AddForm, user: User): boolean;

View File

@ -1,6 +1,7 @@
import { acquireConnection } from './pool.js'; import sqlite from 'better-sqlite3';
export default async function addWorkOrderBurialSite(workOrderLotForm, user) { import { sunriseDB } from '../helpers/database.helpers.js';
const database = await acquireConnection(); export default function addWorkOrderBurialSite(workOrderLotForm, user) {
const database = sqlite(sunriseDB);
const rightNowMillis = Date.now(); const rightNowMillis = Date.now();
const row = database const row = database
.prepare(`select recordDelete_timeMillis .prepare(`select recordDelete_timeMillis
@ -32,6 +33,6 @@ export default async function addWorkOrderBurialSite(workOrderLotForm, user) {
.run(user.userName, rightNowMillis, user.userName, rightNowMillis, workOrderLotForm.workOrderId, workOrderLotForm.burialSiteId); .run(user.userName, rightNowMillis, user.userName, rightNowMillis, workOrderLotForm.workOrderId, workOrderLotForm.burialSiteId);
} }
} }
database.release(); database.close();
return true; return true;
} }

Some files were not shown because too many files have changed in this diff Show More