*: added projectEdit and tweaking projectSearch

added useredit param into projectSearchController.js, also use switch case instead of if-else. projectEdit is still not working yet

Signed-off-by: supphakitd <67319010028@technictrang.ac.th>

exthernal-ttc-api/src/controllers/projectEditController.js

@@ -0,0 +1,128 @@
+import { ProjectEditService } from '../services/projectEditService.js'
+import { sendError } from '../utils/response.js'
+import { GeneralService } from '../share/generalservice.js';
+import { trim_all_array } from '../utils/trim.js'
+import { verifyToken, generateToken } from '../utils/token.js'
+import { Interface } from '../interfaces/Interface.js';
+import fs from 'fs';
+import path from 'path';
+import { getDTM } from '../utils/date.js';
+
+
+export class projectEdit {
+
+  constructor() {
+    this.generalService = new GeneralService();
+    this.Interface = new Interface();
+    this.projectEditService = new ProjectEditService();
+  }
+
+  async onNavigate(req, res) {
+    this.generalService.devhint(1, 'projectAdd.js', 'onNavigate() start');
+    
+    let organization = req.body.organization;
+    const prommis = await this.onProjectEdit(req, res, organization);
+    return prommis;
+  }
+
+  async onProjectEdit(req, res, database) {
+    let idx = -1
+    let aryResult = []
+    let latSeq = []
+    try {
+      let token = req.headers.authorization?.split(' ')[1];
+      const decoded = verifyToken(token);
+
+      const requestData = req.body; 
+      let name = requestData.prjnam;
+      
+      database = decoded.organization || 'dbo';
+
+      aryResult = await this.projectEditService.getProjectEdit(database, name);
+      latSeq = await this.projectEditService.getLatestProjectSeq(database);
+
+    } catch (error) {
+      idx = 1;
+      console.error(error);
+    } finally {
+      if (idx === 1) return sendError('เกิดข้อผิดพลาดไม่คาดคิดเกิดขึ้น', 'Unexpected error');
+
+      if (aryResult == 0) {
+        const currentSeq = (latSeq && latSeq[0] && latSeq[0].prjseq) ? latSeq[0].prjseq : 0;
+        let prommis = await this.makeArySave(req, currentSeq);
+        return prommis
+      } else {
+        if (req.files) {
+            req.files.forEach(f => {
+                if (fs.existsSync(f.path)) fs.unlinkSync(f.path);
+            });
+        }
+        return sendError('คีย์หลักซ้ำในระบบ', 'Duplicate Primary Key');
+      }
+    }
+  }
+
+  async makeArySave(req, latseq) {
+    const requestData = req.body;
+    const nextSeq = latseq + 1;
+
+    let prjwntbdg = requestData.prjwntbdg;
+    if (!prjwntbdg || prjwntbdg === '' || prjwntbdg === 'undefined' || prjwntbdg === 'null') {
+        prjwntbdg = '0.00';
+    }
+
+    let prjusrseq = requestData.prjusrseq;
+    if (!prjusrseq || prjusrseq === '' || prjusrseq === 'undefined' || prjusrseq === 'null') {
+        prjusrseq = null;
+    }
+
+    const typ = requestData.typ; 
+
+    let arysave = {
+      methods: 'post',
+      prjseq: nextSeq,
+      prjnam: requestData.prjnam,
+      prjusrseq: prjusrseq, 
+      prjwntbdg: prjwntbdg,
+      prjacpbdg: '0.00',
+      prjbdgcod: '',
+      prjcomstt: requestData.prjcomstt || 'UAC',
+      prjacpdtm: getDTM(),
+    }
+
+    let savedFileNames = [];
+    if (req.files && req.files.length > 0) {
+        if (typ === 'prj') {
+            const targetDir = `uploads/projects/${nextSeq}`;
+            
+            try {
+                if (!fs.existsSync(targetDir)) {
+                    fs.mkdirSync(targetDir, { recursive: true });
+                }
+
+                req.files.forEach(file => {
+                    const targetPath = path.join(targetDir, file.filename);
+                    fs.renameSync(file.path, targetPath);
+                    savedFileNames.push(file.filename);
+                });
+                
+                arysave.prjdoc = savedFileNames.join(',');
+
+            } catch (err) {
+                console.error('Error moving files:', err);
+                return sendError('ไม่สามารถบันทึกไฟล์ลงโฟลเดอร์โครงการได้');
+            }
+        } else {
+            arysave.prjdoc = req.files.map(f => f.filename).join(',');
+        }
+    }
+
+    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);
+  }
+}

exthernal-ttc-api/src/controllers/projectSearchController.js

@@ -23,6 +23,7 @@ export class projectSearch {
     let idx = -1
     let aryResult = []
     let condition = {}
+    let column = ""
     try {
       let token = req.headers.authorization?.split(' ')[1];
       const decoded = verifyToken(token);
@@ -31,10 +32,11 @@ export class projectSearch {
       database = decoded.organization || database
 
       let columnParams = req.query.column
+      condition['prjseq'] = req.body.request.prjseq;
 
-  
-      if (columnParams == 'user') {
-        let column = `prjseq, prjnam, prjwntbdg, prjcomstt, prjacpdtm,
+      switch (columnParams) {
+        case "user":
+          column = `prjseq, prjnam, prjwntbdg, prjcomstt, prjacpdtm,
           (
            SELECT trnacpdtm 
             FROM ${database}.trnmst t 
@@ -42,24 +44,21 @@ export class projectSearch {
             ORDER BY trnacpdtm DESC 
             LIMIT 1
           ) as trnacpdtm`
-        condition['prjusrseq'] = req.body.request.prjusrseq || decoded.id
-        // เรียก Service ตัวเดิม (Simple)
-        aryResult = await this.projectSearchService.getProjectSearch(database, column, condition);
+          aryResult = await this.projectSearchService.getProjectSearch(database, column, condition);
+          break;
 
-      } else if (columnParams == 'edit') {
-        let column = `prjseq, prjnam, prjwntbdg, prjcomstt`
-        condition['prjseq'] = req.body.request.prjseq
+        case "edit":
+          column = `prjseq, prjnam, prjwntbdg, prjcomstt`
+          aryResult = await this.projectSearchService.getProjectSearch(database, column, condition);
+          break;
 
-        // เรียก Service ตัวเดิม (Simple)
-        aryResult = await this.projectSearchService.getProjectSearch(database, column, condition);
+        case "useredit":
+          column = `prjseq, prjnam, prjwntbdg, prjdoc`
+          aryResult = await this.projectSearchService.getProjectSearch(database, column, condition);
+          break;
 
-      } else if (columnParams == 'result' || columnParams == undefined || columnParams == '') {
-        
-        // กำหนดเงื่อนไข (ถ้ามีส่งมา)
-        condition['prjseq'] = req.body.request.prjseq;
-        
-        //  สร้าง Column String ที่มี Subquery ดึงงบจาก trnmst
-        let column = `
+        default:
+          column = `
           prjseq, 
           prjnam, 
           usrthinam as prjusrnam, 
@@ -83,9 +82,8 @@ export class projectSearch {
           prjcomstt,
           prjacpdtm
         `;
-
-        // ใช้ Service ตัวใหม่ (Detail Search / Join)
-        aryResult = await this.projectSearchService.getProjectDetailSearch(database, column, condition);
+          aryResult = await this.projectSearchService.getProjectDetailSearch(database, column, condition);
+          break;
       }
 
     } catch (error) {

exthernal-ttc-api/src/routes/route.js

@@ -39,6 +39,11 @@ router.post('/projectadd', uploadMiddleware, async (req, res) => {
   if (result) return res.json(result)
 })
 
+router.post('/projectedit', uploadMiddleware, async (req, res) => {
+  const result = await controller_projectAdd_post.onNavigate(req, res)
+  if (result) return res.json(result)
+})
+
 router.get('/projectdownload', async (req, res) => {
     // ไม่ต้อง return res.json() เพราะ Controller จัดการ Stream แล้ว
     await controller_projectDownload_get.onNavigate(req, res)

exthernal-ttc-api/src/services/projectEditService.js

@@ -0,0 +1,34 @@
+import { GeneralService } from '../share/generalservice.js'
+
+export class ProjectEditService {
+
+  constructor() {
+    this.generalService = new GeneralService()
+  }
+
+  async getProjectEdit(database, name) {
+    const sql = `
+      SELECT 
+        prjseq,
+        prjnam
+      FROM ${database}.prjmst
+      WHERE prjnam = $1
+  `
+    const params = [name]
+    const result = await this.generalService.executeQueryParam(database, sql, params);
+    return result
+  }
+
+  async getLatestProjectSeq(database) {
+    const sql = `
+      SELECT 
+        prjseq
+      FROM ${database}.prjmst
+      WHERE prjseq=(SELECT max(prjseq) FROM ${database}.prjmst)
+    `
+
+    const params = []
+    const result = await this.generalService.executeQueryParam(database, sql, params);
+    return result
+  }
+}