+ ZjZ Rt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t H t H t ^RIHt]!R4t]R, t]R, t]R, t]R, t]!R 4t]!]4P.R , t]R , tR t^t.ReOt^R ^R^R^R^R^R^R^R/tRRRRR/RRRRR/RRRRR//tR R!R"R#R$R%R&R'R(R(R)R*R+R,R-R.R/R0R1R2R3R4/ t.RfOt .RgOt!.RhOt".RiOt#.RjOt$.RkOt%R5t&R6t'R7t(R8t)R9t*R:t+R;t,R<t-RlR=lt.RmR>lt/RmR?lt0R@t1RAt2RBt3RCt4RDt5RnRElt6RFt7RGt8RHt9RIt:RJt;RKtRNt?ROt@RPtARQtBRRtCRStDRTtERUtFRVtGRWtHRXtIRYtJRZtKR[tLR\tMR]tNR^tOR_tPR`tQRatRRbtSRctT]URd8Xd ]T!4R#R#)ou i4Fuel deal pipeline v2 — single-file CLI. Companies and contacts are first-class entities (independent of deals). Inquiries are the pre-deal layer — every inbound FCO/RFQ lands here first. Incidents track scams, no-shows, breaches against companies over time. Auto-checks on company creation: - Local blacklist folder scan (Dropbox/Petrol trade/Blacklists/) - OFAC SDN list match (cached weekly) Storage: SQLite on Dropbox. Dashboard: auto-regenerated HTML. N)datetime timedeltatimezone)PathzX/Users/bjornvanwieringen/Library/CloudStorage/Dropbox-i4fuel/i4fuel team folder/Pipelinez i4fuel.dbzdashboard.htmlACTIVECLOSEDzg/Users/bjornvanwieringen/Library/CloudStorage/Dropbox-i4fuel/i4fuel team folder/Petrol trade/Blacklistscachez ofac_sdn.csvz/https://www.treasury.gov/ofac/downloads/sdn.csvInquiryz Mandate / LOIzOffer (ICPO/FCO)zContract (SPA)zVerification / POPPaymentzCommission settlementClosedi4fuelnamez i4Fuel BVkvk97064874 hertsbergzHertsberg Ventures BV82687978glayazGlaya Holding BV82618464EN590zEN590 10ppm DieselJA1z Jet Fuel A1D6zD6 Virgin Fuel OilCRUDEz Crude OilLNGSUGARzBrazil Sugar ICUMSA 45SBOzCrude Soybean OilSFOLz Sunflower OilBITUMBitumenCHEM ChemicalsLUBE Lubricantsa CREATE TABLE IF NOT EXISTS companies ( id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, name_normalized TEXT NOT NULL, country TEXT, registration_no TEXT, address TEXT, website TEXT, email TEXT, phone TEXT, trust_level TEXT NOT NULL DEFAULT 'unknown', dd_status TEXT NOT NULL DEFAULT 'not_checked', dd_score TEXT, dd_report_path TEXT, dd_checked_at TEXT, ofac_status TEXT NOT NULL DEFAULT 'not_checked', ofac_checked_at TEXT, ofac_hit_details TEXT, blacklist_folder_match TEXT, notes TEXT, created_at TEXT NOT NULL, updated_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_companies_normalized ON companies(name_normalized); CREATE INDEX IF NOT EXISTS idx_companies_trust ON companies(trust_level); CREATE INDEX IF NOT EXISTS idx_companies_dd ON companies(dd_status); CREATE TABLE IF NOT EXISTS contacts ( id INTEGER PRIMARY KEY AUTOINCREMENT, company_id INTEGER REFERENCES companies(id) ON DELETE CASCADE, name TEXT NOT NULL, email TEXT, phone TEXT, title TEXT, passport_no TEXT, nationality TEXT, notes TEXT, created_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_contacts_company ON contacts(company_id); CREATE TABLE IF NOT EXISTS inquiries ( id INTEGER PRIMARY KEY AUTOINCREMENT, direction TEXT NOT NULL, type TEXT NOT NULL, channel TEXT NOT NULL, company_id INTEGER REFERENCES companies(id) ON DELETE SET NULL, contact_id INTEGER REFERENCES contacts(id) ON DELETE SET NULL, raw_company_name TEXT, raw_contact TEXT, commodity_code TEXT, volume_mt REAL, monthly_mt REAL, price_usd REAL, price_unit TEXT, incoterm TEXT, origin TEXT, port TEXT, payment_terms TEXT, received_at TEXT, status TEXT NOT NULL DEFAULT 'open', rejection_reason TEXT, deal_id TEXT REFERENCES deals(id) ON DELETE SET NULL, next_action TEXT, notes TEXT, created_at TEXT NOT NULL, updated_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_inquiries_status ON inquiries(status); CREATE INDEX IF NOT EXISTS idx_inquiries_company ON inquiries(company_id); CREATE TABLE IF NOT EXISTS incidents ( id INTEGER PRIMARY KEY AUTOINCREMENT, company_id INTEGER NOT NULL REFERENCES companies(id) ON DELETE CASCADE, date TEXT NOT NULL, type TEXT NOT NULL, description TEXT, related_inquiry_id INTEGER REFERENCES inquiries(id) ON DELETE SET NULL, related_deal_id TEXT REFERENCES deals(id) ON DELETE SET NULL, created_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_incidents_company ON incidents(company_id); CREATE TABLE IF NOT EXISTS deals ( id TEXT PRIMARY KEY, commodity_code TEXT NOT NULL, commodity TEXT NOT NULL, counterparty_company_id INTEGER REFERENCES companies(id) ON DELETE SET NULL, counterparty_name TEXT NOT NULL, our_role TEXT NOT NULL, our_entity TEXT NOT NULL, stage INTEGER NOT NULL DEFAULT 1, volume_mt REAL, monthly_mt REAL, price_usd REAL, price_unit TEXT, incoterm TEXT, port TEXT, origin TEXT, payment_terms TEXT, folder_path TEXT, inquiry_id INTEGER REFERENCES inquiries(id) ON DELETE SET NULL, notes TEXT, created_at TEXT NOT NULL, updated_at TEXT NOT NULL, closed_at TEXT ); CREATE INDEX IF NOT EXISTS idx_deals_stage ON deals(stage); CREATE INDEX IF NOT EXISTS idx_deals_company ON deals(counterparty_company_id); CREATE TABLE IF NOT EXISTS deal_parties ( id INTEGER PRIMARY KEY AUTOINCREMENT, deal_id TEXT NOT NULL REFERENCES deals(id) ON DELETE CASCADE, company_id INTEGER NOT NULL REFERENCES companies(id) ON DELETE CASCADE, contact_id INTEGER REFERENCES contacts(id) ON DELETE SET NULL, role TEXT NOT NULL, bank_name TEXT, bank_iban TEXT, bank_swift TEXT, bank_account_name TEXT, notes TEXT, created_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_dealparties_deal ON deal_parties(deal_id); CREATE INDEX IF NOT EXISTS idx_dealparties_company ON deal_parties(company_id); CREATE TABLE IF NOT EXISTS commissions ( id INTEGER PRIMARY KEY AUTOINCREMENT, deal_id TEXT NOT NULL REFERENCES deals(id) ON DELETE CASCADE, deal_party_id INTEGER NOT NULL REFERENCES deal_parties(id) ON DELETE CASCADE, amount_per_unit REAL NOT NULL, unit TEXT NOT NULL, total_amount REAL, paid INTEGER NOT NULL DEFAULT 0, paid_at TEXT, notes TEXT, created_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_commissions_deal ON commissions(deal_id); CREATE TABLE IF NOT EXISTS documents ( id INTEGER PRIMARY KEY AUTOINCREMENT, deal_id TEXT REFERENCES deals(id) ON DELETE CASCADE, inquiry_id INTEGER REFERENCES inquiries(id) ON DELETE CASCADE, doc_type TEXT NOT NULL, stage INTEGER, filename TEXT, filepath TEXT, signed INTEGER NOT NULL DEFAULT 0, sent_at TEXT, received_at TEXT, notes TEXT, created_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_documents_deal ON documents(deal_id); CREATE TABLE IF NOT EXISTS comms_log ( id INTEGER PRIMARY KEY AUTOINCREMENT, deal_id TEXT REFERENCES deals(id) ON DELETE CASCADE, inquiry_id INTEGER REFERENCES inquiries(id) ON DELETE CASCADE, company_id INTEGER REFERENCES companies(id) ON DELETE SET NULL, contact_id INTEGER REFERENCES contacts(id) ON DELETE SET NULL, direction TEXT NOT NULL, channel TEXT NOT NULL, subject TEXT, summary TEXT, timestamp TEXT NOT NULL, created_at TEXT NOT NULL ); CREATE INDEX IF NOT EXISTS idx_commslog_deal ON comms_log(deal_id); CREATE INDEX IF NOT EXISTS idx_commslog_inquiry ON comms_log(inquiry_id); CREATE TABLE IF NOT EXISTS stage_history ( id INTEGER PRIMARY KEY AUTOINCREMENT, deal_id TEXT NOT NULL REFERENCES deals(id) ON DELETE CASCADE, from_stage INTEGER, to_stage INTEGER NOT NULL, changed_at TEXT NOT NULL, notes TEXT ); c\P!\4p\PVnVP R4V#)zPRAGMA foreign_keys = ON)sqlite3connectDB_PATHRow row_factoryexecuteconns B/Users/bjornvanwieringen/BJVRN/scripts/i4fuel-pipeline/pipeline.pydbr, s. ??7 #D{{DLL+, Kc@\PRRR7\PRR7\PRR7\PRR7\ 4;_uu_4pVP \4RRR4R# +'giR#;i)Tparentsexist_okr1N) DROPBOX_ROOTmkdir ACTIVE_DIR CLOSED_DIR CACHE_DIRr, executescriptSCHEMAr)s r+init_dbr:shtd3d#d# OOTO"  6" s ,B  B cj\P!\P4P RR7#)seconds)timespec)rnowrutc isoformatr-r+r>r>s# << % / / / CCr-cFV'gR#RPRV44#)c3p"TF,qP4'gKVP4xK. R#5iN)isalnumlower.0cs& r+ normalize.."s 7a99;917799as66)joinss&r+ normalizerPs  777a7 77r-cRRp\P4'dd\P!4\P!\P 4P 4, pVP\8dRpV'd\RRRR7\PP\RR/R7p\PPV^R 7;_uu_4pVP4pR R R 4\P!X4\R \#V4R , R 24\P4#\P4# +'giLl;i \$d-p\RT R24R p?\P4#R p?ii;i)zBDownload OFAC SDN list if missing or older than OFAC_REFRESH_DAYS.TFz fetching OFAC SDN list... )endflushz User-Agentzi4fuel-pipeline/2)headers)timeoutNzok (iz kB)zfailed (z!); using stale cache if available) OFAC_CACHEexistsrr> fromtimestampstatst_mtimedaysOFAC_REFRESH_DAYSprinturllibrequestRequestOFAC_URLurlopenread write_byteslen Exception) needs_refreshagereqrdataes r+ensure_ofac_cachern%s8Mllnx55joo6G6P6PQQ 88' '!M C /c F..((LJ];^(_C''R'88Avvx9  " "4 ( DTD). /    :    98 C HQC@A B B     Cs1 AE/'E8"8$$X):y?RV\?\ H%t9> > uzz$'(( ! > =s% B(E)9 E) E)E)E)) E9 c`\P4'gR#\V4p\V4^8dR#\P 4F\pVP 4'gKVP p\V4pV'd\V4^8dKLW9g WA9gKZVu# R#)zUSubstring match against local blacklist folder names. Returns matched folder or None.N)LOCAL_BLACKLIST_DIRrXrPrfiterdiris_dirr )r|r}entryfolderns& r+blacklist_folder_checkrTs  % % ' ' | $F 6{Q$,,.||~~  f CFQJ  ;!+M/ r-cxVeRV R2MRpV'dVRRPV4 R2, p\V V R24P4pV'gVeV#V'g V'gR#V'gV'd\R 4KV'd&WS9d \R R PV4 24KV#) TNz []rC (/): z required.z must be one of: , )rMinputrzr^)labeldefaultrequiredoptionssuffixvals&&&& r+promptrhs $+$72gYaR  388G,-Q/ /FugfXR()//1w*N8x -  s) &tyy'9&:; <  r-c|\WVR7pVfR#\V4# \d\R4K9i;i)TrrNz must be a number.)rfloat ValueErrorr^rrrrs&&& r+ prompt_floatr{s@ Uh? ; ):  ) ' ( ) !;;c|\WVR7pVfR#\V4# \d\R4K9i;i)TrNz must be an integer.)rintrr^rs&&& r+ prompt_intrs? Uh? ; +s8O + ) * +rc^RPRV44PR4R,#)rCc3T"TFqP4'dTMRxK R#5i)-N)rFrHs& r+rKslug..s;d 1,ds&(rNN)rMrz)texts&r+slugrs' 77;d; ; A A# Fs KKr-c  \P!4Pp\4;_uu_4pVP RV RV R234P 4pRRR4XR,^,# +'giL ;i)z/SELECT COUNT(*) AS n FROM deals WHERE id LIKE ?z-%-z-%Nr)rr>yearr,r(fetchone)commodity_coderr*rs& r+ next_deal_seqrsj <<>  D ll =vS( + -  (*   s8a< s (A22 B c \P!4Pp\V4pV RVR RV R\ V4P 4R, 2#)r02dN N)rr>rrrupper)r counterpartyrseqs&& r+ make_deal_idrsQ <<>  D  'CV1SIQ~.a\0B0H0H0J30O/P QQr-cV R\V4 R\V4 2p\V, pVPRRR7\FpWE, PRR7K V#)_Tr/r2)rr5r4DEAL_SUBFOLDERS)deal_id commodityrr rsubs&&& r+create_deal_foldersrs_YaY($|*<)= >D $ F LLL- d+ Mr-c\V4p\4;_uu_4pVPRV34P4pRRR4V# +'giX#;i)z1SELECT * FROM companies WHERE name_normalized = ?N)rPr,r(r)r rr*rs& r+find_company_by_namersI$A llNQRPTU^^`  J  Js "A  A c<.p\4p \V4p \V4wrV R8wdT MRp RpV 'gV R8Xd:RpV 'dVPRV 24V R8XdVPRV 24\ 4;_uu_4pVP RV\ V4WW4WVWWWW34pVPpV 'dVP R VV R R V 2V 34V R8XdVP R VV R W34RRR4VV3# +'giXT3#;i) zOCreate company and run blacklist + OFAC checks. Returns (company_id, warnings).ruNunknownrt blacklistedzBLACKLIST FOLDER MATCH: z OFAC HIT: a1INSERT INTO companies (name, name_normalized, country, registration_no, address, website, email, phone, trust_level, ofac_status, ofac_checked_at, ofac_hit_details, blacklist_folder_match, notes, created_at, updated_at) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)ZINSERT INTO incidents (company_id, date, type, description, created_at) VALUES (?,?,?,?,?) blacklist_hitzFolder match: ofac_hit)r>rrr{r,r(rP lastrowid)r countryregistration_noaddresswebsiteemailphonenoteswarningstsbl_match ofac_status ofac_detailsofac_ts trust_levelr*curcids&&&&&&&& r+create_company_with_checksrs4H B%d+H *4 0K=0bdGK;%'#  OO6xjA B %  OOj7 8 ll ;9T?GgPU whr W  mm  LLlb/^H:+FK  %  LLlb*l7 # * =+ * =s A0D D c\R24\R4\R24\RRRR.R7p\RR\R7p\RR.R3OR7p\R RR 7p\V4pR p.pV'd5VR ,p\R VR , RVR, RVR, R24M\R4\R4p\R4p \R4p \R4p \R4p \R4p \ WHWWV 4wrgVFp\RV 24K V'd \R4\R4p\R4\R\ \ P44R7p\R 4p\R!4p\R"4p\R#R$R%7p\R&4p\R'4p\R(4p\R)R*R%7p\R+4p\R,4p\4p\4;_uu_4pVPR-WW6WOVVVVVVVVVVR.VVVV34pVPpR R R 4\R/X R024V'd \R14\4R # +'giL>;i)4=z New inquiry DirectionTinboundoutboundrrTypeChannelzCounterparty company namerNidu" → linked to existing company # (trust: r, DD: dd_statusru4 company not in DB — creating with auto-checks...z Countryz Registration / KVK noz Addressz Websitez Company emailz Phone ⚠ uU → company created as 'blacklisted'. Override with: pipeline.py company trust uGContact person (name only — add full contact later via 'contact new')z) Deal terms (as proposed in the inquiry):z Commodity code)rz Volume MTz Monthly MTz Price USDz Price unitMTrz Incotermz Originz Portz Payment termsMT103/TTz Next actionNotesapINSERT INTO inquiries (direction, type, channel, company_id, raw_company_name, raw_contact, commodity_code, volume_mt, monthly_mt, price_usd, price_unit, incoterm, origin, port, payment_terms, received_at, status, next_action, notes, created_at, updated_at) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)rwu ✓ Inquiry #z logged.uJ ⚠ Counterparty has blacklist/OFAC flags — review before progressing.<============================================================)rteamswhatsapprbroker)r^r INQUIRY_TYPESrrlistCOMMODITY_CODESkeysrr>r,r(rregenerate_dashboard)args directioninq_typechannelr|existing company_idrrregaddrwebrrw contact_rawr volume_mt monthly_mt price_usd price_unitincotermoriginport payment_terms next_actionrrr*riids& r+cmd_inquiry_newr sj (O - (O{TIz;RSIft]CHYNPG5EL#L1HJHd^  28D>2B)HUbLcKddjkstlAkBBCD E DE%./k"[!()y!9 3c%  A F1#,   i jbcK 67._=Q=Q=S8TUN]+In-J]+I5Jl#H J F ( D,jAM'K 7OE B ll E '| Y Iz vt]B B   mm  OC5 )* Z[# s ?1I&& I6 cVP'gRMRp\4;_uu_4pVPRV R24P4pRRR4X'g\ R4R#\ RRR R R R R R R R RR R RR R RR R RR R RR 24\ R!4VFp\ VR,R R VR,R R VR,R R VR,R R VR,;'gRR R VR,;'gRR,R R VR,;'gRR R VR ,;'gRR 24K R# +'giL;i)"zWHERE status = 'open'rCzSELECT i.*, c.trust_level, c.dd_status FROM inquiries i LEFT JOIN companies c ON c.id = i.company_id z ORDER BY created_at DESCNz No inquiries. ID>4s Dir8srRr6sStatus12s Commodity Counterparty28sTrustDDr>4drtypestatusr—raw_company_name:NNrrzn--------------------------------------------------------------------------------------------------------------)allr,r(fetchallr^)rwherer*rowsrks& r+cmd_inquiry_listr$#sl+/888 #E ||w/ 3  (*    o BtCj5*AfR[(3q  Q~c2!GC=$s MN )  4 R+r2!AfIb>1X;sBSST$%..4Aq9K7L7R7RPRTW6XY\5]]^M"++eS1AkN4K4KeS2QS T s $D<< E cx\4;_uu_4pVPRVP34P4pRRR4X'g0\ RVP R24\ P !^4\ RR; RVR, RR; 24\ RVR, 24\ R VR , 24\ R VR , 24\ R VR, 24\ RVR,;'g VR, RVR,;'gR R24\ RVR,;'gR RVR,;'gR 24\ RVR,;'gR 24\ RVR,;'gR 24\ RVR ,;'gR R!VR",;'gR R#24\ R$VR%,;'gR R&VR',;'gR 24\ R(VR),;'gR 24\ R*VR+,;'gR R,VR-,;'gR 24\ R.VR/,;'gR 24\ R0VR1,'dVR1,R2,MR 24\ R3VR4,;'gR 24\ R5VR6,;'gR 24VR7,'d\ R8VR7, 24VR9,'d\ R:VR9, 24R#R# +'giEL;i);R;RU:S TU Q}-667 89 Q/099E: ;< Q{^44u5]1\?C[C[V[B\\` ab Q{^44u5U1\?;S;Se:T UV Qz]33e4 56 Qx[11E2%& 8J8JU7K LM Q/8859 :; a 6F6FQ}-c2ER ST Q}-667 89 Qy\22U3 45   #5!6 789zz  7 -.9 s ,L(( L9 c\4;_uu_4pVPRVP34P4pV'g0\ RVP R24\ P !^4VR,R8Xd-\ RVR, R24\ P !^4VR,'g"\ R 4\ P !^4VPR VR,34P4pR R R 4\ R XR , R24\ RXR, RVR, RVR, R24VR,R89dUVP'g-\ RVR, R24\ P !^4\ RVR, R24VR,R8wdJVP'g-\ RVR, R24\ P !^4\ R4\RR.R9OR"7p\R#R$\\P44R%7pVR&,;'g*\R'R\\P44R"7p\V,p\R(4p\WcR,4p \WVR,4p \4p \4;_uu_4pVPR)WWsR ,VR,WEVR*,VR+,VR,,VR-,VR.,VR/,VR0,VR1,\!V 4VR ,VW34VR 8XdR!MR p VPR2WR ,W34VPR3V R ^V R4VR , 234VPR5WVR ,34R R R 4\ R6V 24\ R7V 24\#4R # +'giEL;i +'giLL;i):$SELECT * FROM inquiries WHERE id = ?r&r'r convertedz"Inquiry already converted to deal r.rzGInquiry has no linked company. Link one first: pipeline.py inquiry link$SELECT * FROM companies WHERE id = ?NzConverting inquiry #rz to deal.zCounterparty: r rrrrru⚠ Counterparty is z. Use --force to override.u⚠ Proceeding despite z flag.passedu⚠ DD status is 'z'. Run DD first or use --force.u!⚠ Proceeding without passed DD.Our roleTbuyersellerr Our entityrrrrCommodity codez.Notes (optional, in addition to inquiry notes)avINSERT INTO deals (id, commodity_code, commodity, counterparty_company_id, counterparty_name, our_role, our_entity, stage, volume_mt, monthly_mt, price_usd, price_unit, incoterm, port, origin, payment_terms, folder_path, inquiry_id, notes, created_at, updated_at) VALUES (?,?,?,?,?,?,?,1,?,?,?,?,?,?,?,?,?,?,?,?,?)rrrrrrrrz`INSERT INTO deal_parties (deal_id, company_id, role, created_at) VALUES (?,?,?,?)_INSERT INTO stage_history (deal_id, from_stage, to_stage, changed_at, notes) VALUES (?,?,?,?,?)zConverted from inquiry #zSUPDATE inquiries SET status = 'converted', deal_id = ?, updated_at = ? WHERE id = ?u ✓ Converted to deal Folder: scammerrr>r? intermediary)r,r(rrr^r4r5forcerrENTITIESrrrrr>strr) rr*inqcompanyour_role our_entityrrrrrrcounterparty_roles & r+cmd_inquiry_convertrQXsl llADGG:NWWY HTWWI[1 2 HHQK x=K ' 6s9~6FaH I HHQK<  [ \ HHQK,,ELHYG[\eeg  T 9 56 N76?+9W]5K4LFSZ[fSgRhhi jk}!;;zzz ()?(@@Z[ \ HHQK ' (>'?vFG{x'zzz &w{';&<<[\ ] HHQK 13j49\]H k4 CXYJ)*\\f5EPT>B?CWCWCY>Z/\N/I C DE>6?;G WV_ EF B   E i 3{#3S5F  s<0#j/3v; ]C0#f+s4y%    )1G(;H  # dm%6 ; m dAr%=c$i[#I J  a #d) $ 1 : $WI ./ Jvh  M N s B+O ?A O CO4 O1 4 P c XVP;'g\RRR7p\RRRR.R7R8HpRpV'd2\RR P\44\R R\R 7p\ 4p\ 4;_uu_4pVPR VP34P4pV'g0\R VP R24\P!^4VPRWVP34V'dXVR,'dIVPRVR,WCWPV34VR9dVPRWFR,34RRR4\RVP R24\4R# +'giL5;i)zRejection reasonTrz,Log as incident on company? (scam/fake/etc.)ryrANzIncident types:rz Incident typerr8r&r'z[UPDATE inquiries SET status = 'rejected', rejection_reason = ?, updated_at = ? WHERE id = ?rzINSERT INTO incidents (company_id, date, type, description, related_inquiry_id, created_at) VALUES (?,?,?,?,?,?)zeUPDATE companies SET trust_level = 'suspect', updated_at = ? WHERE id = ? AND trust_level = 'unknown' ✓ Inquiry #z rejected.) scam_attempt fake_offerpayment_default) reasonrr^rMINCIDENT_TYPESr>r,r(rrr4r5r)rrX log_incident incident_typerr*rLs& r+cmd_inquiry_rejectr\sU [[ E EF#5EFHRU`ceh_ijnqqLM >!:;~V B llADGG:NWWY HTWWI[1 2 HHQK i  !  C -- LLK\"BvwwK   QQ {\*+# * M$''* -.- s BF$AF F) c F\4;_uu_4pVPRVP34P4pVPRVP34P4pV'd V'g"\ R4\ P!^4VPRVP\4VP34RRR4\ RVP RVP RXR , R 24\4R# +'giLL;i) z!Link inquiry to existing company.r8r;zInquiry or company not found.z@UPDATE inquiries SET company_id = ?, updated_at = ? WHERE id = ?NrTz linked to company #rr z).) r,r(rrrr^r4r5r>r)rr*rLrMs& r+cmd_inquiry_linkr^s llADGG:NWWY,,EGYZcce' 1 2 HHQK N __ceTWW -  M$''"6t6Gr'RX/IZZ\ ]^ sA&D:AD D c H\R4\R4\R4\RRR7p\V4pV'd6\RVR, RVR, 24\P!^4\R 4p\R 4p\R 4p\R 4p\R 4p\R4p\R4p \R4\ WWEWgW4wrV Fp \RV 24K \RV R24V 'd \R4\ 4R#)rz New companyz Company nameTru⚠ Company already exists: #rrRr CountryzRegistration / KVK noAddressWebsiteEmailPhonerz# Running blacklist + OFAC checks...ru ✓ Company #z created.uF → trust_level set to 'blacklisted'. Review and override if needed.Nr)r^rrr4r5rr) rr rrrrrrrrrrrs & r+cmd_company_newres (O - (O .4 0D#D)H -htn-=Qx?O>PQR  YG ( )C ) D  C 7OE 7OE 7OE 01.tcUZbMC  qcl OC5 *+ VXr-cVP'dRpMVP'dRpMRp\4;_uu_4pVPRV R24P 4pRRR4X'g\ R4R#\ RRR R R R R RR R RR R RR R RR R RR 24\ R"4VF~pVR,'dRMRp\ VR,R R VR,R,R R VR,;'gRR,R R VR,R R VR ,R R VR!,R R VR 2 4K R# +'giL;i)#z,;'gR*R?, 24KG \ R@\X4 R124VF-p \ R9V R ,RA RBV RC, RDV RE, 24K/ \ RF\X4 R124VFCp\ RGVR ,RH RDVRI,RJ R'VR<,RK R'VRL,;'gR 24KE R# +'giELU;i)Nr;Company r'z+SELECT * FROM contacts WHERE company_id = ?z?SELECT * FROM incidents WHERE company_id = ? ORDER BY date DESCzSELECT id, stage, commodity FROM deals WHERE counterparty_company_id = ? OR id IN (SELECT deal_id FROM deal_parties WHERE company_id = ?)zKSELECT id, status, type, commodity_code FROM inquiries WHERE company_id = ?Nr z Company #rrr z Country: rrz Registration: rz Address: rz Website / Mail: rr*rz Phone: rz Trust level: rz DD status: rz (score: dd_scorerz DD report: dd_report_pathz DD checked at: dd_checked_atz OFAC status: rrRofac_hit_details(rCz Blacklist: rnno matchrz Notes: z Contacts (): [3d] 25stitle20sz Incidents ( daterr18s description:N<Nz Deals (riz stage stagerrz Inquiries (z #z>3drrrrr3) r,r(rrr^r4r5r!rf) rr*rJcontacts incidentsdeals inquiriesctids & r+cmd_company_showrsE  LL?$'' L U U W HTWWI[1 2 HHQK<< 9DGG: (* LL MPTPWPWz (*   X WWdgg   (* LL Y\`\c\c[e (*  & Bxj agYb6 2hZ HI q|44u5 67 q!23<? q|44u5 67 q|44u5S79L9Lu8M NO qz22U3 45 q/0 12 q~.i* 8N8N7Oq QR q!12;;e< => q1::U; <= q/0RSTfRgRgAa8J6K5LA2Nmo1p qr q!9:HHjI JKzz "1W:,/0 N3x=/ ,- bhr]"RZ$4Abk6G6GR5LAbQXkN_N_]_M`ab OC N+2 ./  QvYs^$Aai_Aq7G7M7M2s6S5TUV KE |2 &'  QtWSM7 Bq~6FGH OC N+2 ./  agc]"Qx[$5QqynAaHXFYFbFb]bEcde_ s DQ99 R c 2\4;_uu_4pVPRVP34P4pV'g0\ RVP R24\ P !^4RRR4\ RXR, 24\RR\R 7pRpVR9d\R R.ROR 7p\R 4p\R R \R .,R7p\4p\4;_uu_4pVPRW4WWWpP34VR 8wdVPRW`P34RRR4\ RT RT;'gR 24\4R# +'giEL;i +'giLK;i)z/Update DD status after running /supplier-check.r;rvr'NzDD update for: r z DD statusTrzDD scorez DD report file path (in Dropbox)zUpdate trust level?norAzUPDATE companies SET dd_status = ?, dd_score = ?, dd_report_path = ?, dd_checked_at = ?, updated_at = ? WHERE id = ?z1UPDATE companies SET trust_level = ? WHERE id = ?u✓ DD updated: z, score=r)r<failedrr)lowmediumhigh) r,r(rrr^r4r5r DD_STATUSES TRUST_LEVELSr>r)rr*rJrscorereporttrustrs& r+cmd_company_checkr9sB  LL?$'' L U U W HTWWI[1 2 HHQK   OAfI; '( K$ DF E 00zD:ST 6 7F ($ PTv@U VE B   A FGG 4 D= LLLuV]V]N^ _  VHHU^^e,< =>-  sA#E2?AF2 F  F cFVP;'g\RR\R7p\4;_uu_4pVP RV\ 4VP 34RRR4\RVP RV 24\4R# +'giL7;i)zSet trust level directly.z Trust levelTrzAUPDATE companies SET trust_level = ?, updated_at = ? WHERE id = ?Nu ✓ Company #u trust level → ) levelrrr,r(r>rr^r)rrr*s& r+cmd_company_trustrTss JJ T T&|TE  O CE477 #    M$''"3E7 ;< s (B B c \4;_uu_4pVPRVP34P4pV'g0\ RVP R24\ P !^4RRR4\ RXR, 24\VR,4wr4\4p\4;_uu_4pVPRW5WEVP34VR8Xd>VPR VPVR WE34VPR VP34RRR4\ R T R V'd RV,MR 24\4R# +'giL;i +'giLQ;i)zRe-run OFAC check.r;rvr'NzRunning OFAC check for: r z{UPDATE companies SET ofac_status = ?, ofac_checked_at = ?, ofac_hit_details = ?, updated_at = ? WHERE id = ?rtrrz=UPDATE companies SET trust_level = 'blacklisted' WHERE id = ?u ✓ OFAC: rRu— rC) r,r(rrr^r4r5rr>r)rr*rJrdetailsrs& r+cmd_company_ofacr`s(  LL?$'' L U U W HTWWI[1 2 HHQK   $QvYK 01 6+OF B   D dgg . U? LLl"j'6  LLX[_[b[bZd e  JvhaG 0D EF+  sA#EA$E0 E- 0 F c \RVP 24\RRP\44\ RR\R7p\ RRR7p\ 4p\ 4;_uu_4pVPRVPW1W#34R R R 4\R 4\4R # +'giL';i) zNew incident for company #zTypes:rrTr DescriptionrziINSERT INTO incidents (company_id, date, type, description, created_at) VALUES (?,?,?,?,?)Nu✓ Incident logged.) r^rrMrYrr>r,r(r)ritypedescrr*s& r+cmd_company_incidentrzs &twwi 01 (DIIn-. 6D. AE -$ /D B   % WWb *    " s 3 B22 C c\4;_uu_4pVPRVP34P4pV'g0\ RVP R24\ P !^4RRR4\ RXR, 24\RRR7p\R 4p\R 4p\R 4p\R 4p\R 4p\R4p \4;_uu_4pVPRVPW4WVWxV \43 4p V Pp RRR4\ RX R24\4R# +'giL;i +'giL>;i)r;rvr'NzNew contact at r rhTrrcrdTitlez Passport no NationalityrzINSERT INTO contacts (company_id, name, email, phone, title, passport_no, nationality, notes, created_at) VALUES (?,?,?,?,?,?,?,?,?)u ✓ Contact #z added.) r,r(rrr^r4r5rr>rr) rr*rJr rrrpassport nationalityrrrs & r+cmd_contact_newrs  LL?$//AS T ] ] _ HT__-[9 : HHQK   OAfI; '( &4 (D 7OE 7OE 7OEm$H'K 7OE ll -__d5PUWZW\ ]   mm  M#g &'-  sA#E47E! E ! E1 cp\R24\R4\R24\R4\RRR7p\4;_uu_4pVPRV34P 4pRRR4X'g&\RV R 24\ P !^4\R VR , R VR , RVR, R24VR ,R39gVR,R8wd,\RRRR.R7R8wd\ P !^4\RRP\P444\RRR7P4pV\9d%\RV 24\ P !^4\V,p\RR.R4OR7p\RR\\P44R7p\R 4p\R!4p \R"4p \R#R$R%7p \R&4p \R'4p \R(4p\R)R*R%7p\R+4p\WCR ,4p\!VWSR ,4p\#4p\4;_uu_4pVPR,VWEWR ,WgWWWVV\%V4VVV34VR8XdRMRpVPR-VVVV34VPR.VR^VR/34RRR4\R0V 24\R1V 24\'4R# +'giEL;i +'giLL;i)5uRCreate deal directly (without going through inquiry — outbound proactive deals).u*New deal (direct — bypass inquiry layer)z^Note: typically inbound deals start as 'inquiry new'. Use this for outbound origination only. z-Counterparty company ID (from 'company list')Trr;Nrvr'u → r rrrrrr<zProceed anyway?rrSrAz Commodity codes:rrBzUnknown code: r=r>r?rr@rzTrial volume MTzMonthly volume MTz Price USDz Price unitrrIncotermPortOriginz Payment termsrrahINSERT INTO deals (id, commodity_code, commodity, counterparty_company_id, counterparty_name, our_role, our_entity, stage, volume_mt, monthly_mt, price_usd, price_unit, incoterm, port, origin, payment_terms, folder_path, notes, created_at, updated_at) VALUES (?,?,?,?,?,?,?,1,?,?,?,?,?,?,?,?,?,?,?,?)zQINSERT INTO deal_parties (deal_id, company_id, role, created_at) VALUES (?,?,?,?)rCzDeal created (outbound)u ✓ Created deal rDrrErG)r^rr,r(rr4r5rrMrrrrrJrrrr>rKr)rrr*rJrrrNrOrrrrrrrrrrrrrPs& r+ cmd_deal_newrs (O 67 (O klKVZ[J  LL?* O X X Z    K01   F1V9+Yq'7&8q~>Na PQ55;89S #S3* E L HHQK  /*>*>*@ AB,t<BBDN_, ~./0  /Ij49\]H k4 CXYJ./I12J[)I d3Jj!H &>D H F?J?M 7OE>V95G )vY ?F B   C nvY I86 CKB 8 )1G(;H _ j"3R 8  m dAr#< = ! ( y )* Jvh  m @ s "L9A(L% L" % L5 czVPp\4;_uu_4pTPRV'dRMR R24P4pRRR4X'g\ R4R#\ RRR R R R R R R R RR R RR R RR 2 4\ R4VFpVR, R\ VR,, 2p\ VR,R R VR R VR,R,R R VR,R,R R VR,;'g^R R VR,;'g^R 2 4K R# +'giL;i) zSELECT * FROM deals WHERE z stage = 8z stage < 8rgNz No deals.r r rirRStage22srrr24szVol/MTz>10sz$/Uz>8sr. rr:NNcounterparty_name:NNrz>10,.0frz>8,.2fzx------------------------------------------------------------------------------------------------------------------------)closedr,r(r!r^STAGES)rrr*r#rk stage_labels& r+ cmd_deal_listrs? [[F ||(K(PPi j (*    k BtCj'#a C'8.9MQxX\o]^_deh^i jk ) 7 Bvaj'9&:;  4 Q{3/q;$S)1-@+A#+Fs*K1K.%%Aw/q!K.2E2EAv0NP Q s .D** D: cB \4;_uu_4pVPRVP34P4pV'g0\ RVP R24\ P !^4VPRVP34P4pVPRVP34P4pVPRVP34P4pVPRVP34P4pRRR4\ RRc R XR , RRc 24\ R VR , R \VR ,, 24\ RVR, 24\ RVR, RVR,;'gR R24\ RVR, R\VR,,R, R24\ RVR,;'gR RVR,;'gR R24\ R VR!,;'gR R"VR#,;'gR 24\ R$VR%,;'gR 24\ R&VR',;'gR 24\ R(VR),;'gR 24\ R*VR+,;'gR 24\ R,VR-, 24VR.,'d\ R/VR., 24VR0,'d\ R1VR0, 24\ R2\X4 R324VFDp\ R4VR ,R5 R6VR7,R8 R9VR:,R; R R?VR@, 2 4KF X'd\ RA\V4 R324VFepVRB,'dRCMRDp \ R4VR ,R5 R6VRE,R; R9VRF,RG RHVRI,RJ RKVRL,;'g^RM RNV 2 4Kg X'dm\ RO\V4 R324VFNp V RP,'dRQMR9p \ R4V R ,R5 RRT R6V RS,RT R9V RU,;'gR 24KP X'dy\ RV\V4 R324VFZpVRW,RX8XdRYMRZp \ R[VR\,R], R9T R9VR^,R_ R9VR`,;'gRaRb, 24K\ \ 4R# +'giEL;i)d SELECT * FROM deals WHERE id = ?Deal r'zSELECT dp.*, c.name AS company_name, c.trust_level, c.dd_status FROM deal_parties dp JOIN companies c ON c.id = dp.company_id WHERE dp.deal_id = ? ORDER BY dp.idzSELECT cm.*, c.name AS party_name FROM commissions cm JOIN deal_parties dp ON dp.id = cm.deal_party_id JOIN companies c ON c.id = dp.company_id WHERE cm.deal_id = ? ORDER BY cm.idzBSELECT * FROM documents WHERE deal_id = ? ORDER BY created_at DESCzJSELECT * FROM comms_log WHERE deal_id = ? ORDER BY timestamp DESC LIMIT 10Nr z rz Stage: rrz Commodity: rz Counterparty: rr(counterparty_company_idrrz Our role: rNrrOr z Volume: rz MT trial / rz MT monthlyz Price: rr-rz Incoterm: rz Port: rz Origin: rz Payment: rz Folder: folder_path inquiry_idz From inquiry: #rz Notes: z Parties (r}r~rrrole13srRr|riz trust=rrkz DD=rz Commissions (paidPAIDPENDING party_nameamount_per_unitz>8.2frunitz<3sz total $ total_amountz>10,.2frz Documents (signedroz] [doc_typerfilenamez Recent comms (rout→←r timestampr0rrsubjectrC:N2Nr3) r,r(rrr^r4r5r!rrJrf) rr*dealparties commissionsdocscommsprJrrrarrows & r+ cmd_deal_showrs ||>PYY[ E$,,{3 4 HHQK,, 68<   (*  ll 69=   (*  || PSWS_S_Ra (*  X \\O  (* ' 0 BxjT$ZL8* 56 d7m_Bvd7m/D.E FG d;/0 12 d#678DAZ<[[ \] d:.77%8 9: d6l33e4 56 d8n556 78 d?3<? d=12 34 L "4 #5"678 G}} !$w-12 M#g,r *+  agb\AfIc?!An4Ec3JK',D;0@B C !#k"2!3267A yyViF E!D'"R,'RSX=YYZ[\]c[dehZijn-227;2fXG H   D {"-.AkkUsF E!D'"S1Z=2EQq}G]G]X]F^_ `  "3u:,b12A{^u4E%E D;,-QugQq|B6Gq!I,J\J\Z\^aIbHcd e GA s DT  T c \4;_uu_4pVPRVP34P4pV'g0\ RVP R24\ P !^4VP'd VPMVR,^,pV^8gV^8d"\ R4\ P !^4\4pVPRW4VP34VPRVPVR,W4VP34V^8XdVPRW@P34\VR,4pVP4'dVP\8Xd~\VP, pVP4'gQ\ P"!\%V4\%V44VPR \%V4VP34R R R 4\ R VP R XR, R X R\&V, R2 4\)4R # +'giLP;i)rrr'rzStage must be 1-8.z7UPDATE deals SET stage = ?, updated_at = ? WHERE id = ?rCz+UPDATE deals SET closed_at = ? WHERE id = ?rz-UPDATE deals SET folder_path = ? WHERE id = ?Nu✓ z: stage r.rr)r,r(rrr^r4r5rr>noterrXparentr5r6r shutilmoverKrr)rr*r new_stagerrdsts& r+cmd_deal_advancer=s ||>PYY[ E$,,{3 4 HHQK"&***DJJ$w-!2C q=IM & ' HHQK U E DLL )  m \\4=) C  > LLF\\HZ [$}-.F}}6==J#> 6;;.zz||KKF SX6LLGS4<<03 : DhtG}oU9+RyHYGZZ[ \]= sA4ID1I:AI I" c`^VnVP;'gRVn\V4R#)z Deal closedN)rrrrs&r+cmd_deal_closer_s$DJ **]DITr-c\4;_uu_4pVPRVP34P4'g0\ RVP R24\ P !^4RRR4\RRR7p\RR\R 7p\R 4p\R 4p\R 4p\R 4p\R4p\R4p \4;_uu_4pVPRVPW$W5VWxV \43 4p V Pp RRR4\ RX R24\4R# +'giL;i +'giL>;i)z.Link an existing company as a party to a deal. SELECT 1 FROM deals WHERE id = ?rr'Nz Company ID (from 'company list')TrRolerzContact ID (optional)z Bank namezIBAN / account noz SWIFT/BICzBank account namerzINSERT INTO deal_parties (deal_id, company_id, contact_id, role, bank_name, bank_iban, bank_swift, bank_account_name, notes, created_at) VALUES (?,?,?,?,?,?,?,?,?,?)u ✓ Party #z added to deal.) r,r(rrr^r4r5rr PARTY_ROLESr>rr) rr*rr contact_id bank_name bank_iban bank_swiftbank_account_namerrpids & r+cmd_deal_party_addres ||>PYY[[ E$,,{3 4 HHQK >NJ &4 =D34J{#I*+I $J23 7OE ll /\\:4I E35 :  mm  KuO ,--  sA!E /8E E  E- c \4;_uu_4pVPRVP34P4pVPRVPVP34P4pV'd V'g"\ R4\ P!^4RRR4\RRR7p\RXR,;'gR R 7pVR ,'dYBR ,;'g^,MRp\R V'dVR MRR 7p\R4p\4;_uu_4pVPRVPVPWEWx\434RRR4\ RXR, RVR RV 24\4R# +'giL;i +'giLK;i)rzSELECT dp.*, c.name AS company_name FROM deal_parties dp JOIN companies c ON c.id = dp.company_id WHERE dp.id = ? AND dp.deal_id = ?zDeal or party not found.NzAmount per unit (USD)TrUnitrrrrzTotal amount (USD)z.2frzINSERT INTO commissions (deal_id, deal_party_id, amount_per_unit, unit, total_amount, notes, created_at) VALUES (?,?,?,?,?,?,?)u✓ Commission added for r|z: $r) r,r(rrparty_idr^r4r5rrr>r) rr*rpartyamountr total_defaulttotalrs & r+cmd_commission_addrs\ ||>PYY[  5]]DLL )  (*  5 , - HHQK 1D AF &$|"4"<"< =D;? ;L;LVK055A6RVM -Q^-9Ldh iE 7OE   )\\4==&ce L    %eN&;% commission_idr^r)rr*s& r+cmd_commission_payrsW  G UD&& '    OD../} => s 'A'' A7 c \VRR4p\4;_uu_4pV'd/VPRVP34P 4pRpM>VPRVP34P 4pV'd VR,MRpV'g"\ R4\ P!^4RRR4\RR.ROR 7p\R 4p\R R R R .R7R 8Hp\R4p\4;_uu_4pV'd5TPRVPYVV'd^M^V\434M4TPRVPTXYg'd^M^V\434RRR4\ RV 24\4R# +'giL;i +'giL=;i)inquiryFr8NrrzTarget not found.zDoc typeTrFilenamezSigned?rrSrArzyINSERT INTO documents (inquiry_id, doc_type, filename, signed, notes, created_at) VALUES (?,?,?,?,?,?)zINSERT INTO documents (deal_id, doc_type, stage, filename, signed, notes, created_at) VALUES (?,?,?,?,?,?,?)u✓ Document logged: ) ICPOFCOSCOLOINCNDAIMFPASPACIPOPMT103 CommissionOther getattrr,r( target_idrr^r4r5rr>r) rtarget_inquiryr*r}rrrrrs & r+ cmd_doc_addrseT9e4N  \\"H4>>J[\eegFE\\"Dt~~FWXaacF'-F7O4E % ' HHQK j4STHj!H IsS#J ?3 FF 7OE   LL+&QaPSPUV  LL-5(AQPUWZW\]   !( ,-=  s%A)F$ F$!F$A1F7$ F4 7 G c n\VRR4p\4;_uu_4pV'dTVPRVP34P 4'g"\ R4\ P!^4MRVPRVP34P 4'g"\ R4\ P!^4RRR4\RRR R .R 7p\R R.ROR 7p\R 4p\R4p\4p\4;_uu_4pV'd"VPRVPW4WVWw34M VPRVPW4WVWw34RRR4\ R4\4R# +'giL;i +'giL:;i)rFz$SELECT 1 FROM inquiries WHERE id = ?zInquiry not found.rzDeal not found.NrTinrrrSubjectSummaryzINSERT INTO comms_log (inquiry_id, direction, channel, subject, summary, timestamp, created_at) VALUES (?,?,?,?,?,?,?)zINSERT INTO comms_log (deal_id, direction, channel, subject, summary, timestamp, created_at) VALUES (?,?,?,?,?,?,?)u✓ Comm logged.)rrrrotherr)rrr*rrrsummaryrs& r+ cmd_comm_logrsBT9e4N  << FHYZccee*+ << BT^^DUV__aa'(  {TD%=IIY7ghGYGYG B   LL-WrN  LL-WrN   9  s%9FAF-!F(A F$ F! $ F4 c>\4\R\ 24R#)u✓ Dashboard regenerated: N)rr^DASHBOARD_PATHrs&r+ cmd_dashboardrs ''7 89r-u% i4Fuel Pipeline

i4Fuel Pipeline

Generated {ts} · {db_path}
{alerts}
Open inquiries{n_inbox}
Active deals{n_active}
Companies{n_companies}
DD needed{n_dd_needed}
Flagged companies{n_flagged}
Active contract value${total_value:,.0f}
Commissions pending${comm_pending:,.0f}
Commissions paid${comm_paid:,.0f}

Deal kanban

{kanban_columns}

Open inquiries

{inbox_table}

Recently rejected / converted

{inbox_closed_table}

Active deals ({n_active})

{deals_active_table}

Closed deals ({n_closed})

{deals_closed_table}

All companies

{companies_table}

Flagged companies (suspect / scammer / blacklisted)

{flagged_table}

Recent incidents

{incidents_table}
{detail_modals} cVfR#\V4PRR4PRR4PRR4PRR 4#) NrC&z&z>rsz")rKrprNs&r+her$sEy FNN3 ( 0 0f = WS& !''#x"8:r-c&RV R\V4 R2#)zzr$)clsrs&&r+badger(s R4z 99r-c#aaCaDaEaFaG\4;_uu_4pVPR4P4pVPR4P4pVPR4P4pVPR4P4pVPR4P4pVPR4P4pVPR4P4pVPR4P4pRRR4/oGXF+p SGPV R ,.4P V 4K- /p XF+oV PSR ,.4P S4K- /p XF<p V R ,'gKV PV R ,.4P V 4K> /p XF<pVR ,'gKV PVR ,.4P V4K> /p\4;_uu_4pVPR 4P4F+pVPVR ,.4P V4K- RRR4XU u.uFqR ,^8gKV NK pp VU u.uFqR ,^8XgKV NK pp XUu.uFpVR ,R8XgKVNK ppVUu.uFpVR ,R8wgKVNK ppXUu.uFpVR,R9gKVNK ppVUu.uFpVR,R9gKVNK pp\ RV44p\ RV44p\ RV44p.pVUu.uFpVR,R8XgKVNK ppV'dhRP RVR,44p\V4^8dR\V4^, R2MRpVP R\V4 V R24V'dVP R\V4 R24.p\^^ 4EFp VU u.uFqR ,V 8XgKV NK p!p .p"V!EFp SGPV R,.4p#\;QJdR V#4F 'gK R!M R"M !R V#44p$V$'dR#MR$p%V R%,'dV R%,R& R'2MR(p&V R),'d"R*V R),R+ R,V R-,;'gR. 2MR(p'V"P R/V% R0V R, R1\V R,4 R2\V R3,4 R4\V R5,4 R6\V R7,4 R8V& R9V' R:24EK! V"'gV"P R;4VP R\V!4 R?RP V"4 R@2 4EK VG3RAloDRBp(V'd"RCV( RP VD3RDlV44 RE2MRFp)V'd"RCV( RP VD3RGlV44 RE2MRHp*RIoFRJp+V'd"RCV+ RP VF3RKlV44 RE2MRLp,V'd)RCV+ RP VF3RMlVRN,44 RE2MROp-RPoCRQp.V'd"RCV. RP VC3RRlV44 RE2MRSp/V'd"RCV. RP VC3RTlV44 RE2MRUp0RVoEX'd RWRP VE3RXlV44 RE2MRYp1.p2VEF+p SGPV R,.4p#V PV R,.4p3V PV R,.4p4V PV R,.4p5RP RZV#44;'gR[p6RP R\V344;'gR]p7RP R^V444;'gR_p8RP R`V5Ra,44;'gRbp9V Rc,'dRd\V Rc,4 Re2MR(p:T2P RP .RfNV R, NRgN\V R,4 NRhN\V R3,4 NR6N\V R5,4 NRiNV R , NR=N\\V R ,,4 NRjN\V R7,4 NRkN\\V Rl,,Rm,4 NRnNV R%,;'g^R& NRoNV Rp,;'g^R& NRqNV R),;'g^R+ NRrN\V R-,;'gR.4 NRsN\V Rt,;'gR(4 NRuN\V Rv,;'gR(4 NRwN\V Rx,;'gR(4 NRyN\V Rz,;'gR(4 NR{NV: NR|NV R},'d R~V R}, 2MR( NRN\V R,;'gR(4 NRNV6 NRNV7 NRNV8 NRNV9 NRN44EK. VEFpT2P RP .RNVR, NRNVR, NRhN\VR,4 NR6N\VR,4 NR6N\VR,4 NR6N\RVR , 2VR ,4 NRN\VR,;'gR(4 NRNVR ,'dRVR , R2MR NRN\VR,;'gR(4 NRN\VR,;'gR(4 NRNVR%,;'g^R& NRNVRp,;'g^R& NRNVR),;'g^R+ NR,N\VR-,;'gR.4 NRsN\VRt,;'gR(4 NRN\VRx,;'gR(4 NRN\VRv,;'gR(4 NRN\VRz,;'gR(4 NRN\VR,;'gRR,4 NRN\VR,;'gR(4 NRN\VR ,;'gR(4 NRN\VR,;'gR(4 NRN\VR,;'gR(4 NRN44EK VEF(oVPSR,.4p;RP RV;44;'gRpT2P RP .RNSR, NRgN\SRm,4 NRN\RSR, 2SR,4 NRN\RSR, 2SR,4 NRN\RSR, 2SR,4 NRN\SR,;'gR(4 NRN\SR,;'gR(4 NRN\SR,;'gR(4 NRN\SR,;'gR(4 NRN\SR,;'gR(4 NRwN\SR,;'gR(4 NRN\SR,;'gR(4 NR6N\SR,;'gR(4 NRN\SR,;'gRR,;'gR(4 NRN\SR,;'gR(4 NRN\SR,;'gR4 NRN\SR,;'gR(4 NRNV< NRNV> NRN44EK+ /R\4R,P!RR4bR\#\$4bR\#\V44bR\#\V44bR\#\V44bR\#\V44bR\#\V44bR\#\V44bRVR& bRVR& bRVR& bRRP V4bRRP V4bRV,bRV-bRV)bRV*bRV/RV0RV1RRP V24/Cp?\&p@V?P)4FwpApBX@P!VAVB4p@K \*P-X@4R# +'giELu;i +'giEL0;iuup iuup iuupiuupiuupiuupiuupiuup iuup i)z,SELECT * FROM deals ORDER BY updated_at DESCz%SELECT * FROM companies ORDER BY namez0SELECT * FROM inquiries ORDER BY created_at DESCzSELECT i.*, c.name AS company_name FROM incidents i JOIN companies c ON c.id = i.company_id ORDER BY date DESC LIMIT 30zSELECT dp.*, c.name AS company_name, c.trust_level, c.dd_status FROM deal_parties dp JOIN companies c ON c.id = dp.company_idzSELECT cm.*, c.name AS party_name FROM commissions cm JOIN deal_parties dp ON dp.id = cm.deal_party_id JOIN companies c ON c.id = dp.company_idz0SELECT * FROM documents ORDER BY created_at DESCz/SELECT * FROM comms_log ORDER BY timestamp DESCNrz*SELECT * FROM incidents ORDER BY date DESCrrrrwrrrc3v"TF/qR,;'g^VR,;'g^,xK1 R#5i)rrNrArIrs& r+rK'regenerate_dashboard..s.Z\~**q~/B/BCC\s 999c3h"TF(qR,'dKVR,;'g^xK* R#5irrNrArHs& r+rKr,s)Ry!& -q(--A-y 22 2c3h"TF(qR,'gKVR,;'g^xK* R#5ir.rArHs& r+rKr,s)KIq6*An%***Ir/rc32"TF qR,xK R#5i)r NrArHs& r+rKr,s>-=F))-=s:NNz (+z more)rCz1
BLACKLISTED: z%. Review before any engagement.
z
zb companies need DD. Run /supplier-check, then: pipeline.py company check <id>
rc3b"TF%pVR,R9;'g VR,R8gxK' R#5irrr<NsuspectrFrrArIrs& r+rKr,s>I@G1M*.SS77kNh67@G-/TFz card flaggedcardr,.0fz MTrr$,.2frrrz
z.
rz'
ru · rNz.
zz1
u
—
z3

rzz

z
c<SPVR,.4p\;QJdRV4F 'gK RM RM !RV44pV'dRMRpRT RVR, R\VR,4 R VR , R \\VR ,,4 R \VR ,4 R \VR,4 R \VR,4 R \\VR,,R,4 R VR,;'g^R RVR,;'g^R R\VR,;'gR4 R \VR,;'gR4 R \VR,R,4 R2#)rc3b"TF%pVR,R9;'g VR,R8gxK' R#5ir4rAr7s& r+rK9regenerate_dashboard..deal_row..s>E⚠ rC z rr rrrNrOr rr: $rr<rrrr updated_atr )getanyr$rrJ)rrrrflagparties_by_deals& r+deal_row®enerate_dashboard..deal_rows!%%agr2#EStageCommodityCounterparty RoleEntityVol/MTPrice IncotermUpdatedzc34<"TF pS!V4xK R#5irErArIrrKs& r+rKr,&ILqx{{Lz
z%

No active deals.

c34<"TF pS!V4xK R#5irErArNs& r+rKr,rOrPz%

No closed deals.

cpRVR, RVR, R\VR,4 R\VR,4 R\VR,4 R\VR,;'gR 4 R\VR ,;'gR 4 RVR ,;'g^R R VR,;'g^R R\VR,;'gR4 R\RVR, 2VR,4 R\VR,;'gRR,4 R\VR,;'gRR,4 R2#)z3 #rBrrCrrrrrrr:rDrr<rrrCstatus-rr:N(Nr/rrFr$r(rs&r+ inquiry_row)regenerate_dashboard..inquiry_rowsP//0wiuQtWIF!K.!"#!F)}o!I, !!&'005123!$%../01+##!T*+;$$1d+1R,0E0E2-F,GHwq{m,ak:;<1]#))r3/0121]#))r3/012  r-zIDDirTypeChannelCompany CommodityVol/MTPriceStatus Next actionReceivedc34<"TF pS!V4xK R#5irErArIrrWs& r+rKr,2s)Q.Q+a...rPz'

No open inquiries.

c34<"TF pS!V4xK R#5irErArZs& r+rKr,6s)XBWQ+a..BWrPrz

None.

cVR,'dRMRpRVR, R\VR,4 R\VR,;'gR 4 R \VR ,;'gR 4 R \R VR , 2VR ,4 R \RVR, 2VR,4 R\VR,;'gR4 R \RVR, 2VR,4 R V R2#)rnu)⚠rCz3 No companies yet.

c34<"TF pS!V4xK R#5irErArcs& r+rKr,Ns)TBSQ+a..BSrPz*

No flagged companies.

c R\VR,R,4 RVR, R\VR,4 R\VR,4 R \VR ,;'gR R ,4 R 2 #)r@rrz4 DateCompanyTypeDescriptionc34<"TF pS!V4xK R#5irErA)rIrrgs& r+rKr,]s6Iq<??IrPz)

No incidents logged.

c3("TFpR\RVR,4 R\VR,4 R\RVR, 2VR,4 R\RVR, 2VR,4 R\VR,;'gR 4 R 2 xK R #5i) r r|r]rr^rrrC N)r(r$r7s& r+rKr,ks  uVQvY/01a'()*6!M"2!34a 6FGHI3q~./;@ABa n**+,J  8 sBBz;No parties yet.c3Z"TFpR\VR,4 RVR,R R\VR,4 RVR,;'g^R R\VR ,'dR MR VR ,'dR MR 4 R\VR ,;'gRR,4 R2 xK R#5i)rkrz $rr<rrrrlrpendingrrpaid_atrCrrmNrUrHs& r+rKr,ts  r!L/*+,'(.a1V9 ?n%**4011V99)qyyVV_`abq|))r3/01  = sAB+ *B+4B+B+zBNo commissions logged.c3 "TFzpR\VR,4 RVR,;'gR R\VR,;'gR4 RVR,'dRMR R\VR,R ,4 R 2 xK| R #5i) rkrrlrrCrrro created_atrrmNr&)rIdocs& r+rKr,}s  r#j/*+9S\5G5GR4HIc*o++,-.MM5r23c,',-.j :s(BBB)Bz9No documents.c3"TFpR\VR,R,4 RVR,R8XdRMR R\VR,4 R\VR ,;'gR 4 R\VR ,;'gR 4 R 2 xK R #5i)rkrr0rlrrrrrrrCrrmNr&)rIls& r+rKr,s  r!K.-./0kNE15u=>a l#$%a l((b)*+a l((b)**  6 sAB B :B :NNz5No comms.rzOpen folderz4

z3

u · Stage zW
Our role
rrOr z?)
Trial / Monthly
z MT / rz8 MT
Price
$z per z7
Incoterm
rz<
Port / Origin
rr*rz<
Payment terms
rz5
Folder
z;
From inquiry
r#z4
Notes
rz

Parties

z
RoleCompanyTrustDDBank

Commissions

z
PartyPer unitTotalStatusPaid

Documents

z
TypeStageFilenameSignedLogged

Recent comms

z"
TimeDirChannelSubjectSummary
z7

Inquiry #rrrrSzV

Company
rrRz(#rz6
Contact
r+z8
Commodity
rz5
Volume
r,z9 MT)
Price
$z<
Origin / Port
r.z6
Payment
z7
Received
r/r0z:
Next action
rz6
Deal ID
z?
Rejection reason
r2z3
c 3"TFRpR\VR,R,4 R\VR,4 R\VR,;'gR4 R2xKT R#5i) rkrrrlrrrCrmNr&)rIincs& r+rKr,s\ "r#f+c*+,IbVo5FiPRSVWdSeSkSkikPlOmmw x"sAAz9No incidents.rc3H<"TFqR,SR,8HxK R#5i)rrNrA)rIrrJs& r+rKr,s\;[a!D'1;[s"c3"TF`pRVR, R\VR,4 RVR, R\\VR,,4 R\VR,4 R2 xKb R #5i) z3No deals.z7
Country
rz;
Registration
rz6
Address
rz6
Website
rz<
Email / Phone
rrz@
DD score / report
rwrxz<
DD checked at
ryrz;
OFAC details
rzz>
Blacklist match
rnr|z

Incidents

zk
DateTypeDescription

Deals

z{ts}Tz {db_path}z {n_inbox}z {n_active}z {n_closed}z {n_companies}z {n_flagged}z {n_dd_needed}z{total_value:,.0f}z{comm_pending:,.0f}z{comm_paid:,.0f}z{alerts}z{kanban_columns}z {inbox_table}z{inbox_closed_table}z{deals_active_table}z{deals_closed_table}z{companies_table}z{flagged_table}z{incidents_table}z{detail_modals}r5)ru in_progressrr)r,r(r! setdefaultr{sumrMrfr$rangerGrHrrJr(r>rprKr%DASHBOARD_TEMPLATEitemsr write_text)Hr*r companiesrr all_parties all_commsall_docsall_logsr comms_by_deal docs_by_dealr logs_by_dealruincidents_by_companyr active_deals closed_dealsopen_inquiriesclosed_inquiriesrJflagged_companies dd_needed total_value comm_pending comm_paid alerts_html bl_companiesnamesmore columns_html stage_num stage_deals cards_htmlrrrklass volume_str price_str deal_headerdeals_active_htmldeals_closed_htmlinquiry_header inbox_tableinbox_closed_tablecompany_headercompanies_table flagged_tableincidents_table modals_htmlrrlogs parties_rows comms_rows docs_rows logs_rows folder_link c_incidentsinc_rowsc_deals deal_rows replacementshtmlkvr`rKrgrWrJsH ` @@@@@r+rrs  KLUUWLL!HIRRT LL!ST]]_ LL V  (* ll P  (* LL ;  (*  << RS\\^<< QR[[]% (O ""1Y<4;;A>M   9r299!<L  Y<<  # #AiL" 5 < \"-=>>47 4E4IS&q()0r?5 {4&Pu v )#i.)9:\ ] L1a[ "'C%QW:+Bqq% C A%))!D'26GcI@GIcccI@GIIG&-N6E89+AkN404EJOPQ\~~!AkN40!L/2I2IT1JKchI   # '!=agYG!!#AdG .((*1[>(:';)??PQ05     4 45dG9 = AdG  . /1;.@-A  BF  GIK^I_F`Ea  bl  mnnulvkw  xz  {}~DEFGNEO~P{QzR  R1  24AjM1B0C  DF  GIRST`RaIbciIjFkEl  m8  :;;9L9L1d7S TZ \]]i[j[o[onoquYv w/ 12+0C0C!T.J KP QSSTUaSbSjSjfjPkOl m1 24AjM4J4JU1K0L M6 7969K9Ke6L5M NQ RTTUV^T_ThThchQiPj k6 79?9K9T9Tu6U5V W/ 0;m <5 OPP\ooq<8I5Jch4i j. /171D1Du.E-F G` "am_m# "nf# &gqeq' &rg' *hqfq+ *rf+ .gpep/ .q /  YP   7 78wi @ D' #. /1;.@-A  BF  GI6m_  UY  Z\\]^g\hYiXj  ko  puw~@ABJ@KLvMOPQYOZp[o\  \0  1315G3H3Q3QE0R/S  TU  qrr~ppWYZ[\hZiYjjkUlFHUI  I0  131]3C3L3Lu0M/N O2 35Q7G5H5Q5QE2R1S T/ 12+0C0C!T.J KX Z[[gYhYmYmlmosWt u/ 12+0C0C!T.J KL MOqQ]OfOfbfLgKh i1 24AjM4J4JU1K0L M6 7989M9M6N5O PU VXXYZ`XaXjXjejUkTl m0 131_3E3N3N0O/P Q1 24Q}5E5K5KS4Q1R0S T4 57q7G7P7P54Q3R S0 131Y<3H3H50I/J! K9! ":PAAF7AF& AF&AF++AF+7AF0 AF0AF5-AF59AF:AF:AF?/AF?3AGAG;AG AG #AG%+AG2AG AGE> AF F AF# c  \P!RR\P\P!R4R7pVP RRR7pVP R4pVP RRR7pVP R 4VP R 4pVPR R R 7VP R4pVPR\R7VP R4pVPR\R7VPRR R 7VP R4pVPR\R7VPRRR7VP R4pVPR\R7VPR\RRR7VP R4p V P RRR7p V P R 4V P R 4p V PRR R 7V PRR R 7V P R4p V PR\R7V P R4p V PR\R7V P R4pVPR\R7VPR \R!7V P R"4pVPR\R7V P R#4pVPR\R7VP R$4pVP RRR7pVP R 4pVPR\R7VP R%4pVP RRR7pVP R 4VP R 4pVPR&R R 7VP R4pVPR'4VP R(4pVPR'4VPR)\R7VPR*RR7VP R+4pVPR'4VPR*RR7VP R,4pVP R-RR7pVP R.4pVPR'4VP R/4pVP RRR7pVP R.4pVPR'4VPR0\RR1R7VP R24p V PR3\R7VP R44p!V!P RRR7p"V"P R.4p#V#PR54V#PR6R R 7VP R74p$V$PR54V$PR6R R 7VP R84VP4p%\4/R9\bR:\bR;\bR<\bR=\ bR>\"bR?\$bR@\&bRA\(bRB\*bRC\,bRD\.bRE\0bRF\2bRG\4bRH\6bRI\8bRJ\:RK\<RL\>RM\@RN\B/Cp&V%PD\GV%RR43p'V%PDR88Xd\IV%4R#V%PDR78Xd\KV%4R#V%PDR%8XdV%PLR,8Xd\OV%4R#V'V&9dV&V',!V%4R#VPQ4\RPT!^4R#)OpipelineuAi4Fuel deal pipeline (v2 — companies, inquiries, incidents, DD)a common flow: pipeline.py inquiry new new inbound FCO/RFQ pipeline.py company check record DD result pipeline.py inquiry convert promote to deal pipeline.py deal advance next stage pipeline.py deal close other: pipeline.py inquiry list [--all] pipeline.py inquiry reject --reason "..." pipeline.py inquiry link --company pipeline.py company new pipeline.py company list [--needs-dd|--flagged] pipeline.py company show pipeline.py company trust --level scammer pipeline.py company ofac pipeline.py company incident pipeline.py contact new pipeline.py deal new outbound origination pipeline.py deal list [--closed] pipeline.py deal show pipeline.py deal party add pipeline.py comm add --party pipeline.py comm pay pipeline.py doc add [--inquiry] pipeline.py log [--inquiry] pipeline.py dashboard )progrformatter_classepilogcmdT)destrractionnewrz--all store_true)rshowr)rconvertz--forcerejectz--reasonNrlinkz --companyr)rrrrMz --needs-ddz --flaggedcheckrz--level)choicesofacincidentcontactrz--closedradvancez--stagez--notecloseraction2addcommz--partyrpayrrsrz --inquirylog dashboard)rr)rr)rr)rr)rr)rr)rMr)rMr)rMr)rMr)rMr)rMr)rMr)rr)rr)rr)rr)rr)rr)rr)rr)rsr)+argparseArgumentParserRawDescriptionHelpFormattertextwrapdedentadd_subparsers add_parser add_argumentrr parse_argsr:r r$r6rQr\r^rertrrrrrrrrrrrrrrrrrrrr print_helpr4r5)(parserrrLinq_subinq_listinq_showinq_convinq_rejinq_linkcoco_subco_listco_showco_checkco_trustco_ofacco_incrct_subct_newrdeal_subd_listd_showd_advd_closed_party d_party_sub d_party_addrcomm_subc_addc_payrsdoc_subd_addrrhandlerskeys( r+mainr s  $ $ W <<  $FJ   UT  :C .. #C  h >G u!!&)H ',7!!&)H $S)!!),H $S) )L9  *G C( T2!!&)H $S) +C$\R  "B   Ht  >& !D""4"@H    (F  <8   (F  "    *E y! ys+ x.!!'*G # 40!!'*G((i$(GK((/KY' >>& !D""4"@H    &E y! ysT K    &E S1 .. C  h >G   u %E {# {<8 .. C[![6NN;    D IO- -  3  1  -  O - - / / - !5 O  -!" -#$ ->++ -H0 88WT8T2 3C xx;d U T V  w 64  d  r-__main__) 01_Inquiry 02_Mandate03_Offer 04_Contract05_Verification 06_Payment 07_Commission 08_Closed)r>r?rHmandater paymaster)rverifiedr6rFr)rur}r<rrr)rw in_reviewr9rejected no_responsestale)RFQrrr introduction cold_outreach) rUrVno_showrWcontract_breachsuspicious_docrrrejected_inquiryr)NFN)NF)NNNNNNN)V__doc__rrxjsonosrr#r4rurllib.requestr_rrrpathlibrr3r%rr5r6r__file__rr7rWrbr]rrrJrrrrINQUIRY_STATUSESrrYr9r,r:r>rPrnrrrrrrrrrrrr r$r6rQr\r^rertrrrrrrrrrrrrrrrrrrr$r(rr__name__rAr-r+rs   22^   $ 00 H $ H $ m N ! !G +  ' < y!_a);0!Y8  v{E:6&15*E f(% <  !5-?S [%1I ) K T K K YM u p#D 8 (6(&)+LR &TAHT(/BGTD "4],1fh6 4 "6>BQ$A HD 88 FB: bJ::g$V dN zFr-
IDStageCommodity