fastadmin_tailored/application/api/controller/inspection/Order.php

<?php

namespace app\api\controller\inspection;

use app\api\controller\inspection\Base;
use app\common\Service\OrderService;
use app\common\Enum\OrderEnum;
use app\common\Service\OrderActionService;
use app\common\Enum\OrderActionEnum;
use app\common\Service\Order\OrderShipService;
/**
 * 验货端订单接口
 * 
 * 包含功能：
 * - 订单详情查询
 * - 订单列表查询
 * - 订单发货确认
 * - 订单统计功能（按日/月/年统计）
 * - 订单趋势数据
 * 
 * 统计功能说明：
 * - 验收订单：已验货通过的订单
 * - 退回订单：验货不通过的订单
 * - 售后订单：退款相关的订单
 */
class Order extends Base
{

    protected $noNeedLogin = [];

      //订单详情
      public function detail()
      {
          // 验证请求参数
          $validate = new \app\api\validate\Order();
          $orderId = $this->request->get('orderId');
          $params = ['orderId' => $orderId];
          if (!$validate->scene('detail')->check($params)) {
              $this->error($validate->getError());
          }
          $order = OrderService::getDetail($orderId, $this->auth->id);
          if (empty($order)) {
              $this->error('未找到订单');
          }
          /** @var \app\common\model\Order $order */
          //$order->append(['order_status_text']);
          $address = OrderService::getAddressInfo($orderId);
          $order->address = $address;
          // $order->append(['status_text']);
          // $order->hidden(explode(',', 'method,transactionid,updatetime,deletetime'));
          // $order->expiretime = $order->expiretime - time();
          $order->order_status_text = OrderEnum::STATUS_TEXT_MAP_INSPECTION[$order->order_status];
          $this->success('', $order);
      }
  
      //订单列表
      public function index()
      {
          // 验证请求参数
          $validate = new \app\api\validate\inspection\Order();
          $param = $this->request->param();
          $param['time_range'] = '1'; // 添加触发时间范围验证的字段
          
          if (!$validate->scene('lists')->check($param)) {
              $this->error($validate->getError());
          }        
          // 设置默认值
          $userId = 0;
          $param['page']     = $param['page'] ?? 1;
          $param['page_size'] = $param['page_size'] ?? 10;
          $status   = $param['status'] ?? 0; // 默认为0（全部订单）
          $param['keywords'] = $param['keywords'] ?? '';
          $status   = OrderEnum::SHOW_INSPECTION_TYPE_STATUS_MAP[$status];         

          // 查询对应的工厂 信息
          $supplierId = $this->application->supplier_id;
          $list = OrderService::getSupplierOrderList($supplierId ,$userId, $param, $status);
          foreach ($list as $item) {
             // $item->append(['order_status_text']);
              $field = 'id,order_sn,amount,goods_price,order_amount,express_name,express_no,order_goods,order_status_text,order_status';
              $item->visible(explode(',', $field));
              $item->order_status_text = OrderEnum::STATUS_TEXT_MAP_INSPECTION[$item->order_status];
          }
          $this->success('获取成功', $list);
      }

      //确认发货
      public function send()
      {
          // 验证请求参数
          $userId = $this->auth->id;
          $validate = new \app\api\validate\inspection\Order();
          $params = [
              'order_id' => $this->request->post('order_id'),
              'order_goods_id' => $this->request->post('order_goods_id'),
              'express_name' => $this->request->post('express_name'),
              'express_no' => $this->request->post('express_no'),
              'express_image' => $this->request->post('express_image/a', [])
          ];
          if (!$validate->scene('send')->check($params)) {
              $this->error($validate->getError());
          }        
          
          $orderId = intval($params['order_id'] ?? 0);
          $orderGoodsId = intval($params['order_goods_id'] ?? 0);
          
          if (empty($orderId)) {
              $this->error('订单ID不能为空');
          }
          
          if (empty($orderGoodsId)) {
              $this->error('订单商品ID不能为空');
          }
          
          // 验证订单商品是否可以发货
          $orderData = OrderService::validateOrderGoodsForDelivery($orderId, $orderGoodsId);
          if (!$orderData) {
              $this->error('订单或订单商品不存在，或不允许发货');
          }
          
          $order = $orderData['order'];
          $orderGoods = $orderData['order_goods'];
          
          // 验证权限（根据业务需求，这里可能需要验证供应商权限而不是用户权限）
          if ($order->user_id != $this->auth->id) {
              $this->error('该订单不属于当前用户');
          }
          
          $expressName = trim($params['express_name'] ?? '');
          $expressNo = trim($params['express_no'] ?? '');
          $expressImage = $params['express_image'] ?? [];
          
          // 1. 更新订单商品发货状态
          $result = OrderService::updateOrderGoodsDeliveryStatus($orderGoodsId, $expressName, $expressNo, $expressImage);
          if (!$result) {
              $this->error('更新订单商品发货状态失败');
          }
          
          // 2. 检查并更新订单状态
          OrderService::updateOrderStatusByDeliveryResult($orderId, $userId);
          
          // 3. 记录操作日志
          $orderActionService = new OrderActionService();
          $orderActionService->addInspectionAction(
              $order->order_sn,
              OrderActionEnum::ACTION_SHIP,
              $userId,
              '订单商品发货，商品：' . $orderGoods->goods_title . '，快递公司：' . $expressName . '，快递单号：' . $expressNo,
              $userId,   
              [
                  'order_goods_id' => $orderGoodsId,
                  'goods_title' => $orderGoods->goods_title,
                  'express_name' => $expressName,
                  'express_no' => $expressNo,
              ]
          );             
          
          $this->success('发货成功');
      }

      // 统计订单 
      public function statistics()
      {
          // 验证请求参数
          $validate = new \app\api\validate\Order();
          $params = [
              'type' => $this->request->param('type', 'day'),
              'date' => $this->request->param('date', date('Y-m-d'))
          ];
          
          if (!$validate->scene('statistics')->check($params)) {
              $this->error($validate->getError());
          }
          
          // 获取验证后的参数
          $type = $params['type'];
          $date = $params['date'];
          
          // 根据类型处理日期和时间范围
          switch ($type) {
              case 'day':
                  $startTime = strtotime($date . ' 00:00:00');
                  $endTime = strtotime($date . ' 23:59:59');
                  $displayDate = date('m-d', $startTime);
                  // 前一天
                  $prevStartTime = strtotime($date . ' 00:00:00') - 86400;
                  $prevEndTime = strtotime($date . ' 23:59:59') - 86400;
                  break;
              case 'month':
                  $startTime = strtotime(date('Y-m-01 00:00:00', strtotime($date)));
                  $endTime = strtotime(date('Y-m-t 23:59:59', strtotime($date)));
                  $displayDate = date('Y-m', $startTime);
                  // 前一个月
                  $prevStartTime = strtotime(date('Y-m-01 00:00:00', strtotime($date . ' -1 month')));
                  $prevEndTime = strtotime(date('Y-m-t 23:59:59', strtotime($date . ' -1 month')));
                  break;
              case 'year':
                  $startTime = strtotime(date('Y-01-01 00:00:00', strtotime($date)));
                  $endTime = strtotime(date('Y-12-31 23:59:59', strtotime($date)));
                  $displayDate = date('Y', $startTime) . '年';
                  // 前一年
                  $prevStartTime = strtotime(date('Y-01-01 00:00:00', strtotime($date . ' -1 year')));
                  $prevEndTime = strtotime(date('Y-12-31 23:59:59', strtotime($date . ' -1 year')));
                  break;
          }
          
          // 获取当前用户ID
          $userId = $this->auth->id;
          
          // 如果需要根据工厂统计，可以在这里添加工厂相关逻辑
          // 目前先按用户统计，后续可以根据实际的工厂关联字段进行调整
          
          // 当前期间统计
          $currentStats = $this->getOrderStatistics($userId, $startTime, $endTime);
          
          // 上期统计（用于对比）
          $prevStats = $this->getOrderStatistics($userId, $prevStartTime, $prevEndTime);
          
          // 计算增长率
          $growthRate = [
              'inspection_rate' => $this->calculateGrowthRate($prevStats['inspection_count'], $currentStats['inspection_count']),
              'return_rate' => $this->calculateGrowthRate($prevStats['return_count'], $currentStats['return_count']),
              'aftersale_rate' => $this->calculateGrowthRate($prevStats['aftersale_count'], $currentStats['aftersale_count'])
          ];
          
          // 返回统计数据
          $data = [
              'date' => $displayDate,
              'type' => $type,
              'current_period' => $currentStats,
              'previous_period' => $prevStats,
              'growth_rate' => $growthRate,
              'statistics' => [
                  'inspection_count' => $currentStats['inspection_count'],
                  'return_count' => $currentStats['return_count'],
                  'aftersale_count' => $currentStats['aftersale_count']
              ]
          ];
          
          $this->success('统计数据获取成功', $data);
      }
      
      /**
       * 获取订单统计数据
       */
      private function getOrderStatistics($userId, $startTime, $endTime)
      {
          // 统计验收订单（验货通过）
          $inspectionCount = \app\common\model\Order::where('user_id', $userId)
              ->where('order_status', OrderEnum::STATUS_INSPECTION_PASS)
              ->where('createtime', '>=', $startTime)
              ->where('createtime', '<=', $endTime)
              ->count();
          
          // 统计退回订单（验货不通过）
          $returnCount = \app\common\model\Order::where('user_id', $userId)
              ->where('order_status', OrderEnum::STATUS_INSPECTION_FAIL)
              ->where('createtime', '>=', $startTime)
              ->where('createtime', '<=', $endTime)
              ->count();
          
          // 统计待验收订单
          $aftersaleCount = \app\common\model\Order::where('user_id', $userId)
              ->whereIn('order_status', [OrderEnum::STATUS_PAY])
              ->where('createtime', '>=', $startTime)
              ->where('createtime', '<=', $endTime)
              ->count();
          
          return [
              'inspection_count' => $inspectionCount,
              'return_count' => $returnCount,
              'aftersale_count' => $aftersaleCount
          ];
      }
      
      /**
       * 计算增长率
       */
      private function calculateGrowthRate($prevValue, $currentValue)
      {
          if ($prevValue == 0) {
              return $currentValue > 0 ? 100 : 0;
          }
          return round((($currentValue - $prevValue) / $prevValue) * 100, 2);
      }
      
      /**
       * 获取统计数据的时间范围选择
       */
      public function getStatisticsDateRange()
      {
          // 获取最早和最晚的订单时间
          $userId = $this->auth->id;
          
          $earliest = \app\common\model\Order::where('user_id', $userId)
              ->order('createtime', 'asc')
              ->value('createtime');
          
          $latest = \app\common\model\Order::where('user_id', $userId)
              ->order('createtime', 'desc')
              ->value('createtime');
          
          $data = [
              'earliest_date' => $earliest ? date('Y-m-d', $earliest) : date('Y-m-d'),
              'latest_date' => $latest ? date('Y-m-d', $latest) : date('Y-m-d'),
              'current_date' => date('Y-m-d'),
              'current_month' => date('Y-m'),
              'current_year' => date('Y')
          ];
          
          $this->success('日期范围获取成功', $data);
      }
      
       /**
        * 获取历史趋势数据
        */
       public function getTrendData()
       {
           // 验证请求参数
           $validate = new \app\api\validate\Order();
           $params = [
               'type' => $this->request->param('type', 'day'),
               'days' => $this->request->param('days', 7)
           ];
           
           if (!$validate->scene('trend')->check($params)) {
               $this->error($validate->getError());
           }
           
           // 获取验证后的参数
           $type = $params['type'];
           $days = $params['days'];
          
          $userId = $this->auth->id;
          $trendData = [];
          
          for ($i = $days - 1; $i >= 0; $i--) {
              $date = date('Y-m-d', strtotime("-{$i} days"));
              $startTime = strtotime($date . ' 00:00:00');
              $endTime = strtotime($date . ' 23:59:59');
              
              $stats = $this->getOrderStatistics($userId, $startTime, $endTime);
              $trendData[] = [
                  'date' => $date,
                  'display_date' => date('m-d', $startTime),
                  'inspection_count' => $stats['inspection_count'],
                  'return_count' => $stats['return_count'],
                  'aftersale_count' => $stats['aftersale_count']
              ];
          }
          
          $this->success('趋势数据获取成功', $trendData);
      }

      // 获取快递公司列表
      public function getExpressCompany(){
        $list = OrderShipService::getExpressCompany();
        $this->success('快递公司列表获取成功', $list);
      }

}