huahuibao/app-ghs/controllers/TestController.php

<?php

namespace ghs\controllers;

use biz\shop\classes\ShopClass;
use biz\sj\services\MerchantService;
use bizGhs\express\services\DadaExpressServices;
use bizGhs\order\classes\OrderClass;
use bizHd\message\classes\InformAdminClass;
use bizHd\order\services\OrderService;
use bizHd\wx\classes\WxOpenClass;
use bizGhs\express\services\MiniExpressService;
use common\components\dict;
use common\components\lakala\Lakala;
use common\components\miniUtil;
use common\components\orderSn;
use common\components\wxUtil;
use common\components\payUtil;
use Yii;
use common\components\util;

class TestController extends BaseController
{

    public $guestAccess = ['inform', 'notice', 'order-query', 'add-order', 'index', 'get', 'trade-query'];

    public function actionApply()
    {
        $sjNo = '';

        $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',
            'merchant_no' => $sjNo,
            'term_no' => 'C6337694',
            'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
            'lklCertificatePath' => $lklCertificatePath,
        ];
        $data = [

        ];
        $laResource = new Lakala($params);
        $response = $laResource->applyInviteClear($data);
    }

    public function actionGet()
    {
        ini_set('memory_limit', '2045M');
        set_time_limit(0);

        $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
        $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';

        $arr = [
            //['name' => '国兰花尚OK', 'merchantNo' => '82239305992006L', 'wx' => [600913569, 600907053], 'zfb' => '2088820709029782'],
            //['name' => '花掌柜OK', 'merchantNo' => '82240505992000P', 'wx' => [600466131, 600465187], 'zfb' => '2088820656569304'],
            //['name' => '纯彩花艺OK', 'merchantNo' => '82239305992006M', 'wx' => [600922790, 600915407], 'zfb' => '2088820710146836'],
            //['name' => '集美天天鲜花OK', 'merchantNo' => '82239305992006P', 'wx' => [601036538, 601036322], 'zfb' => '2088820726763339'],
            //['name' => '丰行花行OK', 'merchantNo' => '82260205992007P', 'wx' => [601053759, 601052157], 'zfb' => '2088820725885465'],
            //['name' => '独家花行OK', 'merchantNo' => '82239305992006Q', 'wx' => [601049483, 601048223], 'zfb' => '2088820725546555'],
            //['name' => '好多花海沧OK', 'merchantNo' => '82239305992006R', 'wx' => [601052177, 601053735], 'zfb' => '2088820725549695'],
            //['name' => '美天鲜花OK', 'merchantNo' => '82259505992003F', 'wx' => [601062064, 601138175], 'zfb' => '2088820729400990'],
            //['name' => '天天陈江店OK', 'merchantNo' => '82259505992003E', 'wx' => [601060616, 601059382], 'zfb' => '2088820725555368'],
            //['name' => '叶上花OK', 'merchantNo' => '82231805992002G', 'wx' => [601062892, 601062589], 'zfb' => '2088820728763546'],
            //['name' => '好又多（小明）OK', 'merchantNo' => '82239305992006S', 'wx' => [601135715, 601067347], 'zfb' => '2088820729698012'],
            //['name' => '我卖花OK', 'merchantNo' => '82227505992000R', 'wx' => [601177139, 601148755], 'zfb' => '2088820746424032'],
            //['name' => '问境OK', 'merchantNo' => '8226900599200KX', 'wx' => [601299388, 601299453], 'zfb' => '2088820787661843'],
            //['name' => '昱成OK', 'merchantNo' => '8226900599200KY', 'wx' => [601312993, 601325844], 'zfb' => '2088820788900240'],
            //['name' => '杭州斗南', 'merchantNo' => '杭州斗南', 'wx' => [601405963, 601405929], 'zfb' => '2088820793601705'],
            //['name' => '杭州斗南(没用)', 'merchantNo' => '8223310599200AD', 'wx' => [601254682, 601250805], 'zfb' => '2088820782666872'],
            ['name' => '买手很忙', 'merchantNo' => '8227310599200GJ', 'wx' => [601597167, 601595526], 'zfb' => '2088820818930267'],
            ['name' => '七彩花都OK', 'merchantNo' => '8227310599200GF', 'wx' => [601176481, 601148503], 'zfb' => '2088820748594478'],
            //['name' => '十年OK', 'merchantNo' => '82252305992001U', 'wx' => [601285154, 601261795], 'zfb' => '2088820782171763'],
            //['name' => '都市花季OK', 'merchantNo' => '82239305992006U', 'wx' => [601174342, 601147649], 'zfb' => '2088820748507346'],
            //['name' => '花样年华OK', 'merchantNo' => '82260205992007Q', 'wx' => [601134352, 601091710], 'zfb' => '2088820735043444'],
            //['name' => '精茂城OK', 'merchantNo' => '8225840599200TF', 'wx' => [601173752, 601143352], 'zfb' => '2088820746800005'],
            //['name' => '莱漫OK', 'merchantNo' => '82239305992007A', 'wx' => [601288494, 601288166], 'zfb' => '2088820783686611'],
            //['name' => '莱漫(没用)', 'merchantNo' => '82239305992006T', 'wx' => [601134065, 601125595], 'zfb' => '2088820743859918'],
            //['name' => '福州我要花OK', 'merchantNo' => '82239105992007J', 'wx' => [601134030, 601128111], 'zfb' => '2088820745276973'],
            //['name' => '泉城OK', 'merchantNo' => '82239705992004F', 'wx' => [601273270, 601272854], 'zfb' => '2088820784658561'],
            //['name' => '泉城(没用)', 'merchantNo' => '82239705992004E', 'wx' => [601133056, 601133821], 'zfb' => '2088820746111323'],
            //['name' => '美丽花行OK', 'merchantNo' => '82239305992006V', 'wx' => [601155249, 601149712], 'zfb' => '2088820747673312'],
            //['name' => '三叶OK', 'merchantNo' => '82236805992001Y', 'wx' => [601152233, 601151024], 'zfb' => '2088820747556725'],
            //['name' => '花大苪OK', 'merchantNo' => '8227310599200GG', 'wx' => [601174221, 601165136], 'zfb' => '2088820751181377'],
            //['name' => '十堰天天鲜花OK', 'merchantNo' => '82252305992001S', 'wx' => [601171131, 601170642], 'zfb' => '2088820750844626'],
            //['name' => '珑松花卉OK', 'merchantNo' => '82260205992007S', 'wx' => [601176093, 601174262], 'zfb' => '2088820754742492'],
            //['name' => '惠雅鲜花OK', 'merchantNo' => '82260205992007R', 'wx' => [601173390, 601174002], 'zfb' => '2088820753174540'],
            //['name' => '锦绣花卉OK', 'merchantNo' => '82252305992001T', 'wx' => [601176719, 601176660], 'zfb' => '2088820754751663'],
            //['name' => '祥瑞鲜花同安店OK', 'merchantNo' => '82239305992006W', 'wx' => [601178350, 601177795], 'zfb' => '2088820755715024'],
            //['name' => '祥瑞鲜花翔安店OK', 'merchantNo' => '82239305992006X', 'wx' => [601178260, 601178199], 'zfb' => '2088820754481553'],
            //['name' => '初见花季OK', 'merchantNo' => '82239305992006Y', 'wx' => [601178998, 601179605], 'zfb' => '2088820757223312'],
            //['name' => '荣发鲜花OK', 'merchantNo' => '82242705992000D', 'wx' => [601179681, 601179180], 'zfb' => '2088820756926593'],
            //['name' => '花千朵（多多）OK', 'merchantNo' => '82239305992006Z', 'wx' => [601223474, 601208096], 'zfb' => '2088820766783276'],
            //['name' => '花悠星OK', 'merchantNo' => '8225810599200NH', 'wx' => [601228194, 601227691], 'zfb' => '2088820774587446'],
            //['name' => '花悠星(没用)', 'merchantNo' => '8225810599200NG', 'wx' => [601223630, 601210952], 'zfb' => '2088820767072874'],
            //['name' => '源花汇OK', 'merchantNo' => '82222105992004A', 'wx' => [601221944, 601214269], 'zfb' => '2088820770594246'],
            //['name' => '源花汇2(没用)', 'merchantNo' => '8227310599200GD', 'wx' => [601136305, 601067016], 'zfb' => '2088820729832744'],
        ];
        $new = [];
        foreach ($arr as $item) {
            $wx = $item['wx'];
            $zfb = $item['zfb'];
            $merchantNo = $item['merchantNo'];
            $name = $item['name'] . ' ' . $merchantNo;
            $group = [];
            foreach ($wx as $oneWx) {
                $params = [
                    'appid' => 'OP00002119',
                    'serial_no' => '018b08cfddbd',
                    'merchant_no' => $merchantNo,
                    'term_no' => 'C6337694',
                    'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
                    'lklCertificatePath' => $lklCertificatePath,
                ];
                $data = [
                    'subMerchantId' => $oneWx,
                    'tradeMode' => 'WECHAT',
                ];
                $laResource = new Lakala($params);
                $response = $laResource->openStateQuery($data);
                $statusName = '出错了';
                if ($response['retCode'] == '000000') {
                    $checkResult = $response['respData']['checkResult'] ?? '';
                    $statusName = '未确认';
                    if ($checkResult == 'AUTHORIZE_STATE_AUTHORIZED') {
                        $statusName = '已确认';
                    }
                }
                $group[] = '微信 ' . $oneWx . ' ' . $statusName;
            }

            $params = [
                'appid' => 'OP00002119',
                'serial_no' => '018b08cfddbd',
                'merchant_no' => $merchantNo,
                'term_no' => 'C6337694',
                'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
                'lklCertificatePath' => $lklCertificatePath,
            ];
            $data = [
                'subMerchantId' => $zfb,
                'tradeMode' => 'ALIPAY',
            ];
            $laResource = new Lakala($params);
            $response = $laResource->openStateQuery($data);
            $statusName = '出错了';
            if ($response['retCode'] == '000000') {
                $checkResult = $response['respData']['checkResult'] ?? '';
                $statusName = '未确认';
                if ($checkResult == 'AUTHORIZED') {
                    $statusName = '已确认';
                }
            }
            $group[] = '支付宝 ' . $zfb . ' ' . $statusName;
            $new[] = ['name' => $name, 'status' => $group];
        }
        echo '<pre>';
        print_r($new);
        die;
    }

    //交易查询 ssh 20231021
    public function actionTradeQuery()
    {
        $shopId = 795;
        $shop = ShopClass::getById($shopId, true);
        if (empty($shop)) {
            util::stop('没有找到门店');
        }
        $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',
            'merchant_no' => $shop->lklSjNo,
            'term_no' => $shop->lklScanTermNo,
            'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
            'lklCertificatePath' => $lklCertificatePath,
        ];
        $laResource = new Lakala($params);
        $queryParams = [
            'tradeNo' => '20231021110113130266215211135188',
        ];
        $response = $laResource->query($queryParams, 1);
        if (isset($response['code']) && $response['code'] == 'BBS00000') {
            $capitalType = dict::getDict('capitalType', 'hdPurchaseClear', 'id');
            $connection = Yii::$app->db;
            $transaction = $connection->beginTransaction();
            try {
                util::stop();
                $wxPay = dict::getDict('payWay', 'wxPay');
                //支付成功后续流程
                $attach = '';
                $payer_amount = $response['resp_data']['payer_amount'] ?? 0;
                $orderSn = 'CL28681399';
                $totalFee = $payer_amount / 100;
                $transactionId = '20231021110113130266215211135188';
                payUtil::thirdPay($wxPay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
                $transaction->commit();
                echo 'OK';
            } catch (\Exception $e) {
                $transaction->rollBack();
                Yii::error("失败原因：" . $e->getMessage());
            }
        }
    }

    public function actionAliRun2()
    {
        $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',
            'merchant_no' => '82240505992000N',
            'term_no' => 'C6337694',
            'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
            'lklCertificatePath' => $lklCertificatePath,
        ];
        $outTradeNo = orderSn::getPurchaseSn();
        $notifyUrl = Yii::$app->params['hdHost'] . "/notice/pay-callback";
        $currentCapitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
        $aliParams = [
            'orderSn' => $outTradeNo,
            'amount' => 0.16,
            'capitalType' => $currentCapitalType,
            'notifyUrl' => $notifyUrl,
        ];
        $laResource = new Lakala($params);
        $response = $laResource->driveAliPay($aliParams);
        if ($response && isset($response['cmdRetCode']) && $response['cmdRetCode'] == 'GLOBAL_SUCCESS') {
            echo '<pre>';
            echo "下单成功<br/>";
            print_r($response);
        } else {
            echo '<pre>';
            echo "下单失败<br/>";
            print_r($response);
        }
    }

    public function actionAliRun3()
    {
        $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',
            'merchant_no' => '82240505992000N',
            'term_no' => 'C6337694',
            'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
            'lklCertificatePath' => $lklCertificatePath,
        ];
        $laResource = new Lakala($params);
        $outTradeNo = orderSn::getPurchaseSn();
        $notifyUrl = Yii::$app->params['hdHost'] . "/notice/pay-callback";
        $currentCapitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
        $wxParams = [
            'orderSn' => $outTradeNo,
            'amount' => 0.16,
            'capitalType' => $currentCapitalType,
            'notifyUrl' => $notifyUrl,
        ];
        $response = $laResource->driveWxPay($wxParams);
        if ($response && isset($response['cmdRetCode']) && $response['cmdRetCode'] == 'GLOBAL_SUCCESS') {
            echo '<pre>';
            echo "下单成功<br/>";
            print_r($response);
        } else {
            echo '<pre>';
            echo "下单失败<br/>";
            print_r($response);
        }
    }

    //dada 城市code
    public function actionDadaCityCode()
    {
        $res = dada::getCityCode(0);
        util::success($res);
    }

    //理由
    public function actionDadaReasons()
    {
        $res = dada::getCancelReason(0);
        util::success($res);
    }

    //达达 ：下单
    public function actionDadaAddOrder()
    {
        $orderSn = 'XSD_CS26316851';
        $orderInfo = OrderClass::getByOrderSn($orderSn);
        $res = DadaExpressServices::addOrder($orderInfo);
        util::success($res);
    }

    //重发快递
    public function actionDadaReAdd()
    {
        $orderSn = 'XSD_CS26316851';
        $orderInfo = OrderClass::getByOrderSn($orderSn);
        $res = DadaExpressServices::reAddOrder($orderInfo);
        util::success($res);
    }

    //达达状态查询
    public function actionDadaOrderStatus()
    {
        $orderSn = 'XSD_CS26316851';
        $res = DadaExpressServices::statusOrder($orderSn);
        util::success($res);
    }

    //达达取消下单
    public function actionDadaCancelOrder()
    {
        $orderSn = 'XSD_CS26316851';
        $res = DadaExpressServices::cancelOrder($orderSn, 1);
        util::success($res);
    }

    //获取已支持的配送公司列表接口
    public function actionGetAllDelivery()
    {
        $data = MiniExpressService::getAllImmeDelivery();
        util::success($data);
    }

    //即时配送
    /*
     * Array
(
    [resultcode] => 0
    [resultmsg] => OK
    [shop_list] => Array
        (
            [0] => Array
                (
                    [shopid] => 1588714266
                    [delivery_id] => SFTC
                    [audit_result] => 0
                    [create_time] => 1612172838
                    [remark] =>
                    [delivery_name] => 顺丰同城急送
                )

        )
)
     */
    public function actionGetBindAccount()
    {
        $merchant = WxOpenClass::getGhsWxInfo();
        $isOpen = 2;
        $r = miniUtil::getBindAccount($merchant, $isOpen);
        dd($r);
    }


    //下单 (沙箱)

    /**
     * Array
     * (
     * [resultcode] => 0
     * [resultmsg] => ok
     * [fee] => 10
     * [waybill_id] => test_shop_id1612365974_waybillid
     * [order_status] => 101
     * [dispatch_duration] => 300
     * )
     */
    public function actionCreateWaybill()
    {
        $merchant = WxOpenClass::getGhsWxInfo();
        $isOpen = 2;
        $shopId = 'test_shop_id';
        $shopOrderId = 'test_shop_id' . time();
        $appSecret = 'test_app_secrect';
        $data = [
            'shopid' => $shopId,
            'shop_order_id' => $shopOrderId,
            'shop_no' => '1',
            'delivery_sign' => miniUtil::getDeliverySign($shopId, $shopOrderId, $appSecret), //，则delivery_sign=SHA1(shopid + shop_order_id + AppSecret)
            'delivery_id' => "TEST",
            'openid' => 'oGKMp45YLxewOTWEbpMFzWoVqdW0',
            'sender' => [
                'name' => 'test',
                'city' => '厦门市',
                'address' => '思明区',
                'address_detail' => '软件园二期',
                'phone' => '19959271111',
                'lng' => 118.134343,
                'lat' => 24.483566,
                'coordinate_type' => 0,
            ],
            'receiver' => [
                'name' => 'test',
                'city' => '厦门市',
                'address' => '思明区',
                'address_detail' => '软件园二期',
                'phone' => '19959271111',
                'lng' => 118.134343,
                'lat' => 24.493566,
                'coordinate_type' => 0,
            ],
            'cargo' => [
                'goods_value' => 1,
                'goods_weight' => 0.1,
                'cargo_first_class' => '鲜花',
                'cargo_second_class' => '鲜花',
            ],
            'order_info' => [
                'order_type' => 0,
            ],
            'shop' => [
                'wxa_path' => '/shop',
                'img_url' => 'http://www.baidu.com/test.png',
                'goods_name' => 'test',
                'goods_count' => 1,
            ],

        ];

        $r = miniUtil::addOrder($data, $merchant, $isOpen);
        dd($r);

    }

    //获取运单数据

    /**
     * Array
     * (
     * [resultcode] => 0
     * [resultmsg] => ok
     * [order_status] => 101
     * [agent_info] => Array
     * (
     * )
     *
     * [waybill_id] => test_shop_id1612365974_waybillid
     * [rider_name] =>
     * [rider_phone] =>
     * [order_token] => NsXweKCKhSyAEIhAdnX3TYZsVDES0-t-tymHDONG0MpRsF31dQvVxiP_JJvLFaKS-kwXuOG3D0hzKkl7o-gzew
     * )
     */
    public function actionGetOrder()
    {
        $shopId = 'test_shop_id';
        $shopOrderId = 'test_shop_id1612365974';
        $appSecret = 'test_app_secrect';
        $merchant = WxOpenClass::getGhsWxInfo();
        $isOpen = 2;
        $data = [
            'shopid' => $shopId,
            'shop_order_id' => $shopOrderId,
            'shop_no' => '1',
            'delivery_sign' => MiniExpressService::getDeliverySign($shopId, $shopOrderId, $appSecret),
        ];
        $r = miniUtil::getOrder($data, $merchant, $isOpen);
        dd($r);
    }


    //沙盒 更新快递状态
    public function actionMockUpdateOrder()
    {
        $merchant = WxOpenClass::getGhsWxInfo();
        $isOpen = 2;
        /**
         * {
         * "shopid": "test_shop_id",
         * "shop_order_id": "xxxxxxxxxxx",
         * "waybill_id": "xxxxxxxxxxxxx",
         * "action_time": 12345678,
         * "order_status": 101,
         * "action_msg": "",
         * }
         */
        $shopId = 'test_shop_id';
        $shopOrderId = 'test_shop_id1612365974';
        $data = [
            'shop_order_id' => $shopOrderId,
            "shopid" => $shopId,
            "action_time" => time(),
            "order_status" => 302,
            'action_msg' => '状态变更',
        ];
        $r = miniUtil::mockUpdateOrder($data, $merchant, $isOpen);
        dd($r);
    }

    public function actionTest()
    {


    }


    //新增订单
    public function actionAddOrder()
    {
        $dada = Yii::getAlias("@vendor/dada/");
        require_once $dada . 'api/addOrderApi.php';
        require_once $dada . 'client/dadaRequestClient.php';
        require_once $dada . 'client/dadaResponse.php';
        require_once $dada . 'config/config.php';
        require_once $dada . 'model/orderModel.php';

        // isOnline 判断是否是测试环境，会有不同的域名等
        $isOnline = false;
        $sourceId = 1000000;
        // 初始化一个config
        $config = new \Config($sourceId, $isOnline);

        $orderModel = new \OrderModel();
        $orderModel->setShopNo('11047059');
        $orderModel->setOriginId('2018091100000002');
        $orderModel->setCityCode('021');
        $orderModel->setCargoPrice(10);
        $orderModel->setIsPrepay(0);
        $orderModel->setReceiverName('测试达达');
        $orderModel->setReceiverAddress('上海市崇明岛');
        $orderModel->setReceiverLat(31.63);
        $orderModel->setReceiverLng(121.41);
        $orderModel->setReceiverPhone('18588888888');
        $orderModel->setCallback('http://api.b.huaml.com/data/request');

        // api主要有2个参数，一个是url， 一个是业务参数
        $addOrderApi = new \AddOrderApi(json_encode($orderModel));

        $dada_client = new \DadaRequestClient($config, $addOrderApi);
        $resp = $dada_client->makeRequest();
        echo json_encode($resp);
    }

    //订单详情查询
    public function actionOrderQuery()
    {
        $dada = Yii::getAlias("@vendor/dada/");
        require_once $dada . 'api/OrderQueryApi.php';
        require_once $dada . 'client/dadaRequestClient.php';
        require_once $dada . 'client/dadaResponse.php';
        require_once $dada . 'config/config.php';
        require_once $dada . 'model/orderModel.php';

        // isOnline 判断是否是测试环境，会有不同的域名等
        $isOnline = false;
        $sourceId = 1000000;
        // 初始化一个config
        $config = new \Config($sourceId, $isOnline);

        $orderModel = new \OrderModel();
        $orderModel->setOrderId('2018091100000002');

        // api主要有2个参数，一个是url， 一个是业务参数
        $addOrderApi = new \OrderQueryApi(json_encode($orderModel));

        $dada_client = new \DadaRequestClient($config, $addOrderApi);
        $resp = $dada_client->makeRequest();
        echo json_encode($resp);
    }

    public function actionFocus()
    {
        $name = '花卉宝';
        if (getenv('YII_ENV') == 'dev') {
            $name = '花美灵';
        }
        $merchant = MerchantService::getByCondition(['name' => $name]);
        $list = wxUtil::getSubscribeUserList($merchant);
        dd($list);
    }

    //宝贝售出提醒 ssh 2020.1.30
    public function actionInform()
    {
        $merchant = MerchantService::getMerchantById(12362);
        $order = OrderService::getById(214810);
        InformAdminClass::sendComplete($order);
    }

    public function actionNotice()
    {
        $data = ['messageType' => 'inform', 'informWay' => 'wx', 'userType' => 'admin', 'id' => 6, 'mobile' => '15280215347'];
        $producer = Yii::$app->rabbitmq->getProducer('informProducer');
        echo '<pre>';
        print_r($data);
        $msg = serialize($data);
        $r = $producer->publish($msg, 'informExchange', 'informRoute');
    }

}