webman/push推送失敗,websocket連接成功但是無法推送消息,提示調(diào)用trigger方法時返回false
這是改裝后的方法
function sendSocketMessage($channels, $content, string $form = 'system')
{
try {
// 發(fā)送進入保留狀態(tài)消息
$api = new Api(
'http://127.0.0.1:3232',
config('plugin.webman.push.app.app_key'),
config('plugin.webman.push.app.app_secret')
);
$a = $api->trigger($channels, 'message', [
'from_uid' => $form,
'content' => json_encode($content)
]);
dump($a);
return $a;
} catch (Exception $e) {
dump("推送失敗" . $e->getMessage());
Log::error('sendSocketMessage', [$e->getMessage()]);
return false;
}
}
這是調(diào)用
```php
function reviewedRechargeMessage()
{
$subQuery = PlayerRechargeRecord::query()
->select(DB::raw('MAX(id) as id'))
->where('status', PlayerRechargeRecord::STATUS_RECHARGING)
->whereIn('type', [PlayerRechargeRecord::TYPE_REGULAR, PlayerRechargeRecord::TYPE_ACTIVITY, PlayerRechargeRecord::TYPE_ARTIFICIAL])
->groupBy('department_id');
/** @var PlayerRechargeRecord $playerRechargeRecord */
$playerRechargeRecordList = PlayerRechargeRecord::query()
->whereIn('id', $subQuery)
->get();
if (!empty($playerRechargeRecordList)) {
/** @var PlayerRechargeRecord $item */
foreach ($playerRechargeRecordList as $item) {
var_dump('private-admin_group-channel-' . $item->department_id);
sendSocketMessage('private-admin_group-channel-' . $item->department_id, [
'msg_type' => 'player_examine_recharge_order',
'id' => $item->id,
'player_id' => $item->player_id,
'player_name' => $item->player_name,
'player_phone' => $item->player_phone,
'money' => $item->money,
'status' => $item->status,
'tradeno' => $item->tradeno,
]);
}
}
}
#### 截圖報錯信息里報錯文件相關(guān)代碼

#### 操作系統(tǒng)及workerman/webman等框架組件具體版本
本地測試環(huán)境
WS_URL=ws://127.0.0.1:39494