add service

internal/repository/supplier.go

@@ -44,15 +44,30 @@ func (r *supplierRepository) bulkInsertWithExecutor(ctx context.Context, exec DB
 		query = query.Values(requestID, s.Name, s.Email, s.Phone, s.Address, s.URL)
 	}
 
+	query = query.Suffix("RETURNING id")
+
 	sqlQuery, args, err := query.ToSql()
 	if err != nil {
 		return errs.NewInternalError(errs.DatabaseError, "failed to build query", err)
 	}
 
-	_, err = exec.Exec(ctx, sqlQuery, args...)
+	rows, err := exec.Query(ctx, sqlQuery, args...)
 	if err != nil {
 		return errs.NewInternalError(errs.DatabaseError, "failed to bulk insert suppliers", err)
 	}
+	defer rows.Close()
+
+	i := 0
+	for rows.Next() {
+		if i >= len(suppliers) {
+			break
+		}
+		if err := rows.Scan(&suppliers[i].ID); err != nil {
+			return errs.NewInternalError(errs.DatabaseError, "failed to scan supplier id", err)
+		}
+		suppliers[i].RequestID = requestID
+		i++
+	}
 
 	return nil
 }