|
|
|
@ -27,25 +27,25 @@ $worker->onWorkerStart = function($worker) use($config) { |
|
|
|
$data = []; |
|
|
|
# 主动推送对应页面数据 |
|
|
|
|
|
|
|
$groupIdArr = []; |
|
|
|
$groupRes = $dm->select('bt_passenger_monitor_group',['type' => 1]); |
|
|
|
foreach ($groupRes as $groupRow) $groupIdArr[] = $groupRow['groupId']; |
|
|
|
$groupIdStr = !empty($groupIdArr) ? implode("|",$groupIdArr) : ''; |
|
|
|
// $groupIdArr = []; |
|
|
|
// $groupRes = $dm->select('bt_passenger_monitor_group',['type' => 1]); |
|
|
|
// foreach ($groupRes as $groupRow) $groupIdArr[] = $groupRow['groupId']; |
|
|
|
// $groupIdStr = !empty($groupIdArr) ? implode("|",$groupIdArr) : ''; |
|
|
|
|
|
|
|
# 累计服务人数 |
|
|
|
$data['allGroupNum'] = ['data' => PassFlow::allGroupNum($dm,['groupsId' => $groupIdStr])]; |
|
|
|
$data['allGroupNum'] = ['data' => PassFlow::allGroupNum($dm,['type' => 1])]; |
|
|
|
|
|
|
|
# 24小时 |
|
|
|
$data['getPassHoursData'] = ['data' => PassFlow::getPassHoursData($dm,['groupsId' => $groupIdStr])]; |
|
|
|
$data['getPassHoursData'] = ['data' => PassFlow::getPassHoursData($dm,['type' => 1])]; |
|
|
|
|
|
|
|
# 24小时进馆人数 |
|
|
|
$data['realTimeData'] = ['data' => PassFlow::realTimeData($dm)]; |
|
|
|
|
|
|
|
# 各场馆服务人次占比 |
|
|
|
$data['allGroupTimeNum'] = ['data' => PassFlow::allGroupTimeNum(['groupsId' => $groupIdStr,'granularity' => 'daily'],$dm)]; |
|
|
|
$data['allGroupTimeNum'] = ['data' => PassFlow::allGroupTimeNum(['type' => 1,'granularity' => 'daily'],$dm)]; |
|
|
|
|
|
|
|
# 各场馆服务人次趋势 |
|
|
|
$data['toDayGroupsEnterNum'] = ['data' => PassFlow::toDayGroupsEnterNum($dm,['groupsId' => $groupIdStr])]; |
|
|
|
$data['toDayGroupsEnterNum'] = ['data' => PassFlow::toDayGroupsEnterNum($dm,['type' => 1])]; |
|
|
|
|
|
|
|
$connection->send(json_encode($data)); |
|
|
|
} |
|
|
|
|