c1e74d8e68
- 按 docs/renew-code-comment.md 将 PHP 文件头改为带边框的 Author 注释\n- 注释中的 crmeb.com 替换为 uj345.cn（代码字符串中的外链未改）\n- 新增 docs/renew-code-comment.md 说明 Made-with: Cursor
152 lines
4.7 KiB
PHP
152 lines
4.7 KiB
PHP
<?php
|
|
// +----------------------------------------------------------------------
|
|
// | Author: ScottPan Team
|
|
// +----------------------------------------------------------------------
|
|
|
|
namespace app\jobs;
|
|
|
|
|
|
use app\jobs\user\UserJob;
|
|
use app\services\other\queue\QueueServices;
|
|
use app\services\product\product\StoreProductServices;
|
|
use app\services\product\sku\StoreProductAttrServices;
|
|
use crmeb\basic\BaseJobs;
|
|
use crmeb\traits\QueueTrait;
|
|
use think\facade\Log;
|
|
|
|
/**
|
|
* 批量任务队列
|
|
* Class BatchHandleJob
|
|
* @package app\jobs
|
|
*/
|
|
class BatchHandleJob extends BaseJobs
|
|
{
|
|
use QueueTrait;
|
|
|
|
/**
|
|
* @return mixed
|
|
*/
|
|
public static function queueName()
|
|
{
|
|
$default = config('queue.default');
|
|
return config('queue.connections.' . $default . '.batch_queue');
|
|
}
|
|
|
|
/**
|
|
* 批量任务队列
|
|
* @param false $data
|
|
* @param $type
|
|
* @param array $other
|
|
* @return bool
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function doJob($data = false, $type = 1, array $other = [])
|
|
{
|
|
/** @var QueueServices $queueServices */
|
|
$queueServices = app()->make(QueueServices::class);
|
|
$re = true;
|
|
try {
|
|
switch ($type) {
|
|
case 1://批量发放优惠券
|
|
if (!$data) {
|
|
return true;
|
|
}
|
|
$re = $queueServices->sendCoupon($data, $type);
|
|
break;
|
|
case 2://批量设置用户分组
|
|
if (!$data) {
|
|
return true;
|
|
}
|
|
$re = $queueServices->setUserGroup($data, $type);
|
|
break;
|
|
case 3://批量设置用户标签
|
|
if (!$data) {
|
|
return true;
|
|
}
|
|
$re = $queueServices->setUserLabel($data, $type, $other);
|
|
break;
|
|
case 4://批量上下架商品
|
|
$re = $queueServices->setProductShow($data, $type);
|
|
break;
|
|
case 5://批量删除商品规格
|
|
$re = $queueServices->delProductRule($type);
|
|
break;
|
|
case 6://批量删除用户已删除订单
|
|
$re = $queueServices->delOrder($type);
|
|
break;
|
|
case 7://批量手动发货
|
|
case 8://批量电子面单发货
|
|
case 9://批量配送
|
|
case 10://批量虚拟发货
|
|
$re = $queueServices->orderDelivery($data, $other);
|
|
break;
|
|
case 11://批量回收站
|
|
$re = $queueServices->productRecycle($type);
|
|
break;
|
|
case 12://回收站批量删除
|
|
$re = $queueServices->productDeleteBatch($type);
|
|
break;
|
|
default:
|
|
$re = false;
|
|
break;
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$queueName = $queueServices->queue_type_name[$type] ?? '';
|
|
Log::error($queueName . '失败，原因' . $e->getMessage());
|
|
$re = false;
|
|
}
|
|
if ($re === false) $queueServices->delWrongQueue(0, $type, false);
|
|
|
|
//清除缓存
|
|
/** @var StoreProductServices $productService */
|
|
$productService = app()->make(StoreProductServices::class);
|
|
/** @var StoreProductAttrServices $productAttrService */
|
|
$productAttrService = app()->make(StoreProductAttrServices::class);
|
|
$productService->cacheTag()->clear();
|
|
$productAttrService->cacheTag()->clear();
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 用户批量队列
|
|
* @param $type
|
|
* @param $uids
|
|
* @param $data
|
|
* @return bool
|
|
*/
|
|
public function userBatch($type, $uids, $data)
|
|
{
|
|
if (!$type || !$uids || !$data) {
|
|
return true;
|
|
}
|
|
//拆分大数组 分批加入二级队列
|
|
$uidsArr = array_chunk($uids, 100);
|
|
foreach ($uidsArr as $ids) {
|
|
//加入分批队列
|
|
self::dispatchDo('chunkUserBatch', [$type, $ids, $data]);
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 拆分分批队列
|
|
* @param $type
|
|
* @param $uids
|
|
* @param $data
|
|
* @return bool
|
|
*/
|
|
public function chunkUserBatch($type, $uids, $data)
|
|
{
|
|
if (!$type || !$uids || !$data) {
|
|
return true;
|
|
}
|
|
foreach ($uids as $id) {
|
|
UserJob::dispatchDo('runUserBatch', [$type, $id, $data]);
|
|
}
|
|
return true;
|
|
}
|
|
}
|