Upload 13 files

src/db/ca.pem

@@ -0,0 +1,26 @@
+-----BEGIN CERTIFICATE-----
+MIIEUDCCArigAwIBAgIUfwNzc0s5wNLad9xuTq9aKHnTIckwDQYJKoZIhvcNAQEM
+BQAwQDE+MDwGA1UEAww1ODg2NWZlZTEtOTIyMy00MTMxLWIwNjItYWJlNDg5YWMw
+ZTFmIEdFTiAxIFByb2plY3QgQ0EwHhcNMjUxMTI2MTMwMjIzWhcNMzUxMTI0MTMw
+MjIzWjBAMT4wPAYDVQQDDDU4ODY1ZmVlMS05MjIzLTQxMzEtYjA2Mi1hYmU0ODlh
+YzBlMWYgR0VOIDEgUHJvamVjdCBDQTCCAaIwDQYJKoZIhvcNAQEBBQADggGPADCC
+AYoCggGBALXpJK142iOT6sCj2zc820av/G8Yr69U9oowbRuMBH+fot0Brz3IxxZz
+4Eb+g3OGfbytvz2A39W4Gf7vM1qzYTpvQeb3I1WEp6ECJIxixPpeAwVr5FYCMPgw
+Tp3hg6BOnMUFHmS10942WzHWpx8JajZFLYeFtk1VgR7cxqMZ1UEKZlc6SrA8HBqM
+ok3E0VvgA1jw0iiJtPG7NTEI5G5HOJ10sFttpf1KdhqWiwVqG1tRpRTwQpVDKvU4
+JEvBCAonZ2gxp2rf/11KOOEgS3Rk9KzCHNYJ4zcg+9ipcpwyaD5hNWQKxO0XLoIj
+bJaXPcevfHXebad1dVD+3+sJYaTLNRaIuRs6AYm7/c0OxaetLplyzyafsw0mZAp/
+ZswnS8XvOUuqKJke2QR3zpJSOZQ9qbHygziDgg3erLO0s/EimVj/j6QPZoUjKXkJ
+8dWoiF7kkF+USynIEEKN87VRHbi+lepuC32TgXdPGyuN2cmrg1mtS9Y/jDqUlfl8
+ElmfFTRbPwIDAQABo0IwQDAdBgNVHQ4EFgQUWWJ7i7Zro8zA4tEwfzNQpF9+IP4w
+EgYDVR0TAQH/BAgwBgEB/wIBADALBgNVHQ8EBAMCAQYwDQYJKoZIhvcNAQEMBQAD
+ggGBAFYTDm036bi/0vOtLEP9jqDc51SMF1rWKf7Gy/wKsUTO9j7egEayy/lpvhKd
+DY8ioyeBHtREMZ7RmOah165OnzQa6/gvfXQG78MSyo16HIBK/VrICK1gGVNPp/u5
+wWx6wZ1fN709xKO7Q+nbYoCbxmlY+3BJq5xfvxcN7YFtTtEV5MSVUB76r7Mb+flk
+fq+0HjTpUEV/VmEncKrQaN345L0v/b6gxUjiQjHdi9McDybM1x2JV0dqea3ZXySU
+Igx168r1IQuiKTHvHTzibAEllulYj598YBtMeXaBnOEZm3JUkPBuyFpW2j/CyJQ9
+9y0UfOZkLqwDA3G5xatR6TAcGH7eByDrVqEKWXg1fgIJ7fmMijWyzXelLiOX0agl
+pa43TlAP5KZfeR3GOtFfNAhiW448LhpZvKGi2q75G71uTopKtK2EdOuzjYJZCXxA
+YU0EkC3KrKl/jzVOgvHz8kc+HWj5khW/pm6knWstpb3AUg7nD151ejVQuIuI8oJJ
+rwCc8g==
+-----END CERTIFICATE-----

src/routes/lots.js

@@ -75,4 +75,44 @@ router.get('/mirchi/:mirchiTypeId', async (req, res) => {
     }
 });
 
+// POST check if lot number is unique
+router.post('/check-unique', async (req, res) => {
+    try {
+        const { lot_number } = req.body;
+
+        if (!lot_number) {
+            return res.status(400).json({ success: false, message: 'Lot number is required' });
+        }
+
+        const result = await pool.query(
+            'SELECT id FROM lots WHERE lot_number = $1',
+            [lot_number]
+        );
+
+        res.json({ exists: result.rows.length > 0 });
+    } catch (error) {
+        console.error('Error checking lot uniqueness:', error);
+        res.status(500).json({ success: false, message: error.message });
+    }
+});
+
+// GET available lots for a mirchi type (with remaining quantity > 0)
+router.get('/available/:mirchiTypeId', async (req, res) => {
+    try {
+        const { mirchiTypeId } = req.params;
+        const result = await pool.query(
+            `SELECT * FROM lots 
+       WHERE mirchi_type_id = $1 
+       AND status = 'active' 
+       AND remaining_quantity > 0 
+       ORDER BY purchase_date DESC`,
+            [mirchiTypeId]
+        );
+        res.json(result.rows);
+    } catch (error) {
+        console.error('Error fetching available lots:', error);
+        res.status(500).json({ success: false, message: error.message });
+    }
+});
+
 module.exports = router;

src/routes/transactions.js

@@ -16,6 +16,7 @@ router.get('/', async (req, res) => {
                'mirchi_name', ti.mirchi_name,
                'quality', ti.quality,
                'lot_id', ti.lot_id,
+               'lot_number', l.lot_number,
                'poti_weights', ti.poti_weights,
                'gross_weight', ti.gross_weight,
                'poti_count', ti.poti_count,
@@ -44,6 +45,7 @@ router.get('/', async (req, res) => {
              )) FILTER (WHERE p.id IS NOT NULL) as payments
       FROM transactions t
       LEFT JOIN transaction_items ti ON t.id = ti.transaction_id
+      LEFT JOIN lots l ON ti.lot_id = l.id
       LEFT JOIN expenses e ON t.id = e.transaction_id
       LEFT JOIN payments p ON t.id = p.transaction_id
     `;
@@ -97,6 +99,7 @@ router.get('/:id', async (req, res) => {
                'mirchi_name', ti.mirchi_name,
                'quality', ti.quality,
                'lot_id', ti.lot_id,
+               'lot_number', l.lot_number,
                'poti_weights', ti.poti_weights,
                'gross_weight', ti.gross_weight,
                'poti_count', ti.poti_count,
@@ -125,6 +128,7 @@ router.get('/:id', async (req, res) => {
              )) FILTER (WHERE p.id IS NOT NULL) as payments
       FROM transactions t
       LEFT JOIN transaction_items ti ON t.id = ti.transaction_id
+      LEFT JOIN lots l ON ti.lot_id = l.id
       LEFT JOIN expenses e ON t.id = e.transaction_id
       LEFT JOIN payments p ON t.id = p.transaction_id
       WHERE t.id = $1
@@ -283,47 +287,100 @@ router.post('/', async (req, res) => {
         }
 
         // 6. Update lots (stock management)
-        if (bill_type === 'jawaak' && !is_return) {
-            // Purchase: Create new lots
+        // AWAAK = Purchase (Stock IN), JAWAAK = Sale (Stock OUT)
+        if (bill_type === 'awaak' && !is_return) {
+            // Purchase: Create new lots or update existing ones
             for (let i = 0; i < items.length; i++) {
                 const item = items[i];
                 const mirchi = await client.query('SELECT name FROM mirchi_types WHERE id = $1', [item.mirchi_type_id]);
                 const mirchiName = mirchi.rows[0]?.name || 'Unknown';
 
-                const lotId = uuidv4();
-                const lotNumber = `LOT-${mirchiName.substring(0, 3).toUpperCase()}-${bill_date.replace(/-/g, '')}-${Date.now()}`;
+                // Check if lot_number is provided (user-entered or selected existing)
+                if (item.lot_number) {
+                    // Check if lot already exists
+                    const existingLot = await client.query(
+                        'SELECT id FROM lots WHERE lot_number = $1',
+                        [item.lot_number]
+                    );
 
-                await client.query(
-                    `INSERT INTO lots (id, lot_number, mirchi_type_id, mirchi_name, total_quantity, remaining_quantity, purchase_date, status, avg_rate)
-           VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)`,
-                    [lotId, lotNumber, item.mirchi_type_id, mirchiName, item.net_weight, item.net_weight, bill_date, 'active', item.rate_per_kg]
-                );
-            }
-        } else if (bill_type === 'awaak') {
-            // Sales: Update lot quantities
-            for (const item of items) {
-                if (item.lot_id) {
-                    if (is_return) {
-                        // Sales return: Add stock back
+                    if (existingLot.rows.length > 0) {
+                        // Update existing lot - add stock
+                        const lotId = existingLot.rows[0].id;
                         await client.query(
                             `UPDATE lots 
-               SET remaining_quantity = remaining_quantity + $1, 
-                   status = CASE WHEN remaining_quantity + $1 > 0 THEN 'active' ELSE status END
-               WHERE id = $2`,
-                            [item.net_weight, item.lot_id]
+                             SET total_quantity = total_quantity + $1,
+                                 remaining_quantity = remaining_quantity + $1,
+                                 status = 'active',
+                                 updated_at = CURRENT_TIMESTAMP
+                             WHERE id = $2`,
+                            [item.net_weight, lotId]
+                        );
+
+                        // Update item with lot_id
+                        await client.query(
+                            'UPDATE transaction_items SET lot_id = $1 WHERE id = $2',
+                            [lotId, item.id || uuidv4()]
                         );
                     } else {
-                        // Regular sale: Reduce stock
+                        // Create new lot with user-provided lot_number
+                        const lotId = uuidv4();
                         await client.query(
-                            `UPDATE lots 
-               SET remaining_quantity = remaining_quantity - $1,
-                   status = CASE WHEN remaining_quantity - $1 <= 0 THEN 'sold_out' ELSE 'active' END
-               WHERE id = $2`,
-                            [item.net_weight, item.lot_id]
+                            `INSERT INTO lots (id, lot_number, mirchi_type_id, mirchi_name, total_quantity, remaining_quantity, purchase_date, status, avg_rate)
+                             VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)`,
+                            [lotId, item.lot_number, item.mirchi_type_id, mirchiName, item.net_weight, item.net_weight, bill_date, 'active', item.rate_per_kg]
+                        );
+
+                        // Update item with lot_id
+                        await client.query(
+                            'UPDATE transaction_items SET lot_id = $1 WHERE id = $2',
+                            [lotId, item.id || uuidv4()]
                         );
                     }
                 }
             }
+        } else if (bill_type === 'awaak' && is_return) {
+            // Purchase Return: Reduce stock from lots
+            for (const item of items) {
+                if (item.lot_id) {
+                    await client.query(
+                        `UPDATE lots 
+                         SET total_quantity = total_quantity - $1,
+                             remaining_quantity = remaining_quantity - $1,
+                             status = CASE WHEN remaining_quantity - $1 <= 0 THEN 'sold_out' ELSE 'active' END,
+                             updated_at = CURRENT_TIMESTAMP
+                         WHERE id = $2`,
+                        [item.net_weight, item.lot_id]
+                    );
+                }
+            }
+        } else if (bill_type === 'jawaak' && !is_return) {
+            // Sale: Reduce stock from selected lots
+            for (const item of items) {
+                if (item.lot_id) {
+                    await client.query(
+                        `UPDATE lots 
+                         SET remaining_quantity = remaining_quantity - $1,
+                             status = CASE WHEN remaining_quantity - $1 <= 0 THEN 'sold_out' ELSE 'active' END,
+                             updated_at = CURRENT_TIMESTAMP
+                         WHERE id = $2`,
+                        [item.net_weight, item.lot_id]
+                    );
+                }
+            }
+        } else if (bill_type === 'jawaak' && is_return) {
+            // Sales Return: Add stock back to lots
+            for (const item of items) {
+                if (item.lot_id) {
+                    await client.query(
+                        `UPDATE lots 
+                         SET remaining_quantity = remaining_quantity + $1,
+                             status = CASE WHEN remaining_quantity + $1 > 0 THEN 'active' ELSE status END,
+                             updated_at = CURRENT_TIMESTAMP
+                         WHERE id = $2`,
+                        [item.net_weight, item.lot_id]
+                    );
+                }
+            }
         }
 
         await client.query('COMMIT');
@@ -337,6 +394,7 @@ router.post('/', async (req, res) => {
                      'mirchi_name', ti.mirchi_name,
                      'quality', ti.quality,
                      'lot_id', ti.lot_id,
+                     'lot_number', l.lot_number,
                      'poti_weights', ti.poti_weights,
                      'gross_weight', ti.gross_weight,
                      'poti_count', ti.poti_count,
@@ -365,6 +423,7 @@ router.post('/', async (req, res) => {
                    )) FILTER (WHERE p.id IS NOT NULL) as payments
             FROM transactions t
             LEFT JOIN transaction_items ti ON t.id = ti.transaction_id
+            LEFT JOIN lots l ON ti.lot_id = l.id
             LEFT JOIN expenses e ON t.id = e.transaction_id
             LEFT JOIN payments p ON t.id = p.transaction_id
             WHERE t.id = $1

src/server.js

@@ -1,73 +1,73 @@
-const express = require('express');
-const cors = require('cors');
-require('dotenv').config();
-
-const partiesRouter = require('./routes/parties');
-const mirchiTypesRouter = require('./routes/mirchiTypes');
-const lotsRouter = require('./routes/lots');
-const transactionsRouter = require('./routes/transactions');
-
-const app = express();
-const PORT = process.env.PORT || 7860; // Hugging Face default port
-
-// Middleware
-app.use(cors());
-app.use(express.json());
-app.use(express.urlencoded({ extended: true }));
-
-// Request logging
-app.use((req, res, next) => {
-    console.log(`${new Date().toISOString()} - ${req.method} ${req.path}`);
-    next();
-});
-
-// Routes
-app.use('/api/parties', partiesRouter);
-app.use('/api/mirchi-types', mirchiTypesRouter);
-app.use('/api/lots', lotsRouter);
-app.use('/api/transactions', transactionsRouter);
-
-// Health check
-app.get('/health', (req, res) => {
-    res.json({ status: 'ok', timestamp: new Date().toISOString() });
-});
-
-// Root endpoint
-app.get('/', (req, res) => {
-    res.json({
-        message: 'Pattanshetty Inventory Management API',
-        version: '1.0.0',
-        endpoints: {
-            parties: '/api/parties',
-            mirchiTypes: '/api/mirchi-types',
-            lots: '/api/lots',
-            transactions: '/api/transactions'
-        }
-    });
-});
-
-// Error handling middleware
-app.use((err, req, res, next) => {
-    console.error('Error:', err);
-    res.status(500).json({
-        success: false,
-        message: err.message || 'Internal server error'
-    });
-});
-
-// 404 handler
-app.use((req, res) => {
-    res.status(404).json({
-        success: false,
-        message: 'Route not found'
-    });
-});
-
-// Start server
-app.listen(PORT, () => {
-    console.log(`🚀 Server running on port ${PORT}`);
-    console.log(`📍 API available at http://localhost:${PORT}`);
-    console.log(`💚 Health check: http://localhost:${PORT}/health`);
-});
-
-module.exports = app;
+const express = require('express');
+const cors = require('cors');
+require('dotenv').config();
+
+const partiesRouter = require('./routes/parties');
+const mirchiTypesRouter = require('./routes/mirchiTypes');
+const lotsRouter = require('./routes/lots');
+const transactionsRouter = require('./routes/transactions');
+
+const app = express();
+const PORT = process.env.PORT || 4000;
+
+// Middleware
+app.use(cors());
+app.use(express.json());
+app.use(express.urlencoded({ extended: true }));
+
+// Request logging
+app.use((req, res, next) => {
+    console.log(`${new Date().toISOString()} - ${req.method} ${req.path}`);
+    next();
+});
+
+// Routes
+app.use('/api/parties', partiesRouter);
+app.use('/api/mirchi-types', mirchiTypesRouter);
+app.use('/api/lots', lotsRouter);
+app.use('/api/transactions', transactionsRouter);
+
+// Health check
+app.get('/health', (req, res) => {
+    res.json({ status: 'ok', timestamp: new Date().toISOString() });
+});
+
+// Root endpoint
+app.get('/', (req, res) => {
+    res.json({
+        message: 'Pattanshetty Inventory Management API',
+        version: '1.0.0',
+        endpoints: {
+            parties: '/api/parties',
+            mirchiTypes: '/api/mirchi-types',
+            lots: '/api/lots',
+            transactions: '/api/transactions'
+        }
+    });
+});
+
+// Error handling middleware
+app.use((err, req, res, next) => {
+    console.error('Error:', err);
+    res.status(500).json({
+        success: false,
+        message: err.message || 'Internal server error'
+    });
+});
+
+// 404 handler
+app.use((req, res) => {
+    res.status(404).json({
+        success: false,
+        message: 'Route not found'
+    });
+});
+
+// Start server
+app.listen(PORT, () => {
+    console.log(`🚀 Server running on port ${PORT}`);
+    console.log(`📍 API available at http://localhost:${PORT}`);
+    console.log(`💚 Health check: http://localhost:${PORT}/health`);
+});
+
+module.exports = app;