|
|
<?php
|
|
|
|
|
|
namespace app\mall\service;
|
|
|
|
|
|
use app\distribution\logic\Commission;
|
|
|
use app\distribution\model\DistributionCommissionIncome;
|
|
|
use app\distribution\model\DistributionConfig;
|
|
|
use app\mall\model\MallCart;
|
|
|
use app\mall\model\MallOrder;
|
|
|
use app\mall\model\MallOrderProduct;
|
|
|
use app\mall\model\MallProduct;
|
|
|
use app\mall\model\MallProductSku;
|
|
|
use app\mall\model\MallSpikeProduct;
|
|
|
use app\mall\model\MallSpikeProductSku;
|
|
|
use app\money\logic\Money;
|
|
|
use Godruoyi\Snowflake\Snowflake;
|
|
|
use think\facade\Db;
|
|
|
use think\facade\Request;
|
|
|
|
|
|
class Order extends Base
|
|
|
{
|
|
|
|
|
|
/**
|
|
|
* 获取下单时购买商品数组列表
|
|
|
* @param int $buy_type 购买方式 1--购物车 2--立即购买
|
|
|
* @param int $product_id buy_type=2时，产品ID
|
|
|
* @param string $product_sku buy_type=2时，产品SKU
|
|
|
* @param int $number buy_type=2时，购买数量
|
|
|
* @param int $type 下单类型 1--商城 2--秒杀
|
|
|
* @param int $spike_product_id type=2时，秒杀产品ID
|
|
|
* @date 2022-10-13
|
|
|
*/
|
|
|
public function getOrderProduct($buy_type, $product_id = '', $product_sku = '', $number = 1, $type = 1, $spike_product_id = '')
|
|
|
{
|
|
|
$cart_model = new MallCart();
|
|
|
$product_model = new MallProduct();
|
|
|
$sku_model = new MallProductSku();
|
|
|
$spike_product_model = new MallSpikeProduct();
|
|
|
$spike_sku_model = new MallSpikeProductSku();
|
|
|
|
|
|
// 购物车结算
|
|
|
if ($buy_type == 1) {
|
|
|
$where = [
|
|
|
['uid', '=', $this->mid],
|
|
|
['user_id', '=', $this->userId],
|
|
|
// 是否选中 0-未选中 1--选中
|
|
|
['is_select', '=', 1],
|
|
|
// 是否失效 0--失效 1--有效
|
|
|
['is_effective', '=', 1]
|
|
|
];
|
|
|
$cart_product = $cart_model->getAllCart($where, 'id,product_id,is_product_spec_open,product_sku,number');
|
|
|
|
|
|
// 释放无用字段
|
|
|
foreach ($cart_product as $k => &$v) {
|
|
|
unset($v['product_is_publish']);
|
|
|
unset($v['product_delete_time']);
|
|
|
}
|
|
|
// 立即购买
|
|
|
} else if ($buy_type == 2) {
|
|
|
// 产品
|
|
|
$product = $product_model->getOneData([
|
|
|
['id', '=', $product_id],
|
|
|
['is_publish', '=', 1]
|
|
|
], 'id,name,is_spec_open,stock,cover_img,price,freight_type,freight_id,freight_money,weight');
|
|
|
|
|
|
// 商品有规格
|
|
|
if (!empty($product_sku)) {
|
|
|
$product_sku_list = $sku_model->getOneData([
|
|
|
['product_id', '=', $product_id],
|
|
|
['sku', '=', $product_sku],
|
|
|
], 'id,product_id,sku,cover_img,price,stock');
|
|
|
}
|
|
|
|
|
|
// 秒杀商城（秒杀商城只有立即购买）
|
|
|
if ($type == 2) {
|
|
|
// 秒杀商品
|
|
|
$spike_product = $spike_product_model->getOneData([
|
|
|
['id', '=', $spike_product_id]
|
|
|
]);
|
|
|
|
|
|
// 秒杀有规格
|
|
|
if (!empty($product_sku)) {
|
|
|
$spike_product_sku = $spike_sku_model->getOneData([
|
|
|
['spike_product_id', '=', $spike_product_id],
|
|
|
['sku', '=', $product_sku]
|
|
|
]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$cart_product[] = [
|
|
|
// 产品ID
|
|
|
'product_id' => $product['id'],
|
|
|
// 产品是否开启规格
|
|
|
'is_product_spec_open' => $product['is_spec_open'],
|
|
|
// 产品SKU
|
|
|
'product_sku' => $product_sku,
|
|
|
// 产品购买数量
|
|
|
'number' => $number,
|
|
|
// 产品名称
|
|
|
'product_name' => $product['name'],
|
|
|
// 产品SKU名称
|
|
|
'product_sku_name' => $product['is_spec_open'] == 0 ? '' : $product_sku_list['sku_name'],
|
|
|
// 产品封面图
|
|
|
'product_cover_img' => $product['cover_img'],
|
|
|
|
|
|
// 产品价钱
|
|
|
'product_price' => $product['is_spec_open'] == 0
|
|
|
? ($type == 1 ? $product['price'] : $spike_product['price_spike'])
|
|
|
: ($type == 1 ? $product_sku_list['price'] : $spike_product_sku['price_spike']),
|
|
|
|
|
|
// 产品库存
|
|
|
'product_stock' => $product['is_spec_open'] == 0
|
|
|
? ($type == 1 ? $product['stock'] : $spike_product['number'])
|
|
|
: ($type == 1 ? $product_sku_list['stock'] : $spike_product_sku['number']),
|
|
|
|
|
|
// 运费类型
|
|
|
'freight_type' => $product['freight_type'],
|
|
|
// 运费模板ID
|
|
|
'freight_id' => $product['freight_id'],
|
|
|
// 运费金额
|
|
|
'freight_money' => $product['freight_money'],
|
|
|
// 产品总重量
|
|
|
'weight' => $product['weight'],
|
|
|
// 秒杀产品ID 仅仅立即购买的时候有此字段
|
|
|
'spike_product_id' => $spike_product_id
|
|
|
];
|
|
|
|
|
|
}
|
|
|
return $cart_product;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 产品库存变动
|
|
|
* @param int $product_id 产品ID
|
|
|
* @param int $number 变动数量 >0 增加 <0 减少
|
|
|
* @param string $product_sku 产品SKU
|
|
|
* @param int $order_type 订单类型 1--商城订单 2--秒杀订单
|
|
|
* @param int $spike_product_id 秒杀产品ID
|
|
|
* @date 2022-10-21
|
|
|
*/
|
|
|
public function productStockChange($product_id, $number, $product_sku = '', $order_type = 1, $spike_product_id = '')
|
|
|
{
|
|
|
$product_model = new MallProduct();
|
|
|
$product_sku_model = new MallProductSku();
|
|
|
$spike_product_model = new MallSpikeProduct();
|
|
|
$spike_sku_model = new MallSpikeProductSku();
|
|
|
|
|
|
// 符号
|
|
|
$symbol = $number > 0 ? '+' : '-';
|
|
|
|
|
|
// 更新产品表库存
|
|
|
$product_update_data = [
|
|
|
'id' => $product_id,
|
|
|
'stock' => Db::raw('stock' . $symbol . abs($number))
|
|
|
];
|
|
|
$res = $product_model->dataUpdate($product_update_data);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2001, '更新产品库存失败');
|
|
|
}
|
|
|
|
|
|
// 更新秒杀产品表库存
|
|
|
if ($order_type == 2) { //秒杀商城订单
|
|
|
$spike_product_update_data = [
|
|
|
'id' => $spike_product_id,
|
|
|
'number' => Db::raw('number' . $symbol . abs($number))
|
|
|
];
|
|
|
$res = $spike_product_model->dataUpdate($spike_product_update_data);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2002, '更新秒杀产品库存失败');
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 商品有SKU
|
|
|
if (!empty($product_sku)) {
|
|
|
// 获取SKU_ID
|
|
|
$sku_id = $product_sku_model->getOneData([
|
|
|
['product_id', '=', $product_id],
|
|
|
['sku', '=', $product_sku]
|
|
|
], 'id');
|
|
|
|
|
|
// 如果还能找到该规格项 则减库存 否则暂时不减
|
|
|
if (!empty($sku_id)) {
|
|
|
// 更改产品SKU库存
|
|
|
$product_data_sku = [
|
|
|
'stock' => Db::raw('stock' . $symbol . abs($number))
|
|
|
];
|
|
|
$res = $product_sku_model->dataUpdate($product_data_sku, [
|
|
|
['product_id', '=', $product_id],
|
|
|
['sku', '=', $product_sku]
|
|
|
]);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2003, '更新产品SKU库存失败');
|
|
|
}
|
|
|
|
|
|
// 更改秒杀产品SKU库存
|
|
|
if ($order_type == 2) {
|
|
|
$spike_product_data_sku = [
|
|
|
'number' => Db::raw('number' . $symbol . abs($number))
|
|
|
];
|
|
|
$res = $spike_sku_model->dataUpdate($spike_product_data_sku, [
|
|
|
['spike_product_id', '=', $spike_product_id],
|
|
|
['sku', '=', $product_sku]
|
|
|
]);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2004, '更新库存失败');
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return sendSuccessArray();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 产品销量变动
|
|
|
* @param int $product_id 产品ID
|
|
|
* @param int $number 变动数量 >0 增加 <0 减少
|
|
|
* @param int $order_type 订单类型 1--商城订单 2--秒杀订单
|
|
|
* @param int $spike_product_id 秒杀产品ID
|
|
|
* @date 2022-10-31
|
|
|
*/
|
|
|
public function productSalesChange($product_id, $number, $order_type = 1, $spike_product_id = '')
|
|
|
{
|
|
|
$product_model = new MallProduct();
|
|
|
$spike_product_model = new MallSpikeProduct();
|
|
|
|
|
|
$symbol = $number > 0 ? '+' : '-';
|
|
|
|
|
|
// 更新产品表销量
|
|
|
$product_update_data = [
|
|
|
'id' => $product_id,
|
|
|
'sales_actual_number' => Db::raw('sales_actual_number' . $symbol . abs($number))
|
|
|
];
|
|
|
$res = $product_model->dataUpdate($product_update_data);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2001, '更新产品销量失败');
|
|
|
}
|
|
|
|
|
|
//更新秒杀产品表销量
|
|
|
if ($order_type == 2) {
|
|
|
$spike_product_update_data = [
|
|
|
'id' => $spike_product_id,
|
|
|
'sales_number' => Db::raw('sales_number' . $symbol . abs($number))
|
|
|
];
|
|
|
$res = $spike_product_model->dataUpdate($spike_product_update_data);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2002, '更新秒杀产品销量失败');
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return sendSuccessArray();
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
* 订单支付成功
|
|
|
* @param int $order_id 订单ID
|
|
|
* @param string $transaction_id 微信支付环境：微信支付系统生成的订单号 支付宝支付环境：支付宝交易号
|
|
|
* @date 2022-10-21
|
|
|
*/
|
|
|
public function afterOrderPaySuccess($order_id, $transaction_id = '')
|
|
|
{
|
|
|
$order_model = new MallOrder();
|
|
|
$order_product_model = new MallOrderProduct();
|
|
|
$income_model = new DistributionCommissionIncome();
|
|
|
$config_model = new DistributionConfig();
|
|
|
$commission_logic = new Commission();
|
|
|
$snow_flake_class = new Snowflake();
|
|
|
|
|
|
// 查找订单
|
|
|
$order = $order_model->getOneData([
|
|
|
['id', '=', $order_id]
|
|
|
], 'id,uid,user_agent,type,user_id,pay_money');
|
|
|
|
|
|
// 1 - 更改订单状态
|
|
|
$data_update = [
|
|
|
'id' => $order['id'],
|
|
|
'is_pay' => 1,
|
|
|
'pay_time' => time(),
|
|
|
'status' => 2,
|
|
|
'transaction_id' => $transaction_id
|
|
|
];
|
|
|
|
|
|
$res = $order_model->dataUpdate($data_update);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2001, '订单状态修改失败');
|
|
|
}
|
|
|
|
|
|
// 订单产品表
|
|
|
$order_product = $order_product_model->getAllData([
|
|
|
['order_id', '=', $order_id]
|
|
|
], 'id,product_id,spike_product_id,number');
|
|
|
|
|
|
// 2 - 付款之后，产品增加销量
|
|
|
foreach ($order_product as $k => $v) {
|
|
|
$res = $this->productSalesChange($v['product_id'], $v['number'], $order['type'], $v['spike_product_id']);
|
|
|
if ($res['code'] != 0) {
|
|
|
return $res;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 3 - 存入佣金收入表（佣金在路上）
|
|
|
if ($order['pay_money']) {
|
|
|
// 查找订单产品表的购买商品的名称
|
|
|
$product_name_arr = array_column($order_product->toArray(), 'product_name');
|
|
|
$product_name = implode(',', $product_name_arr);
|
|
|
|
|
|
// 查找分销比例
|
|
|
$config = $config_model->getOneData([
|
|
|
['uid', '=', $order['uid']]
|
|
|
], 'first_percent,first_commission,second_percent,second_commission,third_percent,third_commission');
|
|
|
|
|
|
// 获取上三级以及分销佣金
|
|
|
$commission = $commission_logic->getCommission($order['pay_money'], $order['user_id'], $config);
|
|
|
foreach ($commission as $k => $v) {
|
|
|
$data_income[] = [
|
|
|
'id' => $snow_flake_class->id(),
|
|
|
'uid' => $order['uid'],
|
|
|
'user_agent' => $order['user_agent'],
|
|
|
'user_id' => $order['user_id'],
|
|
|
'distributor_user_id' => $v['user_id'],
|
|
|
'relation_type' => 2,
|
|
|
'money' => $order['pay_money'],
|
|
|
'commission' => $v['commission'],
|
|
|
'rank' => $k + 1,
|
|
|
'show_text' => '购买商品"' . $product_name . '"',
|
|
|
'status' => 1,
|
|
|
'remark' => serialize([
|
|
|
'mall_order_id' => $order['id']
|
|
|
]),
|
|
|
'create_time' => time(),
|
|
|
'update_time' => time()
|
|
|
];
|
|
|
}
|
|
|
if (!empty($data_income)) {
|
|
|
$res = $income_model->insertAll($data_income);
|
|
|
if (!$res) {
|
|
|
return sendErrorArray(2002, '生成佣金记录失败');
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 4 - 统计系统 - 新增订单信息
|
|
|
$statistics_class = new \jucheng\tongji\Statistics();
|
|
|
$statistics_class->updateOrderInfo($order['pay_money']);
|
|
|
|
|
|
return sendSuccessArray();
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
* 调起支付
|
|
|
* @param int $order_id 订单ID
|
|
|
* @date 2022-10-26
|
|
|
*/
|
|
|
public function createPayOrder($order_id)
|
|
|
{
|
|
|
$order_model = new MallOrder();
|
|
|
|
|
|
// 获取订单信息
|
|
|
$order = $order_model->getOneData([
|
|
|
['id', '=', $order_id]
|
|
|
], 'id,user_agent,user_id,order_number,pay_type,pay_money');
|
|
|
|
|
|
// 调起支付
|
|
|
switch ($order['pay_type']) {
|
|
|
// 微信支付
|
|
|
case 1:
|
|
|
$wxpay_param = get_wxpay_config_with_weixin($order['user_agent']);
|
|
|
$wxpay_class = new \tencent\wechat\pay\Wxpay($wxpay_param);
|
|
|
$openid = $this->openid;
|
|
|
$notify_url = Request::domain() . '/index.php/mall/api/Callback/weixinNotify/agent/' . $order['user_agent'] . '/uid/' . $this->mid;
|
|
|
|
|
|
// 生成支付订单
|
|
|
$result = $wxpay_class->createOrder($openid, $order['pay_money'], $order['order_number'], '商城支付订单', $notify_url, $order['user_agent']);
|
|
|
|
|
|
if ($result['return_code'] == 'FAIL' || $result['result_code'] == 'FAIL') {
|
|
|
return sendErrorArray(3100, $result['return_code'] != 'SUCCESS' ? $result['return_msg'] : $result['err_code_des']);
|
|
|
}
|
|
|
|
|
|
/* --H5平台微信支付--
|
|
|
直接返回 */
|
|
|
if ($order['user_agent'] == 'h5') {
|
|
|
// mweb_url为拉起微信支付收银台的中间页面，可通过访问该url来拉起微信客户端，完成支付,mweb_url的有效期为5分钟
|
|
|
return sendSuccessArray(['need_pay' => 1, 'pay_params' => $result['mweb_url']]);
|
|
|
}
|
|
|
|
|
|
/* --其他平台微信支付--
|
|
|
获取支付参数 */
|
|
|
$result_pay = $wxpay_class->wxPay($result['prepay_id'], $order['user_agent']);
|
|
|
|
|
|
return sendSuccessArray([
|
|
|
// 是否需要支付
|
|
|
'need_pay' => 1,
|
|
|
// 支付参数
|
|
|
'pay_params' => $result_pay
|
|
|
]);
|
|
|
break;
|
|
|
// $fubei_param = get_fubei_config();
|
|
|
// switch ($order['user_agent']) {
|
|
|
// // app 支付宝支付
|
|
|
// case 'mp_weixin':
|
|
|
// $mp_weixin_param = get_mp_weixin_config();
|
|
|
// $fubei_param['sub_appid'] = $mp_weixin_param['app_id'];
|
|
|
// break;
|
|
|
// case 'weixin':
|
|
|
// $weixin_param = get_weixin_config();
|
|
|
// $fubei_param['sub_appid'] = $weixin_param['app_id'];
|
|
|
// break;
|
|
|
// }
|
|
|
// $pay_class = new \fubei\pay\Pay($fubei_param);
|
|
|
// $openid = $this->openid;
|
|
|
// $notify_url = Request::domain() . '/index.php/mall/api/Callback/fubeiNotify/agent/' . $order['user_agent'] . '/uid/' . $this->mid;
|
|
|
// $result = $pay_class->pay($openid, $order['pay_money'], $order['order_number'], $order['fubri_order_number'], '商城支付订单', $notify_url, $fubei_param['store_id'], $order['user_agent']);
|
|
|
//
|
|
|
// // 没有调起支付，返回报错
|
|
|
// if ($result['result_code'] != 200) {
|
|
|
// return sendErrorArray($result['result_code'], $result['result_message']);
|
|
|
// }
|
|
|
// return sendSuccessArray([
|
|
|
// // 是否需要支付
|
|
|
// 'need_pay' => 1,
|
|
|
// // 支付参数
|
|
|
// 'pay_params' => $result['data']['sign_package']
|
|
|
// ]);
|
|
|
// break;
|
|
|
// 支付宝支付
|
|
|
case 2:
|
|
|
switch ($order['user_agent']) {
|
|
|
// app 支付宝支付
|
|
|
case 'app':
|
|
|
$ali_pay_param = get_app_alipay_config();
|
|
|
$ali_pay_class = new \ali\alipay\pay\AliPay($ali_pay_param);
|
|
|
|
|
|
$notify_url = Request::domain() . '/index.php/mall/api/Callback/alipayNotify/agent/' . $order['user_agent'] . '/uid/' . $this->mid;
|
|
|
$result = $ali_pay_class->aliPay($order['pay_money'], $order['order_number'], '商城支付订单', $notify_url);
|
|
|
|
|
|
if (empty($result['body'])) {
|
|
|
return sendErrorArray(3101, '生成支付宝订单失败');
|
|
|
}
|
|
|
|
|
|
return sendSuccessArray([
|
|
|
'need_pay' => 1,
|
|
|
'pay_params' => $result['body']
|
|
|
]);
|
|
|
break;
|
|
|
// 支付宝小程序 支付宝支付
|
|
|
case 'mp_alipay':
|
|
|
$ali_pay_param = get_mp_alipay_config();
|
|
|
$ali_pay_class = new \ali\alipay\pay\AliPay($ali_pay_param);
|
|
|
|
|
|
$notify_url = Request::domain() . '/index.php/mall/api/Callback/alipayNotify/agent/' . $order['user_agent'] . '/uid/' . $this->mid;
|
|
|
|
|
|
// 统一下单
|
|
|
$result = $ali_pay_class->mpAliPay($order['pay_money'], $order['order_number'], $this->openid, '商城支付订单', $notify_url);
|
|
|
|
|
|
if ($result['code'] != 10000) {
|
|
|
return sendErrorArray($result['code'], $result['sub_msg']);
|
|
|
}
|
|
|
|
|
|
return sendSuccessArray(['need_pay' => 1, 'pay_params' => $result['trade_no']]);
|
|
|
break;
|
|
|
// H5 支付宝支付
|
|
|
case 'h5':
|
|
|
$ali_pay_param = get_h5_alipay_config();
|
|
|
$ali_pay_class = new \ali\alipay\pay\AliPay($ali_pay_param);
|
|
|
|
|
|
$notify_url = Request::domain() . '/index.php/mall/api/Callback/alipayNotify/agent/' . $order['user_agent'] . '/uid/' . $this->mid;
|
|
|
// 用户付款中途退出返回商户网站的地址 添加该参数后在H5支付收银台会出现返回按钮，可用于用户付款中途退出并返回到该参数指定的商家网站地址
|
|
|
$quit_url = Request::domain() . '/h5/#/pages/mall/my/orderList';
|
|
|
$return_url = $quit_url;
|
|
|
|
|
|
// 统一下单
|
|
|
$result = $ali_pay_class->h5AliPay($order['pay_money'], $order['order_number'], '商城支付订单', $quit_url, $return_url, $notify_url);
|
|
|
|
|
|
if (empty($result['body'])) {
|
|
|
return sendErrorArray(2001, '生成支付宝订单失败');
|
|
|
}
|
|
|
|
|
|
return sendSuccessArray(['need_pay' => 1, 'pay_params' => $result['body']]);
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
break;
|
|
|
// 余额支付
|
|
|
case 3:
|
|
|
$money_service = new \app\money\service\Money();
|
|
|
|
|
|
Db::startTrans();
|
|
|
//支付成功
|
|
|
$res = $this->afterOrderPaySuccess($order_id);
|
|
|
if ($res['code'] != 0) {
|
|
|
Db::rollback();
|
|
|
return $res;
|
|
|
}
|
|
|
// 扣除余额
|
|
|
$res = $money_service->change($order['user_id'], 2, -$order['pay_money'], '商城购物', $order['order_number'], [
|
|
|
'mall_order_id' => $order_id
|
|
|
]);
|
|
|
if ($res['code'] != 0) {
|
|
|
Db::rollback();
|
|
|
return $res;
|
|
|
}
|
|
|
|
|
|
Db::commit();
|
|
|
return sendSuccessArray(['need_pay' => 0], '支付成功');
|
|
|
break;
|
|
|
// 其他
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
