From ca846b02e0c962335241f35b2d1784af6d92bd00 Mon Sep 17 00:00:00 2001
From: Patrick Fic <>
Date: Tue, 14 Dec 2021 09:54:46 -0800
Subject: [PATCH] IO-1459 DMS Export marks bills as exported.

---
 server/accounting/pbs/pbs-job-export.js | 4 ++++
 server/cdk/cdk-job-export.js            | 4 ++++
 server/graphql-client/queries.js        | 5 ++++-
 3 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/server/accounting/pbs/pbs-job-export.js b/server/accounting/pbs/pbs-job-export.js
index 89114751a..2d38bb46c 100644
--- a/server/accounting/pbs/pbs-job-export.js
+++ b/server/accounting/pbs/pbs-job-export.js
@@ -654,6 +654,10 @@ async function MarkJobExported(socket, jobid) {
         successful: true,
         useremail: socket.user.email,
       },
+      bill: {
+        exported: true,
+        exported_at: new Date(),
+      },
     });
 
   return result;
diff --git a/server/cdk/cdk-job-export.js b/server/cdk/cdk-job-export.js
index 14e39a3c1..437d11a06 100644
--- a/server/cdk/cdk-job-export.js
+++ b/server/cdk/cdk-job-export.js
@@ -1324,6 +1324,10 @@ async function MarkJobExported(socket, jobid) {
         successful: true,
         useremail: socket.user.email,
       },
+      bill: {
+        exported: true,
+        exported_at: new Date(),
+      },
     });
 
   return result;
diff --git a/server/graphql-client/queries.js b/server/graphql-client/queries.js
index f0b94763b..e31e4de18 100644
--- a/server/graphql-client/queries.js
+++ b/server/graphql-client/queries.js
@@ -1367,7 +1367,7 @@ exports.SET_QBO_AUTH = `mutation SET_QBO_AUTH($email: String!, $qbo_auth: jsonb!
 `;
 
 exports.MARK_JOB_EXPORTED = `
-mutation MARK_JOB_EXPORTED($jobId: uuid!, $job: jobs_set_input!, $log: exportlog_insert_input!) {
+mutation MARK_JOB_EXPORTED($jobId: uuid!, $job: jobs_set_input!, $log: exportlog_insert_input!, $bill: bills_set_input!) {
   update_jobs(where: {id: {_eq: $jobId}}, _set: $job) {
     returning {
       id
@@ -1382,6 +1382,9 @@ mutation MARK_JOB_EXPORTED($jobId: uuid!, $job: jobs_set_input!, $log: exportlog
   insert_exportlog_one(object: $log) {
     id
   }
+  update_bills(where:{jobid:{_eq :$jobId}}, _set:$bill){
+  affected_rows
+  }
 }
 `;
 exports.INSERT_EXPORT_LOG = `