561 行
20 KiB
PHP
561 行
20 KiB
PHP
<?php
|
|
namespace Admin\Controller;
|
|
|
|
use Admin\Controller\BaseController;
|
|
use Common\Business\RiderOrderDispatch;
|
|
|
|
/**
|
|
* 后台骑手管理控制器
|
|
* Class RiderManageController
|
|
* @package Admin\Controller
|
|
*/
|
|
class RiderManageController extends BaseController
|
|
{
|
|
/**
|
|
* 订单分配页面
|
|
* @return void
|
|
*/
|
|
public function orderDispatch()
|
|
{
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 获取待分配订单列表
|
|
* @return void
|
|
*/
|
|
public function getPendingOrders()
|
|
{
|
|
$param = I('post.');
|
|
|
|
$page = isset($param['page']) ? intval($param['page']) : 1;
|
|
$pageSize = isset($param['page_size']) ? intval($param['page_size']) : 20;
|
|
$storeId = isset($param['store_id']) ? intval($param['store_id']) : 0;
|
|
|
|
$billOrderModel = D('RetailBillOrder');
|
|
$billOnlineModel = D('RetailBillOnline');
|
|
|
|
// 构建查询条件
|
|
$where = [
|
|
'bo.type' => 1, // 商城订单
|
|
'bo.pay_state' => 1, // 已支付
|
|
'bol.pickup_type' => 2, // 配送订单
|
|
'bol.status' => 1, // 未发货
|
|
];
|
|
|
|
if ($storeId > 0) {
|
|
$where['bo.store_id'] = $storeId;
|
|
}
|
|
|
|
// 排除已分配给骑手的订单
|
|
$riderOrderModel = D('RiderOrder');
|
|
$assignedOrderIds = $riderOrderModel->getColumn(['order_status' => ['neq', -1]], 'bill_id');
|
|
if (!empty($assignedOrderIds)) {
|
|
$where['bo.id'] = ['not in', $assignedOrderIds];
|
|
}
|
|
|
|
// 获取订单列表
|
|
$orders = $billOrderModel->alias('bo')
|
|
->join('ls_retail_bill_online bol ON bo.id = bol.bill_id')
|
|
->join('ls_retail_store rs ON bo.store_id = rs.id')
|
|
->where($where)
|
|
->field('bo.*, bol.pickup_type, bol.status, bol.user_name, bol.user_phone, bol.user_address, rs.store_name, rs.lat as store_lat, rs.lng as store_lng')
|
|
->order('bo.add_time DESC')
|
|
->page($page, $pageSize)
|
|
->select();
|
|
|
|
$total = $billOrderModel->alias('bo')
|
|
->join('ls_retail_bill_online bol ON bo.id = bol.bill_id')
|
|
->where($where)
|
|
->count();
|
|
|
|
$result = [
|
|
'list' => $orders ?: [],
|
|
'total' => $total,
|
|
'page' => $page,
|
|
'page_size' => $pageSize
|
|
];
|
|
|
|
$this->ajaxReturn(callBack(statusCode()['success'], '获取待分配订单成功', $result));
|
|
}
|
|
|
|
/**
|
|
* 手动分配订单
|
|
* @return void
|
|
*/
|
|
public function manualDispatch()
|
|
{
|
|
$param = I('post.');
|
|
|
|
if (empty($param['bill_id'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单ID不能为空'));
|
|
}
|
|
|
|
if (empty($param['rider_id'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '请选择骑手'));
|
|
}
|
|
|
|
// 获取订单信息
|
|
$billOrderModel = D('RetailBillOrder');
|
|
$orderInfo = $billOrderModel->getFind(['id' => $param['bill_id']]);
|
|
|
|
if (empty($orderInfo)) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单不存在'));
|
|
}
|
|
|
|
$riderOrderDispatch = new RiderOrderDispatch();
|
|
|
|
$dispatchParam = [
|
|
'bill_id' => $param['bill_id'],
|
|
'merchant_id' => $orderInfo['merchant_id'],
|
|
'store_id' => $orderInfo['store_id'],
|
|
'auto_assign' => false,
|
|
'rider_id' => $param['rider_id']
|
|
];
|
|
|
|
$result = $riderOrderDispatch->dispatchOrder($dispatchParam);
|
|
|
|
$this->ajaxReturn($result);
|
|
}
|
|
|
|
/**
|
|
* 自动分配订单
|
|
* @return void
|
|
*/
|
|
public function autoDispatch()
|
|
{
|
|
$param = I('post.');
|
|
|
|
if (empty($param['bill_id'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单ID不能为空'));
|
|
}
|
|
|
|
// 获取订单信息
|
|
$billOrderModel = D('RetailBillOrder');
|
|
$orderInfo = $billOrderModel->getFind(['id' => $param['bill_id']]);
|
|
|
|
if (empty($orderInfo)) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单不存在'));
|
|
}
|
|
|
|
$riderOrderDispatch = new RiderOrderDispatch();
|
|
|
|
$dispatchParam = [
|
|
'bill_id' => $param['bill_id'],
|
|
'merchant_id' => $orderInfo['merchant_id'],
|
|
'store_id' => $orderInfo['store_id'],
|
|
'auto_assign' => true
|
|
];
|
|
|
|
$result = $riderOrderDispatch->dispatchOrder($dispatchParam);
|
|
|
|
$this->ajaxReturn($result);
|
|
}
|
|
|
|
/**
|
|
* 获取可用骑手列表
|
|
* @return void
|
|
*/
|
|
public function getAvailableRiders()
|
|
{
|
|
$param = I('post.');
|
|
|
|
if (empty($param['bill_id'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单ID不能为空'));
|
|
}
|
|
|
|
// 获取订单信息
|
|
$billOrderModel = D('RetailBillOrder');
|
|
$orderInfo = $billOrderModel->getFind(['id' => $param['bill_id']]);
|
|
|
|
if (empty($orderInfo)) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单不存在'));
|
|
}
|
|
|
|
$riderOrderDispatch = new RiderOrderDispatch();
|
|
|
|
$dispatchParam = [
|
|
'bill_id' => $param['bill_id'],
|
|
'merchant_id' => $orderInfo['merchant_id'],
|
|
'store_id' => $orderInfo['store_id'],
|
|
'auto_assign' => false
|
|
];
|
|
|
|
$result = $riderOrderDispatch->dispatchOrder($dispatchParam);
|
|
|
|
$this->ajaxReturn($result);
|
|
}
|
|
|
|
/**
|
|
* 骑手订单管理页面
|
|
* @return void
|
|
*/
|
|
public function riderOrders()
|
|
{
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 获取骑手订单列表
|
|
* @return void
|
|
*/
|
|
public function getRiderOrderList()
|
|
{
|
|
$param = I('post.');
|
|
|
|
$page = isset($param['page']) ? intval($param['page']) : 1;
|
|
$pageSize = isset($param['page_size']) ? intval($param['page_size']) : 20;
|
|
$riderId = isset($param['rider_id']) ? intval($param['rider_id']) : 0;
|
|
$orderStatus = isset($param['order_status']) ? $param['order_status'] : '';
|
|
$storeId = isset($param['store_id']) ? intval($param['store_id']) : 0;
|
|
|
|
$riderOrderModel = D('RiderOrder');
|
|
|
|
// 构建查询条件
|
|
$where = [];
|
|
if ($riderId > 0) {
|
|
$where['ro.rider_id'] = $riderId;
|
|
}
|
|
if ($orderStatus !== '') {
|
|
$where['ro.order_status'] = $orderStatus;
|
|
}
|
|
if ($storeId > 0) {
|
|
$where['ro.store_id'] = $storeId;
|
|
}
|
|
|
|
// 获取订单列表
|
|
$orders = $riderOrderModel->alias('ro')
|
|
->join('ls_rider_info ri ON ro.rider_id = ri.id')
|
|
->join('ls_retail_store rs ON ro.store_id = rs.id')
|
|
->where($where)
|
|
->field('ro.*, ri.real_name as rider_name, ri.phone as rider_phone, rs.store_name')
|
|
->order('ro.add_time DESC')
|
|
->page($page, $pageSize)
|
|
->select();
|
|
|
|
$total = $riderOrderModel->alias('ro')->where($where)->count();
|
|
|
|
// 处理订单状态显示
|
|
import('Common.Business.OrderStatusUtil');
|
|
$statusMap = [
|
|
'0' => \Common\Business\OrderStatusUtil::getStatusText('pending'),
|
|
'1' => \Common\Business\OrderStatusUtil::getStatusText('accepted'),
|
|
'2' => \Common\Business\OrderStatusUtil::getStatusText('picking_up'),
|
|
'3' => \Common\Business\OrderStatusUtil::getStatusText('delivering'),
|
|
'6' => \Common\Business\OrderStatusUtil::getStatusText('completed'),
|
|
'8' => \Common\Business\OrderStatusUtil::getStatusText('cancelled'),
|
|
'7' => \Common\Business\OrderStatusUtil::getStatusText('exception')
|
|
];
|
|
|
|
foreach ($orders as &$order) {
|
|
$order['status_text'] = isset($statusMap[$order['order_status']]) ? $statusMap[$order['order_status']] : '未知';
|
|
|
|
// 添加配送凭证信息
|
|
if ($order['order_status'] == 6) { // 已送达订单
|
|
$order['has_receipt'] = !empty($order['delivery_receipt_type']);
|
|
$order['receipt_type'] = $order['delivery_receipt_type'];
|
|
$order['receipt_upload_time'] = $order['receipt_upload_time'];
|
|
}
|
|
}
|
|
|
|
$result = [
|
|
'list' => $orders ?: [],
|
|
'total' => $total,
|
|
'page' => $page,
|
|
'page_size' => $pageSize
|
|
];
|
|
|
|
$this->ajaxReturn(callBack(statusCode()['success'], '获取骑手订单列表成功', $result));
|
|
}
|
|
|
|
/**
|
|
* 获取骑手列表
|
|
* @return void
|
|
*/
|
|
public function getRiderList()
|
|
{
|
|
$param = I('post.');
|
|
|
|
$storeId = isset($param['store_id']) ? intval($param['store_id']) : 0;
|
|
$workStatus = isset($param['work_status']) ? intval($param['work_status']) : -1;
|
|
|
|
$riderInfoModel = D('RiderInfo');
|
|
|
|
// 构建查询条件
|
|
$where = [
|
|
'auth_status' => 2, // 已认证
|
|
'status' => 1 // 正常状态
|
|
];
|
|
|
|
if ($storeId > 0) {
|
|
$where['store_id'] = $storeId;
|
|
}
|
|
|
|
if ($workStatus >= 0) {
|
|
$where['work_status'] = $workStatus;
|
|
}
|
|
|
|
$riders = $riderInfoModel->getList($where, 'id,real_name,phone,work_status,rating,on_time_rate,max_orders_per_time');
|
|
|
|
// 获取每个骑手的当前订单数量
|
|
$riderOrderModel = D('RiderOrder');
|
|
foreach ($riders as &$rider) {
|
|
import('@.Common.Business.OrderStatusUtil');
|
|
$inProgress = \Common\Business\OrderStatusUtil::getInProgressStatuses();
|
|
$rider['current_orders'] = $riderOrderModel->getCount([
|
|
'rider_id' => $rider['id'],
|
|
'order_status' => ['in', implode(',', $inProgress)]
|
|
]);
|
|
$rider['work_status_text'] = $rider['work_status'] == 1 ? '在线' : '离线';
|
|
}
|
|
|
|
$this->ajaxReturn(callBack(statusCode()['success'], '获取骑手列表成功', $riders));
|
|
}
|
|
|
|
/**
|
|
* 批量分配订单
|
|
* @return void
|
|
*/
|
|
public function batchDispatch()
|
|
{
|
|
$param = I('post.');
|
|
|
|
if (empty($param['bill_ids']) || !is_array($param['bill_ids'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '请选择要分配的订单'));
|
|
}
|
|
|
|
$riderOrderDispatch = new RiderOrderDispatch();
|
|
$successCount = 0;
|
|
$failCount = 0;
|
|
$errors = [];
|
|
|
|
foreach ($param['bill_ids'] as $billId) {
|
|
// 获取订单信息
|
|
$billOrderModel = D('RetailBillOrder');
|
|
$orderInfo = $billOrderModel->getFind(['id' => $billId]);
|
|
|
|
if (empty($orderInfo)) {
|
|
$failCount++;
|
|
$errors[] = "订单ID {$billId} 不存在";
|
|
continue;
|
|
}
|
|
|
|
$dispatchParam = [
|
|
'bill_id' => $billId,
|
|
'merchant_id' => $orderInfo['merchant_id'],
|
|
'store_id' => $orderInfo['store_id'],
|
|
'auto_assign' => true
|
|
];
|
|
|
|
$result = $riderOrderDispatch->dispatchOrder($dispatchParam);
|
|
|
|
if ($result['status'] == 1) {
|
|
$successCount++;
|
|
} else {
|
|
$failCount++;
|
|
$errors[] = "订单ID {$billId}: " . $result['msg'];
|
|
}
|
|
}
|
|
|
|
$message = "批量分配完成，成功：{$successCount}个，失败：{$failCount}个";
|
|
|
|
$this->ajaxReturn(callBack(statusCode()['success'], $message, [
|
|
'success_count' => $successCount,
|
|
'fail_count' => $failCount,
|
|
'errors' => $errors
|
|
]));
|
|
}
|
|
|
|
/**
|
|
* 获取订单配送凭证详情
|
|
* @return void
|
|
*/
|
|
public function getOrderReceiptDetail()
|
|
{
|
|
$param = I('post.');
|
|
|
|
if (empty($param['order_id'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单ID不能为空'));
|
|
}
|
|
|
|
$riderOrderModel = D('RiderOrder');
|
|
|
|
// 获取订单配送凭证信息
|
|
$order = $riderOrderModel->alias('ro')
|
|
->join('ls_rider_info ri ON ro.rider_id = ri.id')
|
|
->join('ls_retail_store rs ON ro.store_id = rs.id')
|
|
->where(['ro.id' => $param['order_id']])
|
|
->field('ro.id, ro.order_status, ro.delivery_receipt_type, ro.delivery_receipt_photos,
|
|
ro.delivery_signature, ro.delivery_receipt_code, ro.delivery_receipt_remark,
|
|
ro.receipt_upload_time, ro.delivery_time, ro.customer_name, ro.customer_phone,
|
|
ro.customer_address, ri.real_name as rider_name, ri.phone as rider_phone,
|
|
rs.store_name')
|
|
->find();
|
|
|
|
if (empty($order)) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单不存在'));
|
|
}
|
|
|
|
if ($order['order_status'] != 6) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单未完成配送'));
|
|
}
|
|
|
|
// 格式化配送凭证数据
|
|
$receiptData = [
|
|
'order_id' => $order['id'],
|
|
'order_status' => $order['order_status'],
|
|
'delivery_time' => $order['delivery_time'],
|
|
'receipt_type' => $order['delivery_receipt_type'],
|
|
'receipt_type_text' => $this->getReceiptTypeText($order['delivery_receipt_type']),
|
|
'receipt_photos' => $order['delivery_receipt_photos'] ? explode(',', $order['delivery_receipt_photos']) : [],
|
|
'delivery_signature' => $order['delivery_signature'],
|
|
'receipt_code' => $order['delivery_receipt_code'],
|
|
'receipt_remark' => $order['delivery_receipt_remark'],
|
|
'upload_time' => $order['receipt_upload_time'],
|
|
'customer_info' => [
|
|
'name' => $order['customer_name'],
|
|
'phone' => $order['customer_phone'],
|
|
'address' => $order['customer_address']
|
|
],
|
|
'rider_info' => [
|
|
'name' => $order['rider_name'],
|
|
'phone' => $order['rider_phone']
|
|
],
|
|
'store_name' => $order['store_name']
|
|
];
|
|
|
|
$this->ajaxReturn(callBack(statusCode()['success'], '获取配送凭证成功', $receiptData));
|
|
}
|
|
|
|
/**
|
|
* 获取凭证类型文本
|
|
* @param int $type
|
|
* @return string
|
|
*/
|
|
private function getReceiptTypeText($type)
|
|
{
|
|
$typeMap = [
|
|
1 => '照片凭证',
|
|
2 => '签名凭证',
|
|
3 => '验证码凭证'
|
|
];
|
|
|
|
return isset($typeMap[$type]) ? $typeMap[$type] : '未知类型';
|
|
}
|
|
|
|
/**
|
|
* 订单重新分配
|
|
* @return void
|
|
*/
|
|
public function reassignOrder()
|
|
{
|
|
$param = I('post.');
|
|
|
|
if (empty($param['rider_order_id'])) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '骑手订单ID不能为空'));
|
|
}
|
|
|
|
$riderOrderModel = D('RiderOrder');
|
|
|
|
// 获取骑手订单信息
|
|
$riderOrder = $riderOrderModel->getFind(['id' => $param['rider_order_id']]);
|
|
if (empty($riderOrder)) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '骑手订单不存在'));
|
|
}
|
|
|
|
// 检查订单状态
|
|
if ($riderOrder['order_status'] > 1) {
|
|
$this->ajaxReturn(callBack(statusCode()['error'], '订单已开始配送，无法重新分配'));
|
|
}
|
|
|
|
// 取消当前分配
|
|
$riderOrderModel->updateOrder(['id' => $param['rider_order_id']], [
|
|
'order_status' => -2, // 已取消
|
|
'cancel_time' => date('Y-m-d H:i:s'),
|
|
'cancel_reason' => '管理员重新分配',
|
|
'updated_at' => date('Y-m-d H:i:s')
|
|
]);
|
|
|
|
// 重新分配
|
|
$riderOrderDispatch = new RiderOrderDispatch();
|
|
|
|
$dispatchParam = [
|
|
'bill_id' => $riderOrder['bill_id'],
|
|
'merchant_id' => $riderOrder['merchant_id'],
|
|
'store_id' => $riderOrder['store_id'],
|
|
'auto_assign' => true
|
|
];
|
|
|
|
$result = $riderOrderDispatch->dispatchOrder($dispatchParam);
|
|
|
|
$this->ajaxReturn($result);
|
|
}
|
|
|
|
/**
|
|
* 获取订单统计数据
|
|
* @return void
|
|
*/
|
|
public function getOrderStats()
|
|
{
|
|
$param = I('post.');
|
|
|
|
$storeId = isset($param['store_id']) ? intval($param['store_id']) : 0;
|
|
$dateRange = isset($param['date_range']) ? $param['date_range'] : 'today';
|
|
|
|
// 计算日期范围
|
|
switch ($dateRange) {
|
|
case 'today':
|
|
$startDate = date('Y-m-d 00:00:00');
|
|
$endDate = date('Y-m-d 23:59:59');
|
|
break;
|
|
case 'yesterday':
|
|
$startDate = date('Y-m-d 00:00:00', strtotime('-1 day'));
|
|
$endDate = date('Y-m-d 23:59:59', strtotime('-1 day'));
|
|
break;
|
|
case 'week':
|
|
$startDate = date('Y-m-d 00:00:00', strtotime('-7 days'));
|
|
$endDate = date('Y-m-d 23:59:59');
|
|
break;
|
|
case 'month':
|
|
$startDate = date('Y-m-01 00:00:00');
|
|
$endDate = date('Y-m-d 23:59:59');
|
|
break;
|
|
default:
|
|
$startDate = date('Y-m-d 00:00:00');
|
|
$endDate = date('Y-m-d 23:59:59');
|
|
}
|
|
|
|
$riderOrderModel = D('RiderOrder');
|
|
|
|
// 构建基础查询条件
|
|
$baseWhere = [
|
|
'add_time' => ['between', [$startDate, $endDate]]
|
|
];
|
|
|
|
if ($storeId > 0) {
|
|
$baseWhere['store_id'] = $storeId;
|
|
}
|
|
|
|
// 统计各状态订单数量
|
|
$stats = [
|
|
'total_orders' => $riderOrderModel->getCount($baseWhere),
|
|
'pending_orders' => $riderOrderModel->getCount(array_merge($baseWhere, ['order_status' => 0])),
|
|
'accepted_orders' => $riderOrderModel->getCount(array_merge($baseWhere, ['order_status' => 1])),
|
|
'delivering_orders' => $riderOrderModel->getCount(array_merge($baseWhere, ['order_status' => ['in', \Common\Business\OrderStatusUtil::getInTransitStatuses()]])),
|
|
'completed_orders' => $riderOrderModel->getCount(array_merge($baseWhere, ['order_status' => 6])),
|
|
'exception_orders' => $riderOrderModel->getCount(array_merge($baseWhere, ['order_status' => 7])),
|
|
'cancelled_orders' => $riderOrderModel->getCount(array_merge($baseWhere, ['order_status' => 8])),
|
|
];
|
|
|
|
// 计算完成率
|
|
$stats['completion_rate'] = $stats['total_orders'] > 0 ?
|
|
round(($stats['completed_orders'] / $stats['total_orders']) * 100, 2) : 0;
|
|
|
|
// 计算平均配送时间
|
|
$avgDeliveryTime = $riderOrderModel->where(array_merge($baseWhere, ['order_status' => 6]))
|
|
->avg('TIMESTAMPDIFF(MINUTE, accept_time, delivery_time)');
|
|
$stats['avg_delivery_time'] = round($avgDeliveryTime ?: 0, 2);
|
|
|
|
$this->ajaxReturn(callBack(statusCode()['success'], '获取统计数据成功', $stats));
|
|
}
|
|
} |