LogisticZopService.php 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. <?php
  2. namespace App\Services;
  3. use App\OrderPackage;
  4. use Carbon\Carbon;
  5. use Illuminate\Support\Facades\Http;
  6. class LogisticZopService implements LogisticRouteInterface
  7. {
  8. public function query($logistic_number)
  9. {
  10. $url = config('api_logistic.ZTO.url');
  11. $xAppKey = config('api_logistic.ZTO.x-appKey');
  12. $appSecret = config('api_logistic.ZTO.appSecret');
  13. $body = json_encode([
  14. 'billCode' => $logistic_number,
  15. ], JSON_UNESCAPED_UNICODE);
  16. $data_digest = base64_encode(md5($body . $appSecret, TRUE));
  17. $headers = [
  18. 'Content-Type' => 'application/json; charset=UTF-8',
  19. 'x-companyid' => $xAppKey,
  20. 'x-datadigest' => $data_digest,
  21. ];
  22. $response = Http::withHeaders($headers)->withBody($body, 'application/json')->post($url);
  23. return json_decode($response->body());
  24. }
  25. public function format($nativeResponse,$logistic_number)
  26. {
  27. $order_package = OrderPackage::query()->where('logistic_number', $logistic_number)->first();
  28. $result = [
  29. 'logistic_number' => $logistic_number,
  30. 'status' => $order_package->status,
  31. 'transfer_status' => $order_package->transfer_status,
  32. 'received_at' => $order_package->received_at,
  33. ];
  34. if (empty($nativeResponse->result)|| !$nativeResponse->status || $nativeResponse->statusCode=='P-OW005') {
  35. return $result;
  36. }
  37. $nativeRoutes = $nativeResponse->result??[];
  38. $lastRoute = $nativeRoutes[count($nativeRoutes) - 1]??[];
  39. list($status, $received_at) = $this->getNormalStatusAndReceivedAt($lastRoute);
  40. $result['status'] = $status;
  41. $result['received_at'] = $received_at;
  42. $result['transfer_status'] = $this->getTransferStatus($nativeRoutes);
  43. $result['routes_length'] = count($result['transfer_status']);
  44. return $result;
  45. }
  46. /**
  47. * 正常的状态与签收时间
  48. */
  49. private function getNormalStatusAndReceivedAt($lastRoute): array
  50. {
  51. $status = null;
  52. $received_at = null;
  53. switch ($lastRoute->scanType) {
  54. case '收件':
  55. $status = '已揽收';
  56. break;
  57. case '到件':
  58. case '发件':
  59. $status = '在途';
  60. break;
  61. case 'ARRIVAL':
  62. case '派件':
  63. $status = '派送中';
  64. break;
  65. case 'SIGNED':
  66. case '签收':
  67. $status = '已签收';
  68. $received_at = Carbon::parse($lastRoute->scanDate / 1000)->addHours(8)->toDateTimeString();
  69. break;
  70. default:
  71. $status = '其他';
  72. break;
  73. }
  74. return array($status, $received_at);
  75. }
  76. /**
  77. * @param $nativeRoutes
  78. * @return array
  79. */
  80. private function getTransferStatus($nativeRoutes): array
  81. {
  82. $transfer_status = [];
  83. foreach ($nativeRoutes as $item) {
  84. $data = [];
  85. $data['accept_time'] = Carbon::parse($item->scanDate / 1000)->addHours(8)->toDateTimeString();
  86. $scanSite = $item->scanSite;
  87. $data['accept_address'] = $scanSite->prov . '-' . $scanSite->name;
  88. $data['remark'] = $item->desc;
  89. $transfer_status[] = $data;
  90. }
  91. return $transfer_status;
  92. }
  93. }