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)
+  }
+}