huahuibao/app-mall/controllers/NoticeController.php

<?php

namespace mall\controllers;

use biz\shop\classes\ShopClass;
use biz\wx\classes\WxMessageClass;
use bizHd\express\classes\HdDeliveryOrderClass;
use bizHd\order\classes\OrderClass;
use bizHd\order\classes\ScanPayClass;
use bizHd\recharge\classes\RechargeClass;
use bizHd\refund\classes\HdRefundClass;
use bizHd\shop\classes\MainClass;
use bizHd\work\classes\WorkClass;
use bizHd\wx\classes\WxOpenClass;
use common\components\noticeUtil;
use common\components\payUtil;
use Yii;
use common\components\util;
use common\components\dict;
use biz\shop\classes\ShopExtClass;
use common\components\lakala\Lakala;
use bizHd\recharge\classes\RechargeShbClass;
use bizHd\hb\classes\HbClass;
use bizHd\hb\classes\HbManageClass;
use bizHd\order\classes\PsMethodClass;

class NoticeController extends PublicController
{

    //微信退款结果通知
    public function actionWxRefundCallback()
    {
        $postStr = file_get_contents('php://input');//接收微信服务器返回的xml消息体
        if (empty($postStr)) {
            util::end();
        }
        $postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
        if ($postObj->return_code != 'SUCCESS') {
            $msg = $postObj->return_msg ?? '';
            $text = '微信退款结果通知，报错了，报错内容：' . $msg;
            Yii::warning($text);
            noticeUtil::push($text, '15280215347');
            util::end();
        }

        //解密req_info
        $wx = WxOpenClass::getMallWxInfo();
        $req_info = $postObj->req_info ?? '';
        $key = $wx['wxPayKey'] ?? '';
        $xml = openssl_decrypt(base64_decode($req_info), 'AES-256-ECB', MD5($key), OPENSSL_RAW_DATA, '');
        $req_info_obj = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);

        $refund_status = $req_info_obj->refund_status ?? '';

        $orderSn = $req_info_obj->out_trade_no ?? '';
        $out_refund_no = $req_info_obj->out_refund_no ?? '';
        //订单总金额
        $total_fee = $req_info_obj->total_fee ?? 0.00;
        //申请退款金额
        //$refund_fee = $req_info_obj->refund_fee ?? 0.00;
        //退款金额
        $settlement_refund_fee = $req_info_obj->settlement_refund_fee ?? 0.00;

        $new_total_fee = bcdiv($total_fee, 100, 2);
        $new_total_fee = floatval($new_total_fee);
        $new_settlement_refund_fee = bcdiv($settlement_refund_fee, 100, 2);
        $new_settlement_refund_fee = floatval($new_settlement_refund_fee);

        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        $text = '';
        try {
            if ($refund_status == 'SUCCESS') {
                $hdRefund = HdRefundClass::getByCondition(['refundSn' => $out_refund_no], true);
                if (!empty($hdRefund)) {
                    $hdRefund->status = HdRefundClass::STATUS_COMPLETE;
                    $hdRefund->save();
                }
                //$text = "【退款成功】退款单号：{$orderSn} {$out_refund_no} 订单金额：{$new_total_fee} 退款金额：{$new_settlement_refund_fee} ";
            } elseif ($refund_status == 'REFUNDCLOSE') {
                $text = "【退款关闭】退款单号：{$orderSn} {$out_refund_no} 订单金额：{$new_total_fee} 退款金额：{$new_settlement_refund_fee} ";
            } else {
                $text = "【退款失败】退款单号：{$orderSn} {$out_refund_no} 订单金额：{$new_total_fee} 退款金额：{$new_settlement_refund_fee} ";
            }
            $transaction->commit();
            echo '<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>';
            if (!empty($text)) {
                noticeUtil::push($text, '15280215347');
            }
            exit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }

    }

    //支付回调 ssh 20231011
    public function actionPayCallback()
    {
        Yii::$app->params['ptStyle'] = dict::getDict('ptStyle', 'mall');

        $postStr = file_get_contents('php://input');//接收微信服务器返回的xml消息体
        if (empty($postStr)) {
            util::end();
        }

        $headers = Yii::$app->getRequest()->getHeaders();
        $Authorization = $headers->get('Authorization');

        $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
        $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
        $params = [
            'appid' => 'OP00002119',
            'serial_no' => '018b08cfddbd',
            'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
            'lklCertificatePath' => $lklCertificatePath,
        ];
        $laResource = new Lakala($params);
        $return = $laResource->signatureVerification($Authorization, $postStr);

        $postData = json_decode($postStr, true);
        $orderSn = $postData['out_trade_no'] ?? '';
        $total_amount = $postData['total_amount'] ?? 0;
        $account_type = $postData['account_type'] ?? '';
        if (empty($account_type)) {
            noticeUtil::push('支付回调失败了，没有找到钱包类型，请注意，orderSn:' . $orderSn, '15280215347');
            util::end();
        }
        $totalFee = $total_amount / 100;
        $transactionId = $postData['trade_no'] ?? 0;

        if ($return == false) {
            noticeUtil::push('支付回调验证失败了，请注意，orderSn:' . $orderSn, '15280215347');
            util::end();
        }
        //接收流水类型、代金劵
        $remarkString = $postData['remark'] ?? '';
        $remarkData = json_decode($remarkString, true);
        //流水类型
        $capitalType = isset($remarkData['capitalType']) ? $remarkData['capitalType'] : null;
        if (isset($capitalType) == false) {
            noticeUtil::push('支付回调失败了，没有找到capitalType，orderSn:' . $orderSn . ' remark:' . $remarkString, '15280215347');
            util::end();
        }

        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            $currentPayWay = null;
            if ($account_type == 'WECHAT') {
                $currentPayWay = dict::getDict('payWay', 'wxPay');
            } elseif ($account_type == 'ALIPAY') {
                $currentPayWay = dict::getDict('payWay', 'alipay');
            } else {
                noticeUtil::push('支付回调失败了，没有找到支付类型，orderSn:' . $orderSn, '15280215347');
                util::end();
            }
            //支付成功后续流程
            $attach = '';
            payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
            $transaction->commit();

            echo "SUCCESS";

            if ($capitalType == dict::getDict('capitalType', 'xhOrder', 'id')) {
                //解决重复通知，重要
                $cacheKey = 'pay_success_notice_' . $orderSn;
                $has = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
                if (empty($has)) {
                    Yii::$app->redis->executeCommand('SETEX', [$cacheKey, 864000, 'has']);

                    //打印小票和语音播报
                    $order = OrderClass::getByCondition(['orderSn' => $orderSn], true);
                    if (!empty($order)) {
                        OrderClass::onlinePrint($order);

                        //付款成功了，通知发跑腿功能，关键词 hd_pay_after_call_pt，多处要同步修改
                        HdDeliveryOrderClass::payAfter($order);

                        $shopId = $order->shopId ?? 0;
                        $shop = ShopClass::getById($shopId, true);
                        //制作任务
                        $shopExt = ShopExtClass::getByCondition(['shopId' => $shopId], true);
                        if ($shopExt->needWork == 1 && $order->hasWork != 1) {
                            $mainId = $shop->mainId ?? 0;
                            $main = MainClass::getById($mainId, true);
                            $orderId = $order->id ?? 0;
                            WorkClass::needWork($order, $main);
                            $has = WorkClass::getByCondition(['orderId' => $orderId], true);
                            if (!empty($has)) {
                                $order->hasWork = 1;
                                $order->save();
                            }
                            ShopExtClass::newWorkRemind($shopExt, $order);
                        }

                        //来自商城的新订单微信通知
                        WxMessageClass::hdNewOrderInform($shop, $order);

                        // 标记 xhPsMethod 未达门槛附加费当日已收（每日每客户每配送方式只收一次）
                        self::markPsUnMeetFeeAfterPay($order);
                    }
                }
            }

            if ($capitalType == dict::getDict('capitalType', 'scanPay', 'id')) {
                //解决重复通知，重要
                $myKey = 'mall_order_scan_pay_' . $orderSn;
                $has = Yii::$app->redis->executeCommand('GET', [$myKey]);
                if (empty($has)) {
                    Yii::$app->redis->executeCommand('SETEX', [$myKey, 864000, 'has']);
                    $scan = ScanPayClass::getByCondition(['orderSn' => $orderSn], true);

                    //微信通知
                    $shopId = $scan->shopId ?? 0;
                    $shop = ShopClass::getById($shopId, true);
                    WxMessageClass::hdScanPayInform($shop, $scan);

                    ShopExtClass::hdScanPayReport($scan);
                }
            }

            if ($capitalType == dict::getDict('capitalType', 'xhRecharge', 'id')) {
                //解决重复通知，重要
                $myKey = 'mall_rehcarge_' . $orderSn;
                $has = Yii::$app->redis->executeCommand('GET', [$myKey]);
                if (empty($has)) {
                    Yii::$app->redis->executeCommand('SETEX', [$myKey, 864000, 'has']);
                    $recharge = RechargeClass::getByCondition(['orderSn' => $orderSn], true);
                    ShopExtClass::skRechargeReport($recharge);
                }
            }
            exit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }
    }

    //微信支付异步回调
    public function actionWxCallback()
    {
        Yii::$app->params['ptStyle'] = dict::getDict('ptStyle', 'mall');

        $postStr = file_get_contents('php://input');//接收微信服务器返回的xml消息体
        if (empty($postStr)) {
            util::end();
        }
        $postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
        if ($postObj->return_code != 'SUCCESS') {
            Yii::warning('return_code error:' . $postObj->return_code);
            util::end();
        }
        $orderSn = $postObj->out_trade_no;
        $total_fee = $postObj->total_fee;
        $totalFee = $total_fee / 100;
        $attach = $postObj->attach;
        $transactionId = $postObj->transaction_id ?? '';
        //接收流水类型、代金劵
        parse_str($attach);
        //流水类型
        $capitalType = $capitalType ?? null;
        if (!isset($capitalType)) {
            Yii::warning('capitalType empty,orderSn:' . $orderSn);
            util::end();
        }
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            $wxPay = dict::getDict('payWay', 'wxPay');
            //支付成功后续流程
            payUtil::thirdPay($wxPay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
            $transaction->commit();

            echo '<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>';

            //解决重复通知
            $cacheKey = 'pay_success_notice_' . $orderSn;
            $has = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
            if (empty($has)) {
                Yii::$app->redis->executeCommand('SETEX', [$cacheKey, 864000, 'has']);

                //打印小票和语音播报
                $order = OrderClass::getByCondition(['orderSn' => $orderSn], true);
                ShopExtClass::hdGatheringReport($order);
                OrderClass::onlinePrint($order);

                $shopId = $order->shopId ?? 0;
                $shop = ShopClass::getById($shopId, true);
                if (in_array($order->fromType, [dict::getDict("fromType", "shop"), dict::getDict("fromType", "friend")])) {
                    //您有新的收入提醒
                    WxMessageClass::gatheringIncomeInform($shop, $order);
                }
                if ($order->fromType == dict::getDict("fromType", "mall")) {
                    //来自商城的新订单微信通知
                    WxMessageClass::hdNewOrderInform($shop, $order);
                }

                $shopExt = ShopExtClass::getByCondition(['shopId' => $shopId], true);
                ShopExtClass::newWorkRemind($shopExt, $order);

                if ($order->fromType == dict::getDict("fromType", "mall")) {
                    self::markPsUnMeetFeeAfterPay($order);
                }
            }
            exit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }
    }

    //支付宝异步通知
    public function actionAliCallback()
    {
        header("Content-type: text/html; charset=utf-8");
        $aliWap = Yii::getAlias("@vendor/alipayWap");
        //商户订单号
        $orderSn = $_POST['out_trade_no'];

        $order = OrderClass::getByCondition(['orderSn' => $orderSn], true);

        $aliPId = '2021003122664465';
        $aliKey = 'MIIEpAIBAAKCAQEAnefrChYa5FUbGTlZNMTDNG531WrVP+TBPw3/hSmycRlBE/1sg9EryM0S3a9OQKQenRdYOoalqkkBuzt41ygJUC5hfNeaiV2OzphIiAyxUaiL1mSftP5B8joBN3HGG2AKbcvKlWcFoeiGY4ZmV/K0t3fqj/uPP6N/pEtnx6X4Ifgz4WGCDKUXKqT1Pyk2rqyIpel2EYk+HtC+9iicfac9kKQQiksDopb7sYosttdk64Dmjp2nMLDSpR+KOZUaqB39MEeHcJGeTzdVrp+Z9wW/NcJzSkSUb9juA0YjmogdbiKltykVHTbP6J0uPyByvzfyyY22QPqwNPiIPbCN6H543QIDAQABAoIBAQCO0+rOecYjSDO1siDVUTC8KTutR+/R1klRjojUWy3zjQNHYJAZ/0ZaX9wzttDSOWETeL0uWwJYL6coQxf/jVA3PWyirqYyn/R/PFFG9iwhj5HE/8lRvjXKMttM2lV2B34HaDE6yC/ZDmkYdsX1wSvjU81QJRuiVXIsGqSpep8hoVvVAn5sjvoC+zBSUaCsYy+7v7IXc6L8f/oLCBXY1r5j/+F/XFU1uFv4j162eRShQs6jQyVqQGLGCy4sSujj+8mpd6uCyJSIGJQHJlaN6cibTYStU/Z9+I/AP/+wQPVx31OwEC5J2xBfSHsezMsHSF7HQnfpQSz5AsOYZ3MOkiglAoGBAPV8sZz3C1gQ6WX5eKZE7PEUSxvAHsP+X6AAA6sWfH4cZq1uGJXgiDpTqN5dOqfNpNAU8gBDNTx4xUZ+cDuDH4WYxqkCe3CDdL97QmXDl2PnNvCKgHl735g3U1v3kCXgUAfBomc/xEIDguiEtsjPpknfjte/HmDE0zrWMOAQkJqXAoGBAKSrD5ryiVREpBmUohsI1g+e7BVR2nAtGYiquXIk2lkk5eQVO1yDh/LOU0jf8kI+UyRv16fANBjXqVc/twG016US5FNPV6fSllevsr0V020QemInO0+yJnTojSAfcayLroQId8Y3nPqVPpKMwvjvV7r50nGCCqXBtQsF4KITRzqrAoGAZBNyYNgBguRaEd1Sxw2gPmOUfvqiUCo6F4MJ+8xN8idn4FnaofcH8ic613PQPqpB/yYaxeqgIEfnvGY9ILXCuvbePfYqFmMwzALWvZ+v7uVKa2M7HstWCrq7O+m/lQFN/ut8ZnUDcBn4WwwHa/PjCYietetO2gpDRmAdSqrWGH8CgYBkwp+r6pkJzW60kHSZIlEKAe7oJMwLNC2ZqQ4MwGwzfBaH+E34kCuR8ZqYzyAIVOa/Nwi5By1Zvi1KzBwJmUUTJ3o7WCOE96EzSrmOZlqXNCwO/36Vh6dshhhE/birIlXJSP0xdzpBQy2ksyli9eGy8cdJ2Y72Wo+TjSclRbKiPQKBgQD1C/CJRQbahz6B3Sc4NOiFUQioM30qDKbDibzUq95u5PtQOx69+/h68tA2nj7ILZOXoh6/KF6LM9WK0QctY0HR5Uy4Uz8YkY/Y0L/LExSkNdpYqbpBc8DdIsKYHoMLNHDwc03tpINRLrmq00sD0907oeuY8/2l6P7XOZSnCvE5Fw==';
        $aliPublicKey = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAgEb9zdQQDva63DhksZHPZCDrRe2xvZcTRy9mEiWs/pUhCG0QABkuePUyvqTAKINiCEv2QJmdF8qt3hmTSXuME5bT4vghckSGUTp4CNzsT90Vfjk4wci+bpAqNnpUASDuqZLCzebTuOhxYtGVBqYzhp/CxcC/Mag3ISjUG6jRqyUi15R1e2ruq74sohLGnb4m3nnwRVwnNVAaUcVfV1J0Nb0/9pusrj2t6FCyCkFeWbRDzKhplPQejaET2p5yplwSUpd1gqF+3srIn3erW5uAR6F0Z0NoCMzlo5TEXKWY2XMq97ubueE7Cgp8/c3dh5dkscAT2CCWwRq23aKozp+XMwIDAQAB';

        if (getenv('YII_ENV') == 'production') {
            if (isset($order->shopId) && $order->shopId == 1) {
                //国兰保留使用老的支付宝账号
                $aliPId = '2017041906821571';
                $aliKey = 'MIIEpAIBAAKCAQEAvbeu6o90L+0AilI+mbhuJJH0lUv7hWQCEC+XUc+cWlC9ulKC3cSVScVLJHpUc09aj6v/iD1p9iVfgMxjeADNVKiQC2RJyRshAjzyTq+2bTcODp619iV2y4qW8UM65VcP7Ide3P0uT5xC2ReW0HpkdHZgm4F+P7mh1VhGt9qOP3hjvoraAHhtGACvsGvy8H69HhSAG+CEmFt7f2tKNWJ8xEUvkfhDvys93PfTk4xMWj048hJE2r38+2mWI/Il5dFQHWXXTVl2x9yi7uhEEW42a+7s9Q3HgqEvZiQ2NI1FTeEAPLFBApiEsNLY/smaszwqqfWGAyTMvtQ6T4K96GcTLQIDAQABAoIBAHwYTj33n9RJfnT73x7F2KXrIsUVcmyKQh88QgqtdmRNNA1QM3HESLJ8bu5pZhwW5/HaW8dOBKWRRKsHBnlUbPrXV4FcFDeLm0fPfd+iZ/2AaZ1+ix962f3BpYIiq7+f9zaMRazfnw9L8x31pByyMktLs12EkoQ0dHsMxxUzzKAOiiPnvCn8Pv+Jb2qej8GXgCjefutCVNMWGsdwJtMVXEbpdmMa48Wvw+0In5ZS/UG39YAreFzgDqI9jWHE1ZhkGmB1+8hKpeIlEeVGAeYVveUgssMORdA/YY8SWHk26KSIFXBrmdKjAcRJ8Q7ZHUmzIqAV+IMV+RD4J5mZHeJgdAECgYEA8J+Hp1M6eYbT4CPLXa//yRP6Xo+qSzrKHaRB1LRAjYhvKpx/TQetYpNCJ5bWpa+Jp0T5R21pzuYaJkPuGlNEHA13b5T3r1l2ltomSEdaShvD5EZ9WtErYV5zpSv7FjjIGkbwa0H3A8Ydnvw5z4A9TZjjHLjC2GtVGJReqHGglMECgYEAydddA4NRPxmXvIjjmLb1Ft1qwHuyv3vvWhi50foGZXNEnBcfP/OkfyBDDpOEu34GZBMXK9ykHBs1l93OEFGXh7AwW0Lp5lARahBEfBZgPjq5yPO8TOJZrb5hVcuvoDdGjxpRh93XDnQDhWS/1IvUcBLcIsTcnVvfrkX4NLxF/W0CgYEAxamG+gD4rBQBwMImsRN+/2MV7M//iEUG+0qPeXeI/7rv9wUP3etMlwl48qSKNxj37xxN2ksa/Acxu/VZhu6XqKO3VUX+IWFQdaNGh2F13iLozIDLQOtKw3WfcjOq0xpZ5pwXq0RI8iSw+IUhyD8EHNZW2qU8CiRBhyt6hsywqQECgYBa8+06FAachI/XqWfF/UvcDdJ5AkS9/L8SvmmdsSkItjSIkfLHAqdxkbwl6Vu6kUOX/PJIFZjuAWTZFl4xBFNgFYj01uZHnnT6cnIp6HteD2CAqTSFAMqgfFWoL6zoaYAmJBnxO4oZPTYI+ilnQcts5VLFaChx0GCvS2BZgy2W0QKBgQDjP2VtRq4aVSLUq2z1KIDI7GJBbOM5KSW1OEj4sfEdViozPh3Ar/FQWiij1oCZF+iJdKkonHoDbDd+Q0ykcpQ+5Gv07iiT8wJYFR/0j8g2kfql7bVQhGSBeBMS5sawKR3CvkfW73WX+CNnf0PklTY0kTyt6WRXDnKSeyxFVwSZ7g==';
                $aliPublicKey = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAsz3m9juAR1xew4DY6c34gvbwNg8pZ92f932tseKs+4+pF0e+jTDiUo/xHImNDi1KXt1B+s3LxY9L/sxEksbavwmhgbz/igN1cAEwS2YM+Gnf0csDrxAPJhoKL5FTwxPEQ/8VSgroU+6GlF3LAx4VHa1qfn5MqRPfLroJcyPDyGfNe9vna2FnO4E/PH+hVbvPUAwX3XrUvJIm4OgY0JE3HYFlu+O7F4Ln6+Sl+Zv/ZE2nZAvNiyAwW5iVKhKXLieExqwd0NdrP28baBqkkIY+tmV7butGjB52iK1UbU0+1uiaPL4xBxRy6d0LZmYlvdVHp0JRUuwxBLChGgOCo/76DQIDAQAB';
            }
        }

        $config = [
            //应用ID,您的APP_ID
            'app_id' => $aliPId,
            //商户私钥，您的原始格式RSA私钥
            'merchant_private_key' => $aliKey,
            //异步通知地址
            'notify_url' => Yii::$app->params['mallHost'] . "/notice/ali-async",
            //同步跳转
            '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' => $aliPublicKey,
        ];

        require_once($aliWap . '/wappay/service/AlipayTradeService.php');
        require_once($aliWap . '/wappay/buildermodel/AlipayTradeQueryContentBuilder.php');//查询接口

        $arr = $_POST;
        $aliService = new \AlipayTradeService($config);
        $aliService->writeLog(var_export($_POST, true));
        $result = $aliService->check($arr);
        Yii::info('check:' . $result);
        if ($result == false) {
            //请不要修改
            echo "fail";
            util::end();
        }

        //验证成功后续
        $tradeNo = $_POST['trade_no'];//支付宝交易号
        $tradeStatus = $_POST['trade_status'];//交易状态
        $totalFee = $_POST['total_amount'];
        $appId = $_POST['app_id'];
        $attach = $_POST['passback_params'];
        $attach = urldecode($attach);
        //接收流水类型、代金劵
        parse_str($attach);
        //流水类型
        $capitalType = isset($capitalType) ? $capitalType : null;

        $RequestBuilder = new \AlipayTradeQueryContentBuilder();
        $RequestBuilder->setTradeNo($tradeNo);
        //$queryResult = $aliService->Query($RequestBuilder);
        //$aliId = $queryResult->buyer_user_id;
        //买家的支付宝帐号，不完整，带*号
        //$aliAccount = $queryResult->buyer_logon_id;

        if (isset($capitalType) == false) {
            Yii::warning('capitalType empty, orderSn:' . $orderSn);
            util::end();
        }
        if ($config['app_id'] != $appId) {
            Yii::warning('app_id disagree, orderSn:' . $orderSn . ' config app_id:' . $config['app_id'] . ' appId:' . $appId);
            util::end();
        }
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            if ($tradeStatus == 'TRADE_FINISHED' || $tradeStatus == 'TRADE_SUCCESS') {
                $aliPay = dict::getDict('payWay', 'alipay');
                //支付成功后续流程
                payUtil::thirdPay($aliPay, $capitalType, $orderSn, $totalFee, $attach);
                $transaction->commit();

                //打印小票和语音播报
                $order = OrderClass::getByCondition(['orderSn' => $orderSn], true);
                ShopExtClass::hdGatheringReport($order);
                OrderClass::onlinePrint($order);

                $shopId = $order->shopId ?? 0;
                $shop = ShopClass::getById($shopId, true);
                if (in_array($order->fromType, [dict::getDict("fromType", "shop"), dict::getDict("fromType", "friend")])) {
                    //您有新的收入提醒
                    WxMessageClass::gatheringIncomeInform($shop, $order);
                }
                if ($order->fromType == dict::getDict("fromType", "mall")) {
                    //来自商城的新订单微信通知
                    WxMessageClass::hdNewOrderInform($shop, $order);
                    self::markPsUnMeetFeeAfterPay($order);
                }
            }
            exit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }
    }

    //收银台支付回调
    public function actionCashPayCallback()
    {
        header("Content-type: text/html; charset=utf-8");

        Yii::$app->params['ptStyle'] = dict::getDict('ptStyle', 'mall');

        $postStr = file_get_contents('php://input');//接收微信服务器返回的xml消息体
        if (empty($postStr)) {
            util::end();
        }

        $headers = Yii::$app->getRequest()->getHeaders();
        $Authorization = $headers->get('Authorization');

        $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
        $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
        $params = [
            'appid' => 'OP00002119',
            'serial_no' => '018b08cfddbd',
            'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
            'lklCertificatePath' => $lklCertificatePath,
        ];
        $laResource = new Lakala($params);
        $return = $laResource->signatureVerification($Authorization, $postStr);

        $postData = json_decode($postStr, true);
        $orderSn = $postData['out_order_no'] ?? '';
        $orderTradeInfo = $postData['order_trade_info'] ?? [];
        $payMode = $orderTradeInfo['pay_mode'] ?? null;
        if (empty($payMode)) {
            noticeUtil::push('收银台支付回调失败了，没有找到钱包类型，请注意，orderSn:' . $orderSn, '15280215347');
            util::end();
        }
        $thirdLogNo = $orderTradeInfo['log_no'] ?? '';
        $trade_amount = $orderTradeInfo['trade_amount'] ?? 0;
        $totalFee = $trade_amount / 100;
        if ($totalFee <= 0) {
            noticeUtil::push('收银台支付回调验证失败了，金额错误，请注意，orderSn:' . $orderSn, '15280215347');
            util::end();
        }
        $transactionId = $orderTradeInfo['trade_no'] ?? 0;

        if ($return == false) {
            noticeUtil::push('收银台支付回调验证失败了，请注意，orderSn:' . $orderSn, '15280215347');
            util::end();
        }
        $orderStatus = $postData['order_status'];
        $tradeType = $orderTradeInfo['trade_type'] ?? '';
        if ($tradeType != 'PAY') {
            noticeUtil::push('收银台支付回调验证失败了，不是消费的回调，orderSn:' . $orderSn, '15280215347');
            util::end();
        }

        //接收流水类型、代金劵等
        $remarkString = $orderTradeInfo['trade_remark'] ?? '';
        $remarkData = json_decode($remarkString, true);
        $capitalType = $remarkData['capitalType'] ?? null;
        if (!isset($capitalType)) {
            $msg = '支付回调失败了，没有找到capitalType，orderSn:' . $orderSn . ' remark:' . $remarkString;
            noticeUtil::push($msg, '15280215347');
            util::end();
        }

        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            if ($orderStatus == 2) {
                $payWayType = null;
                if ($payMode == 'ALIPAY') {
                    $payWayType = dict::getDict('payWay', 'alipay');
                }
                if ($payMode == 'WECHAT') {
                    $payWayType = dict::getDict('wxPay', 'alipay');
                }
                if (isset($payWayType) == false) {
                    noticeUtil::push('收银台支付回调验证失败了，没有找到支付方式，orderSn:' . $orderSn, '15280215347');
                    util::end();
                }

                $attach = '';
                payUtil::thirdPay($payWayType, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
                $transaction->commit();

                if ($capitalType == dict::getDict('capitalType', 'xhOrder', 'id')) {
                    //避免重复
                    $cacheKey = 'pay_success_notice_' . $orderSn;
                    $has = Yii::$app->redis->executeCommand('GET', [$cacheKey]);
                    if (empty($has)) {
                        Yii::$app->redis->executeCommand('SETEX', [$cacheKey, 864000, 'has']);
                        //打印小票和语音播报
                        $order = OrderClass::getByCondition(['orderSn' => $orderSn], true);
                        if (!empty($order)) {
                            $order->thirdLogNo = $thirdLogNo;
                            $order->save();
                            OrderClass::onlinePrint($order);

                            //付款成功了，通知发跑腿功能，关键词 hd_pay_after_call_pt，多处要同步修改
                            HdDeliveryOrderClass::payAfter($order);

                            $shopId = $order->shopId ?? 0;
                            $shop = ShopClass::getById($shopId, true);
                            //来自商城的新订单微信通知
                            WxMessageClass::hdNewOrderInform($shop, $order);
                        }
                    }
                }
                if ($capitalType == dict::getDict('capitalType', 'scanPay', 'id')) {
                    //避免重复
                    $myKey = 'mall_order_scan_pay_' . $orderSn;
                    $has = Yii::$app->redis->executeCommand('GET', [$myKey]);
                    if (empty($has)) {
                        Yii::$app->redis->executeCommand('SETEX', [$myKey, 864000, 'has']);
                        $scan = ScanPayClass::getByCondition(['orderSn' => $orderSn], true);

                        //微信通知
                        $shopId = $scan->shopId ?? 0;
                        $shop = ShopClass::getById($shopId, true);
                        WxMessageClass::hdScanPayInform($shop, $scan);

                        ShopExtClass::hdScanPayReport($scan);
                    }
                }
            }
            //请不要修改
            echo "SUCCESS";
            exit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }
    }

    /**
     * 商城订单支付成功后，标记 xhPsMethod 未达门槛附加费当日已收
     */
    protected static function markPsUnMeetFeeAfterPay($order)
    {
        PsMethodClass::markUnMeetFeePaidFromOrder($order);
    }

}