IO-710 Export Log page & insert actions on export

client/src/components/jobs-export-all-button/jobs-export-all-button.component.jsx

@@ -7,15 +7,21 @@ import { useTranslation } from "react-i18next";
 import { connect } from "react-redux";
 import { createStructuredSelector } from "reselect";
 import { auth, logImEXEvent } from "../../firebase/firebase.utils";
+import { INSERT_EXPORT_LOG } from "../../graphql/accounting.queries";
 import { UPDATE_JOBS } from "../../graphql/jobs.queries";
-import { selectBodyshop } from "../../redux/user/user.selectors";
+import {
+  selectBodyshop,
+  selectCurrentUser,
+} from "../../redux/user/user.selectors";
 
 const mapStateToProps = createStructuredSelector({
   bodyshop: selectBodyshop,
+  currentUser: selectCurrentUser,
 });
 
 export function JobsExportAllButton({
   bodyshop,
+  currentUser,
   jobIds,
   disabled,
   loadingCallback,
@@ -23,6 +29,8 @@ export function JobsExportAllButton({
 }) {
   const { t } = useTranslation();
   const [updateJob] = useMutation(UPDATE_JOBS);
+  const [insertExportLog] = useMutation(INSERT_EXPORT_LOG);
+
   const [loading, setLoading] = useState(false);
   const handleQbxml = async () => {
     logImEXEvent("jobs_export_all");
@@ -73,35 +81,67 @@ export function JobsExportAllButton({
 
     console.log("PartnerResponse", PartnerResponse);
     const groupedData = _.groupBy(PartnerResponse.data, "id");
-    const proms = [];
 
-    Object.keys(groupedData).forEach((key) => {
-      proms.push(async () => {
+    await Promise.all(
+      Object.keys(groupedData).map(async (key) => {
         //Check to see if any of them failed. If they didn't don't execute the update.
         const failedTransactions = groupedData[key].filter((r) => !r.success);
 
         if (failedTransactions.length > 0) {
           //Uh oh. At least one was no good.
-          failedTransactions.map((ft) =>
-            notification["error"]({
+          failedTransactions.forEach((ft) => {
+            notification.open({
+              // key: "failedexports",
+              type: "error",
               message: t("jobs.errors.exporting", {
                 error: ft.errorMessage || "",
               }),
-            })
-          );
+            });
+            //Call is not awaited as it is not critical to finish before proceeding.
+          });
+          await insertExportLog({
+            variables: {
+              logs: [
+                {
+                  bodyshopid: bodyshop.id,
+                  jobid: key,
+                  successful: false,
+                  message: JSON.stringify(
+                    failedTransactions.map((ft) => ft.errorMessage)
+                  ),
+                  useremail: currentUser.email,
+                },
+              ],
+            },
+          });
         } else {
+          await insertExportLog({
+            variables: {
+              logs: [
+                {
+                  bodyshopid: bodyshop.id,
+                  jobid: key,
+                  successful: true,
+                  useremail: currentUser.email,
+                },
+              ],
+            },
+          });
+
           const jobUpdateResponse = await updateJob({
             variables: {
               jobIds: [key],
-              job: {
+              fields: {
                 status: bodyshop.md_ro_statuses.default_exported || "Exported*",
                 date_exported: new Date(),
               },
             },
           });
 
-          if (!!!jobUpdateResponse.errors) {
-            notification["success"]({
+          if (!jobUpdateResponse.errors) {
+            notification.open({
+              type: "success",
+              key: "jobsuccessexport",
               message: t("jobs.successes.exported"),
             });
           } else {
@@ -112,9 +152,8 @@ export function JobsExportAllButton({
             });
           }
         }
-      });
-    });
-    await Promise.all(proms);
+      })
+    );
 
     if (!!completedCallback) completedCallback([]);
     if (!!loadingCallback) loadingCallback(false);