You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
322 lines
17 KiB
322 lines
17 KiB
const asyncHandler = require("../Middleware/async"); |
|
const sequelize = require('sequelize') |
|
const StoreModel = require("../Model/StoreModel"); |
|
const db = require("../Config/db"); |
|
const ErrorResponse = require("../utils/errorResponse"); |
|
const SuccessResponse = require("../utils/successResponse"); |
|
|
|
const dateFormat = require("dateformat"); |
|
|
|
exports.getStoreInfo = asyncHandler(async (req, res, next) => { |
|
console.log("GET STORE INFO EXEC ") |
|
try { |
|
let store = await StoreModel.findAll() |
|
console.log("STORE ", store) |
|
if (!store) { |
|
return next(new ErrorResponse("No store found", 400)); |
|
} |
|
res.status(200).send({ |
|
success: true, |
|
data: store |
|
}) |
|
} catch (err) { |
|
console.log("ERROR GET ALL STORE", err) |
|
return next(new ErrorResponse(err, 400)); |
|
} |
|
}) |
|
|
|
exports.registerStore = asyncHandler(async (req, res, next) => { |
|
const { store_name } = req.body |
|
try { |
|
const t = await db.transaction() |
|
// check whether store name is existing |
|
const existingStore = await StoreModel.findOne({ |
|
where: { ST_NAME: store_name } |
|
}) |
|
|
|
if (existingStore) { |
|
return next(new ErrorResponse("Store name already exists", 400)); |
|
} |
|
var date = dateFormat(new Date(), "mm/dd/yyyy"); |
|
|
|
const nextStoreCode = await generateNextStoreCode() |
|
let store = await StoreModel.create( |
|
{ |
|
ST_CODE: nextStoreCode, |
|
ST_NAME: store_name, |
|
ST_STAT: 'A', |
|
DATE_CREA: date, |
|
DATE_UPDT: date, |
|
DATE_FORMAT: "MM/dd/yyyy", |
|
DATE_DEFAULT: 'L', |
|
SA_DECIMAL: '2', |
|
SB_DECICMA: '2', |
|
DEC_SEP: '.', |
|
THO_SEP: ',', |
|
USER_CREA: req.user.USER_NAME, |
|
USER_UPDT: '', |
|
}, { transaction: t } |
|
) |
|
|
|
await createStoreTables(nextStoreCode, t); |
|
|
|
await t.commit(); |
|
|
|
res.status(201).json({ |
|
success: true, |
|
data: store |
|
|
|
}) |
|
|
|
} catch (err) { |
|
return next(new ErrorResponse(err, 400)); |
|
} |
|
}) |
|
|
|
async function generateNextStoreCode() { |
|
const lastStore = await StoreModel.findOne({ |
|
order: [['ST_CODE', 'DESC']] |
|
}); |
|
|
|
if (!lastStore) { |
|
return 'AA001'; // Starting point if no stores are present |
|
} |
|
|
|
// use regex to separate letters and numbers |
|
let [letters, numbers] = lastStore.ST_CODE.match(/[A-Z]+|\d+/g); |
|
// letters -> AA , numbers -> 001 |
|
|
|
numbers = parseInt(numbers); |
|
|
|
if (numbers < 999) { |
|
numbers++; |
|
} else { |
|
numbers = 1; |
|
letters = incrementLetters(letters); |
|
} |
|
|
|
return letters + numbers.toString().padStart(3, '0'); |
|
} |
|
|
|
function incrementLetters(letters) { |
|
const maxLetters = 'ZZ'; |
|
if (letters === maxLetters) { |
|
throw new Error("Maximum limit reached."); |
|
} |
|
|
|
let firstChar = letters.charCodeAt(0); |
|
let secondChar = letters.charCodeAt(1); |
|
|
|
// if second character is Z, increment first character |
|
// and reset second character to A |
|
if (secondChar === 90) { |
|
firstChar++; |
|
secondChar = 65; |
|
} else { |
|
secondChar++; |
|
} |
|
|
|
return String.fromCharCode(firstChar) + String.fromCharCode(secondChar); |
|
} |
|
|
|
async function createStoreTables(storeCode, transaction) { |
|
try { |
|
// Table for TDSOHDR |
|
const tableTDSOHDR = `${storeCode}TDSOHDR`; |
|
await db.query(` |
|
IF NOT EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'dbo' AND TABLE_NAME = '${tableTDSOHDR}') |
|
BEGIN |
|
CREATE TABLE [dbo].${tableTDSOHDR} ( |
|
[REC_TYPE] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_REF] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[HEADER_ID] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[CUST_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DELIV_ADD] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_DATE] smalldatetime NOT NULL, |
|
[STATUS] char(2) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_CD] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_CODE] nvarchar(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ORDER_NO] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ORDER_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[PRN_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DEL_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[INV_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[INV_PRD] int NOT NULL, |
|
[CUST_REF] nvarchar(25) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DEL_REF] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[COMMENTS] nvarchar(25) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_VAL] numeric(18,5) NOT NULL, |
|
[PAY_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M0] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M1] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M2] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M3] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M4] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M5] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M6] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M7] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M8] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M9] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[QUOTE_CONVERT] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[QUOTE_PRINT] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[QUOTE_EXPIRY] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[QUOTED_PRD] int NOT NULL, |
|
[QUOTATION_REF] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DATE_QUOTED] nvarchar(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[VOID_STATUS] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[USER_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
CONSTRAINT [PK_${tableTDSOHDR}] PRIMARY KEY CLUSTERED ([REC_TYPE], [TRANS_REF]) |
|
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) |
|
ON [PRIMARY] |
|
) |
|
ON [PRIMARY] |
|
|
|
|
|
ALTER TABLE [dbo].${tableTDSOHDR} SET (LOCK_ESCALATION = TABLE) |
|
END |
|
`, { type: sequelize.QueryTypes.RAW, transaction }); |
|
|
|
// Table for TDSODET |
|
const tableTDSODET = `${storeCode}TDSODET`; |
|
await db.query(` |
|
IF NOT EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'dbo' AND TABLE_NAME = '${tableTDSODET}') |
|
BEGIN |
|
CREATE TABLE [dbo].${tableTDSODET} ( |
|
[REC_TYPE] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DETAIL_ID] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_TYPE] nvarchar(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_REF] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_LINE] char(5) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[TRANS_CD] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[LOCATION] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ITEM_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DESCRIPTN] nvarchar(50) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[DUE_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[STATUS] char(2) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[VALUE_1] numeric(18,5) NOT NULL, |
|
[VALUE_2] numeric(18,5) NOT NULL, |
|
[VALUE_3] numeric(18,5) NOT NULL, |
|
[VALUE_4] numeric(18,5) NOT NULL, |
|
[VALUE_5] numeric(18,5) NOT NULL, |
|
[VALUE_6] numeric(18,5) NOT NULL, |
|
[VALUE_7] numeric(18,5) NOT NULL, |
|
[VALUE_8] numeric(18,5) NOT NULL, |
|
[VALUE_9] numeric(18,5) NOT NULL, |
|
[VALUE_10] numeric(18,5) NOT NULL, |
|
[VALUE_11] numeric(18,5) NOT NULL, |
|
[VALUE_12] numeric(18,5) NOT NULL, |
|
[VALUE_13] numeric(18,5) NOT NULL, |
|
[VALUE_14] numeric(18,5) NOT NULL, |
|
[VALUE_15] numeric(18,5) NOT NULL, |
|
[VALUE_16] numeric(18,5) NOT NULL, |
|
[VALUE_17] numeric(18,5) NOT NULL, |
|
[VALUE_18] numeric(18,5) NOT NULL, |
|
[VALUE_19] numeric(18,5) NOT NULL, |
|
[VALUE_20] numeric(18,5) NOT NULL, |
|
[UNIT_SALE] nvarchar(5) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ORD_PRD] int NOT NULL, |
|
[DEL_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[INV_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[INV_NO] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[INV_PRD] int NOT NULL, |
|
[ACCNT_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M0] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M1] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M2] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M3] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M4] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M5] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M6] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M7] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M8] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M9] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ASSEMBLY_IND] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[SPLIT_VAL] int NOT NULL, |
|
[CREDIT_STATUS] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[PRICE_BOOK] nvarchar(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[SALE_QTY_VALUE] int NOT NULL, |
|
[STK_QTY_VALUE] int NOT NULL, |
|
[TOT_VALUE] int NOT NULL, |
|
[DISP_VAL_1] int NOT NULL, |
|
[DISP_VAL_2] int NOT NULL, |
|
[FIXED_VAL] int NOT NULL, |
|
[LINE_REF] nvarchar(20) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[USER_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[USER_INVOICED] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ALLOC_REF] char(20) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[UPDATE_STOCK] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[FIXED_VAL_2] int NOT NULL, |
|
[FIXED_VAL_3] int NOT NULL, |
|
CONSTRAINT [PK_${tableTDSODET}] PRIMARY KEY CLUSTERED ([TRANS_REF], [TRANS_LINE]) |
|
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) |
|
ON [PRIMARY] |
|
) |
|
ON [PRIMARY] |
|
|
|
|
|
ALTER TABLE [dbo].${tableTDSODET} SET (LOCK_ESCALATION = TABLE) |
|
END |
|
`, { type: sequelize.QueryTypes.RAW, transaction }); |
|
|
|
// Table for TDINVMOV |
|
const tableTDINVMOV = `${storeCode}TDINVMOV`; |
|
await db.query(` |
|
IF NOT EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'dbo' AND TABLE_NAME = '${tableTDINVMOV}') |
|
BEGIN |
|
CREATE TABLE [dbo].${tableTDINVMOV} ( |
|
[SEQUENCE] int NOT NULL, |
|
[REC_TYPE] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[MOV_PRD] int NOT NULL, |
|
[MOV_REF] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[MOV_LINE] char(4) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[LOCATION] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ITEM_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[MOV_DATE] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[STATUS] char(2) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[IR_STAT] char(1) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[BATCH_NO] int NOT NULL, |
|
[BATCH_LINE] char(5) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[LINE_REF] nvarchar(20) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[QUANTITY] numeric(18,5) NOT NULL, |
|
[COST] numeric(18,5) NOT NULL, |
|
[TOTAL] numeric(18,5) NOT NULL, |
|
[MOV_UNITS] nvarchar(5) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[MOV_TYPE] nvarchar(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[UPDTE_PHYS] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[UPDTE_ORDR] char(10) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ALLOC_REF] nvarchar(20) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ACCNT_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ASSET_CODE] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M0] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M1] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M2] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M3] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M4] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M5] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M6] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M7] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M8] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ANAL_M9] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ORIG_LINE_NO] char(5) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[PO_VALUE] numeric(18,5) NOT NULL, |
|
[ID_ENTERED] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
[ID_ALLOC] nvarchar(15) COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL, |
|
CONSTRAINT [PK_${tableTDINVMOV}] PRIMARY KEY CLUSTERED ([MOV_REF], [MOV_LINE]) |
|
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) |
|
ON [PRIMARY] |
|
) |
|
ON [PRIMARY] |
|
|
|
|
|
ALTER TABLE [dbo].${tableTDINVMOV} SET (LOCK_ESCALATION = TABLE) |
|
END |
|
`, { type: sequelize.QueryTypes.RAW, transaction }); |
|
|
|
} catch (error) { |
|
console.error('Error creating store tables:', error); |
|
throw new Error('Failed to create store tables.'); |
|
} |
|
} |
|
|
|
|
|
|
|
|