This commit is contained in:
nguyentrungthat 2025-11-05 11:07:04 +07:00
parent 9c4d8d4041
commit 21cb42ebc0
2 changed files with 9 additions and 0 deletions

View File

@ -83,6 +83,14 @@ export default class StationsController {
await station.save()
if (lines && Array.isArray(lines)) {
// Xóa những line không còn trong payload
const existingLines = await station.related('lines').query()
const existingLineIds = existingLines.map((line) => line.id)
const linesToKeepIds = lines.filter((line) => line.id).map((line) => line.id)
const linesToDeleteIds = existingLineIds.filter((id) => !linesToKeepIds.includes(id))
if (linesToDeleteIds.length > 0) {
await Line.query().whereIn('id', linesToDeleteIds).delete()
}
lines.forEach(async (line) => {
if (line.id) {
const value = await Line.find(line.id)

View File

@ -138,6 +138,7 @@ export default class LineConnection {
this.client.on('close', () => {
console.log(`🔌 Line ${lineNumber} disconnected`)
this.config.status = 'disconnected'
this.config.inventory = undefined
this.socketIO.emit('line_disconnected', {
stationId,
lineId: id,