exports.FIND_BODYSHOP_BY_MESSAGING_SERVICE_SID = ` query FIND_BODYSHOP_BY_MESSAGING_SERVICE_SID( $mssid: String! $phone: String! ) { bodyshops(where: { messagingservicesid: { _eq: $mssid } }) { id conversations(where: { phone_num: { _eq: $phone } }) { id } } } `; exports.UNARCHIVE_CONVERSATION = ` mutation UNARCHIVE_CONVERSATION($id: uuid!) { update_conversations_by_pk(pk_columns: {id: $id}, _set: {archived: false}) { id } } `; exports.INSERT_NEW_JOB_LINE = ` mutation INSERT_NEW_JOB_LINE($lineInput: [joblines_insert_input!]!) { insert_joblines(objects: $lineInput) { returning { id } } } `; exports.UPDATE_JOB_LINE = ` mutation UPDATE_JOB_LINE($lineId: uuid!, $line: joblines_set_input!) { update_joblines(where: { id: { _eq: $lineId } }, _set: $line) { returning { id notes mod_lbr_ty part_qty db_price act_price line_desc line_no oem_partno notes location status removed } } } `; exports.RECEIVE_MESSAGE = ` mutation RECEIVE_MESSAGE($msg: [messages_insert_input!]!) { insert_messages(objects: $msg) { returning { conversation { id archived bodyshop{ imexshopid } created_at updated_at unreadcnt phone_num } conversationid created_at id image_path image isoutbound msid read text updated_at status userid } } } `; exports.INSERT_MESSAGE = ` mutation INSERT_MESSAGE($msg: [messages_insert_input!]!, $conversationid: uuid!) { update_conversations_by_pk(pk_columns: {id: $conversationid}, _set: {archived: false}) { id archived } insert_messages(objects: $msg) { returning { conversation { id archived bodyshop{ imexshopid } created_at updated_at unreadcnt phone_num } conversationid created_at id image_path image isoutbound msid read text updated_at status userid } } } `; exports.UPDATE_MESSAGE_STATUS = ` mutation UPDATE_MESSAGE($msid: String!, $fields: messages_set_input!) { update_messages(where: { msid: { _eq: $msid } }, _set: $fields) { returning { id } } } `; exports.QUERY_JOBS_FOR_RECEIVABLES_EXPORT = ` query QUERY_JOBS_FOR_RECEIVABLES_EXPORT($ids: [uuid!]!) { jobs(where: {id: {_in: $ids}}) { id job_totals ded_amt date_invoiced ro_number clm_total clm_no v_model_yr v_model_desc v_make_desc v_vin plate_no ownerid ownr_ln ownr_fn ownr_co_nm ownr_addr1 ownr_addr2 ownr_zip ownr_city ownr_st ownr_ea ins_co_nm job_totals rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd class ca_bc_pvrt ca_customer_gst towing_payable storage_payable adjustment_bottom_line state_tax_rate qb_multiple_payers owner { accountingid } joblines(where:{removed: {_eq:false}}) { id line_desc part_type act_price mod_lb_hrs mod_lbr_ty part_qty op_code_desc profitcenter_labor profitcenter_part db_ref prt_dsmk_p prt_dsmk_m tax_part line_ref unq_seq lbr_op } } bodyshops(where: {associations: {active: {_eq: true}}}) { id md_responsibility_centers region_config accountingconfig md_ins_cos timezone md_ro_statuses } } `; exports.QUERY_JOBS_FOR_CDK_EXPORT = ` query QUERY_JOBS_FOR_CDK_EXPORT($id: uuid!) { jobs_by_pk(id: $id) { id job_totals date_invoiced ro_number clm_total clm_no invoice_allocation ownerid ownr_ln ownr_fn ownr_co_nm ownr_addr1 ownr_addr2 ownr_ph1 ownr_ph2 ownr_zip ownr_city ownr_ctry ownr_st ownr_ea ins_co_nm job_totals rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd class ca_bc_pvrt plate_no plate_st v_vin v_model_yr v_model_desc v_make_desc v_color ca_customer_gst bodyshop { id md_ro_statuses md_responsibility_centers accountingconfig cdk_dealerid cdk_configuration timezone } owner { accountingid } joblines(where:{removed: {_eq:false}}) { id line_desc part_type act_price mod_lb_hrs mod_lbr_ty part_qty op_code_desc profitcenter_labor profitcenter_part db_ref prt_dsmk_p } } } `; exports.QUERY_JOBS_FOR_PBS_EXPORT = ` query QUERY_JOBS_FOR_PBS_EXPORT($id: uuid!) { jobs_by_pk(id: $id) { id job_totals date_invoiced ro_number clm_total clm_no dms_allocation invoice_allocation kmin kmout ownerid ownr_ln ownr_fn ownr_addr1 ownr_addr2 ownr_ph1 ownr_ph2 ownr_zip ownr_city ownr_ctry ownr_st ownr_ea ins_co_nm job_totals rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd class ca_bc_pvrt plate_no plate_st v_vin v_model_yr v_model_desc v_make_desc v_color ca_customer_gst vehicle{ v_trimcode v_makecode } bodyshop { id md_ro_statuses md_responsibility_centers accountingconfig pbs_serialnumber pbs_configuration timezone } owner { id accountingid } joblines(where:{removed: {_eq:false}}) { id line_desc part_type act_price mod_lb_hrs mod_lbr_ty part_qty op_code_desc profitcenter_labor profitcenter_part db_ref prt_dsmk_p unq_seq line_ref } } } `; exports.QUERY_BILLS_FOR_PAYABLES_EXPORT = ` query QUERY_BILLS_FOR_PAYABLES_EXPORT($bills: [uuid!]!) { bodyshops(where: {associations: {active: {_eq: true}}}) { id md_responsibility_centers timezone region_config accountingconfig } bills(where: {id: {_in: $bills}}) { id date due_date federal_tax_rate invoice_number is_credit_memo invoice_number job { id ro_number clm_no ownr_fn ownr_ln ownr_co_nm class } billlines{ id cost_center actual_cost quantity applicable_taxes } state_tax_rate local_tax_rate total vendor{ id name due_date } } } `; exports.QUERY_PAYMENTS_FOR_EXPORT = ` query QUERY_PAYMENTS_FOR_EXPORT($payments: [uuid!]!) { bodyshops(where: {associations: {active: {_eq: true}}}) { id md_responsibility_centers accountingconfig timezone md_ins_cos } payments(where: {id: {_in: $payments}}) { id created_at jobid job { id ro_number ownerid ownr_ln ownr_fn ownr_addr1 ownr_addr2 ownr_zip ownr_city ownr_st ins_co_nm owner{ accountingid } ownr_fn ownr_ln ownr_co_nm bodyshop{ accountingconfig md_responsibility_centers md_ins_cos } } transactionid memo amount stripeid exportedat stripeid type payer paymentnum date } } `; exports.QUERY_UPCOMING_APPOINTMENTS = `query QUERY_UPCOMING_APPOINTMENTS($now: timestamptz!, $jobId: uuid!) { jobs_by_pk(id: $jobId) { bodyshop { ssbuckets ss_configuration target_touchtime workingdays timezone } jobhrs: joblines_aggregate(where: {removed: {_eq: false}}) { aggregate { sum { mod_lb_hrs } } } } blockedDays: appointments(where: {_and: {canceled: {_eq: false}, block: {_eq: true}, start: {_gte: $now}}}) { start block } arrJobs: jobs(where: {scheduled_in: {_gte: $now}, suspended: {_eq: false}}) { id scheduled_in ro_number labhrs: joblines_aggregate(where: {mod_lbr_ty: {_neq: "LAR"}, removed: {_eq: false}}) { aggregate { sum { mod_lb_hrs } } } larhrs: joblines_aggregate(where: {mod_lbr_ty: {_eq: "LAR"}, removed: {_eq: false}}) { aggregate { sum { mod_lb_hrs } } } } compJobs: jobs(where: {_and: [{suspended: {_eq: false}}, {_or: [{scheduled_completion: {_gte: $now}}, {actual_completion: {_gte: $now}}]}]}) { id ro_number scheduled_completion actual_completion labhrs: joblines_aggregate(where: {mod_lbr_ty: {_neq: "LAR"}, removed: {_eq: false}}) { aggregate { sum { mod_lb_hrs } } } larhrs: joblines_aggregate(where: {mod_lbr_ty: {_eq: "LAR"}, removed: {_eq: false}}) { aggregate { sum { mod_lb_hrs } } } } prodJobs: jobs(where: {inproduction: {_eq: true}, suspended: {_eq: false}}) { id scheduled_completion labhrs: joblines_aggregate(where: {_and: [{mod_lbr_ty: {_neq: "LAR"}}, {removed: {_eq: false}}]}) { aggregate { sum { mod_lb_hrs } } } larhrs: joblines_aggregate(where: {_and: [{mod_lbr_ty: {_eq: "LAR"}}, {removed: {_eq: false}}]}) { aggregate { sum { mod_lb_hrs } } } } }`; exports.QUERY_EMPLOYEE_PIN = `query QUERY_EMPLOYEE_PIN($shopId: uuid!, $employeeId: String!) { employees(where: {_and: {shopid: {_eq: $shopId}, employee_number: {_eq: $employeeId}}}) { last_name first_name employee_number id pin } }`; exports.AUTOHOUSE_QUERY = `query AUTOHOUSE_EXPORT($start: timestamptz, $bodyshopid: uuid!, $end: timestamptz) { bodyshops_by_pk(id: $bodyshopid){ id shopname address1 city state zip_post country phone md_ro_statuses md_order_statuses autohouseid md_responsibility_centers jc_hourly_rates cdk_dealerid pbs_serialnumber timezone } jobs(where: {_and: [{converted: {_eq: true}}, {updated_at: {_gt: $start}}, {updated_at: {_lte: $end}}, {shopid: {_eq: $bodyshopid}}]}) { id created_at ro_number status est_ct_fn est_ct_ln ownr_fn ownr_ln ownr_co_nm ownr_addr1 ownr_city ownr_st ownr_ph1 ownr_zip loss_type v_model_yr v_model_desc v_make_desc v_vin plate_no plate_st kmin v_color tlos_ind ins_co_nm ins_addr1 ins_city ins_st ins_zip ins_ph1 loss_type policy_no clm_no loss_date asgn_date date_estimated date_open scheduled_in actual_in scheduled_completion actual_completion scheduled_delivery actual_delivery date_invoiced date_exported rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_matd rate_mapa rate_mash job_totals driveable parts_tax_rates ded_amt joblines(where: {removed: {_eq: false}}) { id line_no line_ind status line_ind db_price act_price mod_lb_hrs mod_lbr_ty line_desc prt_dsmk_m prt_dsmk_p part_qty part_type oem_partno lbr_op profitcenter_part profitcenter_labor parts_order_lines(order_by: {parts_order: {order_date: desc_nulls_last}} limit: 1){ parts_order{ id order_date } } billlines(order_by: {bill: {date: desc_nulls_last}} limit: 1) { actual_cost actual_price quantity bill { vendor { name } invoice_number date } } } bills { id federal_tax_rate local_tax_rate state_tax_rate is_credit_memo billlines { actual_cost cost_center id quantity } } timetickets { id rate cost_center actualhrs productivehrs } area_of_damage employee_prep_rel { first_name last_name employee_number id } employee_refinish_rel { first_name last_name employee_number id } employee_body_rel { first_name last_name employee_number id } } } `; exports.ENTEGRAL_EXPORT = ` query ENTEGRAL_EXPORT($bodyshopid: uuid!) { jobs(where: {_and: [{converted: {_eq: true}}, {shopid: {_eq: $bodyshopid}}]}) { joblines { id line_ind } id ro_number status asgn_date date_open kmin scheduled_completion actual_completion actual_delivery date_exported ins_co_nm ins_addr1 ins_addr2 ins_city ins_st ins_zip ins_ctry ins_ph1 ins_ph2 est_ct_ln est_ct_fn insd_fn insd_ln ownr_fn ownr_ln ownr_co_nm ownr_addr1 ownr_addr2 ownr_city ownr_st ownr_zip ownr_ctry ownr_ph1 ownr_ph2 ownr_ea clm_ct_fn clm_ct_ln v_vin plate_no v_model_yr v_make_desc v_model_desc v_color driveable clm_no policy_no loss_date area_of_damage tlos_ind parts_tax_rates federal_tax_rate state_tax_rate rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd job_totals ded_amt cieca_ttl adjustment_bottom_line } } `; exports.UPDATE_JOB = ` mutation UPDATE_JOB($jobId: uuid!, $job: jobs_set_input!) { update_jobs(where: { id: { _eq: $jobId } }, _set: $job) { returning { id date_exported status alt_transport ro_number production_vars lbr_adjustments } } } `; exports.GET_JOB_BY_PK = ` query GET_JOB_BY_PK($id: uuid!) { jobs_by_pk(id: $id) { updated_at alt_transport intakechecklist loss_desc kmin kmout comment referral_source referral_source_extra unit_number po_number special_coverage_policy scheduled_delivery converted lbr_adjustments ro_number clm_total inproduction vehicleid plate_no v_vin v_model_yr v_model_desc v_make_desc v_color vehicleid driveable towin ins_co_id policy_no loss_date clm_no area_of_damage ins_co_nm ins_addr1 ins_city ins_ct_ln ins_ct_fn ins_ea ins_ph1 est_co_nm est_ct_fn est_ct_ln vehicle{ id notes } est_ph1 est_ea selling_dealer servicing_dealer selling_dealer_contact servicing_dealer_contact regie_number scheduled_completion id ded_amt ded_status depreciation_taxes other_amount_payable towing_payable storage_payable adjustment_bottom_line federal_tax_rate state_tax_rate local_tax_rate tax_tow_rt tax_str_rt tax_paint_mat_rt tax_shop_mat_rt tax_sub_rt tax_lbr_rt tax_levies_rt parts_tax_rates job_totals ownr_fn ownr_ln ownr_ea ownr_addr1 ownr_addr2 ownr_city ownr_st ownr_zip ownr_ctry ownr_ph1 ownr_ph2 production_vars ca_gst_registrant labor_rate_desc rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd actual_in federal_tax_rate local_tax_rate state_tax_rate scheduled_completion scheduled_in actual_completion scheduled_delivery actual_delivery date_estimated date_open date_scheduled date_invoiced date_exported status owner_owing tax_registration_number class category deliverchecklist voided ca_bc_pvrt ca_customer_gst materials auto_add_ats rate_ats joblines(where: { removed: { _eq: false } }){ id line_no unq_seq line_ind line_desc part_type line_ref oem_partno db_price act_price part_qty mod_lbr_ty db_hrs mod_lb_hrs lbr_op lbr_amt op_code_desc status notes location tax_part db_ref manual_line prt_dsmk_p prt_dsmk_m parts_order_lines { id parts_order { id order_number order_date user_email vendor { id name } } } } } }`; exports.QUERY_JOB_COSTING_DETAILS = ` query QUERY_JOB_COSTING_DETAILS($id: uuid!) { jobs_by_pk(id: $id) { ro_number clm_total id ded_amt ded_status depreciation_taxes other_amount_payable towing_payable storage_payable adjustment_bottom_line federal_tax_rate state_tax_rate local_tax_rate tax_tow_rt tax_str_rt tax_paint_mat_rt tax_sub_rt tax_lbr_rt tax_levies_rt parts_tax_rates job_totals labor_rate_desc rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd actual_in status ca_bc_pvrt ca_customer_gst dms_allocation joblines(where: { removed: { _eq: false } }) { id db_ref line_ref unq_seq line_ind tax_part line_desc prt_dsmk_p prt_dsmk_m part_type oem_partno db_price act_price part_qty mod_lbr_ty db_hrs mod_lb_hrs lbr_op lbr_amt op_code_desc profitcenter_part profitcenter_labor } bills { id federal_tax_rate local_tax_rate state_tax_rate is_credit_memo billlines { actual_cost cost_center id quantity } } timetickets { id rate cost_center actualhrs productivehrs flat_rate ciecacode } bodyshop{ id md_responsibility_centers jc_hourly_rates cdk_dealerid pbs_serialnumber } } }`; exports.QUERY_JOB_COSTING_DETAILS_MULTI = ` query QUERY_JOB_COSTING_DETAILS_MULTI($ids: [uuid!]!) { jobs( where: {id: {_in: $ids}}) { ro_number clm_total id ded_amt ded_status depreciation_taxes other_amount_payable towing_payable storage_payable adjustment_bottom_line federal_tax_rate state_tax_rate local_tax_rate tax_tow_rt tax_str_rt tax_paint_mat_rt tax_sub_rt tax_lbr_rt tax_levies_rt parts_tax_rates job_totals labor_rate_desc rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd actual_in status ca_bc_pvrt ca_customer_gst dms_allocation joblines(where: {removed: {_eq: false}}) { id db_ref unq_seq line_ref line_ind tax_part line_desc prt_dsmk_p prt_dsmk_m part_type oem_partno db_price act_price part_qty mod_lbr_ty db_hrs mod_lb_hrs lbr_op lbr_amt op_code_desc profitcenter_part profitcenter_labor } bills { id federal_tax_rate local_tax_rate state_tax_rate is_credit_memo billlines { actual_cost cost_center id quantity } } timetickets { id rate cost_center actualhrs productivehrs flat_rate ciecacode } bodyshop { id md_responsibility_centers jc_hourly_rates cdk_dealerid pbs_serialnumber } } } `; exports.INSERT_IOEVENT = ` mutation INSERT_IOEVENT($event: ioevents_insert_input!) { insert_ioevents_one(object: $event) { id } } `; exports.GET_AUTOHOUSE_SHOPS = `query GET_AUTOHOUSE_SHOPS { bodyshops(where: {autohouseid: {_is_null: false}}){ id shopname address1 city state zip_post country phone md_ro_statuses md_order_statuses autohouseid md_responsibility_centers jc_hourly_rates imexshopid timezone } } `; exports.GET_ENTEGRAL_SHOPS = `query GET_AUTOHOUSE_SHOPS { bodyshops(where: {entegral_id: {_is_null: false}}){ id shopname address1 city state zip_post country phone md_ro_statuses md_order_statuses entegral_id md_responsibility_centers imexshopid timezone features } } `; exports.DELETE_ALL_DMS_VEHICLES = `mutation DELETE_ALL_DMS_VEHICLES{ delete_dms_vehicles(where: {}) { affected_rows } } `; exports.INSERT_DMS_VEHICLES = `mutation INSERT_DMS_VEHICLES($vehicles: [dms_vehicles_insert_input!]!) { insert_dms_vehicles(objects: $vehicles) { affected_rows } } `; exports.GET_CDK_ALLOCATIONS = `query QUERY_JOB_CLOSE_DETAILS($id: uuid!) { jobs_by_pk(id: $id) { bodyshop { id md_responsibility_centers cdk_configuration } ro_number dms_allocation invoice_allocation ins_co_id id ded_amt ded_status depreciation_taxes other_amount_payable towing_payable storage_payable adjustment_bottom_line federal_tax_rate state_tax_rate local_tax_rate tax_tow_rt tax_str_rt tax_paint_mat_rt tax_sub_rt tax_lbr_rt tax_levies_rt parts_tax_rates job_totals rate_la1 rate_la2 rate_la3 rate_la4 rate_laa rate_lab rate_lad rate_lae rate_laf rate_lag rate_lam rate_lar rate_las rate_lau rate_ma2s rate_ma2t rate_ma3s rate_mabl rate_macs rate_mahw rate_mapa rate_mash rate_matd status date_exported date_invoiced voided scheduled_completion actual_completion scheduled_delivery actual_delivery scheduled_in actual_in ca_bc_pvrt timetickets { id actualhrs cost_center productivehrs rate ciecacode employee { flat_rate } } bills(where: {isinhouse: {_eq: false}}) { id federal_tax_rate local_tax_rate state_tax_rate is_credit_memo billlines { actual_cost cost_center id quantity applicable_taxes } } joblines(where: {removed: {_eq: false}}) { id removed tax_part line_desc prt_dsmk_p prt_dsmk_m part_type oem_partno db_price db_ref act_price part_qty mod_lbr_ty db_hrs mod_lb_hrs lbr_op lbr_amt op_code_desc profitcenter_labor profitcenter_part line_ref unq_seq } } } `; exports.GET_QBO_AUTH = `query GET_QBO_AUTH($email: String!) { associations(where: {_and: {active: {_eq: true}, useremail: {_eq: $email}}}){ id qbo_auth qbo_realmId } }`; exports.SET_QBO_AUTH_WITH_REALM = `mutation SET_QBO_AUTH($email: String!, $qbo_auth: jsonb!, $qbo_realmId: String) { update_associations(_set: {qbo_auth: $qbo_auth, qbo_realmId: $qbo_realmId}, where: {_and: {active: {_eq: true}, useremail: {_eq: $email}}}){ affected_rows } } `; exports.SET_QBO_AUTH = `mutation SET_QBO_AUTH($email: String!, $qbo_auth: jsonb!) { update_associations(_set: {qbo_auth: $qbo_auth}, where: {_and: {active: {_eq: true}, useremail: {_eq: $email}}}){ affected_rows } } `; exports.MARK_JOB_EXPORTED = ` 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 date_exported status alt_transport ro_number production_vars lbr_adjustments } } insert_exportlog_one(object: $log) { id } update_bills(where:{jobid:{_eq :$jobId}}, _set:$bill){ affected_rows } } `; exports.INSERT_EXPORT_LOG = ` mutation INSERT_EXPORT_LOG($log: exportlog_insert_input!) { insert_exportlog_one(object: $log) { id } } `; exports.QUERY_EXISTING_TRANSITION = ` mutation INSERT_EXPORT_LOG($log: exportlog_insert_input!) { insert_exportlog_one(object: $log) { id } } `; exports.UPDATE_OLD_TRANSITION = `mutation UPDATE_OLD_TRANSITION($jobid: uuid!, $existingTransition: transitions_set_input!){ update_transitions(where:{jobid:{_eq:$jobid}, end:{_is_null:true }}, _set:$existingTransition){ affected_rows returning{ id start end prev_value next_value value } } }`; exports.INSERT_NEW_TRANSITION = `mutation INSERT_NEW_TRANSITION($newTransition: transitions_insert_input!, $oldTransitionId: uuid, $duration: numeric) { insert_transitions_one(object: $newTransition) { id } update_transitions(where: {id: {_eq: $oldTransitionId}}, _set: {duration: $duration}) { affected_rows } } `; exports.QUERY_JOB_ID_MIXDATA = `query QUERY_JOB_ID_MIXDATA($roNumbers: [String!]!) { jobs(where: {ro_number: {_in: $roNumbers}}) { id ro_number mixdata { id } } } `; exports.QBO_MARK_JOB_EXPORTED = ` mutation QBO_MARK_JOB_EXPORTED($jobId: uuid!, $job: jobs_set_input!, $logs: [exportlog_insert_input!]!) { insert_exportlog(objects: $logs) { affected_rows } update_jobs(where: {id: {_eq: $jobId}}, _set: $job) { returning { id } } } `; exports.QBO_MARK_BILL_EXPORTED = ` mutation QBO_MARK_BILL_EXPORTED($billId: uuid!, $bill: bills_set_input!, $logs: [exportlog_insert_input!]!) { insert_exportlog(objects: $logs) { affected_rows } update_bills(where: { id: { _eq: $billId } }, _set: $bill) { returning { id } } } `; exports.QBO_MARK_PAYMENT_EXPORTED = ` mutation QBO_MARK_PAYMENT_EXPORTED($paymentId: uuid!, $payment: payments_set_input!, $logs: [exportlog_insert_input!]!) { insert_exportlog(objects: $logs) { affected_rows } update_payments(where: {id: {_eq: $paymentId}}, _set: $payment) { returning { id } } }`; exports.INSERT_EXPORT_LOG = ` mutation INSERT_EXPORT_LOG($logs: [exportlog_insert_input!]!) { insert_exportlog(objects: $logs) { affected_rows } } `; exports.INSERT_EMAIL_AUDIT = `mutation INSERT_EMAIL_AUDIT($email: email_audit_trail_insert_input!) { insert_email_audit_trail_one(object: $email) { id } } `; exports.DELETE_MEDIA_DOCUMENTS = ` mutation DELETE_DOCUMENTS($ids: [uuid!]!) { delete_documents(where: { id: { _in: $ids } }) { returning { id } } } `; exports.UPDATE_EMAIL_AUDIT = ` mutation ($sesid: String!, $status: String, $context: jsonb) { update_email_audit_trail(where: {sesmessageid: {_eq: $sesid}}, _set: {status: $status, status_context: $context}) { returning { contents } } }`;