201 lines
7.7 KiB
PHP
201 lines
7.7 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | ShopXO 国内领先企业级B2C免费开源电商系统
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2011~2019 http://shopxo.net All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
|
||
// +----------------------------------------------------------------------
|
||
// | Author: Devil
|
||
// +----------------------------------------------------------------------
|
||
namespace app\service;
|
||
|
||
use think\Db;
|
||
use app\service\WarehouseService;
|
||
|
||
/**
|
||
* 订单拆分服务层
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2020-07-18
|
||
* @desc description
|
||
*/
|
||
class OrderSplitService
|
||
{
|
||
/**
|
||
* 订单拆分入口
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2020-07-18
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function Run($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'goods',
|
||
'error_msg' => '商品为空',
|
||
],
|
||
[
|
||
'checked_type' => 'is_array',
|
||
'key_name' => 'goods',
|
||
'error_msg' => '商品有误',
|
||
],
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 商品仓库集合
|
||
$data = self::GoodsWarehouseAggregate($params['goods']);
|
||
return DataReturn('操作成功', 0, $data);
|
||
}
|
||
|
||
/**
|
||
* 商品仓库集合
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2020-07-18
|
||
* @desc description
|
||
* @param [array] $data [商品数据]
|
||
*/
|
||
public static function GoodsWarehouseAggregate($data)
|
||
{
|
||
// 仓库组扩展展示数据
|
||
// name 名称
|
||
// price 金额
|
||
// type 类型（0减少, 1增加）
|
||
// tips 提示信息
|
||
// business 业务类型（内容格式不限）
|
||
// ext 扩展数据（内容格式不限）
|
||
// $extension_data = [
|
||
// [
|
||
// 'name' => '感恩节9折',
|
||
// 'price' => 23,
|
||
// 'type' => 0,
|
||
// 'tips' => '-￥23元',
|
||
// 'business' => null,
|
||
// 'ext' => null,
|
||
// ],
|
||
// ];
|
||
|
||
// 数据分组
|
||
$result = [];
|
||
foreach($data as $v)
|
||
{
|
||
// 不存在规格则使用默认
|
||
$spec = empty($v['spec']) ? [['type' => '默认规格','value' => 'default']] : $v['spec'];
|
||
|
||
// 获取商品库存
|
||
$where = [
|
||
'wgs.goods_id' => $v['goods_id'],
|
||
'wgs.md5_key' => md5(implode('', array_column($spec, 'value'))),
|
||
'wg.is_enable' => 1,
|
||
'w.is_enable' => 1,
|
||
'w.is_delete_time' => 0,
|
||
];
|
||
$field = 'distinct w.id,w.name,w.alias,w.lng,w.lat,w.province,w.city,w.county,w.address,wgs.inventory,w.is_default,w.level';
|
||
$warehouse = Db::name('WarehouseGoodsSpec')->alias('wgs')->join(['__WAREHOUSE_GOODS__'=>'wg'], 'wgs.warehouse_id=wg.warehouse_id')->join(['__WAREHOUSE__'=>'w'], 'wg.warehouse_id=w.id')->where($where)->field($field)->order('w.level desc,w.is_default desc,wgs.inventory desc')->select();
|
||
|
||
// 默认仓库
|
||
$warehouse_default = [];
|
||
|
||
// 商品仓库分组
|
||
if(!empty($warehouse))
|
||
{
|
||
foreach($warehouse as $w)
|
||
{
|
||
// 是否还存在未分配的数量
|
||
if($v['stock'] > 0)
|
||
{
|
||
// 赋值数据
|
||
$temp_v = $v;
|
||
|
||
// 购买数量计算
|
||
if($temp_v['stock'] > $w['inventory'])
|
||
{
|
||
$temp_v['stock'] = $w['inventory'];
|
||
}
|
||
|
||
// 总价计算
|
||
$temp_v['total_price'] = $temp_v['price']*$temp_v['stock'];
|
||
|
||
// 减除数量
|
||
$v['stock'] -= $w['inventory'];
|
||
|
||
// 是否第一次赋值
|
||
if(!array_key_exists($w['id'], $result))
|
||
{
|
||
// 仓库
|
||
$warehouse_handle = WarehouseService::DataHandle([$w]);
|
||
$result[$w['id']] = $warehouse_handle[0];
|
||
$result[$w['id']]['extension_data'] = [
|
||
[
|
||
'name' => '感恩节9折',
|
||
'price' => 23,
|
||
'type' => 0,
|
||
'tips' => '-￥23元',
|
||
'business' => null,
|
||
'ext' => null,
|
||
],
|
||
];
|
||
$result[$w['id']]['goods_items'] = [];
|
||
unset($result[$w['id']]['is_default'], $result[$w['id']]['level'], $result[$w['id']]['inventory']);
|
||
|
||
// 订单基础信息
|
||
$result[$w['id']]['items_total_price'] = 0;
|
||
$result[$w['id']]['items_stock_total'] = 0;
|
||
}
|
||
|
||
// 商品归属到仓库下
|
||
$result[$w['id']]['goods_items'] = array_merge($result[$w['id']]['goods_items'], [$temp_v]);
|
||
|
||
// 基础信息
|
||
$result[$w['id']]['items_total_price'] += $temp_v['total_price'];
|
||
$result[$w['id']]['items_stock_total'] += $temp_v['stock'];
|
||
} else {
|
||
break;
|
||
}
|
||
}
|
||
} else {
|
||
// 未获取到仓库则使用默认仓库
|
||
if(empty($warehouse_default))
|
||
{
|
||
$warehouse_default = Db::name('Warehouse')->where(['is_default'=>1, 'is_enable'=>1, 'is_delete_time'=>0])->field('id,name,alias,lng,lat,province,city,county,address')->find();
|
||
}
|
||
if(!empty($warehouse_default))
|
||
{
|
||
if(!array_key_exists($warehouse_default['id'], $result))
|
||
{
|
||
// 仓库
|
||
$warehouse_handle = WarehouseService::DataHandle([$warehouse_default]);
|
||
$result[$warehouse_default['id']] = $warehouse_handle[0];
|
||
$result[$warehouse_default['id']]['extension_data'] = [];
|
||
$result[$warehouse_default['id']]['goods_items'] = [];
|
||
|
||
// 订单基础信息
|
||
$result[$warehouse_default['id']]['items_total_price'] = 0;
|
||
$result[$warehouse_default['id']]['items_stock_total'] = 0;
|
||
}
|
||
|
||
// 商品归属到仓库下
|
||
$result[$warehouse_default['id']]['goods_items'][] = $v;
|
||
|
||
// 基础信息
|
||
$result[$warehouse_default['id']]['items_total_price'] += $temp_v['total_price'];
|
||
$result[$warehouse_default['id']]['items_stock_total'] += $temp_v['stock'];
|
||
}
|
||
}
|
||
}
|
||
return array_values($result);
|
||
}
|
||
}
|
||
?>
|