fix:订单发货大小写

application/common/Service/Order/ShippingInfo/Base.php

@@ -0,0 +1,105 @@
+<?php
+
+namespace app\common\Service\Order\ShippingInfo;
+
+use app\common\Enum\PayEnum;
+use app\common\exception\BusinessException;
+use app\common\model\pay\Index as PayModel;
+use think\helper\Str;
+use app\common\Enum\GoodsEnum;
+class Base
+{
+    protected $order = null;
+    //protected $deliveryTypes = [];
+    public function __construct($order)
+    {
+        $this->order = $order; 
+       // $this->deliveryTypes = GoodsEnum::getDeliveryTypeList();
+        
+    }
+    
+
+    /**
+     * 设置微信支付相关的参数
+     *
+     * @param array $uploadParams
+     * @param \think\Model $wechatPay
+     * @return array
+     */
+    protected function setWechatParams($uploadParams, $wechatPay)
+    {
+        $order_key = [
+            'order_number_type' => 2,
+            'transaction_id' => $wechatPay->transaction_id,
+            'out_trade_no' => $wechatPay->pay_sn,
+        ];
+
+        $payer = [
+            'openid' => $wechatPay['buyer_info']
+        ];
+
+        foreach ($uploadParams as &$params) {
+            $params['order_key'] = $order_key;
+            $params['payer'] = $payer;
+        }
+
+        return $uploadParams;
+    }
+
+
+
+    /**
+     * 获取订单中的微信支付 pay 记录
+     *
+     * @return think\Model
+     */
+    protected function getWechatPay($type = 1)
+    {
+        $wechatPay = PayModel::where('order_type', $type)
+            ->where('order_id', $this->order['id'])
+            ->where('status', '<>', PayEnum::PAY_STATUS_UNPAID)
+            ->where('pay_type', PayEnum::METHOD_WECHAT)
+            ->order('id', 'desc')->find();
+      
+        if (!$wechatPay) {
+            throw new BusinessException('未找到订单微信支付记录');
+        }
+
+        return $wechatPay;
+    }
+
+
+
+    /**
+     * 配送方式转换
+     *
+     * @param string $deliveryType
+     * @return integer
+     */
+    protected function getLogisticsType($deliveryType)
+    {
+        switch ($deliveryType) {
+            case 'express':
+                $logistics_type = 1;
+                break;
+            case 'store_delivery':
+                $logistics_type = 2;
+                break;
+            case 'autosend':
+                $logistics_type = 3;
+                break;
+            case 'custom':
+                $logistics_type = 3;
+                break;
+            case 'selfetch':
+                $logistics_type = 4;
+                break;
+            default:
+                $logistics_type = 1;
+                break;
+        }
+
+        return $logistics_type;
+    }
+    
+}

application/common/Service/Order/ShippingInfo/OrderShippingInfo.php

@@ -0,0 +1,301 @@
+<?php
+
+namespace app\common\Service\Order\ShippingInfo;
+
+use app\common\model\OrderGoods as OrderGoodsModel;
+use app\common\model\OrderExpress as OrderExpressModel;
+use app\common\model\OrderAddress as OrderAddressModel;
+use app\common\Enum\OrderGoodsEnum;
+use app\common\Enum\GoodsEnum;
+class OrderShippingInfo extends Base
+{
+
+    protected $orderItems = null;
+    protected $deliveryTypes = [];
+   
+
+
+    /**
+     * 获取整个订单的 shippingParams 参数
+     *
+     * @return array
+     */
+    public function getShippingParams()
+    {
+        $wechatPay = $this->getWechatPay();
+
+        $this->setSendOrderItems();
+
+        $uploadParams = [];
+        if (in_array(GoodsEnum::DELIVERY_TYPE_EXPRESS, $this->deliveryTypes)) {
+            // 有 快递物流 商品
+            $expressUploadParams = $this->getExpressShippingParams();
+            $uploadParams = array_merge($uploadParams, $expressUploadParams);
+        }
+
+        if (!$uploadParams && array_intersect(['autosend', 'custom'], $this->deliveryTypes)) {
+            // 有 自动发货，或者手动发货 商品
+            $virtualParams = $this->getVirtualShippingParams();
+            $uploadParams[] = $virtualParams;
+        }
+
+        if (!$uploadParams && in_array('selfetch', $this->deliveryTypes)) {
+            // 有 到店自提 商品
+            $selfParams = $this->getSelfetchShippingParams();
+            $uploadParams[] = $selfParams;
+        }
+
+
+        if (!$uploadParams && in_array('store_delivery', $this->deliveryTypes)) {
+            // 有 店铺配送 商品
+            $storeDeliveryParams = $this->getStoreDeliveryShippingParams();
+            $uploadParams[] = $storeDeliveryParams;
+        }
+        // 处理微信相关参数
+        return $this->setWechatParams($uploadParams, $wechatPay);
+    }
+
+
+
+
+    /**
+     * 修改物流是获取指定 包裹的 shippingParams
+     *
+     * @param \think\Model $express
+     * @return array
+     */
+    public function getChangeShippingParams($express)
+    {
+        $wechatPay = $this->getWechatPay();
+
+        $this->setSendOrderItems();
+
+        $orderExpresses = collection([$express]);       // 指定包裹
+
+        // 获取包裹的 params
+        $uploadParams = $this->getExpressShippingParamsByExpresses($orderExpresses);
+
+        // 处理微信相关参数
+        return $this->setWechatParams($uploadParams, $wechatPay);
+    }
+
+
+
+
+    /**
+     * 获取订单所有包裹的 shippingParams
+     *
+     * @return array
+     */
+    private function getExpressShippingParams()
+    {
+        $orderExpresses = collection(OrderExpressModel::where('order_id', $this->order['id'])->select());
+        return $this->getExpressShippingParamsByExpresses($orderExpresses);
+    }
+
+
+
+    /**
+     * 获取订单指定包裹的 shippingParams
+     *
+     * @param \think\Model $order
+     * @param \think\Collection $orderExpresses
+     * @return array
+     */
+    private function getExpressShippingParamsByExpresses($orderExpresses)
+    {
+        $uploadParams = [];
+        if (!$orderExpresses->isEmpty()) {
+            $orderAddress = OrderAddressModel::where('order_id', $this->order['id'])->find();
+            $receiver_contact = $orderAddress ? mb_substr($orderAddress->mobile, 0, 3) . '****' . mb_substr($orderAddress->mobile, -4) : '130****0000';
+
+            $shippingList = [];
+            foreach ($orderExpresses as $orderExpress) {
+                $currentItems = $this->getItemsByCondition('order_express_id', $orderExpress->id);
+                $item_desc = [];
+                foreach ($currentItems as $currentItem) {
+                    $item_desc[] = $currentItem['goods_title'] . '*' . $currentItem['nums'];
+                }
+
+                $item_desc = join(', ', $item_desc);
+                $item_desc = mb_strlen($item_desc) > 110 ? mb_substr($item_desc, 0, 110) . ' 等商品' : $item_desc;      // 处理字符串
+
+                $shippingList[] = [
+                    'tracking_no' => $orderExpress['express_no'],
+                    'express_company' => $orderExpress['express_code'],
+                    'item_desc' => $item_desc,
+                    'contact' => [
+                        'receiver_contact' => $receiver_contact
+                    ]
+                ];
+            }
+            if ($shippingList) {
+                // 发货
+                $uploadParams[] = [
+                    'logistics_type' => $this->getLogisticsType('express'),
+                    'shipping_list' => $shippingList,
+                ];
+            }
+        }
+        return $uploadParams;
+    }
+
+
+
+    /**
+     * 获取订单中虚拟商品的 shippingParams
+     *
+     * @return array
+     */
+    private function getVirtualShippingParams()
+    {
+        // 是否存在虚拟发货商品
+        $virtualItems = $this->getItemsByCondition('_type', ['autosend', 'custom'], 'in_array');
+
+        if (!$virtualItems->isEmpty()) {
+            $shippingList = [];
+
+            $item_desc = [];
+            foreach ($virtualItems as $virtualItem) {
+                $item_desc[] = $virtualItem['goods_title'] . '*' . $virtualItem['goods_num'];
+            }
+
+            $item_desc = join(', ', $item_desc);
+            $item_desc = mb_strlen($item_desc) > 110 ? mb_substr($item_desc, 0, 110) . ' 等商品' : $item_desc;      // 处理字符串
+
+            $shippingList[] = [
+                'item_desc' => $item_desc,
+            ];
+
+            // 发货
+            $currentParams = [
+                'logistics_type' => $this->getLogisticsType('autosend'),
+                'shipping_list' => $shippingList,
+            ];
+        }
+
+        return $currentParams ?? null;
+    }
+
+
+
+    /**
+     * 获取订单中到店自提商品的 shippingParams
+     *
+     * @return array
+     */
+    public function getSelfetchShippingParams()
+    {
+        // 到店自提商品
+        $selfetchItems = $this->getItemsByCondition('delivery_type', ['selfetch'], 'in_array');
+        if (!$selfetchItems->isEmpty()) {
+            $shippingList = [];
+
+            $item_desc = [];
+            foreach ($selfetchItems as $selfetchItem) {
+                $item_desc[] = $selfetchItem['goods_title'] . '*' . $selfetchItem['goods_num'];
+            }
+
+            $item_desc = join(', ', $item_desc);
+            $item_desc = mb_strlen($item_desc) > 110 ? mb_substr($item_desc, 0, 110) . ' 等商品' : $item_desc;      // 处理字符串
+
+            $shippingList[] = [
+                'item_desc' => $item_desc,
+            ];
+
+            // 发货
+            $currentParams = [
+                'logistics_type' => $this->getLogisticsType('selfetch'),
+                'shipping_list' => $shippingList,
+            ];
+        }
+
+        return $currentParams ?? null;
+    }
+
+
+
+    /**
+     * 获取订单中店铺配送商品的 shippingParams
+     *
+     * @return array
+     */
+    public function getStoreDeliveryShippingParams()
+    {
+        // 到店自提商品
+        $storeDeliveryItems = $this->getItemsByCondition('delivery_type', ['store_delivery'], 'in_array');
+        if (!$storeDeliveryItems->isEmpty()) {
+            $shippingList = [];
+
+            $item_desc = [];
+            foreach ($storeDeliveryItems as $storeDeliveryItem) {
+                $item_desc[] = $storeDeliveryItem['goods_title'] . '*' . $storeDeliveryItem['goods_num'];
+            }
+
+            $item_desc = join(', ', $item_desc);
+            $item_desc = mb_strlen($item_desc) > 110 ? mb_substr($item_desc, 0, 110) . ' 等商品' : $item_desc;      // 处理字符串
+
+            $shippingList[] = [
+                'item_desc' => $item_desc,
+            ];
+
+            // 发货
+            $currentParams = [
+                'logistics_type' => $this->getLogisticsType('store_delivery'),
+                'shipping_list' => $shippingList,
+            ];
+        }
+
+        return $currentParams ?? null;
+    }
+
+
+
+    /**
+     * 设置 orderItems （这里是订单中的所有 items）
+     *
+     * @return void
+     */
+    private function setSendOrderItems()
+    {
+        $orderItems = OrderGoodsModel::where('order_id', $this->order['id'])
+            // ->where('refund_status', OrderItem::REFUND_STATUS_NOREFUND)
+            ->whereIn('delivery_status', 
+            [
+                OrderGoodsEnum::DELIVERY_STATUS_SENDED,
+                OrderGoodsEnum::DELIVERY_STATUS_GETED
+                ])
+            ->select();
+
+        $this->orderItems = $orderItems instanceof \think\Collection ? $orderItems : collection($orderItems);  
+
+        $this->deliveryTypes = array_values(array_unique(array_filter($this->orderItems->column('delivery_type'))));
+    }
+
+
+
+    /**
+     * 根据条件获取指定 itemd
+     *
+     * @param string $field
+     * @param mixed $value
+     * @return \think\Collection
+     */
+    private function getItemsByCondition($field, $value, $exp = '')
+    {
+        $new = [];
+        foreach ($this->orderItems as $item) {
+            if ($exp == 'in_array') {
+                if (in_array($item[$field], $value)) {
+                    $new[] = $item;
+                }    
+            } else {
+                if ($item[$field] == $value) {
+                    $new[] = $item;    
+                }
+            }
+        }
+
+        return collection($new);
+    }
+}

application/common/Service/Order/shippingInfo/Base.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace app\common\service\order\shippingInfo;
+namespace app\common\Service\Order\ShippingInfo;
 
 use app\common\Enum\PayEnum;
 use app\common\exception\BusinessException;

application/common/Service/Order/shippingInfo/OrderShippingInfo.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace app\common\service\order\shippingInfo;
+namespace app\common\Service\Order\ShippingInfo;
 
 use app\common\model\OrderGoods as OrderGoodsModel;
 use app\common\model\OrderExpress as OrderExpressModel;

application/common/library/easywechatPlus/WechatMiniProgramShop.php

@@ -1,9 +1,7 @@
 <?php
 
 namespace app\common\library\easywechatPlus;
-
-use app\common\exception\ShoproException;
-use app\common\service\order\shippingInfo\OrderShippingInfo;
+use app\common\Service\Order\ShippingInfo\OrderShippingInfo;
 use app\commom\model\data\WechatExpress;
 use app\common\exception\BusinessException;
 use app\common\facade\HttpClient;