1968 lines
78 KiB
PHP
Executable File
1968 lines
78 KiB
PHP
Executable File
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | ShopXO 国内领先企业级B2C免费开源电商系统
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2011~2099 http://shopxo.net All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed ( https://opensource.org/licenses/mit-license.php )
|
||
// +----------------------------------------------------------------------
|
||
// | Author: Devil
|
||
// +----------------------------------------------------------------------
|
||
namespace app\service;
|
||
|
||
use think\facade\Db;
|
||
use app\service\SystemBaseService;
|
||
use app\service\UserService;
|
||
use app\service\GoodsService;
|
||
use app\service\GoodsCartService;
|
||
use app\service\UserAddressService;
|
||
use app\service\ResourcesService;
|
||
use app\service\PaymentService;
|
||
use app\service\ConfigService;
|
||
use app\service\OrderSplitService;
|
||
use app\service\WarehouseGoodsService;
|
||
use app\service\OrderCurrencyService;
|
||
use app\service\OrderService;
|
||
|
||
/**
|
||
* 购买服务层
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 0.0.1
|
||
* @datetime 2016-12-01T21:51:08+0800
|
||
*/
|
||
class BuyService
|
||
{
|
||
/**
|
||
* 下订单 - 正常购买
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-09-21
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyGoods($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'goods_data',
|
||
'error_msg' => MyLang('common_service.buy.buy_goods_data_error_tips'),
|
||
],
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
if(!is_array($params['goods_data']))
|
||
{
|
||
$params['goods_data'] = json_decode(base64_decode(urldecode($params['goods_data'])), true);
|
||
}
|
||
|
||
// 获取商品
|
||
$goods_ids = array_column($params['goods_data'], 'goods_id');
|
||
$goods_params = array_merge($params, [
|
||
'where' => [
|
||
['id', 'in', $goods_ids],
|
||
['is_delete_time', '=', 0],
|
||
['is_shelves', '=', 1],
|
||
],
|
||
'field' => 'id,id AS goods_id,title,images,brand_id,simple_desc,spec_desc,approval_number,approval_number_expire,batch_number,batch_number_expire,coding,model,produce_company,produce_region,inventory_unit,is_shelves,buy_min_number,buy_max_number,site_type,content_web,use_guide',
|
||
'm' => 0,
|
||
'n' => 0,
|
||
]);
|
||
$ret = GoodsService::GoodsList($goods_params);
|
||
if(empty($ret['data'][0]))
|
||
{
|
||
return DataReturn(MyLang('data_no_exist_or_delete_error_tips'), -10);
|
||
}
|
||
|
||
// 商品处理
|
||
$data = [];
|
||
$temp_goods = array_column($ret['data'], null, 'id');
|
||
foreach($params['goods_data'] as $v)
|
||
{
|
||
if(array_key_exists($v['goods_id'], $temp_goods))
|
||
{
|
||
// 商品
|
||
$goods = $temp_goods[$v['goods_id']];
|
||
|
||
// 规格
|
||
$goods['spec'] = self::GoodsSpecificationsHandle($v);
|
||
$goods['spec_text'] = empty($goods['spec']) ? '' : implode('，', array_filter(array_map(function($spec)
|
||
{
|
||
return (isset($spec['type']) && isset($spec['value'])) ? $spec['type'].':'.$spec['value'] : '';
|
||
}, $goods['spec'])));
|
||
|
||
// id处理、避免不同规格导致id一样
|
||
$goods['id'] = md5($goods['goods_id'].(empty($goods['spec']) ? 'default' : implode('', array_column($goods['spec'], 'value'))));
|
||
|
||
// 获取商品基础信息
|
||
$spec_params = array_merge($params, [
|
||
'id' => $goods['goods_id'],
|
||
'spec' => $goods['spec'],
|
||
'stock' => $v['stock']
|
||
]);
|
||
$goods_base = GoodsService::GoodsSpecDetail($spec_params);
|
||
if($goods_base['code'] == 0)
|
||
{
|
||
$goods['inventory'] = $goods_base['data']['spec_base']['inventory'];
|
||
$goods['price'] = (float) $goods_base['data']['spec_base']['price'];
|
||
$goods['original_price'] = (float) $goods_base['data']['spec_base']['original_price'];
|
||
$goods['spec_base_id'] = $goods_base['data']['spec_base']['id'];
|
||
$goods['spec_buy_min_number'] = $goods_base['data']['spec_base']['buy_min_number'];
|
||
$goods['spec_buy_max_number'] = $goods_base['data']['spec_base']['buy_max_number'];
|
||
$goods['spec_weight'] = $goods_base['data']['spec_base']['weight'];
|
||
$goods['spec_volume'] = $goods_base['data']['spec_base']['volume'];
|
||
$goods['spec_coding'] = $goods_base['data']['spec_base']['coding'];
|
||
$goods['spec_barcode'] = $goods_base['data']['spec_base']['barcode'];
|
||
$goods['extends'] = $goods_base['data']['spec_base']['extends'];
|
||
// 库存单位
|
||
if(!empty($goods_base['data']['spec_base']['inventory_unit']))
|
||
{
|
||
$goods['inventory_unit'] = $goods_base['data']['spec_base']['inventory_unit'];
|
||
if(!empty($goods['show_price_unit']))
|
||
{
|
||
$goods['show_price_unit'] = ' / '.$goods['inventory_unit'];
|
||
}
|
||
if(!empty($goods['show_original_price_unit']))
|
||
{
|
||
$goods['show_original_price_unit'] = ' / '.$goods['inventory_unit'];
|
||
}
|
||
}
|
||
|
||
// 商品价格容器赋值规格价格
|
||
$goods['price_container']['price'] = $goods['price'];
|
||
$goods['price_container']['original_price'] = $goods['original_price'];
|
||
} else {
|
||
return $goods_base;
|
||
}
|
||
|
||
// 获取商品规格图片
|
||
if(!empty($goods['spec']))
|
||
{
|
||
$images = self::BuyGoodsSpecImages($goods['goods_id'], $goods['spec']);
|
||
if(!empty($images))
|
||
{
|
||
$goods['images'] = ResourcesService::AttachmentPathViewHandle($images);
|
||
}
|
||
}
|
||
|
||
// 数量/小计
|
||
$goods['stock'] = $v['stock'];
|
||
$goods['total_price'] = $v['stock']* ((float) $goods['price']);
|
||
$data[] = $goods;
|
||
}
|
||
}
|
||
$ret['data'] = $data;
|
||
return $ret;
|
||
}
|
||
|
||
/**
|
||
* 商品规格解析
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-09-21
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function GoodsSpecificationsHandle($params = [])
|
||
{
|
||
$spec = '';
|
||
if(!empty($params['spec']))
|
||
{
|
||
if(!is_array($params['spec']))
|
||
{
|
||
$spec = json_decode(htmlspecialchars_decode($params['spec']), true);
|
||
} else {
|
||
$spec = $params['spec'];
|
||
}
|
||
}
|
||
return empty($spec) ? '' : $spec;
|
||
}
|
||
|
||
/**
|
||
* 下订单 - 购物车
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-09-21
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyCart($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'ids',
|
||
'error_msg' => MyLang('common_service.buy.cart_id_error_tips'),
|
||
],
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'user',
|
||
'error_msg' => MyLang('user_info_incorrect_tips'),
|
||
],
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 获取购物车数据
|
||
$params['where'] = [
|
||
['g.is_delete_time', '=', 0],
|
||
['g.is_shelves', '=', 1],
|
||
['c.id', 'in', explode(',', $params['ids'])],
|
||
];
|
||
return GoodsCartService::GoodsCartList($params);
|
||
}
|
||
|
||
/**
|
||
* 获取规格图片
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2019-08-02
|
||
* @desc description
|
||
* @param [int] $goods_id [商品id]
|
||
* @param [string] $spec [图片地址或空字符串]
|
||
*/
|
||
public static function BuyGoodsSpecImages($goods_id, $spec)
|
||
{
|
||
if(!empty($spec))
|
||
{
|
||
$data = Db::name('GoodsSpecType')->where(['goods_id'=>$goods_id])->field('name,value')->select()->toArray();
|
||
if(!empty($data))
|
||
{
|
||
$spec_images = [];
|
||
foreach($data as $v)
|
||
{
|
||
if(!empty($v['value']))
|
||
{
|
||
foreach(json_decode($v['value'], true) as $vs)
|
||
{
|
||
if(!empty($vs['images']))
|
||
{
|
||
$spec_images[$v['name']][$vs['name']] = $vs['images'];
|
||
}
|
||
}
|
||
}
|
||
}
|
||
if(!empty($spec_images))
|
||
{
|
||
foreach($spec as $v)
|
||
{
|
||
if(array_key_exists($v['type'], $spec_images) && array_key_exists($v['value'], $spec_images[$v['type']]))
|
||
{
|
||
return $spec_images[$v['type']][$v['value']];
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return '';
|
||
}
|
||
|
||
/**
|
||
* 下订单购物车删除
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @datetime 2018-10-12T00:42:49+0800
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyCartDelete($params = [])
|
||
{
|
||
if(isset($params['buy_type']) && $params['buy_type'] == 'cart' && !empty($params['ids']))
|
||
{
|
||
Db::name('Cart')->where(['id'=>explode(',', $params['ids'])])->delete();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 根据购买类型获取商品列表
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-09-26
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyTypeGoodsList($params = [])
|
||
{
|
||
if(isset($params['buy_type']))
|
||
{
|
||
switch($params['buy_type'])
|
||
{
|
||
// 正常购买
|
||
case 'goods' :
|
||
$goods = self::BuyGoods($params);
|
||
break;
|
||
|
||
// 购物车
|
||
case 'cart' :
|
||
$goods = self::BuyCart($params);
|
||
break;
|
||
|
||
// 默认
|
||
default :
|
||
$goods = DataReturn(MyLang('params_error_tips'), -1);
|
||
}
|
||
} else {
|
||
$goods = DataReturn(MyLang('params_error_tips'), -1);
|
||
}
|
||
|
||
// 数据组装
|
||
if($goods['code'] == 0)
|
||
{
|
||
// 下单类型
|
||
$model = self::BuyOredrSiteTypeModelData($goods['data'], $params);
|
||
|
||
// 数据处理
|
||
$address = null;
|
||
$extraction_address = [];
|
||
|
||
// 站点模式 - 用户收货地址（未选择则取默认地址）
|
||
// 销售,同城
|
||
if(in_array($model['site_model'], [0,1]))
|
||
{
|
||
$address_params = [
|
||
'user' => $params['user'],
|
||
];
|
||
if(!empty($params['address_id']))
|
||
{
|
||
$address_params['where'] = ['id' => $params['address_id']];
|
||
}
|
||
$ads = UserAddressService::UserDefaultAddress($address_params);
|
||
if(!empty($ads['data']))
|
||
{
|
||
$address = $ads['data'];
|
||
}
|
||
}
|
||
|
||
// 自提模式 - 自提点地址
|
||
if($model['site_model'] == 2)
|
||
{
|
||
$extraction = self::SiteExtractionAddress($params);
|
||
if(!empty($extraction['data']['data_list']))
|
||
{
|
||
$extraction_address = $extraction['data']['data_list'];
|
||
}
|
||
if(!empty($extraction['data']['default']))
|
||
{
|
||
$address = $extraction['data']['default'];
|
||
}
|
||
}
|
||
|
||
// 订单拆分处理
|
||
return self::OrderSplitHandle($model['site_model'], $model['common_site_type'], $address, $extraction_address, $goods['data'], $params);
|
||
}
|
||
return $goods;
|
||
}
|
||
|
||
/**
|
||
* 下单站点类型数据
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2023-12-10
|
||
* @desc description
|
||
* @param [array] $goods [订单商品数据]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyOredrSiteTypeModelData($goods, $params = [])
|
||
{
|
||
// 站点模式 0快递, 1同城, 2自提, 3虚拟, 4展示, 5快递+自提, 6同城+自提, 7快递+同城, 8快递+同城+自提
|
||
$common_site_type = SystemBaseService::SiteTypeValue();
|
||
if(!isset($params['site_model']) || $params['site_model'] == -1)
|
||
{
|
||
// 用户未指定或者负数则默认第一种模式
|
||
$user_site_model = ($common_site_type >= 5) ? (in_array($common_site_type, [5,7,8]) ? 0 : 1) : $common_site_type;
|
||
} else {
|
||
$user_site_model = intval($params['site_model']);
|
||
}
|
||
$site_model = ($common_site_type >= 5) ? $user_site_model : $common_site_type;
|
||
|
||
// 商品销售模式
|
||
// 商品小于等于1则使用商品的类型
|
||
if(!empty($goods) && count($goods) == 1 && isset($goods[0]) && isset($goods[0]['goods_id']))
|
||
{
|
||
$ret = GoodsService::GoodsSalesModelType($goods[0]['goods_id']);
|
||
$common_site_type = $ret['data'];
|
||
$site_model = ($ret['data'] >= 5) ? $user_site_model : $ret['data'];
|
||
}
|
||
|
||
// 下单站点类型数据钩子
|
||
$hook_name = 'plugins_service_buy_oredr_site_type_model';
|
||
MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'params' => $params,
|
||
'common_site_type' => &$common_site_type,
|
||
'site_model' => &$site_model,
|
||
]);
|
||
|
||
return [
|
||
'common_site_type' => $common_site_type,
|
||
'site_model' => $site_model,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 订单拆分处理
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2021-09-06
|
||
* @desc description
|
||
* @param [int] $site_model [当前指定类型]
|
||
* @param [int] $common_site_type [当前站点类型]
|
||
* @param [array] $address [收货地址]
|
||
* @param [array] $extraction_address [自提地址]
|
||
* @param [array] $goods [订单商品]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function OrderSplitHandle($site_model, $common_site_type, $address, $extraction_address, $goods, $params)
|
||
{
|
||
// 订单拆分
|
||
$order_split = OrderSplitService::Run([
|
||
'site_model' => $site_model,
|
||
'common_site_type' => $common_site_type,
|
||
'address' => $address,
|
||
'extraction_address' => $extraction_address,
|
||
'goods' => $goods,
|
||
'params' => $params,
|
||
]);
|
||
if($order_split['code'] != 0)
|
||
{
|
||
return $order_split;
|
||
}
|
||
|
||
// 订单总计基础信息字段处理
|
||
$base_fields = [
|
||
'total_price' => 0,
|
||
'actual_price' => 0,
|
||
'preferential_price' => 0,
|
||
'increase_price' => 0,
|
||
'goods_count' => 0,
|
||
'spec_weight_total' => 0,
|
||
'spec_volume_total' => 0,
|
||
'buy_count' => 0,
|
||
];
|
||
if(!empty($order_split['data']))
|
||
{
|
||
$order_base = array_column($order_split['data'], 'order_base');
|
||
foreach($base_fields as $field=>$value)
|
||
{
|
||
$base_fields[$field] = array_sum(array_column($order_base, $field));
|
||
}
|
||
}
|
||
|
||
// 订单总计基础信息组合
|
||
$base = [
|
||
// 总价
|
||
'total_price' => $base_fields['total_price'],
|
||
|
||
// 订单实际支付金额(已减去优惠金额, 已加上增加金额)
|
||
'actual_price' => $base_fields['actual_price'],
|
||
|
||
// 优惠金额
|
||
'preferential_price' => $base_fields['preferential_price'],
|
||
|
||
// 增加金额
|
||
'increase_price' => $base_fields['increase_price'],
|
||
|
||
// 商品数量
|
||
'goods_count' => $base_fields['goods_count'],
|
||
|
||
// 规格重量总计
|
||
'spec_weight_total' => $base_fields['spec_weight_total'],
|
||
|
||
// 规格体积总计
|
||
'spec_volume_total' => $base_fields['spec_volume_total'],
|
||
|
||
// 购买总数
|
||
'buy_count' => $base_fields['buy_count'],
|
||
|
||
// 默认地址
|
||
'address' => $address,
|
||
|
||
// 自提地址列表
|
||
'extraction_address' => $extraction_address,
|
||
|
||
// 当前使用的站点模式
|
||
'site_model' => $site_model,
|
||
|
||
// 公共站点模式
|
||
'common_site_type' => $common_site_type,
|
||
];
|
||
|
||
// 返回数据
|
||
$result = [
|
||
'goods' => $order_split['data'],
|
||
'base' => $base,
|
||
];
|
||
|
||
// 生成订单数据处理钩子
|
||
$hook_name = 'plugins_service_buy_handle';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'params' => $params,
|
||
'data' => &$result,
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
|
||
// 返回数据再次处理，防止钩子插件处理不够完善
|
||
$result['base']['total_price'] = ($result['base']['total_price'] <= 0) ? 0.00 : PriceNumberFormat($result['base']['total_price']);
|
||
$result['base']['actual_price'] = ($result['base']['actual_price'] <= 0) ? 0.00 : PriceNumberFormat($result['base']['actual_price']);
|
||
$result['base']['preferential_price'] = ($result['base']['preferential_price'] <= 0) ? 0.00 : PriceNumberFormat($result['base']['preferential_price']);
|
||
$result['base']['increase_price'] = ($result['base']['increase_price'] <= 0) ? 0.00 : PriceNumberFormat($result['base']['increase_price']);
|
||
|
||
return DataReturn(MyLang('operate_success'), 0, $result);
|
||
}
|
||
|
||
/**
|
||
* 购买商品校验
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-09-26
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyGoodsCheck($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'goods',
|
||
'error_msg' => MyLang('goods_data_empty_tips'),
|
||
],
|
||
[
|
||
'checked_type' => 'is_array',
|
||
'key_name' => 'goods',
|
||
'error_msg' => MyLang('goods_info_incorrect_tips'),
|
||
]
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 是否需要校验商品类型、is_buy、1校验、默认0不校验
|
||
$is_check_goods_site_type = (isset($params['is_buy']) && $params['is_buy'] == 1) ? 1 : 0;
|
||
// 商品小于等于1不校验
|
||
if($is_check_goods_site_type == 1 &&
|
||
count(array_unique(array_column($params['goods'], 'goods_id'))) <= 1)
|
||
{
|
||
$is_check_goods_site_type = 0;
|
||
}
|
||
|
||
// 是否存在字段缺失
|
||
$goods_data = [];
|
||
if(!array_key_exists('is_shelves', $params['goods'][0]))
|
||
{
|
||
$goods_data = Db::name('Goods')->where(['id'=>array_column($params['goods'], 'goods_id')])->column('is_shelves,buy_min_number,buy_max_number,site_type', 'id');
|
||
}
|
||
|
||
// 数据校验
|
||
foreach($params['goods'] as $v)
|
||
{
|
||
// 数据合并
|
||
if(!empty($goods_data) && array_key_exists($v['goods_id'], $goods_data))
|
||
{
|
||
$v = array_merge($v, $goods_data[$v['goods_id']]);
|
||
}
|
||
|
||
// 是否存在规格所属数据
|
||
if(!array_key_exists('spec_buy_min_number', $v) || !array_key_exists('spec_buy_max_number', $v))
|
||
{
|
||
$goods_base = GoodsService::GoodsSpecDetail(array_merge($params, [
|
||
'id' => $v['goods_id'],
|
||
'spec' => isset($v['spec']) ? $v['spec'] : [],
|
||
]));
|
||
if($goods_base['code'] == 0)
|
||
{
|
||
$v['price'] = $goods_base['data']['spec_base']['price'];
|
||
$v['inventory'] = $goods_base['data']['spec_base']['inventory'];
|
||
$v['spec_buy_min_number'] = $goods_base['data']['spec_base']['buy_min_number'];
|
||
$v['spec_buy_max_number'] = $goods_base['data']['spec_base']['buy_max_number'];
|
||
} else {
|
||
return $goods_base;
|
||
}
|
||
}
|
||
|
||
// 基础判断
|
||
if($v['is_shelves'] != 1)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_already_shelves_tips').'['.$v['title'].']', -1);
|
||
}
|
||
|
||
// 先判断规格的起购数、则再判断商品的起购数
|
||
$min = (isset($v['spec_buy_min_number']) && $v['spec_buy_min_number'] > 0) ? $v['spec_buy_min_number'] : (isset($v['buy_min_number']) ? $v['buy_min_number'] : 0);
|
||
if($min > 0 && $v['stock'] < $min)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_buy_min_error_tips').'['.$v['title'].']['.$v['stock'].'<'.$min.']', -1);
|
||
}
|
||
|
||
// 先判断规格的限购数、则再判断商品的限购数
|
||
$max = (isset($v['spec_buy_max_number']) && $v['spec_buy_max_number'] > 0) ? $v['spec_buy_max_number'] : (isset($v['buy_max_number']) ? $v['buy_max_number'] : 0);
|
||
if($max > 0 && $v['stock'] > $max)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_buy_max_error_tips').'['.$v['title'].']['.$v['stock'].'>'.$max.']', -1);
|
||
}
|
||
|
||
// 是否支持购物车操作
|
||
if($is_check_goods_site_type)
|
||
{
|
||
$ret = GoodsService::IsGoodsSiteTypeConsistent($v['goods_id'], $v['site_type']);
|
||
if($ret['code'] != 0)
|
||
{
|
||
return DataReturn($ret['msg'].'['.$v['title'].']', $ret['code']);
|
||
}
|
||
}
|
||
|
||
// 库存
|
||
if($v['stock'] > $v['inventory'])
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_buy_exceed_inventory_tips').'['.$v['title'].']['.$v['stock'].'>'.$v['inventory'].']', -1);
|
||
}
|
||
}
|
||
return DataReturn(MyLang('check_success'), 0);
|
||
}
|
||
|
||
/**
|
||
* 订单添加
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-09-26
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function OrderInsert($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'user',
|
||
'error_msg' => MyLang('user_info_incorrect_tips'),
|
||
],
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 查询用户状态是否正常
|
||
$ret = UserService::UserStatusCheck($params['user']['id']);
|
||
if($ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
|
||
// 清单商品
|
||
$params['is_order_submit'] = 1;
|
||
$buy = self::BuyTypeGoodsList($params);
|
||
if(!isset($buy['code']) || $buy['code'] != 0)
|
||
{
|
||
return $buy;
|
||
}
|
||
|
||
// 下单类型
|
||
$model = self::BuyOredrSiteTypeModelData(($buy['data']['base']['goods_count'] == 1) ? $buy['data']['goods'][0]['goods_items'] : null, $params);
|
||
// 站点展示型
|
||
if($model['common_site_type'] == 4)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.exhibition_not_allow_submit_tips'), -1);
|
||
}
|
||
// 快递,同城,自提点 则校验地址（自提的地址id可以是0、所以这里恒等null）
|
||
if((in_array($model['site_model'], [0,1]) && empty($params['address_id'])) || $model['site_model'] == 2 && $params['address_id'] === null)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.choice_not_address_tips'), -1);
|
||
}
|
||
|
||
// 是否预约模式
|
||
$common_order_is_booking = MyC('common_order_is_booking', 0);
|
||
|
||
// 金额大于0、非预约模式 必须选择支付方式
|
||
if($buy['data']['base']['actual_price'] > 0 && $common_order_is_booking != 1)
|
||
{
|
||
if(empty($params['payment_id']))
|
||
{
|
||
return DataReturn(MyLang('payment_method_error_tips'), -1);
|
||
}
|
||
}
|
||
|
||
// 用户留言
|
||
$user_note = empty($params['user_note']) ? '' : str_replace(['"', "'"], '', strip_tags($params['user_note']));
|
||
|
||
// 订单默认状态
|
||
$order_status = ($common_order_is_booking == 1) ? 0 : 1;
|
||
|
||
// 支付方式
|
||
$payment_id = 0;
|
||
$is_under_line = 0;
|
||
if(!empty($params['payment_id']))
|
||
{
|
||
$payment = PaymentService::PaymentData(['where'=>['id'=>intval($params['payment_id'])]]);
|
||
if(empty($payment))
|
||
{
|
||
return DataReturn(MyLang('payment_method_error_tips'), -1);
|
||
}
|
||
$payment_id = $payment['id'];
|
||
$is_under_line = in_array($payment['payment'], MyConfig('shopxo.under_line_list')) ? 1 : 0;
|
||
|
||
// 线下支付订单是否直接成功
|
||
// 是否开启线下订单正常进入流程
|
||
if($common_order_is_booking != 1 && $is_under_line == 1 && MyC('common_is_under_line_order_normal') == 1)
|
||
{
|
||
$order_status = 2;
|
||
}
|
||
}
|
||
$payment_id = intval($payment_id);
|
||
|
||
// 循环处理数据
|
||
$order_data = [];
|
||
foreach($buy['data']['goods'] as $v)
|
||
{
|
||
// 商品校验
|
||
$check = self::BuyGoodsCheck(['goods'=>$v['goods_items'], 'is_buy'=>1]);
|
||
if($check['code'] != 0)
|
||
{
|
||
return $check;
|
||
}
|
||
|
||
// 快递,同城,自提点 地址处理
|
||
$address = [];
|
||
if(in_array($model['site_model'], [0,1,2]))
|
||
{
|
||
if(empty($v['order_base']['address']))
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.address_empty_tips'), -1);
|
||
} else {
|
||
$address = $v['order_base']['address'];
|
||
}
|
||
}
|
||
|
||
// 订单主信息
|
||
$order = [
|
||
'user_id' => $params['user']['id'],
|
||
'warehouse_id' => $v['id'],
|
||
'user_note' => $user_note,
|
||
'status' => $order_status,
|
||
'preferential_price' => ($v['order_base']['preferential_price'] <= 0.00) ? 0.00 : $v['order_base']['preferential_price'],
|
||
'increase_price' => ($v['order_base']['increase_price'] <= 0.00) ? 0.00 : $v['order_base']['increase_price'],
|
||
'price' => ($v['order_base']['total_price'] <= 0.00) ? 0.00 : $v['order_base']['total_price'],
|
||
'total_price' => ($v['order_base']['actual_price'] <= 0.00) ? 0.00 : $v['order_base']['actual_price'],
|
||
'extension_data' => empty($v['order_base']['extension_data']) ? '' : json_encode(array_values($v['order_base']['extension_data']), JSON_UNESCAPED_UNICODE),
|
||
'payment_id' => $payment_id,
|
||
'buy_number_count' => $v['order_base']['buy_count'],
|
||
'client_type' => APPLICATION_CLIENT_TYPE,
|
||
'order_model' => $model['site_model'],
|
||
'is_under_line' => $is_under_line,
|
||
];
|
||
|
||
// 订单地址
|
||
$order['address_data'] = $address;
|
||
|
||
// 订单详情
|
||
$order['detail_data'] = [];
|
||
foreach($v['goods_items'] as $vs)
|
||
{
|
||
$order['detail_data'][] = [
|
||
'user_id' => $order['user_id'],
|
||
'goods_id' => $vs['goods_id'],
|
||
'title' => $vs['title'],
|
||
'images' => $vs['images'],
|
||
'original_price' => $vs['original_price'],
|
||
'price' => $vs['price'],
|
||
'total_price' => PriceNumberFormat($vs['stock']*$vs['price']),
|
||
'spec' => empty($vs['spec']) ? '' : json_encode($vs['spec'], JSON_UNESCAPED_UNICODE),
|
||
'buy_number' => intval($vs['stock']),
|
||
'inventory_unit' => $vs['inventory_unit'],
|
||
'brand_id' => $vs['brand_id'],
|
||
'simple_desc' => $vs['simple_desc'],
|
||
'spec_desc' => $vs['spec_desc'],
|
||
'approval_number' => $vs['approval_number'],
|
||
'approval_number_expire' => $vs['approval_number_expire'],
|
||
'batch_number' => $vs['batch_number'],
|
||
'batch_number_expire' => $vs['batch_number_expire'],
|
||
'coding' => $vs['coding'],
|
||
'model' => $vs['model'],
|
||
'produce_company' => $vs['produce_company'],
|
||
'produce_region' => $vs['produce_region'],
|
||
'goods_content_web' => empty($vs['content_web']) ? '' : ResourcesService::ContentStaticReplace(htmlspecialchars_decode($vs['content_web']), 'add'),
|
||
'goods_use_guide' => empty($vs['use_guide']) ? '' : ResourcesService::ContentStaticReplace(htmlspecialchars_decode($vs['use_guide']), 'add'),
|
||
'spec_weight' => empty($vs['spec_weight']) ? 0.00 : (float) $vs['spec_weight'],
|
||
'spec_volume' => empty($vs['spec_volume']) ? 0.00 : (float) $vs['spec_volume'],
|
||
'spec_coding' => empty($vs['spec_coding']) ? '' : $vs['spec_coding'],
|
||
'spec_barcode' => empty($vs['spec_barcode']) ? '' : $vs['spec_barcode'],
|
||
'extends' => empty($vs['extends']) ? '' : json_decode($vs['extends'], true),
|
||
];
|
||
}
|
||
$order_data[] = $order;
|
||
}
|
||
|
||
// 订单添加处理
|
||
$order_ids = [];
|
||
$ret = self::OrderInsertHandle($order_data, $params);
|
||
if($ret['code'] == 0)
|
||
{
|
||
$order_ids = $ret['data'];
|
||
} else {
|
||
return $ret;
|
||
}
|
||
|
||
// 删除购物车
|
||
self::BuyCartDelete($params);
|
||
|
||
// 返回信息
|
||
$data = [
|
||
'order_status' => $order_status,
|
||
'order_ids' => $order_ids,
|
||
'payment_id' => $payment_id,
|
||
'jump_url' => MyUrl('index/order/index'),
|
||
];
|
||
|
||
|
||
// 获取订单信息
|
||
switch($order_status)
|
||
{
|
||
// 预约成功
|
||
case 0 :
|
||
$msg = MyLang('common_service.buy.order_submit_booking_success_tips');
|
||
break;
|
||
|
||
// 提交成功,进入合并支付
|
||
case 1 :
|
||
$msg = MyLang('submit_success');
|
||
$data['jump_url'] = MyUrl('index/order/pay', ['ids'=>implode(',', $order_ids)]);
|
||
break;
|
||
|
||
// 默认操作成功
|
||
default :
|
||
$msg = MyLang('operate_success');
|
||
}
|
||
|
||
// 订单提交成功钩子
|
||
$hook_name = 'plugins_service_buy_order_submit_success';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'data' => &$data,
|
||
'params' => $params,
|
||
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
|
||
return DataReturn($msg, 0, $data);
|
||
}
|
||
|
||
/**
|
||
* 订单添加处理
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2021-09-05
|
||
* @desc description
|
||
* @param [array] $data [订单数据]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function OrderInsertHandle($data, $params = [])
|
||
{
|
||
// 所有订单id、单号
|
||
$order_ids = [];
|
||
$order_nos = [];
|
||
$order_data = [];
|
||
|
||
// 启动事务
|
||
Db::startTrans();
|
||
|
||
// 捕获异常
|
||
try {
|
||
// 循环处理
|
||
foreach($data as $v)
|
||
{
|
||
// 订单主信息
|
||
$v['order_no'] = self::OrderNoCreate();
|
||
$v['add_time'] = time();
|
||
|
||
// 确认时间
|
||
if($v['status'] == 1)
|
||
{
|
||
$v['confirm_time'] = time();
|
||
}
|
||
|
||
// 订单数据
|
||
$order = $v;
|
||
unset($order['address_data'], $order['detail_data']);
|
||
|
||
// 订单添加前钩子
|
||
$hook_name = 'plugins_service_buy_order_insert_begin';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'data' => $v,
|
||
'order' => &$order,
|
||
'goods' => &$v['detail_data'],
|
||
'params' => $params,
|
||
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
|
||
// 未指定系统类型则增加默认
|
||
if(empty($order['system_type']))
|
||
{
|
||
$order['system_type'] = empty($params['system_type']) ? SYSTEM_TYPE : $params['system_type'];
|
||
}
|
||
// 订单添加
|
||
$order_id = Db::name('Order')->insertGetId($order);
|
||
if($order_id <= 0)
|
||
{
|
||
throw new \Exception(MyLang('common_service.buy.order_insert_fail_tips'));
|
||
}
|
||
$order['id'] = $order_id;
|
||
|
||
// 订单详情商品需要记录的数据
|
||
// 当前所有商品id
|
||
$goods_ids = array_column($v['detail_data'], 'goods_id');
|
||
// 商品参数数据
|
||
$goods_params_group = [];
|
||
$goods_params_data = GoodsService::GoodsParametersData($goods_ids);
|
||
if(!empty($goods_params_data) && is_array($goods_params_data))
|
||
{
|
||
foreach($goods_params_data as $gpgk=>$gpgv)
|
||
{
|
||
foreach($gpgv as $gpgvgv)
|
||
{
|
||
if(!empty($gpgvgv) && is_array($gpgvgv))
|
||
{
|
||
if(!array_key_exists($gpgk, $goods_params_group))
|
||
{
|
||
$goods_params_group[$gpgk] = [];
|
||
}
|
||
foreach($gpgvgv as $gpgvk=>$gpgvv)
|
||
{
|
||
if(!array_key_exists($gpgvv['id'], $goods_params_group[$gpgk]))
|
||
{
|
||
$temp_id = $gpgvv['id'];
|
||
unset($gpgvv['id'], $gpgvv['goods_id'], $gpgvv['add_time']);
|
||
$goods_params_group[$gpgk][$temp_id] = $gpgvv;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
// 商品手机端详情数据
|
||
$goods_content_app_group = GoodsService::GoodsAppData($goods_ids);
|
||
if(!empty($goods_content_app_group) && is_array($goods_content_app_group))
|
||
{
|
||
foreach($goods_content_app_group as $gapk=>$gapv)
|
||
{
|
||
if(!empty($gapv) && is_array($gapv))
|
||
{
|
||
foreach($gapv as $gapvk=>$gapvv)
|
||
{
|
||
$goods_content_app_group[$gapk][$gapvk]['images'] = ResourcesService::AttachmentPathHandle($gapvv['images']);
|
||
unset($goods_content_app_group[$gapk][$gapvk]['id'], $goods_content_app_group[$gapk][$gapvk]['goods_id'], $goods_content_app_group[$gapk][$gapvk]['content_old']);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 订单详情添加
|
||
foreach($v['detail_data'] as &$vs)
|
||
{
|
||
// 合并需要记录的数据
|
||
$vs = array_merge($vs, [
|
||
'goods_params' => (!empty($goods_params_group) && !empty($goods_params_group[$vs['goods_id']])) ? json_encode(array_values($goods_params_group[$vs['goods_id']]), JSON_UNESCAPED_UNICODE) : '',
|
||
'goods_content_app' => (!empty($goods_content_app_group) && !empty($goods_content_app_group[$vs['goods_id']])) ? json_encode($goods_content_app_group[$vs['goods_id']], JSON_UNESCAPED_UNICODE) : '',
|
||
]);
|
||
// 添加订单详情数据,data返回自增id
|
||
$order_detail_id = 0;
|
||
$ret = self::OrderDetailInsert($order_id, $order['user_id'], $vs, $params);
|
||
if($ret['code'] == 0)
|
||
{
|
||
$order_detail_id = $ret['data'];
|
||
$vs['id'] = $order_detail_id;
|
||
} else {
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
|
||
// 订单模式 - 虚拟信息添加
|
||
if($order['order_model'] == 3)
|
||
{
|
||
$ret = self::OrderFictitiousValueInsert($order_id, $order_detail_id, $order['user_id'], $vs['goods_id'], $params);
|
||
if($ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
}
|
||
}
|
||
|
||
// 订单模式处理 销售,同城,自提
|
||
if(in_array($order['order_model'], [0,1,2]))
|
||
{
|
||
// 添加订单(收货|取货)地址
|
||
if(!empty($v['address_data']))
|
||
{
|
||
$ret = self::OrderAddressInsert($order_id, $order['user_id'], $v['address_data'], $params);
|
||
if($ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
}
|
||
|
||
// 自提模式 添加订单取货码
|
||
if($order['order_model'] == 2)
|
||
{
|
||
$ret = self::OrderExtractionCcodeInsert($order_id, $order['user_id'], $params);
|
||
if($ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
}
|
||
}
|
||
|
||
// 订单货币
|
||
$ret = OrderCurrencyService::OrderCurrencyInsert($order_id, $order['user_id'], $params);
|
||
if($ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
|
||
// 库存扣除
|
||
if(in_array($order['status'], [1,2]))
|
||
{
|
||
$ret = self::OrderInventoryDeduct(['order_id'=>$order_id, 'opt_type'=>'confirm']);
|
||
if($ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
}
|
||
|
||
// 订单状态日志
|
||
$creator = isset($params['creator']) ? intval($params['creator']) : 0;
|
||
$creator_name = isset($params['creator_name']) ? htmlentities($params['creator_name']) : '';
|
||
OrderService::OrderHistoryAdd($order_id, '', $order['status'], MyLang('created_title'), $creator, $creator_name);
|
||
|
||
// 订单添加成功钩子
|
||
$hook_name = 'plugins_service_buy_order_insert_end';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'order_id' => $order_id,
|
||
'order' => $order,
|
||
'data' => $v,
|
||
'goods' => $v['detail_data'],
|
||
'address' => $v['address_data'],
|
||
'params' => $params,
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
throw new \Exception($ret['msg']);
|
||
}
|
||
|
||
// 订单id、单号集合
|
||
$order_ids[] = $order_id;
|
||
$order_nos[] = $v['order_no'];
|
||
$order_data[] = [
|
||
'order_id' => $order_id,
|
||
'order_no' => $v['order_no'],
|
||
];
|
||
}
|
||
|
||
// 完成
|
||
Db::commit();
|
||
} catch(\Exception $e) {
|
||
Db::rollback();
|
||
return DataReturn($e->getMessage(), -1);
|
||
}
|
||
|
||
// 订单添加成功钩子, 不校验返回值
|
||
$hook_name = 'plugins_service_buy_order_insert_success';
|
||
MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'order_ids' => $order_ids,
|
||
'order_nos' => $order_nos,
|
||
'order_data' => $order_data,
|
||
'params' => $params,
|
||
]);
|
||
|
||
// 删除购买信息
|
||
if(!empty($data[0]) && !empty($data[0]['user_id']))
|
||
{
|
||
self::BuyDataDelete($data[0]['user_id']);
|
||
}
|
||
|
||
// 返回信息
|
||
return DataReturn(MyLang('operate_success'), 0, $order_ids);
|
||
}
|
||
|
||
/**
|
||
* 订单号生成
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2021-08-17
|
||
* @desc description
|
||
*/
|
||
public static function OrderNoCreate()
|
||
{
|
||
return date('YmdHis').GetNumberCode(6);
|
||
}
|
||
|
||
/**
|
||
* 订单详情添加
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2019-11-20
|
||
* @desc description
|
||
* @param [int] $order_id [订单id]
|
||
* @param [int] $user_id [用户id]
|
||
* @param [array] $detail [商品详情数据]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
private static function OrderDetailInsert($order_id, $user_id, $detail, $params = [])
|
||
{
|
||
$data = [
|
||
'order_id' => $order_id,
|
||
'user_id' => $user_id,
|
||
'goods_id' => $detail['goods_id'],
|
||
'title' => $detail['title'],
|
||
'images' => ResourcesService::AttachmentPathHandle($detail['images']),
|
||
'original_price' => $detail['original_price'],
|
||
'price' => $detail['price'],
|
||
'total_price' => PriceNumberFormat(isset($detail['total_price']) ? $detail['total_price'] : $detail['total_price']*$detail['buy_number']),
|
||
'spec' => empty($detail['spec']) ? '' : (is_array($detail['spec']) ? json_encode($detail['spec'], JSON_UNESCAPED_UNICODE) : $detail['spec']),
|
||
'buy_number' => intval($detail['buy_number']),
|
||
'inventory_unit' => $detail['inventory_unit'],
|
||
'brand_id' => $detail['brand_id'],
|
||
'simple_desc' => $detail['simple_desc'],
|
||
'spec_desc' => $detail['spec_desc'],
|
||
'approval_number' => $detail['approval_number'],
|
||
'approval_number_expire' => empty($detail['approval_number_expire']) ? 0 : (is_numeric($detail['approval_number_expire']) ? $detail['approval_number_expire'] : strtotime($detail['approval_number_expire'])),
|
||
'batch_number' => $detail['batch_number'],
|
||
'batch_number_expire' => empty($detail['batch_number_expire']) ? 0 : (is_numeric($detail['batch_number_expire']) ? $detail['batch_number_expire'] : strtotime($detail['batch_number_expire'])),
|
||
'coding' => $detail['coding'],
|
||
'model' => $detail['model'],
|
||
'produce_company' => $detail['produce_company'],
|
||
'produce_region' => $detail['produce_region'],
|
||
'goods_params' => $detail['goods_params'],
|
||
'goods_content_app' => $detail['goods_content_app'],
|
||
'goods_content_web' => $detail['goods_content_web'],
|
||
'goods_use_guide' => $detail['goods_use_guide'],
|
||
'spec_weight' => empty($detail['spec_weight']) ? 0.00 : (float) $detail['spec_weight'],
|
||
'spec_volume' => empty($detail['spec_volume']) ? 0.00 : (float) $detail['spec_volume'],
|
||
'spec_coding' => empty($detail['spec_coding']) ? '' : $detail['spec_coding'],
|
||
'spec_barcode' => empty($detail['spec_barcode']) ? '' : $detail['spec_barcode'],
|
||
'add_time' => time(),
|
||
];
|
||
|
||
// 订单详情添加前钩子
|
||
$hook_name = 'plugins_service_buy_order_detail_insert_begin';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'order_id' => $order_id,
|
||
'user_id' => $user_id,
|
||
'data' => &$data,
|
||
'params' => $params,
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
|
||
// 添加订单详情数据
|
||
$order_detail_id = Db::name('OrderDetail')->insertGetId($data);
|
||
if($order_detail_id > 0)
|
||
{
|
||
return DataReturn(MyLang('insert_success'), 0, $order_detail_id);
|
||
}
|
||
return DataReturn(MyLang('common_service.buy.order_detail_insert_fail_tips'), -1);
|
||
}
|
||
|
||
/**
|
||
* 订单关联自提取货码添加
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2019-11-20
|
||
* @desc description
|
||
* @param [int] $order_id [订单id]
|
||
* @param [int] $user_id [用户id]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
private static function OrderExtractionCcodeInsert($order_id, $user_id, $params = [])
|
||
{
|
||
$data = [
|
||
'order_id' => $order_id,
|
||
'user_id' => $user_id,
|
||
'code' => GetNumberCode(4),
|
||
'add_time' => time(),
|
||
];
|
||
|
||
// 订单取货码添加前钩子
|
||
$hook_name = 'plugins_service_buy_order_extraction_code_insert_begin';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'user_id' => $user_id,
|
||
'order_id' => $order_id,
|
||
'data' => &$data,
|
||
'params' => $params,
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
|
||
// 添加订单虚拟数据
|
||
if(Db::name('OrderExtractionCode')->insertGetId($data) > 0)
|
||
{
|
||
return DataReturn(MyLang('insert_success'), 0);
|
||
}
|
||
return DataReturn(MyLang('common_service.buy.order_take_insert_fail_tips'), -1);
|
||
}
|
||
|
||
/**
|
||
* 订单关联虚拟销售数据添加
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2019-11-20
|
||
* @desc description
|
||
* @param [int] $order_id [订单id]
|
||
* @param [int] $order_detail_id [订单详情id]
|
||
* @param [int] $user_id [用户id]
|
||
* @param [int] $goods_id [商品id]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
private static function OrderFictitiousValueInsert($order_id, $order_detail_id, $user_id, $goods_id, $params = [])
|
||
{
|
||
$data = [
|
||
'order_id' => $order_id,
|
||
'order_detail_id' => $order_detail_id,
|
||
'user_id' => $user_id,
|
||
'value' => Db::name('Goods')->where(['id'=>$goods_id])->value('fictitious_goods_value'),
|
||
'add_time' => time(),
|
||
];
|
||
|
||
// 订单虚拟数据添加前钩子
|
||
$hook_name = 'plugins_service_buy_order_fictitious_insert_begin';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'user_id' => $user_id,
|
||
'order_id' => $order_id,
|
||
'order_detail_id' => $order_detail_id,
|
||
'goods_id' => $goods_id,
|
||
'data' => &$data,
|
||
'params' => $params,
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
|
||
// 添加订单虚拟数据
|
||
if(Db::name('OrderFictitiousValue')->insertGetId($data) > 0)
|
||
{
|
||
return DataReturn(MyLang('insert_success'), 0);
|
||
}
|
||
return DataReturn(MyLang('common_service.buy.order_fictitious_insert_fail_tips'), -1);
|
||
}
|
||
|
||
/**
|
||
* 订单关联地址添加
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2019-11-20
|
||
* @desc description
|
||
* @param [int] $order_id [订单id]
|
||
* @param [int] $user_id [用户id]
|
||
* @param [array] $address [地址]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
private static function OrderAddressInsert($order_id, $user_id, $address, $params = [])
|
||
{
|
||
// 订单收货地址
|
||
$data = [
|
||
'order_id' => $order_id,
|
||
'user_id' => $user_id,
|
||
'address_id' => isset($address['id']) ? intval($address['id']) : 0,
|
||
'alias' => isset($address['alias']) ? $address['alias'] : '',
|
||
'name' => isset($address['name']) ? $address['name'] : '',
|
||
'tel' => isset($address['tel']) ? $address['tel'] : '',
|
||
'province' => isset($address['province']) ? intval($address['province']) : 0,
|
||
'city' => isset($address['city']) ? intval($address['city']) : 0,
|
||
'county' => isset($address['county']) ? intval($address['county']) : 0,
|
||
'address' => isset($address['address']) ? $address['address'] : '',
|
||
'province_name' => isset($address['province_name']) ? $address['province_name'] : '',
|
||
'city_name' => isset($address['city_name']) ? $address['city_name'] : '',
|
||
'county_name' => isset($address['county_name']) ? $address['county_name'] : '',
|
||
'lng' => isset($address['lng']) ? (float) $address['lng'] : '0.0000000000',
|
||
'lat' => isset($address['lat']) ? (float) $address['lat'] : '0.0000000000',
|
||
'appoint_time' => empty($params['appoint_time']) ? '' : trim($params['appoint_time']),
|
||
'extraction_contact_name' => empty($params['extraction_contact_name']) ? '' : trim($params['extraction_contact_name']),
|
||
'extraction_contact_tel' => empty($params['extraction_contact_tel']) ? '' : trim($params['extraction_contact_tel']),
|
||
'idcard_name' => empty($address['idcard_name']) ? '' : $address['idcard_name'],
|
||
'idcard_number' => empty($address['idcard_number']) ? '' : $address['idcard_number'],
|
||
'idcard_front' => empty($address['idcard_front']) ? '' : ResourcesService::AttachmentPathHandle($address['idcard_front']),
|
||
'idcard_back' => empty($address['idcard_back']) ? '' : ResourcesService::AttachmentPathHandle($address['idcard_back']),
|
||
'add_time' => time(),
|
||
];
|
||
|
||
// 订单地址添加前钩子
|
||
$hook_name = 'plugins_service_buy_order_address_insert_begin';
|
||
$ret = EventReturnHandle(MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'user_id' => $user_id,
|
||
'order_id' => $order_id,
|
||
'data' => &$data,
|
||
'params' => $params,
|
||
]));
|
||
if(isset($ret['code']) && $ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
|
||
// 添加订单地址
|
||
if(Db::name('OrderAddress')->insertGetId($data) > 0)
|
||
{
|
||
return DataReturn(MyLang('insert_success'), 0);
|
||
}
|
||
return DataReturn(MyLang('common_service.buy.order_address_insert_fail_tips'), -1);
|
||
}
|
||
|
||
/**
|
||
* 单个订单支付前校验
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-11-09
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function SingleOrderPayBeginCheck($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'order_id',
|
||
'error_msg' => MyLang('order_id_error_tips'),
|
||
],
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 是否扣除库存
|
||
$common_is_deduction_inventory = MyC('common_is_deduction_inventory', 0);
|
||
if($common_is_deduction_inventory != 1)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_not_enable_tips'), 0);
|
||
}
|
||
|
||
// 扣除库存规则
|
||
$common_deduction_inventory_rules = MyC('common_deduction_inventory_rules', 1);
|
||
|
||
// 这里仅订单支付规则类型下校验
|
||
if($common_deduction_inventory_rules == 1)
|
||
{
|
||
// 获取订单商品
|
||
$order_detail = Db::name('OrderDetail')->field('id,goods_id,buy_number,spec')->where(['order_id'=>$params['order_id']])->select()->toArray();
|
||
if(empty($order_detail))
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.order_detail_data_error_tips'), -1);
|
||
}
|
||
|
||
// 数据校验
|
||
foreach($order_detail as $v)
|
||
{
|
||
$ret = self::BuyOrderPayBeginGoodsCheck($v, $params);
|
||
if($ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
}
|
||
}
|
||
return DataReturn(MyLang('check_success'), 0);
|
||
}
|
||
|
||
/**
|
||
* 多个订单下单库存校验
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2020-08-04
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function MoreOrderPayBeginCheck($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'is_array',
|
||
'key_name' => 'order_data',
|
||
'error_msg' => MyLang('common_service.buy.order_data_error_tips'),
|
||
]
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 是否扣除库存
|
||
$common_is_deduction_inventory = MyC('common_is_deduction_inventory', 0);
|
||
if($common_is_deduction_inventory != 1)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_not_enable_tips'), 0);
|
||
}
|
||
|
||
// 扣除库存规则
|
||
$common_deduction_inventory_rules = MyC('common_deduction_inventory_rules', 1);
|
||
|
||
// 这里仅订单支付规则类型下校验
|
||
if($common_deduction_inventory_rules == 1)
|
||
{
|
||
// 数据集合
|
||
$detail = Db::name('OrderDetail')->field('id,order_id,goods_id,buy_number,spec')->where(['order_id'=>array_column($params['order_data'], 'id')])->select()->toArray();
|
||
if(empty($detail))
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.order_detail_data_error_tips'), -1);
|
||
}
|
||
|
||
// 订单集合
|
||
$order_group = [];
|
||
foreach($params['order_data'] as $o)
|
||
{
|
||
$order_group[$o['id']] = $o['warehouse_id'];
|
||
}
|
||
|
||
// 订单详情
|
||
$data = [];
|
||
foreach($detail as $d)
|
||
{
|
||
$key = md5(empty($d['spec']) ? 'default' : $d['spec']);
|
||
if(!isset($data[$order_group[$d['order_id']]][$d['goods_id']][$key]))
|
||
{
|
||
$data[$order_group[$d['order_id']]][$d['goods_id']][$key] = $d;
|
||
} else {
|
||
$data[$order_group[$d['order_id']]][$d['goods_id']][$key]['buy_number'] += $d['buy_number'];
|
||
}
|
||
}
|
||
|
||
// 数据校验
|
||
foreach($data as $w)
|
||
{
|
||
foreach($w as $g)
|
||
{
|
||
foreach($g as $v)
|
||
{
|
||
$ret = self::BuyOrderPayBeginGoodsCheck($v, $params);
|
||
if($ret['code'] != 0)
|
||
{
|
||
return $ret;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return DataReturn(MyLang('check_success'), 0);
|
||
}
|
||
|
||
/**
|
||
* 订单支付前商品校验
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2020-08-05
|
||
* @desc description
|
||
* @param [array] $detail [订单详情]
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyOrderPayBeginGoodsCheck($detail, $params)
|
||
{
|
||
// 获取商品
|
||
$goods = GoodsService::GoodsData($detail['goods_id'], 'is_shelves,is_deduction_inventory,inventory,title');
|
||
if(empty($goods))
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_no_exist_tips'), -10);
|
||
}
|
||
|
||
// 商品状态
|
||
if($goods['is_shelves'] != 1)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_already_shelves_tips').'['.$goods['title'].']', -10);
|
||
}
|
||
|
||
// 库存
|
||
if(isset($goods['is_deduction_inventory']) && $goods['is_deduction_inventory'] == 1)
|
||
{
|
||
// 先判断商品库存是否不足
|
||
if($goods['inventory'] < $detail['buy_number'])
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_inventory_not_enough_tips').'['.$goods['title'].'('.$goods['inventory'].'<'.$detail['buy_number'].')]', -10);
|
||
}
|
||
|
||
// 规格库存
|
||
$spec = empty($detail['spec']) ? '' : json_decode($detail['spec'], true);
|
||
$spec_params = array_merge($params, [
|
||
'id' => $detail['goods_id'],
|
||
'spec' => $spec,
|
||
]);
|
||
$base = GoodsService::GoodsSpecDetail($spec_params);
|
||
if($base['code'] == 0)
|
||
{
|
||
// 先判断商品规格库存是否不足
|
||
if($base['data']['spec_base']['inventory'] < $detail['buy_number'])
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_inventory_not_enough_tips').'['.$goods['title'].'('.$base['data']['spec_base']['inventory'].'<'.$detail['buy_number'].')]', -10);
|
||
}
|
||
} else {
|
||
return $base;
|
||
}
|
||
}
|
||
return DataReturn(MyLang('check_success'), 0);
|
||
}
|
||
|
||
/**
|
||
* 库存扣除
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-11-09
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function OrderInventoryDeduct($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'order_id',
|
||
'error_msg' => MyLang('order_id_error_tips'),
|
||
],
|
||
[
|
||
'checked_type' => 'in',
|
||
'key_name' => 'opt_type',
|
||
'checked_data' => ['confirm', 'pay', 'delivery'],
|
||
'error_msg' => MyLang('common_service.buy.order_inventory_dec_type_error_tips'),
|
||
],
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 是否扣除库存
|
||
$common_is_deduction_inventory = MyC('common_is_deduction_inventory', 0);
|
||
if($common_is_deduction_inventory != 1)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_not_enable_tips'), 0);
|
||
}
|
||
|
||
// 扣除库存规则
|
||
$common_deduction_inventory_rules = MyC('common_deduction_inventory_rules', 1);
|
||
switch($common_deduction_inventory_rules)
|
||
{
|
||
// 订单确认成功
|
||
case 0 :
|
||
if($params['opt_type'] != 'confirm')
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_not_confirm_tips').'['.$params['order_id'].']', 0);
|
||
}
|
||
break;
|
||
|
||
// 订单支付成功
|
||
case 1 :
|
||
if($params['opt_type'] != 'pay')
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_not_pay_tips').'['.$params['order_id'].']', 0);
|
||
}
|
||
break;
|
||
|
||
// 订单发货
|
||
case 2 :
|
||
if($params['opt_type'] != 'delivery')
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_not_delivery_tips').'['.$params['order_id'].']', 0);
|
||
}
|
||
break;
|
||
}
|
||
|
||
// 获取订单商品
|
||
$order_detail = Db::name('OrderDetail')->field('id,goods_id,buy_number,inventory_unit,spec')->where(['order_id'=>$params['order_id']])->select()->toArray();
|
||
if(!empty($order_detail))
|
||
{
|
||
$goods_unit = Db::name('Goods')->where(['id'=>array_column($order_detail, 'goods_id')])->column('inventory_unit', 'id');
|
||
foreach($order_detail as $v)
|
||
{
|
||
// 查看是否已扣除过库存,避免更改模式导致重复扣除
|
||
$temp = Db::name('OrderGoodsInventoryLog')->where(['order_id'=>$params['order_id'], 'order_detail_id'=>$v['id'], 'goods_id'=>$v['goods_id']])->find();
|
||
if(empty($temp))
|
||
{
|
||
$goods = GoodsService::GoodsData($v['goods_id'], 'is_deduction_inventory,inventory,title');
|
||
if(!empty($goods) && isset($goods['is_deduction_inventory']) && $goods['is_deduction_inventory'] == 1)
|
||
{
|
||
// 先判断商品库存是否不足
|
||
if($goods['inventory'] < $v['buy_number'])
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_inventory_not_enough_tips').'['.$goods['title'].'('.$goods['inventory'].'<'.$v['buy_number'].')]', -10);
|
||
}
|
||
|
||
// 扣除操作
|
||
$where = [
|
||
['id', '=', $v['goods_id']],
|
||
['inventory', '>=', $v['buy_number']],
|
||
];
|
||
if(Db::name('Goods')->where($where)->dec('inventory', $v['buy_number'])->update() === false)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_inventory_dec_fail_tips').'['.$params['order_id'].'-'.$v['id'].'-'.$v['goods_id'].'('.$goods['inventory'].'-'.$v['buy_number'].')]', -10);
|
||
}
|
||
|
||
// 扣除规格库存
|
||
$spec = empty($v['spec']) ? '' : json_decode($v['spec'], true);
|
||
$spec_params = array_merge($params, [
|
||
'id' => $v['goods_id'],
|
||
'spec' => $spec,
|
||
]);
|
||
$base = GoodsService::GoodsSpecDetail($spec_params);
|
||
if($base['code'] == 0)
|
||
{
|
||
// 先判断商品规格库存是否不足
|
||
if($base['data']['spec_base']['inventory'] < $v['buy_number'])
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_spec_inventory_not_enough_tips').'['.$goods['title'].'('.$base['data']['spec_base']['inventory'].'<'.$v['buy_number'].']', -10);
|
||
}
|
||
|
||
// 扣除规格操作
|
||
$where = [
|
||
['id', '=', $base['data']['spec_base']['id']],
|
||
['goods_id', '=', $v['goods_id']],
|
||
['inventory', '>=', $v['buy_number']],
|
||
];
|
||
if(Db::name('GoodsSpecBase')->where($where)->dec('inventory', $v['buy_number'])->update() === false)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.goods_spec_inventory_dec_fail_tips').'['.$params['order_id'].'-'.$v['goods_id'].'('.$goods['inventory'].'-'.$v['buy_number'].')]', -10);
|
||
}
|
||
} else {
|
||
return $base;
|
||
}
|
||
|
||
// 仓库库存扣除
|
||
$inventory_unit = empty($v['inventory_unit']) ? (isset($goods_unit[$v['goods_id']]) ? $goods_unit[$v['goods_id']] : '') : $v['inventory_unit'];
|
||
$we_ret = WarehouseGoodsService::WarehouseGoodsInventoryDeduct($params['order_id'], $v['goods_id'], $spec, $v['buy_number'], $inventory_unit);
|
||
if($we_ret['code'] != 0)
|
||
{
|
||
return $we_ret;
|
||
}
|
||
|
||
// 扣除日志添加
|
||
$log_data = [
|
||
'order_id' => $params['order_id'],
|
||
'order_detail_id' => $v['id'],
|
||
'goods_id' => $v['goods_id'],
|
||
'order_status' => Db::name('Order')->where(['id'=>$params['order_id']])->value('status'),
|
||
'original_inventory' => $goods['inventory'],
|
||
'new_inventory' => Db::name('Goods')->where(['id'=>$v['goods_id']])->value('inventory'),
|
||
'add_time' => time(),
|
||
];
|
||
if(Db::name('OrderGoodsInventoryLog')->insertGetId($log_data) <= 0)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_log_insert_fail_tips').'['.$params['order_id'].'-'.$v['goods_id'].']', -100);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return DataReturn(MyLang('operate_success'), 0);
|
||
}
|
||
return DataReturn(MyLang('common_service.buy.inventory_dec_no_data_tips'), 0);
|
||
}
|
||
|
||
/**
|
||
* 库存回滚
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2018-11-09
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function OrderInventoryRollback($params = [])
|
||
{
|
||
// 请求参数
|
||
$p = [
|
||
[
|
||
'checked_type' => 'empty',
|
||
'key_name' => 'order_id',
|
||
'error_msg' => MyLang('order_id_error_tips'),
|
||
],
|
||
[
|
||
'checked_type' => 'is_array',
|
||
'key_name' => 'order_data',
|
||
'error_msg' => MyLang('common_service.buy.order_data_error_tips'),
|
||
]
|
||
];
|
||
$ret = ParamsChecked($params, $p);
|
||
if($ret !== true)
|
||
{
|
||
return DataReturn($ret, -1);
|
||
}
|
||
|
||
// 订单状态
|
||
if(isset($params['order_data']['status']))
|
||
{
|
||
// 仅订单取消、关闭操作库存回滚
|
||
if(!in_array($params['order_data']['status'], [5,6]))
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_revert_not_allow_tips').'['.$params['order_id'].'-'.$params['order_data']['status'].']', 0);
|
||
}
|
||
}
|
||
|
||
// 是否指定商品和数量
|
||
$appoint_buy_number = empty($params['appoint_buy_number']) ? 0 : intval($params['appoint_buy_number']);
|
||
$detail_where = ['order_id' => $params['order_id']];
|
||
if(!empty($params['appoint_order_detail_id']))
|
||
{
|
||
$detail_where['id'] = intval($params['appoint_order_detail_id']);
|
||
}
|
||
|
||
// 获取订单商品
|
||
$order_detail = Db::name('OrderDetail')->field('goods_id,buy_number,inventory_unit,spec')->where($detail_where)->select()->toArray();
|
||
if(!empty($order_detail))
|
||
{
|
||
$goods_unit = Db::name('Goods')->where(['id'=>array_column($order_detail, 'goods_id')])->column('inventory_unit', 'id');
|
||
foreach($order_detail as $v)
|
||
{
|
||
// 查看是否已扣除过库存
|
||
$temp = Db::name('OrderGoodsInventoryLog')->where(['order_id'=>$params['order_id'], 'goods_id'=>$v['goods_id']])->find();
|
||
if(!empty($temp))
|
||
{
|
||
// 规格
|
||
$spec = empty($v['spec']) ? '' : json_decode($v['spec'], true);
|
||
|
||
// 数量
|
||
$buy_number = ($appoint_buy_number == 0) ? $v['buy_number'] : $appoint_buy_number;
|
||
|
||
// 商品回滚操作
|
||
$temp_goods = GoodsService::GoodsData($v['goods_id'], 'id');
|
||
if(!empty($temp_goods))
|
||
{
|
||
// 商品库存增加
|
||
if(!Db::name('Goods')->where(['id'=>$v['goods_id']])->inc('inventory', $buy_number)->update())
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_revert_goods_fail_tips').'['.$params['order_id'].'-'.$v['goods_id'].']', -10);
|
||
}
|
||
|
||
// 回滚规格库存
|
||
$spec_params = array_merge($params, [
|
||
'id' => $v['goods_id'],
|
||
'spec' => $spec,
|
||
]);
|
||
$base = GoodsService::GoodsSpecDetail($spec_params);
|
||
if($base['code'] == 0)
|
||
{
|
||
// 回滚规格操作
|
||
if(!Db::name('GoodsSpecBase')->where(['id'=>$base['data']['spec_base']['id'], 'goods_id'=>$v['goods_id']])->inc('inventory', $buy_number)->update())
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_revert_goods_spec_fail_tips').'['.$params['order_id'].'-'.$v['goods_id'].']', -10);
|
||
}
|
||
}
|
||
}
|
||
|
||
// 仓库库存回滚
|
||
$inventory_unit = empty($v['inventory_unit']) ? (isset($goods_unit[$v['goods_id']]) ? $goods_unit[$v['goods_id']] : '') : $v['inventory_unit'];
|
||
$we_ret = WarehouseGoodsService::WarehouseGoodsInventoryRollback($params['order_id'], $v['goods_id'], $spec, $buy_number, $inventory_unit);
|
||
if($we_ret['code'] != 0)
|
||
{
|
||
return $we_ret;
|
||
}
|
||
|
||
// 回滚日志更新
|
||
$log_data = [
|
||
'is_rollback' => 1,
|
||
'rollback_time' => time(),
|
||
];
|
||
if(Db::name('OrderGoodsInventoryLog')->where(['id'=>$temp['id']])->update($log_data) === false)
|
||
{
|
||
return DataReturn(MyLang('common_service.buy.inventory_revert_log_fail_tips').'['.$temp['id'].'-'.$params['order_id'].']', -100);
|
||
}
|
||
}
|
||
}
|
||
return DataReturn(MyLang('operate_success'), 0);
|
||
}
|
||
return DataReturn(MyLang('common_service.buy.inventory_revert_no_data_tips'), 0);
|
||
}
|
||
|
||
/**
|
||
* 自提点地址选中地址获取
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2019-11-18
|
||
* @desc description
|
||
* @param [int] $params['address_id'] [自提点地址索引值]
|
||
*/
|
||
public static function SiteExtractionAddress($params = [])
|
||
{
|
||
// 自提地址列表
|
||
$address = ConfigService::SiteTypeExtractionAddressList();
|
||
|
||
// 选中地址处理
|
||
$default = null;
|
||
if(isset($params['address_id']) && $params['address_id'] !== null && !empty($address['data']) && is_array($address['data']))
|
||
{
|
||
if(isset($address['data'][$params['address_id']]))
|
||
{
|
||
$default = $address['data'][$params['address_id']];
|
||
}
|
||
}
|
||
|
||
// 默认地址
|
||
if(empty($default) && !empty($address['data']))
|
||
{
|
||
foreach($address['data'] as $v)
|
||
{
|
||
if(isset($v['is_default']) && $v['is_default'] == 1)
|
||
{
|
||
$default = $v;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
// 返回数据
|
||
$result = [
|
||
'data_list' => $address['data'],
|
||
'default' => $default,
|
||
];
|
||
|
||
// 自提点地址数据钩子
|
||
$hook_name = 'plugins_service_site_extraction_address_handle';
|
||
$ret = MyEventTrigger($hook_name, [
|
||
'hook_name' => $hook_name,
|
||
'is_backend' => true,
|
||
'params' => $params,
|
||
'data' => &$result,
|
||
]);
|
||
|
||
return DataReturn(MyLang('operate_success'), 0, $result);
|
||
}
|
||
|
||
/**
|
||
* 购买订单初始化
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2022-07-31
|
||
* @desc description
|
||
* @param [array] $params [输入参数]
|
||
*/
|
||
public static function BuyOrderInit($params = [])
|
||
{
|
||
// 商品数据
|
||
$ret = self::BuyTypeGoodsList($params);
|
||
if(isset($ret['code']) && $ret['code'] == 0 && !empty($ret['data']))
|
||
{
|
||
// 是否开启虚拟订单快速创建订单
|
||
// 购物车页面初始化则不处理订单创建
|
||
if((!isset($params['is_cart_init']) || $params['is_cart_init'] != 1) && $ret['data']['base']['site_model'] == 3 && MyC('common_fictitious_order_direct_pay') == 1)
|
||
{
|
||
// 指定订单类型
|
||
$params['site_model'] = $ret['data']['base']['site_model'];
|
||
// 调用订单添加
|
||
$ret = self::OrderInsert($params);
|
||
if($ret['code'] == 0)
|
||
{
|
||
// 标记订单已提交
|
||
$ret['data']['is_order_submit'] = 1;
|
||
}
|
||
}
|
||
}
|
||
return $ret;
|
||
}
|
||
|
||
/**
|
||
* 购买数据存储
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2025-01-23
|
||
* @desc description
|
||
* @param [int] $user_id [用户id]
|
||
* @param [array] $buy_data [购买数据]
|
||
*/
|
||
public static function BuyDataStorage($user_id, $buy_data)
|
||
{
|
||
if(!empty($buy_data))
|
||
{
|
||
MyCache('buy_post_data_'.$user_id, $buy_data, 21600);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 购买数据读取
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2025-01-23
|
||
* @desc description
|
||
* @param [int] $user_id [用户id]
|
||
*/
|
||
public static function BuyDataRead($user_id)
|
||
{
|
||
return MyCache('buy_post_data_'.$user_id);
|
||
}
|
||
|
||
/**
|
||
* 购买数据删除
|
||
* @author Devil
|
||
* @blog http://gong.gg/
|
||
* @version 1.0.0
|
||
* @date 2025-01-23
|
||
* @desc description
|
||
* @param [int] $user_id [用户id]
|
||
*/
|
||
public static function BuyDataDelete($user_id)
|
||
{
|
||
return MyCache('buy_post_data_'.$user_id, null);
|
||
}
|
||
}
|
||
?>
|