Skip to content

Commit

Permalink
Merge branch 'EH-1406' into qa
Browse files Browse the repository at this point in the history
  • Loading branch information
@tomikat
tomikat committed Nov 21, 2023
2 parents 6892d28 + 097e63c commit 5d9f245
Show file tree
Hide file tree
Showing 11 changed files with 7 additions and 81 deletions.
18 changes: 0 additions & 18 deletions cdk/lib/amis.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -631,23 +631,6 @@ export class HeratepalveluAMISStack extends HeratepalveluStack {
targets: [new targets.LambdaFunction(EhoksOpiskeluoikeusUpdateHandler)]
});

const dbChanger = new lambda.Function(this, "dbChanger", {
runtime: this.runtime,
code: lambdaCode,
environment: {
...this.envVars,
table: AMISherateTable.tableName,
caller_id: `1.2.246.562.10.00000000001.${id}-dbChanger`
},
handler: "oph.heratepalvelu.util.dbChanger::handleDBUpdate",
memorySize: 1024,
reservedConcurrentExecutions: 1,
timeout: Duration.seconds(900),
tracing: lambda.Tracing.ACTIVE
});

AMISherateTable.grantReadWriteData(dbChanger);

/*
const dbArchiver = new lambda.Function(this, "archiveHerateTable", {
runtime: this.runtime,
Expand Down Expand Up @@ -684,7 +667,6 @@ export class HeratepalveluAMISStack extends HeratepalveluStack {
AMISTimedOperationsHandler,
AMISMassHerateResendHandler,
EhoksOpiskeluoikeusUpdateHandler,
dbChanger,
updateSmsLahetystila,
// dbArchiver,
].forEach(
Expand Down
5 changes: 1 addition & 4 deletions src/oph/heratepalvelu/amis/AMISCommon.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -74,9 +74,7 @@
uuid (c/generate-uuid)
oppilaitos (:oid (:oppilaitos opiskeluoikeus))
suorituskieli (str/lower-case
(:koodiarvo (:suorituskieli suoritus)))
rahoitusryhma (c/get-rahoitusryhma opiskeluoikeus
herate-date)]
(:koodiarvo (:suorituskieli suoritus)))]
(if-some [existing (c/already-superseding-herate! oppija
koulutustoimija
laskentakausi
Expand Down Expand Up @@ -128,7 +126,6 @@
:hankintakoulutuksen-toteuttaja
[:s (str (:hankintakoulutuksen_toteuttaja req-body))]
:tallennuspvm [:s (str (c/local-date-now))]
:rahoitusryhma [:s rahoitusryhma]
:herate-source [:s herate-source]}
db-data-cond-values
(cond-> db-data
Expand Down
9 changes: 0 additions & 9 deletions src/oph/heratepalvelu/common.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -102,15 +102,6 @@
[opiskeluoikeus date]
(period-contains-date? (:erityinenTuki (:lisätiedot opiskeluoikeus)) date))

(defn get-rahoitusryhma
"Päättää, mihin rahoitusryhmään oppilas kuuluu. Oppilas kuuluu rahoitusryhmään
1 jos hänen opinnot ovat maksuttomia tai hän on erityisen tuen opiskelijan."
[opiskeluoikeus ^LocalDate herate-date]
(if (or (is-maksuton? opiskeluoikeus (str herate-date))
(erityinen-tuki-voimassa? opiskeluoikeus (str herate-date)))
"01"
"02"))

(defn has-time-to-answer?
"Tarkistaa, onko aikaa jäljellä ennen annettua päivämäärää."
[loppupvm]
Expand Down
6 changes: 1 addition & 5 deletions src/oph/heratepalvelu/tep/jaksoHandler.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -143,9 +143,6 @@
tutkinto (get-in suoritus [:koulutusmoduuli
:tunniste
:koodiarvo])
rahoitusryhma (c/get-rahoitusryhma
opiskeluoikeus
(LocalDate/parse (:loppupvm herate)))
db-data {:hankkimistapa_id [:n tapa-id]
:hankkimistapa_tyyppi
[:s (last (str/split (:hankkimistapa-tyyppi herate)
Expand Down Expand Up @@ -183,8 +180,7 @@
(:tyopaikan-ytunnus herate) "/"
koulutustoimija "/" tutkinto)]
:tyopaikan_normalisoitu_nimi
[:s (c/normalize-string (:tyopaikan-nimi herate))]
:rahoitusryhma [:s rahoitusryhma]}
[:s (c/normalize-string (:tyopaikan-nimi herate))]}
jaksotunnus-table-data
(cond-> db-data
(not-empty (:tyopaikkaohjaaja-email herate))
Expand Down
4 changes: 0 additions & 4 deletions src/oph/heratepalvelu/tep/rahoitusLaskentaHandler.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -66,9 +66,6 @@
:koodiarvo])
existing-arvo-tunnus
(:tunnus (read-previously-processed-hankkimistapa tapa-id))
rahoitusryhma (->> (:loppupvm herate)
(LocalDate/parse)
(c/get-rahoitusryhma opiskeluoikeus))
jakso {:hankkimistapa_id tapa-id
:oppija_oid (:oppija-oid herate)
:jakso_alkupvm (:alkupvm herate)
Expand Down Expand Up @@ -113,7 +110,6 @@
koulutustoimija "/" tutkinto)]
:tyopaikan_normalisoitu_nimi
[:s (c/normalize-string (:tyopaikan-nimi herate))]
:rahoitusryhma [:s rahoitusryhma]
:existing-arvo-tunnus [:s (str existing-arvo-tunnus)]
:vanha-kesto [:n kesto-vanha]
; NOTE: Uudessa laskutavassa osa-aikaisuutta ei oteta
Expand Down
29 changes: 1 addition & 28 deletions src/oph/heratepalvelu/util/dbChanger.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
[clojure.tools.logging :as log]
[oph.heratepalvelu.common :as c]
[oph.heratepalvelu.log.caller-log :as cl]
[oph.heratepalvelu.external.koski :as koski]
[oph.heratepalvelu.amis.AMISCommon :as ac]
[oph.heratepalvelu.tep.niputusHandler :as nip])
(:import (software.amazon.awssdk.services.dynamodb.model
Expand All @@ -13,10 +12,7 @@

(gen-class
:name "oph.heratepalvelu.util.dbChanger"
:methods [[^:static handleDBUpdate
[com.amazonaws.services.lambda.runtime.events.ScheduledEvent
com.amazonaws.services.lambda.runtime.Context] void]
[^:static handleDBUpdateTep
:methods [[^:static handleDBUpdateTep
[com.amazonaws.services.lambda.runtime.events.ScheduledEvent
com.amazonaws.services.lambda.runtime.Context] void]
[^:static updateSmsLahetystila
Expand All @@ -41,29 +37,6 @@

(defn- attr [^String input] (.build (.s (AttributeValue/builder) input)))

(defn -handleDBUpdate [this event context]
(loop [resp (scan {:filter-expression
"attribute_not_exists(rahoitusryhma) AND alkupvm = :pvm"
:expr-attr-vals {":pvm" (attr "2022-08-11")}})]
(doseq [item (map ddb/map-attribute-values-to-vals (.items resp))]
(try
(let [opiskeluoikeus (koski/get-opiskeluoikeus-catch-404!
(:opiskeluoikeus-oid item))
rahoitusryhma (c/get-rahoitusryhma
opiskeluoikeus (LocalDate/parse (:alkupvm item)))]
(when (some? rahoitusryhma)
(ac/update-herate
item
{:rahoitusryhma [:s rahoitusryhma]})))
(catch Exception e
(log/error e))))
(when (.hasLastEvaluatedKey resp)
(recur (scan
{:filter-expression
"attribute_not_exists(rahoitusryhma) AND alkupvm = :pvm"
:expr-attr-vals {":pvm" (attr "2022-07-11")}
:exclusive-start-key (.lastEvaluatedKey resp)})))))

(defn -handleDBUpdateTep [this event context]
(loop [resp (scan {:filter-expression
(str "jakso_loppupvm >= :start "
Expand Down
6 changes: 1 addition & 5 deletions test/oph/heratepalvelu/amis/AMISCommon_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,6 @@
:hankintakoulutuksen-toteuttaja
[:s "test-hankintakoulutuksen-toteuttaja"]
:tallennuspvm [:s "2021-12-17"]
:rahoitusryhma [:s "02"]
:herate-source [:s (:ehoks c/herate-sources)]}
:options
{:cond-expr "attribute_not_exists(kyselylinkki)"}}
Expand Down Expand Up @@ -243,7 +242,6 @@
:hankintakoulutuksen-toteuttaja
[:s "test-hankintakoulutuksen-toteuttaja"]
:tallennuspvm [:s "2021-12-17"]
:rahoitusryhma [:s "02"]
:herate-source [:s (:koski c/herate-sources)]}
:options
{:cond-expr (str "attribute_not_exists(toimija_oppija) "
Expand Down Expand Up @@ -284,8 +282,7 @@
{:type "mock-get-hankintakoulutuksen-toteuttaja",
:ehoks-id 98}
{:type "mock-put-item",
:item {:rahoitusryhma [:s "02"],
:kyselytyyppi [:s "tutkinnon_suorittaneet"],
:item {:kyselytyyppi [:s "tutkinnon_suorittaneet"],
:request-id [:s "test-uuid"],
:voimassa-loppupvm [:s "2022-01-15"],
:hankintakoulutuksen-toteuttaja
Expand Down Expand Up @@ -369,7 +366,6 @@
:hankintakoulutuksen-toteuttaja
[:s "test-hankintakoulutuksen-toteuttaja"]
:tallennuspvm [:s "2021-12-17"]
:rahoitusryhma [:s "02"]
:herate-source [:s (:ehoks c/herate-sources)]}
:options
{:cond-expr "attribute_not_exists(kyselylinkki)"}}
Expand Down
1 change: 0 additions & 1 deletion test/oph/heratepalvelu/integration_tests/amis/AMISherateHandler_i_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,6 @@
:oppija-oid [:s "3.4.5"]
:ehoks-id [:n "456"]
:rahoituskausi [:s "2022-2023"]
:rahoitusryhma [:s "01"]
:herate-source [:s (:ehoks c/herate-sources)]}})

(def expected-http-results
Expand Down
1 change: 0 additions & 1 deletion test/oph/heratepalvelu/integration_tests/amis/UpdatedOpiskeluoikeusHandler_i_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,6 @@
:oppija-oid [:s "1.2.3"]
:ehoks-id [:n "123"]
:rahoituskausi [:s "2022-2023"]
:rahoitusryhma [:s "02"]
:herate-source [:s (:koski c/herate-sources)]}})

(def expected-http-results
Expand Down
3 changes: 1 addition & 2 deletions test/oph/heratepalvelu/integration_tests/tep/jaksoHandler_i_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -178,8 +178,7 @@
:rahoituskausi [:s "2021-2022"]
:tutkintonimike [:s "(\"test-tutkintonimike\")"]
:viimeinen_vastauspvm [:s "2022-04-17"]
:request_id [:s "test-uuid"]
:rahoitusryhma [:s "02"]}})
:request_id [:s "test-uuid"]}})

(def expected-nippu-table
#{{:ohjaaja_ytunnus_kj_tutkinto
Expand Down
6 changes: 2 additions & 4 deletions test/oph/heratepalvelu/tep/jaksoHandler_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -326,8 +326,7 @@
:oppija_oid [:s "123.456.789"]
:rahoituskausi [:s "2021-2022"]
:tutkintonimike [:s ""]
:viimeinen_vastauspvm [:s "2022-02-14"]
:rahoitusryhma [:s "02"]}
:viimeinen_vastauspvm [:s "2022-02-14"]}
:nippu-table-data
{:tyopaikka [:s "Testityöpaikka"]
:koulutuksenjarjestaja [:s "koulutustoimija-id"]
Expand Down Expand Up @@ -437,8 +436,7 @@
:oppija_oid [:s "123.456.789"]
:rahoituskausi [:s "2021-2022"]
:tutkintonimike [:s ""]
:viimeinen_vastauspvm [:s "2022-02-14"]
:rahoitusryhma [:s "02"]}
:viimeinen_vastauspvm [:s "2022-02-14"]}
:nippu-table-data
{:tyopaikka [:s "Testityöpaikka"]
:koulutuksenjarjestaja [:s "koulutustoimija-id"]
Expand Down

0 comments on commit 5d9f245

Please sign in to comment.