diff --git a/app/Console/Commands/Swoole.php b/app/Console/Commands/Swoole.php index 1967e06..c58160a 100644 --- a/app/Console/Commands/Swoole.php +++ b/app/Console/Commands/Swoole.php @@ -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(); diff --git a/app/Services/Business/BusinessClient.php b/app/Services/Business/BusinessClient.php index 2d83682..d9372ec 100644 --- a/app/Services/Business/BusinessClient.php +++ b/app/Services/Business/BusinessClient.php @@ -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; }