123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165 |
- <?php
- namespace app\jobs\product;
- use app\services\product\product\CopyTaobaoServices;
- use app\services\product\product\StoreDescriptionServices;
- use app\services\product\product\StoreProductServices;
- use app\services\product\sku\StoreProductAttrValueServices;
- use crmeb\basic\BaseJobs;
- use crmeb\services\CacheService;
- use crmeb\traits\QueueTrait;
- use think\facade\Log;
- class ProductCopyJob extends BaseJobs
- {
- use QueueTrait;
-
- public function copyDescriptionImage($id, $description, $image, $count)
- {
- try {
-
- $copyTaobao = app()->make(CopyTaobaoServices::class);
-
- $storeDescriptionServices = app()->make(StoreDescriptionServices::class);
- if (is_int(strpos($image, 'http'))) {
- $d_image = $image;
- } else {
- $d_image = 'http://' . ltrim($image, '\//');
- }
- $description_cache = CacheService::getTokenBucket('desc_images_' . $id);
- if ($description_cache === null) {
- $description_cache = $description;
- CacheService::setTokenBucket('desc_images_count' . $id, 0);
- }
- $res = $copyTaobao->downloadCopyImage($d_image);
- $description_cache = str_replace($image, $res, $description_cache);
- $desc_count = CacheService::getTokenBucket('desc_images_count' . $id) + 1;
- if ($desc_count == $count) {
- CacheService::clearToken('desc_images_' . $id);
- CacheService::clearToken('desc_images_count' . $id);
- $storeDescriptionServices->saveDescription((int)$id, $description_cache);
- } else {
- CacheService::setTokenBucket('desc_images_' . $id, $description_cache);
- CacheService::setTokenBucket('desc_images_count' . $id, $desc_count);
- }
- } catch (\Throwable $e) {
- Log::error('下载商品详情图片失败,失败原因:' . $e->getMessage());
- }
- return true;
- }
-
- public function copySliderImage($id, $image, $count)
- {
- try {
-
- $copyTaobao = app()->make(CopyTaobaoServices::class);
-
- $StoreProductServices = app()->make(StoreProductServices::class);
-
- $StoreProductAttrValueServices = app()->make(StoreProductAttrValueServices::class);
-
- $res = $copyTaobao->downloadCopyImage($image);
-
- $slider_images = CacheService::getTokenBucket('slider_images_' . $id);
-
- if ($slider_images === null) $slider_images = [];
-
- array_push($slider_images, $res);
-
- if (count($slider_images) == $count) {
- CacheService::clearToken('slider_images_' . $id);
- $image = $slider_images[0];
- $slider_images = $slider_images ? json_encode($slider_images) : '';
- $StoreProductServices->update($id, ['slider_image' => $slider_images, 'image' => $image]);
- $StoreProductAttrValueServices->update(['product_id' => $id], ['image' => $image]);
- } else {
- CacheService::setTokenBucket('slider_images_' . $id, $slider_images);
- }
- } catch (\Throwable $e) {
- Log::error('下载商品轮播图片失败,失败原因:' . $e->getMessage());
- }
- return true;
- }
-
- public function copyAttrImage($id, $type = 0)
- {
- if (!$id) {
- return true;
- }
- try {
- $productAttrValue = app()->make(StoreProductAttrValueServices::class);
- $attrValueList = $productAttrValue->getColumn(['product_id' => $id, 'type' => $type], 'image', 'id');
- foreach ($attrValueList as $value_id => $value_image) {
- ProductCopyJob::dispatch('copyAttrImageDo', [$value_id, $value_image]);
- }
- } catch (\Throwable $e) {
- Log::error('下载商品轮播图片失败,失败原因:' . $e->getMessage());
- }
- return true;
- }
-
- public function copyAttrImageDo($attrId, $value_image)
- {
- if (!$attrId) {
- return true;
- }
- try {
-
- $copyTaobao = app()->make(CopyTaobaoServices::class);
-
- $StoreProductAttrValueServices = app()->make(StoreProductAttrValueServices::class);
-
- $res = $copyTaobao->downloadCopyImage($value_image);
- $StoreProductAttrValueServices->update($attrId, ['image' => $res]);
- } catch (\Throwable $e) {
- Log::error('下载商品规格图片失败,失败原因:' . $e->getMessage() . '_' . $e->getFile() . '_' . $e->getLine());
- }
- return true;
- }
- }
|