mirror of
https://github.com/Karaka-Management/oms-Exchange.git
synced 2026-02-14 16:58:42 +00:00
import articles
This commit is contained in:
parent
d2cec2348e
commit
00535b71fe
|
|
@ -32,6 +32,11 @@ use phpOMS\DataStorage\Database\Connection\ConnectionFactory;
|
||||||
use phpOMS\DataStorage\Database\DatabaseStatus;
|
use phpOMS\DataStorage\Database\DatabaseStatus;
|
||||||
use phpOMS\DataStorage\Database\DataMapperAbstract;
|
use phpOMS\DataStorage\Database\DataMapperAbstract;
|
||||||
use phpOMS\Message\RequestAbstract;
|
use phpOMS\Message\RequestAbstract;
|
||||||
|
use Modules\Admin\Models\Account;
|
||||||
|
use Modules\Profile\Models\Profile;
|
||||||
|
use Modules\Exchange\Interfaces\GSD\Model\GSDArticleMapper;
|
||||||
|
use Modules\ItemManagement\Models\Item;
|
||||||
|
use Modules\ItemManagement\Models\ItemMapper;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* GSD import class
|
* GSD import class
|
||||||
|
|
@ -218,6 +223,14 @@ final class Importer extends ImporterAbstract
|
||||||
$obj = new Client();
|
$obj = new Client();
|
||||||
$obj->setNumber($customer->getNumber());
|
$obj->setNumber($customer->getNumber());
|
||||||
|
|
||||||
|
$account = new Account();
|
||||||
|
$account->setName1($customer->getAddress()->getName1());
|
||||||
|
$account->setName2($customer->getAddress()->getName2());
|
||||||
|
$account->setName3($customer->getAddress()->getName3());
|
||||||
|
|
||||||
|
$profile = new Profile($account);
|
||||||
|
$obj->setProfile($profile);
|
||||||
|
|
||||||
ClientMapper::create($obj);
|
ClientMapper::create($obj);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -247,6 +260,14 @@ final class Importer extends ImporterAbstract
|
||||||
$obj = new Supplier();
|
$obj = new Supplier();
|
||||||
$obj->setNumber($supplier->getNumber());
|
$obj->setNumber($supplier->getNumber());
|
||||||
|
|
||||||
|
$account = new Account();
|
||||||
|
$account->setName1($supplier->getAddress()->getName1());
|
||||||
|
$account->setName2($supplier->getAddress()->getName2());
|
||||||
|
$account->setName3($supplier->getAddress()->getName3());
|
||||||
|
|
||||||
|
$profile = new Profile($account);
|
||||||
|
$obj->setProfile($profile);
|
||||||
|
|
||||||
SupplierMapper::create($obj);
|
SupplierMapper::create($obj);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -277,6 +298,21 @@ final class Importer extends ImporterAbstract
|
||||||
*/
|
*/
|
||||||
public function importArticle(\DateTime $start, \DateTime $end) : void
|
public function importArticle(\DateTime $start, \DateTime $end) : void
|
||||||
{
|
{
|
||||||
|
DataMapperAbstract::setConnection($this->remote);
|
||||||
|
$query = GSDArticleMapper::getQuery();
|
||||||
|
$query->where('row_create_time', '=>', $start->format('Y-m-d H:i:s'))
|
||||||
|
->andWhere('row_create_time', '<=', $end->format('Y-m-d H:i:s'));
|
||||||
|
|
||||||
|
$articles = GSDArticleMapper::getAllByQuery($query);
|
||||||
|
|
||||||
|
DataMapperAbstract::setConnection($this->local);
|
||||||
|
|
||||||
|
foreach ($articles as $article) {
|
||||||
|
$obj = new Item();
|
||||||
|
$obj->setNumber($article->getNumber());
|
||||||
|
|
||||||
|
ItemMapper::create($obj);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user