aklast/frontendApi/modules/v1/controllers/ShopController.php

<?php
/**
 * Created by PhpStorm.
 * User: leo
 * Date: 2018/2/24
 * Time: 下午12:48
 */

namespace frontendApi\modules\v1\controllers;

use common\helpers\Date;
use common\helpers\Form;
use common\helpers\LoggerTool;
use common\helpers\Logistics;
use common\helpers\Tool;
use common\helpers\user\Info;
use common\models\ApproachOrder;
use common\models\ApproachOrderGoods;
use common\models\DecOrder;
use common\models\forms\ApproachOrderForm;
use common\models\forms\DeclarationForm;
use common\models\forms\OrderForm;
use common\models\Order;
use common\models\OrderGoods;
use common\models\ReceiveAddress;
use common\models\Region;
use common\models\ShopGoods;
use common\models\User;
use common\models\UserBonus;
use common\models\UserWallet;
use yii\data\Pagination;
use yii\db\Query;
use yii\web\HttpException;

class ShopController extends BaseController {

    public $modelClass = DecOrder::class;

    const TRANSACTION_TYPE_PAYMENT = 'payment';

    /**
     * 商品列表
     * @return mixed
     * @throws \yii\web\HttpException
     */
    public function actionIndex() {
        $condition = ' AND STATUS=1 AND (FIND_IN_SET(2,GIFT_TYPE)>0';
//        $isStudio = User::getEnCodeInfo(\Yii::$app->user->id)['IS_STUDIO'];
//        if($isStudio==1){
//            $condition.= " OR FIND_IN_SET(4,GIFT_TYPE)>0";
//        }
        $condition.=")";

        $data = ShopGoods::lists($condition, [], [
            'orderBy' => 'SORT ASC,CREATED_AT DESC',
            'from' => ShopGoods::tableName(),
        ]);
        foreach ($data['list'] as $key => $value) {
            $data['list'][$key]['DISCOUNT'] = $value['SELL_DISCOUNT']*100;
            $data['list'][$key]['CATE'] = ShopGoods::GOODS_TYPE[$value['CATE_ID']]['name'] ?? '';
        }
        return static::notice($data);
    }

    /**
     * 获取商品详情
     * @return mixed
     * @throws \yii\web\HttpException
     */
    public function actionGoodsDetail(){
        $id = \Yii::$app->request->get('id');
        $data = null;
        if($id){
            $data = ShopGoods::findOneAsArray('ID=:ID AND STATUS=1', [':ID'=>$id]);
        }
        return static::notice($data);
    }

    /**
     * 购物车订单展示
     * @throws \yii\web\HttpException
     */
    public function actionShowCart(){
        $userId = \Yii::$app->user->id;
        $payList = ShopGoods::payTypes();
        $allAddress = ReceiveAddress::findAllAsArray('USER_ID=:USER_ID', [':USER_ID'=>$userId]);
        if($allAddress) {
            foreach ($allAddress as $key => $row) {
                $allAddress[$key]['PROVINCE_NAME'] = Region::getCnName($row['PROVINCE']);
                $allAddress[$key]['CITY_NAME'] = Region::getCnName($row['CITY']);
                $allAddress[$key]['COUNTY_NAME'] = Region::getCnName($row['COUNTY']);
            }
        }
        $userBalance = [
            'points' => 0,
            'cash' => 0,
            'exchange' => 0
        ];
        if ($userBonusResult = UserBonus::findOneAsArray(['USER_ID' => $userId])) {
            $userBalance['points'] = $userBonusResult['RECONSUME_POINTS'];
            $userBalance['exchange'] = $userBonusResult['EXCHANGE_POINTS'];
        }
        if ($userCashResult = UserWallet::findOneAsArray(['USER_ID' => $userId])) {
            $userBalance['cash'] = $userCashResult['CASH'];
        }
        return static::notice(['payList'=>$payList,'allAddress'=>$allAddress,'userBalance'=>$userBalance]);
    }

    /**
     * 确认订单
     */
    public function actionSureOrder(){
        if (\Yii::$app->request->isPost) {
            $formModel = new OrderForm();
            $formModel->scenario = 'userOrder';
            $formModel->remark = '复销备注';
            $post = \Yii::$app->request->post();
            $post['type'] = DeclarationForm::TYPE_FX;
            if ($formModel->load($post, '') && $formModel->add()) {
                return static::notice('购物成功');
            } else {
                return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
            }
        }
    }

    /**
     * 订单支付成功
     * @throws \yii\web\HttpException
     */
    public function actionPaySuccess(){
        $orderSn = \Yii::$app->request->get('orderSn');
        $data = null;
        if($orderSn){
            $data = Order::findOneAsArray('SN=:SN', [':SN'=>$orderSn]);
        }
        return static::notice($data);
    }

    /**
     * 我的报单
     * @return mixed
     * @throws \yii\web\HttpException
     */
    public function actionDecOrderList() {
        $condition = ' AND USER_ID=:USER_ID AND IS_DEL=0';
        $params[':USER_ID'] = \Yii::$app->user->id;
        $data = DecOrder::lists($condition, $params, [
            'select' => 'DO.*,U.USER_NAME USER_NAME,U.REAL_NAME REAL_NAME,RU.USER_NAME REC_USER_NAME,RU.REAL_NAME REC_REAL_NAME,CU.USER_NAME CON_USER_NAME,CU.REAL_NAME CON_REAL_NAME,OG.*',
            'orderBy' => 'DO.CREATED_AT DESC',
            'from' => DecOrder::tableName() . ' AS DO',
            'join' => [
                ['LEFT JOIN', User::tableName() . ' AS U', 'DO.TO_USER_ID=U.ID'],
                ['LEFT JOIN', User::tableName() . ' AS RU', 'DO.REC_USER_ID=RU.ID'],
                ['LEFT JOIN', User::tableName() . ' AS CU', 'DO.CON_USER_ID=CU.ID'],
                ['LEFT JOIN', OrderGoods::tableName() . ' AS OG', 'OG.ORDER_SN=DO.ORDER_SN'],
            ],
        ]);
        return static::notice($data);
    }

//    /**
//     * 我的订单
//     * @return mixed
//     * @throws \yii\web\HttpException
//     */
//    public function actionOrderList() {
//        $uname = Info::getUserNameByUserId(\Yii::$app->user->id);
//        $condition = " AND IS_DELETE=0 AND ORDER_TYPE='FX' AND (USER_ID=:USER_ID OR CREATE_USER='$uname')";
//        $params[':USER_ID'] = \Yii::$app->user->id;
//        $data = Order::lists($condition, $params, [
//            'select' => 'O.*,U.REAL_NAME,OG.*',
//            'orderBy' => 'O.CREATED_AT DESC',
//            'from' => Order::tableName() . ' AS O',
//            'join' => [
//                ['LEFT JOIN', User::tableName() . ' AS U', 'U.ID=O.USER_ID'],
//                ['LEFT JOIN', OrderGoods::tableName() . ' AS OG', 'OG.ORDER_SN=O.SN'],
//            ],
//        ]);
//        foreach ($data['list'] as $key => $value) {
//            if($value['ORDER_TYPE']=='ZC'){
//                $data['list'][$key]['ORDER_TYPE'] = '首单';
//            }else{
////                $data['list'][$key]['ORDER_TYPE'] = in_array($value['PAY_TYPE'], ['cash', 'paystack']) ? '复消': '积分';
//                $data['list'][$key]['ORDER_TYPE'] = '复消';
//            }
//            //$data['list'][$key]['PROVINCE_NAME'] = $value['PROVINCE'] ? Region::getCnName($value['PROVINCE']) : '';
//           //$data['list'][$key]['CITY_NAME'] = $value['CITY'] ? Region::getCnName($value['CITY']) : '';
//            //$data['list'][$key]['COUNTY_NAME'] = $value['COUNTY'] ? Region::getCnName($value['COUNTY']) : '';
//            $data['list'][$key]['PAY_AT'] = Date::convert($value['PAY_AT'],'Y-m-d H:i:s');
//            $data['list'][$key]['PAY_TYPE'] = $value['PAY_TYPE'] == 'cash' ? '消费点数' : ($value['PAY_TYPE'] == 'exchange' ? '兑换点数' : '复消点数');
//        }
//        return static::notice($data);
//    }

    /**
     * 我的订单
     * @return mixed
     * @throws \yii\web\HttpException
     */
    public function actionOrderList() {
        $uname = Info::getUserNameByUserId(\Yii::$app->user->id);
        $condition = " O.IS_DELETE = 0 AND O.ORDER_TYPE='FX' AND (O.USER_ID=:USER_ID OR O.CREATE_USER='$uname')";
        $params[':USER_ID'] = \Yii::$app->user->id;
        $orderQuery = Order::find()
            ->alias('O')
            ->where($condition, $params)
            ->select('O.*,U.REAL_NAME,OG.REAL_PRICE,OG.BUY_NUMS,OG.SKU_CODE,OG.GOODS_TITLE,OG.REAL_PV,OG.ORDER_SN,OG.GOODS_ID')
            ->join('LEFT JOIN', User::tableName() . ' AS U', 'U.ID=O.USER_ID')
            ->join('LEFT JOIN', OrderGoods::tableName() . ' AS OG', 'OG.ORDER_SN=O.SN')
            ->orderBy('O.CREATED_AT DESC');

        // 订单中间表只查询待支付和支付失败的订单
        $params[':NOT_PAID'] = \Yii::$app->params['orderStatus']['notPaid']['value'];   // 待支付
        $params[':FAIL_PAID'] = \Yii::$app->params['orderStatus']['failPaid']['value'];   // 支付失败
        $orderStandardQuery = ApproachOrder::find()
            ->alias('O')
            ->where($condition . ' AND (O.STATUS = :NOT_PAID OR O.STATUS = :FAIL_PAID)', $params)
            ->select('O.*,U.REAL_NAME,OG.REAL_PRICE,OG.BUY_NUMS,OG.SKU_CODE,OG.GOODS_TITLE,OG.REAL_PV,OG.ORDER_SN,OG.GOODS_ID')
            ->join('LEFT JOIN', User::tableName() . ' AS U', 'U.ID=O.USER_ID')
            ->join('LEFT JOIN', ApproachOrderGoods::tableName() . ' AS OG', 'OG.ORDER_SN=O.SN')
            ->orderBy('O.CREATED_AT DESC');

        $queryAll = $orderQuery->union($orderStandardQuery, true);
        $query = (new Query())->from(['Q' => $queryAll])->select('Q.*')->distinct()->orderBy(['CREATED_AT' => SORT_DESC]);

        $totalCount = $query->count();
        $pagination = new Pagination(['totalCount' => $totalCount, 'pageSize' => \Yii::$app->request->get('pageSize')]);
        $lists = $query->offset($pagination->offset)->limit($pagination->limit)->all();

        $data = [
            'list' => $lists,
            'currentPage'=>$pagination->page,
            'totalPages'=>$pagination->pageCount,
            'startNum' => $pagination->page * $pagination->pageSize + 1,
            'totalCount' => $pagination->totalCount,
            'pageSize' => $pagination->pageSize,
        ];

        foreach ($data['list'] as $key => $value) {
            $data['list'][$key]['ORDER_TYPE'] = $value['ORDER_TYPE'] == 'ZC' ? '首单' : '复消';
            $data['list'][$key]['PAY_AT'] = $value['PAY_AT'] ? Date::convert($value['PAY_AT'],'Y-m-d H:i:s') : '';
            $data['list'][$key]['PAY_TYPE'] = ShopGoods::payTypes()[$value['PAY_TYPE']]['name'] ?? '';
            $data['list'][$key]['STATUS'] = \Yii::$app->params['orderStatus'][$value['STATUS']]['label'] ?? '';
        }

        return $data;
    }

    /**
     * 会员复消
     */
    public function actionReconsume() {
        $isStudio = User::getEnCodeInfo(\Yii::$app->user->id)['IS_STUDIO'];
        $condition = " AND STATUS=1";
        if($isStudio==1){
            $condition .= " AND  (FIND_IN_SET(4,GIFT_TYPE)>0)";
        }
//        $condition.= ")";

        $data = ShopGoods::lists($condition, [], [
            'orderBy' => 'SORT ASC,CREATED_AT DESC',
            'from' => ShopGoods::tableName(),
        ]);
        foreach ($data['list'] as $key => $value) {
            $data['list'][$key]['DISCOUNT'] = $value['SELL_DISCOUNT']*100;
        }
        return static::notice($data);
    }

    /**
     * 帮会员复消购物车
     * @throws \yii\web\HttpException
     */
    public function actionReconsumeCart(){
        $userId = \Yii::$app->user->id;
        $payList = ['cash'=>['name'=>'消费点数支付'],];
        $userBalance = [
            'points' => 0,
            'cash' => 0
        ];
        if ($userBonusResult = UserBonus::findOneAsArray(['USER_ID' => $userId])) {
            $userBalance['points'] = $userBonusResult['RECONSUME_POINTS'];
        }
        if ($userCashResult = UserWallet::findOneAsArray(['USER_ID' => $userId])) {
            $userBalance['cash'] = $userCashResult['CASH'];
        }
        return static::notice(['payList'=>$payList,'userBalance'=>$userBalance]);
    }

    /**
     * 帮会员复消确认订单
     */
    public function actionReconsumeSureOrder(){
        if (\Yii::$app->request->isPost) {
            $formModel = new OrderForm();
            $formModel->scenario = 'reconsumeOrder';
            $formModel->remark = '帮会员复销';
            $post = \Yii::$app->request->post();
            $post['type'] = DeclarationForm::TYPE_FX;
            if ($formModel->load($post, '') && $formModel->reconsumeAdd()) {
                return static::notice('帮会员复消成功');
            } else {
                return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
            }
        }

        return static::notice('无效请求');
    }

    /**
     * 确认订单
     */
    public function actionSureApproachOrder(){
        if (\Yii::$app->request->isPost) {
            $formModel = new ApproachOrderForm();
            $formModel->scenario = 'userOrder';
            $formModel->remark = '复销备注';
            $post = \Yii::$app->request->post();
            $post['type'] = DeclarationForm::TYPE_FX;
            if ($formModel->load($post, '') && $order = $formModel->add()) {
                return static::notice($order);
            } else {
                return static::notice(Form::formatErrorsForApi($formModel->getErrors()),400);
            }
        }

        return static::notice('无效请求');
    }

    /**
     * iPay88支付成功的webhook.
     * @throws HttpException
     * @throws \Exception
     */
    public function actionVerifyApproachOrder() {
        // iPay88支付成功的webhook.
        $rawPostData = file_get_contents('php://input');
//        $data = [];
//        if (strlen($rawPostData) > 0) {
//            $rawPostArray = explode('&', $rawPostData);
//            foreach ($rawPostArray as $raw) {
//                $raw = explode('=', $raw);
//                if (count($raw) == 2)
//                    $data[$raw[0]] = urldecode($raw[1]);
//            }
//        }

        $data = json_decode($rawPostData, true);

        // 支付webhook回调日志
        Tool::approachOrderCall($data);

        try {
            // 订单状态
            $orderStatus = ($data['Status'] == '1') ? \Yii::$app->params['orderStatus']['paid']['value'] : \Yii::$app->params['orderStatus']['failPaid']['value'];

            $oderSn = $data['RefNo'] ?? '';

            $formModel =  new ApproachOrderForm();
            $formModel->scenario = 'verifyPay';
            $load = [
                'sn' => $oderSn,
                'scenario' => 'verifyPay',
                'status' => $orderStatus,
                'note' => [
                    'MerchantCode' => $data['MerchantCode'],
                    'PaymentId' => $data['PaymentId'],
                    'status' => $data['Status'],
                    'Signature' => $data['Signature'],
                    'Currency' => $data['Currency'],
                    'Amount' => $data['Amount'],
                    'TransId' => $data['TransId'],
                    'TranDate' => $data['TranDate'],
                    'BankMID' => $data['BankMID'],
                    'CCNo' => $data['CCNo'],

                ],
            ];

            if ($formModel->load($load, '') && $result = $formModel->verifyPayOnline()) {
                LoggerTool::info($result);

                // 发送物流接口
                $order = Order::find()
                    ->alias('O')
                    ->where('SN=:SN', [':SN' => $oderSn])
                    ->select('O.*,U.REAL_NAME,OG.REAL_PRICE,OG.BUY_NUMS,OG.SKU_CODE,OG.GOODS_TITLE,OG.REAL_PV')
                    ->join('LEFT JOIN', User::tableName() . ' AS U', 'U.ID=O.USER_ID')
                    ->join('LEFT JOIN', OrderGoods::tableName() . ' AS OG', 'OG.ORDER_SN=O.SN')
                    ->asArray()
                    ->one();

                $logistics = new Logistics();
                $response = $logistics->createOrder($order);
                LoggerTool::info($response);

                return http_response_code(200);
            } else {
                LoggerTool::error(Form::formatErrorsForApi($formModel->getErrors()));
                return http_response_code(500);
            }
        } catch (\Exception $e) {
            LoggerTool::error(sprintf('actionVerifyApproachOrderError: File[%s], Line:[%s], Message[%s]', $e->getFile(), $e->getLine(), $e->getMessage()));
            return http_response_code(500);
        }
    }

    /**
     * 删除准订单
     */
    public function actionDeleteApproachOrder()
    {
        $orderSn = \Yii::$app->request->post('orderSn');
        // 删除订单中间表
        ApproachOrder::deleteAll('SN = :SN', [':SN' => $orderSn]);
        // 删除订单商品中间表
        ApproachOrderGoods::deleteAll('ORDER_SN = :ORDER_SN', [':ORDER_SN' => $orderSn]);

        return static::notice('');
    }

    /**
     * iPay88支付
     * @return mixed
     * @throws HttpException
     */
    public function actionIPay88()
    {
        // 订单ID
        $paymentParams['RefNo'] = \Yii::$app->request->post('RefNo');
        // 订单金额,元=>分
        $money = \Yii::$app->request->post('Amount');   // TODO:
        $amount = number_format(1, 2, '.', '');
        $paymentParams['Amount'] = str_replace('.', '', $amount);

        // (Optional) (int)
        $paymentParams['PaymentId'] = '2';
        // Product description. (length 100)
        $paymentParams['ProdDesc'] = 'Pay for sales';
        // Customer name. (length 100)
        $paymentParams['UserName'] = 'MY32';
        $paymentParams['SignatureType'] = 'SHA256';
        // Customer email.  (length 100)
        $paymentParams['UserEmail'] = 'ek_dummy25@elken.com';
        // Customer contact.  (length 20)
        $paymentParams['UserContact'] = '60172249692';

        // (Optional) Merchant remarks. (length 100)
        //$paymentParams['Remark'] = 'Here is the description';
        //merchantkey + merchantcode+ reference Number + amount in cent + currency_code
        $paymentFields = \Yii::$app->iPay88->getPaymentFields($paymentParams, self::TRANSACTION_TYPE_PAYMENT);
        // 拼接订单ID
//        $paymentFields['ResponseURL'] .= $paymentParams['RefNo'];
        // 拼接订单ID
//        $paymentFields['BackendURL'] .= $paymentParams['RefNo'] . '/1';

        $transactionUrl = \Yii::$app->iPay88->getTransactionUrl(self::TRANSACTION_TYPE_PAYMENT);
        $paymentFields['Amount'] = $amount;
        $res = [
            'paymentFields' => $paymentFields,
            'transactionUrl' => $transactionUrl,
        ];

        return static::notice($res);
    }

    public function actionLogistics()
    {
        // OS202305308326566415
        $order = Order::find()
            ->alias('O')
            ->where('SN=:SN', [':SN' => 'OS202305301428462244'])
            ->select('O.*,U.REAL_NAME,OG.REAL_PRICE,OG.BUY_NUMS,OG.SKU_CODE,OG.GOODS_TITLE,OG.REAL_PV')
            ->join('LEFT JOIN', User::tableName() . ' AS U', 'U.ID=O.USER_ID')
            ->join('LEFT JOIN', OrderGoods::tableName() . ' AS OG', 'OG.ORDER_SN=O.SN')
            ->asArray()
            ->one();

//        $logistics = new Logistics();

        // 2、创建订单和产品(以前不存在/已提交的产品).
//        $result = $logistics->createOrder($order);
//        LoggerTool::info(['createOrder', $result]);
//        $result = $logistics->getProduct($order);
//        $result = $logistics->getOrder($order);
//        $result = $logistics->notifyDelivery($order);


//        $products = OrderGoods::findAllAsArray('ORDER_SN=:ORDER_SN', [':ORDER_SN' => 'OS202305301428462244']);
//        $result = $logistics->addProduct($products);

//        $result = $logistics->stockOut($order);

//        $result = $logistics->deleteOrder($order);

//        $result = $logistics->cancelOrder($order);

//        $result = $logistics->trackOrder();


//        return static::notice($result);
    }
}