68 lines
1.7 KiB
PHP
68 lines
1.7 KiB
PHP
<?php
|
|
|
|
namespace app\common;
|
|
|
|
use think\Db;
|
|
use think\facade\Log;
|
|
use Workerman\Lib\Timer;
|
|
use think\worker\Server;
|
|
use WeChatDeviceApi\Adapters\ChuKeBao\Adapter as ChuKeBaoAdapter;
|
|
|
|
class TaskServer extends Server
|
|
{
|
|
|
|
const PROCESS_COUNT = 4;
|
|
|
|
protected $socket = 'text://0.0.0.0:2980';
|
|
|
|
protected $option = [
|
|
'count' => self::PROCESS_COUNT,
|
|
'name' => 'ckb_task_server'
|
|
];
|
|
|
|
/**
|
|
* 当客户端的连接上发生错误时触发
|
|
* @param $connection
|
|
* @param $code
|
|
* @param $msg
|
|
*/
|
|
public function onError($connection, $code, $msg)
|
|
{
|
|
Log::record("error $code $msg");
|
|
}
|
|
|
|
public function onMessage($connection, $data) {}
|
|
|
|
public function onClose($connection) {}
|
|
|
|
public function onConnect($connection) {}
|
|
|
|
public function onWorkerStart($worker)
|
|
{
|
|
|
|
$current_worker_id = $worker->id;
|
|
|
|
$process_count_for_status_0 = self::PROCESS_COUNT - 1;
|
|
|
|
$adapter = new ChuKeBaoAdapter();
|
|
|
|
// 在一个进程里处理获客任务添加后的相关逻辑
|
|
if ($current_worker_id == self::PROCESS_COUNT - 1) {
|
|
Timer::add(60, function () use($adapter) {
|
|
$adapter->handleCustomerTaskWithStatusIsCreated();
|
|
});
|
|
}
|
|
|
|
// 3个进程处理获客新任务
|
|
if ($current_worker_id < self::PROCESS_COUNT - 1) {
|
|
Timer::add(1, function () use ($current_worker_id, $process_count_for_status_0, $adapter) {
|
|
$adapter->handleCustomerTaskWithStatusIsNew($current_worker_id, $process_count_for_status_0);
|
|
});
|
|
}
|
|
|
|
// 更多其他后台任务
|
|
// ......
|
|
|
|
}
|
|
}
|