https://www.infraagent.ai/assets/workOrderService-D95I0a5u.js

1import{s as a}from"./dashboard-VcvU7gQ4.js";import{w as _,b as f,c as i,f as n,h as u,i as k,j as q,k as g,s as v,m as T}from"./eamAdapter-D9Hs75MH.js";async function R(r,e){if(!a)return[];let o=a.from("work_order").select("*").eq("workspace_id",r).eq("is_deleted",!1).order("created_at",{ascending:!1});e?.status&&(Array.isArray(e.status)?o=o.in("status",e.status):o=o.eq("status",e.status)),e?.woTypeKey&&(o=o.eq("wo_type_key",e.woTypeKey)),e?.priorityKey&&(o=o.eq("priority_key",e.priorityKey)),e?.assignedTo&&(o=o.eq("assigned_to",e.assignedTo)),e?.twinNodeId&&(o=o.eq("twin_node_id",e.twinNodeId)),e?.twinId&&(o=o.eq("twin_id",e.twinId));const{data:t,error:s}=await o;return s||!t?[]:t.map(n)}async function h(r){if(!a)return null;const[e,o,t,s,l,w,m]=await Promise.all([a.from("work_order").select("*").eq("id",r).single(),a.from("wo_task").select("*").eq("wo_id",r).eq("is_deleted",!1).order("sequence"),a.from("wo_failure_report").select("*").eq("wo_id",r).eq("is_deleted",!1).maybeSingle(),a.from("wo_status_history").select("*").eq("wo_id",r).order("transitioned_at",{ascending:!1}),a.from("permit_to_work").select("*").eq("work_order_id",r).eq("is_deleted",!1).order("created_at",{ascending:!1}),a.from("isolation_plan").select("*").eq("work_order_id",r).eq("is_deleted",!1).order("created_at",{ascending:!1}),a.from("material_request").select("*, spare_part(*)").eq("work_order_id",r).eq("is_deleted",!1).order("created_at",{ascending:!1})]);if(e.error||!e.data)return null;const d=n(e.data);return d.tasks=o.data?.map(i)??[],d.failureReport=t.data?u(t.data):null,d.statusHistory=s.data?.map(k)??[],d.permits=l.data?.map(q)??[],d.isolationPlans=w.data?.map(g)??[],d.materials=(m.data??[]).map(c=>{const y=c.spare_part?v(c.spare_part):void 0;return T(c,y)}),d}async function I(r){if(!a)return null;const{data:e,error:o}=await a.rpc("generate_wo_number",{_workspace_id:r.workspaceId});if(o||!e)return null;const{data:t,error:s}=await a.from("work_order").insert({workspace_id:r.workspaceId,twin_node_id:r.twinNodeId,twin_id:r.twinId??null,wo_number:e,title:r.title,description:r.description??null,wo_type_key:r.woTypeKey,priority_key:r.priorityKey??"P4",assigned_to:r.assignedTo??null,requested_by:r.requestedBy??null,source_type:r.sourceType??null,source_ref_id:r.sourceRefId??null,scheduled_start:r.scheduledStart??null,scheduled_end:r.scheduledEnd??null,estimated_hours:r.estimatedHours??null,cost_estimate:r.costEstimate??null,notes:r.notes??null,metadata:r.metadata??{}}).select().single();return s||!t?null:n(t)}async function b(r,e){if(!a)return null;const o={};e.title!==void 0&&(o.title=e.title),e.description!==void 0&&(o.description=e.description),e.priorityKey!==void 0&&(o.priority_key=e.priorityKey),e.assignedTo!==void 0&&(o.assigned_to=e.assignedTo),e.scheduledStart!==void 0&&(o.scheduled_start=e.scheduledStart),e.scheduledEnd!==void 0&&(o.scheduled_end=e.scheduledEnd),e.actualStart!==void 0&&(o.actual_start=e.actualStart),e.actualEnd!==void 0&&(o.actual_end=e.actualEnd),e.estimatedHours!==void 0&&(o.estimated_hours=e.estimatedHours),e.actualHours!==void 0&&(o.actual_hours=e.actualHours),e.costEstimate!==void 0&&(o.cost_estimate=e.costEstimate),e.actualCost!==void 0&&(o.actual_cost=e.actualCost),e.notes!==void 0&&(o.notes=e.notes),e.metadata!==void 0&&(o.metadata=e.metadata);const{data:t,error:s}=await a.from("work_order").update(o).eq("id",r).select().single();return s||!t?null:n(t)}async function W(r){if(!a)return!1;const{error:e}=await a.from("work_order").update({is_deleted:!0}).eq("id",r);return!e}async function C(r,e,o){if(!a)return{success:!1,error:"Not connected"};const{data:t,error:s}=await a.rpc("wo_transition",{_wo_id:r,_new_status:e,_reason:o});if(s)return{success:!1,error:s.message};if(!t)return{success:!1,error:"No response from RPC"};const l=t;return l.error?{success:!1,error:l.error,gate:l.gate}:{success:!0}}async function M(r,e){if(!a)return{success:!1,error:"Not connected"};const{data:o,error:t}=await a.rpc("wo_close",{_wo_id:r,_failure_report:e||void 0});if(t)return{success:!1,error:t.message};if(!o)return{success:!1,error:"No response from RPC"};const s=o;return s.error?{success:!1,error:s.error}:{success:!0}}async function N(r){if(!a)return[];const{data:e,error:o}=await a.from("wo_task").select("*").eq("wo_id",r).eq("is_deleted",!1).order("sequence");return o||!e?[]:e.map(i)}async function P(r){if(!a)return null;const e={workspace_id:r.workspaceId,wo_id:r.woId,twin_node_id:r.twinNodeId??null,task_type_key:r.taskTypeKey??null,sequence:r.sequence??0,title:r.title,instructions:r.instructions??null,iso14224_maint_activity_code:r.iso14224MaintActivityCode??null},{data:o,error:t}=await a.from("wo_task").insert(e).select().single();return t||!o?null:i(o)}async function K(r,e){if(!a)return null;const o={};e.title!==void 0&&(o.title=e.title),e.instructions!==void 0&&(o.instructions=e.instructions),e.sequence!==void 0&&(o.sequence=e.sequence),e.isCompleted!==void 0&&(o.is_completed=e.isCompleted),e.completedAt!==void 0&&(o.completed_at=e.completedAt),e.completedBy!==void 0&&(o.completed_by=e.completedBy),e.durationMinutes!==void 0&&(o.duration_minutes=e.durationMinutes),e.notes!==void 0&&(o.notes=e.notes),e.iso14224MaintActivityCode!==void 0&&(o.iso14224_maint_activity_code=e.iso14224MaintActivityCode);const{data:t,error:s}=await a.from("wo_task").update(o).eq("id",r).select().single();return s||!t?null:i(t)}async function O(r){if(!a)return!1;const{error:e}=await a.from("wo_task").update({is_deleted:!0}

1).eq("id",r);return!e}async function S(r){if(!a)return[];const{data:e,error:o}=await a.from("wo_measurement").select("*").eq("wo_id",r).eq("is_deleted",!1).order("measured_at",{ascending:!1});return o||!e?[]:e.map(f)}async function E(r){if(!a)return null;const{data:e,error:o}=await a.from("wo_measurement").insert({workspace_id:r.workspaceId,wo_id:r.woId,wo_task_id:r.woTaskId??null,channel_id:r.channelId??null,parameter_name:r.parameterName,value:r.value??null,unit:r.unit??null,measured_by:r.measuredBy??null,notes:r.notes??null}).select().single();return o||!e?null:f(e)}async function H(r){if(!a)return[];const{data:e,error:o}=await a.from("wo_labor").select("*").eq("wo_id",r).eq("is_deleted",!1).order("work_date",{ascending:!1});return o||!e?[]:e.map(_)}async function A(r){if(!a)return null;const{data:e,error:o}=await a.from("wo_labor").insert({workspace_id:r.workspaceId,wo_id:r.woId,worker_id:r.workerId??null,worker_name:r.workerName,craft:r.craft??null,hours:r.hours,hourly_rate:r.hourlyRate??null,work_date:r.workDate,notes:r.notes??null}).select().single();return o||!e?null:_(e)}async function p(r){if(!a)return null;const{data:e,error:o}=await a.from("wo_failure_report").select("*").eq("wo_id",r).eq("is_deleted",!1).maybeSingle();return o||!e?null:u(e)}async function B(r){if(!a)return null;const{data:e,error:o}

1=await a.from("wo_failure_report").upsert({workspace_id:r.workspaceId,wo_id:r.woId,failure_mode_id:r.failureModeId??null,cause_code_key:r.causeCodeKey??null,failure_mechanism_key:r.failureMechanismKey??null,action_taken:r.actionTaken,root_cause_notes:r.rootCauseNotes??null,failure_date:r.failureDate??null,detected_date:r.detectedDate??null,repaired_date:r.repairedDate??null,downtime_hours:r.downtimeHours??null,parts_replaced:r.partsReplaced??null,recommendations:r.recommendations??null},{onConflict:"wo_id"}).select().single();return o||!e?null:u(e)}const L=Object.freeze(Object.defineProperty({__proto__:null,closeWorkOrder:M,createWoLabor:A,createWoMeasurement:E,createWoTask:P,createWorkOrder:I,deleteWoTask:O,deleteWorkOrder:W,getFailureReport:p,getWorkOrder:h,listWoLabor:H,listWoMeasurements:S,listWoTasks:N,listWorkOrders:R,transitionWorkOrder:C,updateWoTask:K,updateWorkOrder:b,upsertFailureReport:B},Symbol.toStringTag,{value:"Module"}));export{P as a,I as c,h as g,R as l,C as t,L as w};