Karlcarlo
c7f85ffbda
- 引入 alibabacloud/dysmsapi-20170525 依赖，集成阿里云短信服务 - 将短信验证码从6位改为4位，优化用户体验 - 添加聚水潭商品按时间范围同步功能，支持分页拉取 - 增强Cron任务异常处理，添加错误日志记录 - 修复系统附件服务中图片路径处理逻辑 - 更新阿里云SDK相关组件至最新版本 - 添加think-trace调试扩展，便于问题排查 - 优化跨域中间件，使用str_contains替代strpos
144 lines
3.3 KiB
PHP
144 lines
3.3 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2026 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
|
||
|
||
namespace crmeb\utils;
|
||
|
||
use think\swoole\Manager;
|
||
use Swoole\Timer;
|
||
use think\facade\Log;
|
||
|
||
/**
|
||
* Cron定时执行
|
||
* Class Cron
|
||
* @package crmeb\utils
|
||
*/
|
||
class Cron
|
||
{
|
||
/**
|
||
* @var Manager
|
||
*/
|
||
protected $manager;
|
||
|
||
/**
|
||
* @var int
|
||
*/
|
||
protected $workerId = 0;
|
||
|
||
/**
|
||
* @var
|
||
*/
|
||
protected $timer;
|
||
|
||
/**
|
||
* @var bool
|
||
*/
|
||
protected $debug = false;
|
||
|
||
/**
|
||
* Cron constructor.
|
||
* @param Manager $manager
|
||
*/
|
||
public function __construct(Manager $manager)
|
||
{
|
||
$this->manager = $manager;
|
||
$this->debug = env('APP_DEBUG', false);
|
||
$this->workerId = $this->manager->getWorkerId();
|
||
|
||
}
|
||
|
||
/**
|
||
* @param int $workerId
|
||
* @return Cron
|
||
*/
|
||
public function setWorkerId(int $workerId)
|
||
{
|
||
$this->workerId = $workerId;
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 沙盒运行
|
||
* @param callable $callable
|
||
*/
|
||
protected function runInSandbox(callable $callable)
|
||
{
|
||
try {
|
||
$callable();
|
||
} catch (\Throwable $e) {
|
||
Log::error('cron.sandbox.error ' . json_encode([
|
||
'message' => $e->getMessage(),
|
||
'file' => $e->getFile(),
|
||
'line' => $e->getLine(),
|
||
], JSON_UNESCAPED_UNICODE));
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 添加启动定时任务
|
||
* @param int $ms
|
||
* @param callable $callable
|
||
* @return mixed
|
||
*/
|
||
public function tick(int $ms, callable $callable)
|
||
{
|
||
if ($this->workerId === $this->manager->getWorkerId()) {
|
||
return Timer::tick($ms, fn() => $this->runInSandbox($callable));
|
||
} else {
|
||
return null;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 每天的某时某分运行一次
|
||
* minuteTick('12:15',fun()) 例如: 12:15 会在当天的中午12点15分钟运行一次
|
||
* @param string $time
|
||
* @param callable $callable
|
||
* @return mixed|null
|
||
*/
|
||
public function minuteTick(string $time, callable $callable)
|
||
{
|
||
return $this->tick(1000 * 60, function () use ($callable, $time) {
|
||
$nowTime = date('H:i');
|
||
if ($nowTime === $time) {
|
||
$callable();
|
||
}
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 一次执行
|
||
* @param int $ms
|
||
* @param callable $callable
|
||
*/
|
||
public function after(int $ms, callable $callable)
|
||
{
|
||
Timer::after($ms, fn() => $this->runInSandbox($callable));
|
||
}
|
||
|
||
/**
|
||
* 清除定时任务
|
||
* @param int $timer
|
||
*/
|
||
public function clear(int $timer)
|
||
{
|
||
Timer::clear($timer);
|
||
}
|
||
|
||
/**
|
||
* 清除所有定时任务
|
||
*/
|
||
public function clearAll()
|
||
{
|
||
Timer::clearAll();
|
||
}
|
||
}
|