cf_cloud/erp
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: #20220818 订单获取日志记录修改

Browse Source
This commit is contained in:
赵世界 2022-08-18 13:20:55 +08:00
parent 73e28e6caf
commit b774245cf6
2 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/Console/Commands/Swoole.php
View File

@ -48,7 +48,7 @@ class Swoole extends Command
$endTime = DateTimeUtils::getMicroTime();
$beginTime = $endTime - 10000;
foreach ($shops as $shop) {
BusinessFactory::init()->make($shop->plat_id)->setShop($shop)->downloadOrdersAndSave($beginTime, $endTime, 'increment', 1);
BusinessFactory::init()->make($shop->plat_id)->setShop($shop)->downloadOrdersAndSave($beginTime, $endTime, 'increment');
}
});
Event::wait();

24
app/Services/Business/BusinessClient.php
View File

@ -139,21 +139,19 @@ abstract class BusinessClient
$res = (new Client())->request($method, $url, $headers);
$size = $res->getBody()->getSize();
$res = json_decode($res->getBody()->getContents(), true);
if ('pdd.ktt.increment.order.query' === $params['type']) {
$log = Log::query()->where('user_id', $this->getShop()->id)->where('target_field', $params['type'])->first();
} else {
if (!in_array($params['type'], ['pdd.ktt.increment.order.query', 'pdd.ktt.order.list'], true)) {
$log = new Log();
$log->module = 'plat';
$log->action = $method;
$log->target_type = $this->getShop()->plat_id;
$log->target_id = $this->getSkuId();
$log->target_field = $params['type'];
$log->user_id = $this->getShop()->id;
if ($size < 64000) {
$log->message = json_encode($res, 256);
}
$log->save();
}
$log->module = 'plat';
$log->action = $method;
$log->target_type = $this->getShop()->plat_id;
$log->target_id = $this->getSkuId();
$log->target_field = $params['type'];
$log->user_id = $this->getShop()->id;
if ($size < 64000) {
$log->message = json_encode($res, 256);
}
$log->save();
return $res;
}