cityssm/faster-web-helper

import { parseW217ExcelReport } from '@cityssm/faster-report-parser/xlsx';
import { dateStringToInteger, timeStringToInteger } from '@cityssm/utils-datetime';
import { WorkTechAPI } from '@cityssm/worktech-api';
import camelCase from 'camelcase';
import Debug from 'debug';
import { getConfigProperty } from '../../../helpers/functions.config.js';
import { downloadFilesToTemp } from '../../../helpers/functions.sftp.js';
import addReturnToVendorRecord from '../database/addReturnToVendorRecord.js';
import addWorkOrderNumberMapping from '../database/addWorkOrderNumberMapping.js';
import getReturnToVendorRecord from '../database/getReturnToVendorRecord.js';
import getWorkOrderNumberMapping from '../database/getWorkOrderNumberMapping.js';
import updateWorkOrderNumberMapping from '../database/updateWorkOrderNumberMapping.js';
import { moduleName } from '../helpers/moduleHelpers.js';
export const taskName = 'Direct Change Helper Task';
const debug = Debug(`faster-web-helper:${camelCase(moduleName)}:${camelCase(taskName)}`);
const worktech = new WorkTechAPI(getConfigProperty('worktech'));
const directChargeTransactionsConfig = getConfigProperty('modules.worktechUpdate.reports.w217');
async function _updateWorkOrderNumberMappings(report, data) {
    const mapping = getWorkOrderNumberMapping(data.documentNumber);
    const exportDate = dateStringToInteger(report.exportDate);
    const exportTime = timeStringToInteger(report.exportTime);
    if (mapping === undefined) {
        /*
         * Unseen Mapping
         * Save it
         */
        debug(`New Mapping: ${data.documentNumber} -> ${data.symptom}`);
        addWorkOrderNumberMapping({
            documentNumber: data.documentNumber,
            workOrderNumber: data.symptom,
            exportDate,
            exportTime
        });
    }
    else if (mapping.exportDate < exportDate ||
        (mapping.exportDate === exportDate && mapping.exportTime < exportTime)) {
        /*
         * This record is newer.
         */
        if (mapping.workOrderNumber !== data.symptom) {
            /*
             * Work order number change.
             * Update any previous records for the document number.
             */
            debug(`Work Order Number Update: ${data.documentNumber} -> ${data.symptom}`);
            const oldResourceRecords = await worktech.getWorkOrderResourcesByWorkOrderNumber(mapping.workOrderNumber);
            if (data.symptom === '') {
                for (const oldResourceRecord of oldResourceRecords) {
                    await worktech.deleteWorkOrderResource(oldResourceRecord.serviceRequestItemSystemId);
                }
            }
            else {
                const newWorkOrder = await worktech.getWorkOrderByWorkOrderNumber(data.symptom);
                if (newWorkOrder === undefined) {
                    debug(`New work order number not found: ${data.symptom}`);
                    return false;
                }
                for (const oldResourceRecord of oldResourceRecords) {
                    await worktech.updateWorkOrderResource({
                        serviceRequestItemSystemId: oldResourceRecord.serviceRequestItemSystemId,
                        serviceRequestSystemId: newWorkOrder?.serviceRequestSystemId,
                        workOrderNumber: newWorkOrder?.workOrderNumber
                    });
                }
            }
        }
        /*
         * Update mapping record
         */
        updateWorkOrderNumberMapping({
            documentNumber: mapping.documentNumber,
            workOrderNumber: data.symptom,
            exportDate,
            exportTime
        });
    }
    return true;
}
function _trackReturnToVendorRecords(report, data) {
    for (const transaction of data.transactions) {
        if (transaction.repairDescription.startsWith('Return to Vendor - ')) {
            const transactionRecord = {
                documentNumber: data.documentNumber,
                storeroom: transaction.storeroom,
                itemNumber: transaction.itemNumber,
                transactionDate: dateStringToInteger(transaction.transactionDate),
                quantity: transaction.quantity,
                cost: transaction.cost
            };
            const existingRecord = getReturnToVendorRecord(transactionRecord);
            if (existingRecord === undefined) {
                debug(`New "Return to Vendor" record: ${JSON.stringify(transactionRecord)}`);
                addReturnToVendorRecord(transactionRecord);
            }
        }
    }
}
/**
 * - Maintains mappings between Faster document numbers and Worktech work order numbers.
 * - Tracks "Return to Vendor" transactions.
 */
export default async function runDirectChargeHelperTask() {
    if (directChargeTransactionsConfig === undefined) {
        return;
    }
    debug(`Running "${taskName}"...`);
    /*
     * Download files to temp
     */
    const tempDirectChargeReportFiles = await downloadFilesToTemp(directChargeTransactionsConfig.ftpPath);
    /*
     * Loop through files
     */
    debug(`${tempDirectChargeReportFiles.length} file(s) to process...`);
    for (const reportFile of tempDirectChargeReportFiles) {
        try {
            const report = parseW217ExcelReport(reportFile);
            if ((report.parameters['Include Returns'] ?? '') !== 'Yes') {
                debug('W217 reports must have "Include Returns" = "Yes", skipping file.');
                continue;
            }
            for (const data of report.data) {
                await _updateWorkOrderNumberMappings(report, data);
                _trackReturnToVendorRecords(report, data);
            }
        }
        catch (error) {
            debug(error);
        }
    }
    debug(`Finished "${taskName}".`);
}