yueshengshop/addon/topic/model/TopicOrderCreate.php

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

namespace addon\topic\model;

use app\model\order\OrderCreate;
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 TopicOrderCreate extends OrderCreate
{
	
	private $goods_money = 0;//商品金额
	private $balance_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 $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 (isset($calculate_data['code']) && $calculate_data['code'] < 0)
			return $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" => "topic",
				"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['discount_price'] * $order_goods['num'],
					'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;
				}
//                    model("goods_sku")->setDec([['sku_id', '=', $order_goods['sku_id']]], 'stock', $order_goods['num']);
//                    $sku_stock = model("goods_sku")->getInfo([['sku_id', '=', $order_goods['sku_id']]], 'stock');
//                    if($sku_stock['stock'] < 0)
//                    {
//                        model("order")->rollback();
//                        return $this->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_topic_" . $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;
          }
		//商品列表信息
		$shop_goods_list = $this->getOrderGoodsCalculate($data);
		
		//查询专题信息
		$topic_model = new Topic();
		$topic_id = $shop_goods_list["goods_list"][0]["topic_id"];
		$topic_info_result = $topic_model->getTopicInfo([ [ "topic_id", "=", $topic_id ] ]);
		$topic_info = $topic_info_result["data"];
		if (empty($topic_info)) {
			return $this->error([], "找不到可用的专题活动!");
		}
		$data["topic_info"] = $topic_info;
		//判断时间段是否符合
		$time = time();//当日时间戳
		
		if (empty($topic_info) || $topic_info["status"] != 1 || ($time < $topic_info["start_time"] || $time > $topic_info["end_time"])) {
			$this->error = 1;
			$this->error_msg = "当前商品专题活动未开启!";
		}
		
		$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);
		if (isset($calculate_data['code']) && $calculate_data['code'] < 0)
			return $calculate_data;
		
		$shop_goods_list = $calculate_data['shop_goods_list'];
		
		$calculate_data['shop_goods_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 $this->success($calculate_data);
	}
	
	/**
	 * 获取商品的计算信息
	 * @param unknown $data
	 */
	public function getOrderGoodsCalculate($data)
	{
		$shop_goods_list = [];
		//通过专题id查询 商品数据
//        $cache = Cache::get("order_create_topic_".$data['id'].'_'.$data['num'].'_'.$data['member_id']);
//        if(!empty($cache))
//        {
//            return $cache;
//        }
		$goods_list = $this->getTopicGoodsInfo($data["id"], $data['num']);
		$goods_list['promotion_money'] = 0;
		$shop_goods_list = $goods_list;
//        Cache::tag("order_create_topic_".$data['member_id'])->set("order_create_topic_".$data['id'].'_'.$data['num'].'_'.$data['member_id'], $shop_goods_list, 600);
		return $shop_goods_list;
	}
	
	/**
	 * 获取专题商品列表信息
	 * @param unknown $bl_id
	 */
	public function getTopicGoodsInfo($id, $num)
	{
		//组装商品列表
		$field = 'ptg.sku_id,ptg.id,ptg.topic_id,ptg.topic_price,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 = 'ptg';
		$join = [
			[
				'goods_sku ngs',
				'ptg.sku_id = ngs.sku_id',
				'inner'
			],
		];
		$info = model("promotion_topic_goods")->getInfo([ [ 'ptg.id', '=', $id ] ], $field, $alias, $join);
		$shop_goods_list = [];
		
		if (!empty($info)) {
			//判断是否是虚拟订单
			if ($info['is_virtual']) {
				$this->is_virtual = 1;
			} else {
				$this->is_virtual = 0;
			}
			$info["num"] = $num;
			$site_id = $info['site_id'];
			$info["discount_price"] = $info["topic_price"];
			
			$shop_goods_list['site_id'] = $site_id;
			$shop_goods_list['site_name'] = $info['site_name'];
			$shop_goods_list['goods_money'] = $info['discount_price'] * $info['num'];
			$shop_goods_list['goods_list_str'] = $info['sku_id'] . ':' . $info['num'];
			$shop_goods_list['order_name'] = string_split("", ",", $info['sku_name']);
			$shop_goods_list['goods_num'] = $info['num'];
			$shop_goods_list['goods_list'][] = $info;
                    $shop_goods_list['website_id'] = $info['website_id'];
			
		}
		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'];
		//定义计算金额
		$goods_money = $shop_goods['goods_money'];  //商品金额
		$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 ($this->is_virtual == 1) {
			//虚拟订单  运费为0
			$delivery_money = 0;
			$shop_goods['delivery']['delivery_type'] = '';
		} else {
			//计算邮费
			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();
						$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") {
					//门店自提
					$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") {
					//外卖配送
					$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 - $coupon_money - $invoice_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;
	}
	
}