<?php

namespace addons\WangDianTong\console\controllers;

use addons\WangDianTong\common\helper\EmojiHelper;
use addons\WangDianTong\common\listeners\OrderCloseListener;
use addons\WangDianTong\common\listeners\OrderCreateListener;
use addons\WangDianTong\common\listeners\OrderPaidListener;
use addons\WangDianTong\common\listeners\OrderRefundCancelListener;
use addons\WangDianTong\common\listeners\OrderRefundFinishListener;
use addons\WangDianTong\common\listeners\OrderRefundListener;
use addons\WangDianTong\common\listeners\OrderTakeDeliveryListener;
use addons\WangDianTong\common\models\AddonsWangDianTongLogisticsCompany;
use addons\WangDianTong\common\service\LogisticsSyncQueryService;
use addons\WangDianTong\common\service\OrderSyncFailService;
use common\models\common\Express;
use yii\console\Controller;

class TestController extends Controller
{

    /**
     * @return void
     * @throws \Exception
     */
    public function actionTest()
    {
        var_dump(13);
        (new OrderCreateListener())->async_handle(['order_ids' => [461], 'mall_id' => 1]);
//        (new OrderTakeDeliveryListener())->async_handle(['id' => 5818, 'mall_id' => 1]);
//        (new OrderCloseListener())->async_handle(['id' => 5818, 'mall_id' => 1]);
//        (new OrderPaidListener())->async_handle(['id' => 5857, 'mall_id' => 1]);
//        var_dump(file_exists());
//        (new OrderRefundListener())->async_handle(['id' => 11]);
//        (new \addons\WangDianTong\common\listeners\OrderRefundCancelListener())->handleSync(['id' => 40]);

        try {
//            (new LogisticsSyncQueryService())->sync();
//            (new OrderSyncFailService())->compensate();
//            var_dump(EmojiHelper::convert('何🌹🌹🌹'));
//            \Yii::$app->services->rabbitMq->push(\common\enums\RabbitMqEnum::EXCHANGE_ORDER, \common\enums\RabbitMqEnum::ORDER_QUEUE, ['order_detail_id' => 14, 'id' => 3],
//                self::class, 'async_handle');
        }catch (\Exception $e) {
            var_dump($e->getTrace());
        }
//        (new OrderSyncFailService())->compensate();
//        (new OrderRefundCancelListener())->handleSync(['id' => 62, 'mall_id' => 1]);
//        (new OrderRefundCancelListener())->handleSync(['id' => 59, 'mall_id' => 1]);
//        (new OrderRefundListener())->async_handle(['id' => 200, 'mall_id' => 1]);
//        (new OrderRefundCancelListener())->handleSync(['id' => 82, 'mall_id' => 1]);
//        (new OrderRefundFinishListener())->handleSync(['id' => 83, 'mall_id' => 1]);

        /*
        foreach (AddonsWangDianTongLogisticsCompany::find()->each() as $each) {
            $match = Express::find()->where(['like', 'name', trim($each->erp_name)])->asArray()->all();
            if (!empty($match)) {
                $each->express_id = $match[0]['id'];
                $each->express_name = $match[0]['name'];
                $each->express_code = $match[0]['code'];
                $each->save();
            }
        }
         */

        /*
        $file = \Yii::$app->basePath . "/../wangdiantong-logistics.txt";
        $content = file_get_contents($file);
        $arr = explode("\n", $content);
        $express_data = [];
        foreach ($arr as $key => $item) {
            $row = explode(":", $item);
            $match = Express::find()->where(['like', 'name', trim($row[1])])->asArray()->all();
            $express_data[$key] = [
                'created_at'    => time(),
                'updated_at'    => time(),
                'erp_type'      => $row[0],
                'erp_name'      => trim($row[1]),
            ];
            if (!empty($match)) {
//                $express_data[$key]['express_id']   = $match[0]['id'];
//                $express_data[$key]['express_name'] = $match[0]['name'];
//                $express_data[$key]['express_code'] = $match[0]['code'];
            }
        }
        AddonsWangDianTongLogisticsCompany::find()->createCommand()
            ->batchInsert(AddonsWangDianTongLogisticsCompany::tableName(),
                array_keys($express_data[0]),
                $express_data)
            ->execute();
        */
    }
}