|
|
@@ -355,11 +355,13 @@ Class CommodityService
|
|
|
public function pushCommodityToCache()
|
|
|
{
|
|
|
$amount = 1000;
|
|
|
- $sum = Commodity::query()->count('id');
|
|
|
+ $commodity = Commodity::query()->orderByDesc('id')->first();
|
|
|
+ $sum=$commodity->id;
|
|
|
$number = ceil($sum / $amount);
|
|
|
for ($i = 0; $i < $number; $i++) {
|
|
|
+ if ($i<41) continue;
|
|
|
$commodities = $this->getPiece(($i * $amount), $amount);
|
|
|
- if (!$commodities) continue;
|
|
|
+ if (count($commodities)<1) continue;
|
|
|
$this->pushToCache($commodities);
|
|
|
}
|
|
|
}
|
|
|
@@ -368,7 +370,7 @@ Class CommodityService
|
|
|
{
|
|
|
$commodities = Commodity::query()->with(['owner', 'barcodes'])
|
|
|
->where('id', '>=', $start)
|
|
|
- ->where('id', '<', $amount)
|
|
|
+ ->where('id', '<', ($start+$amount))
|
|
|
->get();
|
|
|
return $commodities;
|
|
|
}
|
|
|
@@ -381,15 +383,6 @@ Class CommodityService
|
|
|
Cache::remember($commodity_key, config('cache.expirations.forever'), function () use ($commodity) {
|
|
|
return $commodity;
|
|
|
});
|
|
|
-
|
|
|
-// if (count($commodity->barcodes) >= 1) {
|
|
|
-// foreach ($commodity->barcodes as $barcode) {
|
|
|
-// $barcode_key = "barcode_{$barcode['code']}";
|
|
|
-// Cache::remember($barcode_key, config('cache.expirations.forever'),function()use($commodity) {
|
|
|
-// return $commodity;
|
|
|
-// });
|
|
|
-// }
|
|
|
-// }
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -407,7 +400,7 @@ Class CommodityService
|
|
|
$last_records = $basSkus->where('addtime', $last_time);
|
|
|
if (!$basSkus) return;
|
|
|
$addBasSkus = $this->getLastRecordsByRedis($create_set, $create_key, $basSkus);
|
|
|
- if (count($addBasSkus) > 0) $addBasSkus=$this->filterByCommodityCache($addBasSkus);
|
|
|
+ //if (count($addBasSkus) > 0) $addBasSkus=$this->filterByCommodityCache($addBasSkus);
|
|
|
if (count($addBasSkus) > 0) {
|
|
|
$this->syncCreateCommodity($addBasSkus);
|
|
|
$this->deleteCacheKey($create_set, $create_keys);
|
haozi