munawwirul_jamal/simrsx-be
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rename package

Browse Source
This commit is contained in:
vanilia
2025-11-18 13:51:27 +07:00
parent 7b170deffb
commit 94314e641d
5 changed files with 26 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

internal/use-case/simgos-sync-use-case/division/case.go
+5 -5
View File
@@ -6,7 +6,7 @@ import (
d "github.com/karincake/dodol" d "github.com/karincake/dodol"
"gorm.io/gorm" "gorm.io/gorm"
dualtx "simrs-vx/pkg/dualtrx-helper" db "simrs-vx/pkg/dualtrx-helper"
e "simrs-vx/internal/domain/main-entities/division" e "simrs-vx/internal/domain/main-entities/division"
esimgos "simrs-vx/internal/domain/simgos-entities/division" esimgos "simrs-vx/internal/domain/simgos-entities/division"
@@ -31,7 +31,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 1: Insert to simgos // STEP 1: Insert to simgos
sgData, err = CreateSimgosData(input, &event, tx.Simgos) sgData, err = CreateSimgosData(input, &event, tx.Simgos)
if err != nil { if err != nil {
@@ -74,7 +74,7 @@ func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
tx := dualtx.NewTx() tx := db.NewTx()
err := tx.Sync.Transaction(func(tx *gorm.DB) error { err := tx.Sync.Transaction(func(tx *gorm.DB) error {
// Insert to Log // Insert to Log
if err := CreateLogData(input, &event, tx); err != nil { if err := CreateLogData(input, &event, tx); err != nil {
@@ -114,7 +114,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
return nil, err return nil, err
} }
tx := dualtx.NewTx() tx := db.NewTx()
err = tx.Simgos.Transaction(func(tx *gorm.DB) error { err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
// Step 2: Update Simgos // Step 2: Update Simgos
if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil { if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil {
@@ -158,7 +158,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
return nil, err return nil, err
} }
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 3: Delete Simgos // STEP 3: Delete Simgos
err = HardDeleteSimgosData(sgData, &event, tx.Simgos) err = HardDeleteSimgosData(sgData, &event, tx.Simgos)
if err != nil { if err != nil {
internal/use-case/simgos-sync-use-case/installation/case.go
+5 -5
View File
@@ -7,7 +7,7 @@ import (
"gorm.io/gorm" "gorm.io/gorm"
dualtx "simrs-vx/pkg/dualtrx-helper" db "simrs-vx/pkg/dualtrx-helper"
e "simrs-vx/internal/domain/main-entities/installation" e "simrs-vx/internal/domain/main-entities/installation"
esimgos "simrs-vx/internal/domain/simgos-entities/installation" esimgos "simrs-vx/internal/domain/simgos-entities/installation"
@@ -32,7 +32,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 1: Insert to simgos // STEP 1: Insert to simgos
sgData, err = CreateSimgosData(input, &event, tx.Simgos) sgData, err = CreateSimgosData(input, &event, tx.Simgos)
if err != nil { if err != nil {
@@ -75,7 +75,7 @@ func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
tx := dualtx.NewTx() tx := db.NewTx()
err := tx.Sync.Transaction(func(tx *gorm.DB) error { err := tx.Sync.Transaction(func(tx *gorm.DB) error {
// Insert to Log // Insert to Log
if err := CreateLogData(input, &event, tx); err != nil { if err := CreateLogData(input, &event, tx); err != nil {
@@ -115,7 +115,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
return nil, err return nil, err
} }
tx := dualtx.NewTx() tx := db.NewTx()
err = tx.Simgos.Transaction(func(tx *gorm.DB) error { err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
// Step 2: Update Simgos // Step 2: Update Simgos
if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil { if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil {
@@ -159,7 +159,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
return nil, err return nil, err
} }
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 3: Delete Simgos // STEP 3: Delete Simgos
err = SoftDeleteSimgosData(sgData, &event, tx.Simgos) err = SoftDeleteSimgosData(sgData, &event, tx.Simgos)
if err != nil { if err != nil {
internal/use-case/simgos-sync-use-case/specialist/case.go
+5 -5
View File
@@ -6,7 +6,7 @@ import (
d "github.com/karincake/dodol" d "github.com/karincake/dodol"
"gorm.io/gorm" "gorm.io/gorm"
dualtx "simrs-vx/pkg/dualtrx-helper" db "simrs-vx/pkg/dualtrx-helper"
e "simrs-vx/internal/domain/main-entities/specialist" e "simrs-vx/internal/domain/main-entities/specialist"
esimgos "simrs-vx/internal/domain/simgos-entities/specialist" esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
@@ -31,7 +31,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 1: Insert to simgos // STEP 1: Insert to simgos
sgData, err = CreateSimgosData(input, &event, tx.Simgos) sgData, err = CreateSimgosData(input, &event, tx.Simgos)
if err != nil { if err != nil {
@@ -73,7 +73,7 @@ func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
tx := dualtx.NewTx() tx := db.NewTx()
err := tx.Sync.Transaction(func(tx *gorm.DB) error { err := tx.Sync.Transaction(func(tx *gorm.DB) error {
// Insert to Log // Insert to Log
if err := CreateLogData(input, &event, tx); err != nil { if err := CreateLogData(input, &event, tx); err != nil {
@@ -113,7 +113,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
return nil, err return nil, err
} }
tx := dualtx.NewTx() tx := db.NewTx()
err = tx.Simgos.Transaction(func(tx *gorm.DB) error { err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
// Step 2: Update Simgos // Step 2: Update Simgos
err = UpdateSimgosData(input, syncLink, &event, tx) err = UpdateSimgosData(input, syncLink, &event, tx)
@@ -158,7 +158,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
return nil, err return nil, err
} }
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 3: Delete Simgos // STEP 3: Delete Simgos
err = HardDeleteSimgosData(sgData, &event, tx.Simgos) err = HardDeleteSimgosData(sgData, &event, tx.Simgos)
if err != nil { if err != nil {
internal/use-case/simgos-sync-use-case/subspecialist/case.go
+6 -5
View File
@@ -1,12 +1,13 @@
package subspecialist package subspecialist
import ( import (
dualtx "simrs-vx/pkg/dualtrx-helper"
pl "simrs-vx/pkg/logger" pl "simrs-vx/pkg/logger"
d "github.com/karincake/dodol" d "github.com/karincake/dodol"
"gorm.io/gorm" "gorm.io/gorm"
db "simrs-vx/pkg/dualtrx-helper"
e "simrs-vx/internal/domain/main-entities/subspecialist" e "simrs-vx/internal/domain/main-entities/subspecialist"
//esimgos "simrs-vx/internal/domain/simgos-entities/specialist" //esimgos "simrs-vx/internal/domain/simgos-entities/specialist"
elog "simrs-vx/internal/domain/sync-entities/log" elog "simrs-vx/internal/domain/sync-entities/log"
@@ -30,7 +31,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
//err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { //err = db.WithDualTx(func(tx *db.Dualtx) error {
// // STEP 1: Insert to simgos // // STEP 1: Insert to simgos
// sgData, err = CreateSimgosData(input, &event, tx.Simgos) // sgData, err = CreateSimgosData(input, &event, tx.Simgos)
// if err != nil { // if err != nil {
@@ -73,7 +74,7 @@ func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
tx := dualtx.NewTx() tx := db.NewTx()
err := tx.Sync.Transaction(func(tx *gorm.DB) error { err := tx.Sync.Transaction(func(tx *gorm.DB) error {
// Insert to Log // Insert to Log
if err := CreateLogData(input, &event, tx); err != nil { if err := CreateLogData(input, &event, tx); err != nil {
@@ -115,7 +116,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
// return nil, err // return nil, err
//} //}
// //
//tx := dualtx.NewTx() //tx := db.NewTx()
//err = tx.Simgos.Transaction(func(tx *gorm.DB) error { //err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
// // Step 2: Update Simgos // // Step 2: Update Simgos
// if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil { // if err = UpdateSimgosData(input, syncLink, &event, tx); err != nil {
@@ -159,7 +160,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
// return nil, err // return nil, err
//} //}
// //
//err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { //err = db.WithDualTx(func(tx *db.Dualtx) error {
// // STEP 3: Delete Simgos // // STEP 3: Delete Simgos
// err = HardDeleteSimgosData(sgData, &event, tx.Simgos) // err = HardDeleteSimgosData(sgData, &event, tx.Simgos)
// if err != nil { // if err != nil {
internal/use-case/simgos-sync-use-case/unit/case.go
+5 -5
View File
@@ -6,7 +6,7 @@ import (
d "github.com/karincake/dodol" d "github.com/karincake/dodol"
"gorm.io/gorm" "gorm.io/gorm"
dualtx "simrs-vx/pkg/dualtrx-helper" db "simrs-vx/pkg/dualtrx-helper"
e "simrs-vx/internal/domain/main-entities/unit" e "simrs-vx/internal/domain/main-entities/unit"
esimgos "simrs-vx/internal/domain/simgos-entities/unit" esimgos "simrs-vx/internal/domain/simgos-entities/unit"
@@ -31,7 +31,7 @@ func Create(input e.CreateDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 1: Insert to simgos // STEP 1: Insert to simgos
sgData, err = CreateSimgosData(input, &event, tx.Simgos) sgData, err = CreateSimgosData(input, &event, tx.Simgos)
if err != nil { if err != nil {
@@ -74,7 +74,7 @@ func CreateSimxLog(input elog.SimxLogDto) (*d.Data, error) {
// Start log // Start log
pl.SetLogInfo(&event, input, "started", "create") pl.SetLogInfo(&event, input, "started", "create")
tx := dualtx.NewTx() tx := db.NewTx()
err := tx.Sync.Transaction(func(tx *gorm.DB) error { err := tx.Sync.Transaction(func(tx *gorm.DB) error {
// Insert to Log // Insert to Log
if err := CreateLogData(input, &event, tx); err != nil { if err := CreateLogData(input, &event, tx); err != nil {
@@ -114,7 +114,7 @@ func Update(input e.UpdateDto) (*d.Data, error) {
return nil, err return nil, err
} }
tx := dualtx.NewTx() tx := db.NewTx()
err = tx.Simgos.Transaction(func(tx *gorm.DB) error { err = tx.Simgos.Transaction(func(tx *gorm.DB) error {
// Step 2: Update Simgos // Step 2: Update Simgos
err = UpdateSimgosData(input, syncLink, &event, tx) err = UpdateSimgosData(input, syncLink, &event, tx)
@@ -159,7 +159,7 @@ func Delete(input e.DeleteDto) (*d.Data, error) {
return nil, err return nil, err
} }
err = dualtx.WithDualTx(func(tx *dualtx.Dualtx) error { err = db.WithDualTx(func(tx *db.Dualtx) error {
// STEP 3: Delete M_Poly Simgos // STEP 3: Delete M_Poly Simgos
err = HardDeleteSimgosData(sgData, &event, tx.Simgos) err = HardDeleteSimgosData(sgData, &event, tx.Simgos)
if err != nil { if err != nil {