Skip to content

Commit

Permalink
Merge branch 'master' into feature/tm-1758
Browse files Browse the repository at this point in the history
  • Loading branch information
Pomarom authored Dec 11, 2024
2 parents dc0bc7e + 5876f9e commit 37390ee
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 44 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,5 +5,4 @@ export const up = async () => {
name: "tmp:migration:formation-certification",
queued: true,
});
await addJob({ name: "hydrate:contrats-deca-raw", queued: true });
};
40 changes: 1 addition & 39 deletions server/src/jobs/jobs.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,11 @@ import { addJob, initJobProcessor } from "job-processor";
import { MongoError } from "mongodb";
import { MOTIF_SUPPRESSION } from "shared/constants";
import type { IEffectif } from "shared/models";
import type { IEffectifDECA } from "shared/models/data/effectifsDECA.model";
import { getAnneesScolaireListFromDate } from "shared/utils";

import { softDeleteEffectif } from "@/common/actions/effectifs.actions";
import logger from "@/common/logger";
import { effectifsDb, effectifsDECADb } from "@/common/model/collections";
import { effectifsDb } from "@/common/model/collections";
import { createCollectionIndexes } from "@/common/model/indexes/createCollectionIndexes";
import { getDatabase } from "@/common/mongodb";
import config from "@/config";
Expand Down Expand Up @@ -390,43 +389,6 @@ export async function setupJobProcessor() {
await Promise.all(bulkEffectifs.map(processEffectif));
}

const processEffectifDeca = async (effectif: IEffectifDECA) => {
const certification = await getEffectifCertification(effectif);

const update = {
formation: fiabilisationEffectifFormation(effectif, certification),
_computed: {
...effectif._computed,
formation: {
...effectif._computed?.formation,
codes_rome: certification?.domaines.rome.rncp?.map(({ code }) => code) ?? null,
},
},
};

await effectifsDECADb().updateOne({ _id: effectif._id }, { $set: update });
};

const cursorEffectifDeca = effectifsDECADb().find(
{ created_at: { $lte: job.created_at } },
{ sort: { created_at: -1 } }
);
let bulkEffectifsDeca: IEffectifDECA[] = [];
for await (const effectif of cursorEffectifDeca) {
bulkEffectifsDeca.push(effectif);

if (bulkEffectifsDeca.length > 100) {
await Promise.all(bulkEffectifsDeca.map(processEffectifDeca));
if (signal.aborted) {
return;
}
bulkEffectifsDeca = [];
}
}
if (bulkEffectifsDeca.length > 0) {
await Promise.all(bulkEffectifsDeca.map(processEffectifDeca));
}

// TODO: Formation v2 migration
},
resumable: true,
Expand Down
2 changes: 1 addition & 1 deletion ui/components/Ribbons/Ribbons.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ type RibbonsProps = {

const Ribbons = ({ variant = "info", oneLiner = true, children, px, py, ...rest }: RibbonsProps) => {
return (
<Box width="50%" {...rest}>
<Box width={2 / 3} {...rest}>
<Flex
borderColor={stylesMap[variant].borderColor}
borderWidth={stylesMap[variant].borderWidth}
Expand Down
2 changes: 1 addition & 1 deletion ui/modules/dashboard/DashboardOrganisme.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -353,7 +353,7 @@ const DashboardOrganisme = ({ organisme, modePublique }: Props) => {
{organisme.fiabilisation_statut && (
<InfoFiabilisationOrganisme fiabilisationStatut={organisme.fiabilisation_statut} />
)}
{!modePublique && duplicates && duplicates?.totalItems > 0 && <AlertDuplicatsEffectifs />}
{duplicates && duplicates?.totalItems > 0 && <AlertDuplicatsEffectifs />}
{organisationType === "ADMINISTRATEUR" && (
<>
<Button
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,13 +93,14 @@ const EffectifsDoublonsPage = ({ isMine }) => {

<Stack spacing={6}>
{isMine && (
<VStack align="start" width={2 / 3} gap={0}>
<VStack align="start" width={2 / 3} gap={0} mb={6}>
<Text fontWeight="bold" fontSize="delta">
Vérifiez {duplicates?.length === 1 ? "le duplicat" : `les ${duplicates?.length} duplicats`}{" "}
d&apos;effectifs. Pour chacun, supprimez celui avec les informations incorrectes.
</Text>
<Text mt={2}>
Les effectifs ci-dessous existent car des données ont été modifiées sur chacun d’entre eux.
Les effectifs ci-dessous apparaissent en doublons car une ou plusieurs données ont été modifiées sur
chacun d’entre eux.
</Text>
<Text>
Ces dernières sont signalées en{" "}
Expand Down

0 comments on commit 37390ee

Please sign in to comment.