2018-12-28 18:58:37 +08:00
|
|
|
|
<?php
|
|
|
|
|
// +----------------------------------------------------------------------
|
|
|
|
|
// | ShopXO 国内领先企业级B2C免费开源电商系统
|
|
|
|
|
// +----------------------------------------------------------------------
|
2019-02-18 13:52:07 +08:00
|
|
|
|
// | Copyright (c) 2011~2019 http://shopxo.net All rights reserved.
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// +----------------------------------------------------------------------
|
|
|
|
|
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
|
|
|
|
|
// +----------------------------------------------------------------------
|
|
|
|
|
// | Author: Devil
|
|
|
|
|
// +----------------------------------------------------------------------
|
|
|
|
|
namespace app\service;
|
|
|
|
|
|
|
|
|
|
use think\Db;
|
2019-03-12 18:06:57 +08:00
|
|
|
|
use think\facade\Hook;
|
2019-01-17 00:37:20 +08:00
|
|
|
|
use app\service\PaymentService;
|
|
|
|
|
use app\service\BuyService;
|
|
|
|
|
use app\service\IntegralService;
|
|
|
|
|
use app\service\RegionService;
|
|
|
|
|
use app\service\ExpressService;
|
|
|
|
|
use app\service\ResourcesService;
|
2019-05-07 17:39:55 +08:00
|
|
|
|
use app\service\PayLogService;
|
2020-06-27 22:48:16 +08:00
|
|
|
|
use app\service\UserService;
|
2020-07-24 15:11:13 +08:00
|
|
|
|
use app\service\OrderAftersaleService;
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单服务层
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 0.0.1
|
|
|
|
|
* @datetime 2016-12-01T21:51:08+0800
|
|
|
|
|
*/
|
|
|
|
|
class OrderService
|
|
|
|
|
{
|
|
|
|
|
/**
|
|
|
|
|
* 订单支付
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-26
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function Pay($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'key_name' => 'ids',
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user',
|
|
|
|
|
'error_msg' => '用户信息有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 支付订单id
|
|
|
|
|
$ids = is_array($params['ids']) ? $params['ids'] : explode(',', urldecode($params['ids']));
|
|
|
|
|
if(empty($ids))
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
return DataReturn('订单支付id有误', -1);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 支付基础信息
|
|
|
|
|
$order_payment_id = 0;
|
|
|
|
|
$client_type = '';
|
|
|
|
|
$total_price = 0;
|
|
|
|
|
$success_count = 0;
|
|
|
|
|
$order_ids = [];
|
|
|
|
|
$order_nos = [];
|
|
|
|
|
|
|
|
|
|
// 循环处理
|
|
|
|
|
foreach($ids as $k=>$order_id)
|
2019-12-31 16:25:23 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['id'=>intval($order_id), 'user_id' => $params['user']['id']];
|
|
|
|
|
$order = Db::name('Order')->where($where)->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if($order['status'] != 1)
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_user_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']'.$order['order_no'], -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 订单支付前校验
|
|
|
|
|
$ret = BuyService::OrderPayBeginCheck(['order_id'=>$order['id'], 'order_data'=>$order]);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 金额为0、走直接支付成功
|
|
|
|
|
if($order['total_price'] <= 0.00)
|
|
|
|
|
{
|
|
|
|
|
$params['user']['user_name_view'] = '用户-'.$params['user']['user_name_view'];
|
|
|
|
|
$pay_result = self::OrderDirectSuccess([
|
|
|
|
|
'order' => $order,
|
|
|
|
|
'payment' => $payment[0],
|
|
|
|
|
'user' => $params['user'],
|
|
|
|
|
'params' => $params,
|
|
|
|
|
]);
|
|
|
|
|
if($pay_result['code'] == 0)
|
|
|
|
|
{
|
|
|
|
|
$success_count++;
|
|
|
|
|
}
|
|
|
|
|
return $pay_result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 订单id/号集合
|
|
|
|
|
$order_ids[] = $order['id'];
|
|
|
|
|
$order_nos[] = $order['order_no'];
|
|
|
|
|
$total_price += $order['total_price'];
|
|
|
|
|
|
|
|
|
|
// 仅第一个订单获取的数据
|
|
|
|
|
if($k == 0)
|
|
|
|
|
{
|
|
|
|
|
$client_type = $order['client_type'];
|
|
|
|
|
$order_payment_id = $order['payment_id'];
|
|
|
|
|
}
|
2019-12-31 16:25:23 +08:00
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 支付方式
|
2020-07-28 21:15:47 +08:00
|
|
|
|
$payment_id = empty($params['payment_id']) ? $order_payment_id : intval($params['payment_id']);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
$payment = PaymentService::PaymentList(['where'=>['id'=>$payment_id]]);
|
|
|
|
|
if(empty($payment[0]))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付方式有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
// 更新订单支付方式信息
|
2020-07-28 21:15:47 +08:00
|
|
|
|
if($payment_id != $order_payment_id)
|
2019-05-25 20:21:08 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
Db::name('Order')->where(['id'=>$ids])->update([
|
2020-04-07 17:29:57 +08:00
|
|
|
|
'payment_id' => $payment_id,
|
|
|
|
|
'is_under_line' => in_array($payment[0]['payment'], config('shopxo.under_line_list')) ? 1 : 0,
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
]);
|
2019-05-25 20:21:08 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 是否直接跳转
|
|
|
|
|
if($success_count > 0 && $success_count == count($ids))
|
2019-05-29 11:33:36 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
return DataReturn('支付成功', 0, ['data'=>MyUrl('index/order/respond', ['appoint_status'=>0])]);
|
2019-05-29 11:33:36 +08:00
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 支付入口文件检查
|
|
|
|
|
$pay_checked = PaymentService::EntranceFileChecked($payment[0]['payment'], 'order');
|
|
|
|
|
if($pay_checked['code'] != 0)
|
|
|
|
|
{
|
2019-04-29 18:34:50 +08:00
|
|
|
|
// 入口文件不存在则创建
|
|
|
|
|
$payment_params = [
|
|
|
|
|
'payment' => $payment[0]['payment'],
|
2019-05-14 16:17:19 +08:00
|
|
|
|
'respond' => '/index/order/respond',
|
|
|
|
|
'notify' => '/api/ordernotify/notify',
|
2019-04-29 18:34:50 +08:00
|
|
|
|
];
|
|
|
|
|
$ret = PaymentService::PaymentEntranceCreated($payment_params);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 回调地址
|
2019-01-08 21:34:25 +08:00
|
|
|
|
$url = __MY_URL__.'payment_order_'.strtolower($payment[0]['payment']);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
2019-01-03 16:43:46 +08:00
|
|
|
|
// url模式, pathinfo模式下采用自带url生成url, 避免非index.php多余
|
|
|
|
|
if(MyC('home_seo_url_model', 0) == 0)
|
|
|
|
|
{
|
|
|
|
|
$call_back_url = $url.'_respond.php';
|
|
|
|
|
} else {
|
|
|
|
|
$call_back_url = MyUrl('index/order/respond', ['paymentname'=>$payment[0]['payment']]);
|
2019-01-08 18:47:38 +08:00
|
|
|
|
if(stripos($call_back_url, '?') !== false)
|
|
|
|
|
{
|
|
|
|
|
$call_back_url = $url.'_respond.php';
|
|
|
|
|
}
|
2019-01-03 16:43:46 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 新增支付日志
|
|
|
|
|
$pay_log = self::OrderPayLogInsert([
|
|
|
|
|
'user_id' => $params['user']['id'],
|
|
|
|
|
'business_ids' => $order_ids,
|
|
|
|
|
'business_nos' => $order_nos,
|
|
|
|
|
'total_price' => $total_price,
|
|
|
|
|
'payment' => $payment[0]['payment'],
|
|
|
|
|
'payment_name' => $payment[0]['name'],
|
|
|
|
|
]);
|
|
|
|
|
if($pay_log['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $pay_log;
|
|
|
|
|
}
|
|
|
|
|
|
2020-01-02 00:25:03 +08:00
|
|
|
|
// 发起支付数据
|
2018-12-28 18:58:37 +08:00
|
|
|
|
$pay_data = array(
|
2019-01-08 14:14:53 +08:00
|
|
|
|
'user' => $params['user'],
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'out_user' => md5($params['user']['id']),
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'order_id' => $pay_log['data']['id'],
|
|
|
|
|
'order_no' => $pay_log['data']['log_no'],
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'name' => '订单支付',
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'total_price' => $total_price,
|
|
|
|
|
'client_type' => $client_type,
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'notify_url' => $url.'_notify.php',
|
2019-01-03 16:43:46 +08:00
|
|
|
|
'call_back_url' => $call_back_url,
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'redirect_url' => MyUrl('index/order/index'),
|
2019-03-29 10:56:14 +08:00
|
|
|
|
'site_name' => MyC('home_site_name', 'ShopXO', true),
|
2019-04-29 18:34:50 +08:00
|
|
|
|
'ajax_url' => MyUrl('index/order/paycheck'),
|
2018-12-28 18:58:37 +08:00
|
|
|
|
);
|
2019-12-17 14:18:14 +08:00
|
|
|
|
|
|
|
|
|
// 发起支付处理钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_pay_launch_handle';
|
|
|
|
|
$ret = HookReturnHandle(Hook::listen($hook_name, [
|
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'order_ids' => $order_ids,
|
2019-12-17 14:18:14 +08:00
|
|
|
|
'params' => &$params,
|
|
|
|
|
'pay_data' => &$pay_data,
|
|
|
|
|
]));
|
|
|
|
|
if(isset($ret['code']) && $ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
|
|
|
|
|
2020-01-02 00:25:03 +08:00
|
|
|
|
// 微信中打开并且webopenid为空
|
|
|
|
|
if(in_array(APPLICATION_CLIENT_TYPE, ['pc', 'h5']))
|
|
|
|
|
{
|
|
|
|
|
if(!empty($_SERVER['HTTP_USER_AGENT']) && stripos($_SERVER['HTTP_USER_AGENT'], 'MicroMessenger') !== false && empty($pay_data['user']['weixin_web_openid']))
|
|
|
|
|
{
|
|
|
|
|
// 授权成功后回调订单详情页面重新自动发起支付
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 单个订单进入详情,则进入列表
|
|
|
|
|
$weixin_params = [
|
|
|
|
|
'is_pay_auto' => 1,
|
|
|
|
|
'is_pay_submit' => 1,
|
|
|
|
|
'payment_id' => $payment_id,
|
|
|
|
|
];
|
|
|
|
|
if(count($order_ids) == 1)
|
|
|
|
|
{
|
|
|
|
|
$weixin_params['id'] = $order_ids[0];
|
|
|
|
|
$weixin_params['ids'] = $order_ids[0];
|
|
|
|
|
$url = MyUrl('index/order/detail', $weixin_params);
|
|
|
|
|
} else {
|
|
|
|
|
$weixin_params['ids'] = urldecode(implode(',', $order_ids));
|
|
|
|
|
$url = MyUrl('index/order/index', $weixin_params);
|
|
|
|
|
}
|
2020-01-02 00:25:03 +08:00
|
|
|
|
session('plugins_weixinwebauth_pay_callback_view_url', $url);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2019-12-17 14:18:14 +08:00
|
|
|
|
// 发起支付
|
2018-12-28 18:58:37 +08:00
|
|
|
|
$pay_name = 'payment\\'.$payment[0]['payment'];
|
|
|
|
|
$ret = (new $pay_name($payment[0]['config']))->Pay($pay_data);
|
|
|
|
|
if(isset($ret['code']) && $ret['code'] == 0)
|
|
|
|
|
{
|
|
|
|
|
// 支付信息返回
|
|
|
|
|
$ret['data'] = [
|
2020-04-07 17:29:57 +08:00
|
|
|
|
// 支付类型(0正常线上支付、1线下支付、2钱包支付)
|
|
|
|
|
'is_payment_type' => 0,
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 支付模块处理数据
|
2020-04-07 17:29:57 +08:00
|
|
|
|
'data' => $ret['data'],
|
2018-12-28 18:58:37 +08:00
|
|
|
|
];
|
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
// 是否线下支付
|
|
|
|
|
if(in_array($payment[0]['payment'], config('shopxo.under_line_list')))
|
|
|
|
|
{
|
|
|
|
|
$ret['data']['is_payment_type'] = 1;
|
|
|
|
|
} else {
|
|
|
|
|
// 是否钱包支付
|
|
|
|
|
if($payment[0]['payment'] == 'WalletPay')
|
|
|
|
|
{
|
|
|
|
|
$ret['data']['is_payment_type'] = 2;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
return $ret;
|
|
|
|
|
}
|
2019-01-07 14:26:12 +08:00
|
|
|
|
return DataReturn(empty($ret['msg']) ? '支付接口异常' : $ret['msg'], -1);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
/**
|
|
|
|
|
* 新增订单支付日志
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-07-28
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
|
|
|
|
public static function OrderPayLogInsert($params = [])
|
|
|
|
|
{
|
|
|
|
|
$business_ids = isset($params['business_ids']) ? $params['business_ids'] : [];
|
|
|
|
|
$business_nos = isset($params['business_nos']) ? $params['business_nos'] : [];
|
|
|
|
|
return PayLogService::PayLogInsert([
|
|
|
|
|
'user_id' => isset($params['user_id']) ? intval($params['user_id']) : 0,
|
|
|
|
|
'business_ids' => is_array($business_ids) ? $business_ids : [$business_ids],
|
|
|
|
|
'business_nos' => is_array($business_nos) ? $business_nos : [$business_nos],
|
|
|
|
|
'total_price' => isset($params['total_price']) ? PriceNumberFormat($params['total_price']) : 0.00,
|
|
|
|
|
'subject' => '订单支付',
|
|
|
|
|
'payment' => isset($params['payment']) ? $params['payment'] : '',
|
|
|
|
|
'payment_name' => isset($params['payment_name']) ? $params['payment_name'] : '',
|
|
|
|
|
'business_type' => '订单',
|
|
|
|
|
]);
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
/**
|
|
|
|
|
* 管理员订单支付
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-26
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function AdminPay($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user',
|
|
|
|
|
'error_msg' => '管理员信息有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['id'=>intval($params['id'])];
|
|
|
|
|
$order = Db::name('Order')->where($where)->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if($order['status'] != 1)
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_admin_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', -1);
|
|
|
|
|
}
|
|
|
|
|
|
2020-01-07 15:32:47 +08:00
|
|
|
|
// 订单支付前校验
|
|
|
|
|
$ret = BuyService::OrderPayBeginCheck(['order_id'=>$order['id'], 'order_data'=>$order]);
|
2019-12-31 16:25:23 +08:00
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 支付方式
|
|
|
|
|
$payment_id = empty($params['payment_id']) ? $order['payment_id'] : intval($params['payment_id']);
|
|
|
|
|
$payment = PaymentService::PaymentList(['where'=>['id'=>$payment_id]]);
|
|
|
|
|
if(empty($payment[0]))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付方式有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
// 线下支付处理
|
|
|
|
|
return self::OrderPaymentUnderLineSuccess([
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'order' => $order,
|
|
|
|
|
'payment' => $payment[0],
|
|
|
|
|
'user' => $params['user'],
|
2020-04-07 17:29:57 +08:00
|
|
|
|
'params' => $params,
|
2018-12-28 18:58:37 +08:00
|
|
|
|
]);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
2020-04-07 17:29:57 +08:00
|
|
|
|
* 订单金额为小于等于0直接成功
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-04-07
|
|
|
|
|
* @desc description
|
2018-12-28 18:58:37 +08:00
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2020-04-07 17:29:57 +08:00
|
|
|
|
private static function OrderDirectSuccess($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
if(!empty($params['order']) && !empty($params['payment']) && !empty($params['user']))
|
|
|
|
|
{
|
2020-04-07 17:29:57 +08:00
|
|
|
|
if($params['order']['total_price'] <= 0.00)
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 新增支付日志
|
|
|
|
|
$pay_log = self::OrderPayLogInsert([
|
|
|
|
|
'user_id' => $params['user']['id'],
|
|
|
|
|
'business_ids' => $params['order']['id'],
|
|
|
|
|
'business_nos' => $params['order']['order_no'],
|
|
|
|
|
'total_price' => $params['order']['total_price'],
|
|
|
|
|
'payment' => $params['payment']['payment'],
|
|
|
|
|
'payment_name' => $params['payment']['name'],
|
|
|
|
|
]);
|
|
|
|
|
if($pay_log['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $pay_log;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 新增日志订单
|
|
|
|
|
$pay_log_data = [];
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 支付处理
|
|
|
|
|
$pay_params = [
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'order' => [$params['order']],
|
|
|
|
|
'payment' => $params['payment'],
|
|
|
|
|
'pay_log_data' => $pay_log['data'],
|
|
|
|
|
'pay' => [
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'trade_no' => '',
|
|
|
|
|
'subject' => isset($params['params']['subject']) ? $params['params']['subject'] : '订单支付',
|
|
|
|
|
'buyer_user' => $params['user']['user_name_view'],
|
|
|
|
|
'pay_price' => $params['order']['total_price'],
|
|
|
|
|
],
|
|
|
|
|
];
|
2019-01-17 00:37:20 +08:00
|
|
|
|
return self::OrderPayHandle($pay_params);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
2020-04-07 17:29:57 +08:00
|
|
|
|
return DataReturn('订单金额有误、请正常发起支付', -1);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
2020-04-07 17:29:57 +08:00
|
|
|
|
return DataReturn('支付传参有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 线下支付方式、直接支付成功
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-04-07
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
|
|
|
|
private static function OrderPaymentUnderLineSuccess($params = [])
|
|
|
|
|
{
|
|
|
|
|
if(!empty($params['order']) && !empty($params['payment']) && !empty($params['user']))
|
|
|
|
|
{
|
|
|
|
|
if(in_array($params['payment']['payment'], config('shopxo.under_line_list')))
|
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 新增支付日志
|
|
|
|
|
$pay_log = self::OrderPayLogInsert([
|
|
|
|
|
'user_id' => $params['user']['id'],
|
|
|
|
|
'business_ids' => $params['order']['id'],
|
|
|
|
|
'business_nos' => $params['order']['order_no'],
|
|
|
|
|
'total_price' => $params['order']['total_price'],
|
|
|
|
|
'payment' => $params['payment']['payment'],
|
|
|
|
|
'payment_name' => $params['payment']['name'],
|
|
|
|
|
]);
|
|
|
|
|
if($pay_log['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $pay_log;
|
|
|
|
|
}
|
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
// 支付处理
|
|
|
|
|
$pay_params = [
|
2020-07-28 21:43:57 +08:00
|
|
|
|
'order' => [$params['order']],
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'payment' => $params['payment'],
|
|
|
|
|
'pay_log_data' => $pay_log['data'],
|
|
|
|
|
'pay' => [
|
2020-04-07 17:29:57 +08:00
|
|
|
|
'trade_no' => '',
|
|
|
|
|
'subject' => isset($params['params']['subject']) ? $params['params']['subject'] : '订单支付',
|
|
|
|
|
'buyer_user' => $params['user']['user_name_view'],
|
|
|
|
|
'pay_price' => $params['order']['total_price'],
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
return self::OrderPayHandle($pay_params);
|
|
|
|
|
}
|
|
|
|
|
return DataReturn('仅线下支付方式处理', -1);
|
|
|
|
|
}
|
|
|
|
|
return DataReturn('支付传参有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
/**
|
|
|
|
|
* 支付同步处理
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-28
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function Respond($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user',
|
|
|
|
|
'error_msg' => '用户信息有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 支付方式
|
2019-01-03 16:43:46 +08:00
|
|
|
|
$payment_name = defined('PAYMENT_TYPE') ? PAYMENT_TYPE : (isset($params['paymentname']) ? $params['paymentname'] : '');
|
|
|
|
|
if(empty($payment_name))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付方式标记异常', -1);
|
|
|
|
|
}
|
|
|
|
|
$payment = PaymentService::PaymentList(['where'=>['payment'=>$payment_name]]);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(empty($payment[0]))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付方式有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 支付数据校验
|
2019-01-03 16:43:46 +08:00
|
|
|
|
$pay_name = 'payment\\'.$payment_name;
|
2019-07-15 02:09:08 +08:00
|
|
|
|
$ret = (new $pay_name($payment[0]['config']))->Respond(array_merge(input('get.'), input('post.')));
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(isset($ret['code']) && $ret['code'] == 0)
|
|
|
|
|
{
|
|
|
|
|
if(empty($ret['data']['out_trade_no']))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('单号有误', -1);
|
|
|
|
|
}
|
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['order_no'=>$ret['data']['out_trade_no'], 'is_delete_time'=>0, 'user_is_delete_time'=>0];
|
|
|
|
|
$order = Db::name('Order')->where($where)->find();
|
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
// 线下支付方式处理
|
2020-04-23 15:38:24 +08:00
|
|
|
|
if(in_array($payment_name, config('shopxo.under_line_list')))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('提交成功、待管理员确认', 0);
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 支付异步处理
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-28
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function Notify($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 支付方式
|
|
|
|
|
$payment = PaymentService::PaymentList(['where'=>['payment'=>PAYMENT_TYPE]]);
|
|
|
|
|
if(empty($payment[0]))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付方式有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 支付数据校验
|
|
|
|
|
$pay_name = 'payment\\'.PAYMENT_TYPE;
|
2020-07-28 21:15:47 +08:00
|
|
|
|
$pay_ret = (new $pay_name($payment[0]['config']))->Respond(array_merge(input('get.'), input('post.')));
|
|
|
|
|
if(!isset($pay_ret['code']) || $pay_ret['code'] != 0)
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
return $pay_ret;
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 获取支付日志订单
|
|
|
|
|
$pay_log_data = Db::name('PayLog')->where([
|
|
|
|
|
'log_no' => $pay_ret['data']['out_trade_no'],
|
|
|
|
|
'status' => 0,
|
|
|
|
|
])->find();
|
|
|
|
|
if(empty($pay_log_data))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('日志订单有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取关联信息
|
|
|
|
|
$pay_log_value = Db::name('PayLogValue')->where(['pay_log_id'=>$pay_log_data['id']])->column('business_id');
|
|
|
|
|
if(empty($pay_log_value))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('日志订单关联信息有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单
|
|
|
|
|
$order_list = Db::name('Order')->where(['id'=>$pay_log_value, 'status'=>1])->select();
|
|
|
|
|
if(empty($order_list))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('订单信息有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 订单数量是否一致
|
|
|
|
|
if(count($order_list) != count($pay_log_value))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('订单与日志记录数量不一致', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 支付金额是否小于订单金额
|
|
|
|
|
if($pay_ret['data']['pay_price'] < $pay_log_data['total_price'])
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付金额小于日志订单金额', -1);
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 支付处理
|
|
|
|
|
$pay_params = [
|
2020-07-28 21:43:57 +08:00
|
|
|
|
'order' => $order_list,
|
2020-07-28 21:15:47 +08:00
|
|
|
|
'payment' => $payment[0],
|
|
|
|
|
'pay_log_data' => $pay_log_data,
|
|
|
|
|
'pay' => [
|
|
|
|
|
'trade_no' => $pay_ret['data']['trade_no'],
|
|
|
|
|
'subject' => $pay_ret['data']['subject'],
|
|
|
|
|
'buyer_user' => $pay_ret['data']['buyer_user'],
|
|
|
|
|
'pay_price' => $pay_ret['data']['pay_price'],
|
2018-12-28 18:58:37 +08:00
|
|
|
|
],
|
|
|
|
|
];
|
2019-12-17 14:18:14 +08:00
|
|
|
|
|
|
|
|
|
// 支付成功异步通知处理钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_pay_notify_handle';
|
2020-07-28 21:15:47 +08:00
|
|
|
|
$pay_ret = HookReturnHandle(Hook::listen($hook_name, [
|
2019-12-17 14:18:14 +08:00
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
|
|
|
|
'payment' => $payment[0],
|
|
|
|
|
'order' => $order,
|
|
|
|
|
'pay_params' => &$pay_params,
|
|
|
|
|
]));
|
|
|
|
|
if(isset($ret['code']) && $ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 支付结果处理
|
2019-01-17 00:37:20 +08:00
|
|
|
|
return self::OrderPayHandle($pay_params);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
2020-07-28 21:15:47 +08:00
|
|
|
|
* 订单支付处理
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-07-28
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
2018-12-28 18:58:37 +08:00
|
|
|
|
*/
|
2019-06-16 18:02:45 +08:00
|
|
|
|
public static function OrderPayHandle($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 订单信息
|
2020-07-28 21:15:47 +08:00
|
|
|
|
if(empty($params['order']) || !is_array($params['order']))
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
return DataReturn('订单数据不存在或类型有误', -1);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 支付方式
|
|
|
|
|
if(empty($params['payment']))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付方式有误', -1);
|
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 日志订单
|
|
|
|
|
if(empty($params['pay_log_data']))
|
2019-04-11 18:27:50 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
return DataReturn('日志订单有误', -1);
|
2019-04-11 18:27:50 +08:00
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 开启事务
|
|
|
|
|
Db::startTrans();
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 循环处理
|
|
|
|
|
foreach($params['order'] as $order)
|
|
|
|
|
{
|
|
|
|
|
if($order['status'] > 1)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
$status_text = lang('common_order_user_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', 0);
|
|
|
|
|
}
|
2020-04-07 17:29:57 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 订单支付成功处理前钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_pay_handle_begin';
|
|
|
|
|
$ret = HookReturnHandle(Hook::listen($hook_name, [
|
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
|
|
|
|
'params' => &$params,
|
|
|
|
|
'order_id' => $order['id']
|
|
|
|
|
]));
|
|
|
|
|
if(isset($ret['code']) && $ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
2020-04-07 17:29:57 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 消息通知
|
|
|
|
|
$detail = '订单支付成功,金额'.PriceBeautify($order['total_price']).'元';
|
|
|
|
|
MessageService::MessageAdd($order['user_id'], '订单支付', $detail, 1, $order['id']);
|
|
|
|
|
|
|
|
|
|
// 订单更新数据
|
|
|
|
|
$upd_data = [
|
|
|
|
|
'status' => 2,
|
|
|
|
|
'pay_status' => 1,
|
|
|
|
|
'pay_price' => $order['total_price'],
|
|
|
|
|
'payment_id' => $params['payment']['id'],
|
|
|
|
|
'pay_time' => time(),
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
];
|
|
|
|
|
|
|
|
|
|
// 是否线下支付
|
|
|
|
|
$upd_data['is_under_line'] = in_array($params['payment']['payment'], config('shopxo.under_line_list')) ? 1 : 0;
|
|
|
|
|
|
|
|
|
|
// 更新订单状态
|
|
|
|
|
if(!Db::name('Order')->where(['id'=>$order['id']])->update($upd_data))
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn('订单更新失败['.$order['id'].']', -10);
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 添加状态日志
|
|
|
|
|
if(!self::OrderHistoryAdd($order['id'], 2, $order['status'], '支付', 0, '系统'))
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn('订单日志添加失败['.$order['id'].']', -10);
|
|
|
|
|
}
|
2019-04-11 18:27:50 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 库存扣除
|
|
|
|
|
$ret = BuyService::OrderInventoryDeduct(['order_id'=>$order['id'], 'order_data'=>$upd_data]);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn($ret['msg'], -10);
|
|
|
|
|
}
|
2019-04-11 18:27:50 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 订单支付成功处理完毕钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_pay_success_handle_end';
|
|
|
|
|
$ret = HookReturnHandle(Hook::listen($hook_name, [
|
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
|
|
|
|
'params' => $params,
|
|
|
|
|
'order_id' => $order['id']
|
|
|
|
|
]));
|
|
|
|
|
if(isset($ret['code']) && $ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
2019-11-19 21:46:22 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 虚拟商品自动触发发货操作
|
|
|
|
|
if($order['order_model'] == 3)
|
|
|
|
|
{
|
|
|
|
|
self::OrderDelivery([
|
|
|
|
|
'id' => $order['id'],
|
|
|
|
|
'creator' => 0,
|
|
|
|
|
'creator_name' => '系统',
|
|
|
|
|
'user_id' => $order['user_id'],
|
|
|
|
|
]);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 更新支付日志
|
|
|
|
|
$pay_log_data = [
|
|
|
|
|
'log_id' => $params['pay_log_data']['id'],
|
|
|
|
|
'trade_no' => isset($params['pay']['trade_no']) ? $params['pay']['trade_no'] : '',
|
|
|
|
|
'buyer_user' => isset($params['pay']['buyer_user']) ? $params['pay']['buyer_user'] : '',
|
|
|
|
|
'pay_price' => isset($params['pay']['pay_price']) ? $params['pay']['pay_price'] : 0,
|
|
|
|
|
'subject' => isset($params['pay']['subject']) ? $params['pay']['subject'] : '订单支付',
|
|
|
|
|
'payment' => $params['payment']['payment'],
|
|
|
|
|
'payment_name' => $params['payment']['name'],
|
|
|
|
|
];
|
|
|
|
|
$ret = PayLogService::PayLogSuccess($pay_log_data);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
2020-07-28 21:15:47 +08:00
|
|
|
|
// 提交事务
|
|
|
|
|
Db::commit();
|
|
|
|
|
return DataReturn('支付成功', 0);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单列表条件
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-29
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderListWhere($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 用户类型
|
|
|
|
|
$user_type = isset($params['user_type']) ? $params['user_type'] : 'user';
|
|
|
|
|
|
|
|
|
|
// 条件初始化
|
|
|
|
|
$where = [
|
|
|
|
|
['is_delete_time', '=', 0],
|
|
|
|
|
];
|
|
|
|
|
|
|
|
|
|
// id
|
|
|
|
|
if(!empty($params['id']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['id', '=', intval($params['id'])];
|
2019-07-31 20:00:25 +08:00
|
|
|
|
}
|
|
|
|
|
// 订单号
|
|
|
|
|
if(!empty($params['orderno']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['order_no', '=', trim($params['orderno'])];
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
2019-01-10 11:32:15 +08:00
|
|
|
|
|
|
|
|
|
// 用户类型
|
|
|
|
|
if(isset($params['user_type']) && $params['user_type'] == 'user')
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2019-01-10 11:32:15 +08:00
|
|
|
|
$where[] = ['user_is_delete_time', '=', 0];
|
|
|
|
|
|
|
|
|
|
// 用户id
|
|
|
|
|
if(!empty($params['user']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['user_id', '=', $params['user']['id']];
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-03-02 13:53:53 +08:00
|
|
|
|
// 关键字
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(!empty($params['keywords']))
|
|
|
|
|
{
|
2020-03-02 13:53:53 +08:00
|
|
|
|
// 查询状态
|
|
|
|
|
$keywords_status = false;
|
|
|
|
|
|
|
|
|
|
// 订单表查询
|
|
|
|
|
$oids = Db::name('Order')->where([['order_no|express_number', '=', $params['keywords']]])->column('id');
|
|
|
|
|
if(!empty($oids))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['id', 'in', $oids];
|
|
|
|
|
$keywords_status = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 取货码查询
|
|
|
|
|
if($keywords_status === false && strlen(intval($params['keywords'])) == 4)
|
|
|
|
|
{
|
|
|
|
|
$oid = Db::name('OrderExtractionCode')->where(['code'=>$params['keywords']])->value('order_id');
|
|
|
|
|
if(!empty($oid))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['id', '=', $oid];
|
|
|
|
|
$keywords_status = true;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 收件姓名电话查询
|
|
|
|
|
if($keywords_status === false)
|
|
|
|
|
{
|
|
|
|
|
$oids = Db::name('OrderAddress')->where([['name|tel', '=', $params['keywords']]])->column('order_id');
|
|
|
|
|
if(!empty($oids))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['id', 'in', $oids];
|
|
|
|
|
$keywords_status = true;
|
|
|
|
|
}
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 是否更多条件
|
|
|
|
|
if(isset($params['is_more']) && $params['is_more'] == 1)
|
|
|
|
|
{
|
|
|
|
|
// 等值
|
|
|
|
|
if(isset($params['payment_id']) && $params['payment_id'] > -1)
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['payment_id', '=', intval($params['payment_id'])];
|
|
|
|
|
}
|
|
|
|
|
if(isset($params['express_id']) && $params['express_id'] > -1)
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['express_id', '=', intval($params['express_id'])];
|
|
|
|
|
}
|
|
|
|
|
if(isset($params['pay_status']) && $params['pay_status'] > -1)
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['pay_status', '=', intval($params['pay_status'])];
|
|
|
|
|
}
|
2020-03-02 13:53:53 +08:00
|
|
|
|
if(isset($params['order_model']) && $params['order_model'] > -1)
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['order_model', '=', intval($params['order_model'])];
|
|
|
|
|
}
|
2019-05-30 16:30:06 +08:00
|
|
|
|
if(!empty($params['client_type']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['client_type', '=', $params['client_type']];
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(isset($params['status']) && $params['status'] != -1)
|
|
|
|
|
{
|
|
|
|
|
// 多个状态,字符串以半角逗号分割
|
|
|
|
|
if(!is_array($params['status']))
|
|
|
|
|
{
|
|
|
|
|
$params['status'] = explode(',', $params['status']);
|
|
|
|
|
}
|
|
|
|
|
$where[] = ['status', 'in', $params['status']];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 评价状态
|
|
|
|
|
if(isset($params['is_comments']) && $params['is_comments'] > -1)
|
|
|
|
|
{
|
|
|
|
|
$comments_field = ($user_type == 'user') ? 'user_is_comments' : 'is_comments';
|
|
|
|
|
if($params['is_comments'] == 0)
|
|
|
|
|
{
|
|
|
|
|
$where[] = [$comments_field, '=', 0];
|
|
|
|
|
} else {
|
|
|
|
|
$where[] = [$comments_field, '>', 0];
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 时间
|
|
|
|
|
if(!empty($params['time_start']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['add_time', '>', strtotime($params['time_start'])];
|
|
|
|
|
}
|
|
|
|
|
if(!empty($params['time_end']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['add_time', '<', strtotime($params['time_end'])];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 价格
|
|
|
|
|
if(!empty($params['price_start']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['price', '>', floatval($params['price_start'])];
|
|
|
|
|
}
|
|
|
|
|
if(!empty($params['price_end']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['price', '<', floatval($params['price_end'])];
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return $where;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单总数
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-29
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $where [条件]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderTotal($where = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
return (int) Db::name('Order')->where($where)->count();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单列表
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-29
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderList($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
$where = empty($params['where']) ? [] : $params['where'];
|
|
|
|
|
$m = isset($params['m']) ? intval($params['m']) : 0;
|
|
|
|
|
$n = isset($params['n']) ? intval($params['n']) : 10;
|
|
|
|
|
$order_by = empty($params['order_by']) ? 'id desc' : $params['order_by'];
|
|
|
|
|
|
|
|
|
|
// 获取订单
|
|
|
|
|
$data = Db::name('Order')->where($where)->limit($m, $n)->order($order_by)->select();
|
2020-07-07 18:58:29 +08:00
|
|
|
|
|
|
|
|
|
// 数据处理
|
|
|
|
|
return self::OrderDataHandle($data, $params);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单数据处理
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-07-05
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $data [订单数据]
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
|
|
|
|
public static function OrderDataHandle($data, $params = [])
|
|
|
|
|
{
|
|
|
|
|
$result = [];
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(!empty($data))
|
|
|
|
|
{
|
2020-07-07 18:58:29 +08:00
|
|
|
|
// 其它额外处理
|
|
|
|
|
$is_items = isset($params['is_items']) ? intval($params['is_items']) : 1;
|
|
|
|
|
$is_orderaftersale = isset($params['is_orderaftersale']) ? intval($params['is_orderaftersale']) : 0;
|
|
|
|
|
$user_type = isset($params['user_type']) ? $params['user_type'] : 'user';
|
|
|
|
|
|
|
|
|
|
// 静态数据
|
2018-12-28 18:58:37 +08:00
|
|
|
|
$order_status_list = lang('common_order_user_status');
|
|
|
|
|
$order_pay_status = lang('common_order_pay_status');
|
2019-05-30 16:30:06 +08:00
|
|
|
|
$common_platform_type = lang('common_platform_type');
|
2019-11-19 21:46:22 +08:00
|
|
|
|
$common_site_type_list = lang('common_site_type_list');
|
2020-07-07 18:58:29 +08:00
|
|
|
|
|
|
|
|
|
// 循环处理数据
|
2018-12-28 18:58:37 +08:00
|
|
|
|
foreach($data as &$v)
|
|
|
|
|
{
|
2019-03-12 18:06:57 +08:00
|
|
|
|
// 订单处理前钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_handle_begin';
|
2019-12-02 20:58:24 +08:00
|
|
|
|
$ret = HookReturnHandle(Hook::listen($hook_name, [
|
2019-03-12 18:06:57 +08:00
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
|
|
|
|
'params' => &$params,
|
|
|
|
|
'order' => &$v,
|
|
|
|
|
'order_id' => $v['id']
|
2019-12-02 20:58:24 +08:00
|
|
|
|
]));
|
2019-03-12 18:06:57 +08:00
|
|
|
|
if(isset($ret['code']) && $ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
|
|
|
|
|
2019-11-21 17:02:27 +08:00
|
|
|
|
// 订单模式处理
|
|
|
|
|
// 销售型模式+自提模式
|
|
|
|
|
if(in_array($v['order_model'], [0,2]))
|
2019-11-19 21:46:22 +08:00
|
|
|
|
{
|
2019-11-21 17:02:27 +08:00
|
|
|
|
// 销售模式+自提模式 地址信息
|
2019-11-26 14:00:00 +08:00
|
|
|
|
$v['address_data'] = self::OrderAddressData($v['id']);
|
2019-11-21 17:02:27 +08:00
|
|
|
|
|
|
|
|
|
// 自提模式 添加订单取货码
|
|
|
|
|
if($v['order_model'] == 2)
|
|
|
|
|
{
|
2020-04-07 12:44:38 +08:00
|
|
|
|
$v['extraction_data'] = self::OrdersExtractionData($v['id'], $v['user_id']);
|
2019-11-21 17:02:27 +08:00
|
|
|
|
}
|
2019-11-19 21:46:22 +08:00
|
|
|
|
}
|
|
|
|
|
|
2019-06-13 00:56:02 +08:00
|
|
|
|
// 用户信息
|
|
|
|
|
if(isset($v['user_id']))
|
|
|
|
|
{
|
|
|
|
|
if(isset($params['is_public']) && $params['is_public'] == 0)
|
|
|
|
|
{
|
|
|
|
|
$v['user'] = UserService::GetUserViewInfo($v['user_id']);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2019-11-19 21:46:22 +08:00
|
|
|
|
// 订单模式
|
|
|
|
|
$v['order_model_name'] = isset($common_site_type_list[$v['order_model']]) ? $common_site_type_list[$v['order_model']]['name'] : '未知';
|
|
|
|
|
|
2019-05-30 16:30:06 +08:00
|
|
|
|
// 客户端
|
|
|
|
|
$v['client_type_name'] = isset($common_platform_type[$v['client_type']]) ? $common_platform_type[$v['client_type']]['name'] : '';
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 状态
|
2019-11-20 18:35:38 +08:00
|
|
|
|
$v['status_name'] = ($v['order_model'] == 2 && $v['status'] == 2) ? '待取货' : $order_status_list[$v['status']]['name'];
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 支付状态
|
|
|
|
|
$v['pay_status_name'] = $order_pay_status[$v['pay_status']]['name'];
|
|
|
|
|
|
|
|
|
|
// 快递公司
|
|
|
|
|
$v['express_name'] = ExpressService::ExpressName($v['express_id']);
|
|
|
|
|
|
|
|
|
|
// 支付方式
|
2020-04-07 17:29:57 +08:00
|
|
|
|
$v['payment_name'] = PaymentService::OrderPaymentName($v['id'], $v['payment_id']);
|
|
|
|
|
|
|
|
|
|
// 线下支付 icon 名称
|
|
|
|
|
$v['is_under_line_text'] = ($v['is_under_line'] == 1) ? '线下支付' : null;
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
2020-07-24 15:11:13 +08:00
|
|
|
|
// 是否可发起售后
|
|
|
|
|
$v['is_can_launch_aftersale'] = OrderAftersaleService::OrderIsCanLaunchAftersale($v['collect_time']);
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 创建时间
|
|
|
|
|
$v['add_time_time'] = date('Y-m-d H:i:s', $v['add_time']);
|
|
|
|
|
$v['add_time_date'] = date('Y-m-d', $v['add_time']);
|
|
|
|
|
$v['add_time'] = date('Y-m-d H:i:s', $v['add_time']);
|
|
|
|
|
|
|
|
|
|
// 更新时间
|
2020-06-08 14:03:33 +08:00
|
|
|
|
$v['upd_time'] = empty($v['upd_time']) ? null : date('Y-m-d H:i:s', $v['upd_time']);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 确认时间
|
|
|
|
|
$v['confirm_time'] = empty($v['confirm_time']) ? null : date('Y-m-d H:i:s', $v['confirm_time']);
|
|
|
|
|
|
|
|
|
|
// 支付时间
|
|
|
|
|
$v['pay_time'] = empty($v['pay_time']) ? null : date('Y-m-d H:i:s', $v['pay_time']);
|
|
|
|
|
|
|
|
|
|
// 发货时间
|
|
|
|
|
$v['delivery_time'] = empty($v['delivery_time']) ? null : date('Y-m-d H:i:s', $v['delivery_time']);
|
|
|
|
|
|
|
|
|
|
// 收货时间
|
|
|
|
|
$v['collect_time'] = empty($v['collect_time']) ? null : date('Y-m-d H:i:s', $v['collect_time']);
|
|
|
|
|
|
|
|
|
|
// 取消时间
|
|
|
|
|
$v['cancel_time'] = empty($v['cancel_time']) ? null : date('Y-m-d H:i:s', $v['cancel_time']);
|
|
|
|
|
|
|
|
|
|
// 关闭时间
|
|
|
|
|
$v['close_time'] = empty($v['close_time']) ? null : date('Y-m-d H:i:s', $v['close_time']);
|
|
|
|
|
|
|
|
|
|
// 评论时间
|
|
|
|
|
$v['user_is_comments_time'] = ($v['user_is_comments'] == 0) ? null : date('Y-m-d H:i:s', $v['user_is_comments']);
|
|
|
|
|
|
|
|
|
|
// 空字段数据处理
|
|
|
|
|
if(empty($v['express_number']))
|
|
|
|
|
{
|
|
|
|
|
$v['express_number'] = null;
|
|
|
|
|
}
|
|
|
|
|
if(empty($v['user_note']))
|
|
|
|
|
{
|
|
|
|
|
$v['user_note'] = null;
|
|
|
|
|
}
|
2019-03-21 17:34:40 +08:00
|
|
|
|
|
|
|
|
|
// 扩展数据
|
|
|
|
|
$v['extension_data'] = empty($v['extension_data']) ? null : json_decode($v['extension_data'], true);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 订单详情
|
|
|
|
|
if($is_items == 1)
|
|
|
|
|
{
|
2020-05-15 19:23:05 +08:00
|
|
|
|
$items = self::OrderItemList($v['id'], $v['order_model'], $v['status'], $v['pay_status'], $is_orderaftersale);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
$v['items'] = $items;
|
2019-05-30 02:06:17 +08:00
|
|
|
|
$v['items_count'] = count($items);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 描述
|
2020-02-04 17:18:14 +08:00
|
|
|
|
$v['describe'] = '共'.$v['buy_number_count'].'件 合计:'.config('shopxo.price_symbol').$v['total_price'].'元';
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
2019-03-12 18:06:57 +08:00
|
|
|
|
|
2020-05-15 19:23:05 +08:00
|
|
|
|
// 管理员读取
|
|
|
|
|
if($user_type == 'admin')
|
|
|
|
|
{
|
|
|
|
|
// 获取最新一条售后订单
|
|
|
|
|
$v['aftersale_first'] = self::OrderAftersaleFirst($v['id']);
|
|
|
|
|
}
|
|
|
|
|
|
2019-03-12 18:06:57 +08:00
|
|
|
|
// 订单处理后钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_handle_end';
|
2019-12-02 20:58:24 +08:00
|
|
|
|
$ret = HookReturnHandle(Hook::listen($hook_name, [
|
2019-03-12 18:06:57 +08:00
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
|
|
|
|
'params' => &$params,
|
|
|
|
|
'order' => &$v,
|
|
|
|
|
'order_id' => $v['id']
|
2019-12-02 20:58:24 +08:00
|
|
|
|
]));
|
2019-03-12 18:06:57 +08:00
|
|
|
|
if(isset($ret['code']) && $ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
return $ret;
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
}
|
2019-03-12 18:06:57 +08:00
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
return DataReturn('success', 0, $data);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
2020-05-15 19:23:05 +08:00
|
|
|
|
/**
|
|
|
|
|
* 订单最新一条售后
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-05-15
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [int] $order_id [订单 id]
|
|
|
|
|
*/
|
|
|
|
|
public static function OrderAftersaleFirst($order_id)
|
|
|
|
|
{
|
|
|
|
|
$data = Db::name('OrderAftersale')->where(['order_id'=>$order_id])->field('status,type,number,price,reason,msg')->order('id desc')->find();
|
|
|
|
|
if(!empty($data))
|
|
|
|
|
{
|
|
|
|
|
$type_list = lang('common_order_aftersale_type_list');
|
|
|
|
|
$status_list = lang('common_order_aftersale_status_list');
|
|
|
|
|
|
|
|
|
|
// 类型
|
|
|
|
|
$data['type_text'] = array_key_exists($data['type'], $type_list) ? $type_list[$data['type']]['name'] : '';
|
|
|
|
|
|
|
|
|
|
// 状态
|
|
|
|
|
$data['status_text'] = array_key_exists($data['status'], $status_list) ? $status_list[$data['status']]['name'] : '';
|
|
|
|
|
}
|
|
|
|
|
return $data;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单详情列表
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2020-05-15
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [int] $order_id [订单 id]
|
|
|
|
|
* @param [int] $order_model [订单模式]
|
|
|
|
|
* @param [int] $status [订单状态]
|
|
|
|
|
* @param [int] $pay_status [支付状态]
|
|
|
|
|
* @param [int] $is_orderaftersale [是否读取订单售后(0否, 1是)]
|
|
|
|
|
*/
|
|
|
|
|
public static function OrderItemList($order_id, $order_model, $status, $pay_status, $is_orderaftersale = 0)
|
|
|
|
|
{
|
|
|
|
|
$items = Db::name('OrderDetail')->where(['order_id'=>$order_id])->select();
|
|
|
|
|
if(!empty($items))
|
|
|
|
|
{
|
|
|
|
|
foreach($items as &$vs)
|
|
|
|
|
{
|
|
|
|
|
// 商品信息
|
|
|
|
|
$vs['images'] = ResourcesService::AttachmentPathViewHandle($vs['images']);
|
|
|
|
|
$vs['goods_url'] = MyUrl('index/goods/index', ['id'=>$vs['goods_id']]);
|
|
|
|
|
$vs['total_price'] = $vs['buy_number']*$vs['price'];
|
|
|
|
|
|
|
|
|
|
// 规格
|
|
|
|
|
if(!empty($vs['spec']))
|
|
|
|
|
{
|
|
|
|
|
$vs['spec'] = json_decode($vs['spec'], true);
|
|
|
|
|
if(!empty($vs['spec']) && is_array($vs['spec']))
|
|
|
|
|
{
|
|
|
|
|
$vs['spec_text'] = implode(',', array_map(function($spec)
|
|
|
|
|
{
|
|
|
|
|
return $spec['type'].':'.$spec['value'];
|
|
|
|
|
}, $vs['spec']));
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
$vs['spec'] = null;
|
|
|
|
|
$vs['spec_text'] = null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 虚拟销售商品 - 虚拟信息处理
|
|
|
|
|
if($order_model == 3 && $pay_status == 1 && in_array($status, [3,4]))
|
|
|
|
|
{
|
|
|
|
|
$vs['fictitious_goods_value'] = Db::name('OrderFictitiousValue')->where(['order_detail_id'=>$vs['id']])->value('value');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 是否获取最新一条售后信息
|
|
|
|
|
if($is_orderaftersale == 1)
|
|
|
|
|
{
|
|
|
|
|
$orderaftersale = Db::name('OrderAftersale')->where(['order_detail_id'=>$vs['id']])->order('id desc')->find();
|
|
|
|
|
$vs['orderaftersale'] = $orderaftersale;
|
|
|
|
|
$vs['orderaftersale_btn_text'] = self::OrderAftersaleStatusBtnText($status, $orderaftersale);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return $items;
|
|
|
|
|
}
|
|
|
|
|
|
2019-11-26 14:00:00 +08:00
|
|
|
|
/**
|
|
|
|
|
* 订单自提信息
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2019-11-26
|
|
|
|
|
* @desc description
|
2020-04-07 12:44:38 +08:00
|
|
|
|
* @param [int] $order_id [订单id]
|
|
|
|
|
* @param [int] $user_id [用户id]
|
2019-11-26 14:00:00 +08:00
|
|
|
|
*/
|
2020-04-07 12:44:38 +08:00
|
|
|
|
private static function OrdersExtractionData($order_id, $user_id)
|
2019-11-26 14:00:00 +08:00
|
|
|
|
{
|
2020-04-07 12:44:38 +08:00
|
|
|
|
// 必须返回的内容格式
|
2019-11-26 14:00:00 +08:00
|
|
|
|
$result = [
|
|
|
|
|
'code' => null,
|
|
|
|
|
'images' => null,
|
|
|
|
|
];
|
2020-04-07 12:44:38 +08:00
|
|
|
|
|
|
|
|
|
// 获取取货码
|
2019-11-26 14:00:00 +08:00
|
|
|
|
$code = Db::name('OrderExtractionCode')->where(['order_id'=>$order_id])->value('code');
|
|
|
|
|
if(!empty($code))
|
|
|
|
|
{
|
|
|
|
|
$result['code'] = $code;
|
2020-04-07 12:44:38 +08:00
|
|
|
|
|
|
|
|
|
// 生成二维码参数
|
|
|
|
|
$qrcode_params = [
|
|
|
|
|
'content' => $code,
|
|
|
|
|
'root_path' => ROOT.'public',
|
|
|
|
|
'path' => DS.'download'.DS.'order'.DS.'extraction_ode'.DS,
|
|
|
|
|
'filename' => $user_id.'_'.$order_id.'.png',
|
|
|
|
|
];
|
|
|
|
|
|
|
|
|
|
// 图片不存在则去生成二维码图片并保存至目录
|
|
|
|
|
$file = $qrcode_params['root_path'].$qrcode_params['path'].$qrcode_params['filename'];
|
|
|
|
|
if(!file_exists($file))
|
|
|
|
|
{
|
|
|
|
|
$ret = (new \base\Qrcode())->Create($qrcode_params);
|
|
|
|
|
if($ret['code'] == 0)
|
|
|
|
|
{
|
|
|
|
|
$result['images'] = $qrcode_params['path'].$qrcode_params['filename'];
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
$result['images'] = $qrcode_params['path'].$qrcode_params['filename'];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 展示地址处理
|
|
|
|
|
if(!empty($result['images']))
|
|
|
|
|
{
|
|
|
|
|
$result['images'] = ResourcesService::AttachmentPathViewHandle($result['images']);
|
|
|
|
|
}
|
2019-11-26 14:00:00 +08:00
|
|
|
|
}
|
|
|
|
|
return $result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单地址
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2019-11-26
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [int] $order_id [订单id]
|
|
|
|
|
*/
|
|
|
|
|
private static function OrderAddressData($order_id)
|
|
|
|
|
{
|
|
|
|
|
// 销售模式+自提模式 地址信息
|
|
|
|
|
$data = Db::name('OrderAddress')->where(['order_id'=>$order_id])->find();
|
2019-11-27 21:09:42 +08:00
|
|
|
|
|
|
|
|
|
// 坐标处理
|
2020-01-30 10:58:32 +08:00
|
|
|
|
if(!empty($data) && is_array($data) && in_array(APPLICATION_CLIENT_TYPE, config('shopxo.coordinate_transformation')))
|
2019-11-26 14:00:00 +08:00
|
|
|
|
{
|
|
|
|
|
// 坐标转换 百度转火星(高德,谷歌,腾讯坐标)
|
|
|
|
|
if(isset($data['lng']) && isset($data['lat']) && $data['lng'] > 0 && $data['lat'] > 0)
|
|
|
|
|
{
|
|
|
|
|
$map = \base\GeoTransUtil::BdToGcj($data['lng'], $data['lat']);
|
|
|
|
|
if(isset($map['lng']) && isset($map['lat']))
|
|
|
|
|
{
|
2019-11-27 20:43:19 +08:00
|
|
|
|
$data['lng'] = $map['lng'];
|
|
|
|
|
$data['lat'] = $map['lat'];
|
2019-11-26 14:00:00 +08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return empty($data) ? [] : $data;
|
|
|
|
|
}
|
|
|
|
|
|
2019-10-04 16:28:59 +08:00
|
|
|
|
/**
|
|
|
|
|
* 订单售后操作名称
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @datetime 2019-10-04T13:11:55+0800
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [int] $order_status [订单状态]
|
|
|
|
|
* @param [array] $orderaftersale [售后数据]
|
|
|
|
|
*/
|
|
|
|
|
private static function OrderAftersaleStatusBtnText($order_status, $orderaftersale)
|
|
|
|
|
{
|
|
|
|
|
$text = '';
|
|
|
|
|
if(in_array($order_status, [2,3,4,6]))
|
|
|
|
|
{
|
|
|
|
|
if(empty($orderaftersale))
|
|
|
|
|
{
|
|
|
|
|
if(in_array($order_status, [2,3]))
|
|
|
|
|
{
|
|
|
|
|
$text = '退款/退货';
|
|
|
|
|
} else {
|
|
|
|
|
if($order_status == 4)
|
|
|
|
|
{
|
|
|
|
|
$text = '申请售后';
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
$text = ($orderaftersale['status'] == 3) ? '查看退款' : '查看进度';
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return $text;
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
/**
|
|
|
|
|
* 订单日志添加
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-30
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [int] $order_id [订单id]
|
|
|
|
|
* @param [int] $new_status [更新后的状态]
|
|
|
|
|
* @param [int] $original_status [原始状态]
|
|
|
|
|
* @param [string] $msg [描述]
|
|
|
|
|
* @param [int] $creator [操作人]
|
|
|
|
|
* @param [string] $creator_name [操作人名称]
|
|
|
|
|
* @return [boolean] [成功 true, 失败 false]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderHistoryAdd($order_id, $new_status, $original_status, $msg = '', $creator = 0, $creator_name = '')
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 状态描述
|
|
|
|
|
$order_status_list = lang('common_order_user_status');
|
|
|
|
|
$original_status_name = $order_status_list[$original_status]['name'];
|
|
|
|
|
$new_status_name = $order_status_list[$new_status]['name'];
|
|
|
|
|
$msg .= '['.$original_status_name.'-'.$new_status_name.']';
|
|
|
|
|
|
|
|
|
|
// 添加
|
|
|
|
|
$data = [
|
|
|
|
|
'order_id' => intval($order_id),
|
|
|
|
|
'new_status' => intval($new_status),
|
|
|
|
|
'original_status' => intval($original_status),
|
|
|
|
|
'msg' => htmlentities($msg),
|
|
|
|
|
'creator' => intval($creator),
|
|
|
|
|
'creator_name' => htmlentities($creator_name),
|
|
|
|
|
'add_time' => time(),
|
|
|
|
|
];
|
2019-04-11 18:27:50 +08:00
|
|
|
|
|
|
|
|
|
// 日志添加
|
|
|
|
|
if(Db::name('OrderStatusHistory')->insertGetId($data) > 0)
|
|
|
|
|
{
|
|
|
|
|
// 订单状态改变添加日志钩子
|
|
|
|
|
$hook_name = 'plugins_service_order_status_change_history_success_handle';
|
2019-12-02 20:58:24 +08:00
|
|
|
|
Hook::listen($hook_name, [
|
2019-04-11 18:27:50 +08:00
|
|
|
|
'hook_name' => $hook_name,
|
|
|
|
|
'is_backend' => true,
|
|
|
|
|
'data' => $data,
|
|
|
|
|
'order_id' => $data['order_id']
|
|
|
|
|
]);
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
return false;
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单取消
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-30
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderCancel($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user_id',
|
|
|
|
|
'error_msg' => '用户id有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['id'=>intval($params['id']), 'user_id'=>$params['user_id'], 'is_delete_time'=>0, 'user_is_delete_time'=>0];
|
|
|
|
|
$order = Db::name('Order')->where($where)->field('id,status,user_id')->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if(!in_array($order['status'], [0,1]))
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_user_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 开启事务
|
|
|
|
|
Db::startTrans();
|
|
|
|
|
$upd_data = [
|
|
|
|
|
'status' => 5,
|
|
|
|
|
'cancel_time' => time(),
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
];
|
|
|
|
|
if(Db::name('Order')->where($where)->update($upd_data))
|
|
|
|
|
{
|
|
|
|
|
// 库存回滚
|
|
|
|
|
$ret = BuyService::OrderInventoryRollback(['order_id'=>$order['id'], 'order_data'=>$upd_data]);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn($ret['msg'], -10);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户消息
|
|
|
|
|
MessageService::MessageAdd($order['user_id'], '订单取消', '订单取消成功', 1, $order['id']);
|
|
|
|
|
|
|
|
|
|
// 订单状态日志
|
|
|
|
|
$creator = isset($params['creator']) ? intval($params['creator']) : 0;
|
|
|
|
|
$creator_name = isset($params['creator_name']) ? htmlentities($params['creator_name']) : '';
|
2019-01-17 00:37:20 +08:00
|
|
|
|
self::OrderHistoryAdd($order['id'], $upd_data['status'], $order['status'], '取消', $creator, $creator_name);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 提交事务
|
|
|
|
|
Db::commit();
|
|
|
|
|
return DataReturn('取消成功', 0);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn('取消失败', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单发货
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-30
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderDelivery($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user_id',
|
|
|
|
|
'error_msg' => '用户id有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['id'=>intval($params['id']), 'user_id'=>$params['user_id'], 'is_delete_time'=>0, 'user_is_delete_time'=>0];
|
2019-11-19 21:46:22 +08:00
|
|
|
|
$order = Db::name('Order')->where($where)->field('id,status,user_id,order_model')->find();
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if(!in_array($order['status'], [2]))
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_user_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', -1);
|
|
|
|
|
}
|
|
|
|
|
|
2019-11-21 17:02:27 +08:00
|
|
|
|
// 订单模式
|
|
|
|
|
switch($order['order_model'])
|
2019-11-19 21:46:22 +08:00
|
|
|
|
{
|
2019-11-21 17:02:27 +08:00
|
|
|
|
// 销售模式- 订单快递信息校验
|
|
|
|
|
case 0 :
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'express_id',
|
|
|
|
|
'error_msg' => '快递id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'express_number',
|
|
|
|
|
'error_msg' => '快递单号有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
// 自提模式 - 验证取货码
|
|
|
|
|
case 2 :
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'extraction_code',
|
|
|
|
|
'error_msg' => '取货码有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 校验
|
|
|
|
|
$extraction_code = Db::name('OrderExtractionCode')->where(['order_id'=>$order['id']])->value('code');
|
|
|
|
|
if(empty($extraction_code))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('订单取货码不存在、请联系管理员', -10);
|
|
|
|
|
}
|
|
|
|
|
if($extraction_code != $params['extraction_code'])
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('取货码不正确', -11);
|
|
|
|
|
}
|
|
|
|
|
break;
|
2019-11-19 21:46:22 +08:00
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 开启事务
|
|
|
|
|
Db::startTrans();
|
|
|
|
|
$upd_data = [
|
|
|
|
|
'status' => 3,
|
2019-11-19 21:46:22 +08:00
|
|
|
|
'express_id' => isset($params['express_id']) ? intval($params['express_id']) : 0,
|
2018-12-28 18:58:37 +08:00
|
|
|
|
'express_number' => isset($params['express_number']) ? $params['express_number'] : '',
|
|
|
|
|
'delivery_time' => time(),
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
];
|
|
|
|
|
if(Db::name('Order')->where($where)->update($upd_data))
|
|
|
|
|
{
|
|
|
|
|
// 库存扣除
|
|
|
|
|
$ret = BuyService::OrderInventoryDeduct(['order_id'=>$order['id'], 'order_data'=>$upd_data]);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn($ret['msg'], -10);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户消息
|
|
|
|
|
MessageService::MessageAdd($order['user_id'], '订单发货', '订单已发货', 1, $order['id']);
|
|
|
|
|
|
|
|
|
|
// 订单状态日志
|
|
|
|
|
$creator = isset($params['creator']) ? intval($params['creator']) : 0;
|
|
|
|
|
$creator_name = isset($params['creator_name']) ? htmlentities($params['creator_name']) : '';
|
2019-01-17 00:37:20 +08:00
|
|
|
|
self::OrderHistoryAdd($order['id'], $upd_data['status'], $order['status'], '收货', $creator, $creator_name);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 提交事务
|
|
|
|
|
Db::commit();
|
|
|
|
|
return DataReturn('发货成功', 0);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn('发货失败', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单收货
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-30
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderCollect($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user_id',
|
|
|
|
|
'error_msg' => '用户id有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['id'=>intval($params['id']), 'user_id'=>$params['user_id'], 'is_delete_time'=>0, 'user_is_delete_time'=>0];
|
|
|
|
|
$order = Db::name('Order')->where($where)->field('id,status,user_id')->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if(!in_array($order['status'], [3]))
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_user_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 开启事务
|
|
|
|
|
Db::startTrans();
|
|
|
|
|
|
|
|
|
|
// 更新订单状态
|
|
|
|
|
$upd_data = [
|
|
|
|
|
'status' => 4,
|
|
|
|
|
'collect_time' => time(),
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
];
|
|
|
|
|
if(Db::name('Order')->where($where)->update($upd_data))
|
|
|
|
|
{
|
2020-06-28 22:50:10 +08:00
|
|
|
|
// 订单商品积分赠送
|
|
|
|
|
$ret = IntegralService::OrderGoodsIntegralGiving(['order_id'=>$order['id']]);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn($ret['msg'], -10);
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
// 订单商品销量增加
|
2019-01-17 00:37:20 +08:00
|
|
|
|
$ret = self::GoodsSalesCountInc(['order_id'=>$order['id']]);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn($ret['msg'], -10);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户消息
|
|
|
|
|
MessageService::MessageAdd($order['user_id'], '订单收货', '订单收货成功', 1, $order['id']);
|
|
|
|
|
|
|
|
|
|
// 订单状态日志
|
|
|
|
|
$creator = isset($params['creator']) ? intval($params['creator']) : 0;
|
|
|
|
|
$creator_name = isset($params['creator_name']) ? htmlentities($params['creator_name']) : '';
|
2019-01-17 00:37:20 +08:00
|
|
|
|
self::OrderHistoryAdd($order['id'], $upd_data['status'], $order['status'], '收货', $creator, $creator_name);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 提交事务
|
|
|
|
|
Db::commit();
|
|
|
|
|
return DataReturn('收货成功', 0);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn('收货失败', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单确认
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-30
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderConfirm($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user_id',
|
|
|
|
|
'error_msg' => '用户id有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单信息
|
|
|
|
|
$where = ['id'=>intval($params['id']), 'user_id'=>$params['user_id'], 'is_delete_time'=>0, 'user_is_delete_time'=>0];
|
|
|
|
|
$order = Db::name('Order')->where($where)->field('id,status,user_id')->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if(!in_array($order['status'], [0]))
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_admin_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 开启事务
|
|
|
|
|
Db::startTrans();
|
|
|
|
|
|
|
|
|
|
// 更新订单状态
|
|
|
|
|
$upd_data = [
|
|
|
|
|
'status' => 1,
|
|
|
|
|
'confirm_time' => time(),
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
];
|
|
|
|
|
if(Db::name('Order')->where($where)->update($upd_data))
|
|
|
|
|
{
|
|
|
|
|
// 库存扣除
|
|
|
|
|
$ret = BuyService::OrderInventoryDeduct(['order_id'=>$params['id'], 'order_data'=>$upd_data]);
|
|
|
|
|
if($ret['code'] != 0)
|
|
|
|
|
{
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn($ret['msg'], -10);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户消息
|
|
|
|
|
MessageService::MessageAdd($order['user_id'], '订单确认', '订单确认成功', 1, $order['id']);
|
|
|
|
|
|
|
|
|
|
// 订单状态日志
|
|
|
|
|
$creator = isset($params['creator']) ? intval($params['creator']) : 0;
|
|
|
|
|
$creator_name = isset($params['creator_name']) ? htmlentities($params['creator_name']) : '';
|
2019-01-17 00:37:20 +08:00
|
|
|
|
self::OrderHistoryAdd($order['id'], $upd_data['status'], $order['status'], '确认', $creator, $creator_name);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
|
|
|
|
// 事务提交
|
|
|
|
|
Db::commit();
|
|
|
|
|
return DataReturn('确认成功', 0);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 事务回滚
|
|
|
|
|
Db::rollback();
|
|
|
|
|
return DataReturn('确认失败', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单删除
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-09-30
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderDelete($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user_id',
|
|
|
|
|
'error_msg' => '用户id有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user_type',
|
|
|
|
|
'error_msg' => '用户类型有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户类型
|
|
|
|
|
switch($params['user_type'])
|
|
|
|
|
{
|
|
|
|
|
case 'admin' :
|
|
|
|
|
$delete_field = 'is_delete_time';
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
case 'user' :
|
|
|
|
|
$delete_field = 'user_is_delete_time';
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
if(empty($delete_field))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('用户类型有误['.$params['user_type'].']', -2);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单信息
|
2019-09-24 16:26:25 +08:00
|
|
|
|
$where = ['id'=>intval($params['id']), 'user_id'=>$params['user_id'], $delete_field=>0];
|
2018-12-28 18:58:37 +08:00
|
|
|
|
$order = Db::name('Order')->where($where)->field('id,status,user_id')->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('资源不存在或已被删除', -1);
|
|
|
|
|
}
|
|
|
|
|
if(!in_array($order['status'], [4,5,6]))
|
|
|
|
|
{
|
|
|
|
|
$status_text = lang('common_order_user_status')[$order['status']]['name'];
|
|
|
|
|
return DataReturn('状态不可操作['.$status_text.']', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$data = [
|
|
|
|
|
$delete_field => time(),
|
|
|
|
|
'upd_time' => time(),
|
|
|
|
|
];
|
|
|
|
|
if(Db::name('Order')->where($where)->update($data))
|
|
|
|
|
{
|
|
|
|
|
// 用户消息
|
|
|
|
|
MessageService::MessageAdd($order['user_id'], '订单删除', '订单删除成功', 1, $order['id']);
|
|
|
|
|
|
|
|
|
|
return DataReturn('删除成功', 0);
|
|
|
|
|
}
|
|
|
|
|
return DataReturn('删除失败或资源不存在', -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单每个环节状态总数
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-10-10
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderStatusStepTotal($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 状态数据封装
|
|
|
|
|
$result = [];
|
|
|
|
|
$order_status_list = lang('common_order_user_status');
|
|
|
|
|
foreach($order_status_list as $v)
|
|
|
|
|
{
|
|
|
|
|
$result[] = [
|
|
|
|
|
'name' => $v['name'],
|
|
|
|
|
'status' => $v['id'],
|
|
|
|
|
'count' => 0,
|
|
|
|
|
];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户类型
|
|
|
|
|
$user_type = isset($params['user_type']) ? $params['user_type'] : '';
|
|
|
|
|
|
|
|
|
|
// 条件
|
|
|
|
|
$where = [];
|
|
|
|
|
$where['is_delete_time'] = 0;
|
|
|
|
|
|
|
|
|
|
// 用户类型
|
|
|
|
|
switch($user_type)
|
|
|
|
|
{
|
|
|
|
|
case 'user' :
|
|
|
|
|
$where['user_is_delete_time'] = 0;
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用户条件
|
|
|
|
|
if($user_type == 'user')
|
|
|
|
|
{
|
|
|
|
|
if(!empty($params['user']))
|
|
|
|
|
{
|
|
|
|
|
$where['user_id'] = $params['user']['id'];
|
|
|
|
|
} else {
|
|
|
|
|
return DataReturn('用户信息有误', 0, $result);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$field = 'COUNT(DISTINCT id) AS count, status';
|
|
|
|
|
$data = Db::name('Order')->where($where)->field($field)->group('status')->select();
|
|
|
|
|
|
|
|
|
|
// 数据处理
|
|
|
|
|
if(!empty($data))
|
|
|
|
|
{
|
|
|
|
|
foreach($result as &$v)
|
|
|
|
|
{
|
|
|
|
|
foreach($data as $vs)
|
|
|
|
|
{
|
|
|
|
|
if($v['status'] == $vs['status'])
|
|
|
|
|
{
|
|
|
|
|
$v['count'] = $vs['count'];
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2019-10-07 18:06:26 +08:00
|
|
|
|
// 待评价 状态站位100
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(isset($params['is_comments']) && $params['is_comments'] == 1)
|
|
|
|
|
{
|
|
|
|
|
switch($user_type)
|
|
|
|
|
{
|
|
|
|
|
case 'user' :
|
|
|
|
|
$where['user_is_comments'] = 0;
|
|
|
|
|
break;
|
|
|
|
|
case 'admin' :
|
|
|
|
|
$where['is_comments'] = 0;
|
|
|
|
|
break;
|
|
|
|
|
default :
|
|
|
|
|
$where['user_is_comments'] = 0;
|
|
|
|
|
$where['is_comments'] = 0;
|
|
|
|
|
}
|
|
|
|
|
$where['status'] = 4;
|
|
|
|
|
$result[] = [
|
|
|
|
|
'name' => '待评价',
|
|
|
|
|
'status' => 100,
|
|
|
|
|
'count' => (int) Db::name('Order')->where($where)->count(),
|
|
|
|
|
];
|
|
|
|
|
}
|
2019-10-07 18:06:26 +08:00
|
|
|
|
|
|
|
|
|
// 退款/售后 状态站位101
|
|
|
|
|
if(isset($params['is_aftersale']) && $params['is_aftersale'] == 1)
|
|
|
|
|
{
|
|
|
|
|
$where = [
|
|
|
|
|
['status', '<=', 2],
|
|
|
|
|
];
|
|
|
|
|
if($user_type == 'user' && !empty($params['user']))
|
|
|
|
|
{
|
|
|
|
|
$where[] = ['user_id', '=', $params['user']['id']];
|
|
|
|
|
}
|
|
|
|
|
$result[] = [
|
|
|
|
|
'name' => '退款/售后',
|
|
|
|
|
'status' => 101,
|
|
|
|
|
'count' => (int) Db::name('OrderAftersale')->where($where)->count(),
|
|
|
|
|
];
|
|
|
|
|
}
|
2018-12-28 18:58:37 +08:00
|
|
|
|
|
2020-04-07 17:29:57 +08:00
|
|
|
|
return DataReturn('success', 0, $result);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 订单商品销量添加
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2018-11-14
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function GoodsSalesCountInc($params = [])
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'order_id',
|
|
|
|
|
'error_msg' => '订单id有误',
|
|
|
|
|
]
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单商品
|
2020-03-18 15:03:20 +08:00
|
|
|
|
$order_detail = Db::name('OrderDetail')->field('id,goods_id,title,buy_number')->where(['order_id'=>$params['order_id']])->select();
|
2018-12-28 18:58:37 +08:00
|
|
|
|
if(!empty($order_detail))
|
|
|
|
|
{
|
|
|
|
|
foreach($order_detail as $v)
|
|
|
|
|
{
|
2020-03-18 15:03:20 +08:00
|
|
|
|
if(Db::name('Goods')->where(['id'=>$v['goods_id']])->setInc('sales_count', $v['buy_number']) === false)
|
2018-12-28 18:58:37 +08:00
|
|
|
|
{
|
2020-03-18 15:03:20 +08:00
|
|
|
|
return DataReturn('订单商品销量增加失败['.$v['title'].']', -10);
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return DataReturn('操作成功', 0);
|
|
|
|
|
} else {
|
|
|
|
|
return DataReturn('订单有误,没有找到相关商品', -100);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2019-01-08 13:59:14 +08:00
|
|
|
|
/**
|
|
|
|
|
* 支付状态校验
|
|
|
|
|
* @author Devil
|
|
|
|
|
* @blog http://gong.gg/
|
|
|
|
|
* @version 1.0.0
|
|
|
|
|
* @date 2019-01-08
|
|
|
|
|
* @desc description
|
|
|
|
|
* @param [array] $params [输入参数]
|
|
|
|
|
*/
|
2019-01-17 00:37:20 +08:00
|
|
|
|
public static function OrderPayCheck($params = [])
|
2019-01-08 13:59:14 +08:00
|
|
|
|
{
|
|
|
|
|
// 请求参数
|
|
|
|
|
$p = [
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'order_no',
|
|
|
|
|
'error_msg' => '订单号有误',
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'checked_type' => 'empty',
|
|
|
|
|
'key_name' => 'user',
|
|
|
|
|
'error_msg' => '用户信息有误',
|
|
|
|
|
],
|
|
|
|
|
];
|
|
|
|
|
$ret = ParamsChecked($params, $p);
|
|
|
|
|
if($ret !== true)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn($ret, -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取订单状态
|
|
|
|
|
$where = ['order_no'=>$params['order_no'], 'user_id'=>$params['user']['id']];
|
|
|
|
|
$order = Db::name('Order')->where($where)->field('id,pay_status')->find();
|
|
|
|
|
if(empty($order))
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('订单不存在', -400, ['url'=>__MY_URL__]);
|
|
|
|
|
}
|
|
|
|
|
if($order['pay_status'] == 1)
|
|
|
|
|
{
|
|
|
|
|
return DataReturn('支付成功', 0, ['url'=>MyUrl('index/order/detail', ['id'=>$order['id']])]);
|
|
|
|
|
}
|
|
|
|
|
return DataReturn('支付中', -300);
|
|
|
|
|
}
|
|
|
|
|
|
2018-12-28 18:58:37 +08:00
|
|
|
|
}
|
|
|
|
|
?>
|