+ pkg multer, archiver

+ ระบบ uploads ที่เือบสมบูร
This commit is contained in:
x2Skyz
2025-11-30 19:28:03 +07:00
parent b32515779f
commit e881d7311b
6 changed files with 60 additions and 15 deletions

View File

@@ -30,20 +30,28 @@ export class projectAdd {
let token = req.headers.authorization?.split(' ')[1];
const decoded = verifyToken(token);
let name = req.body.request.prjnam;
database = decoded.organization;
// ✅ รองรับทั้ง JSON { request: {...} } และ Form-Data (Flat body)
const requestData = req.body.request ? req.body.request : req.body;
let name = requestData.prjnam;
// Override Database จาก Token ตาม Pattern เดิม
database = decoded.organization || 'dbo';
aryResult = await this.projectAddService.getProjectAdd(database, name);
latSeq = await this.projectAddService.getLatestProjectSeq(database);
// this.generalService.devhint(1, 'budgetSearch.js', 'Login success');
} catch (error) {
idx = 1;
console.error(error); // เพิ่ม log error เพื่อ debug
} finally {
if (idx === 1) return sendError('เกิดข้อผิดพลาดไม่คาดคิดเกิดขึ้น', 'Unexpected error');
// if (!aryResult) return sendError('ไม่พบการมีอยู่ของข้อมูล', 'Cannot Find Any Data');
if (aryResult == 0) {
let prommis = await this.makeArySave(req, latSeq[0].prjseq);
// ส่ง latSeq เข้าไป (ต้อง handle กรณี null ถ้า table ว่าง)
const currentSeq = (latSeq && latSeq[0] && latSeq[0].prjseq) ? latSeq[0].prjseq : 0;
let prommis = await this.makeArySave(req, currentSeq);
return prommis
} else {
return sendError('คีย์หลักซ้ำในระบบ', 'Duplicate Primary Key');
@@ -53,17 +61,38 @@ export class projectAdd {
async makeArySave(req, latseq) {
// Extract Data ให้รองรับทั้ง 2 แบบ
const requestData = req.body.request ? req.body.request : req.body;
// ✅ แก้ไข: Sanitise Input ป้องกัน Error numeric: ""
// ถ้าเป็นค่าว่าง ให้แปลงเป็น null หรือ 0.00 ตามประเภทข้อมูล
const prjwntbdg = (requestData.prjwntbdg && requestData.prjwntbdg !== '') ? requestData.prjwntbdg : '0.00';
const prjusrseq = (requestData.prjusrseq && requestData.prjusrseq !== '') ? requestData.prjusrseq : null;
let arysave = {
methods: 'post',
prjseq: latseq+1,
prjnam: req.body.request.prjnam,
prjusrseq: req.body.request.prjusrseq,
prjwntbdg: req.body.request.prjwntbdg,
prjseq: latseq + 1,
prjnam: requestData.prjnam,
prjusrseq: prjusrseq,
prjwntbdg: prjwntbdg,
prjacpbdg: '0.00',
prjbdgcod: '',
prjcomstt: req.body.request.prjcomstt,
prjacpdtm: req.body.request.prjacpdtm
prjcomstt: requestData.prjcomstt || 'UAC', // Default UAC ถ้ายิงมาแค่ชื่อกับงบ
prjacpdtm: requestData.prjacpdtm || null
}
// เพิ่ม Logic จัดการไฟล์
if (req.file) {
arysave.prjdoc = req.file.filename // บันทึกชื่อไฟล์ลง DB
}
// กรณี User Seq ไม่ได้ส่งมา (เป็น null) ให้ใช้จาก Token
if (!arysave.prjusrseq) {
const token = req.headers.authorization?.split(' ')[1];
const decoded = verifyToken(token);
if (decoded) arysave.prjusrseq = decoded.id;
}
return this.Interface.saveInterface('prjmst', arysave, req);
}
}
}