huahuibao/app-ghs/controllers/OrderController.php

<?php

namespace ghs\controllers;

use biz\sj\services\MerchantExtendService;
use bizGhs\express\services\DadaExpressServices;
use bizHd\wx\classes\WxOpenClass;
use bizGhs\admin\classes\AdminClass;
use bizGhs\custom\classes\CustomClass;
use bizGhs\merchant\services\ShopService;
use bizGhs\order\classes\OrderClass;
use bizGhs\order\services\OrderService;
use bizHd\saas\services\RegionService;
use bizGhs\product\classes\ProductClass;
use common\components\dict;
use common\components\dateUtil;
use common\components\httpUtil;
use common\services\xhPayToolService;
use Yii;
use common\components\util;
use common\components\stringUtil;

class OrderController extends BaseController
{

    public $guestAccess = ['create-order', 'order-relate', 'fast-pay'];

    //订单列表 ssh 2021.1.20
    public function actionList()
    {
        $get = Yii::$app->request->get();
        $status = $get['status'] ?? 0;
        if (!empty($status)) {
            $where['status'] = $status;
        }
        $where['merchantId'] = $this->sjId;
        if (isset($get['shopId'])) {
            $shopId = $get['shopId'] ?? 0;
            if (!empty($shopId)) {
                $where['shopId'] = $this->shopId;
            }
        } else {
            $where['shopId'] = $this->shopId;
        }
        $searchTime = $get['searchTime'] ?? '';
        if (!empty($searchTime)) {
            $startTime = $get['startTime'] ?? '';
            $endTime = $get['endTime'] ?? '';
            $period = dateUtil::formatTime($searchTime, $startTime, $endTime);
            $where['addTime'] = ['between', [$period['startTime'], $period['endTime']]];
        }
        $name = $get['name'] ?? '';
        if (!empty($name)) {
            if (preg_match("/^[a-zA-Z\s]+$/", $name)) {
                $where['customNamePy'] = ['like', $name];
            } else {
                $where['customName'] = ['like', $name];
            }
        }
        $respond = OrderClass::getOrderList($where);

        $shop = $this->shop;
        $respond['allNum'] = $shop['totalOrder'] ?? 0;
        $respond['unPayNum'] = $shop['unPayOrder'] ?? 0;
        $respond['unSendNum'] = $shop['unSendOrder'] ?? 0;
        $respond['sendingNum'] = $shop['sendingOrder'] ?? 0;
        $respond['finishNum'] = $shop['finishOrder'] ?? 0;

        util::success($respond);
    }

    //商城下单操作 ssh 2021.1.14
    public function actionCreateOrder()
    {
        $post = Yii::$app->request->post();
        $shopId = $this->shopId;
        $customId = $post['customId'] ?? 0;
        $post['customId'] = $customId;
        if (!empty($customId)) {
            $custom = CustomClass::getCustom($customId);
            CustomClass::valid($custom, $this->sjId);
            $post['customMobile'] = $custom['mobile'] ?? '';
            $customName = $custom['name'] ?? '';
            $post['customName'] = $customName;
            $post['customNamePy'] = $custom['py'] ?? '';
            $post['customAvatar'] = $custom['shortSmallAvatar'] ?? '';
        }

        $post['shopAdminId'] = $this->shopAdminId;
        $shopAdmin = $this->shopAdmin;
        $post['shopAdminName'] = $shopAdmin['adminName'] ?? '';
        $post['shopId'] = $shopId;
        $post['payWay'] = $this->isWx == true ? 0 : 1;
        $post['merchantId'] = $this->sjId;
        $post['fromType'] = 1;
        $post['prePrice'] = 0.01;
        $post['actPrice'] = 0.01;
        $post['expressId'] = $post['expressId'] ?? 0;
        $post['clearType'] = $post['clearType'] ?? OrderClass::CLEAR_DEBT;

        $productJson = $post['product'] ?? '';
        if (empty($productJson)) {
            util::fail('请选择花材');
        }
        $productList = json_decode($productJson, true);
        if (empty($productList)) {
            util::fail('请选择花材');
        }
        $connection = Yii::$app->db;//事务处理
        $transaction = $connection->beginTransaction();
        try {
            //判断花材有效性
            ProductClass::valid($productList, $this->shopId);
            $post['product'] = $productList;
            $return = OrderClass::addOrder($post, $this->shop);
            //总订单+1
            \biz\shop\services\ShopService::totalOrderPlus($this->shopId);
            //总收入
            \biz\shop\services\ShopService::updateTotalIncome($this->shopId,$return['actPrice']);
            $transaction->commit();
            util::success($return);
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::info("下单失败原因：" . $e->getMessage());
            util::fail('下单失败');
        }
    }

    //延期支付 ssh 2021.1.19
    public function actionDebt()
    {
        $get = Yii::$app->request->get();
        $id = $get['id'] ?? 0;
        $info = OrderClass::getOrderInfo($id);
        OrderClass::valid($info, $this->shopId);
        OrderClass::debt($info, $this->shop);
        util::complete();
    }

    //获取商城下单要用的微信支付和小程序支付参数 ssh 2019.21.3
    public function actionWxPay()
    {
        ini_set('date.timezone', 'Asia/Shanghai');
        $post = Yii::$app->request->post();
        $couponId = $post['couponId'] ?? 0;
        $orderSn = isset($post['orderSn']) ? $post['orderSn'] : 0;
        $order = OrderClass::getByOrderSn($orderSn);
        if (empty($order)) {
            util::fail('订单号无效');
        }
        $id = $order['id'];

        //支付前验证订单有效性
        if (isset($order['adminId']) == false || $order['adminId'] != $this->adminId) {
            util::fail('没有权限操作');
        }

        $name = $order['orderName'] ?? '购买商品';
        $totalFee = $order['actPrice'];

        //强制使用小程序的miniOpenId
        $openId = $this->admin['miniOpenId'];

        $typeList = dict::getConfig('capitalType');
        $capitalType = $typeList['xhGhsOrder']['id'];
        //流水类型、优惠卷、微信支付（h5还是小程序支付）类型 带到回调
        $wxPayType = 0;
        if (httpUtil::isMiniProgram()) {
            $wxPayType = 1;
        }
        $attach = "couponId=" . $couponId . "&capitalType=" . $capitalType . '&wxPayType=' . $wxPayType;
        //订单30分钟后过期
        $now = time();
        $expireTime = $now + 1800;

        $wx = Yii::getAlias("@vendor/weixin");
        require_once($wx . '/lib/WxPay.Api.php');
        require_once($wx . '/example/WxPay.JsApiPay.php');
        $input = new \WxPayUnifiedOrder();
        $input->SetBody($name);
        $input->SetOut_trade_no($orderSn);
        $input->SetTotal_fee($totalFee * 100);
        $input->SetTime_start(date("YmdHis", $now));
        $input->SetAttach($attach);//将流水类型、代金劵等传给微信再回传
        $input->SetTime_expire(date("YmdHis", $expireTime));
        $input->SetNotify_url(Yii::$app->params['ghsHost'] . '/notice/wx-callback/');
        $input->SetTrade_type("JSAPI");

        //花卉宝代为申请的微信支付
        //$merchantExtend = $this->sjExtend;
        $merchantExtend = WxOpenClass::getGhsWxInfo();
        if (isset($merchantExtend['wxPayApply']) && $merchantExtend['wxPayApply'] == 1) {
            $input->SetSub_openid($openId);
        } else {
            $input->SetOpenid($openId);
        }

        //强制使用小程序的miniAppId
        $merchantExtend['wxAppId'] = $merchantExtend['miniAppId'];

        $wxOrder = \WxPayApi::unifiedOrder($input, 6, $merchantExtend);
        $tools = new \JsApiPay();
        $jsApiParameters = $tools->GetJsApiParameters($wxOrder, $merchantExtend);
        $newParams = json_decode($jsApiParameters, true);
        //微信不能修改价格
        $current = date("Y-m-d H:i:s");
        $updateData = ['deadline' => $current, 'modPrice' => 0];
        OrderClass::updateById($id, $updateData);
        util::success($newParams);
    }

    //获取订单详情 ssh 2021.1.21
    public function actionDetail()
    {
        $get = Yii::$app->request->get();
        $id = $get['id'] ?? 0;
        $info = OrderClass::getOrderInfo($id, true, true, true, false);
        OrderClass::valid($info, $this->shopId);
        util::success($info);
    }

    //自取和免发货流程处理 ssh 2021.1.22
    public function actionWithoutSend()
    {
        $get = Yii::$app->request->get();
        $id = $get['id'] ?? 0;
        $info = OrderClass::getOrderInfo($id);
        OrderClass::valid($info, $this->shopId);
        OrderClass::withoutSend($info);
        util::complete();
    }

    //本店送 ssh 2021.1.24
    public function actionSelfSend()
    {
        $get = Yii::$app->request->get();
        $id = isset($get['id']) ? $get['id'] : 0;
        $info = OrderClass::getOrderInfo($id);
        OrderClass::valid($info, $this->shopId);
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            OrderClass::selfSend($info);
            $transaction->commit();
        } catch (\Exception $exception) {
            $transaction->rollBack();
            Yii::info("本店送操作报错：" . $exception->getMessage());
            util::fail('操作失败');
        }
        util::complete();
    }

    //运费计算 ssh 2021.1.24
    public function actionFreight()
    {
        //2021.3.28 接入达达
        $get = Yii::$app->request->get();
        $orderId = $get['id'] ?? 0; //订单ID

        $customId = $get['customId'] ?? 0;
        if (!empty($customId)) {
            util::success(['sedCost' => 27]);
        }
        if(empty($orderId)){
            util::success(['sedCost' => 10]);
        }
        $province = $get['province'] ?? '';
        $city = $get['city'] ?? '';
        $address = $get['address'] ?? '';
        $floor = $get['floor'] ?? '';
        $fullAddress = $province . $city . $address . $floor;
        $sendTime = $get['sendTime'] ?? '';
        $lat = $get['lat'] ?? '';
        $lng = $get['long'] ?? '';
        if (empty($lat) || empty($lng) || empty($fullAddress)) {
            util::fail('请选择配送地址');
        }
        if (!empty($sendTime)) {
            //配送时间不为空
            // 预约发单时间（预约时间unix时间戳(10位),精确到分;整分钟为间隔，并且需要至少提前5分钟预约
            $sendTimeInt = strtotime($sendTime);
            $now = time();
            $diff = $sendTimeInt - $now;
            //因服务器写入时间，改为至少提前6分钟
            if ($diff <= 360) {
                util::fail('配送时间至少提前6分钟');
            }
        }
        //更新订单表
        $info = OrderClass::getOrderInfo($orderId);
        OrderClass::valid($info, $this->shopId);
        $expressAddInfo = [
            'province' => $province,
            'city' => $city,
            'address' => $address,
            'floor' => $floor,
            'lat' => $lat,
            'long' => $lng,
            'sendTime' => date('Y-m-d H:i', strtotime($sendTime)),
        ];
        OrderClass::updateCustomExpressInfo($orderId, $expressAddInfo);
        //计算运费
        $info['province'] = $province;
        $info['city'] = $city;
        $info['address'] = $address;
        $info['floor'] = $floor;
        $info['fullAddress'] = $fullAddress;
        $info['lat'] = $lat;
        $info['long'] = $lng;
        $info['sendTime'] = $expressAddInfo['sendTime'];
        $res = DadaExpressServices::queryDeliverFee($info);
        util::success(['sedCost' => $res['fee']]);
    }

    //发快递和第三方配送 ssh 2021.1.24
    public function actionThirdSend()
    {
        $get = Yii::$app->request->get();
        $id = isset($get['id']) ? $get['id'] : 0;
        $info = OrderClass::getOrderInfo($id);
        OrderClass::valid($info, $this->shopId);
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            $respond = OrderClass::thirdSend($info, $get);
            $transaction->commit();
            util::success($respond);
        } catch (\Exception $exception) {
            $transaction->rollBack();
            Yii::info("发快递操作报错：" . $exception->getMessage());
            util::fail('操作失败' . $exception->getMessage());
        }
    }

    //确认送达 ssh 2021.1.24
    public function actionReach()
    {
        $get = Yii::$app->request->get();
        $id = isset($get['id']) ? $get['id'] : 0;
        $info = OrderClass::getOrderInfo($id);
        OrderClass::valid($info, $this->shopId);
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            OrderClass::reach($info);
            $transaction->commit();
        } catch (\Exception $exception) {
            $transaction->rollBack();
            Yii::info("送达操作报错：" . $exception->getMessage());
            util::fail('操作失败');
        }
        util::complete();
    }

    //快捷付款订单
    public function actionFastPay()
    {
        ini_set('date.timezone', 'Asia/Shanghai');
        $post = Yii::$app->request->post();
        $payWay = isset($post['payWay']) ? $post['payWay'] : 0;
        $post['shopId'] = 2;
        //默认门店订单
        $store = isset($post['store']) ? $post['store'] : 1;
        $post['store'] = $store;
        $fromType = $post['fromType'] ?? 1;
        $post['userId'] = $this->adminId;
        $admin = $this->admin;
        $post['bookName'] = isset($admin['adminName']) ? $admin['adminName'] : '';
        $bookMobile = isset($post['bookMobile']) && !empty($post['bookMobile']) && stringUtil::isMobile($post['bookMobile']) ? $post['bookMobile'] : '';
        $bookMobile = empty($bookMobile) && isset($admin['mobile']) && !empty($admin['mobile']) ? $admin['mobile'] : $bookMobile;
        $post['bookMobile'] = $bookMobile;
        $prePrice = round($post['prePrice'], 2);
        $couponId = isset($post['couponId']) ? $post['couponId'] : 0;
        $sourceType = 0;
        $discountData = OrderService::getDiscountPrice(['price' => $prePrice, 'sourceType' => $sourceType, 'couponId' => $couponId, 'userId' => $this->adminId]);
        $actPrice = $discountData['price'];
        $post['discountType'] = $discountData['discountType'];
        $post['discountAmount'] = $discountData['discountAmount'];
        $post['actPrice'] = $actPrice;
        $post['payStyle'] = 0;
        $post['merchantId'] = $this->sjId;
        $now = time();
        //订单5分钟后过期
        $expireTime = $now + 300;
        $post['createTime'] = date("Y-m-d H:i:s", $now);
        $post['deadline'] = $expireTime;
        if ($actPrice <= 0) {
            util::fail('请填写正确的金额');
        }
        //微信支付订单提交不能修改价格
        $post['modPrice'] = $this->isWx ? 0 : 1;
        $post['sourceType'] = $sourceType;
        $post['goodsNum'] = 1;
        $post['fromType'] = $fromType;
        $post['product'] = [];
        $order = OrderClass::addOrder($post);
        $id = $order['id'];
        $orderSn = $order['orderSn'];
        $merchantId = $this->sjId;
        if ($payWay == 0) {
            $id = $order['id'];
            $name = '购买商品';
            $totalFee = $actPrice;
            $admin = AdminClass::getAdminById($this->adminId);
            //小程序使用miniOpenId
            $openId = $admin['miniOpenId'];
            $typeList = dict::getConfig('capitalType');
            $capitalType = $typeList['xhGhsOrder']['id'];
            //流水类型、优惠卷、微信支付（h5还是小程序支付）类型 带到回调
            $wxPayType = 0;
            if (httpUtil::isMiniProgram()) {
                $wxPayType = 1;
            }
            $attach = 'capitalType=' . $capitalType . '&couponId=' . $couponId . '&wxPayType=' . $wxPayType;
            $wx = Yii::getAlias("@vendor/weixin");
            require_once($wx . '/lib/WxPay.Api.php');
            require_once($wx . '/example/WxPay.JsApiPay.php');
            $input = new \WxPayUnifiedOrder();
            $input->SetBody($name);
            $input->SetOut_trade_no($orderSn);
            $input->SetTotal_fee($totalFee * 100);
            $input->SetTime_start(date("YmdHis", $now));
            $input->SetAttach($attach);
            //设置订单有效期5分钟
            $input->SetTime_expire(date("YmdHis", $expireTime));
            $input->SetNotify_url(Yii::$app->params['ghsHost'] . '/notice/wx-callback/');
            $input->SetTrade_type("JSAPI");

            //花卉宝代为申请的微信支付
            //$merchantExtend = $this->sjExtend;
            $merchantExtend = WxOpenClass::getGhsWxInfo();
            if (isset($merchantExtend['wxPayApply']) && $merchantExtend['wxPayApply'] == 1) {
                $input->SetSub_openid($openId);
            } else {
                $input->SetOpenid($openId);
            }
            //小程序使用miniAppId
            if (httpUtil::isMiniProgram()) {
                $merchantExtend['wxAppId'] = $merchantExtend['miniAppId'];
            }
            //强制使用小程序的appId
            $merchantExtend['wxAppId'] = $merchantExtend['miniAppId'];
            Yii::info('支付发起使用小程序信息' . json_encode($merchantExtend));
            $wxOrder = \WxPayApi::unifiedOrder($input, 6, $merchantExtend);
            $tools = new \JsApiPay();
            $jsApiParameters = $tools->GetJsApiParameters($wxOrder, $merchantExtend);
            $newParams = json_decode($jsApiParameters, true);
            $newParams['orderId'] = $id;
            util::success($newParams);
        } elseif ($payWay == 1) {
            $extend = MerchantExtendService::getByMerchantId($merchantId);
            if (isset($extend['alipayInit']) == false || $extend['alipayInit'] == 0) {
                util::fail('支付宝付款即将开通...');
            }
            $config = [
                //应用ID,您的APPID。
                'app_id' => $extend['alipayPId'],
                //商户私钥，您的原始格式RSA私钥
                'merchant_private_key' => $extend['alipayKey'],
                //异步通知地址
                'notify_url' => Yii::$app->params['ghsHost'] . "/notice/alipay-callback",
                //同步跳转
                'return_url' => "",
                //编码格式
                'charset' => "UTF-8",
                //签名方式
                'sign_type' => "RSA2",
                //支付宝网关
                'gatewayUrl' => "https://openapi.alipay.com/gateway.do",
                //支付宝公钥,查看地址：https://openhome.alipay.com/platform/keyManage.htm 对应APPID下的支付宝公钥。
                'alipay_public_key' => $extend['alipayPublicKey'],
            ];

            Yii::info(json_encode($config) . ' aplipay config');

            $alipayWap = Yii::getAlias("@vendor/alipayWap");
            require_once($alipayWap . '/wappay/service/AlipayTradeService.php');
            require_once($alipayWap . '/wappay/buildermodel/AlipayTradeWapPayContentBuilder.php');

            $totalFee = $order['actPrice'];
            $out_trade_no = $orderSn;//商户订单号，商户网站订单系统中唯一订单号，必填
            $subject = '购买商品';//订单名称，必填
            $total_amount = $totalFee;//付款金额，必填
            $body = '';//商品描述，可空
            $timeout_express = "1m";//超时时间

            $typeList = dict::getConfig('capitalType');
            $capitalType = $typeList['xhGhsOrder']['id'];
            $passBackParams = 'capitalType=' . $capitalType . '&couponId=' . $couponId . '&merchantId=' . $merchantId;//将流水类型、优惠卷传过去
            $passBackParams = urlencode($passBackParams);

            $payRequestBuilder = new \AlipayTradeWapPayContentBuilder();
            $payRequestBuilder->setBody($body);
            $payRequestBuilder->setSubject($subject);
            $payRequestBuilder->setOutTradeNo($out_trade_no);
            $payRequestBuilder->setTotalAmount($total_amount);
            $payRequestBuilder->setTimeExpress($timeout_express);
            //在异步通知时将该参数原样返回
            $payRequestBuilder->setPassbackParams($passBackParams);
            //同步通知
            $returnUrl = Yii::$app->params['mallDomain'] . "/#/pages/callback/success?account={$merchantId}&shopId={$shopId}&orderSn={$orderSn}&totalPrice={$totalFee}&pageStatus=3&payDiscountPrice=0&payDiscountType=0";
            //异步通知
            $notifyUrl = Yii::$app->params['ghsHost'] . "/notice/alipay-callback";
            $payResponse = new \AlipayTradeService($config);
            $result = $payResponse->wapPay($payRequestBuilder, $returnUrl, $notifyUrl);
            //直接将支付宝的html返回给前端
            echo $result;
        } elseif ($payWay == 2) {
            $typeList = dict::getConfig('capitalType');
            $capitalType = $typeList['xhGhsOrder']['id'];
            $callbackParams = [];
            $respond = xhPayToolService::balancePay($callbackParams, $orderSn, $actPrice, $capitalType, $couponId);
            $balance = isset($respond['balance']) ? $respond['balance'] : 0;
            util::success(['discountAmount' => $discountData['discountAmount'], 'discountType' => $discountData['discountType'], 'orderSn' => $orderSn, 'orderId' => $id, 'balance' => $balance]);
        } else {
            util::fail('无效的支付方式');
        }
    }

    //下单要用到的相关信息 ssh 2019.12.6
    public function actionOrderRelate()
    {
        $regionTree = RegionService::tree();
        $shop = ShopService::getDefaultShop($this->sj);
        $freight = ['first' => 5, 'add' => 2];
        $mapKey = 'OFWBZ-2NTHP-EHNDD-LKWQY-GANM7-PXBJH';
        $out = ['freight' => $freight, 'shop' => $shop, 'region' => $regionTree, 'txMapKey' => $mapKey, 'merchant' => $this->sj];
        util::success($out);
    }

    //客户欠款的订单 ssh 2021.2.4
    public function actionDebtList()
    {
        $id = Yii::$app->request->get('id', 0);
        $info = CustomClass::getCustom($id);
        CustomClass::valid($info, $this->sjId);
        $where = ['customId' => $id, 'debt' => 1];
        $respond = OrderService::getDebtOrderList($where);
        $respond['customInfo'] = $info;
        util::success($respond);
    }

}