diff --git a/system1-factory/api/config/routes.js b/system1-factory/api/config/routes.js index 1b1594a..59348fc 100644 --- a/system1-factory/api/config/routes.js +++ b/system1-factory/api/config/routes.js @@ -52,6 +52,9 @@ function setupRoutes(app) { const patrolRoutes = require('../routes/patrolRoutes'); const notificationRoutes = require('../routes/notificationRoutes'); const pushSubscriptionRoutes = require('../routes/pushSubscriptionRoutes'); + const purchaseRequestRoutes = require('../routes/purchaseRequestRoutes'); + const purchaseRoutes = require('../routes/purchaseRoutes'); + const settlementRoutes = require('../routes/settlementRoutes'); // Rate Limiters 설정 const rateLimit = require('express-rate-limit'); @@ -161,6 +164,9 @@ function setupRoutes(app) { app.use('/api/patrol', patrolRoutes); // 일일순회점검 시스템 app.use('/api/notifications', notificationRoutes); // 알림 시스템 app.use('/api/push', pushSubscriptionRoutes); // Push 구독 + app.use('/api/purchase-requests', purchaseRequestRoutes); // 구매신청 + app.use('/api/purchases', purchaseRoutes); // 구매 내역 + app.use('/api/settlements', settlementRoutes); // 월간 정산 app.use('/api', uploadBgRoutes); // Swagger API 문서 diff --git a/system1-factory/api/controllers/purchaseController.js b/system1-factory/api/controllers/purchaseController.js new file mode 100644 index 0000000..8ec722d --- /dev/null +++ b/system1-factory/api/controllers/purchaseController.js @@ -0,0 +1,104 @@ +const PurchaseModel = require('../models/purchaseModel'); +const PurchaseRequestModel = require('../models/purchaseRequestModel'); +const logger = require('../utils/logger'); + +const PurchaseController = { + // 구매 처리 (신청 → 구매) + create: async (req, res) => { + try { + const { request_id, item_id, vendor_id, quantity, unit_price, purchase_date, update_base_price, notes } = req.body; + + if (!item_id) return res.status(400).json({ success: false, message: '소모품을 선택해주세요.' }); + if (!unit_price) return res.status(400).json({ success: false, message: '구매 단가를 입력해주세요.' }); + if (!purchase_date) return res.status(400).json({ success: false, message: '구매일을 입력해주세요.' }); + + // 구매 내역 생성 + const purchaseId = await PurchaseModel.createFromRequest({ + request_id: request_id || null, + item_id, + vendor_id: vendor_id || null, + quantity: quantity || 1, + unit_price, + purchase_date, + purchaser_id: req.user.id, + notes + }); + + // 기준가 업데이트 요청 시 + if (update_base_price) { + const items = await PurchaseModel.getConsumableItems(false); + const item = items.find(i => i.item_id === parseInt(item_id)); + if (item) { + await PurchaseModel.updateBasePrice(item_id, unit_price, item.base_price, req.user.id); + } + } + + // 설비 자동 등록 (category='equipment') + let equipmentResult = null; + if (request_id) { + const requestData = await PurchaseRequestModel.getById(request_id); + if (requestData && requestData.category === 'equipment') { + equipmentResult = await PurchaseModel.tryAutoRegisterEquipment({ + item_name: requestData.item_name, + maker: requestData.maker, + vendor_name: null, + unit_price, + purchase_date, + purchase_id: purchaseId, + purchaser_id: req.user.id + }); + } + } else { + // 직접 구매 시에도 category 확인 + const items = await PurchaseModel.getConsumableItems(false); + const item = items.find(i => i.item_id === parseInt(item_id)); + if (item && item.category === 'equipment') { + const vendors = await PurchaseModel.getVendors(); + const vendor = vendors.find(v => v.vendor_id === parseInt(vendor_id)); + equipmentResult = await PurchaseModel.tryAutoRegisterEquipment({ + item_name: item.item_name, + maker: item.maker, + vendor_name: vendor ? vendor.vendor_name : null, + unit_price, + purchase_date, + purchase_id: purchaseId, + purchaser_id: req.user.id + }); + } + } + + const result = { purchase_id: purchaseId }; + if (equipmentResult) result.equipment = equipmentResult; + + res.status(201).json({ success: true, data: result, message: '구매 처리가 완료되었습니다.' }); + } catch (err) { + logger.error('Purchase create error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 구매 내역 목록 + getAll: async (req, res) => { + try { + const { vendor_id, category, from_date, to_date, year_month } = req.query; + const rows = await PurchaseModel.getAll({ vendor_id, category, from_date, to_date, year_month }); + res.json({ success: true, data: rows }); + } catch (err) { + logger.error('Purchase getAll error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 가격 변동 이력 + getPriceHistory: async (req, res) => { + try { + const rows = await PurchaseModel.getPriceHistory(req.params.itemId); + res.json({ success: true, data: rows }); + } catch (err) { + logger.error('PriceHistory get error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + } +}; + +module.exports = PurchaseController; diff --git a/system1-factory/api/controllers/purchaseRequestController.js b/system1-factory/api/controllers/purchaseRequestController.js new file mode 100644 index 0000000..c5f17c4 --- /dev/null +++ b/system1-factory/api/controllers/purchaseRequestController.js @@ -0,0 +1,120 @@ +const PurchaseRequestModel = require('../models/purchaseRequestModel'); +const PurchaseModel = require('../models/purchaseModel'); +const logger = require('../utils/logger'); + +const PurchaseRequestController = { + // 구매신청 목록 + getAll: async (req, res) => { + try { + const { status, category, from_date, to_date } = req.query; + const isAdmin = req.user && ['admin', 'system'].includes(req.user.access_level); + const filters = { status, category, from_date, to_date }; + if (!isAdmin) filters.requester_id = req.user.id; + const rows = await PurchaseRequestModel.getAll(filters); + res.json({ success: true, data: rows }); + } catch (err) { + logger.error('PurchaseRequest getAll error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 구매신청 상세 + getById: async (req, res) => { + try { + const row = await PurchaseRequestModel.getById(req.params.id); + if (!row) return res.status(404).json({ success: false, message: '신청 건을 찾을 수 없습니다.' }); + res.json({ success: true, data: row }); + } catch (err) { + logger.error('PurchaseRequest getById error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 구매신청 생성 + create: async (req, res) => { + try { + const { item_id, quantity, notes } = req.body; + if (!item_id) return res.status(400).json({ success: false, message: '소모품을 선택해주세요.' }); + if (!quantity || quantity < 1) return res.status(400).json({ success: false, message: '수량은 1 이상이어야 합니다.' }); + + const request = await PurchaseRequestModel.create({ + item_id, + quantity, + requester_id: req.user.id, + request_date: new Date().toISOString().substring(0, 10), + notes + }); + res.status(201).json({ success: true, data: request, message: '구매신청이 등록되었습니다.' }); + } catch (err) { + logger.error('PurchaseRequest create error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 보류 처리 (admin) + hold: async (req, res) => { + try { + const { hold_reason } = req.body; + const request = await PurchaseRequestModel.hold(req.params.id, hold_reason); + if (!request) return res.status(404).json({ success: false, message: '신청 건을 찾을 수 없습니다.' }); + res.json({ success: true, data: request, message: '보류 처리되었습니다.' }); + } catch (err) { + logger.error('PurchaseRequest hold error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // pending으로 되돌리기 (admin) + revert: async (req, res) => { + try { + const request = await PurchaseRequestModel.revertToPending(req.params.id); + if (!request) return res.status(404).json({ success: false, message: '신청 건을 찾을 수 없습니다.' }); + res.json({ success: true, data: request, message: '대기 상태로 되돌렸습니다.' }); + } catch (err) { + logger.error('PurchaseRequest revert error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 삭제 (본인 + pending만) + delete: async (req, res) => { + try { + const existing = await PurchaseRequestModel.getById(req.params.id); + if (!existing) return res.status(404).json({ success: false, message: '신청 건을 찾을 수 없습니다.' }); + const isAdmin = req.user && ['admin', 'system'].includes(req.user.access_level); + if (!isAdmin && existing.requester_id !== req.user.id) { + return res.status(403).json({ success: false, message: '본인의 신청만 삭제할 수 있습니다.' }); + } + const deleted = await PurchaseRequestModel.delete(req.params.id); + if (!deleted) return res.status(400).json({ success: false, message: '대기 상태의 신청만 삭제할 수 있습니다.' }); + res.json({ success: true, message: '삭제되었습니다.' }); + } catch (err) { + logger.error('PurchaseRequest delete error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 소모품 목록 (select용) + getConsumableItems: async (req, res) => { + try { + const items = await PurchaseModel.getConsumableItems(); + res.json({ success: true, data: items }); + } catch (err) { + logger.error('ConsumableItems get error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 업체 목록 (select용) + getVendors: async (req, res) => { + try { + const vendors = await PurchaseModel.getVendors(); + res.json({ success: true, data: vendors }); + } catch (err) { + logger.error('Vendors get error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + } +}; + +module.exports = PurchaseRequestController; diff --git a/system1-factory/api/controllers/settlementController.js b/system1-factory/api/controllers/settlementController.js new file mode 100644 index 0000000..484329b --- /dev/null +++ b/system1-factory/api/controllers/settlementController.js @@ -0,0 +1,76 @@ +const SettlementModel = require('../models/settlementModel'); +const logger = require('../utils/logger'); + +const SettlementController = { + // 월간 요약 (분류별 + 업체별) + getMonthlySummary: async (req, res) => { + try { + const { year_month } = req.query; + if (!year_month) return res.status(400).json({ success: false, message: '년월을 선택해주세요.' }); + + const [categorySummary, vendorSummary] = await Promise.all([ + SettlementModel.getCategorySummary(year_month), + SettlementModel.getVendorSummary(year_month) + ]); + + res.json({ success: true, data: { categorySummary, vendorSummary } }); + } catch (err) { + logger.error('Settlement summary error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 월간 상세 구매 목록 + getMonthlyPurchases: async (req, res) => { + try { + const { year_month } = req.query; + if (!year_month) return res.status(400).json({ success: false, message: '년월을 선택해주세요.' }); + const rows = await SettlementModel.getMonthlyPurchases(year_month); + res.json({ success: true, data: rows }); + } catch (err) { + logger.error('Settlement purchases error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 가격 변동 목록 + getPriceChanges: async (req, res) => { + try { + const { year_month } = req.query; + if (!year_month) return res.status(400).json({ success: false, message: '년월을 선택해주세요.' }); + const rows = await SettlementModel.getPriceChanges(year_month); + res.json({ success: true, data: rows }); + } catch (err) { + logger.error('Settlement priceChanges error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 정산 완료 + complete: async (req, res) => { + try { + const { year_month, vendor_id, notes } = req.body; + if (!year_month || !vendor_id) return res.status(400).json({ success: false, message: '년월과 업체를 선택해주세요.' }); + const result = await SettlementModel.completeSettlement(year_month, vendor_id, req.user.id, notes); + res.json({ success: true, data: result, message: '정산 완료 처리되었습니다.' }); + } catch (err) { + logger.error('Settlement complete error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + }, + + // 정산 취소 + cancel: async (req, res) => { + try { + const { year_month, vendor_id } = req.body; + if (!year_month || !vendor_id) return res.status(400).json({ success: false, message: '년월과 업체를 선택해주세요.' }); + const result = await SettlementModel.cancelSettlement(year_month, vendor_id); + res.json({ success: true, data: result, message: '정산이 취소되었습니다.' }); + } catch (err) { + logger.error('Settlement cancel error:', err); + res.status(500).json({ success: false, message: '서버 오류가 발생했습니다.' }); + } + } +}; + +module.exports = SettlementController; diff --git a/system1-factory/api/db/migrations/20260313100000_create_purchase_system.sql b/system1-factory/api/db/migrations/20260313100000_create_purchase_system.sql new file mode 100644 index 0000000..ed93e86 --- /dev/null +++ b/system1-factory/api/db/migrations/20260313100000_create_purchase_system.sql @@ -0,0 +1,102 @@ +-- 생산소모품 구매 관리 시스템 테이블 + +-- 업체 (tkuser에서 CRUD) +CREATE TABLE IF NOT EXISTS vendors ( + vendor_id INT AUTO_INCREMENT PRIMARY KEY, + vendor_name VARCHAR(100) NOT NULL, + business_number VARCHAR(20), + representative VARCHAR(50), + contact_name VARCHAR(50), + contact_phone VARCHAR(20), + address VARCHAR(200), + bank_name VARCHAR(50), + bank_account VARCHAR(50), + notes TEXT, + is_active TINYINT(1) DEFAULT 1, + created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP +); + +-- 소모품 마스터 (tkuser에서 CRUD) +CREATE TABLE IF NOT EXISTS consumable_items ( + item_id INT AUTO_INCREMENT PRIMARY KEY, + item_name VARCHAR(100) NOT NULL, + maker VARCHAR(100), + category ENUM('consumable','safety','repair','equipment') NOT NULL + COMMENT '소모품, 안전용품, 수선비, 설비', + base_price DECIMAL(12,0) DEFAULT 0, + unit VARCHAR(20) DEFAULT 'EA', + photo_path VARCHAR(255), + is_active TINYINT(1) DEFAULT 1, + created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + UNIQUE KEY uq_name_maker (item_name, maker) +); + +-- 구매신청 (tkfb에서 CRUD) +CREATE TABLE IF NOT EXISTS purchase_requests ( + request_id INT AUTO_INCREMENT PRIMARY KEY, + item_id INT NOT NULL, + quantity INT NOT NULL DEFAULT 1, + requester_id INT NOT NULL COMMENT 'FK → sso_users.user_id', + request_date DATE NOT NULL, + status ENUM('pending','purchased','hold') DEFAULT 'pending' + COMMENT '대기, 구매완료, 보류', + hold_reason TEXT, + notes TEXT, + created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (item_id) REFERENCES consumable_items(item_id), + FOREIGN KEY (requester_id) REFERENCES sso_users(user_id) +); + +-- 구매 내역 (tkfb에서 CRUD) +CREATE TABLE IF NOT EXISTS purchases ( + purchase_id INT AUTO_INCREMENT PRIMARY KEY, + request_id INT, + item_id INT NOT NULL, + vendor_id INT, + quantity INT NOT NULL DEFAULT 1, + unit_price DECIMAL(12,0) NOT NULL, + purchase_date DATE NOT NULL, + purchaser_id INT NOT NULL COMMENT 'FK → sso_users.user_id', + notes TEXT, + created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (item_id) REFERENCES consumable_items(item_id), + FOREIGN KEY (request_id) REFERENCES purchase_requests(request_id), + FOREIGN KEY (vendor_id) REFERENCES vendors(vendor_id), + FOREIGN KEY (purchaser_id) REFERENCES sso_users(user_id) +); + +-- 가격 변동 이력 +CREATE TABLE IF NOT EXISTS consumable_price_history ( + history_id INT AUTO_INCREMENT PRIMARY KEY, + item_id INT NOT NULL, + old_price DECIMAL(12,0), + new_price DECIMAL(12,0) NOT NULL, + changed_by INT COMMENT 'FK → sso_users.user_id', + changed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + FOREIGN KEY (item_id) REFERENCES consumable_items(item_id) +); + +-- 월간 정산 +CREATE TABLE IF NOT EXISTS monthly_settlements ( + settlement_id INT AUTO_INCREMENT PRIMARY KEY, + year_month VARCHAR(7) NOT NULL COMMENT 'YYYY-MM', + vendor_id INT NOT NULL, + total_amount DECIMAL(12,0) DEFAULT 0, + status ENUM('pending','completed') DEFAULT 'pending', + completed_at TIMESTAMP NULL, + completed_by INT COMMENT 'FK → sso_users.user_id', + notes TEXT, + created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (vendor_id) REFERENCES vendors(vendor_id), + UNIQUE KEY uq_ym_vendor (year_month, vendor_id) +); + +-- 페이지 키 등록 +INSERT IGNORE INTO pages (page_key, page_name, page_path, category, is_admin_only, display_order) VALUES +('purchase.request', '구매신청', '/pages/purchase/request.html', 'purchase', 0, 40), +('purchase.analysis', '구매 분석', '/pages/admin/purchase-analysis.html', 'purchase', 1, 41); diff --git a/system1-factory/api/models/purchaseModel.js b/system1-factory/api/models/purchaseModel.js new file mode 100644 index 0000000..b014723 --- /dev/null +++ b/system1-factory/api/models/purchaseModel.js @@ -0,0 +1,147 @@ +// models/purchaseModel.js +const { getDb } = require('../dbPool'); + +const PurchaseModel = { + // 구매 내역 목록 + async getAll(filters = {}) { + const db = await getDb(); + let sql = ` + SELECT p.*, ci.item_name, ci.maker, ci.category, ci.unit, ci.photo_path, + v.vendor_name, su.name AS purchaser_name + FROM purchases p + JOIN consumable_items ci ON p.item_id = ci.item_id + LEFT JOIN vendors v ON p.vendor_id = v.vendor_id + LEFT JOIN sso_users su ON p.purchaser_id = su.user_id + WHERE 1=1 + `; + const params = []; + + if (filters.vendor_id) { sql += ' AND p.vendor_id = ?'; params.push(filters.vendor_id); } + if (filters.category) { sql += ' AND ci.category = ?'; params.push(filters.category); } + if (filters.from_date) { sql += ' AND p.purchase_date >= ?'; params.push(filters.from_date); } + if (filters.to_date) { sql += ' AND p.purchase_date <= ?'; params.push(filters.to_date); } + if (filters.year_month) { + sql += ' AND DATE_FORMAT(p.purchase_date, "%Y-%m") = ?'; + params.push(filters.year_month); + } + + sql += ' ORDER BY p.purchase_date DESC, p.created_at DESC'; + const [rows] = await db.query(sql, params); + return rows; + }, + + // 구매 처리 (구매신청 → 구매 내역 생성 + 상태 변경) + async createFromRequest(data) { + const db = await getDb(); + + // 구매 내역 INSERT + const [result] = await db.query( + `INSERT INTO purchases (request_id, item_id, vendor_id, quantity, unit_price, purchase_date, purchaser_id, notes) + VALUES (?, ?, ?, ?, ?, ?, ?, ?)`, + [data.request_id || null, data.item_id, data.vendor_id || null, + data.quantity, data.unit_price, data.purchase_date, data.purchaser_id, data.notes || null] + ); + + // 구매신청 상태 → purchased + if (data.request_id) { + await db.query( + `UPDATE purchase_requests SET status = 'purchased' WHERE request_id = ?`, + [data.request_id] + ); + } + + return result.insertId; + }, + + // 기준가 업데이트 + 이력 기록 + async updateBasePrice(itemId, newPrice, oldPrice, changedBy) { + const db = await getDb(); + + // 이력 기록 + await db.query( + `INSERT INTO consumable_price_history (item_id, old_price, new_price, changed_by) + VALUES (?, ?, ?, ?)`, + [itemId, oldPrice, newPrice, changedBy] + ); + + // base_price 갱신 + await db.query( + `UPDATE consumable_items SET base_price = ? WHERE item_id = ?`, + [newPrice, itemId] + ); + }, + + // 설비 자동 등록 시도 (category='equipment') + async tryAutoRegisterEquipment(purchaseData) { + try { + const EquipmentModel = require('./equipmentModel'); + const equipmentCode = await EquipmentModel.getNextEquipmentCode('TKP'); + + await EquipmentModel.create({ + equipment_code: equipmentCode, + equipment_name: purchaseData.item_name, + manufacturer: purchaseData.maker || null, + supplier: purchaseData.vendor_name || null, + purchase_price: purchaseData.unit_price, + installation_date: purchaseData.purchase_date, + status: 'active', + notes: `구매 자동 등록 (purchase_id: ${purchaseData.purchase_id})` + }); + + return { success: true, equipment_code: equipmentCode }; + } catch (err) { + console.error('[purchase] 설비 자동 등록 실패:', err.message); + + // admin 알림 전송 + try { + const notificationModel = require('./notificationModel'); + await notificationModel.createTypedNotification({ + type: 'equipment', + title: `설비 자동 등록 실패: ${purchaseData.item_name}`, + message: `구매 완료 후 설비 자동 등록에 실패했습니다. 수동으로 등록해주세요. 오류: ${err.message}`, + link_url: '/pages/admin/equipments.html', + created_by: purchaseData.purchaser_id + }); + } catch (notifErr) { + console.error('[purchase] 설비 등록 실패 알림 전송 오류:', notifErr.message); + } + + return { success: false, error: err.message }; + } + }, + + // 업체 목록 (vendors 테이블 직접 조회) + async getVendors() { + const db = await getDb(); + const [rows] = await db.query( + 'SELECT vendor_id, vendor_name FROM vendors WHERE is_active = 1 ORDER BY vendor_name' + ); + return rows; + }, + + // 소모품 목록 (구매신청용) + async getConsumableItems(activeOnly = true) { + const db = await getDb(); + let sql = 'SELECT item_id, item_name, maker, category, base_price, unit, photo_path FROM consumable_items'; + if (activeOnly) sql += ' WHERE is_active = 1'; + sql += ' ORDER BY category, item_name'; + const [rows] = await db.query(sql); + return rows; + }, + + // 가격 변동 이력 + async getPriceHistory(itemId) { + const db = await getDb(); + const [rows] = await db.query( + `SELECT cph.*, su.name AS changed_by_name + FROM consumable_price_history cph + LEFT JOIN sso_users su ON cph.changed_by = su.user_id + WHERE cph.item_id = ? + ORDER BY cph.changed_at DESC`, + [itemId] + ); + return rows; + } +}; + +module.exports = PurchaseModel; diff --git a/system1-factory/api/models/purchaseRequestModel.js b/system1-factory/api/models/purchaseRequestModel.js new file mode 100644 index 0000000..92f1cc0 --- /dev/null +++ b/system1-factory/api/models/purchaseRequestModel.js @@ -0,0 +1,94 @@ +// models/purchaseRequestModel.js +const { getDb } = require('../dbPool'); + +const PurchaseRequestModel = { + // 구매신청 목록 (소모품 정보 JOIN) + async getAll(filters = {}) { + const db = await getDb(); + let sql = ` + SELECT pr.*, ci.item_name, ci.maker, ci.category, ci.base_price, ci.unit, ci.photo_path, + su.name AS requester_name + FROM purchase_requests pr + JOIN consumable_items ci ON pr.item_id = ci.item_id + LEFT JOIN sso_users su ON pr.requester_id = su.user_id + WHERE 1=1 + `; + const params = []; + + if (filters.status) { sql += ' AND pr.status = ?'; params.push(filters.status); } + if (filters.requester_id) { sql += ' AND pr.requester_id = ?'; params.push(filters.requester_id); } + if (filters.category) { sql += ' AND ci.category = ?'; params.push(filters.category); } + if (filters.from_date) { sql += ' AND pr.request_date >= ?'; params.push(filters.from_date); } + if (filters.to_date) { sql += ' AND pr.request_date <= ?'; params.push(filters.to_date); } + + sql += ' ORDER BY pr.created_at DESC'; + const [rows] = await db.query(sql, params); + return rows; + }, + + // 단건 조회 + async getById(requestId) { + const db = await getDb(); + const [rows] = await db.query(` + SELECT pr.*, ci.item_name, ci.maker, ci.category, ci.base_price, ci.unit, ci.photo_path, + su.name AS requester_name + FROM purchase_requests pr + JOIN consumable_items ci ON pr.item_id = ci.item_id + LEFT JOIN sso_users su ON pr.requester_id = su.user_id + WHERE pr.request_id = ? + `, [requestId]); + return rows[0] || null; + }, + + // 구매신청 생성 + async create(data) { + const db = await getDb(); + const [result] = await db.query( + `INSERT INTO purchase_requests (item_id, quantity, requester_id, request_date, notes) + VALUES (?, ?, ?, ?, ?)`, + [data.item_id, data.quantity || 1, data.requester_id, data.request_date, data.notes || null] + ); + return this.getById(result.insertId); + }, + + // 상태 변경 (보류) + async hold(requestId, holdReason) { + const db = await getDb(); + await db.query( + `UPDATE purchase_requests SET status = 'hold', hold_reason = ? WHERE request_id = ?`, + [holdReason || null, requestId] + ); + return this.getById(requestId); + }, + + // 상태 → purchased + async markPurchased(requestId) { + const db = await getDb(); + await db.query( + `UPDATE purchase_requests SET status = 'purchased' WHERE request_id = ?`, + [requestId] + ); + }, + + // pending으로 되돌리기 + async revertToPending(requestId) { + const db = await getDb(); + await db.query( + `UPDATE purchase_requests SET status = 'pending', hold_reason = NULL WHERE request_id = ?`, + [requestId] + ); + return this.getById(requestId); + }, + + // 삭제 (admin only, pending 상태만) + async delete(requestId) { + const db = await getDb(); + const [result] = await db.query( + `DELETE FROM purchase_requests WHERE request_id = ? AND status = 'pending'`, + [requestId] + ); + return result.affectedRows > 0; + } +}; + +module.exports = PurchaseRequestModel; diff --git a/system1-factory/api/models/settlementModel.js b/system1-factory/api/models/settlementModel.js new file mode 100644 index 0000000..3d0a741 --- /dev/null +++ b/system1-factory/api/models/settlementModel.js @@ -0,0 +1,104 @@ +// models/settlementModel.js +const { getDb } = require('../dbPool'); + +const SettlementModel = { + // 월간 분류별 요약 + async getCategorySummary(yearMonth) { + const db = await getDb(); + const [rows] = await db.query(` + SELECT ci.category, + COUNT(*) AS count, + SUM(p.quantity * p.unit_price) AS total_amount + FROM purchases p + JOIN consumable_items ci ON p.item_id = ci.item_id + WHERE DATE_FORMAT(p.purchase_date, '%Y-%m') = ? + GROUP BY ci.category + `, [yearMonth]); + return rows; + }, + + // 월간 업체별 요약 + async getVendorSummary(yearMonth) { + const db = await getDb(); + const [rows] = await db.query(` + SELECT v.vendor_id, v.vendor_name, + COUNT(*) AS count, + SUM(p.quantity * p.unit_price) AS total_amount, + ms.settlement_id, ms.status AS settlement_status, + ms.completed_at, ms.notes AS settlement_notes + FROM purchases p + LEFT JOIN vendors v ON p.vendor_id = v.vendor_id + LEFT JOIN monthly_settlements ms ON ms.vendor_id = p.vendor_id AND ms.year_month = ? + WHERE DATE_FORMAT(p.purchase_date, '%Y-%m') = ? + GROUP BY COALESCE(v.vendor_id, 0), v.vendor_name, ms.settlement_id, ms.status, ms.completed_at, ms.notes + ORDER BY total_amount DESC + `, [yearMonth, yearMonth]); + return rows; + }, + + // 월간 상세 구매 목록 + async getMonthlyPurchases(yearMonth) { + const db = await getDb(); + const [rows] = await db.query(` + SELECT p.*, ci.item_name, ci.maker, ci.category, ci.unit, ci.base_price, ci.photo_path, + v.vendor_name, su.name AS purchaser_name + FROM purchases p + JOIN consumable_items ci ON p.item_id = ci.item_id + LEFT JOIN vendors v ON p.vendor_id = v.vendor_id + LEFT JOIN sso_users su ON p.purchaser_id = su.user_id + WHERE DATE_FORMAT(p.purchase_date, '%Y-%m') = ? + ORDER BY p.purchase_date DESC + `, [yearMonth]); + return rows; + }, + + // 정산 완료 처리 + async completeSettlement(yearMonth, vendorId, completedBy, notes) { + const db = await getDb(); + + // 총액 계산 + const [[{ total }]] = await db.query(` + SELECT COALESCE(SUM(p.quantity * p.unit_price), 0) AS total + FROM purchases p + WHERE p.vendor_id = ? AND DATE_FORMAT(p.purchase_date, '%Y-%m') = ? + `, [vendorId, yearMonth]); + + // UPSERT + await db.query(` + INSERT INTO monthly_settlements (year_month, vendor_id, total_amount, status, completed_at, completed_by, notes) + VALUES (?, ?, ?, 'completed', NOW(), ?, ?) + ON DUPLICATE KEY UPDATE status = 'completed', total_amount = ?, completed_at = NOW(), completed_by = ?, notes = ? + `, [yearMonth, vendorId, total, completedBy, notes || null, total, completedBy, notes || null]); + + return { year_month: yearMonth, vendor_id: vendorId, total_amount: total, status: 'completed' }; + }, + + // 정산 취소 + async cancelSettlement(yearMonth, vendorId) { + const db = await getDb(); + await db.query(` + UPDATE monthly_settlements SET status = 'pending', completed_at = NULL, completed_by = NULL + WHERE year_month = ? AND vendor_id = ? + `, [yearMonth, vendorId]); + return { year_month: yearMonth, vendor_id: vendorId, status: 'pending' }; + }, + + // 가격 변동 목록 (월간) + async getPriceChanges(yearMonth) { + const db = await getDb(); + const [rows] = await db.query(` + SELECT p.purchase_id, p.purchase_date, p.unit_price, p.quantity, + ci.item_id, ci.item_name, ci.maker, ci.category, ci.base_price, + v.vendor_name + FROM purchases p + JOIN consumable_items ci ON p.item_id = ci.item_id + LEFT JOIN vendors v ON p.vendor_id = v.vendor_id + WHERE DATE_FORMAT(p.purchase_date, '%Y-%m') = ? + AND p.unit_price != ci.base_price + ORDER BY ABS(p.unit_price - ci.base_price) DESC + `, [yearMonth]); + return rows; + } +}; + +module.exports = SettlementModel; diff --git a/system1-factory/api/routes/purchaseRequestRoutes.js b/system1-factory/api/routes/purchaseRequestRoutes.js new file mode 100644 index 0000000..fce1ba3 --- /dev/null +++ b/system1-factory/api/routes/purchaseRequestRoutes.js @@ -0,0 +1,18 @@ +const express = require('express'); +const router = express.Router(); +const ctrl = require('../controllers/purchaseRequestController'); +const { requireMinLevel } = require('../middlewares/auth'); + +// 보조 데이터 +router.get('/consumable-items', ctrl.getConsumableItems); +router.get('/vendors', ctrl.getVendors); + +// 구매신청 CRUD +router.get('/', ctrl.getAll); +router.get('/:id', ctrl.getById); +router.post('/', ctrl.create); +router.put('/:id/hold', requireMinLevel('admin'), ctrl.hold); +router.put('/:id/revert', requireMinLevel('admin'), ctrl.revert); +router.delete('/:id', ctrl.delete); + +module.exports = router; diff --git a/system1-factory/api/routes/purchaseRoutes.js b/system1-factory/api/routes/purchaseRoutes.js new file mode 100644 index 0000000..45faed8 --- /dev/null +++ b/system1-factory/api/routes/purchaseRoutes.js @@ -0,0 +1,10 @@ +const express = require('express'); +const router = express.Router(); +const ctrl = require('../controllers/purchaseController'); +const { requireMinLevel } = require('../middlewares/auth'); + +router.get('/', ctrl.getAll); +router.post('/', requireMinLevel('admin'), ctrl.create); +router.get('/price-history/:itemId', ctrl.getPriceHistory); + +module.exports = router; diff --git a/system1-factory/api/routes/settlementRoutes.js b/system1-factory/api/routes/settlementRoutes.js new file mode 100644 index 0000000..39ff5a4 --- /dev/null +++ b/system1-factory/api/routes/settlementRoutes.js @@ -0,0 +1,12 @@ +const express = require('express'); +const router = express.Router(); +const ctrl = require('../controllers/settlementController'); +const { requireMinLevel } = require('../middlewares/auth'); + +router.get('/summary', ctrl.getMonthlySummary); +router.get('/purchases', ctrl.getMonthlyPurchases); +router.get('/price-changes', ctrl.getPriceChanges); +router.post('/complete', requireMinLevel('admin'), ctrl.complete); +router.post('/cancel', requireMinLevel('admin'), ctrl.cancel); + +module.exports = router; diff --git a/system1-factory/web/pages/admin/purchase-analysis.html b/system1-factory/web/pages/admin/purchase-analysis.html new file mode 100644 index 0000000..66155c1 --- /dev/null +++ b/system1-factory/web/pages/admin/purchase-analysis.html @@ -0,0 +1,113 @@ + + + + + + 구매 분석 - TK 공장관리 + + + + + +
+
+
+
+ + +

TK 공장관리

+
+
+ +
-
+ +
+
+
+
+ +
+
+ +
+ +
+
+

구매 분석

+

월간 구매 현황 분석 및 업체별 정산 관리

+
+
+ + +
+ + +
+ + +
+
월을 선택하고 조회해주세요
+
+ + +
+

업체별 요약

+
+ + + + + + + + + + + + + +
업체건수총액정산액션
-
+
+
+ + +
+

상세 구매 목록

+
+ + + + + + + + + + + + + + + + +
품목분류수량단가소계업체구매일비고
-
+
+
+ + +
+

가격 변동 항목

+
+

-

+
+
+ +
+
+
+ + + + diff --git a/system1-factory/web/pages/purchase/request.html b/system1-factory/web/pages/purchase/request.html new file mode 100644 index 0000000..48bf1db --- /dev/null +++ b/system1-factory/web/pages/purchase/request.html @@ -0,0 +1,181 @@ + + + + + + 구매신청 - TK 공장관리 + + + + + +
+
+
+
+ + +

TK 공장관리

+
+
+ +
-
+ +
+
+
+
+ +
+
+ +
+ +
+
+

구매신청

+

생산소모품 구매를 신청하고 처리 현황을 확인합니다

+
+
+ + +
+

신규 구매신청

+
+
+ + + +
+
+ + +
+
+ + +
+
+
+ +
+
+ + +
+ + + +
+ + +
+
+ + + + + + + + + + + + + + + +
품목분류수량신청자신청일상태액션
데이터를 불러오는 중...
+
+
+ + + + + + + +
+
+
+ + + + diff --git a/system1-factory/web/static/js/purchase-analysis.js b/system1-factory/web/static/js/purchase-analysis.js new file mode 100644 index 0000000..1e29176 --- /dev/null +++ b/system1-factory/web/static/js/purchase-analysis.js @@ -0,0 +1,183 @@ +/* ===== 구매 분석 페이지 ===== */ +const CAT_LABELS = { consumable: '소모품', safety: '안전용품', repair: '수선비', equipment: '설비' }; +const CAT_ICONS = { consumable: 'fa-box', safety: 'fa-hard-hat', repair: 'fa-wrench', equipment: 'fa-cogs' }; +const CAT_BG = { consumable: 'bg-blue-50 text-blue-700', safety: 'bg-green-50 text-green-700', repair: 'bg-amber-50 text-amber-700', equipment: 'bg-purple-50 text-purple-700' }; + +let currentYearMonth = ''; + +async function loadAnalysis() { + currentYearMonth = document.getElementById('paMonth').value; + if (!currentYearMonth) { showToast('월을 선택해주세요.', 'error'); return; } + + try { + const [summaryRes, purchasesRes, priceChangesRes] = await Promise.all([ + api(`/settlements/summary?year_month=${currentYearMonth}`), + api(`/settlements/purchases?year_month=${currentYearMonth}`), + api(`/settlements/price-changes?year_month=${currentYearMonth}`) + ]); + + renderCategorySummary(summaryRes.data?.categorySummary || []); + renderVendorSummary(summaryRes.data?.vendorSummary || []); + renderPurchaseList(purchasesRes.data || []); + renderPriceChanges(priceChangesRes.data || []); + } catch (e) { + showToast('데이터 로드 실패: ' + e.message, 'error'); + } +} + +function renderCategorySummary(data) { + const el = document.getElementById('paCategorySummary'); + const allCategories = ['consumable', 'safety', 'repair', 'equipment']; + const dataMap = {}; + data.forEach(d => { dataMap[d.category] = d; }); + + const totalAmount = data.reduce((sum, d) => sum + Number(d.total_amount || 0), 0); + + el.innerHTML = allCategories.map(cat => { + const d = dataMap[cat] || { count: 0, total_amount: 0 }; + const label = CAT_LABELS[cat]; + const icon = CAT_ICONS[cat]; + const bg = CAT_BG[cat]; + return `
+
+
+ ${label} +
+
${Number(d.total_amount || 0).toLocaleString()}원
+
${d.count || 0}건
+
`; + }).join('') + ` +
+ 월 합계: ${totalAmount.toLocaleString()}원 +
`; +} + +function renderVendorSummary(data) { + const tbody = document.getElementById('paVendorSummary'); + if (!data.length) { + tbody.innerHTML = '해당 월 구매 내역이 없습니다.'; + return; + } + tbody.innerHTML = data.map(v => { + const isCompleted = v.settlement_status === 'completed'; + const statusBadge = isCompleted + ? '정산완료' + : '미정산'; + const vendorName = v.vendor_name || '(업체 미지정)'; + const vendorId = v.vendor_id || 0; + + let actionBtn = ''; + if (vendorId > 0) { + if (isCompleted) { + actionBtn = ``; + } else { + actionBtn = ``; + } + } + + return ` + ${escapeHtml(vendorName)} + ${v.count}건 + ${Number(v.total_amount || 0).toLocaleString()}원 + ${statusBadge} + ${actionBtn} + `; + }).join(''); +} + +function renderPurchaseList(data) { + const tbody = document.getElementById('paPurchaseList'); + if (!data.length) { + tbody.innerHTML = '해당 월 구매 내역이 없습니다.'; + return; + } + tbody.innerHTML = data.map(p => { + const catLabel = CAT_LABELS[p.category] || p.category; + const catColor = CAT_BG[p.category] || ''; + const subtotal = (p.quantity || 0) * (p.unit_price || 0); + const basePrice = Number(p.base_price || 0); + const unitPrice = Number(p.unit_price || 0); + const hasPriceDiff = basePrice > 0 && unitPrice > 0 && basePrice !== unitPrice; + const priceDiffClass = hasPriceDiff ? (unitPrice > basePrice ? 'text-red-600 font-semibold' : 'text-blue-600 font-semibold') : ''; + + return ` + +
${escapeHtml(p.item_name)}
+
${escapeHtml(p.maker || '')}
+ + ${catLabel} + ${p.quantity} + ${unitPrice.toLocaleString()}원${hasPriceDiff ? `
(기준: ${basePrice.toLocaleString()})
` : ''} + ${subtotal.toLocaleString()}원 + ${escapeHtml(p.vendor_name || '-')} + ${formatDate(p.purchase_date)} + ${escapeHtml(p.notes || '')} + `; + }).join(''); +} + +function renderPriceChanges(data) { + const el = document.getElementById('paPriceChanges'); + if (!data.length) { + el.innerHTML = '

가격 변동 항목이 없습니다.

'; + return; + } + el.innerHTML = ` + + + + + + + + + + + ${data.map(p => { + const diff = Number(p.unit_price) - Number(p.base_price); + const arrow = diff > 0 ? '▲' : '▼'; + const color = diff > 0 ? 'text-red-600' : 'text-blue-600'; + return ` + + + + + + + `; + }).join('')} +
품목기준가실구매가차이업체구매일
${escapeHtml(p.item_name)} ${p.maker ? '(' + escapeHtml(p.maker) + ')' : ''}${Number(p.base_price).toLocaleString()}원${Number(p.unit_price).toLocaleString()}원${arrow} ${Math.abs(diff).toLocaleString()}원${escapeHtml(p.vendor_name || '-')}${formatDate(p.purchase_date)}
`; +} + +/* ===== 정산 처리 ===== */ +async function completeSettlement(vendorId) { + if (!confirm('이 업체의 정산을 완료 처리하시겠습니까?')) return; + try { + await api('/settlements/complete', { + method: 'POST', + body: JSON.stringify({ year_month: currentYearMonth, vendor_id: vendorId }) + }); + showToast('정산 완료 처리되었습니다.'); + await loadAnalysis(); + } catch (e) { showToast(e.message, 'error'); } +} + +async function cancelSettlement(vendorId) { + if (!confirm('정산 완료를 취소하시겠습니까?')) return; + try { + await api('/settlements/cancel', { + method: 'POST', + body: JSON.stringify({ year_month: currentYearMonth, vendor_id: vendorId }) + }); + showToast('정산이 취소되었습니다.'); + await loadAnalysis(); + } catch (e) { showToast(e.message, 'error'); } +} + +/* ===== Init ===== */ +(async function() { + if (!await initAuth()) return; + // 기본값: 현재 월 + const now = new Date(); + document.getElementById('paMonth').value = `${now.getFullYear()}-${String(now.getMonth() + 1).padStart(2, '0')}`; +})(); diff --git a/system1-factory/web/static/js/purchase-request.js b/system1-factory/web/static/js/purchase-request.js new file mode 100644 index 0000000..9938835 --- /dev/null +++ b/system1-factory/web/static/js/purchase-request.js @@ -0,0 +1,294 @@ +/* ===== 구매신청 페이지 ===== */ +const TKUSER_BASE_URL = location.hostname.includes('technicalkorea.net') + ? 'https://tkuser.technicalkorea.net' + : location.protocol + '//' + location.hostname + ':30180'; + +const CAT_LABELS = { consumable: '소모품', safety: '안전용품', repair: '수선비', equipment: '설비' }; +const CAT_COLORS = { consumable: 'badge-blue', safety: 'badge-green', repair: 'badge-amber', equipment: 'badge-purple' }; +const STATUS_LABELS = { pending: '대기', purchased: '구매완료', hold: '보류' }; +const STATUS_COLORS = { pending: 'badge-amber', purchased: 'badge-green', hold: 'badge-gray' }; + +let consumableItems = []; +let vendorsList = []; +let requestsList = []; +let currentRequestForPurchase = null; +let currentRequestForHold = null; +let isAdmin = false; + +async function loadInitialData() { + try { + const [itemsRes, vendorsRes] = await Promise.all([ + api('/purchase-requests/consumable-items'), + api('/purchase-requests/vendors') + ]); + consumableItems = itemsRes.data || []; + vendorsList = vendorsRes.data || []; + populateItemSelect(); + populateVendorSelect(); + } catch (e) { + console.error('초기 데이터 로드 실패:', e); + } +} + +function populateItemSelect() { + const sel = document.getElementById('prItemSelect'); + const groups = {}; + consumableItems.forEach(item => { + const cat = CAT_LABELS[item.category] || item.category; + if (!groups[cat]) groups[cat] = []; + groups[cat].push(item); + }); + let html = ''; + for (const [cat, items] of Object.entries(groups)) { + html += ``; + items.forEach(item => { + const maker = item.maker ? ` (${escapeHtml(item.maker)})` : ''; + html += ``; + }); + html += ''; + } + sel.innerHTML = html; +} + +function populateVendorSelect() { + const sel = document.getElementById('pmVendor'); + sel.innerHTML = '' + + vendorsList.map(v => ``).join(''); +} + +function onItemSelect() { + const itemId = parseInt(document.getElementById('prItemSelect').value); + const preview = document.getElementById('prItemPreview'); + const item = consumableItems.find(i => i.item_id === itemId); + if (!item) { preview.classList.add('hidden'); return; } + + preview.classList.remove('hidden'); + const photoEl = document.getElementById('prItemPhoto'); + if (item.photo_path) { + photoEl.src = TKUSER_BASE_URL + item.photo_path; + photoEl.classList.remove('hidden'); + photoEl.onerror = () => photoEl.classList.add('hidden'); + } else { + photoEl.classList.add('hidden'); + } + document.getElementById('prItemInfo').textContent = `${item.item_name} ${item.maker ? '(' + item.maker + ')' : ''}`; + const price = item.base_price ? Number(item.base_price).toLocaleString() + '원/' + (item.unit || 'EA') : '기준가 미설정'; + document.getElementById('prItemPrice').textContent = price; +} + +/* ===== 구매신청 제출 ===== */ +async function submitPurchaseRequest() { + const item_id = document.getElementById('prItemSelect').value; + const quantity = parseInt(document.getElementById('prQuantity').value) || 0; + const notes = document.getElementById('prNotes').value.trim(); + + if (!item_id) { showToast('소모품을 선택해주세요.', 'error'); return; } + if (quantity < 1) { showToast('수량은 1 이상이어야 합니다.', 'error'); return; } + + try { + await api('/purchase-requests', { + method: 'POST', + body: JSON.stringify({ item_id: parseInt(item_id), quantity, notes }) + }); + showToast('구매신청이 등록되었습니다.'); + document.getElementById('prItemSelect').value = ''; + document.getElementById('prQuantity').value = '1'; + document.getElementById('prNotes').value = ''; + document.getElementById('prItemPreview').classList.add('hidden'); + await loadRequests(); + } catch (e) { showToast(e.message, 'error'); } +} + +/* ===== 신청 목록 ===== */ +async function loadRequests() { + try { + const status = document.getElementById('prFilterStatus').value; + const category = document.getElementById('prFilterCategory').value; + const params = new URLSearchParams(); + if (status) params.set('status', status); + if (category) params.set('category', category); + const res = await api('/purchase-requests?' + params.toString()); + requestsList = res.data || []; + renderRequests(); + } catch (e) { + document.getElementById('prRequestList').innerHTML = `${escapeHtml(e.message)}`; + } +} + +function renderRequests() { + const tbody = document.getElementById('prRequestList'); + if (!requestsList.length) { + tbody.innerHTML = '구매신청 내역이 없습니다.'; + return; + } + tbody.innerHTML = requestsList.map(r => { + const catLabel = CAT_LABELS[r.category] || r.category; + const catColor = CAT_COLORS[r.category] || 'badge-gray'; + const statusLabel = STATUS_LABELS[r.status] || r.status; + const statusColor = STATUS_COLORS[r.status] || 'badge-gray'; + const photoSrc = r.photo_path ? TKUSER_BASE_URL + r.photo_path : ''; + + let actions = ''; + if (isAdmin && r.status === 'pending') { + actions = ` + `; + } else if (isAdmin && r.status === 'hold') { + actions = ``; + } + if (r.status === 'pending' && (isAdmin || r.requester_id === currentUser.id)) { + actions += ` `; + } + + return ` + +
+ ${photoSrc ? `` : ''} +
+
${escapeHtml(r.item_name)}
+
${escapeHtml(r.maker || '')}
+
+
+ + ${catLabel} + ${r.quantity} + ${escapeHtml(r.requester_name || '')} + ${formatDate(r.request_date)} + + ${statusLabel} + ${r.status === 'hold' && r.hold_reason ? `
${escapeHtml(r.hold_reason)}
` : ''} + + ${actions} + `; + }).join(''); +} + +/* ===== 구매 처리 모달 ===== */ +function openPurchaseModal(requestId) { + const r = requestsList.find(x => x.request_id === requestId); + if (!r) return; + currentRequestForPurchase = r; + + const basePrice = r.base_price ? Number(r.base_price).toLocaleString() + '원' : '-'; + document.getElementById('purchaseModalInfo').innerHTML = ` +
${escapeHtml(r.item_name)} ${r.maker ? '(' + escapeHtml(r.maker) + ')' : ''}
+
분류: ${CAT_LABELS[r.category] || r.category} | 기준가: ${basePrice} | 신청수량: ${r.quantity}
+ `; + document.getElementById('pmUnitPrice').value = r.base_price || ''; + document.getElementById('pmQuantity').value = r.quantity; + document.getElementById('pmDate').value = new Date().toISOString().substring(0, 10); + document.getElementById('pmNotes').value = ''; + document.getElementById('pmPriceDiffArea').innerHTML = ''; + document.getElementById('purchaseModal').classList.remove('hidden'); + showPriceDiff(); +} + +function closePurchaseModal() { + document.getElementById('purchaseModal').classList.add('hidden'); + currentRequestForPurchase = null; +} + +function showPriceDiff() { + if (!currentRequestForPurchase) return; + const basePrice = Number(currentRequestForPurchase.base_price) || 0; + const unitPrice = Number(document.getElementById('pmUnitPrice').value) || 0; + const area = document.getElementById('pmPriceDiffArea'); + + if (basePrice > 0 && unitPrice > 0 && basePrice !== unitPrice) { + const diff = unitPrice - basePrice; + const arrow = diff > 0 ? '▲' : '▼'; + const color = diff > 0 ? 'text-red-600' : 'text-blue-600'; + area.innerHTML = ` +
+ 기준가 ${basePrice.toLocaleString()}원 → 실구매가 ${unitPrice.toLocaleString()}원 ${arrow}${Math.abs(diff).toLocaleString()} +
+ `; + } else { + area.innerHTML = ''; + } +} + +async function submitPurchase() { + if (!currentRequestForPurchase) return; + const unit_price = Number(document.getElementById('pmUnitPrice').value); + const purchase_date = document.getElementById('pmDate').value; + if (!unit_price) { showToast('구매 단가를 입력해주세요.', 'error'); return; } + if (!purchase_date) { showToast('구매일을 입력해주세요.', 'error'); return; } + + const updateCheckbox = document.getElementById('pmUpdateBasePrice'); + const body = { + request_id: currentRequestForPurchase.request_id, + item_id: currentRequestForPurchase.item_id, + vendor_id: parseInt(document.getElementById('pmVendor').value) || null, + quantity: parseInt(document.getElementById('pmQuantity').value) || currentRequestForPurchase.quantity, + unit_price, + purchase_date, + update_base_price: updateCheckbox ? updateCheckbox.checked : false, + notes: document.getElementById('pmNotes').value.trim() + }; + + try { + const res = await api('/purchases', { method: 'POST', body: JSON.stringify(body) }); + let msg = '구매 처리가 완료되었습니다.'; + if (res.data?.equipment?.success) msg += ` 설비 ${res.data.equipment.equipment_code} 자동 등록됨.`; + else if (res.data?.equipment && !res.data.equipment.success) msg += ' (설비 자동 등록 실패 - 수동 등록 필요)'; + showToast(msg); + closePurchaseModal(); + await loadRequests(); + } catch (e) { showToast(e.message, 'error'); } +} + +/* ===== 보류 모달 ===== */ +function openHoldModal(requestId) { + currentRequestForHold = requestId; + document.getElementById('holdReason').value = ''; + document.getElementById('holdModal').classList.remove('hidden'); +} + +function closeHoldModal() { + document.getElementById('holdModal').classList.add('hidden'); + currentRequestForHold = null; +} + +async function submitHold() { + if (!currentRequestForHold) return; + const hold_reason = document.getElementById('holdReason').value.trim(); + try { + await api(`/purchase-requests/${currentRequestForHold}/hold`, { + method: 'PUT', + body: JSON.stringify({ hold_reason }) + }); + showToast('보류 처리되었습니다.'); + closeHoldModal(); + await loadRequests(); + } catch (e) { showToast(e.message, 'error'); } +} + +/* ===== 기타 액션 ===== */ +async function revertRequest(requestId) { + if (!confirm('이 신청을 대기 상태로 되돌리시겠습니까?')) return; + try { + await api(`/purchase-requests/${requestId}/revert`, { method: 'PUT' }); + showToast('대기 상태로 되돌렸습니다.'); + await loadRequests(); + } catch (e) { showToast(e.message, 'error'); } +} + +async function deleteRequest(requestId) { + if (!confirm('이 구매신청을 삭제하시겠습니까?')) return; + try { + await api(`/purchase-requests/${requestId}`, { method: 'DELETE' }); + showToast('삭제되었습니다.'); + await loadRequests(); + } catch (e) { showToast(e.message, 'error'); } +} + +/* ===== Init ===== */ +(async function() { + if (!await initAuth()) return; + isAdmin = currentUser && ['admin', 'system', 'system admin'].includes(currentUser.role); + await loadInitialData(); + await loadRequests(); +})(); diff --git a/system1-factory/web/static/js/tkfb-core.js b/system1-factory/web/static/js/tkfb-core.js index 116e9e0..0fb835f 100644 --- a/system1-factory/web/static/js/tkfb-core.js +++ b/system1-factory/web/static/js/tkfb-core.js @@ -119,6 +119,10 @@ const NAV_MENU = [ { href: '/pages/attendance/checkin.html', icon: 'fa-user-check', label: '출근 체크', key: 'inspection.checkin' }, { href: '/pages/attendance/work-status.html', icon: 'fa-briefcase', label: '근무 현황', key: 'inspection.work_status' }, ]}, + { cat: '구매 관리', items: [ + { href: '/pages/purchase/request.html', icon: 'fa-shopping-cart', label: '구매신청', key: 'purchase.request' }, + { href: '/pages/admin/purchase-analysis.html', icon: 'fa-chart-line', label: '구매 분석', key: 'purchase.analysis', admin: true }, + ]}, { cat: '근태 관리', items: [ { href: '/pages/attendance/my-vacation-info.html', icon: 'fa-info-circle', label: '내 연차 정보', key: 'attendance.my_vacation_info' }, { href: '/pages/attendance/monthly.html', icon: 'fa-calendar', label: '월간 근태', key: 'attendance.monthly' }, diff --git a/user-management/api/controllers/consumableItemController.js b/user-management/api/controllers/consumableItemController.js new file mode 100644 index 0000000..f96e63b --- /dev/null +++ b/user-management/api/controllers/consumableItemController.js @@ -0,0 +1,90 @@ +const consumableItemModel = require('../models/consumableItemModel'); +const fs = require('fs'); +const path = require('path'); + +async function list(req, res) { + try { + const { category, search, is_active } = req.query; + const rows = await consumableItemModel.findAll({ + category, + search, + is_active: is_active !== undefined ? is_active === 'true' || is_active === '1' : undefined + }); + res.json({ success: true, data: rows }); + } catch (err) { + console.error('ConsumableItem list error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function getById(req, res) { + try { + const item = await consumableItemModel.findById(req.params.id); + if (!item) return res.status(404).json({ success: false, error: '소모품을 찾을 수 없습니다' }); + res.json({ success: true, data: item }); + } catch (err) { + console.error('ConsumableItem get error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function create(req, res) { + try { + const { item_name, category } = req.body; + if (!item_name || !item_name.trim()) { + return res.status(400).json({ success: false, error: '품명은 필수입니다' }); + } + if (!category) { + return res.status(400).json({ success: false, error: '분류는 필수입니다' }); + } + const data = { ...req.body }; + if (req.file) { + data.photo_path = '/uploads/consumables/' + req.file.filename; + } + const item = await consumableItemModel.create(data); + res.status(201).json({ success: true, data: item }); + } catch (err) { + if (err.code === 'ER_DUP_ENTRY') { + return res.status(400).json({ success: false, error: '동일한 품명+메이커 조합이 이미 존재합니다' }); + } + console.error('ConsumableItem create error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function update(req, res) { + try { + const existing = await consumableItemModel.findById(req.params.id); + if (!existing) return res.status(404).json({ success: false, error: '소모품을 찾을 수 없습니다' }); + + const data = { ...req.body }; + if (req.file) { + data.photo_path = '/uploads/consumables/' + req.file.filename; + // 기존 사진 삭제 + if (existing.photo_path) { + const oldPath = path.join(__dirname, '..', existing.photo_path); + fs.unlink(oldPath, () => {}); + } + } + const item = await consumableItemModel.update(req.params.id, data); + res.json({ success: true, data: item }); + } catch (err) { + if (err.code === 'ER_DUP_ENTRY') { + return res.status(400).json({ success: false, error: '동일한 품명+메이커 조합이 이미 존재합니다' }); + } + console.error('ConsumableItem update error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function deactivate(req, res) { + try { + await consumableItemModel.deactivate(req.params.id); + res.json({ success: true, message: '비활성화 완료' }); + } catch (err) { + console.error('ConsumableItem deactivate error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +module.exports = { list, getById, create, update, deactivate }; diff --git a/user-management/api/controllers/vendorController.js b/user-management/api/controllers/vendorController.js new file mode 100644 index 0000000..30500be --- /dev/null +++ b/user-management/api/controllers/vendorController.js @@ -0,0 +1,66 @@ +const vendorModel = require('../models/vendorModel'); + +async function list(req, res) { + try { + const { search, is_active } = req.query; + const rows = await vendorModel.findAll({ + search, + is_active: is_active !== undefined ? is_active === 'true' || is_active === '1' : undefined + }); + res.json({ success: true, data: rows }); + } catch (err) { + console.error('Vendor list error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function getById(req, res) { + try { + const vendor = await vendorModel.findById(req.params.id); + if (!vendor) return res.status(404).json({ success: false, error: '업체를 찾을 수 없습니다' }); + res.json({ success: true, data: vendor }); + } catch (err) { + console.error('Vendor get error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function create(req, res) { + try { + const { vendor_name } = req.body; + if (!vendor_name || !vendor_name.trim()) { + return res.status(400).json({ success: false, error: '업체명은 필수입니다' }); + } + const vendor = await vendorModel.create(req.body); + res.status(201).json({ success: true, data: vendor }); + } catch (err) { + if (err.code === 'ER_DUP_ENTRY') { + return res.status(400).json({ success: false, error: '이미 등록된 업체입니다' }); + } + console.error('Vendor create error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function update(req, res) { + try { + const vendor = await vendorModel.update(req.params.id, req.body); + if (!vendor) return res.status(404).json({ success: false, error: '업체를 찾을 수 없습니다' }); + res.json({ success: true, data: vendor }); + } catch (err) { + console.error('Vendor update error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +async function deactivate(req, res) { + try { + await vendorModel.deactivate(req.params.id); + res.json({ success: true, message: '비활성화 완료' }); + } catch (err) { + console.error('Vendor deactivate error:', err); + res.status(500).json({ success: false, error: err.message }); + } +} + +module.exports = { list, getById, create, update, deactivate }; diff --git a/user-management/api/index.js b/user-management/api/index.js index 793b0b9..f9ee2e9 100644 --- a/user-management/api/index.js +++ b/user-management/api/index.js @@ -18,6 +18,8 @@ const equipmentRoutes = require('./routes/equipmentRoutes'); const taskRoutes = require('./routes/taskRoutes'); const vacationRoutes = require('./routes/vacationRoutes'); const partnerRoutes = require('./routes/partnerRoutes'); +const vendorRoutes = require('./routes/vendorRoutes'); +const consumableItemRoutes = require('./routes/consumableItemRoutes'); const notificationRecipientRoutes = require('./routes/notificationRecipientRoutes'); const app = express(); @@ -59,6 +61,8 @@ app.use('/api/equipments', equipmentRoutes); app.use('/api/tasks', taskRoutes); app.use('/api/vacations', vacationRoutes); app.use('/api/partners', partnerRoutes); +app.use('/api/vendors', vendorRoutes); +app.use('/api/consumable-items', consumableItemRoutes); app.use('/api/notification-recipients', notificationRecipientRoutes); // 404 diff --git a/user-management/api/middleware/upload.js b/user-management/api/middleware/upload.js index d1f65c5..29362cb 100644 --- a/user-management/api/middleware/upload.js +++ b/user-management/api/middleware/upload.js @@ -5,6 +5,7 @@ const multer = require('multer'); const path = require('path'); const crypto = require('crypto'); +const fs = require('fs'); const storage = multer.diskStorage({ destination: (req, file, cb) => { @@ -32,4 +33,26 @@ const upload = multer({ limits: { fileSize: 5 * 1024 * 1024 } }); +// 소모품 사진 업로드 +const consumablesDir = path.join(__dirname, '..', 'uploads', 'consumables'); +if (!fs.existsSync(consumablesDir)) { fs.mkdirSync(consumablesDir, { recursive: true }); } + +const consumableStorage = multer.diskStorage({ + destination: (req, file, cb) => { + cb(null, consumablesDir); + }, + filename: (req, file, cb) => { + const ext = path.extname(file.originalname).toLowerCase(); + const uniqueName = `consumable-${Date.now()}-${crypto.randomInt(100000000, 999999999)}${ext}`; + cb(null, uniqueName); + } +}); + +const consumableUpload = multer({ + storage: consumableStorage, + fileFilter, + limits: { fileSize: 5 * 1024 * 1024 } +}); + module.exports = upload; +module.exports.consumableUpload = consumableUpload; diff --git a/user-management/api/models/consumableItemModel.js b/user-management/api/models/consumableItemModel.js new file mode 100644 index 0000000..72a645b --- /dev/null +++ b/user-management/api/models/consumableItemModel.js @@ -0,0 +1,56 @@ +const { getPool } = require('./userModel'); + +// ===== 소모품 마스터 ===== + +async function findAll({ category, search, is_active } = {}) { + const db = getPool(); + let sql = 'SELECT * FROM consumable_items WHERE 1=1'; + const params = []; + if (is_active !== undefined) { sql += ' AND is_active = ?'; params.push(is_active); } + if (category) { sql += ' AND category = ?'; params.push(category); } + if (search) { sql += ' AND (item_name LIKE ? OR maker LIKE ?)'; params.push(`%${search}%`, `%${search}%`); } + sql += ' ORDER BY category, item_name'; + const [rows] = await db.query(sql, params); + return rows; +} + +async function findById(id) { + const db = getPool(); + const [rows] = await db.query('SELECT * FROM consumable_items WHERE item_id = ?', [id]); + return rows[0] || null; +} + +async function create(data) { + const db = getPool(); + const [result] = await db.query( + `INSERT INTO consumable_items (item_name, maker, category, base_price, unit, photo_path) + VALUES (?, ?, ?, ?, ?, ?)`, + [data.item_name, data.maker || null, data.category, + data.base_price || 0, data.unit || 'EA', data.photo_path || null] + ); + return findById(result.insertId); +} + +async function update(id, data) { + const db = getPool(); + const fields = []; + const values = []; + if (data.item_name !== undefined) { fields.push('item_name = ?'); values.push(data.item_name); } + if (data.maker !== undefined) { fields.push('maker = ?'); values.push(data.maker || null); } + if (data.category !== undefined) { fields.push('category = ?'); values.push(data.category); } + if (data.base_price !== undefined) { fields.push('base_price = ?'); values.push(data.base_price); } + if (data.unit !== undefined) { fields.push('unit = ?'); values.push(data.unit || 'EA'); } + if (data.photo_path !== undefined) { fields.push('photo_path = ?'); values.push(data.photo_path || null); } + if (data.is_active !== undefined) { fields.push('is_active = ?'); values.push(data.is_active); } + if (fields.length === 0) return findById(id); + values.push(id); + await db.query(`UPDATE consumable_items SET ${fields.join(', ')} WHERE item_id = ?`, values); + return findById(id); +} + +async function deactivate(id) { + const db = getPool(); + await db.query('UPDATE consumable_items SET is_active = FALSE WHERE item_id = ?', [id]); +} + +module.exports = { findAll, findById, create, update, deactivate }; diff --git a/user-management/api/models/vendorModel.js b/user-management/api/models/vendorModel.js new file mode 100644 index 0000000..916b7a9 --- /dev/null +++ b/user-management/api/models/vendorModel.js @@ -0,0 +1,59 @@ +const { getPool } = require('./userModel'); + +// ===== 업체(공급업체) ===== + +async function findAll({ search, is_active } = {}) { + const db = getPool(); + let sql = 'SELECT * FROM vendors WHERE 1=1'; + const params = []; + if (is_active !== undefined) { sql += ' AND is_active = ?'; params.push(is_active); } + if (search) { sql += ' AND (vendor_name LIKE ? OR business_number LIKE ? OR contact_name LIKE ?)'; params.push(`%${search}%`, `%${search}%`, `%${search}%`); } + sql += ' ORDER BY vendor_name'; + const [rows] = await db.query(sql, params); + return rows; +} + +async function findById(id) { + const db = getPool(); + const [rows] = await db.query('SELECT * FROM vendors WHERE vendor_id = ?', [id]); + return rows[0] || null; +} + +async function create(data) { + const db = getPool(); + const [result] = await db.query( + `INSERT INTO vendors (vendor_name, business_number, representative, contact_name, contact_phone, address, bank_name, bank_account, notes) + VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`, + [data.vendor_name, data.business_number || null, data.representative || null, + data.contact_name || null, data.contact_phone || null, data.address || null, + data.bank_name || null, data.bank_account || null, data.notes || null] + ); + return findById(result.insertId); +} + +async function update(id, data) { + const db = getPool(); + const fields = []; + const values = []; + if (data.vendor_name !== undefined) { fields.push('vendor_name = ?'); values.push(data.vendor_name); } + if (data.business_number !== undefined) { fields.push('business_number = ?'); values.push(data.business_number || null); } + if (data.representative !== undefined) { fields.push('representative = ?'); values.push(data.representative || null); } + if (data.contact_name !== undefined) { fields.push('contact_name = ?'); values.push(data.contact_name || null); } + if (data.contact_phone !== undefined) { fields.push('contact_phone = ?'); values.push(data.contact_phone || null); } + if (data.address !== undefined) { fields.push('address = ?'); values.push(data.address || null); } + if (data.bank_name !== undefined) { fields.push('bank_name = ?'); values.push(data.bank_name || null); } + if (data.bank_account !== undefined) { fields.push('bank_account = ?'); values.push(data.bank_account || null); } + if (data.notes !== undefined) { fields.push('notes = ?'); values.push(data.notes || null); } + if (data.is_active !== undefined) { fields.push('is_active = ?'); values.push(data.is_active); } + if (fields.length === 0) return findById(id); + values.push(id); + await db.query(`UPDATE vendors SET ${fields.join(', ')} WHERE vendor_id = ?`, values); + return findById(id); +} + +async function deactivate(id) { + const db = getPool(); + await db.query('UPDATE vendors SET is_active = FALSE WHERE vendor_id = ?', [id]); +} + +module.exports = { findAll, findById, create, update, deactivate }; diff --git a/user-management/api/routes/consumableItemRoutes.js b/user-management/api/routes/consumableItemRoutes.js new file mode 100644 index 0000000..dec6449 --- /dev/null +++ b/user-management/api/routes/consumableItemRoutes.js @@ -0,0 +1,15 @@ +const express = require('express'); +const router = express.Router(); +const { requireAuth, requireAdmin } = require('../middleware/auth'); +const ctrl = require('../controllers/consumableItemController'); +const { consumableUpload } = require('../middleware/upload'); + +router.use(requireAuth); + +router.get('/', ctrl.list); +router.get('/:id', ctrl.getById); +router.post('/', requireAdmin, consumableUpload.single('photo'), ctrl.create); +router.put('/:id', requireAdmin, consumableUpload.single('photo'), ctrl.update); +router.delete('/:id', requireAdmin, ctrl.deactivate); + +module.exports = router; diff --git a/user-management/api/routes/vendorRoutes.js b/user-management/api/routes/vendorRoutes.js new file mode 100644 index 0000000..31e0877 --- /dev/null +++ b/user-management/api/routes/vendorRoutes.js @@ -0,0 +1,14 @@ +const express = require('express'); +const router = express.Router(); +const { requireAuth, requireAdmin } = require('../middleware/auth'); +const ctrl = require('../controllers/vendorController'); + +router.use(requireAuth); + +router.get('/', ctrl.list); +router.get('/:id', ctrl.getById); +router.post('/', requireAdmin, ctrl.create); +router.put('/:id', requireAdmin, ctrl.update); +router.delete('/:id', requireAdmin, ctrl.deactivate); + +module.exports = router; diff --git a/user-management/web/index.html b/user-management/web/index.html index e2cc492..1397a90 100644 --- a/user-management/web/index.html +++ b/user-management/web/index.html @@ -64,6 +64,12 @@ + + @@ -1482,6 +1488,70 @@ + + + + + + + + + + + + + + + + + +