qimall/addons/QiJuhe/api/modules/v1/controllers/OrderController.php

<?php

namespace addons\QiJuhe\api\modules\v1\controllers;

use addons\QiJuhe\common\models\GoodsModel;
use addons\QiJuhe\common\service\OrderService;
use addons\QiJuhe\common\enums\QiJuheEnum;
use addons\QiJuhe\common\enums\RefundTypeEnum;
use addons\QiJuhe\common\enums\ShippingTypeEnum;
use addons\QiJuhe\common\models\ExpressModel;
use addons\QiJuhe\common\models\GoodsSkuModel;
use addons\QiJuhe\common\models\MallOrderModel;
use addons\QiJuhe\common\models\OrderModel;
use addons\QiJuhe\common\models\OrderRefundModel;
use addons\QiJuhe\common\service\ApiService;
use addons\QiJuhe\common\service\RefundService;
use api\controllers\OnAuthController;
use common\enums\AppEnum;
use common\enums\OrderStatusEnum;
use common\enums\RefundStatusEnum;
use common\enums\ShippingStatusEnum;
use common\enums\AddonsEnum;
use common\enums\StatusEnum;
use common\logic\order\OrderFormLogic;
use common\logic\order\OrderInitDataLogic;
use common\logic\order\OrderLimitLogic;
use common\logic\order\OrderMarketingLogic;
use common\models\common\Attachment;
use common\models\order\Order;
use common\models\order\OrderDetail;
use common\models\order\OrderRefund;
use common\models\order\OrderRefundStep;
use common\models\user\UserAddress;
use common\models\goods\Goods;
use Exception;
use Yii;
use yii\helpers\Json;

/**
 * 默认控制器
 *
 * Class OrderController
 * @package addons\QiJuhe\api\modules\v1\controllers
 */
class OrderController extends OnAuthController
{
    public $modelClass = '';

    /**
     * 不用进行登录验证的方法
     *
     * 例如： ['index', 'update', 'create', 'view', 'delete']
     * 默认全部需要验证
     *
     * @var array
     */
    protected $authOptional = ['index'];

    /**
     * 订单预览
     *
     * @return string
     */
    public function actionPreview()
    {
        $orderFormLogic = new OrderFormLogic();
        $form = $orderFormLogic->getDefaultform($this->mall_id, $this->user_id);
        $form->attributes = Yii::$app->request->post();
        $form['action'] = AppEnum::ACTION_PREVIEW;
        !empty($form->shipping_type) && $form->shipping_type = ShippingTypeEnum::LOGISTICS;
        // 初始化订单数据
        $orderInitDataLogic = new OrderInitDataLogic();
        $form = $orderInitDataLogic->execute($form, $form->type);
        if ($form === false) {
            return $this->error($orderInitDataLogic->getError());
        }

        // 购买限制验证
        $orderLimitLogic = new OrderLimitLogic();
        $form = $orderLimitLogic->run($form);
        if ($form === false) {
            return $this->error($orderLimitLogic->getError());
        }

        // 获取收货地址
        $address_info = UserAddress::getUserAddress($this->user_id, $form->address_id);
        $form->address_id = $address_info['id'] ?? 0;

        // 营销减免活动
        $orderMarketingLogic = new OrderMarketingLogic();
        $form = $orderMarketingLogic->run($form);
        if ($form === false) {
            return $this->error($orderMarketingLogic->getError());
        }

        // 聚合供应链处理
        $service = new OrderService(['mall_id' => $this->mall_id]);
        try {
//            $form = $service->createBeforeCheck($form);
            $form = $service->validForm($form);
        } catch (Exception $e) {
            return $this->error($e->getMessage());
        }

        $group_order_goods = $form['group_order_goods'];

        $marketing = $form['marketing'];
        $pay_type_list = Yii::$app->services->pay->getEnablePayment($this->mall_id, $this->platform);
        $shipping_type_list = ShippingTypeEnum::getMap();
        $info = compact('group_order_goods', 'marketing', 'address_info', 'pay_type_list', 'shipping_type_list');
        $info['total_pay_money'] = '￥' . $form['total_pay_money'];
        $info['is_address'] = $form['is_address'] ?? 0;

        return $this->success('操作成功', $info);
    }

    /**
     * 创建订单
     *
     * @return void
     */
    public function actionCreate()
    {
        $orderFormLogic = new OrderFormLogic();
        $form = $orderFormLogic->getDefaultform($this->mall_id, $this->user_id);
        $form->attributes = Yii::$app->request->post();
        $form['action'] = AppEnum::ACTION_CREATE;
        // 初始化订单数据
        $orderInitDataLogic = new OrderInitDataLogic();
        $form = $orderInitDataLogic->execute($form, $form->type);
        if ($form === false) return $this->error($orderInitDataLogic->getError());

        // 购买限制验证
        $orderLimitLogic = new OrderLimitLogic();
        $form = $orderLimitLogic->run($form);
    
        if ($form === false) return $this->error($orderLimitLogic->getError());

        // 营销减免活动
        $orderMarketingLogic = new OrderMarketingLogic();
        $form = $orderMarketingLogic->run($form, true);
        if ($form === false) return $this->error($orderMarketingLogic->getError());

        // 聚合供应链处理
        $service = new OrderService(['mall_id' => $this->mall_id]);
        try {
//            $form = $service->createBeforeCheck($form, true);
            $form = $service->validForm($form, true);
        } catch (Exception $e) {
            return $this->error($e->getMessage());
        }
        
        $res = Order::createOrder($form);
        if ($res === false) return $this->error(Order::getStaticError());
        return $this->success('操作成功', $res);
    }

    /**
     * 加载提交售后订单数据
     *
     * @return void
     */
    public function actionToRefundSubmit()
    {
        $params = $this->request->get();
        $res = Yii::$app->services->validate->validate($params, [
            [['order_detail_id'], 'required'],
        ]);
        if ($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
        $select = 'id,order_id,goods_name,sign_id,goods_id,goods_attr_name,goods_attr_id,price,num,pic_url,goods_price,order_status,marketing_type,extra_info,adjust_money';
        $order_detail = OrderDetail::getOne([['id' => $params['order_detail_id']], 'user_id' => $this->user_id, 'mall_id' => $this->mall_id], 1, [], false, $select);
        if (empty($order_detail)) return $this->error('订单不存在');
        $order = MallOrderModel::find()->where(['id' => $order_detail['order_id']])->select('id, order_no, shipping_money, order_source')->one();
        if($order->order_source == AddonsEnum::ADDONS_NAME_CARD_COUPONS){
            $goods = Goods::findOne($order_detail['goods_id']);
            if(!$goods || $goods['goods_source'] != QiJuheEnum::PLUGIN_SIGN) throw new Exception('该订单不是聚合供应链订单');
        }else{
            if ($order->order_source != QiJuheEnum::PLUGIN_SIGN) return $this->error('该订单不是供应链订单');
        }

        // 供应链订单信息
//        $qijuhe_order = OrderModel::getOrderByOrderId($order->id, 'id, order_id, supply_id');

        // 中台订单
        /**
         * @var $qijuhe_order OrderModel
         */
        $qijuhe_order = OrderModel::find()->where(['order_id' => $order->id,'order_detail_id'=>$order_detail['id']])->one();
        if (empty($qijuhe_order)) {
            return $this->error('供应链订单不存在');
        }

        // 价格等于商品价格加上修改价格
        $order_detail['goods_price'] = round($order_detail['goods_price'] + $order_detail['adjust_money'], 2);
        $data['goods_info'] = $order_detail;
        // sku
        $sku = GoodsSkuModel::getSku($order_detail['goods_id'], $order_detail['goods_attr_id']);
        if (empty($sku)) return $this->error('Sku不存在');
 
        $refund_service = new RefundService(['mall_id' => $this->mall_id, 'supply_id' => $qijuhe_order->supply_id]);

        try {
            $feedback_type_resp = $refund_service->getAfterSalesTypeNameMap($qijuhe_order->getOrderItemId());
            if (empty($feedback_type_resp)) throw new Exception("当前商品不支持售后");
            $feedback_types = array_keys($feedback_type_resp);
        } catch (Exception $e) {
            return $this->error($e->getMessage());
        }

        $feedback_type_list = RefundTypeEnum::getRefundMap();
        foreach ($feedback_types as $type) {
            if (empty(RefundTypeEnum::TYPE_MAP_THIRD[$type])) return $this->error("售后类型不存在: {$type}");
            $t_feedback_type[] = $feedback_type_list[RefundTypeEnum::TYPE_MAP_THIRD[$type]];
        }

        if (in_array($order_detail['order_status'], [OrderStatusEnum::PAY, OrderStatusEnum::SHIPMENTS, OrderStatusEnum::SING])) {
            // 待发货
            if (!empty($t_feedback_type[RefundTypeEnum::ONLY_MONEY-1])) $feedback_type[] = $t_feedback_type[RefundTypeEnum::ONLY_MONEY-1];
        }
        if (in_array($order_detail['order_status'], [OrderStatusEnum::SHIPMENTS, OrderStatusEnum::SING])) {
            // 已发货
            if (!empty($t_feedback_type[RefundTypeEnum::MONEY_AND_PRODUCT-1])) $feedback_type[] = $t_feedback_type[RefundTypeEnum::MONEY_AND_PRODUCT-1];
            if (!empty($t_feedback_type[RefundTypeEnum::EXCHANGE_GOODS-1])) $feedback_type[] = $t_feedback_type[RefundTypeEnum::EXCHANGE_GOODS-1];
        }

        //  订单完成之前都可以执行部分仅退款
        $data['can_partial_refund'] = StatusEnum::DISABLED;
        if (in_array($order_detail['order_status'], [OrderStatusEnum::SHIPMENTS, OrderStatusEnum::SING])) {
            $supplyGoods = GoodsModel::findOne(['goods_id' => $qijuhe_order->goods_id]);
            if (!empty($supplyGoods) && in_array($supplyGoods->source, [QiJuheEnum::FREE_SHIPPING_SOURCE, QiJuheEnum::SUPPLY_YIYATONG])) {  //  可以申请部分退款
                $data['can_partial_refund'] = StatusEnum::ENABLED;
                $feedback_type[] = $feedback_type_list[RefundTypeEnum::ONLY_PART_MONEY];
            }
        }

        $data['feedback_type'] = $refund_service->getFeedbackTypeReason($feedback_type);

        // 待发货添加邮费
        // if ($order_detail['order_status'] == OrderStatusEnum::PAY) {
        //     $data['goods_info']['goods_price'] = bcadd($order_detail['goods_price'], $order->shipping_money, 2);
        // }

        //  未发货且当前商品为优选
//        $data['can_full_refund'] = StatusEnum::DISABLED;
//        if ($order_detail['order_status'] == OrderStatusEnum::PAY) {
//            //  取出商品
//            $supplyGoods = GoodsModel::findOne(['goods_id' => $qijuhe_order->goods_id]);
//            $data['can_full_refund'] = !empty($supplyGoods) && $supplyGoods->source == QiJuheEnum::FREE_SHIPPING_SOURCE ? StatusEnum::ENABLED : StatusEnum::DISABLED;
//        }


        $data['order_status'] = $order_detail['order_status'];
        return $this->success('操作成功', $data);
    }

    /**
     * 提交售后数据
     *
     * @return void
     */
    public function actionDoRefundSubmit()
    {
        $params = $this->request->post();
        $res = Yii::$app->services->validate->validate($params, [
            [['order_detail_id', 'reason_id', 'type', 'remark'], 'required'],
            [['shipping_status', 'pic_list', 'reason', 'refund_price', 'remark'], 'safe'],
            [['num', 'type'], 'integer']
        ]);

        if ($res === false) return $this->error(Yii::$app->services->validate->getErrorMessage());
        $params['user_id'] = $this->user_id;
        $params['mall_id'] = $this->mall_id;
        $where = [
            ['=', 'order_detail_id', $params['order_detail_id']],
            ['=', 'user_id', $this->user_id],
            ['=', 'mall_id', $this->mall_id],
            ['>', 'step_status', 0],
            ['<>', 'refund_status', RefundStatusEnum::REVOKE]
        ];
        $order_refund_model = OrderRefund::getOne($where, true);

        if ($order_refund_model) return $this->error('该订单商品已经申请过售后');

        $refund_service = new RefundService(['mall_id' => $this->mall_id]);
        $res = $refund_service->doRefund($params);

        if ($res === false) return $this->error($refund_service->error);
        return $this->success('操作成功', ['id' => $res->id]);
    }

    /**
     * 聚合供应链售后上传售后截图
     *
     * @return void
     */
    public function actionUpload()
    {
        return $this->error('功能开发中');
    }
    
    /**
     * 填写物流单号
     *
     * @return void
     */
    public function actionRefundSend()
    {
        $params = \Yii::$app->request->post();
        $res = \Yii::$app->services->validate->validate($params, [
            [['id'], 'required'],
            [['express_id', 'express_no'], 'required'],
        ]);
        if ($res === false) return $this->error(\Yii::$app->services->validate->getErrorMessage());

        // 供应链售后信息
        /**
         * @var $refund_order OrderRefundModel
         */
        $refund_order = OrderRefundModel::find()->where(['order_refund_id' => $params['id']])->one();        
        if (empty($refund_order)) {
            return $this->error('供应链订单不存在');
        }
        $api = ApiService::getConnect($refund_order->mall_id, $refund_order->supply_id);
        // 获取供应链端当前售后ID
        /* $sales_list = $api->afterSalesList($refund_order->order_no);
        if (empty($sales_list)) {
            return $this->error('供应链端无法查到售后信息');
        }
        $salse_info = current($sales_list['list']);
        if (empty($salse_info)) {
            return $this->error('供应链端无法查到售后信息2');
        } */

        $ex_where[] = 'and';
        $ex_where[] = ['express_id' => $params['express_id']];

        $goods_id = OrderDetail::find()->where(['id' => $refund_order->order_detail_id])->select('goods_id')->scalar();
        $attr = GoodsSkuModel::findOne(['goods_id' => $goods_id]);
        $goods = GoodsModel::findOne(['goods_id' => $attr->supply_goods_id]);
        //  如果当前商品是怡亚通的，那么就需要独立处理
        if ($goods->source == 122) {
            $ex_where[] = ['type' => 1];
        }

        // 物流
        $ex = ExpressModel::find()->where($ex_where)->one();
        if (empty($ex)) {
            return $this->error('物流公司不存在');
        }

        // 添加商城物流信息
        $params2 = [
            'id'            => $params['id'],
            'express'       => $ex->name,
            'express_no'    => $params['express_no'],
        ];
        $params2['mall_id'] = $this->mall_id;
        $params2['user_id'] = $this->user_id;
        $res = OrderRefundStep::refundSend($params2);
        if ($res === false) return $this->error(Order::getStaticError());

        // 修改供应链售后信息
        $send_info = [
            // 'after_sales_id'        => $salse_info['id'],
            'after_sales_id'        => $refund_order->after_sales_id,
            // 'company_name'          => $ex->express_id,
            'company_name'          => $ex->name,       //  需要对应
            'company_code'          => $ex->code,       //  需要对应
            'express_no'            => $params['express_no'],
            'shipping_address_id'   => $refund_order->shipping_address_id,
        ];
        $refund_order->return_data = Json::encode($send_info);
        $refund_order->save();

        // 推送发货消息
        $res = $api->afterSalesSend($send_info);

        return $this->success('操作成功');
    }

    /**
     * 物流编号
     *
     * @return void
     */
    public function actionExpressList()
    {
        $list = ExpressModel::find()->cache(10)->asArray()->all();

        return $this->success('ok', $list);
    }
}