拆单逻辑
This commit is contained in:
liu
parent
454a0ea3ad
commit
2ead3b7fd2
@ -475,16 +475,26 @@ class OrderController extends BaseApiController
|
||||
return $this->success('ok', ['order_count' => $res]);
|
||||
}
|
||||
|
||||
|
||||
//订单退款申请
|
||||
|
||||
#[
|
||||
ApiDoc\Title('订单退款申请'),
|
||||
ApiDoc\url('/api/order/order/apply_refund'),
|
||||
ApiDoc\Method('POST'),
|
||||
ApiDoc\Param(name: "refund_message", type: "string", require: true, desc: "退款原因"),
|
||||
ApiDoc\Param(name: "refund_num", type: "int", require: true, desc: "退款数量"),
|
||||
ApiDoc\Param(name: "id", type: "int", require: true, desc: "订单id"),
|
||||
ApiDoc\Param(name: "old_cart_id", type: "int", require: true, desc: "购物车id"),
|
||||
ApiDoc\NotHeaders(),
|
||||
ApiDoc\Header(name: "token", type: "string", require: true, desc: "token"),
|
||||
ApiDoc\ResponseSuccess("data", type: "array"),
|
||||
]
|
||||
public function apply_refund()
|
||||
{
|
||||
$params = (new OrderValidate())->post()->goCheck('add');
|
||||
$uid = $this->userId;
|
||||
// OrderLogic::dealRefund($uid,$params);
|
||||
|
||||
|
||||
|
||||
//拆单逻辑
|
||||
OrderLogic::dealRefund($uid,$params);
|
||||
return $this->success('申请成功');
|
||||
}
|
||||
|
||||
|
||||
|
||||
@ -51,7 +51,7 @@ class OrderList extends BaseAdminDataLists implements ListsSearchInterface
|
||||
->each(function($item){
|
||||
$item['goods_list']=StoreOrderCartInfo::where('oid',$item['id'])->with(['goodsName'=> function ($query) {
|
||||
$query->withTrashed();
|
||||
}])->field('product_id,cart_num,verify_code,is_writeoff,writeoff_time')->limit(3)->select();
|
||||
}])->field('product_id,cart_num,verify_code,is_writeoff,writeoff_time,old_cart_id')->limit(3)->select();
|
||||
$item['goods_count']=count(explode(',',$item['cart_id']));
|
||||
})
|
||||
->toArray();
|
||||
|
||||
@ -23,10 +23,12 @@ use app\common\model\system_store\SystemStoreStaff;
|
||||
use app\common\model\user\User;
|
||||
use app\common\model\user\UserAddress;
|
||||
use app\common\model\user\UserShip;
|
||||
use support\exception\BusinessException;
|
||||
use support\Log;
|
||||
use taoser\exception\ValidateException;
|
||||
use think\Exception;
|
||||
use think\facade\Db;
|
||||
use Workerman\Events\Select;
|
||||
use Yansongda\Pay\Event\PayEnd;
|
||||
|
||||
/**
|
||||
@ -47,7 +49,7 @@ class OrderLogic extends BaseLogic
|
||||
{
|
||||
|
||||
$where = ['is_pay' => 0];
|
||||
$cart_select = Cart::whereIn('id', $cartId)->where($where)->field('product_id as goods,cart_num')->select()->toArray();
|
||||
$cart_select = Cart::whereIn('id', $cartId)->where($where)->field('id,product_id as goods,cart_num')->select()->toArray();
|
||||
if (empty($cart_select)) {
|
||||
self::setError('购物车为空');
|
||||
return false;
|
||||
@ -63,12 +65,18 @@ class OrderLogic extends BaseLogic
|
||||
$cart_select[$k]['total'] = bcmul($v['cart_num'], $find['price'], 2);//钱
|
||||
$cart_select[$k]['price'] = $find['price'];
|
||||
$cart_select[$k]['product_id'] = $v['goods'];
|
||||
$cart_select[$k]['old_cart_id'] = implode(',', $cartId);
|
||||
$cart_select[$k]['old_cart_id'] = $v['id'];
|
||||
$cart_select[$k]['cart_num'] = $v['cart_num'];
|
||||
$cart_select[$k]['verify_code'] = $params['verify_code'] ?? '';
|
||||
$cartInfo = $cart_select[$k];
|
||||
$cartInfo['name'] = $find['store_name'];
|
||||
$cartInfo['image'] = $find['image'];
|
||||
//计算好vip价格
|
||||
$vipPrice = self::dealVip($find['price']);
|
||||
if($vipPrice){
|
||||
$cartInfo['price'] = $vipPrice;
|
||||
}
|
||||
$cartInfo['vip_price'] = $cart_select[$k]['total'] - $vipPrice??0;
|
||||
$cart_select[$k]['cart_info'] = json_encode($cartInfo);
|
||||
//理论上每笔都是拆分了
|
||||
$cart_select[$k]['name'] = $find['store_name'];
|
||||
@ -141,7 +149,7 @@ class OrderLogic extends BaseLogic
|
||||
*/
|
||||
static public function createOrder($cartId, $addressId, $user = null, $params = [])
|
||||
{
|
||||
$verify_code = generateUniqueVerificationCode();
|
||||
$verify_code = verificationCode();
|
||||
$params['verify_code'] = $verify_code;
|
||||
$orderInfo = self::cartIdByOrderInfo($cartId, $addressId, $user, $params);
|
||||
if (!$orderInfo) {
|
||||
@ -585,4 +593,198 @@ class OrderLogic extends BaseLogic
|
||||
'count'=>$count
|
||||
];
|
||||
}
|
||||
|
||||
public static function dealRefund($uid,$params)
|
||||
{
|
||||
//todo 单子不是完成的不允许退款
|
||||
//单笔不拆单子直接修改状态
|
||||
$order = StoreOrder::where('id',$params['id'])->withTrashed()->findOrEmpty();
|
||||
if(count($params['old_cart_id']) ==1){
|
||||
$order->refund_status = OrderEnum::REFUND_STATUS_YES;
|
||||
$order->status = OrderEnum::ALREADY_REFUND;
|
||||
$order->refund_reason_wap_explain =$params['refund_message']??'';
|
||||
$order->refund_num = $params['refund_num'];
|
||||
$refund_price_cart = StoreOrderCartInfo::where('oid',$params['id'])
|
||||
->field('id,oid,cart_info')
|
||||
->find()->toArray();
|
||||
$vipPrice = $order['vip_price'];
|
||||
$price = $refund_price_cart['cart_info']['price'] * $params['refund_num'];
|
||||
$onePrice = 0;
|
||||
bcscale(2);
|
||||
if($vipPrice){
|
||||
//每单的vip价格
|
||||
$onePrice = bcdiv($vipPrice, $refund_price_cart['cart_info']['cart_num']);
|
||||
}
|
||||
if($price > $onePrice){
|
||||
$price =bcsub($price, $onePrice);
|
||||
}
|
||||
$order->refund_price = $price;
|
||||
$order->save();
|
||||
}else{
|
||||
// 多单的情况 拆主订单为新的2单 修改新的2单的核销码 修改cart_info的核销码 和订单id 退款直接退一单的钱
|
||||
$order->delete_time = time();
|
||||
$order->save();
|
||||
Db::startTrans();
|
||||
try {
|
||||
$order = $order->toArray();
|
||||
$cart_info = StoreOrderCartInfo::where('oid',$params['id'])
|
||||
->whereNotIn('old_cart_id',$params['old_cart_id'])
|
||||
->select()->toArray();
|
||||
if($cart_info){
|
||||
$leftOrder = self::dealCreateLeftOrder($order,$cart_info);
|
||||
self::dealChangeCartInfo($leftOrder);
|
||||
}
|
||||
$refundOrder = self::dealCreateRefundOrder($order,$params);
|
||||
self::dealChangeCartInfo($refundOrder);
|
||||
// d($leftOrder,$refundOrder);
|
||||
Db::commit();
|
||||
} catch (\Exception $e) {
|
||||
// 回滚事务
|
||||
Db::rollback();
|
||||
throw new BusinessException($e->getMessage());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
|
||||
public static function dealChangeCartInfo($leftOrder)
|
||||
{
|
||||
$code = $leftOrder->verify_code;
|
||||
$new_oid = $leftOrder->id;
|
||||
$old_id = $leftOrder->pid;
|
||||
$car_id = explode(',',$leftOrder->cart_id);
|
||||
return StoreOrderCartInfo::where('oid',$old_id)
|
||||
->whereIn('old_cart_id',$car_id)
|
||||
->update([
|
||||
'oid'=>$new_oid,
|
||||
'verify_code'=>$code
|
||||
]);
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static function dealCreateLeftOrder($order,$cart_info)
|
||||
{
|
||||
//查出不在这个退货中的数据
|
||||
$order['order_id'] = $order['order_id'].'-2';
|
||||
$order['pid'] = $order['id'];
|
||||
unset($order['id']);
|
||||
$allOldCartIds =[];
|
||||
$totalTotal = 0;
|
||||
$totalPrice = 0;
|
||||
$totalVipPrice = 0;
|
||||
foreach ($cart_info as $value){
|
||||
if (isset($value['old_cart_id'])) {
|
||||
$allOldCartIds[] = $value['old_cart_id'];
|
||||
}
|
||||
if (isset($value['cart_info'])) {
|
||||
if (isset($value['cart_info']['total'])) {
|
||||
$totalTotal += floatval($value['cart_info']['total']);
|
||||
}
|
||||
if (isset($value['cart_info']['price'])) {
|
||||
$totalPrice += floatval($value['cart_info']['price']);
|
||||
}
|
||||
if (isset($value['cart_info']['vip_price'])) {
|
||||
$totalVipPrice += floatval($value['cart_info']['vip_price']);
|
||||
}
|
||||
}
|
||||
}
|
||||
$order['cart_id'] = implode(',',$allOldCartIds);
|
||||
$order['total_num'] = count($cart_info);
|
||||
$order['total_price'] = number_format($totalTotal, 2);
|
||||
$order['pay_price'] = number_format($totalPrice, 2);
|
||||
$order['vip_price'] = number_format($totalVipPrice, 2);
|
||||
$order['verify_code'] = verificationCode();
|
||||
$order['create_time'] = time();
|
||||
$order['update_time'] = null;
|
||||
$order['delete_time'] = null;
|
||||
return StoreOrder::create($order);
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static function dealCreateRefundOrder($order,$params)
|
||||
{
|
||||
$order['order_id'] = $order['order_id'].'-1';
|
||||
$order['pid'] = $order['id'];
|
||||
unset($order['id']);
|
||||
$order['cart_id'] = implode(',',$params['old_cart_id']);
|
||||
|
||||
$order['refund_status'] = OrderEnum::REFUND_STATUS_YES;
|
||||
$order['status'] = OrderEnum::ALREADY_REFUND;
|
||||
$order['refund_num'] = $params['refund_num'];//按数量整单退剩余的
|
||||
$order['refund_reason_wap_explain'] = $params['refund_message']??'';
|
||||
$order['total_num'] = count($params['old_cart_id']);
|
||||
$refund_price_cart = StoreOrderCartInfo::whereIn('old_cart_id',$params['old_cart_id'])
|
||||
->field('id,oid,cart_info')
|
||||
->select()->toArray();
|
||||
$totalTotals = array_column(array_column($refund_price_cart, 'cart_info'), 'total');
|
||||
$totalTotal = array_reduce($totalTotals, function ($carry, $item) {
|
||||
return $carry + $item;
|
||||
}, 0);
|
||||
$totalPrices = array_column(array_column($refund_price_cart, 'cart_info'), 'price');
|
||||
$totalPrice = array_reduce($totalPrices, function ($carry, $item) {
|
||||
return $carry + $item;
|
||||
}, 0);
|
||||
|
||||
$totalVipPrices = array_column(array_column($refund_price_cart, 'cart_info'), 'vip_price');
|
||||
$totalVipPrices = array_reduce($totalVipPrices, function ($carry, $item) {
|
||||
return $carry + $item;
|
||||
}, 0);
|
||||
|
||||
$order['total_price'] = number_format($totalTotal, 2);
|
||||
$order['pay_price'] = number_format($totalPrice, 2);
|
||||
$order['vip_price'] = number_format($totalVipPrices, 2);
|
||||
$order['refund_price'] = number_format($totalPrice, 2);
|
||||
$order['verify_code'] = verificationCode();
|
||||
$order['create_time'] = time()+1;
|
||||
$order['update_time'] = null;
|
||||
$order['delete_time'] = null;
|
||||
return StoreOrder::create($order);
|
||||
|
||||
}
|
||||
|
||||
|
||||
public static function dealVip($pay_price)
|
||||
{
|
||||
$check = DictType::where('type','activities')->find();
|
||||
if(isset($check) && $check['status'] == 1){
|
||||
// $discountRate = '0.99';//首单逻辑
|
||||
$discountRate = $check['remark'];
|
||||
$discountRate = bcdiv($discountRate, '100', 2);
|
||||
$pay_price = bcdiv(bcmul($pay_price, $discountRate, 4), '1', 2);
|
||||
}else{
|
||||
$userVip = User::where('id',\request()->userId)->value('user_ship');
|
||||
if($userVip){
|
||||
switch ($userVip){
|
||||
case UserShipEnum::VIP1:
|
||||
$discountRate = UserShip::where('id',UserShipEnum::VIP1)->value('discount');
|
||||
break;
|
||||
case UserShipEnum::VIP2:
|
||||
$discountRate = UserShip::where('id',UserShipEnum::VIP2)->value('discount');
|
||||
break;
|
||||
case UserShipEnum::VIP3:
|
||||
$discountRate = UserShip::where('id',UserShipEnum::VIP3)->value('discount');
|
||||
break;
|
||||
case UserShipEnum::VIP4:
|
||||
$discountRate = UserShip::where('id',UserShipEnum::VIP4)->value('discount');
|
||||
break;
|
||||
case UserShipEnum::VIP5:
|
||||
$discountRate = UserShip::where('id',UserShipEnum::VIP5)->value('discount');
|
||||
break;
|
||||
default:
|
||||
$discountRate = 1;
|
||||
}
|
||||
$discountRate = bcdiv($discountRate, '100', 2);
|
||||
$pay_price = bcdiv(bcmul($pay_price, $discountRate, 4), '1', 2);
|
||||
}
|
||||
}
|
||||
return $pay_price;
|
||||
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
@ -18,6 +18,10 @@ class OrderValidate extends BaseValidate
|
||||
*/
|
||||
protected $rule = [
|
||||
'verify_code' => 'require',
|
||||
'refund_message' => 'require',
|
||||
'refund_num' => 'require|number',
|
||||
'id' => 'require|number',
|
||||
'old_cart_id' => 'require|array',
|
||||
];
|
||||
|
||||
|
||||
@ -27,6 +31,10 @@ class OrderValidate extends BaseValidate
|
||||
*/
|
||||
protected $field = [
|
||||
'verify_code' => '验证码',
|
||||
'refund_message' => '退款原因',
|
||||
'refund_num' => '退款数量',
|
||||
'id' => '订单id',
|
||||
'old_cart_id' => '购物车id',
|
||||
];
|
||||
|
||||
|
||||
@ -41,6 +49,15 @@ class OrderValidate extends BaseValidate
|
||||
return $this->only(['verify_code']);
|
||||
}
|
||||
|
||||
/**
|
||||
* @notes 退款场景
|
||||
* @return OrderValidate
|
||||
*/
|
||||
public function sceneAdd()
|
||||
{
|
||||
return $this->only(['refund_message','refund_num','id','old_cart_id']);
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
@ -360,6 +360,22 @@ if (!function_exists('generateUniqueVerificationCode')) {
|
||||
|
||||
}
|
||||
|
||||
|
||||
if (!function_exists('verificationCode')) {
|
||||
function verificationCode() {
|
||||
$sec = time();
|
||||
// 将前缀、秒时间戳和随机数连接起来
|
||||
$type = rand(1, 10); // 生成一个1-10之间的随机数作为前缀
|
||||
$code = $type .'-'. $sec;
|
||||
$check = \app\common\model\store_order\StoreOrder::where('verify_code',$code)->count();
|
||||
if($check){
|
||||
verificationCode();
|
||||
}
|
||||
return $code;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
if (!function_exists('haversineDistance')) {
|
||||
function haversineDistance($latitude1, $longitude1, $latitude2, $longitude2) {
|
||||
$earthRadius = 6371; // 地球平均半径，单位是千米
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user