huahuibao/app-ghs/controllers/NoticeController.php

<?php

namespace ghs\controllers;

use biz\express\classes\ExpressShanClass;
use bizGhs\express\services\DadaExpressServices;
use bizGhs\order\classes\OrderClass;
use bizGhs\order\classes\OrderExpressClass;
use bizGhs\order\classes\OrderSendClass;
use bizGhs\order\services\OrderService;
use common\components\dict;
use common\components\noticeUtil;
use common\components\payUtil;
use common\components\shans\shans;
use Yii;
use common\components\util;
use biz\recharge\classes\RechargeClass;

class NoticeController extends PublicController
{

    //微信支付异步回调
    public function actionWxCallback()
    {
        $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 = isset($capitalType) ? $capitalType : null;
        if (isset($capitalType) == false) {
            Yii::warning('capitalType empty,orderSn:' . $orderSn);
            util::end();
        }

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

        $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>';

            if ($capitalType == dict::getDict('capitalType', 'xhRenew', 'id')) {
                noticeUtil::push("有客户付款成功：" . $orderSn . ' ' . $totalFee, '15280215347');
            }

        } 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'];

//        $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';

        $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';

        $config = [
            //应用ID,您的APP_ID
            'app_id' => $aliPId,
            //商户私钥，您的原始格式RSA私钥
            'merchant_private_key' => $aliKey,
            //异步通知地址
            'notify_url' => Yii::$app->params['ghsHost'] . "/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();
            }
            //请不要修改
            echo "success";
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }
    }


    /*
     *   {
     "signature": "aaaaaaaaaaaaaaaaaa", //签名
     "client_id": "270340107542552", 返回达达运单号，默认为空
     "order_id": "111111111111", 添加订单接口中的origin_id值
     "order_status": 4, 订单状态(待接单＝1,待取货＝2,配送中＝3,已完成＝4,已取消＝5, 指派单=8,妥投异常之物品返回中=9, 妥投异常之物品返回完成=10, 骑士到店=100,创建达达运单失败=1000 可参考文末的状态说明）
     "cancel_reason": "",  订单取消原因,其他状态下默认值为空字符串
     "cancel_from": 0, 订单取消原因来源(1:达达配送员取消；2:门店主动取消；3:系统或客服取消；0:默认值)
     "dm_id": 1, 达达配送员id，接单以后会传
     "dm_name": "测试", 配送员姓名，接单以后会传
     "dm_mobile": "13100001111",  配送员手机号，接单以后会传
     "update_time": 1511789475 更新时间
  }
     */
    public function actionExpressCallBack()
    {
        $postStr = file_get_contents('php://input');//接收微信服务器返回的json消息体
        Yii::warning("dada call back params: " . $postStr);
        if (empty($postStr)) {
            util::end();
        }
        $postData = json_decode($postStr, true);
        if (empty($postData)) {
            Yii::warning("dada callback json_decode error");
        }
        //订单号
        $orderSn = $postData['order_id'];
        $sign = $postData['signature']; //签名验证？没有
        //判断订单是否存在
        $orderInfo = OrderClass::getByOrderSn($orderSn, true);
        if (!$orderInfo) {
            Yii::warning("dada callback error: 订单不不存在: " . $orderSn);
            util::end();
        }

        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {

            $orderStatus = $postData['order_status'];
            $orderSn = $orderInfo->orderSn;
            $sjId = $orderInfo->sjId ?? 0;
            $sendTime = $orderInfo->sendTime;

            switch ($orderStatus) {
                case DadaExpressServices::ORDER_WAIT_ACCEPT:
                    //待接单, 即下单成功： 处理相应的业务逻辑（订单状态变更，消息通知？）

                    break;
                case DadaExpressServices::ORDER_WAIT_PICKUP:
                    //待收货
                    //修改骑手姓名，手机号
                    $dmName = $postData['dm_name'] ?? '';
                    $dmMobile = $postData['dm_mobile'] ?? '';
                    $model = OrderExpressClass::getByOrderSn($orderSn, true);
                    OrderExpressClass::pickUp($model, $dmName, $dmMobile);
                    break;
                case DadaExpressServices::ORDER_SENDING:
                    //配送中
                    OrderExpressClass::updateExpressStatus($orderSn, OrderExpressClass::STATUS_RECEIVE);
                    break;
                case DadaExpressServices::ORDER_COMPLETE:
                    //订单完成
                    OrderService::reach($orderInfo);
                    break;
                case DadaExpressServices::ORDER_CANCEL:
                    //取消
                    $cancel_reason = $postData['cancel_reason']; //取消理由
                    OrderExpressClass::updateExpressStatus($orderSn, OrderExpressClass::STATUS_CANCEL);
                    break;
                case DadaExpressServices::ORDER_WAIT_DISPATCH:
                    //指派单
                    break;
                case DadaExpressServices::ORDER_UNUSUAL_BACK:
                    //妥投异常之物品返回中
                    break;
                case DadaExpressServices::ORDER_UNUSUAL_COMPLETE:
                    //妥投异常之物品返回完成

                    break;
                case DadaExpressServices::RIDER_TO_SHOP:
                    //骑士到店

                    break;
                case DadaExpressServices::ORDER_FAIL:
                    //失败
                    OrderExpressClass::updateExpressStatus($orderSn, OrderExpressClass::STATUS_CANCEL);
                    break;
                default:

            }
            $transaction->commit();
            echo "success";
            util::end();
        } catch (\Exception $e) {
            $transaction->rollBack();
            Yii::error("失败原因：" . $e->getMessage());
        }

    }

    //闪送授权
    public function actionShansAuth()
    {
        $get = Yii::$app->request->get();
        $token = $get['token'] ?? '';
        if ($token !== 'hhb-shans') {
            util::end();
        }
        $url = shans::getAuthUrl(1, 20000000000000969);
        $this->redirect($url);
    }

    //闪送开放者授权跳转
    public function actionShansRedirect()
    {
        $get = Yii::$app->request->get();
        Yii::info("get info" . json_encode($get));
        $code = $get['code'] ?? '';
        $thirdStoreId = $get['thirdStoreId'] ?? 0;
        $state = $get['state'] ?? 0; //shopId
        $data = [
            'shopId' => $state,
            'thirdStoreId' => $thirdStoreId
        ];
        if ($code) {
            //获取token
            $res = shans::getAccessToken($code);
            $res = json_decode($res, true);
            if (is_array($res) && $res['status'] == 200) {
                $accessToken = $res['data']['access_token'] ?? '';
                $refreshToken = $res['data']['refresh_token'] ?? '';
                $expiresIn = $res['data']['expires_in'] ?? 0;
                $expiresIn = date('Y-m-d H:i:s', strtotime("+$expiresIn seconds"));
                $data['accessToken'] = $accessToken;
                $data['refreshToken'] = $refreshToken;
                $data['expiresIn '] = $expiresIn;
                ExpressShanClass::add($data);
            }
        }
    }


}