huahuibao/app-ghs/controllers/IntraCityController.php

<?php

namespace ghs\controllers;

use bizHd\express\classes\ExpressOrderClass;
use bizHd\express\models\ExpressOrder;
use bizHd\order\classes\OrderGoodsClass;
use bizHd\user\classes\UserClass;
use bizHd\order\classes\OrderItemClass;
use hd\models\IntraCity\StoreFeeForm;
// 以上类来自零售端

use bizGhs\order\classes\OrderClass;
use biz\shop\classes\MainClass;
use biz\shop\classes\ShopClass;
use common\components\noticeUtil;
use common\components\util;
use common\components\IntraCityExpress;
use yii\helpers\Json;
use yii\db\Query;
use Yii;

/**
 * 同城配送控制器
 *
 * 提供同城配送相关的API接口
 */
class IntraCityController extends BaseController
{
    public $guestAccess = ['callback'];

    /**
     * 创建门店
     * POST /intra-city/create-store
     */
    public function actionCreateStore()
    {
        try {
            $shop = $this->shop;
            $shopName = $shop->shopName ?? '';
            $sjName = $shop->merchantName ?? '';
            $name = $shopName == '首店' ? $sjName : $sjName . ' ' . $shopName;

            $storeData = [
                'out_store_id' => $this->mainId, //自定义门店编号
                'store_name' => $name,
                'address_info' => [
                    'province' => $shop->province,
                    'city' => $shop->city,
                    'area' => $shop->dist,
                    'street' => '',
                    'house' => $shop->floor ? $shop->address . $shop->floor : $shop->address,
                    'lat' => $shop->lat,
                    'lng' => $shop->long,
                    'phone' => $shop->telephone
                ]
            ];

            // 验证必填参数
            $requiredFields = ['out_store_id', 'store_name', 'address_info'];
            foreach ($requiredFields as $field) {
                if (empty($storeData[$field])) {
                    util::fail("缺少必填参数：{$field}");
                }
            }

            // 创建门店前，检查是否已经 开通门店权限 (有wxStoreId，即说明开通了)
            $shopExt = MainClass::getById($this->mainId, true, 'id, wxStoreId');

            // 查询是否存在 wx_store_id，不存在则执行apply
            if ($shopExt->wxStoreId == '') {
                $re = IntraCityExpress::applyStore();
                if (!is_array($re)) {
                    $re = Json::decode($re, true);
                }
                if ($re['errcode'] != 0) {
                    Yii::error("开通门店权限失败：" . $re['errmsg']);
                    util::fail('开通门店权限失败');
                }
            }

            $result = IntraCityExpress::createStore($storeData);
            if ($result['errcode'] === 0) {
                // 保存微信门店编号（wx_store_id）
                $shopExt->wxStoreId = $result['wx_store_id'];
                $shopExt->save();

                util::success($result, "门店创建成功");
            } else {
                Yii::error("门店创建失败：" . $result['errmsg']);
                util::fail($result['errmsg']);
            }
        } catch (\Exception $e) {
            Yii::error("门店创建失败：" . $e->getMessage());
            util::fail("系统出错");
        }
    }

    /**
     * 查询门店创建情况
     */
    public function actionStore()
    {
        $shopId = $this->shopId;
        // 首先从门店扩展表查询是否已经创建
        $shopExt = MainClass::getById($this->mainId, true, 'id, wxStoreId');
        if ($shopExt->wxStoreId == '') { // 不存在，则从微信接口查询
            $result = IntraCityExpress::getStore($this->mainId);
            if ($result['errcode'] === 0) {
                $store = $result['store_list'][0];
                // 保存 wx_store_id
                $shopExt->wxStoreId = $store['wx_store_id'];
                $shopExt->save();

                util::success($store, "门店查询成功");
            } else {
                Yii::error("门店查询失败：" . $result['errmsg']);
                util::error(-1,'门店查询失败');
            }
        } else {
            $field = 'province, city, dist, lat, long, floor, address';
            $shop = ShopClass::getById($shopId, false, $field);
            $data = array_merge($shop, $shopExt->toArray());
            util::success($data, "门店查询成功");
        }
    }

    /**
     * 更新门店
     */
    public function actionUpdateStore()
    {
        // 首先从门店扩展表查询是否已经创建
        $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
        if ($shopExt['wxStoreId'] == '') {
            util::fail('未创建门店，请先创建');
        }

        $shop = $this->shop;
        $shopName = $shop->shopName ?? '';
        $sjName = $shop->merchantName ?? '';
        $name = $shopName == '首店' ? $sjName : $sjName . ' ' . $shopName;

        $storeData = [
            'keys' => ['wx_store_id' => $shopExt['wxStoreId']],
            'content' => [
                'store_name' => $name,
                'address_info' => [
                    'province' => $shop->province,
                    'city' => $shop->city,
                    'area' => $shop->dist,
                    'street' => '',
                    'house' => $shop->floor ? $shop->address . $shop->floor : $shop->address,
                    'lat' => $shop->lat,
                    'lng' => $shop->long,
                    'phone' => $shop->telephone
                ],
                //"order_pattern" => 2,
                //"service_trans_prefer" => "SFTC" //order_pattern = 2时必填
            ]
        ];
        $result = IntraCityExpress::updateStore($storeData);
        if ($result['errcode'] === 0) {
            util::success($result, "门店更新成功");
        } else {
            Yii::error("门店更新失败：" . $result['errmsg']);
            util::fail($result['errmsg']);
        }
    }

    /**
     * 门店运费充值
     */
    public function actionStoreCharge()
    {
        $post = Yii::$app->request->post();
        $amount = floatval($post['amount']);
        $amountTurnFen = $amount * 100;
        if ($amountTurnFen < 5000) {
            util::fail('50元起充');
        }

        $expressId = $post['expressId'];
        $serviceTransIds = ['SFTC', 'DADA'];
        if (!in_array($expressId, $serviceTransIds)) {
            util::fail('快递动力ID出错');
        }

        $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
        if ($shopExt['wxStoreId'] == '') {
            util::fail('微信门店编号为空');
        }
        $wxStoreId = $shopExt['wxStoreId'];
        $result = IntraCityExpress::storeCharge($wxStoreId, $expressId, $amountTurnFen);
        if ($result['errcode'] === 0) {
            util::success($result, "门店余额充值单已生成");
        } else {
            Yii::error("门店余额充值失败：" . $result['errmsg']);
            util::fail('门店余额充值失败');
        }
    }

    /**
     * 门店余额查询
     */
    public function actionStoreBalance()
    {
        $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
        if ($shopExt['wxStoreId'] == '') {
            util::error(-1,'微信门店编号为空');
        }
        $wxStoreId = $shopExt['wxStoreId'];
        $result = IntraCityExpress::getBalance($wxStoreId);
        if ($result['errcode'] === 0) {
            $data = ['all_balance' => $result['all_balance'] / 100.0];
            foreach ($result['balance_detail'] as $item) {
                if ($item['service_trans_id'] == 'DADA') {
                    $data['dada_balance'] = $item['balance'] / 100.0;
                }
                if ($item['service_trans_id'] == 'SFTC') {
                    $data['sf_balance'] = $item['balance'] / 100.0;
                }
            }
            util::success($data, "门店余额查询成功");
        } else {
            Yii::error("门店余额查询失败：" . $result['errmsg']);
            util::fail('门店余额查询失败');
        }
    }

    /**
     * 查询运费
     */
    public function actionStoreFee()
    {
        $post = Yii::$app->request->post();
        // 创建表单验证模型
        $form = new StoreFeeForm();
        $form->setScenario('store_fee');
        $form->load($post, ''); // 直接从 post 数据加载，不使用模型名作为前缀
        // 执行表单验证
        $form->validateForm();

        $orderId = $post['orderId'];
        $order = OrderClass::getById($orderId);
        if (empty($order)) {
            util::fail('订单出错');
        }
        if ($order['mainId'] != $this->mainId) {
            util::fail('订单出错');
        }
        $sn = $order['orderSn'];
        $shopId = intval($this->shopId);
        if (empty($shopId)) {
            util::fail("门店不存在");
        }
        $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
        if (empty($shopExt)) {
            util::fail("微信门店不存在");
        }

        $itemInfoList = OrderItemClass::getListBySn($sn);
        $orderType = 2; // 默认是 2。说明：1花束订单 2花材订单 3花束和花材都有
        if (empty($itemInfoList)) {
            $orderType = 1;
        }

        $cargoName = '花材'; // 商品名称，默认是花材
        $goodsInfoList = OrderGoodsClass::getListBySn($sn);
        if (count($goodsInfoList) == 1) {
            $goodsInfo = $goodsInfoList[0];
            $cargoName = $goodsInfo['name'];
        } else {
            if ($orderType != 2) {
                util::fail("订单商品数量不正确");
            }
        }

        $cargo = [
            'cargo_name' => $cargoName, // 商品名称 -- $order 中没有，要在 goodsInfo 中取
            'cargo_weight' => intval($post['weight'] * 1000), // 单位：克 -- 把千克转换为克
            'cargo_price' => intval($post['price'] * 100), // 单位：分 -- 把元转换为分
            'cargo_type' => IntraCityExpress::GOODS_TYPE_FLOWER,
            'cargo_num' => intval($post['packageNum'])
        ];
        $originalLng = doubleval($post['user_lng']);
        $originalLat = doubleval($post['user_lat']);
        $orderData = [
            //'out_store_id' => $shopId,
            'wx_store_id' => $shopExt['wxStoreId'],
            'user_name' => $post['user_name'],
            'user_phone' => $post['user_phone'],
            'user_lng' => $originalLng,
            'user_lat' => $originalLat,
            'user_address' => $post['user_address'],
            'cargo' => $cargo,
            //'use_sandbox' => 1 // 如果不需要沙箱，use_sandbox就不传就好了 -- 踩坑人的经验
            //'use_sandbox' => getenv('YII_ENV') == 'production' ? 0 : 1 // 根据环境变量判断是否使用沙盒环境 -- 没用，不生效
        ];
        //多处有用到这个方法，需修改请同步修改，搜索关键词 intra_city_express_pre_add
        $result = IntraCityExpress::preAddOrder($orderData);
        if ($result['errcode'] === 0) {
            util::success($result, "查询成功");
        } else {
            Yii::error("运费查询失败：" . json_encode($result));
            util::fail('运费查询失败' . json_encode($result));
        }
    }

    /**
     * 创建订单
     * POST /intra-city/create-order
     */
    public function actionCreateOrder()
    {
        try {
            $post = Yii::$app->request->post();
            $orderId = $post['orderId'];
            $order = OrderClass::getById($orderId);
            if (empty($order)) {
                util::fail('订单出错');
            }
            if ($order['mainId'] != $this->mainId) {
                util::fail('订单出错');
            }

            $sn = $order['orderSn'];
            $itemInfoList = OrderItemClass::getListBySn($sn, 'id, name, cover, num');
            $itemList = [];
            $orderType = 2; // 默认是 2。说明：1花束订单 2花材订单 3花束和花材都有
            if (empty($itemInfoList)) {
                $orderType = 1; // 花束订单
                $goodsInfoList = OrderGoodsClass::getListBySn($sn);
                $itemCount = 0;
                foreach ($goodsInfoList as $itemInfo) {
                    $itemList[] = [
                        'item_name' => $itemInfo['name'],
                        'item_pic_url' => $itemInfo['bigCover'],
                        'count' => $itemInfo['num'],
                    ];
                    $itemCount += $itemInfo['num'];
                }
                $post['packageNum'] = $itemCount;
            } else {
                $itemCount = 0;
                foreach ($itemInfoList as $itemInfo) {
                    $itemList[] = [
                        'item_name' => $itemInfo['name'],
                        'item_pic_url' => $itemInfo['bigCover'],
                        'count' => $itemInfo['num'],
                    ];
                    $itemCount += $itemInfo['num'];
                }
                $post['packageNum'] = $itemCount;
            }

            $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
            if (empty($shopExt)) {
                util::fail("微信门店不存在");
            }

            $cargoName = '花材'; // 商品名称，默认是花材
            $goodsInfoList = OrderGoodsClass::getListBySn($sn);
            if (count($goodsInfoList) == 1) {
                $goodsInfo = $goodsInfoList[0];
                $cargoName = $goodsInfo['name'];
            } else {
                if ($orderType != 2) {
                    Yii::error('订单商品数量不正确');
                    util::fail("订单商品数量不正确");
                }
            }

            // 通过 userId 获取 openid(小程序OpenId)
            $user = UserClass::getById($order['userId'], false, 'id, miniOpenId');
            if (empty($user)) {
                Yii::error('获取用户openId出错');
                util::fail('数据出错');
            }

            $cargo = [
                'cargo_name' => $cargoName,
                'cargo_weight' => intval($post['weight'] * 1000),
                'cargo_type' => IntraCityExpress::GOODS_TYPE_FLOWER,
                'cargo_num' => intval($post['packageNum']),
                'cargo_price' => intval($order['actPrice'] * 100), // $order 中有各个价格，请注意
                'item_list' => $itemList,
            ];

            //生成 store_order_id
            $storeOrderId = $orderId;
            if ($post['isNew'] == 0) { // 如果不是首次用 $orderId 创建快递配送，则要生成新 store_order_id
                // store_order_id 门店订单编号, 即 orderId。如果是重新配送的第n次，订单编号的命名规则为：orderId_copy_n
                $query = (new Query())
                    ->from('xhExpressOrder')
                    ->where(new \yii\db\Expression('storeOrderId LIKE CONCAT(:prefix, "%")', [':prefix' => $orderId . '_copy_%']))
                    ->andWhere(['mainId' => $this->mainId]);
                // $command = $query->createCommand();
                // $sql = $command->sql;
                $copyOrderCount = $query->count();
                $copyOrderCount += 1;
                $storeOrderId = $orderId . '_copy_' . $copyOrderCount;
            }


            $callbackUrl = Yii::$app->params['hdHost'] . '/intra-city/callback';
            $orderData = [
                'wx_store_id' => $shopExt['wxStoreId'],
                'store_order_id' => $storeOrderId, //同一个门店订单编号要保证唯一，相同的订单号会重入
                'user_openid' => $user['miniOpenId'],
                'user_lng' => $post['user_lng'],
                'user_lat' => $post['user_lat'],
                'user_address' => $post['user_address'],
                'user_name' => $post['user_name'],
                'user_phone' => $post['user_phone'],
                //'order_seq' => '', // 用于配送员快速寻找到匹配的商品(非必传)
                'verify_code_type' => 0,
                'order_detail_path' => '/admin/order/detail?id=' . $orderId, // TODO 使用花掌柜的地址，后期要重新选个地址
                'callback_url' => $callbackUrl, // 订单状态回调地址（非必传）
                //'use_sandbox' => getenv('YII_ENV') == 'production' ? 0 : 1, // 是否使用沙箱(非必传)
                'cargo' => $cargo
            ];
            $result = IntraCityExpress::createOrder($orderData);

            if (isset($result['errcode']) && $result['errcode'] === 0) {
                OrderClass::updateById($orderId, ['sendStatus' => 1]); // 更新订单状态为配送中

                // 保存进 xhExpressOrder 表
                $orderData = [
                    'mainId' => $this->mainId,
                    'shopId' => $this->shopId,
                    'deliveryId' => isset($result['service_trans_id']) ? $result['service_trans_id'] : '',
                    'wxOrderId' => isset($result['wx_order_id']) ? $result['wx_order_id'] : '',
                    'wxStoreId' => isset($result['wx_store_id']) ? $result['wx_store_id'] : '',
                    'storeOrderId' => isset($result['store_order_id']) ? $result['store_order_id'] : '',
                    'transOrderId' => isset($result['trans_order_id']) ? $result['trans_order_id'] : '',
                    'distance' => isset($result['distance']) ? $result['distance'] : 0,
                    'fee' => isset($result['fee']) ? $result['fee'] : 0,
                    'fetchCode' => isset($result['fetch_code']) ? $result['fetch_code'] : '',
                    'orderSeq' => isset($result['order_seq']) ? $result['order_seq'] : ''
                ];
                ExpressOrderClass::add($orderData);

                util::success(['fee' => $result['fee']], '订单创建成功');
            } else {
                noticeUtil::push("门店 -- " . $this->mainId . "，订单创建失败：" . json_encode($result));
                Yii::error("订单创建失败：" . ($result['errmsg'] ?? '未知错误'), 'intracity');
                util::fail( '订单创建失败: ' . $result['errcode']);
            }
        } catch (\Exception $e) {
            Yii::error("订单创建异常：" . $e->getMessage(), 'intracity');
            util::fail("系统出错");
        }
    }

    /**
     * 查询订单
     * GET /intra-city/get-order
     */
    public function actionGetOrder()
    {
        try {
            $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
            if (empty($shopExt)) {
                util::fail("微信门店不存在");
            }

            $post = Yii::$app->request->post();
            $wxOrderId = isset($post['wx_order_id']) ? $post['wx_order_id'] : '';
            $orderId = $post['orderId'];
            $wxStoreId = isset($post['wx_store_id']) ? $post['wx_store_id'] : $shopExt['wxStoreId'];

            if (empty($wxOrderId) && (empty($orderId) || empty($wxStoreId))) {
                util::fail("参数不足：wx_order_id 或 (order_id + wx_store_id) 必须提供一组");
            }
            $order = OrderClass::getById($orderId, false, 'id, mainId, sendStatus');
            if ($order['mainId'] != $this->mainId) {
                util::fail('订单未找到');
            }

            // 检查是否存在重复的订单：如果存在，则使用最后一个订单的 store_order_id
            $storeOrderId = $orderId; // ------------------------------------- 注意区分：$storeOrderId ， $orderId 。它们有可能不相同
            $query = (new Query())
                ->from('xhExpressOrder')
                ->where(['and',
                    new \yii\db\Expression('storeOrderId LIKE CONCAT(:prefix, "%")', [':prefix' => $orderId . '_copy_']),
                    ['status' => 1]
                ])->andWhere(['mainId' => $this->mainId])
                ->orderBy('addTime DESC');
            $esDatas = $query->all();
            $count = count($esDatas);
            if ($count > 0) {
                $es = $esDatas[0];
                $storeOrderId = $es['storeOrderId'];

                if ($count > 1) {
                    noticeUtil::push('同城配送订单重复多于1个. store_order_id:' . $orderId . '，wx_store_id:' . $wxStoreId);
                }
            }


            $result = IntraCityExpress::queryOrder($wxStoreId, $storeOrderId, $wxOrderId);
            if (isset($result['errcode']) && $result['errcode'] === 0) {
                util::success($result, "查询成功");
            } else {
                Yii::error("订单查询失败：" . ($result['errmsg'] ?? '未知错误'), 'intracity');
                util::fail( '订单查询失败: ' . $result['errcode']);
            }
        } catch (\Exception $e) {
            Yii::error("订单查询异常：" . $e->getMessage(), 'intracity');
            util::fail("系统出错");
        }
    }

    /**
     * 取消订单
     * POST /intra-city/cancel-order
     */
    public function actionCancelOrder()
    {
        try {
            $post = Yii::$app->request->post();

            $shopExt = MainClass::getById($this->mainId, false, 'id, wxStoreId');
            if (empty($shopExt)) {
                util::fail("微信门店不存在");
            }

            $wxOrderId = isset($post['wx_order_id']) ? $post['wx_order_id'] : '';
            $orderId = $post['orderId'];    //配送订单创建成功后，也会返回的 store_order_id。 即 orderId
            $wxStoreId = isset($post['wx_store_id']) ? $post['wx_store_id'] : $shopExt['wxStoreId'];
            if (empty($wxOrderId) && (empty($orderId) || empty($wxStoreId))) {
                util::fail("参数不足：wx_order_id 或 (store_order_id + wx_store_id) 必须提供一组");
            }
            $order = OrderClass::getById($orderId, false, 'id, mainId, sendStatus');
            if ($order['mainId'] != $this->mainId) {
                util::fail('订单未找到');
            }
            if ($order['sendStatus'] != 1) {
                util::fail('配送单状态不是配送中');
            }

            // 检查是否存在重复的订单，如果存在，则使用最后一个订单的 store_order_id
            $storeOrderId = $orderId; // ------------------------------------- 注意区分：$storeOrderId ， $orderId 。它们有可能不相同
            $query = (new Query())
                ->from('xhExpressOrder')
                ->where(['and',
                    new \yii\db\Expression('storeOrderId LIKE CONCAT(:prefix, "%")', [':prefix' => $orderId . '_copy_']),
                    ['status' => 1]
                ])->andWhere(['mainId' => $this->mainId])
                ->orderBy('addTime DESC');
            // $command = $query->createCommand();
            // $sql = $command->sql;
            $esDatas = $query->all();

            $count = count($esDatas);
            if ($count > 0) {
                $es = $esDatas[0];
                $storeOrderId = $es['storeOrderId'];

                if ($count > 1) {
                    noticeUtil::push('同城配送订单重复多于1个. store_order_id:' . $orderId . '，wx_store_id:' . $wxStoreId);
                }
            }

            $result = IntraCityExpress::cancelOrder($wxOrderId, $storeOrderId, $wxStoreId);
            if (isset($result['errcode']) && $result['errcode'] === 0) {
                // 更新订单状态
                OrderClass::updateById($orderId, ['sendStatus' => OrderClass::ORDER_STATUS_CANCEL]);//设置为取消状态
                $eo = ExpressOrderClass::getByCondition(['storeOrderId' => $storeOrderId, 'wxStoreId' => $wxStoreId], true);
                if (!empty($eo)) {
                    $eo->status = 3;
                    $eo->cancelTime = date('Y-m-d H:i:s');
                    $eo->deductfee = $result['deductfee'];
                    $eo->save();
                }

                util::success($result, "订单取消成功");
            } else {
                if ($result['errcode'] == 934018) { // 93401 -- 订单已取消，请勿重复操作
                    // 更新订单状态
                    OrderClass::updateById($orderId, ['sendStatus' => OrderClass::ORDER_STATUS_CANCEL]);//设置为取消状态
                    util::success($result, "订单取消成功");
                }

                Yii::error("订单取消失败：" . ($result['errmsg'] ?? '未知错误'), 'intracity');
                util::fail('订单取消失败: ' . $result['errcode']);
            }
        } catch (\Exception $e) {
            Yii::error("订单取消异常：" . $e->getMessage(), 'intracity');
            util::fail("系统出错");
        }
    }

}