// ============ Inbox · รับบิล/งานจากแอปพนักงาน (OPS) ============ // 5A: แสดงรายการ integrationInbox (eventType=purchase_bill) ที่พนักงานส่งเข้ามา // ดูรูป · ตีกลับ · กรองสถานะ (AI อ่านบิล=5B, ยืนยันเข้าสต็อก=5C ทำต่อภายหลัง) function inboxStatusMeta(status){ switch(status){ case 'new': return {label:'รอตรวจ', tone:'orange'}; case 'parsing': return {label:'AI กำลังอ่าน', tone:'blue'}; case 'review': return {label:'รอยืนยัน', tone:'blue'}; case 'confirmed': return {label:'ยืนยันแล้ว', tone:'green'}; case 'rejected': return {label:'ตีกลับ', tone:'red'}; default: return {label:status||'-', tone:'gray'}; } } function inboxFmtTs(iso){ if(!iso) return '–'; const d=new Date(iso); if(isNaN(d)) return String(iso); return d.toLocaleString('th-TH',{dateStyle:'medium',timeStyle:'short'}); } // ดึงตัวเลขออกจากข้อความ (กันคอมมา/สัญลักษณ์เงิน) function billNum(v,d=0){ if(typeof v==='number') return isNaN(v)?d:v; const n=parseFloat(String(v??'').replace(/[^0-9.\-]/g,'')); return isNaN(n)?d:n; } // แปลงผลจาก AI Vision → ร่างบิลที่จับคู่วัตถุดิบแล้ว function buildBillDraft(json, db){ const src=(json&&(json.bill||json.data||json))||{}; const rows=src.items||src.lines||src.ingredients||[]; const lines=rows.map((row,i)=>{ const label=row.name||row.item||row.ingredient||('รายการ #'+(i+1)); const code=String(row.code??row.articleNumber??row.article??row.barcode??row.sku??'').trim(); // จับคู่ด้วยรหัสก่อน (แม่นกว่า) ถ้าไม่เจอค่อยจับด้วยชื่อ let item=code?(db.ingredients||[]).find(ing=>(ing.codes||[]).includes(code)):null; if(!item) item=window.aiMatchNamed?window.aiMatchNamed(db.ingredients||[],label):null; return { label, code, ingId:item?item.id:'', qty:billNum(row.qty??row.quantity??row.amount,1), unit:(item&&item.unit)||row.unit||'', unitPrice:billNum(row.unitPrice??row.price??row.unit_price??row.unitprice,0), }; }); return { source:'vision', vendor:src.vendor||'', billDate:src.billDate||src.date||'', total:billNum(src.total,0), discount:billNum(src.discount??src.discountTotal??src.totalDiscount,0), lines, notes:src.notes||'', }; } // รวมยอดร่างบิลจากบรรทัด (qty×unitPrice) function billLinesTotal(lines){ return (lines||[]).reduce((s,l)=>s+billNum(l.qty,0)*billNum(l.unitPrice,0),0); } function InboxPage(){ const { db, setDb, flash, settings, addMediaAsset, logActivity } = useData(); const inbox = (db.integrationInbox||[]) .filter(r=>r.eventType==='purchase_bill') .slice().sort((a,b)=>String(b.createdAt||'').localeCompare(String(a.createdAt||''))); const [filter,setFilter]=React.useState('all'); const [viewImg,setViewImg]=React.useState(null); // {url,name} const [rejectFor,setRejectFor]=React.useState(null); // record const [rejectReason,setRejectReason]=React.useState(''); const [reviewFor,setReviewFor]=React.useState(null); // record ที่เปิดร่างบิล const [busyId,setBusyId]=React.useState(null); // id ที่ AI กำลังอ่าน const [addOpen,setAddOpen]=React.useState(false); // modal เพิ่มบิลเอง const aiEndpoint=(typeof localStorage!=='undefined' && localStorage.getItem('jebar_ai_chat_endpoint'))||''; const counts = { new: inbox.filter(r=>r.status==='new').length, review: inbox.filter(r=>r.status==='review'||r.status==='parsing').length, confirmed: inbox.filter(r=>r.status==='confirmed').length, rejected: inbox.filter(r=>r.status==='rejected').length, }; const pendingValue = inbox.filter(r=>r.status==='new'||r.status==='review') .reduce((s,r)=>s+(+(r.hint&&r.hint.totalAmount)||0),0); const rows = inbox.filter(r=>filter==='all' || r.status===filter || (filter==='review' && r.status==='parsing')); const updateRecord=(id,patch)=>{ setDb(prev=>({ ...prev, integrationInbox:(prev.integrationInbox||[]).map(r=>r.id===id?{...r,...patch}:r) })); }; const doReject=()=>{ if(!rejectFor) return; updateRecord(rejectFor.id,{ status:'rejected', reviewedAt:new Date().toISOString(), parsed:{...(rejectFor.parsed||{}),rejectReason:rejectReason.trim()||'ไม่ระบุเหตุผล'} }); flash('ตีกลับบิลแล้ว'); setRejectFor(null); setRejectReason(''); }; const firstImage=(r)=>(r.images&&r.images[0])||null; // เรียก AI อ่านบิล → จับคู่วัตถุดิบ → เปิดร่างให้ตรวจ const runAiParse=async(r)=>{ const img=firstImage(r); if(!aiEndpoint){ // ไม่มี endpoint → เปิดร่างเปล่าให้กรอกเอง const draft=(r.parsed&&r.parsed.lines)?r.parsed:{source:'manual',vendor:(r.hint&&r.hint.vendor)||'',billDate:(r.hint&&r.hint.billDate)||'',total:0,lines:[],notes:''}; updateRecord(r.id,{status:'review',parsed:draft}); setReviewFor({...r,status:'review',parsed:draft}); flash('ยังไม่ได้ตั้งค่า AI endpoint (หน้า AI) — เปิดโหมดกรอกเองให้แทน','warn'); return; } setBusyId(r.id); updateRecord(r.id,{status:'parsing'}); try{ const res=await fetch(aiEndpoint,{ method:'POST',headers:{'Content-Type':'application/json'}, body:JSON.stringify({ mode:'parse_bill', imageUrl:(img&&img.url)||null, image:r.imageData||null, ingredients:(db.ingredients||[]).map(i=>({id:i.id,name:i.name,unit:i.unit})), }) }); if(!res.ok) throw new Error((await res.text())||('AI error '+res.status)); const json=await res.json(); if(json.error) throw new Error(json.error); const draft=buildBillDraft(json, db); updateRecord(r.id,{status:'review',parsed:draft}); setReviewFor({...r,status:'review',parsed:draft}); flash('AI อ่านบิลแล้ว ตรวจและแก้ก่อนยืนยัน'); }catch(e){ updateRecord(r.id,{status:'new'}); flash('AI อ่านบิลไม่สำเร็จ: '+(e.message||e),'err'); }finally{ setBusyId(null); } }; const saveDraft=(record,draft)=>{ updateRecord(record.id,{status:'review',parsed:draft}); flash('บันทึกร่างบิลแล้ว'); setReviewFor(null); }; // 5C: ยืนยันร่างบิล → สร้าง purchaseEvent + รับเข้าสต็อก + (ออปชัน) อัปเดตต้นทุน const confirmToStock=(record,draft)=>{ const lines=(draft.lines||[]).filter(l=>l.ingId && billNum(l.qty,0)>0); if(!lines.length){ flash('ต้องมีอย่างน้อย 1 บรรทัดที่จับคู่วัตถุดิบและมีจำนวน','err'); return; } const now=new Date().toISOString(); // บิลย้อนหลัง: ใช้วันที่บนบิลเป็นวันที่มีผลต่อสต็อก/ต้นทุน ถ้าไม่มี/ไม่ถูกต้องค่อย fallback เป็นวันนี้ let effDate=now; if(draft.billDate){ const d=new Date(draft.billDate+'T12:00:00'); if(!isNaN(d)) effDate=d.toISOString(); } // เฉลี่ยส่วนลดทั้งบิลลงทุกบรรทัดตามสัดส่วนมูลค่า (pro-rata) const discount=billNum(draft.discount,0); const grossConf=lines.reduce((s,l)=>s+billNum(l.qty,0)*billNum(l.unitPrice,0),0); const factor=(discount>0 && grossConf>0) ? Math.max(0,(grossConf-discount))/grossConf : 1; let work={...db}; const peIds=[]; const updatedCost={}; lines.forEach(l=>{ const qty=billNum(l.qty,0); const unitPrice=billNum(l.unitPrice,0)*factor; // ราคาหลังเฉลี่ยส่วนลด // หา/สร้าง stockItem ของวัตถุดิบนี้ let item=(work.stockItems||[]).find(s=>s.refType==='ingredient'&&s.refId===l.ingId); if(!item){ item=stockNewItem(work,'ingredient',l.ingId); work={...work,stockItems:[...(work.stockItems||[]),item]}; } // รับเข้าสต็อก (ลงวันที่ตามบิล) const upd=stockApplyMovement(work,item.id,qty,'receive',`บิล ${draft.vendor||record.id}`,'purchase',record.id,effDate); work={...work,...upd}; // purchaseEvent (เมื่อมีราคา) if(unitPrice>0){ const peId=nextCode(work.purchaseEvents||[],'PEV'); peIds.push(peId); work={...work,purchaseEvents:[...(work.purchaseEvents||[]),{ id:peId, stockItemId:item.id, qty, unitCost:unitPrice, totalCost:qty*unitPrice, supplier:draft.vendor||'', receivedAt:effDate, note:'จากบิล '+record.id+(discount>0?` (เฉลี่ยส่วนลด ${Math.round((1-factor)*100)}%)`:''), }]}; updatedCost[l.ingId]=unitPrice; } }); // เรียนรู้รหัสสินค้า: ผูกรหัสในบิลเข้ากับวัตถุดิบที่จับคู่ (ครั้งหน้าจับด้วยรหัสได้เลย) const learnCodes={}; // ingId -> [codes] lines.forEach(l=>{ const code=String(l.code||'').trim(); if(code){ (learnCodes[l.ingId]=learnCodes[l.ingId]||[]).push(code); } }); // อัปเดตต้นทุน + เรียนรู้รหัส ในรอบเดียว if((draft.updateCost!==false && Object.keys(updatedCost).length) || Object.keys(learnCodes).length){ work={...work, ingredients:(work.ingredients||[]).map(i=>{ let ni=i; if(draft.updateCost!==false && updatedCost[i.id]!=null) ni={...ni,costPerUnit:updatedCost[i.id]}; if(learnCodes[i.id]){ const merged=Array.from(new Set([...(ni.codes||[]), ...learnCodes[i.id]])); ni={...ni,codes:merged}; } return ni; })}; } // ปิดงานบิลใน inbox work={...work, integrationInbox:(work.integrationInbox||[]).map(r=>r.id===record.id?{ ...r, status:'confirmed', reviewedAt:now, parsed:{...draft,total:billLinesTotal(draft.lines)}, resultRefs:{purchaseEventIds:peIds}, }:r)}; setDb(work); if(logActivity) logActivity('inbox.confirm',{entityType:'inbox',entityId:record.id,note:`ยืนยันบิล ${draft.vendor||record.id} · ${lines.length} รายการ`}); flash(`ยืนยันเข้าสต็อกแล้ว ${lines.length} รายการ`); setReviewFor(null); }; // เจ้าของเพิ่มบิลเอง: สร้าง record ใหม่ใน inbox แล้วเปิดร่างให้กรอก/แก้ const createOwnerBill=(rec)=>{ setDb(prev=>({...prev, integrationInbox:[...(prev.integrationInbox||[]), rec]})); setReviewFor(rec); }; // สร้างวัตถุดิบใหม่จากบรรทัดในบิล (กรณีสินค้าไม่มีในระบบ) แล้วคืน object ให้ผูกกับบรรทัด const createIngredient=({name,unit,costPerUnit,category,code})=>{ const id=nextCode(db.ingredients||[],'ING'); const cat=category||'ของใช้สิ้นเปลือง'; const ing={ id, name:(name||'').trim()||id, unit:unit||'หน่วย', costPerUnit:billNum(costPerUnit,0), category:cat, type:cat, status:'active', buyPrice:billNum(costPerUnit,0), buyQty:1, yield:1, codes:code?[String(code).trim()]:[] }; setDb(prev=>({...prev, ingredients:[...(prev.ingredients||[]), ing]})); if(logActivity) logActivity('ingredient.created',{entityType:'ingredient',entityId:id,note:`สร้างจากบิล: ${ing.name}`}); return ing; }; return
{/* summary */}
setAddOpen(true)}>เพิ่มบิลเอง}>กล่องรับบิล (Inbox)