mkm/multi-store
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

处理支付成功后通用商品统计逻辑

Browse Source
This commit is contained in:
liu 2024-06-20 17:30:23 +08:00
parent eb57117246
commit 36d1131c3e
2 changed files with 47 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/api/logic/order/OrderLogic.php
View File

@ -192,7 +192,7 @@ class OrderLogic extends BaseLogic
}
$_order = $orderInfo['order'];
$_order['uid'] = $user['id'];
$_order['spread_uid'] =$params['spread_uid']??0;// UserSpreadLog::where('uid',request()->userId)->value('old_spread_uid')??0;//预留分享关系
$_order['spread_uid'] =$params['spread_uid']??0;
$_order['real_name'] = $user['real_name'];
$_order['mobile'] = $user['mobile'];
$_order['pay_type'] = $orderInfo['order']['pay_type'];

46
app/common/logic/PayNotifyLogic.php
View File

@ -12,6 +12,7 @@ use app\common\model\pay\PayNotify;
use app\common\model\store_finance_flow\StoreFinanceFlow;
use app\common\model\store_order\StoreOrder;
use app\common\model\store_order_cart_info\StoreOrderCartInfo;
use app\common\model\store_product_log\StoreProductLog;
use app\common\model\system_store\SystemStore;
use app\common\model\user\User;
use app\common\model\user\UserAddress;
@ -87,6 +88,7 @@ class PayNotifyLogic extends BaseLogic
}
$capitalFlowDao = new CapitalFlowLogic($user);
$capitalFlowDao->userExpense('user_order_balance_pay', 'order', $order['id'], $order['pay_price'],'',0,$order['store_id']);
self::dealProductLog($order);
// self::afterPay($order);
// Redis::send('push-platform-print', ['id' => $order['id']], 60);
// PushService::push('store_merchant_' . $order['store_id'], $order['store_id'], ['type' => 'store_merchant', 'msg' => '您有一笔新的订单']);
@ -133,6 +135,7 @@ class PayNotifyLogic extends BaseLogic
];
OrderLogic::writeOff($params);
}
self::dealProductLog($order);
// self::afterPay($order);
// Redis::send('push-platform-print', ['id' => $order['id']], 60);
@ -171,6 +174,7 @@ class PayNotifyLogic extends BaseLogic
$capitalFlowDao->userExpense('user_order_pay', 'order', $order['id'], $order->pay_price, '', 1,$order['store_id']);
}
self::dealProductLog($order);
// if ($order->pay_type == 9) {
// $extra['create_time'] = $order['create_time'];
@ -268,6 +272,7 @@ class PayNotifyLogic extends BaseLogic
self::afterPay($order);
$cashFlowLogic = new CashFlowLogic();
$cashFlowLogic->insert($order['store_id'], $order['pay_price']);
self::dealProductLog($order);
// Redis::send('push-platform-print', ['id' => $order['id']]);
}
@ -298,6 +303,7 @@ class PayNotifyLogic extends BaseLogic
$order->status = 2;
self::afterPay($order);
}
self::dealProductLog($order);
// if ($order->pay_type == 9) {
// $extra['create_time'] = $order['create_time'];
@ -552,4 +558,44 @@ class PayNotifyLogic extends BaseLogic
return true;
}
/**
* 商品统计逻辑
* @param $order
* @return true
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public static function dealProductLog($order)
{
$store_id = $order['store_id'];
$cart_id = $order['cart_id'];
$uid = $order['uid'];
if($uid && $cart_id && $store_id){
$cart_id = explode(',',$cart_id);
$productLog = StoreProductLog::where([
'uid'=>$uid
])->whereIn('cart_id',$cart_id)
->select()->toArray();
foreach ($productLog as &$value){
$value['pay_uid'] = $uid;
$value['oid'] = $order['id'];
$cart_info = StoreOrderCartInfo::where([
'uid'=>$uid,'old_cart_id'=>$value['cart_id'],'store_id'=>$store_id
])->find();
$value['order_num'] = $cart_info['cart_num']??1;
$value['pay_num'] = $cart_info['cart_num']??1;
$value['pay_price'] = $cart_info['price']??0;
$value['cost_price'] = $cart_info['cart_info']['cost']??0;
$value['update_time'] = time();
unset($value['create_time'],$value['delete_time']);
}
(new StoreProductLog())->saveAll($productLog);
}
return true;
}
}