diff --git a/web/ws_task_real_ty.php b/web/ws_task_real_ty.php index a2d8fa0..5cf6861 100644 --- a/web/ws_task_real_ty.php +++ b/web/ws_task_real_ty.php @@ -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)); }