UplaodImageJob.php 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. <?php
  2. /**
  3. * 重庆赤晓店信息科技有限公司
  4. * https://www.chixiaodian.com
  5. * Copyright (c) 2023 赤店商城 All rights reserved.
  6. */
  7. namespace app\jobs;
  8. use app\models\Option;
  9. use app\models\StoreImageSearchSetting;
  10. use app\models\UploadGoodsImage;
  11. use app\utils\TiiaHelper;
  12. use yii\base\BaseObject;
  13. use yii\queue\JobInterface;
  14. /**
  15. * 以图搜图
  16. */
  17. class UplaodImageJob extends BaseObject implements JobInterface
  18. {
  19. public $store_id;
  20. public $id;
  21. public $cover_pic;
  22. public $name;
  23. public function execute($queue)
  24. {
  25. // 获取对应商城的信息
  26. $storeSetting = StoreImageSearchSetting::findOne(['store_id'=>$this->store_id]);
  27. $tiia = new TiiaHelper();
  28. // 查询图库是否存在 返回code==0的时候标识图库已存在
  29. $uploadRes = $tiia::createImage($storeSetting->group_id,$this->id,$this->id.'-'.$this->name,$this->cover_pic);
  30. debug_log(json_encode($uploadRes,JSON_UNESCAPED_UNICODE) );
  31. if($uploadRes['code'] == 0){
  32. // 标记为已上传状态
  33. UploadGoodsImage::updateAll(['status'=>1,'updated_at'=>time()],['store_id'=>$this->store_id,'goods_id'=>$this->id,'is_delete'=>0]);
  34. $storeSetting->image_num = $storeSetting->image_num + 1;
  35. $storeSetting->save();
  36. }else{
  37. // 上传失败删除记录 方便后期同步上传
  38. UploadGoodsImage::updateAll(['status' => 2,'updated_at'=>time()],['store_id'=>$this->store_id,'goods_id'=>$this->id,'is_delete'=>0]);
  39. }
  40. }
  41. }