You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
747 lines
30 KiB
747 lines
30 KiB
<?php
|
|
|
|
namespace app\common\logic;
|
|
|
|
use app\common\dm\Dm;
|
|
|
|
class PassFlow
|
|
{
|
|
/**
|
|
* 分时时间段接口 <首页-客流趋势>
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function allGroupTimeNum($param, $dm = null)
|
|
{
|
|
|
|
$granularity = $param['granularity'];
|
|
$groupsId = $param['groupsId'];
|
|
|
|
if (empty($granularity)) return ['code' => 0, 'msg' => '缺少参数：granularity'];
|
|
$where = '';
|
|
if (!empty($groupsId)) {
|
|
$garr = explode("|", $groupsId);
|
|
$where .= ' "groupId" in(' . "'" . implode("','", $garr) . "')";
|
|
|
|
}
|
|
|
|
$allTimeData = [];
|
|
$groupsData = [];
|
|
$dkeys = [];
|
|
if (empty($dm)) $dm = new Dm();
|
|
if ($granularity == 'daily') {
|
|
$date = self::getDateData('day');
|
|
$start_time = $date['day']['start_time'];
|
|
$end_time = $date['day']['end_time'];
|
|
$where .= $where ? ' and "granularity" = ' . "'hourly'" : ' "granularity" = ' . "'hourly'";
|
|
$where .= ' and "statTime" >= ' . "'{$start_time}'" . ' and "statTime" <= ' . "'{$end_time}'";
|
|
$list = $dm->select('bt_passenger_flow', $where);
|
|
$data = self::handleGroupData($list,'H:00',$dm,$groupsId);
|
|
$allTimeData = $data['allTimeData'];
|
|
$groupsData = $data['groupsData'];
|
|
$dkeys = $data['dkeys'];
|
|
} elseif ($granularity == 'monthly') {
|
|
$date = self::getDateData('month');
|
|
$start_time = $date['month']['start_time'];
|
|
$end_time = $date['month']['end_time'];
|
|
$where .= $where ? ' and "granularity" = ' . "'daily'" : ' "granularity" = ' . "'daily'";
|
|
$where .= ' and "statTime" >= ' . "'{$start_time}'" . ' and "statTime" <= ' . "'{$end_time}'";
|
|
$list = $dm->select('bt_passenger_flow', $where);
|
|
$data = self::handleGroupData($list, 'd',$dm,$groupsId);
|
|
$allTimeData = $data['allTimeData'];
|
|
$groupsData = $data['groupsData'];
|
|
$dkeys = $data['dkeys'];
|
|
} elseif ($granularity == 'yearly') {
|
|
$date = self::getDateData('year');
|
|
$start_time = $date['year']['start_time'];
|
|
$end_time = $date['year']['end_time'];
|
|
$where .= $where ? ' and "granularity" = ' . "'monthly'" : ' "granularity" = ' . "'monthly'";
|
|
$where .= ' and "statTime" >= ' . "'{$start_time}'" . ' and "statTime" <= ' . "'{$end_time}'";
|
|
$list = $dm->select('bt_passenger_flow', $where);
|
|
$data = self::handleGroupData($list, 'm',$dm,$groupsId);
|
|
$allTimeData = $data['allTimeData'];
|
|
$groupsData = $data['groupsData'];
|
|
$dkeys = $data['dkeys'];
|
|
}
|
|
|
|
$data = ['allTimeData' => $allTimeData, 'groupsData' => $groupsData, 'dkeys' => $dkeys];
|
|
return ['code' => 1, 'msg' => 'success', 'data' => $data];
|
|
}
|
|
|
|
/**
|
|
* 获取统计开始时间 统计结束时间
|
|
* @param $date
|
|
* @return array
|
|
*/
|
|
protected static function getDateData($date = 'all')
|
|
{
|
|
$data = [];
|
|
if ($date == 'day' || $date == 'all') {
|
|
$data['day'] = [
|
|
'start_time' => date("Y-m-d") . 'T00:00:00.000+08:00',
|
|
'end_time' => date("Y-m-d") . 'T23:59:59.000+08:00'
|
|
];
|
|
}
|
|
if ($date == 'week' || $date == 'all') {
|
|
$data['week'] = [
|
|
'start_time' => date("Y-m-d",strtotime("this week")) . 'T00:00:00.000+08:00',
|
|
'end_time' => date("Y-m-d",strtotime("-".(date("w") - 7) . "day")) . 'T23:59:59.000+08:00'
|
|
];
|
|
}
|
|
if ($date == 'month' || $date == 'all') {
|
|
$data['month'] = [
|
|
'start_time' => date("Y-m-01") . 'T00:00:00.000+08:00',
|
|
'end_time' => date("Y-m-d", strtotime('-1 day', strtotime(date('Y-m-01', strtotime('+1 month'))))) . 'T23:59:59.000+08:00'
|
|
];
|
|
}
|
|
if ($date == 'year' || $date == 'all') {
|
|
$data['year'] = [
|
|
'start_time' => date("Y-01-01") . 'T00:00:00.000+08:00',
|
|
'end_time' => date("Y-m-d", strtotime('-1 day', strtotime(date('Y-01-01', strtotime('+1 year'))))) . 'T23:59:59.000+08:00'
|
|
];
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 特殊处理
|
|
* @param $list
|
|
* @param $date_str
|
|
* @return array
|
|
*/
|
|
protected static function handleGroupData($list,$date_str = 'H:00',$dm = null,$groupsId = '') {
|
|
$allTimeData = [];
|
|
$groupsData = [];
|
|
$dkey=[];
|
|
if ($date_str == 'H:00') {
|
|
$hour = (int) date('H');
|
|
for ($i = 0; $i <= $hour; $i++) {
|
|
$str = strlen($i) == 1 ? '0'.$i.':00' : $i.':00';
|
|
$allTimeData[$str]['num'] = 0;
|
|
$allTimeData[$str]['title'] = $str;
|
|
$dkey[]=$str;
|
|
}
|
|
} elseif ($date_str == 'd') {
|
|
$d = date('d') * 1;
|
|
$date = $d - 12 > 0 ? $d - 12 : 1;
|
|
for ($i = $date; $i <= $d; $i++) {
|
|
$str = strlen($i) == 1 ? '0'.$i : $i;
|
|
$allTimeData[$str]['num'] = 0;
|
|
$allTimeData[$str]['title'] = $str;
|
|
$dkey[]=$str;
|
|
}
|
|
} elseif ($date_str == 'm') {
|
|
$m = date('m') * 1;
|
|
$date = $m - 12 > 0 ? $m - 12 : 1;
|
|
for ($i = $date; $i <= $m; $i++) {
|
|
$str = strlen($i) == 1 ? '0'.$i : $i;
|
|
$allTimeData[$str]['num'] = 0;
|
|
$allTimeData[$str]['title'] = $str;
|
|
$dkey[]=$str;
|
|
}
|
|
}
|
|
# 体育 + 博物馆客流柱状图数据
|
|
$sumNoRepeatInNum = 0;
|
|
$groupsIdArr = [];
|
|
foreach ($list as $value) {
|
|
$groupsIdArr[] = $value['groupId'];
|
|
$sumNoRepeatInNum += $value['flowInNum']; // 进馆总人数
|
|
if (!isset($groupsData[$value['groupName']]['noRepeatInNum'])) $groupsData[$value['groupName']]['noRepeatInNum'] = 0;
|
|
$groupsData[$value['groupName']]['noRepeatInNum'] += $value['flowInNum']; // 分租进馆人数
|
|
$date = date($date_str,strtotime($value['statTime'])); // 各时间端进馆人数
|
|
if (!isset($allTimeData[$date])) continue;
|
|
$allTimeData[$date]['num'] += $value['flowInNum'];
|
|
}
|
|
ksort($allTimeData);
|
|
|
|
$groupsIdParamArr = [];
|
|
# 总览-合并文化数据
|
|
if (empty($groupsId)) {
|
|
$res = $dm->select('bt_library',['group_id' => ['baz001','BAF055']]);
|
|
foreach ($res as $row) {
|
|
if (!isset($groupsData[$row['group_name']]['noRepeatInNum'])) $groupsData[$row['group_name']]['noRepeatInNum'] = 0;
|
|
if ($date_str == 'H:00') {
|
|
$sumNoRepeatInNum += $row['today_incount'];
|
|
$groupsData[$row['group_name']]['noRepeatInNum'] = $row['today_incount']?:0;
|
|
} elseif ($date_str == 'd') {
|
|
$sumNoRepeatInNum += $row['month_incount'];
|
|
$groupsData[$row['group_name']]['noRepeatInNum'] = $row['month_incount']?:0;
|
|
} elseif ($date_str == 'm') {
|
|
$sumNoRepeatInNum += $row['year_incount'];
|
|
$groupsData[$row['group_name']]['noRepeatInNum'] = $row['year_incount']?:0;
|
|
}
|
|
}
|
|
$whgData = [];
|
|
if ($date_str == 'H:00') {
|
|
$whgData = $dm->select('bt_library_hours',['create_time' => ['>=',date("Y-m-d 00:00:00")],'group_id' => 'lib001']);
|
|
} elseif ($date_str == 'd') {
|
|
$whgData = $dm->select('bt_library_data',['create_time' => ['>=',date("Y-m-01 00:00:00")],'group_id' => 'lib001','date' => 'day']);
|
|
} elseif ($date_str == 'm') {
|
|
$whgData = $dm->select('bt_library_data',['create_time' => ['>=',date("Y-01-01 00:00:00")],'group_id' => 'lib001','date' => 'month']);
|
|
}
|
|
# 文化馆客流柱状图数据
|
|
foreach ($whgData as $whgRow) {
|
|
$date = date($date_str,strtotime($whgRow['create_time'])); // 各时间端进馆人数
|
|
if (!isset($allTimeData[$date])) continue;
|
|
$allTimeData[$date]['num'] += $whgRow['incount'];
|
|
}
|
|
} else {
|
|
$groupsIdParamArr = explode("|",$groupsId);
|
|
}
|
|
// ------------------ 组数据不存在赋值为0 ------------------ //
|
|
# 去重存在的统计组id
|
|
$groupsIdArr = array_unique($groupsIdArr);
|
|
# type 1-体育 2-文化
|
|
$type = [1,2];
|
|
if ($groupsIdParamArr) {
|
|
$type = [1];
|
|
# 和传值参数 分组取相同值
|
|
$groupsIdArr = array_intersect($groupsIdArr,$groupsIdParamArr);
|
|
}
|
|
# 如果为空
|
|
$groupsIdArr = $groupsIdArr ?: [0];
|
|
# 查询分组中没有数据的统计组
|
|
$groupWhere = ' "groupId" not in (' . "'" . implode("','",$groupsIdArr) ."')";
|
|
$groupWhere .= ' and "type" in (' ."'" . implode("','",$type) . "')";
|
|
$groupRes = $dm->select("bt_passenger_monitor_group",$groupWhere);
|
|
foreach ($groupRes as $groupRow) {
|
|
$groupsData[$groupRow['groupName']]['noRepeatInNum'] = 0;
|
|
}
|
|
// ------------------ 组数据不存在赋值 ------------------ //
|
|
// 计算各组占比
|
|
foreach ($groupsData as &$val) {
|
|
$val['proportion'] = $val['noRepeatInNum'] > 0 ? (round($val['noRepeatInNum']/$sumNoRepeatInNum,4) * 100) ."%" : '0%';
|
|
}
|
|
|
|
$groupData = [];
|
|
foreach ($groupsData as $groupName => $groupValue) {
|
|
$groupData[] = [
|
|
'groupName' => $groupName,
|
|
'noRepeatInNum' => $groupValue['noRepeatInNum'],
|
|
'proportion' => $groupValue['proportion']
|
|
];
|
|
}
|
|
|
|
return [
|
|
'allTimeData' => $allTimeData, // 总客流趋势时间段
|
|
'groupsData' => $groupData, // 各组总数及占比
|
|
'dkeys' =>$dkey
|
|
];
|
|
}
|
|
|
|
/**
|
|
* 总览总数据接口 <首页-中间部分总览>
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function allGroupNum($dm = null,$param = []) {
|
|
|
|
$dateArr = ['day' => 'daily', 'week' => 'daily', 'month' => 'monthly', 'year' => 'yearly'];
|
|
|
|
$returnData = [];
|
|
$y = date("Y");
|
|
if (empty($dm)) $dm = new Dm();
|
|
$paramWhere = '';
|
|
if (!empty($param)) {
|
|
if (!empty($param['groupsId'])) {
|
|
$groupsId = explode("|",$param['groupsId']);
|
|
$paramWhere .= ' and "groupId" in (' . "'" . implode("','",$groupsId) . "')";
|
|
}
|
|
}
|
|
# 日 周 月 年
|
|
$dateData = self::getDateData();
|
|
foreach ($dateArr as $date => $granularity) {
|
|
$where = ' "granularity" = ' . "'{$granularity}'" . ' and "date" = ' . "'{$date}' {$paramWhere}";
|
|
$where .= ' and "statTime" >= ' . "'{$dateData[$date]['start_time']}'" . ' and "statTime" <= ' . "'{$dateData[$date]['end_time']}'";
|
|
$list = $dm->select(
|
|
'bt_passenger_flow_all',
|
|
$where
|
|
);
|
|
|
|
$returnData[$date]['noRepeatInNum'] = 0;
|
|
foreach ($list as $value) {
|
|
if ($date == 'year') {
|
|
$yDate = date('Y',ceil($value['createTime'] / 1000)); // 各今年端进馆人数
|
|
if ($y == $yDate) $returnData[$date]['noRepeatInNum'] += $value['flowInNum'];
|
|
} else {
|
|
$returnData[$date]['noRepeatInNum'] += $value['flowInNum'];
|
|
}
|
|
}
|
|
}
|
|
|
|
#累计进馆人数
|
|
$sumWhere = ' "granularity" = ' . "'yearly'" . ' and "date" = ' . "'year' {$paramWhere}";
|
|
$sumFind = $dm->find('bt_passenger_flow_all', $sumWhere,'SUM("flowInNum") as NUM');
|
|
$returnData['sumYear']['noRepeatInNum'] = isset($sumFind['NUM']) ? $sumFind['NUM'] : 0;
|
|
|
|
if (empty($groupsId)) {
|
|
# 文化数据
|
|
$mData = $dm->find('bt_library',['group_id' => 'lib001']);
|
|
$returnData['day']['noRepeatInNum'] += isset($mData['today_incount']) ? $mData['today_incount'] : 0;
|
|
$returnData['month']['noRepeatInNum'] += isset($mData['month_incount']) ? $mData['month_incount'] : 0;
|
|
$returnData['year']['noRepeatInNum'] += isset($mData['year_incount']) ? $mData['year_incount'] : 0;
|
|
$returnData['sumYear']['noRepeatInNum'] += isset($mData['year_incount']) ? $mData['year_incount'] : 0;
|
|
$week_start = date("Y-m-d 00:00:00",strtotime('this week'));
|
|
$week_end = date("Y-m-d 23:59:59",strtotime("-".(date("w") - 7) . "day"));
|
|
$weekDateWhere = ' "group_id" =' . "'lib001'" . ' and "create_time" >= ' . "'{$week_start}'" . ' and "create_time" <= ' . "'{$week_end}'";
|
|
$weekDate = $dm->find('bt_library_hours',$weekDateWhere,'SUM("incount") as NUM');
|
|
$returnData['week']['noRepeatInNum'] += isset($weekDate['NUM']) ? $weekDate['NUM'] : 0;
|
|
}
|
|
foreach ($returnData as &$val) {
|
|
$val['noRepeatInNum'] = formatNumber($val['noRepeatInNum']);
|
|
}
|
|
|
|
return $returnData;
|
|
}
|
|
|
|
/**
|
|
* 查询最新客流统计组实时数据 <各场管实施实时进馆人数>
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function realTimeData($dm = null)
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
|
|
$list = $dm->select('bt_passenger_flow_real');
|
|
$data = [];
|
|
|
|
$configRes = $dm->find("bt_config",' "key" = ' . "'threshold'");
|
|
$threshold = $configRes['value'] ?: 0;
|
|
|
|
foreach ($list as $value) {
|
|
if (!isset($data[$value['groupId']]['allEnter'])) $data[$value['groupId']]['allEnter'] = 0;
|
|
$data[$value['groupId']]['allEnter'] += $value['allEnter'];
|
|
}
|
|
|
|
$returnData = [];
|
|
foreach ($data as $groupId => $val) {
|
|
$proportion = $val['allEnter'] > 0 ? round($val['allEnter']/$threshold,4) : 0;
|
|
$val['proportion'] = ($proportion * 100) . "%";
|
|
$val['congestion'] = self::getPassType($proportion);
|
|
$val['groupId'] = $groupId;
|
|
|
|
$getGroup = $dm->find('bt_passenger_monitor_group',' "groupId" = ' . "'{$groupId}'");
|
|
$val['groupName'] = $getGroup['groupName'] ?: '';
|
|
$val['sort']=intval($getGroup['sort']);
|
|
$returnData[] = $val;
|
|
}
|
|
$libData = $dm->select('bt_library',['group_id' => ['baz001','BAF055']]);
|
|
foreach ($libData as $libRow) {
|
|
$libProportion = $libRow['today_incount'] > 0 ? round($libRow['today_incount']/$threshold,4) : 0;
|
|
// 文化馆排 4# 图书馆 2#
|
|
$isort = $libRow['group_id']=='baz001'?2:4;
|
|
$returnData[] = [
|
|
'allEnter' => $libRow['today_incount'] ?: 0,
|
|
'proportion' => ($libProportion * 100) . "%",
|
|
'congestion' => self::getPassType($libProportion),
|
|
'groupId' => $libRow['group_id'],
|
|
'groupName' => $libRow['group_name'],
|
|
'sort' => $isort,
|
|
];
|
|
}
|
|
// 排序
|
|
$tmparr =[];
|
|
foreach($returnData as $k=>$rv){
|
|
$tmparr[$k]=$rv['sort'];
|
|
}
|
|
array_multisort($tmparr,SORT_ASC,$returnData);
|
|
|
|
return $returnData;
|
|
}
|
|
|
|
protected static function getPassType($proportion)
|
|
{
|
|
# 舒适：阈值＜80%
|
|
if ($proportion < 0.8) {
|
|
return '舒适';
|
|
}
|
|
# 饱和：80%＜阈值＜100%
|
|
if (0.8 < $proportion || $proportion < 1) {
|
|
return '饱和';
|
|
}
|
|
# 拥挤：阈值=100%
|
|
if ($proportion == 1) {
|
|
return '拥挤';
|
|
}
|
|
# 拥挤：阈值=100%
|
|
if ($proportion >= 1.2) {
|
|
return '爆满';
|
|
}
|
|
return '';
|
|
}
|
|
|
|
/**
|
|
* 今日各场馆人数趋势
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function toDayGroupsEnterNum($dm = null,$param = [])
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
|
|
$where = ' "granularity"='."'hourly' ";
|
|
$groupsWhere = null;
|
|
if (!empty($param)) {
|
|
if (!empty($param['groupsId'])) {
|
|
$groupsId = explode("|",$param['groupsId']);
|
|
$groupsWhere = ['groupId' => $groupsId];
|
|
$where .= ' and "groupId" in (' . "'" . implode("','",$groupsId) . "')";
|
|
}
|
|
}
|
|
$date = self::getDateData('day');
|
|
$start_time = $date['day']['start_time'];
|
|
$end_time = $date['day']['end_time'];
|
|
$where .= ' and "statTime" >= ' . "'{$start_time}'" . ' and "statTime" <= ' . "'{$end_time}'";
|
|
$list = $dm->select('bt_passenger_flow',$where);
|
|
$allTimeData = [];
|
|
for ($i = 0; $i <= 23; $i++) {
|
|
$str = strlen($i) == 1 ? '0'.$i.':00' : $i.':00';
|
|
$allTimeData[$str] = 0;
|
|
}
|
|
$returnData = [];
|
|
|
|
# 获取各组初始数值
|
|
$groupData = $dm->select('bt_passenger_monitor_group',$groupsWhere);
|
|
foreach ($groupData as $groupDataRow) {
|
|
foreach ($allTimeData as $date => $dateValue) {
|
|
$returnData[$groupDataRow['groupId']][$date] = $dateValue;
|
|
}
|
|
}
|
|
|
|
foreach ($list as $value) {
|
|
$date = date('H:00',ceil($value['createTime'] / 1000)); // 各时间端进馆人数
|
|
if (!isset($allTimeData[$date])) continue;
|
|
if (!isset($returnData[$value['groupId']][$allTimeData[$date]])) $returnData[$value['groupId']][$date] = 0;
|
|
$returnData[$value['groupId']][$date] += $value['flowInNum'];
|
|
}
|
|
|
|
$data = [];
|
|
foreach ($returnData as $groupName => $item) {
|
|
$listData = [];
|
|
foreach ($item as $itemKey => $itemRow) {
|
|
/*$listData[] = [
|
|
'time' => $itemKey,
|
|
'count' => $itemRow
|
|
];*/
|
|
$listData['dkeys'][] = $itemKey;
|
|
$listData['dvalue'][] = $itemRow;
|
|
}
|
|
if (is_numeric($groupName)) {
|
|
$groupData = $dm->find('bt_passenger_monitor_group',['groupId' => $groupName]);
|
|
$groupName = isset($groupData['groupName']) ? $groupData['groupName'] : $groupName;
|
|
}
|
|
$data[] = [
|
|
'groupName' => $groupName,
|
|
'list' => $listData
|
|
];
|
|
}
|
|
if(empty($param['groupsId'])){
|
|
$data = self::getLibraryGroupHoursList($dm,false,$data);
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 文化-博物-图书-数据接口 总计服务人数
|
|
* @return array
|
|
* 返回数据：today.incount=今天进 month.incount=本月进 year.incount=今年进 day30.incount=近30天近 outcount=出
|
|
* 不传参数就是所有摄像头，传cameraid就是按传的摄像头ID
|
|
* cameraid = 宝安图书馆9,7,6,4,2,1,67,3 1990分馆134、 135
|
|
*/
|
|
public static function allFlowTrends($dm = null)
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
# 累计进馆人数
|
|
$sum_all_incount = 0;
|
|
# 宝安图书馆数据
|
|
$ts_res = $dm->find('bt_library',['group_id' => 'baz001']);
|
|
$ts_today_incount = isset($ts_res['today_incount']) ? $ts_res['today_incount'] : 0;
|
|
$ts_month_incount = isset($ts_res['month_incount']) ? $ts_res['month_incount'] : 0;
|
|
$ts_year_incount = isset($ts_res['year_incount']) ? $ts_res['year_incount'] : 0;
|
|
|
|
# 劳务博物馆数据
|
|
$dateArr = ['day' => 'daily', 'month' => 'monthly', 'year' => 'yearly'];
|
|
$dateData = self::getDateData();
|
|
$bw_data = [];
|
|
foreach ($dateArr as $date => $granularity) {
|
|
|
|
$museumWhere = ' "groupId"='."'510'".' and "granularity" = ' . "'{$granularity}'" ;
|
|
$museumWhere .= ' and "statTime" >= ' . "'{$dateData[$date]['start_time']}'" . ' and "statTime" <= ' . "'{$dateData[$date]['end_time']}'";
|
|
$museumRes = $dm->find('bt_passenger_flow',$museumWhere,' SUM("flowInNum") as NUM');
|
|
$bw_data[$date] = $museumRes['NUM'] ?: 0;
|
|
}
|
|
$bw_today_incount = isset($bw_data['day']) ? $bw_data['day'] : 0;
|
|
$bw_month_incount = isset($bw_data['month']) ? $bw_data['month'] : 0;
|
|
$bw_year_incount = isset($bw_data['year']) ? $bw_data['year'] : 0;
|
|
|
|
# 文化馆数据
|
|
$wh_res = $dm->find('bt_library',['group_id' => 'BAF055']);
|
|
$wh_today_incount = isset($wh_res['today_incount']) ? $wh_res['today_incount'] : 0;
|
|
$wh_month_incount = isset($wh_res['month_incount']) ? $wh_res['month_incount'] : 0;
|
|
$wh_year_incount = isset($wh_res['year_incount']) ? $wh_res['year_incount'] : 0;
|
|
|
|
# 总年、月、日总数
|
|
$sum_today_incount = $ts_today_incount + $bw_today_incount + $wh_today_incount;
|
|
$sum_month_incount = $ts_month_incount + $bw_month_incount + $wh_month_incount;
|
|
$sum_year_incount = $ts_year_incount + $bw_year_incount + $wh_year_incount;
|
|
|
|
# 累计进馆人数 - 博物馆
|
|
$sumAllWhere = ' "granularity" = ' . "'yearly'" . ' and "date" = ' . "'year' " . ' and "groupId"='."'510'";
|
|
$sumAllFind = $dm->find('bt_passenger_flow_all', $sumAllWhere,'SUM("flowInNum") as NUM');
|
|
$sum_all_incount += isset($sumAllFind['NUM']) ? $sumAllFind['NUM'] : 0;
|
|
# 累计进馆人数 - 文化、图书
|
|
$libData = $dm->find('bt_library_data',['group_id' => 'lib001','date' => 'year'],' SUM("incount") as SUM');
|
|
$sum_all_incount += $libData ? $libData['SUM'] : 0;
|
|
|
|
$data = [
|
|
'month' => [
|
|
'incount' => $sum_month_incount
|
|
],
|
|
'today' => [
|
|
'incount' => $sum_today_incount
|
|
],
|
|
'year' => [
|
|
'incount' => $sum_year_incount
|
|
],
|
|
'sum_year' => [
|
|
'incount' => $sum_all_incount
|
|
],
|
|
'hour24' => [
|
|
[
|
|
'groupName' => '图书馆',
|
|
'incount' => $ts_today_incount
|
|
],
|
|
[
|
|
'groupName' => '博物馆',
|
|
'incount' => $bw_today_incount
|
|
],
|
|
[
|
|
'groupName' => '文化馆',
|
|
'incount' => $wh_today_incount
|
|
],
|
|
]
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
/**
|
|
* 体育 24小时各场馆数据 柱状图
|
|
* @return array
|
|
*/
|
|
public static function getPassHoursData($dm = null,$param = [])
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
|
|
$where = ' "granularity"='."'hourly' ";
|
|
if (!empty($param)) {
|
|
if (!empty($param['groupsId'])) {
|
|
$groupsId = explode("|",$param['groupsId']);
|
|
$where .= ' and "groupId" in (' . "'" . implode("','",$groupsId) . "')";
|
|
}
|
|
}
|
|
|
|
#$date = self::getDateData('day');
|
|
$start_time = date("Y-m-d\TH",strtotime('-23 hours')) . ':00:00.000+08:00';
|
|
$end_time = date("Y-m-d\TH") . ':59:59.000+08:00';
|
|
|
|
$where .= ' and "statTime" >= ' . "'{$start_time}'" . ' and "statTime" <= ' . "'{$end_time}'";
|
|
$list = $dm->select('bt_passenger_flow',$where);
|
|
$allTimeData = [];
|
|
$returnData = [];
|
|
|
|
$hoursArr = self::getHoursArr();
|
|
foreach ($hoursArr as $hoursVal) {
|
|
$str = $hoursVal . ':00';
|
|
$allTimeData[$str] = 0;
|
|
if (!isset($returnData[$str])) $returnData[$str] = 0;
|
|
}
|
|
foreach ($list as $value) {
|
|
$date = date('H:00',strtotime($value['statTime'])); // 各时间端进馆人数
|
|
if (!isset($allTimeData[$date])) continue;
|
|
$returnData[$date] += $value['flowInNum'];
|
|
}
|
|
|
|
$data = [];
|
|
foreach ($returnData as $date => $item) {
|
|
|
|
$data['dkeys'][] = $date;
|
|
$data['dvalue'][] = $item;
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 获取24小时字段
|
|
* @return array
|
|
*/
|
|
protected static function getHoursArr() {
|
|
$hours = array(); // 创建空数组
|
|
|
|
// 获取当前时间戳和当前小时数
|
|
$current_time = time();
|
|
$current_hour = date('H', $current_time);
|
|
|
|
// 循环向前获取23个小时的小时数，并添加到数组中
|
|
for ($i = 23; $i >= 1; $i--) {
|
|
$hour = date('H', strtotime("-{$i} hour", $current_time));
|
|
array_push($hours, $hour);
|
|
}
|
|
|
|
// 将当前小时数添加到数组末尾
|
|
array_push($hours, $current_hour);
|
|
|
|
return $hours;
|
|
}
|
|
|
|
/**
|
|
* 文化 24小时数据 柱状图
|
|
* @param $dm
|
|
* @return array
|
|
*/
|
|
public static function getLibraryHours24List($dm = null)
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
|
|
# 获取时间参数
|
|
$start_time = date("Y-m-d\TH",strtotime('-23 hours')) . ':00:00.000+08:00';
|
|
$end_time = date("Y-m-d\TH") . ':59:59.000+08:00';
|
|
# 获取文化组id
|
|
$groupRes = $dm->select('bt_passenger_monitor_group',['type' => 2],'"groupId","groupName"');
|
|
$groupsId = [];
|
|
foreach ($groupRes as $groupRow) $groupsId[] = $groupRow['groupId'];
|
|
# 查询文化组 24小时数据
|
|
$where = ' "granularity"='."'hourly' " . ' and "statTime" >= ' . "'{$start_time}'" . ' and "statTime" <= ' . "'{$end_time}'";
|
|
$where .= ' and "groupId" in (' . "'" . implode("','",$groupsId) . "')";
|
|
$list = $dm->select('bt_passenger_flow',$where);
|
|
# 收集参数
|
|
$allTimeData = [];
|
|
$returnData = [];
|
|
$hoursArr = self::getHoursArr();
|
|
foreach ($hoursArr as $hoursVal) {
|
|
$str = $hoursVal . ':00';
|
|
$allTimeData[$str] = 0;
|
|
if (!isset($returnData[$str])) $returnData[$str] = 0;
|
|
}
|
|
foreach ($list as $value) {
|
|
$date = date('H:00',ceil($value['createTime'] / 1000)); // 各时间端进馆人数
|
|
if (!isset($allTimeData[$date])) continue;
|
|
$returnData[$date] += $value['flowInNum'];
|
|
}
|
|
# 图书、文化馆
|
|
$start_create_time = date("Y-m-d H:00:00",strtotime('-23 hours'));
|
|
$end_create_time = date("Y-m-d H:59:59");
|
|
$hoursWhere = ' "group_id" in (' . "'baz001','BAF055')" . ' and "create_time" >= ' . "'{$start_create_time}'"
|
|
. ' and "create_time" <= ' . "'{$end_create_time}'" ;
|
|
$hoursRes = $dm->select('bt_library_hours',$hoursWhere);
|
|
foreach ($hoursRes as $hoursRow) {
|
|
$date = $hoursRow['hour_time'];
|
|
if (!isset($allTimeData[$date])) continue;
|
|
$returnData[$date] += $hoursRow['incount'];
|
|
}
|
|
|
|
$data = [];
|
|
foreach ($returnData as $date => $item) {
|
|
|
|
$data['dkeys'][] = $date;
|
|
$data['dvalue'][] = $item;
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 文化 今日各场馆数据
|
|
* @param $dm
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function getLibraryGroupHoursList($dm = null,$is_group = true,$data = [])
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
|
|
# 获取文化组id
|
|
if ($is_group) {
|
|
$groupRes = $dm->select('bt_passenger_monitor_group',['type' => 2],'"groupId","groupName"');
|
|
$groupsId = [];
|
|
foreach ($groupRes as $groupRow) $groupsId[] = $groupRow['groupId'];
|
|
$data = self::toDayGroupsEnterNum($dm,['groupsId' => implode("|",$groupsId)]);
|
|
}
|
|
# 图书、文化馆
|
|
$start_create_time = date("Y-m-d 00:00:00");
|
|
$end_create_time = date("Y-m-d 23:59:59");
|
|
$allTimeData = [];
|
|
for ($i = 0; $i <= 23; $i++) {
|
|
$str = strlen($i) == 1 ? '0'.$i.':00' : $i.':00';
|
|
$allTimeData[$str] = 0;
|
|
}
|
|
$returnData = [];
|
|
|
|
# 获取各组初始数值
|
|
$groupData = [['groupName' => '图书馆'], ['groupName' => '文化馆']];
|
|
foreach ($groupData as $groupDataRow) {
|
|
foreach ($allTimeData as $date => $dateValue) {
|
|
$returnData[$groupDataRow['groupName']][$date] = $dateValue;
|
|
}
|
|
}
|
|
$hoursWhere = ' "group_id" in (' . "'baz001','BAF055')" . ' and "create_time" >= ' . "'{$start_create_time}'"
|
|
. ' and "create_time" <= ' . "'{$end_create_time}'" ;
|
|
$hoursRes = $dm->select('bt_library_hours',$hoursWhere);
|
|
|
|
foreach ($hoursRes as $hoursRow) {
|
|
$date = $hoursRow['hour_time']; // 各时间端进馆人数
|
|
if (!isset($allTimeData[$date])) continue;
|
|
if (!isset($returnData[$hoursRow['group_name']][$date])) $returnData[$hoursRow['group_name']][$date] = 0;
|
|
$returnData[$hoursRow['group_name']][$date] += $hoursRow['incount'];
|
|
}
|
|
|
|
foreach ($returnData as $groupName => $item) {
|
|
$listData = [];
|
|
foreach ($item as $itemKey => $itemRow) {
|
|
$listData['dkeys'][] = $itemKey;
|
|
$listData['dvalue'][] = $itemRow;
|
|
}
|
|
$data[] = [
|
|
'groupName' => $groupName,
|
|
'list' => $listData
|
|
];
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 获取今日图书馆借阅、办证数据
|
|
* @param $dm
|
|
* @return int[]
|
|
*/
|
|
public static function getLibraryLeaseData($dm = null)
|
|
{
|
|
if (empty($dm)) $dm = new Dm();
|
|
|
|
$today = date("Y-m-d 00:00:00");
|
|
$LibLeaseRes = $dm->find('bt_library_lease',['library' => '044007','create_time' => ['>=',$today]]);
|
|
$data = [
|
|
'newreader' => 0,
|
|
'servcount' => 0,
|
|
'returncount' => 0
|
|
];
|
|
if ($LibLeaseRes) {
|
|
$data['newreader'] = $LibLeaseRes['newreader']; # 今日办证册数
|
|
$data['servcount'] = $LibLeaseRes['servcount']; # 今日借书人数
|
|
$data['returncount'] = $LibLeaseRes['returncount']; # 今日还书册数
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
|
|
}
|
|
|