Compare commits
2 Commits
798688e4c2
...
17c62d2b45
| Author | SHA1 | Date | |
|---|---|---|---|
| 17c62d2b45 | |||
| 2282d29322 |
@ -1,2 +1,2 @@
|
||||
import{a as s}from"./index-BgkDE8Pi.js";import"./radix-vendor-CYvDqP9X.js";import"./charts-vendor-BVfwAPj-.js";import"./utils-vendor-DNMmNUQL.js";import"./ui-vendor-DyksGUTu.js";import"./socket-vendor-TjCxX7sJ.js";import"./redux-vendor-tbZCm13o.js";import"./router-vendor-B_rK4TXr.js";async function m(n){return(await s.post(`/conclusions/${n}/generate`)).data.data}async function f(n,t){return(await s.post(`/conclusions/${n}/finalize`,{finalRemark:t})).data.data}async function d(n){var t;try{return(await s.get(`/conclusions/${n}`)).data.data}catch(o){if(((t=o.response)==null?void 0:t.status)===404)return null;throw o}}export{f as finalizeConclusion,m as generateConclusion,d as getConclusion};
|
||||
//# sourceMappingURL=conclusionApi-VENY18zj.js.map
|
||||
import{a as s}from"./index-PI_IMErM.js";import"./radix-vendor-CYvDqP9X.js";import"./charts-vendor-BVfwAPj-.js";import"./utils-vendor-DNMmNUQL.js";import"./ui-vendor-DfwWW08H.js";import"./socket-vendor-TjCxX7sJ.js";import"./redux-vendor-tbZCm13o.js";import"./router-vendor-B_rK4TXr.js";async function m(n){return(await s.post(`/conclusions/${n}/generate`)).data.data}async function f(n,t){return(await s.post(`/conclusions/${n}/finalize`,{finalRemark:t})).data.data}async function d(n){var t;try{return(await s.get(`/conclusions/${n}`)).data.data}catch(o){if(((t=o.response)==null?void 0:t.status)===404)return null;throw o}}export{f as finalizeConclusion,m as generateConclusion,d as getConclusion};
|
||||
//# sourceMappingURL=conclusionApi-D5monZ70.js.map
|
||||
@ -1 +1 @@
|
||||
{"version":3,"file":"conclusionApi-VENY18zj.js","sources":["../../src/services/conclusionApi.ts"],"sourcesContent":["import apiClient from './authApi';\r\n\r\nexport interface ConclusionRemark {\r\n conclusionId: string;\r\n requestId: string;\r\n aiGeneratedRemark: string | null;\r\n aiModelUsed: string | null;\r\n aiConfidenceScore: number | null;\r\n finalRemark: string | null;\r\n editedBy: string | null;\r\n isEdited: boolean;\r\n editCount: number;\r\n approvalSummary: any;\r\n documentSummary: any;\r\n keyDiscussionPoints: string[];\r\n generatedAt: string | null;\r\n finalizedAt: string | null;\r\n createdAt: string;\r\n updatedAt: string;\r\n}\r\n\r\n/**\r\n * Generate AI-powered conclusion remark\r\n */\r\nexport async function generateConclusion(requestId: string): Promise<{\r\n conclusionId: string;\r\n aiGeneratedRemark: string;\r\n keyDiscussionPoints: string[];\r\n confidence: number;\r\n generatedAt: string;\r\n}> {\r\n const response = await apiClient.post(`/conclusions/${requestId}/generate`);\r\n return response.data.data;\r\n}\r\n\r\n/**\r\n * Update conclusion remark (edit by initiator)\r\n */\r\nexport async function updateConclusion(requestId: string, finalRemark: string): Promise<ConclusionRemark> {\r\n const response = await apiClient.put(`/conclusions/${requestId}`, { finalRemark });\r\n return response.data.data;\r\n}\r\n\r\n/**\r\n * Finalize conclusion and close request\r\n */\r\nexport async function finalizeConclusion(requestId: string, finalRemark: string): Promise<{\r\n conclusionId: string;\r\n requestNumber: string;\r\n status: string;\r\n finalRemark: string;\r\n finalizedAt: string;\r\n}> {\r\n const response = await apiClient.post(`/conclusions/${requestId}/finalize`, { finalRemark });\r\n return response.data.data;\r\n}\r\n\r\n/**\r\n * Get conclusion for a request\r\n * Returns null if conclusion doesn't exist (404) instead of throwing error\r\n */\r\nexport async function getConclusion(requestId: string): Promise<ConclusionRemark | null> {\r\n try {\r\n const response = await apiClient.get(`/conclusions/${requestId}`);\r\n return response.data.data;\r\n } catch (error: any) {\r\n // Handle 404 gracefully - conclusion doesn't exist yet, which is normal\r\n if (error.response?.status === 404) {\r\n return null;\r\n }\r\n // Re-throw other errors\r\n throw error;\r\n }\r\n}\r\n\r\n"],"names":["generateConclusion","requestId","apiClient","finalizeConclusion","finalRemark","getConclusion","error","_a"],"mappings":"6RAwBA,eAAsBA,EAAmBC,EAMtC,CAED,OADiB,MAAMC,EAAU,KAAK,gBAAgBD,CAAS,WAAW,GAC1D,KAAK,IACvB,CAaA,eAAsBE,EAAmBF,EAAmBG,EAMzD,CAED,OADiB,MAAMF,EAAU,KAAK,gBAAgBD,CAAS,YAAa,CAAE,YAAAG,EAAa,GAC3E,KAAK,IACvB,CAMA,eAAsBC,EAAcJ,EAAqD,OACvF,GAAI,CAEF,OADiB,MAAMC,EAAU,IAAI,gBAAgBD,CAAS,EAAE,GAChD,KAAK,IACvB,OAASK,EAAY,CAEnB,KAAIC,EAAAD,EAAM,WAAN,YAAAC,EAAgB,UAAW,IAC7B,OAAO,KAGT,MAAMD,CACR,CACF"}
|
||||
{"version":3,"file":"conclusionApi-D5monZ70.js","sources":["../../src/services/conclusionApi.ts"],"sourcesContent":["import apiClient from './authApi';\r\n\r\nexport interface ConclusionRemark {\r\n conclusionId: string;\r\n requestId: string;\r\n aiGeneratedRemark: string | null;\r\n aiModelUsed: string | null;\r\n aiConfidenceScore: number | null;\r\n finalRemark: string | null;\r\n editedBy: string | null;\r\n isEdited: boolean;\r\n editCount: number;\r\n approvalSummary: any;\r\n documentSummary: any;\r\n keyDiscussionPoints: string[];\r\n generatedAt: string | null;\r\n finalizedAt: string | null;\r\n createdAt: string;\r\n updatedAt: string;\r\n}\r\n\r\n/**\r\n * Generate AI-powered conclusion remark\r\n */\r\nexport async function generateConclusion(requestId: string): Promise<{\r\n conclusionId: string;\r\n aiGeneratedRemark: string;\r\n keyDiscussionPoints: string[];\r\n confidence: number;\r\n generatedAt: string;\r\n}> {\r\n const response = await apiClient.post(`/conclusions/${requestId}/generate`);\r\n return response.data.data;\r\n}\r\n\r\n/**\r\n * Update conclusion remark (edit by initiator)\r\n */\r\nexport async function updateConclusion(requestId: string, finalRemark: string): Promise<ConclusionRemark> {\r\n const response = await apiClient.put(`/conclusions/${requestId}`, { finalRemark });\r\n return response.data.data;\r\n}\r\n\r\n/**\r\n * Finalize conclusion and close request\r\n */\r\nexport async function finalizeConclusion(requestId: string, finalRemark: string): Promise<{\r\n conclusionId: string;\r\n requestNumber: string;\r\n status: string;\r\n finalRemark: string;\r\n finalizedAt: string;\r\n}> {\r\n const response = await apiClient.post(`/conclusions/${requestId}/finalize`, { finalRemark });\r\n return response.data.data;\r\n}\r\n\r\n/**\r\n * Get conclusion for a request\r\n * Returns null if conclusion doesn't exist (404) instead of throwing error\r\n */\r\nexport async function getConclusion(requestId: string): Promise<ConclusionRemark | null> {\r\n try {\r\n const response = await apiClient.get(`/conclusions/${requestId}`);\r\n return response.data.data;\r\n } catch (error: any) {\r\n // Handle 404 gracefully - conclusion doesn't exist yet, which is normal\r\n if (error.response?.status === 404) {\r\n return null;\r\n }\r\n // Re-throw other errors\r\n throw error;\r\n }\r\n}\r\n\r\n"],"names":["generateConclusion","requestId","apiClient","finalizeConclusion","finalRemark","getConclusion","error","_a"],"mappings":"6RAwBA,eAAsBA,EAAmBC,EAMtC,CAED,OADiB,MAAMC,EAAU,KAAK,gBAAgBD,CAAS,WAAW,GAC1D,KAAK,IACvB,CAaA,eAAsBE,EAAmBF,EAAmBG,EAMzD,CAED,OADiB,MAAMF,EAAU,KAAK,gBAAgBD,CAAS,YAAa,CAAE,YAAAG,EAAa,GAC3E,KAAK,IACvB,CAMA,eAAsBC,EAAcJ,EAAqD,OACvF,GAAI,CAEF,OADiB,MAAMC,EAAU,IAAI,gBAAgBD,CAAS,EAAE,GAChD,KAAK,IACvB,OAASK,EAAY,CAEnB,KAAIC,EAAAD,EAAM,WAAN,YAAAC,EAAgB,UAAW,IAC7B,OAAO,KAGT,MAAMD,CACR,CACF"}
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
67
build/assets/index-PI_IMErM.js
Normal file
67
build/assets/index-PI_IMErM.js
Normal file
File diff suppressed because one or more lines are too long
1
build/assets/index-PI_IMErM.js.map
Normal file
1
build/assets/index-PI_IMErM.js.map
Normal file
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -13,11 +13,11 @@
|
||||
<!-- Preload critical fonts and icons -->
|
||||
<link rel="preconnect" href="https://fonts.googleapis.com">
|
||||
<link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
|
||||
<script type="module" crossorigin src="/assets/index-BgkDE8Pi.js"></script>
|
||||
<script type="module" crossorigin src="/assets/index-PI_IMErM.js"></script>
|
||||
<link rel="modulepreload" crossorigin href="/assets/charts-vendor-BVfwAPj-.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/radix-vendor-CYvDqP9X.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/utils-vendor-DNMmNUQL.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/ui-vendor-DyksGUTu.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/ui-vendor-DfwWW08H.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/socket-vendor-TjCxX7sJ.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/redux-vendor-tbZCm13o.js">
|
||||
<link rel="modulepreload" crossorigin href="/assets/router-vendor-B_rK4TXr.js">
|
||||
|
||||
@ -4,7 +4,7 @@
|
||||
"description": "Royal Enfield Workflow Management System - Backend API (TypeScript)",
|
||||
"main": "dist/server.js",
|
||||
"scripts": {
|
||||
"start": "npm run build && npm run start:prod && npm run setup",
|
||||
"start": "npm run build && npm run setup && npm run start:prod",
|
||||
"dev": "npm run setup && nodemon --exec ts-node -r tsconfig-paths/register src/server.ts",
|
||||
"dev:no-setup": "nodemon --exec ts-node -r tsconfig-paths/register src/server.ts",
|
||||
"build": "tsc && tsc-alias",
|
||||
|
||||
11
src/app.ts
11
src/app.ts
@ -85,18 +85,17 @@ app.use(cookieParser());
|
||||
|
||||
const userService = new UserService();
|
||||
|
||||
// Initialize database connection
|
||||
const initializeDatabase = async () => {
|
||||
// Initializer for database connection (called from server.ts)
|
||||
export const initializeAppDatabase = async () => {
|
||||
try {
|
||||
await sequelize.authenticate();
|
||||
console.log('✅ App database connection established');
|
||||
} catch (error) {
|
||||
console.error('❌ Database connection failed:', error);
|
||||
console.error('❌ App database connection failed:', error);
|
||||
throw error;
|
||||
}
|
||||
};
|
||||
|
||||
// Initialize database
|
||||
initializeDatabase();
|
||||
|
||||
// Trust proxy - Enable this when behind a reverse proxy (nginx, load balancer, etc.)
|
||||
// This allows Express to read X-Forwarded-* headers correctly
|
||||
// Set to true in production, false in development
|
||||
|
||||
@ -132,10 +132,13 @@ export class AuthController {
|
||||
|
||||
// Set new access token in cookie if using cookie-based auth
|
||||
const isProduction = process.env.NODE_ENV === 'production';
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
const isSecureEnv = isProduction || isUat;
|
||||
|
||||
const cookieOptions = {
|
||||
httpOnly: true,
|
||||
secure: isProduction,
|
||||
sameSite: isProduction ? 'lax' as const : 'lax' as const, // 'lax' is safer and works on same-domain
|
||||
secure: isSecureEnv,
|
||||
sameSite: isSecureEnv ? 'lax' as const : 'lax' as const, // 'lax' is safer and works on same-domain
|
||||
maxAge: 24 * 60 * 60 * 1000, // 24 hours
|
||||
};
|
||||
|
||||
@ -206,10 +209,13 @@ export class AuthController {
|
||||
|
||||
// Set tokens in httpOnly cookies (production) or return in body (development)
|
||||
const isProduction = process.env.NODE_ENV === 'production';
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
const isSecureEnv = isProduction || isUat;
|
||||
|
||||
const cookieOptions = {
|
||||
httpOnly: true,
|
||||
secure: isProduction,
|
||||
sameSite: isProduction ? ('lax' as const) : ('lax' as const),
|
||||
secure: isSecureEnv,
|
||||
sameSite: isSecureEnv ? ('lax' as const) : ('lax' as const),
|
||||
maxAge: 24 * 60 * 60 * 1000, // 24 hours
|
||||
path: '/',
|
||||
};
|
||||
@ -256,10 +262,13 @@ export class AuthController {
|
||||
|
||||
// Set new access token in cookie
|
||||
const isProduction = process.env.NODE_ENV === 'production';
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
const isSecureEnv = isProduction || isUat;
|
||||
|
||||
const cookieOptions = {
|
||||
httpOnly: true,
|
||||
secure: isProduction,
|
||||
sameSite: isProduction ? ('lax' as const) : ('lax' as const),
|
||||
secure: isSecureEnv,
|
||||
sameSite: isSecureEnv ? ('lax' as const) : ('lax' as const),
|
||||
maxAge: 24 * 60 * 60 * 1000,
|
||||
path: '/',
|
||||
};
|
||||
@ -293,13 +302,16 @@ export class AuthController {
|
||||
|
||||
// Helper function to clear cookies with all possible option combinations
|
||||
const clearCookiesCompletely = () => {
|
||||
const isProduction = process.env.NODE_ENV === 'production';
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
const isSecureEnv = isProduction || isUat;
|
||||
const cookieNames = ['accessToken', 'refreshToken'];
|
||||
|
||||
// Get the EXACT options used when setting cookies (from exchangeToken)
|
||||
// These MUST match exactly: httpOnly, secure, sameSite, path
|
||||
const cookieOptions = {
|
||||
httpOnly: true,
|
||||
secure: isProduction,
|
||||
secure: isSecureEnv,
|
||||
sameSite: 'lax' as const,
|
||||
path: '/',
|
||||
};
|
||||
@ -469,10 +481,13 @@ export class AuthController {
|
||||
|
||||
// Set cookies for web clients
|
||||
const isProduction = process.env.NODE_ENV === 'production';
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
const isSecureEnv = isProduction || isUat;
|
||||
|
||||
const cookieOptions = {
|
||||
httpOnly: true,
|
||||
secure: isProduction,
|
||||
sameSite: isProduction ? 'lax' as const : 'lax' as const,
|
||||
secure: isSecureEnv,
|
||||
sameSite: isSecureEnv ? 'lax' as const : 'lax' as const,
|
||||
maxAge: 24 * 60 * 60 * 1000, // 24 hours
|
||||
};
|
||||
|
||||
@ -549,10 +564,13 @@ export class AuthController {
|
||||
|
||||
// Set cookies with httpOnly flag for security
|
||||
const isProduction = process.env.NODE_ENV === 'production';
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
const isSecureEnv = isProduction || isUat;
|
||||
|
||||
const cookieOptions = {
|
||||
httpOnly: true,
|
||||
secure: isProduction,
|
||||
sameSite: isProduction ? 'lax' as const : 'lax' as const, // 'lax' for same-domain
|
||||
secure: isSecureEnv,
|
||||
sameSite: isSecureEnv ? 'lax' as const : 'lax' as const, // 'lax' for same-domain
|
||||
maxAge: 24 * 60 * 60 * 1000, // 24 hours for access token
|
||||
};
|
||||
|
||||
|
||||
119
src/migrations/20260209-add-gst-and-pwc-fields.ts
Normal file
119
src/migrations/20260209-add-gst-and-pwc-fields.ts
Normal file
@ -0,0 +1,119 @@
|
||||
import { QueryInterface, DataTypes } from 'sequelize';
|
||||
|
||||
/**
|
||||
* Helper function to check if a column exists in a table
|
||||
*/
|
||||
async function columnExists(
|
||||
queryInterface: QueryInterface,
|
||||
tableName: string,
|
||||
columnName: string
|
||||
): Promise<boolean> {
|
||||
try {
|
||||
const tableDescription = await queryInterface.describeTable(tableName);
|
||||
return columnName in tableDescription;
|
||||
} catch (error) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
export async function up(queryInterface: QueryInterface): Promise<void> {
|
||||
// 1. ActivityType
|
||||
const activityCols = {
|
||||
hsn_code: { type: DataTypes.STRING(20), allowNull: true },
|
||||
sac_code: { type: DataTypes.STRING(20), allowNull: true },
|
||||
gst_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
gl_code: { type: DataTypes.STRING(20), allowNull: true },
|
||||
credit_nature: { type: DataTypes.STRING(50), allowNull: true }
|
||||
};
|
||||
|
||||
for (const [col, spec] of Object.entries(activityCols)) {
|
||||
if (!(await columnExists(queryInterface, 'activity_types', col))) {
|
||||
await queryInterface.addColumn('activity_types', col, spec);
|
||||
}
|
||||
}
|
||||
|
||||
// 2. GST Fields mapping for Multiple Tables
|
||||
const gstFields = {
|
||||
gst_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
gst_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
cgst_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
cgst_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
sgst_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
sgst_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
igst_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
igst_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
utgst_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
utgst_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
cess_rate: { type: DataTypes.DECIMAL(5, 2), allowNull: true },
|
||||
cess_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
total_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
};
|
||||
|
||||
const tables = ['dealer_proposal_cost_items', 'dealer_completion_expenses', 'claim_credit_notes'];
|
||||
|
||||
for (const table of tables) {
|
||||
for (const [col, spec] of Object.entries(gstFields)) {
|
||||
if (!(await columnExists(queryInterface, table, col))) {
|
||||
await queryInterface.addColumn(table, col, spec);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Add missing expense_date to DealerCompletionExpense
|
||||
if (!(await columnExists(queryInterface, 'dealer_completion_expenses', 'expense_date'))) {
|
||||
await queryInterface.addColumn('dealer_completion_expenses', 'expense_date', { type: DataTypes.DATEONLY, allowNull: true });
|
||||
}
|
||||
|
||||
// 3. ClaimInvoice
|
||||
const invoiceCols = {
|
||||
irn: { type: DataTypes.STRING(500), allowNull: true },
|
||||
ack_no: { type: DataTypes.STRING(255), allowNull: true },
|
||||
ack_date: { type: DataTypes.DATE, allowNull: true },
|
||||
signed_invoice: { type: DataTypes.TEXT, allowNull: true },
|
||||
signed_invoice_url: { type: DataTypes.STRING(500), allowNull: true },
|
||||
dealer_claim_number: { type: DataTypes.STRING(100), allowNull: true },
|
||||
qr_code: { type: DataTypes.TEXT, allowNull: true },
|
||||
qr_image: { type: DataTypes.TEXT, allowNull: true },
|
||||
dealer_claim_date: { type: DataTypes.DATEONLY, allowNull: true },
|
||||
billing_no: { type: DataTypes.STRING(100), allowNull: true },
|
||||
billing_date: { type: DataTypes.DATEONLY, allowNull: true },
|
||||
taxable_value: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
cgst_total: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
sgst_total: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
igst_total: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
utgst_total: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
cess_total: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
tcs_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
round_off_amt: { type: DataTypes.DECIMAL(15, 2), allowNull: true },
|
||||
place_of_supply: { type: DataTypes.STRING(255), allowNull: true },
|
||||
total_value_in_words: { type: DataTypes.STRING(500), allowNull: true },
|
||||
tax_value_in_words: { type: DataTypes.STRING(500), allowNull: true },
|
||||
credit_nature: { type: DataTypes.STRING(100), allowNull: true },
|
||||
consignor_gsin: { type: DataTypes.STRING(255), allowNull: true },
|
||||
gstin_date: { type: DataTypes.DATEONLY, allowNull: true }
|
||||
};
|
||||
|
||||
for (const [col, spec] of Object.entries(invoiceCols)) {
|
||||
if (!(await columnExists(queryInterface, 'claim_invoices', col))) {
|
||||
await queryInterface.addColumn('claim_invoices', col, spec);
|
||||
}
|
||||
}
|
||||
|
||||
// Ensure file_path exists as 'file_path'
|
||||
try {
|
||||
if (!(await columnExists(queryInterface, 'claim_invoices', 'file_path'))) {
|
||||
if (await columnExists(queryInterface, 'claim_invoices', 'invoice_file_path')) {
|
||||
await queryInterface.renameColumn('claim_invoices', 'invoice_file_path', 'file_path');
|
||||
} else {
|
||||
await queryInterface.addColumn('claim_invoices', 'file_path', { type: DataTypes.STRING(500), allowNull: true });
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
// Silently continue
|
||||
}
|
||||
}
|
||||
|
||||
export async function down(queryInterface: QueryInterface): Promise<void> {
|
||||
// Note: Best effort rollback (usually not recommended to drop columns in shared dev unless necessary)
|
||||
await queryInterface.removeColumn('dealer_completion_expenses', 'expense_date').catch(() => { });
|
||||
}
|
||||
@ -9,6 +9,11 @@ interface ActivityTypeAttributes {
|
||||
taxationType?: string;
|
||||
sapRefNo?: string;
|
||||
isActive: boolean;
|
||||
hsnCode?: string | null;
|
||||
sacCode?: string | null;
|
||||
gstRate?: number | null;
|
||||
glCode?: string | null;
|
||||
creditNature?: 'Commercial' | 'GST' | null;
|
||||
createdBy: string;
|
||||
updatedBy?: string;
|
||||
createdAt: Date;
|
||||
@ -24,6 +29,11 @@ class ActivityType extends Model<ActivityTypeAttributes, ActivityTypeCreationAtt
|
||||
public taxationType?: string;
|
||||
public sapRefNo?: string;
|
||||
public isActive!: boolean;
|
||||
public hsnCode?: string | null;
|
||||
public sacCode?: string | null;
|
||||
public gstRate?: number | null;
|
||||
public glCode?: string | null;
|
||||
public creditNature?: 'Commercial' | 'GST' | null;
|
||||
public createdBy!: string;
|
||||
public updatedBy?: string;
|
||||
public createdAt!: Date;
|
||||
@ -71,6 +81,31 @@ ActivityType.init(
|
||||
defaultValue: true,
|
||||
field: 'is_active'
|
||||
},
|
||||
hsnCode: {
|
||||
type: DataTypes.STRING(20),
|
||||
allowNull: true,
|
||||
field: 'hsn_code'
|
||||
},
|
||||
sacCode: {
|
||||
type: DataTypes.STRING(20),
|
||||
allowNull: true,
|
||||
field: 'sac_code'
|
||||
},
|
||||
gstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'gst_rate'
|
||||
},
|
||||
glCode: {
|
||||
type: DataTypes.STRING(50),
|
||||
allowNull: true,
|
||||
field: 'gl_code'
|
||||
},
|
||||
creditNature: {
|
||||
type: DataTypes.ENUM('Commercial', 'GST'),
|
||||
allowNull: true,
|
||||
field: 'credit_nature'
|
||||
},
|
||||
createdBy: {
|
||||
type: DataTypes.UUID,
|
||||
allowNull: false,
|
||||
|
||||
@ -9,7 +9,20 @@ interface ClaimCreditNoteAttributes {
|
||||
invoiceId?: string;
|
||||
creditNoteNumber?: string;
|
||||
creditNoteDate?: Date;
|
||||
creditNoteAmount?: number;
|
||||
creditNoteAmount: number;
|
||||
gstRate?: number;
|
||||
gstAmt?: number;
|
||||
cgstRate?: number;
|
||||
cgstAmt?: number;
|
||||
sgstRate?: number;
|
||||
sgstAmt?: number;
|
||||
igstRate?: number;
|
||||
igstAmt?: number;
|
||||
utgstRate?: number;
|
||||
utgstAmt?: number;
|
||||
cessRate?: number;
|
||||
cessAmt?: number;
|
||||
totalAmt?: number;
|
||||
sapDocumentNumber?: string;
|
||||
creditNoteFilePath?: string;
|
||||
status?: string;
|
||||
@ -22,7 +35,7 @@ interface ClaimCreditNoteAttributes {
|
||||
updatedAt: Date;
|
||||
}
|
||||
|
||||
interface ClaimCreditNoteCreationAttributes extends Optional<ClaimCreditNoteAttributes, 'creditNoteId' | 'invoiceId' | 'creditNoteNumber' | 'creditNoteDate' | 'creditNoteAmount' | 'sapDocumentNumber' | 'creditNoteFilePath' | 'status' | 'errorMessage' | 'confirmedBy' | 'confirmedAt' | 'reason' | 'description' | 'createdAt' | 'updatedAt'> {}
|
||||
interface ClaimCreditNoteCreationAttributes extends Optional<ClaimCreditNoteAttributes, 'creditNoteId' | 'invoiceId' | 'creditNoteNumber' | 'creditNoteDate' | 'gstRate' | 'gstAmt' | 'cgstRate' | 'cgstAmt' | 'sgstRate' | 'sgstAmt' | 'igstRate' | 'igstAmt' | 'utgstRate' | 'utgstAmt' | 'cessRate' | 'cessAmt' | 'totalAmt' | 'sapDocumentNumber' | 'creditNoteFilePath' | 'status' | 'errorMessage' | 'confirmedBy' | 'confirmedAt' | 'reason' | 'description' | 'createdAt' | 'updatedAt'> { }
|
||||
|
||||
class ClaimCreditNote extends Model<ClaimCreditNoteAttributes, ClaimCreditNoteCreationAttributes> implements ClaimCreditNoteAttributes {
|
||||
public creditNoteId!: string;
|
||||
@ -30,7 +43,20 @@ class ClaimCreditNote extends Model<ClaimCreditNoteAttributes, ClaimCreditNoteCr
|
||||
public invoiceId?: string;
|
||||
public creditNoteNumber?: string;
|
||||
public creditNoteDate?: Date;
|
||||
public creditNoteAmount?: number;
|
||||
public creditNoteAmount!: number;
|
||||
public gstRate?: number;
|
||||
public gstAmt?: number;
|
||||
public cgstRate?: number;
|
||||
public cgstAmt?: number;
|
||||
public sgstRate?: number;
|
||||
public sgstAmt?: number;
|
||||
public igstRate?: number;
|
||||
public igstAmt?: number;
|
||||
public utgstRate?: number;
|
||||
public utgstAmt?: number;
|
||||
public cessRate?: number;
|
||||
public cessAmt?: number;
|
||||
public totalAmt?: number;
|
||||
public sapDocumentNumber?: string;
|
||||
public creditNoteFilePath?: string;
|
||||
public status?: string;
|
||||
@ -86,8 +112,73 @@ ClaimCreditNote.init(
|
||||
},
|
||||
creditNoteAmount: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: false,
|
||||
field: 'credit_amount'
|
||||
},
|
||||
gstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'credit_amount',
|
||||
field: 'gst_rate'
|
||||
},
|
||||
gstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'gst_amt'
|
||||
},
|
||||
cgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_rate'
|
||||
},
|
||||
cgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_amt'
|
||||
},
|
||||
sgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_rate'
|
||||
},
|
||||
sgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_amt'
|
||||
},
|
||||
igstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_rate'
|
||||
},
|
||||
igstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_amt'
|
||||
},
|
||||
utgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_rate'
|
||||
},
|
||||
utgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_amt'
|
||||
},
|
||||
cessRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_rate'
|
||||
},
|
||||
cessAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_amt'
|
||||
},
|
||||
totalAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'total_amt'
|
||||
},
|
||||
sapDocumentNumber: {
|
||||
type: DataTypes.STRING(100),
|
||||
|
||||
@ -6,11 +6,36 @@ interface ClaimInvoiceAttributes {
|
||||
invoiceId: string;
|
||||
requestId: string;
|
||||
invoiceNumber?: string;
|
||||
invoiceDate?: Date;
|
||||
amount?: number;
|
||||
dmsNumber?: string;
|
||||
invoiceFilePath?: string;
|
||||
status?: string;
|
||||
invoiceDate?: Date;
|
||||
amount: number;
|
||||
status: string;
|
||||
irn?: string | null;
|
||||
ackNo?: string | null;
|
||||
ackDate?: Date | null;
|
||||
signedInvoice?: string | null;
|
||||
signedInvoiceUrl?: string | null;
|
||||
dealerClaimNumber?: string | null;
|
||||
dealerClaimDate?: Date | null;
|
||||
billingNo?: string | null;
|
||||
billingDate?: Date | null;
|
||||
taxableValue?: number | null;
|
||||
cgstTotal?: number | null;
|
||||
sgstTotal?: number | null;
|
||||
igstTotal?: number | null;
|
||||
utgstTotal?: number | null;
|
||||
cessTotal?: number | null;
|
||||
tcsAmt?: number | null;
|
||||
roundOffAmt?: number | null;
|
||||
placeOfSupply?: string | null;
|
||||
totalValueInWords?: string | null;
|
||||
taxValueInWords?: string | null;
|
||||
creditNature?: string | null;
|
||||
consignorGsin?: string | null;
|
||||
gstinDate?: Date | null;
|
||||
filePath?: string | null;
|
||||
qrCode?: string | null;
|
||||
qrImage?: string | null;
|
||||
errorMessage?: string;
|
||||
generatedAt?: Date;
|
||||
description?: string;
|
||||
@ -18,17 +43,42 @@ interface ClaimInvoiceAttributes {
|
||||
updatedAt: Date;
|
||||
}
|
||||
|
||||
interface ClaimInvoiceCreationAttributes extends Optional<ClaimInvoiceAttributes, 'invoiceId' | 'invoiceNumber' | 'invoiceDate' | 'amount' | 'dmsNumber' | 'invoiceFilePath' | 'status' | 'errorMessage' | 'generatedAt' | 'description' | 'createdAt' | 'updatedAt'> {}
|
||||
interface ClaimInvoiceCreationAttributes extends Optional<ClaimInvoiceAttributes, 'invoiceId' | 'invoiceNumber' | 'dmsNumber' | 'invoiceDate' | 'irn' | 'ackNo' | 'ackDate' | 'signedInvoice' | 'signedInvoiceUrl' | 'dealerClaimNumber' | 'dealerClaimDate' | 'billingNo' | 'billingDate' | 'taxableValue' | 'cgstTotal' | 'sgstTotal' | 'igstTotal' | 'utgstTotal' | 'cessTotal' | 'tcsAmt' | 'roundOffAmt' | 'placeOfSupply' | 'totalValueInWords' | 'taxValueInWords' | 'creditNature' | 'consignorGsin' | 'gstinDate' | 'filePath' | 'qrCode' | 'qrImage' | 'errorMessage' | 'generatedAt' | 'description' | 'createdAt' | 'updatedAt'> { }
|
||||
|
||||
class ClaimInvoice extends Model<ClaimInvoiceAttributes, ClaimInvoiceCreationAttributes> implements ClaimInvoiceAttributes {
|
||||
public invoiceId!: string;
|
||||
public requestId!: string;
|
||||
public invoiceNumber?: string;
|
||||
public invoiceDate?: Date;
|
||||
public amount?: number;
|
||||
public dmsNumber?: string;
|
||||
public invoiceFilePath?: string;
|
||||
public status?: string;
|
||||
public invoiceDate?: Date;
|
||||
public amount!: number;
|
||||
public status!: string;
|
||||
public irn?: string | null;
|
||||
public ackNo?: string | null;
|
||||
public ackDate?: Date | null;
|
||||
public signedInvoice?: string | null;
|
||||
public signedInvoiceUrl?: string | null;
|
||||
public dealerClaimNumber?: string | null;
|
||||
public dealerClaimDate?: Date | null;
|
||||
public billingNo?: string | null;
|
||||
public billingDate?: Date | null;
|
||||
public taxableValue?: number | null;
|
||||
public cgstTotal?: number | null;
|
||||
public sgstTotal?: number | null;
|
||||
public igstTotal?: number | null;
|
||||
public utgstTotal?: number | null;
|
||||
public cessTotal?: number | null;
|
||||
public tcsAmt?: number | null;
|
||||
public roundOffAmt?: number | null;
|
||||
public placeOfSupply?: string | null;
|
||||
public totalValueInWords?: string | null;
|
||||
public taxValueInWords?: string | null;
|
||||
public creditNature?: string | null;
|
||||
public consignorGsin?: string | null;
|
||||
public gstinDate?: Date | null;
|
||||
public filePath?: string | null;
|
||||
public qrCode?: string | null;
|
||||
public qrImage?: string | null;
|
||||
public errorMessage?: string;
|
||||
public generatedAt?: Date;
|
||||
public description?: string;
|
||||
@ -61,6 +111,11 @@ ClaimInvoice.init(
|
||||
allowNull: true,
|
||||
field: 'invoice_number',
|
||||
},
|
||||
dmsNumber: {
|
||||
type: DataTypes.STRING(100),
|
||||
allowNull: true,
|
||||
field: 'dms_number',
|
||||
},
|
||||
invoiceDate: {
|
||||
type: DataTypes.DATEONLY,
|
||||
allowNull: true,
|
||||
@ -68,23 +123,143 @@ ClaimInvoice.init(
|
||||
},
|
||||
amount: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
allowNull: false,
|
||||
field: 'invoice_amount',
|
||||
},
|
||||
dmsNumber: {
|
||||
type: DataTypes.STRING(100),
|
||||
allowNull: true,
|
||||
field: 'dms_number',
|
||||
},
|
||||
invoiceFilePath: {
|
||||
type: DataTypes.STRING(500),
|
||||
allowNull: true,
|
||||
field: 'invoice_file_path',
|
||||
},
|
||||
status: {
|
||||
type: DataTypes.STRING(50),
|
||||
allowNull: false,
|
||||
defaultValue: 'PENDING',
|
||||
field: 'generation_status'
|
||||
},
|
||||
irn: {
|
||||
type: DataTypes.STRING(500),
|
||||
allowNull: true
|
||||
},
|
||||
ackNo: {
|
||||
type: DataTypes.STRING(255),
|
||||
allowNull: true,
|
||||
field: 'generation_status',
|
||||
field: 'ack_no'
|
||||
},
|
||||
ackDate: {
|
||||
type: DataTypes.DATE,
|
||||
allowNull: true,
|
||||
field: 'ack_date'
|
||||
},
|
||||
signedInvoice: {
|
||||
type: DataTypes.TEXT,
|
||||
allowNull: true,
|
||||
field: 'signed_invoice'
|
||||
},
|
||||
signedInvoiceUrl: {
|
||||
type: DataTypes.STRING(500),
|
||||
allowNull: true,
|
||||
field: 'signed_invoice_url'
|
||||
},
|
||||
dealerClaimNumber: {
|
||||
type: DataTypes.STRING(100),
|
||||
allowNull: true,
|
||||
field: 'dealer_claim_number'
|
||||
},
|
||||
dealerClaimDate: {
|
||||
type: DataTypes.DATEONLY,
|
||||
allowNull: true,
|
||||
field: 'dealer_claim_date'
|
||||
},
|
||||
billingNo: {
|
||||
type: DataTypes.STRING(100),
|
||||
allowNull: true,
|
||||
field: 'billing_no'
|
||||
},
|
||||
billingDate: {
|
||||
type: DataTypes.DATEONLY,
|
||||
allowNull: true,
|
||||
field: 'billing_date'
|
||||
},
|
||||
taxableValue: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'taxable_value'
|
||||
},
|
||||
cgstTotal: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_total'
|
||||
},
|
||||
sgstTotal: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_total'
|
||||
},
|
||||
igstTotal: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_total'
|
||||
},
|
||||
utgstTotal: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_total'
|
||||
},
|
||||
cessTotal: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_total'
|
||||
},
|
||||
tcsAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'tcs_amt'
|
||||
},
|
||||
roundOffAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'round_off_amt'
|
||||
},
|
||||
placeOfSupply: {
|
||||
type: DataTypes.STRING(255),
|
||||
allowNull: true,
|
||||
field: 'place_of_supply'
|
||||
},
|
||||
totalValueInWords: {
|
||||
type: DataTypes.STRING(500),
|
||||
allowNull: true,
|
||||
field: 'total_value_in_words'
|
||||
},
|
||||
taxValueInWords: {
|
||||
type: DataTypes.STRING(500),
|
||||
allowNull: true,
|
||||
field: 'tax_value_in_words'
|
||||
},
|
||||
creditNature: {
|
||||
type: DataTypes.STRING(100),
|
||||
allowNull: true,
|
||||
field: 'credit_nature'
|
||||
},
|
||||
consignorGsin: {
|
||||
type: DataTypes.STRING(255),
|
||||
allowNull: true,
|
||||
field: 'consignor_gsin'
|
||||
},
|
||||
gstinDate: {
|
||||
type: DataTypes.DATEONLY,
|
||||
allowNull: true,
|
||||
field: 'gstin_date'
|
||||
},
|
||||
filePath: {
|
||||
type: DataTypes.STRING(500),
|
||||
allowNull: true,
|
||||
field: 'file_path'
|
||||
},
|
||||
qrCode: {
|
||||
type: DataTypes.TEXT,
|
||||
allowNull: true,
|
||||
field: 'qr_code'
|
||||
},
|
||||
qrImage: {
|
||||
type: DataTypes.TEXT,
|
||||
allowNull: true,
|
||||
field: 'qr_image'
|
||||
},
|
||||
errorMessage: {
|
||||
type: DataTypes.TEXT,
|
||||
|
||||
@ -9,6 +9,20 @@ interface DealerCompletionExpenseAttributes {
|
||||
completionId?: string | null;
|
||||
description: string;
|
||||
amount: number;
|
||||
gstRate?: number;
|
||||
gstAmt?: number;
|
||||
cgstRate?: number;
|
||||
cgstAmt?: number;
|
||||
sgstRate?: number;
|
||||
sgstAmt?: number;
|
||||
igstRate?: number;
|
||||
igstAmt?: number;
|
||||
utgstRate?: number;
|
||||
utgstAmt?: number;
|
||||
cessRate?: number;
|
||||
cessAmt?: number;
|
||||
totalAmt?: number;
|
||||
expenseDate: Date;
|
||||
createdAt: Date;
|
||||
updatedAt: Date;
|
||||
}
|
||||
@ -21,6 +35,20 @@ class DealerCompletionExpense extends Model<DealerCompletionExpenseAttributes, D
|
||||
public completionId?: string | null;
|
||||
public description!: string;
|
||||
public amount!: number;
|
||||
public gstRate?: number;
|
||||
public gstAmt?: number;
|
||||
public cgstRate?: number;
|
||||
public cgstAmt?: number;
|
||||
public sgstRate?: number;
|
||||
public sgstAmt?: number;
|
||||
public igstRate?: number;
|
||||
public igstAmt?: number;
|
||||
public utgstRate?: number;
|
||||
public utgstAmt?: number;
|
||||
public cessRate?: number;
|
||||
public cessAmt?: number;
|
||||
public totalAmt?: number;
|
||||
public expenseDate!: Date;
|
||||
public createdAt!: Date;
|
||||
public updatedAt!: Date;
|
||||
}
|
||||
@ -63,6 +91,76 @@ DealerCompletionExpense.init(
|
||||
allowNull: false,
|
||||
field: 'amount',
|
||||
},
|
||||
gstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'gst_rate'
|
||||
},
|
||||
gstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'gst_amt'
|
||||
},
|
||||
cgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_rate'
|
||||
},
|
||||
cgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_amt'
|
||||
},
|
||||
sgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_rate'
|
||||
},
|
||||
sgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_amt'
|
||||
},
|
||||
igstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_rate'
|
||||
},
|
||||
igstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_amt'
|
||||
},
|
||||
utgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_rate'
|
||||
},
|
||||
utgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_amt'
|
||||
},
|
||||
cessRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_rate'
|
||||
},
|
||||
cessAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_amt'
|
||||
},
|
||||
totalAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'total_amt'
|
||||
},
|
||||
expenseDate: {
|
||||
type: DataTypes.DATE,
|
||||
allowNull: false,
|
||||
field: 'expense_date',
|
||||
},
|
||||
createdAt: {
|
||||
type: DataTypes.DATE,
|
||||
allowNull: false,
|
||||
|
||||
@ -9,6 +9,19 @@ interface DealerProposalCostItemAttributes {
|
||||
requestId: string;
|
||||
itemDescription: string;
|
||||
amount: number;
|
||||
gstRate?: number;
|
||||
gstAmt?: number;
|
||||
cgstRate?: number;
|
||||
cgstAmt?: number;
|
||||
sgstRate?: number;
|
||||
sgstAmt?: number;
|
||||
igstRate?: number;
|
||||
igstAmt?: number;
|
||||
utgstRate?: number;
|
||||
utgstAmt?: number;
|
||||
cessRate?: number;
|
||||
cessAmt?: number;
|
||||
totalAmt?: number;
|
||||
itemOrder: number;
|
||||
createdAt: Date;
|
||||
updatedAt: Date;
|
||||
@ -22,6 +35,19 @@ class DealerProposalCostItem extends Model<DealerProposalCostItemAttributes, Dea
|
||||
public requestId!: string;
|
||||
public itemDescription!: string;
|
||||
public amount!: number;
|
||||
public gstRate?: number;
|
||||
public gstAmt?: number;
|
||||
public cgstRate?: number;
|
||||
public cgstAmt?: number;
|
||||
public sgstRate?: number;
|
||||
public sgstAmt?: number;
|
||||
public igstRate?: number;
|
||||
public igstAmt?: number;
|
||||
public utgstRate?: number;
|
||||
public utgstAmt?: number;
|
||||
public cessRate?: number;
|
||||
public cessAmt?: number;
|
||||
public totalAmt?: number;
|
||||
public itemOrder!: number;
|
||||
public createdAt!: Date;
|
||||
public updatedAt!: Date;
|
||||
@ -66,6 +92,71 @@ DealerProposalCostItem.init(
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: false
|
||||
},
|
||||
gstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'gst_rate'
|
||||
},
|
||||
gstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'gst_amt'
|
||||
},
|
||||
cgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_rate'
|
||||
},
|
||||
cgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cgst_amt'
|
||||
},
|
||||
sgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_rate'
|
||||
},
|
||||
sgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'sgst_amt'
|
||||
},
|
||||
igstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_rate'
|
||||
},
|
||||
igstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'igst_amt'
|
||||
},
|
||||
utgstRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_rate'
|
||||
},
|
||||
utgstAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'utgst_amt'
|
||||
},
|
||||
cessRate: {
|
||||
type: DataTypes.DECIMAL(5, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_rate'
|
||||
},
|
||||
cessAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'cess_amt'
|
||||
},
|
||||
totalAmt: {
|
||||
type: DataTypes.DECIMAL(15, 2),
|
||||
allowNull: true,
|
||||
field: 'total_amt'
|
||||
},
|
||||
itemOrder: {
|
||||
type: DataTypes.INTEGER,
|
||||
allowNull: false,
|
||||
|
||||
@ -10,25 +10,42 @@
|
||||
* 5. Configs are auto-seeded by configSeed.service.ts on server start (30 configs)
|
||||
*/
|
||||
|
||||
import fs from 'fs';
|
||||
import path from 'path';
|
||||
import dotenv from 'dotenv';
|
||||
|
||||
// 1. Initialize dotenv FIRST before any other internal imports
|
||||
// This ensures that modules imported later (like GoogleSecretManagerService)
|
||||
// can see the environment variables in their constructor/initialization
|
||||
const envPath = path.resolve(process.cwd(), '.env');
|
||||
if (fs.existsSync(envPath)) {
|
||||
dotenv.config({ path: envPath });
|
||||
} else {
|
||||
const parentEnvPath = path.resolve(process.cwd(), '..', '.env');
|
||||
if (fs.existsSync(parentEnvPath)) {
|
||||
dotenv.config({ path: parentEnvPath });
|
||||
}
|
||||
}
|
||||
|
||||
// 2. Now import internal modules
|
||||
import { Client } from 'pg';
|
||||
import { QueryTypes } from 'sequelize';
|
||||
import { initializeGoogleSecretManager } from '../services/googleSecretManager.service';
|
||||
import { exec } from 'child_process';
|
||||
import { promisify } from 'util';
|
||||
import dotenv from 'dotenv';
|
||||
import path from 'path';
|
||||
|
||||
dotenv.config({ path: path.resolve(__dirname, '../../.env') });
|
||||
|
||||
const execAsync = promisify(exec);
|
||||
|
||||
async function checkAndCreateDatabase(): Promise<boolean> {
|
||||
// DB constants moved inside functions to ensure secrets are loaded first
|
||||
const isSSL = (process.env.DB_SSL || '').trim() === 'true';
|
||||
async function checkAndCreateDatabase(): Promise<boolean> {
|
||||
const DB_HOST = process.env.DB_HOST || 'localhost';
|
||||
const DB_PORT = parseInt(process.env.DB_PORT || '5432');
|
||||
const DB_USER = process.env.DB_USER || 'postgres';
|
||||
const DB_PASSWORD = process.env.DB_PASSWORD || '';
|
||||
const DB_NAME = process.env.DB_NAME || 'royal_enfield_workflow';
|
||||
const DB_PASSWORD = typeof process.env.DB_PASSWORD === 'string' ? process.env.DB_PASSWORD : '';
|
||||
const DB_NAME = process.env.DB_NAME || 're_workflow_db';
|
||||
|
||||
console.log(`[Setup Debug] DB_HOST: ${DB_HOST}, DB_USER: ${DB_USER}, SSL: ${isSSL}, HasPassword: ${!!DB_PASSWORD}`);
|
||||
|
||||
const client = new Client({
|
||||
host: DB_HOST,
|
||||
@ -140,6 +157,7 @@ async function runMigrations(): Promise<void> {
|
||||
const m42 = require('../migrations/20250125-create-activity-types');
|
||||
const m43 = require('../migrations/20260113-redesign-dealer-claim-history');
|
||||
const m44 = require('../migrations/20260123-fix-template-id-schema');
|
||||
const m45 = require('../migrations/20260209-add-gst-and-pwc-fields');
|
||||
|
||||
const migrations = [
|
||||
{ name: '2025103000-create-users', module: m0 },
|
||||
@ -189,6 +207,7 @@ async function runMigrations(): Promise<void> {
|
||||
{ name: '20250125-create-activity-types', module: m42 },
|
||||
{ name: '20260113-redesign-dealer-claim-history', module: m43 },
|
||||
{ name: '20260123-fix-template-id-schema', module: m44 },
|
||||
{ name: '20260209-add-gst-and-pwc-fields', module: m45 },
|
||||
];
|
||||
|
||||
// Dynamically import sequelize after secrets are loaded
|
||||
|
||||
@ -47,6 +47,7 @@ import * as m41 from '../migrations/20250120-create-dealers-table';
|
||||
import * as m42 from '../migrations/20250125-create-activity-types';
|
||||
import * as m43 from '../migrations/20260113-redesign-dealer-claim-history';
|
||||
import * as m44 from '../migrations/20260123-fix-template-id-schema';
|
||||
import * as m45 from '../migrations/20260209-add-gst-and-pwc-fields';
|
||||
|
||||
interface Migration {
|
||||
name: string;
|
||||
@ -108,6 +109,7 @@ const migrations: Migration[] = [
|
||||
{ name: '20250125-create-activity-types', module: m42 },
|
||||
{ name: '20260113-redesign-dealer-claim-history', module: m43 },
|
||||
{ name: '20260123-fix-template-id-schema', module: m44 },
|
||||
{ name: '20260209-add-gst-and-pwc-fields', module: m45 }
|
||||
];
|
||||
|
||||
/**
|
||||
|
||||
@ -4,13 +4,10 @@ import path from 'path';
|
||||
|
||||
// Load environment variables from .env file FIRST
|
||||
dotenv.config({ path: path.resolve(__dirname, '../.env') });
|
||||
import { initializeGoogleSecretManager } from './services/googleSecretManager.service';
|
||||
import { seedDefaultActivityTypes } from './services/activityTypeSeed.service';
|
||||
// Stop queue metrics collection on shutdown
|
||||
// Note: This is imported statically but doesn't trigger database/queue activity until called
|
||||
import { stopQueueMetrics } from './utils/queueMetrics';
|
||||
|
||||
// Dynamic imports will be used inside startServer to ensure secrets are loaded first
|
||||
import { emailService } from './services/email.service';
|
||||
|
||||
const PORT: number = parseInt(process.env.PORT || '5000', 10);
|
||||
|
||||
// Start server
|
||||
@ -18,12 +15,16 @@ const startServer = async (): Promise<void> => {
|
||||
try {
|
||||
// Initialize Google Secret Manager before starting server
|
||||
// This will merge secrets from GCS into process.env if enabled
|
||||
const { initializeGoogleSecretManager } = require('./services/googleSecretManager.service');
|
||||
console.log('🔐 Initializing secrets...');
|
||||
await initializeGoogleSecretManager();
|
||||
|
||||
// Dynamically import everything else after secrets are loaded
|
||||
const app = require('./app').default;
|
||||
const { default: app, initializeAppDatabase } = require('./app');
|
||||
const { initSocket } = require('./realtime/socket');
|
||||
|
||||
// Initialize database connection explicitly after secrets are loaded
|
||||
await initializeAppDatabase();
|
||||
|
||||
require('./queues/tatWorker'); // Initialize TAT worker
|
||||
const { logTatConfig } = require('./config/tat.config');
|
||||
const { logSystemConfig } = require('./config/system.config');
|
||||
@ -34,22 +35,12 @@ const startServer = async (): Promise<void> => {
|
||||
const { initializeQueueMetrics } = require('./utils/queueMetrics');
|
||||
const { emailService } = require('./services/email.service');
|
||||
|
||||
// Re-initialize email service after secrets are loaded (in case SMTP credentials were loaded)
|
||||
// This ensures the email service uses production SMTP if credentials are available
|
||||
// Initialize email service after secrets are loaded
|
||||
try {
|
||||
await emailService.initialize();
|
||||
console.log('📧 Email service re-initialized after secrets loaded');
|
||||
console.log('📧 Email service initialized');
|
||||
} catch (error) {
|
||||
console.warn('⚠️ Email service re-initialization warning (will use test account if SMTP not configured):', error);
|
||||
}
|
||||
|
||||
// Re-initialize email service after secrets are loaded (in case SMTP credentials were loaded)
|
||||
// This ensures the email service uses production SMTP if credentials are available
|
||||
try {
|
||||
await emailService.initialize();
|
||||
console.log('📧 Email service re-initialized after secrets loaded');
|
||||
} catch (error) {
|
||||
console.warn('⚠️ Email service re-initialization warning (will use test account if SMTP not configured):', error);
|
||||
console.warn('⚠️ Email service initialization warning (will use test account if SMTP not configured):', error);
|
||||
}
|
||||
|
||||
const server = http.createServer(app);
|
||||
@ -63,6 +54,7 @@ const startServer = async (): Promise<void> => {
|
||||
}
|
||||
|
||||
// Seed default activity types if table is empty
|
||||
const { seedDefaultActivityTypes } = require('./services/activityTypeSeed.service');
|
||||
try {
|
||||
await seedDefaultActivityTypes();
|
||||
} catch (error) {
|
||||
|
||||
@ -247,3 +247,42 @@ export async function searchDealers(searchTerm: string, limit: number = 10): Pro
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Find dealer in local table by code or email (tiered lookup)
|
||||
* Used as a fallback until external API is available
|
||||
* @param dealerCode - Optional dealer code (dlrcode)
|
||||
* @param email - Optional email (domainId or dealerPrincipalEmailId)
|
||||
*/
|
||||
export async function findDealerLocally(dealerCode?: string, email?: string): Promise<DealerInfo | null> {
|
||||
try {
|
||||
// 1. Try Lookup by Dealer Code
|
||||
if (dealerCode) {
|
||||
const dealer = await getDealerByCode(dealerCode);
|
||||
if (dealer) return dealer;
|
||||
}
|
||||
|
||||
// 2. Try Lookup by Email (checks both domainId and dealerPrincipalEmailId)
|
||||
if (email) {
|
||||
const dealer = await Dealer.findOne({
|
||||
where: {
|
||||
[Op.or]: [
|
||||
{ domainId: { [Op.iLike]: email.toLowerCase() } as any },
|
||||
{ dealerPrincipalEmailId: { [Op.iLike]: email.toLowerCase() } as any }
|
||||
],
|
||||
isActive: true
|
||||
}
|
||||
});
|
||||
|
||||
if (dealer) {
|
||||
// reuse same logic as getDealerByEmail for consistency
|
||||
return getDealerByEmail(dealer.domainId || dealer.dealerPrincipalEmailId || email);
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
} catch (error) {
|
||||
logger.error('[DealerService] Error in local dealer fallback lookup:', error);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -18,12 +18,16 @@ import { DealerClaimApprovalService } from './dealerClaimApproval.service';
|
||||
import { generateRequestNumber } from '../utils/helpers';
|
||||
import { Priority, WorkflowStatus, ApprovalStatus, ParticipantType } from '../types/common.types';
|
||||
import { sapIntegrationService } from './sapIntegration.service';
|
||||
import { dmsIntegrationService } from './dmsIntegration.service';
|
||||
import { pwcIntegrationService } from './pwcIntegration.service';
|
||||
import { notificationService } from './notification.service';
|
||||
import { activityService } from './activity.service';
|
||||
import { UserService } from './user.service';
|
||||
import { dmsIntegrationService } from './dmsIntegration.service';
|
||||
import { findDealerLocally } from './dealer.service';
|
||||
import logger from '../utils/logger';
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Dealer Claim Service
|
||||
* Handles business logic specific to dealer claim management workflow
|
||||
@ -83,6 +87,15 @@ export class DealerClaimService {
|
||||
throw new Error('Initiator not found');
|
||||
}
|
||||
|
||||
// Fallback: Enrichment from local dealer table if data is missing or incomplete
|
||||
const localDealer = await findDealerLocally(claimData.dealerCode, claimData.dealerEmail);
|
||||
if (localDealer) {
|
||||
logger.info(`[DealerClaimService] Enriched claim request with local dealer data: ${localDealer.dealerCode}`);
|
||||
claimData.dealerName = claimData.dealerName || localDealer.dealerName;
|
||||
claimData.dealerEmail = claimData.dealerEmail || localDealer.dealerPrincipalEmailId || localDealer.email;
|
||||
claimData.dealerPhone = claimData.dealerPhone || localDealer.phone;
|
||||
}
|
||||
|
||||
// Validate approvers array is provided
|
||||
if (!claimData.approvers || !Array.isArray(claimData.approvers) || claimData.approvers.length === 0) {
|
||||
throw new Error('Approvers array is required. Please assign approvers for all workflow steps.');
|
||||
@ -1260,6 +1273,19 @@ export class DealerClaimService {
|
||||
requestId,
|
||||
itemDescription: item.description || item.itemDescription || '',
|
||||
amount: Number(item.amount) || 0,
|
||||
gstRate: Number(item.gstRate) || 0,
|
||||
gstAmt: Number(item.gstAmt) || 0,
|
||||
cgstRate: Number(item.cgstRate) || 0,
|
||||
cgstAmt: Number(item.cgstAmt) || 0,
|
||||
sgstRate: Number(item.sgstRate) || 0,
|
||||
sgstAmt: Number(item.sgstAmt) || 0,
|
||||
igstRate: Number(item.igstRate) || 0,
|
||||
igstAmt: Number(item.igstAmt) || 0,
|
||||
utgstRate: Number(item.utgstRate) || 0,
|
||||
utgstAmt: Number(item.utgstAmt) || 0,
|
||||
cessRate: Number(item.cessRate) || 0,
|
||||
cessAmt: Number(item.cessAmt) || 0,
|
||||
totalAmt: Number(item.totalAmt) || Number(item.amount) || 0,
|
||||
itemOrder: index
|
||||
}));
|
||||
|
||||
@ -1397,7 +1423,21 @@ export class DealerClaimService {
|
||||
requestId,
|
||||
completionId,
|
||||
description: item.description,
|
||||
amount: item.amount,
|
||||
amount: Number(item.amount) || 0,
|
||||
gstRate: Number(item.gstRate) || 0,
|
||||
gstAmt: Number(item.gstAmt) || 0,
|
||||
cgstRate: Number(item.cgstRate) || 0,
|
||||
cgstAmt: Number(item.cgstAmt) || 0,
|
||||
sgstRate: Number(item.sgstRate) || 0,
|
||||
sgstAmt: Number(item.sgstAmt) || 0,
|
||||
igstRate: Number(item.igstRate) || 0,
|
||||
igstAmt: Number(item.igstAmt) || 0,
|
||||
utgstRate: Number(item.utgstRate) || 0,
|
||||
utgstAmt: Number(item.utgstAmt) || 0,
|
||||
cessRate: Number(item.cessRate) || 0,
|
||||
cessAmt: Number(item.cessAmt) || 0,
|
||||
totalAmt: Number(item.totalAmt) || Number(item.amount) || 0,
|
||||
expenseDate: item.date instanceof Date ? item.date : (item.date ? new Date(item.date) : (completionData.activityCompletionDate || new Date())),
|
||||
}));
|
||||
await DealerCompletionExpense.bulkCreate(expenseRows);
|
||||
}
|
||||
@ -1874,33 +1914,31 @@ export class DealerClaimService {
|
||||
|| budgetTracking?.initialEstimatedBudget
|
||||
|| 0;
|
||||
|
||||
const invoiceResult = await dmsIntegrationService.generateEInvoice({
|
||||
requestNumber,
|
||||
dealerCode: claimDetails.dealerCode,
|
||||
dealerName: claimDetails.dealerName,
|
||||
amount: invoiceAmount,
|
||||
description: invoiceData?.description || `E-Invoice for claim request ${requestNumber}`,
|
||||
ioNumber: internalOrder?.ioNumber || undefined,
|
||||
});
|
||||
const invoiceResult = await pwcIntegrationService.generateSignedInvoice(requestId);
|
||||
|
||||
if (!invoiceResult.success) {
|
||||
throw new Error(`Failed to generate e-invoice: ${invoiceResult.error}`);
|
||||
throw new Error(`Failed to generate signed e-invoice via PWC: ${invoiceResult.error}`);
|
||||
}
|
||||
|
||||
await ClaimInvoice.upsert({
|
||||
requestId,
|
||||
invoiceNumber: invoiceResult.eInvoiceNumber,
|
||||
invoiceDate: invoiceResult.invoiceDate || new Date(),
|
||||
dmsNumber: invoiceResult.dmsNumber,
|
||||
invoiceNumber: invoiceResult.ackNo, // Using Ack No as primary identifier for now
|
||||
invoiceDate: invoiceResult.ackDate instanceof Date ? invoiceResult.ackDate : (invoiceResult.ackDate ? new Date(invoiceResult.ackDate) : new Date()),
|
||||
irn: invoiceResult.irn,
|
||||
ackNo: invoiceResult.ackNo,
|
||||
ackDate: invoiceResult.ackDate instanceof Date ? invoiceResult.ackDate : (invoiceResult.ackDate ? new Date(invoiceResult.ackDate) : null),
|
||||
signedInvoice: invoiceResult.signedInvoice,
|
||||
qrCode: invoiceResult.qrCode,
|
||||
qrImage: invoiceResult.qrImage,
|
||||
amount: invoiceAmount,
|
||||
status: 'GENERATED',
|
||||
generatedAt: new Date(),
|
||||
description: invoiceData?.description || `E-Invoice for claim request ${requestNumber}`,
|
||||
description: invoiceData?.description || `PWC Signed Invoice for claim request ${requestNumber}`,
|
||||
});
|
||||
|
||||
logger.info(`[DealerClaimService] E-Invoice generated via DMS for request: ${requestId}`, {
|
||||
eInvoiceNumber: invoiceResult.eInvoiceNumber,
|
||||
dmsNumber: invoiceResult.dmsNumber
|
||||
logger.info(`[DealerClaimService] Signed Invoice generated via PWC for request: ${requestId}`, {
|
||||
ackNo: invoiceResult.ackNo,
|
||||
irn: invoiceResult.irn
|
||||
});
|
||||
} else {
|
||||
// Manual entry - just update the fields
|
||||
@ -1909,7 +1947,7 @@ export class DealerClaimService {
|
||||
invoiceNumber: invoiceData.eInvoiceNumber,
|
||||
invoiceDate: invoiceData.eInvoiceDate || new Date(),
|
||||
dmsNumber: invoiceData.dmsNumber,
|
||||
amount: invoiceData.amount,
|
||||
amount: Number(invoiceData.amount) || 0,
|
||||
status: 'UPDATED',
|
||||
generatedAt: new Date(),
|
||||
description: invoiceData.description,
|
||||
@ -2067,7 +2105,7 @@ export class DealerClaimService {
|
||||
invoiceId: claimInvoice.invoiceId,
|
||||
creditNoteNumber: creditNoteResult.creditNoteNumber,
|
||||
creditNoteDate: creditNoteResult.creditNoteDate || new Date(),
|
||||
creditNoteAmount: creditNoteResult.creditNoteAmount,
|
||||
creditNoteAmount: Number(creditNoteResult.creditNoteAmount) || 0,
|
||||
status: 'GENERATED',
|
||||
confirmedAt: new Date(),
|
||||
reason: creditNoteData?.reason || 'Claim settlement',
|
||||
@ -2100,7 +2138,7 @@ export class DealerClaimService {
|
||||
invoiceId: claimInvoice?.invoiceId || undefined, // Allow undefined if no invoice
|
||||
creditNoteNumber: creditNoteData.creditNoteNumber,
|
||||
creditNoteDate: creditNoteData.creditNoteDate || new Date(),
|
||||
creditNoteAmount: creditNoteData.creditNoteAmount,
|
||||
creditNoteAmount: Number(creditNoteData.creditNoteAmount) || 0,
|
||||
status: 'UPDATED',
|
||||
confirmedAt: new Date(),
|
||||
reason: creditNoteData?.reason,
|
||||
|
||||
@ -119,7 +119,7 @@ export class DMSWebhookService {
|
||||
amount: payload.total_amount || payload.claim_amount,
|
||||
status: 'GENERATED',
|
||||
generatedAt: new Date(),
|
||||
invoiceFilePath: payload.invoice_file_path || null,
|
||||
filePath: payload.invoice_file_path || null,
|
||||
errorMessage: payload.error_message || null,
|
||||
description: this.buildInvoiceDescription(payload),
|
||||
});
|
||||
@ -137,7 +137,7 @@ export class DMSWebhookService {
|
||||
amount: payload.total_amount || payload.claim_amount,
|
||||
status: 'GENERATED',
|
||||
generatedAt: new Date(),
|
||||
invoiceFilePath: payload.invoice_file_path || null,
|
||||
filePath: payload.invoice_file_path || null,
|
||||
errorMessage: payload.error_message || null,
|
||||
// Store additional DMS data in description or separate fields if needed
|
||||
description: this.buildInvoiceDescription(payload),
|
||||
|
||||
@ -264,10 +264,6 @@ export class EmailService {
|
||||
// Singleton instance
|
||||
export const emailService = new EmailService();
|
||||
|
||||
// Initialize on import (will use test account if SMTP not configured)
|
||||
// Note: If secrets are loaded later, the service will re-initialize automatically
|
||||
// when sendEmail is called (if SMTP credentials become available)
|
||||
emailService.initialize().catch(error => {
|
||||
logger.error('Failed to initialize email service:', error);
|
||||
});
|
||||
// Note: initialize() is now called explicitly in server.ts
|
||||
// to ensure it happens after secrets are loaded.
|
||||
|
||||
|
||||
@ -30,6 +30,7 @@ class GoogleSecretManagerService {
|
||||
private secretPrefix: string;
|
||||
private secretMap: Record<string, string> = {};
|
||||
private isInitialized: boolean = false;
|
||||
private isLoaded: boolean = false;
|
||||
|
||||
constructor() {
|
||||
this.projectId = process.env.GCP_PROJECT_ID || '';
|
||||
@ -206,6 +207,15 @@ class GoogleSecretManagerService {
|
||||
return;
|
||||
}
|
||||
|
||||
if (this.isLoaded && !secretNames) {
|
||||
logger.debug('[Secret Manager] ℹ️ Secrets already loaded in this process, skipping.');
|
||||
return;
|
||||
}
|
||||
|
||||
if (!this.projectId) {
|
||||
this.projectId = process.env.GCP_PROJECT_ID || '';
|
||||
}
|
||||
|
||||
if (!this.projectId) {
|
||||
logger.warn('[Secret Manager] GCP_PROJECT_ID not set, skipping Google Secret Manager');
|
||||
return;
|
||||
@ -237,33 +247,40 @@ class GoogleSecretManagerService {
|
||||
}
|
||||
|
||||
// Load each secret
|
||||
for (const secretName of secretsToLoad) {
|
||||
const fullSecretName = this.secretPrefix
|
||||
? `${this.secretPrefix}-${secretName}`
|
||||
: secretName;
|
||||
const uatSecrets = ['OKTA_CLIENT_ID', 'OKTA_CLIENT_SECRET', 'OKTA_API_TOKEN', 'OKTA_DOMAIN', 'DB_PASSWORD'];
|
||||
const isUat = process.env.NODE_ENV === 'uat';
|
||||
|
||||
// Log OKTA and EMAIL secret attempts in detail
|
||||
const isOktaSecret = /^OKTA_/i.test(secretName);
|
||||
const isEmailSecret = /^EMAIL_|^SMTP_/i.test(secretName);
|
||||
if (isOktaSecret || isEmailSecret) {
|
||||
logger.info(`[Secret Manager] Attempting to load: ${secretName} (full name: ${fullSecretName})`);
|
||||
for (const secretName of secretsToLoad) {
|
||||
// Handle UAT-specific secret names if in UAT environment
|
||||
let secretNameToFetch = secretName;
|
||||
if (isUat && uatSecrets.includes(secretName)) {
|
||||
secretNameToFetch = `${secretName}_UAT`;
|
||||
logger.info(`[Secret Manager] UAT mode: Fetching source ${secretNameToFetch} for ${secretName}`);
|
||||
}
|
||||
|
||||
const secretValue = await this.getSecret(secretName);
|
||||
const fullSecretName = this.secretPrefix
|
||||
? `${this.secretPrefix}-${secretNameToFetch}`
|
||||
: secretNameToFetch;
|
||||
|
||||
const rawValue = await this.getSecret(secretNameToFetch);
|
||||
const secretValue = rawValue ? rawValue.trim() : null;
|
||||
|
||||
if (secretValue !== null) {
|
||||
const envVarName = this.getEnvVarName(secretName);
|
||||
loadedSecrets[envVarName] = secretValue;
|
||||
loadedCount++;
|
||||
if (isOktaSecret || isEmailSecret) {
|
||||
logger.info(`[Secret Manager] ✅ Successfully loaded: ${secretName} -> ${envVarName}`);
|
||||
}
|
||||
|
||||
// Print masked value for verification as requested by user
|
||||
// Note: Trailing/leading whitespace is now trimmed to prevent auth errors
|
||||
const maskedValue = secretValue.length > 8
|
||||
? `${secretValue.substring(0, 3)}...${secretValue.substring(secretValue.length - 3)}`
|
||||
: '***';
|
||||
|
||||
logger.info(`[Secret Manager] ✅ Loaded: ${secretNameToFetch} -> process.env.${envVarName} (Value: ${maskedValue})`);
|
||||
} else {
|
||||
// Track which secrets weren't found for better logging
|
||||
notFoundSecrets.push(fullSecretName);
|
||||
if (isOktaSecret || isEmailSecret) {
|
||||
logger.warn(`[Secret Manager] ❌ Not found: ${secretName} (searched as: ${fullSecretName})`);
|
||||
}
|
||||
logger.warn(`[Secret Manager] ❌ Not found: ${secretNameToFetch} (searched as: ${fullSecretName})`);
|
||||
}
|
||||
}
|
||||
|
||||
@ -271,18 +288,18 @@ class GoogleSecretManagerService {
|
||||
// Log when overriding existing env vars vs setting new ones
|
||||
for (const [envVar, value] of Object.entries(loadedSecrets)) {
|
||||
const existingValue = process.env[envVar];
|
||||
const isOverriding = existingValue !== undefined;
|
||||
const isAlreadySet = existingValue !== undefined && existingValue !== '';
|
||||
|
||||
if (isAlreadySet) {
|
||||
logger.debug(`[Secret Manager] ℹ️ Skipping ${envVar}: Already set in local environment`);
|
||||
continue;
|
||||
}
|
||||
|
||||
process.env[envVar] = value;
|
||||
|
||||
// Log override behavior for debugging
|
||||
if (isOverriding) {
|
||||
logger.debug(`[Secret Manager] 🔄 Overrode existing env var: ${envVar} (was: ${existingValue ? 'set' : 'undefined'}, now: from Secret Manager)`);
|
||||
} else {
|
||||
logger.debug(`[Secret Manager] ✨ Set new env var: ${envVar} (from Secret Manager)`);
|
||||
}
|
||||
}
|
||||
|
||||
this.isLoaded = true;
|
||||
logger.info(`[Secret Manager] ✅ Successfully loaded ${loadedCount}/${secretsToLoad.length} secrets`);
|
||||
|
||||
if (loadedCount > 0) {
|
||||
@ -345,9 +362,10 @@ class GoogleSecretManagerService {
|
||||
'SESSION_SECRET',
|
||||
|
||||
// Okta/SSO
|
||||
//'OKTA_CLIENT_ID',
|
||||
//'OKTA_CLIENT_SECRET',
|
||||
//'OKTA_API_TOKEN',
|
||||
'OKTA_CLIENT_ID',
|
||||
'OKTA_CLIENT_SECRET',
|
||||
'OKTA_API_TOKEN',
|
||||
'OKTA_DOMAIN',
|
||||
|
||||
// Email
|
||||
'SMTP_HOST',
|
||||
|
||||
171
src/services/pwcIntegration.service.ts
Normal file
171
src/services/pwcIntegration.service.ts
Normal file
@ -0,0 +1,171 @@
|
||||
import axios from 'axios';
|
||||
import logger from '../utils/logger';
|
||||
import { Dealer } from '../models/Dealer';
|
||||
import { ActivityType } from '../models/ActivityType';
|
||||
import { WorkflowRequest } from '../models/WorkflowRequest';
|
||||
import { ClaimInvoice } from '../models/ClaimInvoice';
|
||||
import { InternalOrder } from '../models/InternalOrder';
|
||||
|
||||
/**
|
||||
* PWC E-Invoice Integration Service
|
||||
* Handles communication with PWC API for signed invoice generation
|
||||
*/
|
||||
export class PWCIntegrationService {
|
||||
private apiUrl: string;
|
||||
private appKey: string;
|
||||
private appSecret: string;
|
||||
|
||||
constructor() {
|
||||
this.apiUrl = process.env.PWC_API_URL || 'https://api.qa.einvoice.aw.navigatetax.pwc.co.in';
|
||||
this.appKey = process.env.PWC_APP_KEY || '';
|
||||
this.appSecret = process.env.PWC_APP_SECRET || '';
|
||||
}
|
||||
|
||||
/**
|
||||
* Resolve GL Code based on Activity Type and Internal Order
|
||||
*/
|
||||
private async resolveGLCode(activityTypeId: string, ioNumber?: string): Promise<string> {
|
||||
const activity = await ActivityType.findByPk(activityTypeId);
|
||||
if (activity?.glCode) {
|
||||
return activity.glCode;
|
||||
}
|
||||
|
||||
// Default Fallback or IO based logic if required
|
||||
// Based on "IO GL will be changed" comment in user screenshot
|
||||
if (ioNumber) {
|
||||
const io = await InternalOrder.findOne({ where: { ioNumber } });
|
||||
// Logic to derive GL from IO if needed
|
||||
}
|
||||
|
||||
return '610000'; // Default placeholder
|
||||
}
|
||||
|
||||
/**
|
||||
* Generate Signed Invoice via PWC API
|
||||
*/
|
||||
async generateSignedInvoice(requestId: string): Promise<{
|
||||
success: boolean;
|
||||
irn?: string;
|
||||
ackNo?: string;
|
||||
ackDate?: Date | string;
|
||||
signedInvoice?: string;
|
||||
qrCode?: string;
|
||||
qrImage?: string;
|
||||
error?: string;
|
||||
}> {
|
||||
try {
|
||||
const request = await WorkflowRequest.findByPk(requestId, {
|
||||
include: ['claimDetails', 'initiator']
|
||||
});
|
||||
|
||||
if (!request) return { success: false, error: 'Request not found' };
|
||||
|
||||
const dealer = await Dealer.findOne({ where: { dlrcode: (request as any).claimDetails?.dealerCode } });
|
||||
const activity = await ActivityType.findOne({ where: { title: (request as any).claimDetails?.activityType } });
|
||||
|
||||
if (!dealer || !activity) {
|
||||
return { success: false, error: 'Dealer or Activity details missing' };
|
||||
}
|
||||
|
||||
// Construct PWC Payload (keeping existing logic for now)
|
||||
const payload = {
|
||||
UserGstin: "33AAACE3882D1ZZ",
|
||||
DocDtls: {
|
||||
Typ: "INV",
|
||||
No: `INV-${Date.now()}`,
|
||||
Dt: new Date().toLocaleDateString('en-GB').replace(/\//g, '-')
|
||||
},
|
||||
SellerDtls: {
|
||||
Gstin: dealer.gst || "33AAACE3882D1ZZ",
|
||||
LglNm: dealer.dealership || 'Dealer',
|
||||
Addr1: dealer.showroomAddress || "Address Line 1",
|
||||
Loc: dealer.location || "Location",
|
||||
Pin: 600001,
|
||||
Stcd: "33"
|
||||
},
|
||||
BuyerDtls: {
|
||||
Gstin: "33AAACE3882D1ZZ",
|
||||
LglNm: "ROYAL ENFIELD (A UNIT OF EICHER MOTORS LTD)",
|
||||
Addr1: "No. 2, Thiruvottiyur High Road",
|
||||
Loc: "Thiruvottiyur",
|
||||
Pin: 600019,
|
||||
Stcd: "33",
|
||||
Pos: "33"
|
||||
},
|
||||
ItemList: [
|
||||
{
|
||||
SlNo: "1",
|
||||
PrdDesc: activity.title,
|
||||
IsServc: "Y",
|
||||
HsnCd: activity.hsnCode || activity.sacCode || "9983",
|
||||
Qty: 1,
|
||||
Unit: "OTH",
|
||||
UnitPrce: (request as any).amount,
|
||||
TotAmt: (request as any).amount,
|
||||
GstRt: activity.gstRate || 18,
|
||||
AssAmt: (request as any).amount,
|
||||
IgstAmt: activity.gstRate === 18 ? ((request as any).amount * 0.18) : 0,
|
||||
TotItemVal: (request as any).amount * 1.18
|
||||
}
|
||||
],
|
||||
ValDtls: {
|
||||
AssVal: (request as any).amount,
|
||||
IgstVal: activity.gstRate === 18 ? ((request as any).amount * 0.18) : 0,
|
||||
TotInvVal: (request as any).amount * 1.18
|
||||
}
|
||||
};
|
||||
|
||||
logger.info(`[PWC] Sending e-invoice request for ${request.requestNumber}`);
|
||||
|
||||
const response = await axios.post(`${this.apiUrl}/generate`, payload, {
|
||||
headers: { 'AppKey': this.appKey, 'AppSecret': this.appSecret }
|
||||
});
|
||||
|
||||
// Parse PWC Response based on provided structure
|
||||
// Sample response is an array: [{ pwc_response, irp_response, qr_b64_encoded }]
|
||||
const responseData = Array.isArray(response.data) ? response.data[0] : response.data;
|
||||
const irpData = responseData?.irp_response?.data;
|
||||
const nicData = irpData?.nic_response_data;
|
||||
const qrB64 = responseData?.qr_b64_encoded;
|
||||
|
||||
let irn = nicData?.Irn;
|
||||
let ackNo = nicData?.AckNo;
|
||||
let ackDate = nicData?.AckDt;
|
||||
let signedInvoice = nicData?.SignedInvoice;
|
||||
let qrCode = nicData?.SignedQRCode;
|
||||
|
||||
// Handle Duplicate IRN Case
|
||||
if (!irn && irpData?.InfoDtls) {
|
||||
const dupInfo = irpData.InfoDtls.find((info: any) => info.InfCd === 'DUPIRN');
|
||||
if (dupInfo?.Desc) {
|
||||
irn = dupInfo.Desc.Irn;
|
||||
ackNo = dupInfo.Desc.AckNo;
|
||||
ackDate = dupInfo.Desc.AckDt;
|
||||
logger.info(`[PWC] Handled duplicate IRN for ${request.requestNumber}: ${irn}`);
|
||||
}
|
||||
}
|
||||
|
||||
if (!irn) {
|
||||
const errorMsg = responseData?.irp_response?.message || 'E-Invoice generation failed';
|
||||
logger.error(`[PWC] E-Invoice failed for ${request.requestNumber}: ${errorMsg}`);
|
||||
return { success: false, error: errorMsg };
|
||||
}
|
||||
|
||||
return {
|
||||
success: true,
|
||||
irn,
|
||||
ackNo: String(ackNo),
|
||||
ackDate: ackDate ? new Date(ackDate) : undefined,
|
||||
signedInvoice,
|
||||
qrCode,
|
||||
qrImage: qrB64
|
||||
};
|
||||
|
||||
} catch (error) {
|
||||
logger.error('[PWC] Error generating e-invoice:', error);
|
||||
return { success: false, error: error instanceof Error ? error.message : 'Unknown error' };
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
export const pwcIntegrationService = new PWCIntegrationService();
|
||||
@ -124,12 +124,12 @@ if (process.env.LOKI_HOST) {
|
||||
}
|
||||
}
|
||||
|
||||
// ============ CONSOLE TRANSPORT (Development) ============
|
||||
if (!isProduction) {
|
||||
// ============ CONSOLE TRANSPORT ============
|
||||
// Enabled for all environments to ensure visibility in terminal/container logs
|
||||
transports.push(
|
||||
new winston.transports.Console({
|
||||
format: winston.format.combine(
|
||||
winston.format.colorize(),
|
||||
winston.format.colorize({ all: !isProduction }),
|
||||
winston.format.printf(({ level, message, timestamp, ...meta }) => {
|
||||
const metaStr = Object.keys(meta).length && !meta.service
|
||||
? ` ${JSON.stringify(meta)}`
|
||||
@ -139,7 +139,6 @@ if (!isProduction) {
|
||||
),
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
// ============ ERROR SANITIZER ============
|
||||
/**
|
||||
|
||||
@ -2,7 +2,9 @@
|
||||
"compilerOptions": {
|
||||
"target": "ES2021",
|
||||
"module": "commonjs",
|
||||
"lib": ["ES2021"],
|
||||
"lib": [
|
||||
"ES2021"
|
||||
],
|
||||
"outDir": "./dist",
|
||||
"rootDir": "./src",
|
||||
"strict": true,
|
||||
@ -21,39 +23,50 @@
|
||||
"noUnusedParameters": false,
|
||||
"noImplicitReturns": true,
|
||||
"noFallthroughCasesInSwitch": true,
|
||||
"types": ["node", "jest"],
|
||||
"typeRoots": ["./node_modules/@types", "./src/types"],
|
||||
"types": [
|
||||
"node",
|
||||
"jest"
|
||||
],
|
||||
"typeRoots": [
|
||||
"./node_modules/@types",
|
||||
"./src/types"
|
||||
],
|
||||
"baseUrl": "./src",
|
||||
"paths": {
|
||||
"@/*": ["./*"],
|
||||
"@controllers/*": ["./controllers/*"],
|
||||
"@middlewares/*": ["./middlewares/*"],
|
||||
"@services/*": ["./services/*"],
|
||||
"@models/*": ["./models/*"],
|
||||
"@routes/*": ["./routes/*"],
|
||||
"@validators/*": ["./validators/*"],
|
||||
"@utils/*": ["./utils/*"],
|
||||
"@types/*": ["./types/*"],
|
||||
"@config/*": ["./config/*"]
|
||||
"@/*": [
|
||||
"./*"
|
||||
],
|
||||
"@controllers/*": [
|
||||
"./controllers/*"
|
||||
],
|
||||
"@middlewares/*": [
|
||||
"./middlewares/*"
|
||||
],
|
||||
"@services/*": [
|
||||
"./services/*"
|
||||
],
|
||||
"@models/*": [
|
||||
"./models/*"
|
||||
],
|
||||
"@routes/*": [
|
||||
"./routes/*"
|
||||
],
|
||||
"@validators/*": [
|
||||
"./validators/*"
|
||||
],
|
||||
"@utils/*": [
|
||||
"./utils/*"
|
||||
],
|
||||
"@types/*": [
|
||||
"./types/*"
|
||||
],
|
||||
"@config/*": [
|
||||
"./config/*"
|
||||
]
|
||||
}
|
||||
},
|
||||
"include": [
|
||||
"src/app.ts",
|
||||
"src/server.ts",
|
||||
"src/routes/index.ts",
|
||||
"src/routes/auth.routes.ts",
|
||||
"src/controllers/auth.controller.ts",
|
||||
"src/services/auth.service.ts",
|
||||
"src/middlewares/auth.middleware.ts",
|
||||
"src/middlewares/cors.middleware.ts",
|
||||
"src/middlewares/validate.middleware.ts",
|
||||
"src/middlewares/errorHandler.middleware.ts",
|
||||
"src/utils/logger.ts",
|
||||
"src/utils/responseHandler.ts",
|
||||
"src/config/**/*",
|
||||
"src/types/**/*",
|
||||
"src/validators/auth.validator.ts",
|
||||
"src/models/**/*"
|
||||
"src/**/*"
|
||||
],
|
||||
"exclude": [
|
||||
"node_modules",
|
||||
@ -61,10 +74,6 @@
|
||||
"tests",
|
||||
"**/*.test.ts",
|
||||
"**/*.spec.ts",
|
||||
"src/routes/workflow.routes.ts",
|
||||
"src/controllers/workflow.controller.ts",
|
||||
"src/controllers/approval.controller.ts",
|
||||
"src/services/workflow.service.ts",
|
||||
"src/services/approval.service.ts"
|
||||
"src/services/enhancedTemplate.service.ts"
|
||||
]
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user