ESL Price Sync: Deterministic Retail Shelf-Edge Pricing Architecture

Ensure strict real-time parity between ERP/POS price masters and Electronic Shelf Label (ESL) fleets (SES-imagotag, ZKONG, Pricer, Hanshow, SOLUM) via bounded delta streams, monotonic idempotency tokens, and Sub-GHz RF battery preservation models.

When to Use This Skill

Activate this skill when:

• Designing, implementing, or auditing integration pipelines between enterprise retail masters (SAP, Oracle Retail, Dynamics 365, Lightspeed) and ESL server platforms.
• The user asks: "How do I sync price updates to ESL tags without draining batteries?", "Debug ghost pricing where POS doesn't match the shelf tag", "Design an idempotent delta feed for ZKONG or SES-imagotag", or "Schedule promotional pricing with automatic rollback".
• Reconciling price discrepancy logs between central ERP databases, ESL middleware, and wireless base station ACK telemetry.
• Calculating battery life depletion curves for e-paper tags running on CR2450 coin cells under varying refresh frequencies.

Do NOT use this skill when:

• Managing e-commerce web store frontends or dynamic pricing algorithms (this skill governs faithful delivery of decided prices to physical tags).
• Troubleshooting individual dead hardware tags before gateway RF coverage and RSSI signal propagation have been verified.
• Performing live write operations on production store fleets without a preceding read-only audit verification pass.

Core Mental Models & Non-Negotiable Rules

1. The 5-Layer ESL Architecture Pipeline:

   • Every price synchronization event traverses five distinct operational tiers: $$\mathbf{Price\ Master\ (ERP/POS)} \xrightarrow{\text{Extract}} \mathbf{Transform\ Middleware} \xrightarrow{\text{API/Message}} \mathbf{ESL\ Server} \xrightarrow{\text{Sub-GHz/2.4GHz}} \mathbf{Base\ Station\ (AP)} \xrightarrow{\text{RF\ Packet}} \mathbf{Physical\ Tag}$$
   • Traceability Invariant: Every price payload MUST carry a deterministic trace_id recording timestamps and status codes across all five layers. A "200 OK" from the ESL central server API is NEVER treated as proof that the physical shelf display has updated.

2. Strict Delta Discipline & Cryptographic Watermarking:

   • Pushing a full 50,000-SKU store catalog on a scheduled cron is strictly forbidden.
   • Updates MUST be generated by calculating a cryptographic row hash: $$\text{RowHash} = \text{SHA256}(\text{SKU} + \text{BasePrice} + \text{PromoPrice} + \text{Currency} + \text{UnitOfMeasure} + \text{Barcode} + \text{TemplateID})$$
   • Only records where $\text{RowHash}{new} \neq \text{RowHash}{pushed}$ are queued for transmission.
   • Full pushes are strictly restricted to initial store commissioning and disaster recovery restores.

3. Monotonic Idempotency & Out-of-Order Packet Defense:

   • High-volume retail message brokers inevitably deliver packets out of order during network re-balancing.
   • Every transmission packet MUST include an idempotency_key and a monotonically increasing version_timestamp (ISO 8601 UTC).
   • If an incoming price payload has $\text{version_timestamp} \le \text{last_applied_version}$, the ESL middleware MUST discard the payload to eliminate race condition reversions.

4. RF Gateway Rate-Limiting & Battery Longevity Budget:

   • Each physical e-paper display refresh costs between $12\ \mu\text{Ah}$ and $25\ \mu\text{Ah}$.
   • A dual-CR2450 battery pack provides $1,200\text{ mAh}$ nominal capacity ($960\text{ mAh}$ usable considering passivation and low-temperature shelf environments).
   • The 3-Update Daily Rule: Limiting tag updates to $\le 3$ refreshes per day guarantees a $5.5\text{--}7\text{ year}$ operational lifespan.
   • Base Station Queue Throttling: Gateways operate over shared Sub-GHz (868/915 MHz) or proprietary 2.4 GHz RF channels. Batch transmissions must not exceed 150 tag updates per gateway per minute to prevent RF collision retries from draining batteries.

5. Read-Only Audit Mode by Default:

   • Diagnostic and reconciliation tasks MUST execute in read-only audit mode.
   • Output discrepancy reports containing SKU, ERP Price, Gateway ACK Price, and Divergence Layer.
   • State-changing write updates require explicit operator consent.

Named Sins & Anti-Patterns (Что категорически ЗАПРЕЩЕНО)

Concrete Archetypes / Presets

Archetype 1: Idempotent Delta Synchronizer (Python 3.10+)

import hashlib
import time
from typing import Dict, List, Optional

def compute_sku_hash(item: dict) -> str:
    payload = f"{item['sku']}:{item['price']}:{item['promo_price']}:{item['uom']}:{item['template']}"
    return hashlib.sha256(payload.encode('utf-8')).hexdigest()

class ESLDeltaSyncPipeline:
    def __init__(self, watermark_db: dict, max_rate_per_min: int = 150):
        self.watermark_db = watermark_db  # SKU -> last_pushed_hash
        self.max_rate_per_min = max_rate_per_min
        self.last_tx_time = 0.0

    def process_catalog_stream(self, incoming_feed: List[dict], dry_run: bool = True) -> dict:
        to_push = []
        unchanged = 0

        for item in incoming_feed:
            sku = item['sku']
            current_hash = compute_sku_hash(item)
            last_hash = self.watermark_db.get(sku)

            if current_hash != last_hash:
                idempotency_key = hashlib.sha1(f"{sku}:{item['version']}:{current_hash}".encode()).hexdigest()
                to_push.append({
                    "sku": sku,
                    "tag_id": item['tag_id'],
                    "price_data": item,
                    "idempotency_key": idempotency_key,
                    "content_hash": current_hash
                })
            else:
                unchanged += 1

        if dry_run:
            return {"mode": "DRY_RUN", "queued_for_rf": len(to_push), "unchanged": unchanged}

        # Rate-limited physical transmission
        sent = 0
        min_interval = 60.0 / self.max_rate_per_min
        for job in to_push:
            now = time.time()
            elapsed = now - self.last_tx_time
            if elapsed < min_interval:
                time.sleep(min_interval - elapsed)

            transmit_to_esl_gateway(job)
            self.watermark_db[job['sku']] = job['content_hash']
            self.last_tx_time = time.time()
            sent += 1

        return {"mode": "LIVE_COMMITTED", "sent_deltas": sent, "unchanged": unchanged}

Archetype 2: Reconciliation Audit Report Schema

{
  "audit_timestamp": "2026-09-22T10:15:00Z",
  "store_id": "STORE-0842",
  "total_audited_skus": 14200,
  "in_sync": 14188,
  "ghost_pricing_discrepancies": [
    {
      "sku": "SKU-99014",
      "barcode": "4006381333931",
      "tag_mac": "00:1A:7D:DA:71:04",
      "aisle": "Aisle 4 - Cereals",
      "erp_master_price": 4.99,
      "esl_server_price": 4.99,
      "tag_ack_price": 3.99,
      "divergence_layer": "RF Base Station (Packet dropped due to antenna shadow)",
      "last_ack_timestamp": "2026-09-20T04:12:00Z",
      "recommended_action": "Force targeted re-transmit on Channel 11"
    }
  ]
}

Archetype 3: Battery Longevity Estimation Model

def estimate_tag_battery_years(
    updates_per_day: float,
    ambient_temp_celsius: float = 21.0,
    battery_mah: float = 1200.0,
    uAh_per_refresh: float = 18.0,
    standby_uA: float = 1.2
) -> float:
    # Temperature de-rating factor (freezer sections de-rate capacity significantly)
    temp_factor = 0.65 if ambient_temp_celsius < 0.0 else (0.85 if ambient_temp_celsius < 10.0 else 1.0)
    effective_mah = battery_mah * 0.85 * temp_factor  # 85% usable chemistry margin

    daily_drain_uAh = (updates_per_day * uAh_per_refresh) + (standby_uA * 24.0)
    daily_drain_mAh = daily_drain_uAh / 1000.0

    lifespan_days = effective_mah / daily_drain_mAh
    return round(lifespan_days / 365.25, 2)

The Pre-Emit Quality Gate Checklist

Before finalizing any ESL integration, sync workflow, or audit output:

• Delta Discipline: Confirmed that only changed row hashes are queued; no scheduled full catalog pushes.
• Idempotency Proof: Monotonic versioning and idempotency keys attached to every modification payload.
• 5-Layer Traceability: Explicit separation between ERP status, server queue, and base station physical tag ACK.
• RF Rate-Limiting: Gateway transmission queued at $\le 150$ updates/min per AP.
• Battery Budget Checked: Verified tag refresh schedule does not breach 3 updates/day lifespan limit.
• Layout Safety: Text width and font truncation verified against display canvas dimensions.
• Dry-Run Audit Default: Executed read-only reconciliation prior to proposing live write broadcasts.

Self-Correction & Verification Loop

Bad (Vibe-Coded AI Slop Output):

"To update the electronic labels, run a Python script that loops over all 50,000 products in your database and POSTs them to the ZKONG API every hour. If prices are wrong on the shelves, just run the script again." Problems: Fatal catalog flooding, battery destruction, zero delta tracking, zero idempotency, ignores gateway rate-limiting, blind to physical tag ACK status.

Good (Production ESL Price Sync Output):

1. Execute read-only audit comparing ERP pricing against ESL gateway ACK states; identify 12 divergent SKUs.
2. Compute SHA256 delta hashes for all modified SKUs since watermark 2026-09-22T08:00:00Z.
3. Generate idempotent mutation payloads with UUIDv5 tokens and monotonic timestamp versioning.
4. Verify tag layout: Confirm that promo prices fit within the 2.9-inch 3-color e-paper template without numeric truncation.
5. Queue rate-limited dispatch at 120 tags/min on Base Station 03, logging transmission to physical tag ACK confirmation.

Limitations

• ESL APIs, radio limits, acknowledgements, battery figures, and rate limits depend on the vendor, firmware, tag model, and local radio rules. Confirm each value in the deployed system's documentation before use.
• Start with read-only reconciliation and a small authorized pilot. A server acknowledgement does not prove the physical label displayed the intended value; require tag-level confirmation and a rollback plan before wider writes.
• Protect retail pricing, product, and device identifiers as business data. Do not transmit credentials or customer data in diagnostic logs or reports.
• The scripts and payloads in this guide are illustrative and are not vendor-certified integrations.