Add prepid insertion in bulkblocks API

dmwm · Apr 12, 2022 · 6c4220e · 6c4220e
1 parent c4179e5
commit 6c4220e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/dbs/bulkblocks.go b/dbs/bulkblocks.go
@@ -438,6 +438,7 @@ func (a *API) InsertBulkBlocks() error {
 		PROCESSING_ERA_ID:      processingEraID,
 		PHYSICS_GROUP_ID:       physicsGroupID,
 		XTCROSSSECTION:         rec.Dataset.Xtcrosssection,
+		PREP_ID:                rec.Dataset.PrepID,
 		CREATION_DATE:          rec.Dataset.CreationDate,
 		CREATE_BY:              rec.Dataset.CreateBy,
 		LAST_MODIFICATION_DATE: creationDate,

diff --git a/dbs/bulkblocks2.go b/dbs/bulkblocks2.go
@@ -384,6 +384,7 @@ func getDatasetID(
 	processingEraID int64,
 	physicsGroupID int64,
 	xtcrosssection float64,
+	prepId string,
 	creationDate int64,
 	createBy string,
 	lastModificationDate int64,
@@ -410,6 +411,7 @@ func getDatasetID(
 		PROCESSING_ERA_ID:      processingEraID,
 		PHYSICS_GROUP_ID:       physicsGroupID,
 		XTCROSSSECTION:         xtcrosssection,
+		PREP_ID:                prepId,
 		CREATION_DATE:          creationDate,
 		CREATE_BY:              createBy,
 		LAST_MODIFICATION_DATE: lastModificationDate,
@@ -578,6 +580,7 @@ func (a *API) InsertBulkBlocksConcurrently() error {
 		processingEraID,
 		physicsGroupID,
 		rec.Dataset.Xtcrosssection,
+		rec.Dataset.PrepID,
 		rec.Dataset.CreationDate,
 		rec.Dataset.CreateBy,
 		creationDate,