From 77c7d0574b2c996edb97f768a82eeddca253b4de Mon Sep 17 00:00:00 2001 From: x2Skyz Date: Mon, 17 Nov 2025 18:34:30 +0700 Subject: [PATCH] =?UTF-8?q?-=20=E0=B9=80=E0=B8=9E=E0=B8=B4=E0=B9=88?= =?UTF-8?q?=E0=B8=A1=20interface=20prjmst=20-=20=E0=B9=80=E0=B8=9E?= =?UTF-8?q?=E0=B8=B4=E0=B9=88=E0=B8=A1=20interface=20trnmst?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- exthernal-ttc-api/src/interfaces/Interface.js | 4 + .../src/interfaces/table/prjmstInterface.js | 84 +++++++++++++++++++ .../src/interfaces/table/trnmstInterface.js | 84 +++++++++++++++++++ 3 files changed, 172 insertions(+) create mode 100644 exthernal-ttc-api/src/interfaces/table/prjmstInterface.js create mode 100644 exthernal-ttc-api/src/interfaces/table/trnmstInterface.js diff --git a/exthernal-ttc-api/src/interfaces/Interface.js b/exthernal-ttc-api/src/interfaces/Interface.js index 1978a85..505e9df 100644 --- a/exthernal-ttc-api/src/interfaces/Interface.js +++ b/exthernal-ttc-api/src/interfaces/Interface.js @@ -1,5 +1,7 @@ import jwt from 'jsonwebtoken' import { BdgmstInterface } from './table/bdgmstInterface.js' +import { PrjmstInterface } from './table/prjmstInterface.js' +import { TrnmstInterface } from './table/trnmstInterface.js' import { sendError } from '../utils/response.js' // import { ActmstInterface } from './actmstInterface.js' @@ -13,6 +15,8 @@ export class Interface { constructor() { this.map = { bdgmst: new BdgmstInterface(), + prjmst: new PrjmstInterface(), + trnmst: new TrnmstInterface(),ห // actmst: new ActmstInterface(), } } diff --git a/exthernal-ttc-api/src/interfaces/table/prjmstInterface.js b/exthernal-ttc-api/src/interfaces/table/prjmstInterface.js new file mode 100644 index 0000000..683c312 --- /dev/null +++ b/exthernal-ttc-api/src/interfaces/table/prjmstInterface.js @@ -0,0 +1,84 @@ +import { GeneralService } from '../../share/generalservice.js' + +export class PrjmstInterface { + + constructor() { + this.general = new GeneralService() + this.table = 'prjmst' + this.pk = ['prjseq', 'prjnam'] + } + + async saveInterface(database, data) { + const method = data.methods.toLowerCase() + const { methods, ...payload } = data + + if (method === 'put') return this.update(database, payload) + if (method === 'post') return this.insert(database, payload) + if (method === 'delete') return this.remove(database, payload) + + throw new Error(`Unknown method: ${method}`) + } + + async insert(database, payload) { + const cols = Object.keys(payload) + const vals = Object.values(payload) + const placeholders = cols.map((_, i) => `$${i + 1}`).join(', ') + + const sql = ` + INSERT INTO ${database}.${this.table} (${cols.join(', ')}) + VALUES (${placeholders}) + RETURNING * + ` + return await this.general.executeQueryParam(database, sql, vals) + } + + async update(database, payload) { + const where = {} + const update = {} + + for (const col in payload) { + if (this.pk.includes(col)) where[col] = payload[col] + else update[col] = payload[col] + } + + const setCols = Object.keys(update) + .map((col, i) => `${col} = $${i + 1}`) + .join(', ') + + const whereCols = Object.keys(where) + .map((col, i) => `${col} = $${i + 1 + Object.keys(update).length}`) + .join(' AND ') + + const params = [...Object.values(update), ...Object.values(where)] + + const sql = ` + UPDATE ${database}.${this.table} + SET ${setCols} + WHERE ${whereCols} + RETURNING * + ` + return await this.general.executeQueryParam(database, sql, params) + } + + async remove(database, payload) { + const where = {} + + this.pk.forEach(pk => { + if (!payload[pk]) throw new Error(`Missing PK: ${pk}`) + where[pk] = payload[pk] + }) + + const whereCols = Object.keys(where) + .map((col, i) => `${col} = $${i + 1}`) + .join(' AND ') + + const params = Object.values(where) + + const sql = ` + DELETE FROM ${database}.${this.table} + WHERE ${whereCols} + RETURNING * + ` + return await this.general.executeQueryParam(database, sql, params) + } +} diff --git a/exthernal-ttc-api/src/interfaces/table/trnmstInterface.js b/exthernal-ttc-api/src/interfaces/table/trnmstInterface.js new file mode 100644 index 0000000..551f9c5 --- /dev/null +++ b/exthernal-ttc-api/src/interfaces/table/trnmstInterface.js @@ -0,0 +1,84 @@ +import { GeneralService } from '../../share/generalservice.js' + +export class TrnmstInterface { + + constructor() { + this.general = new GeneralService() + this.table = 'trnmst' + this.pk = ['trnseq', 'trnprjnam'] // ⭐ PK จาก table + } + + async saveInterface(database, data) { + const method = data.methods.toLowerCase() + const { methods, ...payload } = data + + if (method === 'put') return this.update(database, payload) + if (method === 'post') return this.insert(database, payload) + if (method === 'delete') return this.remove(database, payload) + + throw new Error(`Unknown method: ${method}`) + } + + async insert(database, payload) { + const cols = Object.keys(payload) + const vals = Object.values(payload) + const placeholders = cols.map((_, i) => `$${i + 1}`).join(', ') + + const sql = ` + INSERT INTO ${database}.${this.table} (${cols.join(', ')}) + VALUES (${placeholders}) + RETURNING * + ` + return await this.general.executeQueryParam(database, sql, vals) + } + + async update(database, payload) { + const where = {} + const update = {} + + for (const col in payload) { + if (this.pk.includes(col)) where[col] = payload[col] + else update[col] = payload[col] + } + + const setCols = Object.keys(update) + .map((col, i) => `${col} = $${i + 1}`) + .join(', ') + + const whereCols = Object.keys(where) + .map((col, i) => `${col} = $${i + 1 + Object.keys(update).length}`) + .join(' AND ') + + const params = [...Object.values(update), ...Object.values(where)] + + const sql = ` + UPDATE ${database}.${this.table} + SET ${setCols} + WHERE ${whereCols} + RETURNING * + ` + return await this.general.executeQueryParam(database, sql, params) + } + + async remove(database, payload) { + const where = {} + + this.pk.forEach(pk => { + if (!payload[pk]) throw new Error(`Missing PK: ${pk}`) + where[pk] = payload[pk] + }) + + const whereCols = Object.keys(where) + .map((col, i) => `${col} = $${i + 1}`) + .join(' AND ') + + const params = Object.values(where) + + const sql = ` + DELETE FROM ${database}.${this.table} + WHERE ${whereCols} + RETURNING * + ` + return await this.general.executeQueryParam(database, sql, params) + } +}