yueshengshop/addon/bundling/model/BundlingOrderCreate.php

<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 山西牛酷信息科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com.cn
 * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用。
 * 任何企业和个人不允许对程序代码以任何形式任何目的再发布。
 * =========================================================
 */
namespace addon\bundling\model;

use app\model\order\OrderCreate;
use addon\coupon\model\Coupon;
use app\model\goods\GoodsStock;
use app\model\store\Store;
use think\facade\Cache;
use app\model\express\Express;
use app\model\system\Pay;
use app\model\express\Config as ExpressConfig;
/**
 * 订单创建(优惠套餐)
 *
 * @author Administrator
 *
 */
 
class BundlingOrderCreate extends OrderCreate
{

    private $goods_money = 0;//商品金额
    private $delivery_money = 0;//配送费用
    private $coupon_money = 0;//优惠券金额
    private $adjust_money = 0;//调整金额
    private $invoice_money = 0;//发票费用
    private $promotion_money = 0;//优惠金额
    private $order_money = 0;//订单金额
    private $pay_money = 0;//支付总价
    private $is_virtual = 0;  //是否是虚拟类订单
    private $order_name = '';  //订单详情
    private $goods_num = 0;  //商品种数
    private $balance_money = 0;//余额
    private $member_balance_money = 0;//会员账户余额(计算过程中会逐次减少)
    private $pay_type = 'ONLINE_PAY';//支付方式

    private $error = 0;  //是否有错误
    private $error_msg = '';  //错误描述

    /**
     * 订单创建
     * @param unknown $data
     */
    public function create($data)
    {
        //查询出会员相关信息
        $calculate_data = $this->calculate($data);
        if($this->error > 0){
            return $this->error("", $this->error_msg);
        }
        $pay = new Pay();
        $out_trade_no = $pay->createOutTradeNo();
        model("order")->startTrans();
        //循环生成多个订单
        try{
            $pay_money = 0;
            $goods_stock_model = new GoodsStock();
            $shop_goods_list = $calculate_data['shop_goods_list'];
            $item_delivery = $shop_goods_list['delivery'] ?? [];
            $delivery_type = $item_delivery['delivery_type'] ?? '';
            $delivery_type_name = Express::express_type[$delivery_type]["title"] ?? '';

            //订单主表
            $order_type = $this->orderType($shop_goods_list, $calculate_data);
            $order_no = $this->createOrderNo($shop_goods_list['site_id']);
            $data_order = [
                'order_no'    => $order_no,
                'site_id'     => $shop_goods_list['site_id'],
                'site_name'   => $shop_goods_list['site_name'],
                'order_from'  => $data['order_from'],
                'order_from_name' => $data['order_from_name'],
                'order_type' => $order_type['order_type_id'],
                'order_type_name' => $order_type['order_type_name'],
                'order_status_name' => $order_type['order_status']['name'],
                'order_status_action' => json_encode($order_type['order_status'], JSON_UNESCAPED_UNICODE),
                'out_trade_no' => $out_trade_no,
                'member_id' => $data['member_id'],
                'name' => $calculate_data['member_address']['name'] ?? '',
                'mobile' => $calculate_data['member_address']['mobile'] ?? '',
                'telephone' => $calculate_data['member_address']['telephone'] ?? '',
                'province_id' => $calculate_data['member_address']['province_id'] ?? '',
                'city_id'  => $calculate_data['member_address']['city_id'] ?? '',
                'district_id' => $calculate_data['member_address']['district_id'] ?? '',
                'community_id' => $calculate_data['member_address']['community_id'] ?? '',
                'address' => $calculate_data['member_address']['address'] ?? '',
                'full_address' => $calculate_data['member_address']['full_address'] ?? '',
                'longitude' => $calculate_data['member_address']['longitude'] ?? '',
                'latitude' => $calculate_data['member_address']['latitude'] ?? '',
                'buyer_ip' => request()->ip(),
                'goods_money' => $shop_goods_list['goods_money'],
                'delivery_money' => $shop_goods_list['delivery_money'],
                'coupon_id' => isset($shop_goods_list['coupon_id']) ? $shop_goods_list['coupon_id'] : 0,
                'coupon_money' => $shop_goods_list['coupon_money'],
                'adjust_money' => $shop_goods_list['adjust_money'],
                'invoice_money' => $shop_goods_list['invoice_money'],
                'promotion_money' => $shop_goods_list['promotion_money'],
                'order_money' => $shop_goods_list['order_money'],
                'balance_money' => $shop_goods_list['balance_money'],
                'pay_money' => $shop_goods_list['pay_money'],
                'create_time' => time(),
                'is_enable_refund' => 0,
                'order_name' => $shop_goods_list["order_name"],
                'goods_num' => $shop_goods_list['goods_num'],
                'delivery_type' => $delivery_type,
                'delivery_type_name' => $delivery_type_name,
                'delivery_store_id' => $shop_goods_list["delivery_store_id"] ?? 0,
                "delivery_store_name" => $shop_goods_list["delivery_store_name"] ?? '',
                "delivery_store_info" => $shop_goods_list["delivery_store_info"] ?? '',
                "buyer_message" => $data["buyer_message"],
                "promotion_type" => "bundling",
                "promotion_type_name" => "组合套餐",
                "promotion_status_name" => "",
                "website_id" => $shop_goods_list["website_id"]
            ];

            $order_id = model("order")->add($data_order);
            $pay_money += $shop_goods_list['pay_money'];
            //订单项目表
            foreach ($shop_goods_list['goods_list'] as $k_order_goods => $order_goods)
            {
                $data_order_goods = array(
                    'order_id'        => $order_id,
                    'site_id'         => $shop_goods_list['site_id'],
                    'site_name'       => $shop_goods_list['site_name'],
                    'order_no'        => $order_no,
                    'member_id'       => $data['member_id'],
                    'sku_id'          => $order_goods['sku_id'],
                    'sku_name'        => $order_goods['sku_name'],
                    'sku_image'       => $order_goods['sku_image'],
                    'sku_no'        => $order_goods['sku_no'],
                    'is_virtual'      => $order_goods['is_virtual'],
                    'goods_class'      => $order_goods['goods_class'],
                    'goods_class_name' => $order_goods['goods_class_name'],
                    'price'           => $order_goods['discount_price'],
                    'cost_price'      => $order_goods['cost_price'],
                    'num'             => $order_goods['num'],
                    'goods_money'     => $order_goods['goods_money'],
                    'cost_money'      => $order_goods['cost_price']*$order_goods['num'],
                    'commission_rate' => $order_goods['commission_rate'],
                    'goods_id' => $order_goods['goods_id'],
                    'delivery_status' => 0,
                    'delivery_status_name' => "未发货",
                );
                model("order_goods")->add($data_order_goods);
                //库存变化
                $stock_result = $goods_stock_model->decStock(["sku_id" => $order_goods['sku_id'], "num" => $order_goods['num']]);
                if($stock_result["code"] != 0){
                    model("order")->rollback();
                    return $stock_result;
                }
            }

            //优惠券
            if($shop_goods_list['coupon_money'] > 0)
            {
                //优惠券处理方案
                $coupon_id = $shop_goods_list['coupon_id'];
                $member_coupon_model = new Coupon();
                $coupon_use_result = $member_coupon_model->useCoupon($coupon_id, $data['member_id'], $order_id);//使用优惠券
                if($coupon_use_result['code'] != 0)
                {
                    model("order")->rollback();
                    return $this->error('', "COUPON_ERROR");
                }
            }

            //扣除余额(统一扣除)
            if($calculate_data["balance_money"] > 0){
                $balance_result = $this->useBalance($calculate_data);
                if($balance_result["code"] < 0){
                    model("order")->rollback();
                    return $balance_result;
                }
            }

            //生成整体支付单据
            $pay->addPay(0, $out_trade_no, $this->pay_type, $this->order_name, $this->order_name, $this->pay_money, '', 'OrderPayNotify', '');

            $this->addOrderCronClose($order_id);//增加关闭订单自动事件

            Cache::tag("order_create_bunding_".$data['member_id'])->clear();
            $result_list = event("OrderCreate", [ 'order_id' => $order_id ]);
            if(!empty($result_list)){
                foreach($result_list as $k => $v){
                    if(!empty($v) && $v["code"] < 0){
                        model("order")->rollback();
                        return $v;
                    }
                }
            }
            model("order")->commit();
            return $this->success($out_trade_no);
        
        }catch(\Exception $e)
        {
            model("order")->rollback();
            return $this->error('', $e->getMessage());
        }
        
    }
    
    /**
     * 订单计算
     * @param unknown $data
     */
    public function calculate($data)
    {
        $data = $this->initMemberAddress($data);
        $data = $this->initMemberAccount($data);//初始化会员账户
        //余额付款
        if($data['is_balance'] > 0)
        {
            $this->member_balance_money = $data["member_account"]["balance"] ?? 0;
        }

        //组合套餐id  查询订单商品数据
        $bunding_model = new Bundling();
        $bunding_info_result = $bunding_model->getBundlingInfo([["bl_id", "=", $data["bl_id"]]]);
        $bunding_info = $bunding_info_result["data"];
        $data["bunding_info"] = $bunding_info;//组合套餐信息
        //商品列表信息
        $shop_goods_list = $this->getOrderGoodsCalculate($data);
        $data['shop_goods_list'] = $this->shopOrderCalculate($shop_goods_list, $data);

        //总结计算
        $data['delivery_money'] = $this->delivery_money;
        $data['coupon_money'] = $this->coupon_money;
        $data['adjust_money'] = $this->adjust_money;
        $data['invoice_money'] = $this->invoice_money;
        $data['promotion_money'] = $this->promotion_money;
        $data['order_money'] = $this->order_money;
        $data['balance_money'] = $this->balance_money;
        $data['pay_money'] = $this->pay_money;
        $data['goods_money'] = $this->goods_money;
        $data['goods_num'] = $this->goods_num;
        $data['is_virtual'] = $this->is_virtual;
        return $data;
    }
    
    /**
     * 待付款订单
     * @param unknown $data
     */
    public function orderPayment($data)
    {
        $calculate_data = $this->calculate($data);
        $shop_goods_list = $calculate_data['shop_goods_list'];
        //1、查询会员优惠券
        $member_coupon_model = new Coupon();
        $member_coupon_list_result = $member_coupon_model->getMemberCouponList($data["member_id"], 1, $shop_goods_list["site_id"], $shop_goods_list["goods_money"], "money desc");
        $coupon_list = $member_coupon_list_result["data"];
        $calculate_data['shop_goods_list']["coupon_list"] = $coupon_list;
        $express_type = [];
        if($this->is_virtual == 0){
            if(!empty($calculate_data['member_address'])){
                //2. 查询店铺配送方式（1. 物流  2. 自提  3. 外卖）
                if($shop_goods_list["express_config"]["is_use"] == 1){
                    $express_type[] = ["title" => Express::express_type["express"]["title"], "name" => "express"];
                }
                //查询店铺是否开启门店自提
                if($shop_goods_list["store_config"]["is_use"] == 1){
                    $store_model = new Store();
                    $member_address = $calculate_data["member_address"] ?? [];
                    $province_id = $member_address["province_id"] ?? 0;
                    $city_id = $member_address["city_id"] ?? 0;
//                    $district_id = $member_address["district_id"] ?? 0;
                    $store_condition = array(
                        ["site_id", "=", $shop_goods_list["site_id"]],
                        ["province_id", "=", $province_id],
                        ["city_id", "=", $city_id],
                        ["status", "=", 1],
                        ["is_pickup", "=", 1],
//                    ["district_id", "=", $district_id],
                    );
                    $store_list_result = $store_model->getStoreList($store_condition);
                    $store_list = $store_list_result["data"];
                    $express_type[] = ["title" => Express::express_type["store"]["title"], "name" => "store", "store_list" => $store_list];
                }
                //查询店铺是否开启外卖配送
                if($shop_goods_list["local_config"]["is_use"] == 1){
                    //查询本店的通讯地址
                    $express_type[] = ["title" => "外卖配送", "name" => "local"];
                }
            }
        }
        $calculate_data['shop_goods_list']["express_type"] = $express_type;

        return $calculate_data;
        
    }
    
    /**
     * 获取商品的计算信息
     * @param unknown $data
     */
    public function getOrderGoodsCalculate($data)
    {
        $shop_goods_list = [];
        //传输组合套餐id组合','隔开要进行拆单
//        $cache = Cache::get("order_create_bunding_".$data['bl_id'].'_'.$data['num'].'_'.$data['member_id']);
//        if(!empty($cache))
//        {
//            return $cache;
//        }
        $goods_list = $this->getBundingGoodsList($data["bl_id"],$data['num']);

        $goods_list['promotion_money'] = 0;
        $shop_goods_list = $goods_list;
//        Cache::tag("order_create_bunding_".$data['member_id'])->set("order_create_bunding_".$data['bl_id'].'_'.$data['num'].'_'.$data['member_id'], $shop_goods_list, 600)
        return $shop_goods_list;
    }
    
    /**
     * 获取组合套餐商品列表信息
     * @param unknown $bl_id
     */
    public function getBundingGoodsList($bl_id,$num)
    {
        //组装商品列表
        $field = ' ngbg.sku_id, ngs.sku_name, ngs.sku_no,
            ngs.price, ngs.discount_price, ngs.cost_price, ngs.stock, ngs.weight, ngs.volume, ngs.sku_image, 
            ngs.site_id, ngs.site_name, ngs.website_id, ngs.is_own, ngs.goods_state, ngs.is_virtual, 
            ngs.is_free_shipping, ngs.shipping_template, ngs.goods_class, ngs.goods_class_name, ngs.commission_rate,ngs.goods_id';
        $alias = 'ngbg';
        $join = [
            [
                'goods_sku ngs',
                'ngbg.sku_id = ngs.sku_id',
                'inner'
            ],
        ];
        $goods_list = model("promotion_bundling_goods")->getList([['ngbg.bl_id', '=', $bl_id]], $field, '', $alias, $join);
        $shop_goods_list = [];
        if(!empty($goods_list))
        {
            foreach ($goods_list as $k => $v)
            {
                $v["num"] = $num;
                $site_id = $v['site_id'];
                if(!empty($shop_goods_list))
                {
                    $shop_goods_list['goods_list'][] = $v;
                    $shop_goods_list['order_name'] = string_split($shop_goods_list['order_name'], ",", $v['sku_name']);
                    $shop_goods_list['goods_num'] += $v['num'];
                    $shop_goods_list['goods_money'] += $v['discount_price'] * $v['num'];
                    $shop_goods_list['goods_list_str'] = $shop_goods_list['goods_list_str'].';'.$v['sku_id'].':'.$v['num'];
                }else{
                    $shop_goods_list['site_id'] = $site_id;
                    $shop_goods_list['website_id'] = $v['website_id'];
                    $shop_goods_list['site_name'] = $v['site_name'];
                    $shop_goods_list['goods_money'] = $v['discount_price'] * $v['num'];
                    $shop_goods_list['goods_list_str'] = $v['sku_id'].':'.$v['num'];
                    $shop_goods_list['order_name'] = string_split("", ",", $v['sku_name']);
                    $shop_goods_list['goods_num'] = $v['num'];
                    $shop_goods_list['goods_list'][] = $v;
                }
            }
        }
        return $shop_goods_list;
    }
    
    /**
     * 获取店铺订单计算
     * @param unknown $site_id  店铺id
     * @param unknown $site_name 店铺名称
     * @param unknown $goods_money 商品总价
     * @param unknown $goods_list  店铺商品列表
     * @param unknown $data   传输生成订单数据
     */
    public function shopOrderCalculate($shop_goods, $data)
    {
        $site_id = $shop_goods['site_id'];
        //循环计算订单项商品价格(受组合套餐的影响)
        $rate = $data["bunding_info"]["bl_price"]*$data["num"]/$shop_goods['goods_money'];//计算组合套餐与原商品价格计算比率
        $rate = substr(sprintf("%.5f", $rate), 0, -1);

        $add_money = $data["bunding_info"]["bl_price"]*$data["num"];//累计金额
        $count = count($shop_goods["goods_list"]);
        foreach($shop_goods["goods_list"] as $k => $v){
            if($k == ($count - 1)){
                $temp_money = $add_money;
                $temp_price = round($temp_money/$data["num"], 3);
                $temp_price = substr(sprintf("%.3f", $temp_price), 0, -1);
                $temp_money = substr(sprintf("%.3f", $temp_money), 0, -1);
                $shop_goods["goods_list"][$k]['discount_price'] = $temp_price;
                $shop_goods["goods_list"][$k]['goods_money'] = $temp_money;
            }else{
                $temp_price = round($v['discount_price'] * $rate, 3);
                $temp_money = round($v['discount_price'] * $data["num"] * $rate, 3);
                $temp_price = substr(sprintf("%.3f", $temp_price), 0, -1);
                $temp_money = substr(sprintf("%.3f", $temp_money), 0, -1);
                $add_money -= $temp_money;
            }
            $shop_goods["goods_list"][$k]['discount_price'] = $temp_price;
            $shop_goods["goods_list"][$k]['goods_money'] = $temp_money;
        }
//        $goods_money = $shop_goods['goods_money'] * $rate;  //商品金额
        $goods_money = $data["bunding_info"]["bl_price"]*$data["num"];//直接使用组合套餐价格
        //定义计算金额
        $delivery_money = 0;  //配送费用
        $promotion_money = $shop_goods['promotion_money'];  //优惠费用（满减）
        $coupon_money = 0;     //优惠券费用
        $adjust_money = 0;     //调整金额
        $invoice_money = 0;    //发票金额
        $order_money = 0;      //订单金额
        $balance_money = 0;    //会员余额
        $pay_money = 0;        //应付金额
	    
        //计算邮费
        if(empty($data['member_address']))
        {
            $delivery_money = 0;
            $shop_goods['delivery']['delivery_type'] = 'express';

            $this->error = 1;
            $this->error_msg = "未配置默认收货地址!";
        }else{

            //查询店铺是否开启快递配送
            $express_config_model = new ExpressConfig();
            $express_config_result = $express_config_model->getExpressConfig($site_id);
            $express_config = $express_config_result["data"];
            $shop_goods["express_config"] = $express_config;
            //查询店铺是否开启门店自提
            $store_config_result = $express_config_model->getStoreConfig($site_id);
            $store_config = $store_config_result["data"];
            $shop_goods["store_config"] = $store_config;
            //查询店铺是否开启外卖配送
            $local_config_result = $express_config_model->getLocalDeliveryConfig($site_id);
            $local_config = $local_config_result["data"];
            $shop_goods["local_config"] = $local_config;

            if(!isset($data['delivery']["delivery_type"]) || $data['delivery']["delivery_type"] == "express"){
                if($shop_goods["express_config"]["is_use"] == 1){
                    //物流配送
                    $express = new Express();
                    if($data["bunding_info"]["shipping_fee_type"] == 1){
                        $delivery_fee = 0;
                    }else{
                        $express_fee_result = $express->calculate($shop_goods, $data);
                        if($express_fee_result["code"] < 0){
                            $this->error = 1;
                            $this->error_msg = $express_fee_result["message"];
                            $delivery_fee = 0;
                        }else{
                            $delivery_fee = $express_fee_result['data']['delivery_fee'];
                        }
                    }

                }else{
                    $this->error = 1;
                    $this->error_msg = "物流配送方式未开启!";
                    $delivery_fee = 0;
                }
                $delivery_money = $delivery_fee;
                $shop_goods['delivery']['delivery_type'] = 'express';
            }else if($data['delivery']["delivery_type"] == "store"){
                //门店自提
                if($data["bunding_info"]["shipping_fee_type"] == 1){
                    $delivery_money = 0;
                }else{
                    $delivery_money = 0;
                }

                $shop_goods['delivery']['delivery_type'] = 'store';
                if($shop_goods["store_config"]["is_use"] == 0){
                    $this->error = 1;
                    $this->error_msg = "门店自提方式未开启!";
                }
                if(empty($data['delivery']["store_id"])){
                    $this->error = 1;
                    $this->error_msg = "门店未选择!";
                }
                $shop_goods['delivery']['store_id'] = $data['delivery']["store_id"];
                $shop_goods = array_merge($shop_goods,$this->storeOrderData($shop_goods, $data));
            }else if($data['delivery']["delivery_type"] == "local"){
                //外卖配送
                if($data["bunding_info"]["shipping_fee_type"] == 1){
                    $delivery_money = 0;
                }else{
                    $delivery_money = 0;
                }
                $shop_goods['delivery']['delivery_type'] = 'local';
                if($shop_goods["local_config"]["is_use"] == 0){
                    $this->error = 1;
                    $this->error_msg = "外卖配送方式未开启!";
                }
            }
        }

        $order_money = $goods_money + $delivery_money - $promotion_money + $invoice_money;

        //优惠券活动(采用站点id:coupon_id)
        if(!empty($data['coupon']) && $data['coupon']["coupon_id"] > 0)
        {
            $coupon_info = $data['coupon'];
            $shop_goods['coupon_id'] = $coupon_info["coupon_id"];
            //查询优惠券信息,计算优惠券费用
            $coupon = new Coupon();
            $coupon_info_result = $coupon->getCouponInfo([['coupon_id', '=', $shop_goods['coupon_id']]], 'member_id,at_least,money,state');
            $coupon_info = $coupon_info_result["data"];
            if(($coupon_info['at_least'] <= $goods_money-$promotion_money) && ($coupon_info['state'] == 1) && $coupon_info['member_id'] == $data['member_id'])
            {
                $coupon_money = $coupon_info['money'];
            }else{
                $this->error = 1;
                $this->error_msg = "优惠券不可用!";
            }
        }
        if($coupon_money > $order_money){
            $coupon_money = $order_money;
        }
        $order_money -= $coupon_money;

        if($order_money < 0)
        {
            $order_money = 0;
        }
        //余额抵扣(判断是否使用余额)
        if($this->member_balance_money > 0)
        {
            if($order_money <= $this->member_balance_money)
            {
                $balance_money = $order_money;
            }else{
                $balance_money = $this->member_balance_money;
            }
        }else{
            $balance_money = 0;
        }
        $pay_money = $order_money - $balance_money;//计算出实际支付金额
        $this->member_balance_money -= $balance_money;//预减少账户余额
        $this->balance_money += $balance_money;//累计余额

        //总结计算
        $shop_goods['goods_money'] = $goods_money;
        $shop_goods['delivery_money'] = $delivery_money;
        $shop_goods['coupon_money'] = $coupon_money;
        $shop_goods['adjust_money'] = $adjust_money;
        $shop_goods['invoice_money'] = $invoice_money;
        $shop_goods['promotion_money'] = $promotion_money;
        $shop_goods['order_money'] = $order_money;
        $shop_goods['balance_money'] = $balance_money;
        $shop_goods['pay_money'] = $pay_money;

        $this->goods_money += $goods_money;
        $this->delivery_money += $delivery_money;
        $this->coupon_money += $coupon_money;
        $this->adjust_money += $adjust_money;
        $this->invoice_money += $invoice_money;
        $this->promotion_money += $promotion_money;
        $this->order_money += $order_money;
        $this->pay_money += $pay_money;

        $this->goods_num += $shop_goods["goods_num"];
        $this->order_name = string_split($this->order_name, ",", $shop_goods["order_name"]);
        return $shop_goods;
    }
    
}