508 行
18 KiB
PHP
508 行
18 KiB
PHP
<?php
|
|
namespace Retail\Controller;
|
|
use Think\Controller;
|
|
|
|
/**
|
|
* 骑手工作状态监控控制器
|
|
*/
|
|
class RiderMonitorController extends Controller {
|
|
|
|
/**
|
|
* 监控首页
|
|
*/
|
|
public function index() {
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 获取在线骑手列表
|
|
*/
|
|
public function getOnlineRiders() {
|
|
$page = I('page', 1, 'intval');
|
|
$pageSize = I('pageSize', 20, 'intval');
|
|
$keyword = I('keyword', '', 'trim');
|
|
$area_id = I('area_id', 0, 'intval');
|
|
$work_status = I('work_status', '', 'trim');
|
|
|
|
$where = array('u.user_type' => 'rider', 'u.status' => 1);
|
|
|
|
// 关键词搜索
|
|
if (!empty($keyword)) {
|
|
$where['_string'] = "(u.nickname LIKE '%{$keyword}%' OR u.phone LIKE '%{$keyword}%')";
|
|
}
|
|
|
|
// 工作状态筛选
|
|
if ($work_status !== '') {
|
|
$where['rs.work_status'] = $work_status;
|
|
}
|
|
|
|
// 区域筛选
|
|
if ($area_id > 0) {
|
|
$where['ra.area_id'] = $area_id;
|
|
}
|
|
|
|
$model = M('users');
|
|
$total = $model->alias('u')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id', 'LEFT')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where($where)
|
|
->count('DISTINCT u.id');
|
|
|
|
$list = $model->alias('u')
|
|
->field('u.*, rs.work_status, rs.current_lat, rs.current_lng, rs.last_update_time, rs.order_count_today')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id', 'LEFT')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where($where)
|
|
->group('u.id')
|
|
->order('rs.last_update_time desc')
|
|
->page($page, $pageSize)
|
|
->select();
|
|
|
|
// 格式化数据
|
|
foreach ($list as &$item) {
|
|
$item['work_status_text'] = $this->getWorkStatusText($item['work_status']);
|
|
$item['last_update_time_format'] = $item['last_update_time'] ? date('Y-m-d H:i:s', $item['last_update_time']) : '';
|
|
|
|
// 计算在线时长
|
|
if ($item['work_status'] == 'online') {
|
|
$online_duration = time() - strtotime(date('Y-m-d 00:00:00'));
|
|
$item['online_duration'] = $this->formatDuration($online_duration);
|
|
} else {
|
|
$item['online_duration'] = '0分钟';
|
|
}
|
|
|
|
// 获取当前订单信息
|
|
$current_order = M('order')->where(array(
|
|
'rider_id' => $item['id'],
|
|
'status' => array('in', array('accepted', 'picked_up', 'delivering'))
|
|
))->find();
|
|
$item['current_order'] = $current_order;
|
|
|
|
// 获取配送区域
|
|
$areas = M('rider_area')->alias('ra')
|
|
->field('da.area_name')
|
|
->join('ls_delivery_area da ON ra.area_id = da.id')
|
|
->where(array('ra.rider_id' => $item['id']))
|
|
->select();
|
|
$item['areas'] = $areas;
|
|
}
|
|
|
|
$this->ajaxReturn(array(
|
|
'code' => 0,
|
|
'msg' => 'success',
|
|
'data' => array(
|
|
'list' => $list,
|
|
'total' => $total
|
|
)
|
|
));
|
|
}
|
|
|
|
/**
|
|
* 获取骑手实时位置
|
|
*/
|
|
public function getRiderLocation() {
|
|
$rider_id = I('rider_id', 0, 'intval');
|
|
if (empty($rider_id)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '参数错误'));
|
|
}
|
|
|
|
$location = M('rider_status')->where(array('rider_id' => $rider_id))->find();
|
|
if (empty($location)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '未找到位置信息'));
|
|
}
|
|
|
|
// 获取骑手信息
|
|
$rider = M('users')->where(array('id' => $rider_id))->find();
|
|
|
|
$data = array(
|
|
'rider_id' => $rider_id,
|
|
'nickname' => $rider['nickname'],
|
|
'phone' => $rider['phone'],
|
|
'current_lat' => floatval($location['current_lat']),
|
|
'current_lng' => floatval($location['current_lng']),
|
|
'work_status' => $location['work_status'],
|
|
'work_status_text' => $this->getWorkStatusText($location['work_status']),
|
|
'last_update_time' => date('Y-m-d H:i:s', $location['last_update_time'])
|
|
);
|
|
|
|
// 获取最近的位置轨迹
|
|
$tracks = M('rider_location_track')->where(array(
|
|
'rider_id' => $rider_id,
|
|
'create_time' => array('egt', time() - 3600) // 最近1小时
|
|
))->order('create_time desc')->limit(50)->select();
|
|
|
|
$track_points = array();
|
|
foreach ($tracks as $track) {
|
|
$track_points[] = array(
|
|
'lat' => floatval($track['latitude']),
|
|
'lng' => floatval($track['longitude']),
|
|
'time' => date('H:i:s', $track['create_time'])
|
|
);
|
|
}
|
|
|
|
$data['track_points'] = $track_points;
|
|
|
|
$this->ajaxReturn(array(
|
|
'code' => 0,
|
|
'msg' => 'success',
|
|
'data' => $data
|
|
));
|
|
}
|
|
|
|
/**
|
|
* 获取骑手工作统计
|
|
*/
|
|
public function getRiderWorkStats() {
|
|
$rider_id = I('rider_id', 0, 'intval');
|
|
$date = I('date', date('Y-m-d'), 'trim');
|
|
|
|
if (empty($rider_id)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '参数错误'));
|
|
}
|
|
|
|
$start_time = strtotime($date . ' 00:00:00');
|
|
$end_time = strtotime($date . ' 23:59:59');
|
|
|
|
// 基础统计
|
|
$stats = array();
|
|
|
|
// 订单统计
|
|
$order_where = array(
|
|
'rider_id' => $rider_id,
|
|
'create_time' => array('between', array($start_time, $end_time))
|
|
);
|
|
|
|
$stats['order_count'] = M('order')->where($order_where)->count();
|
|
$stats['completed_count'] = M('order')->where(array_merge($order_where, array('status' => 'completed')))->count();
|
|
$stats['cancelled_count'] = M('order')->where(array_merge($order_where, array('status' => 'cancelled')))->count();
|
|
|
|
// 收入统计
|
|
$stats['total_income'] = M('order')->where(array_merge($order_where, array('status' => 'completed')))->sum('delivery_fee') ?: 0;
|
|
$stats['total_income_format'] = number_format($stats['total_income'], 2);
|
|
|
|
// 在线时长统计
|
|
$online_logs = M('rider_online_log')->where(array(
|
|
'rider_id' => $rider_id,
|
|
'date' => $date
|
|
))->find();
|
|
|
|
$stats['online_duration'] = $online_logs ? $online_logs['online_duration'] : 0;
|
|
$stats['online_duration_format'] = $this->formatDuration($stats['online_duration']);
|
|
|
|
// 平均配送时间
|
|
$avg_delivery_time = M('order')->where(array_merge($order_where, array('status' => 'completed')))
|
|
->avg('delivery_duration');
|
|
$stats['avg_delivery_time'] = $avg_delivery_time ? round($avg_delivery_time / 60, 1) : 0;
|
|
|
|
// 准时率
|
|
$timeout_count = M('order')->where(array_merge($order_where, array(
|
|
'status' => 'completed',
|
|
'is_timeout' => 1
|
|
)))->count();
|
|
|
|
$stats['punctuality_rate'] = $stats['completed_count'] > 0 ?
|
|
round((($stats['completed_count'] - $timeout_count) / $stats['completed_count']) * 100, 2) : 0;
|
|
|
|
$this->ajaxReturn(array(
|
|
'code' => 0,
|
|
'msg' => 'success',
|
|
'data' => $stats
|
|
));
|
|
}
|
|
|
|
/**
|
|
* 获取实时监控数据
|
|
*/
|
|
public function getRealtimeData() {
|
|
$area_id = I('area_id', 0, 'intval');
|
|
|
|
$where = array('u.user_type' => 'rider', 'u.status' => 1);
|
|
if ($area_id > 0) {
|
|
$where['ra.area_id'] = $area_id;
|
|
}
|
|
|
|
// 在线骑手统计
|
|
$online_count = M('users')->alias('u')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id', 'LEFT')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where(array_merge($where, array('rs.work_status' => 'online')))
|
|
->count('DISTINCT u.id');
|
|
|
|
// 忙碌骑手统计
|
|
$busy_count = M('users')->alias('u')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id', 'LEFT')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where(array_merge($where, array('rs.work_status' => 'busy')))
|
|
->count('DISTINCT u.id');
|
|
|
|
// 离线骑手统计
|
|
$offline_count = M('users')->alias('u')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id', 'LEFT')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where(array_merge($where, array('rs.work_status' => array('in', array('offline', '')))))
|
|
->count('DISTINCT u.id');
|
|
|
|
// 今日订单统计
|
|
$today_start = strtotime(date('Y-m-d 00:00:00'));
|
|
$today_end = strtotime(date('Y-m-d 23:59:59'));
|
|
|
|
$order_where = array('create_time' => array('between', array($today_start, $today_end)));
|
|
if ($area_id > 0) {
|
|
$order_where['delivery_area_id'] = $area_id;
|
|
}
|
|
|
|
$today_orders = M('order')->where($order_where)->count();
|
|
$completed_orders = M('order')->where(array_merge($order_where, array('status' => 'completed')))->count();
|
|
$pending_orders = M('order')->where(array_merge($order_where, array('status' => 'pending')))->count();
|
|
|
|
$data = array(
|
|
'rider_stats' => array(
|
|
'online_count' => $online_count,
|
|
'busy_count' => $busy_count,
|
|
'offline_count' => $offline_count,
|
|
'total_count' => $online_count + $busy_count + $offline_count
|
|
),
|
|
'order_stats' => array(
|
|
'today_orders' => $today_orders,
|
|
'completed_orders' => $completed_orders,
|
|
'pending_orders' => $pending_orders,
|
|
'completion_rate' => $today_orders > 0 ? round(($completed_orders / $today_orders) * 100, 2) : 0
|
|
)
|
|
);
|
|
|
|
$this->ajaxReturn(array(
|
|
'code' => 0,
|
|
'msg' => 'success',
|
|
'data' => $data
|
|
));
|
|
}
|
|
|
|
/**
|
|
* 获取骑手分布地图数据
|
|
*/
|
|
public function getRiderMapData() {
|
|
$area_id = I('area_id', 0, 'intval');
|
|
|
|
$where = array(
|
|
'u.user_type' => 'rider',
|
|
'u.status' => 1,
|
|
'rs.work_status' => array('in', array('online', 'busy'))
|
|
);
|
|
|
|
if ($area_id > 0) {
|
|
$where['ra.area_id'] = $area_id;
|
|
}
|
|
|
|
$riders = M('users')->alias('u')
|
|
->field('u.id, u.nickname, u.phone, rs.current_lat, rs.current_lng, rs.work_status')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where($where)
|
|
->group('u.id')
|
|
->select();
|
|
|
|
$map_data = array();
|
|
foreach ($riders as $rider) {
|
|
if (empty($rider['current_lat']) || empty($rider['current_lng'])) {
|
|
continue;
|
|
}
|
|
|
|
$map_data[] = array(
|
|
'rider_id' => $rider['id'],
|
|
'nickname' => $rider['nickname'],
|
|
'phone' => $rider['phone'],
|
|
'lat' => floatval($rider['current_lat']),
|
|
'lng' => floatval($rider['current_lng']),
|
|
'work_status' => $rider['work_status'],
|
|
'work_status_text' => $this->getWorkStatusText($rider['work_status'])
|
|
);
|
|
}
|
|
|
|
$this->ajaxReturn(array(
|
|
'code' => 0,
|
|
'msg' => 'success',
|
|
'data' => $map_data
|
|
));
|
|
}
|
|
|
|
/**
|
|
* 强制下线骑手
|
|
*/
|
|
public function forceOffline() {
|
|
$rider_id = I('rider_id', 0, 'intval');
|
|
$reason = I('reason', '', 'trim');
|
|
|
|
if (empty($rider_id)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '参数错误'));
|
|
}
|
|
|
|
if (empty($reason)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '请填写下线原因'));
|
|
}
|
|
|
|
// 检查骑手是否有进行中的订单
|
|
$active_order = M('order')->where(array(
|
|
'rider_id' => $rider_id,
|
|
'status' => array('in', array('accepted', 'picked_up', 'delivering'))
|
|
))->find();
|
|
|
|
if ($active_order) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '该骑手有进行中的订单，无法强制下线'));
|
|
}
|
|
|
|
// 更新骑手状态
|
|
$result = M('rider_status')->where(array('rider_id' => $rider_id))->save(array(
|
|
'work_status' => 'offline',
|
|
'last_update_time' => time()
|
|
));
|
|
|
|
if ($result !== false) {
|
|
// 记录操作日志
|
|
M('rider_operation_log')->add(array(
|
|
'rider_id' => $rider_id,
|
|
'operator_id' => session('admin_id'),
|
|
'action' => 'force_offline',
|
|
'reason' => $reason,
|
|
'create_time' => time()
|
|
));
|
|
|
|
$this->ajaxReturn(array('code' => 0, 'msg' => '操作成功'));
|
|
} else {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '操作失败'));
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 发送通知给骑手
|
|
*/
|
|
public function sendNotification() {
|
|
$rider_id = I('rider_id', 0, 'intval');
|
|
$message = I('message', '', 'trim');
|
|
|
|
if (empty($rider_id)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '参数错误'));
|
|
}
|
|
|
|
if (empty($message)) {
|
|
$this->ajaxReturn(array('code' => 1, 'msg' => '请输入通知内容'));
|
|
}
|
|
|
|
// 这里可以集成推送服务
|
|
// 示例：调用推送接口发送通知
|
|
|
|
// 记录通知日志
|
|
M('rider_notification_log')->add(array(
|
|
'rider_id' => $rider_id,
|
|
'sender_id' => session('admin_id'),
|
|
'message' => $message,
|
|
'create_time' => time()
|
|
));
|
|
|
|
$this->ajaxReturn(array('code' => 0, 'msg' => '通知发送成功'));
|
|
}
|
|
|
|
/**
|
|
* 导出监控数据
|
|
*/
|
|
public function exportMonitorData() {
|
|
$date = I('date', date('Y-m-d'), 'trim');
|
|
$area_id = I('area_id', 0, 'intval');
|
|
|
|
$start_time = strtotime($date . ' 00:00:00');
|
|
$end_time = strtotime($date . ' 23:59:59');
|
|
|
|
$where = array('u.user_type' => 'rider', 'u.status' => 1);
|
|
if ($area_id > 0) {
|
|
$where['ra.area_id'] = $area_id;
|
|
}
|
|
|
|
$list = M('users')->alias('u')
|
|
->field('u.*, rs.work_status, rs.last_update_time, rs.order_count_today')
|
|
->join('ls_rider_status rs ON u.id = rs.rider_id', 'LEFT')
|
|
->join('ls_rider_area ra ON u.id = ra.rider_id', 'LEFT')
|
|
->where($where)
|
|
->group('u.id')
|
|
->select();
|
|
|
|
// 导出Excel
|
|
vendor('PHPExcel.PHPExcel');
|
|
$objPHPExcel = new \PHPExcel();
|
|
$objPHPExcel->setActiveSheetIndex(0);
|
|
$objActSheet = $objPHPExcel->getActiveSheet();
|
|
|
|
// 设置表头
|
|
$objActSheet->setCellValue('A1', '骑手ID');
|
|
$objActSheet->setCellValue('B1', '姓名');
|
|
$objActSheet->setCellValue('C1', '手机号');
|
|
$objActSheet->setCellValue('D1', '工作状态');
|
|
$objActSheet->setCellValue('E1', '今日订单数');
|
|
$objActSheet->setCellValue('F1', '今日收入');
|
|
$objActSheet->setCellValue('G1', '在线时长');
|
|
$objActSheet->setCellValue('H1', '最后更新时间');
|
|
|
|
// 填充数据
|
|
$row = 2;
|
|
foreach ($list as $item) {
|
|
// 计算今日收入
|
|
$today_income = M('order')->where(array(
|
|
'rider_id' => $item['id'],
|
|
'status' => 'completed',
|
|
'create_time' => array('between', array($start_time, $end_time))
|
|
))->sum('delivery_fee') ?: 0;
|
|
|
|
// 获取在线时长
|
|
$online_log = M('rider_online_log')->where(array(
|
|
'rider_id' => $item['id'],
|
|
'date' => $date
|
|
))->find();
|
|
$online_duration = $online_log ? $this->formatDuration($online_log['online_duration']) : '0分钟';
|
|
|
|
$objActSheet->setCellValue('A' . $row, $item['id']);
|
|
$objActSheet->setCellValue('B' . $row, $item['nickname']);
|
|
$objActSheet->setCellValue('C' . $row, $item['phone']);
|
|
$objActSheet->setCellValue('D' . $row, $this->getWorkStatusText($item['work_status']));
|
|
$objActSheet->setCellValue('E' . $row, $item['order_count_today'] ?: 0);
|
|
$objActSheet->setCellValue('F' . $row, number_format($today_income, 2));
|
|
$objActSheet->setCellValue('G' . $row, $online_duration);
|
|
$objActSheet->setCellValue('H' . $row, $item['last_update_time'] ? date('Y-m-d H:i:s', $item['last_update_time']) : '');
|
|
$row++;
|
|
}
|
|
|
|
$filename = '骑手监控数据_' . $date . '_' . date('His') . '.xlsx';
|
|
header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
|
|
header('Content-Disposition: attachment;filename="' . $filename . '"');
|
|
header('Cache-Control: max-age=0');
|
|
|
|
$objWriter = \PHPExcel_IOFactory::createWriter($objPHPExcel, 'Excel2007');
|
|
$objWriter->save('php://output');
|
|
exit;
|
|
}
|
|
|
|
/**
|
|
* 格式化时长
|
|
*/
|
|
private function formatDuration($seconds) {
|
|
$hours = floor($seconds / 3600);
|
|
$minutes = floor(($seconds % 3600) / 60);
|
|
|
|
if ($hours > 0) {
|
|
return $hours . '小时' . $minutes . '分钟';
|
|
} else {
|
|
return $minutes . '分钟';
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取工作状态文本
|
|
*/
|
|
private function getWorkStatusText($status) {
|
|
$statusMap = array(
|
|
'online' => '在线空闲',
|
|
'busy' => '配送中',
|
|
'offline' => '离线',
|
|
'rest' => '休息中'
|
|
);
|
|
return isset($statusMap[$status]) ? $statusMap[$status] : '未知';
|
|
}
|
|
}
|
|
?>
|