kailin/app/Http/Controllers/Api/Orders.php

<?php namespace App\Http\Controllers\Api;

use App\Http\Controllers\Api\Api;
use App\Models\Orders as Model;
use App\Models\Product;
use App\Models\Product\Skus as ProductSkus;
use App\Http\Requests\Api\Orders as Request;
use App\Models\Business;
use App\Models\City;
use App\Models\Custom;
use App\Models\CustomAddr;
use App\Models\CustomCoupon;
use App\Models\CustomScore;
use App\Models\OrdersAddr;
use App\Models\OrdersProduct;
use App\Models\ShopCart;
use Illuminate\Support\Facades\DB;

/**
 * 订单接口
 * 
 * @author 刘相欣
 * 
 * */
class Orders extends Api{

	/**
	 * 创建订单						 	/api/orders/create
	 * 
	 * */
	public function create(Request $request,Custom $Custom,City $City,Model $Model,OrdersAddr $OrdersAddr,OrdersProduct $OrdersProduct,Product $Product,ProductSkus $ProductSkus,CustomCoupon $CustomCoupon,ShopCart $ShopCart,CustomAddr $CustomAddr,CustomScore $CustomScore){
		// 接口验签
		// $this->verify_sign();
		// 验证参数
		$request->scene('create')->validate();
		// 检查登录
		$uid							= $this->checkLogin();
		// 接收参数
		$isCart							= request('is_cart',0);
		$productList					= request('product_list','[]');
		$customCouponId					= request('custom_coupon_id',1);
		$addr							= $CustomAddr->getOne(request('addr_id',0));
		// 如果不存在数据
		if( !$addr )					return json_send(['code'=>'error','msg'=>'地址有误，请核对','data'=>['error'=>'没有找到对应的地址']]);
		// 重组数据
		$addr							= ['contact_name'=>$addr['contact_name'],'contact_shop'=>$addr['contact_shop'],'contact_phone'=>$addr['contact_phone'],'contact_province'=>$addr['contact_province'],'contact_city'=>$addr['contact_city'],'contact_area'=>$addr['contact_area'],'contact_addr'=>$addr['contact_addr']];
		// 获取客户城市ID
		$cityId							= (int) $Custom->getValue($uid,'city_id');
		$cityName						= $City->getOne($cityId,'name');
		$pid 							= $City->getOne($cityId,'pid');
		$province						= $City->getOne($pid,'name');
		// 判断选择的城市名称是不是一致
		if( $cityName != $addr['contact_city'] ) return json_send(['code'=>'error','msg'=>'收货地址请选择'.$province.'/'.$cityName,'data'=>['error'=>'收货地址需与您所选城市一致']]);
		// 解码购买信息
		$buyList						= json_decode($productList,true);
		// 如果不存在数据
		if( empty($buyList) )			return json_send(['code'=>'error','msg'=>'没有需下单的产品','data'=>['error'=>'产品列表为空']]);
		// 商品购买数量
		$buyNum							= [];
		// 循环购买信息
		foreach ($buyList as $key => $value) {
			// 获取每个商品的总量
			$buyNum[$value['product_id']] = isset($buyNum[$value['product_id']]) ? ($buyNum[$value['product_id']] + $value['buy_num']) : $value['buy_num'];
		}
		// 查询产品信息
		$productList					= $Product->getListByIds(array_column($buyList,'product_id'));
		$skusList						= $ProductSkus->getListByIds(array_column($buyList,'product_skuid'));
		// 当前时间
		$time 							= time();
		// 产品以商业公司分组，方便写入订单
		$orderProduct					= [];
		// 产品价格同级，用于优惠券计算
		$productPrice					= [];
		// 循环处理购买信息
		foreach ($buyList as $buyInfo) 	{
			// 如果产品不存在
			if( empty($productList[$buyInfo['product_id']]) )	return json_send(['code'=>'error','msg'=>'产品不存在或已下架','data'=>['error'=>'产品不存在或已下架=>'.$buyInfo['product_id']]]);
			// 获取产信息
			$productInfo 				= $productList[$buyInfo['product_id']];
			// 如果产品限购
			if( $productInfo['quota'] )	{
				// 是否在限购时间，当前时间大于开始时间，并且小于结束时间
				if( $productInfo['quota_start'] <= $time && $time <= $productInfo['quota_end'] ){
					// 通过时间查询商品的购买总数
					$total 				= $OrdersProduct->query()->where([['custom_uid','=',$uid],['product_id','=',$productInfo['id']],['insert_time','>=',$productInfo['quota_start']],['insert_time','<=',$productInfo['quota_end']]])->sum('buy_num');
					// 判断限购数量
					$total	 			= $buyNum[$buyInfo['product_id']] + $total;
					// 如果超过数量
					if( $total > $productInfo['quota'] ) return json_send(['code'=>'error','msg'=>'限购'.$productInfo['quota'].'套-'.$productInfo['product_name'],'data'=>['error'=>'已超限=>'.($total - $productInfo['quota'])]]);
				}
			}
			// 如果存在SKU
			if( $buyInfo['product_skuid'] ) {
				// 判断SKU信息存不存在
				if( empty($skusList[$buyInfo['product_skuid']]) ) return json_send(['code'=>'error','msg'=>'该产品规格不存在或已下架','data'=>['error'=>'SKU不存在或已下架=>'.$buyInfo['product_skuid']]]);
				// 产品ID不匹配的话
				if( $skusList[$buyInfo['product_skuid']]['product_id'] != $buyInfo['product_id'] ) return json_send(['code'=>'error','msg'=>'该产品规格不存在或已下架','data'=>['error'=>'SKU不匹配=>'.$buyInfo['product_skuid']]]);
				// 如果SKU存在,合并产品信息
				$productInfo			= array_merge($productInfo,$skusList[$buyInfo['product_skuid']]);
				// 需要扣除的库存
				$skusList[$buyInfo['product_skuid']]['decr'] = empty($skusList[$buyInfo['product_skuid']]['decr']) ? $buyInfo['buy_num'] : $skusList[$buyInfo['product_skuid']]['decr'] + $buyInfo['buy_num'];
			}
			// 需要扣除的库存
			$productList[$buyInfo['product_id']]['decr'] = empty($productList[$buyInfo['product_id']]['decr']) ? $buyInfo['buy_num'] : $productList[$buyInfo['product_id']]['decr'] + $buyInfo['buy_num'];
			// 判断库存
			if( $productInfo['stock'] < $productList[$buyInfo['product_id']]['decr'] )  return json_send(['code'=>'error','msg'=>$productInfo['product_name'].'-库存不足','data'=>['error'=>'产品库存不足=>'.$buyInfo['product_id']]]);
			// 计算价值
			$priceTotal					= $buyInfo['buy_num'] * $productInfo['price'];
			// 购买信息
			$buyInfo					= ['is_rebate'=>0,'custom_uid'=>$uid,'business_id'=>$productInfo['business_id'],'product_id'=>$buyInfo['product_id'],'buy_num'=>$buyInfo['buy_num'],'price_total'=>$priceTotal,'pay_total'=>$priceTotal,'coupon_total'=>0,'product_name'=>$productInfo['product_name'],'sku_attr_names'=>$productInfo['sku_attr_names'],'product_thumb'=>$productInfo['product_thumb']];
			// 获取信息
			if( !isset($orderProduct[$buyInfo['business_id']]) )		$orderProduct[$buyInfo['business_id']] = ['business_id'=>$buyInfo['business_id'],'custom_uid'=>$buyInfo['custom_uid'],'price_total'=>0,'pay_total'=>0,'coupon_total'=>0,'product_list'=>[]];
			// 订单产品
			$orderProduct[$buyInfo['business_id']]['price_total']		+= $buyInfo['price_total'];
			$orderProduct[$buyInfo['business_id']]['pay_total']			+= $buyInfo['price_total'];
			$orderProduct[$buyInfo['business_id']]['product_list'][]	= $buyInfo;
			// 商品优惠信息不存在，创建
			if( !isset($productPrice[$buyInfo['product_id']]) )			$productPrice[$buyInfo['product_id']] = ['price_total'=>0,'rebate_price'=>0];
			// 计算总价
			$productPrice[$buyInfo['product_id']]['price_total']		= $productPrice[$buyInfo['product_id']]['price_total'] + $priceTotal;
		}
		// 优惠券数据
		$couponRebate					= $CustomCoupon->getRebatePrice($customCouponId,$uid,$productPrice);
		// 判断是否使用了优惠券
		$usedCoupon						= $couponRebate['is_used'];
		// 获取优惠券扣减金额
		$productPrice					= $couponRebate['product_price'];
		// 获取优惠券赠品信息
		$rebateProduct					= $couponRebate['rebate_product'];
		// 组合订单数据
		foreach ($orderProduct as $key => $order) {
			// 判断哪一家的赠品
			if( isset($rebateProduct[$order['business_id']]) ){
				// 循环赠品
				foreach ( $rebateProduct[$order['business_id']] as $value) {
					// 没有对应的产品
					if( !isset($productList[$value['product_id']]) )  $productList[$value['product_id']] = ['id'=>$value['id'],'stock'=>$value['stock']];
					// 判断库存，如果库存不足，只赠送最后的库存
					if( $productList[$value['product_id']]['stock'] <= $value['buy_num'] )  $value['buy_num'] = $productList[$value['product_id']]['stock'];
					// 库存扣减
					$productList[$value['product_id']]['decr']  = empty($productList[$value['product_id']]['decr']) ? $value['buy_num'] : $productList[$value['product_id']]['decr'] + $value['buy_num'];
					// 追加到订单表
					$order['product_list'][] = ['is_rebate'=>1,'custom_uid'=>$uid,'business_id'=>$value['business_id'],'product_id'=>$value['product_id'],'buy_num'=>$value['buy_num'],'price_total'=>$value['price_total'],'pay_total'=>$value['pay_total'],'coupon_total'=>$value['coupon_total'],'product_name'=>$value['product_name'],'sku_attr_names'=>$value['sku_attr_names'],'product_thumb'=>$value['product_thumb']];
				}
			}
			// 计算总价格
			foreach ($order['product_list'] as $k=>$product) {
				// 商品不存在，不进行扣减
				if( empty($productPrice[$product['product_id']]['rebate_price']) ) {
					// 重组
					$order['product_list'][$k] = $product;
					continue;
				}
				// 总优惠增加
				$order['coupon_total']	 = $order['coupon_total']  + $productPrice[$product['product_id']]['rebate_price'];
				// 当前商品的优惠折扣计算
				$product['coupon_total'] = number_format( $productPrice[$product['product_id']]['rebate_price'] * ($product['price_total'] / $productPrice[$product['product_id']]['price_total']) , 2 , '.' ,'');
				// 成交小计
				$product['pay_total']	 = $product['pay_total'] -  $product['coupon_total'];
				// 重组
				$order['product_list'][$k] = $product;
			}
			// 成交总价
			$order['pay_total']			= $order['pay_total'] -  $order['coupon_total'];
			// 赠送积分
			$order['order_score']		= (config('order_score_send',0) && floor( $order['pay_total'] * 1 ) > 0 )  ? floor( $order['pay_total'] * 1 ) : 0;
			// 成交总价
			$order['custom_uid']		= $uid;
			// 重组
			$orderProduct[$key]			= $order;
		}
		// 组合数据，写入订单表，子表
		DB::beginTransaction();
		// 写入数据
		try {
			// 扣减商品库存
			foreach ($productList as $key => $value) {
				// 扣减库存
				$result 				= $Product->edit($value['id'],['stock'=>DB::raw('stock+-'.$value['decr'])]);
				// 判断结果
				if( !$result ) 			{
					// 回退数据
					DB::rollBack();
					// 错误提示
					return 				json_send(['code'=>'error','msg'=>'库存扣减失败','data'=>['error'=>'库存扣减失败']]);
				}
			}
			// 扣减商品库存
			foreach ($skusList as $key => $value) {
				// 扣减库存
				$result 				= $ProductSkus->edit($value['sku_id'],['stock'=>DB::raw('stock+-'.$value['decr'])]);
				// 判断结果
				if( !$result ) 			{
					// 回退数据
					DB::rollBack();
					// 错误提示
					return 				json_send(['code'=>'error','msg'=>'库存扣减失败','data'=>['error'=>'库存扣减失败']]);
				}
			}
			// 循环订单数据
			foreach ($orderProduct as $order) {
				// 先获取产品列表，并去除key
				$productItem			= array_values($order['product_list']);
				// 删除非必要数据
				unset($order['product_list']);
				// 创建总订单
				$orderId				= $Model->add($order);
				// 如果订单写入失败	
				if( !$orderId )			{
					// 回退数据
					DB::rollBack();
					// 错误提示
					return 				json_send(['code'=>'error','msg'=>'下单失败','data'=>['error'=>'订单创建失败']]);
				}
				// 创建子订单
				foreach ($productItem as $key=>$value) {
					// 增加订单ID
					$value['order_id']	= $orderId;
					// 增加订单ID
					$value['insert_time']= $time;
					$value['update_time']= $time;
					// 结果
					$productItem[$key]	= $value;
				}
				// 写入子表
				$result					= $OrdersProduct->query()->insert($productItem);
				// 如果扣减失败
				if( !$result )			{
					// 回退数据
					DB::rollBack();
					// 提示信息
					return				json_send(['code'=>'error','msg'=>'子订单创建失败','data'=>['error'=>'子订单创建失败']]);
				}
				// 写入订单地址表
				$addr['order_id']		= $orderId;
				// 写入订单地址表
				$result 				= $OrdersAddr->add($addr);
				// 地址写入失败
				if( !$result )			{
					// 回退数据
					DB::rollBack();
					// 提示信息
					return				json_send(['code'=>'error','msg'=>'地址写入失败','data'=>['error'=>'地址写入失败']]);
				}
				// 赠送积分
				if( $order['order_score'] > 0 ) $CustomScore->trade($order['custom_uid'],$orderId,$order['order_score'],5,1);
				// 如果使用了优惠券
				if( $usedCoupon )		$CustomCoupon->edit($usedCoupon,['status'=>1,'order_id'=>$orderId]);
				// 购物车
				if( $isCart )			$ShopCart->query()->where([['custom_uid','=',$uid]])->whereIn('skuid',array_column($buyList,'product_skuid'))->delete();
			}
			// 自动发放优惠券
			$this->autoCoupon($uid);
			// 提交数据
			DB::commit();
			// 返回结果
			return						json_send(['code'=>'success','msg'=>'下单成功','data'=>['id'=>null]]);
			// 返回结果
		} catch (\Throwable $th) {
			// 回退数据
			DB::rollBack();
			// 判断结果，如果库存扣减失败的话
			if( stripos($th->getMessage(),'UNSIGNED') )  return json_send(['code'=>'error','msg'=>'库存不足','data'=>['error'=>'产品库存扣减失败']]);
			// 下单失败提示
			return						json_send(['code'=>'error','msg'=>'系统异常，请稍后再试','data'=>['error'=>$th->getMessage().$th->getLine()]]);
		}
	}


	/**
	 * 获取产品列表		 /api/orders/get_list
	 * 
	 * @param	string	$name		    产品名称
	 * @param	int		$page			页码,默认1
	 * @param	int		$limit			每页条数,默认10条
	 * 
	 * */
	public function get_list(Request $request,Model $Model,OrdersProduct $OrdersProduct,Business $Business){
		// 接口验签
		// $this->verify_sign();
        // 验证参数
		$request->scene('get_list')->validate();
		// 检查登录
		$uid						= $this->checkLogin();
		// 接收参数
		$status						= request('status',0);
		$limit						= request('limit',10);
		// 显示
		$map						= [['custom_uid','=',$uid]];
		// 查询状态
		if( $status )				$map[] = ['status','=',$status];
		// 查询
		$Paginator					= $Model->query()->where($map)->orderByDesc('id')->paginate($limit,['id','pay_total','status','price_total','coupon_total','business_id','pay_total','weizan_orderid','insert_time']);
		// 订单产品
		$productList 				= $OrdersProduct->query()->whereIn('order_id', array_column($Paginator->items(),'id'))->select(['id as item_id','order_id','product_id','buy_num','is_rebate','sku_attr_names as product_spec','product_name','product_thumb'])->get()->toArray();
		// 循环处理
		foreach ($Paginator as $key => $order) {
			// 商品列表
			$itemList				= [];
			// 返回结果
			foreach ($productList as $item) {
				// 产品图路径
				$item['product_thumb']	= path_compat($item['product_thumb']);
				// 如果是订单的
				if( $item['order_id'] == $order['id'] ) $itemList[]	= $item;
			}
			// 获取子列表
			$order['state']			= (string) $Model->getState($order['status'],'state');
			// 获取子列表
			$order['business_name']	= (string) ($order['business_id'] ? $Business->getOne($order['business_id'],'name') : ($order['weizan_orderid'] ? '微赞订单' : ''));
			// 获取子列表
			$order['contents_class']= 0;
			// 获取子列表
			$order['product_list']	= $itemList;
			// 重组
			$Paginator[$key]		= $order;
		}
		// 获取数据
		$data['total']				= $Paginator->total();
		$data['current_page']		= $Paginator->currentPage();
		$data['per_page']			= $Paginator->perPage();
		$data['last_page']			= $Paginator->lastPage();
		$data['data']				= $Paginator->items();
		// 返回结果
		return						json_send(['code'=>'success','msg'=>'获取成功','data'=>$data]);
	}

	/**
	 * 自动发放优惠券
	 * 
	 */
	private function autoCoupon($uid){
		// 模型实例
		$Rule 					= new \App\Models\CouponRewardRule();
		// 获取配置列表
		$ruleList				= $Rule->getList();
		// 如果没有信息的话
		if( !$ruleList )		return ['success'=>'暂无活动'];
		// 其他实例
		$RuleProduct 			= new \App\Models\CouponRewardProduct();
		$OrdersProduct 			= new \App\Models\OrdersProduct();
		$Custom					= new \App\Models\Custom();
		$Coupon					= new \App\Models\Coupon();
		$CustomCoupon			= new \App\Models\CustomCoupon();
		// 获取客户城市ID
		$customCityId			= (int) $Custom->getValue($uid,'city_id');
		// 循环配置列表
		foreach ( $ruleList as 	$value ) {
			// 如果存在城市范围，并且不在城市范围,不参与这个活动
			if( $value['city_ids'] && !in_array($customCityId,explode(',',$value['city_ids'])) ) continue;
			// 未到开始时间
			if( $value['start_time'] > time() )  continue;
			// 通过配置ID获取对应的商品范围
			$productList 		= $RuleProduct->getListByRule($value['id']);
			// 如果不存在产品范围，跳过
			if( !$productList ) continue;
			// 获取客户 规定时段内订单的商品ID以及购买数量
			$orderList 			= $OrdersProduct->query()->where([['custom_uid','=',$uid],['status','=',1],['insert_time','>=',$value['start_time']],['insert_time','<=',$value['end_time']]])->get(['product_id','buy_num'])->toArray();
			// 如果没有订单总数
			if( !$orderList ) 	continue;
			// 计算商品总量
			$total				= 0;
			// 循环商品范围
			foreach ($productList as $scope) {
				// 循环订单产品
				foreach ($orderList as $order) {
					// 如果产品不相等
					if( $scope['product_id'] != $order['product_id'] ) continue;
					// 相等的计算总量
					$total		+= $scope['product_units'] * $order['buy_num'];
				}
			}
			// 判断总数是不是达标
			if( $total < $value['std_num'] )  continue;
			// 达标的是否已经发送过优惠券
			$havaCoupon			= $CustomCoupon->query()->where([['custom_uid','=',$uid],['coupon_id','=',$value['coupon_id']]])->first(['status']);
			// 已经发过优惠券的，不发
			if( $havaCoupon )   continue;
			// 获取优惠券的可用时间
			$expTime			= $Coupon->query()->where([['id','=',$value['coupon_id']]])->value('exp_time');
			// 时间转时间
			$expTime			= $Coupon->getExpTime($expTime);
			// 发送优惠券
			$CustomCoupon->add(['coupon_id'=>$value['coupon_id'],'custom_uid'=>$uid,'exp_time'=>$expTime]);
		}
		// 返回成功
		return					['success'=>'操作成功'];
	}

	/**
	 * 取消				/api/orders/cancel
	 * 
	 * */
	public function cancel( Request $request, Model $Model,OrdersProduct $OrdersProduct,CustomScore $CustomScore){
		// 验证参数
		$request->scene('cancel')->validate();
		// 检查登录
		$uid			= $this->checkLogin();
		// 接收参数
		$id				= request('id',0);
		$status 		= 4;
		// 获取产品和数量
		$oldData 		= $Model->query()->where([['id','=',$id],['custom_uid','=',$uid]])->first(['id','order_score','status','custom_uid','insert_time']);
		// 如果用户不存在
		if( !$oldData )	return json_send(['code'=>'error','msg'=>'订单不存在']);
		// 如果已经取消
		if( $oldData['status'] == 4 ) 	return json_send(['code'=>'error','msg'=>'订单已取消']);
		// 组合数据，写入订单表，子表
		DB::beginTransaction();
		try{
			// 查询数据
			$result			= $Model->setOrderStatus($id,$status,$OrdersProduct);
			// 提示新增失败
			if( isset($result['error']) )	{
				// 回退数据
				DB::rollBack();
				// 提示信息
				return		json_send(['code'=>'error','msg'=>$result['error'],'data'=>['error'=>$result['error']]]);
			}
			if( $status == 4 ){
				// 取消积分
				if( $oldData['order_score'] > 0 ) {
					// 如果扣减失败
					$result 	= $CustomScore->trade($oldData['custom_uid'],$oldData['id'],($oldData['order_score']*-1),6,1);
					// 提示新增失败
					if( isset($result['error']) )	{
						// 回退数据
						DB::rollBack();
						// 提示信息
						return json_send(['code'=>'error','msg'=>'取消赠送积分失败','data'=>['error'=>$result['error']]]);
					}
				}
				// 取消关联订单
				$result			= $Model->cancelRelate($oldData['insert_time'],$oldData['custom_uid'],$OrdersProduct,$CustomScore);
				// 提示新增失败
				if( isset($result['error']) )	{
					// 回退数据
					DB::rollBack();
					// 提示信息
					return		json_send(['code'=>'error','msg'=>'取消关联订单失败','data'=>['error'=>$result['error']]]);
				}
			}
			// 提交数据
			DB::commit();
			// 告知结果
			return			json_send(['code'=>'success','msg'=>'取消成功']);
			// 返回结果
		} catch (\Throwable $th) {
			// 回退数据
			DB::rollBack();
			// 下单失败提示
			return			json_send(['code'=>'error','msg'=>'取消失败','data'=>['error'=>$th->getMessage().$th->getLine()]]);
		}
	}


	

}