li
1b24994e74
- Contract.php: 返回合约账户余额(balance_contract) - My.php: 地址管理增加BTC/ETH - AppContract.php: 一键平仓(closeall) - AppProxy.php: 代理专属注册链接 + 分级权限(L1/L2) - site.php: 手续费减半(0.018→0.009) - agent_permission_setup.sql: 代理权限SQL - crypto_news_crawler.py: 新闻自动采集脚本
39 lines
1.1 KiB
PHP
Executable File
39 lines
1.1 KiB
PHP
Executable File
<?php
|
|
|
|
namespace app\api\controller;
|
|
|
|
use app\common\controller\Api;
|
|
use think\Db;
|
|
use think\Config;
|
|
use think\Queue;
|
|
|
|
/**
|
|
* 队列接口
|
|
*/
|
|
class Job extends Api
|
|
{
|
|
// 无需登录的接口,*表示全部
|
|
protected $noNeedLogin = ['*'];
|
|
// 无需鉴权的接口,*表示全部
|
|
protected $noNeedRight = ['*'];
|
|
|
|
public function dismiss(){
|
|
$params = "123";
|
|
/*创建新消息并推送到消息队列*/
|
|
// 当前任务由哪个类负责处理
|
|
$job_handler_classname = "app\api\job\Dismiss";
|
|
// 当前队列归属的队列名称
|
|
$job_queue_name = "dismiss_job_queue";
|
|
// 当前任务所需的业务数据
|
|
$job_data = ["ts"=>time(), "bizid"=>uniqid(), "params"=>$params];
|
|
// 将任务推送到消息队列等待对应的消费者去执行
|
|
$is_pushed = Queue::push($job_handler_classname, $job_data, $job_queue_name);
|
|
if($is_pushed == false){
|
|
$this->error("dismiss job queue went wrong");
|
|
}
|
|
//操作成功
|
|
$this->success('success');
|
|
}
|
|
|
|
}
|