'https://api.mercadolibre.com', 'timeout' => 30, ]); function getCredentials(mysqli $conn): array { $res = $conn->query(" SELECT user_id, access_token, refresh_token, expires_in, updated_at FROM tb_marketplace_tokens WHERE idMP=1 ORDER BY updated_at DESC LIMIT 1 "); if (!$row = $res->fetch_assoc()) { die("

ERROR: Ejecuta authorize.php primero.

"); } return [ 'user_id' => $row['user_id'], 'access_token' => $row['access_token'], 'refresh_token' => $row['refresh_token'], 'expires_in' => $row['expires_in'], 'updated_at' => $row['updated_at'], ]; } function refreshTokenIfNeeded(Client $http, array &$creds, mysqli $conn) { $expTs = strtotime($creds['updated_at']) + $creds['expires_in']; if (time() < $expTs - 60) return; $r = $http->post('/oauth/token', [ 'form_params' => [ 'grant_type' => 'refresh_token', 'client_id' => '3658695067033012', 'client_secret' => 'GZBg63xJNM9Eeb2cOhF9JwsOEv6vTxo7', 'refresh_token' => $creds['refresh_token'] ], 'headers' => ['Accept' => 'application/json'] ]); $d = json_decode((string)$r->getBody(), true); foreach (['access_token', 'refresh_token', 'expires_in'] as $k) { $creds[$k] = $d[$k]; } $u = $conn->prepare(" UPDATE tb_marketplace_tokens SET access_token=?, refresh_token=?, expires_in=?, updated_at=NOW() WHERE user_id=? "); $u->bind_param( 'ssis', $creds['access_token'], $creds['refresh_token'], $creds['expires_in'], $creds['user_id'] ); $u->execute(); $u->close(); } function updateWithRetry(Client $http, string $m, string $e, string $t, array $p = [], int $r = 3) { $a = 0; while (true) { try { usleep(100000); $opts = [ 'headers' => [ 'Authorization' => "Bearer {$t}", 'Content-Type' => 'application/json' ] ]; if ($m !== 'GET') $opts['json'] = $p; $resp = match ($m) { 'GET' => $http->get($e, $opts), 'POST' => $http->post($e, $opts), default => $http->put($e, $opts) }; return json_decode((string)$resp->getBody(), true); } catch (RequestException $x) { $code = $x->getResponse()?->getStatusCode() ?: 0; if ($code === 429 && $a++ < $r) { sleep((int)$x->getResponse()->getHeaderLine('Retry-After') ?: 5); continue; } throw $x; } } } function predictCategories(Client $http, string $token, string $q): array { try { $r = $http->get("/sites/" . SITE_ID . "/domain_discovery/search", [ 'headers' => ['Authorization' => "Bearer {$token}", 'Accept' => 'application/json'], 'query' => ['limit' => PREDICT_LIMIT, 'q' => $q] ]); return json_decode((string)$r->getBody(), true) ?: []; } catch (RequestException) { return []; } } function fetchCategoryPath(Client $http, string $catId): string { try { $r = $http->get("/categories/{$catId}", ['headers' => ['Accept' => 'application/json']]); $d = json_decode((string)$r->getBody(), true); $names = array_column($d['path_from_root'], 'name'); return implode(' › ', $names); } catch (RequestException) { return $catId; } } function uploadPicture(Client $http, string $token, string $url): ?string { try { $r = $http->post('/pictures', [ 'headers' => ['Authorization' => "Bearer {$token}", 'Content-Type' => 'application/json'], 'json' => ['source' => $url] ]); $d = json_decode((string)$r->getBody(), true); // ——>> LOG: respuesta completa file_put_contents(__DIR__ . '/ml_pictures.log', date('c') . " | URL: {$url}\n" . print_r($d, true) . "\n", FILE_APPEND); return $d['id'] ?? null; } catch (RequestException $x) { file_put_contents(__DIR__ . '/ml_pictures.log', date('c') . " | ERROR cargando {$url}: " . $x->getMessage() . "\n", FILE_APPEND); return null; } } function e(?string $s): string { // si viene null, lo convertimos en cadena vacía return htmlspecialchars((string)$s, ENT_QUOTES); } ?> Publicar ML Wizard

Publicar en MercadoLibre

1) Productos pendientes

'; exit; } // — 2) SELECCIONAR categoría — if ($stage === 'select_category') { // cargo datos del producto $row = $conn->query(" SELECT p.tituloPublicacion, pr.descripcion AS descripcion, pr.txtMedidas, pr.txtMaterial FROM tb_marketplace_productos p JOIN tb_productos pr ON p.idProducto=pr.id WHERE p.id={$product_id} ")->fetch_assoc(); $title = $row['tituloPublicacion']; $desc = $row['descripcion']; $med = $row['txtMedidas']; $mat = $row['txtMaterial']; // buscar o usar título como query $search = $_REQUEST['search_query'] ?? $title; if ($_SERVER['REQUEST_METHOD'] === 'POST') { $cat = $_POST['category_id']; header("Location:?stage=fill_attributes&product_id={$product_id}&category_id={$cat}"); exit; } $preds = predictCategories($http, $token, $search); // filtro solo categorías que acepten variaciones // 2) Generar listado de categorías que admitan variaciones $candidates = []; foreach ($preds as $p) { // Traemos los atributos de la categoría (con token) $attrs = updateWithRetry( $http, 'GET', "/categories/{$p['category_id']}/attributes", $token ); // Buscamos si tiene algún atributo de variación $hasVariation = false; foreach ($attrs as $a) { if ( (($a['hierarchy'] ?? '') === 'CHILD_PK') || !empty($a['tags']['variation_attribute']) ) { $hasVariation = true; break; } } if ($hasVariation) { // Obtenemos la ruta desde la raíz para mostrar el árbol $path = fetchCategoryPath($http, $p['category_id']); $candidates[] = [ 'id' => $p['category_id'], 'name' => e($path) ]; } } // Si no hay ninguna categoría con variaciones, usamos el fallback if (empty($candidates)) { $candidates[] = [ 'id' => CATEGORY_FALLBACK, 'name' => CATEGORY_FALLBACK . ' (fallback)' ]; } echo '

2) Selecciona categoría

'; echo "

" . e($title) . "
" . e($desc) . "
Medidas: " . e($med) . " | Material: " . e($mat) . "

"; // formulario de búsqueda echo "
"; // dropdown de candidatos echo "
"; exit; } // — 3) RELLENAR atributos y variaciones — if ($stage === 'fill_attributes') { $category_id = $_REQUEST['category_id']; // cargo datos del producto $prod = $conn->query(" SELECT p.tituloPublicacion, pr.descripcion AS descripcion, pr.txtMedidas, pr.txtMaterial, p.precioPublicacion, p.stockPublicacion, p.skuMP FROM tb_marketplace_productos p JOIN tb_productos pr ON p.idProducto=pr.id WHERE p.id={$product_id} ")->fetch_assoc(); // cargo variaciones (solo stock>0) $vars = []; $stmt = $conn->prepare(" SELECT v.idVariante,v.skuMPVariante,v.precioPublicacion,v.stockPublicacion, v.colorTipoVariante, iv.linkImagen FROM tb_marketplace_variantes v JOIN tb_imagenes_variantes iv ON v.idVariante=iv.idVariante WHERE v.idMarketplaceProducto=? AND v.stockPublicacion>0 "); $stmt->bind_param('i', $product_id); $stmt->execute(); $stmt->bind_result($idVar, $vs, $vp, $vsx, $vc, $vi); while ($stmt->fetch()) { $vars[] = [ 'id' => $idVar, 'sku' => $vs, 'price' => $vp, 'stock' => $vsx, 'color' => $vc, 'img' => str_replace('J:/', 'https://sistema.compranet.com.co/', $vi) ]; } $stmt->close(); // obtengo spec UI de la categoría try { $tech = updateWithRetry($http, 'GET', "/categories/{$category_id}/technical_specs/input", $token, [], 1); } catch (RequestException $ex) { $tech = ['groups' => []]; } if ($_SERVER['REQUEST_METHOD'] === 'POST') { $qs = http_build_query([ 'stage' => 'publish', 'product_id' => $product_id, 'category_id' => $category_id ]); header("Location:?{$qs}&" . http_build_query($_POST)); exit; } // render echo '

3) Completa atributos y variaciones

'; echo "

" . e($prod['tituloPublicacion']) . "
" . e($prod['descripcion']) . "
" . "Medidas: " . e($prod['txtMedidas']) . " | Material: " . e($prod['txtMaterial']) . "

"; echo "
"; // recorro grupos y componentes foreach ($tech['groups'] as $group) { echo "

" . e($group['label']) . "

"; foreach ($group['components'] as $comp) { $ui = $comp['ui_config'] ?? []; foreach ($comp['attributes'] as $attr) { // salto hidden // salto atributos ocultos, de solo lectura o de variación // salto hidden, read_only o variation_attribute (tanto si vienen como keys o como valores) $tags = $attr['tags'] ?? []; foreach (['hidden', 'read_only', 'variation_attribute'] as $t) { if ((isset($tags[$t]) && $tags[$t]) || in_array($t, $tags, true)) { continue 2; // salta este atributo } } // además salto cualquier PACKAGE_* if (strpos($attr['id'], 'PACKAGE_') === 0) { continue; } // --- Definir siempre el id y abrir el div/label --- $id = e($attr['id']); $name = e($attr['name']); echo "
"; // override MODEL if ($attr['id'] === 'MODEL') { echo ""; echo "
"; // cierro el div que abrí arriba continue; } // override BRAND if ($attr['id'] === 'BRAND') { echo ""; echo "
"; continue; } // valor fixed → auto-assign + readonly if (!empty($attr['tags']['fixed']) && count($attr['values'] ?? []) === 1) { $only = $attr['values'][0]; echo ""; echo ""; } // COMBO → select o datalist elseif ($comp['component'] === 'COMBO') { $vals = $attr['values'] ?? []; if (!empty($ui['allow_filtering'])) { // uso datalist $listId = "lst_{$id}"; echo ""; echo ""; foreach ($vals as $v) { printf(""; } else { // normal select echo ""; } } // TEXT_INPUT → input libre elseif ($comp['component'] === 'TEXT_INPUT') { $val = $ui['allow_custom_value'] ? '' : ''; echo ""; } // NUMBER_UNIT, BOOLEAN, etc → campo texto libre (podrías especializarlo) else { echo ""; } echo ""; } } } // variaciones echo "

Variaciones

"; // determinar varAttrId $varAttrId = 'COLOR'; foreach ($tech['groups'] as $g) { foreach ($g['components'] as $c) { foreach ($c['attributes'] as $a) { if (!empty($a['tags']['variation_attribute'])) { $varAttrId = $a['id']; break 3; } } } } foreach ($vars as $i => $v) { echo "
SKU " . e($v['sku']) . ""; printf( "Precio:
", $i, e($v['price']) ); printf( "Stock:
", $i, e($v['stock']) ); // combinaciones // busco los valores del varAttrId $vals = []; foreach ($tech['groups'] as $g) { foreach ($g['components'] as $c) { foreach ($c['attributes'] as $a) { if ($a['id'] === $varAttrId) { $vals = $a['values'] ?? []; break 3; } } } } // Pon esto: echo "
"; echo ""; // muestro el color actual en un input de solo lectura echo ""; // envío el mismo valor oculto para que llegue en el POST echo ""; echo "
"; echo "
"; echo ""; } echo "
"; echo ""; echo ""; exit; } // — 4) PUBLICAR final — if ($stage === 'publish') { $category_id = $_REQUEST['category_id']; // recargo datos $row = $conn->query(" SELECT p.tituloPublicacion, p.descripcionPublicacion AS descripcion, pr.txtMedidas, pr.txtMaterial, p.precioPublicacion, p.stockPublicacion, p.skuMP FROM tb_marketplace_productos p JOIN tb_productos pr ON p.idProducto=pr.id WHERE p.id={$product_id} ")->fetch_assoc(); $title = $row['tituloPublicacion']; $description = $row['descripcion']; $price = $row['precioPublicacion']; $stock = $row['stockPublicacion']; $sku_main = $row['skuMP']; // variaciones $vars = []; $stmt = $conn->prepare(" SELECT v.idVariante,v.skuMPVariante,v.precioPublicacion,v.stockPublicacion,iv.linkImagen FROM tb_marketplace_variantes v JOIN tb_imagenes_variantes iv ON v.idVariante=iv.idVariante WHERE v.idMarketplaceProducto=? AND v.stockPublicacion>0 "); $stmt->bind_param('i', $product_id); $stmt->execute(); $stmt->bind_result( $idVar, // idVariante $vs, // skuMPVariante $vp, // precioPublicacion $vsx, // stockPublicacion $vi // linkImagen ); while ($stmt->fetch()) { $vars[] = [ 'id' => $idVar, 'sku' => $vs, 'price' => $vp, 'stock' => $vsx, 'img' => str_replace('J:/', 'https://sistema.compranet.com.co/', $vi) ]; } $stmt->close(); // 1) Cargo y filtro los atributos permitidos $meta = updateWithRetry( $http, 'GET', "/categories/{$category_id}/attributes", $token, [], 1 ); $allowed = array_filter($meta, function ($a) { $tags = $a['tags'] ?? []; foreach (['hidden', 'read_only', 'variation_attribute'] as $t) { if ((isset($tags[$t]) && $tags[$t]) || in_array($t, $tags, true)) { return false; } } // no permito PACKAGE_* if (strpos($a['id'], 'PACKAGE_') === 0) { return false; } return true; }); $allowedIds = array_column($allowed, 'id'); // 2) Construyo topAttrs A PARTIR DE allowedIds $topAttrs = []; foreach ($_GET as $k => $v) { if (!str_starts_with($k, 'attr_') || $v === '') continue; $aid = substr($k, 5); if (!in_array($aid, $allowedIds, true)) continue; $topAttrs[] = is_numeric($v) ? ['id' => $aid, 'value_id' => $v] : ['id' => $aid, 'value_name' => $v]; } // 3) Salvavidas extra: elimino cualquier PACKAGE_* $topAttrs = array_values(array_filter( $topAttrs, fn($a) => strpos($a['id'], 'PACKAGE_') !== 0 )); $allowedIds = array_column($allowed, 'id'); // ya tienes $allowed (filtrado) justo arriba… $varAttrId = 'COLOR'; foreach ($allowed as $a) { $tags = $a['tags'] ?? []; if ( (isset($tags['variation_attribute']) && $tags['variation_attribute']) || in_array('variation_attribute', $tags, true) ) { $varAttrId = $a['id']; break; } } // build variations payload $varsPayload = []; foreach ($vars as $i => $v) { $vp = (float)($_GET["var_{$i}_price"] ?? $v['price']); $vs = (int) ($_GET["var_{$i}_stock"] ?? $v['stock']); $vc = $_GET["var_{$i}_combo"] ?? ''; $comb = $vc ? [['id' => $varAttrId, 'value_name' => $vc]] : []; $entry = [ 'seller_custom_field' => $v['sku'], 'price' => $vp, 'available_quantity' => $vs, 'attribute_combinations' => $comb, 'attributes' => [ [ 'id' => 'SELLER_SKU', 'value_name' => $v['sku'] ] ] ]; if ($pic = uploadPicture($http, $token, $v['img'])) { $entry['picture_ids'] = [$pic]; } else { file_put_contents(__DIR__ . '/ml_pictures.log', date('c') . " | NO se obtuvo ID para SKU {$v['sku']} URL {$v['img']}\n", FILE_APPEND); } $varsPayload[] = $entry; } // sale_terms fijos $sale_terms = [ ['id' => 'WARRANTY_TYPE', 'value_id' => '2230280'], ['id' => 'WARRANTY_TIME', 'value_name' => '30 días'], ['id' => 'MANUFACTURING_TIME', 'value_name' => '3 días'], ]; $topAttrs = array_values(array_filter($topAttrs, fn($a) => strpos($a['id'], 'PACKAGE_') !== 0)); // payload final $payload = [ 'site_id' => SITE_ID, 'title' => $title, 'category_id' => $category_id, 'price' => $price, 'currency_id' => 'COP', 'available_quantity' => $stock, 'buying_mode' => 'buy_it_now', 'listing_type_id' => 'gold_pro', 'condition' => 'new', 'seller_custom_field' => $sku_main, 'accepts_mercadopago' => true, 'shipping' => ['mode' => 'not_specified', 'local_pick_up' => false], 'sale_terms' => $sale_terms, 'pictures' => [], 'attributes' => $topAttrs, 'variations' => $varsPayload ]; echo '

4) Resultado de la publicación

'; try { $resp = updateWithRetry($http, 'POST', '/items', $token, $payload); $itemData = updateWithRetry($http, 'GET', "/items/{$resp['id']}", $token, [], 1); file_put_contents( __DIR__ . '/ml_pictures.log', date('c') . " | ITEM {$resp['id']} pictures:\n" . print_r($itemData['pictures'] ?? [], true) . "\n\n", FILE_APPEND ); if (!empty($resp['id'])) { $ml = $resp['id']; $u = $conn->prepare(" UPDATE tb_marketplace_productos SET refMP=?, fechaSincronizacion=NOW() WHERE id=? "); // 1.a) Subo la descripción en un llamado aparte updateWithRetry( $http, 'POST', "/items/{$ml}/description", $token, ['plain_text' => $description] ); // — Actualizar variantes con sus IDs en ML — try { $itemData = updateWithRetry($http, 'GET', "/items/{$ml}", $token, [], 1); foreach ($itemData['variations'] ?? [] as $var) { // $var['seller_custom_field'] es tu SKU local $remoteVarId = $var['id']; $localSku = $var['seller_custom_field']; $upVar = $conn->prepare(" UPDATE tb_marketplace_variantes SET refMPVariante = ? WHERE skuMPVariante = ? AND idMarketplaceProducto = ? "); $upVar->bind_param('ssi', $remoteVarId, $localSku, $product_id); $upVar->execute(); $upVar->close(); } } catch (RequestException $e) { // opcionalmente loguear el error… } $u->bind_param('si', $ml, $product_id); $u->execute(); $u->close(); echo "

✅ Publicado con ID {$ml}

"; } else { echo "

❌ No devolvió ID.

"; } } catch (RequestException $x) { $err = json_decode((string)$x->getResponse()->getBody(), true); $msgs = array_map(fn($c) => $c['message'] ?? $c['field'], $err['cause'] ?? []); echo "

❗ " . implode(', ', $msgs) . "

"; } echo "

← Empezar otro

"; echo '
'; exit; } // Etapa desconocida echo "

Etapa desconocida.

";