售后寄回，抓取物流信息，2

addons/shopro/library/express/provider/Baseaftersale.php

@@ -0,0 +1,121 @@
+<?php
+
+namespace addons\shopro\library\express\provider;
+
+use addons\shopro\library\express\contract\ExpressInterface;
+use app\admin\model\shopro\order\Aftersale;
+use app\admin\model\shopro\order\AftersaleExpressLog;
+
+class Baseaftersale implements ExpressInterface
+{
+
+    public function __construct()
+    {
+    }
+
+
+    /**
+     * 快递查询
+     *
+     * @param array $data
+     * @param mixed $order_express_id
+     * @return array
+     */
+    public function search(array $data, $orderExpress = 0) 
+    {
+        return null;
+    }
+
+
+    /**
+     * 物流信息订阅
+     *
+     * @param array $data
+     * @return void
+     */
+    public function subscribe(array $data)
+    {
+        error_stop('当前快递驱动不支持物流信息订阅');
+    }
+
+
+    /**
+     * 物流信息推送
+     *
+     * @param array $data
+     * @return array
+     */
+    public function push(array $data)
+    {
+        error_stop('当前快递驱动不支持接受推送');
+    }
+
+
+    /**
+     * 电子面单
+     *
+     * @param array $data
+     * @param array $items
+     * @return array
+     */
+    public function eOrder(array $data, $items)
+    {
+        error_stop('当前快递驱动不支持电子面单');
+    }
+
+
+
+    /**
+     * 更新包裹信息
+     *
+     * @param array $data
+     * @param mixed $orderExpress
+     * @return array
+     */
+    protected function updateExpress(array $data, $orderExpress) 
+    {
+        // 更新包裹状态
+        if (is_numeric($orderExpress)) {
+            $orderExpress = Aftersale::find($orderExpress);
+        }
+        if ($orderExpress) {
+            $orderExpress->express_status = $data['status'];
+            $orderExpress->save();
+
+            $this->syncTraces($data['traces'], $orderExpress);
+        }
+    }
+
+
+    /**
+     * 更新物流信息
+     *
+     * @param array $traces
+     * @param mixed $orderExpress
+     * @return void
+     */
+    protected function syncTraces($traces, $orderExpress)
+    {
+        // 查询现有轨迹记录
+        $orderExpressLog = AftersaleExpressLog::where('order_aftersale_id', $orderExpress->id)->select();
+
+        $log_count = count($orderExpressLog);
+        if ($log_count > 0) {
+            // 移除已经存在的记录
+            array_splice($traces, 0, $log_count);
+        }
+
+        // 增加包裹记录
+        foreach ($traces as $k => $trace) {
+            $orderExpressLog = new AftersaleExpressLog();
+
+            $orderExpressLog->user_id = $orderExpress['user_id'];
+            $orderExpressLog->order_id = $orderExpress['order_id'];
+            $orderExpressLog->order_aftersale_id = $orderExpress['id'];
+            $orderExpressLog->content = $trace['content'];
+            $orderExpressLog->change_date = $trace['change_date'];
+            $orderExpressLog->status = $trace['status'];
+            $orderExpressLog->save();
+        }
+    }
+}

addons/shopro/library/express/provider/Kdniaoaftersale.php

@@ -5,10 +5,10 @@ namespace addons\shopro\library\express\provider;
 use think\Log;
 use think\exception\HttpResponseException;
 use addons\shopro\library\express\adapter\Kdniao as KdniaoServer;
-use app\admin\model\shopro\order\Express;
-use app\admin\model\shopro\order\ExpressLog;
+use app\admin\model\shopro\order\Aftersale;
+use app\admin\model\shopro\order\AftersaleExpressLog;
 
-class Kdniaoaftersale extends Base
+class Kdniaoaftersale extends Baseaftersale
 {
     public function __construct()
     {
@@ -109,11 +109,11 @@ class Kdniaoaftersale extends Base
             $expressData = $data['Data'];
 
             foreach ($expressData as $key => $express) {
-                $orderExpress = Express::where('express_no', $express['LogisticCode'])->where('express_code', $express['ShipperCode'])->find();
+                $orderExpress = Aftersale::where('express_no', $express['LogisticCode'])->where('express_code', $express['ShipperCode'])->find();
 
                 if (!$orderExpress) {
                     // 包裹不存在,记录日志信息，然后继续下一个
-                    Log::error('order-express-notfound:' . json_encode($express));
+                    Log::error('aftersale-express-notfound:' . json_encode($express));
                     continue;
                 }
 
@@ -127,7 +127,7 @@ class Kdniaoaftersale extends Base
                         ]);
                     }
 
-                    Log::error('order-express-resubscribe:' . json_encode($express));
+                    Log::error('aftersale-express-resubscribe:' . json_encode($express));
                     continue;
                 }