Integrations DI refactor, remove Sellasist/Baselinker, fix product-edit encoding (0.263)
- New: Domain\Integrations\IntegrationsRepository + admin\Controllers\IntegrationsController (DI) - Cleanup: removed all Sellasist and Baselinker integrations from entire project - Fix: product-edit.php Polish characters (UTF-8/CP1250 double-encoding) - Update: factory\Integrations as facade (Apilo + ShopPRO only) - Tests: 212 tests, 577 assertions Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
408
autoload/Domain/Integrations/IntegrationsRepository.php
Normal file
408
autoload/Domain/Integrations/IntegrationsRepository.php
Normal file
@@ -0,0 +1,408 @@
|
||||
<?php
|
||||
namespace Domain\Integrations;
|
||||
|
||||
class IntegrationsRepository
|
||||
{
|
||||
private $db;
|
||||
|
||||
private const SETTINGS_TABLES = [
|
||||
'apilo' => 'pp_shop_apilo_settings',
|
||||
'shoppro' => 'pp_shop_shoppro_settings',
|
||||
];
|
||||
|
||||
public function __construct( $db )
|
||||
{
|
||||
$this->db = $db;
|
||||
}
|
||||
|
||||
// ── Settings ────────────────────────────────────────────────
|
||||
|
||||
private function settingsTable( string $provider ): string
|
||||
{
|
||||
if ( !isset( self::SETTINGS_TABLES[$provider] ) )
|
||||
throw new \InvalidArgumentException( "Unknown provider: $provider" );
|
||||
|
||||
return self::SETTINGS_TABLES[$provider];
|
||||
}
|
||||
|
||||
public function getSettings( string $provider ): array
|
||||
{
|
||||
$table = $this->settingsTable( $provider );
|
||||
$results = $this->db->query( "SELECT * FROM $table" )->fetchAll( \PDO::FETCH_ASSOC );
|
||||
$settings = [];
|
||||
foreach ( $results as $row )
|
||||
$settings[$row['name']] = $row['value'];
|
||||
|
||||
return $settings;
|
||||
}
|
||||
|
||||
public function getSetting( string $provider, string $name ): ?string
|
||||
{
|
||||
$table = $this->settingsTable( $provider );
|
||||
$value = $this->db->get( $table, 'value', [ 'name' => $name ] );
|
||||
return $value !== false ? $value : null;
|
||||
}
|
||||
|
||||
public function saveSetting( string $provider, string $name, $value ): bool
|
||||
{
|
||||
$table = $this->settingsTable( $provider );
|
||||
if ( $this->db->count( $table, [ 'name' => $name ] ) ) {
|
||||
$this->db->update( $table, [ 'value' => $value ], [ 'name' => $name ] );
|
||||
} else {
|
||||
$this->db->insert( $table, [ 'name' => $name, 'value' => $value ] );
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
// ── Product linking (Apilo) ─────────────────────────────────
|
||||
|
||||
public function linkProduct( int $productId, $externalId, $externalName ): bool
|
||||
{
|
||||
return (bool) $this->db->update( 'pp_shop_products', [
|
||||
'apilo_product_id' => $externalId,
|
||||
'apilo_product_name' => \S::remove_special_chars( $externalName ),
|
||||
], [ 'id' => $productId ] );
|
||||
}
|
||||
|
||||
public function unlinkProduct( int $productId ): bool
|
||||
{
|
||||
return (bool) $this->db->update( 'pp_shop_products', [
|
||||
'apilo_product_id' => null,
|
||||
'apilo_product_name' => null,
|
||||
], [ 'id' => $productId ] );
|
||||
}
|
||||
|
||||
// ── Apilo OAuth ─────────────────────────────────────────────
|
||||
|
||||
public function apiloAuthorize( string $clientId, string $clientSecret, string $authCode ): bool
|
||||
{
|
||||
$postData = [
|
||||
'grantType' => 'authorization_code',
|
||||
'token' => $authCode,
|
||||
];
|
||||
|
||||
$ch = curl_init( "https://projectpro.apilo.com/rest/auth/token/" );
|
||||
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
|
||||
curl_setopt( $ch, CURLOPT_CUSTOMREQUEST, "POST" );
|
||||
curl_setopt( $ch, CURLOPT_POSTFIELDS, json_encode( $postData ) );
|
||||
curl_setopt( $ch, CURLOPT_HTTPHEADER, [
|
||||
"Authorization: Basic " . base64_encode( $clientId . ":" . $clientSecret ),
|
||||
"Accept: application/json"
|
||||
] );
|
||||
|
||||
$response = curl_exec( $ch );
|
||||
if ( curl_errno( $ch ) ) {
|
||||
curl_close( $ch );
|
||||
return false;
|
||||
}
|
||||
curl_close( $ch );
|
||||
$response = json_decode( $response, true );
|
||||
|
||||
if ( empty( $response['accessToken'] ) )
|
||||
return false;
|
||||
|
||||
$this->saveSetting( 'apilo', 'access-token', $response['accessToken'] );
|
||||
$this->saveSetting( 'apilo', 'refresh-token', $response['refreshToken'] );
|
||||
$this->saveSetting( 'apilo', 'access-token-expire-at', $response['accessTokenExpireAt'] );
|
||||
$this->saveSetting( 'apilo', 'refresh-token-expire-at', $response['refreshTokenExpireAt'] );
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
public function apiloGetAccessToken(): ?string
|
||||
{
|
||||
$settings = $this->getSettings( 'apilo' );
|
||||
|
||||
if ( empty( $settings['access-token-expire-at'] ) || empty( $settings['access-token'] ) )
|
||||
return null;
|
||||
|
||||
$expireAt = new \DateTime( $settings['access-token-expire-at'] );
|
||||
$now = new \DateTime( date( 'Y-m-d H:i:s' ) );
|
||||
|
||||
if ( $expireAt >= $now )
|
||||
return $settings['access-token'];
|
||||
|
||||
// Token expired - refresh
|
||||
$postData = [
|
||||
'grantType' => 'refresh_token',
|
||||
'token' => $settings['refresh-token'],
|
||||
];
|
||||
|
||||
$ch = curl_init( "https://projectpro.apilo.com/rest/auth/token/" );
|
||||
curl_setopt( $ch, CURLOPT_HTTPHEADER, [
|
||||
"Authorization: Basic " . base64_encode( $settings['client-id'] . ":" . $settings['client-secret'] ),
|
||||
"Accept: application/json"
|
||||
] );
|
||||
curl_setopt( $ch, CURLOPT_POST, true );
|
||||
curl_setopt( $ch, CURLOPT_POSTFIELDS, json_encode( $postData ) );
|
||||
curl_setopt( $ch, CURLOPT_CUSTOMREQUEST, "POST" );
|
||||
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
|
||||
|
||||
$response = curl_exec( $ch );
|
||||
if ( curl_errno( $ch ) ) {
|
||||
curl_close( $ch );
|
||||
return null;
|
||||
}
|
||||
curl_close( $ch );
|
||||
$response = json_decode( $response, true );
|
||||
|
||||
if ( empty( $response['accessToken'] ) )
|
||||
return null;
|
||||
|
||||
$this->saveSetting( 'apilo', 'access-token', $response['accessToken'] );
|
||||
$this->saveSetting( 'apilo', 'refresh-token', $response['refreshToken'] );
|
||||
$this->saveSetting( 'apilo', 'access-token-expire-at', $response['accessTokenExpireAt'] );
|
||||
$this->saveSetting( 'apilo', 'refresh-token-expire-at', $response['refreshTokenExpireAt'] );
|
||||
|
||||
return $response['accessToken'];
|
||||
}
|
||||
|
||||
// ── Apilo API fetch lists ───────────────────────────────────
|
||||
|
||||
private const APILO_ENDPOINTS = [
|
||||
'platform' => 'https://projectpro.apilo.com/rest/api/orders/platform/map/',
|
||||
'status' => 'https://projectpro.apilo.com/rest/api/orders/status/map/',
|
||||
'carrier' => 'https://projectpro.apilo.com/rest/api/orders/carrier-account/map/',
|
||||
'payment' => 'https://projectpro.apilo.com/rest/api/orders/payment/map/',
|
||||
];
|
||||
|
||||
private const APILO_SETTINGS_KEYS = [
|
||||
'platform' => 'platform-list',
|
||||
'status' => 'status-types-list',
|
||||
'carrier' => 'carrier-account-list',
|
||||
'payment' => 'payment-types-list',
|
||||
];
|
||||
|
||||
/**
|
||||
* Fetch list from Apilo API and save to settings.
|
||||
* @param string $type platform|status|carrier|payment
|
||||
*/
|
||||
public function apiloFetchList( string $type ): bool
|
||||
{
|
||||
if ( !isset( self::APILO_ENDPOINTS[$type] ) )
|
||||
throw new \InvalidArgumentException( "Unknown apilo list type: $type" );
|
||||
|
||||
$accessToken = $this->apiloGetAccessToken();
|
||||
if ( !$accessToken )
|
||||
return false;
|
||||
|
||||
$ch = curl_init( self::APILO_ENDPOINTS[$type] );
|
||||
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
|
||||
curl_setopt( $ch, CURLOPT_HTTPHEADER, [
|
||||
"Authorization: Bearer " . $accessToken,
|
||||
"Accept: application/json"
|
||||
] );
|
||||
|
||||
$response = curl_exec( $ch );
|
||||
if ( curl_errno( $ch ) ) {
|
||||
curl_close( $ch );
|
||||
return false;
|
||||
}
|
||||
curl_close( $ch );
|
||||
|
||||
$data = json_decode( $response, true );
|
||||
if ( !$data )
|
||||
return false;
|
||||
|
||||
$this->saveSetting( 'apilo', self::APILO_SETTINGS_KEYS[$type], $data );
|
||||
return true;
|
||||
}
|
||||
|
||||
// ── Apilo product operations ────────────────────────────────
|
||||
|
||||
public function getProductSku( int $productId ): ?string
|
||||
{
|
||||
$sku = $this->db->get( 'pp_shop_products', 'sku', [ 'id' => $productId ] );
|
||||
return $sku ?: null;
|
||||
}
|
||||
|
||||
public function apiloProductSearch( string $sku ): array
|
||||
{
|
||||
$accessToken = $this->apiloGetAccessToken();
|
||||
if ( !$accessToken )
|
||||
return [ 'status' => 'error', 'msg' => 'Brak tokenu Apilo.' ];
|
||||
|
||||
$url = "https://projectpro.apilo.com/rest/api/warehouse/product/?" . http_build_query( [ 'sku' => $sku ] );
|
||||
|
||||
$ch = curl_init( $url );
|
||||
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
|
||||
curl_setopt( $ch, CURLOPT_HTTPHEADER, [
|
||||
"Authorization: Bearer " . $accessToken,
|
||||
"Accept: application/json"
|
||||
] );
|
||||
|
||||
$response = curl_exec( $ch );
|
||||
if ( curl_errno( $ch ) ) {
|
||||
curl_close( $ch );
|
||||
return [ 'status' => 'error', 'msg' => 'Błąd cURL: ' . curl_error( $ch ) ];
|
||||
}
|
||||
curl_close( $ch );
|
||||
|
||||
$data = json_decode( $response, true );
|
||||
if ( $data && isset( $data['products'] ) ) {
|
||||
$data['status'] = 'SUCCESS';
|
||||
return $data;
|
||||
}
|
||||
|
||||
return [ 'status' => 'SUCCESS', 'msg' => 'Brak wyników dla podanego SKU.', 'products' => '' ];
|
||||
}
|
||||
|
||||
public function apiloCreateProduct( int $productId ): array
|
||||
{
|
||||
$accessToken = $this->apiloGetAccessToken();
|
||||
if ( !$accessToken )
|
||||
return [ 'success' => false, 'message' => 'Brak tokenu Apilo.' ];
|
||||
|
||||
$product = new \shop\Product( $productId );
|
||||
|
||||
$params = [
|
||||
'sku' => $product->sku,
|
||||
'ean' => $product->ean,
|
||||
'name' => $product->language['name'],
|
||||
'tax' => (int) $product->vat,
|
||||
'status' => 1,
|
||||
'quantity' => (int) $product->quantity,
|
||||
'priceWithTax' => $product->price_brutto,
|
||||
'description' => $product->language['description'] . '<br>' . $product->language['short_description'],
|
||||
'shortDescription' => '',
|
||||
'images' => [],
|
||||
];
|
||||
|
||||
foreach ( $product->images as $image )
|
||||
$params['images'][] = "https://" . $_SERVER['HTTP_HOST'] . $image['src'];
|
||||
|
||||
$ch = curl_init( "https://projectpro.apilo.com/rest/api/warehouse/product/" );
|
||||
curl_setopt( $ch, CURLOPT_POSTFIELDS, json_encode( [ $params ] ) );
|
||||
curl_setopt( $ch, CURLOPT_CUSTOMREQUEST, "POST" );
|
||||
curl_setopt( $ch, CURLOPT_HTTPHEADER, [
|
||||
"Authorization: Bearer " . $accessToken,
|
||||
"Content-Type: application/json",
|
||||
"Accept: application/json"
|
||||
] );
|
||||
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
|
||||
$response = curl_exec( $ch );
|
||||
$responseData = json_decode( $response, true );
|
||||
|
||||
if ( curl_errno( $ch ) ) {
|
||||
$error = curl_error( $ch );
|
||||
curl_close( $ch );
|
||||
return [ 'success' => false, 'message' => 'Błąd cURL: ' . $error ];
|
||||
}
|
||||
curl_close( $ch );
|
||||
|
||||
if ( !empty( $responseData['products'] ) ) {
|
||||
$this->db->update( 'pp_shop_products', [
|
||||
'apilo_product_id' => reset( $responseData['products'] ),
|
||||
'apilo_product_name' => $product->language['name'],
|
||||
], [ 'id' => $product->id ] );
|
||||
|
||||
return [ 'success' => true, 'message' => 'Produkt został dodany do magazynu APILO.' ];
|
||||
}
|
||||
|
||||
return [ 'success' => false, 'message' => 'Podczas dodawania produktu wystąpił błąd.' ];
|
||||
}
|
||||
|
||||
// ── ShopPRO import ──────────────────────────────────────────
|
||||
|
||||
public function shopproImportProduct( int $productId ): array
|
||||
{
|
||||
$settings = $this->getSettings( 'shoppro' );
|
||||
|
||||
$mdb2 = new \medoo( [
|
||||
'database_type' => 'mysql',
|
||||
'database_name' => $settings['db_name'],
|
||||
'server' => $settings['db_host'],
|
||||
'username' => $settings['db_user'],
|
||||
'password' => $settings['db_password'],
|
||||
'charset' => 'utf8'
|
||||
] );
|
||||
|
||||
$product = $mdb2->get( 'pp_shop_products', '*', [ 'id' => $productId ] );
|
||||
if ( !$product )
|
||||
return [ 'success' => false, 'message' => 'Podczas importowania produktu wystąpił błąd.' ];
|
||||
|
||||
$this->db->insert( 'pp_shop_products', [
|
||||
'price_netto' => $product['price_netto'],
|
||||
'price_brutto' => $product['price_brutto'],
|
||||
'vat' => $product['vat'],
|
||||
'stock_0_buy' => $product['stock_0_buy'],
|
||||
'quantity' => $product['quantity'],
|
||||
'wp' => $product['wp'],
|
||||
'sku' => $product['sku'],
|
||||
'ean' => $product['ean'],
|
||||
'custom_label_0' => $product['custom_label_0'],
|
||||
'custom_label_1' => $product['custom_label_1'],
|
||||
'custom_label_2' => $product['custom_label_2'],
|
||||
'custom_label_3' => $product['custom_label_3'],
|
||||
'custom_label_4' => $product['custom_label_4'],
|
||||
'additional_message' => $product['additional_message'],
|
||||
'additional_message_text' => $product['additional_message_text'],
|
||||
'additional_message_required'=> $product['additional_message_required'],
|
||||
'weight' => $product['weight'],
|
||||
] );
|
||||
|
||||
$newProductId = $this->db->id();
|
||||
if ( !$newProductId )
|
||||
return [ 'success' => false, 'message' => 'Podczas importowania produktu wystąpił błąd.' ];
|
||||
|
||||
// Import translations
|
||||
$languages = $mdb2->select( 'pp_shop_products_langs', '*', [ 'product_id' => $productId ] );
|
||||
if ( is_array( $languages ) ) {
|
||||
foreach ( $languages as $lang ) {
|
||||
$this->db->insert( 'pp_shop_products_langs', [
|
||||
'product_id' => $newProductId,
|
||||
'lang_id' => $lang['lang_id'],
|
||||
'name' => $lang['name'],
|
||||
'short_description' => $lang['short_description'],
|
||||
'description' => $lang['description'],
|
||||
'tab_name_1' => $lang['tab_name_1'],
|
||||
'tab_description_1' => $lang['tab_description_1'],
|
||||
'tab_name_2' => $lang['tab_name_2'],
|
||||
'tab_description_2' => $lang['tab_description_2'],
|
||||
'meta_title' => $lang['meta_title'],
|
||||
'meta_description' => $lang['meta_description'],
|
||||
'meta_keywords' => $lang['meta_keywords'],
|
||||
'seo_link' => $lang['seo_link'],
|
||||
'copy_from' => $lang['copy_from'],
|
||||
'warehouse_message_zero' => $lang['warehouse_message_zero'],
|
||||
'warehouse_message_nonzero'=> $lang['warehouse_message_nonzero'],
|
||||
'canonical' => $lang['canonical'],
|
||||
'xml_name' => $lang['xml_name'],
|
||||
] );
|
||||
}
|
||||
}
|
||||
|
||||
// Import images
|
||||
$images = $mdb2->select( 'pp_shop_products_images', '*', [ 'product_id' => $productId ] );
|
||||
if ( is_array( $images ) ) {
|
||||
foreach ( $images as $image ) {
|
||||
$imageUrl = 'https://' . $settings['domain'] . $image['src'];
|
||||
|
||||
$ch = curl_init( $imageUrl );
|
||||
curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
|
||||
curl_setopt( $ch, CURLOPT_FOLLOWLOCATION, true );
|
||||
curl_setopt( $ch, CURLOPT_SSL_VERIFYPEER, false );
|
||||
curl_setopt( $ch, CURLOPT_SSL_VERIFYHOST, false );
|
||||
$imageData = curl_exec( $ch );
|
||||
curl_close( $ch );
|
||||
|
||||
$imageName = basename( $imageUrl );
|
||||
$imageDir = '../upload/product_images/product_' . $newProductId;
|
||||
$imagePath = $imageDir . '/' . $imageName;
|
||||
|
||||
if ( !file_exists( $imageDir ) )
|
||||
mkdir( $imageDir, 0777, true );
|
||||
|
||||
file_put_contents( $imagePath, $imageData );
|
||||
|
||||
$this->db->insert( 'pp_shop_products_images', [
|
||||
'product_id' => $newProductId,
|
||||
'src' => '/upload/product_images/product_' . $newProductId . '/' . $imageName,
|
||||
'o' => $image['o'],
|
||||
] );
|
||||
}
|
||||
}
|
||||
|
||||
return [ 'success' => true, 'message' => 'Produkt został zaimportowany.' ];
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user