106 lines
2.7 KiB
JavaScript
106 lines
2.7 KiB
JavaScript
|
'use strict';
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* stockModel.js
|
|||
|
|
* Stok hareketleri veri katmanı — JSON dosya depolama.
|
|||
|
|
* Her giriş/çıkış hareketini log'lar; ürün güncellemesi productModel'e bırakılır.
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
const fs = require('fs');
|
|||
|
|
const path = require('path');
|
|||
|
|
|
|||
|
|
const DATA_DIR = path.join(__dirname, '..', 'data');
|
|||
|
|
const FILE_PATH = path.join(DATA_DIR, 'stockMovements.json');
|
|||
|
|
|
|||
|
|
function ensureDir() {
|
|||
|
|
if (!fs.existsSync(DATA_DIR)) {
|
|||
|
|
fs.mkdirSync(DATA_DIR, { recursive: true });
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Tüm hareket kayıtlarını okur.
|
|||
|
|
* @returns {Array} hareket listesi
|
|||
|
|
*/
|
|||
|
|
function readMovements() {
|
|||
|
|
try {
|
|||
|
|
ensureDir();
|
|||
|
|
if (!fs.existsSync(FILE_PATH)) return [];
|
|||
|
|
const raw = fs.readFileSync(FILE_PATH, 'utf8');
|
|||
|
|
const data = JSON.parse(raw);
|
|||
|
|
return Array.isArray(data) ? data : [];
|
|||
|
|
} catch (err) {
|
|||
|
|
console.error('Stok hareket dosyası okunamadı:', err.message);
|
|||
|
|
return [];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Hareket listesini yazar.
|
|||
|
|
* @param {Array} movements hareket listesi
|
|||
|
|
*/
|
|||
|
|
function writeMovements(movements) {
|
|||
|
|
ensureDir();
|
|||
|
|
fs.writeFileSync(FILE_PATH, JSON.stringify(movements, null, 2), 'utf8');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Sonraki hareket ID'si.
|
|||
|
|
* @param {Array} movements hareket listesi
|
|||
|
|
* @returns {number} yeni id
|
|||
|
|
*/
|
|||
|
|
function _nextId(movements) {
|
|||
|
|
if (!movements.length) return 1;
|
|||
|
|
return Math.max(...movements.map((m) => Number(m.id) || 0)) + 1;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Yeni stok hareketi oluşturur ve kaydeder.
|
|||
|
|
* @param {Object} params {productId, type, quantity, note, remainingStock}
|
|||
|
|
* @returns {Object} hareket kaydı
|
|||
|
|
*/
|
|||
|
|
function addMovement({ productId, type, quantity, note, remainingStock }) {
|
|||
|
|
const movements = readMovements();
|
|||
|
|
const movement = {
|
|||
|
|
id: _nextId(movements),
|
|||
|
|
productId: Number(productId),
|
|||
|
|
type: type === 'in' || type === 'out' ? type : 'in',
|
|||
|
|
quantity: Number(quantity) || 0,
|
|||
|
|
note: note ? String(note).trim() : '',
|
|||
|
|
remainingStock: Number(remainingStock) !== undefined ? Number(remainingStock) : 0,
|
|||
|
|
date: new Date().toISOString()
|
|||
|
|
};
|
|||
|
|
movements.push(movement);
|
|||
|
|
writeMovements(movements);
|
|||
|
|
return movement;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Ürüne ait hareketleri tarih sıralı getirir (eski→yeni).
|
|||
|
|
* @param {number} productId ürün ID
|
|||
|
|
* @returns {Array} hareket listesi
|
|||
|
|
*/
|
|||
|
|
function getByProduct(productId) {
|
|||
|
|
const movements = readMovements();
|
|||
|
|
return movements
|
|||
|
|
.filter((m) => m.productId === Number(productId))
|
|||
|
|
.sort((a, b) => new Date(a.date) - new Date(b.date));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Tüm hareketleri en yeni üstte getirir.
|
|||
|
|
* @returns {Array} hareket listesi
|
|||
|
|
*/
|
|||
|
|
function getAll() {
|
|||
|
|
const movements = readMovements();
|
|||
|
|
return movements.sort((a, b) => new Date(b.date) - new Date(a.date));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
module.exports = {
|
|||
|
|
readMovements,
|
|||
|
|
addMovement,
|
|||
|
|
getByProduct,
|
|||
|
|
getAll,
|
|||
|
|
_nextId
|
|||
|
|
};
|