diff --git a/api/signal.go b/api/signal.go index 6c900849..16e8c64f 100644 --- a/api/signal.go +++ b/api/signal.go @@ -94,7 +94,7 @@ func listSignal(ctx context.Context, r *http.Request, user platform.User, query /* rows, err := models.Signals.Query( - models.SelectWhere.Signals.OrganizationID.EQ(org.ID), + models.SelectWhere.Signals.OrganizationID.EQ(org.ID()), sm.OrderBy("created").Desc(), ).All(ctx, db.PGInstance.BobDB) */ diff --git a/db/fieldseeker.go b/db/fieldseeker.go index 3395e56c..165c4aa9 100644 --- a/db/fieldseeker.go +++ b/db/fieldseeker.go @@ -58,7 +58,7 @@ func SaveOrUpdateContainerRelate(ctx context.Context, org *models.Organization, } return []SqlParam{ Uint("p_objectid", row.ObjectID), - Int32("p_organization_id", org.ID), + Int32("p_organization_id", org.ID()), UUID("p_globalid", row.GlobalID), String("p_created_user", row.CreatedUser), Timestamp("p_created_date", row.CreatedDate), diff --git a/platform/upload.go b/platform/upload.go index 1b4407ba..95117e58 100644 --- a/platform/upload.go +++ b/platform/upload.go @@ -93,7 +93,7 @@ func UploadCommit(ctx context.Context, org Organization, file_id int32, committe um.SetCol("status").ToArg("committing"), um.SetCol("committer").ToArg(committer.ID), um.Where(psql.Quote("id").EQ(psql.Arg(file_id))), - um.Where(psql.Quote("organization_id").EQ(psql.Arg(org.ID))), + um.Where(psql.Quote("organization_id").EQ(psql.Arg(org.ID()))), ).Exec(ctx, txn) if err != nil { return fmt.Errorf("update upload: %w", err) @@ -111,7 +111,7 @@ func UploadDiscard(ctx context.Context, org Organization, file_id int32) error { um.Table(models.FileuploadFiles.Alias()), um.SetCol("status").ToArg("discarded"), um.Where(psql.Quote("id").EQ(psql.Arg(file_id))), - um.Where(psql.Quote("organization_id").EQ(psql.Arg(org.ID))), + um.Where(psql.Quote("organization_id").EQ(psql.Arg(org.ID()))), ).Exec(ctx, db.PGInstance.BobDB) return err }