EDI 856 ASN via SFTP to Odoo —
Complete Tutorial

ISA*00*          *00*          *ZZ*VENDOR         *ZZ*YOURCOMPANY      *260510*0800*^*00501*000000042*0*P*:
GS*SH*VENDOR*YOURCOMPANY*20260510*0800*42*X*005010
ST*856*0001
~ ── Shipment header ────────────────────────────────────────────
BSN*00*ASN-20260510-001*20260510*0800*0001  ~ # ASN number + date/time
DTM*011*20260510              ~ Ship date
DTM*017*20260513              ~ Estimated delivery date
~ ── Carrier and tracking ───────────────────────────────────────
TD5*B*2*ESTAFETA**             ~ Carrier: Estafeta
REF*CN*9261290100830121234567  ~ Tracking number
~ ── Level Embarque (HL S) ──────────────────────────────────────
HL*1**S
TD1*CTN*2****G*18.5*KG          ~ 2 packages, 18.5 kg total
~ ── Level Orden (HL O, padre=1) ────────────────────────────────
HL*2*1*O
PRF*OC-2026-0089**20260501     ~ Reference to original PO
~ ── Level Bulto 1 (HL P, padre=2) ─────────────────────────────
HL*3*2*P
MAN*GM*1234567890128           ~ SSCC/código de caja
~ ── Level Ítem 1 (HL I, padre=3) ──────────────────────────────
HL*4*3*I
LIN**VP*SKU-MX-001              ~ VP = vendor part number (your SKU)
SN1**24*EA                      ~ Quantity: 24 units
PID*F****Widget Azul 500ml
~ ── Level Ítem 2 (HL I, padre=3) ──────────────────────────────
HL*5*3*I
LIN**VP*SKU-MX-002
SN1**12*EA
PID*F****Widget Rojo Pro
~ ── Totals ─────────────────────────────────────────────────────
CTT*5                           ~ 5 HL segments total
SE*20*0001
GE*1*42
IEA*1*000000042

import paramiko
import os

# Config — ideally from environment variables or Odoo ir.config.parameter
SFTP_CONFIG = {
    "host": os.getenv("SFTP_HOST", "sftp.vendor.com"),
    "port": 22,
    "username": os.getenv("SFTP_USER"),
    "key_path": os.getenv("SFTP_KEY_PATH", "/etc/molten/keys/vendor_rsa"),
    "outbound_dir": "/edi/outbound",
    "processing_dir": "/edi/processing",
    "processed_dir": "/edi/processed",
    "error_dir": "/edi/error",
}

def get_sftp_client(config):
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    key = paramiko.RSAKey.from_private_key_file(config["key_path"])
    ssh.connect(
        hostname=config["host"],
        port=config["port"],
        username=config["username"],
        pkey=key,
        timeout=30,
    )
    return ssh.open_sftp(), ssh

def fetch_pending_856_files(config):
    """Fetches and locks all pending .edi files from outbound/"""
    sftp, ssh = get_sftp_client(config)
    files_fetched = []
    try:
        pending = sftp.listdir(config["outbound_dir"])
        for fname in pending:
            if not fname.endswith(".edi"):
                continue
            src  = f"{config['outbound_dir']}/{fname}"
            lock = f"{config['processing_dir']}/{fname}"
            sftp.rename(src, lock)           # rename = atomic lock
            raw = sftp.file(lock, "r").read().decode("utf-8")
            files_fetched.append((fname, raw, lock))
    finally:
        sftp.close(); ssh.close()
    return files_fetched

import re

def parse_856(raw_edi: str) -> dict:
    """
    Parsea un X12 856 crudo y retorna estructura:
    {
      "asn_number": str,
      "ship_date": str,
      "delivery_date": str,
      "carrier": str,
      "tracking": str,
      "po_reference": str,
      "packages": [{"sscc": str, "items": [{"sku": str, "qty": int, "desc": str}]}]
    }
    """
    # Detect delimiters from the ISA envelope
    elem_sep    = raw_edi[3]            # position 3 of ISA
    segment_sep = raw_edi[105]          # position 105 of ISA

    segments = [s.strip() for s in raw_edi.split(segment_sep) if s.strip()]
    result = {"packages": [], "po_reference": "", "carrier": "", "tracking": ""}

    current_package = None
    hl_map = {}

    for seg in segments:
        els = seg.split(elem_sep)
        tag = els[0]

        if tag == "BSN":
            result["asn_number"]   = els[2]   # BSN02
            result["ship_date"]    = els[3]   # BSN03

        elif tag == "DTM" and els[1] == "017":
            result["delivery_date"] = els[2]

        elif tag == "TD5":
            result["carrier"] = els[3] if len(els) > 3 else ""   # TD503

        elif tag == "REF" and els[1] == "CN":
            result["tracking"] = els[2]

        elif tag == "PRF":
            result["po_reference"] = els[1]   # Original PO number

        elif tag == "HL":
            hl_id    = els[1]
            hl_level = els[3] if len(els) > 3 else ""
            hl_map[hl_id] = hl_level
            if hl_level == "P":              # new package/carton
                current_package = {"sscc": "", "items": []}
                result["packages"].append(current_package)

        elif tag == "MAN" and current_package is not None:
            current_package["sscc"] = els[2]   # Carton/SSCC code

        elif tag == "LIN":
            # New item starting — store SKU
            result["_current_item"] = {"sku": els[3] if len(els) > 3 else "", "qty": 0, "desc": ""}
            if current_package:
                current_package["items"].append(result["_current_item"])

        elif tag == "SN1" and "_current_item" in result:
            result["_current_item"]["qty"] = int(els[2])   # SN102

        elif tag == "PID" and "_current_item" in result:
            result["_current_item"]["desc"] = els[5] if len(els) > 5 else ""

    result.pop("_current_item", None)   # clean up temp field
    return result

import xmlrpc.client
from datetime import datetime

ODOO_URL  = "https://tuempresa.odoo.com"
ODOO_DB   = "tuempresa"
ODOO_USER = "edi@tuempresa.com"
ODOO_PASS = "tu_api_key_aqui"   # use API Key, not password

def odoo_connect():
    common = xmlrpc.client.ServerProxy(f"{ODOO_URL}/xmlrpc/2/common")
    uid    = common.authenticate(ODOO_DB, ODOO_USER, ODOO_PASS, {})
    models = xmlrpc.client.ServerProxy(f"{ODOO_URL}/xmlrpc/2/object")
    return models, uid

def resolve_product_from_supplier_sku(models, uid, partner_id, supplier_sku):
    # Search product.supplierinfo by vendor part code
    info_ids = models.execute_kw(ODOO_DB, uid, ODOO_PASS,
        "product.supplierinfo", "search",
        [[("partner_id", "=", partner_id), ("product_code", "=", supplier_sku)]]
    )
    if not info_ids:
        raise ValueError(f"Vendor SKU not found: {supplier_sku}")
    info = models.execute_kw(ODOO_DB, uid, ODOO_PASS,
        "product.supplierinfo", "read", [info_ids[0]], {"fields": ["product_id", "product_tmpl_id"]}
    )
    return info["product_id"][0]   # product.product ID

def create_picking_from_856(asn_data: dict, partner_id: int):
    models, uid = odoo_connect()

    # Look up the referenced PO
    po_ids = models.execute_kw(ODOO_DB, uid, ODOO_PASS,
        "purchase.order", "search",
        [[("name", "=", asn_data["po_reference"])]]
    )
    purchase_id = po_ids[0] if po_ids else False

    # Map date YYYYMMDD → Odoo datetime string
    ship_dt = datetime.strptime(asn_data["ship_date"], "%Y%m%d").strftime("%Y-%m-%d %H:%M:%S")

    # Build move lines
    move_lines = []
    for pkg in asn_data["packages"]:
        for item in pkg["items"]:
            product_id = resolve_product_from_supplier_sku(models, uid, partner_id, item["sku"])
            move_lines.append((0, 0, {
                "name":             item["desc"] or item["sku"],
                "product_id":       product_id,
                "product_uom_qty":  item["qty"],
                "product_uom":      1,   # Units — adjust if using a different UOM
                "location_id":      8,   # Vendor location (adjust ID)
                "location_dest_id": 12,  # WH/Input (adjust ID)
            }))

    # Create the picking (receipt)
    picking_vals = {
        "picking_type_id":       1,     # Receipts — adjust for your warehouse
        "partner_id":            partner_id,
        "origin":                f"EDI-ASN: {asn_data['asn_number']}",
        "scheduled_date":        ship_dt,
        "carrier_tracking_ref":  asn_data["tracking"],
        "move_ids_without_package": move_lines,
        "note": f"Automatically imported by Molten Logistics EDI Engine. ASN: {asn_data['asn_number']}",
    }
    if purchase_id:
        picking_vals["purchase_id"] = purchase_id

    picking_id = models.execute_kw(ODOO_DB, uid, ODOO_PASS,
        "stock.picking", "create", [picking_vals]
    )
    # Confirm the picking (sets to "Ready" state)
    models.execute_kw(ODOO_DB, uid, ODOO_PASS, "stock.picking", "action_confirm", [[picking_id]])
    return picking_id